From fbd04b4b80614ec35341d33a951b397c8aee1538 Mon Sep 17 00:00:00 2001 From: gzydong Date: Mon, 9 Nov 2020 22:59:25 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=9D=E5=A7=8B=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/Cache/FriendRemarkCache.php | 36 ++ app/Cache/LastMsgCache.php | 59 ++ app/Cache/UnreadTalkCache.php | 92 ++++ app/Controller/Api/V1/TalkController.php | 243 +++++++++ app/Service/TalkService.php | 667 +++++++++++++++++++++++ app/helper.php | 27 + 6 files changed, 1124 insertions(+) create mode 100644 app/Cache/FriendRemarkCache.php create mode 100644 app/Cache/LastMsgCache.php create mode 100644 app/Cache/UnreadTalkCache.php diff --git a/app/Cache/FriendRemarkCache.php b/app/Cache/FriendRemarkCache.php new file mode 100644 index 0000000..04b5c6d --- /dev/null +++ b/app/Cache/FriendRemarkCache.php @@ -0,0 +1,36 @@ +hset(self::KEY, "{$user_id}_{$friend_id}", $remark); + } + + /** + * 获取好友备注 + * + * @param int $user_id 用户ID + * @param int $friend_id 好友ID + * @return string + */ + public static function get(int $user_id, int $friend_id) + { + return redis()->hget(self::KEY, "{$user_id}_{$friend_id}") ?: ''; + } +} diff --git a/app/Cache/LastMsgCache.php b/app/Cache/LastMsgCache.php new file mode 100644 index 0000000..e645058 --- /dev/null +++ b/app/Cache/LastMsgCache.php @@ -0,0 +1,59 @@ +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; + } +} diff --git a/app/Cache/UnreadTalkCache.php b/app/Cache/UnreadTalkCache.php new file mode 100644 index 0000000..3997b92 --- /dev/null +++ b/app/Cache/UnreadTalkCache.php @@ -0,0 +1,92 @@ +get($user_id, $friend_id) + 1; + + return (bool)$this->redis()->hset($this->_key($user_id), $friend_id, $num); + } + + /** + * 获取用户指定好友的未读消息数 + * + * @param int $user_id 用户ID + * @param int $friend_id 好友ID + * @return int + */ + public function get(int $user_id, int $friend_id) + { + return (int)$this->redis()->hget($this->_key($user_id), $friend_id); + } + + /** + * 获取用户未读消息列表 + * + * @param int $user_id 用户ID + * @return mixed + */ + public function getAll(int $user_id) + { + return $this->redis()->hgetall($this->_key($user_id)); + } + + /** + * 清除用户指定好友的未读消息 + * + * @param int $user_id 用户ID + * @param int $friend_id 好友ID + * @return bool + */ + public function del(int $user_id, int $friend_id) + { + return (bool)$this->redis()->hdel($this->_key($user_id), $friend_id); + } + + /** + * 清除用户所有好友未读数 + * + * @param int $user_id + * @return bool + */ + public function delAll(int $user_id) + { + return (bool)$this->redis()->del($this->_key($user_id)); + } + + /** + * 获取缓存key + * + * @param int $user_id 用户ID + * @return string + */ + private function _key(int $user_id) + { + return self::KEY . ":{$user_id}"; + } + + /** + * 获取Redis连接 + */ + private function redis() + { + return redis(); + } +} \ No newline at end of file diff --git a/app/Controller/Api/V1/TalkController.php b/app/Controller/Api/V1/TalkController.php index b9e3332..36d98e8 100644 --- a/app/Controller/Api/V1/TalkController.php +++ b/app/Controller/Api/V1/TalkController.php @@ -2,8 +2,251 @@ namespace App\Controller\Api\V1; +use App\Cache\UnreadTalkCache; +use App\Service\TalkService; +use Hyperf\Di\Annotation\Inject; +use Hyperf\HttpServer\Annotation\Controller; +use Hyperf\HttpServer\Annotation\RequestMapping; +use Hyperf\HttpServer\Annotation\Middleware; +use Phper666\JWTAuth\Middleware\JWTAuthMiddleware; + +/** + * Class TalkController + * + * @Controller(path="/api/v1/talk") + * @Middleware(JWTAuthMiddleware::class) + * + * @package App\Controller\Api\V1 + */ class TalkController extends CController { + /** + * @Inject + * @var TalkService + */ + public $talkService; + /** + * @Inject + * @var UnreadTalkCache + */ + public $unreadTalkCache; + + /** + * 获取用户对话列表 + * + * @RequestMapping(path="list", methods="get") + */ + public function list() + { + $user_id = $this->uid(); + + // 读取用户的未读消息列表 + $result = $this->unreadTalkCache->getAll($user_id); + if ($result) { + $this->talkService->updateUnreadTalkList($user_id, $result); + } + + // 获取聊天列表 + $rows = $this->talkService->talks($user_id); + if ($rows) { + $rows = arraysSort($rows, 'updated_at'); + } + + return $this->response->success($rows); + } + + /** + * @RequestMapping(path="create", methods="post") + */ + public function create() + { + $uid = $this->uid(); + $type = $this->request->post('type', 1);//创建的类型 + $receive_id = $this->request->post('receive_id', 0);//接收者ID + + 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, '暂不属于好友关系，无法进行聊天...'); + } + } else { + if (!UserGroup::isMember($receive_id, $uid)) { + return $this->ajaxReturn(305, '暂不属于群成员，无法进行群聊 ...'); + } + } + + $result = UserChatList::addItem($uid, $receive_id, $type); + if (!$result) { + return $this->ajaxError('创建失败...'); + } + + $data = [ + 'id' => $result['id'], + 'type' => $result['type'], + 'group_id' => $result['group_id'], + 'friend_id' => $result['friend_id'], + 'is_top' => 0, + 'msg_text' => '', + 'not_disturb' => 0, + 'online' => 1, + 'name' => '', + 'remark_name' => '', + 'avatar' => '', + 'unread_num' => 0, + 'updated_at' => date('Y-m-d H:i:s') + ]; + + if ($result['type'] == 1) { + $data['unread_num'] = app('unread.talk')->get($uid, $result['friend_id']); + + $userInfo = User::where('id', $uid)->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']); + $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); + if ($records) { + $data['msg_text'] = $records['text']; + $data['updated_at'] = $records['created_at']; + } + + return $this->ajaxSuccess('创建成功...', ['talkItem' => $data]); + } + + /** + * @RequestMapping(path="delete", methods="post") + */ + public function delete() + { + + } + + /** + * @RequestMapping(path="topping", methods="post") + */ + public function topping() + { + + } + + /** + * @RequestMapping(path="set-not-disturb", methods="post") + */ + public function setNotDisturb() + { + + } + + /** + * @RequestMapping(path="update-unread-num", methods="post") + */ + public function updateUnreadNum() + { + + } + + /** + * @RequestMapping(path="revoke-records", methods="post") + */ + public function revokeChatRecords() + { + + } + + /** + * @RequestMapping(path="remove-records", methods="post") + */ + public function removeChatRecords() + { + + } + + /** + * @RequestMapping(path="forward-records", methods="post") + */ + public function forwardChatRecords() + { + + } + + /** + * @RequestMapping(path="records", methods="get") + */ + public function getChatRecords() + { + + } + + /** + * @RequestMapping(path="get-forward-records", methods="get") + */ + public function getForwardRecords() + { + + } + + /** + * @RequestMapping(path="find-chat-records", methods="get") + */ + public function findChatRecords() + { + + } + + /** + * @RequestMapping(path="search-chat-records", methods="get") + */ + public function searchChatRecords() + { + + } + + /** + * @RequestMapping(path="get-records-context", methods="get") + */ + public function getRecordsContext() + { + + } + + /** + * @RequestMapping(path="send-image", methods="post") + */ + public function sendImage() + { + + } + + /** + * @RequestMapping(path="send-code-block", methods="post") + */ + public function sendCodeBlock() + { + + } + + /** + * @RequestMapping(path="send-file", methods="post") + */ + public function sendFile() + { + + } + + /** + * @RequestMapping(path="send-emoticon", methods="post") + */ + public function sendEmoticon() + { + + } } diff --git a/app/Service/TalkService.php b/app/Service/TalkService.php index d531394..6cc7341 100644 --- a/app/Service/TalkService.php +++ b/app/Service/TalkService.php @@ -2,7 +2,674 @@ namespace App\Service; +use App\Cache\FriendRemarkCache; +use App\Cache\LastMsgCache; +use App\Model\Chat\ChatRecord; +use App\Model\Chat\ChatRecordsCode; +use App\Model\Chat\ChatRecordsFile; +use App\Model\Chat\ChatRecordsForward; +use App\Model\Chat\ChatRecordsInvite; +use App\Model\Group\UsersGroup; +use App\Model\User; +use App\Model\UsersChatList; +use App\Model\UsersFriend; +use App\Traits\PagingTrait; +use Exception; +use Hyperf\DbConnection\Db; + class TalkService extends BaseService { + use PagingTrait; + /** + * 获取用户的聊天列表 + * + * @param int $user_id 用户ID + * @return array + */ + public function talks(int $user_id) + { + $filed = [ + 'list.id', 'list.type', 'list.friend_id', 'list.group_id', 'list.updated_at', 'list.not_disturb', 'list.is_top', + 'users.avatar as user_avatar', 'users.nickname', + 'group.group_name', 'group.avatar as group_avatar' + ]; + + $rows = UsersChatList::from('users_chat_list as list') + ->leftJoin('users', 'users.id', '=', 'list.friend_id') + ->leftJoin('users_group as group', 'group.id', '=', 'list.group_id') + ->where('list.uid', $user_id) + ->where('list.status', 1) + ->orderBy('updated_at', 'desc') + ->get($filed) + ->toArray(); + + if (!$rows) { + return []; + } + + $rows = array_map(function ($item) use ($user_id) { + $data['id'] = $item['id']; + $data['type'] = $item['type']; + $data['friend_id'] = $item['friend_id']; + $data['group_id'] = $item['group_id']; + $data['name'] = '';//对方昵称/群名称 + $data['unread_num'] = 0;//未读消息数量 + $data['avatar'] = '';//默认头像 + $data['remark_name'] = '';//好友备注 + $data['msg_text'] = '......'; + $data['updated_at'] = $item['updated_at']; + $data['online'] = 0; + $data['not_disturb'] = $item['not_disturb']; + $data['is_top'] = $item['is_top']; + + if ($item['type'] == 1) { + $data['name'] = $item['nickname']; + $data['avatar'] = $item['user_avatar']; +// $data['unread_num'] = app('unread.talk')->get($user_id, $item['friend_id']); +// $data['online'] = app('client.manage')->isOnline($item['friend_id']); + + $remark = FriendRemarkCache::get($user_id, $item['friend_id']); + if ($remark) { + $data['remark_name'] = $remark; + } else { + + $info = UsersFriend::select('user1', 'user2', 'user1_remark', 'user2_remark') + ->where('user1', ($user_id < $item['friend_id']) ? $user_id : $item['friend_id']) + ->where('user2', ($user_id < $item['friend_id']) ? $item['friend_id'] : $user_id)->first(); + if ($info) { + $data['remark_name'] = ($info->user1 == $item['friend_id']) ? $info->user2_remark : $info->user1_remark; + + FriendRemarkCache::set($user_id, $item['friend_id'], $data['remark_name']); + } + } + } else { + $data['name'] = $item['group_name']; + $data['avatar'] = $item['group_avatar']; + } + + $records = LastMsgCache::get($item['type'] == 1 ? $item['friend_id'] : $item['group_id'], $item['type'] == 1 ? $user_id : 0); + + if ($records) { + $data['msg_text'] = $records['text']; + $data['updated_at'] = $records['created_at']; + } + + return $data; + }, $rows); + + return $rows; + } + + /** + * 同步未读的消息到数据库中 + * + * @param int $user_id 用户ID + * @param $data + */ + public function updateUnreadTalkList(int $user_id, $data) + { + foreach ($data as $friend_id => $num) { + UsersChatList::updateOrCreate([ + 'uid' => $user_id, + 'friend_id' => intval($friend_id), + 'type' => 1 + ], [ + 'status' => 1, + 'created_at' => date('Y-m-d H:i:s'), + 'updated_at' => date('Y-m-d H:i:s') + ]); + } + } + + /** + * 处理聊天记录信息 + * + * @param array $rows 聊天记录 + * @return array + */ + public function handleChatRecords(array $rows) + { + if (empty($rows)) { + return []; + } + + $files = $codes = $forwards = $invites = []; + foreach ($rows as $value) { + switch ($value['msg_type']) { + case 2: + $files[] = $value['id']; + break; + case 3: + $invites[] = $value['id']; + break; + case 4: + $forwards[] = $value['id']; + break; + case 5: + $codes[] = $value['id']; + break; + } + } + + // 查询聊天文件信息 + if ($files) { + $files = ChatRecordsFile::whereIn('record_id', $files)->get(['id', 'record_id', 'user_id', 'file_source', 'file_type', 'save_type', 'original_name', 'file_suffix', 'file_size', 'save_dir'])->keyBy('record_id')->toArray(); + } + + // 查询群聊邀请信息 + if ($invites) { + $invites = ChatRecordsInvite::whereIn('record_id', $invites)->get(['record_id', 'type', 'operate_user_id', 'user_ids'])->keyBy('record_id')->toArray(); + } + + // 查询代码块消息 + if ($codes) { + $codes = ChatRecordsCode::whereIn('record_id', $codes)->get(['record_id', 'code_lang', 'code'])->keyBy('record_id')->toArray(); + } + + // 查询消息转发信息 + if ($forwards) { + $forwards = ChatRecordsForward::whereIn('record_id', $forwards)->get(['record_id', 'records_id', 'text'])->keyBy('record_id')->toArray(); + } + + foreach ($rows as $k => $row) { + $rows[$k]['file'] = []; + $rows[$k]['code_block'] = []; + $rows[$k]['forward'] = []; + $rows[$k]['invite'] = []; + + switch ($row['msg_type']) { + case 1://1:文本消息 + if (!empty($rows[$k]['content'])) { + $rows[$k]['content'] = replace_url_link($row['content']); + } + break; + case 2://2:文件消息 + $rows[$k]['file'] = $files[$row['id']] ?? []; + if ($rows[$k]['file']) { + $rows[$k]['file']['file_url'] = get_media_url($rows[$k]['file']['save_dir']); + } + break; + case 3://3:入群消息/退群消息 + if (isset($invites[$row['id']])) { + $rows[$k]['invite'] = [ + 'type' => $invites[$row['id']]['type'], + 'operate_user' => [ + 'id' => $invites[$row['id']]['operate_user_id'], + 'nickname' => User::where('id', $invites[$row['id']]['operate_user_id'])->value('nickname') + ], + 'users' => [] + ]; + + if ($rows[$k]['invite']['type'] == 1 || $rows[$k]['invite']['type'] == 3) { + $rows[$k]['invite']['users'] = User::select('id', 'nickname')->whereIn('id', explode(',', $invites[$row['id']]['user_ids']))->get()->toArray(); + } else { + $rows[$k]['invite']['users'] = $rows[$k]['invite']['operate_user']; + } + } + break; + case 4://4:会话记录消息 + if (isset($forwards[$row['id']])) { + $rows[$k]['forward'] = [ + 'num' => substr_count($forwards[$row['id']]['records_id'], ',') + 1, + 'list' => json_decode($forwards[$row['id']]['text'], true) ?? [] + ]; + } + break; + case 5://5:代码块消息 + $rows[$k]['code_block'] = $codes[$row['id']] ?? []; + if ($rows[$k]['code_block']) { + $rows[$k]['code_block']['code'] = htmlspecialchars_decode($rows[$k]['code_block']['code']); + unset($rows[$k]['code_block']['record_id']); + } + break; + } + } + + unset($files, $codes, $forwards, $invites); + return $rows; + } + + /** + * 查询对话页面的历史聊天记录 + * + * @param int $user_id 用户ID + * @param int $receive_id 接收者ID（好友ID或群ID） + * @param int $source 消息来源 1:好友消息 2:群聊消息 + * @param int $record_id 上一次查询的聊天记录ID + * @param int $limit 查询数据长度 + * @param array $msg_type 消息类型 + * @return mixed + */ + public function getChatRecords(int $user_id, int $receive_id, int $source, int $record_id, $limit = 30, $msg_type = []) + { + $fields = [ + 'chat_records.id', + 'chat_records.source', + 'chat_records.msg_type', + 'chat_records.user_id', + 'chat_records.receive_id', + 'chat_records.content', + 'chat_records.is_revoke', + 'chat_records.created_at', + 'users.nickname', + 'users.avatar as avatar', + ]; + + $rowsSqlObj = ChatRecord::select($fields); + + $rowsSqlObj->leftJoin('users', 'users.id', '=', 'chat_records.user_id'); + if ($record_id) { + $rowsSqlObj->where('chat_records.id', '<', $record_id); + } + + if ($source == 1) { + $rowsSqlObj->where(function ($query) use ($user_id, $receive_id) { + $query->where([ + ['chat_records.user_id', '=', $user_id], + ['chat_records.receive_id', '=', $receive_id] + ])->orWhere([ + ['chat_records.user_id', '=', $receive_id], + ['chat_records.receive_id', '=', $user_id] + ]); + }); + } else { + $rowsSqlObj->where('chat_records.receive_id', $receive_id); + $rowsSqlObj->where('chat_records.source', $source); + } + + if ($msg_type) { + $rowsSqlObj->whereIn('chat_records.msg_type', $msg_type); + } + + //过滤用户删除记录 + $rowsSqlObj->whereNotExists(function ($query) use ($user_id) { + $prefix = config('databases.default.prefix'); + $query->select(Db::raw(1))->from('chat_records_delete'); + $query->whereRaw("{$prefix}chat_records_delete.record_id = {$prefix}chat_records.id and {$prefix}chat_records_delete.user_id = {$user_id}"); + $query->limit(1); + }); + + $rows = $rowsSqlObj->orderBy('chat_records.id', 'desc')->limit($limit)->get()->toArray(); + return $this->handleChatRecords($rows); + } + + /** + * 获取转发会话记录信息 + * + * @param int $user_id 用户ID + * @param int $record_id 聊天记录ID + * @return array + */ + public function getForwardRecords(int $user_id, int $record_id) + { + $result = ChatRecord::where('id', $record_id)->first([ + 'id', 'source', 'msg_type', 'user_id', 'receive_id', 'content', 'is_revoke', 'created_at' + ]); + + //判断是否有权限查看 + if ($result->source == 1 && ($result->user_id != $user_id && $result->receive_id != $user_id)) { + return []; + } else if ($result->source == 2 && !UsersGroup::isMember($result->receive_id, $user_id)) { + return []; + } + + $forward = ChatRecordsForward::where('record_id', $record_id)->first(); + + $fields = [ + 'chat_records.id', + 'chat_records.source', + 'chat_records.msg_type', + 'chat_records.user_id', + 'chat_records.receive_id', + 'chat_records.content', + 'chat_records.is_revoke', + 'chat_records.created_at', + 'users.nickname', + 'users.avatar as avatar', + ]; + + $rowsSqlObj = ChatRecord::select($fields); + $rowsSqlObj->leftJoin('users', 'users.id', '=', 'chat_records.user_id'); + $rowsSqlObj->whereIn('chat_records.id', explode(',', $forward->records_id)); + + return $this->handleChatRecords($rowsSqlObj->get()->toArray()); + } + + /** + * 批量删除聊天消息 + * + * @param int $user_id 用户ID + * @param int $source 消息来源 1:好友消息 2:群聊消息 + * @param int $receive_id 好友ID或者群聊ID + * @param array $record_ids 聊天记录ID + * @return bool + */ + public function removeRecords(int $user_id, int $source, int $receive_id, array $record_ids) + { + if ($source == 1) {//私聊信息 + $ids = ChatRecord::whereIn('id', $record_ids)->where(function ($query) use ($user_id, $receive_id) { + $query->where([['user_id', '=', $user_id], ['receive_id', '=', $receive_id]])->orWhere([['user_id', '=', $receive_id], ['receive_id', '=', $user_id]]); + })->where('source', 1)->pluck('id'); + } else {//群聊信息 + $ids = ChatRecord::whereIn('id', $record_ids)->where('source', 2)->pluck('id'); + } + + // 判断要删除的消息在数据库中是否存在 + if (count($ids) != count($record_ids)) { + return false; + } + + // 判读是否属于群消息并且判断是否是群成员 + if ($source == 2 && !UsersGroup::isMember($receive_id, $user_id)) { + return false; + } + + $data = array_map(function ($record_id) use ($user_id) { + return [ + 'record_id' => $record_id, + 'user_id' => $user_id, + 'created_at' => date('Y-m-d H:i:s'), + ]; + }, $ids->toArray()); + + return Db::table('chat_records_delete')->insert($data); + } + + /** + * 撤回单条聊天消息 + * + * @param int $user_id 用户ID + * @param int $record_id 聊天记录ID + * @return array + */ + public function revokeRecord(int $user_id, int $record_id) + { + $result = ChatRecord::where('id', $record_id)->first(['id', 'source', 'user_id', 'receive_id', 'created_at']); + if (!$result) return [false, '消息记录不存在']; + + //判断是否在两分钟之内撤回消息，超过2分钟不能撤回消息 + if ((time() - strtotime($result->created_at) > 120)) { + return [false, '已超过有效的撤回时间', []]; + } + + if ($result->source == 1) { + if ($result->user_id != $user_id && $result->receive_id != $user_id) { + return [false, '非法操作', []]; + } + } else if ($result->source == 2) { + if (!UsersGroup::isMember($result->receive_id, $user_id)) { + return [false, '非法操作', []]; + } + } + + $result->is_revoke = 1; + $result->save(); + + return [true, '消息已撤回', $result->toArray()]; + } + + /** + * 转发消息（单条转发） + * + * @param int $user_id 转发的用户ID + * @param int $record_id 转发消息的记录ID + * @param array $receive_ids 接受者数组 例如:[['source' => 1,'id' => 3045],['source' => 1,'id' => 3046],['source' => 1,'id' => 1658]] 二维数组 + * @return array + * @throws \Exception + */ + public function forwardRecords(int $user_id, int $record_id, array $receive_ids) + { + $result = ChatRecord::where('id', $record_id)->whereIn('msg_type', [1, 2, 5])->first(); + if (!$result) { + return []; + } + + // 根据消息类型判断用户是否有转发权限 + if ($result->source == 1) { + if ($result->user_id != $user_id && $result->receive_id != $user_id) { + return []; + } + } else if ($result->source == 2) { + if (!UsersGroup::isMember($result->receive_id, $user_id)) { + return []; + } + } + + $fileInfo = null; + $codeBlock = null; + if ($result->msg_type == 2) { + $fileInfo = ChatRecordsFile::where('record_id', $record_id)->first(); + } else if ($result->msg_type == 5) { + $codeBlock = ChatRecordsCode::where('record_id', $record_id)->first(); + } + + $insRecordIds = []; + Db::beginTransaction(); + try { + foreach ($receive_ids as $item) { + $res = ChatRecord::create([ + 'source' => $item['source'], + 'msg_type' => $result->msg_type, + 'user_id' => $user_id, + 'receive_id' => $item['id'], + 'content' => $result->content, + 'created_at' => date('Y-m-d H:i:s') + ]); + + if (!$res) { + throw new Exception('插入消息记录失败'); + } + + $insRecordIds[] = $res->id; + + if ($result->msg_type == 2) { + if (!ChatRecordsFile::create([ + 'record_id' => $res->id, + 'user_id' => $fileInfo->user_id, + 'file_source' => $fileInfo->file_source, + 'file_type' => $fileInfo->file_type, + 'save_type' => $fileInfo->save_type, + 'original_name' => $fileInfo->original_name, + 'file_suffix' => $fileInfo->file_suffix, + 'file_size' => $fileInfo->file_size, + 'save_dir' => $fileInfo->save_dir, + 'created_at' => date('Y-m-d H:i:s') + ])) { + throw new \Exception('插入文件消息记录失败'); + } + } else if ($result->msg_type == 5) { + if (!ChatRecordsCode::create([ + 'record_id' => $res->id, + 'user_id' => $user_id, + 'code_lang' => $codeBlock->code_lang, + 'code' => $codeBlock->code, + 'created_at' => date('Y-m-d H:i:s') + ])) { + throw new \Exception('插入代码消息记录失败'); + } + } + } + + Db::commit(); + } catch (Exception $e) { + Db::rollBack(); + return []; + } + + return $insRecordIds; + } + + /** + * 转发消息（多条合并转发） + * + * @param int $user_id 转发的用户ID + * @param int $receive_id 当前转发消息的所属者(好友ID或者群聊ID) + * @param int $source 消息来源 1:好友消息 2:群聊消息 + * @param array $records_ids 转发消息的记录ID + * @param array $receive_ids 接受者数组 例如:[['source' => 1,'id' => 3045],['source' => 1,'id' => 3046],['source' => 1,'id' => 1658]] 二维数组 + * @return array + */ + public function mergeForwardRecords(int $user_id, int $receive_id, int $source, $records_ids, array $receive_ids) + { + // 支持转发的消息类型 + $msg_type = [1, 2, 5]; + + $sqlObj = ChatRecord::whereIn('id', $records_ids); + + //验证是否有权限转发 + if ($source == 2) {//群聊消息 + //判断是否是群聊成员 + if (!UsersGroup::isMember($receive_id, $user_id)) { + return []; + } + + $sqlObj = $sqlObj->where('receive_id', $receive_id)->whereIn('msg_type', $msg_type)->where('source', 2)->where('is_revoke', 0); + } else {//私聊消息 + //判断是否存在好友关系 + if (!UsersFriend::isFriend($user_id, $receive_id)) { + return []; + } + + $sqlObj = $sqlObj->where(function ($query) use ($user_id, $receive_id) { + $query->where([ + ['user_id', '=', $user_id], + ['receive_id', '=', $receive_id] + ])->orWhere([ + ['user_id', '=', $receive_id], + ['receive_id', '=', $user_id] + ]); + })->whereIn('msg_type', $msg_type)->where('source', 1)->where('is_revoke', 0); + } + + $result = $sqlObj->get(); + + //判断消息记录是否存在 + if (count($result) != count($records_ids)) { + return []; + } + + $rows = ChatRecord::leftJoin('users', 'users.id', '=', 'chat_records.user_id') + ->whereIn('chat_records.id', array_slice($records_ids, 0, 3)) + ->get(['chat_records.msg_type', 'chat_records.content', 'users.nickname']); + + $jsonText = []; + foreach ($rows as $row) { + if ($row->msg_type == 1) { + $jsonText[] = [ + 'nickname' => $row->nickname, + 'text' => mb_substr(str_replace(PHP_EOL, "", $row->content), 0, 30) + ]; + } else if ($row->msg_type == 2) { + $jsonText[] = [ + 'nickname' => $row->nickname, + 'text' => '【文件消息】' + ]; + } else if ($row->msg_type == 5) { + $jsonText[] = [ + 'nickname' => $row->nickname, + 'text' => '【代码消息】' + ]; + } + } + + $jsonText = json_encode($jsonText); + + $insRecordIds = []; + Db::beginTransaction(); + try { + foreach ($receive_ids as $item) { + $res = ChatRecord::create([ + 'source' => $item['source'], + 'msg_type' => 4, + 'user_id' => $user_id, + 'receive_id' => $item['id'], + 'created_at' => date('Y-m-d H:i:s') + ]); + + if (!$res) { + throw new Exception('插入消息失败'); + } + + $insRecordIds[] = $res->id; + + if (!ChatRecordsForward::create([ + 'record_id' => $res->id, + 'user_id' => $user_id, + 'records_id' => implode(',', $records_ids), + 'text' => $jsonText, + 'created_at' => date('Y-m-d H:i:s'), + ])) { + throw new Exception('插入转发消息失败'); + } + } + + Db::commit(); + } catch (Exception $e) { + Db::rollBack(); + return []; + } + + return $insRecordIds; + } + + /** + * 关键词搜索聊天记录 + * + * @param int $user_id 用户ID + * @param int $receive_id 接收者ID(用户ID或群聊接收ID) + * @param int $source 聊天来源（1:私信 2:群聊） + * @param int $page 当前查询分页 + * @param int $page_size 分页大小 + * @param array $params 查询参数 + * @return mixed + */ + public function searchRecords(int $user_id, int $receive_id, int $source, int $page, int $page_size, array $params) + { + $fields = [ + 'chat_records.id', + 'chat_records.source', + 'chat_records.msg_type', + 'chat_records.user_id', + 'chat_records.receive_id', + 'chat_records.content', + 'chat_records.is_revoke', + 'chat_records.created_at', + + 'users.nickname', + 'users.avatar as avatar', + ]; + + $rowsSqlObj = ChatRecord::select($fields)->leftJoin('users', 'users.id', '=', 'chat_records.user_id'); + if ($source == 1) { + $rowsSqlObj->where(function ($query) use ($user_id, $receive_id) { + $query->where([ + ['chat_records.user_id', '=', $user_id], + ['chat_records.receive_id', '=', $receive_id] + ])->orWhere([ + ['chat_records.user_id', '=', $receive_id], + ['chat_records.receive_id', '=', $user_id] + ]); + }); + } else { + $rowsSqlObj->where('chat_records.receive_id', $receive_id); + $rowsSqlObj->where('chat_records.source', $source); + } + + if (isset($params['keywords'])) { + $rowsSqlObj->where('chat_records.content', 'like', "%{$params['keywords']}%"); + } + + if (isset($params['date'])) { + $rowsSqlObj->whereDate('chat_records.created_at', $params['date']); + } + + $count = $rowsSqlObj->count(); + if ($count == 0) { + return $this->getPagingRows([], 0, $page, $page_size); + } + + $rows = $rowsSqlObj->orderBy('chat_records.id', 'desc')->forPage($page, $page_size)->get()->toArray(); + return $this->getPagingRows($this->handleChatRecords($rows), $count, $page, $page_size); + } } diff --git a/app/helper.php b/app/helper.php index 21fb819..cbfad68 100644 --- a/app/helper.php +++ b/app/helper.php @@ -166,3 +166,30 @@ function create_image_name(string $ext, int $width, int $height) { return uniqid() . Str::random(18) . uniqid() . '_' . $width . 'x' . $height . '.' . $ext; } + +/** + * 替换文本中的url 为 a标签 + * + * @param string $str + * @return null|string|string[] + */ +function replace_url_link(string $str) +{ + $re = '@((https|http)?://([-\w\.]+)+(:\d+)?(/([\w/_\-.#%]*(\?\S+)?)?)?)@'; + return preg_replace_callback($re, function ($matches) { + return sprintf('%s', trim($matches[0], '"'), $matches[0]); + }, $str); +} + +/** + * 二维数组排序 + * @param array $array 数组 + * @param string $field 排序字段 + * @param int $sort 排序方式 + * @return array + */ +function arraysSort(array $array, $field, $sort = SORT_DESC) +{ + array_multisort(array_column($array, $field), $sort, $array); + return $array; +} \ No newline at end of file