]>
Commit | Line | Data |
---|---|---|
f1611683 AD |
1 | <?php |
2 | /** | |
3 | * Send by mail a digest of last articles. | |
4 | * | |
5 | * @param mixed $link The database connection. | |
6 | * @param integer $limit The maximum number of articles by digest. | |
7 | * @return boolean Return false if digests are not enabled. | |
8 | */ | |
9 | function send_headlines_digests($link, $debug = false) { | |
10 | ||
11 | require_once 'lib/phpmailer/class.phpmailer.php'; | |
12 | ||
13 | $user_limit = 15; // amount of users to process (e.g. emails to send out) | |
14 | $limit = 1000; // maximum amount of headlines to include | |
15 | ||
16 | if ($debug) _debug("Sending digests, batch of max $user_limit users, headline limit = $limit"); | |
17 | ||
18 | if (DB_TYPE == "pgsql") { | |
19 | $interval_query = "last_digest_sent < NOW() - INTERVAL '1 days'"; | |
20 | } else if (DB_TYPE == "mysql") { | |
21 | $interval_query = "last_digest_sent < DATE_SUB(NOW(), INTERVAL 1 DAY)"; | |
22 | } | |
23 | ||
24 | $result = db_query($link, "SELECT id,email FROM ttrss_users | |
25 | WHERE email != '' AND (last_digest_sent IS NULL OR $interval_query)"); | |
26 | ||
27 | while ($line = db_fetch_assoc($result)) { | |
28 | ||
29 | if (get_pref($link, 'DIGEST_ENABLE', $line['id'], false)) { | |
30 | $preferred_ts = strtotime(get_pref($link, 'DIGEST_PREFERRED_TIME', $line['id'], '00:00')); | |
31 | ||
32 | // try to send digests within 2 hours of preferred time | |
33 | if ($preferred_ts && time() >= $preferred_ts && | |
34 | time() - $preferred_ts <= 7200) { | |
35 | ||
36 | if ($debug) print "Sending digest for UID:" . $line['id'] . " - " . $line["email"] . " ... "; | |
37 | ||
38 | $do_catchup = get_pref($link, 'DIGEST_CATCHUP', $line['id'], false); | |
39 | ||
40 | global $tz_offset; | |
41 | ||
42 | // reset tz_offset global to prevent tz cache clash between users | |
43 | $tz_offset = -1; | |
44 | ||
45 | $tuple = prepare_headlines_digest($link, $line["id"], 1, $limit); | |
46 | $digest = $tuple[0]; | |
47 | $headlines_count = $tuple[1]; | |
48 | $affected_ids = $tuple[2]; | |
49 | $digest_text = $tuple[3]; | |
50 | ||
51 | if ($headlines_count > 0) { | |
52 | ||
53 | $mail = new PHPMailer(); | |
54 | ||
55 | $mail->PluginDir = "lib/phpmailer/"; | |
56 | $mail->SetLanguage("en", "lib/phpmailer/language/"); | |
57 | ||
58 | $mail->CharSet = "UTF-8"; | |
59 | ||
60 | $mail->From = SMTP_FROM_ADDRESS; | |
61 | $mail->FromName = SMTP_FROM_NAME; | |
62 | $mail->AddAddress($line["email"], $line["login"]); | |
63 | ||
64 | if (SMTP_HOST) { | |
65 | $mail->Host = SMTP_HOST; | |
66 | $mail->Mailer = "smtp"; | |
67 | $mail->SMTPAuth = SMTP_LOGIN != ''; | |
68 | $mail->Username = SMTP_LOGIN; | |
69 | $mail->Password = SMTP_PASSWORD; | |
70 | } | |
71 | ||
72 | $mail->IsHTML(true); | |
73 | $mail->Subject = DIGEST_SUBJECT; | |
74 | $mail->Body = $digest; | |
75 | $mail->AltBody = $digest_text; | |
76 | ||
77 | $rc = $mail->Send(); | |
78 | ||
79 | if (!$rc && $debug) print "ERROR: " . $mail->ErrorInfo; | |
80 | ||
81 | if ($debug) print "RC=$rc\n"; | |
82 | ||
83 | if ($rc && $do_catchup) { | |
84 | if ($debug) print "Marking affected articles as read...\n"; | |
85 | catchupArticlesById($link, $affected_ids, 0, $line["id"]); | |
86 | } | |
87 | } else { | |
88 | if ($debug) print "No headlines\n"; | |
89 | } | |
90 | ||
91 | db_query($link, "UPDATE ttrss_users SET last_digest_sent = NOW() | |
92 | WHERE id = " . $line["id"]); | |
93 | ||
94 | } | |
95 | } | |
96 | } | |
97 | ||
98 | if ($debug) _debug("All done."); | |
99 | ||
100 | } | |
101 | ||
102 | function prepare_headlines_digest($link, $user_id, $days = 1, $limit = 1000) { | |
103 | ||
104 | require_once "lib/MiniTemplator.class.php"; | |
105 | ||
106 | $tpl = new MiniTemplator; | |
107 | $tpl_t = new MiniTemplator; | |
108 | ||
109 | $tpl->readTemplateFromFile("templates/digest_template_html.txt"); | |
110 | $tpl_t->readTemplateFromFile("templates/digest_template.txt"); | |
111 | ||
112 | $user_tz_string = get_pref($link, 'USER_TIMEZONE', $user_id); | |
113 | $local_ts = convert_timestamp(time(), 'UTC', $user_tz_string); | |
114 | ||
115 | $tpl->setVariable('CUR_DATE', date('Y/m/d', $local_ts)); | |
116 | $tpl->setVariable('CUR_TIME', date('G:i', $local_ts)); | |
117 | ||
118 | $tpl_t->setVariable('CUR_DATE', date('Y/m/d', $local_ts)); | |
119 | $tpl_t->setVariable('CUR_TIME', date('G:i', $local_ts)); | |
120 | ||
121 | $affected_ids = array(); | |
122 | ||
123 | if (DB_TYPE == "pgsql") { | |
124 | $interval_query = "ttrss_entries.date_updated > NOW() - INTERVAL '$days days'"; | |
125 | } else if (DB_TYPE == "mysql") { | |
126 | $interval_query = "ttrss_entries.date_updated > DATE_SUB(NOW(), INTERVAL $days DAY)"; | |
127 | } | |
128 | ||
129 | $result = db_query($link, "SELECT ttrss_entries.title, | |
130 | ttrss_feeds.title AS feed_title, | |
131 | COALESCE(ttrss_feed_categories.title, '".__('Uncategorized')."') AS cat_title, | |
132 | date_updated, | |
133 | ttrss_user_entries.ref_id, | |
134 | link, | |
135 | score, | |
136 | content, | |
137 | ".SUBSTRING_FOR_DATE."(last_updated,1,19) AS last_updated | |
138 | FROM | |
139 | ttrss_user_entries,ttrss_entries,ttrss_feeds | |
140 | LEFT JOIN | |
141 | ttrss_feed_categories ON (cat_id = ttrss_feed_categories.id) | |
142 | WHERE | |
143 | ref_id = ttrss_entries.id AND feed_id = ttrss_feeds.id | |
144 | AND include_in_digest = true | |
145 | AND $interval_query | |
146 | AND ttrss_user_entries.owner_uid = $user_id | |
147 | AND unread = true | |
148 | AND score >= 0 | |
149 | ORDER BY ttrss_feed_categories.title, ttrss_feeds.title, score DESC, date_updated DESC | |
150 | LIMIT $limit"); | |
151 | ||
152 | $cur_feed_title = ""; | |
153 | ||
154 | $headlines_count = db_num_rows($result); | |
155 | ||
156 | $headlines = array(); | |
157 | ||
158 | while ($line = db_fetch_assoc($result)) { | |
159 | array_push($headlines, $line); | |
160 | } | |
161 | ||
162 | for ($i = 0; $i < sizeof($headlines); $i++) { | |
163 | ||
164 | $line = $headlines[$i]; | |
165 | ||
166 | array_push($affected_ids, $line["ref_id"]); | |
167 | ||
168 | $updated = make_local_datetime($link, $line['last_updated'], false, | |
169 | $user_id); | |
170 | ||
171 | /* if ($line["score"] != 0) { | |
172 | if ($line["score"] > 0) $line["score"] = '+' . $line["score"]; | |
173 | ||
174 | $line["title"] .= " (".$line['score'].")"; | |
175 | } */ | |
176 | ||
177 | if (get_pref($link, 'ENABLE_FEED_CATS', $user_id)) { | |
178 | $line['feed_title'] = $line['cat_title'] . " / " . $line['feed_title']; | |
179 | } | |
180 | ||
181 | $tpl->setVariable('FEED_TITLE', $line["feed_title"]); | |
182 | $tpl->setVariable('ARTICLE_TITLE', $line["title"]); | |
183 | $tpl->setVariable('ARTICLE_LINK', $line["link"]); | |
184 | $tpl->setVariable('ARTICLE_UPDATED', $updated); | |
185 | $tpl->setVariable('ARTICLE_EXCERPT', | |
186 | truncate_string(strip_tags($line["content"]), 300)); | |
187 | // $tpl->setVariable('ARTICLE_CONTENT', | |
188 | // strip_tags($article_content)); | |
189 | ||
190 | $tpl->addBlock('article'); | |
191 | ||
192 | $tpl_t->setVariable('FEED_TITLE', $line["feed_title"]); | |
193 | $tpl_t->setVariable('ARTICLE_TITLE', $line["title"]); | |
194 | $tpl_t->setVariable('ARTICLE_LINK', $line["link"]); | |
195 | $tpl_t->setVariable('ARTICLE_UPDATED', $updated); | |
196 | // $tpl_t->setVariable('ARTICLE_EXCERPT', | |
197 | // truncate_string(strip_tags($line["excerpt"]), 100)); | |
198 | ||
199 | $tpl_t->addBlock('article'); | |
200 | ||
201 | if ($headlines[$i]['feed_title'] != $headlines[$i+1]['feed_title']) { | |
202 | $tpl->addBlock('feed'); | |
203 | $tpl_t->addBlock('feed'); | |
204 | } | |
205 | ||
206 | } | |
207 | ||
208 | $tpl->addBlock('digest'); | |
209 | $tpl->generateOutputToString($tmp); | |
210 | ||
211 | $tpl_t->addBlock('digest'); | |
212 | $tpl_t->generateOutputToString($tmp_t); | |
213 | ||
214 | return array($tmp, $headlines_count, $affected_ids, $tmp_t); | |
215 | } | |
216 | ?> |