commit 11206

src/main/java/com/mfsys/uco/constants/UCOURI.java

@@ -5,6 +5,7 @@ public interface UCOURI {
     String CUSTOMER_ONBOARDING = "/crm/onboarding/digital/customer";
     String GET_CMP_UCOACCOUNTS = "/deposit/getUcoAccounts";
     String FETCH_EXCHANGE_RATE = "/deposit/uco/fetchExchangeRate";
+    String FETCH_DEPOSIT_PRODUCTS = "/deposit/product/uco";
     String UCO_CUSTOMER_ACCOUNT = "/deposit/onboarding/digital/UcoCustomerAccount";
 
 }

src/main/java/com/mfsys/uco/service/DepositUcoProductsService.java

@@ -1,5 +1,6 @@
 package com.mfsys.uco.service;
 
+import com.mfsys.uco.constants.UCOURI;
 import com.mfsys.uco.model.ChartOfAccount;
 import com.mfsys.uco.model.Product;
 import com.mfsys.uco.model.TransactionTrail;
@@ -13,13 +14,14 @@ import java.util.List;
 @Service
 @RequiredArgsConstructor
 public class DepositUcoProductsService {
-
+    private final WebClientDepositService webClientDepositService;
     private final DepositUcoProductsRepository depositUcoProductsRepository;
     private final ChartOfAccountRepository chartOfAccountRepository;
 
 
     public List<Product> fetchDepositUcoProducts(String porOrgacode) {
-        return depositUcoProductsRepository.fetchAllUcoActiveProducts(porOrgacode);
+            String url = UCOURI.FETCH_DEPOSIT_PRODUCTS + "?porOrgacode=" + porOrgacode;
+            return (List<Product>) webClientDepositService.fetchUcoDepositProducts(url, porOrgacode);
     }
 
 

src/main/java/com/mfsys/uco/service/WebClientDepositService.java

@@ -59,6 +59,12 @@ public class WebClientDepositService {
                         .header("POR_ORGACODE", porOrgacode).retrieve().toEntity(Object.class),
                 null);
     }
+    public Object fetchUcoDepositProducts(String url, String porOrgacode) {
+        return handleResponse(webClientDeposit.get().uri(url).accept(MediaType.APPLICATION_JSON)
+                        .header("SUS_USERCODE", porOrgacode)
+                        .header("POR_ORGACODE", porOrgacode).retrieve().toEntity(Object.class),
+                null);
+    }
 
     private <T> T handleResponse(Mono<ResponseEntity<T>> responseMono, String porgaCode) {
         try {