| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Boolean taskIsWait(String taskId, String processInsId) { |
|---|
| | | List<ProcessLog> list = new LambdaQueryChainWrapper<>(baseMapper) |
|---|
| | | .eq(ProcessLog::getProcessInsId, processInsId) |
|---|
| | | .eq(ProcessLog::getTaskId, taskId) |
|---|
| | | .list(); |
|---|
| | | return list.stream().anyMatch(log -> ProcessLogEventTypeEnum.WAIT.equals(log.getEventType())) |
|---|
| | | && list.stream().filter(log -> ProcessLogEventTypeEnum.FINISHED.equals(log.getEventType())).count() < 1; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Boolean taskIsJump(String taskId, String processInsId) { |
|---|
| | | List<ProcessLog> list = new LambdaQueryChainWrapper<>(baseMapper) |
|---|
| | | .eq(ProcessLog::getProcessInsId, processInsId) |
|---|
| | | .eq(ProcessLog::getTaskId, taskId) |
|---|
| | | .eq(ProcessLog::getEventType, ProcessLogEventTypeEnum.JUMP) |
|---|
| | | .list(); |
|---|
| | | return list.size() > 0; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Boolean taskIsTeamwork(String taskId, String processInsId) { |
|---|
| | | ProcessLog log = new LambdaQueryChainWrapper<>(baseMapper) |
|---|
| | | .eq(ProcessLog::getProcessInsId, processInsId) |
|---|
