大客线索处理

clueSync/everything.go

@@ -431,7 +431,18 @@ func bigCustomer() {
 			phone := common.ObjToString(v["user_phone"])
 			order_status := common.IntAll(v["order_status"])
 			product_type := common.ObjToString(v["product_type"])
-			userData := TiDb.FindOne("dwd_f_userbase_baseinfo", map[string]interface{}{"phone": phone}, "", "")
+			orderUserId := gconv.String(v["user_id"])
+			query := map[string]interface{}{}
+			if !mongodb.IsObjectIdHex(orderUserId) {
+				userMapping := TiDb.FindOne("dwd_f_userbase_id_mapping", map[string]interface{}{"position_id": orderUserId}, "", "")
+				if userMapping != nil && len(*userMapping) > 0 {
+					uid := common.ObjToString((*userMapping)["uid"])
+					query["uid"] = uid
+				}
+			} else {
+				query["userid"] = orderUserId
+			}
+			userData := TiDb.FindOne("dwd_f_userbase_baseinfo", query, "", "")
 			username, usernickname, userid, uid, source, payorderinfo, unpayorderinfo := "", "", "", "", "", "", ""
 			if userData != nil {
 				username = common.ObjToString((*userData)["name"])