设备状态长时间未变化算法更新

Lius

2024-03-07 c51323e6fcc84f08bc8c01e3dd6c916427f83f4e

 lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentServiceImpl.java

@@ -455,7 +455,7 @@
                            } else {
                                value = "无";
                            }
                        }  else if ("alarmContent".equals(englishName)) {
                        } else if ("alarmContent".equals(englishName)) {
                            if (oporation == 22) {
                                List<MdcAlarmInfo> mdcAlarmInfo = mdcAlarmInfoService.list(new LambdaQueryWrapper<MdcAlarmInfo>().eq(MdcAlarmInfo::getDriveType, mdcEquipment.getDriveType()).eq(MdcAlarmInfo::getAlarmCode, equipmentLog.getAlarm()).eq(MdcAlarmInfo::getIsUse, 0));
                                if (mdcAlarmInfo != null && !mdcAlarmInfo.isEmpty()) {
@@ -759,8 +759,13 @@
                Map<String, Object> param = new HashMap<>();
                param.put("columns", builder.toString());
                param.put("tableName", saveTableName);
                Map<String, Object> map = this.baseMapper.getWorkLineLast(param);
                if (map != null) {
                Map<String, Object> map = new HashMap<>();
                try {
                    map = this.baseMapper.getWorkLineLast(param);
                } catch (Exception e) {
                    log.error("查询单表数据出差！", e);
                }
                if (!map.isEmpty()) {
                    for (MdcEquipmentThreshold mdcEquipmentThreshold : mdcEquipmentThresholdList) {
                        Integer actualValue = Integer.valueOf(map.get(mdcEquipmentThreshold.getEnglishName()).toString());
                        Integer max = mdcEquipmentThreshold.getMaxThreshold();
@@ -790,45 +795,6 @@
                    }
                }
            }


//            //查询单表数据
//            MdcEquipmentDto mdcEquipmentDto = this.baseMapper.getWorkLineLast(saveTableName);
//            if (mdcEquipmentDto != null) {
//                MessageDTO messageDTO = new MessageDTO();
//                messageDTO.setTitle("设备运行转速报警！");
//                messageDTO.setCategory("预警消息");
//                messageDTO.setFromUser("admin");
//                messageDTO.setToUser("admin");
//                Integer spindlespeed = Integer.valueOf(mdcEquipmentDto.getSpindlespeed());
//                Integer actualspindlespeed = Integer.valueOf(mdcEquipmentDto.getActualspindlespeed());
//                if (range.equals(0)) {
//                    if (spindlespeed > actualspindlespeed) {
//                        // 实际值大于设定值   高
//                        messageDTO.setContent("设备编号为 [" + mdcEquipment.getEquipmentId() + "] 的设备运行转速高报警！");
//                        sysBaseApi.sendSysAnnouncement(messageDTO);
//                    } else if (spindlespeed < actualspindlespeed) {
//                        // 实际值小于设定值   低
//                        messageDTO.setContent("设备编号为 [" + mdcEquipment.getEquipmentId() + "] 的设备运行转速低报警！");
//                        sysBaseApi.sendSysAnnouncement(messageDTO);
//                    }
//                } else {
//                    int max = actualspindlespeed + actualspindlespeed * (range / 100);
//                    int min = actualspindlespeed - actualspindlespeed * (range / 100);
//                    if (spindlespeed > max || spindlespeed < min) {
//                        if (spindlespeed > actualspindlespeed) {
//                            // 实际值大于设定值   高
//                            messageDTO.setContent("设备编号为 [" + mdcEquipment.getEquipmentId() + "] 的设备运行转速高报警！");
//                            sysBaseApi.sendSysAnnouncement(messageDTO);
//                        } else if (spindlespeed < actualspindlespeed) {
//                            // 实际值小于设定值   低
//                            messageDTO.setContent("设备编号为 [" + mdcEquipment.getEquipmentId() + "] 的设备运行转速低报警！");
//                            sysBaseApi.sendSysAnnouncement(messageDTO);
//                        }
//                    }
//                }
//
//            }
        }

    }
@@ -849,4 +815,41 @@
        return this.baseMapper.exportXlsList(mdcEquipment);
    }

    /**
     * 通过车间ids获取设备树
     *
     * @param ids
     * @return
     */
    @Override
    public List<MdcEquipmentTree> loadTreeListByProductionIds(String ids) {
        List<String> productionIds = Arrays.asList(ids.split(","));
        //获取所有产线数据
        List<MdcProduction> productionList = mdcProductionService.list(new LambdaQueryWrapper<MdcProduction>().eq(MdcProduction::getDelFlag, CommonConstant.DEL_FLAG_0.toString()).orderByAsc(MdcProduction::getProductionOrder));
        List<String> allProductionIds = new ArrayList<>();
        //找到所有产线id的上级id
        if (!productionIds.isEmpty()) {
            for (String productionId : productionIds) {
                this.getAllProductionIds(productionList, productionId, allProductionIds);
            }
        }
        //过滤产线数据
        List<MdcProduction> list = productionList.stream().filter((MdcProduction mdcProduction) -> allProductionIds.contains(mdcProduction.getId())).collect(Collectors.toList());
        //组装产线设备树
        List<MdcEquipmentTree> treeList = FindsEquipmentProductionUtil.wrapEquipmentProductionTreeList(list);
        //填充设备数据
        FillEquipmentByProduction(treeList);
        return treeList;
    }

    /**
     * 查询单表数据
     * @param tableName
     * @return
     */
    @Override
    public MdcEquipmentDto getWorkLineLast(String tableName) {
        return this.baseMapper.findWorkLineLast(tableName);
    }

}