Compare commits

..

No commits in common. "a7cf191437f7f16bb8255728efd3a75da42723d3" and "50924acbc7b58e41736ee1013f749cc5a68993f5" have entirely different histories.

1 changed files with 7 additions and 11 deletions

View File

@ -21,7 +21,6 @@ import (
// WxCallback 微信支付回调 // WxCallback 微信支付回调
func WxCallback(c *gin.Context) { func WxCallback(c *gin.Context) {
logger.Info(c, "WxCallback-回调数据", c.Request)
payChannelId := c.Param("payChannelId") payChannelId := c.Param("payChannelId")
logger.Info(c, "WxCallback-回调数据payChannelId", payChannelId) logger.Info(c, "WxCallback-回调数据payChannelId", payChannelId)
if payChannelId == "" { if payChannelId == "" {
@ -32,11 +31,7 @@ func WxCallback(c *gin.Context) {
var payChannelModel paychannelmodel.PayChannel var payChannelModel paychannelmodel.PayChannel
payChannelIdInt, _ := strconv.Atoi(payChannelId) payChannelIdInt, _ := strconv.Atoi(payChannelId)
payChannelModel.Id = int64(payChannelIdInt) payChannelModel.Id = int64(payChannelIdInt)
code := services.PayChannelGet(&payChannelModel) services.PayChannelGet(&payChannelModel)
if code == errorcode.PayChannelNotFound {
logger.Error(c, "AliCallback-回调数据未获取到支付配置404")
c.String(http.StatusBadRequest, "%s", "fail")
}
if payChannelModel.ChannelType != common.PAY_CHANNEL_WECHAT_H5 { if payChannelModel.ChannelType != common.PAY_CHANNEL_WECHAT_H5 {
logger.Error(c, "WxCallback-回调数据解析支付配置错误,查询的数据不是当前渠道") logger.Error(c, "WxCallback-回调数据解析支付配置错误,查询的数据不是当前渠道")
c.String(http.StatusBadRequest, "%s", "fail") c.String(http.StatusBadRequest, "%s", "fail")
@ -54,6 +49,7 @@ func WxCallback(c *gin.Context) {
} }
wxConfig.AppId = payChannelModel.AppId wxConfig.AppId = payChannelModel.AppId
logger.Info(c, "WxCallback-回调数据", c.Request)
notifyReq, err := wechat.V3ParseNotify(c.Request) notifyReq, err := wechat.V3ParseNotify(c.Request)
if err != nil { if err != nil {
logger.Error(c, "WxCallback-回调数据验签失败", err.Error()) logger.Error(c, "WxCallback-回调数据验签失败", err.Error())
@ -74,7 +70,6 @@ func WxCallback(c *gin.Context) {
// AliCallback 支付宝支付回调 // AliCallback 支付宝支付回调
func AliCallback(c *gin.Context) { func AliCallback(c *gin.Context) {
logger.Info(c, "AliCallback-回调数据", c.Request)
payChannelId := c.Param("payChannelId") payChannelId := c.Param("payChannelId")
logger.Info(c, "AliCallback-回调数据APPID", payChannelId) logger.Info(c, "AliCallback-回调数据APPID", payChannelId)
if payChannelId == "" { if payChannelId == "" {
@ -85,14 +80,14 @@ func AliCallback(c *gin.Context) {
payChannelIdInt, _ := strconv.Atoi(payChannelId) payChannelIdInt, _ := strconv.Atoi(payChannelId)
payChannelModel.Id = int64(payChannelIdInt) payChannelModel.Id = int64(payChannelIdInt)
code := services.PayChannelGet(&payChannelModel) code := services.PayChannelGet(&payChannelModel)
if code == errorcode.PayChannelNotFound {
logger.Error(c, "AliCallback-回调数据未获取到支付配置404")
c.String(http.StatusBadRequest, "%s", "fail")
}
if payChannelModel.ChannelType != common.PAY_CHANNEL_ALIPAY_WEB { if payChannelModel.ChannelType != common.PAY_CHANNEL_ALIPAY_WEB {
logger.Error(c, "AliCallback-回调数据解析支付配置错误,查询的数据不是当前渠道") logger.Error(c, "AliCallback-回调数据解析支付配置错误,查询的数据不是当前渠道")
c.String(http.StatusBadRequest, "%s", "fail") c.String(http.StatusBadRequest, "%s", "fail")
} }
if code == errorcode.PayChannelNotFound {
logger.Error(c, "AliCallback-回调数据未获取到支付配置404")
c.String(http.StatusBadRequest, "%s", "fail")
}
var aliConfig paymentService.AliPay var aliConfig paymentService.AliPay
var aliConfigModel struct { var aliConfigModel struct {
@ -117,6 +112,7 @@ func AliCallback(c *gin.Context) {
aliConfig.AlipayPublicCert = []byte(aliConfigModel.AlipayPublicCert) aliConfig.AlipayPublicCert = []byte(aliConfigModel.AlipayPublicCert)
notifyReq, err := alipay.ParseNotifyToBodyMap(c.Request) // c.Request 是 gin 框架的写法 notifyReq, err := alipay.ParseNotifyToBodyMap(c.Request) // c.Request 是 gin 框架的写法
logger.Info(c, "AliCallback-回调数据", c.Request)
if err != nil { if err != nil {
xlog.Error(err) xlog.Error(err)
return return