行车时刻表统计表

娄高锋
1 parent aec65783
Showing 1 changed file with 84 additions and 170 deletions
src/main/java/com/bsth/service/report/impl/ReportServiceImpl.java
@@ -324,37 +324,24 @@ public class ReportServiceImpl implements ReportService{
 	        }
 		return list;
 	}
+	
 	@Override
 	public Map<String, Object> tbodyTime1(String line, String ttinfo) {
 		DecimalFormat df = new DecimalFormat("#0.00");
+		Map<String, Object> map=new HashMap<String,Object>();
 		// TODO Auto-generated method stub
+		
 		//查询配车
-		String sqlPc="  select count(*) from bsth_c_cars where id in("
-				+ " select cl from bsth_c_s_ccinfo where  xl in ( "
-				+ " select id from bsth_c_line where line_code='"+line+"' )"
-				+ " group by equipment_code ) ";
-
-		Map<String, Object> map=new HashMap<String,Object>();
-
-		/*List<Map<String, Object>> listPc= jdbcTemplate.query(sqlPc,
-				 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("zbh", rs.getString("cl_zbh"));
-				 return m;
-			 }
-		});*/
+		String sqlPc=" select count(*) from (select lp, count(*) from"
+				+ " bsth_c_s_ttinfo_detail where ttinfo ='"+ttinfo+"'"
+				+ " group by lp ) a";
 		//配车
 		int pcs=jdbcTemplate.queryForObject(sqlPc, Integer.class);
+		
 		String sqlPlan=" SELECT jhlc,bc_type,fcsj FROM bsth_c_s_ttinfo_detail "
 				+" where ttinfo ='"+ttinfo+"' ";
-		//班次
-		int zgf_0 = 6*60+31,zgf_1 = 8*60+30,wgf_0 = 16*60+1,wgf_1 = 18*60;
-		int qcBc=0,qjBc=0,zqcBc=0,zqjBc=0,wqcBc=0,wqjBc=0;
-		double zlc = 0 , yylc = 0,kslc=0;
 		//查询班次
 		List<Map<String, Object>> listPlan= jdbcTemplate.query(sqlPlan,
 				new RowMapper<Map<String, Object>>(){
@@ -368,6 +355,11 @@ public class ReportServiceImpl implements ReportService{
 					}
 				});
+		//班次
+		int zgf_0 = 6*60+31,zgf_1 = 8*60+30,wgf_0 = 16*60+1,wgf_1 = 18*60;
+		int qcBc=0,qjBc=0,zqcBc=0,zqjBc=0,wqcBc=0,wqjBc=0;
+		double zlc = 0 , yylc = 0,kslc=0;
+		
 		for (int i = 0; i < listPlan.size(); i++) {
 			Map<String, Object> m=listPlan.get(i);
 			double jhlc=Double.parseDouble(m.get("jhlc").toString());
@@ -423,21 +415,23 @@ public class ReportServiceImpl implements ReportService{
 		String minfcsj="02:00";
         List<Line> lineList=lineRepository.findLineByCode(line);
         if(lineList.size()>0){
-	        String sqlMinYysj="select start_opt from bsth_c_line_config where "
-	         		+ " id = ("
-	         		+ "select max(id) from bsth_c_line_config where line ='"+lineList.get(0).getId() +"'"
-	         		+ ")";
-	        minfcsj=jdbcTemplate.queryForObject(sqlMinYysj, String.class);
+        	String sql = "select count(*) from bsth_c_line_config where line = '"+lineList.get(0).getId()+"'";
+        	if(jdbcTemplate.queryForObject(sql, Integer.class) > 0){
+		        String sqlMinYysj="select start_opt from bsth_c_line_config where "
+		         		+ " id = ("
+		         		+ "select max(id) from bsth_c_line_config where line ='"+lineList.get(0).getId() +"'"
+		         		+ ")";
+		        minfcsj=jdbcTemplate.queryForObject(sqlMinYysj, String.class);
+        	}
         }
 		String[] minSjs = minfcsj.split(":");
 		int minSj=Integer.parseInt(minSjs[0])*60+Integer.parseInt(minSjs[1]);
 		//查询时间里程
-		String sqlPc=" (SELECT jhlc,fcsj,bc_type,lp,2 as xh, ists FROM bsth_c_s_ttinfo_detail "
+		String sqlPc=" (SELECT jhlc,fcsj,bc_type,bcsj,lp,2 as xh, ists FROM bsth_c_s_ttinfo_detail "
 				+ " where ttinfo ='"+ttinfo+"' and fcsj <='"+minfcsj+"' ) "
 				+ " union "
-				+ " (SELECT jhlc,fcsj,bc_type,lp,1 as xh, ists FROM bsth_c_s_ttinfo_detail "
-				+ " where ttinfo ='"+ttinfo+"' and fcsj > '"+minfcsj+"') order by lp,xh,fcsj";
-
+				+ " (SELECT jhlc,fcsj,bc_type,bcsj,lp,1 as xh, ists FROM bsth_c_s_ttinfo_detail "
+				+ " where ttinfo ='"+ttinfo+"' and fcsj > '"+minfcsj+"' ) order by lp,xh,fcsj";
 		Map<String, Object> map=new HashMap<String,Object>();
 		List<Map<String, Object>> list= jdbcTemplate.query(sqlPc,
 				new RowMapper<Map<String, Object>>(){
@@ -447,26 +441,31 @@ public class ReportServiceImpl implements ReportService{
 						m.put("fcsj", rs.getString("fcsj"));
 						m.put("yygl", rs.getString("jhlc")==null?"0":rs.getString("jhlc"));
 						m.put("bcType", rs.getString("bc_type"));
+						m.put("bcsj", rs.getString("bcsj"));
 						m.put("lp", rs.getString("lp"));
 						m.put("ists", rs.getObject("ists")==null?"0":rs.getString("ists"));
 						return m;
 					}
 				});
-		int yysj=0 ;
+		
+		int yysj=0;
 		double yycs=0 ,yygl=0;
 		String lp ="0";
-		int sj=0;
-
+		int sj=0, bcsj = 0;
+		int temp = 0;
 		for(int i=0;i<list.size();i++){
 			Map<String, Object> m=list.get(i);
 			String time=m.get("fcsj").toString();
 			String[] times = time.split(":");
+			int sjT = Integer.parseInt(times[0])*60+Integer.parseInt(times[1]);
 			if(lp.equals(m.get("lp").toString())){
-				if(Integer.parseInt(times[0])*60+Integer.parseInt(times[1]) <=minSj){
+				if(sjT <= minSj){
 					if(m.get("bcType").equals("in") || m.get("bcType").equals("out")){
 						if(m.get("bcType").equals("in")){
 							if(sj!=0){
-								yysj +=(Integer.parseInt(times[0])+24)*60+Integer.parseInt(times[1])-sj;
+//								yysj += sjT + (24*60) - sj;
+								yysj += bcsj;
+								bcsj = 0;
 							}
 							sj=0;
 						}
@@ -474,45 +473,62 @@ public class ReportServiceImpl implements ReportService{
 						yygl += Double.parseDouble(m.get("yygl").toString());
 						if(sj==0){
-							sj=(Integer.parseInt(times[0])+24)*60+Integer.parseInt(times[1]);
+							sj = sjT + (24*60);
 						}else{
-							yysj +=(Integer.parseInt(times[0])+24)*60+Integer.parseInt(times[1])-sj;
-							sj=(Integer.parseInt(times[0])+24)*60+Integer.parseInt(times[1]);
+							yysj += sjT + (24*60) - sj;
+							if(m.containsKey("ists") && m.get("ists").equals("1")){
+								yysj += Integer.valueOf(m.get("bcsj").toString());
+							} else {
+								sj = sjT + (24*60);
+							}
 						}
 					}
 				}else{
 					if(m.get("bcType").equals("in") || m.get("bcType").equals("out")){
 						if(m.get("bcType").equals("in")){
 							if(sj!=0){
-								yysj +=Integer.parseInt(times[0])*60+Integer.parseInt(times[1])-sj;
+//								yysj += sjT - sj;
+								yysj += bcsj;
+								bcsj = 0;
 							}
 							sj=0;
 						}
-					}else{
+					} else {
 						yygl += Double.parseDouble(m.get("yygl").toString());
 						if(sj==0){
-							sj=Integer.parseInt(times[0])*60+Integer.parseInt(times[1]);
+							sj = sjT;
 						}else{
-							yysj +=Integer.parseInt(times[0])*60+Integer.parseInt(times[1])-sj;
-							sj=Integer.parseInt(times[0])*60+Integer.parseInt(times[1]);
+							yysj += sjT - sj;
+							if(m.containsKey("ists") && m.get("ists").equals("1")){
+								yysj += Integer.valueOf(m.get("bcsj").toString());
+							} else {
+								sj = sjT;
+							}
 						}
 					}
 				}
 			}else{
+				if(sj == 0){
+					yysj += bcsj;
+					bcsj = 0;
+				}
 				if( !(m.get("bcType").equals("in") || m.get("bcType").equals("out"))){
 					yygl += Double.parseDouble(m.get("yygl").toString());
-					sj =Integer.parseInt(times[0])*60+Integer.parseInt(times[1]);
+					sj = sjT;
 				}else{
 					sj=0;
 				}
 				lp=m.get("lp").toString();
-
 			}
+			
 			if(m.containsKey("ists") && m.get("ists").equals("1")){
 				sj = 0;
 			}
+			if( !(m.get("bcType").equals("in") || m.get("bcType").equals("out")))
+				bcsj = Integer.valueOf(m.get("bcsj").toString());
 		}
+		
 		if(yysj>0){
 			yycs =yygl/(yysj*1.0/60);
 		}
@@ -522,6 +538,7 @@ public class ReportServiceImpl implements ReportService{
 		map.put("yysj", hh+":"+mm);
 		map.put("yycs", df.format(yycs)+"公里/小时");
 //		map.put(key, value)
+		
 		return map;
 	}
@@ -529,126 +546,15 @@ public class ReportServiceImpl implements ReportService{
 		System.out.println(609360/60);
 		System.out.println(609360%60);
 	}
-	/*	@Override
-        public List<Map<String, Object>> tbodyTime3(String line, String ttinfo) {
-            // TODO Auto-generated method stub
-            List<Map<String, Object>> list=new ArrayList<Map<String,Object>>();
-
-
-
-            String sqlZd="select a.qdz_name,COUNT(a.cl_zbh)  as cls,'zqc' AS lx from ("
-                    + " select cl_zbh,qdz_name from bsth_c_s_sp_info where tt_info ='"+ttinfo+"' "
-                    + " and bc_type ='normal'"
-                    + " and ((fcsj >'06:31' and fcsj<'08:30')  or ( fcsj>'6:31' and fcsj<'8:30'))"
-                    + " group by cl_zbh,qdz_name) a group by a.qdz_name"
-                    + " union "
-                    + " select a.qdz_name,COUNT(a.cl_zbh)  as cls,'wqc' AS lx from ("
-                    + " select cl_zbh,qdz_name from bsth_c_s_sp_info where tt_info ='"+ttinfo+"'"
-                    + " and bc_type ='normal' "
-                    + " and fcsj >'16:01' and fcsj<'18:00' group by cl_zbh,qdz_name "
-                    + " ) a group by a.qdz_name "
-                    + " union "
-                    + " select a.qdz_name,COUNT(a.cl_zbh)  as cls,'zqj' AS lx from ("
-                    + " select cl_zbh,qdz_name from bsth_c_s_sp_info where tt_info ='"+ttinfo+"'"
-                    + " and bc_type ='region' "
-                    + " and ((fcsj >'06:31' and fcsj<'08:30')  or ( fcsj>'6:31' and fcsj<'8:30'))"
-                    + " group by cl_zbh,qdz_name) a group by a.qdz_name"
-                    + " union "
-                    + " select a.qdz_name,COUNT(a.cl_zbh)  as cls,'wqj' AS lx from ("
-                    + " select cl_zbh,qdz_name from bsth_c_s_sp_info where tt_info ='"+ttinfo+"'"
-                    + " and bc_type ='region' and fcsj >'16:01' and fcsj<'18:00'"
-                    + " group by cl_zbh,qdz_name) a group by a.qdz_name";
-            List<Map<String, Object>> lists= jdbcTemplate.query(sqlZd,
-                     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("zdm", rs.getString("qdz_name"));
-                     m.put("cls", rs.getString("cls"));
-                     m.put("lx", rs.getString("lx"));
-                     return m;
-                 }
-            });
-            int a=0;
-            int b=0;
-            int c=0;
-            int d=0;
-            for(int i=0;i<lists.size();i++){
-                boolean fage=true;
-                Map<String, Object> newMap= new HashMap<String, Object>();
-                list.add(newMap);
-                Map<String, Object> maps=lists.get(i);
-                if(maps.get("lx").equals("zqc")){
-                    list.get(a).put("zqcZm", maps.get("zdm"));
-                    list.get(a).put("zqcCls", maps.get("cls"));
-                    a++;
-                    fage=false;
-                }else if(maps.get("lx").equals("wqc")){
-                    list.get(b).put("wqcZm", maps.get("zdm"));
-                    list.get(b).put("wqcCls", maps.get("cls"));
-                    b++;
-                    fage=false;
-                }else if(maps.get("lx").equals("zqj")){
-                    list.get(c).put("zqjZm", maps.get("zdm"));
-                    list.get(c).put("zqjCls", maps.get("cls"));
-                    c++;
-                    fage=false;
-                }else if(maps.get("lx").equals("wqj")){
-                    list.get(d).put("wqjZm", maps.get("zdm"));
-                    list.get(d).put("wqjCls", maps.get("cls"));
-                    d++;
-                    fage=false;
-                }
-                if(fage){
-                    break;
-                }
-            }
-            boolean status=true;
-            while (status) {
-                for (int i = 0; i < list.size(); i++) {
-                    if(list.get(i).isEmpty()){
-                        list.remove(i);
-                        status=true;
-                    }else{
-                        status=false;
-                    }
-                }
-
-            }
-            return list;
-        }*/
+	
 	@Override
 	public List<Map<String, Object>> tbodyTime3(String line, String ttinfo) {
 		// TODO Auto-generated method stub
 		List<Map<String, Object>> list=new ArrayList<Map<String,Object>>();
 		List<Map<String, Object>> list_s=new ArrayList<Map<String,Object>>();
-
-		/*String sqlZd="select a.qdz_name,COUNT(a.cl_zbh)  as cls,'zqc' AS lx from ("
-				+ " select cl_zbh,qdz_name from bsth_c_s_sp_info where tt_info ='"+ttinfo+"' "
-				+ " and bc_type ='normal'"
-				+ " and ((fcsj >'06:31' and fcsj<'08:30')  or ( fcsj>'6:31' and fcsj<'8:30'))"
-				+ " group by cl_zbh,qdz_name) a group by a.qdz_name"
-				+ " union "
-				+ " select a.qdz_name,COUNT(a.cl_zbh)  as cls,'wqc' AS lx from ("
-				+ " select cl_zbh,qdz_name from bsth_c_s_sp_info where tt_info ='"+ttinfo+"'"
-				+ " and bc_type ='normal' "
-				+ " and fcsj >'16:01' and fcsj<'18:00' group by cl_zbh,qdz_name "
-				+ " ) a group by a.qdz_name "
-				+ " union "
-				+ " select a.qdz_name,COUNT(a.cl_zbh)  as cls,'zqj' AS lx from ("
-				+ " select cl_zbh,qdz_name from bsth_c_s_sp_info where tt_info ='"+ttinfo+"'"
-				+ " and bc_type ='region' "
-				+ " and ((fcsj >'06:31' and fcsj<'08:30')  or ( fcsj>'6:31' and fcsj<'8:30'))"
-				+ " group by cl_zbh,qdz_name) a group by a.qdz_name"
-				+ " union "
-				+ " select a.qdz_name,COUNT(a.cl_zbh)  as cls,'wqj' AS lx from ("
-				+ " select cl_zbh,qdz_name from bsth_c_s_sp_info where tt_info ='"+ttinfo+"'"
-				+ " and bc_type ='region' and fcsj >'16:01' and fcsj<'18:00'"
-				+ " group by cl_zbh,qdz_name) a group by a.qdz_name";*/
-
-		String sqlCl="SELECT cl_zbh,qdz_name,bc_type,fcsj,bcsj FROM"
-				+ "  bsth_c_s_sp_info WHERE tt_info = '"+ttinfo+"' "
+		String sqlCl="SELECT lp cl_zbh,qdz_name,bc_type,fcsj,bcsj FROM"
+				+ "  bsth_c_s_ttinfo_detail WHERE ttinfo = '"+ttinfo+"' "
 				+ " AND  (bc_type = 'normal' or bc_type='region') order by qdz_name";
 		List<Map<String, Object>> listj= jdbcTemplate.query(sqlCl,
@@ -665,7 +571,7 @@ public class ReportServiceImpl implements ReportService{
 					}
 				});
-		String sqlZd="select qdz_name ,bc_type from  bsth_c_s_sp_info WHERE tt_info = '"+ttinfo+"' "
+		String sqlZd="select qdz_name,bc_type from bsth_c_s_ttinfo_detail WHERE ttinfo = '"+ttinfo+"' "
 				+ " AND (bc_type = 'normal' or bc_type='region') group by qdz_name ,bc_type "
 				+ " order by qdz_name";
 		List<Map<String, Object>> lists= jdbcTemplate.query(sqlZd,
@@ -807,6 +713,8 @@ public class ReportServiceImpl implements ReportService{
 		}
 		boolean status=true;
 		while (status) {
+			if(list.size() == 0)
+				break;
 			for (int i = 0; i < list.size(); i++) {
 				if(list.get(i).isEmpty()){
 					list.remove(i);
@@ -815,8 +723,8 @@ public class ReportServiceImpl implements ReportService{
 					status=false;
 				}
 			}
-
 		}
+		
 		return list;
 	}
@@ -828,11 +736,14 @@ public class ReportServiceImpl implements ReportService{
 		String minfcsj="02:00";
         List<Line> lineList=lineRepository.findLineByCode(line);
         if(lineList.size()>0){
-	        String sqlMinYysj="select start_opt from bsth_c_line_config where "
-	         		+ " id = ("
-	         		+ "select max(id) from bsth_c_line_config where line ='"+lineList.get(0).getId() +"'"
-	         		+ ")";
-	        minfcsj=jdbcTemplate.queryForObject(sqlMinYysj, String.class);
+        	String sql = "select count(*) from bsth_c_line_config where line = '"+lineList.get(0).getId()+"'";
+        	if(jdbcTemplate.queryForObject(sql, Integer.class) > 0){
+		        String sqlMinYysj="select start_opt from bsth_c_line_config where "
+		         		+ " id = ("
+		         		+ "select max(id) from bsth_c_line_config where line ='"+lineList.get(0).getId() +"'"
+		         		+ ")";
+		        minfcsj=jdbcTemplate.queryForObject(sqlMinYysj, String.class);
+        	}
         }
 		//查询全程
@@ -917,11 +828,14 @@ public class ReportServiceImpl implements ReportService{
 		String minfcsj="02:00";
         List<Line> lineList=lineRepository.findLineByCode(line);
         if(lineList.size()>0){
-	        String sqlMinYysj="select start_opt from bsth_c_line_config where "
-	         		+ " id = ("
-	         		+ "select max(id) from bsth_c_line_config where line ='"+lineList.get(0).getId() +"'"
-	         		+ ")";
-	        minfcsj= jdbcTemplate.queryForObject(sqlMinYysj, String.class);
+        	String sql = "select count(*) from bsth_c_line_config where line = '"+lineList.get(0).getId()+"'";
+        	if(jdbcTemplate.queryForObject(sql, Integer.class) > 0){
+		        String sqlMinYysj="select start_opt from bsth_c_line_config where "
+		         		+ " id = ("
+		         		+ "select max(id) from bsth_c_line_config where line ='"+lineList.get(0).getId() +"'"
+		         		+ ")";
+		        minfcsj= jdbcTemplate.queryForObject(sqlMinYysj, String.class);
+        	}
         }
 		String[] minSjs = minfcsj.split(":");
 		int minSj=Integer.parseInt(minSjs[0])*60+Integer.parseInt(minSjs[1]);