]>
git.wh0rd.org - tt-rss.git/blob - classes/digest.php
6 * Send by mail a digest of last articles.
8 * @param mixed $link The database connection.
9 * @param integer $limit The maximum number of articles by digest.
10 * @return boolean Return false if digests are not enabled.
12 static function send_headlines_digests($debug = false) {
14 require_once 'classes/ttrssmailer.php';
16 $user_limit = 15; // amount of users to process (e.g. emails to send out)
17 $limit = 1000; // maximum amount of headlines to include
19 if ($debug) _debug("Sending digests, batch of max $user_limit users, headline limit = $limit");
21 if (DB_TYPE
== "pgsql") {
22 $interval_query = "last_digest_sent < NOW() - INTERVAL '1 days'";
23 } else if (DB_TYPE
== "mysql") {
24 $interval_query = "last_digest_sent < DATE_SUB(NOW(), INTERVAL 1 DAY)";
27 $result = db_query("SELECT id,email FROM ttrss_users
28 WHERE email != '' AND (last_digest_sent IS NULL OR $interval_query)");
30 while ($line = db_fetch_assoc($result)) {
32 if (@get_pref
('DIGEST_ENABLE', $line['id'], false)) {
33 $preferred_ts = strtotime(get_pref('DIGEST_PREFERRED_TIME', $line['id'], '00:00'));
35 // try to send digests within 2 hours of preferred time
36 if ($preferred_ts && time() >= $preferred_ts &&
37 time() - $preferred_ts <= 7200
40 if ($debug) _debug("Sending digest for UID:" . $line['id'] . " - " . $line["email"]);
42 $do_catchup = get_pref('DIGEST_CATCHUP', $line['id'], false);
46 // reset tz_offset global to prevent tz cache clash between users
49 $tuple = Digest
::prepare_headlines_digest($line["id"], 1, $limit);
51 $headlines_count = $tuple[1];
52 $affected_ids = $tuple[2];
53 $digest_text = $tuple[3];
55 if ($headlines_count > 0) {
57 $mail = new ttrssMailer();
59 $rc = $mail->quickMail($line["email"], $line["login"], DIGEST_SUBJECT
, $digest, $digest_text);
61 if (!$rc && $debug) _debug("ERROR: " . $mail->ErrorInfo
);
63 if ($debug) _debug("RC=$rc");
65 if ($rc && $do_catchup) {
66 if ($debug) _debug("Marking affected articles as read...");
67 Article
::catchupArticlesById($affected_ids, 0, $line["id"]);
70 if ($debug) _debug("No headlines");
73 db_query("UPDATE ttrss_users SET last_digest_sent = NOW()
74 WHERE id = " . $line["id"]);
80 if ($debug) _debug("All done.");
84 static function prepare_headlines_digest($user_id, $days = 1, $limit = 1000) {
86 require_once "lib/MiniTemplator.class.php";
88 $tpl = new MiniTemplator
;
89 $tpl_t = new MiniTemplator
;
91 $tpl->readTemplateFromFile("templates/digest_template_html.txt");
92 $tpl_t->readTemplateFromFile("templates/digest_template.txt");
94 $user_tz_string = get_pref('USER_TIMEZONE', $user_id);
95 $local_ts = convert_timestamp(time(), 'UTC', $user_tz_string);
97 $tpl->setVariable('CUR_DATE', date('Y/m/d', $local_ts));
98 $tpl->setVariable('CUR_TIME', date('G:i', $local_ts));
100 $tpl_t->setVariable('CUR_DATE', date('Y/m/d', $local_ts));
101 $tpl_t->setVariable('CUR_TIME', date('G:i', $local_ts));
103 $affected_ids = array();
105 if (DB_TYPE
== "pgsql") {
106 $interval_query = "ttrss_entries.date_updated > NOW() - INTERVAL '$days days'";
107 } else if (DB_TYPE
== "mysql") {
108 $interval_query = "ttrss_entries.date_updated > DATE_SUB(NOW(), INTERVAL $days DAY)";
111 $result = db_query("SELECT ttrss_entries.title,
112 ttrss_feeds.title AS feed_title,
113 COALESCE(ttrss_feed_categories.title, '" . __('Uncategorized') . "') AS cat_title,
115 ttrss_user_entries.ref_id,
119 " . SUBSTRING_FOR_DATE
. "(last_updated,1,19) AS last_updated
121 ttrss_user_entries,ttrss_entries,ttrss_feeds
123 ttrss_feed_categories ON (cat_id = ttrss_feed_categories.id)
125 ref_id = ttrss_entries.id AND feed_id = ttrss_feeds.id
126 AND include_in_digest = true
128 AND ttrss_user_entries.owner_uid = $user_id
131 ORDER BY ttrss_feed_categories.title, ttrss_feeds.title, score DESC, date_updated DESC
134 $headlines_count = db_num_rows($result);
136 $headlines = array();
138 while ($line = db_fetch_assoc($result)) {
139 array_push($headlines, $line);
142 for ($i = 0; $i < sizeof($headlines); $i++
) {
144 $line = $headlines[$i];
146 array_push($affected_ids, $line["ref_id"]);
148 $updated = make_local_datetime($line['last_updated'], false,
151 /* if ($line["score"] != 0) {
152 if ($line["score"] > 0) $line["score"] = '+' . $line["score"];
154 $line["title"] .= " (".$line['score'].")";
157 if (get_pref('ENABLE_FEED_CATS', $user_id)) {
158 $line['feed_title'] = $line['cat_title'] . " / " . $line['feed_title'];
161 $tpl->setVariable('FEED_TITLE', $line["feed_title"]);
162 $tpl->setVariable('ARTICLE_TITLE', $line["title"]);
163 $tpl->setVariable('ARTICLE_LINK', $line["link"]);
164 $tpl->setVariable('ARTICLE_UPDATED', $updated);
165 $tpl->setVariable('ARTICLE_EXCERPT',
166 truncate_string(strip_tags($line["content"]), 300));
167 // $tpl->setVariable('ARTICLE_CONTENT',
168 // strip_tags($article_content));
170 $tpl->addBlock('article');
172 $tpl_t->setVariable('FEED_TITLE', $line["feed_title"]);
173 $tpl_t->setVariable('ARTICLE_TITLE', $line["title"]);
174 $tpl_t->setVariable('ARTICLE_LINK', $line["link"]);
175 $tpl_t->setVariable('ARTICLE_UPDATED', $updated);
176 // $tpl_t->setVariable('ARTICLE_EXCERPT',
177 // truncate_string(strip_tags($line["excerpt"]), 100));
179 $tpl_t->addBlock('article');
181 if ($headlines[$i]['feed_title'] != $headlines[$i +
1]['feed_title']) {
182 $tpl->addBlock('feed');
183 $tpl_t->addBlock('feed');
188 $tpl->addBlock('digest');
189 $tpl->generateOutputToString($tmp);
191 $tpl_t->addBlock('digest');
192 $tpl_t->generateOutputToString($tmp_t);
194 return array($tmp, $headlines_count, $affected_ids, $tmp_t);