判重—repeat_ids

src/increaseRepeat.go

@@ -79,6 +79,18 @@ func increaseRepeat(mapInfo map[string]interface{}) {
 					repeat_ids =  append(repeat_ids,info.id)
 					source.repeat_ids = repeat_ids
 					DM.replacePoolData(source)//替换数据池-更新
+
+					Update.updatePool <- []map[string]interface{}{//原始数据打标签
+						map[string]interface{}{
+							"_id": StringTOBsonId(source.id),
+						},
+						map[string]interface{}{
+							"$set": map[string]interface{}{
+								"repeat_ids": repeat_ids,
+							},
+						},
+					}
+
 					Update.updatePool <- []map[string]interface{}{//重复数据打标签
 						updateID,
 						map[string]interface{}{

src/main.go

@@ -173,7 +173,7 @@ func getRepeatTask()  {
 }
 
 
-func main() {
+func mainT() {
 	IsFull = true
 	sid := "1fffffffffffffffffffffff"
 	eid := "9fffffffffffffffffffffff"
@@ -184,7 +184,7 @@ func main() {
 }
 
 //主函数
-func mainT() {
+func main() {
 	go checkMapJob()
 	updport := Sysconfig["udpport"].(string)
 	udpclient = mu.UdpClient{Local: updport, BufSize: 1024}

work_repeat/src/config.json

@@ -1,7 +1,7 @@
 {
 	"mgo_addr": "127.0.0.1:27017",
 	"mgo_db": "zhengkun",
-	"mgo_table": "repeat_test",
+	"mgo_table": "zktest_mysql_bidding_repeat_0221",
 	"mgo_sort": "-1",
 	"cycle_month": 12
 }