역할 기반 알림 대상 조회는 + * {@code com.eactive.apim.portal.djb.swing.repository.SwingStaffRepository} 로 분리했다.
+ */ @EMSDataSource public interface UserInfoRepository extends BaseRepositorySwing 메신저는 {@code TSEAIRM02.USERID} 를 수신자 코드로 사용하며 운영 직원은 숫자 행번을 쓴다. + * portal-admin 역할이 부여된 개발용 계정(영문 ID 등)은 Swing 에 존재하지 않아 발송이 무의미하므로 + * 이 정책으로 처리 방식을 선택한다. PTL_PROPERTY + * {@code Portal / djb.swing.notify.non-employee.policy} 로 지정한다.
+ */ +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; + } +} diff --git a/src/main/java/com/eactive/apim/portal/djb/swing/SwingMessageWriter.java b/src/main/java/com/eactive/apim/portal/djb/swing/SwingMessageWriter.java new file mode 100644 index 0000000..b80bc11 --- /dev/null +++ b/src/main/java/com/eactive/apim/portal/djb/swing/SwingMessageWriter.java @@ -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 에 직접 적재한다. + * + *TSEAIRM02(직원) → PTL_MESSAGE_TEMPLATE(본문) → PTL_MESSAGE_REQUEST(발송 요청) 순으로 + * 처리하며, 실제 발송은 기존과 동일하게 eapim-admin 의 {@code UmsDispatchJob}(5초 주기)이 + * {@code REQUEST_STATUS='PENDING'} 행을 수집해 수행한다.
+ */ +@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포털 사용자용 범용 발송 경로({@code MessageHandlerService} → {@code MessageSendService})를 + * 타지 않고 TSEAIRM02 / PTL_MESSAGE_TEMPLATE / PTL_MESSAGE_REQUEST 를 직접 다룬다. + * 내부 직원은 수신자 ID 체계(행번)와 채널(메신저 단일)이 포털 사용자와 완전히 달라 분리했다.
+ * + *비동기 실행이므로 게시물 등록 트랜잭션과 분리된다. 발송 적재 실패가 등록을 되돌리지 않는 대신, + * 등록이 롤백돼도 알림은 남을 수 있다.
+ */ +@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그룹 {@code Portal}, 점 구분 소문자 키 관례를 따른다. + * {@link PortalPropertyService#getOrCreateProperty} 는 최초 접근 시 기본값으로 DB row 를 + * 생성하므로 별도 초기 데이터 없이도 동작한다.
+ */ +@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게시물 등록 트랜잭션이 메신저 알림 적재를 기다리지 않도록 분리한다. + * eapim-admin 의 {@code WebhookAsyncConfig} 와 동일한 구성.
+ */ +@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; + } +} diff --git a/src/main/java/com/eactive/apim/portal/djb/swing/repository/SwingStaffRepository.java b/src/main/java/com/eactive/apim/portal/djb/swing/repository/SwingStaffRepository.java new file mode 100644 index 0000000..e3c8030 --- /dev/null +++ b/src/main/java/com/eactive/apim/portal/djb/swing/repository/SwingStaffRepository.java @@ -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