app/http/controllers/front/payment_controller.go

@@ -12,6 +12,7 @@ import (
 	"github.com/go-pay/gopay"
 	"github.com/go-pay/gopay/alipay"
 	"github.com/go-pay/gopay/wechat/v3"
+	"github.com/go-pay/xlog"
 	"github.com/qit-team/snow-core/log/logger"
 	"strconv"
 
@@ -25,7 +26,6 @@ func WxCallback(c *gin.Context) {
 	logger.Info(c, "WxCallback-回调数据payChannelId", payChannelId)
 	if payChannelId == "" {
 		c.String(http.StatusBadRequest, "%s", "fail")
-		return
 	}
 
 	// 查询应用下的支付配置
@@ -36,12 +36,10 @@ func WxCallback(c *gin.Context) {
 	if code == errorcode.PayChannelNotFound {
 		logger.Error(c, "AliCallback-回调数据未获取到支付配置，404")
 		c.String(http.StatusBadRequest, "%s", "fail")
-		return
 	}
 	if payChannelModel.ChannelType != common.PAY_CHANNEL_WECHAT_H5 {
 		logger.Error(c, "WxCallback-回调数据解析支付配置错误,查询的数据不是当前渠道")
 		c.String(http.StatusBadRequest, "%s", "fail")
-		return
 	}
 
 	var wxConfig paymentService.WxPay
@@ -49,26 +47,22 @@ func WxCallback(c *gin.Context) {
 	if err != nil {
 		logger.Error(c, "WxCallback-回调数据解析支付配置错误", fmt.Sprintf("错误原因：%s", err.Error()))
 		c.String(http.StatusBadRequest, "%s", "fail")
-		return
 	}
 	if wxConfig.ApiV3Key == "" || wxConfig.MchId == "" || wxConfig.PrivateKey == "" || wxConfig.SerialNo == "" {
 		logger.Error(c, "WxCallback-回调数据解析支付配置错误，解析出来的信息为空")
 		c.String(http.StatusBadRequest, "%s", "fail")
-		return
 	}
 	wxConfig.AppId = payChannelModel.AppId
 
 	notifyReq, err := wechat.V3ParseNotify(c.Request)
 	if err != nil {
 		logger.Error(c, "WxCallback-回调数据验签失败", err.Error())
-		c.String(http.StatusBadRequest, "%s", "fail")
 		return
 	}
 
 	err = paymentService.WxPayCallBack(notifyReq, wxConfig)
 	if err != nil {
 		logger.Error(c, "WxCallback-回调执行失败，失败原因：", err.Error())
-		c.String(http.StatusBadRequest, "%s", "fail")
 		return
 	}
 
@@ -76,7 +70,6 @@ func WxCallback(c *gin.Context) {
 	// 退款通知http应答码为200且返回状态码为SUCCESS才会当做商户接收成功，否则会重试。
 	// 注意：重试过多会导致微信支付端积压过多通知而堵塞，影响其他正常通知。
 	c.JSON(http.StatusOK, &wechat.V3NotifyRsp{Code: gopay.SUCCESS, Message: "成功"})
-	return
 }
 
 // AliCallback	支付宝支付回调
@@ -86,7 +79,6 @@ func AliCallback(c *gin.Context) {
 	logger.Info(c, "AliCallback-回调数据APPID", payChannelId)
 	if payChannelId == "" {
 		c.String(http.StatusBadRequest, "%s", "fail")
-		return
 	}
 	// 查询应用下的支付配置
 	var payChannelModel paychannelmodel.PayChannel
@@ -96,12 +88,10 @@ func AliCallback(c *gin.Context) {
 	if code == errorcode.PayChannelNotFound {
 		logger.Error(c, "AliCallback-回调数据未获取到支付配置，404")
 		c.String(http.StatusBadRequest, "%s", "fail")
-		return
 	}
 	if payChannelModel.ChannelType != common.PAY_CHANNEL_ALIPAY_WEB {
 		logger.Error(c, "AliCallback-回调数据解析支付配置错误,查询的数据不是当前渠道")
 		c.String(http.StatusBadRequest, "%s", "fail")
-		return
 	}
 
 	var aliConfig paymentService.AliPay
@@ -115,12 +105,10 @@ func AliCallback(c *gin.Context) {
 	if err != nil {
 		logger.Error(c, "AliCallback-回调数据解析支付配置错误", fmt.Sprintf("错误原因：%s", err.Error()))
 		c.String(http.StatusBadRequest, "%s", "fail")
-		return
 	}
 	if aliConfigModel.AlipayPublicCert == "" || aliConfigModel.PrivateKey == "" || aliConfigModel.AppPublicCert == "" || aliConfigModel.AlipayRootCert == "" {
 		logger.Error(c, "AliCallback-回调数据解析支付配置错误，解析出来的信息为空")
 		c.String(http.StatusBadRequest, "%s", "fail")
-		return
 	}
 	aliConfig.AppId = payChannelModel.AppId
 	aliConfig.PrivateKey = aliConfigModel.PrivateKey
@@ -130,16 +118,14 @@ func AliCallback(c *gin.Context) {
 
 	notifyReq, err := alipay.ParseNotifyToBodyMap(c.Request) // c.Request 是 gin 框架的写法
 	if err != nil {
-		c.String(http.StatusBadRequest, "%s", "fail")
+		xlog.Error(err)
 		return
 	}
 	err = paymentService.ALiCallBack(notifyReq, aliConfig)
 	if err != nil {
 		logger.Error(c, "AliCallback-回调执行失败，失败原因：", err.Error())
-		c.String(http.StatusBadRequest, "%s", "fail")
 		return
 	}
 
 	c.String(http.StatusOK, "%s", "success")
-	return
 }

app/third/paymentService/payment_test.go

@@ -1,6 +1,7 @@
 package paymentService
 
 import (
+	"PaymentCenter/bootstrap"
 	"PaymentCenter/config"
 	"context"
 	"crypto/md5"
@@ -27,7 +28,12 @@ func TestMarketSendRequest_Market(t *testing.T) {
 
 	//加载配置
 	opts.ConfFile = "../../../.env"
-	_, err := config.Load(opts.ConfFile)
+	conf, err := config.Load(opts.ConfFile)
+	if err != nil {
+		return
+	}
+	//引导程序
+	err = bootstrap.Bootstrap(conf)
 	if err != nil {
 		return
 	}

config/config.go

@@ -93,7 +93,7 @@ type CronConfig struct {
 }
 
 type PayService struct {
-	Host   string `toml:"Host"`
+	Host   string `toml:"TestHost"`
 	IsProd bool   `toml:"IsProd"`
 }