10 Commits

Author SHA1 Message Date
Rinjae 07fbe1ba54 장애·지연 구분 및 집계 개선:
eapim-portal CI / build (push) Has been cancelled
eapim-portal Test / test (push) Has been cancelled
- 지연 유형 로직 및 UI/스타일 업데이트
- JPQL 조회와 공개 조건 로직 전면 개정
2026-08-03 16:57:57 +09:00
Rinjae 4916bdf4af API 상태 지연 필터 및 UI/로직 개선:
- 장애·지연 구분 및 집계 로직 추가 대응
- 지연 유형 반영 색상/태그/레이블/UI 경로 업데이트
2026-08-03 15:33:21 +09:00
Rinjae 35621b5174 Merge branch 'master' into feats/api-status 2026-07-31 17:35:11 +09:00
Rinjae b97b0fcf7b "SBOM 생성 및 변환 추가 - CycloneDX -> Excel(xlsx) 지원 - Jenkins 단계에 SBOM 빌드 및 아티팩트 보관 연결"
eapim-portal CI / build (push) Has been cancelled
eapim-portal Test / test (push) Has been cancelled
2026-07-31 17:31:45 +09:00
Rinjae 6cb98d36bb API Status 개선 및 조회 기간 설정 추가 2026-07-31 16:22:43 +09:00
Rinjae fd229fca43 API Status 페이지 기능 및 UI 업데이트:
- 상태 모니터링 시각 및 세부 정보 노출 관련 로직 추가
- 지연 필터 및 상대 시간 표기 기능 구현
- 점검/장애 필터 옵션 및 탐지 메타 정보 조회 로직 보완
2026-07-31 14:42:09 +09:00
Rinjae 5e8d08f1af API Status 페이지 포탈 미게시 API 안내 추가:
- 포탈 미게시 API 필터 안내 배너 HTML 및 JS 추가
- 조회 시 API 명 표시 및 API 옵션 외 필터 유지 로직 변경
2026-07-31 14:10:39 +09:00
Rinjae e7945233fe Merged from master 2026-07-31 13:41:25 +09:00
Rinjae 0629e842a3 푸터 외부 링크 스타일 추가 및 SCSS 리팩토링
eapim-portal CI / build (push) Has been cancelled
eapim-portal Test / test (push) Has been cancelled
- footer-link--external 스타일 추가로 외부 링크 시각화
- 불필요한 CSS 줄바꿈 및 공백 제거로 파일 최적화
2026-07-31 13:33:41 +09:00
Rinjae 6fa2167378 Swing 알림 체계 도입 - 기존 Q&A 관리자 알림 제거 - Swing Notifier 구현 2026-07-30 19:33:11 +09:00
46 changed files with 1977 additions and 341 deletions
+15
View File
@@ -80,6 +80,21 @@ pipeline {
}
}
}
// SBOM(CycloneDX) -> xlsx. 산출물 eapim-portal-sbom.xlsx 를 아티팩트로 보관.
// 실패해도 배포는 진행하도록 UNSTABLE 로만 표시한다.
stage('SBOM') {
steps {
catchError(buildResult: 'UNSTABLE', stageResult: 'FAILURE') {
sh 'gradle sbomXlsx --no-daemon -Pprofile=weblogic'
}
}
post {
always {
archiveArtifacts allowEmptyArchive: true, artifacts: 'build/reports/sbom/*.xlsx', fingerprint: true
}
}
}
}
}
+15
View File
@@ -101,5 +101,20 @@ pipeline {
}
}
}
// SBOM(CycloneDX) -> xlsx. 산출물 eapim-portal-sbom.xlsx 를 아티팩트로 보관.
// 실패해도 빌드는 진행하도록 UNSTABLE 로만 표시한다.
stage('SBOM') {
steps {
catchError(buildResult: 'UNSTABLE', stageResult: 'FAILURE') {
sh 'gradle sbomXlsx --no-daemon'
}
}
post {
always {
archiveArtifacts allowEmptyArchive: true, artifacts: 'build/reports/sbom/*.xlsx', fingerprint: true
}
}
}
}
}
+2
View File
@@ -204,3 +204,5 @@ task printSourceSets {
}
}
}
// CycloneDX SBOM -> xlsx 변환 (gradle sbomXlsx)
apply from: "$projectDir/gradle/sbom-xlsx.gradle"
+326
View File
@@ -0,0 +1,326 @@
/*
* CycloneDX SBOM(bom.json) -> Excel(xlsx) 변환 태스크.
*
* gradle sbomXlsx # cyclonedxBom 실행 후 변환
* gradle sbomXlsx -PsbomJson=path.json # 기존 bom.json 사용(cyclonedxBom 생략)
* gradle sbomXlsx -PsbomOut=out.xlsx # 출력 경로 지정
*
* buildscript 블록이 이 스크립트에만 적용되므로 POI 의존성이 메인 빌드
* classpath 나 WAR 산출물에는 포함되지 않는다.
*
* 시트: 요약 / WAR 기준
* 산출 기준은 war 태스크의 classpath(= runtimeClasspath) 이므로
* test·annotationProcessor·developmentOnly·compileOnly 의존은 모두 제외된다.
* bom.json 은 라이선스/해시/설명/직접-전이 판별을 위한 메타 소스로만 쓴다.
*/
buildscript {
repositories {
maven {
url "https://nexus.eactive.synology.me:8090/repository/maven-public/"
allowInsecureProtocol = true
}
mavenCentral()
}
dependencies {
classpath 'org.apache.poi:poi-ooxml:3.17'
}
}
import groovy.json.JsonSlurper
import org.apache.poi.ss.usermodel.BorderStyle
import org.apache.poi.ss.usermodel.FillPatternType
import org.apache.poi.ss.usermodel.HorizontalAlignment
import org.apache.poi.ss.usermodel.IndexedColors
import org.apache.poi.ss.usermodel.VerticalAlignment
import org.apache.poi.ss.util.CellRangeAddress
import org.apache.poi.xssf.usermodel.XSSFWorkbook
// 엑셀 셀 문자열 상한(32767)보다 여유를 둔 절단 길이
ext.SBOM_CELL_LIMIT = 32000
task sbomXlsx {
group = 'sbom'
description = 'CycloneDX bom.json 을 WAR 수록 기준 xlsx 로 변환한다'
// -PsbomJson 으로 기존 산출물을 지정하면 재생성하지 않는다
if (!project.hasProperty('sbomJson')) {
dependsOn 'cyclonedxBom'
}
doLast {
File src = resolveBomJson(project)
File out = project.hasProperty('sbomOut')
? project.file(project.property('sbomOut'))
: new File(project.buildDir, "reports/sbom/${sbomFileName(project)}")
out.parentFile.mkdirs()
def bom = new JsonSlurper().parse(src, 'UTF-8')
def deploy = collectDeployJars(project)
def warRows = joinWarRows(deploy.jars, indexComponents(bom))
def wb = new XSSFWorkbook()
def st = createStyles(wb)
writeSummarySheet(wb, st, bom, warRows, src, deploy.label)
writeWarSheet(wb, st, warRows)
out.withOutputStream { os -> wb.write(os) }
wb.close()
int unmatched = warRows.count { it.matched == 'N' }
logger.lifecycle("SBOM xlsx 생성: ${out.absolutePath} " +
"(배포 수록 ${warRows.size()}개, SBOM 미매칭 ${unmatched}개, 원본 ${src.name})")
}
}
/** 산출 파일명: 배포 패키지명 기준 (war 있으면 war 파일명, 없으면 project 이름[-버전]) */
String sbomFileName(Project p) {
def warTask = p.tasks.findByName('war')
if (warTask != null) {
String archive = warTask.archiveFileName.get()
return archive.replaceAll(/\.(war|jar|ear)$/, '') + '-sbom.xlsx'
}
String ver = (p.version == null || p.version.toString() in ['', 'unspecified']) ? '' : "-${p.version}"
return "${p.name}${ver}-sbom.xlsx"
}
/** bom.json 위치 결정: -PsbomJson > cyclonedxBom 산출 경로 후보 */
File resolveBomJson(Project p) {
if (p.hasProperty('sbomJson')) {
File f = p.file(p.property('sbomJson'))
if (!f.exists()) {
throw new GradleException("bom.json 없음: ${f.absolutePath}")
}
return f
}
def candidates = [
new File(p.buildDir, 'reports/cyclonedx/bom.json'),
new File(p.buildDir, 'reports/bom.json'),
]
File found = candidates.find { it.exists() }
if (found == null) {
throw new GradleException(
"bom.json 을 찾지 못했다. 확인한 경로: " + candidates*.absolutePath.join(', ') +
"\n'gradle cyclonedxBom' 실행 후 재시도하거나 -PsbomJson=<경로> 로 지정한다.")
}
return found
}
/**
* 실제 배포물에 packaging 되는 jar 목록.
* war 프로젝트는 war 태스크 classpath(= runtimeClasspath), 그 외는 runtimeClasspath 를
* 기준으로 하므로 test/annotationProcessor/developmentOnly/compileOnly 는 자동으로 빠진다.
*
* @return [label: 기준 설명, jars: 행 목록]
*/
Map collectDeployJars(Project p) {
def cfg = p.configurations.findByName('runtimeClasspath')
if (cfg == null) {
p.logger.warn("[${p.name}] runtimeClasspath 가 없어 배포 기준 시트를 비운다")
return [label: '(없음)', jars: []]
}
def warTask = p.tasks.findByName('war')
def files
String label
if (warTask != null) {
files = warTask.classpath.files
label = 'WAR WEB-INF/lib (war 태스크 classpath)'
} else {
files = cfg.files
label = 'runtimeClasspath (war 태스크 없음)'
}
def coordByFile = [:]
cfg.resolvedConfiguration.resolvedArtifacts.each { a ->
def id = a.moduleVersion.id
coordByFile[a.file] = [group: id.group, name: id.name, version: id.version]
}
def jars = files.findAll { it.name.endsWith('.jar') }.collect { f ->
def c = coordByFile[f]
[
file : f.name,
group : c?.group ?: '',
name : c?.name ?: f.name.replaceAll(/\.jar$/, ''),
version: c?.version ?: '',
coord : c ? "${c.group}:${c.name}:${c.version}".toString() : '',
]
}.sort { it.file }
return [label: label, jars: jars]
}
/** bom.json 컴포넌트를 'group:name:version' 키로 색인 (라이선스/해시/설명/직접-전이) */
Map indexComponents(bom) {
String rootRef = bom.metadata?.component?.'bom-ref'
Set directRefs = (bom.dependencies?.find { it.ref == rootRef }?.dependsOn ?: []) as Set
def index = [:]
bom.components?.each { c ->
def hashes = [:]
c.hashes?.each { h -> hashes[h.alg] = h.content }
def licenses = (c.licenses ?: []).collect { l ->
l.license?.id ?: l.license?.name ?: l.expression ?: ''
}.findAll { it }
index["${c.group ?: ''}:${c.name ?: ''}:${c.version ?: ''}".toString()] = [
direct : directRefs.contains(c.'bom-ref') ? '직접' : '전이',
licenses : licenses.join('; '),
licenseList: licenses.isEmpty() ? ['(미상)'] : licenses,
purl : c.purl ?: '',
sha256 : hashes['SHA-256'] ?: '',
sha1 : hashes['SHA-1'] ?: '',
description: c.description ?: '',
]
}
return index
}
/** WAR jar 목록에 SBOM 메타를 좌표로 결합 */
List joinWarRows(List warJars, Map index) {
def result = []
warJars.eachWithIndex { j, i ->
def m = j.coord ? index[j.coord] : null
result << [
no : i + 1,
file : j.file,
group : j.group,
name : j.name,
version : j.version,
direct : m?.direct ?: '',
licenses : m?.licenses ?: '',
licenseList: m?.licenseList ?: ['(미상)'],
purl : m?.purl ?: '',
sha256 : m?.sha256 ?: '',
sha1 : m?.sha1 ?: '',
matched : (m != null) ? 'Y' : 'N',
description: m?.description ?: '',
]
}
return result
}
Map createStyles(wb) {
def headFont = wb.createFont()
headFont.setBold(true)
headFont.setColor(IndexedColors.WHITE.getIndex())
def head = wb.createCellStyle()
head.setFont(headFont)
head.setFillForegroundColor(IndexedColors.DARK_BLUE.getIndex())
head.setFillPattern(FillPatternType.SOLID_FOREGROUND)
head.setAlignment(HorizontalAlignment.CENTER)
head.setVerticalAlignment(VerticalAlignment.CENTER)
head.setBorderBottom(BorderStyle.THIN)
def body = wb.createCellStyle()
body.setVerticalAlignment(VerticalAlignment.TOP)
def wrap = wb.createCellStyle()
wrap.setVerticalAlignment(VerticalAlignment.TOP)
wrap.setWrapText(true)
def labelFont = wb.createFont()
labelFont.setBold(true)
def label = wb.createCellStyle()
label.setFont(labelFont)
return [head: head, body: body, wrap: wrap, label: label]
}
/** 헤더 행 생성 + 폭 지정 + 틀고정 */
def writeHeader(sheet, style, List<String> headers, List<Integer> widths) {
def row = sheet.createRow(0)
row.setHeightInPoints(20f)
headers.eachWithIndex { h, i ->
def cell = row.createCell(i)
cell.setCellValue(h)
cell.setCellStyle(style)
sheet.setColumnWidth(i, widths[i] * 256)
}
sheet.createFreezePane(0, 1)
}
def cellOf(row, int idx, value, style) {
def cell = row.createCell(idx)
String s = (value == null) ? '' : value.toString()
if (s.length() > SBOM_CELL_LIMIT) {
s = s.substring(0, SBOM_CELL_LIMIT) + '…(생략)'
}
cell.setCellValue(s)
cell.setCellStyle(style)
return cell
}
def writeSummarySheet(wb, st, bom, List warRows, File src, String basisLabel) {
def sheet = wb.createSheet('요약')
def comp = bom.metadata?.component ?: [:]
def tool = bom.metadata?.tools?.components?.getAt(0)
Set licenseKinds = warRows.collectMany { it.licenseList } as Set
def items = [
['대상 프로젝트', "${comp.group ?: ''}:${comp.name ?: ''}:${comp.version ?: ''}"],
['산출 기준', "${basisLabel} — test/annotationProcessor/compileOnly 제외"],
['BOM 포맷', "${bom.bomFormat ?: ''} ${bom.specVersion ?: ''}"],
['serialNumber', bom.serialNumber ?: ''],
['생성 시각', bom.metadata?.timestamp ?: ''],
['생성 도구', tool ? "${tool.name} ${tool.version}" : ''],
['원본 파일', src.absolutePath],
['배포 수록 jar', warRows.size()],
[' └ 직접 의존', warRows.count { it.direct == '직접' }],
[' └ 전이 의존', warRows.count { it.direct == '전이' }],
[' └ SBOM 미매칭', warRows.count { it.matched == 'N' }],
['라이선스 종류', licenseKinds.size()],
['라이선스 미상', warRows.count { it.licenses.isEmpty() }],
]
writeHeader(sheet, st.head, ['항목', '값'], [30, 90])
items.eachWithIndex { item, i ->
def row = sheet.createRow(i + 1)
cellOf(row, 0, item[0], st.label)
cellOf(row, 1, item[1], st.body)
}
// 라이선스 분포 (요약 하단)
def byLicense = [:].withDefault { 0 }
warRows.each { r -> r.licenseList.each { lic -> byLicense[lic] = byLicense[lic] + 1 } }
def sorted = byLicense.entrySet().sort { a, b -> (b.value <=> a.value) ?: (a.key <=> b.key) }
int base = items.size() + 2
def hdr = sheet.createRow(base)
cellOf(hdr, 0, '라이선스', st.head)
cellOf(hdr, 1, 'jar 수', st.head)
sorted.eachWithIndex { e, i ->
def row = sheet.createRow(base + 1 + i)
cellOf(row, 0, e.key, st.body)
cellOf(row, 1, e.value, st.body)
}
}
/** 실제 배포물(WAR WEB-INF/lib) 기준 시트 */
def writeWarSheet(wb, st, List warRows) {
def sheet = wb.createSheet('WAR 기준')
def headers = ['No', 'jar 파일명', 'Group', 'Name', 'Version', '구분',
'License', 'purl', 'SHA-256', 'SHA-1', 'SBOM매칭', 'Description']
def widths = [6, 46, 32, 34, 16, 7, 30, 60, 40, 30, 10, 60]
writeHeader(sheet, st.head, headers, widths)
warRows.eachWithIndex { r, i ->
def row = sheet.createRow(i + 1)
cellOf(row, 0, r.no, st.body)
cellOf(row, 1, r.file, st.body)
cellOf(row, 2, r.group, st.body)
cellOf(row, 3, r.name, st.body)
cellOf(row, 4, r.version, st.body)
cellOf(row, 5, r.direct, st.body)
cellOf(row, 6, r.licenses, st.body)
cellOf(row, 7, r.purl, st.body)
cellOf(row, 8, r.sha256, st.body)
cellOf(row, 9, r.sha1, st.body)
cellOf(row, 10, r.matched, st.body)
cellOf(row, 11, r.description, st.wrap)
}
if (!warRows.isEmpty()) {
sheet.setAutoFilter(new CellRangeAddress(0, warRows.size(), 0, headers.size() - 1))
}
}
@@ -11,8 +11,8 @@ import java.time.LocalDateTime;
/**
* API 상태 모니터링 결과 (AGWAPP.API_STATUS).
*
* <p>eapim-admin 의 {@code ApiStatusMonitorJob}(Quartz, 매분)이 상태 변화가 있을 때만 upsert 한다.
* 포털은 읽기 전용으로 "마지막 상태 갱신 시각" 표시에 사용한다.</p>
* <p>eapim-admin 의 {@code ApiStatusMonitorJob} 이 상태 변화가 있을 때만 upsert 한다.
* 포털은 읽기 전용으로 "마지막 상태 변경 시각" 표시에 사용한다.</p>
*/
@Entity
@Table(name = "API_STATUS")
@@ -10,7 +10,7 @@ import java.util.Optional;
public interface GwApiStatusRepository extends Repository<GwApiStatus, String> {
/**
* 탐지 결과가 마지막으로 갱신된 시각. 데이터가 없으면 empty.
* API 상태가 마지막으로 변경된 시각. 데이터가 없으면 empty.
*/
@Query("SELECT MAX(s.modifiedDate) FROM GwApiStatus s")
Optional<LocalDateTime> findLastModifiedDate();
@@ -9,6 +9,7 @@ import com.eactive.apim.portal.apps.apiservice.dto.ApiServiceDTO;
import com.eactive.apim.portal.apps.apiservice.service.ApiServiceService;
import com.eactive.apim.portal.common.exception.NotFoundException;
import com.eactive.apim.portal.common.util.SecurityUtil;
import com.eactive.apim.portal.djb.apistatus.service.ApiStatusCatalogService;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
@@ -31,6 +32,7 @@ public class ApiController {
private final ApiService apiService;
private final ApiServiceService apiServiceService;
private final ApiSearchFacade apiSearchFacade;
private final ApiStatusCatalogService apiStatusCatalogService;
private static final String DEFAULT_TOKEN_API_ID = "default-token-api-spec";
private static final String DEFAULT_TOKEN_API_NAME = "인증";
@@ -86,6 +88,8 @@ public class ApiController {
model.addAttribute("totalApiCount", searchResult.get("totalApiCount"));
model.addAttribute("selectedApiCount", searchResult.get("selectedApiCount"));
model.addAttribute("selected", search.getGroupIds().size() > 0 ? search.getGroupIds().get(0) : "-1");
// 카드의 현재 상태 태그 노출 여부 (PTL_PROPERTY djb.apistatus.api-list-status-badge)
model.addAttribute("apiStatusBadgeEnabled", apiStatusCatalogService.isApiListStatusBadgeEnabled());
return "apps/apis/mainApiList";
}
@@ -6,7 +6,7 @@ import com.eactive.apim.portal.apps.community.partnership.mapper.PartnershipAppl
import com.eactive.apim.portal.common.user.PortalAuthenticatedUser;
import com.eactive.apim.portal.common.util.SecurityUtil;
import com.eactive.apim.portal.common.util.UserTypeUtil;
import com.eactive.apim.portal.djb.community.qna.comment.service.CommunityAdminNotifier;
import com.eactive.apim.portal.djb.swing.SwingNotifier;
import com.eactive.apim.portal.file.entity.FileInfo;
import com.eactive.apim.portal.file.service.FileService;
import com.eactive.apim.portal.file.service.FileTypeContext;
@@ -29,7 +29,7 @@ public class PartnershipApplicationFacadeImpl implements PartnershipApplicationF
private final PartnershipApplicationMapper partnershipApplicationMapper;
private final FileService fileService;
// portal-admin 알림 발행기(범용). Q&A 등록 알림과 동일 컴포넌트를 재사용한다.
private final CommunityAdminNotifier portalAdminNotifier;
private final SwingNotifier swingNotifier;
@Override
@@ -61,7 +61,7 @@ public class PartnershipApplicationFacadeImpl implements PartnershipApplicationF
if (writer != null) {
params.put("writerName", writer.getUserName());
}
portalAdminNotifier.notifyPortalAdmins(MessageCode.PARTNERSHIP_CREATED, params);
swingNotifier.notifyPortalAdmins(MessageCode.PARTNERSHIP_CREATED, params);
}
@Override
@@ -6,7 +6,7 @@ import com.eactive.apim.portal.apps.community.qna.mapper.InquiryMapper;
import com.eactive.apim.portal.common.user.PortalAuthenticatedUser;
import com.eactive.apim.portal.common.util.SecurityUtil;
import com.eactive.apim.portal.common.util.StringMaskingUtil;
import com.eactive.apim.portal.djb.community.qna.comment.service.CommunityAdminNotifier;
import com.eactive.apim.portal.djb.swing.SwingNotifier;
import com.eactive.apim.portal.file.entity.FileInfo;
import com.eactive.apim.portal.file.exception.InvalidFileException;
import com.eactive.apim.portal.file.service.FileService;
@@ -40,7 +40,7 @@ public class InquiryFacadeImpl implements InquiryFacade {
private final InquiryService inquiryService;
private final InquiryMapper inquiryMapper;
private final CommunityAdminNotifier inquiryAdminNotifier;
private final SwingNotifier swingNotifier;
private final FileService fileService;
@Override
@@ -142,7 +142,7 @@ public class InquiryFacadeImpl implements InquiryFacade {
params.put("inquiryId", inquiry.getId());
params.put("inquirySubject", inquiry.getInquirySubject());
params.put("writerName", current.getUserName());
inquiryAdminNotifier.notifyPortalAdmins(MessageCode.INQUIRY_CREATED, params);
swingNotifier.notifyPortalAdmins(MessageCode.INQUIRY_CREATED, params);
}
@Override
@@ -2,12 +2,14 @@ package com.eactive.apim.portal.djb.apistatus.controller;
import com.eactive.apim.portal.common.util.SecurityUtil;
import com.eactive.apim.portal.djb.apistatus.dto.ActiveIncidentDTO;
import com.eactive.apim.portal.djb.apistatus.dto.ApiCurrentStatusDTO;
import com.eactive.apim.portal.djb.apistatus.dto.ApiOptionDTO;
import com.eactive.apim.portal.djb.apistatus.dto.DailyStatDTO;
import com.eactive.apim.portal.djb.apistatus.dto.IssueDateEntryDTO;
import com.eactive.apim.portal.djb.apistatus.dto.MaintenanceCardDTO;
import com.eactive.apim.portal.djb.apistatus.dto.MyApiStatusDTO;
import com.eactive.apim.portal.djb.apistatus.dto.PastIssueCardDTO;
import com.eactive.apim.portal.djb.apistatus.service.ApiCurrentStatusService;
import com.eactive.apim.portal.djb.apistatus.service.ApiStatusCatalogService;
import com.eactive.apim.portal.djb.apistatus.service.ApiStatusIssueHistoryService;
import com.eactive.apim.portal.djb.apistatus.service.ApiStatusQueryService;
@@ -30,6 +32,7 @@ import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.Collections;
import java.util.List;
@@ -49,20 +52,27 @@ public class ApiStatusController {
private static final int DEFAULT_RECENT_ISSUE_SIZE = 5;
private static final int MAX_PAGE_SIZE = 50;
/** 현재 상태 일괄 조회 시 한 번에 물어볼 수 있는 API 수 */
private static final int MAX_STATUS_BATCH = 100;
private final ApiStatusQueryService apiStatusQueryService;
private final ApiStatusUptimeService uptimeService;
private final ApiStatusIssueHistoryService issueHistoryService;
private final MyApiStatusQueryService myApiStatusQueryService;
private final ApiStatusCatalogService catalogService;
private final ApiCurrentStatusService apiCurrentStatusService;
/** P1 - API Status 메인 */
@GetMapping
public ModelAndView index() {
ModelAndView mav = new ModelAndView("djb/apistatus/index");
mav.addObject("windowDays", ApiStatusSupport.DEFAULT_WINDOW_DAYS);
mav.addObject("windowDays", catalogService.getWindowDays());
mav.addObject("authenticated", SecurityUtil.isAuthenticated());
mav.addObject("lastStatusUpdatedAt", catalogService.getLastStatusUpdatedAt());
LocalDateTime lastFireAt = catalogService.getLastMonitorFireAt();
mav.addObject("lastFireAt", lastFireAt);
mav.addObject("lastFireRelative",
ApiStatusSupport.relativeTime(lastFireAt, ApiStatusSupport.now()));
mav.addObject("lastStatusChangedAt", catalogService.getLastStatusChangedAt());
return mav;
}
@@ -78,11 +88,12 @@ public class ApiStatusController {
@RequestParam(value = "kind", required = false) String kind) {
LocalDate today = ApiStatusSupport.now().toLocalDate();
int windowDays = catalogService.getWindowDays();
ModelAndView mav = new ModelAndView("djb/apistatus/issues");
mav.addObject("windowDays", ApiStatusSupport.DEFAULT_WINDOW_DAYS);
mav.addObject("windowDays", windowDays);
mav.addObject("today", today);
mav.addObject("minDate", today.minusDays(ApiStatusSupport.DEFAULT_WINDOW_DAYS - 1L));
mav.addObject("minDate", today.minusDays(windowDays - 1L));
mav.addObject("selectedDate", date);
mav.addObject("selectedApiId", apiId);
mav.addObject("selectedKind", kind);
@@ -100,8 +111,8 @@ public class ApiStatusController {
@GetMapping("/uptime.json")
@ResponseBody
public List<DailyStatDTO> uptime(
@RequestParam(value = "days", defaultValue = "90") int days) {
return uptimeService.getDailyStats(days);
@RequestParam(value = "days", defaultValue = "0") int days) {
return uptimeService.getDailyStats(days > 0 ? days : catalogService.getWindowDays());
}
/** P3 - 진행 중 장애 */
@@ -149,10 +160,10 @@ public class ApiStatusController {
@GetMapping("/issues/dates.json")
@ResponseBody
public List<IssueDateEntryDTO> issueDates(
@RequestParam(value = "days", defaultValue = "90") int days,
@RequestParam(value = "days", defaultValue = "0") int days,
@RequestParam(value = "apiId", required = false) String apiId,
@RequestParam(value = "kind", required = false) String kind) {
return issueHistoryService.getIssueDates(days, apiId, kind);
return issueHistoryService.getIssueDates(days > 0 ? days : catalogService.getWindowDays(), apiId, kind);
}
/** P10 - 이슈 목록 (날짜/API/유형 필터) */
@@ -170,4 +181,31 @@ public class ApiStatusController {
int safeSize = size <= 0 ? 20 : Math.min(size, MAX_PAGE_SIZE);
return issueHistoryService.getIssues(date, apiId, kind, PageRequest.of(safePage, safeSize));
}
/**
* P11 - API 한 건의 현재 상태 (정상/점검/지연/장애). API 상세 화면이 사용한다.
*
* <p>게시된 장애·점검만 반영하므로 비로그인도 조회 가능하다.</p>
*/
@GetMapping("/current.json")
@ResponseBody
public ResponseEntity<ApiCurrentStatusDTO> currentStatus(@RequestParam("apiId") String apiId) {
return apiCurrentStatusService.getStatus(apiId)
.map(ResponseEntity::ok)
.orElseGet(() -> ResponseEntity.badRequest().build());
}
/**
* P11 - 여러 API 의 현재 상태. {@code ?apiId=A&apiId=B} 로 반복 지정한다.
*/
@GetMapping("/current-list.json")
@ResponseBody
public ResponseEntity<List<ApiCurrentStatusDTO>> currentStatuses(
@RequestParam(value = "apiId", required = false) List<String> apiIds) {
if (apiIds != null && apiIds.size() > MAX_STATUS_BATCH) {
return ResponseEntity.badRequest().build();
}
return ResponseEntity.ok(apiCurrentStatusService.getStatuses(apiIds));
}
}
@@ -0,0 +1,53 @@
package com.eactive.apim.portal.djb.apistatus.dto;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.time.LocalDateTime;
/**
* API 한 건의 현재 상태 (정상/점검/지연/장애).
*
* <p>게시된 장애·점검 공지(PTL_NOTICE + DJB_APISTATUS_INCIDENT)만 근거로 한다.
* 미게시(초안/USE_YN='N') 건은 다른 API Status 화면과 동일하게 보이지 않는다.</p>
*/
@Data
public class ApiCurrentStatusDTO {
private String apiId;
/** 공개 API 목록(PTL_API_SPEC_INFO, DISPLAY_YN='Y')에 없으면 null */
private String apiName;
/** NORMAL / DEGRADED / OUTAGE / MAINTENANCE */
private String currentStatus;
/** 정상 / 지연 / 장애 / 점검 */
private String currentStatusLabel;
/** 현재 상태의 근거가 된 이슈. 정상이면 null */
private Long activeIncidentId;
/** INCIDENT / MAINTENANCE */
private String activeIncidentKind;
private String activeIncidentTitle;
/** 현재 상태가 시작된 시각 (근거 이슈의 시작 시각) */
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime statusSince;
/** 점검 종료 예정 시각. 장애이거나 미정이면 null */
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime expectedEndAt;
/** 조회 기간 내 마지막 장애 발생 시각 */
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime lastIncidentAt;
/** 조회 기간 가동률 (0.0 ~ 1.0). 상태만 계산하는 경로에서는 채우지 않는다 */
private Double uptimeRatio;
/** 가동률·최근 장애 집계 기간(일) */
private int windowDays;
}
@@ -19,8 +19,12 @@ public class DailyStatDTO {
/** 0.0000 ~ 1.0000 */
private double uptimeRatio;
/** 장애 + 지연 합계 (가동률 차감분). 지연도 서비스 저하이므로 계속 차감한다 */
private long incidentMinutes;
/** 그 중 지연(자동 탐지) 분 */
private long delayMinutes;
private long maintenanceMinutes;
/** 막대 색상 구분: NORMAL / DEGRADED / OUTAGE / MAINTENANCE */
@@ -16,9 +16,14 @@ public class IssueDateEntryDTO {
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd")
private LocalDate date;
/** INCIDENT / MAINTENANCE */
/** INCIDENT / DELAY / MAINTENANCE - 유형 필터와 같은 값 */
private List<String> kinds = new ArrayList<>();
/** 장애 건수 (자동 탐지 지연 제외) */
private int incCount;
/** 지연 건수 (자동 탐지 지연 - INCIDENT 중 INTERFACE_ID 가 DELAY_START: 인 건) */
private int dlyCount;
private int mntCount;
}
@@ -15,31 +15,52 @@ import java.util.List;
import java.util.Optional;
/**
* 개발자포탈 API Status 화면 전용 조회. 읽기 전용이며 공개 조건(공지 게시 + 초안 아님)을 항상 적용한다.
* 개발자포탈 API Status 화면 전용 조회. 읽기 전용이며 공개 조건을 항상 적용한다.
*
* <p>PTL_NOTICE 와의 조인은 두 가지 역할을 한다.
* (1) 관리자가 미게시(USE_YN='N')한 장애/점검을 숨긴다.
* (2) 공지가 삭제된 고아 장애 행을 자연히 제외한다 (물리 FK 없음 - ADR-F10).</p>
* <p>공개 조건({@link #VISIBLE})은 두 갈래다.
* <ul>
* <li>공지가 붙은 이슈(장애·점검) - 그 공지가 게시(USE_YN='Y')되어 있어야 한다.
* 공지가 삭제된 고아 행도 이 조건에서 자연히 빠진다 (물리 FK 없음 - ADR-F10).</li>
* <li>공지가 없는 이슈(지연) - 자동 탐지 전용이라 검수할 공지가 없다.
* 초안(DRAFT_YN='Y')만 아니면 노출한다.</li>
* </ul>
*
* <p>공지 조건을 EXISTS 로 쓰는 이유: 예전처럼 {@code FROM ... , PortalNotice n} 으로 조인하면
* NOTICE_ID 가 없는 지연 이슈가 행 자체에서 사라진다.</p>
*/
public interface ApiStatusIncidentQueryRepository extends Repository<DjbApistatusIncident, Long> {
String VISIBLE = " i.noticeId = n.id AND n.useYn = 'Y' AND i.draftYn = 'N' ";
String VISIBLE = " i.draftYn = 'N'"
+ " AND (i.noticeId IS NULL"
+ " OR EXISTS (SELECT 1 FROM PortalNotice n"
+ " WHERE n.id = i.noticeId AND n.useYn = 'Y')) ";
/** 종결 판정이 STATE 로 이뤄지는 종류 (장애·지연). JPQL 리터럴로 써야 해서 FQCN 을 쓴다 */
String KIND_INCIDENT = "com.eactive.apim.portal.djb.apistatus.incident.entity.IncidentKind.INCIDENT";
String KIND_DELAY = "com.eactive.apim.portal.djb.apistatus.incident.entity.IncidentKind.DELAY";
String KIND_MAINTENANCE = "com.eactive.apim.portal.djb.apistatus.incident.entity.IncidentKind.MAINTENANCE";
/** 종결 조건 - 장애·지연은 STATE 로, 점검은 종료 시각 경과로 판정한다 */
String CLOSED_CONDITION = " ((i.kind IN (" + KIND_INCIDENT + ", " + KIND_DELAY + ")"
+ " AND i.state IN :closedStates)"
+ " OR (i.kind = " + KIND_MAINTENANCE
+ " AND i.endAt IS NOT NULL AND i.endAt < :now)) ";
/**
* 진행 중 장애 (P3)
* 진행 중 이슈 (P3). 장애와 지연을 함께 본다.
*/
@Query("SELECT i FROM DjbApistatusIncident i, PortalNotice n"
@Query("SELECT i FROM DjbApistatusIncident i"
+ " WHERE " + VISIBLE
+ " AND i.kind = :kind"
+ " AND i.kind IN :kinds"
+ " AND i.state NOT IN :closedStates"
+ " ORDER BY i.startedAt DESC")
List<DjbApistatusIncident> findVisibleOpenIncidents(@Param("kind") IncidentKind kind,
List<DjbApistatusIncident> findVisibleOpenIncidents(@Param("kinds") Collection<IncidentKind> kinds,
@Param("closedStates") Collection<IncidentState> closedStates);
/**
* 예정/진행 중 점검 (P5). 종료 시각이 없거나 아직 지나지 않은 점검.
*/
@Query("SELECT i FROM DjbApistatusIncident i, PortalNotice n"
@Query("SELECT i FROM DjbApistatusIncident i"
+ " WHERE " + VISIBLE
+ " AND i.kind = :kind"
+ " AND (i.endAt IS NULL OR i.endAt >= :now)"
@@ -48,21 +69,15 @@ public interface ApiStatusIncidentQueryRepository extends Repository<DjbApistatu
@Param("now") LocalDateTime now);
/**
* 종결된 이슈 (P6). 장애 종결 상태, 점검은 종료 시각 경과.
* 종결된 이슈 (P6). 장애·지연은 종결 상태, 점검은 종료 시각 경과.
*/
@Query(value = "SELECT i FROM DjbApistatusIncident i, PortalNotice n"
@Query(value = "SELECT i FROM DjbApistatusIncident i"
+ " WHERE " + VISIBLE
+ " AND ((i.kind = com.eactive.apim.portal.djb.apistatus.incident.entity.IncidentKind.INCIDENT"
+ " AND i.state IN :closedStates)"
+ " OR (i.kind = com.eactive.apim.portal.djb.apistatus.incident.entity.IncidentKind.MAINTENANCE"
+ " AND i.endAt IS NOT NULL AND i.endAt < :now))"
+ " AND " + CLOSED_CONDITION
+ " ORDER BY i.startedAt DESC",
countQuery = "SELECT COUNT(i) FROM DjbApistatusIncident i, PortalNotice n"
countQuery = "SELECT COUNT(i) FROM DjbApistatusIncident i"
+ " WHERE " + VISIBLE
+ " AND ((i.kind = com.eactive.apim.portal.djb.apistatus.incident.entity.IncidentKind.INCIDENT"
+ " AND i.state IN :closedStates)"
+ " OR (i.kind = com.eactive.apim.portal.djb.apistatus.incident.entity.IncidentKind.MAINTENANCE"
+ " AND i.endAt IS NOT NULL AND i.endAt < :now))")
+ " AND " + CLOSED_CONDITION)
Page<DjbApistatusIncident> findVisibleClosedIssues(@Param("closedStates") Collection<IncidentState> closedStates,
@Param("now") LocalDateTime now,
Pageable pageable);
@@ -71,7 +86,7 @@ public interface ApiStatusIncidentQueryRepository extends Repository<DjbApistatu
* 기간과 겹치는 모든 이슈 (P2 가동률 집계, P9 일자 인덱스, P10 목록).
* 진행 중(END_AT IS NULL) 이슈도 포함한다.
*/
@Query("SELECT i FROM DjbApistatusIncident i, PortalNotice n"
@Query("SELECT i FROM DjbApistatusIncident i"
+ " WHERE " + VISIBLE
+ " AND i.startedAt < :to"
+ " AND (i.endAt IS NULL OR i.endAt >= :from)"
@@ -82,7 +97,7 @@ public interface ApiStatusIncidentQueryRepository extends Repository<DjbApistatu
/**
* 기간과 겹치고 특정 API 에 영향을 준 이슈 (P9/P10 의 apiId 필터).
*/
@Query("SELECT DISTINCT i FROM DjbApistatusIncident i, PortalNotice n, DjbApistatusIncidentApi a"
@Query("SELECT DISTINCT i FROM DjbApistatusIncident i, DjbApistatusIncidentApi a"
+ " WHERE " + VISIBLE
+ " AND a.incidentId = i.incidentId"
+ " AND a.apiId = :apiId"
@@ -96,7 +111,7 @@ public interface ApiStatusIncidentQueryRepository extends Repository<DjbApistatu
/**
* 공개 상세 (P7)
*/
@Query("SELECT i FROM DjbApistatusIncident i, PortalNotice n"
@Query("SELECT i FROM DjbApistatusIncident i"
+ " WHERE " + VISIBLE
+ " AND i.incidentId = :incidentId")
Optional<DjbApistatusIncident> findVisibleById(@Param("incidentId") Long incidentId);
@@ -0,0 +1,274 @@
package com.eactive.apim.portal.djb.apistatus.service;
import com.eactive.apim.portal.apispec.entity.ApiSpecInfo;
import com.eactive.apim.portal.apispec.repository.ApiSpecInfoRepository;
import com.eactive.apim.portal.djb.apistatus.dto.ApiCurrentStatusDTO;
import com.eactive.apim.portal.djb.apistatus.incident.entity.DjbApistatusIncident;
import com.eactive.apim.portal.djb.apistatus.incident.entity.DjbApistatusIncidentApi;
import com.eactive.apim.portal.djb.apistatus.incident.entity.IncidentKind;
import com.eactive.apim.portal.djb.apistatus.incident.entity.IncidentState;
import com.eactive.apim.portal.djb.apistatus.incident.repository.DjbApistatusIncidentApiRepository;
import com.eactive.apim.portal.djb.apistatus.repository.ApiStatusIncidentQueryRepository;
import lombok.RequiredArgsConstructor;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
/**
* API 별 현재 상태(정상/점검/지연/장애) 조회.
*
* <p>"내 API 현황"(P4)과 API 상세 화면이 이 서비스를 공유해 판정 기준을 하나로 유지한다.
* 근거는 <b>게시된</b> 장애·점검 공지뿐이며(PTL_NOTICE.USE_YN='Y' + DRAFT_YN='N'),
* 미게시 건은 다른 API Status 화면과 마찬가지로 반영하지 않는다.</p>
*
* <p>판정 규칙 (심각한 쪽 우선)
* <ul>
* <li>진행 중 장애 → 장애(OUTAGE). 단 모니터링 상태이거나 자동 탐지 지연 건이면 지연(DEGRADED)</li>
* <li>이미 시작된 점검 → 점검(MAINTENANCE)</li>
* <li>해당 없음 → 정상(NORMAL)</li>
* </ul>
*/
@Service
@RequiredArgsConstructor
@Transactional(readOnly = true)
public class ApiCurrentStatusService {
private final ApiStatusIncidentQueryRepository incidentQueryRepository;
private final DjbApistatusIncidentApiRepository incidentApiRepository;
private final ApiSpecInfoRepository apiSpecInfoRepository;
private final ApiStatusUptimeService uptimeService;
private final ApiStatusCatalogService catalogService;
/** API 한 건의 현재 상태. apiId 가 비어 있으면 empty */
public Optional<ApiCurrentStatusDTO> getStatus(String apiId) {
if (StringUtils.isBlank(apiId)) {
return Optional.empty();
}
return getStatuses(Collections.singletonList(apiId)).stream().findFirst();
}
/**
* 여러 API 의 현재 상태 (API 명·가동률 포함). 요청 순서를 유지하며 중복 apiId 는 한 번만 반환한다.
*/
public List<ApiCurrentStatusDTO> getStatuses(Collection<String> apiIds) {
Set<String> ids = normalize(apiIds);
if (ids.isEmpty()) {
return Collections.emptyList();
}
Map<String, ApiCurrentStatusDTO> statuses = resolveStatuses(ids);
Map<String, String> names = resolveApiNames(ids);
Map<String, Double> uptimes = uptimeService.getApiUptimeRatios(ids, catalogService.getWindowDays());
List<ApiCurrentStatusDTO> result = new ArrayList<>(ids.size());
for (String apiId : ids) {
ApiCurrentStatusDTO dto = statuses.get(apiId);
dto.setApiName(names.get(apiId));
dto.setUptimeRatio(uptimes.getOrDefault(apiId, 1.0d));
result.add(dto);
}
return result;
}
/**
* 상태만 계산한다 (API 명·가동률 제외). 대상 API 를 이미 알고 있고 이름·가동률을
* 따로 채우는 호출자(P4 내 API 현황)를 위한 경량 경로다.
*/
public Map<String, ApiCurrentStatusDTO> resolveStatuses(Set<String> apiIds) {
if (apiIds == null || apiIds.isEmpty()) {
return Collections.emptyMap();
}
LocalDateTime now = ApiStatusSupport.now();
int windowDays = catalogService.getWindowDays();
Map<String, DjbApistatusIncident> openByApi = mapOpenIncidents(apiIds);
Map<String, DjbApistatusIncident> maintenanceByApi = mapStartedMaintenance(apiIds, now);
Map<String, LocalDateTime> lastIncidentAt = collectLastIncidentAt(apiIds, now, windowDays);
Map<String, ApiCurrentStatusDTO> result = new LinkedHashMap<>();
for (String apiId : apiIds) {
DjbApistatusIncident open = openByApi.get(apiId);
DjbApistatusIncident maintenance = maintenanceByApi.get(apiId);
ApiCurrentStatusDTO dto = new ApiCurrentStatusDTO();
dto.setApiId(apiId);
dto.setCurrentStatus(resolveStatus(open, maintenance != null));
dto.setCurrentStatusLabel(ApiStatusSupport.statusLabel(dto.getCurrentStatus()));
dto.setLastIncidentAt(lastIncidentAt.get(apiId));
dto.setWindowDays(windowDays);
// 장애가 점검보다 심각하므로 근거 이슈도 장애를 우선한다
DjbApistatusIncident active = open != null ? open : maintenance;
if (active != null) {
dto.setActiveIncidentId(active.getIncidentId());
dto.setActiveIncidentKind(active.getKind() == null ? null : active.getKind().name());
dto.setActiveIncidentTitle(active.getTitle());
dto.setStatusSince(active.getStartedAt());
dto.setExpectedEndAt(active.getEndAt());
}
result.put(apiId, dto);
}
return result;
}
/** 빈 값·중복 제거. 요청 순서는 유지한다 */
private Set<String> normalize(Collection<String> apiIds) {
if (apiIds == null || apiIds.isEmpty()) {
return Collections.emptySet();
}
return apiIds.stream()
.filter(StringUtils::isNotBlank)
.map(StringUtils::trim)
.collect(Collectors.toCollection(LinkedHashSet::new));
}
/**
* API 명은 공개 목록(DISPLAY_YN='Y')에서만 가져온다. 비공개 API 의 이름이 새어나가지 않게 한다.
*/
private Map<String, String> resolveApiNames(Set<String> apiIds) {
List<ApiSpecInfo> specs =
apiSpecInfoRepository.findAllByDisplayYnAndApiIdIn("Y", new ArrayList<>(apiIds));
Map<String, String> names = new HashMap<>();
for (ApiSpecInfo spec : specs) {
names.put(spec.getApiId(), StringUtils.defaultIfBlank(spec.getApiName(), spec.getApiId()));
}
return names;
}
/** 진행 중(미종결) 장애·지연 중 API 별로 가장 심각한 한 건 */
private Map<String, DjbApistatusIncident> mapOpenIncidents(Set<String> apiIds) {
List<DjbApistatusIncident> openIncidents = incidentQueryRepository
.findVisibleOpenIncidents(IncidentKind.DEGRADING, ApiStatusSupport.CLOSED_STATES);
if (openIncidents.isEmpty()) {
return Collections.emptyMap();
}
Map<Long, DjbApistatusIncident> byId = openIncidents.stream()
.collect(Collectors.toMap(DjbApistatusIncident::getIncidentId, incident -> incident));
Map<String, DjbApistatusIncident> byApi = new HashMap<>();
for (DjbApistatusIncidentApi api :
incidentApiRepository.findByIncidentIdInOrderByIncidentIdAscApiIdAsc(byId.keySet())) {
if (!apiIds.contains(api.getApiId()) || api.getRecoveredAt() != null) {
continue;
}
DjbApistatusIncident incident = byId.get(api.getIncidentId());
DjbApistatusIncident previous = byApi.get(api.getApiId());
// 같은 API 에 여러 장애가 열려 있으면 더 심각한(장애 > 지연, 조사중 > 모니터링) 쪽을 우선한다
if (previous == null || severity(incident) < severity(previous)) {
byApi.put(api.getApiId(), incident);
}
}
return byApi;
}
/** 이미 시작된 점검 중 API 별로 가장 먼저 시작된 한 건 (예정 점검은 현재 상태가 아니므로 제외) */
private Map<String, DjbApistatusIncident> mapStartedMaintenance(Set<String> apiIds, LocalDateTime now) {
List<DjbApistatusIncident> maintenances = incidentQueryRepository
.findVisibleOngoingMaintenance(IncidentKind.MAINTENANCE, now).stream()
.filter(incident -> incident.getStartedAt() != null && !incident.getStartedAt().isAfter(now))
.collect(Collectors.toList());
if (maintenances.isEmpty()) {
return Collections.emptyMap();
}
Map<Long, DjbApistatusIncident> byId = maintenances.stream()
.collect(Collectors.toMap(DjbApistatusIncident::getIncidentId, incident -> incident));
Map<String, DjbApistatusIncident> byApi = new HashMap<>();
for (DjbApistatusIncidentApi api :
incidentApiRepository.findByIncidentIdInOrderByIncidentIdAscApiIdAsc(byId.keySet())) {
if (!apiIds.contains(api.getApiId())) {
continue;
}
DjbApistatusIncident incident = byId.get(api.getIncidentId());
DjbApistatusIncident previous = byApi.get(api.getApiId());
if (previous == null
|| (incident.getStartedAt() != null && previous.getStartedAt() != null
&& incident.getStartedAt().isBefore(previous.getStartedAt()))) {
byApi.put(api.getApiId(), incident);
}
}
return byApi;
}
/** 조회 기간 내 마지막 장애·지연 발생 시각 */
private Map<String, LocalDateTime> collectLastIncidentAt(Set<String> apiIds, LocalDateTime now, int windowDays) {
LocalDateTime windowStart = now.toLocalDate().minusDays(windowDays - 1L).atStartOfDay();
List<DjbApistatusIncident> incidents = incidentQueryRepository
.findVisibleOverlapping(windowStart, now.toLocalDate().plusDays(1).atStartOfDay()).stream()
.filter(incident -> incident.getKind() != null && incident.getKind().isDegrading())
.collect(Collectors.toList());
if (incidents.isEmpty()) {
return Collections.emptyMap();
}
Map<Long, DjbApistatusIncident> byId = incidents.stream()
.collect(Collectors.toMap(DjbApistatusIncident::getIncidentId, incident -> incident));
Map<String, LocalDateTime> result = new HashMap<>();
for (DjbApistatusIncidentApi api :
incidentApiRepository.findByIncidentIdInOrderByIncidentIdAscApiIdAsc(byId.keySet())) {
if (!apiIds.contains(api.getApiId())) {
continue;
}
LocalDateTime startedAt = byId.get(api.getIncidentId()).getStartedAt();
LocalDateTime previous = result.get(api.getApiId());
if (startedAt != null && (previous == null || startedAt.isAfter(previous))) {
result.put(api.getApiId(), startedAt);
}
}
return result;
}
/**
* 진행 중 장애·지연 + 점검 여부로 현재 상태를 정한다.
*
* <p>KIND 가 DELAY 면 지연이다. 장애(INCIDENT)라도 모니터링 단계면 이미 완화된 상태라
* 지연으로 표기한다 - 이슈 이력의 유형 필터(KIND 기준)와는 이 지점만 다르다.</p>
*/
private String resolveStatus(DjbApistatusIncident open, boolean underMaintenance) {
if (open != null) {
boolean degraded = open.getKind() == IncidentKind.DELAY
|| open.getState() == IncidentState.MONITORING;
return degraded ? ApiStatusSupport.STATUS_DEGRADED : ApiStatusSupport.STATUS_OUTAGE;
}
if (underMaintenance) {
return ApiStatusSupport.STATUS_MAINTENANCE;
}
return ApiStatusSupport.STATUS_NORMAL;
}
/**
* 같은 API 에 열린 이슈가 여럿일 때의 우선순위 (낮을수록 심각).
* 지연은 장애보다 뒤로 민다.
*/
private int severity(DjbApistatusIncident incident) {
if (incident == null) {
return 99;
}
int base = incident.getKind() == IncidentKind.DELAY ? 10 : 0;
IncidentState state = incident.getState();
if (state == null) {
return base + 9;
}
switch (state) {
case INVESTIGATING: return base;
case IDENTIFIED: return base + 1;
// 모니터링 단계는 지연으로 표기되므로 같은 장애라도 뒤로 민다
case MONITORING: return base + 12;
default: return base + 8;
}
}
}
@@ -125,7 +125,7 @@ public class ApiStatusAssembler {
}
/**
* 지난 이슈 카드. 장애 타임라인 전체를 붙이고 점검은 붙이지 않는다 (ADR-F15).
* 지난 이슈 카드. 장애·지연은 타임라인 전체를 붙이고 점검은 붙이지 않는다 (ADR-F15).
*/
public List<PastIssueCardDTO> toPastIssueCards(List<DjbApistatusIncident> incidents) {
if (incidents.isEmpty()) {
@@ -135,7 +135,7 @@ public class ApiStatusAssembler {
Map<Long, List<AffectedApiDTO>> apis = loadApis(ids);
List<Long> incidentKindIds = incidents.stream()
.filter(incident -> incident.getKind() == IncidentKind.INCIDENT)
.filter(incident -> incident.getKind() != null && incident.getKind().isDegrading())
.map(DjbApistatusIncident::getIncidentId)
.collect(Collectors.toList());
Map<Long, List<TimelineEntryDTO>> timelines = loadTimelines(incidentKindIds);
@@ -5,12 +5,16 @@ import com.eactive.apim.portal.apps.apis.dto.ApiSpecInfoDto;
import com.eactive.apim.portal.apps.apis.service.ApiSearchFacade;
import com.eactive.apim.portal.apps.apiservice.dto.ApiGroupSearch;
import com.eactive.apim.portal.djb.apistatus.dto.ApiOptionDTO;
import com.eactive.apim.portal.portalproperty.service.PortalPropertyService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import java.time.Instant;
import java.time.LocalDateTime;
import java.util.Collections;
import java.util.Comparator;
@@ -18,7 +22,7 @@ import java.util.List;
import java.util.stream.Collectors;
/**
* API Status 화면의 부가 조회 - 필터용 API 목록, 탐지 결과 갱신 시각.
* API Status 화면의 부가 조회 - 필터용 API 목록, 상태 모니터링 최근 실행 시각.
*/
@Slf4j
@Service
@@ -26,9 +30,32 @@ import java.util.stream.Collectors;
@Transactional(readOnly = true)
public class ApiStatusCatalogService {
public static final String PROPERTY_GROUP = "Portal";
/** API 상태 모니터링 Quartz Job 이름 (eapim-admin QRTZ_JOB_DETAILS.JOB_NAME) */
public static final String KEY_MONITOR_JOB_NAME = "djb.apistatus.monitor.job-name";
/** 실서버(DAPM) QRTZ_JOB_DETAILS 실사값 (2026-07-31) */
private static final String DEFAULT_MONITOR_JOB_NAME = "ApiStatusMonitorJob";
/** 상태/이력 조회 기간(일). 가동률 바·이슈 인덱스·date picker 범위가 모두 이 값을 따른다 */
public static final String KEY_WINDOW_DAYS = "djb.apistatus.window-days";
/** OPEN API 목록 카드의 현재 상태 태그 노출 여부 (true/false) */
public static final String KEY_API_LIST_STATUS_BADGE = "djb.apistatus.api-list-status-badge";
private static final boolean DEFAULT_API_LIST_STATUS_BADGE = true;
private static final int MIN_WINDOW_DAYS = 1;
private static final int MAX_WINDOW_DAYS = 365;
private final ApiSearchFacade apiSearchFacade;
private final PortalPropertyService portalPropertyService;
private final GwApiStatusRepository gwApiStatusRepository;
@PersistenceContext
private EntityManager entityManager;
/**
* 이슈 이력 필터용 API 목록.
*
@@ -54,15 +81,98 @@ public class ApiStatusCatalogService {
}
/**
* 탐지 결과(AGWAPP.API_STATUS)가 마지막으로 갱신된 시각.
* 상태 변화가 있을 때만 갱신되므로 "마지막 상태 변경 시각" 이다.
* API 상태 모니터링 Job(eapim-admin Quartz)의 마지막 실행 시각.
*
* <p>Job 이름은 PTL_PROPERTY({@code Portal} / {@code djb.apistatus.monitor.job-name})로
* 바꿀 수 있으며, 최초 접근 시 기본값으로 row 가 자동 생성된다.
* Quartz 메타(QRTZ_TRIGGERS)는 EMSAPP 스키마라 EMS EntityManager 로 직접 읽는다.</p>
*
* <p>readOnly 를 풀어야 최초 접근 시 프로퍼티 row 자동 생성(INSERT)이 가능하다.</p>
*/
public LocalDateTime getLastStatusUpdatedAt() {
@Transactional
public LocalDateTime getLastMonitorFireAt() {
try {
String jobName = portalPropertyService.getOrCreateProperty(
PROPERTY_GROUP, KEY_MONITOR_JOB_NAME, DEFAULT_MONITOR_JOB_NAME,
"API 상태 모니터링 Quartz Job 이름 (eapim-admin QRTZ_JOB_DETAILS.JOB_NAME)");
if (StringUtils.isBlank(jobName)) {
jobName = DEFAULT_MONITOR_JOB_NAME;
}
Object fireTime = entityManager.createNativeQuery(
"SELECT MAX(PREV_FIRE_TIME) FROM QRTZ_TRIGGERS WHERE JOB_NAME = :jobName")
.setParameter("jobName", jobName)
.getSingleResult();
if (!(fireTime instanceof Number)) {
return null;
}
long epochMillis = ((Number) fireTime).longValue();
if (epochMillis <= 0) {
return null;
}
return LocalDateTime.ofInstant(Instant.ofEpochMilli(epochMillis), ApiStatusSupport.ZONE);
} catch (Exception e) {
// 스케줄 메타 조회 실패가 화면 전체를 막지 않도록 한다
log.warn("API 상태 모니터링 실행 시각 조회 실패", e);
return null;
}
}
/**
* 상태/이력 조회 기간(일). PTL_PROPERTY({@code Portal} / {@code djb.apistatus.window-days})로
* 조절하며 1~365 로 clamp 한다. 값이 이상하면 기본 90일.
*/
@Transactional
public int getWindowDays() {
try {
String value = portalPropertyService.getOrCreateProperty(
PROPERTY_GROUP, KEY_WINDOW_DAYS,
String.valueOf(ApiStatusSupport.DEFAULT_WINDOW_DAYS),
"API Status 조회 기간(일). 가동률 바·이슈 인덱스·날짜 선택 범위에 적용 (1~365)");
int days = Integer.parseInt(StringUtils.trimToEmpty(value));
return Math.max(MIN_WINDOW_DAYS, Math.min(MAX_WINDOW_DAYS, days));
} catch (Exception e) {
log.warn("조회 기간 프로퍼티 해석 실패 - 기본값 {}일 사용", ApiStatusSupport.DEFAULT_WINDOW_DAYS, e);
return ApiStatusSupport.DEFAULT_WINDOW_DAYS;
}
}
/**
* OPEN API 목록(/apis) 카드에 현재 상태 태그를 노출할지 여부.
* PTL_PROPERTY({@code Portal} / {@code djb.apistatus.api-list-status-badge}) 로 켜고 끈다.
*
* <p>{@code true/Y/1} 이면 노출, {@code false/N/0} 이면 숨김. 값이 비었거나 이상하면 기본 노출.</p>
*/
@Transactional
public boolean isApiListStatusBadgeEnabled() {
try {
String value = portalPropertyService.getOrCreateProperty(
PROPERTY_GROUP, KEY_API_LIST_STATUS_BADGE,
String.valueOf(DEFAULT_API_LIST_STATUS_BADGE),
"OPEN API 목록 카드에 현재 상태(정상/점검/지연/장애) 태그 노출 여부 (true/false)");
String normalized = StringUtils.trimToEmpty(value);
if (StringUtils.equalsAnyIgnoreCase(normalized, "false", "n", "0")) {
return false;
}
if (StringUtils.equalsAnyIgnoreCase(normalized, "true", "y", "1")) {
return true;
}
return DEFAULT_API_LIST_STATUS_BADGE;
} catch (Exception e) {
log.warn("API 목록 상태 태그 노출 프로퍼티 조회 실패 - 기본값 {} 사용", DEFAULT_API_LIST_STATUS_BADGE, e);
return DEFAULT_API_LIST_STATUS_BADGE;
}
}
/**
* API 상태가 마지막으로 <b>변경</b>된 시각 (AGWAPP.API_STATUS 최근 upsert).
* 실행 시각(fire)과 달리 상태 변화가 있을 때만 갱신된다.
*/
public LocalDateTime getLastStatusChangedAt() {
try {
return gwApiStatusRepository.findLastModifiedDate().orElse(null);
} catch (Exception e) {
// 게이트웨이 조회 실패가 화면 전체를 막지 않도록 한다
log.warn("API 상태 갱신 시각 조회 실패", e);
log.warn("API 상태 변경 시각 조회 실패", e);
return null;
}
}
@@ -32,6 +32,7 @@ public class ApiStatusIssueHistoryService {
private final ApiStatusIncidentQueryRepository incidentQueryRepository;
private final ApiStatusAssembler assembler;
private final ApiStatusCatalogService catalogService;
/**
* P9 - 90일 인덱스바용 일자별 이슈 집계. 이슈가 여러 날에 걸치면 걸친 날짜 모두에 집계한다.
@@ -68,17 +69,7 @@ public class ApiStatusIssueHistoryService {
while (!cursor.isAfter(last)) {
IssueDateEntryDTO entry = byDate.get(cursor);
if (entry != null) {
if (incident.getKind() == IncidentKind.MAINTENANCE) {
entry.setMntCount(entry.getMntCount() + 1);
if (!entry.getKinds().contains(IncidentKind.MAINTENANCE.name())) {
entry.getKinds().add(IncidentKind.MAINTENANCE.name());
}
} else {
entry.setIncCount(entry.getIncCount() + 1);
if (!entry.getKinds().contains(IncidentKind.INCIDENT.name())) {
entry.getKinds().add(IncidentKind.INCIDENT.name());
}
}
tally(entry, incident);
}
cursor = cursor.plusDays(1);
}
@@ -87,6 +78,24 @@ public class ApiStatusIssueHistoryService {
return new ArrayList<>(byDate.values());
}
/**
* 인덱스바 1칸에 이슈 1건을 집계한다. 유형은 이슈 목록 필터와 같은 세 축(장애/지연/점검)으로 가른다.
*/
private void tally(IssueDateEntryDTO entry, DjbApistatusIncident incident) {
IncidentKind kind = incident.getKind();
if (kind == null) {
return;
}
switch (kind) {
case MAINTENANCE: entry.setMntCount(entry.getMntCount() + 1); break;
case DELAY: entry.setDlyCount(entry.getDlyCount() + 1); break;
default: entry.setIncCount(entry.getIncCount() + 1); break;
}
if (!entry.getKinds().contains(kind.name())) {
entry.getKinds().add(kind.name());
}
}
/**
* P10 - 날짜/API/유형 필터 이슈 목록. 날짜 미지정 시 90일 전체.
*/
@@ -97,7 +106,7 @@ public class ApiStatusIssueHistoryService {
if (date == null) {
LocalDate today = now.toLocalDate();
from = today.minusDays(ApiStatusSupport.DEFAULT_WINDOW_DAYS - 1L).atStartOfDay();
from = today.minusDays(catalogService.getWindowDays() - 1L).atStartOfDay();
to = today.plusDays(1).atStartOfDay();
} else {
from = date.atStartOfDay();
@@ -125,24 +134,24 @@ public class ApiStatusIssueHistoryService {
? incidentQueryRepository.findVisibleOverlapping(from, to)
: incidentQueryRepository.findVisibleOverlappingByApi(from, to, apiId);
IncidentKind selected = parseKind(kind);
if (selected == null) {
java.util.function.Predicate<DjbApistatusIncident> filter = kindFilter(kind);
if (filter == null) {
return incidents;
}
return incidents.stream()
.filter(incident -> incident.getKind() == selected)
.collect(Collectors.toList());
return incidents.stream().filter(filter).collect(Collectors.toList());
}
/**
* 유형 필터. 미지정/ALL/알 수 없는 값은 전체(null)로 본다.
* 필터 값은 {@link IncidentKind} 이름 그대로다 (INCIDENT / DELAY / MAINTENANCE).
*/
private IncidentKind parseKind(String kind) {
private java.util.function.Predicate<DjbApistatusIncident> kindFilter(String kind) {
if (StringUtils.isBlank(kind) || "ALL".equalsIgnoreCase(kind)) {
return null;
}
try {
return IncidentKind.valueOf(kind.toUpperCase());
IncidentKind selected = IncidentKind.valueOf(kind.trim().toUpperCase());
return incident -> incident.getKind() == selected;
} catch (IllegalArgumentException e) {
return null;
}
@@ -26,11 +26,11 @@ public class ApiStatusQueryService {
private final ApiStatusIncidentQueryRepository incidentQueryRepository;
private final ApiStatusAssembler assembler;
/** P3 - 진행 중 장애 */
/** P3 - 진행 중 장애·지연 */
public List<ActiveIncidentDTO> getActiveIncidents() {
LocalDateTime now = ApiStatusSupport.now();
List<DjbApistatusIncident> incidents = incidentQueryRepository
.findVisibleOpenIncidents(IncidentKind.INCIDENT, ApiStatusSupport.CLOSED_STATES);
.findVisibleOpenIncidents(IncidentKind.DEGRADING, ApiStatusSupport.CLOSED_STATES);
return assembler.toActiveIncidents(incidents, now);
}
@@ -1,5 +1,7 @@
package com.eactive.apim.portal.djb.apistatus.service;
import com.eactive.apim.portal.djb.apistatus.incident.entity.DjbApistatusIncident;
import com.eactive.apim.portal.djb.apistatus.incident.entity.IncidentKind;
import com.eactive.apim.portal.djb.apistatus.incident.entity.IncidentState;
import java.time.Duration;
@@ -36,6 +38,39 @@ public final class ApiStatusSupport {
return LocalDateTime.now(ZONE);
}
/** 지연 건인지 여부 (장애와 구분) */
public static boolean isDelay(DjbApistatusIncident incident) {
return incident != null && incident.getKind() == IncidentKind.DELAY;
}
/** 이슈 종류에 대응하는 현재 상태 코드 */
public static String statusOf(IncidentKind kind) {
if (kind == null) {
return STATUS_NORMAL;
}
switch (kind) {
case INCIDENT: return STATUS_OUTAGE;
case DELAY: return STATUS_DEGRADED;
case MAINTENANCE: return STATUS_MAINTENANCE;
default: return STATUS_NORMAL;
}
}
/**
* 상태 심각도 순위 (낮을수록 심각). 정렬·상태 병합에 함께 쓴다.
*/
public static int statusRank(String status) {
if (status == null) {
return 9;
}
switch (status) {
case STATUS_OUTAGE: return 0;
case STATUS_MAINTENANCE: return 1;
case STATUS_DEGRADED: return 2;
default: return 3;
}
}
public static String stateLabel(IncidentState state) {
if (state == null) {
return null;
@@ -72,4 +107,26 @@ public final class ApiStatusSupport {
}
return Duration.between(from, to).toMinutes();
}
/**
* "N분 전" 형태의 상대 시간 표기.
*/
public static String relativeTime(LocalDateTime past, LocalDateTime now) {
if (past == null || now == null) {
return null;
}
long minutes = Duration.between(past, now).toMinutes();
if (minutes < 1) {
return "방금 전";
}
if (minutes < 60) {
return minutes + "분 전";
}
long hours = minutes / 60;
if (hours < 24) {
long restMinutes = minutes % 60;
return restMinutes == 0 ? hours + "시간 전" : hours + "시간 " + restMinutes + "분 전";
}
return (hours / 24) + "일 전";
}
}
@@ -64,9 +64,10 @@ public class ApiStatusUptimeService {
LocalDateTime now = ApiStatusSupport.now();
LocalDateTime windowStart = now.toLocalDate().minusDays(windowDays - 1L).atStartOfDay();
// 장애와 지연 모두 서비스 저하이므로 가동률에서 차감한다. 점검은 계획된 작업이라 제외.
List<DjbApistatusIncident> incidents = incidentQueryRepository
.findVisibleOverlapping(windowStart, now.toLocalDate().plusDays(1).atStartOfDay()).stream()
.filter(incident -> incident.getKind() == IncidentKind.INCIDENT)
.filter(incident -> incident.getKind() != null && incident.getKind().isDegrading())
.collect(Collectors.toList());
Map<String, List<long[]>> intervalsByApi = new HashMap<>();
@@ -116,7 +117,11 @@ public class ApiStatusUptimeService {
return dto;
}
// 가동률은 장애+지연을 합쳐 차감하므로 합집합 계산용 리스트를 따로 둔다.
// (장애와 지연을 나눠 union 한 뒤 더하면 겹치는 구간이 이중 차감된다)
List<long[]> incidentIntervals = new ArrayList<>();
List<long[]> outageIntervals = new ArrayList<>();
List<long[]> delayIntervals = new ArrayList<>();
List<long[]> maintenanceIntervals = new ArrayList<>();
Set<Long> seen = new HashSet<>();
@@ -131,6 +136,11 @@ public class ApiStatusUptimeService {
maintenanceIntervals.add(interval);
} else {
incidentIntervals.add(interval);
if (incident.getKind() == IncidentKind.DELAY) {
delayIntervals.add(interval);
} else {
outageIntervals.add(interval);
}
}
if (seen.add(incident.getIncidentId())) {
dto.getIssues().add(new DailyStatDTO.IssueRefDTO(incident.getIncidentId(),
@@ -141,18 +151,24 @@ public class ApiStatusUptimeService {
long dayMinutes = Math.max(1L, ApiStatusSupport.minutesBetween(dayStart, dayEnd));
long incidentMinutes = unionMinutes(incidentIntervals);
long outageMinutes = unionMinutes(outageIntervals);
long delayMinutes = unionMinutes(delayIntervals);
long maintenanceMinutes = unionMinutes(maintenanceIntervals);
dto.setIncidentMinutes(incidentMinutes);
dto.setDelayMinutes(delayMinutes);
dto.setMaintenanceMinutes(maintenanceMinutes);
long downMinutes = Math.min(dayMinutes, incidentMinutes + maintenanceMinutes);
dto.setUptimeRatio(round4((double) (dayMinutes - downMinutes) / dayMinutes));
if (incidentMinutes > 0) {
// 색상은 심각한 순으로 하나만 고른다 (장애 > 점검 > 지연)
if (outageMinutes > 0) {
dto.setStatus(ApiStatusSupport.STATUS_OUTAGE);
} else if (maintenanceMinutes > 0) {
dto.setStatus(ApiStatusSupport.STATUS_MAINTENANCE);
} else if (delayMinutes > 0) {
dto.setStatus(ApiStatusSupport.STATUS_DEGRADED);
} else {
dto.setStatus(ApiStatusSupport.STATUS_NORMAL);
}
@@ -5,34 +5,25 @@ import com.eactive.apim.portal.app.repository.CredentialRepository;
import com.eactive.apim.portal.apispec.entity.ApiSpecInfo;
import com.eactive.apim.portal.common.user.PortalAuthenticatedUser;
import com.eactive.apim.portal.common.util.SecurityUtil;
import com.eactive.apim.portal.djb.apistatus.dto.ApiCurrentStatusDTO;
import com.eactive.apim.portal.djb.apistatus.dto.MyApiStatusDTO;
import com.eactive.apim.portal.djb.apistatus.incident.entity.DjbApistatusIncident;
import com.eactive.apim.portal.djb.apistatus.incident.entity.DjbApistatusIncidentApi;
import com.eactive.apim.portal.djb.apistatus.incident.entity.IncidentKind;
import com.eactive.apim.portal.djb.apistatus.incident.entity.IncidentState;
import com.eactive.apim.portal.djb.apistatus.incident.repository.DjbApistatusIncidentApiRepository;
import com.eactive.apim.portal.djb.apistatus.repository.ApiStatusIncidentQueryRepository;
import lombok.RequiredArgsConstructor;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.TreeMap;
import java.util.stream.Collectors;
/**
* 로그인 사용자가 이용 중인 API 의 현재 상태 (P4).
*
* <p>대상 API 는 소속 기관이 발급받은 앱(Credential)의 API 목록(ptl_credential_api)이다.</p>
* <p>대상 API 는 소속 기관이 발급받은 앱(Credential)의 API 목록(ptl_credential_api)이다.
* 상태 판정은 {@link ApiCurrentStatusService} 에 위임해 API 상세 화면과 기준을 맞춘다.</p>
*/
@Service
@RequiredArgsConstructor
@@ -40,9 +31,9 @@ import java.util.stream.Collectors;
public class MyApiStatusQueryService {
private final CredentialRepository credentialRepository;
private final ApiStatusIncidentQueryRepository incidentQueryRepository;
private final DjbApistatusIncidentApiRepository incidentApiRepository;
private final ApiCurrentStatusService apiCurrentStatusService;
private final ApiStatusUptimeService uptimeService;
private final ApiStatusCatalogService catalogService;
public List<MyApiStatusDTO> getMyApiStatuses() {
PortalAuthenticatedUser user = SecurityUtil.getPortalAuthenticatedUser();
@@ -55,30 +46,29 @@ public class MyApiStatusQueryService {
return Collections.emptyList();
}
LocalDateTime now = ApiStatusSupport.now();
Map<String, DjbApistatusIncident> openByApi = mapOpenIncidents(myApis.keySet());
Set<String> underMaintenance = collectApisUnderMaintenance(myApis.keySet(), now);
Map<String, LocalDateTime> lastIncidentAt = collectLastIncidentAt(myApis.keySet(), now);
Map<String, Double> uptimes = uptimeService.getApiUptimeRatios(
myApis.keySet(), ApiStatusSupport.DEFAULT_WINDOW_DAYS);
Map<String, ApiCurrentStatusDTO> statuses = apiCurrentStatusService.resolveStatuses(myApis.keySet());
Map<String, Double> uptimes =
uptimeService.getApiUptimeRatios(myApis.keySet(), catalogService.getWindowDays());
List<MyApiStatusDTO> result = new ArrayList<>();
for (Map.Entry<String, String> entry : myApis.entrySet()) {
String apiId = entry.getKey();
DjbApistatusIncident open = openByApi.get(apiId);
ApiCurrentStatusDTO status = statuses.get(apiId);
MyApiStatusDTO dto = new MyApiStatusDTO();
dto.setApiId(apiId);
// 기관이 발급받은 앱 기준 목록이므로 API 명은 credential 쪽 값을 그대로 쓴다
dto.setApiName(entry.getValue());
dto.setCurrentStatus(resolveStatus(open, underMaintenance.contains(apiId)));
dto.setCurrentStatus(status == null ? ApiStatusSupport.STATUS_NORMAL : status.getCurrentStatus());
dto.setCurrentStatusLabel(ApiStatusSupport.statusLabel(dto.getCurrentStatus()));
dto.setActiveIncidentId(open == null ? null : open.getIncidentId());
dto.setLastIncidentAt(lastIncidentAt.get(apiId));
dto.setActiveIncidentId(status == null ? null : status.getActiveIncidentId());
dto.setLastIncidentAt(status == null ? null : status.getLastIncidentAt());
dto.setUptime90d(uptimes.getOrDefault(apiId, 1.0d));
result.add(dto);
}
result.sort(Comparator.comparingInt((MyApiStatusDTO dto) -> statusRank(dto.getCurrentStatus()))
result.sort(Comparator
.comparingInt((MyApiStatusDTO dto) -> ApiStatusSupport.statusRank(dto.getCurrentStatus()))
.thenComparing(MyApiStatusDTO::getApiName, Comparator.nullsLast(Comparator.naturalOrder())));
return result;
}
@@ -101,113 +91,4 @@ public class MyApiStatusQueryService {
}
return myApis;
}
private Map<String, DjbApistatusIncident> mapOpenIncidents(Set<String> apiIds) {
List<DjbApistatusIncident> openIncidents = incidentQueryRepository
.findVisibleOpenIncidents(IncidentKind.INCIDENT, ApiStatusSupport.CLOSED_STATES);
if (openIncidents.isEmpty()) {
return Collections.emptyMap();
}
Map<Long, DjbApistatusIncident> byId = openIncidents.stream()
.collect(Collectors.toMap(DjbApistatusIncident::getIncidentId, incident -> incident));
Map<String, DjbApistatusIncident> byApi = new HashMap<>();
for (DjbApistatusIncidentApi api :
incidentApiRepository.findByIncidentIdInOrderByIncidentIdAscApiIdAsc(byId.keySet())) {
if (!apiIds.contains(api.getApiId()) || api.getRecoveredAt() != null) {
continue;
}
DjbApistatusIncident incident = byId.get(api.getIncidentId());
DjbApistatusIncident previous = byApi.get(api.getApiId());
// 같은 API 에 여러 장애가 열려 있으면 더 심각한(조사중) 쪽을 우선한다
if (previous == null || statePriority(incident.getState()) < statePriority(previous.getState())) {
byApi.put(api.getApiId(), incident);
}
}
return byApi;
}
private Set<String> collectApisUnderMaintenance(Set<String> apiIds, LocalDateTime now) {
List<DjbApistatusIncident> maintenances = incidentQueryRepository
.findVisibleOngoingMaintenance(IncidentKind.MAINTENANCE, now).stream()
.filter(incident -> incident.getStartedAt() != null && !incident.getStartedAt().isAfter(now))
.collect(Collectors.toList());
if (maintenances.isEmpty()) {
return Collections.emptySet();
}
List<Long> ids = maintenances.stream()
.map(DjbApistatusIncident::getIncidentId)
.collect(Collectors.toList());
Set<String> result = new HashSet<>();
for (DjbApistatusIncidentApi api : incidentApiRepository.findByIncidentIdInOrderByIncidentIdAscApiIdAsc(ids)) {
if (apiIds.contains(api.getApiId())) {
result.add(api.getApiId());
}
}
return result;
}
private Map<String, LocalDateTime> collectLastIncidentAt(Set<String> apiIds, LocalDateTime now) {
LocalDateTime windowStart = now.toLocalDate()
.minusDays(ApiStatusSupport.DEFAULT_WINDOW_DAYS - 1L).atStartOfDay();
List<DjbApistatusIncident> incidents = incidentQueryRepository
.findVisibleOverlapping(windowStart, now.toLocalDate().plusDays(1).atStartOfDay()).stream()
.filter(incident -> incident.getKind() == IncidentKind.INCIDENT)
.collect(Collectors.toList());
if (incidents.isEmpty()) {
return Collections.emptyMap();
}
Map<Long, DjbApistatusIncident> byId = incidents.stream()
.collect(Collectors.toMap(DjbApistatusIncident::getIncidentId, incident -> incident));
Map<String, LocalDateTime> result = new HashMap<>();
for (DjbApistatusIncidentApi api :
incidentApiRepository.findByIncidentIdInOrderByIncidentIdAscApiIdAsc(byId.keySet())) {
if (!apiIds.contains(api.getApiId())) {
continue;
}
LocalDateTime startedAt = byId.get(api.getIncidentId()).getStartedAt();
LocalDateTime previous = result.get(api.getApiId());
if (startedAt != null && (previous == null || startedAt.isAfter(previous))) {
result.put(api.getApiId(), startedAt);
}
}
return result;
}
private String resolveStatus(DjbApistatusIncident open, boolean underMaintenance) {
if (open != null) {
return open.getState() == IncidentState.MONITORING
? ApiStatusSupport.STATUS_DEGRADED : ApiStatusSupport.STATUS_OUTAGE;
}
if (underMaintenance) {
return ApiStatusSupport.STATUS_MAINTENANCE;
}
return ApiStatusSupport.STATUS_NORMAL;
}
private int statePriority(IncidentState state) {
if (state == null) {
return 9;
}
switch (state) {
case INVESTIGATING: return 0;
case IDENTIFIED: return 1;
case MONITORING: return 2;
default: return 8;
}
}
private int statusRank(String status) {
if (status == null) {
return 9;
}
switch (status) {
case ApiStatusSupport.STATUS_OUTAGE: return 0;
case ApiStatusSupport.STATUS_MAINTENANCE: return 1;
case ApiStatusSupport.STATUS_DEGRADED: return 2;
default: return 3;
}
}
}
@@ -3,20 +3,13 @@ package com.eactive.apim.portal.djb.community.qna.comment.repository;
import com.eactive.apim.portal.user.entity.UserInfo;
import com.eactive.eai.data.jpa.BaseRepository;
import com.eactive.eai.rms.data.EMSDataSource;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import java.util.List;
/**
* 댓글 작성자(내부 직원) 표시용 TSEAIRM02 조회.
*
* <p>역할 기반 알림 대상 조회는
* {@code com.eactive.apim.portal.djb.swing.repository.SwingStaffRepository} 로 분리했다.</p>
*/
@EMSDataSource
public interface UserInfoRepository extends BaseRepository<UserInfo, String> {
/**
* TSEAIRM02.roleidnfiname 컬럼은 콤마로 구분된 복수 역할을 저장한다.
* (예: {@code "admin,portal-admin"}). Oracle native query로 콤마 토큰 매치.
*/
@Query(value = "SELECT * FROM TSEAIRM02 t"
+ " WHERE ',' || t.ROLEIDNFINAME || ',' LIKE '%,' || :role || ',%'",
nativeQuery = true)
List<UserInfo> findByRoleContaining(@Param("role") String role);
}
@@ -1,57 +0,0 @@
package com.eactive.apim.portal.djb.community.qna.comment.service;
import com.eactive.apim.portal.djb.community.qna.comment.repository.UserInfoRepository;
import com.eactive.apim.portal.djb.community.qna.constant.DjbAdminRole;
import com.eactive.apim.portal.template.entity.MessageCode;
import com.eactive.apim.portal.template.service.MessageHandlerService;
import com.eactive.apim.portal.template.service.MessageRecipient;
import com.eactive.apim.portal.user.entity.UserInfo;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
/**
* Q&A 등록/댓글 등록 시 portal-admin 역할(TSEAIRM02)을 가진 관리자 전원에게
* 알림 메시지를 발행한다. 발송 실패는 트랜잭션 롤백을 유발하지 않는다.
*/
@Slf4j
@Service
@RequiredArgsConstructor
public class CommunityAdminNotifier {
private final UserInfoRepository userInfoRepository;
private final MessageHandlerService messageHandlerService;
public void notifyPortalAdmins(MessageCode code, Map<String, Object> params) {
try {
List<UserInfo> admins = userInfoRepository.findByRoleContaining(DjbAdminRole.PORTAL_ADMIN);
if (admins == null || admins.isEmpty()) {
log.warn("portal-admin 역할 관리자가 없습니다 — 알림 미발송 code={}", code.name());
return;
}
for (UserInfo admin : admins) {
try {
MessageRecipient recipient = toRecipient(admin);
messageHandlerService.publishEvent(code, recipient, params);
} catch (Exception e) {
log.warn("portal-admin 개별 알림 발행 실패 — userid={}, code={}",
admin.getUserid(), code.name(), e);
}
}
} catch (Exception e) {
log.warn("portal-admin 알림 발행 실패 — code={}", code.name(), e);
}
}
private MessageRecipient toRecipient(UserInfo admin) {
MessageRecipient r = new MessageRecipient();
r.setUsername(admin.getUsername());
r.setUserId(admin.getEmad());
r.setPhone(admin.getCphnno());
r.setMessengerId(admin.getUserid());
return r;
}
}
@@ -8,6 +8,7 @@ import com.eactive.apim.portal.djb.community.qna.comment.dto.InquiryCommentDTO;
import com.eactive.apim.portal.djb.community.qna.comment.repository.InquiryCommentRepository;
import com.eactive.apim.portal.djb.community.qna.comment.repository.UserInfoRepository;
import com.eactive.apim.portal.djb.community.qna.constant.DjbInquiryStatus;
import com.eactive.apim.portal.djb.swing.SwingNotifier;
import com.eactive.apim.portal.djb.community.qna.support.InquiryCommentPermissionChecker;
import com.eactive.apim.portal.portalorg.entity.PortalOrg;
import com.eactive.apim.portal.portaluser.entity.PortalUser;
@@ -47,7 +48,7 @@ public class InquiryCommentFacadeImpl implements InquiryCommentFacade {
private final InquiryCommentService commentService;
private final InquiryCommentRepository commentRepository;
private final InquiryCommentPermissionChecker permissionChecker;
private final CommunityAdminNotifier adminNotifier;
private final SwingNotifier swingNotifier;
private final PortalUserRepository portalUserRepository;
private final UserInfoRepository userInfoRepository;
@@ -107,7 +108,7 @@ public class InquiryCommentFacadeImpl implements InquiryCommentFacade {
params.put("inquirySubject", inquiry.getInquirySubject());
params.put("commentContent", comment.getCommentDetail());
params.put("writerName", current.getUserName());
adminNotifier.notifyPortalAdmins(MessageCode.INQUIRY_COMMENT_CREATED, params);
swingNotifier.notifyPortalAdmins(MessageCode.INQUIRY_COMMENT_CREATED, params);
}
private Map<String, Writer> resolveWriters(List<InquiryComment> comments) {
@@ -1,10 +0,0 @@
package com.eactive.apim.portal.djb.community.qna.constant;
public final class DjbAdminRole {
/** TSEAIRM02.roleidnfiname 컬럼에서 포털 관리자를 식별하는 값. */
public static final String PORTAL_ADMIN = "portal-admin";
private DjbAdminRole() {
}
}
@@ -0,0 +1,40 @@
package com.eactive.apim.portal.djb.swing;
/**
* Swing 메신저 수신자 ID 가 행번(직원번호)이 아닐 때의 처리 정책.
*
* <p>Swing 메신저는 {@code TSEAIRM02.USERID} 를 수신자 코드로 사용하며 운영 직원은 숫자 행번을 쓴다.
* portal-admin 역할이 부여된 개발용 계정(영문 ID 등)은 Swing 에 존재하지 않아 발송이 무의미하므로
* 이 정책으로 처리 방식을 선택한다. PTL_PROPERTY
* {@code Portal / djb.swing.notify.non-employee.policy} 로 지정한다.</p>
*/
public enum EmployeeIdPolicy {
/** 정상 발송 (PTL_MESSAGE_REQUEST 에 PENDING 적재) */
SEND,
/** 발송 + WARN 로그 */
SEND_WARN,
/** 무시 처리 — REQUEST_STATUS='SKIPPED' 로 적재해 이력만 남기고 배치는 수집하지 않음 */
SKIP,
/** 거부 — PTL_MESSAGE_REQUEST 에 적재하지 않음 + INFO 로그 */
REJECT_LOG,
/** 완전 거부 — 적재하지 않고 로그도 남기지 않음 */
REJECT;
/** 프로퍼티 문자열 → enum. 값이 없거나 알 수 없으면 기본값 {@link #SKIP}. */
public static EmployeeIdPolicy from(String value) {
if (value != null) {
String trimmed = value.trim();
for (EmployeeIdPolicy policy : values()) {
if (policy.name().equalsIgnoreCase(trimmed)) {
return policy;
}
}
}
return SKIP;
}
}
@@ -0,0 +1,160 @@
package com.eactive.apim.portal.djb.swing;
import com.eactive.apim.portal.djb.swing.repository.SwingStaffRepository;
import com.eactive.apim.portal.template.entity.MessageCode;
import com.eactive.apim.portal.template.entity.MessageRequest;
import com.eactive.apim.portal.template.entity.MessageTemplate;
import com.eactive.apim.portal.template.repository.MessageRequestRepository;
import com.eactive.apim.portal.template.repository.MessageTemplateRepository;
import com.eactive.apim.portal.user.entity.UserInfo;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;
import java.time.LocalDateTime;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* Swing 메신저 발송 요청을 PTL_MESSAGE_REQUEST 에 직접 적재한다.
*
* <p>TSEAIRM02(직원) → PTL_MESSAGE_TEMPLATE(본문) → PTL_MESSAGE_REQUEST(발송 요청) 순으로
* 처리하며, 실제 발송은 기존과 동일하게 eapim-admin 의 {@code UmsDispatchJob}(5초 주기)이
* {@code REQUEST_STATUS='PENDING'} 행을 수집해 수행한다.</p>
*/
@Slf4j
@Service
@RequiredArgsConstructor
public class SwingMessageWriter {
private static final String MESSAGE_TYPE_MESSENGER = "MESSENGER";
private static final String STATUS_PENDING = "PENDING";
/** 행번 아닌 ID 를 무시 처리할 때 쓰는 신설 상태값. 배치(PENDING 수집)가 건드리지 않는다. */
private static final String STATUS_SKIPPED = "SKIPPED";
private static final String ENABLED = "Y";
private final SwingStaffRepository swingStaffRepository;
private final MessageTemplateRepository messageTemplateRepository;
private final MessageRequestRepository messageRequestRepository;
private final SwingNotifyProperties properties;
@Transactional
public void write(MessageCode code, Map<String, Object> params) {
String role = properties.getTargetRole();
List<UserInfo> staffs = swingStaffRepository.findByRole(role);
if (staffs == null || staffs.isEmpty()) {
log.warn("Swing 알림 대상 직원이 없습니다 — role={}, code={}", role, code.name());
return;
}
MessageTemplate template = messageTemplateRepository.findById(code.name()).orElse(null);
if (template == null) {
log.warn("메세지 템플릿이 존재하지 않습니다 — code={}", code.name());
return;
}
if (!ENABLED.equalsIgnoreCase(template.getEnableMessenger())) {
log.warn("메신저 발송이 비활성화된 템플릿입니다 — code={}, enableMessenger={}",
code.name(), template.getEnableMessenger());
return;
}
SwingNotifyProperties.UmsMessengerIds umsIds = properties.getUmsMessengerIds();
EmployeeIdPolicy policy = properties.getNonEmployeePolicy();
for (UserInfo staff : staffs) {
try {
writeOne(code, template, params, staff, umsIds, policy);
} catch (Exception e) {
log.warn("Swing 알림 적재 실패 — userid={}, code={}", staff.getUserid(), code.name(), e);
}
}
}
private void writeOne(MessageCode code, MessageTemplate template, Map<String, Object> params,
UserInfo staff, SwingNotifyProperties.UmsMessengerIds umsIds,
EmployeeIdPolicy policy) {
String messengerId = staff.getUserid();
String requestStatus = STATUS_PENDING;
if (!properties.isEmployeeId(messengerId)) {
switch (policy) {
case REJECT:
return;
case REJECT_LOG:
log.info("행번이 아닌 ID — 발송 거부(미적재). userid={}, code={}", messengerId, code.name());
return;
case SKIP:
log.info("행번이 아닌 ID — 무시 처리({}). userid={}, code={}",
STATUS_SKIPPED, messengerId, code.name());
requestStatus = STATUS_SKIPPED;
break;
case SEND_WARN:
log.warn("행번이 아닌 ID — 발송 진행. Swing 미등록 계정이면 발송 실패한다. userid={}, code={}",
messengerId, code.name());
break;
case SEND:
default:
break;
}
}
Map<String, String> messageParams = toStringParams(params);
messageParams.put("userId", messengerId);
messageParams.putIfAbsent("USER_ID", messengerId);
if (StringUtils.hasText(staff.getUsername())) {
messageParams.put("userName", staff.getUsername());
messageParams.putIfAbsent("USER_NAME", staff.getUsername());
}
MessageRequest request = new MessageRequest();
request.setMessageCode(code);
request.setMessageType(MESSAGE_TYPE_MESSENGER);
request.setSubject(buildMessage(template.getSubjectTemplate(), messageParams));
request.setMessage(buildMessage(template.getMessengerTemplate(), messageParams));
request.setUsername(staff.getUsername());
request.setUserId(messengerId);
request.setMessengerId(messengerId);
request.setEaiInterfaceId(umsIds.getInterfaceId());
request.setServiceId(umsIds.getServiceId());
request.setRequestDate(LocalDateTime.now());
request.setRequestStatus(requestStatus);
// email/phone 은 설정하지 않는다 — 메신저 전용 경로라 개인정보를 적재할 이유가 없다.
messageRequestRepository.save(request);
log.debug("Swing 알림 적재 — code={}, userid={}, status={}", code.name(), messengerId, requestStatus);
}
/** 수신자별로 파라미터를 복사한다(공유 맵을 오염시키지 않기 위함). */
private static Map<String, String> toStringParams(Map<String, Object> params) {
Map<String, String> result = new HashMap<>();
if (params != null) {
for (Map.Entry<String, Object> entry : params.entrySet()) {
if (entry.getKey() == null || entry.getValue() == null) {
continue;
}
result.put(entry.getKey(), String.valueOf(entry.getValue()));
}
}
return result;
}
/** 템플릿 본문의 {@code %KEY%} 플레이스홀더를 치환한다(정규식 아닌 리터럴 치환). */
private static String buildMessage(String contents, Map<String, String> params) {
if (!StringUtils.hasText(contents)) {
return "";
}
String result = contents;
for (Map.Entry<String, String> entry : params.entrySet()) {
if (entry.getKey() == null || entry.getValue() == null) {
continue;
}
result = result.replace("%" + entry.getKey() + "%", entry.getValue());
}
return result;
}
}
@@ -0,0 +1,43 @@
package com.eactive.apim.portal.djb.swing;
import com.eactive.apim.portal.djb.swing.config.SwingAsyncConfig;
import com.eactive.apim.portal.template.entity.MessageCode;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import java.util.Map;
/**
* DjBankSwing(사내 메신저) 전용 알림 발행자.
*
* <p>포털 사용자용 범용 발송 경로({@code MessageHandlerService} → {@code MessageSendService})를
* 타지 않고 TSEAIRM02 / PTL_MESSAGE_TEMPLATE / PTL_MESSAGE_REQUEST 를 직접 다룬다.
* 내부 직원은 수신자 ID 체계(행번)와 채널(메신저 단일)이 포털 사용자와 완전히 달라 분리했다.</p>
*
* <p>비동기 실행이므로 게시물 등록 트랜잭션과 분리된다. 발송 적재 실패가 등록을 되돌리지 않는 대신,
* 등록이 롤백돼도 알림은 남을 수 있다.</p>
*/
@Slf4j
@Service
@RequiredArgsConstructor
public class SwingNotifier {
private final SwingMessageWriter swingMessageWriter;
/**
* 대상 역할(PTL_PROPERTY {@code djb.swing.notify.role}) 직원 전원에게 메신저 알림을 적재한다.
*
* @param code 메세지 코드 (PTL_MESSAGE_TEMPLATE.MESSAGE_CODE 와 동일)
* @param params 템플릿 {@code %KEY%} 치환 파라미터
*/
@Async(SwingAsyncConfig.EXECUTOR)
public void notifyPortalAdmins(MessageCode code, Map<String, Object> params) {
try {
swingMessageWriter.write(code, params);
} catch (Exception e) {
log.warn("Swing 알림 발행 실패 — code={}", code == null ? null : code.name(), e);
}
}
}
@@ -0,0 +1,112 @@
package com.eactive.apim.portal.djb.swing;
import com.eactive.apim.portal.portalproperty.service.PortalPropertyService;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.util.Map;
import java.util.regex.Pattern;
/**
* Swing 알림 관련 PTL_PROPERTY 접근 래퍼.
*
* <p>그룹 {@code Portal}, 점 구분 소문자 키 관례를 따른다.
* {@link PortalPropertyService#getOrCreateProperty} 는 최초 접근 시 기본값으로 DB row 를
* 생성하므로 별도 초기 데이터 없이도 동작한다.</p>
*/
@Slf4j
@Component
@RequiredArgsConstructor
public class SwingNotifyProperties {
public static final String GROUP = "Portal";
public static final String KEY_TARGET_ROLE = "djb.swing.notify.role";
public static final String KEY_EMPLOYEE_ID_PATTERN = "djb.swing.notify.employee-id.pattern";
public static final String KEY_NON_EMPLOYEE_POLICY = "djb.swing.notify.non-employee.policy";
/** UMS 메신저 연계 식별자. 기존 발송 경로(MessageSendService)와 같은 키를 그대로 읽는다. */
public static final String KEY_MESSENGER_IF_ID = "djb.ums.messenger.if_id";
public static final String KEY_MESSENGER_TX_ID = "djb.ums.messenger.tx_id";
private static final String DEFAULT_TARGET_ROLE = "portal-admin";
private static final String DEFAULT_EMPLOYEE_ID_PATTERN = "^[0-9]+$";
private final PortalPropertyService portalPropertyService;
/** 컴파일된 행번 정규식 캐시. 프로퍼티 값이 바뀌면 다시 컴파일한다. */
private volatile String cachedPatternValue;
private volatile Pattern cachedPattern;
/** 알림 대상 직원을 식별하는 TSEAIRM02.ROLEIDNFINAME 역할명 */
public String getTargetRole() {
return resolve(KEY_TARGET_ROLE, DEFAULT_TARGET_ROLE,
"Swing 알림 대상 직원 역할명 (TSEAIRM02.ROLEIDNFINAME 의 콤마 구분 토큰)");
}
/** 행번 아닌 ID 처리 정책 */
public EmployeeIdPolicy getNonEmployeePolicy() {
return EmployeeIdPolicy.from(resolve(KEY_NON_EMPLOYEE_POLICY, EmployeeIdPolicy.SKIP.name(),
"행번 아닌 ID 처리 정책 (SEND/SEND_WARN/SKIP/REJECT_LOG/REJECT)"));
}
/**
* 행번(직원번호) 형식인지 여부. 정규식이 잘못 지정된 경우 기본 정규식으로 폴백한다.
*
* @param userId TSEAIRM02.USERID
*/
public boolean isEmployeeId(String userId) {
if (userId == null || userId.trim().isEmpty()) {
return false;
}
return employeeIdPattern().matcher(userId.trim()).matches();
}
/** UMS 메신저 연계 식별자(EAI 인터페이스 ID / 서비스 ID) */
public UmsMessengerIds getUmsMessengerIds() {
// 환경별 실제 연계값이라 임의 기본값을 만들면 위험 — getOrCreateProperty 대신 조회만 한다.
Map<String, String> portalProperties = portalPropertyService.getPortalPropertiesAsMap(GROUP);
return new UmsMessengerIds(
portalProperties.get(KEY_MESSENGER_IF_ID),
portalProperties.get(KEY_MESSENGER_TX_ID));
}
private Pattern employeeIdPattern() {
String value = resolve(KEY_EMPLOYEE_ID_PATTERN, DEFAULT_EMPLOYEE_ID_PATTERN,
"행번(직원번호) 판별 정규식. 미매치 시 개발용 ID 로 간주");
Pattern cached = this.cachedPattern;
if (cached != null && value != null && value.equals(this.cachedPatternValue)) {
return cached;
}
Pattern compiled;
try {
compiled = Pattern.compile(value);
} catch (Exception e) {
log.warn("행번 판별 정규식이 잘못되어 기본값으로 대체합니다 — pattern={}", value, e);
compiled = Pattern.compile(DEFAULT_EMPLOYEE_ID_PATTERN);
}
this.cachedPatternValue = value;
this.cachedPattern = compiled;
return compiled;
}
private String resolve(String key, String defaultValue, String description) {
return portalPropertyService.getOrCreateProperty(GROUP, key, defaultValue, description);
}
/** UMS 메신저 연계 식별자 묶음 */
@Getter
public static class UmsMessengerIds {
private final String interfaceId;
private final String serviceId;
public UmsMessengerIds(String interfaceId, String serviceId) {
this.interfaceId = interfaceId;
this.serviceId = serviceId;
}
}
}
@@ -0,0 +1,34 @@
package com.eactive.apim.portal.djb.swing.config;
import java.util.concurrent.Executor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
/**
* Swing 알림 전용 비동기 실행기.
*
* <p>게시물 등록 트랜잭션이 메신저 알림 적재를 기다리지 않도록 분리한다.
* eapim-admin 의 {@code WebhookAsyncConfig} 와 동일한 구성.</p>
*/
@Configuration
@EnableAsync
public class SwingAsyncConfig {
public static final String EXECUTOR = "swingNotifyExecutor";
@Bean(name = EXECUTOR)
public Executor swingNotifyExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(2);
executor.setMaxPoolSize(10);
executor.setQueueCapacity(100);
executor.setThreadNamePrefix("swing-notify-");
executor.setWaitForTasksToCompleteOnShutdown(true);
executor.setAwaitTerminationSeconds(30);
executor.initialize();
return executor;
}
}
@@ -0,0 +1,27 @@
package com.eactive.apim.portal.djb.swing.repository;
import com.eactive.apim.portal.user.entity.UserInfo;
import com.eactive.eai.rms.data.EMSDataSource;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* Swing 알림 대상 직원(TSEAIRM02) 조회 전용 리포지토리.
*/
@Repository
@EMSDataSource
public interface SwingStaffRepository extends JpaRepository<UserInfo, String> {
/**
* TSEAIRM02.roleidnfiname 컬럼은 콤마로 구분된 복수 역할을 저장한다.
* (예: {@code "admin,portal-admin"}). Oracle native query로 콤마 토큰 매치.
*/
@Query(value = "SELECT * FROM TSEAIRM02 t"
+ " WHERE ',' || t.ROLEIDNFINAME || ',' LIKE '%,' || :role || ',%'",
nativeQuery = true)
List<UserInfo> findByRole(@Param("role") String role);
}
+163 -7
View File
@@ -1692,6 +1692,19 @@ hr {
}
}
.footer-link--external {
display: inline-flex;
align-items: center;
gap: 4px;
.footer-link-external-icon {
flex-shrink: 0;
width: 14px;
height: 14px;
color: currentColor;
}
}
.footer-separator {
color: #D1D5DB;
font-size: 16px;
@@ -11150,16 +11163,28 @@ body.index-page-body {
.api-card:active .api-card-desc {
color: #ffffff;
}
.api-card-badge {
.api-card {
/* 그룹 배지 + 현재 상태 태그를 줄에 둔다.
기존 그룹 배지가 갖고 있던 절대 위치(top 39 / left 32) 래퍼가 이어받는다 */
}
.api-card-badges {
position: absolute;
top: 39px;
left: 32px;
right: 32px;
display: flex;
align-items: center;
gap: 8px;
min-width: 0;
}
.api-card-badge {
background-color: #f2f2f3;
border-radius: 10px;
padding: 2px 20px;
display: inline-flex;
align-items: center;
justify-content: center;
min-width: 0;
}
.api-card-badge span {
font-size: 14px;
@@ -11167,6 +11192,44 @@ body.index-page-body {
font-weight: 500;
color: #1b4ab7;
white-space: nowrap;
overflow: hidden;
text-overflow: ellipsis;
}
.api-card {
/* 현재 상태 태그. 규격은 API Status 화면(.as-badge) 동일.
상태를 받았을 ( ) 자리만 차지하지 않도록 숨긴다 */
}
.api-card-status {
flex-shrink: 0;
display: inline-flex;
align-items: center;
padding: 3px 12px;
border-radius: 10px;
font-size: 12px;
font-family: "Spoqa Han Sans Neo", sans-serif;
font-weight: 600;
white-space: nowrap;
background: #eef1f5;
color: #4b5563;
}
.api-card-status:empty {
display: none;
}
.api-card-status.is-outage {
background: #feeae7;
color: #c8362f;
}
.api-card-status.is-maintenance {
background: #e7f0fb;
color: #0a66c2;
}
.api-card-status.is-degraded {
background: #fef3c7;
color: #c77800;
}
.api-card-status.is-normal {
background: #e7f6ec;
color: #1b8c4a;
}
.api-card-title {
position: absolute;
@@ -11486,7 +11549,7 @@ body.index-page-body {
}
}
/* "기본 정보" 헤더: 좌측 제목 + 우측 "API 사용 신청" 버튼 */
/* "기본 정보" 헤더: 좌측 제목 + 우측 현재 상태/상태 이력 */
.api-basic-info-header {
display: flex;
align-items: center;
@@ -11495,6 +11558,55 @@ body.index-page-body {
flex-wrap: wrap;
}
/* 현재 상태 배지 + "상태 이력 확인" 버튼.
규격은 API Status 화면(.as-badge) 동일하게 맞춘다 */
.api-status-inline {
display: flex;
align-items: center;
gap: 10px;
flex-wrap: wrap;
}
.api-status-inline .api-status-inline__label {
font-size: 13px;
font-weight: 500;
color: #4b5563;
}
.api-status-inline .api-status-inline__badge {
display: inline-flex;
align-items: center;
font-size: 12px;
font-weight: 600;
padding: 5px 12px;
border-radius: 999px;
letter-spacing: 0.02em;
white-space: nowrap;
background: #eef1f5;
color: #4b5563;
}
.api-status-inline .api-status-inline__badge.is-outage {
background: #feeae7;
color: #c8362f;
}
.api-status-inline .api-status-inline__badge.is-maintenance {
background: #e7f0fb;
color: #0a66c2;
}
.api-status-inline .api-status-inline__badge.is-degraded {
background: #fef3c7;
color: #c77800;
}
.api-status-inline .api-status-inline__badge.is-normal {
background: #e7f6ec;
color: #1b8c4a;
}
.api-status-inline .api-status-inline__badge.is-loading {
color: #6b7280;
}
.api-status-inline .api-status-inline__badge.is-muted {
background: #eef1f5;
color: #6b7280;
}
/* 하단 중앙 "API 사용 신청" 버튼 */
.api-apply-footer {
display: flex;
@@ -26615,6 +26727,16 @@ input[type=checkbox]:checked + .custom-checkbox {
color: #ffffff;
}
.as-title-banner,
.as-title-banner h1,
.api-status,
.api-status h1,
.api-status h2,
.api-status h3,
.api-status h4 {
font-family: "Spoqa Han Sans Neo", "SpoqaHanSans", "Noto Sans KR", -apple-system, BlinkMacSystemFont, "Segoe UI", sans-serif;
}
.as-title-banner {
margin: 44px 0 28px;
border-radius: 12px;
@@ -26698,6 +26820,7 @@ input[type=checkbox]:checked + .custom-checkbox {
--as-radius: 12px;
--as-pill: 999px;
display: grid;
grid-template-columns: minmax(0, 1fr);
gap: 20px;
padding: 0 0 70px;
}
@@ -26979,7 +27102,7 @@ input[type=checkbox]:checked + .custom-checkbox {
.api-status .as-legend .as-sw.is-none {
background: var(--as-none-bg);
}
.api-status .as-legend .as-sw.is-both {
.api-status .as-legend .as-sw.is-mixed, .api-status .as-legend .as-sw.is-both {
background: var(--as-both);
}
.api-status .as-my-apis table {
@@ -27098,6 +27221,9 @@ input[type=checkbox]:checked + .custom-checkbox {
.api-status .as-issue-card.is-incident {
border-left: 4px solid var(--as-err);
}
.api-status .as-issue-card.is-degraded {
border-left: 4px solid var(--as-warn);
}
.api-status .as-issue-card.is-maintenance {
border-left: 4px solid var(--as-info);
}
@@ -27120,6 +27246,9 @@ input[type=checkbox]:checked + .custom-checkbox {
.api-status .as-issue-card.is-incident .as-issue-title {
color: var(--as-err);
}
.api-status .as-issue-card.is-degraded .as-issue-title {
color: var(--as-warn);
}
.api-status .as-issue-card.is-maintenance .as-issue-title {
color: var(--as-info);
}
@@ -27224,10 +27353,13 @@ input[type=checkbox]:checked + .custom-checkbox {
.api-status .as-index-cell.has-incident {
background: var(--as-err);
}
.api-status .as-index-cell.has-degraded {
background: var(--as-warn);
}
.api-status .as-index-cell.has-maintenance {
background: var(--as-info);
}
.api-status .as-index-cell.has-both {
.api-status .as-index-cell.has-mixed, .api-status .as-index-cell.has-both {
background: var(--as-both);
}
.api-status .as-index-cell.is-selected {
@@ -27369,6 +27501,26 @@ input[type=checkbox]:checked + .custom-checkbox {
font-size: 12px;
text-align: center;
}
.api-status .as-unlisted-banner {
display: flex;
align-items: center;
gap: 10px;
padding: 12px 18px;
border: 1px solid var(--as-border);
border-left: 4px solid var(--as-muted);
border-radius: var(--as-radius);
background: #f6f8fa;
font-size: 13px;
color: var(--as-text-3);
}
.api-status .as-unlisted-banner b {
color: var(--as-text);
}
.api-status .as-unlisted-banner .as-unlisted-icon {
flex: 0 0 auto;
color: var(--as-muted);
font-size: 15px;
}
.api-status .as-pager {
display: flex;
justify-content: center;
@@ -27455,7 +27607,13 @@ input[type=checkbox]:checked + .custom-checkbox {
justify-content: space-between;
}
.api-status .as-index-bar {
height: 36px;
height: 40px;
}
.api-status .as-index-bar .as-index-cell {
flex: 0 0 12px;
}
.api-status .as-uptime .as-bar-chart .as-bar {
flex: 0 0 12px;
}
.api-status .as-issue-card {
padding: 18px 16px;
@@ -28462,5 +28620,3 @@ input[type=checkbox]:checked + .custom-checkbox {
white-space: nowrap;
border: 0;
}
/*# sourceMappingURL=main.css.map */
File diff suppressed because one or more lines are too long
@@ -11,11 +11,14 @@
/** 오픈 API 목록에 노출되는 API (링크 가능 대상) */
const linkableApiIds = new Set();
const KIND_LABEL = { INCIDENT: '장애', MAINTENANCE: '점검' };
const KIND_LABEL = { INCIDENT: '장애', DELAY: '지연', MAINTENANCE: '점검' };
const KIND_CLASS = { INCIDENT: 'is-incident', DELAY: 'is-degraded', MAINTENANCE: 'is-maintenance' };
const PAGE_SIZE = 10;
const API_LIST_LIMIT = 50; // 라이브서치 결과 표시 상한
const today = page.getAttribute('data-today') || '';
// My APIs 등에서 넘어올 때 표시용 API 명 (필터 자체는 apiId 로 동작)
const urlApiName = new URLSearchParams(window.location.search).get('apiName') || '';
const minDate = page.getAttribute('data-min-date') || '';
// 진입 시 날짜 미지정 = 조회 기간 전체
@@ -39,6 +42,8 @@
const apiInput = document.getElementById('filterApiInput');
const apiClearBtn = document.getElementById('filterApiClear');
const apiListEl = document.getElementById('filterApiList');
const unlistedBanner = document.getElementById('unlistedApiBanner');
const unlistedName = document.getElementById('unlistedApiName');
let apiOptions = [];
@@ -124,15 +129,21 @@
indexBar.innerHTML = entries.map(function (entry) {
const hasIncident = entry.incCount > 0;
const hasDelay = entry.dlyCount > 0;
const hasMaintenance = entry.mntCount > 0;
// 유형이 2종 이상 섞인 날은 개별 색 대신 복합 색으로 표시한다
const kindCount = (hasIncident ? 1 : 0) + (hasDelay ? 1 : 0) + (hasMaintenance ? 1 : 0);
let cls = '';
if (hasIncident && hasMaintenance) cls = ' has-both';
if (kindCount > 1) cls = ' has-mixed';
else if (hasIncident) cls = ' has-incident';
else if (hasDelay) cls = ' has-degraded';
else if (hasMaintenance) cls = ' has-maintenance';
if (state.date && state.date === entry.date) cls += ' is-selected';
const parts = [];
if (hasIncident) parts.push('장애 ' + entry.incCount + '건');
if (hasDelay) parts.push('지연 ' + entry.dlyCount + '건');
if (hasMaintenance) parts.push('점검 ' + entry.mntCount + '건');
const tooltip = entry.date + (parts.length ? ' · ' + parts.join(' · ') : ' · 이슈 없음');
@@ -181,7 +192,7 @@
}
function issueCardHtml(issue) {
const kindClass = issue.kind === 'MAINTENANCE' ? 'is-maintenance' : 'is-incident';
const kindClass = KIND_CLASS[issue.kind] || 'is-incident';
let inner;
if (issue.kind === 'MAINTENANCE') {
@@ -271,13 +282,8 @@
.then(function (apis) {
apiOptions = (apis || []).filter(function (api) { return api.apiId; });
apiOptions.forEach(function (api) { linkableApiIds.add(api.apiId); });
const selected = findApiOption(state.apiId);
if (state.apiId && !selected) {
// 조회 가능 목록에 없는 API 가 URL 로 들어온 경우 필터 해제
state.apiId = '';
syncBrowserUrl();
}
// URL 로 들어온 apiId 는 옵션(오픈 API 목록)에 없어도 필터를 유지한다.
// My APIs(기관 계약 API)처럼 오픈 API 목록 밖의 API 로도 진입하기 때문.
renderApiInput();
})
.catch(function () { /* 옵션 조회 실패 시 전체 API 기준으로 동작 */ });
@@ -299,8 +305,16 @@
function renderApiInput() {
const selected = findApiOption(state.apiId);
apiInput.value = optionLabel(selected);
apiCombo.classList.toggle('has-value', !!selected);
// 옵션에 없는 API(오픈 API 목록 밖)는 전달받은 API 명 또는 ID 로 표시해 필터 상태를 보이게 한다
apiInput.value = selected ? optionLabel(selected) : (state.apiId ? (urlApiName || state.apiId) : '');
apiCombo.classList.toggle('has-value', !!state.apiId);
// 포탈 미게시 API 필터 안내 배너 (옵션 목록을 받은 뒤에만 판단)
const unlisted = !!state.apiId && apiOptions.length > 0 && !selected;
if (unlisted) {
unlistedName.textContent = urlApiName || state.apiId;
}
unlistedBanner.style.display = unlisted ? '' : 'none';
}
function closeApiList() {
@@ -375,7 +389,20 @@
applyFilters(true);
});
apiInput.addEventListener('focus', function () { openApiList(''); });
// readonly 자동완성 차단 트릭: 브라우저 autofill 은 readonly 입력을 후보에서 제외한다.
// 사용자가 실제로 만지는 순간에만 readonly 를 풀어 입력을 허용한다 (모바일은 touchstart 가 먼저 온다).
function unlockApiInput() {
if (apiInput.hasAttribute('readonly')) {
apiInput.removeAttribute('readonly');
}
}
apiInput.addEventListener('touchstart', unlockApiInput, { passive: true });
apiInput.addEventListener('mousedown', unlockApiInput);
apiInput.addEventListener('focus', function () {
unlockApiInput();
openApiList('');
});
apiInput.addEventListener('input', function () { openApiList(apiInput.value); });
+10 -5
View File
@@ -12,7 +12,8 @@
/** 오픈 API 목록에 노출되는 API (링크 가능 대상) */
const linkableApiIds = new Set();
const KIND_LABEL = { INCIDENT: '장애', MAINTENANCE: '점검' };
const KIND_LABEL = { INCIDENT: '장애', DELAY: '지연', MAINTENANCE: '점검' };
const KIND_CLASS = { INCIDENT: 'is-incident', DELAY: 'is-degraded', MAINTENANCE: 'is-maintenance' };
/** 진행 중 장애 카드 노출 상한. 초과분은 전체 이력 링크로 넘긴다. */
const ACTIVE_INCIDENT_LIMIT = 1;
@@ -81,6 +82,7 @@
const query = [];
if (params.date) query.push('date=' + encodeURIComponent(params.date));
if (params.apiId) query.push('apiId=' + encodeURIComponent(params.apiId));
if (params.apiName) query.push('apiName=' + encodeURIComponent(params.apiName));
return base + '/issues' + (query.length ? '?' + query.join('&') : '');
}
@@ -206,7 +208,7 @@
document.getElementById('myApisCount').textContent = apis.length + '건';
document.getElementById('myApisBody').innerHTML = apis.map(function (api) {
const cls = badgeClass[api.currentStatus] || 'is-muted';
return '<tr data-api-id="' + escapeHtml(api.apiId) + '">'
return '<tr data-api-id="' + escapeHtml(api.apiId) + '" data-api-name="' + escapeHtml(api.apiName) + '">'
+ '<td><span class="as-api-name">' + escapeHtml(api.apiName) + '</span></td>'
+ '<td><span class="as-badge ' + cls + '">' + escapeHtml(api.currentStatusLabel) + '</span></td>'
+ '<td class="as-num">' + formatPercent(api.uptime90d) + '%</td>'
@@ -216,7 +218,10 @@
card.style.display = '';
card.querySelectorAll('tbody tr').forEach(function (row) {
row.addEventListener('click', function () {
window.location.href = issuesHref({ apiId: row.getAttribute('data-api-id') });
window.location.href = issuesHref({
apiId: row.getAttribute('data-api-id'),
apiName: row.getAttribute('data-api-name')
});
});
});
}
@@ -258,8 +263,8 @@
// ---------------- ❺ 지난 이슈 사항 ----------------
function issueCardHtml(issue) {
const kindClass = issue.kind === 'MAINTENANCE' ? 'is-maintenance' : 'is-incident';
const kindBadge = issue.kind === 'MAINTENANCE' ? 'is-maintenance' : 'is-incident';
const kindClass = KIND_CLASS[issue.kind] || 'is-incident';
const kindBadge = kindClass;
let inner;
if (issue.kind === 'MAINTENANCE') {
@@ -142,7 +142,11 @@ const customPopups = {
$('#passwordPopupMessage').html(customPopups._sanitizeHtml(message));
// 입력 필드 및 에러 초기화 (placeholder 는 호출부 커스텀 허용)
$('#passwordPopupInput').val('').removeClass('error').attr('placeholder', placeholder);
// type 은 열려 있는 동안만 password 로 전환한다.
// 상주 DOM 에 password 입력이 있으면 브라우저가 페이지의 다른 텍스트 입력을
// 아이디 칸으로 오인해 계정 자동완성을 띄우기 때문 (닫을 때 text 로 복원).
$('#passwordPopupInput').val('').removeClass('error')
.attr('type', 'password').attr('placeholder', placeholder);
$('#passwordPopupError').removeClass('show').text('');
// 팝업 표시 (modal 구조 사용)
@@ -219,8 +223,8 @@ const customPopups = {
// Body 스크롤 복원
$('body').css('overflow', '');
// 입력 필드 초기화
$('#passwordPopupInput').val('').removeClass('error');
// 입력 필드 초기화 (type 도 text 로 복원 — 상주 password 로 남기지 않는다)
$('#passwordPopupInput').val('').removeClass('error').attr('type', 'text');
$('#passwordPopupError').removeClass('show').text('');
// 이벤트 리스너 제거
@@ -65,6 +65,19 @@
}
}
.footer-link--external {
display: inline-flex;
align-items: center;
gap: 4px;
.footer-link-external-icon {
flex-shrink: 0;
width: 14px;
height: 14px;
color: currentColor;
}
}
.footer-separator {
color: #D1D5DB;
font-size: 16px;
@@ -467,16 +467,27 @@
}
}
&-badge {
/* 그룹 배지 + 현재 상태 태그를 한 줄에 둔다.
기존 그룹 배지가 갖고 있던 절대 위치(top 39 / left 32)를 이 래퍼가 이어받는다 */
&-badges {
position: absolute;
top: 39px;
left: 32px;
right: 32px;
display: flex;
align-items: center;
gap: 8px;
min-width: 0;
}
&-badge {
background-color: #f2f2f3;
border-radius: 10px;
padding: 2px 20px;
display: inline-flex;
align-items: center;
justify-content: center;
min-width: 0;
span {
font-size: 14px;
@@ -484,9 +495,34 @@
font-weight: 500;
color: #1b4ab7;
white-space: nowrap;
overflow: hidden;
text-overflow: ellipsis;
}
}
/* 현재 상태 태그. 색 규격은 API Status 화면(.as-badge)과 동일.
상태를 못 받았을 때(빈 값)는 자리만 차지하지 않도록 숨긴다 */
&-status {
flex-shrink: 0;
display: inline-flex;
align-items: center;
padding: 3px 12px;
border-radius: 10px;
font-size: 12px;
font-family: 'Spoqa Han Sans Neo', sans-serif;
font-weight: 600;
white-space: nowrap;
background: #eef1f5;
color: #4b5563;
&:empty { display: none; }
&.is-outage { background: #feeae7; color: #c8362f; }
&.is-maintenance { background: #e7f0fb; color: #0a66c2; }
&.is-degraded { background: #fef3c7; color: #c77800; }
&.is-normal { background: #e7f6ec; color: #1b8c4a; }
}
&-title {
position: absolute;
top: 86px;
@@ -846,7 +882,7 @@
}
// API Overview Card (Flat Style)
/* "기본 정보" 헤더: 좌측 제목 + 우측 "API 사용 신청" 버튼 */
/* "기본 정보" 헤더: 좌측 제목 + 우측 현재 상태/상태 이력 */
.api-basic-info-header {
display: flex;
align-items: center;
@@ -855,6 +891,41 @@
flex-wrap: wrap;
}
/* 현재 상태 배지 + "상태 이력 확인" 버튼.
색 규격은 API Status 화면(.as-badge)과 동일하게 맞춘다 */
.api-status-inline {
display: flex;
align-items: center;
gap: 10px;
flex-wrap: wrap;
.api-status-inline__label {
font-size: 13px;
font-weight: 500;
color: #4b5563;
}
.api-status-inline__badge {
display: inline-flex;
align-items: center;
font-size: 12px;
font-weight: 600;
padding: 5px 12px;
border-radius: 999px;
letter-spacing: 0.02em;
white-space: nowrap;
background: #eef1f5;
color: #4b5563;
&.is-outage { background: #feeae7; color: #c8362f; }
&.is-maintenance { background: #e7f0fb; color: #0a66c2; }
&.is-degraded { background: #fef3c7; color: #c77800; }
&.is-normal { background: #e7f6ec; color: #1b8c4a; }
&.is-loading { color: #6b7280; }
&.is-muted { background: #eef1f5; color: #6b7280; }
}
}
/* 하단 중앙 "API 사용 신청" 버튼 */
.api-apply-footer {
display: flex;
@@ -3,6 +3,19 @@
// 설계: architecture/01-api-status/02-screen-design
// 타이틀 배너: Figma eapim-portal node 1:16
// ============================================================
@use '../abstracts/variables' as *;
// API Status 화면은 제목 포함 전부 본문 폰트(Spoqa Han Sans)를 쓴다.
// 전역 타이포가 h1~h6 에 $font-family-heading(OneShinhan 우선)을 지정하므로 페이지 범위에서 되돌린다.
.as-title-banner,
.as-title-banner h1,
.api-status,
.api-status h1,
.api-status h2,
.api-status h3,
.api-status h4 {
font-family: $font-family-primary;
}
// 타이틀 배너 — 레이아웃의 .container 안에 놓이므로 컨테이너 폭을 따른다
.as-title-banner {
@@ -92,6 +105,9 @@
--as-pill: 999px;
display: grid;
// minmax(0,1fr): grid 자식의 암묵적 min-width(auto)를 해제한다.
// 90일 막대(90개 × 최소폭)가 카드의 최소 폭을 밀어올려 좁은 화면에서 카드가 잘리는 것 방지
grid-template-columns: minmax(0, 1fr);
gap: 20px;
padding: 0 0 70px;
@@ -368,6 +384,8 @@
&.is-maintenance { background: var(--as-info); }
&.is-degraded { background: var(--as-warn); }
&.is-none { background: var(--as-none-bg); }
// 장애·지연·점검 중 2종 이상이 겹친 날
&.is-mixed,
&.is-both { background: var(--as-both); }
}
}
@@ -477,6 +495,7 @@
box-shadow: 0 1px 2px rgba(15, 23, 42, 0.05);
&.is-incident { border-left: 4px solid var(--as-err); }
&.is-degraded { border-left: 4px solid var(--as-warn); }
&.is-maintenance { border-left: 4px solid var(--as-info); }
.as-issue-meta-row {
@@ -498,6 +517,7 @@
}
&.is-incident .as-issue-title { color: var(--as-err); }
&.is-degraded .as-issue-title { color: var(--as-warn); }
&.is-maintenance .as-issue-title { color: var(--as-info); }
}
@@ -585,7 +605,10 @@
transition: opacity 0.15s;
&.has-incident { background: var(--as-err); }
&.has-degraded { background: var(--as-warn); }
&.has-maintenance { background: var(--as-info); }
// 유형이 2종 이상 섞인 날
&.has-mixed,
&.has-both { background: var(--as-both); }
&.is-selected { outline: 2px solid var(--as-text-2); outline-offset: 1px; }
&:hover { opacity: 0.75; }
@@ -732,6 +755,28 @@
}
}
// 포탈에 게시되지 않은 API 필터 안내
.as-unlisted-banner {
display: flex;
align-items: center;
gap: 10px;
padding: 12px 18px;
border: 1px solid var(--as-border);
border-left: 4px solid var(--as-muted);
border-radius: var(--as-radius);
background: #f6f8fa;
font-size: 13px;
color: var(--as-text-3);
b { color: var(--as-text); }
.as-unlisted-icon {
flex: 0 0 auto;
color: var(--as-muted);
font-size: 15px;
}
}
.as-pager {
display: flex;
justify-content: center;
@@ -805,7 +850,14 @@
.as-filter-right { justify-content: space-between; }
}
.as-index-bar { height: 36px; }
// 90일 바: 셀을 균등 축소하지 않고 최소 터치 폭을 보장한 뒤 가로 스크롤
.as-index-bar {
height: 40px;
.as-index-cell { flex: 0 0 12px; }
}
.as-uptime .as-bar-chart .as-bar { flex: 0 0 12px; }
.as-issue-card { padding: 18px 16px; }
.as-issue-title { font-size: 17px; }
@@ -69,9 +69,18 @@
<div class="tab-content" th:classappend="${activeTab == 'testbed'} ? '' : 'active'" id="api-info-tab">
<!-- API Overview Card (Merged with Additional Information) -->
<div class="api-overview-card">
<!--/* 현재 상태는 게시된 장애·점검 공지 기준(/apistatus/current.json). 조회 실패해도 화면은 유지 */-->
<div class="org-section-header org-section-header--agreement api-basic-info-header">
<h3>기본 정보</h3>
<button type="button" class="btn-action-primary md api-apply-btn">API 사용 신청</button>
<div class="api-status-inline" id="apiStatusInline"
th:attr="data-api-id=${apiSpecInfo.apiId},
data-status-url=@{/apistatus/current.json}">
<span class="api-status-inline__label">현재 상태</span>
<span class="api-status-inline__badge is-loading" id="apiStatusBadge">조회 중</span>
<!--/* apiName 은 표시용 - 이슈 이력 화면 필터는 apiId 로 동작한다 */-->
<a class="btn-action-primary md"
th:href="@{/apistatus/issues(apiId=${apiSpecInfo.apiId},apiName=${apiSpecInfo.apiName})}">상태 이력 확인</a>
</div>
</div>
<div class="api-overview-header">
<div class="api-method-badge" th:text="${apiSpecInfo.apiMethod}">GET</div>
@@ -475,6 +484,51 @@
btn.addEventListener('click', requestApiUse);
});
// ===== 기본 정보: 현재 상태 =====
// 게시된 장애·점검 공지 기준(/apistatus/current.json). 상태 이력은 /apistatus/issues?apiId= 로 이어진다.
(function loadApiCurrentStatus() {
const box = document.getElementById('apiStatusInline');
const badge = document.getElementById('apiStatusBadge');
if (!box || !badge) return;
const apiId = box.getAttribute('data-api-id');
const statusUrl = box.getAttribute('data-status-url');
if (!apiId || !statusUrl) return;
const BADGE_CLASS = {
OUTAGE: 'is-outage',
DEGRADED: 'is-degraded',
MAINTENANCE: 'is-maintenance',
NORMAL: 'is-normal'
};
function paint(cls, text, tooltip) {
badge.className = 'api-status-inline__badge ' + cls;
badge.textContent = text;
if (tooltip) badge.setAttribute('title', tooltip);
else badge.removeAttribute('title');
}
fetch(statusUrl + '?apiId=' + encodeURIComponent(apiId), { credentials: 'same-origin' })
.then(function (r) {
if (!r.ok) throw new Error('HTTP ' + r.status);
return r.json();
})
.then(function (status) {
const tooltip = [
status.activeIncidentTitle,
status.statusSince ? '시작 ' + status.statusSince : null,
status.expectedEndAt ? '종료 예정 ' + status.expectedEndAt : null
].filter(Boolean).join('\n');
paint(BADGE_CLASS[status.currentStatus] || 'is-muted',
status.currentStatusLabel || '정상', tooltip);
})
.catch(function (e) {
console.error('API 현재 상태 조회 실패', e);
paint('is-muted', '상태 확인 불가');
});
})();
// ===== DJPGPT0001: 앱 인증 정보 자동 주입 =====
const DEFAULT_TOKEN_API_ID = 'default-token-api-spec';
const appsSelect = document.getElementById('apps');
@@ -75,14 +75,21 @@
</div>
<!-- API Cards Grid -->
<div class="api-card-grid" th:if="${apis != null and !apis.isEmpty()}">
<div class="api-card-grid" th:if="${apis != null and !apis.isEmpty()}"
th:attr="data-status-url=@{/apistatus/current-list.json}">
<div class="api-card" th:each="api : ${apis}" th:data-href="@{/apis/detail(id=${api.apiId})}" role="button"
tabindex="0">
<!-- Group Badge -->
<!-- Group Badge + 현재 상태 태그 -->
<div class="api-card-badges">
<div class="api-card-badge">
<span th:text="${api.apiGroupName}">그룹 이름</span>
</div>
<!--/* 상태 태그 노출은 PTL_PROPERTY(djb.apistatus.api-list-status-badge) 로 제어.
값은 로드 후 JS가 채우며, 비어 있는 동안은 CSS(:empty)로 숨긴다 */-->
<span th:if="${apiStatusBadgeEnabled}" class="api-card-status"
th:attr="data-api-id=${api.apiId}"></span>
</div>
<!-- API Name -->
<h3 class="api-card-title" th:text="${api.apiName}">API 이름</h3>
@@ -152,6 +159,62 @@
});
});
// ===== 카드 현재 상태 태그 =====
// 게시된 장애·점검 공지 기준(/apistatus/current-list.json). 태그 자체는 PTL_PROPERTY 로 노출 제어된다.
(function loadApiCardStatuses() {
const grid = document.querySelector('.api-card-grid');
if (!grid) return;
const statusUrl = grid.getAttribute('data-status-url');
const slots = Array.prototype.slice.call(grid.querySelectorAll('.api-card-status[data-api-id]'));
if (!statusUrl || !slots.length) return;
const BADGE_CLASS = {
OUTAGE: 'is-outage',
DEGRADED: 'is-degraded',
MAINTENANCE: 'is-maintenance',
NORMAL: 'is-normal'
};
const CHUNK = 50; // 서버 일괄 조회 상한(100) 이내로 나눠 요청
// 같은 API 가 여러 카드에 나올 수 있어 apiId → 슬롯 목록으로 묶는다
const slotsByApiId = {};
slots.forEach(function (el) {
const apiId = el.getAttribute('data-api-id');
if (!apiId) return;
(slotsByApiId[apiId] = slotsByApiId[apiId] || []).push(el);
});
const apiIds = Object.keys(slotsByApiId);
function paint(list) {
(list || []).forEach(function (status) {
const targets = slotsByApiId[status.apiId];
const cls = BADGE_CLASS[status.currentStatus];
if (!targets || !cls) return;
targets.forEach(function (el) {
el.className = 'api-card-status ' + cls;
el.textContent = status.currentStatusLabel || '';
if (status.activeIncidentTitle) el.setAttribute('title', status.activeIncidentTitle);
});
});
}
for (let index = 0; index < apiIds.length; index += CHUNK) {
const query = apiIds.slice(index, index + CHUNK).map(function (apiId) {
return 'apiId=' + encodeURIComponent(apiId);
}).join('&');
fetch(statusUrl + '?' + query, { credentials: 'same-origin' })
.then(function (r) {
if (!r.ok) throw new Error('HTTP ' + r.status);
return r.json();
})
.then(paint)
// 상태 조회 실패는 목록 자체를 막지 않는다 (태그는 비어 있는 채로 숨겨진다)
.catch(function (e) { console.error('API 현재 상태 조회 실패', e); });
}
})();
// Category/Service Selection
const menuTitles = document.querySelectorAll('.js-menu-trigger');
menuTitles.forEach(function (title) {
@@ -10,13 +10,16 @@
<div class="as-title-banner">
<div class="as-title-banner-inner">
<h1>API Status</h1>
<div class="as-title-meta" th:if="${lastStatusUpdatedAt != null}">
<p class="as-title-meta-main">
<div class="as-title-meta" th:if="${lastFireAt != null or lastStatusChangedAt != null}">
<p class="as-title-meta-main" th:if="${lastFireAt != null}">
<span class="as-title-dot"></span>
<span>마지막 상태 갱신 </span>
<strong th:text="${#temporals.format(lastStatusUpdatedAt, 'yyyy-MM-dd HH:mm')} + ' KST'">-</strong>
<span>마지막 점검 </span>
<strong th:text="${lastFireRelative}">-</strong>
</p>
<p class="as-title-meta-sub">API 상태 모니터링 최근 반영 시각</p>
<p class="as-title-meta-sub" th:if="${lastFireAt != null}"
th:text="${#temporals.format(lastFireAt, 'yyyy-MM-dd HH:mm')} + ' KST · API 상태 모니터링 실행 시각'">-</p>
<p class="as-title-meta-sub" th:if="${lastStatusChangedAt != null}"
th:text="'마지막 상태 변경 ' + ${#temporals.format(lastStatusChangedAt, 'yyyy-MM-dd HH:mm')} + ' KST'">-</p>
</div>
</div>
</div>
@@ -33,7 +36,7 @@
<div class="as-card-head">
<div>
<h2 th:text="|최근 ${windowDays}일 서비스 상태|">최근 90일 서비스 상태</h2>
<p class="as-desc">막대 1개 = 하루 · 장애점검이 있던 날만 색으로 표시됩니다.
<p class="as-desc">막대 1개 = 하루 · 장애·지연·점검이 있던 날만 색으로 표시됩니다.
막대를 클릭하면 그 날짜의 이슈 이력으로 이동합니다.</p>
</div>
</div>
@@ -47,6 +50,7 @@
<div class="as-legend">
<span><span class="as-sw is-ok"></span>정상</span>
<span><span class="as-sw is-outage"></span>장애</span>
<span><span class="as-sw is-degraded"></span>지연</span>
<span><span class="as-sw is-maintenance"></span>점검</span>
</div>
</section>
@@ -47,8 +47,9 @@
<div class="as-legend">
<span><span class="as-sw is-none"></span>정상 (이슈 없음)</span>
<span><span class="as-sw is-outage"></span>장애만</span>
<span><span class="as-sw is-degraded"></span>지연만</span>
<span><span class="as-sw is-maintenance"></span>점검만</span>
<span><span class="as-sw is-both"></span>장애 + 점검</span>
<span><span class="as-sw is-mixed"></span>복합 (2종 이상)</span>
</div>
</section>
@@ -67,10 +68,11 @@
<div class="as-filter-field as-combo" id="apiCombo">
<label class="as-filter-label" for="filterApiInput">API</label>
<div class="as-field-control">
<!-- type=search: 레이아웃에 비밀번호 팝업(input[type=password])이 늘 포함돼 있어
일반 text 입력은 브라우저가 계정 자동완성 대상으로 오인한다 -->
<input type="search" id="filterApiInput" name="issueApiKeyword" class="as-input"
autocomplete="off" autocorrect="off" autocapitalize="off" spellcheck="false"
<!-- 레이아웃에 비밀번호 팝업(input[type=password])이 늘 포함돼 있어 브라우저가
이 입력을 계정(아이디) 칸으로 오인한다. autocomplete=off 는 Chrome 이 무시하므로
new-password + 초기 readonly(focus 시 해제, JS) 조합으로 자동완성을 차단한다 -->
<input type="search" id="filterApiInput" class="as-input" readonly
autocomplete="new-password" autocorrect="off" autocapitalize="off" spellcheck="false"
data-lpignore="true" data-1p-ignore data-form-type="other"
placeholder="전체 API (API 명 입력)" aria-expanded="false"
role="combobox" aria-controls="filterApiList">
@@ -83,8 +85,9 @@
<div class="as-filter-field">
<label class="as-filter-label" for="filterKindSelect">유형</label>
<select id="filterKindSelect" class="as-input">
<option value="">장애 + 점검</option>
<option value="">전체 유형</option>
<option value="INCIDENT">장애만</option>
<option value="DELAY">지연만</option>
<option value="MAINTENANCE">점검만</option>
</select>
</div>
@@ -95,6 +98,13 @@
</div>
</div>
<!-- 필터 중인 API 가 포탈에 게시되지 않은 경우 안내 -->
<div class="as-unlisted-banner" id="unlistedApiBanner" style="display:none">
<span class="as-unlisted-icon" aria-hidden="true"></span>
<span><b id="unlistedApiName"></b> 은(는) 포탈에 게시되지 않은 API 입니다.
이슈 이력은 조회되지만 API 상세 정보는 제공되지 않습니다.</span>
</div>
<!-- 이슈 목록 -->
<div class="as-issue-list" id="issueList"></div>
<div class="as-pager" id="issuePager"></div>
@@ -11,7 +11,13 @@
<a th:href="@{/agreements/terms}" class="footer-link">이용약관</a>
<span class="footer-separator"></span>
<a href="https://www.jejubank.co.kr/hmpg/csct/secuCenr/ptctPlcy/procsPlcy/ctnt.do"
target="_blank" rel="noopener noreferrer" class="footer-link">개인정보처리방침</a>
target="_blank" rel="noopener noreferrer" class="footer-link footer-link--external">개인정보처리방침<svg class="footer-link-external-icon" width="14" height="14" viewBox="0 0 16 16" fill="none"
xmlns="http://www.w3.org/2000/svg" aria-hidden="true" focusable="false">
<path d="M6.5 2.5H3.2A1.2 1.2 0 0 0 2 3.7v9.1A1.2 1.2 0 0 0 3.2 14h9.1a1.2 1.2 0 0 0 1.2-1.2V9.5"
stroke="currentColor" stroke-width="1.3" stroke-linecap="round" stroke-linejoin="round"/>
<path d="M9.5 2h4.5v4.5M14 2 7.5 8.5" stroke="currentColor" stroke-width="1.3"
stroke-linecap="round" stroke-linejoin="round"/>
</svg><span class="sr-only">새 창으로 열림</span></a>
</div>
<p class="footer-copyright">Copyright &copy; 2026 JEJU Bank. All Rights Reserved.</p>
</div>
@@ -25,10 +25,14 @@
</p>
<!-- Password Input Field -->
<!-- 초기 type=text: 이 팝업은 모든 페이지 DOM 에 상주하므로 type=password 로 두면
브라우저가 페이지의 다른 텍스트 입력을 아이디 칸으로 오인해 계정 자동완성을 띄운다.
팝업을 열 때 JS(custom-popups.js)가 password 로 전환하고 닫을 때 되돌린다. -->
<div class="pop_input_group">
<input type="password"
<input type="text"
id="passwordPopupInput"
class="pop_input_field"
autocomplete="new-password"
placeholder="비밀번호를 입력하세요">
<div id="passwordPopupError" class="error-message"></div>
</div>