X-Git-Url: http://git.polytechnique.org/?a=blobdiff_plain;f=include%2Fmassmailer.inc.php;h=19996fe4befd2ba660f7a288165fe00f184160c4;hb=68ef4e7d2c4d1bfd08e59d6118047044530c4ae2;hp=e326a31d04ae5ab6ab55734468cc5eedbd3fdcb6;hpb=16cd99fb32e14082c9745ba6d1fbc29a6aa5ae51;p=platal.git diff --git a/include/massmailer.inc.php b/include/massmailer.inc.php index e326a31..19996fe 100644 --- a/include/massmailer.inc.php +++ b/include/massmailer.inc.php @@ -1,6 +1,6 @@ _tpl = $tpl; $this->_css = $css; $this->_prefix = $prefix; + $this->_table = $tbl; + $this->_subscriptionTable = $stbl; } public function id() @@ -48,6 +53,53 @@ abstract class MassMailer return is_null($this->_shortname) ? $this->_id : $this->_shortname; } + private function selectId($where) + { + $res = XDB::query("SELECT IF (n.short_name IS NULL, n.id, n.short_name) + FROM {$this->_table} AS n + WHERE n.bits != 'new' AND {$where} + LIMIT 1"); + if ($res->numRows() != 1) { + return null; + } + return $res->fetchOneCell(); + } + + public function prev() + { + static $val; + if (!isset($val)) { + $val = $this->selectId("n.id < {$this->_id} ORDER BY n.id DESC"); + } + return $val; + } + + public function next() + { + static $val; + if (!isset($val)) { + $val = $this->selectId("n.id > {$this->_id} ORDER BY n.id"); + } + return $val; + } + + public function last() + { + static $val; + if (!isset($val)) { + $res = XDB::query("SELECT MAX(n.id) + FROM {$this->_table} AS n + WHERE n.bits != 'new' AND n.id > {?}", + $this->_id); + if ($res->numRows() != 1) { + $val = null; + } else { + $val = $res->fetchOneCell(); + } + } + return $val; + } + public function title($mail = false) { return $mail ? $this->_title_mail : $this->_title; @@ -56,18 +108,13 @@ abstract class MassMailer public function head($prenom = null, $nom = null, $sexe = null, $type = 'text') { if (is_null($prenom)) { - return $this->_head; + return $this->_head; } else { $head = $this->_head; - $head = str_replace('', $sexe ? 'Chère' : 'Cher', $head); + $head = str_replace('', $sexe ? 'Chère' : 'Cher', $head); $head = str_replace('', $prenom, $head); $head = str_replace('', $nom, $head); - if ($type == 'text') { - $head = enriched_to_text($head, false, true, 2, 64); - } else { - $head = enriched_to_text($head, true); - } - return $head; + return format_text($head, $type, 2, 64); } } @@ -78,7 +125,7 @@ abstract class MassMailer return true; } else { $css = file_get_contents(dirname(__FILE__) . '/../htdocs/css/' . $this->_css); - return preg_replace('@/\*.*?\*/@s', '', $css); + return preg_replace('@/\*.*?\*/@us', '', $css); } } @@ -86,7 +133,7 @@ abstract class MassMailer { $this->css($page); $page->assign('is_mail', false); - $page->assign('html_version', false); + $page->assign('mail_part', 'text'); $page->assign('prenom', $prenom); $page->assign('nom', $nom); $page->assign('sexe', $sexe); @@ -98,16 +145,41 @@ abstract class MassMailer $this->css($page); $page->assign('prefix', $this->_prefix . '/' . $this->id()); $page->assign('is_mail', false); - $page->assign('html_version', true); + $page->assign('mail_part', 'html'); $page->assign('prenom', $prenom); $page->assign('nom', $nom); $page->assign('sexe', $sexe); $this->assignData($page); } - public function sendTo($prenom, $nom, $login, $sexe, $html) + private function createHash($line, $key = null) + { + $hash = implode(time(), $line) . rand(); + $hash = md5($hash); + return $hash; + } + + public function sendTo($prenom, $nom, $login, $sexe, $html, $hash = 0) { global $globals; + $alias = $login; + if (strpos($login, '@') === false) { + $login = "$login@{$globals->mail->domain}"; + } + require_once('user.func.inc.php'); + $forlife = get_user_forlife($login, '_silent_user_callback'); + if ($forlife) { + $alias = $forlife; + } + if (strpos($alias, '@') === false && (is_null($hash) || $hash == 0)) { + + $hash = $this->createHash(array($prenom, $nom, $login, $sexe, $html, rand(), "X.org rulez")); + XDB::query("UPDATE {$this->_subscriptionTable} as ni + INNER JOIN aliases AS a ON (ni.user_id = a.id) + SET ni.hash = {?} + WHERE ni.user_id != 0 AND a.alias = {?}", + $hash, $alias); + } $mailer = new PlMailer($this->_tpl); $this->assignData($mailer); @@ -116,38 +188,48 @@ abstract class MassMailer $mailer->assign('nom', $nom); $mailer->assign('sexe', $sexe); $mailer->assign('prefix', null); - $mailer->addTo("\"$prenom $nom\" <$login@{$globals->mail->domain}>"); + $mailer->assign('hash', $hash); + $mailer->assign('email', $login); + $mailer->assign('alias', $alias); + $mailer->addTo("\"$prenom $nom\" <$login>"); $mailer->send($html); } + protected function getAllRecipients() + { + global $globals; + return "SELECT u.user_id, CONCAT(a.alias, '@{$globals->mail->domain}'), + u.prenom, IF(u.nom_usage='', u.nom, u.nom_usage), + FIND_IN_SET('femme', u.flags), + q.core_mail_fmt AS pref, ni.hash AS hash + FROM {$this->_subscriptionTable} AS ni + INNER JOIN auth_user_md5 AS u USING(user_id) + INNER JOIN auth_user_quick AS q ON(q.user_id = u.user_id) + INNER JOIN aliases AS a ON(u.user_id=a.id AND FIND_IN_SET('bestalias',a.flags)) + LEFT JOIN emails AS e ON(e.uid=u.user_id AND e.flags='active') + WHERE ni.last < {?} AND ({$this->subscriptionWhere()}) AND + (e.email IS NOT NULL OR FIND_IN_SET('googleapps', u.mail_storage)) + GROUP BY u.user_id"; + } + public function sendToAll() { $this->setSent(); - $query = "SELECT u.user_id, a.alias, - u.prenom, IF(u.nom_usage='', u.nom, u.nom_usage), - FIND_IN_SET('femme', u.flags), - q.core_mail_fmt AS pref - FROM {$this->subscriptionTable()} AS ni - INNER JOIN auth_user_md5 AS u USING(user_id) - INNER JOIN auth_user_quick AS q ON(q.user_id = u.user_id) - INNER JOIN aliases AS a ON(u.user_id=a.id AND FIND_IN_SET('bestalias',a.flags)) - LEFT JOIN emails AS e ON(e.uid=u.user_id AND e.flags='active') - WHERE ni.last < {?} AND ({$this->subscriptionWhere()}) AND e.email IS NOT NULL - GROUP BY u.user_id - LIMIT 60"; + $query = $this->getAllRecipients() . " LIMIT {?}"; while (true) { - $res = XDB::iterRow($query, $this->_id); + $res = XDB::iterRow($query, $this->_id, 60); if (!$res->total()) { - exit; + return; } $sent = array(); - while (list($uid, $bestalias, $prenom, $nom, $sexe, $fmt) = $res->next()) { - $sent[] = "user_id='$uid'"; - $this->sendTo($prenom, $nom, $bestalias, $sexe, $fmt=='html'); + while (list($uid, $bestalias, $prenom, $nom, $sexe, $fmt, $hash) = $res->next()) { + $sent[] = "(user_id='$uid'" . (!$uid ? " AND email='$bestalias')": ')'); + $this->sendTo($prenom, $nom, $bestalias, $sexe, $fmt=='html', $hash); } - XDB::execute("UPDATE {$this->subscriptionTable()} + XDB::execute("UPDATE {$this->_subscriptionTable} SET last = {?} WHERE " . implode(' OR ', $sent), $this->_id); + sleep(60); } } @@ -155,87 +237,23 @@ abstract class MassMailer abstract protected function assignData(&$smarty); abstract protected function setSent(); - abstract protected function subscriptionTable(); abstract protected function subscriptionWhere(); } // }}} // {{{ Functions -function justify($text,$n) +function format_text($input, $format, $indent = 0, $width = 68) { - $arr = explode("\n",wordwrap($text,$n)); - $arr = array_map('trim',$arr); - $res = ''; - foreach ($arr as $key => $line) { - $nxl = isset($arr[$key+1]) ? trim($arr[$key+1]) : ''; - $nxl_split = preg_split('! +!',$nxl); - $nxw_len = count($nxl_split) ? strlen($nxl_split[0]) : 0; - $line = trim($line); - - if (strlen($line)+1+$nxw_len < $n) { - $res .= "$line\n"; - continue; - } - - if (preg_match('![.:;]$!',$line)) { - $res .= "$line\n"; - continue; - } - - $tmp = preg_split('! +!',trim($line)); - $words = count($tmp); - if ($words <= 1) { - $res .= "$line\n"; - continue; - } - - $len = array_sum(array_map('strlen',$tmp)); - $empty = $n - $len; - $sw = floatval($empty) / floatval($words-1); - - $cur = 0; - $l = ''; - foreach ($tmp as $word) { - $l .= $word; - $cur += $sw + strlen($word); - $l = str_pad($l,intval($cur+0.5)); - } - $res .= trim($l)."\n"; - } - return trim($res); -} - -function enriched_to_text($input,$html=false,$just=false,$indent=0,$width=68) -{ - $text = trim($input); - if ($html) { - $text = htmlspecialchars($text); - $text = str_replace('[b]','', $text); - $text = str_replace('[/b]','', $text); - $text = str_replace('[i]','', $text); - $text = str_replace('[/i]','', $text); - $text = str_replace('[u]','', $text); - $text = str_replace('[/u]','', $text); - require_once('url_catcher.inc.php'); - $text = url_catcher($text); - return nl2br($text); - } else { - $text = preg_replace('!\[\/?b\]!','*',$text); - $text = preg_replace('!\[\/?u\]!','_',$text); - $text = preg_replace('!\[\/?i\]!','/',$text); - $text = preg_replace('!(((https?|ftp)://|www\.)[^\r\n\t ]*)!','[\1]', $text); - $text = preg_replace('!(([a-zA-Z0-9\-_+.]*@[a-zA-Z0-9\-_+.]*)(?:\?[^\r\n\t ]*)?)!','[mailto:\1]', $text); - $text = $just ? justify($text,$width-$indent) : wordwrap($text,$width-$indent); - if($indent) { - $ind = str_pad('',$indent); - $text = $ind.str_replace("\n","\n$ind",$text); - } - return $text; + if ($format == 'text') { + return MiniWiki::WikiToText($input, true, $indent, $width, "title"); } + return MiniWiki::WikiToHTML($input, "title"); } +// function enriched_to_text($input,$html=false,$just=false,$indent=0,$width=68) + // }}} -// vim:set et sw=4 sts=4 sws=4: +// vim:set et sw=4 sts=4 sws=4 enc=utf-8: ?>