OMC/be.ems
1
0
Fork 0
Code Issues Releases 3 Activity

fix:...

Browse Source
This commit is contained in:
simonzhangsz
2023-10-28 16:58:34 +08:00
parent 7c1f5bc179
commit 4a577c89e7
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/modules/crontask/delExpiredNeBackup/delExpiredNeBackup.go
View File

@@ -29,7 +29,7 @@ type BarParams struct {
} }
func (s *BarProcessor) Execute(data any) (any, error) { func (s *BarProcessor) Execute(data any) (any, error) {
log.Infof("执行 %d 次，上次进度： %d ", s.count, s.progress) log.Infof("count: %d ，progress: %d ", s.count, s.progress)
s.count++ s.count++
options := data.(cron.JobData) options := data.(cron.JobData)
@@ -41,7 +41,7 @@ func (s *BarProcessor) Execute(data any) (any, error) {
if err == nil { if err == nil {
duration = params.Duration duration = params.Duration
} }
log.Infof("重复 %v 任务ID %s", options.Repeat, sysJob.JobID) log.Infof("Repeat: %v JobID: %s", options.Repeat, sysJob.JobID)
// // 实现任务处理逻辑 // // 实现任务处理逻辑
// i := 0 // i := 0