|
@@ -207,7 +207,6 @@ public class ArchiveFileTaskController extends BladeController {
|
|
|
params.add(dto.getProjectIdValue());
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
if (ObjectUtil.isNotEmpty(dto.getBatchValue())) {
|
|
|
sqlString.append(" AND batch = ?");
|
|
|
params.add(dto.getBatchValue());
|
|
@@ -283,7 +282,7 @@ public class ArchiveFileTaskController extends BladeController {
|
|
|
String resultIds = processInstanceIds.stream()
|
|
|
.map(id -> "'" + id + "'")
|
|
|
.collect(Collectors.joining(","));
|
|
|
- taskParallelGroupMap = jdbcTemplate.query("select process_instance_id,task_user,task_user_name,e_visa_status,e_visa_content from u_task_parallel where process_instance_id in(" + resultIds + ") order by id", new BeanPropertyRowMapper<>(TaskParallel.class)).stream().collect(Collectors.groupingBy(TaskParallel::getProcessInstanceId));
|
|
|
+ taskParallelGroupMap = jdbcTemplate.query("select process_instance_id,task_user,task_user_name,e_visa_status,e_visa_content,status from u_task_parallel where process_instance_id in(" + resultIds + ") order by id", new BeanPropertyRowMapper<>(TaskParallel.class)).stream().collect(Collectors.groupingBy(TaskParallel::getProcessInstanceId));
|
|
|
}
|
|
|
Map<String, List<TaskParallel>> finalTaskParallelGroupMap = taskParallelGroupMap;
|
|
|
|
|
@@ -319,14 +318,26 @@ public class ArchiveFileTaskController extends BladeController {
|
|
|
vo.setEVisaStatus("废除成功");
|
|
|
}
|
|
|
|
|
|
- /*List<String> contentsList = new LinkedList<>();
|
|
|
- for (TaskParallel taskParallel : taskParallelList) {
|
|
|
- contentsList.add("【" + taskParallel.getTaskUserName() + "】msg:" + (ObjectUtil.isNotEmpty(taskParallel.getEVisaContent()) ? taskParallel.getEVisaContent() : "null") + " code:" + (ObjectUtil.isNotEmpty(taskParallel.getEVisaStatus()) ? taskParallel.getEVisaStatus() : "null "));
|
|
|
+ //判断签字人的验证 2=绿色 3=黄色 999=红色 其他代表=灰色
|
|
|
+ List<TaskParallel> statList = new ArrayList<>();
|
|
|
+ for (TaskParallel taskPa : taskParallelList) {
|
|
|
+ if (taskPa.getStatus() == 2 && ObjectUtil.isNotEmpty(taskPa.getEVisaStatus()) && taskPa.getEVisaStatus() == 1) {
|
|
|
+ taskPa.setEVisaStatus(2);
|
|
|
+ } else if (taskPa.getStatus() == 3 && taskPa.getTaskUser().equals(SecureUtil.getUserId().toString())) {
|
|
|
+ taskPa.setEVisaStatus(3);
|
|
|
+ } else if (taskPa.getStatus() == 999) {
|
|
|
+ taskPa.setEVisaStatus(999);
|
|
|
+ } else {
|
|
|
+ taskPa.setEVisaStatus(1);
|
|
|
+ }
|
|
|
+ statList.add(taskPa);
|
|
|
+ }
|
|
|
+ if (statList.size() > 0) {
|
|
|
+ List<Object> objectList = statList.stream()
|
|
|
+ .map(taskPa -> (Object) taskPa)
|
|
|
+ .collect(Collectors.toList());
|
|
|
+ vo.setTaskApproveUserNamesList(objectList);
|
|
|
}
|
|
|
- if (contentsList.size() > 0) {
|
|
|
- vo.setEVisaStatus(StringUtils.join(contentsList, " 、"));
|
|
|
- }*/
|
|
|
-
|
|
|
}
|
|
|
return vo;
|
|
|
})
|
|
@@ -335,8 +346,7 @@ public class ArchiveFileTaskController extends BladeController {
|
|
|
page.setTotal(totalCount);
|
|
|
|
|
|
R<IPage<ArchiveTaskPageVO>> iPageR = R.data(page);
|
|
|
-
|
|
|
- //待办推送 TODO 档案暂时不推送,推送时放开
|
|
|
+ //待办推送
|
|
|
/*if (dto.getSelectedType().equals(1)) {
|
|
|
if (ObjectUtil.isNotEmpty(iPageR.getData()) && ObjectUtil.isNotEmpty(iPageR.getData().getRecords()) && ObjectUtil.isNotEmpty(dto.getContractIdValue()) && ObjectUtil.isNotEmpty(dto.getProjectIdValue())) {
|
|
|
this.sendWebSocketArchiveMsg(new SendsWebSocketArchiveDTO(totalCount, 1, dto));
|
|
@@ -344,7 +354,6 @@ public class ArchiveFileTaskController extends BladeController {
|
|
|
this.sendWebSocketArchiveMsg(new SendsWebSocketArchiveDTO(0, 2, dto));
|
|
|
}
|
|
|
}*/
|
|
|
-
|
|
|
return iPageR;
|
|
|
}
|
|
|
|