|
@@ -411,117 +411,121 @@ public class TApproveDangerController extends BaseController {
|
|
|
}
|
|
|
List<DevTask> list = new ArrayList<>();
|
|
|
if (taskList.size() > 0) {
|
|
|
- for (Task task : taskList) {
|
|
|
- ProcessInstance pi = processEngine.getRuntimeService()/**表示正在执行的流程实例和执行对象*/
|
|
|
- .createProcessInstanceQuery()/**创建流程实例查询*/
|
|
|
- .processInstanceId(task.getProcessInstanceId())/**使用流程实例ID查询*/
|
|
|
- .singleResult();
|
|
|
- logger.info("待办任务ID:" + task.getId());
|
|
|
- logger.info("待办任务name:" + task.getName());
|
|
|
- logger.info("待办任务创建时间:" + task.getCreateTime());
|
|
|
- logger.info("待办任务办理人:" + task.getAssignee());
|
|
|
- logger.info("流程实例ID:" + task.getProcessInstanceId());
|
|
|
- logger.info("执行对象ID:" + task.getExecutionId());
|
|
|
- logger.info(task.getTenantId());
|
|
|
- logger.info(task.getCategory());
|
|
|
- logger.info(task.getFormKey());
|
|
|
- logger.info("流程实例Name:" + pi.getProcessDefinitionName());
|
|
|
- DevTask devTask = new DevTask();
|
|
|
- devTask.setTaskId(task.getId());
|
|
|
- devTask.setTaskName(task.getName());
|
|
|
- devTask.setTaskCreateTime(task.getCreateTime());
|
|
|
- devTask.setProcessId(task.getProcessInstanceId());
|
|
|
- devTask.setProcessName(pi.getProcessDefinitionName());
|
|
|
- devTask.setProcessCreateTime(pi.getStartTime());
|
|
|
- devTask.setBusinessKey(pi.getBusinessKey());
|
|
|
- if (pi.getProcessDefinitionName().equals("重大隐患审批流程") || pi.getProcessDefinitionName().equals("普通隐患审批流程")) {
|
|
|
- TApproveDanger approveDanger = tApproveDangerService.selectTApproveDangerById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- devTask.settApprove(approveDanger);
|
|
|
- devTask.setApNo(approveDanger.getApproveNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("事件审批流程")) {
|
|
|
- TApproveAccident approveAccident = tApproveAccidentService.selectTApproveAccidentById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- devTask.settApproveAccident(approveAccident);
|
|
|
- devTask.setApNo(approveAccident.getApproveNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("特种设备审核")) {
|
|
|
- TApprove approve = tApproveService.selectTApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- devTask.setSpecApprove(approve);
|
|
|
- devTask.setApNo(approve.getApNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("年度检查报告申请")) {
|
|
|
- TApprove approve = tApproveService.selectTApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- devTask.setSpecApprove(approve);
|
|
|
- devTask.setApNo(approve.getApNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("月度检查")) {
|
|
|
- TApprove approve = tApproveService.selectTApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- devTask.setSpecApprove(approve);
|
|
|
- devTask.setApNo(approve.getApNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("设备修改/删除审核") || pi.getProcessDefinitionName().equals("设备新增/删除审核")) {
|
|
|
- TApproveSpecModify approve = tApproveSpecModifyService.selectTApproveSpecModifyById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- logger.info("设备修改/删除审核" + JSON.toJSONString(approve));
|
|
|
- devTask.setApproveSpecModify(approve);
|
|
|
- devTask.setApNo(approve.getApNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("专项培训计划审核")) {
|
|
|
- TStApprove approve = tStApproveService.selectTStApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- logger.info("专项培训计划审核" + JSON.toJSONString(approve));
|
|
|
- devTask.setApproveObj(approve);
|
|
|
- devTask.setApNo(approve.getApNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("设备维修审批流程")) {
|
|
|
- TApproveMaintenance approve = tApproveMaintenanceService.selectTApproveMaintenanceById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- logger.info("设备维修审批流程" + JSON.toJSONString(approve));
|
|
|
- devTask.setApproveObj(approve);
|
|
|
- devTask.setApNo(approve.getApNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("设备变更申请")) {
|
|
|
- TIntactApprove approve = tIntactApproveService.selectTIntactApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- logger.info("设备变更申请" + JSON.toJSONString(approve));
|
|
|
- devTask.setApproveObj(approve);
|
|
|
- devTask.setApNo(approve.getApNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("可靠性管理申请")) {
|
|
|
- TKekaoApprove approve = tKekaoApproveService.selectTKekaoApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- logger.info("可靠性管理申请" + JSON.toJSONString(approve));
|
|
|
- devTask.setApproveObj(approve);
|
|
|
- devTask.setApNo(approve.getApNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("预约开票审批流程")) {
|
|
|
- TApproveReserveInvoice approve = tApproveReserveInvoiceService.selectTApproveReserveInvoiceById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- devTask.setApproveObject(approve);
|
|
|
- devTask.setApNo(approve.getApNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("安全阀离线/切出申请流程")) {
|
|
|
- TApplyOfflinevalve approve = tApplyOfflinevalveService.selectTApplyOfflinevalveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- devTask.setApproveObject(approve);
|
|
|
- devTask.setApNo(approve.getApNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("组织保护措施状态变更申请流程")) {
|
|
|
- TApplySafetychange approve = tApplySafetychangeService.selectTApplySafetychangeById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- devTask.setApproveObject(approve);
|
|
|
- devTask.setApNo(approve.getApNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("SAI开项申请流程")) {
|
|
|
- TSaiApply approve = tSaiApplyService.selectTSaiApplyById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- devTask.setApproveObject(approve);
|
|
|
- devTask.setApNo(approve.getApNo());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("每周安全排查报告")) {
|
|
|
- TSpecWeekcheck t = tSpecWeekcheckService.selectTSpecWeekcheckById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- devTask.setApproveObject(t);
|
|
|
- devTask.setApNo(t.getId().toString());
|
|
|
- } else if (pi.getProcessDefinitionName().equals("导师带徒经理审批")) {
|
|
|
- TTsApprove t = tTsApproveService.selectTTsApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- devTask.setApNo(t.getApNo());
|
|
|
- devTask.setApproveObject(t);
|
|
|
- } else if (pi.getProcessDefinitionName().equals("导师带徒学员成绩不合格审批")) {
|
|
|
- TTsApprove t = tTsApproveService.selectTTsApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- devTask.setApNo(t.getApNo());
|
|
|
- devTask.setApproveObject(t);
|
|
|
- } else if (pi.getProcessDefinitionName().equals("PSSR装置经理审批")) {
|
|
|
- TPssrApprove t = tPssrApproveService.selectTPssrApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- TPssrAboveall tPssrAboveall = tPssrAboveallService.selectTPssrAboveallById(t.getAboveallId());
|
|
|
- devTask.setProcessName(pi.getProcessDefinitionName()+"_"+tPssrAboveall.getUnit());
|
|
|
- devTask.setApNo(t.getApNo());
|
|
|
- devTask.setApproveObject(t);
|
|
|
- } else if (pi.getProcessDefinitionName().contains("PSSR")&&!pi.getProcessDefinitionName().equals("PSSR装置经理审批")) {
|
|
|
- TPssrApprove t = tPssrApproveService.selectTPssrApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
- TPssrSubcontent tPssrSubcontent = tPssrSubcontentService.selectTPssrSubcontentById(t.getSubId());
|
|
|
- t.setSn(tPssrSubcontent.getForShort());
|
|
|
- devTask.setProcessName(pi.getProcessDefinitionName()+"_"+tPssrSubcontent.getUnit()+"_"+tPssrSubcontent.getItem());
|
|
|
- devTask.setApNo(t.getApNo());
|
|
|
- devTask.setApproveObject(t);
|
|
|
+ try {
|
|
|
+ for (Task task : taskList) {
|
|
|
+ ProcessInstance pi = processEngine.getRuntimeService()/**表示正在执行的流程实例和执行对象*/
|
|
|
+ .createProcessInstanceQuery()/**创建流程实例查询*/
|
|
|
+ .processInstanceId(task.getProcessInstanceId())/**使用流程实例ID查询*/
|
|
|
+ .singleResult();
|
|
|
+ logger.info("待办任务ID:" + task.getId());
|
|
|
+ logger.info("待办任务name:" + task.getName());
|
|
|
+ logger.info("待办任务创建时间:" + task.getCreateTime());
|
|
|
+ logger.info("待办任务办理人:" + task.getAssignee());
|
|
|
+ logger.info("流程实例ID:" + task.getProcessInstanceId());
|
|
|
+ logger.info("执行对象ID:" + task.getExecutionId());
|
|
|
+ logger.info(task.getTenantId());
|
|
|
+ logger.info(task.getCategory());
|
|
|
+ logger.info(task.getFormKey());
|
|
|
+ logger.info("流程实例Name:" + pi.getProcessDefinitionName());
|
|
|
+ DevTask devTask = new DevTask();
|
|
|
+ devTask.setTaskId(task.getId());
|
|
|
+ devTask.setTaskName(task.getName());
|
|
|
+ devTask.setTaskCreateTime(task.getCreateTime());
|
|
|
+ devTask.setProcessId(task.getProcessInstanceId());
|
|
|
+ devTask.setProcessName(pi.getProcessDefinitionName());
|
|
|
+ devTask.setProcessCreateTime(pi.getStartTime());
|
|
|
+ devTask.setBusinessKey(pi.getBusinessKey());
|
|
|
+ if (pi.getProcessDefinitionName().equals("重大隐患审批流程") || pi.getProcessDefinitionName().equals("普通隐患审批流程")) {
|
|
|
+ TApproveDanger approveDanger = tApproveDangerService.selectTApproveDangerById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ devTask.settApprove(approveDanger);
|
|
|
+ devTask.setApNo(approveDanger.getApproveNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("事件审批流程")) {
|
|
|
+ TApproveAccident approveAccident = tApproveAccidentService.selectTApproveAccidentById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ devTask.settApproveAccident(approveAccident);
|
|
|
+ devTask.setApNo(approveAccident.getApproveNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("特种设备审核")) {
|
|
|
+ TApprove approve = tApproveService.selectTApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ devTask.setSpecApprove(approve);
|
|
|
+ devTask.setApNo(approve.getApNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("年度检查报告申请")) {
|
|
|
+ TApprove approve = tApproveService.selectTApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ devTask.setSpecApprove(approve);
|
|
|
+ devTask.setApNo(approve.getApNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("月度检查")) {
|
|
|
+ TApprove approve = tApproveService.selectTApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ devTask.setSpecApprove(approve);
|
|
|
+ devTask.setApNo(approve.getApNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("设备修改/删除审核") || pi.getProcessDefinitionName().equals("设备新增/删除审核")) {
|
|
|
+ TApproveSpecModify approve = tApproveSpecModifyService.selectTApproveSpecModifyById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ logger.info("设备修改/删除审核" + JSON.toJSONString(approve));
|
|
|
+ devTask.setApproveSpecModify(approve);
|
|
|
+ devTask.setApNo(approve.getApNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("专项培训计划审核")) {
|
|
|
+ TStApprove approve = tStApproveService.selectTStApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ logger.info("专项培训计划审核" + JSON.toJSONString(approve));
|
|
|
+ devTask.setApproveObj(approve);
|
|
|
+ devTask.setApNo(approve.getApNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("设备维修审批流程")) {
|
|
|
+ TApproveMaintenance approve = tApproveMaintenanceService.selectTApproveMaintenanceById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ logger.info("设备维修审批流程" + JSON.toJSONString(approve));
|
|
|
+ devTask.setApproveObj(approve);
|
|
|
+ devTask.setApNo(approve.getApNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("设备变更申请")) {
|
|
|
+ TIntactApprove approve = tIntactApproveService.selectTIntactApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ logger.info("设备变更申请" + JSON.toJSONString(approve));
|
|
|
+ devTask.setApproveObj(approve);
|
|
|
+ devTask.setApNo(approve.getApNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("可靠性管理申请")) {
|
|
|
+ TKekaoApprove approve = tKekaoApproveService.selectTKekaoApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ logger.info("可靠性管理申请" + JSON.toJSONString(approve));
|
|
|
+ devTask.setApproveObj(approve);
|
|
|
+ devTask.setApNo(approve.getApNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("预约开票审批流程")) {
|
|
|
+ TApproveReserveInvoice approve = tApproveReserveInvoiceService.selectTApproveReserveInvoiceById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ devTask.setApproveObject(approve);
|
|
|
+ devTask.setApNo(approve.getApNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("安全阀离线/切出申请流程")) {
|
|
|
+ TApplyOfflinevalve approve = tApplyOfflinevalveService.selectTApplyOfflinevalveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ devTask.setApproveObject(approve);
|
|
|
+ devTask.setApNo(approve.getApNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("组织保护措施状态变更申请流程")) {
|
|
|
+ TApplySafetychange approve = tApplySafetychangeService.selectTApplySafetychangeById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ devTask.setApproveObject(approve);
|
|
|
+ devTask.setApNo(approve.getApNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("SAI开项申请流程")) {
|
|
|
+ TSaiApply approve = tSaiApplyService.selectTSaiApplyById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ devTask.setApproveObject(approve);
|
|
|
+ devTask.setApNo(approve.getApNo());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("每周安全排查报告")) {
|
|
|
+ TSpecWeekcheck t = tSpecWeekcheckService.selectTSpecWeekcheckById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ devTask.setApproveObject(t);
|
|
|
+ devTask.setApNo(t.getId().toString());
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("导师带徒经理审批")) {
|
|
|
+ TTsApprove t = tTsApproveService.selectTTsApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ devTask.setApNo(t.getApNo());
|
|
|
+ devTask.setApproveObject(t);
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("导师带徒学员成绩不合格审批")) {
|
|
|
+ TTsApprove t = tTsApproveService.selectTTsApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ devTask.setApNo(t.getApNo());
|
|
|
+ devTask.setApproveObject(t);
|
|
|
+ } else if (pi.getProcessDefinitionName().equals("PSSR装置经理审批")) {
|
|
|
+ TPssrApprove t = tPssrApproveService.selectTPssrApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ TPssrAboveall tPssrAboveall = tPssrAboveallService.selectTPssrAboveallById(t.getAboveallId());
|
|
|
+ devTask.setProcessName(pi.getProcessDefinitionName()+"_"+tPssrAboveall.getUnit());
|
|
|
+ devTask.setApNo(t.getApNo());
|
|
|
+ devTask.setApproveObject(t);
|
|
|
+ } else if (pi.getProcessDefinitionName().contains("PSSR")&&!pi.getProcessDefinitionName().equals("PSSR装置经理审批")) {
|
|
|
+ TPssrApprove t = tPssrApproveService.selectTPssrApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
+ TPssrSubcontent tPssrSubcontent = tPssrSubcontentService.selectTPssrSubcontentById(t.getSubId());
|
|
|
+ t.setSn(tPssrSubcontent.getForShort());
|
|
|
+ devTask.setProcessName(pi.getProcessDefinitionName()+"_"+tPssrSubcontent.getUnit()+"_"+tPssrSubcontent.getItem());
|
|
|
+ devTask.setApNo(t.getApNo());
|
|
|
+ devTask.setApproveObject(t);
|
|
|
+ }
|
|
|
+ list.add(devTask);
|
|
|
}
|
|
|
- list.add(devTask);
|
|
|
+ }catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
}
|
|
|
}
|
|
|
return getDataTable(list, count);
|