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 }