diff --git a/src/main/java/com/eactive/apim/portal/apps/auth/service/AuthNumberService.java b/src/main/java/com/eactive/apim/portal/apps/auth/service/AuthNumberService.java
index a142517..b747af2 100644
--- a/src/main/java/com/eactive/apim/portal/apps/auth/service/AuthNumberService.java
+++ b/src/main/java/com/eactive/apim/portal/apps/auth/service/AuthNumberService.java
@@ -4,11 +4,23 @@ public interface AuthNumberService {
String sendRequestAuthNumber(String recipientKey, String msgType);
+ /**
+ * 기본 TTL 로 발송하되 수신자 이름을 지정한다. 세 번째 인자가 int 인 오버로드(TTL 지정)와 혼동하지 말 것.
+ */
+ String sendRequestAuthNumber(String recipientKey, String msgType, String username);
+
/**
* 인증번호를 지정한 유효시간(초)으로 발송한다. 로그인/step-up 2FA 는 회원가입 기본 TTL 과
* 다른 값을 쓸 수 있으므로 호출부에서 TTL 을 지정한다.
*/
String sendRequestAuthNumber(String recipientKey, String msgType, int ttlSeconds);
+ /**
+ * 수신자 이름을 지정해 인증번호를 발송한다. 메시지 템플릿의 %USER_NAME% 치환에 사용되며,
+ * 회원가입·아이디/비밀번호 찾기처럼 사용자 이름을 알 수 없는 흐름은 "guest" 를 넘긴다.
+ * username 이 비어 있으면 %USER_NAME% 은 치환되지 않고 원문이 그대로 남는다.
+ */
+ String sendRequestAuthNumber(String recipientKey, String msgType, int ttlSeconds, String username);
+
boolean verifyAuthNumber(String recipientKey, String authNumber);
}
diff --git a/src/main/java/com/eactive/apim/portal/apps/auth/service/AuthNumberServiceImpl.java b/src/main/java/com/eactive/apim/portal/apps/auth/service/AuthNumberServiceImpl.java
index ce08043..b140f76 100644
--- a/src/main/java/com/eactive/apim/portal/apps/auth/service/AuthNumberServiceImpl.java
+++ b/src/main/java/com/eactive/apim/portal/apps/auth/service/AuthNumberServiceImpl.java
@@ -45,19 +45,31 @@ public class AuthNumberServiceImpl implements AuthNumberService {
@Override
@Transactional(noRollbackFor = AuthNumberException.class)
public String sendRequestAuthNumber(String recipientKey, String msgType) {
- return sendRequestAuthNumber(recipientKey, msgType, authNumberExpirationTime);
+ return sendRequestAuthNumber(recipientKey, msgType, authNumberExpirationTime, null);
+ }
+
+ @Override
+ @Transactional(noRollbackFor = AuthNumberException.class)
+ public String sendRequestAuthNumber(String recipientKey, String msgType, String username) {
+ return sendRequestAuthNumber(recipientKey, msgType, authNumberExpirationTime, username);
}
@Override
@Transactional(noRollbackFor = AuthNumberException.class)
public String sendRequestAuthNumber(String recipientKey, String msgType, int ttlSeconds) {
+ return sendRequestAuthNumber(recipientKey, msgType, ttlSeconds, null);
+ }
+
+ @Override
+ @Transactional(noRollbackFor = AuthNumberException.class)
+ public String sendRequestAuthNumber(String recipientKey, String msgType, int ttlSeconds, String username) {
logger.info("Sending auth number to: {} via {} (ttl={}s)", recipientKey, msgType, ttlSeconds);
validateResendTime(recipientKey);
String authNumber = generator.generateAuthNumber();
- MessageRecipient recipient = createMessageRecipient(recipientKey, msgType);
+ MessageRecipient recipient = createMessageRecipient(recipientKey, msgType, username);
messageSender.sendAuthMessage(recipient, authNumber, msgType);
storage.saveAuthNumber(recipientKey, authNumber,
@@ -99,9 +111,13 @@ public class AuthNumberServiceImpl implements AuthNumberService {
});
}
- private MessageRecipient createMessageRecipient(String recipientKey, String msgType) {
+ private MessageRecipient createMessageRecipient(String recipientKey, String msgType, String username) {
MessageRecipient recipient = new MessageRecipient();
recipient.setUserId(recipientKey);
+ // 메시지 템플릿 %USER_NAME% 치환용. 비어 있으면 MessageSendService 가 파라미터 자체를 넣지 않는다.
+ if (username != null && !username.trim().isEmpty()) {
+ recipient.setUsername(username);
+ }
if ("SMS".equalsIgnoreCase(msgType)) {
recipient.setPhone(recipientKey);
} else if ("EMAIL".equalsIgnoreCase(msgType)) {
diff --git a/src/main/java/com/eactive/apim/portal/apps/user/facade/AuthFacadeImpl.java b/src/main/java/com/eactive/apim/portal/apps/user/facade/AuthFacadeImpl.java
index b4ec6b1..0c3776e 100644
--- a/src/main/java/com/eactive/apim/portal/apps/user/facade/AuthFacadeImpl.java
+++ b/src/main/java/com/eactive/apim/portal/apps/user/facade/AuthFacadeImpl.java
@@ -17,6 +17,12 @@ public class AuthFacadeImpl implements AuthFacade {
private final AuthNoticeProperties authNoticeProperties;
private static final Logger log = LoggerFactory.getLogger(AuthFacadeImpl.class);
+ /**
+ * 회원가입·아이디/비밀번호 찾기 등 로그인 이전 흐름은 수신자 이름을 알 수 없으므로
+ * 메시지 템플릿 %USER_NAME% 자리에 넣을 기본값.
+ */
+ private static final String GUEST_USER_NAME = "guest";
+
/**
* 인증 요청
@@ -43,7 +49,7 @@ public class AuthFacadeImpl implements AuthFacade {
}
try {
- String generatedAuthNumber = authNumberService.sendRequestAuthNumber(recipientKey, msgType);
+ String generatedAuthNumber = authNumberService.sendRequestAuthNumber(recipientKey, msgType, GUEST_USER_NAME);
response.setValid(true);
response.setMessage("인증번호를 발송하였습니다.");
// 테스트 환경(PTL_PROPERTY auth.test-notice.enabled=true, prod 제외)에서만 인증번호를 응답에 노출
diff --git a/src/main/java/com/eactive/apim/portal/common/migration/LegacyEncryptionMigrationController.java b/src/main/java/com/eactive/apim/portal/common/migration/LegacyEncryptionMigrationController.java
index c539cbc..c9d4680 100644
--- a/src/main/java/com/eactive/apim/portal/common/migration/LegacyEncryptionMigrationController.java
+++ b/src/main/java/com/eactive/apim/portal/common/migration/LegacyEncryptionMigrationController.java
@@ -2,6 +2,7 @@ package com.eactive.apim.portal.common.migration;
import com.eactive.apim.portal.common.util.StringMaskingUtil;
import com.eactive.apim.portal.jpa.PersonalDataEncryptConverter;
+import com.eactive.apim.portal.portalproperty.service.PortalPropertyService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.http.HttpStatus;
@@ -20,6 +21,8 @@ import java.util.Arrays;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
/**
* [임시] 레거시 평문 데이터를 {@link PersonalDataEncryptConverter} 규칙으로 일괄 정규화(암호화)하는 운영 도구.
@@ -29,15 +32,19 @@ import java.util.Map;
* 쓰기에서 무조건 인코딩하므로, {@code convertToDatabaseColumn(convertToEntityAttribute(x))}는
* 평문→인코딩, 인코딩→동일값(멱등)으로 정규화된다. 이 값이 기존과 다를 때만 UPDATE 한다.
*
- *
보안: 오직 127.0.0.1(localhost)에서 직접 호출한 요청만 허용한다. 기본은 dry-run(미변경)이며,
- * 실제 실행은 {@code dryRun=false}를 명시해야 한다. 작업 완료 후 이 클래스는 제거한다.
+ *
보안: PTL_PROPERTY {@code Portal / migration.internal.allow-ips} 허용 IP 목록(콤마 구분,
+ * 기본 loopback)에 포함된 IP 의 직접 호출만 허용한다 ({@code MenuInternalController} 모델).
+ * 운영 서버는 bind IP 가 NIC IP 라 loopback 호출이 불가하므로, 실행 전 property 에 호출자 IP 를
+ * 추가하고 작업 완료 후 원복한다. 프록시 경유(X-Forwarded-For 존재) 요청은 거부한다.
+ * 기본은 dry-run(미변경)이며, 실제 실행은 {@code dryRun=false}를 명시해야 한다.
+ * 작업 완료 후 이 클래스는 제거한다.
*
*
* # 미리보기(변경 안 함)
* curl -X POST 'http://127.0.0.1:39130/internal/migration/encrypt-legacy'
* # 실제 실행 (PII 컬럼)
* curl -X POST 'http://127.0.0.1:39130/internal/migration/encrypt-legacy?dryRun=false'
- * # audit 컬럼(created_by/last_modified_by, 15개 테이블)까지 포함
+ * # audit 컬럼(created_by/last_modified_by, 19개 테이블)까지 포함
* curl -X POST 'http://127.0.0.1:39130/internal/migration/encrypt-legacy?dryRun=false&includeAudit=true'
*
*/
@@ -46,13 +53,14 @@ import java.util.Map;
@RequestMapping("/internal/migration")
public class LegacyEncryptionMigrationController {
- /** PII 직접 컬럼 (로그인/검색에 직접 영향) */
+ /** PII 직접 컬럼 (로그인/검색에 직접 영향). ofctelno 는 admin(UnifbwkManService)이 컨버터를 수동 호출해 암호화하는 컬럼 */
private static final List PII_TARGETS = Arrays.asList(
new TargetTable("PTL_USER", Arrays.asList("login_id", "email_addr", "phone_number", "mobile_number")),
new TargetTable("PTL_MESSAGE_REQUEST", Arrays.asList("email", "phone")),
- new TargetTable("tseairm02", Arrays.asList("cphnno", "emad")),
+ new TargetTable("tseairm02", Arrays.asList("cphnno", "emad", "ofctelno")),
new TargetTable("PTL_USER_LOG", Arrays.asList("login_id")),
- new TargetTable("PTL_TWO_FACTOR_AUTH", Arrays.asList("recipient"))
+ new TargetTable("PTL_TWO_FACTOR_AUTH", Arrays.asList("recipient")),
+ new TargetTable("PTL_USER_INVITATION", Arrays.asList("INVITATION_MOBILE"))
);
/** Auditable(@MappedSuperclass) 상속 테이블의 감사 컬럼 (옵션) */
@@ -61,16 +69,24 @@ public class LegacyEncryptionMigrationController {
"DJB_APISTATUS_INCIDENT", "DJB_APISTATUS_INCIDENT_TIMELINE", "DJB_APISTATUS_INCIDENT_API",
"ptl_file", "PTL_MESSAGE_TEMPLATE", "ptl_notice", "ptl_terms",
"ptl_user_privacy_policy_agreement", "ptl_approval_line",
- "PTL_INQUIRY_COMMENT", "ptl_inquiry", "ptl_partnership_application"
+ "PTL_INQUIRY_COMMENT", "ptl_inquiry", "ptl_partnership_application",
+ "PTL_MENU_ITEM", "PTL_MENU_PLACEMENT", "PTL_ROLE", "PTL_ROLE_AUTHORITY"
);
private static final List AUDIT_COLUMNS = Arrays.asList("created_by", "last_modified_by");
+ static final String PROP_GROUP = "Portal";
+ static final String PROP_ALLOW_IPS = "migration.internal.allow-ips";
+ static final String DEFAULT_ALLOW_IPS = "127.0.0.1,::1";
+
private final JdbcTemplate jdbcTemplate;
+ private final PortalPropertyService portalPropertyService;
private final PersonalDataEncryptConverter converter = new PersonalDataEncryptConverter();
- public LegacyEncryptionMigrationController(@Qualifier("portalDataSource") DataSource emsDataSource) {
+ public LegacyEncryptionMigrationController(@Qualifier("portalDataSource") DataSource emsDataSource,
+ PortalPropertyService portalPropertyService) {
// EMS(EMSAPP) 스키마 데이터소스. 컨버터 적용 테이블은 모두 EMS에 존재한다.
this.jdbcTemplate = new JdbcTemplate(emsDataSource);
+ this.portalPropertyService = portalPropertyService;
}
@PostMapping("/encrypt-legacy")
@@ -78,7 +94,7 @@ public class LegacyEncryptionMigrationController {
public Map encryptLegacy(HttpServletRequest request,
@RequestParam(defaultValue = "true") boolean dryRun,
@RequestParam(defaultValue = "false") boolean includeAudit) {
- assertLocalOnly(request);
+ assertAllowedIp(request);
assertNotBypass();
List targets = new ArrayList<>(PII_TARGETS);
@@ -90,24 +106,36 @@ public class LegacyEncryptionMigrationController {
List