feat: 미션 인증 생성/조회 구현

build.gradle

@@ -53,6 +53,9 @@ dependencies {
     // javax.xml.bind
     implementation 'javax.xml.bind:jaxb-api:2.4.0-b180830.0359'
 
+    // object storage
+    implementation 'org.springframework.cloud:spring-cloud-starter-aws:2.2.6.RELEASE'
+
     compileOnly 'org.projectlombok:lombok'
     annotationProcessor 'org.projectlombok:lombok'
     testRuntimeOnly 'org.junit.platform:junit-platform-launcher'

src/main/java/com/nexters/goalpanzi/application/auth/AuthService.java

@@ -6,10 +6,10 @@
 import com.nexters.goalpanzi.application.auth.dto.TokenResponse;
 import com.nexters.goalpanzi.common.jwt.Jwt;
 import com.nexters.goalpanzi.common.jwt.JwtProvider;
-import com.nexters.goalpanzi.domain.auth.RefreshTokenRepository;
+import com.nexters.goalpanzi.domain.auth.repository.RefreshTokenRepository;
 import com.nexters.goalpanzi.domain.member.Member;
-import com.nexters.goalpanzi.domain.member.repository.MemberRepository;
 import com.nexters.goalpanzi.domain.member.SocialType;
+import com.nexters.goalpanzi.domain.member.repository.MemberRepository;
 import com.nexters.goalpanzi.exception.ErrorCode;
 import com.nexters.goalpanzi.exception.UnauthorizedException;
 import lombok.RequiredArgsConstructor;

src/main/java/com/nexters/goalpanzi/application/mission/MissionVerificationService.java

@@ -0,0 +1,113 @@
+package com.nexters.goalpanzi.application.mission;
+
+import com.nexters.goalpanzi.application.mission.dto.CreateMissionVerificationCommand;
+import com.nexters.goalpanzi.application.mission.dto.MissionVerificationCommand;
+import com.nexters.goalpanzi.application.mission.dto.MissionVerificationResponse;
+import com.nexters.goalpanzi.application.mission.dto.MyMissionVerificationCommand;
+import com.nexters.goalpanzi.domain.member.Member;
+import com.nexters.goalpanzi.domain.member.repository.MemberRepository;
+import com.nexters.goalpanzi.domain.mission.Mission;
+import com.nexters.goalpanzi.domain.mission.MissionMember;
+import com.nexters.goalpanzi.domain.mission.MissionVerification;
+import com.nexters.goalpanzi.domain.mission.repository.MissionMemberRepository;
+import com.nexters.goalpanzi.domain.mission.repository.MissionRepository;
+import com.nexters.goalpanzi.domain.mission.repository.MissionVerificationRepository;
+import com.nexters.goalpanzi.exception.BadRequestException;
+import com.nexters.goalpanzi.exception.ErrorCode;
+import com.nexters.goalpanzi.exception.NotFoundException;
+import com.nexters.goalpanzi.infrastructure.ncp.ObjectStorageManager;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.Comparator;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+@RequiredArgsConstructor
+@Service
+public class MissionVerificationService {
+
+    private final MissionRepository missionRepository;
+    private final MissionVerificationRepository missionVerificationRepository;
+    private final MissionMemberRepository missionMemberRepository;
+    private final MemberRepository memberRepository;
+
+    private final ObjectStorageManager objectStorageManager;
+
+    @Transactional(readOnly = true)
+    public List<MissionVerificationResponse> getVerifications(final MissionVerificationCommand command) {
+        LocalDate date = command.date() != null ? command.date() : LocalDate.now();
+        Member member =
+                memberRepository.findById(command.memberId())
+                        .orElseThrow(() -> new NotFoundException(ErrorCode.NOT_FOUND_MEMBER));
+        List<MissionMember> missionMembers = missionMemberRepository.findAllByMissionId(command.missionId());
+        List<MissionVerification> verifications = missionVerificationRepository.findAllByMissionIdAndDate(command.missionId(), date);
+
+        Map<Long, MissionVerification> verificationMap = verifications.stream()
+                .collect(Collectors.toMap(v -> v.getMember().getId(), v -> v));
+
+        return missionMembers.stream()
+                .map(m -> {
+                    MissionVerification v = verificationMap.get(m.getMember().getId());
+                    return v != null
+                            ? MissionVerificationResponse.verified(m.getMember(), v)
+                            : MissionVerificationResponse.notVerified(m.getMember());
+                })
+                .sorted(Comparator.comparing((MissionVerificationResponse r) -> r.nickname().equals(member.getNickname())).reversed()
+                        .thenComparing(MissionVerificationResponse::verifiedAt, Comparator.nullsLast(Comparator.reverseOrder())))
+                .collect(Collectors.toList());
+    }
+
+    @Transactional(readOnly = true)
+    public MissionVerificationResponse getMyVerification(final MyMissionVerificationCommand command) {
+        Member member =
+                memberRepository.findById(command.memberId())
+                        .orElseThrow(() -> new NotFoundException(ErrorCode.NOT_FOUND_MEMBER));
+        MissionVerification verification =
+                missionVerificationRepository.findByMemberIdAndMissionIdAndBoardNumber(command.memberId(), command.missionId(), command.number())
+                        .orElseThrow(() -> new NotFoundException(ErrorCode.NOT_FOUND_VERIFICATION));
+
+        return MissionVerificationResponse.verified(member, verification);
+    }
+
+    @Transactional
+    public void createVerification(final CreateMissionVerificationCommand command) {
+        Member member =
+                memberRepository.findById(command.memberId())
+                        .orElseThrow(() -> new NotFoundException(ErrorCode.NOT_FOUND_MEMBER));
+        Mission mission =
+                missionRepository.findById(command.missionId())
+                        .orElseThrow(() -> new NotFoundException("TODO"));
+        MissionMember missionMember =
+                missionMemberRepository.findByMemberIdAndMissionId(command.memberId(), command.missionId())
+                        .orElseThrow(() -> new NotFoundException("TODO"));
+
+        checkVerificationValidation(command.memberId(), command.missionId(), mission, missionMember);
+
+        String imageUrl = objectStorageManager.uploadFile(command.imageFile());
+        missionVerificationRepository.save(new MissionVerification(member, mission, imageUrl));
+        missionMember.verify();
+    }
+
+    private void checkVerificationValidation(final Long memberId, final Long missionId, final Mission mission, final MissionMember missionMember) {
+        if (isCompletedMission(mission, missionMember)) {
+            throw new BadRequestException(ErrorCode.ALREADY_COMPLETED_MISSION);
+        }
+        if (isDuplicatedVerification(memberId, missionId)) {
+            throw new BadRequestException(ErrorCode.DUPLICATE_VERIFICATION);
+        }
+    }
+
+    private boolean isCompletedMission(final Mission mission, final MissionMember missionMember) {
+        return missionMember.getVerificationCount() >= mission.getBoardCount();
+    }
+
+    private boolean isDuplicatedVerification(final Long memberId, final Long missionId) {
+        LocalDate today = LocalDateTime.now().toLocalDate();
+        return missionVerificationRepository.findByMemberIdAndMissionIdAndDate(memberId, missionId, today).isPresent();
+    }
+}

src/main/java/com/nexters/goalpanzi/application/mission/dto/CreateMissionVerificationCommand.java

@@ -0,0 +1,10 @@
+package com.nexters.goalpanzi.application.mission.dto;
+
+import org.springframework.web.multipart.MultipartFile;
+
+public record CreateMissionVerificationCommand(
+        Long memberId,
+        Long missionId,
+        MultipartFile imageFile
+) {
+}

src/main/java/com/nexters/goalpanzi/application/mission/dto/MissionVerificationCommand.java

@@ -0,0 +1,10 @@
+package com.nexters.goalpanzi.application.mission.dto;
+
+import java.time.LocalDate;
+
+public record MissionVerificationCommand(
+        Long memberId,
+        Long missionId,
+        LocalDate date
+) {
+}

src/main/java/com/nexters/goalpanzi/application/mission/dto/MissionVerificationResponse.java

@@ -0,0 +1,30 @@
+package com.nexters.goalpanzi.application.mission.dto;
+
+import com.nexters.goalpanzi.domain.member.Member;
+import com.nexters.goalpanzi.domain.mission.MissionVerification;
+import io.swagger.v3.oas.annotations.media.Schema;
+import org.hibernate.validator.constraints.NotEmpty;
+
+import java.time.LocalDateTime;
+
+public record MissionVerificationResponse(
+        @Schema(description = "닉네임", requiredMode = Schema.RequiredMode.REQUIRED)
+        @NotEmpty String nickname,
+
+        // TODO 캐릭터 이미지
+
+        @Schema(description = "인증 이미지 URL", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+        String imageUrl,
+
+        @Schema(description = "인증 시간", requiredMode = Schema.RequiredMode.NOT_REQUIRED)
+        LocalDateTime verifiedAt
+) {
+
+    public static MissionVerificationResponse verified(Member member, MissionVerification verification) {
+        return new MissionVerificationResponse(member.getNickname(), verification.getImageUrl(), verification.getCreatedAt());
+    }
+
+    public static MissionVerificationResponse notVerified(Member member) {
+        return new MissionVerificationResponse(member.getNickname(), "", null);
+    }
+}

src/main/java/com/nexters/goalpanzi/application/mission/dto/MyMissionVerificationCommand.java

@@ -0,0 +1,8 @@
+package com.nexters.goalpanzi.application.mission.dto;
+
+public record MyMissionVerificationCommand(
+        Long memberId,
+        Long missionId,
+        Integer number
+) {
+}

src/main/java/com/nexters/goalpanzi/config/NcpConfig.java

@@ -0,0 +1,36 @@
+package com.nexters.goalpanzi.config;
+
+import com.amazonaws.auth.AWSStaticCredentialsProvider;
+import com.amazonaws.auth.BasicAWSCredentials;
+import com.amazonaws.client.builder.AwsClientBuilder;
+import com.amazonaws.services.s3.AmazonS3;
+import com.amazonaws.services.s3.AmazonS3ClientBuilder;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class NcpConfig {
+    @Value("${cloud.aws.credentials.access-key}")
+    private String accessKey;
+
+    @Value("${cloud.aws.credentials.secret-key}")
+    private String secretKey;
+
+    @Value("${cloud.aws.region.static}")
+    private String region;
+
+    @Value("${cloud.aws.s3.endpoint}")
+    private String endPoint;
+
+    @Bean
+    public AmazonS3 s3Client() {
+        BasicAWSCredentials credentials = new BasicAWSCredentials(accessKey, secretKey);
+
+        return AmazonS3ClientBuilder
+                .standard()
+                .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(endPoint, region))
+                .withCredentials(new AWSStaticCredentialsProvider(credentials))
+                .build();
+    }
+}

src/main/java/com/nexters/goalpanzi/domain/auth/RefreshTokenRepository.java → src/main/java/com/nexters/goalpanzi/domain/auth/repository/RefreshTokenRepository.java

@@ -1,4 +1,4 @@
-package com.nexters.goalpanzi.domain.auth;
+package com.nexters.goalpanzi.domain.auth.repository;
 
 import com.nexters.goalpanzi.infrastructure.common.RedisRepository;
 

src/main/java/com/nexters/goalpanzi/domain/mission/MissionMember.java

@@ -0,0 +1,35 @@
+package com.nexters.goalpanzi.domain.mission;
+
+import com.nexters.goalpanzi.domain.common.BaseEntity;
+import com.nexters.goalpanzi.domain.member.Member;
+import jakarta.persistence.*;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Table(name = "mission_member")
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Getter
+public class MissionMember extends BaseEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "mission_member_id")
+    private Long id;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "member_id", nullable = false)
+    private Member member;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "mission_id", nullable = false)
+    private Mission mission;
+
+    @Column(name = "verification_count")
+    private Integer verificationCount;
+
+    public void verify() {
+        this.verificationCount++;
+    }
+}

src/main/java/com/nexters/goalpanzi/domain/mission/MissionVerification.java

@@ -0,0 +1,40 @@
+package com.nexters.goalpanzi.domain.mission;
+
+import com.nexters.goalpanzi.domain.common.BaseEntity;
+import com.nexters.goalpanzi.domain.member.Member;
+import jakarta.persistence.*;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Table(name = "mission_verification")
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Getter
+public class MissionVerification extends BaseEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "mission_verification_id")
+    private Long id;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "member_id", nullable = false)
+    private Member member;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "mission_id", nullable = false)
+    private Mission mission;
+
+    @Column(name = "image_url")
+    private String imageUrl;
+
+    @Column(name = "board_number")
+    private Integer boardNumber;
+
+    public MissionVerification(final Member member, final Mission mission, final String imageUrl) {
+        this.member = member;
+        this.mission = mission;
+        this.imageUrl = imageUrl;
+    }
+}

src/main/java/com/nexters/goalpanzi/domain/mission/repository/MissionMemberRepository.java

@@ -0,0 +1,15 @@
+package com.nexters.goalpanzi.domain.mission.repository;
+
+import com.nexters.goalpanzi.domain.mission.MissionMember;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+import java.util.Optional;
+
+@Repository
+public interface MissionMemberRepository extends JpaRepository<MissionMember, Long> {
+    Optional<MissionMember> findByMemberIdAndMissionId(final Long memberId, final Long missionId);
+
+    List<MissionMember> findAllByMissionId(final Long MissionId);
+}

src/main/java/com/nexters/goalpanzi/domain/mission/repository/MissionVerificationRepository.java

@@ -0,0 +1,21 @@
+package com.nexters.goalpanzi.domain.mission.repository;
+
+import com.nexters.goalpanzi.domain.mission.MissionVerification;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.stereotype.Repository;
+
+import java.time.LocalDate;
+import java.util.List;
+import java.util.Optional;
+
+@Repository
+public interface MissionVerificationRepository extends JpaRepository<MissionVerification, Long> {
+    Optional<MissionVerification> findByMemberIdAndMissionIdAndBoardNumber(final Long memberId, final Long missionId, final Integer boardNumber);
+
+    @Query(value = "SELECT * FROM mission_verification mv WHERE mv.mission_id = :missionId AND DATE(mv.created_at) = :date", nativeQuery = true)
+    List<MissionVerification> findAllByMissionIdAndDate(final Long missionId, final LocalDate date);
+
+    @Query(value = "SELECT * FROM mission_verification mv WHERE mv.member_id = :memberId AND mv.mission_id = :missionId AND DATE(mv.created_at) = :date", nativeQuery = true)
+    Optional<MissionVerification> findByMemberIdAndMissionIdAndDate(final Long memberId, final Long missionId, final LocalDate date);
+}

src/main/java/com/nexters/goalpanzi/exception/BadRequestException.java

@@ -1,6 +1,11 @@
 package com.nexters.goalpanzi.exception;
 
 public class BadRequestException extends BaseException {
+
+    public BadRequestException(final ErrorCode errorCode) {
+        super(errorCode.getMessage());
+    }
+
     public BadRequestException(final String message) {
         super(message);
     }

src/main/java/com/nexters/goalpanzi/exception/ErrorCode.java

@@ -18,7 +18,16 @@ public enum ErrorCode {
 
     // MEMBER
     NOT_FOUND_MEMBER("존재하지 않는 회원입니다"),
-    ALREADY_EXIST_NICKNAME("이미 존재하는 회원 닉네임입니다");
+    ALREADY_EXIST_NICKNAME("이미 존재하는 회원 닉네임입니다"),
+
+    // MISSION VERIFICATION
+    NOT_FOUND_VERIFICATION("존재하지 않는 미션 인증입니다."),
+    DUPLICATE_VERIFICATION("이미 인증한 미션이므로 더 이상 인증할 수 없습니다."),
+    ALREADY_COMPLETED_MISSION("이미 완료된 미션이므로 더 이상 인증할 수 없습니다."),
+
+    // FILE UPLOAD
+    INVALID_FILE("유효하지 않은 파일입니다."),
+    FILE_UPLOAD_FAILED("파일 업로드에 실패했습니다.");
 
     private String message;
 }

src/main/java/com/nexters/goalpanzi/infrastructure/auth/RefreshTokenRepositoryImpl.java

@@ -1,6 +1,6 @@
 package com.nexters.goalpanzi.infrastructure.auth;
 
-import com.nexters.goalpanzi.domain.auth.RefreshTokenRepository;
+import com.nexters.goalpanzi.domain.auth.repository.RefreshTokenRepository;
 import lombok.RequiredArgsConstructor;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Repository;