Merge branch 'develop' into FOTON

This commit is contained in:
super_liu
2021-12-15 21:10:40 +08:00
8 changed files with 82 additions and 49 deletions
@@ -15,7 +15,9 @@ import org.activiti.engine.ActivitiException;
import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener; import org.activiti.engine.delegate.TaskListener;
import java.text.SimpleDateFormat;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date;
import java.util.List; import java.util.List;
/** /**
@@ -65,9 +67,15 @@ public class DirectorChooseAfter implements TaskListener {
}else { }else {
delegateTask.setVariable("memberList",nextUserList); delegateTask.setVariable("memberList",nextUserList);
} }
delegateTask.setVariable("passFlag","0");
delegateTask.setVariable("memberCount",delegateTask.getVariable("memberList",List.class).size()); delegateTask.setVariable("memberCount",delegateTask.getVariable("memberList",List.class).size());
} }
if (delegateTask.getVariable("memberList",List.class).size()==0){
delegateTask.setVariable("passFlag","1");
prcName = prcName + "流程结束";
}
// 存储当前节点意见 // 存储当前节点意见
if (null != object.getString("commentText")) { if (null != object.getString("commentText")) {
@@ -93,7 +101,11 @@ public class DirectorChooseAfter implements TaskListener {
QueryWrapper queryWrapper2 = new QueryWrapper(); QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId()); queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
if (one1 != null) { if (one1 != null) {
if ("1".equals(delegateTask.getVariable("passFlag"))){
one1.setOverTime(OVERTIME);
}
one1.setPrcType("21"); one1.setPrcType("21");
one1.setPrcName(prcName); one1.setPrcName(prcName);
one1.setCreatUser(user); one1.setCreatUser(user);
@@ -14,7 +14,9 @@ import org.activiti.engine.ActivitiException;
import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener; import org.activiti.engine.delegate.TaskListener;
import java.text.SimpleDateFormat;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date;
import java.util.List; import java.util.List;
/** /**
@@ -45,7 +47,7 @@ public class DirectorChooseAfter implements TaskListener {
} }
//全员不通过,检测条件 directorCount //全员不通过,检测条件 directorCount
Integer allCount = delegateTask.getVariable("directorList",List.class).size();; Integer allCount = delegateTask.getVariable("directorList",List.class).size();
Integer count = 0; Integer count = 0;
if(null == delegateTask.getVariable("directorCount")){ if(null == delegateTask.getVariable("directorCount")){
delegateTask.setVariable("directorCount", count); delegateTask.setVariable("directorCount", count);
@@ -63,9 +65,13 @@ public class DirectorChooseAfter implements TaskListener {
}else { }else {
delegateTask.setVariable("memberList",nextUserList); delegateTask.setVariable("memberList",nextUserList);
} }
delegateTask.setVariable("passFlag","0");
delegateTask.setVariable("memberCount",delegateTask.getVariable("memberList",List.class).size()); delegateTask.setVariable("memberCount",delegateTask.getVariable("memberList",List.class).size());
} }
if (delegateTask.getVariable("memberList",List.class).size()==0){
delegateTask.setVariable("passFlag","1");
prcName = prcName + "流程结束";
}
// 存储当前节点意见 // 存储当前节点意见
if (null != object.getString("commentText")) { if (null != object.getString("commentText")) {
@@ -88,11 +94,14 @@ public class DirectorChooseAfter implements TaskListener {
String standName = object.getString("listName"); String standName = object.getString("listName");
delegateTask.setVariable("listName", standName); delegateTask.setVariable("listName", standName);
String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
QueryWrapper queryWrapper2 = new QueryWrapper(); QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId()); queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
if (one1 != null) { if (one1 != null) {
if ("1".equals(delegateTask.getVariable("passFlag"))){
one1.setOverTime(OVERTIME);
}
one1.setPrcType("20"); one1.setPrcType("20");
one1.setPrcName(prcName); one1.setPrcName(prcName);
one1.setCreatUser(user); one1.setCreatUser(user);
@@ -43,6 +43,19 @@ public class DeptApplayAfter implements TaskListener{
delegateTask.setVariable("objectJson", object); delegateTask.setVariable("objectJson", object);
List<String> nextUserList = new ArrayList(); List<String> nextUserList = new ArrayList();
String standName = "";
if (null == object.getString("standInData")){
standName = "未知";
}else {
if(object.getString("standInData").equals("INLAND")){
standName = "国内";
}else {
standName = "海外";
}
}
String prcName = standName+"-标准解读流程";
//部长进行审批(1:通过) //部长进行审批(1:通过)
if (object.getString("gcApplyFlag").equals("1")) { if (object.getString("gcApplyFlag").equals("1")) {
delegateTask.setVariable("bzFlag", 1); delegateTask.setVariable("bzFlag", 1);
@@ -108,24 +121,16 @@ public class DeptApplayAfter implements TaskListener{
lawsUserInfoService.sarStandItemsSaveBatch(sarStandItems); lawsUserInfoService.sarStandItemsSaveBatch(sarStandItems);
lawsUserInfoService.SarInterpretationNationalStandardSaveBatch(standards); lawsUserInfoService.SarInterpretationNationalStandardSaveBatch(standards);
prcName=prcName+"-流程结束";
} else { } else {
delegateTask.setVariable("bzFlag", 2); delegateTask.setVariable("bzFlag", 2);
prcName=prcName+"-填写解读分析";
} }
//截止时间 流程描述 创建人 //截止时间 流程描述 创建人
String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
String user = object.getString("applyUserId"); String user = object.getString("applyUserId");
String username = object.getString("applyUserIdName"); String username = object.getString("applyUserIdName");
String standName = "";
if (null == object.getString("standInData")){
standName = "未知";
}else {
if(object.getString("standInData").equals("INLAND")){
standName = "国内";
}else {
standName = "海外";
}
}
String prcName = standName+"-标准解读流程";
QueryWrapper queryWrapper2 = new QueryWrapper(); QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
@@ -67,7 +67,7 @@ public class DeptZrAfter implements TaskListener{
standName = "海外"; standName = "海外";
} }
} }
String prcName = standName+"-标准解读流程"; String prcName = standName+"-标准解读流程-填写解读分析";
QueryWrapper queryWrapper2 = new QueryWrapper(); QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
@@ -36,22 +36,7 @@ public class EngineerApplayAfter implements TaskListener{
delegateTask.setVariable("objectJson", object); delegateTask.setVariable("objectJson", object);
List<String> nextUserList = new ArrayList(); List<String> nextUserList = new ArrayList();
//工程师是否要进行审核
if (object.getString("zrApplyFlag").equals("1")) {
delegateTask.setVariable("gcFlag", 1);
if (StringUtils.isNotBlank(object.getString("deptUserId"))) {
delegateTask.setVariable("deptUserId", object.getString("deptUserId"));
nextUserList.add(object.getString("deptUserId"));
}
} else {
delegateTask.setVariable("gcFlag", 2);
JSONObject object1=delegateTask.getVariable("zxUserId",JSONObject.class);
nextUserList.add(object1.getString("id"));
}
//截止时间 流程描述 创建人
String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
String user = object.getString("applyUserId");
String username = object.getString("applyUserIdName");
String standName = ""; String standName = "";
if (null == object.getString("standInData")){ if (null == object.getString("standInData")){
standName = "未知"; standName = "未知";
@@ -63,6 +48,26 @@ public class EngineerApplayAfter implements TaskListener{
} }
} }
String prcName = standName + "-标准解读流程"; String prcName = standName + "-标准解读流程";
//工程师是否要进行审核
if (object.getString("zrApplyFlag").equals("1")) {
delegateTask.setVariable("gcFlag", 1);
prcName=prcName+"-部长审批";
if (StringUtils.isNotBlank(object.getString("deptUserId"))) {
delegateTask.setVariable("deptUserId", object.getString("deptUserId"));
nextUserList.add(object.getString("deptUserId"));
}
} else {
prcName=prcName+"-填写解读分析";
delegateTask.setVariable("gcFlag", 2);
JSONObject object1=delegateTask.getVariable("zxUserId",JSONObject.class);
nextUserList.add(object1.getString("id"));
}
//截止时间 流程描述 创建人
String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
String user = object.getString("applyUserId");
String username = object.getString("applyUserIdName");
QueryWrapper queryWrapper2 = new QueryWrapper(); QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId()); queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
@@ -51,7 +51,7 @@ public class ExpainAfter implements TaskListener{
standName = "海外"; standName = "海外";
} }
} }
String prcName = standName+"-标准解读流程"; String prcName = standName+"-标准解读流程-责任人审核";
QueryWrapper queryWrapper2 = new QueryWrapper(); QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
@@ -74,7 +74,7 @@ public class ResolveAfter implements TaskListener{
standName = "海外"; standName = "海外";
} }
} }
String prcName = standName+"-标准解读流程"; String prcName = standName+"-标准解读流程-选择执行人";
QueryWrapper queryWrapper2 = new QueryWrapper(); QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
@@ -36,22 +36,6 @@ public class ZrApplayAfter implements TaskListener{
delegateTask.setVariable("objectJson",object); delegateTask.setVariable("objectJson",object);
List<String> nextUserList = new ArrayList(); List<String> nextUserList = new ArrayList();
//责任人是否要进行审核
if(object.getString("resolveFlag").equals("1")){
delegateTask.setVariable("zrFlag",1);
if(StringUtils.isNotBlank(object.getString("applyUserId"))){
delegateTask.setVariable("engineerUserId",object.getString("applyUserId"));
nextUserList.add(object.getString("applyUserId"));
}
}else {
delegateTask.setVariable("zrFlag",2);
JSONObject object1=JSONObject.parseObject(String.valueOf(delegateTask.getVariable("zxUserId")));
nextUserList.add(String.valueOf(object1.getString("id")));
}
//截止时间 流程描述 创建人
String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
String user = object.getString("applyUserId");
String username = object.getString("applyUserIdName");
String standName = ""; String standName = "";
if (null == object.getString("standInData")){ if (null == object.getString("standInData")){
standName = "未知"; standName = "未知";
@@ -63,6 +47,24 @@ public class ZrApplayAfter implements TaskListener{
} }
} }
String prcName = standName+"-标准解读流程"; String prcName = standName+"-标准解读流程";
//责任人是否要进行审核
if(object.getString("resolveFlag").equals("1")){
delegateTask.setVariable("zrFlag",1);
prcName=prcName+"-工程师审核";
if(StringUtils.isNotBlank(object.getString("applyUserId"))){
delegateTask.setVariable("engineerUserId",object.getString("applyUserId"));
nextUserList.add(object.getString("applyUserId"));
}
}else {
prcName=prcName+"-填写解读分析";
delegateTask.setVariable("zrFlag",2);
JSONObject object1=JSONObject.parseObject(String.valueOf(delegateTask.getVariable("zxUserId")));
nextUserList.add(String.valueOf(object1.getString("id")));
}
//截止时间 流程描述 创建人
String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
String user = object.getString("applyUserId");
String username = object.getString("applyUserIdName");
QueryWrapper queryWrapper2 = new QueryWrapper(); QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);