hotgo/server/internal/crons/test2.go

// Package crons
// @Link  https://github.com/bufanyun/hotgo
// @Copyright  Copyright (c) 2023 HotGo CLI
// @Author  Ms <133814250@qq.com>
// @License  https://github.com/bufanyun/hotgo/blob/master/LICENSE
package crons

import (
	"context"
	"github.com/gogf/gf/v2/errors/gerror"
	"hotgo/internal/library/cron"
	"time"
)

func init() {
	cron.Register(Test2)
}

// Test2 测试2任务（带参数）
var Test2 = &cTest2{name: "test2"}

type cTest2 struct {
	name string
}

func (c *cTest2) GetName() string {
	return c.name
}

// Execute 执行任务
func (c *cTest2) Execute(ctx context.Context, parser *cron.Parser) (err error) {
	if len(parser.Args) != 3 {
		err = gerror.New("传入参数不正确!")
		return
	}

	var (
		name = parser.Args[0]
		age  = parser.Args[1]
		msg  = parser.Args[2]
	)

	parser.Logger.Infof(ctx, "cron test2 Execute:%v, name:%v, age:%v, msg:%v", time.Now(), name, age, msg)
	return
}