|
@@ -1,7 +1,6 @@
|
|
package com.ruoyi.project.pssr.controller;
|
|
package com.ruoyi.project.pssr.controller;
|
|
|
|
|
|
import com.ruoyi.common.utils.DateUtils;
|
|
import com.ruoyi.common.utils.DateUtils;
|
|
-import com.ruoyi.common.utils.StringUtils;
|
|
|
|
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;
|
|
import com.ruoyi.framework.aspectj.lang.enums.BusinessType;
|
|
import com.ruoyi.framework.aspectj.lang.enums.BusinessType;
|
|
@@ -303,13 +302,11 @@ public class TPssrApproveController extends BaseController {
|
|
|
|
|
|
|
|
|
|
TStaffmgr tStaffmgr = new TStaffmgr();
|
|
TStaffmgr tStaffmgr = new TStaffmgr();
|
|
- tStaffmgr.setActualposts("24,26");
|
|
|
|
- StringBuilder executor = new StringBuilder();
|
|
|
|
|
|
+ tStaffmgr.setActualposts("24");
|
|
|
|
+ tStaffmgr.setDeptId(103L);
|
|
|
|
+ String executor = "";
|
|
for (SysUser user : userService.selectUserPost(tStaffmgr)) {
|
|
for (SysUser user : userService.selectUserPost(tStaffmgr)) {
|
|
- executor.append(user.getUserId().toString()).append(",");
|
|
|
|
- }
|
|
|
|
- if (StringUtils.isNotEmpty(executor.toString())) {
|
|
|
|
- executor = new StringBuilder(executor.substring(0, executor.length() - 1));
|
|
|
|
|
|
+ executor = user.getUserId().toString();
|
|
}
|
|
}
|
|
|
|
|
|
// 开始申请流程
|
|
// 开始申请流程
|
|
@@ -408,7 +405,11 @@ public class TPssrApproveController extends BaseController {
|
|
} else {
|
|
} else {
|
|
// 已存在流程时,删除旧流程,重新发起
|
|
// 已存在流程时,删除旧流程,重新发起
|
|
TPssrApprove approve = tPssrApproves.get(0);
|
|
TPssrApprove approve = tPssrApproves.get(0);
|
|
- runtimeService.deleteProcessInstance(approve.getProcessId(), "pssr1confirm");
|
|
|
|
|
|
+ try {
|
|
|
|
+ runtimeService.deleteProcessInstance(approve.getProcessId(), "pssr1confirm");
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ logger.info("无运行时流程");
|
|
|
|
+ }
|
|
historyService.deleteHistoricProcessInstance(approve.getProcessId());
|
|
historyService.deleteHistoricProcessInstance(approve.getProcessId());
|
|
|
|
|
|
// 开始申请流程
|
|
// 开始申请流程
|
|
@@ -488,7 +489,11 @@ public class TPssrApproveController extends BaseController {
|
|
} else {
|
|
} else {
|
|
// 已存在流程时,删除旧流程,重新发起
|
|
// 已存在流程时,删除旧流程,重新发起
|
|
TPssrApprove approve = tPssrApproves.get(0);
|
|
TPssrApprove approve = tPssrApproves.get(0);
|
|
- runtimeService.deleteProcessInstance(approve.getProcessId(), "pssr2confirm");
|
|
|
|
|
|
+ try {
|
|
|
|
+ runtimeService.deleteProcessInstance(approve.getProcessId(), "pssr2confirm");
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ logger.info("无运行时流程");
|
|
|
|
+ }
|
|
historyService.deleteHistoricProcessInstance(approve.getProcessId());
|
|
historyService.deleteHistoricProcessInstance(approve.getProcessId());
|
|
|
|
|
|
tPssrBlind = new TPssrBlind();
|
|
tPssrBlind = new TPssrBlind();
|
|
@@ -534,7 +539,6 @@ public class TPssrApproveController extends BaseController {
|
|
TPssrLock tPssrLock = new TPssrLock();
|
|
TPssrLock tPssrLock = new TPssrLock();
|
|
tPssrLock.setApproveStatus(0L);
|
|
tPssrLock.setApproveStatus(0L);
|
|
tPssrLock.setSubId(sub.getId());
|
|
tPssrLock.setSubId(sub.getId());
|
|
- Set<String> unlockers = new HashSet<>();
|
|
|
|
Set<String> lockeders = new HashSet<>();
|
|
Set<String> lockeders = new HashSet<>();
|
|
Set<String> confirmers = new HashSet<>();
|
|
Set<String> confirmers = new HashSet<>();
|
|
for (TPssrLock item : tPssrLockService.selectTPssrLockList(tPssrLock)) {
|
|
for (TPssrLock item : tPssrLockService.selectTPssrLockList(tPssrLock)) {
|
|
@@ -543,13 +547,10 @@ public class TPssrApproveController extends BaseController {
|
|
item.setUpdaterCode(userId);
|
|
item.setUpdaterCode(userId);
|
|
tPssrLockService.updateTPssrLock(item);
|
|
tPssrLockService.updateTPssrLock(item);
|
|
|
|
|
|
- // 拆锁人员
|
|
|
|
- unlockers.add(item.getUnlocker());
|
|
|
|
-
|
|
|
|
- // 上锁人员
|
|
|
|
|
|
+ // 确认人1
|
|
lockeders.add(item.getLockeder());
|
|
lockeders.add(item.getLockeder());
|
|
|
|
|
|
- // 确认人
|
|
|
|
|
|
+ // 确认人2
|
|
confirmers.add(item.getConfirm());
|
|
confirmers.add(item.getConfirm());
|
|
}
|
|
}
|
|
|
|
|
|
@@ -573,19 +574,18 @@ public class TPssrApproveController extends BaseController {
|
|
Authentication.setAuthenticatedUserId(userId);//设置当前申请人
|
|
Authentication.setAuthenticatedUserId(userId);//设置当前申请人
|
|
Map<String, Object> variables = new HashMap<>();
|
|
Map<String, Object> variables = new HashMap<>();
|
|
variables.put("applyUser", userId);
|
|
variables.put("applyUser", userId);
|
|
- variables.put("confirmUsers1", new ArrayList<>(unlockers));
|
|
|
|
- variables.put("confirmUsers2", new ArrayList<>(lockeders));
|
|
|
|
- variables.put("confirmUsers3", new ArrayList<>(confirmers));
|
|
|
|
|
|
+ variables.put("confirmUsers1", new ArrayList<>(lockeders));
|
|
|
|
+ variables.put("confirmUsers2", new ArrayList<>(confirmers));
|
|
variables.put("chargePerson", sub.getConfirm());
|
|
variables.put("chargePerson", sub.getConfirm());
|
|
//采用key来启动流程定义并设置流程变量,返回流程实例
|
|
//采用key来启动流程定义并设置流程变量,返回流程实例
|
|
- ProcessInstance pi = runtimeService.startProcessInstanceByKey("pssr3confirm", String.valueOf(businessKey), variables);
|
|
|
|
|
|
+ ProcessInstance pi = runtimeService.startProcessInstanceByKey("pssr2confirm", String.valueOf(businessKey), variables);
|
|
approve.setProcessId(pi.getProcessInstanceId());
|
|
approve.setProcessId(pi.getProcessInstanceId());
|
|
tPssrApproveService.updateTPssrApprove(approve);
|
|
tPssrApproveService.updateTPssrApprove(approve);
|
|
} else {
|
|
} else {
|
|
// 已存在流程时,删除旧流程,重新发起
|
|
// 已存在流程时,删除旧流程,重新发起
|
|
TPssrApprove approve = tPssrApproves.get(0);
|
|
TPssrApprove approve = tPssrApproves.get(0);
|
|
try {
|
|
try {
|
|
- runtimeService.deleteProcessInstance(approve.getProcessId(), "pssr3confirm");
|
|
|
|
|
|
+ runtimeService.deleteProcessInstance(approve.getProcessId(), "pssr2confirm");
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
logger.info("无运行时流程");
|
|
logger.info("无运行时流程");
|
|
}
|
|
}
|
|
@@ -596,14 +596,10 @@ public class TPssrApproveController extends BaseController {
|
|
tPssrLock.setSubId(sub.getId());
|
|
tPssrLock.setSubId(sub.getId());
|
|
for (TPssrLock item : tPssrLockService.selectTPssrLockList(tPssrLock)) {
|
|
for (TPssrLock item : tPssrLockService.selectTPssrLockList(tPssrLock)) {
|
|
|
|
|
|
-
|
|
|
|
- // 拆锁人员
|
|
|
|
- unlockers.add(item.getUnlocker());
|
|
|
|
-
|
|
|
|
- // 上锁人员
|
|
|
|
|
|
+ // 确认人1
|
|
lockeders.add(item.getLockeder());
|
|
lockeders.add(item.getLockeder());
|
|
|
|
|
|
- // 确认人
|
|
|
|
|
|
+ // 确认人2
|
|
confirmers.add(item.getConfirm());
|
|
confirmers.add(item.getConfirm());
|
|
}
|
|
}
|
|
|
|
|
|
@@ -613,12 +609,11 @@ public class TPssrApproveController extends BaseController {
|
|
Authentication.setAuthenticatedUserId(userId);//设置当前申请人
|
|
Authentication.setAuthenticatedUserId(userId);//设置当前申请人
|
|
Map<String, Object> variables = new HashMap<>();
|
|
Map<String, Object> variables = new HashMap<>();
|
|
variables.put("applyUser", userId);
|
|
variables.put("applyUser", userId);
|
|
- variables.put("confirmUsers1", new ArrayList<>(unlockers));
|
|
|
|
- variables.put("confirmUsers2", new ArrayList<>(lockeders));
|
|
|
|
- variables.put("confirmUsers3", new ArrayList<>(confirmers));
|
|
|
|
|
|
+ variables.put("confirmUsers1", new ArrayList<>(lockeders));
|
|
|
|
+ variables.put("confirmUsers2", new ArrayList<>(confirmers));
|
|
variables.put("chargePerson", sub.getConfirm());
|
|
variables.put("chargePerson", sub.getConfirm());
|
|
//采用key来启动流程定义并设置流程变量,返回流程实例
|
|
//采用key来启动流程定义并设置流程变量,返回流程实例
|
|
- ProcessInstance pi = runtimeService.startProcessInstanceByKey("pssr3confirm", String.valueOf(businessKey), variables);
|
|
|
|
|
|
+ ProcessInstance pi = runtimeService.startProcessInstanceByKey("pssr2confirm", String.valueOf(businessKey), variables);
|
|
approve.setProcessId(pi.getProcessInstanceId());
|
|
approve.setProcessId(pi.getProcessInstanceId());
|
|
tPssrApproveService.updateTPssrApprove(approve);
|
|
tPssrApproveService.updateTPssrApprove(approve);
|
|
}
|
|
}
|
|
@@ -679,7 +674,11 @@ public class TPssrApproveController extends BaseController {
|
|
} else {
|
|
} else {
|
|
// 已存在流程时,删除旧流程,重新发起
|
|
// 已存在流程时,删除旧流程,重新发起
|
|
TPssrApprove approve = tPssrApproves.get(0);
|
|
TPssrApprove approve = tPssrApproves.get(0);
|
|
- runtimeService.deleteProcessInstance(approve.getProcessId(), "pssr2confirm");
|
|
|
|
|
|
+ try {
|
|
|
|
+ runtimeService.deleteProcessInstance(approve.getProcessId(), "pssr2confirm");
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ logger.info("无运行时流程");
|
|
|
|
+ }
|
|
historyService.deleteHistoricProcessInstance(approve.getProcessId());
|
|
historyService.deleteHistoricProcessInstance(approve.getProcessId());
|
|
|
|
|
|
tPssrPipe = new TPssrPipe();
|
|
tPssrPipe = new TPssrPipe();
|