Springboot整合微信支付(订单过期取消及商户主动查单)

/**
* 提交订单
* @param orders
* @param session
*/
@Override
@Transactional
public Orders createOrder(Orders orders, HttpSession session) {
    //获取当前用户信息
    Long userId = (Long) session.getAttribute("user");
    //查询地址数据
    Long addressBookId = orders.getAddressBookId();
    AddressBook addressBook = addressBookService.getById(addressBookId);
    if(addressBook == null) {
        throw new CustomException("用户地址信息有误，不能下单");
    }
    //获取当前用户购物车数据
    LambdaQueryWrapper<ShoppingCart> SCLqw = new LambdaQueryWrapper<>();
    SCLqw.eq(ShoppingCart::getUserId,userId);
    List<ShoppingCart> shoppingCartList = shoppingCartService.list(SCLqw);
    //生成订单号
    long orderId = IdWorker.getId();
    //设置订单号
    orders.setNumber(String.valueOf(orderId));
    //设置订单状态(待付款)
    orders.setStatus(1);
    //设置下单用户id
    orders.setUserId(userId);
    //设置下单时间
    orders.setOrderTime(LocalDateTime.now());
    //设置付款时间
    orders.setCheckoutTime(LocalDateTime.now());
    //设置实收金额
    AtomicInteger amount = new AtomicInteger(0);
    for(ShoppingCart shoppingCart : shoppingCartList) {
        amount.addAndGet(shoppingCart.getAmount().multiply(new BigDecimal(100)).multiply(new BigDecimal(shoppingCart.getNumber())).intValue());
    }
    orders.setAmount(BigDecimal.valueOf(amount.get()));
    //设置用户信息
    User user = userService.getById(userId);
    orders.setPhone(addressBook.getPhone());
    orders.setAddress(addressBook.getDetail());
    orders.setUserName(user.getPhone());
    orders.setConsignee(addressBook.getConsignee());
    //保存单条订单信息
    this.save(orders);
    //设置订单详细信息
    List<OrderDetail> orderDetailList = new ArrayList<>();
    for(ShoppingCart shoppingCart : shoppingCartList) {
        OrderDetail orderDetail = new OrderDetail();
        orderDetail.setName(shoppingCart.getName());
        orderDetail.setImage(shoppingCart.getImage());
        orderDetail.setOrderId(orderId);
        orderDetail.setDishId(shoppingCart.getDishId());
        orderDetail.setSetmealId(shoppingCart.getSetmealId());
        orderDetail.setDishFlavor(shoppingCart.getDishFlavor());
        orderDetail.setNumber(shoppingCart.getNumber());
        AtomicInteger detailAmount = new AtomicInteger(0);
        detailAmount.addAndGet(shoppingCart.getAmount().multiply(new BigDecimal(shoppingCart.getNumber())).intValue());
        orderDetail.setAmount(BigDecimal.valueOf(detailAmount.get()));
        orderDetailList.add(orderDetail);
    }
    //批量保存订单详细数据
    orderDetailService.saveBatch(orderDetailList);
    //清空购物车数据
    shoppingCartService.remove(SCLqw);
    
    //设置延迟队列，过期时间为5分钟
    log.info("订单编号：{}进入延迟队列...",orders.getNumber());
    delayProducer.publish(orders.getNumber(),String.valueOf(orders.getId()),
            DelayMessageConfig.DELAY_EXCHANGE_NAME,DelayMessageConfig.ROUTING_KEY_ORDER,1000*60*5);
            
    return orders;
}

/**
* 监听订单延迟队列
* @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("消息接收失败，重新入队");
    }
}

/**
* 商户主动查询订单状态
* 当核实到订单超时未支付则取消订单
* 当核实到订单已支付则更新订单状态
*/
@Transactional(rollbackFor = Exception.class)
@Override
public void checkOrderStatus(String orderNo) throws Exception {
    log.info("根据订单号核实订单状态==>{}",orderNo);
    
    log.info("在数据库中查询订单状态....");
    Integer status = ordersService.getOrderStatus(orderNo);
    if(status != 1) {
        //订单不是”未支付“状态
        log.info("订单不是”未支付“状态，无需进行进一步处理");
        return;
    }
    
    String result = this.queryOrder(orderNo);
    Gson gson = new Gson();
    Map<String,String> map = gson.fromJson(result, HashMap.class);
    
    //获取订单状态
    String tradeState = map.get("trade_state");
    //判断订单状态
    if(WxTradeState.NOTPAY.getType().equals(tradeState)) {
        log.info("核实到订单超时未支付==>{}",orderNo);
        //关闭订单
        log.info("订单已自动取消");
        this.closeOrder(orderNo);
        //更新本地订单状态
        ordersService.updateStatusByOrderNo(orderNo,"5");
    }
    else if(WxTradeState.SUCCESS.getType().equals(tradeState)) {
        log.info("核实到订单已支付==>{}",orderNo);
        Integer orderStatus = ordersService.getOrderStatus(orderNo);
        if(orderStatus != null && orderStatus != 2) {
            //更新本地订单状态
            ordersService.updateStatusByOrderNo(orderNo,"2");
            //保存订单记录
            paymentInfoService.saveInfo(result);
        }
    }
    else if(WxTradeState.CLOSED.getType().equals(tradeState)) {
        log.info("核实到订单已取消==>{}",orderNo);
        Integer orderStatus = ordersService.getOrderStatus(orderNo);
        if(orderStatus != null && orderStatus != 5) {
            //更新本地订单状态
            ordersService.updateStatusByOrderNo(orderNo,"5");
            //保存订单记录
            paymentInfoService.saveInfo(result);
        }
    }
}

/**
* 查询订单
* @param orderNo
* @return
*/
@Override
public String queryOrder(String orderNo) throws Exception {
    log.info("查单接口调用===>{}",orderNo);
    //构建请求链接
    String url = String.format(WxApiType.ORDER_QUERY_BY_NO.getType(),orderNo);
    url = wxPayConfig.getDomain().concat(url).concat("?mchid=").concat(wxPayConfig.getMchId());
    URIBuilder uriBuilder = new URIBuilder(url);
    HttpGet httpGet = new HttpGet(uriBuilder.build());
    httpGet.addHeader("Accept","application/json");

    CloseableHttpResponse response = wxPayClient.execute(httpGet);
    
    return EntityUtils.toString(response.getEntity());
}