feat :: 정책 엔티티 생성 및 데이터 삽입

build.gradle

@@ -46,6 +46,11 @@ dependencies {
 	implementation 'io.jsonwebtoken:jjwt-api:0.11.5'
 	runtimeOnly 'io.jsonwebtoken:jjwt-impl:0.11.5'
 	runtimeOnly 'io.jsonwebtoken:jjwt-jackson:0.11.5'
+
+	// csv
+	implementation 'com.opencsv:opencsv:5.5.2'
+	implementation 'org.apache.poi:poi:5.2.2'
+	implementation 'org.apache.poi:poi-ooxml:5.2.2'
 }
 
 tasks.named('test') {

settings.gradle

@@ -1 +1,6 @@
+pluginManagement {
+    plugins {
+        id 'org.jetbrains.kotlin.jvm' version '2.0.20'
+    }
+}
 rootProject.name = 'onchung'

src/main/java/com/danpoong/onchung/domain/policy/controller/PolicyController.java

@@ -0,0 +1,19 @@
+package com.danpoong.onchung.domain.policy.controller;
+
+import com.danpoong.onchung.global.csv.service.CsvService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/api")
+public class PolicyController {
+    private final CsvService csvService;
+
+//    @PostMapping("/csv/policy")
+//    public ResponseTemplate<?> readCsvAndSaveInfo(@RequestParam("file") MultipartFile file) {
+//        csvService.loadDataFromCSV(file);
+//        return new ResponseTemplate<>(HttpStatus.CREATED, "csv 파일 저장 성공");
+//    }
+}

src/main/java/com/danpoong/onchung/domain/policy/domain/FilteringDetails.java

@@ -0,0 +1,19 @@
+package com.danpoong.onchung.domain.policy.domain;
+
+import jakarta.persistence.Embeddable;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Embeddable
+@NoArgsConstructor
+@AllArgsConstructor
+@Getter
+@Builder
+public class FilteringDetails {
+    private String ageInfo; // 연령 정보
+    private String employmentStatus; // 취업상태내용
+    private String specializationField; // 특화분야내용
+    private String educationRequirement; // 학력요건내용
+}

src/main/java/com/danpoong/onchung/domain/policy/domain/Policy.java

@@ -0,0 +1,76 @@
+package com.danpoong.onchung.domain.policy.domain;
+
+import com.danpoong.onchung.domain.policy.domain.enums.PolicyCategory;
+import com.danpoong.onchung.domain.public_office.domain.PublicOffice;
+import jakarta.persistence.*;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+@Entity
+@NoArgsConstructor
+@Getter
+public class Policy {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "policy_id")
+    private Long id;
+
+    @Column(name = "policy_name")
+    private String name;
+    @Column(name = "policy_introduction")
+    private String introduction; // 정책소개
+
+    @Column(name = "support_details")
+    private String supportDetails; // 지원내용
+    @Column(name = "support_scale")
+    private String supportScale; // 지원규모
+    @Column(name = "support_target")
+    private String supportTarget; // 지원대상
+
+    @Column(name = "application_period")
+    private String applicationPeriod; // 신청기간
+    @Column(name = "application_procedure")
+    private String applicationProcedure; // 신청절차
+    @Column(name = "required_documents")
+    private String requiredDocuments; // 제출서류내용
+    private String applicationSite; // 신청사이트주소
+
+    // 연락처
+    @Column(name = "contact_info")
+    private String contactInfo;
+
+    // 필터링 시 사용 - 연령, 취업상태, 특화분야, 학력요건
+    @Embedded
+    private FilteringDetails filteringDetails;
+
+    @Enumerated(EnumType.STRING)
+    private PolicyCategory category;
+
+    @ManyToMany
+    @JoinTable(
+            name = "policy_public_office",
+            joinColumns = @JoinColumn(name = "policy_id"),
+            inverseJoinColumns = @JoinColumn(name = "public_office_id")
+    )
+    private List<PublicOffice> publicOffices;
+
+    @Builder
+    public Policy(String name, String introduction, String supportDetails, String supportScale, String supportTarget, String applicationPeriod, String applicationProcedure, String requiredDocuments, String applicationSite, String contactInfo, FilteringDetails filteringDetails, String category, List<PublicOffice> publicOffices) {
+        this.name = name;
+        this.introduction = introduction;
+        this.supportDetails = supportDetails;
+        this.supportScale = supportScale;
+        this.supportTarget = supportTarget;
+        this.applicationPeriod = applicationPeriod;
+        this.applicationProcedure = applicationProcedure;
+        this.requiredDocuments = requiredDocuments;
+        this.applicationSite = applicationSite;
+        this.contactInfo = contactInfo;
+        this.filteringDetails = filteringDetails;
+        this.category = PolicyCategory.findCategory(category);
+        this.publicOffices = publicOffices;
+    }
+}

src/main/java/com/danpoong/onchung/domain/policy/domain/enums/PolicyCategory.java

@@ -0,0 +1,28 @@
+package com.danpoong.onchung.domain.policy.domain.enums;
+
+import lombok.Getter;
+
+@Getter
+public enum PolicyCategory {
+    Employment("23010"), // (일자리 분야)
+    Housing("23020"), // 주거 분야
+    Education("23030"), //교육 분야
+    WelfareCulture("23040"), // 복지, 문화 분야
+    ParticipationRights("23050"); // 참여, 권리 분야
+
+    private final String code;
+
+    PolicyCategory(String code) {
+        this.code = code;
+    }
+
+    public static PolicyCategory findCategory(String code) {
+        for (PolicyCategory category : PolicyCategory.values()) {
+            if (category.getCode().equals(code)) {
+                return category;
+            }
+        }
+
+        throw new IllegalArgumentException("Invalid category code: " + code);
+    }
+}

src/main/java/com/danpoong/onchung/domain/policy/repository/PolicyRepository.java

@@ -0,0 +1,7 @@
+package com.danpoong.onchung.domain.policy.repository;
+
+import com.danpoong.onchung.domain.policy.domain.Policy;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface PolicyRepository extends JpaRepository<Policy, Long> {
+}

src/main/java/com/danpoong/onchung/domain/public_office/domain/PublicOffice.java

@@ -1,10 +1,14 @@
 package com.danpoong.onchung.domain.public_office.domain;
 
+import com.danpoong.onchung.domain.policy.domain.Policy;
 import jakarta.persistence.*;
 import lombok.Builder;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 
+import java.util.ArrayList;
+import java.util.List;
+
 @Entity
 @NoArgsConstructor
 @Getter
@@ -36,16 +40,19 @@ public class PublicOffice {
     @Column(name = "public_office_phone_number")
     private String phoneNumber;
 
+    @ManyToMany(mappedBy = "publicOffices")  // 반대 방향 설정
+    private List<Policy> policies = new ArrayList<>();
+
     @Builder
-    public PublicOffice(String name, String phoneNumber) {
+    public PublicOffice(String name) {
         this.name = name;
-        this.phoneNumber = phoneNumber;
     }
 
-    public void updateAddress(String roadAddress, String longitude, String latitude) {
+    public void updateInfo(String roadAddress, String longitude, String latitude, String phoneNumber) {
         this.roadAddress = roadAddress;
         this.longitude = longitude;
         this.latitude = latitude;
+        this.phoneNumber = phoneNumber;
 
         splitAddress(roadAddress);
     }
@@ -62,4 +69,4 @@ private void splitAddress(String address) {
             this.city = "";
         }
     }
-}
+}

src/main/java/com/danpoong/onchung/domain/public_office/repository/PublicOfficeRepository.java

@@ -3,5 +3,8 @@
 import com.danpoong.onchung.domain.public_office.domain.PublicOffice;
 import org.springframework.data.jpa.repository.JpaRepository;
 
+import java.util.Optional;
+
 public interface PublicOfficeRepository extends JpaRepository<PublicOffice, Long> {
+    Optional<PublicOffice> findByName(String name);
 }

src/main/java/com/danpoong/onchung/domain/public_office/service/PublicOfficeService.java

@@ -52,7 +52,7 @@ public void saveAddress() {
                             .findFirst();
 
                     targetDocument.ifPresent(document ->
-                            publicOffice.updateAddress(document.getRoadAddress(), document.getX(), document.getY())
+                            publicOffice.updateInfo(document.getRoadAddress(), document.getX(), document.getY(), document.getPhone())
                     );
 
                     return publicOffice;

src/main/java/com/danpoong/onchung/global/csv/service/CsvService.java

@@ -0,0 +1,125 @@
+package com.danpoong.onchung.global.csv.service;
+
+import com.danpoong.onchung.domain.policy.domain.FilteringDetails;
+import com.danpoong.onchung.domain.policy.domain.Policy;
+import com.danpoong.onchung.domain.policy.repository.PolicyRepository;
+import com.danpoong.onchung.domain.public_office.domain.PublicOffice;
+import com.danpoong.onchung.domain.public_office.repository.PublicOfficeRepository;
+import jakarta.transaction.Transactional;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.poi.ss.usermodel.*;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.ArrayList;
+import java.util.List;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class CsvService {
+    private final PolicyRepository policyRepository;
+    private final PublicOfficeRepository publicOfficeRepository;
+
+    @Transactional
+    public void loadDataFromCSV(MultipartFile file) {
+        List<Policy> policyList = new ArrayList<>();
+
+        try (InputStream inputStream = file.getInputStream();
+             Workbook workbook = WorkbookFactory.create(inputStream)) {
+
+            Sheet sheet = workbook.getSheetAt(0);
+            boolean isFirstRow = true;
+
+            for (Row row : sheet) {
+                if (isFirstRow) {
+                    isFirstRow = false;
+                    continue;
+                }
+
+                List<PublicOffice> publicOffices = extractPublicOffices(row);
+                FilteringDetails filteringDetails = createFilteringDetails(row);
+                Policy policy = createPolicy(row, publicOffices, filteringDetails);
+
+                for (PublicOffice publicOffice : publicOffices) {
+                    publicOffice.getPolicies().add(policy);
+                }
+
+                policyList.add(policy);
+            }
+
+        } catch (IOException e) {
+            e.printStackTrace();
+        } finally {
+            if (!policyList.isEmpty()) {
+                policyRepository.saveAll(policyList);
+            }
+        }
+    }
+
+    private List<PublicOffice> extractPublicOffices(Row row) {
+        List<PublicOffice> publicOffices = new ArrayList<>();
+        String cellValue = getCellValue(row, 28);
+        String[] values = cellValue.contains(",") ? cellValue.split(",") : new String[]{cellValue};
+
+        for (String value : values) {
+            PublicOffice publicOffice = publicOfficeRepository.findByName(value)
+                    .orElseGet(() -> {
+                        PublicOffice newPublicOffice = PublicOffice.builder()
+                                .name(value)
+                                .build();
+
+                        return publicOfficeRepository.save(newPublicOffice);
+                    });
+
+            publicOffices.add(publicOffice);
+        }
+
+        return publicOffices;
+    }
+
+    private String getPhoneNumber(Row row) {
+        return !getCellValue(row, 30).isEmpty() && getCellValue(row, 30).contains("-")
+                ? getCellValue(row, 30)
+                : getCellValue(row, 27);
+    }
+
+    private FilteringDetails createFilteringDetails(Row row) {
+        return FilteringDetails.builder()
+                .ageInfo(getCellValue(row, 11))
+                .employmentStatus(getCellValue(row, 13))
+                .specializationField(getCellValue(row, 14))
+                .educationRequirement(getCellValue(row, 15))
+                .build();
+    }
+
+    private Policy createPolicy(Row row, List<PublicOffice> publicOffices, FilteringDetails filteringDetails) {
+        return Policy.builder()
+                .name(getCellValue(row, 4))
+                .introduction(getCellValue(row, 5))
+                .supportDetails(getCellValue(row, 6))
+                .supportScale(getCellValue(row, 7))
+                .supportTarget(getSupportTarget(row))
+                .applicationPeriod(getCellValue(row, 8))
+                .applicationProcedure(getCellValue(row, 19))
+                .requiredDocuments(getCellValue(row, 20))
+                .applicationSite(getCellValue(row, 22))
+                .contactInfo(getPhoneNumber(row))
+                .filteringDetails(filteringDetails)
+                .category(getCellValue(row, 32))
+                .publicOffices(publicOffices)
+                .build();
+    }
+
+    private String getSupportTarget(Row row) {
+        return !getCellValue(row, 16).isEmpty() ? getCellValue(row, 16) : getCellValue(row, 17);
+    }
+
+    private String getCellValue(Row row, int columnIndex) {
+        Cell cell = row.getCell(columnIndex);
+        return cell == null ? "" : cell.toString().trim();
+    }
+}

src/main/java/com/danpoong/onchung/global/map/response/AddressApiResponse.java

@@ -24,5 +24,7 @@ public static class Document {
 
         @JsonProperty("road_address_name")
         private String roadAddress;
+
+        private String phone;
     }
 }