X-Git-Url: http://git.polytechnique.org/?a=blobdiff_plain;f=include%2Fnotifs.inc.php;h=ec9d8bf860a416aafdaba06a3af26bb73accf93d;hb=fb813fb52d5ab65ca9a5b92b5cb9089523380d79;hp=26eea44685844dd1d6e01e414ab1ec4725b50def;hpb=34062b64fa9f161dc071527b2e864496555d598d;p=platal.git diff --git a/include/notifs.inc.php b/include/notifs.inc.php index 26eea44..ec9d8bf 100644 --- a/include/notifs.inc.php +++ b/include/notifs.inc.php @@ -1,6 +1,6 @@ title); + } else { + return str_replace(array('$x', '$s'), array('x', 's'), $this->title); } - XDB::execute('UPDATE auth_user_md5 SET DATE=NOW() WHERE user_id={?}', $uid); - } elseif($cid == WATCH_INSCR) { - XDB::execute('REPLACE INTO contacts (uid,contact) - SELECT uid,ni_id - FROM watch_nonins - WHERE ni_id={?}', $uid); - XDB::execute('DELETE FROM watch_nonins WHERE ni_id={?}', $uid); - } - Platal::session()->updateNbNotifs(); -} - -// }}} -// {{{ function _select_notifs_base - -function _select_notifs_base($table, $mail, $where) -{ - $cases = Array( - 'contacts' => Array('wfield' => 'contact', 'ufield' => 'user_id', 'need_contact' => false, - 'freq_sql' => '', - 'contact_sql' => '1' - ), - 'watch_promo' => Array('wfield' => 'promo', 'ufield' => 'promo', 'need_contact' => true, - 'freq_sql' => ' AND ( wc.type = "basic" OR wc.type="near" AND (u.promo <= v.promo_sortie-2 AND u.promo_sortie >= v.promo+2) )', - 'contact_sql' => 'IF(c.contact IS NULL, 0, 1)' - ), - 'watch_nonins' => Array('wfield' => 'ni_id', 'ufield' => 'user_id', 'need_contact' => true, - 'freq_sql' => '', - 'contact_sql' => 'IF(c.contact IS NULL, 0, 1)' - ) - ); - - $our = $cases[$table]; - $sql = " - ( - SELECT u.promo, u.prenom, IF(u.nom_usage='',u.nom,u.nom_usage) AS nom, - u.deces != 0 AS dcd, (u.flags = 'femme') AS sexe, - a.alias AS bestalias, - wo.*, - {$our['contact_sql']} AS contact, - (u.perms IN('admin','user')) AS inscrit"; - if ($mail) { - $sql.=", - w.uid AS aid, v.prenom AS aprenom, IF(v.nom_usage='',v.nom,v.nom_usage) AS anom, - b.alias AS abestalias, (v.flags='femme') AS asexe, q.core_mail_fmt AS mail_fmt"; } - $sql .= " - FROM $table AS w - INNER JOIN auth_user_md5 AS u ON(u.{$our['ufield']} = w.{$our['wfield']}) - INNER JOIN auth_user_quick AS q ON(q.user_id = w.uid) - INNER JOIN auth_user_md5 AS v ON(v.user_id = q.user_id)"; - if ($mail) { - $sql .=" - INNER JOIN aliases AS b ON(b.id = q.user_id AND FIND_IN_SET('bestalias', b.flags))"; - } - if ($our['need_contact']) { - $sql .=" - LEFT JOIN contacts AS c ON(c.uid = w.uid AND c.contact = u.user_id)"; + public function getCondition(PlUser &$user, $date) + { + $this->date = $date; + if (!$user->watch($this->flag)) { + return new PFC_False(); + } else { + return $this->buildCondition($user); + } } - $sql .=" - INNER JOIN watch_ops AS wo ON(wo.uid = u.user_id AND ".($mail ? 'wo.known > q.watch_last' : '( wo.known > {?} OR wo.date=NOW() )').") - INNER JOIN watch_sub AS ws ON(ws.cid = wo.cid AND ws.uid = w.uid) - INNER JOIN watch_cat AS wc ON(wc.id = wo.cid{$our['freq_sql']}) - LEFT JOIN aliases AS a ON(a.id = u.user_id AND FIND_IN_SET('bestalias', a.flags)) - WHERE $where - )"; - - return $sql; -} - -// }}} -// {{{ function select_notifs + abstract protected function buildCondition(PlUser &$user); + abstract public function getOrder(); + abstract public function getDate(PlUser &$user); -function select_notifs($mail, $uid=null, $last=null, $iterator=true) -{ - $where = $mail ? 'q.watch_flags=3' : 'w.uid = {?}'; - $sql = _select_notifs_base('contacts', $mail, $where.($mail?'':' AND (q.watch_flags=1 OR q.watch_flags=3)')) . " UNION DISTINCT "; - $sql .= _select_notifs_base('watch_promo', $mail, $where) . " UNION DISTINCT "; - $sql .= _select_notifs_base('watch_nonins', $mail, $where); - - if ($iterator) { - return XDB::iterator($sql . ' ORDER BY cid, promo, date DESC, nom', $last, $uid, $last, $uid, $last, $uid); - } else { - return XDB::query($sql, $last, $uid, $last, $uid, $last, $uid); + public function publicationDate(PlUser &$user) + { + return $this->getDate($user); } -} -// }}} -// {{{ - -global $prf_desc; -$prf_desc = array('nom' => 'Son patronyme', - 'freetext' => 'Le texte libre', - 'mobile' => 'Son numéro de téléphone portable', - 'nationalite' => 'Sa nationalité', - 'nationalite2' => 'Sa seconde nationalité', - 'nationalite3' => 'Sa troisième nationalité', - 'nick' => 'Son surnom', - 'networking' => 'La liste de ses adresses de networking', - 'edus' => 'Ses formations', - 'addresses' => 'Ses adresses', - 'section' => 'Sa section sportive', - 'binets' => 'La liste de ses binets', - 'medals' => 'Ses décorations', - 'cv' => 'Son Curriculum Vitae', - 'corps' => 'Son Corps d\'État', - 'jobs' => 'Ses informations professionnelles', - 'photo' => 'Sa photographie'); - -function get_profile_change_details($event, $limit) { - global $prf_desc; - $res = XDB::iterRow("SELECT field - FROM watch_profile - WHERE uid = {?} AND ts > {?} - ORDER BY ts DESC", - $event['uid'], $limit); - if ($res->total() > 0) { - $data = array(); - while (list($field) = $res->next()) { - $data[] .= $prf_desc[$field]; - } - return ''; + public function seen(PlUser &$user, $last) + { + return strtotime($this->getDate($user)) > $last; } - return null; -} - -// }}} -// {{{ function register_profile_update -function register_profile_update($uid, $field) { - XDB::execute("REPLACE INTO watch_profile (uid, ts, field) - VALUES ({?}, NOW(), {?})", - $uid, $field); + public function getData(PlUser &$user) + { + return null; + } } -// {{{ class AllNotifs - -class AllNotifs +class WatchProfileUpdate extends WatchOperation { - public $_cats = Array(); - public $_data = Array(); + public $flag = 'profile'; + public $title = 'Mise$s à jour de fiche'; - public function __construct() + public static function register(Profile &$profile, $field) { - $res = XDB::iterator("SELECT * FROM watch_cat"); - while($tmp = $res->next()) { - $this->_cats[$tmp['id']] = $tmp; - } - - // recupère tous les watchers, avec détails des watchers, a partir du - // watch_last de chacun, seulement ceux qui sont surveillés, ordonnés - $res = select_notifs(true); - - while($tmp = $res->next()) { - $aid = $tmp['aid']; - if (empty($this->_data[$aid])) { - $this->_data[$aid] = Array("prenom" => $tmp['aprenom'], 'nom' => $tmp['anom'], - 'bestalias'=>$tmp['abestalias'], 'sexe' => $tmp['asexe'], 'mail_fmt' => $tmp['mail_fmt'], - 'dcd'=>$tmp['dcd']); - } - unset($tmp['aprenom'], $tmp['anom'], $tmp['abestalias'], $tmp['aid'], $tmp['asexe'], $tmp['mail_fmt'], $tmp['dcd']); - $this->_data[$aid]['data'][$tmp['cid']][] = $tmp; - } + XDB::execute('REPLACE INTO watch_profile (uid, ts, field) + VALUES ({?}, NOW(), {?})', + $profile->id(), $field); } -} - -// }}} -// {{{ class Notifs - -class Notifs -{ - public $_uid; - public $_cats = Array(); - public $_data = Array(); - function __construct($uid, $up=false) + protected function buildCondition(PlUser &$user) { - $this->_uid = $uid; + return new PFC_And(new UFC_ProfileUpdated('>', $this->date), + new UFC_WatchContact($user)); + } - $res = XDB::iterator("SELECT * FROM watch_cat"); - while($tmp = $res->next()) { - $this->_cats[$tmp['id']] = $tmp; - } + public function getOrder() + { + return new UFO_ProfileUpdate(); + } - $lastweek = date('YmdHis', time() - 7*24*60*60); + public function getDate(PlUser &$user) + { + return $user->profile()->last_change; + } - // recupere les notifs du watcher $uid, sans detail sur le watcher, - // depuis la semaine dernière, meme ceux sans surveillance, ordonnés - $res = select_notifs(false, $uid, $lastweek); - while($tmp = $res->next()) { - if ($tmp['cid'] == WATCH_FICHE) { - $tmp['data'] = get_profile_change_details($tmp, $lastweek); + static private $descriptions = array('search_names' => 'L\'un de ses noms', + 'freetext' => 'Le texte libre', + 'mobile' => 'Son numéro de téléphone portable', + 'nationalite' => 'Sa nationalité', + 'nationalite2' => 'Sa seconde nationalité', + 'nationalite3' => 'Sa troisième nationalité', + 'nick' => 'Son surnom', + 'networking' => 'La liste de ses adresses de networking', + 'edus' => 'Ses formations', + 'addresses' => 'Ses adresses', + 'section' => 'Sa section sportive', + 'binets' => 'La liste de ses binets', + 'medals' => 'Ses décorations', + 'cv' => 'Son Curriculum Vitae', + 'corps' => 'Son Corps d\'État', + 'jobs' => 'Ses informations professionnelles', + 'photo' => 'Sa photographie'); + public function getData(PlUser &$user) + { + $data = XDB::fetchColumn('SELECT field + FROM watch_profile + WHERE uid = {?} AND ts > FROM_UNIXTIME({?}) AND field != \'\' + ORDER BY ts', + $user->id(), $this->date); + if (count($data) == 0) { + return null; + } else { + $text = array(); + foreach ($data as $f) { + $text[] = self::$descriptions[$f]; } - $this->_data[$tmp['cid']][$tmp['promo']][] = $tmp; - } - - if($up) { - XDB::execute('UPDATE auth_user_quick SET watch_last=NOW() WHERE user_id={?}', $uid); + return $text; } } } -// }}} -// {{{ class Watch - -class Watch +class WatchRegistration extends WatchOperation { - public $_uid; - public $_promos; - public $_nonins; - public $_cats = Array(); - public $_subs; - public $watch_contacts; - public $watch_mail; - - public function __construct($uid) + public $flag = 'registration'; + public $title = 'Inscription$s'; + + protected function buildCondition(PlUser &$user) { - $this->_uid = $uid; - $this->_promos = new PromoNotifs($uid); - $this->_nonins = new NoninsNotifs($uid); - $this->_subs = new WatchSub($uid); - $res = XDB::query("SELECT FIND_IN_SET('contacts',watch_flags),FIND_IN_SET('mail',watch_flags) - FROM auth_user_quick - WHERE user_id={?}", $uid); - list($this->watch_contacts,$this->watch_mail) = $res->fetchOneRow(); - - $res = XDB::iterator("SELECT * FROM watch_cat"); - while($tmp = $res->next()) { - $this->_cats[$tmp['id']] = $tmp; - } + return new PFC_And(new UFC_Registered(false, '>', $this->date), + new PFC_Or(new UFC_WatchContact($user), + new UFC_WatchPromo($user))); } - public function saveFlags() + public function getOrder() { - $flags = ""; - if ($this->watch_contacts) - $flags = "contacts"; - if ($this->watch_mail) - $flags .= ($flags ? ',' : '')."mail"; - XDB::execute('UPDATE auth_user_quick SET watch_flags={?} WHERE user_id={?}', - $flags, $this->_uid); + return new UFO_Registration(); } - public function cats() + public function getDate(PlUser &$user) { - return $this->_cats; + return $user->registration_date; } +} + +class WatchDeath extends WatchOperation +{ + public $flag = 'death'; + public $title = 'Décès'; - public function subs($i) + protected function buildCondition(PlUser &$user) { - return $this->_subs->_data[$i]; + return new PFC_And(new UFC_Dead('>', $this->date, true), + new PFC_Or(new UFC_WatchPromo($user), + new UFC_WatchContact($user))); } - public function promos() + public function getOrder() { - return $this->_promos->toRanges(); + return new UFO_Death(); } - public function nonins() + public function getDate(PlUser &$user) { - return $this->_nonins->_data; + return $user->profile()->deathdate; } -} - -// }}} -// {{{ class WatchSub - -class WatchSub -{ - public $_uid; - public $_data = Array(); - public function __construct($uid) + public function publicationDate(PlUser &$user) { - $this->_uid = $uid; - $res = XDB::iterRow('SELECT cid FROM watch_sub WHERE uid={?}', $uid); - while(list($c) = $res->next()) { - $this->_data[$c] = $c; - } + return $user->profile()->deathdate_rec; } - public function update($ind) + public function seen(PlUser &$user, $last) { - $this->_data = Array(); - XDB::execute('DELETE FROM watch_sub WHERE uid={?}', $this->_uid); - foreach (Env::v($ind) as $key=>$val) { - XDB::query('INSERT INTO watch_sub SELECT {?},id FROM watch_cat WHERE id={?}', $this->_uid, $key); - if(XDB::affectedRows()) { - $this->_data[$key] = $key; - } - } + return strtotime($user->profile()->deathdate_rec) > $last; } } -// }}} -// {{{ class PromoNotifs - -class PromoNotifs +class WatchBirthday extends WatchOperation { - public $_uid; - public $_data = Array(); + const WATCH_LIMIT = 604800; // 1 week - public function __construct($uid) - { - $this->_uid = $uid; - $res = XDB::iterRow('SELECT promo FROM watch_promo WHERE uid={?} ORDER BY promo', $uid); - while (list($p) = $res->next()) { - $this->_data[intval($p)] = intval($p); - } - } + public $flag = 'birthday'; + public $title = 'Anniversaire$s'; - public function add($p) + protected function buildCondition(PlUser &$user) { - $promo = intval($p); - XDB::execute('REPLACE INTO watch_promo (uid,promo) VALUES({?},{?})', $this->_uid, $promo); - $this->_data[$promo] = $promo; - asort($this->_data); + return new PFC_And(new PFC_OR(new UFC_Birthday('=', time()), + new PFC_And(new UFC_Birthday('<=', time() + self::WATCH_LIMIT), + new UFC_Birthday('>', $this->date + self::WATCH_LIMIT))), + new PFC_Or(new UFC_WatchPromo($user), + new UFC_WatchContact($user))); } - public function del($p) + public function getOrder() { - $promo = intval($p); - XDB::execute('DELETE FROM watch_promo WHERE uid={?} AND promo={?}', $this->_uid, $promo); - unset($this->_data[$promo]); + return new UFO_Birthday(); } - public function addRange($_p1,$_p2) + public function getDate(PlUser &$user) { - $p1 = intval($_p1); - $p2 = intval($_p2); - $values = Array(); - for($i = min($p1,$p2); $i<=max($p1,$p2); $i++) { - $values[] = "('{$this->_uid}',$i)"; - $this->_data[$i] = $i; - } - XDB::execute('REPLACE INTO watch_promo (uid,promo) VALUES '.join(',',$values)); - asort($this->_data); + return $user->profile()->next_birthday; } - public function delRange($_p1,$_p2) + public function publicationDate(PlUser &$user) { - $p1 = intval($_p1); - $p2 = intval($_p2); - $where = Array(); - for($i = min($p1,$p2); $i<=max($p1,$p2); $i++) { - $where[] = "promo=$i"; - unset($this->_data[$i]); - } - XDB::execute('DELETE FROM watch_promo WHERE uid={?} AND ('.join(' OR ',$where).')', $this->_uid); + return date('Y-m-d', strtotime($user->profile()->next_birthday) - self::WATCH_LIMIT); } - public function toRanges() + public function seen(PlUser &$user, $last) { - $ranges = Array(); - $I = Array(); - foreach($this->_data as $promo) { - if(!isset($I[0])) { - $I = Array($promo,$promo); - } - elseif($I[1]+1 == $promo) { - $I[1] ++; - } - else { - $ranges[] = $I; - $I = Array($promo,$promo); - } - } - if(isset($I[0])) $ranges[] = $I; - return $ranges; + $birthday = strtotime($user->profile()->next_birthday); + return $birthday > $last + self::WATCH_LIMIT + || date('Ymd', $birthday) == date('Ymd'); } } -// }}} -// {{{ class NoninsNotifs - -class NoninsNotifs +class Watch { - public $_uid; - public $_data = Array(); + private static $classes = array('WatchRegistration', + 'WatchProfileUpdate', + 'WatchDeath', + 'WatchBirthday'); - public function __construct($uid) + private static function fetchCount(PlUser &$user, $date, $class) { - $this->_uid = $uid; - $res = XDB::iterator("SELECT u.prenom,IF(u.nom_usage='',u.nom,u.nom_usage) AS nom, u.promo, u.user_id - FROM watch_nonins AS w - INNER JOIN auth_user_md5 AS u ON (u.user_id = w.ni_id) - WHERE w.uid = {?} - ORDER BY promo,nom", $uid); - while($tmp = $res->next()) { - $this->_data[$tmp['user_id']] = $tmp; + $obj = new $class(); + $uf = new UserFilter($obj->getCondition($user, $date)); + return $uf->getTotalCount(); + } + + public static function getCount(PlUser &$user, $date = null) + { + $count = 0; + if (is_null($date)) { + $date = $user->watchLast(); } + foreach (self::$classes as $class) { + $count += self::fetchCount($user, $date, $class); + } + return $count; } - public function del($p) + + private static function fetchEvents(PlUser &$user, $date, $class) { - unset($this->_data["$p"]); - XDB::execute('DELETE FROM watch_nonins WHERE uid={?} AND ni_id={?}', $this->_uid, $p); + $obj = new $class(); + $uf = new UserFilter($obj->getCondition($user, $date), + array($obj->getOrder(), new UFO_Name(UserFilter::DN_SORT))); + $users = $uf->getUsers(); + if (count($users) == 0) { + return null; + } else { + return array('operation' => $obj, + 'title' => $obj->getTitle(count($users)), + 'users' => $users); + } } - public function add($p) + public static function getEvents(PlUser &$user, $date = null) { - XDB::execute('INSERT INTO watch_nonins (uid,ni_id) VALUES({?},{?})', $this->_uid, $p); - $res = XDB::query('SELECT prenom,IF(nom_usage="",nom,nom_usage) AS nom,promo,user_id - FROM auth_user_md5 - WHERE user_id={?}', $p); - $this->_data["$p"] = $res->fetchOneAssoc(); + if (is_null($date)) { + $date = $user->watchLast(); + } + $events = array(); + foreach (self::$classes as $class) { + $e = self::fetchEvents($user, $date, $class); + if (!is_null($e)) { + $events[] = $e; + } + } + return $events; } } -// }}} - // vim:set et sw=4 sts=4 sws=4 foldmethod=marker enc=utf-8: ?>