유량제어토큰감시 스케쥴러 메세지 1건만 발송

src/main/java/com/eactive/eai/rms/data/entity/onl/djb/inflow/InflowTokenInsufficient.java

@@ -1,7 +0,0 @@
-package com.eactive.eai.rms.data.entity.onl.djb.inflow;
-
-public interface InflowTokenInsufficient {
-	String getEaisvcname();
-	String getEaisvcdesc();
-	Long getCnt();
-}

src/main/java/com/eactive/eai/rms/ext/djb/inflow/InflowTokenRepository.java

@@ -1,21 +1,16 @@
 package com.eactive.eai.rms.ext.djb.inflow;
 
-import java.util.List;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.query.Param;
 import com.eactive.eai.data.jpa.BaseRepository;
-import com.eactive.eai.rms.data.entity.onl.djb.inflow.InflowTokenInsufficient;
 import com.eactive.eai.rms.data.entity.onl.djb.inflow.InflowTokenInsufficientLog;
 import com.eactive.eai.rms.data.entity.onl.djb.inflow.InflowTokenInsufficientLogId;
 
 public interface InflowTokenRepository extends BaseRepository<InflowTokenInsufficientLog, InflowTokenInsufficientLogId> {
 
 	@Query(nativeQuery = true, value =
-        " SELECT EAISVCNAME" +
+        " SELECT COUNT(*)" +
-	    "      , (SELECT EAISVCDESC FROM TSEAIHE01 WHERE A.EAISVCNAME = EAISVCNAME) AS EAISVCDESC" + 
+        " FROM TSEAIFR11" +
-        "      , COUNT(*) AS CNT" +
+        " WHERE MSGDPSTYMS >= TO_CHAR(SYSTIMESTAMP - NUMTODSINTERVAL(:rangeMinute, 'MINUTE'), 'YYYYMMDDHH24MISSFF3')")
-        " FROM TSEAIFR11 A" +
+	long countTokenInsufficient(@Param("rangeMinute") long rangeMinute);
-        " WHERE MSGDPSTYMS >= TO_CHAR(SYSTIMESTAMP - NUMTODSINTERVAL(:rangeMinute, 'MINUTE'), 'YYYYMMDDHH24MISSFF3')" +
-        " GROUP BY EAISVCNAME")
-	List<InflowTokenInsufficient> countTokenInsufficient(@Param("rangeMinute") long rangeMinute);
 }

src/main/java/com/eactive/eai/rms/ext/djb/inflow/InflowTokenService.java

@@ -1,7 +1,6 @@
 package com.eactive.eai.rms.ext.djb.inflow;
 
 import java.util.HashMap;
-import java.util.List;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -11,7 +10,6 @@ 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;
 
 
@@ -31,17 +29,21 @@ public class InflowTokenService {
     private UmsManager ums;
 
 	public void checkRecentFails(long rangeMinute) {
-		if (monitoringContext.getBooleanProperty(MonitoringContext.DJB_UMS_MESSENGER_APIMONITOR_ENABLED, true)) {
+		if (!monitoringContext.getBooleanProperty(MonitoringContext.DJB_UMS_MESSENGER_APIMONITOR_ENABLED, true)) {
-			List<InflowTokenInsufficient> rows = inflowTokenRepository.countTokenInsufficient(rangeMinute);
+			return;
+		}
 
-			for (InflowTokenInsufficient info : rows) {
+		long failCount = inflowTokenRepository.countTokenInsufficient(rangeMinute);
-				log.debug("유량제어 토큰 획득 실패: {}-{} 최근 {}분 동안 {}건", info.getEaisvcname(), info.getEaisvcdesc(), rangeMinute, info.getCnt());
+		if (failCount <= 0) {
-				String message = "유량제어 토큰 획득 실패가 발생하였습니다 \n" + info.getEaisvcname();
+			return;
+		}
 
-				HashMap<String,Object> params = new HashMap<String,Object>();
+		log.debug("유량제어 토큰 획득 실패: 최근 {}분 동안 {}건", rangeMinute, failCount);
+
+		String message = "유량제어 토큰 획득 실패가 발생하였습니다\n최근 " + rangeMinute + "분 동안 " + failCount + "건";
+
+		HashMap<String, Object> params = new HashMap<String, Object>();
 		params.put("message", message);
 		ums.sendMessenger("api-monitor", MessageCode.INFLOW_TOKEN_FAILED, params);
 	}
-		}
-	}
 }