切换主体

This commit is contained in:
ziming 2026-03-26 15:05:18 +08:00
parent 0d5259c9b0
commit 417e813b84
1 changed files with 2 additions and 6 deletions

View File

@ -68,15 +68,11 @@ func (srv *NotifyService) Notify(ctx http.Context) error {
}) })
} }
headerJson, _ := json.Marshal(headers)
log.Warnf("微信回调通知[%s],consumer处理失败:%s\nheaders:%s\nbody:%s\n解析数据:%+v", mchId, err.Error(), headerJson, string(bodyBytes), bizData)
ip := helper.GetClientIP(ctx) ip := helper.GetClientIP(ctx)
if err = srv.VoucherBiz.WechatNotifyConsumer(ctx, ip, bizData); err != nil { 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)
if errors.Is(err, gorm.ErrRecordNotFound) { if errors.Is(err, gorm.ErrRecordNotFound) {
return ctx.JSON(http2.StatusOK, nil) return ctx.JSON(http2.StatusOK, nil)