备份

udp_winner/timedTaskBuyer.go

@@ -205,6 +205,21 @@ func TaskBuyer(mapinfo *map[string]interface{}) {
 						}
 					}
 					oldTmp["contact"] = contactMaps
+
+					//更新buyerclass合并
+					if tmp["buyerclass"] == nil || tmp["buyerclass"] == "" {
+						//无值，不更新
+					}else {
+						//有值
+						var buyerclass_new,buyerclass_old string
+						buyerclass_new = tmp["buyerclass"].(string)
+						buyerclass_old = oldTmp["buyerclass"].(string)
+						if strings.Contains(buyerclass_old, buyerclass_new) {
+							oldTmp["buyerclass"] = buyerclass_old + ","+buyerclass_new //采购单位类型
+						}
+
+					}
+
 					//mongo更新
 					oldTmp["updatatime"] = time.Now().Unix()
 					FClient.DbName = Config["mgodb_extract_kf"]
@@ -361,6 +376,21 @@ func TaskBuyer(mapinfo *map[string]interface{}) {
 					}
 				}
 				oldTmp["contact"] = contactMaps
+
+				//更新buyerclass合并
+				if tmp["buyerclass"] == nil || tmp["buyerclass"] == "" {
+					//无值，不更新
+				}else {
+					//有值
+					var buyerclass_new,buyerclass_old string
+					buyerclass_new = tmp["buyerclass"].(string)
+					buyerclass_old = oldTmp["buyerclass"].(string)
+					if strings.Contains(buyerclass_old, buyerclass_new) {
+						oldTmp["buyerclass"] = buyerclass_old + ","+buyerclass_new //采购单位类型
+					}
+
+				}
+
 				//mongo更新
 				oldTmp["updatatime"] = time.Now().Unix()
 				FClient.DbName = Config["mgodb_extract_kf"]