Merge pull request #14 from ddankey/accident

feat: 지반 침하 사고 리스트 및 상세 데이터 저장, 조회 api 구현

Author: sycuuui

src/main/java/com/ddanguizip/server/domain/accident/controller/AccidentController.java

@@ -0,0 +1,32 @@
+package com.ddanguizip.server.domain.accident.controller;
+
+import com.ddanguizip.server.domain.accident.dto.AccidentInfoList;
+import com.ddanguizip.server.domain.accident.service.AccidentService;
+import com.ddanguizip.server.domain.map.dto.reponse.RiskAreaListRes;
+import com.ddanguizip.server.domain.map.dto.reponse.RiskListRes;
+import com.ddanguizip.server.domain.map.service.MapService;
+import com.ddanguizip.server.global.common.ApplicationResponse;
+import com.ddanguizip.server.global.success.SuccessCode;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.web.PageableDefault;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/api/v1/accident")
+@RequiredArgsConstructor
+public class AccidentController {
+    private final AccidentService accidentService;
+
+    @GetMapping("")
+    public ApplicationResponse<AccidentInfoList> search(
+            @RequestParam(name = "category", defaultValue = "") String category,
+            @PageableDefault(size = 10,page = 0) Pageable pageable) {
+
+        AccidentInfoList accidentInfoList = accidentService.searchAccidentListByCategory(category, pageable);
+        return ApplicationResponse.success(SuccessCode.SUCCESS,accidentInfoList);
+    }
+}

src/main/java/com/ddanguizip/server/domain/accident/dto/AccidentInfoDetail.java

@@ -0,0 +1,34 @@
+package com.ddanguizip.server.domain.accident.dto;
+
+import com.ddanguizip.server.domain.accident.entity.AccidentDetail;
+import lombok.Builder;
+
+@Builder
+public record AccidentInfoDetail(
+        String gu,
+        String dong,
+        String addr,
+        String sagoDetail,
+        String sinkWidth,
+        String sinkExtend,
+        String sinkDepth,
+        String accidentDate,
+        String categoryDescription
+) {
+    public static AccidentInfoDetail of(
+            AccidentDetail accidentDetail,
+            String categoryDescription
+    ){
+        return AccidentInfoDetail.builder()
+                .gu(accidentDetail.getLocation().getGu())
+                .dong(accidentDetail.getLocation().getDong())
+                .addr(accidentDetail.getAddr())
+                .accidentDate(accidentDetail.getSagoDate())
+                .sagoDetail(accidentDetail.getSagoDetail())
+                .sinkWidth(accidentDetail.getSinkWidth())
+                .sinkExtend(accidentDetail.getSinkExtend())
+                .sinkDepth(accidentDetail.getSinkDepth())
+                .categoryDescription(categoryDescription)
+                .build();
+    }
+}

src/main/java/com/ddanguizip/server/domain/accident/dto/AccidentInfoList.java

@@ -0,0 +1,29 @@
+package com.ddanguizip.server.domain.accident.dto;
+
+import lombok.Builder;
+
+import java.util.List;
+
+@Builder
+public record AccidentInfoList(
+        List<AccidentInfoDetail> accidentInfoDetailList,
+        int pageNo,
+        long pageSize,
+        long totalSize,
+        int totalPages
+) {
+    public static AccidentInfoList of(List<AccidentInfoDetail> accidentInfoDetailList,
+                                      int pageNo,
+                                      long pageSize,
+                                      long totalSize,
+                                      int totalPages
+    ){
+        return AccidentInfoList.builder()
+                .accidentInfoDetailList(accidentInfoDetailList)
+                .pageSize(pageSize)
+                .totalPages(totalPages)
+                .totalSize(totalSize)
+                .pageNo(pageNo)
+                .build();
+    }
+}

src/main/java/com/ddanguizip/server/domain/accident/entity/AccidentDetail.java

@@ -0,0 +1,72 @@
+package com.ddanguizip.server.domain.accident.entity;
+
+import com.ddanguizip.server.domain.accident.enumrate.AccidentCategory;
+import com.ddanguizip.server.domain.location.entity.Location;
+import com.ddanguizip.server.global.common.BaseTimeEntity;
+import jakarta.persistence.*;
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Entity
+@Table(name = "accidentDetail")
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class AccidentDetail extends BaseTimeEntity {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id", nullable = false, columnDefinition = "bigint")
+    private Long id;
+
+    @Column(nullable = false, length = 40)
+    private String addr;
+
+    @Column(nullable = false, length = 500)
+    private String sagoDetail;
+
+    @Column(nullable = false, length = 20)
+    private String sagoDate;
+
+    @Column(nullable = false, length = 20)
+    private String sinkWidth;
+
+    @Column(nullable = false, length = 20)
+    private String sinkExtend;
+
+    @Column(nullable = false, length = 20)
+    private String sinkDepth;
+
+    @ManyToOne(fetch = FetchType.LAZY, optional = false)
+    @JoinColumn(name = "location_id")
+    private Location location;
+
+    @OneToOne
+    @JoinColumn(name = "accident_sageNo", unique = true)
+    private AccidentSagoNo sageNo;
+
+    @Enumerated(EnumType.STRING)
+    @Column(nullable = false)
+    private AccidentCategory category;
+
+    @Builder
+    public AccidentDetail(String addr,
+                          String sagoDetail,
+                          String sagoDate,
+                          String sinkWidth,
+                          String sinkExtend,
+                          String sinkDepth,
+                          Location location,
+                          AccidentSagoNo sageNo,
+                          AccidentCategory category) {
+        this.addr = addr;
+        this.sagoDetail = sagoDetail;
+        this.sagoDate = sagoDate;
+        this.sinkWidth = sinkWidth;
+        this.sinkExtend = sinkExtend;
+        this.sinkDepth = sinkDepth;
+        this.location = location;
+        this.sageNo = sageNo;
+        this.category = category;
+    }
+}

src/main/java/com/ddanguizip/server/domain/accident/entity/AccidentSagoNo.java

@@ -0,0 +1,20 @@
+package com.ddanguizip.server.domain.accident.entity;
+
+import com.ddanguizip.server.global.common.BaseTimeEntity;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import lombok.*;
+
+@Entity
+@Table(name = "accident_sago_no")
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@Builder
+//20250505: 20250504
+public class AccidentSagoNo extends BaseTimeEntity {
+
+    @Id
+    private String sagoNo;  // sagoNo가 저장될 PK 컬럼
+}

src/main/java/com/ddanguizip/server/domain/accident/enumrate/AccidentCategory.java

@@ -0,0 +1,31 @@
+package com.ddanguizip.server.domain.accident.enumrate;
+
+public enum AccidentCategory {
+    AGING_INFRA("노후 지하시설물"),
+    BAD_CONSTRUCTION("시공·복구 불량"),
+    EXTERNAL_LOAD("외부 하중·진동"),
+    WEATHER_NATURE("기상·자연 요인"),
+    CONSTRUCTION_SITE("건축공사장 영향"),
+    COMPLEX_CAUSE("복합 요인·관리 부재"),
+    UNKNOWN("원인 불명/조사 중"),
+    ETC("기타");
+
+    private final String description;
+
+    AccidentCategory(String description) {
+        this.description = description;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public static boolean existCategory(String category) {
+        for (AccidentCategory value : AccidentCategory.values()) {
+            if (value.name().equalsIgnoreCase(category)) {
+                return true;
+            }
+        }
+        return false;
+    }
+}

src/main/java/com/ddanguizip/server/domain/accident/factory/AccidentFactory.java

@@ -0,0 +1,32 @@
+package com.ddanguizip.server.domain.accident.factory;
+
+import com.ddanguizip.server.domain.accident.entity.AccidentDetail;
+import com.ddanguizip.server.domain.accident.entity.AccidentSagoNo;
+import com.ddanguizip.server.domain.accident.enumrate.AccidentCategory;
+import com.ddanguizip.server.domain.location.entity.GuLocation;
+import com.ddanguizip.server.domain.location.entity.Location;
+import com.ddanguizip.server.domain.publicData.dto.response.AccidentDetailRes;
+import org.springframework.stereotype.Component;
+
+@Component
+public class AccidentFactory {
+    public AccidentSagoNo createAccidentSagoNo(String sagoNo) {
+        return AccidentSagoNo.builder()
+                .sagoNo(sagoNo)
+                .build();
+    }
+
+    public AccidentDetail createAccidentDetail(AccidentDetailRes accidentDetailRes, Location location, AccidentSagoNo sageNo, AccidentCategory accidentCategory) {
+        return AccidentDetail.builder()
+                .addr(accidentDetailRes.addr())
+                .sagoDetail(accidentDetailRes.sagoDetail())
+                .sagoDate(accidentDetailRes.sagoDate())
+                .sinkWidth(accidentDetailRes.sinkWidth())
+                .sinkExtend(accidentDetailRes.sinkExtend())
+                .sinkDepth(accidentDetailRes.sinkDepth())
+                .location(location)
+                .sageNo(sageNo)
+                .category(accidentCategory)
+                .build();
+    }
+}

src/main/java/com/ddanguizip/server/domain/accident/repository/AccidentDetailRepository.java

@@ -0,0 +1,8 @@
+package com.ddanguizip.server.domain.accident.repository;
+
+import com.ddanguizip.server.domain.accident.entity.AccidentDetail;
+import com.ddanguizip.server.domain.accident.entity.AccidentSagoNo;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface AccidentDetailRepository extends JpaRepository<AccidentDetail, Long>,AccidentDetailRepositoryCustom {
+}

src/main/java/com/ddanguizip/server/domain/accident/repository/AccidentDetailRepositoryCustom.java

@@ -0,0 +1,14 @@
+package com.ddanguizip.server.domain.accident.repository;
+
+import com.ddanguizip.server.domain.accident.entity.AccidentDetail;
+import com.ddanguizip.server.domain.accident.enumrate.AccidentCategory;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+
+public interface AccidentDetailRepositoryCustom {
+    /**
+     * 행궁동 기반 데이터 검색
+     * @param category category
+     */
+    Page<AccidentDetail> searchList (AccidentCategory category, Pageable pageable);
+}

src/main/java/com/ddanguizip/server/domain/accident/repository/AccidentDetailRepositoryImpl.java

@@ -0,0 +1,50 @@
+package com.ddanguizip.server.domain.accident.repository;
+
+import com.ddanguizip.server.domain.accident.entity.AccidentDetail;
+import com.ddanguizip.server.domain.accident.enumrate.AccidentCategory;
+import com.querydsl.core.types.dsl.BooleanExpression;
+import com.querydsl.jpa.impl.JPAQueryFactory;
+import jakarta.persistence.EntityManager;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageImpl;
+import org.springframework.data.domain.Pageable;
+
+import java.util.List;
+
+import static com.ddanguizip.server.domain.accident.entity.QAccidentDetail.accidentDetail;
+
+public class AccidentDetailRepositoryImpl implements AccidentDetailRepositoryCustom {
+    private final JPAQueryFactory queryFactory;
+
+    public AccidentDetailRepositoryImpl(EntityManager em) {
+        this.queryFactory = new JPAQueryFactory(em);
+    }
+
+    @Override
+    public Page<AccidentDetail> searchList(AccidentCategory category, Pageable pageable) {
+        BooleanExpression filterCondition = categoryEq(category);
+
+        List<AccidentDetail> results = queryFactory
+                .selectFrom(accidentDetail)
+                .where(filterCondition)
+                .orderBy(accidentDetail.createdAt.desc())
+                .offset(pageable.getOffset())
+                .limit(pageable.getPageSize())
+                .fetch();
+
+        long total = queryFactory
+                .select(accidentDetail.count())
+                .from(accidentDetail)
+                .where(filterCondition)
+                .fetchOne();
+
+        return new PageImpl<>(results, pageable, total);
+    }
+
+    private BooleanExpression categoryEq(AccidentCategory category) {
+        if (category == null) {
+            return null;
+        }
+        return accidentDetail.category.eq(category);
+    }
+}