<?php

namespace App\Controller\TAPI;

use Symfony\Bundle\FrameworkBundle\Controller\Controller;
use Symfony\Component\HttpFoundation\Request;

use Doctrine\ORM\Query;
use Doctrine\ORM\EntityManagerInterface;

use CrEOF\Spatial\PHP\Types\Geometry\Point;

use Catalyst\APIBundle\Controller\APIController;
use Catalyst\APIBundle\Response\APIResponse;

use App\Ramcar\WarrantyClass;
use App\Ramcar\JOStatus;
use App\Ramcar\AdvanceOrderSlot;
use App\Ramcar\AutoAssignStatus;
use App\Ramcar\InvoiceCriteria;
use App\Ramcar\ServiceType;
use App\Ramcar\TransactionOrigin;
use App\Ramcar\TradeInType;
use App\Ramcar\JOEventType;
use App\Ramcar\HubCriteria;
use App\Ramcar\ModeOfPayment;
use App\Ramcar\APIRiderStatus;

use App\Service\InvoiceGeneratorInterface;
use App\Service\RisingTideGateway;
use App\Service\MQTTClient;
use App\Service\GeofenceTracker;
use App\Service\InventoryManager;
use App\Service\RiderAssignmentHandlerInterface;
use App\Service\HubSelector;
use App\Service\HubDistributor;
use App\Service\HubFilterLogger;
use App\Service\HubFilteringGeoChecker;
use App\Service\RiderTracker;
use App\Service\PromoLogger;
use App\Service\MapTools;

use App\Entity\JobOrder;
use App\Entity\CustomerVehicle;
use App\Entity\Promo;
use App\Entity\Battery;
use App\Entity\JOEvent;
use App\Entity\Customer;
use App\Entity\Hub;
use App\Entity\Invoice;

use DateTime;
use DateInterval;

use Catalyst\APIBundle\Access\Generator as ACLGenerator;

class JobOrderController extends APIController
{
    protected $acl_gen;

    public function __construct(ACLGenerator $acl_gen)
    {
        $this->acl_gen = $acl_gen;
    }

    // TODO: break this monolithic method down
    public function requestJobOrder(Request $req, InvoiceGeneratorInterface $ic, GeofenceTracker $geo,
                                       InventoryManager $im, MQTTClient $mclient,
                                       RiderAssignmentHandlerInterface $rah, PromoLogger $promo_logger,
                                       HubSelector $hub_select, HubDistributor $hub_dist, HubFilterLogger $hub_filter_logger,
                                       HubFilteringGeoChecker $hub_geofence, EntityManagerInterface $em)
    {
        $this->denyAccessUnlessGranted('tapi_jo.request', null, 'No access.');

        // check required parameters and api key
        $required_params = [
            'service_type',
            'trade_in_type',
            'longitude',
            'latitude',
            'mode_of_payment',
            'first_name',
            'last_name',
            'mobile_number',
            'vehicle_manufacturer',
            'vehicle_model',
            'plate_number'
        ];

        $res = $this->checkParamsAndKey($req, $em, $required_params);
        if ($res->isError())
            return $res->getReturnResponse();

        // get data from request
        $data = [];
        $data = $this->getJobOrderRequestInfo($req, $data);

        // process customer and vehicle information
        $this->processCustomerAndVehicleInformation($data, $em);

        $is_covered = false;
        // geofence
        $is_covered = $geo->isCovered($data['long'], $data['lat']);

        if (!$is_covered)
        {
            // TODO: put geofence error message in config file somewhere
            $res->setError(true)
                ->setErrorMessage('Oops! Our service is limited to some areas in Metro Manila, Laguna, and Baguio only. We will update you as soon as we are able to cover your area');
            return $res->getReturnResponse();
        }

        $jo = new JobOrder();
        $jo->setSource(TransactionOrigin::MOBILE_APP)
            ->setStatus(JOStatus::PENDING)
            ->setDeliveryInstructions('')
            ->setTier1Notes('')
            ->setTier2Notes('')
            ->setDeliveryAddress($address)
            ->setTradeInType($trade_in)
            ->setDeliveryInstructions($instructions)
            // TODO: error check for valid mode of payment
            ->setModeOfPayment($data['payment_mode'])
            ->setAdvanceOrder($data['is_advance_order'])
            ->setStatusAutoAssign(AutoAssignStatus::NOT_ASSIGNED)
            ->setLandmark($landmark);

        $jo->setCustomer($cust);

        // set coordinates
        $point = new Point($long, $lat);
        $jo->setCoordinates($point);

        // make invoice criteria
        $icrit = new InvoiceCriteria();
        $icrit->setServiceType($stype);

        // TODO add promo to criteria if any
        // check promo
        // put in criteria
        $icrit->addPromo($promo);

        // check customer vehicle
        $cv = $em->getRepository(CustomerVehicle::class)->find($req->request->get('cv_id'));
        if ($cv == null)
        {
            $res->setError(true)
                ->setErrorMessage('Invalid customer vehicle id');
            return $res->getReturnResponse();
        }
        $icrit->setCustomerVehicle($cv);
        $jo->setCustomerVehicle($cv);

        // check if customer owns vehicle
        if ($cust->getID() != $cv->getCustomer()->getID())
        {
            $res->setError(true)
                ->setErrorMessage('Customer does not own vehicle');
            return $res->getReturnResponse();
        }

        switch ($trade_in)
        {
            case TradeInType::MOTOLITE:
            case TradeInType::OTHER:
                break;

            default:
                $trade_in = '';
                break;
        }

        $icrit->addEntry($batt, $trade_in, 1);

        // send to invoice generator
        $invoice = $ic->generateInvoice($icrit);
        $jo->setInvoice($invoice);

        // assign hub and rider
        // check if hub is null
        if ($hub == null)
        {
            // TODO: need to factor out the setting of HubCriteria fields
            $hub_criteria = new HubCriteria();
            $hub_criteria->setPoint($jo->getCoordinates());

            // get distance limit for mobile from env
            // get value of hub_filter_enable from env
            $dotenv = new Dotenv();
            $dotenv->loadEnv(__DIR__.'/../../.env');
            $limit_distance = $_ENV['CUST_DISTANCE_LIMIT'];
            $hub_filter_enabled = $_ENV['HUB_FILTER_ENABLE'];

            // set distance limit
            $hub_criteria->setLimitDistance($limit_distance);

            // check if hub filter is enabled. If not, use default values
            // for the rest of the HubCriteria fields
            if ($hub_filter_enabled == 'true')
            {
                // error_log('hub filter is enabled');
                // check if customer location is in hub filter area
                if ($hub_geofence->isCovered($long, $lat))
                {
                    // if true, set other values for HubCriteria
                    // TODO: set this properly, since the other flags
                    // are on default values
                    // error_log('Area is covered by hub filtering');
                    $hub_criteria->setJoType($jo->getServiceType())
                        ->setPaymentMethod($jo->getModeOfPayment())
                        ->setRoundRobin(true);
                }
            }

            // check if batt is null
            if ($batt != null)
            {
                // add battery to items
                $sku = $batt->getSAPCode();
                if (!empty($sku))
                    $hub_criteria->addItem($batt->getSAPCode(), 1);
            }

            // get customer id. No JO id at this point
            $customer_id = $cust->getID();

            $hub_criteria->setCustomerId($customer_id);

            // find nearest hubs
            $nearest_hubs = $hub_select->find($hub_criteria);

            if (!empty($nearest_hubs))
            {
                // go through the hub list, find the nearest hub
                // with an available rider
                // error_log('found nearest hub ' . $nearest_hub->getID());
                foreach ($nearest_hubs as $nearest_hub)
                {
                    // check if hub can be auto assigned
                    // if not, move on to the next hub in the list
                    if (($nearest_hub['hub']->isHubAutoAssign()))
                    {
                        // check if hub has riders that can be auto assigned
                        // if not, move on to the next hub
                        if (($nearest_hub['hub']->isRiderAutoAssign()))
                        {
                            $available_riders = $nearest_hub['hub']->getAvailableRiders();
                            if (count($available_riders) >= 1)
                            {
                                $assigned_rider = null;
                                if (count($available_riders) == 1)
                                {
                                    $assigned_rider = $available_riders[0];
                                }
                                else
                                {
                                    // TODO: the setting of riders into an array
                                    //  will no longer be necessary when the contents
                                    // of randomizeRider changes
                                    $riders = [];
                                    foreach ($available_riders as $rider)
                                    {
                                        $riders[] = $rider;
                                    }

                                    $assigned_rider = $this->randomizeRider($riders);
                                }

                                $jo->setHub($nearest_hub['hub']);
                                $jo->setRider($assigned_rider);
                                $jo->setStatus(JOStatus::ASSIGNED);
                                $jo->setStatusAutoAssign(AutoAssignStatus::HUB_AND_RIDER_ASSIGNED);
                                $jo->setDeliveryStatus(DeliveryStatus::RIDER_ASSIGN);

                                // set date_assigned for job order
                                $jo->setDateAssign(new DateTime());

                                $assigned_rider->setAvailable(false);

                                // set rider's current job order
                                $assigned_rider->setCurrentJobOrder($jo);

                                // update redis hub_jo_count for hub
                                $hub_dist->incrementJoCountForHub($nearest_hub['hub']);

                                // break out of loop
                                break;
                            }
                            else
                            {
                                // we just create the JO and let admin panel handle the hub assignment
                                // log hub into hub_filter_log
                                $hub_filter_logger->logFilteredHub($nearest_hub['hub'], 'no_available_rider', null, $cust->getID());
                                // continue to go through list to find hub with an available rider
                            }
                        }
                        else
                        {
                            // TODO: log hub as cannot be auto rider assigned somewhere
                            // assign hub
                            // error_log('Rider cannot be auto assigned ' . $nearest_hub['hub']->getID());
                            $jo->setHub($nearest_hub['hub']);
                            $jo->setStatus(JOStatus::RIDER_ASSIGN);
                            $jo->setStatusAutoAssign(AutoAssignStatus::HUB_ASSIGNED);

                            // update redis hub_jo_count for hub
                            $hub_dist->incrementJoCountForHub($nearest_hub['hub']);

                            break;
                        }
                    }
                    else
                    {
                        // TODO: log hub as cannot be auto assigned somewhere
                        // move to next hub
                        error_log('Hub cannot be auto-assigned ' . $nearest_hub['hub']->getID());
                        continue;
                    }
                }
            }
        }
        else
        {
            $jo->setHub($hub);
            $jo->setStatus(JOStatus::RIDER_ASSIGN);
            $jo->setStatusAutoAssign(AutoAssignStatus::HUB_ASSIGNED);

            if ($date_schedule != null)
                $jo->setDateSchedule($date_schedule);

            // update redis hub_jo_count for hub
            $hub_dist->incrementJoCountForHub($hub);
        }

        $em->persist($jo);
        $em->persist($invoice);

        // add event log for JO
        $event = new JOEvent();
        $event->setDateHappen(new DateTime())
            ->setTypeID(JOEventType::CREATE)
            ->setJobOrder($jo);
        $em->persist($event);

        // check JO status
        if ($jo->getStatus() == JOStatus::ASSIGNED)
        {
            // add event logs for hub and rider assignments
            $hub_assign_event = new JOEvent();
            $hub_assign_event->setDateHappen(new DateTime())
                ->setTypeID(JOEventType::HUB_ASSIGN)
                ->setJobOrder($jo);

            $em->persist($hub_assign_event);

            $rider_assign_event = new JOEvent();
            $rider_assign_event->setDateHappen(new DateTime())
                ->setTypeID(JOEventType::RIDER_ASSIGN)
                ->setJobOrder($jo);

            $em->persist($rider_assign_event);

            // user mqtt event
            $payload = [
               'event' => 'outlet_assign'
            ];
            $mclient->sendEvent($jo, $payload);

            $rah->assignJobOrder($jo, $jo->getRider());
        }

        if ($jo->getStatus() == JOStatus::RIDER_ASSIGN)
        {
            // add event logs for hub assignments
            $hub_assign_event = new JOEvent();
            $hub_assign_event->setDateHappen(new DateTime())
                ->setTypeID(JOEventType::HUB_ASSIGN)
                ->setJobOrder($jo);

            $em->persist($hub_assign_event);

            // user mqtt event
            $payload = [
               'event' => 'outlet_assign'
            ];
            $mclient->sendEvent($jo, $payload);
        }

        $em->flush();

        // make invoice json data
        $invoice_data = [
            'total_price' => $invoice->getTotalPrice(),
            'vat_ex_price' => (float) $invoice->getVATExclusivePrice(),
            'vat' => $invoice->getVAT(),
            'discount' => $invoice->getDiscount(),
            'trade_in' => $invoice->getTradeIn(),
        ];
        $items = $invoice->getItems();
        $items_data = [];
        foreach ($items as $item)
        {
            $items_data[] = [
                'title' => $item->getTitle(),
                'qty' => $item->getQuantity() + 0,
                'price' => $item->getPrice() + 0.0,
            ];
        }
        $invoice_data['items'] = $items_data;

        // make job order data
        $data = [
            'jo_id' => $jo->getID(),
            'invoice' => $invoice_data
        ];

        // need to check for customer tag/promo
        // check service type
        if ($jo->getServiceType() == ServiceType::BATTERY_REPLACEMENT_NEW)
        {
            $customer = $cv->getCustomer();
            $customer_tags = $customer->getCustomerTagObjects();
            if (!empty($customer_tags))
            {
                foreach ($customer_tags as $customer_tag)
                {
                    if ($customer_tag->getID() == $invoice->getUsedCustomerTagId())
                    {
                        // remove associated entity
                        $customer->removeCustomerTag($customer_tag);

                        // log the availment of promo from customer
                        $created_by = $req->query->get('api_key');;
                        $cust_id = $jo->getCustomer()->getID();
                        $cust_fname = $jo->getCustomer()->getFirstName();
                        $cust_lname = $jo->getCustomer()->getLastName();
                        $jo_id = $jo->getID();
                        $invoice_id = $jo->getInvoice()->getID();
                        // TODO: check if we store total price of invoice or just the discounted amount
                        $amount = $jo->getInvoice()->getTotalPrice();
                        $promo_logger->logPromoInfo($created_by, $cust_id, $cust_fname, $cust_lname, $jo_id,
                                                          $invoice_id, $amount);
                    }
                }
            }
        }

        // set data
        $res->setData($data);

        return $res->getReturnResponse();
    }

    public function getEstimate(Request $req, InvoiceGeneratorInterface $ic, EntityManagerInterface $em)
    {
        $this->denyAccessUnlessGranted('tapi_jo.get.estimate', null, 'No access.');

        // check required parameters and api key
        $required_params = [
            'service_type',
            'cv_id',
            // 'batt_id',
            'trade_in',
        ];
        $res = $this->checkParamsAndKey($req, $em, $required_params);
        if ($res->isError())
            return $res->getReturnResponse();

        // customer
        // TODO: needs to be modified to get customer
        $cust = $this->session->getCustomer();
        if ($cust == null)
        {
            $res->setError(true)
                ->setErrorMessage('No customer information found');
            return $res->getReturnResponse();
        }

        // make invoice criteria
        $icrit = new InvoiceCriteria();
        $icrit->setServiceType($req->request->get('service_type'));

        // check promo
        $promo_id = $req->request->get('promo_id');
        if (!empty($promo_id))
        {
            $promo = $em->getRepository(Promo::class)->find($promo_id);
            if ($promo == null)
            {
                $res->setError(true)
                    ->setErrorMessage('Invalid promo id');
                return $res->getReturnResponse();
            }

            // put in criteria
            $icrit->addPromo($promo);
        }

        // check customer vehicle
        $cv = $em->getRepository(CustomerVehicle::class)->find($req->request->get('cv_id'));
        if ($cv == null)
        {
            $res->setError(true)
                ->setErrorMessage('Invalid customer vehicle id');
            return $res->getReturnResponse();
        }
        $icrit->setCustomerVehicle($cv);

        // check if customer owns vehicle
        if ($cust->getID() != $cv->getCustomer()->getID())
        {
            $res->setError(true)
                ->setErrorMessage('Customer does not own vehicle');
            return $res->getReturnResponse();
        }

        // check battery
        $batt_id = $req->request->get('batt_id');
        if ($batt_id != null)
        {
            $batt = $em->getRepository(Battery::class)->find($batt_id);
            if ($batt == null)
            {
                $res->setError(true)
                    ->setErrorMessage('Invalid battery id');
                return $res->getReturnResponse();
            }
        }
        else
            $batt = null;

        $trade_in = $req->request->get('trade_in');
        switch ($trade_in)
        {
            case TradeInType::MOTOLITE:
            case TradeInType::OTHER:
                break;

            default:
                $trade_in = '';
                break;
        }

        $icrit->addEntry($batt, $trade_in, 1);

        // send to invoice generator
        $invoice = $ic->generateInvoice($icrit);

        // make invoice json data
        $data = [
            'total_price' => (float) $invoice->getTotalPrice(),
            'vat_ex_price' => (float) $invoice->getVATExclusivePrice(),
            'vat' => (float) $invoice->getVAT(),
            'discount' => (float) $invoice->getDiscount(),
            'trade_in' => (float) $invoice->getTradeIn(),
        ];
        $items = $invoice->getItems();
        $items_data = [];
        foreach ($items as $item)
        {
            $my_data = [
                'title' => $item->getTitle(),
                'qty' => (int) $item->getQuantity() + 0,
                'price' => (float) $item->getPrice() + 0.0,
            ];

            $item_batt = $item->getBattery();
            if ($item_batt != null)
            {
                $my_data['image_url'] = $this->getBatteryImageURL($req, $item_batt);
            }

            $items_data[] = $my_data;
        }

        $data['items'] = $items_data;

        // set data
        $res->setData($data);

        return $res->getReturnResponse();
    }

    public function getJOInvoice(Request $req, EntityManagerInterface $em)
    {
        $this->denyAccessUnlessGranted('tapi_jo.get.invoice', null, 'No access.');

        $required_params = [
            'jo_id',
        ];
        $res = $this->checkParamsAndKey($req, $em, $required_params);
        if ($res->isError())
            return $res->getReturnResponse();

        // get job order
        $jo_id = $req->query->get('jo_id');
        $jo = $em->getRepository(JobOrder::class)->find($jo_id);
        if ($jo == null)
        {
            $res->setError(true)
                ->setErrorMessage('No job order found');
            return $res->getReturnResponse();
        }

        // get customer
        // TODO: modify to get customer
        $cust = $this->session->getCustomer();
        if ($cust == null)
        {
            $res->setError(true)
                ->setErrorMessage('No customer information found');
            return $res->getReturnResponse();
        }

        // check that the customer owns the job order
        $jo_cust = $jo->getCustomer();
        if ($jo_cust->getID() != $cust->getID())
        {
            $res->setError(true)
                ->setErrorMessage('Job order was not initiated by customer');
            return $res->getReturnResponse();
        }

        $invoice = $jo->getInvoice();

        // make invoice json data
        $data = [
            'total_price' => (float) $invoice->getTotalPrice(),
            'vat_ex_price' => (float) $invoice->getVATExclusivePrice(),
            'vat' => (float) $invoice->getVAT(),
            'discount' => (float) $invoice->getDiscount(),
            'trade_in' => (float) $invoice->getTradeIn(),
        ];
        $items = $invoice->getItems();
        $items_data = [];
        foreach ($items as $item)
        {
            $my_data = [
                'title' => $item->getTitle(),
                'qty' => (int) $item->getQuantity() + 0,
                'price' => (float) $item->getPrice() + 0.0,
            ];

            $item_batt = $item->getBattery();
            if ($item_batt != null)
            {
                $my_data['image_url'] = $this->getBatteryImageURL($req, $item_batt);
            }

            $items_data[] = $my_data;
        }

        $data['items'] = $items_data;

        // set data
        $res->setData($data);

        return $res->getReturnResponse();
    }

    public function cancelJobOrder(Request $req, MQTTClient $mclient, EntityManagerInterface $em)
    {
        $this->denyAccessUnlessGranted('tapi_jo.cancel', null, 'No access.');

        $required_params = [
            'jo_id',
            'reason'
        ];
        $res = $this->checkParamsAndKey($req, $em, $required_params);
        if ($res->isError())
            return $res->getReturnResponse();

        // get job order
        $jo_id = $req->request->get('jo_id');
        $jo = $em->getRepository(JobOrder::class)->find($jo_id);
        if ($jo == null)
        {
            $res->setError(true)
                ->setErrorMessage('No job order found');
            return $res->getReturnResponse();
        }

        // get customer
        // TODO: modify to get customer
        $cust = $this->session->getCustomer();
        if ($cust == null)
        {
            $res->setError(true)
                ->setErrorMessage('No customer information found');
            return $res->getReturnResponse();
        }

        // check that the customer owns the job order
        $jo_cust = $jo->getCustomer();
        if ($jo_cust->getID() != $cust->getID())
        {
            $res->setError(true)
                ->setErrorMessage('Job order was not initiated by customer');
            return $res->getReturnResponse();
        }

        // TODO: check job order status, if it's cancellable
                $cancel_reason = $req->request->get('reason');

        $jo->cancel($cancel_reason);

        // add event log
        $event = new JOEvent();
        $event->setDateHappen(new DateTime())
            ->setTypeID(JOEventType::CANCEL)
            ->setJobOrder($jo);
        $em->persist($event);

        $em->flush();

        // TODO: do we need this?
        // send mobile app event
        $payload = [
            'event' => 'cancelled',
            'reason' => $cancel_reason,
            'jo_id' => $jo->getID(),
        ];
        $mclient->sendRiderEvent($jo, $payload);


        $res->setData([]);

        return $res->getReturnResponse();
    }

    // we can't use param converter for now because we want to output the proper 404
    public function getJobOrderInfo($id, Request $req, EntityManagerInterface $em, RiderTracker $rt)
    {
        $this->denyAccessUnlessGranted('tapi_jo.get.info', null, 'No access.');

        // check required parameters and api key
        $res = $this->checkParamsAndKey($req, $em, []);
        if ($res->isError())
            return $res->getReturnResponse();

        // get customer
        // TODO: modify to get customer
        $cust = $this->session->getCustomer();
        if ($cust == null)
        {
            $res->setError(true)
                ->setErrorMessage('No customer information found');
            return $res->getReturnResponse();
        }

        // get job order data
        $jo = $em->getRepository(JobOrder::class)->find($id);
        if ($jo == null)
        {
            $res->setError(true)
                ->setErrorMessage('No job order information found');
            return $res->getReturnResponse();
        }

        // check if job order belongs to customer / user
        if ($cust->getID() != $jo->getCustomer()->getID())
        {
            $res->setError(true)
                ->setErrorMessage('No job order information found');
            return $res->getReturnResponse();
        }

        // put into job order data array
        $jo_data = $this->generateJobOrderData($req, $jo, $rt);

        $data = [
            'job_order' => $jo_data
        ];
        $res->setData($data);

        return $res->getReturnResponse();
    }

    public function getJOHistory(Request $req, EntityManagerInterface $em)
    {
        $this->denyAccessUnlessGranted('tapi_jo.get.history', null, 'No access.');

        $res = $this->checkParamsAndKey($req, $em, []);
        if ($res->isError())
            return $res->getReturnResponse();

        // get customer
        // TODO: modify to find customer
        $cust = $this->session->getCustomer();
        if ($cust == null)
        {
            $res->setError(true)
                ->setErrorMessage('No customer information found');
            return $res->getReturnResponse();
        }

        // get job orders
        $all_jo_data = [];
        // get the fulfilled and cancelled job orders, since ongoing jos are not yet part of history
        $jos = $em->getRepository(JobOrder::class)->findBy([
            'customer' => $cust,
            'status' => [JOStatus::CANCELLED, JOStatus::FULFILLED]
        ], ['date_schedule' => 'DESC']);
        foreach ($jos as $jo)
        {
            // NOTE: use generateJobOrderData method, maybe?
            $status = $jo->getStatus();

            $jo_data = [
                'id' => $jo->getID(),
                'date_create' => $jo->getDateCreate()->format('M d, Y'),
                'service_type' => $jo->getServiceType(),
                'status' => $status,
            ];

            // customer vehicle and warranty
            $cv = $jo->getCustomerVehicle();

            // get latest warranty using plate number
            $warranty = $this->findWarranty($cv->getPlateNumber(), $em);

            $jo_data['customer_vehicle'] = [
                'id' => $cv->getID(),
                'plate_number' => $cv->getPlateNumber(),
                'warranty' => $warranty,
            ];

            // rider
            $rider = $jo->getRider();

            // check if jo has rider rating set to true
            $has_rider_rating = $jo->hasRiderRating();
            $rating = 0;
            $comment = '';
            if ($rider != null)
            {
                $jo_data['rider'] = $rider->getFullName();

                // find the rider rating if any
                if ($has_rider_rating)
                {
                    $jo_rating = $jo->getRating();
                    if ($jo_rating != null)
                    {
                        $rating = $jo_rating->getRating();

                        // get comment
                        $comment = $jo_rating->getComment();
                    }
                }
            }

            // rider rating for jo
            $jo_data['has_rider_rating'] = $has_rider_rating;
            $jo_data['rider_rating'] = $rating;
            $jo_data['comment'] = $comment;

            // invoice items
            $items = [];
            $jo_items = $jo->getInvoice()->getItems();
            foreach ($jo_items as $item)
            {
                $items[] = [
                    'id' => $item->getID(),
                    'title' => $item->getTitle(),
                    'qty' => $item->getQuantity(),
                    'price' => $item->getPrice(),
                ];
            }

            $jo_data['items'] = $items;

            // dates depending on status
            switch ($status)
            {
                case JOStatus::FULFILLED:
                    if ($jo->getDateFulfill() == null)
                        $jo_data['date_fulfilled'] = '';
                    else
                        $jo_data['date_fulfilled'] = $jo->getDateFulfill()->format('M d, Y');
                    break;
                case JOStatus::CANCELLED:
                    $date_cancel = $jo->getDateCancel();
                    if ($date_cancel == null)
                        $date_cancel = new DateTime();
                    $jo_data['date_cancelled'] = $date_cancel->format('M d, Y');
                    break;
            }

            $all_jo_data[] = $jo_data;
        }

        // return data
        $data = [
            'job_orders' => $all_jo_data
        ];
        $res->setData($data);

        // response
        return $res->getReturnResponse();
    }

    public function locationSupport(Request $req, GeofenceTracker $geo, EntityManagerInterface $em)
    {
        $this->denyAccessUnlessGranted('tapi_jo.location.support', null, 'No access.');

        $required_params = [
            'longitude',
            'latitude',
        ];
        $res = $this->checkParamsAndKey($req, $em, $required_params);
        if ($res->isError())
            return $res->getReturnResponse();

        $long = $req->query->get('longitude');
        $lat = $req->query->get('latitude');

        // NOTE: had to add this for promo tag
        // TODO: modify to find customer if we still need this
        $cust = $this->session->getCustomer();
        if ($cust == null)
        {
            $res->setError(true)
                ->setErrorMessage('No customer information found');
            return $res->getReturnResponse();
        }

        $is_covered = false;
        // check if customer still has promo
        if (($cust->getCustomerTag('TAG_CAR_CLUB_OFFICER_PROMO')) ||
            ($cust->getCustomerTag('TAG_CAR_CLUB_MEMBER_PROMO')))
        {
            // if has customer tag, customer has not availed of promo
            $is_covered = true;
        }
        else
        {
            // geofence
            $is_covered = $geo->isCovered($long, $lat);
        }

        $data = [
            'longitude' => $long,
            'latitude' => $lat,
            'supported' => $is_covered,
        ];
        $res->setData($data);

        // check if is_covered is false. If so, we need to set the error part in the response
        if (!$is_covered)
        {
            $res->setError(true)
                ->setErrorMessage('Oops! Our service is limited to some areas in Metro Manila, Laguna, and Baguio only. We will update you as soon as we are able to cover your area');
        }

        return $res->getReturnResponse();
    }

    // TODO: should we change to the HubSelector?
    public function getNearestHubAndSlots(Request $req, EntityManagerInterface $em,
                                          MapTools $map_tools)
    {
        $this->denyAccessUnlessGranted('tapi_jo.nearest_hub.get', null, 'No access.');

        $required_params = [
            'longitude',
            'latitude',
        ];

        $res = $this->checkParamsAndKey($req, $em, $required_params);
        if ($res->isError())
            return $res->getReturnResponse();

        $coordinates = new Point($req->query->get('longitude'), $req->query->get('latitude'));

        // add checking if customer has a pre-registered hub
        // TODO: modify how we get customer
        $cust = $this->session->getCustomer();
        if ($cust == null)
        {
            $res->setError(true)
                ->setErrorMessage('No customer information found');
            return $res->getReturnResponse();
        }

        // check if customer has customer tag promo
        // TODO: do we still need this?
        if (($cust->getCustomerTag('TAG_CAR_CLUB_OFFICER_PROMO')) ||
            ($cust->getCustomerTag('TAG_CAR_CLUB_MEMBER_PROMO')))
        {
            // if has customer tag, customer has not availed of promo, get the hub where customer is pre-registered
            $car_club_cust_hub = $cust->getCarClubCustomerHub();
            if ($car_club_cust_hub != null)
            {
                // need to get the rider slots for the pre-registered hub
                $hub = $car_club_cust_hub->getHub();
                $nearest_hub_slots = $this->findAdvanceNearestHubAndSlots($coordinates, $em, $map_tools, $hub);
            }
            else
            {
                $nearest_hub_slots = $this->findAdvanceNearestHubAndSlots($coordinates, $em, $map_tools);

                if (empty($nearest_hub_slots['hub']))
                {
                    $res->setError(true)
                        ->setErrorMessage('Thank you for reaching out to us. Please expect a call from us and we will assist you with your request. Thank you and stay safe!');
                    return $res->getReturnResponse();
                }
            }
        }
        else
        {
            $nearest_hub_slots = $this->findAdvanceNearestHubAndSlots($coordinates, $em, $map_tools);

            if (empty($nearest_hub_slots['hub']))
            {
                $res->setError(true)
                    ->setErrorMessage('Thank you for reaching out to us. Please expect a call from us and we will assist you with your request. Thank you and stay safe!');
                return $res->getReturnResponse();
            }
        }

        // make hub data
        $data = [
            'hub_id' => $nearest_hub_slots['hub']->getID(),
            'hub_slots' => $nearest_hub_slots['slots'],
        ];

        $res->setData($data);

        return $res->getReturnResponse();
    }

    public function scheduleOptionStatus(Request $req, EntityManagerInterface $em)
    {
        $this->denyAccessUnlessGranted('tapi_jo.schedule_option.status', null, 'No access.');

        // check required parameters and api key
        $required_params = [];
        $res = $this->checkParamsAndKey($req, $em, $required_params);
        if ($res->isError())
            return $res->getReturnResponse();

        $schedule_choice = true;

        // remove the time check after ECQ. This will then always return true
        // get current time
        $current_datetime = new DateTime();
        //$current_datetime = DateTime::createFromFormat('Y-m-d H:i', '2020-04-30 17:01');

        // get the hour
        $hour = $current_datetime->format('G');

        // commenting out the time check since we can now book 24/7
        // this will get uncommented out if and when ECQ will kick in
        //if (($hour < 8) || ($hour > 16))
        //    $schedule_choice = false;

        // add checking if customer has a pre-registered hub
        // TODO: modify how we get customer
        $cust = $this->session->getCustomer();
        if ($cust == null)
        {
            $res->setError(true)
                ->setErrorMessage('No customer information found');
            return $res->getReturnResponse();
        }
        // check if customer has customer tag promo
        if (($cust->getCustomerTag('TAG_CAR_CLUB_OFFICER_PROMO')) ||
            ($cust->getCustomerTag('TAG_CAR_CLUB_MEMBER_PROMO')))
        {
            // if has customer tag, customer has not availed of promo, get the hub where customer is pre-registered
            $car_club_hub = $cust->getCarClubCustomerHub();
            if ($car_club_hub != null)
            {
                $schedule_choice = false;
            }
        }

        // schedule_choice will always be true aka customer can opt to
        // Book Now or Schedule Order EXCEPT if customer has customer tag promo
        // or ECQ comes back
        $data = [
            'display_schedule_choice' => $schedule_choice,
        ];
        $res->setData($data);

        return $res->getReturnResponse();
    }

    protected function generateJobOrderData($req, $jo, $rt)
    {
        $status = $jo->getStatus();

        $dest = $jo->getCoordinates();

        $jo_data = [
            'id' => $jo->getID(),
            'date_create' => $jo->getDateCreate()->format('M d, Y'),
            'service_type' => $jo->getServiceType(),
            'destination' => [
                'long' => $dest->getLongitude(),
                 'lat' => $dest->getLatitude(),
            ],
            'delivery_address' => $jo->getDeliveryAddress(),
            'delivery_instructions' => $jo->getDeliveryInstructions(),
            'jo_status' => $status,
            'status' => $this->generateAPIRiderStatus($status),
                ];

        // customer vehicle and warranty
        $cv = $jo->getCustomerVehicle();

        // get latest warranty using plate number
        $warranty = $this->findWarranty($cv->getPlateNumber(), $em);

        $jo_data['customer_vehicle'] = [
            'id' => $cv->getID(),
            'plate_number' => $cv->getPlateNumber(),
            'warranty' => $warranty,
        ];

        // customer information
        $customer = $jo->getCustomer();
        $jo_data['customer'] = [
            'first_name' => $customer->getFirstName(),
            'last_name' => $customer->getLastName(),
            'mobile_number' => $customer->getPhoneMobile(),
        ];

        // rider
        $rider = $jo->getRider();
        if ($rider != null)
        {
            // default image url
            $url_prefix = $req->getSchemeAndHttpHost();
            $image_url = $url_prefix . '/assets/images/user.gif';
            if ($rider->getImageFile() != null)
                $image_url = $url_prefix . '/uploads/' . $rider->getImageFile();

            $coord = $rt->getRiderLocation($rider->getID());

            $jo_data['rider'] = [
                                'id' => $rider->getID(),
                                'name' => $rider->getFullName(),
                                'plate_num' => $rider->getPlateNumber(),
                                'contact_num' => $rider->getContactNumber(),
                                'image_url' => $image_url,
                                'location' => [
                                        'long' => $coord->getLongitude(),
                                        'lat' => $coord->getLatitude()
                                ]
            ];
        }
        else
        {
            $jo_data['rider'] = null;
        }

        // invoice items
        $items = [];
        $jo_items = $jo->getInvoice()->getItems();
        foreach ($jo_items as $item)
        {
            $items[] = [
                'id' => $item->getID(),
                'title' => $item->getTitle(),
                'qty' => $item->getQuantity(),
                'price' => $item->getPrice(),
            ];
        }

        $jo_data['items'] = $items;


        // dates depending on status
        switch ($status)
        {
            case JOStatus::FULFILLED:
                if ($jo->getDateFulfill() == null)
                    $jo_data['date_fulfilled'] = '';
                else
                    $jo_data['date_fulfilled'] = $jo->getDateFulfill()->format('M d, Y');
                break;
            case JOStatus::CANCELLED:
                $date_cancel = $jo->getDateCancel();
                if ($date_cancel == null)
                    $date_cancel = new DateTime();
                $jo_data['date_cancelled'] = $date_cancel->format('M d, Y');
                break;
        }

        return $jo_data;
    }

    protected function findWarranty($plate_number, EntityManagerInterface $em)
    {
        // NOTE: Modify the search for the latest warranty. This seems hacky.
        // get latest warranty using plate number
        $warranty_results = $em->getRepository(Warranty::class)->findBy(['plate_number' => $plate_number],
                        ['date_create' => 'desc']);

        $warr = [];

        // check if warranty_results is empty
        if (empty($warranty_results))
        {
            /*
            $res->setError(true)
                ->setErrorMessage('No warranty found for plate number');
            return $res->getReturnResponse();
            */

            return $warr;
        }

        // get first entry
        $warranty = current($warranty_results);

        // check for null values for battery and date claim and date expire
        $batt_model = '';
        $batt_size = '';
        $sap_batt = '';
        $claim_date = '';
        $expiry_date = '';

        if (!(is_null($warranty->getBatteryModel()))) {
            $batt_model = $warranty->getBatteryModel()->getName();
        }
        if (!(is_null($warranty->getBatterySize()))) {
            $batt_size = $warranty->getBatterySize()->getName();
        }
        if (!(is_null($warranty->getSAPBattery()))) {
            $sap_batt = $warranty->getSAPBattery()->getID();
        }
        if (!(is_null($warranty->getDateClaim()))) {
            $claim_date = $warranty->getDateClaim()->format("d M Y");
        }
        if (!(is_null($warranty->getDateExpire()))) {
            $expiry_date = $warranty->getDateExpire()->format("d M Y");
        }

        $warr[] = [
            'id' => $warranty->getID(),
            'serial' => $warranty->getSerial(),
            'warranty_class' => $warranty->getWarrantyClass(),
            'plate_number' => $warranty->getPlateNumber(),
            'first_name' => $warranty->getFirstName(),
            'last_name' => $warranty->getLastName(),
            'mobile_number' => $warranty->getMobileNumber(),
            'battery_model' => $batt_model,
            'battery_size' => $batt_size,
            'sap_battery' => $sap_batt,
            'status' => $warranty->getStatus(),
            'date_create' => $warranty->getDateCreate()->format("d M Y g:i A"),
            'date_purchase' => $warranty->getDatePurchase()->format("d M Y"),
            'date_expire' => $expiry_date,
            'date_claim' => $claim_date,
            'claim_from' => $warranty->getClaimedFrom(),
            'is_activated' => $warranty->isActivated() ? 1 : 0,
        ];

        return $warr;
    }

    protected function findAdvanceNearestHubAndSlots(Point $coordinates, EntityManagerInterface $em, MapTools $map_tools, $hub=null)
    {
        $hub_data = [];

        if ($hub != null)
        {
            // get the slots of hub
            $hub_slots = $this->getHubRiderSlots($hub, $em);

            $slots = $hub_slots['slot_data'];

            $hub_data = [
                'hub' => $hub,
                'slots' => $slots,
            ];
            return $hub_data;
        }

        // get the nearest 10 hubs
        $nearest_hubs_with_distance = [];
        $hubs = $map_tools->getClosestOpenHubs($coordinates, 10);

        foreach ($hubs as $hub)
        {
            $nearest_hubs_with_distance[] = $hub;
            // TODO: insert checking for branch code here when inventory manager is up
        }

        $nearest = null;
        $hub_slots = [];
        $slot_found = false;
        // find the nearest hub
        if (!empty($nearest_hubs_with_distance))
        {
            // get slots of nearest hub right after getting nearest hub.
            // then check if hub has available slots. If not, get next nearest hub.
            foreach ($nearest_hubs_with_distance as $nhd)
            {
                if (empty($nearest))
                {
                    // get the slots for the hub to check if hub is available for assignment
                    $hub_slots = $this->getHubRiderSlots($nhd['hub'], $em);

                    $flag_hub_available = $hub_slots['flag_hub_available'];
                    if ($flag_hub_available == true)
                    {
                        $nearest = $nhd;
                    }
                }
                else
                {
                    if ($nhd['distance'] < $nearest['distance'])
                    {
                        // get the slots for nearest which is nhd right now
                        $hub_slots = $this->getHubRiderSlots($nhd['hub'], $em);

                        $flag_hub_available = $hub_slots['flag_hub_available'];

                        // if hub is available, set hub to nearest
                        if ($flag_hub_available == true)
                        {
                            $nearest = $nhd;
                        }
                    }
                }
            }
        }

        if ($nearest != null)
        {
            // set hub data to what is in nearest
            $hub_data = [
                'hub' => $nearest['hub'],
                'slots' => $hub_slots['slot_data'],
            ];
        }

        return $hub_data;

    }

    protected function getHubRiderSlots(Hub $hub, EntityManagerInterface $em)
    {
        // check hub's advance orders for the day

        /*
        // get number of advance orders for the next day if request came in before midnight
        // or for current day if request came in after midnight
        // check request_time
        $request_time = time();
        $midnight = strtotime('00:00');
        */
        $start_date =  new DateTime();
        $end_date = new DateTime();

        // to keep things simple, just start on next day regardless of midnight timer
        $start_date->add(new DateInterval('P1D'));
        $end_date->add(new DateInterval('P3D'));

        /*
        if ($request_time < $midnight)
        {
            // add +1 to start date to get the next day
            // add +3 to date to end date to get the advance orders for the next three days
            $start_date->add(new DateInterval('P1D'));
            $end_date->add(new DateInterval('P1D'));
        }
        $end_date->add(new DateInterval('P2D'));
        */

        // set time bounds for the start and end date
        $start_date->setTime(0, 1);
        $end_date->setTime(23, 59);

        // NOTE: get advance orders via query
        // get JOs assigned to hub that are advance orders and scheduled for the next three days with
        // for hub assignment status
        $query = $em->createQuery('select jo from App\Entity\JobOrder jo where jo.hub = :hub and jo.flag_advance = true and 
                jo.date_schedule >= :date_start and jo.date_schedule <= :date_end and jo.status != :status_cancelled
                and jo.status != :status_fulfilled');
        $jos_advance_orders = $query->setParameters([
                'hub' => $hub,
                'date_start' => $start_date,
                'date_end' => $end_date,
                'status_cancelled' => JOStatus::CANCELLED,
                'status_fulfilled' => JOStatus::FULFILLED,
            ])
           ->getResult();
        // check request_time

        // define slots
        $slots = [
            '08_09' => '8:00 AM',
            '09_10' => '9:00 AM',
            '10_11' => '10:00 AM',
            '11_12' => '11:00 AM',
            '12_13' => '12:00 PM',
            '13_14' => '1:00 PM',
            '14_15' => '2:00 PM',
            '15_16' => '3:00 PM',
            '16_17' => '4:00 PM',
        ];

        // get the dates for the next three days
        $first_date = $start_date->format('Y-m-d');
        $second_date = $start_date->add(new DateInterval('P1D'));
        $sec_date = $second_date->format('Y-m-d');
        $third_date = $end_date->format('Y-m-d');

        // define days
        $days = [
            $first_date => $first_date,
            $sec_date => $sec_date,
            $third_date => $third_date,
        ];

        // initialize hub rider slots
        $hub_rider_slots = [];
        foreach ($days as $day)
        {
            foreach ($slots as $slot_key => $slot)
            {
                $hub_rider_slots[$day][$slot_key] = $hub->getRiderSlots();
            }
        }

        // check each JO's date_schedule, decrement rider_slots if date schedule falls in that slot
        foreach ($jos_advance_orders as $jo)
        {
            // get date key
            $date_sched = $jo->getDateSchedule();
            $date_string = $date_sched->format('Y-m-d');
            $hour = $date_sched->format('H');
            $slot_id = sprintf('%02d_%02d', $hour, $hour + 1);

            // error_log("SLOT - $date_string - $slot_id");

            // decrement rider slot
            if (isset($hub_rider_slots[$date_string][$slot_id]))
                $hub_rider_slots[$date_string][$slot_id]--;

            // check if it goes through next slot (10 min allowance)
            $mins = $date_sched->format('i');
            if ($mins > 10)
            {
                $next_slot_id = sprintf('%02d_%02d', $hour + 1, $hour + 2);
                // error_log("NEXT SLOT - $date_string - $next_slot_id");
                // decrement rider slot
                if (isset($hub_rider_slots[$date_string][$next_slot_id]))
                    $hub_rider_slots[$date_string][$next_slot_id]--;

            }
        }

        // error_log(print_r($hub_rider_slots, true));

        $hub_slots = $this->generateHubSlots($hub_rider_slots, $slots);

        // error_log(print_r($hub_slots, true));

        return $hub_slots;
    }

    protected function getTimeFromSlot($slot_id)
    {
        $time_selected = '';

        switch($slot_id) {
            case '08_09':
                $time_selected = AdvanceOrderSlot::_08_09;
                break;
           case '09_10':
                $time_selected = AdvanceOrderSlot::_09_10;
                break;
           case '10_11':
                $time_selected = AdvanceOrderSlot::_10_11;
                break;
           case '11_12':
                $time_selected = AdvanceOrderSlot::_11_12;
                break;
           case '12_13':
                $time_selected = AdvanceOrderSlot::_12_13;
                break;
           case '13_14':
                $time_selected = AdvanceOrderSlot::_13_14;
                break;
           case '14_15':
                $time_selected = AdvanceOrderSlot::_14_15;
                break;
           case '15_16':
                $time_selected = AdvanceOrderSlot::_15_16;
                break;
           case '16_17':
                $time_selected = AdvanceOrderSlot::_16_17;
                break;
           default:
                error_log('Invalid slot id ' . $slot_id);
        }

        return $time_selected;
    }

    protected function randomizeRider($riders)
    {
        // TODO: get redis to track the sales per rider per day
        //       check the time they came in
        // for now, randomize the rider
        $selected_index = array_rand($riders);

        $selected_rider = $riders[$selected_index];

        return $selected_rider;
    }

    protected function getBatteryImageURL($req, $batt)
    {
        // TODO: workaround for now, we get static image of battery based on model name
        $filename = trim(strtolower($batt->getModel()->getName())) . '_mobile.jpg';
        $file_path = $req->getSchemeAndHttpHost() . $this->generateUrl('static_battery_image') . '/' . $filename;

        return $file_path;
    }

    protected function getJobOrderRequestInfo(Request $req, EntityManagerInterface $em, &$data)
    {
        $r = $req->request;

        // trade-in type
        $trade_in_type = $this->cleanText($r->get('trade_in_type'));
        if (!TradeInType::validate($trade_in_type))
        {
            $message = 'Invalid trade in type';
            return $message;
        }

        // address
        $address = $r->get('delivery_address', 'Set by third party API');

        // instructions
        $instructions = $r->get('delivery_instructions', '');

        // landmark
        $landmark = $r->get('landmark', ' ');

        // longitude and latitude
        $long = $r->get('longitude');
        $lat = $r->get('latitude');

        // validate service type
        $stype = $this->cleanText($r->get('service_type'));
        if (!ServiceType::validate($stype))
        {
            $message = 'Invalid service type';
            return $message;
        }

        // get mode of payment
        // TODO: do we need to validate this?
        $payment_mode = $this->clean($r->get('mode_of_payment'));
        if (!ModeOfPayment::validate($payment_mode))
        {
            $message = 'Invalid mode of payment';
            return $message;
        }

        $advance_order = $r->get('flag_advance_order');
        // check for 'false' text
        if ($advance_order === false || $advance_order === 0 || $advance_order === '0' || $advance_order == 'false')
            $flag_advance_order = false;
        else
            $flag_advance_order = true;

        $hub = null;
        $hub_id = $r->get('hub_id');
        if (strlen($hub_id) > 0)
            $hub = $em->getRepository(Hub::class)->find($hub_id);

        $schedule_date = $r->get('date_schedule');
        $slot_id = $r->get('slot_id');

        // process the jo date schedule
        $date_schedule = null;
        if ((strlen($schedule_date) > 0) && (strlen($slot_id) > 0))
        {
            $time_schedule = $this->getTimeFromSlot($slot_id);
            if (!empty($time_schedule))
            {
                $s_date = $schedule_date . ' ' . $time_schedule;
                $date_schedule = DateTime::createFromFormat('Y-m-d H:i', $s_date);
                // error_log($date_schedule->format('Y-m-d H:i'));
            }
        }

        // check promo
        $promo =  null;
        $promo_id = $r->get('promo_id');
        if (!empty($promo_id))
        {
            $promo = $em->getRepository(Promo::class)->find($promo_id);
            if ($promo == null)
            {
                $message = 'Invalid promo id';
                return $message;
            }
        }

        // check battery
        $batt = null;
        $batt_id = $req->request->get('batt_id');
        if ($batt_id != null)
        {
            $batt = $em->getRepository(Battery::class)->find($batt_id);
            if ($batt == null)
            {
                $message = 'Invalid battery id';
                return $message;
            }
        }

        // get customer and vehicle info
        $fname = $r->get('first_name', '');
        $lname = $r->get('last_name', '');
        $mobile = $r->get('mobile_number', '');

        // validate mobile number
        $clean_mobile = $this->cleanPhoneNumber($mobile);
        if ($clean_mobile == false)
        {
            $message = 'Invalid mobile number.';
            return $message;
        }

        $vmanu = $r->get('vehicle_manufacturer', '');
        $vmodel = $r->get('vehicle_model', '');
        $plate_number = $r->get('plate_number');

        // clean plate number
        $clean_plate = $this->cleanPlateNumber($plate_number);

        $data = [
            'trade_in_type' => $trade_in_type,
            'service_type' => $stype,
            'long' => $long,
            'lat' => $lat,
            'payment_mode' => $payment_mode,
            'first_name' => $fname,
            'last_name' => $lname,
            'mobile' => $clean_mobile,
            'vmanu' => $vmanu,
            'vmodel' => $model,
            'plate_number' => $clean_plate,
            'address' => $address,
            'instructions' => $instructions,
            'landmark' => $landmark,
            'is_advance_order' => $flag_advance_order,
            'hub' => $hub,
            'date_schedule' => $date_schedule,
            'promo' => $promo,
            'batt' => $batt,
        ];

        return null;
    }

    protected function processCustomerAndVehicleInformation($data, EntityManagerInterface $em)
    {
        // retrieve customer info
        $fname = $data['first_name'];
        $lname = $data['last_name'];
        $vmanu = $data['vmanu'];
        $vmodel = $data['vmodel'];
        $plate_number = $data['plate_number'];
        $mobile = $data['mobile']; 
        
        // find customer given phone number
        $cust = $em->getRepository(Customer::class)->findOneBy(['phone_mobile' => $mobile]);

        if ($cust == null)
        {
            // create new customer and customer vehicle
        }
        else
        {
            // find customer vehicle using plate number
            $cv = $em->getRepository(CustomerVehicle::class)->findOneBy(['plate_number' => $plate_number]);
            if ($cv == null)
            {
                // create customer vehicle
            }
        }

        return $cust;
    }

    protected function cleanPhoneNumber($mobile)
    {
        // remove any non digit character from string
        $clean_number = preg_replace('~\D~', '', $mobile);

        // does it fit our 09XXXXXXXXX pattern?
        if (preg_match('/^09[0-9]{9}$/', $clean_number))
        {
            return $clean_number;
        }
        // does it fit our 9XXXXXXXXX pattern?
        else if (preg_match('/^9[0-9]{9}$/', $clean_number))
        {
            return $clean_number;
        }
        // does it fit our 63XXXXXXXXXX pattern?
        else if (preg_match('/^63[0-9]{10}$/', $clean_number))
        {
            // strip the 63 since we don't save the country code
            $c_number = substr($clean_number, 0, 2);
            return $c_number;
        }

        return false;
    }

    protected function cleanPlateNumber($plate)
    {
         // remove spaces and make upper case
        return strtoupper(str_replace(' ', '', $plate));
    }

    protected function cleanText($name)
    {
        return strtolower(trim($name));
    }
}