Implementaciones de CustomLogic en los archivos ValidatePerson.java y MergePerson.java

public class ValidatePerson implements CustomLogic {
    private CompositeServiceClient besClient;
    private CallContext callContext;
    public ValidatePerson(CompositeServiceClient besClient, CallContext callContext) {
        this.besClient = besClient;
        this.callContext = callContext;
    }
    @Override
    public DataObject process(HelperContext helperContext, DataObject inputSdo,
                              Map < String, Object > inParams, 
                              Map < String, Object > outParams) throws StepException {
            try {
                List < ValidationError > errorList = new ArrayList < > ();
                DataFactory dataFactory = helperContext.getDataFactory();

                // Ensure that the Person SDO has at least one Address item
                List<?> list = inputSdo.getList("Person/Addresses/item");
                if ((list == null) || list.isEmpty()) {
                    String personId = inputSdo.getString("Person/rowidObject");

                    if(personId != null) { // Verify if an address already exists
                        DataObject readEntity = dataFactory.create(ReadEntity.class);
                        DataObject personFilter =
                        readEntity.createDataObject("parameters").createDataObject("coFilter").createDataObject("object");
                        personFilter.setString("name", "Person");
                        personFilter.createDataObject("key").setString("rowid", personId);
                        DataObject addressFilter = personFilter.createDataObject("object");
                        addressFilter.setString("name", "Addresses");
                        addressFilter.createDataObject("pager").setInt("recordsToReturn", 1);
                        DataObject readEntityReturn = besClient.process(callContext, readEntity);
                        List existingList = readEntityReturn.getList("object/Person/Addresses/item");
                        if (existingList == null || existingList.isEmpty()) {
                            errorList.add(createValidationError(dataFactory, "CUSTOM-00001", "You must enter at least one Address.", "Person.Addresses"));
                        }

Implementación de CustomLogicFactory en el archivo CustomLogicFactorImpl.java

public class CustomLogicFactoryImpl implements CustomLogicFactory {

             public static final String PERSON = "Person";

             private static final CustomLogic EMPTY_LOGIC = new EmptyLogic();

             private CompositeServiceClient besClient;

             public CustomLogicFactoryImpl(CompositeServiceClient besClient) { this.besClient = besClient; 
             }

             @Override
             public CustomLogic create(ExternalCallRequest externalCallRequest, CallContext callContext) throws StepException {
              // Interest is in the Person business entity. The logic can handle a few service phases.
                 Trigger trigger = externalCallRequest.getTrigger();
                 String businessEntity = trigger.getBusinessEntity();
                 ServicePhase phase = trigger.getServicePhase();

                 switch (phase) {
                     case WRITE_CO_BEFORE_VALIDATE:
                         if (PERSON.equals(businessEntity)) {
                             return new ValidatePerson(besClient, callContext);
                         }
                         break;
                     case PREVIEW_MERGE_CO_BEFORE_EVERYTHING:
                     case MERGE_CO_BEFORE_EVERYTHING:
                         if (PERSON.equals(businessEntity)) {
                             return new MergePerson();
                         }
                         break;
                     default:
                         //
                 }
                 return EMPTY_LOGIC; // This one does nothing
              }

externalCallRequest

Una instancia de la solicitud que representa la llamada externa como se define en el archivo bes-external-call.xsd.

callContext

Una instancia del contexto de servicio compuesto que las solicitudes de CompositeServiceClient usan en implementaciones lógicas personalizadas.

Implementación de WebService en el archivo CustomLogicService.java

/**
* Web service implementation.
* It must accept a {urn:bes-external-call.informatica.mdm}ExternalCallRequest as an operation input
* and return a {urn:bes-external-call.informatica.mdm}ExternalCallResponse as output.
*/
@WebServiceProvider(
        targetNamespace = "http://cs.sample.mdm.informatica.com/",
        serviceName = "CustomLogicService",
        portName = "CustomLogicServicePort",
        wsdlLocation = "WEB-INF/wsdl/custom-logic-service.wsdl"
)
@ServiceMode(Mode.PAYLOAD)
public class CustomLogicService implements Provider<Source> {

    @Override
    public Source invoke(Source request) {

        CompositeServiceClient compositeServiceClient =
createCompositeServiceClient();
        CustomLogicFactory customLogicFactory = new
CustomLogicFactoryImpl(compositeServiceClient);
        String appName = "<trusted_user>"; // replace with proper application user name

        // Create a processor instance and let the instance perform the job.
        // Provide a custom logic factory implementation.
        ExternalCallProcessor externalCallProcessor =
                new ExternalCallProcessor(compositeServiceClient, appName, customLogicFactory);

 return externalCallProcessor.invoke(request);
}

Ejemplo de BESExternalCall

Al crear o actualizar una persona, la llamada valida si la persona tiene al menos una dirección. Si la validación falla, la llamada devuelve un mensaje de error personalizado.
Al generar una vista previa de los registros fusionados, la llamada no fusiona los números de teléfono.
Al fusionar registros, la llamada no fusiona números de teléfono.