From 4a8c7756c66e2c5128dc9974ff7d3335deb903e4 Mon Sep 17 00:00:00 2001 From: luodangjia <luodangjia> Date: 星期五, 03 一月 2025 14:18:48 +0800 Subject: [PATCH] merge --- medicalWaste-system/src/main/java/com/sinata/system/service/impl/MwMonitorDeviceServiceImpl.java | 17 +++++++++++++++++ 1 files changed, 17 insertions(+), 0 deletions(-) diff --git a/medicalWaste-system/src/main/java/com/sinata/system/service/impl/MwMonitorDeviceServiceImpl.java b/medicalWaste-system/src/main/java/com/sinata/system/service/impl/MwMonitorDeviceServiceImpl.java index ee26ef9..bb75cd1 100644 --- a/medicalWaste-system/src/main/java/com/sinata/system/service/impl/MwMonitorDeviceServiceImpl.java +++ b/medicalWaste-system/src/main/java/com/sinata/system/service/impl/MwMonitorDeviceServiceImpl.java @@ -116,4 +116,21 @@ }); return PageDTO.of(page); } + + @Override + public PageDTO<MwMonitorDeviceVO> pageMonitorPage1(MwMonitorDeviceQuery query) { + query.setPageCurr(1); + query.setPageSize(999999999); + //获取视频服务器中的在线设备列表 + List<String> deviceList = monitorDeviceApiNewService.getDeviceList(); + String treeCode = sysDepartmentService.getTreeCodeByDepartmentId(query.getDepartmentId()); + if (StringUtils.isBlank(treeCode)) { + return PageDTO.empty(0L, 0L); + } + Page<MwMonitorDeviceVO> page = baseMapper.pageMonitorPage(new Page<>(query.getPageCurr(), query.getPageSize()), query.getStatus(), treeCode, deviceList); + page.getRecords().stream().filter(item -> deviceList.contains(item.getDeviceNumber())).peek(item -> { + item.setStatus(1); + }); + return PageDTO.of(page); + } } -- Gitblit v1.7.1