From 3d593b39648ff583a255765f76760768d6ba5f55 Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Thu, 23 Dec 2021 14:32:14 +0800 Subject: [PATCH] 正式库city_aqi,city_weather,history_aqi第三方数据存入开发库 --- screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java | 84 +++++++++++++++++++++++------------------- 1 files changed, 46 insertions(+), 38 deletions(-) diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java index 66b431a..03a4812 100644 --- a/screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java +++ b/screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java @@ -12,6 +12,7 @@ import com.moral.api.service.DeviceService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.moral.api.service.OrganizationService; import com.moral.api.service.SysDictDataService; import com.moral.api.util.CacheUtils; import com.moral.api.util.AdjustDataUtils; @@ -39,6 +40,7 @@ import java.util.List; import java.util.Map; import java.util.Objects; +import java.util.stream.Collectors; import javax.servlet.http.HttpServletRequest; @@ -75,8 +77,6 @@ @Autowired private SysDictDataService sysDictDataService; - @Autowired - private LogUtils logUtils; @Autowired private RedisTemplate redisTemplate; @@ -92,6 +92,9 @@ @Autowired private AdjustDataUtils adjustDataUtils; + + @Autowired + private OrganizationService organizationService; /* * ���redis������������������ @@ -135,7 +138,7 @@ HttpServletRequest request = ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest(); StringBuilder content = new StringBuilder(); content.append("������������������").append(device.getName()).append(":").append("mac���").append(mac); - logUtils.saveOperationForManage(request, content.toString(), Constants.INSERT_OPERATE_TYPE); + LogUtils.saveOperationForManage(request, content.toString(), Constants.INSERT_OPERATE_TYPE); } @Override @@ -158,7 +161,7 @@ HttpServletRequest request = ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest(); StringBuilder content = new StringBuilder(); content.append("������������������").append(device.getName()).append(";").append("mac���").append(mac); - logUtils.saveOperationForManage(request, content.toString(), Constants.DELETE_OPERATE_TYPE); + LogUtils.saveOperationForManage(request, content.toString(), Constants.DELETE_OPERATE_TYPE); } @Override @@ -218,7 +221,7 @@ } } - logUtils.saveOperationForManage(request, content.toString(), Constants.UPDATE_OPERATE_TYPE); + LogUtils.saveOperationForManage(request, content.toString(), Constants.UPDATE_OPERATE_TYPE); } @Override @@ -242,8 +245,14 @@ @Override public List<Map<String, Object>> selectMonitorsByOrgId(Integer orgId) { + //��������������������� + List<Organization> organizations = organizationService.getAllChildrenOrganization(orgId); + List<Integer> orgIds = organizations.stream().map(Organization::getId).collect(Collectors.toList()); + orgIds.add(orgId); QueryWrapper<MonitorPoint> queryWrapper = new QueryWrapper<>(); - queryWrapper.select("id", "name").eq("organization_id", orgId).eq("is_delete", Constants.NOT_DELETE); + queryWrapper.select("id", "name") + .eq("is_delete", Constants.NOT_DELETE) + .in("organization_id", orgIds); return monitorPointMapper.selectMaps(queryWrapper); } @@ -269,9 +278,13 @@ Object orgId = parameters.get("organizationId"); Object mpId = parameters.get("monitorPointId"); - //������������������������������ + //������������������������������,��������������� if (orgId != null) { - queryWrapper.eq("organization_id", orgId); + //��������������������� + List<Organization> organizations = organizationService.getAllChildrenOrganization(Integer.parseInt(orgId.toString())); + List<Integer> orgIds = organizations.stream().map(Organization::getId).collect(Collectors.toList()); + orgIds.add(Integer.parseInt(orgId.toString())); + queryWrapper.in("organization_id", orgIds); } //������������������������������ @@ -279,14 +292,9 @@ queryWrapper.eq("monitor_point_id", mpId); } - //��������������������� - if (name != null) { - queryWrapper.like("name", name); - } - - //mac������������ - if (mac != null) { - queryWrapper.like("mac", mac); + //���������������mac������������ + if (name != null && mac != null) { + queryWrapper.like("name", name).or().like("mac", mac); } //������������,������create_time������ @@ -340,9 +348,11 @@ //������������ deviceInfo.put("extend", device.getExtend()); + //������������������ + deviceInfo.put("town", device.getTown()); + //������ - deviceInfo.put("profession", device.getProfession()); - deviceInfo.put("professionName", device.getProfessionName()); + deviceInfo.put("professions", device.getProfessions()); //������ deviceInfo.put("tech", device.getTech()); @@ -441,13 +451,11 @@ Map<String, Object> adjustFormula = redisTemplate.opsForHash().entries(RedisConstants.ADJUST + "_" + mac); if (!ObjectUtils.isEmpty(adjustFormula)) { Map<String, Object> deviceInfo = getDeviceByMac(mac); - Map<String, Object> monitorPoint = (Map<String, Object>) deviceInfo.get("monitorPoint"); - String areaCode = monitorPoint.get("areaCode").toString(); - String cityCode = monitorPoint.get("cityCode").toString(); - - Map<String, Object> aqiMap = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.AQI_DATA, areaCode); - if (ObjectUtils.isEmpty(aqiMap)) { - aqiMap = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.AQI_DATA, cityCode); + //������������������������������������ + Map<String, Object> govMpInfo = (Map<String, Object>) deviceInfo.get("govMonitorPoint"); + Map<String, Object> aqiMap = null; + if (govMpInfo.get("guid") != null) { + aqiMap = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.AQI_DATA, govMpInfo.get("guid").toString()); } return adjustDataUtils.adjust(deviceData, adjustFormula, ObjectUtils.isEmpty(aqiMap) ? null : aqiMap); } @@ -528,12 +536,12 @@ } /** - * @Description: ��������������������������������������������������������������������������������������������� - * @Param: [orgId, versionId] - * @return: void - * @Author: ��������� - * @Date: 2021/9/6 - */ + * @Description: ��������������������������������������������������������������������������������������������� + * @Param: [orgId, versionId] + * @return: void + * @Author: ��������� + * @Date: 2021/9/6 + */ private void insertOrganizationUnitAlarm(Integer orgId, Integer versionId) { //��������������������������� QueryWrapper<OrganizationUnitAlarm> queryOrganizationVersionWrapper = new QueryWrapper<>(); @@ -556,7 +564,7 @@ String sensorCode = versionSensorUnit.getSensorCode(); //��������������������� SysDictData alarm = sensorAlarms.get(sensorCode); - if(alarm!=null) + if (alarm != null) organizationUnitAlarm.setAlarmLevel(alarm.getDataValue()); organizationUnitAlarm.setOrganizationId(orgId); organizationUnitAlarm.setVersionId(versionId); @@ -570,12 +578,12 @@ } /** - * @Description: ������������������������������������������������������������������������������������������������������������������������������������ - * @Param: [orgId, versionId] - * @return: void - * @Author: ��������� - * @Date: 2021/9/6 - */ + * @Description: ������������������������������������������������������������������������������������������������������������������������������������ + * @Param: [orgId, versionId] + * @return: void + * @Author: ��������� + * @Date: 2021/9/6 + */ private void deleteOrganizationUnitAlarm(Integer orgId, Integer versionId) { QueryWrapper<Device> queryOrganizationVersionWrapper = new QueryWrapper<>(); queryOrganizationVersionWrapper.eq("organization_id", orgId); -- Gitblit v1.8.0