Notes

package net.apmm.mdm.cmd.soapclient;

import lombok.extern.slf4j.Slf4j;
import net.apmm.mdm.cmd.client.CMDCommonIdentifierHandler;
import net.apmm.mdm.cmd.client.CMDRequestHeaderModifier;
import net.apmoller.services.amm.customermanagement.v3.*;
import net.apmoller.services.managementframework.commonidentifier.v2.CommonIdentifierRequest;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.retry.annotation.Backoff;
import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Service;
import org.springframework.ws.client.core.support.WebServiceGatewaySupport;
import org.springframework.ws.soap.SoapHeader;
import org.springframework.ws.soap.SoapMessage;

import javax.xml.bind.JAXBContext;
import javax.xml.bind.JAXBException;
import javax.xml.bind.Marshaller;
import java.net.SocketTimeoutException;
import java.util.concurrent.TimeoutException;

@Slf4j
@Service
public class CustomerManagementWebserviceClient extends WebServiceGatewaySupport {

@Value("${spring.application.customerManagement.service.host}/${spring.application.customerManagement.service.resource}")
protected String customerManagementEndPointUrl;
@Autowired
private CMDRequestHeaderModifier soapRequestHeaderModifier;

@Autowired
private CMDCommonIdentifierHandler commonIdentifierHandler;

@Retryable(
value = {SocketTimeoutException.class, TimeoutException.class},
maxAttempts = 3,
backoff = @Backoff(delay = 100),
listeners = {"retryListener"}
)
public SearchDuplicateCustomerResponse searchDuplicateCustomer(SearchDuplicateCustomerRequest searchDuplicateCustomerRequest) {
log.info("Trigger Search Duplicate customer API");
return (SearchDuplicateCustomerResponse) getWebServiceTemplate()
.marshalSendAndReceive(customerManagementEndPointUrl, searchDuplicateCustomerRequest, soapRequestHeaderModifier);
}

@Retryable(
value = {SocketTimeoutException.class, TimeoutException.class},
maxAttempts = 3,
backoff = @Backoff(delay = 100),
listeners = {"retryListener"}
)
public UpsertCustomerResponse upsertCustomer(UpsertCustomerRequest upsertCustomerRequest,String customerCode, String requesterId) {
log.info("Trigger Upsert customer API");

return (UpsertCustomerResponse)getWebServiceTemplate().marshalSendAndReceive(customerManagementEndPointUrl, upsertCustomerRequest, message -> {
SoapMessage soapMessage = (SoapMessage) message;
SoapHeader header = soapMessage.getSoapHeader();
CommonIdentifierRequest commonIdentifierRequest = commonIdentifierHandler.getCommonIdentifierRequestForAudit(customerCode, requesterId);
try {
JAXBContext context = JAXBContext.newInstance(CommonIdentifierRequest.class);
Marshaller marshaller = context.createMarshaller();
marshaller.marshal(commonIdentifierRequest, header.getResult());

} catch (JAXBException e) {
log.error("Unable to get inject commonIdentifier" + e.getMessage() + e);
}
});

}

@Retryable(
value = {SocketTimeoutException.class, TimeoutException.class},
maxAttempts = 3,
backoff = @Backoff(delay = 100),
listeners = {"retryListener"}
)
public RetrieveCustomerResponse retrieveCustomer(RetrieveCustomerRequest retrieveCustomerRequest) {
log.info("Trigger Retrieve customer API");
return (RetrieveCustomerResponse) getWebServiceTemplate()
.marshalSendAndReceive(customerManagementEndPointUrl, retrieveCustomerRequest, soapRequestHeaderModifier);
}


@Retryable(
value = {SocketTimeoutException.class, TimeoutException.class},
maxAttempts = 3,
backoff = @Backoff(delay = 100),
listeners = {"retryListener"}
)
public AssignCustomerContactResponse assignCustContRelation(AssignCustomerContactRequest assignCustomerContactRequest){
log.info("Trigger Assign Customer Contact API");
return (AssignCustomerContactResponse)getWebServiceTemplate().marshalSendAndReceive(customerManagementEndPointUrl, assignCustomerContactRequest, message -> {
SoapMessage soapMessage = (SoapMessage) message;
SoapHeader header = soapMessage.getSoapHeader();
CommonIdentifierRequest commonIdentifierRequest = commonIdentifierHandler.getCommonIdentifierRequest();
try {
JAXBContext context = JAXBContext.newInstance(CommonIdentifierRequest.class);
Marshaller marshaller = context.createMarshaller();
marshaller.marshal(commonIdentifierRequest, header.getResult());

} catch (JAXBException e) {
log.error("Unable to get inject commonIdentifier" + e.getMessage() + e);
}
});
}

}