From 3974fad5d836431e417e99220cc07bb5b0aba331 Mon Sep 17 00:00:00 2001
From: zhangback <zhangback@163.com>
Date: 星期一, 08 十二月 2025 14:16:16 +0800
Subject: [PATCH] 提交
---
tms/src/main/java/com/ruoyi/tms/consumer/CarKeyExpireConsumer.java | 31 +++++++++++++++++++++++++++++++
1 files changed, 31 insertions(+), 0 deletions(-)
diff --git a/tms/src/main/java/com/ruoyi/tms/consumer/CarKeyExpireConsumer.java b/tms/src/main/java/com/ruoyi/tms/consumer/CarKeyExpireConsumer.java
new file mode 100644
index 0000000..caac680
--- /dev/null
+++ b/tms/src/main/java/com/ruoyi/tms/consumer/CarKeyExpireConsumer.java
@@ -0,0 +1,31 @@
+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)
+ );
+ }
+ }
+}
--
Gitblit v1.8.0