使用 php 和 mysql 的通知系统
Notification system using php and mysql
我想为我们学校实现一个通知系统，它是一个 php/mysql webapp，没有为 public 打开，所以它没有收到太多流量。 "daily 500-1000 visitor".
1.我最初的方法是使用 MYSQL 触发器：
我使用 Mysql AFTER INSERT trigger 将记录添加到名为 notifications 的 table。有点像。
'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);'
这种黑魔法效果很好，但我无法跟踪这个通知是否是新的 "to show count of new notifications for user"。
所以我添加了一个名为通知的页面。
通过类似
的方式检索通知
SELECT n.* from notifications n
JOIN user_class on user_class.class_id = n.class_id where user_class.user_id = X;
注意：table user_class link 用户到 class "user_id,class_id,subject_id" -除非用户是教师，否则主题为空'
现在我的下一个挑战是。
- 如何跟踪每个用户的新旧通知？
- 如何将与用户相似的通知聚合到一行中？
例如，如果 2 位用户对某事发表了评论，则不要插入新行，只需用类似 'userx and 1 other commented on hw'.
的内容更新旧行即可
非常感谢
编辑
根据下面的回答，要在行上设置 read/unread 标志，我需要为每个学生设置一行，而不仅仅是为整个 class.. 这意味着编辑触发类似
的东西
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
答案：
在通知中引入一个read/unread变量。然后，您可以通过在 sql.
你真的不能......你会想要推送那个通知。您可以做的仍然是使用 GROUP BY 聚合它们。您可能希望对一些独特的东西进行分组，比如新的家庭作业，所以它可能类似于...... GROUP BY homework.id
您可以通过制作 NotificationsRead table 来解决问题，其中包含用户 ID 和用户想要标记为已读的通知的 ID。
（这样你就可以让每个学生和老师分开。）
然后，您可以将 table 加入通知的 table，您就会知道它应该被视为旧的还是新的。
geggleto 关于第二部分的回答是正确的，你可以用 SELECT *, COUNT(*) AS counter WHERE ... GROUP BY 'type' 抓取通知然后你会知道你有多少相同类型的，你可以准备 'userx and 1 other commented on hw' 视图.
我还建议您不要存储要显示的整个文本，而是存储所需的信息，例如：from_id、class_id、类型、名称等等 - 这样如果需要，您以后可以更轻松地更改机制，并且您必须存储更少。
好吧，这个问题已经有 9 个月了，所以我不确定 OP 是否仍然需要答案，但由于有很多观点和美味的赏金，我还想加点芥末酱（德语说.. ).
在这个 post 中，我将尝试做一个关于如何开始构建通知系统的简单解释示例。
编辑： 好的，结果比我预期的要长得多。最后实在是太累了，对不起
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 Table
现在，在为 SQL 定义真正的 table 结构时，我们在数据库设计方面做出了一些决定。我将采用最简单的解决方案，看起来像这样：
+--------------+--------+---------------------------------------------------------+
| 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 创建 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 中构建通知系统的黄金标准。
通知模型
这是通知本身的示例基础模型，没有什么特别的，只是所需的属性和抽象方法 messageForNotification 和 messageForNotifications 我们期望在不同的通知类型中实现。
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);
}
}
你必须添加一个constructor, getters, setters 之类的以你自己的风格自己做事，我不会提供一个随时可用的通知系统。
通知类型
现在您可以为每种类型创建一个新的 Notification 子类。以下示例将处理评论的 点赞操作 ：
- 雷喜欢你的评论。 （1 条通知）
- 约翰和简喜欢你的评论。 （2 条通知）
- Jane、Johnny、James 和 Jenny 喜欢您的评论。 （4 条通知）
- Jonny、James 和其他 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;
}
在本示例中，notificationAdapter 属性 应包含与您的数据后端直接通信的逻辑 mysql。
正在创建通知
使用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(),
]);
}
}
在 notificationAdapter 的 add 方法后面可以是一个原始的 mysql 插入命令。使用此适配器抽象使您可以轻松地从 mysql 切换到基于文档的数据库，例如 mongodb，这对于通知系统来说是有意义的。
notificationAdapter 上的 isDoublicate 方法应该简单地检查是否已经存在具有相同 recipient、sender、type 和 reference.
我怎么指出这只是一个例子。（而且我真的必须缩短接下来的步骤，这个 post 变得非常长 -.- )
所以假设你有某种控制器，当老师上传作业时有一个动作：
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 个），这会很好地工作。但是假设用户/学生的 post 获得了大约一百个赞，而你只 select 最后 20 个通知。然后，用户只会看到 20 个人喜欢他的 post，这也是他唯一的通知。
一个 "correct" 解决方案将对数据库中已有的通知进行分组，并且 select 每个通知组只收集一些样本。比你只需要将真实计数注入你的通知消息。
您可能没有阅读下面的文字，所以让我继续摘录：
select *, count(*) as count from notifications
where recipient_id = 1
group by `type`, `reference_id`
order by created_at desc, unread desc
limit 20
现在您知道给定用户应该有哪些通知以及该组包含多少通知。
现在是糟糕的部分。我仍然找不到更好的方法来 select 在不对每个组进行查询的情况下为每个组发送有限数量的通知。 非常欢迎所有建议。
所以我做了类似的事情：
$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;
}
我现在将继续假设 notificationAdapters get 方法实现了这个分组和 returns 一个像这样的数组：
[
{
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);
}
}
最后我们实际上可以将大部分内容放在一起。 NotificationManager 上的 get 函数可能如下所示：
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);
}
对于那些正在寻找一种不使用应用程序的方法的人，您可以使用 vanilla PHP 和 MySQL 而无需使用应用程序。添加作业后，您可以添加通知。 （是的，我知道这对 SQL 注入是开放的，但为了简单起见，我使用常规 MySQL）
SQL 当有人添加作业时：
$noti_homework = "INSERT INTO homework(unread, username, recipient, topic) VALUES(true, user_who_added_hw, user_who_receives_notification, homework_name);
然后可以查看通知是否未读：
$noti_select = "SELECT FROM homework WHERE recipient='".$_SESSION['username']."' AND unread='true'";
$noti_s_result = $conn->query($noti_select);
$noti_s_row = $noti_s_result = $noti_s_result->fetch_assoc();
if ($noti_s_row['unread'] == true) {
}
最后，如果是真的，您可以回显通知。
if ($noti_s_row['unread'] == true) {
echo $noti_s_row['username'] . " has sent out the homework " . $noti_s_row['homework'] . ".";
}
给评论点赞的方法非常相似，实际上要容易得多。
$noti_like = "INSERT INTO notification_like(unread, username, recepient), VALUES(true, user_who_followed, user_who_recieves_notification);
然后您只需按照相同的模式回显行即可：
$noti_like = "INSERT INTO notification_like(unread, username, recipient), VALUES(true, user_who_followed, user_who_receives_notification);
$noti_like_select = "SELECT FROM notification_like WHERE recipient='".$_SESSION['username']."' AND unread='true'";
$noti_l_result = $conn->query($noti_like_select);
$noti_l_row = $noti_s_result = $noti_l_result->fetch_assoc();
if ($noti_l_row['unread'] == true) {
echo $noti_l_row['username'] . " has liked your topic!";
}
然后获取通知数量：
$count_like = "SELECT COUNT(*) FROM notification_like WHERE recipient='".$_SESSION['username']."' AND unread='true'";
$num_count = $count_like->fetch_row();
$count_hw = "SELECT COUNT(*) FROM homework WHERE recipient='".$_SESSION['username']."' AND unread='true'";
$num_count_hw = $count_hw->fetch_row();
使用 PHP 你可以回显两个变量，$num_count 和 $num_count_hw.
$num_count_real = $num_count[0];
$num_count_hw_real = $num_count_hw[0];
echo $num_count_real + $num_count_hw_real;
此代码的 None 已测试，仅供参考。希望这对您有所帮助:)
我想为我们学校实现一个通知系统，它是一个 php/mysql webapp，没有为 public 打开，所以它没有收到太多流量。 "daily 500-1000 visitor".
1.我最初的方法是使用 MYSQL 触发器：
我使用 Mysql AFTER INSERT trigger 将记录添加到名为 notifications 的 table。有点像。
'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);'
这种黑魔法效果很好，但我无法跟踪这个通知是否是新的 "to show count of new notifications for user"。 所以我添加了一个名为通知的页面。
通过类似
的方式检索通知SELECT n.* from notifications n
JOIN user_class on user_class.class_id = n.class_id where user_class.user_id = X;
注意：table user_class link 用户到 class "user_id,class_id,subject_id" -除非用户是教师，否则主题为空'
现在我的下一个挑战是。
- 如何跟踪每个用户的新旧通知？
- 如何将与用户相似的通知聚合到一行中？
例如，如果 2 位用户对某事发表了评论，则不要插入新行，只需用类似 'userx and 1 other commented on hw'.
的内容更新旧行即可非常感谢
编辑
根据下面的回答，要在行上设置 read/unread 标志，我需要为每个学生设置一行，而不仅仅是为整个 class.. 这意味着编辑触发类似
的东西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
答案：
在通知中引入一个read/unread变量。然后，您可以通过在 sql.
中执行 ... WHERE status = 'UNREAD' 来仅提取未读通知
你真的不能......你会想要推送那个通知。您可以做的仍然是使用 GROUP BY 聚合它们。您可能希望对一些独特的东西进行分组，比如新的家庭作业，所以它可能类似于...... GROUP BY
homework.id
您可以通过制作 NotificationsRead table 来解决问题，其中包含用户 ID 和用户想要标记为已读的通知的 ID。 （这样你就可以让每个学生和老师分开。） 然后，您可以将 table 加入通知的 table，您就会知道它应该被视为旧的还是新的。
geggleto 关于第二部分的回答是正确的，你可以用 SELECT *, COUNT(*) AS counter WHERE ... GROUP BY 'type' 抓取通知然后你会知道你有多少相同类型的，你可以准备 'userx and 1 other commented on hw' 视图.
我还建议您不要存储要显示的整个文本，而是存储所需的信息，例如：from_id、class_id、类型、名称等等 - 这样如果需要，您以后可以更轻松地更改机制，并且您必须存储更少。
好吧，这个问题已经有 9 个月了，所以我不确定 OP 是否仍然需要答案，但由于有很多观点和美味的赏金，我还想加点芥末酱（德语说.. ).
在这个 post 中，我将尝试做一个关于如何开始构建通知系统的简单解释示例。
编辑： 好的，结果比我预期的要长得多。最后实在是太累了，对不起
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 Table
现在，在为 SQL 定义真正的 table 结构时，我们在数据库设计方面做出了一些决定。我将采用最简单的解决方案，看起来像这样：
+--------------+--------+---------------------------------------------------------+
| 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 创建 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 中构建通知系统的黄金标准。
通知模型
这是通知本身的示例基础模型，没有什么特别的，只是所需的属性和抽象方法 messageForNotification 和 messageForNotifications 我们期望在不同的通知类型中实现。
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);
}
}
你必须添加一个constructor, getters, setters 之类的以你自己的风格自己做事，我不会提供一个随时可用的通知系统。
通知类型
现在您可以为每种类型创建一个新的 Notification 子类。以下示例将处理评论的 点赞操作 ：
- 雷喜欢你的评论。 （1 条通知）
- 约翰和简喜欢你的评论。 （2 条通知）
- Jane、Johnny、James 和 Jenny 喜欢您的评论。 （4 条通知）
- Jonny、James 和其他 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;
}
在本示例中，notificationAdapter 属性 应包含与您的数据后端直接通信的逻辑 mysql。
正在创建通知
使用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(),
]);
}
}
在 notificationAdapter 的 add 方法后面可以是一个原始的 mysql 插入命令。使用此适配器抽象使您可以轻松地从 mysql 切换到基于文档的数据库，例如 mongodb，这对于通知系统来说是有意义的。
notificationAdapter 上的 isDoublicate 方法应该简单地检查是否已经存在具有相同 recipient、sender、type 和 reference.
我怎么指出这只是一个例子。（而且我真的必须缩短接下来的步骤，这个 post 变得非常长 -.- )
所以假设你有某种控制器，当老师上传作业时有一个动作：
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 个），这会很好地工作。但是假设用户/学生的 post 获得了大约一百个赞，而你只 select 最后 20 个通知。然后，用户只会看到 20 个人喜欢他的 post，这也是他唯一的通知。
一个 "correct" 解决方案将对数据库中已有的通知进行分组，并且 select 每个通知组只收集一些样本。比你只需要将真实计数注入你的通知消息。
您可能没有阅读下面的文字，所以让我继续摘录：
select *, count(*) as count from notifications
where recipient_id = 1
group by `type`, `reference_id`
order by created_at desc, unread desc
limit 20
现在您知道给定用户应该有哪些通知以及该组包含多少通知。
现在是糟糕的部分。我仍然找不到更好的方法来 select 在不对每个组进行查询的情况下为每个组发送有限数量的通知。 非常欢迎所有建议。
所以我做了类似的事情：
$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;
}
我现在将继续假设 notificationAdapters get 方法实现了这个分组和 returns 一个像这样的数组：
[
{
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);
}
}
最后我们实际上可以将大部分内容放在一起。 NotificationManager 上的 get 函数可能如下所示：
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);
}
对于那些正在寻找一种不使用应用程序的方法的人，您可以使用 vanilla PHP 和 MySQL 而无需使用应用程序。添加作业后，您可以添加通知。 （是的，我知道这对 SQL 注入是开放的，但为了简单起见，我使用常规 MySQL） SQL 当有人添加作业时：
$noti_homework = "INSERT INTO homework(unread, username, recipient, topic) VALUES(true, user_who_added_hw, user_who_receives_notification, homework_name);
然后可以查看通知是否未读：
$noti_select = "SELECT FROM homework WHERE recipient='".$_SESSION['username']."' AND unread='true'";
$noti_s_result = $conn->query($noti_select);
$noti_s_row = $noti_s_result = $noti_s_result->fetch_assoc();
if ($noti_s_row['unread'] == true) {
}
最后，如果是真的，您可以回显通知。
if ($noti_s_row['unread'] == true) {
echo $noti_s_row['username'] . " has sent out the homework " . $noti_s_row['homework'] . ".";
}
给评论点赞的方法非常相似，实际上要容易得多。
$noti_like = "INSERT INTO notification_like(unread, username, recepient), VALUES(true, user_who_followed, user_who_recieves_notification);
然后您只需按照相同的模式回显行即可：
$noti_like = "INSERT INTO notification_like(unread, username, recipient), VALUES(true, user_who_followed, user_who_receives_notification);
$noti_like_select = "SELECT FROM notification_like WHERE recipient='".$_SESSION['username']."' AND unread='true'";
$noti_l_result = $conn->query($noti_like_select);
$noti_l_row = $noti_s_result = $noti_l_result->fetch_assoc();
if ($noti_l_row['unread'] == true) {
echo $noti_l_row['username'] . " has liked your topic!";
}
然后获取通知数量：
$count_like = "SELECT COUNT(*) FROM notification_like WHERE recipient='".$_SESSION['username']."' AND unread='true'";
$num_count = $count_like->fetch_row();
$count_hw = "SELECT COUNT(*) FROM homework WHERE recipient='".$_SESSION['username']."' AND unread='true'";
$num_count_hw = $count_hw->fetch_row();
使用 PHP 你可以回显两个变量，$num_count 和 $num_count_hw.
$num_count_real = $num_count[0];
$num_count_hw_real = $num_count_hw[0];
echo $num_count_real + $num_count_hw_real;
None 已测试，仅供参考。希望这对您有所帮助:)