From 6624a5193f57baad5bca8d64d1edf61af14368c6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=AD=90=E9=93=AD?= Date: Thu, 13 Mar 2025 11:31:28 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/biz/notify_retry_consume.go | 5 ++--- internal/biz/order.go | 4 ++++ 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/internal/biz/notify_retry_consume.go b/internal/biz/notify_retry_consume.go index 864b5b7..e516739 100644 --- a/internal/biz/notify_retry_consume.go +++ b/internal/biz/notify_retry_consume.go @@ -51,10 +51,9 @@ func (v *VoucherBiz) NotifyRetryConsume(ctx context.Context, orderNotifyId uint6 } if order.Type.IsCmb() { + orderNotify, err2 = v.Cmb.NotifyRetryConsume(ctx, order, orderNotify) - if err2 != nil { - return err2 - } + return err2 } return fmt.Errorf("订单类型错误:%s", order.Type.GetText()) diff --git a/internal/biz/order.go b/internal/biz/order.go index 0fbf47c..7873f11 100644 --- a/internal/biz/order.go +++ b/internal/biz/order.go @@ -117,6 +117,10 @@ func (v *VoucherBiz) registerNotifyTag(ctx context.Context, stockCreatorMchID, s if wechatNotifyTag != nil { + if wechatNotifyTag.Tag != v.bc.WechatNotifyMQ.Tag { + return fmt.Errorf("tag不一致，请检查tag配置:%s", wechatNotifyTag.Tag) + } + return v.setCache(ctx, c, wechatNotifyTag) }