[FEATURE/#54] 전체 자산 동기화 API 구현 (#70)

## 🔗 Related Issue
<!-- 이슈 번호를 작성하여 종료시켜주세요 -->
- closes #54 

## 📝 Summary
<!-- 작업한 기능을 설명해주세요 -->
사용자의 금융 자산(은행 내역, 카드 내역)을 한 번에 가져오는 전체 동기화 API를 구현하였습니다. 
- 전체 자산 동기화 API 구현 및 성능 개선
  - 은행/카드 거래 내역을 외부 API로 조회 후 DB에 저장하는 전체 동기화 로직 구현
- JPA saveAll() 대신 JdbcTemplate 기반 Bulk Insert 방식 적용 (대량 Insert 시 발생하던
성능 저하 문제 개선)
- 트러블슈팅 및 안정화
 
## 🔄 Changes
<!-- 구체적으로 어떤 파일/로직이 변경되었는지 체크해주세요 -->
- [X] API 변경 (추가/수정)
- [ ] 데이터 및 도메인 변경 (DB, 비즈니스 로직)
- [ ] 설정 또는 인프라 관련 변경
- [X] 리팩토링

## 💬 Questions & Review Points
<!-- 리뷰어가 특별히 봐주었으면 하는 부분이 있다면 작성해주세요 -->
 

## 📸 API Test Results (Swagger)
<!-- API 테스트 스크린샷 첨부 -->
<img width="1949" height="1216" alt="image"
src="https://github.com/user-attachments/assets/890e548e-8e34-429c-9ce6-0c0c970b14d0"
/>

## ✅ Checklist
- [X] API 테스트 완료
- [X] 테스트 결과 사진 첨부
- [X] 빌드 성공 확인 (./gradlew build)

Author: seamooll

src/main/java/org/umc/valuedi/domain/asset/controller/AssetController.java

@@ -4,12 +4,15 @@
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
+import org.umc.valuedi.domain.asset.exception.code.AssetSuccessCode;
 import org.umc.valuedi.domain.asset.dto.res.AssetResDTO;
 import org.umc.valuedi.domain.asset.dto.res.BankResDTO;
 import org.umc.valuedi.domain.asset.dto.res.CardResDTO;
 import org.umc.valuedi.domain.asset.service.query.AssetQueryService;
+import org.umc.valuedi.domain.asset.service.command.AssetSyncFacadeService;
 import org.umc.valuedi.domain.connection.service.ConnectionQueryService;
 import org.umc.valuedi.global.apiPayload.ApiResponse;
 import org.umc.valuedi.global.apiPayload.code.GeneralSuccessCode;
@@ -25,6 +28,7 @@ public class AssetController implements AssetControllerDocs {
 
     private final ConnectionQueryService connectionQueryService;
     private final AssetQueryService assetQueryService;
+    private final AssetSyncFacadeService assetSyncFacadeService;
 
 
     @GetMapping("/cards")
@@ -79,4 +83,12 @@ public ApiResponse<AssetResDTO.AssetSummaryCountDTO> getAssetCount(
     ) {
         return ApiResponse.onSuccess(GeneralSuccessCode.OK, assetQueryService.getAssetSummaryCount(memberId));
     }
+
+    @PostMapping("/sync/refresh")
+    public ApiResponse<Void> refreshAssetSync(
+            @CurrentMember Long memberId
+    ) {
+        assetSyncFacadeService.refreshAssetSync(memberId);
+        return ApiResponse.onSuccess(AssetSuccessCode.SYNC_REQUEST_SUCCESS, null);
+    }
 }

src/main/java/org/umc/valuedi/domain/asset/controller/AssetControllerDocs.java

@@ -319,4 +319,52 @@ ApiResponse<BankResDTO.BankAssetResponse> getAccountsByBank(
             )
     })
     ApiResponse<AssetResDTO.AssetSummaryCountDTO> getAssetCount(@CurrentMember Long memberId);
+
+    @Operation(
+            summary = "전체 자산 새로고침(동기화) 요청 API",
+            description = """
+                    사용자가 연동한 모든 금융사의 최신 거래내역 수집을 **백그라운드에서 시작**하도록 요청합니다.
+                    - **즉시 응답**: API는 동기화 작업을 백그라운드로 넘기고 즉시 '요청 성공' 응답을 반환합니다.
+                    - **결과 확인**: 실제 동기화 결과는 잠시 후 자산 관련 다른 API를 통해 확인해야 합니다.
+                    - **10분 쿨타임**: 마지막 동기화 시간으로부터 10분 이내에는 재호출할 수 없습니다.
+                    """
+    )
+    @ApiResponses({
+            @io.swagger.v3.oas.annotations.responses.ApiResponse(
+                    responseCode = "200",
+                    description = "성공 - 동기화 작업이 성공적으로 시작됨",
+                    content = @Content(
+                            schema = @Schema(implementation = ApiResponse.class),
+                            examples = @ExampleObject(
+                                    name = "성공 예시",
+                                    value = """
+                                            {
+                                              "isSuccess": true,
+                                              "code": "ASSET200_1",
+                                              "message": "자산 동기화 요청이 성공적으로 접수되었습니다. 잠시 후 데이터를 확인해주세요.",
+                                              "result": null
+                                            }
+                                            """
+                            )
+                    )
+            ),
+            @io.swagger.v3.oas.annotations.responses.ApiResponse(
+                    responseCode = "429",
+                    description = "실패 - 10분 쿨타임 제한",
+                    content = @Content(
+                            schema = @Schema(implementation = ApiResponse.class),
+                            examples = @ExampleObject(
+                                    name = "쿨타임 실패 예시",
+                                    value = """
+                                            {
+                                              "isSuccess": false,
+                                              "code": "ASSET429_1",
+                                              "message": "자산 동기화는 10분에 한 번만 요청할 수 있습니다."
+                                            }
+                                            """
+                            )
+                    )
+            )
+    })
+    ApiResponse<Void> refreshAssetSync(@Parameter(hidden = true) @CurrentMember Long memberId);
 }

src/main/java/org/umc/valuedi/domain/asset/dto/res/AssetResDTO.java

@@ -6,6 +6,9 @@
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 
+import java.time.LocalDate;
+import java.util.List;
+
 @Schema(description = "자산 통합 응답 DTO")
 public class AssetResDTO {
 
@@ -24,4 +27,28 @@ public static class AssetSummaryCountDTO {
         @Schema(description = "총 연동 자산 수 (계좌 + 카드)", example = "8")
         private Long totalAssetCount;
     }
-}
+
+    @Getter
+    @AllArgsConstructor
+    @Builder
+    @Schema(description = "AssetFetchService의 내부 처리 결과 DTO (API 응답으로 직접 사용되지 않음)")
+    public static class AssetSyncResult {
+        @Schema(description = "새로 수집된 은행 거래내역 수")
+        private int newBankTransactionCount;
+
+        @Schema(description = "새로 수집된 카드 승인내역 수")
+        private int newCardApprovalCount;
+
+        @Schema(description = "데이터 수집에 성공한 기관 목록")
+        private List<String> successOrganizations;
+
+        @Schema(description = "데이터 수집에 실패한 기관 목록")
+        private List<String> failureOrganizations;
+
+        @Schema(description = "가계부 동기화에 사용될 조회 시작일")
+        private LocalDate fromDate;
+
+        @Schema(description = "가계부 동기화에 사용될 조회 종료일")
+        private LocalDate toDate;
+    }
+}

src/main/java/org/umc/valuedi/domain/asset/entity/BankTransaction.java

@@ -17,7 +17,15 @@
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
 @AllArgsConstructor(access = AccessLevel.PRIVATE)
 @Getter
-@Table(name = "bank_transaction")
+@Table(
+        name = "bank_transaction",
+        uniqueConstraints = {
+                @UniqueConstraint(
+                        name = "uk_bank_transaction_identity",
+                        columnNames = {"bank_account_id", "tr_datetime", "in_amount", "out_amount", "desc3"}
+                )
+        }
+)
 public class BankTransaction extends BaseEntity {
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)

src/main/java/org/umc/valuedi/domain/asset/exception/AssetException.java

@@ -0,0 +1,10 @@
+package org.umc.valuedi.domain.asset.exception;
+
+import org.umc.valuedi.global.apiPayload.code.BaseErrorCode;
+import org.umc.valuedi.global.apiPayload.exception.GeneralException;
+
+public class AssetException extends GeneralException {
+    public AssetException(BaseErrorCode code) {
+        super(code);
+    }
+}

src/main/java/org/umc/valuedi/domain/asset/exception/code/AssetErrorCode.java

@@ -0,0 +1,18 @@
+package org.umc.valuedi.domain.asset.exception.code;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import org.springframework.http.HttpStatus;
+import org.umc.valuedi.global.apiPayload.code.BaseErrorCode;
+
+@Getter
+@AllArgsConstructor
+public enum AssetErrorCode implements BaseErrorCode {
+
+    SYNC_COOL_DOWN(HttpStatus.TOO_MANY_REQUESTS, "ASSET429_1", "전체 동기화는 10분에 한 번만 요청할 수 있습니다."),
+    ;
+
+    private final HttpStatus status;
+    private final String code;
+    private final String message;
+}

src/main/java/org/umc/valuedi/domain/asset/exception/code/AssetSuccessCode.java

@@ -0,0 +1,19 @@
+package org.umc.valuedi.domain.asset.exception.code;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import org.springframework.http.HttpStatus;
+import org.umc.valuedi.global.apiPayload.code.BaseSuccessCode;
+
+
+@Getter
+@AllArgsConstructor
+public enum AssetSuccessCode implements BaseSuccessCode {
+
+    SYNC_REQUEST_SUCCESS(HttpStatus.OK, "ASSET200_1", "자산 동기화 요청이 성공적으로 접수되었습니다. 잠시 후 데이터를 확인해주세요."),
+    ;
+
+    private final HttpStatus status;
+    private final String code;
+    private final String message;
+}

src/main/java/org/umc/valuedi/domain/asset/repository/bank/bankTransaction/BankTransactionRepository.java

@@ -1,11 +1,21 @@
 package org.umc.valuedi.domain.asset.repository.bank.bankTransaction;
 
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import org.umc.valuedi.domain.asset.entity.BankAccount;
 import org.umc.valuedi.domain.asset.entity.BankTransaction;
 
 import java.time.LocalDate;
+import java.time.LocalDateTime;
 import java.util.List;
+import java.util.Optional;
 
 public interface BankTransactionRepository extends JpaRepository<BankTransaction, Long>, BankTransactionRepositoryCustom {
     List<BankTransaction> findByTrDateBetween(LocalDate fromDate, LocalDate toDate);
+
+    @Query("SELECT MAX(bt.trDate) FROM BankTransaction bt WHERE bt.bankAccount = :account")
+    Optional<LocalDate> findLatestTransactionDateByAccount(@Param("account") BankAccount account);
+
+    List<BankTransaction> findByBankAccountInAndTrDatetimeAfter(List<BankAccount> accounts, LocalDateTime startTime);
 }

src/main/java/org/umc/valuedi/domain/asset/repository/bank/bankTransaction/BankTransactionRepositoryImpl.java

@@ -3,21 +3,23 @@
 import lombok.RequiredArgsConstructor;
 import org.springframework.jdbc.core.BatchPreparedStatementSetter;
 import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Repository;
 import org.umc.valuedi.domain.asset.entity.BankTransaction;
 
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
 import java.sql.Timestamp;
 import java.util.List;
 
+@Repository
 @RequiredArgsConstructor
 public class BankTransactionRepositoryImpl implements BankTransactionRepositoryCustom {
 
     private final JdbcTemplate jdbcTemplate;
 
     @Override
     public void bulkInsert(List<BankTransaction> transactions) {
-        if (transactions.isEmpty()) {
+        if (transactions == null || transactions.isEmpty()) {
             return;
         }
 

src/main/java/org/umc/valuedi/domain/asset/repository/card/card/CardRepository.java

@@ -32,4 +32,6 @@ public interface CardRepository extends JpaRepository<Card, Long> {
             "AND c.isActive = true " +
             "ORDER BY c.createdAt DESC")
     List<Card> findAllByMemberId(@Param("memberId") Long memberId);
+
+    List<Card> findAllByCodefConnection(CodefConnection connection);
 }