fix bug of scene

core/function-impl/mogo-core-function-autopilot/src/main/java/com/mogo/eagle/core/function/autopilot/adapter/MoGoAdasMsgConnectStatusListenerImpl.kt

@@ -1,5 +1,6 @@
 package com.mogo.eagle.core.function.autopilot.adapter
 
+import android.annotation.SuppressLint
 import com.mogo.cloud.passport.MoGoAiCloudClientConfig
 import com.mogo.commons.debug.DebugConfig
 import com.mogo.eagle.core.data.autopilot.AutopilotStatusInfo
@@ -8,6 +9,7 @@ import com.mogo.eagle.core.function.api.autopilot.IMoGoAutopilotStatusListener
 import com.mogo.eagle.core.function.autopilot.network.AdasServiceModel
 import com.mogo.eagle.core.function.call.autopilot.CallerAutoPilotStatusListenerManager
 import com.mogo.eagle.core.utilcode.mogo.logger.CallerLogger
+import com.mogo.eagle.core.utilcode.mogo.toast.TipToast
 import com.zhidao.support.adas.high.AdasManager
 import com.zhidao.support.adas.high.OnAdasConnectStatusListener
 import com.zhidao.support.adas.high.common.Constants
@@ -42,14 +44,22 @@ class MoGoAdasMsgConnectStatusListenerImpl : OnAdasConnectStatusListener,
 
             // 同步SN给工控机
             syncBasicInfoToAutopilot()
-
-            // 开启轮训上传自动驾驶状态
+            // 开启轮询上传自动驾驶状态
             updateDriveStatusTask()
+
         } else if (ipcConnectionStatus == Constants.IPC_CONNECTION_STATUS.DISCONNECTED) {
             CallerLogger.d("$M_ADAS_IMPL$TAG", "webSocket 连接失败 reason:$reason")
+            reason?.let {
+                TipToast.shortTip("工控机连接断开，原因:$it , 等待重连")
+            }
             CallerAutoPilotStatusListenerManager.getAutoPilotStatusInfo().connectIP =
                 AdasManager.getInstance().ipcConnectedIp
             CallerAutoPilotStatusListenerManager.getAutoPilotStatusInfo().connectStatus = false
+            //与工控机断开连接，需要重置自动驾驶状态(包括上传至云平台缓存信息)，等待连接成功后同步状态信息
+            mCurrentAutopilotStatus = 0
+            mCurrentAutopilotSpeed = 0.0f
+            CallerAutoPilotStatusListenerManager.getAutoPilotStatusInfo().state = 0
+            CallerAutoPilotStatusListenerManager.getAutoPilotStatusInfo().pilotmode = 0
             CallerAutoPilotStatusListenerManager.invokeAutoPilotStatus()
         } else if (ipcConnectionStatus == Constants.IPC_CONNECTION_STATUS.CONNECTING) {
             CallerLogger.d("$M_ADAS_IMPL$TAG", "webSocket 正在连接")
@@ -60,7 +70,6 @@ class MoGoAdasMsgConnectStatusListenerImpl : OnAdasConnectStatusListener,
         }
     }
 
-
     /**
      * 工控机获取SN
      */
@@ -96,13 +105,14 @@ class MoGoAdasMsgConnectStatusListenerImpl : OnAdasConnectStatusListener,
     /**
      * 上传自动驾驶状态任务
      */
+    @SuppressLint("CheckResult")
     private fun updateDriveStatusTask() {
         CallerLogger.d("$M_ADAS_IMPL$TAG", "updateDriveStatusTask")
         Flowable.interval(0, 5, TimeUnit.SECONDS)
             .subscribeOn(Schedulers.io())
             .unsubscribeOn(Schedulers.io())
             .observeOn(AndroidSchedulers.mainThread())
-            .subscribe { aLong: Long? ->
+            .subscribe {
                 AdasServiceModel.getInstance()
                     .updateDriveStatus(mCurrentAutopilotStatus, mCurrentAutopilotSpeed)
             }