hyperf-chat/app/Cache/UnreadTalkCache.php

<?php

namespace App\Cache;

use App\Cache\Repository\HashRedis;
use App\Traits\StaticInstance;

/**
 * 私信消息未读数 - 缓存助手
 *
 * @package App\Cache
 */
class UnreadTalkCache extends HashRedis
{
    use StaticInstance;

    public $name = 'unread-talk';

    /**
     * 消息未读数自增
     *
     * @param int $sender  发送者ID
     * @param int $receive 接收者ID
     */
    public function increment(int $sender, int $receive)
    {
        $this->incr($this->flag($sender, $receive), 1);
    }

    /**
     * 读取消息未读数
     *
     * @param int $sender  发送者ID
     * @param int $receive 接收者ID
     * @return int
     */
    public function read(int $sender, int $receive): int
    {
        return (int)$this->get($this->flag($sender, $receive));
    }

    /**
     * 消息未读数清空
     *
     * @param int $sender  发送者ID
     * @param int $receive 接收者ID
     */
    public function reset(int $sender, int $receive)
    {
        $this->rem($this->flag($sender, $receive));
    }

    /**
     * 获取 Hash 成员 key
     *
     * @param int $sender
     * @param int $receive
     * @return string
     */
    public function flag(int $sender, int $receive): string
    {
        return sprintf("%s_%s", $sender, $receive);
    }

    /**
     * 读取指定用户的未读消息列表
     *
     * @param int $user_id 用户ID
     * @return array
     */
    public function reads(int $user_id): array
    {
        $iterator = null;
        $arr      = [];
        while ($elements = $this->redis()->hscan($this->getCacheKey(), $iterator, '*_' . $user_id, 20)) {
            foreach ($elements as $key => $value) {
                $arr[explode('_', $key)[0]] = $value;
            }
        }

        return $arr;
    }
}