From 18919d53ea7d71d830ebacd49fe22ba9050264cc Mon Sep 17 00:00:00 2001 From: yangyakun Date: Mon, 9 Sep 2024 15:38:54 +0800 Subject: [PATCH] =?UTF-8?q?[6.6.0]=20[fix]=20[=E9=87=8D=E8=BF=9E=E5=8F=B8?= =?UTF-8?q?=E6=9C=BA=E5=B1=8F=E5=90=8E=E9=87=8D=E6=96=B0=E8=AF=B7=E6=B1=82?= =?UTF-8?q?=E6=9C=80=E6=96=B0=E7=8A=B6=E6=80=81]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../weaknet/passenger/model/BusPassengerModel.kt | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/OCH/shuttle/passenger_weaknet/src/main/java/jinlv/com/mogo/och/shuttle/weaknet/passenger/model/BusPassengerModel.kt b/OCH/shuttle/passenger_weaknet/src/main/java/jinlv/com/mogo/och/shuttle/weaknet/passenger/model/BusPassengerModel.kt index 59c8b27433..cd696ee235 100644 --- a/OCH/shuttle/passenger_weaknet/src/main/java/jinlv/com/mogo/och/shuttle/weaknet/passenger/model/BusPassengerModel.kt +++ b/OCH/shuttle/passenger_weaknet/src/main/java/jinlv/com/mogo/och/shuttle/weaknet/passenger/model/BusPassengerModel.kt @@ -12,6 +12,8 @@ import com.mogo.eagle.core.utilcode.mogo.logger.Logger import com.mogo.eagle.core.utilcode.mogo.logger.scene.SceneConstant import com.mogo.eagle.core.utilcode.util.GsonUtils import com.mogo.eagle.core.utilcode.util.StringUtils +import com.mogo.och.common.module.biz.lansocket.IOchLanPassengerStatusListener +import com.mogo.och.common.module.biz.lansocket.LoginLanPassengerSocket import com.mogo.och.common.module.manager.autopilot.autopilot.IOchAutopilotStatusListener import com.mogo.och.common.module.manager.autopilot.autopilot.OchAutoPilotStatusListenerManager import com.mogo.och.common.module.manager.autopilot.location.OchLocationManager @@ -171,6 +173,8 @@ object BusPassengerModel { AbnormalFactorsLoopManager.startLoopAbnormalFactors(mContext!!) TrajectoryAndDistanceManager.addDistanceListener(TAG, trajectoryListener) + + LoginLanPassengerSocket.addListener(TAG,connectDriverListener) } private fun releaseListeners() { @@ -185,6 +189,16 @@ object BusPassengerModel { LanSocketManager.unRegisterSocketMessageListener(DPMsgType.TYPE_TASK_DETAILS.type, typeTaskDetails) AbnormalFactorsLoopManager.stopLoopAbnormalFactors() + LoginLanPassengerSocket.removeListener(TAG) + } + + private val connectDriverListener = object : IOchLanPassengerStatusListener{ + override fun onDriverConnectChangeListener(isConnect: Boolean) { + super.onDriverConnectChangeListener(isConnect) + if(isConnect){ + queryDriverByLocalDriver() + } + } } private val commonListener = object : ILanMessageListener {