update...

潘钊
1 parent e6014c28
Showing 2 changed files with 23 additions and 15 deletions
src/main/java/com/bsth/Application.java
src/main/java/com/bsth/data/schedule/auto_exec/AutoExecScanThread.java
@@ -17,7 +17,7 @@ import java.util.concurrent.ScheduledExecutorService;
 @SpringBootApplication
 public class Application extends SpringBootServletInitializer {
-	public static ScheduledExecutorService mainServices = Executors.newScheduledThreadPool(16);
+	public static ScheduledExecutorService mainServices = Executors.newScheduledThreadPool(17);
 	@Override
 	protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
@@ -4,6 +4,8 @@ import com.bsth.data.LineConfigData;
 import com.bsth.data.schedule.DayOfSchedule;
 import com.bsth.entity.realcontrol.LineConfig;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -28,25 +30,31 @@ public class AutoExecScanThread extends Thread{
     @Autowired
     RealScheduleAutoExecHandler realScheduleAutoExecHandler;
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
     @Override
     public void run() {
-        //要自动执行的线路
-        List<String> autos = new ArrayList<>();
-        Collection<LineConfig> lcs = lineConfigData.getAll();
-
-        for(LineConfig config : lcs){
-            if(config.isAutoExec()){
-                autos.add(config.getLine().getLineCode());
+        try{
+            //要自动执行的线路
+            List<String> autos = new ArrayList<>();
+            Collection<LineConfig> lcs = lineConfigData.getAll();
+
+            for(LineConfig config : lcs){
+                if(config.isAutoExec()){
+                    autos.add(config.getLine().getLineCode());
+                }
             }
-        }
-        if(autos.size()==0)
-            return;
-        List<ScheduleRealInfo> all = new ArrayList<>(dayOfSchedule.findAll());
-        for(ScheduleRealInfo sch : all){
-            if(autos.contains(sch.getXlBm())){
-                realScheduleAutoExecHandler.exec(sch);
+            if(autos.size()==0)
+                return;
+            List<ScheduleRealInfo> all = new ArrayList<>(dayOfSchedule.findAll());
+            for(ScheduleRealInfo sch : all){
+                if(autos.contains(sch.getXlBm())){
+                    realScheduleAutoExecHandler.exec(sch);
+                }
             }
+        }catch (Exception e){
+            logger.error("", e);
         }
     }
 }