上节课我们调通了支付罚款的功能,后端接收到付款成功的通知,并且把这个结果推送给前端页面。我们在页面的弹窗中看到了提示付款成功的文字。看似付款功能做的很完美了,但是这里面存在隐患。如果用户或者商户系统没有收到微信平台发送的付款成功通知消息,那该怎么做呢?这就需要我们主动发起请求,查询这笔付款到底成功了还是失败了。
用户想要主动发起查询付款结果,可以点击支付成功按钮。前端页面会发送Ajax请求给后端的Web方法,然后端系统调用微信支付API查询付款结果。
一、查询支付结果的API接口
微信官方的API接口(https://pay.weixin.qq.com/wiki/doc/api/native.php?chapter=9_2)给我们提供了查询付款结果的功能,所以我们只要正常调用接口就可以了。
参数 | 含义 | 类型 | 示例 |
---|---|---|---|
appid | 开发者账号的APPID | String | wxd678efh567hg6787 |
mch_id | 商户号ID | String | 1230000109 |
transaction_id | 支付订单ID | String | 1009660380201506130 |
out_trade_no | 商品订单ID | String | 20150806125346 |
nonce_str | 随机字符串 | String | C380BEC2BFD727A4B6845133519F3AD6 |
sign | 数字签名 | String | 5K8264ILTKCH16CQ2502SI8ZNMTM67VS |
返回的响应,我们只需要看4个参数就可以了。
参数 | 含义 | 类型 | 示例 |
---|---|---|---|
return_code | 通信状态码 | String | SUCCESS |
result_code | 业务状态码 | String | SUCCESS |
trade_state | 交易状态码 | String | SUCCESS |
sign | 数字签名 | String | 5K8264ILTKCH16CQ2502SI8ZNMTM67VS |
二、编写业务层代码
在AmectService.java
接口中,声明抽象方法。
public interface AmectService {
……
public void searchNativeAmectPayResult(HashMap param);
}
在AmectServiceImpl.java
类中,实现抽象方法。
public class AmectServiceImpl implements AmectService {
……
@Override
public void searchNativeAmectPayResult(HashMap param) {
HashMap map = amectDao.searchAmectByCondition(param);
if (MapUtil.isNotEmpty(map)) {
String uuid = MapUtil.getStr(map, "uuid");
param.clear();
param.put("appid", myWXPayConfig.getAppID());
param.put("mch_id", myWXPayConfig.getMchID());
param.put("out_trade_no", uuid);
param.put("nonce_str", WXPayUtil.generateNonceStr());
try {
String sign = WXPayUtil.generateSignature(param, myWXPayConfig.getKey());
param.put("sign", sign);
WXPay wxPay = new WXPay(myWXPayConfig);
Map<String, String> result = wxPay.orderQuery(param);
String returnCode = result.get("return_code");
String resultCode = result.get("result_code");
if ("SUCCESS".equals(returnCode) && "SUCCESS".equals(resultCode)) {
String tradeState = result.get("trade_state");
//查询到订单支付成功
if ("SUCCESS".equals(tradeState)) {
//更新订单状态
amectDao.updateStatus(new HashMap() {{
put("uuid", uuid);
put("status", 2);
}});
}
}
} catch (Exception e) {
log.error("执行异常", e);
throw new EmosException("执行异常");
}
}
}
}
三、编写Web层代码
创建SearchNativeAmectPayResultForm.java
类,用于封装Ajax提交的数据。
@Data
@Schema(description = "查询Navtive支付罚款单支付结果表单")
public class SearchNativeAmectPayResultForm {
@NotNull(message = "amectId不能为空")
@Min(value = 1, message = "amectId不能小于1")
@Schema(description = "罚款单ID")
private Integer amectId;
}
在AmectController.java
类中,定义Web方法。
public class AmectController {
……
@PostMapping("/searchNativeAmectPayResult")
@Operation(summary = "查询Native支付罚款订单结果")
@SaCheckLogin
public R searchNativeAmectPayResult(@Valid @RequestBody SearchNativeAmectPayResultForm form) {
int userId = StpUtil.getLoginIdAsInt();
int amectId = form.getAmectId();
HashMap param = new HashMap() {{
put("amectId", amectId);
put("userId", userId);
put("status", 1);
}};
amectService.searchNativeAmectPayResult(param);
return R.ok();
}
}