定时任务-符合条件-均更新标签

udpfilterdup/src/main.go

@@ -858,6 +858,17 @@ func timedTaskOnce() {
 						},
 					},
 				})
+			}else {
+				updateExtract = append(updateExtract, []map[string]interface{}{
+					map[string]interface{}{
+						"_id": tmp["_id"],
+					},
+					map[string]interface{}{
+						"$set": map[string]interface{}{
+							"dataging": 0,//符合条件的都为dataging==0
+						},
+					},
+				})
 			}
 			if len(updateExtract) > 500 {
 				mgo.UpSertBulk(extract, updateExtract...)