到离站查询优化

娄高锋
1 parent 31c8db92
Showing 1 changed file with 35 additions and 9 deletions
src/main/java/com/bsth/service/report/impl/ReportServiceImpl.java
@@ -253,6 +253,7 @@ public class ReportServiceImpl implements ReportService{
  
  
 	public List<ArrivalInfo> load2(String line,Long date1,Long date2,Date dates1,Date dates2,String zd,String zdlx,String fcsj){
+		SimpleDateFormat yearFormat = new SimpleDateFormat("yyyy");
 		List<ArrivalInfo> list = new ArrayList<ArrivalInfo>();
 		Calendar cal = Calendar.getInstance();
 		cal.setTime(dates1);
@@ -264,18 +265,43 @@ public class ReportServiceImpl implements ReportService{
 		PreparedStatement ps = null;
 		ResultSet rs = null;
 		String year=fcsj.substring(0,4);
-		String sql = "select * from bsth_c_arrival_info_"+year+" where line_id=? AND weeks_year>=? "
-				+ " AND weeks_year<=? AND ts > ? AND ts <=? AND up_down=? AND stop_no like ? order by ts";
+		
+		String year1 = yearFormat.format(dates1);
+		String year2 = yearFormat.format(dates2);
+		List<Integer> weeksList = new ArrayList<Integer>();
+		if(year1.equals(year2)){
+			//把每一周的编号加入list，一年最多五十几周。最多循环60次避免意外死循环
+			for(int w = 0, weeks_num = weeks_year1; w < 60 && weeks_num <= weeks_year2; w++, weeks_num++){
+				weeksList.add(weeks_num);
+			}
+		} else {
+			weeksList.add(weeks_year1);
+			weeksList.add(weeks_year2);
+		}
+		
+		String tempStr = "";
+		for(int i = 0; i < weeksList.size(); i++){
+			tempStr += "?,";
+		}
+		if(tempStr.length() > 0){
+			tempStr = tempStr.substring(0, tempStr.length() - 1);
+		}
+		
+		String sql = "select * from bsth_c_arrival_info_"+year+" where weeks_year in ("+tempStr+") "
+				+ " AND line_id=? AND up_down=? AND stop_no like ? AND ts between ? AND ? order by ts";
+		System.out.println(sql);
 		try{
 			conn = DBUtils_MS.getConnection();
 			ps = conn.prepareStatement(sql);
-			ps.setString(1, line);
-			ps.setInt(2, weeks_year1);
-			ps.setInt(3, weeks_year2);
-			ps.setLong(4, date1);
-			ps.setLong(5, date2);
-			ps.setString(6, zdlx);
-			ps.setString(7, "%"+zd+"%");
+			int no = 1;
+			for(;no <= weeksList.size(); no++){
+				ps.setInt(no, weeksList.get(no-1));
+			}
+			ps.setString(no++, line);
+			ps.setString(no++, zdlx);
+			ps.setString(no++, ""+zd+"%");
+			ps.setLong(no++, date1);
+			ps.setLong(no++, date2);
 			rs = ps.executeQuery();
  
 			list = resultSet2Set(rs);