Commit 79de92333fc2038363e82f2f784294cc5c0778d0

Authored by YunaiV
1 parent 773d0941

fix(im): 将频道消息的 pull 改成 pullChannelMessageList

yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/message/ImChannelMessageController.java
@@ -40,14 +40,14 @@ public class ImChannelMessageController { @@ -40,14 +40,14 @@ public class ImChannelMessageController {
40 40
41 @GetMapping("/pull") 41 @GetMapping("/pull")
42 @Operation(summary = "拉取频道消息(离线增量);按 minId 游标分页") 42 @Operation(summary = "拉取频道消息(离线增量);按 minId 游标分页")
43 - public CommonResult<List<ImChannelMessagePullRespVO>> pull( 43 + public CommonResult<List<ImChannelMessagePullRespVO>> pullChannelMessageList(
44 @RequestParam(value = "minId", defaultValue = "0") @PositiveOrZero(message = "minId 不能小于 0") Long minId, 44 @RequestParam(value = "minId", defaultValue = "0") @PositiveOrZero(message = "minId 不能小于 0") Long minId,
45 @RequestParam(value = "size", defaultValue = "100") 45 @RequestParam(value = "size", defaultValue = "100")
46 @Min(value = 1, message = "size 必须大于 0") 46 @Min(value = 1, message = "size 必须大于 0")
47 @Max(value = 200, message = "size 一次最多 200 条") Integer size) { 47 @Max(value = 200, message = "size 一次最多 200 条") Integer size) {
48 // 1. 拉取消息列表 48 // 1. 拉取消息列表
49 Long userId = getLoginUserId(); 49 Long userId = getLoginUserId();
50 - List<ImChannelMessageDO> list = channelMessageService.getMessageListForPull(userId, minId, size); 50 + List<ImChannelMessageDO> list = channelMessageService.pullChannelMessageList(userId, minId, size);
51 if (CollUtil.isEmpty(list)) { 51 if (CollUtil.isEmpty(list)) {
52 return success(Collections.emptyList()); 52 return success(Collections.emptyList());
53 } 53 }
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/message/ImChannelMessageService.java
@@ -27,7 +27,7 @@ public interface ImChannelMessageService { @@ -27,7 +27,7 @@ public interface ImChannelMessageService {
27 * @param size 返回条数 27 * @param size 返回条数
28 * @return 频道消息列表;按 id 升序 28 * @return 频道消息列表;按 id 升序
29 */ 29 */
30 - List<ImChannelMessageDO> getMessageListForPull(Long userId, Long minId, Integer size); 30 + List<ImChannelMessageDO> pullChannelMessageList(Long userId, Long minId, Integer size);
31 31
32 /** 32 /**
33 * 上报频道消息已读位置;同步推 READ 事件给自己多端 33 * 上报频道消息已读位置;同步推 READ 事件给自己多端
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/message/ImChannelMessageServiceImpl.java
@@ -57,7 +57,7 @@ public class ImChannelMessageServiceImpl implements ImChannelMessageService { @@ -57,7 +57,7 @@ public class ImChannelMessageServiceImpl implements ImChannelMessageService {
57 // ==================== 用户端 ==================== 57 // ==================== 用户端 ====================
58 58
59 @Override 59 @Override
60 - public List<ImChannelMessageDO> getMessageListForPull(Long userId, Long minId, Integer size) { 60 + public List<ImChannelMessageDO> pullChannelMessageList(Long userId, Long minId, Integer size) {
61 return channelMessageMapper.selectListByUserAndMinId(userId, minId, size); 61 return channelMessageMapper.selectListByUserAndMinId(userId, minId, size);
62 } 62 }
63 63