chat_producer/app/JsonRpc/ChatService.php

<?php

namespace App\JsonRpc;

use App\Model\ChatFriends;
use App\Model\ChatGroups;
use App\Model\ChatGroupsMember;
use App\Model\ChatRecords;
use App\Model\ChatTopic;
use App\Model\ChatTopicsReply;

use App\Model\ChatTopicClass;
use App\Model\User;
use App\Model\GroupMemberImp;
use App\Model\GroupImp;
use App\Model\GroupTalkImp;


use App\Tools\PublicData;
use App\Tools\Result;
use Hyperf\DbConnection\Db;
use Hyperf\RpcServer\Annotation\RpcService;
use Hyperf\Context\ApplicationContext as ContextApplicationContext;
use Hyperf\Amqp\Producer;

use App\Amqp\Producer\MqProducer;

#[RpcService(name: "ChatService", protocol: "jsonrpc-http", server: "jsonrpc-http")]
class ChatService implements ChatServiceInterface
{
    /**
     * 获取用户信息
     * @param array $data
     * @return array
     */
    public function getFriendInfo(array $data): array
    {
        $result = ChatFriends::where('friend_id', $data['friend_id'])
            ->where('user_id', $data['user_id'])
            ->select(
                'chat_friends.*',
                'user.user_name',
                'user.mobile',
                'user.nickname',
                'user.avatar'
            )
            ->leftJoin('user', 'user.id', '=', 'chat_friends.friend_id')
            ->first();

        return Result::success($result);
    }
    /**
     * 搜索好友
     * @param array $data
     * @return array
     */
    public function searchFriend(array $data): array
    {
        $keyword = $data['keyword'];
        $userId = $data['user_id'];

        $result = User::leftJoin('chat_friends', function ($join) use ($userId) {
            $join->on('user.id', '=', 'chat_friends.friend_id')
                ->where('chat_friends.user_id', '=', $userId);
        })
            ->where(function ($query) use ($data) {
                $query->where('user.user_name', 'like', '%' . $data['keyword'] . '%')
                    ->orWhere('user.nickname', 'like', '%' . $data['keyword'] . '%')
                    ->orWhere('user.mobile', 'like', '%' . $data['keyword'] . '%');
            })
            ->where('user.id', '<>', $userId)
            ->where('user.type_id', '<>', '20000')
            ->select('user.*', 'chat_friends.remark as remark', 'chat_friends.id as isfriend')
            // ->select('user.*', 'chat_friends.friend_id')
            ->get();

        return Result::success($result);

        if ($result) {
            return Result::success($result);
        } else {
            return Result::error('没有找到相关好友');
        }
    }
    /**
     * 添加申请
     * @param array $data
     * @return array
     */
    public function addFriend(array $data): array
    {
        Db::beginTransaction();
        try {
            // 检查是否存在相同的记录
            $existingRecord = ChatFriends::where([
                'user_id' => $data['user_id'],
                'friend_id' => $data['friend_id'],
            ])->first();

            if ($existingRecord) {
                Db::rollBack();
                if ($existingRecord->status == 1) {
                    return Result::error("好友申请已存在", 0);
                } elseif ($existingRecord->status == 2) {
                    return Result::error("已经是好友关系", 0);
                }
            }

            $result = ChatFriends::insertGetId($data);
            Db::commit();
        } catch (\Throwable $ex) {
            Db::rollBack();
            var_dump($ex->getMessage());
            return Result::error("添加好友申请失败", 0);
        }
        return Result::success("添加成功");
    }

    /**
     * 好友列表
     * @param array $data
     * @return array
     */
    public function getFriendsList(array $data): array
    {
        var_dump($data);
        $result = ChatFriends::leftJoin('user', 'user.id', '=', 'chat_friends.friend_id')
            ->select(
                'chat_friends.*',
                'user.user_name',
                'user.mobile',
                'user.nickname',
                'user.avatar'
            )
            ->where([
                ['user_id', $data['user_id']],
                ['chat_friends.status', $data['status']], // 明确指定 chat_friends 表中的 status 列
            ])
            ->get();
        return Result::success($result);
    }

    /**
     * 好友列表
     * @param array $data
     * @return array
     */
    public function getFriendsApplyList(array $data): array
    {
        var_dump($data);
        $result = ChatFriends::leftJoin('user', 'user.id', '=', 'chat_friends.user_id')
            ->select(
                'chat_friends.*',
                'user.user_name',
                'user.mobile',
                'user.nickname',
                'user.avatar'
            )
            ->where([
                ['friend_id', $data['friend_id']],
                ['chat_friends.status', $data['status']], // 明确指定 chat_friends 表中的 status 列
            ])
            ->get();
        return Result::success($result);
    }
    /**
     * 更新申请
     * @param array $data
     * @return array
     */
    public function applyFriend(array $data): array
    {
        $status = $data['status'];
        //判断同意还是不同意
        if ($status == 2) {
            Db::beginTransaction();
            try {
                $where = [
                    'id' => $data['id'],
                    'status' => 1,
                ];
                $fr = ChatFriends::where($where)->first();
                if (empty($fr)) {
                    Db::rollBack();
                    return Result::error("好友申请记录不存在,已经是好友了", 0);
                }
                $data['status'] = $status;
                $data['applied_at'] = date("Y-m-d H:i:s"); //好友审核时间操作人friend_id
                unset($data['user_id']);
                ChatFriends::where($where)->update($data);
                Db::table('chat_friends')
                    ->updateOrInsert(

                        [
                            'user_id' => $fr['friend_id'],
                            'friend_id' => $fr['user_id'],
                        ],
                        [
                            'status' => $status,
                        ]
                    );

                // 给对方发送通知
                $friendId = $fr['user_id'];
                $userId = $fr['friend_id'];
                $content = "你们已经成为好友了" . date("Y-m-d H:i:s");
                $chatRecordsData = [[
                    'user_id' => $userId,
                    'receiver_id' => $friendId,
                    'content' => $content,
                    'msg_type' => 1,
                    'is_read' => 1,
                    'talk_type' => 1,
                    'action' => 'said',

                ], [
                    'user_id' => $friendId,
                    'receiver_id' => $userId,
                    'content' => $content,
                    'msg_type' => 1,
                    'is_read' => 1,
                    'talk_type' => 1,
                    'action' => 'recieved',

                ]];
                ChatRecords::insert($chatRecordsData);
                Db::commit();
            } catch (\Throwable $ex) {
                Db::rollBack();
                var_dump($ex->getMessage());
                return Result::error("同意添加为好友失败", 0);
            }
            return Result::success(['添加成功']);
        } else if ($status == 4) { //拒绝
            Db::beginTransaction();
            try {
                $where1 = [
                    'id' => $data['id'],
                ];
                $deletedRows = ChatFriends::where($where1)->delete();
                if ($deletedRows > 0) {
                    Db::commit();
                } else {
                    // 处理记录不存在的情况
                    Db::rollBack();
                    throw new \Exception('记录不存在');
                }
            } catch (\Throwable $ex) {
                Db::rollBack();
                var_dump($ex->getMessage());
                return Result::error("拒绝添加好友失败", 0);
            }
            return Result::success(['已经拒绝']);
        }
    }

    /**
     * 删除好友
     * @param array $data
     * @return array
     */
    public function delFriend(array $data): array
    {
        Db::beginTransaction();
        try {
            $where = [
                'user_id' => $data['user_id'],
                'friend_id' => $data['friend_id'],
            ];
            $orwhere = [
                'user_id' => $data['friend_id'],
                'friend_id' => $data['user_id'],
            ];

            // 使用闭包来确保正确的 OR 关系
            $result = ChatFriends::where(function ($query) use ($where) {
                $query->where($where);
            })
                ->orWhere(function ($query) use ($orwhere) {
                    $query->where($orwhere);
                })
                ->delete();

            var_dump($result, '-0------------------');

            $wherechat = [
                'user_id' => $data['user_id'],
                'receiver_id' => $data['friend_id'],
            ];
            $orwherechat = [
                'user_id' => $data['friend_id'],
                'receiver_id' => $data['user_id'],
            ];

            // 使用闭包来确保正确的 OR 关系
            ChatRecords::where(function ($query) use ($wherechat) {
                $query->where($wherechat);
            })
                ->orWhere(function ($query) use ($orwherechat) {
                    $query->where($orwherechat);
                })
                ->delete();

            Db::commit();
            return Result::success("删除成功");
        } catch (\Exception $e) {
            Db::rollback();
            return Result::error($e->getMessage());
        }
    }
    /**
     * 是否好友
     * @param array $data
     * @return array
     */
    public function isFriend(array $data): array
    {
        $where = [
            'user_id' => $data['user_id'],
            'friend_id' => $data['friend_id'],
        ];
        $result = ChatFriends::where($where)->first();
        if ($result) {
            return Result::success(true);
        } else {
            return Result::error('不是好友');
        }
    }

    /**
     * 添加聊天内容
     * @param array $data
     * @return array
     */
    public function addChatRecords(array $data): array
    {
        Db::beginTransaction();
        try {
            //添加会话内容
            $ChatRecordsData = [[
                'msg_type' => $data['msg_type'] ?? 0,
                'user_id' => $data['user_id'] ?? 0,
                'is_read' => $data['is_read'] ?? 0,
                'talk_type' => $data['talk_type'] ?? 0,
                'action' => $data['action'] ?? 0,
                'group_receiver_id' => $data['group_receiver_id'] ?? 0,
                'content' => $data['content'] ?? '',
                'receiver_id' => $data['receiver_id'] ?? '',
            ]];
            ChatRecords::insert($ChatRecordsData);
            Db::commit();
        } catch (\Throwable $ex) {
            Db::rollBack();
            var_dump($ex->getMessage());
            return Result::error("存储消息失败", 0);
        }
        return Result::success([]);
    }

    /**
     * 修改好友备注
     * @param array $data
     * @return array
     */
    public function updateFriend(array $data): array
    {
        $result = ChatFriends::where([
            'user_id' => $data['user_id'],
            'friend_id' => $data['friend_id'],
            'status' => 2,
        ])->update(['remark' => $data['remark']]);
        if ($result) {
            return Result::success('修改成功');
        } else {
            return Result::error('修改失败');
        }
    }
    /**
     * 会话列表
     * @param array $data
     * @return array
     */
    public function getConversation(array $data): array
    {
        $userId = $data['user_id'];
        $unreadMessages = ChatRecords::where('user_id', $userId)
            ->where('is_read', 0)
            // ->where('action', 'recieved')
            ->leftJoin('user', 'chat_records.receiver_id', '=', 'user.id')
            ->leftJoin('chat_groups', 'chat_records.receiver_id', '=', 'chat_groups.id')
            ->select(
                'receiver_id',
                DB::raw('COUNT(receiver_id) AS num'),
                DB::raw('MAX(chat_records.id) AS max_id'),
                'user.user_name as user_name',
                'user.avatar as avatar',
                'user.mobile as mobile',
                'chat_groups.group_name as group_name'
            )
            ->groupBy('receiver_id')
            ->orderBy(DB::raw('MAX(chat_records.id)'), 'desc')
            ->get();

        // 查询已读消息，并将 num 字段设置为 0
        $readMessages = ChatRecords::where('user_id', $userId)
            ->where('is_read', 1)
            // ->where('action', 'recieved')
            ->leftJoin('user', 'chat_records.receiver_id', '=', 'user.id')
            ->leftJoin('chat_groups', 'chat_records.receiver_id', '=', 'chat_groups.id')
            ->select(
                'receiver_id',
                DB::raw('0 AS num'),
                DB::raw('MAX(chat_records.id) AS max_id'),
                'user.user_name as user_name',
                'user.avatar as avatar',
                'user.mobile as mobile',
                'chat_groups.group_name as group_name'
            )
            ->groupBy('receiver_id')
            ->orderBy(DB::raw('MAX(chat_records.id)'), 'desc')
            ->get();

        // 合并未读消息和已读消息
        // $allMessages = array_merge($unreadMessages->toArray(), $readMessages->toArray());
        // 使用关联数组去重，并优先保留未读消息
        $allMessages = [];
        foreach ($unreadMessages as $message) {
            $allMessages[$message['receiver_id']] = $message->toArray();
        }

        foreach ($readMessages as $message) {
            if (strlen($message['receiver_id']) === 18) {
            } else {
                // $allMessages[$message['receiver_id']] = $message->toArray();
            }
            if (!isset($allMessages[$message['receiver_id']])) {
                $allMessages[$message['receiver_id']] = $message->toArray();
            }
        }

        // var_dump($allMessages);
        // 处理结果，判断是否是群聊
        $formattedMessages = [];
        foreach ($allMessages as $message) {
            $formattedMessage = [
                'receiver_id' => $message['receiver_id'],
                'num' => $message['num'],
                'max_id' => $message['max_id'],
                'user_name' => $message['user_name'],
                'avatar' => $message['avatar'],
                'mobile' => $message['mobile'],
                'group_name' => $message['group_name'],
            ];

            if (strlen($message['receiver_id']) === 18) { // 判断是否是 UUID
                $formattedMessage['type'] = 'group';
                $formattedMessage['name'] = $message['group_name'];
                $formattedMessage['is_group'] = 1;
            } else {
                $formattedMessage['type'] = 'user';
                $formattedMessage['name'] = $message['user_name'];
                $formattedMessage['is_group'] = 0;
            }

            $formattedMessages[] = $formattedMessage;
        }

        if (!empty($formattedMessages)) {
            return Result::success($formattedMessages);
        } else {
            return Result::error('没有消息');
        }
    }
    /**
     * 获取聊天记录
     * @param array $data
     * @return array
     */
    public function getChatRecords(array $data): array
    {
        var_dump('222222');
        Db::beginTransaction();
        try {
            $userId = $data['user_id'];
            $friendId = $data['friend_id'];
            $result = ChatRecords::where(function ($query) use ($userId, $friendId) {
                $query->where('user_id', $userId)->where('receiver_id', $friendId);
            })
                // ->orWhere(function ($query) use ($userId, $friendId) {
                //     $query->where('user_id', $friendId)->where('receiver_id', $userId);
                // })
                ->leftJoin('user as u1', 'chat_records.user_id', '=', 'u1.id')
                ->leftJoin('user as u2', 'chat_records.receiver_id', '=', 'u2.id')
                ->select('chat_records.*', 'u1.user_name as user_id_name', 'u1.avatar as user_avatar', 'u2.user_name as receiver_id_name', 'u2.avatar as receiver_avatar')
                ->orderBy('id', 'asc')->paginate(100, ['*'], 'page', $data['page'] ?? 1);
            //更新聊天记录已读
            ChatRecords::where('user_id', $userId)
                ->where('receiver_id', $friendId)
                ->where('is_read', 0)
                ->where('talk_type', 1)
                ->update(['is_read' => 1]);
            Db::commit();
        } catch (\Throwable $ex) {
            Db::rollBack();
            var_dump($ex->getMessage());
            return Result::error("获取聊天记录失败", 0);
        }
        if ($result) {
            return Result::success($result);
        } else {
            return Result::error('没有聊天记录');
        }
    }
    /**
     * 获取群聊天记录
     * @param array $data
     * @return array
     */
    public function getGroupChatRecords(array $data): array
    {
        Db::beginTransaction();
        try {
            $userId = $data['user_id'];
            $group_id = $data['group_id'];
            $result = ChatRecords::where('receiver_id', $group_id)
                ->where('user_id', $userId)
                ->leftJoin('user as u1', 'chat_records.user_id', '=', 'u1.id')
                ->leftJoin('user as u2', 'chat_records.group_receiver_id', '=', 'u2.id')
                ->select('chat_records.*', 'u1.user_name as user_id_name', 'u1.avatar as user_avatar', 'u2.user_name as receiver_id_name', 'u2.avatar as receiver_avatar')
                ->orderBy('id', 'asc')->paginate(100, ['*'], 'page', $data['page'] ?? 1);
            //更新群聊天记录
            ChatRecords::where('receiver_id', $group_id)
                ->where('user_id', $userId)
                ->update(['is_read' => 1]);
            Db::commit();
        } catch (\Throwable $ex) {
            Db::rollBack();
            var_dump($ex->getMessage());
            return Result::error("获取群聊天记录失败", 0);
        }
        if ($result) {
            return Result::success($result);
        } else {
            return Result::error('没有群消息');
        }
    }
    /**
     * 群组 - 创建群
     * @param array $data
     * @return array
     */
    public function addGroup(array $data): array
    {
        Db::beginTransaction();
        try {
            //创建群
            $groupData = [
                'id' => PublicData::uuid(),
                'creator_id' => $data['user_id'],
                'group_name' => $data['group_name'],
                'avatar' => $data['avatar'] ?? '',
                'profile' => $data['profile'] ?? '',
            ];
            ChatGroups::insert($groupData);
            //创建群用户
            $groupMemberData = [];
            $groupChatData = [];
            if ($data['group_member']) {
                foreach ($data['group_member'] as $key => $val) {
                    $groupMemberData[$key] = [
                        'id' => PublicData::uuid(),
                        'group_id' => $groupData['id'],
                        'user_id' => $val,
                        'leader' => $data['user_id'] == $val ? 2 : 0,
                    ];

                    $groupChatData[$key] = [
                        'user_id' => $val,
                        'receiver_id' => $groupData['id'],
                        'content' => '创建群' . Date('Y-m-d H:i:s'),
                        'msg_type' => 1,
                        'is_read' => 0,
                        'talk_type' => 2,
                        'action' => 'recieved',
                        'group_receiver_id' => $data['user_id'],
                    ];
                }
            }
            ChatGroupsMember::insert($groupMemberData);
            //插入一条消息
            ChatRecords::insert($groupChatData);
            Db::commit();
        } catch (\Throwable $ex) {
            Db::rollBack();
            var_dump($ex->getMessage());
            return Result::error("创建群失败", 0);
        }
        return Result::success([]);
    }
    /**
     * 群组 - 加入群
     * @param array $data
     * @return array
     */
    public function addGroupMember(array $data): array
    {
        $result = ChatGroupsMember::where(['group_id' => $data['group_id'], 'user_id' => $data['user_id']])->update(['leader' => 2]);

        $groupChatData = [
            'user_id' => $data['user_id'],
            'receiver_id' => $data['group_id'],
            'content' => '加入群' . Date('Y-m-d H:i:s'),
            'msg_type' => 1,
            'is_read' => 0,
            'talk_type' => 2,
            'action' => 'recieved',
            'group_receiver_id' => $data['user_id'],
        ];
        ChatRecords::insert($groupChatData);

        if ($result) {
            return Result::success('修改成功');
        } else {
            return Result::error('修改失败');
        }
    }
    /**
     * 群组 - 群信息
     * @param array $data
     * @return array
     */
    public function getGroupInfo(array $data): array
    {
        $result = ChatGroups::where(['chat_groups.id' => $data['group_id']])
            ->join('user', 'chat_groups.creator_id', '=', 'user.id')
            ->select('chat_groups.*', 'user.user_name as user_name', 'user.avatar as avatar')
            ->first();
        return Result::success($result);
    }
    /**
     * 群组 - 删除群
     * @param array $data
     * @return array
     */
    public function delGroup(array $data): array
    {
        Db::beginTransaction();
        try {
            $groupMember = ChatGroupsMember::where(['group_id' => $data['group_id']])->delete();
            $result = ChatGroups::where(['id' => $data['group_id']])->delete();
            $result = ChatRecords::where(['receiver_id' => $data['group_id']])->delete();
            //群聊记录
            Db::commit();
        } catch (\Throwable $ex) {
            Db::rollBack();
            var_dump($ex->getMessage());
            return Result::error("删除群失败", 0);
        }

        if ($result) {
            return Result::success('删除成功');
        } else {
            return Result::error('删除失败');
        }
    }
    /**
     * 群组 - 退出群
     * @param array $data
     * @return array
     */
    public function quitGroup(array $data): array
    {
        $result = ChatGroupsMember::where(['group_id' => $data['group_id'], 'user_id' => $data['user_id']])->delete();
        ChatRecords::where(['receiver_id' => $data['group_id'], 'user_id' => $data['user_id']])->delete();

        if ($result) {
            return Result::success('退出成功');
        } else {
            return Result::error('退出失败');
        }
    }
    /**
     * 群组 - 我的群
     * @param array $data
     * @return array
     */
    public function getGroupList(array $data): array
    {
        $result = ChatGroupsMember::where(['user_id' => $data['user_id']])
            ->leftJoin('chat_groups', 'chat_groups_members.group_id', '=', 'chat_groups.id')
            ->select('chat_groups.*', 'chat_groups_members.group_id as group_id')
            ->orderBy('chat_groups.id', 'desc')
            ->paginate(100, ['*'], 'page', $data['page'] ?? 1);
        return Result::success($result);
    }
    /**
     * 群组 - 删除群成员
     * @param array $data
     * @return array
     */
    public function delGroupMembers(array $data): array
    {
        $result = ChatGroupsMember::where(['group_id' => $data['group_id'], 'user_id' => $data['user_id']])->delete();
        ChatRecords::where(['receiver_id' => $data['group_id'], 'user_id' => $data['user_id']])->delete();
        if ($result) {
            return Result::success('删除成功');
        } else {
            return Result::error('删除失败');
        }
    }
    /**
     * 群组 - 更新群
     * @param array $data
     * @return array
     */
    public function updateGroup(array $data): array
    {
        // 提取需要的字段
        $groupId = $data['group_id'];
        $groupName = $data['group_name'] ?? null;
        $profile = $data['profile'] ?? null;
        $avatar = $data['avatar'] ?? null;
        // 查询群组
        $group = ChatGroups::find($groupId);
        if (!$group) {
            return Result::error('群组不存在');
        }
        // 更新群组信息
        if ($groupName !== null) {
            $group->group_name = $groupName;
        }
        if ($profile !== null) {
            $group->profile = $profile;
        }
        if ($avatar !== null) {
            $group->avatar = $avatar;
        }
        // 保存更改
        if ($group->save()) {
            return Result::success($group->toArray());
        } else {
            return Result::error('更新群组信息失败');
        }
    }
    /**
     * 群组 - 删除群
     * @param array $data
     * @return array
     */
    public function deleteGroup(array $data): array
    {
        $result = ChatGroups::where(['id' => $data['group_id']])->delete();
        if ($result) {
            return Result::success('删除成功');
        } else {
            return Result::error('删除失败');
        }
    }
    /**
     * 群组 - 群用户列表
     * @param array $data
     * @return array
     */
    public function getGroupMembers(array $data): array
    {
        $groupMember = ChatGroupsMember::where(['group_id' => $data['group_id']])
            ->leftJoin('user as u1', 'chat_groups_members.user_id', '=', 'u1.id')
            ->leftJoin('chat_groups as c1', 'c1.id', '=', 'chat_groups_members.group_id')
            ->select('chat_groups_members.*', 'u1.user_name', 'u1.avatar', 'c1.group_name as group_name')
            ->orderBy('id', 'desc')
            ->get();
        return Result::success($groupMember);
    }

    /**
     * 群组 - 添加群
     * @param array $data
     * @return array
     */
    public function joinGroup(array $data): array
    {
        //新版im
        $group = GroupImp::where(['id' => $data['group_id']])->first();
        if (empty($group)) {
            return Result::error("群不存在", 0);
        }
        $groupMember = GroupMemberImp::where(['user_id' => $data['user_id'], 'group_id' => $data['group_id']])->first();
        if ($groupMember) {
            return Result::error("已加入群", 0);
        }
        $groupMember = [
            'user_id' => $data['user_id'],
            'group_id' => $data['group_id'],
            'leader' => 3,
            'join_time' => Date('Y-m-d H:i:s')
        ];

        $groupMemberResult = GroupMemberImp::insertGetId($groupMember);
        $talk_session = [
            'user_id' => $data['user_id'],
            'to_from_id' => $data['group_id'],
            'talk_mode' => 2,
            'created_at' => Date('Y-m-d H:i:s'),
            'updated_at' => Date('Y-m-d H:i:s'),
        ];
        $talk_session_result = GroupTalkImp::insertGetId($talk_session);
        if ($groupMemberResult) {
            return Result::success($data);
        } else {
            return Result::error($data);
        };
        //ljim
        $group = ChatGroups::where(['id' => $data['group_id']])->first();
        if (empty($group)) {
            return Result::error("群不存在", 0);
        }
        $groupMember = ChatGroupsMember::where(['user_id' => $data['user_id'], 'group_id' => $data['group_id']])->first();
        if ($groupMember) {
            return Result::error("已加入群", 0);
        }
        $info = [
            'id' => PublicData::uuid(),
            'user_id' => $data['user_id'],
            'group_id' => $data['group_id'],
        ];
        $result = ChatGroupsMember::insert($info);
        var_dump($result, '--------------------');
        if ($result) {
            return Result::success($data);
        } else {
            return Result::error($data);
        };
    }
    /**
     * 话题 - 列表
     * @param array $data
     * @return array
     */
    public function getTopicsList(array $data): array
    {

        $where = [];
        if (!empty($data['title'])) {
            $where[] = ['chat_topics.title', 'like', '%' . $data['title'] . '%'];
        }
        // 不是看自己的话题
        if (!empty($data['user_id_search'])) {
            $where[] = ['chat_topics.user_id', '=', $data['user_id_search']];
        }
        if (!empty($data['status'])) {
            $where[] = ['chat_topics.status', '=', $data['status']];
        }
        if (!empty($data['type'])) {
            $where[] = ['chat_topics.type', '=', $data['type']];
        }
        if (!empty($data['nickname'])) {
            $where[] = ['user.nickname', '=', $data['nickname']];
        }
        var_dump($where);
        $result = ChatTopic::where($where)
            ->leftJoin('user', 'user.id', '=', 'chat_topics.user_id')
            ->leftJoin('chat_topics_reply', 'chat_topics.id', '=', 'chat_topics_reply.topic_id')
            ->leftJoin('chat_topic_class', 'chat_topics.type', '=', 'chat_topic_class.id')
            ->select(
                'chat_topics.*', 
                'chat_topic_class.topicname as type_name',
                'user.nickname',
                'user.avatar',
                'user.user_name',
                DB::raw('count(chat_topics_reply.id) as num')
            )
            ->groupBy('chat_topics.id')
            ->orderBy('chat_topics.updated_at', 'desc')
            ->paginate($data['page_size'], ['*'], 'page', $data['page'] ?? 1);
        return Result::success($result);
    }
    public function getTopic(array $data): array
    {
        $result = ChatTopic::where(['id' => $data['id']])->first();
        return Result::success($result);
    }

    public function addTopic(array $data): array
    {
        $chattopic = [];
        date_default_timezone_set('Asia/Shanghai');
        $data['created_at'] = date('Y-m-d H:i:s');
        $data['updated_at'] = date('Y-m-d H:i:s');
        $group_id = '';
        if ($data['type_id'] != 10000) {
            $this->sendMessage([
                'talk_type' => 300,
                'title' => $data['title'],
                'content' => '提交了审核',
                'messageType' => 4,
            ]);
            $data['status'] = 1;
        } else {
            $data['status'] = 2;
            if ($data['is_group'] == 1) {
                $group_id = PublicData::uuid();
                var_dump($group_id);
                $groupData = [
                    'id' => $group_id,
                    'creator_id' => $data['user_id'],
                    'group_name' => $data['group_name'] ?? '',
                    'profile' => '',
                ];
                $groupResult = ChatGroups::insertGetId($groupData);
                $groupMemberData = [
                    'id' => PublicData::uuid(),
                    'user_id' => $data['user_id'],
                    'group_id' => $group_id,
                    'leader' => 2,
                ];
                $groupMemberResult = ChatGroupsMember::insertGetId($groupMemberData);
                //更新result的 group_id
                // $datas['group_id'] = $group_id;
                // ChatTopic::where(['id' => $data['id']])->update($datas);

                //插入一条消息
                $chatRecordsData = [
                    'user_id' => $data['user_id'],
                    'receiver_id' => $group_id,
                    'content' => '我创建了一个群' . Date('Y-m-d H:i:s'),
                    'msg_type' => 1,
                    'is_read' => 0,
                    'talk_type' => 2,
                    'action' => 'said',
                    'group_receiver_id' => $data['user_id'],
                ];
                ChatRecords::insert($chatRecordsData);
                //插入imp group  group_member
                $group = [
                    'type' => 1,
                    'name' => $data['group_name'] ?? '',
                    'profile' => '',
                    'avatar' => '',
                    'creator_id' => $data['user_id'],
                ];
                $groupResult = GroupImp::insertGetId($group);
                var_dump($groupResult, '获取imp group_id');
                $groupMember = [
                    'user_id' => $data['user_id'],
                    'group_id' => $groupResult,
                    'leader' => 1,
                    'join_time' => Date('Y-m-d H:i:s')
                ];
                $groupMemberResult = GroupMemberImp::insertGetId($groupMember);
                $talk_session = [
                    'user_id' => $data['user_id'],
                    'to_from_id' => $groupResult,
                    'talk_mode' => 2,
                    'created_at' => Date('Y-m-d H:i:s'),
                    'updated_at' => Date('Y-m-d H:i:s'),
                ];
                $talk_session_result = GroupTalkImp::insertGetId($talk_session);
                $group_id = $groupResult;
            }
        }
        unset($data['type_id']);
        if ($group_id) {
            $data['group_id'] = $group_id;
        }
        $result = ChatTopic::insertGetId($data);
        $chattopic = Chattopic::find($result);
        Db::commit();
        Db::beginTransaction();
        try {
        } catch (\Exception $e) {
            Db::rollBack();
            return Result::error($data, $e->getMessage());
        }
        return Result::success($chattopic);
    }
    public function applyTopic(array $data): array
    {
        date_default_timezone_set('Asia/Shanghai');
        db::beginTransaction();
        try {
            $query = ChatTopic::where(['id' => $data['id']]);
            $topdata = $query->first();

            $result = ChatTopic::where(['id' => $data['id']])->update(['status' => $data['status']]);
            // var_dump($data, 'tedst111111111111111');
            // var_dump(date('Y-m-d H:i:s'), 'tedst111111111111111');
            $creatter = $topdata['user_id'];
            if ($data['status'] == 2 && $topdata['is_group'] == 1) {
                $group_id = '';
                if (empty($topdata['group_id'])) {
                    $group_id = PublicData::uuid();
                    $groupData = [
                        'id' => $group_id,
                        'creator_id' => $topdata['user_id'],
                        'group_name' => $topdata['group_name'] ?? '',
                        'profile' => '',
                    ];
                    $groupResult = ChatGroups::insertGetId($groupData);
                    $groupMemberData = [
                        'id' => PublicData::uuid(),
                        'user_id' => $topdata['user_id'],
                        'group_id' => $group_id,
                        'leader' => 2,
                    ];
                    $groupMemberResult = ChatGroupsMember::insertGetId($groupMemberData);

                    $group = [
                        'type' => 1,
                        'name' => $topdata['group_name'] ?? '',
                        'profile' => '',
                        'avatar' => '',
                        'creator_id' => $topdata['user_id'],
                    ];
                    $groupResult = GroupImp::insertGetId($group);
                    var_dump($groupResult, '获取imp group_id');
                    $groupMember = [
                        'user_id' => $topdata['user_id'],
                        'group_id' => $groupResult,
                        'leader' => 1,
                        'join_time' => Date('Y-m-d H:i:s')
                    ];
                    $groupMemberResult = GroupMemberImp::insertGetId($groupMember);
                    $talk_session = [
                        'user_id' => $topdata['user_id'],
                        'to_from_id' => $groupResult,
                        'talk_mode' => 2,
                        'created_at' => Date('Y-m-d H:i:s'),
                        'updated_at' => Date('Y-m-d H:i:s'),
                    ];
                    $talk_session_result = GroupTalkImp::insertGetId($talk_session);
                    $group_id = $groupResult;
                } else {
                    $group_id = $topdata['group_id'];
                }

                //更新result的 group_id
                $datas['group_id'] = $group_id;
                ChatTopic::where(['id' => $data['id']])->update($datas);
                //插入一条消息
                $chatRecordsData = [
                    'user_id' => $topdata['user_id'],
                    'receiver_id' => $group_id,
                    'content' => '我创建了一个群' . Date('Y-m-d H:i:s'),
                    'msg_type' => 1,
                    'is_read' => 0,
                    'talk_type' => 2,
                    'action' => 'said',
                    'group_receiver_id' => $topdata['user_id'],
                ];
                ChatRecords::insert($chatRecordsData);
                //新数据库


            } elseif ($data['status'] == 3) {
                if (isset($topdata['group_id']) && !empty($topdata['group_id'])) {
                    ChatRecords::where('receiver_id', $topdata['group_id'])->delete();
                    ChatGroupsMember::where('group_id', $topdata['group_id'])
                        ->where([["user_id", '!=', $creatter]])->delete();
                    //直接删除imp
                    GroupImp::where('id', $topdata['group_id'])->delete();
                    GroupMemberImp::where('group_id', $topdata['group_id'])->delete();
                    GroupTalkImp::where('to_from_id', $topdata['group_id'])->delete();
                    //删除group_id
                    ChatTopic::where('id', $topdata['id'])->update(['group_id' => 0]);
                }
            }
            if ($data['status'] == 2) {
                $this->sendMessage([
                    'talk_type' => 301,
                    'title' => $topdata['title'],
                    'content' => '审核通过',
                    'messageType' => 4,
                    'user_id' => $topdata['user_id'],
                ]);
            } else if ($data['status'] == 3) {
                $this->sendMessage([
                    'talk_type' => 301,
                    'title' => $topdata['title'],
                    'content' => '审核拒绝',
                    'messageType' => 4,
                    'user_id' => $topdata['user_id'],
                ]);
            }
            Db::commit();
            if ($result) {
                return Result::success($data);
            } else {
                return Result::error($data);
            }
        } catch (\Exception $e) {
            Db::rollBack();
            return Result::error($data, $e->getMessage());
        }
        if (empty($data['id'])) {
            return Result::error('id不能为空');
        }
    }
    public function updateTopic(array $data): array
    {
        if (empty($data['id'])) {
            return Result::error('id不能为空');
        }
        if ($data['type_id'] != 10000) {
            $this->sendMessage([
                'talk_type' => 300,
                'title' => $data['title'],
                'content' => '提交了审核',
                'messageType' => 4,
            ]);
            $data['status'] = 1;
        }

        $result = ChatTopic::where(['id' => $data['id']])->update($data);
        if ($result) {
            return Result::success($data);
        } else {
            return Result::error($data);
        };
    }
    public function delTopic(array $data): array
    {
        $result = ChatTopic::where(['id' => $data['id']])->delete();
        //删除群和成员和聊天
        //删除话题回复
        if ($result) {
            return Result::success($data);
        } else {
            return Result::error('删除失败');
        };
    }
    public function getTopicInfo(array $data): array
    {
        $result = ChatTopic::where(['chat_topics.id' => $data['id']])
            ->leftJoin('user', 'user.id', '=', 'chat_topics.user_id')
            ->leftJoin('chat_topic_class', 'chat_topic_class.id', '=', 'chat_topics.type')
            ->select('chat_topics.*', 'user.nickname', 'user.avatar', 'user.user_name', 'chat_topic_class.topicname')
            ->first();
        return Result::success($result);
    }
    public function addReply(array $data): array
    {
        $result = ChatTopic::where(['id' => $data['id']])->get();
        if ($result) {
            $replydata['created_at'] = date('Y-m-d H:i:s');
            $replydata['updated_at'] = date('Y-m-d H:i:s');
            $replydata['content'] = $data['content'];
            $replydata['user_id'] = $data['user_id'];
            $replydata['topic_id'] = $data['id'];
            $re = ChatTopicsReply::insertGetId($replydata);
        }
        if ($re) {
            return Result::success($data);
        } else {
            return Result::error($data);
        }
    }
    public function getTopicReply(array $data): array
    {
        var_dump($data);
        $result = ChatTopicsReply::where(['topic_id' => $data['id']])
            ->leftJoin('user', 'user.id', '=', 'chat_topics_reply.user_id')
            ->select('chat_topics_reply.*', 'user.nickname', 'user.avatar', 'user.user_name')
            ->orderBy('chat_topics_reply.id', 'desc')
            ->paginate($data['page_size'], ['*'], 'page', $data['page'] ?? 1);
        return Result::success($result);
    }

    /**
     *  修改群成员
     * @param array $data
     * @return array
     */
    public function updateGroupMembers(array $data): array
    {
        DB::beginTransaction();
        try {
            $where = [
                'group_id' => $data['group_id'],
            ];
            $group_id = $data['group_id'];
            //先删除群成员
            $result = ChatGroupsMember::where($where)
                ->where([["user_id", '!=', $data['user_id']]])->delete();
            $groupMemberData = [];
            foreach ($data['group_member'] as $value) {
                $groupMemberData[] = [
                    'id' => PublicData::uuid(),
                    'user_id' => $value,
                    'group_id' => $group_id,
                    'leader' => 0,
                ];
            }
            $result = ChatGroupsMember::where($where)->insert($groupMemberData);
            //删除会话踢出群的会话信息
            // var_dump("data",$data);
            //字符串转数组,
            $groupIdList = $data['group_member'];
            array_push($groupIdList, $data['user_id']);
            // var_dump("几个",$groupIdList);
            ChatRecords::whereNotIn('receiver_id', $groupIdList)->delete();

            // 获取群信息
            $groupInfo = ChatGroups::where(['id' => $group_id])->first();
            DB::commit();
            return Result::success($groupInfo);
        } catch (\Exception $e) {
            DB::rollBack();
            return Result::error($data, $e->getMessage());
        }
    }
    public function clearGroupRecords(array $data): array
    {
        $result = ChatRecords::where(['user_id' => $data['user_id'], 'receiver_id' => $data['id']])->delete();
        if ($result) {
            return Result::success("删除成功");
        } else {
            return Result::error("删除失败");
        }
    }
    public function recallRecord(array $data): array
    {
        //获取所有id，并删除掉
        $ids = array_column($data, 'id');
        $result = ChatRecords::whereIn('id', $ids)->delete();
        if ($result) {
            return Result::success("删除成功");
        } else {
            return Result::error("删除失败");
        }
    }
    public function clearRecords(array $data): array
    {
        $result = ChatRecords::where(['user_id' => $data['user_id'], 'receiver_id' => $data['friend_id']])->delete();
        if ($result) {
            return Result::success("删除成功");
        } else {
            return Result::error("删除失败");
        }
    }
    public function getRecordByContent(array $data): array
    {
        $result = ChatRecords::where(['chat_records.user_id' => $data['user_id'], 'chat_records.receiver_id' => $data['receiver_id'], 'chat_records.content' => $data['content']])
            ->orWhere(['chat_records.receiver_id' => $data['user_id'], 'chat_records.user_id' => $data['receiver_id'], 'chat_records.content' => $data['content']])
            ->all();
        if ($result) {
            return Result::success($result['id']);
        } else {
            return Result::error("没有数据");
        }
    }
    public function getRecord(array $data): array
    {
        $result = ChatRecords::where(['chat_records.id' => $data['id']])
            ->leftJoin('user', 'user.id', '=', 'chat_records.user_id')
            ->leftJoin('user as user2', 'user2.id', '=', 'chat_records.receiver_id')
            ->select('chat_records.*', 'user.nickname', 'user.avatar', 'user.user_name', 'user2.nickname as receiver_nickname', 'user2.avatar as receiver_avatar')
            ->get();
        return Result::success($result);
    }
    public function delReply(array $data): array
    {
        $result = ChatTopicsReply::where(['id' => $data['id']])->delete();
        if ($result) {
            return Result::success("删除成功");
        } else {
            return Result::error("删除失败");
        }
    }
    public function delAllReply(array $data): array
    {
        $result = ChatTopicsReply::where(['topic_id' => $data['topicid']])->delete();
        if ($result) {
            return Result::success("删除成功");
        } else {
            return Result::error("删除失败");
        }
    }
    public function getTopicsListAdmin(array $data): array
    {
        $where = [];
        if (!empty($data['type'])) {
            $where['type'] = $data['type'];
        }
        if (!empty($data['title'])) {
            $where['title'] = $data['title'];
        }
        $result = ChatTopic::where($where)
            ->leftJoin('user', 'user.id', '=', 'chat_topics.user_id')
            ->select('chat_topics.*', 'user.nickname', 'user.avatar', 'user.user_name')
            ->paginate($data['page_size'], ['*'], 'page', $data['page'] ?? 1);
        return Result::success($result);
    }
    public function getTopicClassList(array $data): array
    {
        $where = [];
        if (!empty($data['topicname'])) {
            $where[] = ['topicname', 'like', '%' . $data['topicname'] . '%'];
        }
        $result = ChatTopicClass::where($where)->orderBy('updated_at', 'desc')
            ->paginate($data['page_size'], ['*'], 'page', $data['page'] ?? 1);
        return Result::success($result);
    }
    public function deleteTopicClass(array $data): array
    {

        $result = ChatTopicClass::where(['id' => $data['id']])->delete();
        if ($result) {
            return Result::success("删除成功");
        }
        return Result::error("删除失败");
    }

    public function updateTopicClass(array $data): array
    {
        //topicname
        if (!empty($data['topicname'])) {

            $re = ChatTopicClass::where(['topicname' => $data['topicname']])->first();
            if ($re) {
                return Result::error("话题分类已存在");
            }
        }
        $result = ChatTopicClass::where(['id' => $data['id']])->update([
            'topicname' => $data['topicname'],
            'updated_at' => date('Y-m-d H:i:s'),
        ]);
        if ($result) {
            return Result::success("修改成功");
        }
        return Result::error("修改失败");
    }
    public function addTopicClass(array $data): array
    {
        //topicname
        if (!empty($data['topicname'])) {

            $re = ChatTopicClass::where(['topicname' => $data['topicname']])->first();
            if ($re) {
                return Result::error("话题分类已存在");
            }
        }
        $result = ChatTopicClass::insert($data);
        if ($result) {
            return Result::success("添加成功");
        }
        return Result::error("添加失败");
    }
    /**
     * 获取话题分类信息
     * @param array $data
     * @return array
     */
    public function getTopicClassInfo(array $data): array
    {
        $result = ChatTopicClass::where(['id' => $data['id']])->first();
        return Result::success($result);
    }

    /**
     * @param array $data
     * @return array
     */
    public function getBusinessDistrictList(array $data): array
    {
        $query = GroupMemberImp::Join('hyperf.chat_topics', 'hyperf.chat_topics.group_id', '=', 'imp.group_member.group_id')
            ->leftJoin('hyperf.chat_topic_class', 'hyperf.chat_topic_class.id', '=', 'hyperf.chat_topics.type')
            ->where(['imp.group_member.user_id' => $data['user_id']])
            ->when($data, function ($query) use ($data) {
                if (!empty($data['type'])) {
                    $query->where(['hyperf.chat_topics.type' => $data['type']]);
                }
                if (!empty($data['title'])) {
                    $query->where('hyperf.chat_topics.title', 'like', '%' . $data['title'] . '%');
                }
                if (!empty($data['created_at'])) {
                    $query->whereDate('hyperf.chat_topics.created_at', $data['created_at']);
                }
            })
            ->select(
                'hyperf.chat_topics.id',
                'hyperf.chat_topics.title',
                'hyperf.chat_topics.author',
                'hyperf.chat_topics.created_at',
                'hyperf.chat_topics.updated_at',
                'hyperf.chat_topic_class.topicname',
            )
            ->orderBy('hyperf.chat_topics.created_at', 'desc');
        $total = $query->count();
        $list = $query->forPage($data['page'], $data['page_size'])->get();
        $result = [
            'list' => $list,
            'total' => $total,
            'page' => intval($data['page']),
            'page_size' => intval($data['page_size']),
        ];
        return  Result::success($result);
    }

    /**
     * 发送消息
     * @param array $messageData
     * @return void
     */
    public function sendMessage($messageData)
    {
        $msg = [
            'talk_type' => $messageData['talk_type'],
            'title' => $messageData['title'],
            'content' => $messageData['content'],
            'messageType' => $messageData['messageType'],
            'user_id' => $messageData['user_id'] ?? '',
            'time' => microtime(),
        ];
        $message = new MqProducer($msg);
        $producer = ContextApplicationContext::getContainer()->get(Producer::class);
        $producer->produce($message);
    }
}