diff --git a/vehicle-history-server/pom.xml b/vehicle-history-server/pom.xml index 3a43f87..b34d31c 100644 --- a/vehicle-history-server/pom.xml +++ b/vehicle-history-server/pom.xml @@ -77,6 +77,11 @@ dragon-common-log + + com.dragon + dragon-common-redis + + com.dragon dragon-common-core diff --git a/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/controller/CarController.java b/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/controller/CarController.java index 2a8b286..832204c 100644 --- a/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/controller/CarController.java +++ b/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/controller/CarController.java @@ -5,6 +5,7 @@ import com.dragon.common.core.domain.PageResult; import com.dragon.vehicle.history.common.domain.Car; import com.dragon.vehicle.history.common.domain.CarType; import com.dragon.vehicle.history.common.domain.Fence; +import com.dragon.vehicle.history.common.domain.VehicleData; import com.dragon.vehicle.history.common.domain.req.ReqCar; import com.dragon.vehicle.history.common.domain.res.ResCar; import com.dragon.vehicle.history.server.service.CarService; @@ -80,4 +81,14 @@ public class CarController { public Result> listFence() { return carService.listFence(); } + + /** + * 添加实时轨迹事件 + * @param vin + * @return + */ + @PostMapping("/realTime") + public Result realTime(String vin){ + return carService.realTime(vin); + } } diff --git a/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/controller/HistoricalTrackController.java b/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/controller/HistoricalTrackController.java index 0ab8563..dca5890 100644 --- a/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/controller/HistoricalTrackController.java +++ b/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/controller/HistoricalTrackController.java @@ -26,7 +26,7 @@ public class HistoricalTrackController { * 历史轨迹列表 * @return */ - @PostMapping("/listHistoricalTrack") + @GetMapping("/listHistoricalTrack") @DS(value = "slave") public Result> listHistoricalTrack() { return Result.success(historicalTrackService.listHistoricalTrack()); diff --git a/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/service/CarService.java b/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/service/CarService.java index 395528d..46cc4ea 100644 --- a/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/service/CarService.java +++ b/vehicle-history-server/src/main/java/com/dragon/vehicle/history/server/service/CarService.java @@ -54,4 +54,11 @@ public interface CarService { * @return */ Result> listFence(); + + /** + * 添加实时轨迹事件 + * @param vin + * @return + */ + Result realTime(String vin); } 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 95889e4..285a054 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 @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.dragon.common.core.domain.PageResult; import com.dragon.common.core.domain.Result; +import com.dragon.common.redis.service.RedisService; import com.dragon.vehicle.history.common.domain.Car; import com.dragon.vehicle.history.common.domain.CarType; import com.dragon.vehicle.history.common.domain.Fence; @@ -35,6 +36,8 @@ public class CarServiceImpl implements CarService { private CarTypeMapper carTypeMapper; @Autowired private FenceMapper fenceMapper; + @Autowired + private RedisService redisService; /** * 车辆信息列表 @@ -126,4 +129,18 @@ public class CarServiceImpl implements CarService { List fences = fenceMapper.selectList(new MPJLambdaWrapper().select(Fence::getFenceId,Fence::getFenceName)); return Result.success(fences); } + + /** + * 添加实时轨迹事件 + * @param vin + * @return + */ + @Override + public Result realTime(String vin) { + List cacheList = redisService.getCacheList(vin);//根据vin查询出车辆的事件列表 + cacheList.add("runtimeTraceEvent");//添加实时轨迹事件 + redisService.setCacheList("event_"+vin,cacheList);//将事件列表存入redis + + return Result.success("事件添加成功!"); + } }