diff --git a/consts/url.go b/consts/url.go index 968224a..a2bc21f 100644 --- a/consts/url.go +++ b/consts/url.go @@ -46,3 +46,15 @@ const ( // LKL_RECONF_SUBMIT 拉卡拉商户进件复议提交 LKL_RECONF_SUBMIT = "/v2/mms/openApi/reconsiderSubmit" ) + +// unifiedReturn 统一退货API地址 +const ( + // LKL_UNIFIED_RETURN_MERGE_REFUND_URL 拉卡拉合单退货 + LKL_UNIFIED_RETURN_MERGE_REFUND_URL = "/v3/rfd/refund_front/merge_refund" + // LKL_UNIFIED_RETURN_REFUND_URL 拉卡拉退货 + LKL_UNIFIED_RETURN_REFUND_URL = "/v3/rfd/refund_front/refund" + // LKL_UNIFIED_RETURN_REFUND_QUERY_URL 拉卡拉退货查询 + LKL_UNIFIED_RETURN_REFUND_QUERY_URL = "/v3/rfd/refund_front/refund_query" + // LKL_UNIFIED_RETURN_REFUND_FEE_URL 拉卡拉退货手续费查询 + LKL_UNIFIED_RETURN_REFUND_FEE_URL = "/v3/rfd/refund_front/refund_fee" +) diff --git a/lklsdk/account.go b/lklsdk/account.go index 0891b82..73008ce 100644 --- a/lklsdk/account.go +++ b/lklsdk/account.go @@ -1,10 +1,9 @@ package lklsdk import ( - "time" - "github.com/black1552/lkl_sdk/consts" "github.com/black1552/lkl_sdk/model" + "github.com/gogf/gf/v2/os/gtime" ) // AccountService 账户服务 @@ -26,7 +25,7 @@ func (a *AccountService[T]) BalanceQuery(req *model.BalanceQueryReqData) (*T, er // 构建BaseModel请求 baseReq := model.BalanceQueryRequest{ - ReqTime: time.Now().Format("20060102150405"), + ReqTime: gtime.Now().Format("YmdHis"), Version: "3.0", ReqData: req, } @@ -46,7 +45,7 @@ func (a *AccountService[T]) Withdraw(req *model.WithdrawReqData) (*T, error) { // 构建BaseModel请求 baseReq := model.WithdrawRequest{ - ReqTime: time.Now().Format("20060102150405"), + ReqTime: gtime.Now().Format("YmdHis"), Version: "3.0", ReqData: req, } diff --git a/lklsdk/common/client.go b/lklsdk/common/client.go new file mode 100644 index 0000000..4c6e80b --- /dev/null +++ b/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) +} diff --git a/lklsdk/common/structs.go b/lklsdk/common/structs.go new file mode 100644 index 0000000..3f2e7a0 --- /dev/null +++ b/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:"回调地址"` +} diff --git a/lklsdk/unifiedReturn/mergeRefund/api.go b/lklsdk/unifiedReturn/mergeRefund/api.go new file mode 100644 index 0000000..a42ed28 --- /dev/null +++ b/lklsdk/unifiedReturn/mergeRefund/api.go @@ -0,0 +1,34 @@ +package mergerefund + +import ( + "github.com/black1552/lkl_sdk/consts" + "github.com/black1552/lkl_sdk/lklsdk/common" + "github.com/gogf/gf/v2/os/gtime" +) + +type MergeRefund[T any] struct { + client *common.Client[T] +} + +func NewMergeRefund[T any](client *common.Client[T]) *MergeRefund[T] { + return &MergeRefund[T]{ + client: client, + } +} +func (t *MergeRefund[T]) MergeRefund(req *RequestDataMergeRefund) (*T, error) { + // 构建请求参数 + url := consts.BASE_URL + consts.LKL_UNIFIED_RETURN_MERGE_REFUND_URL + // 构建BaseModel请求 + baseReq := RequestMergeRefund{ + ReqTime: gtime.Now().Format("YmdHis"), + Version: "3.0", + ReqData: req, + } + + // 发送请求 + respBody, err := t.client.DoRequest(url, baseReq) + if err != nil { + return nil, err + } + return respBody, nil +} diff --git a/lklsdk/unifiedReturn/mergeRefund/request.go b/lklsdk/unifiedReturn/mergeRefund/request.go new file mode 100644 index 0000000..f7501cf --- /dev/null +++ b/lklsdk/unifiedReturn/mergeRefund/request.go @@ -0,0 +1,42 @@ +package mergerefund + +// RequestMergeRefund 统一退货基础请求结构体 +type RequestMergeRefund struct { + ReqTime string `json:"req_time" dc:"ReqTime 请求时间 必填，格式yyyyMMddHHmmss"` + Version string `json:"version" dc:"Version 版本号 必填，固定为\"3\""` + ReqData *RequestDataMergeRefund `json:"req_data" dc:"ReqData 请求参数 必填，具体字段见对应的数据结构体"` +} + +// RequestDataMergeRefund 合单退货请求参数结构体 +type RequestDataMergeRefund struct { + MerchantNo string `json:"merchant_no" dc:"MerchantNo 商户号 必填，拉卡拉分配的商户号"` + TermNo string `json:"term_no" dc:"TermNo 终端号 必填，拉卡拉分配的终端号"` + OutTradeNo string `json:"out_trade_no" dc:"OutTradeNo 商户请求流水号 必填，商户系统唯一"` + RefundAmount string `json:"refund_amount" dc:"RefundAmount 退款金额 必填，单位分，整数数字型字符"` + RefundReason string `json:"refund_reason,omitempty" dc:"RefundReason 退货原因 可选"` + OriginLogNo string `json:"origin_log_no,omitempty" dc:"OriginLogNo 拉卡拉对账单流水号 可选，正交易返回的拉卡拉对账单流水号"` + OriginOutTradeNo string `json:"origin_out_trade_no,omitempty" dc:"OriginOutTradeNo 原商户交易流水号 可选"` + OriginTradeNo string `json:"origin_trade_no,omitempty" dc:"OriginTradeNo 原交易拉卡拉交易订单号 可选"` + LocationInfo *LocationInfo `json:"location_info" dc:"LocationInfo 地址位置信息 必填"` + NotifyURL string `json:"notify_url,omitempty" dc:"NotifyURL 后台通知地址 可选，交易结果通知地址"` + RefundAccMode string `json:"refund_acc_mode,omitempty" dc:"RefundAccMode 退货账户模式 可选，00退货账户余额 05商户余额 06终端余额"` + RefundSplitInfo []*RelateOutSplitInfo `json:"refund_split_info,omitempty" dc:"RefundSplitInfo 请参合单域 可选"` +} + +// LocationInfo 地址位置信息结构体 +type LocationInfo struct { + RequestIP string `json:"request_ip" dc:"RequestIP 请求方IP地址 必填，格式如36.45.36.95"` + Location string `json:"location,omitempty" dc:"Location 维度,经度 可选，商户终端的地理位置，格式：纬度,经度，+表示北纬、东经，-表示南纬、西经，精度最长支持小数点后9位"` + BaseStation string `json:"base_station,omitempty" dc:"BaseStation 基站信息 可选，客户端设备的基站信息"` +} + +// RelateOutSplitInfo 请求合单域结构体 +type RelateOutSplitInfo struct { + OutSubTradeNo string `json:"out_sub_trade_no" dc:"OutSubTradeNo 外部子退款交易流水号 必填，商户子交易退款流水号，商户号下唯一"` + MerchantNo string `json:"merchant_no" dc:"MerchantNo 商户号 必填，拉卡拉分配的商户号"` + TermNo string `json:"term_no" dc:"TermNo 终端号 必填，拉卡拉分配的业务终端号"` + RefundAmount string `json:"refund_amount" dc:"RefundAmount 申请退款金额 必填，单位分，整数型字符"` + OriginOutSubTradeNo string `json:"origin_out_sub_trade_no,omitempty" dc:"OriginOutSubTradeNo 原商户交易流水号 可选，下单时的商户子单请求流水号"` + OriginSubTradeNo string `json:"origin_sub_trade_no,omitempty" dc:"OriginSubTradeNo 原拉卡拉子交易流水号 可选，下单成功时，返回的拉卡拉交易子流水"` + OriginSubLogNo string `json:"origin_sub_log_no,omitempty" dc:"OriginSubLogNo 原对账单子流水号 可选，原交易的tradeNo的后14位，必须是66开头的"` +} diff --git a/lklsdk/unifiedReturn/mergeRefund/response.go b/lklsdk/unifiedReturn/mergeRefund/response.go new file mode 100644 index 0000000..3736e47 --- /dev/null +++ b/lklsdk/unifiedReturn/mergeRefund/response.go @@ -0,0 +1,53 @@ +package mergerefund + +// ResponseMergeRefund 统一退货响应结构体 +type ResponseMergeRefund struct { + Code string `json:"code" dc:"Code 响应码"` + Msg string `json:"msg" dc:"Msg 响应描述"` + RespTime string `json:"resp_time" dc:"RespTime 响应时间"` + RespData *ResponseDataMergeRefund `json:"resp_data" dc:"RespData 响应数据"` +} + +func (r *ResponseMergeRefund) SuccessOrFail() bool { + return r.Code == "000000" +} + +// ResponseDataMergeRefund 合单退货响应数据结构体 +type ResponseDataMergeRefund struct { + TradeState string `json:"trade_state" dc:"TradeState 交易状态 必填，INIT-初始化；SUCCESS-交易成功；FAIL-交易失败；DEAL-交易处理中/未知；PROCESSING-交易已受理；TIMEOUT-超时未知；EXCEPTION-异常"` + RefundType string `json:"refund_type" dc:"RefundType 退货模式 必填"` + MerchantNo string `json:"merchant_no" dc:"MerchantNo 商户号 必填，拉卡拉分配的商户号"` + OutTradeNo string `json:"out_trade_no" dc:"OutTradeNo 商户请求流水号 必填，请求中的商户请求流水号"` + TradeNo string `json:"trade_no" dc:"TradeNo 拉卡拉交易流水号 必填"` + LogNo string `json:"log_no" dc:"LogNo 拉卡拉对账单流水号 必填，tradeNo的后14位"` + AccTradeNo string `json:"acc_trade_no,omitempty" dc:"AccTradeNo 账户端交易订单号 可选"` + AccountType string `json:"account_type,omitempty" dc:"AccountType 钱包类型 可选，微信：WECHAT；支付宝：ALIPAY；银联：UQRCODEPAY；翼支付:BESTPAY；苏宁易付宝:SUNING"` + TotalAmount string `json:"total_amount" dc:"TotalAmount 交易金额 必填，单位分，整数数字型字符串"` + RefundAmount string `json:"refund_amount" dc:"RefundAmount 申请退款金额 必填，单位分，整数数字型字符串"` + PayerAmount string `json:"payer_amount" dc:"PayerAmount 实际退款金额 必填，单位分，整数数字型字符串"` + TradeTime string `json:"trade_time,omitempty" dc:"TradeTime 退款时间 可选，实际退款时间。yyyyMMddHHmmss"` + OriginLogNo string `json:"origin_log_no,omitempty" dc:"OriginLogNo 原拉卡拉对账单流水号 可选，如果请求中携带，则返回"` + OriginTradeNo string `json:"origin_trade_no,omitempty" dc:"OriginTradeNo 原拉卡拉交易流水号 可选，如果请求中携带，则返回"` + OriginOutTradeNo string `json:"origin_out_trade_no,omitempty" dc:"OriginOutTradeNo 原商户请求流水号 可选，如果请求中携带，则返回"` + UpIssAddnData string `json:"up_iss_addn_data,omitempty" dc:"UpIssAddnData 单品营销附加数据 可选，扫码交易，参与单品营销优惠时返回"` + UpCouponInfo string `json:"up_coupon_info,omitempty" dc:"UpCouponInfo 银联优惠信息 可选，扫码交易，参与单品营销优惠时返回"` + TradeInfo string `json:"trade_info,omitempty" dc:"TradeInfo 出资方信息 可选，扫码交易"` + ChannelRetDesc string `json:"channel_ret_desc" dc:"ChannelRetDesc 返回描述信息 必填"` + RefundSplitInfo []*RelateOutSplitRspInfo `json:"refund_split_info" dc:"RefundSplitInfo 响应合单域 必填"` +} + +// RelateOutSplitRspInfo 响应合单域结构体 +type RelateOutSplitRspInfo struct { + OutSubTradeNo string `json:"out_sub_trade_no" dc:"OutSubTradeNo 外部子退款交易流水号 必填，请求中的商户子流水号"` + MerchantNo string `json:"merchant_no" dc:"MerchantNo 商户号 必填，拉卡拉分配的商户号"` + TermNo string `json:"term_no" dc:"TermNo 终端号 必填，拉卡拉分配的业务终端号"` + TradeState string `json:"trade_state" dc:"TradeState 交易状态 必填，INIT-初始化；SUCCESS-交易成功；FAIL-交易失败；DEAL-交易处理中/未知；PROCESSING-交易已受理；TIMEOUT-超时未知；EXCEPTION-异常"` + SubTradeNo string `json:"sub_trade_no" dc:"SubTradeNo 拉卡拉子交易流水号 必填"` + SubLogNo string `json:"sub_log_no" dc:"SubLogNo 拉卡拉子对账单流水号 必填"` + RefundAmount string `json:"refund_amount" dc:"RefundAmount 申请退款金额 必填，单位分，整数型字符"` + PayerAmount string `json:"payer_amount" dc:"PayerAmount 实际退款金额 必填，单位分，整数型字符"` + TotalAmount string `json:"total_amount" dc:"TotalAmount 交易金额 必填，单位分，整数型字符"` + OriginSubLogNo string `json:"origin_sub_log_no,omitempty" dc:"OriginSubLogNo 原拉卡拉子对账单流水号 可选，如果请求中携带，则返回"` + OriginSubTradeNo string `json:"origin_sub_trade_no,omitempty" dc:"OriginSubTradeNo 原拉卡拉子交易流水号 可选，如果请求中携带，则返回"` + OriginOutSubTradeNo string `json:"origin_out_sub_trade_no,omitempty" dc:"OriginOutSubTradeNo 原商户子交易流水号 可选，如果请求中携带，则返回"` +} diff --git a/lklsdk/unifiedReturn/refund/api.go b/lklsdk/unifiedReturn/refund/api.go new file mode 100644 index 0000000..ed2f6f5 --- /dev/null +++ b/lklsdk/unifiedReturn/refund/api.go @@ -0,0 +1,40 @@ +package refund + +import ( + "github.com/black1552/lkl_sdk/consts" + "github.com/black1552/lkl_sdk/lklsdk/common" + "github.com/gogf/gf/v2/os/gtime" +) + +// Refund 统一退货API结构体 +type Refund[T any] struct { + client *common.Client[T] +} + +// NewRefund 创建统一退货API实例 +func NewRefund[T any](client *common.Client[T]) *Refund[T] { + return &Refund[T]{ + client: client, + } +} + +// Refund 发起统一退货请求 +// request: 统一退货请求参数 +// 返回统一退货响应结果和错误信息 +func (api *Refund[T]) Refund(req *RequestDataRefund) (*T, error) { + // 构建请求参数 + url := consts.BASE_URL + consts.LKL_UNIFIED_RETURN_REFUND_URL + // 构建BaseModel请求 + baseReq := RequestRefund{ + ReqTime: gtime.Now().Format("YmdHis"), + Version: "3.0", + ReqData: req, + } + + // 发送请求 + respBody, err := api.client.DoRequest(url, baseReq) + if err != nil { + return nil, err + } + return respBody, nil +} diff --git a/lklsdk/unifiedReturn/refund/reponse.go b/lklsdk/unifiedReturn/refund/reponse.go new file mode 100644 index 0000000..f353ba3 --- /dev/null +++ b/lklsdk/unifiedReturn/refund/reponse.go @@ -0,0 +1,37 @@ +package refund + +// ResponseRefund 统一退货响应结构体 +// 参考文档：https://o.lakala.com/#/home/document/detail?id=892 +type ResponseRefund struct { + Code string `json:"code" dc:"Code 返回业务代码 必填，通讯成功返回码：000000；交易未知：RFD11105/RFD11112；其他返回码可视为失败"` + Msg string `json:"msg" dc:"Msg 返回业务代码描述 必填，如\"成功\""` + RespTime string `json:"resp_time" dc:"RespTime 响应时间 必填，格式yyyyMMddHHmmss"` + RespData *ResponseDataRefund `json:"resp_data" dc:"RespData 响应数据 必填，具体字段根据接口返回"` +} + +func (r *ResponseRefund) SuccessOrFail() bool { + return r.Code == "000000" +} + +// ResponseDataRefund 统一退货响应数据结构体 +type ResponseDataRefund struct { + TradeState string `json:"trade_state" dc:"TradeState 交易状态 必填，INIT-初始化；SUCCESS-交易成功；FAIL-交易失败；DEAL-交易处理中/未知；PROCESSING-交易已受理；TIMEOUT-超时未知；EXCEPTION-异常"` + RefundType string `json:"refund_type" dc:"RefundType 退货模式 必填"` + MerchantNo string `json:"merchant_no" dc:"MerchantNo 商户号 必填，拉卡拉分配的商户号"` + OutTradeNo string `json:"out_trade_no" dc:"OutTradeNo 商户请求流水号 必填，请求中的商户请求流水号"` + TradeNo string `json:"trade_no" dc:"TradeNo 拉卡拉交易流水号 必填"` + LogNo string `json:"log_no" dc:"LogNo 拉卡拉对账单流水号 必填，tradeNo的后14位"` + AccTradeNo string `json:"acc_trade_no,omitempty" dc:"AccTradeNo 账户端交易订单号 可选"` + AccountType string `json:"account_type,omitempty" dc:"AccountType 钱包类型 可选，微信：WECHAT；支付宝：ALIPAY；银联：UQRCODEPAY；翼支付:BESTPAY；苏宁易付宝:SUNING"` + TotalAmount string `json:"total_amount" dc:"TotalAmount 交易金额 必填，单位分，整数数字型字符串"` + RefundAmount string `json:"refund_amount" dc:"RefundAmount 申请退款金额 必填，单位分，整数数字型字符串"` + PayerAmount string `json:"payer_amount" dc:"PayerAmount 实际退款金额 必填，单位分，整数数字型字符串"` + TradeTime string `json:"trade_time,omitempty" dc:"TradeTime 退款时间 可选，实际退款时间。yyyyMMddHHmmss"` + OriginLogNo string `json:"origin_log_no,omitempty" dc:"OriginLogNo 原拉卡拉对账单流水号 可选，如果请求中携带，则返回"` + OriginTradeNo string `json:"origin_trade_no,omitempty" dc:"OriginTradeNo 原拉卡拉交易流水号 可选，如果请求中携带，则返回"` + OriginOutTradeNo string `json:"origin_out_trade_no,omitempty" dc:"OriginOutTradeNo 原商户请求流水号 可选，如果请求中携带，则返回"` + UpIssAddData string `json:"up_iss_add_data,omitempty" dc:"UpIssAddData 单品营销附加数据 可选，扫码交易，参与单品营销优惠时返回"` + UpCouponInfo string `json:"up_coupon_info,omitempty" dc:"UpCouponInfo 银联优惠信息 可选，扫码交易，参与单品营销优惠时返回"` + TradeInfo string `json:"trade_info,omitempty" dc:"TradeInfo 出资方信息 可选，扫码交易"` + ChannelRetDesc string `json:"channel_ret_desc" dc:"ChannelRetDesc 返回描述信息 必填"` +} diff --git a/lklsdk/unifiedReturn/refund/request.go b/lklsdk/unifiedReturn/refund/request.go new file mode 100644 index 0000000..ad655d6 --- /dev/null +++ b/lklsdk/unifiedReturn/refund/request.go @@ -0,0 +1,34 @@ +package refund + +// RequestRefund 统一退货基础请求结构体 +// 参考文档：https://o.lakala.com/#/home/document/detail?id=894 +type RequestRefund struct { + ReqTime string `json:"req_time"` + Version string `json:"version"` + ReqData *RequestDataRefund `json:"req_data"` +} + +// RequestDataRefund 统一退货请求数据结构体 +// 注意：origin_out_trade_no、origin_log_no、origin_trade_no至少一个必填（调用收银台下单接口拉起交易后发起退款时至少要传两个） +// 优先级顺序：origin_trade_no > origin_log_no > origin_out_trade_no +type RequestDataRefund struct { + MerchantNo string `json:"merchant_no"` // merchant_no: 商户号 (必填，拉卡拉分配的商户号，String(15)) + TermNo string `json:"term_no"` // term_no: 终端号 (必填，拉卡拉分配的终端号，String(8)) + OutTradeNo string `json:"out_trade_no"` // out_trade_no: 商户请求流水号 (必填，商户系统唯一，String(32)) + RefundAmount string `json:"refund_amount"` // refund_amount: 退款金额 (必填，单位分，整数数字型字符，String(12)) + RefundReason string `json:"refund_reason,omitempty"` // refund_reason: 退货原因 (可选，String(32)) + OriginLogNo string `json:"origin_log_no,omitempty"` // origin_log_no: 拉卡拉对账单流水号 (可选，正交易返回的拉卡拉对账单流水号，String(14)) + OriginOutTradeNo string `json:"origin_out_trade_no,omitempty"` // origin_out_trade_no: 原商户交易流水号 (可选，String(32)) + OriginTradeNo string `json:"origin_trade_no,omitempty"` // origin_trade_no: 原交易拉卡拉交易订单号 (可选，String(32)) + LocationInfo *LocationInfo `json:"location_info"` // location_info: 地址位置信息 (必填) + RefundAccMode string `json:"refund_acc_mode,omitempty"` // refund_acc_mode: 退货账户模式 (可选，00退货账户余额 05商户余额 06终端余额 30终点账户，String(2)) + NotifyURL string `json:"notify_url,omitempty"` // notify_url: 后台通知地址 (可选，交易结果通知地址，String(128)) + RefundAmtSts string `json:"refund_amt_sts,omitempty"` // refund_amt_sts: 退货资金状态 (可选，00 分账前，01 分账后；分账交易部分退货的情况，需要前端上送交易的分账状态，String(2)) +} + +// LocationInfo 地址位置信息结构体 +type LocationInfo struct { + RequestIP string `json:"request_ip"` // request_ip: 请求IP (必填) + Location string `json:"location"` // location: 位置信息 (必填，如经纬度等) + BaseStation string `json:"base_station,omitempty"` // base_station: 基站信息 (可选) +} diff --git a/lklsdk/unifiedReturn/refundfee/api.go b/lklsdk/unifiedReturn/refundfee/api.go new file mode 100644 index 0000000..2985e1d --- /dev/null +++ b/lklsdk/unifiedReturn/refundfee/api.go @@ -0,0 +1 @@ +package refundfee diff --git a/lklsdk/unifiedReturn/refundfee/request.go b/lklsdk/unifiedReturn/refundfee/request.go new file mode 100644 index 0000000..2985e1d --- /dev/null +++ b/lklsdk/unifiedReturn/refundfee/request.go @@ -0,0 +1 @@ +package refundfee diff --git a/lklsdk/unifiedReturn/refundfee/response.go b/lklsdk/unifiedReturn/refundfee/response.go new file mode 100644 index 0000000..2985e1d --- /dev/null +++ b/lklsdk/unifiedReturn/refundfee/response.go @@ -0,0 +1 @@ +package refundfee diff --git a/lklsdk/unifiedReturn/refundquery/api.go b/lklsdk/unifiedReturn/refundquery/api.go new file mode 100644 index 0000000..0ea05a0 --- /dev/null +++ b/lklsdk/unifiedReturn/refundquery/api.go @@ -0,0 +1,37 @@ +package refundquery + +import ( + "github.com/black1552/lkl_sdk/consts" + "github.com/black1552/lkl_sdk/lklsdk/common" + "github.com/gogf/gf/v2/os/gtime" +) + +type RefundQuery[T any] struct { + client *common.Client[T] +} + +// NewRefundQuery 创建统一退货查询API实例 +func NewRefundQuery[T any](client *common.Client[T]) *RefundQuery[T] { + return &RefundQuery[T]{ + client: client, + } +} + +// RefundQuery 发起统一退货查询请求 +func (api *RefundQuery[T]) RefundQuery(req *RequestDataRefundQuery) (*T, error) { + // 构建请求参数 + url := consts.BASE_URL + consts.LKL_UNIFIED_RETURN_REFUND_QUERY_URL + // 构建BaseModel请求 + baseReq := RequestRefundQuery{ + ReqTime: gtime.Now().Format("YmdHis"), + Version: "3.0", + ReqData: req, + } + + // 发送请求 + respBody, err := api.client.DoRequest(url, baseReq) + if err != nil { + return nil, err + } + return respBody, nil +} diff --git a/lklsdk/unifiedReturn/refundquery/request.go b/lklsdk/unifiedReturn/refundquery/request.go new file mode 100644 index 0000000..aab1d02 --- /dev/null +++ b/lklsdk/unifiedReturn/refundquery/request.go @@ -0,0 +1,18 @@ +package refundquery + +// RequestRefundQuery 统一退货查询请求结构体 +// API文档: https://o.lakala.com/#/home/document/detail?id=893 +type RequestRefundQuery struct { + ReqTime string `json:"req_time" dc:"ReqTime 请求时间 格式yyyyMMddHHmmss"` + Version string `json:"version" dc:"Version 版本号 固定值3.0"` + ReqData *RequestDataRefundQuery `json:"req_data" dc:"ReqData 请求数据"` +} + +// RequestDataRefundQuery 统一退货查询请求数据结构体 +// API文档: https://o.lakala.com/#/home/document/detail?id=893 +type RequestDataRefundQuery struct { + MerchantNo string `json:"merchant_no" dc:"MerchantNo 商户号 必填，拉卡拉分配的商户号，String(15)"` + TermNo string `json:"term_no" dc:"TermNo 终端号 必填，拉卡拉分配的业务终端号，String(8)"` + OutTradeNo string `json:"out_trade_no,omitempty" dc:"OutTradeNo 商户交易流水号 选填，下单时的商户请求流水号，String(32) 与拉卡拉交易流水号二选一"` + TradeNo string `json:"trade_no,omitempty" dc:"TradeNo 拉卡拉交易流水号 选填，拉卡拉交易流水号，String(32) 与商户交易流水号二选一"` +} diff --git a/lklsdk/unifiedReturn/refundquery/response.go b/lklsdk/unifiedReturn/refundquery/response.go new file mode 100644 index 0000000..0775776 --- /dev/null +++ b/lklsdk/unifiedReturn/refundquery/response.go @@ -0,0 +1,56 @@ +package refundquery + +// ResponseRefundQuery 统一退货查询响应结构体 +// API文档: https://o.lakala.com/#/home/document/detail?id=893 +type ResponseRefundQuery struct { + Code string `json:"code" dc:"Code 响应码 RFD00000#成功、RFD11112#网络请求超时"` + Msg string `json:"msg" dc:"Msg 响应描述"` + Data *ResponseDataRefundQuery `json:"data,omitempty" dc:"Data 响应数据"` + Sign string `json:"sign" dc:"Sign 签名"` +} + +// ResponseDataRefundQuery 统一退货查询响应数据结构体 +// API文档: https://o.lakala.com/#/home/document/detail?id=893 +type ResponseDataRefundQuery struct { + OutTradeNo string `json:"out_trade_no" dc:"OutTradeNo 商户请求流水号 必填，原退款交易商户请求流水号（扫码交易返回）"` + TradeTime string `json:"trade_time" dc:"TradeTime 交易时间 必填，交易时间yyyyMMddHHmmss"` + TradeState string `json:"trade_state" dc:"TradeState 交易状态 必填，INIT-初始化；SUCCESS-交易成功；FAIL-交易失败；DEAL-交易处理中/未知；TIMEOUT-超时未知；EXCEPTION-异常"` + TradeNo string `json:"trade_no" dc:"TradeNo 拉卡拉商户订单号 必填，拉卡拉生成的交易流水"` + LogNo string `json:"log_no" dc:"LogNo 拉卡拉对账单流水号 必填，拉卡拉生成的对账单流水号（新增）"` + AccTradeNo string `json:"acc_trade_no,omitempty" dc:"AccTradeNo 账户端交易订单号 选填，账户端交易流水号，String(32)"` + RefundAmount string `json:"refund_amount" dc:"RefundAmount 交易金额 必填"` + PayMode string `json:"pay_mode,omitempty" dc:"PayMode 支付方式 选填，00 借记卡 01 贷记卡 02 准贷记卡 银行卡交易返回"` + CrdNo string `json:"crd_no,omitempty" dc:"CrdNo 卡号 选填，脱敏卡号，前六后四，中间用*替换"` + AccountType string `json:"account_type,omitempty" dc:"AccountType 钱包类型 选填，微信：WECHAT 支付宝：ALIPAY 银联：UNION 翼支付: BESTPAY 苏宁易付宝: SUNING 扫码交易返回"` + PayerAmount string `json:"payer_amount,omitempty" dc:"PayerAmount 付款人实付金额 选填，实际退款金额，单位分 扫码交易返回"` + AccSettleAmount string `json:"acc_settle_amount,omitempty" dc:"AccSettleAmount 账户端结算金额 选填，账户端应结订单金额，单位分 扫码交易返回"` + AccMdiscountAmount string `json:"acc_mdiscount_amount,omitempty" dc:"AccMdiscountAmount 商户侧优惠金额（账户端） 选填，商户优惠金额，单位分 扫码交易返回"` + AccDiscountAmount string `json:"acc_discount_amount,omitempty" dc:"AccDiscountAmount 账户端优惠金额 选填，拉卡拉优惠金额， 扫码交易返回"` + ChannelRetDesc string `json:"channel_ret_desc" dc:"ChannelRetDesc 返回描述信息 必填，code#msg：RFD00000#成功、RFD11112#网络请求超时"` + RefundSplitInfo []*RelateOutSplitRspInfo `json:"refund_split_info,omitempty" dc:"RefundSplitInfo 退款拆单信息 选填，合单交易退款查询时返回"` + OriginLogNo string `json:"origin_log_no" dc:"OriginLogNo 拉卡拉对账单流水号 必填，原交易拉卡拉对账单流水号"` + OriginOutTradeNo string `json:"origin_out_trade_no" dc:"OriginOutTradeNo 原商户交易流水号 必填"` + OriginTradeNo string `json:"origin_trade_no" dc:"OriginTradeNo 原交易拉卡拉交易订单号 必填"` + OriginTotalAmount string `json:"origin_total_amount" dc:"OriginTotalAmount 原交易金额 必填，原正交易订单金额"` + RefundType string `json:"refund_type,omitempty" dc:"RefundType 退货模式 选填"` +} + +// RelateOutSplitRspInfo 退款拆单信息结构体 +// API文档: https://o.lakala.com/#/home/document/detail?id=893 +type RelateOutSplitRspInfo struct { + OutSubTradeNo string `json:"out_sub_trade_no" dc:"OutSubTradeNo 外部子退款交易流水号 必填，商户子交易流水号，商户号下唯一"` + MerchantNo string `json:"merchant_no" dc:"MerchantNo 商户号 必填，拉卡拉分配的商户号"` + TermNo string `json:"term_no" dc:"TermNo 终端号 必填，拉卡拉分配的业务终端号"` + RefundAmount string `json:"refund_amount" dc:"RefundAmount 申请退款金额 必填，单位分，整数型字符"` + SubTradeNo string `json:"sub_trade_no,omitempty" dc:"SubTradeNo 拉卡拉子交易流水号 选填"` + SubLogNo string `json:"sub_log_no,omitempty" dc:"SubLogNo 对账单子流水号 选填，sub_trade_no后14位"` + TradeState string `json:"trade_state,omitempty" dc:"TradeState 子交易状态 选填，SUCCESS-交易成功 FAIL-交易失败"` + ResultCode string `json:"result_code,omitempty" dc:"ResultCode 处理结果码 选填"` + ResultMsg string `json:"result_msg,omitempty" dc:"ResultMsg 处理描述 选填"` +} + +// SuccessOrFail 判断交易是否成功 +// 返回true表示交易成功，false表示交易失败或处理中 +func (r *ResponseRefundQuery) SuccessOrFail() bool { + return r.Code == "000000" +} diff --git a/lklsdk/unifiedReturn/unifiedReturn.go b/lklsdk/unifiedReturn/unifiedReturn.go new file mode 100644 index 0000000..566511b --- /dev/null +++ b/lklsdk/unifiedReturn/unifiedReturn.go @@ -0,0 +1,43 @@ +package unifiedreturn + +import ( + "context" + + "github.com/black1552/lkl_sdk/lklsdk/common" + "github.com/black1552/lkl_sdk/lklsdk/unifiedreturn/mergerefund" + "github.com/black1552/lkl_sdk/lklsdk/unifiedreturn/refund" + "github.com/black1552/lkl_sdk/lklsdk/unifiedreturn/refundquery" +) + +type Server[T any] struct { + Client *common.Client[T] + MergeRefound *mergerefund.MergeRefund[T] + Refound *refund.Refund[T] + RefoundQuery *refundquery.RefundQuery[T] +} + +// NewServer 创建拉卡拉统一退货服务实例 +func NewServer[T any](ctx context.Context, cfgJson string) *Server[T] { + client := common.NewClient[T](ctx, cfgJson) + return &Server[T]{ + Client: client, + MergeRefound: mergerefund.NewMergeRefund[T](client), + Refound: refund.NewRefund[T](client), + RefoundQuery: refundquery.NewRefundQuery[T](client), + } +} + +// MergeRefund 合单退货 +func (u *Server[T]) MergeRefund(req *mergerefund.RequestDataMergeRefund) (*T, error) { + return u.MergeRefound.MergeRefund(req) +} + +// Refund 退货 +func (u *Server[T]) Refund(req *refund.RequestDataRefund) (*T, error) { + return u.Refound.Refund(req) +} + +// RefundQuery 退货查询 +func (u *Server[T]) RefundQuery(req *refundquery.RequestDataRefundQuery) (*T, error) { + return u.RefoundQuery.RefundQuery(req) +}