diff --git a/docs/API.md b/docs/API.md index b8fa0e3..f499b30 100644 --- a/docs/API.md +++ b/docs/API.md @@ -426,6 +426,15 @@ curl -X POST {host}/api/v1/mail/read -H "Authorization: Bearer $AGENT_KEY" - 重复标记已读的邮件返回 `marked: 0`，不是错误（Agent 常把上一轮的 id 原样传回） - 「全部标掉」排除已归档会话：那些邮件在收件箱里看不到， 标了只会让计数与用户看到的对不上 +- ★ **已读是按调用者记录的**（表 `mail_reads`）：一封同时发给多个收件人（含抄送） + 的邮件，A 读掉之后**对 B 仍然是未读** —— `?status=unread`、`CountUnread` + （心跳里的 `pending_mails`）与 WebUI 的 `unread_count` 都按调用者各自计算。 + 这条语义是 2026-09-13 从一次实测缺陷里改出来的：原先 `mails.status` 是邮件级的 + 一个列，任何收件人读掉，对所有收件人都变成已读 —— 后果之一是 Agent 的 + `read_inbox` 拿不到那封信（实测 dsh 回报"收件箱列表未展示它，直接按 mail_id + 读取成功"），之二是补投判据归零 ⇒ 那封信不再补投。 +- 兼容说明：`mails.status` 仍然会被刷新（`read`/`archived`），但它现在只表示 + "有人读过 / 已归档"，**不再是未读判据**。 ### 每个 Agent 可用的模型范围 diff --git a/docs/PLUGIN-CONTRACT.md b/docs/PLUGIN-CONTRACT.md index a4487c5..22c67f8 100644 --- a/docs/PLUGIN-CONTRACT.md +++ b/docs/PLUGIN-CONTRACT.md @@ -642,6 +642,7 @@ SSE 只推连上之后的事件。插件重启前发来的邮件不会再推一 |---|---|---| | T-1.1 | 附件清单必须带 **`attachment_id`** | 只说「有附件」模型无从下载 | | T-1.2 | 抄送人必须显示 | 模型以为是私信，回信时漏掉其他参与方 | +| T-1.4 | 已读**按读取者**记（一封多发邮件被 A 读掉后，对 B 仍未读） | 服务端的 `?status=unread` 与 `pending_mails` 都是按调用者算的；插件不该自己缓存"这封读过了" | | T-1.3 | 只标**本次列出**的那些，且 `status=all` 时**不标** | `limit` 之外的还没看过；把历史邮件标成已读会让下一轮的新邮件混在里面认不出来 | 默认参数：`status='unread'`、`limit=5`。 diff --git a/server/internal/db/migrate.go b/server/internal/db/migrate.go index 612e3d6..84fa297 100644 --- a/server/internal/db/migrate.go +++ b/server/internal/db/migrate.go @@ -2,7 +2,9 @@ package db import ( "context" + "database/sql" _ "embed" + "errors" "fmt" "strings" ) @@ -37,10 +39,59 @@ func Migrate(ctx context.Context) error { return fmt.Errorf("migrate: 未初始化的方言") } + if err := backfillMailReads(ctx); err != nil { + return err + } + fmt.Printf("数据库迁移完成（%s）\n", D) return nil } +/* +backfillMailReads 把已读模型从"邮件级"迁到"读者级"时补一次历史数据。 + +背景：`mails.status='read'` 原先表示"有人读过"，但**没记是谁读的**。新的 +mail_reads 表按读者记录，因此老数据只能推断 —— 取主收件人（to_name）作为默认读者： +绝大多数已读发生在主收件人身上，而抄送方"被代读"的情况本来就是要修掉的错。 + +**只能跑一次**：每次启动都跑的话，它会把"某个抄送方读过"的邮件按主收件人写成已读 —— +正是这次要修的语义错误。所以用 app_meta 里的标记守住（见 init_sqlite.sql 的注释）。 +*/ +func backfillMailReads(ctx context.Context) error { + const marker = "read_model_per_recipient_v1" + var v string + err := DB.QueryRowContext(ctx, `SELECT value FROM app_meta WHERE key = $1`, marker).Scan(&v) + if err == nil { + return nil // 已迁过 + } + if !errors.Is(err, sql.ErrNoRows) { + return fmt.Errorf("backfill mail_reads: 读标记失败: %w", err) + } + + // INSERT ... SELECT ... WHERE NOT EXISTS 两种方言都认；WHERE 只是防御 + // （标记保证只跑一次，但万一上次中断在半路，这条能安全续上）。 + res, err := DB.ExecContext(ctx, ` + INSERT INTO mail_reads (mail_id, reader_name) + SELECT m.mail_id, m.to_name + FROM mails m + WHERE m.status = 'read' + AND NOT EXISTS ( + SELECT 1 FROM mail_reads r WHERE r.mail_id = m.mail_id AND r.reader_name = m.to_name + )`) + if err != nil { + return fmt.Errorf("backfill mail_reads: %w", err) + } + n, _ := res.RowsAffected() + + if _, err := DB.ExecContext(ctx, `INSERT INTO app_meta (key, value) VALUES ($1, $2)`, marker, fmt.Sprintf("done rows=%d", n)); err != nil { + return fmt.Errorf("backfill mail_reads: 写标记失败: %w", err) + } + if n > 0 { + fmt.Printf("已读模型迁移：把 %d 封历史已读邮件记到主收件人名下（一次性）\n", n) + } + return nil +} + // splitStatements 按分号切分 SQL 脚本并剔除注释行。 // 本项目的 SQLite schema 只有 CREATE 语句，不含字符串字面量里的分号， // 因此按分号朴素切分是安全的；若将来加入含分号的字面量需改用真正的词法切分。 diff --git a/server/internal/db/migrations/init.sql b/server/internal/db/migrations/init.sql index de92bb3..d98e5cc 100644 --- a/server/internal/db/migrations/init.sql +++ b/server/internal/db/migrations/init.sql @@ -438,3 +438,22 @@ ALTER TABLE sessions ADD COLUMN IF NOT EXISTS platform_id VARCHAR(256) NOT NULL CREATE INDEX IF NOT EXISTS idx_sessions_platform ON sessions(platform_id) WHERE platform_id <> ''; + +-- ─── 按人记录的已读状态（mail_reads）───────────────────────────────── +-- +-- 与 init_sqlite.sql 的同一段语义一致：未读是**每个读者各自的状态**， +-- 而不是邮件行上的一个全局列（详见那边的注释：dsh 那句"收件箱列表未展示它"）。 +CREATE TABLE IF NOT EXISTS mail_reads ( + mail_id TEXT NOT NULL REFERENCES mails(mail_id), + reader_name TEXT NOT NULL, + read_at TIMESTAMPTZ DEFAULT NOW(), + PRIMARY KEY (mail_id, reader_name) +); + +CREATE INDEX IF NOT EXISTS idx_mail_reads_reader ON mail_reads(reader_name); + +-- 一次性迁移标记（见 sqlite 侧注释） +CREATE TABLE IF NOT EXISTS app_meta ( + key TEXT PRIMARY KEY, + value TEXT NOT NULL DEFAULT '' +); diff --git a/server/internal/db/migrations/init_sqlite.sql b/server/internal/db/migrations/init_sqlite.sql index 8ab59c9..0eb7ab7 100644 --- a/server/internal/db/migrations/init_sqlite.sql +++ b/server/internal/db/migrations/init_sqlite.sql @@ -477,3 +477,35 @@ CREATE INDEX IF NOT EXISTS idx_calendar_att_event -- 存在 —— CREATE TABLE IF NOT EXISTS 不会给它补 platform_id 列，于是这里建 -- 索引会以 "no such column" 失败，整个迁移中断（实测过一次）。 -- 依赖补出来的列的索引一律放 migrate.go 的 sqliteAddIndexes。 + +-- ─── 按人记录的已读状态（mail_reads）───────────────────────────────── +-- +-- 为什么需要它（2026-09-13 实测缺陷）：已读原先只存在 mails.status 这一列上， +-- 而它是**邮件级**的 —— 任何收件人读掉，对所有收件人（含抄送）都变成已读。 +-- 后果三连： +-- ① Agent 的 read_inbox（默认 status=unread）拿不到信，只能靠提示词里的 +-- mail_id 兜（实测 dsh 明确回报"收件箱列表未展示它，直接按 mail_id 读取成功"）； +-- ② 人类还没读，未读却被抄送的 Agent 读掉了（徽标一起变）； +-- ③ 桥的补投判据 pending_mails = CountUnread(agent)：被别人读掉后计数为 0， +-- 于是 SSE 漏过或进程重启时那封信**不会被补投** —— "以为送到了，其实没人看过"。 +-- +-- 语义：某封邮件对某个读者（用户名或 Agent 名）是否未读 = 这张表里没有对应行。 +-- mails.status 保留为"有人读过/已归档"的冗余，不再作为未读判据。 +CREATE TABLE IF NOT EXISTS mail_reads ( + mail_id TEXT NOT NULL REFERENCES mails(mail_id), + reader_name TEXT NOT NULL, + read_at DATETIME DEFAULT (strftime('%Y-%m-%d %H:%M:%f','now')), + PRIMARY KEY (mail_id, reader_name) +); + +CREATE INDEX IF NOT EXISTS idx_mail_reads_reader ON mail_reads(reader_name); + +-- 键值元数据表：给**一次性**迁移/回填留标记。 +-- +-- 为什么不能只靠 INSERT ... IF NOT EXISTS 这类幂等语句：回填只能做一次。 +-- 若每次启动都跑，它会把"某个抄送方读过"的邮件按主收件人身份写成已读 —— 正是 +-- 这次要修的错。所以回填必须由标记守住。 +CREATE TABLE IF NOT EXISTS app_meta ( + key TEXT PRIMARY KEY, + value TEXT NOT NULL DEFAULT '' +); diff --git a/server/internal/handler/mail.go b/server/internal/handler/mail.go index bbc4c20..7181001 100644 --- a/server/internal/handler/mail.go +++ b/server/internal/handler/mail.go @@ -616,7 +616,9 @@ func MarkMailRead(w http.ResponseWriter, r *http.Request) { return } - if err := repo.MarkMailRead(r.Context(), mailID); err != nil { + // 已读是**按读者**记的（见 repo.markReadFor 的说明）：这里传当前登录用户， + // 而不是把邮件行上的全局 status 一改 —— 那会让抄送方读掉的信从别人未读里消失。 + if err := repo.MarkMailRead(r.Context(), mailID, user.Username); err != nil { Error(w, http.StatusInternalServerError, "Failed to mark read") return } diff --git a/server/internal/handler/permission.go b/server/internal/handler/permission.go index 75b84cb..7cc4306 100644 --- a/server/internal/handler/permission.go +++ b/server/internal/handler/permission.go @@ -349,7 +349,8 @@ func DecidePermission(w http.ResponseWriter, r *http.Request) { return } - if _, err := repo.DecidePermission(r.Context(), mailID, req.Decision); err != nil { + // 决策人 = 当前登录用户（已读只记到他名下，不影响这条线索上其他收件人） + if _, err := repo.DecidePermission(r.Context(), mailID, user.Username, req.Decision); err != nil { Error(w, http.StatusInternalServerError, "Failed to decide permission") return } @@ -459,4 +460,3 @@ func contains(list []string, v string) bool { } return false } - diff --git a/server/internal/repo/permission_deadline_test.go b/server/internal/repo/permission_deadline_test.go index 24c571a..c482364 100644 --- a/server/internal/repo/permission_deadline_test.go +++ b/server/internal/repo/permission_deadline_test.go @@ -52,7 +52,7 @@ func TestPermissionDeadlineVisibleOnEveryReadPath(t *testing.T) { "读取配置", []string{"同意", "拒绝"}, "cat cfg", "permission", false); err != nil { t.Fatal(err) } - if _, err := DecidePermission(ctx, settledID, "同意"); err != nil { + if _, err := DecidePermission(ctx, settledID, "alice", "同意"); err != nil { t.Fatal(err) } diff --git a/server/internal/repo/readstate_test.go b/server/internal/repo/readstate_test.go new file mode 100644 index 0000000..498a541 --- /dev/null +++ b/server/internal/repo/readstate_test.go @@ -0,0 +1,212 @@ +package repo + +import ( + "context" + "testing" + + "github.com/agentmail/gateway/internal/db" + "github.com/google/uuid" +) + +/* +已读语义：**按读者**记录，而不是邮件行上的一个全局列。 + +2026-09-13 线上实测：`jianf → dsh` 那封打了招呼、抄送 pi/opencode/zcode/homeagent 的 +邮件里，pi 最先回复 ⇒ 它读过了 ⇒ 这封对 dsh 也变成 `read` ⇒ dsh 的 +`read_inbox`（默认 unread）返回空，它只能按提示词里的 mail_id 直接读，并在回信里 +写下"收件箱列表未展示它，直接按 mail_id 读取成功"。 + +同一封邮件**对每个读者各自算未读**，是这一组判据要钉住的不变量。 +*/ + +// unreadList 返回 ListInbox 在 unread 过滤下给出的邮件 id。 +func unreadList(t *testing.T, reader string) []uuid.UUID { + t.Helper() + mails, err := ListInbox(context.Background(), reader, "unread", 50) + if err != nil { + t.Fatal(err) + } + out := []uuid.UUID{} + for _, m := range mails { + out = append(out, m.ID) + } + return out +} + +func hasID(list []uuid.UUID, id uuid.UUID) bool { + for _, x := range list { + if x == id { + return true + } + } + return false +} + +// statusSeenBy 返回 ListInbox 在 all 过滤下、某个读者看到的那封邮件的 status。 +func statusSeenBy(t *testing.T, reader string, id uuid.UUID) string { + t.Helper() + mails, err := ListInbox(context.Background(), reader, "all", 50) + if err != nil { + t.Fatal(err) + } + for _, m := range mails { + if m.ID == id { + return m.Status + } + } + t.Fatalf("读者 %s 的收件箱里没有 %s", reader, id) + return "" +} + +func TestReadStateIsPerRecipient(t *testing.T) { + setupTestDB(t) + ctx := context.Background() + + // 一封主收件人 alice、抄送 bob 的邮件 —— 正是线上那封信的形状 + id := seedMailTo(t, "alice", "bob") + + // 初始：两边都未读 + if n, _ := CountUnread(ctx, "alice"); n != 1 { + t.Fatalf("alice 初始未读 = %d，期望 1", n) + } + if n, _ := CountUnread(ctx, "bob"); n != 1 { + t.Fatalf("bob 初始未读 = %d，期望 1", n) + } + + // alice 读掉它 + if err := MarkMailRead(ctx, id, "alice"); err != nil { + t.Fatal(err) + } + + // ★ 核心判据：alice 的未读清了，bob 的**必须还在** + if n, _ := CountUnread(ctx, "alice"); n != 0 { + t.Fatalf("alice 读过后未读 = %d，期望 0", n) + } + if n, _ := CountUnread(ctx, "bob"); n != 1 { + t.Fatalf("★ bob 没读，未读却变成了 %d —— 这正是要修的缺陷（任一收件人读掉，所有人变已读）", n) + } + if !hasID(unreadList(t, "bob"), id) { + t.Fatal("★ bob 的 unread 收件箱里必须还能看到这封信") + } + if hasID(unreadList(t, "alice"), id) { + t.Fatal("alice 自己读过了，unread 收件箱不该再有它") + } + + // 同一封邮件，两个读者看到的状态不同 —— 这就是"按读者"的直接证据 + if got := statusSeenBy(t, "alice", id); got != "read" { + t.Fatalf("alice 看到的 status = %q，期望 read", got) + } + if got := statusSeenBy(t, "bob", id); got != "unread" { + t.Fatalf("★ bob 看到的 status = %q，期望 unread（同一封邮件，按读者算）", got) + } + + // 反向对照：bob 也读掉 → 两边都清 + if err := MarkMailRead(ctx, id, "bob"); err != nil { + t.Fatal(err) + } + if n, _ := CountUnread(ctx, "bob"); n != 0 { + t.Fatalf("bob 读过后未读 = %d，期望 0", n) + } +} + +// CountUnreadInSession 是会话列表徽标用的，同样必须按读者算。 +func TestCountUnreadInSessionIsPerRecipient(t *testing.T) { + setupTestDB(t) + ctx := context.Background() + + id := seedMailTo(t, "alice", "bob") + var sid uuid.UUID + if err := db.DB.QueryRowContext(ctx, `SELECT session_id FROM mails WHERE mail_id = $1`, id).Scan(&sid); err != nil { + t.Fatal(err) + } + + if err := MarkMailRead(ctx, id, "alice"); err != nil { + t.Fatal(err) + } + if n, _ := CountUnreadInSession(ctx, "alice", sid); n != 0 { + t.Fatalf("alice 会话内未读 = %d，期望 0", n) + } + if n, _ := CountUnreadInSession(ctx, "bob", sid); n != 1 { + t.Fatalf("★ bob 会话内未读 = %d，期望 1（徽标不能因为别人读过就归零）", n) + } +} + +// 批量标已读（Agent 的 /mail/read）同样只影响调用者自己。 +func TestBulkMarkReadOnlyAffectsCaller(t *testing.T) { + setupTestDB(t) + ctx := context.Background() + + id := seedMailTo(t, "alice", "bob") + if _, err := MarkMailsReadFor(ctx, "alice", []uuid.UUID{id}); err != nil { + t.Fatal(err) + } + if n, _ := CountUnread(ctx, "bob"); n != 1 { + t.Fatalf("★ 批量标已读后 bob 未读 = %d，期望 1", n) + } + + // 全部标已读（不带 id）也只能标自己收件箱里的 + if _, err := MarkAllInboxReadFor(ctx, "alice"); err != nil { + t.Fatal(err) + } + if n, _ := CountUnread(ctx, "bob"); n != 1 { + t.Fatalf("★ 全标已读后 bob 未读 = %d，期望 1", n) + } +} + +// 归档是**会话级**的全局状态：归档后对所有人都不可见（unread 与 all 都不给）， +// 而且不能因为"没人读过"就把它算成未读。 +func TestArchivedStaysArchivedForEveryone(t *testing.T) { + setupTestDB(t) + ctx := context.Background() + + id := seedMailTo(t, "alice", "bob") + var sid uuid.UUID + if err := db.DB.QueryRowContext(ctx, `SELECT session_id FROM mails WHERE mail_id = $1`, id).Scan(&sid); err != nil { + t.Fatal(err) + } + if err := ArchiveSession(ctx, sid); err != nil { + t.Fatal(err) + } + + if n, _ := CountUnread(ctx, "bob"); n != 0 { + t.Fatalf("归档会话里的邮件不该计入未读，实际 %d", n) + } + if hasID(unreadList(t, "bob"), id) { + t.Fatal("归档邮件的 status 是 archived，不该出现在 unread 收件箱") + } + // ListInbox 会整体排除归档会话（`s.status <> 'archived'`），所以它在 + // `all` 里也不出现 —— 归档是"从收件箱拿走"，不是"标成已读"。 + mails, err := ListInbox(ctx, "bob", "all", 50) + if err != nil { + t.Fatal(err) + } + for _, m := range mails { + if m.ID == id { + t.Fatal("归档会话里的邮件不该出现在收件箱列表（all 也不该有）") + } + } +} + +// 权限决策把邮件记成**决策人**已读：同一条线索上其他收件人不受影响。 +func TestPermissionDecisionMarksOnlyDecider(t *testing.T) { + setupTestDB(t) + ctx := context.Background() + + // 一封 alice 收、bob 抄送的权限邮件 + id := seedMailTo(t, "alice", "bob") + if _, err := db.DB.ExecContext(ctx, + `INSERT INTO permission_requests (mail_id, session_id, agent_name, question, options, kind) + SELECT mail_id, session_id, 'bot', 'q', '["同意","拒绝"]', 'permission' FROM mails WHERE mail_id = $1`, + id); err != nil { + t.Fatal(err) + } + if _, err := DecidePermission(ctx, id, "alice", "同意"); err != nil { + t.Fatal(err) + } + if n, _ := CountUnread(ctx, "alice"); n != 0 { + t.Fatalf("决策人 alice 未读 = %d，期望 0", n) + } + if n, _ := CountUnread(ctx, "bob"); n != 1 { + t.Fatalf("★ bob 未读 = %d，期望 1（决策是 alice 做的，不该替他标记已读）", n) + } +} diff --git a/server/internal/repo/repo.go b/server/internal/repo/repo.go index e7b96cb..259fc05 100644 --- a/server/internal/repo/repo.go +++ b/server/internal/repo/repo.go @@ -444,7 +444,58 @@ func GetMailByID(ctx context.Context, id uuid.UUID) (*models.Mail, error) { return &m, nil } -func MarkMailRead(ctx context.Context, id uuid.UUID) error { +/* +─── 已读语义：按**读者**记录，而不是邮件行上的一个全局列 ─────────────── + +2026-09-13 实测缺陷：`mails.status` 是邮件级的，任何收件人读掉，对所有收件人 +（含抄送）都变成已读。后果：Agent 的 read_inbox（默认 unread）拿不到信（dsh 明确 +回报"收件箱列表未展示它，直接按 mail_id 读取成功"）；人类的未读被抄送的 Agent +读掉；桥的补投判据 CountUnread 归零 ⇒ 那封信不再补投（静默丢信）。 + +现在的判据：**对某个读者未读 = mail_reads 里没有 (mail_id, reader_name) 这一行。** +`mails.status` 保留为"有人读过 / 已归档"的冗余，不再作为未读判据。 + +下列两个片段把这件事收在一处，避免每条 SQL 各写一遍判据（写岔了就是又一次语义漂移）。 +*/ + +// unreadFor 返回"$n 这个读者看这封邮件是未读"的谓词；`m` 必须是 mails 的别名。 +func unreadFor(arg string) string { + return `(m.status <> 'archived' AND NOT EXISTS ( + SELECT 1 FROM mail_reads r WHERE r.mail_id = m.mail_id AND r.reader_name = ` + arg + `))` +} + +// readStateFor 返回给前端的 status 值（archived 是全局的，read/unread 按读者算）。 +func readStateFor(arg string) string { + return `CASE WHEN m.status = 'archived' THEN 'archived' + WHEN EXISTS (SELECT 1 FROM mail_reads r WHERE r.mail_id = m.mail_id AND r.reader_name = ` + arg + `) + THEN 'read' ELSE 'unread' END` +} + +// markReadFor 批量记下"某个读者读过哪些邮件"。 +// +// `where` 是**只用于 INSERT 的**筛选片段，里面可以（也应当）用 `m.` 前缀引用 mails —— +// 调用方各自负责随后刷新 mails.status 那列冗余（那个语句没有 `m` 别名）。 +// 之前我把同一个 where 复用到 UPDATE 上，直接 SQL 报 "no such column: m.mail_id" +// （测试当场抓到）。 +func markReadFor(ctx context.Context, reader string, where string, args ...any) error { + _, err := db.DB.ExecContext(ctx, + `INSERT INTO mail_reads (mail_id, reader_name) + SELECT m.mail_id, $1 FROM mails m + WHERE `+where+` + AND NOT EXISTS (SELECT 1 FROM mail_reads r WHERE r.mail_id = m.mail_id AND r.reader_name = $1)`, + append([]any{reader}, args...)...) + return err +} + +// MarkMailRead 记下**这个读者**读过这封邮件（人类端点）。 +func MarkMailRead(ctx context.Context, id uuid.UUID, reader string) error { + if _, err := db.DB.ExecContext(ctx, + `INSERT INTO mail_reads (mail_id, reader_name) + SELECT $1, $2 + WHERE NOT EXISTS (SELECT 1 FROM mail_reads WHERE mail_id = $1 AND reader_name = $2)`, + id, reader); err != nil { + return err + } _, err := db.DB.ExecContext(ctx, `UPDATE mails SET status = 'read' WHERE mail_id = $1`, id) return err } @@ -455,7 +506,7 @@ func ListInbox(ctx context.Context, agentName, status string, limit int) ([]mode m.cc_list, m.subject, m.body, m.mail_type, COALESCE(m.permission_result,'') AS permission_result, COALESCE(m.permission_kind,'') AS permission_kind, COALESCE(m.permission_multi_select,0) AS permission_multi_select, - m.status, m.created_at, s.session_alias, s.workspace, + ` + readStateFor("$1") + ` AS status, m.created_at, s.session_alias, s.workspace, EXISTS (SELECT 1 FROM users u WHERE u.username = m.from_name) AS from_human, EXISTS (SELECT 1 FROM users u WHERE u.username = m.to_name) AS to_human, COALESCE(NULLIF(s.permission_mode, ''), 'workspace') AS permission_mode, @@ -466,8 +517,16 @@ func ListInbox(ctx context.Context, agentName, status string, limit int) ([]mode AND s.status <> 'archived'` args := []any{agentName} if status != "" && status != "all" { - q += ` AND m.status = $2` - args = append(args, status) + // 未读/已读都按**这个读者**算（原先直接比 m.status，于是被抄送方读掉 + // 别人的未读也跟着变 —— 这就是要修的那条） + if status == "unread" { + q += ` AND ` + unreadFor("$1") + } else if status == "read" { + q += ` AND NOT ` + unreadFor("$1") + ` AND m.status <> 'archived'` + } else { + q += ` AND m.status = $2` + args = append(args, status) + } } q += ` ORDER BY m.created_at DESC, m.mail_id DESC` if limit > 0 { @@ -521,7 +580,7 @@ func CountUnread(ctx context.Context, agentName string) (int, error) { FROM mails m JOIN sessions s ON m.session_id = s.session_id WHERE (m.to_name = $1 OR `+db.CCHas("m.cc_list", 1)+`) - AND m.status = 'unread' + AND `+unreadFor("$1")+` AND s.status <> 'archived' `, agentName).Scan(&count) return count, err @@ -614,7 +673,9 @@ func AttachPermissionDeadlines(mails []models.Mail) { } } -func DecidePermission(ctx context.Context, mailID uuid.UUID, decision string) (*models.PermissionRequest, error) { +// decider 是**做出决策的人**（用户名）：权限邮件对他也应当变成已读 —— 但只对他一个人， +// 而不是像原先那样把邮件行的全局 status 一改（抄送的其他 Agent 会因此看不到它）。 +func DecidePermission(ctx context.Context, mailID uuid.UUID, decider, decision string) (*models.PermissionRequest, error) { var pr models.PermissionRequest var optsJSON []byte @@ -634,6 +695,14 @@ func DecidePermission(ctx context.Context, mailID uuid.UUID, decision string) (* _, _ = db.DB.ExecContext(context.Background(), `UPDATE mails SET permission_result = $1, status = 'read' WHERE mail_id = $2`, decision, mailID) + if decider != "" { + // 记到决策人名下（按读者记，见 repo.markReadFor） + _, _ = db.DB.ExecContext(context.Background(), + `INSERT INTO mail_reads (mail_id, reader_name) + SELECT $1, $2 + WHERE NOT EXISTS (SELECT 1 FROM mail_reads WHERE mail_id = $1 AND reader_name = $2)`, + mailID, decider) + } return &pr, nil } @@ -1037,7 +1106,9 @@ func ListContactsFor(ctx context.Context, forUser string, archived bool) ([]Cont COALESCE(s.session_alias, '') AS alias, s.status, (SELECT COUNT(*) FROM mails x WHERE x.session_id = s.session_id), - (SELECT COUNT(*) FROM mails x WHERE x.session_id = s.session_id AND x.status = 'unread'), + (SELECT COUNT(*) FROM mails x WHERE x.session_id = s.session_id + AND x.status <> 'archived' + AND NOT EXISTS (SELECT 1 FROM mail_reads r WHERE r.mail_id = x.mail_id AND r.reader_name = $1)), s.updated_at, s.subject, COALESCE(s.max_rounds, 0), @@ -1359,14 +1430,17 @@ func ListSessionsFor(ctx context.Context, forUser string, limit int) ([]models.S // CountUnreadInSession 统计某人在某会话内的未读数（含被抄送） func CountUnreadInSession(ctx context.Context, name string, sessionID uuid.UUID) (int, error) { - ccProbe, _ := json.Marshal([]map[string]string{{"name": name}}) var n int + // 抄送判定必须走 db.CCHas：这条路原先写的是 PG 专有的 `cc_list @> $3::jsonb`， + // 而**线上是 SQLite** —— 那条 SQL 直接语法错误（unrecognized token: "@"）， + // 调用点又是 `unread, _ :=`（吞错），于是会话列表的未读数一直显示 0。 + // 用的是与 CountUnread 同一个助手，两种方言都正确。 err := db.DB.QueryRowContext(ctx, ` - SELECT COUNT(*) FROM mails - WHERE session_id = $1 - AND status = 'unread' - AND (to_name = $2 OR cc_list @> $3::jsonb) - `, sessionID, name, string(ccProbe)).Scan(&n) + SELECT COUNT(*) FROM mails m + WHERE m.session_id = $1 + AND `+unreadFor("$2")+` + AND (m.to_name = $2 OR `+db.CCHas("m.cc_list", 2)+`) + `, sessionID, name).Scan(&n) return n, err } @@ -1460,6 +1534,14 @@ func MarkMailsReadFor(ctx context.Context, recipient string, ids []uuid.UUID) (i args = append(args, id) } + if err := markReadFor(ctx, recipient, + `m.mail_id IN (`+strings.Join(ph, ",")+`) AND (m.to_name = $1 OR `+db.CCHas("m.cc_list", 1)+`)`, + args...); err != nil { + return 0, err + } + // 冗余列：mails.status 只表示"有人读过 / 已归档"，**不再作为未读判据** + // （判据是 mail_reads，见 unreadFor）。保留它是为了兼容仍在读这一列的老路径， + // 以及让 SQL 层面"邮件是否被任何人读过"仍可一眼看出。 res, err := db.DB.ExecContext(ctx, ` UPDATE mails SET status = 'read' WHERE mail_id IN (`+strings.Join(ph, ",")+`) @@ -1478,6 +1560,13 @@ func MarkMailsReadFor(ctx context.Context, recipient string, ids []uuid.UUID) (i // 排除已归档会话：那些邮件在收件箱里根本看不到， // 标掉它们只会让「标记了 N 封」这个数字与用户看到的对不上。 func MarkAllInboxReadFor(ctx context.Context, recipient string) (int, error) { + if err := markReadFor(ctx, recipient, + `(m.to_name = $1 OR `+db.CCHas("m.cc_list", 1)+`) + AND m.session_id IN (SELECT session_id FROM sessions WHERE status <> 'archived')`, + recipient); err != nil { + return 0, err + } + // 同上：刷新冗余列，未读判据在 mail_reads res, err := db.DB.ExecContext(ctx, ` UPDATE mails SET status = 'read' WHERE status = 'unread'