refactor: 整理页面的目录结构

.env

@@ -19,7 +19,7 @@ VITE_LAMP_PASSWORD = fjoc(1KHP(Ls&Bje)C
 VITE_LAMP_AUTHORIZATION = Y3VlZGVzX2FkbWluOmN1ZWRlc19hZG1pbl9zZWNyZXQ=
 
 # 当需要重置localStorage时, 修改此变量
-VITE_STORAGE_VERSION = 5
+VITE_STORAGE_VERSION = 3
 
 # 调试码
 VITE_DEBUG_CODE = ndm_debug

README.md

@@ -40,145 +40,18 @@ pnpm build
 
 在执行 `pnpm build` 之前，你可以在 `package.json` 中修改 `version` 字段，将其设置为你期望的版本号，构建完成后，项目的根目录中除了 `dist` 目录外，还会生成三个压缩包，文件名的格式统一为 `ndm-web-platform_v<version>_<datetime>`，文件格式则分别为 `zip`、`tar`、`tar.gz`。
 
-## 业务结构
-
-所有业务相关的页面都在 `src/pages` 目录下，路由配置在 `src/router/index.ts` 文件，除登录页之外，其余页面都作为 `src/layouts/app-layout.vue` 的子路由。
-
-```bash
-src/
-  router/
-    index.ts                   # 路由配置文件
-  layouts/
-    app-layout.vue             # 布局
-  pages/
-    login/
-      login-page.vue           # 登录页面
-    station/
-      station-page.vue         # 车站状态页面(首页)
-    device/
-      device-page.vue          # 设备诊断页面
-    alarm/
-      alarm-ignore-page.vue    # 告警忽略管理页面
-      alarm-log-page.vue       # 设备告警记录页面
-    log/
-      call-log-page.vue        # 上级调用日志页面
-      vimp-log-page.vue        # 视频平台日志页面
-    permission/
-      permission-page.vue      # 权限管理页面
-    error/
-      not-found-page.vue       # 404 页面
-```
-
-## 数据轮询
-
-由于后端服务的架构限制，需要前端向所有车站服务依次发送请求来获取数据，需要获取的数据包含车站状态、设备数据以及告警数据，因此需要设计一套数据轮询方案，定期从所有车站服务获取数据。
-
-在项目中，`src/composables/query/` 目录下是所有数据轮询相关的代码，其中与业务相关的代码主要包括：
-
-- `use-line-stations-query.ts`: 查询所有车站
-- `use-line-devices-query.ts`: 查询所有设备
-- `use-line-alarms-query.ts`: 查询所有告警
-- `use-user-permission-query.ts`: 查询用户权限
-
-在描述整个数据轮询流程之前，我们要明确项目中必须存在的几个关键概念：
-
-- 车站相关：车站query + 车站store
-- 设备相关：设备query + 设备store
-- 告警相关：告警query + 告警store
-- 权限相关：权限query + 权限store
-
-整个数据轮询流程采用“单点驱动 + 变更监听 + 级联触发”的模式，如下图所示。
-
-![数据轮询流程](./docs/assets/query-chain.png)
-
-1. 轮询入口：车站query
-   - 触发条件：以120秒的周期自动轮询车站列表
-   - 数据流向：车站store
-2. 核心调度：权限query
-   - 触发条件：车站query执行后触发
-   - 数据流向：权限store，并计算当前用户在各车站的权限
-   - 数据监听：监听车站和权限变化，触发设备query和告警query
-3. 设备query & 告警query
-   - 触发条件：被动触发，由权限query主动调用
-   - 数据流向：设备store & 告警store
-
 ## 调试模式
 
-在设置面板中有一系列与调试模式有关的设置项，主要用于开发和故障排查。
+在调试模式中，用户可以查看设备的原始诊断数据，也可以对轮询器进行控制，或者启用离线开发模式，系统不会自动调用一些主动触发的请求。
 
-### 开启方式
+### 开启调试模式
 
-调试模式默认隐藏，通过以下方式开启：
+在非登录页的任意页面中，使用键盘组合键 `Ctrl+Alt+D`，系统会弹出一个输入框，输入环境变量 `.env` 中的 `VITE_DEBUG_CODE` 对应的值即可开启调试模式，如需关闭调试模式，再次使用上述组合键并点击 `确认` 按钮即可。
 
-1. 使用快捷键 `Ctrl + Alt + D` 唤起验证弹窗
+注意调试模式与其内部的功能之间没有联动关系，例如在开启调试模式后可以关闭轮询或者启用离线开发模式，但是在关闭调试模式后，轮询不会重新被开启，离线开发模式也不会被关闭，因此在关闭离线开发模式前，请务必确保系统处于正确的运行状态下。
-2. 输入授权码进行验证（授权码对应环境变量 `.env` 中的 `VITE_DEBUG_CODE`）
-3. 验证通过后，在“系统设置”面板中会出现 **调试** 分组
 
-### 设置项说明
+### 关于离线开发模式
 
-#### 数据设置
+由于离线开发模式涉及到登录操作，因此项目中将离线开发模式暴露到了全局变量 `window.$offlineDev` 中，允许在登录页中直接开启离线开发模式。
 
-- **显示设备原始数据**
+如果你第一次启动这个项目，系统在正常情况下会先跳转至登录页，此时如果希望开启离线模式，可以直接打开浏览器的开发者工具，在控制台输入 `window.$offlineDev.value = true` 即可，系统会直接跳转到首页。
-  - 控制是否在设备详情页显示“原始数据”标签页
-  - 开启后可查看设备接口返回的原始 JSON 数据，便于排查字段缺失或格式错误
-
-#### 网络设置
-
-- **轮询车站**
-  - 控制是否定时拉取车站状态，进而触发权限、设备及告警数据的更新
-  - 关闭后将暂停所有业务数据的自动轮询机制
-- **主动请求**
-  - 控制组件挂载时是否自动发起数据请求
-  - 涵盖设备在线状态检测、用户登录验证等逻辑，关闭后组件在初始化时将不再自动拉取数据
-- **订阅消息**
-  - 控制是否通过 WebSocket (STOMP) 接收实时告警或状态推送
-  - 关闭后将不再处理后端推送的实时消息
-- **模拟用户**
-  - 开启后使用内置的超管用户绕过登录
-  - 开启时会自动进入调试模式，便于开发环境快速测试
-
-#### 数据库设置
-
-- **直接操作本地数据库**
-  - 控制某些业务逻辑（如交换机端口、安防箱回路）是否直接读写本地 IndexedDB
-  - 用于在无后端环境或特定测试场景下验证本地数据逻辑
-
-## 离线开发
-
-项目支持在无后端服务的情况下正常启动，具体操作取决于你的本地环境是否已有历史数据。
-
-### 场景一：已有本地缓存
-
-如果你的浏览器曾接入过现场环境，IndexedDB 中已保存了车站、设备等数据，只需在设置中关闭网络请求即可进入离线模式：
-
-1. 开启调试模式（`Ctrl + Alt + D`）。
-2. 在“网络设置”中，关闭 **轮询车站**、**主动请求** 和 **订阅消息**。
-3. 此时平台将停止向后端发起请求，直接展示本地缓存的历史数据。
-
-### 场景二：全新环境启动（新人推荐）
-
-如果你是首次拉取项目且无法连接后端，需要按以下步骤操作：
-
-1. **模拟登录**
-   在登录页按 `F12` 打开控制台，输入以下命令强制进入平台：
-
-   ```javascript
-   window.$mockUser.value = true;
-   ```
-
-   执行后平台将自动完成以下操作：
-   - 注入测试 Token 和管理员身份信息
-   - 关闭所有网络请求（轮询、主动请求、消息订阅）
-   - 开启调试模式
-   - 自动跳转至平台首页
-
-2. **导入模拟数据**
-   进入平台后，页面默认为空。需导入预设数据以填充内容：
-   - 打开“系统设置”（已自动开启调试模式）。
-   - 在 **调试** -> **数据库设置** 中，勾选 **直接操作本地数据库**。
-   - 点击该选项下方的 **导入数据** 按钮。
-   - 依次导入项目根目录 `docs/data/` 下的三个文件：
-     - `ndm-station-store.json`（车站数据）
-     - `ndm-device-store.json`（设备数据）
-     - `ndm-alarm-store.json`（告警数据）
-       > **注意**：每次导入一个文件后，平台会自动刷新页面以应用数据。请等待刷新完成后，重新打开设置面板导入下一个文件。

docs/data/ndm-station-store.json

@@ -1,203 +0,0 @@
-{
-  "stations": [
-    {
-      "code": "1075",
-      "name": "吴中路控制中心",
-      "online": true,
-      "ip": "10.18.128.10",
-      "occ": true
-    },
-    {
-      "code": "1001",
-      "name": "虹桥火车站",
-      "online": true,
-      "ip": "10.18.129.10"
-    },
-    {
-      "code": "1002",
-      "name": "虹桥2号航站楼",
-      "online": true,
-      "ip": "10.18.131.10"
-    },
-    {
-      "code": "1003",
-      "name": "虹桥一号航站楼",
-      "online": true,
-      "ip": "10.18.133.10"
-    },
-    {
-      "code": "1004",
-      "name": "上海动物园",
-      "online": true,
-      "ip": "10.18.135.10"
-    },
-    {
-      "code": "1005",
-      "name": "龙溪路",
-      "online": true,
-      "ip": "10.18.137.10"
-    },
-    {
-      "code": "1006",
-      "name": "水城路",
-      "online": true,
-      "ip": "10.18.139.10"
-    },
-    {
-      "code": "1007",
-      "name": "伊犁路",
-      "online": true,
-      "ip": "10.18.141.10"
-    },
-    {
-      "code": "1008",
-      "name": "宋园路",
-      "online": true,
-      "ip": "10.18.143.10"
-    },
-    {
-      "code": "1009",
-      "name": "虹桥路",
-      "online": true,
-      "ip": "10.18.145.10"
-    },
-    {
-      "code": "1010",
-      "name": "交通大学",
-      "online": true,
-      "ip": "10.18.147.10"
-    },
-    {
-      "code": "1011",
-      "name": "图书馆",
-      "online": true,
-      "ip": "10.18.149.10"
-    },
-    {
-      "code": "1012",
-      "name": "陕西南路",
-      "online": true,
-      "ip": "10.18.151.10"
-    },
-    {
-      "code": "1013",
-      "name": "新天地",
-      "online": true,
-      "ip": "10.18.153.10"
-    },
-    {
-      "code": "1014",
-      "name": "老西门",
-      "online": true,
-      "ip": "10.18.155.10"
-    },
-    {
-      "code": "1015",
-      "name": "豫园",
-      "online": true,
-      "ip": "10.18.157.10"
-    },
-    {
-      "code": "1016",
-      "name": "南京东路",
-      "online": true,
-      "ip": "10.18.159.10"
-    },
-    {
-      "code": "1017",
-      "name": "天潼路",
-      "online": true,
-      "ip": "10.18.161.10"
-    },
-    {
-      "code": "1018",
-      "name": "四川北路",
-      "online": true,
-      "ip": "10.18.163.10"
-    },
-    {
-      "code": "1019",
-      "name": "海伦路",
-      "online": true,
-      "ip": "10.18.165.10"
-    },
-    {
-      "code": "1020",
-      "name": "邮电新村",
-      "online": true,
-      "ip": "10.18.167.10"
-    },
-    {
-      "code": "1021",
-      "name": "四平路",
-      "online": true,
-      "ip": "10.18.169.10"
-    },
-    {
-      "code": "1022",
-      "name": "同济大学",
-      "online": true,
-      "ip": "10.18.171.10"
-    },
-    {
-      "code": "1023",
-      "name": "国权路",
-      "online": true,
-      "ip": "10.18.173.10"
-    },
-    {
-      "code": "1024",
-      "name": "五角场",
-      "online": true,
-      "ip": "10.18.175.10"
-    },
-    {
-      "code": "1025",
-      "name": "江湾体育场",
-      "online": true,
-      "ip": "10.18.177.10"
-    },
-    {
-      "code": "1026",
-      "name": "三门路",
-      "online": true,
-      "ip": "10.18.179.10"
-    },
-    {
-      "code": "1027",
-      "name": "殷高东路",
-      "online": true,
-      "ip": "10.18.181.10"
-    },
-    {
-      "code": "1028",
-      "name": "新江湾城",
-      "online": true,
-      "ip": "10.18.183.10"
-    },
-    {
-      "code": "1029",
-      "name": "航中路",
-      "online": true,
-      "ip": "10.18.185.10"
-    },
-    {
-      "code": "1030",
-      "name": "紫藤路",
-      "online": true,
-      "ip": "10.18.187.10"
-    },
-    {
-      "code": "1031",
-      "name": "龙柏新村",
-      "online": true,
-      "ip": "10.18.189.10"
-    },
-    {
-      "code": "1032",
-      "name": "吴中路基地",
-      "online": true,
-      "ip": "10.18.244.10"
-    }
-  ]
-}

src/App.vue

@@ -7,10 +7,10 @@ import { dateZhCN, NConfigProvider, NDialogProvider, NLoadingBarProvider, NMessa
 import { storeToRefs } from 'pinia';
 
 const settingStore = useSettingStore();
-const { themeMode, mockUser } = storeToRefs(settingStore);
+const { themeMode, offlineDev } = storeToRefs(settingStore);
 
 // 允许通过控制台启用离线开发模式 (登录页适用)
-window.$mockUser = mockUser;
+window.$offlineDev = offlineDev;
 
 useVersionCheckQuery();
 </script>

src/apis/model/biz/entity/index.ts

@@ -1,5 +1,5 @@
 import type { Nullable, Optional } from '@/types';
-import type { ReduceForPageQuery, ReduceForSaveVO, ReduceForUpdateVO } from '../../schema';
+import type { ReduceForPageQuery, ReduceForSaveVO, ReduceForUpdateVO } from '../../types';
 import type { NdmAlarmHost } from './alarm';
 import type { NdmSecurityBox, NdmSwitch } from './other';
 import type { NdmNvr } from './storage';

src/apis/model/index.ts

@@ -1,5 +1,5 @@
 export * from './base';
 export * from './biz';
 export * from './common';
-export * from './schema';
 export * from './system';
+export * from './types';

src/apis/request/biz/log/ndm-record-check.ts

@@ -48,13 +48,3 @@ export const reloadAllRecordCheckApi = async (dayOffset: number, options?: { sta
   if (!data) throw new Error(`${data}`);
   return data;
 };
-
-export const batchExportRecordCheckApi = async (params: { checkDuration: number; gapSeconds: number; stationCode: Station['code'][] }, options?: { signal?: AbortSignal }) => {
-  const { signal } = options ?? {};
-  const { checkDuration, gapSeconds, stationCode } = params;
-  const client = userClient;
-  const endpoint = `/api/ndm/ndmRecordCheck/batchExportByTemplate`;
-  const resp = await client.post<Blob>(endpoint, { checkDuration, gapSeconds, stationCode }, { responseType: 'blob', retRaw: true, signal });
-  const data = unwrapResponse(resp);
-  return data;
-};

src/apis/request/biz/other/ndm-permission.ts

@@ -71,13 +71,3 @@ export const deletePermissionApi = async (ids: string[], options?: { stationCode
   const result = unwrapResponse(resp);
   return result;
 };
-
-export const modifyPermissionApi = async (params: { employeeId: string; saveList: NdmPermissionSaveVO[]; removeList: string[] }, options?: { stationCode?: Station['code']; signal?: AbortSignal }) => {
-  const { stationCode, signal } = options ?? {};
-  const client = stationCode ? ndmClient : userClient;
-  const prefix = stationCode ? `/${stationCode}` : '';
-  const endpoint = `${prefix}/api/ndm/ndmPermission/modify`;
-  const resp = await client.post<boolean>(endpoint, params, { signal });
-  const result = unwrapResponse(resp);
-  return result;
-};

src/components/device/device-card/components/current-diag/device-hardware-card.vue

@@ -17,7 +17,7 @@ const props = defineProps<{
 const { cpuUsage, memUsage, diskUsage, runningTime, cpuUsageLabel, memUsageLabel, diskUsageLabel, runningTimeLabel } = toRefs(props);
 
 const showCard = computed(() => {
-  return Object.values({ cpuUsage, memUsage, diskUsage, runningTime }).some((refValue) => !!refValue.value);
+  return Object.values({ cpuUsage, memUsage, diskUsage, runningTime }).some((value) => !!value);
 });
 
 const cpuPercent = computed(() => {

src/components/device/device-card/components/current-diag/nvr-record-card.vue

@@ -1,58 +1,34 @@
 <script setup lang="ts">
-import { getChannelListApi, getRecordCheckApi, reloadAllRecordCheckApi, reloadRecordCheckApi, type NdmNvrResultVO, type RecordItem, type Station } from '@/apis';
+import { getChannelListApi, getRecordCheckApi, reloadAllRecordCheckApi, reloadRecordCheckApi, type NdmNvrResultVO, type NdmRecordCheck, type RecordItem, type Station } from '@/apis';
 import { exportRecordDiagCsv, transformRecordChecks } from '@/helpers';
-import { useSettingStore } from '@/stores';
+import { useStationStore } from '@/stores';
 import { parseErrorFeedback } from '@/utils';
-import { useMutation, useQuery, useQueryClient } from '@tanstack/vue-query';
+import { useMutation } from '@tanstack/vue-query';
 import { isCancel } from 'axios';
 import dayjs from 'dayjs';
 import { DownloadIcon, RotateCwIcon } from 'lucide-vue-next';
 import { NButton, NCard, NFlex, NIcon, NPagination, NPopconfirm, NPopover, NRadioButton, NRadioGroup, NTooltip, useThemeVars } from 'naive-ui';
 import { storeToRefs } from 'pinia';
-import { computed, onBeforeUnmount, ref, toRefs, watch } from 'vue';
+import { computed, onBeforeUnmount, onMounted, ref, toRefs, watch } from 'vue';
 
 const props = defineProps<{
   ndmDevice: NdmNvrResultVO;
   station: Station;
 }>();
 
-const settingStore = useSettingStore();
-const { activeRequests } = storeToRefs(settingStore);
-
 const themeVars = useThemeVars();
 
-const queryClient = useQueryClient();
+const stationStore = useStationStore();
+const { stations } = storeToRefs(stationStore);
 
 const { ndmDevice, station } = toRefs(props);
 
+const recordChecks = ref<NdmRecordCheck[]>([]);
+
 const lossInput = ref<number>(0);
 
-const abortController = ref<AbortController>(new AbortController());
-
-const NVR_RECORD_CHECK_KEY = 'nvr_record_check_query';
-
-const {
-  data: recordChecks,
-  isFetching: loading,
-  refetch: refetchRecordChecks,
-} = useQuery({
-  queryKey: computed(() => [NVR_RECORD_CHECK_KEY, ndmDevice.value.id, ndmDevice.value.lastDiagTime]),
-  enabled: computed(() => activeRequests.value),
-  refetchInterval: 30 * 1000,
-  gcTime: 0,
-  queryFn: async ({ signal }) => {
-    const checks = await getRecordCheckApi(ndmDevice.value, 90, [], { stationCode: station.value.code, signal });
-    return checks;
-  },
-});
-watch(activeRequests, (active) => {
-  if (!active) {
-    queryClient.cancelQueries({ queryKey: [NVR_RECORD_CHECK_KEY] });
-  }
-});
-
 const recordDiags = computed(() => {
-  return transformRecordChecks(recordChecks.value ?? []).filter((recordDiag) => {
+  return transformRecordChecks(recordChecks.value).filter((recordDiag) => {
     if (lossInput.value === 0) {
       return true;
     } else if (lossInput.value === 1) {
@@ -64,6 +40,26 @@ const recordDiags = computed(() => {
   });
 });
 
+const abortController = ref<AbortController>(new AbortController());
+
+const { mutate: getRecordCheckByParentId, isPending: loading } = useMutation({
+  mutationFn: async () => {
+    abortController.value.abort();
+    abortController.value = new AbortController();
+    const checks = await getRecordCheckApi(ndmDevice.value, 90, [], { stationCode: station.value.code, signal: abortController.value.signal });
+    return checks;
+  },
+  onSuccess: (checks) => {
+    recordChecks.value = checks;
+  },
+  onError: (error) => {
+    if (isCancel(error)) return;
+    console.error(error);
+    const errorFeedback = parseErrorFeedback(error);
+    window.$message.error(errorFeedback);
+  },
+});
+
 const { mutate: reloadAllRecordCheck, isPending: reloading } = useMutation({
   mutationFn: async () => {
     abortController.value.abort();
@@ -82,7 +78,9 @@ const { mutate: reloadAllRecordCheck, isPending: reloading } = useMutation({
 });
 
 const onExportRecordCheck = () => {
-  exportRecordDiagCsv(recordDiags.value, station.value.name);
+  const code = station.value.code;
+  const stationName = stations.value.find((station) => station.code === code)?.name ?? '';
+  exportRecordDiagCsv(recordDiags.value, stationName);
 };
 
 const page = ref(1);
@@ -123,7 +121,7 @@ const { mutate: reloadRecordCheckByGbId } = useMutation({
     }
   },
   onSuccess: () => {
-    refetchRecordChecks();
+    getRecordCheckByParentId();
   },
   onError: (error) => {
     if (isCancel(error)) return;
@@ -133,6 +131,20 @@ const { mutate: reloadRecordCheckByGbId } = useMutation({
   },
 });
 
+onMounted(() => {
+  getRecordCheckByParentId();
+});
+
+watch(
+  () => ndmDevice.value.id,
+  (devieDbId) => {
+    if (devieDbId) {
+      recordChecks.value = [];
+      getRecordCheckByParentId();
+    }
+  },
+);
+
 onBeforeUnmount(() => {
   abortController.value.abort();
 });
@@ -157,7 +169,7 @@ onBeforeUnmount(() => {
       <NFlex>
         <NTooltip trigger="hover">
           <template #trigger>
-            <NButton size="small" quaternary circle :loading="loading" @click="() => refetchRecordChecks()">
+            <NButton size="small" quaternary circle :loading="loading" @click="() => getRecordCheckByParentId()">
               <template #icon>
                 <NIcon :component="RotateCwIcon" />
               </template>

src/components/device/device-card/components/current-diag/security-box-circuit-card.vue

@@ -13,9 +13,7 @@ import {
   type Station,
 } from '@/apis';
 import { SecurityBoxCircuitLinkModal } from '@/components';
-import { usePermission } from '@/composables';
 import { SELECT_DEVICE_FN_INJECTION_KEY } from '@/constants';
-import { PERMISSION_TYPE_LITERALS } from '@/enums';
 import { useDeviceStore, useSettingStore } from '@/stores';
 import { parseErrorFeedback } from '@/utils';
 import { useMutation } from '@tanstack/vue-query';
@@ -40,9 +38,7 @@ const deviceStore = useDeviceStore();
 const { lineDevices } = storeToRefs(deviceStore);
 
 const settingStore = useSettingStore();
-const { useLocalDB } = storeToRefs(settingStore);
+const { offlineDev } = storeToRefs(settingStore);
-
-const { hasPermission } = usePermission();
 
 const { ndmDevice, station, circuits } = toRefs(props);
 
@@ -227,7 +223,6 @@ const onSelectDropdownOption = (key: string, option: DropdownOption) => {
 const onContextmenu = (payload: PointerEvent, circuitIndex: number) => {
   payload.stopPropagation();
   payload.preventDefault();
-  if (!hasPermission(station.value.code, PERMISSION_TYPE_LITERALS.OPERATION)) return;
   const { clientX, clientY } = payload;
   contextmenu.value = { x: clientX, y: clientY, circuitIndex };
   showContextmenu.value = true;
@@ -263,8 +258,8 @@ const { mutate: unlinkDevice } = useMutation({
     delete modifiedUpperLinkDescription.downstream?.[circuitIndex];
     modifiedUpperDevice.linkDescription = JSON.stringify(modifiedUpperLinkDescription);
 
-    // 3. 发起update请求并获取最新的设备详情（使用本地数据库时直接修改本地数据）
+    // 3. 发起update请求并获取最新的设备详情（离线模式下直接修改本地数据）
-    if (useLocalDB.value) {
+    if (offlineDev.value) {
       return { upperDevice: modifiedUpperDevice, lowerDevice: modifiedLowerDevice };
     }
     const stationCode = station.value.code;

src/components/device/device-card/components/current-diag/security-box-circuit-link-modal.vue

@@ -23,7 +23,7 @@ const show = defineModel<boolean>('show', { default: false });
 const deviceStore = useDeviceStore();
 
 const settingStore = useSettingStore();
-const { useLocalDB } = storeToRefs(settingStore);
+const { offlineDev } = storeToRefs(settingStore);
 
 const { ndmDevice, station, circuitIndex } = toRefs(props);
 
@@ -150,8 +150,8 @@ const { mutate: linkPortToDevice, isPending: linking } = useMutation({
     }
     modifiedLowerDevice.linkDescription = JSON.stringify(modifiedLowerDeviceLinkDescription);
 
-    // 3. 发起update请求并获取最新的设备详情（使用本地数据库时直接修改本地数据）
+    // 3. 发起update请求并获取最新的设备详情（离线模式下直接修改本地数据）
-    if (useLocalDB.value) {
+    if (offlineDev.value) {
       return { upperDevice: modifiedUpperDevice, lowerDevice: modifiedLowerDevice };
     }
     const stationCode = station.value.code;

src/components/device/device-card/components/current-diag/switch-port-card.vue

@@ -1,9 +1,7 @@
 <script setup lang="ts">
 import { detailDeviceApi, updateDeviceApi, type LinkDescription, type NdmDeviceResultVO, type NdmSwitchLinkDescription, type NdmSwitchPortInfo, type NdmSwitchResultVO, type Station } from '@/apis';
 import { SwitchPortLinkModal } from '@/components';
-import { usePermission } from '@/composables';
 import { SELECT_DEVICE_FN_INJECTION_KEY } from '@/constants';
-import { PERMISSION_TYPE_LITERALS } from '@/enums';
 import { getPortStatusValue, transformPortSpeed } from '@/helpers';
 import { useDeviceStore, useSettingStore } from '@/stores';
 import { parseErrorFeedback } from '@/utils';
@@ -27,9 +25,7 @@ const deviceStore = useDeviceStore();
 const { lineDevices } = storeToRefs(deviceStore);
 
 const settingStore = useSettingStore();
-const { useLocalDB } = storeToRefs(settingStore);
+const { offlineDev } = storeToRefs(settingStore);
-
-const { hasPermission } = usePermission();
 
 const { ndmDevice, station, ports } = toRefs(props);
 
@@ -176,7 +172,6 @@ const onSelectDropdownOption = (key: string, option: DropdownOption) => {
 const onContextmenu = (payload: PointerEvent, port: NdmSwitchPortInfo) => {
   payload.stopPropagation();
   payload.preventDefault();
-  if (!hasPermission(station.value.code, PERMISSION_TYPE_LITERALS.OPERATION)) return;
   const { clientX, clientY } = payload;
   contextmenu.value = { x: clientX, y: clientY, port };
   showContextmenu.value = true;
@@ -213,8 +208,8 @@ const { mutate: unlinkDevice } = useMutation({
     delete modifiedUpperLinkDescription.downstream?.[port.portName];
     modifiedUpperDevice.linkDescription = JSON.stringify(modifiedUpperLinkDescription);
 
-    // 3. 发起update请求并获取最新的设备详情（使用本地数据库时直接修改本地数据）
+    // 3. 发起update请求并获取最新的设备详情（离线模式下直接修改本地数据）
-    if (useLocalDB.value) {
+    if (offlineDev.value) {
       return { upperDevice: modifiedUpperDevice, lowerDevice: modifiedLowerDevice };
     }
     const stationCode = station.value.code;

src/components/device/device-card/components/current-diag/switch-port-link-modal.vue

@@ -32,7 +32,7 @@ const show = defineModel<boolean>('show', { default: false });
 const deviceStore = useDeviceStore();
 
 const settingStore = useSettingStore();
-const { useLocalDB } = storeToRefs(settingStore);
+const { offlineDev } = storeToRefs(settingStore);
 
 const { ndmDevice, station, port } = toRefs(props);
 
@@ -160,8 +160,8 @@ const { mutate: linkPortToDevice, isPending: linking } = useMutation({
     }
     modifiedLowerDevice.linkDescription = JSON.stringify(modifiedLowerDeviceLinkDescription);
 
-    // 3. 发起update请求并获取最新的设备详情（使用本地数据库时直接修改本地数据）
+    // 3. 发起update请求并获取最新的设备详情（离线模式下直接修改本地数据）
-    if (useLocalDB.value) {
+    if (offlineDev.value) {
       return { upperDevice: modifiedUpperDevice, lowerDevice: modifiedLowerDevice };
     }
     const stationCode = station.value.code;

src/components/device/device-card/ndm-alarm-host/alarm-host-card.vue

@@ -18,7 +18,7 @@ const route = useRoute();
 const router = useRouter();
 
 const settingStore = useSettingStore();
-const { showDeviceRawData } = storeToRefs(settingStore);
+const { debugModeEnabled } = storeToRefs(settingStore);
 
 const { hasPermission } = usePermission();
 
@@ -35,8 +35,8 @@ const activeTabName = ref('当前诊断');
 const onTabChange = (name: string) => {
   activeTabName.value = name;
 };
-watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
+watch([ndmDevice, debugModeEnabled], ([newDevice, enabled], [oldDevice]) => {
-  if (newDevice.id !== oldDevice.id || (!showRaw && activeTabName.value === '原始数据')) {
+  if (newDevice.id !== oldDevice.id || !enabled) {
     activeTabName.value = '当前诊断';
   }
 });
@@ -50,7 +50,7 @@ watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
         <NTab name="当前诊断">当前诊断</NTab>
         <NTab name="历史诊断">历史诊断</NTab>
         <NTab v-if="hasPermission(station.code, PERMISSION_TYPE_LITERALS.OPERATION)" name="修改设备">修改设备</NTab>
-        <NTab v-if="showDeviceRawData" name="原始数据">原始数据</NTab>
+        <NTab v-if="debugModeEnabled" name="原始数据">原始数据</NTab>
       </NTabs>
     </template>
     <template #default>

src/components/device/device-card/ndm-camera/camera-card.vue

@@ -18,7 +18,7 @@ const route = useRoute();
 const router = useRouter();
 
 const settingStore = useSettingStore();
-const { showDeviceRawData } = storeToRefs(settingStore);
+const { debugModeEnabled } = storeToRefs(settingStore);
 
 const { hasPermission } = usePermission();
 
@@ -35,8 +35,8 @@ const activeTabName = ref('当前诊断');
 const onTabChange = (name: string) => {
   activeTabName.value = name;
 };
-watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
+watch([ndmDevice, debugModeEnabled], ([newDevice, enabled], [oldDevice]) => {
-  if (newDevice.id !== oldDevice.id || (!showRaw && activeTabName.value === '原始数据')) {
+  if (newDevice.id !== oldDevice.id || !enabled) {
     activeTabName.value = '当前诊断';
   }
 });
@@ -50,7 +50,7 @@ watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
         <NTab name="当前诊断">当前诊断</NTab>
         <NTab name="历史诊断">历史诊断</NTab>
         <NTab v-if="hasPermission(station.code, PERMISSION_TYPE_LITERALS.OPERATION)" name="修改设备">修改设备</NTab>
-        <NTab v-if="showDeviceRawData" name="原始数据">原始数据</NTab>
+        <NTab v-if="debugModeEnabled" name="原始数据">原始数据</NTab>
       </NTabs>
     </template>
     <template #default>

src/components/device/device-card/ndm-camera/camera-current-diag.vue

@@ -31,7 +31,7 @@ const props = defineProps<{
 }>();
 
 const settingStore = useSettingStore();
-const { activeRequests } = storeToRefs(settingStore);
+const { offlineDev } = storeToRefs(settingStore);
 
 const queryClient = useQueryClient();
 
@@ -49,7 +49,7 @@ const QUERY_KEY = 'camera-installation-area-query';
 
 const { data: installationArea } = useQuery({
   queryKey: computed(() => [QUERY_KEY, ndmDevice.value.gbCode, station.value.code]),
-  enabled: computed(() => activeRequests.value),
+  enabled: computed(() => !offlineDev.value),
   gcTime: 0,
   queryFn: async ({ signal }) => {
     const UNKNOWN_NAME = '-';
@@ -107,8 +107,8 @@ const { data: installationArea } = useQuery({
     return `${tier1Area.name}-${tier2Area.name}`;
   },
 });
-watch(activeRequests, (active) => {
+watch(offlineDev, (offline) => {
-  if (!active) {
+  if (offline) {
     queryClient.cancelQueries({ queryKey: [QUERY_KEY] });
   }
 });

src/components/device/device-card/ndm-decoder/decoder-card.vue

@@ -18,7 +18,7 @@ const route = useRoute();
 const router = useRouter();
 
 const settingStore = useSettingStore();
-const { showDeviceRawData } = storeToRefs(settingStore);
+const { debugModeEnabled } = storeToRefs(settingStore);
 
 const { hasPermission } = usePermission();
 
@@ -35,8 +35,8 @@ const activeTabName = ref('当前诊断');
 const onTabChange = (name: string) => {
   activeTabName.value = name;
 };
-watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
+watch([ndmDevice, debugModeEnabled], ([newDevice, enabled], [oldDevice]) => {
-  if (newDevice.id !== oldDevice.id || (!showRaw && activeTabName.value === '原始数据')) {
+  if (newDevice.id !== oldDevice.id || !enabled) {
     activeTabName.value = '当前诊断';
   }
 });
@@ -50,7 +50,7 @@ watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
         <NTab name="当前诊断">当前诊断</NTab>
         <NTab name="历史诊断">历史诊断</NTab>
         <NTab v-if="hasPermission(station.code, PERMISSION_TYPE_LITERALS.OPERATION)" name="修改设备">修改设备</NTab>
-        <NTab v-if="showDeviceRawData" name="原始数据">原始数据</NTab>
+        <NTab v-if="debugModeEnabled" name="原始数据">原始数据</NTab>
       </NTabs>
     </template>
     <template #default>

src/components/device/device-card/ndm-keyboard/keyboard-card.vue

@@ -18,7 +18,7 @@ const route = useRoute();
 const router = useRouter();
 
 const settingStore = useSettingStore();
-const { showDeviceRawData } = storeToRefs(settingStore);
+const { debugModeEnabled } = storeToRefs(settingStore);
 
 const { hasPermission } = usePermission();
 
@@ -35,8 +35,8 @@ const activeTabName = ref('当前诊断');
 const onTabChange = (name: string) => {
   activeTabName.value = name;
 };
-watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
+watch([ndmDevice, debugModeEnabled], ([newDevice, enabled], [oldDevice]) => {
-  if (newDevice.id !== oldDevice.id || (!showRaw && activeTabName.value === '原始数据')) {
+  if (newDevice.id !== oldDevice.id || !enabled) {
     activeTabName.value = '当前诊断';
   }
 });
@@ -50,7 +50,7 @@ watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
         <NTab name="当前诊断">当前诊断</NTab>
         <NTab name="历史诊断">历史诊断</NTab>
         <NTab v-if="hasPermission(station.code, PERMISSION_TYPE_LITERALS.OPERATION)" name="修改设备">修改设备</NTab>
-        <NTab v-if="showDeviceRawData" name="原始数据">原始数据</NTab>
+        <NTab v-if="debugModeEnabled" name="原始数据">原始数据</NTab>
       </NTabs>
     </template>
     <template #default>

src/components/device/device-card/ndm-nvr/nvr-card.vue

@@ -18,7 +18,7 @@ const route = useRoute();
 const router = useRouter();
 
 const settingStore = useSettingStore();
-const { showDeviceRawData } = storeToRefs(settingStore);
+const { debugModeEnabled } = storeToRefs(settingStore);
 
 const { hasPermission } = usePermission();
 
@@ -35,8 +35,8 @@ const activeTabName = ref('当前诊断');
 const onTabChange = (name: string) => {
   activeTabName.value = name;
 };
-watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
+watch([ndmDevice, debugModeEnabled], ([newDevice, enabled], [oldDevice]) => {
-  if (newDevice.id !== oldDevice.id || (!showRaw && activeTabName.value === '原始数据')) {
+  if (newDevice.id !== oldDevice.id || !enabled) {
     activeTabName.value = '当前诊断';
   }
 });
@@ -50,7 +50,7 @@ watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
         <NTab name="当前诊断">当前诊断</NTab>
         <NTab name="历史诊断">历史诊断</NTab>
         <NTab v-if="hasPermission(station.code, PERMISSION_TYPE_LITERALS.OPERATION)" name="修改设备">修改设备</NTab>
-        <NTab v-if="showDeviceRawData" name="原始数据">原始数据</NTab>
+        <NTab v-if="debugModeEnabled" name="原始数据">原始数据</NTab>
       </NTabs>
     </template>
     <template #default>

src/components/device/device-card/ndm-nvr/nvr-current-diag.vue

@@ -45,7 +45,7 @@ const diskArray = computed(() => lastDiagInfo.value?.info?.groupInfoList);
   <NFlex vertical>
     <DeviceHeaderCard :ndm-device="ndmDevice" :station="station" />
     <DeviceCommonCard :common-info="commonInfo" />
-    <DeviceHardwareCard :cpu-usage="cpuUsage" :mem-usage="memUsage" />
+    <DeviceHardwareCard v-if="!isNvrCluster(ndmDevice)" :cpu-usage="cpuUsage" :mem-usage="memUsage" />
     <NvrDiskCard :disk-health="diskHealth" :disk-array="diskArray" />
     <NvrRecordCard v-if="isNvrCluster(ndmDevice)" :ndm-device="ndmDevice" :station="station" />
   </NFlex>

src/components/device/device-card/ndm-security-box/security-box-card.vue

@@ -18,7 +18,7 @@ const route = useRoute();
 const router = useRouter();
 
 const settingStore = useSettingStore();
-const { showDeviceRawData } = storeToRefs(settingStore);
+const { debugModeEnabled } = storeToRefs(settingStore);
 
 const { hasPermission } = usePermission();
 
@@ -35,8 +35,8 @@ const activeTabName = ref('当前诊断');
 const onTabChange = (name: string) => {
   activeTabName.value = name;
 };
-watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
+watch([ndmDevice, debugModeEnabled], ([newDevice, enabled], [oldDevice]) => {
-  if (newDevice.id !== oldDevice.id || (!showRaw && activeTabName.value === '原始数据')) {
+  if (newDevice.id !== oldDevice.id || !enabled) {
     activeTabName.value = '当前诊断';
   }
 });
@@ -50,7 +50,7 @@ watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
         <NTab name="当前诊断">当前诊断</NTab>
         <NTab name="历史诊断">历史诊断</NTab>
         <NTab v-if="hasPermission(station.code, PERMISSION_TYPE_LITERALS.OPERATION)" name="修改设备">修改设备</NTab>
-        <NTab v-if="showDeviceRawData" name="原始数据">原始数据</NTab>
+        <NTab v-if="debugModeEnabled" name="原始数据">原始数据</NTab>
       </NTabs>
     </template>
     <template #default>

src/components/device/device-card/ndm-server/server-alive.vue

@@ -13,7 +13,7 @@ const props = defineProps<{
 }>();
 
 const settingStore = useSettingStore();
-const { activeRequests } = storeToRefs(settingStore);
+const { offlineDev } = storeToRefs(settingStore);
 
 const queryClient = useQueryClient();
 
@@ -25,7 +25,7 @@ const MEDIA_SERVER_ALIVE_QUERY_KEY = 'media-server-alive-query';
 const VIDEO_SERVER_ALIVE_QUERY_KEY = 'video-server-alive-query';
 const { data: isMediaServerAlive } = useQuery({
   queryKey: computed(() => [MEDIA_SERVER_ALIVE_QUERY_KEY, ndmDevice.value.id, ndmDevice.value.lastDiagTime]),
-  enabled: computed(() => activeRequests.value && deviceType.value === DEVICE_TYPE_LITERALS.ndmMediaServer),
+  enabled: computed(() => !offlineDev.value && deviceType.value === DEVICE_TYPE_LITERALS.ndmMediaServer),
   refetchInterval: 30 * 1000,
   gcTime: 0,
   queryFn: async ({ signal }) => {
@@ -35,15 +35,15 @@ const { data: isMediaServerAlive } = useQuery({
 });
 const { data: isSipServerAlive } = useQuery({
   queryKey: computed(() => [VIDEO_SERVER_ALIVE_QUERY_KEY, ndmDevice.value.id, ndmDevice.value.lastDiagTime]),
-  enabled: computed(() => activeRequests.value && deviceType.value === DEVICE_TYPE_LITERALS.ndmVideoServer),
+  enabled: computed(() => !offlineDev.value && deviceType.value === DEVICE_TYPE_LITERALS.ndmVideoServer),
   refetchInterval: 30 * 1000,
   gcTime: 0,
   queryFn: async ({ signal }) => {
     return await isSipServerAliveApi({ stationCode: station.value.code, signal });
   },
 });
-watch(activeRequests, (active) => {
+watch(offlineDev, (offline) => {
-  if (!active) {
+  if (offline) {
     queryClient.cancelQueries({ queryKey: [MEDIA_SERVER_ALIVE_QUERY_KEY] });
     queryClient.cancelQueries({ queryKey: [VIDEO_SERVER_ALIVE_QUERY_KEY] });
   }
@@ -56,7 +56,7 @@ watch(activeRequests, (active) => {
       <span>服务状态</span>
     </template>
     <template #default>
-      <template v-if="!activeRequests">
+      <template v-if="offlineDev">
         <span>-</span>
       </template>
       <template v-else>

src/components/device/device-card/ndm-server/server-card.vue

@@ -18,7 +18,7 @@ const route = useRoute();
 const router = useRouter();
 
 const settingStore = useSettingStore();
-const { showDeviceRawData } = storeToRefs(settingStore);
+const { debugModeEnabled } = storeToRefs(settingStore);
 
 const { hasPermission } = usePermission();
 
@@ -35,8 +35,8 @@ const activeTabName = ref('当前诊断');
 const onTabChange = (name: string) => {
   activeTabName.value = name;
 };
-watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
+watch([ndmDevice, debugModeEnabled], ([newDevice, enabled], [oldDevice]) => {
-  if (newDevice.id !== oldDevice.id || (!showRaw && activeTabName.value === '原始数据')) {
+  if (newDevice.id !== oldDevice.id || !enabled) {
     activeTabName.value = '当前诊断';
   }
 });
@@ -50,7 +50,7 @@ watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
         <NTab name="当前诊断">当前诊断</NTab>
         <NTab name="历史诊断">历史诊断</NTab>
         <NTab v-if="hasPermission(station.code, PERMISSION_TYPE_LITERALS.OPERATION)" name="修改设备">修改设备</NTab>
-        <NTab v-if="showDeviceRawData" name="原始数据">原始数据</NTab>
+        <NTab v-if="debugModeEnabled" name="原始数据">原始数据</NTab>
       </NTabs>
     </template>
     <template #default>

src/components/device/device-card/ndm-server/server-stream-push.vue

@@ -13,7 +13,7 @@ const props = defineProps<{
 }>();
 
 const settingStore = useSettingStore();
-const { activeRequests } = storeToRefs(settingStore);
+const { offlineDev } = storeToRefs(settingStore);
 
 const queryClient = useQueryClient();
 
@@ -27,7 +27,7 @@ const SERVER_STREAM_PUSH_KEY = 'server-stream-push-query';
 
 const { data: streamPushes } = useQuery({
   queryKey: computed(() => [SERVER_STREAM_PUSH_KEY, ndmDevice.value.id, ndmDevice.value.lastDiagTime]),
-  enabled: computed(() => activeRequests.value && showCard.value),
+  enabled: computed(() => !offlineDev.value && showCard.value),
   refetchInterval: 30 * 1000,
   gcTime: 0,
   queryFn: async ({ signal }) => {
@@ -35,8 +35,8 @@ const { data: streamPushes } = useQuery({
     return streamPushes;
   },
 });
-watch(activeRequests, (active) => {
+watch(offlineDev, (offline) => {
-  if (!active) {
+  if (offline) {
     queryClient.cancelQueries({ queryKey: [SERVER_STREAM_PUSH_KEY] });
   }
 });
@@ -70,7 +70,7 @@ const streamPushStat = computed(() => {
       <span>推流统计</span>
     </template>
     <template #default>
-      <template v-if="!activeRequests">
+      <template v-if="offlineDev">
         <span>-</span>
       </template>
       <template v-else>

src/components/device/device-card/ndm-switch/switch-card.vue

@@ -18,8 +18,7 @@ const route = useRoute();
 const router = useRouter();
 
 const settingStore = useSettingStore();
-const { showDeviceRawData } = storeToRefs(settingStore);
+const { debugModeEnabled } = storeToRefs(settingStore);
-
 const { hasPermission } = usePermission();
 
 const { ndmDevice, station } = toRefs(props);
@@ -35,8 +34,8 @@ const activeTabName = ref('当前诊断');
 const onTabChange = (name: string) => {
   activeTabName.value = name;
 };
-watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
+watch([ndmDevice, debugModeEnabled], ([newDevice, enabled], [oldDevice]) => {
-  if (newDevice.id !== oldDevice.id || (!showRaw && activeTabName.value === '原始数据')) {
+  if (newDevice.id !== oldDevice.id || !enabled) {
     activeTabName.value = '当前诊断';
   }
 });
@@ -50,7 +49,7 @@ watch([ndmDevice, showDeviceRawData], ([newDevice, showRaw], [oldDevice]) => {
         <NTab name="当前诊断">当前诊断</NTab>
         <NTab name="历史诊断">历史诊断</NTab>
         <NTab v-if="hasPermission(station.code, PERMISSION_TYPE_LITERALS.OPERATION)" name="修改设备">修改设备</NTab>
-        <NTab v-if="showDeviceRawData" name="原始数据">原始数据</NTab>
+        <NTab v-if="debugModeEnabled" name="原始数据">原始数据</NTab>
       </NTabs>
     </template>
     <template #default>

src/components/device/device-tree/device-tree.vue

@@ -4,7 +4,7 @@ import { useDeviceTree, usePermission, type UseDeviceTreeReturn } from '@/compos
 import { DEVICE_TYPE_NAMES, DEVICE_TYPE_LITERALS, tryGetDeviceType, type DeviceType, PERMISSION_TYPE_LITERALS } from '@/enums';
 import { isNvrCluster } from '@/helpers';
 import { useDeviceStore, usePermissionStore } from '@/stores';
-import { watchDebounced, watchImmediate } from '@vueuse/core';
+import { watchImmediate } from '@vueuse/core';
 import destr from 'destr';
 import { isFunction } from 'es-toolkit';
 import {
@@ -27,7 +27,7 @@ import {
   type TreeProps,
 } from 'naive-ui';
 import { storeToRefs } from 'pinia';
-import { computed, h, nextTick, onBeforeUnmount, onMounted, ref, toRefs, useTemplateRef, watch, type CSSProperties } from 'vue';
+import { computed, h, nextTick, onBeforeUnmount, ref, toRefs, useTemplateRef, watch, type CSSProperties } from 'vue';
 
 const props = defineProps<{
   /**
@@ -67,15 +67,15 @@ const {
   selectedStationCode,
   selectedDeviceType,
   selectedDevice,
-  syncFromRoute,
-  syncToRoute,
   selectDevice,
   // 设备管理
   exportDevice,
   exportDeviceTemplate,
   importDevice,
   deleteDevice,
-} = useDeviceTree();
+} = useDeviceTree({
+  syncRoute: computed(() => !!syncRoute.value),
+});
 
 // 将 `selectDevice` 函数暴露给父组件
 emit('exposeSelectDeviceFn', selectDevice);
@@ -91,7 +91,6 @@ const onSelectDevice = (device: NdmDeviceResultVO, stationCode: Station['code'])
 
 const permissionStore = usePermissionStore();
 const stations = computed(() => permissionStore.stations.VIEW ?? []);
-
 const deviceStore = useDeviceStore();
 const { lineDevices } = storeToRefs(deviceStore);
 
@@ -484,38 +483,11 @@ const onLocateDeviceTree = async () => {
 
   animated.value = true;
 };
-
+// 渲染全线设备树时，当选择的设备发生变化，则定位设备树
-// 当选择的设备发生变化时，定位设备树，并同步选中状态到路由参数
 // 暂时不考虑多次执行的问题，因为当选择的设备在设备树视口内时，不会发生滚动
-watch(selectedDevice, async (newDevice, oldDevice) => {
+watch(selectedDevice, async () => {
   if (!!station.value) return;
-  if (newDevice?.id === oldDevice?.id) return;
+  await onLocateDeviceTree();
-  // console.log('selectedDevice changed');
-  onLocateDeviceTree();
-  syncToRoute();
-});
-
-// 当全线设备发生变化时，从路由参数同步选中状态
-// 但lineDevices是shallowRef，因此需要深度侦听才能获取内部变化，
-// 而单纯的深度侦听又可能会引发性能问题，因此尝试使用防抖侦听
-watchDebounced(
-  lineDevices,
-  (newLineDevices) => {
-    if (syncRoute.value) {
-      // console.log('lineDevices changed');
-      syncFromRoute(newLineDevices);
-    }
-  },
-  {
-    debounce: 500,
-    deep: true,
-  },
-);
-
-onMounted(() => {
-  if (syncRoute.value) {
-    syncFromRoute(lineDevices.value);
-  }
 });
 </script>
 

src/components/global/settings-drawer/settings-drawer.vue

@@ -4,7 +4,7 @@ import { ThemeSwitch } from '@/components';
 import { usePermission } from '@/composables';
 import { NDM_ALARM_STORE_ID, NDM_DEVICE_STORE_ID, NDM_STATION_STORE_ID } from '@/constants';
 import { PERMISSION_TYPE_LITERALS } from '@/enums';
-import { useSettingStore, useStationStore } from '@/stores';
+import { usePollingStore, useSettingStore, useStationStore } from '@/stores';
 import { downloadByData, getAppEnvConfig, parseErrorFeedback, sleep } from '@/utils';
 import { useMutation } from '@tanstack/vue-query';
 import { useEventListener } from '@vueuse/core';
@@ -25,7 +25,7 @@ const { stations } = storeToRefs(stationStore);
 const occStation = computed(() => stations.value.find((station) => !!station.occ));
 
 const settingsStore = useSettingStore();
-const { menuCollpased, stationGridCols, debugMode, showDeviceRawData, pollingStations, activeRequests, subscribeMessages, mockUser, useLocalDB } = storeToRefs(settingsStore);
+const { menuCollpased, stationGridCols, debugModeEnabled, offlineDev } = storeToRefs(settingsStore);
 
 const { hasPermission } = usePermission();
 
@@ -132,11 +132,11 @@ const enableDebugMode = () => {
     return;
   }
   showDebugCodeModal.value = false;
-  debugMode.value = true;
+  settingsStore.enableDebugMode();
 };
 const disableDebugMode = () => {
   showDebugCodeModal.value = false;
-  debugMode.value = false;
+  settingsStore.disableDebugMode();
 };
 useEventListener('keydown', (event) => {
   const { ctrlKey, altKey, code } = event;
@@ -147,18 +147,28 @@ useEventListener('keydown', (event) => {
 
 const expectToShowDebugCodeInput = ref(false);
 const onModalAfterEnter = () => {
-  expectToShowDebugCodeInput.value = !debugMode.value;
+  expectToShowDebugCodeInput.value = !debugModeEnabled.value;
 };
 const onModalAfterLeave = () => {
   expectToShowDebugCodeInput.value = false;
   debugCode.value = '';
 };
 
+const pollingStore = usePollingStore();
+const { pollingEnabled } = storeToRefs(pollingStore);
+const onPollingEnabledUpdate = (enabled: boolean) => {
+  if (enabled) {
+    pollingStore.startPolling();
+  } else {
+    pollingStore.stopPolling();
+  }
+};
+
 type IndexedDbStoreId = typeof NDM_STATION_STORE_ID | typeof NDM_DEVICE_STORE_ID | typeof NDM_ALARM_STORE_ID;
 type IndexedDbStoreStates = {
   [NDM_STATION_STORE_ID]: { stations: Station[] };
   [NDM_DEVICE_STORE_ID]: { lineDevices: LineDevices };
-  [NDM_ALARM_STORE_ID]: { lineAlarms: LineAlarms };
+  [NDM_ALARM_STORE_ID]: { lineAlarms: LineAlarms; unreadLineAlarms: LineAlarms };
 };
 const exportFromIndexedDB = async <K extends IndexedDbStoreId>(storeId: K, options?: { errorMsg?: string }) => {
   const { errorMsg } = options ?? {};
@@ -171,9 +181,8 @@ const exportFromIndexedDB = async <K extends IndexedDbStoreId>(storeId: K, optio
 };
 const importToIndexedDB = async <K extends IndexedDbStoreId>(storeId: K, options?: { successMsg?: string; errorMsg?: string }) => {
   const { successMsg, errorMsg } = options ?? {};
-  pollingStations.value = false;
+  pollingStore.stopPolling();
-  activeRequests.value = false;
+  offlineDev.value = true;
-  subscribeMessages.value = false;
   const fileInput = document.createElement('input');
   fileInput.type = 'file';
   fileInput.accept = '.json';
@@ -196,9 +205,8 @@ const importToIndexedDB = async <K extends IndexedDbStoreId>(storeId: K, options
   };
 };
 const deleteFromIndexedDB = async (storeId: IndexedDbStoreId) => {
-  pollingStations.value = false;
+  pollingStore.stopPolling();
-  activeRequests.value = false;
+  offlineDev.value = true;
-  subscribeMessages.value = false;
   await localforage.removeItem(storeId).catch((error) => {
     window.$message.error(`${error}`);
     return;
@@ -267,14 +275,15 @@ const onSelectDropdownOption = (key: string, option: DropdownOption) => {
   }
 };
 
-watch([activeRequests, show], ([active, entered]) => {
+watch([offlineDev, show], ([offline, entered]) => {
-  if (!active) return;
+  if (!offline) {
-  if (entered) {
+    if (entered) {
-    getRetentionDays();
+      getRetentionDays();
-    getSnapStatus();
+      getSnapStatus();
-  } else {
+    } else {
-    abortControllers.value.retentionDays.abort();
+      abortControllers.value.retentionDays.abort();
-    abortControllers.value.snapStatus.abort();
+      abortControllers.value.snapStatus.abort();
+    }
   }
 });
 const onDrawerAfterEnter = () => {
@@ -325,33 +334,15 @@ const onDrawerAfterLeave = () => {
           </NFormItem>
         </template>
 
-        <template v-if="debugMode">
+        <template v-if="debugModeEnabled">
           <NDivider title-placement="center">调试</NDivider>
-          <NFormItem label="调试模式" label-placement="left">
+          <NFormItem label="启用轮询" label-placement="left">
-            <NSwitch size="small" v-model:value="debugMode" />
+            <NSwitch size="small" :value="pollingEnabled" @update:value="onPollingEnabledUpdate" />
           </NFormItem>
-          <NDivider title-placement="left" dashed>数据设置</NDivider>
+          <NFormItem label="离线开发" label-placement="left">
-          <NFormItem label="显示设备原始数据" label-placement="left">
+            <NSwitch size="small" v-model:value="offlineDev" />
-            <NSwitch size="small" v-model:value="showDeviceRawData" />
           </NFormItem>
-          <NDivider title-placement="left" dashed>网络设置</NDivider>
+          <NFormItem label="本地数据库" label-placement="left">
-          <NFormItem label="轮询车站" label-placement="left">
-            <NSwitch size="small" v-model:value="pollingStations" />
-          </NFormItem>
-          <NFormItem label="主动请求" label-placement="left">
-            <NSwitch size="small" v-model:value="activeRequests" />
-          </NFormItem>
-          <NFormItem label="订阅消息" label-placement="left">
-            <NSwitch size="small" v-model:value="subscribeMessages" />
-          </NFormItem>
-          <NFormItem label="模拟用户" label-placement="left">
-            <NSwitch size="small" v-model:value="mockUser" />
-          </NFormItem>
-          <NDivider title-placement="left" dashed>数据库设置</NDivider>
-          <NFormItem label="直接操作本地数据库" label-placement="left">
-            <NSwitch size="small" v-model:value="useLocalDB" />
-          </NFormItem>
-          <NFormItem label="数据操作" label-placement="left">
             <NFlex>
               <NDropdown trigger="click" :options="exportDropdownOptions" @select="onSelectDropdownOption">
                 <NButton secondary size="small">
@@ -391,7 +382,7 @@ const onDrawerAfterLeave = () => {
 
   <NModal v-model:show="showDebugCodeModal" preset="dialog" type="info" @after-enter="onModalAfterEnter" @after-leave="onModalAfterLeave">
     <template #header>
-      <NText v-if="!debugMode">请输入调试码</NText>
+      <NText v-if="!debugModeEnabled">请输入调试码</NText>
       <NText v-else>确认关闭调试模式</NText>
     </template>
     <template #default>
@@ -399,7 +390,7 @@ const onDrawerAfterLeave = () => {
     </template>
     <template #action>
       <NButton @click="showDebugCodeModal = false">取消</NButton>
-      <NButton v-if="!debugMode" type="primary" @click="enableDebugMode">启用</NButton>
+      <NButton v-if="!debugModeEnabled" type="primary" @click="enableDebugMode">启用</NButton>
       <NButton v-else type="primary" @click="disableDebugMode">确认</NButton>
     </template>
   </NModal>

src/components/global/theme-switch/theme-switch.vue

@@ -5,14 +5,14 @@ import { storeToRefs } from 'pinia';
 import type { ComponentInstance } from 'vue';
 
 const settingsStore = useSettingStore();
-const { darkMode } = storeToRefs(settingsStore);
+const { darkThemeEnabled } = storeToRefs(settingsStore);
 
 // 使外部能够获取NSwitch的类型提示
 defineExpose({} as ComponentInstance<typeof NSwitch>);
 </script>
 
 <template>
-  <NSwitch v-model:value="darkMode">
+  <NSwitch v-model:value="darkThemeEnabled">
     <template #unchecked-icon>
       <NIcon>
         <svg width="24" height="24" viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg">

src/components/permission/index.ts

@@ -1,6 +1 @@
-import type { ComponentInstance } from 'vue';
+export * from './permission-config-modal';
-import PermissionConfigModal from './permission-config-modal.vue';
-
-export type PermissionConfigModalProps = ComponentInstance<typeof PermissionConfigModal>['$props'];
-
-export { PermissionConfigModal };

src/components/permission/permission-config-modal.vue

@@ -1,302 +0,0 @@
-<script setup lang="ts">
-import { detailBaseEmployeeApi, modifyPermissionApi, pagePermissionApi, type BaseEmployeeResultVO, type NdmPermissionResultVO, type NdmPermissionSaveVO, type Station } from '@/apis';
-import { PERMISSION_TYPE_LITERALS, PERMISSION_TYPE_NAMES, type PermissionType } from '@/enums';
-import { useStationStore } from '@/stores';
-import { parseErrorFeedback } from '@/utils';
-import { useMutation } from '@tanstack/vue-query';
-import { objectEntries } from '@vueuse/core';
-import { isCancel } from 'axios';
-import { cloneDeep } from 'es-toolkit';
-import { NButton, NCheckbox, NDataTable, NFlex, NModal, NText, type DataTableColumn, type DataTableColumns } from 'naive-ui';
-import { storeToRefs } from 'pinia';
-import { computed, h, ref, toRefs } from 'vue';
-
-type NdmPermissionSaveOrResultVO = NdmPermissionSaveVO | NdmPermissionResultVO;
-
-const props = defineProps<{
-  employeeId?: string;
-}>();
-
-const stationStore = useStationStore();
-const { stations } = storeToRefs(stationStore);
-
-const show = defineModel<boolean>('show', { default: false });
-
-const { employeeId } = toRefs(props);
-
-const abortController = ref<AbortController>(new AbortController());
-
-const employee = ref<BaseEmployeeResultVO>();
-const { mutateAsync: getEmployeeAsync } = useMutation({
-  mutationFn: async () => {
-    abortController.value.abort();
-    abortController.value = new AbortController();
-
-    if (!employeeId.value) return;
-
-    const signal = abortController.value.signal;
-
-    const data = await detailBaseEmployeeApi(employeeId.value, { signal });
-    return data;
-  },
-  onSuccess: (data) => {
-    if (!data) return;
-    employee.value = data;
-  },
-  onError: (error) => {
-    if (isCancel(error)) return;
-    console.error(error);
-    const errorFeedback = parseErrorFeedback(error);
-    window.$message.error(errorFeedback);
-  },
-});
-
-// 从后端获取的原始权限列表
-const originalList = ref<NdmPermissionResultVO[]>([]);
-// 当前用户配置的权限列表
-const currentList = ref<NdmPermissionSaveOrResultVO[]>([]);
-
-const { mutate: getPermissions, isPending: permissionsLoading } = useMutation({
-  mutationFn: async () => {
-    if (!employeeId.value) throw new Error('员工ID不能为空');
-
-    abortController.value.abort();
-    abortController.value = new AbortController();
-
-    const signal = abortController.value.signal;
-
-    const data = await pagePermissionApi(
-      {
-        model: {
-          employeeId: employeeId.value,
-        },
-        current: 1,
-        size: Object.keys(PERMISSION_TYPE_LITERALS).length * stations.value.length,
-      },
-      { signal },
-    );
-
-    return data;
-  },
-  onSuccess: (data) => {
-    if (!data) return;
-    const { records } = data;
-    originalList.value = cloneDeep(records);
-    currentList.value = cloneDeep(records);
-  },
-  onError: (error) => {
-    if (isCancel(error)) return;
-    console.error(error);
-    const errorFeedback = parseErrorFeedback(error);
-    window.$message.error(errorFeedback);
-  },
-});
-
-const onUpdatePermissionChecked = (checked: boolean, stationCode: Station['code'], permissionType: PermissionType) => {
-  if (!employeeId.value) return;
-  if (checked) {
-    const existed = currentList.value.some((permission) => permission.stationCode === stationCode && permission.type === permissionType);
-    if (!existed) {
-      const saveVO: NdmPermissionSaveVO = {
-        employeeId: employeeId.value,
-        stationCode,
-        type: permissionType,
-      };
-      currentList.value.push(saveVO);
-    }
-  } else {
-    const index = currentList.value.findIndex((permission) => permission.stationCode === stationCode && permission.type === permissionType);
-    if (index !== -1) {
-      currentList.value.splice(index, 1);
-    }
-  }
-};
-
-const tableColumns = computed<DataTableColumns<Station>>(() => {
-  return [
-    {
-      title: () => {
-        const permissionCount = currentList.value.length;
-        const permissionTypeCount = objectEntries(PERMISSION_TYPE_LITERALS).length;
-        const checked = permissionCount === stations.value.length * permissionTypeCount;
-        const indeterminate = permissionCount > 0 && permissionCount < stations.value.length * permissionTypeCount;
-        return h(NCheckbox, {
-          checked,
-          indeterminate,
-          onUpdateChecked: (checked) => {
-            objectEntries(PERMISSION_TYPE_LITERALS).forEach(([permissionType]) => {
-              stations.value.forEach((station) => {
-                onUpdatePermissionChecked(checked, station.code, permissionType);
-              });
-            });
-          },
-        });
-      },
-      key: 'row-check',
-      align: 'center',
-      width: 60,
-      fixed: 'left',
-      render: (rowData) => {
-        const { code: stationCode } = rowData;
-        const permissionTypeCount = objectEntries(PERMISSION_TYPE_LITERALS).length;
-        const stationCheckedPermissions = currentList.value.filter((permission) => permission.stationCode === stationCode);
-        const checked = stationCheckedPermissions.length === permissionTypeCount;
-        const indeterminate = stationCheckedPermissions.length > 0 && stationCheckedPermissions.length < permissionTypeCount;
-        return h(NCheckbox, {
-          checked,
-          indeterminate,
-          onUpdateChecked: (checked) => {
-            objectEntries(PERMISSION_TYPE_LITERALS).forEach(([permissionType]) => {
-              onUpdatePermissionChecked(checked, stationCode, permissionType);
-            });
-          },
-        });
-      },
-    },
-    { title: '车站编号', key: 'code', align: 'center', width: 120 },
-    { title: '车站名称', key: 'name', align: 'center', width: 360 },
-    // 「权限」列
-    ...objectEntries(PERMISSION_TYPE_NAMES).map<DataTableColumn<Station>>(([permissionType, title]) => ({
-      title: () => {
-        const permissionCount = currentList.value.filter((permission) => permission.type === permissionType).length;
-        const checked = permissionCount === stations.value.length;
-        const indeterminate = permissionCount > 0 && permissionCount < stations.value.length;
-        return h(
-          NFlex,
-          {
-            justify: 'center',
-            align: 'center',
-          },
-          {
-            default: () => [
-              h(NCheckbox, {
-                checked,
-                indeterminate,
-                onUpdateChecked: (checked) => {
-                  stations.value.forEach((station) => {
-                    onUpdatePermissionChecked(checked, station.code, permissionType);
-                  });
-                },
-              }),
-              h('span', title),
-            ],
-          },
-        );
-      },
-      key: permissionType,
-      align: 'center',
-      render: (rowData) => {
-        const { code: stationCode } = rowData;
-        return h(NCheckbox, {
-          checked: currentList.value.some((permission) => permission.stationCode === stationCode && permission.type === permissionType),
-          onUpdateChecked: (checked) => onUpdatePermissionChecked(checked, stationCode, permissionType),
-        });
-      },
-    })),
-  ];
-});
-
-const { mutate: savePermissions, isPending: permissionsSaving } = useMutation({
-  mutationFn: async () => {
-    if (!employeeId.value) throw new Error('员工ID不能为空');
-
-    abortController.value.abort();
-    abortController.value = new AbortController();
-
-    const signal = abortController.value.signal;
-
-    // 执行diff计算，生成需要保存的权限列表和需要删除的权限ID列表
-    const saveList: NdmPermissionSaveVO[] = [];
-    const removeList: string[] = [];
-    // 遍历当前状态，如果权限不在原始权限列表中，说明是需要新增的权限
-    currentList.value.forEach((permission) => {
-      const { stationCode, type } = permission;
-      if (!stationCode || !type) return;
-      if (!originalList.value.some((permission) => permission.stationCode === stationCode && permission.type === type)) {
-        saveList.push({
-          employeeId: employeeId.value,
-          stationCode,
-          type,
-        });
-      }
-    });
-    // 遍历原始状态，如果权限不在当前状态中，说明是需要删除的权限
-    originalList.value.forEach((permission) => {
-      const { id, stationCode, type } = permission;
-      if (!id) return;
-      if (!currentList.value.some((permission) => permission.stationCode === stationCode && permission.type === type)) {
-        removeList.push(id);
-      }
-    });
-
-    await modifyPermissionApi(
-      {
-        employeeId: employeeId.value,
-        saveList,
-        removeList,
-      },
-      {
-        signal,
-      },
-    );
-  },
-  onSuccess: () => {
-    window.$message.success('权限配置保存成功');
-    getPermissions();
-  },
-  onError: (error) => {
-    if (isCancel(error)) return;
-    console.error(error);
-    const errorFeedback = parseErrorFeedback(error);
-    window.$message.error(errorFeedback);
-  },
-});
-
-const onAfterEnter = () => {
-  getEmployeeAsync().then(() => getPermissions());
-};
-
-const onAfterLeave = () => {
-  employee.value = undefined;
-  originalList.value = [];
-  currentList.value = [];
-};
-
-const onClose = () => {
-  abortController.value.abort();
-  show.value = false;
-};
-</script>
-
-<template>
-  <NModal
-    v-model:show="show"
-    preset="card"
-    style="width: 100vw; height: 100vh"
-    :content-style="{ height: '100%', overflow: 'hidden' }"
-    :close-on-esc="false"
-    :mask-closable="false"
-    :auto-focus="false"
-    @after-enter="onAfterEnter"
-    @after-leave="onAfterLeave"
-    @close="onClose"
-  >
-    <template #header>
-      <span>{{ `配置权限 - ${employee?.realName ?? ''}` }}</span>
-    </template>
-    <template #default>
-      <NDataTable flex-height style="height: 100%" :columns="tableColumns" :data="stations" :loading="permissionsLoading" :single-line="false" />
-    </template>
-    <template #footer>
-      <NText depth="3" style="font-size: smaller">*未勾选任何权限的用户将被认为拥有所有权限</NText>
-    </template>
-    <template #action>
-      <NFlex justify="end">
-        <NButton size="small" @click="onClose">取消</NButton>
-        <NButton type="primary" size="small" :loading="permissionsSaving" @click="() => savePermissions()">保存</NButton>
-      </NFlex>
-    </template>
-  </NModal>
-</template>
-
-<style scoped lang="scss"></style>

src/components/permission/permission-config-modal/index.ts

@@ -0,0 +1,6 @@
+import type { ComponentInstance } from 'vue';
+import PermissionConfigModal from './permission-config-modal.vue';
+
+export type PermissionConfigModalProps = ComponentInstance<typeof PermissionConfigModal>['$props'];
+
+export { PermissionConfigModal };

src/components/permission/permission-config-modal/permission-config-modal.vue

@@ -0,0 +1,263 @@
+<script setup lang="ts">
+import {
+  deletePermissionApi,
+  detailBaseEmployeeApi,
+  pagePermissionApi,
+  savePermissionApi,
+  type BaseEmployeeResultVO,
+  type NdmPermissionResultVO,
+  type NdmPermissionSaveVO,
+  type Station,
+} from '@/apis';
+import { PERMISSION_TYPE_NAMES, type PermissionType } from '@/enums';
+import { useStationStore } from '@/stores';
+import { parseErrorFeedback } from '@/utils';
+import { useMutation } from '@tanstack/vue-query';
+import { objectEntries } from '@vueuse/core';
+import { isCancel } from 'axios';
+import { cloneDeep, groupBy } from 'es-toolkit';
+import { NButton, NCheckbox, NDataTable, NFlex, NModal, NText, type DataTableColumn, type DataTableColumns } from 'naive-ui';
+import { storeToRefs } from 'pinia';
+import { computed, h, ref, toRefs } from 'vue';
+
+/**
+ * 为避免修改权限记录而带来复杂的状态管理，引入 `action` 字段
+ *
+ * - `save`：新增权限
+ * - `delete`：删除权限
+ *
+ * 修改权限的过程中会对本地的权限列表进行修改：
+ * - 当勾选权限时，在本地新增一条权限，`action` 为 `save`
+ * - 当取消勾选权限时，如果该权限来自服务器，则将`action` 改为 `delete`，否则直接删除权限记录
+ *
+ * 最后，保存权限时，只需要遍历本地权限列表：
+ * - 如果 `action` 为 `save`，则调用 `savePermissionApi` 新增权限
+ * - 如果 `action` 为 `delete`，则调用 `deletePermissionApi` 删除权限
+ */
+type PermissionAction = 'save' | 'delete';
+
+type NdmPermissionSaveOrResultVO = NdmPermissionSaveVO | NdmPermissionResultVO;
+
+type NdmPermissionExtendedSaveVO = NdmPermissionSaveVO & { action?: PermissionAction };
+
+type NdmPermissionExtendedResultVO = NdmPermissionResultVO & { action?: PermissionAction };
+
+type NdmPermissionExtendedSaveOrResultVO = NdmPermissionExtendedSaveVO | NdmPermissionExtendedResultVO;
+
+const omitActionField = (extendedSaveOrResultVO: NdmPermissionExtendedSaveOrResultVO) => {
+  const copy = cloneDeep(extendedSaveOrResultVO);
+  delete copy.action;
+  const saveOrResultVO = copy as NdmPermissionSaveOrResultVO;
+  return saveOrResultVO;
+};
+
+const isSaveVO = (saveOrResultVO: NdmPermissionSaveOrResultVO): saveOrResultVO is NdmPermissionSaveVO => {
+  return !('id' in saveOrResultVO);
+};
+
+const isResultVO = (saveOrResultVO: NdmPermissionSaveOrResultVO): saveOrResultVO is NdmPermissionResultVO => {
+  return 'id' in saveOrResultVO;
+};
+
+const props = defineProps<{
+  employeeId?: string;
+}>();
+
+const stationStore = useStationStore();
+const { stations } = storeToRefs(stationStore);
+
+const show = defineModel<boolean>('show', { default: false });
+
+const { employeeId } = toRefs(props);
+
+const abortController = ref<AbortController>(new AbortController());
+
+const employee = ref<BaseEmployeeResultVO>();
+const { mutateAsync: getEmployeeAsync } = useMutation({
+  mutationFn: async () => {
+    abortController.value.abort();
+    abortController.value = new AbortController();
+
+    if (!employeeId.value) return;
+
+    const signal = abortController.value.signal;
+
+    const data = await detailBaseEmployeeApi(employeeId.value, { signal });
+    return data;
+  },
+  onSuccess: (data) => {
+    if (!data) return;
+    employee.value = data;
+  },
+  onError: (error) => {
+    if (isCancel(error)) return;
+    console.error(error);
+    const errorFeedback = parseErrorFeedback(error);
+    window.$message.error(errorFeedback);
+  },
+});
+
+const permissions = ref<Record<Station['code'], NdmPermissionExtendedSaveOrResultVO[]>>({});
+const { mutate: getPermissions, isPending: permissionsLoading } = useMutation({
+  mutationFn: async () => {
+    abortController.value.abort();
+    abortController.value = new AbortController();
+
+    if (!employeeId.value) return;
+
+    const signal = abortController.value.signal;
+
+    const data = await pagePermissionApi(
+      {
+        model: {
+          employeeId: employeeId.value,
+        },
+        extra: {},
+        current: 1,
+        size: Object.keys(PERMISSION_TYPE_NAMES).length * stations.value.length,
+        sort: 'id',
+        order: 'ascending',
+      },
+      { signal },
+    );
+
+    return data;
+  },
+  onSuccess: (data) => {
+    if (!data) return;
+    const { records } = data;
+    permissions.value = groupBy(records, (record) => record.stationCode ?? '');
+  },
+  onError: (error) => {
+    if (isCancel(error)) return;
+    console.error(error);
+    const errorFeedback = parseErrorFeedback(error);
+    window.$message.error(errorFeedback);
+  },
+});
+
+const onUpdatePermissionChecked = (checked: boolean, stationCode: Station['code'], permissionType: PermissionType) => {
+  if (!employeeId.value) return;
+  if (checked) {
+    // 勾选时，新增一条权限记录，`action` 为 `save`
+    if (!permissions.value[stationCode]) permissions.value[stationCode] = [];
+    permissions.value[stationCode].push({ employeeId: employeeId.value, stationCode, type: permissionType, action: 'save' });
+  } else {
+    if (!permissions.value[stationCode]) return;
+    // 取消勾选时，先找到所有该类型的权限并遍历，
+    // 如果权限来自数据库（即有 `id` 字段），则将其 `action` 设为 `delete`，
+    // 否则直接从权限记录中移除
+    const targets = permissions.value[stationCode].filter((permission) => permission.type === permissionType);
+    for (const permission of targets) {
+      if (isResultVO(permission)) {
+        permission.action = 'delete';
+      } else {
+        permissions.value[stationCode].splice(permissions.value[stationCode].indexOf(permission), 1);
+      }
+    }
+  }
+};
+
+const tableColumns = computed<DataTableColumns<Station>>(() => {
+  return [
+    { title: '车站编号', key: 'code', align: 'center', width: 120 },
+    { title: '车站名称', key: 'name', align: 'center', width: 360 },
+    // 「权限」列
+    ...objectEntries(PERMISSION_TYPE_NAMES).map<DataTableColumn<Station>>(([permissionType, title]) => ({
+      title: title,
+      key: permissionType,
+      align: 'center',
+      render: (rowData) => {
+        const { code: stationCode } = rowData;
+        return h(NCheckbox, {
+          // 如果权限记录中存在该权限且 `action` 不为 `delete`，则处于勾选状态
+          checked: !!(permissions.value[stationCode] ?? []).find((permission) => permission.type === permissionType && permission.action !== 'delete'),
+          // 改变勾选状态
+          onUpdateChecked: (checked) => onUpdatePermissionChecked(checked, stationCode, permissionType),
+        });
+      },
+    })),
+  ];
+});
+
+const { mutate: savePermissions, isPending: permissionsSaving } = useMutation({
+  mutationFn: async () => {
+    abortController.value.abort();
+    abortController.value = new AbortController();
+
+    const signal = abortController.value.signal;
+
+    // 遍历所有的权限记录，根据 `action` 进行保存或删除
+    for (const stationPermissions of Object.values(permissions.value)) {
+      for (const permission of stationPermissions) {
+        const saveOrResultVO = omitActionField(permission);
+        if (permission.action === 'save' && isSaveVO(saveOrResultVO)) {
+          await savePermissionApi(saveOrResultVO, { signal });
+        }
+        if (permission.action === 'delete' && isResultVO(saveOrResultVO)) {
+          const id = saveOrResultVO.id;
+          if (!id) continue;
+          await deletePermissionApi([id], { signal });
+        }
+      }
+    }
+  },
+  onSuccess: () => {
+    window.$message.success('权限配置保存成功');
+    getPermissions();
+  },
+  onError: (error) => {
+    if (isCancel(error)) return;
+    console.error(error);
+    const errorFeedback = parseErrorFeedback(error);
+    window.$message.error(errorFeedback);
+  },
+});
+
+const onAfterEnter = () => {
+  getEmployeeAsync().then(() => getPermissions());
+};
+
+const onAfterLeave = () => {
+  employee.value = undefined;
+  permissions.value = {};
+};
+
+const onClose = () => {
+  abortController.value.abort();
+  show.value = false;
+};
+</script>
+
+<template>
+  <NModal
+    v-model:show="show"
+    preset="card"
+    style="width: 100vw; height: 100vh"
+    :content-style="{ height: '100%', overflow: 'hidden' }"
+    :close-on-esc="false"
+    :mask-closable="false"
+    :auto-focus="false"
+    @after-enter="onAfterEnter"
+    @after-leave="onAfterLeave"
+    @close="onClose"
+  >
+    <template #header>
+      <span>{{ `配置权限 - ${employee?.realName ?? ''}` }}</span>
+    </template>
+    <template #default>
+      <NDataTable flex-height style="height: 100%" :columns="tableColumns" :data="stations" :loading="permissionsLoading" :single-line="false" />
+    </template>
+    <template #footer>
+      <NText depth="3" style="font-size: smaller">*未勾选任何权限的用户将被认为拥有所有权限</NText>
+    </template>
+    <template #action>
+      <NFlex justify="end">
+        <NButton size="small" @click="onClose">取消</NButton>
+        <NButton type="primary" size="small" :loading="permissionsSaving" @click="() => savePermissions()">保存</NButton>
+      </NFlex>
+    </template>
+  </NModal>
+</template>
+
+<style scoped lang="scss"></style>

src/components/station/record-check-export-modal/record-check-export-modal.vue

@@ -1,11 +1,13 @@
 <script setup lang="ts">
-import { batchExportRecordCheckApi, pageDefParameterApi, type Station } from '@/apis';
+import { getRecordCheckApi, type NdmNvrResultVO, type Station } from '@/apis';
-import { downloadByData, parseErrorFeedback } from '@/utils';
+import { exportRecordDiagCsv, isNvrCluster, transformRecordChecks } from '@/helpers';
+import { useDeviceStore } from '@/stores';
+import { parseErrorFeedback } from '@/utils';
 import { useMutation } from '@tanstack/vue-query';
 import { isCancel } from 'axios';
-import dayjs from 'dayjs';
+import { NButton, NGrid, NGridItem, NModal, NScrollbar, NSpin } from 'naive-ui';
-import { NButton, NFlex, NGrid, NGridItem, NModal, NScrollbar, NSpin } from 'naive-ui';
+import { storeToRefs } from 'pinia';
-import { ref, toRefs } from 'vue';
+import { computed, ref, toRefs } from 'vue';
 
 const props = defineProps<{
   stations: Station[];
@@ -17,66 +19,50 @@ const emit = defineEmits<{
 
 const show = defineModel<boolean>('show');
 
+const deviceStore = useDeviceStore();
+const { lineDevices } = storeToRefs(deviceStore);
+
 const { stations } = toRefs(props);
 
+const nvrClusterRecord = computed(() => {
+  const clusterMap: Record<Station['code'], { stationName: Station['name']; clusters: NdmNvrResultVO[] }> = {};
+  stations.value.forEach((station) => {
+    clusterMap[station.code] = {
+      stationName: station.name,
+      clusters: [],
+    };
+    const stationDevices = lineDevices.value[station.code];
+    const nvrs = stationDevices?.['ndmNvr'] ?? [];
+    nvrs.forEach((nvr) => {
+      if (isNvrCluster(nvr)) {
+        clusterMap[station.code]?.clusters?.push(nvr);
+      }
+    });
+  });
+  return clusterMap;
+});
+
 const abortController = ref<AbortController>(new AbortController());
 
-const { mutate: batchExportRecordCheck, isPending: batchExporting } = useMutation({
+const { mutate: exportRecordDiags, isPending: exporting } = useMutation({
-  mutationFn: async (params: { stations: Station[] }) => {
+  mutationFn: async (params: { clusters: NdmNvrResultVO[]; stationCode: Station['code'] }) => {
-    const timer = setTimeout(() => {
+    const { clusters, stationCode } = params;
-      if (!batchExporting.value) return;
+    if (clusters.length === 0) {
-      window.$message.info('导出耗时较长，请耐心等待...', { duration: 0 });
+      const stationName = nvrClusterRecord.value[stationCode]?.stationName ?? '';
-    }, 3000);
+      window.$message.info(`${stationName} 没有录像诊断数据`);
-
+      return;
-    try {
-      abortController.value.abort();
-      abortController.value = new AbortController();
-      const { records = [] } = await pageDefParameterApi(
-        {
-          model: {
-            key: 'NVR_GAP_SECONDS',
-          },
-          extra: {},
-          current: 1,
-          size: 1,
-          sort: 'id',
-          order: 'descending',
-        },
-        {
-          signal: abortController.value.signal,
-        },
-      );
-      const gapSeconds = parseInt(records.at(0)?.value ?? '5');
-
-      abortController.value.abort();
-      abortController.value = new AbortController();
-      const data = await batchExportRecordCheckApi(
-        {
-          checkDuration: 90,
-          gapSeconds,
-          stationCode: params.stations.map((station) => station.code),
-        },
-        {
-          signal: abortController.value.signal,
-        },
-      );
-
-      return data;
-    } finally {
-      window.$message.destroyAll();
-      clearTimeout(timer);
     }
+    const cluster = clusters.at(0);
+    if (!cluster) return;
+    abortController.value.abort();
+    abortController.value = new AbortController();
+    const checks = await getRecordCheckApi(cluster, 90, [], { stationCode: stationCode, signal: abortController.value.signal });
+    return checks;
   },
-  onSuccess: (data, { stations }) => {
+  onSuccess: (checks, { stationCode }) => {
-    const time = dayjs().format('YYYY-MM-DD_HH-mm-ss');
+    if (!checks || checks.length === 0) return;
-    let stationName = '';
+    const recordDiags = transformRecordChecks(checks);
-    if (stations.length === 1) {
+    exportRecordDiagCsv(recordDiags, nvrClusterRecord.value[stationCode]?.stationName ?? '');
-      const name = stations.at(0)?.name;
-      if (!!name) {
-        stationName = `${name}_`;
-      }
-    }
-    downloadByData(data, `${stationName}录像缺失记录_${time}.xlsx`);
   },
   onError: (error) => {
     if (isCancel(error)) return;
@@ -87,7 +73,6 @@ const { mutate: batchExportRecordCheck, isPending: batchExporting } = useMutatio
 });
 
 const onAfterLeave = () => {
-  abortController.value.abort();
   emit('afterLeave');
 };
 </script>
@@ -96,22 +81,17 @@ const onAfterLeave = () => {
   <NModal v-model:show="show" preset="card" title="导出录像诊断" @after-leave="onAfterLeave" style="width: 800px">
     <template #default>
       <NScrollbar style="height: 300px">
-        <NSpin size="small" :show="batchExporting">
+        <NSpin size="small" :show="exporting">
           <NGrid :cols="6">
-            <template v-for="station in stations" :key="station.code">
+            <template v-for="({ stationName, clusters }, code) in nvrClusterRecord" :key="code">
               <NGridItem>
-                <NButton text type="info" style="height: 30px" @click="() => batchExportRecordCheck({ stations: [station] })">{{ station.name }}</NButton>
+                <NButton text type="info" style="height: 30px" @click="() => exportRecordDiags({ clusters, stationCode: code })">{{ stationName }}</NButton>
               </NGridItem>
             </template>
           </NGrid>
         </NSpin>
       </NScrollbar>
     </template>
-    <template #action>
-      <NFlex justify="flex-end" align="center">
-        <NButton secondary :loading="batchExporting" @click="() => batchExportRecordCheck({ stations })">导出全部</NButton>
-      </NFlex>
-    </template>
   </NModal>
 </template>
 

src/components/station/sync-camera-result-modal/sync-camera-result-modal.vue

@@ -1,9 +1,10 @@
 <script setup lang="ts">
 import type { Station, SyncCameraResult } from '@/apis';
-import { usePermissionStore } from '@/stores';
+import { useStationStore } from '@/stores';
 import { watchDebounced } from '@vueuse/core';
 import { EditIcon, PlusCircleIcon, Trash2Icon } from 'lucide-vue-next';
 import { NFlex, NIcon, NList, NListItem, NModal, NScrollbar, NStatistic, NText, NThing } from 'naive-ui';
+import { storeToRefs } from 'pinia';
 import { computed, ref, toRefs } from 'vue';
 
 const props = defineProps<{
@@ -14,8 +15,8 @@ const emit = defineEmits<{
   afterLeave: [];
 }>();
 
-const permissionStore = usePermissionStore();
+const stationStore = useStationStore();
-const stations = computed(() => permissionStore.stations.VIEW ?? []);
+const { stations } = storeToRefs(stationStore);
 
 const { syncCameraResult } = toRefs(props);
 

src/composables/device/use-device-selection.ts

@@ -1,33 +1,39 @@
 import type { LineDevices, NdmDeviceResultVO, Station } from '@/apis';
 import { tryGetDeviceType, type DeviceType } from '@/enums';
-import { ref } from 'vue';
+import { useDeviceStore } from '@/stores';
+import { watchDebounced } from '@vueuse/core';
+import { storeToRefs } from 'pinia';
+import { onMounted, ref, toValue, watch, type MaybeRefOrGetter } from 'vue';
 import { useRoute, useRouter } from 'vue-router';
 
-export const useDeviceSelection = () => {
+export const useDeviceSelection = (options?: { syncRoute?: MaybeRefOrGetter<boolean> }) => {
+  const { syncRoute } = options ?? {};
+
   const route = useRoute();
   const router = useRouter();
 
+  const deviceStore = useDeviceStore();
+  const { lineDevices } = storeToRefs(deviceStore);
+
   const selectedStationCode = ref<Station['code']>();
   const selectedDeviceType = ref<DeviceType>();
   const selectedDevice = ref<NdmDeviceResultVO>();
 
-  // 从路由参数同步选中的车站、设备类型以及设备
+  const initFromRoute = (lineDevices: LineDevices) => {
-  const syncFromRoute = (lineDevices: LineDevices) => {
+    const { stationCode, deviceType, deviceDbId } = route.query;
-    // console.log('sync from route');
+    if (stationCode) {
-    const { stationCode: routeStationCode, deviceType: routeDeviceType, deviceDbId: routeDeviceDbId } = route.query;
+      selectedStationCode.value = stationCode as Station['code'];
-    if (routeStationCode) {
-      selectedStationCode.value = routeStationCode as Station['code'];
     }
-    if (routeDeviceType) {
+    if (deviceType) {
-      selectedDeviceType.value = routeDeviceType as DeviceType;
+      selectedDeviceType.value = deviceType as DeviceType;
     }
-    if (routeDeviceDbId && selectedStationCode.value && selectedDeviceType.value) {
+    if (deviceDbId && selectedStationCode.value && selectedDeviceType.value) {
-      const selectedDeviceDbId = routeDeviceDbId as string;
+      const selectedDeviceDbId = deviceDbId as string;
       const stationDevices = lineDevices[selectedStationCode.value];
       if (stationDevices) {
-        const classifiedDevices = stationDevices[selectedDeviceType.value];
+        const devices = stationDevices[selectedDeviceType.value];
-        if (classifiedDevices) {
+        if (devices) {
-          const device = classifiedDevices.find((device) => device.id === selectedDeviceDbId);
+          const device = devices.find((device) => device.id === selectedDeviceDbId);
           if (device) {
             selectedDevice.value = device;
           }
@@ -45,9 +51,7 @@ export const useDeviceSelection = () => {
     }
   };
 
-  // 将选中的车站、设备类型以及设备ID同步到路由参数
   const syncToRoute = () => {
-    // console.log('sync to route');
     const query = { ...route.query };
     // 当选中的设备发生变化时，删除fromPage参数
     if (selectedDevice.value?.id && route.query.deviceDbId !== selectedDevice.value.id) {
@@ -65,13 +69,39 @@ export const useDeviceSelection = () => {
     router.replace({ query });
   };
 
+  watch(selectedDevice, () => {
+    if (toValue(syncRoute)) {
+      syncToRoute();
+    }
+  });
+
+  // lineDevices是shallowRef，因此需要深度侦听才能获取内部变化，
+  // 而单纯的深度侦听又可能会引发性能问题，因此尝试使用防抖侦听
+  watchDebounced(
+    lineDevices,
+    (newLineDevices) => {
+      if (toValue(syncRoute)) {
+        initFromRoute(newLineDevices);
+      }
+    },
+    {
+      debounce: 500,
+      deep: true,
+    },
+  );
+
+  onMounted(() => {
+    if (toValue(syncRoute)) {
+      initFromRoute(lineDevices.value);
+    }
+  });
+
   return {
     selectedStationCode,
     selectedDeviceType,
     selectedDevice,
 
-    syncFromRoute,
+    initFromRoute,
-    syncToRoute,
     selectDevice,
   };
 };

src/composables/device/use-device-tree.ts

@@ -1,8 +1,11 @@
+import type { MaybeRefOrGetter } from 'vue';
 import { useDeviceManagement } from './use-device-management';
 import { useDeviceSelection } from './use-device-selection';
 
-export const useDeviceTree = () => {
+export const useDeviceTree = (options?: { syncRoute?: MaybeRefOrGetter<boolean> }) => {
-  const deviceSelection = useDeviceSelection();
+  const { syncRoute } = options ?? {};
+
+  const deviceSelection = useDeviceSelection({ syncRoute });
   const deviceManagement = useDeviceManagement();
 
   return {

src/composables/permission/use-permission.ts

@@ -1,10 +1,11 @@
+import type { Station } from '@/apis';
 import type { PermissionType } from '@/enums';
 import { usePermissionStore } from '@/stores';
 
 export const usePermission = () => {
   const permissionStore = usePermissionStore();
 
-  const hasPermission = (stationCode: string, permissionType: PermissionType) => {
+  const hasPermission = (stationCode: Station['code'], permissionType: PermissionType) => {
     return !!permissionStore.permissions[stationCode]?.includes(permissionType);
   };
 

src/composables/query/index.ts

@@ -1,6 +1,6 @@
 export * from './use-line-alarms-query';
 export * from './use-line-devices-query';
 export * from './use-line-stations-query';
-export * from './use-user-permission-query';
+export * from './use-user-permissions-query';
 export * from './use-verify-user-query';
 export * from './use-version-check-query';

src/composables/query/use-line-alarms-query.ts

@@ -1,11 +1,12 @@
 import { initStationAlarms, pageDeviceAlarmLogApi, type Station } from '@/apis';
 import { LINE_ALARMS_QUERY_KEY, STATION_ALARMS_MUTATION_KEY } from '@/constants';
 import { tryGetDeviceType } from '@/enums';
-import { useAlarmStore, usePermissionStore } from '@/stores';
+import { useAlarmStore, useStationStore } from '@/stores';
 import { parseErrorFeedback } from '@/utils';
 import { CancelledError, useMutation, useQuery } from '@tanstack/vue-query';
 import { isCancel } from 'axios';
 import dayjs from 'dayjs';
+import { storeToRefs } from 'pinia';
 import { computed } from 'vue';
 
 export const useStationAlarmsMutation = () => {
@@ -55,8 +56,8 @@ export const useStationAlarmsMutation = () => {
       alarmStore.setStationAlarms(station.code, stationAlarms);
     },
     onError: (error) => {
-      if (isCancel(error) || error instanceof CancelledError) return;
       console.error(error);
+      if (isCancel(error) || error instanceof CancelledError) return;
       const errorFeedback = parseErrorFeedback(error);
       window.$message.error(errorFeedback);
     },
@@ -68,22 +69,19 @@ export const useStationAlarmsMutation = () => {
  * @see [use-line-stations-query.ts](./use-line-stations-query.ts)
  */
 export const useLineAlarmsQuery = () => {
-  const permissionStore = usePermissionStore();
+  const stationStore = useStationStore();
-  const stations = computed(() => permissionStore.stations.VIEW ?? []);
+  const { stations } = storeToRefs(stationStore);
-
   const { mutateAsync: getStationAlarms } = useStationAlarmsMutation();
 
   return useQuery({
     queryKey: computed(() => [LINE_ALARMS_QUERY_KEY]),
     enabled: false,
     queryFn: async ({ signal }) => {
-      const startTime = performance.now();
+      console.time(LINE_ALARMS_QUERY_KEY);
       for (const station of stations.value) {
         await getStationAlarms({ station, signal }).catch(() => {});
       }
-      const endTime = performance.now();
+      console.timeEnd(LINE_ALARMS_QUERY_KEY);
-      console.log(`${LINE_ALARMS_QUERY_KEY}: ${endTime - startTime} ms`);
-
       return null;
     },
   });

src/composables/query/use-line-devices-query.ts

@@ -1,9 +1,10 @@
 import { getAllDevicesApi, initStationDevices, type Station } from '@/apis';
 import { LINE_DEVICES_QUERY_KEY, STATION_DEVICES_MUTATION_KEY } from '@/constants';
-import { useDeviceStore, usePermissionStore } from '@/stores';
+import { useDeviceStore, useStationStore } from '@/stores';
 import { parseErrorFeedback } from '@/utils';
 import { CancelledError, useMutation, useQuery } from '@tanstack/vue-query';
 import { isCancel } from 'axios';
+import { storeToRefs } from 'pinia';
 import { computed } from 'vue';
 
 export const useStationDevicesMutation = () => {
@@ -22,8 +23,8 @@ export const useStationDevicesMutation = () => {
       deviceStore.setStationDevices(station.code, devices);
     },
     onError: (error) => {
-      if (isCancel(error) || error instanceof CancelledError) return;
       console.error(error);
+      if (isCancel(error) || error instanceof CancelledError) return;
       const errorFeedback = parseErrorFeedback(error);
       window.$message.error(errorFeedback);
     },
@@ -35,22 +36,19 @@ export const useStationDevicesMutation = () => {
  * @see [use-line-stations-query.ts](./use-line-stations-query.ts)
  */
 export const useLineDevicesQuery = () => {
-  const permissionStore = usePermissionStore();
+  const stationStore = useStationStore();
-  const stations = computed(() => permissionStore.stations.VIEW ?? []);
+  const { stations } = storeToRefs(stationStore);
-
   const { mutateAsync: getStationDevices } = useStationDevicesMutation();
 
   return useQuery({
     queryKey: computed(() => [LINE_DEVICES_QUERY_KEY]),
     enabled: false,
     queryFn: async ({ signal }) => {
-      const startTime = performance.now();
+      console.time(LINE_DEVICES_QUERY_KEY);
       for (const station of stations.value) {
         await getStationDevices({ station, signal }).catch(() => {});
       }
-      const endTime = performance.now();
+      console.timeEnd(LINE_DEVICES_QUERY_KEY);
-      console.log(`${LINE_DEVICES_QUERY_KEY}: ${endTime - startTime} ms`);
-
       return null;
     },
   });

src/composables/query/use-line-stations-query.ts

@@ -1,12 +1,14 @@
 import { batchVerifyApi, type Station } from '@/apis';
 import { LINE_STATIONS_MUTATION_KEY, LINE_STATIONS_QUERY_KEY } from '@/constants';
-import { useSettingStore, useStationStore } from '@/stores';
+import { usePollingStore, useStationStore } from '@/stores';
 import { getAppEnvConfig, parseErrorFeedback } from '@/utils';
 import { CancelledError, useMutation, useQuery } from '@tanstack/vue-query';
 import axios, { isCancel } from 'axios';
 import dayjs from 'dayjs';
 import { storeToRefs } from 'pinia';
 import { computed } from 'vue';
+import { useLineDevicesQuery } from './use-line-devices-query';
+import { useLineAlarmsQuery } from './use-line-alarms-query';
 
 export const useLineStationsMutation = () => {
   const stationStore = useStationStore();
@@ -34,8 +36,8 @@ export const useLineStationsMutation = () => {
       stationStore.setStations(stations);
     },
     onError: (error) => {
-      if (isCancel(error) || error instanceof CancelledError) return;
       console.error(error);
+      if (isCancel(error) || error instanceof CancelledError) return;
       const errorFeedback = parseErrorFeedback(error);
       window.$message.error(errorFeedback);
     },
@@ -43,21 +45,28 @@ export const useLineStationsMutation = () => {
 };
 
 export const useLineStationsQuery = () => {
-  const settingStore = useSettingStore();
+  const pollingStore = usePollingStore();
-  const { pollingStations } = storeToRefs(settingStore);
+  const { pollingEnabled } = storeToRefs(pollingStore);
   const { requestInterval } = getAppEnvConfig();
   const { mutateAsync: getLineStations } = useLineStationsMutation();
+  const { refetch: refetchLineDevicesQuery } = useLineDevicesQuery();
+  const { refetch: refetchLineAlarmsQuery } = useLineAlarmsQuery();
 
   return useQuery({
     queryKey: computed(() => [LINE_STATIONS_QUERY_KEY]),
-    enabled: computed(() => pollingStations.value),
+    enabled: computed(() => pollingEnabled.value),
     refetchInterval: requestInterval * 1000,
     staleTime: (requestInterval * 1000) / 2,
     queryFn: async ({ signal }) => {
-      const startTime = performance.now();
+      console.time(LINE_STATIONS_QUERY_KEY);
       await getLineStations({ signal }).catch(() => {});
-      const endTime = performance.now();
+      console.timeEnd(LINE_STATIONS_QUERY_KEY);
-      console.log(`${LINE_STATIONS_QUERY_KEY}: ${endTime - startTime} ms`);
+
+      if (!pollingEnabled.value) return null;
+      await refetchLineDevicesQuery();
+
+      if (!pollingEnabled.value) return null;
+      await refetchLineAlarmsQuery();
 
       return null;
     },

src/composables/query/use-user-permission-query.ts

@@ -1,67 +0,0 @@
-import { useLineDevicesQuery } from './use-line-devices-query';
-import { useLineAlarmsQuery } from './use-line-alarms-query';
-import { pagePermissionApi } from '@/apis';
-import { USER_PERMISSION_QUERY_KEY } from '@/constants';
-import { PERMISSION_TYPE_LITERALS } from '@/enums';
-import { usePermissionStore, useSettingStore, useStationStore, useUserStore } from '@/stores';
-import { useQuery } from '@tanstack/vue-query';
-import { storeToRefs } from 'pinia';
-import { computed, watch } from 'vue';
-import { useLineStationsQuery } from './use-line-stations-query';
-
-export const useUserPermissionQuery = () => {
-  const settingStore = useSettingStore();
-  const { pollingStations, activeRequests } = storeToRefs(settingStore);
-
-  const userStore = useUserStore();
-  const { userInfo } = storeToRefs(userStore);
-
-  const stationStore = useStationStore();
-  const { stations } = storeToRefs(stationStore);
-
-  const permissionStore = usePermissionStore();
-  const { permissions } = storeToRefs(permissionStore);
-
-  const { dataUpdatedAt: stationsUpdatedTime } = useLineStationsQuery();
-  const { refetch: refetchLineDevicesQuery } = useLineDevicesQuery();
-  const { refetch: refetchLineAlarmsQuery } = useLineAlarmsQuery();
-
-  watch([permissions, stationsUpdatedTime], async ([newPermissions, newUpdatedTime], [oldPermissions, oldUpdatedTime]) => {
-    const newPermissionsJson = JSON.stringify(newPermissions);
-    const oldPermissionsJson = JSON.stringify(oldPermissions);
-    if (newPermissionsJson === oldPermissionsJson && newUpdatedTime === oldUpdatedTime) return;
-    // 设备查询和告警查询依赖pollingEnabdled
-    // 当关闭轮询时，只会取消当前正在执行的查询，
-    // 所以如果在关闭轮询时refetch还未执行，那么这一次取消就是无效的，refetch依然会执行，
-    // 所以在每个refetch被调用前都需要检查pollingEnabled，否则就可能会取消失败
-    if (!pollingStations.value) return;
-    await refetchLineDevicesQuery();
-    if (!pollingStations.value) return;
-    await refetchLineAlarmsQuery();
-  });
-
-  return useQuery({
-    queryKey: computed(() => [USER_PERMISSION_QUERY_KEY]),
-    // 启用【车站轮询】或【主动请求】时，都认为查询被启用
-    enabled: computed(() => (pollingStations.value || activeRequests.value) && userInfo.value?.['employeeId'] && stations.value.length > 0),
-    // 当启用【车站轮询】时，刷新间隔为10秒，缓存时间为5秒
-    refetchInterval: computed(() => (pollingStations.value ? 10 * 1000 : undefined)),
-    staleTime: computed(() => (pollingStations.value ? 5 * 1000 : undefined)),
-    queryFn: async ({ signal }) => {
-      const { records } = await pagePermissionApi(
-        {
-          model: {
-            employeeId: userInfo.value['employeeId'],
-          },
-          current: 1,
-          size: Object.keys(PERMISSION_TYPE_LITERALS).length * stations.value.length,
-        },
-        {
-          signal,
-        },
-      );
-      permissionStore.setPermRecords(records);
-      return null;
-    },
-  });
-};

src/composables/query/use-user-permissions-query.ts

@@ -0,0 +1,55 @@
+import { pagePermissionApi } from '@/apis';
+import { USER_PERMISSIONS_QUERY_KEY } from '@/constants';
+import { PERMISSION_TYPE_NAMES } from '@/enums';
+import { usePermissionStore, useSettingStore, useStationStore, useUserStore } from '@/stores';
+import { useQuery, useQueryClient } from '@tanstack/vue-query';
+import { storeToRefs } from 'pinia';
+import { computed, watch } from 'vue';
+
+export const useUserPermissionsQuery = () => {
+  const queryClient = useQueryClient();
+
+  const settingStore = useSettingStore();
+  const { offlineDev } = storeToRefs(settingStore);
+
+  const stationStore = useStationStore();
+  const { stations } = storeToRefs(stationStore);
+  const userStore = useUserStore();
+  const { userInfo } = storeToRefs(userStore);
+  const permissionStore = usePermissionStore();
+
+  watch(offlineDev, (offline) => {
+    if (offline) {
+      queryClient.cancelQueries({ queryKey: [USER_PERMISSIONS_QUERY_KEY] });
+    }
+  });
+
+  return useQuery({
+    queryKey: computed(() => [USER_PERMISSIONS_QUERY_KEY]),
+    enabled: computed(() => !offlineDev.value),
+    refetchInterval: 10 * 1000,
+    queryFn: async ({ signal }) => {
+      const { employeeId } = userInfo.value ?? {};
+      if (!employeeId) return null;
+
+      const { records } = await pagePermissionApi(
+        {
+          model: {
+            employeeId,
+          },
+          extra: {},
+          current: 1,
+          size: Object.keys(PERMISSION_TYPE_NAMES).length * stations.value.length,
+          sort: 'id',
+          order: 'ascending',
+        },
+        {
+          signal,
+        },
+      );
+      permissionStore.setPermRecords(records);
+
+      return null;
+    },
+  });
+};

src/composables/query/use-verify-user-query.ts

@@ -8,17 +8,17 @@ import { computed, watch } from 'vue';
 export const useVerifyUserQuery = () => {
   const queryClient = useQueryClient();
   const settingStore = useSettingStore();
-  const { activeRequests } = storeToRefs(settingStore);
+  const { offlineDev } = storeToRefs(settingStore);
 
-  watch(activeRequests, (active) => {
+  watch(offlineDev, (offline) => {
-    if (!active) {
+    if (offline) {
       queryClient.cancelQueries({ queryKey: [VERIFY_USER_QUERY_KEY] });
     }
   });
 
   return useQuery({
     queryKey: [VERIFY_USER_QUERY_KEY],
-    enabled: computed(() => activeRequests.value),
+    enabled: computed(() => !offlineDev.value),
     refetchInterval: 10 * 1000,
     queryFn: async ({ signal }) => {
       await verifyApi({ signal });

src/composables/station/use-batch-actions.ts

@@ -1,8 +1,6 @@
 import { usePermission } from '../permission';
 import { type Station } from '@/apis';
 import { PERMISSION_TYPE_LITERALS, type PermissionType } from '@/enums';
-import { objectEntries } from '@vueuse/core';
-import type { CheckboxProps } from 'naive-ui';
 import { computed, ref, watch, type Ref } from 'vue';
 
 type BatchActionKey = 'export-icmp' | 'export-record' | 'sync-camera' | 'sync-nvr';
@@ -62,21 +60,6 @@ export const useBatchActions = (stations: Ref<Station[]>, abortController?: Ref<
 
   const stationSelection = ref<Record<Station['code'], boolean>>({});
 
-  const selectionProps = computed<CheckboxProps>(() => {
-    const selectableStationsLength = selectableStations.value.length;
-    const selectedStationsLength = objectEntries(stationSelection.value).filter(([, selected]) => selected).length;
-
-    const disabled = selectableStationsLength === 0;
-    const checked = selectableStationsLength > 0 && selectedStationsLength === selectableStationsLength;
-    const indeterminate = selectableStationsLength > 0 && selectedStationsLength > 0 && selectedStationsLength < selectableStationsLength;
-
-    return {
-      disabled,
-      checked,
-      indeterminate,
-    };
-  });
-
   const toggleSelectAction = (action: BatchAction) => {
     batchActions.value.forEach((batchAction) => {
       if (batchAction.key === action.key) {
@@ -128,8 +111,6 @@ export const useBatchActions = (stations: Ref<Station[]>, abortController?: Ref<
     selectableStations,
     stationSelection,
 
-    selectionProps,
-
     toggleSelectAction,
     toggleSelectAllStations,
 

src/composables/stomp/use-stomp-client.ts

@@ -1,12 +1,12 @@
 import type { NdmDeviceAlarmLogResultVO, Station, SyncCameraResult } from '@/apis';
-import { ALARM_TOPIC, PERMISSION_TOPIC, SYNC_CAMERA_STATUS_TOPIC } from '@/constants';
+import { ALARM_TOPIC, SYNC_CAMERA_STATUS_TOPIC } from '@/constants';
-import { useSettingStore, useStationStore, useUnreadStore, useUserStore } from '@/stores';
+import { useAlarmStore, useSettingStore, useStationStore } from '@/stores';
 import { Client } from '@stomp/stompjs';
 import { watchDebounced } from '@vueuse/core';
 import destr from 'destr';
 import { storeToRefs } from 'pinia';
 import { onBeforeUnmount, onMounted, ref, watch } from 'vue';
-import { useStationAlarmsMutation, useUserPermissionQuery } from '../query';
+import { useStationAlarmsMutation } from '../query';
 
 const getBrokerUrl = () => {
   const protocol = window.location.protocol === 'https:' ? 'wss:' : 'ws:';
@@ -19,17 +19,11 @@ const getBrokerUrl = () => {
 export const useStompClient = () => {
   const stationStore = useStationStore();
   const { stations } = storeToRefs(stationStore);
-
+  const alarmStore = useAlarmStore();
-  const unreadStore = useUnreadStore();
+  const { unreadLineAlarms } = storeToRefs(alarmStore);
-  const { unreadLineAlarms } = storeToRefs(unreadStore);
-
   const settingStore = useSettingStore();
-  const { subscribeMessages } = storeToRefs(settingStore);
+  const { offlineDev } = storeToRefs(settingStore);
 
-  const userStore = useUserStore();
-  const { userInfo } = storeToRefs(userStore);
-
-  const { refetch: refetchUserPermissionQuery } = useUserPermissionQuery();
   const { mutate: refreshStationAlarms } = useStationAlarmsMutation();
 
   const stompClient = ref<Client | null>(null);
@@ -46,16 +40,10 @@ export const useStompClient = () => {
         console.log('Stomp连接成功');
         stompClient.value?.subscribe(ALARM_TOPIC, (message) => {
           const alarm = destr<NdmDeviceAlarmLogResultVO>(message.body);
-          const { alarmCategory, stationCode } = alarm;
+          if (alarm.alarmCategory === '1') {
-          if (alarmCategory === '1' && !!stations.value.find((station) => station.code === stationCode)) {
+            alarmStore.pushUnreadAlarm(alarm);
-            unreadStore.pushUnreadAlarm(alarm);
           }
         });
-        stompClient.value?.subscribe(PERMISSION_TOPIC, (message) => {
-          const employeeId = destr<string>(message.body);
-          if (userInfo.value?.['employeeId'] !== employeeId) return;
-          refetchUserPermissionQuery();
-        });
         stompClient.value?.subscribe(SYNC_CAMERA_STATUS_TOPIC, (message) => {
           const { stationCode, startTime, endTime, insertList, updateList, deleteList } = destr<SyncCameraResult>(message.body);
           syncCameraResult.value[stationCode] = { stationCode, startTime, endTime, insertList, updateList, deleteList };
@@ -64,7 +52,6 @@ export const useStompClient = () => {
       onDisconnect: () => {
         console.log('Stomp连接断开');
         stompClient.value?.unsubscribe(ALARM_TOPIC);
-        stompClient.value?.unsubscribe(PERMISSION_TOPIC);
         stompClient.value?.unsubscribe(SYNC_CAMERA_STATUS_TOPIC);
       },
       onStompError: (frame) => {
@@ -76,7 +63,7 @@ export const useStompClient = () => {
         window.$message.error('WebSocket错误');
       },
     });
-    if (subscribeMessages.value) {
+    if (!offlineDev.value) {
       stompClient.value.activate();
     }
   });
@@ -86,11 +73,11 @@ export const useStompClient = () => {
     stompClient.value = null;
   });
 
-  watch(subscribeMessages, (subscribe) => {
+  watch(offlineDev, (offline) => {
-    if (subscribe) {
+    if (offline) {
-      stompClient.value?.activate();
-    } else {
       stompClient.value?.deactivate();
+    } else {
+      stompClient.value?.activate();
     }
   });
 
@@ -100,8 +87,8 @@ export const useStompClient = () => {
   watchDebounced(
     () => Object.entries(unreadLineAlarms.value).map(([stationCode, stationAlarms]) => ({ stationCode, count: stationAlarms['unclassified'].length })),
     (newValue, oldValue) => {
-      // 关闭消息订阅时，跳过处理
+      // 启用离线模式时，跳过处理
-      if (!subscribeMessages.value) return;
+      if (offlineDev.value) return;
       if (newValue.length === 0) return;
       const codes: Station['code'][] = [];
       newValue.forEach(({ stationCode, count }) => {

src/constants/query.ts

@@ -1,6 +1,6 @@
 export const LINE_ALARMS_QUERY_KEY = 'line-alarms';
 export const LINE_DEVICES_QUERY_KEY = 'line-devices';
 export const LINE_STATIONS_QUERY_KEY = 'line-stations';
-export const USER_PERMISSION_QUERY_KEY = 'user-permission';
+export const USER_PERMISSIONS_QUERY_KEY = 'user-permissions';
 export const VERIFY_USER_QUERY_KEY = 'verify-user';
 export const VERSION_CHECK_QUERY_KEY = 'version-check';

src/constants/stomp.ts

@@ -1,3 +1,3 @@
 export const ALARM_TOPIC = '/topic/deviceAlarm';
-export const PERMISSION_TOPIC = '/topic/permission';
+
 export const SYNC_CAMERA_STATUS_TOPIC = '/topic/syncCameraStatus';

src/constants/store.ts

@@ -4,5 +4,4 @@ export const NDM_PERMISSION_STORE_ID = 'ndm-permission-store';
 export const NDM_POLLIING_STORE_ID = 'ndm-polling-store';
 export const NDM_SETTING_STORE_ID = 'ndm-setting-store';
 export const NDM_STATION_STORE_ID = 'ndm-station-store';
-export const NDM_UNREAD_STORE_ID = 'ndm-unread-store';
 export const NDM_USER_STORE_ID = 'ndm-user-store';

src/global.d.ts

@@ -7,6 +7,6 @@ declare global {
     $loadingBar: ReturnType<typeof useLoadingBar>;
     $message: ReturnType<typeof useMessage>;
     $notification: ReturnType<typeof useNotification>;
-    $mockUser: Ref<boolean>;
+    $offlineDev: Ref<boolean>;
   }
 }

src/layouts/app-layout.vue

@@ -1,10 +1,12 @@
 <script setup lang="ts">
 import { SettingsDrawer, SyncCameraResultModal } from '@/components';
-import { useLineStationsQuery, useStompClient, useUserPermissionQuery, useVerifyUserQuery } from '@/composables';
+import { useLineStationsQuery, useStompClient, useUserPermissionsQuery, useVerifyUserQuery } from '@/composables';
 import { LINE_ALARMS_QUERY_KEY, LINE_DEVICES_QUERY_KEY, LINE_STATIONS_MUTATION_KEY, LINE_STATIONS_QUERY_KEY, STATION_ALARMS_MUTATION_KEY, STATION_DEVICES_MUTATION_KEY } from '@/constants';
-import { useSettingStore, useUnreadStore, useUserStore } from '@/stores';
+import { useAlarmStore, useSettingStore, useUserStore } from '@/stores';
-import { useIsFetching, useIsMutating } from '@tanstack/vue-query';
+import { parseErrorFeedback } from '@/utils';
-import { ChevronDownIcon, ChevronsLeftIcon, ChevronsRightIcon, ComputerIcon, KeyRoundIcon, LogOutIcon, LogsIcon, MapPinIcon, SettingsIcon, SirenIcon } from 'lucide-vue-next';
+import { useIsFetching, useIsMutating, useMutation } from '@tanstack/vue-query';
+import { isCancel } from 'axios';
+import { ChevronDownIcon, ChevronsLeftIcon, ChevronsRightIcon, ComputerIcon, KeyIcon, LogOutIcon, LogsIcon, MapPinIcon, SettingsIcon, SirenIcon } from 'lucide-vue-next';
 import {
   NBadge,
   NButton,
@@ -22,26 +24,26 @@ import {
   type MenuOption,
 } from 'naive-ui';
 import { storeToRefs } from 'pinia';
-import { computed, h, ref, type Component, type VNode } from 'vue';
+import { computed, h, ref, watchEffect, type Component, type VNode } from 'vue';
 import { RouterLink, useRoute, useRouter } from 'vue-router';
 
 const route = useRoute();
 const router = useRouter();
 
 const userStore = useUserStore();
-const { userInfo, isLamp } = storeToRefs(userStore);
+const { userInfo } = storeToRefs(userStore);
 
-const unreadStore = useUnreadStore();
+const alarmStore = useAlarmStore();
-const { unreadAlarmCount } = storeToRefs(unreadStore);
+const { unreadAlarmCount } = storeToRefs(alarmStore);
 
 const settingStore = useSettingStore();
-const { menuCollpased } = storeToRefs(settingStore);
+const { menuCollpased, offlineDev } = storeToRefs(settingStore);
 
 const { syncCameraResult, afterCheckSyncCameraResult } = useStompClient();
 
 useVerifyUserQuery();
 useLineStationsQuery();
-useUserPermissionQuery();
+useUserPermissionsQuery();
 
 // 全局loading状态依赖于轮询query的queryKey以及相关的mutationKey
 const queryingCount = useIsFetching({
@@ -64,7 +66,7 @@ const onToggleMenuCollapsed = () => {
   menuCollpased.value = !menuCollpased.value;
 };
 
-const menuOptions = computed<MenuOption[]>(() => [
+const menuOptions: MenuOption[] = [
   {
     label: () => h(RouterLink, { to: '/station' }, { default: () => '车站状态' }),
     key: '/station',
@@ -108,10 +110,10 @@ const menuOptions = computed<MenuOption[]>(() => [
   {
     label: () => h(RouterLink, { to: '/permission' }, { default: () => '权限管理' }),
     key: '/permission',
-    show: isLamp.value,
+    show: userStore.isLamp,
-    icon: renderIcon(KeyRoundIcon),
+    icon: renderIcon(KeyIcon),
   },
-]);
+];
 
 const dropdownOptions: DropdownOption[] = [
   {
@@ -146,12 +148,33 @@ const routeToRoot = () => {
 };
 
 const routeToAlarmPage = () => {
-  unreadStore.clearUnreadAlarms();
+  alarmStore.clearUnreadAlarms();
   if (route.path !== '/alarm/alarm-log') {
     router.push({ path: '/alarm/alarm-log' });
   }
 };
 
+const { mutate: getUserInfo } = useMutation({
+  mutationFn: async (params?: { signal?: AbortSignal }) => {
+    const { signal } = params ?? {};
+    await userStore.userGetInfo({ signal });
+  },
+  onError: (error) => {
+    if (isCancel(error)) return;
+    console.error(error);
+    const errorFeedback = parseErrorFeedback(error);
+    window.$message.error(errorFeedback);
+  },
+});
+
+// 判断是否为离线开发模式 决定是否自动发送获取用户信息请求
+watchEffect((onCleanup) => {
+  if (offlineDev.value) return;
+  const abortController = new AbortController();
+  getUserInfo({ signal: abortController.signal });
+  onCleanup(() => abortController.abort());
+});
+
 function renderIcon(icon: Component): () => VNode {
   return () => h(NIcon, null, { default: () => h(icon) });
 }

src/pages/alarm/alarm-ignore-page.vue

@@ -46,7 +46,8 @@ interface SearchFields extends PageQueryExtra<NdmCameraIgnore> {
   stationCode?: Station['code'];
   // deviceId_like?: string;
 }
-
+const deviceStore = useDeviceStore();
+const { lineDevices } = storeToRefs(deviceStore);
 const permissionStore = usePermissionStore();
 const { permissions } = storeToRefs(permissionStore);
 
@@ -54,9 +55,6 @@ const { hasPermission } = usePermission();
 
 const stations = computed(() => permissionStore.stations.VIEW ?? []);
 
-const deviceStore = useDeviceStore();
-const { lineDevices } = storeToRefs(deviceStore);
-
 const stationSelectOptions = computed<SelectOption[]>(() => {
   return stations.value.map((station) => ({
     label: station.name,

src/pages/alarm/alarm-log-page.vue

@@ -3,7 +3,7 @@ import { exportDeviceAlarmLogApi, pageDeviceAlarmLogApi, type NdmDeviceAlarmLog,
 import { useAlarmActionColumn, useCameraSnapColumn } from '@/composables';
 import { ALARM_TYPES, DEVICE_TYPE_CODES, DEVICE_TYPE_LITERALS, DEVICE_TYPE_NAMES, FAULT_LEVELS, tryGetDeviceType, type DeviceType } from '@/enums';
 import { renderAlarmDateCell, renderAlarmTypeCell, renderDeviceTypeCell, renderFaultLevelCell } from '@/helpers';
-import { useDeviceStore, usePermissionStore, useUnreadStore } from '@/stores';
+import { useAlarmStore, useDeviceStore, usePermissionStore } from '@/stores';
 import { downloadByData, parseErrorFeedback } from '@/utils';
 import { useMutation } from '@tanstack/vue-query';
 import { watchDebounced } from '@vueuse/core';
@@ -37,24 +37,20 @@ interface SearchFields extends PageQueryExtra<NdmDeviceAlarmLog> {
   alarmType_in: string[];
   faultLevel_in: string[];
   alarmDate: [number, number];
-  alarmCategory: string;
-  alarmConfirm: string;
 }
 
 const route = useRoute();
 const router = useRouter();
 
+const deviceStore = useDeviceStore();
+const { lineDevices } = storeToRefs(deviceStore);
+const alarmStore = useAlarmStore();
+const { unreadAlarmCount } = storeToRefs(alarmStore);
 const permissionStore = usePermissionStore();
 const { permissions } = storeToRefs(permissionStore);
 
 const stations = computed(() => permissionStore.stations.VIEW ?? []);
 
-const deviceStore = useDeviceStore();
-const { lineDevices } = storeToRefs(deviceStore);
-
-const unreadStore = useUnreadStore();
-const { unreadAlarmCount } = storeToRefs(unreadStore);
-
 const stationSelectOptions = computed<SelectOption[]>(() => {
   return stations.value.map((station) => ({
     label: station.name,
@@ -117,8 +113,6 @@ const searchFields = ref<SearchFields>({
   alarmType_in: [],
   faultLevel_in: [],
   alarmDate: [dayjs().startOf('date').valueOf(), dayjs().endOf('date').valueOf()],
-  alarmCategory: '',
-  alarmConfirm: '',
 });
 const resetSearchFields = () => {
   searchFields.value = {
@@ -128,8 +122,6 @@ const resetSearchFields = () => {
     alarmType_in: [],
     faultLevel_in: [],
     alarmDate: [dayjs().startOf('date').valueOf(), dayjs().endOf('date').valueOf()],
-    alarmCategory: '',
-    alarmConfirm: '',
   };
 };
 const getExtraFields = (): PageQueryExtra<NdmDeviceAlarmLog> => {
@@ -244,10 +236,7 @@ const { mutate: getTableData, isPending: tableLoading } = useMutation({
 
     const res = await pageDeviceAlarmLogApi(
       {
-        model: {
+        model: {},
-          alarmCategory: searchFields.value.alarmCategory || undefined,
-          alarmConfirm: searchFields.value.alarmConfirm || undefined,
-        },
         extra: getExtraFields(),
         current: pagination.page ?? 1,
         size: pagination.pageSize ?? DEFAULT_PAGE_SIZE,
@@ -355,28 +344,6 @@ onBeforeUnmount(() => {
         <NFormItemGi span="1" label="告警级别" label-placement="left">
           <NSelect multiple clearable placeholder="请选择告警级别" v-model:value="searchFields.faultLevel_in" :options="faultLevelSelectOptions" />
         </NFormItemGi>
-        <NFormItemGi span="1" label="恢复状态" label-placement="left">
-          <NSelect
-            clearable
-            placeholder="请选择恢复状态"
-            v-model:value="searchFields.alarmCategory"
-            :options="[
-              { label: '未恢复', value: '1' },
-              { label: '已恢复', value: '2' },
-            ]"
-          />
-        </NFormItemGi>
-        <NFormItemGi span="1" label="确认状态" label-placement="left">
-          <NSelect
-            clearable
-            placeholder="请选择确认状态"
-            v-model:value="searchFields.alarmConfirm"
-            :options="[
-              { label: '未确认', value: '2' },
-              { label: '已确认', value: '1' },
-            ]"
-          />
-        </NFormItemGi>
         <NFormItemGi span="1" label="告警时间" label-placement="left">
           <NDatePicker v-model:value="searchFields.alarmDate" type="datetimerange" />
         </NFormItemGi>

src/pages/device/device-page.vue

@@ -8,6 +8,7 @@ import { NLayout, NLayoutContent, NLayoutSider } from 'naive-ui';
 import { computed, provide, ref } from 'vue';
 
 const permissionStore = usePermissionStore();
+
 const stations = computed(() => permissionStore.stations.VIEW ?? []);
 
 const selectedStation = ref<Station>();

src/pages/login/login-page.vue

@@ -22,7 +22,8 @@ const { mutate: login, isPending: loading } = useMutation({
   mutationFn: async (params: LoginParams) => {
     const userStore = useUserStore();
     await userStore.userLogin(params);
-    await userStore.userGetInfo();
+    const [err] = await userClient.post<void>(`/api/ndm/ndmKeepAlive/verify`, {}, { timeout: 5000 });
+    if (err) throw err;
   },
   onSuccess: () => {
     window.$message.success('登录成功');

src/pages/station/station-page.vue

@@ -4,48 +4,27 @@ import { AlarmDetailModal, DeviceDetailModal, DeviceParamConfigModal, IcmpExport
 import { useBatchActions, useLineDevicesQuery } from '@/composables';
 import { useAlarmStore, useDeviceStore, usePermissionStore, useSettingStore } from '@/stores';
 import { useMutation } from '@tanstack/vue-query';
-import { useElementSize } from '@vueuse/core';
 import { isCancel } from 'axios';
 import { NButton, NButtonGroup, NCheckbox, NFlex, NGrid, NGridItem, NScrollbar } from 'naive-ui';
 import { storeToRefs } from 'pinia';
-import { computed, ref, useTemplateRef } from 'vue';
+import { computed, ref } from 'vue';
 
 const settingStore = useSettingStore();
-const { stationGridCols } = storeToRefs(settingStore);
+const { stationGridCols: stationGridColumns } = storeToRefs(settingStore);
-
-const permissionStore = usePermissionStore();
-const stations = computed(() => permissionStore.stations.VIEW ?? []);
-
 const deviceStore = useDeviceStore();
 const { lineDevices } = storeToRefs(deviceStore);
-
 const alarmStore = useAlarmStore();
 const { lineAlarms } = storeToRefs(alarmStore);
+const permissionStore = usePermissionStore();
 
-const STATION_CARD_MIN_WIDTH = 230;
+const stations = computed(() => permissionStore.stations.VIEW ?? []);
-const STATION_GRID_PADDING = 8;
-const STATION_GRID_GAP = 6;
-const STATION_GRID_REF_NAME = 'stationGridRef';
-const stationGridRef = useTemplateRef<HTMLDivElement>(STATION_GRID_REF_NAME);
-const { width: stationGridWidth } = useElementSize(stationGridRef);
-// 计算合适的车站布局列数
-const actualStationGridColumns = computed(() => {
-  const currentStationCardWidth = (stationGridWidth.value - STATION_GRID_PADDING * 2 - (stationGridCols.value - 1) * STATION_GRID_GAP) / stationGridCols.value;
-  // 当卡片宽度大于最小宽度时，说明用户的设置没有问题，直接返回列数
-  if (currentStationCardWidth > STATION_CARD_MIN_WIDTH) return stationGridCols.value;
-  // 否则，说明用户的设置不合适，需要根据当前布局宽度重新计算列数
-  return Math.floor((stationGridWidth.value - STATION_GRID_PADDING * 2 + STATION_GRID_GAP) / STATION_CARD_MIN_WIDTH);
-});
 
 const showIcmpExportModal = ref(false);
 const showRecordCheckExportModal = ref(false);
 
 const abortController = ref(new AbortController());
 
-const { batchActions, selectedAction, selectableStations, stationSelection, selectionProps, toggleSelectAction, toggleSelectAllStations, confirmAction, cancelAction } = useBatchActions(
+const { batchActions, selectedAction, selectableStations, stationSelection, toggleSelectAction, toggleSelectAllStations, confirmAction, cancelAction } = useBatchActions(stations, abortController);
-  stations,
-  abortController,
-);
 
 const { refetch: refetchLineDevicesQuery } = useLineDevicesQuery();
 
@@ -81,7 +60,7 @@ const { mutate: syncCamera, isPending: cameraSyncing } = useMutation({
     window.$notification.info({
       title: '摄像机同步结果',
       content: notices.join('，'),
-      duration: 10000,
+      duration: 3000,
     });
     if (successRequests.length > 0) {
       // 摄像机同步后，需要重新查询一次设备
@@ -123,7 +102,7 @@ const { mutate: syncNvrChannels, isPending: nvrChannelsSyncing } = useMutation({
     window.$notification.info({
       title: '录像机通道同步结果',
       content: notices.join('，'),
-      duration: 10000,
+      duration: 3000,
     });
     cancelAction();
   },
@@ -173,35 +152,33 @@ const onClickDetail: StationCardProps['onClickDetail'] = (type, station) => {
 <template>
   <NScrollbar content-style="padding-right: 8px" style="width: 100%; height: 100%">
     <!-- 工具栏 -->
-    <NFlex align="center" :style="{ padding: `${STATION_GRID_PADDING}px ${STATION_GRID_PADDING}px 0 ${STATION_GRID_PADDING}px` }">
+    <NFlex align="center" style="padding: 8px 8px 0 8px">
       <NButtonGroup>
         <template v-for="batchAction in batchActions" :key="batchAction.key">
           <NButton :secondary="!batchAction.active" :focusable="false" @click="() => toggleSelectAction(batchAction)">{{ batchAction.label }}</NButton>
         </template>
       </NButtonGroup>
       <template v-if="selectedAction">
-        <NCheckbox label="全选" :disabled="selectionProps.disabled" :checked="selectionProps.checked" :indeterminate="selectionProps.indeterminate" @update:checked="toggleSelectAllStations" />
+        <NCheckbox label="全选" :checked="selectableStations.length === Object.keys(stationSelection).length" @update:checked="toggleSelectAllStations" />
         <NButton tertiary size="small" type="primary" :focusable="false" :loading="confirming" @click="onClickConfirmAction">确定</NButton>
         <NButton tertiary size="small" type="tertiary" :focusable="false" @click="cancelAction">取消</NButton>
       </template>
     </NFlex>
 
     <!-- 车站 -->
-    <div :ref="STATION_GRID_REF_NAME">
+    <NGrid :cols="stationGridColumns" :x-gap="6" :y-gap="6" style="padding: 8px">
-      <NGrid :cols="actualStationGridColumns" :x-gap="STATION_GRID_GAP" :y-gap="STATION_GRID_GAP" :style="{ padding: `${STATION_GRID_PADDING}px` }">
+      <NGridItem v-for="station in stations" :key="station.code">
-        <NGridItem v-for="station in stations" :key="station.code">
+        <StationCard
-          <StationCard
+          :station="station"
-            :station="station"
+          :devices="lineDevices[station.code] ?? initStationDevices()"
-            :devices="lineDevices[station.code] ?? initStationDevices()"
+          :alarms="lineAlarms[station.code] ?? initStationAlarms()"
-            :alarms="lineAlarms[station.code] ?? initStationAlarms()"
+          :selectable="!!selectableStations.find((selectable) => selectable.code === station.code)"
-            :selectable="!!selectableStations.find((selectable) => selectable.code === station.code)"
+          v-model:selected="stationSelection[station.code]"
-            v-model:selected="stationSelection[station.code]"
+          @click-detail="onClickDetail"
-            @click-detail="onClickDetail"
+          @click-config="onClickConfig"
-            @click-config="onClickConfig"
+        />
-          />
+      </NGridItem>
-        </NGridItem>
+    </NGrid>
-      </NGrid>
-    </div>
   </NScrollbar>
 
   <IcmpExportModal v-model:show="showIcmpExportModal" :stations="stations.filter((station) => stationSelection[station.code])" @after-leave="cancelAction" />

src/stores/alarm.ts

@@ -1,7 +1,8 @@
-import { type LineAlarms, type Station, type StationAlarms } from '@/apis';
+import { initStationAlarms, type LineAlarms, type NdmDeviceAlarmLogResultVO, type Station, type StationAlarms } from '@/apis';
 import { NDM_ALARM_STORE_ID } from '@/constants';
+import { tryGetDeviceType } from '@/enums';
 import { defineStore } from 'pinia';
-import { shallowRef, triggerRef } from 'vue';
+import { computed, shallowRef, triggerRef } from 'vue';
 
 export const useAlarmStore = defineStore(
   NDM_ALARM_STORE_ID,
@@ -17,10 +18,42 @@ export const useAlarmStore = defineStore(
       triggerRef(lineAlarms);
     };
 
+    // 全线所有车站的未读告警 (来自stomp订阅)
+    const unreadLineAlarms = shallowRef<LineAlarms>({});
+    const unreadAlarmCount = computed(() => {
+      let count = 0;
+      Object.values(unreadLineAlarms.value).forEach((stationAlarms) => {
+        count += stationAlarms['unclassified'].length;
+      });
+      return count;
+    });
+    const pushUnreadAlarm = (alarm: NdmDeviceAlarmLogResultVO) => {
+      const stationCode = alarm.stationCode;
+      if (!stationCode) return;
+      if (!unreadLineAlarms.value[stationCode]) {
+        unreadLineAlarms.value[stationCode] = initStationAlarms();
+      }
+      const deviceType = tryGetDeviceType(alarm.deviceType);
+      if (!deviceType) return;
+      const stationAlarms = unreadLineAlarms.value[stationCode];
+      stationAlarms[deviceType].push(alarm);
+      stationAlarms['unclassified'].push(alarm);
+      triggerRef(unreadLineAlarms);
+    };
+    const clearUnreadAlarms = () => {
+      unreadLineAlarms.value = {};
+      triggerRef(unreadLineAlarms);
+    };
+
     return {
       lineAlarms,
       setLineAlarms,
       setStationAlarms,
+
+      unreadLineAlarms,
+      unreadAlarmCount,
+      pushUnreadAlarm,
+      clearUnreadAlarms,
     };
   },
   {

src/stores/index.ts

@@ -1,7 +1,7 @@
 export * from './alarm';
 export * from './device';
 export * from './permission';
+export * from './polling';
 export * from './setting';
 export * from './station';
-export * from './unread';
 export * from './user';

src/stores/permission.ts

@@ -11,27 +11,22 @@ type Permissions = Record<Station['code'], PermissionType[]>;
 export const usePermissionStore = defineStore(
   NDM_PERMISSION_STORE_ID,
   () => {
-    const stationStore = useStationStore();
+    const permRecords = ref<NdmPermissionResultVO[]>([]);
-
-    const permissionRecords = ref<NdmPermissionResultVO[] | null>(null);
 
     const permissions = computed<Permissions>(() => {
+      const stationStore = useStationStore();
+
       const result: Permissions = {};
 
-      const records = permissionRecords.value;
-
-      // 如果权限记录不存在，则不做权限配置
-      if (!records) return result;
-
       // 如果该用户没有任何权限记录，则开放所有权限，否则根据记录配置权限
-      if (records.length === 0) {
+      if (permRecords.value.length === 0) {
         stationStore.stations.forEach((station) => {
           result[station.code] = [...objectEntries(PERMISSION_TYPE_NAMES).map(([permType]) => permType)];
         });
       } else {
         stationStore.stations.forEach((station) => {
           result[station.code] = [];
-          const stationPermRecords = records.filter((record) => record.stationCode === station.code);
+          const stationPermRecords = permRecords.value.filter((record) => record.stationCode === station.code);
           if (stationPermRecords.length === 0) return;
           stationPermRecords.forEach(({ type: permType }) => {
             if (!permType) return;
@@ -45,6 +40,7 @@ export const usePermissionStore = defineStore(
 
     // 按权限对车站进行分类
     const stations = computed(() => {
+      const stationStore = useStationStore();
       const result: Partial<Record<PermissionType, Station[]>> = {};
       // 按原始的车站顺序进行遍历，保持显示顺序不变
       stationStore.stations.forEach((station) => {
@@ -59,11 +55,11 @@ export const usePermissionStore = defineStore(
     });
 
     const setPermRecords = (records: NdmPermissionResultVO[]) => {
-      permissionRecords.value = records;
+      permRecords.value = records;
     };
 
     return {
-      permissionRecords,
+      permRecords,
 
       permissions,
       stations,

src/stores/setting.ts

@@ -1,72 +1,36 @@
-import { useUserStore } from './user';
+import { NDM_SETTING_STORE_ID } from '@/constants';
-import { LINE_ALARMS_QUERY_KEY, LINE_DEVICES_QUERY_KEY, LINE_STATIONS_QUERY_KEY, NDM_SETTING_STORE_ID } from '@/constants';
-import router from '@/router';
-import { useQueryClient } from '@tanstack/vue-query';
 import { darkTheme, lightTheme } from 'naive-ui';
 import { defineStore } from 'pinia';
 import { computed, ref, watch } from 'vue';
+import { useUserStore } from './user';
+import router from '@/router';
 
 export const useSettingStore = defineStore(
   NDM_SETTING_STORE_ID,
   () => {
-    const queryClient = useQueryClient();
+    const darkThemeEnabled = ref(true);
-
-    // 主题设置
-    const darkMode = ref(true);
     const themeMode = computed(() => {
-      return darkMode.value ? darkTheme : lightTheme;
+      return darkThemeEnabled.value ? darkTheme : lightTheme;
     });
 
-    // 布局设置
     const menuCollpased = ref(false);
+
     const stationGridCols = ref(6);
 
-    // 调试模式
+    const debugModeEnabled = ref(false);
-    const debugMode = ref(false);
+    const enableDebugMode = () => {
-    /* 数据设置 */
+      debugModeEnabled.value = true;
-    // 显示设备原始数据
+    };
-    const showDeviceRawData = ref(false);
+    const disableDebugMode = () => {
-    /* 网络设置 */
+      debugModeEnabled.value = false;
-    // 轮询车站
+    };
-    const pollingStations = ref(true);
-    // 主动请求
-    const activeRequests = ref(true);
-    // 订阅消息
-    const subscribeMessages = ref(true);
-    // 模拟用户
-    const mockUser = ref(false);
-    /* 数据库设置 */
-    // 使用本地数据库
-    const useLocalDB = ref(false);
 
-    watch(debugMode, (newValue, oldValue) => {
+    // 离线开发模式
-      // 监听关闭调试模式
+    // 控制 版本轮询 stomp连接 app-layout中的自动getUserInfo
-      if (oldValue && !newValue) {
+    const offlineDev = ref(false);
-        showDeviceRawData.value = false;
+    watch(offlineDev, (newValue, oldValue) => {
-        pollingStations.value = true;
+      // 如果启用离线开发模式且当前未登录 自动填写token以绕过路由守卫并跳过登录页
-        activeRequests.value = true;
-        subscribeMessages.value = false;
-        mockUser.value = false;
-        useLocalDB.value = false;
-      }
-    });
-
-    watch(pollingStations, (newValue, oldValue) => {
-      // 监听关闭车站轮询
-      if (oldValue && !newValue) {
-        queryClient.cancelQueries({ queryKey: [LINE_STATIONS_QUERY_KEY] });
-        queryClient.cancelQueries({ queryKey: [LINE_DEVICES_QUERY_KEY] });
-        queryClient.cancelQueries({ queryKey: [LINE_ALARMS_QUERY_KEY] });
-        queryClient.invalidateQueries({ queryKey: [LINE_STATIONS_QUERY_KEY] });
-        queryClient.invalidateQueries({ queryKey: [LINE_DEVICES_QUERY_KEY] });
-        queryClient.invalidateQueries({ queryKey: [LINE_ALARMS_QUERY_KEY] });
-      }
-    });
-
-    watch(mockUser, (newValue, oldValue) => {
-      // 监听启用模拟用户
       if (!oldValue && newValue) {
-        // 如果启当前未登录，填写token以绕过路由守卫
         const userStore = useUserStore();
         if (!userStore.userLoginResult) {
           userStore.userLoginResult = {
@@ -78,11 +42,9 @@ export const useSettingStore = defineStore(
             expiration: '',
           };
         }
-        // 如果token为空，填写token
         if (!userStore.userLoginResult.token) {
           userStore.userLoginResult.token = 'test';
         }
-        // 如果用户信息为空，填写用户信息
         if (!userStore.userInfo) {
           userStore.userInfo = {
             id: '2',
@@ -93,42 +55,35 @@ export const useSettingStore = defineStore(
             tenantId: '1',
           };
         }
-        // 如果当前路由为登录页，跳转到首页
         if (router.currentRoute.value.path === '/login') {
           router.push({ path: '/' });
         }
-        // 开启模拟用户时，也开启调试模式，但关闭其他的网络设置
-        debugMode.value = true;
-        pollingStations.value = false;
-        activeRequests.value = false;
-        subscribeMessages.value = false;
       }
     });
 
     return {
-      darkMode,
+      darkThemeEnabled,
       themeMode,
 
       menuCollpased,
+
       stationGridCols,
 
-      debugMode,
+      debugModeEnabled,
-      showDeviceRawData,
+      enableDebugMode,
-      pollingStations,
+      disableDebugMode,
-      activeRequests,
+
-      subscribeMessages,
+      offlineDev,
-      mockUser,
-      useLocalDB,
     };
   },
   {
     persist: [
       {
-        omit: ['showDeviceRawData'],
+        omit: ['debugModeEnabled'],
         storage: window.localStorage,
       },
       {
-        pick: ['showDeviceRawData'],
+        pick: ['debugModeEnabled'],
         storage: window.sessionStorage,
       },
     ],

src/stores/unread.ts

@@ -1,44 +0,0 @@
-import { initStationAlarms, type LineAlarms, type NdmDeviceAlarmLogResultVO } from '@/apis';
-import { NDM_UNREAD_STORE_ID } from '@/constants';
-import { tryGetDeviceType } from '@/enums';
-import { defineStore } from 'pinia';
-import { computed, shallowRef, triggerRef } from 'vue';
-
-export const useUnreadStore = defineStore(NDM_UNREAD_STORE_ID, () => {
-  // 全线所有车站的未读告警 (来自stomp订阅)
-  const unreadLineAlarms = shallowRef<LineAlarms>({});
-  const unreadAlarmCount = computed(() => {
-    let count = 0;
-    Object.values(unreadLineAlarms.value).forEach((stationAlarms) => {
-      count += stationAlarms['unclassified'].length;
-    });
-    return count;
-  });
-
-  const pushUnreadAlarm = (alarm: NdmDeviceAlarmLogResultVO) => {
-    const stationCode = alarm.stationCode;
-    if (!stationCode) return;
-    if (!unreadLineAlarms.value[stationCode]) {
-      unreadLineAlarms.value[stationCode] = initStationAlarms();
-    }
-    const deviceType = tryGetDeviceType(alarm.deviceType);
-    if (!deviceType) return;
-    const stationAlarms = unreadLineAlarms.value[stationCode];
-    stationAlarms[deviceType].push(alarm);
-    stationAlarms['unclassified'].push(alarm);
-    triggerRef(unreadLineAlarms);
-  };
-
-  const clearUnreadAlarms = () => {
-    unreadLineAlarms.value = {};
-    triggerRef(unreadLineAlarms);
-  };
-
-  return {
-    unreadLineAlarms,
-    unreadAlarmCount,
-
-    pushUnreadAlarm,
-    clearUnreadAlarms,
-  };
-});