From 67f8811b21e4586d953a63f631ea59c0fd853927 Mon Sep 17 00:00:00 2001
From: dinggang <2498628697@qq.com>
Date: Thu, 21 Jul 2022 15:40:52 +0800
Subject: [PATCH 1/2] ...

---
 .../java/io/renren/modules/activiti/service/ActTaskService.java | 2 --
 renren-admin/src/main/resources/mapper/resource/ResourceDao.xml | 2 ++
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/renren-admin/src/main/java/io/renren/modules/activiti/service/ActTaskService.java b/renren-admin/src/main/java/io/renren/modules/activiti/service/ActTaskService.java
index 1380766c..8e85a94e 100644
--- a/renren-admin/src/main/java/io/renren/modules/activiti/service/ActTaskService.java
+++ b/renren-admin/src/main/java/io/renren/modules/activiti/service/ActTaskService.java
@@ -209,8 +209,6 @@ public class ActTaskService extends BaseServiceImpl {
         for (Task task : list) {
             TaskDTO dto = new TaskDTO();
             this.convertTaskInfo(task, dto);
-            //Optional<SysUserEntity> sysUserEntity = Optional.ofNullable(sysUserService.selectById(dto.getUserId()));
-            //dto.setUserName(sysUserEntity.get().getRealName());
             Map<String, Object> processVariable = new LinkedHashMap<>();
 
             if (dto.getBusinessKey().startsWith("{") || dto.getBusinessKey().startsWith("[")) { // 为json内容 (特殊处理批量)
diff --git a/renren-admin/src/main/resources/mapper/resource/ResourceDao.xml b/renren-admin/src/main/resources/mapper/resource/ResourceDao.xml
index bea045eb..a345f083 100644
--- a/renren-admin/src/main/resources/mapper/resource/ResourceDao.xml
+++ b/renren-admin/src/main/resources/mapper/resource/ResourceDao.xml
@@ -791,6 +791,7 @@
         WHERE 1 = 1
         AND del_flag = 0
         AND dept_id = #{deptId}
+        LIMIT 30
     </select>
 
     <select id="selectDeptCountList" resultType="java.util.Map">
@@ -857,6 +858,7 @@
         AND su.id = taa.user_id
         AND taa.resource_id = tdr.id
         AND su.dept_id = #{deptId}
+        LIMIT 30
     </select>
 
     <select id="selectApplyDeptCountList" resultType="java.util.Map">

From 544a673f2a68917bf3c4e0e34a2aeaea7fe43c53 Mon Sep 17 00:00:00 2001
From: wangliwen <wangliwen@hisense.com>
Date: Thu, 21 Jul 2022 15:59:36 +0800
Subject: [PATCH 2/2] =?UTF-8?q?...websocket=E5=85=88=E6=94=B6=E5=88=B0?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=EF=BC=9F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/SysNoticeServiceImpl.java     | 18 +++++++-----------
 1 file changed, 7 insertions(+), 11 deletions(-)

diff --git a/renren-admin/src/main/java/io/renren/modules/notice/service/impl/SysNoticeServiceImpl.java b/renren-admin/src/main/java/io/renren/modules/notice/service/impl/SysNoticeServiceImpl.java
index 4ff8780e..ededaae5 100644
--- a/renren-admin/src/main/java/io/renren/modules/notice/service/impl/SysNoticeServiceImpl.java
+++ b/renren-admin/src/main/java/io/renren/modules/notice/service/impl/SysNoticeServiceImpl.java
@@ -31,6 +31,7 @@ import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
@@ -141,16 +142,14 @@ public class SysNoticeServiceImpl extends CrudServiceImpl<SysNoticeDao, SysNotic
 
         //全部用户
         if (notice.getReceiverType() == ReceiverTypeEnum.ALL.value()) {
-            executor.execute(() -> {
+            CompletableFuture.runAsync(() -> {
                 //发送给全部用户
                 sendAllUser(notice);
-            });
-
-            executor.execute(() -> {
+            }, executor).thenRunAsync(() -> {
                 //通过WebSocket，提示全部用户，有新通知
                 MessageData<String> message = new MessageData<String>().msg(notice.getTitle());
                 webSocketServer.sendMessageAll(message);
-            });
+            }, executor);
 
         } else {  //选中用户
             List<Long> userIdList = new ArrayList<>();
@@ -167,16 +166,13 @@ public class SysNoticeServiceImpl extends CrudServiceImpl<SysNoticeDao, SysNotic
             }
 
             List<Long> finalUserIdList = userIdList;
-            executor.execute(() -> {
-                //发送给选中用户
+            CompletableFuture.runAsync(() -> {
                 sendUser(notice, finalUserIdList);
-            });
-
-            executor.execute(() -> {
+            }, executor).thenRunAsync(() -> {
                 //通过WebSocket，提示选中用户，有新通知
                 MessageData<String> message = new MessageData<String>().msg(notice.getTitle());
                 webSocketServer.sendMessage(finalUserIdList, message);
-            });
+            }, executor);
         }
     }