From df250108572073234a048c23c402b16fd536f11b Mon Sep 17 00:00:00 2001 From: yuezhihang Date: Thu, 31 Mar 2022 17:26:55 +0800 Subject: [PATCH 01/12] =?UTF-8?q?=E9=87=8D=E7=82=B9=E8=AE=A4=E8=AF=81?= =?UTF-8?q?=E8=AF=B7=E5=8D=95-=E5=AE=8C=E6=88=90=E6=97=A5=E6=9C=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../listener/KCSTPReviewProcess/AdminReviewAfter.java | 2 -- .../KCSTPReviewProcess/DeptLeaderReviewAfter.java | 2 -- .../listener/KCSTPReviewProcess/DistributionAfter.java | 2 -- .../listener/KCSTPReviewProcess/FeedBackAfter.java | 2 -- .../listener/KCSTPReviewProcess/LaunchAfter.java | 2 -- .../KCSTPReviewProcess/MinisterReviewAfter.java | 1 - .../listener/KCSTPReviewProcess/ReLaunchAfter.java | 2 -- .../KCSTPReviewProcess/SubMinisterReviewAfter.java | 2 -- .../KCSTPReviewProcess/SubViceDirectorAfter.java | 10 +++++++++- .../listener/KCSTPReviewProcess/ViceDirectorAfter.java | 3 --- 10 files changed, 9 insertions(+), 19 deletions(-) diff --git a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/AdminReviewAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/AdminReviewAfter.java index 8a7cdbfa..9de7fd11 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/AdminReviewAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/AdminReviewAfter.java @@ -59,7 +59,6 @@ public class AdminReviewAfter implements TaskListener { //截止时间 流程描述 创建人 - String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); String user = object.getString("prcCreateUser"); String username = object.getString("prcCreateUserName"); // object.getString("standName") @@ -69,7 +68,6 @@ public class AdminReviewAfter implements TaskListener { queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ - one1.setOverTime(OVERTIME); one1.setPrcType("laws3"); // one1.setPrcName(prcName); one1.setCreatUser(user); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/DeptLeaderReviewAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/DeptLeaderReviewAfter.java index 534e6a17..ac2622e6 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/DeptLeaderReviewAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/DeptLeaderReviewAfter.java @@ -58,7 +58,6 @@ public class DeptLeaderReviewAfter implements TaskListener { //截止时间 流程描述 创建人 - String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); String user = object.getString("prcCreateUser"); String username = object.getString("prcCreateUserName"); // object.getString("standName") @@ -68,7 +67,6 @@ public class DeptLeaderReviewAfter implements TaskListener { queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ - one1.setOverTime(OVERTIME); one1.setPrcType("laws3"); // one1.setPrcName(prcName); one1.setCreatUser(user); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/DistributionAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/DistributionAfter.java index c253b06e..7934e840 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/DistributionAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/DistributionAfter.java @@ -57,7 +57,6 @@ public class DistributionAfter implements TaskListener { } //截止时间 流程描述 创建人 - String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); String user = object.getString("prcCreateUser"); String username = object.getString("prcCreateUserName"); // object.getString("standName") @@ -67,7 +66,6 @@ public class DistributionAfter implements TaskListener { queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ - one1.setOverTime(OVERTIME); one1.setPrcType("laws3"); // one1.setPrcName(prcName); one1.setCreatUser(user); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/FeedBackAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/FeedBackAfter.java index c757c961..5fee2644 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/FeedBackAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/FeedBackAfter.java @@ -51,7 +51,6 @@ public class FeedBackAfter implements TaskListener { } //截止时间 流程描述 创建人 - String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); String user = object.getString("prcCreateUser"); String username = object.getString("prcCreateUserName"); // object.getString("standName") @@ -61,7 +60,6 @@ public class FeedBackAfter implements TaskListener { queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ - one1.setOverTime(OVERTIME); one1.setPrcType("laws3"); // one1.setPrcName(prcName); one1.setCreatUser(user); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/LaunchAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/LaunchAfter.java index 885a3273..e3cd8319 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/LaunchAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/LaunchAfter.java @@ -51,7 +51,6 @@ public class LaunchAfter implements TaskListener { //截止时间 流程描述 创建人 - String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); String user = object.getString("prcCreateUser"); String username = object.getString("prcCreateUserName"); // object.getString("standName") @@ -61,7 +60,6 @@ public class LaunchAfter implements TaskListener { queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ -// one1.setOverTime(OVERTIME); one1.setPrcType("laws3"); one1.setPrcName(prcName); one1.setCreatUser(user); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/MinisterReviewAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/MinisterReviewAfter.java index 5716fba3..af952d99 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/MinisterReviewAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/MinisterReviewAfter.java @@ -77,7 +77,6 @@ public class MinisterReviewAfter implements TaskListener { queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ -// one1.setOverTime(OVERTIME); one1.setPrcType("laws3"); // one1.setPrcName(prcName); one1.setCreatUser(user); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/ReLaunchAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/ReLaunchAfter.java index d8d5ba08..e4f042fb 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/ReLaunchAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/ReLaunchAfter.java @@ -60,9 +60,7 @@ public class ReLaunchAfter implements TaskListener { queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ -// one1.setOverTime(OVERTIME); one1.setPrcType("laws3"); -// one1.setPrcName(prcName); one1.setCreatUser(user); one1.setCreatUserName(username); busProcessNameService.saveOrUpdate(one1); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubMinisterReviewAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubMinisterReviewAfter.java index 31b2af92..8d9e750b 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubMinisterReviewAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubMinisterReviewAfter.java @@ -56,7 +56,6 @@ public class SubMinisterReviewAfter implements TaskListener { //截止时间 流程描述 创建人 - String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); String user = object.getString("prcCreateUser"); String username = object.getString("prcCreateUserName"); // object.getString("standName") @@ -66,7 +65,6 @@ public class SubMinisterReviewAfter implements TaskListener { queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ -// one1.setOverTime(OVERTIME); one1.setPrcType("laws3"); // one1.setPrcName(prcName); one1.setCreatUser(user); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java index 9526cf8c..06dc56cb 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java @@ -36,6 +36,12 @@ public class SubViceDirectorAfter implements TaskListener { JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); delegateTask.setVariable("objectJson",object); + int i=1; + if (null!=delegateTask.getVariable("finishCount")){ + i=delegateTask.getVariable("finishCount",Integer.class)+1; + } + delegateTask.setVariable("finishCount",i); + /** * next 结束 @@ -71,7 +77,9 @@ public class SubViceDirectorAfter implements TaskListener { queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ -// one1.setOverTime(OVERTIME); + if (i>=delegateTask.getVariable("responseUserIdList",List.class).size()) { + one1.setOverTime(OVERTIME); + } one1.setPrcType("laws3"); one1.setPrcName(prcName); one1.setCreatUser(user); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/ViceDirectorAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/ViceDirectorAfter.java index c994fa2d..d8e306de 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/ViceDirectorAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/ViceDirectorAfter.java @@ -72,7 +72,6 @@ public class ViceDirectorAfter implements TaskListener { //截止时间 流程描述 创建人 - String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); String user = object.getString("prcCreateUser"); String username = object.getString("prcCreateUserName"); // object.getString("standName") @@ -81,9 +80,7 @@ public class ViceDirectorAfter implements TaskListener { queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ -// one1.setOverTime(OVERTIME); one1.setPrcType("laws3"); -// one1.setPrcName(prcName); one1.setCreatUser(user); one1.setCreatUserName(username); busProcessNameService.saveOrUpdate(one1); From 99ed88c922cae80be79b6d55b435b41568d51ea8 Mon Sep 17 00:00:00 2001 From: super_liu <396572590@qq.com> Date: Thu, 31 Mar 2022 18:07:25 +0800 Subject: [PATCH 02/12] feat: x --- .../bat/wkflow/listener/lawsLibrary/LCLApplicantBefore.java | 2 ++ .../wkflow/listener/lawsLibrary/LawsManagerApproveAfter.java | 5 +++-- .../listener/lawsLibrary/LawsManagerApproveBefore.java | 1 + 3 files changed, 6 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LCLApplicantBefore.java b/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LCLApplicantBefore.java index c8af4d69..7623f36e 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LCLApplicantBefore.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LCLApplicantBefore.java @@ -24,6 +24,8 @@ public class LCLApplicantBefore implements TaskListener{ queryWrapper1.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper1.eq("USER_ID",delegateTask.getAssignee()); queryWrapper1.isNull("TASK_ID"); + queryWrapper1.orderByDesc("CREATE_TIME"); + List list = busBean.list(queryWrapper1); if(!list.isEmpty()){ BusProcessNew one1 = list.get(0); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LawsManagerApproveAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LawsManagerApproveAfter.java index 6d9e8ec5..79328257 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LawsManagerApproveAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LawsManagerApproveAfter.java @@ -8,6 +8,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.listener.bussLibrary.BussUtils; import com.ydw.bat.wkflow.util.SpringContextUtil; import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.TaskListener; @@ -34,7 +35,6 @@ public class LawsManagerApproveAfter implements TaskListener { String approvalOpinion = object.get("approvalOpinion") == null ? "" : object.get("approvalOpinion").toString(); String prcName = "政策入库流程"; if ("1".equalsIgnoreCase(approvalOpinion)) { - delegateTask.setVariable("applyUserId", object.getString("applyUpdUserId")); BusProcessNew busProcessNew = new BusProcessNew(); busProcessNew.setMsgType("clause"); @@ -47,7 +47,8 @@ public class LawsManagerApproveAfter implements TaskListener { busProcessNew.setPrcName(prcName); busBean.save(busProcessNew); - func1(delegateTask, busBean, object, "1"); + BussUtils.approvalFunc1(delegateTask, busBean, object, prcName,"1"); + delegateTask.setVariable("applyUserId", object.getString("applyUpdUserId")); delegateTask.setVariable("jlFlag", 1); } else { delegateTask.setVariable("jlFlag", 0); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LawsManagerApproveBefore.java b/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LawsManagerApproveBefore.java index e845d073..a0146583 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LawsManagerApproveBefore.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LawsManagerApproveBefore.java @@ -23,6 +23,7 @@ public class LawsManagerApproveBefore implements TaskListener{ queryWrapper1.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper1.eq("USER_ID",delegateTask.getAssignee()); queryWrapper1.isNull("TASK_ID"); + queryWrapper1.orderByDesc("CREATE_TIME"); List list = busBean.list(queryWrapper1); if(!list.isEmpty()){ BusProcessNew one1 = list.get(0); From 4c5236f11ad982a0883cf71830cc6dfbfe7178c1 Mon Sep 17 00:00:00 2001 From: super_liu <396572590@qq.com> Date: Mon, 4 Apr 2022 18:19:30 +0800 Subject: [PATCH 03/12] feat: --- .../wkflow/listener/lawsLibrary/LawsManagerApproveAfter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LawsManagerApproveAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LawsManagerApproveAfter.java index 79328257..94000ecf 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LawsManagerApproveAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LawsManagerApproveAfter.java @@ -75,7 +75,7 @@ public class LawsManagerApproveAfter implements TaskListener { if (one2 != null) { //one2.setPrcName("入库流程结束"); one2.setOverTime(OVERTIME); - one2.setPrcType("1"); + one2.setPrcType("laws1"); busProcessNameService.saveOrUpdate(one2); } From be64df110dca63988f1046520dee22e8fef9227d Mon Sep 17 00:00:00 2001 From: yuezhihang Date: Wed, 6 Apr 2022 15:59:36 +0800 Subject: [PATCH 04/12] =?UTF-8?q?=E6=B5=81=E7=A8=8B=20bug=E4=BF=AE?= =?UTF-8?q?=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../business_auth/LawsUserInfoService.java | 9 ++ .../datas/dto/WG/BusinessDeptIssue.java | 88 +++++++++++++++++++ .../datas/dto/WG/ProductDeptIssue.java | 74 ++++++++++++++++ .../SubViceDirectorAfter.java | 74 +++++++++++++++- .../StandardSurvey/ResponUserSignAfter.java | 12 +++ .../UploadResearchResultAfter.java | 15 ++++ .../standardRead/DeptApplayAfter.java | 2 +- 7 files changed, 269 insertions(+), 5 deletions(-) create mode 100644 src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/WG/BusinessDeptIssue.java create mode 100644 src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/WG/ProductDeptIssue.java diff --git a/src/main/java/com/ydw/bat/wkflow/business_auth/LawsUserInfoService.java b/src/main/java/com/ydw/bat/wkflow/business_auth/LawsUserInfoService.java index 229534c7..ca93faa9 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_auth/LawsUserInfoService.java +++ b/src/main/java/com/ydw/bat/wkflow/business_auth/LawsUserInfoService.java @@ -2,6 +2,8 @@ package com.ydw.bat.wkflow.business_auth; import com.ydw.bat.wkflow.business_main.datas.dto.*; +import com.ydw.bat.wkflow.business_main.datas.dto.WG.BusinessDeptIssue; +import com.ydw.bat.wkflow.business_main.datas.dto.WG.ProductDeptIssue; import com.ydw.bat.wkflow.business_main.datas.dto.WG.WgWorkGroupShowDTO; import com.ydw.bat.wkflow.business_main.datas.entity.*; import com.ydw.bat.wkflow.business_slrs.dao.*; @@ -176,5 +178,12 @@ public interface LawsUserInfoService { @GetMapping("/slrs/sar-public-idea/deletePublicIdea") public ResponseMessage deletePublicIdea(@RequestParam("id") String id); + @PostMapping("/sarStandUnqualified/businessDeptIssue/saveBatch") + public ResponseMessage businessDeptIssueSaveBatch(@RequestBody List issue); + + + @PostMapping("/sarStandUnqualified/productDeptIssue/saveBatch") + public ResponseMessage productDeptIssueSaveBatch(@RequestBody List issue); + } diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/WG/BusinessDeptIssue.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/WG/BusinessDeptIssue.java new file mode 100644 index 00000000..3777bec0 --- /dev/null +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/WG/BusinessDeptIssue.java @@ -0,0 +1,88 @@ +package com.ydw.bat.wkflow.business_main.datas.dto.WG; + + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableLogic; +import com.fasterxml.jackson.annotation.JsonFormat; +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +@Data +public class BusinessDeptIssue implements Serializable { + + @TableId(value = "id", type = IdType.UUID) + private String id; + + + @TableField("law_id") + private String lawId; + + + @TableField(exist = false) + private String lawNumber; + + + @TableField(exist = false) + private String lawName; + + + @TableField("product_type") + private String productType; + + + @TableField("impl_time") + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-mm-dd") + private Date implTime; + + + @TableField("impl_require") + private String implRequire; + + + @TableField("conform_situation") + private String conformSituation; + + + @TableField("dev_scheme") + private String devScheme; + + + @TableField("sop_time") + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-mm-dd") + private Date sopTime; + + + @TableField("complete_situation") + private String completeSituation; + + + @TableField("timeout_situation") + private String timeoutSituation; + + + @TableLogic(value = "0", delval = "1") + @TableField("del_flag") + private String delFlag; + + + @TableField("response_dept") + private String responseDept; + + + @TableField("response_people") + private String responsePeople; + + + @TableField("is_close") + private String isClose; + + + @TableField("is_risk") + private String isRisk; + + +} diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/WG/ProductDeptIssue.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/WG/ProductDeptIssue.java new file mode 100644 index 00000000..cb61e0cf --- /dev/null +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/WG/ProductDeptIssue.java @@ -0,0 +1,74 @@ +package com.ydw.bat.wkflow.business_main.datas.dto.WG; + + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableLogic; +import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +@Data +@TableName("product_dept_issue") +public class ProductDeptIssue implements Serializable { + + @TableId + private String id; + + @TableField("law_id") + private String lawId; + + @TableField(exist = false) + private String lawsNumber; + + @TableField(exist = false) + private String lawsName; + + @TableField("product_business") + private String productBusiness; + + @TableField("platform") + private String platform; + + @TableField("poj_name") + private String pojName; + + @TableField("poj_description") + private String pojDescription; + + @TableField("current_node") + private String currentNode; + + @TableField("conceptual_state") + private String conceptualState; + + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-mm-dd") + @TableField("scheduled_issuance_time") + private Date scheduledIssuanceTime; + + @TableField("revised_plan") + private String revisedPlan; + + @TableField("explanation") + private String explanation; + + @TableField("response_dept") + private String responseDept; + + @TableLogic(value = "0",delval = "1") + @TableField("del_flag") + private String delFlag; + + @TableField("is_close") + private String isClose; + + @TableField(exist = false) + private Integer page; + + @TableField(exist = false) + private Integer pageSize; + +} diff --git a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java index 06dc56cb..4a0aafcb 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java @@ -1,7 +1,12 @@ package com.ydw.bat.wkflow.listener.KCSTPReviewProcess; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.ydw.bat.wkflow.business_auth.LawsUserInfoService; +import com.ydw.bat.wkflow.business_main.datas.dto.WG.BusinessDeptIssue; +import com.ydw.bat.wkflow.business_main.datas.dto.WG.ProductDeptIssue; 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; @@ -14,10 +19,7 @@ import org.activiti.engine.delegate.TaskListener; import org.apache.commons.lang.StringUtils; import java.text.SimpleDateFormat; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.Date; -import java.util.List; +import java.util.*; /** * 副总监审核 @@ -28,6 +30,7 @@ public class SubViceDirectorAfter implements TaskListener { IDatasService datasService = SpringContextUtil.getBean(IDatasService.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessNameService busProcessNameService = SpringContextUtil.getBean(IBusProcessNameService.class); + LawsUserInfoService lawsUserInfoService = SpringContextUtil.getBean(LawsUserInfoService.class); QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("ACTI_TASK_ID", delegateTask.getId()); @@ -50,6 +53,69 @@ public class SubViceDirectorAfter implements TaskListener { if ("0".equals(object.getString("actionFlag"))){ delegateTask.setVariable("lawsProveViceChiefVerify",0); + + if ("1".equals(object.getString("feedbackDept"))) { + List list = new ArrayList<>(); + if (null != delegateTask.getVariable("v")) { + list = delegateTask.getVariable("v", List.class); + } + JSONArray array = object.getJSONArray("infoTableDatas"); + if (array.size() > 0) { + for (Object o : array) { + JSONObject object1 = JSON.parseObject(o.toString()); + BusinessDeptIssue businessDeptIssue = new BusinessDeptIssue(); + businessDeptIssue.setDelFlag("0"); + businessDeptIssue.setId(String.valueOf(UUID.randomUUID())); + businessDeptIssue.setLawId(object1.getString("lawId")); + businessDeptIssue.setImplRequire(object1.getString("implRequire")); + businessDeptIssue.setImplTime(object1.getDate("implTime")); + businessDeptIssue.setCompleteSituation(object1.getString("completeSituation")); + businessDeptIssue.setSopTime(object1.getDate("sopTime")); + businessDeptIssue.setLawName(object1.getString("lawName")); + businessDeptIssue.setConformSituation(object1.getString("conformSituation")); + businessDeptIssue.setTimeoutSituation(object1.getString("timeoutSituation")); + businessDeptIssue.setDevScheme(object1.getString("devScheme")); + businessDeptIssue.setLawNumber(object1.getString("lawCode")); + businessDeptIssue.setProductType(object1.getString("dataSource")); + list.add(businessDeptIssue); + } + } + + delegateTask.setVariable("v", list); + + if (i >= delegateTask.getVariable("responseUserIdList", List.class).size()) { + lawsUserInfoService.businessDeptIssueSaveBatch(list); + } + }else { + List list = new ArrayList<>(); + if (null != delegateTask.getVariable("v2")) { + list = delegateTask.getVariable("v2", List.class); + } + JSONArray array = object.getJSONArray("infoTableDatas"); + if (array.size() > 0) { + for (Object o : array) { + JSONObject object1 = JSON.parseObject(o.toString()); + ProductDeptIssue productDeptIssue = new ProductDeptIssue(); + productDeptIssue.setDelFlag("0"); + productDeptIssue.setId(String.valueOf(UUID.randomUUID())); + productDeptIssue.setLawId(object1.getString("lawId")); +// businessDeptIssue.setImplRequire(object1.getString("implRequire")); +// businessDeptIssue.setImplTime(object1.getDate("implTime")); +// businessDeptIssue.setCompleteSituation(object1.getString("completeSituation")); +// businessDeptIssue.setSopTime(object1.getDate("sopTime")); +// businessDeptIssue.setLawName(object1.getString("lawName")); +// businessDeptIssue.setConformSituation(object1.getString("conformSituation")); +// businessDeptIssue.setTimeoutSituation(object1.getString("timeoutSituation")); +// businessDeptIssue.setDevScheme(object1.getString("devScheme")); +// businessDeptIssue.setLawNumber(object1.getString("lawCode")); +// businessDeptIssue.setProductType(object1.getString("dataSource")); + list.add(productDeptIssue); + } + } + + delegateTask.setVariable("v2", list); + } + //流程结束 func2(delegateTask, busBean, object, "0", busProcessNameService); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/StandardSurvey/ResponUserSignAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/StandardSurvey/ResponUserSignAfter.java index 44b76cae..30b3af51 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/StandardSurvey/ResponUserSignAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/StandardSurvey/ResponUserSignAfter.java @@ -123,6 +123,18 @@ public class ResponUserSignAfter implements TaskListener { busBean.save(busProcessNewNext); } } + }else{ + delegateTask.setVariable("actionFlag",1); + delegateTask.setVariable("cs",0); + BusProcessNew busProcessNewNext = new BusProcessNew(); + busProcessNewNext.setMsgType("clause"); + busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); + busProcessNewNext.setMesg(object.toJSONString()); + busProcessNewNext.setFinishFlag("0"); + busProcessNewNext.setTaskInfo("调研结果处理"); + busProcessNewNext.setPrcName(prcName); + busProcessNewNext.setUserId(delegateTask.getVariable("startUser", String.class)); + busBean.save(busProcessNewNext); } } else { delegateTask.setVariable("actionFlag",1); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/StandardSurvey/UploadResearchResultAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/StandardSurvey/UploadResearchResultAfter.java index 5a99dda1..dcc77a36 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/StandardSurvey/UploadResearchResultAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/StandardSurvey/UploadResearchResultAfter.java @@ -80,6 +80,21 @@ public class UploadResearchResultAfter implements TaskListener { busProcessNameService.saveOrUpdate(one1); } + //存储当前节点意见 + if (null != object.getString("commentText")) { + QueryWrapper queryWrapper3 = new QueryWrapper(); + queryWrapper3.eq("TASK_ID", delegateTask.getId()); + queryWrapper3.eq("USER_ID", delegateTask.getAssignee()); + List list = busBean.list(queryWrapper3); + if (!list.isEmpty()) { + BusProcessNew busProcessNews = list.get(0); + busProcessNews.setTaskId(delegateTask.getId()); + busProcessNews.setCommitText(object.getString("commentText")); + busBean.saveOrUpdate(busProcessNews); + } + } + + BusProcessNew busProcessNewNext = new BusProcessNew(); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/standardRead/DeptApplayAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/standardRead/DeptApplayAfter.java index 13e977b0..f65e791b 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/standardRead/DeptApplayAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/standardRead/DeptApplayAfter.java @@ -157,7 +157,7 @@ public class DeptApplayAfter implements TaskListener{ busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setCommitText(object.getString("commentText")); - busProcessNew.setFinishFlag("0"); + busProcessNew.setFinishFlag("1"); busProcessNew.setTaskInfo(delegateTask.getName()); QueryWrapper updataWapper = new QueryWrapper(); From a14011f9ea03e36260e78a09e6906cc0044af6dd Mon Sep 17 00:00:00 2001 From: yuezhihang Date: Wed, 6 Apr 2022 17:42:17 +0800 Subject: [PATCH 05/12] =?UTF-8?q?=E8=A7=A3=E8=AF=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ydw/bat/wkflow/listener/standardRead/DeptApplayAfter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/ydw/bat/wkflow/listener/standardRead/DeptApplayAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/standardRead/DeptApplayAfter.java index f65e791b..13e977b0 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/standardRead/DeptApplayAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/standardRead/DeptApplayAfter.java @@ -157,7 +157,7 @@ public class DeptApplayAfter implements TaskListener{ busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setCommitText(object.getString("commentText")); - busProcessNew.setFinishFlag("1"); + busProcessNew.setFinishFlag("0"); busProcessNew.setTaskInfo(delegateTask.getName()); QueryWrapper updataWapper = new QueryWrapper(); From 4fabc7b061d29fe9a68a4b88e633af62abd4d4b0 Mon Sep 17 00:00:00 2001 From: yuezhihang Date: Thu, 7 Apr 2022 15:16:03 +0800 Subject: [PATCH 06/12] =?UTF-8?q?isEnd=E7=9A=84=E5=80=BC=E5=8F=98=E6=88=90?= =?UTF-8?q?1=E5=B0=B1=E5=8F=AF=E4=BB=A5=E4=BA=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../business_activiti/task/TodoTaskController.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/ydw/bat/wkflow/business_activiti/task/TodoTaskController.java b/src/main/java/com/ydw/bat/wkflow/business_activiti/task/TodoTaskController.java index 69d9c10a..0fc9b90d 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_activiti/task/TodoTaskController.java +++ b/src/main/java/com/ydw/bat/wkflow/business_activiti/task/TodoTaskController.java @@ -1909,7 +1909,15 @@ public class TodoTaskController extends BaseAction { return "0"; } }else { - return "0"; + QueryWrapper queryWrapper2 = new QueryWrapper<>(); + queryWrapper2.eq("PRC_ID", pId); + queryWrapper2.isNotNull("OVER_TIME"); + BusProcessName one = iBusProcessNameService.getOne(queryWrapper2); + if (null!=one){ + return "1"; + }else { + return "0"; + } } } else { return "1"; From 219f359f96b28f5ccf2b0dc01483107dc339db24 Mon Sep 17 00:00:00 2001 From: super_liu <396572590@qq.com> Date: Fri, 8 Apr 2022 18:06:57 +0800 Subject: [PATCH 07/12] feat: xx --- .../bussLibrary/BussLibraryC3After.java | 2 +- .../lawsLibrary/LCLApplicantAfter.java | 20 +++++++++---------- 2 files changed, 11 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussLibraryC3After.java b/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussLibraryC3After.java index baedbd45..50b52381 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussLibraryC3After.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/bussLibrary/BussLibraryC3After.java @@ -98,7 +98,7 @@ public class BussLibraryC3After implements TaskListener{ BusProcessNew busProcessNewNext = new BusProcessNew(); busProcessNewNext.setMsgType("clause"); busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); - busProcessNewNext.setMesg(object.toJSONString()); + busProcessNewNext.setMesg(objectNew.toJSONString()); busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setUserId(nextUser); busProcessNewNext.setPrcName(prcName); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LCLApplicantAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LCLApplicantAfter.java index afed8254..f131ec6d 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LCLApplicantAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/lawsLibrary/LCLApplicantAfter.java @@ -35,8 +35,8 @@ public class LCLApplicantAfter 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 objectNew = JSONObject.parseObject(datas.getFormValsJson()); + delegateTask.setVariable("objectJson",objectNew); QueryWrapper queryWrapper1 = new QueryWrapper(); queryWrapper1.eq("P_ID",delegateTask.getProcessInstanceId()); @@ -48,9 +48,9 @@ public class LCLApplicantAfter implements TaskListener{ JSONObject object = JSONObject.parseObject(one.getMesg()); List nextUserList = new ArrayList(); - if(StringUtils.isNotBlank(object.getString("jlUserId"))){ - delegateTask.setVariable("managerUserId",object.getString("jlUserId")); - nextUserList.add(object.getString("jlUserId")); + if(StringUtils.isNotBlank(objectNew.getString("jlUserId"))){ + delegateTask.setVariable("managerUserId",objectNew.getString("jlUserId")); + nextUserList.add(objectNew.getString("jlUserId")); }else { throw new ActivitiException("1#2经理人不存在,请配置相关人员"); } @@ -59,8 +59,8 @@ public class LCLApplicantAfter implements TaskListener{ //截止时间 流程描述 创建人 String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); - String user = object.getString("prcCreateUser"); - String username = object.getString("prcCreateUserName"); + String user = objectNew.getString("prcCreateUser"); + String username = objectNew.getString("prcCreateUserName"); // object.getString("standName") String standName = ""; String prcName = "政策入库流程"; @@ -81,10 +81,10 @@ public class LCLApplicantAfter implements TaskListener{ busProcessNew.setId(one.getId()); busProcessNew.setMsgType("clause"); busProcessNew.setPId(delegateTask.getProcessInstanceId()); - busProcessNew.setMesg(object.toJSONString()); + busProcessNew.setMesg(objectNew.toJSONString()); busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNew.setTaskId(delegateTask.getId()); - busProcessNew.setCommitText(object.getString("commentText")); + busProcessNew.setCommitText(objectNew.getString("commentText")); busProcessNew.setFinishFlag("0"); busProcessNew.setTaskInfo(delegateTask.getName()); busBean.saveOrUpdate(busProcessNew); @@ -94,7 +94,7 @@ public class LCLApplicantAfter implements TaskListener{ BusProcessNew busProcessNewNext = new BusProcessNew(); busProcessNewNext.setMsgType("clause"); busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); - busProcessNewNext.setMesg(object.toJSONString()); + busProcessNewNext.setMesg(objectNew.toJSONString()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setTaskInfo(delegateTask.getName()); From 5b9d19939d248a97a09836f587facf2a9a174817 Mon Sep 17 00:00:00 2001 From: super_liu <396572590@qq.com> Date: Mon, 11 Apr 2022 15:19:18 +0800 Subject: [PATCH 08/12] =?UTF-8?q?feat:=20bug=20#52429=20=E5=8F=8A=20?= =?UTF-8?q?=E6=94=BF=E7=AD=96=E5=BE=81=E6=B1=82=E6=84=8F=E8=A7=81=20?= =?UTF-8?q?=E5=A1=AB=E5=86=99=E9=A9=B3=E5=9B=9E=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../policyCommentProcess/DirectorAfter.java | 43 +++++++---- .../DistributionAfter.java | 4 +- .../DockerReviewAfter.java | 74 +++++++++--------- .../EngineerReviewAfter.java | 75 +++++++++---------- .../EngineerRevisionAfter.java | 4 +- .../FillCommentAfter.java | 10 +-- .../policyCommentProcess/LaunchAfter.java | 2 +- .../MinisterReviewAfter.java | 72 ++++++++---------- .../ViceDirectorAfter.java | 72 ++++++++---------- 9 files changed, 176 insertions(+), 180 deletions(-) diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DirectorAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DirectorAfter.java index b86028c4..ba602b0b 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DirectorAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DirectorAfter.java @@ -8,7 +8,9 @@ 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.listener.bussLibrary.BussUtils; import com.ydw.bat.wkflow.util.SpringContextUtil; +import org.activiti.engine.ActivitiException; import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.TaskListener; import org.apache.commons.lang.StringUtils; @@ -57,27 +59,38 @@ public class DirectorAfter implements TaskListener { if(one1!=null){ // one1.setOverTime(OVERTIME); one1.setPrcType("1"); -// one1.setPrcName(prcName); + one1.setPrcName(prcName); one1.setCreatUser(user); one1.setCreatUserName(username); busProcessNameService.saveOrUpdate(one1); } - // 存储当前节点意见 - BusProcessNew busProcessNew = new BusProcessNew(); - busProcessNew.setMsgType("clause"); - busProcessNew.setPId(delegateTask.getProcessInstanceId()); - busProcessNew.setMesg(object.toJSONString()); - busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); - busProcessNew.setTaskId(delegateTask.getId()); - busProcessNew.setCommitText(object.getString("commentText")); - busProcessNew.setFinishFlag("0"); - busProcessNew.setTaskInfo(delegateTask.getName()); - busBean.save(busProcessNew); - if (object.getString("lawsProveChiefVerify")=="0"){ - func2(delegateTask, busBean, object, "0", busProcessNameService); - } + if(StringUtils.isNotBlank(object.getString("actionFlag"))){ + String lawsProveEngineerId2 = JSONObject.parseObject(object.getString("form")).getString("lawsProveEngineerId"); + if ("0".equalsIgnoreCase(object.getString("actionFlag"))) { + BussUtils.endFunAll(delegateTask, prcName,busBean, object, "0", busProcessNameService,"laws2"); + delegateTask.setVariable("lawsProveChiefVerify",0); + + } else { + BusProcessNew busProcessNew = new BusProcessNew(); + busProcessNew.setMsgType("clause"); + busProcessNew.setPId(delegateTask.getProcessInstanceId()); + busProcessNew.setMesg(object.toJSONString()); + busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); + busProcessNew.setFinishFlag("0"); + busProcessNew.setTaskInfo(delegateTask.getName()); + busProcessNew.setUserId(lawsProveEngineerId2); + busProcessNew.setPrcName(prcName); + busBean.save(busProcessNew); + + BussUtils.approvalFunc1(delegateTask, busBean, object, prcName,"1"); + delegateTask.setVariable("lawsProveEngineerId2",lawsProveEngineerId2); + delegateTask.setVariable("lawsProveChiefVerify", 1); + } + }else { + throw new ActivitiException("1#2 提交OR驳回参数不存在"); + } } private String verifyObj(String str){ diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DistributionAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DistributionAfter.java index df2efd86..182d670c 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DistributionAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DistributionAfter.java @@ -66,14 +66,14 @@ public class DistributionAfter implements TaskListener { String username = object.getString("prcCreateUserName"); // object.getString("standName") String standName = ""; - String prcName = "政策征求意见流程-工程师填写意见"; + String prcName = "政策征求意见流程"; QueryWrapper queryWrapper2 = new QueryWrapper(); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ one1.setOverTime(OVERTIME); one1.setPrcType("laws2"); -// one1.setPrcName(prcName); + one1.setPrcName(prcName); one1.setCreatUser(user); one1.setCreatUserName(username); busProcessNameService.saveOrUpdate(one1); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DockerReviewAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DockerReviewAfter.java index 97cac22c..2e79982e 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DockerReviewAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DockerReviewAfter.java @@ -8,7 +8,9 @@ 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.listener.bussLibrary.BussUtils; import com.ydw.bat.wkflow.util.SpringContextUtil; +import org.activiti.engine.ActivitiException; import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.TaskListener; import org.apache.commons.lang.StringUtils; @@ -36,18 +38,17 @@ public class DockerReviewAfter implements TaskListener { delegateTask.setVariable("objectJson",object); List nextUserList = new ArrayList(); - if("0".equals(object.getString("actionFlag"))){ - String lawsProveEngineer = JSONObject.parseObject(object.getString("form")).getString("lawsProveEngineerId"); - if(StringUtils.isNotBlank(lawsProveEngineer)){ - delegateTask.setVariable("lawsProveEngineerId",lawsProveEngineer); - delegateTask.setVariable("responseDockerVerify",0); - - nextUserList= Arrays.asList(lawsProveEngineer.split(",")); - delegateTask.addCandidateUsers(nextUserList); - } - }else { - delegateTask.setVariable("responseDockerVerify",1); - } +// if("0".equals(object.getString("actionFlag"))){ +// String lawsProveEngineer = JSONObject.parseObject(object.getString("form")).getString("lawsProveEngineerId"); +// if(StringUtils.isNotBlank(lawsProveEngineer)){ +// delegateTask.setVariable("lawsProveEngineerId",lawsProveEngineer); +// delegateTask.setVariable("responseDockerVerify",0); +// +// nextUserList.add(object.getString("lawsProveEngineerId")); +// } +// }else { +// delegateTask.setVariable("responseDockerVerify",1); +// } //截止时间 流程描述 创建人 @@ -63,37 +64,40 @@ public class DockerReviewAfter implements TaskListener { if(one1!=null){ // one1.setOverTime(OVERTIME); one1.setPrcType("laws2"); -// one1.setPrcName(prcName); + one1.setPrcName(prcName); one1.setCreatUser(user); one1.setCreatUserName(username); busProcessNameService.saveOrUpdate(one1); } - // 存储当前节点意见 - BusProcessNew busProcessNew = new BusProcessNew(); - busProcessNew.setMsgType("clause"); - busProcessNew.setPId(delegateTask.getProcessInstanceId()); - busProcessNew.setMesg(object.toJSONString()); - busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); - busProcessNew.setTaskId(delegateTask.getId()); - busProcessNew.setCommitText(object.getString("commentText")); - busProcessNew.setFinishFlag("0"); - busProcessNew.setTaskInfo(delegateTask.getName()); - busBean.save(busProcessNew); + if(StringUtils.isNotBlank(object.getString("actionFlag"))){ + String lawsProveEngineer = JSONObject.parseObject(object.getString("form")).getString("lawsProveEngineerId"); + String commentUser = JSONObject.parseObject(object.getString("form")).getString("commentUser"); + if ("0".equalsIgnoreCase(object.getString("actionFlag"))) { - if(nextUserList != null && !nextUserList.isEmpty()){ - for(String nextUser : nextUserList){ + delegateTask.setVariable("lawsProveEngineerId",lawsProveEngineer); + nextUserList.add(lawsProveEngineer); - BusProcessNew busProcessNewNext = new BusProcessNew(); - busProcessNewNext.setMsgType("clause"); - busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); - busProcessNewNext.setMesg(object.toJSONString()); - busProcessNewNext.setFinishFlag("0"); - busProcessNewNext.setTaskInfo("法规工程师修订征求意见"); - busProcessNewNext.setUserId(nextUser); - busProcessNewNext.setPrcName(prcName); - busBean.save(busProcessNewNext); + BussUtils.approvalFunc2(delegateTask, object, prcName, nextUserList); + delegateTask.setVariable("responseDockerVerify", 0); + } else { + BusProcessNew busProcessNew = new BusProcessNew(); + busProcessNew.setMsgType("clause"); + busProcessNew.setPId(delegateTask.getProcessInstanceId()); + busProcessNew.setMesg(object.toJSONString()); + busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); + busProcessNew.setFinishFlag("0"); + busProcessNew.setTaskInfo(delegateTask.getName()); + busProcessNew.setUserId(commentUser); + busProcessNew.setPrcName(prcName); + busBean.save(busProcessNew); + + BussUtils.approvalFunc1(delegateTask, busBean, object, prcName,"1"); + delegateTask.setVariable("commentUser",commentUser); + delegateTask.setVariable("responseDockerVerify", 1); } + }else { + throw new ActivitiException("1#2 提交OR驳回参数不存在"); } } diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerReviewAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerReviewAfter.java index 188274fc..67760ca2 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerReviewAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerReviewAfter.java @@ -9,7 +9,9 @@ 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.listener.bussLibrary.BussUtils; import com.ydw.bat.wkflow.util.SpringContextUtil; +import org.activiti.engine.ActivitiException; import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.TaskListener; import org.apache.commons.lang.StringUtils; @@ -36,44 +38,20 @@ public class EngineerReviewAfter implements TaskListener { List nextUserList = new ArrayList(); - if ("0".equals( object.getString("actionFlag"))){ - JSONObject form = JSONObject.parseObject(object.getString("form")); - String lawsProveEngineer = JSONObject.parseObject(form.getString("form")).getString("lawsProveEngineerId"); - if(StringUtils.isNotBlank(lawsProveEngineer)){ - - JSONArray commentCollectionList =delegateTask.getVariable("commentCollectionList", JSONArray.class); - if (commentCollectionList==null) { - commentCollectionList=new JSONArray(); - } - commentCollectionList.addAll(object.getJSONArray("info")); - delegateTask.setVariable("commentCollectionList",commentCollectionList); - - - delegateTask.setVariable("lawsProveEngineerId2",lawsProveEngineer); - delegateTask.setVariable("lawsProveEngineerVerify",0); - - - nextUserList= Arrays.asList(lawsProveEngineer.split(",")); - delegateTask.addCandidateUsers(nextUserList); - } - } - - - //截止时间 流程描述 创建人 String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); String user = object.getString("prcCreateUser"); String username = object.getString("prcCreateUserName"); // object.getString("standName") String standName = ""; - String prcName = "政策征求意见流程-法规工程师汇总修订"; + String prcName = "政策征求意见流程"; QueryWrapper queryWrapper2 = new QueryWrapper(); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ // one1.setOverTime(OVERTIME); one1.setPrcType("laws2"); -// one1.setPrcName(prcName); + one1.setPrcName(prcName); one1.setCreatUser(user); one1.setCreatUserName(username); busProcessNameService.saveOrUpdate(one1); @@ -103,20 +81,41 @@ public class EngineerReviewAfter implements TaskListener { busBean.save(busProcessNew); } + if(StringUtils.isNotBlank(object.getString("actionFlag"))){ + String lawsProveEngineer = JSONObject.parseObject(object.getString("form")).getString("lawsProveEngineerId"); + String commentUser = JSONObject.parseObject(object.getString("form")).getString("commentUser"); + if ("0".equalsIgnoreCase(object.getString("actionFlag"))) { - 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); + JSONArray commentCollectionList =delegateTask.getVariable("commentCollectionList", JSONArray.class); + if (commentCollectionList==null) { + commentCollectionList=new JSONArray(); + } + commentCollectionList.addAll(object.getJSONArray("info")); + delegateTask.setVariable("commentCollectionList",commentCollectionList); + + delegateTask.setVariable("lawsProveEngineerId2",lawsProveEngineer); + nextUserList.add(lawsProveEngineer); + + BussUtils.approvalFunc2(delegateTask, object, prcName, nextUserList); + delegateTask.setVariable("lawsProveEngineerVerify", 0); + } else { + BusProcessNew busProcessNew = new BusProcessNew(); + busProcessNew.setMsgType("clause"); + busProcessNew.setPId(delegateTask.getProcessInstanceId()); + busProcessNew.setMesg(object.toJSONString()); + busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); + busProcessNew.setFinishFlag("0"); + busProcessNew.setTaskInfo(delegateTask.getName()); + busProcessNew.setUserId(commentUser); + busProcessNew.setPrcName(prcName); + busBean.save(busProcessNew); + + BussUtils.approvalFunc1(delegateTask, busBean, object, prcName,"1"); + delegateTask.setVariable("commentUser",commentUser); + delegateTask.setVariable("lawsProveEngineerVerify", 1); } + }else { + throw new ActivitiException("1#2 提交OR驳回参数不存在"); } } diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerRevisionAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerRevisionAfter.java index d7b97d53..7230b8c8 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerRevisionAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerRevisionAfter.java @@ -54,14 +54,14 @@ public class EngineerRevisionAfter implements TaskListener { String username = object.getString("prcCreateUserName"); // object.getString("standName") String standName = ""; - String prcName = "政策征求意见流程-法规认证部长审核"; + String prcName = "政策征求意见流程"; QueryWrapper queryWrapper2 = new QueryWrapper(); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ // one1.setOverTime(OVERTIME); one1.setPrcType("laws2"); -// one1.setPrcName(prcName); + one1.setPrcName(prcName); one1.setCreatUser(user); one1.setCreatUserName(username); busProcessNameService.saveOrUpdate(one1); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/FillCommentAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/FillCommentAfter.java index 4b41a489..d4d1d07b 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/FillCommentAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/FillCommentAfter.java @@ -40,12 +40,8 @@ public class FillCommentAfter implements TaskListener { delegateTask.setVariable("objectJson",object); List nextUserList = new ArrayList(); if(StringUtils.isNotBlank(responseDocker)){ - - - delegateTask.setVariable("responseDockerId",responseDocker); - nextUserList= Arrays.asList(responseDocker.split(",")); - delegateTask.addCandidateUsers(nextUserList); + nextUserList.add(object.getString("responseDockerId")); } @@ -55,14 +51,14 @@ public class FillCommentAfter implements TaskListener { String username = object.getString("prcCreateUserName"); // object.getString("standName") String standName = ""; - String prcName = "政策征求意见流程-责任对接人审核"; + String prcName = "政策征求意见流程"; QueryWrapper queryWrapper2 = new QueryWrapper(); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ // one1.setOverTime(OVERTIME); one1.setPrcType("laws2"); -// one1.setPrcName(prcName); + one1.setPrcName(prcName); one1.setCreatUser(user); one1.setCreatUserName(username); busProcessNameService.saveOrUpdate(one1); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/LaunchAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/LaunchAfter.java index b7eedeca..b2d59dcc 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/LaunchAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/LaunchAfter.java @@ -49,7 +49,7 @@ public class LaunchAfter implements TaskListener { String username = object.getString("prcCreateUserName"); // object.getString("standName") String standName = ""; - String prcName = "政策征求意见流程-任务分发"; + String prcName = "政策征求意见流程"; QueryWrapper queryWrapper2 = new QueryWrapper(); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/MinisterReviewAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/MinisterReviewAfter.java index 7a20e24f..140c77d7 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/MinisterReviewAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/MinisterReviewAfter.java @@ -1,5 +1,6 @@ package com.ydw.bat.wkflow.listener.policyCommentProcess; +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.entity.BusProcessName; @@ -8,7 +9,9 @@ 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.listener.bussLibrary.BussUtils; import com.ydw.bat.wkflow.util.SpringContextUtil; +import org.activiti.engine.ActivitiException; import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.TaskListener; import org.apache.commons.lang.StringUtils; @@ -37,65 +40,54 @@ public class MinisterReviewAfter implements TaskListener { List nextUserList = new ArrayList(); - if ("0".equals(object.getString("actionFlag"))){ - - JSONObject form = JSONObject.parseObject(object.getString("form")); - String lawsProveViceChief = JSONObject.parseObject(form.getString("form")).getString("lawsProveViceChiefId"); - if(StringUtils.isNotBlank(lawsProveViceChief)){ - - delegateTask.setVariable("lawsProveMinisterVerify",0); - delegateTask.setVariable("lawsProveViceChiefId",lawsProveViceChief); - nextUserList= Arrays.asList(lawsProveViceChief.split(",")); - delegateTask.addCandidateUsers(nextUserList); - } - } - - - //截止时间 流程描述 创建人 String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); String user = object.getString("prcCreateUser"); String username = object.getString("prcCreateUserName"); // object.getString("standName") String standName = ""; - String prcName = "政策征求意见流程-法规认证副总监审核"; + String prcName = "政策征求意见流程"; QueryWrapper queryWrapper2 = new QueryWrapper(); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ // one1.setOverTime(OVERTIME); one1.setPrcType("laws2"); -// one1.setPrcName(prcName); + one1.setPrcName(prcName); one1.setCreatUser(user); one1.setCreatUserName(username); busProcessNameService.saveOrUpdate(one1); } - // 存储当前节点意见 - BusProcessNew busProcessNew = new BusProcessNew(); - busProcessNew.setMsgType("clause"); - busProcessNew.setPId(delegateTask.getProcessInstanceId()); - busProcessNew.setMesg(object.toJSONString()); - busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); - busProcessNew.setTaskId(delegateTask.getId()); - busProcessNew.setCommitText(object.getString("commentText")); - busProcessNew.setFinishFlag("0"); - busProcessNew.setTaskInfo(delegateTask.getName()); - busBean.save(busProcessNew); + if(StringUtils.isNotBlank(object.getString("actionFlag"))){ + String lawsProveViceChief = JSONObject.parseObject(object.getString("form")).getString("lawsProveViceChiefId"); + String lawsProveEngineerId2 = JSONObject.parseObject(object.getString("form")).getString("lawsProveEngineerId"); - 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 ("0".equalsIgnoreCase(object.getString("actionFlag"))) { + + delegateTask.setVariable("lawsProveViceChiefId",lawsProveViceChief); + nextUserList.add(lawsProveViceChief); + + BussUtils.approvalFunc2(delegateTask, object, prcName, nextUserList); + delegateTask.setVariable("lawsProveMinisterVerify", 0); + } else { + BusProcessNew busProcessNew = new BusProcessNew(); + busProcessNew.setMsgType("clause"); + busProcessNew.setPId(delegateTask.getProcessInstanceId()); + busProcessNew.setMesg(object.toJSONString()); + busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); + busProcessNew.setFinishFlag("0"); + busProcessNew.setTaskInfo(delegateTask.getName()); + busProcessNew.setUserId(lawsProveEngineerId2); + busProcessNew.setPrcName(prcName); + busBean.save(busProcessNew); + + BussUtils.approvalFunc1(delegateTask, busBean, object, prcName,"1"); + delegateTask.setVariable("lawsProveEngineerId2",lawsProveEngineerId2); + delegateTask.setVariable("lawsProveMinisterVerify", 1); } + }else { + throw new ActivitiException("1#2 提交OR驳回参数不存在"); } } diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/ViceDirectorAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/ViceDirectorAfter.java index 1ef736a7..cfe241af 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/ViceDirectorAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/ViceDirectorAfter.java @@ -8,7 +8,9 @@ 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.listener.bussLibrary.BussUtils; import com.ydw.bat.wkflow.util.SpringContextUtil; +import org.activiti.engine.ActivitiException; import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.TaskListener; import org.apache.commons.lang.StringUtils; @@ -37,65 +39,55 @@ public class ViceDirectorAfter implements TaskListener { List nextUserList = new ArrayList(); - if ("0".equals(object.getString("actionFlag"))){ - - - JSONObject form = JSONObject.parseObject(object.getString("form")); - String lawsProveChief = JSONObject.parseObject(form.getString("form")).getString("lawsProveChiefId"); - if(StringUtils.isNotBlank(lawsProveChief)){ - - delegateTask.setVariable("lawsProveViceChiefVerify",0); - delegateTask.setVariable("lawsProveChiefId",lawsProveChief); - nextUserList= Arrays.asList(lawsProveChief.split(",")); - delegateTask.addCandidateUsers(nextUserList); - } - } - - //截止时间 流程描述 创建人 String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); String user = object.getString("prcCreateUser"); String username = object.getString("prcCreateUserName"); // object.getString("standName") String standName = ""; - String prcName = "政策征求意见流程-法规认证总监审核"; + String prcName = "政策征求意见流程"; QueryWrapper queryWrapper2 = new QueryWrapper(); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ // one1.setOverTime(OVERTIME); one1.setPrcType("laws2"); -// one1.setPrcName(prcName); + one1.setPrcName(prcName); one1.setCreatUser(user); one1.setCreatUserName(username); busProcessNameService.saveOrUpdate(one1); } - // 存储当前节点意见 - BusProcessNew busProcessNew = new BusProcessNew(); - busProcessNew.setMsgType("clause"); - busProcessNew.setPId(delegateTask.getProcessInstanceId()); - busProcessNew.setMesg(object.toJSONString()); - busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); - busProcessNew.setTaskId(delegateTask.getId()); - busProcessNew.setCommitText(object.getString("commentText")); - busProcessNew.setFinishFlag("0"); - busProcessNew.setTaskInfo(delegateTask.getName()); - busBean.save(busProcessNew); + if(StringUtils.isNotBlank(object.getString("actionFlag"))){ + String lawsProveChief = JSONObject.parseObject(object.getString("form")).getString("lawsProveChiefId"); + String lawsProveEngineerId2 = JSONObject.parseObject(object.getString("form")).getString("lawsProveEngineerId"); - 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 ("0".equalsIgnoreCase(object.getString("actionFlag"))) { + + nextUserList.add(lawsProveChief); + + delegateTask.setVariable("lawsProveChiefId",lawsProveChief); + + BussUtils.approvalFunc2(delegateTask, object, prcName, nextUserList); + delegateTask.setVariable("lawsProveViceChiefVerify", 0); + } else { + BusProcessNew busProcessNew = new BusProcessNew(); + busProcessNew.setMsgType("clause"); + busProcessNew.setPId(delegateTask.getProcessInstanceId()); + busProcessNew.setMesg(object.toJSONString()); + busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); + busProcessNew.setFinishFlag("0"); + busProcessNew.setTaskInfo(delegateTask.getName()); + busProcessNew.setUserId(lawsProveEngineerId2); + busProcessNew.setPrcName(prcName); + busBean.save(busProcessNew); + + BussUtils.approvalFunc1(delegateTask, busBean, object, prcName,"1"); + delegateTask.setVariable("lawsProveEngineerId2",lawsProveEngineerId2); + delegateTask.setVariable("lawsProveViceChiefVerify", 1); } + }else { + throw new ActivitiException("1#2 提交OR驳回参数不存在"); } } From 554bd18946470009c40218a5540e32f495d07fa4 Mon Sep 17 00:00:00 2001 From: super_liu <396572590@qq.com> Date: Mon, 11 Apr 2022 16:09:40 +0800 Subject: [PATCH 09/12] feat: bug #52378 --- .../wkflow/listener/policyCommentProcess/DistributionAfter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DistributionAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DistributionAfter.java index 182d670c..b6aa7adb 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DistributionAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DistributionAfter.java @@ -71,7 +71,7 @@ public class DistributionAfter implements TaskListener { queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ - one1.setOverTime(OVERTIME); +// one1.setOverTime(OVERTIME); one1.setPrcType("laws2"); one1.setPrcName(prcName); one1.setCreatUser(user); From 5982486cab477820edbd0e797f1b24c7bf3485f8 Mon Sep 17 00:00:00 2001 From: yuezhihang Date: Mon, 11 Apr 2022 16:23:16 +0800 Subject: [PATCH 10/12] =?UTF-8?q?=E5=AE=A1=E6=9F=A5=E6=B5=81=E7=A8=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../business_auth/LawsUserInfoService.java | 4 +- .../datas/dto/WG/ProductDeptIssue.java | 6 ++- .../SubViceDirectorAfter.java | 48 ++++++++++++------- 3 files changed, 36 insertions(+), 22 deletions(-) diff --git a/src/main/java/com/ydw/bat/wkflow/business_auth/LawsUserInfoService.java b/src/main/java/com/ydw/bat/wkflow/business_auth/LawsUserInfoService.java index ca93faa9..47137630 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_auth/LawsUserInfoService.java +++ b/src/main/java/com/ydw/bat/wkflow/business_auth/LawsUserInfoService.java @@ -182,8 +182,8 @@ public interface LawsUserInfoService { public ResponseMessage businessDeptIssueSaveBatch(@RequestBody List issue); - @PostMapping("/sarStandUnqualified/productDeptIssue/saveBatch") - public ResponseMessage productDeptIssueSaveBatch(@RequestBody List issue); + @RequestMapping(value = "/sarStandUnqualified/productDeptIssue/saveBatch",method = RequestMethod.POST) + public ResponseMessage productDeptIssue(@RequestBody List issue); } diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/WG/ProductDeptIssue.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/WG/ProductDeptIssue.java index cb61e0cf..505452e1 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/WG/ProductDeptIssue.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/dto/WG/ProductDeptIssue.java @@ -42,16 +42,18 @@ public class ProductDeptIssue implements Serializable { @TableField("current_node") private String currentNode; +// 概念状态 @TableField("conceptual_state") private String conceptualState; - +// 概念时间 @JsonFormat(timezone = "GMT+8", pattern = "yyyy-mm-dd") @TableField("scheduled_issuance_time") private Date scheduledIssuanceTime; - +//概念修订计划 @TableField("revised_plan") private String revisedPlan; +// 其他说明 @TableField("explanation") private String explanation; diff --git a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java index 4a0aafcb..e11d5e04 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java @@ -77,6 +77,7 @@ public class SubViceDirectorAfter implements TaskListener { businessDeptIssue.setDevScheme(object1.getString("devScheme")); businessDeptIssue.setLawNumber(object1.getString("lawCode")); businessDeptIssue.setProductType(object1.getString("dataSource")); + businessDeptIssue.setIsClose("0"); list.add(businessDeptIssue); } } @@ -92,28 +93,39 @@ public class SubViceDirectorAfter implements TaskListener { list = delegateTask.getVariable("v2", List.class); } JSONArray array = object.getJSONArray("infoTableDatas"); - if (array.size() > 0) { - for (Object o : array) { - JSONObject object1 = JSON.parseObject(o.toString()); - ProductDeptIssue productDeptIssue = new ProductDeptIssue(); - productDeptIssue.setDelFlag("0"); - productDeptIssue.setId(String.valueOf(UUID.randomUUID())); - productDeptIssue.setLawId(object1.getString("lawId")); -// businessDeptIssue.setImplRequire(object1.getString("implRequire")); -// businessDeptIssue.setImplTime(object1.getDate("implTime")); -// businessDeptIssue.setCompleteSituation(object1.getString("completeSituation")); -// businessDeptIssue.setSopTime(object1.getDate("sopTime")); -// businessDeptIssue.setLawName(object1.getString("lawName")); -// businessDeptIssue.setConformSituation(object1.getString("conformSituation")); -// businessDeptIssue.setTimeoutSituation(object1.getString("timeoutSituation")); -// businessDeptIssue.setDevScheme(object1.getString("devScheme")); -// businessDeptIssue.setLawNumber(object1.getString("lawCode")); -// businessDeptIssue.setProductType(object1.getString("dataSource")); - list.add(productDeptIssue); + JSONArray tables = object.getJSONArray("table"); + if (array.size() > 0 && tables.size()>0) { + for (Object ta:tables){ + JSONObject object2=JSON.parseObject(ta.toString()); + for (Object o : array) { + JSONObject object1 = JSON.parseObject(o.toString()); + ProductDeptIssue productDeptIssue = new ProductDeptIssue(); + productDeptIssue.setDelFlag("0"); + productDeptIssue.setId(String.valueOf(UUID.randomUUID())); + productDeptIssue.setLawId(object1.getString("lawId")); + productDeptIssue.setLawsNumber(object1.getString("lawCode")); + productDeptIssue.setLawsName(object1.getString("lawName")); + productDeptIssue.setProductBusiness(object2.getString("yewu")); + productDeptIssue.setPlatform(object2.getString("pingtai")); + productDeptIssue.setPojName(object2.getString("xiangmu")); + productDeptIssue.setPojDescription(object2.getString("xiangmumiaoshu")); + productDeptIssue.setCurrentNode(object2.getString("dangqianjiedian")); + productDeptIssue.setConceptualState(object2.getString("gainianzhuangtai")); + productDeptIssue.setScheduledIssuanceTime(object2.getDate("gainianzhuangtaiDate")); + productDeptIssue.setRevisedPlan(object2.getString("gainianxiudingjihua")); + productDeptIssue.setExplanation(object2.getString("qitashuoming")); + productDeptIssue.setResponseDept(object2.getString("zerenren")); + productDeptIssue.setIsClose("0"); + list.add(productDeptIssue); + } } + } delegateTask.setVariable("v2", list); + if (i >= delegateTask.getVariable("responseUserIdList", List.class).size()) { + lawsUserInfoService.productDeptIssue(list); + } } //流程结束 From 0e2ace7b7c654cae280cbdb2970a46c045d5c69e Mon Sep 17 00:00:00 2001 From: super_liu <396572590@qq.com> Date: Tue, 12 Apr 2022 16:16:01 +0800 Subject: [PATCH 11/12] feat: There is no way the, bug #52552 #52542 --- .../policyCommentProcess/DirectorAfter.java | 4 +- .../DockerReviewAfter.java | 6 +- .../EngineerReviewAfter.java | 73 ++++++++++++++----- .../EngineerRevisionAfter.java | 6 +- .../FillCommentAfter.java | 2 +- .../MinisterReviewAfter.java | 4 +- .../ViceDirectorAfter.java | 4 +- 7 files changed, 67 insertions(+), 32 deletions(-) diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DirectorAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DirectorAfter.java index ba602b0b..2d1c59f6 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DirectorAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DirectorAfter.java @@ -58,7 +58,7 @@ public class DirectorAfter implements TaskListener { BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); if(one1!=null){ // one1.setOverTime(OVERTIME); - one1.setPrcType("1"); + one1.setPrcType("laws2"); one1.setPrcName(prcName); one1.setCreatUser(user); one1.setCreatUserName(username); @@ -66,7 +66,7 @@ public class DirectorAfter implements TaskListener { } if(StringUtils.isNotBlank(object.getString("actionFlag"))){ - String lawsProveEngineerId2 = JSONObject.parseObject(object.getString("form")).getString("lawsProveEngineerId"); + String lawsProveEngineerId2 = object.getString("lawsProveEngineerId"); if ("0".equalsIgnoreCase(object.getString("actionFlag"))) { BussUtils.endFunAll(delegateTask, prcName,busBean, object, "0", busProcessNameService,"laws2"); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DockerReviewAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DockerReviewAfter.java index 2e79982e..ce300c29 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DockerReviewAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/DockerReviewAfter.java @@ -57,7 +57,7 @@ public class DockerReviewAfter implements TaskListener { String username = object.getString("prcCreateUserName"); // object.getString("standName") String standName = ""; - String prcName = "政策征求意见流程-法规工程师单条审核"; + String prcName = "政策征求意见流程"; QueryWrapper queryWrapper2 = new QueryWrapper(); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); @@ -71,8 +71,8 @@ public class DockerReviewAfter implements TaskListener { } if(StringUtils.isNotBlank(object.getString("actionFlag"))){ - String lawsProveEngineer = JSONObject.parseObject(object.getString("form")).getString("lawsProveEngineerId"); - String commentUser = JSONObject.parseObject(object.getString("form")).getString("commentUser"); + String lawsProveEngineer = object.getString("lawsProveEngineerId"); + String commentUser = object.getString("commentUser"); if ("0".equalsIgnoreCase(object.getString("actionFlag"))) { delegateTask.setVariable("lawsProveEngineerId",lawsProveEngineer); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerReviewAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerReviewAfter.java index 67760ca2..70e5fc05 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerReviewAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerReviewAfter.java @@ -67,25 +67,27 @@ public class EngineerReviewAfter implements TaskListener { delegateTask.setVariable("count",commentCount); Collection commentUserList=delegateTask.getVariable("commentUserList",Collection.class); - if(commentCount>=commentUserList.size()){ - // 存储当前节点意见 - BusProcessNew busProcessNew = new BusProcessNew(); - busProcessNew.setMsgType("clause"); - busProcessNew.setPId(delegateTask.getProcessInstanceId()); - busProcessNew.setMesg(object.toJSONString()); - busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); - busProcessNew.setTaskId(delegateTask.getId()); - busProcessNew.setCommitText(object.getString("commentText")); - busProcessNew.setFinishFlag("0"); - busProcessNew.setTaskInfo(delegateTask.getName()); - busBean.save(busProcessNew); - } + // 存储当前节点意见 + BusProcessNew busProcessNewHis = new BusProcessNew(); + busProcessNewHis.setMsgType("clause"); + busProcessNewHis.setPId(delegateTask.getProcessInstanceId()); + busProcessNewHis.setMesg(object.toJSONString()); + busProcessNewHis.setTaskInfo(delegateTask.getTaskDefinitionKey()); + busProcessNewHis.setTaskId(delegateTask.getId()); + busProcessNewHis.setCommitText(object.getString("commentText")); + busProcessNewHis.setFinishFlag("0"); + busProcessNewHis.setTaskInfo(delegateTask.getName()); + busBean.save(busProcessNewHis); + if(StringUtils.isNotBlank(object.getString("actionFlag"))){ - String lawsProveEngineer = JSONObject.parseObject(object.getString("form")).getString("lawsProveEngineerId"); - String commentUser = JSONObject.parseObject(object.getString("form")).getString("commentUser"); + String lawsProveEngineer = object.getString("lawsProveEngineerId"); + String commentUser = object.getString("commentUser"); if ("0".equalsIgnoreCase(object.getString("actionFlag"))) { + delegateTask.setVariable("lawsProveEngineerId2",lawsProveEngineer); + nextUserList.add(lawsProveEngineer); + JSONArray commentCollectionList =delegateTask.getVariable("commentCollectionList", JSONArray.class); if (commentCollectionList==null) { commentCollectionList=new JSONArray(); @@ -93,10 +95,26 @@ public class EngineerReviewAfter implements TaskListener { commentCollectionList.addAll(object.getJSONArray("info")); delegateTask.setVariable("commentCollectionList",commentCollectionList); - delegateTask.setVariable("lawsProveEngineerId2",lawsProveEngineer); - nextUserList.add(lawsProveEngineer); - BussUtils.approvalFunc2(delegateTask, object, prcName, nextUserList); + if(commentCount>=commentUserList.size()){ + funEnd(delegateTask, busBean, queryWrapper, object, prcName); + if(!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); + } + } + }else { + funEnd(delegateTask, busBean, queryWrapper, object, prcName); + } delegateTask.setVariable("lawsProveEngineerVerify", 0); } else { BusProcessNew busProcessNew = new BusProcessNew(); @@ -119,6 +137,25 @@ public class EngineerReviewAfter implements TaskListener { } } + private void funEnd(DelegateTask delegateTask, IBusProcessNewService busBean, QueryWrapper queryWrapper, JSONObject object, String prcName) { + QueryWrapper queryWrapper1 = new QueryWrapper(); + queryWrapper1.eq("TASK_ID", delegateTask.getId()); + queryWrapper.isNotNull("PRC_NAME"); + List list = busBean.list(queryWrapper1); + if (!list.isEmpty()) { + BusProcessNew one2 = list.get(0); + one2.setMsgType("clause"); + one2.setPId(delegateTask.getProcessInstanceId()); + one2.setMesg(object.toJSONString()); + one2.setFinishFlag("0"); + one2.setTaskInfo(delegateTask.getName()); + one2.setPrcName(prcName); + one2.setCommitFlag("0"); + one2.setCommitText(object.getString("commentText")); + busBean.saveOrUpdate(one2); + } + } + private String verifyObj(String str){ return (str == null || str.equals("")) ? "" : str; } diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerRevisionAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerRevisionAfter.java index 7230b8c8..cf77ba09 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerRevisionAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/EngineerRevisionAfter.java @@ -38,13 +38,11 @@ public class EngineerRevisionAfter implements TaskListener { List nextUserList = new ArrayList(); - JSONObject form = JSONObject.parseObject(object.getString("form")); - String lawsProveMinister = JSONObject.parseObject(form.getString("form")).getString("lawsProveMinisterId"); + String lawsProveMinister = object.getString("lawsProveMinisterId"); if(StringUtils.isNotBlank(lawsProveMinister)){ delegateTask.setVariable("lawsProveMinisterId",lawsProveMinister); - nextUserList= Arrays.asList(lawsProveMinister.split(",")); - delegateTask.addCandidateUsers(nextUserList); + nextUserList.add(lawsProveMinister); } diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/FillCommentAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/FillCommentAfter.java index d4d1d07b..404ef84d 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/FillCommentAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/FillCommentAfter.java @@ -35,7 +35,7 @@ public class FillCommentAfter implements TaskListener { Datas datas = datasService.getOne(queryWrapper); JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); - String responseDocker = JSONObject.parseObject(object.getString("form")).getString("responseDockerId"); + String responseDocker = object.getString("responseDockerId"); delegateTask.setVariable("objectJson",object); List nextUserList = new ArrayList(); diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/MinisterReviewAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/MinisterReviewAfter.java index 140c77d7..0a87c4aa 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/MinisterReviewAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/MinisterReviewAfter.java @@ -60,8 +60,8 @@ public class MinisterReviewAfter implements TaskListener { } if(StringUtils.isNotBlank(object.getString("actionFlag"))){ - String lawsProveViceChief = JSONObject.parseObject(object.getString("form")).getString("lawsProveViceChiefId"); - String lawsProveEngineerId2 = JSONObject.parseObject(object.getString("form")).getString("lawsProveEngineerId"); + String lawsProveViceChief = object.getString("lawsProveViceChiefId"); + String lawsProveEngineerId2 = object.getString("lawsProveEngineerId"); if ("0".equalsIgnoreCase(object.getString("actionFlag"))) { diff --git a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/ViceDirectorAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/ViceDirectorAfter.java index cfe241af..bae4c86d 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/ViceDirectorAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/policyCommentProcess/ViceDirectorAfter.java @@ -59,8 +59,8 @@ public class ViceDirectorAfter implements TaskListener { } if(StringUtils.isNotBlank(object.getString("actionFlag"))){ - String lawsProveChief = JSONObject.parseObject(object.getString("form")).getString("lawsProveChiefId"); - String lawsProveEngineerId2 = JSONObject.parseObject(object.getString("form")).getString("lawsProveEngineerId"); + String lawsProveChief = object.getString("lawsProveChiefId"); + String lawsProveEngineerId2 = object.getString("lawsProveEngineerId"); if ("0".equalsIgnoreCase(object.getString("actionFlag"))) { From 5b1f5663bf665bd2ef6ea8ce6ea17fc1e647ffdf Mon Sep 17 00:00:00 2001 From: yuezhihang Date: Tue, 12 Apr 2022 17:42:35 +0800 Subject: [PATCH 12/12] =?UTF-8?q?=E5=AE=A1=E6=9F=A5=E6=B5=81=E7=A8=8B=20?= =?UTF-8?q?=20=E6=96=B0=E5=A2=9E=E8=B4=A3=E4=BB=BB=E4=BA=BA=E5=AD=97?= =?UTF-8?q?=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java index e11d5e04..cec49359 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/KCSTPReviewProcess/SubViceDirectorAfter.java @@ -77,6 +77,7 @@ public class SubViceDirectorAfter implements TaskListener { businessDeptIssue.setDevScheme(object1.getString("devScheme")); businessDeptIssue.setLawNumber(object1.getString("lawCode")); businessDeptIssue.setProductType(object1.getString("dataSource")); + businessDeptIssue.setResponsePeople(object1.getString("zerenren")); businessDeptIssue.setIsClose("0"); list.add(businessDeptIssue); }