guarded = new java.util.LinkedHashSet<>();
+ guarded.add(REVEAL_SECRET);
+ guarded.add(APP_KEY_DELETE);
+ INTERCEPTOR_GUARDED = Collections.unmodifiableSet(guarded);
+ }
+
+ private StepUpProtectedPaths() {
+ }
+
+ /** 공통 2FA 팝업의 유효 대상(purpose)인지 — open redirect / 임의 purpose 차단용 */
+ public static boolean isTwoFactorPurpose(String servletPath) {
+ return servletPath != null
+ && PATH_TO_LEVEL.get(servletPath) == Level.TWO_FACTOR;
+ }
+
+ /** 인터셉터가 진입 시점에 자동 차단하는 경로인지 */
+ public static boolean isInterceptorGuarded(String servletPath) {
+ return servletPath != null && INTERCEPTOR_GUARDED.contains(servletPath);
+ }
+
+ /** 현재 비밀번호 재확인으로 보호하는 경로인지(PASSWORD 레벨) */
+ public static boolean isPasswordGated(String servletPath) {
+ return servletPath != null && PATH_TO_LEVEL.get(servletPath) == Level.PASSWORD;
+ }
+
+ /** 해당 경로의 지점별 활성화 프로퍼티 키. 대상 경로가 아니면 null */
+ public static String propertyKeyOf(String servletPath) {
+ return servletPath == null ? null : PATH_TO_KEY.get(servletPath);
+ }
+
+ /** 지점별 프로퍼티 키 접두 */
+ public static String keyPrefix() {
+ return KEY_PREFIX;
+ }
+}
diff --git a/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorCleanupScheduler.java b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorCleanupScheduler.java
new file mode 100644
index 0000000..d232aa7
--- /dev/null
+++ b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorCleanupScheduler.java
@@ -0,0 +1,43 @@
+package com.eactive.apim.portal.apps.auth.twofactor;
+
+import com.eactive.apim.portal.portaluser.repository.TwoFactorAuthRepository;
+import lombok.RequiredArgsConstructor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.LocalDateTime;
+
+/**
+ * 만료된 2FA 인증번호(PTL_TWO_FACTOR_AUTH) 정리 스케줄러.
+ *
+ * 검증은 접근 시점 lazy 만료 검사만 하므로, 발송 후 검증 없이 방치된 레코드가 남는다.
+ * 1분 주기로 만료분을 일괄 삭제한다.
+ *
+ * 다중화(스케일아웃) 안전성: 작업이 "만료된 행만" 지우는 멱등 delete 라
+ * 여러 인스턴스가 동시에 실행해도 결과가 동일하고 부작용이 없다. 따라서 분산 락
+ * (ShedLock 등)이 필요 없다. 동일 행을 둘이 지우려 하면 한쪽이 0건 삭제로 끝날 뿐이다.
+ */
+@Component
+@RequiredArgsConstructor
+public class TwoFactorCleanupScheduler {
+
+ private static final Logger log = LoggerFactory.getLogger(TwoFactorCleanupScheduler.class);
+
+ private final TwoFactorAuthRepository twoFactorAuthRepository;
+
+ @Scheduled(fixedRate = 60000)
+ @Transactional
+ public void cleanupExpired() {
+ try {
+ int deleted = twoFactorAuthRepository.deleteAllByExpiresAtBefore(LocalDateTime.now());
+ if (deleted > 0) {
+ log.debug("만료된 2FA 인증번호 {}건 정리", deleted);
+ }
+ } catch (Exception e) {
+ log.warn("2FA 인증번호 정리 실패", e);
+ }
+ }
+}
diff --git a/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorContext.java b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorContext.java
new file mode 100644
index 0000000..f5d381a
--- /dev/null
+++ b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorContext.java
@@ -0,0 +1,102 @@
+package com.eactive.apim.portal.apps.auth.twofactor;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 진행 중인 2FA 절차 상태. HTTP 세션에 단일 소스로 보관한다.
+ *
+ * 세션 클러스터링(stage/prod Redis/Ehcache) 대상이므로 {@link Serializable} 이다.
+ * 여러 탭/페이지에서 동시에 2FA 가 발동되지 않도록, 발송 시 이 컨텍스트 존재 여부로
+ * "진행 중" 을 판정하고 confirm 후 강제 종료(force)로만 새 절차를 시작한다.
+ */
+public class TwoFactorContext implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
+ public enum Mode {
+ /** 로그인 1차 인증 통과 후 대기(pending) 상태의 2FA */
+ LOGIN,
+ /** 로그인 이후 민감기능 접근 시 추가 인증(step-up) */
+ STEPUP
+ }
+
+ private Mode mode;
+ /** 발송 채널 (EMAIL | SMS) */
+ private String channel;
+ /** AuthNumberService 에 전달한 실제 수신처 문자열(이메일 소문자 / 휴대폰 digits). 검증 시 동일 값 사용 */
+ private String recipient;
+ /** step-up 대상 보호 경로(purpose). LOGIN 모드에서는 null */
+ private String purpose;
+ /** 발송 시각 */
+ private LocalDateTime startedAt;
+ /** 유효시간(초) */
+ private int ttlSeconds;
+ /** 검증 시도 횟수 */
+ private int attempts;
+
+ public Mode getMode() {
+ return mode;
+ }
+
+ public void setMode(Mode mode) {
+ this.mode = mode;
+ }
+
+ public String getChannel() {
+ return channel;
+ }
+
+ public void setChannel(String channel) {
+ this.channel = channel;
+ }
+
+ public String getRecipient() {
+ return recipient;
+ }
+
+ public void setRecipient(String recipient) {
+ this.recipient = recipient;
+ }
+
+ public String getPurpose() {
+ return purpose;
+ }
+
+ public void setPurpose(String purpose) {
+ this.purpose = purpose;
+ }
+
+ public LocalDateTime getStartedAt() {
+ return startedAt;
+ }
+
+ public void setStartedAt(LocalDateTime startedAt) {
+ this.startedAt = startedAt;
+ }
+
+ public int getTtlSeconds() {
+ return ttlSeconds;
+ }
+
+ public void setTtlSeconds(int ttlSeconds) {
+ this.ttlSeconds = ttlSeconds;
+ }
+
+ public int getAttempts() {
+ return attempts;
+ }
+
+ public void setAttempts(int attempts) {
+ this.attempts = attempts;
+ }
+
+ public int incrementAttempts() {
+ return ++this.attempts;
+ }
+
+ /** startedAt + ttl 기준 만료 여부(세션 컨텍스트 lazy 만료 판정용) */
+ public boolean isExpired(LocalDateTime now) {
+ return startedAt == null || startedAt.plusSeconds(ttlSeconds).isBefore(now);
+ }
+}
diff --git a/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorController.java b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorController.java
new file mode 100644
index 0000000..46f9391
--- /dev/null
+++ b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorController.java
@@ -0,0 +1,90 @@
+package com.eactive.apim.portal.apps.auth.twofactor;
+
+import com.eactive.apim.portal.apps.auth.twofactor.dto.TwoFactorInfoResponse;
+import com.eactive.apim.portal.apps.auth.twofactor.dto.TwoFactorSendResponse;
+import com.eactive.apim.portal.apps.auth.twofactor.dto.TwoFactorVerifyResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.Model;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpSession;
+
+/**
+ * 공통 2FA 팝업 백엔드. 로그인 pending·step-up 을 모두 처리한다.
+ *
+ * 수신처는 서버가 세션 대상 사용자로부터 결정하므로 클라이언트는 채널만 전달한다.
+ * 모든 POST 는 세션 기반 CSRF(X-XSRF-TOKEN) 보호를 받는다.
+ */
+@Controller
+@RequestMapping("/auth/2fa")
+@RequiredArgsConstructor
+public class TwoFactorController {
+
+ private final TwoFactorService twoFactorService;
+
+ /** 팝업 초기 정보(채널·TTL·진행중 여부) */
+ @GetMapping("/info")
+ @ResponseBody
+ public TwoFactorInfoResponse info(@RequestParam(required = false) String purpose, HttpSession session) {
+ return twoFactorService.getInfo(session, purpose);
+ }
+
+ /** 인증번호 발송 */
+ @PostMapping("/send")
+ @ResponseBody
+ public TwoFactorSendResponse send(@RequestParam String channel,
+ @RequestParam(required = false) String purpose,
+ @RequestParam(required = false, defaultValue = "false") boolean force,
+ HttpServletRequest request,
+ HttpSession session) {
+ return twoFactorService.send(request, session, channel, purpose, force);
+ }
+
+ /** 인증번호 검증 */
+ @PostMapping("/verify")
+ @ResponseBody
+ public TwoFactorVerifyResponse verify(@RequestParam String code,
+ HttpServletRequest request,
+ HttpSession session) {
+ return twoFactorService.verify(request, session, code);
+ }
+
+ /** 팝업 닫기/타이머 만료 → 2차 인증 실패 처리 */
+ @PostMapping("/cancel")
+ @ResponseBody
+ public void cancel(@RequestParam(required = false, defaultValue = "CANCELLED") String reason,
+ HttpServletRequest request,
+ HttpSession session) {
+ twoFactorService.cancel(request, session, reason);
+ }
+
+ /**
+ * step-up GET 진입 지점용 챌린지 페이지. 인터셉터가 리다이렉트하며, 화면이 공통 팝업을 자동 오픈한다.
+ * returnUrl 은 보호 경로 화이트리스트로 검증(open redirect 방지)한다.
+ */
+ @GetMapping("/challenge")
+ public String challenge(@RequestParam(required = false) String returnUrl, Model model) {
+ // returnUrl 은 쿼리스트링을 포함할 수 있으므로 경로 부분만 화이트리스트로 검증(open redirect 방지)
+ String purpose = pathOf(returnUrl);
+ if (!StepUpProtectedPaths.isTwoFactorPurpose(purpose)) {
+ return "redirect:/";
+ }
+ model.addAttribute("returnUrl", returnUrl);
+ model.addAttribute("purpose", purpose);
+ return "apps/auth/twoFactorChallenge";
+ }
+
+ private static String pathOf(String url) {
+ if (url == null) {
+ return null;
+ }
+ int q = url.indexOf('?');
+ return q >= 0 ? url.substring(0, q) : url;
+ }
+}
diff --git a/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorProperties.java b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorProperties.java
new file mode 100644
index 0000000..abe8ea9
--- /dev/null
+++ b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorProperties.java
@@ -0,0 +1,119 @@
+package com.eactive.apim.portal.apps.auth.twofactor;
+
+import com.eactive.apim.portal.portalproperty.service.PortalPropertyService;
+import com.eactive.apim.portal.portaluser.entity.PortalUserEnums.RoleCode;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+/**
+ * 2FA 관련 PTL_PROPERTY 접근 래퍼.
+ *
+ * 그룹 {@code Portal}, 점 구분 소문자 키 관례({@code session.timeout.minutes},
+ * {@code org.hard-delete.enabled} 등)를 따른다.
+ * {@link PortalPropertyService#getOrCreateProperty} 는 최초 접근 시 기본값으로 DB row 를
+ * 생성(그룹 존재 시)하므로 별도 초기 데이터가 필요 없다. 캐시가 없어 매 호출 DB 조회지만
+ * 2FA 진입 경로가 제한적이라 허용 범위다.
+ */
+@Component
+@RequiredArgsConstructor
+public class TwoFactorProperties {
+
+ public static final String GROUP = "Portal";
+
+ public static final String KEY_LOGIN_ENABLED = "two-factor.login.enabled";
+ public static final String KEY_LOGIN_TARGET_ROLES = "two-factor.login.target-roles";
+ public static final String KEY_TTL_SECONDS = "two-factor.ttl.seconds";
+ public static final String KEY_ATTEMPT_LIMIT = "two-factor.attempt.limit";
+ public static final String KEY_TEST_NOTICE_ENABLED = "two-factor.test-notice.enabled";
+ public static final String KEY_STEPUP_ENABLED = "two-factor.stepup.enabled";
+
+ private final PortalPropertyService portalPropertyService;
+
+ /** 로그인 2FA 활성화 여부 */
+ public boolean isLoginEnabled() {
+ return parseBool(resolve(KEY_LOGIN_ENABLED, "false", "로그인 2차 인증 활성화 여부 (true/false)"));
+ }
+
+ /**
+ * 로그인 2FA 적용 대상 역할인지 여부.
+ * 프로퍼티 값: 쉼표 구분 RoleCode 목록(예: {@code ROLE_CORP_MANAGER,ROLE_CORP_USER})
+ * 또는 {@code ALL}(전체 대상). 기본값은 법인관리자만.
+ * 미기재 역할은 로그인 2FA 를 건너뛴다(전체 스위치 {@link #isLoginEnabled()}와 AND 동작).
+ */
+ public boolean isLoginTargetRole(RoleCode roleCode) {
+ if (roleCode == null) {
+ roleCode = RoleCode.ROLE_USER;
+ }
+ String value = resolve(KEY_LOGIN_TARGET_ROLES, RoleCode.ROLE_CORP_MANAGER.name(),
+ "로그인 2차 인증 대상 역할 (쉼표구분: ROLE_USER,ROLE_CORP_USER,ROLE_CORP_MANAGER / 전체: ALL)");
+ if (value == null || value.trim().isEmpty()) {
+ return false;
+ }
+ String trimmed = value.trim();
+ if ("ALL".equalsIgnoreCase(trimmed)) {
+ return true;
+ }
+ for (String token : trimmed.split(",")) {
+ if (roleCode.name().equalsIgnoreCase(token.trim())) {
+ return true;
+ }
+ }
+ return false;
+ }
+
+ /** step-up(민감기능) 2FA 전체 활성화 여부(마스터 스위치) */
+ public boolean isStepUpEnabled() {
+ return parseBool(resolve(KEY_STEPUP_ENABLED, "false", "민감기능 추가 인증(step-up) 전체 활성화 여부 (true/false)"));
+ }
+
+ /**
+ * 특정 보호 경로에 step-up 2FA 를 적용할지 여부(지점별 스위치).
+ * 전체 스위치({@link #isStepUpEnabled()})가 켜진 상태에서 지점별로 개별 on/off 한다.
+ * 지점 프로퍼티({@code two-factor.stepup.<지점>})의 기본값은 true(전체 스위치를 켜면 기본 전 지점 적용).
+ *
+ * @param servletPath 보호 경로. 매핑 키가 없으면(비보호 경로) false
+ */
+ public boolean isStepUpPointEnabled(String servletPath) {
+ String key = StepUpProtectedPaths.propertyKeyOf(servletPath);
+ if (key == null) {
+ return false;
+ }
+ return parseBool(resolve(key, "true", "step-up 2FA 지점 적용 여부 (true/false): " + servletPath));
+ }
+
+ /** 2FA 인증번호 유효시간(초). 기본 180초(3분) */
+ public int getTtlSeconds() {
+ return parseInt(resolve(KEY_TTL_SECONDS, "180", "2차 인증번호 유효시간(초)"), 180);
+ }
+
+ /** 인증번호 검증 시도 한도. 기본 5회 */
+ public int getAttemptLimit() {
+ return parseInt(resolve(KEY_ATTEMPT_LIMIT, "5", "2차 인증번호 검증 시도 한도"), 5);
+ }
+
+ /** 팝업에 테스트용 인증번호를 노출할지 여부(개발/테스트 전용) */
+ public boolean isTestNoticeEnabled() {
+ return parseBool(resolve(KEY_TEST_NOTICE_ENABLED, "false", "2차 인증 팝업에 테스트용 인증번호 표시 여부 (true/false)"));
+ }
+
+ private String resolve(String key, String defaultValue, String description) {
+ return portalPropertyService.getOrCreateProperty(GROUP, key, defaultValue, description);
+ }
+
+ /**
+ * boolean PTL_PROPERTY 값 파싱.
+ * DB 관례에 맞춰 true/false 문자열을 사용한다(예: {@code org.hard-delete.enabled=true}).
+ * "true"(대소문자 무시)만 참으로 본다. 그 외(false/공백/null 등)는 모두 거짓.
+ */
+ private static boolean parseBool(String value) {
+ return value != null && "true".equalsIgnoreCase(value.trim());
+ }
+
+ private static int parseInt(String value, int fallback) {
+ try {
+ return Integer.parseInt(value.trim());
+ } catch (Exception e) {
+ return fallback;
+ }
+ }
+}
diff --git a/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorService.java b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorService.java
new file mode 100644
index 0000000..aa1e6b5
--- /dev/null
+++ b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/TwoFactorService.java
@@ -0,0 +1,510 @@
+package com.eactive.apim.portal.apps.auth.twofactor;
+
+import com.eactive.apim.portal.apps.auth.service.AuthNumberService;
+import com.eactive.apim.portal.apps.auth.service.AuthNumberStorage;
+import com.eactive.apim.portal.apps.auth.twofactor.dto.TwoFactorChannel;
+import com.eactive.apim.portal.apps.auth.twofactor.dto.TwoFactorInfoResponse;
+import com.eactive.apim.portal.apps.auth.twofactor.dto.TwoFactorSendResponse;
+import com.eactive.apim.portal.apps.auth.twofactor.dto.TwoFactorVerifyResponse;
+import com.eactive.apim.portal.apps.login.constants.LoginFailureReason;
+import com.eactive.apim.portal.apps.login.constants.LoginType;
+import com.eactive.apim.portal.apps.login.service.LoginFinalizer;
+import com.eactive.apim.portal.apps.user.service.PortalUserAuthService;
+import com.eactive.apim.portal.apps.user.service.PortalUserLogService;
+import com.eactive.apim.portal.common.user.PortalAuthenticatedUser;
+import com.eactive.apim.portal.common.util.PhoneNumberUtil;
+import com.eactive.apim.portal.common.util.SecurityUtil;
+import com.eactive.apim.portal.common.util.StringMaskingUtil;
+import com.eactive.apim.portal.portalorg.entity.PortalOrgEnums;
+import com.eactive.apim.portal.portaluser.entity.PortalUser;
+import com.eactive.apim.portal.portaluser.entity.PortalUserEnums;
+import com.eactive.apim.portal.portaluser.repository.PortalUserRepository;
+import com.eactive.apim.portal.portaluser.service.AuthNumberException;
+import lombok.RequiredArgsConstructor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
+import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.StringUtils;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpSession;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+import java.util.Optional;
+
+/**
+ * 2FA(2차 인증/추가 인증) 공통 서비스. 로그인 pending 인증과 step-up(민감기능) 인증을 모두 처리한다.
+ *
+ * 핵심 원칙:
+ *
+ * - 수신처는 서버가 세션의 대상 사용자로부터 DB 기준으로 결정한다(클라이언트는 채널만 선택).
+ * - 진행 상태는 세션 {@link TwoFactorContext} 단일 소스로 관리한다.
+ * - 다른 플로우가 진행 중이면 발송을 막고(inProgress), confirm 후 force 로만 강제 종료·재시작한다.
+ *
+ */
+@Service
+@Transactional
+@RequiredArgsConstructor
+public class TwoFactorService {
+
+ private static final Logger log = LoggerFactory.getLogger(TwoFactorService.class);
+
+ // === 세션 attribute 키 ===
+ /** 로그인 1차 인증 통과 후 대기 중인 사용자 id (존재 시 LOGIN 모드) */
+ public static final String ATTR_PENDING_USER_ID = "TFA_PENDING_USER_ID";
+ /** 대기 중 사용자 loginId (감사/세션 표기) */
+ public static final String ATTR_PENDING_LOGIN_ID = "TFA_PENDING_LOGIN_ID";
+ /** 진행 중 2FA 컨텍스트 */
+ public static final String ATTR_CONTEXT = "TFA_CONTEXT";
+ /** step-up 1회용 통과권 - 대상 경로 */
+ public static final String ATTR_STEPUP_PASS_PATH = "TFA_STEPUP_PASS_PATH";
+ /** step-up 1회용 통과권 - 발급 시각 */
+ public static final String ATTR_STEPUP_PASS_AT = "TFA_STEPUP_PASS_AT";
+
+ /** step-up 통과권 유효시간(초). 인증 성공 후 대상 페이지 진입까지의 이동 여유분 */
+ public static final int STEPUP_PASS_TTL_SECONDS = 120;
+ /** 재발송/채널전환 통합 최소 간격(초) */
+ private static final int RESEND_THROTTLE_SECONDS = 30;
+
+ private final TwoFactorProperties properties;
+ private final AuthNumberService authNumberService;
+ private final AuthNumberStorage authNumberStorage;
+ private final PortalUserRepository portalUserRepository;
+ private final PortalUserAuthService portalUserAuthService;
+ private final PortalUserLogService userLogService;
+ private final LoginFinalizer loginFinalizer;
+
+ // =========================================================================
+ // INFO
+ // =========================================================================
+
+ public TwoFactorInfoResponse getInfo(HttpSession session, String purpose) {
+ TwoFactorInfoResponse res = new TwoFactorInfoResponse();
+
+ TwoFactorContext.Mode mode = resolveMode(session);
+ if (mode == null) {
+ res.setAvailable(false);
+ return res;
+ }
+ PortalUser user = resolveTargetUser(session, mode);
+ if (user == null) {
+ res.setAvailable(false);
+ return res;
+ }
+
+ res.setAvailable(true);
+ res.setMode(mode.name());
+ res.setChannels(buildChannels(user));
+ res.setTtlSeconds(properties.getTtlSeconds());
+ res.setTestNoticeEnabled(properties.isTestNoticeEnabled());
+
+ TwoFactorContext ctx = getActiveContext(session);
+ if (ctx != null && !isSameFlow(ctx, mode, purpose)) {
+ res.setInProgress(true);
+ res.setMessage("진행 중인 다른 인증 절차가 있습니다.");
+ }
+ return res;
+ }
+
+ // =========================================================================
+ // SEND
+ // =========================================================================
+
+ public TwoFactorSendResponse send(HttpServletRequest request, HttpSession session, String channel,
+ String purpose, boolean force) {
+ TwoFactorSendResponse res = new TwoFactorSendResponse();
+
+ TwoFactorContext.Mode mode = resolveMode(session);
+ if (mode == null) {
+ res.setValid(false);
+ res.setMessage("인증 대상 정보가 없습니다. 다시 시도해주세요.");
+ return res;
+ }
+ if (mode == TwoFactorContext.Mode.STEPUP && !StepUpProtectedPaths.isTwoFactorPurpose(purpose)) {
+ res.setValid(false);
+ res.setMessage("허용되지 않은 요청입니다.");
+ return res;
+ }
+
+ PortalUser user = resolveTargetUser(session, mode);
+ if (user == null) {
+ res.setValid(false);
+ res.setMessage("인증 대상 사용자를 찾을 수 없습니다.");
+ return res;
+ }
+
+ String normalizedChannel = channel == null ? "" : channel.trim().toUpperCase();
+ String recipient = resolveRecipient(user, normalizedChannel);
+ if (recipient == null) {
+ res.setValid(false);
+ res.setMessage("선택한 방법으로 인증할 수 있는 정보가 없습니다.");
+ return res;
+ }
+
+ // 진행 중 컨텍스트 처리
+ TwoFactorContext ctx = getActiveContext(session);
+ if (ctx != null) {
+ boolean sameFlow = isSameFlow(ctx, mode, purpose);
+ if (!sameFlow) {
+ if (!force) {
+ res.setValid(false);
+ res.setInProgress(true);
+ res.setMessage("진행 중인 다른 인증 절차가 있습니다. 강제 종료 후 진행하시겠습니까?");
+ return res;
+ }
+ discardContext(request, session, ctx); // 강제 종료(감사 기록 포함)
+ } else if (ctx.getStartedAt() != null
+ && ctx.getStartedAt().plusSeconds(RESEND_THROTTLE_SECONDS).isAfter(LocalDateTime.now())) {
+ res.setValid(false);
+ res.setMessage("잠시 후에 다시 시도해 주세요.");
+ return res;
+ }
+ }
+
+ int ttl = properties.getTtlSeconds();
+ String authNumber;
+ try {
+ authNumber = authNumberService.sendRequestAuthNumber(recipient,
+ "SMS".equals(normalizedChannel) ? "SMS" : "EMAIL", ttl);
+ } catch (AuthNumberException e) {
+ res.setValid(false);
+ res.setMessage(e.getMessage());
+ return res;
+ }
+
+ TwoFactorContext newCtx = new TwoFactorContext();
+ newCtx.setMode(mode);
+ newCtx.setChannel(normalizedChannel);
+ newCtx.setRecipient(recipient);
+ newCtx.setPurpose(mode == TwoFactorContext.Mode.STEPUP ? purpose : null);
+ newCtx.setStartedAt(LocalDateTime.now());
+ newCtx.setTtlSeconds(ttl);
+ newCtx.setAttempts(0);
+ session.setAttribute(ATTR_CONTEXT, newCtx);
+
+ res.setValid(true);
+ res.setMessage("인증번호를 발송하였습니다.");
+ res.setTtlSeconds(ttl);
+ if (properties.isTestNoticeEnabled()) {
+ res.setTestAuthNumber(authNumber);
+ }
+ return res;
+ }
+
+ // =========================================================================
+ // VERIFY
+ // =========================================================================
+
+ public TwoFactorVerifyResponse verify(HttpServletRequest request, HttpSession session, String code) {
+ TwoFactorVerifyResponse res = new TwoFactorVerifyResponse();
+
+ TwoFactorContext ctx = getActiveContext(session);
+ if (ctx == null) {
+ res.setValid(false);
+ res.setTerminated(true);
+ res.setMessage("인증 시간이 만료되었습니다. 처음부터 다시 진행해주세요.");
+ return res;
+ }
+
+ if (ctx.isExpired(LocalDateTime.now())) {
+ terminateWithFailure(session, ctx, LoginFailureReason.TWO_FACTOR_TIMEOUT, request);
+ res.setValid(false);
+ res.setTerminated(true);
+ res.setMessage("입력 시간이 초과되었습니다. 처음부터 다시 진행해주세요.");
+ return res;
+ }
+
+ int attempts = ctx.incrementAttempts();
+ int limit = properties.getAttemptLimit();
+
+ try {
+ authNumberService.verifyAuthNumber(ctx.getRecipient(), code);
+ } catch (AuthNumberException e) {
+ AuthNumberException.Reason reason = e.getReason();
+ if (reason == AuthNumberException.Reason.EXPIRED || reason == AuthNumberException.Reason.NOT_FOUND) {
+ terminateWithFailure(session, ctx, LoginFailureReason.TWO_FACTOR_TIMEOUT, request);
+ res.setValid(false);
+ res.setTerminated(true);
+ res.setMessage("입력 시간이 초과되었습니다. 처음부터 다시 진행해주세요.");
+ return res;
+ }
+ // 코드 불일치
+ if (attempts >= limit) {
+ terminateWithFailure(session, ctx, LoginFailureReason.TWO_FACTOR_ATTEMPT_EXCEEDED, request);
+ res.setValid(false);
+ res.setTerminated(true);
+ res.setMessage("인증 시도 횟수를 초과했습니다. 처음부터 다시 진행해주세요.");
+ return res;
+ }
+ session.setAttribute(ATTR_CONTEXT, ctx); // attempts 갱신 반영
+ res.setValid(false);
+ res.setRemainingAttempts(limit - attempts);
+ res.setMessage("인증번호가 일치하지 않습니다. (남은 횟수 " + (limit - attempts) + "회)");
+ return res;
+ }
+
+ // 검증 성공 — 인증번호 즉시 소비(재사용 방지, 2FA 한정)
+ authNumberStorage.deleteAuthNumber(ctx.getRecipient());
+ session.removeAttribute(ATTR_CONTEXT);
+
+ if (ctx.getMode() == TwoFactorContext.Mode.LOGIN) {
+ return completeLogin(request, session, res);
+ }
+
+ // STEPUP — 1회용 통과권 발급
+ issueStepUpPass(session, ctx.getPurpose());
+ res.setValid(true);
+ res.setMessage("인증이 완료되었습니다.");
+ return res;
+ }
+
+ private TwoFactorVerifyResponse completeLogin(HttpServletRequest request, HttpSession session,
+ TwoFactorVerifyResponse res) {
+ String userId = (String) session.getAttribute(ATTR_PENDING_USER_ID);
+ String loginId = (String) session.getAttribute(ATTR_PENDING_LOGIN_ID);
+
+ PortalUser user = userId != null ? portalUserRepository.findById(userId).orElse(null) : null;
+ if (user == null) {
+ clearPending(session);
+ res.setValid(false);
+ res.setTerminated(true);
+ res.setMessage("로그인 정보를 찾을 수 없습니다. 다시 로그인해주세요.");
+ return res;
+ }
+
+ // 1차 인증~2FA 사이 상태 변경 방어(잠금/차단/승인 취소)
+ String stateError = revalidateLoginState(user);
+ if (stateError != null) {
+ userLogService.logFailure(loginId, request.getRemoteAddr(), session.getId(),
+ LoginFailureReason.ACCOUNT_DISABLED, request.getHeader("User-Agent"));
+ clearPending(session);
+ res.setValid(false);
+ res.setTerminated(true);
+ res.setMessage(stateError);
+ return res;
+ }
+
+ // 프로그래매틱 인증 확정 (요청 종료 시 SecurityContextPersistenceFilter 가 세션에 저장)
+ PortalAuthenticatedUser authUser = portalUserAuthService.buildAuthenticatedUser(user);
+ UsernamePasswordAuthenticationToken token =
+ new UsernamePasswordAuthenticationToken(authUser, null, authUser.getAuthorities());
+ token.setDetails(authUser);
+ SecurityContextHolder.getContext().setAuthentication(token);
+
+ String redirect = loginFinalizer.finalizeLogin(user, loginId, request, LoginType.TWO_FACTOR);
+ clearPending(session);
+
+ res.setValid(true);
+ res.setRedirect(redirect);
+ res.setMessage("인증이 완료되었습니다.");
+ return res;
+ }
+
+ // =========================================================================
+ // CANCEL (팝업 닫기 / 타이머 만료)
+ // =========================================================================
+
+ public void cancel(HttpServletRequest request, HttpSession session, String reason) {
+ TwoFactorContext ctx = getActiveContext(session);
+ boolean timeout = "TIMEOUT".equalsIgnoreCase(reason);
+ LoginFailureReason failureReason = timeout
+ ? LoginFailureReason.TWO_FACTOR_TIMEOUT : LoginFailureReason.TWO_FACTOR_CANCELLED;
+
+ if (ctx != null && ctx.getMode() == TwoFactorContext.Mode.LOGIN) {
+ String loginId = (String) session.getAttribute(ATTR_PENDING_LOGIN_ID);
+ userLogService.logFailure(loginId, request.getRemoteAddr(), session.getId(), failureReason,
+ request.getHeader("User-Agent"));
+ }
+ if (ctx != null && ctx.getRecipient() != null) {
+ authNumberStorage.deleteAuthNumber(ctx.getRecipient());
+ }
+ session.removeAttribute(ATTR_CONTEXT);
+
+ // 로그인 2FA 취소는 로그인 자체를 포기(익명 유지) → pending 제거
+ if (ctx == null || ctx.getMode() == TwoFactorContext.Mode.LOGIN) {
+ clearPending(session);
+ }
+ }
+
+ // =========================================================================
+ // LOGIN pending 진입 (SuccessHandler 에서 호출)
+ // =========================================================================
+
+ /** 로그인 1차 인증 통과 사용자를 2FA 대기 상태로 세팅한다. (SecurityContext 클리어는 호출부 책임) */
+ public void beginLoginChallenge(HttpSession session, PortalUser user) {
+ session.setAttribute(ATTR_PENDING_USER_ID, user.getId());
+ session.setAttribute(ATTR_PENDING_LOGIN_ID, user.getLoginId());
+ session.removeAttribute(ATTR_CONTEXT);
+ }
+
+ public boolean hasPendingLogin(HttpSession session) {
+ return session != null && session.getAttribute(ATTR_PENDING_USER_ID) != null;
+ }
+
+ // =========================================================================
+ // STEP-UP 통과권
+ // =========================================================================
+
+ private void issueStepUpPass(HttpSession session, String path) {
+ session.setAttribute(ATTR_STEPUP_PASS_PATH, path);
+ session.setAttribute(ATTR_STEPUP_PASS_AT, LocalDateTime.now());
+ }
+
+ /**
+ * 보호 경로 수정 저장 직후 원경로로 되돌아가는 즉시 왕복(예: {@code /mypage} 수정 →
+ * {@code redirect:/mypage})에서 중복 step-up 을 막기 위해 통과권을 재발급한다.
+ *
+ * 경로 고정 + TTL({@link #STEPUP_PASS_TTL_SECONDS}s) 로 1회 왕복만 커버하며,
+ * 이후 새로 {@code /mypage} 에 진입하면 정상적으로 다시 인증을 요구한다("매번 인증" 유지).
+ */
+ public void grantStepUpPass(HttpSession session, String path) {
+ if (session != null && path != null) {
+ issueStepUpPass(session, path);
+ }
+ }
+
+ /**
+ * 지정 경로에 대한 유효한 1회용 통과권이 있으면 소비(제거)하고 true 를 반환한다.
+ * (매번 인증 정책 — 통과권은 즉시 소멸)
+ */
+ public boolean consumeStepUpPass(HttpSession session, String servletPath) {
+ Object passPath = session.getAttribute(ATTR_STEPUP_PASS_PATH);
+ Object passAt = session.getAttribute(ATTR_STEPUP_PASS_AT);
+ if (!(passPath instanceof String) || !(passAt instanceof LocalDateTime)) {
+ return false;
+ }
+ boolean valid = passPath.equals(servletPath)
+ && ((LocalDateTime) passAt).plusSeconds(STEPUP_PASS_TTL_SECONDS).isAfter(LocalDateTime.now());
+ // 매번 인증: 일치/불일치 무관하게 통과권은 이번 판정에서 소멸시킨다.
+ session.removeAttribute(ATTR_STEPUP_PASS_PATH);
+ session.removeAttribute(ATTR_STEPUP_PASS_AT);
+ return valid;
+ }
+
+ // =========================================================================
+ // 내부 helper
+ // =========================================================================
+
+ private TwoFactorContext.Mode resolveMode(HttpSession session) {
+ if (session.getAttribute(ATTR_PENDING_USER_ID) != null) {
+ return TwoFactorContext.Mode.LOGIN;
+ }
+ if (SecurityUtil.isAuthenticated()) {
+ return TwoFactorContext.Mode.STEPUP;
+ }
+ return null;
+ }
+
+ private PortalUser resolveTargetUser(HttpSession session, TwoFactorContext.Mode mode) {
+ if (mode == TwoFactorContext.Mode.LOGIN) {
+ String userId = (String) session.getAttribute(ATTR_PENDING_USER_ID);
+ return userId != null ? portalUserRepository.findById(userId).orElse(null) : null;
+ }
+ PortalAuthenticatedUser current = SecurityUtil.getPortalAuthenticatedUser();
+ if (current == null) {
+ return null;
+ }
+ // 세션 로드 이후 연락처 변경 반영을 위해 DB 재조회
+ return portalUserRepository.findById(current.getId()).orElse(null);
+ }
+
+ private List buildChannels(PortalUser user) {
+ List channels = new ArrayList<>();
+ if (StringUtils.hasText(user.getEmailAddr())) {
+ channels.add(new TwoFactorChannel("EMAIL", StringMaskingUtil.maskEmail(user.getEmailAddr())));
+ }
+ if (StringUtils.hasText(user.getMobileNumber())) {
+ channels.add(new TwoFactorChannel("SMS", StringMaskingUtil.maskMobileNumber(user.getMobileNumber())));
+ }
+ return channels;
+ }
+
+ private String resolveRecipient(PortalUser user, String channel) {
+ if ("EMAIL".equals(channel)) {
+ return StringUtils.hasText(user.getEmailAddr()) ? user.getEmailAddr() : null;
+ }
+ if ("SMS".equals(channel)) {
+ return StringUtils.hasText(user.getMobileNumber())
+ ? PhoneNumberUtil.digitsOnly(user.getMobileNumber()) : null;
+ }
+ return null;
+ }
+
+ private TwoFactorContext getActiveContext(HttpSession session) {
+ Object ctx = session.getAttribute(ATTR_CONTEXT);
+ if (!(ctx instanceof TwoFactorContext)) {
+ return null;
+ }
+ TwoFactorContext context = (TwoFactorContext) ctx;
+ if (context.isExpired(LocalDateTime.now())) {
+ // 만료 컨텍스트는 정리(감사는 verify/cancel 경로에서 처리)
+ session.removeAttribute(ATTR_CONTEXT);
+ if (context.getRecipient() != null) {
+ authNumberStorage.deleteAuthNumber(context.getRecipient());
+ }
+ return null;
+ }
+ return context;
+ }
+
+ private boolean isSameFlow(TwoFactorContext ctx, TwoFactorContext.Mode mode, String purpose) {
+ return ctx.getMode() == mode && Objects.equals(ctx.getPurpose(),
+ mode == TwoFactorContext.Mode.STEPUP ? purpose : null);
+ }
+
+ /** 강제 종료: 인증번호 삭제 + (로그인 컨텍스트면) 취소 감사 기록 */
+ private void discardContext(HttpServletRequest request, HttpSession session, TwoFactorContext ctx) {
+ if (ctx.getMode() == TwoFactorContext.Mode.LOGIN) {
+ String loginId = (String) session.getAttribute(ATTR_PENDING_LOGIN_ID);
+ userLogService.logFailure(loginId, request.getRemoteAddr(), session.getId(),
+ LoginFailureReason.TWO_FACTOR_CANCELLED, request.getHeader("User-Agent"));
+ }
+ if (ctx.getRecipient() != null) {
+ authNumberStorage.deleteAuthNumber(ctx.getRecipient());
+ }
+ session.removeAttribute(ATTR_CONTEXT);
+ }
+
+ /** 검증 실패로 절차 종료: 인증번호 삭제 + 감사 + 컨텍스트/pending 정리 */
+ private void terminateWithFailure(HttpSession session, TwoFactorContext ctx,
+ LoginFailureReason reason, HttpServletRequest request) {
+ if (ctx.getMode() == TwoFactorContext.Mode.LOGIN) {
+ String loginId = (String) session.getAttribute(ATTR_PENDING_LOGIN_ID);
+ userLogService.logFailure(loginId, request.getRemoteAddr(), session.getId(), reason,
+ request.getHeader("User-Agent"));
+ clearPending(session);
+ }
+ if (ctx.getRecipient() != null) {
+ authNumberStorage.deleteAuthNumber(ctx.getRecipient());
+ }
+ session.removeAttribute(ATTR_CONTEXT);
+ }
+
+ private void clearPending(HttpSession session) {
+ session.removeAttribute(ATTR_PENDING_USER_ID);
+ session.removeAttribute(ATTR_PENDING_LOGIN_ID);
+ }
+
+ /** 1차 인증~2FA 사이 계정 상태 재검증. 문제 있으면 사용자 안내 메시지 반환, 정상이면 null */
+ private String revalidateLoginState(PortalUser user) {
+ if ("Y".equalsIgnoreCase(user.getAccountLockYn())) {
+ return "계정이 잠겼습니다. 비밀번호 초기화 또는 관리자에게 문의하세요.";
+ }
+ if (PortalUserEnums.UserStatus.ADMINBLOCK.equals(user.getUserStatus())) {
+ return "법인 관리자에 의해 비활성화된 계정입니다.";
+ }
+ if (PortalUserEnums.ApprovalStatus.PENDING.equals(user.getApprovalStatus())) {
+ return "사용자 승인 대기중입니다.";
+ }
+ if (user.getPortalOrg() != null
+ && !PortalOrgEnums.ApprovalStatus.COMPLETED.equals(user.getPortalOrg().getApprovalStatus())) {
+ return "로그인할 수 없습니다. 관리자에게 문의하세요. (법인 승인대기중)";
+ }
+ return null;
+ }
+}
diff --git a/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/dto/TwoFactorChannel.java b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/dto/TwoFactorChannel.java
new file mode 100644
index 0000000..10b4d6f
--- /dev/null
+++ b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/dto/TwoFactorChannel.java
@@ -0,0 +1,14 @@
+package com.eactive.apim.portal.apps.auth.twofactor.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+/** 2FA 발송 가능 채널 1건. masked 는 화면 표기용 마스킹 수신처. */
+@Data
+@AllArgsConstructor
+public class TwoFactorChannel {
+ /** EMAIL | SMS */
+ private String type;
+ /** 마스킹된 수신처 (예: te**@ex**.com, 010-12**-34**) */
+ private String masked;
+}
diff --git a/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/dto/TwoFactorInfoResponse.java b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/dto/TwoFactorInfoResponse.java
new file mode 100644
index 0000000..16c406d
--- /dev/null
+++ b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/dto/TwoFactorInfoResponse.java
@@ -0,0 +1,24 @@
+package com.eactive.apim.portal.apps.auth.twofactor.dto;
+
+import lombok.Data;
+
+import java.util.List;
+
+/** GET /auth/2fa/info 응답. 팝업 초기 렌더용. */
+@Data
+public class TwoFactorInfoResponse {
+ /** 컨텍스트 유효 여부(로그인 pending 또는 인증 사용자). false 면 팝업 진입 불가 */
+ private boolean available;
+ /** LOGIN | STEPUP */
+ private String mode;
+ /** 발송 가능 채널(휴대폰 없으면 이메일만) */
+ private List channels;
+ /** 인증번호 유효시간(초) — 타이머 초기값 */
+ private int ttlSeconds;
+ /** 테스트용 인증번호 노출 여부 */
+ private boolean testNoticeEnabled;
+ /** 이미 진행 중인 절차 존재 여부(다른 탭/페이지) */
+ private boolean inProgress;
+ /** 진행 중인 절차의 안내 메시지(있으면) */
+ private String message;
+}
diff --git a/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/dto/TwoFactorSendResponse.java b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/dto/TwoFactorSendResponse.java
new file mode 100644
index 0000000..91fd58c
--- /dev/null
+++ b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/dto/TwoFactorSendResponse.java
@@ -0,0 +1,16 @@
+package com.eactive.apim.portal.apps.auth.twofactor.dto;
+
+import lombok.Data;
+
+/** POST /auth/2fa/send 응답. */
+@Data
+public class TwoFactorSendResponse {
+ private boolean valid;
+ private String message;
+ /** 타이머 유효시간(초) */
+ private int ttlSeconds;
+ /** 테스트용 인증번호(테스트 노출 활성 시에만 채워짐) */
+ private String testAuthNumber;
+ /** 이미 진행 중인 절차가 있어 발송을 막은 경우 true (confirm 후 force 재요청 유도) */
+ private boolean inProgress;
+}
diff --git a/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/dto/TwoFactorVerifyResponse.java b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/dto/TwoFactorVerifyResponse.java
new file mode 100644
index 0000000..f164951
--- /dev/null
+++ b/src/main/java/com/eactive/apim/portal/apps/auth/twofactor/dto/TwoFactorVerifyResponse.java
@@ -0,0 +1,16 @@
+package com.eactive.apim.portal.apps.auth.twofactor.dto;
+
+import lombok.Data;
+
+/** POST /auth/2fa/verify 응답. */
+@Data
+public class TwoFactorVerifyResponse {
+ private boolean valid;
+ private String message;
+ /** LOGIN 모드 성공 시 이동 대상 URL */
+ private String redirect;
+ /** 실패 시 남은 시도 횟수 */
+ private int remainingAttempts;
+ /** 시도 초과/타임아웃 등으로 절차가 강제 종료되어 재시작이 필요한 경우 true */
+ private boolean terminated;
+}
diff --git a/src/main/java/com/eactive/apim/portal/apps/commission/constant/Constants.java b/src/main/java/com/eactive/apim/portal/apps/commission/constant/Constants.java
deleted file mode 100755
index 62df1d0..0000000
--- a/src/main/java/com/eactive/apim/portal/apps/commission/constant/Constants.java
+++ /dev/null
@@ -1,26 +0,0 @@
-package com.eactive.apim.portal.apps.commission.constant;
-
-/**
- * Application constants.
- */
-public final class Constants {
-
- public static final String SYSTEM_ACCOUNT = "system";
-
- public static final String APIM_FOR_OBP_KEY = "x-obp-trust-system";
-
- public static final String APIM_CODE_FOR_OBP_KEY = "x-obp-partnercode";
-
- public static final String SMS_URL = "/api/messaging/sms";
-
- public static final String COMMISSION_URL = "/api/billing/billing/findBillingForCondition";
-
- public static final String COMMISSION_PRINT_URL = "/api/billing/billing/findBillingForCondition/print";
-
- public static final String OBP_ORGANIZATION_URL = "/api/customer/findCustomerByBusinessManRegistrationNo/";
-
- public static String LANGUAGE = "ko";
-
- private Constants() {
- }
-}
diff --git a/src/main/java/com/eactive/apim/portal/apps/commission/controller/CommissionController.java b/src/main/java/com/eactive/apim/portal/apps/commission/controller/CommissionController.java
deleted file mode 100755
index 3fb0963..0000000
--- a/src/main/java/com/eactive/apim/portal/apps/commission/controller/CommissionController.java
+++ /dev/null
@@ -1,320 +0,0 @@
-package com.eactive.apim.portal.apps.commission.controller;
-
-import com.eactive.apim.portal.apps.commission.constant.Constants;
-import com.eactive.apim.portal.apps.commission.dto.CommissionDTO;
-import com.eactive.apim.portal.apps.commission.dto.CommissionSearch;
-import com.eactive.apim.portal.apps.commission.exception.ErrorUtil;
-import com.eactive.apim.portal.apps.commission.service.ExternalService;
-import com.eactive.apim.portal.common.util.SecurityUtil;
-import com.eactive.apim.portal.portalproperty.service.PortalPropertyService;
-import com.fasterxml.jackson.databind.DeserializationFeature;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import lombok.RequiredArgsConstructor;
-import org.apache.commons.collections.MapUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.http.ResponseEntity;
-import org.springframework.security.access.annotation.Secured;
-import org.springframework.stereotype.Controller;
-import org.springframework.ui.Model;
-import org.springframework.util.StringUtils;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-
-
-@Controller
-@RequestMapping(value = "/commission")
-@Secured("ROLE_APP")
-@RequiredArgsConstructor
-public class CommissionController {
-
- private final Logger log = LoggerFactory.getLogger(CommissionController.class);
-
- private final ExternalService externalService;
- private final PortalPropertyService portalPropertyService;
- private final ObjectMapper objectMapper = new ObjectMapper()
- .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
-
- @GetMapping("/manage")
- public String commissionManagePage(Model model) {
- // 기본 정보 설정
- model.addAttribute("organization", SecurityUtil.getUserOrg());
- model.addAttribute("noOrgCode", StringUtils.isEmpty(SecurityUtil.getUserOrg().getOrgCode()));
- return "apps/commission/commissionManage";
- }
-
- @GetMapping("/print/{year}/{month}")
- public String commissionPrintPage(
- @PathVariable("year") String year,
- @PathVariable("month") String month,
- Model model) {
-
- CommissionSearch search = new CommissionSearch();
- search.setPartnerCode(SecurityUtil.getUserOrg().getOrgCode());
- search.setYear(year);
- search.setMonth(month);
-
- CommissionResult result = fetchCommissionData(search, Constants.COMMISSION_PRINT_URL);
-
- if (result.hasError()) {
- model.addAttribute("error", result.getError());
- return "apps/commission/commissionPrint";
- }
-
- // Model에 데이터 바인딩
- model.addAttribute("commission", result.getData());
- model.addAttribute("organization", SecurityUtil.getUserOrg().getOrgName());
- model.addAttribute("year", year);
- model.addAttribute("month", month);
- model.addAttribute("toDay", java.time.LocalDate.now().toString());
-
- return "apps/commission/commissionPrint";
- }
-
- // ==================== API Endpoints ====================
-
- @PostMapping("/print/check")
- public ResponseEntity checkPrintData(@RequestBody CommissionSearch search) {
- search.setPartnerCode(SecurityUtil.getUserOrg().getOrgCode());
-
- if (StringUtils.isEmpty(search.getPartnerCode())) {
- return ErrorUtil.create("fail.commission.needPartnerCode");
- }
-
- CommissionResult result = fetchCommissionData(search, Constants.COMMISSION_PRINT_URL);
-
- if (result.hasError()) {
- return ErrorUtil.create("fail.commission.print", result.getError());
- }
-
- return ResponseEntity.ok().body(result.getData());
- }
-
- @PostMapping()
- public ResponseEntity list(@RequestBody CommissionSearch search) {
- search.setPartnerCode(SecurityUtil.getUserOrg().getOrgCode());
-
- if (StringUtils.isEmpty(search.getPartnerCode())) {
- return ErrorUtil.create("fail.commission.needPartnerCode");
- }
-
- CommissionResult result = fetchCommissionData(search, Constants.COMMISSION_URL);
-
- if (result.hasError()) {
- return ErrorUtil.create("fail.commission.list", result.getError());
- }
-
- return ResponseEntity.ok().body(result.getData());
- }
-
- // ==================== Private Methods ====================
-
- /**
- * 외부 API를 호출하여 수수료 데이터를 조회합니다.
- *
- * @param search 검색 조건
- * @param apiPath API 경로 (Constants.COMMISSION_URL 또는 Constants.COMMISSION_PRINT_URL)
- * @return 조회 결과
- */
- private CommissionResult fetchCommissionData(CommissionSearch search, String apiPath) {
- if (StringUtils.isEmpty(search.getPartnerCode())) {
- return CommissionResult.error("파트너 코드가 없습니다.");
- }
-
- try {
- String obmUrl = portalPropertyService.getPortalPropertiesAsMap("Portal").getOrDefault("obp.obm.url", "");
- String url = obmUrl + apiPath;
-
- // 첫 번째 API 호출
- String result = externalService.getResponseHttpPost(url, toJson(search));
- if (StringUtils.isEmpty(result)) {
- return CommissionResult.error("외부 서버 연결에 실패하였습니다.");
- }
-
- HashMap returnObj = objectMapper.readValue(result, HashMap.class);
-
- // 에러 응답 체크
- String errorMessage = extractErrorMessage(returnObj);
- if (errorMessage != null) {
- return CommissionResult.error(errorMessage);
- }
-
- // Together 관련 추가 처리 (000002-01)
- if (StringUtils.pathEquals(search.getPartnerCode(), "000002-01")) {
- log.debug("Found Together : " + search.getPartnerCode());
-
- CommissionSearch togetherSearch = new CommissionSearch();
- togetherSearch.setPartnerCode("000002-02");
- togetherSearch.setYear(search.getYear());
- togetherSearch.setMonth(search.getMonth());
-
- String togetherResult = externalService.getResponseHttpPost(url, toJson(togetherSearch));
- if (StringUtils.isEmpty(togetherResult)) {
- return CommissionResult.error("외부 서버 연결에 실패하였습니다.");
- }
-
- HashMap togetherReturnObj = objectMapper.readValue(togetherResult, HashMap.class);
- log.debug("togetherLendingReturnObj : " + togetherReturnObj.toString());
-
- String togetherErrorMessage = extractErrorMessage(togetherReturnObj);
- if (togetherErrorMessage != null) {
- return CommissionResult.error(togetherErrorMessage);
- }
-
- HashMap mergeMap = mergeCommissionData(returnObj, togetherReturnObj);
- result = objectMapper.writeValueAsString(mergeMap);
- }
-
- CommissionDTO commissionDTO = objectMapper.readValue(result, CommissionDTO.class);
- return CommissionResult.success(commissionDTO);
-
- } catch (Exception e) {
- log.warn(e.getMessage(), e);
- return CommissionResult.error("수수료 조회에 실패하였습니다.");
- }
- }
-
- /**
- * 응답에서 에러 메시지를 추출합니다.
- */
- private String extractErrorMessage(HashMap response) {
- if (!StringUtils.isEmpty(response.get("error"))) {
- HashMap error = (HashMap) response.get("error");
- return error.get("message").toString();
- }
- return null;
- }
-
- private String toJson(CommissionSearch search) {
- try {
- Map jsonMap = new HashMap<>();
- jsonMap.put("partnerCode", search.getPartnerCode());
- // 월을 두 자리로 패딩 (예: 1 -> 01, 12 -> 12)
- String paddedMonth = String.format("%02d", Integer.parseInt(search.getMonth()));
- jsonMap.put("targetOnMonth", search.getYear() + paddedMonth);
-
- return objectMapper.writeValueAsString(jsonMap);
- } catch (Exception e) {
- log.warn("Failed to serialize CommissionSearch to JSON", e);
- return "{}";
- }
- }
-
- /**
- * Safely parse double value from HashMap
- * Handles both numeric types and string representations
- */
- private double safeGetDouble(HashMap map, String key) {
- Object value = map.get(key);
- if (value == null) {
- return 0.0;
- }
- try {
- if (value instanceof Number) {
- return ((Number) value).doubleValue();
- } else if (value instanceof String) {
- return Double.parseDouble((String) value);
- }
- return 0.0;
- } catch (NumberFormatException e) {
- log.warn("Failed to parse double value for key: {} with value: {}", key, value);
- return 0.0;
- }
- }
-
- public HashMap mergeCommissionData(HashMap o1, HashMap o2) {
-
- HashMap mergeMap = new HashMap();
-
- String o1Status = MapUtils.getString(o1, "status");
- String o2Status = MapUtils.getString(o2, "status");
- String resultStatus = null;
- if (Integer.parseInt(o1Status) <= Integer.parseInt(o2Status)) {
- resultStatus = o1Status;
- } else {
- resultStatus = o2Status;
- }
- double apiTotalValueSum = safeGetDouble(o1, "apiTotalValueSum") + safeGetDouble(o2, "apiTotalValueSum");
- double apiSum = safeGetDouble(o1, "apiSum") + safeGetDouble(o2, "apiSum");
- double apiTotalValueSum2 = safeGetDouble(o1, "apiTotalValueSum2") + safeGetDouble(o2, "apiTotalValueSum2");
- double apiSum2 = safeGetDouble(o1, "apiSum2") + safeGetDouble(o2, "apiSum2");
- double productTotalValueCountSum = safeGetDouble(o1, "productTotalValueCountSum") + safeGetDouble(o2, "productTotalValueCountSum");
- double productTotalValueAmountSum = safeGetDouble(o1, "productTotalValueAmountSum") + safeGetDouble(o2, "productTotalValueAmountSum");
- double productSum = safeGetDouble(o1, "productSum") + safeGetDouble(o2, "productSum");
- double productTotalValueCountSum2 = safeGetDouble(o1, "productTotalValueCountSum2") + safeGetDouble(o2, "productTotalValueCountSum2");
- double productTotalValueAmountSum2 = safeGetDouble(o1, "productTotalValueAmountSum2") + safeGetDouble(o2, "productTotalValueAmountSum2");
- double productSum2 = safeGetDouble(o1, "productSum2") + safeGetDouble(o2, "productSum2");
- double totalValueCountSum = safeGetDouble(o1, "totalValueCountSum") + safeGetDouble(o2, "totalValueCountSum");
- double totalValueCountSum2 = safeGetDouble(o1, "totalValueCountSum2") + safeGetDouble(o2, "totalValueCountSum2");
- double totalValueAmountSum = safeGetDouble(o1, "totalValueAmountSum") + safeGetDouble(o2, "totalValueAmountSum");
- double totalValueAmountSum2 = safeGetDouble(o1, "totalValueAmountSum2") + safeGetDouble(o2, "totalValueAmountSum2");
- double sum = safeGetDouble(o1, "sum") + safeGetDouble(o2, "sum");
- double sum2 = safeGetDouble(o1, "sum2") + safeGetDouble(o2, "sum2");
-
- List
+ 
+ 
+ 
+ 
+ 
+