Compare commits
11 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 7430b03323 | |||
| 5b05489924 | |||
| 3c386b780b | |||
| f928a0b1e4 | |||
| dc9e737aa9 | |||
| db57e95233 | |||
| 643e7fcdf2 | |||
| 36994a57b6 | |||
| 4a087e576b | |||
| 9f22d4fa4d | |||
| 66c01029cd |
@@ -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.
+1
-1
@@ -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();
|
||||||
|
|||||||
+4
-4
@@ -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);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user