每行带 blocks(已按 position 排好)与 tags */ public static function all( int $familyId, int $viewer, string $keyword = '', string $tag = '', int $limit = 0, int $offset = 0 ): array { $sql = 'SELECT n.*, p.name AS author_name, p.avatar, p.avatar_color, CASE WHEN n.person_id = ? THEN 1 ELSE 0 END AS is_mine FROM notes n JOIN persons p ON p.id = n.person_id WHERE n.family_id = ? AND (n.person_id = ? OR n.is_shared = 1)'; $bind = [$viewer, $familyId, $viewer]; $kw = trim($keyword); if ($kw !== '') { // 正文在块里 —— 用 EXISTS 子查询搜块,避免 JOIN 出重复行 $sql .= ' AND (n.title LIKE ? OR EXISTS (SELECT 1 FROM note_blocks b WHERE b.note_id = n.id AND b.content LIKE ?) OR EXISTS (SELECT 1 FROM note_tags t WHERE t.note_id = n.id AND t.tag LIKE ?))'; $like = '%' . $kw . '%'; array_push($bind, $like, $like, $like); } $tg = trim($tag); if ($tg !== '') { $sql .= ' AND EXISTS (SELECT 1 FROM note_tags t WHERE t.note_id = n.id AND t.tag = ?)'; $bind[] = $tg; } // ⚠️ 按「更新时间」倒序:笔记是"最近记的/最近改的"才要优先看(同 flomo 的时间流)。 $sql .= ' ORDER BY n.updated_at DESC, n.id DESC'; if ($limit > 0) { $sql .= ' LIMIT ' . (int)$limit . ' OFFSET ' . (int)$offset; } $st = Database::get()->prepare($sql); $st->execute($bind); $rows = $st->fetchAll(); if (!$rows) { return []; } return self::attachChildren($rows); } /** 与 all() 同一套可见性条件,只为列表页说清"一共几条" */ public static function countVisible(int $familyId, int $viewer, string $keyword = '', string $tag = ''): int { $sql = 'SELECT COUNT(*) FROM notes n WHERE n.family_id = ? AND (n.person_id = ? OR n.is_shared = 1)'; $bind = [$familyId, $viewer]; $kw = trim($keyword); if ($kw !== '') { $sql .= ' AND (n.title LIKE ? OR EXISTS (SELECT 1 FROM note_blocks b WHERE b.note_id = n.id AND b.content LIKE ?) OR EXISTS (SELECT 1 FROM note_tags t WHERE t.note_id = n.id AND t.tag LIKE ?))'; $like = '%' . $kw . '%'; array_push($bind, $like, $like, $like); } $tg = trim($tag); if ($tg !== '') { $sql .= ' AND EXISTS (SELECT 1 FROM note_tags t WHERE t.note_id = n.id AND t.tag = ?)'; $bind[] = $tg; } $st = Database::get()->prepare($sql); $st->execute($bind); return (int)$st->fetchColumn(); } /** * 一次把 blocks / tags 挂到结果集上。 * * ⚠️ 为什么不用 JOIN 一把梭:一条笔记有多块多标签,JOIN 出来是笛卡尔积, * 还要在 PHP 里去重。分两次 IN 查询(块、标签各一次)反而是**两条 SQL * 解决整页**,也不会有 N+1。 */ private static function attachChildren(array $rows): array { $ids = array_map(static fn($r): int => (int)$r['id'], $rows); $in = implode(',', array_map('intval', $ids)); $blocks = []; $st = Database::get()->query( "SELECT * FROM note_blocks WHERE note_id IN ($in) ORDER BY note_id, position, id" ); foreach ($st->fetchAll() as $b) { $blocks[(int)$b['note_id']][] = $b; } $tags = []; $st = Database::get()->query( "SELECT note_id, tag FROM note_tags WHERE note_id IN ($in) ORDER BY note_id, id" ); foreach ($st->fetchAll() as $t) { $tags[(int)$t['note_id']][] = (string)$t['tag']; } foreach ($rows as &$r) { $id = (int)$r['id']; $r['blocks'] = $blocks[$id] ?? []; $r['tags'] = $tags[$id] ?? []; } unset($r); return $rows; } /** 单条(带权限判定)。看不到返回 null。 */ public static function find(int $familyId, int $id, int $viewer): ?array { $st = Database::get()->prepare( 'SELECT n.*, p.name AS author_name, p.avatar, p.avatar_color FROM notes n JOIN persons p ON p.id = n.person_id WHERE n.id = ? AND n.family_id = ? AND (n.person_id = ? OR n.is_shared = 1)' ); $st->execute([$id, $familyId, $viewer]); $r = $st->fetch(); if (!$r) { return null; } $r['blocks'] = self::blocks($id); $r['tags'] = self::tags($id); $r['is_mine'] = (int)$r['person_id'] === $viewer ? 1 : 0; return $r; } /** 某条笔记的块(按位置) */ public static function blocks(int $noteId): array { $st = Database::get()->prepare( 'SELECT * FROM note_blocks WHERE note_id = ? ORDER BY position, id' ); $st->execute([$noteId]); return $st->fetchAll(); } /** 某条笔记的标签 */ public static function tags(int $noteId): array { $st = Database::get()->prepare('SELECT tag FROM note_tags WHERE note_id = ? ORDER BY id'); $st->execute([$noteId]); $out = []; foreach ($st->fetchAll() as $r) { $out[] = (string)$r['tag']; } return $out; } /** * 我用过的全部标签 + 各自多少条(给侧边标签云用)。 * * ⚠️ 统计范围 = **我能看到的**笔记(不带 tag 过滤),否则会出现 * "标签上写着 8 条,点进去只有 3 条"这种自相矛盾。 */ public static function tagCloud(int $familyId, int $viewer): array { $st = Database::get()->prepare( 'SELECT t.tag, COUNT(DISTINCT n.id) AS n FROM note_tags t JOIN notes n ON n.id = t.note_id WHERE n.family_id = ? AND (n.person_id = ? OR n.is_shared = 1) GROUP BY t.tag ORDER BY n DESC, t.tag ASC' ); $st->execute([$familyId, $viewer]); return $st->fetchAll(); } /** 写新笔记时给个标签联想:所有我用过的标签词(按人气) */ public static function tagSuggest(int $familyId, int $viewer, int $limit = 40): array { $rows = self::tagCloud($familyId, $viewer); $out = []; foreach ($rows as $r) { $out[] = (string)$r['tag']; if (count($out) >= $limit) { break; } } return $out; } // ===================================================================== // 写 // ===================================================================== /** * 新建一条笔记。 * * @param array $d title / blocks([{kind,content}]) / tags([string]) / is_shared * @return int 新笔记 id(0 = 标题与正文都空,没建) */ public static function create(int $familyId, int $personId, array $d): int { $title = trim((string)($d['title'] ?? '')); $blocks = self::cleanBlocks($d['blocks'] ?? []); // 标题和正文都空 = 用户什么都没写 → 不建空壳(否则列表里会冒出白卡片) if ($title === '' && !$blocks) { return 0; } $db = Database::get(); $db->prepare( 'INSERT INTO notes (family_id, person_id, title, is_shared, created_at, updated_at) VALUES (?,?,?,?,NOW(),NOW())' )->execute([ $familyId, $personId, mb_substr($title, 0, 200, 'UTF-8'), !empty($d['is_shared']) ? 1 : 0, ]); $id = (int)$db->lastInsertId(); self::writeBlocks($id, $blocks); self::replaceTags($id, $d['tags'] ?? []); // 把这次上传的"草稿附件"(target_id=0)认领到新笔记上 self::claimUploads($familyId, $id, $blocks); return $id; } /** * 改一条笔记。**仅作者本人可改**(共享出去只给别人看,不给别人改)。 * @return bool 是否改到了(改不到 = 不是我的/不存在) */ public static function update(int $familyId, int $id, int $personId, array $d): bool { $db = Database::get(); $st = $db->prepare('SELECT id FROM notes WHERE id = ? AND family_id = ? AND person_id = ?'); $st->execute([$id, $familyId, $personId]); if (!$st->fetchColumn()) { return false; } $title = trim((string)($d['title'] ?? '')); $blocks = self::cleanBlocks($d['blocks'] ?? []); // 改完标题正文全空 = 用户把内容清光了。**不删笔记**(用户可能只是暂时清空), // 但也不让它变成一条列表里点开什么都没有的白卡片 —— 给个占位标题。 if ($title === '' && !$blocks) { $title = '(空笔记)'; } $db->prepare( 'UPDATE notes SET title = ?, is_shared = ?, updated_at = NOW() WHERE id = ?' )->execute([mb_substr($title, 0, 200, 'UTF-8'), !empty($d['is_shared']) ? 1 : 0, $id]); // 块与标签都是"整组替换":与 trip_nodes 的错误清单不同,笔记的块没有历史价值, // 全量重写最简单可靠(不会出现"删掉的块下一轮又回来")。 self::writeBlocks($id, $blocks); self::replaceTags($id, $d['tags'] ?? []); self::claimUploads($familyId, $id, $blocks); return true; } /** * 把本次上传的图片块附件从"草稿态"认领到这条笔记上。 * * 上传发生在写笔记的过程中(点"加图片"就传了),那时笔记还不存在, * 所以附件先挂在 `target_type='note', target_id=0`。这里按图片块的 key * 把它们改挂到真实 note_id 上。 * * ⚠️ 用**本次提交里出现的 key** 来认领,而不是"把 target_id=0 的全部认领" —— * 后者会把别人(或本人在别处还没保存)的草稿一起抢过来。 * ⚠️ 认领完顺手清掉**本家庭**剩下的孤儿草稿(target_id=0 且超过 1 天): * 用户点了加图又放弃保存,就会留下一张谁也看不到的图。 * 按家庭 + 时间双重限定,不会误删"此刻正在编辑中"的那些。 */ private static function claimUploads(int $familyId, int $noteId, array $blocks): void { $keys = []; foreach ($blocks as $b) { if ($b['kind'] === 'image' && $b['content'] !== '') { $keys[] = $b['content']; } } $db = Database::get(); if ($keys) { $in = implode(',', array_fill(0, count($keys), '?')); $args = $keys; $args[] = $familyId; $db->prepare( "UPDATE attachments SET target_id = ? WHERE target_type = 'note' AND target_id = 0 AND `key` IN ($in) AND family_id = ?" )->execute(array_merge([$noteId], $args)); } // 清孤儿草稿(只在认领时顺手做,不必每次请求都扫) $db->prepare( "DELETE FROM attachments WHERE target_type = 'note' AND target_id = 0 AND family_id = ? AND created_at < DATE_SUB(NOW(), INTERVAL 1 DAY)" )->execute([$familyId]); } /** 删除(仅作者本人)。块/标签/附件靠外键 ON DELETE CASCADE 一起走。 */ public static function destroy(int $familyId, int $id, int $personId): void { Database::get()->prepare( 'DELETE FROM notes WHERE id = ? AND family_id = ? AND person_id = ?' )->execute([$id, $familyId, $personId]); } /** * 一条笔记的**文字摘要**(列表卡片上露个开头,不必渲染全部块)。 * 图片块显示成 `[图片]`,清单块显示成 `· 首项`。 */ public static function excerpt(array $note, int $len = 120): string { $buf = []; foreach ((array)($note['blocks'] ?? []) as $b) { $kind = (string)$b['kind']; $c = trim((string)$b['content']); if ($kind === 'image') { $buf[] = '[图片]'; } elseif ($kind === 'list') { foreach (preg_split('/\R/u', $c) ?: [] as $line) { $line = trim($line); if ($line !== '') { $buf[] = '· ' . $line; } } } elseif ($c !== '') { $buf[] = $c; } } $txt = preg_replace('/\s+/u', ' ', implode(' ', $buf)) ?? ''; $txt = trim($txt); if (mb_strlen($txt, 'UTF-8') > $len) { $txt = mb_substr($txt, 0, $len, 'UTF-8') . '…'; } return $txt; } // ===================================================================== // 内部:块 / 标签的清洗与写入 // ===================================================================== /** * 清洗前端提交的块: * · kind 归一(只认白名单里的三种,其它一律当 text) * · 内容裁剪(去首尾空白;图片块 content = 附件 key) * · 丢掉**空块**(用户加了块又没填,不该留一堆空段) * · 上限 MAX_BLOCKS * * @return array */ private static function cleanBlocks($raw): array { if (!is_array($raw)) { return []; } $out = []; foreach ($raw as $b) { if (!is_array($b)) { continue; } $kind = (string)($b['kind'] ?? 'text'); if (!in_array($kind, self::BLOCK_KINDS, true)) { $kind = 'text'; } $content = (string)($b['content'] ?? ''); // 图片块 content 是附件 key:不允许换行/首尾空白(它要当文件名查) $content = $kind === 'image' ? trim(preg_replace('/\s+/', '', $content) ?? '') : rtrim(ltrim($content, "\r\n\t "), "\r\n\t "); if ($content === '') { continue; // 空块丢掉 } if ($kind !== 'image') { $content = mb_substr($content, 0, self::MAX_TEXT, 'UTF-8'); } $out[] = ['kind' => $kind, 'content' => $content]; if (count($out) >= self::MAX_BLOCKS) { break; } } return $out; } private static function writeBlocks(int $noteId, array $blocks): void { $db = Database::get(); $db->prepare('DELETE FROM note_blocks WHERE note_id = ?')->execute([$noteId]); if (!$blocks) { return; } $st = $db->prepare( 'INSERT INTO note_blocks (note_id, kind, content, position) VALUES (?,?,?,?)' ); $pos = 0; foreach ($blocks as $b) { $st->execute([$noteId, $b['kind'], $b['content'], $pos]); $pos += 10; } } /** * 标签归一:`#读书` / `# 读书` / `读书 ` 都算「读书」;去重;单层。 * * ⚠️ 为什么**不建 tags 表**(只有一个 note_tags 存字符串): * 本模块的标签是"我随手打的词",不是需要改名/合并/配色的实体。 * 建一张标签表就得处理"改名后历史笔记怎么办""两个标签合并"—— * 那是重型知识库(思源那类)才值得的复杂度,与"轻量级"直接冲突。 * 用字符串存,标签云靠 GROUP BY 现算,几十上百条笔记毫无压力。 */ private static function replaceTags(int $noteId, $raw): void { $db = Database::get(); $db->prepare('DELETE FROM note_tags WHERE note_id = ?')->execute([$noteId]); $tags = self::cleanTags($raw); if (!$tags) { return; } $st = $db->prepare('INSERT INTO note_tags (note_id, tag) VALUES (?,?)'); foreach ($tags as $t) { $st->execute([$noteId, $t]); } } /** * @param string|array $raw 数组,或一段带 `#标签` 的文本 * @return array 去重后的标签(最多 12 个,每个 ≤ 20 字) */ public static function cleanTags($raw): array { $list = []; if (is_array($raw)) { $list = $raw; } elseif (is_string($raw)) { // 支持"从正文里抓 #标签"(flomo 那种随手写法) $txt = $raw; if (preg_match_all('/(?:^|\s)#([^\s#]{1,20})/u', $txt, $m)) { $list = $m[1]; } else { $list = preg_split('/[\s,,]+/u', $txt) ?: []; } } $out = []; foreach ($list as $t) { $t = trim((string)$t); $t = ltrim($t, '#'); $t = trim($t); // 空白与 `#` 都不允许出现在标签内部(它俩是分隔符) $t = (string)preg_replace('/[\s#]+/u', '', $t); if ($t === '') { continue; } $t = mb_substr($t, 0, 20, 'UTF-8'); if (!in_array($t, $out, true)) { $out[] = $t; } if (count($out) >= 12) { break; } } return $out; } }