package com.panzhihua.service_community.message;
|
|
import com.panzhihua.service_community.dao.McsOrderDao;
|
import com.panzhihua.service_community.entity.McsOrder;
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
|
/**
|
* @author zzj
|
*/
|
@Component
|
public class McsOrderMessage {
|
public static final String DELAYED_QUEUE="huacheng.mcsOrder.queue";
|
@Resource
|
private McsOrderDao mcsOrderDao;
|
@RabbitListener(queues=DELAYED_QUEUE)
|
public void cancelOrder(McsOrder mcsOrder){
|
McsOrder nowOrder=mcsOrderDao.selectById(mcsOrder.getId());
|
if(nowOrder.getStatus()==0){
|
mcsOrder.setStatus(2);
|
mcsOrderDao.updateById(mcsOrder);
|
}
|
}
|
}
|
