diff --git a/internal/biz/multi.go b/internal/biz/multi.go index a87c1aa..21ed30e 100644 --- a/internal/biz/multi.go +++ b/internal/biz/multi.go @@ -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 { if nl.RequestURL == "" { - if err := biz.notifyFail(ctx, nl, "回调通知招行地址为空"); err != nil { + if err := biz.notifyFail(ctx, nl, "回调通知招行地址为空,不做通知"); err != nil { return err } - // 回调通知地址为空,不反回错误,不做再次通知处理 + // 回调通知地址为空,不返回错误,不做再次通知处理 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 { + errMsg := fmt.Sprintf("回调通知招行返回验证结果发生错误,resp:%+v error:%s", reply, err.Error()) + if err2 := biz.notifyFail(ctx, nl, errMsg); err2 != nil { 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 { - 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 { response, err := json.Marshal(reply) 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 { - return err + return fmt.Errorf("更新通知日志成功状态发生错误 error: %v", err) } if err = biz.MultiNotifyDataRepo.AddNoticeNum(ctx, mmd.ID); err != nil { - return err + return fmt.Errorf("更新通知数据通知次数发生错误 error: %v", err) } return nil