From f73ac8faeaa7b9622e9fbf9a689aabe20850ee70 Mon Sep 17 00:00:00 2001
From: wxyclub <tjzdwxy@163.com>
Date: Tue, 5 Dec 2023 14:32:56 +0800
Subject: [PATCH] =?UTF-8?q?add:=20=E4=BC=81=E6=A0=87=E5=BA=9F=E6=AD=A2?=
 =?UTF-8?q?=E6=B5=81=E7=A8=8B=E6=89=B9=E5=87=86=E8=8A=82=E7=82=B9=E6=B7=BB?=
 =?UTF-8?q?=E5=8A=A0=E6=8A=84=E9=80=81=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../listener/aboliish/ProcessStep6After.java  | 27 +++++++++++++++++--
 1 file changed, 25 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/ydw/bat/wkflow/listener/aboliish/ProcessStep6After.java b/src/main/java/com/ydw/bat/wkflow/listener/aboliish/ProcessStep6After.java
index c1181ae5..ba34c372 100644
--- a/src/main/java/com/ydw/bat/wkflow/listener/aboliish/ProcessStep6After.java
+++ b/src/main/java/com/ydw/bat/wkflow/listener/aboliish/ProcessStep6After.java
@@ -7,8 +7,8 @@ import com.ydw.bat.wkflow.business_main.datas.entity.*;
 import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNameService;
 import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNewService;
 import com.ydw.bat.wkflow.business_main.datas.service.IDatasService;
+import com.ydw.bat.wkflow.business_mq.service.CreateMQService;
 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;
@@ -29,6 +29,8 @@ public class ProcessStep6After implements TaskListener {
         IBusProcessNameService busProcessNameService = SpringContextUtil.getBean(IBusProcessNameService.class);
         LawsUserInfoService lawsUserInfoService = SpringContextUtil.getBean(LawsUserInfoService.class);
 
+        CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class);
+
         //根据流程id找到流程信息
         QueryWrapper<Datas> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("ACTI_TASK_ID", delegateTask.getId());
@@ -36,7 +38,7 @@ public class ProcessStep6After implements TaskListener {
         JSONObject object = JSONObject.parseObject(datas.getFormValsJson());
         delegateTask.setVariable("objectJson", object);
         //标准法规部业务经理Id ${sdFlag==0} bafzFlag
-        List<String> nextUserList = new ArrayList();
+        List<String> nextUserList = new ArrayList<>();
         if ("0".equals(object.getString("bafzFlag"))){
             delegateTask.setVariable("bafzFlag","0");
             //入库"3lqnlgmgcn"
@@ -81,6 +83,27 @@ public class ProcessStep6After implements TaskListener {
             one1.setCreatUserName(username);
             busProcessNameService.saveOrUpdate(one1);
         }
+        String csrUserIds = object.getString("csrUserIds");
+        if (StringUtils.isNotEmpty(csrUserIds)) {
+            String[] csrUserIdList = csrUserIds.split(",");
+            for (String csrUserId : csrUserIdList) {
+                // 发送 oa 待阅
+                BusProcessNew sendToBeReadBpn = new BusProcessNew();
+                sendToBeReadBpn.setId(UUID.randomUUID().toString().substring(0, 20));
+                sendToBeReadBpn.setTaskId(delegateTask.getId());
+                sendToBeReadBpn.setTaskInfo(delegateTask.getName());
+                sendToBeReadBpn.setLink("Aboliish7?prcType=24" +
+                        "&taskDefinitionKey=Aboliish7" +
+                        "&operate=view"
+                );
+                sendToBeReadBpn.setTaskInfo(delegateTask.getName());
+                sendToBeReadBpn.setUserId(csrUserId);
+                sendToBeReadBpn.setPrcName(prcName);
+                sendToBeReadBpn.setPId(delegateTask.getProcessInstanceId());
+
+                oaService.sendToBeReadMq(sendToBeReadBpn);
+            }
+        }
 
         // 存储当前节点意见1
         if (null != object.getString("commentText")) {