Compare commits
23 Commits
| Author | SHA1 | Date |
|---|---|---|
|
|
1c6d1dff34 | |
|
|
d8d5d36844 | |
|
|
d86d7c7fb6 | |
|
|
deb2985747 | |
|
|
0b902def62 | |
|
|
c9fa888b05 | |
|
|
ace91cc127 | |
|
|
58068f06af | |
|
|
9af7e32aff | |
|
|
4a46686a68 | |
|
|
a7dca57d23 | |
|
|
5d502d371a | |
|
|
6edab2db55 | |
|
|
468950e555 | |
|
|
2f9a46a6d9 | |
|
|
14ef8bf585 | |
|
|
b10df1f064 | |
|
|
aab78082ce | |
|
|
59158d7309 | |
|
|
6f685ea087 | |
|
|
b038c64873 | |
|
|
03aec086bf | |
|
|
8eeee5cbe1 |
|
|
@ -23,7 +23,8 @@ const (
|
||||||
// LKL_ACCOUNT_BALANCE_QUERY_URL 拉卡拉账户余额查询
|
// LKL_ACCOUNT_BALANCE_QUERY_URL 拉卡拉账户余额查询
|
||||||
LKL_ACCOUNT_BALANCE_QUERY_URL = "/v2/laep/industry/ewalletBalanceQuery"
|
LKL_ACCOUNT_BALANCE_QUERY_URL = "/v2/laep/industry/ewalletBalanceQuery"
|
||||||
// LKL_ACCOUNT_WITHDRAW_URL 拉卡拉账户提现
|
// LKL_ACCOUNT_WITHDRAW_URL 拉卡拉账户提现
|
||||||
LKL_ACCOUNT_WITHDRAW_URL = "/v2/laep/industry/ewalletWithdrawD1"
|
LKL_ACCOUNT_WITHDRAW_URL = "/v2/laep/industry/ewalletWithdrawD1"
|
||||||
|
LKL_SPLIT_LEDGER_FALLBACK_URL = "/v3/sacs/fallback"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
|
@ -55,7 +56,9 @@ const (
|
||||||
// LKL_EC_APPLY_MANUAL 拉卡拉商户电子合同人工复核申请
|
// LKL_EC_APPLY_MANUAL 拉卡拉商户电子合同人工复核申请
|
||||||
LKL_EC_APPLY_MANUAL = "/v3/mms/open_api/ec/apply_manual"
|
LKL_EC_APPLY_MANUAL = "/v3/mms/open_api/ec/apply_manual"
|
||||||
// LKL_EC_QMA_STATUS 拉卡拉商户电子合同人工复核结果查询
|
// LKL_EC_QMA_STATUS 拉卡拉商户电子合同人工复核结果查询
|
||||||
LKL_EC_QMA_STATUS = "/v3/mms/open_api/ec/qma_status"
|
LKL_EC_QMA_STATUS = "/v3/mms/open_api/ec/qma_status"
|
||||||
|
LKL_QUERY_SUB_MER_INFO_URL = "/v2/mms/openApi/querySubMerInfo"
|
||||||
|
LKL_MRCH_AUTH_STATE_QUERY_URL = "/v2/mms/sme/mrchAuthStateQuery"
|
||||||
)
|
)
|
||||||
|
|
||||||
// unifiedReturn 统一退货API地址
|
// unifiedReturn 统一退货API地址
|
||||||
|
|
|
||||||
|
|
@ -39,6 +39,25 @@ func (a *AccountService[T]) BalanceQuery(req *model.BalanceQueryReqData) (*T, er
|
||||||
return respBody, nil
|
return respBody, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (a *AccountService[T]) BalanceQueryTest(req *model.BalanceQueryReqData) (*T, error) {
|
||||||
|
// 构建请求参数
|
||||||
|
url := consts.BASE_TEST_URL + consts.LKL_ACCOUNT_BALANCE_QUERY_URL
|
||||||
|
|
||||||
|
// 构建BaseModel请求
|
||||||
|
baseReq := model.BalanceQueryRequest{
|
||||||
|
ReqTime: gtime.Now().Format("YmdHis"),
|
||||||
|
Version: "3.0",
|
||||||
|
ReqData: req,
|
||||||
|
}
|
||||||
|
// 发送请求
|
||||||
|
respBody, err := a.client.DoRequest(url, baseReq)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return respBody, nil
|
||||||
|
}
|
||||||
|
|
||||||
// Withdraw 账户提现
|
// Withdraw 账户提现
|
||||||
func (a *AccountService[T]) Withdraw(req *model.WithdrawReqData) (*T, error) {
|
func (a *AccountService[T]) Withdraw(req *model.WithdrawReqData) (*T, error) {
|
||||||
// 构建请求参数
|
// 构建请求参数
|
||||||
|
|
@ -58,3 +77,22 @@ func (a *AccountService[T]) Withdraw(req *model.WithdrawReqData) (*T, error) {
|
||||||
}
|
}
|
||||||
return respBody, nil
|
return respBody, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (a *AccountService[T]) WithdrawTest(req *model.WithdrawReqData) (*T, error) {
|
||||||
|
// 构建请求参数
|
||||||
|
url := consts.BASE_TEST_URL + consts.LKL_ACCOUNT_WITHDRAW_URL
|
||||||
|
|
||||||
|
// 构建BaseModel请求
|
||||||
|
baseReq := model.WithdrawRequest{
|
||||||
|
ReqTime: gtime.Now().Format("YmdHis"),
|
||||||
|
Version: "3.0",
|
||||||
|
ReqData: req,
|
||||||
|
}
|
||||||
|
|
||||||
|
// 发送请求
|
||||||
|
respBody, err := a.client.DoRequest(url, baseReq)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return respBody, nil
|
||||||
|
}
|
||||||
|
|
|
||||||
|
|
@ -1,29 +1,26 @@
|
||||||
package common
|
package common
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
|
||||||
"reflect"
|
"reflect"
|
||||||
|
|
||||||
|
"github.com/gogf/gf/v2/encoding/gjson"
|
||||||
|
"github.com/gogf/gf/v2/os/gctx"
|
||||||
|
"github.com/gogf/gf/v2/os/glog"
|
||||||
)
|
)
|
||||||
|
|
||||||
// CleanJSON 清理JSON字符串中的空值和0值字段
|
// CleanJSON 清理JSON字符串中的空值和0值字段
|
||||||
func CleanJSON(jsonStr string) ([]byte, error) {
|
func CleanJSON(jsonStr string) ([]byte, error) {
|
||||||
var data interface{}
|
// 解析为JSON
|
||||||
|
json := gjson.NewWithOptions(jsonStr, gjson.Options{StrNumber: true})
|
||||||
// 解析JSON字符串
|
glog.Infof(gctx.New(), "Cleaning JSON: %+v", json)
|
||||||
if err := json.Unmarshal([]byte(jsonStr), &data); err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
// 递归清理数据
|
// 递归清理数据
|
||||||
cleaned := cleanData(data)
|
cleaned := cleanData(json.Interface())
|
||||||
|
jsons, err := gjson.DecodeToJson(cleaned, gjson.Options{StrNumber: true})
|
||||||
// 转换回JSON字符串
|
|
||||||
result, err := json.Marshal(cleaned)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
glog.Errorf(gctx.New(), "Error decoding JSON: %v", err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
return jsons.ToJson()
|
||||||
return result, nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// cleanData 递归清理map或slice中的空值和0值
|
// cleanData 递归清理map或slice中的空值和0值
|
||||||
|
|
|
||||||
|
|
@ -205,3 +205,48 @@ func (t *MerService[T]) ReconsiderSubmitTest(req *model.ReConfSubmitRequestData)
|
||||||
}
|
}
|
||||||
return respBody, nil
|
return respBody, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (t *MerService[T]) QuerySubMerInfo(req *model.QuerySubMerInfoReqData) (*T, error) {
|
||||||
|
// 构建请求参数
|
||||||
|
url := consts.BASE_URL + consts.LKL_QUERY_SUB_MER_INFO_URL
|
||||||
|
md5, err := gmd5.Encrypt(gconv.String(time.Now().Unix()))
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("创建ReqId失败")
|
||||||
|
}
|
||||||
|
// 构建BaseModel请求
|
||||||
|
baseReq := model.QuerySubMerInfoRequest{
|
||||||
|
ReqData: req,
|
||||||
|
ReqId: md5,
|
||||||
|
Timestamp: time.Now().Unix(),
|
||||||
|
Ver: "1.0",
|
||||||
|
}
|
||||||
|
|
||||||
|
// 发送请求
|
||||||
|
respBody, err := t.client.DoRequest(url, baseReq)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return respBody, nil
|
||||||
|
}
|
||||||
|
func (t *MerService[T]) MrchAuthStateQuery(req *model.MrchAuthStateQueryReqData) (*T, error) {
|
||||||
|
// 构建请求参数
|
||||||
|
url := consts.BASE_URL + consts.LKL_MRCH_AUTH_STATE_QUERY_URL
|
||||||
|
md5, err := gmd5.Encrypt(gconv.String(time.Now().Unix()))
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("创建ReqId失败")
|
||||||
|
}
|
||||||
|
// 构建BaseModel请求
|
||||||
|
baseReq := model.MrchAuthStateQueryRequest{
|
||||||
|
ReqData: req,
|
||||||
|
ReqId: md5,
|
||||||
|
Timestamp: time.Now().Unix(),
|
||||||
|
Ver: "1.0",
|
||||||
|
}
|
||||||
|
|
||||||
|
// 发送请求
|
||||||
|
respBody, err := t.client.DoRequest(url, baseReq)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return respBody, nil
|
||||||
|
}
|
||||||
|
|
|
||||||
|
|
@ -7,8 +7,8 @@ package querystatus
|
||||||
// 生产环境:https://s2.lakala.com/api/v3/mms/open_api/ec/q_status
|
// 生产环境:https://s2.lakala.com/api/v3/mms/open_api/ec/q_status
|
||||||
type ECQueryStatusRequestData struct {
|
type ECQueryStatusRequestData struct {
|
||||||
OrderNo string `json:"order_no" dc:"四方机构自定义订单编号 必选,建议:平台编号+14位年月日时(24小时制)分秒+8位的随机数(同一接入机构不重复)"` // 必选,建议:平台编号+14位年月日时(24小时制)分秒+8位的随机数(同一接入机构不重复)
|
OrderNo string `json:"order_no" dc:"四方机构自定义订单编号 必选,建议:平台编号+14位年月日时(24小时制)分秒+8位的随机数(同一接入机构不重复)"` // 必选,建议:平台编号+14位年月日时(24小时制)分秒+8位的随机数(同一接入机构不重复)
|
||||||
OrgID int `json:"org_id" dc:"机构号 必选,签约方所属拉卡拉机构"` // 必选,签约方所属拉卡拉机构
|
OrgCode int `json:"org_code" dc:"机构号 必选,签约方所属拉卡拉机构"` // 必选,签约方所属拉卡拉机构
|
||||||
EcApplyID int64 `json:"ec_apply_id" dc:"电子合同申请受理号 必选,申请接口反馈编号"` // 必选,申请接口反馈编号
|
EcApplyID int64 `json:"ec_apply_id" dc:"电子合同申请受理号 必选,申请接口反馈编号"` // 必选,申请接口反馈编号
|
||||||
}
|
}
|
||||||
|
|
||||||
// ECQueryStatusRequest 电子合同查询状态请求
|
// ECQueryStatusRequest 电子合同查询状态请求
|
||||||
|
|
|
||||||
|
|
@ -104,31 +104,60 @@ func (s *SDK[T]) ApplyLedgerMer(req *model.ApplyLedgerMerReqData) (*T, error) {
|
||||||
return s.SplitLedger.ApplyLedgerMer(req)
|
return s.SplitLedger.ApplyLedgerMer(req)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SDK[T]) ApplyLedgerMerTest(req *model.ApplyLedgerMerReqData) (*T, error) {
|
||||||
|
return s.SplitLedger.ApplyLedgerMerTest(req)
|
||||||
|
}
|
||||||
|
|
||||||
// QueryLedgerMer 商户分账信息查询
|
// QueryLedgerMer 商户分账信息查询
|
||||||
func (s *SDK[T]) QueryLedgerMer(req *model.QueryLedgerMerReqData) (*T, error) {
|
func (s *SDK[T]) QueryLedgerMer(req *model.QueryLedgerMerReqData) (*T, error) {
|
||||||
return s.SplitLedger.QueryLedgerMer(req)
|
return s.SplitLedger.QueryLedgerMer(req)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SDK[T]) QueryLedgerMerTest(req *model.QueryLedgerMerReqData) (*T, error) {
|
||||||
|
return s.SplitLedger.QueryLedgerMerTest(req)
|
||||||
|
}
|
||||||
|
|
||||||
// ApplyLedgerReceiver 分账接收方创建申请
|
// ApplyLedgerReceiver 分账接收方创建申请
|
||||||
func (s *SDK[T]) ApplyLedgerReceiver(req *model.ApplyLedgerReceiverReqData) (*T, error) {
|
func (s *SDK[T]) ApplyLedgerReceiver(req *model.ApplyLedgerReceiverReqData) (*T, error) {
|
||||||
return s.SplitLedger.ApplyLedgerReceiver(req)
|
return s.SplitLedger.ApplyLedgerReceiver(req)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SDK[T]) ApplyLedgerReceiverTest(req *model.ApplyLedgerReceiverReqData) (*T, error) {
|
||||||
|
return s.SplitLedger.ApplyLedgerReceiverTest(req)
|
||||||
|
}
|
||||||
|
|
||||||
// ApplyBind 分账关系绑定申请
|
// ApplyBind 分账关系绑定申请
|
||||||
func (s *SDK[T]) ApplyBind(req *model.ApplyBindReqData) (*T, error) {
|
func (s *SDK[T]) ApplyBind(req *model.ApplyBindReqData) (*T, error) {
|
||||||
return s.SplitLedger.ApplyBind(req)
|
return s.SplitLedger.ApplyBind(req)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SDK[T]) ApplyBindTest(req *model.ApplyBindReqData) (*T, error) {
|
||||||
|
return s.SplitLedger.ApplyBindTest(req)
|
||||||
|
}
|
||||||
|
|
||||||
// QuerySplitBalance 可分账金额查询
|
// QuerySplitBalance 可分账金额查询
|
||||||
func (s *SDK[T]) QuerySplitBalance(req *model.SplitBalanceReqData) (*T, error) {
|
func (s *SDK[T]) QuerySplitBalance(req *model.SplitBalanceReqData) (*T, error) {
|
||||||
return s.SplitLedger.QuerySplitBalance(req)
|
return s.SplitLedger.QuerySplitBalance(req)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SDK[T]) QuerySplitBalanceTest(req *model.SplitBalanceReqData) (*T, error) {
|
||||||
|
return s.SplitLedger.QuerySplitBalanceTest(req)
|
||||||
|
}
|
||||||
|
|
||||||
// OrderSplitLedger 订单分账
|
// OrderSplitLedger 订单分账
|
||||||
func (s *SDK[T]) OrderSplitLedger(req *model.OrderSplitLedgerReqData) (*T, error) {
|
func (s *SDK[T]) OrderSplitLedger(req *model.OrderSplitLedgerReqData) (*T, error) {
|
||||||
return s.SplitLedger.OrderSplitLedger(req)
|
return s.SplitLedger.OrderSplitLedger(req)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SDK[T]) OrderSplitLedgerTest(req *model.OrderSplitLedgerReqData) (*T, error) {
|
||||||
|
return s.SplitLedger.OrderSplitLedgerTest(req)
|
||||||
|
}
|
||||||
|
|
||||||
|
// OrderSplitLedgerFallback 订单分账回退
|
||||||
|
func (s *SDK[T]) OrderSplitLedgerFallback(req *model.OrderSplitLedgerFallbackReqData) (*T, error) {
|
||||||
|
return s.SplitLedger.OrderSplitLedgerFallback(req)
|
||||||
|
}
|
||||||
|
|
||||||
// TradeQuery 交易查询
|
// TradeQuery 交易查询
|
||||||
func (s *SDK[T]) TradeQuery(req *model.TradeQueryReqData) (*T, error) {
|
func (s *SDK[T]) TradeQuery(req *model.TradeQueryReqData) (*T, error) {
|
||||||
return s.Trade.TradeQuery(req)
|
return s.Trade.TradeQuery(req)
|
||||||
|
|
@ -144,15 +173,26 @@ func (s *SDK[T]) BalanceQuery(req *model.BalanceQueryReqData) (*T, error) {
|
||||||
return s.Account.BalanceQuery(req)
|
return s.Account.BalanceQuery(req)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SDK[T]) BalanceQueryTest(req *model.BalanceQueryReqData) (*T, error) {
|
||||||
|
return s.Account.BalanceQueryTest(req)
|
||||||
|
}
|
||||||
|
|
||||||
func (s *SDK[T]) UploadFileQuery(req *model.UploadFileReqData) (*T, error) {
|
func (s *SDK[T]) UploadFileQuery(req *model.UploadFileReqData) (*T, error) {
|
||||||
return s.UploadFile.UploadFileQuery(req)
|
return s.UploadFile.UploadFileQuery(req)
|
||||||
}
|
}
|
||||||
|
func (s *SDK[T]) UploadFileQueryTest(req *model.UploadFileReqData) (*T, error) {
|
||||||
|
return s.UploadFile.UploadFileQueryTest(req)
|
||||||
|
}
|
||||||
|
|
||||||
// Withdraw 账户提现
|
// Withdraw 账户提现
|
||||||
func (s *SDK[T]) Withdraw(req *model.WithdrawReqData) (*T, error) {
|
func (s *SDK[T]) Withdraw(req *model.WithdrawReqData) (*T, error) {
|
||||||
return s.Account.Withdraw(req)
|
return s.Account.Withdraw(req)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SDK[T]) WithdrawTest(req *model.WithdrawReqData) (*T, error) {
|
||||||
|
return s.Account.WithdrawTest(req)
|
||||||
|
}
|
||||||
|
|
||||||
// ECApply 电子合同申请
|
// ECApply 电子合同申请
|
||||||
func (s *SDK[T]) ECApply(req *ecApply.ECApplyRequestData) (*ecApply.ECApplyResponse, error) {
|
func (s *SDK[T]) ECApply(req *ecApply.ECApplyRequestData) (*ecApply.ECApplyResponse, error) {
|
||||||
return s.EC.ECApply(req)
|
return s.EC.ECApply(req)
|
||||||
|
|
@ -202,3 +242,11 @@ func (s *SDK[T]) ECQmaStatus(req *ecQmaStatus.ECQmaStatusRequestData) (*ecQmaSta
|
||||||
func (s *SDK[T]) ECQmaStatusTest(req *ecQmaStatus.ECQmaStatusRequestData) (*ecQmaStatus.ECQmaStatusResponse, error) {
|
func (s *SDK[T]) ECQmaStatusTest(req *ecQmaStatus.ECQmaStatusRequestData) (*ecQmaStatus.ECQmaStatusResponse, error) {
|
||||||
return s.ECPeQmaStatus.ECQmaStatusTest(req)
|
return s.ECPeQmaStatus.ECQmaStatusTest(req)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SDK[T]) QuerySubMerInfo(req *model.QuerySubMerInfoReqData) (*T, error) {
|
||||||
|
return s.Merchant.QuerySubMerInfo(req)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *SDK[T]) MrchAuthStateQuery(req *model.MrchAuthStateQueryReqData) (*T, error) {
|
||||||
|
return s.Merchant.MrchAuthStateQuery(req)
|
||||||
|
}
|
||||||
|
|
|
||||||
|
|
@ -50,6 +50,31 @@ func (s *SplitLedgerService[T]) ApplyLedgerMer(req *model.ApplyLedgerMerReqData)
|
||||||
return respBody, nil
|
return respBody, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SplitLedgerService[T]) ApplyLedgerMerTest(req *model.ApplyLedgerMerReqData) (*T, error) {
|
||||||
|
// 构建请求参数
|
||||||
|
url := consts.BASE_TEST_URL + consts.LKL_SPLIT_LEDGER_URL
|
||||||
|
|
||||||
|
md5, err := gmd5.Encrypt(gconv.String(time.Now().Unix()))
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("创建ReqId失败")
|
||||||
|
}
|
||||||
|
// 构建BaseModel请求
|
||||||
|
baseReq := model.ApplyLedgerMerRequest{
|
||||||
|
ReqTime: gtime.Now().Format("YmdHis"),
|
||||||
|
Version: "2.0",
|
||||||
|
ReqData: req,
|
||||||
|
ReqId: md5,
|
||||||
|
}
|
||||||
|
|
||||||
|
// 发送请求
|
||||||
|
respBody, err := s.client.DoRequest(url, baseReq)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return respBody, nil
|
||||||
|
}
|
||||||
|
|
||||||
// ApplyLedgerReceiver 分账接收方创建申请
|
// ApplyLedgerReceiver 分账接收方创建申请
|
||||||
func (s *SplitLedgerService[T]) ApplyLedgerReceiver(req *model.ApplyLedgerReceiverReqData) (*T, error) {
|
func (s *SplitLedgerService[T]) ApplyLedgerReceiver(req *model.ApplyLedgerReceiverReqData) (*T, error) {
|
||||||
// 构建请求参数
|
// 构建请求参数
|
||||||
|
|
@ -76,6 +101,31 @@ func (s *SplitLedgerService[T]) ApplyLedgerReceiver(req *model.ApplyLedgerReceiv
|
||||||
return respBody, nil
|
return respBody, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SplitLedgerService[T]) ApplyLedgerReceiverTest(req *model.ApplyLedgerReceiverReqData) (*T, error) {
|
||||||
|
// 构建请求参数
|
||||||
|
url := consts.BASE_TEST_URL + consts.LKL_SPLIT_LEDGER_RECEIVE_URL
|
||||||
|
|
||||||
|
md5, err := gmd5.Encrypt(gconv.String(time.Now().Unix()))
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("创建ReqId失败")
|
||||||
|
}
|
||||||
|
// 构建BaseModel请求
|
||||||
|
baseReq := model.ApplyLedgerReceiverRequest{
|
||||||
|
ReqTime: gtime.Now().Format("YmdHis"),
|
||||||
|
Version: "2.0",
|
||||||
|
ReqId: md5,
|
||||||
|
ReqData: req,
|
||||||
|
}
|
||||||
|
|
||||||
|
// 发送请求
|
||||||
|
respBody, err := s.client.DoRequest(url, baseReq)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return respBody, nil
|
||||||
|
}
|
||||||
|
|
||||||
// QueryLedgerMer 商户分账信息查询
|
// QueryLedgerMer 商户分账信息查询
|
||||||
func (s *SplitLedgerService[T]) QueryLedgerMer(req *model.QueryLedgerMerReqData) (*T, error) {
|
func (s *SplitLedgerService[T]) QueryLedgerMer(req *model.QueryLedgerMerReqData) (*T, error) {
|
||||||
// 构建请求参数
|
// 构建请求参数
|
||||||
|
|
@ -96,3 +146,23 @@ func (s *SplitLedgerService[T]) QueryLedgerMer(req *model.QueryLedgerMerReqData)
|
||||||
|
|
||||||
return respBody, nil
|
return respBody, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SplitLedgerService[T]) QueryLedgerMerTest(req *model.QueryLedgerMerReqData) (*T, error) {
|
||||||
|
// 构建请求参数
|
||||||
|
url := consts.BASE_TEST_URL + consts.LKL_SPLIT_LEDGER_QUERY_URL
|
||||||
|
|
||||||
|
// 构建BaseModel请求
|
||||||
|
baseReq := model.QueryLedgerMerRequest{
|
||||||
|
ReqTime: time.Now().Format("20060102150405"),
|
||||||
|
Version: "3.0",
|
||||||
|
ReqData: req,
|
||||||
|
}
|
||||||
|
|
||||||
|
// 发送请求
|
||||||
|
respBody, err := s.client.DoRequest(url, baseReq)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return respBody, nil
|
||||||
|
}
|
||||||
|
|
|
||||||
|
|
@ -36,6 +36,30 @@ func (s *SplitLedgerService[T]) ApplyBind(req *model.ApplyBindReqData) (*T, erro
|
||||||
return respBody, nil
|
return respBody, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SplitLedgerService[T]) ApplyBindTest(req *model.ApplyBindReqData) (*T, error) {
|
||||||
|
// 构建请求参数
|
||||||
|
url := consts.BASE_TEST_URL + consts.LKL_SPLIT_LEDGER_RECEIVE_BIND_URL
|
||||||
|
|
||||||
|
md5, err := gmd5.Encrypt(gconv.String(time.Now().Unix()))
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("创建ReqId失败")
|
||||||
|
}
|
||||||
|
// 构建BaseModel请求
|
||||||
|
baseReq := model.ApplyBindRequest{
|
||||||
|
ReqTime: time.Now().Format("20060102150405"),
|
||||||
|
Version: "2.0",
|
||||||
|
ReqData: req,
|
||||||
|
ReqId: md5,
|
||||||
|
}
|
||||||
|
|
||||||
|
// 发送请求
|
||||||
|
respBody, err := s.client.DoRequest(url, baseReq)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return respBody, nil
|
||||||
|
}
|
||||||
|
|
||||||
// QuerySplitBalance 可分账金额查询
|
// QuerySplitBalance 可分账金额查询
|
||||||
func (s *SplitLedgerService[T]) QuerySplitBalance(req *model.SplitBalanceReqData) (*T, error) {
|
func (s *SplitLedgerService[T]) QuerySplitBalance(req *model.SplitBalanceReqData) (*T, error) {
|
||||||
// 构建请求参数
|
// 构建请求参数
|
||||||
|
|
@ -56,6 +80,25 @@ func (s *SplitLedgerService[T]) QuerySplitBalance(req *model.SplitBalanceReqData
|
||||||
return respBody, nil
|
return respBody, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SplitLedgerService[T]) QuerySplitBalanceTest(req *model.SplitBalanceReqData) (*T, error) {
|
||||||
|
// 构建请求参数
|
||||||
|
url := consts.BASE_TEST_URL + consts.LKL_SPLIT_LEDGER_BALANCE_URL
|
||||||
|
|
||||||
|
// 构建BaseModel请求
|
||||||
|
baseReq := model.SplitBalanceRequest{
|
||||||
|
ReqTime: gtime.Now().Format("YmdHis"),
|
||||||
|
Version: "3.0",
|
||||||
|
ReqData: req,
|
||||||
|
}
|
||||||
|
|
||||||
|
// 发送请求
|
||||||
|
respBody, err := s.client.DoRequest(url, baseReq)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return respBody, nil
|
||||||
|
}
|
||||||
|
|
||||||
// OrderSplitLedger 订单分账
|
// OrderSplitLedger 订单分账
|
||||||
func (s *SplitLedgerService[T]) OrderSplitLedger(req *model.OrderSplitLedgerReqData) (*T, error) {
|
func (s *SplitLedgerService[T]) OrderSplitLedger(req *model.OrderSplitLedgerReqData) (*T, error) {
|
||||||
// 构建请求参数
|
// 构建请求参数
|
||||||
|
|
@ -75,3 +118,41 @@ func (s *SplitLedgerService[T]) OrderSplitLedger(req *model.OrderSplitLedgerReqD
|
||||||
}
|
}
|
||||||
return respBody, nil
|
return respBody, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *SplitLedgerService[T]) OrderSplitLedgerTest(req *model.OrderSplitLedgerReqData) (*T, error) {
|
||||||
|
// 构建请求参数
|
||||||
|
url := consts.BASE_TEST_URL + consts.LKL_ORDER_SPLIT_LEDGER_URL
|
||||||
|
|
||||||
|
// 构建BaseModel请求
|
||||||
|
baseReq := model.OrderSplitLedgerRequest{
|
||||||
|
ReqTime: time.Now().Format("20060102150405"),
|
||||||
|
Version: "3.0",
|
||||||
|
ReqData: req,
|
||||||
|
}
|
||||||
|
|
||||||
|
// 发送请求
|
||||||
|
respBody, err := s.client.DoRequest(url, baseReq)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return respBody, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *SplitLedgerService[T]) OrderSplitLedgerFallback(req *model.OrderSplitLedgerFallbackReqData) (*T, error) {
|
||||||
|
// 构建请求参数
|
||||||
|
url := consts.BASE_URL + consts.LKL_SPLIT_LEDGER_FALLBACK_URL
|
||||||
|
|
||||||
|
// 构建BaseModel请求
|
||||||
|
baseReq := model.OrderSplitLedgerFallbackRequest{
|
||||||
|
ReqTime: time.Now().Format("20060102150405"),
|
||||||
|
Version: "3.0",
|
||||||
|
ReqData: req,
|
||||||
|
}
|
||||||
|
|
||||||
|
// 发送请求
|
||||||
|
respBody, err := s.client.DoRequest(url, baseReq)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return respBody, nil
|
||||||
|
}
|
||||||
|
|
|
||||||
|
|
@ -46,3 +46,26 @@ func (t *UploadFileService[T]) UploadFileQuery(req *model.UploadFileReqData) (*T
|
||||||
}
|
}
|
||||||
return respBody, nil
|
return respBody, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (t *UploadFileService[T]) UploadFileQueryTest(req *model.UploadFileReqData) (*T, error) {
|
||||||
|
// 构建请求参数
|
||||||
|
url := consts.BASE_TEST_URL + consts.LKL_UPLOAD_FILE_URL
|
||||||
|
md5, err := gmd5.Encrypt(gconv.String(time.Now().Unix()))
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("创建ReqId失败")
|
||||||
|
}
|
||||||
|
// 构建BaseModel请求
|
||||||
|
baseReq := model.UploadFileRequest{
|
||||||
|
Timestamp: gconv.String(time.Now().Unix()),
|
||||||
|
Ver: "1.0",
|
||||||
|
ReqId: md5,
|
||||||
|
ReqData: req,
|
||||||
|
}
|
||||||
|
|
||||||
|
// 发送请求
|
||||||
|
respBody, err := t.client.DoRequest(url, baseReq)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return respBody, nil
|
||||||
|
}
|
||||||
|
|
|
||||||
|
|
@ -23,7 +23,7 @@ type ApplyLedgerMerReqData struct {
|
||||||
SplitEntrustFilePath string `json:"splitEntrustFilePath"` // 分账授权委托书文件路径,必传,长度64,调用附件上传接口获取
|
SplitEntrustFilePath string `json:"splitEntrustFilePath"` // 分账授权委托书文件路径,必传,长度64,调用附件上传接口获取
|
||||||
SplitRange consts.SplitRange `json:"splitRange"` // 分账范围,必传,长度32,取值说明:ALL-全部交易分账(所有交易默认都分账),MARK-标记交易分账(只有带标记交易才分账,其余交易正常结算)
|
SplitRange consts.SplitRange `json:"splitRange"` // 分账范围,必传,长度32,取值说明:ALL-全部交易分账(所有交易默认都分账),MARK-标记交易分账(只有带标记交易才分账,其余交易正常结算)
|
||||||
SepFundSource consts.SepFundSource `json:"sepFundSource"` // 分账依据,非必传,长度32,取值说明:TRA-交易分账,BAR-金额分账
|
SepFundSource consts.SepFundSource `json:"sepFundSource"` // 分账依据,非必传,长度32,取值说明:TRA-交易分账,BAR-金额分账
|
||||||
ElecContractId string `json:"elecContractId"` // 电子合同编号,非必传,长度32,收单已签约交易电子合同编号,供审核人员复核使用
|
EleContractNo string `json:"eleContractNo"` // 电子合同编号,非必传,长度32,收单已签约交易电子合同编号,供审核人员复核使用
|
||||||
SplitLaunchMode consts.SplitLaunchMode `json:"splitLaunchMode"` // 分账发起方式,非必传,长度32,取值说明:AUTO-自动触发分账,POINTTRUE-指定规则分账,MANUAL-手动分账
|
SplitLaunchMode consts.SplitLaunchMode `json:"splitLaunchMode"` // 分账发起方式,非必传,长度32,取值说明:AUTO-自动触发分账,POINTTRUE-指定规则分账,MANUAL-手动分账
|
||||||
SettleType consts.SplitSettleType `json:"settleType"` // 结算类型,非必传,长度32,取值说明:01-主扫现结,02-复扫现结,03-交易自动结算
|
SettleType consts.SplitSettleType `json:"settleType"` // 结算类型,非必传,长度32,取值说明:01-主扫现结,02-复扫现结,03-交易自动结算
|
||||||
SplitRuleSource consts.SplitRuleSource `json:"splitRuleSource"` // 分账规则来源,条件必传,长度32,取值说明:MER-商户自定规则,PLATFORM-平台分润规则(分润规则必传)
|
SplitRuleSource consts.SplitRuleSource `json:"splitRuleSource"` // 分账规则来源,条件必传,长度32,取值说明:MER-商户自定规则,PLATFORM-平台分润规则(分润规则必传)
|
||||||
|
|
|
||||||
|
|
@ -35,30 +35,30 @@ type BalanceQueryReqData struct {
|
||||||
// 包含响应状态码、消息和业务数据
|
// 包含响应状态码、消息和业务数据
|
||||||
type BalanceQueryResponse struct {
|
type BalanceQueryResponse struct {
|
||||||
// 响应状态码,000000
|
// 响应状态码,000000
|
||||||
Code string `json:"code"`
|
Code string `json:"retCode"`
|
||||||
// 响应消息
|
// 响应消息
|
||||||
Msg string `json:"msg"`
|
Msg string `json:"retMsg"`
|
||||||
// 响应业务数据,当code为SACS0000时返回
|
// 响应业务数据,当code为SACS0000时返回
|
||||||
RespData *BalanceQueryRespData `json:"resp_data"`
|
RespData *BalanceQueryRespData `json:"respData"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// BalanceQueryRespData 余额查询响应业务数据结构体
|
// BalanceQueryRespData 余额查询响应业务数据结构体
|
||||||
// 包含余额查询返回的具体账户信息
|
// 包含余额查询返回的具体账户信息
|
||||||
type BalanceQueryRespData struct {
|
type BalanceQueryRespData struct {
|
||||||
// 账号,必传
|
// 账号,必传
|
||||||
PayNo string `json:"pay_no"`
|
PayNo string `json:"payNo"`
|
||||||
// 账户类型,必传
|
// 账户类型,必传
|
||||||
PayType string `json:"pay_type"`
|
PayType string `json:"payType"`
|
||||||
// 账户状态,必传,取值说明:CLOSE销户,NORMAL正常,FREEZE冻结,STOPAY止付
|
// 账户状态,必传,取值说明:CLOSE销户,NORMAL正常,FREEZE冻结,STOPAY止付
|
||||||
AcctSt string `json:"acct_st"`
|
AcctSt string `json:"acctSt"`
|
||||||
// 预付余额(单位元),必传
|
// 预付余额(单位元),必传
|
||||||
ForceBalance string `json:"force_balance"`
|
ForceBalance string `json:"forceBalance"`
|
||||||
// 上日余额(单位元)-该字段已废弃使用,必传
|
// 上日余额(单位元)-该字段已废弃使用,必传
|
||||||
HisBalance string `json:"his_balance"`
|
HisBalance string `json:"hisBalance"`
|
||||||
// 实时余额(单位元),必传
|
// 实时余额(单位元),必传
|
||||||
ReBalance string `json:"re_balance"`
|
ReBalance string `json:"reBalance"`
|
||||||
// 当前可用余额(单位元),必传
|
// 当前可用余额(单位元),必传
|
||||||
CuBalance string `json:"cu_balance"`
|
CuBalance string `json:"cuBalance"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// SuccessOrFail 判断余额查询请求是否成功
|
// SuccessOrFail 判断余额查询请求是否成功
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,29 @@
|
||||||
|
package model
|
||||||
|
|
||||||
|
type MrchAuthStateQueryRequest struct {
|
||||||
|
ReqData *MrchAuthStateQueryReqData `json:"reqData"`
|
||||||
|
Ver string `json:"ver"`
|
||||||
|
Timestamp int64 `json:"timestamp"`
|
||||||
|
ReqId string `json:"reqId"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type MrchAuthStateQueryReqData struct {
|
||||||
|
TradeMode string `json:"tradeMode" dc:"交易模式"`
|
||||||
|
SubMerchantId string `json:"subMerchantId" dc:"子商户号"`
|
||||||
|
MerchantNo string `json:"merchantNo" dc:"商户号"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type MrchAuthStateQueryResponse struct {
|
||||||
|
RetCode string `json:"retCode"`
|
||||||
|
RetMsg string `json:"retMsg"`
|
||||||
|
RespData *MrchAuthStateQueryRespData `json:"respData"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type MrchAuthStateQueryRespData struct {
|
||||||
|
SubMerchantId string `json:"subMerchantId"`
|
||||||
|
CheckResult string `json:"checkResult"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func (t *MrchAuthStateQueryResponse) SuccessOrFail() bool {
|
||||||
|
return t.RetCode == "000000"
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,40 @@
|
||||||
|
package model
|
||||||
|
|
||||||
|
type OrderSplitLedgerFallbackRequest struct {
|
||||||
|
ReqData *OrderSplitLedgerFallbackReqData `json:"req_data"` // 请求业务数据
|
||||||
|
Version string `json:"version"` // 接口版本号
|
||||||
|
ReqTime string `json:"req_time"` // 请求时间,格式为yyyyMMddHHmmss
|
||||||
|
}
|
||||||
|
|
||||||
|
type OrderSplitLedgerFallbackReqData struct {
|
||||||
|
MerchantNo string `json:"merchant_no"` // 商户号,必传,长度32
|
||||||
|
OriginSeparateNo string `json:"origin_separate_no"` // 原分账单号,必传,长度32
|
||||||
|
OutSeparateNo string `json:"out_separate_no"` // 外部分账单号,必传,长度32
|
||||||
|
OriginOutSeparateNo string `json:"origin_out_separate_no"` // 原外部分账单号,必传,长度32
|
||||||
|
FallbackReason string `json:"fallback_reason"` // 回退原因,必传,长度255
|
||||||
|
TotalAmt string `json:"total_amt"` // 总金额,必传,长度15
|
||||||
|
OriginRecvDatas []*OrderSplitLedgerOriginRecvDatas `json:"origin_recv_datas"` // 原分账接收数据,必传,数组长度1-100
|
||||||
|
}
|
||||||
|
|
||||||
|
type OrderSplitLedgerOriginRecvDatas struct {
|
||||||
|
RecvNo string `json:"recv_no"` // 原分账接收号,必传,长度32
|
||||||
|
Amt string `json:"amt"` // 原分账接收金额,必传,长度15
|
||||||
|
}
|
||||||
|
|
||||||
|
type OrderSplitLedgerFallbackResponse struct {
|
||||||
|
Msg string `json:"msg"` // 消息
|
||||||
|
RespTime string `json:"resp_time"` // 响应时间
|
||||||
|
Code string `json:"code"` // 响应码 SACS0000表示成功
|
||||||
|
RespData struct {
|
||||||
|
OutSeparateNo string `json:"out_separate_no"` // 外部分账单号,必传,长度32
|
||||||
|
TotalAmt string `json:"total_amt"` // 总金额,必传,长度15
|
||||||
|
OriginOutSeparateNo string `json:"origin_out_separate_no"` // 原外部分账单号,必传,长度32
|
||||||
|
OriginSeparateNo string `json:"origin_separate_no"` // 原分账单号,必传,长度32
|
||||||
|
Status string `json:"status"` // 状态,必传,长度1
|
||||||
|
SeparateNo string `json:"separate_no"` // 分账单号,必传,长度32
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *OrderSplitLedgerFallbackResponse) SuccessOrFail() bool {
|
||||||
|
return s.Code == "SACS0000"
|
||||||
|
}
|
||||||
|
|
@ -26,7 +26,8 @@ type PreorderReqData struct {
|
||||||
RequestIp string `json:"request_ip"` // 请求方IP地址,存在必填,格式如36.45.36.95,String(64)
|
RequestIp string `json:"request_ip"` // 请求方IP地址,存在必填,格式如36.45.36.95,String(64)
|
||||||
Location string `json:"location"` // 纬度,经度,商户终端的地理位置,银联二维码交易必填,整体格式:纬度,经度,+表示北纬、东经,-表示南纬、西经。经度格式:1位正负号+3位整数+1位小数点+5位小数;纬度格式:1位正负号+2位整数+1位小数点+6位小数;举例:+31.221345,+121.12345,String(32)
|
Location string `json:"location"` // 纬度,经度,商户终端的地理位置,银联二维码交易必填,整体格式:纬度,经度,+表示北纬、东经,-表示南纬、西经。经度格式:1位正负号+3位整数+1位小数点+5位小数;纬度格式:1位正负号+2位整数+1位小数点+6位小数;举例:+31.221345,+121.12345,String(32)
|
||||||
} `json:"location_info"` // 地址位置信息,Object
|
} `json:"location_info"` // 地址位置信息,Object
|
||||||
Subject string `json:"subject"` // 订单标题,用于简单描述订单或商品主题,传输给账户端(账户端控制,实际最多42个字节),微信支付必送,String(42)
|
Subject string `json:"subject"` // 订单标题,用于简单描述订单或商品主题,传输给账户端(账户端控制,实际最多42个字节),微信支付必送,String(42)
|
||||||
|
AccBusiFields *AccBusiFields `json:"acc_busi_fields"` // 账户业务字段,Object
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewPreorder(param *PreorderReqData) *Preorder {
|
func NewPreorder(param *PreorderReqData) *Preorder {
|
||||||
|
|
|
||||||
|
|
@ -5,11 +5,11 @@ package model
|
||||||
// 包含请求头信息和业务数据
|
// 包含请求头信息和业务数据
|
||||||
type QueryLedgerMerRequest struct {
|
type QueryLedgerMerRequest struct {
|
||||||
// 请求业务数据
|
// 请求业务数据
|
||||||
ReqData *QueryLedgerMerReqData `json:"req_data"`
|
ReqData *QueryLedgerMerReqData `json:"reqData"`
|
||||||
// 接口版本号
|
// 接口版本号
|
||||||
Version string `json:"version"`
|
Version string `json:"version"`
|
||||||
// 请求时间,格式为yyyyMMddHHmmss
|
// 请求时间,格式为yyyyMMddHHmmss
|
||||||
ReqTime string `json:"req_time"`
|
ReqTime string `json:"reqTime"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// QueryLedgerMerReqData 分账商户查询请求业务数据结构体
|
// QueryLedgerMerReqData 分账商户查询请求业务数据结构体
|
||||||
|
|
@ -19,13 +19,13 @@ type QueryLedgerMerReqData struct {
|
||||||
// 接口版本号,必传,长度8,取值说明:1.0
|
// 接口版本号,必传,长度8,取值说明:1.0
|
||||||
Version string `json:"version"`
|
Version string `json:"version"`
|
||||||
// 订单编号(便于后续跟踪排查问题及核对报文),必传,长度32,取值说明:14位年月日(24小时制)分秒+8位的随机数(不重复)
|
// 订单编号(便于后续跟踪排查问题及核对报文),必传,长度32,取值说明:14位年月日(24小时制)分秒+8位的随机数(不重复)
|
||||||
OrderNo string `json:"order_no"`
|
OrderNo string `json:"orderNo"`
|
||||||
// 机构代码,必传,长度32
|
// 机构代码,必传,长度32
|
||||||
OrgCode string `json:"org_code"`
|
OrgCode string `json:"orgCode"`
|
||||||
// 拉卡拉内部商户号,可选,长度32,取值说明:拉卡拉内部商户号和银联商户号必须传一个,都送以内部商户号为准
|
// 拉卡拉内部商户号,可选,长度32,取值说明:拉卡拉内部商户号和银联商户号必须传一个,都送以内部商户号为准
|
||||||
MerInnerNo string `json:"mer_inner_no"`
|
MerInnerNo string `json:"merInnerNo"`
|
||||||
// 银联商户号,可选,长度32,取值说明:拉卡拉内部商户号和银联商户号必须传一个,都送以内部商户号为准
|
// 银联商户号,可选,长度32,取值说明:拉卡拉内部商户号和银联商户号必须传一个,都送以内部商户号为准
|
||||||
MerCupNo string `json:"mer_cup_no"`
|
MerCupNo string `json:"merCupNo"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// QueryLedgerMerResponse 分账商户查询响应结构体
|
// QueryLedgerMerResponse 分账商户查询响应结构体
|
||||||
|
|
@ -33,58 +33,58 @@ type QueryLedgerMerReqData struct {
|
||||||
// 包含响应状态码、消息和业务数据
|
// 包含响应状态码、消息和业务数据
|
||||||
type QueryLedgerMerResponse struct {
|
type QueryLedgerMerResponse struct {
|
||||||
// 响应状态码,000000表示成功
|
// 响应状态码,000000表示成功
|
||||||
Code string `json:"code"`
|
RetCode string `json:"retCode"`
|
||||||
// 响应消息
|
// 响应消息
|
||||||
Msg string `json:"msg"`
|
RetMsg string `json:"retMsg"`
|
||||||
// 响应业务数据,当code为000000时返回
|
// 响应业务数据,当code为000000时返回
|
||||||
RespData *QueryLedgerMerRespData `json:"resp_data"`
|
RespData *QueryLedgerMerRespData `json:"respData"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// QueryLedgerMerRespData 分账商户查询响应业务数据结构体
|
// QueryLedgerMerRespData 分账商户查询响应业务数据结构体
|
||||||
// 包含分账商户查询返回的具体业务信息
|
// 包含分账商户查询返回的具体业务信息
|
||||||
type QueryLedgerMerRespData struct {
|
type QueryLedgerMerRespData struct {
|
||||||
// 分账商户机构号
|
// 分账商户机构号
|
||||||
OrgId string `json:"org_id"`
|
OrgId string `json:"orgId"`
|
||||||
// 分账商户机构名称
|
// 分账商户机构名称
|
||||||
OrgName string `json:"org_name"`
|
OrgName string `json:"orgName"`
|
||||||
// 拉卡拉内部商户号
|
// 拉卡拉内部商户号
|
||||||
MerInnerNo string `json:"mer_inner_no"`
|
MerInnerNo string `json:"merInnerNo"`
|
||||||
// 银联商户号
|
// 银联商户号
|
||||||
MerCupNo string `json:"mer_cup_no"`
|
MerCupNo string `json:"merCupNo"`
|
||||||
// 最低分账比例(百分比,支持2位精度),取值说明:70或70.50
|
// 最低分账比例(百分比,支持2位精度),取值说明:70或70.50
|
||||||
SplitLowestRatio string `json:"split_lowest_ratio"`
|
SplitLowestRatio float64 `json:"splitLowestRatio"`
|
||||||
// 商户分账状态,取值说明:VALID启用,INVALID禁用
|
// 商户分账状态,取值说明:VALID启用,INVALID禁用
|
||||||
SplitStatus string `json:"split_status"`
|
SplitStatus string `json:"splitStatus"`
|
||||||
// 分账范围,取值说明:ALL:全部交易分账(商户所有交易默认待分账),MARK:标记交易分账(只有带分账标识交易待分账,其余交易正常结算),默认:MARK
|
// 分账范围,取值说明:ALL:全部交易分账(商户所有交易默认待分账),MARK:标记交易分账(只有带分账标识交易待分账,其余交易正常结算),默认:MARK
|
||||||
SplitRange string `json:"split_range"`
|
SplitRange string `json:"splitRange"`
|
||||||
// 分账依据,取值说明:TR或空:交易分账,BA:余额分账,默认:TR交易分账
|
// 分账依据,取值说明:TR或空:交易分账,BA:余额分账,默认:TR交易分账
|
||||||
SepFundSource string `json:"sep_fund_source"`
|
SepFundSource string `json:"sepFundSource"`
|
||||||
// 平台ID,取值说明:如果商户和绑定平台分账,返回平台ID
|
// 平台ID,取值说明:如果商户和绑定平台分账,返回平台ID
|
||||||
PlatformId string `json:"platform_id"`
|
PlatformId string `json:"platformId"`
|
||||||
// 分账发起方式,取值说明:AUTO:自动规则分账,POINTRULE:指定规则分账,MANUAL:手动规则分账
|
// 分账发起方式,取值说明:AUTO:自动规则分账,POINTRULE:指定规则分账,MANUAL:手动规则分账
|
||||||
SplitLaunchMode string `json:"split_launch_mode"`
|
SplitLaunchMode string `json:"splitLaunchMode"`
|
||||||
// 分账规则来源,取值说明:MER:商户分账规则,PLATFORM:平台分账规则
|
// 分账规则来源,取值说明:MER:商户分账规则,PLATFORM:平台分账规则
|
||||||
SplitRuleSource string `json:"split_rule_source"`
|
SplitRuleSource string `json:"splitRuleSource"`
|
||||||
// 已绑定接收方列表
|
// 已绑定接收方列表
|
||||||
BindRelations []*BindRelation `json:"bind_relations"`
|
BindRelations []*BindRelation `json:"bindRelations"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// BindRelation 已绑定接收方信息结构体
|
// BindRelation 已绑定接收方信息结构体
|
||||||
// 用于表示分账商户已绑定的接收方信息
|
// 用于表示分账商户已绑定的接收方信息
|
||||||
type BindRelation struct {
|
type BindRelation struct {
|
||||||
// 拉卡拉内部商户号
|
// 拉卡拉内部商户号
|
||||||
MerInnerNo string `json:"mer_inner_no"`
|
MerInnerNo string `json:"merInnerNo"`
|
||||||
// 银联商户号
|
// 银联商户号
|
||||||
MerCupNo string `json:"mer_cup_no"`
|
MerCupNo string `json:"merCupNo"`
|
||||||
// 接收方编号
|
// 接收方编号
|
||||||
ReceiverNo string `json:"receiver_no"`
|
ReceiverNo string `json:"receiverNo"`
|
||||||
// 接收方编号名称
|
// 接收方编号名称
|
||||||
ReceiverName string `json:"receiver_name"`
|
ReceiverName string `json:"receiverName"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// SuccessOrFail 判断分账商户查询请求是否成功
|
// SuccessOrFail 判断分账商户查询请求是否成功
|
||||||
// 成功条件:响应码为000000
|
// 成功条件:响应码为000000
|
||||||
// 返回值:true表示成功,false表示失败
|
// 返回值:true表示成功,false表示失败
|
||||||
func (resp *QueryLedgerMerResponse) SuccessOrFail() bool {
|
func (resp *QueryLedgerMerResponse) SuccessOrFail() bool {
|
||||||
return resp.Code == "000000"
|
return resp.RetCode == "000000"
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,50 @@
|
||||||
|
package model
|
||||||
|
|
||||||
|
type QuerySubMerInfoRequest struct {
|
||||||
|
ReqData *QuerySubMerInfoReqData `json:"reqData"`
|
||||||
|
Ver string `json:"ver"`
|
||||||
|
Timestamp int64 `json:"timestamp"`
|
||||||
|
ReqId string `json:"reqId"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type QuerySubMerInfoReqData struct {
|
||||||
|
Version string `json:"version" dc:"接口版本号"`
|
||||||
|
OrderNo string `json:"orderNo" dc:"订单编号,保证唯一"`
|
||||||
|
OrgCode string `json:"orgCode" dc:"机构代码"`
|
||||||
|
MerInnerNo string `json:"merInnerNo" dc:"拉卡拉内部商户号和银联商户号必须传一个,都送以内部商户号为准。"`
|
||||||
|
MerCupNo string `json:"merCupNo" dc:"拉卡拉内部商户号和银联商户号必须传一个,都送以内部商户号为准。"`
|
||||||
|
RegisterChannel string `json:"registerChannel" dc:"报备渠道"`
|
||||||
|
RegisterType string `json:"registerType" dc:"报备类型"`
|
||||||
|
RegisterStatus string `json:"registerStatus" dc:"报备状态 SUCCESS:成功;FAIL:失败"`
|
||||||
|
SubMchId string `json:"subMchId" dc:"子商户号"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type QuerySubMerInfoResponse struct {
|
||||||
|
RetCode string `json:"retCode"`
|
||||||
|
RetMsg string `json:"retMsg"`
|
||||||
|
RespData *QuerySubMerInfoRespData `json:"respData"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type QuerySubMerInfoRespData struct {
|
||||||
|
OrgCode string `json:"orgCode"`
|
||||||
|
OrderNo string `json:"orderNo"`
|
||||||
|
List []*RegisterList `json:"list"`
|
||||||
|
}
|
||||||
|
type RegisterList struct {
|
||||||
|
MerInnerNo string `json:"merInnerNo" dc:"内部商户号"`
|
||||||
|
SubMchId string `json:"subMchId" dc:"子商户号"`
|
||||||
|
SubMchIdBank string `json:"subMchIdBank" dc:"交易子商户号"`
|
||||||
|
DcWalletId string `json:"dcWalletId" dc:"数币钱包ID"`
|
||||||
|
ChannelId string `json:"channelId" dc:"渠道号"`
|
||||||
|
ReceOrgNo string `json:"receOrgNo" dc:"从业机构号"`
|
||||||
|
RegisterChannel string `json:"registerChannel" dc:"报备渠道"`
|
||||||
|
RegisterType string `json:"registerType" dc:"报备类型"`
|
||||||
|
RegisterTm string `json:"registerTm" dc:"报备时间"`
|
||||||
|
RegisterStatus string `json:"registerStatus" dc:"报备状态"`
|
||||||
|
ResultCode string `json:"resultCode" dc:"结果返回码"`
|
||||||
|
ResultMessage string `json:"resultMessage" dc:"结果描述"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func (t *QuerySubMerInfoResponse) SuccessOrFail() bool {
|
||||||
|
return t.RetCode == "000000"
|
||||||
|
}
|
||||||
|
|
@ -2,41 +2,41 @@ package model
|
||||||
|
|
||||||
// TradeQuery 交易查询请求结构体
|
// TradeQuery 交易查询请求结构体
|
||||||
type TradeQuery struct {
|
type TradeQuery struct {
|
||||||
ReqTime string `json:"req_time"` // 请求时间
|
ReqTime string `json:"req_time"` // 请求时间
|
||||||
Version string `json:"version"` // API版本号
|
Version string `json:"version"` // API版本号
|
||||||
OutOrgCode string `json:"out_org_code"` // 外部机构码
|
OutOrgCode string `json:"out_org_code"` // 外部机构码
|
||||||
ReqData *TradeQueryReqData `json:"req_data"` // 请求数据
|
ReqData *TradeQueryReqData `json:"req_data"` // 请求数据
|
||||||
}
|
}
|
||||||
|
|
||||||
// TradeQueryReqData 交易查询请求数据结构体
|
// TradeQueryReqData 交易查询请求数据结构体
|
||||||
type TradeQueryReqData struct {
|
type TradeQueryReqData struct {
|
||||||
MerchantNo string `json:"merchant_no"` // 商户号,必传
|
MerchantNo string `json:"merchant_no"` // 商户号,必传
|
||||||
TermNo string `json:"term_no"` // 终端号,必传
|
TermNo string `json:"term_no"` // 终端号,必传
|
||||||
OutTradeNo string `json:"out_trade_no"` // 商户交易流水号,条件必传,与trade_no必传其一
|
OutTradeNo string `json:"out_trade_no"` // 商户交易流水号,条件必传,与trade_no必传其一
|
||||||
}
|
}
|
||||||
|
|
||||||
// TradeQueryResponse 交易查询响应结构体
|
// TradeQueryResponse 交易查询响应结构体
|
||||||
type TradeQueryResponse struct {
|
type TradeQueryResponse struct {
|
||||||
Msg string `json:"msg"` // 响应消息
|
Msg string `json:"msg"` // 响应消息
|
||||||
RespTime string `json:"resp_time"` // 响应时间
|
RespTime string `json:"resp_time"` // 响应时间
|
||||||
Code string `json:"code"` // 响应码,000000表示成功
|
Code string `json:"code"` // 响应码,000000表示成功
|
||||||
RespData struct {
|
RespData struct {
|
||||||
MerchantNo string `json:"merchant_no"` // 商户号,必传
|
MerchantNo string `json:"merchant_no"` // 商户号,必传
|
||||||
OutTradeNo string `json:"out_trade_no"` // 商户请求流水号,必传
|
OutTradeNo string `json:"out_trade_no"` // 商户请求流水号,必传
|
||||||
TradeNo string `json:"trade_no"` // 拉卡拉商户订单号,必传
|
TradeNo string `json:"trade_no"` // 拉卡拉商户订单号,必传
|
||||||
LogNo string `json:"log_no"` // 拉卡拉对账流水号,必传
|
LogNo string `json:"log_no"` // 拉卡拉对账流水号,必传
|
||||||
TradeMainType string `json:"trade_main_type"` // 交易大类,条件必传(PREORDER-主扫,MICROPAY-被扫,REFUND-退款,CANCEL-撤销)
|
TradeMainType string `json:"trade_main_type"` // 交易大类,条件必传(PREORDER-主扫,MICROPAY-被扫,REFUND-退款,CANCEL-撤销)
|
||||||
SplitAttr string `json:"split_attr"` // 拆单属性,条件必传(M-主单,S-子单)
|
SplitAttr string `json:"split_attr"` // 拆单属性,条件必传(M-主单,S-子单)
|
||||||
SplitInfo []struct {
|
SplitInfo []struct {
|
||||||
SubTradeNo string `json:"sub_trade_no"` // 子单交易流水号,必传
|
SubTradeNo string `json:"sub_trade_no"` // 子单交易流水号,必传
|
||||||
SubLogNo string `json:"sub_log_no"` // 子单对账单单流水号,必传
|
SubLogNo string `json:"sub_log_no"` // 子单对账单单流水号,必传
|
||||||
OutSubTradeNo string `json:"out_sub_trade_no"` // 外部子交易流水号,必传
|
OutSubTradeNo string `json:"out_sub_trade_no"` // 外部子交易流水号,必传
|
||||||
MerchantNo string `json:"merchant_no"` // 商户号,必传
|
MerchantNo string `json:"merchant_no"` // 商户号,必传
|
||||||
MerchantName string `json:"merchant_name"` // 商户名称,必传
|
MerchantName string `json:"merchant_name"` // 商户名称,必传
|
||||||
TermNo string `json:"term_no"` // 终端号,必传
|
TermNo string `json:"term_no"` // 终端号,必传
|
||||||
Amount string `json:"amount"` // 金额,必传(单位分)
|
Amount string `json:"amount"` // 金额,必传(单位分)
|
||||||
} `json:"split_info"` // 拆单信息,条件必传(如果查询订单是主单,则返回)
|
} `json:"split_info"` // 拆单信息,条件必传(如果查询订单是主单,则返回)
|
||||||
RefundSplitInfo []struct {
|
RefundSplitInfo []struct {
|
||||||
OutSubTradeNo string `json:"out_sub_trade_no"` // 外部子退款交易流水号,必传
|
OutSubTradeNo string `json:"out_sub_trade_no"` // 外部子退款交易流水号,必传
|
||||||
MerchantNo string `json:"merchant_no"` // 商户号,必传
|
MerchantNo string `json:"merchant_no"` // 商户号,必传
|
||||||
TermNo string `json:"term_no"` // 终端号,必传
|
TermNo string `json:"term_no"` // 终端号,必传
|
||||||
|
|
@ -46,28 +46,28 @@ type TradeQueryResponse struct {
|
||||||
TradeState string `json:"trade_state"` // 子交易状态,条件必传(SUCCESS-交易成功 FAIL-交易失败)
|
TradeState string `json:"trade_state"` // 子交易状态,条件必传(SUCCESS-交易成功 FAIL-交易失败)
|
||||||
ResultCode string `json:"result_code"` // 处理结果码,条件必传
|
ResultCode string `json:"result_code"` // 处理结果码,条件必传
|
||||||
ResultMsg string `json:"result_msg"` // 处理描述,条件必传
|
ResultMsg string `json:"result_msg"` // 处理描述,条件必传
|
||||||
} `json:"refund_split_info"` // 合单退款拆单信息,条件必传(如果查询订单是退款主单,则返回)
|
} `json:"refund_split_info"` // 合单退款拆单信息,条件必传(如果查询订单是退款主单,则返回)
|
||||||
AccTradeNo string `json:"acc_trade_no"` // 账户端交易订单号,必传
|
AccTradeNo string `json:"acc_trade_no"` // 账户端交易订单号,必传
|
||||||
AccountType string `json:"account_type"` // 钱包类型,必传(微信: WECHAT 支付宝: ALIPAY 银联: UQRCODEPAY 翼支付: BESTPAY 苏宁支付: SUNING)
|
AccountType string `json:"account_type"` // 钱包类型,必传(微信: WECHAT 支付宝: ALIPAY 银联: UQRCODEPAY 翼支付: BESTPAY 苏宁支付: SUNING)
|
||||||
TradeState string `json:"trade_state"` // 交易状态,必传(INIT-初始化 CREATE-下单成功 SUCCESS-交易成功 FAIL-交易失败 DEAL-交易处理中 UNKNOWN-未知状态 CLOSE-订单关闭 PART_REFUND-部分退款 REFUND-全部退款)
|
TradeState string `json:"trade_state"` // 交易状态,必传(INIT-初始化 CREATE-下单成功 SUCCESS-交易成功 FAIL-交易失败 DEAL-交易处理中 UNKNOWN-未知状态 CLOSE-订单关闭 PART_REFUND-部分退款 REFUND-全部退款)
|
||||||
TradeStateDesc string `json:"trade_state_desc"` // 交易状态描述,条件必传
|
TradeStateDesc string `json:"trade_state_desc"` // 交易状态描述,条件必传
|
||||||
TotalAmount string `json:"total_amount"` // 订单金额,必传(单位分)
|
TotalAmount string `json:"total_amount"` // 订单金额,必传(单位分)
|
||||||
PayerAmount string `json:"payer_amount"` // 付款人实付金额,条件必传(单位分)
|
PayerAmount string `json:"payer_amount"` // 付款人实付金额,条件必传(单位分)
|
||||||
AccSettleAmount string `json:"acc_settle_amount"` // 账户端结算金额,条件必传(单位分)
|
AccSettleAmount string `json:"acc_settle_amount"` // 账户端结算金额,条件必传(单位分)
|
||||||
AccMdiscountAmount string `json:"acc_mdiscount_amount"` // 商户侧优惠金额,条件必传(单位分)
|
AccMdiscountAmount string `json:"acc_mdiscount_amount"` // 商户侧优惠金额,条件必传(单位分)
|
||||||
AccDiscountAmount string `json:"acc_discount_amount"` // 账户端优惠金额,条件必传(单位分)
|
AccDiscountAmount string `json:"acc_discount_amount"` // 账户端优惠金额,条件必传(单位分)
|
||||||
AccOtherDiscountAmount string `json:"acc_other_discount_amount"` // 账户端其它优惠金额,条件必传(单位分)
|
AccOtherDiscountAmount string `json:"acc_other_discount_amount"` // 账户端其它优惠金额,条件必传(单位分)
|
||||||
TradeTime string `json:"trade_time"` // 交易完成时间,条件必传(yyyyMMddHHmmss)
|
TradeTime string `json:"trade_time"` // 交易完成时间,条件必传(yyyyMMddHHmmss)
|
||||||
UserId1 string `json:"user_id1"` // 用户标识1,条件必传(微信sub_open_id 支付宝buyer_login_id 买家支付账号)
|
UserId1 string `json:"user_id1"` // 用户标识1,条件必传(微信sub_open_id 支付宝buyer_login_id 买家支付账号)
|
||||||
UserId2 string `json:"user_id2"` // 用户标识2,条件必传(微信open_id 支付宝buyer_user_id 银user_id)
|
UserId2 string `json:"user_id2"` // 用户标识2,条件必传(微信open_id 支付宝buyer_user_id 银user_id)
|
||||||
BankType string `json:"bank_type"` // 付款银行,条件必传
|
BankType string `json:"bank_type"` // 付款银行,条件必传
|
||||||
CardType string `json:"card_type"` // 银行卡类型,条件必传(00: 借记卡 01: 贷记卡 02: 微信零钱 03: 支付宝花呗 04: 支付宝其他 05: 数字货币 06: 拉卡拉支付账户 99: 未知)
|
CardType string `json:"card_type"` // 银行卡类型,条件必传(00: 借记卡 01: 贷记卡 02: 微信零钱 03: 支付宝花呗 04: 支付宝其他 05: 数字货币 06: 拉卡拉支付账户 99: 未知)
|
||||||
AccActivityId string `json:"acc_activity_id"` // 活动ID,条件必传(在账户端商户后台配置的批次ID)
|
AccActivityId string `json:"acc_activity_id"` // 活动ID,条件必传(在账户端商户后台配置的批次ID)
|
||||||
TradeReqDate string `json:"trade_req_date"` // 交易请求日期,必传(yyyyMMdd)
|
TradeReqDate string `json:"trade_req_date"` // 交易请求日期,必传(yyyyMMdd)
|
||||||
AccRespFields map[string]interface{} `json:"acc_resp_fields"` // 账户端返回信息域,条件必传
|
AccRespFields map[string]interface{} `json:"acc_resp_fields"` // 账户端返回信息域,条件必传
|
||||||
} `json:"resp_data"` // 响应数据
|
} `json:"resp_data"` // 响应数据
|
||||||
}
|
}
|
||||||
|
|
||||||
func (t *TradeQueryResponse) SuccessOrFail() bool {
|
func (t *TradeQueryResponse) SuccessOrFail() bool {
|
||||||
return t.Code == "000000"
|
return t.Code == "BBS00000"
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue