diff --git a/internal/service/notify.go b/internal/service/notify.go index f46a0f3..3ad1ea4 100644 --- a/internal/service/notify.go +++ b/internal/service/notify.go @@ -62,10 +62,7 @@ func (srv *NotifyService) Notify(ctx http.Context) error { bizData, err := srv.WechatBiz.CallBack(ctx, mchId, &headers, bodyBytes) if err != nil { - - //log.Errorf("微信回调通知[%s],CallBack处理失败,headers:%s,body:%s,err:%s", mchId, headerJson, string(bodyBytes), err.Error()) - log.Errorf("微信回调通知[%s],CallBack处理失败,:%s", mchId, err.Error()) - + log.Errorf("微信回调通知[%s],CallBack处理失败,headers:%s,body:%s,err:%s", mchId, headerJson, string(bodyBytes), err.Error()) return ctx.JSON(http2.StatusNetworkAuthenticationRequired, map[string]string{ "code": "FAIL", "message": err.Error(), @@ -75,8 +72,8 @@ func (srv *NotifyService) Notify(ctx http.Context) error { ip := helper.GetClientIP(ctx) if err = srv.VoucherBiz.WechatNotifyConsumer(ctx, ip, bizData); err != nil { - headerJson, _ := json.Marshal(headers) - log.Errorf("微信回调通知[%s],consumer处理失败:%s\nheaders:%s\nbody:%s\n解析数据:%+v", mchId, err.Error(), headerJson, string(bodyBytes), bizData) + //log.Errorf("微信回调通知[%s],consumer处理失败:%s\nheaders:%s\nbody:%s\n解析数据:%+v", mchId, err.Error(), headerJson, string(bodyBytes), bizData) + log.Errorf("微信回调通知[%s],consumer处理失败[%s-%s]", mchId, bizData.PlainText.CouponID, err.Error()) if errors.Is(err, gorm.ErrRecordNotFound) { return ctx.JSON(http2.StatusOK, nil)