update...

潘钊
1 parent 80fc0669
Showing 1 changed file with 23 additions and 25 deletions
src/main/java/com/bsth/data/gpsdata_v2/DataHandleProcess.java
@@ -129,36 +129,34 @@ public class DataHandleProcess {
  
         @Override
         public void run() {
-            //try {
-            Collections.sort(list, comp);
-            for (GpsEntity gps : list) {
-                try {
-                    if(StringUtils.isEmpty(gps.getNbbm()))
-                        continue;
-                    if (Math.abs(gps.getTimestamp() - gps.getServerTimestamp()) > 1000 * 60 * 20)
-                        continue;
-
-                    gpsStateProcess.process(gps);//状态处理
-                    stationInsideProcess.process(gps);//场站内外判定
-                    reverseRouteProcess.process(gps);//反向路由处理
-                    abnormalStateProcess.process(gps);//超速越界
-
-                    inStationProcess.process(gps);//进站
-                    outStationProcess.process(gps);//出站
-
-                    GpsCacheData.putGps(gps);//历史gps缓存
-                } catch (Exception e) {
-                    logger.error("", e);
+            try {
+                Collections.sort(list, comp);
+                for (GpsEntity gps : list) {
+                    try {
+                        if (StringUtils.isEmpty(gps.getNbbm()))
+                            continue;
+                        if (Math.abs(gps.getTimestamp() - gps.getServerTimestamp()) > 1000 * 60 * 20)
+                            continue;
+
+                        gpsStateProcess.process(gps);//状态处理
+                        stationInsideProcess.process(gps);//场站内外判定
+                        reverseRouteProcess.process(gps);//反向路由处理
+                        abnormalStateProcess.process(gps);//超速越界
+
+                        inStationProcess.process(gps);//进站
+                        outStationProcess.process(gps);//出站
+
+                        GpsCacheData.putGps(gps);//历史gps缓存
+                    } catch (Exception e) {
+                        logger.error("", e);
+                    }
                 }
-            }
  
-            logger.info(Thread.currentThread().getName() + " -countDown : " + count.getCount());
-            count.countDown();
-            /*} finally {
+            } finally {
                 if (count != null)
                     count.countDown();
                 logger.info(Thread.currentThread().getName() + " -countDown : " + count.getCount());
-            }*/
+            }
         }
     }