版权声明：本文首发 http://asing1elife.com ，转载请注明出处。 https://blog.csdn.net/asing1elife/article/details/82620040

Java微信订单查询

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

更多精彩

• 更多技术博客，请移步 asing1elife’s blog

前置条件

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

官网

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

定义请求参数对象

1. 订单查询请求参数（必填）

public class QueryOrderRequest {// 公众账号idprivate String appid;// 商户号private String mch_id;// 商户订单号，32位以内，不重复private String out_trade_no;// 随机字符串，32位以内private String nonce_str;// 签名，遵循签名算法private String sign;
}

1. 查询订单请求参数（非必填）

public class QueryOrderRequestExt extends QueryOrderRequest {// 签名类型，默认MD5private String sign_type;
}

定义接收参数对象

1. 查询订单接收参数（必填）

public class QueryOrderResponse {// 返回状态码，通信标识，SUCCESS/FAILprivate String return_code;// 公众账号idprivate String appid;// 商户号private String mch_id;// 随机字符串private String nonce_str;// 签名private String sign;// 业务结果，交易标识，SUCCESS/FAILprivate String result_code;// 用户标识private String openid;// 交易类型，JSAPI，NATIVE，APPprivate 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. 查询订单接收参数（非必填）

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 形式

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 才能确定订单支付成功

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. 该工具类目前提供了数据转换、签名生成、随机数生成的通用方法

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("&");}}// 拼接keysb.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);}}

微信支付请求建立类

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());}}