Compare commits

...

4 Commits

Author SHA1 Message Date
gaoda 1c6d1dff34 fix(merchant): 更新商户查询接口URL配置
- 将QuerySubMerInfo接口的BASE_TEST_URL替换为BASE_URL
- 将MrchAuthStateQuery接口的BASE_TEST_URL替换为BASE_URL
- 修复生产环境下商户信息查询的地址配置问题
2025-12-15 15:16:36 +08:00
gaoda d8d5d36844 fix(model): 修正子商户信息查询响应结构体字段类型
- 将 QuerySubMerInfoResponse 中的 RespData 字段类型从 QueryMerResponseData 更正为 QuerySubMerInfoRespData
- 确保响应数据结构与实际返回内容一致
2025-12-13 14:20:34 +08:00
gaoda d86d7c7fb6 feat(lklsdk): 新增商户信息查询和认证状态查询功能
- 删除已弃用的订单分账结果查询相关代码
- 新增 QuerySubMerInfo 方法用于查询子商户信息
- 新增 MrchAuthStateQuery 方法用于查询商户认证状态
- 移除 WechatRealNameQuery 相关实现和模型定义
- 更新常量定义,移除不再使用的 URL 配置
- 添加新的请求和响应模型结构体定义
- 调整 SDK 接口方法,适配新的商户服务功能
2025-12-13 11:49:37 +08:00
gaoda deb2985747 feat(merchant): 新增微信实名认证结果查询功能
- 在 consts/url.go 中新增微信实名认证结果查询接口地址常量
- 在 lklsdk/merchant.go 中实现 WechatRealNameQuery 方法,用于发送实名认证查询请求
- 在 lklsdk/sdk.go 中暴露 WechatRealNameQuery 接口方法,方便外部调用
- 新增 model/wechatRealNameQuery.go 文件,定义微信实名认证查询相关的请求与响应结构体
- 实现 SuccessOrFail 方法判断微信实名认证查询是否成功
2025-12-12 15:51:30 +08:00
7 changed files with 137 additions and 77 deletions

View File

@ -23,9 +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_RESULT_QUERY_URL = "/v3/sacs/query_plus" LKL_SPLIT_LEDGER_FALLBACK_URL = "/v3/sacs/fallback"
LKL_SPLIT_LEDGER_FALLBACK_URL = "/v3/sacs/fallback"
) )
const ( const (
@ -57,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地址

View File

@ -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
}

View File

@ -153,11 +153,6 @@ func (s *SDK[T]) OrderSplitLedgerTest(req *model.OrderSplitLedgerReqData) (*T, e
return s.SplitLedger.OrderSplitLedgerTest(req) return s.SplitLedger.OrderSplitLedgerTest(req)
} }
// OrderSplitLedgerResultQuery 订单分账结果查询
func (s *SDK[T]) OrderSplitLedgerResultQuery(req *model.OrderSplitLedgerResultQueryReqData) (*T, error) {
return s.SplitLedger.OrderSplitLedgerResultQuery(req)
}
// OrderSplitLedgerFallback 订单分账回退 // OrderSplitLedgerFallback 订单分账回退
func (s *SDK[T]) OrderSplitLedgerFallback(req *model.OrderSplitLedgerFallbackReqData) (*T, error) { func (s *SDK[T]) OrderSplitLedgerFallback(req *model.OrderSplitLedgerFallbackReqData) (*T, error) {
return s.SplitLedger.OrderSplitLedgerFallback(req) return s.SplitLedger.OrderSplitLedgerFallback(req)
@ -247,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)
}

View File

@ -138,25 +138,6 @@ func (s *SplitLedgerService[T]) OrderSplitLedgerTest(req *model.OrderSplitLedger
return respBody, nil return respBody, nil
} }
func (s *SplitLedgerService[T]) OrderSplitLedgerResultQuery(req *model.OrderSplitLedgerResultQueryReqData) (*T, error) {
// 构建请求参数
url := consts.BASE_URL + consts.LKL_SPLIT_LEDGER_RESULT_QUERY_URL
// 构建BaseModel请求
baseReq := model.OrderSplitLedgerResultQueryRequest{
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) { func (s *SplitLedgerService[T]) OrderSplitLedgerFallback(req *model.OrderSplitLedgerFallbackReqData) (*T, error) {
// 构建请求参数 // 构建请求参数
url := consts.BASE_URL + consts.LKL_SPLIT_LEDGER_FALLBACK_URL url := consts.BASE_URL + consts.LKL_SPLIT_LEDGER_FALLBACK_URL

View File

@ -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"
}

View File

@ -1,49 +0,0 @@
package model
type OrderSplitLedgerResultQueryRequest struct {
ReqData *OrderSplitLedgerResultQueryReqData `json:"req_data"` // 请求业务数据
Version string `json:"version"` // 接口版本号
ReqTime string `json:"req_time"` // 请求时间格式为yyyyMMddHHmmss
}
type OrderSplitLedgerResultQueryReqData struct {
MerchantNo string `json:"merchant_no"` // 商户号必传长度32
SeparateNo string `json:"separate_no"` // 分账核心系统返回的分账流水号入参中的separate_no,out_separate_no至少二选一优先级: separate_no> out_separate_no
OutSeparateNo string `json:"out_separate_no"` // 商户分账指令流水号入入参中的separate_no,out_separate_no至少二选一优先级: separate_no> out_separate_no
}
type OrderSplitLedgerResultQueryResponse struct {
Msg string `json:"msg"` // 消息
RespTime string `json:"resp_time"` // 响应时间
Code string `json:"code"` // 响应码 SACS0000表示成功
RespData struct {
SeparateNo string `json:"separate_no"` // 分账指令流水号
OutSeparateNo string `json:"out_separate_no"` // 商户分账指令流水号
CmdType string `json:"cmd_type"` // 指令类型 SEPARATE分账 CANCEL分账撤销 FALLBACK分账回退
LogNo string `json:"log_no"` // 拉卡拉对账单流水号
LogDate string `json:"log_date"` // 交易日期 posp日期yyyyMMdd查清结算用
CalType string `json:"cal_type"` // 分账计算类型 0 按照指定金额。1 按照指定比例,默认 0 cmd_type为SEPARATE分账指令类型才有值
SeparateDate string `json:"separate_date"` // 分账日期
FinishDate string `json:"finish_date"` // 完成日期
TotalAmt string `json:"total_amt"` // 发生总金额,单位为分
Status string `json:"status"` // 分账状态ACCEPTED:已受理, PROCESSING:处理中, FAIL:失败, SUCCESS:成功, (如果分账指令后有反向操作指令,则原分账指令会变更成以下的状态之一:) CANCELING:撤销中, CANCELED:撤销成功, CANCEL_FAIL:撤销失败, FALLBACKING:回退中, FALLBACK_END:回退结束
FinalStatus string `json:"final_status"` // 处理状态 ACCEPTED:已受理, PROCESSING:处理中, FAIL:失败, SUCCESS:成功
FrontRuleId string `json:"front_rule_id"` // 分账前置规则ID
ActualSeparateAmt string `json:"actual_separate_amt"` // 实分金额
TotalFeeAmt string `json:"total_fee_amt"` // 手续费金额
AccResultDesc string `json:"acc_result_desc"` // 账户处理错误描述
DetailDatas []*OrderSplitLedgerResultQueryRespDetailDatas `json:"detail_datas"` // 明细数据
}
}
type OrderSplitLedgerResultQueryRespDetailDatas struct {
RecvMerchantNo string `json:"recv_merchant_no"` // 接收方商户号
RecvNo string `json:"recv_no"` // 接收方编号
Amt string `json:"amt"` // 分账金额
ActualAmt string `json:"actual_amt"` // 实分金额
FeeAmt string `json:"fee_amt"` // 手续费金额
}
func (s *OrderSplitLedgerResultQueryResponse) SuccessOrFail() bool {
return s.Code == "SACS0000"
}

50
model/querySubMerInfo.go Normal file
View File

@ -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"
}