[#33] 경매 활성화 및 종료 상태 변경 코드 추가

src/main/java/com/example/readyauction/batch/BatchConfig.java

@@ -6,16 +6,14 @@
 import org.springframework.batch.core.job.builder.JobBuilder;
 import org.springframework.batch.core.repository.JobRepository;
 import org.springframework.batch.core.step.builder.StepBuilder;
+import org.springframework.batch.item.ItemProcessor;
 import org.springframework.batch.item.ItemReader;
 import org.springframework.batch.item.ItemWriter;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.core.task.SimpleAsyncTaskExecutor;
 import org.springframework.transaction.PlatformTransactionManager;
 
-import com.example.readyauction.batch.job.RedisLikeReader;
-import com.example.readyauction.batch.job.RedisLikeWriter;
-
 @Configuration
 @EnableBatchProcessing
 public class BatchConfig {
@@ -27,24 +25,49 @@ public class BatchConfig {
     private final ItemReader redisLikeReader;
     private final ItemWriter redisLikeWriter;
 
+    private final ItemProcessor productConditionUpdate;
+    private final ItemReader productReader;
+    private final ItemWriter productConditionWriter;
+
     public BatchConfig(JobRepository jobRepository, PlatformTransactionManager platformTransactionManager,
-        RedisLikeReader redisLikeReader, RedisLikeWriter redisLikeWriter) {
+        ItemReader redisLikeReader, ItemWriter redisLikeWriter, ItemProcessor productConditionUpdate,
+        ItemReader productReader, ItemWriter productConditionWriter) {
         this.jobRepository = jobRepository;
         this.platformTransactionManager = platformTransactionManager;
         this.redisLikeReader = redisLikeReader;
         this.redisLikeWriter = redisLikeWriter;
+        this.productConditionUpdate = productConditionUpdate;
+        this.productReader = productReader;
+        this.productConditionWriter = productConditionWriter;
+    }
+
+    @Bean
+    public Job updateProductConditionJob() {
+        return new JobBuilder("updateProductCondition", jobRepository)
+            .start(updateProductConditionStep())
+            .build();
+    }
+
+    @Bean
+    public Step updateProductConditionStep() {
+        return new StepBuilder("updateProductConditionStep", jobRepository)
+            .chunk(CHUNK_SIZE, platformTransactionManager)
+            .reader(productReader)
+            .processor(productConditionUpdate)
+            .writer(productConditionWriter)
+            .build();
     }
 
     @Bean
-    public Job readLikeInRedis() {
-        return new JobBuilder("readLikeInRedis", jobRepository)
-            .start(updateStep())
+    public Job readLikeInRedisJob() {
+        return new JobBuilder("readLikeInRedisJob", jobRepository)
+            .start(updateProductLikeStep())
             .build();
     }
 
     @Bean
-    public Step updateStep() {
-        return new StepBuilder("updateProductLikeDB", jobRepository)
+    public Step updateProductLikeStep() {
+        return new StepBuilder("updateProductLikeStep", jobRepository)
             .chunk(CHUNK_SIZE, platformTransactionManager)
             .reader(redisLikeReader)
             .writer(redisLikeWriter)

src/main/java/com/example/readyauction/batch/job/ProductConditionUpdate.java

@@ -0,0 +1,27 @@
+package com.example.readyauction.batch.job;
+
+import java.time.LocalDateTime;
+
+import org.springframework.batch.item.ItemProcessor;
+import org.springframework.stereotype.Component;
+
+import com.example.readyauction.domain.product.Product;
+import com.example.readyauction.domain.product.ProductCondition;
+
+@Component
+public class ProductConditionUpdate implements ItemProcessor<Product, Product> {
+    // 상품의 상태를 갱신하는 로직
+    @Override
+    public Product process(Product product) throws Exception {
+        LocalDateTime now = LocalDateTime.now();
+        // 경매 상태 업데이트
+        if (now.isBefore(product.getStartDate())) {
+            product.updateProductCondition(ProductCondition.READY); // 경매 대기중
+        } else if (now.isAfter(product.getCloseDate())) {
+            product.updateProductCondition(ProductCondition.DONE);  // 경매 종료됨
+        } else {
+            product.updateProductCondition(ProductCondition.ACTIVE);  // 경매 진행중
+        }
+        return product;
+    }
+}

src/main/java/com/example/readyauction/batch/job/ProductConditionWriter.java

@@ -0,0 +1,26 @@
+package com.example.readyauction.batch.job;
+
+import java.util.List;
+
+import org.springframework.batch.item.Chunk;
+import org.springframework.batch.item.ItemWriter;
+import org.springframework.stereotype.Component;
+
+import com.example.readyauction.domain.product.Product;
+import com.example.readyauction.repository.product.ProductRepository;
+
+@Component
+public class ProductConditionWriter implements ItemWriter<Product> {
+
+    private final ProductRepository productRepository;
+
+    public ProductConditionWriter(ProductRepository productRepository) {
+        this.productRepository = productRepository;
+    }
+
+    @Override
+    public void write(Chunk<? extends Product> chunk) throws Exception {
+        List<? extends Product> products = chunk.getItems();
+        productRepository.saveAll(products);
+    }
+}

src/main/java/com/example/readyauction/batch/job/ProductReader.java

@@ -0,0 +1,42 @@
+package com.example.readyauction.batch.job;
+
+import java.util.List;
+
+import org.springframework.batch.item.ItemReader;
+import org.springframework.batch.item.NonTransientResourceException;
+import org.springframework.batch.item.ParseException;
+import org.springframework.batch.item.UnexpectedInputException;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Component;
+
+import com.example.readyauction.domain.product.Product;
+import com.example.readyauction.repository.product.ProductRepository;
+
+@Component
+public class ProductReader implements ItemReader<List<Product>> {
+    private static final int PAGE_SIZE = 500;  // 한번에 읽을 데이터 개수 (청크 사이즈)
+    private final ProductRepository productRepository;
+    private int currentPage = 0;
+
+    public ProductReader(ProductRepository productRepository) {
+        this.productRepository = productRepository;
+    }
+
+    @Override
+    public List<Product> read() throws
+        Exception,
+        UnexpectedInputException,
+        ParseException,
+        NonTransientResourceException {
+        Pageable pageable = PageRequest.of(currentPage, PAGE_SIZE);
+        List<Product> products = productRepository.findAll(pageable).getContent();
+
+        if (products.isEmpty()) {
+            currentPage = 0;
+            return null;
+        }
+        currentPage++;
+        return products;
+    }
+}

src/main/java/com/example/readyauction/controller/product/ProductApiController.java

@@ -45,9 +45,8 @@ public ProductResponse enroll(
 
     @GetMapping("/{id}")
     public ProductFindResponse findById(@PathVariable Long id) {
-        LocalDateTime request = LocalDateTime.now();
-        ProductFindResponse productFindResponse = productFacade.findById(id, request);
-        return productFindResponse;
+        LocalDateTime requestTime = LocalDateTime.now();
+        return productFacade.findById(id, requestTime);
     }
 
     @GetMapping