diff --git a/internal/service/warning_budget.go b/internal/service/warning_budget.go index 8482780..ea2ab51 100644 --- a/internal/service/warning_budget.go +++ b/internal/service/warning_budget.go @@ -37,7 +37,7 @@ func (s *VoucherService) CronWarningBudget(ctx context.Context) error { } if len(cacheValue) > 0 { - log.Error("warningBudget定时任务,notice 获取redis缓存存在,本台服务不做执行") + log.Warnf("warningBudget定时任务,notice 获取redis缓存存在,本台服务不做执行") return nil } @@ -45,6 +45,8 @@ func (s *VoucherService) CronWarningBudget(ctx context.Context) error { return fmt.Errorf(fmt.Sprintf("warningBudget定时任务 设置redis缓存%s异常:%v", cv.Key, err)) } + log.Warnf("warningBudget定时任务,notice 获取redis缓存不存在,本台服务执行") + return s.cron.AddFunc(c.Command, func() { s.VoucherBiz.CronWarningBudget(ctx)