fix: 解决责任树测试死循环问题

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

@@ -1,6 +1,6 @@
 package com.muyu.data.processing.strategy.leaves;
 
-import com.muyu.data.processing.domain.BasicData;
+import com.muyu.common.caffeine.enums.CacheNameEnums;import com.muyu.data.processing.domain.BasicData;
 import java.util.HashMap;
 import java.util.List;
 import com.muyu.data.processing.domain.Temporary2;
@@ -32,6 +32,7 @@ public class DataStorageStrategy extends abstractStrategyRouter<HashMap<String,
     @Override
     public Temporary2 apply(HashMap<String, BasicData> basicDataMap) {
         log.info("数据持久化节点已通过。。。");
+        basicDataMap.remove(CacheNameEnums.STORAGE.getCode());
         return applyStrategy(basicDataMap);
     }
 }

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

@@ -1,5 +1,6 @@
 package com.muyu.data.processing.strategy.leaves;
 
+import com.muyu.common.caffeine.enums.CacheNameEnums;
 import com.muyu.data.processing.domain.BasicData;
 import java.util.HashMap;
 import java.util.List;
@@ -32,6 +33,7 @@ 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

@@ -1,5 +1,6 @@
 package com.muyu.data.processing.strategy.leaves;
 
+import com.muyu.common.caffeine.enums.CacheNameEnums;
 import com.muyu.data.processing.domain.BasicData;
 import java.util.HashMap;
 import java.util.List;
@@ -32,6 +33,7 @@ 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

@@ -1,5 +1,6 @@
 package com.muyu.data.processing.strategy.leaves;
 
+import com.muyu.common.caffeine.enums.CacheNameEnums;
 import com.muyu.data.processing.domain.BasicData;
 import java.util.HashMap;
 import java.util.List;
@@ -32,6 +33,7 @@ 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

@@ -1,5 +1,6 @@
 package com.muyu.data.processing.strategy.leaves;
 
+import com.muyu.common.caffeine.enums.CacheNameEnums;
 import com.muyu.data.processing.domain.BasicData;
 import java.util.HashMap;
 import java.util.List;
@@ -32,6 +33,7 @@ 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);
     }
 }