1.

王通
1 parent 885583f2
Showing 2 changed files with 65 additions and 58 deletions
src/main/java/com/bsth/CXFConfig.java
src/main/java/com/bsth/StartCommand.java
@@ -20,6 +20,7 @@ import com.bsth.server_rs.exception.AesExceptionMapper;
 import com.bsth.server_rs.gps.GpsRestService;
 import com.bsth.server_rs.info_publish.XxfbRestService;
 import com.bsth.server_rs.logs.RealLogRestService;
+import com.bsth.server_rs.man_hours.ManHoursRestService;
 import com.bsth.server_rs.rate.RateService;
 import com.bsth.server_rs.schedule.plan.SchedulePlanService;
 import com.bsth.server_rs.schedule.real.ScheduleRealService;
@@ -135,6 +136,8 @@ public class CXFConfig {
     private DksRestService dksRestService;
     @Autowired
     private XxfbRestService xxfbRestService;
+    @Autowired
+    private ManHoursRestService manHoursRestService;
     @Bean
     public Server rsServer() {
@@ -163,7 +166,8 @@ public class CXFConfig {
                 carparkRestService,
                 departureRestService,
                 dksRestService,
-                xxfbRestService));
+                xxfbRestService,
+                manHoursRestService));
         endpoint.setProviders(Arrays.asList(new JacksonJsonProvider(), new AesExceptionMapper()));
         //endpoint.setFeatures(Arrays.asList(new Swagger2Feature()));
         endpoint.getInInterceptors().add(new AuthorizeInterceptor_IN());
-package com.bsth;
-
-
-import com.bsth.server_rs.gps.buffer.BasicDataRefreshThread;
-import com.bsth.server_rs.gps.buffer.GpsRefreshThread;
-import com.bsth.server_rs.schedule.real.thread.ExecSchDataRefreshThread;
-import com.bsth.server_rs.schedule.real.thread.SchInOutDataRefreshThread;
-import com.bsth.server_rs.thread.RfidCardInfoPersistenceThread;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.CommandLineRunner;
-import org.springframework.stereotype.Component;
-
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.TimeUnit;
-
-
-/**
- * 随应用启动运行
- * @author PanZhao
- *
- */
-@Component
-public class StartCommand implements CommandLineRunner{
-
-
-	@Autowired
-	RfidCardInfoPersistenceThread rfidCardInfoPersistenceThread;
-	@Autowired
-	SchInOutDataRefreshThread schInOutDataRefreshThread;
-	@Autowired
-	ExecSchDataRefreshThread execSchDataRefreshThread;
-	@Autowired
-	GpsRefreshThread gpsRefreshThread;
-	@Autowired
-	BasicDataRefreshThread basicDataRefreshThread;
-
-	@Override
-	public void run(String... arg0){
-		
-		try {
-			ScheduledExecutorService sexec = Application.mainServices;
-			//定时将人车卡数据入库
-			sexec.scheduleWithFixedDelay(rfidCardInfoPersistenceThread, 120, 60 * 10, TimeUnit.SECONDS);
-			//定时从调度系统刷新进出场数据
-			sexec.scheduleWithFixedDelay(schInOutDataRefreshThread, 40, 60, TimeUnit.SECONDS);
-			//定时从调度系统刷新车辆正在的执行班次
-			sexec.scheduleWithFixedDelay(execSchDataRefreshThread, 20, 60, TimeUnit.SECONDS);
-			//定时刷新实时gps缓存
-			Application.mainServices.scheduleWithFixedDelay(gpsRefreshThread, 10, 7, TimeUnit.SECONDS);
-			//定时刷新基础信息
-			Application.mainServices.scheduleWithFixedDelay(basicDataRefreshThread, 30, 30, TimeUnit.MINUTES);
-
-		} catch (Exception e) {
-			e.printStackTrace();
-		}
-	}
-}
+package com.bsth;
+
+
+import com.bsth.server_rs.gps.buffer.BasicDataRefreshThread;
+import com.bsth.server_rs.gps.buffer.GpsRefreshThread;
+import com.bsth.server_rs.man_hours.ManHoursRefreshScheduler;
+import com.bsth.server_rs.schedule.real.thread.ExecSchDataRefreshThread;
+import com.bsth.server_rs.schedule.real.thread.SchInOutDataRefreshThread;
+import com.bsth.server_rs.thread.RfidCardInfoPersistenceThread;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+
+/**
+ * 随应用启动运行
+ * @author PanZhao
+ *
+ */
+@Component
+public class StartCommand implements CommandLineRunner{
+
+
+	@Autowired
+	RfidCardInfoPersistenceThread rfidCardInfoPersistenceThread;
+	@Autowired
+	SchInOutDataRefreshThread schInOutDataRefreshThread;
+	@Autowired
+	ExecSchDataRefreshThread execSchDataRefreshThread;
+	@Autowired
+	GpsRefreshThread gpsRefreshThread;
+	@Autowired
+	BasicDataRefreshThread basicDataRefreshThread;
+	@Autowired
+	ManHoursRefreshScheduler manHoursRefreshScheduler;
+
+	@Override
+	public void run(String... arg0){
+		
+		try {
+			ScheduledExecutorService sexec = Application.mainServices;
+			//定时将人车卡数据入库
+			sexec.scheduleWithFixedDelay(rfidCardInfoPersistenceThread, 120, 60 * 10, TimeUnit.SECONDS);
+			//定时从调度系统刷新进出场数据
+			sexec.scheduleWithFixedDelay(schInOutDataRefreshThread, 40, 60, TimeUnit.SECONDS);
+			//定时从调度系统刷新车辆正在的执行班次
+			sexec.scheduleWithFixedDelay(execSchDataRefreshThread, 20, 60, TimeUnit.SECONDS);
+			//定时刷新实时gps缓存
+			Application.mainServices.scheduleWithFixedDelay(gpsRefreshThread, 10, 7, TimeUnit.SECONDS);
+			//定时刷新基础信息
+			Application.mainServices.scheduleWithFixedDelay(basicDataRefreshThread, 30, 30, TimeUnit.MINUTES);
+			manHoursRefreshScheduler.refresh();
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+	}
+}