From ce10ed17842ac921ea6ab574936070282f1bd417 Mon Sep 17 00:00:00 2001 From: tangwenkang <2720983602@qq.com> Date: Tue, 5 Dec 2023 11:02:09 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E6=AF=953?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../vehicle/history/server/service/impl/CarServiceImpl.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/service/impl/CarServiceImpl.java b/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/service/impl/CarServiceImpl.java index 6c686f7..b49242f 100644 --- a/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/service/impl/CarServiceImpl.java +++ b/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/service/impl/CarServiceImpl.java @@ -17,6 +17,7 @@ import com.dragon.vehicle.history.server.mapper.FenceMapper; import com.dragon.vehicle.history.server.service.CarService; import com.github.yulichang.wrapper.MPJLambdaWrapper; import lombok.extern.log4j.Log4j2; +import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; @@ -40,8 +41,7 @@ public class CarServiceImpl implements CarService { @Autowired private RedisService redisService; @Autowired - private RedisTemplate redisTemplate; - + private RabbitTemplate rabbitTemplate; /** * 车辆信息列表 * @param reqCar 分页参数 @@ -143,6 +143,7 @@ public class CarServiceImpl implements CarService { List cacheList = redisService.getCacheList("event_"+vin);//根据vin查询出车辆的事件列表 cacheList.add("runtimeTraceEvent");//添加实时轨迹事件 redisService.setCacheList("event_"+vin,cacheList);//将事件列表存入redis + rabbitTemplate.convertAndSend("eventChange_queue",vin); return Result.success("添加事件成功！"); }