ValidatePerson.java 및 MergePerson.java 파일의 CustomLogic 구현

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"));
                        }

CustomLogicFactorImpl.java 파일의 CustomLogicFactory 구현

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

bes-external-call.xsd 파일에 정의된 외부 호출을 나타내는 요청의 인스턴스입니다.

callContext

CompositeServiceClient 요청에서 사용자 지정 논리 구현에 사용되는 복합 서비스 컨텍스트의 인스턴스입니다.

CustomLogicService.java 파일의 WebService 구현

/**
* 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);
}

BESExternalCall 예제

한 개인을 생성하거나 업데이트할 때 이 호출은 해당하는 개인에게 적어도 하나의 주소가 있는지 확인합니다. 유효성 검사가 실패하면 호출에서 사용자 지정 오류 메시지가 반환됩니다.
병합된 레코드의 미리 보기를 생성하는 경우 이 호출에서 전화 번호는 병합되지 않습니다.
레코드를 병합하는 경우 이 호출에서 전화 번호는 병합되지 않습니다.