package com.panzhihua.service_community.message;
|
|
import com.panzhihua.common.model.vos.community.rentHouse.RentingHoursePreOrderVO;
|
import com.panzhihua.service_community.dao.RentingHourseOrderDao;
|
import com.panzhihua.service_community.dao.RentingHoursePreOrderDao;
|
import com.panzhihua.service_community.dao.RentingHourseRegisterDao;
|
import com.panzhihua.service_community.entity.RentingHourseOrder;
|
import com.panzhihua.service_community.entity.RentingHoursePreOrder;
|
import com.panzhihua.service_community.entity.RentingHourseRegister;
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
|
/**
|
* @author zzj
|
*/
|
@Component
|
public class OrderMessage {
|
public static final String DELAYED_QUEUE="huacheng.order.queue";
|
|
@Resource
|
private RentingHourseOrderDao rentingHourseOrderDao;
|
@Resource
|
private RentingHourseRegisterDao rentingHourseRegisterDao;
|
@RabbitListener(queues=DELAYED_QUEUE)
|
public void cancelProOrder(RentingHourseOrder rentingHourseOrderVO){
|
RentingHourseOrder rentingHourseOrder=rentingHourseOrderDao.selectById(rentingHourseOrderVO.getId());
|
if(rentingHourseOrder!=null){
|
if(rentingHourseOrder.getStatus().equals(rentingHourseOrderVO.getStatus())){
|
rentingHourseOrder.setStatus(RentingHourseOrder.status.ytk);
|
rentingHourseOrderDao.updateById(rentingHourseOrder);
|
//超时修改房屋状态
|
RentingHourseRegister rentingHourseRegister=new RentingHourseRegister();
|
rentingHourseRegister.setId(rentingHourseOrder.getRegisterId());
|
rentingHourseRegister.setDetailStatus(3);
|
rentingHourseRegisterDao.updateById(rentingHourseRegister);
|
//退款逻辑待开发
|
}
|
}
|
}
|
}
|
