实现统一退货相关API功能

- 新增合单退货、退货、退货查询等API接口
- 使用gtime替代time包处理时间格式
- 新增客户端签名生成和HTTP请求发送逻辑
- 定义统一退货相关请求和响应数据结构
- 实现拉卡拉SDK统一退货服务实例化方法

lklsdk/common/client.go

@@ -0,0 +1,112 @@
+package common
+
+import (
+	"context"
+	"crypto"
+	"crypto/rand"
+	"crypto/rsa"
+	"crypto/sha256"
+	"crypto/x509"
+	"encoding/base64"
+	"encoding/json"
+	"encoding/pem"
+	"fmt"
+	ran "math/rand"
+	"time"
+
+	"github.com/black1552/base-common/utils"
+	"github.com/gogf/gf/v2/os/gfile"
+	"github.com/gogf/gf/v2/util/gconv"
+)
+
+// Client 拉卡拉SDK客户端
+type Client[T any] struct {
+	config   *Config
+	response T
+	ctx      context.Context
+}
+
+// NewClient 创建拉卡拉SDK客户端
+func NewClient[T any](ctx context.Context, cfgJson string) *Client[T] {
+	var config *Config
+	err := gconv.Struct(cfgJson, &config)
+	if err != nil {
+		return nil
+	}
+	return &Client[T]{
+		config: config,
+		ctx:    ctx,
+	}
+}
+func (c *Client[T]) generateNonceStr() string {
+	const letterBytes = "abcdefghijklmnopqrstuvwxyz0123456789"
+	nonce := make([]byte, 12)
+	for i := range nonce {
+		nonce[i] = letterBytes[ran.Intn(len(letterBytes))]
+	}
+	return string(nonce)
+}
+
+// generateSign 生成签名
+func (c *Client[T]) generateSign(request []byte) (string, error) {
+	// 生成随机字符串
+	nonceStr := c.generateNonceStr()
+	// 获取当前时间戳（秒）
+	timestamp := fmt.Sprintf("%d", time.Now().Unix())
+
+	// 构建待签名报文
+	signData := fmt.Sprintf("%s\n%s\n%s\n%s\n%s\n", c.config.AppId, c.config.SerialNo, timestamp, nonceStr, string(request))
+
+	// 计算签名
+	hashed := sha256.Sum256([]byte(signData))
+
+	privateKey, err := c.loadPrivateKey()
+	if err != nil {
+		return "", err
+	}
+	signature, err := rsa.SignPKCS1v15(rand.Reader, privateKey, crypto.SHA256, hashed[:])
+	if err != nil {
+		return "", err
+	}
+	signatureBase64 := base64.StdEncoding.EncodeToString(signature)
+
+	// 构建Authorization头
+	authorization := fmt.Sprintf("LKLAPI-SHA256withRSA appid=\"%s\",serial_no=\"%s\",timestamp=\"%s\",nonce_str=\"%s\",signature=\"%s\"",
+		c.config.AppId, c.config.SerialNo, timestamp, nonceStr, signatureBase64)
+	return authorization, nil
+}
+
+func (c *Client[T]) loadPrivateKey() (*rsa.PrivateKey, error) {
+	block, _ := pem.Decode(gfile.GetBytes(c.config.PrivateKey))
+	if block == nil {
+		return nil, fmt.Errorf("无法解码私钥PEM数据")
+	}
+	// 解析PKCS#8格式私钥
+	privateKey, err := x509.ParsePKCS8PrivateKey(block.Bytes)
+	if err != nil {
+		return nil, err
+	}
+	return privateKey.(*rsa.PrivateKey), nil
+}
+
+// DoRequest 发送HTTP请求
+func (c *Client[T]) DoRequest(url string, reqData interface{}) (*T, error) {
+	// 序列化为JSON
+	jsonData, err := json.Marshal(reqData)
+	if err != nil {
+		return nil, fmt.Errorf("序列化请求数据失败: %v", err)
+	}
+
+	auth, err := c.generateSign(jsonData)
+	if err != nil {
+		return nil, fmt.Errorf("生成签名失败: %v", err)
+	}
+	header := map[string]string{
+		"Authorization": auth,
+		"Content-Type":  "application/json",
+		"Accept":        "application/json",
+	}
+	// 设置其他必要的请求头
+
+	return utils.NewClient[T](jsonData, url, header).Post(c.ctx)
+}

lklsdk/common/structs.go

@@ -0,0 +1,14 @@
+package common
+
+// Config 拉卡拉SDK配置
+type Config struct {
+	PublicKey   string `json:"public_key" dc:"公钥字符串"`
+	PrivateKey  string `json:"private_key" dc:"私钥字符串"`
+	AppId       string `json:"app_id" dc:"lakala应用ID"`
+	SerialNo    string `json:"serial_no" dc:"序列号"`
+	SubAppId    string `json:"sub_app_id" dc:"子应用ID 微信AppId"`
+	Version     string `json:"version" dc:"lakala版本号"`
+	AccountType string `json:"account_type" dc:"账户类型"`
+	TransType   string `json:"trans_type" dc:"交易类型"`
+	NotifyUrl   string `json:"notify_url" dc:"回调地址"`
+}