test cloud data

modules/mogo-module-common/src/main/java/com/mogo/module/common/drawer/SnapshotSetDataDrawer.java

@@ -180,7 +180,7 @@ public class SnapshotSetDataDrawer extends BaseDrawer implements IMogoMarkerClic
                 newDiffSet.add(cloudRoadData);
             }
         }
-        removeUselessMarker(mMarkersCaches);
+        delayRemoveUselessMarker();
         removeUselessLastRecord();
         // 需要新增的 marker 数量
         int newDiffSetSize = newDiffSet.size();
@@ -198,9 +198,8 @@ public class SnapshotSetDataDrawer extends BaseDrawer implements IMogoMarkerClic
                 renderSnapshotOneFrame(marker, uniqueKey, cloudRoadData, newMarkersCaches);
             }
         }
-        sendMessage(MSG_REMOVE_DIRTY_MARKERS, mMarkersCaches);
-        mMarkersCaches.clear();
-        mMarkersCaches = newMarkersCaches;
+//        sendMessage(MSG_REMOVE_DIRTY_MARKERS, mMarkersCaches);
+        mMarkersCaches.putAll(newMarkersCaches);
     }
 
     /**
@@ -224,6 +223,31 @@ public class SnapshotSetDataDrawer extends BaseDrawer implements IMogoMarkerClic
         }
     }
 
+    private void delayRemoveUselessMarker() {
+        if (mMarkersCaches.isEmpty()) {
+            return;
+        }
+        IMogoADASController adasControllerApi = MogoApisHandler.getInstance().getApis().getAdasControllerApi();
+        if (TextUtils.isEmpty(adasControllerApi.getSatelliteTime())) {
+            return;
+        }
+        Iterator<IMogoMarker> iterator = mMarkersCaches.values().iterator();
+        while (iterator.hasNext()) {
+            IMogoMarker result = iterator.next();
+            SocketDownData.CloudRoadDataProto proto = ((SocketDownData.CloudRoadDataProto) result.getObject());
+            long internal = Long.parseLong(adasControllerApi.getSatelliteTime()) - proto.getSatelliteTime();
+            Log.d("EmArrow", "delayRemoveUselessMarker  uuid : " + proto.getUuid()
+                    + "  adasTime :  " + adasControllerApi.getSatelliteTime()
+                    + "  protoTime : " + proto.getSatelliteTime()
+                    + "  internal  : " + internal);
+            if (internal > 2000) {
+                iterator.remove();
+                result.remove();
+                result.destroy();
+            }
+        }
+    }
+
     private void removeUselessLastRecord() {  // todo 最好重新设计一个数据结构，用于多线程数据过期失效的场景，参见redis数据过期
         if (mLastPositions.isEmpty()) {
             return;
@@ -236,7 +260,7 @@ public class SnapshotSetDataDrawer extends BaseDrawer implements IMogoMarkerClic
         Log.d("EmArrow", "removeUselessLastRecord size : " + mLastPositions.size());
         while (iterator.hasNext()) {
             SocketDownData.CloudRoadDataProto result = iterator.next();
-            long internal = result.getSatelliteTime() - Long.parseLong(adasControllerApi.getSatelliteTime());
+            long internal = Long.parseLong(adasControllerApi.getSatelliteTime()) - result.getSatelliteTime();
             if (internal > 3000) {
                 iterator.remove();
             }