新增公司内部需要调用的数据接口：基础班次里程数据接口，指标率数据接口

廖磊
1 parent 8f316979
Showing 2 changed files with 83 additions and 6 deletions
src/main/java/com/bsth/CXFConfig.java
src/main/java/com/bsth/server_rs/bigdata/BigdateService.java → src/main/java/com/bsth/server_rs/bigdata/BigdataService.java
 package com.bsth;
+
 import com.bsth.server_rs.AuthorizeInterceptor_IN;
 import com.bsth.server_rs.base_info.car.CarRestService;
 import com.bsth.server_rs.base_info.line.LineRestService;
@@ -7,7 +8,7 @@ import com.bsth.server_rs.base_info.person.PersonRestService;
 import com.bsth.server_rs.base_info.section.LD_RoadSpeedRestService;
 import com.bsth.server_rs.base_info.section.LD_SectionRestService;
 import com.bsth.server_rs.base_info.station.StationRestService;
-import com.bsth.server_rs.bigdata.BigdateService;
+import com.bsth.server_rs.bigdata.BigdataService;
 import com.bsth.server_rs.directive.DirectiveRestService;
 import com.bsth.server_rs.electric.ElectricService;
 import com.bsth.server_rs.exception.AesExceptionMapper;
@@ -110,7 +111,7 @@ public class CXFConfig {
     @Autowired
     ElectricService electricService;
     @Autowired
-    BigdateService bigdateService;
+    BigdataService bigdataService;
     @Autowired
     StaffViewRealService staffViewRealService;
@@ -134,7 +135,7 @@ public class CXFConfig {
                 ld_roadSpeedRestService,
                 electricService,
                 staffViewRealService,
-                bigdateService));
+                bigdataService));
         endpoint.setProviders(Arrays.asList(new JacksonJsonProvider(), new AesExceptionMapper()));
         //endpoint.setFeatures(Arrays.asList(new Swagger2Feature()));
         endpoint.getInInterceptors().add(new AuthorizeInterceptor_IN());
@@ -28,7 +28,7 @@ import com.alibaba.fastjson.JSONObject;
 @Component
 @Path("/bigdata")
 @Produces({MediaType.APPLICATION_JSON})
-public class BigdateService {
+public class BigdataService {
     Logger logger = LoggerFactory.getLogger(this.getClass());
     @Autowired
@@ -833,8 +833,7 @@ public class BigdateService {
     @GET
     @Path("/car/all")
     public List<Map<String, Object>> findCar() {
-		String carStr= GetHttpInterface.
-				getHttpInterface("http://180.166.5.82:8076/cars/getAllCarsInterface");
+		String carStr= GetHttpInterface.getHttpInterface("http://180.166.5.82:8076/cars/getAllCarsInterface");
 		//车辆库资料资料
 		List<Map<String, Object>> clkList=(List<Map<String, Object>>) JSONObject.parse(carStr);
     	//调度系统车辆资料
@@ -992,6 +991,8 @@ public class BigdateService {
     /**
      * 闵行线路班次里程
      *
+     *
+     *
      */
     @GET
@@ -1136,4 +1137,79 @@ public class BigdateService {
 					});
 	    return list;
     }
+    
+    
+   /**
+     *公司内部使用数据
+     *
+     *班次里程基础数据接口
+     */
+    @GET
+    @Path("/basicData/starDate/{starDate}/endDate/{endDate}/line/{line}")
+    public List<Map<String, Object>> basicData(@PathParam("starDate") String starDate,
+    		@PathParam("endDate") String endDate,@PathParam("line") String line) {
+    	String sql="select gsdm,fgsdm,xl,xl_name,date,jhbc,sjbc,"
+    			+ " jhyylc,sjyylc,jhkslc,sjkslc,jhgfbcsz,sjgfbcs,jhdgbcsz,"
+    			+ " sjdgbcs from bsth_c_calc_count  "
+    			+ " where date>='"+starDate+"' and date<= '"+endDate+"'";
+    	if(!line.equals("all")){
+    		sql +=" and xl='"+line+"'";	
+    	}	
+    	List<Map<String, Object>> list=jdbcTemplate.query(sql,
+				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("fgsdm",rs.getString("fgsdm"));
+						m.put("lineCode",rs.getString("xl"));
+						m.put("lineName", rs.getString("xl_name"));
+						m.put("date",  rs.getString("date"));
+						m.put("jhbc", rs.getString("jhbc"));
+						m.put("sjbc", rs.getString("sjbc"));
+						m.put("jhyylc", rs.getString("jhyylc"));
+						m.put("sjyylc", rs.getString("sjyylc"));
+						m.put("jhkslc", rs.getString("jhkslc"));
+						m.put("sjkslc", rs.getString("sjkslc"));
+						m.put("jhgfbcs", rs.getString("jhgfbcsz"));
+						m.put("sjgfbcs", rs.getString("sjgfbcs"));
+						m.put("jhdgbcs", rs.getString("jhdgbcsz"));
+						m.put("sjdgbcs", rs.getString("sjdgbcs"));
+						return m;
+					}
+				}); 
+    	return list;
+    }
+    
+    @GET
+    @Path("/targetData/starDate/{starDate}/endDate/{endDate}/line/{line}")
+    public List<Map<String, Object>> targetData(@PathParam("starDate") String starDate,
+    		@PathParam("endDate") String endDate,@PathParam("line") String line) {
+    	String sql="select gsdm,fgsdm,date,xl,xl_name,szfczdl,smbfczdl,"
+    			+ " round(if(ifnull(sjcczgf/jhcczgf,0)>1,1,ifnull(sjcczgf/jhcczgf,0)),3) * 100 as zgfccl , "
+    			+ " round(if(ifnull(sjcc/jhcc,0)>1,1,ifnull(sjcc/jhcc,0)),3) * 100 as ccl from bsth_c_calc_sheet  "
+    			+ " where date>='"+starDate+"' and date<= '"+endDate+"'";
+    	if(!line.equals("all")){
+    		sql +=" and xl='"+line+"'";
+    	}	
+    	List<Map<String, Object>> list=jdbcTemplate.query(sql,
+				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("fgsdm",rs.getString("fgsdm"));
+						m.put("lineCode",rs.getString("xl"));
+						m.put("lineName", rs.getString("xl_name"));
+						m.put("date",  rs.getString("date"));
+						m.put("szfczdl", rs.getString("szfczdl"));
+						m.put("smbfczdl", rs.getString("smbfczdl"));
+						m.put("zgfccl", rs.getString("zgfccl"));
+						m.put("ccl", rs.getString("ccl"));
+						return m;
+					}
+				});
+    	return list;
+    }
+    
 }