|
|
@@ -146,12 +146,15 @@ func VisitInfoAdd(start, end int64) {
|
|
|
wait.Wait()
|
|
|
//
|
|
|
log.Println("开始更新不活跃重新活跃用户。。。")
|
|
|
- sTime := gtime.Now().AddDate(0, 0, -1).StartOfDay()
|
|
|
- day30, today, nowFormat, tomorrow := sTime.AddDate(0, 0, -30).String(), sTime.String(), sTime.String(), sTime.AddDate(0, 0, 1).String()
|
|
|
+ sTime := gtime.Now().StartOfDay()
|
|
|
+ day30, today, nowFormat, tomorrow := sTime.AddDate(0, 0, -30).String(), sTime.String(), gtime.Now().String(), sTime.AddDate(0, 0, 1).String()
|
|
|
config.JianyuSubjectdb.SelectByBath(1, func(l *[]map[string]interface{}) bool {
|
|
|
userid := gconv.String((*l)[0]["userid"])
|
|
|
- log.Println("更新不活跃重新活跃用户", userid)
|
|
|
- config.JianyuMaindb.ExecBySql(`INSERT INTO bi_service.freeClubSign (mogUserId,act_again_date,create_time) VALUES (?,?,?) ON DUPLICATE KEY UPDATE act_again_date=?`, userid, nowFormat, nowFormat, nowFormat)
|
|
|
+ datas := config.JianyuMaindb.SelectBySql(`select act_again_date from bi_service.freeClubSign where mogUserId=? limit 1`, userid)
|
|
|
+ if datas == nil || len(*datas) == 0 || gtime.New((*datas)[0]["act_again_date"]).Before(sTime) {
|
|
|
+ log.Println("更新不活跃重新活跃用户", userid)
|
|
|
+ config.JianyuMaindb.ExecBySql(`INSERT INTO bi_service.freeClubSign (mogUserId,act_again_date,create_time) VALUES (?,?,?) ON DUPLICATE KEY UPDATE act_again_date=?`, userid, nowFormat, nowFormat, nowFormat)
|
|
|
+ }
|
|
|
return true
|
|
|
}, `SELECT userid FROM dwd_f_userbase_visit_info a WHERE a.date>? AND a.date<? AND a.contentnum>=5 and not exists(
|
|
|
select 1 from dwd_f_userbase_visit_info b where b.date>? and b.date<? and b.contentnum>=5 and a.userid=b.userid
|
