log

udp_winner/timedTaskAgency.go

@@ -57,7 +57,9 @@ func TaskAgency(mapinfo *map[string]interface{}) {
 		//遍历bidding表保存到redis
 		//key：企业名  value:json结构体{"agency": 1, "agencytel": 1, "agencyperson": 1,"topscopeclass": 1, "agencyaddr": 1,"_id":1}
 		tmp := make(map[string]interface{})
+		var num int
 		for cursor.Next(&tmp) {
+			num++
 			agency, ok := tmp["agency"].(string)
 			if !ok || utf8.RuneCountInString(agency) < 4 {
 				continue
@@ -82,7 +84,7 @@ func TaskAgency(mapinfo *map[string]interface{}) {
 				log.Println(err)
 			}
 		}
-
+		log.Println("存量 agency mongo遍历完成:",num)
 		SourceClient.DestoryMongoConn(SourceClientcc)
 
 		//遍历redis

udp_winner/timedTaskBuyer.go

@@ -57,7 +57,9 @@ func TaskBuyer(mapinfo *map[string]interface{}) {
 		//遍历bidding表保存到redis
 		//key：企业名  value:json结构体{"buyer": 1, "buyertel": 1, "buyerperson": 1,"topscopeclass": 1, "buyeraddr": 1,"_id":1}
 		tmp := make(map[string]interface{})
+		var num int
 		for cursor.Next(&tmp) {
+			num++
 			buyer, ok := tmp["buyer"].(string)
 			if !ok || utf8.RuneCountInString(buyer) < 4 {
 				continue
@@ -82,7 +84,7 @@ func TaskBuyer(mapinfo *map[string]interface{}) {
 				log.Println(err)
 			}
 		}
-
+		log.Println("存量buyer mongo遍历完成:",num)
 		SourceClient.DestoryMongoConn(SourceClientcc)
 
 		//遍历redis

udp_winner/timedTaskWinner.go

@@ -57,7 +57,9 @@ func TaskWinner(mapinfo *map[string]interface{}) {
 		//遍历bidding表保存到redis
 		//key：企业名  value:json结构体{"winner": 1, "winnertel": 1, "winnerperson": 1,"topscopeclass": 1, "winneraddr": 1,"_id":1}
 		tmp := make(map[string]interface{})
+		var num int
 		for cursor.Next(&tmp) {
+			num++
 			winner, ok := tmp["winner"].(string)
 			if !ok || utf8.RuneCountInString(winner) < 4 {
 				continue
@@ -129,6 +131,7 @@ func TaskWinner(mapinfo *map[string]interface{}) {
 				log.Println(err)
 			}
 		}
+		log.Println("存量 winner mongo遍历完成:",num)
 		SourceClient.DestoryMongoConn(SourceClientcc)
 		//遍历redis
 		if scan := conn.Scan(0, "", 100); scan.Err() != nil {