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)
	//})

}