|
|
@@ -561,7 +561,7 @@ func users() {
|
|
|
return
|
|
|
}
|
|
|
//新用户注册后5分钟内进入线索 C
|
|
|
- log.Println("新注册用户定时任务开始")
|
|
|
+ log.Println("新注册用户定时任务开始", cfg.LastUserId)
|
|
|
selectTimeEnd := cfg.LastUserId
|
|
|
sql := fmt.Sprintf(`select * from dwd_f_userbase_baseinfo where createtime > "%s" and (s_platform != 'xcx' or s_platform is NULL) and source = "0101" and status != 2 order by createtime asc`, selectTimeEnd)
|
|
|
//sql := fmt.Sprintf(`select * from dwd_f_userbase_baseinfo where id= 2259277`)
|
|
|
@@ -584,6 +584,8 @@ func users() {
|
|
|
}
|
|
|
}
|
|
|
common.WriteSysConfig(&cfg)
|
|
|
+ log.Println("新注册用户定时任务结束", cfg.LastUserId)
|
|
|
+ log.Println("小程序新注册用户定时任务结束", cfg.LastXcxUserId)
|
|
|
selectXcxTimeEnd := cfg.LastXcxUserId
|
|
|
xcxSql := fmt.Sprintf(`SELECT DISTINCT
|
|
|
aa.mgo_id as userId,
|
|
|
@@ -673,7 +675,7 @@ WHERE
|
|
|
}
|
|
|
}
|
|
|
common.WriteSysConfig(&cfg)
|
|
|
- log.Println("新注册用户定时任务结束")
|
|
|
+ log.Println("小程序新注册用户定时任务结束", cfg.LastXcxUserId)
|
|
|
}
|
|
|
|
|
|
// 留资 5分钟一次
|
WH01243