update pici 位置

createEsIndex/bidding_es.go

@@ -220,18 +220,20 @@ func biddingTask(mapInfo map[string]interface{}) {
 					newTmp["object_type"] = objectType
 				}
 			}
+			newTmp["stype"] = stype
 			//
-			if stype == "bidding" || stype == "bidding_history" || stype == "index-by-id" {
-				//之前存在pici，就不在添加
-				if pici, ok := tmp["pici"]; ok {
-					newTmp["pici"] = pici
-					//log.Info("dddddddd", zap.Any("bidding_id", tmp["_id"]), zap.Any("pici", pici))
-				} else {
-					newTmp["pici"] = time.Now().Unix()
-					update["pici"] = time.Now().Unix()
-				}
-
-			}
+			//if stype == "bidding" || stype == "bidding_history" || stype == "index-by-id" {
+			//	newTmp["stype"] = stype
+			//	//之前存在pici，就不在添加
+			//	if pici, ok := tmp["pici"]; ok {
+			//		newTmp["pici"] = pici
+			//		//log.Info("dddddddd", zap.Any("bidding_id", tmp["_id"]), zap.Any("pici", pici))
+			//	} else {
+			//		newTmp["pici"] = time.Now().Unix()
+			//		update["pici"] = time.Now().Unix()
+			//	}
+			//
+			//}
 			//todo 处理中国移动定制标签
 			if len(globalRegs) > 0 && len(MatchArr) > 0 {
 				gs, _, _ := TaskTags(tmp, globalRegs)
@@ -252,10 +254,10 @@ func biddingTask(mapInfo map[string]interface{}) {
 					"set": update,
 				}
 
-				if util.ObjToString(newTmp["spidercode"]) == "a_jyxxfbpt_gg" {
-					// 剑鱼信息发布数据 通过udp通知信息发布程序
-					go UdpMethod(mongodb.BsonIdToSId(newTmp["_id"]))
-				}
+				//if util.ObjToString(newTmp["spidercode"]) == "a_jyxxfbpt_gg" {
+				//	// 剑鱼信息发布数据 通过udp通知信息发布程序
+				//	go UdpMethod(mongodb.BsonIdToSId(newTmp["_id"]))
+				//}
 			}
 		}(docCopy)
 		tmp = map[string]interface{}{}

createEsIndex/main.go

@@ -448,7 +448,34 @@ func SaveEsMethod() {
 					log.Info("SaveEsMethod", zap.String("上次优选ID删除失败", oid))
 				}
 			}
+			stype := util.ObjToString(v["stype"])
+			delete(v, "stype")
+			mgoUpdate := make(map[string]interface{})
+			if stype == "bidding" || stype == "bidding_history" || stype == "index-by-id" {
+				//之前存在pici，就不在添加
+				if pici, ok := v["pici"]; ok {
+					v["pici"] = pici
+				} else {
+					picc := time.Now().Unix()
+					v["pici"] = picc
+					mgoUpdate["pici"] = picc
+				}
+			}
+
+			if len(mgoUpdate) > 0 {
+				updateBiddingPool <- map[string]interface{}{
+					"_id": mongodb.StringTOBsonId(util.ObjToString(v["_id"])),
+					"set": mgoUpdate,
+				}
+
+				if util.ObjToString(v["spidercode"]) == "a_jyxxfbpt_gg" {
+					// 剑鱼信息发布数据 通过udp通知信息发布程序
+					go UdpMethod(mongodb.BsonIdToSId(v["_id"]))
+				}
+			}
+
 			Es.Save(config.Conf.DB.Es.IndexB, v)
+
 			// 华为云集群1
 			if config.Conf.DB.Es.Addr2 != "" {
 				v["id"] = id