Update

徐烜
2 parents 04e74994 dc0d588d
Showing 9 changed files with 138 additions and 63 deletions
src/main/java/com/bsth/controller/realcontrol/RealMapController.java
src/main/java/com/bsth/controller/realcontrol/anomalyCheckController.java
src/main/java/com/bsth/data/gpsdata/arrival/GeoCacheData.java
src/main/java/com/bsth/data/gpsdata/arrival/entity/TimedEnableStationRoute.java
src/main/java/com/bsth/data/schedule/DayOfSchedule.java
src/main/java/com/bsth/data/schedule/SchAttrCalculator.java
src/main/java/com/bsth/repository/realcontrol/ScheduleRealInfoRepository.java
src/main/java/com/bsth/service/oil/impl/YlxxbServiceImpl.java
src/main/java/com/bsth/service/realcontrol/impl/ScheduleRealInfoServiceImpl.java
 package com.bsth.controller.realcontrol;
+import com.bsth.data.gpsdata.arrival.GeoCacheData;
+import com.bsth.data.gpsdata.arrival.entity.TimedEnableStationRoute;
 import com.bsth.service.realcontrol.RealMapService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
@@ -74,4 +77,9 @@ public class RealMapController {
     public Map<String, Object> multiSectionRoute(@RequestParam String codeIdx){
         return realMapService.multiSectionRoute(codeIdx);
     }
+
+    @RequestMapping(value = "/lockAndFlxedTimeEnabled", method = RequestMethod.POST)
+    public void lockAndFlxedTimeEnabled(TimedEnableStationRoute tes){
+        GeoCacheData.tesMap.put(tes.getLineCode(), tes);
+    }
 }
@@ -102,7 +102,7 @@ public class anomalyCheckController {
     }
     @RequestMapping(value = "/findSchByLpName")
-    public List<ScheduleRealInfo> findSchByLpName(String lpName){
+    public List<ScheduleRealInfo> findSchByLpName(@RequestParam String lpName){
         return dayOfSchedule.getLpScheduleMap().get(lpName);
     }
 }
@@ -2,6 +2,7 @@ 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.entity.TimedEnableStationRoute;
 import com.bsth.data.gpsdata.arrival.utils.CircleQueue;
 import com.bsth.data.gpsdata.arrival.utils.StationRouteComp;
 import com.google.common.collect.ArrayListMultimap;
@@ -53,6 +54,10 @@ public class GeoCacheData {
     //线路限速信息
     private static Map<String, Double> speedLimitMap;
+    //需要定时刷新的站点路由
+    public static Map<String, TimedEnableStationRoute> tesMap = new HashMap<>();
+    //TimedEnableStationRoute
+
     @Autowired
     JdbcTemplate jdbcTemplate;
@@ -282,6 +287,28 @@ public class GeoCacheData {
                 connectStationRoute(tempMap.get(key));
             }
+            //定时启用的站点走向
+            if(tesMap.size() > 0){
+                List<String> rems = new ArrayList<>();
+                long t = System.currentTimeMillis();
+                for(TimedEnableStationRoute tes : tesMap.values()){
+                    if(tes.getEnableTime() > t){
+                        logger.info("锁住站点路由，"  + tes.getLineCode());
+                        tempMap.replaceValues(tes.getLineCode() + "_0", stationCacheMap.get(tes.getLineCode() + "_0"));
+                        tempMap.replaceValues(tes.getLineCode() + "_1", stationCacheMap.get(tes.getLineCode() + "_1"));
+                    }
+                    else
+                        rems.add(tes.getLineCode());
+                }
+
+                //remove
+                if(rems.size() > 0){
+                    for(String lineCode : rems){
+                        logger.info("启用路由，"  + lineCode);
+                        tesMap.remove(lineCode);
+                    }
+                }
+            }
             stationCacheMap = tempMap;
             routeCodeMap = codeMap;
         }
+package com.bsth.data.gpsdata.arrival.entity;
+
+/**
+ * 定时启用站点路由
+ * Created by panzhao on 2017/8/28.
+ */
+public class TimedEnableStationRoute {
+
+    private String lineCode;
+
+    private Long enableTime;
+
+    public String getLineCode() {
+        return lineCode;
+    }
+
+    public void setLineCode(String lineCode) {
+        this.lineCode = lineCode;
+    }
+
+    public Long getEnableTime() {
+        return enableTime;
+    }
+
+    public void setEnableTime(Long enableTime) {
+        this.enableTime = enableTime;
+    }
+}
@@ -278,12 +278,14 @@ public class DayOfSchedule {
         List<String> lprms = new ArrayList<>();
         Set<String> lps = lpScheduleMap.keySet();
         for (String lp : lps) {
-            if (lp.indexOf(lineCode + "_") != -1)
+            if (lp.startsWith(lineCode + "_"))
                 lprms.add(lp);
         }
-        for (String lp : lprms)
+        for (String lp : lprms){
+            logger.info("清理路牌映射 " + lp);
             lpScheduleMap.removeAll(lp);
+        }
         logger.info(lineCode + "排班清理 " + count);
     }
@@ -117,8 +117,7 @@ public class SchAttrCalculator {
 		for(int i = 1; i < len; i ++){
 			curr = list.get(i);
-			if(prve.getZdzName().equals(curr.getQdzName())
-					|| prve.getZdzCode().equals(curr.getQdzCode())){
+			if(isJoin(prve, curr)){
 				curr.setQdzArrDatejh(prve.getZdsj());
 				if(StringUtils.isNotEmpty(prve.getZdsjActual()))
 					curr.setQdzArrDatesj(prve.getZdsjActual());
@@ -126,6 +125,13 @@ public class SchAttrCalculator {
 			prve = curr;
 		}
 	}
+
+	private boolean isJoin(ScheduleRealInfo prve, ScheduleRealInfo curr) {
+		return prve.getZdzName().equals(curr.getQdzName())//名称相等
+				|| prve.getZdzCode().equals(curr.getQdzCode())//编码相等
+				|| prve.getZdzName().startsWith(curr.getQdzName())//起始包括
+				|| curr.getQdzName().startsWith(prve.getZdzName());//起始包括
+	}
 	/**
 	 * 
@@ -139,19 +139,19 @@ public interface ScheduleRealInfoRepository extends BaseRepository&lt;ScheduleRealI
 	//去掉了 xlBm is not null 
 	@EntityGraph(value = "scheduleRealInfo_cTasks", type = EntityGraph.EntityGraphType.FETCH)
-	@Query(value="select DISTINCT s from ScheduleRealInfo s where s.xlBm like %?1%  and DATE_FORMAT(s.scheduleDate,'%Y-%m-%d') = ?2 order by s.xlDir,s.realExecDate,s.dfsj, (s.lpName+1)")
+	@Query(value="select DISTINCT s from ScheduleRealInfo s where s.xlBm like %?1%  and DATE_FORMAT(s.scheduleDate,'%Y-%m-%d') = ?2 order by s.xlDir,s.realExecDate,s.fcsj, lpName")
 	List<ScheduleRealInfo> scheduleByDateAndLine(String line,String date);
 	@EntityGraph(value = "scheduleRealInfo_cTasks", type = EntityGraph.EntityGraphType.FETCH)
-	@Query(value="select DISTINCT s from ScheduleRealInfo s where s.xlBm =?1 and DATE_FORMAT(s.scheduleDate,'%Y-%m-%d') = ?2 order by (s.lpName+1), s.realExecDate,s.dfsj")
+	@Query(value="select DISTINCT s from ScheduleRealInfo s where s.xlBm =?1 and DATE_FORMAT(s.scheduleDate,'%Y-%m-%d') = ?2 order by s.lpName, s.realExecDate,s.fcsj")
 	List<ScheduleRealInfo> scheduleByDateAndLineQp(String line,String date);
 	@EntityGraph(value = "scheduleRealInfo_cTasks", type = EntityGraph.EntityGraphType.FETCH)
-	@Query(value="select DISTINCT s from ScheduleRealInfo s where gsBm like %?1% and fgsBm like %?2%   and DATE_FORMAT(s.scheduleDate,'%Y-%m-%d') = ?3 and s.bcType not in ('in','out','ldks') order by s.xlDir,s.realExecDate,s.dfsj, (s.lpName+1)")
+	@Query(value="select DISTINCT s from ScheduleRealInfo s where gsBm like %?1% and fgsBm like %?2%   and DATE_FORMAT(s.scheduleDate,'%Y-%m-%d') = ?3 and s.bcType not in ('in','out','ldks') order by s.xlDir,s.realExecDate,s.fcsj, s.lpName")
 	List<ScheduleRealInfo> scheduleByDateAndLineByGs(String gsdm,String fgsdm,String date);
 	@EntityGraph(value = "scheduleRealInfo_cTasks", type = EntityGraph.EntityGraphType.FETCH)
-	@Query(value="select DISTINCT s from ScheduleRealInfo s where s.xlBm = ?1  and DATE_FORMAT(s.scheduleDate,'%Y-%m-%d') = ?2 order by s.xlDir,s.realExecDate,s.dfsj, (s.lpName+1)")
+	@Query(value="select DISTINCT s from ScheduleRealInfo s where s.xlBm = ?1  and DATE_FORMAT(s.scheduleDate,'%Y-%m-%d') = ?2 order by s.xlDir,s.realExecDate,s.fcsj, s.lpName")
 	List<ScheduleRealInfo> scheduleByDateAndLineQp2(String line,String date);
 	@EntityGraph(value = "scheduleRealInfo_cTasks", type = EntityGraph.EntityGraphType.FETCH)
@@ -45,23 +45,25 @@ public class YlxxbServiceImpl extends BaseServiceImpl&lt;Ylxxb,Integer&gt; implements 
 	JdbcTemplate jdbcTemplate;
 	@Override
 	public PageObject<Ylxxb> Pagequery(Map<String, Object> map) {
-		
+
 		String rq=map.get("yyrq").toString();
 		String gsdm=map.get("gsdm_like").toString();
 		String fgsdm=map.get("fgsdm_like").toString();
-		
-	String sql="	select * from ("
-			+ "select *,CONCAT(nbbm,jsy)  as nj "
-			+ " from bsth_c_ylxxb where yyrq='"+rq+"' "
-			+ " and gsdm ='"+gsdm+"') x where x.nj not in ("
-			+ " select CONCAT(nbbm,jsy)  from bsth_c_ylb "
-			+ " where  DATE_FORMAT(rq,'%Y-%m-%d')='"+rq+"'"
-			+ " and ssgsdm='"+gsdm+"' and fgsdm ='"+fgsdm+"')"
-			+ " and x.nbbm in (select nbbm  from bsth_c_ylb "
-			+ " where  DATE_FORMAT(rq,'%Y-%m-%d')='"+rq+"'"
-			+ " and ssgsdm='"+gsdm+"' and fgsdm ='"+fgsdm+"')";
-		
-		
+
+		String sql="	select * from ("
+				+ "select *,CONCAT(nbbm,jsy)  as nj "
+				+ " from bsth_c_ylxxb where yyrq='"+rq+"' "
+				+ " and gsdm ='"+gsdm+"' and jylx ='0') x where x.nj not in ("
+				+ " select CONCAT(nbbm,jsy)  from bsth_c_ylb "
+				+ " where rq='"+rq+"'"
+				+ " and ssgsdm='"+gsdm+"' and fgsdm ='"+fgsdm+"')"
+				+ " and x.nbbm in (select nbbm  from bsth_c_ylb "
+				+ " where rq='"+rq+"'"
+				+ " and ssgsdm='"+gsdm+"' and fgsdm ='"+fgsdm+"') "
+				+ " and x.nbbm not in (select nbbm from bsth_c_ylxxb"
+				+ " where yyrq='"+rq+"' and gsdm ='"+gsdm+"' AND jylx ='1')";
+
+
 		/*String sql= "select v.*,u.jsy as ldgh  from "
 				+ " ( select *  from   bsth_c_ylxxb x  where  "
 				+ " DATE_FORMAT(x.yyrq,'%Y-%m-%d')='"+rq+"'  and x.gsdm='"+gsdm+"'"
@@ -76,43 +78,43 @@ public class YlxxbServiceImpl extends BaseServiceImpl&lt;Ylxxb,Integer&gt; implements 
 				+ " where DATE_FORMAT(rq,'%Y-%m-%d')='"+rq+"'"
 				+ " and ssgsdm='"+gsdm+"'  and fgsdm='"+fgsdm+"' )  u "
 				+ " on  v.nbbm=u.nbbm ";*/
-		
+
 		//根具条件查询指定日期Ylxxb的数据
 //		List<Ylxxb> iterator=repository.checkYlxx(rq,gsdm);
 		/*if(map.get("gsdm_in")!=null){
 			map.put("ssgsdm_in", map.get("gsdm_in"));
 			map.remove("gsdm_in");
-			
+
 		}else{
 			map.put("ssgsdm_like", map.get("gsdm_like"));
 			map.remove("gsdm_like");
 		}*/
-		
+
 		//根具条件查询指定日期Ylb的数据
 //		List<Ylb> ylbIterator=ylbRepository.checkYl(rq,gsdm,fgsdm);
-		List<Ylxxb> list=jdbcTemplate.query(sql,  
-		        new RowMapper<Ylxxb>(){  
-            @Override  
-            public Ylxxb  mapRow(ResultSet rs, int rowNum) throws SQLException {  
-            	Ylxxb s  = new Ylxxb(); 
-            	s.setId(rs.getInt("id"));
-            	s.setYyrq(rs.getDate("yyrq"));
-            	s.setNbbm(rs.getString("nbbm"));
-            	s.setGsdm(rs.getString("gsdm"));
-            	s.setFgsdm(rs.getString("fgsdm"));
-            	s.setJsy(rs.getString("jsy"));
-            	s.setJzl(rs.getDouble("jzl"));
-            	s.setStationid(rs.getString("stationid"));
-            	s.setNylx(rs.getInt("nylx"));
-            	s.setJyggh(rs.getString("jyggh"));
-            	s.setYj(rs.getDouble("yj"));
+		List<Ylxxb> list=jdbcTemplate.query(sql,
+				new RowMapper<Ylxxb>(){
+					@Override
+					public Ylxxb  mapRow(ResultSet rs, int rowNum) throws SQLException {
+						Ylxxb s  = new Ylxxb();
+						s.setId(rs.getInt("id"));
+						s.setYyrq(rs.getDate("yyrq"));
+						s.setNbbm(rs.getString("nbbm"));
+						s.setGsdm(rs.getString("gsdm"));
+						s.setFgsdm(rs.getString("fgsdm"));
+						s.setJsy(rs.getString("jsy"));
+						s.setJzl(rs.getDouble("jzl"));
+						s.setStationid(rs.getString("stationid"));
+						s.setNylx(rs.getInt("nylx"));
+						s.setJyggh(rs.getString("jyggh"));
+						s.setYj(rs.getDouble("yj"));
 //            	s.setLdgh(rs.getString("ldgh"));
-            	s.setBz(rs.getString("bz"));
-                return s;  
-            }  
-		});  
-		
-		
+						s.setBz(rs.getString("bz"));
+						return s;
+					}
+				});
+
+
 		List<Ylb> listylb=ylbRepository.obtainYl(rq, gsdm, fgsdm, "", "", "nbbm");
 		for (int i = 0; i < list.size(); i++) {
 			String ldgh="";
@@ -122,11 +124,11 @@ public class YlxxbServiceImpl extends BaseServiceImpl&lt;Ylxxb,Integer&gt; implements 
 					if(ldgh.equals(""))
 						ldgh +=ylb.getJsy();
 					else
-					    ldgh += ","+ylb.getJsy();
+						ldgh += ","+ylb.getJsy();
 				}
 			}
 			list.get(i).setLdgh(ldgh);
-			
+
 		}
 		//正式使用用下面代码
 //		for (int i = 0; i < iterator.size(); i++) {
@@ -147,16 +149,16 @@ public class YlxxbServiceImpl extends BaseServiceImpl&lt;Ylxxb,Integer&gt; implements 
 //				list.add(y1);
 //			}
 //		}
-		
-		
-		
+
+
+
 		PageHelper pageHelper = new PageHelper(list.size(), map);
 		pageHelper.getMap();
 		PageObject<Ylxxb> pageObject = pageHelper.getPageObject();
 		pageObject.setDataList(list);
 		return pageObject;
 	}
-	@Transactional  
+	@Transactional
 	@Override
 	public Map<String, Object> checkJsy(Map<String, Object> map) throws Exception{
 		Map<String, Object> newMap=new HashMap<String,Object>();
@@ -175,11 +177,13 @@ public class YlxxbServiceImpl extends BaseServiceImpl&lt;Ylxxb,Integer&gt; implements 
 				Integer id =jsonObject.getInteger("id");
 				String jsy =jsonObject.getString("jsy");
 				Ylxxb ylxxb=repository.findOne(id);
-				ylxxb.setJsy(jsy);
-				ylxxb.setJylx(1);
-				repository.save(ylxxb);
+				if(!ylxxb.getJsy().equals(jsy)){
+					ylxxb.setJsy(jsy);
+					ylxxb.setJylx(1);
+					repository.save(ylxxb);
+				}
 			}
-		newMap.put("status", ResponseCode.SUCCESS);
+			newMap.put("status", ResponseCode.SUCCESS);
 		}catch(Exception e){
 			newMap.put("status", ResponseCode.ERROR);
 			logger.error("save erro.", e);
@@ -188,4 +192,4 @@ public class YlxxbServiceImpl extends BaseServiceImpl&lt;Ylxxb,Integer&gt; implements 
 		return newMap;
 	}
-}
+}
 \ No newline at end of file
@@ -4669,8 +4669,8 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
                         mr.setSjyygl(rs.getDouble("sjyygl"));
                         mr.setSjksgl(rs.getDouble("sjksgl"));
                         mr.setZgl(rs.getDouble("zyygl"));
-                        mr.setZddfgl(rs.getDouble("sddfgl"));
-                        mr.setSddfgl(rs.getDouble("zddfgl"));
+                        mr.setZddfgl(rs.getDouble("zddfgl"));
+                        mr.setSddfgl(rs.getDouble("sddfgl"));
                         mr.setWqwxhgl(rs.getDouble("wqwxhgl"));
                         mr.setBfwxhgl(rs.getDouble("bfwxhgl"));
                         mr.setPygl(rs.getDouble("pygl"));
@@ -4763,8 +4763,8 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
 				sReport.setSjyybc(rs.getInt("sjyybc"));
 				sReport.setSjksbc(rs.getInt("sjksbc"));
 				sReport.setZbc(rs.getInt("zyybc"));
-				sReport.setZddfbc(rs.getInt("sddfbc"));
-				sReport.setSddfbc(rs.getInt("zddfbc"));
+				sReport.setZddfbc(rs.getInt("zddfbc"));
+				sReport.setSddfbc(rs.getInt("sddfbc"));
 				sReport.setWqwxhbc(rs.getInt("wqwxhbc"));
 				sReport.setBfwxhbc(rs.getInt("bfwxhbc"));
 				sReport.setPybc(rs.getInt("pybc"));