Java 通过统一下单 API 进行订单支付后，除等待微信通过 notify_url 进行回调通知外，还可以主动查询订单状态
更多精彩
前置条件
可参考 Java 微信扫码支付 如果实现微信支付
官网
定义请求参数对象
订单查询请求参数(必填)
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;
}
查询订单请求参数(非必填)
public class QueryOrderRequestExt extends QueryOrderRequest {
// 签名类型，默认MD5
private String sign_type;
}
定义接收参数对象
查询订单接收参数(必填)
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;
}
查询订单接收参数(非必填)
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;
}
生成订单信息
SOPConstants.WECHAT_PAY_APP_ID 是公众账号 id
SOPConstants.WECHAT_PAY_MCH_ID 是商户id
WechatUtil.makeNonceStr() 是生成的随机字符串
WechatUtil.makeSign(BeanMap.create(ext)) 是根据请求参数制作签名
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);
}
向微信发起订单查询请求
SOPConstants.WECHAT_PAY_QUERY_URL 是微信订单查询的请求 URL
WechatConnection.connect() 是向微信发起请求的通用方法
只有 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;
}
}
微信支付相关操作工具类
该工具类目前提供了数据转换、签名生成、随机数生成的通用方法
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 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 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);
}
}
微信支付请求建立类
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());
}
}
