11 Commits

Author SHA1 Message Date
eastargh 7430b03323 다시 적용
eapim-admin CI / build (push) Has been cancelled
2026-08-06 11:33:52 +09:00
eastargh 5b05489924 일단 원래데로
eapim-admin CI / build (push) Has been cancelled
2026-08-06 11:05:45 +09:00
eastargh 3c386b780b Merge branch 'master' of https://git.eactive.synology.me:8090/eapim/djbank/eapim-admin.git
eapim-admin CI / build (push) Has been cancelled
2026-08-06 10:47:01 +09:00
eastargh f928a0b1e4 전문매핑 단일 연결/해제 버튼 추가 2026-08-06 10:46:53 +09:00
Rinjae dc9e737aa9 IP 매칭 유틸리티 추가 - CIDR/와일드카드 포함(#194).
eapim-admin CI / build (push) Has been cancelled
포탈 캐시 리로드 다중 서버 지원 - UI 개선/동시 호출 추가.
내부 API 유틸/테스트 및 JSP UI 연계 최적화.
2026-08-06 09:59:23 +09:00
eastargh db57e95233 이벤트유형 CONTROL_ > CHECK_ 로 변경
eapim-admin CI / build (push) Has been cancelled
2026-08-06 09:15:57 +09:00
Rinjae 643e7fcdf2 damo-manager.jar 라이브러리 업데이트
eapim-admin CI / build (push) Has been cancelled
- eapim-admin, eapim-online, elink-portal 공통 반영
2026-08-05 17:46:55 +09:00
Rinjae 36994a57b6 속성 관리 화면 수정
eapim-admin CI / build (push) Has been cancelled
- 다중라인 값 편집 및 줄바꿈 지원 PRPTY2VAL 속성 수정
- prpty2Val 입력 필드 텍스트 영역으로 변경 및 스타일 추가
- jQuery 선택자 간소화 `<input>` → `<textarea>` for consistency
2026-08-05 15:23:46 +09:00
Rinjae 4a087e576b Merge commit '9f22d4fa4d6720aabb06a5541449ebb120397987'
eapim-admin CI / build (push) Has been cancelled
2026-08-05 14:22:34 +09:00
eastargh 9f22d4fa4d 로그상세에서 정렬클릭시 지수형 풀리지 않도록
eapim-admin CI / build (push) Has been cancelled
2026-08-05 11:36:51 +09:00
eastargh 66c01029cd UMS 설정 수정
eapim-admin CI / build (push) Has been cancelled
2026-08-05 11:12:46 +09:00
14 changed files with 430 additions and 71 deletions
@@ -31,6 +31,8 @@ function init(){
new makeOptions("CODE","NAME").setObj($("select[name=searchJobInst]")).setNoValueInclude(true).setNoValue("", new makeOptions("CODE","NAME").setObj($("select[name=searchJobInst]")).setNoValueInclude(true).setNoValue("",
"<%= localeMessage.getString("combo.all")%>").setData(json.instanceList).rendering(); "<%= localeMessage.getString("combo.all")%>").setData(json.instanceList).rendering();
$("select[name=searchJobUseYn]").val("Y");
putSelectFromParam(); putSelectFromParam();
initGrid(); initGrid();
@@ -45,6 +45,9 @@
background-color: #EDD5DD background-color: #EDD5DD
} }
.btn_move { width:32px; min-width: 32px; height: 32px; background-color: #fff; border:1px solid #999; border-radius:4px; margin-bottom: 4px; }
</style> </style>
<jsp:include page="/jsp/common/include/script.jsp"/> <jsp:include page="/jsp/common/include/script.jsp"/>
<script language="javascript" src="<c:url value="/js/jsplumb.js"/>"></script> <script language="javascript" src="<c:url value="/js/jsplumb.js"/>"></script>
@@ -888,7 +891,7 @@
} }
}); });
$("input[name=auto]").click(function(){ $("#auto").click(function(){
//debugger; //debugger;
jsPlumbInstance.deleteEveryConnection(); jsPlumbInstance.deleteEveryConnection();
@@ -915,7 +918,7 @@
} }
}); });
$("input[name=addAll]").click(function() { $("#addAll").click(function() {
console.debug('addAll'); console.debug('addAll');
var srcRowId = sourceGrid.getGridParam( "selrow" ); var srcRowId = sourceGrid.getGridParam( "selrow" );
var tgtRowId = targetGrid.getGridParam( "selrow" ); var tgtRowId = targetGrid.getGridParam( "selrow" );
@@ -966,7 +969,7 @@
} }
}); });
$("input[name=removeAll]").click(function(){ $("#removeAll").click(function(){
var tgtRowId = targetGrid.getGridParam( "selrow" ); var tgtRowId = targetGrid.getGridParam( "selrow" );
if (tgtRowId == null) {alert("타겟레이아웃을 선택하여 주십시요.");return;} if (tgtRowId == null) {alert("타겟레이아웃을 선택하여 주십시요.");return;}
//grid data //grid data
@@ -986,6 +989,49 @@
} }
}); });
$("#add").click(function() {
var srcRowId = sourceGrid.getGridParam( "selrow" );
var tgtRowId = targetGrid.getGridParam( "selrow" );
if (srcRowId == null) {alert('<%=localeMessage.getString("transformManDetail.alert1")%>');return;}
if (tgtRowId == null) {alert('<%=localeMessage.getString("transformManDetail.alert2")%>');return;}
//field, ATTR 여부 판단
var sourceRow = sourceGrid.getRowData( srcRowId );
var targetRow = targetGrid.getRowData( tgtRowId );
if ( (sourceRow["loutItemType"] == 'Field' || sourceRow["loutItemType"] == 'Attr' || sourceRow["loutItemType"] == 'Array') &&
(targetRow["loutItemType"] == 'Field' || targetRow["loutItemType"] == 'Attr' || targetRow["loutItemType"] == 'Array') ){
;
}else{
alert('<%=localeMessage.getString("transformManDetail.alert3")%>');
return ;
}
targetGrid.jqGrid('setCell',tgtRowId,'CNVSNCMDNAME',addArrayTag(sourceRow['loutItemType'], addGroupTag(srcGroup,sourceRow['LOUTITEMPATH'])));
targetGrid.jqGrid('setCell',tgtRowId,'CNVSNRSULTITEMPATHNAME',addArrayTag(targetRow['loutItemType'], addGroupTag(tgtGroup,targetRow['LOUTITEMPATH'])));
targetGrid.jqGrid('setCell',tgtRowId,'CNVSNITEMSERNO',targetRow['loutItemSerno']);
try {
jsPlumbConnect(srcRowId, tgtRowId);
} catch (e) {console.error(e);}
});
$("#remove").click(function(){
var tgtRowId = targetGrid.getGridParam( "selrow" );
if (tgtRowId == null) {alert("타겟레이아웃을 선택하여 주십시요.");return;}
//grid data
var targetData = targetGrid.getRowData();
targetGrid.jqGrid('setCell', tgtRowId, 'CNVSNCMDNAME', null);
targetGrid.jqGrid('setCell', tgtRowId, 'CNVSNRSULTITEMPATHNAME', null);
targetGrid.jqGrid('setCell', tgtRowId, 'CNVSNITEMSERNO', null);
targetGrid.jqGrid('setCell', tgtRowId, 'CNVSNITEMBASCVAL', null);
const targetEndpointElementId = targetGrid.getEndpointElementId(tgtRowId);
jsPlumbInstance.deleteConnectionsForElement(document.getElementById(targetEndpointElementId));
});
$("textarea[name=CNVSNRSULTITEMPATHNAME],textarea[name=CNVSNCMDNAME],input[name=CNVSNITEMBASCVAL],input[name=CNVSNITEMSERNO]").blur(function(){ $("textarea[name=CNVSNRSULTITEMPATHNAME],textarea[name=CNVSNCMDNAME],input[name=CNVSNITEMBASCVAL],input[name=CNVSNITEMSERNO]").blur(function(){
var rowId = targetGrid.getGridParam( "selrow" ); var rowId = targetGrid.getGridParam( "selrow" );
if (isNull(rowId)) return; if (isNull(rowId)) return;
@@ -2161,12 +2207,12 @@
<div id="sourcePage"></div> <div id="sourcePage"></div>
</div> </div>
</td> </td>
<td style="width:30%; text-align:center; vertical-align: top;"> <td style="width:30%; min-width:70px; text-align:center; vertical-align: top; ">
<button type=button id="remove" name="remove" class="cssbtn btn_move" title="remove"><</button>
<br /><!-- 이 br 이 없을 때 버튼이 제대로 동작 하지 않는다. --> <button type=button id="add" name="add" class="cssbtn btn_move" title="add"> > </button><br />
<input type=button id="removeAll" name="removeAll" class="btn_img btn_removeAll"/><br /> <button type=button id="removeAll" name="removeAll" class="cssbtn btn_move" title="remove all"> << </button>
<input type=button id="addAll" name="addAll" class="btn_img btn_addAll"/><br /> <button type=button id="addAll" name="addAll" class="cssbtn btn_move" title="add all"> >> </button><br />
<input type=button id="auto" name="auto" class="btn_img btn_auto" /> <button type=button id="auto" name="auto" class="cssbtn btn_move" style="width: 70px; " title="auto"> Auto </button>
</td> </td>
<td style="vertical-align:top;"> <td style="vertical-align:top;">
<table class="table_row" cellspacing="0"> <table class="table_row" cellspacing="0">
@@ -189,7 +189,7 @@
<td> <td>
<input type="text" id="keywordList" style="width:100%" placeholder="쉼표(,)로 구분하여 입력"> <input type="text" id="keywordList" style="width:100%" placeholder="쉼표(,)로 구분하여 입력">
<div class="help-text" style="color:#666; font-size:12px; margin-top:5px;"> <div class="help-text" style="color:#666; font-size:12px; margin-top:5px;">
예시: #인증, #대출, #예금 예시: 인증, 대출, 예금
</div> </div>
</td> </td>
</tr> </tr>
@@ -327,14 +327,61 @@
}, 'json').fail(ajaxFail); }, 'json').fail(ajaxFail);
} }
// ── 캐시 Reload ──
var reloadModal;
var reloadBtnHtml;
function reloadPortalCache() { function reloadPortalCache() {
var $btn = $('#btnReloadCache');
if ($btn.prop('disabled')) return;
if (reloadBtnHtml === undefined) reloadBtnHtml = $btn.html();
$btn.prop('disabled', true)
.html('<span class="spinner-border spinner-border-sm"></span> 리로드 중...');
$.post(url, { cmd: 'TRANSACTION_RELOAD' }, function (result) { $.post(url, { cmd: 'TRANSACTION_RELOAD' }, function (result) {
if (result && result.success) { showReloadResult(result);
alert('포탈 메뉴 캐시 리로드 완료 (항목 ' + result.itemCount + '건, ' + result.reloadedAt + ')'); }, 'json').fail(ajaxFail).always(function () {
} else { $btn.prop('disabled', false).html(reloadBtnHtml);
alert('캐시 리로드 실패: ' + (result ? result.message : '알 수 없는 오류')); });
} }
}, 'json').fail(ajaxFail);
function showReloadResult(result) {
if (!result) {
alert('캐시 리로드 실패: 알 수 없는 오류');
return;
}
var servers = result.servers || [];
var $summary = $('#reloadSummary');
$summary.removeClass('alert-success alert-danger alert-warning')
.addClass(result.success ? 'alert-success'
: (result.successCount > 0 ? 'alert-warning' : 'alert-danger'))
.text(result.message || '');
var rows = '';
servers.forEach(function (s) {
var badge = s.success
? '<span class="badge text-bg-success">성공</span>'
: '<span class="badge text-bg-danger">실패</span>';
var detail = s.success
? ('항목 ' + (s.itemCount == null ? '-' : s.itemCount) + '건'
+ (s.reloadedAt ? ' / ' + escapeHtml(String(s.reloadedAt)) : ''))
: escapeHtml(String(s.message || '-'));
rows += '<tr>'
+ '<td class="text-center">' + badge + '</td>'
+ '<td style="word-break:break-all;">' + escapeHtml(String(s.url || '')) + '</td>'
+ '<td>' + detail + '</td>'
+ '<td class="text-end">' + (s.elapsedMs == null ? '-' : s.elapsedMs + 'ms') + '</td>'
+ '</tr>';
});
if (rows === '') {
rows = '<tr><td colspan="4" class="text-center text-muted">'
+ '호출 대상 서버가 없습니다. 아래 설정 안내를 확인하세요.</td></tr>';
}
$('#reloadResultBody').html(rows);
if (!reloadModal) reloadModal = new bootstrap.Modal(document.getElementById('reloadResultModal'));
reloadModal.show();
} }
function ajaxFail(xhr) { function ajaxFail(xhr) {
@@ -453,7 +500,7 @@
<button type="button" class="btn btn-sm btn-outline-danger" level="W" onclick="initializeMenus()"> <button type="button" class="btn btn-sm btn-outline-danger" level="W" onclick="initializeMenus()">
<i class="bi bi-arrow-counterclockwise"></i> 메뉴 초기화</button> <i class="bi bi-arrow-counterclockwise"></i> 메뉴 초기화</button>
<span class="spacer"></span> <span class="spacer"></span>
<button type="button" class="btn btn-sm btn-outline-secondary" level="W" onclick="reloadPortalCache()"> <button type="button" class="btn btn-sm btn-outline-secondary" id="btnReloadCache" level="W" onclick="reloadPortalCache()">
<i class="bi bi-arrow-repeat"></i> 캐시 Reload</button> <i class="bi bi-arrow-repeat"></i> 캐시 Reload</button>
<button type="button" class="btn btn-sm btn-success" level="W" onclick="savePlacements()"> <button type="button" class="btn btn-sm btn-success" level="W" onclick="savePlacements()">
<i class="bi bi-save"></i> 저장</button> <i class="bi bi-save"></i> 저장</button>
@@ -463,6 +510,12 @@
드래그로 위치를 조절한 뒤 <strong>저장</strong> 버튼으로 일괄 반영합니다. 드래그로 위치를 조절한 뒤 <strong>저장</strong> 버튼으로 일괄 반영합니다.
기본 항목([기본] 배지)은 [-] 시 <strong>미배치</strong>로만 이동하고, 커스텀 항목은 미배치 시 <strong>삭제</strong>됩니다. 기본 항목([기본] 배지)은 [-] 시 <strong>미배치</strong>로만 이동하고, 커스텀 항목은 미배치 시 <strong>삭제</strong>됩니다.
저장 후 <strong>캐시 Reload</strong> 를 실행해야 포탈에 즉시 반영됩니다(미실행 시 TTL 경과 후 반영). 저장 후 <strong>캐시 Reload</strong> 를 실행해야 포탈에 즉시 반영됩니다(미실행 시 TTL 경과 후 반영).
<br>
캐시 Reload 대상 서버는 포탈 프로퍼티 <code>Portal / portal.internal.menu-reload-url</code> 로 설정합니다.
포탈이 <strong>다중 서버(이중화)</strong> 로 기동된 경우 모든 서버의 리로드 URL 을
<strong>콤마(,) 또는 줄바꿈</strong> 으로 나열해야 전체 서버에 반영됩니다
(예: <code>http://10.0.0.11:39130/internal/menu/reload, http://10.0.0.12:39130/internal/menu/reload</code>).
서버별 요청 타임아웃은 <strong>3초</strong> 이며, 실행 결과는 서버별로 표시됩니다.
</div> </div>
<div class="menu-board"> <div class="menu-board">
@@ -544,6 +597,39 @@
</div> </div>
</div> </div>
<!-- 캐시 Reload 결과 -->
<div class="modal fade" id="reloadResultModal" tabindex="-1" aria-hidden="true">
<div class="modal-dialog modal-lg">
<div class="modal-content">
<div class="modal-header">
<h5 class="modal-title">포탈 메뉴 캐시 Reload 결과</h5>
<button type="button" class="btn-close" data-bs-dismiss="modal" aria-label="닫기"></button>
</div>
<div class="modal-body">
<div class="alert py-2 px-3" id="reloadSummary" style="font-size:13px;"></div>
<table class="table table-sm table-bordered align-middle" style="font-size:12px;">
<thead class="table-light">
<tr>
<th style="width:70px;" class="text-center">결과</th>
<th>서버 URL</th>
<th style="width:38%;">상세</th>
<th style="width:80px;" class="text-end">소요</th>
</tr>
</thead>
<tbody id="reloadResultBody"></tbody>
</table>
<div class="text-muted" style="font-size:12px;">
대상 서버는 포탈 프로퍼티 <code>Portal / portal.internal.menu-reload-url</code> 에
콤마(,) 또는 줄바꿈으로 나열합니다. 서버별 타임아웃 3초, 전 서버 병렬 호출입니다.
</div>
</div>
<div class="modal-footer">
<button type="button" class="btn btn-sm btn-secondary" data-bs-dismiss="modal">닫기</button>
</div>
</div>
</div>
</div>
</div><!-- end content_middle --> </div><!-- end content_middle -->
</div><!-- end right_box --> </div><!-- end right_box -->
</body> </body>
@@ -40,7 +40,7 @@
if ($('input[name=prptyName]').val() == "") { if ($('input[name=prptyName]').val() == "") {
alert("<%= localeMessage.getString("propertyDetail.checkRequired2") %>"); alert("<%= localeMessage.getString("propertyDetail.checkRequired2") %>");
return false; return false;
} else if ($('input[name=prpty2Val]').val() == "") { } else if ($('[name=prpty2Val]').val() == "") {
alert("<%= localeMessage.getString("propertyDetail.checkRequired3") %>"); alert("<%= localeMessage.getString("propertyDetail.checkRequired3") %>");
return false; return false;
} }
@@ -90,7 +90,19 @@
'설명', '설명',
'<%= localeMessage.getString("propertyDetail.delYn") %>'], '<%= localeMessage.getString("propertyDetail.delYn") %>'],
colModel: [{name: 'PRPTYNAME', width: 50, align: 'left', editable: true}, colModel: [{name: 'PRPTYNAME', width: 50, align: 'left', editable: true},
{name: 'PRPTY2VAL', width: 150, align: 'left', editable: true}, {
name: 'PRPTY2VAL',
width: 150,
align: 'left',
editable: true,
//다행(멀티라인) 값 편집 — 관련 사이트 목록처럼 줄 단위 표기하는 값 지원
edittype: 'textarea',
editoptions: {rows: 3, cols: 60},
//줄바꿈이 그리드에서도 그대로 보이도록
cellattr: function () {
return ' style="white-space:pre-line; word-break:break-all;"';
}
},
{name: 'PRPTYDESC', width: 200, align: 'left', editable: true, edittype: 'textarea', editoptions: {rows: 2}}, {name: 'PRPTYDESC', width: 200, align: 'left', editable: true, edittype: 'textarea', editoptions: {rows: 2}},
{ {
name: 'DELETEYN', name: 'DELETEYN',
@@ -265,7 +277,7 @@
} }
var data = new Object(); var data = new Object();
data["PRPTYNAME"] = $("input[name=prptyName]").val(); data["PRPTYNAME"] = $("input[name=prptyName]").val();
data["PRPTY2VAL"] = $("input[name=prpty2Val]").val(); data["PRPTY2VAL"] = $("[name=prpty2Val]").val();
data["PRPTYDESC"] = $("input[name=prptyDesc]").val(); data["PRPTYDESC"] = $("input[name=prptyDesc]").val();
var rows = $("#grid")[0].rows; var rows = $("#grid")[0].rows;
@@ -346,7 +358,8 @@
<tr> <tr>
<th><%= localeMessage.getString("propertyDetail.propertyValue") %> <th><%= localeMessage.getString("propertyDetail.propertyValue") %>
</th> </th>
<td colspan="3"><input type="text" name="prpty2Val"/> <td colspan="3"><textarea name="prpty2Val" rows="3"
style="width:100%; box-sizing:border-box; resize:vertical;"></textarea>
</td> </td>
</tr> </tr>
<tr> <tr>
@@ -376,7 +376,7 @@
const value = bodyCodeEditor.getValue(); const value = bodyCodeEditor.getValue();
let prettyValue = value; let prettyValue = value;
if(syntax === 'JSN'){ if(syntax === 'JSN'){
prettyValue = vkbeautify.json(value); prettyValue = preserveExponential(value); //vkbeautify.json(value);
}else if(syntax === 'XML'){ }else if(syntax === 'XML'){
prettyValue = vkbeautify.xml(value).trim(); prettyValue = vkbeautify.xml(value).trim();
} }
@@ -407,6 +407,19 @@
} }
}); });
} }
function preserveExponential(jsonString) {
// 1. 지수 형태의 숫자(예: 1e+21, 5.43e-7)를 찾아 문자열 ""로 감쌉니다.
// JSON의 key 뒤에 오는 value 위치의 지수 표기법을 매칭합니다.
let protectedJson = jsonString.replace(/:\s*([+-]?\d+\.?\d*e[+-]?\d+)/gi, ': "$1"');
// 2. 보호된 상태로 vkbeautify를 실행하여 예쁘게 정렬합니다.
let prettyJson = vkbeautify.json(protectedJson);
// 3. (선택사항) 만약 최종 결과물에서 반드시 큰따옴표("")를 다시 제거해야 한다면 아래 주석을 해제하세요.
prettyJson = prettyJson.replace(/:\s*"([+-]?\d+\.?\d*e[+-]?\d+)"/gi, ': $1');
return prettyJson;
}
function doChangeSyntax(syntax){ function doChangeSyntax(syntax){
if(syntax === 'JSN'){ if(syntax === 'JSN'){
$('#btn_pretty_body').css('display', 'block'); $('#btn_pretty_body').css('display', 'block');
Binary file not shown.
@@ -20,6 +20,6 @@ public class WebhookReqEventId implements Serializable {
private String webhookReqId; private String webhookReqId;
@Column(name = "EVENT_TYPE", nullable = false, length = 50) @Column(name = "EVENT_TYPE", nullable = false, length = 50)
@Comment("이벤트 유형 (CONTROL_START, ERROR_START 등)") @Comment("이벤트 유형 (CHECK_START, ERROR_START 등)")
private String eventType; private String eventType;
} }
@@ -58,8 +58,8 @@ public class ApiStatusDetectionService {
private static final Logger log = LoggerFactory.getLogger(ApiStatusDetectionService.class); private static final Logger log = LoggerFactory.getLogger(ApiStatusDetectionService.class);
public static final String EVENT_CONTROL_START = "CONTROL_START"; public static final String EVENT_CHECK_START = "CHECK_START";
public static final String EVENT_CONTROL_END = "CONTROL_END"; public static final String EVENT_CHECK_END = "CHECK_END";
public static final String EVENT_ERROR_START = "ERROR_START"; public static final String EVENT_ERROR_START = "ERROR_START";
public static final String EVENT_ERROR_END = "ERROR_END"; public static final String EVENT_ERROR_END = "ERROR_END";
public static final String EVENT_DELAY_START = "DELAY_START"; public static final String EVENT_DELAY_START = "DELAY_START";
@@ -119,8 +119,8 @@ public class ApiStatusDetectionService {
/** /**
* 이벤트 감지 * 이벤트 감지
* @param event "CONTROL_START" : 점검시작 * @param event "CHECK_START" : 점검시작
"CONTROL_END" : 점검종료 "CHECK_END" : 점검종료
"ERROR_START" : 장애시작 "ERROR_START" : 장애시작
"ERROR_END" : 장애종료 "ERROR_END" : 장애종료
"DELAY_START" : 지연시작 "DELAY_START" : 지연시작
@@ -154,8 +154,8 @@ public class ApiStatusDetectionService {
case EVENT_DELAY_END: case EVENT_DELAY_END:
markRecovered(event, targets); markRecovered(event, targets);
break; break;
case EVENT_CONTROL_START: case EVENT_CHECK_START:
case EVENT_CONTROL_END: case EVENT_CHECK_END:
// 점검은 관리자 등록 공지가 원천 - 재기록하지 않음 // 점검은 관리자 등록 공지가 원천 - 재기록하지 않음
log.debug("점검 이벤트는 장애 데이터로 기록하지 않음: {} {}", event, targets); log.debug("점검 이벤트는 장애 데이터로 기록하지 않음: {} {}", event, targets);
break; break;
@@ -17,8 +17,8 @@ public interface ApiStatusRepository extends BaseRepository<ApiStatus, String> {
/** /**
* API 상태 판단. 정상(N), 점검(C), 지연(D), 장애(E) * API 상태 판단. 정상(N), 점검(C), 지연(D), 장애(E)
* *
* 1. 정상/지연/장애 -> 점검중 : CONTROL_START * 1. 정상/지연/장애 -> 점검중 : CHECK_START
* 2. 점검 -> 점검X : CONTROL_END * 2. 점검 -> 점검X : CHECK_END
* 3. 정상/지연 -> 장애 : ERROR_START * 3. 정상/지연 -> 장애 : ERROR_START
* 4. 장애 -> 장애X : ERROR_END * 4. 장애 -> 장애X : ERROR_END
* 5. 정상 -> 지연 : DELAY_START * 5. 정상 -> 지연 : DELAY_START
@@ -34,8 +34,8 @@ public interface ApiStatusRepository extends BaseRepository<ApiStatus, String> {
+ " FROM (" + " FROM ("
+ " SELECT EAISVCNAME" + " SELECT EAISVCNAME"
+ " , STATUS_CODE AS PREV_STATUS_CODE " + " , STATUS_CODE AS PREV_STATUS_CODE "
+ " , CASE WHEN STATUS_CODE != 'C' AND CTRL_YN = 'Y' THEN 'CONTROL_START'" + " , CASE WHEN STATUS_CODE != 'C' AND CTRL_YN = 'Y' THEN 'CHECK_START'"
+ " WHEN STATUS_CODE = 'C' AND CTRL_YN = 'N' THEN 'CONTROL_END'" + " WHEN STATUS_CODE = 'C' AND CTRL_YN = 'N' THEN 'CHECK_END'"
+ " WHEN STATUS_CODE IN ('N','D') AND ERR_YN = 'Y' THEN 'ERROR_START'" + " WHEN STATUS_CODE IN ('N','D') AND ERR_YN = 'Y' THEN 'ERROR_START'"
+ " WHEN STATUS_CODE = 'E' AND ERR_YN = 'N' THEN 'ERROR_END'" + " WHEN STATUS_CODE = 'E' AND ERR_YN = 'N' THEN 'ERROR_END'"
+ " WHEN STATUS_CODE = 'N' AND DELAY_YN = 'Y' THEN 'DELAY_START'" + " WHEN STATUS_CODE = 'N' AND DELAY_YN = 'Y' THEN 'DELAY_START'"
@@ -45,7 +45,7 @@ public interface ApiStatusRepository extends BaseRepository<ApiStatus, String> {
+ " SELECT A.EAISVCNAME" + " SELECT A.EAISVCNAME"
+ " , NVL(B.STATUS_CODE, 'N') AS STATUS_CODE" + " , NVL(B.STATUS_CODE, 'N') AS STATUS_CODE"
// 점검(KIND='MAINTENANCE')만 CTRL_YN 대상이다. KIND 를 안 걸면 관리자가 시작~종료 시각을 // 점검(KIND='MAINTENANCE')만 CTRL_YN 대상이다. KIND 를 안 걸면 관리자가 시작~종료 시각을
// 넣어 등록한 장애 공지까지 '점검중'으로 오판해 CONTROL_START 가 발생한다. // 넣어 등록한 장애 공지까지 '점검중'으로 오판해 CHECK_START 가 발생한다.
+ " , NVL(( SELECT MAX('Y') FROM EMSAPP.DJB_APISTATUS_INCIDENT_API X" + " , NVL(( SELECT MAX('Y') FROM EMSAPP.DJB_APISTATUS_INCIDENT_API X"
+ " WHERE EXISTS (SELECT 1 FROM EMSAPP.DJB_APISTATUS_INCIDENT Y WHERE X.INCIDENT_ID = Y.INCIDENT_ID " + " WHERE EXISTS (SELECT 1 FROM EMSAPP.DJB_APISTATUS_INCIDENT Y WHERE X.INCIDENT_ID = Y.INCIDENT_ID "
+ " AND Y.KIND = 'MAINTENANCE'" + " AND Y.KIND = 'MAINTENANCE'"
@@ -179,8 +179,8 @@ public class ApiStatusService {
private String resolveStatusCode(String event) { private String resolveStatusCode(String event) {
switch (event) { switch (event) {
case "CONTROL_START": return "C"; //점검 case "CHECK_START": return "C"; //점검
case "CONTROL_END": return "N"; //정상 case "CHECK_END": return "N"; //정상
case "ERROR_START": return "E"; //장애 case "ERROR_START": return "E"; //장애
case "ERROR_END": return "N"; //정상 case "ERROR_END": return "N"; //정상
case "DELAY_START": return "D"; //지연 case "DELAY_START": return "D"; //지연
@@ -195,10 +195,10 @@ public class ApiStatusService {
private HashMap<String, Object> getSwingChatMessage(String event, List<String> apiIds) { private HashMap<String, Object> getSwingChatMessage(String event, List<String> apiIds) {
String message = ""; String message = "";
switch (event) { switch (event) {
case "CONTROL_START": case "CHECK_START":
message = "API 서비스 점검이 시작되었습니다"; //점검 message = "API 서비스 점검이 시작되었습니다"; //점검
break; break;
case "CONTROL_END": case "CHECK_END":
message = "API 서비스 점검이 완료되었습니다"; //정상 message = "API 서비스 점검이 완료되었습니다"; //정상
break; break;
case "ERROR_START": case "ERROR_START":
@@ -166,6 +166,7 @@ public class UmsService {
if ("MESSENGER".equals(messageRequest.getMessageType()) ) { if ("MESSENGER".equals(messageRequest.getMessageType()) ) {
stdHeadVO.setChnl_tycd("FEP"); // 채널유형코드 stdHeadVO.setChnl_tycd("FEP"); // 채널유형코드
stdHeadVO.setHmab_dvcd("2"); // 내외구분코드 1:내부 2:외부(타발)
// 스윙챗 알림 공용 // 스윙챗 알림 공용
SwingCommonVO swiComVO = new SwingCommonVO(); SwingCommonVO swiComVO = new SwingCommonVO();
@@ -85,10 +85,10 @@ public class WebhookReceiveService {
log.info("[Webhook] 이벤트 처리 시작 - eventType: {}", eventType); log.info("[Webhook] 이벤트 처리 시작 - eventType: {}", eventType);
switch (eventType) { switch (eventType) {
case "CONTROL_START": case "CHECK_START":
handleControlStart(data); handleControlStart(data);
break; break;
case "CONTROL_END": case "CHECK_END":
handleControlEnd(data); handleControlEnd(data);
break; break;
case "ERROR_START": case "ERROR_START":
@@ -107,11 +107,11 @@ public class WebhookReceiveService {
/* ------------------------------------------------------------------ */ /* ------------------------------------------------------------------ */
private void handleControlStart(JsonNode data) { private void handleControlStart(JsonNode data) {
log.info("[Webhook] CONTROL_START 처리 - data: {}", data); log.info("[Webhook] CHECK_START 처리 - data: {}", data);
// TODO: 점검시작 처리 로직 // TODO: 점검시작 처리 로직
} }
private void handleControlEnd(JsonNode data) { private void handleControlEnd(JsonNode data) {
log.info("[Webhook] CONTROL_END 처리 - data: {}", data); log.info("[Webhook] CHECK_END 처리 - data: {}", data);
// TODO: 점검종료 처리 로직 // TODO: 점검종료 처리 로직
} }
private void handleErrorStart(JsonNode data) { private void handleErrorStart(JsonNode data) {
@@ -1,22 +1,40 @@
package com.eactive.eai.rms.onl.apim.portalmenu; package com.eactive.eai.rms.onl.apim.portalmenu;
import com.eactive.apim.portal.portalproperty.service.PortalPropertyService; import com.eactive.apim.portal.portalproperty.service.PortalPropertyService;
import org.apache.http.client.HttpClient;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.log4j.Logger; import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity; import org.springframework.http.ResponseEntity;
import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate; import org.springframework.web.client.RestTemplate;
import java.util.ArrayList;
import java.util.Collections;
import java.util.LinkedHashMap; import java.util.LinkedHashMap;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
/** /**
* eapim-portal 메뉴 캐시 리로드 클라이언트 (admin → portal 내부 호출). * eapim-portal 메뉴 캐시 리로드 클라이언트 (admin → portal 내부 호출).
* *
* <p>호출 URL 은 PTL_PROPERTY {@code Portal / portal.internal.menu-reload-url} 로 관리한다 * <p>호출 URL 은 PTL_PROPERTY {@code Portal / portal.internal.menu-reload-url} 로 관리한다
* (기본 {@code http://127.0.0.1:39130/internal/menu/reload}). * (기본 {@code http://127.0.0.1:39130/internal/menu/reload}).
* 포탈이 다중 인스턴스로 기동되는 환경을 위해 <b>콤마/세미콜론/줄바꿈</b> 으로 여러 URL 을 나열할 수 있으며,
* 나열된 모든 서버로 병렬 호출한다. 각 호출의 connect/read 타임아웃은 {@value #TIMEOUT_MS}ms 이다.
* portal 측은 {@code menu.internal.allow-ips} 허용 IP 목록으로 요청을 검증한다. * portal 측은 {@code menu.internal.allow-ips} 허용 IP 목록으로 요청을 검증한다.
* 오류는 결과 Map 으로 감싸 화면에 사유를 표시한다 — 예외를 전파하지 않는다.</p> * 오류는 결과 Map 으로 감싸 화면에 서버별 사유를 표시한다 — 예외를 전파하지 않는다.</p>
*/ */
@Component @Component
public class PortalMenuCacheClient { public class PortalMenuCacheClient {
@@ -26,50 +44,230 @@ public class PortalMenuCacheClient {
static final String PROP_GROUP = "Portal"; static final String PROP_GROUP = "Portal";
static final String PROP_RELOAD_URL = "portal.internal.menu-reload-url"; static final String PROP_RELOAD_URL = "portal.internal.menu-reload-url";
static final String DEFAULT_RELOAD_URL = "http://127.0.0.1:39130/internal/menu/reload"; static final String DEFAULT_RELOAD_URL = "http://127.0.0.1:39130/internal/menu/reload";
static final String PROP_DESCRIPTION =
"eapim-portal 메뉴 캐시 리로드 내부 URL. 다중 서버는 콤마(,)/세미콜론(;)/줄바꿈으로 구분";
/** 서버 1대당 connect/read 타임아웃(ms) */
static final int TIMEOUT_MS = 3000;
/** 병렬 호출 전체 대기 여유분(ms) — 스레드 시작/응답 파싱 지연 흡수 */
private static final int OVERALL_SLACK_MS = 2000;
/** 동시 호출 스레드 상한 */
private static final int MAX_PARALLELISM = 10;
private final PortalPropertyService portalPropertyService; private final PortalPropertyService portalPropertyService;
private final RestTemplate restTemplate; private final RestTemplate restTemplate;
@Autowired @Autowired
public PortalMenuCacheClient(PortalPropertyService portalPropertyService, RestTemplate restTemplate) { public PortalMenuCacheClient(PortalPropertyService portalPropertyService) {
this(portalPropertyService, createRestTemplateWithTimeout(TIMEOUT_MS));
}
/** 테스트용 — 타임아웃이 설정된 RestTemplate 을 직접 주입한다. */
PortalMenuCacheClient(PortalPropertyService portalPropertyService, RestTemplate restTemplate) {
this.portalPropertyService = portalPropertyService; this.portalPropertyService = portalPropertyService;
this.restTemplate = restTemplate; this.restTemplate = restTemplate;
} }
private static RestTemplate createRestTemplateWithTimeout(int timeoutMs) {
RequestConfig requestConfig = RequestConfig.custom()
.setConnectionRequestTimeout(timeoutMs)
.setConnectTimeout(timeoutMs)
.setSocketTimeout(timeoutMs)
.build();
HttpClient httpClient = HttpClientBuilder.create()
.setMaxConnTotal(MAX_PARALLELISM * 2)
.setMaxConnPerRoute(MAX_PARALLELISM)
.setDefaultRequestConfig(requestConfig)
.build();
HttpComponentsClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory();
factory.setHttpClient(httpClient);
RestTemplate restTemplate = new RestTemplate();
restTemplate.setRequestFactory(factory);
return restTemplate;
}
/** /**
* @return {@code {success, message, itemCount?, reloadedAt?}} * 설정된 모든 포탈 서버의 메뉴 캐시를 리로드한다.
*
* @return {@code {success, message, total, successCount, failCount, itemCount?, reloadedAt?,
* servers:[{url, success, message, itemCount?, reloadedAt?, elapsedMs}]}}
* — {@code success} 는 <b>모든</b> 서버가 성공한 경우에만 true
*/ */
public Map<String, Object> reload() { public Map<String, Object> reload() {
Map<String, Object> result = new LinkedHashMap<>(); List<String> urls = resolveUrls();
String url = resolveUrl(); List<Map<String, Object>> servers = callAll(urls);
try {
@SuppressWarnings("unchecked") int successCount = 0;
ResponseEntity<Map> response = restTemplate.postForEntity(url, null, Map.class); for (Map<String, Object> server : servers) {
Map<String, Object> body = response.getBody(); if (Boolean.TRUE.equals(server.get("success"))) {
if (response.getStatusCode().is2xxSuccessful() && body != null && "OK".equals(body.get("result"))) { successCount++;
result.put("success", true); }
result.put("message", "포탈 메뉴 캐시 리로드 완료"); }
result.put("itemCount", body.get("itemCount")); int failCount = servers.size() - successCount;
result.put("reloadedAt", body.get("reloadedAt"));
} else { Map<String, Object> result = new LinkedHashMap<>();
result.put("success", false); result.put("success", failCount == 0);
result.put("message", "포탈 응답 오류: " + (body == null ? response.getStatusCode() : body)); result.put("message", summarize(servers.size(), successCount, failCount));
result.put("total", servers.size());
result.put("successCount", successCount);
result.put("failCount", failCount);
result.put("servers", servers);
// 단일 서버 시절 응답과의 호환 — 첫 성공 서버의 값을 최상위에도 노출
for (Map<String, Object> server : servers) {
if (Boolean.TRUE.equals(server.get("success"))) {
result.put("itemCount", server.get("itemCount"));
result.put("reloadedAt", server.get("reloadedAt"));
break;
} }
} catch (Exception e) {
logger.error("포탈 메뉴 캐시 리로드 실패 - url: " + url, e);
result.put("success", false);
result.put("message", "포탈 호출 실패(" + url + "): " + e.getMessage());
} }
return result; return result;
} }
private String resolveUrl() { private String summarize(int total, int successCount, int failCount) {
if (total == 0) {
return "리로드 대상 URL 이 설정되지 않았습니다 (" + PROP_GROUP + " / " + PROP_RELOAD_URL + ")";
}
if (failCount == 0) {
return "포탈 메뉴 캐시 리로드 완료 (" + successCount + "/" + total + " 서버)";
}
if (successCount == 0) {
return "포탈 메뉴 캐시 리로드 실패 (0/" + total + " 서버)";
}
return "포탈 메뉴 캐시 리로드 일부 실패 (" + successCount + "/" + total + " 서버 성공)";
}
/** 모든 URL 로 병렬 호출. 반환 순서는 {@code urls} 순서와 동일하다. */
private List<Map<String, Object>> callAll(List<String> urls) {
if (urls.isEmpty()) {
return Collections.emptyList();
}
if (urls.size() == 1) {
return Collections.singletonList(callOne(urls.get(0)));
}
List<Callable<Map<String, Object>>> tasks = new ArrayList<>(urls.size());
for (final String url : urls) {
tasks.add(new Callable<Map<String, Object>>() {
@Override
public Map<String, Object> call() {
return callOne(url);
}
});
}
ExecutorService executor = Executors.newFixedThreadPool(Math.min(urls.size(), MAX_PARALLELISM));
try { try {
return portalPropertyService.getOrCreateProperty(PROP_GROUP, PROP_RELOAD_URL, List<Future<Map<String, Object>>> futures =
DEFAULT_RELOAD_URL, "eapim-portal 메뉴 캐시 리로드 내부 URL"); executor.invokeAll(tasks, TIMEOUT_MS + OVERALL_SLACK_MS, TimeUnit.MILLISECONDS);
} catch (Exception e) {
logger.warn("리로드 URL 조회 실패 - 기본값 사용: " + DEFAULT_RELOAD_URL, e); List<Map<String, Object>> results = new ArrayList<>(urls.size());
return DEFAULT_RELOAD_URL; for (int i = 0; i < futures.size(); i++) {
String url = urls.get(i);
Future<Map<String, Object>> future = futures.get(i);
try {
results.add(future.get());
} catch (CancellationException e) {
logger.warn("포탈 메뉴 캐시 리로드 타임아웃 - url: " + url);
results.add(failure(url, "응답 시간 초과(" + TIMEOUT_MS + "ms)", TIMEOUT_MS));
} catch (ExecutionException e) {
logger.error("포탈 메뉴 캐시 리로드 실패 - url: " + url, e.getCause());
results.add(failure(url, message(e.getCause()), 0L));
}
}
return results;
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
logger.error("포탈 메뉴 캐시 리로드 중단됨", e);
List<Map<String, Object>> results = new ArrayList<>(urls.size());
for (String url : urls) {
results.add(failure(url, "호출이 중단되었습니다", 0L));
}
return results;
} finally {
executor.shutdownNow();
} }
} }
/** 서버 1대 호출 — 예외를 전파하지 않고 실패 Map 으로 감싼다. */
private Map<String, Object> callOne(String url) {
long startedAt = System.currentTimeMillis();
try {
@SuppressWarnings("unchecked")
ResponseEntity<Map> response = restTemplate.postForEntity(url, null, Map.class);
long elapsed = System.currentTimeMillis() - startedAt;
@SuppressWarnings("unchecked")
Map<String, Object> body = response.getBody();
if (response.getStatusCode().is2xxSuccessful() && body != null && "OK".equals(body.get("result"))) {
Map<String, Object> server = new LinkedHashMap<>();
server.put("url", url);
server.put("success", true);
server.put("message", "리로드 완료");
server.put("itemCount", body.get("itemCount"));
server.put("reloadedAt", body.get("reloadedAt"));
server.put("elapsedMs", elapsed);
return server;
}
logger.warn("포탈 메뉴 캐시 리로드 응답 오류 - url: " + url + ", status: " + response.getStatusCode()
+ ", body: " + body);
return failure(url, "포탈 응답 오류: " + (body == null ? response.getStatusCode() : body), elapsed);
} catch (Exception e) {
long elapsed = System.currentTimeMillis() - startedAt;
logger.error("포탈 메뉴 캐시 리로드 실패 - url: " + url, e);
return failure(url, message(e), elapsed);
}
}
private Map<String, Object> failure(String url, String message, long elapsedMs) {
Map<String, Object> server = new LinkedHashMap<>();
server.put("url", url);
server.put("success", false);
server.put("message", message);
server.put("elapsedMs", elapsedMs);
return server;
}
private String message(Throwable t) {
if (t == null) {
return "알 수 없는 오류";
}
String msg = t.getMessage();
return (msg == null || msg.trim().isEmpty()) ? t.getClass().getSimpleName() : msg;
}
private List<String> resolveUrls() {
String raw;
try {
raw = portalPropertyService.getOrCreateProperty(PROP_GROUP, PROP_RELOAD_URL,
DEFAULT_RELOAD_URL, PROP_DESCRIPTION);
} catch (Exception e) {
logger.warn("리로드 URL 조회 실패 - 기본값 사용: " + DEFAULT_RELOAD_URL, e);
raw = DEFAULT_RELOAD_URL;
}
List<String> urls = parseUrls(raw);
return urls.isEmpty() ? parseUrls(DEFAULT_RELOAD_URL) : urls;
}
/**
* 콤마/세미콜론/줄바꿈으로 구분된 URL 목록을 파싱한다.
* {@code #} 로 시작하는 줄은 주석으로 무시하고, 중복 URL 은 최초 순서만 남긴다.
*/
static List<String> parseUrls(String raw) {
if (raw == null || raw.trim().isEmpty()) {
return Collections.emptyList();
}
Set<String> urls = new LinkedHashSet<>();
for (String token : raw.split("[,;\\r\\n]")) {
String url = token.trim();
if (url.isEmpty() || url.startsWith("#")) {
continue;
}
urls.add(url);
}
return new ArrayList<>(urls);
}
} }