diff --git a/src/daemon/dispatcher.py b/src/daemon/dispatcher.py
index 8606850..95a4745 100644
--- a/src/daemon/dispatcher.py
+++ b/src/daemon/dispatcher.py
@@ -129,7 +129,7 @@ class Dispatcher:
         # 检查并发限制
         if self.counter and level in (DispatchLevel.FULL_AGENT, DispatchLevel.ESCALATE):
             if not await self.counter.can_acquire(agent_id):
-                self._record_routing(task, decision, "skipped", "Agent busy")
+                self._record_routing(task, decision, "skipped", "Agent busy", _routing_db)
                 return {
                     "level": level.value,
                     "agent_id": agent_id,
@@ -140,7 +140,7 @@ class Dispatcher:
 
         # 本地执行
         if level == DispatchLevel.LOCAL:
-            self._record_routing(task, decision, "dispatched", None)
+            self._record_routing(task, decision, "dispatched", None, _routing_db)
             return {
                 "level": level.value,
                 "agent_id": "daemon",
@@ -152,7 +152,7 @@ class Dispatcher:
         # Full Agent / Escalate spawn
         if level in (DispatchLevel.FULL_AGENT, DispatchLevel.ESCALATE):
             if not self.spawner:
-                self._record_routing(task, decision, "error", "No spawner")
+                self._record_routing(task, decision, "error", "No spawner", _routing_db)
                 return {
                     "level": level.value,
                     "agent_id": agent_id,
@@ -176,7 +176,7 @@ class Dispatcher:
                 )
 
                 self._record_routing(task, decision, "dispatched",
-                                     f"session={session_id}")
+                                     f"session={session_id}", _routing_db)
 
                 return {
                     "level": level.value,
@@ -188,7 +188,7 @@ class Dispatcher:
             except Exception as e:
                 if self.counter:
                     self.counter.release(agent_id)
-                self._record_routing(task, decision, "error", str(e))
+                self._record_routing(task, decision, "error", str(e), _routing_db)
                 return {
                     "level": level.value,
                     "agent_id": agent_id,