datatools/doFreeClueSign/job/job.go

package job

import (
	"context"
	"doFreeClueSign/public"
	"github.com/gogf/gf/v2/frame/g"
	"github.com/gogf/gf/v2/util/gconv"
	"time"
)

// LoadActivityUser 加载新活跃用户
func (jm *JobManager) LoadActivityUser() {
	var (
		runNow = time.Now()
		ctx    = context.TODO()
	)
	start, _ := time.Parse(time.DateTime, jm.lastRun.NewActivity)
	val := public.GetNewActiveUser(start, runNow)
	if len(val) > 0 {
		for i, msg := range val {
			if i%10 == 0 {
				g.Log().Infof(ctx, "JobManager.LoadActivityUser %d/%d", i, len(val))
			}
			if err := jm.FilterPayUserAndSaveDb(ctx, msg); err != nil {
				g.Log().Errorf(ctx, "JobManager.LoadActivityUser.FilterPayUserAndSaveDb %v", gconv.String(msg))
			}
		}
	}
	//更新
	jm.lastRun.NewActivity = start.Format(time.DateTime)
	if err := jm.SaveLastRun(); err != nil {
		g.Log().Errorf(ctx, "LoadActivityUser error %v", err)
	}
}

// LoadBindPhoneUser 加载绑定手机号用户
func (jm *JobManager) LoadBindPhoneUser() {
	var (
		runNow = time.Now()
		ctx    = context.TODO()
	)
	start, _ := time.Parse(time.DateTime, jm.lastRun.BindPhone)
	val := public.GetBidPhoneUser(start, runNow)
	if len(val) > 0 {
		for i, msg := range val {
			if i%10 == 0 {
				g.Log().Infof(ctx, "JobManager.LoadBindPhoneUser %d/%d", i, len(val))
			}
			if err := jm.FilterPayUserAndSaveDb(ctx, msg); err != nil {
				g.Log().Errorf(ctx, "JobManager.LoadBindPhoneUser.FilterPayUserAndSaveDb %v", gconv.String(msg))
			}
		}
	}
	//更新
	jm.lastRun.BindPhone = start.Format(time.DateTime)
	if err := jm.SaveLastRun(); err != nil {
		g.Log().Errorf(ctx, "LoadBindPhoneUser error %v", err)
	}
}

// LoadAgainSubUser 加载再次关注用户
func (jm *JobManager) LoadAgainSubUser() {
	var (
		runNow = time.Now()
		ctx    = context.TODO()
	)
	start, _ := time.Parse(time.DateTime, jm.lastRun.AgainSub)
	val := public.GetAgainSubUser(start, runNow)
	if len(val) > 0 {
		for i, msg := range val {
			if i%10 == 0 {
				g.Log().Infof(ctx, "JobManager.LoadAgainSubUser %d/%d", i, len(val))
			}
			if err := jm.FilterPayUserAndSaveDb(ctx, msg); err != nil {
				g.Log().Errorf(ctx, "JobManager.LoadAgainSubUser.FilterPayUserAndSaveDb %v", gconv.String(msg))
			}
		}
	}
	//更新
	jm.lastRun.AgainSub = start.Format(time.DateTime)
	if err := jm.SaveLastRun(); err != nil {
		g.Log().Errorf(ctx, "LoadAgainSubUser error %v", err)
	}
}