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

kg

This commit is contained in:
ziming 2025-05-21 11:40:36 +08:00
parent 62f946f520
commit e9a754e08a
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/wechat_notify.go
View File

@ -43,10 +43,10 @@ func (v *VoucherBiz) WechatNotifyConsumer(ctx context.Context, tag string, req *
} else if req.PlainText.Status.IsExpired() {
return v.expired(ctx, order)
} else {
return fmt.Errorf("未知通知类型:%s", req.PlainText.Status.GetText())
}
return fmt.Errorf("未知通知类型:%s", req.PlainText.Status.GetText())
})
}
@ -141,10 +141,10 @@ func (v *VoucherBiz) cmbNotify(ctx context.Context, orderId uint64) error {
return err
}
if orderNotify, err := v.Cmb.Notify(ctx, order); err != nil {
if orderNotify, err2 := v.Cmb.Notify(ctx, order); err2 != nil {
if !errPb.IsNeedRetryNotify(err) {
return err
if !errPb.IsNeedRetryNotify(err2) {
return err2
}
// 第一次通知失败重试入队