商户订单号查询订单

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

1package main
2
3import (
4	"demo/wxpay_utility"// 引用微信支付工具库 参考:https://pay.weixin.qq.com/doc/v3/merchant/4015119334
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/merchant/4013070756
14	config, err := wxpay_utility.CreateMchConfig(
15		"填入 商户号",           // 商户号，是由微信支付系统生成并分配给每个商户的唯一标识符，商户号获取方式参考https://pay.weixin.qq.com/doc/v3/merchant/4013070756
16		"填入 商户API证书序列号",    // 商户API证书序列号，如何获取请参考https://pay.weixin.qq.com/doc/v3/merchant/4013053053
17		"填入 商户API证书私钥文件路径", // 商户API证书私钥文件路径，本地文件路径
18		"填入 微信支付公钥ID",      // 微信支付公钥ID，如何获取请参考https://pay.weixin.qq.com/doc/v3/merchant/4013038816
19		"填入 微信支付公钥文件路径",    // 微信支付公钥文件路径，本地文件路径
20	)
21	if err != nil {
22		fmt.Println(err)
23		return
24	}
25
26	request := &QueryByOutTradeNoRequest{
27		Mchid:      wxpay_utility.String("1230000109"),
28		OutTradeNo: wxpay_utility.String("1217752501201407033233368018"),
29	}
30
31	response, err := QueryByOutTradeNo(config, request)
32	if err != nil {
33		fmt.Printf("请求失败: %+v\n", err)
34		// TODO: 请求失败，根据状态码执行不同的处理
35		return
36	}
37
38	// TODO: 请求成功，继续业务逻辑
39	fmt.Printf("请求成功: %+v\n", response)
40}
41
42func QueryByOutTradeNo(config *wxpay_utility.MchConfig, request *QueryByOutTradeNoRequest) (response *DirectApiv3QueryResponse, err error) {
43	const (
44		host   = "https://api.mch.weixin.qq.com"
45		method = "GET"
46		path   = "/v3/pay/transactions/out-trade-no/{out_trade_no}"
47	)
48
49	reqUrl, err := url.Parse(fmt.Sprintf("%s%s", host, path))
50	if err != nil {
51		return nil, err
52	}
53	reqUrl.Path = strings.Replace(reqUrl.Path, "{out_trade_no}", url.PathEscape(*request.OutTradeNo), -1)
54	query := reqUrl.Query()
55	query.Add("mchid", *request.Mchid)
56	reqUrl.RawQuery = query.Encode()
57	httpRequest, err := http.NewRequest(method, reqUrl.String(), nil)
58	if err != nil {
59		return nil, err
60	}
61	httpRequest.Header.Set("Accept", "application/json")
62	httpRequest.Header.Set("Wechatpay-Serial", config.WechatPayPublicKeyId())
63	authorization, err := wxpay_utility.BuildAuthorization(config.MchId(), config.CertificateSerialNo(), config.PrivateKey(), method, reqUrl.RequestURI(), nil)
64	if err != nil {
65		return nil, err
66	}
67	httpRequest.Header.Set("Authorization", authorization)
68
69	client := &http.Client{}
70	httpResponse, err := client.Do(httpRequest)
71	if err != nil {
72		return nil, err
73	}
74
75	respBody, err := wxpay_utility.ExtractResponseBody(httpResponse)
76	if err != nil {
77		return nil, err
78	}
79
80	if httpResponse.StatusCode >= 200 && httpResponse.StatusCode < 300 {
81		// 2XX 成功，验证应答签名
82		err = wxpay_utility.ValidateResponse(
83			config.WechatPayPublicKeyId(),
84			config.WechatPayPublicKey(),
85			&httpResponse.Header,
86			respBody,
87		)
88		if err != nil {
89			return nil, err
90		}
91
92		if err := json.Unmarshal(respBody, response); err != nil {
93			return nil, err
94		}
95
96		return response, nil
97	} else {
98		return nil, &wxpay_utility.ApiException{
99			StatusCode: httpResponse.StatusCode,
100			Header:     httpResponse.Header,
101			Body:       respBody,
102		}
103	}
104}
105
106type CommRespAmountInfo struct {
107	Total         *int64  `json:"total,omitempty"`
108	PayerTotal    *int64  `json:"payer_total,omitempty"`
109	Currency      *string `json:"currency,omitempty"`
110	PayerCurrency *string `json:"payer_currency,omitempty"`
111}
112
113type CommRespSceneInfo struct {
114	DeviceId  *string    `json:"device_id,omitempty"`
115}
116
117type CommRespPayerInfo struct {
118	Openid *string `json:"openid,omitempty"`
119}
120
121type QueryByOutTradeNoRequest struct {
122	Mchid      *string `json:"mchid,omitempty"`
123	OutTradeNo *string `json:"out_trade_no,omitempty"`
124}
125
126func (o *QueryByOutTradeNoRequest) MarshalJSON() ([]byte, error) {
127	type Alias QueryByOutTradeNoRequest
128	a := &struct {
129		Mchid      *string `json:"mchid,omitempty"`
130		OutTradeNo *string `json:"out_trade_no,omitempty"`
131		*Alias
132	}{
133		// 序列化时移除非 Body 字段
134		Mchid:      nil,
135		OutTradeNo: nil,
136		Alias:      (*Alias)(o),
137	}
138	return json.Marshal(a)
139}
140
141type GoodsDetailInPromotion struct {
142	GoodsId        *string `json:"goods_id,omitempty"`
143	Quantity       *int64  `json:"quantity,omitempty"`
144	UnitPrice      *int64  `json:"unit_price,omitempty"`
145	DiscountAmount *int64  `json:"discount_amount,omitempty"`
146	GoodsRemark    *string `json:"goods_remark,omitempty"`
147}
148
149type DirectApiv3QueryResponse struct {
150	Appid           *string             `json:"appid,omitempty"`
151	Mchid           *string             `json:"mchid,omitempty"`
152	OutTradeNo      *string             `json:"out_trade_no,omitempty"`
153	TransactionId   *string             `json:"transaction_id,omitempty"`
154	TradeType       *string             `json:"trade_type,omitempty"`
155	TradeState      *string             `json:"trade_state,omitempty"`
156	TradeStateDesc  *string             `json:"trade_state_desc,omitempty"`
157	BankType        *string             `json:"bank_type,omitempty"`
158	Attach          *string             `json:"attach,omitempty"`
159	SuccessTime     *string             `json:"success_time,omitempty"`
160	Payer           *CommRespPayerInfo  `json:"payer,omitempty"`
161	Amount          *CommRespAmountInfo `json:"amount,omitempty"`
162	SceneInfo       *CommRespSceneInfo  `json:"scene_info,omitempty"`
163	PromotionDetail []PromotionDetail   `json:"promotion_detail,omitempty"`
164}
165
166type PromotionDetail struct {
167	CouponId            *string                  `json:"coupon_id,omitempty"`
168	Name                *string                  `json:"name,omitempty"`
169	Scope               *string                  `json:"scope,omitempty"`
170	Type                *string                  `json:"type,omitempty"`
171	Amount              *int64                   `json:"amount,omitempty"`
172	StockId             *string                  `json:"stock_id,omitempty"`
173	WechatpayContribute *int64                   `json:"wechatpay_contribute,omitempty"`
174	MerchantContribute  *int64                   `json:"merchant_contribute,omitempty"`
175	OtherContribute     *int64                   `json:"other_contribute,omitempty"`
176	Currency            *string                  `json:"currency,omitempty"`
177	GoodsDetail         []GoodsDetailInPromotion `json:"goods_detail,omitempty"`
178}

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