package com.panzhihua.service_community.message;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.panzhihua.common.model.vos.shop.ComShopFlowerOrderVO;
import com.panzhihua.service_community.dao.ComShopFlowerOrderDAO;
import com.panzhihua.service_community.dao.ComShopFlowerOrderGoodsDAO;
import com.panzhihua.service_community.dao.RentingHourseOrderDao;
import com.panzhihua.service_community.dao.RentingHourseRegisterDao;
import com.panzhihua.service_community.entity.RentingHourseOrder;
import com.panzhihua.service_community.entity.RentingHourseRegister;
import com.panzhihua.service_community.model.dos.ComShopFlowerOrderDO;
import com.panzhihua.service_community.model.dos.ComShopFlowerOrderGoodsDO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

import static java.util.Objects.nonNull;

/**
 * @author yh
 * 商城订单处理
 */
@Component
@Slf4j
public class ShopOrderMessage {
    public static final String DELAYED_QUEUE="huacheng.shop.order.queue";

    @Resource
    private ComShopFlowerOrderDAO comShopFlowerOrderDAO;
    @Resource
    private ComShopFlowerOrderGoodsDAO comShopFlowerOrderGoodsDAO;

    @RabbitListener(queues=DELAYED_QUEUE)
    public void cancelOrder(ComShopFlowerOrderVO shopOrderVO){
        ComShopFlowerOrderDO comShopFlowerOrderDO = comShopFlowerOrderDAO.selectById(shopOrderVO.getOrderId());
        if (nonNull(comShopFlowerOrderDO)){
            //30分钟未付款删除订单
            if (comShopFlowerOrderDO.getStatus() == ComShopFlowerOrderDO.status.dfk){
                log.info("30分钟超时未支付订单进行删除");
                comShopFlowerOrderGoodsDAO.delete(new LambdaQueryWrapper<ComShopFlowerOrderGoodsDO>().eq(ComShopFlowerOrderGoodsDO::getOrderId, shopOrderVO.getOrderId()));
                comShopFlowerOrderDAO.deleteById(shopOrderVO.getOrderId());
            }
        }

    }
}