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('user_profile_wall_posts', $post->id, [ 'content' => Output::getDecoded($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` = \'ConvertProfilePosts\'')->first()->c; if (!$hasBeenScheduled) { $totalProfilePosts = DB::getInstance()->query('SELECT COUNT(*) c FROM nl2_user_profile_wall_posts')->first()->c; Queue::schedule((new ConvertProfilePosts())->fromNew( Module::getIdFromName('Core'), 'Convert profile posts', [], date('U'), null, null, true, $totalProfilePosts )); } } }