/**
* 提交訂單
* @param orders
* @param session
*/
@Override
@Transactional
public Orders createOrder(Orders orders, HttpSession session) {
    //獲取當(dāng)前用戶信息
    Long userId = (Long) session.getAttribute("user");
    //查詢地址數(shù)據(jù)
    Long addressBookId = orders.getAddressBookId();
    AddressBook addressBook = addressBookService.getById(addressBookId);
    if(addressBook == null) {
        throw new CustomException("用戶地址信息有誤，不能下單");
    }
    //獲取當(dāng)前用戶購(gòu)物車數(shù)據(jù)
    LambdaQueryWrapper<ShoppingCart> SCLqw = new LambdaQueryWrapper<>();
    SCLqw.eq(ShoppingCart::getUserId,userId);
    List<ShoppingCart> shoppingCartList = shoppingCartService.list(SCLqw);
    //生成訂單號(hào)
    long orderId = IdWorker.getId();
    //設(shè)置訂單號(hào)
    orders.setNumber(String.valueOf(orderId));
    //設(shè)置訂單狀態(tài)(待付款)
    orders.setStatus(1);
    //設(shè)置下單用戶id
    orders.setUserId(userId);
    //設(shè)置下單時(shí)間
    orders.setOrderTime(LocalDateTime.now());
    //設(shè)置付款時(shí)間
    orders.setCheckoutTime(LocalDateTime.now());
    //設(shè)置實(shí)收金額
    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()));
    //設(shè)置用戶信息
    User user = userService.getById(userId);
    orders.setPhone(addressBook.getPhone());
    orders.setAddress(addressBook.getDetail());
    orders.setUserName(user.getPhone());
    orders.setConsignee(addressBook.getConsignee());
    //保存單條訂單信息
    this.save(orders);
    //設(shè)置訂單詳細(xì)信息
    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);
    }
    //批量保存訂單詳細(xì)數(shù)據(jù)
    orderDetailService.saveBatch(orderDetailList);
    //清空購(gòu)物車數(shù)據(jù)
    shoppingCartService.remove(SCLqw);
    
    //設(shè)置延遲隊(duì)列，過期時(shí)間為5分鐘
    log.info("訂單編號(hào)：{}進(jìn)入延遲隊(duì)列...",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)聽訂單延遲隊(duì)列
* @param orderNo
* @throws Exception
*/
@RabbitListener(queues = {"plugin.delay.order.queue"})
public void orderDelayQueue(String orderNo, Message message, Channel channel) throws Exception {
    log.info("訂單延遲隊(duì)列開始消費(fèi)...");
    try {
        //處理訂單
        wxPayService.checkOrderStatus(orderNo);
        //告訴服務(wù)器收到這條消息 已經(jīng)被我消費(fèi)了 可以在隊(duì)列刪掉 這樣以后就不會(huì)再發(fā)了 否則消息服務(wù)器以為這條消息沒處理掉 后續(xù)還會(huì)在發(fā)
        channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
        log.info("消息接收成功");
    } catch (Exception e) {
        e.printStackTrace();
        //消息重新入隊(duì)
        channel.basicNack(message.getMessageProperties().getDeliveryTag(), false,true);
        log.info("消息接收失敗，重新入隊(duì)");
    }
}

/**
* 商戶主動(dòng)查詢訂單狀態(tài)
* 當(dāng)核實(shí)到訂單超時(shí)未支付則取消訂單
* 當(dāng)核實(shí)到訂單已支付則更新訂單狀態(tài)
*/
@Transactional(rollbackFor = Exception.class)
@Override
public void checkOrderStatus(String orderNo) throws Exception {
    log.info("根據(jù)訂單號(hào)核實(shí)訂單狀態(tài)==>{}",orderNo);
    
    log.info("在數(shù)據(jù)庫(kù)中查詢訂單狀態(tài)....");
    Integer status = ordersService.getOrderStatus(orderNo);
    if(status != 1) {
        //訂單不是”未支付“狀態(tài)
        log.info("訂單不是”未支付“狀態(tài)，無(wú)需進(jìn)行進(jìn)一步處理");
        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("核實(shí)到訂單超時(shí)未支付==>{}",orderNo);
        //關(guān)閉訂單
        log.info("訂單已自動(dòng)取消");
        this.closeOrder(orderNo);
        //更新本地訂單狀態(tài)
        ordersService.updateStatusByOrderNo(orderNo,"5");
    }
    else if(WxTradeState.SUCCESS.getType().equals(tradeState)) {
        log.info("核實(shí)到訂單已支付==>{}",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("核實(shí)到訂單已取消==>{}",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)建請(qǐng)求鏈接
    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());
}