添加了一个首末班次发车准点率的实时计算全天计算的统计接口

廖磊
1 parent 543c40f0
Showing 1 changed file with 71 additions and 1 deletions
src/main/java/com/bsth/server_rs/bigdata/BigdataService.java
@@ -35,6 +35,8 @@ public class BigdataService {
     JdbcTemplate jdbcTemplate;
 	DecimalFormat df = new DecimalFormat("0.00");
+	
+	SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
     /*
      * 线路接口开始
@@ -1005,7 +1007,7 @@ public class BigdataService {
     			+ " where date>='"+starDate+"' and date<= '"+endDate+"'";
     	if(!line.equals("all")){
     		sql +=" and xl='"+line+"'";
-    	}	
+    	}
     	List<Map<String, Object>> list=jdbcTemplate.query(sql,
 				new RowMapper<Map<String, Object>>(){
@@ -1212,4 +1214,72 @@ public class BigdataService {
     	return list;
     }
+    @GET
+    @Path("/departureTime/starDate/{starDate}/endDate/{endDate}/line/{line}")
+    public List<Map<String, Object>> departureTime(@PathParam("starDate") String starDate,
+    		@PathParam("endDate") String endDate,@PathParam("line") String line) {
+    	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>='"+starDate+"' and date<= '"+endDate+"'";
+    	if(!line.equals("all")){
+    		sql +=" and xl='"+line+"'";
+    	}
+    	
+    	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"));
+						
+						Date date = new Date();
+						date.setTime(rs.getTimestamp("create_date").getTime());
+						m.put("createDate", sdf.format(date));
+						return m;
+					}
+				});
+    	return list;
+    }
+    
 }