预警41
This commit is contained in:
parent
a51f5d7834
commit
2eefff46e2
|
|
@ -37,7 +37,7 @@ func (s *VoucherService) CronWarningBudget(ctx context.Context) error {
|
||||||
}
|
}
|
||||||
|
|
||||||
if len(cacheValue) > 0 {
|
if len(cacheValue) > 0 {
|
||||||
log.Error("warningBudget定时任务,notice 获取redis缓存存在,本台服务不做执行")
|
log.Warnf("warningBudget定时任务,notice 获取redis缓存存在,本台服务不做执行")
|
||||||
return nil
|
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))
|
return fmt.Errorf(fmt.Sprintf("warningBudget定时任务 设置redis缓存%s异常:%v", cv.Key, err))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
log.Warnf("warningBudget定时任务,notice 获取redis缓存不存在,本台服务执行")
|
||||||
|
|
||||||
return s.cron.AddFunc(c.Command, func() {
|
return s.cron.AddFunc(c.Command, func() {
|
||||||
|
|
||||||
s.VoucherBiz.CronWarningBudget(ctx)
|
s.VoucherBiz.CronWarningBudget(ctx)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue