<?php

namespace App\Controller\ResqAPI;

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\MobileAPIHandler;
use App\Service\RiderTracker;
use App\Service\JobOrderManager;

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 Catalyst\APIBundle\Access\Generator as ACLGenerator;

use DateTime;
use DateInterval;

class JobOrderController extends APIController
{
    protected $acl_gen;

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

    public function requestJobOrder(Request $req, InvoiceGeneratorInterface $ic, GeofenceTracker $geo,
                                    InventoryManager $im, MQTTClient $mclient, RiderAssignmentHandlerInterface $rah, 
                                    EntityManagerInterface $em, HubSelector $hub_select, 
                                    HubDistributor $hub_dist, HubFilterLogger $hub_filter_logger, HubFilteringGeoChecker $hub_geofence,
                                    MobileAPIHandler $mah, JobOrderManager $jo_manager)
    {
        $this->denyAccessUnlessGranted('mobile_jo.request', null, 'No access.');

        // check required parameters
        $required_params = [
            'service_type',
            'cv_id',
            // 'batt_id',
            'trade_in',
            'long',
            'lat',
            'warranty',
            'mode_of_payment',
        ];

        $msg = $this->checkRequiredParameters($req, $required_params);
        if ($msg)
            return new APIResponse(false, $msg);

        // get capi user to link to mobile user
        $user_id = $this->getUser()->getID();

        // get mobile user
        $mobile_user = $mah->findMobileUser($user_id);

        if ($mobile_user == null)
            return new APIResponse(false, 'No mobile user found.');

        // validate request
        $msg = $this->validateJORequest($req, $geo);
        if ($msg)
            return new APIResponse(false, $msg);

        $jo = new JobOrder();
        $this->setJOObject($jo, $req, $em);

        // customer
        $cust = $mobile_user->getCustomer();
        if ($cust == null)
            return new APIResponse(false, 'No customer information found');

        $jo->setCustomer($cust);

        // make invoice criteria
        $icrit = new InvoiceCriteria();
        $msg = $this->setInvoiceCriteria($em, $icrit, $req, $cust, $jo);
        if ($msg != null)
            return new APIResponse(false, $msg);

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

        // set hub criteria details
        $hub_criteria = new HubCriteria();
        $this->setHubCriteria($em, $hub_geofence, $hub_criteria, $jo, $req);

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

        if (!empty($nearest_hubs))
            $this->assignRider($nearest_hubs, $jo, $hub_filter_logger, $hub_dist);

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

        // create JO event logs
        $jo_manager->processJobOrderEvents($jo, JOEventType::CREATE);

        // send mqtt events
        $payload = [
           'event' => 'outlet_assign'
        ];
        $this->processMQTTEvents($jo, $payload, $mclient, $rah); 

        $em->flush();

        $invoice_data = $this->makeInvoiceData($invoice, $mah, $req);

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

        // check service type
        if ($jo->getServiceType() == ServiceType::BATTERY_REPLACEMENT_NEW)
        {
            $customer_tags = $cust->getCustomerTagObjects();
            $jo_manager->removeCustomerTag($jo, $cust, $customer_tags, $mobile_user->getID());
        }

        return new APIResponse(true, 'Job order created', $data);
    }

    public function newRequestJobOrder(Request $req, InvoiceGeneratorInterface $ic, GeofenceTracker $geo,
                                       InventoryManager $im, MQTTClient $mclient,
                                       RiderAssignmentHandlerInterface $rah, HubSelector $hub_select, 
                                       HubDistributor $hub_dist, HubFilterLogger $hub_filter_logger,
                                       HubFilteringGeoChecker $hub_geofence, EntityManagerInterface $em,
                                       MobileAPIHandler $mah, JobOrderManager $jo_manager)
    {
        $this->denyAccessUnlessGranted('mobile_jo.request', null, 'No access.');

        // check required parameters
        $required_params = [
            'service_type',
            'cv_id',
            'trade_in',
            'long',
            'lat',
            'warranty',
            'mode_of_payment',
        ];

        $msg = $this->checkRequiredParameters($req, $required_params);
        if ($msg)
            return new APIResponse(false, $msg);

        // get capi user to link to mobile user
        $user_id = $this->getUser()->getID();

        // get mobile user
        $mobile_user = $mah->findMobileUser($user_id);

        if ($mobile_user == null)
            return new APIResponse(false, 'No mobile user found.');

        // validate request
        $msg = $this->validateJORequest($req, $geo);
        if ($msg)
            return new APIResponse(false, $msg);

        $jo = new JobOrder();
        $this->setJOObject($jo, $req, $em);

        // customer
        $cust = $mobile_user->getCustomer();
        if ($cust == null)
            return new APIResponse(false, 'No customer information found');

        $jo->setCustomer($cust);

        // make invoice criteria
        $icrit = new InvoiceCriteria();
        $msg = $this->setInvoiceCriteria($em, $icrit, $req, $cust, $jo);
        if ($msg != null)
            return new APIResponse(false, $msg);

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

        // assign hub and rider
        // check if hub is null
        if ($jo->getHub() == null)
        {
            // set hub criteria details
            $hub_criteria = new HubCriteria();
            $this->setHubCriteria($em, $hub_geofence, $hub_criteria, $jo, $req);

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

            if (!empty($nearest_hubs))
                $this->assignRider($nearest_hubs, $jo, $hub_filter_logger, $hub_dist);
        }
        else
        {
            $schedule_date = $req->request->get('date_schedule');
            $slot_id = $req->request->get('slot_id');
            $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'));
                }
            }

            $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($jo->getHub());
        }

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

        // create JO event logs
        $jo_manager->processJobOrderEvents($jo, JOEventType::CREATE);

        // send mqtt events
        $payload = [
           'event' => 'outlet_assign'
        ];
        $this->processMQTTEvents($jo, $payload, $mclient, $rah);

        $em->flush();

        // make invoice json data
        $invoice_data = $this->makeInvoiceData($invoice, $mah, $req);

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

        // check service type
        if ($jo->getServiceType() == ServiceType::BATTERY_REPLACEMENT_NEW)
        {
            $customer_tags = $cust->getCustomerTagObjects();
            $jo_manager->removeCustomerTag($jo, $cust, $customer_tags, $mobile_user->getID());
        }

        return new APIResponse(true, 'Job order created', $data);
    }

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

        // check required parameters
        $required_params = [
            'service_type',
            'cv_id',
            // 'batt_id',
            'trade_in',
        ];

        $msg = $this->checkRequiredParameters($req, $required_params);
        if ($msg)
            return new APIResponse(false, $msg);

        // get capi user to link to mobile user
        $user_id = $this->getUser()->getID();

        // get mobile user
        $mobile_user = $mah->findMobileUser($user_id);

        if ($mobile_user == null)
            return new APIResponse(false, 'No mobile user found.');

        // customer
        $cust = $mobile_user->getCustomer();
        if ($cust == null)
            return new APIResponse(false, 'No customer information found');

        // make invoice criteria
        $icrit = new InvoiceCriteria();
        $msg = $this->setInvoiceCriteria($em, $icrit, $req, $cust, null);
        if ($msg != null)
            return new APIResponse(false, $msg);

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

        // make invoice json data
        $invoice_data = $this->makeInvoiceData($invoice, $mah, $req);

        return new APIResponse(true, 'Estimate found', $invoice_data);
    }

    public function getOngoing(Request $req, EntityManagerInterface $em, MobileAPIHandler $mah)
    {
        $this->denyAccessUnlessGranted('mobile_jo.get.ongoing', null, 'No access.');

        $required_params = [];
        $msg = $this->checkRequiredParameters($req, $required_params);
        if ($msg)
            return new APIResponse(false, $msg);

        // get capi user to link to mobile user
        $user_id = $this->getUser()->getID();

        // get mobile user
        $mobile_user = $mah->findMobileUser($user_id);

        if ($mobile_user == null)
            return new APIResponse(false, 'No mobile user found.');

        // customer
        $cust = $mobile_user->getCustomer();
        if ($cust == null)
            return new APIResponse(false, 'No customer information found');

        $ongoing_jos = $mah->getOngoingJobOrders($cust);

        // initialize data
        $data = [];

        // no ongoing
        if (count($ongoing_jos) <= 0)
        {
            $data = [
                'has_ongoing' => false,
            ];
        }
        else
        {
            $data = [
                'has_ongoing' => true,
            ];
        }

        return new APIResponse(true, 'Ongoing job orders found.', $data);
    }

    public function cancelJobOrder(Request $req, MQTTClient $mclient, EntityManagerInterface $em,
                                   MobileAPIHandler $mah, RiderAssignmentHandlerInterface $rah,
                                   JobOrderManager $jo_manager)
    {
        $this->denyAccessUnlessGranted('mobile_jo.cancel', null, 'No access.');

        $required_params = [
            'jo_id',
            'reason'
        ];

        $msg = $this->checkRequiredParameters($req, $required_params);
        if ($msg)
            return new APIResponse(false, $msg);

        // get capi user to link to mobile user
        $user_id = $this->getUser()->getID();

        // get mobile user
        $mobile_user = $mah->findMobileUser($user_id);

        if ($mobile_user == null)
            return new APIResponse(false, 'No mobile user found.');

        // get job order
        $jo_id = $req->request->get('jo_id');
        $jo = $em->getRepository(JobOrder::class)->find($jo_id);
        if ($jo == null)
            return new APIResponse(false, 'No job order found');

        // get customer
        $cust = $mobile_user->getCustomer();
        if ($cust == null)
            new APIResponse(false, 'No customer information found');

        // check that the customer owns the job order
        $jo_cust = $jo->getCustomer();
        if ($jo_cust->getID() != $cust->getID())
            return new APIResponse(false, 'Job order was not initiated by customer');

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

        $jo->cancel($cancel_reason);

        // create event logs
        $jo_manager->processJobOrderEvents($jo, JOEventType::CANCEL);

        // send mqtt events
        $payload = [
            'event' => 'cancelled',
            'reason' => $cancel_reason,
            'jo_id' => $jo->getID(),
        ];
        $this->processMQTTEvents($jo, $payload, $mclient, $rah);

        $em->flush();

        $data = [];
        return new APIResponse(true, 'Job order cancelled', $data);
    }

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

        $required_params = [];
        $msg = $this->checkRequiredParameters($req, $required_params);
        if ($msg)
            return new APIResponse(false, $msg);

        // get capi user to link to mobile user
        $user_id = $this->getUser()->getID();

        // get mobile user
        $mobile_user = $mah->findMobileUser($user_id);

        if ($mobile_user == null)
            return new APIResponse(false, 'No mobile user found.');

        // customer
        $cust = $mobile_user->getCustomer();
        if ($cust == null)
            return new APIResponse(false, 'No customer information found');

        // get job orders
        $all_jo_data = [];
        $jos = $cust->getJobOrders();
        foreach ($jos as $jo)
        {
            $all_jo_data[] = $this->generateJobOrderData($req, $jo, $rt, $mah);
        }

        // return data
        $data = [
            'job_orders' => $all_jo_data
        ];

        return new APIResponse(true, 'Job order history found', $data);
    }

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

        $required_params = [
            'jo_id',
        ];

        $msg = $this->checkRequiredParameters($req, $required_params);
        if ($msg)
            return new APIResponse(false, $msg);

        // get capi user to link to mobile user
        $user_id = $this->getUser()->getID();

        // get mobile user
        $mobile_user = $mah->findMobileUser($user_id);

        if ($mobile_user == null)
            return new APIResponse(false, 'No mobile user found.');

        // customer
        $cust = $mobile_user->getCustomer();
        if ($cust == null)
            return new APIResponse(false, 'No customer information found');

        // check that the customer owns the job order
        $jo_cust = $jo->getCustomer();
        if ($jo_cust->getID() != $cust->getID())
            return new APIResponse(false, 'Job order was not initiated by customer');

        $invoice = $jo->getInvoice();

        $data = $this->makeInvoiceData($invoice, $mah, $req);

        return new APIResponse(true, 'Job order invoice found', $data);
    }

    public function locationSupport(Request $req, GeofenceTracker $geo, EntityManagerInterface $em,
                                    MobileAPIHandler $mah)
    {
        $required_params = [
            'longitude',
            'latitude',
        ];

        $msg = $this->checkRequiredParameters($req, $required_params);
        if ($msg)
            return new APIResponse(false, $msg);

        // get capi user to link to mobile user
        $user_id = $this->getUser()->getID();

        // get mobile user
        $mobile_user = $mah->findMobileUser($user_id);

        if ($mobile_user == null)
            return new APIResponse(false, 'No mobile user found.');

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

        // geofence
        $is_covered = $geo->isCovered($long, $lat);

        $data = [
            'longitude' => $long,
            'latitude' => $lat,
            'supported' => $is_covered,
        ];

        return new APIResponse(true, 'Location checked', $data);
    }

    public function getNearestHubAndSlots(Request $req, EntityManagerInterface $em,
                                          MobileAPIHandler $mah, HubSelector $hub_select)
    {
        $this->denyAccessUnlessGranted('mobile_jo.nearest_hub.get', null, 'No access.');

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

        $msg = $this->checkRequiredParameters($req, $required_params);
        if ($msg)
            return new APIResponse(false, $msg);

        // get capi user to link to mobile user
        $user_id = $this->getUser()->getID();

        // get mobile user
        $mobile_user = $mah->findMobileUser($user_id);

        if ($mobile_user == null)
            return new APIResponse(false, 'No mobile user found.');

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

        $hub_criteria = new HubCriteria();
        // get the nearest 10 hubs
        // TODO: do we need to check for inventory? if so, we need battery id
        $hub_criteria->setPoint($coordinates)
            ->setLimitResults(10);

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

        // get the nearest hub and slots
        $nearest_hub_slots = $this->findAdvanceNearestHubAndSlots($nearest_hubs, $em);

        if (empty($nearest_hub_slots['hub']))
            return new APIResponse(false, 'Thank you for reaching out to us. Due to the General Community Quarantine, our Operations are from 8AM to 6PM only. Please expect a call from us tomorrow and we will assist you with your request. Thank you and stay safe!');

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

        return new APIResponse(true, 'Hub and slot found', $data);
    }

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

        // check required parameters and api key
        $required_params = [];
        $msg = $this->checkRequiredParameters($req, $required_params);
        if ($msg)
            return new APIResponse(false, $msg);

        // get capi user to link to mobile user
        $user_id = $this->getUser()->getID();

        // get mobile user
        $mobile_user = $mah->findMobileUser($user_id);

        if ($mobile_user == null)
            return new APIResponse(false, 'No mobile user found.');

        $schedule_choice = true;

        // TODO: 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');

        if (($hour < 8) || ($hour > 16))
            $schedule_choice = false;

        $data = [
            'display_schedule_choice' => $schedule_choice,
        ];

        return new APIResponse(true, 'Schedule option status check', $data);
    }

    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 findAdvanceNearestHubAndSlots($nearest_hubs, EntityManagerInterface $em)
    {
        $nearest = null;
        $slot_found = false;
        // find the nearest hub
        if (!empty($nearest_hubs))
        {
            foreach ($nearest_hubs as $nhd)
            {
                if (empty($nearest))
                    $nearest = $nhd;
                else
                {
                    if ($nhd['distance'] < $nearest['distance'])
                    $nearest = $nhd;
                }
            }

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

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

        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);

        return $hub_slots;
    }

    protected function generateHubSlots($rider_slots, $slots)
    {
        $data = [];
        foreach ($rider_slots as $day_id => $rslot)
        {
            $data[$day_id] = [];

            foreach ($rslot as $slot_id => $avail_slots)
            {
                $slot_data = [
                    'id' => $slot_id,
                    'label' => $slots[$slot_id],
                    'available' => true,
                ];

                // mark unavailable ones
                if ($avail_slots <= 0)
                    $slot_data['available'] = false;

                // add to day data
                $data[$day_id][] = $slot_data;
            }
        }

        return $data;
    }

    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 validateJORequest(Request $req, GeofenceTracker $geo)
    {
        // geofence
        $long = $req->request->get('long');
        $lat = $req->request->get('lat');
        $is_covered = $geo->isCovered($long, $lat);
        if (!$is_covered)
        {
            // TODO: put geofence error message in config file somewhere
            $msg = '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 $msg;
        }

        // validate service type
        $stype = $req->request->get('service_type');
        if (!ServiceType::validate($stype))
        {
            $msg = 'Invalid service type';
            return $msg;
        }

        // validate warranty
        $warr = $req->request->get('warranty');
        if (!WarrantyClass::validate($warr))
        {
            $msg = 'Invalid warranty class';
            return $msg;
        }

        // validate payment method
        $payment_method = $req->request->get('mode_of_payment');
        if (!ModeOfPayment::validate($payment_method))
        {
            $msg = 'Invalid payment method';
            return $msg;
        }

        return null;
    }

    protected function setJOObject(JobOrder $jo, Request $req, EntityManagerInterface $em)
    {
        // longitude and latitude
        $long = $req->request->get('long');
        $lat = $req->request->get('lat');

        $point = new Point($long, $lat);

        // check for hub
        $hub = null;
        $hub_id = $req->request->get('hub_id');
        if (strlen($hub_id) > 0)
        {
            $hub = $em->getRepository(Hub::class)->find($hub_id);
            $jo->setHub($hub);
        }

        // check if advance order
        $advance_order = $req->request->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;

        $jo->setSource(TransactionOrigin::MOBILE_APP)
            ->setStatus(JOStatus::PENDING)
            ->setDeliveryInstructions('')
            ->setTier1Notes('')
            ->setTier2Notes('')
            ->setDeliveryAddress($req->request->get('delivery_address', 'Set by mobile application'))
            ->setTradeInType($req->request->get('trade_in'))
            ->setDeliveryInstructions($req->request->get('delivery_instructions', ''))
            ->setModeOfPayment($req->request->get('mode_of_payment'))
            ->setServiceType($req->request->get('service_type'))
            ->setWarrantyClass($req->request->get('warranty'))
            ->setCoordinates($point)
            ->setAdvanceOrder($flag_advance_order)
            ->setStatusAutoAssign(AutoAssignStatus::NOT_ASSIGNED);
    }

    protected function setInvoiceCriteria(EntityManagerInterface $em, InvoiceCriteria $icrit, Request $req,
                                          Customer $cust, $jo)
    {
        $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)
            {
                $msg = 'Invalid promo id';
                return $msg;
            }

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

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

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

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

        /*
        // put battery in criteria
        $icrit->addBattery($batt);
        */

        // check trade-in
        // only allow motolite, other, none
        $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);

        return null;
    }

    protected function setHubCriteria(EntityManagerInterface $em, HubFilteringGeoChecker $hub_geofence,
                                      HubCriteria $hub_criteria, JobOrder $jo, Request $req)
    {
        $hub_criteria->setPoint($jo->getCoordinates());
        $long = $jo->getCoordinates()->getLongitude();
        $lat = $jo->getCoordinates()->getLatitude();

        if ($hub_geofence->isCovered($long, $lat))
        {
            // TODO: set this properly, since the other flags
            // are on default values.
            // if true, set other values for HubCriteria
            // error_log('Area is covered by hub filtering');
            $hub_criteria->setJoType($jo->getServiceType())
                ->setPaymentMethod($jo->getModeOfPayment())
                ->setRoundRobin(true);
        }

        $batt_id = $req->request->get('batt_id');
        if ($batt_id != null)
        {
            $batt = $em->getRepository(Battery::class)->find($batt_id);
            if ($batt != null)
            {
                // add battery to items
                $sku = $batt->getSAPCode();
                if (!empty($sku))
                    $hub_criteria->addItem($batt->getSAPCode(), 1);
            }
        }
    }

    protected function assignRider($nearest_hubs, JobOrder $jo, HubFilterLogger $hub_filter_logger,
                                   HubDistributor $hub_dist)
    {
        // try to assin rider
        // 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)
        {
            $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);

                $assigned_rider->setAvailable(false);

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

                // break out of loop
                break;
            }
            else
            {
                // log hub into hub_filter_log
                $hub_filter_logger->logFilteredHub($nearest_hub['hub'], 'no_available_rider', $jo->getID(), $jo->getCustomer()->getID());
                // continue to go through list to find hub with an available rider
            }
        }
    }

    protected function processMQTTEvents(JobOrder $jo, $payload, MQTTClient $mclient, 
                                         RiderAssignmentHandlerInterface$rah)
    {
        // check JO status
        if ($jo->getStatus() == JOStatus::ASSIGNED)
        {
            $mclient->sendEvent($jo, $payload);
            $rah->assignJobOrder($jo, $jo->getRider());
        }
        if ($jo->getStatus() == JOStatus::RIDER_ASSIGN)
        {
            $mclient->sendEvent($jo, $payload);
        }
        if ($jo->getStatus() == JOStatus::CANCELLED)
        {
            $mclient->sendRiderEvent($jo, $payload);
        }
    }

    protected function makeInvoiceData(Invoice $invoice, MobileAPIHandler$mah, Request $req)
    {
        // make invoice json data
        $invoice_data = [
            'total_price' => $invoice->getTotalPrice(),
            'vat_ex_price' => $invoice->getVATExclusivePrice(),
            'vat' => $invoice->getVAT(),
            'discount' => $invoice->getDiscount(),
            'trade_in' => $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)
            {
                // generate the url for image
                $battery_image_url = $this->generateUrl('static_battery_image');
                $my_data['image_url'] = $mah->getBatteryImageURL($req, $item_batt, $battery_image_url);
            }

            $items_data[] = $my_data;
        }

        $invoice_data['items'] = $items_data;
        return $invoice_data;
    }

    protected function generateJobOrderData($req, $jo, $rt, $mah)
    {
        $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 = $mah->findWarranty($cv->getPlateNumber());

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

        // 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 generateAPIRiderStatus($status)
    {
        switch ($status)
        {
            case JOStatus::PENDING:
                return APIRiderStatus::OUTLET_ASSIGN;
            case JOStatus::RIDER_ASSIGN:
                return APIRiderStatus::RIDER_ASSIGN;
            case JOStatus::ASSIGNED:
            case JOStatus::IN_TRANSIT:
            case JOStatus::IN_PROGRESS:
                return APIRiderStatus::RIDER_PICK_UP;
        }
        return 'unknown';
    }
}