135 lines
4.4 KiB
PHP
135 lines
4.4 KiB
PHP
<?php
|
|
|
|
namespace App\Command;
|
|
|
|
use Symfony\Component\Console\Command\Command;
|
|
use Symfony\Component\Console\Input\InputArgument;
|
|
use Symfony\Component\Console\Input\InputInterface;
|
|
use Symfony\Component\Console\Output\OutputInterface;
|
|
|
|
use Doctrine\ORM\EntityManagerInterface;
|
|
|
|
use App\Service\MQTTClient;
|
|
|
|
use App\Entity\JobOrder;
|
|
use App\Entity\Rider;
|
|
|
|
use PDO;
|
|
|
|
class UpdateUnacceptedJobOrdersCommand extends Command
|
|
{
|
|
protected $em;
|
|
protected $mclient;
|
|
|
|
public function __construct(EntityManagerInterface $em, MQTTClient $mclient)
|
|
{
|
|
$this->em = $em;
|
|
$this->mclient = $mclient;
|
|
|
|
parent::__construct();
|
|
}
|
|
|
|
protected function configure()
|
|
{
|
|
$this->setName('joborder:reassignunaccepted')
|
|
->setDescription('Requeue for rider assignment assigned but unaccepted job orders that have been assigned for more than 3 mins.')
|
|
->setHelp('Requeue for rider assignment assigned but unaccepted job orders that have been assigned for more than 3 mins.');
|
|
}
|
|
|
|
protected function execute(InputInterface $input, OutputInterface $output)
|
|
{
|
|
$em = $this->em;
|
|
$mclient = $this->mclient;
|
|
|
|
// TODO: get the timeout limit from .env
|
|
$timeout = 3;
|
|
$current_status = 'assigned';
|
|
$new_status = 'rider_assign';
|
|
|
|
// pdo connection
|
|
$db = $em->getConnection();
|
|
|
|
// since we need the actual job orders for mqtt events, we need to get the ids of the job orders
|
|
// that will be updated
|
|
// need rider id to set rider to available since rider becomes unavailable
|
|
// the minute JO is assigned to rider
|
|
$query_sql = 'SELECT id FROM job_order WHERE status = :current_status and TIMESTAMPDIFF(MINUTE, date_assign, NOW()) >= :timeout';
|
|
|
|
$query_stmt = $db->prepare($query_sql);
|
|
$query_stmt->execute([
|
|
'current_status' => $current_status,
|
|
'timeout' => $timeout,
|
|
]);
|
|
|
|
// go through rows
|
|
$requeued_jos = [];
|
|
while ($row = $query_stmt->fetch(PDO::FETCH_NUM))
|
|
{
|
|
// $row[0] is the jo id
|
|
// store the jos for now for the event sending after update of JOs
|
|
// and the updating of rider's availability
|
|
$jo_id = $row[0];
|
|
|
|
$requeued_jo = $em->getRepository(JobOrder::class)->find($jo_id);
|
|
|
|
$requeued_jos[] = [
|
|
'jo' => $requeued_jo,
|
|
];
|
|
|
|
$update_sql = 'UPDATE job_order SET status = :new_status, rider_id = null WHERE id = :jo_id';
|
|
$update_stmt = $db->prepare($update_sql);
|
|
$update_stmt->execute([
|
|
'new_status' => $new_status,
|
|
'jo_id' => $jo_id,
|
|
]);
|
|
}
|
|
|
|
foreach ($requeued_jos as $jo_info)
|
|
{
|
|
$jo = $jo_info['jo'];
|
|
if ($jo != null)
|
|
{
|
|
// $output->writeln('Requeuing for rider assignment ' . $jo->getID());
|
|
$id = $jo->getID();
|
|
|
|
// send notifications to rider app, telling rider that jo has been requeued
|
|
$rider_payload = [
|
|
'event' => 'cancelled',
|
|
'reason' => 'Reassigned',
|
|
'jo_id' => $id,
|
|
];
|
|
$mclient->sendRiderEvent($jo, $rider_payload);
|
|
|
|
|
|
// send outlet assign since order should go back to hub and await reassignment to another rider
|
|
$payload = [
|
|
'event' => 'outlet_assign',
|
|
'jo_id' => $id,
|
|
];
|
|
$mclient->sendEvent($jo, $payload);
|
|
}
|
|
|
|
$rider = $jo->getRider();
|
|
if ($rider != null)
|
|
{
|
|
// check rider's current job order before changing rider's availability
|
|
// since rider's current job order is set when JO is assigned to rider
|
|
if ($rider->getCurrentJobOrder() != null)
|
|
{
|
|
if ($rider->getCurrentJobOrder()->getID() == $jo->getID())
|
|
{
|
|
// reset rider's availability to true
|
|
$rider->setAvailable(true);
|
|
|
|
// set rider's current job order to null
|
|
$rider->setCurrentJobOrder();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
$em->flush();
|
|
|
|
return 0;
|
|
}
|
|
}
|