给安全系统，按驾驶员统计总公里

娄高锋
1 parent 476f506d
Showing 1 changed file with 77 additions and 1 deletions
src/main/java/com/bsth/server_rs/bigdata/BigdataService.java
@@ -1616,5 +1616,81 @@ public class BigdataService {
     	resMap.put("electricList", dlbList);
     	return resMap;
     }
-    
+	
+	/**
+     * 给安全系统，按驾驶员统计公里
+     * @param starDate
+     * @param endDate
+     * @return
+     * @throws ParseException 
+     */
+	@GET
+	@Path("/mileageByDriver/startDate/{startDate}/endDate/{endDate}")
+	public List<Map<String, Object>> mileageByDriver(@PathParam("startDate") String starDate,
+			@PathParam("endDate") String endDate) throws ParseException {
+		List<Map<String, Object>> resList = new ArrayList<Map<String, Object>>();
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+		Date date1 = sdf.parse(starDate);
+		Date date2 = sdf.parse(endDate);
+		
+		String yyxlSql="SELECT gsdm, gsname, fgsdm, fgsname, rq_str, xl_name, j_gh, j_name,"
+				+ " sjyylc, sjfyylc, ljyylc, ljfyylc"
+				+ " from calc_waybill"
+				+ " where rq between ? and ?";
+		List<Map<String, Object>> calcList=jdbcTemplate.query(yyxlSql, 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("gsdm", rs.getString("gsdm"));
+						m.put("gsname", rs.getString("gsname"));
+						m.put("fgsdm", rs.getString("fgsdm"));
+						m.put("fgsname", rs.getString("fgsname"));
+						m.put("rq_str", rs.getString("rq_str"));
+						m.put("xl_name", rs.getString("xl_name"));
+						m.put("j_gh", rs.getString("j_gh"));
+						m.put("j_name", rs.getString("j_name"));
+						m.put("sjyylc", rs.getString("sjyylc"));
+						m.put("sjfyylc", rs.getString("sjfyylc"));
+						m.put("ljyylc", rs.getString("ljyylc"));
+						m.put("ljfyylc", rs.getString("ljfyylc"));
+						return m;
+					}
+				});
+		
+		Map<String, Map<String, Object>> keyMap = new HashMap<String, Map<String, Object>>();
+		for(Map<String, Object> m : calcList){
+			String rq_str = m.get("rq_str").toString();
+			String gsdm = m.get("gsdm").toString();
+			String fgsdm = m.get("fgsdm").toString();
+			String gh = m.get("j_gh").toString();
+			String name = m.get("j_name").toString();
+			String key = rq_str + "/" + gsdm + "/" + fgsdm + "/" + gh + "/" + name;
+			if(!keyMap.containsKey(key)){
+				Map<String, Object> temp = new HashMap<String, Object>();
+				temp.put("date", rq_str);
+				temp.put("company", gsdm);
+				temp.put("brancheCompany", fgsdm);
+				temp.put("gh", gh);
+				temp.put("name", name);
+				temp.put("mileage", "0");
+				keyMap.put(key, temp);
+			}
+			Map<String, Object> temp = keyMap.get(key);
+			BigDecimal mileage = new BigDecimal(temp.get("mileage").toString());
+			BigDecimal sjyylc = new BigDecimal(m.get("sjyylc").toString());
+			BigDecimal sjfyylc = new BigDecimal(m.get("sjfyylc").toString());
+			BigDecimal ljyylc = new BigDecimal(m.get("ljyylc").toString());
+			BigDecimal ljfyylc = new BigDecimal(m.get("ljfyylc").toString());
+			temp.put("mileage", mileage.add(sjyylc).add(sjfyylc).add(ljyylc).add(ljfyylc));
+		}
+		
+		for(String key : keyMap.keySet()){
+			Map<String, Object> m = keyMap.get(key);
+			resList.add(m);
+		}
+		
+		return resList;
+	}
+	
 }