- update wechatpayapiv2

master
李光春 1 year ago
parent af820fe08c
commit 873be7b05c

@ -1,5 +1,5 @@
package go_library
func Version() string {
return "1.0.118"
return "1.0.119"
}

@ -33,31 +33,32 @@ type TransfersQueryResult struct {
Result TransfersQueryResponse // 结果
Body []byte // 内容
Http gorequest.Response // 请求
Err error // 错误
}
func newTransfersQueryResult(result TransfersQueryResponse, body []byte, http gorequest.Response, err error) *TransfersQueryResult {
return &TransfersQueryResult{Result: result, Body: body, Http: http, Err: err}
func newTransfersQueryResult(result TransfersQueryResponse, body []byte, http gorequest.Response) *TransfersQueryResult {
return &TransfersQueryResult{Result: result, Body: body, Http: http}
}
// TransfersQuery
// 付款到零钱 - 查询付款
// 需要证书
// https://pay.weixin.qq.com/wiki/doc/api/tools/mch_pay.php?chapter=14_3
func (c *Client) TransfersQuery(ctx context.Context, partnerTradeNo string) *TransfersQueryResult {
func (c *Client) TransfersQuery(ctx context.Context, notMustParams ...gorequest.Params) (*TransfersQueryResult, error) {
cert, err := c.P12ToPem()
// 参数
params := NewParams()
params := gorequest.NewParamsWith(notMustParams...)
params.Set("appid", c.GetAppId())
params.Set("mch_id", c.GetMchId())
params.Set("nonce_str", gorandom.Alphanumeric(32))
params.Set("partner_trade_no", partnerTradeNo)
// 签名
params.Set("sign", c.getMd5Sign(params))
// 请求
request, err := c.request(ctx, apiUrl+"/mmpaymkttransfers/gettransferinfo", params, true, cert)
if err != nil {
return newTransfersQueryResult(TransfersQueryResponse{}, request.ResponseBody, request), err
}
// 定义
var response TransfersQueryResponse
err = xml.Unmarshal(request.ResponseBody, &response)
return newTransfersQueryResult(response, request.ResponseBody, request, err)
return newTransfersQueryResult(response, request.ResponseBody, request), err
}

@ -28,35 +28,32 @@ type TransfersResult struct {
Result TransfersResponse // 结果
Body []byte // 内容
Http gorequest.Response // 请求
Err error // 错误
}
func newTransfersResult(result TransfersResponse, body []byte, http gorequest.Response, err error) *TransfersResult {
return &TransfersResult{Result: result, Body: body, Http: http, Err: err}
func newTransfersResult(result TransfersResponse, body []byte, http gorequest.Response) *TransfersResult {
return &TransfersResult{Result: result, Body: body, Http: http}
}
// Transfers
// 付款到零钱 - 付款
// 需要证书
// https://pay.weixin.qq.com/wiki/doc/api/tools/mch_pay.php?chapter=14_2
func (c *Client) Transfers(ctx context.Context, partnerTradeNo, openid string, amount int64, desc string) *TransfersResult {
func (c *Client) Transfers(ctx context.Context, notMustParams ...gorequest.Params) (*TransfersResult, error) {
cert, err := c.P12ToPem()
// 参数
params := NewParams()
params := gorequest.NewParamsWith(notMustParams...)
params.Set("mch_appid", c.GetAppId())
params.Set("mchid", c.GetMchId())
params.Set("nonce_str", gorandom.Alphanumeric(32))
params.Set("partner_trade_no", partnerTradeNo)
params.Set("openid", openid)
params.Set("check_name", "NO_CHECK")
params.Set("amount", amount)
params.Set("desc", desc)
// 签名
params.Set("sign", c.getMd5Sign(params))
// 请求
request, err := c.request(ctx, apiUrl+"/mmpaymkttransfers/promotion/transfers", params, true, cert)
if err != nil {
return newTransfersResult(TransfersResponse{}, request.ResponseBody, request), err
}
// 定义
var response TransfersResponse
err = xml.Unmarshal(request.ResponseBody, &response)
return newTransfersResult(response, request.ResponseBody, request, err)
return newTransfersResult(response, request.ResponseBody, request), err
}

@ -1,72 +0,0 @@
package wechatpayapiv2
import (
"bytes"
"encoding/xml"
"fmt"
"io"
)
// Params 请求参数
type Params map[string]interface{}
func NewParams() Params {
p := make(Params)
return p
}
func (c *Client) NewParamsWith(params ...Params) Params {
p := make(Params)
for _, v := range params {
p.SetParams(v)
}
return p
}
func (p Params) Set(key string, value interface{}) {
p[key] = value
}
func (p Params) SetParams(params Params) {
for key, value := range params {
p[key] = value
}
}
func (p Params) MarshalXML() (reader io.Reader, err error) {
buffer := bytes.NewBuffer(make([]byte, 0))
if _, err = io.WriteString(buffer, "<xml>"); err != nil {
return
}
for k, v := range p {
switch {
case k == "detail":
if _, err = io.WriteString(buffer, "<detail><![CDATA["); err != nil {
return
}
if _, err = io.WriteString(buffer, fmt.Sprintf("%v", v)); err != nil {
return
}
if _, err = io.WriteString(buffer, "]]></detail>"); err != nil {
return
}
default:
if _, err = io.WriteString(buffer, "<"+k+">"); err != nil {
return
}
if err = xml.EscapeText(buffer, []byte(fmt.Sprintf("%v", v))); err != nil {
return
}
if _, err = io.WriteString(buffer, "</"+k+">"); err != nil {
return
}
}
}
if _, err = io.WriteString(buffer, "</xml>"); err != nil {
return
}
return buffer, nil
}

@ -38,7 +38,7 @@ func newPayCloseOrderResult(result PayCloseOrderResponse, body []byte, http gore
// https://pay.weixin.qq.com/wiki/doc/api/wxa/wxa_api.php?chapter=9_3
func (c *Client) PayCloseOrder(ctx context.Context, outTradeNo string) *PayCloseOrderResult {
// 参数
params := NewParams()
params := gorequest.NewParams()
params.Set("appid", c.GetAppId()) // 小程序ID
params.Set("mch_id", c.GetMchId()) // 商户号
params.Set("out_trade_no", outTradeNo) // 商户订单号

Loading…
Cancel
Save