-
Notifications
You must be signed in to change notification settings - Fork 149
/
api_transfer_batch_example_test.go
166 lines (147 loc) · 6.66 KB
/
api_transfer_batch_example_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
// Copyright 2021 Tencent Inc. All rights reserved.
//
// 商家转账对外API
//
// * 场景及业务流程： 商户可通过该产品实现同时向多个用户微信零钱进行转账的操作，可用于发放奖金补贴、佣金货款结算、员工报销等场景。 [https://pay.weixin.qq.com/index.php/public/product/detail?pid=108&productType=0](https://pay.weixin.qq.com/index.php/public/product/detail?pid=108&productType=0) * 接入步骤： * 商户在微信支付商户平台开通“批量转账到零钱”产品权限，并勾选“使用API方式发起转账”。 * 调用批量转账接口，对多个用户微信零钱发起转账。 * 调用查询批次接口，可获取到转账批次详情及当前状态。 * 调用查询明细接口，可获取到单条转账明细详情及当前状态。
//
// API version: 1.0.5
// Code generated by WechatPay APIv3 Generator based on [OpenAPI Generator](https://openapi-generator.tech); DO NOT EDIT.
package transferbatch_test
import (
"context"
"log"
"github.com/wechatpay-apiv3/wechatpay-go/core"
"github.com/wechatpay-apiv3/wechatpay-go/core/option"
"github.com/wechatpay-apiv3/wechatpay-go/services/transferbatch"
"github.com/wechatpay-apiv3/wechatpay-go/utils"
)
func ExampleTransferBatchApiService_GetTransferBatchByNo() {
var (
mchID string = "190000****" // 商户号
mchCertificateSerialNumber string = "3775************************************" // 商户证书序列号
mchAPIv3Key string = "2ab9****************************" // 商户APIv3密钥
)
// 使用 utils 提供的函数从本地文件中加载商户私钥，商户私钥会用来生成请求的签名
mchPrivateKey, err := utils.LoadPrivateKeyWithPath("/path/to/merchant/apiclient_key.pem")
if err != nil {
log.Printf("load merchant private key error:%s", err)
return
}
ctx := context.Background()
// 使用商户私钥等初始化 client，并使它具有自动定时获取微信支付平台证书的能力
opts := []core.ClientOption{
option.WithWechatPayAutoAuthCipher(mchID, mchCertificateSerialNumber, mchPrivateKey, mchAPIv3Key),
}
client, err := core.NewClient(ctx, opts...)
if err != nil {
log.Printf("new wechat pay client err:%s", err)
return
}
svc := transferbatch.TransferBatchApiService{Client: client}
resp, result, err := svc.GetTransferBatchByNo(ctx,
transferbatch.GetTransferBatchByNoRequest{
BatchId: core.String("1030000071100999991182020050700019480001"),
NeedQueryDetail: core.Bool(true),
Offset: core.Int64(0),
Limit: core.Int64(20),
DetailStatus: core.String("FAIL"),
},
)
if err != nil {
// 处理错误
log.Printf("call GetTransferBatchByNo err:%s", err)
} else {
// 处理返回结果
log.Printf("status=%d resp=%s", result.Response.StatusCode, resp)
}
}
func ExampleTransferBatchApiService_GetTransferBatchByOutNo() {
var (
mchID string = "190000****" // 商户号
mchCertificateSerialNumber string = "3775************************************" // 商户证书序列号
mchAPIv3Key string = "2ab9****************************" // 商户APIv3密钥
)
// 使用 utils 提供的函数从本地文件中加载商户私钥，商户私钥会用来生成请求的签名
mchPrivateKey, err := utils.LoadPrivateKeyWithPath("/path/to/merchant/apiclient_key.pem")
if err != nil {
log.Printf("load merchant private key error:%s", err)
return
}
ctx := context.Background()
// 使用商户私钥等初始化 client，并使它具有自动定时获取微信支付平台证书的能力
opts := []core.ClientOption{
option.WithWechatPayAutoAuthCipher(mchID, mchCertificateSerialNumber, mchPrivateKey, mchAPIv3Key),
}
client, err := core.NewClient(ctx, opts...)
if err != nil {
log.Printf("new wechat pay client err:%s", err)
return
}
svc := transferbatch.TransferBatchApiService{Client: client}
resp, result, err := svc.GetTransferBatchByOutNo(ctx,
transferbatch.GetTransferBatchByOutNoRequest{
OutBatchNo: core.String("plfk2020042013"),
NeedQueryDetail: core.Bool(true),
Offset: core.Int64(0),
Limit: core.Int64(20),
DetailStatus: core.String("FAIL"),
},
)
if err != nil {
// 处理错误
log.Printf("call GetTransferBatchByOutNo err:%s", err)
} else {
// 处理返回结果
log.Printf("status=%d resp=%s", result.Response.StatusCode, resp)
}
}
func ExampleTransferBatchApiService_InitiateBatchTransfer() {
var (
mchID string = "190000****" // 商户号
mchCertificateSerialNumber string = "3775************************************" // 商户证书序列号
mchAPIv3Key string = "2ab9****************************" // 商户APIv3密钥
)
// 使用 utils 提供的函数从本地文件中加载商户私钥，商户私钥会用来生成请求的签名
mchPrivateKey, err := utils.LoadPrivateKeyWithPath("/path/to/merchant/apiclient_key.pem")
if err != nil {
log.Printf("load merchant private key error:%s", err)
return
}
ctx := context.Background()
// 使用商户私钥等初始化 client，并使它具有自动定时获取微信支付平台证书的能力
opts := []core.ClientOption{
option.WithWechatPayAutoAuthCipher(mchID, mchCertificateSerialNumber, mchPrivateKey, mchAPIv3Key),
}
client, err := core.NewClient(ctx, opts...)
if err != nil {
log.Printf("new wechat pay client err:%s", err)
return
}
svc := transferbatch.TransferBatchApiService{Client: client}
resp, result, err := svc.InitiateBatchTransfer(ctx,
transferbatch.InitiateBatchTransferRequest{
Appid: core.String("wxf636efh567hg4356"),
OutBatchNo: core.String("plfk2020042013"),
BatchName: core.String("2019年1月深圳分部报销单"),
BatchRemark: core.String("2019年1月深圳分部报销单"),
TotalAmount: core.Int64(4000000),
TotalNum: core.Int64(200),
TransferDetailList: []transferbatch.TransferDetailInput{transferbatch.TransferDetailInput{
OutDetailNo: core.String("x23zy545Bd5436"),
TransferAmount: core.Int64(200000),
TransferRemark: core.String("2020年4月报销"),
Openid: core.String("o-MYE42l80oelYMDE34nYD456Xoy"),
UserName: core.String("757b340b45ebef5467rter35gf464344v3542sdf4t6re4tb4f54ty45t4yyry45"),
}},
TransferSceneId: core.String("1000"),
NotifyUrl: core.String("https://www.weixin.qq.com/wxpay/pay.php"),
},
)
if err != nil {
// 处理错误
log.Printf("call InitiateBatchTransfer err:%s", err)
} else {
// 处理返回结果
log.Printf("status=%d resp=%s", result.Response.StatusCode, resp)
}
}