WebSVN – LeadersLinked - Antes de SPA – Diff – /module/LeadersLinked/src/Controller/ChatController.php

 use LeadersLinked\Model\ChatGroupMessage;
 use LeadersLinked\Model\ChatGroupUserMessage;
 use LeadersLinked\Model\Connection;
 use LeadersLinked\Model\ChatGroup;
 use LeadersLinked\Model\ChatUser;
+use LeadersLinked\Model\Network;
 use LeadersLinked\Form\Chat\CreateGroupForm;
 use LeadersLinked\Mapper\ChatGroupUserMapper;
 use LeadersLinked\Model\ChatGroupUser;
 use LeadersLinked\Mapper\UtilMapper;
 use LeadersLinked\Library\Zoom;
 use LeadersLinked\Mapper\ZoomMeetingMapper;
 use LeadersLinked\Model\ZoomMeetingUser;
 use LeadersLinked\Model\CalendarEvent;
 use LeadersLinked\Mapper\CalendarEventMapper;
 use LeadersLinked\Mapper\ZoomMeetingUserMapper;
+use LeadersLinked\Mapper\QueryMapper;
     public function indexAction()
+    {
         $currentUserPlugin = $this->plugin('currentUserPlugin');
         $currentUser = $currentUserPlugin->getUser();
+        $currentNetworkPlugin = $this->plugin('currentNetworkPlugin');
+        $currentNetwork = $currentNetworkPlugin->getNetwork();
+        $userIds = [];
+        if($currentNetwork->relationship_user_mode == Network::RELATIONSHIP_USER_MODE_USER_2_USER)  {
-        $connectionMapper = ConnectionMapper:: getInstance($this->adapter);
+            $connectionMapper = ConnectionMapper:: getInstance($this->adapter);
+            $userIds = $connectionMapper->fetchAllConnectionsByUserReturnIds( $currentUser->id );
+        } else {
+            $chatUserMapper = ChatUserMapper::getInstance($this->adapter);
+            $records = $chatUserMapper->fetchAllByUserId($currentUser->id);
+            foreach($records as $record)
+            {
+                if($record->user_id1 == $currentUser->id) {
+                    array_push($userIds, $record->user_id2);
+                } else {
+                    array_push($userIds, $record->user_id1);
+                }
+            }
         $connectionIds = $connectionMapper->fetchAllConnectionsByUserReturnIds( $currentUser->id );
         $contacts = [];
-        if($connectionIds) {
+        if($userIds) {
-            $utilMapper = UtilMapper::getInstance($this->adapter);
+            //$utilMapper = UtilMapper::getInstance($this->adapter);
-            $now = $utilMapper->getDatebaseNow();
+            //$now = $utilMapper->getDatebaseNow();
             $userMapper = UserMapper::getInstance($this->adapter);
-            $users = $userMapper->fetchAllByIds($connectionIds);
+            $users = $userMapper->fetchAllByIds($userIds);
      * ]
      * @return \Laminas\View\Model\JsonModel
      */
     public function heartBeatAction()
+    {
+        $currentUserPlugin = $this->plugin('currentUserPlugin');
+        $currentUser = $currentUserPlugin->getUser();
+        $currentNetworkPlugin = $this->plugin('currentNetworkPlugin');
+        $currentNetwork = $currentNetworkPlugin->getNetwork();
         $request    = $this->getRequest();
         if($request->isGet()) {
             $utilMapper = UtilMapper::getInstance($this->adapter);
             $now = $utilMapper->getDatebaseNow();
-            $currentUserPlugin = $this->plugin('currentUserPlugin');
             $currentUser = $currentUserPlugin->getUser();
             $userMapper = UserMapper::getInstance($this->adapter);
+            }
             $chatUserMapper = ChatUserMapper::getInstance($this->adapter);
+            $chatMessageMapper = ChatMessageMapper::getInstance($this->adapter);
+            $userIds = [];
-            $chatMessageMapper = ChatMessageMapper::getInstance($this->adapter);
+            if($currentNetwork->relationship_user_mode == Network::RELATIONSHIP_USER_MODE_USER_2_USER)  {
+                $connectionMapper = ConnectionMapper::getInstance($this->adapter);
+                $userIds = $connectionMapper->fetchAllConnectionsByUserReturnIds($currentUser->id);
+            } else {
+                $records = $chatUserMapper->fetchAllByUserId($currentUser->id);
+                foreach($records as $record)
+                {
+                    if($record->user_id1 == $currentUser->id) {
+                        array_push($userIds, $record->user_id2);
+                    } else {
+                        array_push($userIds, $record->user_id1);
+                    }
+                }
-            $connectionMapper = ConnectionMapper::getInstance($this->adapter);
             $connectionIds = $connectionMapper->fetchAllConnectionsByUserReturnIds($currentUser->id);
-            if ($connectionIds) {
+            if ($userIds) {
      * ]
      * @return \Laminas\View\Model\JsonModel
      */
     public function addUserToGroupAction()
+    {
+        $currentUserPlugin = $this->plugin('currentUserPlugin');
+        $currentUser = $currentUserPlugin->getUser();
+        $currentNetworkPlugin = $this->plugin('currentNetworkPlugin');
+        $currentNetwork = $currentNetworkPlugin->getNetwork();
         $request    = $this->getRequest();
         if($request->isPost()) {
-            $currentUserPlugin = $this->plugin('currentUserPlugin');
-            $currentUser = $currentUserPlugin->getUser();
             $group_id   = $this->params()->fromRoute('group_id');
             $user_id    = $this->params()->fromPost('uid');
                     'data' => 'ERROR_CHAT_I_CAN_NOT_ADD_HIMSELF'
                 ]);
+            }
+            if($currentNetwork->relationship_user_mode == Network::RELATIONSHIP_USER_MODE_USER_2_USER)  {
-            $connectionMapper = ConnectionMapper::getInstance($this->adapter);
+                $connectionMapper = ConnectionMapper::getInstance($this->adapter);
+                $connection = $connectionMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
+                if(!$connection) {
+                    return new JsonModel([
+                        'success' => false,
+                        'data' => 'ERROR_THIS_USER_IS_NOT_A_CONNECTION'
+                    ]);
+                }
-            $connection = $connectionMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
+            } else {
-            if(!$connection) {
+                if($currentUser->network_id != $user->network_id) {
-                return new JsonModel([
+                    return new JsonModel([
+                        'success' => false,
-                    'success' => false,
+                        'data' => 'ERROR_THIS_USER_IS_NOT_A_CONNECTION'
-                    'data' => 'ERROR_THIS_USER_IS_NOT_A_CONNECTION'
+                    ]);
                 ]);
+            }
      * ]
      * @return \Laminas\View\Model\JsonModel
      */
     public function getAllMessagesAction()
+    {
+        $currentUserPlugin = $this->plugin('currentUserPlugin');
+        $currentUser = $currentUserPlugin->getUser();
+        $currentNetworkPlugin = $this->plugin('currentNetworkPlugin');
+        $currentNetwork = $currentNetworkPlugin->getNetwork();
         $request    = $this->getRequest();
-        if($request->isGet()) {
-            $currentUserPlugin = $this->plugin('currentUserPlugin');
+        if($request->isGet()) {
             $currentUser = $currentUserPlugin->getUser();
                         'data' => 'ERROR_USER_NOT_FOUND'
                     ]);
+                }
+                if($currentNetwork->relationship_user_mode == Network::RELATIONSHIP_USER_MODE_USER_2_USER)  {
-                $connectionMapper = ConnectionMapper::getInstance($this->adapter);
+                    $connectionMapper = ConnectionMapper::getInstance($this->adapter);
-                $connection = $connectionMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
+                    $connection = $connectionMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
-                if(!$connection || $connection->status != Connection::STATUS_ACCEPTED) {
+                    if(!$connection || $connection->status != Connection::STATUS_ACCEPTED) {
-                    return new JsonModel([
+                        return new JsonModel([
+                            'success' => false,
+                            'data' => 'ERROR_THIS_USER_IS_NOT_A_CONNECTION'
-                        'success' => false,
+                        ]);
+                    }
-                        'data' => 'ERROR_THIS_USER_IS_NOT_A_CONNECTION'
+                } else {
+                    if($currentNetwork->network_id != $user->network_id) {
+                        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) {
      * ]
      * @return \Laminas\View\Model\JsonModel
      */
     public function sendAction()
+    {
+        $currentUserPlugin = $this->plugin('currentUserPlugin');
+        $currentUser = $currentUserPlugin->getUser();
+        $currentNetworkPlugin = $this->plugin('currentNetworkPlugin');
+        $currentNetwork = $currentNetworkPlugin->getNetwork();
         $request    = $this->getRequest();
         if($request->isPost()) {
             $id         = $this->params()->fromRoute('id');
                     'success' => false,
                     'data' => 'ERROR_PARAMETERS_ARE_INVALID'
                 ]);
+            }
-            $currentUserPlugin = $this->plugin('currentUserPlugin');
             $currentUser = $currentUserPlugin->getUser();
             $userMapper = UserMapper::getInstance($this->adapter);
             $sender_result = $userMapper->fetchOne($currentUser->id);
                         'success' => false,
                         'data' => 'ERROR_USER_NOT_FOUND'
                     ]);
+                }
+                if($currentNetwork->relationship_user_mode == Network::RELATIONSHIP_USER_MODE_USER_2_USER)  {
-                $connectionMapper = ConnectionMapper::getInstance($this->adapter);
+                    $connectionMapper = ConnectionMapper::getInstance($this->adapter);
-                $connection = $connectionMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
+                    $connection = $connectionMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
-                if(!$connection || $connection->status != Connection::STATUS_ACCEPTED) {
+                    if(!$connection || $connection->status != Connection::STATUS_ACCEPTED) {
-                    return new JsonModel([
+                        return new JsonModel([
-                        'success' => false,
+                            'success' => false,
-                        'data' => 'ERROR_THIS_USER_IS_NOT_A_CONNECTION'
+                            'data' => 'ERROR_THIS_USER_IS_NOT_A_CONNECTION'
+                        ]);
+                    }
+                } else {
+                    if($currentUser->network_id != $user->network_id) {
+                        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);
      * ]
      * @return \Laminas\View\Model\JsonModel
      */
     public function contactAvailableGroupListAction()
+    {
+        $currentUserPlugin = $this->plugin('currentUserPlugin');
+        $currentUser = $currentUserPlugin->getUser();
+        $currentNetworkPlugin = $this->plugin('currentNetworkPlugin');
+        $currentNetwork = $currentNetworkPlugin->getNetwork();
         $request    = $this->getRequest();
         if($request->isGet()) {
-            $currentUserPlugin = $this->plugin('currentUserPlugin');
-            $currentUser = $currentUserPlugin->getUser();
             $id = $this->params()->fromRoute('group_id');
             if(!$id) {
                 return new JsonModel([
             $contacts = $chatGroupUserMapper->fetchAllByGroupId($chatGroup->id);
             foreach($contacts as $contact)
+            {
                 array_push($contact_ids, $contact->user_id);
+            }
+            $user_ids = [];
+            if($currentNetwork->relationship_user_mode == Network::RELATIONSHIP_USER_MODE_USER_2_USER)  {
-            $connectionMapper = ConnectionMapper::getInstance($this->adapter);
+                $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);
+                }
+            }
-            $connection_ids = $connectionMapper->fetchAllConnectionsByUserReturnIds($currentUser->id);
-            $connection_ids = array_filter($connection_ids, function($var) use ( $contact_ids) {
+            $user_ids = array_filter($user_ids, function($var) use ( $contact_ids) {
                 return !in_array($var, $contact_ids);
             });
             $items = [];
-            foreach ($connection_ids as $connection_id)
+            foreach ($user_ids as $user_id)
+            {
-                $user = $userMapper->fetchOne($connection_id);
+                $user = $userMapper->fetchOne($user_id);
                 if (! $user) {
                     'image'     => $image,
                     'online'    => $user->online ? 1 : 0,
                 ]);
+            }
+            usort($items, function($a, $b) {
+                return $a['name'] <=> $b['name'];
+            });
+        }
         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 = [];
+            $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)
+                {
+                    $items[ $this->url()->fromRoute('chat/send', ['id' => $record->uuid]) ] = trim($record->first_name .  '  ' . $record->last_name) . ' (' . $record->email . ')';
+                }
+            }
+            $response = [
+                'success' => true,
+                'data' => $items
+            ];
+        } else {
+            $response = [
+                'success' => false,
+                'data' => 'ERROR_METHOD_NOT_ALLOWED'
+            ];
+        }
+        return new JsonModel($response);
+    }
     public function zoomAction()
+    {
         $request = $this->getRequest();

Proyectos de Subversion LeadersLinked - Antes de SPA

(root)/module/LeadersLinked/src/Controller/ChatController.php – Rev 4141 → 4857