关闭二级商户充值

1package com.java.demo;
2
3import com.java.utils.WXPayUtility; // 引用微信支付工具库，参考：https://pay.weixin.qq.com/doc/v3/partner/4014985777
4
5import com.google.gson.annotations.SerializedName;
6import com.google.gson.annotations.Expose;
7import okhttp3.MediaType;
8import okhttp3.OkHttpClient;
9import okhttp3.Request;
10import okhttp3.RequestBody;
11import okhttp3.Response;
12
13import java.io.IOException;
14import java.io.UncheckedIOException;
15import java.security.PrivateKey;
16import java.security.PublicKey;
17import java.util.ArrayList;
18import java.util.HashMap;
19import java.util.List;
20import java.util.Map;
21
22/**
23 * 关闭二级商户充值
24 */
25public class PlatSolutionClose {
26  private static String HOST = "https://api.mch.weixin.qq.com";
27  private static String METHOD = "POST";
28  private static String PATH = "/v3/platsolution/ecommerce/recharges/out-recharge-no/{out_recharge_no}/close";
29
30  public static void main(String[] args) {
31    // TODO: 请准备商户开发必要参数，参考：https://pay.weixin.qq.com/doc/v3/partner/4013080340
32    PlatSolutionClose client = new PlatSolutionClose(
33      "19xxxxxxxx",                    // 商户号，是由微信支付系统生成并分配给每个商户的唯一标识符，商户号获取方式参考 https://pay.weixin.qq.com/doc/v3/partner/4013080340
34      "1DDE55AD98Exxxxxxxxxx",         // 商户API证书序列号，如何获取请参考 https://pay.weixin.qq.com/doc/v3/partner/4013058924
35      "/path/to/apiclient_key.pem",    // 商户API证书私钥文件路径，本地文件路径
36      "PUB_KEY_ID_xxxxxxxxxxxxx",      // 微信支付公钥ID，如何获取请参考 https://pay.weixin.qq.com/doc/v3/partner/4013038589
37      "/path/to/wxp_pub.pem"           // 微信支付公钥文件路径，本地文件路径
38    );
39
40    PlatSolutionCloseRequest request = new PlatSolutionCloseRequest();
41    request.outRechargeNo = "cz2020042013";
42    request.subMchid = "1900102208";
43    try {
44      MchDeposit response = client.run(request);
45
46      // TODO: 请求成功，继续业务逻辑
47      System.out.println(response);
48    } catch (WXPayUtility.ApiException e) {
49      // TODO: 请求失败，根据状态码执行不同的逻辑
50      e.printStackTrace();
51    }
52  }
53
54  public MchDeposit run(PlatSolutionCloseRequest request) {
55    String uri = PATH;
56    uri = uri.replace("{out_recharge_no}", WXPayUtility.urlEncode(request.outRechargeNo));
57    Map<String, Object> args = new HashMap<>();
58    args.put("sub_mchid", request.subMchid);
59    uri = uri + "?" + WXPayUtility.urlEncode(args);
60
61    Request.Builder reqBuilder = new Request.Builder().url(HOST + uri);
62    reqBuilder.addHeader("Accept", "application/json");
63    reqBuilder.addHeader("Wechatpay-Serial", wechatPayPublicKeyId);
64    reqBuilder.addHeader("Authorization", WXPayUtility.buildAuthorization(mchid, certificateSerialNo, privateKey, METHOD, uri, null));
65    reqBuilder.addHeader("Content-Type", "application/json");
66    RequestBody emptyBody = RequestBody.create(null, "");
67    reqBuilder.method(METHOD, emptyBody);
68    Request httpRequest = reqBuilder.build();
69
70    // 发送HTTP请求
71    OkHttpClient client = new OkHttpClient.Builder().build();
72    try (Response httpResponse = client.newCall(httpRequest).execute()) {
73      String respBody = WXPayUtility.extractBody(httpResponse);
74      if (httpResponse.code() >= 200 && httpResponse.code() < 300) {
75        // 2XX 成功，验证应答签名
76        WXPayUtility.validateResponse(this.wechatPayPublicKeyId, this.wechatPayPublicKey,
77            httpResponse.headers(), respBody);
78
79        // 从HTTP应答报文构建返回数据
80        return WXPayUtility.fromJson(respBody, MchDeposit.class);
81      } else {
82        throw new WXPayUtility.ApiException(httpResponse.code(), respBody, httpResponse.headers());
83      }
84    } catch (IOException e) {
85      throw new UncheckedIOException("Sending request to " + uri + " failed.", e);
86    }
87  }
88
89  private final String mchid;
90  private final String certificateSerialNo;
91  private final PrivateKey privateKey;
92  private final String wechatPayPublicKeyId;
93  private final PublicKey wechatPayPublicKey;
94
95  public PlatSolutionClose(String mchid, String certificateSerialNo, String privateKeyFilePath, String wechatPayPublicKeyId, String wechatPayPublicKeyFilePath) {
96    this.mchid = mchid;
97    this.certificateSerialNo = certificateSerialNo;
98    this.privateKey = WXPayUtility.loadPrivateKeyFromPath(privateKeyFilePath);
99    this.wechatPayPublicKeyId = wechatPayPublicKeyId;
100    this.wechatPayPublicKey = WXPayUtility.loadPublicKeyFromPath(wechatPayPublicKeyFilePath);
101  }
102
103  public static class PlatSolutionCloseRequest {
104    @SerializedName("sub_mchid")
105    @Expose(serialize = false)
106    public String subMchid;
107  
108    @SerializedName("out_recharge_no")
109    @Expose(serialize = false)
110    public String outRechargeNo;
111  }
112  
113  public static class MchDeposit {
114    @SerializedName("sp_mchid")
115    public String spMchid;
116  
117    @SerializedName("sub_mchid")
118    public String subMchid;
119  
120    @SerializedName("recharge_id")
121    public String rechargeId;
122  
123    @SerializedName("out_recharge_no")
124    public String outRechargeNo;
125  
126    @SerializedName("recharge_channel")
127    public RechargeChannel rechargeChannel;
128  
129    @SerializedName("account_type")
130    public AccountType accountType;
131  
132    @SerializedName("recharge_state")
133    public RechargeState rechargeState;
134  
135    @SerializedName("recharge_scene")
136    public RechargeScene rechargeScene;
137  
138    @SerializedName("recharge_state_desc")
139    public String rechargeStateDesc;
140  
141    @SerializedName("recharge_amount")
142    public RechargeAmount rechargeAmount;
143  
144    @SerializedName("bank_transfer_info")
145    public BankTransferInfo bankTransferInfo;
146  
147    @SerializedName("qr_recharge_info")
148    public QrRechargeInfo qrRechargeInfo;
149  
150    @SerializedName("online_bank_recharge_info")
151    public OnlineBankRechargeInfo onlineBankRechargeInfo;
152  
153    @SerializedName("accept_time")
154    public String acceptTime;
155  
156    @SerializedName("success_time")
157    public String successTime;
158  
159    @SerializedName("close_time")
160    public String closeTime;
161  
162    @SerializedName("available_recharge_channels")
163    public List<RechargeChannel> availableRechargeChannels;
164  }
165  
166  public enum RechargeChannel {
167    @SerializedName("BANK_TRANSFER")
168    BANK_TRANSFER,
169    @SerializedName("QR_RECHARGE")
170    QR_RECHARGE,
171    @SerializedName("ONLINE_BANK")
172    ONLINE_BANK
173  }
174  
175  public enum AccountType {
176    @SerializedName("DEPOSIT")
177    DEPOSIT,
178    @SerializedName("OPERATION")
179    OPERATION
180  }
181  
182  public enum RechargeState {
183    @SerializedName("SUCCESS")
184    SUCCESS,
185    @SerializedName("RECHARGING")
186    RECHARGING,
187    @SerializedName("CLOSED")
188    CLOSED
189  }
190  
191  public enum RechargeScene {
192    @SerializedName("ECOMMERCE_DEPOSIT")
193    ECOMMERCE_DEPOSIT,
194    @SerializedName("ECOMMERCE_PAYMENT")
195    ECOMMERCE_PAYMENT
196  }
197  
198  public static class RechargeAmount {
199    @SerializedName("amount")
200    public Long amount;
201  
202    @SerializedName("currency")
203    public String currency;
204  }
205  
206  public static class BankTransferInfo {
207    @SerializedName("bill_no")
208    public String billNo;
209  
210    @SerializedName("memo")
211    public String memo;
212  
213    @SerializedName("return_time")
214    public String returnTime;
215  
216    @SerializedName("return_reason")
217    public String returnReason;
218  
219    @SerializedName("bank_name")
220    public String bankName;
221  
222    @SerializedName("bank_card_tail")
223    public String bankCardTail;
224  
225    @SerializedName("bank_account_name")
226    public String bankAccountName;
227  }
228  
229  public static class QrRechargeInfo {
230    @SerializedName("openid")
231    public String openid;
232  
233    @SerializedName("employee_type")
234    public EmployeeType employeeType;
235  }
236  
237  public static class OnlineBankRechargeInfo {
238    @SerializedName("bill_no")
239    public String billNo;
240  
241    @SerializedName("return_time")
242    public String returnTime;
243  
244    @SerializedName("return_reason")
245    public String returnReason;
246  
247    @SerializedName("bank_name")
248    public String bankName;
249  
250    @SerializedName("online_bank_type")
251    public OnlineBankType onlineBankType;
252  
253    @SerializedName("bank_card_tail")
254    public String bankCardTail;
255  
256    @SerializedName("bank_account_name")
257    public String bankAccountName;
258  }
259  
260  public enum EmployeeType {
261    @SerializedName("ADMIN")
262    ADMIN,
263    @SerializedName("STAFF")
264    STAFF,
265    @SerializedName("LEGAL_PERSON")
266    LEGAL_PERSON
267  }
268  
269  public enum OnlineBankType {
270    @SerializedName("ONLINE_BANK_TYPE_CORPORATE")
271    ONLINE_BANK_TYPE_CORPORATE,
272    @SerializedName("ONLINE_BANK_TYPE_PERSONAL")
273    ONLINE_BANK_TYPE_PERSONAL
274  }
275  
276}
277

1package main
2
3import (
4	"demo/wxpay_utility" // 引用微信支付工具库，参考 https://pay.weixin.qq.com/doc/v3/partner/4015119446
5	"encoding/json"
6	"fmt"
7	"net/http"
8	"net/url"
9	"strings"
10	"time"
11)
12
13func main() {
14	// TODO: 请准备商户开发必要参数，参考：https://pay.weixin.qq.com/doc/v3/partner/4013080340
15	config, err := wxpay_utility.CreateMchConfig(
16		"19xxxxxxxx",                 // 商户号，是由微信支付系统生成并分配给每个商户的唯一标识符，商户号获取方式参考 https://pay.weixin.qq.com/doc/v3/partner/4013080340
17		"1DDE55AD98Exxxxxxxxxx",      // 商户API证书序列号，如何获取请参考 https://pay.weixin.qq.com/doc/v3/partner/4013058924
18		"/path/to/apiclient_key.pem", // 商户API证书私钥文件路径，本地文件路径
19		"PUB_KEY_ID_xxxxxxxxxxxxx",   // 微信支付公钥ID，如何获取请参考 https://pay.weixin.qq.com/doc/v3/partner/4013038589
20		"/path/to/wxp_pub.pem",       // 微信支付公钥文件路径，本地文件路径
21	)
22	if err != nil {
23		fmt.Println(err)
24		return
25	}
26
27	request := &PlatSolutionCloseRequest{
28		SubMchid:      wxpay_utility.String("1900102208"),
29		OutRechargeNo: wxpay_utility.String("cz2020042013"),
30	}
31
32	response, err := PlatSolutionClose(config, request)
33	if err != nil {
34		fmt.Printf("请求失败: %+v\n", err)
35		// TODO: 请求失败，根据状态码执行不同的处理
36		return
37	}
38
39	// TODO: 请求成功，继续业务逻辑
40	fmt.Printf("请求成功: %+v\n", response)
41}
42
43func PlatSolutionClose(config *wxpay_utility.MchConfig, request *PlatSolutionCloseRequest) (response *MchDeposit, err error) {
44	const (
45		host   = "https://api.mch.weixin.qq.com"
46		method = "POST"
47		path   = "/v3/platsolution/ecommerce/recharges/out-recharge-no/{out_recharge_no}/close"
48	)
49
50	reqUrl, err := url.Parse(fmt.Sprintf("%s%s", host, path))
51	if err != nil {
52		return nil, err
53	}
54	reqUrl.Path = strings.Replace(reqUrl.Path, "{out_recharge_no}", url.PathEscape(*request.OutRechargeNo), -1)
55	query := reqUrl.Query()
56	query.Add("sub_mchid", *request.SubMchid)
57	reqUrl.RawQuery = query.Encode()
58	httpRequest, err := http.NewRequest(method, reqUrl.String(), nil)
59	if err != nil {
60		return nil, err
61	}
62	httpRequest.Header.Set("Accept", "application/json")
63	httpRequest.Header.Set("Wechatpay-Serial", config.WechatPayPublicKeyId())
64	httpRequest.Header.Set("Content-Type", "application/json")
65	authorization, err := wxpay_utility.BuildAuthorization(config.MchId(), config.CertificateSerialNo(), config.PrivateKey(), method, reqUrl.RequestURI(), nil)
66	if err != nil {
67		return nil, err
68	}
69	httpRequest.Header.Set("Authorization", authorization)
70
71	client := &http.Client{}
72	httpResponse, err := client.Do(httpRequest)
73	if err != nil {
74		return nil, err
75	}
76
77	respBody, err := wxpay_utility.ExtractResponseBody(httpResponse)
78	if err != nil {
79		return nil, err
80	}
81
82	if httpResponse.StatusCode >= 200 && httpResponse.StatusCode < 300 {
83		// 2XX 成功，验证应答签名
84		err = wxpay_utility.ValidateResponse(
85			config.WechatPayPublicKeyId(),
86			config.WechatPayPublicKey(),
87			&httpResponse.Header,
88			respBody,
89		)
90		if err != nil {
91			return nil, err
92		}
93
94		if err := json.Unmarshal(respBody, response); err != nil {
95			return nil, err
96		}
97
98		return response, nil
99	} else {
100		return nil, wxpay_utility.NewApiException(
101			httpResponse.StatusCode,
102			httpResponse.Header,
103			respBody,
104		)
105	}
106}
107
108type PlatSolutionCloseRequest struct {
109	SubMchid      *string `json:"sub_mchid,omitempty"`
110	OutRechargeNo *string `json:"out_recharge_no,omitempty"`
111}
112
113func (o *PlatSolutionCloseRequest) MarshalJSON() ([]byte, error) {
114	type Alias PlatSolutionCloseRequest
115	a := &struct {
116		SubMchid      *string `json:"sub_mchid,omitempty"`
117		OutRechargeNo *string `json:"out_recharge_no,omitempty"`
118		*Alias
119	}{
120		// 序列化时移除非 Body 字段
121		SubMchid:      nil,
122		OutRechargeNo: nil,
123		Alias:         (*Alias)(o),
124	}
125	return json.Marshal(a)
126}
127
128type MchDeposit struct {
129	SpMchid                   *string                 `json:"sp_mchid,omitempty"`
130	SubMchid                  *string                 `json:"sub_mchid,omitempty"`
131	RechargeId                *string                 `json:"recharge_id,omitempty"`
132	OutRechargeNo             *string                 `json:"out_recharge_no,omitempty"`
133	RechargeChannel           *RechargeChannel        `json:"recharge_channel,omitempty"`
134	AccountType               *AccountType            `json:"account_type,omitempty"`
135	RechargeState             *RechargeState          `json:"recharge_state,omitempty"`
136	RechargeScene             *RechargeScene          `json:"recharge_scene,omitempty"`
137	RechargeStateDesc         *string                 `json:"recharge_state_desc,omitempty"`
138	RechargeAmount            *RechargeAmount         `json:"recharge_amount,omitempty"`
139	BankTransferInfo          *BankTransferInfo       `json:"bank_transfer_info,omitempty"`
140	QrRechargeInfo            *QrRechargeInfo         `json:"qr_recharge_info,omitempty"`
141	OnlineBankRechargeInfo    *OnlineBankRechargeInfo `json:"online_bank_recharge_info,omitempty"`
142	AcceptTime                *time.Time              `json:"accept_time,omitempty"`
143	SuccessTime               *time.Time              `json:"success_time,omitempty"`
144	CloseTime                 *time.Time              `json:"close_time,omitempty"`
145	AvailableRechargeChannels []RechargeChannel       `json:"available_recharge_channels,omitempty"`
146}
147
148type RechargeChannel string
149
150func (e RechargeChannel) Ptr() *RechargeChannel {
151	return &e
152}
153
154const (
155	RECHARGECHANNEL_BANK_TRANSFER RechargeChannel = "BANK_TRANSFER"
156	RECHARGECHANNEL_QR_RECHARGE   RechargeChannel = "QR_RECHARGE"
157	RECHARGECHANNEL_ONLINE_BANK   RechargeChannel = "ONLINE_BANK"
158)
159
160type AccountType string
161
162func (e AccountType) Ptr() *AccountType {
163	return &e
164}
165
166const (
167	ACCOUNTTYPE_DEPOSIT   AccountType = "DEPOSIT"
168	ACCOUNTTYPE_OPERATION AccountType = "OPERATION"
169)
170
171type RechargeState string
172
173func (e RechargeState) Ptr() *RechargeState {
174	return &e
175}
176
177const (
178	RECHARGESTATE_SUCCESS    RechargeState = "SUCCESS"
179	RECHARGESTATE_RECHARGING RechargeState = "RECHARGING"
180	RECHARGESTATE_CLOSED     RechargeState = "CLOSED"
181)
182
183type RechargeScene string
184
185func (e RechargeScene) Ptr() *RechargeScene {
186	return &e
187}
188
189const (
190	RECHARGESCENE_ECOMMERCE_DEPOSIT RechargeScene = "ECOMMERCE_DEPOSIT"
191	RECHARGESCENE_ECOMMERCE_PAYMENT RechargeScene = "ECOMMERCE_PAYMENT"
192)
193
194type RechargeAmount struct {
195	Amount   *int64  `json:"amount,omitempty"`
196	Currency *string `json:"currency,omitempty"`
197}
198
199type BankTransferInfo struct {
200	BillNo          *string    `json:"bill_no,omitempty"`
201	Memo            *string    `json:"memo,omitempty"`
202	ReturnTime      *time.Time `json:"return_time,omitempty"`
203	ReturnReason    *string    `json:"return_reason,omitempty"`
204	BankName        *string    `json:"bank_name,omitempty"`
205	BankCardTail    *string    `json:"bank_card_tail,omitempty"`
206	BankAccountName *string    `json:"bank_account_name,omitempty"`
207}
208
209type QrRechargeInfo struct {
210	Openid       *string       `json:"openid,omitempty"`
211	EmployeeType *EmployeeType `json:"employee_type,omitempty"`
212}
213
214type OnlineBankRechargeInfo struct {
215	BillNo          *string         `json:"bill_no,omitempty"`
216	ReturnTime      *time.Time      `json:"return_time,omitempty"`
217	ReturnReason    *string         `json:"return_reason,omitempty"`
218	BankName        *string         `json:"bank_name,omitempty"`
219	OnlineBankType  *OnlineBankType `json:"online_bank_type,omitempty"`
220	BankCardTail    *string         `json:"bank_card_tail,omitempty"`
221	BankAccountName *string         `json:"bank_account_name,omitempty"`
222}
223
224type EmployeeType string
225
226func (e EmployeeType) Ptr() *EmployeeType {
227	return &e
228}
229
230const (
231	EMPLOYEETYPE_ADMIN        EmployeeType = "ADMIN"
232	EMPLOYEETYPE_STAFF        EmployeeType = "STAFF"
233	EMPLOYEETYPE_LEGAL_PERSON EmployeeType = "LEGAL_PERSON"
234)
235
236type OnlineBankType string
237
238func (e OnlineBankType) Ptr() *OnlineBankType {
239	return &e
240}
241
242const (
243	ONLINEBANKTYPE_ONLINE_BANK_TYPE_CORPORATE OnlineBankType = "ONLINE_BANK_TYPE_CORPORATE"
244	ONLINEBANKTYPE_ONLINE_BANK_TYPE_PERSONAL  OnlineBankType = "ONLINE_BANK_TYPE_PERSONAL"
245)
246

1curl -X POST \
2  https://api.mch.weixin.qq.com/v3/platsolution/ecommerce/recharges/out-recharge-no/cz2020042013/close?sub_mchid=1900102208 \
3  -H "Authorization: WECHATPAY2-SHA256-RSA2048 mchid=\"1900000001\",..." \
4  -H "Accept: application/json" 
5