索引新增敏感词逻辑判断

udpcreateindex/src/biddingall.go

@@ -84,6 +84,10 @@ func biddingAllTask(data []byte, mapInfo map[string]interface{}) {
 		// 	tmp = make(map[string]interface{})
 		// 	continue
 		// }
+		if sensitive := qutil.ObjToString(tmp["sensitive"]); sensitive != "" { //bidding中有敏感词，不生索引
+			tmp = make(map[string]interface{})
+			continue
+		}
 		update := map[string]interface{}{}
 		del := map[string]interface{}{} //记录extract没有值而bidding中有值的字段
 		//对比方法----------------

udpcreateindex/src/biddingindex.go

@@ -142,9 +142,14 @@ func doIndex(infos []map[string]interface{}, eMap map[string]map[string]interfac
 		// 	tmp = make(map[string]interface{})
 		// 	continue
 		// }
+		if sensitive := qutil.ObjToString(tmp["sensitive"]); sensitive != "" { //bidding中有敏感词，不生索引
+			tmp = make(map[string]interface{})
+			continue
+		}
 		update := map[string]interface{}{} //要更新的mongo数据
 		//对比方法----------------
 		tid := qutil.BsonIdToSId(tmp["_id"])
+
 		if eMap[tid] != nil {
 			compare = eMap[tid]
 			if qutil.IntAll(compare["dataging"]) == 1 { //extract中dataging=1不生索引

udpcreateindex/src/config.json

@@ -94,7 +94,7 @@
         "db": "mxs"
     },
     "elastic": {
-        "addr": "http://192.168.3.128:9800",
+        "addr": "http://192.168.3.11:9800",
         "pool": 12
     }
 }