Compare commits
No commits in common. "a7cf191437f7f16bb8255728efd3a75da42723d3" and "50924acbc7b58e41736ee1013f749cc5a68993f5" have entirely different histories.
a7cf191437
...
50924acbc7
|
@ -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
|
||||||
|
|
Loading…
Reference in New Issue