src/Controller/OperationDashboardAction.php line 100

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use Symfony\Component\HttpFoundation\JsonResponse;
  6. use Symfony\Component\HttpFoundation\Request;
  7. use Symfony\Component\Security\Core\Security;
  8. use Doctrine\Persistence\ManagerRegistry;
  9. use App\Entity\Contract;
  11. class OperationDashboardAction
  12. {
  13.     private Security $security;
  14.     private ManagerRegistry $doctrine;
  16.     public function __construct(Security $security, ManagerRegistry $doctrine)
  17.     {
  18.         $this->security = $security;
  19.         $this->doctrine = $doctrine;
  20.     }
  22.     public function __invoke(Request $request): JsonResponse
  23.     {
  24.         $user = $this->security->getUser();
  25.         $repository = $this->doctrine->getRepository(Contract::class);
  27.         $filters = [
  28.             'broker' => $request->query->get('broker') 
  29.                 ? str_replace('/api/users/', '', $request->query->get('broker')) 
  30.                 : null,
  31.             'operator' => $request->query->get('operator') 
  32.                 ? str_replace('/api/users/', '', $request->query->get('operator')) 
  33.                 : null,
  34.             'contractType' => $request->query->get('contractType'),
  35.             'status' => $request->query->get('status'),
  36.         ];
  38.         $query = $repository->createQueryBuilder("c")
  39.             ->select('c')
  40.         ;
  42.         $query
  43.             // ->andWhere("(c.status <> 'UNASSIGNED' OR c.contractType = 'COA')")
  44.             ->andWhere("c.status <> 'COMPLETED'")
  45.             ->andWhere("c.liftings IS EMPTY")
  46.         ;
  48.         foreach ($filters as $field => $value) {
  49.             if ($value !== null) {
  50.                 if ($field === 'broker') {
  51.                     $query
  52.                         ->addSelect('b')
  53.                         ->innerJoin('c.broker', 'b')
  54.                         ->andWhere('b.id = :broker')
  55.                         ->setParameter('broker', $value);
  56.                 } else if ($field === 'broker') {
  57.                     $query
  58.                         ->addSelect('o')
  59.                         ->innerJoin('c.operator', 'o')
  60.                         ->andWhere('o.id = :operator')
  61.                         ->setParameter('operator', $value);
  62.                 } else {
  63.                     $query
  64.                         ->andWhere("c.$field = :$field")
  65.                         ->setParameter($field, $value);
  66.                 }
  67.             }
  68.         }
  70.         $contracts = $query
  71.             ->getQuery()
  72.             ->getResult()
  73.         ;
  75.         return new JsonResponse([
  76.             "operations" => array_map(function($contract) {
  78.                 $loadPorts = $contract->getPortCalls()->filter(function($portCall) {
  79.                     return $portCall->getPortCallType() === "Load";
  80.                 })->getValues();
  82.                 usort($loadPorts, function($a, $b) {
  83.                     return $a->getArrival() <=> $b->getArrival();
  84.                 });
  86.                 $load = $loadPorts[0] ?? null;
  87.                 $load2 = $loadPorts[1] ?? null;
  89.                 $dischargePorts = $contract->getPortCalls()->filter(function($portCall) {
  90.                     return $portCall->getPortCallType() === "Discharge";
  91.                 })->getValues();
  93.                 usort($dischargePorts, function($a, $b) {
  94.                     return $b->getArrival() <=> $a->getArrival();
  95.                 });
  97.                 $discharge = $dischargePorts[0] ?? null;
  98.                 $discharge2 = $dischargePorts[1] ?? null;
  100.                 $laycanStart = strtoupper($contract->getLaycanStart()?->format('dMY')) ?: "N/A"; 
  101.                 $laycanEnd = strtoupper($contract->getLaycanEnd()?->format('dMY')) ?: "N/A";
  103.                 return [
  104.                     "id" => $contract->getId(),
  105.                     "type" => $contract->getContractType() ?: "N/A",
  106.                     "vessel" => $contract->getVessel()?->getVesselName() ?: "N/A",
  107.                     "status" => $contract->getStatus() ?: "N/A",
  108.                     "charterer" => $contract->getCharterer()?->getCompanyName() ?: "N/A",
  109.                     "owner" => $contract->getOwner()?->getCompanyName() ?: "N/A",
  110.                     "broker" => $contract->getBroker()?->getName() ?: "N/A",
  111.                     "brokerAvatar" => $contract->getBroker()?->getAvatar()?->getContentUrl(),
  112.                     "operator" => $contract->getOperator()?->getName() ?: "N/A",
  113.                     "operatorAvatar" => $contract->getOperator()?->getAvatar()?->getContentUrl(),
  114.                     "date" => strtoupper((new \DateTime($contract->getContractDate()))?->format('dMY')) ?: "N/A",
  115.                     "contractNumber" => $contract->getContractNumber() ?: "N/A",
  116.                     "laycan" => $laycanStart . ' ' . $laycanEnd,
  117.                     "loadPort" => $load ? $load->getPort()?->getPortName() : "N/A",
  118.                     "loadArrival" => $load && $load->getArrival() ? strtoupper($load->getArrival()?->format('dMY')) : "N/A",
  119.                     "loadBerthing" => $load && $load->getBerthing() ? strtoupper($load->getBerthing()?->format('dMY')) : "N/A",
  120.                     "loadDeparture" => $load && $load->getDeparture() ? strtoupper($load->getDeparture()?->format('dMY')) : "N/A",
  121.                     "loadPort2" => $load2 ? $load2->getPort()?->getPortName() : "N/A",
  122.                     "loadArrival2" => $load2 && $load2->getArrival() ? strtoupper($load2->getArrival()?->format('dMY')) : "N/A",
  123.                     "loadBerthing2" => $load2 && $load2->getBerthing() ? strtoupper($load2->getBerthing()?->format('dMY')) : "N/A",
  124.                     "loadDeparture2" => $load2 && $load2->getDeparture() ? strtoupper($load2->getDeparture()?->format('dMY')) : "N/A",
  125.                     "dischargePort" => $discharge ? $discharge->getPort()?->getPortName() : "N/A",
  126.                     "dischargeArrival" => $discharge && $discharge->getArrival() ? strtoupper($discharge->getArrival()?->format('dMY')) : "N/A",
  127.                     "dischargeBerthing" => $discharge && $discharge->getBerthing() ? strtoupper($discharge->getBerthing()?->format('dMY')) : "N/A",
  128.                     "dischargeDeparture" => $discharge && $discharge->getDeparture() ? strtoupper($discharge->getDeparture()?->format('dMY')) : "N/A",
  129.                     "dischargePort2" => $discharge2 ? $discharge2->getPort()?->getPortName() : "N/A",
  130.                     "dischargeArrival2" => $discharge2 && $discharge2->getArrival() ? strtoupper($discharge2->getArrival()?->format('dMY')) : "N/A",
  131.                     "dischargeBerthing2" => $discharge2 && $discharge2->getBerthing() ? strtoupper($discharge2->getBerthing()?->format('dMY')) : "N/A",
  132.                     "dischargeDeparture2" => $discharge2 && $discharge2->getDeparture() ? strtoupper($discharge2->getDeparture()?->format('dMY')) : "N/A",
  133.                     "isLifting" => $contract->getContractCoa() ? true : false,
  134.                     "liftings" => $contract->getLiftings()->count() ?: 0,
  135.                 ];
  136.             }, $contracts),
  137.             "filters" => $filters
  138.         ]);
  139.     }
  140. }