update...

潘钊
1 parent 2ab5ad10
Showing 3 changed files with 12 additions and 1 deletions
src/main/java/com/bsth/Application.java
src/main/java/com/bsth/StartCommand.java
src/main/java/com/bsth/server_rs/thread/RfidCardInfoPersistenceThread.java
@@ -11,7 +11,7 @@ import java.util.concurrent.ScheduledExecutorService;
 @SpringBootApplication
 public class Application extends SpringBootServletInitializer {
  
-	public static ScheduledExecutorService mainServices = Executors.newScheduledThreadPool(7);
+	public static ScheduledExecutorService mainServices = Executors.newScheduledThreadPool(8);
  
 	@Override
 	protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
 package com.bsth;
  
  
+import com.bsth.server_rs.thread.RfidCardInfoPersistenceThread;
 import com.bsth.service.Line2SystemService;
 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;
+
  
 /**
  * 随应用启动运行
@@ -18,6 +22,9 @@ public class StartCommand implements CommandLineRunner{
 	@Autowired
 	Line2SystemService line2SystemService;
  
+	@Autowired
+	RfidCardInfoPersistenceThread rfidCardInfoPersistenceThread;
+
 	@Override
 	public void run(String... arg0){
  
@@ -25,6 +32,9 @@ public class StartCommand implements CommandLineRunner{
 			//将增量的线路load到对照清单
 			line2SystemService.loadByLineInfo();
  
+			ScheduledExecutorService sexec = Application.mainServices;
+			//定时将人车卡数据入库
+			sexec.scheduleWithFixedDelay(rfidCardInfoPersistenceThread, 120, 60 * 5, TimeUnit.SECONDS);
 			//OldWSClient.returnCCInfo();
 			//OldWSClient.getCurrentDayPlan();
 		} catch (Exception e) {
@@ -37,6 +37,7 @@ public class RfidCardInfoPersistenceThread extends Thread{
         try{
             personCardSave();
             carCardSave();
+            logger.info("RfidCardInfoPersistenceThread..");
         }catch (Exception e){
             logger.error("", e);
         }