From 1a529c3f8a623eb3e10ff6c7dcb99e79bbd451f0 Mon Sep 17 00:00:00 2001 From: lizijie <lzjiiie@163.com> Date: Wed, 01 Sep 2021 09:52:11 +0800 Subject: [PATCH] 修改因子更新特殊设备警报信息 --- screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java | 423 ++++++++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 368 insertions(+), 55 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 57be6cd..9339dc2 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 @@ -1,38 +1,45 @@ package com.moral.api.service.impl; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; -import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.moral.api.entity.Device; -import com.moral.api.entity.ManageAccount; -import com.moral.api.entity.MonitorPoint; -import com.moral.api.entity.Organization; -import com.moral.api.entity.SysDictData; -import com.moral.api.entity.SysDictType; -import com.moral.api.entity.Version; -import com.moral.api.mapper.DeviceMapper; -import com.moral.api.mapper.ManageAccountMapper; -import com.moral.api.mapper.MonitorPointMapper; -import com.moral.api.mapper.OrganizationMapper; -import com.moral.api.mapper.SysDictDataMapper; -import com.moral.api.mapper.SysDictTypeMapper; +import com.googlecode.aviator.AviatorEvaluator; +import com.googlecode.aviator.Expression; +import com.moral.api.entity.*; +import com.moral.api.mapper.*; import com.moral.api.pojo.vo.device.DeviceVO; import com.moral.api.service.DeviceService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; + +import com.moral.api.util.CacheUtils; +import com.moral.api.util.AdjustDataUtils; +import com.moral.api.util.LogUtils; import com.moral.constant.Constants; -import com.moral.redis.RedisUtil; +import com.moral.constant.RedisConstants; import com.moral.util.ConvertUtils; import com.moral.util.DateUtils; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import org.springframework.util.ObjectUtils; +import org.springframework.util.StringUtils; +import org.springframework.web.context.request.RequestContextHolder; +import org.springframework.web.context.request.ServletRequestAttributes; +import java.beans.PropertyDescriptor; +import java.lang.reflect.Field; +import java.lang.reflect.Method; import java.util.ArrayList; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; +import java.util.Objects; + +import javax.servlet.http.HttpServletRequest; /** * <p> @@ -43,6 +50,7 @@ * @since 2021-05-11 */ @Service +@Slf4j public class DeviceServiceImpl extends ServiceImpl<DeviceMapper, Device> implements DeviceService { @Autowired @@ -63,32 +71,150 @@ @Autowired private SysDictDataMapper sysDictDataMapper; + @Autowired + private LogUtils logUtils; + + @Autowired + private RedisTemplate redisTemplate; + + @Autowired + private OrganizationUnitAlarmMapper organizationUnitAlarmMapper; + + @Autowired + private VersionSensorUnitMapper versionSensorUnitMapper; + + @Autowired + private SpecialDeviceMapper specialDeviceMapper; + + @Autowired + private AdjustDataUtils adjustDataUtils; + + /* + * ���redis������������������ + * */ + private Map<String, Object> getDeviceInfoFromRedis(String mac) { + return (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.DEVICE, mac); + } + + /* + * ������������������redis + */ + private void setDeviceInfoToRedis(String mac, Map<String, Object> deviceInfo) { + redisTemplate.opsForHash().put(RedisConstants.DEVICE, mac, deviceInfo); + } + + /* + * ���redis������������������ + */ + private void delDeviceInfoFromRedis(String mac) { + redisTemplate.opsForHash().delete(RedisConstants.DEVICE, mac); + } + @Override @Transactional public void insert(Device device) { + Integer orgId = monitorPointMapper.selectById(device.getMonitorPointId()).getOrganizationId(); + device.setOrganizationId(orgId); deviceMapper.insert(device); Map<String, Object> deviceInfo = selectDeviceInfoById(device.getId()); - RedisUtil.set("device_" + device.getMac(), deviceInfo); + //��������������������������� + insertOrganizationUnitAlarm(orgId, device.getDeviceVersionId()); + //������������������������redis + String mac = device.getMac(); + //���redis��������������������� + delDeviceInfoFromRedis(mac); + //������������������redis + setDeviceInfoToRedis(mac, deviceInfo); + //������deviceInfo������ + CacheUtils.refreshDeviceAlarmInfo(); + //������������������ + 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); } @Override @Transactional public void delete(Integer deviceId) { + Device device = deviceMapper.selectById(deviceId); UpdateWrapper<Device> updateWrapper = new UpdateWrapper<>(); updateWrapper.eq("id", deviceId).set("is_delete", Constants.DELETE); deviceMapper.update(null, updateWrapper); - String mac = deviceMapper.selectById(deviceId).getMac(); - //������redis - RedisUtil.del("device_" + mac); + String mac = device.getMac(); + //���redis��������������������� + delDeviceInfoFromRedis(mac); + //��������������������������� + Integer versionId = device.getDeviceVersionId(); + Integer orgId = device.getOrganizationId(); + deleteOrganizationUnitAlarm(orgId, versionId); + //������deviceInfo������ + CacheUtils.refreshDeviceAlarmInfo(); + //������������������ + 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); } @Override @Transactional public void update(Device device) { + Integer deviceId = device.getId(); + Device oldDevice = deviceMapper.selectById(deviceId); + //���������������������������������������������������������������������������������id������������ + if (!ObjectUtils.isEmpty(device.getMonitorPointId())) { + MonitorPoint monitorPoint = monitorPointMapper.selectById(device.getMonitorPointId()); + device.setOrganizationId(monitorPoint.getOrganizationId()); + } deviceMapper.updateById(device); - //������redis - Map<String, Object> deviceInfo = selectDeviceInfoById(device.getId()); - RedisUtil.set("device_" + deviceInfo.get("mac"), deviceInfo); + Device updateDevice = deviceMapper.selectById(deviceId); + String mac = updateDevice.getMac(); + //��������������������������� + Integer oldOrgId = oldDevice.getOrganizationId(); + Integer newOrgId = updateDevice.getOrganizationId(); + Integer oldVersionId = oldDevice.getDeviceVersionId(); + Integer newVersionId = updateDevice.getDeviceVersionId(); + if (!oldOrgId.equals(newOrgId) || !oldVersionId.equals(newVersionId)) { + deleteOrganizationUnitAlarm(oldOrgId, oldVersionId); + insertOrganizationUnitAlarm(newOrgId, newVersionId); + } + //���redis��������������������� + delDeviceInfoFromRedis(oldDevice.getMac()); + Map<String, Object> deviceInfo = selectDeviceInfoById(deviceId); + //������������������redis + setDeviceInfoToRedis(mac, deviceInfo); + //������deviceInfo������ + CacheUtils.refreshDeviceAlarmInfo(); + //������������������ + HttpServletRequest request = ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest(); + StringBuilder content = new StringBuilder(); + content.append("������������������" + oldDevice.getMac()).append("==>").append(mac).append("���"); + Field[] fields = Device.class.getDeclaredFields(); + for (Field field : fields) { + if (field.getName().equals("id")) { + continue; + } + if ("serialVersionUID".equals(field.getName())) { + continue; + } + String fieldName = field.getName(); + PropertyDescriptor pd = null; + try { + pd = new PropertyDescriptor(fieldName, Device.class); + Method method = pd.getReadMethod(); + Object o1 = method.invoke(oldDevice); + Object o2 = method.invoke(device); + if (o2 != null) { + content.append(fieldName).append("���").append(o1).append("-->").append(o2).append(":"); + } + + } catch (Exception e) { + e.printStackTrace(); + } + + } + logUtils.saveOperationForManage(request, content.toString(), Constants.UPDATE_OPERATE_TYPE); } @Override @@ -118,31 +244,43 @@ } @Override - public List<Map<String, Object>> selectDevicesByOrgId(Integer orgId) { - QueryWrapper<Device> queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("is_delete", Constants.NOT_DELETE).eq("organization_id", orgId); - return deviceMapper.selectMaps(queryWrapper); + public Map<String, Object> selectDevicesByOrgId(Map<String, Object> parameters) { + return selectDevices(parameters); } @Override - public List<Map<String, Object>> selectDevicesByMpId(Integer mpId) { - QueryWrapper<Device> queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("is_delete", Constants.NOT_DELETE).eq("monitor_point_id", mpId); - return deviceMapper.selectMaps(queryWrapper); + public Map<String, Object> selectDevicesByMpId(Map<String, Object> parameters) { + return selectDevices(parameters); } @Override - public IPage<Device> selectDevices(Map<String, Object> parameters) { + public Map<String, Object> selectDevices(Map<String, Object> parameters) { QueryWrapper<Device> queryWrapper = new QueryWrapper<>(); - Integer page = (Integer) parameters.get("page"); - Integer size = (Integer) parameters.get("size"); + int page = Integer.parseInt(parameters.get("page").toString()); + int size = Integer.parseInt(parameters.get("size").toString()); Object order = parameters.get("order"); Object orderType = parameters.get("orderType"); Object name = parameters.get("name"); Object mac = parameters.get("mac"); + Object orgId = parameters.get("organizationId"); + Object mpId = parameters.get("monitorPointId"); + + //������������������������������ + if (orgId != null) { + queryWrapper.eq("organization_id", orgId); + } + + //������������������������������ + if (mpId != null) { + queryWrapper.eq("monitor_point_id", mpId); + } + + //��������������������� if (name != null) { queryWrapper.like("name", name); } + + //mac������������ if (mac != null) { queryWrapper.like("mac", mac); } @@ -160,44 +298,66 @@ queryWrapper.eq("is_delete", Constants.NOT_DELETE); Page<Device> devicePage = new Page<>(page, size); deviceMapper.selectPage(devicePage, queryWrapper); - return devicePage; + List<Device> devices = devicePage.getRecords(); + List<Map<String, Object>> items = new ArrayList<>(); + for (Device device : devices) { + Map<String, Object> deviceInfo = selectDeviceInfoById(device.getId()); + items.add(deviceInfo); + } + Map<String, Object> result = new LinkedHashMap<>(); + result.put("total", devicePage.getTotal()); + result.put("totalPage", devicePage.getPages()); + result.put("current", devicePage.getCurrent()); + result.put("pageSize", devicePage.getSize()); + result.put("item", items); + return result; } @Override public Map<String, Object> selectDeviceInfoById(Integer deviceId) { - Map<String, Object> result = new LinkedHashMap<>(); + String mac = deviceMapper.selectById(deviceId).getMac(); + Map<String, Object> deviceInfo = getDeviceInfoFromRedis(mac); + //������redis������ + if (deviceInfo != null) { + return deviceInfo; + } + deviceInfo = new LinkedHashMap<>(); DeviceVO device = deviceMapper.selectDeviceInfoById(deviceId); //������ - result.put("id", device.getId()); - result.put("name", device.getName()); - result.put("mac", device.getMac()); - result.put("address", device.getAddress()); - result.put("longitude", device.getLongitude()); - result.put("latitude", device.getLatitude()); - result.put("createTime", DateUtils.dateToDateString(device.getCreateTime())); + deviceInfo.put("id", device.getId()); + deviceInfo.put("name", device.getName()); + deviceInfo.put("mac", device.getMac()); + deviceInfo.put("address", device.getAddress()); + deviceInfo.put("longitude", device.getLongitude()); + deviceInfo.put("latitude", device.getLatitude()); + deviceInfo.put("createTime", DateUtils.dateToDateString(device.getCreateTime())); + deviceInfo.put("installTime", device.getInstallTime() == null ? null : DateUtils.dateToDateString(device.getInstallTime())); + + //������������ + deviceInfo.put("extend", device.getExtend()); //������ - result.put("profession", device.getProfession()); - result.put("professionName", device.getProfessionName()); + deviceInfo.put("profession", device.getProfession()); + deviceInfo.put("professionName", device.getProfessionName()); //������ - result.put("tech", device.getTech()); - result.put("techName", device.getTechName()); + deviceInfo.put("tech", device.getTech()); + deviceInfo.put("techName", device.getTechName()); //��������� - result.put("detector", device.getDetector()); - result.put("detectorName", device.getDetectorName()); + deviceInfo.put("detector", device.getDetector()); + deviceInfo.put("detectorName", device.getDetectorName()); //��������� - result.put("purchaser", device.getPurchaser()); - result.put("purchaserName", device.getPurchaserName()); + deviceInfo.put("purchaser", device.getPurchaser()); + deviceInfo.put("purchaserName", device.getPurchaserName()); //������ Map<String, Object> versionInfo = new LinkedHashMap<>(); Version version = device.getVersion(); versionInfo.put("id", version.getId()); versionInfo.put("name", version.getName()); - result.put("version", versionInfo); + deviceInfo.put("version", versionInfo); //��������� List<Map<String, Object>> operatorsInfo = new ArrayList<>(); @@ -208,22 +368,27 @@ operatorMap.put("name", operator.getUserName()); operatorsInfo.add(operatorMap); } - result.put("operators", operatorsInfo); + deviceInfo.put("operators", operatorsInfo); //������ Map<String, Object> orgInfo = new LinkedHashMap<>(); Organization organization = device.getOrganization(); orgInfo.put("id", organization.getId()); orgInfo.put("name", organization.getName()); - result.put("organization", orgInfo); + deviceInfo.put("organization", orgInfo); //������ Map<String, Object> mpInfo = new LinkedHashMap<>(); MonitorPoint monitorPoint = device.getMonitorPoint(); mpInfo.put("id", monitorPoint.getId()); mpInfo.put("name", monitorPoint.getName()); - result.put("monitorPoint", mpInfo); - return result; + mpInfo.put("areaCode", monitorPoint.getAreaCode()); + mpInfo.put("cityCode", monitorPoint.getCityCode()); + mpInfo.put("provinceCode", monitorPoint.getProvinceCode()); + deviceInfo.put("monitorPoint", mpInfo); + + setDeviceInfoToRedis(mac, deviceInfo); + return deviceInfo; } @Override @@ -240,4 +405,152 @@ return monitorPointMapper.selectMaps(queryWrapper); } + @Override + public Map<String, Object> getDeviceByMac(String mac) { + Map<String, Object> deviceInfo = getDeviceInfoFromRedis(mac); + if (ObjectUtils.isEmpty(deviceInfo)) { + QueryWrapper<Device> queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("mac", mac).eq("is_delete", Constants.NOT_DELETE); + Device device = deviceMapper.selectOne(queryWrapper); + if (device != null) { + deviceInfo = selectDeviceInfoById(device.getId()); + setDeviceInfoToRedis(mac, deviceInfo); + } + } + return deviceInfo; + } + + @Override + public Map<String, Object> adjustDeviceData(Map<String, Object> deviceData) { + String mac = deviceData.remove("mac").toString(); + //���redis������������������ + 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"); + Object areaCode = monitorPoint.get("areaCode"); + Object cityCode = monitorPoint.get("cityCode"); + + 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); + } + return adjustDataUtils.adjust(deviceData, adjustFormula, ObjectUtils.isEmpty(aqiMap) ? null : aqiMap); + } + deviceData.remove("DataTime"); + return deviceData; + } + + @Override + public Map<String, Object> adjustSpecialDeviceData(Map<String, Object> deviceData) { + String mac = deviceData.remove("mac").toString(); + //���redis������������������ + Map<String, Object> adjustFormula = redisTemplate.opsForHash().entries(RedisConstants.ADJUST + "_" + mac); + if (!ObjectUtils.isEmpty(adjustFormula)) { + Organization organization = specialDeviceMapper.selectOrgByMac(mac); + Integer areaCode = organization.getAreaCode(); + Integer cityCode = organization.getCityCode(); + 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); + } + return adjustDataUtils.adjust(deviceData, adjustFormula, ObjectUtils.isEmpty(aqiMap) ? null : aqiMap); + } + deviceData.remove("DataTime"); + return deviceData; + } + + @Override + @Transactional + public void judgeDeviceState(Map<String, Object> deviceData) { + String mac = deviceData.remove("mac").toString(); + Device device = (Device) redisTemplate.opsForHash().get(RedisConstants.DEVICE_INFO, mac); + Version version = device.getVersion(); + List<Sensor> sensors = version.getSensors(); + Expression expression; + int state = 1; + for (Sensor sensor : sensors) { + //������������������ + String alarmLevel = sensor.getAlarmLevel(); + if (StringUtils.isEmpty(alarmLevel)) { + continue; + } + List<Object> list = JSONObject.parseObject(alarmLevel, List.class); + String sensorCode = sensor.getCode(); + //������������ + String formula = sensor.getFormula(); + //������������������������ + String sensorValue = (String) deviceData.get(sensorCode); + double value = Double.parseDouble(sensorValue); + //������������ + if (formula != null) { + //������������������ + sensorValue = formula.replace("{0}", sensorValue); + expression = AviatorEvaluator.compile(sensorValue); + value = Double.parseDouble(expression.execute().toString()); + } + int sensorState = judgeState(list, value); + if (sensorState > state) { + state = sensorState; + } + } + //������������������ + UpdateWrapper<Device> updateWrapper = new UpdateWrapper<>(); + updateWrapper.eq("id", device.getId()).set("state", String.valueOf(state)); + deviceMapper.update(null, updateWrapper); + } + + //��������������������������� + private int judgeState(List<Object> levels, Double data) { + int state = 1; + for (int i = levels.size() - 1; i >= 0; i--) { + Double level = Double.parseDouble(levels.get(i).toString()); + if (data >= level) { + state = i + 1; + break; + } + } + return state; + } + + private void insertOrganizationUnitAlarm(Integer orgId, Integer versionId) { + QueryWrapper<OrganizationUnitAlarm> queryOrganizationVersionWrapper = new QueryWrapper<>(); + queryOrganizationVersionWrapper.eq("organization_id", orgId); + queryOrganizationVersionWrapper.eq("version_id", versionId); + queryOrganizationVersionWrapper.eq("is_delete", Constants.NOT_DELETE); + List<OrganizationUnitAlarm> organizationUnitAlarms = organizationUnitAlarmMapper.selectList(queryOrganizationVersionWrapper); + if (ObjectUtils.isEmpty(organizationUnitAlarms)) { + QueryWrapper<VersionSensorUnit> queryVersionSensorUnitWrapper = new QueryWrapper<>(); + queryVersionSensorUnitWrapper.eq("version_id", versionId); + queryVersionSensorUnitWrapper.eq("is_delete", Constants.NOT_DELETE); + List<VersionSensorUnit> versionSensorUnits = versionSensorUnitMapper.selectList(queryVersionSensorUnitWrapper); + if (!ObjectUtils.isEmpty(versionSensorUnits)) { + for (VersionSensorUnit versionSensorUnit : versionSensorUnits) { + OrganizationUnitAlarm organizationUnitAlarm = new OrganizationUnitAlarm(); + organizationUnitAlarm.setOrganizationId(orgId); + organizationUnitAlarm.setVersionId(versionId); + organizationUnitAlarm.setSensorCode(versionSensorUnit.getSensorCode()); + organizationUnitAlarm.setUnitKey(versionSensorUnit.getUnitKey()); + organizationUnitAlarm.setShowUnitKey(versionSensorUnit.getUnitKey()); + organizationUnitAlarmMapper.insert(organizationUnitAlarm); + } + } + } + } + + private void deleteOrganizationUnitAlarm(Integer orgId, Integer versionId) { + QueryWrapper<Device> queryOrganizationVersionWrapper = new QueryWrapper<>(); + queryOrganizationVersionWrapper.eq("organization_id", orgId); + queryOrganizationVersionWrapper.eq("device_version_id", versionId); + queryOrganizationVersionWrapper.eq("is_delete", Constants.NOT_DELETE); + List<Device> devices = deviceMapper.selectList(queryOrganizationVersionWrapper); + if (ObjectUtils.isEmpty(devices)) {//������������������������������������������������������ + UpdateWrapper deleteWrapper = new UpdateWrapper(); + deleteWrapper.eq("organization_id", orgId); + deleteWrapper.eq("version_id", versionId); + deleteWrapper.eq("is_delete", Constants.NOT_DELETE); + deleteWrapper.set("is_delete", Constants.DELETE); + organizationUnitAlarmMapper.update(null, deleteWrapper); + } + } } -- Gitblit v1.8.0