|
@@ -561,7 +561,7 @@ func users() {
|
|
|
//新用户注册后5分钟内进入线索 C
|
|
//新用户注册后5分钟内进入线索 C
|
|
|
log.Println("新注册用户定时任务开始")
|
|
log.Println("新注册用户定时任务开始")
|
|
|
selectTimeEnd := cfg.LastUserId
|
|
selectTimeEnd := cfg.LastUserId
|
|
|
- sql := fmt.Sprintf(`select * from dwd_f_userbase_baseinfo where createtime > "%s" and source = "0101" and status != 2`, selectTimeEnd)
|
|
|
|
|
|
|
+ sql := fmt.Sprintf(`select * from dwd_f_userbase_baseinfo where createtime > "%s" and source = "0101" and status != 2 order by createtime asc`, selectTimeEnd)
|
|
|
data := TiDb.SelectBySql(sql)
|
|
data := TiDb.SelectBySql(sql)
|
|
|
if data != nil && *data != nil && len(*data) > 0 {
|
|
if data != nil && *data != nil && len(*data) > 0 {
|
|
|
for k, v := range *data {
|
|
for k, v := range *data {
|
|
@@ -592,7 +592,7 @@ func users() {
|
|
|
}
|
|
}
|
|
|
common.WriteSysConfig(&cfg)
|
|
common.WriteSysConfig(&cfg)
|
|
|
selectXcxTimeEnd := cfg.LastXcxUserId
|
|
selectXcxTimeEnd := cfg.LastXcxUserId
|
|
|
- xcxSql := fmt.Sprintf(`select * from dwd_f_userbase_baseinfo where s_platform ="xcx" and updatetime> "%s" and source = "0101" and status != 2 and clue_operate_status!=1`, selectXcxTimeEnd)
|
|
|
|
|
|
|
+ xcxSql := fmt.Sprintf(`select * from dwd_f_userbase_baseinfo where s_platform ="xcx" and updatetime> "%s" and source = "0101" and status != 2 and clue_operate_status!=1 order by createtime asc`, selectXcxTimeEnd)
|
|
|
xcxData := TiDb.SelectBySql(xcxSql)
|
|
xcxData := TiDb.SelectBySql(xcxSql)
|
|
|
if xcxData != nil && *xcxData != nil && len(*xcxData) > 0 {
|
|
if xcxData != nil && *xcxData != nil && len(*xcxData) > 0 {
|
|
|
for k, v := range *xcxData {
|
|
for k, v := range *xcxData {
|
