|
|
@@ -561,7 +561,7 @@ func users() {
|
|
|
//新用户注册后5分钟内进入线索 C
|
|
|
log.Println("新注册用户定时任务开始")
|
|
|
selectTimeEnd := cfg.LastUserId
|
|
|
- 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)
|
|
|
+ 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)
|
|
|
data := TiDb.SelectBySql(sql)
|
|
|
if data != nil && *data != nil && len(*data) > 0 {
|
|
|
for k, v := range *data {
|
WH01243