feat: 优化路由逻辑

cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/core/RoutingStrategy.java

@@ -41,6 +41,7 @@ public class RoutingStrategy   extends abstractStrategyRouter<HashMap<String, Ba
             List<String> codes = CacheNameEnums.getCodes();
             for (String code : codes) {
                 if(param.containsKey(code)){
+                    param.remove(code);
                     return map.get(code);
                 }
             }

cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/DataStorageStrategy.java

@@ -35,8 +35,6 @@ import org.springframework.stereotype.Component;
 public class DataStorageStrategy extends abstractStrategyRouter<HashMap<String, BasicData>, Temporary2>
         implements StrategyHandler<HashMap<String, BasicData>, Temporary2> {
 
-    private SessionPool sessionPool = new IotDBSessionConfig().getSessionPool();
-
     @Override
     protected StrategyMapper<HashMap<String, BasicData>, Temporary2> registerStrategy() {
         return param -> {
@@ -47,7 +45,6 @@ public class DataStorageStrategy extends abstractStrategyRouter<HashMap<String,
 
     @Override
     public Temporary2 apply(HashMap<String, BasicData> basicDataMap) {
-        basicDataMap.remove(CacheNameEnums.STORAGE.getCode());
         // 执行持久化方法
         addCarData(basicDataMap);
         return applyStrategy(basicDataMap);
@@ -82,7 +79,7 @@ public class DataStorageStrategy extends abstractStrategyRouter<HashMap<String,
                 .append(values.substring(0, values.length() - 1))
                 .append(")");
         try {
-            sessionPool.executeNonQueryStatement(sql.toString());
+            new IotDBSessionConfig().getSessionPool().executeNonQueryStatement(sql.toString());
         } catch (StatementExecutionException e) {
             throw new RuntimeException(e);
         } catch (IoTDBConnectionException e) {

cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/FaultAlarmStrategy.java

@@ -33,7 +33,6 @@ public class FaultAlarmStrategy extends abstractStrategyRouter<HashMap<String, B
     @Override
     public Temporary2 apply(HashMap<String, BasicData> basicDataMap) {
         log.info("故障报警节点已通过。。。");
-        basicDataMap.remove(CacheNameEnums.FAULT.getCode());
         return applyStrategy(basicDataMap);
     }
 }

cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/FenceAlarmStrategy.java

@@ -33,7 +33,6 @@ public class FenceAlarmStrategy extends abstractStrategyRouter<HashMap<String, B
     @Override
     public Temporary2 apply(HashMap<String, BasicData> basicDataMap) {
         log.info("围栏报警节点已通过。。。");
-        basicDataMap.remove(CacheNameEnums.FENCE.getCode());
         return applyStrategy(basicDataMap);
     }
 }

cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/RealTimeAlarmStrategy.java

@@ -33,7 +33,6 @@ public class RealTimeAlarmStrategy extends abstractStrategyRouter<HashMap<String
     @Override
     public Temporary2 apply(HashMap<String, BasicData> basicDataMap) {
         log.info("实时数据处理节点已通过。。。");
-        basicDataMap.remove(CacheNameEnums.REALTIME.getCode());
         return applyStrategy(basicDataMap);
     }
 }

cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/WarningAlarmStrategy.java

@@ -33,7 +33,6 @@ public class WarningAlarmStrategy extends abstractStrategyRouter<HashMap<String,
     @Override
     public Temporary2 apply(HashMap<String, BasicData> basicDataMap) {
         log.info("预警报警节点已通过。。。");
-        basicDataMap.remove(CacheNameEnums.WARMING.getCode());
         return applyStrategy(basicDataMap);
     }
 }