潘钊 / bsth_control · Commits

Commit 907b94ac994e5454bbb69bbc9567724ccf4eb7d0

Authored by 潘钊
1 parent 89e0f69e

update...

Inline Side-by-side
Showing 3 changed files with 4 additions and 9 deletions
src/main/java/com/bsth/data/directive/DirectivesPstThread.java
  View file @907b94a
@@ -192,7 +192,7 @@ public class DirectivesPstThread extends Thread { @@ -192,7 +192,7 @@ public class DirectivesPstThread extends Thread {
192 192
193 tran.commit(status); 193 tran.commit(status);
194 194
195 - logger.info("60 更新成功: " + d60s.size()); 195 + //logger.info("60 更新成功: " + d60s.size());
196 }catch (Exception e){ 196 }catch (Exception e){
197 tran.rollback(status); 197 tran.rollback(status);
198 logger.error("", e); 198 logger.error("", e);
@@ -266,7 +266,7 @@ public class DirectivesPstThread extends Thread { @@ -266,7 +266,7 @@ public class DirectivesPstThread extends Thread {
266 266
267 tran.commit(status); 267 tran.commit(status);
268 268
269 - logger.info("60 入库成功: " + d60s.size()); 269 + //logger.info("60 入库成功: " + d60s.size());
270 }catch (Exception e){ 270 }catch (Exception e){
271 tran.rollback(status); 271 tran.rollback(status);
272 logger.error("", e); 272 logger.error("", e);
src/main/java/com/bsth/data/gpsdata_v2/DataHandleProcess.java
  View file @907b94a
@@ -41,7 +41,7 @@ public class DataHandleProcess { @@ -41,7 +41,7 @@ public class DataHandleProcess {
41 41
42 static Logger logger = LoggerFactory.getLogger(DataHandleProcess.class); 42 static Logger logger = LoggerFactory.getLogger(DataHandleProcess.class);
43 43
44 - final static int POOL_SIZE = 20; 44 + final static int POOL_SIZE = 9;
45 45
46 static ExecutorService threadPool = Executors.newFixedThreadPool(POOL_SIZE + 1); 46 static ExecutorService threadPool = Executors.newFixedThreadPool(POOL_SIZE + 1);
47 public static CountDownLatch count; 47 public static CountDownLatch count;
src/main/java/com/bsth/data/schedule/thread/CalcOilThread.java
  View file @907b94a
@@ -2,12 +2,10 @@ package com.bsth.data.schedule.thread; @@ -2,12 +2,10 @@ package com.bsth.data.schedule.thread;
2 2
3 import com.bsth.data.directive.DayOfDirectives; 3 import com.bsth.data.directive.DayOfDirectives;
4 import com.bsth.data.gpsdata_v2.handlers.overspeed.OverspeedProcess; 4 import com.bsth.data.gpsdata_v2.handlers.overspeed.OverspeedProcess;
5 -import com.bsth.data.gpsdata_v2.thread.GpsDataLoaderThread;  
6 -import com.bsth.service.oil.DlbService;  
7 import com.bsth.data.safe_driv.SafeDrivCenter; 5 import com.bsth.data.safe_driv.SafeDrivCenter;
  6 +import com.bsth.service.oil.DlbService;
8 import com.bsth.service.oil.YlbService; 7 import com.bsth.service.oil.YlbService;
9 import com.bsth.service.report.SheetService; 8 import com.bsth.service.report.SheetService;
10 -  
11 import org.slf4j.Logger; 9 import org.slf4j.Logger;
12 import org.slf4j.LoggerFactory; 10 import org.slf4j.LoggerFactory;
13 import org.springframework.beans.factory.annotation.Autowired; 11 import org.springframework.beans.factory.annotation.Autowired;
@@ -52,8 +50,5 @@ public class CalcOilThread extends Thread{ @@ -52,8 +50,5 @@ public class CalcOilThread extends Thread{
52 SafeDrivCenter.clear(); 50 SafeDrivCenter.clear();
53 //清除超速缓存数据 51 //清除超速缓存数据
54 OverspeedProcess.clear(); 52 OverspeedProcess.clear();
55 -  
56 - GpsDataLoaderThread.setFlag(0);  
57 -  
58 } 53 }
59 } 54 }