From b86cc2c64617bd00b4b416681854a1c6d466b8d8 Mon Sep 17 00:00:00 2001 From: xyli Date: Mon, 6 Feb 2023 09:54:24 +0800 Subject: [PATCH] =?UTF-8?q?=20AutoImportLocalNode=E7=B1=BB=E6=B7=BB?= =?UTF-8?q?=E5=8A=A0findPid=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mpms/system/init/AutoImportLocalNode.java | 34 +++++++++++++++++++ 1 file changed, 34 insertions(+) diff --git a/src/main/java/mpms/system/init/AutoImportLocalNode.java b/src/main/java/mpms/system/init/AutoImportLocalNode.java index b28b824..09b5368 100644 --- a/src/main/java/mpms/system/init/AutoImportLocalNode.java +++ b/src/main/java/mpms/system/init/AutoImportLocalNode.java @@ -64,4 +64,38 @@ public class AutoImportLocalNode { DefaultSystemLog.getLog().error("自动添加本机节点错误", e); } } + + private static void findPid(String pid) { + File file = ConfigBean.getInstance().getApplicationJpomInfo(Type.Agent); + if (!file.exists() || file.isDirectory()) { + return; + } + // 比较进程id + String json = FileUtil.readString(file, CharsetUtil.CHARSET_UTF_8); + JpomManifest jpomManifest = JSONObject.parseObject(json, JpomManifest.class); + if (!pid.equals(String.valueOf(jpomManifest.getPid()))) { + return; + } + // 判断自动授权文件是否存在 + String path = ConfigBean.getInstance().getAgentAutoAuthorizeFile(jpomManifest.getDataPath()); + if (!FileUtil.exist(path)) { + return; + } + json = FileUtil.readString(path, CharsetUtil.CHARSET_UTF_8); + AgentAutoUser autoUser = JSONObject.parseObject(json, AgentAutoUser.class); + // 判断授权信息 + + NodeModel nodeModel = new NodeModel(); + nodeModel.setUrl(StrUtil.format("127.0.0.1:{}", jpomManifest.getPort())); + nodeModel.setName("本机"); + nodeModel.setId("01"); + + nodeModel.setLoginPwd(autoUser.getAgentPwd()); + nodeModel.setLoginName(autoUser.getAgentName()); + + nodeModel.setOpenStatus(true); + nodeModel.setTimeOut(10); + nodeService.addItem(nodeModel); + Console.log("自动添加本机节点成功：" + nodeModel.getId()); + } } -- Gitee