feat: 공연 정보 갱신 기능 리팩토링, 개별 공연 정보 갱신 기능 추가

Author: Creamcheesepie

src/main/java/com/back/web7_9_codecrete_be/domain/concerts/controller/ConcertAdminController.java

@@ -2,6 +2,7 @@
 
 import com.back.web7_9_codecrete_be.domain.concerts.dto.KopisApiDto.concert.ConcertListResponse;
 import com.back.web7_9_codecrete_be.domain.concerts.dto.KopisApiDto.concertPlace.ConcertPlaceListResponse;
+import com.back.web7_9_codecrete_be.domain.concerts.dto.KopisApiDto.result.SetResultResponse;
 import com.back.web7_9_codecrete_be.domain.concerts.dto.concert.ConcertDetailResponse;
 import com.back.web7_9_codecrete_be.domain.concerts.dto.concert.ConcertItem;
 import com.back.web7_9_codecrete_be.domain.concerts.dto.concert.ConcertTicketTimeSetRequest;
@@ -29,9 +30,9 @@ public class ConcertAdminController { // todo : 인증 권한 추가하기
 
 
     @Operation(summary = "초기 공연 정보 저장", description = "25년 12월부터 앞으로 6개월 이후까지의 전체 공연의 정보를 가져와서 저장합니다. 대략 10~12분 정도 시간이 소요됩니다.")
-    @PostMapping("setConcertPlace")
-    public ConcertPlaceListResponse setConcertPlace() throws InterruptedException {
-        return kopisApiService.setConcertPlace();
+    @PostMapping("setConcertData")
+    public RsData<SetResultResponse> setConcert() throws InterruptedException {
+        return RsData.success(kopisApiService.setConcertsList());
     }
 
     @Operation(summary = "공연 정보 갱신",description = "공연 정보를 직접 갱신합니다.")
@@ -70,20 +71,19 @@ public RsData<ConcertDetailResponse>  ticketTimeSet(
         return RsData.success(concertService.setConcertTime(concertTicketTimeSetRequest));
     }
 
-    // todo: 내용 구현 필요
-    @Operation(summary = "개별 공연 API통한 갱신(구현 전)",description = "개별 공연에 대해서 공연 예술 통합망(Kopis)을 통해 데이터를 조회하고 해당 데이터를 갱신합니다.")
+    @Operation(summary = "개별 공연 API통한 갱신",description = "개별 공연에 대해서 공연 예술 통합망(Kopis)을 통해 데이터를 조회하고 해당 데이터를 갱신합니다.")
     @PatchMapping("updateConcertByKopisAPI/{concertId}")
     public RsData<ConcertDetailResponse> updateConcertByKopisAPI(
             @Schema(description = "갱신 대상이 될 공연의 ID 값입니다.")
-            @PathVariable Long ConcertId
+            @PathVariable Long concertId
     ){
-        return null;
+        kopisApiService.concertUpdateByKopisApi(concertId);
+        return RsData.success(concertService.getConcertDetail(concertId));
     }
 
-    // todo: 내용 구현 필요, 결과 DTO 따로 만들기.
-    @Operation(summary = "공연 목록 갱신(구현 전)", description = "전체 공연에 대해서 공연 예술 통합망(Kopis)을 통해 데이터를 조회하고, 바뀐 내용을 갱신하고 추가된 공연을 가져옵니다.")
-    @PostMapping("updateConcert")
-    public RsData<Void> updateConcert(){
-        return null;
+    @Operation(summary = "공연 목록 갱신", description = "전체 공연에 대해서 공연 예술 통합망(Kopis)을 통해 데이터를 조회하고, 바뀐 내용을 갱신하고 추가된 공연을 가져옵니다.")
+    @PostMapping("updateConcertData")
+    public RsData<SetResultResponse> updateConcert() throws InterruptedException {
+        return RsData.success(kopisApiService.updateConcertData());
     }
 }

src/main/java/com/back/web7_9_codecrete_be/domain/concerts/dto/KopisApiDto/result/SetResultResponse.java

@@ -0,0 +1,42 @@
+package com.back.web7_9_codecrete_be.domain.concerts.dto.KopisApiDto.result;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Getter;
+
+@Getter
+public class SetResultResponse {
+    @Schema(description = "추가된 공연 수")
+    private int addedConcerts;
+
+    @Schema(description = "갱신된 공연 수")
+    private int updatedConcerts;
+
+    @Schema(description = "추가된 공연 장소 수")
+    private int addedConcertPlaces;
+
+    @Schema(description = "갱신된 공연 장소 수")
+    private int updatedConcertPlaces;
+
+    @Schema(description = "추가된 공연 이미지 수")
+    private int addedConcertImages;
+
+    @Schema(description = "갱신된 공연 이미지 수")
+    private int updatedConcertImages;
+
+    @Schema(description = "추가된 예매처 사이트 수")
+    private int addedTicketOffice;
+
+    @Schema(description = "갱신된 예매처 사이트 수")
+    private int updatedTicketOffice;
+
+    public SetResultResponse(int addedConcerts, int updatedConcerts, int addedConcertPlaces, int updatedConcertPlaces, int addedConcertImages, int updatedConcertImages, int addedTicketOffice, int updatedTicketOffice) {
+        this.addedConcerts = addedConcerts;
+        this.updatedConcerts = updatedConcerts;
+        this.addedConcertPlaces = addedConcertPlaces;
+        this.updatedConcertPlaces = updatedConcertPlaces;
+        this.addedConcertImages = addedConcertImages;
+        this.updatedConcertImages = updatedConcertImages;
+        this.addedTicketOffice = addedTicketOffice;
+        this.updatedTicketOffice = updatedTicketOffice;
+    }
+}

src/main/java/com/back/web7_9_codecrete_be/domain/concerts/entity/Concert.java

@@ -83,13 +83,15 @@ public Concert(Long concertId) {
         this.concertId = concertId;
     }
 
-    public Concert update(ConcertPlace concertPlace, String content, LocalDateTime ticketTime, int maxPrice, int minPrice){
+    public Concert updateByAPI(ConcertPlace concertPlace, String content,LocalDate startDate,LocalDate endDate, int maxPrice, int minPrice, String posterUrl) {
         this.concertPlace = concertPlace;
         this.content = content;
-        this.ticketTime = ticketTime;
+        this.startDate = startDate;
+        this.endDate = endDate;
         this.modifiedDate = LocalDateTime.now();
         this.maxPrice = maxPrice;
         this.minPrice = minPrice;
+        this.posterUrl = posterUrl;
         return this;
     }
 

src/main/java/com/back/web7_9_codecrete_be/domain/concerts/entity/ConcertUpdateTime.java

@@ -0,0 +1,31 @@
+package com.back.web7_9_codecrete_be.domain.concerts.entity;
+
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.RequiredArgsConstructor;
+
+import java.time.LocalDateTime;
+
+@Entity
+@Getter
+@RequiredArgsConstructor
+public class ConcertUpdateTime {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    private LocalDateTime updateTime;
+
+    public ConcertUpdateTime(LocalDateTime updateTime) {
+        this.updateTime = updateTime;
+    }
+
+    public ConcertUpdateTime setUpdateTime(LocalDateTime updateTime) {
+        this.updateTime = updateTime;
+        return this;
+    }
+}

src/main/java/com/back/web7_9_codecrete_be/domain/concerts/repository/ConcertImageRepository.java

@@ -1,12 +1,30 @@
 package com.back.web7_9_codecrete_be.domain.concerts.repository;
 
+import com.back.web7_9_codecrete_be.domain.concerts.entity.Concert;
 import com.back.web7_9_codecrete_be.domain.concerts.entity.ConcertImage;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
 
 @Repository
 public interface ConcertImageRepository extends JpaRepository<ConcertImage, Long> {
     List<ConcertImage> getConcertImagesByConcert_ConcertId(Long concertConcertId);
+
+    void deleteAllByConcert(Concert concert);
+
+    @Modifying
+    @Query("""
+    DELETE 
+    FROM 
+    ConcertImage ci
+    WHERE 
+    ci.concert.concertId = :concertId
+""")
+    void deleteByConcertId(
+            @Param("concertId")
+            Long concertId);
 }

src/main/java/com/back/web7_9_codecrete_be/domain/concerts/repository/ConcertUpdateTimeRepository.java

@@ -0,0 +1,11 @@
+package com.back.web7_9_codecrete_be.domain.concerts.repository;
+
+import com.back.web7_9_codecrete_be.domain.concerts.entity.ConcertUpdateTime;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.time.LocalDate;
+
+@Repository
+public interface ConcertUpdateTimeRepository extends JpaRepository<ConcertUpdateTime, Long> {
+}

src/main/java/com/back/web7_9_codecrete_be/domain/concerts/repository/TicketOfficeRepository.java

@@ -3,11 +3,28 @@
 import com.back.web7_9_codecrete_be.domain.concerts.entity.Concert;
 import com.back.web7_9_codecrete_be.domain.concerts.entity.TicketOffice;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
 
 @Repository
 public interface TicketOfficeRepository  extends JpaRepository<TicketOffice, Long> {
     List<TicketOffice> getTicketOfficesByConcert(Concert concert);
+
+    void deleteAllByConcert(Concert concert);
+
+    @Modifying
+    @Query("""
+    DELETE
+    FROM 
+    TicketOffice t
+    WHERE 
+    t.concert.concertId = :concertId
+""")
+    void deleteByConcertId(
+            @Param("concertId")
+            Long concertId);
 }