Pine
856ff88440
后端（backend/，FastAPI :10085）： - 全部数据 REST 接口：dashboard 快照 / 企业分区 / 播放列表 / 媒体 / 设置 - MQTT 控制通道：opc/display/command（切页/播放/卡片/通知）， 管理端 POST /api/display/command → MQTT 广播 → 所有大屏同步响应 - 阿里云 DashScope：通义千问 LLM + 函数调用（工具经 MQTT 广播）， paraformer-realtime-v2 语音识别 /api/ai/asr - 媒体资源统一由后端存储返回（上传/列表/静态服务） - SSE /api/events 保留作 MQTT 不可用时的兼容回退 前端： - config.js + .env.local 配置后端地址与 MQTT 账号（前端 dpm / 服务端 dpmserver） - mqtt.js 客户端 + useMqttControl（MQTT 驱动切页/媒体/卡片/通知） - DpmOverlays 全局覆盖层（通知 toast + 企业/分区/总览卡片） - useParkSim 改为后端 API 数据源（离线回退本地模拟） - AiChatPanel：对话走后端 LLM（工具调用），语音走本地录音 + 后端 ASR - MediaScreen：媒体控制走 MQTT（保留 SSE 回退），修复 useEffect TDZ Rust：lib.rs 移除内嵌 HTTP 服务器，只保留薄壳（窗口/权限/自启/npc 隧道） 安全：backend/.env、.env.local、media、data.json 已 gitignore
45 lines
1.0 KiB
Python
45 lines
1.0 KiB
Python
# -*- coding: utf-8 -*-
|
|
"""SSE 事件总线 —— 兼容旧通道（前端 MQTT 不可用时回退）
|
|
所有 MQTT 控制指令同时推送到 SSE /api/events
|
|
"""
|
|
|
|
import asyncio
|
|
import json
|
|
|
|
|
|
class EventBus:
|
|
def __init__(self):
|
|
self._queues = set()
|
|
self._loop = None
|
|
|
|
def set_loop(self, loop):
|
|
self._loop = loop
|
|
|
|
def subscribe(self):
|
|
q = asyncio.Queue(maxsize=256)
|
|
self._queues.add(q)
|
|
return q
|
|
|
|
def unsubscribe(self, q):
|
|
self._queues.discard(q)
|
|
|
|
def emit(self, payload: dict):
|
|
"""线程安全：从任意线程广播事件"""
|
|
if not self._loop:
|
|
return
|
|
try:
|
|
asyncio.run_coroutine_threadsafe(self._emit(payload), self._loop)
|
|
except Exception: # noqa: BLE001
|
|
pass
|
|
|
|
async def _emit(self, payload):
|
|
data = json.dumps(payload, ensure_ascii=False)
|
|
for q in list(self._queues):
|
|
try:
|
|
q.put_nowait(data)
|
|
except asyncio.QueueFull:
|
|
pass
|
|
|
|
|
|
bus = EventBus()
|