完结支付分订单

1curl -X POST \
2  https://api.mch.weixin.qq.com/v3/payscore/partner/serviceorder/1234323JKHDFE1243252/complete \
3  -H "Authorization: WECHATPAY2-SHA256-RSA2048 mchid=\"1900000001\",..." \
4  -H "Accept: application/json" \
5  -H "Content-Type: application/json" \
6  -d '{
7    "service_id" : "2002000000000558128851361561536",
8    "sub_mchid" : "1900000109",
9    "post_payments" : [
10      {
11        "name" : "就餐费用",
12        "amount" : 40000,
13        "description" : "就餐人均100元",
14        "count" : 4
15      }
16    ],
17    "post_discounts" : [
18      {
19        "name" : "满20减1元",
20        "description" : "不与其他优惠叠加",
21        "amount" : 100,
22        "count" : 2
23      }
24    ],
25    "total_amount" : 50000,
26    "time_range" : {
27      "start_time" : "20091225091010",
28      "end_time" : "20091225121010",
29      "start_time_remark" : "备注1",
30      "end_time_remark" : "备注2"
31    },
32    "location" : {
33      "start_location" : "嗨客时尚主题展餐厅",
34      "end_location" : "嗨客时尚主题展餐厅"
35    },
36    "profit_sharing" : false,
37    "complete_time" : "2019-11-11T16:24:05+08:00",
38    "goods_tag" : "goods_tag",
39    "device" : {
40      "start_device_id" : "HG123456",
41      "end_device_id" : "HG123456",
42      "materiel_no" : "example_materiel_no"
43    }
44  }'
45

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 CompletePartnerServiceOrder {
26  private static String HOST = "https://api.mch.weixin.qq.com";
27  private static String METHOD = "POST";
28  private static String PATH = "/v3/payscore/partner/serviceorder/{out_order_no}/complete";
29
30  public static void main(String[] args) {
31    // TODO: 请准备商户开发必要参数，参考：https://pay.weixin.qq.com/doc/v3/partner/4013080340
32    CompletePartnerServiceOrder client = new CompletePartnerServiceOrder(
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    CompletePartnerServiceOrderRequest request = new CompletePartnerServiceOrderRequest();
41    request.outOrderNo = "1234323JKHDFE1243252";
42    request.serviceId = "2002000000000558128851361561536";
43    request.subMchid = "1900000109";
44    request.postPayments = new ArrayList<>();
45    {
46      Payment postPaymentsItem = new Payment();
47      postPaymentsItem.name = "就餐费用";
48      postPaymentsItem.amount = 40000L;
49      postPaymentsItem.description = "就餐人均100元";
50      postPaymentsItem.count = 4L;
51      request.postPayments.add(postPaymentsItem);
52    };
53    request.postDiscounts = new ArrayList<>();
54    {
55      ServiceOrderCoupon postDiscountsItem = new ServiceOrderCoupon();
56      postDiscountsItem.name = "满20减1元";
57      postDiscountsItem.description = "不与其他优惠叠加";
58      postDiscountsItem.amount = 100L;
59      postDiscountsItem.count = 2L;
60      request.postDiscounts.add(postDiscountsItem);
61    };
62    request.totalAmount = 50000L;
63    request.timeRange = new TimeRange();
64    request.timeRange.startTime = "20091225091010";
65    request.timeRange.endTime = "20091225121010";
66    request.timeRange.startTimeRemark = "备注1";
67    request.timeRange.endTimeRemark = "备注2";
68    request.location = new Location();
69    request.location.startLocation = "嗨客时尚主题展餐厅";
70    request.location.endLocation = "嗨客时尚主题展餐厅";
71    request.profitSharing = false;
72    request.completeTime = "2019-11-11T16:24:05+08:00";
73    request.goodsTag = "goods_tag";
74    request.device = new Device();
75    request.device.startDeviceId = "HG123456";
76    request.device.endDeviceId = "HG123456";
77    request.device.materielNo = "example_materiel_no";
78    try {
79      client.run(request);
80    } catch (WXPayUtility.ApiException e) {
81        // TODO: 请求失败，根据状态码执行不同的逻辑
82        e.printStackTrace();
83    }
84  }
85
86  public void run(CompletePartnerServiceOrderRequest request) {
87    String uri = PATH;
88    uri = uri.replace("{out_order_no}", WXPayUtility.urlEncode(request.outOrderNo));
89    String reqBody = WXPayUtility.toJson(request);
90
91    Request.Builder reqBuilder = new Request.Builder().url(HOST + uri);
92    reqBuilder.addHeader("Accept", "application/json");
93    reqBuilder.addHeader("Wechatpay-Serial", wechatPayPublicKeyId);
94    reqBuilder.addHeader("Authorization", WXPayUtility.buildAuthorization(mchid, certificateSerialNo,privateKey, METHOD, uri, reqBody));
95    reqBuilder.addHeader("Content-Type", "application/json");
96    RequestBody requestBody = RequestBody.create(MediaType.parse("application/json; charset=utf-8"), reqBody);
97    reqBuilder.method(METHOD, requestBody);
98    Request httpRequest = reqBuilder.build();
99
100    // 发送HTTP请求
101    OkHttpClient client = new OkHttpClient.Builder().build();
102    try (Response httpResponse = client.newCall(httpRequest).execute()) {
103      String respBody = WXPayUtility.extractBody(httpResponse);
104      if (httpResponse.code() >= 200 && httpResponse.code() < 300) {
105        // 2XX 成功，验证应答签名
106        WXPayUtility.validateResponse(this.wechatPayPublicKeyId, this.wechatPayPublicKey,
107            httpResponse.headers(), respBody);
108
109        return;
110      } else {
111        throw new WXPayUtility.ApiException(httpResponse.code(), respBody, httpResponse.headers());
112      }
113    } catch (IOException e) {
114      throw new UncheckedIOException("Sending request to " + uri + " failed.", e);
115    }
116  }
117
118  private final String mchid;
119  private final String certificateSerialNo;
120  private final PrivateKey privateKey;
121  private final String wechatPayPublicKeyId;
122  private final PublicKey wechatPayPublicKey;
123
124  public CompletePartnerServiceOrder(String mchid, String certificateSerialNo, String privateKeyFilePath, String wechatPayPublicKeyId, String wechatPayPublicKeyFilePath) {
125    this.mchid = mchid;
126    this.certificateSerialNo = certificateSerialNo;
127    this.privateKey = WXPayUtility.loadPrivateKeyFromPath(privateKeyFilePath);
128    this.wechatPayPublicKeyId = wechatPayPublicKeyId;
129    this.wechatPayPublicKey = WXPayUtility.loadPublicKeyFromPath(wechatPayPublicKeyFilePath);
130  }
131
132  public static class CompletePartnerServiceOrderRequest {
133    @SerializedName("service_id")
134    public String serviceId;
135  
136    @SerializedName("sub_mchid")
137    public String subMchid;
138  
139    @SerializedName("out_order_no")
140    @Expose(serialize = false)
141    public String outOrderNo;
142  
143    @SerializedName("post_payments")
144    public List<Payment> postPayments = new ArrayList<Payment>();
145  
146    @SerializedName("post_discounts")
147    public List<ServiceOrderCoupon> postDiscounts;
148  
149    @SerializedName("total_amount")
150    public Long totalAmount;
151  
152    @SerializedName("time_range")
153    public TimeRange timeRange;
154  
155    @SerializedName("location")
156    public Location location;
157  
158    @SerializedName("profit_sharing")
159    public Boolean profitSharing;
160  
161    @SerializedName("complete_time")
162    public String completeTime;
163  
164    @SerializedName("goods_tag")
165    public String goodsTag;
166  
167    @SerializedName("device")
168    public Device device;
169  }
170  
171  public static class Payment {
172    @SerializedName("name")
173    public String name;
174  
175    @SerializedName("amount")
176    public Long amount;
177  
178    @SerializedName("description")
179    public String description;
180  
181    @SerializedName("count")
182    public Long count;
183  }
184  
185  public static class ServiceOrderCoupon {
186    @SerializedName("name")
187    public String name;
188  
189    @SerializedName("description")
190    public String description;
191  
192    @SerializedName("amount")
193    public Long amount;
194  
195    @SerializedName("count")
196    public Long count;
197  }
198  
199  public static class TimeRange {
200    @SerializedName("start_time")
201    public String startTime;
202  
203    @SerializedName("end_time")
204    public String endTime;
205  
206    @SerializedName("start_time_remark")
207    public String startTimeRemark;
208  
209    @SerializedName("end_time_remark")
210    public String endTimeRemark;
211  }
212  
213  public static class Location {
214    @SerializedName("start_location")
215    public String startLocation;
216  
217    @SerializedName("end_location")
218    public String endLocation;
219  }
220  
221  public static class Device {
222    @SerializedName("start_device_id")
223    public String startDeviceId;
224  
225    @SerializedName("end_device_id")
226    public String endDeviceId;
227  
228    @SerializedName("materiel_no")
229    public String materielNo;
230  }
231  
232}
233

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	"strings"
11	"time"
12)
13
14func main() {
15	// TODO: 请准备商户开发必要参数，参考：https://pay.weixin.qq.com/doc/v3/partner/4013080340
16	config, err := wxpay_utility.CreateMchConfig(
17		"19xxxxxxxx",                 // 商户号，是由微信支付系统生成并分配给每个商户的唯一标识符，商户号获取方式参考 https://pay.weixin.qq.com/doc/v3/partner/4013080340
18		"1DDE55AD98Exxxxxxxxxx",      // 商户API证书序列号，如何获取请参考 https://pay.weixin.qq.com/doc/v3/partner/4013058924
19		"/path/to/apiclient_key.pem", // 商户API证书私钥文件路径，本地文件路径
20		"PUB_KEY_ID_xxxxxxxxxxxxx",   // 微信支付公钥ID，如何获取请参考 https://pay.weixin.qq.com/doc/v3/partner/4013038589
21		"/path/to/wxp_pub.pem",       // 微信支付公钥文件路径，本地文件路径
22	)
23	if err != nil {
24		fmt.Println(err)
25		return
26	}
27
28	request := &CompletePartnerServiceOrderRequest{
29		OutOrderNo: wxpay_utility.String("1234323JKHDFE1243252"),
30		ServiceId:  wxpay_utility.String("2002000000000558128851361561536"),
31		SubMchid:   wxpay_utility.String("1900000109"),
32		PostPayments: []Payment{Payment{
33			Name:        wxpay_utility.String("就餐费用"),
34			Amount:      wxpay_utility.Int64(40000),
35			Description: wxpay_utility.String("就餐人均100元"),
36			Count:       wxpay_utility.Int64(4),
37		}},
38		PostDiscounts: []ServiceOrderCoupon{ServiceOrderCoupon{
39			Name:        wxpay_utility.String("满20减1元"),
40			Description: wxpay_utility.String("不与其他优惠叠加"),
41			Amount:      wxpay_utility.Int64(100),
42			Count:       wxpay_utility.Int64(2),
43		}},
44		TotalAmount: wxpay_utility.Int64(50000),
45		TimeRange: &TimeRange{
46			StartTime:       wxpay_utility.String("20091225091010"),
47			EndTime:         wxpay_utility.String("20091225121010"),
48			StartTimeRemark: wxpay_utility.String("备注1"),
49			EndTimeRemark:   wxpay_utility.String("备注2"),
50		},
51		Location: &Location{
52			StartLocation: wxpay_utility.String("嗨客时尚主题展餐厅"),
53			EndLocation:   wxpay_utility.String("嗨客时尚主题展餐厅"),
54		},
55		ProfitSharing: wxpay_utility.Bool(false),
56		CompleteTime:  wxpay_utility.Time(time.Now()),
57		GoodsTag:      wxpay_utility.String("goods_tag"),
58		Device: &Device{
59			StartDeviceId: wxpay_utility.String("HG123456"),
60			EndDeviceId:   wxpay_utility.String("HG123456"),
61			MaterielNo:    wxpay_utility.String("example_materiel_no"),
62		},
63	}
64
65	err = CompletePartnerServiceOrder(config, request)
66	if err != nil {
67		fmt.Printf("请求失败: %+v\n", err)
68		// TODO: 请求失败，根据状态码执行不同的处理
69		return
70	}
71
72	// TODO: 请求成功，继续业务逻辑
73	fmt.Println("请求成功")
74}
75
76func CompletePartnerServiceOrder(config *wxpay_utility.MchConfig, request *CompletePartnerServiceOrderRequest) (err error) {
77	const (
78		host   = "https://api.mch.weixin.qq.com"
79		method = "POST"
80		path   = "/v3/payscore/partner/serviceorder/{out_order_no}/complete"
81	)
82
83	reqUrl, err := url.Parse(fmt.Sprintf("%s%s", host, path))
84	if err != nil {
85		return err
86	}
87	reqUrl.Path = strings.Replace(reqUrl.Path, "{out_order_no}", url.PathEscape(*request.OutOrderNo), -1)
88	reqBody, err := json.Marshal(request)
89	if err != nil {
90		return err
91	}
92	httpRequest, err := http.NewRequest(method, reqUrl.String(), bytes.NewReader(reqBody))
93	if err != nil {
94		return err
95	}
96	httpRequest.Header.Set("Accept", "application/json")
97	httpRequest.Header.Set("Wechatpay-Serial", config.WechatPayPublicKeyId())
98	httpRequest.Header.Set("Content-Type", "application/json")
99	authorization, err := wxpay_utility.BuildAuthorization(config.MchId(), config.CertificateSerialNo(), config.PrivateKey(), method, reqUrl.RequestURI(), reqBody)
100	if err != nil {
101		return err
102	}
103	httpRequest.Header.Set("Authorization", authorization)
104
105	client := &http.Client{}
106	httpResponse, err := client.Do(httpRequest)
107	if err != nil {
108		return err
109	}
110	respBody, err := wxpay_utility.ExtractResponseBody(httpResponse)
111	if err != nil {
112		return err
113	}
114	if httpResponse.StatusCode >= 200 && httpResponse.StatusCode < 300 {
115		// 2XX 成功，验证应答签名
116		err = wxpay_utility.ValidateResponse(
117			config.WechatPayPublicKeyId(),
118			config.WechatPayPublicKey(),
119			&httpResponse.Header,
120			respBody,
121		)
122		if err != nil {
123			return err
124		}
125		return nil
126	} else {
127		return wxpay_utility.NewApiException(
128			httpResponse.StatusCode,
129			httpResponse.Header,
130			respBody,
131		)
132	}
133}
134
135type CompletePartnerServiceOrderRequest struct {
136	ServiceId     *string              `json:"service_id,omitempty"`
137	SubMchid      *string              `json:"sub_mchid,omitempty"`
138	OutOrderNo    *string              `json:"out_order_no,omitempty"`
139	PostPayments  []Payment            `json:"post_payments,omitempty"`
140	PostDiscounts []ServiceOrderCoupon `json:"post_discounts,omitempty"`
141	TotalAmount   *int64               `json:"total_amount,omitempty"`
142	TimeRange     *TimeRange           `json:"time_range,omitempty"`
143	Location      *Location            `json:"location,omitempty"`
144	ProfitSharing *bool                `json:"profit_sharing,omitempty"`
145	CompleteTime  *time.Time           `json:"complete_time,omitempty"`
146	GoodsTag      *string              `json:"goods_tag,omitempty"`
147	Device        *Device              `json:"device,omitempty"`
148}
149
150func (o *CompletePartnerServiceOrderRequest) MarshalJSON() ([]byte, error) {
151	type Alias CompletePartnerServiceOrderRequest
152	a := &struct {
153		OutOrderNo *string `json:"out_order_no,omitempty"`
154		*Alias
155	}{
156		// 序列化时移除非 Body 字段
157		OutOrderNo: nil,
158		Alias:      (*Alias)(o),
159	}
160	return json.Marshal(a)
161}
162
163type Payment struct {
164	Name        *string `json:"name,omitempty"`
165	Amount      *int64  `json:"amount,omitempty"`
166	Description *string `json:"description,omitempty"`
167	Count       *int64  `json:"count,omitempty"`
168}
169
170type ServiceOrderCoupon struct {
171	Name        *string `json:"name,omitempty"`
172	Description *string `json:"description,omitempty"`
173	Amount      *int64  `json:"amount,omitempty"`
174	Count       *int64  `json:"count,omitempty"`
175}
176
177type TimeRange struct {
178	StartTime       *string `json:"start_time,omitempty"`
179	EndTime         *string `json:"end_time,omitempty"`
180	StartTimeRemark *string `json:"start_time_remark,omitempty"`
181	EndTimeRemark   *string `json:"end_time_remark,omitempty"`
182}
183
184type Location struct {
185	StartLocation *string `json:"start_location,omitempty"`
186	EndLocation   *string `json:"end_location,omitempty"`
187}
188
189type Device struct {
190	StartDeviceId *string `json:"start_device_id,omitempty"`
191	EndDeviceId   *string `json:"end_device_id,omitempty"`
192	MaterielNo    *string `json:"materiel_no,omitempty"`
193}
194