From 51bbd6678bc654b05c5c40a7f7e4c044ee1831f0 Mon Sep 17 00:00:00 2001 From: daekuk Date: Wed, 28 Jan 2026 18:31:38 +0900 Subject: [PATCH] =?UTF-8?q?-=20=EB=A9=94=EB=AA=A8=EB=A6=AC=20=EB=A6=AC?= =?UTF-8?q?=EB=A1=9C=EB=93=9C=20=EB=AC=B8=EC=A0=9C=20=EA=B0=9C=EC=84=A0=20?= =?UTF-8?q?(=EB=B3=80=EA=B2=BD=EB=90=9C=20=EC=96=B4=EB=8C=91=ED=84=B0=20?= =?UTF-8?q?=ED=94=84=EB=9D=BC=ED=8D=BC=ED=8B=B0=20=EA=B0=92=EC=9D=B4=20?= =?UTF-8?q?=EB=B0=98=EC=98=81=EB=90=98=EC=A7=80=EC=95=8A=EC=95=84=EC=84=9C?= =?UTF-8?q?=20=EC=88=98=EC=A0=95)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../adapter/adapter/AdapterController.java | 2 +- .../adapter/adapter/AdapterManService.java | 64 ++++++++++++------- 2 files changed, 41 insertions(+), 25 deletions(-) diff --git a/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterController.java b/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterController.java index 64129af..338f5d5 100644 --- a/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterController.java +++ b/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterController.java @@ -248,7 +248,7 @@ public class AdapterController extends OnlBaseAnnotationController { synchronized (obj) { service.update(adapterGroupUI); - Map resultMap = service.reloadSync(adapterGroupUI); + Map resultMap = service.reloadSyncStdMsgAndAdapter(adapterGroupUI.getAdptrbzwkgroupname()); return ResponseEntity.ok(resultMap); } diff --git a/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterManService.java b/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterManService.java index 9b782ce..7de3d7b 100644 --- a/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterManService.java +++ b/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterManService.java @@ -333,8 +333,6 @@ public class AdapterManService extends OnlBaseService { List stdMsgInfoList = standardmessageinfoService.findByBzwksvckeynameStartingWith(adapterName); // 변경 사항이 있었는지 체크해서 HS04 Reload 함. - boolean isUpdated = false; - for (StandardMessageInfo stdMsgInfo : stdMsgInfoList) { String fullPath = stdMsgInfo.getApifullpath(); @@ -358,8 +356,6 @@ public class AdapterManService extends OnlBaseService { // DB에 즉시 반영 standardmessageinfoService.saveAndFlush(stdMsgInfo); - isUpdated = true; - } catch (Exception e) { log.error("StandardMessageInfo APIFULLPATH SAVE FAIL key = {}", stdMsgInfo.getBzwksvckeyname()); @@ -374,22 +370,6 @@ public class AdapterManService extends OnlBaseService { } } - if (isUpdated) { - - try { - - Command command = new ReloadSTDMessageCommand(); - command.setArgs("ALL"); - - agentUtilService.broadcast(command); - - log.debug("API 경로 변경 감지 -> 전체 표준 전문 리로드 명령 전송 완료 (ALL)"); - - } catch (Exception e) { - log.debug("브로드캐스트 전송 실패", e); - } - } - } public void delete(AdapterGroupUI adapterGroupUI) { @@ -559,7 +539,43 @@ public class AdapterManService extends OnlBaseService { adapterGroup.setMoniuseyn(adapterGroupUI.getMoniuseyn()); } } + + public Map reloadSyncStdMsgAndAdapter(String adapterGroupName) throws Exception { + + Map result = new HashMap<>(); + + String status = "success"; + + try { + log.debug(">>>>>>>> [Reload Start] 어댑터 그룹명 {}", adapterGroupName); + + CommonCommand pcommand = new CommonCommand( + "com.eactive.eai.agent.adapter.ReloadAdapterPropGroupCommand", + adapterGroupName + ); + agentUtilService.broadcast(pcommand); + + CommonCommand acommand = new CommonCommand( + "com.eactive.eai.agent.adapter.ReloadAdapterGroupCommand", + adapterGroupName + ); + agentUtilService.broadcast(acommand); + + Command stdcommand = new ReloadSTDMessageCommand(); + stdcommand.setArgs("ALL"); + agentUtilService.broadcast(stdcommand); + + log.info(">>>>>> [Reload End] 모든 리로드 명령 전송 완료"); + } catch (Exception e) { + status = "error"; + log.error("리로드 실패", e); + } + + result.put("status", status); + return result; + } + public Map reloadSync(AdapterGroupUI adapterGroupUI) throws Exception { Map receive = null; Map result = new HashMap<>(); @@ -571,19 +587,19 @@ public class AdapterManService extends OnlBaseService { prptyGroupName); agentUtilService.broadcast(pcommand); } - + CommonCommand acommand = new CommonCommand("com.eactive.eai.agent.adapter.ReloadAdapterGroupCommand", adapterGroupUI.getAdptrbzwkgroupname()); receive = agentUtilService.broadcast(acommand); - + if (receive.values().stream().anyMatch(value -> value == null || !"success".equals(value))) { status = "error"; } - + result.put("status", status); result.put("message", receive.toString()); return result; - + } public Map deleteSync(AdapterGroupUI map, List list) throws Exception {