src/Worker/TagUpdate.php

   1 <?php
   2
   3 namespace Friendica\Worker;
   4
   5 use Friendica\Core\Logger;
   6 use Friendica\Database\DBA;
   7
   8 class TagUpdate
   9 {
  10         public static function execute()
  11         {
  12                 $messages = DBA::p("SELECT `oid`,`item`.`guid`, `item`.`created`, `item`.`received` FROM `term` INNER JOIN `item` ON `item`.`id`=`term`.`oid` WHERE `term`.`otype` = 1 AND `term`.`guid` = ''");
  13
  14                 Logger::log('fetched messages: ' . DBA::numRows($messages));
  15                 while ($message = DBA::fetch($messages)) {
  16                         if ($message['uid'] == 0) {
  17                                 $global = true;
  18
  19                                 DBA::update('term', ['global' => true], ['otype' => TERM_OBJ_POST, 'guid' => $message['guid']]);
  20                         } else {
  21                                 $global = (DBA::count('term', ['uid' => 0, 'otype' => TERM_OBJ_POST, 'guid' => $message['guid']]) > 0);
  22                         }
  23
  24                         $fields = ['guid' => $message['guid'], 'created' => $message['created'],
  25                                 'received' => $message['received'], 'global' => $global];
  26                         DBA::update('term', $fields, ['otype' => TERM_OBJ_POST, 'oid' => $message['oid']]);
  27                 }
  28
  29                 DBA::close($messages);
  30
  31                 $messages = DBA::select('item', ['guid'], ['uid' => 0]);
  32
  33                 Logger::log('fetched messages: ' . DBA::numRows($messages));
  34                 while ($message = DBA::fetch($messages)) {
  35                         DBA::update('item', ['global' => true], ['guid' => $message['guid']]);
  36                 }
  37
  38                 DBA::close($messages);
  39         }
  40 }