Renames uid to pid in watch_profile table.
[platal.git] / classes / profile.php
index 496b14d..f46eb15 100644 (file)
@@ -49,6 +49,11 @@ class Profile
     const DN_PUBLIC    = 'public_name';
     const DN_SHORT     = 'short_name';
     const DN_SORT      = 'sort_name';
+    /* education related names */
+    const EDU_X    = 'École polytechnique';
+    const DEGREE_X = 'Ingénieur';
+    const DEGREE_M = 'Master';
+    const DEGREE_D = 'Doctorat';
 
     static public $name_variants = array(
             self::LASTNAME => array(self::VN_MARITAL, self::VN_ORDINARY),
@@ -108,6 +113,11 @@ class Profile
         return $this->promo;
     }
 
+    public function yearpromo()
+    {
+        return intval(substr($this->promo, 1, 4));
+    }
+
     /** Print a name with the given formatting:
      * %s = • for women
      * %f = firstname
@@ -205,8 +215,8 @@ class Profile
 
     public function setVisibilityLevel($visibility)
     {
-        if ($visibility != self::VISIBILITY_PRIVATE 
-         && $visibility != self::VISIBILITY_AX 
+        if ($visibility != self::VISIBILITY_PRIVATE
+         && $visibility != self::VISIBILITY_AX
          && $visibility != self::VISIBILITY_PUBLIC) {
             Platal::page()->kill("Visibility invalide: " . $visibility);
         }
@@ -221,16 +231,14 @@ class Profile
      */
     public function getPhoto($fallback = true)
     {
-        /* TODO: migrate photo table to profile_photo, change uid to pid
-         */
         $cond = '';
         if ($this->visibility) {
             $cond = ' AND pub IN ' . XDB::formatArray($this->visibility);
         }
-        $res = XDB::query('SELECT  *
-                             FROM  photo
-                            WHERE  attachmime IN (\'jpeg\', \'png\')
-                                   ' . $cond . ' AND  uid = {?}',
+        $res = XDB::query("SELECT  *
+                             FROM  profile_photos
+                            WHERE  attachmime IN ('jpeg', 'png')
+                                   " . $cond . ' AND  pid = {?}',
                           $this->id());
         if ($res->numRows() > 0) {
             $photo = $res->fetchOneAssoc();
@@ -271,7 +279,7 @@ class Profile
         return XDB::iterator('SELECT  pa.text, pa.postalCode, pa.type, pa.latitude, pa.longitude,
                                       gl.name AS locality, gas.name AS subAdministrativeArea,
                                       ga.name AS administrativeArea, gc.countryFR AS country,
-                                      pp.tel_type, pp.display_tel,
+                                      ppfix.display_tel AS fixed_tel, ppfax.display_tel AS fax_tel,
                                       FIND_IN_SET(\'current\', pa.flags) AS current,
                                       FIND_IN_SET(\'temporary\', pa.flags) AS temporary,
                                       FIND_IN_SET(\'secondary\', pa.flags) AS secondary,
@@ -281,7 +289,8 @@ class Profile
                            LEFT JOIN  geoloc_administrativeareas AS ga ON (ga.id = pa.administrativeAreaId)
                            LEFT JOIN  geoloc_administrativeareas AS gas ON (gas.id = pa.subAdministrativeAreaId)
                            LEFT JOIN  geoloc_countries AS gc ON (gc.iso_3166_1_a2 = pa.countryId)
-                           LEFT JOIN  profile_phones AS pp ON (pp.link_type = \'address\' AND pp.uid = pa.pid AND pp.link_id = pa.id)
+                           LEFT JOIN  profile_phones AS ppfix ON (ppfix.link_type = \'address\' AND ppfix.pid = pa.pid AND ppfix.link_id = pa.id AND ppfix.tel_type = \'fixed\')
+                           LEFT JOIN  profile_phones AS ppfax ON (ppfax.link_type = \'address\' AND ppfax.pid = pa.pid AND ppfax.link_id = pa.id AND ppfax.tel_type = \'fax\')
                                WHERE  ' . $where . '
                             ORDER BY  pa.id
                                       ' . $limit);
@@ -302,7 +311,7 @@ class Profile
      */
     public function getEducations($flags, $limit = null)
     {
-        $where = XDB::format('pe.uid = {?}', $this->id());
+        $where = XDB::format('pe.pid = {?}', $this->id());
         if ($flags & self::EDUCATION_MAIN) {
             $where .= ' AND FIND_IN_SET(\'primary\', pe.flags)';
         } else if ($flags & self::EDUCATION_EXTRA) {
@@ -338,7 +347,7 @@ class Profile
 
     public function getNetworking($flags, $limit = null)
     {
-        $where = XDB::format('pn.uid = {?}', $this->id());
+        $where = XDB::format('pn.pid = {?}', $this->id());
         if ($flags & self::NETWORKING_WEB) {
             $where .= ' AND pn.network_type = 0'; // XXX hardcoded reference to web site index
         }
@@ -372,7 +381,7 @@ class Profile
 
     public function getJobs($flags, $limit = null)
     {
-        $where = XDB::format('pj.uid = {?}', $this->id());
+        $where = XDB::format('pj.pid = {?}', $this->id());
         $cond  = 'TRUE';
         if ($this->visibility) {
             $where .= ' AND pj.pub IN ' . XDB::formatArray($this->visibility);
@@ -408,8 +417,8 @@ class Profile
     public function getBinets()
     {
         return XDB::fetchColumn('SELECT  binet_id
-                                   FROM  binets_ins
-                                  WHERE  user_id = {?}', $this->id());
+                                   FROM  profile_binets
+                                  WHERE  pid = {?}', $this->id());
     }
 
 
@@ -418,35 +427,65 @@ class Profile
         return User::getSilent($this);
     }
 
-    private static function fetchProfileData(array $pids)
+    public function compareNames($firstname, $lastname)
+    {
+        $_lastname  = mb_strtoupper($this->lastName());
+        $_firstname = mb_strtoupper($this->firstName());
+        $lastname   = mb_strtoupper($lastname);
+        $firstname  = mb_strtoupper($firstname);
+
+        $isOk  = (mb_strtoupper($_firstname) == mb_strtoupper($firstname));
+        $tokens = preg_split("/[ \-']/", $lastname, -1, PREG_SPLIT_NO_EMPTY);
+        $maxlen = 0;
+
+        foreach ($tokens as $str) {
+            $isOk &= (strpos($_lastname, $str) !== false);
+            $maxlen = max($maxlen, strlen($str));
+        }
+
+        return ($isOk && ($maxlen > 2 || $maxlen == strlen($_lastname)));
+    }
+
+    private static function fetchProfileData(array $pids, $respect_order = true)
     {
         if (count($pids) == 0) {
             return array();
         }
-        return XDB::fetchAllAssoc('SELECT  p.*, p.sex = \'female\' AS sex, pe.entry_year, pe.grad_year,
-                                           pn_f.name AS firstname, pn_l.name AS lastname, pn_n.name AS nickname,
-                                           IF(pn_uf.name IS NULL, pn_f.name, pn_uf.name) AS firstname_ordinary,
-                                           IF(pn_ul.name IS NULL, pn_l.name, pn_ul.name) AS lastname_ordinary,
-                                           pd.promo AS promo, pd.short_name, pd.directory_name AS full_name,
-                                           pd.directory_name, pp.display_tel AS mobile, pp.pub AS mobile_pub,
-                                           ph.pub AS photo_pub
-                                     FROM  profiles AS p
-                               INNER JOIN  profile_display AS pd ON (pd.pid = p.pid)
-                               INNER JOIN  profile_education AS pe ON (pe.uid = p.pid AND FIND_IN_SET(\'primary\', pe.flags))
-                               INNER JOIN  profile_name AS pn_f ON (pn_f.pid = p.pid
-                                                                    AND pn_f.typeid = ' . self::getNameTypeId('firstname', true) . ')
-                               INNER JOIN  profile_name AS pn_l ON (pn_l.pid = p.pid
-                                                                    AND pn_l.typeid = ' . self::getNameTypeId('lastname', true) . ')
-                                LEFT JOIN  profile_name AS pn_uf ON (pn_uf.pid = p.pid
-                                                                     AND pn_uf.typeid = ' . self::getNameTypeId('firstname_ordinary', true) . ')
-                                LEFT JOIN  profile_name AS pn_ul ON (pn_ul.pid = p.pid
-                                                                     AND pn_ul.typeid = ' . self::getNameTypeId('lastname_ordinary', true) . ')
-                                LEFT JOIN  profile_name AS pn_n ON (pn_n.pid = p.pid 
-                                                                    AND pn_n.typeid = ' . self::getNameTypeId('nickname', true) . ')
-                                LEFT JOIN  profile_phones AS pp ON (pp.uid = p.pid AND pp.link_type = \'user\' AND tel_type = \'mobile\')
-                                LEFT JOIN  photo AS ph ON (ph.uid = p.pid)
-                                    WHERE  p.pid IN ' . XDB::formatArray($pids) . '
-                                 GROUP BY  p.pid');
+
+        if ($respect_order) {
+            $order = 'ORDER BY  ' . XDB::formatCustomOrder('p.pid', $pids);
+        } else {
+            $order = '';
+        }
+
+        return XDB::Iterator('SELECT  p.*, p.sex = \'female\' AS sex, pe.entry_year, pe.grad_year,
+                                      pn_f.name AS firstname, pn_l.name AS lastname, pn_n.name AS nickname,
+                                      IF(pn_uf.name IS NULL, pn_f.name, pn_uf.name) AS firstname_ordinary,
+                                      IF(pn_ul.name IS NULL, pn_l.name, pn_ul.name) AS lastname_ordinary,
+                                      pd.promo AS promo, pd.short_name, pd.directory_name AS full_name,
+                                      pd.directory_name, pp.display_tel AS mobile, pp.pub AS mobile_pub,
+                                      ph.attach IS NOT NULL AS has_photo, ph.pub AS photo_pub,
+                                      p.last_change < DATE_SUB(NOW(), INTERVAL 365 DAY) AS is_old,
+                                      ap.uid AS owner_id
+                                FROM  profiles AS p
+                          INNER JOIN  profile_display AS pd ON (pd.pid = p.pid)
+                          INNER JOIN  profile_education AS pe ON (pe.pid = p.pid AND FIND_IN_SET(\'primary\', pe.flags))
+                          INNER JOIN  profile_name AS pn_f ON (pn_f.pid = p.pid
+                                                               AND pn_f.typeid = ' . self::getNameTypeId('firstname', true) . ')
+                          INNER JOIN  profile_name AS pn_l ON (pn_l.pid = p.pid
+                                                               AND pn_l.typeid = ' . self::getNameTypeId('lastname', true) . ')
+                           LEFT JOIN  profile_name AS pn_uf ON (pn_uf.pid = p.pid
+                                                                AND pn_uf.typeid = ' . self::getNameTypeId('firstname_ordinary', true) . ')
+                           LEFT JOIN  profile_name AS pn_ul ON (pn_ul.pid = p.pid
+                                                                AND pn_ul.typeid = ' . self::getNameTypeId('lastname_ordinary', true) . ')
+                           LEFT JOIN  profile_name AS pn_n ON (pn_n.pid = p.pid
+                                                               AND pn_n.typeid = ' . self::getNameTypeId('nickname', true) . ')
+                           LEFT JOIN  profile_phones AS pp ON (pp.pid = p.pid AND pp.link_type = \'user\' AND tel_type = \'mobile\')
+                           LEFT JOIN  profile_photos AS ph ON (ph.pid = p.pid)
+                           LEFT JOIN  account_profiles AS ap ON (ap.pid = p.pid AND FIND_IN_SET(\'owner\', ap.perms))
+                               WHERE  p.pid IN ' . XDB::formatArray($pids) . '
+                            GROUP BY  p.pid
+                                   ' . $order);
     }
 
     public static function getPID($login)
@@ -467,15 +506,31 @@ class Profile
         }
     }
 
+    public static function getPIDsFromUIDs($uids, $respect_order = true)
+    {
+        if ($respect_order) {
+            $order = 'ORDER BY ' . XDB::formatCustomOrder('uid', $uids);
+        } else {
+            $order = '';
+        }
+        return XDB::fetchAllAssoc('uid', 'SELECT  ap.uid, ap.pid
+                                            FROM  account_profiles AS ap
+                                           WHERE  FIND_IN_SET(\'owner\', ap.perms)
+                                                  AND ap.uid IN ' . XDB::formatArray($uids) .'
+                                               ' . $order);
+    }
 
     /** Return the profile associated with the given login.
      */
     public static function get($login)
     {
+        if (is_array($login)) {
+            return new Profile($login);
+        }
         $pid = self::getPID($login);
         if (!is_null($pid)) {
-            $data = self::fetchProfileData(array($pid));
-            return new Profile(array_pop($data));
+            $it = self::iterOverPIDs(array($pid), false);
+            return $it->next();
         } else {
             /* Let say we can identify a profile using the identifiers of its owner.
              */
@@ -489,6 +544,16 @@ class Profile
         }
     }
 
+    public static function iterOverUIDs($uids, $respect_order = true)
+    {
+        return self::iterOverPIDs(self::getPIDsFromUIDs($uids), $respect_order);
+    }
+
+    public static function iterOverPIDs($pids, $respect_order = true)
+    {
+        return new ProfileIterator(self::fetchProfileData($pids, $respect_order));
+    }
+
     /** Return profiles for the list of pids.
      */
     public static function getBulkProfilesWithPIDs(array $pids)
@@ -496,13 +561,10 @@ class Profile
         if (count($pids) == 0) {
             return array();
         }
-        $data = self::fetchProfileData($pids);
-        $inv = array_flip($pids);
+        $it = self::iterOverPIDs($pids);
         $profiles = array();
-        foreach ($data AS $p) {
-            $p = new Profile($p);
-            $key = $inv[$p->id()];
-            $profiles[$key] = $p;
+        while ($p = $it->next()) {
+            $profiles[$p->id()] = $p;
         }
         return $profiles;
     }
@@ -514,11 +576,7 @@ class Profile
         if (count($uids) == 0) {
             return array();
         }
-        $table = XDB::fetchAllAssoc('uid', 'SELECT  ap.uid, ap.pid
-                                              FROM  account_profiles AS ap
-                                             WHERE  FIND_IN_SET(\'owner\', ap.perms)
-                                                    AND ap.uid IN ' . XDB::formatArray($uids));
-        return self::getBulkProfilesWithPIDs($table);
+        return self::getBulkProfilesWithPIDs(self::getPIDsFromUIDs($uids));
     }
 
     public static function isDisplayName($name)
@@ -544,6 +602,122 @@ class Profile
             return $table[$type];
         }
     }
+
+    public static function rebuildSearchTokens($pid)
+    {
+        XDB::execute('DELETE FROM  search_name
+                            WHERE  uid = {?}',
+                     $pid);
+        $keys = XDB::iterator("SELECT  CONCAT(n.particle, n.name) AS name, e.score,
+                                       FIND_IN_SET('public', e.flags) AS public
+                                 FROM  profile_name      AS n
+                           INNER JOIN  profile_name_enum AS e ON (n.typeid = e.id)
+                                WHERE  n.pid = {?}",
+                              $pid);
+
+        foreach ($keys as $i => $key) {
+            if ($key['name'] == '') {
+                continue;
+            }
+            $toks  = preg_split('/[ \'\-]+/', $key['name']);
+            $token = '';
+            $first = 5;
+            while ($toks) {
+                $token = strtolower(replace_accent(array_pop($toks) . $token));
+                $score = ($toks ? 0 : 10 + $first) * ($key['score'] / 10);
+                XDB::execute('REPLACE INTO  search_name (token, uid, soundex, score, flags)
+                                    VALUES  ({?}, {?}, {?}, {?}, {?})',
+                             $token, $uid, soundex_fr($token), $score, $key['public']);
+                $first = 0;
+            }
+        }
+    }
+
+    /** The school identifier consists of 6 digits. The first 3 represent the
+     * promotion entry year. The last 3 indicate the student's rank.
+     * 
+     * Our identifier consists of 8 digits and both half have the same role.
+     * This enables us to deal with bigger promotions and with a wider range
+     * of promotions.
+     *
+     * getSchoolId returns a school identifier given one of ours.
+     * getXorgId returns a X.org identifier given a school identifier.
+     */
+    public static function getSchoolId($xorgId)
+    {
+        if (!preg_match('/^[0-9]{8}$/', $xorgId)) {
+            return null;
+        }
+
+        $year = intval(substr($xorgId, 0, 4));
+        $rank = intval(substr($xorgId, 5, 3));
+        if ($year < 1996) {
+            return null;
+        } elseif ($year < 2000) {
+            $year = intval(substr(1900 - $year, 1, 3));
+            return sprintf('%02u0%03u', $year, $rank);
+        } else {
+            $year = intval(substr(1900 - $year, 1, 3));
+            return sprintf('%03u%03u', $year, $rank);
+        }
+    }
+
+    public static function getXorgId($schoolId)
+    {
+        if (!preg_match('/^[0-9]{6}$/', $schoolId)) {
+            return null;
+        }
+
+        $year = intval(substr($schoolId, 0, 3));
+        $rank = intval(substr($schoolId, 3, 3));
+
+        if ($year > 200) {
+            $year /= 10;
+        }
+        if ($year < 96) {
+            return null;
+        } else {
+            return sprintf('%04u%04u', 1900 + $year, $rank);
+        }
+    }
+}
+
+/** Iterator over a set of Profiles
+ * @param an XDB::Iterator obtained from a Profile::fetchProfileData
+ */
+class ProfileIterator implements PlIterator
+{
+    private $dbiter;
+
+    public function __construct($dbiter)
+    {
+        $this->dbiter = $dbiter;
+    }
+
+    public function next()
+    {
+        $data = $this->dbiter->next();
+        if ($data == null) {
+            return null;
+        } else {
+            return Profile::get($data);
+        }
+    }
+
+    public function total()
+    {
+        return $this->dbiter->total();
+    }
+
+    public function first()
+    {
+        return $this->dbiter->first();
+    }
+
+    public function last()
+    {
+        return $this->dbiter->last();
+    }
 }
 
 // vim:set et sw=4 sts=4 sws=4 foldmethod=marker enc=utf-8: