update http client service

This commit is contained in:
Ramon Ramirez 2026-01-12 18:51:51 -04:00
parent bcf4fcaca6
commit dba8884e1b
4 changed files with 3 additions and 20 deletions

View File

@ -1,11 +0,0 @@
package com.banesco.common.domain.exception;
public class BusinessException extends BaseApiException {
public BusinessException(String errorCode, String message, String fieldPath) {
super(errorCode, message, fieldPath, "business");
}
public BusinessException(String errorCode, String fieldPath) {
super(errorCode, fieldPath, "business");
}
}

View File

@ -7,7 +7,6 @@ import com.banesco.module.legal_customer_product_directory.application.repositor
import com.banesco.module.legal_customer_product_directory.application.usecase.LegalCustomerProductDirectoryUseCase; import com.banesco.module.legal_customer_product_directory.application.usecase.LegalCustomerProductDirectoryUseCase;
import com.banesco.module.legal_customer_product_directory.domain.dto.request.LegalCustomerProductDirectoryRequest; import com.banesco.module.legal_customer_product_directory.domain.dto.request.LegalCustomerProductDirectoryRequest;
import com.banesco.module.legal_customer_product_directory.domain.dto.response.LegalCustomerProductDirectoryResponse; import com.banesco.module.legal_customer_product_directory.domain.dto.response.LegalCustomerProductDirectoryResponse;
import com.banesco.module.legal_customer_product_directory.domain.model.CustomerProductAndServiceDirectory;
import jakarta.enterprise.context.ApplicationScoped; import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject; import jakarta.inject.Inject;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@ -53,15 +52,9 @@ public class LegalCustomerProductDirectoryService implements LegalCustomerProduc
) { ) {
log.info("Calling persistence repository for client: {}", request.getCustomerIbsNumber()); log.info("Calling persistence repository for client: {}", request.getCustomerIbsNumber());
CustomerProductAndServiceDirectory response = persistenceRepository.execute(request);
if(response == null) {
throw HttpStatusCodeException.badRequest("400");
}
return new ApiResponse<>( return new ApiResponse<>(
LegalCustomerProductDirectoryResponse.builder() LegalCustomerProductDirectoryResponse.builder()
.customerProductAndServiceDirectory(response) .customerProductAndServiceDirectory(persistenceRepository.execute(request))
.build(), .build(),
messageHelper.createStatusResponse("200") messageHelper.createStatusResponse("200")
); );

View File

@ -1,5 +1,6 @@
package com.banesco.module.legal_customer_product_directory.infrastructure.adapter; package com.banesco.module.legal_customer_product_directory.infrastructure.adapter;
import com.banesco.common.domain.exception.HttpStatusCodeException;
import com.banesco.common.infrastructure.config.DataSourceConfig; import com.banesco.common.infrastructure.config.DataSourceConfig;
import com.banesco.module.legal_customer_product_directory.application.repository.PersistenceRepository; import com.banesco.module.legal_customer_product_directory.application.repository.PersistenceRepository;
import com.banesco.module.legal_customer_product_directory.domain.dto.request.LegalCustomerProductDirectoryRequest; import com.banesco.module.legal_customer_product_directory.domain.dto.request.LegalCustomerProductDirectoryRequest;
@ -40,7 +41,7 @@ public class PersistenceAdapter implements PersistenceRepository {
log.info("Cuentas obtenidas por el SP: {}", accountsFromSP.size()); log.info("Cuentas obtenidas por el SP: {}", accountsFromSP.size());
if(accountsFromSP.isEmpty()) { if(accountsFromSP.isEmpty()) {
return null; throw HttpStatusCodeException.badRequest("400");
} }
return CustomerProductAndServiceDirectory.builder() return CustomerProductAndServiceDirectory.builder()