HotFix : itemReader 코드 변경

WE-ARE-RACCOONS · Nov 20, 2024 · 1aaacdf · 1aaacdf
1 parent 879a0e3
commit 1aaacdf
Showing 1 changed file with 23 additions and 23 deletions.
diff --git a/src/main/java/com/postgraduate/batch/salary/CreateSalaryJobConfig.java b/src/main/java/com/postgraduate/batch/salary/CreateSalaryJobConfig.java
@@ -84,28 +84,28 @@ public Step createSalaryStep() {
 
     @Bean
     public QueryDslZeroPagingItemReader<CreateSalary> salaryReader() {
-        LocalDate date = getSalaryDate().plusDays(7);
-        log.info("not in date : {}", date);
-        return new QueryDslZeroPagingItemReader<>(entityManagerFactory, CHUNK_SIZE, queryFactory ->
-                queryFactory.select(Projections.constructor(CreateSalary.class,
-                                senior.seniorId,
-                                account.accountId,
-                                account.bank,
-                                account.accountNumber,
-                                account.accountHolder))
-                        .distinct()
-                        .from(senior)
-                        .join(user)
-                        .on(senior.user.eq(user))
-                        .leftJoin(account)
-                        .on(account.senior.eq(senior))
-                        .where(senior.seniorId.notIn(
-                                        JPAExpressions
-                                                .select(salary.senior.seniorId)
-                                                .from(salary)
-                                                .where(salary.salaryDate.eq(date))
-                                ))
-                        .orderBy(senior.seniorId.desc())
-        );
+        return new QueryDslZeroPagingItemReader<>(entityManagerFactory, CHUNK_SIZE, queryFactory -> {
+            LocalDate date = getSalaryDate().plusDays(7);
+            log.info("not in date : {}", date);
+            return queryFactory.select(Projections.constructor(CreateSalary.class,
+                            senior.seniorId,
+                            account.accountId,
+                            account.bank,
+                            account.accountNumber,
+                            account.accountHolder))
+                    .distinct()
+                    .from(senior)
+                    .join(user)
+                    .on(senior.user.eq(user))
+                    .leftJoin(account)
+                    .on(account.senior.eq(senior))
+                    .where(senior.seniorId.notIn(
+                            JPAExpressions
+                                    .select(salary.senior.seniorId)
+                                    .from(salary)
+                                    .where(salary.salaryDate.eq(date))
+                    ))
+                    .orderBy(senior.seniorId.desc());
+        });
     }
 }