Laravel 数据库通知聚合与计数更新策略

<?php

namespace App\Notifications;

use Illuminate\Bus\Queueable;
use Illuminate\Notifications\Notification;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Notifications\Messages\DatabaseMessage; // 引入 DatabaseMessage 可选，直接返回数组也可

class PostMatchedSearch extends Notification implements ShouldQueue // 推荐使用队列
{
    use Queueable;

    protected $search;
    // 可以在构造函数中传入更多上下文信息，例如触发通知的 Post 对象
    protected $post; 

    /**
     * 创建一个新的通知实例。
     *
     * @param  \App\Models\Search  $search
     * @param  \App\Models\Post|null  $post
     * @return void
     */
    public function __construct($search, $post = null)
    {
        $this->search = $search;
        $this->post = $post;
    }

    /**
     * 获取通知的投递渠道。
     *
     * @param  mixed  $notifiable
     * @return array
     */
    public function via($notifiable): array
    {
        return ['database'];
    }

    /**
     * 获取通知的数据库表示。
     *
     * @param  mixed  $notifiable
     * @return array|null
     */
    public function toDatabase($notifiable): ?array
    {
        // 定义通知聚合的时间窗口（例如30分钟）
        $timeWindowMinutes = 30;

        // 构造当前通知的数据，其中包含用于识别聚合的键（如 'search_id'）
        $currentNotificationData = [
            'search_id' => $this->search->id,
            'title' => $this->search->title,
            'parameters' => $this->search->parameters,
            // 如果需要，可以在这里记录触发当前通知的最新帖子ID
            'latest_post_id' => $this->post ? $this->post->id : null, 
        ];

        // 尝试查找在指定时间窗口内，与当前搜索相关的未读通知
        // 1. where('type', self::class) 确保只聚合同类型的通知
        // 2. where('read_at', null) 确保只聚合用户尚未阅读的通知
        // 3. where('data->search_id', $this->search->id) 通过JSON字段精确匹配搜索ID
        // 4. where('created_at', '>=', now()->subMinutes($timeWindowMinutes)) 定义时间窗口
        $existingNotification = $notifiable->notifications()
            ->where('type', self::class)
            ->where('read_at', null) 
            ->where('data->search_id', $this->search->id) 
            ->where('created_at', '>=', now()->subMinutes($timeWindowMinutes))
            ->first();

        if ($existingNotification) {
            // 如果找到现有通知，更新其计数和内容
            $currentCount = $existingNotification->data['count'] ?? 1;
            $newCount = $currentCount + 1;

            // 更新现有通知的数据
            $existingNotification->update([
                'data' => array_merge($existingNotification->data, [
                    'count' => $newCount,
                    'content' => [
                        'en' => "{$newCount} new posts matched with your saved search {$this->search->title} have been posted. Click here to view more.",
                        // 可以添加一个时间戳，表示最后更新时间
                        'last_updated' => now()->toDateTimeString(),
                    ],
                    // 更新最新的帖子ID
                    'latest_post_id' => $this->post ? $this->post->id : null,
                ]),
                'updated_at' => now(), // 手动更新 updated_at 字段
            ]);

            // 返回 null 阻止创建新的通知记录
            return null;
        }

        // 如果没有找到现有通知，则创建新的通知
        return [
            'content' => [
                'en' => "1 new post matched with your saved search {$this->search->title} has been posted. Click here to view more.",
            ],
            'count' => 1,
            // 确保这里返回的数据结构与查询时使用的键（如 'search_id'）一致
            'search_id' => $this->search->id, 
            'parameters' => $this->search->parameters,
            'latest_post_id' => $this->post ? $this->post->id : null,
        ];
    }
}