人车班次里程预统计查询接口；单日每车加油加电查询接口；

娄高锋
1 parent 05864725
Showing 1 changed file with 107 additions and 0 deletions
src/main/java/com/bsth/server_rs/bigdata/BigdataService.java
 package com.bsth.server_rs.bigdata;
+import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.text.DecimalFormat;
@@ -1507,4 +1509,109 @@ public class BigdataService {
     	return resList;
     }
+    //人车班次里程预统计查询
+    @GET
+    @Path("/findWaybill/startDate/{startDate}/endDate/{endDate}")
+    public List<Map<String, Object>> findWaybill(@PathParam("startDate") String startDate,
+    		@PathParam("endDate") String endDate) {
+    	String sql = "select * from calc_waybill where rq_str >= ? and rq_str <= ?";
+    	List<Map<String, Object>> list=jdbcTemplate.query(sql,
+    			new Object[] {startDate, endDate},
+				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("gsdm", rs.getString("gsdm"));
+						m.put("gsname", rs.getString("gsname"));
+						m.put("fgsdm", rs.getString("fgsdm"));
+						m.put("fgsname", rs.getString("fgsname"));
+						m.put("rqStr", rs.getString("rq_str"));
+						m.put("xl", rs.getString("xl"));
+						m.put("xlName", rs.getString("xl_name"));
+						m.put("cl", rs.getString("cl"));
+						m.put("lp", rs.getString("lp"));
+						m.put("jGh", rs.getString("j_gh"));
+						m.put("jName", rs.getString("j_name"));
+						m.put("sGh", rs.getString("s_gh"));
+						m.put("sName", rs.getString("s_name"));
+						m.put("jhyybc", rs.getInt("jhyybc"));
+						m.put("jhyybczgf", rs.getInt("jhyybczgf"));
+						m.put("jhyybcwgf", rs.getInt("jhyybcwgf"));
+						m.put("jhfyybc", rs.getInt("jhfyybc"));
+						m.put("jhyylc", rs.getDouble("jhyylc"));
+						m.put("jhfyylc", rs.getDouble("jhfyylc"));
+						m.put("sjyybc", rs.getInt("sjyybc"));
+						m.put("sjyybczgf", rs.getInt("sjyybczgf"));
+						m.put("sjyybcwgf", rs.getInt("sjyybcwgf"));
+						m.put("sjfyybc", rs.getInt("sjfyybc"));
+						m.put("sjyylc", rs.getDouble("sjyylc"));
+						m.put("sjfyylc", rs.getDouble("sjfyylc"));
+						m.put("ljbc", rs.getInt("ljbc"));
+						m.put("ljbczgf", rs.getInt("ljbczgf"));
+						m.put("ljbcwgf", rs.getInt("ljbcwgf"));
+						m.put("ljyylc", rs.getDouble("ljyylc"));
+						m.put("ljfyylc", rs.getDouble("ljfyylc"));
+						m.put("lbbc", rs.getInt("lbbc"));
+						m.put("lblc", rs.getDouble("lblc"));
+						m.put("lblcLz", rs.getDouble("lblc_lz"));
+						m.put("lblcDm", rs.getDouble("lblc_dm"));
+						m.put("lblcGz", rs.getDouble("lblc_gz"));
+						m.put("lblcJf", rs.getDouble("lblc_jf"));
+						m.put("lblcZs", rs.getDouble("lblc_zs"));
+						m.put("lblcQr", rs.getDouble("lblc_qr"));
+						m.put("lblcQc", rs.getDouble("lblc_qc"));
+						m.put("lblcKx", rs.getDouble("lblc_kx"));
+						m.put("lblcQh", rs.getDouble("lblc_qh"));
+						m.put("lblcYw", rs.getDouble("lblc_yw"));
+						m.put("lblcQt", rs.getDouble("lblc_qt"));
+						m.put("fzbc", rs.getInt("fzbc"));
+						m.put("fzbczgf", rs.getInt("fzbczgf"));
+						m.put("fzbcwgf", rs.getInt("fzbcwgf"));
+						m.put("dtbc", rs.getInt("dtbc"));
+						m.put("dtbczgf", rs.getInt("dtbczgf"));
+						m.put("dtbcwgf", rs.getInt("dtbcwgf"));
+						return m;
+					}
+				});
+    	
+    	return list;
+    }
+    
+    //单日每车加油加电
+    @GET
+    @Path("/findCarEnergySupplement/{data}")
+    public Map<String, Object> findWaybill(@PathParam("date") String date) {
+    	Map<String, Object> resMap = new HashMap<String, Object>();
+    	
+    	String ylbSql = "select nbbm, sum(jzl) jzl from bsth_c_ylb where rq = ? group by nbbm";
+    	List<Map<String, Object>> ylbList=jdbcTemplate.query(ylbSql,
+    			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("car", rs.getString("nbbm"));
+						m.put("liters", new BigDecimal(rs.getDouble("jzl")).setScale(2, RoundingMode.HALF_UP));
+						return m;
+					}
+				});
+    	
+    	String dlbSql = "select nbbm, sum(cdl) cdl from bsth_c_dlb where rq = ? group by nbbm";
+    	List<Map<String, Object>> dlbList=jdbcTemplate.query(ylbSql,
+    			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("car", rs.getString("nbbm"));
+						m.put("degrees", new BigDecimal(rs.getDouble("cdl")).setScale(2, RoundingMode.HALF_UP));
+						return m;
+					}
+				});
+    	
+    	resMap.put("oilList", ylbList);
+    	resMap.put("electricList", dlbList);
+    	return null;
+    }
+    
 }