213 lines
9.5 KiB
PHP
213 lines
9.5 KiB
PHP
|
<?php
|
|||
|
|
/**
|
|||
|
|
* 通知消息（v30 第 5 条）。
|
|||
|
|
*
|
|||
|
|
* 用户原话：「引入通知模块，这个模块，不在导航显示，在个人头像点击那里显示，
|
|||
|
|
* 放在个人设置前面，名字：通知消息。就是当有人在观影、旅程等地方
|
|||
|
|
* 加我的时候，发一个通知，通知出现在首页中，往年今天的前面。」
|
|||
|
|
*
|
|||
|
|
* ────────────────────────────────────────────────────────────────
|
|||
|
|
* 五条设计判断（每条都对应一个"不这么做就会出的问题"）：
|
|||
|
|
*
|
|||
|
|
* ① **不在 Module::LIST 注册**。它不是"一个可浏览的数据模块"，而是"给我看的消息"。
|
|||
|
|
* 注册进 LIST 就会被 `Module::navModules()` 拿去渲染顶栏（用户明确要求"不在导航显示"），
|
|||
|
|
* 还会出现在个人设置的"模块显示与排序"里 —— 那里对它是没有意义的开关。
|
|||
|
|
* ⇒ 它是一个**独立页面**（`?r=notifications`），入口只在头像下拉里。
|
|||
|
|
*
|
|||
|
|
* ② **只通知"别人把我也加进去了"，不通知"我自己建的"**。
|
|||
|
|
* 这是"通知"与"流水账"的分界：我自己建一条观影、列表里带上家人，
|
|||
|
|
* 不该给自己发一条"有人加了你"。所以只对 `personId !== actorId` 的收件人写入。
|
|||
|
|
*
|
|||
|
|
* ③ **按"新增"发，按"删除"撤销**。整组替换（`saveAttendees` 先 DELETE 再 INSERT）
|
|||
|
|
* 会产生一个很具体的坏情况：用户把参与人从 [A,B] 改成 [A]，
|
|||
|
|
* 如果不撤销，B 的通知还挂在那儿 —— "我明明被移出去了，怎么还说加了我"。
|
|||
|
|
* ⇒ `syncForTarget()` 把"这次要保留的收件人"传进来，多出来的**按未读删掉**。
|
|||
|
|
* ⚠️ 已读的**不删**（那是用户已经看过的历史，删了像"消息会自己消失"）；
|
|||
|
|
* 未读的才是"还没送达的提醒"，撤回它才是对的。
|
|||
|
|
*
|
|||
|
|
* ④ **一次编辑不重复发**。UNIQUE KEY (person_id, target_type, target_id)
|
|||
|
|
* + INSERT IGNORE：同一件事反复保存只会有一条通知。
|
|||
|
|
* 否则用户改三次标题就收到三条"加了你"。
|
|||
|
|
*
|
|||
|
|
* ⑤ **不做邮件/推送**。用户要的是"站内消息"（"通知出现在首页中"）。
|
|||
|
|
* 发邮件要 SMTP 配置、还要防打扰，那是另一个模块的事，这里只做站内。
|
|||
|
|
*/
|
|||
|
|
declare(strict_types=1);
|
|||
|
|
|
|||
|
|
namespace App;
|
|||
|
|
|
|||
|
|
final class Notification
|
|||
|
|
{
|
|||
|
|
/** 宿主类型（与 attachments.target_type 同一套词，便于将来复用跳转逻辑） */
|
|||
|
|
public const MOVIE = 'movie';
|
|||
|
|
public const TRIP = 'trip';
|
|||
|
|
|
|||
|
|
/** 列表一次最多显示多少条（首页那块只取前几条，见 unreadCount / recent） */
|
|||
|
|
public const PAGE_SIZE = 50;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 同步某个宿主的"加人"通知。
|
|||
|
|
*
|
|||
|
|
* 调用时机：观影/旅程保存参与人**之后**（见 Movie::saveAttendees / Trip 的对应处）。
|
|||
|
|
*
|
|||
|
|
* @param int $familyId
|
|||
|
|
* @param string $type 宿主类型（'movie' / 'trip'）
|
|||
|
|
* @param int $targetId 宿主 id
|
|||
|
|
* @param string $title 宿主标题（通知里要显示"《xxx》"）
|
|||
|
|
* @param int $actorId 动作发出者（谁把别人加进去的）
|
|||
|
|
* @param int[] $keepIds 这次**保留**的参与人（总集）
|
|||
|
|
* @param string $href 点通知跳哪儿（相对 url() 的 r 值，如 'movies/show'）
|
|||
|
|
* @param array $params href 的查询参数（如 ['id'=>12]）
|
|||
|
|
*/
|
|||
|
|
public static function syncForTarget(int $familyId, string $type, int $targetId,
|
|||
|
|
string $title, int $actorId, array $keepIds,
|
|||
|
|
string $href, array $params = []): void
|
|||
|
|
{
|
|||
|
|
if ($targetId <= 0 || $familyId <= 0) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
$db = Database::get();
|
|||
|
|
|
|||
|
|
// ---- ① 收件人 = 保留列表 - 动作发出者（不给自己发，见头部第 ②条）----
|
|||
|
|
$keep = [];
|
|||
|
|
foreach ($keepIds as $pid) {
|
|||
|
|
$pid = (int)$pid;
|
|||
|
|
if ($pid > 0 && $pid !== $actorId) {
|
|||
|
|
$keep[$pid] = true;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// ---- ② 撤销：这次不在保留列表里的**未读**通知，删掉（见头部第 ③条）----
|
|||
|
|
$st = $db->prepare(
|
|||
|
|
'SELECT id, person_id FROM notifications
|
|||
|
|
WHERE target_type = ? AND target_id = ? AND is_read = 0'
|
|||
|
|
);
|
|||
|
|
$st->execute([$type, $targetId]);
|
|||
|
|
$del = $db->prepare('DELETE FROM notifications WHERE id = ?');
|
|||
|
|
foreach ($st->fetchAll() as $row) {
|
|||
|
|
if (!isset($keep[(int)$row['person_id']])) {
|
|||
|
|
$del->execute([(int)$row['id']]);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// ---- ③ 新增：给每个收件人写一条（INSERT IGNORE 靠唯一键去重，见第 ④条）----
|
|||
|
|
if (!$keep) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
$ins = $db->prepare(
|
|||
|
|
'INSERT IGNORE INTO notifications
|
|||
|
|
(family_id, person_id, actor_id, kind, title, href, params,
|
|||
|
|
target_type, target_id, is_read, created_at)
|
|||
|
|
VALUES (?,?,?,?,?,?,?,?,?,0,NOW())'
|
|||
|
|
);
|
|||
|
|
$kindWord = $type === self::MOVIE ? '观影' : ($type === self::TRIP ? '旅程' : '记录');
|
|||
|
|
$body = '有人把你加进了' . $kindWord . '「' . self::clip($title, 60) . '」';
|
|||
|
|
foreach (array_keys($keep) as $pid) {
|
|||
|
|
$ins->execute([
|
|||
|
|
$familyId, (int)$pid, $actorId, $type, $body,
|
|||
|
|
$href, $params ? json_encode($params, JSON_UNESCAPED_UNICODE) : null,
|
|||
|
|
$type, $targetId,
|
|||
|
|
]);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 宿主被删除时，把它的通知一并清掉。
|
|||
|
|
* ⚠️ 不做外键（target_type 指向多张表，外键表达不了）→ 必须手动清，
|
|||
|
|
* 否则通知点进去 404（本项目在 attachments 上就是这么做的，同一约定）。
|
|||
|
|
*/
|
|||
|
|
public static function removeForTarget(string $type, int $targetId): void
|
|||
|
|
{
|
|||
|
|
if ($targetId <= 0) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
Database::get()->prepare(
|
|||
|
|
'DELETE FROM notifications WHERE target_type = ? AND target_id = ?'
|
|||
|
|
)->execute([$type, $targetId]);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 我的通知（最新在前）。
|
|||
|
|
*
|
|||
|
|
* ⚠️ 「我叫他什么」在**另一张表**（`nicknames`，按 viewer+target 存），
|
|||
|
|
* `persons` 上**没有** `my_nickname` 这一列 —— 必须 LEFT JOIN 取。
|
|||
|
|
* （本项目所有"显示某个人的称呼"的地方都是这么做的，见 Movie::attendees。）
|
|||
|
|
* ⚠️ join 条件里要带**收件人**（$personId）当 viewer：称呼是"我对他"的，
|
|||
|
|
* 不是"他对我"的 —— 传错方向会让通知里出现别人叫他的名字。
|
|||
|
|
*/
|
|||
|
|
public static function mine(int $personId, int $limit = self::PAGE_SIZE, bool $unreadOnly = false): array
|
|||
|
|
{
|
|||
|
|
$sql = 'SELECT n.*, p.name AS actor_name, p.avatar AS actor_avatar,
|
|||
|
|
nk.nickname AS actor_nick
|
|||
|
|
FROM notifications n
|
|||
|
|
LEFT JOIN persons p ON p.id = n.actor_id
|
|||
|
|
LEFT JOIN nicknames nk ON nk.target_id = n.actor_id AND nk.viewer_id = ?
|
|||
|
|
WHERE n.person_id = ?';
|
|||
|
|
$params = [$personId, $personId];
|
|||
|
|
if ($unreadOnly) {
|
|||
|
|
$sql .= ' AND n.is_read = 0';
|
|||
|
|
}
|
|||
|
|
$sql .= ' ORDER BY n.id DESC LIMIT ' . max(1, min(200, $limit));
|
|||
|
|
$st = Database::get()->prepare($sql);
|
|||
|
|
$st->execute($params);
|
|||
|
|
return $st->fetchAll();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/** 未读数（首页那块与头像下拉的角标都用它） */
|
|||
|
|
public static function unreadCount(int $personId): int
|
|||
|
|
{
|
|||
|
|
$st = Database::get()->prepare(
|
|||
|
|
'SELECT COUNT(*) FROM notifications WHERE person_id = ? AND is_read = 0'
|
|||
|
|
);
|
|||
|
|
$st->execute([$personId]);
|
|||
|
|
return (int)$st->fetchColumn();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/** 全部标记已读（进通知页就自动全读 —— 与"消息中心"的通用做法一致） */
|
|||
|
|
public static function markAllRead(int $personId): int
|
|||
|
|
{
|
|||
|
|
$st = Database::get()->prepare(
|
|||
|
|
'UPDATE notifications SET is_read = 1 WHERE person_id = ? AND is_read = 0'
|
|||
|
|
);
|
|||
|
|
$st->execute([$personId]);
|
|||
|
|
return $st->rowCount();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/** 删除一条（只能删自己的 —— 与其它模块同一道越权栅栏） */
|
|||
|
|
public static function delete(int $id, int $personId): bool
|
|||
|
|
{
|
|||
|
|
$st = Database::get()->prepare(
|
|||
|
|
'DELETE FROM notifications WHERE id = ? AND person_id = ?'
|
|||
|
|
);
|
|||
|
|
$st->execute([$id, $personId]);
|
|||
|
|
return $st->rowCount() > 0;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/** 清空我的（只删已读的？不 —— 用户点"清空"就是要清空，未读也清） */
|
|||
|
|
public static function clearMine(int $personId): int
|
|||
|
|
{
|
|||
|
|
$st = Database::get()->prepare('DELETE FROM notifications WHERE person_id = ?');
|
|||
|
|
$st->execute([$personId]);
|
|||
|
|
return $st->rowCount();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/** 通知的跳转地址（params 是 json 存的，坏数据就当没有参数） */
|
|||
|
|
public static function href(array $n): string
|
|||
|
|
{
|
|||
|
|
$params = [];
|
|||
|
|
if (!empty($n['params'])) {
|
|||
|
|
$dec = json_decode((string)$n['params'], true);
|
|||
|
|
if (is_array($dec)) {
|
|||
|
|
$params = $dec;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return url((string)$n['href'], $params);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/** 文案截断（多字节安全） */
|
|||
|
|
private static function clip(string $s, int $max): string
|
|||
|
|
{
|
|||
|
|
$s = trim(preg_replace('/\s+/u', ' ', $s));
|
|||
|
|
return $s === '' ? '（无标题）' : mb_substr($s, 0, $max, 'UTF-8');
|
|||
|
|
}
|
|||
|
|
}
|