diff --git a/model/src/main/java/cn/org/gitlink/notification/model/dao/entity/vo/NewSysNotificationVo.java b/model/src/main/java/cn/org/gitlink/notification/model/dao/entity/vo/NewSysNotificationVo.java index 20bf99c..8923b3e 100644 --- a/model/src/main/java/cn/org/gitlink/notification/model/dao/entity/vo/NewSysNotificationVo.java +++ b/model/src/main/java/cn/org/gitlink/notification/model/dao/entity/vo/NewSysNotificationVo.java @@ -6,6 +6,7 @@ public class NewSysNotificationVo { private long sender; + //接受者id,单个id或多个 example:"1"/"1,2,3" private String receivers; private String content; diff --git a/model/src/main/java/cn/org/gitlink/notification/model/service/notification/SysNotificationService.java b/model/src/main/java/cn/org/gitlink/notification/model/service/notification/SysNotificationService.java index 07a180e..4986539 100644 --- a/model/src/main/java/cn/org/gitlink/notification/model/service/notification/SysNotificationService.java +++ b/model/src/main/java/cn/org/gitlink/notification/model/service/notification/SysNotificationService.java @@ -8,15 +8,21 @@ import com.baomidou.mybatisplus.extension.service.IService; import java.util.List; public interface SysNotificationService extends IService { + //给用户发送消息 boolean addSysNotificationForUsers(NewSysNotificationVo sysNotification); + //变更消息状态 int changeStatusByNotificationIds(String platform, String notificationIds, Integer status); + //获取全部未读消息数量 int getAllNewSysNotificationNumber(String platform, Integer receiver); + //获取未读消息列表 List getUnreadSysNotificationsList(String platform, Integer receiver, Integer notificationNumber); + //根据类型获取未读系统消息数量 int getSysNotificationNumberByType(String platform, Integer receiver, Integer type); + //获取全部消息分页列表 Page getAllSysNotificationsPageList(int curPage, int pageSize, String orderBy, String platform, Integer receiver); } diff --git a/model/src/main/java/cn/org/gitlink/notification/model/service/notification/impl/SysNotificationServiceImpl.java b/model/src/main/java/cn/org/gitlink/notification/model/service/notification/impl/SysNotificationServiceImpl.java index feec380..ac876b8 100644 --- a/model/src/main/java/cn/org/gitlink/notification/model/service/notification/impl/SysNotificationServiceImpl.java +++ b/model/src/main/java/cn/org/gitlink/notification/model/service/notification/impl/SysNotificationServiceImpl.java @@ -15,6 +15,13 @@ import java.util.List; @Service(value = "sysNotificationServiceImpl") public class SysNotificationServiceImpl extends ServiceImpl implements SysNotificationService { + /** + * @Description: 给用户发送消息 + * @Param: [newSysNotificationVo] + * @return: boolean + * @Author: wanjia + * @Date: 2021/9/8 + */ @Override @Transactional public boolean addSysNotificationForUsers(NewSysNotificationVo newSysNotificationVo) { @@ -31,27 +38,62 @@ public class SysNotificationServiceImpl extends ServiceImpl + * @Author: wanjia + * @Date: 2021/9/8 + */ @Override public List getUnreadSysNotificationsList(String platform, Integer receiver, Integer notificationNumber) { List sysNotificationList = baseMapper.getUnreadSysNotificationsList(platform, receiver, 1, notificationNumber); return sysNotificationList; } + /** + * @Description: 根据类型获取未读系统消息数量 + * @Param: [platform:平台编码, receiver:接收者id, type:消息类型1-系统消息2-@我] + * @return: int + * @Author: wanjia + * @Date: 2021/9/8 + */ @Override public int getSysNotificationNumberByType(String platform, Integer receiver, Integer type) { return baseMapper.getSysNotificationNumberByType(platform, receiver, type); } + /** + * @Description: 获取全部消息分页列表 + * @Param: [curPage, pageSize, orderBy, platform:平台编码, receiver:接受者id] + * @return: Page + * @Author: wanjia + * @Date: 2021/9/8 + */ @Override public Page getAllSysNotificationsPageList(int curPage, int pageSize, String orderBy, String platform, Integer receiver) { Page page = new Page(curPage, pageSize);