diff --git a/src/main/java/mpms/monitor/NodeMonitor.java b/src/main/java/mpms/monitor/NodeMonitor.java index be1da23915fb24e302ff9a013436935a12201fe1..a4223e3f4d89006f145234cac23a30b70e148003 100644 --- a/src/main/java/mpms/monitor/NodeMonitor.java +++ b/src/main/java/mpms/monitor/NodeMonitor.java @@ -76,4 +76,25 @@ public class NodeMonitor implements Task { private void checkList(List nodeModels) { } + private void getNodeInfo(NodeModel nodeModel) { + JsonMessage message = NodeForward.request(nodeModel, null, NodeUrl.GetDirectTop); + JSONObject jsonObject = message.getData(); + if (jsonObject == null) { + return; + } + double disk = jsonObject.getDoubleValue("disk"); + if (disk <= 0) { + return; + } + + SystemMonitorLog log = new SystemMonitorLog(); + log.setId(IdUtil.fastSimpleUUID()); + log.setOccupyMemory(jsonObject.getDoubleValue("memory")); + log.setOccupyDisk(disk); + log.setOccupyCpu(jsonObject.getDoubleValue("cpu")); + log.setMonitorTime(jsonObject.getLongValue("time")); + log.setNodeId(nodeModel.getId()); + System.console().printf("start write da\n"); + dbSystemMonitorLogService.insert(log); + } }