커스텀 액티비티

package com.tmaxsoft.anylink.custom;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import com.tmaxsoft.anylink.engine.core.activity.custom.AnyLinkCustomActivity;
import com.tmaxsoft.anylink.engine.core.activity.custom.CustomActivityContext;

public class MyCustomActivity implements AnyLinkCustomActivity {
    private static final Logger logger = LogManager.getLogger(MyCustomActivity.class);

    @Override
    public void execute(CustomActivityContext context) {
        // TODO Auto-generated method stub

    }
}

public interface AnyLinkCustomActivity {

    /**
     * 초기화 - 액티비티 실행 전 한번 호출 (선택)
     * @param configuration BPMN에서 설정된 구성 정보
     */
    default void initialize(Map<String, Object> configuration) {
        // 기본 구현 - 필요시 오버라이드
    }

    /**
     * 실제 비즈니스 로직 실행 (필수)
     * @param context 액티비티 실행 컨텍스트
     */
    void execute(CustomActivityContext context);

    /**
     * 정리 작업 - 액티비티 실행 후 호출 (선택)
     * 예외 발생 시에도 호출됩니다.
     */
    default void cleanup() {
        // 기본 구현 - 필요시 오버라이드
    }

    /**
     * 실행 타임아웃 설정 (밀리초) (선택)
     * @return 타임아웃 시간 (기본 30초)
     */
    default long getTimeoutMillis() {
        return 30_000L;
    }
}

@Override
public void execute(CustomActivityContext context) {
    // 변수 조회
    String orderId = (String) context.getVariable("orderId");
    Integer amount = context.getVariable("amount", Integer.class);

    // 변수 설정
    context.setVariable("processedAmount", amount * 1.1);
    context.setVariable("status", "PROCESSED");

    // 변수 제거
    context.removeVariable("tempData");
}

@Override
public void execute(CustomActivityContext context) {
    // GUID 조회
    String guid = context.getGuid();

    // 거래 정보 조회
    CustomActivityContext.BizTxInfo bizTxInfo = context.getBizTxInfo();
    String bizTxId = bizTxInfo.getBizTxId();

    // 엔드포인트 정보 조회
    CustomActivityContext.EndpointInfo endpointInfo = context.getEndpointInfo();
    String endpointId = endpointInfo.getEndpointId();

    // 시작 시간 조회
    long startTime = context.getStartTime();

    // 구성 정보 조회
    Map<String, Object> config = context.getConfiguration();
}

@Override
public void execute(CustomActivityContext context) {
    // HTTP 클라이언트 등을 사용한 외부 서비스 호출
    // 주의: 외부 라이브러리 사용 시 의존성 확인 필요

    String result = callExternalService();
    context.setVariable("externalResult", result);
}

private String callExternalService() {
    // 외부 서비스 호출 로직
    return "result";
}

@Override
public void execute(CustomActivityContext context) {
    String type = (String) context.getVariable("transactionType");
    Integer amount = context.getVariable("amount", Integer.class);

    String priority;
    if ("VIP".equals(type) || amount > 1000000) {
        priority = "HIGH";
    } else if (amount > 100000) {
        priority = "MEDIUM";
    } else {
        priority = "LOW";
    }

    context.setVariable("priority", priority);
}

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

public class MyCustomActivity implements AnyLinkCustomActivity {
    private static final Logger logger = LogManager.getLogger(MyCustomActivity.class);

    @Override
    public void execute(CustomActivityContext context) {
        String guid = context.getGuid();
        String bizTxId = context.getBizTxInfo().getBizTxId();

        logger.debug("Processing activity - guid={}, bizTxId={}", guid, bizTxId);

        // 처리 로직

        logger.info("Activity processed - guid={}, bizTxId={}", guid, bizTxId);
    }
}

import java.util.Map;

public class MyCustomActivity implements AnyLinkCustomActivity {
    private String configuredValue;

    @Override
    public void initialize(Map<String, Object> configuration) {
        // BPMN에서 설정된 구성 정보로 초기화
        this.configuredValue = (String) configuration.get("someKey");
    }

    @Override
    public void execute(CustomActivityContext context) {
        // 초기화된 값 사용
        context.setVariable("result", processWithConfig(configuredValue));
    }

    @Override
    public void cleanup() {
        // 리소스 정리
        this.configuredValue = null;
    }

    private String processWithConfig(String config) {
        return "processed: " + config;
    }
}

public class LongRunningActivity implements AnyLinkCustomActivity {

    @Override
    public void execute(CustomActivityContext context) {
        // 장시간 실행 로직
    }

    @Override
    public long getTimeoutMillis() {
        // 60초로 타임아웃 설정
        return 60_000L;
    }
}

@Override
public void execute(CustomActivityContext context) {
    try {
        // 처리 로직
    } catch (Exception e) {
        // 오류 정보를 변수에 저장
        context.setVariable("errorMessage", e.getMessage());

        // 예외를 다시 던지면 플로우 중단
        throw new RuntimeException("Processing failed", e);
    }
}

@Override
public void execute(CustomActivityContext context) {
    try {
        // 처리 로직
        context.setVariable("success", true);
    } catch (Exception e) {
        logger.error("Processing failed - guid={}, reason={}",
            context.getGuid(), e.getMessage(), e);
        context.setVariable("success", false);
        context.setVariable("errorMessage", e.getMessage());
        // 예외를 던지지 않으면 플로우 계속 진행
    }
}