123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211 |
- <?php
- class CCache {
- static function zero_all($owner_uid) {
- $pdo = Db::pdo();
- $sth = $pdo->prepare("UPDATE ttrss_counters_cache SET
- value = 0 WHERE owner_uid = ?");
- $sth->execute([$owner_uid]);
- $sth = $pdo->prepare("UPDATE ttrss_cat_counters_cache SET
- value = 0 WHERE owner_uid = ?");
- $sth->execute([$owner_uid]);
- }
- static function remove($feed_id, $owner_uid, $is_cat = false) {
- $feed_id = (int) $feed_id;
- if (!$is_cat) {
- $table = "ttrss_counters_cache";
- } else {
- $table = "ttrss_cat_counters_cache";
- }
- $pdo = Db::pdo();
- $sth = $pdo->prepare("DELETE FROM $table WHERE
- feed_id = ? AND owner_uid = ?");
- $sth->execute([$feed_id, $owner_uid]);
- }
- static function update_all($owner_uid) {
- $pdo = Db::pdo();
- if (get_pref('ENABLE_FEED_CATS', $owner_uid)) {
- $sth = $pdo->prepare("SELECT feed_id FROM ttrss_cat_counters_cache
- WHERE feed_id > 0 AND owner_uid = ?");
- $sth->execute([$owner_uid]);
- while ($line = $sth->fetch()) {
- CCache::update($line["feed_id"], $owner_uid, true);
- }
- /* We have to manually include category 0 */
- CCache::update(0, $owner_uid, true);
- } else {
- $sth = $pdo->prepare("SELECT feed_id FROM ttrss_counters_cache
- WHERE feed_id > 0 AND owner_uid = ?");
- $sth->execute([$owner_uid]);
- while ($line = $sth->fetch()) {
- print CCache::update($line["feed_id"], $owner_uid);
- }
- }
- }
- static function find($feed_id, $owner_uid, $is_cat = false,
- $no_update = false) {
- // "" (null) is valid and should be cast to 0 (uncategorized)
- // everything else i.e. tags are not
- if (!is_numeric($feed_id) && $feed_id)
- return;
- $feed_id = (int) $feed_id;
- if (!$is_cat) {
- $table = "ttrss_counters_cache";
- } else {
- $table = "ttrss_cat_counters_cache";
- }
- $pdo = Db::pdo();
- $sth = $pdo->prepare("SELECT value FROM $table
- WHERE owner_uid = ? AND feed_id = ?
- LIMIT 1");
- $sth->execute([$owner_uid, $feed_id]);
- if ($row = $sth->fetch()) {
- return $row["value"];
- } else {
- if ($no_update) {
- return -1;
- } else {
- return CCache::update($feed_id, $owner_uid, $is_cat);
- }
- }
- }
- static function update($feed_id, $owner_uid, $is_cat = false,
- $update_pcat = true, $pcat_fast = false) {
- // "" (null) is valid and should be cast to 0 (uncategorized)
- // everything else i.e. tags are not
- if (!is_numeric($feed_id) && $feed_id)
- return;
- $feed_id = (int) $feed_id;
- $prev_unread = CCache::find($feed_id, $owner_uid, $is_cat, true);
- /* When updating a label, all we need to do is recalculate feed counters
- * because labels are not cached */
- if ($feed_id < 0) {
- CCache::update_all($owner_uid);
- return;
- }
- if (!$is_cat) {
- $table = "ttrss_counters_cache";
- } else {
- $table = "ttrss_cat_counters_cache";
- }
- $pdo = Db::pdo();
- if ($is_cat && $feed_id >= 0) {
- /* Recalculate counters for child feeds */
- if (!$pcat_fast) {
- $sth = $pdo->prepare("SELECT id FROM ttrss_feeds
- WHERE owner_uid = :uid AND
- (cat_id = :cat OR (:cat = 0 AND cat_id IS NULL))");
- $sth->execute([":uid" => $owner_uid, ":cat" => $feed_id]);
- while ($line = $sth->fetch()) {
- CCache::update((int)$line["id"], $owner_uid, false, false);
- }
- }
- $sth = $pdo->prepare("SELECT SUM(value) AS sv
- FROM ttrss_counters_cache, ttrss_feeds
- WHERE id = feed_id AND
- (cat_id = :cat OR (:cat = 0 AND cat_id IS NULL)) AND
- ttrss_counters_cache.owner_uid = :uid AND
- ttrss_feeds.owner_uid = :uid");
- $sth->execute([":uid" => $owner_uid, ":cat" => $feed_id]);
- $row = $sth->fetch();
- $unread = (int) $row["sv"];
- } else {
- $unread = (int) Feeds::getFeedArticles($feed_id, $is_cat, true, $owner_uid);
- }
- $tr_in_progress = false;
- try {
- $pdo->beginTransaction();
- } catch (Exception $e) {
- $tr_in_progress = true;
- }
- $sth = $pdo->prepare("SELECT feed_id FROM $table
- WHERE owner_uid = ? AND feed_id = ? LIMIT 1");
- $sth->execute([$owner_uid, $feed_id]);
- if ($sth->fetch()) {
- $sth = $pdo->prepare("UPDATE $table SET
- value = ?, updated = NOW() WHERE
- feed_id = ? AND owner_uid = ?");
- $sth->execute([$unread, $feed_id, $owner_uid]);
- } else {
- $sth = $pdo->prepare("INSERT INTO $table
- (feed_id, value, owner_uid, updated)
- VALUES
- (?, ?, ?, NOW())");
- $sth->execute([$feed_id, $unread, $owner_uid]);
- }
- if (!$tr_in_progress) $pdo->commit();
- if ($feed_id > 0 && $prev_unread != $unread) {
- if (!$is_cat) {
- /* Update parent category */
- if ($update_pcat) {
- $sth = $pdo->prepare("SELECT cat_id FROM ttrss_feeds
- WHERE owner_uid = ? AND id = ?");
- $sth->execute([$owner_uid, $feed_id]);
- if ($row = $sth->fetch()) {
- CCache::update((int)$row["cat_id"], $owner_uid, true, true, true);
- }
- }
- }
- } else if ($feed_id < 0) {
- CCache::update_all($owner_uid);
- }
- return $unread;
- }
- }
|