getFragmentNext() ?? 0; $end = $start + 50; $nextStatus = Task::STATUS_READY; if ($end > $this->getFragmentTotal()) { $end = $this->getFragmentTotal(); $nextStatus = Task::STATUS_COMPLETED; } $posts = DB::getInstance()->query( <<count()) { $posts = $posts->results(); foreach ($posts as $post) { DB::getInstance()->update('posts', $post->id, [ 'post_content' => Output::getDecoded($post->post_content), ]); } } $this->setOutput(['start' => $start, 'end' => $end, 'next_status' => $nextStatus]); $this->setFragmentNext($end); return $nextStatus; } /** * Schedule this task * * @return void */ public static function schedule() { $hasBeenScheduled = DB::getInstance()->query('SELECT COUNT(*) c FROM nl2_queue WHERE `task` = \'ConvertForumPostTask\'')->first()->c; if (!$hasBeenScheduled) { $totalForumPosts = DB::getInstance()->query('SELECT COUNT(*) c FROM nl2_posts')->first()->c; Queue::schedule((new ConvertForumPostTask())->fromNew( Module::getIdFromName('Forum'), 'Convert forum posts', [], date('U'), null, null, true, $totalForumPosts )); } } }