zhangjinkun 5 жил өмнө
parent
commit
04371fdede

+ 2 - 1
udpcreateindex/src/biddingall.go

@@ -97,7 +97,8 @@ func biddingAllTask(data []byte, mapInfo map[string]interface{}) {
 					}
 					if qutil.IntAll(compare["repeat"]) == 1 {
 						update["extracttype"] = -1
-					} else if qutil.IntAll(tmp["extracttype"]) == -1 {
+						//} else if qutil.IntAll(tmp["extracttype"]) == -1 {
+					} else {
 						update["extracttype"] = 1
 					}
 					break

+ 2 - 1
udpcreateindex/src/biddingdata.go

@@ -134,7 +134,8 @@ func biddingDataTask(data []byte, mapInfo map[string]interface{}) {
 					}
 					if qutil.IntAll(compare["repeat"]) == 1 {
 						update["extracttype"] = -1
-					} else if qutil.IntAll(tmp["extracttype"]) == -1 {
+						//} else if qutil.IntAll(tmp["extracttype"]) == -1 {
+					} else {
 						update["extracttype"] = 1
 					}
 					break

+ 2 - 0
udpcreateindex/src/biddingindexback.go

@@ -73,6 +73,8 @@ func biddingBackTask(data []byte, mapInfo map[string]interface{}) {
 		if qutil.IntAll(tmp["extracttype"]) == -1 {
 			tmp = make(map[string]interface{})
 			continue
+		} else {
+			tmp["extracttype"] = 1
 		}
 		ct := qutil.Int64All(tmp["comeintime"])
 		pt := qutil.Int64All(tmp["publishtime"])

+ 2 - 1
udpcreateindex/src/biddingmerge.go

@@ -93,7 +93,8 @@ func biddingMergeTask(data []byte, mapInfo map[string]interface{}) {
 					}
 					if qutil.IntAll(compare["repeat"]) == 1 {
 						update["extracttype"] = -1
-					} else if qutil.IntAll(tmp["extracttype"]) == -1 {
+						//} else if qutil.IntAll(tmp["extracttype"]) == -1 {
+					} else {
 						update["extracttype"] = 1
 					}
 					break