|
|
@@ -78,14 +78,19 @@ func users() {
|
|
|
}
|
|
|
//新用户注册后5分钟内进入线索 C
|
|
|
log.Println("新注册用户定时任务开始")
|
|
|
- selectTimeEnd := time.Unix(time.Now().Unix()-300, 0).Format("2006-01-02 15:04:05")
|
|
|
+ selectTimeEnd := cfg.LastUserId
|
|
|
sql := fmt.Sprintf(`select * from dwd_f_userbase_baseinfo where createtime > "%s" and source = 1`, selectTimeEnd)
|
|
|
data := TiDb.SelectBySql(sql)
|
|
|
if data != nil && *data != nil && len(*data) > 0 {
|
|
|
- for _, v := range *data {
|
|
|
+ for k, v := range *data {
|
|
|
+ createtime := common.ObjToString(v["createtime"])
|
|
|
FormatData(v, "users")
|
|
|
+ if k == len(*data)-1 {
|
|
|
+ cfg.LastUserId = createtime
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
+ common.WriteSysConfig(&cfg)
|
|
|
log.Println("新注册用户定时任务结束")
|
|
|
}
|
|
|
|
