From 4e797947504ac1690a85b6c50de5210aee67f067 Mon Sep 17 00:00:00 2001
From: hyojin kim <hjkim4@gcsc.co.kr>
Date: Fri, 9 Jan 2026 10:21:10 +0900
Subject: [PATCH] :zap: chunk & batch size change

---
 .../compliance/batch/config/ComplianceImportRangeJobConfig.java | 2 +-
 .../jobs/compliance/batch/reader/ComplianceDataRangeReader.java | 2 +-
 .../jobs/movement/batch/config/DestinationsRangeJobConfig.java  | 2 +-
 .../jobs/movement/batch/config/TerminalCallsRangeJobConfig.java | 2 +-
 .../jobs/movement/batch/config/TransitsRangeJobConfig.java      | 2 +-
 .../jobs/movement/batch/reader/DestinationRangeReader.java      | 2 +-
 .../jobs/movement/batch/reader/TerminalCallsRangeReader.java    | 2 +-
 .../batch/jobs/movement/batch/reader/TransitsRangeReader.java   | 2 +-
 .../jobs/pscInspection/batch/config/PscInspectionJobConfig.java | 2 +-
 .../snp/batch/jobs/pscInspection/batch/reader/PscApiReader.java | 2 +-
 .../batch/jobs/risk/batch/config/RiskImportRangeJobConfig.java  | 2 +-
 .../snp/batch/jobs/risk/batch/reader/RiskDataRangeReader.java   | 2 +-
 12 files changed, 12 insertions(+), 12 deletions(-)

diff --git a/src/main/java/com/snp/batch/jobs/compliance/batch/config/ComplianceImportRangeJobConfig.java b/src/main/java/com/snp/batch/jobs/compliance/batch/config/ComplianceImportRangeJobConfig.java
index 647c831..96ee323 100644
--- a/src/main/java/com/snp/batch/jobs/compliance/batch/config/ComplianceImportRangeJobConfig.java
+++ b/src/main/java/com/snp/batch/jobs/compliance/batch/config/ComplianceImportRangeJobConfig.java
@@ -45,7 +45,7 @@ public class ComplianceImportRangeJobConfig extends BaseMultiStepJobConfig<Compl
 
     @Override
     protected int getChunkSize() {
-        return 10000;
+        return 5000;
     }
     public ComplianceImportRangeJobConfig(
             JobRepository jobRepository,
diff --git a/src/main/java/com/snp/batch/jobs/compliance/batch/reader/ComplianceDataRangeReader.java b/src/main/java/com/snp/batch/jobs/compliance/batch/reader/ComplianceDataRangeReader.java
index a98e398..29754ac 100644
--- a/src/main/java/com/snp/batch/jobs/compliance/batch/reader/ComplianceDataRangeReader.java
+++ b/src/main/java/com/snp/batch/jobs/compliance/batch/reader/ComplianceDataRangeReader.java
@@ -22,7 +22,7 @@ public class ComplianceDataRangeReader extends BaseApiReader<ComplianceDto> {
     private final BatchDateService batchDateService; // ✨ BatchDateService 필드 추가
     private List<ComplianceDto> allData;
     private int currentBatchIndex = 0;
-    private final int batchSize = 1000;
+    private final int batchSize = 5000;
     private String fromDate;
     private String toDate;
     public ComplianceDataRangeReader(WebClient webClient, JdbcTemplate jdbcTemplate, BatchDateService batchDateService) {
diff --git a/src/main/java/com/snp/batch/jobs/movement/batch/config/DestinationsRangeJobConfig.java b/src/main/java/com/snp/batch/jobs/movement/batch/config/DestinationsRangeJobConfig.java
index 3e21812..fca2c61 100644
--- a/src/main/java/com/snp/batch/jobs/movement/batch/config/DestinationsRangeJobConfig.java
+++ b/src/main/java/com/snp/batch/jobs/movement/batch/config/DestinationsRangeJobConfig.java
@@ -99,7 +99,7 @@ public class DestinationsRangeJobConfig extends BaseMultiStepJobConfig<Destinati
 
     @Override
     protected int getChunkSize() {
-        return 1000; // API에서 100개씩 가져오므로 chunk도 100으로 설정
+        return 5000;
     }
 
     @Bean(name = "DestinationsRangeImportJob")
diff --git a/src/main/java/com/snp/batch/jobs/movement/batch/config/TerminalCallsRangeJobConfig.java b/src/main/java/com/snp/batch/jobs/movement/batch/config/TerminalCallsRangeJobConfig.java
index bba42be..2870ce4 100644
--- a/src/main/java/com/snp/batch/jobs/movement/batch/config/TerminalCallsRangeJobConfig.java
+++ b/src/main/java/com/snp/batch/jobs/movement/batch/config/TerminalCallsRangeJobConfig.java
@@ -100,7 +100,7 @@ public class TerminalCallsRangeJobConfig extends BaseMultiStepJobConfig<Terminal
 
     @Override
     protected int getChunkSize() {
-        return 1000; // API에서 100개씩 가져오므로 chunk도 1000으로 설정
+        return 5000;
     }
 
     @Bean(name = "TerminalCallsRangeImportJob")
diff --git a/src/main/java/com/snp/batch/jobs/movement/batch/config/TransitsRangeJobConfig.java b/src/main/java/com/snp/batch/jobs/movement/batch/config/TransitsRangeJobConfig.java
index 8fd22bb..54c57fa 100644
--- a/src/main/java/com/snp/batch/jobs/movement/batch/config/TransitsRangeJobConfig.java
+++ b/src/main/java/com/snp/batch/jobs/movement/batch/config/TransitsRangeJobConfig.java
@@ -98,7 +98,7 @@ public class TransitsRangeJobConfig extends BaseMultiStepJobConfig<TransitsDto,
 
     @Override
     protected int getChunkSize() {
-        return 1000; // API에서 100개씩 가져오므로 chunk도 100으로 설정
+        return 5000; // API에서 100개씩 가져오므로 chunk도 100으로 설정
     }
 
     @Bean(name = "TransitsRangeImportJob")
diff --git a/src/main/java/com/snp/batch/jobs/movement/batch/reader/DestinationRangeReader.java b/src/main/java/com/snp/batch/jobs/movement/batch/reader/DestinationRangeReader.java
index e70f17f..d6a9b39 100644
--- a/src/main/java/com/snp/batch/jobs/movement/batch/reader/DestinationRangeReader.java
+++ b/src/main/java/com/snp/batch/jobs/movement/batch/reader/DestinationRangeReader.java
@@ -16,7 +16,7 @@ public class DestinationRangeReader extends BaseApiReader<DestinationDto> {
     private final BatchDateService batchDateService; // ✨ BatchDateService 필드 추가
     private List<DestinationDto> allData;
     private int currentBatchIndex = 0;
-    private final int batchSize = 1000;
+    private final int batchSize = 5000;
     protected String getApiKey() {
         return "DESTINATIONS_IMPORT_API";
     }
diff --git a/src/main/java/com/snp/batch/jobs/movement/batch/reader/TerminalCallsRangeReader.java b/src/main/java/com/snp/batch/jobs/movement/batch/reader/TerminalCallsRangeReader.java
index ad3ad6a..2213167 100644
--- a/src/main/java/com/snp/batch/jobs/movement/batch/reader/TerminalCallsRangeReader.java
+++ b/src/main/java/com/snp/batch/jobs/movement/batch/reader/TerminalCallsRangeReader.java
@@ -16,7 +16,7 @@ public class TerminalCallsRangeReader extends BaseApiReader<TerminalCallsDto> {
     private final BatchDateService batchDateService; // ✨ BatchDateService 필드 추가
     private List<TerminalCallsDto> allData;
     private int currentBatchIndex = 0;
-    private final int batchSize = 1000;
+    private final int batchSize = 5000;
     protected String getApiKey() {
         return "TERMINAL_CALLS_IMPORT_API";
     }
diff --git a/src/main/java/com/snp/batch/jobs/movement/batch/reader/TransitsRangeReader.java b/src/main/java/com/snp/batch/jobs/movement/batch/reader/TransitsRangeReader.java
index a3295a3..f62c3df 100644
--- a/src/main/java/com/snp/batch/jobs/movement/batch/reader/TransitsRangeReader.java
+++ b/src/main/java/com/snp/batch/jobs/movement/batch/reader/TransitsRangeReader.java
@@ -16,7 +16,7 @@ public class TransitsRangeReader extends BaseApiReader<TransitsDto> {
     private final BatchDateService batchDateService; // ✨ BatchDateService 필드 추가
     private List<TransitsDto> allData;
     private int currentBatchIndex = 0;
-    private final int batchSize = 1000;
+    private final int batchSize = 5000;
     protected String getApiKey() {
         return "TRANSITS_IMPORT_API";
     }
diff --git a/src/main/java/com/snp/batch/jobs/pscInspection/batch/config/PscInspectionJobConfig.java b/src/main/java/com/snp/batch/jobs/pscInspection/batch/config/PscInspectionJobConfig.java
index 1143d00..a23d07a 100644
--- a/src/main/java/com/snp/batch/jobs/pscInspection/batch/config/PscInspectionJobConfig.java
+++ b/src/main/java/com/snp/batch/jobs/pscInspection/batch/config/PscInspectionJobConfig.java
@@ -91,7 +91,7 @@ public class PscInspectionJobConfig extends BaseMultiStepJobConfig<PscInspection
 
     @Override
     protected int getChunkSize() {
-        return 1000; // API에서 100개씩 가져오므로 chunk도 100으로 설정
+        return 5000;
     }
 
     @Bean(name = "PSCDetailImportJob")
diff --git a/src/main/java/com/snp/batch/jobs/pscInspection/batch/reader/PscApiReader.java b/src/main/java/com/snp/batch/jobs/pscInspection/batch/reader/PscApiReader.java
index 3ae6a76..4883e09 100644
--- a/src/main/java/com/snp/batch/jobs/pscInspection/batch/reader/PscApiReader.java
+++ b/src/main/java/com/snp/batch/jobs/pscInspection/batch/reader/PscApiReader.java
@@ -26,7 +26,7 @@ public class PscApiReader extends BaseApiReader<PscInspectionDto> {
 
     private List<PscInspectionDto> allData;
     private int currentBatchIndex = 0;
-    private final int batchSize = 1000;
+    private final int batchSize = 5000;
 
     private final JdbcTemplate jdbcTemplate;
     private final BatchDateService batchDateService; // ✨ BatchDateService 필드 추가
diff --git a/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskImportRangeJobConfig.java b/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskImportRangeJobConfig.java
index 0086faf..59b8f62 100644
--- a/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskImportRangeJobConfig.java
+++ b/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskImportRangeJobConfig.java
@@ -43,7 +43,7 @@ public class RiskImportRangeJobConfig extends BaseMultiStepJobConfig<RiskDto, Ri
 
     @Override
     protected int getChunkSize() {
-        return 10000;
+        return 5000;
     }
     public RiskImportRangeJobConfig(
             JobRepository jobRepository,
diff --git a/src/main/java/com/snp/batch/jobs/risk/batch/reader/RiskDataRangeReader.java b/src/main/java/com/snp/batch/jobs/risk/batch/reader/RiskDataRangeReader.java
index a5250af..fc1be7a 100644
--- a/src/main/java/com/snp/batch/jobs/risk/batch/reader/RiskDataRangeReader.java
+++ b/src/main/java/com/snp/batch/jobs/risk/batch/reader/RiskDataRangeReader.java
@@ -22,7 +22,7 @@ public class RiskDataRangeReader extends BaseApiReader<RiskDto> {
     private final BatchDateService batchDateService; // ✨ BatchDateService 필드 추가
     private List<RiskDto> allData;
     private int currentBatchIndex = 0;
-    private final int batchSize = 1000;
+    private final int batchSize = 5000;
     private String fromDate;
     private String toDate;
     public RiskDataRangeReader(WebClient webClient, JdbcTemplate jdbcTemplate, BatchDateService batchDateService) {