diff --git a/src/main/java/com/mfsys/uco/constants/UCOURI.java b/src/main/java/com/mfsys/uco/constants/UCOURI.java index a2551c2..fc16402 100644 --- a/src/main/java/com/mfsys/uco/constants/UCOURI.java +++ b/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"; } diff --git a/src/main/java/com/mfsys/uco/service/DepositUcoProductsService.java b/src/main/java/com/mfsys/uco/service/DepositUcoProductsService.java index 0d3aae2..df96241 100644 --- a/src/main/java/com/mfsys/uco/service/DepositUcoProductsService.java +++ b/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 fetchDepositUcoProducts(String porOrgacode) { - return depositUcoProductsRepository.fetchAllUcoActiveProducts(porOrgacode); + String url = UCOURI.FETCH_DEPOSIT_PRODUCTS + "?porOrgacode=" + porOrgacode; + return (List) webClientDepositService.fetchUcoDepositProducts(url, porOrgacode); } diff --git a/src/main/java/com/mfsys/uco/service/WebClientDepositService.java b/src/main/java/com/mfsys/uco/service/WebClientDepositService.java index c38cbd9..79d384a 100644 --- a/src/main/java/com/mfsys/uco/service/WebClientDepositService.java +++ b/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 handleResponse(Mono> responseMono, String porgaCode) { try {