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("添加事件成功!"); }