Commit 651619d5efbea9382d31a4a148314994ae6f0f7e

Authored by YunaiV
1 parent fa23ce14

【代码评审】IM:review 消息的实现

Showing 13 changed files with 11 additions and 14 deletions
yudao-module-im/yudao-module-im-biz/src/main/java/cn/iocoder/yudao/module/im/controller/admin/inbox/package-info.java deleted
1 -/**  
2 - * @author anhaohao  
3 - * @since 2024/3/27 下午11:36  
4 - */  
5 -package cn.iocoder.yudao.module.im.controller.admin.inbox;  
6 \ No newline at end of file 0 \ No newline at end of file
yudao-module-im/yudao-module-im-biz/src/main/java/cn/iocoder/yudao/module/im/controller/admin/inbox/vo/package-info.java deleted
1 -/**  
2 - * @author anhaohao  
3 - * @since 2024/3/31 下午10:41  
4 - */  
5 -package cn.iocoder.yudao.module.im.controller.admin.inbox.vo;  
6 \ No newline at end of file 0 \ No newline at end of file
yudao-module-im/yudao-module-im-biz/src/main/java/cn/iocoder/yudao/module/im/dal/mysql/group/GroupMapper.java
@@ -7,6 +7,7 @@ import cn.iocoder.yudao.module.im.dal.dataobject.group.ImGroupDO; @@ -7,6 +7,7 @@ import cn.iocoder.yudao.module.im.dal.dataobject.group.ImGroupDO;
7 import org.apache.ibatis.annotations.Mapper; 7 import org.apache.ibatis.annotations.Mapper;
8 import cn.iocoder.yudao.module.im.controller.admin.group.vo.*; 8 import cn.iocoder.yudao.module.im.controller.admin.group.vo.*;
9 9
  10 +// TODO @hao:这个也要有 Im 前缀
10 /** 11 /**
11 * 群 Mapper 12 * 群 Mapper
12 * 13 *
yudao-module-im/yudao-module-im-biz/src/main/java/cn/iocoder/yudao/module/im/dal/mysql/inbox/InboxMapper.java
@@ -7,6 +7,7 @@ import org.apache.ibatis.annotations.Mapper; @@ -7,6 +7,7 @@ import org.apache.ibatis.annotations.Mapper;
7 7
8 import java.util.List; 8 import java.util.List;
9 9
  10 +// TODO @hao:IM 前缀
10 /** 11 /**
11 * IM 收件箱 Mapper 12 * IM 收件箱 Mapper
12 * 13 *
yudao-module-im/yudao-module-im-biz/src/main/java/cn/iocoder/yudao/module/im/dal/mysql/message/MessageMapper.java
@@ -7,6 +7,7 @@ import org.apache.ibatis.annotations.Mapper; @@ -7,6 +7,7 @@ import org.apache.ibatis.annotations.Mapper;
7 7
8 import java.util.List; 8 import java.util.List;
9 9
  10 +// TODO @hao:IM 前缀
10 /** 11 /**
11 * 消息 Mapper 12 * 消息 Mapper
12 * 13 *
yudao-module-im/yudao-module-im-biz/src/main/java/cn/iocoder/yudao/module/im/dal/redis/inbox/SequenceRedisDAO.java
@@ -6,7 +6,7 @@ import org.springframework.stereotype.Repository; @@ -6,7 +6,7 @@ import org.springframework.stereotype.Repository;
6 6
7 import static cn.iocoder.yudao.module.im.dal.redis.RedisKeyConstants.INBOX_SEQUENCE; 7 import static cn.iocoder.yudao.module.im.dal.redis.RedisKeyConstants.INBOX_SEQUENCE;
8 8
9 -// TODO @芋艿:这个名字,需要在考虑下; 9 +// TODO @芋艿:这个名字,需要在考虑下;至少先搞个 IM 前缀
10 10
11 /** 11 /**
12 * 序号生成器 Redis DAO 12 * 序号生成器 Redis DAO
yudao-module-im/yudao-module-im-biz/src/main/java/cn/iocoder/yudao/module/im/service/conversation/ConversationService.java
@@ -6,6 +6,7 @@ import cn.iocoder.yudao.module.im.dal.dataobject.conversation.ImConversationDO; @@ -6,6 +6,7 @@ import cn.iocoder.yudao.module.im.dal.dataobject.conversation.ImConversationDO;
6 6
7 import java.util.List; 7 import java.util.List;
8 8
  9 +// TODO @hao:前缀 IM
9 /** 10 /**
10 * IM 会话 Service 接口 11 * IM 会话 Service 接口
11 * 12 *
yudao-module-im/yudao-module-im-biz/src/main/java/cn/iocoder/yudao/module/im/service/conversation/ConversationServiceImpl.java
@@ -5,13 +5,13 @@ import cn.iocoder.yudao.module.im.controller.admin.conversation.vo.ImConversatio @@ -5,13 +5,13 @@ import cn.iocoder.yudao.module.im.controller.admin.conversation.vo.ImConversatio
5 import cn.iocoder.yudao.module.im.dal.dataobject.conversation.ImConversationDO; 5 import cn.iocoder.yudao.module.im.dal.dataobject.conversation.ImConversationDO;
6 import cn.iocoder.yudao.module.im.dal.mysql.conversation.ConversationMapper; 6 import cn.iocoder.yudao.module.im.dal.mysql.conversation.ConversationMapper;
7 import cn.iocoder.yudao.module.im.enums.conversation.ImConversationTypeEnum; 7 import cn.iocoder.yudao.module.im.enums.conversation.ImConversationTypeEnum;
8 -import cn.iocoder.yudao.module.im.service.inbox.InboxService;  
9 import jakarta.annotation.Resource; 8 import jakarta.annotation.Resource;
10 import org.springframework.stereotype.Service; 9 import org.springframework.stereotype.Service;
11 import org.springframework.validation.annotation.Validated; 10 import org.springframework.validation.annotation.Validated;
12 11
13 import java.util.List; 12 import java.util.List;
14 13
  14 +// TODO @hao:前缀 IM
15 /** 15 /**
16 * IM 会话 Service 实现类 16 * IM 会话 Service 实现类
17 * 17 *
@@ -23,8 +23,6 @@ public class ConversationServiceImpl implements ConversationService { @@ -23,8 +23,6 @@ public class ConversationServiceImpl implements ConversationService {
23 23
24 @Resource 24 @Resource
25 private ConversationMapper conversationMapper; 25 private ConversationMapper conversationMapper;
26 - @Resource  
27 - private InboxService inboxService;  
28 26
29 @Override 27 @Override
30 public List<ImConversationDO> getConversationList() { 28 public List<ImConversationDO> getConversationList() {
yudao-module-im/yudao-module-im-biz/src/main/java/cn/iocoder/yudao/module/im/service/group/GroupService.java
@@ -5,6 +5,7 @@ import cn.iocoder.yudao.module.im.controller.admin.group.vo.*; @@ -5,6 +5,7 @@ import cn.iocoder.yudao.module.im.controller.admin.group.vo.*;
5 import cn.iocoder.yudao.module.im.dal.dataobject.group.ImGroupDO; 5 import cn.iocoder.yudao.module.im.dal.dataobject.group.ImGroupDO;
6 import cn.iocoder.yudao.framework.common.pojo.PageResult; 6 import cn.iocoder.yudao.framework.common.pojo.PageResult;
7 7
  8 +// TODO @hao:前缀 IM
8 /** 9 /**
9 * 群 Service 接口 10 * 群 Service 接口
10 * 11 *
yudao-module-im/yudao-module-im-biz/src/main/java/cn/iocoder/yudao/module/im/service/group/GroupServiceImpl.java
@@ -14,6 +14,7 @@ import cn.iocoder.yudao.module.im.dal.mysql.group.GroupMapper; @@ -14,6 +14,7 @@ import cn.iocoder.yudao.module.im.dal.mysql.group.GroupMapper;
14 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception; 14 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
15 import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.*; 15 import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.*;
16 16
  17 +// TODO @hao:前缀 IM
17 /** 18 /**
18 * 群 Service 实现类 19 * 群 Service 实现类
19 * 20 *
yudao-module-im/yudao-module-im-biz/src/main/java/cn/iocoder/yudao/module/im/service/inbox/InboxService.java
@@ -4,6 +4,7 @@ import cn.iocoder.yudao.module.im.dal.dataobject.message.ImMessageDO; @@ -4,6 +4,7 @@ import cn.iocoder.yudao.module.im.dal.dataobject.message.ImMessageDO;
4 4
5 import java.util.List; 5 import java.util.List;
6 6
  7 +// TODO @hao:前缀 IM
7 /** 8 /**
8 * IM 收件箱 Service 接口 9 * IM 收件箱 Service 接口
9 * 10 *
yudao-module-im/yudao-module-im-biz/src/main/java/cn/iocoder/yudao/module/im/service/message/MessageService.java
@@ -6,6 +6,7 @@ import cn.iocoder.yudao.module.im.dal.dataobject.message.ImMessageDO; @@ -6,6 +6,7 @@ import cn.iocoder.yudao.module.im.dal.dataobject.message.ImMessageDO;
6 6
7 import java.util.List; 7 import java.util.List;
8 8
  9 +// TODO @hao:前缀 IM
9 /** 10 /**
10 * 消息 Service 接口 11 * 消息 Service 接口
11 * 12 *
yudao-module-im/yudao-module-im-biz/src/main/java/cn/iocoder/yudao/module/im/service/message/MessageServiceImpl.java
@@ -24,6 +24,7 @@ import java.util.List; @@ -24,6 +24,7 @@ import java.util.List;
24 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception; 24 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
25 import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.MESSAGE_RECEIVER_NOT_EXISTS; 25 import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.MESSAGE_RECEIVER_NOT_EXISTS;
26 26
  27 +// TODO @hao:前缀 IM
27 /** 28 /**
28 * 消息 Service 实现类 29 * 消息 Service 实现类
29 * 30 *