activiti 7新增处理规则——【2】后端扩展处理器选项

    @OperLog(operModul = "流程任务相关" , operType = LogConst.OTHER , operDesc = "设置用户任务中设置的规则数据")
    @PostMapping("/as/setAssigneeUser")
    public ResultRes setAssigneeUser(@RequestBody JSONObject param){
        return ResultRes.success(assigneeUserService.setAssigneeUser(param));
    }

    /**
     * 流程发布
     * @param param
     * @return
     */
    @OperLog(operModul = "流程定义相关" , operType = LogConst.INSERT , operDesc = "流程发布")
    @PostMapping(value = "/deployment/deployWithBPMNJS")
    public ResultRes deployWithBPMNJS(@RequestBody JSONObject param,String tenantId){
        String stringBPMNXml=param.get("stringBPMNXml").toString();
        try {
            return ResultRes.success(processDefinitionService.deployWithBPMNJS(stringBPMNXml,tenantId));
        }
        catch (Exception ex){
            return ResultRes.error(ex.getMessage());
        }
    }

        @Override
    public String deployWithBPMNJS(String BPMNXml, String tenantId){
        Deployment deployment = repositoryService.createDeployment()
                .addString("createWithBPMNJS.bpmn",BPMNXml)
//                定义租户ID
                .tenantId((tenantId==null || tenantId.equals(""))?"main":tenantId)
                .deploy();
        iProcessDefinitionManager.createTask(deployment.getId());
        return deployment.getId();
    }

                    if (redisUtils.exists(usertaskId + "_" + ruleName)) {
                        assigneeString = redisUtils.get(usertaskId + "_" + ruleName).toString();
                        deleteAssigneeUserByTaskid(usertaskId);
//                        TODO:设置签入人
                        setAssigneeUser(assigneeString, usertaskId, ruleName);
                    }

public String setAssigneeUser(String assigneeList, String usertaskid,String ruleName){
        JSONArray userlist = JSONObject.parseArray(assigneeList);
        List<AssigneeUserEntity> assigneeUserEntityList = Optional.ofNullable(userlist)
                .map(list->list.stream().map(it->{
                    JSONObject json = JSONObject.parseObject(JSON.toJSONString(it));
                    AssigneeUserEntity assigneeUserEntity = new AssigneeUserEntity();
                    if(SystemConfig.IsNullOrEmpty(json.getString("username"))){
                        assigneeUserEntity.setUsername(json.getString("id"));
                    }
                    else {
                        assigneeUserEntity.setUsername(json.getString("username"));
                    }
                    assigneeUserEntity.setUsertaskid(usertaskid);
                    assigneeUserEntity.setRuleName(ruleName);
                    assigneeUserEntity.setId(UUID.randomUUID().toString());
                    return assigneeUserEntity;
                }).collect(Collectors.toList())).orElse(new ArrayList<>());
//        TODO:扩展无具体指代人的找人方式挂载
        /*这里扩展找人方式，目前有按部门主管和部门直属领导的方式，在本节进行扩展。由于没有具体的指代人或者机构，上述循环代码不会执行*/
        List<String> extensionRule = Arrays.asList("byDeptMaster", "byDeptLeader"); 
        if (extensionRule.contains(ruleName)){ 
            assigneeUserEntityList.add( 
                    new AssigneeUserEntity(UUID.randomUUID().toString(), usertaskid, "", "", ruleName, null) 
            ); 
        } 
        assigneeUserMapper.setAssigneeUser(assigneeUserEntityList);

        return "执行成功";
    }

    @Override
    public SendActionDto sendWork(ProcessTaskParams processTaskParams){
        //获取当前登录用户信息
        Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
        String username=authentication.getName();
        securityUtil.logInAs(username);

        return processTaskServiceManager.sendWork(processTaskParams,username);
    }

    @Override
    public HashMap<String,Object> getNextUsers(HashMap<String,Object> variables, FlowElement targetFlowElement
            , String procInstId){
        UserTask defUserTask=(UserTask) targetFlowElement;
        variables=sequenceFlowManager.getVariables(defUserTask,variables,procInstId);
        return variables;
    }

 public HashMap<String,Object> getVariables(UserTask userTask, HashMap<String,Object> variables,
                                                String procInstId){
        //多实例处理规则，如果是 时序多重事件
        if(userTask.getBehavior() instanceof SequentialMultiInstanceBehavior){
            MultiInstanceBehaviorStrategy service=
                    multiInstanceBehaviorContext.getService("SequentialMultiInstanceBehavior");
            variables=service.getMulitUsers(userTask,variables,procInstId);
            return variables;
        } else if (userTask.getBehavior() instanceof ParallelMultiInstanceBehavior) {
            MultiInstanceBehaviorStrategy service=
                    multiInstanceBehaviorContext.getService("ParallelMultiInstanceBehavior");
            variables=service.getMulitUsers(userTask,variables,procInstId);
            return variables;
        }
        else{
            MultiInstanceBehaviorStrategy service=
                    multiInstanceBehaviorContext.getService("NoMulitInstance");
            variables=service.getMulitUsers(userTask,variables,procInstId);
            return variables;
        }
    }

    @Override
    public HashMap<String,Object> getMulitUsers(UserTask userTask, HashMap<String,Object> variables,
                                                String procInstId){
        //获取处理人规则
        String candidateUsers=userTask.getCandidateUsers().get(0);
        String ruleName=sequenceFlowManager.getRuleName(userTask.getId(),candidateUsers);
        //获取处理人
        variables=sequenceFlowManager.getUserInfoByTaskIdAndRuleName(userTask.getId(),
                ruleName,variables,procInstId);
        return variables;
    }

    public HashMap<String,Object> getUserInfoByTaskIdAndRuleName(String taskid,String ruleName,
                                                                 HashMap<String,Object> variables,String procInstId){
        UserByTaskRuleStrategy userByTaskRuleService=userByTaskRuleContext.getService(ruleName);
        variables=userByTaskRuleService.getUserByTaskRule(taskid,ruleName,variables,procInstId);
        return variables;
    }

@Component
public class ByDeptLeader implements UserByTaskRuleStrategy{
    @Autowired
    private UserEntityMapper userEntityMapper;
    @Autowired
    private RedisUtils redisUtils;
    @Override
    public HashMap<String, Object> getUserByTaskRule(String taskid, String ruleName, HashMap<String, Object> variables, String procInstId) {
//        获取任务
        HistoricProcessInstance instance = ProcessEngines.
                getDefaultProcessEngine().getHistoryService()
                .createHistoricProcessInstanceQuery()
                .processInstanceId(procInstId).singleResult();
//        找到负责人和部门
            String userId = instance.getStartUserId();
        DepartmentEntity department = userEntityMapper.getDepartmentByUserId(userId);

        //放入缓存，用于发送消息推送
        variables.put(taskid + "_byDeptLeader", department.getLeader());
        if(redisUtils.exists(procInstId+"_sms")){
            redisUtils.remove(procInstId+"_sms");
        }
        redisUtils.set(procInstId+"_sms",department.getLeader());
        return variables;
    }

    @Override
    public String getType() {
        return "byDeptLeader";
    }
}