diff --git a/api/routers/advisor_agent.py b/api/routers/advisor_agent.py
index 95b6bde..f03d569 100644
--- a/api/routers/advisor_agent.py
+++ b/api/routers/advisor_agent.py
@@ -319,7 +319,6 @@ async def chat_stream(
                 headers={"X-Trace-Id": trace_id},
             )
     else:
-        customer_id = chat_request.customer_id
         relation = await ensure_customer_access(
             db, advisor_id=user.id, customer_id=int(customer_id)
         )
diff --git a/service/advisor/agent_client.py b/service/advisor/agent_client.py
index 791546b..039b00b 100644
--- a/service/advisor/agent_client.py
+++ b/service/advisor/agent_client.py
@@ -177,7 +177,7 @@ class AdvisorAgentClient:
     ) -> dict:
         return await self._request(
             "POST", "/rebalance/run", auth_header=auth_header,
-            trace_id=trace_id, json={"customer_id": customer_id},
+            trace_id=trace_id, json={"query": f"请为客户{customer_id}执行调仓再平衡"},
         )
 
     async def generate_talk_script(
@@ -185,7 +185,8 @@ class AdvisorAgentClient:
     ) -> dict:
         return await self._request(
             "POST", "/generate-talk-script", auth_header=auth_header,
-            trace_id=trace_id, json={"customer_id": customer_id, "scene_type": scene_type},
+            trace_id=trace_id,
+            json={"query": f"请为客户{customer_id}生成{scene_type}沟通话术"},
         )
 
     async def data_query(