From fadb842a5bb1e0e7857e052c3532dc204d1ad16f Mon Sep 17 00:00:00 2001 From: daihh Date: Thu, 10 Nov 2022 15:48:14 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E6=B6=88=E6=81=AF=E7=9A=84?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/xboe/system/user/api/MessageApi.java | 2 +- .../java/com/xboe/system/user/service/IMessageService.java | 2 +- .../xboe/system/user/service/impl/MessageServiceImpl.java | 7 +++---- 3 files changed, 5 insertions(+), 6 deletions(-) diff --git a/servers/boe-server-all/src/main/java/com/xboe/system/user/api/MessageApi.java b/servers/boe-server-all/src/main/java/com/xboe/system/user/api/MessageApi.java index 129cb741..5c28d2f1 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/system/user/api/MessageApi.java +++ b/servers/boe-server-all/src/main/java/com/xboe/system/user/api/MessageApi.java @@ -139,7 +139,7 @@ public class MessageApi extends ApiBaseController { } try { - service.cleanByAcceptId(aid); + service.setReadByAcceptId(aid); return success(true); } catch (Exception e) { log.error("设置已读失败",e); diff --git a/servers/boe-server-all/src/main/java/com/xboe/system/user/service/IMessageService.java b/servers/boe-server-all/src/main/java/com/xboe/system/user/service/IMessageService.java index bce380e2..6411edc1 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/system/user/service/IMessageService.java +++ b/servers/boe-server-all/src/main/java/com/xboe/system/user/service/IMessageService.java @@ -41,7 +41,7 @@ public interface IMessageService { * @param aid * @return */ - Integer setReadByAcceptId(String aid); + void setReadByAcceptId(String aid); /** * 清空所有的消息，按接收人 diff --git a/servers/boe-server-all/src/main/java/com/xboe/system/user/service/impl/MessageServiceImpl.java b/servers/boe-server-all/src/main/java/com/xboe/system/user/service/impl/MessageServiceImpl.java index e6c4be7d..e6944179 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/system/user/service/impl/MessageServiceImpl.java +++ b/servers/boe-server-all/src/main/java/com/xboe/system/user/service/impl/MessageServiceImpl.java @@ -110,14 +110,13 @@ public class MessageServiceImpl implements IMessageService { } @Override - public Integer setReadByAcceptId(String aid) { - int n=dao.deleteByField("acceptId", aid); - return n; + public void setReadByAcceptId(String aid) { + dao.update("Update "+Message.class.getSimpleName()+" set isRead=?1 where acceptId=?2 and isRead=?3", true,aid,false); } @Override public void cleanByAcceptId(String aid) { - dao.update("Update "+Message.class.getSimpleName()+" set isRead=?1 where acceptId=?2 and isRead=?3", true,aid,false); + dao.deleteByField("acceptId", aid); } }