Compare commits

...

22 Commits

Author SHA1 Message Date
yangsy
bd7238a7f1 style: code state 2025-12-11 01:30:37 +08:00
yangsy
6c7897198c fix: alarm-query and secutiryBox switch states 2025-12-11 01:30:11 +08:00
yangsy
15a9f68db7 fix(device-alarm-history-diag-card): throw error if deviceId is undefined/null 2025-12-08 11:15:45 +08:00
yangsy
70f52eb3bb fix(use-device-selection): default select to Camera 2025-12-08 11:10:20 +08:00
yangsy
c189f79aa4 fix(security-box-info-card): access status 2025-12-07 11:05:44 +08:00
yangsy
8e9bd75067 feat: sync-camera-result-modal 2025-12-03 16:48:33 +08:00
yangsy
a215f2e391 feat: multiselect stations to export device icmp state 2025-12-03 10:44:14 +08:00
yangsy
e19fcf79a6 chore: vite proxy 2025-12-03 10:43:23 +08:00
yangsy
54591f401f refactor: remove console.log 2025-12-01 15:33:47 +08:00
yangsy
2116631ba6 fix: avoid mutation error from interrupting query 2025-12-01 15:22:50 +08:00
yangsy
b4e2926f08 fix: sync camera & channels 2025-12-01 15:20:11 +08:00
yangsy
168d11c71b style 2025-12-01 14:43:58 +08:00
yangsy
b0c0b88091 fix: /syncCamera 2025-12-01 14:43:42 +08:00
yangsy
f7d1d2d44c fix(security-box-info-card): access status 2025-12-01 11:30:08 +08:00
yangsy
de723dce00 fix: removeCameraIgnoreApi 2025-11-29 23:18:35 +08:00
yangsy
f0ab42613b refactor(enums): Tab order of DeviceTree 2025-11-28 15:03:22 +08:00
yangsy
4272cd90de fix: wait for 5s after syncCamera then refetch polling 2025-11-28 14:41:48 +08:00
yangsy
fb7657f99c feat: fold/expand menu 2025-11-28 00:13:05 +08:00
yangsy
7f9d868643 feat(statioin-page): action button group 2025-11-27 17:59:39 +08:00
yangsy
f278a690c6 refactor: move /helper 2025-11-27 16:01:50 +08:00
yangsy
d4eade65c4 refactor(station): inrerface Station 2025-11-27 15:59:15 +08:00
yangsy
dec1c4ea17 refactor(api): ndm-record-check 2025-11-27 11:49:57 +08:00
45 changed files with 749 additions and 255 deletions

View File

@@ -2,5 +2,5 @@ export interface Station {
code: string; code: string;
name: string; name: string;
online: boolean; online: boolean;
ip?: string; ip: string;
} }

View File

@@ -15,4 +15,5 @@ export * from './alarm';
export * from './log'; export * from './log';
export * from './other'; export * from './other';
export * from './storage'; export * from './storage';
export * from './upper-ndm';
export * from './video'; export * from './video';

View File

@@ -0,0 +1,2 @@
export * from './sync-camera-result';
export * from './sync-camera-result-detail';

View File

@@ -0,0 +1,6 @@
export interface SyncCameraResultDetail {
name: string;
deviceId: string;
ipAddress: string;
gbCode: string;
}

View File

@@ -0,0 +1,10 @@
import type { SyncCameraResultDetail } from './sync-camera-result-detail';
export interface SyncCameraResult {
stationCode: string;
startTime: string;
endTime: string;
insertList: SyncCameraResultDetail[];
updateList: SyncCameraResultDetail[];
deleteList: SyncCameraResultDetail[];
}

View File

@@ -1,5 +1,6 @@
export * from './ndm-call-log'; export * from './ndm-call-log';
export * from './ndm-device-alarm-log'; export * from './ndm-device-alarm-log';
export * from './ndm-icmp-log'; export * from './ndm-icmp-log';
export * from './ndm-record-check';
export * from './ndm-snmp-log'; export * from './ndm-snmp-log';
export * from './ndm-vimp-log'; export * from './ndm-vimp-log';

View File

@@ -0,0 +1,59 @@
import { ndmClient, userClient, type ClientChannel, type NdmNvrResultVO, type NdmRecordCheck } from '@/apis';
import dayjs from 'dayjs';
export const getChannelListApi = async (ndmNvr: NdmNvrResultVO, options?: { stationCode?: string; signal?: AbortSignal }) => {
const { stationCode, signal } = options ?? {};
const client = stationCode ? ndmClient : userClient;
const prefix = stationCode ? `/${stationCode}` : '';
const endpoint = `${prefix}/api/ndm/ndmRecordCheck/getChannelList`;
const resp = await client.post<ClientChannel[]>(endpoint, { code: ndmNvr.gbCode, time: '' }, { signal });
const [err, data] = resp;
if (err || !data) {
throw err;
}
return data;
};
export const getRecordCheckApi = async (ndmNvr: NdmNvrResultVO, lastDays: number, gbCodeList: string[], options?: { stationCode?: string; signal?: AbortSignal }) => {
const { stationCode, signal } = options ?? {};
const client = stationCode ? ndmClient : userClient;
const prefix = stationCode ? `/${stationCode}` : '';
const endpoint = `${prefix}/api/ndm/ndmRecordCheck/getRecordCheckByParentId`;
const endDateTime = dayjs();
const startDateTime = endDateTime.subtract(lastDays, 'day');
const start = startDateTime.format('YYYY-MM-DD');
const end = endDateTime.format('YYYY-MM-DD');
const parentId = ndmNvr.gbCode;
const resp = await client.post<NdmRecordCheck[]>(endpoint, { start, end, parentId, gbCodeList }, { signal });
const [err, data] = resp;
if (err || !data) {
throw err;
}
return data;
};
export const reloadRecordCheckApi = async (channel: ClientChannel, dayOffset: number, options?: { stationCode?: string; signal?: AbortSignal }) => {
const { stationCode, signal } = options ?? {};
const client = stationCode ? ndmClient : userClient;
const prefix = stationCode ? `/${stationCode}` : '';
const endpoint = `${prefix}/api/ndm/ndmRecordCheck/reloadRecordCheckByGbId`;
const resp = await client.post<boolean>(endpoint, { ...channel, dayOffset }, { signal });
const [err, data] = resp;
if (err || !data) {
throw err;
}
return data;
};
export const reloadAllRecordCheckApi = async (dayOffset: number, options?: { stationCode?: string; signal?: AbortSignal }) => {
const { stationCode, signal } = options ?? {};
const client = stationCode ? ndmClient : userClient;
const prefix = stationCode ? `/${stationCode}` : '';
const endpoint = `${prefix}/api/ndm/ndmRecordCheck/reloadAllRecordCheck`;
const resp = await client.post<boolean>(endpoint, dayOffset, { signal });
const [err, data] = resp;
if (err || !data) {
throw err;
}
return data;
};

View File

@@ -52,59 +52,14 @@ export const probeNvrApi = async (ids: string[], options?: { stationCode?: strin
} }
}; };
export const getChannelListApi = async (ndmNvr: NdmNvrResultVO, options?: { stationCode?: string; signal?: AbortSignal }) => { export const syncNvrChannelsApi = async (options?: { stationCode?: string; signal?: AbortSignal }) => {
const { stationCode, signal } = options ?? {}; const { stationCode, signal } = options ?? {};
const client = stationCode ? ndmClient : userClient; const client = stationCode ? ndmClient : userClient;
const prefix = stationCode ? `/${stationCode}` : ''; const prefix = stationCode ? `/${stationCode}` : '';
const endpoint = `${prefix}/api/ndm/ndmRecordCheck/getChannelList`; const endpoint = `${prefix}/api/ndm/ndmNvr/syncNvrChannels`;
const resp = await client.post<ClientChannel[]>(endpoint, { code: ndmNvr.gbCode, time: '' }, { signal }); const resp = await client.get<void>(endpoint, { signal });
const [err, data] = resp; const [err] = resp;
if (err || !data) { if (err) {
throw err; throw err;
} }
return data;
};
export const getRecordCheckApi = async (ndmNvr: NdmNvrResultVO, lastDays: number, gbCodeList: string[], options?: { stationCode?: string; signal?: AbortSignal }) => {
const { stationCode, signal } = options ?? {};
const client = stationCode ? ndmClient : userClient;
const prefix = stationCode ? `/${stationCode}` : '';
const endpoint = `${prefix}/api/ndm/ndmRecordCheck/getRecordCheckByParentId`;
const endDateTime = dayjs();
const startDateTime = endDateTime.subtract(lastDays, 'day');
const start = startDateTime.format('YYYY-MM-DD');
const end = endDateTime.format('YYYY-MM-DD');
const parentId = ndmNvr.gbCode;
const resp = await client.post<NdmRecordCheck[]>(endpoint, { start, end, parentId, gbCodeList }, { signal });
const [err, data] = resp;
if (err || !data) {
throw err;
}
return data;
};
export const reloadRecordCheckApi = async (channel: ClientChannel, dayOffset: number, options?: { stationCode?: string; signal?: AbortSignal }) => {
const { stationCode, signal } = options ?? {};
const client = stationCode ? ndmClient : userClient;
const prefix = stationCode ? `/${stationCode}` : '';
const endpoint = `${prefix}/api/ndm/ndmRecordCheck/reloadRecordCheckByGbId`;
const resp = await client.post<boolean>(endpoint, { ...channel, dayOffset }, { signal });
const [err, data] = resp;
if (err || !data) {
throw err;
}
return data;
};
export const reloadAllRecordCheckApi = async (dayOffset: number, options?: { stationCode?: string; signal?: AbortSignal }) => {
const { stationCode, signal } = options ?? {};
const client = stationCode ? ndmClient : userClient;
const prefix = stationCode ? `/${stationCode}` : '';
const endpoint = `${prefix}/api/ndm/ndmRecordCheck/reloadAllRecordCheck`;
const resp = await client.post<boolean>(endpoint, dayOffset, { signal });
const [err, data] = resp;
if (err || !data) {
throw err;
}
return data;
}; };

View File

@@ -59,7 +59,7 @@ export const removeCameraIgnoreApi = async (ids: string[], options?: { stationCo
const endpoint = `${prefix}/api/ndm/ndmCameraIgnore`; const endpoint = `${prefix}/api/ndm/ndmCameraIgnore`;
const resp = await client.delete<boolean>(endpoint, ids, { signal }); const resp = await client.delete<boolean>(endpoint, ids, { signal });
const [err, data] = resp; const [err, data] = resp;
if (err || !data) { if (err || data === null) {
throw err; throw err;
} }
return data; return data;

View File

@@ -49,3 +49,16 @@ export const getCameraSnapApi = async (deviceId: string, options?: { signal?: Ab
} }
return data; return data;
}; };
export const syncCameraApi = async (options?: { stationCode?: string; signal?: AbortSignal }) => {
const { stationCode, signal } = options ?? {};
const client = stationCode ? ndmClient : userClient;
const prefix = stationCode ? `/${stationCode}` : '';
const endpoint = `${prefix}/api/ndm/ndmCamera/syncCamera`;
const resp = await client.get<boolean>(endpoint, { signal });
const [err, data] = resp;
if (err || !data) {
throw err;
}
return data;
};

View File

@@ -1,81 +1,15 @@
<script setup lang="ts"> <script setup lang="ts">
import type { NdmNvrResultVO, NdmRecordCheck, RecordInfo, RecordItem, Station } from '@/apis'; import type { NdmNvrResultVO, NdmRecordCheck, RecordItem, Station } from '@/apis';
import { getChannelListApi, getRecordCheckApi as getRecordCheckByParentIdApi, reloadAllRecordCheckApi as reloadAllRecordCheckApi, reloadRecordCheckApi as reloadRecordCheckByGbIdApi } from '@/apis'; import { getChannelListApi, getRecordCheckApi as getRecordCheckByParentIdApi, reloadAllRecordCheckApi as reloadAllRecordCheckApi, reloadRecordCheckApi as reloadRecordCheckByGbIdApi } from '@/apis';
import { exportRecordDiagCsv, transformRecordChecks } from '@/helper';
import { useStationStore } from '@/stores'; import { useStationStore } from '@/stores';
import { downloadByData, formatDuration } from '@/utils';
import { useMutation } from '@tanstack/vue-query'; import { useMutation } from '@tanstack/vue-query';
import { DownloadOutlined } from '@vicons/antd'; import { DownloadOutlined } from '@vicons/antd';
import { RefreshOutline } from '@vicons/ionicons5'; import { RefreshOutline } from '@vicons/ionicons5';
import dayjs from 'dayjs'; import dayjs from 'dayjs';
import destr from 'destr';
import { groupBy } from 'es-toolkit';
import { NButton, NCard, NFlex, NIcon, NPagination, NPopconfirm, NPopover, NRadioButton, NRadioGroup, NTooltip, useThemeVars } from 'naive-ui'; import { NButton, NCard, NFlex, NIcon, NPagination, NPopconfirm, NPopover, NRadioButton, NRadioGroup, NTooltip, useThemeVars } from 'naive-ui';
import { computed, onMounted, ref, toRefs } from 'vue'; import { computed, onMounted, ref, toRefs } from 'vue';
type NvrRecordDiag = {
gbCode: string;
channelName: string;
recordDuration: RecordItem;
lostChunks: RecordItem[];
};
// 解析出丢失的录像时间段
const transformRecordChecks = (rawRecordChecks: NdmRecordCheck[]): NvrRecordDiag[] => {
// 解析diagInfo
const parsedRecordChecks = rawRecordChecks.map((recordCheck) => ({
...recordCheck,
diagInfo: destr<RecordInfo>(recordCheck.diagInfo),
}));
// 按国标码分组
const recordChecksByGbCode = groupBy(parsedRecordChecks, (recordCheck) => recordCheck.gbCode);
// 提取分组后的国标码和录像诊断记录
const channelGbCodes = Object.keys(recordChecksByGbCode);
const recordChecksList = Object.values(recordChecksByGbCode);
// 初始化每个通道的录像诊断数据结构
const recordDiags = channelGbCodes.map((gbCode, index) => ({
gbCode,
channelName: recordChecksList.at(index)?.at(-1)?.name ?? '',
records: [] as RecordItem[],
lostChunks: [] as RecordItem[],
}));
// 写入同一gbCode的录像片段
recordChecksList.forEach((recordChecks, index) => {
recordChecks.forEach((recordCheck) => {
recordDiags.at(index)?.records.push(...recordCheck.diagInfo.recordList);
});
});
// 过滤掉没有录像记录的通道
const filteredRecordDiags = recordDiags.filter((recordDiag) => recordDiag.records.length > 0);
// 计算每个通道丢失的录像时间片段
filteredRecordDiags.forEach((recordDiag) => {
recordDiag.records.forEach((record, index, records) => {
if (!!records.at(index + 1)) {
// 如果下一段录像的开始时间不等于当前录像的结束时间,则判定为丢失
const nextStartTime = records[index + 1].startTime;
const currEndTime = record.endTime;
if (nextStartTime !== currEndTime) {
recordDiag.lostChunks.push({
startTime: currEndTime,
endTime: nextStartTime,
});
}
}
});
});
return recordDiags.map((recordDiag) => {
const firstRecord = recordDiag.records.at(0);
const startTime = firstRecord ? dayjs(firstRecord.startTime).format('YYYY-MM-DD HH:mm:ss') : '';
const lastRecord = recordDiag.records.at(-1);
const endTime = lastRecord ? dayjs(lastRecord.endTime).format('YYYY-MM-DD HH:mm:ss') : '';
return {
gbCode: recordDiag.gbCode,
channelName: recordDiag.channelName,
recordDuration: { startTime, endTime },
lostChunks: recordDiag.lostChunks,
};
});
};
const props = defineProps<{ const props = defineProps<{
stationCode: Station['code']; stationCode: Station['code'];
ndmNvr: NdmNvrResultVO; ndmNvr: NdmNvrResultVO;
@@ -128,27 +62,9 @@ const { mutate: reloadAllRecordCheck, isPending: reloading } = useMutation({
}); });
const onExportRecordCheck = () => { const onExportRecordCheck = () => {
const header = '通道名称,开始时间,结束时间,持续时长\n';
const rows = recordDiags.value
.map((channel) => {
if (channel.lostChunks.length === 0) {
return `${channel.channelName},,,`;
}
return channel.lostChunks
.map((loss) => {
const duration = formatDuration(loss.startTime, loss.endTime);
const startTime = dayjs(loss.startTime).format('YYYY-MM-DD HH:mm:ss');
const endTime = dayjs(loss.endTime).format('YYYY-MM-DD HH:mm:ss');
return `${channel.channelName},${startTime},${endTime},${duration}`;
})
.join('\n');
})
.join('\n');
const csvContent = header + rows;
const stationStore = useStationStore(); const stationStore = useStationStore();
const stationName = stationStore.stationList.find((station) => station.code === stationCode.value)?.name; const stationName = stationStore.stationList.find((station) => station.code === stationCode.value)?.name ?? '';
const time = dayjs().format('YYYY-MM-DD_HH-mm-ss'); exportRecordDiagCsv(recordDiags.value, stationName);
downloadByData(csvContent, `${stationName}_录像缺失记录_${time}.csv`, 'text/csv;charset=utf-8', '\ufeff');
}; };
const page = ref(1); const page = ref(1);

View File

@@ -17,22 +17,24 @@ const cardShow = computed(() => {
return Object.values(props).some((value) => !!value); return Object.values(props).some((value) => !!value);
}); });
// 门禁状态 (switches[0]: 0=关闭/失效, 1=打开/生效) // 门禁状态
const accessControlStatus = computed(() => { const accessControlStatus = computed(() => {
if (!switches?.value || switches.value.length === 0) return null; if (!switches?.value || switches.value.length === 0) return null;
return switches.value[0] === 1 ? '打开' : '关闭'; const status = switches.value.at(0)!;
return status === 0 ? '开门' : status === 1 ? '关门' : '-';
}); });
// 防雷状态 (switches[1]: 0=关闭/失效, 1=打开/生效) // 防雷状态
const lightningProtectionStatus = computed(() => { const lightningProtectionStatus = computed(() => {
if (!switches?.value || switches.value.length < 2) return null; if (!switches?.value || switches.value.length < 2) return null;
return switches.value[1] === 1 ? '生效' : '失效'; const status = switches.value.at(1)!;
return status === 0 ? '正常' : status === 1 ? '失效' : '-';
}); });
// 获取状态标签类型 // 获取状态标签类型
const getStatusTagType = (status: string | null) => { const getStatusTagType = (status: string | null) => {
if (['打开', '生效'].includes(status ?? '')) return 'success'; if (['正常'].includes(status ?? '')) return 'success';
if (['关闭', '失效'].includes(status ?? '')) return 'error'; if (['失效'].includes(status ?? '')) return 'error';
return 'default'; return 'default';
}; };

View File

@@ -16,7 +16,7 @@
*/ */
import type { NdmSwitchPortInfo } from '@/apis'; import type { NdmSwitchPortInfo } from '@/apis';
import { getPortStatusVal, transformPortSpeed } from '@/components'; import { getPortStatusVal, transformPortSpeed } from '@/helper';
import { NCard, NGrid, NGridItem, NPopover } from 'naive-ui'; import { NCard, NGrid, NGridItem, NPopover } from 'naive-ui';
import { computed, toRefs } from 'vue'; import { computed, toRefs } from 'vue';

View File

@@ -1,6 +1,6 @@
<script setup lang="ts"> <script setup lang="ts">
import { pageDeviceAlarmLogApi, type NdmDeviceAlarmLogResultVO, type NdmDeviceResultVO, type PageParams } from '@/apis'; import { pageDeviceAlarmLogApi, type NdmDeviceAlarmLogResultVO, type NdmDeviceResultVO, type PageParams } from '@/apis';
import { renderAlarmDateCell, renderAlarmTypeCell, renderFaultDescriptionCell, renderFaultLevelCell } from '@/components'; import { renderAlarmDateCell, renderAlarmTypeCell, renderFaultDescriptionCell, renderFaultLevelCell } from '@/helper';
import { useMutation } from '@tanstack/vue-query'; import { useMutation } from '@tanstack/vue-query';
import { NCard, NDataTable, type DataTableColumns, type DataTableRowData, type DatePickerProps, type PaginationProps } from 'naive-ui'; import { NCard, NDataTable, type DataTableColumns, type DataTableRowData, type DatePickerProps, type PaginationProps } from 'naive-ui';
import { h } from 'vue'; import { h } from 'vue';
@@ -78,6 +78,7 @@ const { mutate: getDeviceAlarmLogList, isPending } = useMutation({
if (!dateTimeRange.value) throw new Error('请选择时间范围'); if (!dateTimeRange.value) throw new Error('请选择时间范围');
const range = dateTimeRange.value as [number, number]; const range = dateTimeRange.value as [number, number];
const deviceId = ndmDevice.value.deviceId; const deviceId = ndmDevice.value.deviceId;
if (!deviceId) throw new Error('该设备未配置设备ID');
const alarmDate_ge = range[0]; const alarmDate_ge = range[0];
const alarmDate_le = range[1]; const alarmDate_le = range[1];
const restParams: Omit<PageParams<{ id: string }>, 'model' | 'extra'> = { const restParams: Omit<PageParams<{ id: string }>, 'model' | 'extra'> = {

View File

@@ -1,6 +1,7 @@
<script setup lang="ts"> <script setup lang="ts">
import type { NdmNvrResultVO } from '@/apis'; import type { NdmNvrResultVO } from '@/apis';
import { DeviceAlarmHistoryDiagCard, DeviceStatusHistoryDiagCard, DeviceUsageHistoryDiagCard, isNvrCluster, NvrDiskHealthHistoryDiagCard } from '@/components'; import { DeviceAlarmHistoryDiagCard, DeviceStatusHistoryDiagCard, DeviceUsageHistoryDiagCard, NvrDiskHealthHistoryDiagCard } from '@/components';
import { isNvrCluster } from '@/helper';
import dayjs from 'dayjs'; import dayjs from 'dayjs';
import { NButton, NCard, NDatePicker, NFlex, NGi, NGrid, NSelect, type DatePickerProps, type SelectOption } from 'naive-ui'; import { NButton, NCard, NDatePicker, NFlex, NGi, NGrid, NSelect, type DatePickerProps, type SelectOption } from 'naive-ui';
import { computed, onMounted, reactive, ref, toRefs, useTemplateRef } from 'vue'; import { computed, onMounted, reactive, ref, toRefs, useTemplateRef } from 'vue';

View File

@@ -1,6 +1,6 @@
<script setup lang="ts"> <script setup lang="ts">
import { pageSnmpLogApi, type NdmSwitchDiagInfo, type NdmSwitchPortInfo, type NdmSwitchResultVO, type PageParams } from '@/apis'; import { pageSnmpLogApi, type NdmSwitchDiagInfo, type NdmSwitchPortInfo, type NdmSwitchResultVO, type PageParams } from '@/apis';
import { getPortStatusVal, transformPortSpeed } from '@/components'; import { getPortStatusVal, transformPortSpeed } from '@/helper';
import { useMutation } from '@tanstack/vue-query'; import { useMutation } from '@tanstack/vue-query';
import dayjs from 'dayjs'; import dayjs from 'dayjs';
import destr from 'destr'; import destr from 'destr';

View File

@@ -1,6 +1,7 @@
<script setup lang="ts"> <script setup lang="ts">
import type { NdmNvrDiagInfo, NdmNvrResultVO } from '@/apis'; import type { NdmNvrDiagInfo, NdmNvrResultVO } from '@/apis';
import { DeviceCommonCard, DeviceHardwareCard, DeviceHeaderCard, isNvrCluster, NvrDiskCard, NvrHistoryDiagCard, NvrRecordDiagCard } from '@/components'; import { DeviceCommonCard, DeviceHardwareCard, DeviceHeaderCard, NvrDiskCard, NvrHistoryDiagCard, NvrRecordDiagCard } from '@/components';
import { isNvrCluster } from '@/helper';
import { useSettingStore } from '@/stores'; import { useSettingStore } from '@/stores';
import { destr } from 'destr'; import { destr } from 'destr';
import { NCard, NFlex, NTabPane, NTabs } from 'naive-ui'; import { NCard, NFlex, NTabPane, NTabs } from 'naive-ui';

View File

@@ -10,7 +10,7 @@ const deviceTabPanes = Object.keys(DeviceType).map((key) => {
<script setup lang="ts"> <script setup lang="ts">
import type { LineDevices, NdmDeviceResultVO, NdmNvrResultVO, Station } from '@/apis'; import type { LineDevices, NdmDeviceResultVO, NdmNvrResultVO, Station } from '@/apis';
import { isNvrCluster } from '@/components'; import { isNvrCluster } from '@/helper';
import { DeviceType, DeviceTypeName, tryGetDeviceTypeVal, type DeviceTypeKey, type DeviceTypeVal } from '@/enums'; import { DeviceType, DeviceTypeName, tryGetDeviceTypeVal, type DeviceTypeKey, type DeviceTypeVal } from '@/enums';
import { destr } from 'destr'; import { destr } from 'destr';
import { import {
@@ -262,7 +262,7 @@ const scrollDeviceTreeToSelectedDevice = () => {
<template> <template>
<div style="height: 100%; display: flex; flex-direction: column"> <div style="height: 100%; display: flex; flex-direction: column">
<div style="flex-shrink: 0; padding: 12px"> <div style="padding: 12px; flex-shrink: 0">
<NInput v-model:value="searchInput" placeholder="搜索设备名称、设备ID或IP地址" clearable /> <NInput v-model:value="searchInput" placeholder="搜索设备名称、设备ID或IP地址" clearable />
<NFlex justify="space-between" align="center"> <NFlex justify="space-between" align="center">
<NRadioGroup v-model:value="statusInput"> <NRadioGroup v-model:value="statusInput">
@@ -277,13 +277,13 @@ const scrollDeviceTreeToSelectedDevice = () => {
</NFlex> </NFlex>
</div> </div>
<div style="flex: 1; min-height: 0; display: flex; overflow: hidden"> <div style="min-height: 0; overflow: hidden; flex: 1; display: flex">
<div style="flex: 0 0 auto; height: 100%"> <div style="height: 100%; flex: 0 0 auto">
<NTabs v-model:value="activeTab" animated type="line" placement="left" style="height: 100%"> <NTabs v-model:value="activeTab" animated type="line" placement="left" style="height: 100%">
<NTab v-for="pane in deviceTabPanes" :key="pane.name" :name="pane.name" :tab="pane.tab"></NTab> <NTab v-for="pane in deviceTabPanes" :key="pane.name" :name="pane.name" :tab="pane.tab"></NTab>
</NTabs> </NTabs>
</div> </div>
<div style="flex: 1 1 auto; min-width: 0"> <div style="min-width: 0; flex: 1 1 auto">
<NTree <NTree
:ref="'deviceTreeInst'" :ref="'deviceTreeInst'"
v-model:expanded-keys="expandedKeys" v-model:expanded-keys="expandedKeys"

View File

@@ -7,7 +7,7 @@ import { getAppEnvConfig } from '@/utils';
import { useQueryClient } from '@tanstack/vue-query'; import { useQueryClient } from '@tanstack/vue-query';
import { useEventListener } from '@vueuse/core'; import { useEventListener } from '@vueuse/core';
import axios from 'axios'; import axios from 'axios';
import { NButton, NDivider, NDrawer, NDrawerContent, NFlex, NFormItem, NInput, NInputNumber, NModal, NRadio, NRadioGroup, NText } from 'naive-ui'; import { NButton, NDivider, NDrawer, NDrawerContent, NFlex, NFormItem, NInput, NInputNumber, NModal, NRadio, NRadioGroup, NSwitch, NText } from 'naive-ui';
import { storeToRefs } from 'pinia'; import { storeToRefs } from 'pinia';
import { onMounted, ref, watch } from 'vue'; import { onMounted, ref, watch } from 'vue';
import { useRoute } from 'vue-router'; import { useRoute } from 'vue-router';
@@ -17,7 +17,7 @@ const route = useRoute();
const show = defineModel<boolean>('show'); const show = defineModel<boolean>('show');
const settingStore = useSettingStore(); const settingStore = useSettingStore();
const { stationGridColumns, debugModeEnabled } = storeToRefs(settingStore); const { stationGridColumns, debugModeEnabled, menuCollpased } = storeToRefs(settingStore);
const pollingStore = usePollingStore(); const pollingStore = usePollingStore();
const { stationVerifyMode } = storeToRefs(pollingStore); const { stationVerifyMode } = storeToRefs(pollingStore);
@@ -68,8 +68,11 @@ useEventListener('keydown', (event) => {
<NFormItem label="深色模式" label-placement="left"> <NFormItem label="深色模式" label-placement="left">
<ThemeSwitch /> <ThemeSwitch />
</NFormItem> </NFormItem>
<template v-if="route.path === '/station'">
<NDivider>布局</NDivider> <NDivider>布局</NDivider>
<NFormItem label="折叠菜单" label-placement="left">
<NSwitch v-model:value="menuCollpased" />
</NFormItem>
<template v-if="route.path === '/station'">
<NFormItem label="车站列数" label-placement="left"> <NFormItem label="车站列数" label-placement="left">
<NInputNumber v-model:value="stationGridColumns" :min="1" :max="10" /> <NInputNumber v-model:value="stationGridColumns" :min="1" :max="10" />
</NFormItem> </NFormItem>

View File

@@ -1,4 +1,3 @@
export * from './device-page'; export * from './device-page';
export * from './global'; export * from './global';
export * from './helper';
export * from './station-page'; export * from './station-page';

View File

@@ -10,12 +10,12 @@ import {
type StationAlarmCounts, type StationAlarmCounts,
} from '@/apis'; } from '@/apis';
import { AlarmType, DeviceType, DeviceTypeCode, DeviceTypeName, FaultLevel, type DeviceTypeVal } from '@/enums'; import { AlarmType, DeviceType, DeviceTypeCode, DeviceTypeName, FaultLevel, type DeviceTypeVal } from '@/enums';
import { renderAlarmDateCell, renderDeviceTypeCell, renderAlarmTypeCell, renderFaultLevelCell } from '@/helper';
import { downloadByData } from '@/utils'; import { downloadByData } from '@/utils';
import { useMutation } from '@tanstack/vue-query'; import { useMutation } from '@tanstack/vue-query';
import dayjs from 'dayjs'; import dayjs from 'dayjs';
import { NButton, NCol, NDataTable, NModal, NRow, NSpace, NStatistic, NTag, type DataTableColumns, type DataTableProps, type DataTableRowData, type PaginationProps } from 'naive-ui'; import { NButton, NDataTable, NGrid, NGridItem, NModal, NSpace, NStatistic, NTag, type DataTableColumns, type DataTableProps, type DataTableRowData, type PaginationProps } from 'naive-ui';
import { computed, h, reactive, ref, toRefs } from 'vue'; import { computed, h, reactive, ref, toRefs } from 'vue';
import { renderAlarmDateCell, renderDeviceTypeCell, renderAlarmTypeCell, renderFaultLevelCell } from '../helper';
interface Props { interface Props {
station?: Station; station?: Station;
@@ -125,7 +125,7 @@ const resetFilterFields = () => {
filterFields.faultLevel_in = []; filterFields.faultLevel_in = [];
}; };
const tablePagination = reactive<PaginationProps>({ const pagination = reactive<PaginationProps>({
size: 'small', size: 'small',
showSizePicker: true, showSizePicker: true,
page: 1, page: 1,
@@ -135,27 +135,27 @@ const tablePagination = reactive<PaginationProps>({
return h('div', {}, { default: () => `${itemCount}` }); return h('div', {}, { default: () => `${itemCount}` });
}, },
onUpdatePage: (page: number) => { onUpdatePage: (page: number) => {
tablePagination.page = page; pagination.page = page;
getStaionAlarmList(); getTableData();
}, },
onUpdatePageSize: (pageSize: number) => { onUpdatePageSize: (pageSize: number) => {
tablePagination.pageSize = pageSize; pagination.pageSize = pageSize;
tablePagination.page = 1; pagination.page = 1;
getStaionAlarmList(); getTableData();
}, },
}); });
const tableData = ref<DataTableRowData[]>([]); const tableData = ref<DataTableRowData[]>([]);
const onAfterModalEnter = () => { const onAfterModalEnter = () => {
getStaionAlarmList(); getTableData();
}; };
const onAfterModalLeave = () => { const onAfterModalLeave = () => {
resetFilterFields(); resetFilterFields();
tablePagination.page = 1; pagination.page = 1;
tablePagination.pageSize = 10; pagination.pageSize = 10;
tablePagination.itemCount = 0; pagination.itemCount = 0;
tableData.value = []; tableData.value = [];
}; };
@@ -168,10 +168,10 @@ const onUpdateFilters: DataTableProps['onUpdateFilters'] = (filterState) => {
filterFields.alarmType_in = alarmTypeKeys; filterFields.alarmType_in = alarmTypeKeys;
const faultLevelVals = filterState['faultLevel']; const faultLevelVals = filterState['faultLevel'];
filterFields.faultLevel_in = faultLevelVals; filterFields.faultLevel_in = faultLevelVals;
getStaionAlarmList(); getTableData();
}; };
const { mutate: getStaionAlarmList, isPending: tableLoading } = useMutation({ const { mutate: getTableData, isPending: loading } = useMutation({
mutationFn: async () => { mutationFn: async () => {
const now = dayjs(); const now = dayjs();
const res = await pageDeviceAlarmLogApi( const res = await pageDeviceAlarmLogApi(
@@ -188,8 +188,8 @@ const { mutate: getStaionAlarmList, isPending: tableLoading } = useMutation({
createdTime_precisest: now.startOf('date').format('YYYY-MM-DD HH:mm:ss'), createdTime_precisest: now.startOf('date').format('YYYY-MM-DD HH:mm:ss'),
createdTime_preciseed: now.endOf('date').format('YYYY-MM-DD HH:mm:ss'), createdTime_preciseed: now.endOf('date').format('YYYY-MM-DD HH:mm:ss'),
}, },
current: tablePagination.page ?? 1, current: pagination.page ?? 1,
size: tablePagination.pageSize ?? 10, size: pagination.pageSize ?? 10,
order: 'descending', order: 'descending',
sort: 'id', sort: 'id',
}, },
@@ -201,8 +201,8 @@ const { mutate: getStaionAlarmList, isPending: tableLoading } = useMutation({
}, },
onSuccess: (res) => { onSuccess: (res) => {
const { records, size, total } = res; const { records, size, total } = res;
tablePagination.pageSize = parseInt(size); pagination.pageSize = parseInt(size);
tablePagination.itemCount = parseInt(total); pagination.itemCount = parseInt(total);
tableData.value = records; tableData.value = records;
}, },
onError: (error) => { onError: (error) => {
@@ -226,8 +226,8 @@ const { mutate: exportTableData, isPending: exporting } = useMutation({
createdTime_precisest: now.startOf('date').format('YYYY-MM-DD HH:mm:ss'), createdTime_precisest: now.startOf('date').format('YYYY-MM-DD HH:mm:ss'),
createdTime_preciseed: now.endOf('date').format('YYYY-MM-DD HH:mm:ss'), createdTime_preciseed: now.endOf('date').format('YYYY-MM-DD HH:mm:ss'),
}, },
current: tablePagination.page ?? 1, current: pagination.page ?? 1,
size: tablePagination.pageSize ?? 10, size: pagination.pageSize ?? 10,
order: 'descending', order: 'descending',
sort: 'id', sort: 'id',
}, },
@@ -264,11 +264,11 @@ const { mutate: exportTableData, isPending: exporting } = useMutation({
</div> </div>
<div v-else style="height: 100%; display: flex; flex-direction: column"> <div v-else style="height: 100%; display: flex; flex-direction: column">
<div style="flex: 0 0 auto; margin-bottom: 16px"> <div style="flex: 0 0 auto; margin-bottom: 16px">
<NRow> <NGrid cols="9">
<NCol :span="3" v-for="item in classifiedAlarmCounts" :key="item.label"> <NGridItem v-for="item in classifiedAlarmCounts" :key="item.label" span="1">
<NStatistic :label="item.label + '告警'" :value="item.count" /> <NStatistic :label="item.label + '告警'" :value="item.count" />
</NCol> </NGridItem>
</NRow> </NGrid>
</div> </div>
<div style="flex: 0 0 auto; display: flex; align-items: center; padding: 8px 0"> <div style="flex: 0 0 auto; display: flex; align-items: center; padding: 8px 0">
<div style="font-size: medium">今日设备告警列表</div> <div style="font-size: medium">今日设备告警列表</div>
@@ -278,10 +278,10 @@ const { mutate: exportTableData, isPending: exporting } = useMutation({
</div> </div>
<div style="flex: 1 1 auto; min-height: 0"> <div style="flex: 1 1 auto; min-height: 0">
<NDataTable <NDataTable
:loading="tableLoading" :loading="loading"
:columns="tableColumns" :columns="tableColumns"
:data="tableData" :data="tableData"
:pagination="tablePagination" :pagination="pagination"
:single-line="false" :single-line="false"
remote remote
flex-height flex-height

View File

@@ -1,23 +1,36 @@
<script setup lang="ts"> <script setup lang="ts">
import { exportIcmpApi } from '@/apis'; import { exportIcmpApi, type Station } from '@/apis';
import { DeviceType } from '@/enums'; import { DeviceType } from '@/enums';
import { useDeviceStore, useStationStore } from '@/stores'; import { useDeviceStore } from '@/stores';
import { downloadByData } from '@/utils'; import { downloadByData } from '@/utils';
import { useMutation } from '@tanstack/vue-query'; import { useMutation } from '@tanstack/vue-query';
import dayjs from 'dayjs'; import dayjs from 'dayjs';
import { NButton, NFlex, NGrid, NGridItem, NModal, NRadio, NRadioGroup, NStatistic } from 'naive-ui'; import { NButton, NFlex, NGrid, NGridItem, NModal, NRadio, NRadioGroup, NStatistic } from 'naive-ui';
import { storeToRefs } from 'pinia'; import { storeToRefs } from 'pinia';
import { computed, ref } from 'vue'; import { computed, ref, toRefs } from 'vue';
const props = defineProps<{
stationList: Station[];
}>();
const show = defineModel<boolean>('show', { default: false }); const show = defineModel<boolean>('show', { default: false });
const stationStore = useStationStore(); const emit = defineEmits<{
const { stationList } = storeToRefs(stationStore); 'after-leave': [];
}>();
const deviceStore = useDeviceStore(); const deviceStore = useDeviceStore();
const { lineDevices } = storeToRefs(deviceStore); const { lineDevices } = storeToRefs(deviceStore);
const { stationList } = toRefs(props);
const status = ref(''); const status = ref('');
const onAfterLeave = () => {
status.value = '';
emit('after-leave');
};
const { mutate: exportIcmp, isPending: loading } = useMutation({ const { mutate: exportIcmp, isPending: loading } = useMutation({
mutationFn: async (params: { status: string }) => { mutationFn: async (params: { status: string }) => {
const data = await exportIcmpApi(params.status); const data = await exportIcmpApi(params.status);
@@ -70,16 +83,8 @@ const deviceCount = computed(() => onlineDeviceCount.value + offlineDeviceCount.
</script> </script>
<template> <template>
<NModal v-model:show="show" preset="card" title="导出设备列表" @after-leave="() => (status = '')" style="width: 1000px"> <NModal v-model:show="show" preset="card" title="导出设备列表" @after-leave="onAfterLeave" style="width: 800px; height: 300px">
<template #default> <template #default>
<NFlex justify="flex-end" align="center">
<NRadioGroup v-model:value="status">
<NRadio value="">全部</NRadio>
<NRadio value="10">在线</NRadio>
<NRadio value="20">离线</NRadio>
</NRadioGroup>
<NButton secondary :loading="loading" @click="() => exportIcmp({ status })">导出</NButton>
</NFlex>
<NGrid :cols="3" :x-gap="24" :y-gap="8"> <NGrid :cols="3" :x-gap="24" :y-gap="8">
<NGridItem> <NGridItem>
<NStatistic label="全部设备" :value="deviceCount" /> <NStatistic label="全部设备" :value="deviceCount" />
@@ -92,6 +97,16 @@ const deviceCount = computed(() => onlineDeviceCount.value + offlineDeviceCount.
</NGridItem> </NGridItem>
</NGrid> </NGrid>
</template> </template>
<template #action>
<NFlex justify="flex-end" align="center">
<NRadioGroup v-model:value="status">
<NRadio value="">全部</NRadio>
<NRadio value="10">在线</NRadio>
<NRadio value="20">离线</NRadio>
</NRadioGroup>
<NButton secondary :loading="loading" @click="() => exportIcmp({ status })">导出</NButton>
</NFlex>
</template>
</NModal> </NModal>
</template> </template>

View File

@@ -2,4 +2,6 @@ export { default as DeviceAlarmDetailModal } from './device-alarm-detail-modal.v
export { default as DeviceExportModal } from './device-export-modal.vue'; export { default as DeviceExportModal } from './device-export-modal.vue';
export { default as DeviceParamsConfigModal } from './device-params-config-modal.vue'; export { default as DeviceParamsConfigModal } from './device-params-config-modal.vue';
export { default as OfflineDeviceDetailModal } from './offline-device-detail-modal.vue'; export { default as OfflineDeviceDetailModal } from './offline-device-detail-modal.vue';
export { default as RecordCheckExportModal } from './record-check-export-modal.vue';
export { default as StationCard } from './station-card.vue'; export { default as StationCard } from './station-card.vue';
export { default as SyncCameraResultModal } from './sync-camera-result-modal.vue';

View File

@@ -0,0 +1,88 @@
<script setup lang="ts">
import { getRecordCheckApi, type NdmNvrResultVO, type Station } from '@/apis';
import { exportRecordDiagCsv, isNvrCluster, transformRecordChecks } from '@/helper';
import { useDeviceStore } from '@/stores';
import { useMutation } from '@tanstack/vue-query';
import { NButton, NGrid, NGridItem, NModal, NScrollbar, NSpin } from 'naive-ui';
import { storeToRefs } from 'pinia';
import { computed, toRefs } from 'vue';
const props = defineProps<{
stations: Station[];
}>();
const emit = defineEmits<{
'after-leave': [];
}>();
const show = defineModel<boolean>('show', { default: false });
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 { mutate: exportRecordDiags, isPending: exporting } = useMutation({
mutationFn: async (params: { clusters: NdmNvrResultVO[]; stationCode: Station['code'] }) => {
const { clusters, stationCode } = params;
if (clusters.length === 0) {
const stationName = nvrClusterRecord.value[stationCode].stationName;
window.$message.info(`${stationName} 没有录像诊断数据`);
return;
}
const checks = await getRecordCheckApi(clusters[0], 90, [], { stationCode: stationCode });
return checks;
},
onSuccess: (checks, { stationCode }) => {
if (!checks || checks.length === 0) return;
const recordDiags = transformRecordChecks(checks);
exportRecordDiagCsv(recordDiags, nvrClusterRecord.value[stationCode].stationName);
},
onError: (error) => {
console.error(error);
window.$message.error(error.message);
},
});
const onAfterLeave = () => {
emit('after-leave');
};
</script>
<template>
<NModal v-model:show="show" preset="card" title="导出录像诊断" @after-leave="onAfterLeave" style="width: 800px">
<template #default>
<NScrollbar style="height: 300px">
<NSpin size="small" :show="exporting">
<NGrid :cols="6">
<template v-for="({ stationName, clusters }, code) in nvrClusterRecord" :key="code">
<NGridItem>
<NButton text type="info" style="height: 30px" @click="() => exportRecordDiags({ clusters, stationCode: code })">{{ stationName }}</NButton>
</NGridItem>
</template>
</NGrid>
</NSpin>
</NScrollbar>
</template>
</NModal>
</template>
<style scoped lang="scss"></style>

View File

@@ -3,15 +3,18 @@ import type { Station, StationAlarmCounts, StationDevices } from '@/apis';
import { DeviceType } from '@/enums'; import { DeviceType } from '@/enums';
import { MoreOutlined, EllipsisOutlined } from '@vicons/antd'; import { MoreOutlined, EllipsisOutlined } from '@vicons/antd';
import axios from 'axios'; import axios from 'axios';
import { NCard, NTag, NButton, NIcon, useThemeVars, NFlex, NText, NTooltip, NDropdown, type DropdownOption } from 'naive-ui'; import { NCard, NTag, NButton, NIcon, useThemeVars, NFlex, NTooltip, NDropdown, type DropdownOption, NCheckbox } from 'naive-ui';
import { toRefs, computed } from 'vue'; import { toRefs, computed } from 'vue';
const props = defineProps<{ const props = defineProps<{
station: Station; station: Station;
stationDevices?: StationDevices; stationDevices?: StationDevices;
stationAlarmCounts?: StationAlarmCounts; stationAlarmCounts?: StationAlarmCounts;
selectable?: boolean;
}>(); }>();
const selected = defineModel<boolean>('selected', { default: false });
const emit = defineEmits<{ const emit = defineEmits<{
'open-offline-device-detail-modal': [station: Station]; 'open-offline-device-detail-modal': [station: Station];
'open-device-alarm-detail-modal': [station: Station]; 'open-device-alarm-detail-modal': [station: Station];
@@ -125,7 +128,8 @@ const theme = useThemeVars();
</template> </template>
</template> </template>
<template #header-extra> <template #header-extra>
<NFlex :size="4"> <NFlex :size="4" align="center">
<NCheckbox v-if="selectable" v-model:checked="selected" :disabled="!station.online" />
<NTag :type="station.online ? 'success' : 'error'" size="small"> <NTag :type="station.online ? 'success' : 'error'" size="small">
{{ station.online ? '在线' : '离线' }} {{ station.online ? '在线' : '离线' }}
</NTag> </NTag>
@@ -149,7 +153,7 @@ const theme = useThemeVars();
<NFlex justify="end" align="center"> <NFlex justify="end" align="center">
<span> <span>
<span :style="{ color: onlineDeviceCount > 0 ? theme.successColor : '' }">在线 {{ onlineDeviceCount }} </span> <span :style="{ color: onlineDeviceCount > 0 ? theme.successColor : '' }">在线 {{ onlineDeviceCount }} </span>
<NText depth="3"> · </NText> <span> · </span>
<span :style="{ color: offlineDeviceCount > 0 ? theme.errorColor : '' }">离线 {{ offlineDeviceCount }} </span> <span :style="{ color: offlineDeviceCount > 0 ? theme.errorColor : '' }">离线 {{ offlineDeviceCount }} </span>
</span> </span>
<NButton quaternary size="tiny" :focusable="false" style="visibility: hidden"> <NButton quaternary size="tiny" :focusable="false" style="visibility: hidden">

View File

@@ -0,0 +1,88 @@
<script setup lang="ts">
import { watchDebounced } from '@vueuse/core';
import { NFlex, NIcon, NList, NListItem, NModal, NScrollbar, NStatistic, NText, NThing } from 'naive-ui';
import { computed, ref, toRefs } from 'vue';
import { useStationStore } from '@/stores';
import { storeToRefs } from 'pinia';
import type { Station, SyncCameraResult } from '@/apis';
import { DeleteFilled, EditFilled, PlusCircleFilled } from '@vicons/antd';
const props = defineProps<{
syncCameraResult: Record<Station['code'], SyncCameraResult>;
}>();
const emit = defineEmits<{
'after-leave': [];
}>();
const stationStore = useStationStore();
const { stationList } = storeToRefs(stationStore);
const { syncCameraResult } = toRefs(props);
const show = ref(false);
watchDebounced(
[syncCameraResult],
([result]) => {
show.value = Object.keys(result).length > 0;
},
{
debounce: 500,
deep: true,
},
);
const onAfterLeave = () => {
emit('after-leave');
};
const syncList = computed(() => {
return Object.values(syncCameraResult.value).map((sync) => {
const { stationCode, startTime, endTime, insertList, updateList, deleteList } = sync;
const stationName = stationList.value.find((station) => station.code === stationCode)?.name;
return { stationName, startTime, endTime, insertList, updateList, deleteList };
});
});
</script>
<template>
<NModal v-model:show="show" preset="card" title="摄像机同步结果" style="width: 600px" @after-leave="onAfterLeave">
<NScrollbar style="max-height: 400px">
<NList hoverable clickable>
<NListItem v-for="{ stationName, endTime, insertList, updateList, deleteList } in syncList" :key="stationName">
<NThing title-independent>
<template #header>
<NText strong>{{ stationName }}</NText>
</template>
<template #header-extra>
<NText depth="3"> {{ endTime }} 完成 </NText>
</template>
<NFlex justify="space-around" :size="24" style="margin-top: 8px">
<NStatistic label="新增">
<template #prefix>
<NIcon :component="PlusCircleFilled" />
</template>
{{ insertList.length }}
</NStatistic>
<NStatistic label="更新">
<template #prefix>
<NIcon :component="EditFilled" />
</template>
{{ updateList.length }}
</NStatistic>
<NStatistic label="删除">
<template #prefix>
<NIcon :component="DeleteFilled" />
</template>
{{ deleteList.length }}
</NStatistic>
</NFlex>
</NThing>
</NListItem>
</NList>
</NScrollbar>
</NModal>
</template>
<style scoped lang="scss"></style>

View File

@@ -8,7 +8,7 @@ export function useDeviceSelection() {
const router = useRouter(); const router = useRouter();
const selectedStationCode = ref<string>(); const selectedStationCode = ref<string>();
const selectedDeviceType = ref<DeviceTypeVal>(DeviceType.AlarmHost); const selectedDeviceType = ref<DeviceTypeVal>(DeviceType.Camera);
const selectedDevice = ref<NdmDeviceResultVO>(); const selectedDevice = ref<NdmDeviceResultVO>();
const initFromRoute = (lineDevices: LineDevices) => { const initFromRoute = (lineDevices: LineDevices) => {

View File

@@ -40,7 +40,7 @@ export function useLineAlarmsQuery() {
queryFn: async ({ signal }) => { queryFn: async ({ signal }) => {
console.time('useLineALarmCountsQuery'); console.time('useLineALarmCountsQuery');
for (const station of stationList.value) { for (const station of stationList.value) {
await getStationAlarmCounts({ station, signal }); await getStationAlarmCounts({ station, signal }).catch(() => {});
} }
console.timeEnd('useLineALarmCountsQuery'); console.timeEnd('useLineALarmCountsQuery');
// pollingStore.updateAlarmQueryUpdatedAt(); // pollingStore.updateAlarmQueryUpdatedAt();
@@ -78,7 +78,7 @@ function useStationAlarmCountsMutation() {
}, },
size: 50000, size: 50000,
current: 1, current: 1,
sort: 'id', sort: 'alarmDate',
order: 'descending', order: 'descending',
}, },
{ {

View File

@@ -47,7 +47,7 @@ export function useLineDevicesQuery() {
queryFn: async ({ signal }) => { queryFn: async ({ signal }) => {
console.time('useLineDevicesQuery'); console.time('useLineDevicesQuery');
for (const station of stationList.value) { for (const station of stationList.value) {
await getStationDevices({ station, signal }); await getStationDevices({ station, signal }).catch(() => {});
} }
console.timeEnd('useLineDevicesQuery'); console.timeEnd('useLineDevicesQuery');
// pollingStore.updateDeviceQueryUpdatedAt(); // pollingStore.updateDeviceQueryUpdatedAt();

View File

@@ -17,10 +17,10 @@ export function useLineStationsQuery() {
queryKey: computed(() => [LINE_STATIONS_QUERY_KEY]), queryKey: computed(() => [LINE_STATIONS_QUERY_KEY]),
enabled: computed(() => pollingEnabled.value), enabled: computed(() => pollingEnabled.value),
refetchInterval: getAppEnvConfig().requestInterval * 1000, refetchInterval: getAppEnvConfig().requestInterval * 1000,
staleTime: getAppEnvConfig().requestInterval * 1000, staleTime: getAppEnvConfig().requestInterval * 500,
queryFn: async ({ signal }) => { queryFn: async ({ signal }) => {
console.time('useStationListQuery'); console.time('useStationListQuery');
await getStationList({ signal }); await getStationList({ signal }).catch(() => {});
console.timeEnd('useStationListQuery'); console.timeEnd('useStationListQuery');
pollingStore.updateDeviceQueryStamp(); pollingStore.updateDeviceQueryStamp();
pollingStore.updateAlarmQueryStamp(); pollingStore.updateAlarmQueryStamp();
@@ -45,6 +45,7 @@ function useLineStationsMutation() {
code: station.code ?? '', code: station.code ?? '',
name: station.name ?? '', name: station.name ?? '',
online: false, online: false,
ip: '',
})); }));
if (stationVerifyMode.value === 'concurrent') { if (stationVerifyMode.value === 'concurrent') {
// 方案一并发ping所有station // 方案一并发ping所有station
@@ -60,7 +61,7 @@ function useLineStationsMutation() {
return { return {
...station, ...station,
online: !!verifyList.find((stn) => stn.stationCode === station.code)?.onlineState, online: !!verifyList.find((stn) => stn.stationCode === station.code)?.onlineState,
ip: verifyList.find((stn) => stn.stationCode === station.code)?.ipAddress, ip: verifyList.find((stn) => stn.stationCode === station.code)?.ipAddress ?? '',
}; };
}); });
} }

View File

@@ -1,5 +1,5 @@
import type { NdmDeviceAlarmLogResultVO } from '@/apis'; import type { NdmDeviceAlarmLogResultVO, Station, SyncCameraResult } from '@/apis';
import { TOPIC_DEVICE_ALARM } from '@/constants'; import { TOPIC_DEVICE_ALARM, SYNC_CAMERA_STATUS_TOPIC } from '@/constants';
import { useAlarmStore } from '@/stores'; import { useAlarmStore } from '@/stores';
import { Client } from '@stomp/stompjs'; import { Client } from '@stomp/stompjs';
import { destr } from 'destr'; import { destr } from 'destr';
@@ -19,6 +19,8 @@ export const useStompClient = () => {
const { unreadAlarmCount } = storeToRefs(alarmStore); const { unreadAlarmCount } = storeToRefs(alarmStore);
const stompClient = ref<Client | null>(null); const stompClient = ref<Client | null>(null);
const syncCameraResult = ref<Record<Station['code'], SyncCameraResult>>({});
onMounted(() => { onMounted(() => {
stompClient.value = new Client({ stompClient.value = new Client({
brokerURL: getBrokerUrl(), brokerURL: getBrokerUrl(),
@@ -33,10 +35,15 @@ export const useStompClient = () => {
unreadAlarmCount.value++; unreadAlarmCount.value++;
} }
}); });
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 };
});
}, },
onDisconnect: () => { onDisconnect: () => {
console.log('Stomp连接断开'); console.log('Stomp连接断开');
stompClient.value?.unsubscribe(TOPIC_DEVICE_ALARM); stompClient.value?.unsubscribe(TOPIC_DEVICE_ALARM);
stompClient.value?.unsubscribe(SYNC_CAMERA_STATUS_TOPIC);
}, },
onStompError: (frame) => { onStompError: (frame) => {
console.log('Stomp错误', frame); console.log('Stomp错误', frame);
@@ -57,5 +64,10 @@ export const useStompClient = () => {
return { return {
stompClient, stompClient,
syncCameraResult,
afterCheckSyncCamera: () => {
syncCameraResult.value = {};
},
}; };
}; };

View File

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

View File

@@ -1,5 +1,4 @@
export const DeviceType = { export const DeviceType = {
AlarmHost: 'ndmAlarmHost',
Camera: 'ndmCamera', Camera: 'ndmCamera',
Nvr: 'ndmNvr', Nvr: 'ndmNvr',
Switch: 'ndmSwitch', Switch: 'ndmSwitch',
@@ -8,13 +7,13 @@ export const DeviceType = {
MediaServer: 'ndmMediaServer', MediaServer: 'ndmMediaServer',
VideoServer: 'ndmVideoServer', VideoServer: 'ndmVideoServer',
Keyboard: 'ndmKeyboard', Keyboard: 'ndmKeyboard',
AlarmHost: 'ndmAlarmHost',
} as const; } as const;
export type DeviceTypeKey = keyof typeof DeviceType; export type DeviceTypeKey = keyof typeof DeviceType;
export type DeviceTypeVal = (typeof DeviceType)[DeviceTypeKey]; export type DeviceTypeVal = (typeof DeviceType)[DeviceTypeKey];
export const DeviceTypeCode: Record<DeviceTypeVal, string[]> = { export const DeviceTypeCode: Record<DeviceTypeVal, string[]> = {
[DeviceType.AlarmHost]: ['117'],
[DeviceType.Camera]: ['131', '132'], [DeviceType.Camera]: ['131', '132'],
[DeviceType.Nvr]: ['111', '118'], [DeviceType.Nvr]: ['111', '118'],
[DeviceType.Switch]: ['220'], [DeviceType.Switch]: ['220'],
@@ -23,10 +22,10 @@ export const DeviceTypeCode: Record<DeviceTypeVal, string[]> = {
[DeviceType.MediaServer]: ['403'], [DeviceType.MediaServer]: ['403'],
[DeviceType.VideoServer]: ['401'], [DeviceType.VideoServer]: ['401'],
[DeviceType.Keyboard]: ['141'], [DeviceType.Keyboard]: ['141'],
[DeviceType.AlarmHost]: ['117'],
}; };
export const DeviceTypeName: Record<DeviceTypeVal, string> = { export const DeviceTypeName: Record<DeviceTypeVal, string> = {
[DeviceType.AlarmHost]: '报警主机',
[DeviceType.Camera]: '摄像机', [DeviceType.Camera]: '摄像机',
[DeviceType.Nvr]: '网络录像机', [DeviceType.Nvr]: '网络录像机',
[DeviceType.Switch]: '交换机', [DeviceType.Switch]: '交换机',
@@ -35,6 +34,7 @@ export const DeviceTypeName: Record<DeviceTypeVal, string> = {
[DeviceType.MediaServer]: '媒体服务器', [DeviceType.MediaServer]: '媒体服务器',
[DeviceType.VideoServer]: '视频服务器', [DeviceType.VideoServer]: '视频服务器',
[DeviceType.Keyboard]: '网络键盘', [DeviceType.Keyboard]: '网络键盘',
[DeviceType.AlarmHost]: '报警主机',
}; };
/** /**

View File

@@ -0,0 +1,26 @@
import type { Station } from '@/apis';
import type { NvrRecordDiag } from './record-check';
import { downloadByData, formatDuration } from '@/utils';
import dayjs from 'dayjs';
export const exportRecordDiagCsv = (recordDiags: NvrRecordDiag[], stationName: Station['name']) => {
const header = '通道名称,开始时间,结束时间,持续时长\n';
const rows = recordDiags
.map((channel) => {
if (channel.lostChunks.length === 0) {
return `${channel.channelName},,,`;
}
return channel.lostChunks
.map((loss) => {
const duration = formatDuration(loss.startTime, loss.endTime);
const startTime = dayjs(loss.startTime).format('YYYY-MM-DD HH:mm:ss');
const endTime = dayjs(loss.endTime).format('YYYY-MM-DD HH:mm:ss');
return `${channel.channelName},${startTime},${endTime},${duration}`;
})
.join('\n');
})
.join('\n');
const csvContent = header + rows;
const time = dayjs().format('YYYY-MM-DD_HH-mm-ss');
downloadByData(csvContent, `${stationName}_录像缺失记录_${time}.csv`, 'text/csv;charset=utf-8', '\ufeff');
};

View File

@@ -1,3 +1,5 @@
export * from './device-alarm'; export * from './device-alarm';
export * from './export-record-diag-csv';
export * from './nvr-cluster'; export * from './nvr-cluster';
export * from './record-check';
export * from './switch-port'; export * from './switch-port';

View File

@@ -0,0 +1,68 @@
import type { NdmRecordCheck, RecordInfo, RecordItem } from '@/apis';
import dayjs from 'dayjs';
import { destr } from 'destr';
import { groupBy } from 'es-toolkit';
export type NvrRecordDiag = {
gbCode: string;
channelName: string;
recordDuration: RecordItem;
lostChunks: RecordItem[];
};
// 解析出丢失的录像时间段
export const transformRecordChecks = (rawRecordChecks: NdmRecordCheck[]): NvrRecordDiag[] => {
// 解析diagInfo
const parsedRecordChecks = rawRecordChecks.map((recordCheck) => ({
...recordCheck,
diagInfo: destr<RecordInfo>(recordCheck.diagInfo),
}));
// 按国标码分组
const recordChecksByGbCode = groupBy(parsedRecordChecks, (recordCheck) => recordCheck.gbCode);
// 提取分组后的国标码和录像诊断记录
const channelGbCodes = Object.keys(recordChecksByGbCode);
const recordChecksList = Object.values(recordChecksByGbCode);
// 初始化每个通道的录像诊断数据结构
const recordDiags = channelGbCodes.map((gbCode, index) => ({
gbCode,
channelName: recordChecksList.at(index)?.at(-1)?.name ?? '',
records: [] as RecordItem[],
lostChunks: [] as RecordItem[],
}));
// 写入同一gbCode的录像片段
recordChecksList.forEach((recordChecks, index) => {
recordChecks.forEach((recordCheck) => {
recordDiags.at(index)?.records.push(...recordCheck.diagInfo.recordList);
});
});
// 过滤掉没有录像记录的通道
const filteredRecordDiags = recordDiags.filter((recordDiag) => recordDiag.records.length > 0);
// 计算每个通道丢失的录像时间片段
filteredRecordDiags.forEach((recordDiag) => {
recordDiag.records.forEach((record, index, records) => {
if (!!records.at(index + 1)) {
// 如果下一段录像的开始时间不等于当前录像的结束时间,则判定为丢失
const nextStartTime = records[index + 1].startTime;
const currEndTime = record.endTime;
if (nextStartTime !== currEndTime) {
recordDiag.lostChunks.push({
startTime: currEndTime,
endTime: nextStartTime,
});
}
}
});
});
return recordDiags.map((recordDiag) => {
const firstRecord = recordDiag.records.at(0);
const startTime = firstRecord ? dayjs(firstRecord.startTime).format('YYYY-MM-DD HH:mm:ss') : '';
const lastRecord = recordDiag.records.at(-1);
const endTime = lastRecord ? dayjs(lastRecord.endTime).format('YYYY-MM-DD HH:mm:ss') : '';
return {
gbCode: recordDiag.gbCode,
channelName: recordDiag.channelName,
recordDuration: { startTime, endTime },
lostChunks: recordDiag.lostChunks,
};
});
};

View File

@@ -5,20 +5,31 @@ function renderIcon(icon: Component): () => VNode {
</script> </script>
<script setup lang="ts"> <script setup lang="ts">
import { SettingsDrawer } from '@/components'; import { SettingsDrawer, SyncCameraResultModal } from '@/components';
import { useStompClient } from '@/composables'; import { useStompClient } from '@/composables';
import { useLineStationsQuery } from '@/composables'; import { useLineStationsQuery } from '@/composables';
import { LINE_STATIONS_QUERY_KEY, LINE_DEVICES_QUERY_KEY, LINE_ALARMS_QUERY_KEY } from '@/constants'; import { LINE_STATIONS_QUERY_KEY, LINE_DEVICES_QUERY_KEY, LINE_ALARMS_QUERY_KEY } from '@/constants';
import { useAlarmStore, useUserStore } from '@/stores'; import { useAlarmStore, useSettingStore, useUserStore } from '@/stores';
import { useIsFetching } from '@tanstack/vue-query'; import { useIsFetching } from '@tanstack/vue-query';
import { AlertFilled, BugFilled, CaretDownFilled, EnvironmentFilled, /* AreaChartOutlined, */ FileTextFilled, HddFilled, LogoutOutlined, SettingOutlined } from '@vicons/antd'; import {
AlertFilled,
BugFilled,
CaretDownFilled,
DoubleLeftOutlined,
DoubleRightOutlined,
EnvironmentFilled,
/* AreaChartOutlined, */ FileTextFilled,
HddFilled,
LogoutOutlined,
SettingOutlined,
} from '@vicons/antd';
import type { AxiosError } from 'axios'; import type { AxiosError } from 'axios';
import { NBadge, NButton, NDropdown, NFlex, NIcon, NLayout, NLayoutContent, NLayoutFooter, NLayoutHeader, NLayoutSider, NMenu, NScrollbar, type DropdownOption, type MenuOption } from 'naive-ui'; import { NBadge, NButton, NDropdown, NFlex, NIcon, NLayout, NLayoutContent, NLayoutFooter, NLayoutHeader, NLayoutSider, NMenu, NScrollbar, type DropdownOption, type MenuOption } from 'naive-ui';
import { storeToRefs } from 'pinia'; import { storeToRefs } from 'pinia';
import { computed, h, onBeforeMount, ref, watch, type Component, type VNode } from 'vue'; import { computed, h, onBeforeMount, ref, watch, type Component, type VNode } from 'vue';
import { RouterLink, useRoute, useRouter } from 'vue-router'; import { RouterLink, useRoute, useRouter } from 'vue-router';
useStompClient(); const { syncCameraResult, afterCheckSyncCamera } = useStompClient();
const userStore = useUserStore(); const userStore = useUserStore();
const { userInfo } = storeToRefs(userStore); const { userInfo } = storeToRefs(userStore);
@@ -26,6 +37,13 @@ const { userInfo } = storeToRefs(userStore);
const alarmStore = useAlarmStore(); const alarmStore = useAlarmStore();
const { unreadAlarmCount } = storeToRefs(alarmStore); const { unreadAlarmCount } = storeToRefs(alarmStore);
const settingStore = useSettingStore();
const { menuCollpased } = storeToRefs(settingStore);
const onToggleMenuCollapsed = () => {
menuCollpased.value = !menuCollpased.value;
};
const { error: stationListQueryError } = useLineStationsQuery(); const { error: stationListQueryError } = useLineStationsQuery();
watch(stationListQueryError, (newStationListQueryError) => { watch(stationListQueryError, (newStationListQueryError) => {
@@ -134,8 +152,15 @@ const openSettingsDrawer = () => {
<template> <template>
<NScrollbar x-scrollable style="width: 100vw; height: 100vh"> <NScrollbar x-scrollable style="width: 100vw; height: 100vh">
<NLayout has-sider :content-style="{ 'min-width': '1400px' }"> <NLayout has-sider :content-style="{ 'min-width': '1400px' }">
<NLayoutSider bordered collapsed collapse-mode="width" :collapsed-width="64"> <NLayoutSider bordered :collapsed="menuCollpased" collapse-mode="width" :collapsed-width="64" @update:collapsed="onToggleMenuCollapsed">
<NMenu collapsed :collapsed-width="64" :collapsed-icon-size="20" :value="route.path" :options="menuOptions" /> <NFlex vertical justify="space-between" :size="0" style="height: 100%">
<NMenu :collapsed="menuCollpased" :collapsed-width="64" :collapsed-icon-size="20" :value="route.path" :options="menuOptions" />
<NButton block quaternary :focusable="false" @click="onToggleMenuCollapsed">
<template #icon>
<NIcon :component="menuCollpased ? DoubleRightOutlined : DoubleLeftOutlined" />
</template>
</NButton>
</NFlex>
</NLayoutSider> </NLayoutSider>
<NLayout :native-scrollbar="false"> <NLayout :native-scrollbar="false">
<NLayoutHeader bordered class="app-layout-header"> <NLayoutHeader bordered class="app-layout-header">
@@ -145,7 +170,6 @@ const openSettingsDrawer = () => {
<NButton text size="tiny" :loading="fetchingCount > 0" /> <NButton text size="tiny" :loading="fetchingCount > 0" />
</NFlex> </NFlex>
<NFlex align="center" :size="0" style="height: 100%"> <NFlex align="center" :size="0" style="height: 100%">
<!-- <ThemeSwitch /> -->
<NDropdown trigger="hover" show-arrow :options="dropdownOptions" @select="selectDropdownOption"> <NDropdown trigger="hover" show-arrow :options="dropdownOptions" @select="selectDropdownOption">
<NButton :focusable="false" quaternary icon-placement="right" style="height: 100%"> <NButton :focusable="false" quaternary icon-placement="right" style="height: 100%">
<template #default> <template #default>
@@ -181,7 +205,10 @@ const openSettingsDrawer = () => {
</NLayout> </NLayout>
</NLayout> </NLayout>
</NScrollbar> </NScrollbar>
<SettingsDrawer v-model:show="settingsDrawerShow" /> <SettingsDrawer v-model:show="settingsDrawerShow" />
<SyncCameraResultModal :sync-camera-result="syncCameraResult" @after-leave="afterCheckSyncCamera" />
</template> </template>
<style scoped lang="scss"> <style scoped lang="scss">

View File

@@ -9,7 +9,7 @@ import {
removeCameraIgnoreApi, removeCameraIgnoreApi,
type NdmDeviceAlarmLogResultVO, type NdmDeviceAlarmLogResultVO,
} from '@/apis'; } from '@/apis';
import { renderAlarmDateCell, renderAlarmTypeCell, renderDeviceTypeCell, renderFaultLevelCell } from '@/components'; import { renderAlarmDateCell, renderAlarmTypeCell, renderDeviceTypeCell, renderFaultLevelCell } from '@/helper';
import { AlarmType, DeviceType, DeviceTypeCode, DeviceTypeName, FaultLevel, tryGetDeviceTypeVal, type DeviceTypeVal } from '@/enums'; import { AlarmType, DeviceType, DeviceTypeCode, DeviceTypeName, FaultLevel, tryGetDeviceTypeVal, type DeviceTypeVal } from '@/enums';
import { useAlarmStore, useStationStore } from '@/stores'; import { useAlarmStore, useStationStore } from '@/stores';
import { downloadByData } from '@/utils'; import { downloadByData } from '@/utils';
@@ -342,6 +342,7 @@ const onClickQuery = () => {
tablePagination.pageSize = 10; tablePagination.pageSize = 10;
searchFieldsChanged.value = false; searchFieldsChanged.value = false;
} }
realtimeRefresh.value = false;
getTableData(); getTableData();
}; };

View File

@@ -1,11 +1,12 @@
<script setup lang="ts"> <script setup lang="ts">
import type { Station } from '@/apis'; import { syncCameraApi, syncNvrChannelsApi, type Station } from '@/apis';
import { DeviceAlarmDetailModal, DeviceExportModal, DeviceParamsConfigModal, OfflineDeviceDetailModal, StationCard } from '@/components'; import { DeviceAlarmDetailModal, DeviceExportModal, DeviceParamsConfigModal, OfflineDeviceDetailModal, RecordCheckExportModal, StationCard } from '@/components';
import { useLineAlarmsQuery, useLineDevicesQuery } from '@/composables'; import { useLineAlarmsQuery, useLineDevicesQuery } from '@/composables';
import { useAlarmStore, useDeviceStore, useSettingStore, useStationStore } from '@/stores'; import { useAlarmStore, useDeviceStore, usePollingStore, useSettingStore, useStationStore } from '@/stores';
import { NGrid, NGi, NScrollbar, NFlex, NButtonGroup, NButton } from 'naive-ui'; import { useMutation } from '@tanstack/vue-query';
import { NGrid, NGi, NScrollbar, NFlex, NButtonGroup, NButton, NCheckbox } from 'naive-ui';
import { storeToRefs } from 'pinia'; import { storeToRefs } from 'pinia';
import { ref, watch } from 'vue'; import { computed, ref, watch } from 'vue';
const stationStore = useStationStore(); const stationStore = useStationStore();
const { stationList } = storeToRefs(stationStore); const { stationList } = storeToRefs(stationStore);
@@ -13,11 +14,12 @@ const deviceStore = useDeviceStore();
const { lineDevices } = storeToRefs(deviceStore); const { lineDevices } = storeToRefs(deviceStore);
const alarmStore = useAlarmStore(); const alarmStore = useAlarmStore();
const { lineAlarmCounts } = storeToRefs(alarmStore); const { lineAlarmCounts } = storeToRefs(alarmStore);
const settingStore = useSettingStore();
const { stationGridColumns } = storeToRefs(settingStore);
const pollingStore = usePollingStore();
const { error: lineDevicesQueryError } = useLineDevicesQuery(); const { error: lineDevicesQueryError } = useLineDevicesQuery();
const { error: lineAlarmsQueryError } = useLineAlarmsQuery(); const { error: lineAlarmsQueryError } = useLineAlarmsQuery();
const settingStore = useSettingStore();
const { stationGridColumns } = storeToRefs(settingStore);
watch([lineDevicesQueryError, lineAlarmsQueryError], ([newLineDevicesQueryError, newLineAlarmsQueryError]) => { watch([lineDevicesQueryError, lineAlarmsQueryError], ([newLineDevicesQueryError, newLineAlarmsQueryError]) => {
if (newLineDevicesQueryError) { if (newLineDevicesQueryError) {
@@ -28,51 +30,187 @@ watch([lineDevicesQueryError, lineAlarmsQueryError], ([newLineDevicesQueryError,
} }
}); });
// 操作栏
// 当点击操作栏中的一个按钮时,其他按钮会被禁用
type Action = 'export-icmp' | 'export-record' | 'sync-camera' | 'sync-nvr' | null;
const selectedAction = ref<Action>(null);
const showOperation = ref(false);
const stationSelectable = ref(false); const stationSelectable = ref(false);
const selectedStations = ref<Record<Station['code'], boolean>>({}); const stationSelection = ref<Record<Station['code'], boolean>>({});
const showActionConfirm = ref(false); const showIcmpExportModal = ref(false);
const showDeviceExportModal = ref(false); const showRecordCheckExportModal = ref(false);
const openDeviceExportModal = () => {
showDeviceExportModal.value = true; const onToggleSelectAll = (checked: boolean) => {
if (!checked) {
stationSelection.value = {};
} else {
stationSelection.value = Object.fromEntries(stationList.value.map((station) => [station.code, true]));
}
}; };
const onAction = (action: Action) => {
selectedAction.value = action;
if (action === null) return;
showOperation.value = true;
stationSelectable.value = true;
};
const onCancel = () => {
selectedAction.value = null;
showOperation.value = false;
stationSelectable.value = false;
stationSelection.value = {};
};
const onFinish = onCancel;
const { mutate: syncCamera, isPending: cameraSyncing } = useMutation({
mutationFn: async () => {
const stationCodes = Object.entries(stationSelection.value)
.filter(([, selected]) => selected)
.map(([code]) => code);
const results = await Promise.allSettled(stationCodes.map((stationCode) => syncCameraApi({ stationCode })));
return results.map((result, index) => ({ ...result, stationCode: stationCodes[index] }));
},
onSuccess: (results) => {
const successCount = results.filter((result) => result.status === 'fulfilled').length;
const failures = results.filter((result) => result.status === 'rejected');
const failureCount = failures.length;
if (failureCount > 0) {
const failedStations = failures.map((f) => stationList.value.find((s) => s.code === f.stationCode)?.name).join('、');
if (successCount === 0) {
window.$message.error('摄像机同步全部失败');
window.$message.error(`${failedStations}`);
} else {
window.$message.warning(`摄像机同步完成:成功${successCount}个车站,失败${failureCount}个车站`);
window.$message.warning(`${failedStations}`);
}
} else {
window.$message.success('摄像机同步成功');
}
if (successCount > 0) {
pollingStore.disablePolling();
pollingStore.enablePolling();
}
onFinish();
},
onError: (error) => {
console.error(error);
window.$message.error(error.message);
onCancel();
},
});
const { mutate: syncNvrChannels, isPending: nvrChannelsSyncing } = useMutation({
mutationFn: async () => {
const stationCodes = Object.entries(stationSelection.value)
.filter(([, selected]) => selected)
.map(([code]) => code);
const results = await Promise.allSettled(stationCodes.map((stationCode) => syncNvrChannelsApi({ stationCode })));
return results.map((result, index) => ({ ...result, stationCode: stationCodes[index] }));
},
onSuccess: (results) => {
const successCount = results.filter((result) => result.status === 'fulfilled').length;
const failures = results.filter((result) => result.status === 'rejected');
const failureCount = failures.length;
if (failureCount > 0) {
const failedStations = failures.map((f) => stationList.value.find((s) => s.code === f.stationCode)?.name).join('、');
if (successCount === 0) {
window.$message.error('录像机通道同步全部失败');
window.$message.error(`${failedStations}`);
} else {
window.$message.warning(`录像机通道同步完成:成功${successCount}个车站,失败${failureCount}个车站`);
window.$message.warning(`${failedStations}`);
}
} else {
window.$message.success('录像机通道同步成功');
}
onFinish();
},
onError: (error) => {
console.error(error);
window.$message.error(error.message);
onCancel();
},
});
const confirming = computed(() => cameraSyncing.value || nvrChannelsSyncing.value);
const onConfirm = async () => {
const noStationSelected = !Object.values(stationSelection.value).some((selected) => selected);
if (selectedAction.value === 'export-icmp') {
if (noStationSelected) {
window.$message.warning('请选择要导出设备状态的车站');
return;
}
showIcmpExportModal.value = true;
} else if (selectedAction.value === 'export-record') {
if (noStationSelected) {
window.$message.warning('请选择要导出录像诊断的车站');
return;
}
showRecordCheckExportModal.value = true;
} else if (selectedAction.value === 'sync-camera') {
if (noStationSelected) {
window.$message.warning('请选择要同步摄像机的车站');
return;
}
syncCamera();
} else if (selectedAction.value === 'sync-nvr') {
if (noStationSelected) {
window.$message.warning('请选择要同步录像机通道的车站');
return;
}
syncNvrChannels();
} else {
return;
}
};
// 车站卡片的事件
const selectedStation = ref<Station>(); const selectedStation = ref<Station>();
const offlineDeviceTreeModalShow = ref(false); const showOfflineDeviceDetailModal = ref(false);
const deviceAlarmTreeModalShow = ref(false); const showDeviceAlarmDetailModal = ref(false);
const deviceParamsConfigModalShow = ref(false); const showDeviceParamsConfigModal = ref(false);
const openOfflineDeviceDetailModal = (station: Station) => { const openOfflineDeviceDetailModal = (station: Station) => {
selectedStation.value = station; selectedStation.value = station;
offlineDeviceTreeModalShow.value = true; showOfflineDeviceDetailModal.value = true;
}; };
const openDeviceAlarmDetailModal = (station: Station) => { const openDeviceAlarmDetailModal = (station: Station) => {
selectedStation.value = station; selectedStation.value = station;
deviceAlarmTreeModalShow.value = true; showDeviceAlarmDetailModal.value = true;
}; };
const openDeviceParamsConfigModal = (station: Station) => { const openDeviceParamsConfigModal = (station: Station) => {
selectedStation.value = station; selectedStation.value = station;
deviceParamsConfigModalShow.value = true; showDeviceParamsConfigModal.value = true;
}; };
</script> </script>
<template> <template>
<NScrollbar content-style="padding-right: 8px" style="width: 100%; height: 100%"> <NScrollbar content-style="padding-right: 8px" style="width: 100%; height: 100%">
<NFlex justify="space-between" align="center" style="padding: 8px 8px 0 8px"> <!-- 工具栏 -->
<NFlex align="center" style="padding: 8px 8px 0 8px">
<NButtonGroup> <NButtonGroup>
<NButton secondary :focusable="false" @click="openDeviceExportModal">导出设备状态</NButton> <NButton secondary :focusable="false" :disabled="!!selectedAction && selectedAction !== 'export-icmp'" @click="() => onAction('export-icmp')">导出设备状态</NButton>
<NButton v-if="false">导出录像诊断</NButton> <NButton secondary :focusable="false" :disabled="!!selectedAction && selectedAction !== 'export-record'" @click="() => onAction('export-record')">导出录像诊断</NButton>
<NButton v-if="false">同步摄像机</NButton> <NButton secondary :focusable="false" :disabled="!!selectedAction && selectedAction !== 'sync-camera'" @click="() => onAction('sync-camera')">同步摄像机</NButton>
<NButton secondary :focusable="false" :disabled="!!selectedAction && selectedAction !== 'sync-nvr'" @click="() => onAction('sync-nvr')">同步录像机通道</NButton>
</NButtonGroup> </NButtonGroup>
<NFlex v-if="showActionConfirm" size="small"> <template v-if="showOperation">
<NButton quaternary size="small" type="primary" :focusable="false">确定</NButton> <NCheckbox label="全选" @update:checked="onToggleSelectAll" />
<NButton quaternary size="small" type="tertiary" :focusable="false">取消</NButton> <NButton tertiary size="small" type="primary" :focusable="false" :loading="confirming" @click="onConfirm">确定</NButton>
</NFlex> <NButton tertiary size="small" type="tertiary" :focusable="false" @click="onCancel">取消</NButton>
</template>
</NFlex> </NFlex>
<!-- 车站 -->
<NGrid :cols="stationGridColumns" :x-gap="6" :y-gap="6" style="padding: 8px"> <NGrid :cols="stationGridColumns" :x-gap="6" :y-gap="6" style="padding: 8px">
<NGi v-for="station in stationList" :key="station.code"> <NGi v-for="station in stationList" :key="station.code">
<StationCard <StationCard
:station="station" :station="station"
:station-devices="lineDevices[station.code]" :station-devices="lineDevices[station.code]"
:station-alarm-counts="lineAlarmCounts[station.code]" :station-alarm-counts="lineAlarmCounts[station.code]"
:selectable="stationSelectable"
v-model:selected="stationSelection[station.code]"
@open-offline-device-detail-modal="openOfflineDeviceDetailModal" @open-offline-device-detail-modal="openOfflineDeviceDetailModal"
@open-device-alarm-detail-modal="openDeviceAlarmDetailModal" @open-device-alarm-detail-modal="openDeviceAlarmDetailModal"
@open-device-params-config-modal="openDeviceParamsConfigModal" @open-device-params-config-modal="openDeviceParamsConfigModal"
@@ -82,13 +220,15 @@ const openDeviceParamsConfigModal = (station: Station) => {
</NScrollbar> </NScrollbar>
<!-- 离线设备详情对话框 --> <!-- 离线设备详情对话框 -->
<OfflineDeviceDetailModal v-model:show="offlineDeviceTreeModalShow" :station="selectedStation" :station-devices="selectedStation?.code ? lineDevices[selectedStation.code] : undefined" /> <OfflineDeviceDetailModal v-model:show="showOfflineDeviceDetailModal" :station="selectedStation" :station-devices="selectedStation?.code ? lineDevices[selectedStation.code] : undefined" />
<!-- 设备告警详情对话框 --> <!-- 设备告警详情对话框 -->
<DeviceAlarmDetailModal v-model:show="deviceAlarmTreeModalShow" :station="selectedStation" :station-alarm-counts="selectedStation?.code ? lineAlarmCounts[selectedStation.code] : undefined" /> <DeviceAlarmDetailModal v-model:show="showDeviceAlarmDetailModal" :station="selectedStation" :station-alarm-counts="selectedStation?.code ? lineAlarmCounts[selectedStation.code] : undefined" />
<!-- 设备配置面板对话框 --> <!-- 设备配置面板对话框 -->
<DeviceParamsConfigModal v-model:show="deviceParamsConfigModalShow" :station="selectedStation" /> <DeviceParamsConfigModal v-model:show="showDeviceParamsConfigModal" :station="selectedStation" />
<!-- 设备状态导出对话框 --> <!-- 设备状态导出对话框 -->
<DeviceExportModal v-model:show="showDeviceExportModal" /> <DeviceExportModal v-model:show="showIcmpExportModal" :station-list="stationList.filter((station) => stationSelection[station.code])" @after-leave="onFinish" />
<!-- 录像诊断导出对话框 -->
<RecordCheckExportModal v-model:show="showRecordCheckExportModal" :stations="stationList.filter((station) => stationSelection[station.code])" @after-leave="onFinish" />
</template> </template>
<style scoped lang="scss"></style> <style scoped lang="scss"></style>

View File

@@ -1,3 +1,5 @@
import { LINE_ALARMS_QUERY_KEY, LINE_DEVICES_QUERY_KEY, LINE_STATIONS_QUERY_KEY } from '@/constants';
import { useQueryClient } from '@tanstack/vue-query';
import dayjs from 'dayjs'; import dayjs from 'dayjs';
import { defineStore } from 'pinia'; import { defineStore } from 'pinia';
import { ref } from 'vue'; import { ref } from 'vue';
@@ -5,9 +7,19 @@ import { ref } from 'vue';
export const usePollingStore = defineStore( export const usePollingStore = defineStore(
'ndm-polling-store', 'ndm-polling-store',
() => { () => {
const queryClient = useQueryClient();
const pollingEnabled = ref(true); const pollingEnabled = ref(true);
const enablePolling = () => (pollingEnabled.value = true); const enablePolling = () => (pollingEnabled.value = true);
const disablePolling = () => (pollingEnabled.value = false); const disablePolling = () => {
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] });
pollingEnabled.value = false;
};
const deviceQueryStamp = ref(0); const deviceQueryStamp = ref(0);
const alarmQueryStamp = ref(0); const alarmQueryStamp = ref(0);

View File

@@ -10,6 +10,8 @@ export const useSettingStore = defineStore(
return darkThemeEnabled.value ? darkTheme : lightTheme; return darkThemeEnabled.value ? darkTheme : lightTheme;
}); });
const menuCollpased = ref(false);
const stationGridColumns = ref(6); const stationGridColumns = ref(6);
const debugModeEnabled = ref(false); const debugModeEnabled = ref(false);
@@ -24,6 +26,8 @@ export const useSettingStore = defineStore(
darkThemeEnabled, darkThemeEnabled,
themeMode, themeMode,
menuCollpased,
stationGridColumns, stationGridColumns,
debugModeEnabled, debugModeEnabled,

View File

@@ -11,6 +11,36 @@ type ProxyItem = {
rewrite?: [string, string]; rewrite?: [string, string];
}; };
const line04ApiProxyList: ProxyItem[] = [
{ key: '/minio', target: 'http://10.15.128.10:9000', rewrite: ['/minio', ''] },
{ key: '/api', target: 'http://10.15.128.10:18760' },
{ key: '/0475/api', target: 'http://10.15.128.10:18760', rewrite: ['/0475/api', '/api'] },
{ key: '/0401/api', target: 'http://10.15.129.10:18760', rewrite: ['/0401/api', '/api'] },
{ key: '/0402/api', target: 'http://10.15.131.10:18760', rewrite: ['/0402/api', '/api'] },
{ key: '/0403/api', target: 'http://10.15.133.10:18760', rewrite: ['/0403/api', '/api'] },
{ key: '/0404/api', target: 'http://10.15.135.10:18760', rewrite: ['/0404/api', '/api'] },
{ key: '/0405/api', target: 'http://10.15.137.10:18760', rewrite: ['/0405/api', '/api'] },
{ key: '/0406/api', target: 'http://10.15.139.10:18760', rewrite: ['/0406/api', '/api'] },
{ key: '/0407/api', target: 'http://10.15.141.10:18760', rewrite: ['/0407/api', '/api'] },
{ key: '/0408/api', target: 'http://10.15.143.10:18760', rewrite: ['/0408/api', '/api'] },
{ key: '/0409/api', target: 'http://10.15.145.10:18760', rewrite: ['/0409/api', '/api'] },
{ key: '/0410/api', target: 'http://10.15.147.10:18760', rewrite: ['/0410/api', '/api'] },
{ key: '/0411/api', target: 'http://10.15.149.10:18760', rewrite: ['/0411/api', '/api'] },
{ key: '/0412/api', target: 'http://10.15.151.10:18760', rewrite: ['/0412/api', '/api'] },
{ key: '/0413/api', target: 'http://10.15.153.10:18760', rewrite: ['/0413/api', '/api'] },
{ key: '/0414/api', target: 'http://10.15.155.10:18760', rewrite: ['/0414/api', '/api'] },
{ key: '/0415/api', target: 'http://10.15.157.10:18760', rewrite: ['/0415/api', '/api'] },
{ key: '/0416/api', target: 'http://10.15.159.10:18760', rewrite: ['/0416/api', '/api'] },
{ key: '/0417/api', target: 'http://10.15.161.10:18760', rewrite: ['/0417/api', '/api'] },
{ key: '/0418/api', target: 'http://10.15.163.10:18760', rewrite: ['/0418/api', '/api'] },
{ key: '/0419/api', target: 'http://10.15.165.10:18760', rewrite: ['/0419/api', '/api'] },
{ key: '/0420/api', target: 'http://10.15.167.10:18760', rewrite: ['/0420/api', '/api'] },
];
const line10ApiProxyList: ProxyItem[] = [ const line10ApiProxyList: ProxyItem[] = [
{ key: '/minio', target: 'http://10.18.128.10:9000', rewrite: ['/minio', ''] }, { key: '/minio', target: 'http://10.18.128.10:9000', rewrite: ['/minio', ''] },
@@ -54,12 +84,14 @@ const line10ApiProxyList: ProxyItem[] = [
{ key: '/1031/api', target: 'http://10.18.189.10:18760', rewrite: ['/1031/api', '/api'] }, { key: '/1031/api', target: 'http://10.18.189.10:18760', rewrite: ['/1031/api', '/api'] },
{ key: '/1032/api', target: 'http://10.18.244.10:18760', rewrite: ['/1032/api', '/api'] }, { key: '/1032/api', target: 'http://10.18.244.10:18760', rewrite: ['/1032/api', '/api'] },
]; ];
const apiProxyList: ProxyItem[] = [ const apiProxyList: ProxyItem[] = [
// // ...line04ApiProxyList,
...line10ApiProxyList, ...line10ApiProxyList,
]; ];
const wsProxyList: ProxyItem[] = [ const wsProxyList: ProxyItem[] = [
// //
// { key: '/ws', target: 'ws://10.15.128.10:18103' },
{ key: '/ws', target: 'ws://10.18.128.10:18103' }, { key: '/ws', target: 'ws://10.18.128.10:18103' },
]; ];