10-19 主动查询付款结果（后端）_企业级在线办公系统-慕课网

上节课我们调通了支付罚款的功能，后端接收到付款成功的通知，并且把这个结果推送给前端页面。我们在页面的弹窗中看到了提示付款成功的文字。看似付款功能做的很完美了，但是这里面存在隐患。如果用户或者商户系统没有收到微信平台发送的付款成功通知消息，那该怎么做呢？这就需要我们主动发起请求，查询这笔付款到底成功了还是失败了。

图片描述
用户想要主动发起查询付款结果，可以点击支付成功按钮。前端页面会发送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();
    }
}