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

fix: 政策征求意见流程BUG修改

Browse Source
This commit is contained in:
wxyclub
2024-07-01 11:01:11 +08:00
parent 4e782dcd17
commit 508e966fad
28 changed files with 502 additions and 174 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess10After.java
+40 -12
View File
@@ -1,6 +1,7 @@
package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess; package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
import com.ydw.bat.wkflow.business_main.datas.entity.Datas; import com.ydw.bat.wkflow.business_main.datas.entity.Datas;
@@ -11,8 +12,11 @@ import com.ydw.bat.wkflow.util.SpringContextUtil;
import com.ydw.bat.wkflow.util.enums.ApprovalFlagEnum; import com.ydw.bat.wkflow.util.enums.ApprovalFlagEnum;
import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener; import org.activiti.engine.delegate.TaskListener;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import java.util.List;
public class PolicySolicitOpinionProcess10After implements TaskListener { public class PolicySolicitOpinionProcess10After implements TaskListener {
@Override @Override
public void notify(DelegateTask delegateTask) { public void notify(DelegateTask delegateTask) {
@@ -25,6 +29,19 @@ public class PolicySolicitOpinionProcess10After implements TaskListener {
JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
JSONObject jsonForm = object.getJSONObject("form"); JSONObject jsonForm = object.getJSONObject("form");
Object lawsName = jsonForm.get("lawsName");
Object lawsNo = jsonForm.get("lawsNo");
String lawsInfoName = "";
if(lawsName != null && lawsNo != null){
String number = "《" + lawsNo +"-";
String name = lawsName +"》-";
if(StringUtils.isNotBlank(name) && StringUtils.isNotBlank(number)){
lawsInfoName = number + name;
}
}
String prcName = lawsInfoName + "征求意见";
String approvalFlag = jsonForm.getString("approvalFlag"); String approvalFlag = jsonForm.getString("approvalFlag");
if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) { if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) {
// 责任部门 子流程总数 // 责任部门 子流程总数
@@ -45,7 +62,8 @@ public class PolicySolicitOpinionProcess10After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setTaskInfo("管理员");
busProcessNewNext.setUserId(glyUserId); busProcessNewNext.setUserId(glyUserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
} }
@@ -57,22 +75,32 @@ public class PolicySolicitOpinionProcess10After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("责任对接人汇总");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(djrUserId); busProcessNewNext.setUserId(djrUserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
} }
// 存储当前节点意见 // 存储当前节点意见
BusProcessNew busProcessNew = new BusProcessNew(); LambdaQueryWrapper<BusProcessNew> queryWrapper1 = new LambdaQueryWrapper<>();
busProcessNew.setMsgType("clause"); queryWrapper1.eq(BusProcessNew::getTaskId,delegateTask.getId());
busProcessNew.setPId(delegateTask.getProcessInstanceId()); List<BusProcessNew> list = busBean.list(queryWrapper1);
busProcessNew.setMesg(object.toJSONString()); if (CollectionUtils.isNotEmpty(list)) {
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); BusProcessNew busProcessNew = list.get(0);
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busBean.saveOrUpdate(busProcessNew);
busProcessNew.setTaskInfo(delegateTask.getName()); }
busBean.save(busProcessNew); // 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);
delegateTask.setVariable("approvalFlag",approvalFlag); delegateTask.setVariable("approvalFlag",approvalFlag);
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess10Before.java
+1 -1
View File
@@ -19,7 +19,7 @@ public class PolicySolicitOpinionProcess10Before implements TaskListener {
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("TASK_ID"); queryWrapper.isNull("TASK_ID");
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
queryWrapper.eq("USER_ID",delegateTask.getAssignee()); queryWrapper.eq("USER_ID",delegateTask.getAssignee());
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess11After.java
+37 -12
View File
@@ -1,6 +1,7 @@
package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess; package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
import com.ydw.bat.wkflow.business_main.datas.entity.Datas; import com.ydw.bat.wkflow.business_main.datas.entity.Datas;
@@ -32,6 +33,19 @@ public class PolicySolicitOpinionProcess11After implements TaskListener {
JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
JSONObject jsonForm = object.getJSONObject("form"); JSONObject jsonForm = object.getJSONObject("form");
Object lawsName = jsonForm.get("lawsName");
Object lawsNo = jsonForm.get("lawsNo");
String lawsInfoName = "";
if(lawsName != null && lawsNo != null){
String number = "《" + lawsNo +"-";
String name = lawsName +"》-";
if(StringUtils.isNotBlank(name) && StringUtils.isNotBlank(number)){
lawsInfoName = number + name;
}
}
String prcName = lawsInfoName + "征求意见";
String approvalFlag = jsonForm.getString("approvalFlag"); String approvalFlag = jsonForm.getString("approvalFlag");
if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) { if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) {
String shr2UserIds = jsonForm.getString("shr2UserIds"); String shr2UserIds = jsonForm.getString("shr2UserIds");
@@ -45,7 +59,8 @@ public class PolicySolicitOpinionProcess11After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("审核");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(nextUser); busProcessNewNext.setUserId(nextUser);
addBusProcessNewList.add(busProcessNewNext); addBusProcessNewList.add(busProcessNewNext);
} }
@@ -70,7 +85,8 @@ public class PolicySolicitOpinionProcess11After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("批准");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(pzr1UserId); busProcessNewNext.setUserId(pzr1UserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
@@ -78,16 +94,25 @@ public class PolicySolicitOpinionProcess11After implements TaskListener {
} }
// 存储当前节点意见 // 存储当前节点意见
BusProcessNew busProcessNew = new BusProcessNew(); LambdaQueryWrapper<BusProcessNew> queryWrapper1 = new LambdaQueryWrapper<>();
busProcessNew.setMsgType("clause"); queryWrapper1.eq(BusProcessNew::getTaskId,delegateTask.getId());
busProcessNew.setPId(delegateTask.getProcessInstanceId()); List<BusProcessNew> list = busBean.list(queryWrapper1);
busProcessNew.setMesg(object.toJSONString()); if (CollectionUtils.isNotEmpty(list)) {
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); BusProcessNew busProcessNew = list.get(0);
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busBean.saveOrUpdate(busProcessNew);
busProcessNew.setTaskInfo(delegateTask.getName()); }
busBean.save(busProcessNew); // 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);
delegateTask.setVariable("approvalFlag", approvalFlag); delegateTask.setVariable("approvalFlag", approvalFlag);
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess11Before.java
+1 -1
View File
@@ -18,7 +18,7 @@ public class PolicySolicitOpinionProcess11Before implements TaskListener {
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("TASK_ID"); queryWrapper.isNull("TASK_ID");
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
queryWrapper.eq("USER_ID",delegateTask.getAssignee()); queryWrapper.eq("USER_ID",delegateTask.getAssignee());
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess12After.java
+37 -12
View File
@@ -1,6 +1,7 @@
package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess; package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService; import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
@@ -35,6 +36,19 @@ public class PolicySolicitOpinionProcess12After implements TaskListener {
JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
JSONObject jsonForm = object.getJSONObject("form"); JSONObject jsonForm = object.getJSONObject("form");
Object lawsName = jsonForm.get("lawsName");
Object lawsNo = jsonForm.get("lawsNo");
String lawsInfoName = "";
if(lawsName != null && lawsNo != null){
String number = "《" + lawsNo +"-";
String name = lawsName +"》-";
if(StringUtils.isNotBlank(name) && StringUtils.isNotBlank(number)){
lawsInfoName = number + name;
}
}
String prcName = lawsInfoName + "征求意见";
String approvalFlag = jsonForm.getString("approvalFlag"); String approvalFlag = jsonForm.getString("approvalFlag");
if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) { if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) {
int shr2UserPassCount = (int) delegateTask.getVariable("shr2UserPassCount"); int shr2UserPassCount = (int) delegateTask.getVariable("shr2UserPassCount");
@@ -68,7 +82,8 @@ public class PolicySolicitOpinionProcess12After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("会签");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(nextUser); busProcessNewNext.setUserId(nextUser);
addBusProcessNewList.add(busProcessNewNext); addBusProcessNewList.add(busProcessNewNext);
} }
@@ -88,7 +103,8 @@ public class PolicySolicitOpinionProcess12After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("管理员");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(glyUserId); busProcessNewNext.setUserId(glyUserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
@@ -103,16 +119,25 @@ public class PolicySolicitOpinionProcess12After implements TaskListener {
policySolicitOpinionEOService.batchInsert(object); policySolicitOpinionEOService.batchInsert(object);
// 存储当前节点意见 // 存储当前节点意见
BusProcessNew busProcessNew = new BusProcessNew(); LambdaQueryWrapper<BusProcessNew> queryWrapper1 = new LambdaQueryWrapper<>();
busProcessNew.setMsgType("clause"); queryWrapper1.eq(BusProcessNew::getTaskId,delegateTask.getId());
busProcessNew.setPId(delegateTask.getProcessInstanceId()); List<BusProcessNew> list = busBean.list(queryWrapper1);
busProcessNew.setMesg(object.toJSONString()); if (CollectionUtils.isNotEmpty(list)) {
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); BusProcessNew busProcessNew = list.get(0);
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busBean.saveOrUpdate(busProcessNew);
busProcessNew.setTaskInfo(delegateTask.getName()); }
busBean.save(busProcessNew); // 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);
delegateTask.setVariable("approvalFlag", approvalFlag); delegateTask.setVariable("approvalFlag", approvalFlag);
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess12Before.java
+1 -1
View File
@@ -18,7 +18,7 @@ public class PolicySolicitOpinionProcess12Before implements TaskListener {
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("TASK_ID"); queryWrapper.isNull("TASK_ID");
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
queryWrapper.eq("USER_ID",delegateTask.getAssignee()); queryWrapper.eq("USER_ID",delegateTask.getAssignee());
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess13After.java
+37 -12
View File
@@ -1,6 +1,7 @@
package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess; package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService; import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
@@ -32,6 +33,19 @@ public class PolicySolicitOpinionProcess13After implements TaskListener {
JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
JSONObject jsonForm = object.getJSONObject("form"); JSONObject jsonForm = object.getJSONObject("form");
Object lawsName = jsonForm.get("lawsName");
Object lawsNo = jsonForm.get("lawsNo");
String lawsInfoName = "";
if(lawsName != null && lawsNo != null){
String number = "《" + lawsNo +"-";
String name = lawsName +"》-";
if(StringUtils.isNotBlank(name) && StringUtils.isNotBlank(number)){
lawsInfoName = number + name;
}
}
String prcName = lawsInfoName + "征求意见";
String approvalFlag = jsonForm.getString("approvalFlag"); String approvalFlag = jsonForm.getString("approvalFlag");
if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) { if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) {
int hqrUserPassCount = (int) delegateTask.getVariable("hqrUserPassCount"); int hqrUserPassCount = (int) delegateTask.getVariable("hqrUserPassCount");
@@ -53,7 +67,8 @@ public class PolicySolicitOpinionProcess13After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("审定");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(nextUser); busProcessNewNext.setUserId(nextUser);
addBusProcessNewList.add(busProcessNewNext); addBusProcessNewList.add(busProcessNewNext);
} }
@@ -74,7 +89,8 @@ public class PolicySolicitOpinionProcess13After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("管理员");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(glyUserId); busProcessNewNext.setUserId(glyUserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
@@ -83,16 +99,25 @@ public class PolicySolicitOpinionProcess13After implements TaskListener {
} }
// 存储当前节点意见 // 存储当前节点意见
BusProcessNew busProcessNew = new BusProcessNew(); LambdaQueryWrapper<BusProcessNew> queryWrapper1 = new LambdaQueryWrapper<>();
busProcessNew.setMsgType("clause"); queryWrapper1.eq(BusProcessNew::getTaskId,delegateTask.getId());
busProcessNew.setPId(delegateTask.getProcessInstanceId()); List<BusProcessNew> list = busBean.list(queryWrapper1);
busProcessNew.setMesg(object.toJSONString()); if (CollectionUtils.isNotEmpty(list)) {
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); BusProcessNew busProcessNew = list.get(0);
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busBean.saveOrUpdate(busProcessNew);
busProcessNew.setTaskInfo(delegateTask.getName()); }
busBean.save(busProcessNew); // 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);
delegateTask.setVariable("approvalFlag", approvalFlag); delegateTask.setVariable("approvalFlag", approvalFlag);
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess13Before.java
+1 -1
View File
@@ -18,7 +18,7 @@ public class PolicySolicitOpinionProcess13Before implements TaskListener {
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("TASK_ID"); queryWrapper.isNull("TASK_ID");
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
queryWrapper.eq("USER_ID",delegateTask.getAssignee()); queryWrapper.eq("USER_ID",delegateTask.getAssignee());
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess14After.java
+40 -12
View File
@@ -1,6 +1,7 @@
package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess; package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService; import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
@@ -12,8 +13,11 @@ import com.ydw.bat.wkflow.util.SpringContextUtil;
import com.ydw.bat.wkflow.util.enums.ApprovalFlagEnum; import com.ydw.bat.wkflow.util.enums.ApprovalFlagEnum;
import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener; import org.activiti.engine.delegate.TaskListener;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import java.util.List;
/** /**
* 审定后 * 审定后
*/ */
@@ -30,6 +34,19 @@ public class PolicySolicitOpinionProcess14After implements TaskListener {
JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
JSONObject jsonForm = object.getJSONObject("form"); JSONObject jsonForm = object.getJSONObject("form");
Object lawsName = jsonForm.get("lawsName");
Object lawsNo = jsonForm.get("lawsNo");
String lawsInfoName = "";
if(lawsName != null && lawsNo != null){
String number = "《" + lawsNo +"-";
String name = lawsName +"》-";
if(StringUtils.isNotBlank(name) && StringUtils.isNotBlank(number)){
lawsInfoName = number + name;
}
}
String prcName = lawsInfoName + "征求意见";
String approvalFlag = jsonForm.getString("approvalFlag"); String approvalFlag = jsonForm.getString("approvalFlag");
if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) { if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) {
int sdr2UserPassCount = (int) delegateTask.getVariable("sdr2UserPassCount"); int sdr2UserPassCount = (int) delegateTask.getVariable("sdr2UserPassCount");
@@ -48,7 +65,8 @@ public class PolicySolicitOpinionProcess14After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("批准");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(pzr2UserId); busProcessNewNext.setUserId(pzr2UserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
delegateTask.setVariable("pzr2UserId", pzr2UserId); delegateTask.setVariable("pzr2UserId", pzr2UserId);
@@ -61,7 +79,8 @@ public class PolicySolicitOpinionProcess14After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("批准");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(glyUserId); busProcessNewNext.setUserId(glyUserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
@@ -70,16 +89,25 @@ public class PolicySolicitOpinionProcess14After implements TaskListener {
} }
// 存储当前节点意见 // 存储当前节点意见
BusProcessNew busProcessNew = new BusProcessNew(); LambdaQueryWrapper<BusProcessNew> queryWrapper1 = new LambdaQueryWrapper<>();
busProcessNew.setMsgType("clause"); queryWrapper1.eq(BusProcessNew::getTaskId,delegateTask.getId());
busProcessNew.setPId(delegateTask.getProcessInstanceId()); List<BusProcessNew> list = busBean.list(queryWrapper1);
busProcessNew.setMesg(object.toJSONString()); if (CollectionUtils.isNotEmpty(list)) {
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); BusProcessNew busProcessNew = list.get(0);
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busBean.saveOrUpdate(busProcessNew);
busProcessNew.setTaskInfo(delegateTask.getName()); }
busBean.save(busProcessNew); // 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);
delegateTask.setVariable("approvalFlag",approvalFlag); delegateTask.setVariable("approvalFlag",approvalFlag);
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess14Before.java
+1 -1
View File
@@ -18,7 +18,7 @@ public class PolicySolicitOpinionProcess14Before implements TaskListener {
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("TASK_ID"); queryWrapper.isNull("TASK_ID");
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
queryWrapper.eq("USER_ID",delegateTask.getAssignee()); queryWrapper.eq("USER_ID",delegateTask.getAssignee());
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess15After.java
+37 -12
View File
@@ -1,6 +1,7 @@
package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess; package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
import com.ydw.bat.wkflow.business_main.datas.entity.Datas; import com.ydw.bat.wkflow.business_main.datas.entity.Datas;
@@ -33,6 +34,19 @@ public class PolicySolicitOpinionProcess15After implements TaskListener {
JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
JSONObject jsonForm = object.getJSONObject("form"); JSONObject jsonForm = object.getJSONObject("form");
Object lawsName = jsonForm.get("lawsName");
Object lawsNo = jsonForm.get("lawsNo");
String lawsInfoName = "";
if(lawsName != null && lawsNo != null){
String number = "《" + lawsNo +"-";
String name = lawsName +"》-";
if(StringUtils.isNotBlank(name) && StringUtils.isNotBlank(number)){
lawsInfoName = number + name;
}
}
String prcName = lawsInfoName + "征求意见";
String approvalFlag = jsonForm.getString("approvalFlag"); String approvalFlag = jsonForm.getString("approvalFlag");
if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) { if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) {
String csrUserIds = jsonForm.getString("csrUserIds"); String csrUserIds = jsonForm.getString("csrUserIds");
@@ -46,7 +60,8 @@ public class PolicySolicitOpinionProcess15After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("抄送");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(nextUser); busProcessNewNext.setUserId(nextUser);
addBusProcessNewList.add(busProcessNewNext); addBusProcessNewList.add(busProcessNewNext);
} }
@@ -63,7 +78,8 @@ public class PolicySolicitOpinionProcess15After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("管理员");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(glyUserId); busProcessNewNext.setUserId(glyUserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
@@ -71,16 +87,25 @@ public class PolicySolicitOpinionProcess15After implements TaskListener {
} }
// 存储当前节点意见 // 存储当前节点意见
BusProcessNew busProcessNew = new BusProcessNew(); LambdaQueryWrapper<BusProcessNew> queryWrapper1 = new LambdaQueryWrapper<>();
busProcessNew.setMsgType("clause"); queryWrapper1.eq(BusProcessNew::getTaskId,delegateTask.getId());
busProcessNew.setPId(delegateTask.getProcessInstanceId()); List<BusProcessNew> list = busBean.list(queryWrapper1);
busProcessNew.setMesg(object.toJSONString()); if (CollectionUtils.isNotEmpty(list)) {
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); BusProcessNew busProcessNew = list.get(0);
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busBean.saveOrUpdate(busProcessNew);
busProcessNew.setTaskInfo(delegateTask.getName()); }
busBean.save(busProcessNew); // 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);
delegateTask.setVariable("approvalFlag", approvalFlag); delegateTask.setVariable("approvalFlag", approvalFlag);
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess15Before.java
+1 -1
View File
@@ -18,7 +18,7 @@ public class PolicySolicitOpinionProcess15Before implements TaskListener {
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("TASK_ID"); queryWrapper.isNull("TASK_ID");
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
queryWrapper.eq("USER_ID",delegateTask.getAssignee()); queryWrapper.eq("USER_ID",delegateTask.getAssignee());
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess16After.java
+22 -11
View File
@@ -1,6 +1,7 @@
package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess; package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService; import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessName; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessName;
@@ -14,6 +15,7 @@ import com.ydw.bat.wkflow.util.SpringContextUtil;
import com.ydw.bat.wkflow.util.enums.FlowTypeEnum; import com.ydw.bat.wkflow.util.enums.FlowTypeEnum;
import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener; import org.activiti.engine.delegate.TaskListener;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
@@ -73,7 +75,7 @@ public class PolicySolicitOpinionProcess16After implements TaskListener {
); );
if (!existTaskFlag) { if (!existTaskFlag) {
String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
QueryWrapper bpnQueryWrap = new QueryWrapper(); QueryWrapper<BusProcessName> bpnQueryWrap = new QueryWrapper<>();
bpnQueryWrap.eq("PRC_ID", delegateTask.getProcessInstanceId()); bpnQueryWrap.eq("PRC_ID", delegateTask.getProcessInstanceId());
BusProcessName bpn = busProcessNameService.getOne(bpnQueryWrap); BusProcessName bpn = busProcessNameService.getOne(bpnQueryWrap);
if (bpn != null) { if (bpn != null) {
@@ -83,15 +85,24 @@ public class PolicySolicitOpinionProcess16After implements TaskListener {
} }
// 存储当前节点意见 // 存储当前节点意见
BusProcessNew busProcessNew = new BusProcessNew(); LambdaQueryWrapper<BusProcessNew> queryWrapper1 = new LambdaQueryWrapper<>();
busProcessNew.setMsgType("clause"); queryWrapper1.eq(BusProcessNew::getTaskId,delegateTask.getId());
busProcessNew.setPId(delegateTask.getProcessInstanceId()); List<BusProcessNew> list = busBean.list(queryWrapper1);
busProcessNew.setMesg(object.toJSONString()); if (CollectionUtils.isNotEmpty(list)) {
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); BusProcessNew busProcessNew = list.get(0);
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busBean.saveOrUpdate(busProcessNew);
busProcessNew.setTaskInfo(delegateTask.getName()); }
busBean.save(busProcessNew); // 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);
} }
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess16Before.java
+1 -1
View File
@@ -18,7 +18,7 @@ public class PolicySolicitOpinionProcess16Before implements TaskListener {
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("TASK_ID"); queryWrapper.isNull("TASK_ID");
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
queryWrapper.eq("USER_ID",delegateTask.getAssignee()); queryWrapper.eq("USER_ID",delegateTask.getAssignee());
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess1After.java
+5 -4
View File
@@ -53,7 +53,7 @@ public class PolicySolicitOpinionProcess1After implements TaskListener {
} }
} }
String prcName = lawsInfoName + "征求意见"; String prcName = lawsInfoName + "征求意见";
QueryWrapper queryWrapper2 = new QueryWrapper(); QueryWrapper<BusProcessName> queryWrapper2 = new QueryWrapper<>();
queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId()); queryWrapper2.eq("PRC_ID",delegateTask.getProcessInstanceId());
BusProcessName one1 = busProcessNameService.getOne(queryWrapper2); BusProcessName one1 = busProcessNameService.getOne(queryWrapper2);
if(one1!=null){ if(one1!=null){
@@ -72,11 +72,11 @@ public class PolicySolicitOpinionProcess1After implements TaskListener {
busProcessNew.setMsgType("clause"); busProcessNew.setMsgType("clause");
busProcessNew.setPId(delegateTask.getProcessInstanceId()); busProcessNew.setPId(delegateTask.getProcessInstanceId());
busProcessNew.setMesg(object.toJSONString()); busProcessNew.setMesg(object.toJSONString());
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busProcessNew.setFinishFlag("0");
busProcessNew.setTaskInfo(delegateTask.getName()); busProcessNew.setTaskInfo(delegateTask.getName());
busProcessNew.setPrcName(prcName);
busBean.save(busProcessNew); busBean.save(busProcessNew);
if(CollectionUtils.isNotEmpty(nextUserList)){ if(CollectionUtils.isNotEmpty(nextUserList)){
@@ -86,9 +86,10 @@ public class PolicySolicitOpinionProcess1After implements TaskListener {
busProcessNewNext.setMsgType("clause"); busProcessNewNext.setMsgType("clause");
busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); busProcessNewNext.setPId(delegateTask.getProcessInstanceId());
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); // busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setTaskInfo("审核");
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName());
busProcessNewNext.setUserId(nextUser); busProcessNewNext.setUserId(nextUser);
addBusProcessNewList.add(busProcessNewNext); addBusProcessNewList.add(busProcessNewNext);
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess1Before.java
+1 -1
View File
@@ -17,7 +17,7 @@ public class PolicySolicitOpinionProcess1Before implements TaskListener {
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper1 = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper1 = new QueryWrapper<>();
queryWrapper1.isNull("TASK_ID"); queryWrapper1.isNull("TASK_ID");
queryWrapper1.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper1.eq("P_ID",delegateTask.getProcessInstanceId());
List<BusProcessNew> list = busBean.list(queryWrapper1); List<BusProcessNew> list = busBean.list(queryWrapper1);
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess2After.java
+37 -12
View File
@@ -1,6 +1,7 @@
package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess; package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService; import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
@@ -32,6 +33,18 @@ public class PolicySolicitOpinionProcess2After implements TaskListener {
JSONObject jsonForm = object.getJSONObject("form"); JSONObject jsonForm = object.getJSONObject("form");
Object lawsName = jsonForm.get("lawsName");
Object lawsNo = jsonForm.get("lawsNo");
String lawsInfoName = "";
if(lawsName != null && lawsNo != null){
String number = "《" + lawsNo +"-";
String name = lawsName +"》-";
if(StringUtils.isNotBlank(name) && StringUtils.isNotBlank(number)){
lawsInfoName = number + name;
}
}
String prcName = lawsInfoName + "征求意见";
String approvalFlag = jsonForm.getString("approvalFlag"); String approvalFlag = jsonForm.getString("approvalFlag");
if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) { if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) {
int shr1UserPassCount = (int) delegateTask.getVariable("shr1UserPassCount"); int shr1UserPassCount = (int) delegateTask.getVariable("shr1UserPassCount");
@@ -55,7 +68,8 @@ public class PolicySolicitOpinionProcess2After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setTaskInfo("审定");
busProcessNewNext.setUserId(nextUser); busProcessNewNext.setUserId(nextUser);
addBusProcessNewList.add(busProcessNewNext); addBusProcessNewList.add(busProcessNewNext);
} }
@@ -74,23 +88,34 @@ public class PolicySolicitOpinionProcess2After implements TaskListener {
busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); busProcessNewNext.setPId(delegateTask.getProcessInstanceId());
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setTaskInfo("起草修改");
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName());
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
delegateTask.setVariable("shr1UserOverruleCount", 1); delegateTask.setVariable("shr1UserOverruleCount", 1);
} }
// 存储当前节点意见 // 存储当前节点意见
BusProcessNew busProcessNew = new BusProcessNew(); LambdaQueryWrapper<BusProcessNew> queryWrapper1 = new LambdaQueryWrapper<>();
busProcessNew.setMsgType("clause"); queryWrapper1.eq(BusProcessNew::getTaskId,delegateTask.getId());
busProcessNew.setPId(delegateTask.getProcessInstanceId()); List<BusProcessNew> list = busBean.list(queryWrapper1);
busProcessNew.setMesg(object.toJSONString()); if (CollectionUtils.isNotEmpty(list)) {
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); BusProcessNew busProcessNew = list.get(0);
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busBean.saveOrUpdate(busProcessNew);
busProcessNew.setTaskInfo(delegateTask.getName()); }
busBean.save(busProcessNew);
// BusProcessNew busProcessNew = new BusProcessNew();
// busProcessNew.setMsgType("clause");
// busProcessNew.setPId(delegateTask.getProcessInstanceId());
// busProcessNew.setMesg(object.toJSONString());
// busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey());
// busProcessNew.setTaskId(delegateTask.getId());
// busProcessNew.setPrcName(prcName);
// busProcessNew.setCommitText(object.getString("commentText"));
// busProcessNew.setFinishFlag("0");
// busBean.save(busProcessNew);
delegateTask.setVariable("approvalFlag",approvalFlag); delegateTask.setVariable("approvalFlag",approvalFlag);
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess2Before.java
+1 -1
View File
@@ -18,7 +18,7 @@ public class PolicySolicitOpinionProcess2Before implements TaskListener {
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("TASK_ID"); queryWrapper.isNull("TASK_ID");
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
queryWrapper.eq("USER_ID",delegateTask.getAssignee()); queryWrapper.eq("USER_ID",delegateTask.getAssignee());
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess4After.java
+40 -11
View File
@@ -1,6 +1,7 @@
package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess; package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService; import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
@@ -12,8 +13,11 @@ import com.ydw.bat.wkflow.util.SpringContextUtil;
import com.ydw.bat.wkflow.util.enums.ApprovalFlagEnum; import com.ydw.bat.wkflow.util.enums.ApprovalFlagEnum;
import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener; import org.activiti.engine.delegate.TaskListener;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import java.util.List;
public class PolicySolicitOpinionProcess4After implements TaskListener { public class PolicySolicitOpinionProcess4After implements TaskListener {
@Override @Override
public void notify(DelegateTask delegateTask) { public void notify(DelegateTask delegateTask) {
@@ -28,6 +32,19 @@ public class PolicySolicitOpinionProcess4After implements TaskListener {
JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
JSONObject jsonForm = object.getJSONObject("form"); JSONObject jsonForm = object.getJSONObject("form");
Object lawsName = jsonForm.get("lawsName");
Object lawsNo = jsonForm.get("lawsNo");
String lawsInfoName = "";
if(lawsName != null && lawsNo != null){
String number = "《" + lawsNo +"-";
String name = lawsName +"》-";
if(StringUtils.isNotBlank(name) && StringUtils.isNotBlank(number)){
lawsInfoName = number + name;
}
}
String prcName = lawsInfoName + "征求意见";
String approvalFlag = jsonForm.getString("approvalFlag"); String approvalFlag = jsonForm.getString("approvalFlag");
if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) { if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) {
int sdr1UserPassCount = (int) delegateTask.getVariable("sdr1UserPassCount"); int sdr1UserPassCount = (int) delegateTask.getVariable("sdr1UserPassCount");
@@ -45,8 +62,9 @@ public class PolicySolicitOpinionProcess4After implements TaskListener {
busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); busProcessNewNext.setPId(delegateTask.getProcessInstanceId());
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setTaskInfo("批准");
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName());
busProcessNewNext.setUserId(pzr1UserId); busProcessNewNext.setUserId(pzr1UserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
@@ -58,6 +76,8 @@ public class PolicySolicitOpinionProcess4After implements TaskListener {
busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); busProcessNewNext.setPId(delegateTask.getProcessInstanceId());
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setTaskInfo("起草修改");
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo(delegateTask.getName());
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
@@ -66,16 +86,25 @@ public class PolicySolicitOpinionProcess4After implements TaskListener {
} }
// 存储当前节点意见 // 存储当前节点意见
BusProcessNew busProcessNew = new BusProcessNew(); LambdaQueryWrapper<BusProcessNew> queryWrapper1 = new LambdaQueryWrapper<>();
busProcessNew.setMsgType("clause"); queryWrapper1.eq(BusProcessNew::getTaskId,delegateTask.getId());
busProcessNew.setPId(delegateTask.getProcessInstanceId()); List<BusProcessNew> list = busBean.list(queryWrapper1);
busProcessNew.setMesg(object.toJSONString()); if (CollectionUtils.isNotEmpty(list)) {
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); BusProcessNew busProcessNew = list.get(0);
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busBean.saveOrUpdate(busProcessNew);
busProcessNew.setTaskInfo(delegateTask.getName()); }
busBean.save(busProcessNew); // BusProcessNew busProcessNew = new BusProcessNew();
// busProcessNew.setMsgType("clause");
// busProcessNew.setPId(delegateTask.getProcessInstanceId());
// busProcessNew.setMesg(object.toJSONString());
// busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey());
// busProcessNew.setTaskId(delegateTask.getId());
// busProcessNew.setPrcName(prcName);
// busProcessNew.setCommitText(object.getString("commentText"));
// busProcessNew.setFinishFlag("0");
// busBean.save(busProcessNew);
delegateTask.setVariable("approvalFlag",approvalFlag); delegateTask.setVariable("approvalFlag",approvalFlag);
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess4Before.java
+1 -1
View File
@@ -18,7 +18,7 @@ public class PolicySolicitOpinionProcess4Before implements TaskListener {
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("TASK_ID"); queryWrapper.isNull("TASK_ID");
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
queryWrapper.eq("USER_ID",delegateTask.getAssignee()); queryWrapper.eq("USER_ID",delegateTask.getAssignee());
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess5After.java
+40 -13
View File
@@ -1,6 +1,7 @@
package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess; package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
import com.ydw.bat.wkflow.business_main.datas.entity.Datas; import com.ydw.bat.wkflow.business_main.datas.entity.Datas;
@@ -30,6 +31,19 @@ public class PolicySolicitOpinionProcess5After implements TaskListener {
JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
JSONObject jsonForm = object.getJSONObject("form"); JSONObject jsonForm = object.getJSONObject("form");
Object lawsName = jsonForm.get("lawsName");
Object lawsNo = jsonForm.get("lawsNo");
String lawsInfoName = "";
if(lawsName != null && lawsNo != null){
String number = "《" + lawsNo +"-";
String name = lawsName +"》-";
if(StringUtils.isNotBlank(name) && StringUtils.isNotBlank(number)){
lawsInfoName = number + name;
}
}
String prcName = lawsInfoName + "征求意见";
String approvalFlag = jsonForm.getString("approvalFlag"); String approvalFlag = jsonForm.getString("approvalFlag");
if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) { if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) {
Date responsibleUnitDeadlineDate = jsonForm.getDate("responsibleUnitDeadline"); Date responsibleUnitDeadlineDate = jsonForm.getDate("responsibleUnitDeadline");
@@ -44,8 +58,9 @@ public class PolicySolicitOpinionProcess5After implements TaskListener {
busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); busProcessNewNext.setPId(delegateTask.getProcessInstanceId());
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setTaskInfo("管理员");
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName());
busProcessNewNext.setUserId(glyUserId); busProcessNewNext.setUserId(glyUserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
@@ -64,8 +79,9 @@ public class PolicySolicitOpinionProcess5After implements TaskListener {
busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); busProcessNewNext.setPId(delegateTask.getProcessInstanceId());
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setTaskInfo("责任对接人分配任务");
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName());
busProcessNewNext.setUserId(nextUser); busProcessNewNext.setUserId(nextUser);
addBusProcessNewList.add(busProcessNewNext); addBusProcessNewList.add(busProcessNewNext);
} }
@@ -85,22 +101,33 @@ public class PolicySolicitOpinionProcess5After implements TaskListener {
busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); busProcessNewNext.setPId(delegateTask.getProcessInstanceId());
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("起草修改");
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
} }
// 存储当前节点意见 // 存储当前节点意见
BusProcessNew busProcessNew = new BusProcessNew(); LambdaQueryWrapper<BusProcessNew> queryWrapper1 = new LambdaQueryWrapper<>();
busProcessNew.setMsgType("clause"); queryWrapper1.eq(BusProcessNew::getTaskId,delegateTask.getId());
busProcessNew.setPId(delegateTask.getProcessInstanceId()); List<BusProcessNew> list = busBean.list(queryWrapper1);
busProcessNew.setMesg(object.toJSONString()); if (CollectionUtils.isNotEmpty(list)) {
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); BusProcessNew busProcessNew = list.get(0);
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busBean.saveOrUpdate(busProcessNew);
busProcessNew.setTaskInfo(delegateTask.getName()); }
busBean.save(busProcessNew); // BusProcessNew busProcessNew = new BusProcessNew();
// busProcessNew.setMsgType("clause");
// busProcessNew.setPId(delegateTask.getProcessInstanceId());
// busProcessNew.setMesg(object.toJSONString());
// busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey());
// busProcessNew.setTaskId(delegateTask.getId());
// busProcessNew.setPrcName(prcName);
// busProcessNew.setCommitText(object.getString("commentText"));
// busProcessNew.setFinishFlag("0");
// busProcessNew.setTaskInfo(delegateTask.getName());
// busBean.save(busProcessNew);
delegateTask.setVariable("approvalFlag",approvalFlag); delegateTask.setVariable("approvalFlag",approvalFlag);
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess5Before.java
+1 -1
View File
@@ -18,7 +18,7 @@ public class PolicySolicitOpinionProcess5Before implements TaskListener {
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("TASK_ID"); queryWrapper.isNull("TASK_ID");
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
queryWrapper.eq("USER_ID",delegateTask.getAssignee()); queryWrapper.eq("USER_ID",delegateTask.getAssignee());
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess7After.java
+37 -12
View File
@@ -1,6 +1,7 @@
package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess; package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
import com.ydw.bat.wkflow.business_main.datas.entity.Datas; import com.ydw.bat.wkflow.business_main.datas.entity.Datas;
@@ -33,6 +34,19 @@ public class PolicySolicitOpinionProcess7After implements TaskListener {
JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
JSONObject jsonForm = object.getJSONObject("form"); JSONObject jsonForm = object.getJSONObject("form");
Object lawsName = jsonForm.get("lawsName");
Object lawsNo = jsonForm.get("lawsNo");
String lawsInfoName = "";
if(lawsName != null && lawsNo != null){
String number = "《" + lawsNo +"-";
String name = lawsName +"》-";
if(org.apache.commons.lang.StringUtils.isNotBlank(name) && org.apache.commons.lang.StringUtils.isNotBlank(number)){
lawsInfoName = number + name;
}
}
String prcName = lawsInfoName + "征求意见";
// 提交方式，如果该字段不为空，则是定时器自动提交 定时器自动提交value:timerAutoSubmit // 提交方式，如果该字段不为空，则是定时器自动提交 定时器自动提交value:timerAutoSubmit
String submitMethod = object.getString("submitMethod"); String submitMethod = object.getString("submitMethod");
if (StringUtils.isEmpty(submitMethod)) { if (StringUtils.isEmpty(submitMethod)) {
@@ -49,8 +63,9 @@ public class PolicySolicitOpinionProcess7After implements TaskListener {
busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); busProcessNewNext.setPId(delegateTask.getProcessInstanceId());
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("责任人任务处理");
busProcessNewNext.setUserId(nextUser); busProcessNewNext.setUserId(nextUser);
addBusProcessNewList.add(busProcessNewNext); addBusProcessNewList.add(busProcessNewNext);
@@ -89,8 +104,9 @@ public class PolicySolicitOpinionProcess7After implements TaskListener {
busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); busProcessNewNext.setPId(delegateTask.getProcessInstanceId());
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("管理员");
busProcessNewNext.setUserId(glyUserId); busProcessNewNext.setUserId(glyUserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
} }
@@ -99,16 +115,25 @@ public class PolicySolicitOpinionProcess7After implements TaskListener {
} }
// 存储当前节点意见 // 存储当前节点意见
BusProcessNew busProcessNew = new BusProcessNew(); LambdaQueryWrapper<BusProcessNew> queryWrapper1 = new LambdaQueryWrapper<>();
busProcessNew.setMsgType("clause"); queryWrapper1.eq(BusProcessNew::getTaskId,delegateTask.getId());
busProcessNew.setPId(delegateTask.getProcessInstanceId()); List<BusProcessNew> list = busBean.list(queryWrapper1);
busProcessNew.setMesg(object.toJSONString()); if (CollectionUtils.isNotEmpty(list)) {
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); BusProcessNew busProcessNew = list.get(0);
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busBean.saveOrUpdate(busProcessNew);
busProcessNew.setTaskInfo(delegateTask.getName()); }
busBean.save(busProcessNew); // 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);
delegateTask.setVariable("submitMethod",submitMethod); delegateTask.setVariable("submitMethod",submitMethod);
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess7Before.java
+1 -1
View File
@@ -19,7 +19,7 @@ public class PolicySolicitOpinionProcess7Before implements TaskListener {
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("TASK_ID"); queryWrapper.isNull("TASK_ID");
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
queryWrapper.eq("USER_ID",delegateTask.getAssignee()); queryWrapper.eq("USER_ID",delegateTask.getAssignee());
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess8After.java
+40 -12
View File
@@ -1,6 +1,7 @@
package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess; package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService; import com.ydw.bat.wkflow.business_activiti.service.TaskTodoService;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
@@ -12,8 +13,11 @@ import com.ydw.bat.wkflow.business_main.datas.service.IPolicySolicitOpinionEOSer
import com.ydw.bat.wkflow.util.SpringContextUtil; import com.ydw.bat.wkflow.util.SpringContextUtil;
import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener; import org.activiti.engine.delegate.TaskListener;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import java.util.List;
public class PolicySolicitOpinionProcess8After implements TaskListener { public class PolicySolicitOpinionProcess8After implements TaskListener {
@Override @Override
public void notify(DelegateTask delegateTask) { public void notify(DelegateTask delegateTask) {
@@ -28,6 +32,19 @@ public class PolicySolicitOpinionProcess8After implements TaskListener {
JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
JSONObject jsonForm = object.getJSONObject("form"); JSONObject jsonForm = object.getJSONObject("form");
Object lawsName = jsonForm.get("lawsName");
Object lawsNo = jsonForm.get("lawsNo");
String lawsInfoName = "";
if(lawsName != null && lawsNo != null){
String number = "《" + lawsNo +"-";
String name = lawsName +"》-";
if(org.apache.commons.lang.StringUtils.isNotBlank(name) && org.apache.commons.lang.StringUtils.isNotBlank(number)){
lawsInfoName = number + name;
}
}
String prcName = lawsInfoName + "征求意见";
// 提交方式，如果该字段不为空，则是定时器自动提交 定时器自动提交value:timerAutoSubmit // 提交方式，如果该字段不为空，则是定时器自动提交 定时器自动提交value:timerAutoSubmit
String submitMethod = object.getString("submitMethod"); String submitMethod = object.getString("submitMethod");
if (StringUtils.isEmpty(submitMethod)) { if (StringUtils.isEmpty(submitMethod)) {
@@ -37,8 +54,9 @@ public class PolicySolicitOpinionProcess8After implements TaskListener {
busProcessNewNext.setPId(delegateTask.getProcessInstanceId()); busProcessNewNext.setPId(delegateTask.getProcessInstanceId());
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("责任对接人汇总");
busProcessNewNext.setUserId((String) delegateTask.getVariable("djrUserId")); busProcessNewNext.setUserId((String) delegateTask.getVariable("djrUserId"));
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
@@ -66,7 +84,8 @@ public class PolicySolicitOpinionProcess8After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("管理员");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(glyUserId); busProcessNewNext.setUserId(glyUserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
} }
@@ -74,16 +93,25 @@ public class PolicySolicitOpinionProcess8After implements TaskListener {
} }
// 存储当前节点意见 // 存储当前节点意见
BusProcessNew busProcessNew = new BusProcessNew(); LambdaQueryWrapper<BusProcessNew> queryWrapper1 = new LambdaQueryWrapper<>();
busProcessNew.setMsgType("clause"); queryWrapper1.eq(BusProcessNew::getTaskId,delegateTask.getId());
busProcessNew.setPId(delegateTask.getProcessInstanceId()); List<BusProcessNew> list = busBean.list(queryWrapper1);
busProcessNew.setMesg(object.toJSONString()); if (CollectionUtils.isNotEmpty(list)) {
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); BusProcessNew busProcessNew = list.get(0);
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busBean.saveOrUpdate(busProcessNew);
busProcessNew.setTaskInfo(delegateTask.getName()); }
busBean.save(busProcessNew); // 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);
delegateTask.setVariable("submitMethod",submitMethod); delegateTask.setVariable("submitMethod",submitMethod);
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess8Before.java
+1 -1
View File
@@ -18,7 +18,7 @@ public class PolicySolicitOpinionProcess8Before implements TaskListener {
IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class); IBusProcessNewService busBean = SpringContextUtil.getBean(IBusProcessNewService.class);
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("TASK_ID"); queryWrapper.isNull("TASK_ID");
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
queryWrapper.eq("USER_ID",delegateTask.getAssignee()); queryWrapper.eq("USER_ID",delegateTask.getAssignee());
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess9After.java
+39 -13
View File
@@ -1,6 +1,7 @@
package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess; package com.ydw.bat.wkflow.listener.policySolicitOpinionProcess;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew;
import com.ydw.bat.wkflow.business_main.datas.entity.Datas; import com.ydw.bat.wkflow.business_main.datas.entity.Datas;
@@ -11,6 +12,7 @@ import com.ydw.bat.wkflow.util.enums.ApprovalFlagEnum;
import com.ydw.bat.wkflow.util.enums.FlowTypeEnum; import com.ydw.bat.wkflow.util.enums.FlowTypeEnum;
import org.activiti.engine.delegate.DelegateTask; import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener; import org.activiti.engine.delegate.TaskListener;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import java.util.ArrayList; import java.util.ArrayList;
@@ -31,6 +33,18 @@ public class PolicySolicitOpinionProcess9After implements TaskListener {
JSONObject object = JSONObject.parseObject(datas.getFormValsJson()); JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
JSONObject jsonForm = object.getJSONObject("form"); JSONObject jsonForm = object.getJSONObject("form");
Object lawsName = jsonForm.get("lawsName");
Object lawsNo = jsonForm.get("lawsNo");
String lawsInfoName = "";
if(lawsName != null && lawsNo != null){
String number = "《" + lawsNo +"-";
String name = lawsName +"》-";
if(StringUtils.isNotBlank(name) && StringUtils.isNotBlank(number)){
lawsInfoName = number + name;
}
}
String prcName = lawsInfoName + "征求意见";
String approvalFlag = jsonForm.getString("approvalFlag"); String approvalFlag = jsonForm.getString("approvalFlag");
if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) { if (StringUtils.equals(approvalFlag, ApprovalFlagEnum.PASS.getValue())) {
// 内部审查 0 是，1 否 // 内部审查 0 是，1 否
@@ -45,7 +59,8 @@ public class PolicySolicitOpinionProcess9After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("责任单位审批");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(zrdwUserId); busProcessNewNext.setUserId(zrdwUserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
@@ -76,7 +91,8 @@ public class PolicySolicitOpinionProcess9After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("管理员");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(glyUserId); busProcessNewNext.setUserId(glyUserId);
busBean.save(busProcessNewNext); busBean.save(busProcessNewNext);
} }
@@ -95,7 +111,8 @@ public class PolicySolicitOpinionProcess9After implements TaskListener {
busProcessNewNext.setMesg(object.toJSONString()); busProcessNewNext.setMesg(object.toJSONString());
busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey()); busProcessNewNext.setTaskInfo(delegateTask.getTaskDefinitionKey());
busProcessNewNext.setFinishFlag("0"); busProcessNewNext.setFinishFlag("0");
busProcessNewNext.setTaskInfo(delegateTask.getName()); busProcessNewNext.setTaskInfo("责任人任务处理");
busProcessNewNext.setPrcName(prcName);
busProcessNewNext.setUserId(nextUser); busProcessNewNext.setUserId(nextUser);
addBusProcessNewList.add(busProcessNewNext); addBusProcessNewList.add(busProcessNewNext);
} }
@@ -108,16 +125,25 @@ public class PolicySolicitOpinionProcess9After implements TaskListener {
policySolicitOpinionEOService.batchInsert(object); policySolicitOpinionEOService.batchInsert(object);
// 存储当前节点意见 // 存储当前节点意见
BusProcessNew busProcessNew = new BusProcessNew(); LambdaQueryWrapper<BusProcessNew> queryWrapper1 = new LambdaQueryWrapper<>();
busProcessNew.setMsgType("clause"); queryWrapper1.eq(BusProcessNew::getTaskId,delegateTask.getId());
busProcessNew.setPId(delegateTask.getProcessInstanceId()); List<BusProcessNew> list = busBean.list(queryWrapper1);
busProcessNew.setMesg(object.toJSONString()); if (CollectionUtils.isNotEmpty(list)) {
busProcessNew.setTaskInfo(delegateTask.getTaskDefinitionKey()); BusProcessNew busProcessNew = list.get(0);
busProcessNew.setTaskId(delegateTask.getId()); busProcessNew.setTaskId(delegateTask.getId());
busProcessNew.setCommitText(object.getString("commentText")); busProcessNew.setCommitText(object.getString("commentText"));
busProcessNew.setFinishFlag("0"); busBean.saveOrUpdate(busProcessNew);
busProcessNew.setTaskInfo(delegateTask.getName()); }
busBean.save(busProcessNew); // 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);
delegateTask.setVariable("approvalFlag", approvalFlag); delegateTask.setVariable("approvalFlag", approvalFlag);
} }
src/main/java/com/ydw/bat/wkflow/listener/policySolicitOpinionProcess/PolicySolicitOpinionProcess9Before.java
+1 -1
View File
@@ -19,7 +19,7 @@ public class PolicySolicitOpinionProcess9Before implements TaskListener {
CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper<BusProcessNew> queryWrapper = new QueryWrapper<>();
queryWrapper.isNull("TASK_ID"); queryWrapper.isNull("TASK_ID");
queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId()); queryWrapper.eq("P_ID",delegateTask.getProcessInstanceId());
queryWrapper.eq("USER_ID",delegateTask.getAssignee()); queryWrapper.eq("USER_ID",delegateTask.getAssignee());