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

minhang

Merge branch 'minhang' of 192.168.168.201:panzhaov5/bsth_control into
minhang
廖磊
2 parents 6af4597f 2033f1c4
Showing 36 changed files with 1838 additions and 1547 deletions
src/main/java/com/bsth/controller/BusIntervalController.java
src/main/java/com/bsth/controller/forms/ExportController.java
src/main/java/com/bsth/controller/realcontrol/ScheduleRealInfoController.java
src/main/java/com/bsth/data/BasicData.java
src/main/java/com/bsth/data/LineConfigData.java
src/main/java/com/bsth/data/gpsdata/GpsEntity.java
src/main/java/com/bsth/data/gpsdata/GpsRealData.java
src/main/java/com/bsth/data/gpsdata/analyse/GpsAnalyse.java
src/main/java/com/bsth/data/gpsdata/analyse/components/GpsArrival.java
src/main/java/com/bsth/data/gpsdata/analyse/components/GpsStateCorrective.java
src/main/java/com/bsth/data/gpsdata/analyse/GeoCacheData.java → src/main/java/com/bsth/data/gpsdata/arrival/GeoCacheData.java
src/main/java/com/bsth/data/gpsdata/arrival/GpsRealAnalyse.java
src/main/java/com/bsth/data/gpsdata/arrival/SignalHandle.java
src/main/java/com/bsth/data/gpsdata/arrival/entity/RouteReverse.java
src/main/java/com/bsth/data/gpsdata/analyse/StationRoute.java → src/main/java/com/bsth/data/gpsdata/arrival/entity/StationRoute.java
src/main/java/com/bsth/data/gpsdata/arrival/handlers/CorrectSignalHandle.java
src/main/java/com/bsth/data/gpsdata/arrival/handlers/InOutStationSignalHandle.java
src/main/java/com/bsth/data/gpsdata/arrival/handlers/OfflineSignalHandle.java
src/main/java/com/bsth/data/gpsdata/arrival/handlers/ReverseSignalHandle.java
src/main/java/com/bsth/data/gpsdata/arrival/handlers/StationInsideHandle.java
@@ -22,6 +22,11 @@ public class BusIntervalController {
 	public List<Map<String,Object>> getDir(@RequestParam Map<String, Object> map){
 		return busIntervalService.getDir(map);
 	}
+
+	@RequestMapping(value = "/getLp", method = RequestMethod.GET)
+	public List<Map<String,Object>> getLp(@RequestParam Map<String, Object> map){
+		return busIntervalService.getLp(map);
+	}
 	@RequestMapping(value = "/interval", method = RequestMethod.GET)
 	public List<Map<String,Object>> interval(@RequestParam Map<String, Object> map){
@@ -231,7 +231,7 @@ public class ExportController {
 			listI.add(resList.iterator());
 			String path = this.getClass().getResource("/").getPath() + "static\\pages\\forms\\";
 			ee.excelReplace(listI, new Object[] { map }, path + "mould\\vehicleloading.xls",
-					path + "export\\车辆加注" + sdfSimple.format(sdfMonth.parse(map.get("dat").toString())) + ".xls");
+					path + "export\\车辆加注" + sdfSimple.format(sdfMonth.parse(map.get("data").toString())) + ".xls");
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
@@ -131,13 +131,13 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	 * @Title: adjust @Description: TODO(调整人车) @param @param id
 	 * 班次ID @param @param nbbm 内部编码 @param @param jsy 驾驶员 @param @param spy
 	 * 售票员 @throws
-	 */
+
 	@RequestMapping(value = "/adjust", method = RequestMethod.POST)
 	public Map<String, Object> adjust(@RequestParam Long id, String nbbm, String jsy,
 			String spy, Integer revertLine, Integer borrowLine, String borrowTimeStr, String revertTimeStr) {
 		return scheduleRealInfoService.adjust(id, nbbm, jsy, spy, revertLine, borrowLine, borrowTimeStr, revertTimeStr);
 	}
-
+	 */
 	/**
 	 * 
 	 * @Title: realOutAdjust 
 package com.bsth.data;
 import com.bsth.Application;
-import com.bsth.data.gpsdata.analyse.GeoCacheData;
+import com.bsth.data.gpsdata.arrival.GeoCacheData;
 import com.bsth.entity.*;
 import com.bsth.entity.schedule.CarConfigInfo;
 import com.bsth.repository.*;
 package com.bsth.data;
-import java.util.Collection;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.Map;
-import java.util.Set;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.CommandLineRunner;
-import org.springframework.stereotype.Component;
-
 import com.bsth.entity.Line;
 import com.bsth.entity.realcontrol.D80ReplyTemp;
 import com.bsth.entity.realcontrol.LineConfig;
 import com.bsth.oplog.normal.OpLogger;
 import com.bsth.service.LineService;
 import com.bsth.service.realcontrol.LineConfigService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+
+import java.util.*;
 /**
  * 
@@ -92,7 +87,7 @@ public class LineConfigData implements CommandLineRunner {
 		//出场时间类型
 		conf.setOutConfig(1);
 		//进场时间类型
-		conf.setInConfig(1);
+		//conf.setInConfig(1);
 		//短语模板
 		conf.setPhraseTemps("");
 		//调度指令模板 
 package com.bsth.data.gpsdata;
-import com.bsth.data.gpsdata.analyse.StationRoute;
+import com.bsth.data.gpsdata.arrival.entity.StationRoute;
 import com.fasterxml.jackson.annotation.JsonIgnore;
 /**
@@ -78,15 +78,15 @@ public class GpsEntity {
 	private boolean sEPoint;
 	 */
-	/** 站内 */
-	private boolean instation;
+	/** 0： 站外 1：站内 2：场内 */
+	private int instation;
 	/** 站点信息，站内时有值 */
 	@JsonIgnore
 	private StationRoute station;
 	/** 状态 */
-	private String state2;
+	private String signalState;
 	public Integer getCompanyCode() {
 		return companyCode;
@@ -233,14 +233,6 @@ public class GpsEntity {
 		this.version = version;
 	}
-	public boolean isInstation() {
-		return instation;
-	}
-
-	public void setInstation(boolean instation) {
-		this.instation = instation;
-	}
-
 	public StationRoute getStation() {
 		return station;
 	}
@@ -257,11 +249,19 @@ public class GpsEntity {
 		this.abnormal = abnormal;
 	}
-	public String getState2() {
-		return state2;
+	public String getSignalState() {
+		return signalState;
 	}
-	public void setState2(String state2) {
-		this.state2 = state2;
+	public void setSignalState(String signalState) {
+		this.signalState = signalState;
+	}
+
+	public int getInstation() {
+		return instation;
+	}
+
+	public void setInstation(int instation) {
+		this.instation = instation;
 	}
 }
@@ -5,7 +5,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.bsth.Application;
 import com.bsth.data.BasicData;
 import com.bsth.data.forecast.ForecastRealServer;
-import com.bsth.data.gpsdata.analyse.GpsAnalyse;
+import com.bsth.data.gpsdata.arrival.GpsRealAnalyse;
 import com.bsth.data.gpsdata.recovery.GpsDataRecovery;
 import com.bsth.data.schedule.DayOfSchedule;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
@@ -29,256 +29,187 @@ import java.util.*;
 import java.util.concurrent.TimeUnit;
 /**
- *
+ * @author PanZhao
  * @ClassName: GpsRealData
  * @Description: TODO(实时GPS数据集合)
- * @author PanZhao
  * @date 2016年8月12日 下午2:04:41
- *
  */
 @Component
-public class GpsRealData implements CommandLineRunner{
-
-	static Logger logger = LoggerFactory.getLogger(GpsRealData.class);
-
-	private static Map<String, GpsEntity> gpsMap;
-
-	//按线路分组设备号
-	private static TreeMultimap<String, String> lineCode2Devices;
-
-	// 网关数据接口地址
-	private static String url;
-
-	@Autowired
-	GpsDataLoader gpsDataLoader;
-
-	@Autowired
-	DayOfSchedule dayOfSchedule;
-
-	@Autowired
-	ForecastRealServer forecastRealServer;
-
-
-
-	/**
-	 * 构造函数
-	 */
-	public GpsRealData(){
-		gpsMap = new HashMap<>();
-		lineCode2Devices = TreeMultimap.create();
-		url = ConfigUtil.get("http.gps.real.url");
-	}
-
-	@Override
-	public void run(String... arg0) throws Exception {
-		logger.info("gpsDataLoader,20,6");
-		Application.mainServices.scheduleWithFixedDelay(gpsDataLoader, 40, 20, TimeUnit.SECONDS);
-	}
-
-	public GpsEntity add(GpsEntity gps) {
-		String device = gps.getDeviceId();
-		GpsEntity old = gpsMap.get(device);
-
-		//分析gps
-		if(isAvailable(gps) && (old == null || old.getTimestamp() != gps.getTimestamp()))
-			GpsAnalyse.start(gps);
-
-		if(!StringUtils.isEmpty(gps.getStopNo())){
-			//定时定距数据附带站点编码改变
-			if(null == old || !gps.getStopNo().equals(old.getStopNo())){
-				gps.setArrTime(gps.getTimestamp());
-				//预测到达终点时间
-				forecastRealServer.forecast(gps.getNbbm(), gps);
-			}
-			else{
-				gps.setArrTime(old.getArrTime());
-				//不预测， 重新计算终点时间
-				gps.setExpectStopTime(forecastRealServer.expectStopTime(gps.getNbbm()));
-			}
-		}
-
-		gpsMap.put(device, gps);
-		if(StringUtils.isNotBlank(gps.getLineId()))
-			lineCode2Devices.put(gps.getLineId(), device);
-		return gps;
-	}
-
-	public boolean isAvailable(GpsEntity gps){
-		return StringUtils.isNotEmpty(gps.getLineId()) &&
-				dayOfSchedule.getCurrSchDate().containsKey(gps.getLineId());
-	}
-
-	/**
-	 *
-	 * @Title: get @Description: TODO(设备号获取GPS)
-	 */
-	public GpsEntity get(String deviceId) {
-		return gpsMap.get(deviceId);
-	}
-
-	/**
-	 *
-	 * @Title: get @Description: TODO(线路编码获取GPS集合) @throws
-	 */
-	public List<GpsEntity> getByLine(String lineCode) {
-		NavigableSet<String> set = lineCode2Devices.get(lineCode);
-
-		List<GpsEntity> rs = new ArrayList<>();
-		GpsEntity gps;
-		ScheduleRealInfo sch;
-		for(String device : set){
-			gps = gpsMap.get(device);
-			//过滤异常GPS数据
-			if(gps.isAbnormal())
-				continue;
-
-			sch = dayOfSchedule.execPlanMap().get(gps.getNbbm());
-			if(null != sch)
-				gps.setSchId(sch.getId());
-			rs.add(gps);
-		}
-
-		return rs;
-	}
-
-	public List<GpsEntity> get(List<String> pArray){
-		List<GpsEntity> list = new ArrayList<>();
-
-		for(String code : pArray)
-			list.addAll(getByLine(code));
-		return list;
-	}
-
-	public Set<String> allDevices(){
-		return gpsMap.keySet();
-	}
-
-	public GpsEntity findByDeviceId(String deviceId) {
-		return gpsMap.get(deviceId);
-	}
-
-	public Collection<GpsEntity> all(){
-		return gpsMap.values();
-	}
-
-	public void remove(String device){
-		gpsMap.remove(device);
-	}
-	@Component
-	public static class GpsDataLoader extends Thread{
-
-		Logger logger = LoggerFactory.getLogger(GpsDataLoader.class);
-
-		@Autowired
-		GpsRealData gpsRealData;
-
-		@Override
-		public void run() {
-			try{
-				//如果正在恢复数据
-				if(GpsDataRecovery.run){
-					return;
-				}
-
-				load();
-			}catch(Exception e){
-				logger.error("", e);
-			}
-		}
-
-		public void load() throws Exception {
-			List<GpsEntity> list = new ArrayList<>();
-			CloseableHttpClient httpClient = null;
-			CloseableHttpResponse response = null;
-			try {
-				httpClient = HttpClients.createDefault();
-				HttpGet get = new HttpGet(url);
-
-				response = httpClient.execute(get);
-
-				HttpEntity entity = response.getEntity();
-				if (null != entity) {
-					// 返回数据量比较大，建议以流的形式读取
-					BufferedReader br = new BufferedReader(new InputStreamReader(entity.getContent()));
-					StringBuffer stringBuffer = new StringBuffer();
-					String str = "";
-					while ((str = br.readLine()) != null)
-						stringBuffer.append(str);
-
-					JSONObject jsonObj = JSON.parseObject(stringBuffer.toString());
-
-					if (jsonObj != null)
-						list = JSON.parseArray(jsonObj.getString("data"), GpsEntity.class);
-
-					String nbbm;
-					for(GpsEntity gps : list){
-						//没有设备号
-						if(StringUtils.isBlank(gps.getDeviceId()))
-							continue;
-
-						nbbm = BasicData.deviceId2NbbmMap.get(gps.getDeviceId());
-						if(StringUtils.isBlank(nbbm))
-							gps.setAbnormal(true);//标记为异常数据
-						else
-							gps.setNbbm(nbbm);
-
-						gps.setStationName(BasicData.stationCode2NameMap.get(gps.getStopNo()));
-						gpsRealData.add(gps);
-
-						//纠正走向
-						//correctUpdown(gps);
-					}
-				} else
-					logger.error("result is null");
-			} catch(Exception e){
-				logger.error("", e);
-			}
-			finally {
-				if (null != httpClient)
-					httpClient.close();
-				if(null != response)
-					response.close();
-			}
-		}
-
-		/**
-		 * 是否是起终点
-		 * @param gps
-		 * @return
-
-		public boolean isSEPoint(GpsEntity gps){
-			String key = gps.getLineId()+"_"+gps.getUpDown()+"_"
-					,stationCode;
-
-			if(BasicData.lineSEPointMap.containsKey(key+"B")){
-				stationCode = BasicData.lineSEPointMap.get(key+"B");
-				if(gps.getStopNo().equals(stationCode)){
-					gps.setsEPoint(true);
-					return true;
-				}
-			}
-
-			if(BasicData.lineSEPointMap.containsKey(key+"E")){
-				stationCode = BasicData.lineSEPointMap.get(key+"E");
-				if(gps.getStopNo().equals(stationCode)){
-					gps.setsEPoint(true);
-					return true;
-				}
-			}
-			return false;
-		}*/
-
-		/**
-		 * 纠正上下行
-		 * @param gps
-
-		public void correctUpdown(GpsEntity gps){
-			Integer updown=BasicData.lineStationUpDownMap.get(gps.getLineId()+"_"+gps.getStopNo());
-			if(updown != null && !updown.equals(gps.getUpDown()))
-				gps.setUpDown(updown);
-
-			if(isSEPoint(gps))
-				return;
-		}*/
-	}
+public class GpsRealData implements CommandLineRunner {
+
+    static Logger logger = LoggerFactory.getLogger(GpsRealData.class);
+
+    private static Map<String, GpsEntity> gpsMap;
+
+    //按线路分组设备号
+    private static TreeMultimap<String, String> lineCode2Devices;
+
+    // 网关数据接口地址
+    private static String url;
+
+    @Autowired
+    GpsDataLoader gpsDataLoader;
+
+    @Autowired
+    DayOfSchedule dayOfSchedule;
+
+    @Autowired
+    ForecastRealServer forecastRealServer;
+
+    /**
+     * 构造函数
+     */
+    public GpsRealData() {
+        gpsMap = new HashMap<>();
+        lineCode2Devices = TreeMultimap.create();
+        url = ConfigUtil.get("http.gps.real.url");
+    }
+
+    @Override
+    public void run(String... arg0) throws Exception {
+        logger.info("gpsDataLoader,40,6");
+        Application.mainServices.scheduleWithFixedDelay(gpsDataLoader, 40, 6, TimeUnit.SECONDS);
+    }
+
+    public void put(GpsEntity gps) {
+        gpsMap.put(gps.getDeviceId(), gps);
+    }
+
+    /**
+     * @Title: get @Description: TODO(设备号获取GPS)
+     */
+    public GpsEntity get(String deviceId) {
+        return gpsMap.get(deviceId);
+    }
+
+    /**
+     * @Title: get @Description: TODO(线路编码获取GPS集合) @throws
+     */
+    public List<GpsEntity> getByLine(String lineCode) {
+        NavigableSet<String> set = lineCode2Devices.get(lineCode);
+
+        List<GpsEntity> rs = new ArrayList<>();
+        GpsEntity gps;
+        ScheduleRealInfo sch;
+        for (String device : set) {
+            gps = gpsMap.get(device);
+            //过滤异常GPS数据
+            if (gps.isAbnormal())
+                continue;
+
+            sch = dayOfSchedule.execPlanMap().get(gps.getNbbm());
+            if (null != sch)
+                gps.setSchId(sch.getId());
+            rs.add(gps);
+        }
+
+        return rs;
+    }
+
+    public List<GpsEntity> get(List<String> pArray) {
+        List<GpsEntity> list = new ArrayList<>();
+
+        for (String code : pArray)
+            list.addAll(getByLine(code));
+        return list;
+    }
+
+    public Set<String> allDevices() {
+        return gpsMap.keySet();
+    }
+
+    public GpsEntity findByDeviceId(String deviceId) {
+        return gpsMap.get(deviceId);
+    }
+
+    public Collection<GpsEntity> all() {
+        return gpsMap.values();
+    }
+
+    public void remove(String device) {
+        gpsMap.remove(device);
+    }
+
+    @Component
+    public static class GpsDataLoader extends Thread {
+
+        Logger logger = LoggerFactory.getLogger(GpsDataLoader.class);
+
+        @Autowired
+        GpsRealData gpsRealData;
+
+        @Autowired
+        GpsRealAnalyse gpsRealAnalyse;
+
+        @Override
+        public void run() {
+            try {
+                //如果正在恢复数据
+                if (GpsDataRecovery.run)
+                    return;
+
+                load();
+            } catch (Exception e) {
+                logger.error("", e);
+            }
+        }
+
+        public void load() throws Exception {
+            List<GpsEntity> list = null;
+            List<GpsEntity> updateList = new ArrayList<>();
+            CloseableHttpClient httpClient = null;
+            CloseableHttpResponse response = null;
+            try {
+                httpClient = HttpClients.createDefault();
+                HttpGet get = new HttpGet(url);
+
+                response = httpClient.execute(get);
+
+                HttpEntity entity = response.getEntity();
+                if (null != entity) {
+                    BufferedReader br = new BufferedReader(new InputStreamReader(entity.getContent()));
+                    StringBuffer stringBuffer = new StringBuffer();
+                    String str = "";
+                    while ((str = br.readLine()) != null)
+                        stringBuffer.append(str);
+
+                    JSONObject jsonObj = JSON.parseObject(stringBuffer.toString());
+
+                    if (jsonObj != null)
+                        list = JSON.parseArray(jsonObj.getString("data"), GpsEntity.class);
+
+                    String nbbm;
+                    GpsEntity old;
+                    for (GpsEntity gps : list) {
+                        //没有设备号
+                        if (StringUtils.isBlank(gps.getDeviceId()))
+                            continue;
+
+                        old = gpsMap.get(gps.getDeviceId());
+                        if (old != null &&
+                                old.getTimestamp() == gps.getTimestamp())
+                            continue;
+
+                        nbbm = BasicData.deviceId2NbbmMap.get(gps.getDeviceId());
+                        if (StringUtils.isBlank(nbbm))
+                            gps.setAbnormal(true);//标记为异常数据
+                        else
+                            gps.setNbbm(nbbm);
+                        //有更新的点位
+                        updateList.add(gps);
+                    }
+                    //分析数据
+                    gpsRealAnalyse.analyse(updateList);
+                } else
+                    logger.error("real gps result is null");
+            } catch (Exception e) {
+                logger.error("", e);
+            } finally {
+                if (null != httpClient)
+                    httpClient.close();
+                if (null != response)
+                    response.close();
+            }
+        }
+    }
 }
 \ No newline at end of file
-package com.bsth.data.gpsdata.analyse;
-
-import com.bsth.data.gpsdata.GpsEntity;
-import com.bsth.data.gpsdata.analyse.components.GpsArrival;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-
-/**
- * 分析gps状态信息
- * Created by panzhao on 2016/12/23.
- */
-public class GpsAnalyse {
-
-    static Logger logger = LoggerFactory.getLogger(GpsAnalyse.class);
-
-    //线程池
-    static ExecutorService threadPool = Executors.newFixedThreadPool(50);
-
-    public static void start(GpsEntity gps) {
-        threadPool.execute(new ArrivalMatchThread(gps));
-    }
-
-    public static class ArrivalMatchThread implements Runnable {
-
-        private GpsEntity gps;
-
-        public ArrivalMatchThread(GpsEntity gps) {
-            this.gps = gps;
-        }
-
-        @Override
-        public void run() {
-            GpsArrival.arrival(gps);
-        }
-    }
-}
 \ No newline at end of file
-package com.bsth.data.gpsdata.analyse.components;
-
-import com.bsth.data.LineConfigData;
-import com.bsth.data.gpsdata.GpsEntity;
-import com.bsth.data.gpsdata.analyse.CircleQueue;
-import com.bsth.data.gpsdata.analyse.GeoCacheData;
-import com.bsth.data.gpsdata.analyse.StationRoute;
-import com.bsth.data.gpsdata.analyse.util.GeoUtils;
-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.BeansException;
-import org.springframework.context.ApplicationContext;
-import org.springframework.context.ApplicationContextAware;
-import org.springframework.stereotype.Component;
-
-import java.util.List;
-
-/**
- * gps 到离站判断
- * Created by panzhao on 2016/12/24.
- */
-@Component
-public class GpsArrival implements ApplicationContextAware {
-
-    static Logger logger = LoggerFactory.getLogger(GpsArrival.class);
-
-    static DayOfSchedule dayOfSchedule;
-
-    static LineConfigData lineConfigData;
-
-    public static void arrival(GpsEntity gps) {
-
-        if (gps.getLat() == 0 || gps.getLon() == 0) {
-            //logger.error("无效的gps");
-            return;
-        }
-
-        Object task = DayOfSchedule.executeCurr(gps.getNbbm());
-        if (task == null)
-            return;
-        if (task.getClass().isAssignableFrom(ScheduleRealInfo.class)) {
-            ScheduleRealInfo sch = (ScheduleRealInfo) task;
-            //和班次同步走向
-            gps.setUpDown(Integer.parseInt(sch.getXlDir()));
-
-            //出场
-            if (sch.getBcType().equals("out")) {
-                outCarpark(gps, sch);
-            }
-            else if (sch.getBcType().equals("normal"))
-                normalInOut(gps, sch);
-            else if(sch.getBcType().equals("in")){
-                inCarpark(gps, sch);
-            }
-        }
-
-        GeoCacheData.putGps(gps);
-    }
-
-    /**
-     * 正常班次
-     *
-     * @param gps
-     * @param sch
-     */
-    private static void normalInOut(GpsEntity gps, ScheduleRealInfo sch) {
-        CircleQueue<GpsEntity> queue = GeoCacheData.getGps(gps.getNbbm());
-        GpsEntity prev = null;
-        if (queue != null)
-            prev = queue.getTail();
-
-        List<StationRoute> srs = GeoCacheData.getStationRoute(sch.getXlBm(), gps.getUpDown());
-        StationRoute station = GeoUtils.gpsInStation(gps, srs);
-
-        if (station != null) {
-            //站内
-            gps.setStopNo(station.getCode());
-            gps.setInstation(true);
-            stationInside(gps, prev, sch);
-        } else {
-            //站外
-            stationOutside(gps, prev, sch);
-        }
-    }
-
-    /**
-     * GPS在站点内
-     *
-     * @param gps
-     * @param prev
-     * @param sch
-     */
-    private static void stationInside(GpsEntity gps, GpsEntity prev, ScheduleRealInfo sch) {
-        if(prev == null)
-            return;
-
-        if (gps.getStopNo().equals(sch.getZdzCode()) && sch.getZdsjActual() == null) {
-            //到终点站
-            arriveEnd(sch, gps);
-            return;
-        }
-
-        //上一个点在站外
-        if(!prev.isInstation())
-            return;
-        //超过 （待发时间 + 90%的单程运送时间），还在起点站。默认烂一圈
-        if (prev.getStopNo().equals(gps.getStopNo())){
-            if(gps.getStopNo().equals(sch.getQdzCode())
-                    && gps.getTimestamp() > sch.getDfsjT() + (sch.getBcsj() * 60 * 1000 * 0.9)){
-
-                ScheduleRealInfo next = dayOfSchedule.next(dayOfSchedule.next(sch));
-                dayOfSchedule.addExecPlan(next);
-            }
-            return;
-        }
-
-        //发车
-        if (prev.getStopNo().equals(sch.getQdzCode())) {
-            busWillDepart(sch, gps);
-            return;
-        }
-
-        //中途站
-        StationRoute prevStation = GeoCacheData.getStation(prev.getLineId(), prev.getUpDown(), prev.getStopNo());
-        StationRoute currStation = GeoCacheData.getStation(gps.getLineId(), gps.getUpDown(), gps.getStopNo());
-        if (currStation.getRouteSort() < prevStation.getRouteSort()) {
-            //开始下一个班次
-            finishPlan(sch);
-
-            logger.info("路由反向。。。。。。:" + gps.getTimestamp());
-            //为班次补上实际时间
-
-        }
-    }
-
-    /**
-     * GPS在站点外
-     *
-     * @param gps
-     * @param prev
-     * @param sch
-     */
-    private static void stationOutside(GpsEntity gps, GpsEntity prev, ScheduleRealInfo sch) {
-        if(prev == null)
-            return;
-
-        gps.setStopNo(prev.getStopNo());
-        if (prev.isInstation() && prev.getStopNo().equals(sch.getQdzCode())) {
-            //发车
-            busWillDepart(sch, gps);
-            return;
-        }
-    }
-
-    /**
-     * 公交车起点发出
-     */
-    final static long DRIFT_VAL_TIME = 1000 * 60 * 10;
-    //班次最大差值1小时
-    final static long MAX_DIFF = 1000 * 60 * 60;
-    private static void busWillDepart(ScheduleRealInfo sch, GpsEntity gps) {
-        //实发时间不覆盖
-        if (sch.getFcsjActual() == null && Math.abs(gps.getTimestamp() - sch.getDfsjT()) < MAX_DIFF) {
-
-            //提前10分钟以上发出，判断一下是否是漂移
-            if(sch.getDfsjT() - gps.getTimestamp() > DRIFT_VAL_TIME){
-                ScheduleRealInfo schPrev = dayOfSchedule.prev(sch);
-                if(schPrev != null && schPrev.getZdsjActual() != null){
-                    //计划停站时间
-                    long stopTimeJH = sch.getDfsjT() - schPrev.getZdsjT();
-                    //实际停站时间
-                    long actualStopTime = gps.getTimestamp() - schPrev.getZdsjActualTime();
-                    /*
-                        没停够计划百分之60的，算漂移
-                        （这里出现的误判，由程序在车辆到中途站的时候进行补偿）
-                     */
-                    if(stopTimeJH * 0.6 < actualStopTime){
-                        logger.info("漂移.... 车辆：" + gps.getNbbm() + " ts: " + gps.getTimestamp());
-                        return;
-                    }
-                }
-            }
-
-            LineConfig config = lineConfigData.get(sch.getXlBm());
-            if(config != null && config.getOutConfig() == 2){
-                //出站既出场
-                ScheduleRealInfo schPrev = dayOfSchedule.prev(sch);
-                if(schPrev.getBcType().equals("out")){
-                    schPrev.setFcsjActualAll(schPrev.getDfsjT());
-                    schPrev.setZdsjActualAll(schPrev.getZdsjT());
-                }
-            }
-
-            sch.setFcsjActualAll(gps.getTimestamp());
-            logger.info("（站外）班次：" + sch.getDfsj() + "发车， 时间：" + sch.getFcsjActual());
-        }
-    }
-
-    /**
-     * 公交车到达终点
-     *
-     * @param sch
-     * @param gps
-     */
-    private static void arriveEnd(ScheduleRealInfo sch, GpsEntity gps) {
-        sch.setZdsjActualAll(gps.getTimestamp());
-        ScheduleRealInfo next = finishPlan(sch);
-        logger.info("班次：" + sch.getDfsj() + "到达终点， 时间：" + sch.getZdsjActual());
-
-        if (next == null)
-            return;
-
-        //将gps转换为下一个班次走向的站内信号
-        int updown = Integer.parseInt(next.getXlDir());
-        List<StationRoute> srs = GeoCacheData.getStationRoute(next.getXlBm(), updown);
-        StationRoute station = GeoUtils.gpsInStation(gps, srs);
-        if (station != null) {
-            gps.setUpDown(updown);
-            gps.setStopNo(station.getCode());
-        }
-    }
-
-    /**
-     * 出场班次
-     *
-     * @param gps
-     * @param sch
-     */
-    private static void outCarpark(GpsEntity gps, ScheduleRealInfo sch) {
-        String carpark = GeoUtils.gpsInCarpark(gps);
-        if (carpark != null) {
-            gps.setInstation(true);
-            gps.setStopNo(carpark);
-            return; // 还在场内
-        }
-
-        CircleQueue<GpsEntity> queue = GeoCacheData.getGps(gps.getNbbm());
-        if (queue == null)
-            return;
-        //上一个gps
-        GpsEntity prev = queue.getTail();
-
-        if (carpark == null && prev.isInstation() && prev.getStopNo().equals(sch.getQdzCode())) {
-            gps.setStopNo(prev.getStopNo());
-            //停车场发出
-            busWillDepart(sch, gps);
-            return;
-        }
-
-        List<StationRoute> srs = GeoCacheData.getStationRoute(sch.getXlBm(), gps.getUpDown());
-        StationRoute station = GeoUtils.gpsInStation(gps, srs);
-
-        if (station != null && station.getCode().equals(sch.getZdzCode())) {
-            gps.setStopNo(station.getCode());
-            //到达终点
-            arriveEnd(sch, gps);
-        }
-    }
-
-
-    /**
-     * 进场班次
-     * @param gps
-     * @param sch
-     */
-    private static void inCarpark(GpsEntity gps, ScheduleRealInfo sch) {
-        String carpark = GeoUtils.gpsInCarpark(gps);
-        if (carpark != null && carpark.equals(sch.getZdzCode())) {
-            //进场班次取第一个实际进场时间
-            if(sch.getZdsjActual() != null)
-                return;
-
-            //进场
-            arriveEnd(sch, gps);
-            return;
-        }
-
-        CircleQueue<GpsEntity> queue = GeoCacheData.getGps(gps.getNbbm());
-        if (queue == null)
-            return;
-        //上一个gps
-        GpsEntity prev = queue.getTail();
-
-        if (carpark == null && prev.isInstation() && prev.getStopNo().equals(sch.getQdzCode())) {
-            gps.setStopNo(prev.getStopNo());
-            //进场班次发出
-            busWillDepart(sch, gps);
-            return;
-        }
-    }
-
-    /**
-     * 完成班次 -返回下一个班次
-     *
-     * @param sch
-     */
-    private static ScheduleRealInfo finishPlan(ScheduleRealInfo sch) {
-        ScheduleRealInfo next = dayOfSchedule.next(sch);
-        if (next != null) {
-            next.setQdzArrDatesj(sch.getZdsjActual());
-            dayOfSchedule.addExecPlan(next);
-        }
-        return next;
-    }
-
-    @Override
-    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
-        dayOfSchedule = applicationContext.getBean(DayOfSchedule.class);
-        lineConfigData = applicationContext.getBean(LineConfigData.class);
-    }
-}
-package com.bsth.data.gpsdata.analyse.components;
-
-import com.bsth.data.gpsdata.GpsEntity;
-import com.bsth.data.schedule.DayOfSchedule;
-import com.bsth.entity.realcontrol.ScheduleRealInfo;
-import com.vividsolutions.jts.geom.GeometryFactory;
-import org.joda.time.format.DateTimeFormat;
-import org.joda.time.format.DateTimeFormatter;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.BeansException;
-import org.springframework.context.ApplicationContext;
-import org.springframework.context.ApplicationContextAware;
-import org.springframework.stereotype.Component;
-
-/**
- * GPS状态纠正
- * Created by panzhao on 2016/12/23.
- */
-@Component
-public class GpsStateCorrective implements ApplicationContextAware {
-
-    static Logger logger = LoggerFactory.getLogger(GpsStateCorrective.class);
-
-    static DayOfSchedule dayOfSchedule;
-
-    private static GeometryFactory geometryFactory = new GeometryFactory();
-
-    public static void correct(GpsEntity gps, ScheduleRealInfo sch){
-/*        int upDown = Integer.parseInt(sch.getXlDir());
-        gps.setUpDown(upDown);
-        List<StationRoute> srs = GeoCacheData.getStationRoute(sch.getXlBm(), upDown);
-
-        Point point = geometryFactory.createPoint(new Coordinate(gps.getLat(), gps.getLon()));
-
-        //之前的点位
-        CircleQueue<GpsEntity> queue = GeoCacheData.getGps(gps.getNbbm());
-        GpsEntity prev = null;
-        if(queue != null)
-            prev = queue.getTail();
-
-        //线路上，站点间
-        StationRoute station = GeoUtils.pointInStation(point, srs);
-        //在站内
-        if(station != null){
-            gps.setStopNo(station.getCode());
-            gps.setInstation(true);
-            gps.setStation(station);
-
-            if(prev != null && prev.getUpDown() == upDown){
-                StationRoute prevStation = GeoCacheData.getStation(prev.getLineId(), upDown, prev.getStopNo());
-
-                //倒着开？？
-                if(prevStation.getRouteSort() > station.getRouteSort()){
-                    reversalHandle(gps, prev, sch);
-                }
-            }
-        }
-        else{
-            if(prev != null)
-                gps.setStopNo(prev.getStopNo());
-        }
-
-        //是否在停车场内
-        Map<String, Polygon> carparkMap = GeoCacheData.tccMap;
-        Set<String> codes = carparkMap.keySet();
-        Polygon p;
-        for(String code : codes){
-            p = carparkMap.get(code);
-            //场内
-            if(p.contains(point)){
-                gps.setCarparkNo(code);
-                if(sch.getBcType().equals("out")){
-                    gps.setInstation(true);
-                    gps.setStopNo(code);
-                }
-            }
-        }*/
-    }
-
-    private static DateTimeFormatter fmt = DateTimeFormat.forPattern("HH:mm");
-
-    private static void reversalHandle(GpsEntity gps, GpsEntity prev, ScheduleRealInfo sch){
-        /*if(sch.getBcType().equals("out") && gps.getTimestamp() < sch.getZdsjT())
-            return;
-
-        //先假设没到终点，直接开始了下一个班次
-        ScheduleRealInfo next = dayOfSchedule.next(sch);
-        String log = "倒着开？？？ nbbm: " + gps.getNbbm() + " 当前：" + gps.getStopNo() + " 上一站：" + prev.getStopNo() + " 当前班次：" + sch.getDfsj();
-        if(next != null){
-            dayOfSchedule.addExecPlan(next);
-
-            log += (" 下一个班次：" + next.getDfsj());
-        }
-
-        log += (" GPS时间：" + fmt.print(gps.getTimestamp()));
-
-        logger.info(log);*/
-    }
-
-    @Override
-    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
-        dayOfSchedule = applicationContext.getBean(DayOfSchedule.class);
-    }
-}
-package com.bsth.data.gpsdata.analyse;
+package com.bsth.data.gpsdata.arrival;
 import com.bsth.data.gpsdata.GpsEntity;
+import com.bsth.data.gpsdata.arrival.entity.StationRoute;
+import com.bsth.data.gpsdata.arrival.utils.CircleQueue;
+import com.bsth.data.gpsdata.arrival.utils.StationRouteComp;
 import com.google.common.collect.ArrayListMultimap;
 import com.vividsolutions.jts.geom.Coordinate;
 import com.vividsolutions.jts.geom.GeometryFactory;
@@ -26,8 +29,8 @@ public class GeoCacheData {
     static Logger logger = LoggerFactory.getLogger(GeoCacheData.class);
-    //每辆车缓存最后200条gps
-    private static final int CACHE_SIZE = 200;
+    //每辆车缓存最后500条gps
+    private static final int CACHE_SIZE = 500;
     private static Map<String, CircleQueue<GpsEntity>> gpsCacheMap = new HashMap<>();
     //线路路段走向
@@ -36,6 +39,9 @@ public class GeoCacheData {
     //线路站点路由
     private static ArrayListMultimap<String, StationRoute> stationCacheMap;
+    //线路_上下行_站点编码 ——> 站点
+    private static Map<String, StationRoute> routeCodeMap;
+
     //停车场
     public static Map<String, Polygon> tccMap;
@@ -49,9 +55,9 @@ public class GeoCacheData {
     public static void putGps(GpsEntity gps) {
         CircleQueue<GpsEntity> queue = gpsCacheMap.get(gps.getNbbm());
         if (queue == null) {
-            //第一个点从站内开始
-            if(!gps.isInstation())
-                return;
+            /*//第一个点从站内开始
+            if (gps.getInstation() == 0)
+                return;*/
             queue = new CircleQueue<>(CACHE_SIZE);
             gpsCacheMap.put(gps.getNbbm(), queue);
@@ -59,6 +65,20 @@ public class GeoCacheData {
         queue.add(gps);
     }
+    public static void clear(String nbbm) {
+        try {
+            CircleQueue<GpsEntity> queue = gpsCacheMap.get(nbbm);
+            if (queue != null)
+                queue.clear();
+        } catch (Exception e) {
+            logger.error("", e);
+        }
+    }
+
+    public static StationRoute getRouteCode(GpsEntity gps){
+        return routeCodeMap.get(gps.getLineId() + "_" + gps.getUpDown() + "_" + gps.getStopNo());
+    }
+
     public static List<StationRoute> getStationRoute(String lineCode, int directions) {
         return stationCacheMap.get(lineCode + "_" + directions);
     }
@@ -74,14 +94,14 @@ public class GeoCacheData {
         return null;
     }
-    public static Polygon getTccPolygon(String code){
+    public static Polygon getTccPolygon(String code) {
         return tccMap.get(code);
     }
     public void loadData() {
         final GeometryFactory geometryFactory = new GeometryFactory();
         //加载站点路由
-        String sql = "select r.LINE_CODE,r.DIRECTIONS,r.STATION_CODE,r.STATION_MARK,s.SHAPES_TYPE,s.G_LONX,s.G_LATY,ST_AsText(s.G_POLYGON_GRID) as G_POLYGON_GRID,s.RADIUS, r.STATION_ROUTE_CODE from bsth_c_stationroute r left join bsth_c_station s on r.station=s.id where r.destroy=0 order by r.station_route_code";
+        String sql = "select r.LINE_CODE,r.DIRECTIONS,r.STATION_CODE,r.STATION_MARK,s.SHAPES_TYPE,s.G_LONX,s.G_LATY,ST_AsText(s.G_POLYGON_GRID) as G_POLYGON_GRID,s.RADIUS, r.STATION_ROUTE_CODE,s.STATION_NAME from bsth_c_stationroute r left join bsth_c_station s on r.station=s.id where r.destroy=0 order by r.station_route_code";
         List<StationRoute> routeList = jdbcTemplate.query(sql, new RowMapper<StationRoute>() {
             @Override
             public StationRoute mapRow(ResultSet rs, int rowNum) throws SQLException {
@@ -93,11 +113,12 @@ public class GeoCacheData {
                 sRoute.setRadius(rs.getFloat("RADIUS"));
                 sRoute.setRouteSort(rs.getInt("STATION_ROUTE_CODE"));
                 sRoute.setMark(rs.getString("STATION_MARK"));
+                sRoute.setName(rs.getString("STATION_NAME"));
                 String shapesType = rs.getString("SHAPES_TYPE");
                 //多边形电子围栏
                 if (StringUtils.isNotEmpty(shapesType) && shapesType.equals("d")) {
-                    geometryFactory.createPolygon(parsePolygon(rs.getString("G_POLYGON_GRID")));
+                    sRoute.setPolygon(geometryFactory.createPolygon(parsePolygon(rs.getString("G_POLYGON_GRID"))));
                 }
                 return sRoute;
             }
@@ -105,8 +126,11 @@ public class GeoCacheData {
         //按线路和走向分组
         if (routeList.size() > 0) {
             ArrayListMultimap<String, StationRoute> tempMap = ArrayListMultimap.create();
+            Map<String, StationRoute> codeMap = new HashMap<>(routeList.size());
             for (StationRoute sr : routeList) {
                 tempMap.put(sr.getLineCode() + "_" + sr.getDirections(), sr);
+                //站点编码 ——> 和路由顺序对照
+                codeMap.put(sr.getLineCode() + "_" + sr.getDirections() + "_" + sr.getCode(), sr);
             }
             StationRouteComp srCom = new StationRouteComp();
@@ -118,6 +142,7 @@ public class GeoCacheData {
             }
             stationCacheMap = tempMap;
+            routeCodeMap = codeMap;
         }
         //加载停车场数据
@@ -133,11 +158,11 @@ public class GeoCacheData {
                 tccTempMap.put(tMap.get("PARK_CODE").toString()
                         , polygon);
             } catch (Exception e) {
-                logger.error("停车场：" + tMap.get("PARK_CODE") , e);
+                logger.error("停车场：" + tMap.get("PARK_CODE"), e);
             }
         }
-        if(tccTempMap.size() > 0)
+        if (tccTempMap.size() > 0)
             tccMap = tccTempMap;
     }
@@ -166,5 +191,4 @@ public class GeoCacheData {
         }
         return cds;
     }
-
 }
 \ No newline at end of file
+package com.bsth.data.gpsdata.arrival;
+
+import com.bsth.data.gpsdata.GpsEntity;
+import com.bsth.data.gpsdata.arrival.handlers.*;
+import com.bsth.data.gpsdata.arrival.utils.CircleQueue;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+/**
+ * gps 实时数据分析
+ * Created by panzhao on 2016/12/27.
+ */
+@Component
+public class GpsRealAnalyse {
+
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Autowired
+    OfflineSignalHandle offlineSignalHandle;
+    @Autowired
+    CorrectSignalHandle correctSignalHandle;
+    @Autowired
+    StationInsideHandle stationInsideHandle;
+    @Autowired
+    InOutStationSignalHandle inOutStationSignalHandle;
+    @Autowired
+    ReverseSignalHandle reverseSignalHandle;
+
+    //50个线程
+    static ExecutorService threadPool = Executors.newFixedThreadPool(50);
+
+    public void analyse(List<GpsEntity> list) {
+        CountDownLatch count = new CountDownLatch(list.size());
+
+        for(GpsEntity gps : list)
+            threadPool.execute(new SignalHandleThread(gps, count));
+
+        try {
+            //等待子线程结束
+            count.await();
+        } catch (InterruptedException e) {
+            logger.error("", e);
+        }
+    }
+
+    public class SignalHandleThread implements Runnable {
+
+        GpsEntity gps;
+        CountDownLatch count;
+
+        SignalHandleThread(GpsEntity gps, CountDownLatch count) {
+            this.gps = gps;
+            this.count = count;
+        }
+
+        @Override
+        public void run() {
+
+            try {
+                CircleQueue<GpsEntity> prevs = GeoCacheData.getGps(gps.getNbbm());
+                //掉线处理
+                offlineSignalHandle.handle(gps, prevs);
+                //状态处理
+                if(!correctSignalHandle.handle(gps, prevs))
+                    return;
+                //场，站内外判断
+                stationInsideHandle.handle(gps, prevs);
+                //反向处理
+                reverseSignalHandle.handle(gps, prevs);
+                //进出站动作处理
+                inOutStationSignalHandle.handle(gps, prevs);
+                GeoCacheData.putGps(gps);
+
+            } catch (Exception e) {
+                logger.error("", e);
+            } finally {
+                count.countDown();
+            }
+        }
+    }
+}
+package com.bsth.data.gpsdata.arrival;
+
+import com.bsth.data.gpsdata.GpsEntity;
+import com.bsth.data.gpsdata.arrival.utils.CircleQueue;
+
+/**
+ * Created by panzhao on 2016/12/27.
+ */
+public abstract class SignalHandle {
+
+    public abstract boolean handle(GpsEntity gps, CircleQueue<GpsEntity> prevs);
+
+    protected boolean isNotEmpty(CircleQueue<GpsEntity> prevs) {
+        return prevs != null && prevs.size() > 0 && prevs.getTail() != null;
+    }
+
+    /**
+     * 是不是异常信号
+     *
+     * @param gps
+     * @return
+     */
+    protected boolean isAbnormal(GpsEntity gps) {
+        return gps.getLat() == 0 || gps.getLon() == 0;
+    }
+
+    /**
+     * 连续异常信号个数统计
+     *
+     * @param prevs
+     * @return
+     */
+    protected int abnormalCount(CircleQueue<GpsEntity> prevs) {
+        int count = 0;
+
+        if (!isNotEmpty(prevs))
+            return count;
+
+        GpsEntity[] array = (GpsEntity[]) prevs.getQueue();
+        GpsEntity gps;
+        for (int i = array.length - 1; i > 0; i--) {
+            gps = array[i];
+
+            if (isAbnormal(gps))
+                count++;
+            else
+                break;
+        }
+
+        return count;
+    }
+
+    /**
+     * 车辆运行轨迹（最近20分钟）
+     * 0：上行 1：下行 -1：未知
+     *
+     * @param gps
+     * @return
+     */
+    protected int runTrack(GpsEntity gps, CircleQueue<GpsEntity> prevs) {
+        int rs = -1, count = 0;
+
+        long et = gps.getTimestamp() - (1000 * 60 * 20);
+        Object[] array = prevs.getQueue();
+        GpsEntity prev;
+        for(Object obj : array){
+            prev = (GpsEntity) obj;
+            if(prev.getTimestamp() < et)
+                break;
+
+
+        }
+        //for()
+        return 0;
+    }
+
+}
+package com.bsth.data.gpsdata.arrival.entity;
+
+/** 路由反转
+ * Created by panzhao on 2016/12/28.
+ */
+public class RouteReverse {
+
+    //反转个数
+    private int count;
+
+    //详细 1,2,3,2,1
+    private String detail;
+
+    //掉头站点
+    private String turned;
+
+    //开始时间
+    private long st;
+
+    //掉头时间
+    private long zt;
+
+    //结束时间
+    private long et;
+
+    //是否闭合
+    private boolean close;
+
+    public int getCount() {
+        return count;
+    }
+
+    public void setCount(int count) {
+        this.count = count;
+    }
+
+    public String getDetail() {
+        return detail;
+    }
+
+    public void setDetail(String detail) {
+        this.detail = detail;
+    }
+
+    public String getTurned() {
+        return turned;
+    }
+
+    public void setTurned(String turned) {
+        this.turned = turned;
+    }
+
+    public long getSt() {
+        return st;
+    }
+
+    public void setSt(long st) {
+        this.st = st;
+    }
+
+    public long getEt() {
+        return et;
+    }
+
+    public void setEt(long et) {
+        this.et = et;
+    }
+
+    public boolean isClose() {
+        return close;
+    }
+
+    public void setClose(boolean close) {
+        this.close = close;
+    }
+
+    public long getZt() {
+        return zt;
+    }
+
+    public void setZt(long zt) {
+        this.zt = zt;
+    }
+}
-package com.bsth.data.gpsdata.analyse;
+package com.bsth.data.gpsdata.arrival.entity;
 import com.vividsolutions.jts.geom.Point;
 import com.vividsolutions.jts.geom.Polygon;
@@ -58,6 +58,8 @@ public class StationRoute {
      */
     private StationRoute prve;
+    private String name;
+
     public String getCode() {
         return code;
     }
@@ -137,5 +139,13 @@ public class StationRoute {
     public void setMark(String mark) {
         this.mark = mark;
     }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
 }
+package com.bsth.data.gpsdata.arrival.handlers;
+
+import com.bsth.data.gpsdata.GpsEntity;
+import com.bsth.data.gpsdata.arrival.SignalHandle;
+import com.bsth.data.gpsdata.arrival.utils.CircleQueue;
+import com.bsth.data.schedule.DayOfSchedule;
+import com.bsth.entity.realcontrol.ChildTaskPlan;
+import com.bsth.entity.realcontrol.ScheduleRealInfo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * 信号状态纠正
+ * Created by panzhao on 2016/12/27.
+ */
+@Component
+public class CorrectSignalHandle extends SignalHandle {
+
+    @Autowired
+    DayOfSchedule dayOfSchedule;
+
+    @Override
+    public boolean handle(GpsEntity gps, CircleQueue<GpsEntity> prevs) {
+        Object task = dayOfSchedule.executeCurr(gps.getNbbm());
+        if(task == null)
+            return false;
+        ScheduleRealInfo sch;
+
+        //子任务
+        if(task.getClass().isAssignableFrom(ChildTaskPlan.class)){
+            ChildTaskPlan childTask = (ChildTaskPlan) task;
+            sch = childTask.getSchedule();
+        }
+        else
+            sch = (ScheduleRealInfo) task;
+
+        int updown = Integer.parseInt(sch.getXlDir());
+        //走向
+        if(gps.getUpDown() != updown){
+            gps.setUpDown(updown);
+            gps.setState(0);
+        }
+
+
+        return true;
+    }
+}
+package com.bsth.data.gpsdata.arrival.handlers;
+
+import com.bsth.data.LineConfigData;
+import com.bsth.data.gpsdata.GpsEntity;
+import com.bsth.data.gpsdata.arrival.GeoCacheData;
+import com.bsth.data.gpsdata.arrival.SignalHandle;
+import com.bsth.data.gpsdata.arrival.entity.StationRoute;
+import com.bsth.data.gpsdata.arrival.utils.CircleQueue;
+import com.bsth.data.gpsdata.arrival.utils.GeoUtils;
+import com.bsth.data.schedule.DayOfSchedule;
+import com.bsth.entity.realcontrol.LineConfig;
+import com.bsth.entity.realcontrol.ScheduleRealInfo;
+import com.bsth.service.directive.DirectiveService;
+import com.bsth.websocket.handler.SendUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 进出站动作处理
+ * Created by panzhao on 2016/12/27.
+ */
+@Component
+public class InOutStationSignalHandle extends SignalHandle{
+
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Autowired
+    DayOfSchedule dayOfSchedule;
+
+    @Autowired
+    LineConfigData lineConfigData;
+
+    @Autowired
+    SendUtils sendUtils;
+
+    @Autowired
+    DirectiveService directiveService;
+
+    @Override
+    public boolean handle(GpsEntity gps, CircleQueue<GpsEntity> prevs) {
+
+        if(isNotEmpty(prevs)){
+            GpsEntity prev = prevs.getTail();
+            if(isOutStation(gps, prev))
+                outStation(gps, prev);
+
+
+            if(isInStation(gps, prev))
+                inStation(gps, prev);
+        }
+
+        return true;
+    }
+
+    private boolean isOutStation(GpsEntity gps, GpsEntity prev){
+        //从站内到站外
+        if(prev.getInstation() > 0 && gps.getInstation() == 0)
+            return true;
+
+        //从站内到另一个站内
+        if(prev.getInstation() > 0 && gps.getInstation() > 0
+                && !prev.getStopNo().equals(gps.getStopNo()))
+            return true;
+        return false;
+    }
+
+    private boolean isInStation(GpsEntity gps, GpsEntity prev){
+        //从站外到站内
+        if(prev.getInstation() == 0 && gps.getInstation() > 0
+                /*&& !prev.getStopNo().equals(gps.getStopNo())*/){
+            return true;
+        }
+
+        //从站内到另一个站内
+        if(prev.getInstation() > 0 && gps.getInstation() > 0
+                && !prev.getStopNo().equals(gps.getStopNo()))
+            return true;
+        return false;
+    }
+
+    /**
+     * 出站
+     * @param gps 当前点
+     * @param prev 上一个点
+     */
+    private void outStation(GpsEntity gps, GpsEntity prev) {
+        ScheduleRealInfo sch = dayOfSchedule.executeCurr(gps.getNbbm());
+        String qdzCode = sch.getQdzCode();
+
+
+        //if(sch.getFcsjActual() != )
+
+        //起点发车
+        if(qdzCode != null && prev.getStopNo().equals(qdzCode)
+                && !willDepart(gps, prev, sch)){
+
+            sch.setFcsjActualAll(gps.getTimestamp());
+            //通知客户端
+            sendUtils.sendFcsj(sch);
+            //持久化
+            dayOfSchedule.save(sch);
+
+            //出站既出场
+            outStationAndOutPark(sch);
+            logger.info("班次：" + sch.getDfsj() + "发车， 时间：" + sch.getFcsjActual());
+        }
+    }
+
+    private void outStationAndOutPark(ScheduleRealInfo sch){
+        LineConfig config = lineConfigData.get(sch.getXlBm());
+        if (config != null && config.getOutConfig() == 2) {
+            //出站既出场
+            ScheduleRealInfo schPrev = dayOfSchedule.prev(sch);
+            if (schPrev != null && schPrev.getBcType().equals("out")) {
+                schPrev.setFcsjActualAll(sch.getFcsjActual());
+                schPrev.setZdsjActualAll(sch.getFcsjActual());
+            }
+        }
+    }
+
+    /**
+     * 进站
+     * @param gps 当前点
+     * @param prev 上一个点
+     */
+    private void inStation(GpsEntity gps, GpsEntity prev){
+        ScheduleRealInfo sch = dayOfSchedule.executeCurr(gps.getNbbm());
+        String zdzCode = sch.getZdzCode();
+
+        if(zdzCode != null && gps.getStopNo().equals(zdzCode)){
+
+            sch.setZdsjActualAll(gps.getTimestamp());
+            //已完成班次数
+            int doneSum = dayOfSchedule.doneSum(sch.getClZbh());
+            ScheduleRealInfo next = dayOfSchedule.next(sch);
+            //通知客户端
+            sendUtils.sendZdsj(sch, next, doneSum);
+            //持久化
+            dayOfSchedule.save(sch);
+            //下发调度指令
+            //directiveService.send60Dispatch(next, doneSum, "到站@系统");
+
+            //准备执行下一个班次
+            if (next != null) {
+                next.setQdzArrDatesj(sch.getZdsjActual());
+                dayOfSchedule.addExecPlan(next);
+
+                //进站既进场
+                inStationAndInPark(sch, next);
+
+                //将gps转换为下一个班次走向的站内信号
+                int updown = Integer.parseInt(next.getXlDir());
+                List<StationRoute> srs = GeoCacheData.getStationRoute(next.getXlBm(), updown);
+                StationRoute station = GeoUtils.gpsInStation(gps, srs);
+                if (station != null) {
+                    gps.setUpDown(updown);
+                    gps.setStopNo(station.getCode());
+                }
+            }
+        }
+       /* //如果出场班次计划终点时间5分钟后还未完成，检查一下车辆轨迹，是否已经在执行线路上班次
+        else if(sch.getBcType().equals("out")
+                && sch.getZdsj() != null
+                && gps.getTimestamp() - sch.getZdsjT() >= 1000 * 60 * 5){
+            logger.info("出场班次计划终点时间5分钟后还未完成");
+
+        }*/
+    }
+
+    /**
+     * 进站既进场
+     * @param sch
+     */
+    private void inStationAndInPark(ScheduleRealInfo sch, ScheduleRealInfo next){
+        LineConfig config = lineConfigData.get(sch.getXlBm());
+        if (next.getBcType().equals("in") &&
+                config != null && config.getOutConfig() == 2) {
+            next.setFcsjActualAll(sch.getZdsjActual());
+            next.setZdsjActualAll(sch.getZdsjActual());
+        }
+    }
+
+    /**
+     * 发车漂移判定（这里出现的误判，由车辆到达中途站的时候补偿）
+     * @param gps
+     * @param prev
+     * @param task
+     * @return
+     */
+    private boolean willDepart(GpsEntity gps, GpsEntity prev, Object task){
+
+/*        ScheduleRealInfo sch = (ScheduleRealInfo) task;
+        ScheduleRealInfo prevTask = dayOfSchedule.prev(sch);
+        if(prevTask == null || prevTask.getBcType().equals("out"))
+            return false;
+
+        //计划停站时间
+        int stopTimePlan = (int) (sch.getDfsjT() - prevTask.getZdsjT());
+
+        if(stopTimePlan < 1000 * 60 * 10)
+            return false;
+
+        //实际停站时间
+        if(prevTask.getZdsjActual() != null){
+            int actualTime = (int) (gps.getTimestamp() - prevTask.getZdsjActualTime());
+
+            if(actualTime < stopTimePlan * 0.8){
+                logger.info("漂移判定");
+
+                return true;
+            }
+        }*/
+        return false;
+    }
+}
+package com.bsth.data.gpsdata.arrival.handlers;
+
+import com.bsth.data.gpsdata.GpsEntity;
+import com.bsth.data.gpsdata.arrival.GeoCacheData;
+import com.bsth.data.gpsdata.arrival.SignalHandle;
+import com.bsth.data.gpsdata.arrival.utils.CircleQueue;
+import org.springframework.stereotype.Component;
+
+/**
+ * 信号断线重连处理
+ * Created by panzhao on 2016/12/27.
+ */
+@Component
+public class OfflineSignalHandle extends SignalHandle{
+
+    //断开3分钟，标记为重连信号
+    private final static int OFFLINE_TIME = 1000 * 60 * 3;
+
+    //断开70分钟，之前的信号不再有参考价值
+    private final static int CLEAR_TIME = 1000 * 60 * 70;
+
+    @Override
+    public boolean handle(GpsEntity gps, CircleQueue<GpsEntity> prevs) {
+        //异常信号不管
+        if(isAbnormal(gps)){
+            return true;
+        }
+
+        if(isNotEmpty(prevs)){
+            GpsEntity prev = prevs.getTail();
+            int space = (int) (gps.getTimestamp() - prev.getTimestamp());
+            if(space > OFFLINE_TIME)
+                gps.setSignalState("reconnection");
+
+            if(space > CLEAR_TIME){
+                //清理缓存的信号
+                GeoCacheData.clear(gps.getNbbm());
+            }
+        }
+        return true;
+    }
+}
+package com.bsth.data.gpsdata.arrival.handlers;
+
+import com.alibaba.fastjson.JSON;
+import com.bsth.data.gpsdata.GpsEntity;
+import com.bsth.data.gpsdata.arrival.GeoCacheData;
+import com.bsth.data.gpsdata.arrival.SignalHandle;
+import com.bsth.data.gpsdata.arrival.entity.RouteReverse;
+import com.bsth.data.gpsdata.arrival.entity.StationRoute;
+import com.bsth.data.gpsdata.arrival.utils.CircleQueue;
+import com.bsth.data.schedule.DayOfSchedule;
+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;
+
+/**
+ * 路由反向信号处理
+ * Created by panzhao on 2016/12/28.
+ */
+@Component
+public class ReverseSignalHandle extends SignalHandle {
+
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Autowired
+    DayOfSchedule dayOfSchedule;
+
+    @Override
+    public boolean handle(GpsEntity gps, CircleQueue<GpsEntity> prevs) {
+        if (!isNotEmpty(prevs))
+            return false;
+
+        GpsEntity prev = prevs.getTail();
+
+        if (isReverse(gps, prev)) {
+            RouteReverse reverse = reverseSearch(prevs, gps);
+
+            if (reverse.getCount() >= 2) {
+                //切换到下一个班次
+                ScheduleRealInfo sch = dayOfSchedule.executeCurr(gps.getNbbm());
+                if (sch.getBcType().equals("out") && sch.getZdsjT() != null && sch.getZdsjT() > gps.getTimestamp()) {
+                    return false;
+                }
+                dayOfSchedule.addExecPlan(dayOfSchedule.next(sch));
+
+                if (reverse.isClose()) {
+                    logger.info("区间掉头，车辆：" + gps.getNbbm() + " -" + JSON.toJSONString(reverse));
+                }
+            }
+        }
+        return false;
+    }
+
+    /**
+     * 搜索路由反向详细
+     *
+     * @param prevs
+     * @param gps
+     * @return
+     */
+    public RouteReverse reverseSearch(CircleQueue<GpsEntity> prevs, GpsEntity gps) {
+        RouteReverse routeReverse = new RouteReverse();
+        int count = 0;
+        String path = "";
+        String turned = null;
+
+        //当前站点
+        StationRoute curr = GeoCacheData.getRouteCode(gps), sr;
+        GpsEntity prev;
+        Object[] array = prevs.getQueue();
+        for (int i = array.length - 1; i > 0; i--) {
+            prev = (GpsEntity) array[i];
+
+            if(!prev.getUpDown().equals(gps.getUpDown()))
+                break;
+
+            if (prev.getInstation() == 1) {
+                sr = GeoCacheData.getRouteCode(prev);
+
+                if (sr.getRouteSort() > curr.getRouteSort()) {
+                    path += (curr.getCode() + ",");
+                    count++;
+                } else if (sr.getRouteSort() < curr.getRouteSort()) {
+                    path += (curr.getCode() + ",");
+                    //掉头点
+                    if (turned == null)
+                        turned = prev.getStopNo();
+
+                    //路径闭合
+                    if (sr.getCode().equals(gps.getStopNo())) {
+                        routeReverse.setClose(true);
+                        path += sr.getCode();
+                        break;
+                    }
+                }
+
+                curr = sr;
+            }
+        }
+
+        routeReverse.setCount(count);
+        routeReverse.setDetail(path);
+        routeReverse.setTurned(turned);
+        return routeReverse;
+    }
+
+    /**
+     * 是否反向
+     *
+     * @param gps
+     * @param prev
+     * @return
+     */
+    public boolean isReverse(GpsEntity gps, GpsEntity prev) {
+        if (gps.getInstation() == 1
+                &&
+                gps.getUpDown().equals(prev.getUpDown())
+                && !gps.getStopNo().equals(prev.getStopNo())) {
+
+            StationRoute currStation = GeoCacheData.getRouteCode(gps);
+            StationRoute prevStation = GeoCacheData.getRouteCode(prev);
+
+            if (currStation == null || prevStation == null)
+                return false;
+
+            if (currStation.getRouteSort() < prevStation.getRouteSort())
+                return true;
+        }
+        return false;
+    }
+}
+package com.bsth.data.gpsdata.arrival.handlers;
+
+import com.bsth.data.gpsdata.GpsEntity;
+import com.bsth.data.gpsdata.arrival.GeoCacheData;
+import com.bsth.data.gpsdata.arrival.SignalHandle;
+import com.bsth.data.gpsdata.arrival.entity.StationRoute;
+import com.bsth.data.gpsdata.arrival.utils.CircleQueue;
+import com.bsth.data.gpsdata.arrival.utils.GeoUtils;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 站内站外判定
+ * Created by panzhao on 2016/12/27.
+ */
+@Component
+public class StationInsideHandle extends SignalHandle {
+
+
+    @Override
+    public boolean handle(GpsEntity gps, CircleQueue<GpsEntity> prevs) {
+        //是否在场内
+        String parkCode = GeoUtils.gpsInCarpark(gps);
+        if (parkCode != null) {
+            gps.setInstation(2);
+            gps.setStopNo(parkCode);
+        }
+
+        //是否在站内
+        List<StationRoute> srs = GeoCacheData.getStationRoute(gps.getLineId(), gps.getUpDown());
+        StationRoute station = GeoUtils.gpsInStation(gps, srs);
+        if (station != null) {
+            gps.setInstation(1);
+            gps.setStopNo(station.getCode());
+            gps.setStation(station);
+        }
+
+        //在场，站外
+        if(gps.getInstation() == 0 && isNotEmpty(prevs)){
+            //继承上一个点的站点编码
+            GpsEntity prev = prevs.getTail();
+            gps.setStopNo(prev.getStopNo());
+        }
+
+        return true;
+    }
+}
-package com.bsth.data.gpsdata.analyse;
+package com.bsth.data.gpsdata.arrival.utils;
 import java.util.Arrays;
@@ -19,12 +19,12 @@ public class CircleQueue&lt;T&gt; {
     public Object[] elementData;
     /**
-     * 队头(先进先出)
+     * 头
      */
     public int head = 0;
     /**
-     * 队尾
+     * 尾
      */
     public int tail = 0;
@@ -39,7 +39,7 @@ public class CircleQueue&lt;T&gt; {
     }
     /**
-     * 获取循环队列的大小(包含元素的个数)
+     * 获取循环队列的大小
      */
     public int size() {
         if (isEmpty()) {
@@ -87,10 +87,12 @@ public class CircleQueue&lt;T&gt; {
      * @return 取 循环队列里的值（先进的index=0）
      */
     public Object[] getQueue() {
-        final Object[] elementDataSort = new Object[capacity];
+        final Object[] elementDataSort;
         final Object[] elementDataCopy = elementData.clone();
         if (isEmpty()) {
+            elementDataSort = new Object[0];
         } else if (isFull()) {
+            elementDataSort = new Object[capacity];
             int indexMax = capacity;
             int indexSort = 0;
             for (int i = head; i < indexMax;) {
@@ -103,6 +105,7 @@ public class CircleQueue&lt;T&gt; {
                 }
             }
         } else {
+            elementDataSort = new Object[tail];
             for (int i = 0; i < tail; i++) {
                 elementDataSort[i] = elementDataCopy[i];
             }
@@ -110,6 +113,10 @@ public class CircleQueue&lt;T&gt; {
         return elementDataSort;
     }
+    /**
+     * 取最后一个值
+     * @return
+     */
     public T getTail(){
         return elementData[tail] == null?null:(T)elementData[tail];
     }
-package com.bsth.data.gpsdata.analyse.util;
+package com.bsth.data.gpsdata.arrival.utils;
 import com.bsth.data.gpsdata.GpsEntity;
-import com.bsth.data.gpsdata.analyse.GeoCacheData;
-import com.bsth.data.gpsdata.analyse.StationRoute;
+import com.bsth.data.gpsdata.arrival.GeoCacheData;
+import com.bsth.data.gpsdata.arrival.entity.StationRoute;
 import com.vividsolutions.jts.geom.Coordinate;
 import com.vividsolutions.jts.geom.GeometryFactory;
 import com.vividsolutions.jts.geom.Point;
-package com.bsth.data.gpsdata.analyse;
+package com.bsth.data.gpsdata.arrival.utils;
+
+import com.bsth.data.gpsdata.arrival.entity.StationRoute;
 import java.util.Comparator;
@@ -2,13 +2,19 @@ package com.bsth.data.gpsdata.recovery;
 import com.bsth.data.BasicData;
 import com.bsth.data.gpsdata.GpsEntity;
-import com.bsth.data.gpsdata.analyse.components.GpsArrival;
+import com.bsth.data.gpsdata.arrival.GeoCacheData;
+import com.bsth.data.gpsdata.arrival.handlers.*;
+import com.bsth.data.gpsdata.arrival.utils.CircleQueue;
 import com.bsth.util.db.DBUtils_MS;
 import com.google.common.collect.ArrayListMultimap;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.jdbc.core.RowMapper;
+import org.springframework.stereotype.Component;
 import java.sql.ResultSet;
 import java.sql.SQLException;
@@ -18,20 +24,25 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 /**
- * 数据恢复
+ * gps数据恢复
  * Created by panzhao on 2016/12/24.
  */
-public class GpsDataRecovery {
+@Component
+public class GpsDataRecovery implements ApplicationContextAware{
     static Logger logger = LoggerFactory.getLogger(GpsDataRecovery.class);
     public static boolean run;
-    static ExecutorService threadPool = Executors.newFixedThreadPool(50);
+    static ExecutorService threadPool = Executors.newFixedThreadPool(10);
-    private static CountDownLatch count;
+    static OfflineSignalHandle offlineSignalHandle;
+    static CorrectSignalHandle correctSignalHandle;
+    static StationInsideHandle stationInsideHandle;
+    static InOutStationSignalHandle inOutStationSignalHandle;
+    static ReverseSignalHandle reverseSignalHandle;
-    public static void recovery() {
+    public void recovery() {
         List<GpsEntity> list = loadData();
         //按车辆分组数据
@@ -41,18 +52,20 @@ public class GpsDataRecovery {
                 listMap.put(gps.getNbbm(), gps);
         }
-        count = new CountDownLatch(listMap.keySet().size());
         Set<String> keys = listMap.keySet();
+
+        CountDownLatch count = new CountDownLatch(keys.size());
+        GpsComp comp = new GpsComp();
         for (String nbbm : keys) {
-            threadPool.execute(new RecoveryDataThread(listMap.get(nbbm), count));
-            /*if(nbbm.equals("W9A-250"))
-                new RecoveryDataThread(listMap.get(nbbm), count).run();*/
+            Collections.sort(listMap.get(nbbm), comp);
+            threadPool.execute(new RecoveryThread(listMap.get(nbbm), count));
         }
+
         try {
-            //等待子线程结束
             count.await();
-            logger.info("GPS 数据恢复完成....");
+            run = false;
+            logger.info("数据恢复完成....");
         } catch (InterruptedException e) {
             logger.error("", e);
         }
@@ -63,11 +76,11 @@ public class GpsDataRecovery {
      *
      * @return
      */
-    public static List<GpsEntity> loadData() {
+    public List<GpsEntity> loadData() {
         Calendar calendar = Calendar.getInstance();
         int dayOfYear = calendar.get(Calendar.DAY_OF_YEAR);
-        String sql = "select DEVICE_ID,LAT,LON,TS,SPEED_GPS,LINE_ID,SERVICE_STATE from BSTH_C_GPS_INFO where days_year=" + dayOfYear;
+        String sql = "select DEVICE_ID,LAT,LON,TS,SPEED_GPS,LINE_ID,SERVICE_STATE from bsth_c_gps_info where days_year=" + dayOfYear;
         JdbcTemplate jdbcTemplate = new JdbcTemplate(DBUtils_MS.getDataSource());
         List<GpsEntity> list =
@@ -102,43 +115,58 @@ public class GpsDataRecovery {
         return (((serviceState & 0x10000000) == 0x10000000) ? 1 : 0);
     }
-    public static class RecoveryDataThread implements Runnable {
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        offlineSignalHandle = applicationContext.getBean(OfflineSignalHandle.class);
+        correctSignalHandle = applicationContext.getBean(CorrectSignalHandle.class);
+        stationInsideHandle = applicationContext.getBean(StationInsideHandle.class);
+        inOutStationSignalHandle = applicationContext.getBean(InOutStationSignalHandle.class);
+        reverseSignalHandle = applicationContext.getBean(ReverseSignalHandle.class);
+    }
+
+    public static class GpsComp implements Comparator<GpsEntity>{
+
+        @Override
+        public int compare(GpsEntity g1, GpsEntity g2) {
+            return g1.getTimestamp().compareTo(g2.getTimestamp());
+        }
+    }
+    public static class RecoveryThread implements Runnable{
         List<GpsEntity> list;
         CountDownLatch count;
-        public RecoveryDataThread(List<GpsEntity> list, CountDownLatch count) {
+        RecoveryThread(List<GpsEntity> list, CountDownLatch count){
             this.list = list;
             this.count = count;
         }
-
         @Override
         public void run() {
             try {
-                //排序
-                Collections.sort(list, new GpsComp());
-                //依次跑完gps
-                //int i = 0;
+                //循环gps恢复数据
+                CircleQueue<GpsEntity> prevs;
+
                 for(GpsEntity gps : list){
-                   /* i++;
-                    if(i == 383){
-                        System.out.println("aaa");
-                    }*/
-                    GpsArrival.arrival(gps);
+                    prevs = GeoCacheData.getGps(gps.getNbbm());
+                    //掉线处理
+                    offlineSignalHandle.handle(gps, prevs);
+                    //状态处理
+                    if(!correctSignalHandle.handle(gps, prevs))
+                        continue;
+                    //场，站内外判断
+                    stationInsideHandle.handle(gps, prevs);
+                    //反向处理
+                    reverseSignalHandle.handle(gps, prevs);
+                    //进出站动作处理
+                    inOutStationSignalHandle.handle(gps, prevs);
+                    GeoCacheData.putGps(gps);
                 }
-            } catch (Exception e) {
+            }catch (Exception e){
                 logger.error("", e);
-            } finally {
+            }
+            finally {
                 count.countDown();
             }
         }
     }
-
-    public static class GpsComp implements Comparator<GpsEntity>{
-
-        @Override
-        public int compare(GpsEntity g1, GpsEntity g2) {
-            return (int) (g1.getTimestamp() - g2.getTimestamp());
-        }
-    }
-}
+}
 \ No newline at end of file
 package com.bsth.data.pilot80;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.List;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
 import com.bsth.data.BasicData;
 import com.bsth.data.LineConfigData;
 import com.bsth.data.gpsdata.GpsEntity;
@@ -23,6 +14,14 @@ import com.bsth.repository.directive.D80Repository;
 import com.bsth.service.directive.DirectiveService;
 import com.bsth.websocket.handler.SendUtils;
 import com.google.common.collect.ArrayListMultimap;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
 /**
  * 
@@ -180,7 +179,7 @@ public class PilotReport {
 				return;
 			LineConfig conf = lineConfigData.get(sch.getXlBm());
-			if(conf.getInConfig() == 1){
+			if(conf.getOutConfig() == 1){
 				//为相关班次写入进场时间
 				sch.setZdsjActualAll(d80.getTimestamp());
@@ -37,547 +37,538 @@ import java.util.*;
 import java.util.concurrent.TimeUnit;
 /**
- * 
+ * @author PanZhao
  * @ClassName: DayOfSchedule
  * @Description: TODO(当日实际排班)
- * @author PanZhao
  * @date 2016年8月15日 上午10:16:12
- *
  */
 @Component
 public class DayOfSchedule implements CommandLineRunner {
-	Logger logger = LoggerFactory.getLogger(this.getClass());
-
-	// 按车辆分组的班次数据
-	private static ArrayListMultimap<String, ScheduleRealInfo> nbbmScheduleMap;
-
-	// 班次主键映射
-	private static Map<Long, ScheduleRealInfo> id2SchedulMap;
-
-	// 车辆和排班起终点站对照（包括进出的停车场，区间起终点）
-	private static TreeMultimap<String, String> nbbm2SEStationMap;
-	
-	//车辆 ——> 当前执行班次
-	private static Map<String, ScheduleRealInfo> carExecutePlanMap;
-
-	// 持久化缓冲区
-	public static LinkedList<ScheduleRealInfo> pstBuffer;
-
-	// 排序器
-	private static ScheduleComparator.FCSJ schFCSJComparator;
-
-	@Autowired
-	LineConfigData lineConfigData;
-
-	@Autowired
-	ScheduleRealInfoRepository schRepository;
-
-	@Autowired
-	SchedulePlanInfoService schPlanService;
-
-	@Autowired
-	SchAttrCalculator schAttrCalculator;
-
-	@Autowired
-	SendUtils sendUtils;
-	
-	@Autowired
-	GpsRealData gpsRealData;
-
-	/** 线路当前使用的排班的日期 */
-	public static Map<String, String> currSchDateMap;
-
-	static {
-		nbbmScheduleMap = ArrayListMultimap.create();
-		id2SchedulMap = new HashMap<>();
-		pstBuffer = new LinkedList<>();
-		schFCSJComparator = new ScheduleComparator.FCSJ();
-		currSchDateMap = new HashMap<>();
-		nbbm2SEStationMap = TreeMultimap.create();
-		carExecutePlanMap = new HashMap<>();
-	}
-
-	@Autowired
-	ScheduleRefreshThread scheduleRefreshThread;
-	
-	@Autowired
-	SchedulePstThread schedulePstThread;
-	
-	@Autowired
-	FirstScheduleCheckThread firstScheduleCheckThread;
-	
-	@Autowired
-	ScheduleLateThread scheduleLateThread;
-
-	@Autowired
-	SubmitToTrafficManage submitToTrafficManage;
-
-	@Autowired
-	LineConfigData lineConfigs;
-
-	@Autowired
-	BasicData.BasicDataLoader dataLoader;
-
-	private static DateTimeFormatter fmtyyyyMMdd = DateTimeFormat.forPattern("yyyy-MM-dd")
-				,fmtHHmm = DateTimeFormat.forPattern("HH:mm");
-
-	@Override
-	public void run(String... arg0) throws Exception {
-		//加载基础数据
-		dataLoader.loadAllData();
-		//从数据库恢复排班
-		//dataRecovery();
-
-		//翻班线程
-		Application.mainServices.scheduleWithFixedDelay(scheduleRefreshThread, 15, 240, TimeUnit.SECONDS);
-		//入库
-		Application.mainServices.scheduleWithFixedDelay(schedulePstThread, 60, 60, TimeUnit.SECONDS);
-		//首班出场指令补发器
-//		Application.mainServices.scheduleWithFixedDelay(firstScheduleCheckThread, 30, 240, TimeUnit.SECONDS);
-		//班次误点扫描
-		Application.mainServices.scheduleWithFixedDelay(scheduleLateThread, 60, 60, TimeUnit.SECONDS);
-
-		//每天凌晨2点20提交数据到运管处
-		long diff = (DateUtils.getTimestamp() + 1000*60*140) - System.currentTimeMillis();
-		if(diff < 0)
-			diff+=(1000*60*60*24);
-
-		logger.info(diff/1000/60 + "分钟之后提交到运管处");
-		//Application.mainServices.scheduleWithFixedDelay(submitToTrafficManage, diff / 1000, 60 * 60 * 24, TimeUnit.SECONDS);
-	}
-
-	//数据恢复
-	private void dataRecovery() {
-		GpsDataRecovery.run = true;
-
-		Collection<LineConfig> confs = lineConfigs.getAll();
-		String lineCode, currSchDate;
-		for(LineConfig conf : confs){
-			lineCode = conf.getLine().getLineCode();
-			currSchDate = calcSchDate(lineCode);
-			//加载班次数据
-			reloadSch(lineCode, currSchDate, false);
-		}
+    Logger logger = LoggerFactory.getLogger(this.getClass());
-		//恢复gps数据
-		GpsDataRecovery.recovery();
-	}
-
-	public Map<String, String> getCurrSchDate() {
-		return currSchDateMap;
-	}
-
-	/**
-	 * 
-	 * @Title: calcSchDateB
-	 * @Description: TODO(计算线路当前应该使用的排班日期)
-	 */
-	public String calcSchDate(String lineCode) {
-		LineConfig conf = lineConfigData.get(lineCode);
-		long ct = System.currentTimeMillis();
-		
-		String schDate = fmtyyyyMMdd.print(ct);
-		// 小于当天起始运营时间,则取前一天的排班
-		if (ct < conf.getCurrStartTime())
-			schDate = DateUtils.subtractDay(schDate, 1);
-
-		return schDate;
-	}
-
-	/**
-	 * @Title: reloadSch
-	 * @Title: reloadSch
-	 * @Description: TODO(重新载入排班)
-	 * @param @param
-	 *            lineCode 线路编码
-	 * @param @param
-	 *            schDate 班次日期 yyyy-MM-dd
-	 * @param @param
-	 *            forcePlan 强制从计划调度重新抓取
-	 */
-	public int reloadSch(String lineCode, String schDate, boolean forcePlan) {
-		try {
-			List<ScheduleRealInfo> list;
-
-			if (forcePlan)
-				removeRealSch(lineCode, schDate);
-			else
-				clearRAMData(lineCode);
-
-			if (existRealSch(lineCode, schDate))
-				list = loadRealSch(lineCode, schDate);// 从实际排班表加载
-			else {
-				list = loadPlanSch(lineCode, schDate);// 从计划排班表加载
-				// 写入数据库
-				batchSave(list);
-			}
-
-			//更新线路和班次日期对照
-			currSchDateMap.put(lineCode, schDate);
-			//添加到缓存
-			putAll(list);
-			
-			Set<String> cars = searchAllCars(list);
-			for(String nbbm : cars){
-				//计算“起点站应到”时间
-				schAttrCalculator.calcQdzTimePlan(nbbmScheduleMap.get(nbbm));
-				//车辆 ——> 要执行的班次对照
-				carExecutePlanMap.put(nbbm, schAttrCalculator.calcCurrentExecSch(nbbmScheduleMap.get(nbbm)));
-			}
-
-			//是否是出站即出场
-			LineConfig conf = lineConfigData.get(lineCode);
-			if(conf.getOutConfig() == 2){
-				for(String nbbm : cars)
-					schAttrCalculator.connectOutSchedule(nbbmScheduleMap.get(nbbm));
-			}
-
-			// 页面 翻班通知
-			sendUtils.shiftSchedule(lineCode);
-		} catch (Exception e) {
-			logger.error("", e);
-			return -1;
-		}
+    // 按车辆分组的班次数据
+    private static ArrayListMultimap<String, ScheduleRealInfo> nbbmScheduleMap;
-		return 0;
-	}
-
-	/**
-	 * 
-	 * @Title: searchAllCars 
-	 * @Description: TODO(搜索班次集合中的车辆) 
-	 */
-	private Set<String> searchAllCars(List<ScheduleRealInfo> list) {
-		Set<String> cars = new HashSet<>();
-		for(ScheduleRealInfo sch : list)
-			cars.add(sch.getClZbh());
-		
-		return cars;
-	}
-
-	private void putAll(List<ScheduleRealInfo> list) {
-		for (ScheduleRealInfo sch : list) 
-			put(sch);
-	}
-
-	/**
-	 * @Title: removeRealSch
-	 * @Description: TODO(清除实际排班，包括数据库和内存数据)
-	 * @param @param
-	 *            lineCode 线路编码
-	 * @param @param
-	 *            schDate 班次日期 yyyy-MM-dd
-	 */
-	public void removeRealSch(String lineCode, String schDate) throws Exception {
-		try {
-			// 清理数据库数据
-			schRepository.deleteByLineCodeAndDate(lineCode + "", schDate);
-
-			// 清理内存数据
-			clearRAMData(lineCode + "");
-		} catch (Exception e) {
-			logger.error("removeRealSch error, " + lineCode + " -" + schDate, e);
-			throw e;
-		}
-	}
-
-	/**
-	 * 
-	 * @Title: clearRAMData
-	 * @Description: TODO(清理内存数据)
-	 */
-	public void clearRAMData(String lineCode) {
-		int count = 0;
-		List<ScheduleRealInfo> remList = new ArrayList<>();
-		Collection<ScheduleRealInfo> schs = nbbmScheduleMap.values();
-		for (ScheduleRealInfo sch : schs) {
-			if (sch.getXlBm().equals(lineCode))
-				remList.add(sch);
-		}
-		
-		for(ScheduleRealInfo sch : remList){
-			if(null != sch){
-				nbbmScheduleMap.remove(sch.getClZbh(), sch);
-				id2SchedulMap.remove(sch.getId());
-				count ++;
-			}
-		}
-		
-		logger.info(lineCode + "排班清理 " + count);
-	}
-
-	/**
-	 * @Title: existRealSch
-	 * @Description: TODO(实际排班是否已存在)
-	 */
-	public boolean existRealSch(String lineCode, String schDate) {
-		int count = schRepository.countByLineCodeAndDate(lineCode, schDate);
-		return count > 0;
-	}
-
-	/**
-	 * @Title: loadRealSch
-	 * @Description: TODO(从实际排班表加载数据)
-	 */
-	public List<ScheduleRealInfo> loadRealSch(String lineCode, String schDate) {
-		return schRepository.findByLineCodeAndDate(lineCode, schDate);
-	}
-
-	/**
-	 * @Title: loadPlanSch
-	 * @Description: TODO(从计划排班表加载数据)
-	 */
-	public List<ScheduleRealInfo> loadPlanSch(String lineCode, String schDate) {
-		logger.info("从计划排班表恢复排班，lineCode: " + lineCode + ", schDate: " + schDate);
-		List<ScheduleRealInfo> realList = new ArrayList<>();
-
-		try {
-			Map<String, Object> data = new HashMap<>();
-
-			data.put("scheduleDate_eq", fmtyyyyMMdd.parseDateTime(schDate).toDate());
-			data.put("xlBm_eq", lineCode);
-
-			// 查询计划排班
-			List<SchedulePlanInfo> planItr = cleanSchPlanItr(schPlanService.list(data).iterator());
-
-			// 转换为实际排班
-			realList = JSONArray.parseArray(JSON.toJSONString(planItr), ScheduleRealInfo.class);
-
-			SimpleDateFormat sdf = new SimpleDateFormat("HH:mm");
-			String fcsj;
-			for (ScheduleRealInfo sch : realList) {
-				sch.setScheduleDateStr(fmtyyyyMMdd.print(sch.getScheduleDate().getTime()));
-				sch.setRealExecDate(sch.getScheduleDateStr());
-
-				if(StringUtils.isEmpty(sch.getFcsj()))
-					sch.setFcsj("00:00");
-
-				fcsj=sch.getFcsj().trim();
-				//处理一下发车时间格式没有:号的问题
-				if(fcsj.indexOf(":") == -1 && fcsj.length() >= 4){
-					sch.setFcsj(fcsj.substring(0, 2) + ":" + fcsj.substring(2, 4));
-				}
-
-				try {
-					sdf.parse(sch.getFcsj());
-				} catch (ParseException e) {
-					//发车时间仍然校验不过的，直接写成00:00
-					sch.setFcsj("00:00");
-				}
-				sch.setDfsj(sch.getFcsj());
-
-				// 计划终点时间
-				if (sch.getBcsj() != null) {
-					sch.setZdsj(fmtHHmm.print(fmtHHmm.parseMillis(sch.getFcsj()) + (sch.getBcsj() * 60 * 1000)));
-					sch.setLate(false);
-				}
-				//计划里程为0，设置NULL
-				if(sch.getJhlc() != null && sch.getJhlc() == 0)
-					sch.setJhlc(null);
-			}
-		} catch (Exception e) {
-			logger.error("", e);
-		}
-		return realList;
-	}
-
-	/**
-	 * @Title: batchSave
-	 * @Description: TODO(批量入库)
-	 */
-	private void batchSave(List<ScheduleRealInfo> list) {
-		// 查询数据库最大ID
-		Long id = schRepository.getMaxId();
-		if (null == id)
-			id = 0L;
-		id++;
-
-		SimpleDateFormat sdfyyyyMMdd = new SimpleDateFormat("yyyy-MM-dd");
-		for (ScheduleRealInfo item : list) {
-			item.setSpId(item.getId());// 保留原始的计划ID
-			item.setId(id++);// 设置ID
-			item.setScheduleDateStr(sdfyyyyMMdd.format(item.getScheduleDate()));
-		}
+    // 班次主键映射
+    private static Map<Long, ScheduleRealInfo> id2SchedulMap;
-		// 入库
-		new BatchSaveUtils<ScheduleRealInfo>().saveList(list, ScheduleRealInfo.class);
-	}
+    // 车辆和排班起终点站对照（包括进出的停车场，区间起终点）
+    private static TreeMultimap<String, String> nbbm2SEStationMap;
-	private List<SchedulePlanInfo> cleanSchPlanItr(Iterator<SchedulePlanInfo> itrab) {
-		List<SchedulePlanInfo> list = new ArrayList<>();
+    //车辆 ——> 当前执行班次
+    private static Map<String, ScheduleRealInfo> carExecutePlanMap;
-		SchedulePlanInfo sp;
-		while (itrab.hasNext()) {
-			sp = itrab.next();
-			sp.setSchedulePlan(null);
-			list.add(sp);
-		}
-		return list;
-	}
-
-	/**
-	 * 
-	 * @Title: findByLineCode
-	 * @Description: TODO(lineCode 获取班次)
-	 */
-	public List<ScheduleRealInfo> findByLineCode(String lineCode) {
-		List<ScheduleRealInfo> rs = new ArrayList<>();
+    // 持久化缓冲区
+    public static LinkedList<ScheduleRealInfo> pstBuffer;
-		Collection<ScheduleRealInfo> schs = nbbmScheduleMap.values();
-		for (ScheduleRealInfo sch : schs) {
-			if (sch.getXlBm().equals(lineCode))
-				rs.add(sch);
-		}
-		return rs;
-	}
-	
-	/**
-	 * 
-	 * @Title: findCarByLineCode 
-	 * @Description: TODO(线路下运营的车辆) 
-	 */
-	public Set<String> findCarByLineCode(String lineCode){
-		Set<String> rs = new HashSet<>();
-
-		Collection<ScheduleRealInfo> schs = nbbmScheduleMap.values();
-		for (ScheduleRealInfo sch : schs) {
-			if (sch.getXlBm().equals(lineCode))
-				rs.add(sch.getClZbh());
-		}
-		
-		return rs;
-	}
-
-	public List<ScheduleRealInfo> findByNbbm(String nbbm) {
-		return nbbmScheduleMap.get(nbbm);
-	}
-
-	/**
-	 * 
-	 * @Title: findByLineAndUpDown
-	 * @Description: TODO(lineCode 和走向获取班次)
-	 */
-	public List<ScheduleRealInfo> findByLineAndUpDown(String lineCode, Integer upDown) {
-		List<ScheduleRealInfo> list = findByLineCode(lineCode), rs = new ArrayList<>();
-
-		for (ScheduleRealInfo sch : list) {
-			if (sch.getXlDir().equals(upDown + ""))
-				rs.add(sch);
-		}
-		return rs;
-	}
-
-	public ScheduleRealInfo get(long id) {
-		return id2SchedulMap.get(id);
-	}
-
-	public Set<String> getSEStationList(String nbbm) {
-		return nbbm2SEStationMap.get(nbbm);
-	}
-
-	/**
-	 * 
-	 * @Title: next
-	 * @Description: TODO(下一个班次)
-	 */
-	public ScheduleRealInfo next(ScheduleRealInfo sch) {
-
-		List<ScheduleRealInfo> list = nbbmScheduleMap.get(sch.getClZbh());
-		int outConfig = -1;
-		LineConfig config = lineConfigData.get(sch.getXlBm());
-		if(config != null)
-			outConfig = config.getOutConfig();
-		
-		boolean flag = false;
-		ScheduleRealInfo next = null;
-		for(ScheduleRealInfo temp : list){
-			if(temp.getId() == sch.getId()){
-				flag = true;
-				continue;
-			}
-			//忽略烂班
-			if(temp.isDestroy())
-				continue;
+    // 排序器
+    private static ScheduleComparator.FCSJ schFCSJComparator;
-			//出站既出场，忽略出场班次
-			if(outConfig == 2 && temp.getBcType().equals("out"))
-				continue;
-			
-			if(flag){
-				next = temp;
-				break;
-			}
-		}
-		return next;
-	}
-
-	/**
-	 * 上一个班次
-	 * @param sch
-	 * @return
-	 */
-	public ScheduleRealInfo prev(ScheduleRealInfo sch){
-		List<ScheduleRealInfo> list = nbbmScheduleMap.get(sch.getClZbh());
-
-		//boolean flag = false;
-		ScheduleRealInfo prev = null;
-		int size = list.size();
-
-		for(int i = 0; i < size; i ++){
-			if(list.get(i).isDestroy())
-				continue;
+    @Autowired
+    LineConfigData lineConfigData;
+
+    @Autowired
+    ScheduleRealInfoRepository schRepository;
+
+    @Autowired
+    SchedulePlanInfoService schPlanService;
+
+    @Autowired
+    SchAttrCalculator schAttrCalculator;
+
+    @Autowired
+    SendUtils sendUtils;
+
+    @Autowired
+    GpsRealData gpsRealData;
+
+    /**
+     * 线路当前使用的排班的日期
+     */
+    public static Map<String, String> currSchDateMap;
+
+    static {
+        nbbmScheduleMap = ArrayListMultimap.create();
+        id2SchedulMap = new HashMap<>();
+        pstBuffer = new LinkedList<>();
+        schFCSJComparator = new ScheduleComparator.FCSJ();
+        currSchDateMap = new HashMap<>();
+        nbbm2SEStationMap = TreeMultimap.create();
+        carExecutePlanMap = new HashMap<>();
+    }
+
+    @Autowired
+    ScheduleRefreshThread scheduleRefreshThread;
+
+    @Autowired
+    SchedulePstThread schedulePstThread;
+
+    @Autowired
+    FirstScheduleCheckThread firstScheduleCheckThread;
+
+    @Autowired
+    ScheduleLateThread scheduleLateThread;
+
+    @Autowired
+    SubmitToTrafficManage submitToTrafficManage;
+
+    @Autowired
+    LineConfigData lineConfigs;
+
+    @Autowired
+    BasicData.BasicDataLoader dataLoader;
+
+    @Autowired
+    GpsDataRecovery gpsDataRecovery;
+
+    private static DateTimeFormatter fmtyyyyMMdd = DateTimeFormat.forPattern("yyyy-MM-dd"), fmtHHmm = DateTimeFormat.forPattern("HH:mm");
+
+    @Override
+    public void run(String... arg0) throws Exception {
+        //加载基础数据
+        dataLoader.loadAllData();
+        //从数据库恢复排班
+        dataRecovery();
+
+        //翻班线程
+//        Application.mainServices.scheduleWithFixedDelay(scheduleRefreshThread, 15, 240, TimeUnit.SECONDS);
+        //入库
+//        Application.mainServices.scheduleWithFixedDelay(schedulePstThread, 60, 60, TimeUnit.SECONDS);
+        //首班出场指令补发器
+//		Application.mainServices.scheduleWithFixedDelay(firstScheduleCheckThread, 30, 240, TimeUnit.SECONDS);
+        //班次误点扫描
+        Application.mainServices.scheduleWithFixedDelay(scheduleLateThread, 60, 60, TimeUnit.SECONDS);
+
+        //每天凌晨2点20提交数据到运管处
+        long diff = (DateUtils.getTimestamp() + 1000 * 60 * 140) - System.currentTimeMillis();
+        if (diff < 0)
+            diff += (1000 * 60 * 60 * 24);
+
+        logger.info(diff / 1000 / 60 + "分钟之后提交到运管处");
+        //Application.mainServices.scheduleWithFixedDelay(submitToTrafficManage, diff / 1000, 60 * 60 * 24, TimeUnit.SECONDS);
+    }
+
+    //数据恢复
+    private void dataRecovery() {
+        GpsDataRecovery.run = true;
+
+        Collection<LineConfig> confs = lineConfigs.getAll();
+        String lineCode, currSchDate;
+        for (LineConfig conf : confs) {
+            lineCode = conf.getLine().getLineCode();
+            currSchDate = calcSchDate(lineCode);
+            //加载班次数据
+            reloadSch(lineCode, currSchDate, false);
+        }
+
+        //恢复gps数据
+        gpsDataRecovery.recovery();
+    }
+
+    public Map<String, String> getCurrSchDate() {
+        return currSchDateMap;
+    }
+
+    /**
+     * @Title: calcSchDateB
+     * @Description: TODO(计算线路当前应该使用的排班日期)
+     */
+    public String calcSchDate(String lineCode) {
+        LineConfig conf = lineConfigData.get(lineCode);
+        long ct = System.currentTimeMillis();
+
+        String schDate = fmtyyyyMMdd.print(ct);
+        // 小于当天起始运营时间,则取前一天的排班
+        if (ct < conf.getCurrStartTime())
+            schDate = DateUtils.subtractDay(schDate, 1);
+
+        return schDate;
+    }
+
+    /**
+     * @param @param lineCode 线路编码
+     * @param @param schDate 班次日期 yyyy-MM-dd
+     * @param @param forcePlan 强制从计划调度重新抓取
+     * @Title: reloadSch
+     * @Title: reloadSch
+     * @Description: TODO(重新载入排班)
+     */
+    public int reloadSch(String lineCode, String schDate, boolean forcePlan) {
+        try {
+            List<ScheduleRealInfo> list;
+
+            if (forcePlan)
+                removeRealSch(lineCode, schDate);
+            else
+                clearRAMData(lineCode);
+
+            if (existRealSch(lineCode, schDate))
+                list = loadRealSch(lineCode, schDate);// 从实际排班表加载
+            else {
+                list = loadPlanSch(lineCode, schDate);// 从计划排班表加载
+                // 写入数据库
+                batchSave(list);
+            }
+
+            //更新线路和班次日期对照
+            currSchDateMap.put(lineCode, schDate);
+            //添加到缓存
+            putAll(list);
+
+            Set<String> cars = searchAllCars(list);
+            for (String nbbm : cars) {
+                //计算“起点站应到”时间
+                schAttrCalculator.calcQdzTimePlan(nbbmScheduleMap.get(nbbm));
+                //车辆 ——> 要执行的班次对照
+                reCalcExecPlan(nbbm);
+            }
+
+            //是否是出站即出场
+            LineConfig conf = lineConfigData.get(lineCode);
+            if (conf.getOutConfig() == 2) {
+                for (String nbbm : cars)
+                    schAttrCalculator.connectOutSchedule(nbbmScheduleMap.get(nbbm));
+            }
+
+            // 页面 翻班通知
+            sendUtils.shiftSchedule(lineCode);
+        } catch (Exception e) {
+            logger.error("", e);
+            return -1;
+        }
+
+        return 0;
+    }
+
+    /**
+     * @Title: searchAllCars
+     * @Description: TODO(搜索班次集合中的车辆)
+     */
+    private Set<String> searchAllCars(List<ScheduleRealInfo> list) {
+        Set<String> cars = new HashSet<>();
+        for (ScheduleRealInfo sch : list)
+            cars.add(sch.getClZbh());
+
+        return cars;
+    }
+
+    private void putAll(List<ScheduleRealInfo> list) {
+        for (ScheduleRealInfo sch : list)
+            put(sch);
+    }
+
+    /**
+     * @param @param lineCode 线路编码
+     * @param @param schDate 班次日期 yyyy-MM-dd
+     * @Title: removeRealSch
+     * @Description: TODO(清除实际排班，包括数据库和内存数据)
+     */
+    public void removeRealSch(String lineCode, String schDate) throws Exception {
+        try {
+            // 清理数据库数据
+            schRepository.deleteByLineCodeAndDate(lineCode + "", schDate);
+
+            // 清理内存数据
+            clearRAMData(lineCode + "");
+        } catch (Exception e) {
+            logger.error("removeRealSch error, " + lineCode + " -" + schDate, e);
+            throw e;
+        }
+    }
+
+    /**
+     * @Title: clearRAMData
+     * @Description: TODO(清理内存数据)
+     */
+    public void clearRAMData(String lineCode) {
+        int count = 0;
+        List<ScheduleRealInfo> remList = new ArrayList<>();
+        Collection<ScheduleRealInfo> schs = nbbmScheduleMap.values();
+        for (ScheduleRealInfo sch : schs) {
+            if (sch.getXlBm().equals(lineCode))
+                remList.add(sch);
+        }
+
+        for (ScheduleRealInfo sch : remList) {
+            if (null != sch) {
+                nbbmScheduleMap.remove(sch.getClZbh(), sch);
+                id2SchedulMap.remove(sch.getId());
+                count++;
+            }
+        }
+
+        logger.info(lineCode + "排班清理 " + count);
+    }
+
+    /**
+     * @Title: existRealSch
+     * @Description: TODO(实际排班是否已存在)
+     */
+    public boolean existRealSch(String lineCode, String schDate) {
+        int count = schRepository.countByLineCodeAndDate(lineCode, schDate);
+        return count > 0;
+    }
+
+    /**
+     * @Title: loadRealSch
+     * @Description: TODO(从实际排班表加载数据)
+     */
+    public List<ScheduleRealInfo> loadRealSch(String lineCode, String schDate) {
+        return schRepository.findByLineCodeAndDate(lineCode, schDate);
+    }
+
+    /**
+     * @Title: loadPlanSch
+     * @Description: TODO(从计划排班表加载数据)
+     */
+    public List<ScheduleRealInfo> loadPlanSch(String lineCode, String schDate) {
+        logger.info("从计划排班表恢复排班，lineCode: " + lineCode + ", schDate: " + schDate);
+        List<ScheduleRealInfo> realList = new ArrayList<>();
+
+        try {
+            Map<String, Object> data = new HashMap<>();
+
+            data.put("scheduleDate_eq", fmtyyyyMMdd.parseDateTime(schDate).toDate());
+            data.put("xlBm_eq", lineCode);
+
+            // 查询计划排班
+            List<SchedulePlanInfo> planItr = cleanSchPlanItr(schPlanService.list(data).iterator());
+
+            // 转换为实际排班
+            realList = JSONArray.parseArray(JSON.toJSONString(planItr), ScheduleRealInfo.class);
+
+            SimpleDateFormat sdf = new SimpleDateFormat("HH:mm");
+            String fcsj;
+            for (ScheduleRealInfo sch : realList) {
+                sch.setScheduleDateStr(fmtyyyyMMdd.print(sch.getScheduleDate().getTime()));
+                sch.setRealExecDate(sch.getScheduleDateStr());
+
+                if (StringUtils.isEmpty(sch.getFcsj()))
+                    sch.setFcsj("00:00");
+
+                fcsj = sch.getFcsj().trim();
+                //处理一下发车时间格式没有:号的问题
+                if (fcsj.indexOf(":") == -1 && fcsj.length() >= 4) {
+                    sch.setFcsj(fcsj.substring(0, 2) + ":" + fcsj.substring(2, 4));
+                }
+
+                try {
+                    sdf.parse(sch.getFcsj());
+                } catch (ParseException e) {
+                    //发车时间仍然校验不过的，直接写成00:00
+                    sch.setFcsj("00:00");
+                }
+                sch.setDfsj(sch.getFcsj());
+
+                // 计划终点时间
+                if (sch.getBcsj() != null) {
+                    sch.setZdsj(fmtHHmm.print(fmtHHmm.parseMillis(sch.getFcsj()) + (sch.getBcsj() * 60 * 1000)));
+                    sch.setLate(false);
+                }
+                //计划里程为0，设置NULL
+                if (sch.getJhlc() != null && sch.getJhlc() == 0)
+                    sch.setJhlc(null);
+            }
+        } catch (Exception e) {
+            logger.error("", e);
+        }
+        return realList;
+    }
+
+    /**
+     * @Title: batchSave
+     * @Description: TODO(批量入库)
+     */
+    private void batchSave(List<ScheduleRealInfo> list) {
+        // 查询数据库最大ID
+        Long id = schRepository.getMaxId();
+        if (null == id)
+            id = 0L;
+        id++;
+
+        SimpleDateFormat sdfyyyyMMdd = new SimpleDateFormat("yyyy-MM-dd");
+        for (ScheduleRealInfo item : list) {
+            item.setSpId(item.getId());// 保留原始的计划ID
+            item.setId(id++);// 设置ID
+            item.setScheduleDateStr(sdfyyyyMMdd.format(item.getScheduleDate()));
+        }
+
+        // 入库
+        new BatchSaveUtils<ScheduleRealInfo>().saveList(list, ScheduleRealInfo.class);
+    }
+
+    private List<SchedulePlanInfo> cleanSchPlanItr(Iterator<SchedulePlanInfo> itrab) {
+        List<SchedulePlanInfo> list = new ArrayList<>();
+
+        SchedulePlanInfo sp;
+        while (itrab.hasNext()) {
+            sp = itrab.next();
+            sp.setSchedulePlan(null);
+            list.add(sp);
+        }
+        return list;
+    }
+
+    /**
+     * @Title: findByLineCode
+     * @Description: TODO(lineCode 获取班次)
+     */
+    public List<ScheduleRealInfo> findByLineCode(String lineCode) {
+        List<ScheduleRealInfo> rs = new ArrayList<>();
+
+        Collection<ScheduleRealInfo> schs = nbbmScheduleMap.values();
+        for (ScheduleRealInfo sch : schs) {
+            if (sch.getXlBm().equals(lineCode))
+                rs.add(sch);
+        }
+        return rs;
+    }
+
+    /**
+     * @Title: findCarByLineCode
+     * @Description: TODO(线路下运营的车辆)
+     */
+    public Set<String> findCarByLineCode(String lineCode) {
+        Set<String> rs = new HashSet<>();
+
+        Collection<ScheduleRealInfo> schs = nbbmScheduleMap.values();
+        for (ScheduleRealInfo sch : schs) {
+            if (sch.getXlBm().equals(lineCode))
+                rs.add(sch.getClZbh());
+        }
+
+        return rs;
+    }
+
+    public List<ScheduleRealInfo> findByNbbm(String nbbm) {
+        return nbbmScheduleMap.get(nbbm);
+    }
+
+    /**
+     * @Title: findByLineAndUpDown
+     * @Description: TODO(lineCode 和走向获取班次)
+     */
+    public List<ScheduleRealInfo> findByLineAndUpDown(String lineCode, Integer upDown) {
+        List<ScheduleRealInfo> list = findByLineCode(lineCode), rs = new ArrayList<>();
+
+        for (ScheduleRealInfo sch : list) {
+            if (sch.getXlDir().equals(upDown + ""))
+                rs.add(sch);
+        }
+        return rs;
+    }
+
+    public ScheduleRealInfo get(long id) {
+        return id2SchedulMap.get(id);
+    }
+
+    public Set<String> getSEStationList(String nbbm) {
+        return nbbm2SEStationMap.get(nbbm);
+    }
+
+    /**
+     * @Title: next
+     * @Description: TODO(下一个班次)
+     */
+    public ScheduleRealInfo next(ScheduleRealInfo sch) {
+
+        List<ScheduleRealInfo> list = nbbmScheduleMap.get(sch.getClZbh());
+        int outConfig = -1;
+        LineConfig config = lineConfigData.get(sch.getXlBm());
+        if (config != null)
+            outConfig = config.getOutConfig();
+
+        boolean flag = false;
+        ScheduleRealInfo next = null;
+        for (ScheduleRealInfo temp : list) {
+            if (temp.getId() == sch.getId()) {
+                flag = true;
+                continue;
+            }
+            //忽略烂班
+            if (temp.isDestroy())
+                continue;
+
+            //出站既出场，忽略出场班次
+            if (outConfig == 2 && temp.getBcType().equals("out"))
+                continue;
+
+            if (flag) {
+                next = temp;
+                break;
+            }
+        }
+        return next;
+    }
+
+    /**
+     * 上一个班次
+     *
+     * @param sch
+     * @return
+     */
+    public ScheduleRealInfo prev(ScheduleRealInfo sch) {
+        List<ScheduleRealInfo> list = nbbmScheduleMap.get(sch.getClZbh());
+
+        //boolean flag = false;
+        ScheduleRealInfo prev = null;
+        int size = list.size();
+
+        for (int i = 0; i < size; i++) {
+            if (list.get(i).isDestroy())
+                continue;
+
+            if (list.get(i).getId().equals(sch.getId())) {
+                return prev;
+            }
+            prev = list.get(i);
+        }
+        return prev;
+    }
+
+    public void put(ScheduleRealInfo sch) {
+        schAttrCalculator
+                .calcRealDate(sch)
+                .calcAllTimeByFcsj(sch);
+
+        String nbbm = sch.getClZbh();
+        nbbmScheduleMap.put(nbbm, sch);
+        nbbm2SEStationMap.put(nbbm, sch.getQdzCode());
+        nbbm2SEStationMap.put(nbbm, sch.getZdzCode());
+
+        //主键索引
+        id2SchedulMap.put(sch.getId(), sch);
+        //跨24点的，再save一次
+        if (!sch.getRealExecDate().equals(sch.getScheduleDateStr()))
+            save(sch);
+    }
+
+    public void delete(ScheduleRealInfo sch) {
+        //ScheduleRealInfo sch = id2SchedulMap.get(id);
+        if (!sch.isSflj())
+            return;
+
+        nbbmScheduleMap.remove(sch.getClZbh(), sch);
+        id2SchedulMap.remove(sch.getId());
+        //return sch;
+    }
-			if(list.get(i).getId().equals(sch.getId())){
-				return prev;
-			}
-			prev = list.get(i);
-		}
-		return prev;
-	}
-
-	public void put(ScheduleRealInfo sch) {
-		schAttrCalculator
-			.calcRealDate(sch)
-			.calcAllTimeByFcsj(sch);
-
-		String nbbm = sch.getClZbh();
-		nbbmScheduleMap.put(nbbm, sch);
-		nbbm2SEStationMap.put(nbbm, sch.getQdzCode());
-		nbbm2SEStationMap.put(nbbm, sch.getZdzCode());
-		
-		//主键索引
-		id2SchedulMap.put(sch.getId(), sch);
-		//跨24点的，再save一次
-		if(!sch.getRealExecDate().equals(sch.getScheduleDateStr()))
-			save(sch);
-	}
-	
-	public void delete(ScheduleRealInfo sch) {
-		//ScheduleRealInfo sch = id2SchedulMap.get(id);
-		if(!sch.isSflj())
-			return;
-		
-		nbbmScheduleMap.remove(sch.getClZbh(), sch);
-		id2SchedulMap.remove(sch.getId());
-		//return sch;
-	}
-	
 //	public void calcQdzTimePlan(String nbbm){
 //		schAttrCalculator.calcQdzTimePlan(nbbmScheduleMap.get(nbbm));
 //	}
-	
-	public List<ScheduleRealInfo> updateQdzTimePlan(String nbbm){
-		return schAttrCalculator.updateQdzTimePlan(nbbmScheduleMap.get(nbbm));
-	}
-
-	/**
-	 * 
-	 * @Title: nextAll
-	 * @Description: TODO(之后的所有班次)
-	 */
+
+    public List<ScheduleRealInfo> updateQdzTimePlan(String nbbm) {
+        return schAttrCalculator.updateQdzTimePlan(nbbmScheduleMap.get(nbbm));
+    }
+
+    /**
+     *
+     * @Title: nextAll
+     * @Description: TODO(之后的所有班次)
+     */
 /*	public List<ScheduleRealInfo> nextAll(ScheduleRealInfo sch) {
-		List<ScheduleRealInfo> list = nbbmScheduleMap.get(sch.getClZbh());
+        List<ScheduleRealInfo> list = nbbmScheduleMap.get(sch.getClZbh());
 		// 排序
 		Collections.sort(list, schFCSJComparator);
@@ -592,190 +583,229 @@ public class DayOfSchedule implements CommandLineRunner {
 		return rs;
 	}*/
-	/**
-	 * 
-	 * @Title: doneSum
-	 * @Description: TODO(已完成班次总数)
-	 */
-	public int doneSum(String clZbh) {
-		List<ScheduleRealInfo> list = nbbmScheduleMap.get(clZbh);
-		int rs = 0;
-		
-		for(ScheduleRealInfo sch : list){
-			if(sch.getStatus() == 2 && !sch.isDestroy())
-				rs ++;
-		}
-		return rs;
-	}
-	
-	/**
-	 * 
-	 * @Title: prveNotExecNum 
-	 * @Description: TODO(班次之前未执行班次数量) 
-	 */
-	public int prveNotExecNum(ScheduleRealInfo sch){
-		int n = 0;
-		List<ScheduleRealInfo> list = nbbmScheduleMap.get(sch.getClZbh());
-		for(ScheduleRealInfo s : list){
-			if(s.getFcsjActual() == null && !s.isDestroy())
-				n ++;
-			
-			if(s.getId().equals(sch.getId()))
-				break;
-		}
-		return n;
-	}
-
-	/**
-	 * 
-	 * @Title: validEndTime
-	 * @Description: TODO(是否是有效的到达时间)
-	 */
-	public boolean validEndTime(ScheduleRealInfo sch, Long ts) {
-		if(sch.getFcsjActualTime() != null && sch.getFcsjActualTime() > ts)
-			return false;
-		
-		return validTime(sch, ts);
-	}
-
-	/**
-	 * 
-	 * @Title: validStartTime 
-	 * @Description: TODO(是否是合适的发车时间) 
-	 */
-	public boolean validStartTime(ScheduleRealInfo sch, Long ts) {
-		if(sch.getZdsjActualTime() != null && sch.getZdsjActualTime() < ts)
-			return false;
-		
-		return validTime(sch, ts);
-	}
-	
-	public boolean validTime(ScheduleRealInfo sch, Long ts){
-		List<ScheduleRealInfo> list = nbbmScheduleMap.get(sch.getClZbh());
-		int ci = list.indexOf(sch);
-		ScheduleRealInfo prve, next;
-		if(ci > 0){
-			//之前班次实际时间不能大于该时间
-			for(int i = ci - 1; i >= 0; i --){
-				prve = list.get(i);
-				if(prve.getZdsjActualTime() != null && prve.getZdsjActualTime() > ts )
-					return false;
-				
-				if(prve.getFcsjActualTime() != null && prve.getFcsjActualTime() > ts)
-					return false;
-			}
-		}
-		
-		if(ci < list.size() - 1){
-			//之后班次实际时间不能小于该时间
-			for(int i = ci + 1; i < list.size(); i ++){
-				next = list.get(i);
-				if(next.getFcsjActualTime() != null && next.getFcsjActualTime() < ts)
-					return false;
-				
-				if(next.getZdsjActualTime() != null && next.getZdsjActualTime() < ts)
-					return false;
-			}
-		}
-		return true;
-	}
-	
-	public void save(ScheduleRealInfo sch){
-		//schRepository.save(sch);
-		pstBuffer.add(sch);
-	}
-	
-	
-	/**
-	 * 
-	 * @Title: nextByBcType 
-	 * @Description: TODO(获取下一个指定班次类型的班次) 
-	 */
-	public ScheduleRealInfo nextByBcType(String nbbm, String bcType){
-		List<ScheduleRealInfo> list = findByBcType(nbbm, bcType);
-		
-		Collections.sort(list, schFCSJComparator);
-		ScheduleRealInfo sch = null;
-		for(ScheduleRealInfo temp : list){
-			if(temp.getFcsjActual() == null)
-				sch = temp;
-		}
-		
-		return sch;
-	}
-	
-	public List<ScheduleRealInfo> findByBcType(String nbbm, String bcType){
-		List<ScheduleRealInfo> all = nbbmScheduleMap.get(nbbm)
-				,outList = new ArrayList<>();
-	
-		for(ScheduleRealInfo sch : all){
-			if(sch.getBcType().equals(bcType))
-				outList.add(sch);
-		}
-		return outList;
-	}
-	
-	public Set<String> allCar(){
-		return nbbmScheduleMap.keySet();
-	}
-	
-	public Collection<ScheduleRealInfo> findAll(){
-		return nbbmScheduleMap.values();
-	}
-	
-	public void addExecPlan(ScheduleRealInfo sch){
-		carExecutePlanMap.put(sch.getClZbh(), sch);
-	}
-	
-	public void removeExecPlan(String clzbh){
-		carExecutePlanMap.remove(clzbh);
-	}
-	
-	public Map<String, ScheduleRealInfo> execPlanMap(){
-		return carExecutePlanMap;
-	}
-
-	/**
-	 * 车辆当前执行的班次
-	 * @param nbbm
-	 * @return
-	 */
-	public static ScheduleRealInfo executeCurr(String nbbm){
-		return carExecutePlanMap.get(nbbm);
-	}
-	
-	/**
-	 * @Title: changeCar 
-	 * @Description: TODO(班次换车) 返回有更新的班次
-	 * @param @param sch	
-	 * @param @param newClZbh    新的车辆自编号 
-	 */
-	public List<ScheduleRealInfo> changeCar(ScheduleRealInfo sch , String newClZbh){
-		List<ScheduleRealInfo> ups = new ArrayList<>();
-		String oldClzbh = sch.getClZbh();
-		if(oldClzbh.equals(newClZbh))
-			return ups;
-		
-		
-		//变更相关映射信息
-		nbbmScheduleMap.remove(sch.getClZbh(), sch);
-		
-		sch.setClZbh(newClZbh);
-		nbbmScheduleMap.put(newClZbh, sch);
-		nbbm2SEStationMap.put(newClZbh, sch.getQdzCode());
-		nbbm2SEStationMap.put(newClZbh, sch.getZdzCode());
-		
-		//重新计算班次应到时间
-		ups.addAll(updateQdzTimePlan(oldClzbh));
-		ups.addAll(updateQdzTimePlan(newClZbh));
-		return ups;
-	}
-
-	/**
-	 * 
-	 * @Title: linkToSchPlan 
-	 * @Description: TODO(车辆关联到班次) 
-	 */
+    /**
+     * @Title: doneSum
+     * @Description: TODO(已完成班次总数)
+     */
+    public int doneSum(String clZbh) {
+        List<ScheduleRealInfo> list = nbbmScheduleMap.get(clZbh);
+        int rs = 0;
+
+        for (ScheduleRealInfo sch : list) {
+            if (sch.getStatus() == 2 && !sch.isDestroy())
+                rs++;
+        }
+        return rs;
+    }
+
+    /**
+     * @Title: prveNotExecNum
+     * @Description: TODO(班次之前未执行班次数量)
+     */
+    public int prveNotExecNum(ScheduleRealInfo sch) {
+        int n = 0;
+        List<ScheduleRealInfo> list = nbbmScheduleMap.get(sch.getClZbh());
+        for (ScheduleRealInfo s : list) {
+            if (s.getFcsjActual() == null && !s.isDestroy())
+                n++;
+
+            if (s.getId().equals(sch.getId()))
+                break;
+        }
+        return n;
+    }
+
+    /**
+     * @Title: validEndTime
+     * @Description: TODO(是否是有效的到达时间)
+     */
+    public boolean validEndTime(ScheduleRealInfo sch, Long ts) {
+        if (sch.getFcsjActualTime() != null && sch.getFcsjActualTime() > ts)
+            return false;
+
+        return validTime(sch, ts);
+    }
+
+    /**
+     * @Title: validStartTime
+     * @Description: TODO(是否是合适的发车时间)
+     */
+    public boolean validStartTime(ScheduleRealInfo sch, Long ts) {
+        if (sch.getZdsjActualTime() != null && sch.getZdsjActualTime() < ts)
+            return false;
+
+        return validTime(sch, ts);
+    }
+
+    public boolean validTime(ScheduleRealInfo sch, Long ts) {
+        List<ScheduleRealInfo> list = nbbmScheduleMap.get(sch.getClZbh());
+        int ci = list.indexOf(sch);
+        ScheduleRealInfo prve, next;
+        if (ci > 0) {
+            //之前班次实际时间不能大于该时间
+            for (int i = ci - 1; i >= 0; i--) {
+                prve = list.get(i);
+                if (prve.getZdsjActualTime() != null && prve.getZdsjActualTime() > ts)
+                    return false;
+
+                if (prve.getFcsjActualTime() != null && prve.getFcsjActualTime() > ts)
+                    return false;
+            }
+        }
+
+        if (ci < list.size() - 1) {
+            //之后班次实际时间不能小于该时间
+            for (int i = ci + 1; i < list.size(); i++) {
+                next = list.get(i);
+                if (next.getFcsjActualTime() != null && next.getFcsjActualTime() < ts)
+                    return false;
+
+                if (next.getZdsjActualTime() != null && next.getZdsjActualTime() < ts)
+                    return false;
+            }
+        }
+        return true;
+    }
+
+    public void save(ScheduleRealInfo sch) {
+        //schRepository.save(sch);
+        pstBuffer.add(sch);
+    }
+
+
+    /**
+     * @Title: nextByBcType
+     * @Description: TODO(获取下一个指定班次类型的班次)
+     */
+    public ScheduleRealInfo nextByBcType(String nbbm, String bcType) {
+        List<ScheduleRealInfo> list = findByBcType(nbbm, bcType);
+
+        Collections.sort(list, schFCSJComparator);
+        ScheduleRealInfo sch = null;
+        for (ScheduleRealInfo temp : list) {
+            if (temp.getFcsjActual() == null)
+                sch = temp;
+        }
+
+        return sch;
+    }
+
+    public List<ScheduleRealInfo> findByBcType(String nbbm, String bcType) {
+        List<ScheduleRealInfo> all = nbbmScheduleMap.get(nbbm), outList = new ArrayList<>();
+
+        for (ScheduleRealInfo sch : all) {
+            if (sch.getBcType().equals(bcType))
+                outList.add(sch);
+        }
+        return outList;
+    }
+
+    public Set<String> allCar() {
+        return nbbmScheduleMap.keySet();
+    }
+
+    public Collection<ScheduleRealInfo> findAll() {
+        return nbbmScheduleMap.values();
+    }
+
+    public void addExecPlan(ScheduleRealInfo sch) {
+        if(sch != null)
+            carExecutePlanMap.put(sch.getClZbh(), sch);
+    }
+
+    public void removeExecPlan(String clzbh) {
+        carExecutePlanMap.remove(clzbh);
+    }
+
+    public Map<String, ScheduleRealInfo> execPlanMap() {
+        return carExecutePlanMap;
+    }
+
+    /**
+     * 车辆当前执行的班次
+     *
+     * @param nbbm
+     * @return
+     */
+    public ScheduleRealInfo executeCurr(String nbbm) {
+        return carExecutePlanMap.get(nbbm);
+    }
+
+    /**
+     * @param @param sch
+     * @param @param newClZbh    新的车辆自编号
+     * @Title: changeCar
+     * @Description: TODO(班次换车) 返回有更新的班次
+     */
+    public List<ScheduleRealInfo> changeCar(ScheduleRealInfo sch, String newClZbh) {
+        List<ScheduleRealInfo> ups = new ArrayList<>();
+        String oldClzbh = sch.getClZbh();
+        if (oldClzbh.equals(newClZbh))
+            return ups;
+
+
+        //变更相关映射信息
+        nbbmScheduleMap.remove(sch.getClZbh(), sch);
+
+        sch.setClZbh(newClZbh);
+        nbbmScheduleMap.put(newClZbh, sch);
+        nbbm2SEStationMap.put(newClZbh, sch.getQdzCode());
+        nbbm2SEStationMap.put(newClZbh, sch.getZdzCode());
+
+        //重新计算班次应到时间
+        ups.addAll(updateQdzTimePlan(oldClzbh));
+        ups.addAll(updateQdzTimePlan(newClZbh));
+
+        //重新计算车辆当前执行班次
+        reCalcExecPlan(newClZbh);
+        reCalcExecPlan(sch.getClZbh());
+        return ups;
+    }
+
+    public void reCalcExecPlan(String nbbm){
+        carExecutePlanMap.put(nbbm, schAttrCalculator.calcCurrentExecSch(nbbmScheduleMap.get(nbbm)));
+    }
+
+    /**
+     * 是否在执行首班出场
+     * @param nbbm
+     * @return
+     */
+    public boolean isExecFirstOut(String nbbm, long time){
+        try {
+            List<ScheduleRealInfo> list = nbbmScheduleMap.get(nbbm);
+            ScheduleRealInfo second = list.get(2),
+                    first = executeCurr(nbbm);
+
+            if(first.getBcType().equals("out")
+                && first.getDfsjT() < second.getDfsjT()
+                && doneSum(nbbm) == 0 && second.getDfsjT() > time)
+                return true;
+        } catch (Exception e) {
+            logger.error("", e);
+        }
+
+        return false;
+    }
+
+    /**
+     * 获取班次的计划停站时间
+     * @param sch
+     * @return
+
+    public int stopTimePlan(Object task) {
+
+        ScheduleRealInfo sch = prev((ScheduleRealInfo) task);
+
+        sch.getzdsj
+        return -1;
+    }*/
+
+    /**
+     *
+     * @Title: linkToSchPlan
+     * @Description: TODO(车辆关联到班次)
+     */
 /*	public void linkToSchPlan(String nbbm) {
 		//当前GPS状态
 		GpsEntity gps = gpsRealData.get(BasicData.deviceId2NbbmMap.inverse().get(nbbm));
@@ -23,7 +23,7 @@ import java.util.Date;
 @Entity
 @Table(name = "bsth_c_cars")
-@JsonIgnoreProperties(value={"hibernateLazyInitializer","handler","fieldHandler"})
+@JsonIgnoreProperties(value={"hibernateLazyInitializer","handlers","fieldHandler"})
 public class Cars extends BEntity implements Serializable {
 	/** 主键Id */
@@ -24,7 +24,7 @@ import java.util.Date;
 @Entity
 @Table(name = "bsth_c_line")
-@JsonIgnoreProperties(value={"hibernateLazyInitializer","handler","fieldHandler"})
+@JsonIgnoreProperties(value={"hibernateLazyInitializer","handlers","fieldHandler"})
 public class Line implements Serializable {
 	@Id
@@ -21,7 +21,7 @@ import javax.persistence.*;
 @Entity
 @Table(name = "bsth_c_personnel")
-@JsonIgnoreProperties(value={"hibernateLazyInitializer","handler","fieldHandler"})
+@JsonIgnoreProperties(value={"hibernateLazyInitializer","handlers","fieldHandler"})
 public class Personnel extends BEntity {
     /** 主键Id */
 package com.bsth.entity.realcontrol;
+import com.bsth.entity.Line;
+
+import javax.persistence.*;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.HashSet;
 import java.util.Set;
-import javax.persistence.CascadeType;
-import javax.persistence.Entity;
-import javax.persistence.GeneratedValue;
-import javax.persistence.Id;
-import javax.persistence.NamedAttributeNode;
-import javax.persistence.NamedEntityGraph;
-import javax.persistence.NamedEntityGraphs;
-import javax.persistence.OneToMany;
-import javax.persistence.OneToOne;
-import javax.persistence.Table;
-import javax.persistence.Transient;
-
-import com.bsth.entity.Line;
-import com.bsth.util.DateUtils;
-
 /**
  * 
  * @ClassName: LineConfig
@@ -59,9 +47,6 @@ public class LineConfig {
 	/** 出场时间设置 0：真实出场（设备离开缓冲区时间） 1：请求出场时间 2：出站即出场 */
 	private int outConfig;
-	/** 进场时间设置 0：真实进场（设备进入缓冲区时间） 1：请求进场时间  2：出站即出场*/
-	private int inConfig;
-
 	/** 短语模板 , 号分隔多个 */
 	private String phraseTemps;
@@ -111,14 +96,6 @@ public class LineConfig {
 		this.outConfig = outConfig;
 	}
-	public int getInConfig() {
-		return inConfig;
-	}
-
-	public void setInConfig(int inConfig) {
-		this.inConfig = inConfig;
-	}
-
 	public String getPhraseTemps() {
 		return phraseTemps;
 	}
@@ -19,7 +19,7 @@ import java.util.Date;
                 @NamedAttributeNode("cl")
         })
 })
-@JsonIgnoreProperties(value={"hibernateLazyInitializer","handler","fieldHandler"})
+@JsonIgnoreProperties(value={"hibernateLazyInitializer","handlers","fieldHandler"})
 public class CarConfigInfo extends BEntity implements Serializable {
     /** 主健Id */
@@ -22,7 +22,7 @@ import java.io.Serializable;
             @NamedAttributeNode("xl")
     })
 })
-@JsonIgnoreProperties(value={"hibernateLazyInitializer","handler","fieldHandler"})
+@JsonIgnoreProperties(value={"hibernateLazyInitializer","handlers","fieldHandler"})
 public class EmployeeConfigInfo extends BEntity implements Serializable {
     /** 主键Id */
@@ -15,7 +15,7 @@ import javax.persistence.*;
                 @NamedAttributeNode("xl")
         })
 })
-@JsonIgnoreProperties(value={"hibernateLazyInitializer","handler","fieldHandler"})
+@JsonIgnoreProperties(value={"hibernateLazyInitializer","handlers","fieldHandler"})
 public class GuideboardInfo extends BEntity {
     /** 主键Id */
@@ -9,7 +9,7 @@ import java.util.Set;
 @Entity
 @Table(name = "bsth_c_sys_user")
-@JsonIgnoreProperties(value={"hibernateLazyInitializer","handler","fieldHandler"})
+@JsonIgnoreProperties(value={"hibernateLazyInitializer","handlers","fieldHandler"})
 public class SysUser {
 	@Id
@@ -8,6 +8,8 @@ public interface BusIntervalService {
 	List<Map<String, Object>> getDir(Map<String, Object> map);
+	List<Map<String, Object>> getLp(Map<String, Object> map);
+	
 	List<Map<String, Object>> interval(Map<String, Object> map);
 	Map<String, Object> timeAndSpeed(Map<String, Object> map);
@@ -290,6 +290,7 @@ public class FormsServiceImpl implements FormsService {
 		List<Changetochange> list = jdbcTemplate.query(sql, new RowMapper<Changetochange>() {
+			
 			@Override
 			public Changetochange mapRow(ResultSet arg0, int arg1) throws SQLException {
 				Changetochange chan = new Changetochange();
@@ -314,6 +315,7 @@ public class FormsServiceImpl implements FormsService {
 		return list;
 	}
+	
 	// 路单数据
 	@Override
 	public List<Singledata> singledata(Map<String, Object> map) {