按日期查线路班次执行率接口

娄高锋
1 parent d4bea770
Showing 2 changed files with 214 additions and 7 deletions
src/main/java/com/bsth/server_rs/bigdata/BigdataService.java
src/main/java/com/bsth/server_rs/bigdata/BigscreenService.java
@@ -7,6 +7,8 @@ import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Calendar;
+import java.util.Collections;
+import java.util.Comparator;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.HashSet;
@@ -1314,11 +1316,13 @@ public class BigdataService {
     		@PathParam("endDate") String endDate) throws ParseException {
     	String sql="select gs_bm,fgs_bm,real_exec_date,fcsj,fcsj_actual,xl_name,j_gh,j_name,cl_zbh,car_plate,remarks "
     			+ " from bsth_c_s_sp_info_real r left join bsth_c_cars c on r.cl_zbh = c.inside_code "
-    			+ " where schedule_date_str>='"+startDate+"' and schedule_date_str<= '"+endDate+"' "
-    			+ " and adjust_exps like '%肇事%' and status = '-1' "
+    			+ " where schedule_date_str >= ? and schedule_date_str <= ? "
+    			+ " and ((adjust_exps like '%肇事%' and status = '-1') "
+    			+ " or remarks = '肇事' or remarks like '%;肇事%' or remarks like '%肇事;%') "
     			+ " order by real_exec_date, schedule_date_str, fcsj";
-    	List<Map<String, Object>> list=jdbcTemplate.query(sql,
+    	List<Map<String, Object>> list=(List<Map<String, Object>>) jdbcTemplate.query(sql,
+    			new Object[] {startDate, endDate},
 				new RowMapper<Map<String, Object>>(){
 					@Override
 					public Map<String, Object>  mapRow(ResultSet rs, int rowNum) throws SQLException {
@@ -1360,9 +1364,30 @@ public class BigdataService {
     			m.put("remarks", (s==null?"":(s.getQdzName()+"->"+s.getZdzName()+"；"))+ds.getRemark());
     			list.add(m);
     		}
+    		
     		d1.setTime(d1.getTime() + 1l*1000*60*60*24);
     	}
+    	Collections.sort(list, new Comparator<Map<String, Object>>() {
+			@Override
+			public int compare(Map<String, Object> c1, Map<String, Object> c2) {
+//				int i1 = Integer.valueOf(c1.get("count").toString());
+//				int i2 = Integer.valueOf(c2.get("count").toString());
+				String str1 = c1.get("real_exec_date").toString() + (c1.get("fcsj").toString().length()>0?c1.get("fcsj").toString():"00:00");
+				String str2 = c2.get("real_exec_date").toString() + (c2.get("fcsj").toString().length()>0?c2.get("fcsj").toString():"00:00");
+				Long long1 = Long.valueOf(str1.replaceAll(" ", "").replaceAll("-", "").replaceAll(":", ""));
+				Long long2 = Long.valueOf(str2.replaceAll(" ", "").replaceAll("-", "").replaceAll(":", ""));
+				
+				long diff = long1 - long2;
+				if (diff > 0) {
+					return 1;
+				}else if (diff < 0) {
+					return -1;
+				}
+				return 0; //相等为0
+			}
+		});
+    	
     	return list;
     }
@@ -1406,8 +1431,10 @@ public class BigdataService {
     		if(s.getXlBm() != null && yyLine.contains(s.getXlBm())){//营运线路
 	    		String dateStr = s.getScheduleDateStr();
 	    		String gsBm = s.getGsBm();
+	    		String fgsBm = s.getFgsBm();
+	    		String xlName = s.getXlName();
 	    		String cl = s.getClZbh();
-	    		String key = dateStr + "/" + gsBm + "/" + cl;
+	    		String key = dateStr + "/" + gsBm + "/" + fgsBm + "/" + xlName + "/" + cl;
 	    		if(!(keyMap.containsKey(key))){
 	    			keyMap.put(key, new ArrayList<ScheduleRealInfo>());
 	    			keyList.add(key);
@@ -1440,9 +1467,12 @@ public class BigdataService {
 	    	double zksgl = Arith.add(sjjccgl, sjksgl);//实际空驶总公里
 	    	Map<String, Object> m = new HashMap<String, Object>();
-	    	m.put("date", key.split("/")[0]);
-	    	m.put("companyCode", key.split("/")[1]);
-	    	m.put("car", key.split("/")[2]);
+	    	String[] split = key.split("/");
+	    	m.put("date", split[0]);
+	    	m.put("companyCode", split[1]);
+	    	m.put("brancheCompanyCode", split[2]);
+	    	m.put("lineName", split[3]);
+	    	m.put("car", split[4]);
 	    	m.put("businessMileage", sjyygl);
 	    	m.put("emptyMileage", zksgl);
 	    	resList.add(m);
@@ -1032,6 +1032,183 @@ public class BigscreenService {
     	return JSON.parseObject(JSON.toJSONString(resMap));
     }
+    /**给大屏按日期查线路指标
+     * 
+     */
+    @GET
+    @Path("/selectData/getScheduleStatistics/{date}")
+    public JSONObject getScheduleStatistics(@PathParam("date") String date){
+    	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 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());
+    		}
+    	}
+    	
+    	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 = ? ";
+    	
+    	List<Map<String, Object>> list=jdbcTemplate.query(sql, new Object[]{date},
+				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("jhbc", rs.getString("jhbc"));
+						m.put("sjbc", rs.getString("sjbc"));
+						m.put("bczxl", rs.getString("bczxl"));
+						m.put("jhbcz", rs.getString("jhbcz"));
+						
+						m.put("jhcc", rs.getString("jhcc"));
+						m.put("sjcc", rs.getString("sjcc"));
+						m.put("ccl", rs.getString("ccl"));
+						m.put("jhccz", rs.getString("jhccz"));
+						
+						m.put("jhyylc", rs.getString("jhyylc"));
+						m.put("sjyylc", rs.getString("sjyylc"));
+						m.put("jhyylcz", rs.getString("jhyylcz"));
+						m.put("jhkslc", rs.getString("jhkslc"));
+						m.put("sjkslc", rs.getString("sjkslc"));
+						m.put("jhkslcz", rs.getString("jhkslcz"));
+
+						m.put("jhgfbcs", rs.getString("jhssgfbcs"));
+						m.put("sjgfbcs", rs.getString("sjgfbcs"));
+						m.put("jhgfbcsz", rs.getString("jhgfbcsz"));
+						m.put("jhdgbcs", rs.getString("jhssdgbcs"));
+						m.put("sjdgbcs", rs.getString("sjdgbcs"));
+						m.put("jhdgbcsz", rs.getString("jhdgbcsz"));
+
+						m.put("jhsmbcs", rs.getString("jhsmbcs"));
+						m.put("sjsmbczds", rs.getString("sjsmbczds"));
+						m.put("smbczdl", rs.getString("smbczdl"));
+						m.put("jhsmbcsz", rs.getString("jhsmbcsz"));
+						m.put("sjsmbczdsz", rs.getString("sjsmbczdsz"));
+						m.put("smbczdlz", rs.getString("smbczdlz"));
+						
+						m.put("jhszfcs", rs.getString("jhszfcs"));
+						m.put("sjszfczds", rs.getString("sjszfczds"));
+						m.put("szfczdl", rs.getString("szfczdl"));
+						
+						Date date = new Date();
+						date.setTime(rs.getTimestamp("create_date").getTime());
+						m.put("createDate", sdf.format(date));
+						return m;
+					}
+				});
+    	
+    	List<Map<String, Object>> bcDetail = new ArrayList<Map<String,Object>>();
+    	List<Map<String, Object>> qqDetail = new ArrayList<Map<String,Object>>();
+    	List<Map<String, Object>> gpDetail = new ArrayList<Map<String,Object>>();
+    	
+    	long sjbcs_z = 0l;//实时总班次
+    	BigDecimal yygl_z = new BigDecimal(0);//实时总营运里程
+    	long jhcc = 0, sjcc = 0, jhbc = 0, sjbc = 0, jhsmbc = 0, sjsmbc = 0,
+    			jhqqbc = 0, sjqqzd = 0, jhgpqqbc = 0, sjgpqqzd = 0;
+    	
+    	for(Map<String, Object> t : list){
+    		if(yyLine.contains(t.get("lineCode").toString())){
+    			sjbcs_z += Long.valueOf(t.get("sjbc").toString());
+	    		yygl_z = yygl_z.add(new BigDecimal(t.get("sjyylc").toString()));
+	    		
+	    		jhcc += Long.valueOf(t.get("jhccz").toString());
+	    		sjcc += Long.valueOf(t.get("sjcc").toString());
+	    		jhbc += Long.valueOf(t.get("jhbc").toString());
+	    		sjbc += Long.valueOf(t.get("sjbc").toString());
+	    		jhsmbc += Long.valueOf(t.get("jhsmbcs").toString());
+	    		sjsmbc += Long.valueOf(t.get("sjsmbczds").toString());
+	    		jhqqbc += Long.valueOf(t.get("jhszfcs").toString());
+	    		sjqqzd += Long.valueOf(t.get("sjszfczds").toString());
+	    		if(gpSet.contains(t.get("lineCode").toString())){
+	    			jhgpqqbc += Long.valueOf(t.get("jhszfcs").toString());
+	    			sjgpqqzd += Long.valueOf(t.get("sjszfczds").toString());
+	    		}
+	    		
+	    		Map<String, Object> bc = new HashMap<String, Object>();
+	    		bc.put("type", "班次执行详情");
+	    		bc.put("lineName", t.get("lineName").toString());
+	    		bc.put("jh", t.get("jhbc").toString());
+	    		bc.put("sj", t.get("sjbc").toString());
+	    		bcDetail.add(bc);
+	    		
+	    		Map<String, Object> qq = new HashMap<String, Object>();
+	    		qq.put("type", "起讫站发车准点详情");
+	    		qq.put("lineName", t.get("lineName").toString());
+	    		qq.put("jh", t.get("jhszfcs").toString());
+	    		qq.put("sj", t.get("sjszfczds").toString());
+	    		qqDetail.add(qq);
+	    		
+	    		if(gpSet.contains(t.get("lineCode").toString())){
+	    			Map<String, Object> gp = new HashMap<String, Object>();
+		    		gp.put("type", "挂牌线路发车准点详情");
+		    		gp.put("lineName", t.get("lineName").toString());
+		    		gp.put("jh", t.get("jhszfcs").toString());
+		    		gp.put("sj", t.get("sjszfczds").toString());
+		    		gpDetail.add(gp);
+	    		}
+    		}
+    	}
+    	
+    	List<Map<String, Object>> detailsList = new ArrayList<Map<String, Object>>();
+    	detailsList.addAll(bcDetail);
+    	detailsList.addAll(qqDetail);
+    	detailsList.addAll(gpDetail);
+    	
+    	resMap.put("ccl", jhcc>0?new BigDecimal(sjcc).divide(new BigDecimal(jhcc),
+				4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).doubleValue():"0");
+    	resMap.put("bczxl", jhbc>0?new BigDecimal(sjbc).divide(new BigDecimal(jhbc),
+				4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).doubleValue():"0");
+    	resMap.put("smbzdl", jhsmbc>0?new BigDecimal(sjsmbc).divide(new BigDecimal(jhsmbc),
+				4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).doubleValue():"0");
+    	resMap.put("qqzzdl", jhqqbc>0?new BigDecimal(sjqqzd).divide(new BigDecimal(jhqqbc),
+				4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).doubleValue():"0");
+    	resMap.put("gpzdl", jhgpqqbc>0?new BigDecimal(sjgpqqzd).divide(new BigDecimal(jhgpqqbc),
+				4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).doubleValue():"0");
+    	
+    	resMap.put("detailsList", detailsList);
+    	
+    	return JSON.parseObject(JSON.toJSONString(resMap));
+    }
+    
     @GET
     @Path("/selectData/attendance")
     public JSONObject attendance(){