Proyectos de Subversion LeadersLinked - Backend

use Laminas\Log\LoggerInterface;

use Laminas\View\Model\JsonModel;

use Laminas\View\Model\ViewModel;

use LeadersLinked\Model\Connection;

use LeadersLinked\Library\Functions;

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\Mapper\ChatUserMapper;

use LeadersLinked\Mapper\ChatGroupMapper;

use LeadersLinked\Mapper\ConnectionMapper;

use LeadersLinked\Mapper\ChatMessageMapper;

use LeadersLinked\Mapper\ZoomMeetingMapper;

use LeadersLinked\Model\ChatGroupUserMessage;

use LeadersLinked\Mapper\ZoomMeetingUserMapper;

    }

    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);

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

                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);