chenchong
/
hyperf-chat
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

初始化

main
gzydong 2020-11-11 22:09:23 +08:00
parent fbd04b4b80
commit 8dc7809715
1 changed files with 104 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

125
app/Controller/Api/V1/TalkController.php
View File

@ -2,7 +2,12 @@
namespace App\Controller\Api\V1;
use App\Cache\LastMsgCache;
use App\Cache\UnreadTalkCache;
use App\Model\User;
use App\Model\UsersChatList;
use App\Model\UsersFriend;
use App\Model\Group\UsersGroup;
use App\Service\TalkService;
use Hyperf\Di\Annotation\Inject;
use Hyperf\HttpServer\Annotation\Controller;
@ -58,31 +63,35 @@ class TalkController extends CController
}
/**
* 新增对话列表
*
* @RequestMapping(path="create", methods="post")
*
* @param UnreadTalkCache $unreadTalkCache
* @return \Psr\Http\Message\ResponseInterface
*/
public function create()
public function create(UnreadTalkCache $unreadTalkCache)
{
$uid = $this->uid();
$type = $this->request->post('type', 1);//创建的类型
$receive_id = $this->request->post('receive_id', 0);//接收者ID
$params = $this->request->inputs(['type', 'receive_id']);
$this->validate($params, [
'type' => 'required|in:1,2',
'receive_id' => 'present|integer|min:0'
]);
if (!in_array($type, [1, 2]) || !check_int($receive_id)) {
return $this->ajaxParamError();
}
if ($type == 1) {
if (!UserFriends::isFriend($uid, $receive_id)) {
return $this->ajaxReturn(305, '暂不属于好友关系，无法进行聊天...');
$user_id = $this->uid();
if ($params['type'] == 1) {
if (!UsersFriend::isFriend($user_id, $params['receive_id'])) {
return $this->response->fail('暂不属于好友关系，无法进行聊天...');
}
} else {
if (!UserGroup::isMember($receive_id, $uid)) {
return $this->ajaxReturn(305, '暂不属于群成员，无法进行群聊 ...');
if (!UsersGroup::isMember($params['receive_id'], $user_id)) {
return $this->response->fail('暂不属于群成员，无法进行群聊...');
}
}
$result = UserChatList::addItem($uid, $receive_id, $type);
$result = UsersChatList::addItem($user_id, $params['receive_id'], $params['type']);
if (!$result) {
return $this->ajaxError('创建失败...');
return $this->response->fail('创建失败...');
}
$data = [
@ -102,56 +111,106 @@ class TalkController extends CController
];
if ($result['type'] == 1) {
$data['unread_num'] = app('unread.talk')->get($uid, $result['friend_id']);
$data['unread_num'] = $unreadTalkCache->get($user_id, $result['friend_id']);
$userInfo = User::where('id', $uid)->first(['nickname', 'avatar']);
$userInfo = User::where('id', $user_id)->first(['nickname', 'avatar']);
$data['name'] = $userInfo->nickname;
$data['avatar'] = $userInfo->avatar;
} else if ($result['type'] == 2) {
$groupInfo = UserGroup::where('id', $result['group_id'])->first(['group_name', 'avatar']);
$groupInfo = UsersGroup::where('id', $result['group_id'])->first(['group_name', 'avatar']);
$data['name'] = $groupInfo->group_name;
$data['avatar'] = $groupInfo->avatar;
}
$records = LastMsgCache::get($result['type'] == 1 ? $result['friend_id'] : $result['group_id'], $result['type'] == 1 ? $uid : 0);
$records = LastMsgCache::get($result['type'] == 1 ? $result['friend_id'] : $result['group_id'], $result['type'] == 1 ? $user_id : 0);
if ($records) {
$data['msg_text'] = $records['text'];
$data['updated_at'] = $records['created_at'];
}
return $this->ajaxSuccess('创建成功...', ['talkItem' => $data]);
return $this->response->success(['talkItem' => $data]);
}
/**
* 删除对话列表
*
* @RequestMapping(path="delete", methods="post")
*/
public function delete()
{
$params = $this->request->inputs(['list_id']);
$this->validate($params, [
'list_id' => 'required|integer|min:0'
]);
return UsersChatList::delItem($this->uid(), $params['list_id'])
? $this->response->success([], '对话列表删除成功...')
: $this->response->fail('对话列表删除失败...');
}
/**
* 对话列表置顶
*
* @RequestMapping(path="topping", methods="post")
*/
public function topping()
{
$params = $this->request->inputs(['list_id', 'type']);
$this->validate($params, [
'list_id' => 'required|integer|min:0',
'type' => 'required|in:1,2',
]);
return UsersChatList::topItem($this->uid(), $params['list_id'], $params['type'] == 1)
? $this->response->success([], '对话列表置顶成功...')
: $this->response->fail('对话列表置顶失败...');
}
/**
* 设置消息免打扰状态
*
* @RequestMapping(path="set-not-disturb", methods="post")
*/
public function setNotDisturb()
{
$params = $this->request->inputs(['list_id', 'type', 'not_disturb']);
$this->validate($params, [
'receive_id' => 'required|integer|min:0',
'type' => 'required|in:1,2',
'not_disturb' => 'required|in:0,1',
]);
$isTrue = UsersChatList::notDisturbItem($this->uid(), $params['receive_id'], $params['type'], $params['not_disturb']);
return $isTrue
? $this->response->success([], '对话列表置顶成功...')
: $this->response->fail('对话列表置顶失败...');
}
/**
* 更新对话列表未读数
*
* @RequestMapping(path="update-unread-num", methods="post")
*
* @param UnreadTalkCache $unreadTalkCache
* @return \Psr\Http\Message\ResponseInterface
*/
public function updateUnreadNum()
public function updateUnreadNum(UnreadTalkCache $unreadTalkCache)
{
$params = $this->request->inputs(['receive', 'type']);
$this->validate($params, [
'receive' => 'required|integer|min:0',
'type' => 'required|integer|min:0'
]);
$user_id = $this->uid();
// 设置好友消息未读数
if ($params['type'] == 1) {
$unreadTalkCache->del($user_id, $params['receive']);
}
return $this->response->success([], 'success');
}
/**
@ -159,15 +218,39 @@ class TalkController extends CController
*/
public function revokeChatRecords()
{
$user_id = $this->uid();
$record_id = $this->request->get('record_id', 0);
[$isTrue, $message, $data] = $this->talkService->revokeRecord($user_id, $record_id);
return $isTrue ? $this->ajaxSuccess($message) : $this->ajaxError($message);
}
/**
* 删除聊天记录
*
* @RequestMapping(path="remove-records", methods="post")
*/
public function removeChatRecords()
{
$user_id = $this->uid();
//消息来源（1：好友消息 2：群聊消息）
$source = $this->request->post('source', 0);
//接收者ID（好友ID或者群聊ID）
$receive_id = $this->request->post('receive_id', 0);
//消息ID
$record_ids = explode(',', $this->request->get('record_id', ''));
if (!in_array($source, [1, 2]) || !check_int($receive_id) || !check_ids($record_ids)) {
return $this->ajaxParamError();
}
$isTrue = $this->talkService->removeRecords($user_id, $source, $receive_id, $record_ids);
return $isTrue ? $this->ajaxSuccess('删除成功...') : $this->ajaxError('删除失败...');
}
/**