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) }