批量处理参数改为payload方式

yangys

2025-08-11 291ef3947565e8a20889e04836c04a8b6e4369dd

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
package org.springblade.mdm.flow.service.execute;
 
import org.apache.commons.lang3.StringUtils;
import org.flowable.engine.TaskService;
import org.flowable.task.api.Task;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.tool.support.Kv;
import org.springblade.core.tool.utils.StringUtil;
import org.springblade.mdm.flow.constants.FlowContants;
import org.springblade.mdm.flow.service.ApproveRecordService;
import org.springblade.mdm.flow.service.FlowProgramFileService;
import org.springblade.mdm.flow.vo.BatchDispatchVO;
import org.springblade.mdm.program.service.NcNodeAutoCreateService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import java.util.Map;
 
/**
 * 试切流程完成任务的实现
 */
@Service
public class BatchDispatchService  {
 
    @Autowired
    private ApproveRecordService approveRecordService;
    @Autowired
    private TaskService taskService;
    @Transactional
    public void batchCompleteTask(BatchDispatchVO batchDispatchVO) {
        //String[] taskIds, String[] processInstanceIds, String comment, String assignee
        if(StringUtils.isBlank(batchDispatchVO.getAssignee())){
            throw new ServiceException("缺少处理人参数");
        }
        checkBatchParameter(batchDispatchVO);
 
        Map<String, Object> variables = Kv.create();
        variables.put("assignee", batchDispatchVO.getAssignee());
        variables.put("approve", FlowContants.Y);//默认就是通过
        String taskId;
        String processInstanceId;
        String comment = batchDispatchVO.getComment();
        String[] taskIds = batchDispatchVO.getTaskIds();
        for(int i=0;i<taskIds.length;i++){
            taskId = taskIds[i];
            processInstanceId = batchDispatchVO.getProcessInstanceIds()[i];
 
            Task task = taskService.createTaskQuery()
                .taskId(taskId)
                .singleResult();
            taskService.complete(taskId, variables);
 
            if (StringUtil.isNoneBlank(processInstanceId, comment)) {
                taskService.addComment(taskId, processInstanceId, comment);
            }
 
            approveRecordService.saveApproveRecords(task,FlowContants.Y,comment);
        }
    }
 
    /**
     * 自动批量派工
     * @param batchDispatchVO 批量处理参数
     */
    public void batchAutoCompleteTask(BatchDispatchVO batchDispatchVO) {
        //TODO 带实现
        checkBatchParameter(batchDispatchVO);
    }
 
    /**
     * 验证批量处理参数
     * @param batchDispatchVO 批量处理参数对象
     */
    void checkBatchParameter(BatchDispatchVO batchDispatchVO){
        String[] taskIds = batchDispatchVO.getTaskIds();
        if(taskIds == null || taskIds.length == 0){
            throw new ServiceException("任务id组为空");
        }
        String[] processInstanceIds = batchDispatchVO.getProcessInstanceIds();
        if(processInstanceIds == null || processInstanceIds.length == 0){
            throw new ServiceException("流程实例id组为空");
        }
        if(taskIds.length != processInstanceIds.length){
            throw new ServiceException("任务id与流程实例id数量不一致");
        }
    }
}