liucaijun
/
voucher
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

log

This commit is contained in:
ziming 2025-06-18 09:38:33 +08:00
parent b743aca6fa
commit abc720f88b
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/biz/cron_notice.go
View File

@ -190,7 +190,7 @@ func (v *VoucherBiz) notice(ctx context.Context, order *bo.OrderBo, notifyNum *i
return err return err
} }
orderNotify := &bo.OrderNotifyBo{ notify := &bo.OrderNotifyBo{
OrderNo: order.OrderNo, OrderNo: order.OrderNo,
NotifyUrl: order.NotifyUrl, NotifyUrl: order.NotifyUrl,
Channel: order.Channel, Channel: order.Channel,
@ -198,14 +198,14 @@ func (v *VoucherBiz) notice(ctx context.Context, order *bo.OrderBo, notifyNum *i
Type: order.Type, Type: order.Type,
} }
if err = v.request(ctx, order, orderNotify, notifyNum); err != nil { if err = v.request(ctx, order, notify, notifyNum); err != nil {
return err return err
} }
return v.UpdateOrderStatus(ctx, order.ID, status) return v.UpdateOrderStatus(ctx, order.ID, status)
} }
func (v *VoucherBiz) request(ctx context.Context, order *bo.OrderBo, orderNotify *bo.OrderNotifyBo, notifyNum *int) (respErr error) { func (v *VoucherBiz) request(ctx context.Context, order *bo.OrderBo, notify *bo.OrderNotifyBo, notifyNum *int) (respErr error) {
defer func() { defer func() {
if err := recover(); err != nil { if err := recover(); err != nil {
@ -213,11 +213,11 @@ func (v *VoucherBiz) request(ctx context.Context, order *bo.OrderBo, orderNotify
} }
}() }()
if !orderNotify.Event.CanNotify() { if !notify.Event.CanNotify() {
return nil // 不可通知，忽略 return nil // 不可通知，忽略
} }
request, err := v.Cmb.NotifyRequest(ctx, order, orderNotify) request, err := v.Cmb.NotifyRequest(ctx, order, notify)
if err != nil { if err != nil {
return err return err
} }