Proyectos de Subversion LeadersLinked - Backend

    }

    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'

            ]);

        }