[340][och]临时能否启动自驾判断加入连接状态判断

OCH/mogo-och-common-module/src/main/java/com/mogo/och/common/module/manager/OCHAdasAbilityManager.java

@@ -2,27 +2,36 @@ package com.mogo.och.common.module.manager;
 
 import android.content.Context;
 
+import androidx.annotation.NonNull;
 import androidx.annotation.Nullable;
 
+import com.mogo.eagle.core.data.autopilot.AutopilotStatusInfo;
 import com.mogo.eagle.core.function.api.autopilot.IMoGoAutopilotActionsListener;
 import com.mogo.eagle.core.function.api.autopilot.IMoGoAutopilotStatisticsListener;
+import com.mogo.eagle.core.function.api.autopilot.IMoGoAutopilotStatusListener;
+import com.mogo.eagle.core.function.call.autopilot.CallerAutoPilotControlManager;
+import com.mogo.eagle.core.function.call.autopilot.CallerAutoPilotStatusListenerManager;
 import com.mogo.eagle.core.function.call.autopilot.CallerAutopilotActionsListenerManager;
 import com.mogo.eagle.core.function.call.autopilot.CallerAutopilotStatisticsListenerManager;
 import com.mogo.eagle.core.utilcode.mogo.logger.Logger;
 import com.mogo.och.common.module.callback.OchAdasStartFailureCallback;
 import com.zhjt.mogo.adas.data.bean.AutopilotStatistics;
 
+import mogo.telematics.pad.MessagePad;
+import mogo_msg.MogoReportMsg;
+import system_master.SystemStatusInfo;
+
 /**
  * Created on 2022/10/9
  * 工控机状态信息回调（判断是否能否启动自动驾驶的回调）
  * 目前定的是3秒回调一次
  */
-public class OCHAdasAbilityManager implements IMoGoAutopilotActionsListener, IMoGoAutopilotStatisticsListener {
+public class OCHAdasAbilityManager implements IMoGoAutopilotActionsListener, IMoGoAutopilotStatisticsListener, IMoGoAutopilotStatusListener {
 
     private static final String TAG = OCHAdasAbilityManager.class.getSimpleName();
 
-    private boolean isAutopilotAbility = true;
-    private String autopilotAbilityReason = "";
+    private boolean isAutopilotAbility;
+    private String autopilotAbilityReason;
     private String startFailedCode = "";
     private String startFailedMessage = "";
 
@@ -37,6 +46,7 @@ public class OCHAdasAbilityManager implements IMoGoAutopilotActionsListener, IMo
     }
 
     public void init(Context context) {
+        ipcConnectStatusChanged();
         initListeners();
     }
 
@@ -64,11 +74,18 @@ public class OCHAdasAbilityManager implements IMoGoAutopilotActionsListener, IMo
         //2022.10.9 工控机状态信息回调（判断是否能否启动自动驾驶的回调）， 目前定的是3秒回调一次
         CallerAutopilotActionsListenerManager.INSTANCE.addListener(TAG, this);
         CallerAutopilotStatisticsListenerManager.INSTANCE.addListener(TAG,this);
+        CallerAutoPilotStatusListenerManager.INSTANCE.addListener(TAG, this);
     }
 
     private void releaseListeners() {
         CallerAutopilotActionsListenerManager.INSTANCE.removeListener(this);
         CallerAutopilotStatisticsListenerManager.INSTANCE.removeListener(this);
+        CallerAutoPilotStatusListenerManager.INSTANCE.removeListener(this);
+    }
+
+    private void ipcConnectStatusChanged() {
+        this.isAutopilotAbility = CallerAutoPilotControlManager.INSTANCE.isConnected();
+        this.autopilotAbilityReason = isAutopilotAbility ? "" : "未连接自动驾驶系统";
     }
 
     @Override
@@ -95,4 +112,41 @@ public class OCHAdasAbilityManager implements IMoGoAutopilotActionsListener, IMo
     public void release() {
         releaseListeners();
     }
+
+    @Override
+    public void onAutopilotIpcConnectStatusChanged(int status, @Nullable String reason) {
+        ipcConnectStatusChanged();
+    }
+
+    @Override
+    public void onAutopilotStatusResponse(@NonNull AutopilotStatusInfo autoPilotStatusInfo) {
+    }
+
+    @Override
+    public void onAutopilotStatusResponse(int state) {
+    }
+
+    @Override
+    public void onAutopilotDockerInfo(@NonNull String dockerVersion) {
+    }
+
+    @Override
+    public void onAutopilotArriveAtStation(@Nullable MessagePad.ArrivalNotification arrivalNotification) {
+    }
+
+    @Override
+    public void onAutopilotSNRequest() {
+    }
+
+    @Override
+    public void onAutopilotGuardian(@Nullable MogoReportMsg.MogoReportMessage guardianInfo) {
+    }
+
+    @Override
+    public void onAutopilotStatusRespByQuery(@NonNull SystemStatusInfo.StatusInfo status) {
+    }
+
+    @Override
+    public void onAutopilotRouteLineId(long lineId) {
+    }
 }