浏览代码

Merge branch 'master' into feature/v1.5.13

lianbingjie 10 月之前
父节点
当前提交
0f74098d9b
共有 2 个文件被更改,包括 4 次插入7 次删除
  1. 1 1
      clueSync/job.go
  2. 3 6
      clueSync/kc.go

+ 1 - 1
clueSync/job.go

@@ -208,7 +208,7 @@ func FormatData(data map[string]interface{}, item string) (bool, bool) {
 		phone = common.ObjToString(data["phone"])
 		phone = common.ObjToString(data["phone"])
 		sourceId = common.Int64All(data["sourceId"])
 		sourceId = common.Int64All(data["sourceId"])
 	}
 	}
-	if cluename == "" && item != "message" && item != "orders" && item != "readClue" && item != "rebind" {
+	if cluename == "" && item != "message" && item != "orders" && item != "readClue" && item != "rebind" && item != "allocation" {
 		cluename = phone //没有线索名,手机号代替
 		cluename = phone //没有线索名,手机号代替
 	}
 	}
 	cluename = strings.ReplaceAll(cluename, " ", "")
 	cluename = strings.ReplaceAll(cluename, " ", "")

+ 3 - 6
clueSync/kc.go

@@ -437,8 +437,7 @@ func ordersClue() {
 						source = common.ObjToString((*userInfo)["source"])
 						source = common.ObjToString((*userInfo)["source"])
 					} else {
 					} else {
 						log.Println("后台订单--未查询到 ", user_phone)
 						log.Println("后台订单--未查询到 ", user_phone)
-						//break
-						continue
+						break
 					}
 					}
 				} else {
 				} else {
 					if !mongodb.IsObjectIdHex(userId) {
 					if !mongodb.IsObjectIdHex(userId) {
@@ -447,8 +446,7 @@ func ordersClue() {
 							userId = common.ObjToString((*userMapping)["userid"])
 							userId = common.ObjToString((*userMapping)["userid"])
 						} else {
 						} else {
 							log.Println("后台订单--未查询到 ", user_phone)
 							log.Println("后台订单--未查询到 ", user_phone)
-							//break
-							continue
+							break
 						}
 						}
 					}
 					}
 					query["userid"] = userId
 					query["userid"] = userId
@@ -458,8 +456,7 @@ func ordersClue() {
 						source = common.ObjToString((*userInfo)["source"])
 						source = common.ObjToString((*userInfo)["source"])
 					} else {
 					} else {
 						log.Println("后台订单--未查询到 ", query, user_phone)
 						log.Println("后台订单--未查询到 ", query, user_phone)
-						//break
-						continue
+						break
 					}
 					}
 				}
 				}
 				is_assign := 1
 				is_assign := 1