<?php
/***************************************************************************
- * Copyright (C) 2003-2009 Polytechnique.org *
+ * Copyright (C) 2003-2010 Polytechnique.org *
* http://opensource.polytechnique.org/ *
* *
* This program is free software; you can redistribute it and/or modify *
******************/
// {{{ interface UserFilterCondition
-interface UserFilterCondition
+/** This interface describe objects which filter users based
+ * on various parameters.
+ * The parameters of the filter must be given to the constructor.
+ * The buildCondition function is called by UserFilter when
+ * actually building the query. That function must call
+ * $uf->addWheteverFilter so that the UserFilter makes
+ * adequate joins. It must return the 'WHERE' condition to use
+ * with the filter.
+ */
+interface UserFilterCondition extends PlFilterCondition
{
- const COND_TRUE = 'TRUE';
- const COND_FALSE = 'FALSE';
-
- /** Check that the given user matches the rule.
- */
- public function buildCondition(UserFilter &$uf);
}
// }}}
-// {{{ class UFC_OneChild
-abstract class UFC_OneChild implements UserFilterCondition
+// {{{ class UFC_Profile
+/** Filters users who have a profile
+ */
+class UFC_Profile implements UserFilterCondition
{
- protected $child;
-
- public function __construct($child = null)
+ public function buildCondition(PlFilter &$uf)
{
- if (!is_null($child) && ($child instanceof UserFilterCondition)) {
- $this->setChild($child);
- }
- }
-
- public function setChild(UserFilterCondition &$cond)
- {
- $this->child =& $cond;
+ return '$PID IS NOT NULL';
}
}
// }}}
-// {{{ class UFC_NChildren
-abstract class UFC_NChildren implements UserFilterCondition
+// {{{ class UFC_Hruid
+/** Filters users based on their hruid
+ * @param $val Either an hruid, or a list of those
+ */
+class UFC_Hruid implements UserFilterCondition
{
- protected $children = array();
+ private $hruids;
- public function __construct()
+ public function __construct($val)
{
- $children = func_get_args();
- foreach ($children as &$child) {
- if (!is_null($child) && ($child instanceof UserFilterCondition)) {
- $this->addChild($child);
- }
+ if (!is_array($val)) {
+ $val = array($val);
}
+ $this->hruids = $val;
}
- public function addChild(UserFilterCondition &$cond)
+ public function buildCondition(PlFilter &$uf)
{
- $this->children[] =& $cond;
- }
+ $ufc->requireAccounts();
- protected function catConds(array $cond, $op, $fallback)
- {
- if (count($cond) == 0) {
- return $fallback;
- } else if (count($cond) == 1) {
- return $cond[0];
- } else {
- return '(' . implode(') ' . $op . ' (', $cond) . ')';
- }
+ return 'a.hruid IN ' . XDB::formatArray($this->hruids);
}
}
// }}}
-// {{{ class UFC_True
-class UFC_True implements UserFilterCondition
+// {{{ class UFC_Ip
+/** Filters users based on one of their last IPs
+ * @param $ip IP from which connection are checked
+ */
+class UFC_Ip implements UserFilterCondition
{
- public function buildCondition(UserFilter &$uf)
- {
- return self::COND_TRUE;
- }
-}
-// }}}
+ private $ip;
-// {{{ class UFC_False
-class UFC_False implements UserFilterCondition
-{
- public function buildCondition(UserFilter &$uf)
+ public function __construct($ip)
{
- return self::COND_FALSE;
+ $this->ip = $ip;
}
-}
-// }}}
-// {{{ class UFC_Not
-class UFC_Not extends UFC_OneChild
-{
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
- $val = $this->child->buildCondition($uf);
- if ($val == self::COND_TRUE) {
- return self::COND_FALSE;
- } else if ($val == self::COND_FALSE) {
- return self::COND_TRUE;
- } else {
- return 'NOT (' . $val . ')';
- }
+ $sub = $uf->addLoggerFilter();
+ $ip = ip_to_uint($this->ip);
+ return XDB::format($sub . '.ip = {?} OR ' . $sub . '.forward_ip = {?}', $ip, $ip);
}
}
// }}}
-// {{{ class UFC_And
-class UFC_And extends UFC_NChildren
+// {{{ class UFC_Comment
+class UFC_Comment implements UserFilterCondition
{
- public function buildCondition(UserFilter &$uf)
- {
- if (empty($this->children)) {
- return self::COND_FALSE;
- } else {
- $true = self::COND_FALSE;
- $conds = array();
- foreach ($this->children as &$child) {
- $val = $child->buildCondition($uf);
- if ($val == self::COND_TRUE) {
- $true = self::COND_TRUE;
- } else if ($val == self::COND_FALSE) {
- return self::COND_FALSE;
- } else {
- $conds[] = $val;
- }
- }
- return $this->catConds($conds, 'AND', $true);
- }
- }
-}
-// }}}
+ private $text;
-// {{{ class UFC_Or
-class UFC_Or extends UFC_NChildren
-{
- public function buildCondition(UserFilter &$uf)
+ public function __construct($text)
{
- if (empty($this->children)) {
- return self::COND_TRUE;
- } else {
- $true = self::COND_TRUE;
- $conds = array();
- foreach ($this->children as &$child) {
- $val = $child->buildCondition($uf);
- if ($val == self::COND_TRUE) {
- return self::COND_TRUE;
- } else if ($val == self::COND_FALSE) {
- $true = self::COND_FALSE;
- } else {
- $conds[] = $val;
- }
- }
- return $this->catConds($conds, 'OR', $true);
- }
+ $this->text = $text;
}
-}
-// }}}
-// {{{ class UFC_Profile
-/** Filters users who have a profile
- */
-class UFC_Profile implements UserFilterCondition
-{
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
- return '$PID IS NOT NULL';
+ $uf->requireProfiles();
+ return 'p.freetext ' . XDB::formatWildcards(XDB::WILDCARD_CONTAINS, $this->text);
}
}
// }}}
// {{{ class UFC_Promo
-/** Filters users based on promo
+/** Filters users based on promotion
* @param $comparison Comparison operator (>, =, ...)
* @param $grade Formation on which to restrict, UserFilter::DISPLAY for "any formation"
- * @param $promo Promo on which the filter is based
+ * @param $promo Promotion on which the filter is based
*/
class UFC_Promo implements UserFilterCondition
{
}
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
if ($this->grade == UserFilter::DISPLAY) {
$sub = $uf->addDisplayFilter();
- return XDB::format('pd' . $sub . '.promo = {?}', $this->promo);
+ return XDB::format('pd' . $sub . '.promo ' . $this->comparison . ' {?}', $this->promo);
} else {
$sub = $uf->addEducationFilter(true, $this->grade);
$field = 'pe' . $sub . '.' . UserFilter::promoYear($this->grade);
}
// }}}
+// {{{ class UFC_SchoolId
+/** Filters users based on their shoold identifier
+ * @param type Parameter type (Xorg, AX, School)
+ * @param value School id value
+ */
+class UFC_SchooldId implements UserFilterCondition
+{
+ const AX = 'ax';
+ const Xorg = 'xorg';
+ const School = 'school';
+
+ private $type;
+ private $id;
+
+ static public function assertType($type)
+ {
+ if ($type != self::AX && $type != self::Xorg && $type != self::School) {
+ Platal::page()->killError("Type de matricule invalide: $type");
+ }
+ }
+
+ public function __construct($type, $id)
+ {
+ $this->type = $type;
+ $this->id = $id;
+ self::assertType($type);
+ }
+
+ public function buildCondition(PlFilter &$uf)
+ {
+ $uf->requireProfiles();
+ $id = $this->id;
+ $type = $this->type;
+ if ($type == self::School) {
+ $type = self::Xorg;
+ $id = Profile::getXorgId($id);
+ }
+ return XDB::format('p.' . $type . '_id = {?}', $id);
+ }
+}
+// }}}
+
+// {{{ class UFC_EducationSchool
+/** Filters users by formation
+ * @param $val The formation to search (either ID or array of IDs)
+ */
+class UFC_EducationSchool implements UserFilterCondition
+{
+ private $val;
+
+ public function __construct($val)
+ {
+ if (!is_array($val)) {
+ $val = array($val);
+ }
+ $this->val = $val;
+ }
+
+ public function buildCondition(PlFilter &$uf)
+ {
+ $sub = $uf->addEducationFilter();
+ return 'pe' . $sub . '.eduid IN ' . XDB::formatArray($this->val);
+ }
+}
+// }}}
+
+// {{{ class UFC_EducationDegree
+class UFC_EducationDegree implements UserFilterCondition
+{
+ private $diploma;
+
+ public function __construct($diploma)
+ {
+ if (! is_array($diploma)) {
+ $diploma = array($diploma);
+ }
+ $this->diploma = $diploma;
+ }
+
+ public function buildCondition(PlFilter &$uf)
+ {
+ $sub = $uf->addEducationFilter();
+ return 'pee' . $sub . '.degreeid IN ' . XDB::formatArray($this->val);
+ }
+}
+// }}}
+
+// {{{ class UFC_EducationField
+class UFC_EducationField implements UserFilterCondition
+{
+ private $val;
+
+ public function __construct($val)
+ {
+ if (!is_array($val)) {
+ $val = array($val);
+ }
+ $this->val = $val;
+ }
+
+ public function buildCondition(PlFilter &$uf)
+ {
+ $sub = $uf->addEducationFilter();
+ return 'pee' . $sub . '.fieldid IN ' . XDB::formatArray($this->val);
+ }
+}
+// }}}
+
// {{{ class UFC_Name
/** Filters users based on name
- * @param $type Type of name field on which filtering is done (firstname, lastname, ...)
+ * @param $type Type of name field on which filtering is done (firstname, lastname...)
* @param $text Text on which to filter
- * @param $mode flag indicating search type (prefix, suffix, with particule, ...)
+ * @param $mode Flag indicating search type (prefix, suffix, with particule...)
*/
class UFC_Name implements UserFilterCondition
{
- const PREFIX = 1;
- const SUFFIX = 2;
- const PARTICLE = 7;
- const VARIANTS = 8;
- const CONTAINS = 3;
+ const PREFIX = XDB::WILDCARD_PREFIX; // 0x001
+ const SUFFIX = XDB::WILDCARD_SUFFIX; // 0x002
+ const CONTAINS = XDB::WILDCARD_CONTAINS; // 0x003
+ const PARTICLE = 0x007; // self::CONTAINS | 0x004
+ const VARIANTS = 0x008;
private $type;
private $text;
return str_replace('$ME', 'pn' . $sub, $where);
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
$left = '$ME.name';
- $op = ' LIKE ';
if (($this->mode & self::PARTICLE) == self::PARTICLE) {
$left = 'CONCAT($ME.particle, \' \', $ME.name)';
}
- if (($this->mode & self::CONTAINS) == 0) {
- $right = XDB::format('{?}', $this->text);
- $op = ' = ';
- } else if (($this->mode & self::CONTAINS) == self::PREFIX) {
- $right = XDB::format('CONCAT({?}, \'%\')', $this->text);
- } else if (($this->mode & self::CONTAINS) == self::SUFFIX) {
- $right = XDB::format('CONCAT(\'%\', {?})', $this->text);
- } else {
- $right = XDB::format('CONCAT(\'%\', {?}, \'%\')', $this->text);
- }
- $cond = $left . $op . $right;
+ $right = XDB::formatWildcards($this->mode & self::CONTAINS, $this->text);
+
+ $cond = $left . $right;
$conds = array($this->buildNameQuery($this->type, null, $cond, $uf));
- if (($this->mode & self::VARIANTS) != 0 && isset(UserFilter::$name_variants[$this->type])) {
- foreach (UserFilter::$name_variants[$this->type] as $var) {
+ if (($this->mode & self::VARIANTS) != 0 && isset(Profile::$name_variants[$this->type])) {
+ foreach (Profile::$name_variants[$this->type] as $var) {
$conds[] = $this->buildNameQuery($this->type, $var, $cond, $uf);
}
}
}
// }}}
+// {{{ class UFC_NameTokens
+/** Selects users based on tokens in their name (for quicksearch)
+ * @param $tokens An array of tokens to search
+ * @param $flags Flags the tokens must have (e.g 'public' for public search)
+ * @param $soundex (bool) Whether those tokens are fulltext or soundex
+ */
+class UFC_NameTokens implements UserFilterCondition
+{
+ /* Flags */
+ const FLAG_PUBLIC = 'public';
+
+ private $tokens;
+ private $flags;
+ private $soundex;
+ private $exact;
+
+ public function __construct($tokens, $flags = array(), $soundex = false, $exact = false)
+ {
+ $this->tokens = $tokens;
+ if (is_array($flags)) {
+ $this->flags = $flags;
+ } else {
+ $this->flags = array($flags);
+ }
+ $this->soundex = $soundex;
+ $this->exact = $exact;
+ }
+
+ public function buildCondition(PlFilter &$uf)
+ {
+ $sub = $uf->addNameTokensFilter(!($this->exact || $this->soundex));
+ $conds = array();
+ if ($this->soundex) {
+ $conds[] = $sub . '.soundex IN ' . XDB::formatArray($this->tokens);
+ } else if ($this->exact) {
+ $conds[] = $sub . '.token IN ' . XDB::formatArray($this->tokens);
+ } else {
+ $tokconds = array();
+ foreach ($this->tokens as $token) {
+ $tokconds[] = $sub . '.token ' . XDB::formatWildcards(XDB::WILDCARD_CONTAINS, $token);
+ }
+ $conds[] = implode(' OR ', $tokconds);
+ }
+
+ if ($this->flags != null) {
+ $conds[] = $sub . '.flags IN ' . XDB::formatArray($this->flags);
+ }
+
+ return implode(' AND ', $conds);
+ }
+}
+// }}}
+
+// {{{ class UFC_Nationality
+class UFC_Nationality implements UserFilterCondition
+{
+ private $val;
+
+ public function __construct($val)
+ {
+ if (!is_array($val)) {
+ $val = array($val);
+ }
+ $this->val = $val;
+ }
+
+ public function buildCondition(PlFilter &$uf)
+ {
+ $uf->requireProfiles();
+ $nat = XDB::formatArray($this->val);
+ $conds = array(
+ 'p.nationality1 IN ' . $nat,
+ 'p.nationality2 IN ' . $nat,
+ 'p.nationality3 IN ' . $nat,
+ );
+ return implode(' OR ', $conds);
+ }
+}
+// }}}
+
// {{{ class UFC_Dead
/** Filters users based on death date
* @param $comparison Comparison operator
$this->date = $date;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
+ $uf->requireProfiles();
$str = 'p.deathdate IS NOT NULL';
if (!is_null($this->comparison)) {
$str .= ' AND p.deathdate ' . $this->comparison . ' ' . XDB::format('{?}', date('Y-m-d', $this->date));
public function __construct($active = false, $comparison = null, $date = null)
{
- $this->only_active = $active;
+ $this->active = $active;
$this->comparison = $comparison;
$this->date = $date;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
+ $uf->requireAccounts();
if ($this->active) {
$date = 'a.uid IS NOT NULL AND a.state = \'active\'';
} else {
$this->date = $date;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
+ $uf->requireProfiles();
return 'p.last_change ' . $this->comparison . XDB::format(' {?}', date('Y-m-d H:i:s', $this->date));
}
}
$this->date = $date;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
+ $uf->requireProfiles();
return 'p.next_birthday ' . $this->comparison . XDB::format(' {?}', date('Y-m-d', $this->date));
}
}
$this->sex = $sex;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
if ($this->sex != User::GENDER_MALE && $this->sex != User::GENDER_FEMALE) {
return self::COND_FALSE;
} else {
+ $uf->requireProfiles();
return XDB::format('p.sex = {?}', $this->sex == User::GENDER_FEMALE ? 'female' : 'male');
}
}
// {{{ class UFC_Group
/** Filters users based on group membership
- * @param $group Group whose member we are selecting
- * @param $admin Whether to restrict selection to admins of that group
+ * @param $group Group whose members we are selecting
+ * @param $anim Whether to restrict selection to animators of that group
*/
class UFC_Group implements UserFilterCondition
{
private $group;
- private $admin;
- public function __construct($group, $admin = false)
+ private $anim;
+ public function __construct($group, $anim = false)
{
$this->group = $group;
- $this->admin = $admin;
+ $this->anim = $anim;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
$sub = $uf->addGroupFilter($this->group);
$where = 'gpm' . $sub . '.perms IS NOT NULL';
- if ($this->admin) {
+ if ($this->anim) {
$where .= ' AND gpm' . $sub . '.perms = \'admin\'';
}
return $where;
}
// }}}
+// {{{ class UFC_Binet
+/** Selects users based on their belonging to a given (list of) binet
+ * @param $binet either a binet_id or an array of binet_ids
+ */
+class UFC_Binet implements UserFilterCondition
+{
+ private $val;
+
+ public function __construct($val)
+ {
+ if (!is_array($val)) {
+ $val = array($val);
+ }
+ $this->val = $val;
+ }
+
+ public function buildCondition(PlFilter &$uf)
+ {
+ $sub = $uf->addBinetsFilter();
+ return $sub . '.binet_id IN ' . XDB::formatArray($this->val);
+ }
+}
+// }}}
+
+// {{{ class UFC_Section
+/** Selects users based on section
+ * @param $section ID of the section
+ */
+class UFC_Section implements UserFilterCondition
+{
+ private $section;
+
+ public function __construct($section)
+ {
+ $this->section = $section;
+ }
+
+ public function buildCondition(PlFilter &$uf)
+ {
+ $uf->requireProfiles();
+ return 'p.section = ' . XDB::format('{?}', $this->section);
+ }
+}
+// }}}
+
// {{{ class UFC_Email
/** Filters users based on email address
* @param $email Email whose owner we are looking for
$this->email = $email;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
if (User::isForeignEmailAddress($this->email)) {
$sub = $uf->addEmailRedirectFilter($this->email);
// }}}
// {{{ class UFC_EmailList
-/** Filters users base on an email list
+/** Filters users based on an email list
* @param $emails List of emails whose owner must be selected
*/
class UFC_EmailList implements UserFilterCondition
$this->emails = $emails;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
$email = null;
$virtual = null;
$cond = array();
if (count($this->emails) == 0) {
- return UserFilterCondition::COND_TRUE;
+ return PlFilterCondition::COND_TRUE;
}
foreach ($this->emails as $entry) {
// }}}
// {{{ class UFC_Address
-/** Filters users based on their address
- * @param $field Field of the address used for filtering (city, street, ...)
- * @param $text Text for filter
- * @param $mode Mode for search (PREFIX, SUFFIX, ...)
+abstract class UFC_Address implements UserFilterCondition
+{
+ /** Valid address type ('hq' is reserved for company addresses)
+ */
+ const TYPE_HOME = 1;
+ const TYPE_PRO = 2;
+ const TYPE_ANY = 3;
+
+ /** Text for these types
+ */
+ protected static $typetexts = array(
+ self::TYPE_HOME => 'home',
+ self::TYPE_PRO => 'pro',
+ );
+
+ protected $type;
+
+ /** Flags for addresses
+ */
+ const FLAG_CURRENT = 0x0001;
+ const FLAG_TEMP = 0x0002;
+ const FLAG_SECOND = 0x0004;
+ const FLAG_MAIL = 0x0008;
+ const FLAG_CEDEX = 0x0010;
+
+ // Binary OR of those flags
+ const FLAG_ANY = 0x001F;
+
+ /** Text of these flags
+ */
+ protected static $flagtexts = array(
+ self::FLAG_CURRENT => 'current',
+ self::FLAG_TEMP => 'temporary',
+ self::FLAG_SECOND => 'secondary',
+ self::FLAG_MAIL => 'mail',
+ self::FLAG_CEDEX => 'cedex',
+ );
+
+ protected $flags;
+
+ public function __construct($type = null, $flags = null)
+ {
+ $this->type = $type;
+ $this->flags = $flags;
+ }
+
+ protected function initConds($sub)
+ {
+ $conds = array();
+ $types = array();
+ foreach (self::$typetexts as $flag => $type) {
+ if ($flag & $this->type) {
+ $types[] = $type;
+ }
+ }
+ if (count($types)) {
+ $conds[] = $sub . '.type IN ' . XDB::formatArray($types);
+ }
+
+ if ($this->flags != self::FLAG_ANY) {
+ foreach(self::$flagtexts as $flag => $text) {
+ if ($flag & $this->flags) {
+ $conds[] = 'FIND_IN_SET(' . XDB::format('{?}', $text) . ', ' . $sub . '.flags)';
+ }
+ }
+ }
+ return $conds;
+ }
+
+}
+// }}}
+
+// {{{ class UFC_AddressText
+/** Select users based on their address, using full text search
+ * @param $text Text for filter in fulltext search
+ * @param $textSearchMode Mode for search (one of XDB::WILDCARD_*)
+ * @param $type Filter on address type
+ * @param $flags Filter on address flags
+ * @param $country Filter on address country
+ * @param $locality Filter on address locality
*/
-class UFC_Address implements UserFilterCondition
+class UFC_AddressText extends UFC_Address
{
- const PREFIX = 1;
- const SUFFIX = 2;
- const CONTAINS = 3;
- private $field;
private $text;
- private $mode;
+ private $textSearchMode;
- public function __construct($field, $text, $mode)
+ public function __construct($text = null, $textSearchMode = XDB::WILDCARD_CONTAINS,
+ $type = null, $flags = self::FLAG_ANY, $country = null, $locality = null)
{
- $this->field = $field;
- $this->text = $text;
- $this->mode = $mode;
+ parent::__construct($type, $flags);
+ $this->text = $text;
+ $this->textSearchMode = $textSearchMode;
+ $this->country = $country;
+ $this->locality = $locality;
}
- public function buildCondition(UserFilter &$uf)
+ private function mkMatch($txt)
{
- $left = 'pa.' . $field;
- $op = ' LIKE ';
- if (($this->mode & self::CONTAINS) == 0) {
- $right = XDB::format('{?}', $this->text);
- $op = ' = ';
- } else if (($this->mode & self::CONTAINS) == self::PREFIX) {
- $right = XDB::format('CONCAT({?}, \'%\')', $this->text);
- } else if (($this->mode & self::CONTAINS) == self::SUFFIX) {
- $right = XDB::format('CONCAT(\'%\', {?})', $this->text);
- } else {
- $right = XDB::format('CONCAT(\'%\', {?}, \'%\')', $this->text);
+ return XDB::formatWildcards($this->textSearchMode, $txt);
+ }
+
+ public function buildCondition(PlFilter &$uf)
+ {
+ $sub = $uf->addAddressFilter();
+ $conds = $this->initConds($sub);
+ if ($this->text != null) {
+ $conds[] = $sub . '.text' . $this->mkMatch($this->text);
}
- $cond = $left . $op . $right;
- $uf->addAddressFilter();
- return $cond;
+
+ if ($this->country != null) {
+ $subc = $uf->addAddressCountryFilter();
+ $subconds = array();
+ $subconds[] = $subc . '.country' . $this->mkMatch($this->country);
+ $subconds[] = $subc . '.countryFR' . $this->mkMatch($this->country);
+ $conds[] = implode(' OR ', $subconds);
+ }
+
+ if ($this->locality != null) {
+ $subl = $uf->addAddressLocalityFilter();
+ $conds[] = $subl . '.name' . $this->mkMatch($this->locality);
+ }
+
+ return implode(' AND ', $conds);
+ }
+}
+// }}}
+
+// {{{ class UFC_AddressField
+/** Filters users based on their address,
+ * @param $val Either a code for one of the fields, or an array of such codes
+ * @param $fieldtype The type of field to look for
+ * @param $type Filter on address type
+ * @param $flags Filter on address flags
+ */
+class UFC_AddressField extends UFC_Address
+{
+ const FIELD_COUNTRY = 1;
+ const FIELD_ADMAREA = 2;
+ const FIELD_SUBADMAREA = 3;
+ const FIELD_LOCALITY = 4;
+ const FIELD_ZIPCODE = 5;
+
+ /** Data of the filter
+ */
+ private $val;
+ private $fieldtype;
+
+ public function __construct($val, $fieldtype, $type = null, $flags = self::FLAG_ANY)
+ {
+ parent::__construct($type, $flags);
+
+ if (!is_array($val)) {
+ $val = array($val);
+ }
+ $this->val = $val;
+ $this->fieldtype = $fieldtype;
+ }
+
+ public function buildCondition(PlFilter &$uf)
+ {
+ $sub = $uf->addAddressFilter();
+ $conds = $this->initConds($sub);
+
+ switch ($this->fieldtype) {
+ case self::FIELD_COUNTRY:
+ $field = 'countryId';
+ break;
+ case self::FIELD_ADMAREA:
+ $field = 'administrativeAreaId';
+ break;
+ case self::FIELD_SUBADMAREA:
+ $field = 'subAdministrativeAreaId';
+ break;
+ case self::FIELD_LOCALITY:
+ $field = 'localityId';
+ break;
+ case self::FIELD_ZIPCODE:
+ $field = 'postalCode';
+ break;
+ default:
+ Platal::page()->killError('Invalid address field type: ' . $this->fieldtype);
+ }
+ $conds[] = $sub . '.' . $field . ' IN ' . XDB::formatArray($this->val);
+
+ return implode(' AND ', $conds);
}
}
// }}}
*/
class UFC_Corps implements UserFilterCondition
{
- const CURRENT=1;
- const ORIGIN=2;
+ const CURRENT = 1;
+ const ORIGIN = 2;
private $corps;
private $type;
$this->type = $type;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
- /** Tables shortcuts :
- * pc for profile corps,
+ /** Tables shortcuts:
+ * pc for profile_corps,
* pceo for profile_corps_enum - orginal
* pcec for profile_corps_enum - current
*/
$this->rank = $rank;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
- /** Tables shortcuts :
+ /** Tables shortcuts:
* pcr for profile_corps_rank
*/
$sub = $uf->addCorpsRankFilter();
* @param $type The field being searched (self::JOBID, self::JOBNAME or self::JOBACRONYM)
* @param $value The searched value
*/
-class UFC_Job_Company extends UserFilterCondition
+class UFC_Job_Company implements UserFilterCondition
{
const JOBID = 'id';
const JOBNAME = 'name';
private function assertType($type)
{
if ($type != self::JOBID && $type != self::JOBNAME && $type != self::JOBACRONYM) {
- Platal::page()->killError("Type de recherche non valide");
+ Platal::page()->killError("Type de recherche non valide.");
}
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
$sub = $uf->addJobCompanyFilter();
$cond = $sub . '.' . $this->type . ' = ' . XDB::format('{?}', $this->value);
// {{{ class UFC_Job_Sectorization
/** Filters users based on the ((sub)sub)sector they work in
- * @param $sector The sector searched
- * @param $subsector The subsector
- * @param $subsubsector The subsubsector
+ * @param $val The ID of the sector, or an array of such IDs
+ * @param $type The kind of search (subsubsector/subsector/sector)
*/
-class UFC_Job_Sectorization extends UserFilterCondition
+class UFC_Job_Sectorization implements UserFilterCondition
{
+ private $val;
+ private $type;
- private $sector;
- private $subsector;
- private $subsubsector;
-
- public function __construct($sector = null, $subsector = null, $subsubsector = null)
+ public function __construct($val, $type = UserFilter::JOB_SECTOR)
{
- $this->sector = $sector;
- $this->subsector = $subsector;
- $this->subsubsector = $subsubsector;
+ self::assertType($type);
+ if (!is_array($val)) {
+ $val = array($val);
+ }
+ $this->val = $val;
+ $this->type = $type;
}
- public function buildCondition(UserFilter &$uf)
+ private static function assertType($type)
{
- // No need to add the JobFilter, it will be done by addJobSectorizationFilter
- $conds = array();
- if ($this->sector !== null) {
- $sub = $uf->addJobSectorizationFilter(UserFilter::JOB_SECTOR);
- $conds[] = $sub . '.id = ' . XDB::format('{?}', $this->sector);
- }
- if ($this->subsector !== null) {
- $sub = $uf->addJobSectorizationFilter(UserFilter::JOB_SUBSECTOR);
- $conds[] = $sub . '.id = ' . XDB::format('{?}', $this->subsector);
+ if ($type != UserFilter::JOB_SECTOR && $type != UserFilter::JOB_SUBSECTOR && $type != UserFilter::JOB_SUBSUBSECTOR) {
+ Platal::page()->killError("Type de secteur non valide.");
}
- if ($this->subsubsector !== null) {
- $sub = $uf->addJobSectorizationFilter(UserFilter::JOB_SUBSUBSECTOR);
- $conds[] = $sub . '.id = ' . XDB::format('{?}', $this->subsubsector);
- }
- return implode(' AND ', $conds);
+ }
+
+ public function buildCondition(PlFilter &$uf)
+ {
+ $sub = $uf->addJobSectorizationFilter($this->type);
+ return $sub . '.id = ' . XDB::format('{?}', $this->val);
}
}
// }}}
* @param $description The text being searched for
* @param $fields The fields to search for (user-defined, ((sub|)sub|)sector)
*/
-class UFC_Job_Description extends UserFilterCondition
+class UFC_Job_Description implements UserFilterCondition
{
- /** Meta-filters
- * Built with binary OR on UserFilter::JOB_*
- */
- const ANY = 31;
- const SECTORIZATION = 15;
-
private $description;
private $fields;
- public function __construct($description)
+ public function __construct($description, $fields)
{
$this->fields = $fields;
$this->description = $description;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
$conds = array();
if ($this->fields & UserFilter::JOB_USERDEFINED) {
$sub = $uf->addJobFilter();
- $conds[] = $sub . '.description LIKE ' . XDB::format('CONCAT(\'%\', {?}, \'%\')', $this->description);
+ $conds[] = $sub . '.description ' . XDB::formatWildcards(XDB::WILDCARD_CONTAINS, $this->description);
+ }
+ if ($this->fields & UserFilter::JOB_CV) {
+ $uf->requireProfiles();
+ $conds[] = 'p.cv ' . XDB::formatWildcards(XDB::WILDCARD_CONTAINS, $this->description);
}
if ($this->fields & UserFilter::JOB_SECTOR) {
$sub = $uf->addJobSectorizationFilter(UserFilter::JOB_SECTOR);
- $conds[] = $sub . '.name LIKE ' . XDB::format('CONCAT(\'%\', {?}, \'%\')', $this->description);
+ $conds[] = $sub . '.name ' . XDB::formatWildcards(XDB::WILDCARD_CONTAINS, $this->description);
}
if ($this->fields & UserFilter::JOB_SUBSECTOR) {
$sub = $uf->addJobSectorizationFilter(UserFilter::JOB_SUBSECTOR);
- $conds[] = $sub . '.name LIKE ' . XDB::format('CONCAT(\'%\', {?}, \'%\')', $this->description);
+ $conds[] = $sub . '.name ' . XDB::formatWildcards(XDB::WILDCARD_CONTAINS, $this->description);
}
if ($this->fields & UserFilter::JOB_SUBSUBSECTOR) {
$sub = $uf->addJobSectorizationFilter(UserFilter::JOB_SUBSUBSECTOR);
- $conds[] = $sub . '.name LIKE ' . XDB::format('CONCAT(\'%\', {?}, \'%\')', $this->description);
+ $conds[] = $sub . '.name ' . XDB::formatWildcards(XDB::WILDCARD_CONTAINS, $this->description);
$sub = $uf->addJobSectorizationFilter(UserFilter::JOB_ALTERNATES);
- $conds[] = $sub . '.name LIKE ' . XDB::format('CONCAT(\'%\', {?}, \'%\')', $this->description);
+ $conds[] = $sub . '.name ' . XDB::formatWildcards(XDB::WILDCARD_CONTAINS, $this->description);
}
return implode(' OR ', $conds);
}
* @param $type Type of network (-1 for any)
* @param $value Value to search
*/
-class UFC_Networking extends UserFilterCondition
+class UFC_Networking implements UserFilterCondition
{
private $type;
private $value;
$this->value = $value;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
$sub = $uf->addNetworkingFilter();
$conds = array();
- $conds[] = $sub . '.address = ' . XDB::format('CONCAT(\'%\', {?}, \'%\')', $this->value);
+ $conds[] = $sub . '.address ' . XDB::formatWildcards(XDB::WILDCARD_CONTAINS, $this->value);
if ($this->type != -1) {
$conds[] = $sub . '.network_type = ' . XDB::format('{?}', $this->type);
}
* @param $phone_type Type of phone (fixed/mobile/fax)
* @param $number Phone number
*/
-class UFC_Phone extends UserFilterCondition
+class UFC_Phone implements UserFilterCondition
{
const NUM_PRO = 'pro';
const NUM_USER = 'user';
public function __construct($number, $num_type = self::NUM_ANY, $phone_type = self::PHONE_ANY)
{
- require_once('profil.inc.php');
+ require_once('profil.func.inc.php');
$this->number = $number;
$this->num_type = $num_type;
$this->phone_type = format_phone_number($phone_type);
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
$sub = $uf->addPhoneFilter();
$conds = array();
* @param $medal ID of the medal
* @param $grade Grade of the medal (null for 'any')
*/
-class UFC_Medal extends UserFilterCondition
+class UFC_Medal implements UserFilterCondition
{
private $medal;
private $grade;
$this->grade = $grade;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
$conds = array();
$sub = $uf->addMedalFilter();
/** Filters users by mentoring expertise
* @param $expertise Domain of expertise
*/
-class UFC_Mentor_Expertise extends UserFilterCondition
+class UFC_Mentor_Expertise implements UserFilterCondition
{
private $expertise;
$this->expertise = $expertise;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
$sub = $uf->addMentorFilter(UserFilter::MENTOR_EXPERTISE);
- return $sub . '.expertise LIKE ' . XDB::format('CONCAT(\'%\', {?}, \'%\'', $this->expertise);
+ return $sub . '.expertise ' . XDB::formatWildcards(XDB::WILDCARD_CONTAINS, $this->expertise);
}
}
// }}}
/** Filters users by mentoring country
* @param $country Two-letters code of country being searched
*/
-class UFC_Mentor_Country extends UserFilterCondition
+class UFC_Mentor_Country implements UserFilterCondition
{
private $country;
$this->country = $country;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
$sub = $uf->addMentorFilter(UserFilter::MENTOR_COUNTRY);
return $sub . '.country = ' . XDB::format('{?}', $this->country);
// {{{ class UFC_Mentor_Sectorization
/** Filters users based on mentoring (sub|)sector
- * @param $sector ID of sector
- * @param $subsector Subsector (null for any)
+ * @param $sector ID of (sub)sector
+ * @param $type Whether we are looking for a sector or a subsector
*/
-class UFC_Mentor_Sectorization extends UserFilterCondition
+class UFC_Mentor_Sectorization implements UserFilterCondition
{
+ const SECTOR = 1;
+ const SUBSECTOR = 2;
private $sector;
- private $subsector;
+ private $type;
- public function __construct($sector, $subsector = null)
+ public function __construct($sector, $type = self::SECTOR)
{
$this->sector = $sector;
- $this->subsubsector = $subsector;
+ $this->type = $type;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
$sub = $uf->addMentorFilter(UserFilter::MENTOR_SECTOR);
- $conds = array();
- $conds[] = $sub . '.sectorid = ' . XDB::format('{?}', $this->sector);
- if ($this->subsector != null) {
- $conds[] = $sub . '.subsectorid = ' . XDB::format('{?}', $this->subsector);
+ if ($this->type == self::SECTOR) {
+ $field = 'sectorid';
+ } else {
+ $field = 'subsectorid';
}
- return implode(' AND ', $conds);
+ return $sub . '.' . $field . ' = ' . XDB::format('{?}', $this->sector);
}
}
// }}}
// {{{ class UFC_UserRelated
-/** Filters users based on a relation toward on user
+/** Filters users based on a relation toward a user
* @param $user User to which searched users are related
*/
abstract class UFC_UserRelated implements UserFilterCondition
// }}}
// {{{ class UFC_Contact
-/** Filters users who belongs to selected user's contacts
+/** Filters users who belong to selected user's contacts
*/
class UFC_Contact extends UFC_UserRelated
{
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
$sub = $uf->addContactFilter($this->user->id());
return 'c' . $sub . '.contact IS NOT NULL';
*/
class UFC_WatchRegistration extends UFC_UserRelated
{
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
- if (!$this->user->watch('registration')) {
- return UserFilterCondition::COND_FALSE;
+ if (!$this->user->watchType('registration')) {
+ return PlFilterCondition::COND_FALSE;
}
$uids = $this->user->watchUsers();
if (count($uids) == 0) {
- return UserFilterCondition::COND_FALSE;
+ return PlFilterCondition::COND_FALSE;
} else {
return '$UID IN ' . XDB::formatArray($uids);
}
$this->grade = $grade;
}
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
$promos = $this->user->watchPromos();
if (count($promos) == 0) {
- return UserFilterCondition::COND_FALSE;
+ return PlFilterCondition::COND_FALSE;
} else {
$sube = $uf->addEducationFilter(true, $this->grade);
$field = 'pe' . $sube . '.' . UserFilter::promoYear($this->grade);
*/
class UFC_WatchContact extends UFC_Contact
{
- public function buildCondition(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
if (!$this->user->watchContacts()) {
- return UserFilterCondition::COND_FALSE;
+ return PlFilterCondition::COND_FALSE;
}
return parent::buildCondition($uf);
}
}
// }}}
-
-/******************
- * ORDERS
- ******************/
-
-// {{{ class UserFilterOrder
-abstract class UserFilterOrder
+// {{{ class UFC_MarketingHash
+/** Filters users using the hash generated
+ * to send marketing emails to him.
+ */
+class UFC_MarketingHash implements UserFilterCondition
{
- protected $desc = false;
- public function __construct($desc = false)
+ private $hash;
+
+ public function __construct($hash)
{
- $this->desc = $desc;
+ $this->hash = $hash;
}
- public function buildSort(UserFilter &$uf)
+ public function buildCondition(PlFilter &$uf)
{
- $sel = $this->getSortTokens($uf);
- if (!is_array($sel)) {
- $sel = array($sel);
- }
- if ($this->desc) {
- foreach ($sel as $k=>$s) {
- $sel[$k] = $s . ' DESC';
- }
- }
- return $sel;
+ $table = $uf->addMarketingHash();
+ return XDB::format('rm.hash = {?}', $this->hash);
}
+}
+
+/******************
+ * ORDERS
+ ******************/
- abstract protected function getSortTokens(UserFilter &$uf);
+// {{{ class UserFilterOrder
+/** Base class for ordering results of a query.
+ * Parameters for the ordering must be given to the constructor ($desc for a
+ * descending order).
+ * The getSortTokens function is used to get actual ordering part of the query.
+ */
+abstract class UserFilterOrder extends PlFilterOrder
+{
+ /** This function must return the tokens to use for ordering
+ * @param &$uf The UserFilter whose results must be ordered
+ * @return The name of the field to use for ordering results
+ */
+// abstract protected function getSortTokens(UserFilter &$uf);
}
// }}}
// {{{ class UFO_Promo
-/** Orders users by promo
- * @param $grade Formation whose promo users should be sorted by (restricts results to users of that formation)
+/** Orders users by promotion
+ * @param $grade Formation whose promotion users should be sorted by (restricts results to users of that formation)
* @param $desc Whether sort is descending
*/
class UFO_Promo extends UserFilterOrder
$this->grade = $grade;
}
- protected function getSortTokens(UserFilter &$uf)
+ protected function getSortTokens(PlFilter &$uf)
{
if (UserFilter::isGrade($this->grade)) {
$sub = $uf->addEducationFilter($this->grade);
// {{{ class UFO_Name
/** Sorts users by name
- * @param $type Type of name on which to sort (firstname, ...)
- * @param $variant Variant of that name to user (marital, ordinary, ...)
+ * @param $type Type of name on which to sort (firstname...)
+ * @param $variant Variant of that name to use (marital, ordinary...)
* @param $particle Set to true if particles should be included in the sorting order
* @param $desc If sort order should be descending
*/
$this->particle = $particle;
}
- protected function getSortTokens(UserFilter &$uf)
+ protected function getSortTokens(PlFilter &$uf)
{
- if (UserFilter::isDisplayName($this->type)) {
+ if (Profile::isDisplayName($this->type)) {
$sub = $uf->addDisplayFilter();
return 'pd' . $sub . '.' . $this->type;
} else {
}
// }}}
+// {{{ class UFO_Score
+class UFO_Score extends UserFilterOrder
+{
+ protected function getSortTokens(PlFilter &$uf)
+ {
+ $sub = $uf->addNameTokensFilter();
+ return 'SUM(' . $sub . '.score)';
+ }
+}
+// }}}
+
// {{{ class UFO_Registration
/** Sorts users based on registration date
*/
class UFO_Registration extends UserFilterOrder
{
- protected function getSortTokens(UserFilter &$uf)
+ protected function getSortTokens(PlFilter &$uf)
{
return 'a.registration_date';
}
*/
class UFO_Birthday extends UserFilterOrder
{
- protected function getSortTokens(UserFilter &$uf)
+ protected function getSortTokens(PlFilter &$uf)
{
return 'p.next_birthday';
}
*/
class UFO_ProfileUpdate extends UserFilterOrder
{
- protected function getSortTokens(UserFilter &$uf)
+ protected function getSortTokens(PlFilter &$uf)
{
return 'p.last_change';
}
*/
class UFO_Death extends UserFilterOrder
{
- protected function getSortTokens(UserFilter &$uf)
+ protected function getSortTokens(PlFilter &$uf)
{
return 'p.deathdate';
}
***********************************/
// {{{ class UserFilter
-class UserFilter
+/** This class provides a convenient and centralized way of filtering users.
+ *
+ * Usage:
+ * $uf = new UserFilter(new UFC_Blah($x, $y), new UFO_Coin($z, $t));
+ *
+ * Resulting UserFilter can be used to:
+ * - get a list of User objects matching the filter
+ * - get a list of UIDs matching the filter
+ * - get the number of users matching the filter
+ * - check whether a given User matches the filter
+ * - filter a list of User objects depending on whether they match the filter
+ *
+ * Usage for UFC and UFO objects:
+ * A UserFilter will call all private functions named XXXJoins.
+ * These functions must return an array containing the list of join
+ * required by the various UFC and UFO associated to the UserFilter.
+ * Entries in those returned array are of the following form:
+ * 'join_tablealias' => array('join_type', 'joined_table', 'join_criter')
+ * which will be translated into :
+ * join_type JOIN joined_table AS join_tablealias ON (join_criter)
+ * in the final query.
+ *
+ * In the join_criter text, $ME is replaced with 'join_tablealias', $PID with
+ * profile.pid, and $UID with accounts.uid.
+ *
+ * For each kind of "JOIN" needed, a function named addXXXFilter() should be defined;
+ * its parameter will be used to set various private vars of the UserFilter describing
+ * the required joins ; such a function shall return the "join_tablealias" to use
+ * when referring to the joined table.
+ *
+ * For example, if data from profile_job must be available to filter results,
+ * the UFC object will call $uf-addJobFilter(), which will set the 'with_pj' var and
+ * return 'pj', the short name to use when referring to profile_job; when building
+ * the query, calling the jobJoins function will return an array containing a single
+ * row:
+ * 'pj' => array('left', 'profile_job', '$ME.pid = $UID');
+ *
+ * The 'register_optional' function can be used to generate unique table aliases when
+ * the same table has to be joined several times with different aliases.
+ */
+class UserFilter extends PlFilter
{
- static private $joinMethods = array();
+ protected $joinMethods = array();
+
+ protected $joinMetas = array(
+ '$PID' => 'p.pid',
+ '$UID' => 'a.uid',
+ );
private $root;
private $sort = array();
public function __construct($cond = null, $sort = null)
{
- if (empty(self::$joinMethods)) {
+ if (empty($this->joinMethods)) {
$class = new ReflectionClass('UserFilter');
foreach ($class->getMethods() as $method) {
$name = $method->getName();
if (substr($name, -5) == 'Joins' && $name != 'buildJoins') {
- self::$joinMethods[] = $name;
+ $this->joinMethods[] = $name;
}
}
}
if (!is_null($cond)) {
- if ($cond instanceof UserFilterCondition) {
+ if ($cond instanceof PlFilterCondition) {
$this->setCondition($cond);
}
}
}
if (is_null($this->query)) {
$where = $this->root->buildCondition($this);
+ if ($this->with_forced_sn) {
+ $this->requireProfiles();
+ $from = 'search_name AS sn';
+ } else if ($this->with_accounts) {
+ $from = 'accounts AS a';
+ } else {
+ $this->requireProfiles();
+ $from = 'profiles AS p';
+ }
$joins = $this->buildJoins();
- $this->query = 'FROM accounts AS a
- LEFT JOIN account_profiles AS ap ON (ap.uid = a.uid AND FIND_IN_SET(\'owner\', ap.perms))
- LEFT JOIN profiles AS p ON (p.pid = ap.pid)
+ $this->query = 'FROM ' . $from . '
' . $joins . '
WHERE (' . $where . ')';
}
}
- private function formatJoin(array $joins)
- {
- $str = '';
- foreach ($joins as $key => $infos) {
- $mode = $infos[0];
- $table = $infos[1];
- if ($mode == 'inner') {
- $str .= 'INNER JOIN ';
- } else if ($mode == 'left') {
- $str .= 'LEFT JOIN ';
- } else {
- Platal::page()->kill("Join mode error");
- }
- $str .= $table . ' AS ' . $key;
- if (isset($infos[2])) {
- $str .= ' ON (' . str_replace(array('$ME', '$PID', '$UID'), array($key, 'p.pid', 'a.uid'), $infos[2]) . ')';
- }
- $str .= "\n";
- }
- return $str;
- }
-
- private function buildJoins()
- {
- $joins = array();
- foreach (self::$joinMethods as $method) {
- $joins = array_merge($joins, $this->$method());
- }
- return $this->formatJoin($joins);
- }
-
- private function getUIDList($uids = null, $count = null, $offset = null)
+ private function getUIDList($uids = null, PlLimit &$limit)
{
+ $this->requireAccounts();
$this->buildQuery();
- $limit = '';
- if (!is_null($count)) {
- if (!is_null($offset)) {
- $limit = XDB::format('LIMIT {?}, {?}', (int)$offset, (int)$count);
- } else {
- $limit = XDB::format('LIMIT {?}', (int)$count);
- }
- }
+ $lim = $limit->getSql();
$cond = '';
if (!is_null($uids)) {
$cond = ' AND a.uid IN ' . XDB::formatArray($uids);
' . $this->query . $cond . '
GROUP BY a.uid
' . $this->orderby . '
- ' . $limit);
+ ' . $lim);
$this->lastcount = (int)XDB::fetchOneCell('SELECT FOUND_ROWS()');
return $fetched;
}
+ private function getPIDList($pids = null, PlLimit &$limit)
+ {
+ $this->requireProfiles();
+ $this->buildQuery();
+ $lim = $limit->getSql();
+ $cond = '';
+ if (!is_null($pids)) {
+ $cond = ' AND p.pid IN ' . XDB::formatArray($pids);
+ }
+ $fetched = XDB::fetchColumn('SELECT SQL_CALC_FOUND_ROWS p.pid
+ ' . $this->query . $cond . '
+ GROUP BY p.pid
+ ' . $this->orderby . '
+ ' . $lim);
+ $this->lastcount = (int)XDB::fetchOneCell('SELECT FOUND_ROWS()');
+ return $fetched;
+ }
+
+ private static function defaultLimit($limit) {
+ if ($limit == null) {
+ return new PlLimit();
+ } else {
+ return $limit;
+ }
+ }
+
/** Check that the user match the given rule.
*/
public function checkUser(PlUser &$user)
{
+ $this->requireAccounts();
$this->buildQuery();
$count = (int)XDB::fetchOneCell('SELECT COUNT(*)
' . $this->query . XDB::format(' AND a.uid = {?}', $user->id()));
return $count == 1;
}
- /** Filter a list of user to extract the users matching the rule.
+ /** Check that the profile match the given rule.
+ */
+ public function checkProfile(Profile &$profile)
+ {
+ $this->requireProfiles();
+ $this->buildQuery();
+ $count = (int)XDB::fetchOneCell('SELECT COUNT(*)
+ ' . $this->query . XDB::format(' AND p.pid = {?}', $profile->id()));
+ return $count == 1;
+ }
+
+ /** Default filter is on users
*/
- public function filter(array $users, $count = null, $offset = null)
+ public function filter(array $users, $limit = null)
{
+ return $this->filterUsers($users, self::defaultLimit($limit));
+ }
+
+ /** Filter a list of users to extract the users matching the rule.
+ */
+ public function filterUsers(array $users, $limit = null)
+ {
+ $limit = self::defaultLimit($limit);
+ $this->requireAccounts();
$this->buildQuery();
$table = array();
$uids = array();
$uids[] = $uid;
$table[$uid] = $user;
}
- $fetched = $this->getUIDList($uids, $count, $offset);
+ $fetched = $this->getUIDList($uids, $limit);
$output = array();
foreach ($fetched as $uid) {
$output[] = $table[$uid];
return $output;
}
- public function getUIDs($count = null, $offset = null)
+ /** Filter a list of profiles to extract the users matching the rule.
+ */
+ public function filterProfiles(array $profiles, $limit = null)
+ {
+ $limit = self::defaultLimit($limit);
+ $this->requireProfiles();
+ $this->buildQuery();
+ $table = array();
+ $pids = array();
+ foreach ($profiles as $profile) {
+ if ($profile instanceof Profile) {
+ $pid = $profile->id();
+ } else {
+ $pid = $profile;
+ }
+ $pids[] = $pid;
+ $table[$pid] = $profile;
+ }
+ $fetched = $this->getPIDList($pids, $limit);
+ $output = array();
+ foreach ($fetched as $pid) {
+ $output[] = $table[$pid];
+ }
+ return $output;
+ }
+
+ public function getUIDs($limit = null)
+ {
+ $limit = self::defaultLimit($limit);
+ return $this->getUIDList(null, $limit);
+ }
+
+ public function getUID($pos = 0)
+ {
+ $uids =$this->getUIDList(null, new PlFilter(1, $pos));
+ if (count($uids) == 0) {
+ return null;
+ } else {
+ return $uids[0];
+ }
+ }
+
+ public function getPIDs($limit = null)
+ {
+ $limit = self::defaultLimit($limit);
+ return $this->getPIDList(null, $limit);
+ }
+
+ public function getPID($pos = 0)
+ {
+ $pids =$this->getPIDList(null, new PlFilter(1, $pos));
+ if (count($pids) == 0) {
+ return null;
+ } else {
+ return $pids[0];
+ }
+ }
+
+ public function getUsers($limit = null)
+ {
+ return User::getBulkUsersWithUIDs($this->getUIDs($limit));
+ }
+
+ public function getUser($pos = 0)
+ {
+ $uid = $this->getUID($pos);
+ if ($uid == null) {
+ return null;
+ } else {
+ return User::getWithUID($uid);
+ }
+ }
+
+ public function iterUsers($limit = null)
+ {
+ return User::iterOverUIDs($this->getUIDs($limit));
+ }
+
+ public function getProfiles($limit = null)
{
- return $this->getUIDList(null, $count, $offset);
+ return Profile::getBulkProfilesWithPIDs($this->getPIDs($limit));
}
- public function getUsers($count = null, $offset = null)
+ public function getProfile($pos = 0)
{
- return User::getBulkUsersWithUIDs($this->getUIDs($count, $offset));
+ $pid = $this->getPID($pos);
+ if ($pid == null) {
+ return null;
+ } else {
+ return Profile::get($pid);
+ }
+ }
+
+ public function iterProfiles($limit = null)
+ {
+ return Profile::iterOverPIDs($this->getPIDs($limit));
+ }
+
+ public function get($limit = null)
+ {
+ return $this->getUsers($limit);
}
public function getTotalCount()
{
if (is_null($this->lastcount)) {
$this->buildQuery();
- return (int)XDB::fetchOneCell('SELECT COUNT(DISTINCT a.uid)
+ if ($this->with_accounts) {
+ $field = 'a.uid';
+ } else {
+ $field = 'p.pid';
+ }
+ return (int)XDB::fetchOneCell('SELECT COUNT(DISTINCT ' . $field . ')
' . $this->query);
} else {
return $this->lastcount;
}
}
- public function setCondition(UserFilterCondition &$cond)
+ public function setCondition(PlFilterCondition &$cond)
{
$this->root =& $cond;
$this->query = null;
}
- public function addSort(UserFilterOrder &$sort)
+ public function addSort(PlFilterOrder &$sort)
{
$this->sort[] = $sort;
$this->orderby = null;
if ($promo_min != 0) {
$min = new UFC_Promo('>=', self::GRADE_ING, intval($promo_min));
} else {
- $min = new UFC_True();
+ $min = new PFC_True();
}
if ($promo_max != 0) {
$max = new UFC_Promo('<=', self::GRADE_ING, intval($promo_max));
} else {
- $max = new UFC_True();
+ $max = new PFC_True();
}
- return new UserFilter(new UFC_And($min, $max));
+ return new UserFilter(new PFC_And($min, $max));
}
static public function sortByName()
{
- return array(new UFO_Name(self::LASTNAME), new UFO_Name(self::FIRSTNAME));
+ return array(new UFO_Name(Profile::LASTNAME), new UFO_Name(Profile::FIRSTNAME));
}
static public function sortByPromo()
{
- return array(new UFO_Promo(), new UFO_Name(self::LASTNAME), new UFO_Name(self::FIRSTNAME));
+ return array(new UFO_Promo(), new UFO_Name(Profile::LASTNAME), new UFO_Name(Profile::FIRSTNAME));
}
static private function getDBSuffix($string)
}
+ /** Stores a new (and unique) table alias in the &$table table
+ * @param &$table Array in which the table alias must be stored
+ * @param $val Value which will then be used to build the join
+ * @return Name of the newly created alias
+ */
private $option = 0;
private function register_optional(array &$table, $val)
{
return $sub;
}
+ /** PROFILE VS ACCOUNT
+ */
+ private $with_profiles = false;
+ private $with_accounts = false;
+ private $with_forced_sn = false;
+ public function requireAccounts()
+ {
+ $this->with_accounts = true;
+ }
+
+ public function requireProfiles()
+ {
+ $this->with_profiles = true;
+ }
+
+ /** Forces the "FROM" to use search_name instead of accounts or profiles */
+ public function forceSearchName()
+ {
+ $this->with_forced_sn = true;
+ }
+
+ protected function accountJoins()
+ {
+ $joins = array();
+ /** Quick search is much more efficient with sn first and PID second */
+ if ($this->with_forced_sn) {
+ $joins['p'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profiles', '$PID = sn.uid');
+ if ($this->with_accounts) {
+ $joins['ap'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'account_profiles', '$ME.pid = $PID');
+ $joins['a'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'accounts', '$UID = ap.uid');
+ }
+ } else if ($this->with_profiles && $this->with_accounts) {
+ $joins['ap'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'account_profiles', '$ME.uid = $UID AND FIND_IN_SET(\'owner\', ap.perms)');
+ $joins['p'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profiles', '$PID = ap.pid');
+ }
+ return $joins;
+ }
+
/** DISPLAY
*/
const DISPLAY = 'display';
private $pd = false;
public function addDisplayFilter()
{
+ $this->requireProfiles();
$this->pd = true;
return '';
}
- private function displayJoins()
+ protected function displayJoins()
{
if ($this->pd) {
- return array('pd' => array('left', 'profile_display', '$ME.pid = $PID'));
+ return array('pd' => new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_display', '$ME.pid = $PID'));
} else {
return array();
}
}
- /** NAMES
+ /** LOGGER
*/
- /* name tokens */
- const LASTNAME = 'lastname';
- const FIRSTNAME = 'firstname';
- const NICKNAME = 'nickname';
- const PSEUDONYM = 'pseudonym';
- const NAME = 'name';
- /* name variants */
- const VN_MARITAL = 'marital';
- const VN_ORDINARY = 'ordinary';
- const VN_OTHER = 'other';
- const VN_INI = 'ini';
- /* display names */
- const DN_FULL = 'directory_name';
- const DN_DISPLAY = 'yourself';
- const DN_YOURSELF = 'yourself';
- const DN_DIRECTORY = 'directory_name';
- const DN_PRIVATE = 'private_name';
- const DN_PUBLIC = 'public_name';
- const DN_SHORT = 'short_name';
- const DN_SORT = 'sort_name';
-
- static public $name_variants = array(
- self::LASTNAME => array(self::VN_MARITAL, self::VN_ORDINARY),
- self::FIRSTNAME => array(self::VN_ORDINARY, self::VN_INI, self::VN_OTHER)
- );
- static public function assertName($name)
+ private $with_logger = false;
+ public function addLoggerFilter()
{
- if (!Profile::getNameTypeId($name)) {
- Platal::page()->kill('Invalid name type');
+ $this->with_logger = true;
+ $this->requireAccounts();
+ return 'ls';
+ }
+ protected function loggerJoins()
+ {
+ $joins = array();
+ if ($this->with_logger) {
+ $joins['ls'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'log_sessions', '$ME.uid = $UID');
}
+ return $joins;
}
- static public function isDisplayName($name)
+ /** NAMES
+ */
+
+ static public function assertName($name)
{
- return $name == self::DN_FULL || $name == self::DN_DISPLAY
- || $name == self::DN_YOURSELF || $name == self::DN_DIRECTORY
- || $name == self::DN_PRIVATE || $name == self::DN_PUBLIC
- || $name == self::DN_SHORT || $name == self::DN_SORT;
+ if (!Profile::getNameTypeId($name)) {
+ Platal::page()->kill('Invalid name type: ' . $name);
+ }
}
private $pn = array();
public function addNameFilter($type, $variant = null)
{
+ $this->requireProfiles();
if (!is_null($variant)) {
$ft = $type . '_' . $variant;
} else {
return $sub;
}
- private function nameJoins()
+ protected function nameJoins()
{
$joins = array();
foreach ($this->pn as $sub => $type) {
- $joins['pn' . $sub] = array('left', 'profile_name', '$ME.pid = $PID AND $ME.typeid = ' . $type);
+ $joins['pn' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_name', '$ME.pid = $PID AND $ME.typeid = ' . $type);
}
return $joins;
}
+ /** NAMETOKENS
+ */
+ private $with_sn = false;
+ // Set $doingQuickSearch to true if you wish to optimize the query
+ public function addNameTokensFilter($doingQuickSearch = false)
+ {
+ $this->requireProfiles();
+ $this->with_forced_sn = ($this->with_forced_sn || $doingQuickSearch);
+ $this->with_sn = true;
+ return 'sn';
+ }
+
+ protected function nameTokensJoins()
+ {
+ /* We don't return joins, since with_sn forces the SELECT to run on search_name first */
+ if ($this->with_sn && !$this->with_forced_sn) {
+ return array(
+ 'sn' => new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'search_name', '$ME.uid = $PID')
+ );
+ } else {
+ return array();
+ }
+ }
+
+ /** NATIONALITY
+ */
+
+ private $with_nat = false;
+ public function addNationalityFilter()
+ {
+ $this->with_nat = true;
+ return 'ngc';
+ }
+
+ protected function nationalityJoins()
+ {
+ $joins = array();
+ if ($this->with_nat) {
+ $joins['ngc'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'geoloc_countries', '$ME.iso_3166_1_a2 = p.nationality1 OR $ME.iso_3166_1_a2 = p.nationality2 OR $ME.iso_3166_1_a2 = p.nationality3');
+ }
+ return $joins;
+ }
/** EDUCATION
*/
static public function assertGrade($grade)
{
if (!self::isGrade($grade)) {
- Platal::page()->killError("Diplôme non valide");
+ Platal::page()->killError("Diplôme non valide: $grade");
}
}
private $with_pee = false;
public function addEducationFilter($x = false, $grade = null)
{
+ $this->requireProfiles();
if (!$x) {
$index = $this->option;
$sub = $this->option++;
return $sub;
}
- private function educationJoins()
+ protected function educationJoins()
{
$joins = array();
if ($this->with_pee) {
- $joins['pee'] = array('inner', 'profile_education_enum', 'pee.abbreviation = \'X\'');
+ $joins['pee'] = new PlSqlJoin(PlSqlJoin::MODE_INNER, 'profile_education_enum', 'pee.abbreviation = \'X\'');
}
foreach ($this->pepe as $grade => $sub) {
if ($this->isGrade($grade)) {
- $joins['pe' . $sub] = array('left', 'profile_education', '$ME.eduid = pee.id AND $ME.uid = $PID');
- $joins['pede' . $sub] = array('inner', 'profile_education_degree_enum', '$ME.id = pe' . $sub . '.degreeid AND $ME.abbreviation LIKE ' .
+ $joins['pe' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_education', '$ME.eduid = pee.id AND $ME.pid = $PID');
+ $joins['pede' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_INNER, 'profile_education_degree_enum', '$ME.id = pe' . $sub . '.degreeid AND $ME.abbreviation LIKE ' .
XDB::format('{?}', $grade));
} else {
- $joins['pe' . $sub] = array('left', 'profile_education', '$ME.uid = $PID');
- $joins['pee' . $sub] = array('inner', 'profile_education_enum', '$ME.id = pe' . $sub . '.eduid');
- $joins['pede' . $sub] = array('inner', 'profile_education_degree_enum', '$ME.id = pe' . $sub . '.degreeid');
+ $joins['pe' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_education', '$ME.pid = $PID');
+ $joins['pee' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_INNER, 'profile_education_enum', '$ME.id = pe' . $sub . '.eduid');
+ $joins['pede' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_INNER, 'profile_education_degree_enum', '$ME.id = pe' . $sub . '.degreeid');
}
}
return $joins;
private $gpm = array();
public function addGroupFilter($group = null)
{
+ $this->requireAccounts();
if (!is_null($group)) {
if (ctype_digit($group)) {
$index = $sub = $group;
return $sub;
}
- private function groupJoins()
+ protected function groupJoins()
{
$joins = array();
foreach ($this->gpm as $sub => $key) {
if (is_null($key)) {
- $joins['gpa' . $sub] = array('inner', 'groupex.asso');
- $joins['gpm' . $sub] = array('left', 'groupex.membres', '$ME.uid = $UID AND $ME.asso_id = gpa' . $sub . '.id');
+ $joins['gpa' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_INNER, 'groups');
+ $joins['gpm' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'group_members', '$ME.uid = $UID AND $ME.asso_id = gpa' . $sub . '.id');
} else if (ctype_digit($key)) {
- $joins['gpm' . $sub] = array('left', 'groupex.membres', '$ME.uid = $UID AND $ME.asso_id = ' . $key);
+ $joins['gpm' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'group_members', '$ME.uid = $UID AND $ME.asso_id = ' . $key);
} else {
- $joins['gpa' . $sub] = array('inner', 'groupex.asso', XDB::format('$ME.diminutif = {?}', $key));
- $joins['gpm' . $sub] = array('left', 'groupex.membres', '$ME.uid = $UID AND $ME.asso_id = gpa' . $sub . '.id');
+ $joins['gpa' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_INNER, 'groups', XDB::format('$ME.diminutif = {?}', $key));
+ $joins['gpm' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'group_members', '$ME.uid = $UID AND $ME.asso_id = gpa' . $sub . '.id');
}
}
return $joins;
}
+ /** BINETS
+ */
+
+ private $with_bi = false;
+ private $with_bd = false;
+ public function addBinetsFilter($with_enum = false)
+ {
+ $this->requireProfiles();
+ $this->with_bi = true;
+ if ($with_enum) {
+ $this->with_bd = true;
+ return 'bd';
+ } else {
+ return 'bi';
+ }
+ }
+
+ protected function binetsJoins()
+ {
+ $joins = array();
+ if ($this->with_bi) {
+ $joins['bi'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_binets', '$ME.pid = $PID');
+ }
+ if ($this->with_bd) {
+ $joins['bd'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_binet_enum', '$ME.id = bi.binet_id');
+ }
+ return $joins;
+ }
+
/** EMAILS
*/
private $e = array();
public function addEmailRedirectFilter($email = null)
{
+ $this->requireAccounts();
return $this->register_optional($this->e, $email);
}
private $al = array();
public function addAliasFilter($alias = null)
{
+ $this->requireAccounts();
return $this->register_optional($this->al, $alias);
}
- private function emailJoins()
+ protected function emailJoins()
{
global $globals;
$joins = array();
foreach ($this->e as $sub=>$key) {
if (is_null($key)) {
- $joins['e' . $sub] = array('left', 'emails', '$ME.uid = $UID AND $ME.flags != \'filter\'');
+ $joins['e' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'emails', '$ME.uid = $UID AND $ME.flags != \'filter\'');
} else {
- $joins['e' . $sub] = array('left', 'emails', XDB::format('$ME.uid = $UID AND $ME.flags != \'filter\' AND $ME.email = {?}', $key));
+ $joins['e' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'emails', XDB::format('$ME.uid = $UID AND $ME.flags != \'filter\' AND $ME.email = {?}', $key));
}
}
foreach ($this->al as $sub=>$key) {
if (is_null($key)) {
- $joins['al' . $sub] = array('left', 'aliases', '$ME.id = $UID AND $ME.type IN (\'alias\', \'a_vie\')');
+ $joins['al' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'aliases', '$ME.uid = $UID AND $ME.type IN (\'alias\', \'a_vie\')');
} else if ($key == self::ALIAS_BEST) {
- $joins['al' . $sub] = array('left', 'aliases', '$ME.id = $UID AND $ME.type IN (\'alias\', \'a_vie\') AND FIND_IN_SET(\'bestalias\', $ME.flags)');
+ $joins['al' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'aliases', '$ME.uid = $UID AND $ME.type IN (\'alias\', \'a_vie\') AND FIND_IN_SET(\'bestalias\', $ME.flags)');
} else if ($key == self::ALIAS_FORLIFE) {
- $joins['al' . $sub] = array('left', 'aliases', '$ME.id = $UID AND $ME.type = \'a_vie\'');
+ $joins['al' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'aliases', '$ME.uid = $UID AND $ME.type = \'a_vie\'');
} else {
- $joins['al' . $sub] = array('left', 'aliases', XDB::format('$ME.id = $UID AND $ME.type IN (\'alias\', \'a_vie\') AND $ME.alias = {?}', $key));
+ $joins['al' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'aliases', XDB::format('$ME.uid = $UID AND $ME.type IN (\'alias\', \'a_vie\') AND $ME.alias = {?}', $key));
}
}
foreach ($this->ve as $sub=>$key) {
if (is_null($key)) {
- $joins['v' . $sub] = array('left', 'virtual', '$ME.type = \'user\'');
+ $joins['v' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'virtual', '$ME.type = \'user\'');
} else {
- $joins['v' . $sub] = array('left', 'virtual', XDB::format('$ME.type = \'user\' AND $ME.alias = {?}', $key));
+ $joins['v' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'virtual', XDB::format('$ME.type = \'user\' AND $ME.alias = {?}', $key));
}
- $joins['vr' . $sub] = array('left', 'virtual_redirect', XDB::format('$ME.vid = v' . $sub . '.vid
+ $joins['vr' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'virtual_redirect', XDB::format('$ME.vid = v' . $sub . '.vid
AND ($ME.redirect IN (CONCAT(al_forlife.alias, \'@\', {?}),
CONCAT(al_forlife.alias, \'@\', {?}),
a.email))',
/** ADDRESSES
*/
- private $pa = false;
+ private $with_pa = false;
public function addAddressFilter()
{
- $this->pa = true;
+ $this->requireProfiles();
+ $this->with_pa = true;
+ return 'pa';
+ }
+
+ private $with_pac = false;
+ public function addAddressCountryFilter()
+ {
+ $this->requireProfiles();
+ $this->addAddressFilter();
+ $this->with_pac = true;
+ return 'gc';
}
- private function addressJoins()
+ private $with_pal = false;
+ public function addAddressLocalityFilter()
+ {
+ $this->requireProfiles();
+ $this->addAddressFilter();
+ $this->with_pal = true;
+ return 'gl';
+ }
+
+ protected function addressJoins()
{
$joins = array();
- if ($this->pa) {
- $joins['pa'] = array('left', 'profile_address', '$ME.PID = $PID');
+ if ($this->with_pa) {
+ $joins['pa'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_addresses', '$ME.pid = $PID');
+ }
+ if ($this->with_pac) {
+ $joins['gc'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'geoloc_countries', '$ME.iso_3166_1_a2 = pa.countryID');
+ }
+ if ($this->with_pal) {
+ $joins['gl'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'geoloc_localities', '$ME.id = pa.localityID');
}
return $joins;
}
private $pcr = false;
public function addCorpsFilter($type)
{
+ $this->requireProfiles();
$this->pc = true;
if ($type == UFC_Corps::CURRENT) {
$pce['pcec'] = 'current_corpsid';
public function addCorpsRankFilter()
{
+ $this->requireProfiles();
$this->pc = true;
$this->pcr = true;
return 'pcr';
}
- private function corpsJoins()
+ protected function corpsJoins()
{
$joins = array();
if ($this->pc) {
- $joins['pc'] = array('left', 'profile_corps', '$ME.uid = $UID');
+ $joins['pc'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_corps', '$ME.pid = $PID');
}
if ($this->pcr) {
- $joins['pcr'] = array('left', 'profile_corps_rank_enum', '$ME.id = pc.rankid');
+ $joins['pcr'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_corps_rank_enum', '$ME.id = pc.rankid');
}
foreach($this->pce as $sub => $field) {
- $joins[$sub] = array('left', 'profile_corps_enum', '$ME.id = pc.' . $field);
+ $joins[$sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_corps_enum', '$ME.id = pc.' . $field);
}
return $joins;
}
/** JOBS
*/
- const JOB_SECTOR = 1;
- const JOB_SUBSECTOR = 2;
- const JOB_SUBSUBSECTOR = 4;
- const JOB_ALTERNATES = 8;
- const JOB_USERDEFINED = 16;
+ const JOB_SECTOR = 0x0001;
+ const JOB_SUBSECTOR = 0x0002;
+ const JOB_SUBSUBSECTOR = 0x0004;
+ const JOB_ALTERNATES = 0x0008;
+ const JOB_USERDEFINED = 0x0010;
+ const JOB_CV = 0x0020;
+
+ const JOB_SECTORIZATION = 0x000F;
+ const JOB_ANY = 0x003F;
/** Joins :
* pj => profile_job
public function addJobFilter()
{
+ $this->requireProfiles();
$this->with_pj = true;
return 'pj';
}
}
}
- private function jobJoins()
+ protected function jobJoins()
{
$joins = array();
if ($this->with_pj) {
- $joins['pj'] = array('left', 'profile_job', '$ME.uid = $UID');
+ $joins['pj'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_job', '$ME.pid = $PID');
}
if ($this->with_pje) {
- $joins['pje'] = array('left', 'profile_job_enum', '$ME.id = pj.jobid');
+ $joins['pje'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_job_enum', '$ME.id = pj.jobid');
}
if ($this->with_pjse) {
- $joins['pjse'] = array('left', 'profile_job_sector_enum', '$ME.id = pj.sectorid');
+ $joins['pjse'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_job_sector_enum', '$ME.id = pj.sectorid');
}
if ($this->with_pjsse) {
- $joins['pjsse'] = array('left', 'profile_job_subsector_enum', '$ME.id = pj.subsectorid');
+ $joins['pjsse'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_job_subsector_enum', '$ME.id = pj.subsectorid');
}
if ($this->with_pjssse) {
- $joins['pjssse'] = array('left', 'profile_job_subsubsector_enum', '$ME.id = pj.subsubsectorid');
+ $joins['pjssse'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_job_subsubsector_enum', '$ME.id = pj.subsubsectorid');
}
if ($this->with_pja) {
- $joins['pja'] = array('left', 'profile_job_alternates', '$ME.subsubsectorid = pj.subsubsectorid');
+ $joins['pja'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_job_alternates', '$ME.subsubsectorid = pj.subsubsectorid');
}
return $joins;
}
private $with_pnw = false;
public function addNetworkingFilter()
{
+ $this->requireAccounts();
$this->with_pnw = true;
return 'pnw';
}
- private function networkingJoins()
+ protected function networkingJoins()
{
$joins = array();
if ($this->with_pnw) {
- $joins['pnw'] = array('left', 'profile_networking', '$ME.uid = $UID');
+ $joins['pnw'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_networking', '$ME.pid = $PID');
}
return $joins;
}
/** PHONE
*/
- private $with_phone = false;
+ private $with_ptel = false;
public function addPhoneFilter()
{
- $this->with_phone = true;
+ $this->requireAccounts();
+ $this->with_ptel = true;
return 'ptel';
}
- private function phoneJoins()
+ protected function phoneJoins()
{
$joins = array();
- if ($this->with_phone) {
- $joins['ptel'] = array('left', 'profile_phone', '$ME.uid = $UID');
+ if ($this->with_ptel) {
+ $joins['ptel'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_phones', '$ME.pid = $PID');
}
return $joins;
}
/** MEDALS
*/
- private $with_medals = false;
+ private $with_pmed = false;
public function addMedalFilter()
{
- $this->with_medals = true;
+ $this->requireProfiles();
+ $this->with_pmed = true;
return 'pmed';
}
- private function medalJoins()
+ protected function medalJoins()
{
$joins = array();
- if ($this->with_medals) {
- $joins['pmed'] = array('left', 'profile_medals_sub', '$ME.uid = $UID');
+ if ($this->with_pmed) {
+ $joins['pmed'] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'profile_medals', '$ME.pid = $PID');
}
return $joins;
}
public function addMentorFilter($type)
{
+ $this->requireAccounts();
switch($type) {
- case MENTOR_EXPERTISE:
- $pms['pme'] = 'profile_mentor';
+ case self::MENTOR_EXPERTISE:
+ $this->pms['pme'] = 'profile_mentor';
return 'pme';
- case MENTOR_COUNTRY:
- $pms['pmc'] = 'profile_mentor_country';
+ case self::MENTOR_COUNTRY:
+ $this->pms['pmc'] = 'profile_mentor_country';
return 'pmc';
- case MENTOR_SECTOR:
- $pms['pms'] = 'profile_mentor_sector';
+ case self::MENTOR_SECTOR:
+ $this->pms['pms'] = 'profile_mentor_sector';
return 'pms';
default:
- return;
+ Platal::page()->killError("Undefined mentor filter.");
}
}
- private function mentorJoins()
+ protected function mentorJoins()
{
$joins = array();
foreach ($this->pms as $sub => $tab) {
- $joins[$sub] = array('left', $tab, '$ME.uid = $UID');
+ $joins[$sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, $tab, '$ME.pid = $PID');
}
return $joins;
}
private $cts = array();
public function addContactFilter($uid = null)
{
+ $this->requireAccounts();
return $this->register_optional($this->cts, is_null($uid) ? null : 'user_' . $uid);
}
- private function contactJoins()
+ protected function contactJoins()
{
$joins = array();
foreach ($this->cts as $sub=>$key) {
if (is_null($key)) {
- $joins['c' . $sub] = array('left', 'contacts', '$ME.contact = $UID');
+ $joins['c' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'contacts', '$ME.contact = $UID');
} else {
- $joins['c' . $sub] = array('left', 'contacts', XDB::format('$ME.uid = {?} AND $ME.contact = $UID', substr($key, 5)));
+ $joins['c' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'contacts', XDB::format('$ME.uid = {?} AND $ME.contact = $UID', substr($key, 5)));
}
}
return $joins;
private $wn = array();
public function addWatchRegistrationFilter($uid = null)
{
+ $this->requireAccounts();
return $this->register_optional($this->wn, is_null($uid) ? null : 'user_' . $uid);
}
private $wp = array();
public function addWatchPromoFilter($uid = null)
{
+ $this->requireAccounts();
return $this->register_optional($this->wp, is_null($uid) ? null : 'user_' . $uid);
}
private $w = array();
public function addWatchFilter($uid = null)
{
+ $this->requireAccounts();
return $this->register_optional($this->w, is_null($uid) ? null : 'user_' . $uid);
}
- private function watchJoins()
+ protected function watchJoins()
{
$joins = array();
foreach ($this->w as $sub=>$key) {
if (is_null($key)) {
- $joins['w' . $sub] = array('left', 'watch');
+ $joins['w' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch');
} else {
- $joins['w' . $sub] = array('left', 'watch', XDB::format('$ME.uid = {?}', substr($key, 5)));
+ $joins['w' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch', XDB::format('$ME.uid = {?}', substr($key, 5)));
}
}
foreach ($this->wn as $sub=>$key) {
if (is_null($key)) {
- $joins['wn' . $sub] = array('left', 'watch_nonins', '$ME.ni_id = $UID');
+ $joins['wn' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch_nonins', '$ME.ni_id = $UID');
} else {
- $joins['wn' . $sub] = array('left', 'watch_nonins', XDB::format('$ME.uid = {?} AND $ME.ni_id = $UID', substr($key, 5)));
+ $joins['wn' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch_nonins', XDB::format('$ME.uid = {?} AND $ME.ni_id = $UID', substr($key, 5)));
}
}
foreach ($this->wn as $sub=>$key) {
if (is_null($key)) {
- $joins['wn' . $sub] = array('left', 'watch_nonins', '$ME.ni_id = $UID');
+ $joins['wn' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch_nonins', '$ME.ni_id = $UID');
} else {
- $joins['wn' . $sub] = array('left', 'watch_nonins', XDB::format('$ME.uid = {?} AND $ME.ni_id = $UID', substr($key, 5)));
+ $joins['wn' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch_nonins', XDB::format('$ME.uid = {?} AND $ME.ni_id = $UID', substr($key, 5)));
}
}
foreach ($this->wp as $sub=>$key) {
if (is_null($key)) {
- $joins['wp' . $sub] = array('left', 'watch_promo');
+ $joins['wp' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch_promo');
} else {
- $joins['wp' . $sub] = array('left', 'watch_promo', XDB::format('$ME.uid = {?}', substr($key, 5)));
+ $joins['wp' . $sub] = new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'watch_promo', XDB::format('$ME.uid = {?}', substr($key, 5)));
}
}
return $joins;
}
+
+
+ /** MARKETING
+ */
+ private $with_rm;
+ public function addMarketingHash()
+ {
+ $this->requireAccounts();
+ $this->with_rm = true;
+ }
+
+ protected function marketingJoins()
+ {
+ if ($this->with_rm) {
+ return array('rm' => new PlSqlJoin(PlSqlJoin::MODE_LEFT, 'register_marketing', '$ME.uid = $UID'));
+ } else {
+ return array();
+ }
+ }
+}
+// }}}
+
+// {{{ class ProfileFilter
+class ProfileFilter extends UserFilter
+{
+ public function get($limit = null)
+ {
+ return $this->getProfiles($limit);
+ }
}
// }}}