加个临港给投控年度总里程的接口

娄高锋
1 parent 4e7fc07e
Showing 1 changed file with 51 additions and 1 deletions
src/main/java/com/bsth/server_rs/bigdata/BigdataService.java
 package com.bsth.server_rs.bigdata;
  
+import java.math.BigDecimal;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.text.DecimalFormat;
@@ -1483,7 +1484,9 @@ public class BigdataService {
     	return resList;
     }
  
-    //全部挂牌线路
+    /**
+     * 全部挂牌线路
+     */
     @GET
     @Path("/findLinePlate/all")
     public List<Map<String, Object>> findLinePlate() {
@@ -1509,4 +1512,51 @@ public class BigdataService {
     	return resList;
     }
  
+    /**
+     * 年度总里程（单位：万公里）（临港给投控的接口，周文彬）
+     */
+    @GET
+    @Path("/findMileageByYear/all/{year}")
+    public Map<String, Object> findMileageByYear(@PathParam("year") String year) {
+    	SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+    	SimpleDateFormat yearFormat = new SimpleDateFormat("yyyy");
+    	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);
+	    	String sql = "select sjzgl from bsth_c_calc_count "
+	    			+ "where date >= ? and date <= ? ";
+	    	logger.info(sql);
+	    	logger.info(date1 + "><" + date2);
+	    	List<Map<String, Object>> list=jdbcTemplate.query(sql, 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("sjzgl", rs.getString("sjzgl"));
+							return m;
+						}
+					});
+	    	
+	    	BigDecimal zgl = new BigDecimal(0);
+	    	logger.info(list.size()+"");
+	    	for(Map<String, Object> m : list){
+	    		if(m.containsKey("sjzgl") && m.get("sjzgl").toString().length() > 0){
+	    			zgl = zgl.add(new BigDecimal(m.get("sjzgl").toString()));
+	    		}
+	    	}
+	    	resMap.put("mileage", zgl.divide(new BigDecimal(10000), 3, BigDecimal.ROUND_HALF_UP).doubleValue());
+		} catch (Exception e) {
+			// TODO: handle exception
+			e.printStackTrace();
+		}
+    	return resMap;
+    }
+    
 }