✨ feat(im): 继续优化频道的各种代码，

YunaiV
1 parent d6015601
Showing 25 changed files with 149 additions and 101 deletions
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/channel/ImChannelManagerController.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/channel/vo/material/ImChannelMaterialPageReqVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/channel/vo/material/ImChannelMaterialRespVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/channel/vo/material/ImChannelMaterialSaveReqVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/dal/dataobject/channel/ImChannelMaterialDO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/dal/mysql/channel/ImChannelMaterialMapper.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/enums/channel/ImChannelMaterialContentTypeEnum.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/channel/ImChannelMaterialService.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/channel/ImChannelMaterialServiceImpl.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/channel/ImChannelService.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/channel/ImChannelServiceImpl.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/websocket/dto/ImChannelMessageDTO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/websocket/dto/message/MaterialMessage.java
yudao-module-im/src/test/resources/sql/create_tables.sql
yudao-module-system/src/main/java/cn/iocoder/yudao/module/system/controller/admin/user/UserController.java
 package cn.iocoder.yudao.module.im.controller.admin.manager.channel;
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
 import cn.iocoder.yudao.framework.common.pojo.CommonResult;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
@@ -73,9 +74,9 @@ public class ImChannelManagerController {
     @GetMapping("/simple-list")
     @Operation(summary = "获得启用的频道精简列表；前端表单选择频道时调用")
-    public CommonResult<List<ImChannelRespVO>> getEnabledChannelList() {
-        // TODO @AI：getChannelListByXXX；更通用点；
-        List<ImChannelDO> list = channelService.getEnabledChannelList();
+    public CommonResult<List<ImChannelRespVO>> getSimpleChannelList() {
+        // TODO DONE @AI：getChannelListByStatus 统一命名
+        List<ImChannelDO> list = channelService.getChannelListByStatus(CommonStatusEnum.ENABLE.getStatus());
         return success(BeanUtils.toBean(list, ImChannelRespVO.class));
     }
@@ -18,8 +18,8 @@ public class ImChannelMaterialPageReqVO extends PageParam {
     @Schema(description = "频道编号", example = "1")
     private Long channelId;
-    @Schema(description = "素材类型", example = "125")
-    private Integer type;
+    @Schema(description = "内容类型", example = "1")
+    private Integer type; // 参见 ImChannelMaterialContentTypeEnum 枚举类
     @Schema(description = "标题", example = "活动")
     private String title;
@@ -18,8 +18,8 @@ public class ImChannelMaterialRespVO {
     @Schema(description = "频道名称（关联查询填充）")
     private String channelName;
-    @Schema(description = "素材类型", requiredMode = Schema.RequiredMode.REQUIRED, example = "125")
-    private Integer type; // 参见 ImMessageTypeEnum 枚举类
+    @Schema(description = "内容类型", requiredMode = Schema.RequiredMode.REQUIRED, example = "1")
+    private Integer type; // 参见 ImChannelMaterialContentTypeEnum 枚举类
     @Schema(description = "标题", requiredMode = Schema.RequiredMode.REQUIRED)
     private String title;
@@ -17,9 +17,9 @@ public class ImChannelMaterialSaveReqVO {
     @NotNull(message = "频道编号不能为空")
     private Long channelId;
-    @Schema(description = "素材类型", requiredMode = Schema.RequiredMode.REQUIRED, example = "125")
-    @NotNull(message = "素材类型不能为空")
-    private Integer type; // 参见 ImMessageTypeEnum 枚举类
+    @Schema(description = "内容类型", requiredMode = Schema.RequiredMode.REQUIRED, example = "1")
+    @NotNull(message = "内容类型不能为空")
+    private Integer type; // 参见 ImChannelMaterialContentTypeEnum 枚举类
     @Schema(description = "标题", requiredMode = Schema.RequiredMode.REQUIRED, example = "双十一活动来啦")
     @NotBlank(message = "标题不能为空")
-package cn.iocoder.yudao.module.im.controller.admin.manager.channel;
+package cn.iocoder.yudao.module.im.controller.admin.manager.message;
 import cn.hutool.core.collection.CollUtil;
 import cn.iocoder.yudao.framework.common.pojo.CommonResult;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.common.util.collection.MapUtils;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
-import cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.message.ImChannelMessagePageReqVO;
-import cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.message.ImChannelMessageRespVO;
-import cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.message.ImChannelMessageSendReqVO;
+import cn.iocoder.yudao.module.im.controller.admin.manager.message.vo.channel.ImChannelMessagePageReqVO;
+import cn.iocoder.yudao.module.im.controller.admin.manager.message.vo.channel.ImChannelMessageRespVO;
+import cn.iocoder.yudao.module.im.controller.admin.manager.message.vo.channel.ImChannelMessageSendReqVO;
 import cn.iocoder.yudao.module.im.dal.dataobject.channel.ImChannelDO;
 import cn.iocoder.yudao.module.im.dal.dataobject.channel.ImChannelMaterialDO;
-import cn.iocoder.yudao.module.im.dal.dataobject.channel.ImChannelMessageDO;
+import cn.iocoder.yudao.module.im.dal.dataobject.message.ImChannelMessageDO;
 import cn.iocoder.yudao.module.im.service.channel.ImChannelMaterialService;
-import cn.iocoder.yudao.module.im.service.channel.ImChannelMessageService;
+import cn.iocoder.yudao.module.im.service.message.ImChannelMessageService;
 import cn.iocoder.yudao.module.im.service.channel.ImChannelService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
@@ -26,7 +26,6 @@ import org.springframework.web.bind.annotation.*;
 import java.util.Map;
 import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
-import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertMap;
 import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertSet;
 @Tag(name = "管理后台 - IM 频道消息")
@@ -66,14 +65,11 @@ public class ImChannelMessageManagerController {
         if (CollUtil.isEmpty(pageResult.getList())) {
             return success(PageResult.empty(pageResult.getTotal()));
         }
-        // TODO @AI：最好是 channelService 也包出一个 getChannelMap；类似别的模块
-        Map<Long, ImChannelDO> channelMap = convertMap(
-                channelService.getChannelList(convertSet(pageResult.getList(), ImChannelMessageDO::getChannelId)),
-                ImChannelDO::getId);
-        // TODO @AI：最好是 channelService 也包出一个 getChannelMap；类似别的模块
-        Map<Long, ImChannelMaterialDO> materialMap = convertMap(
-                channelMaterialService.getMaterialList(convertSet(pageResult.getList(), ImChannelMessageDO::getMaterialId)),
-                ImChannelMaterialDO::getId);
+        // 批量查询频道和素材，并回填频道名 / 素材标题
+        Map<Long, ImChannelDO> channelMap = channelService.getChannelMap(
+                convertSet(pageResult.getList(), ImChannelMessageDO::getChannelId));
+        Map<Long, ImChannelMaterialDO> materialMap = channelMaterialService.getMaterialMap(
+                convertSet(pageResult.getList(), ImChannelMessageDO::getMaterialId));
         return success(BeanUtils.toBean(pageResult, ImChannelMessageRespVO.class, vo -> {
             MapUtils.findAndThen(channelMap, vo.getChannelId(), c -> vo.setChannelName(c.getName()));
             MapUtils.findAndThen(materialMap, vo.getMaterialId(), m -> vo.setMaterialTitle(m.getTitle()));
-package cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.message;
+package cn.iocoder.yudao.module.im.controller.admin.manager.message.vo.channel;
 import cn.iocoder.yudao.framework.common.pojo.PageParam;
 import io.swagger.v3.oas.annotations.media.Schema;
-package cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.message;
+package cn.iocoder.yudao.module.im.controller.admin.manager.message.vo.channel;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Data;
-package cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.message;
+package cn.iocoder.yudao.module.im.controller.admin.manager.message.vo.channel;
 import io.swagger.v3.oas.annotations.media.Schema;
 import jakarta.validation.constraints.NotNull;
-package cn.iocoder.yudao.module.im.controller.admin.channel;
+package cn.iocoder.yudao.module.im.controller.admin.message;
 import cn.iocoder.yudao.framework.common.pojo.CommonResult;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
-import cn.iocoder.yudao.module.im.controller.admin.channel.vo.ImChannelMessagePullRespVO;
-import cn.iocoder.yudao.module.im.dal.dataobject.channel.ImChannelMessageDO;
-import cn.iocoder.yudao.module.im.service.channel.ImChannelMessageService;
+import cn.iocoder.yudao.module.im.controller.admin.message.vo.channel.ImChannelMessagePullRespVO;
+import cn.iocoder.yudao.module.im.dal.dataobject.message.ImChannelMessageDO;
+import cn.iocoder.yudao.module.im.service.message.ImChannelMessageService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.annotation.Resource;
+import jakarta.validation.constraints.Max;
+import jakarta.validation.constraints.Min;
+import jakarta.validation.constraints.PositiveOrZero;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -31,8 +34,10 @@ public class ImChannelMessageController {
     @GetMapping("/pull")
     @Operation(summary = "拉取频道消息（离线增量）；按 minId 游标分页")
     public CommonResult<List<ImChannelMessagePullRespVO>> pull(
-            @RequestParam(value = "minId", defaultValue = "0") Long minId,
-            @RequestParam(value = "size", defaultValue = "100") Integer size) {
+            @RequestParam(value = "minId", defaultValue = "0") @PositiveOrZero(message = "minId 不能小于 0") Long minId,
+            @RequestParam(value = "size", defaultValue = "100")
+            @Min(value = 1, message = "size 必须大于 0")
+            @Max(value = 200, message = "size 一次最多 200 条") Integer size) {
         List<ImChannelMessageDO> list = channelMessageService.getMessageListForPull(getLoginUserId(), minId, size);
         return success(BeanUtils.toBean(list, ImChannelMessagePullRespVO.class));
     }
-package cn.iocoder.yudao.module.im.controller.admin.channel.vo;
+package cn.iocoder.yudao.module.im.controller.admin.message.vo.channel;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Data;
 package cn.iocoder.yudao.module.im.dal.dataobject.channel;
 import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
-import cn.iocoder.yudao.module.im.enums.message.ImMessageTypeEnum;
+import cn.iocoder.yudao.module.im.enums.channel.ImChannelMaterialContentTypeEnum;
 import com.baomidou.mybatisplus.annotation.KeySequence;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
@@ -39,9 +39,9 @@ public class ImChannelMaterialDO extends BaseDO {
      */
     private Long channelId;
     /**
-     * 素材类型
+     * 素材内容类型
      * <p>
-     * 枚举 {@link ImMessageTypeEnum}；当前仅 MATERIAL(125)
+     * 枚举 {@link ImChannelMaterialContentTypeEnum}
      */
     private Integer type;
     /**
@@ -56,15 +56,12 @@ public class ImChannelMaterialDO extends BaseDO {
      * 摘要
      */
     private String summary;
-    // TODO @AI：素材类型，是不是有个 type；这样一个 content、url 更好区分；然后这个 type ，是不是在 MATERIAL Message 类上，也带上；
     /**
-     * 正文；富文本 HTML
+     * 富文本 HTML；在 {@link ImChannelMaterialContentTypeEnum#CONTENT} 使用
      */
     private String content;
     /**
-     * 跳转链接
-     * <p>
-     * 为空时点击在客户端内置详情页拉 {@link #content} 渲染；非空则跳 url
+     * 跳转链接；在 {@link ImChannelMaterialContentTypeEnum#LINK} 使用
      */
     private String url;
-package cn.iocoder.yudao.module.im.dal.dataobject.channel;
+package cn.iocoder.yudao.module.im.dal.dataobject.message;
 import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
 import cn.iocoder.yudao.framework.mybatis.core.type.LongListTypeHandler;
@@ -20,21 +20,12 @@ public interface ImChannelMaterialMapper extends BaseMapperX&lt;ImChannelMaterialDO
     }
     default PageResult<ImChannelMaterialDO> selectPage(ImChannelMaterialPageReqVO reqVO) {
-        LambdaQueryWrapperX<ImChannelMaterialDO> wrapper = new LambdaQueryWrapperX<ImChannelMaterialDO>()
+        return selectPage(reqVO, new LambdaQueryWrapperX<ImChannelMaterialDO>()
                 .eqIfPresent(ImChannelMaterialDO::getChannelId, reqVO.getChannelId())
                 .eqIfPresent(ImChannelMaterialDO::getType, reqVO.getType())
                 .likeIfPresent(ImChannelMaterialDO::getTitle, reqVO.getTitle())
                 .betweenIfPresent(ImChannelMaterialDO::getCreateTime, reqVO.getCreateTime())
-                .orderByDesc(ImChannelMaterialDO::getId);
-        // TODO @AI：不用排除；列表问题不大的；
-        // 列表查询排除富文本 content 字段，避免 mediumtext 拖垮分页响应
-        wrapper.select(ImChannelMaterialDO::getId, ImChannelMaterialDO::getChannelId,
-                ImChannelMaterialDO::getType, ImChannelMaterialDO::getTitle,
-                ImChannelMaterialDO::getCoverUrl, ImChannelMaterialDO::getSummary,
-                ImChannelMaterialDO::getUrl, ImChannelMaterialDO::getCreator,
-                ImChannelMaterialDO::getCreateTime, ImChannelMaterialDO::getUpdater,
-                ImChannelMaterialDO::getUpdateTime, ImChannelMaterialDO::getDeleted);
-        return selectPage(reqVO, wrapper);
+                .orderByDesc(ImChannelMaterialDO::getId));
     }
 }
-package cn.iocoder.yudao.module.im.dal.mysql.channel;
+package cn.iocoder.yudao.module.im.dal.mysql.message;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
 import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
-import cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.message.ImChannelMessagePageReqVO;
-import cn.iocoder.yudao.module.im.dal.dataobject.channel.ImChannelMessageDO;
+import cn.iocoder.yudao.module.im.controller.admin.manager.message.vo.channel.ImChannelMessagePageReqVO;
+import cn.iocoder.yudao.module.im.dal.dataobject.message.ImChannelMessageDO;
 import org.apache.ibatis.annotations.Mapper;
 import java.util.List;
+package cn.iocoder.yudao.module.im.enums.channel;
+
+import cn.iocoder.yudao.framework.common.core.ArrayValuable;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+import java.util.Arrays;
+
+/**
+ * IM 频道素材内容类型枚举
+ *
+ * @author 芋道源码
+ */
+@Getter
+@AllArgsConstructor
+public enum ImChannelMaterialContentTypeEnum implements ArrayValuable<Integer> {
+
+    /**
+     * 站内富文本；点击素材在客户端内置详情页拉 content 渲染
+     */
+    CONTENT(1, "站内富文本"),
+    /**
+     * 外链；点击素材跳 url 打开浏览器
+     */
+    LINK(2, "外链");
+
+    public static final Integer[] ARRAYS = Arrays.stream(values()).map(ImChannelMaterialContentTypeEnum::getType).toArray(Integer[]::new);
+
+    private final Integer type;
+    private final String name;
+
+    @Override
+    public Integer[] array() {
+        return ARRAYS;
+    }
+
+}
@@ -8,6 +8,9 @@ import jakarta.validation.Valid;
 import java.util.Collection;
 import java.util.List;
+import java.util.Map;
+
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertMap;
 /**
  * IM 频道素材 Service 接口
@@ -19,14 +22,6 @@ public interface ImChannelMaterialService {
     // ==================== 用户端 ====================
     /**
-     * 获取素材正文；用于客户端点击图文卡片时拉富文本
-     *
-     * @param id 素材编号
-     * @return 富文本 HTML
-     */
-    String getMaterialContent(Long id);
-
-    /**
      * 校验素材存在
      *
      * @param id 素材编号
@@ -43,6 +38,16 @@ public interface ImChannelMaterialService {
     List<ImChannelMaterialDO> getMaterialList(Collection<Long> ids);
     /**
+     * 按编号批量查询素材 Map
+     *
+     * @param ids 素材编号列表
+     * @return id -> 素材 Map
+     */
+   default Map<Long, ImChannelMaterialDO> getMaterialMap(Collection<Long> ids) {
+       return convertMap(getMaterialList(ids), ImChannelMaterialDO::getId);
+   }
+
+    /**
      * 统计指定频道下的素材数量
      *
      * @param channelId 频道编号
@@ -7,7 +7,7 @@ import cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.material.I
 import cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.material.ImChannelMaterialSaveReqVO;
 import cn.iocoder.yudao.module.im.dal.dataobject.channel.ImChannelMaterialDO;
 import cn.iocoder.yudao.module.im.dal.mysql.channel.ImChannelMaterialMapper;
-import cn.iocoder.yudao.module.im.dal.mysql.channel.ImChannelMessageMapper;
+import cn.iocoder.yudao.module.im.dal.mysql.message.ImChannelMessageMapper;
 import jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
 import org.springframework.validation.annotation.Validated;
@@ -39,12 +39,6 @@ public class ImChannelMaterialServiceImpl implements ImChannelMaterialService {
     // ==================== 用户端 ====================
     @Override
-    public String getMaterialContent(Long id) {
-        ImChannelMaterialDO material = validateMaterialExists(id);
-        return material.getContent();
-    }
-
-    @Override
     public ImChannelMaterialDO validateMaterialExists(Long id) {
         ImChannelMaterialDO material = channelMaterialMapper.selectById(id);
         if (material == null) {
@@ -78,20 +72,25 @@ public class ImChannelMaterialServiceImpl implements ImChannelMaterialService {
         return channelMaterialMapper.selectById(id);
     }
-    // TODO @AI：类似别的模块，写全注释
     @Override
     public Long createMaterial(ImChannelMaterialSaveReqVO reqVO) {
+        // 1. 校验所属频道存在
         channelService.validateChannelExists(reqVO.getChannelId());
+
+        // 2. 插入素材
         ImChannelMaterialDO material = BeanUtils.toBean(reqVO, ImChannelMaterialDO.class);
         channelMaterialMapper.insert(material);
         return material.getId();
     }
-    // TODO @AI：类似别的模块，写全注释
     @Override
     public void updateMaterial(ImChannelMaterialSaveReqVO reqVO) {
+        // 1.1 校验存在
         validateMaterialExists(reqVO.getId());
+        // 1.2 校验所属频道存在
         channelService.validateChannelExists(reqVO.getChannelId());
+
+        // 2. 更新素材
         ImChannelMaterialDO updateObj = BeanUtils.toBean(reqVO, ImChannelMaterialDO.class);
         channelMaterialMapper.updateById(updateObj);
     }
@@ -8,6 +8,9 @@ import jakarta.validation.Valid;
 import java.util.Collection;
 import java.util.List;
+import java.util.Map;
+
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertMap;
 /**
  * IM 频道 Service 接口
@@ -18,13 +21,13 @@ public interface ImChannelService {
     // ==================== 用户端 ====================
-    // TODO @AI：getChannelListByStatus 这种形式；
     /**
-     * 获取所有启用的频道，按 sort 升序
+     * 按状态查询频道列表，按 sort 升序
      *
-     * @return 启用的频道列表
+     * @param status 状态；对应 CommonStatusEnum
+     * @return 频道列表
      */
-    List<ImChannelDO> getEnabledChannelList();
+    List<ImChannelDO> getChannelListByStatus(Integer status);
     /**
      * 按编号批量查询频道
@@ -35,6 +38,16 @@ public interface ImChannelService {
     List<ImChannelDO> getChannelList(Collection<Long> ids);
     /**
+     * 按编号批量查询频道 Map
+     *
+     * @param ids 频道编号列表
+     * @return id -> 频道 Map
+     */
+    default Map<Long, ImChannelDO> getChannelMap(Collection<Long> ids) {
+        return convertMap(getChannelList(ids), ImChannelDO::getId);
+    }
+
+    /**
      * 校验频道存在
      *
      * @param id 频道编号
@@ -2,7 +2,6 @@ package cn.iocoder.yudao.module.im.service.channel;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.ObjUtil;
-import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
 import cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.channel.ImChannelPageReqVO;
@@ -18,9 +17,7 @@ import java.util.Collections;
 import java.util.List;
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
-import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.IM_CHANNEL_CODE_DUPLICATED;
-import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.IM_CHANNEL_HAS_MATERIAL;
-import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.IM_CHANNEL_NOT_EXISTS;
+import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.*;
 /**
  * IM 频道 Service 实现类
@@ -39,8 +36,8 @@ public class ImChannelServiceImpl implements ImChannelService {
     // ==================== 用户端 ====================
     @Override
-    public List<ImChannelDO> getEnabledChannelList() {
-        return channelMapper.selectListByStatusOrderBySort(CommonStatusEnum.ENABLE.getStatus());
+    public List<ImChannelDO> getChannelListByStatus(Integer status) {
+        return channelMapper.selectListByStatusOrderBySort(status);
     }
     @Override
-package cn.iocoder.yudao.module.im.service.channel;
+package cn.iocoder.yudao.module.im.service.message;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
-import cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.message.ImChannelMessagePageReqVO;
-import cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.message.ImChannelMessageSendReqVO;
-import cn.iocoder.yudao.module.im.dal.dataobject.channel.ImChannelMessageDO;
+import cn.iocoder.yudao.module.im.controller.admin.manager.message.vo.channel.ImChannelMessagePageReqVO;
+import cn.iocoder.yudao.module.im.controller.admin.manager.message.vo.channel.ImChannelMessageSendReqVO;
+import cn.iocoder.yudao.module.im.dal.dataobject.message.ImChannelMessageDO;
 import jakarta.validation.Valid;
 import java.util.List;
-// TODO @AI：这块消息，我想挪到 message 里；后续，可能整合成一个表存储的；
 /**
  * IM 频道消息 Service 接口
  *
@@ -33,8 +32,6 @@ public interface ImChannelMessageService {
     /**
      * 立即推送频道消息
-     * <p>
-     * 流程：读 material → 组装 payload → INSERT 1 行 im_channel_message → WebSocket 扇出
      *
      * @param reqVO 推送请求
      * @return 消息编号
-package cn.iocoder.yudao.module.im.service.channel;
+package cn.iocoder.yudao.module.im.service.message;
 import cn.hutool.core.collection.CollUtil;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
-import cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.message.ImChannelMessagePageReqVO;
-import cn.iocoder.yudao.module.im.controller.admin.manager.channel.vo.message.ImChannelMessageSendReqVO;
+import cn.iocoder.yudao.module.im.controller.admin.manager.message.vo.channel.ImChannelMessagePageReqVO;
+import cn.iocoder.yudao.module.im.controller.admin.manager.message.vo.channel.ImChannelMessageSendReqVO;
 import cn.iocoder.yudao.module.im.dal.dataobject.channel.ImChannelMaterialDO;
-import cn.iocoder.yudao.module.im.dal.dataobject.channel.ImChannelMessageDO;
-import cn.iocoder.yudao.module.im.dal.mysql.channel.ImChannelMessageMapper;
+import cn.iocoder.yudao.module.im.dal.dataobject.message.ImChannelMessageDO;
+import cn.iocoder.yudao.module.im.dal.mysql.message.ImChannelMessageMapper;
 import cn.iocoder.yudao.module.im.enums.message.ImMessageTypeEnum;
+import cn.iocoder.yudao.module.im.service.channel.ImChannelMaterialService;
 import cn.iocoder.yudao.module.im.service.websocket.ImWebSocketService;
 import cn.iocoder.yudao.module.im.service.websocket.dto.ImChannelMessageDTO;
 import cn.iocoder.yudao.module.im.service.websocket.dto.message.MaterialMessage;
 package cn.iocoder.yudao.module.im.service.websocket.dto;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
-import cn.iocoder.yudao.module.im.dal.dataobject.channel.ImChannelMessageDO;
+import cn.iocoder.yudao.module.im.dal.dataobject.message.ImChannelMessageDO;
 import lombok.Data;
 import lombok.experimental.Accessors;
@@ -15,6 +15,14 @@ import lombok.experimental.Accessors;
 public class MaterialMessage {
     /**
+     * 素材内容类型
+     * <p>
+     * 枚举 {@link cn.iocoder.yudao.module.im.enums.channel.ImChannelMaterialContentTypeEnum}
+     * 客户端按本字段判定点击行为：CONTENT 走站内详情页拉富文本；LINK 跳 url
+     */
+    private Integer type;
+
+    /**
      * 标题
      */
     private String title;
@@ -27,7 +35,7 @@ public class MaterialMessage {
      */
     private String summary;
     /**
-     * 跳转链接；为空时点击在客户端内置详情页按 materialId 拉 content 渲染；非空则跳 url
+     * 跳转链接
      */
     private String url;
@@ -255,7 +255,7 @@ CREATE TABLE IF NOT EXISTS &quot;im_channel&quot; (
 CREATE TABLE IF NOT EXISTS "im_channel_material" (
     "id" bigint NOT NULL GENERATED BY DEFAULT AS IDENTITY COMMENT '编号',
     "channel_id" bigint NOT NULL COMMENT '频道编号',
-    "type" smallint NOT NULL COMMENT '素材类型；对应 ImMessageTypeEnum',
+    "type" tinyint NOT NULL COMMENT '内容类型；1 站内富文本 2 外链',
     "title" varchar(128) NOT NULL COMMENT '标题',
     "cover_url" varchar(512) DEFAULT NULL COMMENT '封面图',
     "summary" varchar(255) DEFAULT NULL COMMENT '摘要',
@@ -116,7 +116,8 @@ public class UserController {
     @GetMapping({"/list-all-simple", "/simple-list"})
     @Operation(summary = "获取用户精简信息列表", description = "只包含被开启的用户，主要用于前端的下拉选项")
-    public CommonResult<List<UserSimpleRespVO>> getSimpleUserList(@RequestParam("id") Long deptId) {
+    public CommonResult<List<UserSimpleRespVO>> getSimpleUserList(
+            @RequestParam(value = "deptId", required = false) Long deptId) {
         List<AdminUserDO> list;
         if (deptId != null) {
             List<Long> deptIds = Collections.singletonList(deptId);