修复空指针

src/main/java/com/shkpr/service/aimodelpower/components/ModelPredictor.java

@@ -114,6 +114,7 @@ public class ModelPredictor {
             ModelPredictorDay predictorDay = new ModelPredictorDay(orgConfig.getOrgId(), startTime.toString(), endTime.toString());
             //发送请求
             ModelPredictorResult startResult = asyncRequestUtil.start(predictProperties.getUrl() + predictDayWaterUri, predictorDay);
+            if (startResult == null) return;
 
             //任务id
             String taskId = (String) startResult.getKeyValue();
@@ -175,6 +176,7 @@ public class ModelPredictor {
 
                 //发送请求
                 ModelPredictorResult startResult = asyncRequestUtil.start(predictProperties.getUrl() + predictHourWaterUri, predictorHour);
+                if (startResult == null) return;
 
                 //任务id
                 String taskId = (String) startResult.getKeyValue();
@@ -273,6 +275,7 @@ public class ModelPredictor {
             ModelPredictorTrain predictorDay = new ModelPredictorTrain(orgConfig.getOrgId());
             //发送请求
             ModelPredictorResult startResult = asyncRequestUtil.start(predictProperties.getUrl() + trainDayWaterUri, predictorDay);
+            if (startResult == null) return;
 
             //任务id
             String taskId = (String) startResult.getKeyValue();
@@ -324,6 +327,7 @@ public class ModelPredictor {
             ModelPredictorTrain predictorDay = new ModelPredictorTrain(orgConfig.getOrgId());
             //发送请求
             ModelPredictorResult startResult = asyncRequestUtil.start(predictProperties.getUrl() + trainHourWaterUri, predictorDay);
+            if (startResult == null) return;
 
             //任务id
             String taskId = (String) startResult.getKeyValue();
@@ -385,6 +389,7 @@ public class ModelPredictor {
 
                 //发送请求
                 ModelPredictorResult startResult = asyncRequestUtil.start(predictProperties.getUrl() + predictHourPumpUri, predictorHour);
+                if (startResult == null) return;
 
                 //任务id
                 String taskId = (String) startResult.getKeyValue();