60 lines
1.6 KiB
PHP
60 lines
1.6 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
namespace App\Cache;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Class LastMsgCache
|
||
|
|
* @package App\Cache
|
||
|
|
*/
|
||
|
|
class LastMsgCache
|
||
|
|
{
|
||
|
|
/**
|
||
|
|
* 用户聊天或群聊的最后一条消息hash存储的hash名
|
||
|
|
*
|
||
|
|
* @param int $sender
|
||
|
|
* @return string
|
||
|
|
*/
|
||
|
|
private static function _name($sender = 0)
|
||
|
|
{
|
||
|
|
return $sender == 0 ? 'groups:chat:last.msg' : 'friends:chat:last:msg';
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取hash key
|
||
|
|
*
|
||
|
|
* @param int $receive 接收者
|
||
|
|
* @param int $sender 发送者
|
||
|
|
* @return string
|
||
|
|
*/
|
||
|
|
private static function _key(int $receive, int $sender)
|
||
|
|
{
|
||
|
|
return $receive < $sender ? "{$receive}_{$sender}" : "{$sender}_{$receive}";
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 设置好友之间或群聊中发送的最后一条消息缓存
|
||
|
|
*
|
||
|
|
* @param array $message 消息内容
|
||
|
|
* @param int $receive 接收者
|
||
|
|
* @param int $sender 发送者(注：若聊天消息类型为群聊消息 $sender 应设置为0)
|
||
|
|
*/
|
||
|
|
public static function set(array $message, int $receive, $sender = 0)
|
||
|
|
{
|
||
|
|
redis()->hset(self::_name($sender), self::_key($receive, $sender), serialize($message));
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取好友之间或群聊中发送的最后一条消息缓存
|
||
|
|
*
|
||
|
|
* @param int $receive 接收者
|
||
|
|
* @param int $sender 发送者(注：若聊天消息类型为群聊消息 $sender 应设置为0)
|
||
|
|
* @return mixed
|
||
|
|
*/
|
||
|
|
public static function get(int $receive, $sender = 0)
|
||
|
|
{
|
||
|
|
$data = redis()->hget(self::_name($sender), self::_key($receive, $sender));
|
||
|
|
|
||
|
|
return $data ? unserialize($data) : null;
|
||
|
|
}
|
||
|
|
}
|