wcc 1 ay önce
ebeveyn
işleme
10f43f4ab6
1 değiştirilmiş dosya ile 6 ekleme ve 11 silme
  1. 6 11
      createEsIndex/bidding_es.go

+ 6 - 11
createEsIndex/bidding_es.go

@@ -91,14 +91,14 @@ func biddingTask(mapInfo map[string]interface{}) {
 			//}
 			//// 增量数据使用上面判断;全量数据使用下面配置
 			//-1:重复 ,1:不重复 ,0:入库 9:分类
-			//if util.IntAll(tmp["extracttype"]) != 1 {
-			//	return
-			//}
-
-			// 优选字段,和 extracttype 一致,isprefer  1:优选 -1:取消优选
-			if util.IntAll(tmp["isprefer"]) != 1 {
+			if util.IntAll(tmp["extracttype"]) != 1 {
 				return
 			}
+
+			// 优选字段,和 extracttype 一致,isprefer  1:优选 -1:取消优选
+			//if util.IntAll(tmp["isprefer"]) != 1 {
+			//	return
+			//}
 			//针对产权数据,暂时不入es 索引库
 			if util.IntAll(tmp["infoformat"]) == 3 {
 				return
@@ -267,11 +267,6 @@ func biddingAllTask(mapInfo map[string]interface{}) {
 				return
 			}
 
-			// 优选字段,和 extracttype 一致,isprefer  1:优选 -1:取消优选
-			if util.IntAll(tmp["isprefer"]) != 1 {
-				return
-			}
-
 			//针对产权数据,暂时不入es 索引库
 			if util.IntAll(tmp["infoformat"]) == 3 {
 				return