|
|
@@ -604,7 +604,11 @@ func ClueToDxTask() {
|
|
|
log.Println("客成用户量:", len(*res))
|
|
|
for _, val := range *res {
|
|
|
//log.Println("ent_id", val["ent_id"])
|
|
|
+ clue_id := gconv.Int(val["clue_id"])
|
|
|
childIds := []string{}
|
|
|
+ if gconv.String(val["ent_id"]) == "" {
|
|
|
+ continue
|
|
|
+ }
|
|
|
if mongodb.IsObjectIdHex(gconv.String(val["ent_id"])) { //mongodb 个人身份大会员
|
|
|
//查询个人大会员下的子账号
|
|
|
query := map[string]interface{}{"s_member_mainid": gconv.String(val["ent_id"])}
|
|
|
@@ -637,7 +641,7 @@ func ClueToDxTask() {
|
|
|
}
|
|
|
}
|
|
|
//log.Println("线索ids:", ids)
|
|
|
- sql := fmt.Sprintf("UPDATE dwd_f_crm_clue_info SET is_assign = -5 WHERE userid IN (%s)", ids)
|
|
|
+ sql := fmt.Sprintf("UPDATE dwd_f_crm_clue_info SET is_assign = -5 WHERE id != %d and userid IN (%s)", clue_id, ids)
|
|
|
log.Println("sql:", sql)
|
|
|
up := TiDb.UpdateOrDeleteBySql(sql)
|
|
|
if up < 0 {
|
