From 1e47c7f05c83c82b3964b0a728bd83a494def416 Mon Sep 17 00:00:00 2001
From: xinfengkun <xinfengkun@zhidaoauto.com>
Date: Mon, 4 Mar 2024 16:05:59 +0800
Subject: [PATCH] =?UTF-8?q?[630][adas]=20=E6=B7=BB=E5=8A=A0=E5=9F=9F?=
 =?UTF-8?q?=E6=8E=A7SSM=E6=8E=A5=E5=8F=A3=E6=8E=A5=E6=94=B6=E8=B6=85?=
 =?UTF-8?q?=E6=97=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/mogo/och/bus/presenter/BusPresenter.java     |  3 +++
 .../api/autopilot/IMoGoAutopilotStatusListener.kt    |  7 +++++++
 .../CallerAutoPilotStatusListenerManager.kt          | 12 ++++++++++++
 3 files changed, 22 insertions(+)

diff --git a/OCH/bus/driver/src/main/java/com/mogo/och/bus/presenter/BusPresenter.java b/OCH/bus/driver/src/main/java/com/mogo/och/bus/presenter/BusPresenter.java
index a61923fc25..d10137f79c 100644
--- a/OCH/bus/driver/src/main/java/com/mogo/och/bus/presenter/BusPresenter.java
+++ b/OCH/bus/driver/src/main/java/com/mogo/och/bus/presenter/BusPresenter.java
@@ -298,4 +298,7 @@ public class BusPresenter extends Presenter<BusFragment>
     public void onAutopilotDockerInfo(@NonNull String dockerVersion) {
     }
 
+    @Override
+    public void onSsmReceiveTimeout(boolean isTimeout) {
+    }
 }
diff --git a/core/mogo-core-function-api/src/main/java/com/mogo/eagle/core/function/api/autopilot/IMoGoAutopilotStatusListener.kt b/core/mogo-core-function-api/src/main/java/com/mogo/eagle/core/function/api/autopilot/IMoGoAutopilotStatusListener.kt
index c8995f3d7f..1906b51a45 100644
--- a/core/mogo-core-function-api/src/main/java/com/mogo/eagle/core/function/api/autopilot/IMoGoAutopilotStatusListener.kt
+++ b/core/mogo-core-function-api/src/main/java/com/mogo/eagle/core/function/api/autopilot/IMoGoAutopilotStatusListener.kt
@@ -48,6 +48,13 @@ interface IMoGoAutopilotStatusListener {
      */
     fun onAutopilotIpcConnectStatusChanged(status: AdasConstants.IpcConnectionStatus, reason: String?) {}
 
+    /**
+     * 域控SSM接口接收超时
+     * 状态变动时才会回调，默认SSM状态正常
+     * @param isTimeout true：SSM接口接收超时  false：SSM接口恢复正常
+     */
+    fun onSsmReceiveTimeout(isTimeout: Boolean) {}
+
     /**
      * 工控机主动查询 AdasManager#sendStatusQueryReq()，后会收到如下回调
      */
diff --git a/core/mogo-core-function-call/src/main/java/com/mogo/eagle/core/function/call/autopilot/CallerAutoPilotStatusListenerManager.kt b/core/mogo-core-function-call/src/main/java/com/mogo/eagle/core/function/call/autopilot/CallerAutoPilotStatusListenerManager.kt
index aa8ecc24aa..1b982b7bb5 100644
--- a/core/mogo-core-function-call/src/main/java/com/mogo/eagle/core/function/call/autopilot/CallerAutoPilotStatusListenerManager.kt
+++ b/core/mogo-core-function-call/src/main/java/com/mogo/eagle/core/function/call/autopilot/CallerAutoPilotStatusListenerManager.kt
@@ -214,6 +214,18 @@ object CallerAutoPilotStatusListenerManager : CallerBase<IMoGoAutopilotStatusLis
         }
     }
 
+    /**
+     * 域控SSM接口接收超时
+     * 状态变动时才会回调，默认SSM状态正常
+     * @param isTimeout true：SSM接口接收超时  false：SSM接口恢复正常
+     */
+    fun invokeSsmReceiveTimeout(isTimeout: Boolean) {
+        M_LISTENERS.forEach {
+            val listener = it.value
+            listener.onSsmReceiveTimeout(isTimeout)
+        }
+    }
+
     /**
      * 主动调查询接口：AdasManager#sendStatusQueryReq(), 会收到以下回调
      */