流程事件 #

@AbMessage(subscribeKey = "flowEvent")
public void flowEvent(com.dstz.bpm.api.dto.invoke.BpmPluginGlobalInvokeDataDTO dataDTO) {
    logger.info("流程事件-事务消息(flowEvent)处理：{}", JsonUtils.toJSONString(dataDTO));
}

package com.dstz;

import com.dstz.bpm.core.entity.BpmTask;
import com.dstz.bpm.engine.action.model.ActionModel;
import com.dstz.bpm.engine.action.model.TaskActionModel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

@Component("bpmServiceBean")
public class BpmServiceBean {
    private static final Logger logger = LoggerFactory.getLogger(BpmServiceBean.class);

    public void execute(ActionModel actionModel) {
        // 转换为任务
        if (actionModel instanceof TaskActionModel) {
            TaskActionModel taskActionModel = (TaskActionModel) actionModel;
            BpmTask bpmTask = taskActionModel.getBpmTask();
            logger.info("ServiceBean 节点KEY：{}, 节点名称：{}", bpmTask.getNodeKey(), bpmTask.getName());
        }
    }
}

import com.dstz.base.common.enums.GlobalApiCodes
import com.dstz.base.common.exceptions.BusinessMessage
import com.dstz.base.common.utils.AbRestTemplateUtil

// 获取RestTemplate，微服务下参数传递true
final restTemplate = AbRestTemplateUtil.getRestTemplate(false)

// 发送请求 POST application/json
def apiResponse = restTemplate.postForObject("http://localhost:3000/flow-event", [taskName: bpmTask.getName(), taskKey: bpmTask.getNodeKey()], Map.class)

// 发送请求 POST application/x-www-form-urlencoded
def apiResponse = restTemplate.postForObject(
        "http://localhost:3000/flow-event",
        new LinkedMultiValueMap().tap {
            add("taskKey", bpmTask.getNodeKey())
            add("taskName", bpmTask.getName())
        },
        Map.class
)

// 发送请求 GET 占位符
def apiResponse = restTemplate.getForObject("http://localhost:3000/flow-event?taskKey={0}&taskName={1}", Map.class, bpmTask.getNodeKey(), bpmTask.getName())

// 发送请求 GET 命名占位符
def apiResponse = restTemplate.getForObject("http://localhost:3000/flow-event?taskKey={taskKey}&taskName={taskName}", Map.class, [taskKey: bpmTask.getNodeKey(), taskName: bpmTask.getName()])


// 处理请求返回
if (!apiResponse?.isOk) {
    throw new BusinessException(GlobalApiCodes.REMOTE_CALL_ERROR.formatDefaultMessage(apiResponse.message))
}

bpmInstance.setTitle("xxxxx")
bpmInstance.setHasUpdate(true)

import com.dstz.base.utils.AbDataSourceUtils

def jdbcTemplate = AbDataSourceUtils.getCurrentDataSource().getJdbcOperations()

jdbcTemplate.update("UPDATE xxx SET col = ? WHERE tak_id_ = ?", ['xxx', bpmTask.getId()])

// 获取流程变量
variableScope.getVariable("xxx")

// 设置流程变量
variableScope.setVariable("orderNo", "xxx")

// 是否任务，用在全局插件中判断是否任务节点；在用户任务节点事件中可直接使用 bpmTask， 无需判断
if (isTask) {
    // 任务ID
    final String taskId = bpmTask.getId()

    // 任务名称
    final String taskName = bpmTask.getName()

    // 任务KEY
    final String nodeKey = bpmTask.getNodeKey()

    // 任务类型 userTask: 用户任务  serviceTask: 服务任务  signTask: 会签任务   signSource: 会签源任务   agentTask: 代理任务
    final String taskType = bpmTask.getTaskType()
}


// 流程实例ID
final String instId = bpmInstance.getId()
// 流程标题
final String title = bpmInstance.getTitle()
// 关联业务主键
final String bizId = bpmInstance.getBizId()
// 流程分类编码
final String typeCode = bpmInstance.getTypeCode()
// 是否支持移动端
final boolean supportMobile = bpmInstance.getSupportMobile() as boolean


// 流程定义KEY
final String defKey = bpmInstance.getDefKey()
// 流程定义ID
final String defId = bpmInstance.getDefId()

// 当前用户ID
final String currentUserId = currentUser.getId()
// 当前用户名
final String currentUsername = currentUser.getUsername()

// 当前用户-组织ID
final String currentOrgId = currentUser.getOrgId()
// 当前用户-组织编码
final String currentOrgCode = currentUser.getOrgCode()
// 当前用户-组织名称
final String currentOrgName = currentUser.getOrgName()


// 发起人-用户ID
final String startUserId = startUser.getId()
// 发起人-用户名
final String startUsername = startUser.getUsername()
// 当前用户-组织ID
final String startUserOrgId = startUser.getOrgId()
// 当前用户-组织编码
final String startUserCode = startUser.getOrgCode()
// 当前用户-组织名称
final String startUserName = startUser.getOrgName()