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

 use LeadersLinked\Model\ChatGroup;
 use LeadersLinked\Model\ChatUser;
 use LeadersLinked\Form\Chat\CreateGroupForm;
 use LeadersLinked\Mapper\ChatGroupUserMapper;
 use LeadersLinked\Model\ChatGroupUser;
+use LeadersLinked\Mapper\UtilMapper;
 class ChatController extends AbstractActionController
         $connectionMapper = ConnectionMapper:: getInstance($this->adapter);
         $connectionIds = $connectionMapper->fetchAllConnectionsByUserReturnIds( $currentUser->id );
         $contacts = [];
+        if($connectionIds) {
+            $utilMapper = UtilMapper::getInstance($this->adapter);
+            $now = $utilMapper->getDatebaseNow();
         if($connectionIds) {
             $userMapper = UserMapper::getInstance($this->adapter);
             $users = $userMapper->fetchAllByIds($connectionIds);
             foreach($users as $user)
-            {
-                $username = trim($user->first_name . ' ' . $user->last_name);
+            {
-                if($this->isInactiveConnection($user->last_heart_beat_at ? $user->last_heart_beat_at : '')) {
-                    $userMapper->updateChatOfflineStatus($user->id);
-                    $status = 'Offline';
-                } else {
-                    $status = "Online";
                 $username = trim($user->first_name . ' ' . $user->last_name);
                 $status = $user->online ? 'LABEL_ONLINE' : 'LABEL_OFFLINE';
                 $user_image = $this->url()->fromRoute('storage', ['type' => 'user', 'code' => $user->uuid, 'filename' => $user->image]);
                 $userMapper = UserMapper::getInstance($this->adapter);
                 $users = $userMapper->fetchAllByIds($connectionIds);
                 foreach ($users as $user)
-                {
-                    if ($this->isInactiveConnection($user->last_heart_beat_at ? $user->last_heart_beat_at : '')) {
-                        $userMapper->updateChatOfflineStatus($user->id);
-                        $online = false;
-                    } else {
-                        $online = true;
-                    }
+                {
                     $chatUser = $chatUserMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
                     if($chatUser) {
                         $count_not_received_messages = $chatMessageMapper->countNotReceivedMessagesByChatIdAndToId($chatUser->id, $currentUser->id);
                         $count_not_seen_messages = $chatMessageMapper->countNotSeenMessagesByChatIdAndToId($chatUser->id, $currentUser->id);
                         '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'                    => $online ? 1 : 0,
+                        '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,
                     $chatGroupUserMapper = ChatGroupUserMapper::getInstance($this->adapter);
                     $result = $chatGroupUserMapper->insert($chatGroupUser);
+                    if($result)  {
+                        $userMapper = UserMapper::getInstance($this->adapter);
                         $userMapper->updateLastActivity($currentUser->id);
                     if($result)  {
                         $fullpath_chat = $this->config['leaderslinked.fullpath.chat'];
                         $dirpath = $fullpath_chat . $chatGroup->uuid;
                         if (! file_exists($dirpath)) {
                     'success' => false,
                     'data' => $chatGroupUserMapper->getError()
                 ]);
+            }
-            if ($this->isInactiveConnection($user->last_heart_beat_at ? $user->last_heart_beat_at : '')) {
-                $userMapper->updateChatOfflineStatus($user->id);
-                $online = false;
-            } else {
-                $online = true;
-            }
             $userMapper->updateLastActivity($currentUser->id);
             return new JsonModel([
                 'success' => true,
                 'data' => [
                     'url_remove_from_group' => $this->url()->fromRoute('chat/remove-user-from-group', ['group_id' => $chatGroup->uuid, 'user_id' => $user->uuid]),
                     'id'        => $user->uuid,
                     'name'      => trim($user->first_name . ' ' . $user->last_name),
                     'image'     => $this->url()->fromRoute('storage', ['code' => $user->uuid, 'type' => 'user', 'filename' => $user->image]),
                     'type'      => 'user',
-                    'online'    => $online,
+                    'online'    => $user->online ? 1 : 0,
+                ]
+            }
+            $response = $chatGroupUserMapper->deleteByGroupIdAndUserId($chatGroup->id, $user->id);
+            if($response) {
-            $response = $chatGroupUserMapper->deleteByGroupIdAndUserId($chatGroup->id, $user->id);
+                $userMapper->updateLastActivity($currentUser->id);
             if($response) {
                 return new JsonModel([
                     'success' => true
                 ]);
+            }
+            $result = $chatGroupUserMapper->deleteByGroupIdAndUserId($chatGroupUser->group_id, $chatGroupUser->user_id);
+            if($result) {
+                $userMapper = UserMapper::getInstance($this->adapter);
-            $result = $chatGroupUserMapper->deleteByGroupIdAndUserId($chatGroupUser->group_id, $chatGroupUser->user_id);
+                $userMapper->updateLastActivity($currentUser->id);
             if($result) {
                 return new JsonModel([
                     'success' => true
                 ]);
         $items = [];
         $users = [];
+        $userMapper = UserMapper::getInstance($this->adapter);
+        $utilMapper = UtilMapper::getInstance($this->adapter);
-        $userMapper = UserMapper::getInstance($this->adapter);
+        $now = $utilMapper->getDatebaseNow();
         foreach ($paginator as $m)
+        {
                 $content = $this->sanitize($m->content);
             } else {
                 $content = $this->url()->fromRoute('storage', ['code' => $chatGroup->uuid, 'type' => 'chat', 'filename' => $m->content]);
+            }
-            $msgtime = $this->timeAgo($m->added_on);
+            $msgtime = $this->timeAgo($m->added_on, $now);
             array_push($items, [
                 'user_name' => trim($userdata_from->first_name . ' ' .$userdata_from->last_name) ,
                 'user_id' => $userdata_from->uuid,
                 'user_image' => $pic_from,
         $items = [];
         $users = [];
+        $userMapper = UserMapper::getInstance($this->adapter);
+        $utilMapper = UtilMapper::getInstance($this->adapter);
-        $userMapper = UserMapper::getInstance($this->adapter);
+        $now = $utilMapper->getDatebaseNow();
         $messages = $paginator->getCurrentItems();
         foreach ($messages as $m) {
                 $content = $this->sanitize($m->content);
             } else {
                 $content = $this->url()->fromRoute('storage', ['code' => $chatUser->uuid, 'type' => 'chat', 'filename' => $m->content]);
+            }
-            $msgtime = $this->timeAgo($m->added_on);
+            $msgtime = $this->timeAgo($m->added_on, $now);
             array_push($items, [
                 'user_name' => ($userdata_from->first_name . ' ' . $userdata_from->last_name),
                 'user_id' => $userdata_from->uuid,
                 'user_image' => $pic_from,
                 'seen' => $seen,
             ]);
+        }
-        if ($this->isInactiveConnection($currentUser->last_heart_beat_at ? $currentUser->last_heart_beat_at : '')) {
-            $userMapper->updateChatOfflineStatus($currentUser->id);
-            $online = false;
-        } else {
             $online = true;
         return [
             'success' => true,
             'data' => [
                 'page' => $page,
                 'pages' => $pages,
                 'items' => $items,
-                'online' => $online
+                'online' => $currentUser->online ? 1 : 0,
                                 'data' => $chatGroupUserMessageMapper->getError()
                             ]);
+                        }
+                    }
+                }
+                $utilMapper = UtilMapper::getInstance($this->adapter);
+                $now = $utilMapper->getDatebaseNow();
-                $msgtime = $this->timeAgo(date('Y-m-d H:i:s'));
+                $msgtime = $this->timeAgo($now, $now);
                 return new JsonModel([
                     'success' => true,
                     'data' => [
                         'user_name'         => $sender_name,
                         'data' => $chatMessageMapper->getError()
                     ]);
+                }
+                $chatMessage = $chatMessageMapper->fetchOne($chatMessage->id);
+                $utilMapper = UtilMapper::getInstance($this->adapter);
-                $chatMessage = $chatMessageMapper->fetchOne($chatMessage->id);
+                $now = $utilMapper->getDatebaseNow();
-                $msgtime = $this->timeAgo(date('Y-m-d H:i:s'));
+                $msgtime = $this->timeAgo($now, $now);
                 return new JsonModel([
                     'success' => true,
                     'data' => [
+                    ]
                  ]);
+            }
             $userMapper->updateLastActivity($currentUser->id);
             return new JsonModel($response);
                 $image  = $this->url()->fromRoute('storage', [
                     'code' => $user->uuid,
                     'type' => 'user',
                     'filename' => $user->image
                 ]);
-                if ($this->isInactiveConnection($user->last_heart_beat_at ? $user->last_heart_beat_at : '')) {
-                    $userMapper->updateChatOfflineStatus($user->id);
-                    $online = false;
-                } else {
-                    $online = true;
-                }
                 array_push($items, [
                     'id'        => $user->uuid,
                     'name'      => $name,
                     'image'     => $image,
-                    'online'    => $online,
+                    'online'    => $user->online ? 1 : 0,
+                ]);
+            }
                 ]);
             $userMapper->updateLastActivity($currentUser->id);
                 } else {
                     $url_remove_from_group = $this->url()->fromRoute('chat/remove-user-from-group', ['group_id' => $chatGroup->uuid, 'user_id' => $user->uuid ]);
-                }
-                if ($this->isInactiveConnection($user->last_heart_beat_at ? $user->last_heart_beat_at : '')) {
-                    $userMapper->updateChatOfflineStatus($user->id);
-                    $online = false;
-                } else {
                     $online = true;
                 array_push($items, [
                     'url_remove_from_group' => $url_remove_from_group,
                     'id'                    => $user->uuid,
                     'name'                  => $name,
                     'image'                 => $image,
+                    'online'                => $user->online ? 1 : 0,
+                ]);
                     'online'                => $online,
                 ]);
             $userMapper->updateLastActivity($currentUser->id);
             $fullpath_chat = $this->config['leaderslinked.fullpath.chat'];
             $dirpath = $fullpath_chat . $chatGroup->uuid;
+            Functions::rmDirRecursive($dirpath);
+            $userMapper = UserMapper::getInstance($this->adapter);
-            Functions::rmDirRecursive($dirpath);
+            $userMapper->updateLastActivity($currentUser->id);
             return new JsonModel([
             if($uuid) {
                 $_SESSION[self::SESSION_CHAT_OPEN_BOXES] = array_filter($_SESSION[self::SESSION_CHAT_OPEN_BOXES], function($var) use($uuid)  {
                     return $uuid != $var;
                 });
+            }
+            $userMapper->updateLastActivity($currentUser->id);
             return new JsonModel([
                 'success' => true
             ]);
                 $_SESSION[self::SESSION_CHAT_OPEN_BOXES] = array_filter($_SESSION[self::SESSION_CHAT_OPEN_BOXES], function($var) use($uuid)  {
                     return $uuid != $var;
                 });
+            }
+            $userMapper->updateLastActivity($currentUser->id);
             return new JsonModel([
                 'success' => true
             ]);
         } else {
+                        }
+                    }
+                }
+                $userMapper->updateLastActivity($currentUser->id);
-                    }
+                $utilMapper = UtilMapper::getInstance($this->adapter);
                 $now = $utilMapper->getDatebaseNow();
-                $msgtime = $this->timeAgo(date('Y-m-d H:i:s'));
+                $msgtime = $this->timeAgo($now, $now);
                 return new JsonModel([
                     'success' => true,
                     ]);
+                }
+                $chatMessage = $chatMessageMapper->fetchOne($chatMessage->id);
+                $userMapper->updateLastActivity($currentUser->id);
-                $chatMessage = $chatMessageMapper->fetchOne($chatMessage->id);
+                $utilMapper = UtilMapper::getInstance($this->adapter);
                 $now = $utilMapper->getDatebaseNow();
-                $msgtime = $this->timeAgo(date('Y-m-d H:i:s'));
+                $msgtime = $this->timeAgo($chatMessage->added_on, $now);
                 return new JsonModel([
                     'success' => true,
+    }
     /**
+     *
+     * @param string $timestamp
-     * @param string $timestamp
+     * @param string $now
      * @return string
      */
-    private function timeAgo($timestamp)
+    private function timeAgo($timestamp, $now = '')
+    {
+        if($now) {
+            $datetime1 = \DateTime::createFromFormat('Y-m-d H:i:s', $now);
+        } else {
-    {
+            $now = date('Y-m-d H:i:s');
+            $datetime1 = date_create($now);
         $datetime1 = new \DateTime("now");
+        $datetime2 = date_create($timestamp);
         $datetime2 = date_create($timestamp);
         $diff = date_diff($datetime1, $datetime2);
         $timemsg = '';
         if ($diff->y > 0) {
             $timemsg = $diff->y . ' año' . ($diff->y > 1 ? "s" : '');
+    }
     /**
+     *
+     * @param string $timestamp
-     * @param string $timestamp
+     * @param string $now
      * @return boolean
      */
-    private function isInactiveConnection($timestamp)
+    private function isInactiveConnection($timestamp, $now = '')
+    {
+        if($now) {
+            $datetime1 = \DateTime::createFromFormat('Y-m-d H:i:s', $now);
+        } else {
+            $now = date('Y-m-d H:i:s');
+            $datetime1 = date_create($now);
+        }
         if (empty($timestamp)) {
             return true;
-        }
+        }
         $now = date('Y-m-d H:i:s');
         $datetime1 = date_create($now);
         $datetime2 = date_create($timestamp);
         $diff = date_diff($datetime1, $datetime2);

Proyectos de Subversion LeadersLinked - Antes de SPA

(root)/module/LeadersLinked/src/Controller/ChatController.php – Rev 2614 → 3086