修改判重

field_sync/task.go

@@ -172,7 +172,9 @@ func biddingAllTask(data []byte, mapInfo map[string]interface{}) {
 					if util.IntAll(compare["repeat"]) == 1 {
 						update["extracttype"] = -1
 						update["dataprocess"] = 7
-						update["repeat_id"] = compare["repeat_id"]
+						if compare["repeat_id"] != nil {
+							update["repeat_id"] = compare["repeat_id"]
+						}
 					} else {
 						update["extracttype"] = 1
 						update["dataprocess"] = 8
@@ -304,7 +306,9 @@ func doIndex(infos []map[string]interface{}, eMap map[string]map[string]interfac
 			if util.IntAll(compare["repeat"]) == 1 {
 				update["extracttype"] = -1
 				update["dataprocess"] = 7
-				update["repeat_id"] = compare["repeat_id"]
+				if compare["repeat_id"] != nil {
+					update["repeat_id"] = compare["repeat_id"]
+				}
 			} else {
 				update["extracttype"] = 1
 				update["dataprocess"] = 8
@@ -678,7 +682,9 @@ func taskinfo(id string) {
 	if util.IntAll((*extractM)["repeat"]) == 1 {
 		update["extracttype"] = -1
 		update["dataprocess"] = 7
-		update["repeat_id"] = (*extractM)["repeat_id"]
+		if (*extractM)["repeat_id"] != nil {
+			update["repeat_id"] = (*extractM)["repeat_id"]
+		}
 	} else {
 		update["extracttype"] = 1
 		update["dataprocess"] = 8