PingQueue::updateQueue

private function updateQueue(DateTime $deadLine, array $existedIds, array $offsets): void
{
	foreach ($existedIds as $index => $existedId)
	{
		$deadlineClone = clone $deadLine; // to avoid influence of ->add(...) to original $deadLine
		$pingDateTime = $offsets[$index] <= 0 ? $deadlineClone : $deadlineClone->add('-' . $offsets[$index] . ' minutes');
		if ($pingDateTime->getTimestamp() > (new DateTime())->getTimestamp())
		{
			ActivityPingQueueTable::update($existedId, ['PING_DATETIME' => $pingDateTime]);
		}
		else
		{
			ActivityPingQueueTable::delete($existedId);
		}
	}
}