From f6eaf6b05f6ad72bfd1c7045db3c74841d3cb652 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=B0=91=E5=B9=B4=E6=A2=A6=E4=B8=8E=E7=A0=96?=
 <2847127106@qq.com>
Date: Mon, 30 Sep 2024 20:37:53 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E9=83=A8=E5=88=86=E8=A1=A5=E5=85=A8?=
 =?UTF-8?q?=E6=A1=86=E6=9E=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../strategy/abstractStrategyRouter.java      |  6 +++++-
 .../strategy/branch/DataProcessStrategy.java  |  2 +-
 .../branch/FaultJudgmentStrategy.java         |  2 +-
 .../branch/FaultProcessingStrategy.java       |  2 +-
 .../branch/FenceJudgmentStrategy.java         |  2 +-
 .../branch/FenceProcessingStrategy.java       |  2 +-
 .../branch/RealTimeJudgmentStrategy.java      |  2 +-
 .../branch/RealTimeProcessingStrategy.java    |  2 +-
 .../branch/WarningJudgmentStrategy.java       |  2 +-
 .../branch/WarningProcessingStrategy.java     |  2 +-
 .../strategy/core/BasicStrategy.java          |  2 +-
 .../strategy/core/RoutingStrategy.java        |  2 +-
 .../strategy/core/StartStrategy.java          | 20 ++++++++++---------
 .../strategy/leaves/DataStorageStrategy.java  |  2 +-
 .../strategy/leaves/FaultAlarmStrategy.java   |  2 +-
 .../strategy/leaves/FenceAlarmStrategy.java   |  2 +-
 .../leaves/RealTimeAlarmStrategy.java         |  2 +-
 .../strategy/leaves/WarningAlarmStrategy.java |  2 +-
 18 files changed, 32 insertions(+), 26 deletions(-)

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);
     }
 }