From dd5380c47deec581a9a4be08cc91c2314d5dc604 Mon Sep 17 00:00:00 2001 From: ziming Date: Thu, 11 Dec 2025 14:34:30 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=9A=E7=AC=94=E7=AB=8B=E5=87=8F=E9=87=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/biz/multi.go | 6 +++--- internal/service/qixing.go | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/biz/multi.go b/internal/biz/multi.go index f88489e..4558bbf 100644 --- a/internal/biz/multi.go +++ b/internal/biz/multi.go @@ -52,7 +52,7 @@ func NewMultiBiz( } } -func (biz *MultiBiz) Notify(ctx context.Context, source string, req *bo.WechatVoucherNotifyBo) error { +func (biz *MultiBiz) Notify(ctx context.Context, ip, source string, req *bo.WechatVoucherNotifyBo) error { cl := vo.MultiNotifyLockKey.BuildCache([]string{ source, @@ -65,12 +65,12 @@ func (biz *MultiBiz) Notify(ctx context.Context, source string, req *bo.WechatVo order, err := biz.order(ctx, req) if err != nil { - log.Errorf("[%s] multi notify error: %v,req:%+v", source, err, req) + log.Errorf("[%s-%s] multi notify error: %v,req:%+v", source, ip, err, req) return err } if err = biz.Run(ctx, source, req, order); err != nil { - log.Errorf("[%s] multi notify error: %v,req:%+v", source, err, req) + log.Errorf("[%s-%s] multi notify error: %v,req:%+v", source, ip, err, req) return err } diff --git a/internal/service/qixing.go b/internal/service/qixing.go index 74af1e7..d74956b 100644 --- a/internal/service/qixing.go +++ b/internal/service/qixing.go @@ -37,5 +37,5 @@ func (srv *TripartiteService) QiXingNotify(ctx http.Context) error { return fmt.Errorf("json unmarshal bodyBytes error: %v", err) } - return srv.multiBiz.Notify(ctx, "qixing_"+req.PlainText.StockCreatorMchid, req) + return srv.multiBiz.Notify(ctx, ip, "qixing_"+req.PlainText.StockCreatorMchid, req) }