mongodb - 创建基于用户偏好的通知系统

Question

我正在尝试开发一个通知系统，但我不确定我是否正确地完成了某些部分。 为了简化案例，我将使用一些通用命名。

系统应该如何工作:

1. 注册用户可以根据从数据表网格中选择的过滤器订阅通知。 (例如，当商品数量为 X 时通知我，或者设置多个过滤器，如 set1.slug.quantity > X, some_value = false 和 some_int = 52)

我如何存储此类偏好:

示例对象

"O:8:"stdClass":2:{s:9:"set1.slug";a:1:{s:3:"$eq";s:10:"item_slug1";}s: 13:"set1.quantity";a:1:{s:4:"$gte";i:1;}}"

生成简化

$object = new \stdClass();
$object->{'set1.slug'} = ['$eq' => 'item_slug1'];
$object->{'set1.quantity'} = ['$gte' => 1];
$object = serialize($object);

它还将 user_id 和所有从表单序列化的数据附加到部分 MongoDB 原始查询。

数据库存储对象 - 为用户预定义的过滤器集。 Md 是对象的 md5 散列，以便于访问和编辑。

+----+-----------------------------------------------------------------------------------------------------------------+---------+----------------------------------+
| id |                                                     object                                                      | user_id |                md                |
+----+-----------------------------------------------------------------------------------------------------------------+---------+----------------------------------+
|  1 | O:8:"stdClass":2:{s:9:"set1.slug";a:1:{s:3:"$eq";s:10:"item_slug1";}s:13:"set1.quantity";a:1:{s:4:"$gte";i:1;}} |      22 | d5003ba3227c4db3189827329815b053 |
+----+-----------------------------------------------------------------------------------------------------------------+---------+----------------------------------+

这就是我使用它的方式 - 我对它的工作方式的看法。

我会在 API 解析器中循环调用 findByFilterMD，同时填充表 Items。

// MongoDB query ( items database )
protected function executeUserFilter($array)
{
    $list = Items::raw(function ($collection) use (&$array) {
        return $collection->find(
            $array, ["typeMap" => ['root' => 'array', 'document' => 'array']])
            ->toArray();
    });

    return $list;
}

// MySQL query - stored filters
protected function findByFilterMD($id)
{
    $user = Auth::user();
    $filter = PredefinedFilters::where('md', '=', $id)->first();
    $deserialize = unserialize($filter->object);

    $results = $this->executeUserFilter($deserialize);
    // here would probably be a notification function like pusher or onesignal
}

我知道我实现这一目标的尝试可能是完全错误的，我可能会重新发明轮子，因为有些工具可能已经做到了。

这是一个 Item MongoDB 对象示例

{
    "_id": {
        "$oid": "5c0406abdc04e7007f17f4ef"
    },
    "name": "myObject",
    "inner_ID": "0db0b19a-9c01-4c21-8e10-6879dbcb37f1",
    "some_value": false,
    "some_int": 52,
    "set1": [
        {
            "slug": "item_slug1",
            "quantity": 88,
            "extra": {
                "value": 0
            }
        },
    ],
    "set2": [
        {
            "slug": "item_slug2",
            "quantity": 88,
            "extra": {
                "value": 0
            }
        },
        {
            "slug": "item_slug3",
            "quantity": 88,
            "extra": {
                "value": 0
            }
        }
    ],
    "expires": "2018-12-02 22:21:30"
}

我的问题来了

• 这种做法合适吗？
• 通知系统应该在哪里启动？我假设它可能在我解析项目 api 的地方，然后我应该遍历用户过滤器数据并运行存储的对象查询 - 或者它应该是一个用 cron 调用的单独系统？

我愿意接受任何建议、重新设计。

Answer 1

我开发了一个类似这样的应用程序。我的方法是使用此处的 Laravel 通知: https://laravel.com/docs/5.7/notifications#creating-notifications

假设，在您的情况下，如果有人修改/创建数据，其他订阅的用户将收到通知。

1. 创建通知

php artisan make:notification UserUpdateQuantity

1. 使用户模型可通知，同时创建订阅范围

<?php

namespace App;

use Illuminate\Notifications\Notifiable;
use Illuminate\Foundation\Auth\User as Authenticatable;

class User extends Authenticatable
{
    use Notifiable;

    public function scopeSubscribe($query) 
    {
        return $query->where('subscribe', true);
    }
}

方法scopeSubscribe中的$query需要根据您的业务逻辑进行调整

1. 发送通知

$subscriber = User::subscribe()->get();
Notification::send($subscriber, new UserUpdateQuantity());

1. 创建事件和监听器

您可以在此处找到事件和监听器 https://laravel.com/docs/5.7/events

在事件服务提供者中

protected $listen = [
    'App\Events\QuantityUpdated' => [
        'App\Listeners\SendUpdateQuantiryNotification',
    ],
];

然后运行命令php artisan event:generate

1. 事件监听器

在事件监听器中，我们发送通知

public function handle(QuantityUpdated $event)
{
    $subscriber = User::subscribe()->get();
    Notification::send($subscriber, new UserUpdateQuantity());
}

1. Eloquent 事件

在你的 Eloquent 模型上添加事件，当有人更新数量时，它会触发事件，监听器会向订阅用户发送通知

// In your model
protected $dispatchesEvents = [
    'updated' => App\Events\QuantityUpdated::class
];