diff --git a/src/main/java/org/springblade/modules/monitor/controller/MonitorController.java b/src/main/java/org/springblade/modules/monitor/controller/MonitorController.java index 6d49d56..432e986 100644 --- a/src/main/java/org/springblade/modules/monitor/controller/MonitorController.java +++ b/src/main/java/org/springblade/modules/monitor/controller/MonitorController.java @@ -1,36 +1,32 @@ package org.springblade.modules.monitor.controller; import lombok.AllArgsConstructor; -import org.springblade.core.tool.api.R; import org.springblade.modules.monitor.service.IConfigMonitorService; -import org.springblade.modules.monitor.vo.ConfigMonitorVO; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; -import java.util.List; - @RestController @AllArgsConstructor @RequestMapping("/monitor") public class MonitorController { - private final IConfigMonitorService configMonitorService; + private final IConfigMonitorService configMonitorService; - /** - * 判断设备是否正常 - */ - @GetMapping("/updateMonitorInfo") - public void ifFestival(){ - configMonitorService.updateMonitorInfo(); - } + /** + * 判断设备是否正常 + */ + @GetMapping("/updateMonitorInfo") + public void ifFestival() { + configMonitorService.updateMonitorInfo(); + } - /** - * 定时排查监控设备状态 - */ - @GetMapping("/monitoringEquip") - public void monitoringEquip(){ - configMonitorService.monitoringEquip(); - } + /** + * 定时排查监控设备状态 + */ + @GetMapping("/monitoringEquip") + public void monitoringEquip() { + configMonitorService.monitoringEquip(); + } } diff --git a/src/main/java/org/springblade/modules/monitor/service/impl/ConfigMonitorServiceImpl.java b/src/main/java/org/springblade/modules/monitor/service/impl/ConfigMonitorServiceImpl.java index 6bf8457..2ae82ea 100644 --- a/src/main/java/org/springblade/modules/monitor/service/impl/ConfigMonitorServiceImpl.java +++ b/src/main/java/org/springblade/modules/monitor/service/impl/ConfigMonitorServiceImpl.java @@ -40,6 +40,8 @@ import org.springblade.modules.monitor.entity.ConfigMonitor; import org.springblade.modules.monitor.mapper.ConfigMonitorMapper; import org.springblade.modules.monitor.service.IConfigMonitorService; import org.springblade.modules.monitor.vo.ConfigMonitorVO; +import org.springblade.modules.system.entity.Dict; +import org.springblade.modules.system.service.IDictService; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; @@ -63,6 +65,8 @@ public class ConfigMonitorServiceImpl extends ServiceImpl queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(ConfigMonitor::getType, MonitorConstant.EQUIP); queryWrapper.eq(BaseEntity::getIsDeleted,0); List list = baseMapper.selectList(queryWrapper); //按照父级id分组 Map> map = list.stream().collect(Collectors.groupingBy(ConfigMonitor::getParentId)); + //获取取数时间间隔数据字典 + List dictList = dictService.getList("time_period"); + Map dictMap = new HashMap<>(); + dictList.forEach(item ->{ + dictMap.put(item.getDictKey(),item.getDictValue()); + }); for(Map.Entry> entry : map.entrySet()){ Long parentId = entry.getKey(); List monitorList = entry.getValue(); @@ -119,6 +140,12 @@ public class ConfigMonitorServiceImpl extends ServiceImpl parentIdList = new ArrayList<>(); @@ -161,7 +188,7 @@ public class ConfigMonitorServiceImpl extends ServiceImpl wrapper = new LambdaQueryWrapper<>(); wrapper.eq(ConfigMonitor::getType, MonitorConstant.WEB); List list = baseMapper.selectList(wrapper); + list.forEach(item ->{ + if(!MonitorConstant.RESULT.equals(item.getResult())){ + item.setResult(String.format("%.2f",Double.parseDouble(item.getResult()))+"%"); + } + }); return list; } diff --git a/src/main/java/org/springblade/modules/monitor/task/MonitorTaskJob.java b/src/main/java/org/springblade/modules/monitor/task/MonitorTaskJob.java index ac7eacf..4f7f510 100644 --- a/src/main/java/org/springblade/modules/monitor/task/MonitorTaskJob.java +++ b/src/main/java/org/springblade/modules/monitor/task/MonitorTaskJob.java @@ -11,7 +11,8 @@ public class MonitorTaskJob { private final IConfigMonitorService configMonitorService; //更新服务器监控状态 - @Scheduled(cron ="0 0 0 1/1 * ? ") + @Scheduled(cron ="0 0 0/1 * * ? ") + //@Scheduled(cron ="0 0/1 * * * ? ") public void updateMonitorInfo(){ configMonitorService.updateMonitorInfo(); } diff --git a/src/main/java/org/springblade/modules/system/entity/Dict.java b/src/main/java/org/springblade/modules/system/entity/Dict.java index 9483f91..29c7f4c 100644 --- a/src/main/java/org/springblade/modules/system/entity/Dict.java +++ b/src/main/java/org/springblade/modules/system/entity/Dict.java @@ -64,7 +64,7 @@ public class Dict implements Serializable { * 字典值 */ @ApiModelProperty(value = "字典值") - private Integer dictKey; + private String dictKey; /** * 字典名称