From e27077002925450fd1d8bb5d3c8ac3447d526d5f Mon Sep 17 00:00:00 2001
From: ffr <492210217@qq.com>
Date: Mon, 8 Apr 2024 10:55:33 +0800
Subject: [PATCH] fufanruiCommit

---
 .../common/redis/service/RedisService.java    |  6 ++++++
 .../VehicleDetectionController.java           | 21 +++++++++++++++++--
 .../service/VehicleDetectionService.java      |  3 +++
 .../impl/VehicleDetectionServiceImpl.java     |  6 ++++++
 4 files changed, 34 insertions(+), 2 deletions(-)

diff --git a/couplet-common/couplet-common-redis/src/main/java/com/couplet/common/redis/service/RedisService.java b/couplet-common/couplet-common-redis/src/main/java/com/couplet/common/redis/service/RedisService.java
index 67ec7c2..5a668a2 100644
--- a/couplet-common/couplet-common-redis/src/main/java/com/couplet/common/redis/service/RedisService.java
+++ b/couplet-common/couplet-common-redis/src/main/java/com/couplet/common/redis/service/RedisService.java
@@ -280,4 +280,10 @@ public class RedisService {
         String key  = "vin:"+realTimeDataRequest.getVin()+"userId:"+realTimeDataRequest.getUserId();
         redisTemplate.opsForValue().set(key, realTimeDataRequest);
     }
+
+    public void stopViewingData(Long userId,String vin) {
+
+        String key  = "vin:"+vin+"userId:"+userId;
+        redisTemplate.delete(key);
+    }
 }
diff --git a/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/controller/VehicleDetectionController.java b/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/controller/VehicleDetectionController.java
index 6031e71..15894bd 100644
--- a/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/controller/VehicleDetectionController.java
+++ b/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/controller/VehicleDetectionController.java
@@ -59,8 +59,13 @@ public class VehicleDetectionController {
         vehicleDetectionService.monitorinData(vin);
     }
 
-
-
+    /*
+     * @param :
+      * @return Result<List<CoupletVehicleData>>
+     * @author 付凡芮
+     * @description 查看事实数据列表
+     * @date
+     */
     @PostMapping("realData")
     public Result<List<CoupletVehicleData>> realData(){
         List<CoupletVehicleData> list = redisService.getList();
@@ -68,4 +73,16 @@ public class VehicleDetectionController {
         return success;
     }
 
+    /*
+     * @param vin:
+      * @return void
+     * @author 付凡芮
+     * @description 停止传送实时数据
+     * @date
+     */
+    @PostMapping("stopViewingData/{vin}")
+    public void stopViewingData(@PathVariable String vin){
+        vehicleDetectionService.stopViewingData(vin);
+    }
+
 }
diff --git a/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/VehicleDetectionService.java b/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/VehicleDetectionService.java
index a874703..9537c17 100644
--- a/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/VehicleDetectionService.java
+++ b/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/VehicleDetectionService.java
@@ -10,4 +10,7 @@ public interface VehicleDetectionService {
     List<Vehicle> detectionList();
 
     void monitorinData(String vin);
+
+
+    void stopViewingData(String vin);
 }
diff --git a/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/impl/VehicleDetectionServiceImpl.java b/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/impl/VehicleDetectionServiceImpl.java
index 00a0a9a..590d938 100644
--- a/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/impl/VehicleDetectionServiceImpl.java
+++ b/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/impl/VehicleDetectionServiceImpl.java
@@ -47,4 +47,10 @@ public class VehicleDetectionServiceImpl implements VehicleDetectionService{
 
     }
 
+    @Override
+    public void stopViewingData(String vin) {
+        Long userId = SecurityUtils.getUserId();
+        redisService.stopViewingData(userId,vin);
+    }
+
 }