数字基建接口--以及配置文件数据库配置修改

ljq
1 parent 77a74bd9
Showing 3 changed files with 162 additions and 4 deletions
src/main/java/com/bsth/server_rs/bigdata/BigscreenService.java
src/main/resources/ms-jdbc.properties
src/main/resources/xxfb-jdbc.properties
@@ -1270,8 +1270,166 @@ public class BigscreenService {
     	return JSON.parseObject(JSON.toJSONString(resMap));
     }
-    
-    /**临港给投控的指标接口（周文彬）
+
+
+
+	/**给大屏按日期查线路指标 --临港数字基建
+	 *
+	 */
+	@GET
+	@Path("/selectData/getScheduleStatistics_lg/{date}")
+	public List getScheduleStatistic_lg(@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,"
+				+ " 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("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>> smDetail = new ArrayList<Map<String,Object>>();
+		List<Map<String, Object>> qqDetail = new ArrayList<Map<String,Object>>();
+
+
+		BigDecimal yygl_z = new BigDecimal(0);//实时总营运里程
+
+		for(Map<String, Object> t : list){
+			if(yyLine.contains(t.get("lineCode").toString())){
+				yygl_z = yygl_z.add(new BigDecimal(t.get("sjyylc").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());
+				Double bfbbc = Double.valueOf(t.get("sjbc").toString()) / Double.valueOf(t.get("jhbc").toString());
+				bc.put("bfb", String.format("%.2f", bfbbc * 100)+ "%");
+				bcDetail.add(bc);
+
+				Map<String, Object> sm = new HashMap<String, Object>();
+				sm.put("type", "首末班准点详情");
+				sm.put("lineName", t.get("lineName").toString());
+				sm.put("jh", t.get("jhsmbcs").toString());
+				sm.put("sj", t.get("sjsmbczds").toString());
+				Double bfbsm = Double.valueOf(t.get("sjsmbczds").toString()) / Double.valueOf(t.get("jhsmbcs").toString());
+				sm.put("bfb", String.format("%.2f", bfbsm * 100)+ "%");
+				smDetail.add(sm);
+
+				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());
+				Double bfbqq = Double.valueOf(t.get("sjszfczds").toString()) / Double.valueOf(t.get("jhszfcs").toString());
+				qq.put("bfb", String.format("%.2f", bfbqq * 100) + "%");
+				qqDetail.add(qq);
+			}
+		}
+
+
+
+		List<Map<String, Object>> detailsList = new ArrayList<Map<String, Object>>();
+
+		detailsList.addAll(bcDetail);
+		detailsList.addAll(smDetail);
+		detailsList.addAll(qqDetail);
+
+		return detailsList;
+	}
+
+
+	/**临港给投控的指标接口（周文彬）
      * 出车率(资料上没有要出车率，要到站准点率但是这里没有)，班次执行率，起讫站准点率，首末班车准点率，挂牌线路准点率，签卡率
      */
     @GET
@@ -6,4 +6,4 @@
 ms.mysql.driver= com.mysql.jdbc.Driver
 ms.mysql.url= jdbc:mysql://10.10.150.103/ms?useUnicode=true&characterEncoding=utf-8
 ms.mysql.username= root
-ms.mysql.password= Aa123456
 \ No newline at end of file
+ms.mysql.password= fsodlgjiuigAQF2$9fs9
 \ No newline at end of file
@@ -6,4 +6,4 @@
 xxfb.mysql.driver= com.mysql.jdbc.Driver
 xxfb.mysql.url= jdbc:mysql://10.10.150.113/info_publish?useUnicode=true&characterEncoding=utf-8
 xxfb.mysql.username= root
-xxfb.mysql.password= Aa123456
 \ No newline at end of file
+xxfb.mysql.password= fsodlgjiuigAQF2$9fs9
 \ No newline at end of file