mainwindow.cpp 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685
  1. #include "mainwindow.h"
  2. #include "database_manager/databasemodule.h"
  3. #include "daemon/daemon_client.h"
  4. #include "daemon/daemon_connection_dialog.h"
  5. #include "daemon/daemon_message_flow_widget.h"
  6. #include "api/SoftBusAPI.h"
  7. #include "settings/settings_dialog.h"
  8. #include "toolbar/toolbar.h"
  9. #include "view_serial/serialmodule.h"
  10. #include "view_serial/serialdockpage.h"
  11. #include "view_network/networkmodule.h"
  12. #include "view_network/networkdockpage.h"
  13. #include "connect_signal/view_instance_manager.h"
  14. #include "view_device_config/device_tree_widget.h"
  15. #include "utils/logging.h"
  16. #include <QAction>
  17. #include <QApplication>
  18. #include <QCloseEvent>
  19. #include <QDockWidget>
  20. #include <QHBoxLayout>
  21. #include <QJsonDocument>
  22. #include <QJsonObject>
  23. #include <QLabel>
  24. #include <QMenu>
  25. #include <QMenuBar>
  26. #include <QMessageBox>
  27. #include <QSettings>
  28. #include <QShortcut>
  29. #include <QStackedWidget>
  30. #include <QStatusBar>
  31. #include <QToolBar>
  32. #include <QVBoxLayout>
  33. MainWindow::MainWindow(QWidget *parent) : QMainWindow(parent) { createUI(); }
  34. void MainWindow::createUI() {
  35. // 创建菜单栏
  36. createMenuBar();
  37. // 创建主布局
  38. QWidget *centralWidget = new QWidget(this);
  39. QVBoxLayout *mainLayout = new QVBoxLayout(centralWidget);
  40. // 界面设置
  41. setWindowTitle("软件总线");
  42. setWindowIcon(QIcon(":/qrc/icons/ads_icon.svg"));
  43. setUnifiedTitleAndToolBarOnMac(true);
  44. setDockNestingEnabled(true);
  45. setAnimated(true);
  46. setTabPosition(Qt::AllDockWidgetAreas, QTabWidget::North);
  47. setDockOptions(QMainWindow::AllowTabbedDocks | QMainWindow::AnimatedDocks |
  48. QMainWindow::VerticalTabs);
  49. setStatusBar(new QStatusBar(this));
  50. setCorner(Qt::TopLeftCorner, Qt::LeftDockWidgetArea);
  51. setCorner(Qt::TopRightCorner, Qt::RightDockWidgetArea);
  52. setCorner(Qt::BottomLeftCorner, Qt::LeftDockWidgetArea);
  53. setCorner(Qt::BottomRightCorner, Qt::RightDockWidgetArea);
  54. setMinimumSize(800, 600);
  55. setMaximumSize(1600, 1200);
  56. // 创建页面堆栈
  57. m_pageStack = new QStackedWidget(this);
  58. mainLayout->addWidget(m_pageStack);
  59. centralWidget->setLayout(mainLayout);
  60. setCentralWidget(centralWidget);
  61. // 先设置守护进程状态(必须在创建模块之前,因为模块可能会初始化 API)
  62. setupDaemonStatus();
  63. // 创建工具栏和页面(在守护进程设置之后)
  64. createHomeToolbar();
  65. createSerialToolbar();
  66. createNetworkToolbar();
  67. createDatabaseToolbar();
  68. createSettingsToolbar();
  69. createHelpToolbar();
  70. // 默认显示主界面
  71. switchToPage(1);
  72. // 设置快捷键
  73. setupShortcuts();
  74. // 链接信号槽
  75. connectSignals();
  76. // 创建状态栏
  77. this->statusBar()->showMessage("就绪");
  78. }
  79. void MainWindow::createMenuBar() {
  80. // 创建菜单栏
  81. QMenuBar *menuBar = new QMenuBar(this);
  82. setMenuBar(menuBar);
  83. // 视图菜单
  84. QMenu *viewMenu = menuBar->addMenu("视图");
  85. QAction *homeAction =
  86. viewMenu->addAction(QIcon(":/qrc/icons/home.png"), "主界面");
  87. QAction *serialAction =
  88. viewMenu->addAction(QIcon(":/qrc/icons/serial.png"), "串口");
  89. QAction *networkAction =
  90. viewMenu->addAction(QIcon(":/qrc/icons/network.png"), "网络");
  91. QAction *databaseAction =
  92. viewMenu->addAction(QIcon(":/qrc/icons/grid_on.svg"), "数据库");
  93. QAction *settingsAction =
  94. viewMenu->addAction(QIcon(":/qrc/icons/settings.png"), "设置");
  95. QAction *helpAction =
  96. viewMenu->addAction(QIcon(":/qrc/icons/help.png"), "帮助");
  97. // 连接视图菜单的切换功能
  98. connect(homeAction, &QAction::triggered, this, [this]() { switchToPage(0); });
  99. connect(serialAction, &QAction::triggered, this,
  100. [this]() { switchToPage(1); });
  101. connect(networkAction, &QAction::triggered, this,
  102. [this]() { switchToPage(2); });
  103. connect(databaseAction, &QAction::triggered, this,
  104. [this]() { switchToPage(3); });
  105. connect(settingsAction, &QAction::triggered, this,
  106. [this]() { switchToPage(4); });
  107. connect(helpAction, &QAction::triggered, this, [this]() { switchToPage(4); });
  108. // 文件菜单
  109. QMenu *fileMenu = menuBar->addMenu("文件");
  110. QAction *newAction =
  111. fileMenu->addAction(QIcon(":/qrc/icons/new.png"), "新建");
  112. QAction *openAction =
  113. fileMenu->addAction(QIcon(":/qrc/icons/open.png"), "打开");
  114. QAction *saveAction =
  115. fileMenu->addAction(QIcon(":/qrc/icons/save.png"), "保存");
  116. fileMenu->addSeparator();
  117. QAction *exitAction =
  118. fileMenu->addAction(QIcon(":/qrc/icons/exit.png"), "退出");
  119. // 编辑菜单
  120. QMenu *editMenu = menuBar->addMenu("编辑");
  121. QAction *undoAction =
  122. editMenu->addAction(QIcon(":/qrc/icons/undo.png"), "撤销");
  123. QAction *redoAction =
  124. editMenu->addAction(QIcon(":/qrc/icons/redo.png"), "重做");
  125. editMenu->addSeparator();
  126. QAction *cutAction =
  127. editMenu->addAction(QIcon(":/qrc/icons/cut.png"), "剪切");
  128. QAction *copyAction =
  129. editMenu->addAction(QIcon(":/qrc/icons/copy.png"), "复制");
  130. QAction *pasteAction =
  131. editMenu->addAction(QIcon(":/qrc/icons/paste.png"), "粘贴");
  132. // 帮助菜单
  133. QMenu *helpMenu = menuBar->addMenu("帮助");
  134. QAction *helpDocAction =
  135. helpMenu->addAction(QIcon(":/qrc/icons/help.png"), "帮助文档");
  136. QAction *aboutAction =
  137. helpMenu->addAction(QIcon(":/qrc/icons/about.png"), "关于");
  138. QAction *updateAction =
  139. helpMenu->addAction(QIcon(":/qrc/icons/update.png"), "检查更新");
  140. connect(aboutAction, &QAction::triggered, this, &MainWindow::showAbout);
  141. // 连接退出菜单项,真正退出应用
  142. connect(exitAction, &QAction::triggered, qApp, &QApplication::quit);
  143. }
  144. void MainWindow::createHomeToolbar() {
  145. // 创建主界面工具栏
  146. Toolbar *homeToolbar = new Toolbar("主工具栏", this);
  147. addToolBar(Qt::TopToolBarArea, homeToolbar);
  148. homeToolbar->hide();
  149. // 添加按钮
  150. homeToolbar->addAction(QIcon(":/qrc/icons/new.png"), "新建");
  151. homeToolbar->addAction(QIcon(":/qrc/icons/open.png"), "打开");
  152. homeToolbar->addAction(QIcon(":/qrc/icons/save.png"), "保存");
  153. homeToolbar->addAction(QIcon(":/qrc/icons/print.png"), "打印");
  154. // 创建主界面页面
  155. QLabel *homePage = new QLabel("<center><h1>主界面</h1></center>", this);
  156. homePage->setAlignment(Qt::AlignCenter);
  157. // 添加到堆栈
  158. m_toolbars.append(homeToolbar);
  159. m_pageStack->addWidget(homePage);
  160. }
  161. void MainWindow::createSerialToolbar() {
  162. if (!m_serialModule) {
  163. m_serialModule = new SerialModule(this, this);
  164. }
  165. if (Toolbar *serialToolbar = m_serialModule->toolbar()) {
  166. addToolBar(Qt::TopToolBarArea, serialToolbar);
  167. serialToolbar->hide();
  168. m_toolbars.append(serialToolbar);
  169. }
  170. if (QWidget *serialPage = m_serialModule->pageWidget()) {
  171. m_serialPageIndex = m_pageStack->addWidget(serialPage);
  172. }
  173. }
  174. void MainWindow::createNetworkToolbar() {
  175. if (!m_networkModule) {
  176. m_networkModule = new NetworkModule(this, this);
  177. }
  178. if (Toolbar *networkToolbar = m_networkModule->toolbar()) {
  179. addToolBar(Qt::TopToolBarArea, networkToolbar);
  180. networkToolbar->hide();
  181. m_toolbars.append(networkToolbar);
  182. }
  183. if (QWidget *networkPage = m_networkModule->pageWidget()) {
  184. m_networkPageIndex = m_pageStack->addWidget(networkPage);
  185. }
  186. }
  187. void MainWindow::createDatabaseToolbar() {
  188. if (!m_databaseModule) {
  189. m_databaseModule = new DatabaseModule(this, this);
  190. }
  191. if (Toolbar *databaseToolbar = m_databaseModule->toolbar()) {
  192. addToolBar(Qt::TopToolBarArea, databaseToolbar);
  193. databaseToolbar->hide();
  194. m_toolbars.append(databaseToolbar);
  195. }
  196. if (QWidget *databasePage = m_databaseModule->pageWidget()) {
  197. m_databasePageIndex = m_pageStack->addWidget(databasePage);
  198. }
  199. }
  200. void MainWindow::createSettingsToolbar() {
  201. // 创建设置界面工具栏
  202. Toolbar *settingsToolbar = new Toolbar("设置工具栏", this);
  203. addToolBar(Qt::TopToolBarArea, settingsToolbar);
  204. settingsToolbar->hide();
  205. // 添加按钮
  206. QAction *preferencesAction = settingsToolbar->addAction(QIcon(":/qrc/icons/preferences.png"), "首选项");
  207. connect(preferencesAction, &QAction::triggered, this, &MainWindow::showSettingsDialog);
  208. settingsToolbar->addAction(QIcon(":/qrc/icons/theme.png"), "主题");
  209. settingsToolbar->addAction(QIcon(":/qrc/icons/keyboard.png"), "快捷键");
  210. settingsToolbar->addAction(QIcon(":/qrc/icons/plugins.png"), "插件");
  211. // 创建设置界面页面
  212. QLabel *settingsPage = new QLabel("<center><h1>设置界面</h1><p>点击工具栏中的\"首选项\"按钮打开设置对话框</p></center>", this);
  213. settingsPage->setAlignment(Qt::AlignCenter);
  214. // 添加到堆栈
  215. m_toolbars.append(settingsToolbar);
  216. m_pageStack->addWidget(settingsPage);
  217. }
  218. void MainWindow::createHelpToolbar() {
  219. // 创建帮助界面工具栏
  220. Toolbar *helpToolbar = new Toolbar("帮助工具栏", this);
  221. addToolBar(Qt::TopToolBarArea, helpToolbar);
  222. helpToolbar->hide();
  223. // 添加按钮
  224. helpToolbar->addAction(QIcon(":/qrc/icons/help.png"), "帮助文档");
  225. helpToolbar->addAction(QIcon(":/qrc/icons/about.png"), "关于");
  226. helpToolbar->addAction(QIcon(":/qrc/icons/update.png"), "检查更新");
  227. // 创建帮助界面页面
  228. QLabel *helpPage = new QLabel("<center><h1>帮助界面</h1></center>", this);
  229. helpPage->setAlignment(Qt::AlignCenter);
  230. // 添加到堆栈
  231. m_toolbars.append(helpToolbar);
  232. m_pageStack->addWidget(helpPage);
  233. }
  234. /*
  235. function: 返回指定索引的页面
  236. @author: flower
  237. @date: 2025-10-23
  238. @param index 页面索引
  239. @return 无
  240. */
  241. void MainWindow::switchToPage(int index) {
  242. // 隐藏所有工具栏
  243. for (Toolbar *toolbar : m_toolbars) {
  244. toolbar->hide();
  245. }
  246. // 显示当前工具栏
  247. if (index >= 0 && index < m_toolbars.size()) {
  248. m_toolbars[index]->show();
  249. m_pageStack->setCurrentIndex(index);
  250. }
  251. }
  252. /*
  253. function: 设置快捷键
  254. @author: flower
  255. @date: 2025-10-23
  256. @param
  257. @return 无
  258. */
  259. void MainWindow::setupShortcuts() {
  260. // 创建快捷键
  261. QShortcut *homeShortcut = new QShortcut(QKeySequence("Ctrl+1"), this);
  262. QShortcut *serialShortcut = new QShortcut(QKeySequence("Ctrl+2"), this);
  263. QShortcut *networkShortcut = new QShortcut(QKeySequence("Ctrl+3"), this);
  264. QShortcut *databaseShortcut = new QShortcut(QKeySequence("Ctrl+4"), this);
  265. QShortcut *settingsShortcut = new QShortcut(QKeySequence("Ctrl+5"), this);
  266. QShortcut *helpShortcut = new QShortcut(QKeySequence("Ctrl+6"), this);
  267. // 连接快捷键信号
  268. connect(homeShortcut, &QShortcut::activated, this,
  269. [this]() { switchToPage(0); });
  270. connect(serialShortcut, &QShortcut::activated, this,
  271. [this]() { switchToPage(1); });
  272. connect(networkShortcut, &QShortcut::activated, this,
  273. [this]() { switchToPage(2); });
  274. connect(databaseShortcut, &QShortcut::activated, this,
  275. [this]() { switchToPage(3); });
  276. connect(settingsShortcut, &QShortcut::activated, this,
  277. [this]() { switchToPage(4); });
  278. connect(helpShortcut, &QShortcut::activated, this,
  279. [this]() { switchToPage(5); });
  280. }
  281. /*
  282. function: 链接信号槽
  283. @author: flower
  284. @date: 2021-10-23
  285. @param
  286. @return 无
  287. */
  288. void MainWindow::connectSignals() {
  289. // 连接设备树选择信号到自动跳转槽函数
  290. // 现在有两个独立的设备树实例(串口页面和网络页面),都需要连接
  291. ViewInstanceManager* viewMgr = ViewInstanceManager::instance();
  292. if (viewMgr) {
  293. // 连接串口页面的设备树
  294. DeviceTreeWidget* serialDeviceTree = viewMgr->getSerialDeviceTreeWidget();
  295. if (serialDeviceTree) {
  296. connect(serialDeviceTree, &DeviceTreeWidget::deviceSelected,
  297. this, &MainWindow::onDeviceSelectedForAutoSwitch);
  298. LOG_INFO() << "MainWindow: 串口页面设备树自动跳转信号已连接";
  299. }
  300. // 连接网络页面的设备树
  301. DeviceTreeWidget* networkDeviceTree = viewMgr->getNetworkDeviceTreeWidget();
  302. if (networkDeviceTree) {
  303. connect(networkDeviceTree, &DeviceTreeWidget::deviceSelected,
  304. this, &MainWindow::onDeviceSelectedForAutoSwitch);
  305. LOG_INFO() << "MainWindow: 网络页面设备树自动跳转信号已连接";
  306. }
  307. }
  308. }
  309. void MainWindow::onDeviceSelectedForAutoSwitch(const QString &deviceType, const QString &deviceId) {
  310. // 根据设备类型自动跳转到相应页面
  311. if (deviceType == QStringLiteral("network")) {
  312. // 如果是网络设备,跳转到网络页面
  313. if (m_networkPageIndex >= 0) {
  314. switchToPage(m_networkPageIndex);
  315. LOG_INFO() << "MainWindow: 自动跳转到网络页面 - 设备=" << deviceId;
  316. }
  317. } else if (deviceType == QStringLiteral("serial")) {
  318. // 如果是串口设备,跳转到串口页面
  319. if (m_serialPageIndex >= 0) {
  320. switchToPage(m_serialPageIndex);
  321. LOG_INFO() << "MainWindow: 自动跳转到串口页面 - 设备=" << deviceId;
  322. }
  323. }
  324. // 其他设备类型(如CAN)可以在这里添加
  325. }
  326. void MainWindow::showAbout() {
  327. QMessageBox::about(this, "关于",
  328. "<h2>基于DoDAF的多源数据融合系统总线</h2>"
  329. "<p> </p>"
  330. "<p>版本: 1.0.0</p>"
  331. "<p>© flower </p>");
  332. }
  333. void MainWindow::setupDaemonStatus()
  334. {
  335. // 创建守护进程客户端
  336. m_daemonClient = new DaemonClient(this);
  337. // 连接信号
  338. connect(m_daemonClient, &DaemonClient::daemonStatusChanged,
  339. this, &MainWindow::onDaemonStatusChanged);
  340. connect(m_daemonClient, &DaemonClient::loadInfoUpdated,
  341. this, &MainWindow::onLoadInfoUpdated);
  342. // 强制使用守护进程模式,先尝试连接守护进程(如果已存在则直接连接)
  343. LOG_INFO() << "强制使用守护进程模式,正在尝试连接守护进程服务...";
  344. bool connected = m_daemonClient->connectToDaemon();
  345. // 如果连接失败,再尝试启动守护进程
  346. if (!connected) {
  347. LOG_INFO() << "守护进程未运行,正在启动守护进程...";
  348. // 尝试启动守护进程(可能已经存在)
  349. m_daemonClient->startDaemon();
  350. // 无论启动是否成功,都尝试连接(守护进程可能已经通过其他方式启动)
  351. LOG_INFO() << "正在尝试连接守护进程...";
  352. connected = m_daemonClient->connectToDaemon();
  353. if (connected) {
  354. LOG_INFO() << "守护进程启动并连接成功";
  355. } else {
  356. LOG_WARNING() << "守护进程启动或连接失败";
  357. }
  358. } else {
  359. LOG_INFO() << "守护进程已存在,连接成功";
  360. }
  361. if (!connected) {
  362. LOG_WARNING() << "守护进程连接失败,弹出对话框询问用户";
  363. // 连接失败,弹出对话框询问是否重试
  364. DaemonConnectionDialog dialog(this);
  365. dialog.setErrorMessage(tr("守护进程服务未运行或无法访问。"));
  366. int result = dialog.exec();
  367. if (result == QDialog::Accepted) {
  368. if (dialog.switchToLocalMode()) {
  369. // 用户选择切换到本地模式(已废弃,但保留兼容性)
  370. QMessageBox::warning(this,
  371. tr("本地模式已移除"),
  372. tr("本地模式已移除,所有硬件操作必须通过守护进程进行。\n"
  373. "请确保守护进程服务正常运行。"));
  374. // 尝试启动守护进程(可能已经存在)
  375. m_daemonClient->startDaemon();
  376. // 无论启动是否成功,都尝试连接(守护进程可能已经通过其他方式启动)
  377. connected = m_daemonClient->connectToDaemon();
  378. } else {
  379. // 用户选择重试,再次尝试启动和连接
  380. LOG_INFO() << "用户选择重试,正在重新启动守护进程...";
  381. // 尝试启动守护进程(可能已经存在)
  382. m_daemonClient->startDaemon();
  383. // 无论启动是否成功,都尝试连接(守护进程可能已经通过其他方式启动)
  384. connected = m_daemonClient->connectToDaemon();
  385. if (!connected) {
  386. // 重试仍然失败
  387. QMessageBox::critical(this,
  388. tr("连接失败"),
  389. tr("重试启动和连接守护进程仍然失败。\n"
  390. "请检查守护进程服务是否正常运行。"));
  391. LOG_CRITICAL() << "重试仍然失败,无法连接守护进程";
  392. } else {
  393. // 重试成功
  394. LOG_INFO() << "重试启动和连接守护进程成功";
  395. }
  396. }
  397. } else {
  398. // 用户取消
  399. QMessageBox::warning(this,
  400. tr("警告"),
  401. tr("未连接到守护进程,硬件操作将无法使用。"));
  402. LOG_WARNING() << "用户取消对话框,守护进程未连接";
  403. }
  404. } else {
  405. // 连接成功
  406. LOG_INFO() << "守护进程启动并连接成功";
  407. }
  408. // 初始化 API(现在强制使用守护进程模式)
  409. SoftBusAPI* api = SoftBusAPI::instance();
  410. if (!api) {
  411. LOG_CRITICAL() << "无法获取 SoftBusAPI 实例";
  412. return;
  413. }
  414. LOG_INFO() << "设置API模式: 守护进程模式(强制)";
  415. api->setUseDaemonMode(true); // 强制使用守护进程模式
  416. // 初始化 API(会根据模式创建相应的 Manager)
  417. LOG_INFO() << "正在初始化 SoftBusAPI...";
  418. if (!api->initialize()) {
  419. LOG_WARNING() << "Failed to initialize SoftBusAPI";
  420. return;
  421. }
  422. LOG_INFO() << "SoftBusAPI 初始化成功";
  423. // 设置 DaemonClient 到 SoftBusAPI,让硬件操作通过守护进程
  424. LOG_INFO() << "设置 DaemonClient 到 SoftBusAPI";
  425. api->setDaemonClient(m_daemonClient);
  426. // 守护进程连接成功后,启动设备扫描(由守护进程负责扫描)
  427. // 注意:在守护进程模式下,设备扫描由守护进程负责,这里只是通知可以开始查询设备列表
  428. LOG_INFO() << "启动设备扫描(守护进程模式)";
  429. api->startDeviceDiscovery(5000);
  430. // 在状态栏添加状态标签
  431. QStatusBar* statusBar = this->statusBar();
  432. if (statusBar) {
  433. m_statusLabel = new QLabel("核心服务: 未连接", this);
  434. m_loadLabel = new QLabel("负载: --", this);
  435. statusBar->addPermanentWidget(m_statusLabel);
  436. statusBar->addPermanentWidget(m_loadLabel);
  437. // 初始更新
  438. updateDaemonStatus(false, QString());
  439. }
  440. // 创建信息流列表停靠窗口(在守护进程客户端创建之后)
  441. createMessageFlowDock();
  442. // 设置守护进程客户端到信息流组件
  443. if (m_daemonClient && m_messageFlowWidget) {
  444. m_messageFlowWidget->setDaemonClient(m_daemonClient);
  445. }
  446. }
  447. void MainWindow::onDaemonStatusChanged(bool running, const QString& statusJson)
  448. {
  449. updateDaemonStatus(running, statusJson);
  450. // 信息流组件会自动处理状态更新(通过信号连接)
  451. }
  452. void MainWindow::onLoadInfoUpdated(const QString& loadInfoJson)
  453. {
  454. updateLoadInfo(loadInfoJson);
  455. // 信息流组件会自动处理负载信息更新(通过信号连接)
  456. }
  457. void MainWindow::updateDaemonStatus(bool running, const QString& statusJson)
  458. {
  459. if (!m_statusLabel) return;
  460. QString statusText;
  461. QString style;
  462. if (running) {
  463. statusText = "核心服务: 运行中";
  464. style = "color: green; font-weight: bold;";
  465. // 获取进程ID
  466. if (m_daemonClient) {
  467. qint64 pid = m_daemonClient->getPid();
  468. if (pid > 0) {
  469. statusText += QString(" (PID: %1)").arg(pid);
  470. }
  471. }
  472. // 解析状态 JSON 获取详细信息
  473. if (!statusJson.isEmpty()) {
  474. QJsonDocument doc = QJsonDocument::fromJson(statusJson.toUtf8());
  475. if (doc.isObject()) {
  476. QJsonObject obj = doc.object();
  477. int deviceCount = obj["deviceCount"].toInt(0);
  478. int onlineCount = obj["onlineDeviceCount"].toInt(0);
  479. statusText += QString(" | 设备: %1/%2").arg(onlineCount).arg(deviceCount);
  480. }
  481. }
  482. } else {
  483. statusText = "核心服务: 未运行";
  484. style = "color: red; font-weight: bold;";
  485. }
  486. m_statusLabel->setText(statusText);
  487. m_statusLabel->setStyleSheet(style);
  488. }
  489. void MainWindow::updateLoadInfo(const QString& loadInfoJson)
  490. {
  491. if (!m_loadLabel) return;
  492. if (loadInfoJson.isEmpty()) {
  493. m_loadLabel->setText("负载: --");
  494. return;
  495. }
  496. QJsonDocument doc = QJsonDocument::fromJson(loadInfoJson.toUtf8());
  497. if (!doc.isObject()) {
  498. m_loadLabel->setText("负载: --");
  499. return;
  500. }
  501. QJsonObject obj = doc.object();
  502. double messageRate = obj["messageRate"].toDouble(0.0);
  503. qint64 totalMessages = obj["totalMessages"].toVariant().toLongLong();
  504. QString loadText = QString("消息速率: %1 msg/s | 总计: %2")
  505. .arg(messageRate, 0, 'f', 1)
  506. .arg(totalMessages);
  507. m_loadLabel->setText(loadText);
  508. }
  509. void MainWindow::createMessageFlowDock()
  510. {
  511. // 创建信息流列表组件
  512. m_messageFlowWidget = new DaemonMessageFlowWidget(this);
  513. // 创建停靠窗口
  514. QDockWidget* dockWidget = new QDockWidget("守护进程信息流", this);
  515. dockWidget->setWidget(m_messageFlowWidget);
  516. dockWidget->setAllowedAreas(Qt::BottomDockWidgetArea | Qt::TopDockWidgetArea);
  517. dockWidget->setFeatures(QDockWidget::DockWidgetMovable | QDockWidget::DockWidgetFloatable);
  518. // 添加到主窗口
  519. addDockWidget(Qt::BottomDockWidgetArea, dockWidget);
  520. // 设置守护进程客户端
  521. if (m_daemonClient) {
  522. m_messageFlowWidget->setDaemonClient(m_daemonClient);
  523. }
  524. // 默认隐藏,可以通过视图菜单显示
  525. dockWidget->hide();
  526. // 添加到视图菜单
  527. QMenuBar* menuBar = this->menuBar();
  528. if (menuBar) {
  529. QMenu* viewMenu = nullptr;
  530. QList<QAction*> actions = menuBar->actions();
  531. for (QAction* action : actions) {
  532. if (action->text() == "视图") {
  533. viewMenu = qobject_cast<QMenu*>(action->menu());
  534. break;
  535. }
  536. }
  537. if (viewMenu) {
  538. QAction* flowAction = viewMenu->addAction("守护进程信息流");
  539. flowAction->setCheckable(true);
  540. flowAction->setChecked(false);
  541. connect(flowAction, &QAction::toggled, dockWidget, &QDockWidget::setVisible);
  542. }
  543. }
  544. }
  545. void MainWindow::loadSettings() {
  546. // 现在强制使用守护进程模式,不再从设置中读取
  547. // 保留此方法以保持接口兼容性
  548. SoftBusAPI* api = SoftBusAPI::instance();
  549. if (api) {
  550. api->setUseDaemonMode(true); // 强制使用守护进程模式
  551. LOG_DEBUG() << "加载设置 - 守护进程模式: 启用(强制)";
  552. }
  553. }
  554. void MainWindow::showSettingsDialog() {
  555. if (!m_settingsDialog) {
  556. m_settingsDialog = new SettingsDialog(this);
  557. // 设置守护进程客户端,让设置对话框能检查守护进程状态
  558. m_settingsDialog->setDaemonClient(m_daemonClient);
  559. }
  560. // 加载当前设置
  561. m_settingsDialog->loadSettings();
  562. // 显示对话框
  563. if (m_settingsDialog->exec() == QDialog::Accepted) {
  564. // 用户点击了"确定",应用设置
  565. // 注意:现在强制使用守护进程模式,设置对话框中的模式选项已无效
  566. SoftBusAPI* api = SoftBusAPI::instance();
  567. if (api) {
  568. api->setUseDaemonMode(true); // 强制使用守护进程模式
  569. LOG_DEBUG() << "设置已更新 - 守护进程模式: 启用(强制)";
  570. }
  571. }
  572. }
  573. void MainWindow::closeEvent(QCloseEvent *event) {
  574. // 关闭窗口时清理 soft_bus 相关资源并退出应用程序
  575. LOG_INFO() << "主界面关闭,正在清理 soft_bus 相关资源并退出应用程序...";
  576. SoftBusAPI* api = SoftBusAPI::instance();
  577. if (api && api->isInitialized()) {
  578. // 关闭所有设备(串口、CAN设备等)并清理资源
  579. // shutdown() 会调用 cleanupManagers() 来关闭所有设备
  580. api->shutdown();
  581. LOG_INFO() << "soft_bus 资源清理完成";
  582. }
  583. // 断开 daemon 连接(删除对象会触发析构函数,自动注销客户端)
  584. if (m_daemonClient) {
  585. delete m_daemonClient;
  586. m_daemonClient = nullptr;
  587. LOG_INFO() << "已断开 daemon 连接";
  588. }
  589. // 接受关闭事件,退出应用程序
  590. // 应用程序退出时,main.cpp 中的 CoreService::shutdown() 会被调用
  591. event->accept();
  592. // 退出应用程序(这会触发 main.cpp 中的 CoreService::shutdown())
  593. QApplication::quit();
  594. }