From 42bc160df92c0393ec441e958ee0d4e991d7ed87 Mon Sep 17 00:00:00 2001 From: yuezhihang Date: Tue, 28 Dec 2021 10:09:53 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BE=81=E6=B1=82=E6=84=8F=E8=A7=81=E5=8D=95?= =?UTF-8?q?=E8=8A=82=E7=82=B9=E5=8F=98=E6=88=90=E5=A4=9A=E5=AE=9E=E4=BE=8B?= =?UTF-8?q?=20=E4=BC=98=E5=8C=96=E9=A1=B9=20=E4=BC=98=E5=8C=96=E5=AE=8C?= =?UTF-8?q?=E6=88=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../StandardCommentNewProcess/Step8After.java | 6 +- .../StandardCommentNewProcess/Step9After.java | 82 ++++++++++++------- 2 files changed, 56 insertions(+), 32 deletions(-) diff --git a/src/main/java/com/ydw/bat/wkflow/listener/StandardCommentNewProcess/Step8After.java b/src/main/java/com/ydw/bat/wkflow/listener/StandardCommentNewProcess/Step8After.java index 2d005905..c12862ed 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/StandardCommentNewProcess/Step8After.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/StandardCommentNewProcess/Step8After.java @@ -14,6 +14,7 @@ import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.TaskListener; import java.util.ArrayList; +import java.util.Arrays; import java.util.List; //新征求意见流程!!!!! @@ -46,7 +47,8 @@ public class Step8After implements TaskListener { //整备数据 if ("0".equals(object.getString("bdFlag"))) { delegateTask.setVariable("bdMark",delegateTask.getVariable("bdMark",Integer.class)); - nextUserList.add(delegateTask.getVariable("directorUser",String.class)); + List strings=new ArrayList<>(Arrays.asList(delegateTask.getVariable("directorUser",String.class).split(","))); + nextUserList.addAll(strings); delegateTask.setVariable("hqFlag", "0"); }else { delegateTask.setVariable("bdMark",delegateTask.getVariable("bdMark",Integer.class)+1); @@ -62,7 +64,7 @@ public class Step8After implements TaskListener { delegateTask.setVariable("bdFlag","1"); } } - delegateTask.setVariable("directorUser",delegateTask.getVariable("directorUser",String.class)); + delegateTask.setVariable("directorUserList",nextUserList); //截止时间 流程描述 创建人 String user = delegateTask.getVariable("user",String.class); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/StandardCommentNewProcess/Step9After.java b/src/main/java/com/ydw/bat/wkflow/listener/StandardCommentNewProcess/Step9After.java index ad3d3522..a74b9fee 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/StandardCommentNewProcess/Step9After.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/StandardCommentNewProcess/Step9After.java @@ -10,6 +10,7 @@ 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.util.SpringContextUtil; +import io.swagger.models.auth.In; import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.TaskListener; @@ -21,7 +22,7 @@ public class Step9After implements TaskListener { @Override public void notify(DelegateTask delegateTask) { - LawsUserInfoService lawsUserInfoService = SpringContextUtil.getBean(LawsUserInfoService.class); + IDatasService datasService = SpringContextUtil.getBean(IDatasService.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessNameService busProcessNameService = SpringContextUtil.getBean(IBusProcessNameService.class); @@ -30,29 +31,38 @@ public class Step9After implements TaskListener { queryWrapper.eq("ACTI_TASK_ID", delegateTask.getId()); Datas datas = datasService.getOne(queryWrapper); - JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); - delegateTask.setVariable("objectJson",object); + JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); + delegateTask.setVariable("objectJson", object); List nextUserList = new ArrayList(); - String prcName=""; - if ("0".equals(object.getString("directorFlag"))){ - delegateTask.setVariable("directorFlag","0"); - prcName =delegateTask.getVariable("cid")+"-标准征求意见流程-工程研究总院院长批准"; - nextUserList.add(object.getString("presidentUser")); - delegateTask.setVariable("presidentUser",object.getString("presidentUser")); - }else { - delegateTask.setVariable("directorFlag","1"); - nextUserList.add(delegateTask.getVariable("bzfgIdSum",String.class)); - prcName =delegateTask.getVariable("cid")+"-标准征求意见流程-标准法规工程师汇总"; + String prcName = ""; + //设置一个计数器 + if (null != delegateTask.getVariable("9Counnt", Integer.class)) { + delegateTask.setVariable("9Counnt", delegateTask.getVariable("9Counnt", Integer.class) + 1); + } else { + delegateTask.setVariable("9Counnt", 1); + } + + if ("0".equals(object.getString("directorFlag"))) { + delegateTask.setVariable("directorFlag", "0"); + if (delegateTask.getVariable("9Counnt", Integer.class) == 1) { + delegateTask.setVariable("9Mark", "true"); + delegateTask.setVariable("presidentUser", object.getString("presidentUser")); + } else if ("true" == delegateTask.getVariable("7Mark", String.class)) { + delegateTask.setVariable("9Mark", "true"); + } + } else { + delegateTask.setVariable("directorFlag", "1"); + delegateTask.setVariable("9Mark", "false"); } //截止时间 流程描述 创建人 - String user = delegateTask.getVariable("user",String.class); - String username = delegateTask.getVariable("userName",String.class); + String user = delegateTask.getVariable("user", String.class); + String username = delegateTask.getVariable("userName", String.class); QueryWrapper queryWrapper2 = new QueryWrapper(); - queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); + queryWrapper2.eq("PRC_ID", delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); - if(one1!=null){ + if (one1 != null) { one1.setPrcType("3"); one1.setPrcName(prcName); one1.setCreatUser(user); @@ -73,19 +83,31 @@ public class Step9After implements TaskListener { busBean.saveOrUpdate(busProcessNews); } } - - if(nextUserList != null && !nextUserList.isEmpty()){ - for(String nextUser : nextUserList){ - BusProcessNew busProcessNewNext = new BusProcessNew(); - busProcessNewNext.setMsgType("clause"); - busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); - busProcessNewNext.setMesg(object.toJSONString()); - busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); - busProcessNewNext.setFinishFlag("0"); - busProcessNewNext.setTaskInfo(delegateTask.getName()); - busProcessNewNext.setUserId(nextUser); - busProcessNewNext.setPrcName(prcName); - busBean.save(busProcessNewNext); + if (delegateTask.getVariable("9Counnt", Integer.class) >= delegateTask.getVariable("directorUserList",List.class).size()) { + if ("true".equals(delegateTask.getVariable("9Mark"))){ + delegateTask.setVariable("directorFlag", "0"); + prcName = delegateTask.getVariable("cid") + "-标准征求意见流程-工程研究总院院长批准"; + nextUserList.add(object.getString("presidentUser")); + delegateTask.setVariable("presidentUser", object.getString("presidentUser")); + }else { + delegateTask.setVariable("9Counnt", 0); + delegateTask.setVariable("directorFlag", "1"); + nextUserList.add(delegateTask.getVariable("bzfgIdSum", String.class)); + prcName = delegateTask.getVariable("cid") + "-标准征求意见流程-标准法规工程师汇总"; + } + if (nextUserList != null && !nextUserList.isEmpty()) { + for (String nextUser : nextUserList) { + BusProcessNew busProcessNewNext = new BusProcessNew(); + busProcessNewNext.setMsgType("clause"); + busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); + busProcessNewNext.setMesg(object.toJSONString()); + busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); + busProcessNewNext.setFinishFlag("0"); + busProcessNewNext.setTaskInfo(delegateTask.getName()); + busProcessNewNext.setUserId(nextUser); + busProcessNewNext.setPrcName(prcName); + busBean.save(busProcessNewNext); + } } } }