给电科手机端的线路指标接口2

娄高锋
1 parent a9f3aed7
Showing 2 changed files with 231 additions and 2 deletions
src/main/java/com/bsth/repository/ScheduleRealInfoRepository.java
src/main/java/com/bsth/server_rs/bigdata/BigscreenService.java
@@ -18,7 +18,7 @@ public interface ScheduleRealInfoRepository extends PagingAndSortingRepository&lt;S
 	 * @return
 	 */
 	@EntityGraph(value = "scheduleRealInfo_cTasks", type = EntityGraph.EntityGraphType.FETCH)
-	@Query("select DISTINCT s from ScheduleRealInfo s where s.scheduleDateStr=?1")
+	@Query("select DISTINCT s from ScheduleRealInfo s where s.scheduleDateStr=?1 order by s.gsBm, s.fgsBm, s.xlName")
 	List<ScheduleRealInfo> findAll(String schDate);
 	/**
@@ -1526,7 +1526,7 @@ public class BigscreenService {
     	return JSON.parseObject(JSON.toJSONString(resMap));
     }
-    /**给电科手机端查线路指标(发车准点率)
+    /**给电科手机端查线路指标(起讫站发车准点率)
      * 
      */
     @GET
@@ -1632,6 +1632,235 @@ public class BigscreenService {
     	return JSON.parseObject(JSON.toJSONString(resMap));
     }
+    /**给电科手机端查线路指标(挂牌线路发车准点率)
+     * 
+     */
+    @GET
+    @Path("/selectData/getPlateLineBus/{company}/{branchCompany}")
+    public JSONObject getPlateLineBus(@PathParam("company") String company,
+    		@PathParam("branchCompany") String branchCompany){
+    	Map<String, Object> resMap = new HashMap<String, Object>();
+    	
+    	String gpLineSql = "select * from bsth_c_line_plate";
+    	List<Map<String, Object>> gpLineList=jdbcTemplate.query(gpLineSql,
+				new RowMapper<Map<String, Object>>(){
+					@Override
+					public Map<String, Object>  mapRow(ResultSet rs, int rowNum) throws SQLException {
+						Map<String, Object> m=new HashMap<String,Object>();
+						m.put("lineName", rs.getString("line_name"));
+						m.put("lineCode", rs.getString("line_code"));
+						return m;
+					}
+				});
+    	
+    	Set<String> gpSet = new HashSet<String>();
+    	for(Map<String, Object> t : gpLineList){
+    		if(t.get("lineCode") != null && t.get("lineCode").toString().trim().length() > 0){
+    			gpSet.add(t.get("lineCode").toString().trim());
+    		}
+    	}
+    	
+    	String date = sd.format(new Date());
+    	String gs = "", fgs = "";
+    	if(company.trim().length() > 0 && !("all".equals(company.trim()))){
+    		gs = company.trim();
+    	}
+    	if(branchCompany.trim().length() > 0 && !("all".equals(branchCompany.trim()))){
+    		fgs = branchCompany.trim();
+    	}
+    	
+    	String yyxlSql="SELECT line_code from bsth_c_line "
+    			+ " where nature in ('yxl','cgxl','gjxl','csbs','cctxl')";
+    	List<Map<String, Object>> yyxlList=jdbcTemplate.query(yyxlSql,
+				new RowMapper<Map<String, Object>>(){
+					@Override
+					public Map<String, Object>  mapRow(ResultSet rs, int rowNum) throws SQLException {
+						Map<String, Object> m=new HashMap<String,Object>();
+						m.put("lineCode", rs.getString("line_code"));
+						return m;
+					}
+				});
+    	Set<String> yyLine = new HashSet<String>();
+    	for(Map<String, Object> t : yyxlList){
+    		if(t.get("lineCode") != null){
+    			yyLine.add(t.get("lineCode").toString());
+    		}
+    	}
+    	
+    	List<String> objList = new ArrayList<String>();
+    	String sql="select xl,xl_name,date,jhbc,bczxl,jhbcz,sjbc,jhcc,sjcc,ccl,jhccz,"
+    			+ " jhyylc,sjyylc,jhyylcz,jhkslc,sjkslc,jhkslcz,"
+    			+ " jhssgfbcs,sjgfbcs,jhgfbcsz,jhssdgbcs,sjdgbcs,jhdgbcsz,"
+    			+ " jhsmbcs,sjsmbczds,smbczdl,jhsmbcsz,sjsmbczdsz,smbczdlz,"
+    			+ " jhszfcs,sjszfczds,szfczdl,create_date"
+    			+ " from bsth_c_calc_count "
+    			+ " where date = ? and gsdm != '77'";
+    	objList.add(date);
+    	if(fgs.length() > 0){
+    		sql +=" and gsdm = ? and fgsdm = ?";
+    		objList.add(gs);
+    		objList.add(fgs);
+    	} else if(gs.length() > 0){
+    		sql +=" and gsdm = ?";
+    		objList.add(gs);
+    	}
+    	
+    	List<Map<String, Object>> list=jdbcTemplate.query(sql,
+    			objList.toArray(),
+				new RowMapper<Map<String, Object>>(){
+					@Override
+					public Map<String, Object>  mapRow(ResultSet rs, int rowNum) throws SQLException {
+						Map<String, Object> m=new HashMap<String,Object>();
+						m.put("lineCode",rs.getString("xl"));
+						m.put("lineName", rs.getString("xl_name"));
+						m.put("date",  rs.getString("date"));
+						
+						m.put("jhszfcs", rs.getString("jhszfcs"));
+						m.put("sjszfczds", rs.getString("sjszfczds"));
+						
+						Date date = new Date();
+						date.setTime(rs.getTimestamp("create_date").getTime());
+						m.put("createDate", sdf.format(date));
+						return m;
+					}
+				});
+
+    	List<Map<String, Object>> detailsList = new ArrayList<Map<String, Object>>();
+    	
+    	long jh = 0, sj = 0;
+    	
+    	for(Map<String, Object> t : list){
+    		if(yyLine.contains(t.get("lineCode").toString())){
+	    		
+    			if(gpSet.contains(t.get("lineCode").toString())){
+    				
+	    			Long plan = Long.valueOf(t.get("jhszfcs").toString());
+	    			Long real = Long.valueOf(t.get("sjszfczds").toString());
+	    			
+		    		jh += plan;
+		    		sj += real;
+		    		
+		    		Map<String, Object> detail = new HashMap<String, Object>();
+		    		detail.put("lineName", t.get("lineName").toString());
+		    		detail.put("plan", plan);
+		    		detail.put("real", real);
+		    		detail.put("ratio", plan>0?new BigDecimal(real*100l).divide(
+		    				new BigDecimal(plan), 2, BigDecimal.ROUND_HALF_UP).doubleValue():"0");
+		    		detailsList.add(detail);
+    			}
+    		}
+    	}
+    	
+    	resMap.put("plan", jh);
+    	resMap.put("real", sj);
+    	resMap.put("ratio", jh>0?new BigDecimal(sj*100l).divide(
+    			new BigDecimal(jh), 2, BigDecimal.ROUND_HALF_UP).doubleValue():"0");
+    	
+    	resMap.put("detailsList", detailsList);
+    	
+    	return JSON.parseObject(JSON.toJSONString(resMap));
+    }
+    
+    /**给电科手机端查线路指标(签卡率)
+     * 
+     */
+    @GET
+    @Path("/selectData/getCardSigning/{company}/{branchCompany}")
+    public JSONObject getCardSigning(@PathParam("company") String company,
+    		@PathParam("branchCompany") String branchCompany){
+    	Map<String, Object> resMap = new HashMap<String, Object>();
+    	String date = sd.format(new Date());
+    	String gs = "", fgs = "";
+    	if(company.trim().length() > 0 && !("all".equals(company.trim()))){
+    		gs = company.trim();
+    	}
+    	if(branchCompany.trim().length() > 0 && !("all".equals(branchCompany.trim()))){
+    		fgs = branchCompany.trim();
+    	}
+    	
+    	String yyxlSql="SELECT line_code from bsth_c_line "
+    			+ " where nature in ('yxl','cgxl','gjxl','csbs','cctxl')";
+    	List<Map<String, Object>> yyxlList=jdbcTemplate.query(yyxlSql,
+				new RowMapper<Map<String, Object>>(){
+					@Override
+					public Map<String, Object>  mapRow(ResultSet rs, int rowNum) throws SQLException {
+						Map<String, Object> m=new HashMap<String,Object>();
+						m.put("lineCode", rs.getString("line_code"));
+						return m;
+					}
+				});
+    	Set<String> yyLine = new HashSet<String>();
+    	for(Map<String, Object> t : yyxlList){
+    		if(t.get("lineCode") != null){
+    			yyLine.add(t.get("lineCode").toString());
+    		}
+    	}
+    	
+    	List<Map<String, Object>> detailsList = new ArrayList<Map<String, Object>>();
+    	Map<String, Map<String, Object>> keyMap = new HashMap<String, Map<String, Object>>();
+    	
+    	long jh = 0, sj = 0;
+    	
+    	List<ScheduleRealInfo> findAll = scheduleRealInfoRepository.findAll(date);
+		for(ScheduleRealInfo s : findAll){
+			if(s.getGsBm() != null && s.getFgsBm() != null){
+				if("77".equals(s.getGsBm())){
+					continue;
+				}
+				if(fgs.length() > 0){
+					if(!(s.getGsBm().equals(gs)) || !(s.getFgsBm().equals(gs))){
+						continue;
+					}
+				} else if(gs.length() > 0){
+					if(!(s.getGsBm().equals(gs))){
+						continue;
+					}
+				}
+    			if(s.getXlBm() != null && yyLine.contains(s.getXlBm())){//营运线路
+	    			if(!isInOut(s) && !s.isCcService() && s.getStatus() != -1 && s.getStatus() != 0){
+	    				long plan = 0, real = 0;
+	    				++plan;
+	    				++jh;
+	    				String sty = decimalToBinary(s.getRfidState());
+	    				Integer state = Integer.parseInt(sty);
+	    				if ((state & 4) == 4) {
+		    				++real;
+	    					++sj;
+	    				}
+	    				if(!(keyMap.containsKey(s.getXlBm()))){
+	    					Map<String, Object> m = new HashMap<String, Object>();
+	    					m = new HashMap<String, Object>();
+	    		    		m.put("lineName", s.getXlName());
+	    		    		m.put("plan", "0");
+	    		    		m.put("real", "0");
+	    		    		keyMap.put(s.getXlBm(), m);
+	    		    		detailsList.add(m);
+	    				}
+	    				Map<String, Object> m = keyMap.get(s.getXlBm());
+	    				m.put("plan", Long.valueOf(m.get("plan").toString()) + plan);
+	    				m.put("real", Long.valueOf(m.get("real").toString()) + real);
+	    			}
+    			}
+			}
+		}
+		
+		for(Map<String, Object> m : detailsList){
+			long plan = Long.valueOf(m.get("plan").toString());
+			long real = Long.valueOf(m.get("real").toString());
+			resMap.put("ratio", plan>0?new BigDecimal(real*100l).divide(
+	    			new BigDecimal(plan), 2, BigDecimal.ROUND_HALF_UP).doubleValue():"0");
+		}
+    	
+    	resMap.put("plan", jh);
+    	resMap.put("real", sj);
+    	resMap.put("ratio", jh>0?new BigDecimal(sj*100l).divide(
+    			new BigDecimal(jh), 2, BigDecimal.ROUND_HALF_UP).doubleValue():"0");
+    	
+    	resMap.put("detailsList", detailsList);
+    	
+    	return JSON.parseObject(JSON.toJSONString(resMap));
+    }
+    
     @GET
     @Path("/selectData/attendance")
     public JSONObject attendance(){