From ba09b6768ef456df8e27beb2d7472a34de114762 Mon Sep 17 00:00:00 2001
From: chakcy <947105045@qq.com>
Date: Fri, 7 Aug 2026 16:40:48 +0800
Subject: [PATCH] =?UTF-8?q?modify:=20internal=5Fmqtt=20=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 aibox_sophon_adapter/edge_app_controller.py | 25 ++++++++++-----------
 1 file changed, 12 insertions(+), 13 deletions(-)

diff --git a/aibox_sophon_adapter/edge_app_controller.py b/aibox_sophon_adapter/edge_app_controller.py
index 0a7e3d3..c19987f 100644
--- a/aibox_sophon_adapter/edge_app_controller.py
+++ b/aibox_sophon_adapter/edge_app_controller.py
@@ -115,7 +115,7 @@ async def _cmd_alg_media_fetch(payload: dict) -> dict | None:
     请求: {"Event": "/alg_media_fetch", "BoardId": "..."}
     返回: {"board_id": ..., "medias": [...], "tasks": [...]}
     """
-    from .global_var import db
+    from .global_var import db, internal_mqtt
 
     board_id = payload.get("BoardId")
     if not board_id:
@@ -126,6 +126,8 @@ async def _cmd_alg_media_fetch(payload: dict) -> dict | None:
 
     if db is None:
         raise RuntimeError("数据库未初始化")
+    if internal_mqtt is None:
+        raise RuntimeError("internal_mqtt 未初始化")
 
     async with db.get_session() as session:
         from .models.orm import BoardHeartbeat
@@ -139,19 +141,16 @@ async def _cmd_alg_media_fetch(payload: dict) -> dict | None:
             print(f"[alg_media_fetch]Board {board_id} not found in database.")
             return None
 
-        import json
-        ping_data = {}
-        try:
-            ping_data = json.loads(record.ping_data) if record.ping_data else {}
-        except json.JSONDecodeError:
-            pass
+        resp = await internal_mqtt.request(
+            request_topic="/chongming/aibox_sophon_adapter/edge_app_controller",
+            response_topic="/chongming/aibox_sophon_adapter/edge_app_controller_reply",
+            payload=payload,
+            timeout=5
+        )
 
-        return {
-            "board_id": board_id,
-            "board_ip": record.board_ip,
-            "medias": ping_data.get("Medias", []),
-            "tasks": ping_data.get("Tasks", []),
-        }
+        print(f"[alg_media_fetch]Response from internal_mqtt: {resp}")
+
+        return resp
 
 async def _cmd_alg_task_fetch(payload: dict) -> dict | None:
     """