EchoChat/docs/plans/2026-03-04-phase2c-implementation.plan.md

# Phase 2c 实施计划：群聊与已读回执

> **状态：** 📋 待执行
> **设计文档：** `docs/plans/2026-03-04-phase2c-design.md`
> **分支：** `feature/phase2c-group-read-receipt`
> **预计 Task 数：** 14 个
> **最后更新：** 2026-03-04

---

## Task 总览

| Task | 阶段 | 描述 | 依赖 | 状态 |
|------|------|------|------|------|
| Task 0 | 基础设施 | MinIO Docker + SDK + 通用上传 API | 无 | 📋 |
| Task 1 | 基础设施 | 数据库迁移 + Model + 常量定义 | 无 | 📋 |
| Task 2 | 群聊后端 | Group DAO 层 | Task 1 | 📋 |
| Task 3 | 群聊后端 | Group Service 业务逻辑 | Task 2 | 📋 |
| Task 4 | 群聊后端 | Group Controller + Router + Wire | Task 3 | 📋 |
| Task 5 | 群聊后端 | WS 群管理事件处理器 | Task 3 | 📋 |
| Task 6 | 群聊后端 | IM Service 扩展（群消息 + @提醒 + 管理员撤回） | Task 2 | 📋 |
| Task 7 | 已读回执 | 已读回执后端（ReadDAO + Service + API + WS 推送） | Task 1 | 📋 |
| Task 8 | 已读回执 | 前端已读回执 UI（单聊标记 + 群聊计数 + 详情页） | Task 7 | 📋 |
| Task 9 | 前端 | 群聊 Store + API 封装 + WS 事件监听 | Task 4, 5 | 📋 |
| Task 10 | 前端 | 群聊核心页面（Tab 改造 + 群对话页 + 创建群页） | Task 9 | 📋 |
| Task 11 | 前端 | 群聊管理页面（群设置 + 成员 + 邀请 + @选择器） | Task 10 | 📋 |
| Task 12 | 前端 | 群聊辅助功能（审批 + 搜索 + 免打扰 + 公告 UI） | Task 11 | 📋 |
| Task 13 | 管理端 | 管理端群聊管理 + 全量文档更新 + 代码审查 | Task 12 | 📋 |

---

## Task 0: MinIO Docker + SDK + 通用上传 API

**目标：** 引入 MinIO 文件存储服务，封装通用上传能力

### 交付物

1. **Docker Compose**
   - `deploy/docker/docker-compose.dev.yml` 添加 minio 服务
   - volumes 持久化 `minio_data`
   - 端口：9000（API）+ 9001（Console）

2. **Go 后端配置**
   - `config/config.yaml` 添加 minio 配置节
   - `config/config.go` 添加 MinioConfig 结构体
   - `pkg/storage/minio.go` — MinIO 客户端初始化（NewMinioClient）

3. **文件模块**
   - `app/file/service/file_service.go` — Upload(ctx, file) → URL
   - `app/file/controller/file_controller.go` — POST /api/v1/upload
   - `app/file/router.go` — 路由注册
   - `app/file/provider.go` — Wire ProviderSet

4. **集成**
   - `app/provider/wire.go` 添加 FileSet
   - `router/router.go` 注册 file 路由

### 验收标准

- `docker compose up -d minio` 正常启动
- `curl -F "file=@test.png" http://localhost:8085/api/v1/upload` 返回 MinIO URL
- MinIO Console (localhost:9001) 可看到上传的文件

---

## Task 1: 数据库迁移 + Model + 常量定义

**目标：** 建立 Phase 2c 所需的数据库表和 Go 模型

### 交付物

1. **新增表 SQL（init.sql 追加）**
   - `im_groups` 表（含所有注释和索引）
   - `im_group_join_requests` 表
   - `im_message_reads` 表

2. **ALTER 现有表**
   - `im_conversation_members` 新增 6 字段：role, nickname, is_muted, is_do_not_disturb, joined_at, at_me_count
   - `im_messages` 新增 1 字段：at_user_ids (BIGINT[])

3. **Go Model 文件**
   - `app/group/model/group.go` — Group 结构体
   - `app/group/model/join_request.go` — JoinRequest 结构体
   - `app/im/model/message_read.go` — MessageRead 结构体
   - `app/im/model/conversation_member.go` — 扩展 ConversationMember 结构体
   - `app/im/model/message.go` — 扩展 Message 结构体（at_user_ids）

4. **常量文件**
   - `app/constants/group.go` — 群角色、群状态、申请状态、系统消息类型

5. **DTO 文件**
   - `app/dto/group_dto.go` — 群聊相关 DTO
   - `app/dto/im_dto.go` — 扩展：已读回执 DTO + ConversationDTO 群聊字段

6. **GORM AutoMigrate**
   - `app/provider/wire_gen.go` 中确保新 Model 注册

### 验收标准

- 数据库迁移成功，`\d+ im_groups` 等表存在
- `go build` 编译通过
- 常量和 DTO 定义完整

---

## Task 2: Group DAO 层

**目标：** 实现群聊数据访问层

### 交付物

`app/group/dao/group_dao.go`

| 方法 | 功能 |
|------|------|
| CreateGroup | 创建 im_groups 记录 |
| GetByID | 根据 ID 查群信息 |
| GetByConversationID | 根据会话 ID 查群信息 |
| UpdateInfo | 更新群名/头像/公告/可搜索性/全体禁言 |
| UpdateOwner | 转让群主 |
| Dissolve | 解散群（status → 2） |
| GetMembers | 获取群成员列表（含用户信息 JOIN auth_users） |
| GetMemberRole | 查询用户在群内的角色 |
| IsMember | 检查用户是否为群成员 |
| AddMembers | 批量添加成员（im_conversation_members） |
| RemoveMember | 移除成员（DELETE im_conversation_members） |
| UpdateMemberRole | 更新成员角色 |
| UpdateMemberMute | 更新成员禁言状态 |
| UpdateMemberNickname | 更新群内昵称 |
| GetMemberCount | 获取群成员数 |
| SearchGroups | 搜索公开群（is_searchable=true，GIN 全文索引） |
| GetUserGroups | 获取用户加入的所有群 |
| CreateJoinRequest | 创建入群申请 |
| GetPendingJoinRequests | 获取待审批申请列表 |
| UpdateJoinRequest | 更新申请状态 |
| HasPendingRequest | 检查是否有待处理的申请 |

### 验收标准

- 所有方法有完整的日志记录（LogFunctionEntry/Exit）
- `go build` 编译通过

---

## Task 3: Group Service 业务逻辑

**目标：** 实现群聊核心业务逻辑

### 交付物

`app/group/service/group_service.go`

| 方法 | 功能 | 关键逻辑 |
|------|------|----------|
| CreateGroup | 创建群聊 | 创建 conversation(type=2) + groups + members，插入系统消息，推送通知 |
| GetGroupInfo | 获取群详情 | 包含成员数 |
| UpdateGroupInfo | 更新群信息 | 权限校验（群主/管理员），推送 group.info.update |
| UpdateNotice | 更新群公告 | 权限校验，插入系统消息，推送 group.notice.update |
| DissolveGroup | 解散群聊 | 仅群主，推送 group.dissolved |
| InviteMembers | 邀请入群 | 权限校验，检查上限，批量添加，系统消息，推送 group.member.join |
| KickMember | 踢人 | 层级权限（群主>管理员>成员），系统消息，推送 group.member.kicked |
| LeaveGroup | 退出群 | 群主不能退出（需先转让），系统消息，推送 group.member.leave |
| TransferOwner | 转让群主 | 仅群主，修改双方角色 |
| SetAdmin | 设置/取消管理员 | 仅群主 |
| MuteMember | 禁言/解除 | 群主/管理员（不能禁言同级或上级） |
| SetAllMuted | 全体禁言 | 群主/管理员 |
| UpdateNickname | 修改群昵称 | 群成员自行修改 |
| SearchGroups | 搜索公开群 | 分页 |
| ApplyJoin | 申请入群 | 创建申请，推送 group.join.request 给群主/管理员 |
| GetJoinRequests | 获取申请列表 | 权限校验 |
| ReviewJoinRequest | 审批申请 | 通过→添加成员+系统消息+推送，拒绝→更新状态 |

**接口依赖：**
- `UserInfoGetter` — 获取用户信息（批量）
- `PubSub` — 推送通知

### 验收标准

- 所有权限校验逻辑完整（群主 > 管理员 > 成员）
- 系统消息正确写入 im_messages (type=10)
- PubSub 推送事件正确

---

## Task 4: Group Controller + Router + Wire

**目标：** 暴露群聊 REST API 并集成到依赖注入

### 交付物

1. **Controller**
   - `app/group/controller/group_controller.go` — 16 个 REST API 处理函数
   - 统一使用 `utils.Response*` 系列响应
   - `handleError` 覆盖所有已知业务错误

2. **Router**
   - `app/group/router.go` — 路由注册
   - 路径前缀 `/api/v1/groups`
   - JWT 中间件保护

3. **Wire 集成**
   - `app/group/provider.go` — GroupSet
   - `app/provider/wire.go` — 添加 GroupSet + 新接口绑定
   - `app/provider/wire_gen.go` — 重新生成
   - `router/router.go` — 注册 group 路由

### 验收标准

- `go build` 编译通过
- 所有 16 个 API 端点可访问（需 JWT Token）
- API 响应格式统一

---

## Task 5: WS 群管理事件处理器

**目标：** 实现群管理相关的 WebSocket 事件推送

### 交付物

`app/group/handler/group_handler.go`

| WS 事件 | 触发时机 | 推送目标 |
|---------|----------|----------|
| group.member.join | 成员加入 | 群所有成员 |
| group.member.leave | 成员退出 | 群所有成员 |
| group.member.kicked | 成员被踢 | 群所有成员 + 被踢者 |
| group.info.update | 群信息变更 | 群所有成员 |
| group.notice.update | 群公告变更 | 群所有成员 |
| group.dissolved | 群解散 | 群所有成员 |
| group.mute.update | 禁言变更 | 群所有成员 |
| group.join.request | 新入群申请 | 群主 + 管理员 |
| group.join.approved | 申请通过 | 申请人 |

**注册方式：** 通过 Hub.RegisterEvent 注册到事件路由表（如有 C→S 事件），S→C 推送通过 PubSub.PublishToUser/PublishToUsers。

### 验收标准

- 群管理操作后相关成员能收到实时通知
- 系统消息在群聊中正确显示

---

## Task 6: IM Service 扩展（群消息 + @提醒 + 管理员撤回）

**目标：** 扩展现有 IMService 以支持群聊消息场景

### 交付物

1. **IMService 方法扩展**

| 方法 | 变更内容 |
|------|----------|
| SendMessage | 增加群聊分支：成员校验、禁言检查、批量未读递增、免打扰跳过 Redis |
| RecallMessage | 增加群聊分支：管理员可撤回他人消息无时限，撤回展示区分操作者 |
| GetConversationList | 增加群聊会话：填充群名/群头像/成员数/免打扰/被@计数 |
| GetHistoryMessages | 群聊适配：返回发送者群昵称（优先于全局昵称） |

2. **新增接口定义**（`app/im/service/im_service.go`）

```go
type GroupMemberChecker interface {
    IsMember(ctx context.Context, conversationID, userID int64) (bool, error)
    GetMemberRole(ctx context.Context, conversationID, userID int64) (int, error)
    IsMuted(ctx context.Context, conversationID, userID int64) (bool, error)
    IsAllMuted(ctx context.Context, conversationID int64) (bool, error)
}

type GroupInfoGetter interface {
    GetByConversationID(ctx context.Context, conversationID int64) (*GroupBasicInfo, error)
    GetMemberCount(ctx context.Context, groupID int64) (int, error)
}
```

3. **SendMessage 扩展**
   - `app/dto/im_dto.go` — SendMessageRequest 新增 at_user_ids 字段
   - `app/im/handler/event_handler.go` — 适配群消息推送（推给所有群成员）
   - im.message.new 推送增加 conv_type、at_user_ids 字段

4. **免打扰逻辑**
   - 免打扰成员：递增会话 unread_count，不递增 Redis 全局未读
   - 会话列表中免打扰会话显示灰色未读数

### 验收标准

- 群消息发送/撤回功能正常
- 禁言用户发消息被拒
- @提醒字段正确存储和推送
- 免打扰用户不增加全局未读数

---

## Task 7: 已读回执后端

**目标：** 实现已读回执完整后端逻辑

### 交付物

1. **ReadDAO**
   - `app/im/dao/read_dao.go`
   - BatchCreate(ctx, messageIDs[], userID) — 批量写入已读记录
   - GetMessageReadUsers(ctx, messageID, page, limit) — 查询已读用户列表
   - GetMessageReadCount(ctx, messageID) — 查询已读计数
   - GetBatchReadCounts(ctx, messageIDs[]) — 批量查询已读计数

2. **IMService 扩展**
   - MarkRead — 重构：单聊走 last_read_msg_id，群聊写 im_message_reads
   - GetMessageReadDetail — 已读详情列表（含用户信息）
   - GetMessageReadCount — 已读/未读计数

3. **REST API**
   - GET /api/v1/im/messages/:id/reads — 已读详情
   - GET /api/v1/im/messages/:id/read-count — 已读计数
   - Controller + Router 更新

4. **WS 事件**
   - im.message.read — 重构：单聊推 read.ack，群聊推 read.count
   - im.message.read.ack — 单聊实时推送
   - im.message.read.count — 群聊计数推送

### 验收标准

- 单聊：打开会话后对方看到 "已读"
- 群聊：打开会话后发送者看到 "X人已读"
- 点击 "X人已读" 可查看已读/未读人员列表

---

## Task 8: 前端已读回执 UI

**目标：** 前端实现已读回执展示（使用 ui-ux-pro-max 设计）

### 交付物

1. **chat Store 扩展**（`store/chat.js`）
   - 新增 readStatus 状态管理
   - WS 监听 im.message.read.ack / im.message.read.count
   - 打开会话时发送 im.message.read

2. **单聊已读标记**（修改 `pages/chat/conversation.vue`）
   - 自己发的消息下方显示 "已读" / "未读"
   - 基于 last_read_msg_id 判断

3. **群聊已读计数**（后续 Task 10 的 group/conversation.vue 中实现基础展示）
   - 消息下方显示 "X人已读"
   - 点击跳转已读详情页

4. **已读详情页**（新增 `pages/chat/read-detail.vue`）
   - Tab 切换：已读 / 未读
   - 用户列表（头像 + 昵称 + 已读时间）
   - 调用 GET /api/v1/im/messages/:id/reads

### 验收标准

- 单聊对话页正确显示 "已读"/"未读"
- 已读详情页正确展示已读/未读人员
- 使用 ui-ux-pro-max 设计规范

---

## Task 9: 前端群聊 Store + API 封装

**目标：** 建立前端群聊数据管理层

### 交付物

1. **API 封装**
   - `api/group.js` — 16 个群聊 REST API 封装
   - `api/file.js` — 文件上传 API 封装

2. **群聊 Store**（`store/group.js`）
   - state: groupConversations, currentGroup, groupMessages, groupMembers
   - actions: loadGroupConversations, sendGroupMessage, loadGroupHistory, ...
   - WS 监听: im.message.new(conv_type=2), group.* 系列事件
   - 群消息缓存策略（同 chat.js 模式）

3. **WS 事件注册**
   - App.vue `_initGlobalWS` 中初始化 groupStore.initWsListeners()
   - 处理 group.member.join/leave/kicked/info.update/notice.update/dissolved 等

### 验收标准

- API 封装完整，方法命名清晰
- Store 能正确管理群聊状态
- WS 群管理事件正确触发 Store 更新

---

## Task 10: 群聊核心页面（ui-ux-pro-max）

**目标：** 实现群聊核心交互页面

### 交付物

1. **会话列表 Tab 改造**（修改 `pages/chat/index.vue`）
   - 顶部增加 Tab 切换：单聊 / 群聊
   - 群聊 Tab 展示群会话列表（群名、群头像、最后消息、未读数）
   - 免打扰群未读数显示为灰色
   - 被@标记："[N条] @了我"

2. **群聊对话页**（新增 `pages/group/conversation.vue`）
   - 消息列表（显示发送者昵称 + 头像）
   - @成员选择器（输入 @ 弹出成员列表）
   - 消息发送（含 at_user_ids）
   - 消息撤回（管理员额外权限）
   - 系统消息特殊展示（居中灰色文字）
   - "X人已读" 显示 + 点击跳转详情

3. **创建群聊页**（新增 `pages/group/create.vue`）
   - 好友列表多选
   - 搜索用户 ID 添加
   - 填写群名称
   - 确认创建

4. **CustomTabBar 适配**
   - TabBar 新增或适配群聊入口（如果需要）

### 验收标准

- Tab 切换流畅，单聊/群聊列表独立
- 群聊对话页消息展示正确
- @选择器交互流畅（输入 @ 弹出选择列表）
- 创建群聊后自动跳转到群聊对话页

---

## Task 11: 群聊管理页面（ui-ux-pro-max）

**目标：** 实现群聊管理相关页面

### 交付物

1. **群设置页**（新增 `pages/group/settings.vue`）
   - 群信息展示（名称/头像/公告/群 ID）
   - 群信息编辑（群主/管理员可修改名称/头像/公告）
   - 成员概览（前 N 个头像 + "查看全部"）
   - 免打扰开关
   - 群昵称设置
   - 退出群聊 / 解散群聊

2. **群成员列表页**（新增 `pages/group/members.vue`）
   - 完整成员列表
   - 角色标识（群主皇冠/管理员盾牌/成员无标识）
   - 管理操作入口（踢人/禁言/设管理员）— 根据当前用户角色显示
   - 搜索成员

3. **邀请入群页**（新增 `pages/group/invite.vue`）
   - 好友列表选择（排除已在群内的）
   - 搜索用户 ID 添加

### 验收标准

- 群设置页信息展示完整
- 角色权限控制正确（群主能看到所有管理入口，普通成员看不到）
- 邀请页排除已有成员

---

## Task 12: 群聊辅助功能（ui-ux-pro-max）

**目标：** 实现群聊辅助功能页面

### 交付物

1. **入群申请审批页**（新增 `pages/group/join-requests.vue`）
   - 待审批申请列表（申请人信息 + 附言 + 时间）
   - 通过/拒绝操作
   - 已处理记录

2. **搜索群聊页**（新增 `pages/group/search.vue`）
   - 关键词搜索公开群
   - 搜索结果：群名、头像、成员数、简介
   - 申请加入（填写申请附言）
   - 已加入的群直接进入

3. **免打扰 UI**
   - 群设置页免打扰开关
   - 会话列表免打扰标识（灰色未读数）

4. **群公告 UI**
   - 群设置页公告展示 + 编辑
   - 群公告系统消息展示

5. **全局消息搜索扩展**（修改 `pages/chat/search.vue`）
   - 搜索结果包含群聊消息
   - 结果标识会话类型（单聊/群聊图标）

### 验收标准

- 入群审批流程完整（申请→通知→审批→入群）
- 群搜索结果准确
- 免打扰功能正常
- 全局搜索包含群聊消息

---

## Task 13: 管理端 + 文档更新 + 代码审查

**目标：** 管理端群聊管理 + 全量文档同步 + 代码审查

### 交付物

1. **管理端后端**
   - `app/admin/service/group_manage_service.go` — 群列表/详情/解散/移除
   - `app/admin/controller/group_manage_controller.go` — 4 个 REST API
   - `app/admin/router.go` — 路由扩展

2. **管理端前端**
   - `admin/src/views/group/list.vue` — 群列表页（搜索/分页/状态筛选）
   - `admin/src/views/group/detail.vue` — 群详情页（成员管理/解散）
   - `admin/src/api/group.js` — API 封装
   - 侧边栏菜单添加群聊管理入口

3. **文档更新**
   - `docs/progress/CURRENT_STATUS.md` — 进度更新
   - `.cursor/rules/project-context.mdc` — 记忆更新
   - `docs/architecture/system-architecture.md` — 架构更新
   - `docs/plans/2026-02-27-echochat-system-design.md` — 总体设计更新
   - `docs/api/frontend/im.md` — IM API 文档更新
   - `docs/api/frontend/group.md` — 新增群聊 API 文档
   - `docs/api/websocket.md` — WS 事件文档更新
   - `docs/api/admin/group.md` — 新增管理端群聊 API 文档
   - `docs/api/README.md` — 导航更新

4. **代码审查**
   - 使用 code-reviewer 子代理进行结构化审查
   - 修复审查发现的问题

### 验收标准

- 管理端群列表/详情页功能正常
- 管理员可解散群/移除成员
- 所有文档与代码保持一致
- 代码审查通过

---

## 实施依赖关系图

```
Task 0 (MinIO)  ──────────────────────────────────────────────┐
Task 1 (DB迁移) ──┬── Task 2 (Group DAO) ──┬── Task 3 (Group Service) ──┬── Task 4 (Controller+Wire)
                  │                        │                           └── Task 5 (WS Handler)
                  │                        └── Task 6 (IM扩展)
                  └── Task 7 (已读回执后端) ── Task 8 (已读回执前端)
                                                                            │
Task 4 + Task 5 ── Task 9 (Store+API) ── Task 10 (核心页面) ── Task 11 (管理页面) ── Task 12 (辅助功能)
                                                                                                    │
Task 0 + Task 12 ── Task 13 (管理端+文档+审查)
```

---

## 开发注意事项

1. **代码风格一致性**：严格遵循 Phase 2b 的代码风格（日志记录、错误处理、常量命名、DTO 设计）
2. **接口注入模式**：新模块间通信必须走 interface injection，禁止直接 import
3. **批量查询优化**：群成员信息获取使用批量查询 + Map 映射，避免 N+1
4. **前端设计规范**：所有前端页面使用 ui-ux-pro-max 技能包设计
5. **系统消息**：群管理操作产生的系统消息统一使用 type=10（MessageTypeSystem），内容格式化
6. **权限层级**：群主(2) > 管理员(1) > 成员(0)，操作时必须校验层级
7. **Wire 依赖**：Phase 2b 中 Wire 有过手动 patch 历史，注意检查 wire_gen.go 一致性