Merge branch 'minhang' of 192.168.168.201:panzhaov5/bsth_control into minhang

娄高锋
2 parents d7b32888 7f04b456
Showing 11 changed files with 224 additions and 136 deletions
src/main/java/com/bsth/controller/realcontrol/ScheduleRealInfoController.java
src/main/java/com/bsth/controller/realcontrol/anomalyCheckController.java
src/main/java/com/bsth/data/directive/GatewayHttpUtils.java
src/main/java/com/bsth/data/gpsdata/GpsRealData.java
src/main/java/com/bsth/data/gpsdata/arrival/GpsRealAnalyse.java
src/main/java/com/bsth/data/gpsdata/thread/GpsDataLoaderThread.java
src/main/java/com/bsth/data/gpsdata/thread/ThreadPollMonitor.java
src/main/java/com/bsth/data/pilot80/PilotReport.java
src/main/java/com/bsth/data/schedule/DayOfSchedule.java
src/main/java/com/bsth/data/schedule/ScheduleComparator.java
src/main/java/com/bsth/websocket/handler/RealControlSocketHandler.java
@@ -24,10 +24,10 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	/*@Autowired
 	GetSchedulePlanThread getSchedulePlanThread;*/
-	
+
 	@Autowired
 	ScheduleRealInfoService scheduleRealInfoService;
-	
+
 	@Autowired
 	DayOfSchedule dayOfSchedule;
@@ -42,29 +42,29 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	}
 	/**
-	 * 
+	 *
 	 * @Title: outgoAdjust @Description: TODO(待发调整) @param @param id
 	 * 主键 @param @param remarks 备注 @param @param dfsj 待发时间（HH:mm） @throws
 	 */
 	@RequestMapping(value = "/outgoAdjust", method = RequestMethod.POST)
 	public Map<String, Object> outgoAdjust(@RequestParam Long id, @RequestParam String remarks,
-			@RequestParam String dfsj,String bcType) {
+										   @RequestParam String dfsj,String bcType) {
 		return scheduleRealInfoService.outgoAdjust(id, remarks, dfsj, bcType);
 	}
 	/**
-	 * 
+	 *
 	 * @Title: destroy @Description: TODO(销毁，烂班) @param @param idsStr 要烂掉的班次ID ,分隔 
 	 */
 	@RequestMapping(value = "/destroy", method = RequestMethod.POST)
 	public Map<String, Object> destroy(@RequestParam String idsStr
 			/*, @RequestParam(defaultValue = "-1") int spaceAdjust*/,
-			@RequestParam String remarks, @RequestParam String adjustExps/*, @RequestParam(defaultValue = "0") int spaceNum*/) {
+									   @RequestParam String remarks, @RequestParam String adjustExps/*, @RequestParam(defaultValue = "0") int spaceNum*/) {
 		return scheduleRealInfoService.destroy(idsStr/*, spaceAdjust*/, remarks, adjustExps/*, spaceNum*/);
 	}
 	/**
-	 * 
+	 *
 	 * @Title: carDeviceMapp @Description: TODO(获取车辆自编号和设备号对照，从缓存取) @throws
 	 */
 	@RequestMapping(value = "/carDeviceMapp", method = RequestMethod.GET)
@@ -73,7 +73,7 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	}
 	/**
-	 * 
+	 *
 	 * @Title: findPersionByLine @Description: TODO(根据线路主键获取驾驶员) @param @param
 	 * lineId @throws
 	 */
@@ -83,7 +83,7 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	}
 	/**
-	 * 
+	 *
 	 * @Title: findPersionByLine @Description: TODO(根据线路主键获取售票员) @param @param
 	 * lineId @throws
 	 */
@@ -93,7 +93,7 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	}
 	/**
-	 * 
+	 *
 	 * @Title: findPersionByLine @Description: TODO(根据线路主键获取车辆) @param @param
 	 * lineId @throws
 	 */
@@ -103,7 +103,7 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	}
 	/**
-	 * 
+	 *
 	 * @Title: sreachNbbm @Description: TODO(搜索车辆内部编码) @throws
 	 */
 	@RequestMapping(value = "/sreachVehic", method = RequestMethod.GET)
@@ -111,9 +111,9 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 		return scheduleRealInfoService.sreachVehic(nbbm);
 	}
 	/**
-	 * 
-	 * @Title: realOutAdjust 
-	 * @Description: TODO(实发调整) 
+	 *
+	 * @Title: realOutAdjust
+	 * @Description: TODO(实发调整)
 	 * @param @param id 班次ID
 	 * @param @param fcsjActual 实际发车时间 HH:mm
 	 * @param @param remarks 备注
@@ -121,14 +121,14 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	 */
 	@RequestMapping(value = "/realOutAdjust", method = RequestMethod.POST)
 	public Map<String, Object> realOutAdjust(@RequestParam Long id, @RequestParam String fcsjActual,
-			@RequestParam String remarks) {
+											 @RequestParam String remarks) {
 		return scheduleRealInfoService.realOutAdjust(id, fcsjActual, remarks);
 	}
-	
+
 	/**
-	 * 
-	 * @Title: revokeDestroy 
-	 * @Description: TODO(撤销烂班) 
+	 *
+	 * @Title: revokeDestroy
+	 * @Description: TODO(撤销烂班)
 	 * @param @param id
 	 * @throws
 	 */
@@ -136,11 +136,11 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	public Map<String, Object> revokeDestroy(@RequestParam Long id){
 		return scheduleRealInfoService.revokeDestroy(id);
 	}
-	
+
 	/**
-	 * 
-	 * @Title: revokeRealOutgo 
-	 * @Description: TODO(撤销实发) 
+	 *
+	 * @Title: revokeRealOutgo
+	 * @Description: TODO(撤销实发)
 	 * @param @param id
 	 * @throws
 	 */
@@ -160,9 +160,9 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	}
 	/**
-	 * 
-	 * @Title: spaceAdjust 
-	 * @Description: TODO(间隔调整) 
+	 *
+	 * @Title: spaceAdjust
+	 * @Description: TODO(间隔调整)
 	 * @param @param ids 要调整的班次数组ID
 	 * @param @param space 间隔
 	 * @throws
@@ -171,11 +171,11 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	public Map<String, Object> spaceAdjust(Long[] ids, Integer space){
 		return scheduleRealInfoService.spaceAdjust(ids, space);
 	}
-	
+
 	/**
-	 * 
-	 * @Title: schInfoFineTune 
-	 * @Description: TODO(发车信息微调) 
+	 *
+	 * @Title: schInfoFineTune
+	 * @Description: TODO(发车信息微调)
 	 * @param @param map
 	 * @throws
 	 */
@@ -183,11 +183,11 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	public Map<String, Object> schInfoFineTune(@RequestParam Map<String, String> map){
 		return scheduleRealInfoService.schInfoFineTune(map);
 	}
-	
+
 	/**
-	 * 
-	 * @Title: outgoAdjustAll 
-	 * @Description: TODO(批量待发调整) 
+	 *
+	 * @Title: outgoAdjustAll
+	 * @Description: TODO(批量待发调整)
 	 * @param @param list
 	 * @throws
 	 */
@@ -197,11 +197,11 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 		params = StringEscapeUtils.unescapeHtml4(params);
 		return scheduleRealInfoService.outgoAdjustAll(params);
 	}
-	
+
 	/**
-	 * 
-	 * @Title: findByLineAndUpDown 
-	 * @Description: TODO(根据线路和走向获取班次) 
+	 *
+	 * @Title: findByLineAndUpDown
+	 * @Description: TODO(根据线路和走向获取班次)
 	 * @param @param line
 	 * @param @param upDown
 	 */
@@ -209,11 +209,11 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	public List<ScheduleRealInfo> findByLineAndUpDown(@RequestParam String line,@RequestParam Integer upDown){
 		return dayOfSchedule.findByLineAndUpDown(line, upDown);
 	}
-	
+
 	/**
-	 * 
-	 * @Title: findRouteByLine 
-	 * @Description: TODO(获取线路的站点，路段路由) 
+	 *
+	 * @Title: findRouteByLine
+	 * @Description: TODO(获取线路的站点，路段路由)
 	 * @param @param lineCode
 	 * @throws
 	 */
@@ -221,11 +221,11 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	public Map<String, Object> findRouteByLine(@RequestParam String lineCode){
 		return scheduleRealInfoService.findRouteByLine(lineCode);
 	}
-	
+
 	/**
-	 * 
-	 * @Title: removeChildTask 
-	 * @Description: TODO(删除子任务) 
+	 *
+	 * @Title: removeChildTask
+	 * @Description: TODO(删除子任务)
 	 * @param @param taskId 子任务ID
 	 * @throws
 	 */
@@ -235,9 +235,9 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	}
 	/**
-	 * 
-	 * @Title: findByLineCode 
-	 * @Description: TODO(根据线路获取班次信息) 
+	 *
+	 * @Title: findByLineCode
+	 * @Description: TODO(根据线路获取班次信息)
 	 * @param @param lineCode
 	 */
 	@RequestMapping(value = "/lineCode/{lineCode}")
@@ -247,29 +247,29 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	@RequestMapping(value = "/queryUserInfo")
 	public List<ScheduleRealInfo> queryUserInfo(@RequestParam String line,
-			@RequestParam String date,@RequestParam String state) {
+												@RequestParam String date,@RequestParam String state) {
 		return scheduleRealInfoService.queryUserInfo(line, date,state);
 	}
-	
+
 	@RequestMapping(value = "/queryUserInfoPx")
 	public List<ScheduleRealInfo> queryUserInfoPx(@RequestParam String line,
-			@RequestParam String date,@RequestParam String state,@RequestParam String type) {
+												  @RequestParam String date,@RequestParam String state,@RequestParam String type) {
 		return scheduleRealInfoService.queryUserInfoPx(line, date,state,type);
 	}
 	@RequestMapping(value = "/exportWaybill",method = RequestMethod.GET)
 	public List<ScheduleRealInfo> exportWaybill(@RequestParam String jName, @RequestParam String clZbh,
-			@RequestParam String lpName,@RequestParam String date,@RequestParam String line) {
+												@RequestParam String lpName,@RequestParam String date,@RequestParam String line) {
 		return scheduleRealInfoService.exportWaybill(jName, clZbh, lpName,date,line);
 	}
-	
+
 	@RequestMapping(value = "/exportWaybillQp",method = RequestMethod.GET)
 	public List<ScheduleRealInfo> exportWaybillQp(@RequestParam String clZbh
 			,@RequestParam String date,@RequestParam String line) {
 		return scheduleRealInfoService.exportWaybillQp( clZbh, date,line);
 	}
-	
+
 	@RequestMapping(value = "/dailyInfo")
 	public List<Map<String, Object>> dailyInfo(@RequestParam String line, @RequestParam String date,@RequestParam String type) {
 		return scheduleRealInfoService.dailyInfo(line, date, type);
@@ -277,41 +277,41 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	@RequestMapping(value = "/historyMessage")
 	public List<Object[]> historyMessage(@RequestParam String line, @RequestParam String date,
-			@RequestParam String code, @RequestParam String type) {
+										 @RequestParam String code, @RequestParam String type) {
 		return scheduleRealInfoService.historyMessage(line, date, code, type);
 	}
-	
+
 	@RequestMapping(value="/findLine")
 	public List<Map<String,String>> findLine(@RequestParam String line){
 		return scheduleRealInfoService.findLine(line);
 	}
-	
+
 	@RequestMapping(value="/findKMBC",method = RequestMethod.GET)
 	public Map<String,Object> findKMBC(@RequestParam String jGh,@RequestParam String clZbh,@RequestParam String lpName
 			,@RequestParam String date,@RequestParam String line){
 		return scheduleRealInfoService.findKMBC(jGh, clZbh,lpName,date,line);
 	}
-	
+
 	@RequestMapping(value="/findKMBCQp",method = RequestMethod.GET)
 	public Map<String,Object> findKMBCQp(@RequestParam String clZbh
 			,@RequestParam String date,@RequestParam String line){
 		return scheduleRealInfoService.findKMBCQp(clZbh,date,line);
 	}
-	
+
 	@RequestMapping(value="/findLpName")
 	public List<Map<String,String>> findLpName(@RequestParam String lpName){
 		return scheduleRealInfoService.findLpName(lpName);
 	}
-	
+
 	@RequestMapping(value = "/account")
 	public List<Map<String,Object>> account(@RequestParam String line, @RequestParam String date,
-			@RequestParam String code,@RequestParam String xlName, @RequestParam String type) {
+											@RequestParam String code,@RequestParam String xlName, @RequestParam String type) {
 		return scheduleRealInfoService.account(line, date, code, xlName, type);
 	}
-	
+
 	@RequestMapping(value = "/correctForm")
 	public List<ScheduleRealInfo> correctForm(@RequestParam String line, @RequestParam String startDate,
-			@RequestParam String endDate, @RequestParam String lpName, @RequestParam String code, @RequestParam String type) {
+											  @RequestParam String endDate, @RequestParam String lpName, @RequestParam String code, @RequestParam String type) {
 		return scheduleRealInfoService.correctForm(line, startDate, endDate, lpName, code, type);
 	}
 	/**
@@ -327,19 +327,19 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 			,@RequestParam String date,@RequestParam String line){
 		return scheduleRealInfoService.queryListWaybill(jName, clZbh,lpName,date,line);
 	}
-	
+
 	@RequestMapping(value="/queryListWaybillQp",method = RequestMethod.GET)
 	public List<ScheduleRealInfo> queryListWaybillQp(@RequestParam String clZbh,
-			@RequestParam String date,@RequestParam String line){
+													 @RequestParam String date,@RequestParam String line){
 		return scheduleRealInfoService.queryListWaybillQp(clZbh,date,line);
 	}
-	
+
 	@RequestMapping(value="/statisticsDaily")
 	public List<Map<String,Object>> statisticsDaily(@RequestParam String line, @RequestParam String date,
-			@RequestParam String xlName, @RequestParam String type){
+													@RequestParam String xlName, @RequestParam String type){
 		return scheduleRealInfoService.statisticsDaily(line, date, xlName, type);
 	}
-	
+
 	@RequestMapping(value="/statisticsDailyTj")
 	public List<Map<String,Object>> statisticsDailyTj(@RequestParam Map<String, Object> map){
 		String gsdm="";
@@ -372,41 +372,41 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 		}
 		return scheduleRealInfoService.statisticsDailyTj(gsdm,fgsdm,line, date,date2, xlName, type);
 	}
-	
+
 	@RequestMapping(value="/MapById",method = RequestMethod.GET)
 	public Map<String, Object> MapById(@RequestParam("id") Long id){
 		return scheduleRealInfoService.MapById(id);
 	}
-	
+
 	/**
-	 * @Title: scheduleDaily 
-	 * @Description: TODO(调度日报表) 
+	 * @Title: scheduleDaily
+	 * @Description: TODO(调度日报表)
 	 * @param line 线路
 	 * @param date 时间
-	 * @return 
+	 * @return
 	 */
 	@RequestMapping(value="/scheduleDaily")
 	public Map<String,Object> scheduleDaily(@RequestParam String line,@RequestParam String date){
 		return scheduleRealInfoService.scheduleDaily(line,date);
 	}
-	
+
 	@RequestMapping(value="/realScheduleList")
 	public List<ScheduleRealInfo> realScheduleList(@RequestParam String line,@RequestParam String date){
 		return scheduleRealInfoService.realScheduleList(line,date);
 	}
-	
+
 	@RequestMapping(value="/realScheduleListQp")
 	public List<ScheduleRealInfo> realScheduleListQp(@RequestParam String line,@RequestParam String date){
 		return scheduleRealInfoService.realScheduleListQp(line,date);
 	}
-	
+
 	@RequestMapping(value="/multi_tzrc", method=RequestMethod.POST)
 	public Map<String, Object> multi_tzrc(@RequestParam String cpcsJson){
 		cpcsJson = StringEscapeUtils.unescapeHtml4(cpcsJson);
 		List<ChangePersonCar> cpcs = JSONArray.parseArray(cpcsJson, ChangePersonCar.class);
 		return scheduleRealInfoService.multi_tzrc(cpcs);
 	}
-	
+
 	@RequestMapping(value="/multi_dftz", method=RequestMethod.POST)
 	public Map<String, Object> multi_dftz(@RequestParam String dcsJson){
 		dcsJson = StringEscapeUtils.unescapeHtml4(dcsJson);
@@ -436,7 +436,7 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 		List<String> rs = new ArrayList<>();
 		long t = new Date().getTime() - ONE_DAY - (1000 * 60 * 60 * 2);
-		for(int i = 0; i < 5; i ++){
+		for(int i = 0; i < 10; i ++){
 			rs.add(fmtyyyyMMdd.print(t));
 			t -= ONE_DAY;
 		}
@@ -467,7 +467,7 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	public List<Map<String, Object>> scheduleDailyExport(@RequestParam Map<String, Object> map){
 		return scheduleRealInfoService.scheduleDailyExport(map);
 	}
-	
+
 	@RequestMapping(value = "exportWaybillMore", method = RequestMethod.GET)
 	public Map<String, Object> exportWaybillMore(@RequestParam Map<String, Object> map){
 		return scheduleRealInfoService.exportWaybillMore(map);
 package com.bsth.controller.realcontrol;
+import com.bsth.data.gpsdata.arrival.GpsRealAnalyse;
 import com.bsth.data.schedule.DayOfSchedule;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
 import org.slf4j.Logger;
@@ -49,4 +50,9 @@ public class anomalyCheckController {
             dayOfSchedule.replaceByNbbm(nbbm, map.values());
         }
     }
+
+    @RequestMapping(value = "/shutdownThreadPool")
+    public void shutdownThreadPool(){
+        GpsRealAnalyse.shutdown();
+    }
 }
 package com.bsth.data.directive;
-import java.io.IOException;
-
+import com.alibaba.fastjson.JSONObject;
+import com.bsth.util.ConfigUtil;
 import org.apache.http.client.config.RequestConfig;
 import org.apache.http.client.methods.CloseableHttpResponse;
 import org.apache.http.client.methods.HttpPost;
@@ -12,8 +12,7 @@ import org.apache.http.util.EntityUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import com.alibaba.fastjson.JSONObject;
-import com.bsth.util.ConfigUtil;
+import java.io.IOException;
 /**
  * 
@@ -42,7 +41,7 @@ public class GatewayHttpUtils {
 			//超时时间
 			RequestConfig requestConfig = RequestConfig.custom()  
-			        .setConnectTimeout(3000).setConnectionRequestTimeout(1000)  
+			        .setConnectTimeout(3000).setConnectionRequestTimeout(1000)
 			        .setSocketTimeout(3000).build();
 			HttpPost post = new HttpPost(url);
@@ -4,6 +4,7 @@ import com.bsth.data.BasicData;
 import com.bsth.data.forecast.ForecastRealServer;
 import com.bsth.data.gpsdata.thread.GpsDataLoaderThread;
 import com.bsth.data.gpsdata.thread.OfflineMonitorThread;
+import com.bsth.data.gpsdata.thread.ThreadPollMonitor;
 import com.bsth.data.schedule.DayOfSchedule;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
 import com.google.common.collect.TreeMultimap;
@@ -46,6 +47,9 @@ public class GpsRealData implements CommandLineRunner {
     @Autowired
     ForecastRealServer forecastRealServer;
+    @Autowired
+    ThreadPollMonitor threadPollMonitor;
+
     /**
      * 构造函数
      */
@@ -61,6 +65,10 @@ public class GpsRealData implements CommandLineRunner {
         //Application.mainServices.scheduleWithFixedDelay(gpsDataLoader, 20, 2, TimeUnit.SECONDS);
         //定时扫描掉离线
         //Application.mainServices.scheduleWithFixedDelay(offlineMonitorThread, 120, 60, TimeUnit.SECONDS);
+
+        //扫描GPS线程池状态
+        //Application.mainServices.scheduleWithFixedDelay(threadPollMonitor, 60, 20, TimeUnit.SECONDS);
+
     }
@@ -26,7 +26,7 @@ import java.util.concurrent.Executors;
 @Component
 public class GpsRealAnalyse {
-    Logger logger = LoggerFactory.getLogger(this.getClass());
+    static Logger logger = LoggerFactory.getLogger(GpsRealAnalyse.class);
     @Autowired
     OfflineSignalHandle offlineSignalHandle;
@@ -46,40 +46,54 @@ public class GpsRealAnalyse {
     static ExecutorService threadPool = Executors.newFixedThreadPool(100);
+    public static long st;
+    public static CountDownLatch count;
+
     public void analyse(List<GpsEntity> list) {
-        //如果正在恢复数据
-        if (GpsDataRecovery.run)
-            return;
-
-        long t = System.currentTimeMillis();
-        logger.info("analyse gps size: " + list.size());
-        //按线路分组gps
-        ArrayListMultimap multimap = ArrayListMultimap.create();
-        for(GpsEntity gps : list){
-            multimap.put(gps.getLineId(), gps);
-        }
+        try {
+            st = System.currentTimeMillis();
+            //如果正在恢复数据
+            if (GpsDataRecovery.run)
+                return;
+
+            //按线路分组gps
+            ArrayListMultimap multimap = ArrayListMultimap.create();
+            for (GpsEntity gps : list) {
+                multimap.put(gps.getLineId(), gps);
+            }
-        Set<String> ks = multimap.keySet();
-        CountDownLatch count = new CountDownLatch(ks.size());
+            Set<String> ks = multimap.keySet();
+            logger.info("analyse gps size: " + list.size() + ", ks: " + ks.size());
+            count = new CountDownLatch(ks.size());
-        for(String lineCode : ks){
-            threadPool.execute(new SignalHandleThread(multimap.get(lineCode), count));
-        }
+            for (String lineCode : ks) {
+                threadPool.execute(new SignalHandleThread(multimap.get(lineCode), count));
+            }
-        try {
             //等待子线程结束
             count.await();
             //加入实时gps对照
-            for(GpsEntity gps: list)
+            for (GpsEntity gps : list)
                 gpsRealData.put(gps);
-            logger.info("time , " + (System.currentTimeMillis() - t));
-        } catch (InterruptedException e) {
+            logger.info("time , " + (System.currentTimeMillis() - st));
+        } catch (Exception e) {
             logger.error("", e);
         }
     }
+    public static void shutdown() {
+        logger.warn("GpsRealAnalyse shutdown！！");
+        threadPool.shutdownNow();
+        long len = count.getCount();
+        for (int i = 0; i < len; i++) {
+            count.countDown();
+        }
+
+        threadPool = Executors.newFixedThreadPool(100);
+    }
+
     static GpsComp comp = new GpsComp();
     public class SignalHandleThread implements Runnable {
@@ -97,7 +111,7 @@ public class GpsRealAnalyse {
             try {
                 Collections.sort(list, comp);
-                for(GpsEntity gps : list){
+                for (GpsEntity gps : list) {
                     //是否有任务
                     boolean task;
                     CircleQueue<GpsEntity> prevs = GeoCacheData.getGps(gps.getNbbm());
@@ -110,7 +124,7 @@ public class GpsRealAnalyse {
                     //异常判定（越界/超速）
                     abnormalStateHandle.handle(gps, prevs);
-                    if(!task)
+                    if (!task)
                         return; //无任务的，到这里就结束
                     //反向处理
@@ -122,7 +136,7 @@ public class GpsRealAnalyse {
             } catch (Exception e) {
                 logger.error("", e);
             } finally {
-                if(count != null)
+                if (count != null)
                     count.countDown();
             }
         }
@@ -101,9 +101,9 @@ public class GpsDataLoaderThread extends Thread {
                     old = gpsRealData.get(gps.getDeviceId());
                     if (old != null &&
-                            old.getTimestamp() == gps.getTimestamp() &&
-                            old.getLat() == gps.getLat() &&
-                            old.getLon() == gps.getLon())
+                            old.getTimestamp().equals(gps.getTimestamp()) &&
+                            old.getLat().equals(gps.getLat()) &&
+                            old.getLon().equals(gps.getLon()))
                         continue;
                     nbbm = BasicData.deviceId2NbbmMap.get(gps.getDeviceId());
+package com.bsth.data.gpsdata.thread;
+
+import com.bsth.data.gpsdata.arrival.GpsRealAnalyse;
+import org.springframework.stereotype.Component;
+
+/**
+ * 线程池监听
+ * Created by panzhao on 2017/5/10.
+ */
+@Component
+public class ThreadPollMonitor extends Thread{
+
+    @Override
+    public void run() {
+        long t = System.currentTimeMillis();
+
+        if(t - GpsRealAnalyse.st > 3000 * 10){
+            GpsRealAnalyse.shutdown();
+        }
+    }
+}
@@ -74,7 +74,7 @@ public class PilotReport {
 		switch (d80.getData().getRequestCode()) {
 		case 0xA3:
 			//出场请求
-			ScheduleRealInfo outSch = dayOfSchedule.nextByBcType(nbbm, "out");
+			ScheduleRealInfo outSch = dayOfSchedule.searchNearByBcType(nbbm, "out");
 			//如果有对应出场班次
 			if(outSch != null){
 				//没有计划里程的出场班次，出场既是首发站，发送下一班次的营运指令
@@ -833,6 +833,29 @@ public class DayOfSchedule implements CommandLineRunner {
         return sch;
     }
+    /**
+     * 搜索离当前时间最近的一个指定类型的班次
+     * @param nbbm
+     * @param bcType
+     * @return
+     */
+    public ScheduleRealInfo searchNearByBcType(String nbbm, String bcType){
+        List<ScheduleRealInfo> list = findByBcType(nbbm, bcType);
+        Collections.sort(list, schFCSJComparator);
+
+        long t = System.currentTimeMillis();
+        int distance=-1;
+
+        ScheduleRealInfo sch = null;
+        for(ScheduleRealInfo temp : list){
+
+            if(Math.abs(temp.getDfsjT() - t) < distance || distance == -1){
+                sch = temp;
+            }
+        }
+        return sch;
+    }
+
     public List<ScheduleRealInfo> findByBcType(String nbbm, String bcType) {
         List<ScheduleRealInfo> all = nbbmScheduleMap.get(nbbm), outList = new ArrayList<>();
 package com.bsth.data.schedule;
-import java.util.Comparator;
-
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
+import java.util.Comparator;
+
 /**
  * 
  * @ClassName: ScheduleComparator 
@@ -25,7 +25,7 @@ public class ScheduleComparator {
 		@Override
 		public int compare(ScheduleRealInfo s1, ScheduleRealInfo s2) {
-			return (int) (s1.getDfsjT() - s2.getDfsjT());
+			return (int) (s1.getFcsjT() - s2.getFcsjT());
 		}
 	}
 }
@@ -4,7 +4,6 @@ import com.alibaba.fastjson.JSONObject;
 import com.bsth.common.Constants;
 import com.bsth.data.BasicData;
 import com.google.common.base.Splitter;
-import com.google.common.collect.ArrayListMultimap;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Scope;
@@ -12,6 +11,7 @@ import org.springframework.stereotype.Component;
 import org.springframework.web.socket.*;
 import java.util.*;
+import java.util.concurrent.ConcurrentHashMap;
 /**
  * @author PanZhao
@@ -22,12 +22,14 @@ public class RealControlSocketHandler implements WebSocketHandler {
 	Logger logger = LoggerFactory.getLogger(this.getClass());
-	private static final ArrayList<WebSocketSession> users;
-	private static final ArrayListMultimap<String, WebSocketSession> listenMap;
+	private static ArrayList<WebSocketSession> users;
+	//private static final ArrayListMultimap<String, WebSocketSession> listenMap;
+	private static ConcurrentHashMap<String, List<WebSocketSession>> listenMap;
 	static {
 		users = new ArrayList<WebSocketSession>();
-		listenMap = ArrayListMultimap.create();
+		//listenMap = ArrayListMultimap.create();
+		listenMap = new ConcurrentHashMap();
 	}
 	@Override
@@ -35,19 +37,31 @@ public class RealControlSocketHandler implements WebSocketHandler {
 			throws Exception {
 		users.remove(session);
 		//清理监听
-		Set<String> keys = listenMap.keySet();
-		Map<String, WebSocketSession> remMap = new HashMap<>();
-		for(String k : keys){
-			if(listenMap.get(k).contains(session))
-				remMap.put(k, session);
-		}
+		//Set<String> keys = listenMap.keySet();
+		//Map<String, WebSocketSession> remMap = new HashMap<>();
+
+		int vsCount=0;
+		Collection<List<WebSocketSession>> vs = listenMap.values();
+		for(List<WebSocketSession> list : vs){
+			list.remove(session);
-		Set<String> remSet = remMap.keySet();
+			vsCount += list.size();
+		}
+		/*List<WebSocketSession> vs;
+		for(String k : keys){
+			//vs = listenMap.get(k);
+			//vs.remove(session);
+			listenMap.get(k).remove()
+			*//*if(listenMap.get(k).contains(session))
+				remMap.put(k, session);*//*
+		}*/
+
+		/*Set<String> remSet = remMap.keySet();
 		for(String k : remSet){
 			listenMap.remove(k, remMap.get(k));
 			logger.info("web socket close, remove listen K: "+ k);
-		}
-		logger.info("listen values size: " + listenMap.values().size() + " -CloseStatus:" + arg1);
+		}*/
+		logger.info("listen values size: " + vsCount + " -CloseStatus:" + arg1);
 	}
 	@Override
@@ -65,8 +79,12 @@ public class RealControlSocketHandler implements WebSocketHandler {
 				//注册线路监听
 				List<String> idx = Splitter.on(",").splitToList(jsonObj.getString("idx"));
 				for(String lineCode : idx){
-					if(BasicData.lineCode2NameMap.containsKey(lineCode))
-						listenMap.put(lineCode, session);
+					if(BasicData.lineCode2NameMap.containsKey(lineCode)){
+						if(!listenMap.containsKey(lineCode)){
+							listenMap.put(lineCode, new ArrayList<WebSocketSession>());
+						}
+						listenMap.get(lineCode).add(session);
+					}
 				}
 				break;
@@ -97,12 +115,11 @@ public class RealControlSocketHandler implements WebSocketHandler {
 	public void sendMessageToLine(String lineCode, String msg) {
 		TextMessage message = new TextMessage(msg.getBytes());
+		List<WebSocketSession> list = listenMap.get(lineCode);
+		if(list == null || list.size() == 0)
+			return;
-		Iterator<WebSocketSession> iterator = listenMap.get(lineCode).iterator();
-
-		WebSocketSession user;
-		while(iterator.hasNext()){
-			user = iterator.next();
+		for(WebSocketSession user : list){
 			try {
 				if (user.isOpen()) {
 					user.sendMessage(message);