JSAPI合单下单

1curl -X POST \
2  https://api.mch.weixin.qq.com/v3/combine-transactions/jsapi \
3  -H "Authorization: WECHATPAY2-SHA256-RSA2048 mchid=\"1900000001\",..." \
4  -H "Accept: application/json" \
5  -H "Content-Type: application/json" \
6  -d '{
7    "time_expire" : "2018-06-08T10:34:56+08:00",
8    "combine_appid" : "wxd678efh567hg6787",
9    "sub_orders" : [
10      {
11        "mchid" : "1230000109",
12        "sub_mchid" : "1900000109",
13        "sub_appid" : "wxd678efh567hg6999",
14        "out_trade_no" : "20150806125346",
15        "amount" : {
16          "total_amount" : 10,
17          "currency" : "CNY"
18        },
19        "attach" : "深圳分店",
20        "description" : "Image形象店-深圳腾大-QQ公仔",
21        "detail" : "买单费用",
22        "goods_tag" : "WXG",
23        "settle_info" : {
24          "profit_sharing" : false
25        }
26      }
27    ],
28    "combine_payer_info" : {
29      "openid" : "oUpF8uMuAJO_M2pxb1Q9zNjWeS6o",
30      "sub_openid" : "oUpF8uMuAJO_M2pxb1Q9zNjWeS6o"
31    },
32    "combine_out_trade_no" : "P20150806125346",
33    "notify_url" : "https://yourapp.com/notify",
34    "combine_mchid" : "1230000109",
35    "scene_info" : {
36      "device_id" : "POS1:1",
37      "payer_client_ip" : "127.0.0.1"
38    }
39  }'
40

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

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