diff --git a/internal/server/http.go b/internal/server/http.go index c91851e..1cd1114 100644 --- a/internal/server/http.go +++ b/internal/server/http.go @@ -34,8 +34,6 @@ func NewHTTPServer( return ctx.String(http2.StatusOK, "pong") }) - r.POST("/wechatNotify", voucherService.WechatNotify) - cmb := r.Group("/cmb") v1 := cmb.Group("/v1") diff --git a/internal/service/wechat_notify_consume.go b/internal/service/wechat_notify_consume.go index 7e1ee5d..8f4acd4 100644 --- a/internal/service/wechat_notify_consume.go +++ b/internal/service/wechat_notify_consume.go @@ -3,23 +3,9 @@ package service import ( "context" "encoding/json" - "github.com/go-kratos/kratos/v2/log" - "github.com/go-kratos/kratos/v2/transport/http" - "io" "voucher/internal/biz/bo" ) -func (v *VoucherService) WechatNotify(ctx http.Context) error { - bodyBytes, err := io.ReadAll(ctx.Request().Body) - if err != nil { - return err - } - - log.Warnf("微信回调通知bodyBytes: %s", bodyBytes) - - return ctx.JSON(200, "ok") -} - func (v *VoucherService) WechatUseNotifyConsumer(ctx context.Context, tag, msg string) error { var req *bo.WechatVoucherNotifyBo