package com.ruoyi.tms.consumer;
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.ruoyi.tms.domain.TmsCarKeyDispatch;
|
import com.ruoyi.tms.mapper.TmsCarKeyDispatchMapper;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
|
@Slf4j
|
@Component
|
public class CarKeyExpireConsumer {
|
|
@Resource
|
private TmsCarKeyDispatchMapper tmsCarKeyDispatchMapper;
|
|
@RabbitListener(queues = "car_key_dead_queue")
|
public void handle(Integer carKeyId) {
|
|
TmsCarKeyDispatch tmsCarKeyDispatch = tmsCarKeyDispatchMapper.selectTmsCarKeyDispatchById(carKeyId);
|
if (tmsCarKeyDispatch != null && tmsCarKeyDispatch.getStatus() == 0){
|
log.info("超时领取钥匙：{}", carKeyId);
|
tmsCarKeyDispatchMapper.update(new LambdaUpdateWrapper<TmsCarKeyDispatch>()
|
.eq(TmsCarKeyDispatch::getId, carKeyId)
|
.set(TmsCarKeyDispatch::getStatus, 2)
|
);
|
}
|
}
|
}
|
