按月份查询油电氢月度百公里能耗

娄高锋
1 parent c6475169
Showing 1 changed file with 96 additions and 0 deletions
src/main/java/com/bsth/server_rs/bigdata/BigscreenService.java
@@ -3312,6 +3312,102 @@ public class BigscreenService {
 		return resList;
 	}
  
+    /** 按月查询油电氢百公里能耗(临港大屏，顾婷婷) 
+     * @throws ParseException */
+	@GET
+	@Path("/selectData/getConsumeByMonth/{month}")
+	public Map<String, Object> getConsumeByMonth(@PathParam("month") String month) throws Exception{
+		Map<String, Object> resMap = new HashMap<String, Object>();
+		SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+		SimpleDateFormat monFormat = new SimpleDateFormat("yyyy-MM");
+		
+		Date m1 = monFormat.parse(month);
+		Date m2 = new Date();
+		m2.setTime(m1.getTime() + 32l*1000*60*60*24);
+		m2 = monFormat.parse(monFormat.format(m2));
+		m2.setTime(m2.getTime() - 1l*1000*60*60*24);
+		
+		String date1 = dateFormat.format(m1);
+		String date2 = dateFormat.format(m2);
+		
+		String ylbSql="SELECT yh, zlc from bsth_c_ylb where rq >= ? and rq <= ? "
+				+ " and yh is not null and yh > 0 and zlc is not null and zlc > 0 ";
+    	List<Map<String, Object>> ylbList=jdbcTemplate.query(ylbSql, new Object[]{date1, date2},
+				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("yh", rs.getString("yh"));
+						m.put("zlc", rs.getString("zlc"));
+						return m;
+					}
+				});
+    	
+    	String dlbSql="SELECT hd, zlc from bsth_c_dlb where rq >= ? and rq <= ? "
+				+ " and hd is not null and hd > 0 and zlc is not null and zlc > 0 ";
+    	List<Map<String, Object>> dlbList=jdbcTemplate.query(dlbSql, new Object[]{date1, date2},
+				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("hd", rs.getString("hd"));
+						m.put("zlc", rs.getString("zlc"));
+						return m;
+					}
+				});
+    	
+    	String qlbSql="SELECT hn, zlc from bsth_c_qlb where rq >= ? and rq <= ? "
+				+ " and hn is not null and hn > 0 and zlc is not null and zlc > 0 ";
+    	List<Map<String, Object>> qlbList=jdbcTemplate.query(qlbSql, new Object[]{date1, date2},
+				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("hn", rs.getString("hn"));
+						m.put("zlc", rs.getString("zlc"));
+						return m;
+					}
+				});
+    	
+    	BigDecimal yh = new BigDecimal(0), yh_zlc = new BigDecimal(0),
+    				hd = new BigDecimal(0), hd_zlc = new BigDecimal(0),
+    				hn = new BigDecimal(0), hn_zlc = new BigDecimal(0);
+    	for(Map<String, Object> m : ylbList){
+    		yh = yh.add(new BigDecimal(m.get("yh").toString()));
+    		yh_zlc = yh_zlc.add(new BigDecimal(m.get("zlc").toString()));
+    	}
+    	
+    	for(Map<String, Object> m : dlbList){
+    		hd = hd.add(new BigDecimal(m.get("hd").toString()));
+    		hd_zlc = hd_zlc.add(new BigDecimal(m.get("zlc").toString()));
+    	}
+    	
+    	for(Map<String, Object> m : qlbList){
+    		hn = hn.add(new BigDecimal(m.get("hn").toString()));
+    		hn_zlc = hn_zlc.add(new BigDecimal(m.get("zlc").toString()));
+    	}
+		
+    	if(yh_zlc.compareTo(new BigDecimal(0)) > 0){
+    		resMap.put("oil", yh.divide(yh_zlc, 4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).doubleValue());
+    	} else {
+    		resMap.put("oil", 0);
+    	}
+    	if(hd_zlc.compareTo(new BigDecimal(0)) > 0){
+    		resMap.put("electricity", hd.divide(hd_zlc, 4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).doubleValue());
+    	} else {
+    		resMap.put("electricity", 0);
+    	}
+    	if(hn_zlc.compareTo(new BigDecimal(0)) > 0){
+    		resMap.put("hydrogen", hn.divide(hn_zlc, 4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)).doubleValue());
+    	} else {
+    		resMap.put("hydrogen", 0);
+    	}
+    	
+    	
+    	
+		return resMap;
+	}
+    
 //    public static void main(String[] args){
 //    	
 //    }