Skip to content

Commit

Permalink
[SEL-5902] Update institution reqiurements migrating from enum to str…
Browse files Browse the repository at this point in the history 
…ing (#586)
  • Loading branch information
@andrea-putzu
andrea-putzu authored Oct 31, 2024
1 parent 501a03a commit 8faf8ec
Showing 1 changed file with 174 additions and 146 deletions.
320 changes: 174 additions & 146 deletions ...-functions/src/main/java/it/pagopa/selfcare/onboarding/utils/BaseNotificationBuilder.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@
import it.pagopa.selfcare.onboarding.entity.Onboarding;
import it.pagopa.selfcare.onboarding.entity.PaymentServiceProvider;
import it.pagopa.selfcare.onboarding.entity.Token;
import org.openapi.quarkus.core_json.model.InstitutionRequest;
import org.openapi.quarkus.core_json.model.InstitutionResponse;
import org.openapi.quarkus.core_json.model.PaymentServiceProviderResponse;
import org.openapi.quarkus.party_registry_proxy_json.api.GeographicTaxonomiesApi;
Expand All @@ -25,163 +26,190 @@
import java.util.UUID;

public class BaseNotificationBuilder implements NotificationBuilder {
public static final String CLOSED = "CLOSED";
public static final String ACTIVE = "ACTIVE";
private final String alternativeEmail;
protected NotificationConfig.Consumer consumer;
protected final InstitutionApi proxyRegistryInstitutionApi;
protected final GeographicTaxonomiesApi geographicTaxonomiesApi;
protected final org.openapi.quarkus.core_json.api.InstitutionApi coreInstitutionApi;
protected static final String DESCRIPTION_TO_REPLACE_REGEX = " - COMUNE";
protected static final Logger log = LoggerFactory.getLogger(BaseNotificationBuilder.class);


public BaseNotificationBuilder(
String alternativeEmail,
NotificationConfig.Consumer consumer,
InstitutionApi proxyRegistryInstitutionApi,
GeographicTaxonomiesApi geographicTaxonomiesApi,
org.openapi.quarkus.core_json.api.InstitutionApi coreInstitutionApi
) {
this.alternativeEmail = alternativeEmail;
this.consumer = consumer;
this.proxyRegistryInstitutionApi = proxyRegistryInstitutionApi;
this.geographicTaxonomiesApi = geographicTaxonomiesApi;
this.coreInstitutionApi = coreInstitutionApi;
public static final String CLOSED = "CLOSED";
public static final String ACTIVE = "ACTIVE";
private final String alternativeEmail;
protected NotificationConfig.Consumer consumer;
protected final InstitutionApi proxyRegistryInstitutionApi;
protected final GeographicTaxonomiesApi geographicTaxonomiesApi;
protected final org.openapi.quarkus.core_json.api.InstitutionApi coreInstitutionApi;
protected static final String DESCRIPTION_TO_REPLACE_REGEX = " - COMUNE";
protected static final Logger log = LoggerFactory.getLogger(BaseNotificationBuilder.class);

public BaseNotificationBuilder(
String alternativeEmail,
NotificationConfig.Consumer consumer,
InstitutionApi proxyRegistryInstitutionApi,
GeographicTaxonomiesApi geographicTaxonomiesApi,
org.openapi.quarkus.core_json.api.InstitutionApi coreInstitutionApi) {
this.alternativeEmail = alternativeEmail;
this.consumer = consumer;
this.proxyRegistryInstitutionApi = proxyRegistryInstitutionApi;
this.geographicTaxonomiesApi = geographicTaxonomiesApi;
this.coreInstitutionApi = coreInstitutionApi;
}

public NotificationToSend buildNotificationToSend(
Onboarding onboarding, Token token, InstitutionResponse institution, QueueEvent queueEvent) {
NotificationToSend notificationToSend = new NotificationToSend();
if (queueEvent.equals(QueueEvent.ADD)) {
notificationToSend.setId(onboarding.getId());
} else {
notificationToSend.setId(UUID.randomUUID().toString());
}

public NotificationToSend buildNotificationToSend(Onboarding onboarding, Token token, InstitutionResponse institution, QueueEvent queueEvent) {
NotificationToSend notificationToSend = new NotificationToSend();
if (queueEvent.equals(QueueEvent.ADD)) {
notificationToSend.setId(onboarding.getId());
} else {
notificationToSend.setId(UUID.randomUUID().toString());
}
notificationToSend.setState(convertOnboardingStatusToNotificationStatus(onboarding.getStatus()));
mapDataFromOnboarding(onboarding, notificationToSend, queueEvent);
notificationToSend.setInstitution(retrieveInstitution(institution));
if (Objects.nonNull(token)) {
setTokenData(notificationToSend, token);
}

return notificationToSend;
notificationToSend.setState(
convertOnboardingStatusToNotificationStatus(onboarding.getStatus()));
mapDataFromOnboarding(onboarding, notificationToSend, queueEvent);
notificationToSend.setInstitution(retrieveInstitution(institution));
if (Objects.nonNull(token)) {
setTokenData(notificationToSend, token);
}

private void mapDataFromOnboarding(Onboarding onboarding, NotificationToSend notificationToSend, QueueEvent queueEvent) {
notificationToSend.setOnboardingTokenId(onboarding.getId());
notificationToSend.setBilling(retrieveBilling(onboarding));
notificationToSend.setPricingPlan(onboarding.getPricingPlan());
notificationToSend.setCreatedAt(OffsetDateTime.of(Optional.ofNullable(onboarding.getActivatedAt()).orElse(onboarding.getCreatedAt()), ZoneOffset.UTC));
notificationToSend.setProduct(onboarding.getProductId());

if (queueEvent.equals(QueueEvent.ADD)) {
// when onboarding complete last update is activated date
notificationToSend.setUpdatedAt(OffsetDateTime.of(Optional.ofNullable(onboarding.getActivatedAt()).orElse(onboarding.getCreatedAt()), ZoneOffset.UTC));
} else {
if (onboarding.getStatus().equals(OnboardingStatus.DELETED)) {
// Queue.ClosedAt: if token.deleted show closedAt
notificationToSend.setClosedAt(OffsetDateTime.of(Optional.ofNullable(onboarding.getDeletedAt()).orElse(onboarding.getUpdatedAt()), ZoneOffset.UTC));
notificationToSend.setUpdatedAt(OffsetDateTime.of(Optional.ofNullable(onboarding.getDeletedAt()).orElse(onboarding.getUpdatedAt()), ZoneOffset.UTC));
} else {
// when update last update is updated date
notificationToSend.setUpdatedAt(OffsetDateTime.of(Optional.ofNullable(onboarding.getUpdatedAt()).orElse(onboarding.getCreatedAt()), ZoneOffset.UTC));
}
}
return notificationToSend;
}

private void mapDataFromOnboarding(
Onboarding onboarding, NotificationToSend notificationToSend, QueueEvent queueEvent) {
notificationToSend.setOnboardingTokenId(onboarding.getId());
notificationToSend.setBilling(retrieveBilling(onboarding));
notificationToSend.setPricingPlan(onboarding.getPricingPlan());
notificationToSend.setCreatedAt(
OffsetDateTime.of(
Optional.ofNullable(onboarding.getActivatedAt()).orElse(onboarding.getCreatedAt()),
ZoneOffset.UTC));
notificationToSend.setProduct(onboarding.getProductId());

if (queueEvent.equals(QueueEvent.ADD)) {
// when onboarding complete last update is activated date
notificationToSend.setUpdatedAt(
OffsetDateTime.of(
Optional.ofNullable(onboarding.getActivatedAt()).orElse(onboarding.getCreatedAt()),
ZoneOffset.UTC));
} else {
if (onboarding.getStatus().equals(OnboardingStatus.DELETED)) {
// Queue.ClosedAt: if token.deleted show closedAt
notificationToSend.setClosedAt(
OffsetDateTime.of(
Optional.ofNullable(onboarding.getDeletedAt()).orElse(onboarding.getUpdatedAt()),
ZoneOffset.UTC));
notificationToSend.setUpdatedAt(
OffsetDateTime.of(
Optional.ofNullable(onboarding.getDeletedAt()).orElse(onboarding.getUpdatedAt()),
ZoneOffset.UTC));
} else {
// when update last update is updated date
notificationToSend.setUpdatedAt(
OffsetDateTime.of(
Optional.ofNullable(onboarding.getUpdatedAt()).orElse(onboarding.getCreatedAt()),
ZoneOffset.UTC));
}
}

private String convertOnboardingStatusToNotificationStatus(OnboardingStatus status) {
if (status.equals(OnboardingStatus.DELETED)) {
return CLOSED;
} else if (status.equals(OnboardingStatus.COMPLETED)) {
return ACTIVE;
} else {
return status.name();
}
}

private String convertOnboardingStatusToNotificationStatus(OnboardingStatus status) {
if (status.equals(OnboardingStatus.DELETED)) {
return CLOSED;
} else if (status.equals(OnboardingStatus.COMPLETED)) {
return ACTIVE;
} else {
return status.name();
}

@Override
public InstitutionToNotify retrieveInstitution(InstitutionResponse institution) {
InstitutionToNotify toNotify = new InstitutionToNotify();
toNotify.setInstitutionType(InstitutionType.valueOf(institution.getInstitutionType()));
toNotify.setDescription(institution.getDescription());
toNotify.setDigitalAddress(institution.getDigitalAddress() == null ? alternativeEmail : institution.getDigitalAddress());
toNotify.setAddress(institution.getAddress());
toNotify.setTaxCode(institution.getTaxCode());
toNotify.setOrigin(institution.getOrigin());
toNotify.setOriginId(institution.getOriginId());
toNotify.setZipCode(institution.getZipCode());
toNotify.setPaymentServiceProvider(toSetPaymentServiceProvider(institution.getPaymentServiceProvider()));
if (institution.getSubunitType() != null && !"EC".equals(institution.getSubunitType())) {
toNotify.setSubUnitType(institution.getSubunitType());
toNotify.setSubUnitCode(institution.getSubunitCode());
}
RootParent rootParent = new RootParent();
if (Objects.nonNull(institution.getRootParent())) {
rootParent.setId(institution.getRootParent().getId());
rootParent.setDescription(institution.getRootParent().getDescription());
InstitutionResponse parentInstitution = coreInstitutionApi.retrieveInstitutionByIdUsingGET(rootParent.getId());
rootParent.setOriginId(Objects.nonNull(parentInstitution) ? parentInstitution.getOriginId() : null);
toNotify.setRootParent(rootParent);
}
if (Objects.nonNull(institution.getAttributes()) && !institution.getAttributes().isEmpty()) {
toNotify.setCategory(institution.getAttributes().get(0).getCode());
}
if (Objects.isNull(institution.getCity())) {
retrieveAndSetGeographicData(toNotify);
} else {
toNotify.setCounty(institution.getCounty());
toNotify.setCountry(institution.getCountry());
toNotify.setIstatCode(institution.getIstatCode());
toNotify.setCity(institution.getCity().replace(DESCRIPTION_TO_REPLACE_REGEX, ""));
}
return toNotify;
}

@Override
public InstitutionToNotify retrieveInstitution(InstitutionResponse institution) {
InstitutionToNotify toNotify = new InstitutionToNotify();
toNotify.setInstitutionType(InstitutionType.valueOf(institution.getInstitutionType()));
toNotify.setDescription(institution.getDescription());
toNotify.setDigitalAddress(
institution.getDigitalAddress() == null
? alternativeEmail
: institution.getDigitalAddress());
toNotify.setAddress(institution.getAddress());
toNotify.setTaxCode(institution.getTaxCode());
toNotify.setOrigin(institution.getOrigin());
toNotify.setOriginId(institution.getOriginId());
toNotify.setZipCode(institution.getZipCode());
toNotify.setPaymentServiceProvider(
toSetPaymentServiceProvider(institution.getPaymentServiceProvider()));
if (institution.getSubunitType() != null && !"EC".equals(institution.getSubunitType())) {
toNotify.setSubUnitType(institution.getSubunitType());
toNotify.setSubUnitCode(institution.getSubunitCode());
}

private PaymentServiceProvider toSetPaymentServiceProvider(PaymentServiceProviderResponse paymentServiceProvider) {
PaymentServiceProvider paymentServiceProviderToNotify = new PaymentServiceProvider();
if (Objects.isNull(paymentServiceProvider)) {
return null;
}

paymentServiceProviderToNotify.setAbiCode(paymentServiceProvider.getAbiCode());
paymentServiceProviderToNotify.setBusinessRegisterNumber(paymentServiceProvider.getBusinessRegisterNumber());
paymentServiceProviderToNotify.setLegalRegisterName(paymentServiceProvider.getLegalRegisterName());
paymentServiceProviderToNotify.setLegalRegisterNumber(paymentServiceProvider.getLegalRegisterNumber());
paymentServiceProviderToNotify.setVatNumberGroup(paymentServiceProvider.getVatNumberGroup());
return paymentServiceProviderToNotify;
RootParent rootParent = new RootParent();
if (Objects.nonNull(institution.getRootParent())) {
rootParent.setId(institution.getRootParent().getId());
rootParent.setDescription(institution.getRootParent().getDescription());
InstitutionResponse parentInstitution =
coreInstitutionApi.retrieveInstitutionByIdUsingGET(rootParent.getId());
rootParent.setOriginId(
Objects.nonNull(parentInstitution) ? parentInstitution.getOriginId() : null);
toNotify.setRootParent(rootParent);
}

@Override
public void retrieveAndSetGeographicData(InstitutionToNotify institution) {
InstitutionResource institutionProxyInfo = proxyRegistryInstitutionApi.findInstitutionUsingGET(institution.getTaxCode(), null, null);
institution.setIstatCode(institutionProxyInfo.getIstatCode());
institution.setCategory(institutionProxyInfo.getCategory());
GeographicTaxonomyResource geographicTaxonomies = geographicTaxonomiesApi.retrieveGeoTaxonomiesByCodeUsingGET(institutionProxyInfo.getIstatCode());
institution.setCounty(geographicTaxonomies.getProvinceAbbreviation());
institution.setCountry(geographicTaxonomies.getCountryAbbreviation());
institution.setCity(geographicTaxonomies.getDesc().replace(DESCRIPTION_TO_REPLACE_REGEX, ""));
if (Objects.nonNull(institution.getAttributes()) && !institution.getAttributes().isEmpty()) {
toNotify.setCategory(institution.getAttributes().get(0).getCode());
}

@Override
public BillingToSend retrieveBilling(Onboarding onboarding) {
return convertBilling(onboarding.getBilling());
if (Objects.isNull(institution.getCity())
&& institution
.getInstitutionType()
.equals(InstitutionRequest.InstitutionTypeEnum.PA.name())) {
retrieveAndSetGeographicData(toNotify);
} else {
toNotify.setCounty(institution.getCounty());
toNotify.setCountry(institution.getCountry());
toNotify.setIstatCode(institution.getIstatCode());
toNotify.setCity(institution.getCity().replace(DESCRIPTION_TO_REPLACE_REGEX, ""));
}
return toNotify;
}

private BillingToSend convertBilling(Billing billing) {
BillingToSend billingToSend = new BillingToSend();
if (Objects.isNull(billing)) {
return null;
}
billingToSend.setVatNumber(billing.getVatNumber());
billingToSend.setRecipientCode(billing.getRecipientCode());
return billingToSend;
private PaymentServiceProvider toSetPaymentServiceProvider(PaymentServiceProviderResponse psp) {
PaymentServiceProvider paymentServiceProviderToNotify = new PaymentServiceProvider();
if (Objects.isNull(psp)) {
return null;
}

@Override
public void setTokenData(NotificationToSend notificationToSend, Token token) {
if (Objects.nonNull(token) && Objects.nonNull(token.getContractSigned())) {
notificationToSend.setFileName(Paths.get(token.getContractSigned()).getFileName().toString());
notificationToSend.setContentType(token.getContractSigned());
}
paymentServiceProviderToNotify.setAbiCode(psp.getAbiCode());
paymentServiceProviderToNotify.setBusinessRegisterNumber(psp.getBusinessRegisterNumber());
paymentServiceProviderToNotify.setLegalRegisterName(psp.getLegalRegisterName());
paymentServiceProviderToNotify.setLegalRegisterNumber(psp.getLegalRegisterNumber());
paymentServiceProviderToNotify.setVatNumberGroup(psp.getVatNumberGroup());
return paymentServiceProviderToNotify;
}

@Override
public void retrieveAndSetGeographicData(InstitutionToNotify institution) {
InstitutionResource proxyInfo =
proxyRegistryInstitutionApi.findInstitutionUsingGET(institution.getTaxCode(), null, null);
institution.setIstatCode(proxyInfo.getIstatCode());
institution.setCategory(proxyInfo.getCategory());
GeographicTaxonomyResource geographicTaxonomies =
geographicTaxonomiesApi.retrieveGeoTaxonomiesByCodeUsingGET(proxyInfo.getIstatCode());
institution.setCounty(geographicTaxonomies.getProvinceAbbreviation());
institution.setCountry(geographicTaxonomies.getCountryAbbreviation());
institution.setCity(geographicTaxonomies.getDesc().replace(DESCRIPTION_TO_REPLACE_REGEX, ""));
}

@Override
public BillingToSend retrieveBilling(Onboarding onboarding) {
return convertBilling(onboarding.getBilling());
}

private BillingToSend convertBilling(Billing billing) {
BillingToSend billingToSend = new BillingToSend();
if (Objects.isNull(billing)) {
return null;
}
billingToSend.setVatNumber(billing.getVatNumber());
billingToSend.setRecipientCode(billing.getRecipientCode());
return billingToSend;
}

@Override
public void setTokenData(NotificationToSend notificationToSend, Token token) {
if (Objects.nonNull(token) && Objects.nonNull(token.getContractSigned())) {
notificationToSend.setFileName(Paths.get(token.getContractSigned()).getFileName().toString());
notificationToSend.setContentType(token.getContractSigned());
}
}
}

0 comments on commit 8faf8ec

Please sign in to comment.