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<AppConnectMsg> {