定时任务修改

clueSync/jobutil.go

@@ -561,7 +561,7 @@ func users() {
 	//新用户注册后5分钟内进入线索 C
 	log.Println("新注册用户定时任务开始")
 	selectTimeEnd := cfg.LastUserId
-	sql := fmt.Sprintf(`select * from woxianzai1 where createtime > "%s" and source = "0101" and status != 2  order by  createtime asc`, selectTimeEnd)
+	sql := fmt.Sprintf(`select * from dwd_f_userbase_baseinfo   where createtime > "%s" and s_platform!="xcx"   and source = "0101" and status != 2  order by  createtime asc`, selectTimeEnd)
 	data := TiDb.SelectBySql(sql)
 	if data != nil && *data != nil && len(*data) > 0 {
 		for k, v := range *data {
@@ -569,7 +569,7 @@ func users() {
 			s_platform := gconv.String(v["s_platform"])
 			login_positionid := gconv.Int64(v["login_positionid"])
 			createtime := common.ObjToString(v["createtime"])
-			if s_platform == "xcx" && login_positionid == 0 {
+			/*if s_platform == "xcx" && login_positionid == 0 {
 				log.Println(v, "用户是否有小程序且未使用过剑鱼其他产品")
 			} else {
 				ok1, ok2 := FormatData(v, "users")
@@ -580,8 +580,15 @@ func users() {
 						log.Println("用户分配已达上限", "users", v, selectTimeEnd)
 					}
 				}
+			}*/
+			ok1, ok2 := FormatData(v, "users")
+			if !ok1 {
+				log.Println("线索卡点", "users", v, selectTimeEnd)
+			} else {
+				if !ok2 {
+					log.Println("用户分配已达上限", "users", v, selectTimeEnd)
+				}
 			}
-
 			if k == len(*data)-1 {
 				cfg.LastUserId = createtime
 			}