WebSVN – LeadersLinked - Services – Diff – /module/LeadersLinked/src/Mapper/UserMapper.php

+    {
         $prototype = new User();
         $select = $this->sql->select(self::_TABLE);
         $select->where->equalTo('email', $email);
         $select->where->equalTo('network_id', $network_id);
         return $this->executeFetchOneObject($select, $prototype);
+    }
     /**
     public function fetchOneByUsernameXmpp($username_xmpp)
+    {
         $prototype = new User();
         $select = $this->sql->select(self::_TABLE);
         $select->where->equalTo('username_xmpp', $username_xmpp);
         //echo $select->getSqlString($this->adapter->platform); exit;
         return $this->executeFetchOneObject($select, $prototype);
+    }
     /**
+     *
      * @param $username_xmpp
      * @return void|User
      */
+    {
         $prototype = new User();
         $select = $this->sql->select(self::_TABLE);
         $select->where->like('username_xmpp', $username_xmpp . '%');
         $select->order('id desc');
         return $this->executeFetchOneObject($select, $prototype);
+    }
     /**
+     *
      * @param $username_xmpp
      * @return void|User
      */
         $prototype = new User();
         $select = $this->sql->select(self::_TABLE);
         $select->where->equalTo('username_xmpp', $username_xmpp);
         $select->where->equalTo('status', User::STATUS_ACTIVE);
         $select->where->equalTo('email_verified', User::EMAIL_VERIFIED_YES);
         //echo $select->getSqlString($this->adapter->platform); exit;
         return $this->executeFetchOneObject($select, $prototype);
+    }
+    {
         $hydrator = new ObjectPropertyHydrator();
         $values = $hydrator->extract($user);
         //$values = $this->removeEmpty($values);
         unset($values['added_on']);
         $values['updated_on'] = new Expression('NOW()');
         $update = $this->sql->update(self::_TABLE);
         $update->set($values);
         $update->where->equalTo('id', $user->id);
         $update->where->equalTo('id', $user->id);
         return $this->executeUpdate($update);
     }
     /**
+     *
      * @param User $user
         $values = [
             'first_name' => $user->first_name,
             'last_name' => $user->last_name,
             'updated_on' => new Expression('NOW()')
         ];
         $update = $this->sql->update(self::_TABLE);
         $update->set($values);
         $update->where->equalTo('id', $user->id);
         return $this->executeUpdate($update);
+    }
     /**
+     *
      * @param User $user
+    {
         $select = $this->sql->select();
         $select->columns(['status', 'backend', 'creator']);
         $select->from(['tb1' => CompanyUserMapper::_TABLE]);
         $select->join(['tb2' => self::_TABLE], 'tb1.user_id = tb2.id', [
+            'id',
+            'uuid',
+            'first_name',
+            'last_name',
+            'email',
-            'id', 'uuid', 'first_name', 'last_name', 'email', 'last_activity_on', 'image',
+            'last_activity_on',
+            'image',
+            'blocked',
+            'login_attempt',
-            'blocked', 'login_attempt', 'email_verified'
+            'email_verified'
         ]);
         $prototype = new User();
         return $this->executeFetchAllObject($select, $prototype);
     }
     /**
+     *
      * @param int $network_id
+     *
      * @return User[]
      */
     public function fetchAllSuggestPaginateByNetworkIdAndSearchAndNotBlocked($network_id, $search, $records_per_page, $page,  $userBlockedIds = [])
+    {
         $select = $this->sql->select();
         $select->from(self::_TABLE);
         $select->where->equalTo('network_id', $network_id);
         $select->where->equalTo('status', User::STATUS_ACTIVE);
         $select->where->equalTo('email_verified', User::EMAIL_VERIFIED_YES);
-        if($userBlockedIds) {
+        if ($userBlockedIds) {
             $select->where->notIn('id', $userBlockedIds);
+        }
         if ($search) {
             $select->where->nest()
-            ->like('first_name', '%' . $search . '%')
+                ->like('first_name', '%' . $search . '%')
-            ->or->like('last_name', '%' . $search . '%')
+                ->or->like('last_name', '%' . $search . '%')
-            ->or->like(new Expression("CONCAT(first_name,' ',last_name)"), '%' . $search . '%')
+                ->or->like(new Expression("CONCAT(first_name,' ',last_name)"), '%' . $search . '%')
-            ->or->like(new Expression("CONCAT(last_name,' ',first_name)"), '%' . $search . '%')
+                ->or->like(new Expression("CONCAT(last_name,' ',first_name)"), '%' . $search . '%')
-            ->or->like('email', '%' . $search . '%')
+                ->or->like('email', '%' . $search . '%')
-            ->unnest();
+                ->unnest();
+        }
         $select->order(['first_name', 'last_name']);
         // echo $select->getSqlString($this->adapter->platform); exit;
         $prototype = new User();
         $hydrator   = new ObjectPropertyHydrator();
         $resultset  = new HydratingResultSet($hydrator, $prototype);
         $adapter = new DbSelect($select, $this->sql, $resultset);
         $paginator = new Paginator($adapter);
         $paginator->setItemCountPerPage($records_per_page);
         $paginator->setCurrentPageNumber($page);
         return $paginator;
+    }
     /**
+     *
      * @param int $company_id
         $selectCompanyUsers->columns(['user_id']);
         $selectCompanyUsers->where->equalTo('company_id', $company_id);
         $selectCompanyUsers->where->in('status', [
             CompanyUser::STATUS_ACCEPTED,
             CompanyUser::STATUS_ADMIN_WILL_ADD,
         ]);
         //echo $selectCompanyUsers->getSqlString($this->adapter->platform); exit;
         $select = $this->sql->select();
         $select->from(self::_TABLE);
         $select->where->equalTo('network_id', $network_id);
         $select->where->equalTo('status', User::STATUS_ACTIVE);
         $select->where->equalTo('email_verified', User::EMAIL_VERIFIED_YES);
         if ($search) {
             $select->where->nest()
-            ->like('first_name', '%' . $search . '%')
+                ->like('first_name', '%' . $search . '%')
-            ->or->like('last_name', '%' . $search . '%')
+                ->or->like('last_name', '%' . $search . '%')
-            ->or->like('email', '%' . $search . '%')
+                ->or->like('email', '%' . $search . '%')
-            ->unnest();
+                ->unnest();
+        }
         $select->where->In('id', $selectCompanyUsers);
         $select->order(['first_name', 'last_name']);
-       // echo $select->getSqlString($this->adapter->platform); exit;
+        // echo $select->getSqlString($this->adapter->platform); exit;
         $prototype = new User();
         return $this->executeFetchAllObject($select, $prototype);
+    }
     /**
+     *
      * @param int $company_id
      * @param int $network_id
      * @param string $search
         $update->where->equalTo('id', $id);
         return $this->executeUpdate($update);
-    }
+    }
     /**
+     *
      * @param int $company_id
         $prototype = User();
         return $this->executeFetchAllObject($select, $prototype);
     }
     /**
+     *
      * @param string $username_inmail
         $prototype = new User();
         $select = $this->sql->select(self::_TABLE);
         $select->where->equalTo('username_inmail', $username_inmail);
         $select->where->equalTo('network_id', $network_id);
         $select->where->equalTo('status', User::STATUS_ACTIVE);
         //echo $select->getSqlString($this->adapter->platform); exit;
         return $this->executeFetchOneObject($select, $prototype);
+    }
+    /**
+     * Update the verification status of a user.
+     *
+     * @param User $user
+     * @param bool $is_verified
+     * @return boolean
+     */
+    public function updateUserEmailVerified($user, $is_verified)
+    {
+        $values = [
+            'email_verified' => $is_verified,
+            'updated_on'  => new Expression('NOW()')
+        ];
+        $update = $this->sql->update(self::_TABLE);
+        $update->set($values);
+        $update->where->equalTo('id', $user->id);
+        return $this->executeUpdate($update);
+    }
+    /**
+     * Update the blocked status of a user.
+     *
+     * @param User $user
+     * @param bool $is_blocked
+     * @return boolean
+     */
+    public function updateUserBlockedStatus($user, $is_blocked)
+    {
+        $values = [
+            'blocked' => $is_blocked,
+            'updated_on' => new Expression('NOW()')
+        ];
+        $update = $this->sql->update(self::_TABLE);
+        $update->set($values);
+        $update->where->equalTo('id', $user->id);
+        return $this->executeUpdate($update);
+    }
+    /**
+     * Update the status of a user.
+     *
+     * @param User $user
+     * @param string $status
+     * @return boolean
+     */
+    public function updateUserStatus($user, $status)
+    {
+        $values = [
+            'status'     => $status,
+            'updated_on' => new Expression('NOW()')
+        ];
+        $update = $this->sql->update(self::_TABLE);
+        $update->set($values);
+        $update->where->equalTo('id', $user->id);
+        return $this->executeUpdate($update);
+    }
+}

Proyectos de Subversion LeadersLinked - Services

(root)/module/LeadersLinked/src/Mapper/UserMapper.php – Rev 626 → 629