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

多笔立减金

This commit is contained in:
ziming 2025-12-12 17:18:03 +08:00
parent 5dfec0d509
commit 349fe2621c
1 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
internal/biz/multi.go
View File

@ -247,10 +247,10 @@ func (biz *MultiBiz) GetRequest(ctx context.Context, nl *bo.MultiNotifyLogBo) (*
func (biz *MultiBiz) Request(ctx context.Context, mmd *bo.MultiNotifyDataBo, nl *bo.MultiNotifyLogBo) error { func (biz *MultiBiz) Request(ctx context.Context, mmd *bo.MultiNotifyDataBo, nl *bo.MultiNotifyLogBo) error {
if nl.RequestURL == "" { if nl.RequestURL == "" {
if err := biz.notifyFail(ctx, nl, "回调通知招行地址为空"); err != nil { if err := biz.notifyFail(ctx, nl, "回调通知招行地址为空,不做通知"); err != nil {
return err return err
} }
// 回调通知地址为空，不反回错误，不做再次通知处理 // 回调通知地址为空，不返回错误，不做再次通知处理
return nil return nil
} }
@ -268,7 +268,9 @@ func (biz *MultiBiz) Request(ctx context.Context, mmd *bo.MultiNotifyDataBo, nl
} }
if err = biz.CmbMixRepo.VerifyResponse(ctx, reply); err != nil { if err = biz.CmbMixRepo.VerifyResponse(ctx, reply); err != nil {
errMsg := fmt.Sprintf("回调通知招行返回验证结果发生错误,resp:%+v error:%s", reply, err.Error()) errMsg := fmt.Sprintf("回调通知招行返回验证结果发生错误,resp:%+v error:%s", reply, err.Error())
if err2 := biz.notifyFail(ctx, nl, errMsg); err2 != nil { if err2 := biz.notifyFail(ctx, nl, errMsg); err2 != nil {
return err2 return err2
} }
@ -279,22 +281,27 @@ func (biz *MultiBiz) Request(ctx context.Context, mmd *bo.MultiNotifyDataBo, nl
} }
func (biz *MultiBiz) notifyFail(ctx context.Context, nl *bo.MultiNotifyLogBo, remark string) error { func (biz *MultiBiz) notifyFail(ctx context.Context, nl *bo.MultiNotifyLogBo, remark string) error {
return biz.MultiNotifyLogRepo.Fail(ctx, nl.ID, remark)
if err := biz.MultiNotifyLogRepo.Fail(ctx, nl.ID, remark); err != nil {
return fmt.Errorf("更新通知日志失败状态发生错误 error: %v", err)
}
return nil
} }
func (biz *MultiBiz) notifySuccess(ctx context.Context, mmd *bo.MultiNotifyDataBo, nl *bo.MultiNotifyLogBo, reply *v1.CmbReply) error { func (biz *MultiBiz) notifySuccess(ctx context.Context, mmd *bo.MultiNotifyDataBo, nl *bo.MultiNotifyLogBo, reply *v1.CmbReply) error {
response, err := json.Marshal(reply) response, err := json.Marshal(reply)
if err != nil { if err != nil {
return err return fmt.Errorf("json.Marshal CmbReply error: %v", err)
} }
if err = biz.MultiNotifyLogRepo.Success(ctx, nl.ID, string(response)); err != nil { if err = biz.MultiNotifyLogRepo.Success(ctx, nl.ID, string(response)); err != nil {
return err return fmt.Errorf("更新通知日志成功状态发生错误 error: %v", err)
} }
if err = biz.MultiNotifyDataRepo.AddNoticeNum(ctx, mmd.ID); err != nil { if err = biz.MultiNotifyDataRepo.AddNoticeNum(ctx, mmd.ID); err != nil {
return err return fmt.Errorf("更新通知数据通知次数发生错误 error: %v", err)
} }
return nil return nil