internal/biz/multi.go

@@ -5,6 +5,8 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"github.com/go-kratos/kratos/v2/log"
+	"gorm.io/gorm"
 	v1 "voucher/api/v1"
 	"voucher/internal/biz/bo"
 	"voucher/internal/biz/cmb"
@@ -14,9 +16,6 @@ import (
 	"voucher/internal/conf"
 	"voucher/internal/data"
 	"voucher/internal/pkg/lock"
-
-	"github.com/go-kratos/kratos/v2/log"
-	"gorm.io/gorm"
 )
 
 type MultiBiz struct {
@@ -150,11 +149,6 @@ func (biz *MultiBiz) RetryRunByMultiNotifyDataId(ctx context.Context, multiNotif
 }
 
 func (biz *MultiBiz) run(ctx context.Context, req *bo.WechatVoucherNotifyBo, mnd *bo.MultiNotifyDataBo, order *bo.OrderBo) error {
-	// 如果核销金额为空，不再推送下游
-	if mnd.ConsumeAmount == 0 {
-		log.Warnf("[%s] multi notify log consume amount is 0,req:%+v", mnd.NotifyID, req)
-		return nil
-	}
 
 	nl, request, err := biz.nlCreate(ctx, req, mnd, order)
 	if err != nil {