update...

潘钊
1 parent afed5209
Showing 4 changed files with 40 additions and 13 deletions
src/main/java/com/bsth/data/gpsdata/arrival/handlers/InOutStationSignalHandle.java
src/main/java/com/bsth/data/gpsdata/recovery/GpsDataRecovery.java
src/main/java/com/bsth/data/schedule/DayOfSchedule.java
src/main/java/com/bsth/entity/realcontrol/ScheduleRealInfo.java
@@ -260,7 +260,7 @@ public class InOutStationSignalHandle extends SignalHandle{
         if (config != null && config.getOutConfig() == 2) {
             //出站既出场
             ScheduleRealInfo schPrev = dayOfSchedule.prev(sch);
-            if (schPrev != null && schPrev.getBcType().equals("out") && (schPrev.getBcsj()==0 || schPrev.getJhlcOrig().equals(0))
+            if (schPrev != null && schPrev.getBcType().equals("out") && (schPrev.getBcsj()==0 || schPrev.getJhlcOrig().intValue()==0)
                     && (!limitPark || park.equals(schPrev.getQdzCode()))) {
  
                 schPrev.setFcsjActualAll(sch.getFcsjActualTime());
@@ -429,7 +429,7 @@ public class InOutStationSignalHandle extends SignalHandle{
         String stopId = gps.getStopNo();
         for(int i = 0; i < halfList.size(); i ++){
             sch = halfList.get(i);
-            if(!sch.getZdzCode().equals(stopId))
+            if(!sch.getZdzCode().equals(stopId) || sch.getStatus()==2)
                 continue;
  
             if(sch.getZdsjT() < gps.getTimestamp())
@@ -60,7 +60,7 @@ public class GpsDataRecovery implements ApplicationContextAware {
         for (String nbbm : keys) {
             Collections.sort(listMap.get(nbbm), comp);
             threadPool.execute(new RecoveryThread(listMap.get(nbbm), count));
-            /*if(nbbm.equals("W09-164"))
+            /*if(nbbm.equals("S0K-004"))
                 new RecoveryThread(listMap.get(nbbm), count).run();*/
             /*if(lineId.equals("60028"))
                 new RecoveryThread(listMap.get(lineId), count).run();*/
@@ -84,7 +84,7 @@ public class GpsDataRecovery implements ApplicationContextAware {
         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=241";// + dayOfYear;
+        String sql = "select DEVICE_ID,LAT,LON,TS,SPEED_GPS,LINE_ID,SERVICE_STATE from bsth_c_gps_info where days_year=245";// + dayOfYear;
         JdbcTemplate jdbcTemplate = new JdbcTemplate(DBUtils_MS.getDataSource());
  
         List<GpsEntity> list =
@@ -153,7 +153,7 @@ public class GpsDataRecovery implements ApplicationContextAware {
                 boolean task;
                 for (GpsEntity gps : list) {
                     try {
-                        /*if(gps.getTimestamp() >= 1503960000000L){
+                        /*if(gps.getTimestamp() >= 1504298280000L){
                             System.out.println("debugger...");
                         }*/
                         //是否有任务
@@ -592,7 +592,7 @@ public class DayOfSchedule {
      * @param sch  当前班次
      * @return
      */
-    private ScheduleRealInfo next2(Collection<ScheduleRealInfo> list, ScheduleRealInfo sch) {
+    private ScheduleRealInfo next2_lp(Collection<ScheduleRealInfo> list, ScheduleRealInfo sch) {
         int outConfig = -1;
         LineConfig config = lineConfigData.get(sch.getXlBm());
         if (config != null)
@@ -605,8 +605,35 @@ public class DayOfSchedule {
                 flag = true;
                 continue;
             }
-            //忽略烂班
-            if (temp.isDestroy())
+
+            if (flag) {
+                next = temp;
+                break;
+            }
+        }
+        return next;
+    }
+
+    private ScheduleRealInfo next3_lp(Collection<ScheduleRealInfo> list, ScheduleRealInfo sch) {
+        int outConfig = -1;
+        LineConfig config = lineConfigData.get(sch.getXlBm());
+        if (config != null)
+            outConfig = config.getOutConfig();
+
+        //限定出站既出场的停车场
+        String park = config.getTwinsPark();
+        boolean limitPark = StringUtils.isNotEmpty(park);
+        boolean flag = false;
+        ScheduleRealInfo next = null;
+        for (ScheduleRealInfo temp : list) {
+            if (temp.getId() == sch.getId()) {
+                flag = true;
+                continue;
+            }
+
+            //出站既出场，忽略出场班次
+            if (outConfig == 2 && temp.getBcType().equals("out") && (temp.getBcsj()==0 || temp.getJhlcOrig().equals(0))
+                    && (!limitPark || park.equals(temp.getQdzCode())))
                 continue;
  
             if (flag) {
@@ -1121,7 +1148,7 @@ public class DayOfSchedule {
     public ScheduleRealInfo nextByLp(ScheduleRealInfo sch) {
         List<ScheduleRealInfo> list = lpScheduleMap.get(sch.getXlBm() + "_" + sch.getLpName());
         Collections.sort(list, schFCSJComparator);
-        return next(list, sch);
+        return next3_lp(list, sch);
     }
  
     /**
@@ -1133,7 +1160,7 @@ public class DayOfSchedule {
     public ScheduleRealInfo nextByLp2(ScheduleRealInfo sch) {
         List<ScheduleRealInfo> list = lpScheduleMap.get(sch.getXlBm() + "_" + sch.getLpName());
         Collections.sort(list, schFCSJComparator);
-        return next2(list, sch);
+        return next2_lp(list, sch);
     }
  
     public ArrayListMultimap<String, ScheduleRealInfo> getLpScheduleMap() {
@@ -223,7 +223,7 @@ public class ScheduleRealInfo {
 	 * 2：到站漂移
 	 * 3：中途漂移
 	 */
-	private int driftStatus = 0;
+	private Integer driftStatus = 0;
  
 	public boolean isDfAuto() {
 		return dfAuto;
@@ -942,11 +942,11 @@ public class ScheduleRealInfo {
 		this.siginCompate = siginCompate;
 	}
  
-	public int getDriftStatus() {
+	public Integer getDriftStatus() {
 		return driftStatus;
 	}
  
-	public void setDriftStatus(int driftStatus) {
+	public void setDriftStatus(Integer driftStatus) {
 		this.driftStatus = driftStatus;
 	}
 }