我的流程页面，列表操作建议对查询流程状态、部署信息、任务信息等加入批量操作

原来的代码，五条数据，接口性能5s才能响应
![输入图片说明](https://foruda.gitee.com/images/1724121359414057701/ff5b84a7_5045296.png "屏幕截图")

加入批量操作后，五条数据接口性能不到1s就可以响应，代码如下

```
@Autowired
    private WfProcessStatusMapper wfProcessStatusMapper;

@Override
    public PageResult<WfMyRequestResponse> querySelective(Integer pageNum, Integer pageSize, WfMyRequestQueryParam queryParam) {
        // 查询历史流程实例
        String loginUserIdStr = String.valueOf(jwtUtil.getUserId());
        HistoricProcessInstanceQuery historicProcessInstanceQuery = historyService.createHistoricProcessInstanceQuery()
                .startedBy(loginUserIdStr)
                .orderByProcessInstanceStartTime().desc();
        // 应用查询条件
        buildQueryParam(queryParam, historicProcessInstanceQuery);
        long pageTotal = historicProcessInstanceQuery.count();
        if (pageTotal == 0) {
            return new PageResult<>(List.of(), 0L);
        }
        List<HistoricProcessInstance> historicProcessInstances = historicProcessInstanceQuery
                .listPage((pageNum - 1) * pageSize, pageSize);
        // 批量查询部署信息、任务和流程状态
        Map<String, Deployment> deploymentMap = fetchDeployments(historicProcessInstances);
        Map<String, List<Task>> taskMap = fetchTasks(historicProcessInstances);
        List<WfProcessStatus> processStatusList = wfProcessStatusMapper.queryProcessStatus("processStatus",
                historicProcessInstances.stream()
                        .map(HistoricProcessInstance::getId).distinct()
                        .collect(Collectors.toList()));
        List<WfMyRequestResponse> responses = new ArrayList<>(historicProcessInstances.size());
        for (HistoricProcessInstance instance : historicProcessInstances) {
            WfMyRequestResponse response = new WfMyRequestResponse();
            response.setProcInsId(instance.getId());
            response.setCreateTime(instance.getStartTime());
            response.setFinishTime(instance.getEndTime());
            response.setProcessStatus(getProcessStatus(processStatusList, instance.getId(), instance.getEndTime()));
            // 计算耗时
            response.setDuration(calculateDuration(instance, instance.getStartTime(), instance.getEndTime()));
            // 填充部署信息
            Deployment deployment = deploymentMap.get(instance.getDeploymentId());
            if (deployment != null) {
                response.setProcDefName(instance.getProcessDefinitionName());
                response.setProcDefVersion(instance.getProcessDefinitionVersion());
                response.setCategory(deployment.getCategory());
            }
            // 填充任务信息
            List<Task> tasks = taskMap.getOrDefault(instance.getId(), List.of());
            if (!tasks.isEmpty()) {
                response.setTaskName(tasks.stream()
                        .map(Task::getName)
                        .filter(StringUtils::isNotBlank)
                        .collect(Collectors.joining(",")));
            }
            responses.add(response);
        }

return new PageResult<>(responses, pageTotal);
    }

private String calculateDuration(HistoricProcessInstance historicProcessInstance, Date startTime, Date endTime) {
        if (Objects.nonNull(historicProcessInstance.getEndTime())) {
            return DateUtils.getDatePoor(historicProcessInstance.getEndTime(), historicProcessInstance.getStartTime());
        }
        return DateUtils.getDatePoor(new Date(), historicProcessInstance.getStartTime());
    }

private void buildQueryParam(WfMyRequestQueryParam queryParam, HistoricProcessInstanceQuery query) {
        if (StringUtils.isNotBlank(queryParam.getProcessKey())) {
            query.processDefinitionKey(queryParam.getProcessKey());
        }
        if (StringUtils.isNotBlank(queryParam.getProcessName())) {
            query.processDefinitionName(queryParam.getProcessName());
        }
        if (StringUtils.isNotBlank(queryParam.getCategory())) {
            query.processDefinitionCategory(queryParam.getCategory());
        }
    }

private Map<String, Deployment> fetchDeployments(List<HistoricProcessInstance> instances) {
        return repositoryService.createDeploymentQuery()
                .deploymentIds(List.of(instances.stream()
                        .map(HistoricProcessInstance::getDeploymentId).distinct().toArray(String[]::new)))
                .list()
                .stream()
                .collect(Collectors.toMap(Deployment::getId, Function.identity()));
    }

private Map<String, List<Task>> fetchTasks(List<HistoricProcessInstance> instances) {
        return taskService.createTaskQuery()
                .processInstanceIdIn(List.of(instances.stream()
                        .map(HistoricProcessInstance::getId).distinct().toArray(String[]::new)))
                .list()
                .stream()
                .collect(Collectors.groupingBy(Task::getProcessInstanceId));
    }

private String getProcessStatus(List<WfProcessStatus> processStatusList, String instanceId, Date instanceEndTime) {
        String processStatus = null;
        for (WfProcessStatus wfProcessStatus : processStatusList) {
            if (wfProcessStatus.getProcInsId().equals(instanceId)) {
                processStatus = wfProcessStatus.getProcessStatus();
                break;
            }
        }
        // 兼容旧流程
        if (processStatus == null) {
            processStatus = ObjectUtil.isNull(instanceEndTime) ? ProcessStatusEnum.RUNNING.getStatus() : ProcessStatusEnum.COMPLETED.getStatus();
        }
        return processStatus;
    }
```

mapper的具体sql如下

```
@Data
public class WfProcessStatus {
    private String procInsId;
    private String processStatus;
}

public interface WfProcessStatusMapper {
    List<WfProcessStatus> queryProcessStatus(@Param("variableName")String variableName, @Param("procInsIds") List<String> procInsIds);
}

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.grm.workflow.mapper.WfProcessStatusMapper">
    <select id="queryProcessStatus" resultType="com.grm.workflow.entity.WfProcessStatus">
        SELECT
            PROC_INST_ID_ as procInsId,TEXT_ as processStatus
        FROM ACT_HI_VARINST
        WHERE
        NAME_ = #{variableName} AND PROC_INST_ID_ in
        <foreach collection="procInsIds" item="procInsId" separator="," open="(" close=")">
            #{procInsId}
        </foreach>
    </select>
</mapper>
```

KonBAI/RuoYi-Flowable-Plus

内容风险标识

评论 (0)

KonBAI/RuoYi-Flowable-Plus .gitee-modal { width: 500px !important; }

内容风险标识