2015-03-07 21:24:39 +01:00
< ? php
2018-02-04 05:49:48 +01:00
2017-11-15 22:12:33 +01:00
namespace Friendica\Worker ;
2018-04-09 23:34:23 +02:00
use dba ;
2018-02-04 05:49:48 +01:00
class TagUpdate
{
public static function execute ()
{
$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` = '' " );
logger ( 'fetched messages: ' . dba :: num_rows ( $messages ));
while ( $message = dba :: fetch ( $messages )) {
if ( $message [ 'uid' ] == 0 ) {
$global = true ;
2018-04-09 23:34:23 +02:00
dba :: update ( 'term' , [ 'global' => true ], [ 'otype' => TERM_OBJ_POST , 'guid' => $message [ 'guid' ]]);
2018-02-04 05:49:48 +01:00
} else {
2018-04-09 23:34:23 +02:00
$global = ( dba :: count ( 'term' , [ 'uid' => 0 , 'otype' => TERM_OBJ_POST , 'guid' => $message [ 'guid' ]]) > 0 );
2018-02-04 05:49:48 +01:00
}
2018-04-09 23:34:23 +02:00
$fields = [ 'guid' => $message [ 'guid' ], 'created' => $message [ 'created' ],
'received' => $message [ 'received' ], 'global' => $global ];
dba :: update ( 'term' , $fields , [ 'otype' => TERM_OBJ_POST , 'oid' => $message [ 'oid' ]]);
2018-02-04 05:49:48 +01:00
}
dba :: close ( $messages );
$messages = dba :: p ( " SELECT `guid` FROM `item` WHERE `uid` = 0 " );
logger ( 'fetched messages: ' . dba :: num_rows ( $messages ));
while ( $message = dba :: fetch ( messages )) {
2018-04-09 23:34:23 +02:00
dba :: update ( 'item' , [ 'global' => true ], [ 'guid' => $message [ 'guid' ]]);
2018-02-04 05:49:48 +01:00
}
dba :: close ( $messages );
2017-11-15 22:12:33 +01:00
}
2015-03-07 21:24:39 +01:00
}