From 5051e2e744712e8b4c7b8c7278e3e56f912eb4df Mon Sep 17 00:00:00 2001 From: ziming Date: Thu, 26 Mar 2026 10:57:16 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=87=E6=8D=A2=E4=B8=BB=E4=BD=93?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/service/notify.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/internal/service/notify.go b/internal/service/notify.go index 2dacb6d..4425565 100644 --- a/internal/service/notify.go +++ b/internal/service/notify.go @@ -55,11 +55,11 @@ func (srv *NotifyService) Notify(ctx http.Context) error { }) } - headerJson, _ := json.Marshal(headers) - log.Warnf("微信回调通知[%s],数据,headers:%s,body:%s", mchId, string(headerJson), string(bodyBytes)) - response, err := srv.WechatBiz.CallBack(ctx, mchId, &headers, bodyBytes) if err != nil { + headerJson, _ := json.Marshal(headers) + 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(), @@ -72,7 +72,9 @@ func (srv *NotifyService) Notify(ctx http.Context) error { if err = srv.VoucherBiz.WechatNotifyConsumer(ctx, ip, response); err != nil { - log.Errorf("微信回调通知[%s],处理失败,headers:%s,body:%s,err:%s", mchId, headerJson, string(bodyBytes), err.Error()) + headerJson, _ := json.Marshal(headers) + log.Errorf("微信回调通知[%s],Consumer处理失败,headers:%s,body:%s,err:%s", mchId, headerJson, string(bodyBytes), err.Error()) + return ctx.JSON(http2.StatusBadRequest, map[string]string{ "code": "FAIL", "message": err.Error(),