2282 lines
69 KiB
PHP
2282 lines
69 KiB
PHP
<?php
|
|
|
|
namespace App\Service\RiderAPIHandler;
|
|
|
|
use Doctrine\ORM\EntityManagerInterface;
|
|
use Symfony\Component\HttpFoundation\Request;
|
|
use Symfony\Component\Security\Core\Encoder\EncoderFactoryInterface;
|
|
|
|
use App\Ramcar\CMBServiceType;
|
|
use App\Ramcar\TradeInType;
|
|
use App\Ramcar\JOStatus;
|
|
use App\Ramcar\CMBJOEventType;
|
|
use App\Ramcar\InvoiceStatus;
|
|
use App\Ramcar\CMBModeOfPayment;
|
|
use App\Ramcar\InvoiceCriteria;
|
|
use App\Ramcar\CMBCancelReason;
|
|
|
|
use App\Service\RiderAPIHandlerInterface;
|
|
use App\Service\RedisClientProvider;
|
|
use App\Service\RiderCache;
|
|
use App\Service\MQTTClient;
|
|
use App\Service\WarrantyHandler;
|
|
use App\Service\JobOrderHandlerInterface;
|
|
use App\Service\InvoiceGeneratorInterface;
|
|
use App\Service\RiderTracker;
|
|
|
|
use App\Entity\RiderSession;
|
|
use App\Entity\Rider;
|
|
use App\Entity\User;
|
|
use App\Entity\JOEvent;
|
|
use App\Entity\Promo;
|
|
use App\Entity\Battery;
|
|
use App\Entity\BatteryModel;
|
|
use App\Entity\BatterySize;
|
|
use App\Entity\JobOrder;
|
|
use App\Entity\JOExtra;
|
|
|
|
use DateTime;
|
|
use DateInterval;
|
|
|
|
class CMBRiderAPIHandler implements RiderAPIHandlerInterface
|
|
{
|
|
// NOTE: Rider's constructor sets flag_available and flag_active to true, by default.
|
|
|
|
protected $em;
|
|
protected $redis;
|
|
protected $ef;
|
|
protected $rcache;
|
|
protected $country_code;
|
|
protected $mclient;
|
|
protected $wh;
|
|
protected $jo_handler;
|
|
protected $ic;
|
|
protected $session;
|
|
protected $upload_dir;
|
|
|
|
public function __construct(EntityManagerInterface $em, RedisClientProvider $redis,
|
|
EncoderFactoryInterface $ef, RiderCache $rcache,
|
|
string $country_code, MQTTClient $mclient,
|
|
WarrantyHandler $wh, JobOrderHandlerInterface $jo_handler,
|
|
InvoiceGeneratorInterface $ic, string $upload_dir,
|
|
RiderTracker $rider_tracker)
|
|
{
|
|
$this->em = $em;
|
|
$this->redis = $redis;
|
|
$this->ef = $ef;
|
|
$this->rcache = $rcache;
|
|
$this->country_code = $country_code;
|
|
$this->mclient = $mclient;
|
|
$this->wh = $wh;
|
|
$this->jo_handler = $jo_handler;
|
|
$this->ic = $ic;
|
|
$this->upload_dir = $upload_dir;
|
|
$this->rider_tracker = $rider_tracker;
|
|
|
|
// one device = one session, since we have control over the devices
|
|
// when a rider logs in, we just change the rider assigned to the device
|
|
// when a rider logs out, we remove the rider assigned to the device
|
|
$this->session = null;
|
|
}
|
|
|
|
public function register(Request $req)
|
|
{
|
|
// confirm parameters
|
|
$required_params = [
|
|
'phone_number',
|
|
'device_push_id'
|
|
];
|
|
|
|
$missing = $this->checkMissingParameters($req, $required_params);
|
|
if (count($missing) > 0)
|
|
{
|
|
$params = implode(', ', $missing);
|
|
$data = [
|
|
'title' => 'Failed Registration',
|
|
'error' => 'Missing parameter(s): ' . $params
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
// retry until we get a unique id
|
|
while (true)
|
|
{
|
|
try
|
|
{
|
|
// instantiate session
|
|
$sess = new RiderSession();
|
|
$sess->setPhoneNumber($req->request->get('phone_number'))
|
|
->setDevicePushID($req->request->get('device_push_id'));
|
|
|
|
// reopen in case we get an exception
|
|
if (!$this->em->isOpen())
|
|
{
|
|
$this->em = $this->em->create(
|
|
$this->em->getConnection(),
|
|
$this->em->getConfiguration()
|
|
);
|
|
}
|
|
|
|
// save
|
|
$this->em->persist($sess);
|
|
$this->em->flush();
|
|
|
|
// create redis entry for the session
|
|
$redis_client = $this->redis->getRedisClient();
|
|
$redis_key = 'rider.id.' . $sess->getID();
|
|
error_log('redis_key: ' . $redis_key);
|
|
$redis_client->set($redis_key, '');
|
|
}
|
|
catch (DBALException $e)
|
|
{
|
|
error_log($e->getMessage());
|
|
// delay one second and try again
|
|
sleep(1);
|
|
continue;
|
|
}
|
|
|
|
break;
|
|
}
|
|
|
|
// return data
|
|
$data = [
|
|
'session_id' => $sess->getID()
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function login(Request $req)
|
|
{
|
|
$required_params = [
|
|
'user',
|
|
'pass',
|
|
];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Login';
|
|
return $data;
|
|
}
|
|
|
|
// check if session has a rider already
|
|
if ($this->session->hasRider())
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Login',
|
|
'error' => 'Another rider is already logged in. Please logout first.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
// look for rider with username
|
|
$rider = $this->em->getRepository(Rider::class)->findOneBy(['username' => $req->request->get('user')]);
|
|
if ($rider == null)
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Login',
|
|
'error' => 'Invalid username or password.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
// check if rider password is correct
|
|
$encoder = $this->ef->getEncoder(new User());
|
|
if (!$encoder->isPasswordValid($rider->getPassword(), $req->request->get('pass'), ''))
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Login',
|
|
'error' => 'Invalid username or password.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
// assign rider to session
|
|
$this->session->setRider($rider);
|
|
|
|
//$rider->setAvailable(true);
|
|
$rider->setActive(true);
|
|
|
|
$rider_id = $rider->getID();
|
|
// cache rider location (default to hub)
|
|
// TODO: figure out longitude / latitude default
|
|
$this->rcache->addActiveRider($rider_id, 0, 0);
|
|
|
|
// TODO: log rider logging in
|
|
|
|
$this->em->flush();
|
|
|
|
// update redis rider.id.<session id> with the rider id
|
|
$redis_client = $this->redis->getRedisClient();
|
|
$redis_key = 'rider.id.' . $this->session->getID();
|
|
$rider_id = $rider->getID();
|
|
|
|
$redis_client->set($redis_key, $rider_id);
|
|
|
|
$hub = $rider->getHub();
|
|
if ($hub == null)
|
|
$hub_data = null;
|
|
else
|
|
{
|
|
$coord = $hub->getCoordinates();
|
|
$hub_data = [
|
|
'id' => $hub->getID(),
|
|
'name' => $hub->getName(),
|
|
'branch' => $hub->getBranch(),
|
|
'longitude' => $coord->getLongitude(),
|
|
'latitude' => $coord->getLatitude(),
|
|
'contact_nums' => $hub->getContactNumbers(),
|
|
];
|
|
}
|
|
|
|
// data
|
|
$data = [
|
|
'hub' => $hub_data,
|
|
'rider_id' => $rider_id,
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function logout(Request $req)
|
|
{
|
|
$required_params = [];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Logout';
|
|
return $data;
|
|
}
|
|
|
|
// make rider unavailable
|
|
$rider = $this->session->getRider();
|
|
|
|
// check if rider has assigned JOs
|
|
$assigned_jos = $this->em->getRepository(JobOrder::class)->findBy(['rider' => $rider->getID(), 'status' => JOStatus::ASSIGNED]);
|
|
if ($assigned_jos != null)
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Logout',
|
|
'error' => 'Rider has assigned job orders.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
$rider->setAvailable(false);
|
|
$rider->setActive(false);
|
|
|
|
// remove from cache
|
|
$this->rcache->removeActiveRider($rider->getID());
|
|
|
|
// remove rider from session
|
|
$this->session->setRider(null);
|
|
|
|
// TODO: log rider logging out
|
|
|
|
$this->em->flush();
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function goOnline(Request $req)
|
|
{
|
|
$required_params = [];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Go Online';
|
|
return $data;
|
|
}
|
|
|
|
// set rider to available to take on JOs
|
|
$rider = $this->session->getRider();
|
|
|
|
$rider->setAvailable(true);
|
|
|
|
$this->em->flush();
|
|
|
|
// send mqtt event to put rider on map
|
|
// get rider coordinates from redis
|
|
$coord = $this->rider_tracker->getRiderLocation($rider->getID());
|
|
|
|
$lng = $coord->getLongitude();
|
|
$lat = $coord->getLatitude();;
|
|
$channel = 'rider/' . $rider->getID() . '/availability';
|
|
$payload = [
|
|
'status' => 'rider_online',
|
|
'longitude' => $lng,
|
|
'latitude' => $lat,
|
|
];
|
|
$this->mclient->publish($channel, json_encode($payload));
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function goOffline(Request $req)
|
|
{
|
|
$required_params = [];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Go Offline';
|
|
return $data;
|
|
}
|
|
|
|
// set rider to unavailable to take on JOs
|
|
$rider = $this->session->getRider();
|
|
|
|
// check if rider has assigned JOs
|
|
$assigned_jos = $this->em->getRepository(JobOrder::class)->findBy(['rider' => $rider->getID(), 'status' => JOStatus::ASSIGNED]);
|
|
if ($assigned_jos != null)
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Go Offline',
|
|
'error' => 'Rider has assigned job orders.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
$rider->setAvailable(false);
|
|
|
|
$this->em->flush();
|
|
|
|
// send mqtt event to remove rider from map
|
|
$channel = 'rider/' . $rider->getID() . '/availability';
|
|
$payload = [
|
|
'status' => 'rider_offline'
|
|
];
|
|
$this->mclient->publish($channel, json_encode($payload));
|
|
|
|
return $data;
|
|
|
|
}
|
|
|
|
public function getJobOrderHistory(Request $req, $period)
|
|
{
|
|
$required_params = [];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Get Job Order History';
|
|
return $data;
|
|
}
|
|
|
|
// are we logged in?
|
|
if (!$this->session->hasRider())
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Get Job Order History',
|
|
'error' => 'No logged in rider.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
$rider = $this->session->getRider();
|
|
|
|
// get JOs assigned to rider for the month given
|
|
// setup start date and end dates
|
|
// get current year
|
|
$current_date = new DateTime();
|
|
|
|
if ($period == 'lastmonth')
|
|
{
|
|
$date_interval = new DateInterval('P1M');
|
|
$period_date = $current_date->sub($date_interval);
|
|
}
|
|
else
|
|
$period_date = $current_date;
|
|
|
|
$period_year = $period_date->format('Y');
|
|
$period_month = $period_date->format('m');
|
|
|
|
// get number of days in month requested
|
|
$last_day = cal_days_in_month(CAL_GREGORIAN, $period_month, $period_year);
|
|
|
|
$s_date = $period_year . '-' . $period_month . '-01 00:00:00';
|
|
$e_date = $period_year . '-' . $period_month . '-' . $last_day . ' 23:59:59';
|
|
|
|
$qb = $this->em->getRepository(JobOrder::class)->createQueryBuilder('j');
|
|
|
|
$query = $qb->innerJoin('j.rider', 'r')
|
|
->where('j.date_schedule >= :start')
|
|
->andWhere('j.date_schedule <= :end')
|
|
->andWhere('r.id = :rider_id')
|
|
->setParameter('start', $s_date)
|
|
->setParameter('end', $e_date)
|
|
->setParameter('rider_id', $rider->getID())
|
|
->getQuery();
|
|
|
|
$jo_results = $query->getResult();
|
|
|
|
$jo_data = [];
|
|
|
|
if (!(empty($jo_results)))
|
|
{
|
|
foreach ($jo_results as $jo)
|
|
{
|
|
// TODO: refactor this to call formatJobOrderData
|
|
$coord = $jo->getCoordinates();
|
|
$cust = $jo->getCustomer();
|
|
$cv = $jo->getCustomerVehicle();
|
|
$v = $cv->getVehicle();
|
|
$inv = $jo->getInvoice();
|
|
$promo = $inv->getPromo();
|
|
|
|
// invoice items
|
|
$inv_items = [];
|
|
foreach ($inv->getItems() as $item)
|
|
{
|
|
// if more than 1, split it into one of each of the same item
|
|
$item_qty = $item->getQuantity();
|
|
for ($i = 0; $i < $item_qty; $i++)
|
|
{
|
|
$item_batt = $item->getBattery();
|
|
if ($item_batt == null)
|
|
$batt_id = null;
|
|
else
|
|
$batt_id = $item_batt->getID();
|
|
|
|
$inv_items[] = [
|
|
'id' => $item->getID(),
|
|
'title' => $item->getTitle(),
|
|
'qty' => 1,
|
|
'price' => $item->getPrice(),
|
|
'batt_id' => $batt_id,
|
|
];
|
|
}
|
|
}
|
|
|
|
// promo
|
|
if ($promo != null)
|
|
{
|
|
$promo_data = [
|
|
'id' => $promo->getID(),
|
|
'name' => $promo->getName(),
|
|
'code' => $promo->getCode(),
|
|
'discount_rate' => $promo->getDiscountRate(),
|
|
'discount_apply' => $promo->getDiscountApply(),
|
|
];
|
|
}
|
|
else
|
|
{
|
|
$promo_data = null;
|
|
}
|
|
|
|
$trade_in_type = $jo->getTradeInType();
|
|
if (empty($trade_in_type))
|
|
$trade_in_type = 'none';
|
|
|
|
// get time when JO was accepted by rider
|
|
$accept_event_type = CMBJOEventType::RIDER_ACCEPT;
|
|
$rider_id = $this->session->getRider()->getID();
|
|
$jo_id = $jo->getID();
|
|
$date_accept = '';
|
|
|
|
$accept_results = $this->em->getRepository(JOEvent::class)->findby(['type_id' => $accept_event_type, 'rider' => $rider_id, 'job_order' => $jo_id], ['date_happen' => 'DESC']);
|
|
if ($accept_results != null)
|
|
{
|
|
$jo_event = current($accept_results);
|
|
$date_accept = $jo_event->getDateHappen()->format('Ymd H:i:s');
|
|
}
|
|
|
|
// get time when JO was started by rider
|
|
$start_event_type = CMBJOEventType::RIDER_START;
|
|
$date_start = '';
|
|
$start_results = $this->em->getRepository(JOEvent::class)->findby(['type_id' => $start_event_type, 'rider' => $rider_id, 'job_order' => $jo_id], ['date_happen' => 'DESC']);
|
|
if ($start_results != null)
|
|
{
|
|
$jo_event = current($start_results);
|
|
$date_start = $jo_event->getDateHappen()->format('Ymd H:i:s');
|
|
}
|
|
|
|
$jo_data[] = [
|
|
'job_order' => [
|
|
'id' => $jo->getID(),
|
|
'service_type' => $jo->getServiceType(),
|
|
'date_schedule' => $jo->getDateSchedule()->format('Ymd H:i:s'),
|
|
'longitude' => $coord->getLongitude(),
|
|
'latitude' => $coord->getLatitude(),
|
|
'status' => $jo->getStatus(),
|
|
'customer' => [
|
|
'title' => $cust->getTitle(),
|
|
'first_name' => $cust->getFirstName(),
|
|
'last_name' => $cust->getLastName(),
|
|
'phone_mobile' => $this->country_code . $cust->getPhoneMobile(),
|
|
'phone_landline' => $this->country_code . $cust->getPhoneLandline(),
|
|
],
|
|
'vehicle' => [
|
|
'manufacturer' => $v->getManufacturer()->getName(),
|
|
'make' => $v->getMake(),
|
|
'model' => $cv->getModelYear(),
|
|
'plate_number' => $cv->getPlateNumber(),
|
|
'color' => $cv->getColor(),
|
|
],
|
|
'or_num' => $jo->getORNum(),
|
|
'or_name' => $jo->getORName(),
|
|
'delivery_instructions' => $jo->getDeliveryInstructions(),
|
|
'delivery_address' => $jo->getDeliveryAddress(),
|
|
'landmark' => $jo->getLandmark(),
|
|
'invoice' => [
|
|
'discount' => $inv->getDiscount(),
|
|
'trade_in' => $inv->getTradeIn(),
|
|
'total_price' => $inv->getTotalPrice(),
|
|
'vat' => $inv->getVat(),
|
|
'items' => $inv_items,
|
|
],
|
|
'mode_of_payment' => $jo->getModeOfPayment(),
|
|
'mode_of_payment_display' => CMBModeOfPayment::getName($jo->getModeOfPayment()),
|
|
'trade_in_type' => $trade_in_type,
|
|
'promo' => $promo_data,
|
|
// TODO: load the actual
|
|
'has_warranty_doc' => false,
|
|
'flag_coolant' => $jo->hasCoolant(),
|
|
'has_motolite' => $cv->hasMotoliteBattery(),
|
|
// date and time accepted and started
|
|
'date_accept' => $date_accept,
|
|
'date_start' => $date_start,
|
|
]
|
|
];
|
|
}
|
|
}
|
|
|
|
$data = [
|
|
'jo_history' => $jo_data,
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function getAssignedJobOrders(Request $req)
|
|
{
|
|
$required_params = [];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Get Assigned Job Orders';
|
|
return $data;
|
|
}
|
|
|
|
// are we logged in?
|
|
if (!$this->session->hasRider())
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Get Assigned Job Orders',
|
|
'error' => 'No logged in rider.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
$rider = $this->session->getRider();
|
|
|
|
$qb = $this->em->getRepository(JobOrder::class)->createQueryBuilder('j');
|
|
|
|
$query = $qb->innerJoin('j.rider', 'r')
|
|
->andWhere('r.id = :rider_id')
|
|
->andWhere('j.status = :status')
|
|
->setParameter('rider_id', $rider->getID())
|
|
->setParameter('status', JOStatus::ASSIGNED)
|
|
->getQuery();
|
|
|
|
$jo_results = $query->getResult();
|
|
|
|
$jo_data = [];
|
|
|
|
if (!(empty($jo_results)))
|
|
{
|
|
foreach ($jo_results as $jo)
|
|
{
|
|
// TODO: refactor this to call formatJobOrderData
|
|
$coord = $jo->getCoordinates();
|
|
$cust = $jo->getCustomer();
|
|
$cv = $jo->getCustomerVehicle();
|
|
$v = $cv->getVehicle();
|
|
$inv = $jo->getInvoice();
|
|
$promo = $inv->getPromo();
|
|
|
|
// invoice items
|
|
$inv_items = [];
|
|
foreach ($inv->getItems() as $item)
|
|
{
|
|
// if more than 1, split it into one of each of the same item
|
|
$item_qty = $item->getQuantity();
|
|
for ($i = 0; $i < $item_qty; $i++)
|
|
{
|
|
$item_batt = $item->getBattery();
|
|
if ($item_batt == null)
|
|
$batt_id = null;
|
|
else
|
|
$batt_id = $item_batt->getID();
|
|
|
|
$inv_items[] = [
|
|
'id' => $item->getID(),
|
|
'title' => $item->getTitle(),
|
|
'qty' => 1,
|
|
'price' => $item->getPrice(),
|
|
'batt_id' => $batt_id,
|
|
];
|
|
}
|
|
}
|
|
|
|
// promo
|
|
if ($promo != null)
|
|
{
|
|
$promo_data = [
|
|
'id' => $promo->getID(),
|
|
'name' => $promo->getName(),
|
|
'code' => $promo->getCode(),
|
|
'discount_rate' => $promo->getDiscountRate(),
|
|
'discount_apply' => $promo->getDiscountApply(),
|
|
];
|
|
}
|
|
else
|
|
{
|
|
$promo_data = null;
|
|
}
|
|
|
|
$trade_in_type = $jo->getTradeInType();
|
|
if (empty($trade_in_type))
|
|
$trade_in_type = 'none';
|
|
|
|
$jo_data[] = [
|
|
'job_order' => [
|
|
'id' => $jo->getID(),
|
|
'service_type' => $jo->getServiceType(),
|
|
'date_schedule' => $jo->getDateSchedule()->format('Ymd H:i:s'),
|
|
'longitude' => $coord->getLongitude(),
|
|
'latitude' => $coord->getLatitude(),
|
|
'status' => $jo->getStatus(),
|
|
'customer' => [
|
|
'title' => $cust->getTitle(),
|
|
'first_name' => $cust->getFirstName(),
|
|
'last_name' => $cust->getLastName(),
|
|
'phone_mobile' => $this->country_code . $cust->getPhoneMobile(),
|
|
'phone_landline' => $this->country_code . $cust->getPhoneLandline(),
|
|
],
|
|
'vehicle' => [
|
|
'manufacturer' => $v->getManufacturer()->getName(),
|
|
'make' => $v->getMake(),
|
|
'model' => $cv->getModelYear(),
|
|
'plate_number' => $cv->getPlateNumber(),
|
|
'color' => $cv->getColor(),
|
|
],
|
|
'or_num' => $jo->getORNum(),
|
|
'or_name' => $jo->getORName(),
|
|
'delivery_instructions' => $jo->getDeliveryInstructions(),
|
|
'delivery_address' => $jo->getDeliveryAddress(),
|
|
'landmark' => $jo->getLandmark(),
|
|
'invoice' => [
|
|
'discount' => $inv->getDiscount(),
|
|
'trade_in' => $inv->getTradeIn(),
|
|
'total_price' => $inv->getTotalPrice(),
|
|
'vat' => $inv->getVat(),
|
|
'items' => $inv_items,
|
|
],
|
|
'mode_of_payment' => $jo->getModeOfPayment(),
|
|
'mode_of_payment_display' => CMBModeOfPayment::getName($jo->getModeOfPayment()),
|
|
'trade_in_type' => $trade_in_type,
|
|
'promo' => $promo_data,
|
|
// TODO: load the actual
|
|
'has_warranty_doc' => false,
|
|
'flag_coolant' => $jo->hasCoolant(),
|
|
'has_motolite' => $cv->hasMotoliteBattery(),
|
|
]
|
|
];
|
|
}
|
|
}
|
|
|
|
$data = [
|
|
'assigned_jos' => $jo_data,
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
|
|
protected function formatJobOrderData($req, $jo)
|
|
{
|
|
$coord = $jo->getCoordinates();
|
|
$cust = $jo->getCustomer();
|
|
$cv = $jo->getCustomerVehicle();
|
|
$v = $cv->getVehicle();
|
|
$inv = $jo->getInvoice();
|
|
$promo = $inv->getPromo();
|
|
|
|
// invoice items
|
|
$inv_items = [];
|
|
foreach ($inv->getItems() as $item)
|
|
{
|
|
// if more than 1, split it into one of each of the same item
|
|
$item_qty = $item->getQuantity();
|
|
for ($i = 0; $i < $item_qty; $i++)
|
|
{
|
|
$item_batt = $item->getBattery();
|
|
if ($item_batt == null)
|
|
$batt_id = null;
|
|
else
|
|
$batt_id = $item_batt->getID();
|
|
|
|
$inv_items[] = [
|
|
'id' => $item->getID(),
|
|
'title' => $item->getTitle(),
|
|
'qty' => 1,
|
|
'price' => $item->getPrice(),
|
|
'batt_id' => $batt_id,
|
|
];
|
|
}
|
|
}
|
|
|
|
// promo
|
|
if ($promo != null)
|
|
{
|
|
$promo_data = [
|
|
'id' => $promo->getID(),
|
|
'name' => $promo->getName(),
|
|
'code' => $promo->getCode(),
|
|
'discount_rate' => $promo->getDiscountRate(),
|
|
'discount_apply' => $promo->getDiscountApply(),
|
|
];
|
|
}
|
|
else
|
|
{
|
|
$promo_data = null;
|
|
}
|
|
|
|
$trade_in_type = $jo->getTradeInType();
|
|
if (empty($trade_in_type))
|
|
$trade_in_type = 'none';
|
|
|
|
// get date of status last change
|
|
if ($jo->getDateStatusChange() == null)
|
|
$date_status_change = null;
|
|
else
|
|
$date_status_change = $jo->getDateStatusChange()->format('Ymd H:i:s');
|
|
|
|
// get odometer reading
|
|
$odo = $jo->getMeta('odometer');
|
|
if ($odo <= 0)
|
|
$odo = 0;
|
|
|
|
$images = [
|
|
'image_1' => null,
|
|
'image_2' => null,
|
|
'image_3' => null,
|
|
'image_4' => null,
|
|
'others' => [],
|
|
];
|
|
$jo_extra = $jo->getJOExtra();
|
|
if ($jo_extra != null)
|
|
{
|
|
$images['image_1'] = $this->getURLExtraImage($req, $jo_extra->getImage1Filename());
|
|
$images['image_2'] = $this->getURLExtraImage($req, $jo_extra->getImage2Filename());
|
|
$images['image_3'] = $this->getURLExtraImage($req, $jo_extra->getImage3Filename());
|
|
$images['image_4'] = $this->getURLExtraImage($req, $jo_extra->getImage4Filename());
|
|
|
|
// other images
|
|
$other_images = [];
|
|
foreach ($jo_extra->getOtherImages() as $others)
|
|
{
|
|
$other_images[] = $this->getURLExtraImage($req, $others);
|
|
}
|
|
$images['others'] = $other_images;
|
|
}
|
|
|
|
// customer email
|
|
if ($jo->getMeta('customer_email') == null)
|
|
$cust_email = '';
|
|
else
|
|
$cust_email = $jo->getMeta('customer_email');
|
|
|
|
// get time when JO was accepted by rider
|
|
$accept_event_type = CMBJOEventType::RIDER_ACCEPT;
|
|
$rider_id = $this->session->getRider()->getID();
|
|
$jo_id = $jo->getID();
|
|
$date_accept = '';
|
|
|
|
$accept_results = $this->em->getRepository(JOEvent::class)->findby(['type_id' => $accept_event_type, 'rider' => $rider_id, 'job_order' => $jo_id], ['date_happen' => 'DESC']);
|
|
if ($accept_results != null)
|
|
{
|
|
$jo_event = current($accept_results);
|
|
$date_accept = $jo_event->getDateHappen()->format('Ymd H:i:s');
|
|
}
|
|
|
|
// get time when JO was started by rider
|
|
$start_event_type = CMBJOEventType::RIDER_START;
|
|
$date_start = '';
|
|
$start_results = $this->em->getRepository(JOEvent::class)->findby(['type_id' => $start_event_type, 'rider' => $rider_id, 'job_order' => $jo_id], ['date_happen' => 'DESC']);
|
|
if ($start_results != null)
|
|
{
|
|
$jo_event = current($start_results);
|
|
$date_start = $jo_event->getDateHappen()->format('Ymd H:i:s');
|
|
}
|
|
|
|
$data = [
|
|
'id' => $jo->getID(),
|
|
'service_type' => $jo->getServiceType(),
|
|
'date_schedule' => $jo->getDateSchedule()->format('Ymd H:i:s'),
|
|
'longitude' => $coord->getLongitude(),
|
|
'latitude' => $coord->getLatitude(),
|
|
'status' => $jo->getStatus(),
|
|
'date_status_change' => $date_status_change,
|
|
'customer' => [
|
|
'title' => $cust->getTitle(),
|
|
'first_name' => $cust->getFirstName(),
|
|
'last_name' => $cust->getLastName(),
|
|
'phone_mobile' => $this->country_code . $cust->getPhoneMobile(),
|
|
'phone_landline' => $this->country_code . $cust->getPhoneLandline(),
|
|
],
|
|
'vehicle' => [
|
|
'manufacturer' => $v->getManufacturer()->getName(),
|
|
'make' => $v->getMake(),
|
|
'model' => $cv->getModelYear(),
|
|
'plate_number' => $cv->getPlateNumber(),
|
|
'color' => $cv->getColor(),
|
|
],
|
|
'or_num' => $jo->getORNum(),
|
|
'or_name' => $jo->getORName(),
|
|
'delivery_instructions' => $jo->getDeliveryInstructions(),
|
|
'delivery_address' => $jo->getDeliveryAddress(),
|
|
'landmark' => $jo->getLandmark(),
|
|
'invoice' => [
|
|
'discount' => $inv->getDiscount(),
|
|
'trade_in' => $inv->getTradeIn(),
|
|
'total_price' => $inv->getTotalPrice(),
|
|
'vat' => $inv->getVat(),
|
|
'items' => $inv_items,
|
|
],
|
|
'mode_of_payment' => $jo->getModeOfPayment(),
|
|
'mode_of_payment_display' => CMBModeOfPayment::getName($jo->getModeOfPayment()),
|
|
'trade_in_type' => $trade_in_type,
|
|
'promo' => $promo_data,
|
|
// TODO: load the actual
|
|
'has_warranty_doc' => false,
|
|
'flag_coolant' => $jo->hasCoolant(),
|
|
'has_motolite' => $cv->hasMotoliteBattery(),
|
|
|
|
// BEGIN: cmb specific details
|
|
|
|
// odometer
|
|
'odometer' => $odo,
|
|
|
|
// images
|
|
'finish_photos' => $images,
|
|
|
|
// customer email
|
|
'customer_email' => $cust_email,
|
|
|
|
// date and time accepted and started
|
|
'date_accept' => $date_accept,
|
|
'date_start' => $date_start,
|
|
|
|
// END: cmb specific details
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function getJobOrder(Request $req)
|
|
{
|
|
$required_params = [
|
|
'jo_id'
|
|
];
|
|
$data = $this->checkJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Get Job Order';
|
|
return $data;
|
|
}
|
|
|
|
$jo_data = $this->formatJobOrderData($req, $jo);
|
|
|
|
$data = [
|
|
'job_order' => $jo_data
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function acceptJobOrder(Request $req)
|
|
{
|
|
$required_params = [
|
|
'jo_id'
|
|
];
|
|
$data = $this->checkJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Accept Job Order';
|
|
return $data;
|
|
}
|
|
|
|
// TODO: put JO in job queue
|
|
|
|
// TODO: refactor this into a jo handler class, so we don't have to repeat for control center
|
|
// TODO: send mqtt event (?)
|
|
// add event log
|
|
$rider = $this->session->getRider();
|
|
$event = new JOEvent();
|
|
$event->setDateHappen(new DateTime())
|
|
->setTypeID(CMBJOEventType::RIDER_ACCEPT)
|
|
->setJobOrder($jo)
|
|
->setRider($rider);
|
|
$this->em->persist($event);
|
|
|
|
$this->em->flush();
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function setJobOrderInTransit(Request $req)
|
|
{
|
|
$required_params = ['jo_id'];
|
|
$data = $this->checkActiveJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Set Job Order in Transit';
|
|
return $data;
|
|
}
|
|
|
|
// set jo status to in transit
|
|
$jo->setStatus(JOStatus::IN_TRANSIT);
|
|
|
|
// set rider's active JO
|
|
|
|
|
|
// TODO: send mqtt event (?)
|
|
|
|
// add event log
|
|
$rider = $this->session->getRider();
|
|
$event = new JOEvent();
|
|
$event->setDateHappen(new DateTime())
|
|
->setTypeID(CMBJOEventType::RIDER_IN_TRANSIT)
|
|
->setJobOrder($jo)
|
|
->setRider($rider);
|
|
$this->em->persist($event);
|
|
|
|
$this->em->flush();
|
|
|
|
return $data;
|
|
|
|
}
|
|
|
|
public function cancelJobOrder(Request $req)
|
|
{
|
|
$required_params = [
|
|
'jo_id',
|
|
'cancel_reason'
|
|
];
|
|
$data = $this->checkJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Job Order Cancellation';
|
|
return $data;
|
|
}
|
|
|
|
$cancel_reason = $req->request->get('cancel_reason');
|
|
|
|
$jo->cancel($cancel_reason);
|
|
|
|
// add event log
|
|
$rider = $this->session->getRider();
|
|
$event = new JOEvent();
|
|
$event->setDateHappen(new DateTime())
|
|
->setTypeID(CMBJOEventType::REQUEUE)
|
|
->setJobOrder($jo)
|
|
->setRider($rider);
|
|
$this->em->persist($event);
|
|
|
|
$this->em->flush();
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function performJobOrder(Request $req)
|
|
{
|
|
$required_params = [
|
|
'jo_id',
|
|
];
|
|
|
|
$data = $this->checkJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Job Order Perform';
|
|
return $data;
|
|
}
|
|
|
|
$jo->perform();
|
|
|
|
// add event log
|
|
$rider = $this->session->getRider();
|
|
$event = new JOEvent();
|
|
$event->setDateHappen(new DateTime())
|
|
->setTypeID(CMBJOEventType::PERFORM)
|
|
->setJobOrder($jo)
|
|
->setRider($rider);
|
|
$this->em->persist($event);
|
|
|
|
$this->em->flush();
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function rejectJobOrder(Request $req)
|
|
{
|
|
$required_params = [
|
|
'jo_id'
|
|
];
|
|
$data = $this->checkJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Job Order Rejection';
|
|
return $data;
|
|
}
|
|
|
|
$jo->requeue();
|
|
|
|
// set rider to null
|
|
$jo->clearRider();
|
|
|
|
// add event log
|
|
$rider = $this->session->getRider();
|
|
$event = new JOEvent();
|
|
$event->setDateHappen(new DateTime())
|
|
->setTypeID(CMBJOEventType::REQUEUE)
|
|
->setJobOrder($jo)
|
|
->setRider($rider);
|
|
$this->em->persist($event);
|
|
|
|
// set rider's active JO to null
|
|
$rider->setActiveJobOrder();
|
|
|
|
$this->em->flush();
|
|
|
|
// send mqtt event
|
|
// send outlet assign since order should go back to hub and await reassignment to another rider
|
|
$payload = [
|
|
'event' => 'outlet_assign',
|
|
'jo_id' => $jo->getID(),
|
|
];
|
|
$this->mclient->sendEvent($jo, $payload);
|
|
|
|
// send available event to change rider icon status
|
|
$channel = 'rider/' . $rider->getID() . '/status';
|
|
$rider_status = 'available';
|
|
|
|
$this->mclient->publish($channel, $rider_status);
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function arrive(Request $req)
|
|
{
|
|
$required_params = ['jo_id'];
|
|
$data = $this->checkActiveJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Arrive';
|
|
return $data;
|
|
}
|
|
|
|
// TODO: refactor this into a jo handler class, so we don't have to repeat for control center
|
|
|
|
// set jo status to in progress
|
|
$jo->setStatus(JOStatus::IN_PROGRESS);
|
|
|
|
// add event log
|
|
$rider = $this->session->getRider();
|
|
$event = new JOEvent();
|
|
$event->setDateHappen(new DateTime())
|
|
->setTypeID(CMBJOEventType::RIDER_ARRIVE)
|
|
->setJobOrder($jo)
|
|
->setRider($rider);
|
|
$this->em->persist($event);
|
|
|
|
$this->em->flush();
|
|
|
|
// send mqtt event
|
|
$rider = $this->session->getRider();
|
|
$image_url = $req->getScheme() . '://' . $req->getHttpHost() . $req->getBasePath() . '/assets/images/user.gif';
|
|
if ($rider->getImageFile() != null)
|
|
$image_url = $req->getScheme() . '://' . $req->getHttpHost() . $req->getBasePath() . '/uploads/' . $rider->getImageFile();
|
|
|
|
$payload = [
|
|
'event' => 'driver_arrived',
|
|
'jo_id' => $jo->getID(),
|
|
'driver_image' => $image_url,
|
|
'driver_name' => $rider->getFullName(),
|
|
'driver_id' => $rider->getID(),
|
|
];
|
|
$this->mclient->sendEvent($jo, $payload);
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function hubArrive(Request $req)
|
|
{
|
|
$required_params = [];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
return $data;
|
|
|
|
// are we logged in?
|
|
if (!$this->session->hasRider())
|
|
{
|
|
$data = [
|
|
'error' => 'No logged in rider.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
// tag rider as available
|
|
$rider = $this->session->getRider();
|
|
$rider->setAvailable(true);
|
|
|
|
$this->em->flush();
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function payment(Request $req)
|
|
{
|
|
$required_params = [
|
|
'jo_id',
|
|
'mode_of_payment',
|
|
];
|
|
$data = $this->checkActiveJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Payment';
|
|
return $data;
|
|
}
|
|
|
|
// add mode of payment
|
|
$mode = $req->request->get('mode_of_payment');
|
|
$jo->setModeOfPayment($mode);
|
|
|
|
// set status to paid
|
|
$jo->setStatus(JOStatus::PAID);
|
|
|
|
|
|
// set invoice to paid
|
|
$jo->getInvoice()->setStatus(InvoiceStatus::PAID);
|
|
|
|
// add event log
|
|
$rider = $this->session->getRider();
|
|
$event = new JOEvent();
|
|
$event->setDateHappen(new DateTime())
|
|
->setTypeID(CMBJOEventType::PAID)
|
|
->setJobOrder($jo)
|
|
->setRider($rider);
|
|
$this->em->persist($event);
|
|
|
|
$this->em->flush();
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function available(Request $req)
|
|
{
|
|
$required_params = [];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Available Rider';
|
|
return $data;
|
|
}
|
|
|
|
// make rider available
|
|
$this->session->getRider()->setAvailable(true);
|
|
|
|
// TODO: log rider available
|
|
$this->em->flush();
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function getPromos(Request $req)
|
|
{
|
|
$required_params = [];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Get Promos';
|
|
return $data;
|
|
}
|
|
|
|
$promos = $this->em->getRepository(Promo::class)->findAll();
|
|
|
|
$promo_data = [];
|
|
foreach ($promos as $promo)
|
|
{
|
|
$promo_data[] = [
|
|
'id' => $promo->getID(),
|
|
'name' => $promo->getName(),
|
|
'code' => $promo->getCode(),
|
|
];
|
|
}
|
|
|
|
$data = [
|
|
'promos' => $promo_data,
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function getBatteries(Request $req)
|
|
{
|
|
// get batteries, models, and sizes
|
|
$required_params = [];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Get Batteries';
|
|
return $data;
|
|
}
|
|
|
|
$batts = $this->em->getRepository(Battery::class)->findAll();
|
|
$models = $this->em->getRepository(BatteryModel::class)->findAll();
|
|
$sizes = $this->em->getRepository(BatterySize::class)->findAll();
|
|
|
|
$batt_data = [];
|
|
foreach ($batts as $batt)
|
|
{
|
|
$batt_data[] = [
|
|
'id' => $batt->getID(),
|
|
'model_id' => $batt->getModel()->getID(),
|
|
'size_id' => $batt->getSize()->getID(),
|
|
'sell_price' => $batt->getSellingPrice(),
|
|
];
|
|
}
|
|
|
|
$model_data = [];
|
|
foreach ($models as $model)
|
|
{
|
|
$model_data[] = [
|
|
'id' => $model->getID(),
|
|
'name' => $model->getName(),
|
|
];
|
|
}
|
|
|
|
$size_data = [];
|
|
foreach ($sizes as $size)
|
|
{
|
|
$size_data[] = [
|
|
'id' => $size->getID(),
|
|
'name' => $size->getName(),
|
|
];
|
|
}
|
|
|
|
$data = [
|
|
'batteries' => $batt_data,
|
|
'models' => $model_data,
|
|
'sizes' => $size_data,
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function changeService(Request $req)
|
|
{
|
|
$this->debugRequest($req);
|
|
|
|
// allow rider to change service, promo, battery and trade-in options
|
|
$required_params = ['jo_id', 'service_type', 'promo_id'];
|
|
$data = $this->checkJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Service Change';
|
|
return $data;
|
|
}
|
|
|
|
// check service type
|
|
$service_type = $req->request->get('service_type');
|
|
if (!CMBServiceType::validate($service_type))
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Service Change',
|
|
'error' => 'Invalid service type - ' . $service_type
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
// check promo id
|
|
$promo_id = $req->request->get('promo_id');
|
|
// no promo
|
|
if ($promo_id == 0)
|
|
$promo = null;
|
|
else
|
|
{
|
|
$promo = $this->em->getRepository(Promo::class)->find($promo_id);
|
|
if ($promo == null)
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Service Change',
|
|
'error' => 'Invalid promo id - ' . $promo_id
|
|
];
|
|
return $data;
|
|
}
|
|
}
|
|
|
|
// check or number
|
|
$or_num = $req->request->get('or_num');
|
|
if ($or_num != null)
|
|
$jo->setORNum($or_num);
|
|
|
|
// coolant
|
|
$flag_coolant = $req->request->get('flag_coolant', 'false');
|
|
if ($flag_coolant == 'true')
|
|
$jo->setHasCoolant(true);
|
|
else
|
|
$jo->setHasCoolant(false);
|
|
|
|
// has motolite battery
|
|
$cv = $jo->getCustomerVehicle();
|
|
$has_motolite = $req->request->get('has_motolite', 'false');
|
|
if ($has_motolite == 'true')
|
|
$cv->setHasMotoliteBattery(true);
|
|
else
|
|
$cv->setHasMotoliteBattery(false);
|
|
$this->em->persist($cv);
|
|
|
|
// check battery id
|
|
$batt_id = $req->request->get('batt_id', null);
|
|
// no battery
|
|
if ($batt_id == 0 || $batt_id == null)
|
|
$battery = null;
|
|
else
|
|
{
|
|
$battery = $this->em->getRepository(Battery::class)->find($batt_id);
|
|
if ($battery == null)
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Service Change',
|
|
'error' => 'Invalid battery id - ' . $batt_id
|
|
];
|
|
return $data;
|
|
}
|
|
}
|
|
|
|
// check trade in
|
|
$trade_in = $req->request->get('trade_in');
|
|
if (!TradeInType::validate($trade_in))
|
|
$trade_in = null;
|
|
|
|
// check mode of payment
|
|
// TODO: defaulting to credit_card for now if mode of payment is invalid
|
|
$mode = $req->request->get('mode_of_payment');
|
|
if (!CMBModeOfPayment::validate($mode))
|
|
$mode = CMBModeOfPayment::CASH;
|
|
$jo->setModeOfPayment($mode);
|
|
|
|
// generate new invoice
|
|
$crit = new InvoiceCriteria();
|
|
$crit->setServiceType($service_type);
|
|
$crit->setCustomerVehicle($cv);
|
|
$crit->setHasCoolant($jo->hasCoolant());
|
|
|
|
if ($promo != null)
|
|
$crit->addPromo($promo);
|
|
|
|
if ($battery != null)
|
|
{
|
|
$crit->addEntry($battery, $trade_in, 1);
|
|
error_log('adding entry for battery - ' . $battery->getID());
|
|
}
|
|
|
|
$invoice = $this->ic->generateInvoice($crit);
|
|
|
|
// remove previous invoice
|
|
$old_invoice = $jo->getInvoice();
|
|
$this->em->remove($old_invoice);
|
|
$this->em->flush();
|
|
|
|
// save job order
|
|
$jo->setServiceType($service_type);
|
|
|
|
// save invoice
|
|
$jo->setInvoice($invoice);
|
|
$this->em->persist($invoice);
|
|
|
|
// add event log
|
|
$rider = $this->session->getRider();
|
|
$event = new JOEvent();
|
|
$event->setDateHappen(new DateTime())
|
|
->setTypeID(CMBJOEventType::RIDER_EDIT)
|
|
->setJobOrder($jo)
|
|
->setRider($rider);
|
|
$this->em->persist($event);
|
|
|
|
$this->em->flush();
|
|
// TODO: send mqtt event (?)
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function generateInvoice(Request $req)
|
|
{
|
|
$required_params = ['jo_id'];
|
|
$data = $this->checkActiveJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Invoice Generation';
|
|
return $data;
|
|
}
|
|
|
|
$inv = $jo->getInvoice();
|
|
$promo = $inv->getPromo();
|
|
|
|
// invoice items
|
|
$inv_items = [];
|
|
foreach ($inv->getItems() as $item)
|
|
{
|
|
// if more than 1, split it into one of each of the same item
|
|
$item_qty = $item->getQuantity();
|
|
for ($i = 0; $i < $item_qty; $i++)
|
|
{
|
|
$item_batt = $item->getBattery();
|
|
if ($item_batt == null)
|
|
$batt_id = null;
|
|
else
|
|
$batt_id = $item_batt->getID();
|
|
|
|
$inv_items[] = [
|
|
'id' => $item->getID(),
|
|
'title' => $item->getTitle(),
|
|
'qty' => 1,
|
|
'price' => $item->getPrice(),
|
|
'batt_id' => $batt_id,
|
|
];
|
|
}
|
|
}
|
|
|
|
// promo
|
|
if ($promo != null)
|
|
{
|
|
$promo_data = [
|
|
'id' => $promo->getID(),
|
|
'name' => $promo->getName(),
|
|
'code' => $promo->getCode(),
|
|
'discount_rate' => $promo->getDiscountRate(),
|
|
'discount_apply' => $promo->getDiscountApply(),
|
|
];
|
|
}
|
|
else
|
|
{
|
|
$promo_data = null;
|
|
}
|
|
|
|
$trade_in_type = $jo->getTradeInType();
|
|
if (empty($trade_in_type))
|
|
$trade_in_type = 'none';
|
|
|
|
$data = [
|
|
'invoice' => [
|
|
'id' => $inv->getID(),
|
|
'discount' => $inv->getDiscount(),
|
|
'trade_in' => $inv->getTradeIn(),
|
|
'total_price' => $inv->getTotalPrice(),
|
|
'vat' => $inv->getVat(),
|
|
'items' => $inv_items,
|
|
'trade_in_type' => $trade_in_type,
|
|
'promo' => $promo_data,
|
|
]
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function startJobOrder(Request $req)
|
|
{
|
|
$required_params = ['jo_id'];
|
|
$data = $this->checkActiveJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Job Order Start';
|
|
return $data;
|
|
}
|
|
|
|
// set jo status to in progress
|
|
$jo->setStatus(JOStatus::IN_PROGRESS);
|
|
|
|
// add event log
|
|
$rider = $this->session->getRider();
|
|
$event = new JOEvent();
|
|
$event->setDateHappen(new DateTime())
|
|
->setTypeID(CMBJOEventType::RIDER_START)
|
|
->setJobOrder($jo)
|
|
->setRider($rider);
|
|
$this->em->persist($event);
|
|
|
|
$this->em->flush();
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function completeJobOrder(Request $req)
|
|
{
|
|
$required_params = ['jo_id'];
|
|
$data = $this->checkActiveJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Job Order Completion';
|
|
return $data;
|
|
}
|
|
|
|
// set customer signature
|
|
$jo_extra = $jo->getJOExtra();
|
|
$sig_file = $this->handleFileUpload($req, 'signature');
|
|
if ($sig_file)
|
|
$jo_extra->setCustomerSignature($sig_file);
|
|
|
|
// set email
|
|
$cust_email = $req->request->get('customer_email', '');
|
|
$jo->addMeta('customer_email', $cust_email);
|
|
|
|
|
|
/*
|
|
// set jo status to fulfilled
|
|
$jo->setStatus(JOStatus::FULFILLED);
|
|
*/
|
|
//$jo->fulfill();
|
|
$jo->setStatus(JOStatus::FULFILLED)
|
|
->setDateFulfill(new DateTime());
|
|
|
|
// add event log
|
|
$rider = $this->session->getRider();
|
|
$event = new JOEvent();
|
|
$event->setDateHappen(new DateTime())
|
|
->setTypeID(CMBJOEventType::FULFILL)
|
|
->setJobOrder($jo)
|
|
->setRider($rider);
|
|
$this->em->persist($event);
|
|
|
|
// save to customer vehicle battery record
|
|
$this->jo_handler->updateVehicleBattery($jo);
|
|
|
|
$this->em->flush();
|
|
|
|
// create warranty
|
|
if($this->jo_handler->checkIfNewBattery($jo))
|
|
{
|
|
$serial = null;
|
|
$warranty_class = $jo->getWarrantyClass();
|
|
$first_name = $jo->getCustomer()->getFirstName();
|
|
$last_name = $jo->getCustomer()->getLastName();
|
|
$mobile_number = $jo->getCustomer()->getPhoneMobile();
|
|
|
|
// check if date fulfilled is null
|
|
//if ($jo->getDateFulfill() == null)
|
|
// $date_purchase = $jo->getDateCreate();
|
|
//else
|
|
// $date_purchase = $jo->getDateFulfill();
|
|
|
|
// use date_schedule for warranty expiration computation
|
|
$date_purchase = $jo->getDateSchedule();
|
|
|
|
$plate_number = $this->wh->cleanPlateNumber($jo->getCustomerVehicle()->getPlateNumber());
|
|
|
|
$batt_list = array();
|
|
$invoice = $jo->getInvoice();
|
|
if (!empty($invoice))
|
|
{
|
|
// get battery
|
|
$invoice_items = $invoice->getItems();
|
|
foreach ($invoice_items as $item)
|
|
{
|
|
$battery = $item->getBattery();
|
|
if ($battery != null)
|
|
{
|
|
$batt_list[] = $item->getBattery();
|
|
}
|
|
}
|
|
}
|
|
|
|
$this->wh->createWarranty($serial, $plate_number, $first_name, $last_name, $mobile_number, $batt_list, $date_purchase, $warranty_class);
|
|
}
|
|
|
|
// TODO: Need to verify if needed.
|
|
// send mqtt event (fulfilled)
|
|
$image_url = $req->getScheme() . '://' . $req->getHttpHost() . $req->getBasePath() . '/assets/images/user.gif';
|
|
if ($rider->getImageFile() != null)
|
|
$image_url = $req->getScheme() . '://' . $req->getHttpHost() . $req->getBasePath() . '/uploads/' . $rider->getImageFile();
|
|
|
|
$payload = [
|
|
'event' => 'fulfilled',
|
|
'jo_id' => $jo->getID(),
|
|
'driver_image' => $image_url,
|
|
'driver_name' => $rider->getFullName(),
|
|
'driver_id' => $rider->getID(),
|
|
];
|
|
$this->mclient->sendEvent($jo, $payload);
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function setActiveJobOrder(Request $req)
|
|
{
|
|
$required_params = [
|
|
'jo_id'
|
|
];
|
|
$data = $this->checkJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Set Active Job Order';
|
|
return $data;
|
|
}
|
|
|
|
$rider = $this->session->getRider();
|
|
$rider->setActiveJobOrder($jo);
|
|
|
|
$this->em->persist($rider);
|
|
$this->em->flush();
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function setOdometer(Request $req)
|
|
{
|
|
$required_params = [
|
|
'jo_id',
|
|
'odometer'
|
|
];
|
|
$data = $this->checkActiveJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Set Odometer';
|
|
return $data;
|
|
}
|
|
|
|
$odometer_reading = $req->request->get('odometer');
|
|
|
|
if ($odometer_reading > 999999)
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Set Odometer',
|
|
'error' => 'Odometer cannot be more than 6 figures.',
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
$jo->addMeta('odometer', $odometer_reading);
|
|
|
|
$this->em->flush();
|
|
|
|
return $data;
|
|
}
|
|
|
|
protected function handleFileUpload($req, $name)
|
|
{
|
|
$file = $req->files->get($name);
|
|
if (empty($file))
|
|
return false;
|
|
|
|
$orig_filename = pathinfo($file->getClientOriginalName(), PATHINFO_FILENAME);
|
|
|
|
// generate prefix to assure uniqueness
|
|
$prefix = uniqid() . '_';
|
|
$new_filename = $prefix . $orig_filename . '.' . $file->guessClientExtension();
|
|
|
|
// move to our upload dir
|
|
$dest = $this->upload_dir;
|
|
try
|
|
{
|
|
$file->move($dest, $new_filename);
|
|
}
|
|
catch (FileException $e)
|
|
{
|
|
return false;
|
|
}
|
|
|
|
return $new_filename;
|
|
}
|
|
|
|
public function uploadFinishPhotos(Request $req)
|
|
{
|
|
$required_params = [
|
|
'jo_id',
|
|
];
|
|
$data = $this->checkActiveJO($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Upload Finish Photos';
|
|
return $data;
|
|
}
|
|
|
|
$dest = $this->upload_dir;
|
|
|
|
$img_1_file = $req->files->get('img_1');
|
|
$img_2_file = $req->files->get('img_2');
|
|
$img_3_file = $req->files->get('img_3');
|
|
$img_4_file = $req->files->get('img_4');
|
|
$other_img_files[]= $req->files->get('other_images');
|
|
|
|
if ((empty($img_1_file)) &&
|
|
(empty($img_2_file)) &&
|
|
(empty($img_3_file)) &&
|
|
(empty($img_4_file)))
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Upload Arrive Photos',
|
|
'error' => 'No image files received.'
|
|
];
|
|
return $data;
|
|
}
|
|
else
|
|
{
|
|
$new_img1_filename = '';
|
|
$new_img2_filename = '';
|
|
$new_img3_filename = '';
|
|
$new_img4_filename = '';
|
|
$other_filenames = [];
|
|
|
|
if (!empty($img_1_file))
|
|
{
|
|
$orig_img1_filename = pathinfo($img_1_file->getClientOriginalName(), PATHINFO_FILENAME);
|
|
$new_img1_filename = uniqid() . '-'. $orig_img1_filename . '.' . $img_1_file->guessClientExtension();
|
|
|
|
try
|
|
{
|
|
$img_1_file->move($dest, $new_img1_filename);
|
|
}
|
|
catch (FileException $e)
|
|
{
|
|
$data = [
|
|
'error' => 'Error saving image files.'
|
|
];
|
|
return $data;
|
|
}
|
|
}
|
|
if (!empty($img_2_file))
|
|
{
|
|
$orig_img2_filename = pathinfo($img_2_file->getClientOriginalName(), PATHINFO_FILENAME);
|
|
$new_img2_filename = uniqid() . '-' . $orig_img2_filename . '.' . $img_2_file->guessClientExtension();
|
|
|
|
try
|
|
{
|
|
$img_2_file->move($dest, $new_img2_filename);
|
|
}
|
|
catch (FileException $e)
|
|
{
|
|
$data = [
|
|
'error' => 'Error saving image files.'
|
|
];
|
|
return $data;
|
|
}
|
|
}
|
|
if (!empty($img_3_file))
|
|
{
|
|
$orig_img3_filename = pathinfo($img_3_file->getClientOriginalName(), PATHINFO_FILENAME);
|
|
$new_img3_filename = uniqid() . '-' . $orig_img3_filename . '.' . $img_3_file->guessClientExtension();
|
|
|
|
try
|
|
{
|
|
$img_3_file->move($dest, $new_img3_filename);
|
|
}
|
|
catch (FileException $e)
|
|
{
|
|
$data = [
|
|
'error' => 'Error saving image files.'
|
|
];
|
|
return $data;
|
|
}
|
|
}
|
|
|
|
if (!empty($img_4_file))
|
|
{
|
|
$orig_img4_filename = pathinfo($img_4_file->getClientOriginalName(), PATHINFO_FILENAME);
|
|
$new_img4_filename = uniqid() . '-' . $orig_img4_filename . '.' . $img_4_file->guessClientExtension();
|
|
|
|
try
|
|
{
|
|
$img_4_file->move($dest, $new_img4_filename);
|
|
}
|
|
catch (FileException $e)
|
|
{
|
|
$data = [
|
|
'error' => 'Error saving image files.'
|
|
];
|
|
return $data;
|
|
}
|
|
}
|
|
|
|
foreach ($other_img_files as $other_img_file)
|
|
{
|
|
if (!(empty($other_img_file)))
|
|
{
|
|
foreach($other_img_file as $other_img)
|
|
{
|
|
$orig_other_filename = pathinfo($other_img->getClientOriginalName(), PATHINFO_FILENAME);
|
|
$new_other_filename = uniqid() . '-'. $orig_other_filename . '.' . $other_img->guessClientExtension();
|
|
|
|
$other_filenames[] = $new_other_filename;
|
|
|
|
try
|
|
{
|
|
$other_img->move($dest, $new_other_filename);
|
|
}
|
|
catch (FileException $e)
|
|
{
|
|
$data = [
|
|
'error' => 'Error saving image files.'
|
|
];
|
|
return $data;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
$jo_extra = $jo->getJOExtra();
|
|
if ($jo_extra == null)
|
|
{
|
|
// create JOExtra entity
|
|
$jo_extra = new JOExtra();
|
|
|
|
$jo_extra->setImage1Filename($new_img1_filename);
|
|
$jo_extra->setImage2Filename($new_img2_filename);
|
|
$jo_extra->setImage3Filename($new_img3_filename);
|
|
$jo_extra->setImage4Filename($new_img4_filename);
|
|
|
|
if (empty($other_filenames))
|
|
{
|
|
$jo_extra->clearOtherImages();
|
|
}
|
|
else
|
|
{
|
|
$jo_extra->setOtherImages($other_filenames);
|
|
}
|
|
|
|
$jo->setJOExtra($jo_extra);
|
|
|
|
$this->em->persist($jo_extra);
|
|
}
|
|
else
|
|
{
|
|
$jo_extra->setImage1Filename($new_img1_filename);
|
|
$jo_extra->setImage2Filename($new_img2_filename);
|
|
$jo_extra->setImage3Filename($new_img3_filename);
|
|
$jo_extra->setImage4Filename($new_img4_filename);
|
|
|
|
if (empty($other_filenames))
|
|
{
|
|
$jo_extra->clearOtherImages();
|
|
}
|
|
else
|
|
{
|
|
$jo_extra->setOtherImages($other_filenames);
|
|
}
|
|
}
|
|
|
|
$this->em->flush();
|
|
}
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function getStatus(Request $req)
|
|
{
|
|
$required_params = [];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Get Status';
|
|
return $data;
|
|
}
|
|
|
|
$rider = $this->session->getRider();
|
|
|
|
$rider_status = $rider->isAvailable();
|
|
|
|
$status = 'Offline';
|
|
if ($rider_status)
|
|
$status = 'Online';
|
|
|
|
$data = [
|
|
'status' => $status,
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function getOngoingJobOrder(Request $req)
|
|
{
|
|
$required_params = [];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Get Ongoing Job Order';
|
|
$data['job_order'] = null;
|
|
return $data;
|
|
}
|
|
|
|
// are we logged in?
|
|
if (!$this->session->hasRider())
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Get Ongoing Job Order',
|
|
'error' => 'No logged in rider.',
|
|
'job_order' => null,
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
$rider = $this->session->getRider();
|
|
|
|
// check if we have an active JO
|
|
$jo = $rider->getRiderActiveJobOrder();
|
|
if ($jo == null)
|
|
{
|
|
$data = [
|
|
'title' => 'Failed Get Ongoing Job Order',
|
|
'error' => 'No active job order.',
|
|
'job_order' => null,
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
$jo_data = [];
|
|
// check if JO status is in_progress, in_transit, performed, paid
|
|
switch($jo->getStatus())
|
|
{
|
|
case JOStatus::IN_TRANSIT:
|
|
case JOStatus::IN_PROGRESS:
|
|
case JOStatus::PERFORMED:
|
|
case JOStatus::PAID:
|
|
$jo_data = $this->formatJobOrderData($req, $jo);
|
|
break;
|
|
}
|
|
|
|
$data = [
|
|
'job_order' => $jo_data
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
|
|
public function getPaymentMethods(Request $req)
|
|
{
|
|
$required_params = [];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Get Payment Methods';
|
|
return $data;
|
|
}
|
|
|
|
$data = [
|
|
'payment_methods' => CMBModeOfPayment::getCollection(),
|
|
];
|
|
|
|
return $data;
|
|
|
|
}
|
|
|
|
public function getCancelReasons(Request $req)
|
|
{
|
|
$required_params = [];
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Get Cancel Reasons';
|
|
return $data;
|
|
}
|
|
|
|
$data = [
|
|
'cancel_reasons' => CMBCancelReason::getCollection(),
|
|
];
|
|
|
|
return $data;
|
|
|
|
}
|
|
|
|
public function verifyJobOrder(Request $req)
|
|
{
|
|
$required_params = [
|
|
'jo_id'
|
|
];
|
|
$data = $this->checkJOForVerify($req, $required_params, $jo);
|
|
if (isset($data['error']))
|
|
{
|
|
$data['title'] = 'Failed Verify Job Order';
|
|
return $data;
|
|
}
|
|
|
|
$rider = $this->session->getRider();
|
|
// check if rider is assigned to JO
|
|
if ($jo->getRider() != null)
|
|
{
|
|
if ($rider->getID() != $jo->getRider()->getID())
|
|
{
|
|
$data = [
|
|
'assigned' => false,
|
|
'available' => false,
|
|
];
|
|
return $data;
|
|
}
|
|
}
|
|
|
|
// check if JO status is not fulfilled and not cancelled
|
|
if (($jo->getStatus() == JOStatus::FULFILLED) ||
|
|
($jo->getStatus() == JOStatus::CANCELLED))
|
|
{
|
|
$data = [
|
|
'assigned' => true,
|
|
'available' => false
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
$data = [
|
|
'assigned' => true,
|
|
'available' => true,
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
|
|
protected function checkMissingParameters(Request $req, $params = [])
|
|
{
|
|
$missing = [];
|
|
|
|
// check if parameters are there
|
|
foreach ($params as $param)
|
|
{
|
|
if ($req->getMethod() == 'GET')
|
|
{
|
|
$check = $req->query->get($param);
|
|
if ($check == null)
|
|
$missing[] = $param;
|
|
}
|
|
else if ($req->getMethod() == 'POST')
|
|
{
|
|
$check = $req->request->get($param);
|
|
if ($check == null)
|
|
$missing[] = $param;
|
|
}
|
|
else
|
|
return $params;
|
|
}
|
|
|
|
return $missing;
|
|
}
|
|
|
|
protected function checkParamsAndKey(Request $req, $params)
|
|
{
|
|
$data = [];
|
|
|
|
// check for api_key in query string
|
|
$api_key = $req->query->get('api_key');
|
|
if (empty($api_key))
|
|
{
|
|
$data = [
|
|
'error' => 'Missing API key'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
// check missing parameters
|
|
$missing = $this->checkMissingParameters($req, $params);
|
|
if (count($missing) > 0)
|
|
{
|
|
$miss_string = implode(', ', $missing);
|
|
$data = [
|
|
'error' => 'Missing parameter(s): ' . $miss_string
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
// check api key
|
|
$sess = $this->checkAPIKey($req->query->get('api_key'));
|
|
if ($sess == null)
|
|
{
|
|
$data = [
|
|
'error' => 'Invalid API Key'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
// store session
|
|
$this->session = $sess;
|
|
|
|
return $data;
|
|
}
|
|
|
|
protected function checkAPIKey($api_key)
|
|
{
|
|
// find the api key (session id)
|
|
$session = $this->em->getRepository(RiderSession::class)->find($api_key);
|
|
if ($session == null)
|
|
return null;
|
|
|
|
return $session;
|
|
}
|
|
|
|
protected function checkActiveJO(Request $req, $required_params, &$jo = null)
|
|
{
|
|
// set jo status to in transit
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
return $data;
|
|
|
|
// are we logged in?
|
|
if (!$this->session->hasRider())
|
|
{
|
|
$data = [
|
|
'error' => 'No logged in rider.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
$rider = $this->session->getRider();
|
|
|
|
// check if we have an active JO
|
|
$jo = $rider->getRiderActiveJobOrder();
|
|
if ($jo == null)
|
|
{
|
|
$data = [
|
|
'error' => 'No active job order.'
|
|
];
|
|
return $data;
|
|
}
|
|
$jo_id = '';
|
|
if ($req->getMethod() == 'GET')
|
|
$jo_id = $req->query->get('jo_id');
|
|
else
|
|
$jo_id = $req->request->get('jo_id');
|
|
|
|
// check if the jo_id sent is the same as our active jo
|
|
if ($jo_id != $jo->getID())
|
|
{
|
|
$data = [
|
|
'error' => 'Job order selected is not active job order.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
return $data;
|
|
}
|
|
|
|
protected function checkJO(Request $req, $required_params, &$jo = null)
|
|
{
|
|
// set jo status to in transit
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
return $data;
|
|
|
|
// are we logged in?
|
|
if (!$this->session->hasRider())
|
|
{
|
|
$data = [
|
|
'error' => 'No logged in rider.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
$rider = $this->session->getRider();
|
|
|
|
// get jo
|
|
$jo_id = '';
|
|
if ($req->getMethod() == 'GET')
|
|
$jo_id = $req->query->get('jo_id');
|
|
else
|
|
$jo_id = $req->request->get('jo_id');
|
|
|
|
$jo = $this->em->getRepository(JobOrder::class)->find($jo_id);
|
|
if ($jo == null)
|
|
{
|
|
$data = [
|
|
'error' => 'No job order found.'
|
|
];
|
|
return $data;
|
|
|
|
}
|
|
|
|
// check if rider assigned to jo is our rider
|
|
if ($jo->getRider() == null)
|
|
{
|
|
$data = [
|
|
'error' => 'Job order selected has no rider assigned.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
// check if rider is assigned to JO
|
|
if ($rider->getID() != $jo->getRider()->getID())
|
|
{
|
|
$data = [
|
|
'error' => 'Job order selected is not assigned to rider'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
return $data;
|
|
}
|
|
|
|
protected function checkJOForVerify(Request $req, $required_params, &$jo = null)
|
|
{
|
|
// set jo status to in transit
|
|
$data = $this->checkParamsAndKey($req, $required_params);
|
|
if (isset($data['error']))
|
|
return $data;
|
|
|
|
// are we logged in?
|
|
if (!$this->session->hasRider())
|
|
{
|
|
$data = [
|
|
'error' => 'No logged in rider.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
$rider = $this->session->getRider();
|
|
|
|
// get jo
|
|
$jo_id = '';
|
|
if ($req->getMethod() == 'GET')
|
|
$jo_id = $req->query->get('jo_id');
|
|
else
|
|
$jo_id = $req->request->get('jo_id');
|
|
|
|
$jo = $this->em->getRepository(JobOrder::class)->find($jo_id);
|
|
if ($jo == null)
|
|
{
|
|
$data = [
|
|
'error' => 'No job order found.'
|
|
];
|
|
return $data;
|
|
|
|
}
|
|
|
|
// check if rider assigned to jo is our rider
|
|
if ($jo->getRider() == null)
|
|
{
|
|
$data = [
|
|
'error' => 'Job order selected has no rider assigned.'
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
/*
|
|
// check if rider is assigned to JO
|
|
if ($rider->getID() != $jo->getRider()->getID())
|
|
{
|
|
$data = [
|
|
'error' => 'Job order selected is not assigned to rider'
|
|
];
|
|
return $data;
|
|
} */
|
|
|
|
return $data;
|
|
}
|
|
|
|
protected function debugRequest(Request $req)
|
|
{
|
|
$all = $req->request->all();
|
|
error_log(print_r($all, true));
|
|
}
|
|
|
|
protected function getURLExtraImage(Request $req, $filename)
|
|
{
|
|
// return null if blank filename
|
|
if (strlen(trim($filename)) <= 0)
|
|
return null;
|
|
|
|
return $req->getScheme() . '://' . $req->getHttpHost() . $req->getBasePath() . '/uploads/jo_extra/' . $filename;
|
|
}
|
|
}
|