From 616747c2ebad352796b21ec153e4f9590aa26c45 Mon Sep 17 00:00:00 2001 From: lizijie <lzjiiie@163.com> Date: Tue, 28 Dec 2021 16:01:31 +0800 Subject: [PATCH] 修改获取AVG、MIN、MAX数据接口 --- screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java | 11 +++++++++++ 1 files changed, 11 insertions(+), 0 deletions(-) diff --git a/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java index 1c1b45b..3541861 100644 --- a/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java +++ b/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java @@ -22,6 +22,7 @@ import java.util.List; import java.util.Map; +import java.util.stream.Collectors; /** * <p> @@ -162,6 +163,16 @@ return device; } + @Override + public List<Map<String, Object>> getDevicesByOrganizationId(Integer orgId) { + //������������������mac + QueryWrapper<Device> queryWrapper = new QueryWrapper<>(); + queryWrapper.select("mac").eq("organization_id", orgId).eq("is_delete", Constants.NOT_DELETE); + List<Device> devices = deviceMapper.selectList(queryWrapper); + //���redis������������������������ + return devices.stream().map(device -> (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.DEVICE, device.getMac())).collect(Collectors.toList()); + } + private Device getDeviceByMacFromDB(String mac) { QueryWrapper<Device> wrapper = new QueryWrapper<>(); wrapper.eq("mac", mac); -- Gitblit v1.8.0