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")) {