FT/foton-wkflow-rest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

项目维度和标准维度评估正向

Browse Source
This commit is contained in:
yuezhihang
2021-12-01 17:58:17 +08:00
parent df6b9b7df7
commit 0c08766db5
19 changed files with 246 additions and 68 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/SarStandUnqualified.java
+3
View File
@@ -28,6 +28,9 @@ public class SarStandUnqualified {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "产品线编号")
private String productId;
@ApiModelProperty(value = "标准ID")
private String standId;
src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/SarStandardComplianceProductAssess.java
+12
View File
@@ -117,5 +117,17 @@ public class SarStandardComplianceProductAssess {
@TableField("type")
private String type;
@ApiModelProperty(value = "评估时间")
@TableField("evaluation_time")
private String evaluationTime;
@ApiModelProperty(value = "评估人")
@TableField("evaluation_people")
private String evaluationPeople;
@ApiModelProperty(value = "评估人")
@TableField("evaluation_people_name")
private String evaluationPeopleName;
}
src/main/java/com/ydw/bat/wkflow/listener/ProjectComplianceAssessment/PCAComplianceAssessmentAfter.java
+28 -2
View File
@@ -19,6 +19,7 @@ import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.UUID;
public class PCAComplianceAssessmentAfter implements TaskListener {
@@ -41,8 +42,33 @@ public class PCAComplianceAssessmentAfter implements TaskListener {
List<String> nextUserList=new ArrayList<>();
JSONArray jsonArray=JSONArray.parseArray(object.getString("dataList"));
JSONObject jsonObject=JSONObject.parseObject(jsonArray.get(0).toString());
nextUserList.add(jsonObject.getString("liablePeopleId"));
delegateTask.setVariable("ffUserId",jsonObject.getString("liablePeopleId"));
//新去除数据之后的结果
JSONArray newRes=new JSONArray();
for (Object json:jsonArray) {
JSONObject jsonObject1=JSONObject.parseObject(json.toString());
JSONArray remove=new JSONArray();
for (Object os:jsonObject1.getJSONArray("children")) {
JSONObject jsonObject2=JSONObject.parseObject(os.toString());
if ("".equals(jsonObject2.get("complianceReasons"))&&"".equals(jsonObject2.get("noCompliance"))
&& "".equals(jsonObject2.get("countermeasures")) && null==jsonObject2.get("completionTime")){
remove.add(jsonObject2);
}
}
jsonObject1.getJSONArray("children").removeAll(remove);
if (jsonObject1.getJSONArray("children").size()==0 && "".equals(jsonObject1.get("complianceReasons"))&&"".equals(jsonObject1.get("noCompliance"))
&& "".equals(jsonObject1.get("countermeasures")) && null==jsonObject1.get("completionTime")){
}else {
newRes.add(jsonObject1);
}
}
String uuid= String.valueOf(UUID.randomUUID());
delegateTask.setVariable(uuid,object.getString("dataList"));
object.put("dataList",newRes.toJSONString());
object.put("key",uuid);
JSONObject res=JSONObject.parseObject(newRes.get(0).toString());
nextUserList.add(res.getString("liablePeopleId"));
delegateTask.setVariable("ffUserId",res.getString("liablePeopleId"));
//截止时间 流程描述 创建人
String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
String user = delegateTask.getVariable("prcCreateUser",String.class);
src/main/java/com/ydw/bat/wkflow/listener/ProjectComplianceAssessment/PCAbafgManagerApproveAfter.java
+4
View File
@@ -4,6 +4,7 @@ package com.ydw.bat.wkflow.listener.ProjectComplianceAssessment;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.tmsps.fk.common.util.JsonUtil;
import com.ydw.bat.wkflow.business_main.datas.dto.DataList;
import com.ydw.bat.wkflow.business_main.datas.dto.PCA.PCAtotal;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessName;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
@@ -53,6 +54,7 @@ public class PCAbafgManagerApproveAfter implements TaskListener {
delegateTask.setVariable("pass", "1");
}
} else {
object.put("dataList",delegateTask.getVariable(object.getString("key")));
nextUserList.add(String.valueOf(delegateTask.getVariable("workPeople")));
delegateTask.setVariable("bzFlag", "2");
}
@@ -101,8 +103,10 @@ public class PCAbafgManagerApproveAfter implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskId("996");
busProcessNewNext.setTaskInfo(delegateTask.getName());
busProcessNewNext.setUserId(userId);
busProcessNewNext.setPrcName(prcName);
busBean.save(busProcessNewNext);
}
}
src/main/java/com/ydw/bat/wkflow/listener/ProjectComplianceAssessment/PCAdlApproveAfter.java
+11 -3
View File
@@ -55,7 +55,7 @@ public class PCAdlApproveAfter implements TaskListener {
List<SarStandUnqualified> standUnqualifieds = new ArrayList<>();
//评估结果存储集合
List<SarStandardComplianceProductAssess> sarStandardComplianceProductAssesses = new ArrayList<>();
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
res.getDataList().forEach(pcAdataList -> {
//标准一级别
if (null != pcAdataList.getNoCompliance()) {
@@ -73,6 +73,7 @@ public class PCAdlApproveAfter implements TaskListener {
sarStandUnqualified.setReason(pcAdataList.getNoCompliance());
sarStandUnqualified.setPlanCloseTime(pcAdataList.getCompletionTime());
sarStandUnqualified.setProductLine(delegateTask.getVariable("productLines",String.class));
sarStandUnqualified.setProductId(delegateTask.getVariable("stId",String.class));
standUnqualifieds.add(sarStandUnqualified);
}
@@ -91,6 +92,7 @@ public class PCAdlApproveAfter implements TaskListener {
sarStandUnqualified.setReason(pcAdataList.getZcNoCompliance());
sarStandUnqualified.setProductType("product");
sarStandUnqualified.setPlanCloseTime(pcAdataList.getZcCompletionTime());
sarStandUnqualified.setProductId(delegateTask.getVariable("stId",String.class));
standUnqualifieds.add(sarStandUnqualified);
}
@@ -119,8 +121,9 @@ public class PCAdlApproveAfter implements TaskListener {
sarStandard.setResearchImplementationTime(pcAdataList.getXcxssrqgj());
sarStandard.setClauseName(pcAdataList.getItemsName());
sarStandard.setStandardItem(pcAdataList.getItemNum());
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
sarStandard.setEvaluationTime(simpleDateFormat.format(new Date()));
sarStandard.setEvaluationPeopleName(pcAdataList.getWorkPeople());
sarStandard.setEvaluationPeople(pcAdataList.getWorkPeople());
sarStandard.setResearchImplementationTime(pcAdataList.getXcxssrqgj());
// simpleDateFormat.parse(String.valueOf(delegateTask.getVariable("XCXSSRQ")))
sarStandard.setProductionImplementationTime(pcAdataList.getZccssrqgj());
@@ -145,6 +148,7 @@ public class PCAdlApproveAfter implements TaskListener {
sarStandUnqualified.setProductType("research");
sarStandUnqualified.setReason(pcAchildren.getNoCompliance());
sarStandUnqualified.setPlanCloseTime(pcAchildren.getCompletionTime());
sarStandUnqualified.setProductId(delegateTask.getVariable("stId",String.class));
standUnqualifieds.add(sarStandUnqualified);
}
@@ -166,6 +170,7 @@ public class PCAdlApproveAfter implements TaskListener {
sarStandUnqualified.setReason(pcAchildren.getZcNoCompliance());
sarStandUnqualified.setProductType("product");
sarStandUnqualified.setPlanCloseTime(pcAchildren.getZcCompletionTime());
sarStandUnqualified.setProductId(delegateTask.getVariable("stId",String.class));
standUnqualifieds.add(sarStandUnqualified);
}
//合估评规 结果！
@@ -191,6 +196,9 @@ public class PCAdlApproveAfter implements TaskListener {
sarStandardChild.setProductionImplementationTime(pcAdataList.getZccssrqgj());
sarStandardChild.setClauseName(pcAchildren.getItemsName());
sarStandardChild.setStandardItem(pcAchildren.getItemsNum());
sarStandardChild.setEvaluationTime(simpleDateFormat.format(new Date()));
sarStandardChild.setEvaluationPeopleName(pcAchildren.getWorkPeople());
sarStandardChild.setEvaluationPeople(pcAchildren.getWorkPeople());
sarStandardComplianceProductAssesses.add(sarStandardChild);
}
});
src/main/java/com/ydw/bat/wkflow/listener/ProjectComplianceAssessment/PCAffLiableApproveAfter.java
+3
View File
@@ -1,8 +1,10 @@
package com.ydw.bat.wkflow.listener.ProjectComplianceAssessment;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_main.datas.dto.DataList;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessName;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
import com.ydw.bat.wkflow.business_main.datas.entity.Datas;
@@ -42,6 +44,7 @@ public class PCAffLiableApproveAfter implements TaskListener {
delegateTask.setVariable("JGManager", delegateTask.getVariable("JGUserId"));
delegateTask.setVariable("ffFlag", "1");
}else {
object.put("dataList",delegateTask.getVariable(object.getString("key")));
nextUserList.add(String.valueOf(delegateTask.getVariable("workPeople")));
delegateTask.setVariable("ffFlag", "2");
}
src/main/java/com/ydw/bat/wkflow/listener/ProjectComplianceAssessment/PCAffLiableDistributeAfter.java
+99 -40
View File
@@ -43,62 +43,120 @@ public class PCAffLiableDistributeAfter implements TaskListener {
Datas datas = datasService.getOne(queryWrapper);
JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
delegateTask.setVariable("objectJson", object);
PCAtotal pcAtotal=JSONObject.parseObject(datas.getFormValsJson(),PCAtotal.class);
PCAtotal pcAtotal = JSONObject.parseObject(datas.getFormValsJson(), PCAtotal.class);
//后续节点所需要的数据
List<String> nextUserList=new ArrayList<>();
List<String> nextUserList = new ArrayList<>();
//猜测写代码
//准备标准数据
Map<String,PCAdataList> mapData=new HashMap<>();
Map<String, PCAtotal> map = new HashMap<>();
Map<String, PCAdataList> mapData = new HashMap<>();
pcAtotal.getDataList().forEach(pcAdataList -> {
List<PCAchildren> pcAchildren=new ArrayList<>();
List<PCAchildren> pcAchildren = new ArrayList<>();
pcAdataList.setChildren(pcAchildren);
mapData.put(pcAdataList.getStandId(),pcAdataList);
mapData.put(pcAdataList.getStandId(), pcAdataList);
});
Map<String, PCAtotal> map=new HashMap<>();
//获取被分发的条款
//获取被分发的条款----人员多选修改
pcAtotal.getChildren().forEach(o -> {
if (null!=map.get(o.getWorkPeopleId())){
map.get(o.getWorkPeopleId()).getChildren().add(o);
int flag=0;
for (PCAdataList ps: map.get(o.getWorkPeopleId()).getDataList()) {
if (ps.getStandId().equals(mapData.get(o.getKey()).getStandId())){
ps.getChildren().add(o);
flag++;
if (null!=o && null != o.getWorkPeopleId()) {
List<String> ids = new ArrayList(Arrays.asList(o.getWorkPeopleId().split(",")));
List<String> names = new ArrayList(Arrays.asList(o.getWorkPeople().split(",")));
int i = 0;
for (String id : ids) {
//重组数据
PCAchildren middle = new PCAchildren();
BeanUtils.copyProperties(o, middle);
middle.setWorkPeopleId(id);
middle.setWorkPeople(names.get(i));
if (null != map.get(id)) {
map.get(id).getChildren().add(middle);
int flag = 0;
for (PCAdataList ps : map.get(id).getDataList()) {
if (ps.getStandId().equals(mapData.get(middle.getKey()).getStandId())) {
ps.getChildren().add(middle);
flag++;
}
}
if (flag == 0) {
map.get(id).getDataList().add(mapData.get(middle.getKey()));
mapData.get(middle.getKey()).getChildren().add(middle);
}
} else {
PCAtotal pcs = new PCAtotal();
BeanUtils.copyProperties(pcAtotal, pcs);
//建立空的子 为了后面遍历
List<PCAchildren> list = new ArrayList<>();
List<PCAchildren> list1 = new ArrayList<>();
list.add(middle);
list1.add(middle);
pcs.setChildren(list);
List<PCAdataList> list2 = new ArrayList<>();
PCAdataList adataLists = new PCAdataList();
BeanUtils.copyProperties(mapData.get(middle.getKey()), adataLists);
adataLists.setWorkPeopleId(id);
adataLists.setWorkPeople(names.get(i));
adataLists.setChildren(list1);
list2.add(adataLists);
pcs.setDataList(list2);
map.put(id, pcs);
}
i++;
}
if (flag==0){
map.get(o.getWorkPeopleId()).getDataList().add(mapData.get(o.getKey()));
mapData.get(o.getKey()).getChildren().add(o);
}
});
mapData.keySet().forEach(s -> {
if (null != mapData.get(s).getWorkPeopleId()) {
List<String> peos = new ArrayList<>(Arrays.asList(mapData.get(s).getWorkPeopleId().split(",")));
List<String> names = new ArrayList<>(Arrays.asList(mapData.get(s).getWorkPeople().split(",")));
int count=0;
for (String i : peos) {
if (null==map.get(i)){
PCAtotal pcs = new PCAtotal();
BeanUtils.copyProperties(pcAtotal, pcs);
//建立空的子 为了后面遍历
List<PCAchildren> list = new ArrayList<>();
List<PCAdataList> list2 = new ArrayList<>();
PCAdataList pcAdataList = new PCAdataList();
BeanUtils.copyProperties(mapData.get(s),pcAdataList);
pcAdataList.setChildren(list);
pcAdataList.setWorkPeopleId(i);
pcAdataList.setWorkPeople(names.get(count));
list2.add(pcAdataList);
pcs.setDataList(list2);
map.put(i,pcs);
}else {
boolean flag=true;
for (PCAdataList pc:map.get(i).getDataList()) {
if (pc.getStandId().equals(mapData.get(s).getStandId())){
flag=false;
}
}
if (flag){
List<PCAchildren> list = new ArrayList<>();
PCAdataList pcAdataList = new PCAdataList();
BeanUtils.copyProperties(mapData.get(s),pcAdataList);
pcAdataList.setChildren(list);
pcAdataList.setWorkPeopleId(i);
pcAdataList.setWorkPeople(names.get(count));
map.get(i).getDataList().add(pcAdataList);
}
}
count++;
}
}else {
PCAtotal pcs=new PCAtotal();
BeanUtils.copyProperties(pcAtotal,pcs);
//建立空的子 为了后面遍历
List<PCAchildren> list=new ArrayList<>();
List<PCAchildren> list1=new ArrayList<>();
list.add(o);
list1.add(o);
pcs.setChildren(list);
List<PCAdataList> list2=new ArrayList<>();
PCAdataList adataLists=new PCAdataList();
BeanUtils.copyProperties(mapData.get(o.getKey()),adataLists);
adataLists.setChildren(list1);
list2.add(adataLists);
pcs.setDataList(list2);
map.put(o.getWorkPeopleId(),pcs);
}
});
map.forEach((s, pcAtotal1) -> {
if (null!=s) {
if (null != s && !"".equals(s)) {
nextUserList.add(s);
}
});
delegateTask.setVariable("workPeoples",nextUserList);
delegateTask.setVariable("workPeoples", nextUserList);
//截止时间 流程描述 创建人
String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
String user = delegateTask.getVariable("prcCreateUser",String.class);
String username = delegateTask.getVariable("prcCreateUserName",String.class);
String prcName = delegateTask.getVariable("stId",String.class)+"-项目合规评估流程-合规性评估";
String user = delegateTask.getVariable("prcCreateUser", String.class);
String username = delegateTask.getVariable("prcCreateUserName", String.class);
String prcName = delegateTask.getVariable("stId", String.class) + "-项目合规评估流程-合规性评估";
QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
@@ -112,8 +170,8 @@ public class PCAffLiableDistributeAfter implements TaskListener {
}
// 存储当前节点意见
if(nextUserList != null && !nextUserList.isEmpty()){
for(String userId : nextUserList){
if (nextUserList != null && !nextUserList.isEmpty()) {
for (String userId : nextUserList) {
BusProcessNew busProcessNewNext = new BusProcessNew();
busProcessNewNext.setMsgType("clause");
busProcessNewNext.setPId(delegateTask.getProcessInstanceId());
@@ -126,5 +184,6 @@ public class PCAffLiableDistributeAfter implements TaskListener {
busBean.save(busProcessNewNext);
}
}
}
}
src/main/java/com/ydw/bat/wkflow/listener/ProjectComplianceAssessment/PCAgcManagerApproveAfter.java
+2
View File
@@ -3,6 +3,7 @@ package com.ydw.bat.wkflow.listener.ProjectComplianceAssessment;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_main.datas.dto.DataList;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessName;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
import com.ydw.bat.wkflow.business_main.datas.entity.Datas;
@@ -43,6 +44,7 @@ public class PCAgcManagerApproveAfter implements TaskListener {
delegateTask.setVariable("bzManager", delegateTask.getVariable("bzfgl"));
delegateTask.setVariable("gcFlag","1");
}else {
object.put("dataList",delegateTask.getVariable(object.getString("key")));
nextUserList.add(String.valueOf(delegateTask.getVariable("workPeople")));
delegateTask.setVariable("gcFlag", "2");
}
src/main/java/com/ydw/bat/wkflow/listener/ProjectComplianceAssessment/PCAjgManagerApproveAfter.java
+2
View File
@@ -3,6 +3,7 @@ package com.ydw.bat.wkflow.listener.ProjectComplianceAssessment;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_main.datas.dto.DataList;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessName;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
import com.ydw.bat.wkflow.business_main.datas.entity.Datas;
@@ -44,6 +45,7 @@ public class PCAjgManagerApproveAfter implements TaskListener {
delegateTask.setVariable("gcManager", delegateTask.getVariable("gcjl"));
delegateTask.setVariable("jgFlag","1");
}else {
object.put("dataList",delegateTask.getVariable(object.getString("key")));
nextUserList.add(String.valueOf(delegateTask.getVariable("workPeople")));
delegateTask.setVariable("jgFlag", "2");
}
src/main/java/com/ydw/bat/wkflow/listener/aboliish/ProcessStep2After.java
+1 -1
View File
@@ -60,7 +60,7 @@ public class ProcessStep2After implements TaskListener {
//截止时间 流程描述 创建人
String user = delegateTask.getVariable("prcCreateUser",String.class);
String username = delegateTask.getVariable("prcCreateUserName", String.class);
String prcName = "企标复审流程-起草人修改标准状态";
String prcName = "企标废止流程-起草人修改标准状态";
QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
src/main/java/com/ydw/bat/wkflow/listener/aboliish/ProcessStep3After.java
+1 -1
View File
@@ -41,7 +41,7 @@ public class ProcessStep3After implements TaskListener {
//截止时间 流程描述 创建人
String user = delegateTask.getVariable("prcCreateUser",String.class);
String username = delegateTask.getVariable("prcCreateUserName", String.class);
String prcName = "企标复审流程-标准法规部部长审核";
String prcName = "企标废止流程-标准法规部部长审核";
QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
src/main/java/com/ydw/bat/wkflow/listener/aboliish/ProcessStep4After.java
+2 -2
View File
@@ -49,9 +49,9 @@ public class ProcessStep4After implements TaskListener {
String username = delegateTask.getVariable("prcCreateUserName", String.class);
String prcName="";
if ("0".equals(object.getString("bzFlag"))){
prcName = "企标复审流程-审定责任人审定";
prcName = "企标废止流程-审定责任人审定";
}else {
prcName = "企标复审流程-起草人修改标准状态";
prcName = "企标废止流程-起草人修改标准状态";
}
QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId());
src/main/java/com/ydw/bat/wkflow/listener/aboliish/ProcessStep5After.java
+2 -2
View File
@@ -49,9 +49,9 @@ public class ProcessStep5After implements TaskListener {
String username = delegateTask.getVariable("prcCreateUserName", String.class);
String prcName = "";
if ("0".equals(object.getString("sdFlag"))){
prcName = "企标复审流程-批准负责人审批";
prcName = "企标废止流程-批准负责人审批";
}else {
prcName = "企标复审流程-起草人修改标准状态";
prcName = "企标废止流程-起草人修改标准状态";
}
QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId());
src/main/java/com/ydw/bat/wkflow/listener/aboliish/ProcessStep6After.java
+2 -2
View File
@@ -49,9 +49,9 @@ public class ProcessStep6After implements TaskListener {
String username = delegateTask.getVariable("prcCreateUserName", String.class);
String prcName = "";
if ("0".equals(object.getString("sdFlag"))){
prcName = "企标复审流程-批准负责人审批";
prcName = "企标废止流程-批准负责人审批";
}else {
prcName = "企标复审流程-起草人修改标准状态";
prcName = "企标废止流程-起草人修改标准状态";
}
String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
QueryWrapper queryWrapper2 = new QueryWrapper();
src/main/java/com/ydw/bat/wkflow/listener/projectEvaluationProcess/PEPDepartLeaderAfter.java
+16
View File
@@ -13,6 +13,7 @@ import com.ydw.bat.wkflow.business_main.datas.entity.Datas;
import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNameService;
import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNewService;
import com.ydw.bat.wkflow.business_main.datas.service.IDatasService;
import com.ydw.bat.wkflow.business_slrs.dao.StandProjectRelationDto;
import com.ydw.bat.wkflow.util.SpringContextUtil;
import org.activiti.engine.ActivitiException;
import org.activiti.engine.delegate.DelegateTask;
@@ -53,6 +54,8 @@ public class PEPDepartLeaderAfter implements TaskListener {
JSONArray dataList=JSONArray.parseArray(object.getString("dataList"));
List<SarStandUnqualified> sarStandUnqualifieds=new ArrayList<>();
List<SarStandardComplianceProductAssess> productAssesses=new ArrayList<>();
//清单和项目关联
List<StandProjectRelationDto> standProjectRelationDtos = new ArrayList<>();
int i=0;
for (Object j : jsonArray) {
Step3DTO o=JSONObject.parseObject(String.valueOf(j), Step3DTO.class);
@@ -79,6 +82,7 @@ public class PEPDepartLeaderAfter implements TaskListener {
sarStandUnqualified.setProductType("research");
sarStandUnqualified.setReason(object1.getString("noCompliance"));
sarStandUnqualified.setPlanCloseTime(JSONObject.parseObject(String.valueOf(object1.get("completionTime")),Date.class));
sarStandUnqualified.setProductId(o.getProjectNumber());
sarStandUnqualifieds.add(sarStandUnqualified);
}
@@ -102,6 +106,7 @@ public class PEPDepartLeaderAfter implements TaskListener {
sarStandUnqualified.setReason(object1.getString("zcNoCompliance"));
sarStandUnqualified.setProductType("product");
sarStandUnqualified.setPlanCloseTime(JSONObject.parseObject(String.valueOf(object1.get("zcCompletionTime")),Date.class));
sarStandUnqualified.setProductId(o.getProjectNumber());
sarStandUnqualifieds.add(sarStandUnqualified);
}
//合估评规 结果！
@@ -128,6 +133,9 @@ public class PEPDepartLeaderAfter implements TaskListener {
sarStandard.setResearchCountermeasures(object1.getString("countermeasures"));
sarStandard.setResearchNonCompliance(object1.getString("noCompliance"));
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
sarStandard.setEvaluationPeople(object1.getString("implementer"));
sarStandard.setEvaluationPeopleName(object1.getString("implementerId"));
sarStandard.setEvaluationTime(simpleDateFormat.format(new Date()));
try {
if (null!=delegateTask.getVariable("XCXSSRQ")) {
sarStandard.setResearchImplementationTime(simpleDateFormat.parse(String.valueOf(delegateTask.getVariable("XCXSSRQ"))));
@@ -139,10 +147,18 @@ public class PEPDepartLeaderAfter implements TaskListener {
e.printStackTrace();
}
i++;
Map map=delegateTask.getVariable("numberWithId",Map.class);
StandProjectRelationDto standProjectRelationDto = new StandProjectRelationDto();
standProjectRelationDto.setProjectId(String.valueOf(map.get(o.getProjectNumber())));
standProjectRelationDto.setStandId(delegateTask.getVariable("standsId",String.class));
if (!standProjectRelationDtos.contains(standProjectRelationDto)) {
standProjectRelationDtos.add(standProjectRelationDto);
}
//数据归类
productAssesses.add(sarStandard);
}
//数据入库！！！！
lawsUserInfoService.batchInsert(standProjectRelationDtos);
lawsUserInfoService.addsarStandUnqualified(sarStandUnqualifieds);
lawsUserInfoService.addProduct(productAssesses);
//是否审批通过 passFlag == 1 通过
src/main/java/com/ydw/bat/wkflow/listener/projectEvaluationProcess/PEPffresPersonAfter.java
+14
View File
@@ -127,6 +127,20 @@ public class PEPffresPersonAfter implements TaskListener {
if (!"1".equals(object.getString("fenFlag"))) {
JSONArray jsonArray = JSONArray.parseArray(object.getString("step3DTOS"));
JSONArray dataList = JSONArray.parseArray(object.getString("dataList"));
//去除jaonArry中的无效数据
JSONArray remove=new JSONArray();
List<String> standard=new ArrayList<>();
dataList.forEach(o -> {
JSONObject os=JSONObject.parseObject(o.toString());
standard.add(os.getString("itemNum")+os.getString("projectNumber"));
});
jsonArray.forEach(o -> {
JSONObject object1=JSONObject.parseObject(o.toString());
if (!standard.contains(object1.getString("itemNum")+object1.getString("projectNumber"))){
remove.add(o);
}
});
jsonArray.removeAll(remove);
PEPDTO res = JSONObject.parseObject(object.toString(), PEPDTO.class);
int i = 0;
for (Object j : jsonArray) {
src/main/java/com/ydw/bat/wkflow/listener/projectEvaluationProcess/PEPmanagerApproveAfter.java
+4 -1
View File
@@ -15,6 +15,7 @@ import com.ydw.bat.wkflow.util.DealWithDate;
import com.ydw.bat.wkflow.util.JsonDateValueProcessor;
import com.ydw.bat.wkflow.util.SpringContextUtil;
import net.sf.json.JsonConfig;
import org.activiti.engine.ActivitiException;
import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener;
import org.springframework.beans.BeanUtils;
@@ -57,7 +58,6 @@ public class PEPmanagerApproveAfter implements TaskListener {
queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
if (one1 != null) {
// one1.setOverTime(OVERTIME);
one1.setPrcType("5");
one1.setPrcName(prcName);
one1.setCreatUser(user);
@@ -65,6 +65,7 @@ public class PEPmanagerApproveAfter implements TaskListener {
busProcessNameService.saveOrUpdate(one1);
}
//生成任务信息
Map<String,String> numberWithId=new HashMap<>();
Map<String,PEPres> map=new HashMap<>();
//是否审批通过 passFlag == 1 不通过
if (null!=object.get("passFlag")) {
@@ -77,6 +78,7 @@ public class PEPmanagerApproveAfter implements TaskListener {
PEPres pePres=new PEPres();
List<PEPDTO> pepdtos=new ArrayList<>();
for (SarStandProjectLibraries sa:da.getSarStandProjectLibraries()) {
numberWithId.put(sa.getProjectNumber(),sa.getId());
for (BreakdownList breakdownList1:breakdownList) {
//造数据
//项目
@@ -120,6 +122,7 @@ public class PEPmanagerApproveAfter implements TaskListener {
}
}
delegateTask.setVariable("numberWithId",numberWithId);
delegateTask.setVariable("liablePeopleList",liablePeopleList);
delegateTask.setVariable("PEPAllCount",count);
}
src/main/java/com/ydw/bat/wkflow/listener/projectEvaluationProcess/PEPtaskEstimateAfter.java
+23 -7
View File
@@ -20,6 +20,7 @@ import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.UUID;
public class PEPtaskEstimateAfter implements TaskListener {
@@ -42,19 +43,34 @@ public class PEPtaskEstimateAfter implements TaskListener {
JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
JSONArray jsonArray=JSONArray.parseArray(object.getString("dataList"));
JSONArray jsonArray = JSONArray.parseArray(object.getString("dataList"));
//操作数据库
JSONArray remove = new JSONArray();
for (Object json : jsonArray) {
JSONObject jsonObject1 = JSONObject.parseObject(json.toString());
if ("".equals(jsonObject1.get("complianceReasons")) && "".equals(jsonObject1.get("noCompliance"))
&& "".equals(jsonObject1.get("countermeasures")) && "".equals(jsonObject1.get("completionTime"))) {
remove.add(jsonObject1);
}
}
String uuid = String.valueOf(UUID.randomUUID());
delegateTask.setVariable(uuid, object.getString("dataList"));
jsonArray.removeAll(remove);
object.put("dataList", jsonArray);
object.put("key", uuid);
//设置分发负责人
List<String> nextUserList = new ArrayList();
JSONObject object1=JSONObject.parseObject(jsonArray.getString(0));
JSONObject object1 = JSONObject.parseObject(jsonArray.getString(0));
if (StringUtils.isNotBlank(object1.getString("distributePersonId"))) {
delegateTask.setVariable("ffUserId", object1.getString("distributePersonId"));
nextUserList.add(delegateTask.getVariable("ffUserId",String.class));
nextUserList.add(delegateTask.getVariable("ffUserId", String.class));
}
//截止时间 流程描述 创建人
String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
String user = delegateTask.getVariable("prcCreateUser", String.class);
String username = delegateTask.getVariable("prcCreateUserName", String.class);
String prcName = delegateTask.getVariable("stands",String.class)+"-标准项目合规评估-分发负责人审批";
String prcName = delegateTask.getVariable("stands", String.class) + "-标准项目合规评估-分发负责人审批";
QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
@@ -67,12 +83,12 @@ public class PEPtaskEstimateAfter implements TaskListener {
busProcessNameService.saveOrUpdate(one1);
}
// 存储当前节点意见
if (null!=object.getString("commentText")) {
if (null != object.getString("commentText")) {
QueryWrapper queryWrapper3 = new QueryWrapper();
queryWrapper3.eq("TASK_ID", delegateTask.getId());
queryWrapper3.eq("USER_ID",delegateTask.getAssignee());
queryWrapper3.eq("USER_ID", delegateTask.getAssignee());
List<BusProcessNew> list = busBean.list(queryWrapper3);
if(!list.isEmpty()){
if (!list.isEmpty()) {
BusProcessNew busProcessNews = list.get(0);
busProcessNews.setTaskId(delegateTask.getId());
busProcessNews.setCommitText(object.getString("commentText"));
src/main/java/com/ydw/bat/wkflow/listener/projectEvaluationProcess/PEPtaskLssueAfter.java
+17 -7
View File
@@ -16,6 +16,7 @@ import org.activiti.engine.ActivitiException;
import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeanUtils;
import java.text.SimpleDateFormat;
import java.util.*;
@@ -52,20 +53,28 @@ public class PEPtaskLssueAfter implements TaskListener {
res.addAll(JSONArray.parseArray(String.valueOf(map.get(s)), Step3DTO.class));
JSONArray.parseArray(String.valueOf(map.get(s)), Step3DTO.class).forEach(step3DTO -> {
List<String> users = new ArrayList<>(Arrays.asList(step3DTO.getImplementerId().split(",")));
users.forEach(s1 -> {
step3DTO.setCertifiedEngineerName(String.valueOf(delegateTask.getVariable("certifiedEngineerName")));
step3DTO.setQualityEngineerName(String.valueOf(delegateTask.getVariable("qualityEngineerName")));
List<String> names = new ArrayList<>(Arrays.asList(step3DTO.getImplementer().split(",")));
int i = 0;
for (String s1 : users) {
Step3DTO result = new Step3DTO();
BeanUtils.copyProperties(step3DTO, result);
result.setCertifiedEngineerName(String.valueOf(delegateTask.getVariable("certifiedEngineerName")));
result.setQualityEngineerName(String.valueOf(delegateTask.getVariable("qualityEngineerName")));
result.setImplementerId(s1);
result.setImplementer(names.get(i));
if (!workPeoples.contains(s1)) {
workPeoples.add(s1);
}
if (null != maps.get(s1)) {
maps.get(s1).add(step3DTO);
maps.get(s1).add(result);
} else {
List<Step3DTO> dtos = new ArrayList<>();
dtos.add(step3DTO);
dtos.add(result);
maps.put(s1, dtos);
}
});
i++;
}
});
}
}
@@ -74,10 +83,11 @@ public class PEPtaskLssueAfter implements TaskListener {
} else {
delegateTask.getVariable("workPeoples", List.class).addAll(workPeoples);
}
//截止时间 流程描述 创建人
String user = delegateTask.getVariable("prcCreateUser", String.class);
String username = delegateTask.getVariable("prcCreateUserName", String.class);
String prcName = delegateTask.getVariable("stands",String.class)+"-标准项目合规评估-合规性评估";
String prcName = delegateTask.getVariable("stands", String.class) + "-标准项目合规评估-合规性评估";
QueryWrapper queryWrapper2 = new QueryWrapper();
queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);