Native合单下单

1curl -X POST \
2  https://api.mch.weixin.qq.com/v3/combine-transactions/native \
3  -H "Authorization: WECHATPAY2-SHA256-RSA2048 mchid=\"1900000001\",..." \
4  -H "Accept: application/json" \
5  -H "Content-Type: application/json" \
6  -d '{
7    "time_expire" : "2000-01-01T00:00:00+08:00",
8    "combine_appid" : "wxd678efh567hg6787",
9    "sub_orders" : [
10      {
11        "mchid" : "1230000109",
12        "attach" : "深圳分店",
13        "amount" : {
14          "total_amount" : 10,
15          "currency" : "CNY"
16        },
17        "out_trade_no" : "20150806125346",
18        "sub_mchid" : "1900000109",
19        "description" : "腾讯充值中心-QQ会员充值",
20        "settle_info" : {
21          "profit_sharing" : false
22        },
23        "sub_appid" : "wxd678efh567hg6999",
24        "goods_tag" : "WXG"
25      }
26    ],
27    "combine_out_trade_no" : "20150806125346",
28    "notify_url" : "https://yourapp.com/notify",
29    "combine_mchid" : "1900000109",
30    "scene_info" : {
31      "device_id" : "POS1:1",
32      "payer_client_ip" : "14.17.22.32"
33    }
34  }'
35

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 * 合单下单-NATIVE
24 */
25public class UnionNativePrepay {
26  private static String HOST = "https://api.mch.weixin.qq.com";
27  private static String METHOD = "POST";
28  private static String PATH = "/v3/combine-transactions/native";
29
30  public static void main(String[] args) {
31    // TODO: 请准备商户开发必要参数，参考：https://pay.weixin.qq.com/doc/v3/partner/4013080340
32    UnionNativePrepay client = new UnionNativePrepay(
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    UnionAPIv3NativePrepayRequest request = new UnionAPIv3NativePrepayRequest();
41    request.combineAppid = "wxd678efh567hg6787";
42    request.combineOutTradeNo = "20150806125346";
43    request.combineMchid = "1900000109";
44    request.sceneInfo = new UnionSceneInfo();
45    request.sceneInfo.deviceId = "POS1:1";
46    request.sceneInfo.payerClientIp = "14.17.22.32";
47    request.subOrders = new ArrayList<>();
48    {
49      UnionCommonSubOrder subOrdersItem0 = new UnionCommonSubOrder();
50      subOrdersItem0.mchid = "1230000109";
51      subOrdersItem0.subMchid = "1900000109";
52      subOrdersItem0.subAppid = "wxd678efh567hg6999";
53      subOrdersItem0.outTradeNo = "20150806125346";
54      subOrdersItem0.amount = new UnionAmountInfo();
55      subOrdersItem0.amount.totalAmount = 10L;
56      subOrdersItem0.amount.currency = "CNY";
57      subOrdersItem0.attach = "深圳分店";
58      subOrdersItem0.description = "腾讯充值中心-QQ会员充值";
59      subOrdersItem0.goodsTag = "WXG";
60      subOrdersItem0.settleInfo = new UnionSettleInfo();
61      subOrdersItem0.settleInfo.profitSharing = false;
62      request.subOrders.add(subOrdersItem0);
63    };
64    request.timeExpire = "2000-01-01T00:00:00+08:00";
65    request.notifyUrl = "https://yourapp.com/notify";
66    try {
67      UnionAPIv3NativePrepayResponse response = client.run(request);
68        // TODO: 请求成功，继续业务逻辑
69        System.out.println(response);
70    } catch (WXPayUtility.ApiException e) {
71        // TODO: 请求失败，根据状态码执行不同的逻辑
72        e.printStackTrace();
73    }
74  }
75
76  public UnionAPIv3NativePrepayResponse run(UnionAPIv3NativePrepayRequest request) {
77    String uri = PATH;
78    String reqBody = WXPayUtility.toJson(request);
79
80    Request.Builder reqBuilder = new Request.Builder().url(HOST + uri);
81    reqBuilder.addHeader("Accept", "application/json");
82    reqBuilder.addHeader("Wechatpay-Serial", wechatPayPublicKeyId);
83    reqBuilder.addHeader("Authorization", WXPayUtility.buildAuthorization(mchid, certificateSerialNo,privateKey, METHOD, uri, reqBody));
84    reqBuilder.addHeader("Content-Type", "application/json");
85    RequestBody requestBody = RequestBody.create(MediaType.parse("application/json; charset=utf-8"), reqBody);
86    reqBuilder.method(METHOD, requestBody);
87    Request httpRequest = reqBuilder.build();
88
89    // 发送HTTP请求
90    OkHttpClient client = new OkHttpClient.Builder().build();
91    try (Response httpResponse = client.newCall(httpRequest).execute()) {
92      String respBody = WXPayUtility.extractBody(httpResponse);
93      if (httpResponse.code() >= 200 && httpResponse.code() < 300) {
94        // 2XX 成功，验证应答签名
95        WXPayUtility.validateResponse(this.wechatPayPublicKeyId, this.wechatPayPublicKey,
96            httpResponse.headers(), respBody);
97
98        // 从HTTP应答报文构建返回数据
99        return WXPayUtility.fromJson(respBody, UnionAPIv3NativePrepayResponse.class);
100      } else {
101        throw new WXPayUtility.ApiException(httpResponse.code(), respBody, httpResponse.headers());
102      }
103    } catch (IOException e) {
104      throw new UncheckedIOException("Sending request to " + uri + " failed.", e);
105    }
106  }
107
108  private final String mchid;
109  private final String certificateSerialNo;
110  private final PrivateKey privateKey;
111  private final String wechatPayPublicKeyId;
112  private final PublicKey wechatPayPublicKey;
113
114  public UnionNativePrepay(String mchid, String certificateSerialNo, String privateKeyFilePath, String wechatPayPublicKeyId, String wechatPayPublicKeyFilePath) {
115    this.mchid = mchid;
116    this.certificateSerialNo = certificateSerialNo;
117    this.privateKey = WXPayUtility.loadPrivateKeyFromPath(privateKeyFilePath);
118    this.wechatPayPublicKeyId = wechatPayPublicKeyId;
119    this.wechatPayPublicKey = WXPayUtility.loadPublicKeyFromPath(wechatPayPublicKeyFilePath);
120  }
121
122  public static class UnionAPIv3NativePrepayRequest {
123    @SerializedName("combine_appid")
124    public String combineAppid;
125  
126    @SerializedName("combine_out_trade_no")
127    public String combineOutTradeNo;
128  
129    @SerializedName("combine_mchid")
130    public String combineMchid;
131  
132    @SerializedName("scene_info")
133    public UnionSceneInfo sceneInfo;
134  
135    @SerializedName("sub_orders")
136    public List<UnionCommonSubOrder> subOrders = new ArrayList<UnionCommonSubOrder>();
137  
138    @SerializedName("time_expire")
139    public String timeExpire;
140  
141    @SerializedName("notify_url")
142    public String notifyUrl;
143  }
144  
145  public static class UnionAPIv3NativePrepayResponse {
146    @SerializedName("code_url")
147    public String codeUrl;
148  }
149  
150  public static class UnionSceneInfo {
151    @SerializedName("device_id")
152    public String deviceId;
153  
154    @SerializedName("payer_client_ip")
155    public String payerClientIp;
156  }
157  
158  public static class UnionCommonSubOrder {
159    @SerializedName("mchid")
160    public String mchid;
161  
162    @SerializedName("sub_mchid")
163    public String subMchid;
164  
165    @SerializedName("sub_appid")
166    public String subAppid;
167  
168    @SerializedName("out_trade_no")
169    public String outTradeNo;
170  
171    @SerializedName("amount")
172    public UnionAmountInfo amount;
173  
174    @SerializedName("attach")
175    public String attach;
176  
177    @SerializedName("description")
178    public String description;
179  
180    @SerializedName("goods_tag")
181    public String goodsTag;
182  
183    @SerializedName("settle_info")
184    public UnionSettleInfo settleInfo;
185  }
186  
187  public static class UnionAmountInfo {
188    @SerializedName("total_amount")
189    public Long totalAmount;
190  
191    @SerializedName("currency")
192    public String currency;
193  }
194  
195  public static class UnionSettleInfo {
196    @SerializedName("profit_sharing")
197    public Boolean profitSharing;
198  }
199  
200}
201

1package main
2
3import (
4	"bytes"
5	"demo/wxpay_utility" // 引用微信支付工具库，参考 https://pay.weixin.qq.com/doc/v3/partner/4015119446
6	"encoding/json"
7	"fmt"
8	"net/http"
9	"net/url"
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 := &UnionApiv3NativePrepayRequest{
28		CombineAppid:      wxpay_utility.String("wxd678efh567hg6787"),
29		CombineOutTradeNo: wxpay_utility.String("20150806125346"),
30		CombineMchid:      wxpay_utility.String("1900000109"),
31		SceneInfo: &UnionSceneInfo{
32			DeviceId:      wxpay_utility.String("POS1:1"),
33			PayerClientIp: wxpay_utility.String("14.17.22.32"),
34		},
35		SubOrders: []UnionCommonSubOrder{
36			UnionCommonSubOrder{
37				Mchid:      wxpay_utility.String("1230000109"),
38				SubMchid:   wxpay_utility.String("1900000109"),
39				SubAppid:   wxpay_utility.String("wxd678efh567hg6999"),
40				OutTradeNo: wxpay_utility.String("20150806125346"),
41				Amount: &UnionAmountInfo{
42					TotalAmount: wxpay_utility.Int64(10),
43					Currency:    wxpay_utility.String("CNY"),
44				},
45				Attach:      wxpay_utility.String("深圳分店"),
46				Description: wxpay_utility.String("腾讯充值中心-QQ会员充值"),
47				GoodsTag:    wxpay_utility.String("WXG"),
48				SettleInfo: &UnionSettleInfo{
49					ProfitSharing: wxpay_utility.Bool(false),
50				},
51			},
52		},
53		TimeExpire: wxpay_utility.Time(time.Now()),
54		NotifyUrl:  wxpay_utility.String("https://yourapp.com/notify"),
55	}
56
57	response, err := UnionNativePrepay(config, request)
58	if err != nil {
59		fmt.Printf("请求失败: %+v\n", err)
60		// TODO: 请求失败，根据状态码执行不同的处理
61		return
62	}
63
64	// TODO: 请求成功，继续业务逻辑
65	fmt.Printf("请求成功: %+v\n", response)
66}
67
68func UnionNativePrepay(config *wxpay_utility.MchConfig, request *UnionApiv3NativePrepayRequest) (response *UnionApiv3NativePrepayResponse, err error) {
69	const (
70		host   = "https://api.mch.weixin.qq.com"
71		method = "POST"
72		path   = "/v3/combine-transactions/native"
73	)
74
75	reqUrl, err := url.Parse(fmt.Sprintf("%s%s", host, path))
76	if err != nil {
77		return nil, err
78	}
79	reqBody, err := json.Marshal(request)
80	if err != nil {
81		return nil, err
82	}
83	httpRequest, err := http.NewRequest(method, reqUrl.String(), bytes.NewReader(reqBody))
84	if err != nil {
85		return nil, err
86	}
87	httpRequest.Header.Set("Accept", "application/json")
88	httpRequest.Header.Set("Wechatpay-Serial", config.WechatPayPublicKeyId())
89	httpRequest.Header.Set("Content-Type", "application/json")
90	authorization, err := wxpay_utility.BuildAuthorization(config.MchId(), config.CertificateSerialNo(), config.PrivateKey(), method, reqUrl.RequestURI(), reqBody)
91	if err != nil {
92		return nil, err
93	}
94	httpRequest.Header.Set("Authorization", authorization)
95
96	client := &http.Client{}
97	httpResponse, err := client.Do(httpRequest)
98	if err != nil {
99		return nil, err
100	}
101	respBody, err := wxpay_utility.ExtractResponseBody(httpResponse)
102	if err != nil {
103		return nil, err
104	}
105	if httpResponse.StatusCode >= 200 && httpResponse.StatusCode < 300 {
106		// 2XX 成功，验证应答签名
107		err = wxpay_utility.ValidateResponse(
108			config.WechatPayPublicKeyId(),
109			config.WechatPayPublicKey(),
110			&httpResponse.Header,
111			respBody,
112		)
113		if err != nil {
114			return nil, err
115		}
116		response := &UnionApiv3NativePrepayResponse{}
117		if err := json.Unmarshal(respBody, response); err != nil {
118			return nil, err
119		}
120
121		return response, nil
122	} else {
123		return nil, wxpay_utility.NewApiException(
124			httpResponse.StatusCode,
125			httpResponse.Header,
126			respBody,
127		)
128	}
129}
130
131type UnionApiv3NativePrepayRequest struct {
132	CombineAppid      *string               `json:"combine_appid,omitempty"`
133	CombineOutTradeNo *string               `json:"combine_out_trade_no,omitempty"`
134	CombineMchid      *string               `json:"combine_mchid,omitempty"`
135	SceneInfo         *UnionSceneInfo       `json:"scene_info,omitempty"`
136	SubOrders         []UnionCommonSubOrder `json:"sub_orders,omitempty"`
137	TimeExpire        *time.Time            `json:"time_expire,omitempty"`
138	NotifyUrl         *string               `json:"notify_url,omitempty"`
139}
140
141type UnionApiv3NativePrepayResponse struct {
142	CodeUrl *string `json:"code_url,omitempty"`
143}
144
145type UnionSceneInfo struct {
146	DeviceId      *string `json:"device_id,omitempty"`
147	PayerClientIp *string `json:"payer_client_ip,omitempty"`
148}
149
150type UnionCommonSubOrder struct {
151	Mchid       *string          `json:"mchid,omitempty"`
152	SubMchid    *string          `json:"sub_mchid,omitempty"`
153	SubAppid    *string          `json:"sub_appid,omitempty"`
154	OutTradeNo  *string          `json:"out_trade_no,omitempty"`
155	Amount      *UnionAmountInfo `json:"amount,omitempty"`
156	Attach      *string          `json:"attach,omitempty"`
157	Description *string          `json:"description,omitempty"`
158	GoodsTag    *string          `json:"goods_tag,omitempty"`
159	SettleInfo  *UnionSettleInfo `json:"settle_info,omitempty"`
160}
161
162type UnionAmountInfo struct {
163	TotalAmount *int64  `json:"total_amount,omitempty"`
164	Currency    *string `json:"currency,omitempty"`
165}
166
167type UnionSettleInfo struct {
168	ProfitSharing *bool `json:"profit_sharing,omitempty"`
169}
170