流程优化

field_sync/main.go

@@ -66,20 +66,20 @@ func main() {
 	UdpClient.Listen(processUdpMsg)
 	log.Println("Udp服务监听 port:", config.Conf.Udp.LocPort)
 
-	info, _ := MgoB.Find("bidding_processing_ids", `{"dataprocess": 6}`, bson.M{"_id": 1}, nil, false, -1, -1)
-	log.Println(len(*info))
-	log.Println("size", len(*info))
-	if len(*info) > 0 {
-		for _, m := range *info {
-			mapInfo := make(map[string]interface{})
-			mapInfo["gtid"] = util.ObjToString(m["gtid"])
-			mapInfo["lteid"] = util.ObjToString(m["lteid"])
-			mapInfo["stype"] = "bidding"
-			mapInfo["key"] = fmt.Sprintf("%s-%s-bidding", util.ObjToString(m["gtid"]), util.ObjToString(m["lteid"]))
-			log.Println("--", mapInfo)
-			biddingTask(nil, mapInfo)
-		}
-	}
+	// info, _ := MgoB.Find("bidding_processing_ids", `{"dataprocess": 7}`, bson.M{"_id": 1}, nil, false, -1, -1)
+	// log.Println(len(*info))
+	// log.Println("size", len(*info))
+	// if len(*info) > 0 {
+	// 	for _, m := range *info {
+	// 		mapInfo := make(map[string]interface{})
+	// 		mapInfo["gtid"] = util.ObjToString(m["gtid"])
+	// 		mapInfo["lteid"] = util.ObjToString(m["lteid"])
+	// 		mapInfo["stype"] = "bidding"
+	// 		mapInfo["key"] = fmt.Sprintf("%s-%s-bidding", util.ObjToString(m["gtid"]), util.ObjToString(m["lteid"]))
+	// 		log.Println("--", mapInfo)
+	// 		biddingTask(nil, mapInfo)
+	// 	}
+	// }
 
 	ch := make(chan bool, 1)
 	<-ch

field_sync/task.go

@@ -109,7 +109,7 @@ func biddingTask(data []byte, mapInfo map[string]interface{}) {
 				"$lte": util.ObjToString(mapInfo["lteid"]),
 			},
 		}
-		MgoB.Update("bidding_processing_ids", uq, bson.M{"$set": bson.M{"dataprocess": 7, "updatetime": time.Now().Unix()}}, false, true)
+		MgoB.Update("bidding_processing_ids", uq, bson.M{"$set": bson.M{"dataprocess": 8, "updatetime": time.Now().Unix()}}, false, true)
 	}
 	//领域标签处理的数据 id段
 	if stype == "bidding_history" {

field_sync_ai/main.go

@@ -67,20 +67,20 @@ func main() {
 	UdpClient.Listen(processUdpMsg)
 	log.Println("Udp服务监听 port:", config.Conf.Udp.LocPort)
 
-	info, _ := MgoBP.Find("bidding_processing_ids", `{"dataprocess_ai": 5}`, bson.M{"_id": 1}, nil, false, -1, -1)
-	log.Println(len(*info))
-	log.Println("size", len(*info))
-	if len(*info) > 0 {
-		for _, m := range *info {
-			mapInfo := make(map[string]interface{})
-			mapInfo["gtid"] = util.ObjToString(m["gtid"])
-			mapInfo["lteid"] = util.ObjToString(m["lteid"])
-			mapInfo["stype"] = "bidding"
-			mapInfo["key"] = fmt.Sprintf("%s-%s-bidding", util.ObjToString(m["gtid"]), util.ObjToString(m["lteid"]))
-			log.Println("--", mapInfo)
-			biddingTask(nil, mapInfo)
-		}
-	}
+	// info, _ := MgoBP.Find("bidding_processing_ids", `{"dataprocess_ai": 6}`, bson.M{"_id": 1}, nil, false, -1, -1)
+	// log.Println(len(*info))
+	// log.Println("size", len(*info))
+	// if len(*info) > 0 {
+	// 	for _, m := range *info {
+	// 		mapInfo := make(map[string]interface{})
+	// 		mapInfo["gtid"] = util.ObjToString(m["gtid"])
+	// 		mapInfo["lteid"] = util.ObjToString(m["lteid"])
+	// 		mapInfo["stype"] = "bidding"
+	// 		mapInfo["key"] = fmt.Sprintf("%s-%s-bidding", util.ObjToString(m["gtid"]), util.ObjToString(m["lteid"]))
+	// 		log.Println("--", mapInfo)
+	// 		biddingTask(nil, mapInfo)
+	// 	}
+	// }
 
 	ch := make(chan bool, 1)
 	<-ch

field_sync_ai/task.go

@@ -76,7 +76,7 @@ func biddingTask(data []byte, mapInfo map[string]interface{}) {
 				"$lte": util.ObjToString(mapInfo["lteid"]),
 			},
 		}
-		MgoBP.Update("bidding_processing_ids", uq, bson.M{"$set": bson.M{"dataprocess_ai": 6, "updatetime": time.Now().Unix()}}, false, true)
+		MgoBP.Update("bidding_processing_ids", uq, bson.M{"$set": bson.M{"dataprocess_ai": 7, "updatetime": time.Now().Unix()}}, false, true)
 	}
 	//领域标签处理的数据 id段
 	// if stype == "bidding_history" {