wechat-api/crontask/init.go

package crontask

import (
	"context"
	"wechat-api/internal/svc"

	"github.com/robfig/cron/v3"
	"github.com/zeromicro/go-zero/core/logx"
)

type CronTask struct {
	logx.Logger
	ctx    context.Context
	svcCtx *svc.ServiceContext
}

func NewCronTask(ctx context.Context, svcCtx *svc.ServiceContext) *CronTask {
	return &CronTask{
		Logger: logx.WithContext(ctx),
		ctx:    ctx,
		svcCtx: svcCtx,
	}
}

func ScheduleRun(c *cron.Cron, serverCtx *svc.ServiceContext) {

	//除了fe环境任务关闭 其他环境任务要正常打开
	l := NewCronTask(context.Background(), serverCtx)
	c.AddFunc("* * * * *", func() {
		l.sendMsg()
	})

	sendWx := NewCronTask(context.Background(), serverCtx)
	c.AddFunc("* * * * *", func() {
		sendWx.sendWx()
	})

	sendWxOnTimeout := NewCronTask(context.Background(), serverCtx)
	c.AddFunc("* * * * *", func() {
		sendWxOnTimeout.sendWxOnTimeout()
	})

	computeStatistic := NewCronTask(context.Background(), serverCtx)
	c.AddFunc("0 * * * *", func() {
		computeStatistic.computeStatistic()
	})

	contactForm := NewCronTask(context.Background(), serverCtx)
	c.AddFunc("10 0 * * *", func() {
		contactForm.analyze()
	})

	l = NewCronTask(context.Background(), serverCtx)
	c.AddFunc("*/30 * * * *", func() {
		l.wxAddFriend()
	})

	//l = NewCronTask(context.Background(), serverCtx)
	//c.AddFunc("* * * * *", func() {
	//	MaxWorker := 10
	//	MaxChannel := 3
	//	l.compApiCallback(MaxWorker, MaxChannel)
	//})

}