X-Git-Url: http://git.polytechnique.org/?a=blobdiff_plain;f=include%2Fnotifs.inc.php;h=4d8013cb5574c3804718debeee1eef09fe97fecc;hb=0f5f1b707d93b4dc8c5875c2129bb38fcd186563;hp=a3f5fad29ed6e99873b98f1e5c675fbf762a2876;hpb=50a40a33a496131e817df875607ea5542d096a64;p=platal.git
diff --git a/include/notifs.inc.php b/include/notifs.inc.php
index a3f5fad..4d8013c 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 inscription_notifs_base
+ 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 inscription_notifs_base($uid)
-{
- global $globals;
- $globals->xdb->execute('REPLACE INTO watch_sub (uid,cid) SELECT {?},id FROM watch_cat', $uid);
-}
+ abstract protected function buildCondition(Watch $watch);
+ abstract public function getOrder();
+ abstract public function getDate(PlUser $user);
-// }}}
-// {{{ function register_watch_op
+ public function publicationDate(PlUser $user)
+ {
+ return $this->getDate($user);
+ }
-function register_watch_op($uid, $cid, $date='', $info='')
-{
- global $globals;
- if (empty($date)) {
- $date = date('Y-m-d');
- };
- $globals->xdb->execute('REPLACE INTO watch_ops (uid,cid,known,date,info) VALUES({?},{?},NOW(),{?},{?})',
- $uid, $cid, $date, $info);
- if($cid == WATCH_FICHE) {
- $globals->xdb->execute('UPDATE auth_user_md5 SET DATE=NOW() WHERE user_id={?}', $uid);
- } elseif($cid == WATCH_INSCR) {
- $globals->xdb->execute('REPLACE INTO contacts (uid,contact)
- SELECT uid,ni_id
- FROM watch_nonins
- WHERE ni_id={?}', $uid);
- $globals->xdb->execute('DELETE FROM watch_nonins WHERE ni_id={?}', $uid);
+ public function seen(PlUser $user, $last)
+ {
+ return strtotime($this->getDate($user)) > $last;
}
-}
-// }}}
-// {{{ function _select_notifs_base
+ public function getData(PlUser $user)
+ {
+ return null;
+ }
+}
-function _select_notifs_base($table, $mail, $where)
+class WatchProfileUpdate extends WatchOperation
{
- $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;
-}
+ 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 select_notifs
+ protected function buildCondition(Watch $watch)
+ {
+ $this->date = $watch->date();
+ return new PFC_And(new UFC_ProfileUpdated('>', $watch->date()),
+ $watch->contactCondition());
+ }
-function select_notifs($mail, $uid=null, $last=null, $iterator=true)
-{
- global $globals;
- $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);
+ public function getOrder()
+ {
+ if (!self::$order) {
+ self::$order = new UFO_ProfileUpdate();
+ }
+ return self::$order;
+ }
- if ($iterator) {
- return $globals->xdb->iterator($sql . ' ORDER BY cid, promo, date DESC, nom', $last, $uid, $last, $uid, $last, $uid);
- } else {
- return $globals->xdb->query($sql, $last, $uid, $last, $uid, $last, $uid);
+ public function getDate(PlUser $user)
+ {
+ return $user->profile()->last_change;
}
-}
-// }}}
-// {{{ function getNbNotifs
-
-function getNbNotifs() {
- global $globals;
- if (!Session::has('uid')) {
- return 0;
- }
- $uid = Session::getInt('uid', -1);
- $watchlast = Session::get('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();
- $url = $globals->baseurl."/carnet/panel.php";
- if($n==0) { return; }
- if($n==1) { return "1 évènement !"; }
- return "$n évènements !";
+ 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 WatchRegistration extends WatchOperation
+{
+ private static $order = null;
-class AllNotifs {
- var $_cats = Array();
- var $_data = Array();
+ public $flag = 'registration';
+ public $title = 'Inscription$s';
- function AllNotifs() {
- global $globals;
-
- $res = $globals->xdb->iterator("SELECT * FROM watch_cat");
- while($tmp = $res->next()) {
- $this->_cats[$tmp['id']] = $tmp;
- }
+ protected function buildCondition(Watch $watch)
+ {
+ return new PFC_And(new UFC_Registered(false, '>', $watch->date()),
+ new PFC_Or($watch->contactCondition(),
+ $watch->promoCondition()));
+ }
- // 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);
+ public function getOrder()
+ {
+ if (!self::$order) {
+ self::$order = new UFO_Registration();
+ }
+ return self::$order;
+ }
- 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 getDate(PlUser $user)
+ {
+ return $user->registration_date;
}
}
-// }}}
-// {{{ class Notifs
-
-class Notifs {
- var $_uid;
- var $_cats = Array();
- var $_data = Array();
-
- function Notifs($uid, $up=false) {
- global $globals;
- $this->_uid = $uid;
-
- $res = $globals->xdb->iterator("SELECT * FROM watch_cat");
- while($tmp = $res->next()) {
- $this->_cats[$tmp['id']] = $tmp;
+class WatchDeath extends WatchOperation
+{
+ private static $order = null;
+
+ public $flag = 'death';
+ public $title = 'Décès';
+
+ protected function buildCondition(Watch $watch)
+ {
+ return new PFC_And(new UFC_Dead('>', $watch->date(), true),
+ new PFC_Or($watch->contactCondition(),
+ $watch->promoCondition()));
+ }
+
+ public function getOrder()
+ {
+ if (!self::$order) {
+ self::$order = new UFO_Death();
}
+ return self::$order;
+ }
- $lastweek = date('YmdHis',mktime() - 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) {
- $globals->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) {
- global $globals;
- $this->_uid = $uid;
- $this->_promos = new PromoNotifs($uid);
- $this->_nonins = new NoninsNotifs($uid);
- $this->_subs = new WatchSub($uid);
- $res = $globals->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 = $globals->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)
+ {
+ $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)));
}
+ return new PFC_And($select_date, $cond);
}
- function saveFlags() {
- global $globals;
- $flags = "";
- if($this->watch_contacts) $flags = "contacts";
- if($this->watch_mail) $flags .= ($flags ? ',' : '')."mail";
- $globals->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();
- }
-
- function nonins() {
- return $this->_nonins->_data;
+
+ public function seen(PlUser $user, $last)
+ {
+ $birthday = strtotime($user->profile()->next_birthday);
+ return $birthday > $last + self::WATCH_LIMIT
+ || date('Ymd', $birthday) == date('Ymd');
}
}
-// }}}
-// {{{ class WatchSub
+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 $filters = array();
+
+ public function __construct(PlUser $user, $date = null)
+ {
+ $this->user = $user;
+ $this->date = self::getDate($user, $date);
+ }
+
+ public function user()
+ {
+ return $this->user;
+ }
-class WatchSub {
- var $_uid;
- var $_data = Array();
+ public function profile()
+ {
+ return $this->user->profile();
+ }
+
+ public function date()
+ {
+ return $this->date;
+ }
- function WatchSub($uid) {
- $this->_uid = $uid;
- global $globals;
- $res = $globals->xdb->iterRow('SELECT cid FROM watch_sub WHERE uid={?}', $uid);
- while(list($c) = $res->next()) {
- $this->_data[$c] = $c;
+ public function contactCondition()
+ {
+ if (!$this->contactCond) {
+ $this->contactCond = new UFC_WatchContact($this->user);
}
+ return $this->contactCond;
}
- function update($ind) {
- global $globals;
- $this->_data = Array();
- $globals->xdb->execute('DELETE FROM watch_sub WHERE uid={?}', $this->_uid);
- foreach(Env::getMixed($ind) as $key=>$val) {
- $globals->xdb->query('INSERT INTO watch_sub SELECT {?},id FROM watch_cat WHERE id={?}', $this->_uid, $key);
- if(mysql_affected_rows()) {
- $this->_data[$key] = $key;
- }
- }
+ public function promoCondition()
+ {
+ if (!$this->promoCond) {
+ $this->promoCond = new UFC_WatchPromo($this->user);
+ }
+ return $this->promoCond;
}
-}
-// }}}
-// {{{ class PromoNotifs
+ private function fetchEventWatch($class)
+ {
+ if (!isset(self::$events[$class])) {
+ self::$events[$class] = new $class();
+ }
+ return self::$events[$class];
+ }
-class PromoNotifs {
- var $_uid;
- var $_data = Array();
+ private function fetchFilter($class)
+ {
- function PromoNotifs($uid) {
- $this->_uid = $uid;
- global $globals;
- $res = $globals->xdb->iterRow('SELECT promo FROM watch_promo WHERE uid={?} ORDER BY promo', $uid);
- while (list($p) = $res->next()) {
- $this->_data[intval($p)] = intval($p);
+ if (!isset($this->filters[$class])) {
+ $event = $this->fetchEventWatch($class);
+ $this->filters[$class] = new UserFilter($event->getCondition($this),
+ array($event->getOrder(), new UFO_Name(Profile::DN_SORT)));
}
+ return $this->filters[$class];
}
- function add($p) {
- global $globals;
- $promo = intval($p);
- $globals->xdb->execute('REPLACE INTO watch_promo (uid,promo) VALUES({?},{?})', $this->_uid, $promo);
- $this->_data[$promo] = $promo;
- asort($this->_data);
- }
-
- function del($p) {
- global $globals;
- $promo = intval($p);
- $globals->xdb->execute('DELETE FROM watch_promo WHERE uid={?} AND promo={?}', $this->_uid, $promo);
- unset($this->_data[$promo]);
- }
-
- function addRange($_p1,$_p2) {
- global $globals;
- $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;
- }
- $globals->xdb->execute('REPLACE INTO watch_promo (uid,promo) VALUES '.join(',',$values));
- asort($this->_data);
- }
-
- function delRange($_p1,$_p2) {
- global $globals;
- $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]);
- }
- $globals->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);
- }
- }
- if(isset($I[0])) $ranges[] = $I;
- return $ranges;
+ public function count()
+ {
+ $count = 0;
+ foreach (self::$classes as $class) {
+ $uf = $this->fetchFilter($class);
+ $count += $uf->getTotalCount();
+ }
+ return $count;
+ }
+
+
+ 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);
+ }
+ }
+
+ public function events()
+ {
+ $events = array();
+ foreach (self::$classes as $class) {
+ $e = $this->fetchEvents($class);
+ if (!is_null($e)) {
+ $events[] = $e;
+ }
+ }
+ return $events;
}
-}
-// }}}
-// {{{ class NoninsNotifs
-
-class NoninsNotifs {
- var $_uid;
- var $_data = Array();
-
- function NoninsNotifs($uid) {
- global $globals;
- $this->_uid = $uid;
- $res = $globals->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) {
- global $globals;
- unset($this->_data["$p"]);
- $globals->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) {
- global $globals;
- $globals->xdb->execute('INSERT INTO watch_nonins (uid,ni_id) VALUES({?},{?})', $this->_uid, $p);
- $res = $globals->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:
?>