新增年度总能耗接口，给投控。（周文彬）

娄高锋
1 parent f07de4cc
Showing 1 changed file with 98 additions and 0 deletions
src/main/java/com/bsth/server_rs/bigdata/BigdataService.java
@@ -1576,4 +1576,102 @@ public class BigdataService {
     	return resMap;
     }
  
+    /**
+     * 年度总能耗（单位：万公里）（临港给投控的接口，周文彬）
+     */
+    @GET
+    @Path("/findConsumptionByYear/all/{year}")
+    public Map<String, Object> findConsumptionByYear(@PathParam("year") String year) {
+    	SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+    	SimpleDateFormat yearFormat = new SimpleDateFormat("yyyy");
+    	SimpleDateFormat monFormat = new SimpleDateFormat("MM");
+    	Map<String, Object> resMap = new HashMap<String, Object>();
+    	try {
+	    	logger.info(year);
+    		Date parse = yearFormat.parse(year);
+    		String date1 = year + "-01-01", date2 = year + "-12-31";
+    		dateFormat.parse(year + "-01-01");
+    		dateFormat.parse(year + "-12-31");
+    		List<String> strList = new ArrayList<>();
+    		strList.add(date1);
+    		strList.add(date2);
+	    	BigDecimal zyh = new BigDecimal(0), zdh = new BigDecimal(0), zqh = new BigDecimal(0);
+	    	String ylbSql = "select yh from bsth_c_ylb "
+	    			+ "where rq >= ? and rq <= ? ";
+	    	List<Map<String, Object>> ylbList=jdbcTemplate.query(ylbSql, strList.toArray(),
+					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"));
+							return m;
+						}
+					});
+	    	
+//	    	logger.info(list.size()+"");
+//	    	HashMap<String, BigDecimal> monMap = new HashMap<String, BigDecimal>();
+	    	for(Map<String, Object> m : ylbList){
+	    		if(m.containsKey("yh") && m.get("yh").toString().length() > 0){
+	    			try {
+	    				zyh = zyh.add(new BigDecimal(m.get("yh").toString()));
+					} catch (Exception e) {
+						continue;
+					}
+	    		}
+	    	}
+	    	
+	    	String dlbSql = "select hd from bsth_c_dlb "
+	    			+ "where rq >= ? and rq <= ? ";
+	    	List<Map<String, Object>> dlbList=jdbcTemplate.query(dlbSql, strList.toArray(),
+					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"));
+							return m;
+						}
+					});
+	    	
+	    	for(Map<String, Object> m : dlbList){
+	    		if(m.containsKey("hd") && m.get("hd").toString().length() > 0){
+	    			try {
+	    				zdh = zdh.add(new BigDecimal(m.get("hd").toString()));
+					} catch (Exception e) {
+						continue;
+					}
+	    		}
+	    	}
+	    	
+	    	String qlbSql = "select hn from bsth_c_qlb "
+	    			+ "where rq >= ? and rq <= ? ";
+	    	List<Map<String, Object>> qlbList=jdbcTemplate.query(qlbSql, strList.toArray(),
+					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"));
+							return m;
+						}
+					});
+	    	
+	    	for(Map<String, Object> m : qlbList){
+	    		if(m.containsKey("hn") && m.get("hn").toString().length() > 0){
+	    			try {
+	    				zqh = zdh.add(new BigDecimal(m.get("hn").toString()));
+					} catch (Exception e) {
+						continue;
+					}
+	    		}
+	    	}
+	    	
+	    	resMap.put("oil", zyh.doubleValue());
+	    	resMap.put("electricity", zdh.doubleValue());
+	    	resMap.put("hydrogen", zqh.doubleValue());
+		} catch (Exception e) {
+			// TODO: handle exception
+			e.printStackTrace();
+		}
+    	return resMap;
+    }
+    
 }