[Feat] 스마트 컨트랙트 환불 메소드 호출하는 서버 스케줄러 작성

build.gradle

@@ -74,7 +74,8 @@ dependencies {
     implementation 'software.amazon.awssdk:s3'
 
 	// Smart Contract
-	implementation 'org.web3j:core:4.9.4'
+	implementation 'org.web3j:core:4.12.0'
+	implementation 'org.web3j:contracts:4.12.0'
 }
 
 tasks.named('test') {

src/main/java/com/donet/donet/donation/adapter/in/scheduler/RefundScheduler.java

@@ -0,0 +1,17 @@
+package com.donet.donet.donation.adapter.in.scheduler;
+
+import com.donet.donet.donation.application.port.in.RefundDonationUsecase;
+import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class RefundScheduler {
+    private final RefundDonationUsecase refundDonationUsecase;
+
+    @Scheduled(cron = "0 0 0 * * *", zone = "Asia/Seoul")
+    public void runRefundJob() {
+        refundDonationUsecase.refundDonation();
+    }
+}

src/main/java/com/donet/donet/donation/adapter/out/persistence/donation/DonationPersistenceAdapter.java

@@ -14,6 +14,7 @@
 import com.donet.donet.global.exception.CustomException;
 import com.donet.donet.global.exception.DonationException;
 import com.donet.donet.global.exception.UserException;
+import com.donet.donet.global.persistence.BaseStatus;
 import com.donet.donet.review.adapter.out.persistence.DonationReviewRepository;
 import com.donet.donet.user.adapter.out.persistence.UserJpaEntity;
 import com.donet.donet.user.adapter.out.persistence.UserRepository;
@@ -26,6 +27,7 @@
 import org.springframework.data.domain.Pageable;
 import org.springframework.stereotype.Component;
 
+import java.time.LocalDate;
 import java.util.List;
 import java.util.Set;
 import java.util.stream.Collectors;
@@ -125,6 +127,14 @@ public List<RegisteredDonation> findRegisteredDonations(User user, int size) {
         return registeredDonations;
     }
 
+    @Override
+    public List<Donation> findRefundableDonation() {
+        return donationRepository.findRefundableDonations(LocalDate.now(), BaseStatus.ACTIVE)
+                .stream()
+                .map(donationMapper::mapToDomainEntity)
+                .toList();
+    }
+
     @Override
     public Donation increaseDonationView(Long donationId) {
         DonationJpaEntity donationJpaEntity = donationRepository.findDonationById(donationId)

src/main/java/com/donet/donet/donation/adapter/out/persistence/donation/DonationRepository.java

@@ -1,5 +1,6 @@
 package com.donet.donet.donation.adapter.out.persistence.donation;
 
+import com.donet.donet.global.persistence.BaseStatus;
 import com.donet.donet.user.adapter.out.persistence.UserJpaEntity;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
@@ -8,6 +9,7 @@
 import org.springframework.data.repository.query.Param;
 import org.springframework.stereotype.Repository;
 
+import java.time.LocalDate;
 import java.util.List;
 import java.util.Optional;
 
@@ -90,4 +92,12 @@ SELECT COUNT(*)
     Page<JoinedDonationProjection> findJoinedDonations(@Param("userId") Long userId, Pageable pageable);
 
     List<DonationJpaEntity> findAllByUserJpaEntityOrderByIdDesc(UserJpaEntity userJpaEntity, Pageable pageable);
+
+    @Query("""
+        SELECT d FROM DonationJpaEntity d
+        WHERE d.endDate < :today
+          AND d.currentAmount < d.targetAmount
+          AND d.status = :status
+    """)
+    List<DonationJpaEntity> findRefundableDonations(LocalDate today, BaseStatus status);
 }

src/main/java/com/donet/donet/donation/application/RefundDonationService.java

@@ -0,0 +1,42 @@
+package com.donet.donet.donation.application;
+
+import com.donet.donet.donation.application.port.in.RefundDonationUsecase;
+import com.donet.donet.donation.application.port.out.FindDonationPort;
+import com.donet.donet.donation.application.port.out.SmartContractPort;
+import com.donet.donet.donation.domain.Donation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class RefundDonationService implements RefundDonationUsecase {
+
+    private final FindDonationPort findDonationPort;
+    private final SmartContractPort smartContractPort;
+
+    @Override
+    public void refundDonation() {
+        List<Long> refundTargetDonationIds = findDonationPort.findRefundableDonation()
+                .stream()
+                .map(Donation::getId)
+                .toList();
+
+        if (refundTargetDonationIds.isEmpty()) {
+            log.info("환불 대상 기부가 없습니다.");
+            return;
+        }
+
+        log.info("환불 처리 시작: {} 건", refundTargetDonationIds.size());
+        boolean success = smartContractPort.refundDonations(refundTargetDonationIds);
+
+        if (success) {
+            log.info("환불 처리 완료: {} 건", refundTargetDonationIds.size());
+        }else{
+            log.error("환불 처리 실패: donation IDs = {}", refundTargetDonationIds);
+        }
+    }
+}

src/main/java/com/donet/donet/donation/application/port/in/RefundDonationUsecase.java

@@ -0,0 +1,5 @@
+package com.donet.donet.donation.application.port.in;
+
+public interface RefundDonationUsecase {
+    void refundDonation();
+}

src/main/java/com/donet/donet/donation/application/port/out/FindDonationPort.java

@@ -18,4 +18,6 @@ public interface FindDonationPort {
 
     List<JoinedDonation> findJoinedDonations(User user, int size);
     List<RegisteredDonation> findRegisteredDonations(User user, int size);
+
+    List<Donation> findRefundableDonation();
 }

src/main/java/com/donet/donet/donation/application/port/out/SmartContractPort.java

@@ -0,0 +1,7 @@
+package com.donet.donet.donation.application.port.out;
+
+import java.util.List;
+
+public interface SmartContractPort {
+    boolean refundDonations(List<Long> donationIds);
+}