首末班准点率表：实驶班次如果有首末班时点准时的班次就认为准点（实驶不一定是第一班或最后一班）。

娄高锋
1 parent e2819b05
Showing 1 changed file with 302 additions and 8 deletions
src/main/java/com/bsth/service/schedule/impl/PeopleCarPlanServiceImpl.java
@@ -1291,6 +1291,7 @@ public class PeopleCarPlanServiceImpl implements PeopleCarPlanService {
 		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
 		NumberFormat nf = NumberFormat.getNumberInstance();
 		nf.setMinimumFractionDigits(2);
+		Map<Long, String> spMap = new HashMap<Long, String>();
 		List<ScheduleRealInfo> list = new ArrayList<ScheduleRealInfo>();
 		List<Map<String, Object>> resList = new ArrayList<Map<String, Object>>();
@@ -1309,6 +1310,48 @@ public class PeopleCarPlanServiceImpl implements PeopleCarPlanService {
 			date = sdf.format(new Date());
 		try {
+			List<SchedulePlanInfo> listSp = new ArrayList<SchedulePlanInfo>();
+			
+			ArrayList<String> objList = new ArrayList<String>();
+			String sql = "select a.id, a.bc_type"
+					+ " from bsth_c_s_sp_info a where schedule_date = ?";
+			objList.add(date);
+			if(line.trim().length() != 0){
+				sql += " and xl_bm = ?";
+				objList.add(line);
+			}
+			if(company.length() != 0){
+				sql += " and gs_bm = ?";
+				objList.add(company);
+			}
+			if(subCompany.length() != 0){
+				sql += " and fgs_bm = ?";
+				objList.add(subCompany);
+			}
+			
+			listSp = jdbcTemplate.query(sql,
+					objList.toArray(),
+					new RowMapper<SchedulePlanInfo>(){
+				@Override
+				public SchedulePlanInfo mapRow(ResultSet rs, int rowNum) throws SQLException {
+					SchedulePlanInfo schedule = new SchedulePlanInfo();
+					schedule.setId(rs.getLong("id"));
+					schedule.setBcType(rs.getString("bc_type"));
+					
+					return schedule;
+				}
+			});
+			
+			for(SchedulePlanInfo sp : listSp){
+				spMap.put(sp.getId(), sp.getBcType());
+			}
+			
+		} catch (Exception e) {
+			// TODO: handle exception
+			e.printStackTrace();
+		}
+		
+		try {
 			List<String> objList = new ArrayList<String>();
 			String sql = "select a.schedule_date_str, a.real_exec_date, a.xl_name, a.fcsj, a.fcsj_actual, a.zdsj, a.zdsj_actual, a.qdz_name, a.zdz_name, a.xl_dir, a.status, a.gs_name, a.fgs_name,"
 					+ " a.xl_bm, a.fgs_bm, a.cc_service, (select start_opt from bsth_c_line_config where id ="
@@ -1472,11 +1515,62 @@ public class PeopleCarPlanServiceImpl implements PeopleCarPlanService {
 				Collections.sort(up1);
 				Collections.sort(up2);
 				ScheduleRealInfo s1 = up1Map.get(up1.get(0));
+				for(Long jhfcsj : up1){
+					s1 = up1Map.get(jhfcsj);
+					String bcType = s1.getBcType();
+					if(s1.getSpId() != null && spMap.containsKey(s1.getSpId())){
+						bcType = spMap.get(s1.getSpId());
+					}
+					if(bcType.equals("region") || bcType.equals("venting")
+    						|| bcType.equals("major")){
+    					continue;
+    				}
+					break;
+				}
 				ScheduleRealInfo s2 = up2Map.get(up2.get(0));
+				for(Long sjfcsj : up2){
+					ScheduleRealInfo temp2 = up2Map.get(sjfcsj);
+					String bcType = temp2.getBcType();
+					if(bcType.equals("region") || bcType.equals("venting")
+    						|| bcType.equals("major")){
+    					continue;
+    				}
+					long delayFirst0 = s1.getFcsjT() - temp2.getFcsjActualTime();
+					if(delayFirst0 <= 1l && delayFirst0 >= -2l){
+						s2 = temp2;
+						break;
+					}
+				}
 				ScheduleRealInfo s3 = up1Map.get(up1.get(up1.size()-1));
+				for(int i = up1.size() - 1; i >= 0; i--){
+					s3 = up1Map.get(up1.get(i));
+					String bcType = s3.getBcType();
+					if(s3.getSpId() != null && spMap.containsKey(s3.getSpId())){
+						bcType = spMap.get(s3.getSpId());
+					}
+					if(bcType.equals("region") || bcType.equals("venting")
+    						|| bcType.equals("major")){
+    					continue;
+    				}
+					break;
+				}
 				ScheduleRealInfo s4 = up2Map.get(up2.get(up2.size()-1));
-				long delayFirst0 = up1.get(0) - up2.get(0);
-				long delayLast0 = up1.get(up1.size()-1) - up2.get(up2.size()-1);
+				for(int i = up2.size() - 1; i >= 0; i--){
+					ScheduleRealInfo temp4 = up2Map.get(up2.get(i));
+					String bcType = temp4.getBcType();
+					if(bcType.equals("region") || bcType.equals("venting")
+    						|| bcType.equals("major")){
+    					continue;
+    				}
+					long delayLast0 = s3.getFcsjT() - temp4.getFcsjActualTime();
+					if(delayLast0 <= 1l && delayLast0 >= -2l){
+						s4 = temp4;
+						break;
+					}
+					break;
+				}
+				long delayFirst0 = s1.getFcsjT() - s2.getFcsjActualTime();
+				long delayLast0 = s3.getFcsjT() - s4.getFcsjActualTime();
 				tempMap.put("qdzFirst0", s1.getQdzName());
 				tempMap.put("jhfcFirst0", s1.getFcsj());
 				tempMap.put("sjfcFirst0", s2.getFcsjActual());
@@ -1499,11 +1593,63 @@ public class PeopleCarPlanServiceImpl implements PeopleCarPlanService {
 				Collections.sort(dn1);
 				Collections.sort(dn2);
 				ScheduleRealInfo s1 = dn1Map.get(dn1.get(0));
+				for(Long jhfcsj : dn1){
+					s1 = dn1Map.get(jhfcsj);
+					String bcType = s1.getBcType();
+					if(s1.getSpId() != null && spMap.containsKey(s1.getSpId())){
+						bcType = spMap.get(s1.getSpId());
+					}
+					if(bcType.equals("region") || bcType.equals("venting")
+    						|| bcType.equals("major")){
+    					continue;
+    				}
+					break;
+				}
 				ScheduleRealInfo s2 = dn2Map.get(dn2.get(0));
+				for(Long sjfcsj : dn2){
+					ScheduleRealInfo temp2 = dn2Map.get(sjfcsj);
+					String bcType = temp2.getBcType();
+					if(bcType.equals("region") || bcType.equals("venting")
+    						|| bcType.equals("major")){
+    					continue;
+    				}
+					long delayFirst1 = s1.getFcsjT() - temp2.getFcsjActualTime();
+					if(delayFirst1 <= 1l && delayFirst1 >= -2l){
+						s2 = temp2;
+						break;
+					}
+					break;
+				}
 				ScheduleRealInfo s3 = dn1Map.get(dn1.get(dn1.size()-1));
+				for(int i = dn1.size() - 1; i >= 0; i--){
+					s3 = dn1Map.get(dn1.get(i));
+					String bcType = s3.getBcType();
+					if(s3.getSpId() != null && spMap.containsKey(s3.getSpId())){
+						bcType = spMap.get(s3.getSpId());
+					}
+					if(bcType.equals("region") || bcType.equals("venting")
+    						|| bcType.equals("major")){
+    					continue;
+    				}
+					break;
+				}
 				ScheduleRealInfo s4 = dn2Map.get(dn2.get(dn2.size()-1));
-				long delayFirst1 = dn1.get(0) - dn2.get(0);
-				long delayLast1 = dn1.get(dn1.size()-1) - dn2.get(dn2.size()-1);
+				for(int i = dn2.size() - 1; i >= 0; i--){
+					ScheduleRealInfo temp4 = dn2Map.get(dn2.get(i));
+					String bcType = temp4.getBcType();
+					if(bcType.equals("region") || bcType.equals("venting")
+    						|| bcType.equals("major")){
+    					continue;
+    				}
+					long delayLast1 = s3.getFcsjT() - temp4.getFcsjActualTime();
+					if(delayLast1 <= 1l && delayLast1 >= -2l){
+						s4 = temp4;
+						break;
+					}
+					break;
+				}
+				long delayFirst1 = s1.getFcsjT() - s2.getFcsjActualTime();
+				long delayLast1 = s3.getFcsjT() - s4.getFcsjActualTime();
 				tempMap.put("qdzFirst1", s1.getQdzName());
 				tempMap.put("jhfcFirst1", s1.getFcsj());
 				tempMap.put("sjfcFirst1", s2.getFcsjActual());
@@ -1558,6 +1704,7 @@ public class PeopleCarPlanServiceImpl implements PeopleCarPlanService {
 		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
 		NumberFormat nf = NumberFormat.getNumberInstance();
 		nf.setMinimumFractionDigits(2);
+		Map<Long, String> spMap = new HashMap<Long, String>();
 		List<ScheduleRealInfo> list = new ArrayList<ScheduleRealInfo>();
 		List<Map<String, Object>> resList = new ArrayList<Map<String, Object>>();
@@ -1591,6 +1738,50 @@ public class PeopleCarPlanServiceImpl implements PeopleCarPlanService {
 		}
 		try {
+			List<SchedulePlanInfo> listSp = new ArrayList<SchedulePlanInfo>();
+			
+			ArrayList<String> objList = new ArrayList<String>();
+			String sql = "select a.id, a.bc_type"
+					+ " from bsth_c_s_sp_info a where"
+					+ " schedule_date >= ? and schedule_date <= ?";
+			objList.add(startDate);
+			objList.add(endDate);
+			if(line.trim().length() != 0){
+				sql += " and xl_bm = ?";
+				objList.add(line);
+			}
+			if(company.length() != 0){
+				sql += " and gs_bm = ?";
+				objList.add(company);
+			}
+			if(subCompany.length() != 0){
+				sql += " and fgs_bm = ?";
+				objList.add(subCompany);
+			}
+			
+			listSp = jdbcTemplate.query(sql,
+					objList.toArray(),
+					new RowMapper<SchedulePlanInfo>(){
+				@Override
+				public SchedulePlanInfo mapRow(ResultSet rs, int rowNum) throws SQLException {
+					SchedulePlanInfo schedule = new SchedulePlanInfo();
+					schedule.setId(rs.getLong("id"));
+					schedule.setBcType(rs.getString("bc_type"));
+					
+					return schedule;
+				}
+			});
+			
+			for(SchedulePlanInfo sp : listSp){
+				spMap.put(sp.getId(), sp.getBcType());
+			}
+			
+		} catch (Exception e) {
+			// TODO: handle exception
+			e.printStackTrace();
+		}
+		
+		try {
 			List<String> objList = new ArrayList<String>();
 			String sql = "select a.schedule_date_str, a.real_exec_date, a.xl_bm, a.xl_name, a.fcsj, a.fcsj_actual, a.zdsj, a.zdsj_actual, a.qdz_name, a.zdz_name, a.xl_dir, a.status, a.gs_name, a.fgs_name,"
 					+ " a.fgs_bm, a.cc_service, a.remarks, a.adjust_exps, (select start_opt from bsth_c_line_config where id = "
@@ -1783,11 +1974,62 @@ public class PeopleCarPlanServiceImpl implements PeopleCarPlanService {
 					Collections.sort(up1);
 					Collections.sort(up2);
 					ScheduleRealInfo s1 = up1Map.get(up1.get(0));
+					for(Long jhfcsj : up1){
+						s1 = up1Map.get(jhfcsj);
+						String bcType = s1.getBcType();
+						if(s1.getSpId() != null && spMap.containsKey(s1.getSpId())){
+							bcType = spMap.get(s1.getSpId());
+						}
+						if(bcType.equals("region") || bcType.equals("venting")
+	    						|| bcType.equals("major")){
+	    					continue;
+	    				}
+						break;
+					}
 					ScheduleRealInfo s2 = up2Map.get(up2.get(0));
+					for(Long sjfcsj : up2){
+						ScheduleRealInfo temp2 = up2Map.get(sjfcsj);
+						String bcType = temp2.getBcType();
+						if(bcType.equals("region") || bcType.equals("venting")
+	    						|| bcType.equals("major")){
+	    					continue;
+	    				}
+						long delayFirst0 = s1.getFcsjT() - temp2.getFcsjActualTime();
+						if(delayFirst0 <= 1l && delayFirst0 >= -2l){
+							s2 = temp2;
+							break;
+						}
+					}
 					ScheduleRealInfo s3 = up1Map.get(up1.get(up1.size()-1));
+					for(int i = up1.size() - 1; i >= 0; i--){
+						s3 = up1Map.get(up1.get(i));
+						String bcType = s3.getBcType();
+						if(s3.getSpId() != null && spMap.containsKey(s3.getSpId())){
+							bcType = spMap.get(s3.getSpId());
+						}
+						if(bcType.equals("region") || bcType.equals("venting")
+	    						|| bcType.equals("major")){
+	    					continue;
+	    				}
+						break;
+					}
 					ScheduleRealInfo s4 = up2Map.get(up2.get(up2.size()-1));
-					long delayFirst0 = up1.get(0) - up2.get(0);
-					long delayLast0 = up1.get(up1.size()-1) - up2.get(up2.size()-1);
+					for(int i = up2.size() - 1; i >= 0; i--){
+						ScheduleRealInfo temp4 = up2Map.get(up2.get(i));
+						String bcType = temp4.getBcType();
+						if(bcType.equals("region") || bcType.equals("venting")
+	    						|| bcType.equals("major")){
+	    					continue;
+	    				}
+						long delayLast0 = s3.getFcsjT() - temp4.getFcsjActualTime();
+						if(delayLast0 <= 1l && delayLast0 >= -2l){
+							s4 = temp4;
+							break;
+						}
+						break;
+					}
+					long delayFirst0 = s1.getFcsjT() - s2.getFcsjActualTime();
+					long delayLast0 = s3.getFcsjT() - s4.getFcsjActualTime();
 					temp.put("qdzFirst0", s1.getQdzName());
 					temp.put("jhfcFirst0", s1.getFcsj());
 					temp.put("sjfcFirst0", s2.getFcsjActual());
@@ -1849,11 +2091,63 @@ public class PeopleCarPlanServiceImpl implements PeopleCarPlanService {
 					Collections.sort(dn1);
 					Collections.sort(dn2);
 					ScheduleRealInfo s1 = dn1Map.get(dn1.get(0));
+					for(Long jhfcsj : dn1){
+						s1 = dn1Map.get(jhfcsj);
+						String bcType = s1.getBcType();
+						if(s1.getSpId() != null && spMap.containsKey(s1.getSpId())){
+							bcType = spMap.get(s1.getSpId());
+						}
+						if(bcType.equals("region") || bcType.equals("venting")
+	    						|| bcType.equals("major")){
+	    					continue;
+	    				}
+						break;
+					}
 					ScheduleRealInfo s2 = dn2Map.get(dn2.get(0));
+					for(Long sjfcsj : dn2){
+						ScheduleRealInfo temp2 = dn2Map.get(sjfcsj);
+						String bcType = temp2.getBcType();
+						if(bcType.equals("region") || bcType.equals("venting")
+	    						|| bcType.equals("major")){
+	    					continue;
+	    				}
+						long delayFirst1 = s1.getFcsjT() - temp2.getFcsjActualTime();
+						if(delayFirst1 <= 1l && delayFirst1 >= -2l){
+							s2 = temp2;
+							break;
+						}
+						break;
+					}
 					ScheduleRealInfo s3 = dn1Map.get(dn1.get(dn1.size()-1));
+					for(int i = dn1.size() - 1; i >= 0; i--){
+						s3 = dn1Map.get(dn1.get(i));
+						String bcType = s3.getBcType();
+						if(s3.getSpId() != null && spMap.containsKey(s3.getSpId())){
+							bcType = spMap.get(s3.getSpId());
+						}
+						if(bcType.equals("region") || bcType.equals("venting")
+	    						|| bcType.equals("major")){
+	    					continue;
+	    				}
+						break;
+					}
 					ScheduleRealInfo s4 = dn2Map.get(dn2.get(dn2.size()-1));
-					long delayFirst1 = dn1.get(0) - dn2.get(0);
-					long delayLast1 = dn1.get(dn1.size()-1) - dn2.get(dn2.size()-1);
+					for(int i = dn2.size() - 1; i >= 0; i--){
+						ScheduleRealInfo temp4 = dn2Map.get(dn2.get(i));
+						String bcType = temp4.getBcType();
+						if(bcType.equals("region") || bcType.equals("venting")
+	    						|| bcType.equals("major")){
+	    					continue;
+	    				}
+						long delayLast1 = s3.getFcsjT() - temp4.getFcsjActualTime();
+						if(delayLast1 <= 1l && delayLast1 >= -2l){
+							s4 = temp4;
+							break;
+						}
+						break;
+					}
+					long delayFirst1 = s1.getFcsjT() - s2.getFcsjActualTime();
+					long delayLast1 = s3.getFcsjT() - s4.getFcsjActualTime();
 					temp.put("qdzFirst1", s1.getQdzName());
 					temp.put("jhfcFirst1", s1.getFcsj());
 					temp.put("sjfcFirst1", s2.getFcsjActual());