|
@@ -69,10 +69,7 @@ public class TaskProcessServiceImpl extends BaseServiceImpl<TaskProcessMapper, T
|
|
|
queryWrapper.lambda().like(TaskProcessInfo::getAuditUserIds, SecureUtil.getUserId());
|
|
|
queryWrapper.lambda().eq(TaskProcessInfo::getStatus, 1);
|
|
|
} else if (dto.getSelectType().equals("2")) { //已审核、已驳回为已办任务
|
|
|
- queryWrapper.lambda().like(TaskProcessInfo::getAuditUserIds, SecureUtil.getUserId())
|
|
|
- .or()
|
|
|
- .like(TaskProcessInfo::getAuditUserIdsComplete, SecureUtil.getUserId())
|
|
|
- .and(wrapper -> wrapper.in(TaskProcessInfo::getStatus, 2, 3));
|
|
|
+ queryWrapper.lambda().apply("(audit_user_ids_complete LIKE '%" + SecureUtil.getUserId() + "%' AND STATUS IN ( 2, 3 )) OR (audit_user_ids LIKE '%" + SecureUtil.getUserId() + "%' AND STATUS = 3)");
|
|
|
} else if (dto.getSelectType().equals("3")) { //我发起的任务
|
|
|
if (ObjectUtil.isNotEmpty(dto.getSelectStatus()) && !dto.getSelectStatus().equals("1")) {
|
|
|
queryWrapper.lambda().eq(TaskProcessInfo::getStatus, dto.getSelectStatus());
|
|
@@ -332,7 +329,7 @@ public class TaskProcessServiceImpl extends BaseServiceImpl<TaskProcessMapper, T
|
|
|
if (!firstUserId.equals(SecureUtil.getUserId() + "")) {
|
|
|
User user = iUserClient.userInfoById(Long.parseLong(firstUserId)).getData();
|
|
|
bladeRedis.del("user:id=" + SecureUtil.getUserId());//解锁
|
|
|
- throw new ServiceException("当前任务的审批人【" + user.getRealName() + "】还未完成审批流程,请稍后再试");
|
|
|
+ throw new ServiceException("当前任务的审批人【" + user.getRealName() + "】还未完成审批,请稍后再试");
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -494,10 +491,7 @@ public class TaskProcessServiceImpl extends BaseServiceImpl<TaskProcessMapper, T
|
|
|
|
|
|
//审批人
|
|
|
List<String> auditUserIds = new LinkedList<>();
|
|
|
- EMProcessTaskUser responsibleObj = new EMProcessTaskUser(); //部门负责人
|
|
|
- responsibleObj.setUserId(departmentHead.getId() + "");
|
|
|
- responsibleObj.setUserName(departmentHead.getRealName());
|
|
|
- auditUserIds.add(responsibleObj.getUserId());
|
|
|
+ auditUserIds.add(departmentHead.getId() + "");
|
|
|
|
|
|
List<String> nonEmptyAuditUserIds = new LinkedList<>();
|
|
|
for (String userId : auditUserIds) {
|
|
@@ -530,10 +524,7 @@ public class TaskProcessServiceImpl extends BaseServiceImpl<TaskProcessMapper, T
|
|
|
|
|
|
//审批人
|
|
|
List<String> auditUserIds = new LinkedList<>();
|
|
|
- EMProcessTaskUser responsibleObj = new EMProcessTaskUser(); //部门负责人
|
|
|
- responsibleObj.setUserId(departmentHead.getId() + "");
|
|
|
- responsibleObj.setUserName(departmentHead.getRealName());
|
|
|
- auditUserIds.add(responsibleObj.getUserId());
|
|
|
+ auditUserIds.add(departmentHead.getId() + "");
|
|
|
|
|
|
List<String> nonEmptyAuditUserIds = new LinkedList<>();
|
|
|
for (String userId : auditUserIds) {
|
|
@@ -768,15 +759,17 @@ public class TaskProcessServiceImpl extends BaseServiceImpl<TaskProcessMapper, T
|
|
|
if (user != null && ObjectUtil.isEmpty(user.getIsLeader())) {
|
|
|
//负责人getIsLeader字段=null,证明不是负责人,那么获取当前部门负责人
|
|
|
User departmentHead = this.getDepartmentHead(Long.parseLong(SecureUtil.getUser().getDeptId()));
|
|
|
- auditUserIds.add(departmentHead.getId() + "");
|
|
|
+ if (departmentHead != null) {
|
|
|
+ auditUserIds.add(departmentHead.getId() + "");
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
- //获取审批人信息
|
|
|
+ //获取审批人、抄送人信息
|
|
|
Map<String, List<User>> approveUserMaps = this.getApproveUserMaps(type);
|
|
|
|
|
|
//审批人
|
|
|
- List<User> spUserList = approveUserMaps.get("SP");
|
|
|
- if (spUserList.size() == 0) {
|
|
|
+ List<User> spUserList = approveUserMaps.getOrDefault("SP", null);
|
|
|
+ if (spUserList == null || spUserList.size() == 0) {
|
|
|
throw new ServiceException("获取当前审批流程人员信息失败,请联系管理员");
|
|
|
}
|
|
|
auditUserIds.addAll(spUserList.stream().map(User::getId).map(String::valueOf).collect(Collectors.toList()));
|
|
@@ -794,8 +787,8 @@ public class TaskProcessServiceImpl extends BaseServiceImpl<TaskProcessMapper, T
|
|
|
}
|
|
|
|
|
|
//抄送人
|
|
|
- List<User> zcUserList = approveUserMaps.get("ZC");
|
|
|
- if (zcUserList.size() > 0) {
|
|
|
+ List<User> zcUserList = approveUserMaps.getOrDefault("ZC", null);
|
|
|
+ if (zcUserList != null && zcUserList.size() > 0) {
|
|
|
List<String> zcUserIds = zcUserList.stream().map(User::getId).map(String::valueOf).collect(Collectors.toList());
|
|
|
taskProcessInfo.setCcUserIds(StringUtils.join(zcUserIds, ","));
|
|
|
}
|
|
@@ -915,10 +908,22 @@ public class TaskProcessServiceImpl extends BaseServiceImpl<TaskProcessMapper, T
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- List<User> spUserList = jdbcTemplate.query("select * from blade_user where tenant_id = 003077 and dept_id in(" + StringUtils.join(spPostIds, ",") + ")", new BeanPropertyRowMapper<>(User.class));
|
|
|
- List<User> zcUserList = jdbcTemplate.query("select * from blade_user where tenant_id = 003077 and dept_id in(" + StringUtils.join(zcPostIds, ",") + ")", new BeanPropertyRowMapper<>(User.class));
|
|
|
- resultMaps.put("SP", spUserList);
|
|
|
- resultMaps.put("ZC", zcUserList);
|
|
|
+ if (spPostIds.size() > 0) {
|
|
|
+ List<User> spUserListAll = new LinkedList<>();
|
|
|
+ for (String spPostId : spPostIds) {
|
|
|
+ List<User> spUserList = jdbcTemplate.query("select * from blade_user where tenant_id = 003077 and dept_id =" + spPostId, new BeanPropertyRowMapper<>(User.class));
|
|
|
+ spUserListAll.addAll(spUserList);
|
|
|
+ }
|
|
|
+ if (spUserListAll.size() > 0) {
|
|
|
+ resultMaps.put("SP", spUserListAll);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (zcPostIds.size() > 0) {
|
|
|
+ List<User> zcUserList = jdbcTemplate.query("select * from blade_user where tenant_id = 003077 and dept_id in(" + StringUtils.join(zcPostIds, ",") + ")", new BeanPropertyRowMapper<>(User.class));
|
|
|
+ if (zcUserList.size() > 0) {
|
|
|
+ resultMaps.put("ZC", zcUserList);
|
|
|
+ }
|
|
|
+ }
|
|
|
return resultMaps;
|
|
|
}
|
|
|
|