ttrss/classes/digest.php

209 lines
6.4 KiB
PHP
Raw Normal View History

2012-12-24 11:52:59 +00:00
<?php
2017-05-04 12:41:38 +00:00
class Digest
{
static function send_headlines_digests(): void {
2012-12-24 11:52:59 +00:00
$user_limit = 15; // amount of users to process (e.g. emails to send out)
$limit = 1000; // maximum amount of headlines to include
Debug::log("Sending digests, batch of max $user_limit users, headline limit = $limit");
2012-12-24 11:52:59 +00:00
2021-02-22 18:47:48 +00:00
if (Config::get(Config::DB_TYPE) == "pgsql") {
2017-12-01 15:31:23 +00:00
$interval_qpart = "last_digest_sent < NOW() - INTERVAL '1 days'";
2021-02-22 18:47:48 +00:00
} else /* if (Config::get(Config::DB_TYPE) == "mysql") */ {
2017-12-01 15:31:23 +00:00
$interval_qpart = "last_digest_sent < DATE_SUB(NOW(), INTERVAL 1 DAY)";
2012-12-24 11:52:59 +00:00
}
2017-12-01 15:31:23 +00:00
$pdo = Db::pdo();
2012-12-24 11:52:59 +00:00
2017-12-01 15:31:23 +00:00
$res = $pdo->query("SELECT id,email FROM ttrss_users
WHERE email != '' AND (last_digest_sent IS NULL OR $interval_qpart)");
while ($line = $res->fetch()) {
2012-12-24 11:52:59 +00:00
2021-02-25 11:49:58 +00:00
if (get_pref(Prefs::DIGEST_ENABLE, $line['id'])) {
$preferred_ts = strtotime(get_pref(Prefs::DIGEST_PREFERRED_TIME, $line['id']));
2012-12-24 11:52:59 +00:00
// try to send digests within 2 hours of preferred time
if ($preferred_ts && time() >= $preferred_ts &&
2017-05-04 12:41:38 +00:00
time() - $preferred_ts <= 7200
) {
2012-12-24 11:52:59 +00:00
Debug::log("Sending digest for UID:" . $line['id'] . " - " . $line["email"]);
2012-12-24 11:52:59 +00:00
2021-02-25 11:49:58 +00:00
$do_catchup = get_pref(Prefs::DIGEST_CATCHUP, $line['id']);
2012-12-24 11:52:59 +00:00
global $tz_offset;
// reset tz_offset global to prevent tz cache clash between users
$tz_offset = -1;
2017-05-04 12:41:38 +00:00
$tuple = Digest::prepare_headlines_digest($line["id"], 1, $limit);
2012-12-24 11:52:59 +00:00
$digest = $tuple[0];
$headlines_count = $tuple[1];
$affected_ids = $tuple[2];
$digest_text = $tuple[3];
if ($headlines_count > 0) {
$mailer = new Mailer();
2021-02-22 19:35:27 +00:00
//$rc = $mail->quickMail($line["email"], $line["login"], Config::get(Config::DIGEST_SUBJECT), $digest, $digest_text);
2012-12-24 11:52:59 +00:00
2018-11-22 13:36:10 +00:00
$rc = $mailer->mail(["to_name" => $line["login"],
"to_address" => $line["email"],
2021-02-22 19:35:27 +00:00
"subject" => Config::get(Config::DIGEST_SUBJECT),
"message" => $digest_text,
"message_html" => $digest]);
2012-12-24 11:52:59 +00:00
//if (!$rc && $debug) Debug::log("ERROR: " . $mailer->lastError());
2012-12-24 11:52:59 +00:00
Debug::log("RC=$rc");
2012-12-24 11:52:59 +00:00
if ($rc && $do_catchup) {
Debug::log("Marking affected articles as read...");
2021-02-15 12:52:28 +00:00
Article::_catchup_by_id($affected_ids, 0, $line["id"]);
2012-12-24 11:52:59 +00:00
}
} else {
Debug::log("No headlines");
2012-12-24 11:52:59 +00:00
}
2017-12-01 15:31:23 +00:00
$sth = $pdo->prepare("UPDATE ttrss_users SET last_digest_sent = NOW()
WHERE id = ?");
$sth->execute([$line["id"]]);
2012-12-24 11:52:59 +00:00
}
}
}
Debug::log("All done.");
2012-12-24 11:52:59 +00:00
}
/**
* @return array{0: string, 1: int, 2: array<int>, 3: string}
*/
static function prepare_headlines_digest(int $user_id, int $days = 1, int $limit = 1000) {
2012-12-24 11:52:59 +00:00
$tpl = new Templator();
$tpl_t = new Templator();
2012-12-24 11:52:59 +00:00
$tpl->readTemplateFromFile("digest_template_html.txt");
$tpl_t->readTemplateFromFile("digest_template.txt");
2012-12-24 11:52:59 +00:00
2021-02-25 11:49:58 +00:00
$user_tz_string = get_pref(Prefs::USER_TIMEZONE, $user_id);
if ($user_tz_string == 'Automatic')
$user_tz_string = 'GMT';
$local_ts = TimeHelper::convert_timestamp(time(), 'UTC', $user_tz_string);
2012-12-24 11:52:59 +00:00
$tpl->setVariable('CUR_DATE', date('Y/m/d', $local_ts));
$tpl->setVariable('CUR_TIME', date('G:i', $local_ts));
$tpl->setVariable('TTRSS_HOST', Config::get(Config::SELF_URL_PATH));
2012-12-24 11:52:59 +00:00
$tpl_t->setVariable('CUR_DATE', date('Y/m/d', $local_ts));
$tpl_t->setVariable('CUR_TIME', date('G:i', $local_ts));
$tpl_t->setVariable('TTRSS_HOST', Config::get(Config::SELF_URL_PATH));
2012-12-24 11:52:59 +00:00
$affected_ids = array();
2021-02-22 18:47:48 +00:00
if (Config::get(Config::DB_TYPE) == "pgsql") {
2017-12-01 15:31:23 +00:00
$interval_qpart = "ttrss_entries.date_updated > NOW() - INTERVAL '$days days'";
2021-02-22 18:47:48 +00:00
} else /* if (Config::get(Config::DB_TYPE) == "mysql") */ {
2017-12-01 15:31:23 +00:00
$interval_qpart = "ttrss_entries.date_updated > DATE_SUB(NOW(), INTERVAL $days DAY)";
2012-12-24 11:52:59 +00:00
}
2017-12-01 15:31:23 +00:00
$pdo = Db::pdo();
$sth = $pdo->prepare("SELECT ttrss_entries.title,
2012-12-24 11:52:59 +00:00
ttrss_feeds.title AS feed_title,
2017-05-04 12:41:38 +00:00
COALESCE(ttrss_feed_categories.title, '" . __('Uncategorized') . "') AS cat_title,
2012-12-24 11:52:59 +00:00
date_updated,
ttrss_user_entries.ref_id,
link,
score,
content,
".SUBSTRING_FOR_DATE."(last_updated,1,19) AS last_updated
2012-12-24 11:52:59 +00:00
FROM
ttrss_user_entries,ttrss_entries,ttrss_feeds
LEFT JOIN
ttrss_feed_categories ON (cat_id = ttrss_feed_categories.id)
WHERE
ref_id = ttrss_entries.id AND feed_id = ttrss_feeds.id
AND include_in_digest = true
2017-12-01 15:31:23 +00:00
AND $interval_qpart
AND ttrss_user_entries.owner_uid = :user_id
2012-12-24 11:52:59 +00:00
AND unread = true
AND score >= 0
ORDER BY ttrss_feed_categories.title, ttrss_feeds.title, score DESC, date_updated DESC
LIMIT " . (int)$limit);
$sth->execute([':user_id' => $user_id]);
2012-12-24 11:52:59 +00:00
2017-12-01 15:31:23 +00:00
$headlines_count = 0;
2012-12-24 11:52:59 +00:00
$headlines = array();
2017-12-01 15:31:23 +00:00
while ($line = $sth->fetch()) {
2012-12-24 11:52:59 +00:00
array_push($headlines, $line);
2017-12-01 15:31:23 +00:00
$headlines_count++;
2012-12-24 11:52:59 +00:00
}
for ($i = 0; $i < sizeof($headlines); $i++) {
$line = $headlines[$i];
array_push($affected_ids, $line["ref_id"]);
$updated = TimeHelper::make_local_datetime($line['last_updated'], false,
2012-12-24 11:52:59 +00:00
$user_id);
2021-02-25 11:49:58 +00:00
if (get_pref(Prefs::ENABLE_FEED_CATS, $user_id)) {
2012-12-24 11:52:59 +00:00
$line['feed_title'] = $line['cat_title'] . " / " . $line['feed_title'];
}
2021-02-15 12:52:28 +00:00
$article_labels = Article::_get_labels($line["ref_id"], $user_id);
2019-03-02 14:57:25 +00:00
$article_labels_formatted = "";
if (is_array($article_labels) && count($article_labels) > 0) {
$article_labels_formatted = implode(", ", array_map(function($a) {
return $a[1];
}, $article_labels));
}
2012-12-24 11:52:59 +00:00
$tpl->setVariable('FEED_TITLE', $line["feed_title"]);
$tpl->setVariable('ARTICLE_TITLE', $line["title"]);
$tpl->setVariable('ARTICLE_LINK', $line["link"]);
$tpl->setVariable('ARTICLE_UPDATED', $updated);
$tpl->setVariable('ARTICLE_EXCERPT',
truncate_string(strip_tags($line["content"]), 300));
// $tpl->setVariable('ARTICLE_CONTENT',
// strip_tags($article_content));
2019-03-02 14:57:25 +00:00
$tpl->setVariable('ARTICLE_LABELS', $article_labels_formatted, true);
2012-12-24 11:52:59 +00:00
$tpl->addBlock('article');
$tpl_t->setVariable('FEED_TITLE', $line["feed_title"]);
$tpl_t->setVariable('ARTICLE_TITLE', $line["title"]);
$tpl_t->setVariable('ARTICLE_LINK', $line["link"]);
$tpl_t->setVariable('ARTICLE_UPDATED', $updated);
2019-03-02 14:57:25 +00:00
$tpl_t->setVariable('ARTICLE_LABELS', $article_labels_formatted, true);
2019-03-16 12:35:11 +00:00
$tpl_t->setVariable('ARTICLE_EXCERPT',
truncate_string(strip_tags($line["content"]), 300, "..."), true);
2012-12-24 11:52:59 +00:00
$tpl_t->addBlock('article');
2017-05-04 12:41:38 +00:00
if ($headlines[$i]['feed_title'] != $headlines[$i + 1]['feed_title']) {
2012-12-24 11:52:59 +00:00
$tpl->addBlock('feed');
$tpl_t->addBlock('feed');
}
}
$tpl->addBlock('digest');
$tpl->generateOutputToString($tmp);
$tpl_t->addBlock('digest');
$tpl_t->generateOutputToString($tmp_t);
return array($tmp, $headlines_count, $affected_ids, $tmp_t);
}
}