全部开发者教程

企业级在线办公系统

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

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