优化 Laravel 数据库通知：实现聚合与避免重复创建

public function toDatabase($notifiable): array
{
    return [
        'content' => [
            'en' => "1 new post matched with your saved search {$this->search->title} has been posted, Press here to view more.",
        ],
        'count' => 1,
        'search' => $this->search->id,
        'parameters' => $this->search->parameters
    ];
}

// 初始尝试的代码片段
public function toDatabase($notifiable): array
{
    $count = 1;
    // 尝试查找在过去30分钟内，与当前搜索相关的现有通知
    if ($notification = $notifiable->notifications()
        ->where('data->search', $this->search->id)
        ->where('updated_at', '>=', now()->subMinutes(30))
        ->first()) {

        // 如果找到，更新其计数
        $count = isset($notification->data['count']) ? $notification->data['count'] + 1 : 1;
        $notification->update([
            'data' => [
                'content' => [
                    'en' => "{$count} new posts matched with your saved search {$this->search->title} has been posted, Press here to view more.",
                ],
                'count' => $count,
                // 确保保留其他原有数据
                'search' => $this->search->id,
                'parameters' => $this->search->parameters
            ]
        ]);
    }

    // 问题所在：无论是否更新了现有通知，这里都会返回一个数组
    return [
        'content' => [
            'en' => "{$count} new post matched with your saved search {$this->search->title} has been posted, Press here to view more.",
        ],
        'count' => $count,
        'search' => $this->search->id,
        'parameters' => $this->search->parameters
    ];
}

<?php

namespace App\Notifications;

use Illuminate\Bus\Queueable;
use Illuminate\Notifications\Notification;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Notifications\Messages\DatabaseMessage; // 如果需要自定义DatabaseMessage
use App\Models\Search; // 假设您的Search模型

class NewPostsMatchedSearch extends Notification // 假设这是您的通知类
{
    use Queueable;

    protected $search;

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

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

    /**
     * 获取通知的数据库表示。
     *
     * @param  mixed  $notifiable
     * @return array|null // 关键：返回类型可以是 array 或 null
     */
    public function toDatabase($notifiable): ?array
    {
        // 1. 定义聚合的时间窗口（例如30分钟）
        $timeWindow = now()->subMinutes(30);

        // 2. 尝试查找在指定时间窗口内，针对当前用户和当前搜索的同类型通知
        // 务必添加 'type' 过滤，以确保只聚合相同类型的通知
        $existingNotification = $notifiable->notifications()
            ->where('type', self::class) // 过滤通知类型
            ->where('data->search', $this->search->id) // 过滤搜索ID
            ->where('updated_at', '>=', $timeWindow) // 过滤时间窗口
            ->first();

        if ($existingNotification) {
            // 3. 如果找到现有通知，则更新其计数和内容
            $newCount = isset($existingNotification->data['count']) ? $existingNotification->data['count'] + 1 : 1;
            $existingNotification->update([
                'data' => [
                    'content' => [
                        'en' => "{$newCount} new posts matched with your saved search {$this->search->title} has been posted, Press here to view more.",
                    ],
                    'count' => $newCount,
                    'search' => $this->search->id,
                    'parameters' => $this->search->parameters,
                ]
            ]);

            // 4. 关键步骤：返回 null 或空数组以阻止 Laravel 创建新的通知记录
            return null; // 或者 return [];
        }

        // 5. 如果没有找到现有通知，则创建新的通知
        return [
            'content' => [
                'en' => "1 new post matched with your saved search {$this->search->title} has been posted, Press here to view more.",
            ],
            'count' => 1,
            'search' => $this->search->id,
            'parameters' => $this->search->parameters
        ];
    }
}