活动批次查询确认

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")

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