新加指标接口

廖磊
1 parent fe97ad3d
Showing 1 changed file with 59 additions and 2 deletions
src/main/java/com/bsth/server_rs/bigdata/BigdateService.java
@@ -1044,7 +1044,7 @@ public class BigdateService {
     		@PathParam("date") String date) {
     	String sql="select t.company as gs_code,t.date,SUM(t.jhcczgf) as jhccs ,SUM(t.sjcczgf) as ccs,AVG(ccl) as ccl"
     			+ " ,SUM(t.sjzgl*1000)/1000 as sum_mileage ,SUM(jcgl*1000)/1000 as airpor_mileage "
-    			+ " from (select a.line_code,a.b.date,a.company,b.jhcczgf,b.sjcczgf,"
+    			+ " from (select a.line_code,b.date,a.company,b.jhcczgf,b.sjcczgf,"
     			+ " round(if(ifnull(b.sjcczgf/b.jhcczgf,0)>1,1,ifnull(b.sjcczgf/b.jhcczgf,0)),3) as ccl,c.sjzgl ,"
     			+ " ifnull(d.sjzgl,0) as jcgl from bsth_c_line  a LEFT JOIN "
     			+ " (SELECT * from bsth_c_calc_sheet where date='"+date+"') b on a.line_code=b.xl"
@@ -1076,5 +1076,62 @@ public class BigdateService {
 				});
     	return list;
     }
-   
+    @GET
+    @Path("/findTarget/gs/{gs}/fgs/{fgs}/date/{date}")
+    public List<Map<String, Object>> findTarget(@PathParam("gs") String gs,@PathParam("fgs")  String fgs,
+    		@PathParam("date") String date) {
+		 String sql="";
+		 if(fgs.equals("all")){
+			 sql ="select x.gsdm,'' as fgsdm,x.smb_zdl,x.zgf_ccl,y.yylc_zxl,y.szfc_zdl,y.bc_zxl from ("
+		 		+ "  select b.gsdm,round(avg(if(ifnull(b.sjcczgf/b.jhcczgf,0)>1,1,ifnull(b.sjcczgf/b.jhcczgf,0))),3)as zgf_ccl,"
+		 		+ "  round(avg(ifnull(b.smbfczdl,0)),3) as smb_zdl from "
+		 		+ "  bsth_c_calc_sheet  b where b.date like '%"+date+"%' "
+		 		+ "  and b.xl in(select a.line_code from bsth_c_line a where "
+		 		+ "  a.nature in ('yxl','cgxl','gjxl','csbs','cctxl') ) group by b.gsdm ) x "
+		 		+ "  left join (select c.gsdm,round(avg(if(CONVERT(c.yylczxl,DECIMAL(9,2))>100,100,c.yylczxl)),3) as yylc_zxl,"
+		 		+ "  round(avg(if(CONVERT(c.szfczdl,DECIMAL(9,2))>100,100,c.szfczdl)),3) as szfc_zdl,"
+		 		+ "  round(avg(if(CONVERT(c.bczxl,DECIMAL(9,2))>100,100,c.bczxl)),3) as bc_zxl "
+		 		+ "  from bsth_c_calc_count  c  where c.date like '%"+date+"%' and "
+		 		+ "  c.xl in(select a.line_code from bsth_c_line a where a.nature in ('yxl','cgxl','gjxl','csbs','cctxl') ) "
+		 		+ "  group by c.gsdm ) y on x.gsdm=y.gsdm  where 1=1 ";
+				 
+		 }else{
+			 sql ="select x.gsdm,x.fgsdm,x.smb_zdl,x.zgf_ccl,y.yylc_zxl,y.szfc_zdl,y.bc_zxl from ("
+		 		+ "  select b.gsdm,b.fgsdm,round(avg(if(ifnull(b.sjcczgf/b.jhcczgf,0)>1,1,ifnull(b.sjcczgf/b.jhcczgf,0))),3)as zgf_ccl,"
+		 		+ "  round(avg(ifnull(b.smbfczdl,0)),3) as smb_zdl from "
+		 		+ "  bsth_c_calc_sheet  b where b.date like '%"+date+"%' "
+		 		+ "  and b.xl in(select a.line_code from bsth_c_line a where "
+		 		+ "  a.nature in ('yxl','cgxl','gjxl','csbs','cctxl') ) group by b.gsdm,b.fgsdm ) x "
+		 		+ "  left join (select c.gsdm,c.fgsdm,round(avg(if(CONVERT(c.yylczxl,DECIMAL(9,2))>100,100,c.yylczxl)),3) as yylc_zxl,"
+		 		+ "  round(avg(if(CONVERT(c.szfczdl,DECIMAL(9,2))>100,100,c.szfczdl)),3) as szfc_zdl,"
+		 		+ "  round(avg(if(CONVERT(c.bczxl,DECIMAL(9,2))>100,100,c.bczxl)),3) as bc_zxl "
+		 		+ "  from bsth_c_calc_count  c  where c.date like '%"+date+"%' and "
+		 		+ "  c.xl in(select a.line_code from bsth_c_line a where a.nature in ('yxl','cgxl','gjxl','csbs','cctxl') ) "
+		 		+ "  group by c.gsdm,c.fgsdm ) y on x.gsdm=y.gsdm and x.fgsdm=y.fgsdm where 1=1 ";
+				  
+		 }
+		 if(!gs.equals("all")){
+			   sql += " and x.gsdm='"+gs+"'"; 
+		 }
+		   
+		 if(!fgs.equals("all")){
+			   sql += " and x.fgsdm='"+fgs+"'";
+		 }
+		 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", getGs(rs.getString("gsdm")));
+							m.put("fgsdm",rs.getString("fgsdm"));
+							m.put("smb_zdl", rs.getString("smb_zdl"));
+							m.put("zgf_ccl",  rs.getString("zgf_ccl"));
+							m.put("yylc_zxl", rs.getString("yylc_zxl"));
+							m.put("szfc_zdl", rs.getString("szfc_zdl"));
+							m.put("bc_zxl", rs.getString("bc_zxl"));
+							return m;
+						}
+					});
+	    return list;
+    }
 }