大会员子账号不作为电销线索

clueSync/autoTask.go

@@ -603,7 +603,7 @@ func ClueToDxTask() {
 	}
 	log.Println("客成用户量:", len(*res))
 	for _, val := range *res {
-		log.Println("ent_id", val["ent_id"])
+		//log.Println("ent_id", val["ent_id"])
 		childIds := []string{}
 		if mongodb.IsObjectIdHex(gconv.String(val["ent_id"])) { //mongodb  个人身份大会员
 			//查询个人大会员下的子账号
@@ -620,7 +620,7 @@ func ClueToDxTask() {
 			//根据企业id查询企业下的员工
 			data := TiDb.Query("SELECT userid,uid FROM dwd_f_userbase_id_mapping WHERE ent_id = ?", gconv.Int(val["ent_id"]))
 			if data != nil && len(*data) > 0 {
-				log.Println("企业下员工数：", len(*data))
+				log.Println("企业下员工数：", gconv.Int(val["ent_id"]), len(*data))
 				for _, vv := range *data {
 					childIds = append(childIds, gconv.String(vv["userid"]))
 				}
@@ -636,7 +636,7 @@ func ClueToDxTask() {
 					ids += fmt.Sprintf(",'%s'", vv)
 				}
 			}
-			log.Println("线索ids:", ids)
+			//log.Println("线索ids:", ids)
 			sql := fmt.Sprintf("UPDATE dwd_f_crm_clue_info SET is_assign = -5 WHERE userid IN (%s)", ids)
 			log.Println("sql:", sql)
 			up := TiDb.UpdateOrDeleteBySql(sql)