Merge branch 'develop' of https://github.com/prgrms-web-devcourse-final-project/WEB6_8_LuckyVicky_BE into infra#138

Author: yeeJin227

src/main/java/com/back/BackApplication.java

@@ -2,8 +2,10 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
+@EnableScheduling
 public class BackApplication {
 
     public static void main(String[] args) {

src/main/java/com/back/domain/funding/controller/FundingStatusController.java

@@ -0,0 +1,75 @@
+package com.back.domain.funding.controller;
+
+import com.back.domain.funding.service.FundingStatusService;
+import com.back.global.rsData.RsData;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.validation.constraints.Positive;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/api/fundings")
+@Tag(name = "펀딩 상태", description = "펀딩 상태 관리 API")
+public class FundingStatusController {
+
+    private final FundingStatusService fundingStatusService;
+
+    @PutMapping("/{id}/close")
+    @PreAuthorize("isAuthenticated()")
+    @Operation(summary = "펀딩 종료", description = "펀딩 수동 종료")
+    public ResponseEntity<RsData<?>> closeFunding(
+            @PathVariable @Positive Long id,
+            @AuthenticationPrincipal(expression = "username") String userEmail) {
+        fundingStatusService.closeFunding(id, userEmail);
+        return ResponseEntity.ok(RsData.of("200", "펀딩이 종료되었습니다."));
+    }
+
+    @PutMapping("/{id}/cancel")
+    @PreAuthorize("isAuthenticated()")
+    @Operation(summary = "펀딩 취소", description = "펀딩 취소")
+    public ResponseEntity<RsData<?>> cancelFunding(
+            @PathVariable @Positive Long id,
+            @AuthenticationPrincipal(expression = "username") String userEmail) {
+        fundingStatusService.cancelFunding(id, userEmail);
+        return ResponseEntity.ok(RsData.of("200", "펀딩이 취소되었습니다."));
+    }
+
+    @PutMapping("/{id}/finalize")
+    @PreAuthorize("hasAuthority('ROLE_ADMIN') or hasAuthority('ROLE_ROOT')")
+    @Operation(summary = "단일 펀딩 최종 처리", description = "펀딩 성공/실패 확정 (관리자 전용) ")
+    public ResponseEntity<RsData<?>> finalizeFunding(
+            @PathVariable @Positive Long id) {
+        fundingStatusService.finalizeFunding(id);
+        return ResponseEntity.ok(RsData.of("200", "펀딩이 최종 처리되었습니다."));
+    }
+
+    @PutMapping("/finalize/all")
+    @PreAuthorize("hasAuthority('ROLE_ADMIN') or hasAuthority('ROLE_ROOT')")
+    @Operation(summary = "모든 펀딩 최종 처리", description = "모든 펀딩 성공/실패 확정 (관리자 전용) ")
+    public ResponseEntity<RsData<?>> finalizeAllFundings() {
+        fundingStatusService.finalizeAllClosedFundings();
+        return ResponseEntity.ok(RsData.of("200", "모든 펀딩이 최종 처리되었습니다."));
+    }
+
+    @PutMapping("/process/all")
+    @PreAuthorize("hasAuthority('ROLE_ADMIN') or hasAuthority('ROLE_ROOT')")
+    @Operation(summary = "모든 펀딩 통합 처리",
+            description = "만료된 펀딩을 종료하고, 종료된 펀딩을 최종 처리합니다. (종료 + 최종 처리 한 번에)")
+    public ResponseEntity<RsData<?>> processAllFundings() {
+        var result = fundingStatusService.processAllFundings();
+
+        String message = String.format(
+                "펀딩 통합 처리 완료 - 종료: %d건, 성공: %d건, 실패: %d건",
+                result.closedCount(), result.successCount(), result.failedCount()
+        );
+
+        return ResponseEntity.ok(
+                RsData.of("200", message)
+        );
+    }
+}

src/main/java/com/back/domain/funding/entity/Funding.java

@@ -14,7 +14,9 @@
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
 @AllArgsConstructor
 @Builder
-@Table(name = "fundings")
+@Table(name = "fundings", indexes = {
+        @Index(name = "idx_funding_status_enddate",
+                columnList = "status, end_date")})
 public class Funding extends BaseEntity {
 
     @ManyToOne(fetch = FetchType.LAZY, optional = false)
@@ -128,4 +130,40 @@ public static Funding create(
         }
         return f;
     }
+
+    // 펀딩 상태 관련 메서드
+    public void close() {
+        if (this.status != FundingStatus.OPEN) {
+            throw new IllegalStateException("진행 중인 펀딩만 종료할 수 있습니다.");
+        }
+        this.status = FundingStatus.CLOSED;
+    }
+
+    public void markAsSuccess() {
+        if (this.status != FundingStatus.CLOSED) {
+            throw new IllegalStateException("종료된 펀딩만 성공 처리할 수 있습니다.");
+        }
+        if (this.collectedAmount < this.targetAmount) {
+            throw new IllegalStateException("목표 금액을 달성하지 못했습니다.");
+        }
+        this.status = FundingStatus.SUCCESS;
+    }
+
+    public void markAsFailed() {
+        if (this.status != FundingStatus.CLOSED) {
+            throw new IllegalStateException("종료된 펀딩만 실패 처리할 수 있습니다.");
+        }
+        this.status = FundingStatus.FAILED;
+    }
+
+    public void cancel() {
+        if (this.status == FundingStatus.SUCCESS || this.status == FundingStatus.FAILED) {
+            throw new IllegalStateException("이미 완료된 펀딩은 취소할 수 없습니다.");
+        }
+        this.status = FundingStatus.CANCELED;
+    }
+
+    public boolean isEndDatePassed() {
+        return LocalDateTime.now().isAfter(this.endDate);
+    }
 }

src/main/java/com/back/domain/funding/repository/FundingRepository.java

@@ -4,12 +4,12 @@
 import com.back.domain.funding.entity.FundingStatus;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
-import org.springframework.data.jpa.repository.EntityGraph;
-import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
-import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.jpa.repository.*;
 import org.springframework.data.repository.query.Param;
+import org.springframework.transaction.annotation.Transactional;
 
+import java.time.LocalDateTime;
+import java.util.List;
 import java.util.Optional;
 import java.util.Set;
 
@@ -71,5 +71,29 @@ Page<Funding> findFundingsByArtist(
             @Param("order") String order,
             Pageable pageable
     );
+
+    // 종료일이 지난 펀딩 조회
+    @Query("SELECT COUNT(f) FROM Funding f " +
+            "WHERE f.status = :status AND f.endDate < :now")
+    long countByStatusAndEndDateBefore(
+            @Param("status") FundingStatus status,
+            @Param("now") LocalDateTime now
+    );
+
+    // 만료된 펀딩 일괄 종료
+    @Modifying
+    @Transactional
+    @Query("UPDATE Funding f SET f.status = 'CLOSED' " +
+            "WHERE f.status = 'OPEN' AND f.endDate < :now")
+    int bulkCloseExpiredFundings(@Param("now") LocalDateTime now);
+
+    // 특정 상태의 펀딩 전체 조회
+    List<Funding> findByStatus(FundingStatus status);
+
+    // 종료된 펀딩 조회 (정합성 체크용)
+    List<Funding> findByStatusAndEndDateBefore(
+            FundingStatus status,
+            LocalDateTime endDate
+    );
 }
 

src/main/java/com/back/domain/funding/scheduler/FundingStatusScheduler.java

@@ -0,0 +1,62 @@
+package com.back.domain.funding.scheduler;
+
+import com.back.domain.funding.service.FundingStatusService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+@Slf4j
+public class FundingStatusScheduler {
+
+    private final FundingStatusService fundingStatusService;
+
+    // 매시간 정각에 종료일이 지난 펀딩을 CLOSED로 변경
+    @Scheduled(cron = "0 0 * * * *")
+    public void closeExpiredFundings() {
+        long startTime = System.currentTimeMillis();
+
+        int closed = fundingStatusService.closeExpiredFundings();
+
+        long duration = System.currentTimeMillis() - startTime;
+
+        if (closed > 0) {
+            log.info("[스케줄러] 펀딩 자동 종료 완료 - 처리: {}건, 소요: {}ms", closed, duration);
+
+            // 성능 모니터링: 5초 이상 걸리면 경고
+            if (duration > 5000) {
+                log.warn("[성능 경고] 펀딩 종료 처리 시간 초과: {}ms", duration);
+            }
+        }
+    }
+
+    // 매시간 5분에 CLOSED 펀딩을 SUCCESS/FAILED로 최종 처리
+    @Scheduled(cron = "0 5 * * * *")
+    public void finalizeFundings() {
+        long startTime = System.currentTimeMillis();
+
+        FundingStatusService.FinalizeResult result = fundingStatusService.finalizeAllClosedFundings();
+
+        long duration = System.currentTimeMillis() - startTime;
+
+        if (result.totalProcessed() > 0) {
+            log.info("[스케줄러] 펀딩 최종 처리 완료 - 성공 펀딩: {}건, 실패 펀딩: {}건, 오류: {}건, 소요: {}ms",
+                    result.successCount(), result.failedCount(), result.errorCount(), duration);
+        }
+    }
+
+    /**
+     * 매일 새벽 1시에 정합성 체크 (안전장치)
+     * 혹시 놓친 펀딩이 있는지 확인
+     */
+    @Scheduled(cron = "0 0 1 * * *")
+    public void dailyStatusCheck() {
+        int closed = fundingStatusService.checkAndCloseMissedFundings();
+
+        if (closed > 0) {
+            log.warn("[스케줄러] 정합성 체크 - 누락 펀딩 {}건 처리 완료", closed);
+        }
+    }
+}