From 2e30239a9062fd7bdcc3bb068ab214460cb015b8 Mon Sep 17 00:00:00 2001 From: eastargh Date: Tue, 18 Aug 2026 15:03:45 +0900 Subject: [PATCH] =?UTF-8?q?UMS=20messenger=20api-monitor=20=EB=B0=9C?= =?UTF-8?q?=EC=86=A1=EC=97=AC=EB=B6=80=20=EC=B2=B4=ED=81=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../eai/rms/common/context/MonitoringContext.java | 2 +- .../eai/rms/ext/djb/apistatus/ApiStatusService.java | 2 +- .../eai/rms/ext/djb/inflow/InflowTokenService.java | 13 ++++++++++--- 3 files changed, 12 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/eactive/eai/rms/common/context/MonitoringContext.java b/src/main/java/com/eactive/eai/rms/common/context/MonitoringContext.java index 3eb2840..3f908ea 100644 --- a/src/main/java/com/eactive/eai/rms/common/context/MonitoringContext.java +++ b/src/main/java/com/eactive/eai/rms/common/context/MonitoringContext.java @@ -271,7 +271,7 @@ public interface MonitoringContext { public static final String RMS_PASSWORD_FAIL_COUNT = "rms.password.fail.count"; // API 상태변화 스윙챗 발송여부 - public static final String DJB_UMS_MESSENGER_APISTATUS_ENABLED = "djb.ums.messenger.apistatus.enabled"; + public static final String DJB_UMS_MESSENGER_APIMONITOR_ENABLED = "djb.ums.messenger.api-monitor.enabled"; diff --git a/src/main/java/com/eactive/eai/rms/ext/djb/apistatus/ApiStatusService.java b/src/main/java/com/eactive/eai/rms/ext/djb/apistatus/ApiStatusService.java index 538edb0..5fb5d1b 100644 --- a/src/main/java/com/eactive/eai/rms/ext/djb/apistatus/ApiStatusService.java +++ b/src/main/java/com/eactive/eai/rms/ext/djb/apistatus/ApiStatusService.java @@ -91,7 +91,7 @@ public class ApiStatusService { List apiIds = entry.getValue(); //내부직원 스윙챗 발송 - if (monitoringContext.getBooleanProperty(MonitoringContext.DJB_UMS_MESSENGER_APISTATUS_ENABLED, true)) { + if (monitoringContext.getBooleanProperty(MonitoringContext.DJB_UMS_MESSENGER_APIMONITOR_ENABLED, true)) { HashMap params = getSwingChatMessage(event, apiIds); ums.send("api-monitor", MessageCode.API_STATUS_CHANGED, params); } diff --git a/src/main/java/com/eactive/eai/rms/ext/djb/inflow/InflowTokenService.java b/src/main/java/com/eactive/eai/rms/ext/djb/inflow/InflowTokenService.java index 2388c5b..436de74 100644 --- a/src/main/java/com/eactive/eai/rms/ext/djb/inflow/InflowTokenService.java +++ b/src/main/java/com/eactive/eai/rms/ext/djb/inflow/InflowTokenService.java @@ -10,6 +10,7 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import com.eactive.apim.portal.template.entity.MessageCode; +import com.eactive.eai.rms.common.context.MonitoringContext; import com.eactive.eai.rms.data.entity.onl.djb.inflow.InflowTokenInsufficient; import com.eactive.eai.rms.ext.djb.ums.UmsManager; @@ -23,6 +24,9 @@ public class InflowTokenService { @Autowired private InflowTokenRepository inflowTokenRepository; + @Autowired + private MonitoringContext monitoringContext; + @Autowired private UmsManager ums; @@ -32,9 +36,12 @@ public class InflowTokenService { for (InflowTokenInsufficient info : rows) { log.debug("유량제어 토큰 획득 실패: {}-{} 최근 {}분 동안 {}건", info.getEaisvcname(), info.getEaisvcdesc(), rangeMinute, info.getCnt()); String message = "유량제어 토큰 획득 실패가 발생하였습니다 \n" + info.getEaisvcname(); - HashMap params = new HashMap(); - params.put("message", message); - ums.send("api-monitor", MessageCode.INFLOW_TOKEN_FAILED, params); + + if (monitoringContext.getBooleanProperty(MonitoringContext.DJB_UMS_MESSENGER_APIMONITOR_ENABLED, true)) { + HashMap params = new HashMap(); + params.put("message", message); + ums.send("api-monitor", MessageCode.INFLOW_TOKEN_FAILED, params); + } } } }