<?php

namespace App\Models;

use Carbon\Carbon;

/**
 * App\Models\WebSocketDialogMsgRead
 *
 * @property int $id
 * @property int|null $dialog_id 对话ID
 * @property int|null $msg_id 消息ID
 * @property int|null $userid 接收会员ID
 * @property int|null $mention 是否提及（被@）
 * @property int|null $silence 是否免打扰：0否，1是
 * @property int|null $email 是否发了邮件
 * @property int|null $after 在阅读之后才添加的记录
 * @property int|null $dot 红点标记
 * @property \Illuminate\Support\Carbon|null $read_at 阅读时间
 * @property-read \App\Models\WebSocketDialogMsg|null $webSocketDialogMsg
 * @method static \Illuminate\Database\Eloquent\Builder|AbstractModel cancelAppend()
 * @method static \Illuminate\Database\Eloquent\Builder|AbstractModel cancelHidden()
 * @method static \Illuminate\Database\Eloquent\Builder|AbstractModel change($array)
 * @method static \Illuminate\Database\Eloquent\Builder|AbstractModel getKeyValue()
 * @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialogMsgRead newModelQuery()
 * @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialogMsgRead newQuery()
 * @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialogMsgRead query()
 * @method static \Illuminate\Database\Eloquent\Builder|AbstractModel remove()
 * @method static \Illuminate\Database\Eloquent\Builder|AbstractModel saveOrIgnore()
 * @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialogMsgRead whereAfter($value)
 * @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialogMsgRead whereDialogId($value)
 * @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialogMsgRead whereDot($value)
 * @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialogMsgRead whereEmail($value)
 * @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialogMsgRead whereId($value)
 * @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialogMsgRead whereMention($value)
 * @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialogMsgRead whereMsgId($value)
 * @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialogMsgRead whereReadAt($value)
 * @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialogMsgRead whereSilence($value)
 * @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialogMsgRead whereUserid($value)
 * @mixin \Eloquent
 */
class WebSocketDialogMsgRead extends AbstractModel
{
    function __construct(array $attributes = [])
    {
        parent::__construct($attributes);
        $this->timestamps = false;
    }

    /**
     * @return \Illuminate\Database\Eloquent\Relations\HasOne
     */
    public function webSocketDialogMsg(): \Illuminate\Database\Eloquent\Relations\HasOne
    {
        return $this->hasOne(WebSocketDialogMsg::class, 'id', 'msg_id');
    }

    /**
     * 强制标记成阅读
     * @param $dialogId
     * @param $userId
     * @return void
     */
    public static function forceRead($dialogId, $userId)
    {
        self::whereDialogId($dialogId)
            ->whereUserid($userId)
            ->whereNull('read_at')
            ->update(['read_at' => Carbon::now()]);
    }

    /**
     * 仅标记成阅读
     * @param $list
     * @return void
     */
    public static function onlyMarkRead($list)
    {
        $dialogMsg = [];
        /** @var WebSocketDialogMsgRead $item */
        foreach ($list as $item) {
            $item->read_at = Carbon::now();
            $item->save();
            if (isset($dialogMsg[$item->msg_id])) {
                $dialogMsg[$item->msg_id]['readNum']++;
            } else {
                $dialogMsg[$item->msg_id] = [
                    'dialogMsg' => $item->webSocketDialogMsg,
                    'readNum' => 1
                ];
            }
        }
        foreach ($dialogMsg as $item) {
            if ($item['dialogMsg']) {
                $item['dialogMsg']->increment('read', $item['readNum']);
            }
        }
    }
}