屏蔽 预处理 代码

createEsIndex/bidding_es.go

@@ -73,14 +73,14 @@ func biddingTask(mapInfo map[string]interface{}) {
 				wg.Done()
 			}()
 			//判断是否是预处理数据;pre_id 是标识
-			if config.Conf.Env.OpenPre {
-				if pre_id, ok := tmp["pre_id"]; ok {
-					preID := util.ObjToString(pre_id)
-					if preID != "" {
-						deletePreEsData(preID)
-					}
-				}
-			}
+			//if config.Conf.Env.OpenPre {
+			//	if pre_id, ok := tmp["pre_id"]; ok {
+			//		preID := util.ObjToString(pre_id)
+			//		if preID != "" {
+			//			deletePreEsData(preID)
+			//		}
+			//	}
+			//}
 			if sensitive := util.ObjToString(tmp["sensitive"]); sensitive == "测试" { //bidding中有敏感词，不生索引
 				tmp = make(map[string]interface{})
 				return
@@ -218,15 +218,15 @@ func biddingAllTask(mapInfo map[string]interface{}) {
 				<-ch
 				wg.Done()
 			}()
-			//判断是否是预处理数据;pre_id 是标识
-			if config.Conf.Env.OpenPre {
-				if pre_id, ok := tmp["pre_id"]; ok {
-					preID := util.ObjToString(pre_id)
-					if preID != "" {
-						deletePreEsData(preID)
-					}
-				}
-			}
+			////判断是否是预处理数据;pre_id 是标识
+			//if config.Conf.Env.OpenPre {
+			//	if pre_id, ok := tmp["pre_id"]; ok {
+			//		preID := util.ObjToString(pre_id)
+			//		if preID != "" {
+			//			deletePreEsData(preID)
+			//		}
+			//	}
+			//}
 
 			if sensitive := util.ObjToString(tmp["sensitive"]); sensitive == "测试" { //bidding中有敏感词，不生索引
 				tmp = make(map[string]interface{})
@@ -381,15 +381,15 @@ func biddingTaskById(mapInfo map[string]interface{}) {
 	stype := util.ObjToString(mapInfo["stype"])
 	infoid := util.ObjToString(mapInfo["infoid"])
 	tmp, _ := MgoB.FindById(config.Conf.DB.MongoB.Coll, infoid, map[string]interface{}{"contenthtml": 0})
-	//判断是否是预处理数据;pre_id 是标识
-	if config.Conf.Env.OpenPre {
-		if pre_id, ok := (*tmp)["pre_id"]; ok {
-			preID := util.ObjToString(pre_id)
-			if preID != "" {
-				deletePreEsData(preID)
-			}
-		}
-	}
+	////判断是否是预处理数据;pre_id 是标识
+	//if config.Conf.Env.OpenPre {
+	//	if pre_id, ok := (*tmp)["pre_id"]; ok {
+	//		preID := util.ObjToString(pre_id)
+	//		if preID != "" {
+	//			deletePreEsData(preID)
+	//		}
+	//	}
+	//}
 	if sensitive := util.ObjToString((*tmp)["sensitive"]); sensitive == "测试" { //bidding中有敏感词，不生索引
 		return
 	}

createEsIndex/common.toml

@@ -80,33 +80,32 @@ password2 = "Top2023_JEB01i@31"
 indexb2 = "bidding"
 
 ## 预处理数据 索引配置
-[[pre]]
-    [pre.19905] ## 华为云集群
-        addr = "http://127.0.0.1:19905"
-#        addr = "http://172.17.4.184:19905"
-        username = "jybid"
-        password = "Top2023_JEB01i@31"
-#        index = ["bidding"]  ## 生索引的表名，支持多个
-
-    [pre.19805] ## 老集群
-        addr = "http://127.0.0.1:19805"
-#        addr = "http://172.17.4.184:19805"
-        username = "es_all"
-        password = "TopJkO2E_d1x"
-#        index = ["bidding"]  ## 生索引的表名，支持多个
+#[[pre]]
+#    [pre.19905] ## 华为云集群
+#        addr = "http://127.0.0.1:19905"
+##        addr = "http://172.17.4.184:19905"
+#        username = "jybid"
+#        password = "Top2023_JEB01i@31"
+##        index = ["bidding"]  ## 生索引的表名，支持多个
+#
+#    [pre.19805] ## 老集群
+#        addr = "http://127.0.0.1:19805"
+##        addr = "http://172.17.4.184:19805"
+#        username = "es_all"
+#        password = "TopJkO2E_d1x"
+##        index = ["bidding"]  ## 生索引的表名，支持多个
 
 
 
 [mail]
 send = false
 to = "wangjianghan@topnet.net.cn"
-api = "http://172.17.145.179:19281/_send/_mail"
+api = "http://172.17.162.36:19281/_send/_mail"
 
 [env]
     stype = 1           ## 默认0 正式环境；1测试环境。测试环境不会执行定时任务更新采购单位、中标单位、数据检测
-    openpre = true      ## 是否开启预处理流程
-    spectype = "day"    ## 定时任务类型;正式环境应该是 month 。day 表示每天创建一个索引;month 表示每个月创建一个
-    alias = "bidding_pre"   ## 根据别名删除数据；正式环境应使用bidding
+#    openpre = false      ## 是否开启预处理流程
+#    spectype = "day"    ## 定时任务类型;正式环境应该是 month 。day 表示每天创建一个索引;month 表示每个月创建一个
 
 
 [[others]]

createEsIndex/main.go

@@ -65,10 +65,10 @@ func init() {
 	InitEs()
 	InitField()
 
-	if config.Conf.Env.OpenPre {
-		InitPreProcessField()
-		InitPreEsClient()
-	}
+	//if config.Conf.Env.OpenPre {
+	//	InitPreProcessField()
+	//	InitPreEsClient()
+	//}
 
 	InitEsBiddingField()
 	oss.InitOss()
@@ -107,10 +107,10 @@ func main() {
 
 	go SaveBidErr()
 	//添加预处理函数
-	if config.Conf.Env.OpenPre {
-		go SavePreEsMethod()
-		go dealPreProcess()
-	}
+	//if config.Conf.Env.OpenPre {
+	//	go SavePreEsMethod()
+	//	go dealPreProcess()
+	//}
 
 	UdpClient = udp.UdpClient{Local: config.Conf.Udp.LocPort, BufSize: 1024}
 	UdpClient.Listen(processUdpMsg)