1

2023-04-06 18:25:24 +08:00
parent 18572ce050
commit 88e7b96fec
10 changed files with 457 additions and 18 deletions
--- a/platformapi/kuaishou_mini/kuaishou_callback.go
+++ b/platformapi/kuaishou_mini/kuaishou_callback.go
@@ -0,0 +1,93 @@
+package kuaishou_mini
+
+import (
+	"encoding/json"
+	"errors"
+	"git.rosy.net.cn/baseapi/utils"
+	"io/ioutil"
+	"net/http"
+)
+
+const (
+	CallbackTypePay    = "PAYMENT" // 支付回调
+	CallbackTypeRefund = "REFUND"  // 退款回调
+	CallbackTypeSettle = "SETTLE"  // 结算回调
+
+	OrderPayStatusHandleing = "PROCESSING" // 支付订单处理中
+	OrderPayStatusSuccess   = "SUCCESS"    // 订单支付成功
+	OrderPayStatusFailed    = "FAILED"     // 订单支付失败
+)
+
+// KauiShouCallback 回调处理
+func (a *API) KauiShouCallback(request *http.Request) (*CallBackDetail, *RefundCallBack, string, string, error) {
+	data, err := ioutil.ReadAll(request.Body)
+	if err != nil {
+		return nil, nil, "", "-1", err
+	}
+
+	var callback *KauiShouCallbackRes
+	if err := json.Unmarshal(data, &callback); err != nil {
+		return nil, nil, "", "-1", err
+	}
+
+	switch callback.BizType {
+	case CallbackTypePay:
+		var payCallback *CallBackDetail
+		if value, ok := callback.Data.(string); ok {
+			if err := json.Unmarshal([]byte(value), &payCallback); err != nil {
+				return nil, nil, "", callback.MessageId, err
+			}
+		} else {
+			if err := json.Unmarshal([]byte(utils.Interface2String(value)), &payCallback); err != nil {
+				return nil, nil, "", callback.MessageId, err
+			}
+		}
+		return payCallback, nil, CallbackTypePay, callback.MessageId, err
+	case CallbackTypeRefund:
+		var refundCallback *RefundCallBack
+		if value, ok := callback.Data.(string); ok {
+			if err := json.Unmarshal([]byte(value), &refundCallback); err != nil {
+				return nil, nil, "", callback.MessageId, err
+			}
+		} else {
+			if err := json.Unmarshal([]byte(utils.Interface2String(value)), &refundCallback); err != nil {
+				return nil, nil, "", callback.MessageId, err
+			}
+		}
+		return nil, refundCallback, CallbackTypeRefund, callback.MessageId, err
+	case CallbackTypeSettle:
+		return nil, nil, "", callback.MessageId, errors.New("无效回调类型")
+	default:
+		return nil, nil, "", callback.MessageId, errors.New("无效回调类型")
+	}
+}
+
+// KuaiShouRefundCallBack 快手退款回调
+//func (a *API) KuaiShouRefundCallBack(request *http.Request) (*RefundCallBack, error) {
+//	data, err := ioutil.ReadAll(request.Body)
+//	if err != nil {
+//		return nil, err
+//	}
+//
+//	var callback *RefundCallBack
+//	if err := json.Unmarshal(data, &callback); err != nil {
+//		return nil, err
+//	}
+//
+//	return callback, err
+//}
+
+// KuaiShouSettleCallBack 当订单结算成功之后，快手小程序服务端会通过 post 方式回调开发者提供的 HTTP 接口
+//func (a *API) KuaiShouSettleCallBack(request *http.Request) (*SettleCallback, error) {
+//	data, err := ioutil.ReadAll(request.Body)
+//	if err != nil {
+//		return nil, err
+//	}
+//
+//	var callback *SettleCallback
+//	if err := json.Unmarshal(data, &callback); err != nil {
+//		return nil, err
+//	}
+//
+//	return callback, err
+//}