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