From bd83a242c05649412c8cd2bf04dc13ee37a12ce9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=AD=90=E9=93=AD?= Date: Tue, 18 Mar 2025 11:37:36 +0800 Subject: [PATCH] =?UTF-8?q?=E5=9B=9E=E8=B0=83=E9=80=9A=E7=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/service/cron.go | 22 ++++++++++++++++++++++ internal/service/voucher.go | 18 ------------------ 2 files changed, 22 insertions(+), 18 deletions(-) create mode 100644 internal/service/cron.go diff --git a/internal/service/cron.go b/internal/service/cron.go new file mode 100644 index 0000000..7872cc4 --- /dev/null +++ b/internal/service/cron.go @@ -0,0 +1,22 @@ +package service + +import ( + "context" + "github.com/go-kratos/kratos/v2/log" + "time" +) + +func (s *VoucherService) CronNotice(ctx context.Context) error { + + start := time.Now() + + if err := s.VoucherBiz.Notice(ctx); err != nil { + log.Error("订单定时通知,执行失败,err: %v", err) + } + + end := time.Now() + elapsed := end.Sub(start) + log.Warnf("订单定时通知,开始执行时间%s,执行结束时间%s,代码块执行耗时: %s", start.Format(time.DateTime), end.Format(time.DateTime), elapsed) + + return nil +} diff --git a/internal/service/voucher.go b/internal/service/voucher.go index 3b601c2..4b87215 100644 --- a/internal/service/voucher.go +++ b/internal/service/voucher.go @@ -1,9 +1,6 @@ package service import ( - "context" - "github.com/go-kratos/kratos/v2/log" - "time" "voucher/internal/biz" "voucher/internal/biz/mixrepos" "voucher/internal/biz/wechatrepo" @@ -30,18 +27,3 @@ func NewVoucherService( WechatCpnRepo: WechatCpnRepo, } } - -func (s *VoucherService) CronNotice(ctx context.Context) error { - - start := time.Now() - - if err := s.VoucherBiz.Notice(ctx); err != nil { - log.Error("订单定时通知,执行失败,err: %v", err) - } - - end := time.Now() - elapsed := end.Sub(start) - log.Warnf("订单定时通知,开始执行时间%s,执行结束时间%s,代码块执行耗时: %s", start.Format(time.DateTime), end.Format(time.DateTime), elapsed) - - return nil -}