X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=include%2Fpost_update.php;h=8dcf070526e4eaf3d042bc18e834911324f0715c;hb=0cd9db9cb7f4c96f597e37590a536eaae123238d;hp=6918bf0fa433d64fac2c719b0a74758bd4511f31;hpb=2e9d233367068fceac8005126d14a2002539c772;p=friendica.git diff --git a/include/post_update.php b/include/post_update.php index 6918bf0fa4..8dcf070526 100644 --- a/include/post_update.php +++ b/include/post_update.php @@ -8,14 +8,18 @@ */ function post_update() { - if (!post_update_1192()) + if (!post_update_1192()) { return; - - if (!post_update_1194()) + } + if (!post_update_1194()) { return; - - if (!post_update_1198()) + } + if (!post_update_1198()) { return; + } + if (!post_update_1206()) { + return; + } } /** @@ -41,7 +45,7 @@ function post_update_1192() { WHERE `thread`.`gcontact-id` = 0 AND (`thread`.`uid` IN (SELECT `uid` from `user`) OR `thread`.`uid` = 0)"); - if ($r AND ($r[0]["total"] == 0)) { + if ($r && ($r[0]["total"] == 0)) { set_config("system", "post_update_version", 1192); return true; } @@ -64,7 +68,7 @@ function post_update_1192() { } // Set the "gcontact-id" in the item table and add a new gcontact entry if needed - foreach($item_arr AS $item) { + foreach ($item_arr AS $item) { $gcontact_id = get_gcontact_id(array("url" => $item['author-link'], "network" => $item['network'], "photo" => $item['author-avatar'], "name" => $item['author-name'])); q("UPDATE `item` SET `gcontact-id` = %d WHERE `uid` = %d AND `author-link` = '%s' AND `gcontact-id` = 0", @@ -159,7 +163,7 @@ function post_update_1198() { logger("Start", LOGGER_DEBUG); // Check if the first step is done (Setting "author-id" and "owner-id" in the item table) - $r = q("SELECT `author-link`, `owner-link`, `uid` FROM `item` WHERE `author-id` = 0 AND `owner-id` = 0 LIMIT 1000"); + $r = q("SELECT `author-link`, `owner-link`, `uid` FROM `item` WHERE `author-id` = 0 AND `owner-id` = 0 LIMIT 100"); if (!$r) { // Are there unfinished entries in the thread table? $r = q("SELECT COUNT(*) AS `total` FROM `thread` @@ -167,20 +171,25 @@ function post_update_1198() { WHERE `thread`.`author-id` = 0 AND `thread`.`owner-id` = 0 AND (`thread`.`uid` IN (SELECT `uid` from `user`) OR `thread`.`uid` = 0)"); - if ($r AND ($r[0]["total"] == 0)) { + if ($r && ($r[0]["total"] == 0)) { set_config("system", "post_update_version", 1198); logger("Done", LOGGER_DEBUG); return true; } // Update the thread table from the item table - q("UPDATE `thread` INNER JOIN `item` ON `item`.`id`=`thread`.`iid` + $r = q("UPDATE `thread` INNER JOIN `item` ON `item`.`id`=`thread`.`iid` SET `thread`.`author-id` = `item`.`author-id`, `thread`.`owner-id` = `item`.`owner-id` WHERE `thread`.`author-id` = 0 AND `thread`.`owner-id` = 0 AND (`thread`.`uid` IN (SELECT `uid` from `user`) OR `thread`.`uid` = 0)"); logger("Updated threads", LOGGER_DEBUG); + if (dbm::is_result($r)) { + set_config("system", "post_update_version", 1198); + logger("Done", LOGGER_DEBUG); + return true; + } return false; } @@ -195,7 +204,7 @@ function post_update_1198() { } // Set the "gcontact-id" in the item table and add a new gcontact entry if needed - foreach($item_arr AS $item) { + foreach ($item_arr AS $item) { $author_id = get_contact($item["author-link"], 0); $owner_id = get_contact($item["owner-link"], 0); @@ -215,4 +224,37 @@ function post_update_1198() { logger("Updated items", LOGGER_DEBUG); return false; } -?> + +/** + * @brief update the "last-item" field in the "self" contact + * + * This field avoids cost intensive calls in the admin panel and in "nodeinfo" + * + * @return bool "true" when the job is done + */ +function post_update_1206() { + // Was the script completed? + if (get_config("system", "post_update_version") >= 1206) + return true; + + logger("Start", LOGGER_DEBUG); + $r = q("SELECT `contact`.`id`, `contact`.`last-item`, + (SELECT MAX(`changed`) FROM `item` USE INDEX (`uid_wall_changed`) WHERE `wall` AND `uid` = `user`.`uid`) AS `lastitem_date` + FROM `user` + INNER JOIN `contact` ON `contact`.`uid` = `user`.`uid` AND `contact`.`self`"); + + if (!dbm::is_result($r)) { + return false; + } + foreach ($r AS $user) { + if (!empty($user["lastitem_date"]) && ($user["lastitem_date"] > $user["last-item"])) { + q("UPDATE `contact` SET `last-item` = '%s' WHERE `id` = %d", + dbesc($user["lastitem_date"]), + intval($user["id"])); + } + } + + set_config("system", "post_update_version", 1206); + logger("Done", LOGGER_DEBUG); + return true; +}