使用 php 和 mysql 的通知系统

php triggers notifications mysql

2022-08-30 10:06:36

我想为我们学校实现一个通知系统，它是一个php / mysql webapp，不向公众开放，所以它没有收到太多的流量。“每天500-1000名访客”。

1. 我最初的方法是使用 MYSQL 触发器：

我使用Mysql将记录添加到名为.类似的东西。AFTER INSERT triggernotifications

'CREATE TRIGGER `notify_new_homwork` AFTER INSERT ON `homeworks`
 FOR EACH ROW INSERT INTO `notifications` 
    ( `from_id`, `note`, `class_id`) 
 VALUES 
    (new.user_id, 
        concat('A New homework Titled: "',left(new.title,'50'),
        '".. was added' )
    ,new.subject_id , 11);'

这种黑魔法效果很好，但我无法跟踪此通知是否是新的“为用户显示新通知的计数”。所以我添加了一个名为通知的页面。

使用类似如下内容检索通知

SELECT n.* from notifications n 
JOIN user_class on user_class.class_id = n.class_id where user_class.user_id = X;

注意：表user_class用户链接到类“user_id，class_id，subject_id”-主题为空，除非用户是教师

现在我的下一个挑战是。

如何跟踪每个用户的新旧通知？
如何将与用户相似的通知聚合到一行中？

例如，如果有2个用户评论了某件事，那么不要插入新行，只需用“userx和1个其他评论hw”之类的内容更新旧行即可。

多谢

编辑

根据下面的答案，要在行上设置一个已读/未读标志，我需要为每个学生设置一行，而不仅仅是整个班级的一行。这意味着将触发器编辑为类似

insert into notifications (from_id,note,student_id,isread)
select new.user_id,new.note,user_id,'0' from user_class where user_class.class_id = new.class_id group by user_class.user_id

答案 1

好吧，这个问题已经9个月了，所以我不确定OP是否仍然需要答案，但由于许多观点和美味的赏金，我还想添加我的芥末（德语谚语..）。

在这篇文章中，我将尝试做一个简单的解释性例子，说明如何开始构建通知系统。

编辑：好吧，这原来比我预期的要长。我最后真的很累，对不起。

WTLDR;

问题 1：每个通知上都有一个标志。

问题 2：仍将每个通知存储为数据库中的单个记录，并在请求时对其进行分组。

结构

我假设通知将如下所示：

+---------------------------------------------+
| ▣ James has uploaded new Homework: Math 1+1 |
+---------------------------------------------+
| ▣ Jane and John liked your comment: Im s... | 
+---------------------------------------------+
| ▢ The School is closed on independence day. |
+---------------------------------------------+

在窗帘后面，这可能看起来像这样：

+--------+-----------+--------+-----------------+-------------------------------------------+
| unread | recipient | sender | type            | reference                                 |
+--------+-----------+--------+-----------------+-------------------------------------------+
| true   | me        | James  | homework.create | Math 1 + 1                                |
+--------+-----------+--------+-----------------+-------------------------------------------+
| true   | me        | Jane   | comment.like    | Im sick of school                         |
+--------+-----------+--------+-----------------+-------------------------------------------+
| true   | me        | John   | comment.like    | Im sick of school                         |
+--------+-----------+--------+-----------------+-------------------------------------------+
| false  | me        | system | message         | The School is closed on independence day. |
+--------+-----------+--------+-----------------+-------------------------------------------+

注意：我不建议在数据库中对通知进行分组，在运行时执行此操作，这样可以使事情变得更加灵活。

未读
每个通知都应该有一个标志来指示收件人是否已打开通知。
收件人
定义接收通知的人员。
发件人
定义触发通知的人员。
类型
创建类型不是让数据库内的每条消息都以纯文本形式显示。这样，您就可以在后端内为不同的通知类型创建特殊的处理程序。将减少存储在数据库中的数据量，并为您提供更大的灵活性，使通知的轻松翻译，过去消息的更改等成为可能。
引用
大多数通知都会引用数据库或应用程序上的记录。

我一直在使用的每个系统在通知上都有一个简单的1比1引用关系，你可能有一个1到n，请记住，我将以1：1继续我的例子。这也意味着我不需要定义引用的对象类型的字段，因为这是由通知类型定义的。

SQL 表

现在，在为SQL定义真正的表结构时，我们会在数据库设计方面做出一些决定。我将使用最简单的解决方案，如下所示：

+--------------+--------+---------------------------------------------------------+
| column       | type   | description                                             |
+--------------+--------+---------------------------------------------------------+
| id           | int    | Primary key                                             |
+--------------+--------+---------------------------------------------------------+
| recipient_id | int    | The receivers user id.                                  |
+--------------+--------+---------------------------------------------------------+
| sender_id    | int    | The sender's user id.                                   |
+--------------+--------+---------------------------------------------------------+
| unread       | bool   | Flag if the recipient has already read the notification |
+--------------+--------+---------------------------------------------------------+
| type         | string | The notification type.                                  |
+--------------+--------+---------------------------------------------------------+
| parameters   | array  | Additional data to render different notification types. |
+--------------+--------+---------------------------------------------------------+
| reference_id | int    | The primary key of the referencing object.              |
+--------------+--------+---------------------------------------------------------+
| created_at   | int    | Timestamp of the notification creation date.            |
+--------------+--------+---------------------------------------------------------+

或者对于懒惰的人来说，SQL create table命令用于此示例：

CREATE TABLE `notifications` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `recipient_id` int(11) NOT NULL,
  `sender_id` int(11) NOT NULL,
  `unread` tinyint(1) NOT NULL DEFAULT '1',
  `type` varchar(255) NOT NULL DEFAULT '',
  `parameters` text NOT NULL,
  `reference_id` int(11) NOT NULL,
  `created_at` int(11) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

PHP 服务

这个实现完全取决于你应用程序的需求，注意：这是一个例子，而不是关于如何用PHP构建通知系统的黄金标准。

通知模型

这是通知本身的一个示例基本模型，没有什么花哨的，只有所需的属性和抽象方法，我们希望在不同的通知类型中实现。messageForNotificationmessageForNotifications

abstract class Notification
{
    protected $recipient;
    protected $sender;
    protected $unread;
    protected $type;
    protected $parameters;
    protected $referenceId;
    protected $createdAt;

    /**
     * Message generators that have to be defined in subclasses
     */
    public function messageForNotification(Notification $notification) : string;
    public function messageForNotifications(array $notifications) : string;

    /**
     * Generate message of the current notification.
     */ 
    public function message() : string
    {
        return $this->messageForNotification($this);
    }
}

你将不得不以自己的风格添加一个构造函数，getters，setters和那种东西，我不会提供一个现成的通知系统。

通知类型

现在，您可以为每个类型创建一个新的子类。以下示例将处理注释的类似操作：Notification

Ray 喜欢您的评论。（1 通知）
约翰和简喜欢你的评论。（2 条通知）
简，约翰尼，詹姆斯和珍妮喜欢你的评论。（4 条通知）
强尼，詹姆斯和其他12人喜欢你的评论。（14 条通知）

示例实现：

namespace Notification\Comment;

class CommentLikedNotification extends \Notification
{
    /**
     * Generate a message for a single notification
     * 
     * @param Notification              $notification
     * @return string 
     */
    public function messageForNotification(Notification $notification) : string 
    {
        return $this->sender->getName() . 'has liked your comment: ' . substr($this->reference->text, 0, 10) . '...'; 
    }

    /**
     * Generate a message for a multiple notifications
     * 
     * @param array              $notifications
     * @return string 
     */
    public function messageForNotifications(array $notifications, int $realCount = 0) : string 
    {
        if ($realCount === 0) {
            $realCount = count($notifications);
        }

        // when there are two 
        if ($realCount === 2) {
            $names = $this->messageForTwoNotifications($notifications);
        }
        // less than five
        elseif ($realCount < 5) {
            $names = $this->messageForManyNotifications($notifications);
        }
        // to many
        else {
            $names = $this->messageForManyManyNotifications($notifications, $realCount);
        }

        return $names . ' liked your comment: ' . substr($this->reference->text, 0, 10) . '...'; 
    }

    /**
     * Generate a message for two notifications
     *
     *      John and Jane has liked your comment.
     * 
     * @param array              $notifications
     * @return string 
     */
    protected function messageForTwoNotifications(array $notifications) : string 
    {
        list($first, $second) = $notifications;
        return $first->getName() . ' and ' . $second->getName(); // John and Jane
    }

    /**
     * Generate a message many notifications
     *
     *      Jane, Johnny, James and Jenny has liked your comment.
     * 
     * @param array              $notifications
     * @return string 
     */
    protected function messageForManyNotifications(array $notifications) : string 
    {
        $last = array_pop($notifications);

        foreach($notifications as $notification) {
            $names .= $notification->getName() . ', ';
        }

        return substr($names, 0, -2) . ' and ' . $last->getName(); // Jane, Johnny, James and Jenny
    }

    /**
     * Generate a message for many many notifications
     *
     *      Jonny, James and 12 other have liked your comment.
     * 
     * @param array              $notifications
     * @return string 
     */
    protected function messageForManyManyNotifications(array $notifications, int $realCount) : string 
    {
        list($first, $second) = array_slice($notifications, 0, 2);

        return $first->getName() . ', ' . $second->getName() . ' and ' .  $realCount . ' others'; // Jonny, James and 12 other
    }
}

通知管理器

要在应用程序中处理通知，请创建类似于通知管理器的内容：

class NotificationManager
{
    protected $notificationAdapter;

    public function add(Notification $notification);

    public function markRead(array $notifications);

    public function get(User $user, $limit = 20, $offset = 0) : array;
}

在此示例 mysql 的情况下，该属性应包含与数据后端直接通信的逻辑。notificationAdapter

创建通知

使用触发器没有错，因为没有错误的解决方案。什么有效，什么就有效。.但我强烈建议不要让数据库处理应用程序逻辑。mysql

因此，在通知管理器中，您可能希望执行如下操作：

public function add(Notification $notification)
{
    // only save the notification if no possible duplicate is found.
    if (!$this->notificationAdapter->isDoublicate($notification))
    {
        $this->notificationAdapter->add([
            'recipient_id' => $notification->recipient->getId(),
            'sender_id' => $notification->sender->getId()
            'unread' => 1,
            'type' => $notification->type,
            'parameters' => $notification->parameters,
            'reference_id' => $notification->reference->getId(),
            'created_at' => time(),
        ]);
    }
}

方法的背后可以是一个原始的mysql插入命令。使用此适配器抽象，您可以轻松地从mysql切换到基于文档的数据库，如mongodb，这对于通知系统是有意义的。addnotificationAdapter

上的方法应该简单地检查是否已经存在具有相同、和的通知。isDoublicatenotificationAdapterrecipientsendertypereference

我再怎么指出也不过分，这只是一个例子。（另外，我真的必须缩短下一步，这篇文章变得荒谬可笑-.-）

因此，假设您有某种控制器，当教师上传家庭作业时具有操作：

function uploadHomeworkAction(Request $request)
{
    // handle the homework and have it stored in the var $homework.

    // how you handle your services is up to you...
    $notificationManager = new NotificationManager;

    foreach($homework->teacher->students as $student)
    {
        $notification = new Notification\Homework\HomeworkUploadedNotification;
        $notification->sender = $homework->teacher;
        $notification->recipient = $student;
        $notification->reference = $homework;

        // send the notification
        $notificationManager->add($notification);
    }
}

将为每个教师的学生上传新家庭作业时创建通知。

阅读通知

现在是困难的部分。PHP端分组的问题在于，您必须加载当前用户的所有通知才能正确分组。这将是不好的，好吧，如果你只有几个用户，它可能仍然没有问题，但这并不能使它变得好。

简单的解决方案是简单地限制请求的通知数量，并仅对这些通知进行分组。当没有很多类似的通知（例如每20个通知中有3-4个）时，这将正常工作。但是，假设用户/学生的帖子获得了大约一百个赞，而您只选择了最后20个通知。然后，用户只会看到20人喜欢他的帖子，这也是他唯一的通知。

“正确”的解决方案是对数据库中已有的通知进行分组，并为每个通知组仅选择一些样本。比你只需要将真实计数注入到通知消息中。

您可能没有阅读下面的文本，因此让我继续一个片段：

select *, count(*) as count from notifications
where recipient_id = 1
group by `type`, `reference_id`
order by created_at desc, unread desc
limit 20

现在，您知道给定用户应该有哪些通知以及该组包含多少通知。

现在是糟糕的部分。我仍然无法找到更好的方法来为每个组选择有限数量的通知，而无需为每个组进行查询。这里非常欢迎所有建议。

所以我做了这样的事情：

$notifcationGroups = [];

foreach($results as $notification)
{
    $notifcationGroup = ['count' => $notification['count']];

    // when the group only contains one item we don't 
    // have to select it's children
    if ($notification['count'] == 1)
    {
        $notifcationGroup['items'] = [$notification];
    }
    else
    {
        // example with query builder
        $notifcationGroup['items'] = $this->select('notifications')
            ->where('recipient_id', $recipient_id)
            ->andWehere('type', $notification['type'])
            ->andWhere('reference_id', $notification['reference_id'])
            ->limit(5);
    }

    $notifcationGroups[] = $notifcationGroup;
}

我现在将继续假设 s 方法实现此分组并返回如下数组：notificationAdapterget

[
    {
        count: 12,
        items: [Note1, Note2, Note3, Note4, Note5] 
    },
    {
        count: 1,
        items: [Note1] 
    },
    {
        count: 3,
        items: [Note1, Note2, Note3] 
    }
]

由于我们的组中始终至少有一个通知，并且我们的排序更喜欢未读和新通知，因此我们可以将第一个通知用作呈现的示例。

因此，为了能够处理这些分组通知，我们需要一个新对象：

class NotificationGroup
{
    protected $notifications;

    protected $realCount;

    public function __construct(array $notifications, int $count)
    {
        $this->notifications = $notifications;
        $this->realCount = $count;
    }

    public function message()
    {
        return $this->notifications[0]->messageForNotifications($this->notifications, $this->realCount);
    }

    // forward all other calls to the first notification
    public function __call($method, $arguments)
    {
        return call_user_func_array([$this->notifications[0], $method], $arguments);
    }
}

最后，我们实际上可以将大部分内容放在一起。以下是 may 上的 get 函数的样子：NotificationManager

public function get(User $user, $limit = 20, $offset = 0) : array
{
    $groups = [];

    foreach($this->notificationAdapter->get($user->getId(), $limit, $offset) as $group)
    {
        $groups[] = new NotificationGroup($group['notifications'], $group['count']);
    }

    return $gorups;
}

最后，在可能的控制器操作中：

public function viewNotificationsAction(Request $request)
{
    $notificationManager = new NotificationManager;

    foreach($notifications = $notificationManager->get($this->getUser()) as $group)
    {
        echo $group->unread . ' | ' . $group->message() . ' - ' . $group->createdAt() . "\n"; 
    }

    // mark them as read 
    $notificationManager->markRead($notifications);
}

答案 2

答：

在通知上引入一个已读/未读变量。然后，您可以通过执行以下命令仅拉取未读通知...WHERE 状态 = SQL 中的“未读”。
你真的不能...您将需要推送该通知。您可以做的仍然是通过使用分组来聚合它们。您可能希望对独特的东西进行分组，例如新的家庭作业，因此它可能类似于...分组依据。homeworkid