去掉启动依赖

examcloud-core-oe-task-starter/src/main/java/cn/com/qmth/examcloud/core/oe/task/starter/config/StreamTaskExecutor.java

@@ -1,6 +1,5 @@
 package cn.com.qmth.examcloud.core.oe.task.starter.config;
 
-import cn.com.qmth.examcloud.commons.exception.ExamCloudRuntimeException;
 import cn.com.qmth.examcloud.commons.helpers.pipeline.Node;
 import cn.com.qmth.examcloud.commons.helpers.pipeline.SimpleNode;
 import cn.com.qmth.examcloud.commons.helpers.pipeline.TaskContext;
@@ -12,17 +11,12 @@ import cn.com.qmth.examcloud.support.cache.CacheHelper;
 import cn.com.qmth.examcloud.support.cache.bean.SysPropertyCacheBean;
 import cn.com.qmth.examcloud.support.examing.ExamRecordData;
 import cn.com.qmth.examcloud.web.bootstrap.PropertyHolder;
-import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
-import org.springframework.cloud.client.ServiceInstance;
-import org.springframework.cloud.client.discovery.DiscoveryClient;
 import org.springframework.core.annotation.Order;
 import org.springframework.stereotype.Component;
 
-import java.util.List;
-
 /**
  * @Description 流式任务执行器
  * @Author lideyin
@@ -68,35 +62,21 @@ public class StreamTaskExecutor implements ApplicationRunner {
 
         node1.setFirst(true);
         node1.setLowerNode(node2);
-        SysPropertyCacheBean node1SleepProperty = CacheHelper.getSysProperty("oeTask.executor.gainExamData.sleep");
-        if (node1SleepProperty.getHasValue()) {
-            node1.setSleep(Integer.valueOf(node1SleepProperty.getValue().toString()));//单位秒
-        } else {
-            node1.setSleep(DEFAULT_GAIN_EXAM_DATA_EXECUTOR_SLEEP_SECONDS);//单位秒
-        }
+        node1.setSleep(PropertyHolder.getInt("oeTask.executor.gainExamData.sleep",
+                DEFAULT_GAIN_EXAM_DATA_EXECUTOR_SLEEP_SECONDS));//单位秒
 
         node2.setLowerNode(node3);
-		SysPropertyCacheBean node2SleepProperty = CacheHelper.getSysProperty("oeTask.executor.handInExam.sleep");
-		if (node2SleepProperty.getHasValue()) {
-			node2.setSleep(Integer.valueOf(node2SleepProperty.getValue().toString()));//单位秒
-		} else {
-			node2.setSleep(DEFAULT_HAND_IN_EXAM_EXECUTOR_SLEEP_SECONDS);//单位秒
-		}
+        SysPropertyCacheBean node2SleepProperty = CacheHelper.getSysProperty("oeTask.executor.handInExam.sleep");
+        node2.setSleep(PropertyHolder.getInt("oeTask.executor.gainExamData.sleep",
+                DEFAULT_HAND_IN_EXAM_EXECUTOR_SLEEP_SECONDS));//单位秒
 
         node3.setLowerNode(node4);
-		SysPropertyCacheBean node3SleepProperty = CacheHelper.getSysProperty("oeTask.executor.afterHandInExam.sleep");
-		if (node3SleepProperty.getHasValue()) {
-			node3.setSleep(Integer.valueOf(node3SleepProperty.getValue().toString()));//单位秒
-		} else {
-			node3.setSleep(DEFAULT_AFTER_HAND_IN_EXAM_EXECUTOR_SLEEP_SECONDS);//单位秒
-		}
-
-		SysPropertyCacheBean node4SleepProperty = CacheHelper.getSysProperty("oeTask.executor.syncExamData.sleep");
-		if (node4SleepProperty.getHasValue()) {
-			node4.setSleep(Integer.valueOf(node4SleepProperty.getValue().toString()));//单位秒
-		} else {
-			node4.setSleep(DEFAULT_SYNC_EXAM_DATA_EXECUTOR_SLEEP_SECONDS);//单位秒
-		}
+        SysPropertyCacheBean node3SleepProperty = CacheHelper.getSysProperty("oeTask.executor.afterHandInExam.sleep");
+        node3.setSleep(PropertyHolder.getInt("oeTask.executor.gainExamData.sleep",
+                DEFAULT_AFTER_HAND_IN_EXAM_EXECUTOR_SLEEP_SECONDS));//单位秒
+
+        node4.setSleep(PropertyHolder.getInt("oeTask.executor.gainExamData.sleep",
+                DEFAULT_SYNC_EXAM_DATA_EXECUTOR_SLEEP_SECONDS));//单位秒
 
         node1.start();
         node2.start();