|
@@ -1,9 +1,8 @@
|
|
package com.ruoyi.project.ehs.controller;
|
|
package com.ruoyi.project.ehs.controller;
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
import com.alibaba.fastjson.JSON;
|
|
-import com.github.pagehelper.PageInfo;
|
|
|
|
-import com.ruoyi.common.constant.HttpStatus;
|
|
|
|
import com.ruoyi.common.utils.PageUtils;
|
|
import com.ruoyi.common.utils.PageUtils;
|
|
|
|
+import com.ruoyi.common.utils.StringUtils;
|
|
import com.ruoyi.common.utils.http.HttpContextUtils;
|
|
import com.ruoyi.common.utils.http.HttpContextUtils;
|
|
import com.ruoyi.common.utils.poi.ExcelUtil;
|
|
import com.ruoyi.common.utils.poi.ExcelUtil;
|
|
import com.ruoyi.framework.aspectj.lang.annotation.Log;
|
|
import com.ruoyi.framework.aspectj.lang.annotation.Log;
|
|
@@ -234,12 +233,23 @@ public class TApproveDangerController extends BaseController {
|
|
public TableDataInfo myApprovelist(@RequestParam Map<String, Object> params) {
|
|
public TableDataInfo myApprovelist(@RequestParam Map<String, Object> params) {
|
|
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
|
|
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
|
|
//查询发起流程
|
|
//查询发起流程
|
|
- List<HistoricProcessInstance> historicProcessInstanceList =
|
|
|
|
- historyService.createHistoricProcessInstanceQuery()
|
|
|
|
- .startedBy(getUserId().toString()).orderByProcessInstanceStartTime().desc()//参与者,组任务查询
|
|
|
|
- .listPage(PageUtils.getStart(params), Integer.parseInt((String) params.get("pageSize")));
|
|
|
|
- Long count = historyService.createHistoricProcessInstanceQuery()
|
|
|
|
- .startedBy(getUserId().toString()).count();
|
|
|
|
|
|
+ List<HistoricProcessInstance> historicProcessInstanceList = null;
|
|
|
|
+ Long count;
|
|
|
|
+ if (StringUtils.isEmpty(params.getOrDefault("definitionKey", "").toString())) {
|
|
|
|
+ historicProcessInstanceList = historyService.createHistoricProcessInstanceQuery()
|
|
|
|
+ .startedBy(getUserId().toString()).orderByProcessInstanceStartTime().desc()//参与者,组任务查询
|
|
|
|
+ .listPage(PageUtils.getStart(params), Integer.parseInt((String) params.get("pageSize")));
|
|
|
|
+ count = historyService.createHistoricProcessInstanceQuery()
|
|
|
|
+ .startedBy(getUserId().toString()).count();
|
|
|
|
+ } else {
|
|
|
|
+ historicProcessInstanceList = historyService.createHistoricProcessInstanceQuery()
|
|
|
|
+ .startedBy(getUserId().toString()).orderByProcessInstanceStartTime().desc()//参与者,组任务查询
|
|
|
|
+ .processDefinitionKeyIn(JSON.parseArray(params.get("definitionKey").toString(), String.class))
|
|
|
|
+ .listPage(PageUtils.getStart(params), Integer.parseInt((String) params.get("pageSize")));
|
|
|
|
+ count = historyService.createHistoricProcessInstanceQuery()
|
|
|
|
+ .processDefinitionKeyIn(JSON.parseArray(params.get("definitionKey").toString(), String.class))
|
|
|
|
+ .startedBy(getUserId().toString()).count();
|
|
|
|
+ }
|
|
logger.info(JSON.toJSONString(historicProcessInstanceList));
|
|
logger.info(JSON.toJSONString(historicProcessInstanceList));
|
|
//整合我的申请数据
|
|
//整合我的申请数据
|
|
List<DevProcess> list = new ArrayList<>();
|
|
List<DevProcess> list = new ArrayList<>();
|
|
@@ -311,13 +321,13 @@ public class TApproveDangerController extends BaseController {
|
|
TSaiApply approve = tSaiApplyService.selectTSaiApplyById(Long.parseLong(pi.getBusinessKey()));
|
|
TSaiApply approve = tSaiApplyService.selectTSaiApplyById(Long.parseLong(pi.getBusinessKey()));
|
|
devProcess.setApproveObject(approve);
|
|
devProcess.setApproveObject(approve);
|
|
devProcess.setApNo(approve.getApNo());
|
|
devProcess.setApNo(approve.getApNo());
|
|
- }else if (pi.getProcessDefinitionName().equals("每周安全排查报告")) {
|
|
|
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("每周安全排查报告")) {
|
|
TSpecWeekcheck t = tSpecWeekcheckService.selectTSpecWeekcheckById(Long.parseLong(pi.getBusinessKey()));
|
|
TSpecWeekcheck t = tSpecWeekcheckService.selectTSpecWeekcheckById(Long.parseLong(pi.getBusinessKey()));
|
|
SysUser user = sysUserService.selectUserById(Long.valueOf(t.getCreaterCode()));
|
|
SysUser user = sysUserService.selectUserById(Long.valueOf(t.getCreaterCode()));
|
|
devProcess.setApNo(t.getId().toString());
|
|
devProcess.setApNo(t.getId().toString());
|
|
devProcess.setApName(user.getNickName());
|
|
devProcess.setApName(user.getNickName());
|
|
devProcess.setApproveObject(t);
|
|
devProcess.setApproveObject(t);
|
|
- }else if (pi.getProcessDefinitionName().equals("导师带徒经理审批")) {
|
|
|
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("导师带徒经理审批")) {
|
|
TTsApprove t = tTsApproveService.selectTTsApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
TTsApprove t = tTsApproveService.selectTTsApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
devProcess.setApNo(t.getApNo());
|
|
devProcess.setApNo(t.getApNo());
|
|
devProcess.setApproveObject(t);
|
|
devProcess.setApproveObject(t);
|
|
@@ -339,7 +349,7 @@ public class TApproveDangerController extends BaseController {
|
|
logger.info("devProcess:" + devProcess);
|
|
logger.info("devProcess:" + devProcess);
|
|
list.add(devProcess);
|
|
list.add(devProcess);
|
|
}
|
|
}
|
|
- return getDataTable(list , count);
|
|
|
|
|
|
+ return getDataTable(list, count);
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -348,14 +358,28 @@ public class TApproveDangerController extends BaseController {
|
|
@GetMapping("/backlogList")
|
|
@GetMapping("/backlogList")
|
|
public TableDataInfo backlogList(@RequestParam Map<String, Object> params) {
|
|
public TableDataInfo backlogList(@RequestParam Map<String, Object> params) {
|
|
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
|
|
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
|
|
- List<Task> taskList = processEngine.getTaskService()//获取任务service
|
|
|
|
- .createTaskQuery()//创建查询对象
|
|
|
|
- .taskCandidateOrAssigned(getUserId().toString())
|
|
|
|
-// .taskAssignee(getUserId().toString())
|
|
|
|
- .orderByTaskCreateTime().desc()//参与者,组任务查询
|
|
|
|
- .listPage(PageUtils.getStart(params), Integer.parseInt((String) params.get("pageSize")));
|
|
|
|
|
|
+ List<Task> taskList;
|
|
//分页数据
|
|
//分页数据
|
|
- Long count = processEngine.getTaskService().createTaskQuery().taskCandidateUser(getUserId().toString()).count();
|
|
|
|
|
|
+ Long count;
|
|
|
|
+ if (StringUtils.isEmpty(params.getOrDefault("definitionKey", "").toString())) {
|
|
|
|
+ taskList = processEngine.getTaskService()//获取任务service
|
|
|
|
+ .createTaskQuery()//创建查询对象
|
|
|
|
+ .taskCandidateOrAssigned(getUserId().toString())
|
|
|
|
+ // .taskAssignee(getUserId().toString())
|
|
|
|
+ .orderByTaskCreateTime().desc()//参与者,组任务查询
|
|
|
|
+ .listPage(PageUtils.getStart(params), Integer.parseInt((String) params.get("pageSize")));
|
|
|
|
+ count = processEngine.getTaskService().createTaskQuery().taskCandidateUser(getUserId().toString()).count();
|
|
|
|
+ } else {
|
|
|
|
+ taskList = processEngine.getTaskService()//获取任务service
|
|
|
|
+ .createTaskQuery()//创建查询对象
|
|
|
|
+ .taskCandidateOrAssigned(getUserId().toString())
|
|
|
|
+ .processDefinitionKeyIn(JSON.parseArray(params.get("definitionKey").toString(), String.class))
|
|
|
|
+ // .taskAssignee(getUserId().toString())
|
|
|
|
+ .orderByTaskCreateTime().desc()//参与者,组任务查询
|
|
|
|
+ .listPage(PageUtils.getStart(params), Integer.parseInt((String) params.get("pageSize")));
|
|
|
|
+ count = processEngine.getTaskService().createTaskQuery().taskCandidateUser(getUserId().toString()).
|
|
|
|
+ processDefinitionKeyIn(JSON.parseArray(params.get("definitionKey").toString(), String.class)).count();
|
|
|
|
+ }
|
|
List<DevTask> list = new ArrayList<>();
|
|
List<DevTask> list = new ArrayList<>();
|
|
if (taskList.size() > 0) {
|
|
if (taskList.size() > 0) {
|
|
for (Task task : taskList) {
|
|
for (Task task : taskList) {
|
|
@@ -442,11 +466,11 @@ public class TApproveDangerController extends BaseController {
|
|
TSaiApply approve = tSaiApplyService.selectTSaiApplyById(Long.parseLong(pi.getBusinessKey()));
|
|
TSaiApply approve = tSaiApplyService.selectTSaiApplyById(Long.parseLong(pi.getBusinessKey()));
|
|
devTask.setApproveObject(approve);
|
|
devTask.setApproveObject(approve);
|
|
devTask.setApNo(approve.getApNo());
|
|
devTask.setApNo(approve.getApNo());
|
|
- }else if (pi.getProcessDefinitionName().equals("每周安全排查报告")) {
|
|
|
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("每周安全排查报告")) {
|
|
TSpecWeekcheck t = tSpecWeekcheckService.selectTSpecWeekcheckById(Long.parseLong(pi.getBusinessKey()));
|
|
TSpecWeekcheck t = tSpecWeekcheckService.selectTSpecWeekcheckById(Long.parseLong(pi.getBusinessKey()));
|
|
devTask.setApproveObject(t);
|
|
devTask.setApproveObject(t);
|
|
devTask.setApNo(t.getId().toString());
|
|
devTask.setApNo(t.getId().toString());
|
|
- }else if (pi.getProcessDefinitionName().equals("导师带徒经理审批")) {
|
|
|
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("导师带徒经理审批")) {
|
|
TTsApprove t = tTsApproveService.selectTTsApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
TTsApprove t = tTsApproveService.selectTTsApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
devTask.setApNo(t.getApNo());
|
|
devTask.setApNo(t.getApNo());
|
|
devTask.setApproveObject(t);
|
|
devTask.setApproveObject(t);
|
|
@@ -454,7 +478,7 @@ public class TApproveDangerController extends BaseController {
|
|
list.add(devTask);
|
|
list.add(devTask);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- return getDataTable(list,count);
|
|
|
|
|
|
+ return getDataTable(list, count);
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -543,7 +567,7 @@ public class TApproveDangerController extends BaseController {
|
|
devProcess.setApNo(approve.getApNo());
|
|
devProcess.setApNo(approve.getApNo());
|
|
devProcess.setApName(user.getNickName());
|
|
devProcess.setApName(user.getNickName());
|
|
devProcess.setApproveObject(approve);
|
|
devProcess.setApproveObject(approve);
|
|
- } else if (pi.getProcessDefinitionName().equals("组织保护措施状态变更申请流程")) {
|
|
|
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("组织保护措施状态变更申请流程")) {
|
|
TApplySafetychange approve = tApplySafetychangeService.selectTApplySafetychangeById(Long.parseLong(pi.getBusinessKey()));
|
|
TApplySafetychange approve = tApplySafetychangeService.selectTApplySafetychangeById(Long.parseLong(pi.getBusinessKey()));
|
|
SysUser user = sysUserService.selectUserById(Long.valueOf(approve.getCreaterCode()));
|
|
SysUser user = sysUserService.selectUserById(Long.valueOf(approve.getCreaterCode()));
|
|
devProcess.setApNo(approve.getApNo());
|
|
devProcess.setApNo(approve.getApNo());
|
|
@@ -555,13 +579,13 @@ public class TApproveDangerController extends BaseController {
|
|
devProcess.setApNo(approve.getApNo());
|
|
devProcess.setApNo(approve.getApNo());
|
|
devProcess.setApName(user.getNickName());
|
|
devProcess.setApName(user.getNickName());
|
|
devProcess.setApproveObject(approve);
|
|
devProcess.setApproveObject(approve);
|
|
- }else if (pi.getProcessDefinitionName().equals("每周安全排查报告")) {
|
|
|
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("每周安全排查报告")) {
|
|
TSpecWeekcheck t = tSpecWeekcheckService.selectTSpecWeekcheckById(Long.parseLong(pi.getBusinessKey()));
|
|
TSpecWeekcheck t = tSpecWeekcheckService.selectTSpecWeekcheckById(Long.parseLong(pi.getBusinessKey()));
|
|
SysUser user = sysUserService.selectUserById(Long.valueOf(t.getCreaterCode()));
|
|
SysUser user = sysUserService.selectUserById(Long.valueOf(t.getCreaterCode()));
|
|
devProcess.setApNo(t.getId().toString());
|
|
devProcess.setApNo(t.getId().toString());
|
|
devProcess.setApName(user.getNickName());
|
|
devProcess.setApName(user.getNickName());
|
|
devProcess.setApproveObject(t);
|
|
devProcess.setApproveObject(t);
|
|
- }else if (pi.getProcessDefinitionName().equals("导师带徒经理审批")) {
|
|
|
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("导师带徒经理审批")) {
|
|
TTsApprove t = tTsApproveService.selectTTsApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
TTsApprove t = tTsApproveService.selectTTsApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
SysUser user = sysUserService.selectUserById(Long.valueOf(t.getCreaterCode()));
|
|
SysUser user = sysUserService.selectUserById(Long.valueOf(t.getCreaterCode()));
|
|
devProcess.setApNo(t.getId().toString());
|
|
devProcess.setApNo(t.getId().toString());
|
|
@@ -589,7 +613,7 @@ public class TApproveDangerController extends BaseController {
|
|
list.add(devProcess);
|
|
list.add(devProcess);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- return getDataTable(list,count);
|
|
|
|
|
|
+ return getDataTable(list, count);
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -674,19 +698,19 @@ public class TApproveDangerController extends BaseController {
|
|
//当前任务
|
|
//当前任务
|
|
try {
|
|
try {
|
|
Task task = taskService.createTaskQuery().processInstanceId(pid).active().singleResult();
|
|
Task task = taskService.createTaskQuery().processInstanceId(pid).active().singleResult();
|
|
- if (task!= null) {
|
|
|
|
|
|
+ if (task != null) {
|
|
task.getName();
|
|
task.getName();
|
|
task.getCreateTime();
|
|
task.getCreateTime();
|
|
DevTask devTask = new DevTask();
|
|
DevTask devTask = new DevTask();
|
|
devTask.setTaskName(task.getName());
|
|
devTask.setTaskName(task.getName());
|
|
devTask.setTaskCreateTime(task.getCreateTime());
|
|
devTask.setTaskCreateTime(task.getCreateTime());
|
|
- if (task.getAssignee()!= null) {
|
|
|
|
|
|
+ if (task.getAssignee() != null) {
|
|
SysUser user = sysUserService.selectUserById(Long.parseLong(task.getAssignee()));
|
|
SysUser user = sysUserService.selectUserById(Long.parseLong(task.getAssignee()));
|
|
devTask.setUserName(user.getNickName());
|
|
devTask.setUserName(user.getNickName());
|
|
}
|
|
}
|
|
devTaskList.add(devTask);
|
|
devTaskList.add(devTask);
|
|
}
|
|
}
|
|
- }catch (Exception e) {
|
|
|
|
|
|
+ } catch (Exception e) {
|
|
logger.error(e.toString());
|
|
logger.error(e.toString());
|
|
}
|
|
}
|
|
return getDataTable(devTaskList);
|
|
return getDataTable(devTaskList);
|
|
@@ -794,7 +818,7 @@ public class TApproveDangerController extends BaseController {
|
|
.finished().list();
|
|
.finished().list();
|
|
//高亮线路id集合
|
|
//高亮线路id集合
|
|
// List<String> highLightedFlowIds = getHighLightedFlows(bpmnModel, historicActivityInstances);
|
|
// List<String> highLightedFlowIds = getHighLightedFlows(bpmnModel, historicActivityInstances);
|
|
- List<String> highLightedFlowIds = getHighLine(bpmnModel, historicActivityInstances,finished);
|
|
|
|
|
|
+ List<String> highLightedFlowIds = getHighLine(bpmnModel, historicActivityInstances, finished);
|
|
DefaultProcessDiagramGenerator generator = new DefaultProcessDiagramGenerator();
|
|
DefaultProcessDiagramGenerator generator = new DefaultProcessDiagramGenerator();
|
|
|
|
|
|
// 生成流程图
|
|
// 生成流程图
|
|
@@ -821,8 +845,6 @@ public class TApproveDangerController extends BaseController {
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
-
|
|
|
|
-
|
|
|
|
/**
|
|
/**
|
|
* 获取已经流转的线
|
|
* 获取已经流转的线
|
|
*
|
|
*
|
|
@@ -964,7 +986,7 @@ public class TApproveDangerController extends BaseController {
|
|
List<SequenceFlow> sequenceFlowList = outgoingFlows.stream()
|
|
List<SequenceFlow> sequenceFlowList = outgoingFlows.stream()
|
|
.filter(sequenceFlow -> sequenceFlow.getTargetRef().equals(historicActivityInstanceResult.getActivityId()))
|
|
.filter(sequenceFlow -> sequenceFlow.getTargetRef().equals(historicActivityInstanceResult.getActivityId()))
|
|
.collect(Collectors.toList());
|
|
.collect(Collectors.toList());
|
|
- highLightedFlowIds.addAll(sequenceFlowList.stream().map(e->e.getId()).collect(Collectors.toList()));
|
|
|
|
|
|
+ highLightedFlowIds.addAll(sequenceFlowList.stream().map(e -> e.getId()).collect(Collectors.toList()));
|
|
}
|
|
}
|
|
return highLightedFlowIds;
|
|
return highLightedFlowIds;
|
|
}
|
|
}
|