From 93fe0b66e85e95e3a7e77a28504d6d289b6906b9 Mon Sep 17 00:00:00 2001 From: kaiyu <404897439@qq.com> Date: Fri, 08 Oct 2021 13:11:22 +0800 Subject: [PATCH] screen-manage screen-api 更改拦截器逻辑,记录token无效的请求IP以及URL。 manage记录到数据库日志中 api记录在日志文件中 --- screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java | 67 +++++++++++++++++++-------------- 1 files changed, 39 insertions(+), 28 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..973e952 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); } //������������������������������ @@ -441,13 +454,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 +539,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 +567,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 +581,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