include/notifs.inc.php

   1 <?php
   2 /***************************************************************************
   3  *  Copyright (C) 2003-2006 Polytechnique.org                              *
   4  *  http://opensource.polytechnique.org/                                   *
   5  *                                                                         *
   6  *  This program is free software; you can redistribute it and/or modify   *
   7  *  it under the terms of the GNU General Public License as published by   *
   8  *  the Free Software Foundation; either version 2 of the License, or      *
   9  *  (at your option) any later version.                                    *
  10  *                                                                         *
  11  *  This program is distributed in the hope that it will be useful,        *
  12  *  but WITHOUT ANY WARRANTY; without even the implied warranty of         *
  13  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the          *
  14  *  GNU General Public License for more details.                           *
  15  *                                                                         *
  16  *  You should have received a copy of the GNU General Public License      *
  17  *  along with this program; if not, write to the Free Software            *
  18  *  Foundation, Inc.,                                                      *
  19  *  59 Temple Place, Suite 330, Boston, MA  02111-1307  USA                *
  20  ***************************************************************************/
  21
  22 define('WATCH_FICHE', 1);
  23 define('WATCH_INSCR', 2);
  24 define('WATCH_DEATH', 3);
  25 define('WATCH_BIRTH', 4);
  26
  27 // {{{ function inscription_notifs_base
  28
  29 function inscription_notifs_base($uid)
  30 {
  31     global $globals;
  32     XDB::execute('REPLACE INTO  watch_sub (uid,cid) SELECT {?},id FROM watch_cat', $uid);
  33 }
  34
  35 // }}}
  36 // {{{ function register_watch_op
  37
  38 function register_watch_op($uid, $cid, $date='', $info='')
  39 {
  40     global $globals;
  41     if (empty($date)) {
  42         $date = date('Y-m-d');
  43     };
  44     XDB::execute('REPLACE INTO watch_ops (uid,cid,known,date,info) VALUES({?},{?},NOW(),{?},{?})',
  45             $uid, $cid, $date, $info);
  46     if($cid == WATCH_FICHE) {
  47         XDB::execute('UPDATE auth_user_md5 SET DATE=NOW() WHERE user_id={?}', $uid);
  48     } elseif($cid == WATCH_INSCR) {
  49         XDB::execute('REPLACE INTO  contacts (uid,contact)
  50                                       SELECT  uid,ni_id
  51                                         FROM  watch_nonins
  52                                        WHERE  ni_id={?}', $uid);
  53         XDB::execute('DELETE FROM watch_nonins WHERE ni_id={?}', $uid);
  54     }
  55 }
  56
  57 // }}}
  58 // {{{ function _select_notifs_base
  59
  60 function _select_notifs_base($table, $mail, $where)
  61 {
  62     $cases = Array(
  63             'contacts'     => Array('wfield' => 'contact', 'ufield' => 'user_id', 'need_contact' => false,
  64                 'freq_sql' => '',
  65                 'contact_sql' => '1'
  66             ),
  67             'watch_promo'  => Array('wfield' => 'promo',   'ufield' => 'promo',   'need_contact' => true,
  68                 'freq_sql' => ' AND ( wc.type = "basic" OR wc.type="near" AND (u.promo <= v.promo_sortie-2 AND u.promo_sortie >= v.promo+2) )',
  69                 'contact_sql' => 'NOT (c.contact IS NULL)'
  70             ),
  71             'watch_nonins' => Array('wfield' => 'ni_id',   'ufield' => 'user_id', 'need_contact' => false,
  72                 'freq_sql' => '',
  73                 'contact_sql' => '0'
  74             )
  75     );
  76
  77     $our   = $cases[$table];
  78     $sql = "
  79         (
  80           SELECT  u.promo, u.prenom, IF(u.nom_usage='',u.nom,u.nom_usage) AS nom,
  81                   u.deces != 0 AS dcd,
  82                   a.alias AS bestalias,
  83                   wo.*,
  84                   {$our['contact_sql']} AS contact,
  85                   (u.perms IN('admin','user')) AS inscrit";
  86     if ($mail) {
  87         $sql.=",
  88                   w.uid AS aid, v.prenom AS aprenom, IF(v.nom_usage='',v.nom,v.nom_usage) AS anom,
  89                   b.alias AS abestalias, (v.flags='femme') AS sexe, q.core_mail_fmt AS mail_fmt";
  90     }
  91
  92     $sql .= "
  93             FROM  $table          AS w
  94       INNER JOIN  auth_user_md5   AS u  ON(u.{$our['ufield']} = w.{$our['wfield']})
  95       INNER JOIN  auth_user_quick AS q  ON(q.user_id = w.uid)
  96       INNER JOIN  auth_user_md5   AS v  ON(v.user_id = q.user_id)";
  97     if ($mail) {
  98         $sql .="
  99       INNER JOIN  aliases         AS b  ON(b.id = q.user_id AND FIND_IN_SET('bestalias', b.flags))";
 100     }
 101     if ($our['need_contact']) {
 102         $sql .="
 103        LEFT JOIN  contacts        AS c  ON(c.uid = w.uid AND c.contact = u.user_id)";
 104     }
 105
 106     $sql .="
 107       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() )').")
 108       INNER JOIN  watch_sub       AS ws ON(ws.cid = wo.cid AND ws.uid = w.uid)
 109       INNER JOIN  watch_cat       AS wc ON(wc.id = wo.cid{$our['freq_sql']})
 110        LEFT JOIN  aliases         AS a  ON(a.id = u.user_id AND FIND_IN_SET('bestalias', a.flags))
 111            WHERE  $where
 112         )";
 113
 114     return $sql;
 115 }
 116
 117 // }}}
 118 // {{{ function select_notifs
 119
 120 function select_notifs($mail, $uid=null, $last=null, $iterator=true)
 121 {
 122     global $globals;
 123     $where = $mail ? 'q.watch_flags=3' : 'w.uid = {?}';
 124     $sql   = _select_notifs_base('contacts',     $mail, $where.($mail?'':' AND (q.watch_flags=1 OR q.watch_flags=3)')) . " UNION DISTINCT ";
 125     $sql  .= _select_notifs_base('watch_promo',  $mail, $where) .  " UNION DISTINCT ";
 126     $sql  .= _select_notifs_base('watch_nonins', $mail, $where);
 127
 128     if ($iterator) {
 129         return XDB::iterator($sql . ' ORDER BY cid, promo, date DESC, nom', $last, $uid, $last, $uid, $last, $uid);
 130     } else {
 131         return XDB::query($sql, $last, $uid, $last, $uid, $last, $uid);
 132     }
 133 }
 134
 135 // }}}
 136 // {{{ function getNbNotifs
 137
 138 function getNbNotifs() {
 139     global $globals;
 140     if (!Session::has('uid')) {
 141         return 0;
 142     }
 143     $uid       = Session::getInt('uid', -1);
 144     $watchlast = Session::get('watch_last');
 145
 146     // selectionne les notifs de uid, sans detail sur le watcher, depuis $watchlast, meme ceux sans surveillance, non ordonnés
 147     $res = select_notifs(false, $uid, $watchlast, false);
 148     $n   = $res->numRows();
 149     $res->free();
 150     $url = $globals->baseurl."/carnet/panel";
 151     if($n==0) { return; }
 152     if($n==1) { return "<a href='$url'>1 évènement !</a>"; }
 153     return "<a href='$url'>$n évènements !</a>";
 154 }
 155
 156 // }}}
 157 // {{{ class AllNotifs
 158
 159 class AllNotifs {
 160     var $_cats = Array();
 161     var $_data = Array();
 162
 163     function AllNotifs() {
 164         global $globals;
 165
 166         $res = XDB::iterator("SELECT * FROM watch_cat");
 167         while($tmp = $res->next()) {
 168             $this->_cats[$tmp['id']] = $tmp;
 169         }
 170
 171         // 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
 172         $res = select_notifs(true);
 173
 174         while($tmp = $res->next()) {
 175             $aid = $tmp['aid'];
 176             if (empty($this->_data[$aid])) {
 177                 $this->_data[$aid] = Array("prenom" => $tmp['aprenom'], 'nom' => $tmp['anom'],
 178                         'bestalias'=>$tmp['abestalias'], 'sexe' => $tmp['sexe'], 'mail_fmt' => $tmp['mail_fmt'],
 179                         'dcd'=>$tmp['dcd']);
 180             }
 181             unset($tmp['aprenom'], $tmp['anom'], $tmp['abestalias'], $tmp['aid'], $tmp['sexe'], $tmp['mail_fmt'], $tmp['dcd']);
 182             $this->_data[$aid]['data'][$tmp['cid']][] = $tmp;
 183         }
 184     }
 185 }
 186
 187 // }}}
 188 // {{{ class Notifs
 189
 190 class Notifs {
 191     var $_uid;
 192     var $_cats = Array();
 193     var $_data = Array();
 194
 195     function Notifs($uid, $up=false) {
 196         global $globals;
 197         $this->_uid = $uid;
 198
 199         $res = XDB::iterator("SELECT * FROM watch_cat");
 200         while($tmp = $res->next()) {
 201             $this->_cats[$tmp['id']] = $tmp;
 202         }
 203
 204         $lastweek = date('YmdHis',mktime() - 7*24*60*60);
 205
 206         // recupere les notifs du watcher $uid, sans detail sur le watcher, depuis la semaine dernière, meme ceux sans surveillance, ordonnés
 207         $res = select_notifs(false, $uid, $lastweek);
 208         while($tmp = $res->next()) {
 209             $this->_data[$tmp['cid']][$tmp['promo']][] = $tmp;
 210         }
 211
 212         if($up) {
 213             XDB::execute('UPDATE auth_user_quick SET watch_last=NOW() WHERE user_id={?}', $uid);
 214         }
 215     }
 216 }
 217
 218 // }}}
 219 // {{{ class Watch
 220
 221 class Watch {
 222     var $_uid;
 223     var $_promos;
 224     var $_nonins;
 225     var $_cats = Array();
 226     var $_subs;
 227     var $watch_contacts;
 228     var $watch_mail;
 229
 230     function Watch($uid) {
 231         global $globals;
 232         $this->_uid = $uid;
 233         $this->_promos = new PromoNotifs($uid);
 234         $this->_nonins = new NoninsNotifs($uid);
 235         $this->_subs = new WatchSub($uid);
 236         $res = XDB::query("SELECT  FIND_IN_SET('contacts',watch_flags),FIND_IN_SET('mail',watch_flags)
 237                                        FROM  auth_user_quick
 238                                       WHERE  user_id={?}", $uid);
 239         list($this->watch_contacts,$this->watch_mail) = $res->fetchOneRow();
 240
 241         $res = XDB::iterator("SELECT * FROM watch_cat");
 242         while($tmp = $res->next()) {
 243             $this->_cats[$tmp['id']] = $tmp;
 244         }
 245     }
 246
 247     function saveFlags() {
 248         global $globals;
 249         $flags = "";
 250         if($this->watch_contacts) $flags = "contacts";
 251         if($this->watch_mail) $flags .= ($flags ? ',' : '')."mail";
 252         XDB::execute('UPDATE auth_user_quick SET watch_flags={?} WHERE user_id={?}', $flags, $this->_uid);
 253
 254     }
 255
 256     function cats() {
 257         return $this->_cats;
 258     }
 259
 260     function subs($i) {
 261         return $this->_subs->_data[$i];
 262     }
 263
 264     function promos() {
 265         return $this->_promos->toRanges();
 266     }
 267
 268     function nonins() {
 269         return $this->_nonins->_data;
 270     }
 271 }
 272
 273 // }}}
 274 // {{{ class WatchSub
 275
 276 class WatchSub {
 277     var $_uid;
 278     var $_data = Array();
 279
 280     function WatchSub($uid) {
 281         $this->_uid = $uid;
 282         global $globals;
 283         $res = XDB::iterRow('SELECT cid FROM watch_sub WHERE uid={?}', $uid);
 284         while(list($c) = $res->next()) {
 285             $this->_data[$c] = $c;
 286         }
 287     }
 288
 289     function update($ind) {
 290         global $globals;
 291         $this->_data = Array();
 292         XDB::execute('DELETE FROM watch_sub WHERE uid={?}', $this->_uid);
 293         foreach(Env::getMixed($ind) as $key=>$val) {
 294             XDB::query('INSERT INTO watch_sub SELECT {?},id FROM watch_cat WHERE id={?}', $this->_uid, $key);
 295             if(mysql_affected_rows()) {
 296                 $this->_data[$key] = $key;
 297             }
 298         }
 299     }
 300 }
 301
 302 // }}}
 303 // {{{ class PromoNotifs
 304
 305 class PromoNotifs {
 306     var $_uid;
 307     var $_data = Array();
 308
 309     function PromoNotifs($uid) {
 310         $this->_uid = $uid;
 311         global $globals;
 312         $res = XDB::iterRow('SELECT promo FROM watch_promo WHERE uid={?} ORDER BY promo', $uid);
 313         while (list($p) = $res->next()) {
 314             $this->_data[intval($p)] = intval($p);
 315         }
 316     }
 317
 318     function add($p) {
 319         global $globals;
 320         $promo = intval($p);
 321         XDB::execute('REPLACE INTO watch_promo (uid,promo) VALUES({?},{?})', $this->_uid, $promo);
 322         $this->_data[$promo] = $promo;
 323         asort($this->_data);
 324     }
 325
 326     function del($p) {
 327         global $globals;
 328         $promo = intval($p);
 329         XDB::execute('DELETE FROM watch_promo WHERE uid={?} AND promo={?}', $this->_uid, $promo);
 330         unset($this->_data[$promo]);
 331     }
 332
 333     function addRange($_p1,$_p2) {
 334         global $globals;
 335         $p1 = intval($_p1);
 336         $p2 = intval($_p2);
 337         $values = Array();
 338         for($i = min($p1,$p2); $i<=max($p1,$p2); $i++) {
 339             $values[] = "('{$this->_uid}',$i)";
 340             $this->_data[$i] = $i;
 341         }
 342         XDB::execute('REPLACE INTO watch_promo (uid,promo) VALUES '.join(',',$values));
 343         asort($this->_data);
 344     }
 345
 346     function delRange($_p1,$_p2) {
 347         global $globals;
 348         $p1 = intval($_p1);
 349         $p2 = intval($_p2);
 350         $where = Array();
 351         for($i = min($p1,$p2); $i<=max($p1,$p2); $i++) {
 352             $where[] = "promo=$i";
 353             unset($this->_data[$i]);
 354         }
 355         XDB::execute('DELETE FROM watch_promo WHERE uid={?} AND ('.join(' OR ',$where).')', $this->_uid);
 356     }
 357
 358     function toRanges() {
 359         $ranges = Array();
 360         $I = Array();
 361         foreach($this->_data as $promo) {
 362             if(!isset($I[0])) {
 363                 $I = Array($promo,$promo);
 364             }
 365             elseif($I[1]+1 == $promo) {
 366                 $I[1] ++;
 367             }
 368             else {
 369                 $ranges[] = $I;
 370                 $I = Array($promo,$promo);
 371             }
 372         }
 373         if(isset($I[0])) $ranges[] = $I;
 374         return $ranges;
 375     }
 376 }
 377
 378 // }}}
 379 // {{{ class NoninsNotifs
 380
 381 class NoninsNotifs {
 382     var $_uid;
 383     var $_data = Array();
 384
 385     function NoninsNotifs($uid) {
 386         global $globals;
 387         $this->_uid = $uid;
 388         $res = XDB::iterator("SELECT  u.prenom,IF(u.nom_usage='',u.nom,u.nom_usage) AS nom, u.promo, u.user_id
 389                                           FROM  watch_nonins  AS w
 390                                     INNER JOIN  auth_user_md5 AS u ON (u.user_id = w.ni_id)
 391                                          WHERE  w.uid = {?}
 392                                       ORDER BY  promo,nom", $uid);
 393         while($tmp = $res->next()) {
 394             $this->_data[$tmp['user_id']] = $tmp;
 395         }
 396     }
 397
 398     function del($p) {
 399         global $globals;
 400         unset($this->_data["$p"]);
 401         XDB::execute('DELETE FROM watch_nonins WHERE uid={?} AND ni_id={?}', $this->_uid, $p);
 402     }
 403
 404     function add($p) {
 405         global $globals;
 406         XDB::execute('INSERT INTO watch_nonins (uid,ni_id) VALUES({?},{?})', $this->_uid, $p);
 407         $res = XDB::query('SELECT  prenom,IF(nom_usage="",nom,nom_usage) AS nom,promo,user_id
 408                                        FROM  auth_user_md5
 409                                       WHERE  user_id={?}', $p);
 410         $this->_data["$p"] = $res->fetchOneAssoc();
 411     }
 412 }
 413
 414 // }}}
 415
 416 ?>