From 40addf61931a87879840e88e78d8f2320dfd9c30 Mon Sep 17 00:00:00 2001
From: zhn <947514737@qq.com>
Date: Wed, 8 Jun 2022 14:29:50 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/BussDocumentLibraryEOServiceImpl.java       | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java
index 74356c5ee..0363ed8a1 100644
--- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java
+++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java
@@ -3044,6 +3044,7 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
         }
         //订阅标准
         List<String> userIdListUpdate = new ArrayList<>();
+        List<String> userIdListUpdateFeishu = new ArrayList<>();
         String id = (String) map.get("id");
         if (StringUtils.isNotBlank(id)) {
             QueryWrapper<OnlCgformSubscribe> querySubscribe = new QueryWrapper<>();
@@ -3057,6 +3058,7 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
                 List<SysUser> sysUsers = this.sysUserMapper.selectList(userQuery);
                 if (org.apache.commons.collections4.CollectionUtils.isNotEmpty(sysUsers)) {
                     userIdListUpdate = sysUsers.stream().map(SysUser::getId).collect(Collectors.toList());
+                    userIdListUpdateFeishu = sysUsers.stream().map(SysUser::getThirdId).collect(Collectors.toList());
                 }
             }
         }
@@ -3091,6 +3093,16 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
                 sysAnnouncementService.saveAnnouncement(sysAnnouncement);
                 sendWebsocket((String) map.get("id"), contentInfo);
             }
+            //订阅文档的飞书消息
+            try {
+                String contentInfoFei = "In the " + technologyTerritoryNameEn + " technical field you subscribed to, the " +
+                        category + " " + serialNumber+" has been updated.";
+                //跳转文档详情
+                String url = backUrl + "/docManage/library/detail?id=" + id;
+                iFeishuService.batchSendMessage(userIdListUpdateFeishu.toArray(new String[]{}), contentInfoFei, MessageTypeEnum.READ.getName(), url);
+            } catch (IOException e) {
+                log.error("文档新增飞书消息推送失败");
+            }
         }
 //        }
         //2. 处理修改代替标准的发送消息(法规负责人)