|
@@ -11,11 +11,10 @@ import (
|
|
|
// LoadActivityUser 加载新活跃用户
|
|
|
func (jm *JobManager) LoadActivityUser() {
|
|
|
var (
|
|
|
- runNow = time.Now()
|
|
|
- ctx = context.TODO()
|
|
|
+ ctx = context.TODO()
|
|
|
)
|
|
|
start, _ := time.ParseInLocation(time.DateTime, jm.lastRun.NewActivity, time.Local)
|
|
|
- val := public.GetNewActiveUser(start, runNow)
|
|
|
+ val, ed := public.GetNewActiveUser(start)
|
|
|
if len(val) > 0 {
|
|
|
for i, msg := range val {
|
|
|
if i%10 == 0 {
|
|
@@ -27,7 +26,7 @@ func (jm *JobManager) LoadActivityUser() {
|
|
|
}
|
|
|
}
|
|
|
//更新
|
|
|
- jm.lastRun.NewActivity = runNow.Format(time.DateTime)
|
|
|
+ jm.lastRun.NewActivity = ed.Format(time.DateTime)
|
|
|
if err := jm.SaveLastRun(); err != nil {
|
|
|
g.Log().Errorf(ctx, "LoadActivityUser error %v", err)
|
|
|
}
|