[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

@@ -26,6 +26,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 +126,14 @@ public List<RegisteredDonation> findRegisteredDonations(User user, int size) {
         return registeredDonations;
     }
 
+    @Override
+    public List<Donation> findRefundableDonation() {
+        return donationRepository.findRefundableDonations(LocalDate.now())
+                .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

@@ -8,6 +8,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 +91,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 = 'ACTIVE'
+    """)
+    List<DonationJpaEntity> findRefundableDonations(LocalDate today);
 }

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

@@ -0,0 +1,28 @@
+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 org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@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();
+
+        smartContractPort.refundDonations(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);
+}

src/main/java/com/donet/donet/global/smartContract/SmartContractAdapter.java

@@ -0,0 +1,63 @@
+package com.donet.donet.global.smartContract;
+
+import com.donet.donet.donation.application.port.out.SmartContractPort;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.web3j.protocol.Web3j;
+import org.web3j.crypto.Credentials;
+import org.web3j.protocol.core.methods.response.TransactionReceipt;
+import org.web3j.tx.gas.ContractGasProvider;
+
+import java.math.BigInteger;
+import java.util.List;
+
+@Component
+@RequiredArgsConstructor
+public class SmartContractAdapter implements SmartContractPort {
+
+    private final CampaignFactory campaignFactory;   // 컨트랙트 주소 조회용
+    private final Web3j web3j;                       // Web3 네트워크 연동
+    private final Credentials credentials;           // 서버 지갑
+    private final ContractGasProvider gasProvider;           // 가스 설정
+
+    @Override
+    public boolean refundDonations(List<Long> donationIds) {
+
+        try {
+            for (Long donationId : donationIds) {
+
+                // 1. Factory에서 donationId로 캠페인 주소 조회
+                String campaignAddress = String.valueOf(campaignFactory.getCampaignAddress(BigInteger.valueOf(donationId)));
+
+                if (campaignAddress == null) {
+                    throw new IllegalStateException("Campaign address not found for donationId=" + donationId);
+                }
+
+                // 2. 해당 주소로 Campaign 컨트랙트 인스턴스 로딩
+                Campaign campaign = Campaign.load(
+                        campaignAddress,
+                        web3j,
+                        credentials,
+                        gasProvider
+                );
+
+                // 3. Donation ID 기반 환불 트랜잭션 실행
+                TransactionReceipt tx = campaign.refund().send();
+
+                // 4. 실패 여부 확인
+                if (!tx.isStatusOK()) {
+                    throw new RuntimeException("Refund transaction failed: " + tx.getTransactionHash());
+                }
+
+                System.out.println("Refund success for donationId=" + donationId +
+                        " / tx=" + tx.getTransactionHash());
+            }
+
+            return true;
+
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+}

src/main/java/com/donet/donet/global/smartContract/Web3jConfig.java

@@ -0,0 +1,58 @@
+package com.donet.donet.global.smartContract;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.web3j.crypto.Credentials;
+import org.web3j.protocol.Web3j;
+import org.web3j.protocol.http.HttpService;
+import org.web3j.tx.gas.ContractGasProvider;
+import org.web3j.tx.gas.StaticGasProvider;
+
+import java.math.BigInteger;
+
+@Configuration
+@RequiredArgsConstructor
+public class Web3jConfig {
+
+    @Value("${web3.rpcUrl}")
+    private String rpcUrl;
+
+    @Value("${web3.privateKey}")
+    private String privateKey;
+
+    @Value("${web3.gasPrice}")
+    private BigInteger gasPrice;
+
+    @Value("${web3.gasLimit}")
+    private BigInteger gasLimit;
+
+    // 이미 배포되어 있는 CampaignFactory의 on-chain 주소
+    @Value("${contracts.campaignFactoryAddress}")
+    private String campaignFactoryAddress;
+
+    @Bean
+    public Web3j web3j() {
+        return Web3j.build(new HttpService(rpcUrl));
+    }
+
+    @Bean
+    public Credentials credentials() {
+        return Credentials.create(privateKey);
+    }
+
+    @Bean
+    public ContractGasProvider contractGasProvider() {
+        return new StaticGasProvider(gasPrice, gasLimit);
+    }
+
+    @Bean
+    public CampaignFactory campaignFactory(
+            Web3j web3j,
+            Credentials credentials,
+            ContractGasProvider gasProvider
+    ) {
+        return CampaignFactory.load(campaignFactoryAddress, web3j, credentials, gasProvider);
+    }
+}

src/main/resources/application.yml

@@ -94,3 +94,12 @@ management:
       show-details: "always"  # 상세 정보 포함
   server:
     port: 8080
+
+web3:
+  rpcUrl: ${RPC_URL}
+  privateKey: ${CONTRACT_PRIVATE_KEY}
+  gasPrice: ${GAS_PRICE}
+  gasLimit: ${GAS_LIMIT}
+
+contracts:
+  campaignFactoryAddress: ${CONTRACT_ADDRESS}