/**
* 提交訂單
* @param orders
* @param session
*/
@Override
@Transactional
public Orders createOrder(Orders orders, HttpSession session) {
    //獲取當前用戶信息
    Long userId = (Long) session.getAttribute("user");
    //查詢地址數(shù)據(jù)
    Long addressBookId = orders.getAddressBookId();
    AddressBook addressBook = addressBookService.getById(addressBookId);
    if(addressBook == null) {
        throw new CustomException("用戶地址信息有誤，不能下單");
    }
    //獲取當前用戶購物車數(shù)據(jù)
    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));
    //設置訂單狀態(tài)(待付款)
    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);
    }
    //批量保存訂單詳細數(shù)據(jù)
    orderDetailService.saveBatch(orderDetailList);
    //清空購物車數(shù)據(jù)
    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;
}

/**
* 監(jiān)聽訂單延遲隊列
* @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);
        //告訴服務器收到這條消息 已經(jīng)被我消費了 可以在隊列刪掉 這樣以后就不會再發(fā)了 否則消息服務器以為這條消息沒處理掉 后續(xù)還會在發(fā)
        channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
        log.info("消息接收成功");
    } catch (Exception e) {
        e.printStackTrace();
        //消息重新入隊
        channel.basicNack(message.getMessageProperties().getDeliveryTag(), false,true);
        log.info("消息接收失敗，重新入隊");
    }
}

/**
* 商戶主動查詢訂單狀態(tài)
* 當核實到訂單超時未支付則取消訂單
* 當核實到訂單已支付則更新訂單狀態(tài)
*/
@Transactional(rollbackFor = Exception.class)
@Override
public void checkOrderStatus(String orderNo) throws Exception {
    log.info("根據(jù)訂單號核實訂單狀態(tài)==>{}",orderNo);
    
    log.info("在數(shù)據(jù)庫中查詢訂單狀態(tài)....");
    Integer status = ordersService.getOrderStatus(orderNo);
    if(status != 1) {
        //訂單不是”未支付“狀態(tài)
        log.info("訂單不是”未支付“狀態(tài)，無需進行進一步處理");
        return;
    }
    
    String result = this.queryOrder(orderNo);
    Gson gson = new Gson();
    Map<String,String> map = gson.fromJson(result, HashMap.class);
    
    //獲取訂單狀態(tài)
    String tradeState = map.get("trade_state");
    //判斷訂單狀態(tài)
    if(WxTradeState.NOTPAY.getType().equals(tradeState)) {
        log.info("核實到訂單超時未支付==>{}",orderNo);
        //關(guān)閉訂單
        log.info("訂單已自動取消");
        this.closeOrder(orderNo);
        //更新本地訂單狀態(tài)
        ordersService.updateStatusByOrderNo(orderNo,"5");
    }
    else if(WxTradeState.SUCCESS.getType().equals(tradeState)) {
        log.info("核實到訂單已支付==>{}",orderNo);
        Integer orderStatus = ordersService.getOrderStatus(orderNo);
        if(orderStatus != null && orderStatus != 2) {
            //更新本地訂單狀態(tài)
            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) {
            //更新本地訂單狀態(tài)
            ordersService.updateStatusByOrderNo(orderNo,"5");
            //保存訂單記錄
            paymentInfoService.saveInfo(result);
        }
    }
}

/**
* 查詢訂單
* @param orderNo
* @return
*/
@Override
public String queryOrder(String orderNo) throws Exception {
    log.info("查單接口調(diào)用===>{}",orderNo);
    //構(gòu)建請求鏈接
    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());
}