+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 搜索
+ 重置
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ row.type_label || typeTagMap[row.type]?.label || '未知' }}
+
+
+
+
+
+
+ {{ getContentPreview(row) }}
+
+
+
+
+
+
+ {{ row.status_label || statusTagMap[row.status]?.label || '未知' }}
+
+
+
+
+
+
+
+ 详情
+
+
+ 撤回
+
+
+ 删除
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/admin/src/views/message/stats.vue b/admin/src/views/message/stats.vue
new file mode 100644
index 0000000..0290a78
--- /dev/null
+++ b/admin/src/views/message/stats.vue
@@ -0,0 +1,387 @@
+
+
+
+
+
+
+ 消息管理
+
+
+
+
+ ![]()
+ {{ (row.sender_nickname || '?')[0] }}
+
+
+ {{ row.sender_nickname || '-' }}
+ ID: {{ row.sender_id }}
+
+
+
+
+
+
+
+
+
+
+
+
+ ![]()
+ {{ (currentMsg.sender_nickname || '?')[0] }}
+
+
+
+
+ {{ currentMsg.sender_nickname }}
+
+ {{ currentMsg.status_label }}
+
+
+
+
+
+
+
+
+ 消息类型
+
+
+ {{ currentMsg.type_label }}
+
+
+
+
+ 发送时间
+ {{ currentMsg.created_at }}
+
+
+
+
+
+ 消息内容
+
+
+
+
+
+
+
+
+ {{ formatJSON(currentMsg.extra) }}
+
+
+
+
+
+
+
diff --git a/backend/go-service/app/admin/controller/message_manage_controller.go b/backend/go-service/app/admin/controller/message_manage_controller.go
new file mode 100644
index 0000000..e09dd73
--- /dev/null
+++ b/backend/go-service/app/admin/controller/message_manage_controller.go
@@ -0,0 +1,137 @@
+// Package controller 提供管理端消息管理的 HTTP 接口处理
+package controller
+
+import (
+ "strconv"
+
+ "github.com/echochat/backend/app/admin/service"
+ "github.com/echochat/backend/app/dto"
+ "github.com/echochat/backend/pkg/utils"
+ "github.com/gin-gonic/gin"
+)
+
+// MessageManageController 管理端消息管理控制器
+type MessageManageController struct {
+ msgService *service.MessageManageService
+}
+
+// NewMessageManageController 创建消息管理控制器
+func NewMessageManageController(msgService *service.MessageManageService) *MessageManageController {
+ return &MessageManageController{msgService: msgService}
+}
+
+// GetMessageList 获取消息列表（分页+多条件筛选）
+// GET /api/v1/admin/messages
+func (ctl *MessageManageController) GetMessageList(c *gin.Context) {
+ ctx := c.Request.Context()
+
+ var req dto.AdminMessageListRequest
+ if err := c.ShouldBindQuery(&req); err != nil {
+ utils.ResponseBadRequest(c, "参数格式错误")
+ return
+ }
+
+ result, err := ctl.msgService.GetMessageList(ctx, &req)
+ if err != nil {
+ ctl.handleError(c, err, "获取消息列表失败")
+ return
+ }
+
+ utils.ResponseOK(c, result)
+}
+
+// GetMessageDetail 获取消息详情
+// GET /api/v1/admin/messages/:id
+func (ctl *MessageManageController) GetMessageDetail(c *gin.Context) {
+ ctx := c.Request.Context()
+
+ id, err := strconv.ParseInt(c.Param("id"), 10, 64)
+ if err != nil || id <= 0 {
+ utils.ResponseBadRequest(c, "无效的消息 ID")
+ return
+ }
+
+ result, err := ctl.msgService.GetMessageDetail(ctx, id)
+ if err != nil {
+ ctl.handleError(c, err, "获取消息详情失败")
+ return
+ }
+
+ utils.ResponseOK(c, result)
+}
+
+// DeleteMessage 删除消息（软删除）
+// DELETE /api/v1/admin/messages/:id
+func (ctl *MessageManageController) DeleteMessage(c *gin.Context) {
+ ctx := c.Request.Context()
+
+ id, err := strconv.ParseInt(c.Param("id"), 10, 64)
+ if err != nil || id <= 0 {
+ utils.ResponseBadRequest(c, "无效的消息 ID")
+ return
+ }
+
+ if err := ctl.msgService.DeleteMessage(ctx, id); err != nil {
+ ctl.handleError(c, err, "删除消息失败")
+ return
+ }
+
+ utils.ResponseOK(c, nil)
+}
+
+// RecallMessage 管理员撤回消息
+// PUT /api/v1/admin/messages/:id/recall
+func (ctl *MessageManageController) RecallMessage(c *gin.Context) {
+ ctx := c.Request.Context()
+
+ id, err := strconv.ParseInt(c.Param("id"), 10, 64)
+ if err != nil || id <= 0 {
+ utils.ResponseBadRequest(c, "无效的消息 ID")
+ return
+ }
+
+ if err := ctl.msgService.RecallMessage(ctx, id); err != nil {
+ ctl.handleError(c, err, "撤回消息失败")
+ return
+ }
+
+ utils.ResponseOK(c, nil)
+}
+
+// GetMessageStats 获取消息统计数据
+// GET /api/v1/admin/messages/stats
+func (ctl *MessageManageController) GetMessageStats(c *gin.Context) {
+ ctx := c.Request.Context()
+
+ var req dto.AdminMessageStatsRequest
+ if err := c.ShouldBindQuery(&req); err != nil {
+ utils.ResponseBadRequest(c, "参数格式错误")
+ return
+ }
+
+ result, err := ctl.msgService.GetStats(ctx, &req)
+ if err != nil {
+ ctl.handleError(c, err, "获取消息统计失败")
+ return
+ }
+
+ utils.ResponseOK(c, result)
+}
+
+// handleError 统一业务错误映射
+func (ctl *MessageManageController) handleError(c *gin.Context, err error, fallbackMsg ...string) {
+ switch err {
+ case service.ErrMessageNotFound:
+ utils.ResponseNotFound(c, err.Error())
+ case service.ErrMessageRecalled:
+ utils.ResponseBadRequest(c, err.Error())
+ case service.ErrMessageDeleted:
+ utils.ResponseBadRequest(c, err.Error())
+ default:
+ msg := "服务器内部错误"
+ if len(fallbackMsg) > 0 && fallbackMsg[0] != "" {
+ msg = fallbackMsg[0]
+ }
+ utils.ResponseError(c, msg)
+ }
+}
diff --git a/backend/go-service/app/admin/dao/message_manage_dao.go b/backend/go-service/app/admin/dao/message_manage_dao.go
new file mode 100644
index 0000000..d00b234
--- /dev/null
+++ b/backend/go-service/app/admin/dao/message_manage_dao.go
@@ -0,0 +1,242 @@
+// Package dao 提供 admin 模块的数据库访问操作
+package dao
+
+import (
+ "context"
+ "fmt"
+ "time"
+
+ "github.com/echochat/backend/app/dto"
+ imModel "github.com/echochat/backend/app/im/model"
+ "github.com/echochat/backend/pkg/logs"
+ "go.uber.org/zap"
+ "gorm.io/gorm"
+)
+
+// MessageManageDAO 管理端消息数据访问对象
+type MessageManageDAO struct {
+ db *gorm.DB
+}
+
+// NewMessageManageDAO 创建 MessageManageDAO 实例
+func NewMessageManageDAO(db *gorm.DB) *MessageManageDAO {
+ return &MessageManageDAO{db: db}
+}
+
+// ListMessages 分页查询消息列表（支持多条件筛选）
+func (d *MessageManageDAO) ListMessages(ctx context.Context, req *dto.AdminMessageListRequest) ([]imModel.Message, int64, error) {
+ funcName := "dao.message_manage_dao.ListMessages"
+ logs.Debug(ctx, funcName, "查询消息列表")
+
+ query := d.db.WithContext(ctx).Model(&imModel.Message{})
+
+ if req.Keyword != "" {
+ query = query.Where("content ILIKE ?", fmt.Sprintf("%%%s%%", req.Keyword))
+ }
+ if req.Type != nil {
+ query = query.Where("type = ?", *req.Type)
+ }
+ if req.SenderID != nil {
+ query = query.Where("sender_id = ?", *req.SenderID)
+ }
+ if req.ConversationID != nil {
+ query = query.Where("conversation_id = ?", *req.ConversationID)
+ }
+ if req.Status != nil {
+ query = query.Where("status = ?", *req.Status)
+ }
+ if req.StartTime != "" {
+ if t, err := time.Parse("2006-01-02", req.StartTime); err == nil {
+ query = query.Where("created_at >= ?", t)
+ }
+ }
+ if req.EndTime != "" {
+ if t, err := time.Parse("2006-01-02", req.EndTime); err == nil {
+ query = query.Where("created_at < ?", t.AddDate(0, 0, 1))
+ }
+ }
+
+ var total int64
+ if err := query.Count(&total).Error; err != nil {
+ logs.Error(ctx, funcName, "统计消息总数失败", zap.Error(err))
+ return nil, 0, err
+ }
+
+ page := req.Page
+ if page <= 0 {
+ page = 1
+ }
+ pageSize := req.PageSize
+ if pageSize <= 0 {
+ pageSize = 20
+ }
+ if pageSize > 100 {
+ pageSize = 100
+ }
+
+ var messages []imModel.Message
+ err := query.Order("id DESC").
+ Offset((page - 1) * pageSize).
+ Limit(pageSize).
+ Find(&messages).Error
+ if err != nil {
+ logs.Error(ctx, funcName, "查询消息列表失败", zap.Error(err))
+ return nil, 0, err
+ }
+
+ return messages, total, nil
+}
+
+// GetMessageByID 根据 ID 查询单条消息
+func (d *MessageManageDAO) GetMessageByID(ctx context.Context, id int64) (*imModel.Message, error) {
+ var msg imModel.Message
+ err := d.db.WithContext(ctx).First(&msg, id).Error
+ if err != nil {
+ return nil, err
+ }
+ return &msg, nil
+}
+
+// UpdateMessageStatus 更新消息状态
+func (d *MessageManageDAO) UpdateMessageStatus(ctx context.Context, id int64, status int) error {
+ return d.db.WithContext(ctx).
+ Model(&imModel.Message{}).
+ Where("id = ?", id).
+ Update("status", status).Error
+}
+
+// GetTotalCount 获取消息总数
+func (d *MessageManageDAO) GetTotalCount(ctx context.Context) (int64, error) {
+ var count int64
+ err := d.db.WithContext(ctx).Model(&imModel.Message{}).Count(&count).Error
+ return count, err
+}
+
+// GetTodayCount 获取今日消息数
+func (d *MessageManageDAO) GetTodayCount(ctx context.Context) (int64, error) {
+ var count int64
+ today := time.Now().Truncate(24 * time.Hour)
+ err := d.db.WithContext(ctx).Model(&imModel.Message{}).
+ Where("created_at >= ?", today).Count(&count).Error
+ return count, err
+}
+
+// GetTypeDistribution 获取消息类型分布
+func (d *MessageManageDAO) GetTypeDistribution(ctx context.Context) ([]dto.TypeDistItem, error) {
+ type row struct {
+ Type int `gorm:"column:type"`
+ Count int64 `gorm:"column:count"`
+ }
+ var rows []row
+ err := d.db.WithContext(ctx).
+ Model(&imModel.Message{}).
+ Select("type, count(*) as count").
+ Group("type").
+ Order("count DESC").
+ Find(&rows).Error
+ if err != nil {
+ return nil, err
+ }
+
+ result := make([]dto.TypeDistItem, 0, len(rows))
+ for _, r := range rows {
+ result = append(result, dto.TypeDistItem{
+ Type: r.Type,
+ Count: r.Count,
+ })
+ }
+ return result, nil
+}
+
+// GetDailyTrend 获取每日消息趋势
+func (d *MessageManageDAO) GetDailyTrend(ctx context.Context, days int) ([]dto.DailyTrendItem, error) {
+ startDate := time.Now().AddDate(0, 0, -days).Truncate(24 * time.Hour)
+ type row struct {
+ Date string `gorm:"column:date"`
+ Count int64 `gorm:"column:count"`
+ }
+ var rows []row
+ err := d.db.WithContext(ctx).
+ Model(&imModel.Message{}).
+ Select("TO_CHAR(created_at, 'YYYY-MM-DD') as date, count(*) as count").
+ Where("created_at >= ?", startDate).
+ Group("date").
+ Order("date ASC").
+ Find(&rows).Error
+ if err != nil {
+ return nil, err
+ }
+
+ result := make([]dto.DailyTrendItem, 0, len(rows))
+ for _, r := range rows {
+ result = append(result, dto.DailyTrendItem{Date: r.Date, Count: r.Count})
+ }
+ return result, nil
+}
+
+// GetActiveUsers 获取活跃用户排行（Top 10）
+func (d *MessageManageDAO) GetActiveUsers(ctx context.Context, days int) ([]dto.ActiveUserItem, error) {
+ startDate := time.Now().AddDate(0, 0, -days).Truncate(24 * time.Hour)
+ type row struct {
+ UserID int64 `gorm:"column:sender_id"`
+ Nickname string `gorm:"column:nickname"`
+ Count int64 `gorm:"column:count"`
+ }
+ var rows []row
+ err := d.db.WithContext(ctx).
+ Raw(`SELECT m.sender_id, u.nickname, count(*) as count
+ FROM im_messages m
+ JOIN auth_users u ON u.id = m.sender_id
+ WHERE m.created_at >= ? AND m.sender_id > 0
+ GROUP BY m.sender_id, u.nickname
+ ORDER BY count DESC
+ LIMIT 10`, startDate).
+ Scan(&rows).Error
+ if err != nil {
+ return nil, err
+ }
+
+ result := make([]dto.ActiveUserItem, 0, len(rows))
+ for _, r := range rows {
+ result = append(result, dto.ActiveUserItem{
+ UserID: r.UserID,
+ Nickname: r.Nickname,
+ Count: r.Count,
+ })
+ }
+ return result, nil
+}
+
+// GetActiveGroups 获取活跃群组排行（Top 10）
+func (d *MessageManageDAO) GetActiveGroups(ctx context.Context, days int) ([]dto.ActiveGroupItem, error) {
+ startDate := time.Now().AddDate(0, 0, -days).Truncate(24 * time.Hour)
+ type row struct {
+ GroupID int64 `gorm:"column:id"`
+ Name string `gorm:"column:name"`
+ Count int64 `gorm:"column:count"`
+ }
+ var rows []row
+ err := d.db.WithContext(ctx).
+ Raw(`SELECT g.id, g.name, count(*) as count
+ FROM im_messages m
+ JOIN im_conversations c ON c.id = m.conversation_id
+ JOIN im_groups g ON g.conversation_id = c.id
+ WHERE m.created_at >= ? AND c.type = 2
+ GROUP BY g.id, g.name
+ ORDER BY count DESC
+ LIMIT 10`, startDate).
+ Scan(&rows).Error
+ if err != nil {
+ return nil, err
+ }
+
+ result := make([]dto.ActiveGroupItem, 0, len(rows))
+ for _, r := range rows {
+ result = append(result, dto.ActiveGroupItem{
+ GroupID: r.GroupID,
+ Name: r.Name,
+ Count: r.Count,
+ })
+ }
+ return result, nil
+}
diff --git a/backend/go-service/app/admin/router.go b/backend/go-service/app/admin/router.go
index d7a5eeb..ebb3580 100644
--- a/backend/go-service/app/admin/router.go
+++ b/backend/go-service/app/admin/router.go
@@ -16,6 +16,7 @@ func RegisterRoutes(
onlineCtrl *controller.OnlineController,
contactManageCtrl *controller.ContactManageController,
groupManageCtrl *controller.GroupManageController,
+ msgManageCtrl *controller.MessageManageController,
jwtAuth gin.HandlerFunc,
) {
// 管理端路由组：JWT 认证 + admin/super_admin 角色检查
@@ -44,5 +45,12 @@ func RegisterRoutes(
adminGroup.GET("/groups", groupManageCtrl.GetGroupList)
adminGroup.GET("/groups/:id", groupManageCtrl.GetGroupDetail)
adminGroup.DELETE("/groups/:id", groupManageCtrl.DissolveGroup)
+
+ // 消息管理
+ adminGroup.GET("/messages/stats", msgManageCtrl.GetMessageStats)
+ adminGroup.GET("/messages", msgManageCtrl.GetMessageList)
+ adminGroup.GET("/messages/:id", msgManageCtrl.GetMessageDetail)
+ adminGroup.DELETE("/messages/:id", msgManageCtrl.DeleteMessage)
+ adminGroup.PUT("/messages/:id/recall", msgManageCtrl.RecallMessage)
}
}
diff --git a/backend/go-service/app/admin/service/message_manage_service.go b/backend/go-service/app/admin/service/message_manage_service.go
new file mode 100644
index 0000000..07e8f09
--- /dev/null
+++ b/backend/go-service/app/admin/service/message_manage_service.go
@@ -0,0 +1,270 @@
+// Package service 提供 admin 模块的核心业务逻辑
+package service
+
+import (
+ "context"
+ "errors"
+
+ adminDAO "github.com/echochat/backend/app/admin/dao"
+ authDAO "github.com/echochat/backend/app/auth/dao"
+ imDAO "github.com/echochat/backend/app/im/dao"
+ "github.com/echochat/backend/app/constants"
+ "github.com/echochat/backend/app/dto"
+ "github.com/echochat/backend/pkg/logs"
+ "github.com/echochat/backend/pkg/ws"
+ "go.uber.org/zap"
+)
+
+var (
+ ErrMessageNotFound = errors.New("消息不存在")
+ ErrMessageRecalled = errors.New("消息已被撤回")
+ ErrMessageDeleted = errors.New("消息已被删除")
+)
+
+// MessageManageService 管理端消息管理服务
+type MessageManageService struct {
+ msgDAO *adminDAO.MessageManageDAO
+ userDAO *authDAO.UserDAO
+ convDAO *imDAO.ConversationDAO
+ pubSub *ws.PubSub
+}
+
+// NewMessageManageService 创建 MessageManageService 实例
+func NewMessageManageService(msgDAO *adminDAO.MessageManageDAO, userDAO *authDAO.UserDAO, convDAO *imDAO.ConversationDAO, pubSub *ws.PubSub) *MessageManageService {
+ return &MessageManageService{
+ msgDAO: msgDAO,
+ userDAO: userDAO,
+ convDAO: convDAO,
+ pubSub: pubSub,
+ }
+}
+
+// GetMessageList 获取消息列表（分页+筛选）
+func (s *MessageManageService) GetMessageList(ctx context.Context, req *dto.AdminMessageListRequest) (*dto.AdminMessageListResponse, error) {
+ funcName := "service.message_manage_service.GetMessageList"
+ logs.Debug(ctx, funcName, "获取消息列表")
+
+ if req.Page <= 0 {
+ req.Page = 1
+ }
+ if req.PageSize <= 0 {
+ req.PageSize = 20
+ }
+
+ messages, total, err := s.msgDAO.ListMessages(ctx, req)
+ if err != nil {
+ return nil, err
+ }
+
+ senderIDs := make([]int64, 0, len(messages))
+ senderSet := make(map[int64]bool)
+ for _, m := range messages {
+ if m.SenderID > 0 && !senderSet[m.SenderID] {
+ senderIDs = append(senderIDs, m.SenderID)
+ senderSet[m.SenderID] = true
+ }
+ }
+
+ userMap := make(map[int64]struct {
+ Nickname string
+ Avatar string
+ })
+ if len(senderIDs) > 0 {
+ users, uErr := s.userDAO.FindByIDs(ctx, senderIDs)
+ if uErr != nil {
+ logs.Error(ctx, funcName, "批量查询用户信息失败", zap.Error(uErr))
+ } else {
+ for _, u := range users {
+ userMap[u.ID] = struct {
+ Nickname string
+ Avatar string
+ }{Nickname: u.Nickname, Avatar: u.Avatar}
+ }
+ }
+ }
+
+ list := make([]dto.AdminMessageDTO, 0, len(messages))
+ for _, m := range messages {
+ item := dto.AdminMessageDTO{
+ ID: m.ID,
+ ConversationID: m.ConversationID,
+ SenderID: m.SenderID,
+ Type: m.Type,
+ TypeLabel: constants.MessageTypeMap[m.Type],
+ Content: m.Content,
+ Extra: m.Extra,
+ Status: m.Status,
+ StatusLabel: constants.MessageStatusMap[m.Status],
+ CreatedAt: m.CreatedAt.Format("2006-01-02 15:04:05"),
+ }
+ if info, ok := userMap[m.SenderID]; ok {
+ item.SenderNickname = info.Nickname
+ item.SenderAvatar = info.Avatar
+ }
+ list = append(list, item)
+ }
+
+ return &dto.AdminMessageListResponse{
+ Total: total,
+ List: list,
+ Page: req.Page,
+ PageSize: req.PageSize,
+ }, nil
+}
+
+// GetMessageDetail 获取消息详情
+func (s *MessageManageService) GetMessageDetail(ctx context.Context, id int64) (*dto.AdminMessageDTO, error) {
+ funcName := "service.message_manage_service.GetMessageDetail"
+ logs.Debug(ctx, funcName, "获取消息详情", zap.Int64("id", id))
+
+ msg, err := s.msgDAO.GetMessageByID(ctx, id)
+ if err != nil {
+ return nil, ErrMessageNotFound
+ }
+
+ item := &dto.AdminMessageDTO{
+ ID: msg.ID,
+ ConversationID: msg.ConversationID,
+ SenderID: msg.SenderID,
+ Type: msg.Type,
+ TypeLabel: constants.MessageTypeMap[msg.Type],
+ Content: msg.Content,
+ Extra: msg.Extra,
+ Status: msg.Status,
+ StatusLabel: constants.MessageStatusMap[msg.Status],
+ CreatedAt: msg.CreatedAt.Format("2006-01-02 15:04:05"),
+ }
+
+ if msg.SenderID > 0 {
+ users, uErr := s.userDAO.FindByIDs(ctx, []int64{msg.SenderID})
+ if uErr == nil && len(users) > 0 {
+ item.SenderNickname = users[0].Nickname
+ item.SenderAvatar = users[0].Avatar
+ }
+ }
+
+ return item, nil
+}
+
+// DeleteMessage 删除消息（软删除，状态改为已删除）
+func (s *MessageManageService) DeleteMessage(ctx context.Context, id int64) error {
+ funcName := "service.message_manage_service.DeleteMessage"
+ logs.Info(ctx, funcName, "删除消息", zap.Int64("id", id))
+
+ msg, err := s.msgDAO.GetMessageByID(ctx, id)
+ if err != nil {
+ return ErrMessageNotFound
+ }
+ if msg.Status == constants.MessageStatusDeleted {
+ return ErrMessageDeleted
+ }
+
+ return s.msgDAO.UpdateMessageStatus(ctx, id, constants.MessageStatusDeleted)
+}
+
+// RecallMessage 管理员撤回消息（更新状态 + 推送 WS 通知给会话成员）
+func (s *MessageManageService) RecallMessage(ctx context.Context, id int64) error {
+ funcName := "service.message_manage_service.RecallMessage"
+ logs.Info(ctx, funcName, "撤回消息", zap.Int64("id", id))
+
+ msg, err := s.msgDAO.GetMessageByID(ctx, id)
+ if err != nil {
+ return ErrMessageNotFound
+ }
+ if msg.Status == constants.MessageStatusRecalled {
+ return ErrMessageRecalled
+ }
+ if msg.Status == constants.MessageStatusDeleted {
+ return ErrMessageDeleted
+ }
+
+ if err := s.msgDAO.UpdateMessageStatus(ctx, id, constants.MessageStatusRecalled); err != nil {
+ return err
+ }
+
+ go s.pushRecallNotification(ctx, msg.ID, msg.ConversationID, msg.SenderID)
+
+ return nil
+}
+
+// pushRecallNotification 向会话成员推送撤回通知
+func (s *MessageManageService) pushRecallNotification(ctx context.Context, messageID, conversationID, senderID int64) {
+ funcName := "service.message_manage_service.pushRecallNotification"
+
+ memberIDs, err := s.convDAO.GetConversationMemberIDs(ctx, conversationID)
+ if err != nil {
+ logs.Error(ctx, funcName, "获取会话成员失败", zap.Error(err))
+ return
+ }
+
+ pushData := map[string]interface{}{
+ "message_id": messageID,
+ "conversation_id": conversationID,
+ "operator_id": int64(0),
+ "sender_id": senderID,
+ "recall_text": "管理员撤回了一条消息",
+ }
+
+ for _, uid := range memberIDs {
+ pushMsg := ws.NewPushMessage("im.message.recalled", pushData)
+ if err := s.pubSub.PublishToUser(ctx, uid, pushMsg); err != nil {
+ logs.Error(ctx, funcName, "推送撤回通知失败", zap.Int64("user_id", uid), zap.Error(err))
+ }
+ }
+}
+
+// GetStats 获取消息统计数据
+func (s *MessageManageService) GetStats(ctx context.Context, req *dto.AdminMessageStatsRequest) (*dto.AdminMessageStatsResponse, error) {
+ funcName := "service.message_manage_service.GetStats"
+ logs.Debug(ctx, funcName, "获取消息统计")
+
+ days := req.Days
+ if days <= 0 {
+ days = 7
+ }
+ if days > 90 {
+ days = 90
+ }
+
+ totalCount, err := s.msgDAO.GetTotalCount(ctx)
+ if err != nil {
+ return nil, err
+ }
+
+ todayCount, err := s.msgDAO.GetTodayCount(ctx)
+ if err != nil {
+ return nil, err
+ }
+
+ typeDist, err := s.msgDAO.GetTypeDistribution(ctx)
+ if err != nil {
+ return nil, err
+ }
+ for i := range typeDist {
+ typeDist[i].Label = constants.MessageTypeMap[typeDist[i].Type]
+ }
+
+ dailyTrend, err := s.msgDAO.GetDailyTrend(ctx, days)
+ if err != nil {
+ return nil, err
+ }
+
+ activeUsers, err := s.msgDAO.GetActiveUsers(ctx, days)
+ if err != nil {
+ return nil, err
+ }
+
+ activeGroups, err := s.msgDAO.GetActiveGroups(ctx, days)
+ if err != nil {
+ return nil, err
+ }
+
+ return &dto.AdminMessageStatsResponse{
+ TotalCount: totalCount,
+ TodayCount: todayCount,
+ TypeDistribution: typeDist,
+ DailyTrend: dailyTrend,
+ ActiveUsers: activeUsers,
+ ActiveGroups: activeGroups,
+ }, nil
+}
diff --git a/backend/go-service/app/auth/dao/user_dao.go b/backend/go-service/app/auth/dao/user_dao.go
index 34f15bc..5c090ce 100644
--- a/backend/go-service/app/auth/dao/user_dao.go
+++ b/backend/go-service/app/auth/dao/user_dao.go
@@ -115,6 +115,20 @@ func (d *UserDAO) UpdateLastLogin(ctx context.Context, userID int64, ip string)
return err
}
+// FindByIDs 批量按 ID 查询用户
+func (d *UserDAO) FindByIDs(ctx context.Context, ids []int64) ([]model.User, error) {
+ funcName := "dao.user_dao.FindByIDs"
+ logs.Debug(ctx, funcName, "批量查询用户", zap.Int("count", len(ids)))
+
+ var users []model.User
+ err := d.db.WithContext(ctx).Where("id IN ?", ids).Find(&users).Error
+ if err != nil {
+ logs.Error(ctx, funcName, "批量查询用户失败", zap.Error(err))
+ return nil, err
+ }
+ return users, nil
+}
+
// FindByAccount 按用户名或邮箱查找用户（登录时使用）
func (d *UserDAO) FindByAccount(ctx context.Context, account string) (*model.User, error) {
funcName := "dao.user_dao.FindByAccount"
diff --git a/backend/go-service/app/constants/im.go b/backend/go-service/app/constants/im.go
index 9e281e3..10b8f4c 100644
--- a/backend/go-service/app/constants/im.go
+++ b/backend/go-service/app/constants/im.go
@@ -15,10 +15,10 @@ var ConversationTypeMap = map[int]string{
// 消息类型
const (
MessageTypeText = 1 // 文本消息
- MessageTypeImage = 2 // 图片消息（预留）
- MessageTypeVoice = 3 // 语音消息（预留）
+ MessageTypeImage = 2 // 图片消息
+ MessageTypeVoice = 3 // 语音消息
MessageTypeVideo = 4 // 视频消息（预留）
- MessageTypeFile = 5 // 文件消息（预留）
+ MessageTypeFile = 5 // 文件消息
MessageTypeSystem = 10 // 系统消息（群聊操作通知）
)
diff --git a/backend/go-service/app/dto/admin_dto.go b/backend/go-service/app/dto/admin_dto.go
index c31508a..01d6f39 100644
--- a/backend/go-service/app/dto/admin_dto.go
+++ b/backend/go-service/app/dto/admin_dto.go
@@ -59,3 +59,84 @@ type AdminCreateUserRequest struct {
Nickname string `json:"nickname" binding:"max=50"` // 昵称（选填）
RoleCode string `json:"role_code" binding:"omitempty"` // 初始角色（选填，默认 user）
}
+
+// ====== 管理端消息管理 DTO ======
+
+// AdminMessageListRequest 管理端消息列表查询请求
+type AdminMessageListRequest struct {
+ Keyword string `form:"keyword"` // 搜索关键词（模糊匹配消息内容）
+ Type *int `form:"type"` // 消息类型筛选（1/2/3/5/10）
+ SenderID *int64 `form:"sender_id"` // 发送者 ID
+ ConversationID *int64 `form:"conversation_id"` // 会话 ID
+ Status *int `form:"status"` // 消息状态（1=正常/2=已撤回/3=已删除）
+ StartTime string `form:"start_time"` // 开始时间（YYYY-MM-DD）
+ EndTime string `form:"end_time"` // 结束时间（YYYY-MM-DD）
+ Page int `form:"page"` // 页码（默认1）
+ PageSize int `form:"page_size"` // 每页条数（默认20）
+}
+
+// AdminMessageListResponse 管理端消息列表响应
+type AdminMessageListResponse struct {
+ Total int64 `json:"total"` // 总条数
+ List []AdminMessageDTO `json:"list"` // 消息列表
+ Page int `json:"page"` // 当前页码
+ PageSize int `json:"page_size"` // 每页条数
+}
+
+// AdminMessageDTO 管理端消息条目
+type AdminMessageDTO struct {
+ ID int64 `json:"id"` // 消息 ID
+ ConversationID int64 `json:"conversation_id"` // 会话 ID
+ SenderID int64 `json:"sender_id"` // 发送者 ID
+ SenderNickname string `json:"sender_nickname"` // 发送者昵称
+ SenderAvatar string `json:"sender_avatar"` // 发送者头像
+ Type int `json:"type"` // 消息类型
+ TypeLabel string `json:"type_label"` // 类型中文标签
+ Content string `json:"content"` // 消息内容
+ Extra *string `json:"extra,omitempty"` // 扩展数据 JSON
+ Status int `json:"status"` // 消息状态
+ StatusLabel string `json:"status_label"` // 状态中文标签
+ CreatedAt string `json:"created_at"` // 发送时间
+}
+
+// AdminMessageStatsRequest 管理端消息统计请求
+type AdminMessageStatsRequest struct {
+ Days int `form:"days"` // 统计天数（默认7，最大90）
+}
+
+// AdminMessageStatsResponse 管理端消息统计响应
+type AdminMessageStatsResponse struct {
+ TotalCount int64 `json:"total_count"` // 消息总数
+ TodayCount int64 `json:"today_count"` // 今日消息数
+ TypeDistribution []TypeDistItem `json:"type_distribution"` // 类型分布
+ DailyTrend []DailyTrendItem `json:"daily_trend"` // 每日趋势
+ ActiveUsers []ActiveUserItem `json:"active_users"` // 活跃用户排行
+ ActiveGroups []ActiveGroupItem `json:"active_groups"` // 活跃群组排行
+}
+
+// TypeDistItem 消息类型分布条目
+type TypeDistItem struct {
+ Type int `json:"type"` // 消息类型
+ Label string `json:"label"` // 类型中文标签
+ Count int64 `json:"count"` // 数量
+}
+
+// DailyTrendItem 每日消息趋势条目
+type DailyTrendItem struct {
+ Date string `json:"date"` // 日期（YYYY-MM-DD）
+ Count int64 `json:"count"` // 数量
+}
+
+// ActiveUserItem 活跃用户排行条目
+type ActiveUserItem struct {
+ UserID int64 `json:"user_id"` // 用户 ID
+ Nickname string `json:"nickname"` // 昵称
+ Count int64 `json:"count"` // 消息数
+}
+
+// ActiveGroupItem 活跃群组排行条目
+type ActiveGroupItem struct {
+ GroupID int64 `json:"group_id"` // 群组 ID
+ Name string `json:"name"` // 群名称
+ Count int64 `json:"count"` // 消息数
+}
diff --git a/backend/go-service/app/dto/im_dto.go b/backend/go-service/app/dto/im_dto.go
index 4e670bb..448c427 100644
--- a/backend/go-service/app/dto/im_dto.go
+++ b/backend/go-service/app/dto/im_dto.go
@@ -6,23 +6,25 @@ package dto
type SendMessageRequest struct {
ConversationID int64 `json:"conversation_id"` // 会话 ID（与 TargetUserID 二选一）
TargetUserID int64 `json:"target_user_id"` // 对方用户 ID（首次发消息时使用，自动创建会话）
- Type int `json:"type"` // 消息类型：1=文本
- Content string `json:"content"` // 消息内容
+ Type int `json:"type"` // 消息类型：1=文本, 2=图片, 3=语音, 5=文件
+ Content string `json:"content"` // 消息内容（富媒体消息时为空字符串）
+ Extra string `json:"extra"` // 扩展数据 JSON 字符串（图片/语音/文件元信息）
ClientMsgID string `json:"client_msg_id"` // 客户端消息唯一 ID，用于幂等去重
AtUserIDs []int64 `json:"at_user_ids"` // @提醒用户 ID 列表（含 0 表示 @所有人）
}
// MessageDTO 消息传输对象（返回给前端）
type MessageDTO struct {
- ID int64 `json:"id"` // 消息 ID
- ConversationID int64 `json:"conversation_id"` // 所属会话 ID
- SenderID int64 `json:"sender_id"` // 发送者用户 ID
- Type int `json:"type"` // 消息类型
- Content string `json:"content"` // 消息内容
- Status int `json:"status"` // 消息状态：1=正常，2=已撤回
- ClientMsgID string `json:"client_msg_id"` // 客户端消息 ID
- AtUserIDs []int64 `json:"at_user_ids"` // @提醒用户 ID 列表
- CreatedAt string `json:"created_at"` // 发送时间
+ ID int64 `json:"id"` // 消息 ID
+ ConversationID int64 `json:"conversation_id"` // 所属会话 ID
+ SenderID int64 `json:"sender_id"` // 发送者用户 ID
+ Type int `json:"type"` // 消息类型
+ Content string `json:"content"` // 消息内容
+ Extra *string `json:"extra,omitempty"` // 扩展数据 JSON（图片/语音/文件元信息）
+ Status int `json:"status"` // 消息状态：1=正常，2=已撤回
+ ClientMsgID string `json:"client_msg_id"` // 客户端消息 ID
+ AtUserIDs []int64 `json:"at_user_ids"` // @提醒用户 ID 列表
+ CreatedAt string `json:"created_at"` // 发送时间
}
// RecallMessageRequest 撤回消息请求（WS 事件 im.message.recall 的 data 字段）
diff --git a/backend/go-service/app/file/controller/file_controller.go b/backend/go-service/app/file/controller/file_controller.go
index 6602efb..ff69eb7 100644
--- a/backend/go-service/app/file/controller/file_controller.go
+++ b/backend/go-service/app/file/controller/file_controller.go
@@ -2,13 +2,19 @@
package controller
import (
+ "strconv"
+
"github.com/echochat/backend/app/file/service"
"github.com/echochat/backend/pkg/middleware"
"github.com/echochat/backend/pkg/utils"
"github.com/gin-gonic/gin"
)
-const maxUploadSize = 10 << 20 // 10 MB
+const (
+ maxUploadSize = 50 << 20 // 50 MB（通用上传）
+ maxImageUploadSize = 20 << 20 // 20 MB（图片上传）
+ maxVoiceUploadSize = 5 << 20 // 5 MB（语音上传）
+)
// FileController 文件上传控制器
type FileController struct {
@@ -20,9 +26,9 @@ func NewFileController(fileService *service.FileService) *FileController {
return &FileController{fileService: fileService}
}
-// Upload 处理文件上传请求
+// Upload 处理通用文件上传请求
// POST /api/v1/upload
-// 支持 multipart/form-data，字段名为 "file"
+// 支持 multipart/form-data，字段名为 "file"，最大 50MB
func (ctl *FileController) Upload(c *gin.Context) {
ctx := c.Request.Context()
_, ok := middleware.GetCurrentUserID(c)
@@ -38,7 +44,7 @@ func (ctl *FileController) Upload(c *gin.Context) {
}
if fileHeader.Size > maxUploadSize {
- utils.ResponseBadRequest(c, "文件大小不能超过 10MB")
+ utils.ResponseBadRequest(c, "文件大小不能超过 50MB")
return
}
@@ -51,14 +57,94 @@ func (ctl *FileController) Upload(c *gin.Context) {
utils.ResponseOK(c, result)
}
+// UploadImage 处理图片上传请求，自动生成缩略图
+// POST /api/v1/upload/image
+// 支持 multipart/form-data，字段名为 "file"，最大 20MB
+// 返回原图 URL + 缩略图 URL + 宽高信息
+func (ctl *FileController) UploadImage(c *gin.Context) {
+ ctx := c.Request.Context()
+ _, ok := middleware.GetCurrentUserID(c)
+ if !ok {
+ utils.ResponseUnauthorized(c, "无法获取当前用户信息")
+ return
+ }
+
+ fileHeader, err := c.FormFile("file")
+ if err != nil {
+ utils.ResponseBadRequest(c, "请选择要上传的图片")
+ return
+ }
+
+ if fileHeader.Size > maxImageUploadSize {
+ utils.ResponseBadRequest(c, "图片大小不能超过 20MB")
+ return
+ }
+
+ result, err := ctl.fileService.UploadImage(ctx, fileHeader)
+ if err != nil {
+ ctl.handleError(c, err, "图片上传失败")
+ return
+ }
+
+ utils.ResponseOK(c, result)
+}
+
+// UploadVoice 处理语音上传请求，校验格式和时长
+// POST /api/v1/upload/voice
+// 支持 multipart/form-data，字段名为 "file"，另需 "duration" 字段（秒）
+// 最大 5MB，时长不超过 60 秒
+func (ctl *FileController) UploadVoice(c *gin.Context) {
+ ctx := c.Request.Context()
+ _, ok := middleware.GetCurrentUserID(c)
+ if !ok {
+ utils.ResponseUnauthorized(c, "无法获取当前用户信息")
+ return
+ }
+
+ fileHeader, err := c.FormFile("file")
+ if err != nil {
+ utils.ResponseBadRequest(c, "请选择要上传的语音文件")
+ return
+ }
+
+ if fileHeader.Size > maxVoiceUploadSize {
+ utils.ResponseBadRequest(c, "语音文件大小不能超过 5MB")
+ return
+ }
+
+ durationStr := c.PostForm("duration")
+ duration := 0
+ if durationStr != "" {
+ duration, err = strconv.Atoi(durationStr)
+ if err != nil || duration < 0 {
+ utils.ResponseBadRequest(c, "语音时长参数无效")
+ return
+ }
+ }
+
+ result, err := ctl.fileService.UploadVoice(ctx, fileHeader, duration)
+ if err != nil {
+ ctl.handleError(c, err, "语音上传失败")
+ return
+ }
+
+ utils.ResponseOK(c, result)
+}
+
// handleError 统一业务错误映射
-// 已知业务错误 → 返回 Service 层定义的具体提示
-// 未知错误 → 返回 fallbackMsg（未传则默认"服务器内部错误"）
func (ctl *FileController) handleError(c *gin.Context, err error, fallbackMsg ...string) {
switch err {
case service.ErrFileOpen:
utils.ResponseBadRequest(c, err.Error())
- case service.ErrUploadFailed:
+ case service.ErrInvalidImage:
+ utils.ResponseBadRequest(c, err.Error())
+ case service.ErrInvalidVoice:
+ utils.ResponseBadRequest(c, err.Error())
+ case service.ErrVoiceTooLong:
+ utils.ResponseBadRequest(c, err.Error())
+ case service.ErrFileTooLarge:
+ utils.ResponseBadRequest(c, err.Error())
+ case service.ErrUploadFailed, service.ErrThumbnailGen:
utils.ResponseError(c, err.Error())
default:
msg := "服务器内部错误"
diff --git a/backend/go-service/app/file/router.go b/backend/go-service/app/file/router.go
index 1eb9d9c..3b4f7ab 100644
--- a/backend/go-service/app/file/router.go
+++ b/backend/go-service/app/file/router.go
@@ -12,5 +12,7 @@ func RegisterRoutes(r *gin.Engine, ctrl *controller.FileController, jwtAuth gin.
authed.Use(jwtAuth)
{
authed.POST("/upload", ctrl.Upload)
+ authed.POST("/upload/image", ctrl.UploadImage)
+ authed.POST("/upload/voice", ctrl.UploadVoice)
}
}
diff --git a/backend/go-service/app/file/service/file_service.go b/backend/go-service/app/file/service/file_service.go
index 3aad8d4..636eb44 100644
--- a/backend/go-service/app/file/service/file_service.go
+++ b/backend/go-service/app/file/service/file_service.go
@@ -3,14 +3,20 @@
package service
import (
+ "bytes"
"context"
"errors"
"fmt"
+ "image"
+ _ "image/gif"
+ _ "image/jpeg"
+ _ "image/png"
"mime/multipart"
"path/filepath"
"strings"
"time"
+ "github.com/disintegration/imaging"
"github.com/echochat/backend/config"
"github.com/echochat/backend/pkg/logs"
"github.com/google/uuid"
@@ -19,8 +25,13 @@ import (
)
var (
- ErrFileOpen = errors.New("打开上传文件失败")
- ErrUploadFailed = errors.New("文件上传失败")
+ ErrFileOpen = errors.New("打开上传文件失败")
+ ErrUploadFailed = errors.New("文件上传失败")
+ ErrFileTooLarge = errors.New("文件大小超出限制")
+ ErrInvalidImage = errors.New("无效的图片文件")
+ ErrInvalidVoice = errors.New("不支持的语音格式，仅支持 mp3/wav/aac/m4a")
+ ErrVoiceTooLong = errors.New("语音时长不能超过 60 秒")
+ ErrThumbnailGen = errors.New("缩略图生成失败")
)
// FileService 文件上传服务
@@ -37,13 +48,41 @@ func NewFileService(client *minio.Client, cfg *config.MinioConfig) *FileService
}
}
-// UploadResult 文件上传结果
+// UploadResult 通用文件上传结果
type UploadResult struct {
URL string `json:"url"`
FileName string `json:"file_name"`
Size int64 `json:"size"`
}
+// ImageUploadResult 图片上传结果（含缩略图和尺寸）
+type ImageUploadResult struct {
+ URL string `json:"url"`
+ ThumbnailURL string `json:"thumbnail_url"`
+ FileName string `json:"file_name"`
+ Size int64 `json:"size"`
+ Width int `json:"width"`
+ Height int `json:"height"`
+ MimeType string `json:"mime_type"`
+}
+
+// VoiceUploadResult 语音上传结果（含时长）
+type VoiceUploadResult struct {
+ URL string `json:"url"`
+ FileName string `json:"file_name"`
+ Size int64 `json:"size"`
+ Duration int `json:"duration"`
+ MimeType string `json:"mime_type"`
+}
+
+// allowedVoiceExts 允许的语音文件扩展名
+var allowedVoiceExts = map[string]bool{
+ ".mp3": true,
+ ".wav": true,
+ ".aac": true,
+ ".m4a": true,
+}
+
// Upload 上传文件到 MinIO，返回文件访问 URL
// 文件按日期目录组织：uploads/2026/03/04/{uuid}.{ext}
func (s *FileService) Upload(ctx context.Context, fileHeader *multipart.FileHeader) (*UploadResult, error) {
@@ -76,11 +115,7 @@ func (s *FileService) Upload(ctx context.Context, fileHeader *multipart.FileHead
return nil, ErrUploadFailed
}
- scheme := "http"
- if s.minioCfg.UseSSL {
- scheme = "https"
- }
- url := fmt.Sprintf("%s://%s/%s/%s", scheme, s.minioCfg.Endpoint, s.minioCfg.Bucket, objectName)
+ url := s.buildURL(objectName)
return &UploadResult{
URL: url,
@@ -88,3 +123,142 @@ func (s *FileService) Upload(ctx context.Context, fileHeader *multipart.FileHead
Size: fileHeader.Size,
}, nil
}
+
+// UploadImage 上传图片并生成缩略图
+// 原图和缩略图均存储到 MinIO，缩略图宽度 200px 等比缩放，JPEG quality 80
+func (s *FileService) UploadImage(ctx context.Context, fileHeader *multipart.FileHeader) (*ImageUploadResult, error) {
+ funcName := "service.file_service.UploadImage"
+ logs.Info(ctx, funcName, "上传图片",
+ zap.String("file_name", fileHeader.Filename),
+ zap.Int64("size", fileHeader.Size))
+
+ file, err := fileHeader.Open()
+ if err != nil {
+ logs.Error(ctx, funcName, "打开图片文件失败", zap.Error(err))
+ return nil, ErrFileOpen
+ }
+ defer file.Close()
+
+ img, _, err := image.Decode(file)
+ if err != nil {
+ logs.Error(ctx, funcName, "解码图片失败", zap.Error(err))
+ return nil, ErrInvalidImage
+ }
+
+ bounds := img.Bounds()
+ width := bounds.Dx()
+ height := bounds.Dy()
+
+ now := time.Now()
+ fileID := uuid.New().String()
+ dateDir := now.Format("2006/01/02")
+
+ // 上传原图（回到文件开头）
+ if _, err = file.Seek(0, 0); err != nil {
+ logs.Error(ctx, funcName, "重置文件指针失败", zap.Error(err))
+ return nil, ErrFileOpen
+ }
+
+ ext := strings.ToLower(filepath.Ext(fileHeader.Filename))
+ objectName := fmt.Sprintf("uploads/%s/%s%s", dateDir, fileID, ext)
+
+ contentType := fileHeader.Header.Get("Content-Type")
+ if contentType == "" {
+ contentType = "image/jpeg"
+ }
+
+ _, err = s.minioClient.PutObject(ctx, s.minioCfg.Bucket, objectName, file, fileHeader.Size, minio.PutObjectOptions{
+ ContentType: contentType,
+ })
+ if err != nil {
+ logs.Error(ctx, funcName, "上传原图到 MinIO 失败", zap.Error(err))
+ return nil, ErrUploadFailed
+ }
+
+ // 生成缩略图：宽度 200px，等比缩放
+ thumb := imaging.Resize(img, 200, 0, imaging.Lanczos)
+
+ var thumbBuf bytes.Buffer
+ if err = imaging.Encode(&thumbBuf, thumb, imaging.JPEG, imaging.JPEGQuality(80)); err != nil {
+ logs.Error(ctx, funcName, "编码缩略图失败", zap.Error(err))
+ return nil, ErrThumbnailGen
+ }
+
+ thumbObjectName := fmt.Sprintf("uploads/%s/%s_thumb.jpg", dateDir, fileID)
+ _, err = s.minioClient.PutObject(ctx, s.minioCfg.Bucket, thumbObjectName, &thumbBuf, int64(thumbBuf.Len()), minio.PutObjectOptions{
+ ContentType: "image/jpeg",
+ })
+ if err != nil {
+ logs.Error(ctx, funcName, "上传缩略图到 MinIO 失败", zap.Error(err))
+ return nil, ErrThumbnailGen
+ }
+
+ return &ImageUploadResult{
+ URL: s.buildURL(objectName),
+ ThumbnailURL: s.buildURL(thumbObjectName),
+ FileName: fileHeader.Filename,
+ Size: fileHeader.Size,
+ Width: width,
+ Height: height,
+ MimeType: contentType,
+ }, nil
+}
+
+// UploadVoice 上传语音文件，校验格式和前端传入的时长
+// duration 由前端录音回调提供（秒），后端仅做范围校验
+func (s *FileService) UploadVoice(ctx context.Context, fileHeader *multipart.FileHeader, duration int) (*VoiceUploadResult, error) {
+ funcName := "service.file_service.UploadVoice"
+ logs.Info(ctx, funcName, "上传语音",
+ zap.String("file_name", fileHeader.Filename),
+ zap.Int64("size", fileHeader.Size),
+ zap.Int("duration", duration))
+
+ ext := strings.ToLower(filepath.Ext(fileHeader.Filename))
+ if !allowedVoiceExts[ext] {
+ return nil, ErrInvalidVoice
+ }
+
+ if duration > 60 {
+ return nil, ErrVoiceTooLong
+ }
+
+ file, err := fileHeader.Open()
+ if err != nil {
+ logs.Error(ctx, funcName, "打开语音文件失败", zap.Error(err))
+ return nil, ErrFileOpen
+ }
+ defer file.Close()
+
+ now := time.Now()
+ objectName := fmt.Sprintf("uploads/%s/%s%s", now.Format("2006/01/02"), uuid.New().String(), ext)
+
+ contentType := fileHeader.Header.Get("Content-Type")
+ if contentType == "" {
+ contentType = "audio/mpeg"
+ }
+
+ _, err = s.minioClient.PutObject(ctx, s.minioCfg.Bucket, objectName, file, fileHeader.Size, minio.PutObjectOptions{
+ ContentType: contentType,
+ })
+ if err != nil {
+ logs.Error(ctx, funcName, "上传语音到 MinIO 失败", zap.Error(err))
+ return nil, ErrUploadFailed
+ }
+
+ return &VoiceUploadResult{
+ URL: s.buildURL(objectName),
+ FileName: fileHeader.Filename,
+ Size: fileHeader.Size,
+ Duration: duration,
+ MimeType: contentType,
+ }, nil
+}
+
+// buildURL 根据 MinIO 配置构建文件访问 URL
+func (s *FileService) buildURL(objectName string) string {
+ scheme := "http"
+ if s.minioCfg.UseSSL {
+ scheme = "https"
+ }
+ return fmt.Sprintf("%s://%s/%s/%s", scheme, s.minioCfg.Endpoint, s.minioCfg.Bucket, objectName)
+}
diff --git a/backend/go-service/app/im/service/im_service.go b/backend/go-service/app/im/service/im_service.go
index c1666f7..279338d 100644
--- a/backend/go-service/app/im/service/im_service.go
+++ b/backend/go-service/app/im/service/im_service.go
@@ -2,6 +2,7 @@ package service
import (
"context"
+ "encoding/json"
"errors"
"fmt"
"time"
@@ -82,13 +83,19 @@ func (s *IMService) SendMessage(ctx context.Context, senderID int64, req *dto.Se
zap.Int64("conversation_id", req.ConversationID),
zap.Int64("target_user_id", req.TargetUserID))
- if req.Content == "" {
- return nil, ErrEmptyContent
- }
if req.Type == 0 {
req.Type = constants.MessageTypeText
}
- if req.Type != constants.MessageTypeText {
+ switch req.Type {
+ case constants.MessageTypeText:
+ if req.Content == "" {
+ return nil, ErrEmptyContent
+ }
+ case constants.MessageTypeImage, constants.MessageTypeVoice, constants.MessageTypeFile:
+ if req.Extra == "" {
+ return nil, ErrEmptyContent
+ }
+ default:
return nil, ErrInvalidMsgType
}
@@ -171,12 +178,16 @@ func (s *IMService) writeAndPushPrivateMessage(ctx context.Context, senderID, co
Status: constants.MessageStatusNormal,
ClientMsgID: req.ClientMsgID,
}
+ if req.Extra != "" {
+ msg.Extra = &req.Extra
+ }
if err := s.msgDAO.Create(ctx, msg); err != nil {
return nil, err
}
now := time.Now()
- if err := s.convDAO.UpdateLastMessage(ctx, convID, msg.ID, truncateContent(req.Content, 100), senderID, now); err != nil {
+ preview := generateLastMsgPreview(req.Type, req.Content, msg.Extra)
+ if err := s.convDAO.UpdateLastMessage(ctx, convID, msg.ID, preview, senderID, now); err != nil {
logs.Error(ctx, funcName, "更新最后消息失败", zap.Error(err))
}
@@ -244,6 +255,9 @@ func (s *IMService) sendGroupMessage(ctx context.Context, senderID int64, req *d
Status: constants.MessageStatusNormal,
ClientMsgID: req.ClientMsgID,
}
+ if req.Extra != "" {
+ msg.Extra = &req.Extra
+ }
if len(req.AtUserIDs) > 0 {
msg.AtUserIDs = req.AtUserIDs
}
@@ -252,7 +266,8 @@ func (s *IMService) sendGroupMessage(ctx context.Context, senderID int64, req *d
}
now := time.Now()
- if err := s.convDAO.UpdateLastMessage(ctx, convID, msg.ID, truncateContent(req.Content, 100), senderID, now); err != nil {
+ preview := generateLastMsgPreview(req.Type, req.Content, msg.Extra)
+ if err := s.convDAO.UpdateLastMessage(ctx, convID, msg.ID, preview, senderID, now); err != nil {
logs.Error(ctx, funcName, "更新最后消息失败", zap.Error(err))
}
@@ -944,6 +959,7 @@ func (s *IMService) toMessageDTO(m *model.Message) *dto.MessageDTO {
SenderID: m.SenderID,
Type: m.Type,
Content: m.Content,
+ Extra: m.Extra,
Status: m.Status,
ClientMsgID: m.ClientMsgID,
CreatedAt: m.CreatedAt.Format("2006-01-02 15:04:05"),
@@ -965,6 +981,9 @@ func (s *IMService) buildMessagePushData(ctx context.Context, msg *model.Message
"client_msg_id": msg.ClientMsgID,
"created_at": msg.CreatedAt.Format("2006-01-02 15:04:05"),
}
+ if msg.Extra != nil && *msg.Extra != "" {
+ pushData["extra"] = *msg.Extra
+ }
if senderUsers, sErr := s.userInfoGetter.GetUsersByIDs(ctx, []int64{senderID}); sErr == nil && len(senderUsers) > 0 {
pushData["sender_name"] = senderUsers[0].Nickname
pushData["sender_avatar"] = senderUsers[0].Avatar
@@ -978,6 +997,60 @@ type userBrief struct {
Avatar string
}
+// generateLastMsgPreview 根据消息类型生成会话列表预览文案
+func generateLastMsgPreview(msgType int, content string, extra *string) string {
+ switch msgType {
+ case constants.MessageTypeImage:
+ count := 1
+ if extra != nil && *extra != "" {
+ var parsed struct {
+ Images []json.RawMessage `json:"images"`
+ }
+ if json.Unmarshal([]byte(*extra), &parsed) == nil && len(parsed.Images) > 1 {
+ count = len(parsed.Images)
+ }
+ }
+ if count > 1 {
+ return fmt.Sprintf("[图片x%d]", count)
+ }
+ return "[图片]"
+ case constants.MessageTypeVoice:
+ duration := 0
+ if extra != nil && *extra != "" {
+ var parsed struct {
+ Voice struct {
+ Duration int `json:"duration"`
+ } `json:"voice"`
+ }
+ if json.Unmarshal([]byte(*extra), &parsed) == nil {
+ duration = parsed.Voice.Duration
+ }
+ }
+ if duration > 0 {
+ return fmt.Sprintf("[语音 %d\"]", duration)
+ }
+ return "[语音]"
+ case constants.MessageTypeFile:
+ fileName := ""
+ if extra != nil && *extra != "" {
+ var parsed struct {
+ File struct {
+ FileName string `json:"file_name"`
+ } `json:"file"`
+ }
+ if json.Unmarshal([]byte(*extra), &parsed) == nil {
+ fileName = parsed.File.FileName
+ }
+ }
+ if fileName != "" {
+ return fmt.Sprintf("[文件] %s", fileName)
+ }
+ return "[文件]"
+ default:
+ return truncateContent(content, 100)
+ }
+}
+
// truncateContent 截断消息内容用于预览
func truncateContent(s string, maxRunes int) string {
runes := []rune(s)
diff --git a/backend/go-service/app/provider/provider.go b/backend/go-service/app/provider/provider.go
index 8a651e3..5b345d4 100644
--- a/backend/go-service/app/provider/provider.go
+++ b/backend/go-service/app/provider/provider.go
@@ -35,6 +35,7 @@ type App struct {
OnlineController *adminController.OnlineController // 管理端在线监控控制器
ContactManageController *adminController.ContactManageController // 管理端好友关系管理控制器
GroupManageController *adminController.GroupManageController // 管理端群组管理控制器
+ MessageManageController *adminController.MessageManageController // 管理端消息管理控制器
WSHandler *wsApp.Handler // WebSocket 连接处理器
Hub *ws.Hub // WebSocket Hub 连接管理
PubSub *ws.PubSub // Redis Pub/Sub 消息路由
@@ -60,6 +61,7 @@ func NewApp(
onlineCtrl *adminController.OnlineController,
contactManageCtrl *adminController.ContactManageController,
groupManageCtrl *adminController.GroupManageController,
+ msgManageCtrl *adminController.MessageManageController,
wsHandler *wsApp.Handler,
hub *ws.Hub,
pubsub *ws.PubSub,
@@ -86,6 +88,7 @@ func NewApp(
OnlineController: onlineCtrl,
ContactManageController: contactManageCtrl,
GroupManageController: groupManageCtrl,
+ MessageManageController: msgManageCtrl,
WSHandler: wsHandler,
Hub: hub,
PubSub: pubsub,
diff --git a/backend/go-service/app/provider/wire_gen.go b/backend/go-service/app/provider/wire_gen.go
index 442d0b4..2f02076 100644
--- a/backend/go-service/app/provider/wire_gen.go
+++ b/backend/go-service/app/provider/wire_gen.go
@@ -93,6 +93,11 @@ func InitializeApp(cfg *config.Config) (*App, error) {
groupManageService := service2.NewGroupManageService(gormDB, groupDAO)
groupManageController := controller2.NewGroupManageController(groupManageService)
- app := NewApp(cfg, gormDB, client, minioClient, authService, authController, adminAuthController, userManageController, onlineController, contactManageController, groupManageController, handler, hub, pubSub, onlineService, contactController, imController, imEventHandler, offlinePusher, fileController, groupController)
+ // Admin 消息管理初始化
+ messageManageDAO := dao2.NewMessageManageDAO(gormDB)
+ messageManageService := service2.NewMessageManageService(messageManageDAO, userDAO, conversationDAO, pubSub)
+ messageManageController := controller2.NewMessageManageController(messageManageService)
+
+ app := NewApp(cfg, gormDB, client, minioClient, authService, authController, adminAuthController, userManageController, onlineController, contactManageController, groupManageController, messageManageController, handler, hub, pubSub, onlineService, contactController, imController, imEventHandler, offlinePusher, fileController, groupController)
return app, nil
}
diff --git a/backend/go-service/go.mod b/backend/go-service/go.mod
index df3d62d..882b513 100644
--- a/backend/go-service/go.mod
+++ b/backend/go-service/go.mod
@@ -24,6 +24,7 @@ require (
github.com/cespare/xxhash/v2 v2.3.0 // indirect
github.com/cloudwego/base64x v0.1.6 // indirect
github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
+ github.com/disintegration/imaging v1.6.2 // indirect
github.com/dustin/go-humanize v1.0.1 // indirect
github.com/fsnotify/fsnotify v1.9.0 // indirect
github.com/gabriel-vasile/mimetype v1.4.8 // indirect
@@ -66,6 +67,7 @@ require (
go.uber.org/multierr v1.10.0 // indirect
go.yaml.in/yaml/v3 v3.0.4 // indirect
golang.org/x/arch v0.20.0 // indirect
+ golang.org/x/image v0.0.0-20191009234506-e7c1f5e7dbb8 // indirect
golang.org/x/mod v0.26.0 // indirect
golang.org/x/net v0.42.0 // indirect
golang.org/x/sync v0.16.0 // indirect
diff --git a/backend/go-service/go.sum b/backend/go-service/go.sum
index 7776e68..b9fb081 100644
--- a/backend/go-service/go.sum
+++ b/backend/go-service/go.sum
@@ -15,6 +15,8 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
+github.com/disintegration/imaging v1.6.2 h1:w1LecBlG2Lnp8B3jk5zSuNqd7b4DXhcjwek1ei82L+c=
+github.com/disintegration/imaging v1.6.2/go.mod h1:44/5580QXChDfwIclfc/PCwrr44amcmDAg8hxG0Ewe4=
github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY=
github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=
github.com/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8=
@@ -149,6 +151,8 @@ golang.org/x/arch v0.20.0 h1:dx1zTU0MAE98U+TQ8BLl7XsJbgze2WnNKF/8tGp/Q6c=
golang.org/x/arch v0.20.0/go.mod h1:bdwinDaKcfZUGpH09BB7ZmOfhalA8lQdzl62l8gGWsk=
golang.org/x/crypto v0.40.0 h1:r4x+VvoG5Fm+eJcxMaY8CQM7Lb0l1lsmjGBQ6s8BfKM=
golang.org/x/crypto v0.40.0/go.mod h1:Qr1vMER5WyS2dfPHAlsOj01wgLbsyWtFn/aY+5+ZdxY=
+golang.org/x/image v0.0.0-20191009234506-e7c1f5e7dbb8 h1:hVwzHzIUGRjiF7EcUjqNxk3NCfkPxbDKRdnNE1Rpg0U=
+golang.org/x/image v0.0.0-20191009234506-e7c1f5e7dbb8/go.mod h1:FeLwcggjj3mMvU+oOTbSwawSJRM1uh48EjtB4UJZlP0=
golang.org/x/mod v0.26.0 h1:EGMPT//Ezu+ylkCijjPc+f4Aih7sZvaAr+O3EHBxvZg=
golang.org/x/mod v0.26.0/go.mod h1:/j6NAhSk8iQ723BGAUyoAcn7SlD7s15Dp9Nd/SfeaFQ=
golang.org/x/net v0.42.0 h1:jzkYrhi3YQWD6MLBJcsklgQsoAcw89EcZbJw8Z614hs=
@@ -158,6 +162,7 @@ golang.org/x/sync v0.16.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.35.0 h1:vz1N37gP5bs89s7He8XuIYXpyY0+QlsKmzipCbUtyxI=
golang.org/x/sys v0.35.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
+golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
golang.org/x/text v0.28.0 h1:rhazDwis8INMIwQ4tpjLDzUhx6RlXqZNPEM0huQojng=
golang.org/x/text v0.28.0/go.mod h1:U8nCwOR8jO/marOQ0QbDiOngZVEBB7MAiitBuMjXiNU=
golang.org/x/tools v0.35.0 h1:mBffYraMEf7aa0sB+NuKnuCy8qI/9Bughn8dC2Gu5r0=
diff --git a/backend/go-service/pkg/storage/minio.go b/backend/go-service/pkg/storage/minio.go
index 976d69d..f2ed060 100644
--- a/backend/go-service/pkg/storage/minio.go
+++ b/backend/go-service/pkg/storage/minio.go
@@ -12,7 +12,10 @@ import (
)
// NewMinioClient 初始化 MinIO 客户端并确保存储桶存在
-// 启动时自动创建配置中指定的 bucket（如不存在）
+// 启动时：
+// 1. 创建配置中指定的 bucket（如不存在）
+// 2. 为 bucket 设置 public-read 策略，使前端可通过 URL 直接访问已上传的图片、语音、文件等资源
+// （写入操作仍需 AccessKey/SecretKey 凭据，不影响安全性）
func NewMinioClient(cfg *config.MinioConfig) (*minio.Client, error) {
client, err := minio.New(cfg.Endpoint, &minio.Options{
Creds: credentials.NewStaticV4(cfg.AccessKey, cfg.SecretKey, ""),
@@ -34,5 +37,27 @@ func NewMinioClient(cfg *config.MinioConfig) (*minio.Client, error) {
}
}
+ if err := ensureBucketPublicRead(ctx, client, cfg.Bucket); err != nil {
+ return nil, fmt.Errorf("设置存储桶 %s 公开读策略失败: %w", cfg.Bucket, err)
+ }
+
return client, nil
}
+
+// ensureBucketPublicRead 设置 bucket 的匿名公开读策略
+// 允许匿名用户通过 HTTP GET 访问 bucket 内的对象（s3:GetObject）
+// 其他操作（上传、删除等）仍然需要 AccessKey/SecretKey 凭据
+func ensureBucketPublicRead(ctx context.Context, client *minio.Client, bucket string) error {
+ policy := fmt.Sprintf(`{
+ "Version": "2012-10-17",
+ "Statement": [
+ {
+ "Effect": "Allow",
+ "Principal": {"AWS": ["*"]},
+ "Action": ["s3:GetObject"],
+ "Resource": ["arn:aws:s3:::%s/*"]
+ }
+ ]
+}`, bucket)
+ return client.SetBucketPolicy(ctx, bucket, policy)
+}
diff --git a/backend/go-service/router/router.go b/backend/go-service/router/router.go
index a4e7568..4d586ca 100644
--- a/backend/go-service/router/router.go
+++ b/backend/go-service/router/router.go
@@ -36,7 +36,7 @@ func Setup(engine *gin.Engine, app *provider.App) {
// --- 各模块路由注册 ---
auth.RegisterRoutes(engine, app.AuthController, app.AdminAuthController, jwtAuth)
- admin.RegisterRoutes(engine, app.UserManageController, app.OnlineController, app.ContactManageController, app.GroupManageController, jwtAuth)
+ admin.RegisterRoutes(engine, app.UserManageController, app.OnlineController, app.ContactManageController, app.GroupManageController, app.MessageManageController, jwtAuth)
wsApp.RegisterRoutes(engine, app.WSHandler)
contact.RegisterRoutes(engine, app.ContactController, jwtAuth)
imApp.RegisterRoutes(engine, app.IMController, jwtAuth)
diff --git a/docs/api/README.md b/docs/api/README.md
index 6b1fb61..cbba0df 100644
--- a/docs/api/README.md
+++ b/docs/api/README.md
@@ -29,6 +29,7 @@
| [admin/online.md](admin/online.md) | 在线监控 | ✅ Phase 2a | 在线用户列表、在线用户计数 |
| [admin/contact.md](admin/contact.md) | 好友关系管理 | ✅ Phase 2a | 好友关系列表（分页）、管理员解除好友关系 |
| [admin/group.md](admin/group.md) | 群聊管理 | ✅ Phase 2c | 群列表/详情、管理员解散群聊 |
+| [admin/message.md](admin/message.md) | 消息管理 | ✅ Phase 2d | 消息列表/详情/撤回/删除、消息统计（5 个 API） |
| [admin/meeting.md](admin/meeting.md) | 会议管理 | 📋 后续 | 会议列表/详情、强制结束、会议统计 |
| [admin/system.md](admin/system.md) | 系统管理 | 📋 待定 | 仪表盘数据、操作日志、系统配置 |
@@ -206,6 +207,7 @@ docs/api/
│ ├── online.md # 在线监控 ✅ Phase 2a
│ ├── contact.md # 好友关系管理 ✅ Phase 2a
│ ├── group.md # 群聊管理（3 个 API） ✅ Phase 2c
+│ ├── message.md # 消息管理（5 个 API） ✅ Phase 2d
│ ├── meeting.md # 会议管理 📋 后续
│ └── system.md # 系统管理 📋 待定
└── websocket.md # WebSocket 全量事件协议 ✅ Phase 2a/2b/2c
diff --git a/docs/api/admin/message.md b/docs/api/admin/message.md
new file mode 100644
index 0000000..7533b00
--- /dev/null
+++ b/docs/api/admin/message.md
@@ -0,0 +1,162 @@
+# 管理端消息管理 API
+
+> **最后更新**：2026-03-03
+> **阶段**：Phase 2d
+
+---
+
+## 接口列表
+
+| 方法 | 路径 | 描述 | 认证 |
+|------|------|------|------|
+| GET | /api/v1/admin/messages | 消息列表（分页+多条件筛选） | JWT + admin |
+| GET | /api/v1/admin/messages/:id | 消息详情 | JWT + admin |
+| DELETE | /api/v1/admin/messages/:id | 删除消息（软删除） | JWT + admin |
+| PUT | /api/v1/admin/messages/:id/recall | 撤回消息 | JWT + admin |
+| GET | /api/v1/admin/messages/stats | 消息统计 | JWT + admin |
+
+---
+
+## GET /api/v1/admin/messages
+
+获取消息列表（分页+多条件筛选）。
+
+### 请求参数（Query）
+
+| 参数 | 类型 | 必填 | 说明 |
+|------|------|------|------|
+| page | int | 否 | 页码（默认 1） |
+| page_size | int | 否 | 每页条数（默认 20，最大 100） |
+| keyword | string | 否 | 搜索关键词（模糊匹配消息内容） |
+| type | int | 否 | 消息类型：1=文本 / 2=图片 / 3=语音 / 5=文件 / 10=系统 |
+| sender_id | int64 | 否 | 发送者 ID |
+| conversation_id | int64 | 否 | 会话 ID |
+| status | int | 否 | 消息状态：1=正常 / 2=已撤回 / 3=已删除 |
+| start_time | string | 否 | 开始日期（YYYY-MM-DD） |
+| end_time | string | 否 | 结束日期（YYYY-MM-DD） |
+
+### 响应
+
+```json
+{
+ "code": 0,
+ "message": "success",
+ "data": {
+ "total": 156,
+ "list": [
+ {
+ "id": 1,
+ "conversation_id": 5,
+ "sender_id": 10,
+ "sender_nickname": "张三",
+ "sender_avatar": "https://...",
+ "type": 1,
+ "type_label": "文本",
+ "content": "你好",
+ "extra": null,
+ "status": 1,
+ "status_label": "正常",
+ "created_at": "2026-03-03 14:30:00"
+ }
+ ],
+ "page": 1,
+ "page_size": 20
+ }
+}
+```
+
+---
+
+## GET /api/v1/admin/messages/:id
+
+获取消息详情。
+
+### 响应
+
+同列表中的单条消息对象。
+
+---
+
+## DELETE /api/v1/admin/messages/:id
+
+删除消息（软删除，状态改为 3=已删除）。
+
+### 响应
+
+```json
+{
+ "code": 0,
+ "message": "success",
+ "data": null
+}
+```
+
+---
+
+## PUT /api/v1/admin/messages/:id/recall
+
+管理员撤回消息。撤回后会通过 WebSocket 推送 `im.message.recalled` 事件给该会话的所有在线成员。
+
+### 响应
+
+```json
+{
+ "code": 0,
+ "message": "success",
+ "data": null
+}
+```
+
+### WS 推送事件
+
+```json
+{
+ "event": "im.message.recalled",
+ "data": {
+ "message_id": 123,
+ "conversation_id": 5,
+ "operator_id": 0,
+ "sender_id": 10,
+ "recall_text": "管理员撤回了一条消息"
+ }
+}
+```
+
+---
+
+## GET /api/v1/admin/messages/stats
+
+获取消息统计数据。
+
+### 请求参数（Query）
+
+| 参数 | 类型 | 必填 | 说明 |
+|------|------|------|------|
+| days | int | 否 | 统计天数（默认 7，最大 90） |
+
+### 响应
+
+```json
+{
+ "code": 0,
+ "message": "success",
+ "data": {
+ "total_count": 5680,
+ "today_count": 120,
+ "type_distribution": [
+ { "type": 1, "label": "文本", "count": 4500 },
+ { "type": 2, "label": "图片", "count": 800 }
+ ],
+ "daily_trend": [
+ { "date": "2026-02-25", "count": 150 },
+ { "date": "2026-02-26", "count": 200 }
+ ],
+ "active_users": [
+ { "user_id": 10, "nickname": "张三", "count": 500 }
+ ],
+ "active_groups": [
+ { "group_id": 1, "name": "技术交流群", "count": 300 }
+ ]
+ }
+}
+```
diff --git a/docs/api/frontend/im.md b/docs/api/frontend/im.md
index 8e3361c..fa0df7e 100644
--- a/docs/api/frontend/im.md
+++ b/docs/api/frontend/im.md
@@ -3,7 +3,7 @@
> 通用规范（认证方式、响应格式、错误码）见 [README.md](../README.md)
> 消息的实时收发（发送/撤回/标记已读/正在输入）通过 WebSocket 完成，见 [websocket.md](../websocket.md)
> 本文档中的接口用于会话管理和消息历史查询等非实时操作。
-> **最后更新：** 2026-03-04（Fix T19 已读详情群昵称 + Fix T20 免打扰 API 补全）
+> **最后更新：** 2026-03-03（Phase 2d 文件上传 API 新增）
---
@@ -20,6 +20,9 @@
| GET | /api/v1/im/messages/search | 需认证 | 全局消息搜索 |
| GET | /api/v1/im/unread | 需认证 | 获取全局未读消息总数 |
| GET | /api/v1/im/messages/:id/reads | 需认证 | 获取消息已读详情 |
+| POST | /api/v1/upload/image | 需认证 | 图片上传（含缩略图生成）[Phase 2d] |
+| POST | /api/v1/upload/voice | 需认证 | 语音上传（含时长校验）[Phase 2d] |
+| POST | /api/v1/upload | 需认证 | 通用文件上传（最大 50MB）[Phase 2d] |
---
diff --git a/docs/plans/2026-03-04-phase2d-design.md b/docs/plans/2026-03-04-phase2d-design.md
new file mode 100644
index 0000000..1ed9a95
--- /dev/null
+++ b/docs/plans/2026-03-04-phase2d-design.md
@@ -0,0 +1,704 @@
+# Phase 2d 设计文档：消息类型扩展
+
+> **状态：** ✅ 已完成
+> **分支：** `feature/phase2d-message-types`
+> **前置依赖：** Phase 2c 全部完成（群聊与已读回执）
+> **最后更新：** 2026-03-03
+
+---
+
+## 一、设计目标
+
+基于 Phase 2b/2c 的单聊+群聊文本消息基础设施，扩展三种富媒体消息类型和管理端消息管理功能。
+
+**核心交付物：**
+- 图片消息（type=2）：前端压缩+多图发送（最多9张）、后端生成 JPEG 缩略图、聊天内缩略图展示+大图预览
+- 语音消息（type=3）：微信风格按住录音/松手发送/上滑取消、最长60秒、时长波形条展示+播放
+- 文件消息（type=5）：任意文件上传（最大50MB）、类型图标+大小展示、点击下载+在线预览（PDF/图片）
+- 文件上传服务增强：大小限制提升至50MB、图片专用上传（缩略图生成）、语音专用上传（格式+时长校验）
+- 管理端消息管理：消息列表（完整筛选搜索）+ 消息统计仪表板（趋势图+类型分布+活跃排行）+ 敏感消息删除/撤回
+
+**不包含（留待后续阶段）：**
+- 视频消息（type=4，录制/压缩/缩略图复杂度高）
+- 表情包 / 自定义贴纸
+- 消息转发 / 合并转发
+- 消息引用 / 回复
+
+---
+
+## 二、需求决策记录
+
+### 2.1 消息类型决策
+
+| 决策项 | 选择 | 理由 |
+|--------|------|------|
+| 消息类型范围 | 图片+语音+文件（无视频） | 视频录制/压缩/缩略图复杂度高，留后续阶段 |
+| 多图策略 | 单条消息包含多图（最多9张） | 微信风格，extra JSON 存图片列表 |
+| 图片缩略图 | 后端 Go 图片库生成 | 保证各端一致性，前端仅做发送前压缩 |
+| 图片格式 | 统一转 JPEG | 兼容性最好，体积适中 |
+| 图片压缩 | 前端发送前压缩（宽>1920px 等比缩放，质量80%） | 减少上传流量 |
+| 缩略图尺寸 | 宽度不超过 200px，等比缩放，JPEG quality 80 | 列表加载快，质量可接受 |
+
+### 2.2 语音消息决策
+
+| 决策项 | 选择 | 理由 |
+|--------|------|------|
+| 交互方式 | 微信风格：按住录音/松手发送/上滑取消 | 用户认知成本低 |
+| 录音时长 | 最长 60 秒 | 微信标准 |
+| 录音格式 | MP3 | 跨端兼容性最好 |
+| 录音技术 | uni-app `uni.getRecorderManager()` | uni-app 原生 API，多端兼容 |
+
+### 2.3 文件消息决策
+
+| 决策项 | 选择 | 理由 |
+|--------|------|------|
+| 大小限制 | 50MB（上调原 10MB） | 支持 PPT/中等大小文件 |
+| 文件能力 | 上传+类型图标+大小显示+下载+在线预览（PDF/图片） | 完整用户体验 |
+| 文件类型限制 | 不限制（后端仅做大小校验） | 通用文件传输场景 |
+
+### 2.4 上传与发送流程决策
+
+| 决策项 | 选择 | 理由 |
+|--------|------|------|
+| 上传流程 | 先上传后发送：前端 REST 上传 → 获取 URL → WS 发消息 | 简单可靠，解耦文件上传和消息发送 |
+| 上传接口 | 按类型分离：通用/图片/语音三个接口 | 图片需要缩略图、语音需要时长校验，逻辑各异 |
+
+### 2.5 UI/UX 决策
+
+| 决策项 | 选择 | 理由 |
+|--------|------|------|
+| 会话列表预览 | 方括号标记：`[图片]`、`[语音 12"]`、`[文件] report.pdf` | 微信风格，用户习惯 |
+| 图片展示 | 聊天内缩略图（网格）+ 点击大图预览（Swiper） | 标准 IM 体验 |
+| 语音展示 | 时长+波形条+播放按钮 | 微信风格 |
+| 文件展示 | 文件图标+文件名+大小+下载/预览按钮 | 清晰直观 |
+| 表情包/贴纸 | 不做 | 专注核心媒体消息 |
+
+### 2.6 管理端决策
+
+| 决策项 | 选择 | 理由 |
+|--------|------|------|
+| 搜索筛选 | 完整：关键词+类型+发送者+会话/群+时间+状态 | 满足运营需求 |
+| 统计维度 | 完整：趋势图+类型分布+活跃用户排行+群活跃度 | 数据运营可视化 |
+| 图表库 | ECharts | admin 项目基于 Vue 3 + Element Plus，ECharts 集成良好 |
+
+---
+
+## 三、架构设计
+
+### 3.1 模块目录结构
+
+```
+backend/go-service/
+├── app/
+│ ├── file/ # 文件上传模块（增强）
+│ │ ├── controller/
+│ │ │ └── file_controller.go # 新增 UploadImage / UploadVoice 接口
+│ │ ├── service/
+│ │ │ └── file_service.go # 新增 UploadWithThumbnail / UploadVoice 方法
+│ │ ├── router.go # 新增 /upload/image 和 /upload/voice 路由
+│ │ └── provider.go
+│ ├── im/ # 即时通讯模块（适配）
+│ │ ├── service/
+│ │ │ └── im_service.go # SendMessage 适配 extra + 预览文案
+│ │ └── handler/
+│ │ └── event_handler.go # im.message.send 适配 extra 字段
+│ ├── admin/ # 管理端（新增消息管理）
+│ │ ├── controller/
+│ │ │ └── message_manage_controller.go # [新增]
+│ │ ├── service/
+│ │ │ └── message_manage_service.go # [新增]
+│ │ ├── dao/
+│ │ │ └── message_manage_dao.go # [新增]
+│ │ └── router.go # 注册消息管理路由
+│ ├── dto/
+│ │ ├── im_dto.go # 扩展 SendMessageRequest + MessageDTO 的 extra
+│ │ └── admin_dto.go # 新增管理端消息 DTO
+│ └── constants/
+│ └── im.go # 消息类型常量注释更新（2/3/5 不再标注"预留"）
+├── frontend/src/
+│ ├── api/
+│ │ └── file.js # [新增] 文件上传 API 封装
+│ ├── components/
+│ │ ├── msg/ # [新增] 消息类型组件
+│ │ │ ├── MsgText.vue # 文本消息组件
+│ │ │ ├── MsgImage.vue # 图片消息组件（网格+大图预览）
+│ │ │ ├── MsgVoice.vue # 语音消息组件（波形条+播放）
+│ │ │ └── MsgFile.vue # 文件消息组件（卡片+下载）
+│ │ └── chat/ # [新增] 聊天辅助组件
+│ │ ├── MorePanel.vue # "+"展开面板（图片/文件入口）
+│ │ ├── VoiceRecorder.vue # 语音录制组件
+│ │ └── ImagePreviewer.vue # 图片全屏预览
+│ ├── pages/
+│ │ ├── chat/conversation.vue # [修改] 引入消息组件+输入栏改造
+│ │ └── group/conversation.vue # [修改] 同上
+│ ├── store/
+│ │ └── chat.js # [修改] 扩展发送方法
+│ └── utils/
+│ └── file.js # [新增] 文件工具（压缩/格式判断/大小格式化）
+├── admin/src/
+│ ├── api/
+│ │ └── message.js # [新增] 管理端消息 API
+│ ├── views/
+│ │ └── message/ # [新增] 消息管理模块
+│ │ ├── list.vue # 消息列表（筛选+分页+操作）
+│ │ └── stats.vue # 消息统计仪表板
+│ └── router/
+│ └── index.js # 注册消息管理路由
+```
+
+### 3.2 跨模块依赖关系
+
+```
+file.FileService ← im.IMService (通过接口注入，暂不直接依赖)
+ ↓
+ im.IMService → convDAO/msgDAO (存储消息 + extra)
+ ↓
+ im.EventHandler → im.IMService (WS 事件调用)
+ ↓
+ admin.MessageManageService → im.MessageDAO (查询消息)
+ → auth.UserDAO (查询发送者)
+```
+
+消息发送流程中，**文件上传与消息发送是解耦的**：
+1. 前端通过 REST API 上传文件到 MinIO，获取 URL
+2. 前端通过 WS 发送消息，payload 中携带 `extra` 字段（含文件 URL）
+3. 后端 IM Service 直接存储，不再访问 file 模块
+
+---
+
+## 四、消息 extra 字段 JSON 结构设计
+
+`im_messages.extra` 字段类型为 JSONB（已存在），按消息类型存储不同元数据。
+
+### 4.1 图片消息（type=2）
+
+```json
+{
+ "images": [
+ {
+ "url": "http://localhost:9000/echochat/uploads/2026/03/05/abc.jpg",
+ "thumbnail_url": "http://localhost:9000/echochat/uploads/2026/03/05/abc_thumb.jpg",
+ "width": 1920,
+ "height": 1080,
+ "size": 245760,
+ "file_name": "photo.jpg"
+ },
+ {
+ "url": "http://localhost:9000/echochat/uploads/2026/03/05/def.jpg",
+ "thumbnail_url": "http://localhost:9000/echochat/uploads/2026/03/05/def_thumb.jpg",
+ "width": 1280,
+ "height": 720,
+ "size": 180000,
+ "file_name": "photo2.jpg"
+ }
+ ]
+}
+```
+
+### 4.2 语音消息（type=3）
+
+```json
+{
+ "voice": {
+ "url": "http://localhost:9000/echochat/uploads/2026/03/05/voice_xxx.mp3",
+ "duration": 12,
+ "size": 48000,
+ "file_name": "voice_20260305_120000.mp3"
+ }
+}
+```
+
+### 4.3 文件消息（type=5）
+
+```json
+{
+ "file": {
+ "url": "http://localhost:9000/echochat/uploads/2026/03/05/doc_xxx.pdf",
+ "file_name": "年度报告.pdf",
+ "size": 1048576,
+ "mime_type": "application/pdf",
+ "ext": ".pdf"
+ }
+}
+```
+
+---
+
+## 五、API 设计
+
+### 5.1 文件上传 REST API（扩展）
+
+| 方法 | 路径 | 权限 | 说明 |
+|------|------|------|------|
+| POST | /api/v1/upload | 需认证 | 通用文件上传（最大50MB） |
+| POST | /api/v1/upload/image | 需认证 | 图片上传（压缩+生成缩略图，返回双 URL） |
+| POST | /api/v1/upload/voice | 需认证 | 语音上传（校验格式+时长<=60s） |
+
+#### POST /api/v1/upload/image
+
+**请求**：multipart/form-data，字段名 `file`
+
+**成功响应**：
+
+```json
+{
+ "code": 0,
+ "message": "success",
+ "data": {
+ "url": "http://localhost:9000/echochat/uploads/2026/03/05/xxx.jpg",
+ "thumbnail_url": "http://localhost:9000/echochat/uploads/2026/03/05/xxx_thumb.jpg",
+ "file_name": "photo.jpg",
+ "size": 245760,
+ "width": 1920,
+ "height": 1080,
+ "mime_type": "image/jpeg"
+ }
+}
+```
+
+#### POST /api/v1/upload/voice
+
+**请求**：multipart/form-data，字段名 `file`
+
+**成功响应**：
+
+```json
+{
+ "code": 0,
+ "message": "success",
+ "data": {
+ "url": "http://localhost:9000/echochat/uploads/2026/03/05/voice_xxx.mp3",
+ "file_name": "voice_20260305.mp3",
+ "size": 48000,
+ "duration": 12,
+ "mime_type": "audio/mpeg"
+ }
+}
+```
+
+### 5.2 管理端消息管理 REST API（新增）
+
+| 方法 | 路径 | 权限 | 说明 |
+|------|------|------|------|
+| GET | /api/v1/admin/messages | admin | 消息列表（分页+多条件筛选） |
+| GET | /api/v1/admin/messages/:id | admin | 消息详情（含发送者信息） |
+| DELETE | /api/v1/admin/messages/:id | admin | 删除消息 |
+| PUT | /api/v1/admin/messages/:id/recall | admin | 管理员撤回消息 |
+| GET | /api/v1/admin/messages/stats | admin | 消息统计数据 |
+
+#### GET /api/v1/admin/messages
+
+**查询参数**：
+
+| 参数 | 类型 | 说明 |
+|------|------|------|
+| keyword | string | 搜索关键词（模糊匹配 content） |
+| type | int | 消息类型筛选（1/2/3/5/10） |
+| sender_id | int64 | 发送者 ID |
+| conversation_id | int64 | 会话 ID |
+| status | int | 消息状态（1=正常/2=已撤回/3=已删除） |
+| start_time | string | 开始时间（YYYY-MM-DD） |
+| end_time | string | 结束时间（YYYY-MM-DD） |
+| page | int | 页码（默认1） |
+| page_size | int | 每页条数（默认20） |
+
+**成功响应**：
+
+```json
+{
+ "code": 0,
+ "message": "success",
+ "data": {
+ "list": [
+ {
+ "id": 1,
+ "conversation_id": 5,
+ "sender_id": 4,
+ "sender_nickname": "张三",
+ "sender_avatar": "",
+ "type": 2,
+ "type_label": "图片",
+ "content": "",
+ "extra": { "images": [...] },
+ "status": 1,
+ "status_label": "正常",
+ "created_at": "2026-03-05 10:30:00"
+ }
+ ],
+ "total": 1000,
+ "page": 1,
+ "page_size": 20
+ }
+}
+```
+
+#### GET /api/v1/admin/messages/stats
+
+**查询参数**：
+
+| 参数 | 类型 | 说明 |
+|------|------|------|
+| days | int | 统计天数（默认7，最大90） |
+
+**成功响应**：
+
+```json
+{
+ "code": 0,
+ "message": "success",
+ "data": {
+ "total_count": 12580,
+ "today_count": 350,
+ "type_distribution": [
+ { "type": 1, "label": "文本", "count": 10000 },
+ { "type": 2, "label": "图片", "count": 1500 },
+ { "type": 3, "label": "语音", "count": 500 },
+ { "type": 5, "label": "文件", "count": 300 },
+ { "type": 10, "label": "系统消息", "count": 280 }
+ ],
+ "daily_trend": [
+ { "date": "2026-03-01", "count": 280 },
+ { "date": "2026-03-02", "count": 320 }
+ ],
+ "active_users": [
+ { "user_id": 4, "nickname": "张三", "count": 120 }
+ ],
+ "active_groups": [
+ { "group_id": 1, "name": "技术讨论群", "count": 500 }
+ ]
+ }
+}
+```
+
+### 5.3 WebSocket 事件变更
+
+**`im.message.send` 请求扩展**：
+
+```json
+{
+ "event": "im.message.send",
+ "data": {
+ "conversation_id": 8,
+ "type": 2,
+ "content": "",
+ "client_msg_id": "xxx",
+ "extra": "{\"images\":[{\"url\":\"...\",\"thumbnail_url\":\"...\",\"width\":1920,\"height\":1080,\"size\":245760,\"file_name\":\"photo.jpg\"}]}"
+ }
+}
+```
+
+**`im.message.new` 推送扩展**：
+
+推送数据增加 `extra` 字段（JSON string），前端解析后根据 `type` 渲染对应组件。
+
+**`im.message.send.ack` 响应扩展**：
+
+ACK 的 `data`（MessageDTO）增加 `extra` 字段。
+
+---
+
+## 六、核心业务流程
+
+### 6.1 图片消息发送流程
+
+1. 用户点击"+"面板中的"图片"，调用 `uni.chooseImage` 选择图片（最多9张）
+2. 前端对每张图片进行压缩（宽>1920px 等比缩放，质量80%）
+3. 逐张调用 `POST /api/v1/upload/image` 上传
+4. 后端接收图片 → 生成 JPEG 缩略图（宽200px，quality 80）→ 原图+缩略图存 MinIO
+5. 返回 `{ url, thumbnail_url, width, height, size, file_name, mime_type }`
+6. 所有图片上传完成后，前端组装 `extra.images` 数组
+7. 通过 WS 发送 `im.message.send`：`type=2`，`content=""`，`extra` 为 JSON 字符串
+8. 后端存储消息，`UpdateLastMessage` 预览文案为 `[图片]` 或 `[图片x3]`
+9. 推送 `im.message.new` 给接收方，携带 `extra`
+
+### 6.2 语音消息发送流程
+
+1. 用户长按麦克风按钮，调用 `uni.getRecorderManager().start({ format: 'mp3', duration: 60000 })`
+2. 录音过程中显示录音动画（时长 + 波形），上滑显示"取消发送"
+3. 松手停止录音 → 录音回调返回临时文件路径
+4. 时长 < 1秒：提示"录音时间太短"并丢弃
+5. 调用 `POST /api/v1/upload/voice` 上传语音文件
+6. 后端校验格式和时长（<=60s）→ 存 MinIO → 返回 `{ url, duration, size, file_name }`
+7. 前端组装 `extra.voice` 对象
+8. 通过 WS 发送：`type=3`，`content=""`，`extra` 为 JSON 字符串
+9. 后端存储，预览文案 `[语音 12"]`
+
+### 6.3 文件消息发送流程
+
+1. 用户点击"+"面板中的"文件"，调用 `uni.chooseFile` 或 `uni.chooseMessageFile`
+2. 校验文件大小（<=50MB）
+3. 调用 `POST /api/v1/upload` 通用上传接口
+4. 返回 `{ url, file_name, size }`
+5. 前端补充 `mime_type` 和 `ext`，组装 `extra.file` 对象
+6. 通过 WS 发送：`type=5`，`content=""`，`extra` 为 JSON 字符串
+7. 后端存储，预览文案 `[文件] report.pdf`
+
+### 6.4 管理员撤回消息流程
+
+1. 管理员在消息列表选中消息 → 点击"撤回"
+2. 调用 `PUT /api/v1/admin/messages/:id/recall`
+3. 后端将消息 status 改为 2（已撤回）
+4. 推送 `im.message.recalled` 给相关在线用户
+5. 会话最后消息预览更新为"管理员撤回了一条消息"
+
+---
+
+## 七、会话列表预览文案规则
+
+在 `IMService` 中 `UpdateLastMessage` 时根据消息类型生成预览文案：
+
+| type | content 字段用途 | last_msg_content 预览 |
+|------|-----------------|----------------------|
+| 1（文本） | 消息正文 | 消息正文（截断） |
+| 2（图片） | 空字符串 | `[图片]` / `[图片x3]`（多图标数量） |
+| 3（语音） | 空字符串 | `[语音 12"]`（duration 从 extra 解析） |
+| 5（文件） | 空字符串 | `[文件] report.pdf`（file_name 从 extra 解析） |
+| 10（系统） | 系统消息正文 | 系统消息正文 |
+
+---
+
+## 八、前端页面规划
+
+### 8.1 新增组件（前台用户端）
+
+| 组件 | 路径 | 说明 |
+|------|------|------|
+| MsgText.vue | components/msg/ | 文本消息组件（从 conversation 提取） |
+| MsgImage.vue | components/msg/ | 图片消息：1张=大图，2-4张=2列网格，5-9张=3列网格；点击放大 |
+| MsgVoice.vue | components/msg/ | 语音消息：播放按钮+波形条+时长（宽度按时长缩放） |
+| MsgFile.vue | components/msg/ | 文件消息：文件图标+文件名+大小+下载/预览按钮 |
+| MorePanel.vue | components/chat/ | 输入栏"+"展开面板：图片、文件两个入口 |
+| VoiceRecorder.vue | components/chat/ | 语音录制：长按录音+上滑取消+时长显示+波形动画 |
+| ImagePreviewer.vue | components/chat/ | 图片全屏预览：Swiper 左右滑+双指缩放 |
+
+### 8.2 修改页面（前台用户端）
+
+| 页面 | 修改内容 |
+|------|----------|
+| pages/chat/conversation.vue | 消息列表按 type 渲染不同组件；输入栏增加"+"和麦克风按钮 |
+| pages/group/conversation.vue | 同上 |
+| store/chat.js | 扩展 sendMessage 支持 extra；新增 sendImageMessage/sendVoiceMessage/sendFileMessage |
+
+### 8.3 新增页面（管理端）
+
+| 页面 | 路径 | 说明 |
+|------|------|------|
+| 消息列表 | views/message/list.vue | 多条件筛选+分页表格+撤回/删除操作 |
+| 消息统计 | views/message/stats.vue | ECharts 图表：趋势折线图+类型饼图+活跃排行柱状图 |
+
+---
+
+## 九、DTO 扩展规划
+
+### 9.1 发送消息请求扩展
+
+```go
+// SendMessageRequest 发送消息请求（WS 事件 im.message.send 的 data 字段）
+type SendMessageRequest struct {
+ ConversationID int64 `json:"conversation_id"`
+ TargetUserID int64 `json:"target_user_id"`
+ Type int `json:"type"`
+ Content string `json:"content"`
+ ClientMsgID string `json:"client_msg_id"`
+ AtUserIDs []int64 `json:"at_user_ids"`
+ Extra string `json:"extra"` // [Phase 2d 新增] 扩展数据 JSON 字符串
+}
+```
+
+### 9.2 消息 DTO 扩展
+
+```go
+// MessageDTO 消息传输对象（返回给前端）
+type MessageDTO struct {
+ ID int64 `json:"id"`
+ ConversationID int64 `json:"conversation_id"`
+ SenderID int64 `json:"sender_id"`
+ Type int `json:"type"`
+ Content string `json:"content"`
+ Extra *string `json:"extra,omitempty"` // [Phase 2d 新增] 扩展数据 JSON
+ Status int `json:"status"`
+ ClientMsgID string `json:"client_msg_id"`
+ AtUserIDs []int64 `json:"at_user_ids"`
+ CreatedAt string `json:"created_at"`
+}
+```
+
+### 9.3 文件上传结果 DTO 扩展
+
+```go
+// ImageUploadResult 图片上传结果
+type ImageUploadResult struct {
+ URL string `json:"url"`
+ ThumbnailURL string `json:"thumbnail_url"`
+ FileName string `json:"file_name"`
+ Size int64 `json:"size"`
+ Width int `json:"width"`
+ Height int `json:"height"`
+ MimeType string `json:"mime_type"`
+}
+
+// VoiceUploadResult 语音上传结果
+type VoiceUploadResult struct {
+ URL string `json:"url"`
+ FileName string `json:"file_name"`
+ Size int64 `json:"size"`
+ Duration int `json:"duration"`
+ MimeType string `json:"mime_type"`
+}
+```
+
+### 9.4 管理端消息 DTO
+
+```go
+// AdminMessageListRequest 管理端消息列表查询
+type AdminMessageListRequest struct {
+ Keyword string `form:"keyword"`
+ Type *int `form:"type"`
+ SenderID *int64 `form:"sender_id"`
+ ConversationID *int64 `form:"conversation_id"`
+ Status *int `form:"status"`
+ StartTime string `form:"start_time"`
+ EndTime string `form:"end_time"`
+ Page int `form:"page"`
+ PageSize int `form:"page_size"`
+}
+
+// AdminMessageDTO 管理端消息条目
+type AdminMessageDTO struct {
+ ID int64 `json:"id"`
+ ConversationID int64 `json:"conversation_id"`
+ SenderID int64 `json:"sender_id"`
+ SenderNickname string `json:"sender_nickname"`
+ SenderAvatar string `json:"sender_avatar"`
+ Type int `json:"type"`
+ TypeLabel string `json:"type_label"`
+ Content string `json:"content"`
+ Extra *string `json:"extra,omitempty"`
+ Status int `json:"status"`
+ StatusLabel string `json:"status_label"`
+ CreatedAt string `json:"created_at"`
+}
+
+// AdminMessageStatsRequest 管理端消息统计请求
+type AdminMessageStatsRequest struct {
+ Days int `form:"days"` // 统计天数（默认7，最大90）
+}
+
+// AdminMessageStatsResponse 管理端消息统计响应
+type AdminMessageStatsResponse struct {
+ TotalCount int64 `json:"total_count"`
+ TodayCount int64 `json:"today_count"`
+ TypeDistribution []TypeDistItem `json:"type_distribution"`
+ DailyTrend []DailyTrendItem `json:"daily_trend"`
+ ActiveUsers []ActiveUserItem `json:"active_users"`
+ ActiveGroups []ActiveGroupItem `json:"active_groups"`
+}
+
+type TypeDistItem struct {
+ Type int `json:"type"`
+ Label string `json:"label"`
+ Count int64 `json:"count"`
+}
+
+type DailyTrendItem struct {
+ Date string `json:"date"`
+ Count int64 `json:"count"`
+}
+
+type ActiveUserItem struct {
+ UserID int64 `json:"user_id"`
+ Nickname string `json:"nickname"`
+ Count int64 `json:"count"`
+}
+
+type ActiveGroupItem struct {
+ GroupID int64 `json:"group_id"`
+ Name string `json:"name"`
+ Count int64 `json:"count"`
+}
+```
+
+---
+
+## 十、技术要点
+
+### 10.1 Go 缩略图生成
+
+- 依赖：`github.com/disintegration/imaging`
+- 流程：`imaging.Open(file)` → `imaging.Resize(img, 200, 0, imaging.Lanczos)` → `imaging.Encode(buf, thumb, imaging.JPEG, imaging.JPEGQuality(80))`
+- 缩略图文件名：原始 UUID + `_thumb` 后缀，如 `abc123_thumb.jpg`
+- 原图同时进行 JPEG 转码（如果不是 JPEG 格式）
+
+### 10.2 前端图片压缩
+
+- H5 平台使用 Canvas 压缩：创建 Canvas → drawImage → toBlob('image/jpeg', 0.8)
+- 小程序/App 平台使用 `uni.compressImage({ src, quality: 80 })`
+- 压缩策略：宽度>1920px 等比缩放至 1920px，质量 80%
+
+### 10.3 语音录制
+
+- uni-app RecorderManager API
+- `start({ format: 'mp3', duration: 60000, sampleRate: 44100, numberOfChannels: 1 })`
+- 监听 `onStop` 获取录音文件临时路径
+- 时长计算：回调中的 `duration` 字段（毫秒），前端转秒显示
+
+### 10.4 语音播放
+
+- uni-app InnerAudioContext API
+- `uni.createInnerAudioContext()` → `src = voiceUrl` → `play()`
+- 全局单例：同一时间只允许一个语音播放
+- 播放状态：空闲 → 加载中 → 播放中 → 播放完成
+
+### 10.5 文件下载与预览
+
+- 下载：`uni.downloadFile({ url })` → `uni.saveFile()` 或直接 `window.open(url)` (H5)
+- 预览：PDF 和图片通过 `uni.openDocument` 或浏览器新标签打开
+- 文件类型图标映射：根据扩展名匹配图标（PDF/Word/Excel/PPT/ZIP/图片/音频/通用）
+
+### 10.6 管理端 ECharts 集成
+
+- `npm install echarts` 安装
+- 使用 Vue 3 Composition API + `onMounted` 初始化
+- 响应式：`window.resize` 时 `chart.resize()`
+- 主题色与系统保持一致（Primary #2563EB）
+
+---
+
+## 十一、补充设计细节
+
+### 11.1 消息内容安全
+
+- 文件上传不做内容安全审查（留后续阶段）
+- 管理端提供人工审查和撤回能力
+- 上传文件类型不限制，但大小限制 50MB
+
+### 11.2 多图布局规则
+
+| 图片数量 | 布局 | 单图最大宽度 |
+|----------|------|-------------|
+| 1 张 | 自适应宽度（最大 500rpx） | 500rpx |
+| 2 张 | 2列1行 | 240rpx |
+| 3 张 | 3列1行 | 160rpx |
+| 4 张 | 2列2行 | 240rpx |
+| 5-6 张 | 3列2行 | 160rpx |
+| 7-9 张 | 3列3行 | 160rpx |
+
+### 11.3 文件类型图标映射
+
+| 扩展名 | 图标 | 颜色 |
+|--------|------|------|
+| .pdf | PDF 图标 | #E53E3E |
+| .doc/.docx | Word 图标 | #2B6CB0 |
+| .xls/.xlsx | Excel 图标 | #276749 |
+| .ppt/.pptx | PPT 图标 | #C05621 |
+| .zip/.rar/.7z | 压缩包图标 | #6B46C1 |
+| .jpg/.png/.gif | 图片图标 | #38A169 |
+| .mp3/.wav/.aac | 音频图标 | #D69E2E |
+| 其他 | 通用文件图标 | #718096 |
+
+### 11.4 语音波形条设计
+
+- 宽度：按时长线性缩放，最小 120rpx（1秒），最大 500rpx（60秒）
+- 高度：固定 60rpx
+- 波形：使用 CSS 模拟随机高度的竖条（5-6 个竖条）
+- 播放时：从左到右逐条变色动画
diff --git a/docs/plans/2026-03-04-phase2d-implementation.plan.md b/docs/plans/2026-03-04-phase2d-implementation.plan.md
new file mode 100644
index 0000000..115b37b
--- /dev/null
+++ b/docs/plans/2026-03-04-phase2d-implementation.plan.md
@@ -0,0 +1,435 @@
+# Phase 2d 实施计划：消息类型扩展
+
+> **状态：** ✅ 已完成
+> **设计文档：** [Phase 2d 设计文档](./2026-03-04-phase2d-design.md)
+> **分支：** `feature/phase2d-message-types`
+> **最后更新：** 2026-03-03
+
+---
+
+## 实施概览
+
+共 14 个 Task，按依赖关系分为 4 个阶段：
+
+| 阶段 | Task | 说明 |
+|------|------|------|
+| 后端基础层 | Task 1-4 | 上传增强 → DTO/常量 → IM 适配 → 管理端后端 |
+| 前端消息组件 | Task 5-9 | 组件体系 → 图片 → 语音 → 文件 → 输入栏 |
+| 管理端前端 | Task 10-12 | 列表页 → 统计页 → 路由/Store/API |
+| 收尾 | Task 13-14 | 群聊适配+测试 → 代码审查+文档 |
+
+---
+
+## Task 1：文件上传服务增强 ✅
+
+**目标**：升级现有文件上传服务，支持 50MB 上传、图片缩略图生成、语音校验。
+
+### 修改文件
+
+| 文件 | 操作 | 说明 |
+|------|------|------|
+| backend/go-service/go.mod | 修改 | 添加 `github.com/disintegration/imaging` 依赖 |
+| backend/go-service/app/file/service/file_service.go | 修改 | 新增 `UploadWithThumbnail`、`UploadVoice` 方法；`UploadResult` 扩展字段 |
+| backend/go-service/app/file/controller/file_controller.go | 修改 | 新增 `UploadImage`、`UploadVoice` 处理器；`maxUploadSize` 提升至 50MB |
+| backend/go-service/app/file/router.go | 修改 | 新增 `/upload/image`、`/upload/voice` 路由 |
+
+### 详细步骤
+
+1. `go get github.com/disintegration/imaging` 安装图片处理库
+2. 扩展 `UploadResult` 添加 `ThumbnailURL`、`Width`、`Height`、`Duration`、`MimeType` 可选字段
+3. 新增 `ImageUploadResult` 和 `VoiceUploadResult` 结构体
+4. 实现 `UploadWithThumbnail`：
+ - 接收图片文件 → 解码获取宽高 → `imaging.Resize(img, 200, 0)` 生成缩略图
+ - 缩略图转 JPEG(quality=80) → 上传原图+缩略图到 MinIO → 返回双 URL + 尺寸
+5. 实现 `UploadVoice`：
+ - 接收语音文件 → 校验扩展名（.mp3/.wav/.aac/.m4a）→ 获取时长（从 header 或前端传参）
+ - 上传到 MinIO → 返回 URL + duration + size
+6. Controller 新增 `UploadImage`、`UploadVoice` 处理器（含大小校验）
+7. `maxUploadSize` 从 `10 << 20` 改为 `50 << 20`
+8. 路由注册新接口
+
+### 验收标准
+
+- [x] `POST /api/v1/upload` 支持 50MB 文件
+- [x] `POST /api/v1/upload/image` 返回 url + thumbnail_url + width + height
+- [x] `POST /api/v1/upload/voice` 返回 url + duration
+- [x] 缩略图宽度 200px，JPEG 格式
+
+---
+
+## Task 2：消息 extra 结构定义 + DTO 扩展 + 常量启用 ✅
+
+**目标**：定义 extra JSON 结构的 Go 类型、扩展消息 DTO、更新常量注释。
+
+### 修改文件
+
+| 文件 | 操作 | 说明 |
+|------|------|------|
+| backend/go-service/app/dto/im_dto.go | 修改 | SendMessageRequest + MessageDTO 增加 Extra 字段 |
+| backend/go-service/app/dto/admin_dto.go | 修改 | 新增管理端消息相关 DTO |
+| backend/go-service/app/constants/im.go | 修改 | 消息类型常量注释去掉"预留"标注 |
+
+### 详细步骤
+
+1. `SendMessageRequest` 增加 `Extra string` 字段
+2. `MessageDTO` 增加 `Extra *string` 字段（omitempty）
+3. `constants/im.go` 消息类型注释更新：去掉"预留"二字
+4. 在 `admin_dto.go` 中新增管理端消息 DTO 结构体
+
+### 验收标准
+
+- [x] SendMessageRequest 和 MessageDTO 支持 extra 字段
+- [x] 管理端消息 DTO 定义完成
+- [x] 常量注释准确反映当前实现状态
+
+---
+
+## Task 3：IM Service 适配富媒体消息 ✅
+
+**目标**：后端 IM 服务支持存储和推送富媒体消息。
+
+### 修改文件
+
+| 文件 | 操作 | 说明 |
+|------|------|------|
+| backend/go-service/app/im/service/im_service.go | 修改 | SendMessage 存储 extra；预览文案生成 |
+| backend/go-service/app/im/handler/event_handler.go | 修改 | im.message.send 解析 extra 字段 |
+| backend/go-service/app/im/dao/message_dao.go | 修改 | MessageDTO 转换包含 extra |
+
+### 详细步骤
+
+1. `EventHandler` 中 `im.message.send` 解析 `req.Extra` 并传给 Service
+2. `SendMessage` 中创建 Message 时设置 `Extra` 字段
+3. 新增 `generateLastMsgPreview(msgType int, content string, extra *string) string` 方法
+4. `UpdateLastMessage` 调用预览文案生成方法
+5. `buildMessagePushData` 返回的 MessageDTO 包含 extra
+6. 历史消息查询 `toMessageDTO` 中包含 extra 字段
+
+### 验收标准
+
+- [x] type=2/3/5 消息能正常存储到数据库，extra 字段不为空
+- [x] 推送 im.message.new 包含 extra 数据
+- [x] 会话列表预览文案正确（[图片]/[语音 12"]/[文件] xxx.pdf）
+- [x] 历史消息接口返回 extra 字段
+
+---
+
+## Task 4：管理端消息 DAO + Service + Controller ✅
+
+**目标**：实现管理端完整的消息管理后端 API。
+
+### 新增文件
+
+| 文件 | 操作 | 说明 |
+|------|------|------|
+| backend/go-service/app/admin/dao/message_manage_dao.go | 新增 | 消息分页查询、统计聚合 |
+| backend/go-service/app/admin/service/message_manage_service.go | 新增 | 消息管理业务逻辑 |
+| backend/go-service/app/admin/controller/message_manage_controller.go | 新增 | REST API 处理器 |
+| backend/go-service/app/admin/router.go | 修改 | 注册消息管理路由 |
+| backend/go-service/app/provider/provider.go | 修改 | Wire 注入新依赖 |
+
+### 详细步骤
+
+1. `message_manage_dao.go`：
+ - `GetMessageList`：分页+多条件筛选（keyword/type/sender/conversation/status/time）
+ - `GetMessageByID`：单条详情
+ - `UpdateMessageStatus`：更新状态（撤回/删除）
+ - `GetMessageStats`：统计聚合（总量/今日/类型分布/每日趋势/活跃用户/活跃群组）
+2. `message_manage_service.go`：
+ - `GetMessageList` / `GetMessageDetail` / `DeleteMessage` / `RecallMessage` / `GetStats`
+ - 撤回时推送 WS 事件给相关在线用户
+3. `message_manage_controller.go`：五个接口处理器
+4. Router 注册路由
+5. Wire provider 注册
+
+### 验收标准
+
+- [x] `GET /api/v1/admin/messages` 支持完整筛选
+- [x] `GET /api/v1/admin/messages/:id` 返回详细信息
+- [x] `DELETE /api/v1/admin/messages/:id` 软删除
+- [x] `PUT /api/v1/admin/messages/:id/recall` 撤回+推送
+- [x] `GET /api/v1/admin/messages/stats` 返回统计数据
+
+---
+
+## Task 5：消息组件体系 + conversation 页改造 ✅
+
+**目标**：建立消息类型组件体系，改造聊天页面按消息类型渲染不同组件。
+
+### 新增/修改文件
+
+| 文件 | 操作 | 说明 |
+|------|------|------|
+| frontend/src/components/msg/MsgText.vue | 新增 | 文本消息组件（从 conversation 抽取） |
+| frontend/src/components/msg/MsgImage.vue | 新增 | 图片消息组件（网格+预览，初始骨架） |
+| frontend/src/components/msg/MsgVoice.vue | 新增 | 语音消息组件（波形+播放，初始骨架） |
+| frontend/src/components/msg/MsgFile.vue | 新增 | 文件消息组件（卡片+下载，初始骨架） |
+| frontend/src/pages/chat/conversation.vue | 修改 | 引入组件体系，按 type 分支渲染 |
+| frontend/src/pages/group/conversation.vue | 修改 | 同上 |
+
+### 详细步骤
+
+1. 从现有 conversation.vue 中提取文本消息渲染逻辑到 `MsgText.vue`
+2. 创建 `MsgImage.vue`/`MsgVoice.vue`/`MsgFile.vue` 骨架组件（接收 msg prop，显示占位）
+3. conversation.vue 消息列表区域改为根据 `msg.type` 使用 `
+
+
+
+ 消息统计
+
+
+ 近 7 天
+ 近 30 天
+
+
+
+
+
+
+
+
+
+
+ 消息总数
+ {{ formatNumber(stats.total_count) }}
+
+
+
+
+
+ 今日消息
+ {{ formatNumber(stats.today_count) }}
+
+
+
+
+
+ 消息趋势
+
+
+
+
+
+
+
+ 类型分布
+
+
+
+
+
+
+
+ 活跃用户 Top 10
+
+
+
+
+
+
+
+ 活跃群组 Top 10
+
+
+
+
+