Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0aa9bc80ec | ||
|
|
1e5214abfb | ||
|
|
bcb4a9536a |
@@ -19,7 +19,7 @@ lklsdk/
|
|||||||
|
|
||||||
```bash
|
```bash
|
||||||
# 将SDK引入到您的项目中
|
# 将SDK引入到您的项目中
|
||||||
go get -u github.com/black1552/lkl_sdk/lklsdk
|
go get -u github.com/black1552/lkl_sdk
|
||||||
```
|
```
|
||||||
|
|
||||||
## 快速开始
|
## 快速开始
|
||||||
@@ -33,22 +33,21 @@ import (
|
|||||||
"github.com/gogf/gf/v2/os/gctx"
|
"github.com/gogf/gf/v2/os/gctx"
|
||||||
)
|
)
|
||||||
|
|
||||||
// 创建配置
|
// 创建配置JSON字符串
|
||||||
config := &lklsdk.Config{
|
cfgJson := `{
|
||||||
AppID: "your_app_id", // 拉卡拉分配的AppID
|
"public_key": "your_public_key", // 公钥字符串
|
||||||
TermNo: "your_term_no", // 终端号
|
"private_key": "your_private_key", // 私钥字符串
|
||||||
MerchantNo: "your_merchant_no", // 商户号
|
"app_id": "your_app_id", // lakala应用ID
|
||||||
SettleMerNo: "your_settle_mer_no", // 结算商户号
|
"serial_no": "your_serial_no", // 序列号
|
||||||
SettleTermNo: "your_settle_term_no", // 结算终端号
|
"sub_app_id": "your_sub_app_id", // 子应用ID 微信AppId
|
||||||
AccountType: "WECHAT", // 账户类型,如WECHAT、ALIPAY等
|
"version": "3.0", // lakala版本号
|
||||||
TransType: "71", // 交易类型
|
"account_type": "WECHAT", // 账户类型
|
||||||
Version: "3.0", // API版本
|
"trans_type": "71", // 交易类型
|
||||||
NotifyURL: "your_notify_url", // 回调URL
|
"notify_url": "your_notify_url" // 回调地址
|
||||||
SerialNo: "your_mch_api_key", // 商户API密钥
|
}`
|
||||||
}
|
|
||||||
|
|
||||||
// 初始化SDK(使用泛型指定响应类型)
|
// 初始化SDK(使用泛型指定响应类型)
|
||||||
sdk := lklsdk.NewSDK[model.ResponseType](gctx.New(), config)
|
sdk := lklsdk.NewSDK[model.ResponseType](gctx.New(), cfgJson)
|
||||||
```
|
```
|
||||||
|
|
||||||
## 功能模块
|
## 功能模块
|
||||||
@@ -57,7 +56,7 @@ sdk := lklsdk.NewSDK[model.ResponseType](gctx.New(), config)
|
|||||||
|
|
||||||
```go
|
```go
|
||||||
// 初始化特定响应类型的SDK
|
// 初始化特定响应类型的SDK
|
||||||
sdk := lklsdk.NewSDK[model.MergePreorderResponse](gctx.New(), config)
|
sdk := lklsdk.NewSDK[model.MergePreorderResponse](gctx.New(), cfgJson)
|
||||||
|
|
||||||
// 准备拆单信息
|
// 准备拆单信息
|
||||||
outSplitInfo := []*model.OutSplitInfo{
|
outSplitInfo := []*model.OutSplitInfo{
|
||||||
@@ -110,7 +109,7 @@ if !mergePreorderResp.SuccessOrFail() {
|
|||||||
|
|
||||||
```go
|
```go
|
||||||
// 初始化特定响应类型的SDK
|
// 初始化特定响应类型的SDK
|
||||||
sdk := lklsdk.NewSDK[model.ApplyLedgerMerResponse](gctx.New(), config)
|
sdk := lklsdk.NewSDK[model.ApplyLedgerMerResponse](gctx.New(), cfgJson)
|
||||||
|
|
||||||
// 构建请求参数
|
// 构建请求参数
|
||||||
applyLedgerReq := &model.ApplyLedgerMerReqData{
|
applyLedgerReq := &model.ApplyLedgerMerReqData{
|
||||||
@@ -143,7 +142,7 @@ if !expectResp.SuccessOrFail() {
|
|||||||
|
|
||||||
```go
|
```go
|
||||||
// 初始化特定响应类型的SDK
|
// 初始化特定响应类型的SDK
|
||||||
sdk := lklsdk.NewSDK[model.TradeQueryResponse](gctx.New(), config)
|
sdk := lklsdk.NewSDK[model.TradeQueryResponse](gctx.New(), cfgJson)
|
||||||
|
|
||||||
// 构建请求参数
|
// 构建请求参数
|
||||||
tradeQueryReq := &model.TradeQueryReqData{
|
tradeQueryReq := &model.TradeQueryReqData{
|
||||||
@@ -168,7 +167,7 @@ if !tradeQueryResp.SuccessOrFail() {
|
|||||||
|
|
||||||
```go
|
```go
|
||||||
// 初始化特定响应类型的SDK
|
// 初始化特定响应类型的SDK
|
||||||
sdk := lklsdk.NewSDK[model.OrderSplitLedgerResponse](gctx.New(), config)
|
sdk := lklsdk.NewSDK[model.OrderSplitLedgerResponse](gctx.New(), cfgJson)
|
||||||
|
|
||||||
// 准备分账接收方数据
|
// 准备分账接收方数据
|
||||||
var recvDatas []*model.OrderSplitLedgerRecvDatas
|
var recvDatas []*model.OrderSplitLedgerRecvDatas
|
||||||
@@ -199,11 +198,44 @@ if !splitLedgerResp.SuccessOrFail() {
|
|||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
|
||||||
### 5. 账户余额查询
|
### 5. 退款
|
||||||
|
|
||||||
```go
|
```go
|
||||||
// 初始化特定响应类型的SDK
|
// 初始化特定响应类型的SDK
|
||||||
sdk := lklsdk.NewSDK[model.BalanceQueryResponse](gctx.New(), config)
|
sdk := lklsdk.NewSDK[model.RefundResponse](gctx.New(), cfgJson)
|
||||||
|
|
||||||
|
// 构建请求参数
|
||||||
|
refundReq := &model.RefundReqData{
|
||||||
|
MerchantNo: "your_merchant_no", // 商户号
|
||||||
|
TermNo: "your_term_no", // 终端号
|
||||||
|
OutTradeNo: "original_out_trade_no", // 原商户交易流水号
|
||||||
|
OutRefundNo: "your_refund_out_trade_no", // 退款商户流水号
|
||||||
|
RefundAmount: "100", // 退款金额,单位为分
|
||||||
|
TotalAmount: "100", // 原交易总金额,单位为分
|
||||||
|
RefundReason: "退款原因", // 退款原因
|
||||||
|
NotifyUrl: "https://your-notify-url.com", // 回调地址
|
||||||
|
}
|
||||||
|
|
||||||
|
// 调用接口
|
||||||
|
refundResp, err := sdk.Refound(refundReq)
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("退款失败: %v\n", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
// 使用SuccessOrFail方法判断请求是否成功
|
||||||
|
if !refundResp.SuccessOrFail() {
|
||||||
|
log.Printf("退款失败: %s\n", refundResp.Msg)
|
||||||
|
}
|
||||||
|
|
||||||
|
// 处理成功响应
|
||||||
|
// 可以从refundResp.RespData中获取退款结果数据
|
||||||
|
```
|
||||||
|
|
||||||
|
### 6. 账户余额查询
|
||||||
|
|
||||||
|
```go
|
||||||
|
// 初始化特定响应类型的SDK
|
||||||
|
sdk := lklsdk.NewSDK[model.BalanceQueryResponse](gctx.New(), cfgJson)
|
||||||
|
|
||||||
// 构建请求参数
|
// 构建请求参数
|
||||||
balanceQueryReq := &model.BalanceQueryReqData{
|
balanceQueryReq := &model.BalanceQueryReqData{
|
||||||
|
|||||||
+18
-15
@@ -16,22 +16,20 @@ import (
|
|||||||
|
|
||||||
"github.com/black1552/base-common/utils"
|
"github.com/black1552/base-common/utils"
|
||||||
"github.com/gogf/gf/v2/os/gfile"
|
"github.com/gogf/gf/v2/os/gfile"
|
||||||
|
"github.com/gogf/gf/v2/util/gconv"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Config 拉卡拉SDK配置
|
// Config 拉卡拉SDK配置
|
||||||
type Config struct {
|
type Config struct {
|
||||||
AppID string `json:"app_id"`
|
PublicKey string `json:"public_key" dc:"公钥字符串"`
|
||||||
TermNo string `json:"term_no"`
|
PrivateKey string `json:"private_key" dc:"私钥字符串"`
|
||||||
MerchantNo string `json:"merchant_no"`
|
AppId string `json:"app_id" dc:"lakala应用ID"`
|
||||||
SettleMerNo string `json:"settle_merchant_no"`
|
SerialNo string `json:"serial_no" dc:"序列号"`
|
||||||
SettleTermNo string `json:"settle_term_no"`
|
SubAppId string `json:"sub_app_id" dc:"子应用ID 微信AppId"`
|
||||||
AccountType string `json:"account_type"`
|
Version string `json:"version" dc:"lakala版本号"`
|
||||||
TransType string `json:"trans_type"`
|
AccountType string `json:"account_type" dc:"账户类型"`
|
||||||
Version string `json:"version"`
|
TransType string `json:"trans_type" dc:"交易类型"`
|
||||||
NotifyURL string `json:"notify_url"`
|
NotifyUrl string `json:"notify_url" dc:"回调地址"`
|
||||||
PublicKey string `json:"public_key"`
|
|
||||||
PrivateKey string `json:"private_key"`
|
|
||||||
SerialNo string `json:"serial_no"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Client 拉卡拉SDK客户端
|
// Client 拉卡拉SDK客户端
|
||||||
@@ -42,7 +40,12 @@ type Client[T any] struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// NewClient 创建拉卡拉SDK客户端
|
// NewClient 创建拉卡拉SDK客户端
|
||||||
func NewClient[T any](ctx context.Context, config *Config) *Client[T] {
|
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]{
|
return &Client[T]{
|
||||||
config: config,
|
config: config,
|
||||||
ctx: ctx,
|
ctx: ctx,
|
||||||
@@ -65,7 +68,7 @@ func (c *Client[T]) generateSign(request []byte) (string, error) {
|
|||||||
timestamp := fmt.Sprintf("%d", time.Now().Unix())
|
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))
|
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))
|
hashed := sha256.Sum256([]byte(signData))
|
||||||
@@ -82,7 +85,7 @@ func (c *Client[T]) generateSign(request []byte) (string, error) {
|
|||||||
|
|
||||||
// 构建Authorization头
|
// 构建Authorization头
|
||||||
authorization := fmt.Sprintf("LKLAPI-SHA256withRSA appid=\"%s\",serial_no=\"%s\",timestamp=\"%s\",nonce_str=\"%s\",signature=\"%s\"",
|
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)
|
c.config.AppId, c.config.SerialNo, timestamp, nonceStr, signatureBase64)
|
||||||
return authorization, nil
|
return authorization, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+2
-2
@@ -17,8 +17,8 @@ type SDK[T any] struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// NewSDK 创建拉卡拉SDK实例
|
// NewSDK 创建拉卡拉SDK实例
|
||||||
func NewSDK[T any](ctx context.Context, config *Config) *SDK[T] {
|
func NewSDK[T any](ctx context.Context, cfgJson string) *SDK[T] {
|
||||||
client := NewClient[T](ctx, config)
|
client := NewClient[T](ctx, cfgJson)
|
||||||
return &SDK[T]{
|
return &SDK[T]{
|
||||||
Client: client,
|
Client: client,
|
||||||
SplitLedger: NewSplitLedgerService(client),
|
SplitLedger: NewSplitLedgerService(client),
|
||||||
|
|||||||
+1
-1
@@ -28,7 +28,7 @@ func (t *TradeService[T]) TradeQuery(req *model.TradeQueryReqData) (*T, error) {
|
|||||||
baseReq := model.TradeQuery{
|
baseReq := model.TradeQuery{
|
||||||
ReqTime: time.Now().Format("20060102150405"),
|
ReqTime: time.Now().Format("20060102150405"),
|
||||||
Version: "3.0",
|
Version: "3.0",
|
||||||
OutOrgCode: t.client.config.AppID,
|
OutOrgCode: t.client.config.AppId,
|
||||||
ReqData: req,
|
ReqData: req,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+4
-2
@@ -24,11 +24,13 @@ type ApplyBindReqData struct {
|
|||||||
EntrustFileName string `json:"entrustFileName"` // 合作协议附件名称,必传,长度32
|
EntrustFileName string `json:"entrustFileName"` // 合作协议附件名称,必传,长度32
|
||||||
EntrustFilePath string `json:"entrustFilePath"` // 合作协议附件路径,必传,长度32,通过调用附件上传接口获取
|
EntrustFilePath string `json:"entrustFilePath"` // 合作协议附件路径,必传,长度32,通过调用附件上传接口获取
|
||||||
RetUrl string `json:"retUrl"` // 回调通知地址,必传,长度128,审核通过后通知地址
|
RetUrl string `json:"retUrl"` // 回调通知地址,必传,长度128,审核通过后通知地址
|
||||||
Attachments []struct {
|
Attachments []*ApplyBindAttachment `json:"attachments,omitempty"` // 附加资料,可选,集合类型,其他附加资料文件信息
|
||||||
|
}
|
||||||
|
|
||||||
|
type ApplyBindAttachment struct {
|
||||||
AttachType string `json:"attachType"` // 附件类型编码,必传,长度32
|
AttachType string `json:"attachType"` // 附件类型编码,必传,长度32
|
||||||
AttachName string `json:"attachName"` // 附件名称,必传,长度32
|
AttachName string `json:"attachName"` // 附件名称,必传,长度32
|
||||||
AttachStorePath string `json:"attachStorePath"` // 附件路径,必传,长度128,通过调用附件上传接口获取
|
AttachStorePath string `json:"attachStorePath"` // 附件路径,必传,长度128,通过调用附件上传接口获取
|
||||||
} `json:"attachments,omitempty"` // 附加资料,可选,集合类型,其他附加资料文件信息
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// ApplyBindResponse 分账关系绑定响应结构体
|
// ApplyBindResponse 分账关系绑定响应结构体
|
||||||
|
|||||||
@@ -26,11 +26,7 @@ type ApplyLedgerMerReqData struct {
|
|||||||
SettleType string `json:"settleType"` // 结算类型,非必传,长度32,取值说明:01-主扫现结,02-复扫现结,03-交易自动结算
|
SettleType string `json:"settleType"` // 结算类型,非必传,长度32,取值说明:01-主扫现结,02-复扫现结,03-交易自动结算
|
||||||
SplitRuleSource string `json:"splitRuleSource"` // 分账规则来源,条件必传,长度32,取值说明:MER-商户自定规则,PLATFORM-平台分润规则(分润规则必传)
|
SplitRuleSource string `json:"splitRuleSource"` // 分账规则来源,条件必传,长度32,取值说明:MER-商户自定规则,PLATFORM-平台分润规则(分润规则必传)
|
||||||
RetUrl string `json:"retUrl"` // 回调通知地址,必传,长度128,分账申请结果以异步消息或同步返回的方式通知,如需无线路由处理,也可以通过第三方商户信息查询接口确定结算结果
|
RetUrl string `json:"retUrl"` // 回调通知地址,必传,长度128,分账申请结果以异步消息或同步返回的方式通知,如需无线路由处理,也可以通过第三方商户信息查询接口确定结算结果
|
||||||
Attachments []struct {
|
Attachments []*ApplyBindAttachment `json:"attachments,omitempty"` // 附加资料,可选,集合,其他需附加的文件信息
|
||||||
AttachType string `json:"attachType"` // 附件类型编码,必传,长度32
|
|
||||||
AttachName string `json:"attachName"` // 附件名称,必传,长度32
|
|
||||||
AttachStorePath string `json:"attachStorePath"` // 附件路径,必传,长度128,调用附件上传接口获取
|
|
||||||
} `json:"attachments,omitempty"` // 附加资料,可选,集合,其他需附加的文件信息
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// ApplyLedgerMerResponse 商户分账业务开通申请响应结构体
|
// ApplyLedgerMerResponse 商户分账业务开通申请响应结构体
|
||||||
|
|||||||
@@ -55,14 +55,7 @@ type ApplyLedgerReceiverReqData struct {
|
|||||||
// 收款账户清算行行号,必传,长度32,取值说明:参照FBI.N信息查询,仅支持对私结算账户
|
// 收款账户清算行行号,必传,长度32,取值说明:参照FBI.N信息查询,仅支持对私结算账户
|
||||||
AcctClearBankCode string `json:"acctClearBankCode"`
|
AcctClearBankCode string `json:"acctClearBankCode"`
|
||||||
// 接收方附件资料,可选,集合
|
// 接收方附件资料,可选,集合
|
||||||
AttachList []struct {
|
AttachList []*ApplyBindAttachment `json:"attachList"`
|
||||||
// 附件名称,可选,长度32
|
|
||||||
AttachName string `json:"attachName"`
|
|
||||||
// 附件路径,可选,长度32,取值说明:(调用进件附件上传接口获取到附件路径)
|
|
||||||
AttachStorePath string `json:"attachStorePath"`
|
|
||||||
// 附件类型编码,可选,长度32
|
|
||||||
AttachType string `json:"attachType"`
|
|
||||||
} `json:"attachList"`
|
|
||||||
// 提款类型,可选,长度32,取值说明:01:主动提款,03:交易自动结算,不填默认01
|
// 提款类型,可选,长度32,取值说明:01:主动提款,03:交易自动结算,不填默认01
|
||||||
SettleType string `json:"settleType"`
|
SettleType string `json:"settleType"`
|
||||||
}
|
}
|
||||||
|
|||||||
+2
-3
@@ -37,7 +37,7 @@ func NewPreorder(param *PreorderReqData) *Preorder {
|
|||||||
type PreorderResponse struct {
|
type PreorderResponse struct {
|
||||||
Code string `json:"code"` // 响应码,BBS00000表示成功
|
Code string `json:"code"` // 响应码,BBS00000表示成功
|
||||||
Msg string `json:"msg"` // 响应信息,对响应码的文字描述
|
Msg string `json:"msg"` // 响应信息,对响应码的文字描述
|
||||||
ReqData ReqData `json:"resp_data"` // 响应业务数据
|
ReqData *ReqData `json:"resp_data"` // 响应业务数据
|
||||||
RespTime string `json:"resp_time"` // 响应时间
|
RespTime string `json:"resp_time"` // 响应时间
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -49,8 +49,7 @@ type ReqData struct {
|
|||||||
LogNo string `json:"log_no"` // 拉卡拉对账单流水号
|
LogNo string `json:"log_no"` // 拉卡拉对账单流水号
|
||||||
SettleMerchantNo string `json:"settle_merchant_no"` // 结算商户号
|
SettleMerchantNo string `json:"settle_merchant_no"` // 结算商户号
|
||||||
SettleTermNo string `json:"settle_term_no"` // 结算终端号
|
SettleTermNo string `json:"settle_term_no"` // 结算终端号
|
||||||
AccRespFields WxPreorderResponse `json:"acc_resp_fields"` // 支付通道返回的具体信息
|
AccRespFields *WxPreorderResponse `json:"acc_resp_fields"` // 支付通道返回的具体信息
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// WxPreorderResponse 支付通道返回的具体信息
|
// WxPreorderResponse 支付通道返回的具体信息
|
||||||
|
|||||||
@@ -66,7 +66,7 @@ type QueryLedgerMerRespData struct {
|
|||||||
// 分账规则来源,取值说明:MER:商户分账规则,PLATFORM:平台分账规则
|
// 分账规则来源,取值说明:MER:商户分账规则,PLATFORM:平台分账规则
|
||||||
SplitRuleSource string `json:"split_rule_source"`
|
SplitRuleSource string `json:"split_rule_source"`
|
||||||
// 已绑定接收方列表
|
// 已绑定接收方列表
|
||||||
BindRelations []BindRelation `json:"bind_relations"`
|
BindRelations []*BindRelation `json:"bind_relations"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// BindRelation 已绑定接收方信息结构体
|
// BindRelation 已绑定接收方信息结构体
|
||||||
|
|||||||
Reference in New Issue
Block a user