liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2022-06-02 10:13:04 +08:00
parent 632b324bbc
commit cbbb9bfd89
3 changed files with 6 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
business/partner/purchase/jx/localjx/tiktokPay.go
View File

@@ -51,7 +51,7 @@ func pay4OrderByTT(ctx *jxcontext.Context, order *model.GoodsOrder, vendorPayTyp
} }
func OnTTPayCallback(msg *tiktok.DetailCallBackMessage, refund *tiktok.DetailCallBackMessage2Refund, payType string) (err error) { func OnTTPayCallback(msg *tiktok.DetailCallBackMessage, refund *tiktok.DetailCallBackMessage2Refund, payType string) (err error) {
globals.SugarLogger.Debugf("OnWxPayCallback msg:%s", utils.Format4Output(msg, true)) globals.SugarLogger.Debugf("OnTTPayCallback msg:%s", utils.Format4Output(msg, true))
switch payType { switch payType {
case tiktok.PayStatus: // 支付回调 case tiktok.PayStatus: // 支付回调
err = onTTPayFinished(msg) err = onTTPayFinished(msg)
@@ -62,6 +62,7 @@ func OnTTPayCallback(msg *tiktok.DetailCallBackMessage, refund *tiktok.DetailCal
} }
func onTTPayFinished(msg *tiktok.DetailCallBackMessage) (err error) { func onTTPayFinished(msg *tiktok.DetailCallBackMessage) (err error) {
globals.SugarLogger.Debugf("支付回调==================1")
orderPay := &model.OrderPay{ orderPay := &model.OrderPay{
PayOrderID: msg.CpOrderno, PayOrderID: msg.CpOrderno,
PayType: model.PayTypeWX, PayType: model.PayTypeWX,
@@ -88,6 +89,7 @@ func onTTPayFinished(msg *tiktok.DetailCallBackMessage) (err error) {
} }
func onTTPayRefund(msg *tiktok.DetailCallBackMessage2Refund) (err error) { func onTTPayRefund(msg *tiktok.DetailCallBackMessage2Refund) (err error) {
globals.SugarLogger.Debugf("退款回调==================2")
orderPayRefund := &model.OrderPayRefund{ orderPayRefund := &model.OrderPayRefund{
RefundID: msg.CpRefundno, RefundID: msg.CpRefundno,
} }

4
controllers/tictok_callback.go
View File

@@ -38,19 +38,21 @@ func MsgFail() *TicktockRes {
} }
} }
func (c *TicTocController) Msg() { func (c *TicTocController) TtMsg() {
if c.Ctx.Input.Method() == http.MethodPost { if c.Ctx.Input.Method() == http.MethodPost {
call, refund, payType, err := api.TiktokApi.GetCallbackMsg(getPayInfo(c.Ctx)) call, refund, payType, err := api.TiktokApi.GetCallbackMsg(getPayInfo(c.Ctx))
globals.SugarLogger.Debugf("tictok callback callbackResponse:%s", utils.Format4Output(call, true)) globals.SugarLogger.Debugf("tictok callback callbackResponse:%s", utils.Format4Output(call, true))
if err != nil { if err != nil {
c.Data["json"] = MsgFail() c.Data["json"] = MsgFail()
c.ServeJSON() c.ServeJSON()
globals.SugarLogger.Debugf("============err:%s", err)
return return
} }
err = localjx.OnTTPayCallback(call, refund, payType) err = localjx.OnTTPayCallback(call, refund, payType)
if err != nil { if err != nil {
c.Data["json"] = MsgFail() c.Data["json"] = MsgFail()
c.ServeJSON() c.ServeJSON()
globals.SugarLogger.Debugf("============err:%s", err)
return return
} }
c.Data["json"] = MsgSuccess() c.Data["json"] = MsgSuccess()

41
controllers/ttpay_callback.go
View File

@@ -1,41 +0,0 @@
package controllers
import (
"fmt"
"net/http"
"git.rosy.net.cn/baseapi/platformapi/wxpayapi"
"git.rosy.net.cn/baseapi/utils"
"git.rosy.net.cn/jx-callback/business/partner/purchase/jx/localjx"
"git.rosy.net.cn/jx-callback/globals"
"git.rosy.net.cn/jx-callback/globals/api"
"github.com/astaxie/beego/server/web"
)
type TTPayController struct {
web.Controller
}
func (c *TTPayController) TtMsg() {
if c.Ctx.Input.Method() == http.MethodPost {
msg, callbackResponse := api.WxpayAPI.GetCallbackMsg(c.Ctx.Request)
globals.SugarLogger.Debugf("wxpayapi callback msg:%s, callbackResponse:%s, %t", utils.Format4Output(msg, true), utils.Format4Output(callbackResponse, true), callbackResponse == nil)
var err error
if callbackResponse == nil {
if msg.MsgType == wxpayapi.MsgTypeUnkown {
err = fmt.Errorf("未知的微信支付回调类型:%d", msg.MsgType)
} else {
err = localjx.OnWxPayCallback(msg)
}
}
if callbackResponse == nil {
callbackResponse = wxpayapi.SuccessResponse
} else if err != nil {
callbackResponse = wxpayapi.Err2CallbackResponse(err, "")
}
c.Data["xml"] = callbackResponse
c.ServeXML()
} else {
c.Abort("404")
}
}