diff --git a/lklsdk/account.go b/lklsdk/account.go index b6fbce3..998ab99 100644 --- a/lklsdk/account.go +++ b/lklsdk/account.go @@ -39,6 +39,25 @@ func (a *AccountService[T]) BalanceQuery(req *model.BalanceQueryReqData) (*T, er 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 账户提现 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 } + +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 +} diff --git a/lklsdk/common/json_cleaner.go b/lklsdk/common/json_cleaner.go index 16164f2..bccc67c 100644 --- a/lklsdk/common/json_cleaner.go +++ b/lklsdk/common/json_cleaner.go @@ -11,7 +11,6 @@ import ( // CleanJSON 清理JSON字符串中的空值和0值字段 func CleanJSON(jsonStr string) ([]byte, error) { // 解析为JSON - //var data interface{} json := gjson.NewWithOptions(jsonStr, gjson.Options{StrNumber: true}) glog.Infof(gctx.New(), "Cleaning JSON: %+v", json) // 递归清理数据 diff --git a/lklsdk/sdk.go b/lklsdk/sdk.go index e3d0c92..6e4d5c7 100644 --- a/lklsdk/sdk.go +++ b/lklsdk/sdk.go @@ -104,31 +104,55 @@ func (s *SDK[T]) ApplyLedgerMer(req *model.ApplyLedgerMerReqData) (*T, error) { return s.SplitLedger.ApplyLedgerMer(req) } +func (s *SDK[T]) ApplyLedgerMerTest(req *model.ApplyLedgerMerReqData) (*T, error) { + return s.SplitLedger.ApplyLedgerMerTest(req) +} + // QueryLedgerMer 商户分账信息查询 func (s *SDK[T]) QueryLedgerMer(req *model.QueryLedgerMerReqData) (*T, error) { return s.SplitLedger.QueryLedgerMer(req) } +func (s *SDK[T]) QueryLedgerMerTest(req *model.QueryLedgerMerReqData) (*T, error) { + return s.SplitLedger.QueryLedgerMerTest(req) +} + // ApplyLedgerReceiver 分账接收方创建申请 func (s *SDK[T]) ApplyLedgerReceiver(req *model.ApplyLedgerReceiverReqData) (*T, error) { return s.SplitLedger.ApplyLedgerReceiver(req) } +func (s *SDK[T]) ApplyLedgerReceiverTest(req *model.ApplyLedgerReceiverReqData) (*T, error) { + return s.SplitLedger.ApplyLedgerReceiverTest(req) +} + // ApplyBind 分账关系绑定申请 func (s *SDK[T]) ApplyBind(req *model.ApplyBindReqData) (*T, error) { return s.SplitLedger.ApplyBind(req) } +func (s *SDK[T]) ApplyBindTest(req *model.ApplyBindReqData) (*T, error) { + return s.SplitLedger.ApplyBindTest(req) +} + // QuerySplitBalance 可分账金额查询 func (s *SDK[T]) QuerySplitBalance(req *model.SplitBalanceReqData) (*T, error) { return s.SplitLedger.QuerySplitBalance(req) } +func (s *SDK[T]) QuerySplitBalanceTest(req *model.SplitBalanceReqData) (*T, error) { + return s.SplitLedger.QuerySplitBalanceTest(req) +} + // OrderSplitLedger 订单分账 func (s *SDK[T]) OrderSplitLedger(req *model.OrderSplitLedgerReqData) (*T, error) { return s.SplitLedger.OrderSplitLedger(req) } +func (s *SDK[T]) OrderSplitLedgerTest(req *model.OrderSplitLedgerReqData) (*T, error) { + return s.SplitLedger.OrderSplitLedgerTest(req) +} + // TradeQuery 交易查询 func (s *SDK[T]) TradeQuery(req *model.TradeQueryReqData) (*T, error) { return s.Trade.TradeQuery(req) @@ -144,15 +168,26 @@ func (s *SDK[T]) BalanceQuery(req *model.BalanceQueryReqData) (*T, error) { 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) { return s.UploadFile.UploadFileQuery(req) } +func (s *SDK[T]) UploadFileQueryTest(req *model.UploadFileReqData) (*T, error) { + return s.UploadFile.UploadFileQueryTest(req) +} // Withdraw 账户提现 func (s *SDK[T]) Withdraw(req *model.WithdrawReqData) (*T, error) { return s.Account.Withdraw(req) } +func (s *SDK[T]) WithdrawTest(req *model.WithdrawReqData) (*T, error) { + return s.Account.WithdrawTest(req) +} + // ECApply 电子合同申请 func (s *SDK[T]) ECApply(req *ecApply.ECApplyRequestData) (*ecApply.ECApplyResponse, error) { return s.EC.ECApply(req) diff --git a/lklsdk/split_ledger.go b/lklsdk/split_ledger.go index aedbd54..6cc8135 100644 --- a/lklsdk/split_ledger.go +++ b/lklsdk/split_ledger.go @@ -50,6 +50,31 @@ func (s *SplitLedgerService[T]) ApplyLedgerMer(req *model.ApplyLedgerMerReqData) 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 分账接收方创建申请 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 } +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 商户分账信息查询 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 } + +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 +} diff --git a/lklsdk/split_ledger_more.go b/lklsdk/split_ledger_more.go index 75f5d20..8daac74 100644 --- a/lklsdk/split_ledger_more.go +++ b/lklsdk/split_ledger_more.go @@ -36,6 +36,30 @@ func (s *SplitLedgerService[T]) ApplyBind(req *model.ApplyBindReqData) (*T, erro 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 可分账金额查询 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 } +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 订单分账 func (s *SplitLedgerService[T]) OrderSplitLedger(req *model.OrderSplitLedgerReqData) (*T, error) { // 构建请求参数 @@ -75,3 +118,22 @@ func (s *SplitLedgerService[T]) OrderSplitLedger(req *model.OrderSplitLedgerReqD } 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 +} diff --git a/lklsdk/uploadFile.go b/lklsdk/uploadFile.go index c793dad..b10d09d 100644 --- a/lklsdk/uploadFile.go +++ b/lklsdk/uploadFile.go @@ -46,3 +46,26 @@ func (t *UploadFileService[T]) UploadFileQuery(req *model.UploadFileReqData) (*T } 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 +}