|
@@ -23,6 +23,7 @@ import org.springblade.core.mp.base.BaseServiceImpl;
|
|
|
import org.springblade.core.oss.model.BladeFile;
|
|
|
import org.springblade.core.secure.BladeUser;
|
|
|
import org.springblade.core.secure.utils.AuthUtil;
|
|
|
+import org.springblade.core.secure.utils.SecureUtil;
|
|
|
import org.springblade.core.tool.api.R;
|
|
|
import org.springblade.core.tool.utils.*;
|
|
|
import org.springblade.manager.entity.ContractInfo;
|
|
@@ -545,7 +546,7 @@ public class InformationQueryServiceImpl extends BaseServiceImpl<InformationQuer
|
|
|
|
|
|
Set<String> processInstanceIds = query.stream().map(Task::getProcessInstanceId).map(id -> "'" + id + "'").collect(Collectors.toSet());
|
|
|
if (processInstanceIds.size() > 0) {
|
|
|
- List<TaskParallel> taskParallels = jdbcTemplate.query("select task_user, task_user_name, e_visa_status, status, process_instance_id, initiative from u_task_parallel where is_deleted = 0 and process_instance_id in(" + StringUtils.join(processInstanceIds, ",") + ")", new BeanPropertyRowMapper<>(TaskParallel.class));
|
|
|
+ List<TaskParallel> taskParallels = jdbcTemplate.query("select task_user, task_user_name, e_visa_status, status, process_instance_id, initiative,e_visa_content from u_task_parallel where is_deleted = 0 and process_instance_id in(" + StringUtils.join(processInstanceIds, ",") + ")", new BeanPropertyRowMapper<>(TaskParallel.class));
|
|
|
taskParallelMaps = taskParallels.stream().collect(Collectors.groupingBy(TaskParallel::getProcessInstanceId));
|
|
|
}
|
|
|
}
|
|
@@ -598,7 +599,7 @@ public class InformationQueryServiceImpl extends BaseServiceImpl<InformationQuer
|
|
|
List<TaskParallel> linkTasks = finalTaskParallelMaps.getOrDefault(tasks.get(0).getProcessInstanceId(), null);
|
|
|
if (linkTasks != null && linkTasks.size() > 0) {
|
|
|
//处理审批状态
|
|
|
- this.integrationMethod(vor, linkTasks);
|
|
|
+ this.integrationMethod(vor, linkTasks,vo.getTaskStatus());
|
|
|
}
|
|
|
//设置上报批次
|
|
|
vor.setReportNumber(String.valueOf(tasks.get(0).getBatch()));
|
|
@@ -816,7 +817,8 @@ public class InformationQueryServiceImpl extends BaseServiceImpl<InformationQuer
|
|
|
/**
|
|
|
* 统合方法
|
|
|
*/
|
|
|
- private void integrationMethod(InformationQueryVO vo, List<TaskParallel> linkList) {
|
|
|
+ private void integrationMethod(InformationQueryVO vo, List<TaskParallel> linkList,String taskStatus) {
|
|
|
+
|
|
|
for (TaskParallel link : linkList) {
|
|
|
vo.setWaitingUserList
|
|
|
(link.getTaskUserName(),
|
|
@@ -824,6 +826,17 @@ public class InformationQueryServiceImpl extends BaseServiceImpl<InformationQuer
|
|
|
(new Integer(2).equals(link.getStatus()) ? 2 :
|
|
|
(new Integer(3).equals(link.getStatus()) && new Integer(1).equals(link.getInitiative())) ? 3
|
|
|
: 1));
|
|
|
+ String eVisaFailedInfo = "";
|
|
|
+ if (link.getStatus() == 2 && ObjectUtil.isNotEmpty(link.getEVisaStatus()) && link.getEVisaStatus() == 2) {
|
|
|
+ if (link.getEVisaContent().contains("请等待") && ObjectUtil.isEmpty(eVisaFailedInfo)) {
|
|
|
+ eVisaFailedInfo = link.getEVisaContent();
|
|
|
+ }
|
|
|
+ } else if (ObjectUtil.isNotEmpty(link.getEVisaStatus()) && link.getEVisaStatus() == 99) {
|
|
|
+ if (ObjectUtil.isEmpty(eVisaFailedInfo)) {
|
|
|
+ eVisaFailedInfo = link.getEVisaContent();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ vo.setEVisaFailedInfo(eVisaFailedInfo);
|
|
|
}
|
|
|
}
|
|
|
|