[V2X][Road]添加所有marker清空监听回调；解决相关bug

core/function-impl/mogo-core-function-v2x/src/main/java/com/mogo/eagle/core/function/v2x/events/scenario/impl/V2XScenarioManager.java

@@ -63,7 +63,6 @@ public class V2XScenarioManager implements IV2XScenarioManager {
                         Intent intent = new Intent(V2XConst.BROADCAST_SCENE_ACTION);
                         intent.putExtra(V2XConst.BROADCAST_SCENE_EXTRA_KEY, v2XMessageEntity);
                         LocalBroadcastManager.getInstance(Utils.getApp()).sendBroadcast(intent);
-                        AiRoadMarker.INSTANCE.clear();
                         // 如果没有拿到之前的，根据类型分发
                         switch (v2XMessageEntity.getType()) {
                             case V2XMessageEntity.V2XTypeEnum.ALERT_ROAD_WARNING:

core/function-impl/mogo-core-function-v2x/src/main/java/com/mogo/eagle/core/function/v2x/events/scenario/scene/airoad/AiRoadMarker.kt

@@ -13,8 +13,10 @@ import androidx.lifecycle.Lifecycle.Event.ON_DESTROY
 import com.mogo.eagle.core.data.map.*
 import com.mogo.eagle.core.data.map.MapRoadInfo.StopLine
 import com.mogo.eagle.core.function.api.map.listener.*
+import com.mogo.eagle.core.function.api.v2x.*
 import com.mogo.eagle.core.function.call.map.*
 import com.mogo.eagle.core.function.call.map.CallerMapRoadListenerManager.OnRoadListener
+import com.mogo.eagle.core.function.call.v2x.*
 import com.mogo.eagle.core.function.v2x.events.scenario.scene.road.*
 import com.mogo.eagle.core.utilcode.kotlin.*
 import com.mogo.eagle.core.utilcode.mogo.logger.*
@@ -62,6 +64,23 @@ object AiRoadMarker {
         }
     }
 
+    private val onClearAllMarker = object : OnClearAllMarker  {
+
+        override fun onClearAllMarkers() {
+            val marker = this@AiRoadMarker.marker.get()
+            if (marker != null) {
+                unMarker(marker)
+            }
+        }
+
+        override fun onClearAllMarkers(tag: String) {
+            val marker = this@AiRoadMarker.marker.get()
+            if (marker != null) {
+                unMarker(marker)
+            }
+        }
+    }
+
     private val markers = ConcurrentSet<Marker>()
 
     private val options by lazy {
@@ -174,11 +193,13 @@ object AiRoadMarker {
 
     private fun onCreate() {
         CallerMapRoadListenerManager.registerRoadListener(TAG, onRoadListener)
+        CallMarkersClearManager.addAllMarkersClearListener(TAG, onClearAllMarker)
         CallerMapLocationListenerManager.addListener(TAG, onLocationListener, true)
     }
 
     private fun onDestroy() {
         CallerMapRoadListenerManager.unRegisterRoadListener(TAG)
+        CallMarkersClearManager.removeAllMarkersClearListener(TAG)
         CallerMapLocationListenerManager.removeListener(TAG, true)
         pool.shutdownNow()
         removeLine()
@@ -201,7 +222,15 @@ object AiRoadMarker {
     }
 
     fun marker(marker: Marker, drawMarker: Boolean) {
+        handler.removeCallbacks(checkExpiredTask)
         val location = carLocation.get() ?: return
+        if (markers.contains(marker)) {
+            Logger.d(TAG, "--- enqueue --- cache hit ---")
+            return
+        }
+        synchronized(markers) {
+            markers += marker
+        }
         this.marker.set(marker)
         //施工中心点前方的自车行驶方向上300米距离
         val l1 = MogoMap.getInstance().mogoMap.getCenterLineRangeInfo(marker.poi_lon, marker.poi_lat, location.third.toFloat(), 300f)
@@ -295,19 +324,7 @@ object AiRoadMarker {
         markers -= marker
         removeLine()
         V2XAiRoadEventMarker.removeMarkers(null)
-    }
-
-    fun clear() {
-        hideLine()
-        V2XAiRoadEventMarker.removeMarkers(null)
-    }
-
-    fun restore() {
-        showLine()
-        val marker = marker.get()
-        if (marker != null) {
-            marker(marker, false)
-        }
+        handler.removeCallbacks(checkExpiredTask)
     }
 
     private fun hideLine() {