Proyectos de Subversion LeadersLinked - Backend

use LeadersLinked\Model\User;

use LeadersLinked\Model\Network;

use Laminas\View\Model\JsonModel;

use Laminas\View\Model\ViewModel;

use LeadersLinked\Mapper\UserMapper;

use LeadersLinked\Mapper\UtilMapper;

use LeadersLinked\Model\ChatMessage;

use LeadersLinked\Model\ZoomMeeting;

use LeadersLinked\Model\ChatGroupUser;

use Laminas\Db\Adapter\AdapterInterface;

use LeadersLinked\Form\Chat\ZoomAddForm;

use LeadersLinked\Model\ChatGroupMessage;

use LeadersLinked\Mapper\ConnectionMapper;

use LeadersLinked\Mapper\ChatGroupUserMapper;

use LeadersLinked\Model\ChatGroupUserMessage;

use LeadersLinked\Mapper\ZoomMeetingUserMapper;

use LeadersLinked\Mapper\ChatGroupMessageMapper;

                        'url_zoom'                  => $this->url()->fromRoute('chat/zoom', ['id' => $user->uuid, 'type' => 'chat']),

    }

    public function zoomAction()

    {

        $request = $this->getRequest();

        if ($request->isPost()) {

            $currentUserPlugin = $this->plugin('currentUserPlugin');

            $currentUser = $currentUserPlugin->getUser();

            $id = $this->params()->fromRoute('id');

            if (!$id) {

                return new JsonModel([

                    'success' => false,

                    'data' => 'ERROR_PARAMETERS_ARE_INVALID'

                ]);

            }

            $chatUserMapper = ChatUserMapper::getInstance($this->adapter);

            $chatGroupMapper = ChatGroupMapper::getInstance($this->adapter);

            $chatUser = null;

            $chatGroup = $chatGroupMapper->fetchOneByUuid($id);

            if ($chatGroup) {

                $chatGroupUserMapper = ChatGroupUserMapper::getInstance($this->adapter);

                $chatGroupUser = $chatGroupUserMapper->fetchOneByGroupIdAndUserId($chatGroup->id, $currentUser->id);

                if (!$chatGroupUser) {

                    $data = [

                        'success' => false,

                        'data' =>  'ERROR_ZOOM_CHAT_UNAUTHORIZE'

                    ];

                    return new JsonModel($data);

                }

            } else {

                $userMapper = UserMapper::getInstance($this->adapter);

                $user = $userMapper->fetchOneByUuid($id);

                if (!$user) {

                    return new JsonModel([

                        'success' => false,

                        'data' => 'ERROR_USER_NOT_FOUND'

                    ]);

                }

                $connectionMapper = ConnectionMapper::getInstance($this->adapter);

                $connection = $connectionMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);

                if (!$connection || $connection->status != Connection::STATUS_ACCEPTED) {

                    return new JsonModel([

                        'success' => false,

                        'data' => 'ERROR_THIS_USER_IS_NOT_A_CONNECTION'

                    ]);

                }

                $chatUserMapper = ChatUserMapper::getInstance($this->adapter);

                $chatUser = $chatUserMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);

                if (!$chatUser) {

                    $chatUser = new ChatUser();

                    $chatUser->user_id1 = $currentUser->id;

                    $chatUser->user_id2 = $user->id;

                    $response = $chatUserMapper->insert($chatUser);

                    if (!$response) {

                        return new JsonModel([

                            'success' => false,

                            'data' => $chatUserMapper->getError()

                        ]);

                    }

                    $chatUser = $chatUserMapper->fetchOne($chatUser->id);

                    $fullpath_chat = $this->config['leaderslinked.fullpath.chat'];

                    $dirpath = $fullpath_chat . $chatUser->uuid;

                    if (!file_exists($dirpath)) {

                        mkdir($dirpath, 0777, true);

                        chmod($dirpath, 0777);

                    }

                }

            }

            if (!$chatUser && !$chatGroup) {

                $data = [

                    'success' => false,

                    'data' => 'ERROR_ZOOM_CHAT_NOT_FOUND'

                ];

                return new JsonModel($data);

            }

            $dataPost = $request->getPost()->toArray();

            $form = new ZoomAddForm();

            $form->setData($dataPost);

            if ($form->isValid()) {

                $dataPost = (array) $form->getData();

                $dtStart = \DateTime::createFromFormat('Y-m-d H:i:s', $dataPost['date'] . ' ' . $dataPost['time']);

                if (!$dtStart) {

                    return new JsonModel([

                        'success' => false,

                        'data' => 'ERROR_PARAMETERS_ARE_INVALID'

                    ]);

                }

                $dtEnd = \DateTime::createFromFormat('Y-m-d H:i:s', $dataPost['date'] . ' ' . $dataPost['time']);

                $dtEnd->add(new \DateInterval('PT' . $dataPost['duration'] . 'M'));

                $start_time = $dtStart->format('Y-m-d\TH:i:s');

                $zoom = new Zoom($this->adapter, $this->config, $this->cache);

                $response =  $zoom->getOAuthAccessToken();

                if ($response['success']) {

                    $access_token = $response['data'];

                    $result = $zoom->addMeeting($access_token, $dataPost['title'], $dataPost['description'], $dataPost['type'], $start_time, $dataPost['duration'], $dataPost['timezone'], $dataPost['password']);

                } else {

                    return new JsonModel([

                        'success' => false,

                        'data' => 'ERROR_ZOOM_CREATING_NEW_MEETING'

                    ]);

                }

                if ($result['success']) {

                    $zoomMeetingMapper = ZoomMeetingMapper::getInstance($this->adapter);

                    $zoomMeeting = $zoomMeetingMapper->fetchOne($result['data']['id']);

                    if (!$zoomMeeting) {

                        $zoomMeeting = new ZoomMeeting();

                        $zoomMeeting->id = $result['data']['id'];

                        $zoomMeeting->topic = $dataPost['title'];

                        $zoomMeeting->agenda = $dataPost['description'];

                        $zoomMeeting->duration = $dataPost['duration'];

                        $zoomMeeting->join_url = $result['data']['join_url'];

                        $zoomMeeting->start_time = $dtStart->format('Y-m-d H:i:s');

                        $zoomMeeting->end_time = $dtEnd->format('Y-m-d H:i:s');

                        $zoomMeeting->timezone = $dataPost['timezone'];

                        $zoomMeeting->type = $dataPost['type'];

                        $zoomMeeting->uuid = $result['data']['uuid'];

                        $zoomMeeting->password = $dataPost['password'];

                        if (!$zoomMeetingMapper->insert($zoomMeeting)) {

                            return new JsonModel([

                                'success' => false,

                                'data' => $zoomMeetingMapper->getError()

                            ]);

                        }

                    }

                    $chatMessageContent = "LABEL_ZOOM_MEETING \r\n" .

                        " LABEL_ZOOM_MEETING_START_DATE : " . $dtStart->format('Y-m-d') . "\r\n" .

                        " LABEL_ZOOM_MEETING_START_TIME : " . $dtStart->format('H:i a') . "\r\n" .

                        " LABEL_ZOOM_MEETING_TIMEZONE : " . $zoomMeeting->timezone . "\r\n" .

                        " LABEL_ZOOM_MEETING_TITLE :  " . $zoomMeeting->topic  . "\r\n" .

                        " LABEL_ZOOM_MEETING_URL : " . $zoomMeeting->join_url . "\r\n" .

                        " LABEL_ZOOM_MEETING_PASSWORD : " . $zoomMeeting->password . "\r\n";

                    $zoomMeetingUserMapper = ZoomMeetingUserMapper::getInstance($this->adapter);

                    $zoomMeetingUser = $zoomMeetingUserMapper->fetchOneByZoomMeetingIdAndUserId($zoomMeeting->id, $currentUser->id);

                    if (!$zoomMeetingUser) {

                        $zoomMeetingUser = new ZoomMeetingUser();

                        $zoomMeetingUser->zoom_meeting_id = $zoomMeeting->id;

                        $zoomMeetingUser->user_id = $currentUser->id;

                        $zoomMeetingUser->type = ZoomMeetingUser::TYPE_CREATOR;

                        $zoomMeetingUserMapper->insert($zoomMeetingUser);

                    }

                    if ($chatUser) {

                        if ($chatUser->user_id1 == $currentUser->id) {

                            $zoomMeetingUser = $zoomMeetingUserMapper->fetchOneByZoomMeetingIdAndUserId($zoomMeeting->id, $chatUser->user_id2);

                            if (!$zoomMeetingUser) {

                                $zoomMeetingUser = new ZoomMeetingUser();

                                $zoomMeetingUser->zoom_meeting_id = $zoomMeeting->id;

                                $zoomMeetingUser->user_id = $chatUser->user_id2;

                                $zoomMeetingUser->type = ZoomMeetingUser::TYPE_CREATOR;

                                $zoomMeetingUserMapper->insert($zoomMeetingUser);

                            }

                        } else {

                            $zoomMeetingUser = $zoomMeetingUserMapper->fetchOneByZoomMeetingIdAndUserId($zoomMeeting->id, $chatUser->user_id1);

                            if (!$zoomMeetingUser) {

                                $zoomMeetingUser = new ZoomMeetingUser();

                                $zoomMeetingUser->zoom_meeting_id = $zoomMeeting->id;

                                $zoomMeetingUser->user_id = $chatUser->user_id1;

                                $zoomMeetingUser->type = ZoomMeetingUser::TYPE_CREATOR;

                                $zoomMeetingUserMapper->insert($zoomMeetingUser);

                            }

                        }

                        $chatMessage = new ChatMessage();

                        $chatMessage->recd = ChatMessage::RECD_NO;

                        $chatMessage->seen = ChatMessage::SEEN_NO;

                        $chatMessage->type = ChatMessage::TYPE_TEXT;

                        $chatMessage->content = $chatMessageContent;

                        $chatMessage->from_id = $currentUser->id;

                        $chatMessage->to_id = $chatUser->user_id1 == $currentUser->id ? $chatUser->user_id2 : $chatUser->user_id1;

                        $chatMessage->chat_id = $chatUser->id;

                        $chatMessageMapper = ChatMessageMapper::getInstance($this->adapter);

                        $chatMessageMapper->insert($chatMessage);

                        $chatUserMapper->markIsOpen1($chatUser->id);

                        $chatUserMapper->markIsOpen2($chatUser->id);

                    } else if ($chatGroup) {

                        $chatGroupMessage = new ChatGroupMessage();

                        $chatGroupMessage->group_id = $chatGroup->id;

                        $chatGroupMessage->content = $chatMessageContent;

                        $chatGroupMessage->sender_id = $currentUser->id;

                        $chatGroupMessage->type = ChatGroupMessage::TYPE_TEXT;

                        $chatGroupMessageMapper = ChatGroupMessageMapper::getInstance($this->adapter);

                        if ($chatGroupMessageMapper->insert($chatGroupMessage)) {

                            $chatGroupUserMapper = ChatGroupUserMapper::getInstance($this->adapter);

                            $groupUsers =   $chatGroupUserMapper->fetchAllByGroupId($chatGroup->id);

                            $chatGroupUserMessageMapper = ChatGroupUserMessageMapper::getInstance($this->adapter);

                            foreach ($groupUsers as $groupUser) {

                                if ($groupUser->user_id != $currentUser->id) {

                                    $zoomMeetingUser = $zoomMeetingUserMapper->fetchOneByZoomMeetingIdAndUserId($zoomMeeting->id, $groupUser->user_id);

                                    if (!$zoomMeetingUser) {

                                        $zoomMeetingUser = new ZoomMeetingUser();

                                        $zoomMeetingUser->zoom_meeting_id = $zoomMeeting->id;

                                        $zoomMeetingUser->user_id = $groupUser->user_id;

                                        $zoomMeetingUser->type = ZoomMeetingUser::TYPE_CREATOR;

                                        $zoomMeetingUserMapper->insert($zoomMeetingUser);

                                    }

                                }

                                $chatGroupUserMessage = new ChatGroupUserMessage();

                                $chatGroupUserMessage->group_id = $chatGroup->id;

                                $chatGroupUserMessage->message_id = $chatGroupMessage->id;

                                $chatGroupUserMessage->receiver_id = $groupUser->user_id;

                                $chatGroupUserMessage->recd = ChatGroupUserMessage::RECD_NO;

                                $chatGroupUserMessage->seen = ChatGroupUserMessage::SEEN_NO;

                                $chatGroupUserMessageMapper->insert($chatGroupUserMessage);

                                $chatGroupUserMapper->markIsOpen($groupUser->group_id, $groupUser->user_id);

                            }

                        }

                    }

                    return new JsonModel([

                        'success' => true,

                        'data' => 'LABEL_ZOOM_NEW_MEETING_SUCCESSFULLY'

                    ]);

                } else {

                    return new JsonModel([

                        'success' => false,

                        'data' => 'ERROR_ZOOM_CREATING_NEW_MEETING'

                    ]);

                }

            } else {

                $messages = [];

                $form_messages = (array) $form->getMessages();

                foreach ($form_messages  as $fieldname => $field_messages) {

                    $messages[$fieldname] = array_values($field_messages);

                }

                return new JsonModel([

                    'success'   => false,

                    'data'   => $messages

                ]);

                return new JsonModel($response);

            }

        } else {

            $response = [

                'success' => false,

                'data' => 'ERROR_METHOD_NOT_ALLOWED'

            ];

        }

        return new JsonModel($response);

    }

    public function usersAction()

    {

        $currentUserPlugin = $this->plugin('currentUserPlugin');

        $currentUser = $currentUserPlugin->getUser();

        $currentNetworkPlugin = $this->plugin('currentNetworkPlugin');

        $currentNetwork = $currentNetworkPlugin->getNetwork();

        $request = $this->getRequest();

        if ($request->isGet()) {

            $items = [];

            $chatUserMapper = ChatUserMapper::getInstance($this->adapter);

            $search = trim(filter_var($this->params()->fromQuery('search', ''), FILTER_SANITIZE_STRING));

            if (strlen($search) >= 3) {

                $user_ids = [];

                $userMapper = UserMapper::getInstance($this->adapter);

                if ($currentNetwork->relationship_user_mode == Network::RELATIONSHIP_USER_MODE_USER_2_USER) {

                    $connectionMapper = ConnectionMapper::getInstance($this->adapter);

                    $user_ids = $connectionMapper->fetchAllConnectionsByUserReturnIds($currentUser->id);

                } else {

                    if ($currentNetwork->default == Network::DEFAULT_YES) {

                        $user_ids = $userMapper->fetchAllIdsByDefaultNetworkId($currentNetwork->id, $currentUser->id);

                    } else {

                        $user_ids = $userMapper->fetchAllIdsByNonDefaultNetworkId($currentNetwork->id, $currentUser->id);

                    }

                }

                $items = [];

                $records = $userMapper->fetchAllByIdsAndSearch($user_ids, $search, $currentUser->id);

                foreach ($records as $record) {

                    $chatUser = $chatUserMapper->fetchOneByUserId1AndUserId2($currentUser->id, $record->id);

                    if ($chatUser) {

                        $link_send = $this->url()->fromRoute('chat/send', ['id' => $record->uuid]);

                    } else {

                        $link_send = '';

                    }

                    $link_open_or_create = $this->url()->fromRoute('chat/open-or-create', ['id' => $record->uuid]);

                    array_push($items, [

                        'name'  => trim($record->first_name .  '  ' . $record->last_name) . ' (' . $record->email . ')',

                        'image' => $this->url()->fromRoute('storage', ['code' => $record->uuid, 'type' => 'user', 'filename' => $record->image]),

                        'link_send' => $link_send,

                        'link_open_or_create' => $link_open_or_create,

                    ]);

                }

            }

            $response = [

                'success' => true,

                'data' => $items

            ];

        } else {

            $response = [

                'success' => false,

                'data' => 'ERROR_METHOD_NOT_ALLOWED'

            ];

        }

        return new JsonModel($response);

    }

    public function openOrCreateAction()

    {

        $request    = $this->getRequest();

        if ($request->isPost()) {

            $currentUserPlugin = $this->plugin('currentUserPlugin');

            $currentUser = $currentUserPlugin->getUser();

            $currentNetworkPlugin = $this->plugin('currentNetworkPlugin');

            $currentNetwork = $currentNetworkPlugin->getNetwork();

            $id = filter_var($this->params()->fromRoute('id'), FILTER_SANITIZE_STRING);

            if (!$id) {

                return new JsonModel([

                    'success' => false,

                    'data' => 'ERROR_PARAMETERS_ARE_INVALID'

                ]);

            }

            $userMapper = UserMapper::getInstance($this->adapter);

            $user = $userMapper->fetchOneByUuid($id);

            if (!$user) {

                return new JsonModel([

                    'success' => false,

                    'data' => 'ERROR_USER_NOT_FOUND'

                ]);

            }

            if ($user->email_verified == User::EMAIL_VERIFIED_NO || $user->status != User::STATUS_ACTIVE) {

                return new JsonModel([

                    'success' => false,

                    'data' => 'ERROR_USER_IS_INACTIVE'

                ]);

            }

            if ($user->network_id != $currentUser->network_id) {

                return new JsonModel([

                    'success' => false,

                    'data' => 'ERROR_USER_IS_INACTIVE'

                ]);

            }

            if ($currentNetwork->relationship_user_mode == Network::RELATIONSHIP_USER_MODE_USER_2_USER) {

                $connectionMapper = ConnectionMapper::getInstance($this->adapter);

                $connection = $connectionMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);

                if (!$connection) {

                    return new JsonModel([

                        'success' => false,

                        'data' =>  'ERROR_CONNECTION_NOT_ACTIVE'

                    ]);

                }

            }

            $chatUserMapper = ChatUserMapper::getInstance($this->adapter);

            $chatUser = $chatUserMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);

            if ($chatUser) {

                if ($currentUser->id == $chatUser->user_id1) {

                    $chatUserMapper->markIsOpen1($chatUser->id);

                } else {

                    $chatUserMapper->markIsOpen2($chatUser->id);

                }

            } else {

                $chatUser = new ChatUser();

                $chatUser->user_id1 = $currentUser->id;

                $chatUser->user_id2 = $user->id;

                $chatUser->user_open1 = ChatUser::OPEN_YES;

                $chatUser->user_open2 = ChatUser::OPEN_NO;

                if (!$chatUserMapper->insert($chatUser)) {

                    return new JsonModel([

                        'success' => false,

                        'data' =>  $chatUserMapper->getError()

                    ]);

                }

            }

            $utilMapper = UtilMapper::getInstance($this->adapter);

            $now = $utilMapper->getDatebaseNow();

            $chatMessageMapper = ChatMessageMapper::getInstance($this->adapter);

            $count_not_received_messages = $chatMessageMapper->countNotReceivedMessagesByChatIdAndToId($chatUser->id, $currentUser->id);

            $count_not_seen_messages = $chatMessageMapper->countNotSeenMessagesByChatIdAndToId($chatUser->id, $currentUser->id);

            $lastMessage = $chatMessageMapper->fetchLastMessage($chatUser->id, $currentUser->id);

            if ($lastMessage) {

                $lastMessage = Functions::timeAgo($lastMessage->added_on, $now);

            } else {

                $lastMessage = '';

            }

            if ($currentUser->id == $chatUser->user_id1) {

                $is_open = $chatUser->user_open1 == ChatUser::OPEN_YES;

            } else {

                $is_open = $chatUser->user_open2 == ChatUser::OPEN_YES;

            }

            $not_received_messages = $count_not_received_messages > 0;

            $not_seen_messages = $count_not_seen_messages > 0;

            $data = [

                'url_clear'                 => $this->url()->fromRoute('chat/clear', ['id' => $user->uuid]),

                'url_close'                 => $this->url()->fromRoute('chat/close', ['id' => $user->uuid]),

                'url_open'                  => $this->url()->fromRoute('chat/open', ['id' => $user->uuid]),

                'url_send'                  => $this->url()->fromRoute('chat/send', ['id' => $user->uuid]),

                'url_upload'                => $this->url()->fromRoute('chat/upload', ['id' => $user->uuid]),

                'url_mark_seen'             => $this->url()->fromRoute('chat/mark-seen', ['id' => $user->uuid]),

                'url_mark_received'         => $this->url()->fromRoute('chat/mark-received', ['id' => $user->uuid]),

                'url_get_all_messages'      => $this->url()->fromRoute('chat/get-all-messages', ['id' => $user->uuid]),

                'url_zoom'                  => $this->url()->fromRoute('chat/zoom', ['id' => $user->uuid, 'type' => 'chat']),

                'id'                        => $user->uuid,

                'name'                      => trim($user->first_name . ' ' . $user->last_name),

                'image'                     => $this->url()->fromRoute('storage', ['code' => $user->uuid, 'type' => 'user', 'filename' => $user->image]),

                'profile'                   => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),

                'type'                      => 'user',

                'online'                    => $user->online ? 1 : 0,

                'is_open'                   => $is_open ? 1 : 0,

                'not_seen_messages'         => $not_seen_messages,

                'not_received_messages'     => $not_received_messages,

                'count_not_seen_messages'       => $count_not_seen_messages,

                'count_not_received_messages'   => $count_not_received_messages,

                'last_message'                  => $lastMessage

            ];

            $userMapper->updateLastActivity($currentUser->id);

            return new JsonModel([

                'success' => true,

                'data' => $data,

            ]);

        } else {

            return new JsonModel([

                'success' => false,

                'data' => 'ERROR_METHOD_NOT_ALLOWED'

            ]);

        }