| | |
| | | import com.moral.api.service.DeviceService; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | |
| | | import com.moral.api.service.SysDictDataService; |
| | | import com.moral.api.util.CacheUtils; |
| | | import com.moral.api.util.AdjustDataUtils; |
| | | import com.moral.api.util.LogUtils; |
| | |
| | | |
| | | @Autowired |
| | | private SysDictDataMapper sysDictDataMapper; |
| | | |
| | | @Autowired |
| | | private SysDictDataService sysDictDataService; |
| | | |
| | | @Autowired |
| | | private LogUtils logUtils; |
| | |
| | | return state; |
| | | } |
| | | |
| | | /** |
| | | * @Description: 判断组织是否含有该设备的型号,如果没有则添加到组织型号关系表中 |
| | | * @Param: [orgId, versionId] |
| | | * @return: void |
| | | * @Author: 陈凯裕 |
| | | * @Date: 2021/9/6 |
| | | */ |
| | | 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); |
| | | //获取所有因子的默认报警值 |
| | | Map<String, SysDictData> sensorAlarms = sysDictDataService.getDictDatasByType("defaultAlarm"); |
| | | if (!ObjectUtils.isEmpty(versionSensorUnits)) { |
| | | for (VersionSensorUnit versionSensorUnit : versionSensorUnits) { |
| | | OrganizationUnitAlarm organizationUnitAlarm = new OrganizationUnitAlarm(); |
| | | String sensorCode = versionSensorUnit.getSensorCode(); |
| | | //设置默认报警值 |
| | | SysDictData alarm = sensorAlarms.get(sensorCode); |
| | | if(alarm!=null) |
| | | organizationUnitAlarm.setAlarmLevel(alarm.getDataValue()); |
| | | organizationUnitAlarm.setOrganizationId(orgId); |
| | | organizationUnitAlarm.setVersionId(versionId); |
| | | organizationUnitAlarm.setSensorCode(versionSensorUnit.getSensorCode()); |
| | |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * @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); |