|
|
@@ -37,6 +37,7 @@ import com.xjrsoft.module.form.mapper.FormTemplateMapper;
|
|
|
import com.xjrsoft.module.form.service.IFormExecuteService;
|
|
|
import com.xjrsoft.module.magicapi.service.IMagicApiService;
|
|
|
import com.xjrsoft.module.magicapi.vo.MagicApiInfoVo;
|
|
|
+import com.xjrsoft.module.oa.entity.News;
|
|
|
import com.xjrsoft.module.organization.entity.User;
|
|
|
import com.xjrsoft.module.organization.entity.UserRoleRelation;
|
|
|
import com.xjrsoft.module.organization.service.IUserService;
|
|
|
@@ -1536,13 +1537,10 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
|
|
|
@Override
|
|
|
public Page<PendingTaskVo> myExamine(Page<PendingTaskVo> page, MyExaminePageDto dto) {
|
|
|
- //获取登录者信息
|
|
|
- SaSession tokenSession = StpUtil.getTokenSession();
|
|
|
- User user = tokenSession.get(GlobalConstant.LOGIN_USER_INFO_KEY, new User());
|
|
|
List<String> taskIds = new ArrayList<>();
|
|
|
List<WorkflowApproveRecord> list = approveRecordService.list(
|
|
|
new QueryWrapper<WorkflowApproveRecord>().lambda()
|
|
|
- .eq(WorkflowApproveRecord::getApproveUserId, user.getId())
|
|
|
+ .eq(WorkflowApproveRecord::getApproveUserId, StpUtil.getLoginIdAsLong())
|
|
|
);
|
|
|
taskIds = list.stream().map(WorkflowApproveRecord::getTaskId).collect(Collectors.toList());
|
|
|
// if(dto.getStatus() != null && dto.getStatus() == 1){
|
|
|
@@ -1586,8 +1584,12 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
// List<Task> tasks = taskQuery.orderByTaskCreateTime().desc().listPage(Convert.toInt((dto.getLimit() - 1) * dto.getSize()), dto.getSize());
|
|
|
// taskIds = tasks.stream().map(Task::getId).collect(Collectors.toList());
|
|
|
// }
|
|
|
- dto.setTaskIds(taskIds);
|
|
|
- return xjrWorkflowExtraMapper.myApproveRecord(page, dto);
|
|
|
+ if(!taskIds.isEmpty()){
|
|
|
+ dto.setTaskIds(taskIds);
|
|
|
+ return xjrWorkflowExtraMapper.myApproveRecord(page, dto);
|
|
|
+ }
|
|
|
+
|
|
|
+ return new Page<>();
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -3185,7 +3187,11 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
.orderByDesc(WorkflowCirculated::getCreateTime)
|
|
|
.like(StrUtil.isNotBlank(dto.getTaskName()), WorkflowCirculated::getTaskName, dto.getTaskName())
|
|
|
.like(StrUtil.isNotBlank(dto.getName()), WorkflowSchema::getName, dto.getName())
|
|
|
- .like(StrUtil.isNotBlank(dto.getKeyword()), WorkflowSchema::getName, dto.getKeyword())
|
|
|
+ .and(StrUtil.isNotBlank(dto.getKeyword()),wp -> wp.like(WorkflowSchema::getName, dto.getKeyword())
|
|
|
+ .or()
|
|
|
+ .like(WorkflowCirculated::getTaskName, dto.getKeyword())
|
|
|
+ .or()
|
|
|
+ .like(WorkflowCirculated::getProcessName, dto.getKeyword()))
|
|
|
.eq(StrUtil.isNotBlank(dto.getOriginator()), User::getId, dto.getOriginator())
|
|
|
.eq(StrUtil.isNotBlank(dto.getSerialNumber()), WorkflowCirculated::getSerialNumber, dto.getSerialNumber())
|
|
|
.between(ObjectUtil.isNotNull(dto.getStartTime()) && ObjectUtil.isNotNull(dto.getEndTime()), WorkflowCirculated::getCreateTime, dto.getStartTime(), dto.getEndTime())
|
|
|
@@ -3331,7 +3337,14 @@ public class WorkflowExecuteServiceImpl implements IWorkflowExecuteService {
|
|
|
List<MyProcessPageVo> result = new ArrayList<>(historicProcessInstances.size());
|
|
|
if (processIds.size() > 0) {
|
|
|
|
|
|
- List<WorkflowExtra> workflowExtras = workflowExtraMapper.selectList(Wrappers.lambdaQuery(WorkflowExtra.class).in(WorkflowExtra::getProcessId, processIds).orderByDesc(WorkflowExtra::getStartTime));
|
|
|
+ List<WorkflowExtra> workflowExtras = workflowExtraMapper.selectList(Wrappers.lambdaQuery(WorkflowExtra.class)
|
|
|
+ .in(WorkflowExtra::getProcessId, processIds)
|
|
|
+ .and(StrUtil.isNotBlank(dto.getKeyword()),wp -> wp.like(WorkflowExtra::getSchemaName, dto.getKeyword())
|
|
|
+ .or()
|
|
|
+ .like(WorkflowExtra::getTaskName, dto.getKeyword())
|
|
|
+ .or()
|
|
|
+ .like(WorkflowExtra::getProcessName, dto.getKeyword()))
|
|
|
+ .orderByDesc(WorkflowExtra::getStartTime));
|
|
|
|
|
|
for (HistoricProcessInstance historicProcessInstance : historicProcessInstances) {
|
|
|
|