新增接口：浦东公交线路调查表，给郑鑫的。

娄高锋
1 parent 4c82259a
Showing 1 changed file with 78 additions and 0 deletions
src/main/java/com/bsth/server_rs/bigdata/BigdataService.java
@@ -31,13 +31,16 @@ import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.jdbc.core.RowMapper;
 import org.springframework.stereotype.Component;
  
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.bsth.common.BusinessCodeData;
+import com.bsth.entity.CalcInvestigateMonth;
 import com.bsth.entity.ChildTaskPlan;
 import com.bsth.entity.DestroySituation;
 import com.bsth.entity.ElecInfo;
 import com.bsth.entity.OilInfo;
 import com.bsth.entity.ScheduleRealInfo;
+import com.bsth.repository.CalcInvestigateMonthRepository;
 import com.bsth.repository.DestroySituationRepository;
 import com.bsth.repository.ElecInfoRepository;
 import com.bsth.repository.OilInfoRepository;
@@ -66,6 +69,10 @@ public class BigdataService {
     @Autowired
     private ElecInfoRepository elecInfoRepository;
  
+    @Autowired
+    private CalcInvestigateMonthRepository calcInvestigateMonthRepository;
+    
+    
 	DecimalFormat df = new DecimalFormat("0.00");
  
 	SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@@ -2066,4 +2073,75 @@ public class BigdataService {
 		return resList;
 	}
  
+	/**
+     * 浦东公交线路调查表（给郑鑫）
+     * @param date
+     * @return
+     * @throws ParseException 
+     */
+	@GET
+	@Path("/calcInvestigateMonth/month/{month}/{gs}/{fgs}/{line}")
+	public List<JSONObject> calcInvestigateMonth(@PathParam("month") String month,
+			@PathParam("gs") String gs, @PathParam("fgs") String fgs,
+			@PathParam("line") String line) throws ParseException {
+		List<JSONObject> resList = new ArrayList<JSONObject>();
+		
+		String xlSql="SELECT line_code, name, nature from bsth_c_line";
+    	List<Map<String, Object>> xlList=jdbcTemplate.query(xlSql,
+				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("lineCode", rs.getString("line_code"));
+						m.put("lineName", rs.getString("name"));
+						m.put("nature", rs.getString("nature"));
+						return m;
+					}
+				});
+    	Set<String> yyLine = new HashSet<String>();
+    	for(Map<String, Object> t : xlList){
+    		if(t.get("lineCode") != null){
+    			String nature = t.get("nature")!=null?t.get("nature").toString():"";
+    			if("yxl".equals(nature) || "cgxl".equals(nature) || "gjxl".equals(nature)
+    					|| "csbs".equals(nature) || "cctxl".equals(nature)){
+					yyLine.add(t.get("lineCode").toString());
+    			}
+    		}
+    	}
+    	
+    	if(gs == null || gs.trim().length() == 0){		//公司编码别传空值，就让传all代表全部
+    		gs = "xxxx";
+    	}
+    	if("all".equals(gs.trim())){
+    		gs = "";
+    	}
+    	if(fgs == null || fgs.trim().length() == 0){	//分公司编码别传空值，就让传all代表全部
+    		fgs = "xxxx";
+    	}
+    	if("all".equals(fgs.trim())){
+    		fgs = "";
+    	}
+    	
+    	List<CalcInvestigateMonth> list = new ArrayList<CalcInvestigateMonth>();
+    	if(line != null && !"all".equals(line.trim())){
+			list = calcInvestigateMonthRepository.findByMonthAndLine(month, line);
+		} else if(gs != null && gs.length() > 0){
+			list = calcInvestigateMonthRepository.findByMonth(month, gs, fgs);
+		} else {
+			list = calcInvestigateMonthRepository.findByMonth(month);
+		}
+    	
+    	for(CalcInvestigateMonth c : list){
+    		if(yyLine.contains(c.getXl())){
+    			JSONObject jsonObject = (JSONObject)JSON.toJSON(c);
+    			jsonObject.put("gsName", BusinessCodeData.code2Name.get(jsonObject.get("gsbm").toString()));
+    			jsonObject.put("fgsName", BusinessCodeData.code2Name.get(jsonObject.get("gsbm").toString()
+    					+ "_" + jsonObject.get("fgsbm").toString()));
+    			resList.add(jsonObject);
+    		}
+		}
+    	
+		return resList;
+	}
+	
 }