Springboot----项目整合微信支付（用户取消订单）

/**
* 用户取消订单
* @param order
* @return
*/
@ApiOperation("取消订单")
@PostMapping("/cancel")
public R<String> cancelOrder(@RequestBody Orders order) throws Exception {
    log.info("取消订单");
    wxPayService.cancelOrder(order);
    return R.success("取消订单成功");
}

/**
* 取消订单
* @param order
*/
@Override
public void cancelOrder(Orders order) throws Exception {
    //调用微信支付的关单接口
    this.closeOrder(order.getNumber());
    //更新订单状态
    Orders order_temp = ordersService.getById(order.getId());
    ordersService.updateStatusByOrderNo(order_temp.getNumber(),"5");
}
/**
* 关单接口的调用
* @param orderNo
*/
@Override
public void closeOrder(String orderNo) throws Exception {
    log.info("关单接口的调用，订单号 ===> {}", orderNo);
    //创建远程请求对象
    String url = String.format(WxApiType.CLOSE_ORDER_BY_NO.getType(), orderNo);
    url = wxPayConfig.getDomain().concat(url);
    HttpPost httpPost = new HttpPost(url);
    httpPost.addHeader("Accept", "application/json");
    httpPost.addHeader("Content-type","application/json; charset=utf-8");
    ByteArrayOutputStream bos = new ByteArrayOutputStream();
    ObjectMapper objectMapper = new ObjectMapper();
    ObjectNode rootNode = objectMapper.createObjectNode();
    rootNode.put("mchid",wxPayConfig.getMchId());
    objectMapper.writeValue(bos, rootNode);
    httpPost.setEntity(new StringEntity(bos.toString(StandardCharsets.UTF_8), "UTF-8"));
    //完成签名并执行请求
    try (CloseableHttpResponse response = wxPayClient.execute(httpPost)) {
        String jsonString = JSON.toJSONString(response);
        JSONObject body = JSON.parseObject(jsonString);
        JSONObject statusLine = body.getJSONObject("statusLine");
        String code = statusLine.getString("statusCode");
        log.info("关闭订单成功订单号：===>{}", code);
    }
}

/**
 * 监听订单延迟队列
 * @param orderNo
 * @throws Exception
*/
@RabbitListener(queues = {"plugin.delay.order.queue"})
public void orderDelayQueue(String orderNo, Message message, Channel channel) throws Exception {
    log.info("订单延迟队列开始消费...");
    try {
        //处理订单
        wxPayService.checkOrderStatus(orderNo);
        //告诉服务器收到这条消息 已经被我消费了 可以在队列删掉 这样以后就不会再发了 否则消息服务器以为这条消息没处理掉 后续还会在发
        channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
        log.info("消息接收成功");
    } catch (Exception e) {
        e.printStackTrace();
        //消息重新入队
        channel.basicNack(message.getMessageProperties().getDeliveryTag(), false,true);
        log.info("消息接收失败，重新入队");
    }
}