diff --git a/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/mofang/MoFangCommandExecutor.kt b/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/mofang/MoFangCommandExecutor.kt
index bc472a3f42..d0d67ef3bd 100644
--- a/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/mofang/MoFangCommandExecutor.kt
+++ b/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/mofang/MoFangCommandExecutor.kt
@@ -3,8 +3,10 @@ package com.zhjt.mogo_core_function_devatools.mofang
 import android.os.*
 import android.util.*
 import android.view.KeyEvent
+import com.mogo.eagle.core.data.config.*
 import com.mogo.eagle.core.function.call.autopilot.*
 import com.mogo.eagle.core.network.utils.GsonUtil
+import com.mogo.eagle.core.utilcode.mogo.*
 import com.zhjt.mogo_core_function_devatools.mofang.MoFangAnalyticUtils.Companion.EVENT_EXECUTE
 import com.zhjt.mogo_core_function_devatools.mofang.MoFangAnalyticUtils.Companion.EVENT_EXECUTE_SUB_KEYCODE
 import com.zhjt.mogo_core_function_devatools.mofang.MoFangAnalyticUtils.Companion.EVENT_EXECUTE_SUB_TYPE
@@ -82,7 +84,13 @@ internal class MoFangCommandExecutor {
                     MoFangAnalyticUtils.track(EVENT_EXECUTE, mutableMapOf(EVENT_EXECUTE_SUB_KEYCODE to (getKeycodeByWhat(msg.what) ?: ""), EVENT_EXECUTE_SUB_TYPE to (getInputTypeByWhat(msg.what) ?: "")))
                     linkedLog?.record(mapOf("执行:${System.currentTimeMillis()}" to "$message, $json"))
                     Log.d(TAG, "--- 启动自驾 ----入参:$json")
-                    CallerAutoPilotControlManager.startAutoPilot(parameters)
+                    //清扫车有FSM模块，魔方启动自驾时需要将Source修改为魔方，以便telamatics做区分并在转发时增加flag标记
+                    if (AppIdentityModeUtils.isSweeper(FunctionBuildConfig.appIdentityMode)) {
+                        CallerAutoPilotControlManager.startAutoPilotByMoFang(parameters)
+                    } else{
+                        CallerAutoPilotControlManager.startAutoPilot(parameters)
+                    }
+
                 } catch (t: Throwable) {
                     t.printStackTrace()
                     Log.e(TAG, "error: ${t.message}, msg-> $msg")