X-Git-Url: http://git.polytechnique.org/?a=blobdiff_plain;f=include%2Fnotifs.inc.php;h=19a64809f0a5c88576afbae4ed59207ded49c91d;hb=3424387cde6c635ff16c3b5459c4caa88bb76e2e;hp=02958900dfd36452b1da3f8d6ea44640ff56f4c9;hpb=0380bf854bc295fb66fb8e1071d63a3537cdba2c;p=platal.git diff --git a/include/notifs.inc.php b/include/notifs.inc.php index 0295890..19a6480 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); + } + } -// }}} -// {{{ function register_watch_op + public function getCondition(Watch $watch) + { + if (!$watch->user()->watchType($this->flag)) { + if (!self::$false) { + self::$false = new PFC_False(); + } + return self::$false; + } else { + return $this->buildCondition($watch); + } + } -function register_watch_op($uid, $cid, $date='', $info='') -{ - if (empty($date)) { - $date = date('Y-m-d'); - }; - XDB::execute('REPLACE INTO watch_ops (uid,cid,known,date,info) VALUES({?},{?},NOW(),{?},{?})', - $uid, $cid, $date, $info); - if($cid == WATCH_FICHE) { - 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); + abstract protected function buildCondition(Watch $watch); + abstract public function getOrder(); + abstract public function getDate(PlUser $user); + + public function publicationDate(PlUser $user) + { + return $this->getDate($user); } -} -// }}} -// {{{ function _select_notifs_base + public function seen(PlUser $user, $last) + { + return strtotime($this->getDate($user)) > $last; + } -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' => 'NOT (c.contact IS NULL)' - ), - 'watch_nonins' => Array('wfield' => 'ni_id', 'ufield' => 'user_id', 'need_contact' => false, - 'freq_sql' => '', - 'contact_sql' => '0' - ) - ); - - $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, - 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 sexe, 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)"; - } - - $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; + public function getData(PlUser $user) + { + return null; + } } -// }}} -// {{{ function select_notifs - -function select_notifs($mail, $uid=null, $last=null, $iterator=true) +class WatchProfileUpdate extends WatchOperation { - $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); + private static $order = null; + + public $flag = 'profile'; + public $title = 'Mise$s à jour de fiche'; + private $date = null; + + public static function register(Profile $profile, $field) + { + XDB::execute('INSERT INTO watch_profile (pid, ts, field) + VALUES ({?}, NOW(), {?}) + ON DUPLICATE KEY UPDATE ts = NOW()', + $profile->id(), $field); } -} -// }}} -// {{{ function getNbNotifs + protected function buildCondition(Watch $watch) + { + $this->date = $watch->date(); + return new PFC_And(new UFC_ProfileUpdated('>', $watch->date()), + $watch->contactCondition()); + } -function getNbNotifs() { - if (!S::has('uid')) { - return 0; + public function getOrder() + { + if (!self::$order) { + self::$order = new UFO_ProfileUpdate(); + } + return self::$order; } - $uid = S::v('uid', -1); - $watchlast = S::v('watch_last'); - // selectionne les notifs de uid, sans detail sur le watcher, depuis - // $watchlast, meme ceux sans surveillance, non ordonnés - $res = select_notifs(false, $uid, $watchlast, false); - $n = $res->numRows(); - $res->free(); - if ($n == 0) { - return; + public function getDate(PlUser $user) + { + return $user->profile()->last_change; } - return "$n événement".($n > 1 ? 's' : '')." !"; + public function getData(PlUser $user) + { + $data = XDB::fetchColumn("SELECT field + FROM watch_profile + WHERE pid = {?} AND ts > FROM_UNIXTIME({?}) AND field != '' + ORDER BY ts", + $user->profile()->id(), $this->date); + if (count($data) == 0) { + return null; + } else { + $text = array(); + foreach ($data as $f) { + $text[] = Profile::$descriptions[$f]; + } + return $text; + } + } } -// }}} -// {{{ class AllNotifs - -class AllNotifs { - var $_cats = Array(); - var $_data = Array(); +class WatchRegistration extends WatchOperation +{ + private static $order = null; - function AllNotifs() { - $res = XDB::iterator("SELECT * FROM watch_cat"); - while($tmp = $res->next()) { - $this->_cats[$tmp['id']] = $tmp; - } + public $flag = 'registration'; + public $title = 'Inscription$s'; - // 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); + protected function buildCondition(Watch $watch) + { + return new PFC_And(new UFC_Registered(false, '>', $watch->date()), + new PFC_Or($watch->contactCondition(), + $watch->promoCondition(), + $watch->groupCondition())); + } - 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['sexe'], 'mail_fmt' => $tmp['mail_fmt'], - 'dcd'=>$tmp['dcd']); - } - unset($tmp['aprenom'], $tmp['anom'], $tmp['abestalias'], $tmp['aid'], $tmp['sexe'], $tmp['mail_fmt'], $tmp['dcd']); - $this->_data[$aid]['data'][$tmp['cid']][] = $tmp; + public function getOrder() + { + if (!self::$order) { + self::$order = new UFO_Registration(); } + return self::$order; + } + + public function getDate(PlUser $user) + { + return $user->registration_date; } } -// }}} -// {{{ class Notifs +class WatchDeath extends WatchOperation +{ + private static $order = null; -class Notifs { - var $_uid; - var $_cats = Array(); - var $_data = Array(); + public $flag = 'death'; + public $title = 'Décès'; - function Notifs($uid, $up=false) { - $this->_uid = $uid; + protected function buildCondition(Watch $watch) + { + return new PFC_And(new UFC_Dead('>', $watch->date(), true), + new PFC_Or($watch->contactCondition(), + $watch->promoCondition(), + $watch->groupCondition())); + } - $res = XDB::iterator("SELECT * FROM watch_cat"); - while($tmp = $res->next()) { - $this->_cats[$tmp['id']] = $tmp; + public function getOrder() + { + if (!self::$order) { + self::$order = new UFO_Death(); } + return self::$order; + } - $lastweek = date('YmdHis', time() - 7*24*60*60); + public function getDate(PlUser $user) + { + return $user->profile()->deathdate; + } - // 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()) { - $this->_data[$tmp['cid']][$tmp['promo']][] = $tmp; - } + public function publicationDate(PlUser $user) + { + return $user->profile()->deathdate_rec; + } - if($up) { - XDB::execute('UPDATE auth_user_quick SET watch_last=NOW() WHERE user_id={?}', $uid); - } + public function seen(PlUser $user, $last) + { + return strtotime($user->profile()->deathdate_rec) > $last; } } -// }}} -// {{{ class Watch - -class Watch { - var $_uid; - var $_promos; - var $_nonins; - var $_cats = Array(); - var $_subs; - var $watch_contacts; - var $watch_mail; - - function Watch($uid) { - $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; +class WatchBirthday extends WatchOperation +{ + const WATCH_LIMIT = 604800; // 1 week + + private static $order = null; + + public $flag = 'birthday'; + public $title = 'Anniversaire$s'; + + protected function buildCondition(Watch $watch) + { + $not_dead = new PFC_Not(new UFC_Dead()); + $select_date = new PFC_OR(new UFC_Birthday('=', time()), + new PFC_And(new UFC_Birthday('<=', time() + self::WATCH_LIMIT), + new UFC_Birthday('>', $watch->date() + self::WATCH_LIMIT))); + $profile = $watch->profile(); + $cond = $watch->contactCondition(); + if ($profile) { + $cond = new PFC_Or($cond, + new PFC_And($watch->promoCondition(), + new UFC_Promo('>=', $profile->mainGrade(), $profile->yearpromo() - 1), + new UFC_Promo('<=', $profile->mainGrade(), $profile->yearpromo() + 1)), + $watch->groupCondition()); } + return new PFC_And($not_dead, $select_date, $cond); } - function saveFlags() { - $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); + public function getOrder() + { + if (!self::$order) { + self::$order = new UFO_Birthday(); + } + return self::$order; } - function cats() { - return $this->_cats; + public function getDate(PlUser $user) + { + return $user->profile()->next_birthday; } - function subs($i) { - return $this->_subs->_data[$i]; + public function publicationDate(PlUser $user) + { + return date('Y-m-d', strtotime($user->profile()->next_birthday) - self::WATCH_LIMIT); } - function promos() { - return $this->_promos->toRanges(); + public function seen(PlUser $user, $last) + { + $birthday = strtotime($user->profile()->next_birthday); + return $birthday > $last + self::WATCH_LIMIT + || date('Ymd', $birthday) == date('Ymd'); } +} - function nonins() { - return $this->_nonins->_data; +class Watch +{ + private static $classes = array('WatchRegistration', + 'WatchProfileUpdate', + 'WatchDeath', + 'WatchBirthday'); + private static $events = array(); + + private $user = null; + private $date = null; + private $contactCond = null; + private $promoCond = null; + private $groupCond = null; + + private $filters = array(); + + public function __construct(PlUser $user, $date = null) + { + $this->user = $user; + $this->date = self::getDate($user, $date); } -} -// }}} -// {{{ class WatchSub + public function user() + { + return $this->user; + } -class WatchSub { - var $_uid; - var $_data = Array(); + public function profile() + { + return $this->user->profile(); + } - function WatchSub($uid) { - $this->_uid = $uid; - $res = XDB::iterRow('SELECT cid FROM watch_sub WHERE uid={?}', $uid); - while(list($c) = $res->next()) { - $this->_data[$c] = $c; - } + public function date() + { + return $this->date; } - function update($ind) { - $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; - } + public function contactCondition() + { + if (!$this->contactCond) { + $this->contactCond = new UFC_WatchContact($this->user); } + return $this->contactCond; } -} - -// }}} -// {{{ class PromoNotifs -class PromoNotifs { - var $_uid; - var $_data = Array(); + public function promoCondition() + { + if (!$this->promoCond) { + $this->promoCond = new UFC_WatchPromo($this->user); + } + return $this->promoCond; + } - function PromoNotifs($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 function groupCondition() + { + if (!$this->groupCond) { + $this->groupCond = new UFC_WatchGroup($this->user); } + return $this->groupCond; } - function add($p) { - $promo = intval($p); - XDB::execute('REPLACE INTO watch_promo (uid,promo) VALUES({?},{?})', $this->_uid, $promo); - $this->_data[$promo] = $promo; - asort($this->_data); + private function fetchEventWatch($class) + { + if (!isset(self::$events[$class])) { + self::$events[$class] = new $class(); + } + return self::$events[$class]; } - function del($p) { - $promo = intval($p); - XDB::execute('DELETE FROM watch_promo WHERE uid={?} AND promo={?}', $this->_uid, $promo); - unset($this->_data[$promo]); + private function fetchFilter($class) + { + + if (!isset($this->filters[$class])) { + $event = $this->fetchEventWatch($class); + $this->filters[$class] = new UserFilter($event->getCondition($this), + array($event->getOrder(), new UFO_Name())); + } + return $this->filters[$class]; } - function addRange($_p1,$_p2) { - $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; + public function count() + { + $count = 0; + foreach (self::$classes as $class) { + $uf = $this->fetchFilter($class); + $count += $uf->getTotalCount(); } - XDB::execute('REPLACE INTO watch_promo (uid,promo) VALUES '.join(',',$values)); - asort($this->_data); + return $count; } - function delRange($_p1,$_p2) { - $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]); + + private function fetchEvents($class) + { + $obj = $this->fetchEventWatch($class); + $uf = $this->fetchFilter($class); + $users = $uf->getUsers(); + if (count($users) == 0) { + return null; + } else { + return array('type' => $obj->flag, + 'operation' => $obj, + 'title' => $obj->getTitle(count($users)), + 'users' => $users); } - XDB::execute('DELETE FROM watch_promo WHERE uid={?} AND ('.join(' OR ',$where).')', $this->_uid); } - function toRanges() { - $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); + public function events() + { + $events = array(); + foreach (self::$classes as $class) { + $e = $this->fetchEvents($class); + if (!is_null($e)) { + $events[] = $e; } } - if(isset($I[0])) $ranges[] = $I; - return $ranges; + return $events; } -} -// }}} -// {{{ class NoninsNotifs - -class NoninsNotifs { - var $_uid; - var $_data = Array(); - - function NoninsNotifs($uid) { - $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; + + private static function getDate(PlUser $user, $date) + { + if (is_null($date)) { + $date = $user->watchLast(); + $limit = time() - (7 * 86400); + if ($date < $limit) { + $date = $limit; + } } + return $date; } - function del($p) { - unset($this->_data["$p"]); - XDB::execute('DELETE FROM watch_nonins WHERE uid={?} AND ni_id={?}', $this->_uid, $p); + public static function getCount(PlUser $user, $date = null) + { + $watch = new Watch($user, $date); + return $watch->count(); } - function add($p) { - 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(); + public static function getEvents(PlUser $user, $date = null) + { + $watch = new Watch($user, $date); + return $watch->events(); } } -// }}} - -// vim:set et sw=4 sts=4 sws=4 foldmethod=marker enc=utf-8: +// vim:set et sw=4 sts=4 sws=4 foldmethod=marker fenc=utf-8: ?>