接口调整

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

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