laoyang
746f02581e
- events 起止时间精确到秒（starts_at DATE→DATETIME + ends_at），_datetime.php 复用 - 影院独立成表（cinemas，地方/名称/地址/主题色 + 50 色板），movie_details 归一为 cinema_id - 评价模型 MovieLog 同款：movie_reviews 每账号每片一条（1-10 分+正文+感受 key）， movie_review_comments 两级平铺评论（回复的回复规范化到顶层、跨评价回复拦截） - 感受目录迁到 MovieReview::CATALOG（12 种，Emoji 11.0 老码位） - 观影列表改瀑布流（CSS grid 海报墙），详情页五大块 + 灯箱 + 评价区 - 升级路径：v8 老数据自动归一（影院三段按 (family,place,name) 去重建行、 评价回填、中文感受反查英文 key），回填全部幂等；老库补 cinema_id 列+索引+外键 - 修三 bug：建表顺序（cinemas 必须在 movie_details 前，否则全新安装 1215）、 layout 导航用键名当路由（影院链接指向 r=cinemas）、 _datetime.php 分钟循环变量 $m 覆盖宿主模板的观影记录（编辑页简介/备注回填被清空）
309 lines
12 KiB
PHP
309 lines
12 KiB
PHP
<?php
|
||
/**
|
||
* 观影记录（统一事件原语的第一个落地种类）。
|
||
*
|
||
* 归一模型（见 familybook.md 的核心设计）：
|
||
* events = 一切记录的共同骨架（标题 / 起止时刻 / 地点 / 来源引用）
|
||
* movie_details = 观影特有的卫星表（海报 / 票根 / 关联影院）
|
||
* attendees = 同行观影的人（persons.id）
|
||
* photos = 现场照片（可多张）
|
||
* reviews = 评价与讨论（movie_reviews / movie_review_comments，见 MovieReview）
|
||
* cinemas = 影院独立管理（见 Cinema）
|
||
*
|
||
* 图片一律存**相对键**（如 posters/xxx.jpg），地址由 media.php 代理 ——
|
||
* 本地与 OSS 的差别被 Storage 吃掉，这里永远不碰完整 URL。
|
||
*
|
||
* source_ref 是迁移幂等的锚点：MovieLog 整体迁入时写成 'movielog:movie:<id>'，
|
||
* 重跑迁移按它先查再插，不会出现一半新一半旧的中间态。
|
||
*/
|
||
|
||
declare(strict_types=1);
|
||
|
||
namespace App;
|
||
|
||
final class Movie
|
||
{
|
||
/** @return array<int,array> 观影记录，按开场时刻倒序（瀑布流用）。
|
||
* $keyword 非空时搜：片名 / 影院名 / 同行人名（LIKE）。 */
|
||
public static function all(int $familyId, string $keyword = ''): array
|
||
{
|
||
$sql =
|
||
'SELECT e.id, e.title, e.starts_at, e.ends_at, e.note,
|
||
d.poster_key, c.name AS cinema_name, c.color AS cinema_color,
|
||
(SELECT COUNT(*) FROM event_attendees a WHERE a.event_id = e.id) AS attendee_count,
|
||
(SELECT GROUP_CONCAT(p.name ORDER BY a.position, p.id SEPARATOR "、")
|
||
FROM event_attendees a JOIN persons p ON p.id = a.person_id
|
||
WHERE a.event_id = e.id) AS attendee_names
|
||
FROM events e
|
||
LEFT JOIN movie_details d ON d.event_id = e.id
|
||
LEFT JOIN cinemas c ON c.id = d.cinema_id
|
||
WHERE e.family_id = ? AND e.kind = "movie"';
|
||
$bind = [$familyId];
|
||
$kw = trim($keyword);
|
||
if ($kw !== '') {
|
||
$sql .= ' AND (e.title LIKE ? OR c.name LIKE ? OR e.location LIKE ?
|
||
OR EXISTS (SELECT 1 FROM event_attendees a JOIN persons p ON p.id = a.person_id
|
||
WHERE a.event_id = e.id AND p.name LIKE ?))';
|
||
$like = '%' . $kw . '%';
|
||
array_push($bind, $like, $like, $like, $like);
|
||
}
|
||
$sql .= ' ORDER BY e.starts_at DESC, e.id DESC';
|
||
$st = Database::get()->prepare($sql);
|
||
$st->execute($bind);
|
||
$rows = $st->fetchAll();
|
||
MovieReview::attachStats($rows);
|
||
return $rows;
|
||
}
|
||
|
||
/** 一条完整记录（详情/编辑页用）：事件 + 卫星 + 影院 + 同行人 + 照片 */
|
||
public static function find(int $familyId, int $id): ?array
|
||
{
|
||
$st = Database::get()->prepare(
|
||
'SELECT e.*, d.info, d.poster_key, d.ticket_key, d.cinema_id,
|
||
c.place AS cinema_place, c.name AS cinema_name,
|
||
c.address AS cinema_address, c.color AS cinema_color
|
||
FROM events e
|
||
LEFT JOIN movie_details d ON d.event_id = e.id
|
||
LEFT JOIN cinemas c ON c.id = d.cinema_id
|
||
WHERE e.family_id = ? AND e.id = ? AND e.kind = "movie"'
|
||
);
|
||
$st->execute([$familyId, $id]);
|
||
$row = $st->fetch();
|
||
if (!$row) {
|
||
return null;
|
||
}
|
||
$row['attendees'] = self::attendees($id);
|
||
$row['photos'] = self::photos($id);
|
||
return $row;
|
||
}
|
||
|
||
/** @return array<int,array{id:int,name:string,avatar:?string}> 同行的人 */
|
||
public static function attendees(int $eventId): array
|
||
{
|
||
$st = Database::get()->prepare(
|
||
'SELECT p.id, p.name, p.avatar
|
||
FROM event_attendees a JOIN persons p ON p.id = a.person_id
|
||
WHERE a.event_id = ?
|
||
ORDER BY a.position, p.id'
|
||
);
|
||
$st->execute([$eventId]);
|
||
return $st->fetchAll();
|
||
}
|
||
|
||
public static function photos(int $eventId): array
|
||
{
|
||
$st = Database::get()->prepare(
|
||
'SELECT id, `key` FROM event_photos WHERE event_id = ? ORDER BY position, id'
|
||
);
|
||
$st->execute([$eventId]);
|
||
return $st->fetchAll();
|
||
}
|
||
|
||
/**
|
||
* 新建一条观影记录，返回事件 id。
|
||
* $d 字段：title, starts_at(Y-m-d H:i:s), ends_at, location, note, info,
|
||
* cinema_id(int|null), poster_key, ticket_key, attendees(int[]), photos(string[])
|
||
*/
|
||
public static function create(int $familyId, ?int $creatorId, array $d): int
|
||
{
|
||
$db = Database::get();
|
||
$db->prepare(
|
||
'INSERT INTO events (family_id, creator_id, kind, title, starts_at, ends_at, location, note, source_ref)
|
||
VALUES (?, ?, "movie", ?, ?, ?, ?, ?, ?)'
|
||
)->execute([
|
||
$familyId, $creatorId, (string)$d['title'],
|
||
self::dtOrNull($d['starts_at'] ?? ''), self::dtOrNull($d['ends_at'] ?? ''),
|
||
self::locOrNull($d['location'] ?? ''), self::textOrNull($d['note'] ?? ''),
|
||
$d['source_ref'] ?? null,
|
||
]);
|
||
$id = (int)$db->lastInsertId();
|
||
self::saveDetails($id, $d);
|
||
self::saveAttendees($id, $d['attendees'] ?? []);
|
||
self::savePhotos($id, $d['photos'] ?? []);
|
||
return $id;
|
||
}
|
||
|
||
public static function update(int $familyId, int $id, array $d): void
|
||
{
|
||
$db = Database::get();
|
||
$db->prepare(
|
||
'UPDATE events SET title = ?, starts_at = ?, ends_at = ?, location = ?, note = ?
|
||
WHERE id = ? AND family_id = ?'
|
||
)->execute([
|
||
(string)$d['title'],
|
||
self::dtOrNull($d['starts_at'] ?? ''), self::dtOrNull($d['ends_at'] ?? ''),
|
||
self::locOrNull($d['location'] ?? ''), self::textOrNull($d['note'] ?? ''),
|
||
$id, $familyId,
|
||
]);
|
||
self::saveDetails($id, $d);
|
||
self::saveAttendees($id, $d['attendees'] ?? []);
|
||
// photos 由单独的「删除某张」路由维护，编辑保存不整组替换
|
||
}
|
||
|
||
/** 卫星表 upsert（编辑时可能还没建过这行） */
|
||
private static function saveDetails(int $eventId, array $d): void
|
||
{
|
||
$db = Database::get();
|
||
$cid = (int)($d['cinema_id'] ?? 0);
|
||
$row = [
|
||
self::textOrNull($d['info'] ?? ''),
|
||
self::keyOrNull($d['poster_key'] ?? ''),
|
||
self::keyOrNull($d['ticket_key'] ?? ''),
|
||
$cid > 0 ? $cid : null,
|
||
];
|
||
$has = $db->prepare('SELECT COUNT(*) FROM movie_details WHERE event_id = ?');
|
||
$has->execute([$eventId]);
|
||
if ((int)$has->fetchColumn() > 0) {
|
||
$db->prepare('UPDATE movie_details SET info=?, poster_key=?, ticket_key=?, cinema_id=? WHERE event_id=?')
|
||
->execute([...$row, $eventId]);
|
||
} else {
|
||
$db->prepare('INSERT INTO movie_details (info, poster_key, ticket_key, cinema_id, event_id) VALUES (?,?,?,?,?)')
|
||
->execute([...$row, $eventId]);
|
||
}
|
||
}
|
||
|
||
/** 整组替换同行人（与 Person::replaceContacts 同一思路：一行不剩、一行不多） */
|
||
public static function saveAttendees(int $eventId, array $personIds): void
|
||
{
|
||
$db = Database::get();
|
||
$db->prepare('DELETE FROM event_attendees WHERE event_id = ?')->execute([$eventId]);
|
||
$ins = $db->prepare(
|
||
'INSERT IGNORE INTO event_attendees (event_id, person_id, position) VALUES (?, ?, ?)'
|
||
);
|
||
$pos = 0;
|
||
foreach ($personIds as $pid) {
|
||
$pid = (int)$pid;
|
||
if ($pid <= 0) {
|
||
continue;
|
||
}
|
||
$pos += 10;
|
||
$ins->execute([$eventId, $pid, $pos]);
|
||
}
|
||
}
|
||
|
||
/** 整组替换现场照片（导入用；表单的「删一张」走 deletePhoto） */
|
||
public static function savePhotos(int $eventId, array $keys): void
|
||
{
|
||
$db = Database::get();
|
||
$db->prepare('DELETE FROM event_photos WHERE event_id = ?')->execute([$eventId]);
|
||
$ins = $db->prepare('INSERT INTO event_photos (event_id, `key`, position) VALUES (?, ?, ?)');
|
||
$pos = 0;
|
||
foreach ($keys as $k) {
|
||
$k = trim((string)$k);
|
||
if ($k === '') {
|
||
continue;
|
||
}
|
||
$pos += 10;
|
||
$ins->execute([$eventId, $k, $pos]);
|
||
}
|
||
}
|
||
|
||
/** 删一张现场照片（连带删存储对象） */
|
||
public static function deletePhoto(int $familyId, int $eventId, int $photoId): void
|
||
{
|
||
$st = Database::get()->prepare('SELECT `key` FROM event_photos WHERE id = ? AND event_id = ?');
|
||
$st->execute([$photoId, $eventId]);
|
||
$key = (string)($st->fetchColumn() ?: '');
|
||
Database::get()->prepare('DELETE FROM event_photos WHERE id = ? AND event_id = ?')
|
||
->execute([$photoId, $eventId]);
|
||
if ($key !== '') {
|
||
Storage\Storage::delete($familyId, $key);
|
||
}
|
||
}
|
||
|
||
/** 删除整条观影记录（events 级联带走卫星/同行人/照片行；存储对象手动清） */
|
||
public static function destroy(int $familyId, int $id): void
|
||
{
|
||
$keys = [];
|
||
foreach (self::photos($id) as $p) {
|
||
$keys[] = (string)$p['key'];
|
||
}
|
||
$st = Database::get()->prepare(
|
||
'SELECT poster_key, ticket_key FROM movie_details WHERE event_id = ?'
|
||
);
|
||
$st->execute([$id]);
|
||
if ($row = $st->fetch()) {
|
||
foreach ([$row['poster_key'], $row['ticket_key']] as $k) {
|
||
if ($k) {
|
||
$keys[] = (string)$k;
|
||
}
|
||
}
|
||
}
|
||
Database::get()->prepare('DELETE FROM events WHERE id = ? AND family_id = ? AND kind = "movie"')
|
||
->execute([$id, $familyId]);
|
||
foreach ($keys as $k) {
|
||
Storage\Storage::delete($familyId, $k);
|
||
}
|
||
}
|
||
|
||
// ---------------- 展示格式化 ----------------
|
||
|
||
/**
|
||
* 观影时刻的人话展示：
|
||
* 只有日期（时间恰好 00:00:00 且无散场）→「2026年09月30日」；
|
||
* 有开场时刻 →「2026年09月30日 19:30:00」；有散场 → 追加「 – 21:45:12」。
|
||
* 两个都空 →「日期待补」。
|
||
*/
|
||
public static function formatWatch(?string $start, ?string $end): string
|
||
{
|
||
if ($start === null || $start === '') {
|
||
return '日期待补';
|
||
}
|
||
$ts = strtotime($start);
|
||
if ($ts === false) {
|
||
return '日期待补';
|
||
}
|
||
$out = date('Y年m月d日', $ts);
|
||
$midnight = substr((string)$start, 11) === '00:00:00';
|
||
if (!$midnight) {
|
||
$out .= ' ' . date('H:i:s', $ts);
|
||
}
|
||
if ($end !== null && $end !== '') {
|
||
$ets = strtotime($end);
|
||
if ($ets !== false) {
|
||
if (date('Y-m-d', $ets) !== date('Y-m-d', $ts)) {
|
||
$out = date('Y年m月d日', $ts) . ($midnight ? '' : ' ' . date('H:i:s', $ts))
|
||
. ' – ' . date('Y年m月d日 H:i:s', $ets);
|
||
} else {
|
||
$out .= ' – ' . date('H:i:s', $ets);
|
||
}
|
||
}
|
||
}
|
||
return $out;
|
||
}
|
||
|
||
// ---------------- 小工具 ----------------
|
||
|
||
/** 'Y-m-d H:i:s' 校验（秒级精确）；空串/不合法回 NULL */
|
||
private static function dtOrNull(string $v): ?string
|
||
{
|
||
$v = trim($v);
|
||
if ($v === '' || !preg_match('/^\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}$/', $v)) {
|
||
return null;
|
||
}
|
||
return $v;
|
||
}
|
||
|
||
private static function locOrNull(string $v): ?string
|
||
{
|
||
$v = mb_substr(trim($v), 0, 200, 'UTF-8');
|
||
return $v !== '' ? $v : null;
|
||
}
|
||
|
||
private static function textOrNull(string $v): ?string
|
||
{
|
||
$v = trim($v);
|
||
return $v !== '' ? $v : null;
|
||
}
|
||
|
||
/** 存储键只留安全字符（相对键，不带路径穿越），空串回 NULL */
|
||
private static function keyOrNull(string $v): ?string
|
||
{
|
||
$v = ltrim(trim($v), '/');
|
||
if ($v === '' || strpos($v, '..') !== false || strpos($v, "\0") !== false) {
|
||
return null;
|
||
}
|
||
return $v;
|
||
}
|
||
}
|