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());
|
}
|
}
|
|
}
|
}
|
