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 003670b9..cd592ed9 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 @@ -7,7 +7,6 @@ import io.renren.common.constant.Constant; import io.renren.common.page.PageData; import io.renren.common.service.impl.CrudServiceImpl; import io.renren.common.utils.ConvertUtils; -import io.renren.common.utils.Result; import io.renren.modules.notice.dao.SysNoticeDao; import io.renren.modules.notice.dto.SysNoticeDTO; import io.renren.modules.notice.entity.SysNoticeEntity; @@ -194,7 +193,12 @@ public class SysNoticeServiceImpl extends CrudServiceImpl message = new MessageData().msg(notice.getTitle()); webSocketServer.sendMessage(finalUserIdList, message); - sendToYaweiUser(notice, finalUserIdList); + }, executor).thenRunAsync(() -> { + try { + sendToYaweiUser(notice, finalUserIdList); + } catch (Exception exception) { + logger.error("", exception); + } }, executor); } } @@ -241,14 +245,14 @@ public class SysNoticeServiceImpl extends CrudServiceImpl\n" + String.format("{%s}\n", UUID.randomUUID().toString().toUpperCase()) + String.format("{%s}\n", UUID.randomUUID().toString().toUpperCase()) + - String.format("%s\n",notice.getTitle()) + + String.format("%s\n", notice.getTitle()) + " 2\n" + String.format("%s\n", userNames.toString()) + String.format("%s\n", userGuids.toString()) + @@ -291,7 +295,7 @@ public class SysNoticeServiceImpl extends CrudServiceImpl