添加接口：按月份查询直属公司统计指标

娄高锋
1 parent 719ddbb1
Showing 1 changed file with 247 additions and 4 deletions
src/main/java/com/bsth/server_rs/bigdata/BigscreenService.java
@@ -249,6 +249,26 @@ public class BigscreenService {
     	}
+    	String cardSignSql="select xl_bm,xl_name,schedule_date_str,bcs,qks,rkgzs,ckgzs"
+    			+ " from card_signing "
+    			+ " where schedule_date_str >= '"+date2+"' and schedule_date_str <= '"+date+"'";
+    	List<Map<String, Object>> cardSignList=jdbcTemplate.query(cardSignSql,
+				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_bm"));
+						m.put("lineName", rs.getString("xl_name"));
+						m.put("date",  rs.getString("schedule_date_str"));
+						m.put("bcs",  rs.getString("bcs"));
+						m.put("qks",  rs.getString("qks"));
+						m.put("rkgzs",  rs.getString("rkgzs"));
+						m.put("ckgzs",  rs.getString("ckgzs"));
+						return m;
+					}
+				});
+    	
+    	
     	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,"
@@ -318,11 +338,12 @@ public class BigscreenService {
     	List<Map<String, Object>> smList = createMap("首末班发车准点率", dates);
     	List<Map<String, Object>> qqList = createMap("起讫站发车准点率", dates);
     	List<Map<String, Object>> gpList = createMap("挂牌线路发车准点率", dates);
+    	List<Map<String, Object>> qkList = createMap("签卡率", dates);
     	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;
+    			jhqqbc = 0, sjqqzd = 0, jhgpqqbc = 0, sjgpqqzd = 0, bcs_qk = 0, qks = 0;
     	for(Map<String, Object> t : list){
     		if(yyLine.contains(t.get("lineCode").toString())){
@@ -397,12 +418,26 @@ public class BigscreenService {
     		}
     	}
+    	for(Map<String, Object> t : cardSignList){
+    		if(yyLine.contains(t.get("lineCode").toString())){
+    			String d = t.get("date").toString();
+    			if(date.equals(d)){
+    				bcs_qk += Long.valueOf(t.get("bcs").toString());
+    				qks += Long.valueOf(t.get("qks").toString());
+    			}
+    			Map<String, Object> qkMap = qkList.get(datesMap.get(d));
+    			qkMap.put("jh", Long.valueOf(qkMap.get("jh").toString()) + Long.valueOf(t.get("bcs").toString()));
+    			qkMap.put("sj", Long.valueOf(qkMap.get("sj").toString()) + Long.valueOf(t.get("qks").toString()));
+    		}
+    	}
+    	
     	List<Map<String, Object>> zxlList = new ArrayList<Map<String, Object>>();
     	zxlList.addAll(ccList);
     	zxlList.addAll(bcList);
     	zxlList.addAll(smList);
     	zxlList.addAll(qqList);
     	zxlList.addAll(gpList);
+    	zxlList.addAll(qkList);
     	List<Map<String, Object>> detailsList = new ArrayList<Map<String, Object>>();
     	detailsList.addAll(bcDetail);
@@ -527,11 +562,13 @@ public class BigscreenService {
 				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", jhbc>0?new BigDecimal(sjsmbc).divide(new BigDecimal(jhsmbc),
+    	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", jhbc>0?new BigDecimal(sjqqzd).divide(new BigDecimal(jhqqbc),
+    	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", jhbc>0?new BigDecimal(sjgpqqzd).divide(new BigDecimal(jhgpqqbc),
+    	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("qkl", bcs_qk>0?new BigDecimal(qks).divide(new BigDecimal(bcs_qk),
 				4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).doubleValue():"0");
     	resMap.put("ratioList", zxlList);
@@ -928,6 +965,171 @@ public class BigscreenService {
     	return JSON.parseObject(JSON.toJSONString(resMap));
     }
+    /** 按月份查询直属公司统计指标 */
+    @GET
+    @Path("/selectData/getMonthly/{gsdm}/{month}")
+    public JSONObject getMonthly(@PathParam("gsdm") String gsdm, @PathParam("month") String month){
+    	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,jhzgl,sjzgl,create_date"
+    			+ " from bsth_c_calc_count "
+    			+ " where gsdm = '"+gsdm+"' and date like '%"+month+"%'";
+    	
+    	List<Map<String, Object>> list=jdbcTemplate.query(sql,
+				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"));
+						
+						m.put("jhzgl", rs.getString("jhzgl"));
+						m.put("sjzgl", rs.getString("sjzgl"));
+						
+						Date date = new Date();
+						date.setTime(rs.getTimestamp("create_date").getTime());
+						m.put("createDate", sdf.format(date));
+						return m;
+					}
+				});
+    	
+    	
+    	BigDecimal jhzgl = new BigDecimal(0), sjzgl = 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())){
+    			
+	    		jhzgl = jhzgl.add(new BigDecimal(t.get("jhzgl").toString()));
+	    		sjzgl = sjzgl.add(new BigDecimal(t.get("sjzgl").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());
+	    		}
+	    		
+    		}
+    	}
+    	
+    	resMap.put("date", month);
+    	
+    	resMap.put("jhzgl", df.format(jhzgl));
+    	resMap.put("sjzgl", df.format(sjzgl));
+    	resMap.put("jhcc", jhcc);
+    	resMap.put("sjcc", sjcc);
+    	resMap.put("jhbc", jhbc);
+    	resMap.put("sjbc", sjbc);
+    	resMap.put("jhsm", jhsmbc);
+    	resMap.put("sjsm", sjsmbc);
+    	resMap.put("jhqq", jhqqbc);
+    	resMap.put("sjqq", sjqqzd);
+    	resMap.put("jhgp", jhgpqqbc);
+    	resMap.put("sjgp", sjgpqqzd);
+
+    	resMap.put("glzxl", jhzgl.doubleValue()>0?sjzgl.divide(jhzgl,
+				4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).doubleValue():"0");
+    	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");
+    	
+    	return JSON.parseObject(JSON.toJSONString(resMap));
+    }
+    
     /** 按日期查询四家直属公司统计指标 */
     @GET
     @Path("/selectData/getCompanyData/{date}")
@@ -1058,6 +1260,27 @@ public class BigscreenService {
 				});
+    	String cardSignSql="select gs_bm,xl_bm,xl_name,schedule_date_str,bcs,qks,rkgzs,ckgzs"
+    			+ " from card_signing "
+    			+ " where schedule_date_str = '"+date+"'";
+    	List<Map<String, Object>> cardSignList=jdbcTemplate.query(cardSignSql,
+				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("gs",rs.getString("gs_bm")!=null?gsMap.get(rs.getString("gs_bm")):"");
+						m.put("lineCode",rs.getString("xl_bm"));
+						m.put("lineName", rs.getString("xl_name"));
+						m.put("date",  rs.getString("schedule_date_str"));
+						m.put("bcs",  rs.getString("bcs"));
+						m.put("qks",  rs.getString("qks"));
+						m.put("rkgzs",  rs.getString("rkgzs"));
+						m.put("ckgzs",  rs.getString("ckgzs"));
+						return m;
+					}
+				});
+    	
+    	
     	Map<String, Integer> sortMap = new HashMap<String, Integer>();
     	sortMap.put("杨高", 0);
     	sortMap.put("上南", 1);
@@ -1118,6 +1341,23 @@ public class BigscreenService {
     		}
     	}
+    	for(Map<String, Object> t : cardSignList){
+    		if(yyLine.contains(t.get("lineCode").toString())){
+	    		if(sortMap.get(t.get("gs")) != null){
+	    			Map<String, Object> m = resList.get(sortMap.get(t.get("gs")));
+					mapPut(m, "bcs", t.get("bcs").toString());
+					mapPut(m, "qks", t.get("qks").toString());
+//					mapPut(m, "rkgzs", t.get("rkgzs").toString());
+//					mapPut(m, "ckgzs", t.get("ckgzs").toString());
+	    		}
+	    		
+	    		mapPut(pjMap, "bcs", t.get("bcs").toString());
+				mapPut(pjMap, "qks", t.get("qks").toString());
+//				mapPut(pjMap, "rkgzs", t.get("rkgzs").toString());
+//				mapPut(pjMap, "ckgzs", t.get("ckgzs").toString());
+    		}
+    	}
+    	
     	for(Map<String, Object> m : resList){
     		m.put("date", date);
@@ -1139,6 +1379,9 @@ public class BigscreenService {
     		m.put("gpzdl", new BigDecimal(m.get("jhgpqqbc").toString()).doubleValue()>0?
     				new BigDecimal(m.get("sjgpqqzd").toString()).divide(new BigDecimal(m.get("jhgpqqbc").toString()),
     				4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).doubleValue():"0");
+    		m.put("qkl", new BigDecimal(m.get("bcs").toString()).doubleValue()>0?
+    				new BigDecimal(m.get("qks").toString()).divide(new BigDecimal(m.get("bcs").toString()),
+    				4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).doubleValue():"0");
     	}
     	return resList;