CLAP-47 Clenup : 엘라스틱 엔티티,폴더명 document로 수정, 포트와 어댑터명 수정

<footer>
- 관련: #10

Author: hyoseong-Choi

…tructure/elastic/ElasticTaskAdapter.java …ructure/elastic/TaskDocumentAdapter.javasrc/main/java/clap/server/adapter/outbound/infrastructure/elastic/ElasticTaskAdapter.java renamed to src/main/java/clap/server/adapter/outbound/infrastructure/elastic/TaskDocumentAdapter.java src/main/java/clap/server/adapter/outbound/infrastructure/elastic/ElasticTaskAdapter.java renamed to src/main/java/clap/server/adapter/outbound/infrastructure/elastic/TaskDocumentAdapter.java

@@ -1,8 +1,8 @@
 package clap.server.adapter.outbound.infrastructure.elastic;
 
-import clap.server.adapter.outbound.infrastructure.elastic.entity.ElasticTask;
+import clap.server.adapter.outbound.infrastructure.elastic.document.TaskDocument;
 import clap.server.adapter.outbound.infrastructure.elastic.repository.TaskElasticRepository;
-import clap.server.application.port.outbound.task.ElasticTaskPort;
+import clap.server.application.port.outbound.task.TaskDocumentPort;
 import clap.server.common.annotation.architecture.InfrastructureAdapter;
 import co.elastic.clients.elasticsearch._types.aggregations.AggregationBuilders;
 import co.elastic.clients.elasticsearch._types.aggregations.MultiBucketBase;
@@ -19,12 +19,12 @@
 
 @InfrastructureAdapter
 @RequiredArgsConstructor
-public class ElasticTaskAdapter implements ElasticTaskPort {
+public class TaskDocumentAdapter implements TaskDocumentPort {
     private final TaskElasticRepository taskElasticRepository;
     private final ElasticsearchOperations elasticsearchOperations;
 
     @Override
-    public void saveStatistics(List<ElasticTask> statistics) {
+    public void saveStatistics(List<TaskDocument> statistics) {
         taskElasticRepository.saveAll(statistics);
     }
 
@@ -142,7 +142,7 @@ private NativeQuery buildSubCategoryTaskRequestQuery(PeriodConfig config, String
 
     private ElasticsearchAggregations executeQuery(NativeQuery query) {
         return (ElasticsearchAggregations) elasticsearchOperations
-                .search(query, ElasticTask.class)
+                .search(query, TaskDocument.class)
                 .getAggregations();
     }
 

…tructure/elastic/entity/ElasticTask.java …cture/elastic/document/TaskDocument.javasrc/main/java/clap/server/adapter/outbound/infrastructure/elastic/entity/ElasticTask.java renamed to src/main/java/clap/server/adapter/outbound/infrastructure/elastic/document/TaskDocument.java src/main/java/clap/server/adapter/outbound/infrastructure/elastic/entity/ElasticTask.java renamed to src/main/java/clap/server/adapter/outbound/infrastructure/elastic/document/TaskDocument.java

@@ -1,4 +1,4 @@
-package clap.server.adapter.outbound.infrastructure.elastic.entity;
+package clap.server.adapter.outbound.infrastructure.elastic.document;
 
 import clap.server.adapter.outbound.persistense.entity.task.TaskEntity;
 import jakarta.persistence.Id;
@@ -12,7 +12,7 @@
 @Document(indexName = "task")
 @Mapping(mappingPath = "elastic/task-mapping.json")
 @Getter
-public class ElasticTask {
+public class TaskDocument {
     @Id
     private Long id;
     @Field(name="task_code")
@@ -28,12 +28,12 @@ public class ElasticTask {
     @Field(name="created_at")
     private LocalDate createdAt;
 
-    public ElasticTask(TaskEntity taskEntity) {
+    public TaskDocument(TaskEntity taskEntity) {
         this.id = taskEntity.getTaskId();
         this.taskCode = taskEntity.getTaskCode();
         this.mainCategory = taskEntity.getCategory().getMainCategory().getName();
         this.subCategory = taskEntity.getCategory().getName();
-        this.status = taskEntity.getStatus().getStatusName().name().toLowerCase();
+        this.status = taskEntity.getTaskStatus().name().toLowerCase();
         this.processor = taskEntity.getProcessor().getNickname();
         this.createdAt = taskEntity.getCreatedAt().toLocalDate();
     }

src/main/java/clap/server/application/StatisticsIndexingService.java

@@ -1,8 +1,8 @@
 package clap.server.application;
 
-import clap.server.adapter.outbound.infrastructure.elastic.entity.ElasticTask;
-import clap.server.application.port.outbound.task.ElasticTaskPort;
+import clap.server.adapter.outbound.infrastructure.elastic.document.TaskDocument;
 import clap.server.application.port.outbound.task.LoadTaskPort;
+import clap.server.application.port.outbound.task.TaskDocumentPort;
 import clap.server.common.annotation.architecture.ApplicationService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -13,13 +13,13 @@
 @RequiredArgsConstructor
 public class StatisticsIndexingService {
     private final LoadTaskPort loadTaskPort;
-    private final ElasticTaskPort elasticTaskPort;
+    private final TaskDocumentPort taskDocumentPort;
 
     @Scheduled(cron = "0 0 0 * * *")
     public void IndexStatistics() {
-        elasticTaskPort.saveStatistics(
+        taskDocumentPort.saveStatistics(
                 loadTaskPort.findYesterdayTaskByDate(LocalDateTime.now().withNano(0))
-                        .stream().map(ElasticTask::new).toList()
+                        .stream().map(TaskDocument::new).toList()
         );
     }
 }

…/port/outbound/task/ElasticTaskPort.java …port/outbound/task/TaskDocumentPort.javasrc/main/java/clap/server/application/port/outbound/task/ElasticTaskPort.java renamed to src/main/java/clap/server/application/port/outbound/task/TaskDocumentPort.java src/main/java/clap/server/application/port/outbound/task/ElasticTaskPort.java renamed to src/main/java/clap/server/application/port/outbound/task/TaskDocumentPort.java

@@ -1,12 +1,12 @@
 package clap.server.application.port.outbound.task;
 
-import clap.server.adapter.outbound.infrastructure.elastic.entity.ElasticTask;
+import clap.server.adapter.outbound.infrastructure.elastic.document.TaskDocument;
 
 import java.util.List;
 import java.util.Map;
 
-public interface ElasticTaskPort {
-    void saveStatistics(List<ElasticTask> statistics);
+public interface TaskDocumentPort {
+    void saveStatistics(List<TaskDocument> statistics);
 
     Map<String, Long> findPeriodTaskRequestByPeriod(String period);
 

src/main/java/clap/server/application/statistics/FindCategoryTaskRequestService.java

@@ -1,7 +1,7 @@
 package clap.server.application.statistics;
 
 import clap.server.application.port.inbound.statistics.FindCategoryTaskRequestUsecase;
-import clap.server.application.port.outbound.task.ElasticTaskPort;
+import clap.server.application.port.outbound.task.TaskDocumentPort;
 import clap.server.common.annotation.architecture.ApplicationService;
 import lombok.RequiredArgsConstructor;
 
@@ -10,10 +10,10 @@
 @ApplicationService
 @RequiredArgsConstructor
 public class FindCategoryTaskRequestService implements FindCategoryTaskRequestUsecase {
-    private final ElasticTaskPort elasticTaskPort;
+    private final TaskDocumentPort taskDocumentPort;
 
     @Override
     public Map<String, Long> aggregateCategoryTaskRequest(String period) {
-        return elasticTaskPort.findCategoryTaskRequestByPeriod(period);
+        return taskDocumentPort.findCategoryTaskRequestByPeriod(period);
     }
 }

src/main/java/clap/server/application/statistics/FindPeriodTaskProcessService.java

@@ -1,7 +1,7 @@
 package clap.server.application.statistics;
 
 import clap.server.application.port.inbound.statistics.FindPeriodTaskProcessUsecase;
-import clap.server.application.port.outbound.task.ElasticTaskPort;
+import clap.server.application.port.outbound.task.TaskDocumentPort;
 import clap.server.common.annotation.architecture.ApplicationService;
 import lombok.RequiredArgsConstructor;
 
@@ -10,10 +10,10 @@
 @ApplicationService
 @RequiredArgsConstructor
 public class FindPeriodTaskProcessService implements FindPeriodTaskProcessUsecase {
-    private final ElasticTaskPort elasticTaskPort;
+    private final TaskDocumentPort taskDocumentPort;
 
     @Override
     public Map<String, Long> aggregatePeriodTaskProcess(String period) {
-        return elasticTaskPort.findPeriodTaskProcessByPeriod(period);
+        return taskDocumentPort.findPeriodTaskProcessByPeriod(period);
     }
 }

src/main/java/clap/server/application/statistics/FindPeriodTaskRequestService.java

@@ -1,7 +1,7 @@
 package clap.server.application.statistics;
 
 import clap.server.application.port.inbound.statistics.FindPeriodTaskRequestUsecase;
-import clap.server.application.port.outbound.task.ElasticTaskPort;
+import clap.server.application.port.outbound.task.TaskDocumentPort;
 import clap.server.common.annotation.architecture.ApplicationService;
 import lombok.RequiredArgsConstructor;
 
@@ -10,10 +10,10 @@
 @ApplicationService
 @RequiredArgsConstructor
 public class FindPeriodTaskRequestService implements FindPeriodTaskRequestUsecase {
-    private final ElasticTaskPort elasticTaskPort;
+    private final TaskDocumentPort taskDocumentPort;
 
     @Override
     public Map<String, Long> aggregatePeriodTaskRequest(String period) {
-        return elasticTaskPort.findPeriodTaskRequestByPeriod(period);
+        return taskDocumentPort.findPeriodTaskRequestByPeriod(period);
     }
 }

src/main/java/clap/server/application/statistics/FindSubCategoryTaskRequestService.java

@@ -1,7 +1,7 @@
 package clap.server.application.statistics;
 
 import clap.server.application.port.inbound.statistics.FindSubCategoryTaskRequestUsecase;
-import clap.server.application.port.outbound.task.ElasticTaskPort;
+import clap.server.application.port.outbound.task.TaskDocumentPort;
 import clap.server.common.annotation.architecture.ApplicationService;
 import lombok.RequiredArgsConstructor;
 
@@ -10,10 +10,10 @@
 @ApplicationService
 @RequiredArgsConstructor
 public class FindSubCategoryTaskRequestService implements FindSubCategoryTaskRequestUsecase {
-    private final ElasticTaskPort elasticTaskPort;
+    private final TaskDocumentPort taskDocumentPort;
 
     @Override
     public Map<String, Long> aggregateSubCategoryTaskRequest(String period, String mainCategory) {
-        return elasticTaskPort.findSubCategoryTaskRequestByPeriod(period, mainCategory);
+        return taskDocumentPort.findSubCategoryTaskRequestByPeriod(period, mainCategory);
     }
 }