1

platformapi/kuaishou_mini/kuaishou_test.go

@@ -2,13 +2,14 @@ package kuaishou_mini
 
 import (
 	"encoding/base64"
+	"encoding/json"
+	"errors"
 	"fmt"
 	"git.rosy.net.cn/baseapi"
 	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/globals"
 	"go.uber.org/zap"
 	"testing"
-	"time"
 )
 
 var (
@@ -106,10 +107,36 @@ func TestAaww(t *testing.T) {
 }
 
 func TestLen(t *testing.T) {
-	for {
-		time.Sleep(1 * time.Second)
-		a := time.Now().Unix()
-		fmt.Println("a====", a)
-		fmt.Println(a%3 == 0)
+	data := `{"data":{"ks_order_no":"123060711428646148797","refund_type":null,"out_refund_no":null,"ks_settle_no":null,"channel":"WECHAT","out_order_no":"88423854448004","ks_refund_fail_reason":null,"apply_refund_reason":null,"promotion_amount":0,"developer_promotion_amount":0,"extra_info":"{\"url\":\"\",\"provider\":\"\",\"item_type\":\"UNKNOWN\",\"item_id\":\"\",\"author_id\":\"\",\"refer_id\":\"\",\"channel_mark\":\"\",\"provider_type\":\"\",\"trade_no\":\"4307400963202306073218531739\"}","settle_amount":null,"order_amount":2,"enable_promotion":false,"out_settle_no":null,"refund_amount":null,"trade_no":"4307400963202306073218531739","attach":"","ks_refund_no":null,"status":"SUCCESS"},"biz_type":"PAYMENT","message_id":"65299d6d-072e-4804-8ef4-23451024a0d9","app_id":"ks680887971696897880","timestamp":1686129660709}`
+	ACCC(data)
+}
+
+func ACCC(data string) (*CallBackDetail, *RefundCallBack, string, string, error) {
+	globals.SugarLogger.Debugf("data================: %s", string(data))
+	var callback *KauiShouCallbackRes
+	if err := json.Unmarshal([]byte(data), &callback); err != nil {
+		return nil, nil, "", "-1", err
+	}
+
+	switch callback.BizType {
+	case CallbackTypePay:
+		var payCallback *CallBackDetail
+		globals.SugarLogger.Debugf("payCallback : %s", utils.Format4Output(callback.Data, false))
+		if err := utils.Map2StructByJson(callback.Data, &payCallback, false); err != nil {
+			globals.SugarLogger.Debugf("err3 =========== :%s", utils.Format4Output(err, false))
+			return nil, nil, "", callback.MessageId, err
+		}
+		return payCallback, nil, CallbackTypePay, callback.MessageId, nil
+	case CallbackTypeRefund:
+		var refundCallback *RefundCallBack
+		if err := utils.Map2StructByJson(callback.Data, &refundCallback, false); err != nil {
+			globals.SugarLogger.Debugf("err5 =========== :%s", utils.Format4Output(err, false))
+			return nil, nil, "", callback.MessageId, err
+		}
+		return nil, refundCallback, CallbackTypeRefund, callback.MessageId, nil
+	case CallbackTypeSettle:
+		return nil, nil, "", callback.MessageId, errors.New("无效回调类型")
+	default:
+		return nil, nil, "", callback.MessageId, errors.New("无效回调类型")
 	}
 }