超速、越界等异常表分区分表...

潘钊
1 parent 27a79842
Showing 1 changed file with 84 additions and 31 deletions
src/main/java/com/bsth/service/gps/GpsServiceImpl.java
@@ -188,25 +188,9 @@ public class GpsServiceImpl implements GpsService {
         String nbbm = nbbmArray[0];
  
         List<DeviceChange> dcs = findDeviceChangeLogs(nbbm, et, st);
-        //没有设备变更记录，则参考车辆信息上的设备号
-        if(null == dcs || dcs.size() == 0){
-            DeviceChange dc = new DeviceChange();
-            dc.setNbbm(nbbm);
-            dc.setDevice(BasicData.deviceId2NbbmMap.inverse().get(nbbm));
-            dc.setSt(st);
-            dc.setEt(et);
-            dc.setType(1);
-
-            dcs.add(dc);
-        }
-
-        //bsth_c_gps_info
-        String tableName = "bsth_c_gps_info";
-        String sYear = fmtyyyy.print(st),
-            currYear = fmtyyyy.print(System.currentTimeMillis());
  
-        if(!sYear.equals(currYear))
-            tableName += "_" + sYear;
+        //按年分表
+        String tableName = "bsth_c_gps_info_" + fmtyyyy.print(st);
  
         StringBuilder sql = new StringBuilder("");
         long t1,t2;
@@ -365,6 +349,18 @@ public class GpsServiceImpl implements GpsService {
  
                 rs.add(dc);
             }
+
+            //没有设备变更记录，则参考车辆信息上的设备号
+            if(null == rs || rs.size() == 0){
+                DeviceChange dc = new DeviceChange();
+                dc.setNbbm(nbbm);
+                dc.setDevice(BasicData.deviceId2NbbmMap.inverse().get(nbbm));
+                dc.setSt(st);
+                dc.setEt(et);
+                dc.setType(1);
+
+                rs.add(dc);
+            }
         }catch (Exception e){
             logger.error("", e);
         }
@@ -887,27 +883,84 @@ public class GpsServiceImpl implements GpsService {
  
     @Override
     public List<GpsSpeed_DTO> speeds(String nbbm, long st, long et) {
-        String deviceId = BasicData.deviceId2NbbmMap.inverse().get(nbbm);
-        String sql = "select vehicle, line, up_down, lon, lat, speed,timestamp from bsth_c_speeding where vehicle=? and timestamp>? and timestamp<?";
+        st = st * 1000;
+        et = et * 1000;
+        //按周分区
+        Calendar sCal = Calendar.getInstance();
+        sCal.setTime(new Date(st));
+        int sWeekYear = sCal.get(Calendar.WEEK_OF_YEAR);
+        Calendar eCal = Calendar.getInstance();
+        eCal.setTime(new Date(et));
+        int eWeekYear = eCal.get(Calendar.WEEK_OF_YEAR);
+
+        //按年分表
+        String tableName = "bsth_c_speeding_" + fmtyyyy.print(st);
+
+        List<DeviceChange> dcs = findDeviceChangeLogs(nbbm, et, st);
+        StringBuilder sql = new StringBuilder("");
+        long t1,t2;
+        DeviceChange dc;
+        for(int i = 0,len=dcs.size(); i < len; i++){
+            t1 = st;
+            t2 = et;
+            dc = dcs.get(i);
+            if(dc.getSt() > st)
+                t1 = dc.getSt();
+            if(dc.getEt() < et && dc.getEt()!=0)
+                t2 = dc.getEt();
+
+            sql.append(" select vehicle, line, up_down, lon, lat, speed,timestamp from "+tableName+" where " +
+                    " weeks_year in ("+sWeekYear+", "+eWeekYear+") and vehicle='"+dc.getDevice()+"' and timestamp>"+t1+" and timestamp< " + t2);
+
+            if(i == len - 1)
+                sql.append(" ORDER BY vehicle,timestamp");
+            else
+                sql.append(" UNION ");
+        }
  
-        return GpsSpeed_DTO.create(new JdbcTemplate(DBUtils_MS.getDataSource()).queryForList(sql, deviceId, st * 1000, et * 1000));
+        logger.info("speed sql : " + sql.toString());
+        return GpsSpeed_DTO.create(new JdbcTemplate(DBUtils_MS.getDataSource()).queryForList(sql.toString()));
     }
  
     @Override
     public List<GpsOutbound_DTO> outbounds(String nbbm, long st, long et) {
-        /**
-         * 如果 st 和 et 跨了周分区，也只查询st 分区的数据。
-         */
         st = st * 1000;
         et = et * 1000;
         //按周分区
-        Calendar weekCal = Calendar.getInstance();
-        weekCal.setTimeInMillis(st);
-        int weekYear = weekCal.get(Calendar.WEEK_OF_YEAR);
-        //设备号
-        String deviceId = BasicData.deviceId2NbbmMap.inverse().get(nbbm);
-        String sql = "select vehicle,line,up_down,lon,lat,timestamp from bsth_c_outbound where weeks_year=" + weekYear + " and vehicle=? and timestamp>? and timestamp<?";
-        return GpsOutbound_DTO.create(new JdbcTemplate(DBUtils_MS.getDataSource()).queryForList(sql, deviceId, st, et));
+        Calendar sCal = Calendar.getInstance();
+        sCal.setTime(new Date(st));
+        int sWeekYear = sCal.get(Calendar.WEEK_OF_YEAR);
+        Calendar eCal = Calendar.getInstance();
+        eCal.setTime(new Date(et));
+        int eWeekYear = eCal.get(Calendar.WEEK_OF_YEAR);
+
+        //按年分表
+        String tableName = "bsth_c_outbound_" + fmtyyyy.print(st);
+
+        List<DeviceChange> dcs = findDeviceChangeLogs(nbbm, et, st);
+        StringBuilder sql = new StringBuilder("");
+        long t1,t2;
+        DeviceChange dc;
+        for(int i = 0,len=dcs.size(); i < len; i++){
+            t1 = st;
+            t2 = et;
+            dc = dcs.get(i);
+            if(dc.getSt() > st)
+                t1 = dc.getSt();
+            if(dc.getEt() < et && dc.getEt()!=0)
+                t2 = dc.getEt();
+
+            sql.append("select vehicle,line,up_down,lon,lat,timestamp from "+tableName+" where " +
+                    " weeks_year in ("+sWeekYear+", "+eWeekYear+") and vehicle='"+dc.getDevice()+"' and timestamp>"+t1+" and timestamp<" + t2);
+
+            if(i == len - 1)
+                sql.append(" ORDER BY vehicle,timestamp");
+            else
+                sql.append(" UNION ");
+        }
+
+        logger.info("outbounds sql : " + sql.toString());
+        return GpsOutbound_DTO.create(new JdbcTemplate(DBUtils_MS.getDataSource()).queryForList(sql.toString()));
     }
  
     @Override