商户订单号查询订单

1package com.java.demo;
2
3import com.google.gson.annotations.Expose;
4import com.google.gson.annotations.SerializedName;
5import com.java.utils.WXPayUtility; // 引用微信支付工具库 参考:https://pay.weixin.qq.com/doc/v3/partner/4014985777
6import java.io.IOException;
7import java.io.UncheckedIOException;
8import java.security.PrivateKey;
9import java.security.PublicKey;
10import java.util.ArrayList;
11import java.util.HashMap;
12import java.util.List;
13import java.util.Map;
14import okhttp3.MediaType;
15import okhttp3.OkHttpClient;
16import okhttp3.Request;
17import okhttp3.RequestBody;
18import okhttp3.Response;
19
20/**
21 * 微信支付商户订单号查询订单
22 */
23public class PartnerQueryByOutTradeNo {
24  private static String HOST = "https://api.mch.weixin.qq.com";
25  private static String METHOD = "GET";
26  private static String PATH = "/v3/pay/partner/transactions/out-trade-no/{out_trade_no}";
27
28  public static void main(String[] args) {
29    // TODO: 请准备商户开发必要参数，参考：https://pay.weixin.qq.com/doc/v3/partner/4013080340
30    PartnerQueryByOutTradeNo client = new PartnerQueryByOutTradeNo(
31        "填入 商户号",                  // 商户号，是由微信支付系统生成并分配给每个商户的唯一标识符，商户号获取方式参考https://pay.weixin.qq.com/doc/v3/partner/4013080340
32        "填入 商户API证书序列号",       // 商户API证书序列号，如何获取请参考https://pay.weixin.qq.com/doc/v3/partner/4013058924
33        "填入 商户API证书私钥文件路径", // 商户API证书私钥文件路径，本地文件路径
34        "填入 微信支付公钥ID",          // 微信支付公钥ID，如何获取请参考https://pay.weixin.qq.com/doc/v3/partner/4013038589
35        "填入 微信支付公钥文件路径"     // 微信支付公钥文件路径，本地文件路径
36    );
37
38    PartnerQueryByOutTradeNoRequest request = new PartnerQueryByOutTradeNoRequest();
39    request.outTradeNo = "1217752501201407033233368018";
40    request.spMchid = "1230000109";
41    request.subMchid = "1900000109";
42    try {
43      PartnerAPIv3PartnerQueryResponse response = client.run(request);
44
45      // TODO: 请求成功，继续业务逻辑
46      System.out.println(response);
47    } catch (WXPayUtility.ApiException e) {
48      // TODO: 请求失败，根据状态码执行不同的逻辑
49      e.printStackTrace();
50    }
51  }
52
53  public PartnerAPIv3PartnerQueryResponse run(PartnerQueryByOutTradeNoRequest request) {
54    String uri = PATH;
55    uri = uri.replace("{out_trade_no}", WXPayUtility.urlEncode(request.outTradeNo));
56    Map<String, Object> args = new HashMap<>();
57    args.put("sp_mchid", request.spMchid);
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.method(METHOD, null);
66    Request httpRequest = reqBuilder.build();
67
68    // 发送HTTP请求
69    OkHttpClient client = new OkHttpClient.Builder().build();
70    try (Response httpResponse = client.newCall(httpRequest).execute()) {
71      String respBody = WXPayUtility.extractBody(httpResponse);
72      if (httpResponse.code() >= 200 && httpResponse.code() < 300) {
73        // 2XX 成功，验证应答签名
74        WXPayUtility.validateResponse(this.wechatPayPublicKeyId, this.wechatPayPublicKey,
75                                      httpResponse.headers(), respBody);
76
77        // 从HTTP应答报文构建返回数据
78        return WXPayUtility.fromJson(respBody, PartnerAPIv3PartnerQueryResponse.class);
79      } else {
80        throw new WXPayUtility.ApiException(httpResponse.code(), respBody, httpResponse.headers());
81      }
82    } catch (IOException e) {
83      throw new UncheckedIOException("Sending request to " + uri + " failed.", e);
84    }
85  }
86
87  private final String mchid;
88  private final String certificateSerialNo;
89  private final PrivateKey privateKey;
90  private final String wechatPayPublicKeyId;
91  private final PublicKey wechatPayPublicKey;
92
93  public PartnerQueryByOutTradeNo(String mchid, String certificateSerialNo, String privateKeyFilePath, String wechatPayPublicKeyId, String wechatPayPublicKeyFilePath) {
94    this.mchid = mchid;
95    this.certificateSerialNo = certificateSerialNo;
96    this.privateKey = WXPayUtility.loadPrivateKeyFromPath(privateKeyFilePath);
97    this.wechatPayPublicKeyId = wechatPayPublicKeyId;
98    this.wechatPayPublicKey = WXPayUtility.loadPublicKeyFromPath(wechatPayPublicKeyFilePath);
99  }
100
101  public static class CommRespAmountInfo {
102    @SerializedName("total")
103    public Long total;
104
105    @SerializedName("payer_total")
106    public Long payerTotal;
107
108    @SerializedName("currency")
109    public String currency;
110
111    @SerializedName("payer_currency")
112    public String payerCurrency;
113  }
114
115  public static class CommRespSceneInfo {
116    @SerializedName("device_id")
117    public String deviceId;
118
119    @SerializedName("store_info")
120    public StoreInfo storeInfo;
121  }
122
123  public static class GoodsDetailInPromotion {
124    @SerializedName("goods_id")
125    public String goodsId;
126
127    @SerializedName("quantity")
128    public Integer quantity;
129
130    @SerializedName("unit_price")
131    public Long unitPrice;
132
133    @SerializedName("discount_amount")
134    public Long discountAmount;
135
136    @SerializedName("goods_remark")
137    public String goodsRemark;
138  }
139
140  public static class PartnerAPIv3PartnerQueryResponse {
141    @SerializedName("sp_appid")
142    public String spAppid;
143
144    @SerializedName("sp_mchid")
145    public String spMchid;
146
147    @SerializedName("sub_appid")
148    public String subAppid;
149
150    @SerializedName("sub_mchid")
151    public String subMchid;
152
153    @SerializedName("out_trade_no")
154    public String outTradeNo;
155
156    @SerializedName("transaction_id")
157    public String transactionId;
158
159    @SerializedName("trade_type")
160    public String tradeType;
161
162    @SerializedName("trade_state")
163    public String tradeState;
164
165    @SerializedName("trade_state_desc")
166    public String tradeStateDesc;
167
168    @SerializedName("bank_type")
169    public String bankType;
170
171    @SerializedName("attach")
172    public String attach;
173
174    @SerializedName("success_time")
175    public String successTime;
176
177    @SerializedName("payer")
178    public PartnerCommRespPayerInfo payer;
179
180    @SerializedName("amount")
181    public CommRespAmountInfo amount;
182
183    @SerializedName("scene_info")
184    public CommRespSceneInfo sceneInfo;
185
186    @SerializedName("promotion_detail")
187    public List<PromotionDetail> promotionDetail;
188  }
189
190  public static class PartnerQueryByOutTradeNoRequest {
191    @SerializedName("sp_mchid")
192    @Expose(serialize = false)
193    public String spMchid;
194
195    @SerializedName("sub_mchid")
196    @Expose(serialize = false)
197    public String subMchid;
198
199    @SerializedName("out_trade_no")
200    @Expose(serialize = false)
201    public String outTradeNo;
202  }
203
204  public static class StoreInfo {
205    @SerializedName("id")
206    public String id;
207
208    @SerializedName("out_id")
209    public String outId;
210  }
211
212  public static class PartnerCommRespPayerInfo {
213    @SerializedName("sp_openid")
214    public String spOpenid;
215
216    @SerializedName("sub_openid")
217    public String subOpenid;
218  }
219
220  public static class PromotionDetail {
221    @SerializedName("coupon_id")
222    public String couponId;
223
224    @SerializedName("name")
225    public String name;
226
227    @SerializedName("scope")
228    public String scope;
229
230    @SerializedName("type")
231    public String type;
232
233    @SerializedName("amount")
234    public Long amount;
235
236    @SerializedName("stock_id")
237    public String stockId;
238
239    @SerializedName("wechatpay_contribute")
240    public Long wechatpayContribute;
241
242    @SerializedName("merchant_contribute")
243    public Long merchantContribute;
244
245    @SerializedName("other_contribute")
246    public Long otherContribute;
247
248    @SerializedName("currency")
249    public String currency;
250
251    @SerializedName("goods_detail")
252    public List<GoodsDetailInPromotion> goodsDetail;
253  }
254}

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)
11
12func main() {
13	// TODO: 请准备商户开发必要参数，参考：https://pay.weixin.qq.com/doc/v3/partner/4013080340
14	config, err := wxpay_utility.CreateMchConfig(
15		"填入 商户号",           // 商户号，是由微信支付系统生成并分配给每个商户的唯一标识符，商户号获取方式参考https://pay.weixin.qq.com/doc/v3/partner/4013080340
16		"填入 商户API证书序列号",    // 商户API证书序列号，如何获取请参考https://pay.weixin.qq.com/doc/v3/partner/4013058924
17		"填入 商户API证书私钥文件路径", // 商户API证书私钥文件路径，本地文件路径
18		"填入 微信支付公钥ID",      // 微信支付公钥ID，如何获取请参考https://pay.weixin.qq.com/doc/v3/partner/4013038589
19		"填入 微信支付公钥文件路径",    // 微信支付公钥文件路径，本地文件路径
20	)
21	if err != nil {
22		fmt.Println(err)
23		return
24	}
25
26	request := &PartnerQueryByOutTradeNoRequest{
27		SpMchid:    wxpay_utility.String("1230000109"),
28		SubMchid:   wxpay_utility.String("1900000109"),
29		OutTradeNo: wxpay_utility.String("1217752501201407033233368018"),
30	}
31
32	response, err := PartnerQueryByOutTradeNo(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 PartnerQueryByOutTradeNo(config *wxpay_utility.MchConfig, request *PartnerQueryByOutTradeNoRequest) (response *PartnerApiv3PartnerQueryResponse, err error) {
44	const (
45		host   = "https://api.mch.weixin.qq.com"
46		method = "GET"
47		path   = "/v3/pay/partner/transactions/out-trade-no/{out_trade_no}"
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_trade_no}", url.PathEscape(*request.OutTradeNo), -1)
55	query := reqUrl.Query()
56	query.Add("sp_mchid", *request.SpMchid)
57	query.Add("sub_mchid", *request.SubMchid)
58	reqUrl.RawQuery = query.Encode()
59	httpRequest, err := http.NewRequest(method, reqUrl.String(), nil)
60	if err != nil {
61		return nil, err
62	}
63	httpRequest.Header.Set("Accept", "application/json")
64	httpRequest.Header.Set("Wechatpay-Serial", config.WechatPayPublicKeyId())
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.ApiException{
101			StatusCode: httpResponse.StatusCode,
102			Header:     httpResponse.Header,
103			Body:       respBody,
104		}
105	}
106}
107
108type CommRespAmountInfo struct {
109	Total         *int64  `json:"total,omitempty"`
110	PayerTotal    *int64  `json:"payer_total,omitempty"`
111	Currency      *string `json:"currency,omitempty"`
112	PayerCurrency *string `json:"payer_currency,omitempty"`
113}
114
115type CommRespSceneInfo struct {
116	DeviceId  *string    `json:"device_id,omitempty"`
117}
118
119type GoodsDetailInPromotion struct {
120	GoodsId        *string `json:"goods_id,omitempty"`
121	Quantity       *int64  `json:"quantity,omitempty"`
122	UnitPrice      *int64  `json:"unit_price,omitempty"`
123	DiscountAmount *int64  `json:"discount_amount,omitempty"`
124	GoodsRemark    *string `json:"goods_remark,omitempty"`
125}
126
127type PartnerQueryByOutTradeNoRequest struct {
128	SpMchid    *string `json:"sp_mchid,omitempty"`
129	SubMchid   *string `json:"sub_mchid,omitempty"`
130	OutTradeNo *string `json:"out_trade_no,omitempty"`
131}
132
133func (o *PartnerQueryByOutTradeNoRequest) MarshalJSON() ([]byte, error) {
134	type Alias PartnerQueryByOutTradeNoRequest
135	a := &struct {
136		SpMchid    *string `json:"sp_mchid,omitempty"`
137		SubMchid   *string `json:"sub_mchid,omitempty"`
138		OutTradeNo *string `json:"out_trade_no,omitempty"`
139		*Alias
140	}{
141		// 序列化时移除非 Body 字段
142		SpMchid:    nil,
143		SubMchid:   nil,
144		OutTradeNo: nil,
145		Alias:      (*Alias)(o),
146	}
147	return json.Marshal(a)
148}
149
150type PartnerApiv3PartnerQueryResponse struct {
151	SpAppid         *string                   `json:"sp_appid,omitempty"`
152	SpMchid         *string                   `json:"sp_mchid,omitempty"`
153	SubAppid        *string                   `json:"sub_appid,omitempty"`
154	SubMchid        *string                   `json:"sub_mchid,omitempty"`
155	OutTradeNo      *string                   `json:"out_trade_no,omitempty"`
156	TransactionId   *string                   `json:"transaction_id,omitempty"`
157	TradeType       *string                   `json:"trade_type,omitempty"`
158	TradeState      *string                   `json:"trade_state,omitempty"`
159	TradeStateDesc  *string                   `json:"trade_state_desc,omitempty"`
160	BankType        *string                   `json:"bank_type,omitempty"`
161	Attach          *string                   `json:"attach,omitempty"`
162	SuccessTime     *string                   `json:"success_time,omitempty"`
163	Payer           *PartnerCommRespPayerInfo `json:"payer,omitempty"`
164	Amount          *CommRespAmountInfo       `json:"amount,omitempty"`
165	SceneInfo       *CommRespSceneInfo        `json:"scene_info,omitempty"`
166	PromotionDetail []PromotionDetail         `json:"promotion_detail,omitempty"`
167}
168
169type PartnerCommRespPayerInfo struct {
170	SpOpenid  *string `json:"sp_openid,omitempty"`
171	SubOpenid *string `json:"sub_openid,omitempty"`
172}
173
174type PromotionDetail struct {
175	CouponId            *string                  `json:"coupon_id,omitempty"`
176	Name                *string                  `json:"name,omitempty"`
177	Scope               *string                  `json:"scope,omitempty"`
178	Type                *string                  `json:"type,omitempty"`
179	Amount              *int64                   `json:"amount,omitempty"`
180	StockId             *string                  `json:"stock_id,omitempty"`
181	WechatpayContribute *int64                   `json:"wechatpay_contribute,omitempty"`
182	MerchantContribute  *int64                   `json:"merchant_contribute,omitempty"`
183	OtherContribute     *int64                   `json:"other_contribute,omitempty"`
184	Currency            *string                  `json:"currency,omitempty"`
185	GoodsDetail         []GoodsDetailInPromotion `json:"goods_detail,omitempty"`
186}

1curl -X GET \
2  https://api.mch.weixin.qq.com/v3/pay/partner/transactions/out-trade-no/1217752501201407033233368018?sp_mchid=1230000109&sub_mchid=1900000109 \
3  -H "Authorization: WECHATPAY2-SHA256-RSA2048 mchid=\"1900000001\",..." \
4  -H "Accept: application/json" 
5