diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/abstractStrategyRouter.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/abstractStrategyRouter.java
index 51ad3d5..9da9691 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/abstractStrategyRouter.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/abstractStrategyRouter.java
@@ -46,7 +46,11 @@ public abstract class abstractStrategyRouter<T,R> {
      * @return 策略处理结果
      */
     public R applyStrategy(T param) {
-        final StrategyHandler<T,R> strategyHandler = registerStrategy().getHandler(param);
+        StrategyMapper<T, R> trStrategyMapper = registerStrategy();
+        if (trStrategyMapper == null) {
+            return defaultStrategyHandler.apply(param);
+        }
+        final StrategyHandler<T,R> strategyHandler = trStrategyMapper.getHandler(param);
         if (strategyHandler != null) {
             return strategyHandler.apply(param);
         }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/DataProcessStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/DataProcessStrategy.java
index 5babcd9..d6b3460 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/DataProcessStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/DataProcessStrategy.java
@@ -29,6 +29,6 @@ public class DataProcessStrategy extends abstractStrategyRouter<Temporary1, Temp
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FaultJudgmentStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FaultJudgmentStrategy.java
index 3962d49..14f5c32 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FaultJudgmentStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FaultJudgmentStrategy.java
@@ -30,6 +30,6 @@ public class FaultJudgmentStrategy extends abstractStrategyRouter<Temporary1, Te
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FaultProcessingStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FaultProcessingStrategy.java
index 50d968e..faf1abc 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FaultProcessingStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FaultProcessingStrategy.java
@@ -29,6 +29,6 @@ public class FaultProcessingStrategy  extends abstractStrategyRouter<Temporary1,
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FenceJudgmentStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FenceJudgmentStrategy.java
index b1dc6b9..e8a7280 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FenceJudgmentStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FenceJudgmentStrategy.java
@@ -30,6 +30,6 @@ public class FenceJudgmentStrategy extends abstractStrategyRouter<Temporary1, Te
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FenceProcessingStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FenceProcessingStrategy.java
index 41f4587..e7046a3 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FenceProcessingStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/FenceProcessingStrategy.java
@@ -28,6 +28,6 @@ public class FenceProcessingStrategy extends abstractStrategyRouter<Temporary1,
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/RealTimeJudgmentStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/RealTimeJudgmentStrategy.java
index a7c378e..75291ef 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/RealTimeJudgmentStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/RealTimeJudgmentStrategy.java
@@ -30,6 +30,6 @@ public class RealTimeJudgmentStrategy extends abstractStrategyRouter<Temporary1,
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/RealTimeProcessingStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/RealTimeProcessingStrategy.java
index 771badc..cab608a 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/RealTimeProcessingStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/RealTimeProcessingStrategy.java
@@ -28,6 +28,6 @@ public class RealTimeProcessingStrategy extends abstractStrategyRouter<Temporary
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/WarningJudgmentStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/WarningJudgmentStrategy.java
index 32c32c0..c26ee7e 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/WarningJudgmentStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/WarningJudgmentStrategy.java
@@ -30,6 +30,6 @@ public class WarningJudgmentStrategy extends abstractStrategyRouter<Temporary1,
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/WarningProcessingStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/WarningProcessingStrategy.java
index 0f959bf..4330cf7 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/WarningProcessingStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/branch/WarningProcessingStrategy.java
@@ -28,6 +28,6 @@ public class WarningProcessingStrategy extends abstractStrategyRouter<Temporary1
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/core/BasicStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/core/BasicStrategy.java
index 5239235..dc98483 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/core/BasicStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/core/BasicStrategy.java
@@ -28,6 +28,6 @@ public class BasicStrategy extends abstractStrategyRouter<Temporary1, Temporary2
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/core/RoutingStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/core/RoutingStrategy.java
index e00d1ab..5adca69 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/core/RoutingStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/core/RoutingStrategy.java
@@ -34,6 +34,6 @@ public class RoutingStrategy   extends abstractStrategyRouter<Temporary1, Tempor
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/core/StartStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/core/StartStrategy.java
index 1154346..f6ed921 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/core/StartStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/core/StartStrategy.java
@@ -18,16 +18,18 @@ import org.springframework.stereotype.Component;
  *                                 ↓
  *                             基础校验节点
  *                                 ↓
- *                              路由节点
+ *                              路由节点    ←      ←        ←        ←      ←    ←
  *          ↙           ↙          ↓       ↘       ↘
- *   数据处理节点 预警处理节点 故障处理节点 围栏处理节点 实时数据数据处理节点
- *      ↓           ↓          ↓        ↓           ↓
- * 数据持久化处理节点 预警处理节点 故障处理节点 围栏处理节点 实时数据数据处理节点
- *      ↓           ↓          ↓        ↓           ↓
- *      ↓     预警通知节点 故障通知节点 围栏通知节点 实时数据处理节点
- *      ↓           ↘          ↓        ↙           ↙
- *      ↓                      ↓
- *       →      →     →     结束节点
+ *     数据处理节点 预警处理节点 故障处理节点 围栏处理节点 实时数据数据处理节点             ↑
+ *         ↓           ↓          ↓        ↓           ↓
+ *  数据持久化处理节点 预警处理节点 故障处理节点 围栏处理节点 实时数据数据处理节点           ↑
+ *         ↓           ↓          ↓        ↓           ↓
+ *         ↓     预警通知节点 故障通知节点 围栏通知节点 实时数据处理节点                 ↑
+ *         ↓           ↘          ↓        ↙           ↙
+ *         ↓                      ↓                                            ↑
+ *         →      →     →      路由节点     →      →     →       →      →     →
+ *                                ↓
+ *                             结束节点
  */
 
 @Slf4j
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/DataStorageStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/DataStorageStrategy.java
index 77fe018..5ead80e 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/DataStorageStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/DataStorageStrategy.java
@@ -29,6 +29,6 @@ public class DataStorageStrategy extends abstractStrategyRouter<Temporary1, Temp
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/FaultAlarmStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/FaultAlarmStrategy.java
index 83a6ed2..b6aaddc 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/FaultAlarmStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/FaultAlarmStrategy.java
@@ -29,6 +29,6 @@ public class FaultAlarmStrategy extends abstractStrategyRouter<Temporary1, Tempo
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/FenceAlarmStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/FenceAlarmStrategy.java
index 8779c59..563f304 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/FenceAlarmStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/FenceAlarmStrategy.java
@@ -29,6 +29,6 @@ public class FenceAlarmStrategy extends abstractStrategyRouter<Temporary1, Tempo
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/RealTimeAlarmStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/RealTimeAlarmStrategy.java
index e515c41..928eeda 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/RealTimeAlarmStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/RealTimeAlarmStrategy.java
@@ -29,6 +29,6 @@ public class RealTimeAlarmStrategy extends abstractStrategyRouter<Temporary1, Te
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }
diff --git a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/WarningAlarmStrategy.java b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/WarningAlarmStrategy.java
index d47dde6..dbfec6f 100644
--- a/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/WarningAlarmStrategy.java
+++ b/cloud-data-processing/src/main/java/com/muyu/data/processing/strategy/leaves/WarningAlarmStrategy.java
@@ -29,6 +29,6 @@ public class WarningAlarmStrategy extends abstractStrategyRouter<Temporary1, Tem
 
     @Override
     public Temporary2 apply(Temporary1 temporary1) {
-        return null;
+        return applyStrategy(temporary1);
     }
 }