liucaijun
/
voucher
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

预警42

This commit is contained in:
ziming 2025-07-02 15:54:58 +08:00
parent 2eefff46e2
commit b710bd8793
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/service/warning_budget.go
View File

@ -33,11 +33,11 @@ func (s *VoucherService) CronWarningBudget(ctx context.Context) error {
cacheValue, err2 := s.rdb.Rdb.Get(ctx, cv.Key).Result() cacheValue, err2 := s.rdb.Rdb.Get(ctx, cv.Key).Result()
if err2 != nil && err2 != redis.Nil { if err2 != nil && err2 != redis.Nil {
return fmt.Errorf(fmt.Sprintf("warningBudget定时任务,notice 获取redis缓存%s异常:%v", cv.Key, err2)) return fmt.Errorf(fmt.Sprintf("warningBudget定时任务,获取redis缓存%s异常:%v", cv.Key, err2))
} }
if len(cacheValue) > 0 { if len(cacheValue) > 0 {
log.Warnf("warningBudget定时任务,notice 获取redis缓存存在,本台服务不做执行") log.Warnf("warningBudget定时任务,获取redis缓存存在,本台服务不做执行")
return nil return nil
} }
@ -45,7 +45,7 @@ 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缓存不存在,本台服务执行") log.Warnf("warningBudget定时任务,获取redis缓存不存在,本台服务执行")
return s.cron.AddFunc(c.Command, func() { return s.cron.AddFunc(c.Command, func() {