ProfileService.java

package life.mosu.mosuserver.application.profile;

import life.mosu.mosuserver.domain.profile.entity.Gender;
import life.mosu.mosuserver.domain.profile.entity.ProfileJpaEntity;
import life.mosu.mosuserver.domain.profile.repository.ProfileJpaRepository;
import life.mosu.mosuserver.domain.user.entity.UserJpaEntity;
import life.mosu.mosuserver.domain.user.entity.UserRole;
import life.mosu.mosuserver.domain.user.repository.UserJpaRepository;
import life.mosu.mosuserver.global.exception.CustomRuntimeException;
import life.mosu.mosuserver.global.exception.ErrorCode;
import life.mosu.mosuserver.global.util.PhoneNumberUtil;
import life.mosu.mosuserver.presentation.profile.dto.EditProfileRequest;
import life.mosu.mosuserver.presentation.profile.dto.ProfileDetailResponse;
import life.mosu.mosuserver.presentation.profile.dto.SignUpProfileRequest;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.dao.DataIntegrityViolationException;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

@Slf4j
@Service
@RequiredArgsConstructor
public class ProfileService {

    private final UserJpaRepository userRepository;
    private final ProfileJpaRepository profileJpaRepository;

    private final ProfileEventTxService eventTxService;

    @Transactional
    public void registerProfile(Long userId, SignUpProfileRequest request) {
        UserJpaEntity user = userRepository.findById(userId).orElseThrow(
                () -> new CustomRuntimeException(ErrorCode.USER_NOT_FOUND, userId)
        );
        checkIfProfileExistsForUser(user);

        try {
            ProfileJpaEntity profile = request.toEntity(userId);
            profileJpaRepository.save(profile);

            user.grantUserRole();
            syncUserInfoFromProfile(user, request);

            eventTxService.publishSuccessEvent(userId);

        } catch (DataIntegrityViolationException ex) {
            throw new CustomRuntimeException(ErrorCode.PROFILE_ALREADY_EXISTS, userId);
        } catch (Exception ex) {
            log.error("프로필 등록 실패: {}", ex.getMessage(), ex);
            throw ex;
        }

    }

    @Transactional
    public void editProfile(Long userId, EditProfileRequest request) {
        ProfileJpaEntity profile = profileJpaRepository.findByUserId(userId)
                .orElseThrow(() -> new CustomRuntimeException(ErrorCode.PROFILE_NOT_FOUND, userId));

        profile.edit(request);
    }

    @Transactional(readOnly = true, propagation = Propagation.SUPPORTS)
    public ProfileDetailResponse getProfile(Long userId) {
        ProfileJpaEntity profile = profileJpaRepository.findByUserId(userId)
                .orElseThrow(
                        () -> new CustomRuntimeException(ErrorCode.PROFILE_DOES_NOT_EXIST, userId));

        return ProfileDetailResponse.from(profile);
    }

    private void checkIfProfileExistsForUser(UserJpaEntity user) {
        if (user.getUserRole() != UserRole.ROLE_PENDING) {
            throw new CustomRuntimeException(ErrorCode.PROFILE_ALREADY_EXISTS, user.getId());
        }
    }

    private void syncUserInfoFromProfile(UserJpaEntity user, SignUpProfileRequest request) {
        if (user.isMosuUser()) {
            user.updateUserInfo(Gender.fromName(request.gender()), request.userName(),
                    PhoneNumberUtil.formatPhoneNumber(request.phoneNumber()), request.birth());
        }
    }
}