Java微信订单查询

Java 通过统一下单 API 进行订单支付后,除等待微信通过 notify_url 进行回调通知外,还可以主动查询订单状态

前置条件

可参考 Java 微信扫码支付 如果实现微信支付

官网

【微信支付】扫码支付开发者文档

定义请求参数对象

  1. 订单查询请求参数(必填)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
public class QueryOrderRequest {
    // 公众账号id
    private String appid;

    // 商户号
    private String mch_id;

    // 商户订单号,32位以内,不重复
    private String out_trade_no;

    // 随机字符串,32位以内
    private String nonce_str;

    // 签名,遵循签名算法
    private String sign;
}
  1. 查询订单请求参数(非必填)
1
2
3
4
5
public class QueryOrderRequestExt extends QueryOrderRequest {
    // 签名类型,默认MD5
    private String sign_type;
}

定义接收参数对象

  1. 查询订单接收参数(必填)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
public class QueryOrderResponse {
    // 返回状态码,通信标识,SUCCESS/FAIL
    private String return_code;

    // 公众账号id
    private String appid;

    // 商户号
    private String mch_id;

    // 随机字符串
    private String nonce_str;

    // 签名
    private String sign;

    // 业务结果,交易标识,SUCCESS/FAIL
    private String result_code;

    // 用户标识
    private String openid;

    // 交易类型,JSAPI,NATIVE,APP
    private String trade_type;

    // 交易状态,SUCCESS-成功 USERPAYING-支付中
    private String trade_state;

    // 付款银行
    private String bank_type;

    // 标价金额,单位分
    private int total_fee;

    // 现金支付金额
    private int cash_fee;

    // 微信支付订单号
    private String transaction_id;

    // 商户订单号
    private String out_trade_no;

    // 支付完成时间
    private String time_end;

    // 交易状态描述
    private String trade_state_desc;
}
  1. 查询订单接收参数(非必填)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
public class QueryOrderResponseExt extends QueryOrderResponse {
    // 返回信息,非空则表示返回了错误信息
    private String return_msg;

    // 错误代码
    private String err_code;

    // 错误代码描述
    private String err_code_des;

    // 设备号
    private String device_info;

    // 是否关注公众号
    private String is_subscribe;

    // 应结订单金额
    private String settlement_total_fee;

    // 标价币种
    private String fee_type;

    // 现金支付币种
    private String cash_fee_type;

    // 附加数据
    private String attach;
}

生成订单信息

  1. SOPConstants.WECHAT_PAY_APP_ID 是公众账号 id
  2. SOPConstants.WECHAT_PAY_MCH_ID 是商户id
  3. WechatUtil.makeNonceStr() 是生成的随机字符串
  4. WechatUtil.makeSign(BeanMap.create(ext)) 是根据请求参数制作签名
  5. WechatUtil.truncateDataToXML(QueryOrderRequestExt.class, ext) 是将数据转换为 XML 形式
1
2
3
4
5
6
7
8
9
10
11
12
13
private String generateOrderInfo(Long orderId) {
    OrderDTO order = orderManageService.getOrder(orderId);

    QueryOrderRequestExt ext = new QueryOrderRequestExt();
    ext.setAppid(SOPConstants.WECHAT_PAY_APP_ID);
    ext.setMch_id(SOPConstants.WECHAT_PAY_MCH_ID);
    ext.setOut_trade_no(order.getCode());
    ext.setNonce_str(WechatUtil.makeNonceStr());

    ext.setSign(WechatUtil.makeSign(BeanMap.create(ext)));

    return WechatUtil.truncateDataToXML(QueryOrderRequestExt.class, ext);
}

向微信发起订单查询请求

  1. SOPConstants.WECHAT_PAY_QUERY_URL 是微信订单查询的请求 URL
  2. WechatConnection.connect() 是向微信发起请求的通用方法
  3. 只有 ext.getResult_code() ext.getResult_code() ext.getTrade_state() 的值都是 SUCCESS 才能确定订单支付成功
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
public Boolean getPayResult(Long orderId) {
    String orderInfo = generateOrderInfo(orderId);

    QueryOrderResponseExt ext = null;
    try {
        ext = (QueryOrderResponseExt) WechatConnection.connect(SOPConstants.WECHAT_PAY_QUERY_URL, orderInfo, QueryOrderResponseExt.class);
    } catch (IOException e) {
        logger.error("微信查询订单" + orderId + "失败!", e);
    }

    if (ext == null) {
        return false;
    }

    if (WechatConnection.SUCCESS_CODE.equals(ext.getResult_code())) {
        if (WechatConnection.SUCCESS_CODE.equals(ext.getResult_code()) && WechatConnection.SUCCESS_CODE.equals(ext.getTrade_state())) {
            // 更新订单状态
            orderPayService.updateOrderInfo(ext.getOut_trade_no(), OrderPay.wchatPay.getCode());
            return true;
        } else {
            logger.error("订单" + orderId + "交易失败,交易状态:" + ext.getTrade_state());
            return false;
        }
    } else {
        logger.error("订单" + orderId + "查询失败!");
        return false;
    }
}

微信支付相关操作工具类

  1. 该工具类目前提供了数据转换、签名生成、随机数生成的通用方法
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
public class WechatUtil {

    private static Logger logger = LoggerFactory.getLogger(WechatUtil.class);

    /**
     * 数据转换为xml格式
     *
     * @param object
     * @param obj
     * @return
     */
    public static String truncateDataToXML(Class<?> object, Object obj) {
        XStream xStream = new XStream(new XppDriver(new XmlFriendlyReplacer("_-", "_")));
        xStream.alias("xml", object);

        return xStream.toXML(obj);
    }

    /**
     * 数据转换为对象
     *
     * @param object
     * @param str
     * @return
     */
    public static Object truncateDataFromXML(Class<?> object, String str) {
        XStream xStream = new XStream(new XppDriver(new XmlFriendlyReplacer("_-", "_")));
        xStream.alias("xml", object);

        return xStream.fromXML(str);
    }

    /**
     * 生成随机字符串
     *
     * @return
     */
    public static String makeNonceStr() {
        StringBuffer str = new StringBuffer(DateUtil.getSysDateString("yyyyMMddHHmmssS"));
        str.append((new Random().nextInt(900) + 100));

        return str.toString();
    }

    /**
     * 拼接签名数据
     *
     * @return
     */
    public static String makeSign(BeanMap beanMap) {
        SortedMap<String, String> signMaps = Maps.newTreeMap();

        for (Object key : beanMap.keySet()) {
            Object value = beanMap.get(key);

            // 排除空数据
            if (value == null) {
                continue;
            }

            signMaps.put(key + "", String.valueOf(value));
        }

        // 生成签名
        return generateSign(signMaps);
    }


    /**
     * 生成签名
     *
     * @param signMaps
     * @return
     * @throws Exception
     */
    public static String generateSign(SortedMap<String, String> signMaps) {
        StringBuffer sb = new StringBuffer();

        // 字典序
        for (Map.Entry signMap : signMaps.entrySet()) {
            String key = (String) signMap.getKey();
            String value = (String) signMap.getValue();

            // 为空不参与签名、参数名区分大小写
            if (null != value && !"".equals(value) && !"sign".equals(key) && !"key".equals(key)) {
                sb.append(key).append("=").append(value).append("&");
            }
        }

        // 拼接key
        sb.append("key=").append(SOPConstants.WECHAT_PAY_KEY);

        // MD5加密
        return Objects.requireNonNull(encoderByMd5(sb.toString())).toUpperCase();
    }

    /**
     * 利用MD5进行加密
     *
     * @param str 待加密的字符串
     * @return 加密后的字符串
     */
    private static String encoderByMd5(String str) {
        // 生成一个MD5加密计算摘要
        MessageDigest md = null;
        try {
            md = MessageDigest.getInstance("MD5");
        } catch (NoSuchAlgorithmException e) {
            logger.error("MD5加密失败!", e);
        }

        if (md == null) {
            return null;
        }

        // 计算md5函数
        md.update(str.getBytes());
        // digest()最后确定返回md5 hash值,返回值为8为字符串。因为md5 hash值是16位的hex值,实际上就是8位的字符
        // BigInteger函数则将8位的字符串转换成16位hex值,用字符串来表示;得到字符串形式的hash值
        return new BigInteger(1, md.digest()).toString(16);
    }

}

微信支付请求建立类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
public class WechatConnection {

    // 成功标志
    public static final String SUCCESS_CODE = "SUCCESS";

    /**
     * 建立微信连接,并返回结果
     *
     * @param url
     * @param info
     * @param object
     * @return
     * @throws IOException
     */
    public static Object connect(String url, String info, Class<?> object) throws IOException {
        // 建立连接
        HttpURLConnection conn = (HttpURLConnection) new URL(url).openConnection();
        conn.setConnectTimeout(8000);
        conn.setRequestMethod("POST");
        conn.setDoOutput(true);

        // 发送数据
        BufferedOutputStream bos = new BufferedOutputStream(conn.getOutputStream());
        bos.write(info.getBytes());
        bos.flush();
        bos.close();

        // 获取数据
        BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream()));

        // 接收数据
        String line;
        StringBuffer str = new StringBuffer();
        while ((line = reader.readLine()) != null) {
            str.append(line);
        }

        return WechatUtil.truncateDataFromXML(object, str.toString());
    }

}