异常处理

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/notify/out/NoticeMessageApiServiceImpl.java

@@ -195,9 +195,13 @@ public class NoticeMessageApiServiceImpl implements NoticeMessageApiService {
             // 用于成员去重
             Set<String> userIdSet = new HashSet<>();
             List<List<StaffClerkRelationDTO>> listList = ListUtil.split(v, 1000);
-            listList.forEach(list->{
-                sendMessage(notifyMessageBatchQDTO, list,userIdSet, qwDTO);
-            });
+            for (List<StaffClerkRelationDTO> list : listList) {
+                try {
+                    sendMessage(notifyMessageBatchQDTO, list,userIdSet, qwDTO);
+                } catch (Exception e) {
+                    logger.error("发送消息通知失败",e);
+                }
+            }
         });
         return ServiceResponse.success();
     }