|
|
@@ -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' 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 createtime > "%s" and (s_platform != 'xcx' or s_sourceid='jyzbw' 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`)
|
|
|
data := TiDb.SelectBySql(sql)
|
|
|
if data != nil && *data != nil && len(*data) > 0 {
|
|
|
@@ -747,7 +747,7 @@ func userbase() {
|
|
|
dwd_f_userbase_contacts a
|
|
|
INNER JOIN dwd_f_userbase_baseinfo b ON
|
|
|
b.status= 1
|
|
|
- and (b.s_platform != 'xcx' or b.s_platform is NULL)
|
|
|
+ and (b.s_platform != 'xcx' or b.s_sourceid='jyzbw' or b.s_platform is NULL)
|
|
|
AND a.phone = b.phone and a.baseinfo_id= b.uid and a.source ="0101"
|
|
|
and a.phone is not NULL
|
|
|
and a.createtime >="%s"
|
