|
@@ -37,7 +37,7 @@ import java.util.*;
|
|
import java.util.stream.Collectors;
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 隐患申请Controller
|
|
|
|
|
|
+ * 流程处理
|
|
*
|
|
*
|
|
* @author ruoyi
|
|
* @author ruoyi
|
|
* @date 2021-02-20
|
|
* @date 2021-02-20
|
|
@@ -46,9 +46,6 @@ import java.util.stream.Collectors;
|
|
@RequestMapping("/ehs/approvedanger")
|
|
@RequestMapping("/ehs/approvedanger")
|
|
public class TApproveDangerController extends BaseController {
|
|
public class TApproveDangerController extends BaseController {
|
|
|
|
|
|
- @Autowired
|
|
|
|
- private RuntimeService runtimeService;
|
|
|
|
-
|
|
|
|
@Autowired
|
|
@Autowired
|
|
private HistoryService historyService;
|
|
private HistoryService historyService;
|
|
|
|
|
|
@@ -64,131 +61,6 @@ public class TApproveDangerController extends BaseController {
|
|
@Autowired
|
|
@Autowired
|
|
private ITBranchMemberService memberService;
|
|
private ITBranchMemberService memberService;
|
|
|
|
|
|
-// @Autowired
|
|
|
|
-// private ITApproveDangerService tApproveDangerService;
|
|
|
|
-
|
|
|
|
-// @Autowired
|
|
|
|
-// private ITApproveAccidentService tApproveAccidentService;
|
|
|
|
-
|
|
|
|
-
|
|
|
|
-
|
|
|
|
-// @Autowired
|
|
|
|
-// private ITCommonfileService tCommonfileService;
|
|
|
|
-// @Autowired
|
|
|
|
-// private ITApproveService tApproveService;
|
|
|
|
-// @Autowired
|
|
|
|
-// private ITApproveSpecModifyService tApproveSpecModifyService;
|
|
|
|
-// @Autowired
|
|
|
|
-// private ITStApproveService tStApproveService;
|
|
|
|
-// @Autowired
|
|
|
|
-// private ITApproveMaintenanceService tApproveMaintenanceService;
|
|
|
|
-// @Autowired
|
|
|
|
-// private ITIntactApproveService tIntactApproveService;
|
|
|
|
-// @Autowired
|
|
|
|
-// private ITKekaoApproveService tKekaoApproveService;
|
|
|
|
-// @Autowired
|
|
|
|
-// private ITApproveReserveInvoiceService tApproveReserveInvoiceService;
|
|
|
|
-//
|
|
|
|
-// @Autowired
|
|
|
|
-// private ITApplyOfflinevalveService tApplyOfflinevalveService;
|
|
|
|
-//
|
|
|
|
-// @Autowired
|
|
|
|
-// private ITApplySafetychangeService tApplySafetychangeService;
|
|
|
|
-//
|
|
|
|
-// @Autowired
|
|
|
|
-// private ITSaiApplyService tSaiApplyService;
|
|
|
|
-
|
|
|
|
-// /**
|
|
|
|
-// * 任务申请
|
|
|
|
-// */
|
|
|
|
-// @PostMapping("/save")
|
|
|
|
-// public AjaxResult save(@RequestBody TApproveDanger tApprove) {
|
|
|
|
-// try {
|
|
|
|
-// logger.info("任务申请" + JSON.toJSONString(tApprove));
|
|
|
|
-// Long userid = getUserId();
|
|
|
|
-// //审批编号
|
|
|
|
-// Date dt = new Date();
|
|
|
|
-// SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddhhmmss");
|
|
|
|
-// String data = sdf.format(dt) + userid;
|
|
|
|
-// tApprove.setApproveNo(data);
|
|
|
|
-// tApprove.setRecorderId(userid);
|
|
|
|
-// logger.info("tApprove:" + tApprove);
|
|
|
|
-// tApproveDangerService.insertTApproveDanger(tApprove);
|
|
|
|
-//
|
|
|
|
-// Map<String, Object> variables = new HashMap<>();
|
|
|
|
-// //执行人、验证人确认
|
|
|
|
-// Long verificationId = null;
|
|
|
|
-// Long deptId = sysUserService.selectUserById(userid).getDeptId();
|
|
|
|
-// List<SysUser> deptPerson = sysUserService.selectUserByDept(deptId);
|
|
|
|
-// for (SysUser s : deptPerson) {
|
|
|
|
-// SysUserRole userRole = sysUserService.selectRoleByUserId(s.getUserId());
|
|
|
|
-// if (userRole.getRoleId() == 100) {
|
|
|
|
-// verificationId = userRole.getUserId();
|
|
|
|
-// }
|
|
|
|
-// }
|
|
|
|
-// tApprove.setVerificationId(verificationId);
|
|
|
|
-//
|
|
|
|
-// //开始工作流、监听
|
|
|
|
-// variables.put("endSucessListener", new EndSucessListener());
|
|
|
|
-// variables.put("recorderTaskCreateListener", new RecorderTaskCreateListener());
|
|
|
|
-// variables.put("executorTaskCreateListener", new ExecutorTaskCreateListener());
|
|
|
|
-// variables.put("verificationTaskCreateListener", new VerificationTaskCreateListener());
|
|
|
|
-//
|
|
|
|
-// //审批人员设置
|
|
|
|
-// variables.put("recorder", userid);
|
|
|
|
-// variables.put("executor", tApprove.getExecutorId());
|
|
|
|
-// variables.put("verification", verificationId);
|
|
|
|
-// logger.info("executor:" + tApprove.getExecutorId());
|
|
|
|
-// logger.info("verification:" + verificationId);
|
|
|
|
-//
|
|
|
|
-// long bussniseeKey = tApprove.getId();
|
|
|
|
-// logger.info("bussniseeKey:" + bussniseeKey);
|
|
|
|
-// Authentication.setAuthenticatedUserId(userid.toString());
|
|
|
|
-// //采用key来启动流程定义并设置流程变量,返回流程实例
|
|
|
|
-// ProcessInstance pi = null;
|
|
|
|
-// if (tApprove.getHiddendangerLevel() == 2) {
|
|
|
|
-// pi = runtimeService.startProcessInstanceByKey("commonProcess", String.valueOf(bussniseeKey), variables);
|
|
|
|
-// } else if (tApprove.getHiddendangerLevel() == 3) {
|
|
|
|
-// //初始化会签人员
|
|
|
|
-// List<Long> confirmlist = new ArrayList<>();
|
|
|
|
-// confirmlist.add(tApprove.getConfirmoneId());
|
|
|
|
-// confirmlist.add(tApprove.getConfirmtwoId());
|
|
|
|
-// //条件表达式方法 一定要序列号
|
|
|
|
-// variables.put("confirmlist", confirmlist);
|
|
|
|
-// pi = runtimeService.startProcessInstanceByKey("majorProcess", String.valueOf(bussniseeKey), variables);
|
|
|
|
-// }
|
|
|
|
-//
|
|
|
|
-// logger.info("流程部署id:" + pi.getDeploymentId());
|
|
|
|
-// logger.info("流程定义id:" + pi.getProcessDefinitionId());
|
|
|
|
-// logger.info("流程实例id:" + pi.getProcessInstanceId());
|
|
|
|
-// logger.info("流程定义对象:" + pi.getProcessVariables());
|
|
|
|
-// tApprove.setProcessId(Long.parseLong(pi.getProcessInstanceId()));
|
|
|
|
-//
|
|
|
|
-// logger.info("tApprove:" + tApprove);
|
|
|
|
-// tApproveDangerService.updateTApproveDanger(tApprove);
|
|
|
|
-// } catch (Exception e) {
|
|
|
|
-// logger.info("e:" + e);
|
|
|
|
-// }
|
|
|
|
-// return AjaxResult.success("申请成功", tApprove);
|
|
|
|
-// }
|
|
|
|
-
|
|
|
|
-// /**
|
|
|
|
-// * 一般隐患任务申请
|
|
|
|
-// */
|
|
|
|
-// @PostMapping("/savegeneral")
|
|
|
|
-// public AjaxResult saveGeneral(@RequestBody TApproveDanger tApprove) {
|
|
|
|
-// try {
|
|
|
|
-// Long userid = getUserId();
|
|
|
|
-// tApprove.setRecorderId(userid);
|
|
|
|
-// logger.info("tApprove:" + tApprove);
|
|
|
|
-// //tApproveDangerService.insertTApproveDanger(tApprove);
|
|
|
|
-// } catch (Exception e) {
|
|
|
|
-// logger.info("e:" + e);
|
|
|
|
-// return AjaxResult.error(e.toString());
|
|
|
|
-// }
|
|
|
|
-// return AjaxResult.success("申请成功");
|
|
|
|
-// }
|
|
|
|
-
|
|
|
|
/**
|
|
/**
|
|
* 我的申请列表
|
|
* 我的申请列表
|
|
*/
|
|
*/
|
|
@@ -219,62 +91,9 @@ public class TApproveDangerController extends BaseController {
|
|
try {
|
|
try {
|
|
if (pi.getProcessDefinitionName().equals("通用审批流程")) {
|
|
if (pi.getProcessDefinitionName().equals("通用审批流程")) {
|
|
TBranchMember member = memberService.selectTBranchMemberByMemberId(Long.parseLong(h.getBusinessKey()));
|
|
TBranchMember member = memberService.selectTBranchMemberByMemberId(Long.parseLong(h.getBusinessKey()));
|
|
- devProcess.setMember(member);
|
|
|
|
|
|
+ devProcess.setObj(member);
|
|
devProcess.setApNo(member.getApNo());
|
|
devProcess.setApNo(member.getApNo());
|
|
}
|
|
}
|
|
-// else if (pi.getProcessDefinitionName().equals("年度检查报告申请")) {
|
|
|
|
-// TApprove approve = tApproveService.selectTApproveById(Long.parseLong(h.getBusinessKey()));
|
|
|
|
-// devProcess.setSpecApprove(approve);
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("月度检查")) {
|
|
|
|
-// TApprove approve = tApproveService.selectTApproveById(Long.parseLong(h.getBusinessKey()));
|
|
|
|
-// devProcess.setSpecApprove(approve);
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("设备修改/删除审核") || pi.getProcessDefinitionName().equals("设备新增/删除审核")) {
|
|
|
|
-// TApproveSpecModify approve = tApproveSpecModifyService.selectTApproveSpecModifyById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// devProcess.setApproveSpecModify(approve);
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("事件审批流程")) {
|
|
|
|
-// TApproveDanger approveDanger = tApproveDangerService.selectTApproveDangerById(Long.parseLong(h.getBusinessKey()));
|
|
|
|
-// devProcess.settApprove(approveDanger);
|
|
|
|
-// devProcess.setApNo(approveDanger.getApproveNo());
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("重大隐患审批流程") || pi.getProcessDefinitionName().equals("普通隐患审批流程")) {
|
|
|
|
-// TApproveDanger approveDanger = tApproveDangerService.selectTApproveDangerById(Long.parseLong(h.getBusinessKey()));
|
|
|
|
-// devProcess.settApprove(approveDanger);
|
|
|
|
-// devProcess.setApNo(approveDanger.getApproveNo());
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("专项培训计划审核")) {
|
|
|
|
-// TStApprove approve = tStApproveService.selectTStApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("设备维修审批流程")) {
|
|
|
|
-// TApproveMaintenance approve = tApproveMaintenanceService.selectTApproveMaintenanceById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("设备变更申请")) {
|
|
|
|
-// TIntactApprove approve = tIntactApproveService.selectTIntactApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("可靠性管理申请")) {
|
|
|
|
-// TKekaoApprove approve = tKekaoApproveService.selectTKekaoApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("预约开票审批流程")) {
|
|
|
|
-// TApproveReserveInvoice approve = tApproveReserveInvoiceService.selectTApproveReserveInvoiceById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("安全阀离线/切出申请流程")) {
|
|
|
|
-// TApplyOfflinevalve approve = tApplyOfflinevalveService.selectTApplyOfflinevalveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("组织保护措施状态变更申请流程")) {
|
|
|
|
-// TApplySafetychange approve = tApplySafetychangeService.selectTApplySafetychangeById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("SAI开项申请流程")) {
|
|
|
|
-// TSaiApply approve = tSaiApplyService.selectTSaiApplyById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// }
|
|
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
logger.error(e.toString());
|
|
logger.error(e.toString());
|
|
}
|
|
}
|
|
@@ -288,7 +107,6 @@ public class TApproveDangerController extends BaseController {
|
|
} else {
|
|
} else {
|
|
devProcess.setEnd(false);
|
|
devProcess.setEnd(false);
|
|
}
|
|
}
|
|
- ;
|
|
|
|
logger.info("devProcess:" + devProcess);
|
|
logger.info("devProcess:" + devProcess);
|
|
list.add(devProcess);
|
|
list.add(devProcess);
|
|
}
|
|
}
|
|
@@ -334,74 +152,12 @@ public class TApproveDangerController extends BaseController {
|
|
devTask.setProcessName(pi.getProcessDefinitionName());
|
|
devTask.setProcessName(pi.getProcessDefinitionName());
|
|
devTask.setProcessCreateTime(pi.getStartTime());
|
|
devTask.setProcessCreateTime(pi.getStartTime());
|
|
devTask.setBusinessKey(pi.getBusinessKey());
|
|
devTask.setBusinessKey(pi.getBusinessKey());
|
|
|
|
+ devTask.setBusinessKey(pi.getBusinessKey());
|
|
if (pi.getProcessDefinitionName().equals("通用审批流程")) {
|
|
if (pi.getProcessDefinitionName().equals("通用审批流程")) {
|
|
TBranchMember member = memberService.selectTBranchMemberByMemberId(Long.parseLong(pi.getBusinessKey()));
|
|
TBranchMember member = memberService.selectTBranchMemberByMemberId(Long.parseLong(pi.getBusinessKey()));
|
|
devTask.setObj(member);
|
|
devTask.setObj(member);
|
|
devTask.setApNo(member.getApNo());
|
|
devTask.setApNo(member.getApNo());
|
|
}
|
|
}
|
|
-// 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());
|
|
|
|
-// }
|
|
|
|
list.add(devTask);
|
|
list.add(devTask);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -439,82 +195,8 @@ public class TApproveDangerController extends BaseController {
|
|
SysUser user = sysUserService.selectUserById(member.getUserId());
|
|
SysUser user = sysUserService.selectUserById(member.getUserId());
|
|
devProcess.setApNo(member.getApNo());
|
|
devProcess.setApNo(member.getApNo());
|
|
devProcess.setApName(user.getNickName());
|
|
devProcess.setApName(user.getNickName());
|
|
- devProcess.setMember(member);
|
|
|
|
|
|
+ devProcess.setObj(member);
|
|
}
|
|
}
|
|
-// else if (pi.getProcessDefinitionName().equals("年度检查报告申请")) {
|
|
|
|
-// TApprove approve = tApproveService.selectTApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// SysUser user = sysUserService.selectUserById(approve.getUserId());
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// devProcess.setApName(user.getNickName());
|
|
|
|
-// devProcess.setSpecApprove(approve);
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("月度检查")) {
|
|
|
|
-// TApprove approve = tApproveService.selectTApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// SysUser user = sysUserService.selectUserById(approve.getUserId());
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// devProcess.setApName(user.getNickName());
|
|
|
|
-// devProcess.setSpecApprove(approve);
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("设备修改/删除审核") || pi.getProcessDefinitionName().equals("设备新增/删除审核")) {
|
|
|
|
-// TApproveSpecModify approve = tApproveSpecModifyService.selectTApproveSpecModifyById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// SysUser user = sysUserService.selectUserById(approve.getUserId());
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// devProcess.setApName(user.getNickName());
|
|
|
|
-// devProcess.setApproveSpecModify(approve);
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("专项培训计划审核")) {
|
|
|
|
-// TStApprove approve = tStApproveService.selectTStApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// SysUser user = sysUserService.selectUserById(approve.getUserId());
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// devProcess.setApName(user.getNickName());
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("设备维修审批流程")) {
|
|
|
|
-// TApproveMaintenance approve = tApproveMaintenanceService.selectTApproveMaintenanceById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// SysUser user = sysUserService.selectUserById(approve.getUserId());
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// devProcess.setApName(user.getNickName());
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("设备变更申请")) {
|
|
|
|
-// TIntactApprove approve = tIntactApproveService.selectTIntactApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// SysUser user = sysUserService.selectUserById(approve.getUserId());
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// devProcess.setApName(user.getNickName());
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("可靠性管理申请")) {
|
|
|
|
-// TKekaoApprove approve = tKekaoApproveService.selectTKekaoApproveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// SysUser user = sysUserService.selectUserById(approve.getUserId());
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// devProcess.setApName(user.getNickName());
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("预约开票审批流程")) {
|
|
|
|
-// TApproveReserveInvoice approve = tApproveReserveInvoiceService.selectTApproveReserveInvoiceById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// SysUser user = sysUserService.selectUserById(approve.getUserId());
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// devProcess.setApName(user.getNickName());
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("安全阀离线/切出申请流程")) {
|
|
|
|
-// TApplyOfflinevalve approve = tApplyOfflinevalveService.selectTApplyOfflinevalveById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// SysUser user = sysUserService.selectUserById(Long.valueOf(approve.getCreaterCode()));
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// devProcess.setApName(user.getNickName());
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("组织保护措施状态变更申请流程")) {
|
|
|
|
-// TApplySafetychange approve = tApplySafetychangeService.selectTApplySafetychangeById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// SysUser user = sysUserService.selectUserById(Long.valueOf(approve.getCreaterCode()));
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// devProcess.setApName(user.getNickName());
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// } else if (pi.getProcessDefinitionName().equals("SAI开项申请流程")) {
|
|
|
|
-// TSaiApply approve = tSaiApplyService.selectTSaiApplyById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// SysUser user = sysUserService.selectUserById(Long.valueOf(approve.getCreateBy()));
|
|
|
|
-// devProcess.setApNo(approve.getApNo());
|
|
|
|
-// devProcess.setApName(user.getNickName());
|
|
|
|
-// devProcess.setApproveObject(approve);
|
|
|
|
-// } else {
|
|
|
|
-// TApproveDanger approveDanger = tApproveDangerService.selectTApproveDangerById(Long.parseLong(pi.getBusinessKey()));
|
|
|
|
-// SysUser user = sysUserService.selectUserById(approveDanger.getRecorderId());
|
|
|
|
-// approveDanger.setRecorderName(user.getNickName());
|
|
|
|
-// devProcess.settApprove(approveDanger);
|
|
|
|
-// devProcess.setApNo(approveDanger.getApproveNo());
|
|
|
|
-// devProcess.setApName(user.getNickName());
|
|
|
|
-// }
|
|
|
|
devProcess.setBusinessKey(pi.getBusinessKey());
|
|
devProcess.setBusinessKey(pi.getBusinessKey());
|
|
devProcess.setProcessCreateTime(pi.getStartTime());
|
|
devProcess.setProcessCreateTime(pi.getStartTime());
|
|
devProcess.setProcessId(pi.getId());
|
|
devProcess.setProcessId(pi.getId());
|
|
@@ -532,55 +214,6 @@ public class TApproveDangerController extends BaseController {
|
|
return getDataTable(list,count);
|
|
return getDataTable(list,count);
|
|
}
|
|
}
|
|
|
|
|
|
-// /**
|
|
|
|
-// * 审核处理
|
|
|
|
-// */
|
|
|
|
-// @Log(title = "隐患审核处理", businessType = BusinessType.UPDATE)
|
|
|
|
-// @PutMapping("/handle")
|
|
|
|
-// public AjaxResult handle(@RequestBody DevTask devTask) {
|
|
|
|
-// logger.info("devTask:" + devTask);
|
|
|
|
-// Map<String, Object> param = new HashMap<>();
|
|
|
|
-// param.put("submitType", devTask.getSubmitType());
|
|
|
|
-// ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
|
|
|
|
-// TaskService taskService = processEngine.getTaskService();
|
|
|
|
-// //使用任务服务完成任务(提交任务)
|
|
|
|
-// String taskId = devTask.getTaskId();
|
|
|
|
-// // 使用任务id,获取任务对象,获取流程实例id
|
|
|
|
-// Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
|
|
|
|
-// logger.info("Assignee:" + task.getAssignee());
|
|
|
|
-// //利用任务对象,获取流程实例id
|
|
|
|
-// String processInstancesId = task.getProcessInstanceId();
|
|
|
|
-// System.out.println(processInstancesId);
|
|
|
|
-// //认领任务
|
|
|
|
-// processEngine.getTaskService()//
|
|
|
|
-// .claim(taskId, getUserId().toString());
|
|
|
|
-//// Authentication.setAuthenticatedUserId("cmc"); // 添加批注时候的审核人
|
|
|
|
-// if (devTask.getComment() == null) {
|
|
|
|
-// devTask.setComment("");
|
|
|
|
-// }
|
|
|
|
-// taskService.addComment(taskId, processInstancesId, devTask.getComment());
|
|
|
|
-// //业务监听处理
|
|
|
|
-//// tApproveService.handleApprove(task ,devTask);
|
|
|
|
-// taskService.complete(taskId, param);
|
|
|
|
-//
|
|
|
|
-// //执行人上传措施前后照片
|
|
|
|
-// if (devTask.getTaskName().equals("执行人") && devTask.getSubmitType().equals("1")) {
|
|
|
|
-// TApproveDanger updatepicture = devTask.gettApprove();
|
|
|
|
-// updatepicture.setBeforeUrl(devTask.getBeforeUrl());
|
|
|
|
-// updatepicture.setBeforeFilename(devTask.getBeforeFilename());
|
|
|
|
-// updatepicture.setAfterUrl(devTask.getAfterUrl());
|
|
|
|
-// updatepicture.setAfterFilename(devTask.getAfterFilename());
|
|
|
|
-// tApproveDangerService.updateTApproveDanger(updatepicture);
|
|
|
|
-// }
|
|
|
|
-// //流程结束,approveDanger实体类实际完成时间字段更新
|
|
|
|
-// if (devTask.getTaskName().equals("验证人") && devTask.getSubmitType().equals("1")) {
|
|
|
|
-// TApproveDanger updateEndTime = devTask.gettApprove();
|
|
|
|
-// updateEndTime.setEndtime(new Date());
|
|
|
|
-// tApproveDangerService.updateTApproveDanger(updateEndTime);
|
|
|
|
-// }
|
|
|
|
-// return AjaxResult.success();
|
|
|
|
-// }
|
|
|
|
-
|
|
|
|
/**
|
|
/**
|
|
* 流转列表
|
|
* 流转列表
|
|
*/
|
|
*/
|
|
@@ -632,68 +265,6 @@ public class TApproveDangerController extends BaseController {
|
|
return getDataTable(devTaskList);
|
|
return getDataTable(devTaskList);
|
|
}
|
|
}
|
|
|
|
|
|
-// /**
|
|
|
|
-// * 查询隐患申请列表
|
|
|
|
-// */
|
|
|
|
-// @PreAuthorize("@ss.hasPermi('ehs:approvedanger:list')")
|
|
|
|
-// @GetMapping("/list")
|
|
|
|
-// public TableDataInfo list(TApproveDanger tApproveDanger) {
|
|
|
|
-// startPage();
|
|
|
|
-// List<TApproveDanger> list = tApproveDangerService.selectTApproveDangerList(tApproveDanger);
|
|
|
|
-// return getDataTable(list);
|
|
|
|
-// }
|
|
|
|
-
|
|
|
|
-// /**
|
|
|
|
-// * 导出隐患申请列表
|
|
|
|
-// */
|
|
|
|
-// @PreAuthorize("@ss.hasPermi('ehs:approvedanger:export')")
|
|
|
|
-// @Log(title = "隐患申请", businessType = BusinessType.EXPORT)
|
|
|
|
-// @GetMapping("/export")
|
|
|
|
-// public AjaxResult export(TApproveDanger tApproveDanger) {
|
|
|
|
-// List<TApproveDanger> list = tApproveDangerService.selectTApproveDangerList(tApproveDanger);
|
|
|
|
-// ExcelUtil<TApproveDanger> util = new ExcelUtil<TApproveDanger>(TApproveDanger.class);
|
|
|
|
-// return util.exportExcel(list, "approvedanger");
|
|
|
|
-// }
|
|
|
|
-
|
|
|
|
-// /**
|
|
|
|
-// * 获取隐患申请详细信息
|
|
|
|
-// */
|
|
|
|
-// @PreAuthorize("@ss.hasPermi('ehs:approvedanger:query')")
|
|
|
|
-// @GetMapping(value = "/{id}")
|
|
|
|
-// public AjaxResult getInfo(@PathVariable("id") Long id) {
|
|
|
|
-// return AjaxResult.success(tApproveDangerService.selectTApproveDangerById(id));
|
|
|
|
-// }
|
|
|
|
-
|
|
|
|
-// /**
|
|
|
|
-// * 新增隐患申请
|
|
|
|
-// */
|
|
|
|
-// @PreAuthorize("@ss.hasPermi('ehs:approvedanger:add')")
|
|
|
|
-// @Log(title = "隐患申请", businessType = BusinessType.INSERT)
|
|
|
|
-// @PostMapping
|
|
|
|
-// public AjaxResult add(@RequestBody TApproveDanger tApproveDanger) {
|
|
|
|
-// return toAjax(tApproveDangerService.insertTApproveDanger(tApproveDanger));
|
|
|
|
-// }
|
|
|
|
-//
|
|
|
|
-// /**
|
|
|
|
-// * 修改隐患申请
|
|
|
|
-// */
|
|
|
|
-// @PreAuthorize("@ss.hasPermi('ehs:approvedanger:edit')")
|
|
|
|
-// @Log(title = "隐患申请", businessType = BusinessType.UPDATE)
|
|
|
|
-// @PutMapping
|
|
|
|
-// public AjaxResult edit(@RequestBody TApproveDanger tApproveDanger) {
|
|
|
|
-// return toAjax(tApproveDangerService.updateTApproveDanger(tApproveDanger));
|
|
|
|
-// }
|
|
|
|
-//
|
|
|
|
-// /**
|
|
|
|
-// * 删除隐患申请
|
|
|
|
-// */
|
|
|
|
-// @PreAuthorize("@ss.hasPermi('ehs:approvedanger:remove')")
|
|
|
|
-// @Log(title = "隐患申请", businessType = BusinessType.DELETE)
|
|
|
|
-// @DeleteMapping("/{ids}")
|
|
|
|
-// public AjaxResult remove(@PathVariable Long[] ids) {
|
|
|
|
-// return toAjax(tApproveDangerService.deleteTApproveDangerByIds(ids));
|
|
|
|
-// }
|
|
|
|
-//
|
|
|
|
@GetMapping("/processImg/{processId}")
|
|
@GetMapping("/processImg/{processId}")
|
|
public void currentProcessInstanceImage(@PathVariable("processId") String processId, HttpServletResponse response) throws IOException {
|
|
public void currentProcessInstanceImage(@PathVariable("processId") String processId, HttpServletResponse response) throws IOException {
|
|
InputStream inputStream = currentProcessInstanceImage(processId);
|
|
InputStream inputStream = currentProcessInstanceImage(processId);
|
|
@@ -760,9 +331,6 @@ public class TApproveDangerController extends BaseController {
|
|
return inputStream;
|
|
return inputStream;
|
|
}
|
|
}
|
|
|
|
|
|
-
|
|
|
|
-
|
|
|
|
-
|
|
|
|
/**
|
|
/**
|
|
* 获取已经流转的线
|
|
* 获取已经流转的线
|
|
*
|
|
*
|