IOT/SERVER/IotAdmin/common/jobs/jobbase.go

package jobs

import (
	"github.com/robfig/cron/v3"
)

var timeFormat = "2006-01-02 15:04:05"
var retryCount = 3

// AddJob 添加任务 AddJob(invokeTarget string, jobId int, jobName string, cronExpression string)
func AddJob(c *cron.Cron, job Job) (int, error) {
	if job == nil {
		jobLogger.Errorf("Job Is Nil")
		return 0, nil
	}
	return job.addJob(c)
}

// Remove 移除任务
func Remove(c *cron.Cron, entryID int) chan bool {
	ch := make(chan bool)
	go func() {
		c.Remove(cron.EntryID(entryID))
		jobLogger.Infof("Remove SUCCESS ,INFO entryID :%d", entryID)
		ch <- true
	}()
	return ch
}