1765 lines
60 KiB
PHP
1765 lines
60 KiB
PHP
<?php
|
|
|
|
namespace App\Controller\CustomerAppAPI;
|
|
|
|
use Symfony\Component\HttpFoundation\Request;
|
|
use Catalyst\ApiBundle\Component\Response as ApiResponse;
|
|
use CrEOF\Spatial\PHP\Types\Geometry\Point;
|
|
|
|
use App\Service\InvoiceGeneratorInterface;
|
|
use App\Service\MQTTClient;
|
|
use App\Service\MQTTClientApiv2;
|
|
use App\Service\FCMSender;
|
|
use App\Service\RiderTracker;
|
|
use App\Service\GeofenceTracker;
|
|
use App\Service\MapTools;
|
|
use App\Service\InventoryManager;
|
|
use App\Service\RiderAssignmentHandlerInterface;
|
|
use App\Service\PromoLogger;
|
|
use App\Service\HubSelector;
|
|
use App\Service\HubDistributor;
|
|
use App\Service\HubFilterLogger;
|
|
use App\Service\HubFilteringGeoChecker;
|
|
use App\Service\JobOrderManager;
|
|
use App\Service\PriceTierManager;
|
|
use App\Ramcar\ServiceType;
|
|
use App\Ramcar\APIRiderStatus;
|
|
use App\Ramcar\InvoiceCriteria;
|
|
use App\Ramcar\TradeInType;
|
|
use App\Ramcar\JOEventType;
|
|
use App\Ramcar\JOStatus;
|
|
use App\Ramcar\AdvanceOrderSlot;
|
|
use App\Ramcar\TransactionOrigin;
|
|
use App\Ramcar\AutoAssignStatus;
|
|
use App\Ramcar\WarrantyClass;
|
|
use App\Ramcar\HubCriteria;
|
|
use App\Ramcar\DeliveryStatus;
|
|
use App\Entity\Battery;
|
|
use App\Entity\Hub;
|
|
use App\Entity\Promo;
|
|
use App\Entity\JOEvent;
|
|
use App\Entity\Warranty;
|
|
use App\Entity\JobOrder;
|
|
use App\Entity\CustomerVehicle;
|
|
|
|
use DateTime;
|
|
|
|
class JobOrderController extends ApiController
|
|
{
|
|
public function getOngoing(Request $req)
|
|
{
|
|
// validate params
|
|
$validity = $this->validateRequest($req);
|
|
|
|
if (!$validity['is_valid']) {
|
|
return new ApiResponse(false, $validity['error']);
|
|
}
|
|
|
|
// get customer
|
|
$cust = $this->session->getCustomer();
|
|
if ($cust == null) {
|
|
return new ApiResponse(false, 'No customer information found.');
|
|
}
|
|
|
|
/*
|
|
// check if we have an ongoing job order
|
|
$ongoing_jos = $this->em->getRepository(JobOrder::class)->findBy([
|
|
'customer' => $cust,
|
|
'status' => [JOStatus::PENDING, JOStatus::RIDER_ASSIGN, JOStatus::IN_TRANSIT, JOStatus::ASSIGNED, JOStatus::IN_PROGRESS],
|
|
]);
|
|
*/
|
|
$ongoing_jos = $this->getOngoingJobOrders($cust);
|
|
|
|
// initialize data
|
|
$data = [];
|
|
|
|
// no ongoing
|
|
if (count($ongoing_jos) <= 0) {
|
|
$data = [
|
|
'has_ongoing' => false,
|
|
];
|
|
} else {
|
|
$data = [
|
|
'has_ongoing' => true,
|
|
];
|
|
}
|
|
|
|
// response
|
|
return new ApiResponse(true, '', $data);
|
|
}
|
|
|
|
public function getJOInvoice(Request $req)
|
|
{
|
|
// validate params
|
|
$validity = $this->validateRequest($req, [
|
|
'jo_id',
|
|
]);
|
|
|
|
if (!$validity['is_valid']) {
|
|
return new ApiResponse(false, $validity['error']);
|
|
}
|
|
|
|
// get job order
|
|
$jo_id = $req->query->get('jo_id');
|
|
$jo = $this->em->getRepository(JobOrder::class)->find($jo_id);
|
|
if ($jo == null) {
|
|
return new ApiResponse(false, 'No job order found.');
|
|
}
|
|
|
|
// get customer
|
|
$cust = $this->session->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();
|
|
|
|
// make invoice json data
|
|
$data = [
|
|
'total_price' => (float) $invoice->getTotalPrice(),
|
|
'vat_ex_price' => (float) $invoice->getVATExclusivePrice(),
|
|
'vat' => (float) $invoice->getVAT(),
|
|
'discount' => (float) $invoice->getDiscount(),
|
|
'trade_in' => (float) $invoice->getTradeIn(),
|
|
];
|
|
$items = $invoice->getItems();
|
|
$items_data = [];
|
|
foreach ($items as $item) {
|
|
$my_data = [
|
|
'title' => $item->getTitle(),
|
|
'qty' => (int) $item->getQuantity() + 0,
|
|
'price' => (float) $item->getPrice() + 0.0,
|
|
];
|
|
|
|
$item_batt = $item->getBattery();
|
|
if ($item_batt != null) {
|
|
$my_data['image_url'] = $this->getBatteryImageURL($req, $item_batt);
|
|
}
|
|
|
|
$items_data[] = $my_data;
|
|
}
|
|
|
|
$data['items'] = $items_data;
|
|
|
|
/*
|
|
// invoice items
|
|
$inv_items = [];
|
|
foreach ($inv->getItems() as $item)
|
|
{
|
|
$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' => $item->getQuantity(),
|
|
'price' => $item->getPrice(),
|
|
'batt_id' => $batt_id,
|
|
];
|
|
}
|
|
|
|
$data = [
|
|
'invoice' => [
|
|
'discount' => $inv->getDiscount(),
|
|
'trade_in' => $inv->getTradeIn(),
|
|
'total_price' => $inv->getTotalPrice(),
|
|
'vat' => $inv->getVat(),
|
|
'items' => $inv_items,
|
|
],
|
|
];
|
|
|
|
*/
|
|
|
|
// response
|
|
return new ApiResponse(true, '', $data);
|
|
}
|
|
|
|
public function cancelJobOrder(Request $req, MQTTClient $mclient)
|
|
{
|
|
// validate params
|
|
$validity = $this->validateRequest($req, [
|
|
'jo_id',
|
|
'reason',
|
|
]);
|
|
|
|
if (!$validity['is_valid']) {
|
|
return new ApiResponse(false, $validity['error']);
|
|
}
|
|
|
|
// get job order
|
|
$jo_id = $req->request->get('jo_id');
|
|
$jo = $this->em->getRepository(JobOrder::class)->find($jo_id);
|
|
if ($jo == null) {
|
|
return new ApiResponse(false, 'No job order found.');
|
|
}
|
|
|
|
// get customer
|
|
$cust = $this->session->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.');
|
|
}
|
|
|
|
// TODO: check job order status, if it's cancellable
|
|
$cancel_reason = $req->request->get('reason');
|
|
|
|
$jo->cancel($cancel_reason);
|
|
|
|
// add event log
|
|
$event = new JOEvent();
|
|
$event->setDateHappen(new DateTime())
|
|
->setTypeID(JOEventType::CANCEL)
|
|
->setJobOrder($jo);
|
|
$this->em->persist($event);
|
|
|
|
$this->em->flush();
|
|
|
|
// send mobile app event
|
|
$payload = [
|
|
'event' => 'cancelled',
|
|
'reason' => $cancel_reason,
|
|
'jo_id' => $jo->getID(),
|
|
];
|
|
// $mclient->sendEvent($jo, $payload);
|
|
$mclient->sendRiderEvent($jo, $payload);
|
|
|
|
// response
|
|
return new ApiResponse();
|
|
}
|
|
|
|
// we can't use param converter for now because we want to output the proper 404
|
|
public function getJobOrderInfo($id, Request $req, RiderTracker $rt)
|
|
{
|
|
// validate params
|
|
$validity = $this->validateRequest($req);
|
|
|
|
if (!$validity['is_valid']) {
|
|
return new ApiResponse(false, $validity['error']);
|
|
}
|
|
|
|
// get customer
|
|
$cust = $this->session->getCustomer();
|
|
if ($cust == null) {
|
|
return new ApiResponse(false, 'No customer information found.');
|
|
}
|
|
|
|
// get job order data
|
|
$jo = $this->em->getRepository(JobOrder::class)->find($id);
|
|
if ($jo == null) {
|
|
return new ApiResponse(false, 'No job order information found.');
|
|
}
|
|
|
|
// check if job order belongs to customer / user
|
|
if ($cust->getID() != $jo->getCustomer()->getID()) {
|
|
return new ApiResponse(false, 'No job order information found.');
|
|
}
|
|
|
|
// put into job order data array
|
|
$jo_data = $this->generateJobOrderData($req, $jo, $rt);
|
|
|
|
// response
|
|
return new ApiResponse(true, '', [
|
|
'job_order' => $jo_data,
|
|
]);
|
|
}
|
|
|
|
public function getJOHistory(Request $req)
|
|
{
|
|
// validate params
|
|
$validity = $this->validateRequest($req);
|
|
|
|
if (!$validity['is_valid']) {
|
|
return new ApiResponse(false, $validity['error']);
|
|
}
|
|
|
|
// get customer
|
|
$cust = $this->session->getCustomer();
|
|
if ($cust == null) {
|
|
return new ApiResponse(false, 'No customer information found.');
|
|
}
|
|
|
|
// get job orders
|
|
$all_jo_data = [];
|
|
// $jos = $cust->getJobOrders();
|
|
// get the fulfilled and cancelled job orders, since ongoing jos are not yet part of history
|
|
$jos = $this->em->getRepository(JobOrder::class)->findBy([
|
|
'customer' => $cust,
|
|
'status' => [JOStatus::CANCELLED, JOStatus::FULFILLED]
|
|
], ['date_schedule' => 'DESC']);
|
|
foreach ($jos as $jo) {
|
|
// NOTE: use generateJobOrderData method, maybe?
|
|
$status = $jo->getStatus();
|
|
|
|
$jo_data = [
|
|
'id' => $jo->getID(),
|
|
'date_create' => $jo->getDateCreate()->format('M d, Y'),
|
|
'service_type' => $jo->getServiceType(),
|
|
'status' => $status,
|
|
];
|
|
|
|
// customer vehicle and warranty
|
|
$cv = $jo->getCustomerVehicle();
|
|
|
|
// get latest warranty using plate number
|
|
$warranty = $this->findWarranty($cv->getPlateNumber());
|
|
|
|
$jo_data['customer_vehicle'] = [
|
|
'id' => $cv->getID(),
|
|
'plate_number' => $cv->getPlateNumber(),
|
|
'warranty' => $warranty,
|
|
];
|
|
|
|
// rider
|
|
$rider = $jo->getRider();
|
|
|
|
// check if jo has rider rating set to true
|
|
$has_rider_rating = $jo->hasRiderRating();
|
|
$rating = 0;
|
|
$comment = '';
|
|
if ($rider != null) {
|
|
$jo_data['rider'] = $rider->getFullName();
|
|
|
|
// find the rider rating if any
|
|
if ($has_rider_rating) {
|
|
$jo_rating = $jo->getRating();
|
|
if ($jo_rating != null) {
|
|
$rating = $jo_rating->getRating();
|
|
|
|
// get comment
|
|
$comment = $jo_rating->getComment();
|
|
}
|
|
}
|
|
}
|
|
|
|
// rider rating for jo
|
|
$jo_data['has_rider_rating'] = $has_rider_rating;
|
|
$jo_data['rider_rating'] = $rating;
|
|
$jo_data['comment'] = $comment;
|
|
|
|
// invoice items
|
|
$items = [];
|
|
$jo_items = $jo->getInvoice()->getItems();
|
|
foreach ($jo_items as $item) {
|
|
$items[] = [
|
|
'id' => $item->getID(),
|
|
'title' => $item->getTitle(),
|
|
'qty' => $item->getQuantity(),
|
|
'price' => $item->getPrice(),
|
|
];
|
|
}
|
|
|
|
$jo_data['items'] = $items;
|
|
|
|
// dates depending on status
|
|
switch ($status) {
|
|
case JOStatus::FULFILLED:
|
|
if ($jo->getDateFulfill() == null)
|
|
$jo_data['date_fulfilled'] = '';
|
|
else
|
|
$jo_data['date_fulfilled'] = $jo->getDateFulfill()->format('M d, Y');
|
|
break;
|
|
case JOStatus::CANCELLED:
|
|
$date_cancel = $jo->getDateCancel();
|
|
if ($date_cancel == null)
|
|
$date_cancel = new DateTime();
|
|
$jo_data['date_cancelled'] = $date_cancel->format('M d, Y');
|
|
break;
|
|
}
|
|
|
|
$all_jo_data[] = $jo_data;
|
|
}
|
|
|
|
// response
|
|
return new ApiResponse(true, '', [
|
|
'job_orders' => $all_jo_data,
|
|
]);
|
|
}
|
|
|
|
public function getLatestJobOrder(Request $req, RiderTracker $rt)
|
|
{
|
|
// validate params
|
|
$validity = $this->validateRequest($req);
|
|
|
|
if (!$validity['is_valid']) {
|
|
return new ApiResponse(false, $validity['error']);
|
|
}
|
|
|
|
// get customer
|
|
$cust = $this->session->getCustomer();
|
|
if ($cust == null) {
|
|
return new ApiResponse(false, 'No customer information found.');
|
|
}
|
|
|
|
// get the latest job order for customer
|
|
$latest_jo = $this->em->getRepository(JobOrder::class)->findOneBy(['customer' => $cust], ['id' => 'DESC']);
|
|
|
|
$jo_data = null;
|
|
if ($latest_jo != null) {
|
|
// TODO: clean the response up to just return what is needed
|
|
$jo_data = $this->generateLatestJobOrderData($req, $latest_jo, $rt);
|
|
}
|
|
|
|
// response
|
|
return new ApiResponse(true, '', [
|
|
'latest_job_order' => $jo_data,
|
|
]);
|
|
}
|
|
|
|
public function getAllOngoingJobOrders(Request $req, RiderTracker $rt)
|
|
{
|
|
// validate params
|
|
$validity = $this->validateRequest($req);
|
|
|
|
if (!$validity['is_valid']) {
|
|
return new ApiResponse(false, $validity['error']);
|
|
}
|
|
|
|
// get customer
|
|
$cust = $this->session->getCustomer();
|
|
if ($cust == null) {
|
|
return new ApiResponse(false, 'No customer information found.');
|
|
}
|
|
|
|
$ongoing_jos = $this->getOngoingJobOrders($cust);
|
|
|
|
// initialize data
|
|
$jo_data = [];
|
|
foreach ($ongoing_jos as $jo) {
|
|
$jo_data[] = $this->generateJobOrderData($req, $jo, $rt);
|
|
}
|
|
|
|
// response
|
|
return new ApiResponse(true, '', [
|
|
'ongoing_job_orders' => $jo_data,
|
|
]);
|
|
}
|
|
|
|
public function getOngoingJobOrderCount(Request $req)
|
|
{
|
|
// validate params
|
|
$validity = $this->validateRequest($req);
|
|
|
|
if (!$validity['is_valid']) {
|
|
return new ApiResponse(false, $validity['error']);
|
|
}
|
|
|
|
// get customer
|
|
$cust = $this->session->getCustomer();
|
|
if ($cust == null) {
|
|
return new ApiResponse(false, 'No customer information found.');
|
|
}
|
|
|
|
$ongoing_jos = $this->getOngoingJobOrders($cust);
|
|
|
|
// response
|
|
return new ApiResponse(true, '', [
|
|
'ongoing_job_order_count' => count($ongoing_jos),
|
|
]);
|
|
}
|
|
|
|
public function newRequestJobOrder(
|
|
Request $req,
|
|
InvoiceGeneratorInterface $ic,
|
|
GeofenceTracker $geo,
|
|
MapTools $map_tools,
|
|
InventoryManager $im,
|
|
MQTTClientApiv2 $mclientv2,
|
|
FCMSender $fcmclient,
|
|
RiderAssignmentHandlerInterface $rah,
|
|
PromoLogger $promo_logger,
|
|
HubSelector $hub_select,
|
|
HubDistributor $hub_dist,
|
|
HubFilterLogger $hub_filter_logger,
|
|
HubFilteringGeoChecker $hub_geofence,
|
|
JobOrderManager $jo_manager,
|
|
PriceTierManager $pt_manager
|
|
) {
|
|
//error_log("CREATING JOB ORDER WITH PARAMS " . print_r($req->request->all(), true));
|
|
|
|
// validate params
|
|
$validity = $this->validateRequest($req, [
|
|
'service_type',
|
|
'cv_id',
|
|
'long',
|
|
'lat',
|
|
'warranty',
|
|
'mode_of_payment',
|
|
]);
|
|
|
|
if (!$validity['is_valid']) {
|
|
return new ApiResponse(false, $validity['error']);
|
|
}
|
|
|
|
// trade in type
|
|
$trade_in_batt = $req->request->get('trade_in_batt');
|
|
$trade_in_type = $req->request->get('trade_in_type', '');
|
|
|
|
// address
|
|
$address = $req->request->get('delivery_address', 'Set by mobile application');
|
|
|
|
// instructions
|
|
$instructions = $req->request->get('delivery_instructions', '');
|
|
|
|
// landmark
|
|
$landmark = $req->request->get('landmark', '');
|
|
|
|
// longitude and latitude
|
|
$long = $req->request->get('long');
|
|
$lat = $req->request->get('lat');
|
|
|
|
// NOTE: had to move this up so we can check for promo before geofence
|
|
// customer
|
|
$cust = $this->session->getCustomer();
|
|
if ($cust == null) {
|
|
return new ApiResponse(false, 'No customer information found.');
|
|
}
|
|
|
|
$is_covered = false;
|
|
// check if customer still has promo
|
|
if (($cust->getCustomerTag('TAG_CAR_CLUB_OFFICER_PROMO')) ||
|
|
($cust->getCustomerTag('TAG_CAR_CLUB_MEMBER_PROMO'))
|
|
) {
|
|
// if has customer tag, customer has not availed of promo
|
|
$is_covered = true;
|
|
} else {
|
|
// geofence
|
|
$is_covered = $geo->isCovered($long, $lat);
|
|
}
|
|
|
|
if (!$is_covered) {
|
|
// TODO: put geofence error message in config file somewhere
|
|
return new ApiResponse(false, $this->getGeoErrorMessage());
|
|
}
|
|
|
|
$hub = null;
|
|
$hub_id = $req->request->get('hub_id');
|
|
// check if hub_id is -1 which means user clicked Book Now before 5 PM
|
|
// but confirmed the order after 5 PM
|
|
if ($hub_id == -1) {
|
|
return new ApiResponse(false, 'Book Now no longer available.');
|
|
}
|
|
if (strlen($hub_id) > 0)
|
|
$hub = $this->em->getRepository(Hub::class)->find($hub_id);
|
|
|
|
$schedule_date = $req->request->get('date_schedule');
|
|
$slot_id = $req->request->get('slot_id');
|
|
|
|
// process the jo date schedule
|
|
$date_schedule = null;
|
|
if ((strlen($schedule_date) > 0) && (strlen($slot_id) > 0)) {
|
|
$time_schedule = $this->getTimeFromSlot($slot_id);
|
|
if (!empty($time_schedule)) {
|
|
$s_date = $schedule_date . ' ' . $time_schedule;
|
|
$date_schedule = DateTime::createFromFormat('Y-m-d H:i', $s_date);
|
|
// error_log($date_schedule->format('Y-m-d H:i'));
|
|
}
|
|
}
|
|
|
|
$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;
|
|
// $flag_advance_order = $advance_order ? true : false;
|
|
|
|
//error_log("RUNNING QUERY NEXT");
|
|
|
|
$jo = new JobOrder();
|
|
$jo->setSource(TransactionOrigin::MOBILE_APP)
|
|
->setStatus(JOStatus::PENDING)
|
|
->setDeliveryInstructions('')
|
|
->setTier1Notes('')
|
|
->setTier2Notes('')
|
|
->setDeliveryAddress($address)
|
|
->setTradeInType($trade_in_type)
|
|
->setDeliveryInstructions($instructions)
|
|
// TODO: error check for valid mode of payment
|
|
->setModeOfPayment($req->request->get('mode_of_payment'))
|
|
->setAdvanceOrder($flag_advance_order)
|
|
->setStatusAutoAssign(AutoAssignStatus::NOT_ASSIGNED)
|
|
->setLandmark($landmark);
|
|
|
|
// customer
|
|
// $cust = $this->session->getCustomer();
|
|
// if ($cust == null)
|
|
// {
|
|
// $res->setError(true)
|
|
// ->setErrorMessage('No customer information found');
|
|
// return $res->getReturnResponse();
|
|
// }
|
|
|
|
// check if customer has more than one job order already
|
|
$flag_cust_new = false;
|
|
|
|
$cust_jo_count = $jo_manager->getCustomerJobOrderCount($cust->getID());
|
|
if ($cust_jo_count <= 1)
|
|
$flag_cust_new = true;
|
|
|
|
$jo->setCustomer($cust);
|
|
$jo->setCustNew($flag_cust_new);
|
|
|
|
// validate service type
|
|
$stype = $req->request->get('service_type');
|
|
if (!ServiceType::validate($stype)) {
|
|
return new ApiResponse(false, 'Invalid service type.');
|
|
}
|
|
$jo->setServiceType($stype);
|
|
|
|
// validate warranty
|
|
$warr = $req->request->get('warranty');
|
|
if (!WarrantyClass::validate($warr)) {
|
|
return new ApiResponse(false, 'Invalid warranty class.');
|
|
}
|
|
$jo->setWarrantyClass($warr);
|
|
|
|
// set coordinates
|
|
$point = new Point($long, $lat);
|
|
$jo->setCoordinates($point);
|
|
|
|
// make invoice criteria
|
|
$icrit = new InvoiceCriteria();
|
|
$icrit->setServiceType($stype);
|
|
|
|
// check promo
|
|
$promo_id = $req->request->get('promo_id');
|
|
if (!empty($promo_id)) {
|
|
$promo = $this->em->getRepository(Promo::class)->find($promo_id);
|
|
if ($promo == null) {
|
|
return new ApiResponse(false, 'Invalid promo id.');
|
|
}
|
|
|
|
// put in criteria
|
|
$icrit->addPromo($promo);
|
|
}
|
|
|
|
//error_log("CONTINUING QUERY BUILDING");
|
|
|
|
// check customer vehicle
|
|
$cv = $this->em->getRepository(CustomerVehicle::class)->find($req->request->get('cv_id'));
|
|
if ($cv == null) {
|
|
return new ApiResponse(false, 'Invalid customer vehicle id.');
|
|
}
|
|
$icrit->setCustomerVehicle($cv);
|
|
$jo->setCustomerVehicle($cv);
|
|
|
|
// check if customer owns vehicle
|
|
if ($cust->getID() != $cv->getCustomer()->getID()) {
|
|
return new ApiResponse(false, 'Customer does not own vehicle.');
|
|
}
|
|
|
|
// check battery
|
|
$batt_id = $req->request->get('batt_id');
|
|
if ($batt_id != null) {
|
|
$batt = $this->em->getRepository(Battery::class)->find($batt_id);
|
|
if ($batt == null) {
|
|
return new ApiResponse(false, 'Invalid battery id.');
|
|
}
|
|
} else
|
|
$batt = null;
|
|
|
|
/*
|
|
// put battery in criteria
|
|
$icrit->addBattery($batt);
|
|
*/
|
|
|
|
// check trade-in
|
|
// only allow motolite, other, none
|
|
switch ($trade_in_type) {
|
|
case TradeInType::MOTOLITE:
|
|
case TradeInType::OTHER:
|
|
break;
|
|
|
|
default:
|
|
$trade_in_type = '';
|
|
break;
|
|
}
|
|
|
|
// add the actual battery item first
|
|
$icrit->addEntry($batt, null, 1);
|
|
|
|
// if we have a trade in, add it as well
|
|
if (!empty($trade_in_type) && !empty($trade_in_batt)) {
|
|
$ti_batt_obj = $this->em->getRepository(Battery::class)->find($trade_in_batt);
|
|
if (!empty($ti_batt_obj)) {
|
|
$icrit->addEntry($ti_batt_obj, $trade_in_type, 1);
|
|
}
|
|
}
|
|
|
|
// set taxable
|
|
$icrit->setIsTaxable();
|
|
|
|
// set JO source
|
|
$icrit->setSource(TransactionOrigin::MOBILE_APP);
|
|
|
|
// set price tier
|
|
$pt_id = $pt_manager->getPriceTier($jo->getCoordinates());
|
|
$icrit->setPriceTier($pt_id);
|
|
|
|
// send to invoice generator
|
|
$invoice = $ic->generateInvoice($icrit);
|
|
$jo->setInvoice($invoice);
|
|
|
|
//error_log("GENERATED INVOICE");
|
|
|
|
// save here first so we have a JO ID which is required for the hub selector
|
|
$this->em->persist($invoice);
|
|
$this->em->persist($jo);
|
|
$this->em->flush();
|
|
|
|
// assign hub and rider
|
|
// check if hub is null
|
|
if ($hub == null) {
|
|
//error_log("NO HUB");
|
|
|
|
// TODO: need to factor out the setting of HubCriteria fields
|
|
$hub_criteria = new HubCriteria();
|
|
$hub_criteria->setPoint($jo->getCoordinates());
|
|
|
|
// set job order info
|
|
$hub_criteria->setJobOrderId($jo->getID())
|
|
->setJoType($jo->getServiceType())
|
|
->setJoOrigin($jo->getSource())
|
|
->setCustomerClass($cust->getCustomerClassification())
|
|
->setOrderDate($jo->getDateCreate())
|
|
->setServiceType($jo->getServiceType());
|
|
|
|
// get distance limit for mobile from env
|
|
// get value of hub_filter_enable from env
|
|
$limit_distance = $_ENV['CUST_DISTANCE_LIMIT'];
|
|
$hub_filter_enabled = $_ENV['HUB_FILTER_ENABLE'];
|
|
|
|
// set distance limit
|
|
$hub_criteria->setLimitDistance($limit_distance);
|
|
|
|
// check if hub filter is enabled. If not, use default values
|
|
// for the rest of the HubCriteria fields
|
|
if ($hub_filter_enabled == 'true') {
|
|
// error_log('hub filter is enabled');
|
|
// check if customer location is in hub filter area
|
|
if ($hub_geofence->isCovered($long, $lat)) {
|
|
// if true, set other values for HubCriteria
|
|
// TODO: set this properly, since the other flags
|
|
// are on default values
|
|
// error_log('Area is covered by hub filtering');
|
|
$hub_criteria->setJoType($jo->getServiceType())
|
|
->setPaymentMethod($jo->getModeOfPayment())
|
|
->setRoundRobin(true);
|
|
}
|
|
}
|
|
|
|
// check if batt is null
|
|
if ($batt != null) {
|
|
// add battery to items
|
|
$sku = $batt->getSAPCode();
|
|
if (!empty($sku))
|
|
$hub_criteria->addItem($batt->getSAPCode(), 1);
|
|
}
|
|
|
|
// get customer id. No JO id at this point
|
|
$customer_id = $cust->getID();
|
|
|
|
$hub_criteria->setCustomerId($customer_id);
|
|
|
|
// set filter flags for inventory and available riders
|
|
$hub_criteria->setInventoryCheck();
|
|
$hub_criteria->setRidersCheck();
|
|
|
|
// find nearest hubs
|
|
$nearest_hubs = $hub_select->find($hub_criteria);
|
|
|
|
if (!empty($nearest_hubs)) {
|
|
// go through the hub list, find the nearest hub
|
|
// with an available rider
|
|
// error_log('found nearest hub ' . $nearest_hub->getID());
|
|
foreach ($nearest_hubs as $nearest_hub) {
|
|
// check if hub can be auto assigned
|
|
// if not, move on to the next hub in the list
|
|
if (($nearest_hub['hub']->isHubAutoAssign())) {
|
|
// check if hub has riders that can be auto assigned
|
|
// if not, move on to the next hub
|
|
if (($nearest_hub['hub']->isRiderAutoAssign())) {
|
|
$available_riders = $nearest_hub['hub']->getAvailableRiders();
|
|
if (count($available_riders) >= 1) {
|
|
$assigned_rider = null;
|
|
if (count($available_riders) == 1) {
|
|
$assigned_rider = $available_riders[0];
|
|
} else {
|
|
// TODO: the setting of riders into an array
|
|
// will no longer be necessary when the contents
|
|
// of randomizeRider changes
|
|
$riders = [];
|
|
foreach ($available_riders as $rider) {
|
|
$riders[] = $rider;
|
|
}
|
|
|
|
$assigned_rider = $this->randomizeRider($riders);
|
|
}
|
|
|
|
$jo->setHub($nearest_hub['hub']);
|
|
$jo->setRider($assigned_rider);
|
|
$jo->setStatus(JOStatus::ASSIGNED);
|
|
$jo->setStatusAutoAssign(AutoAssignStatus::HUB_AND_RIDER_ASSIGNED);
|
|
$jo->setDeliveryStatus(DeliveryStatus::RIDER_ASSIGN);
|
|
|
|
// set date_assigned for job order
|
|
$jo->setDateAssign(new DateTime());
|
|
|
|
$assigned_rider->setAvailable(false);
|
|
|
|
// set rider's current job order
|
|
$assigned_rider->setCurrentJobOrder($jo);
|
|
|
|
// update redis hub_jo_count for hub
|
|
$hub_dist->incrementJoCountForHub($nearest_hub['hub']);
|
|
|
|
// break out of loop
|
|
break;
|
|
} else {
|
|
// we just create the JO and let admin panel handle the hub assignment
|
|
// log hub into hub_filter_log
|
|
$hub_filter_logger->logFilteredHub($nearest_hub['hub'], 'no_available_rider', null, $cust->getID());
|
|
// continue to go through list to find hub with an available rider
|
|
}
|
|
} else {
|
|
// TODO: log hub as cannot be auto rider assigned somewhere
|
|
// assign hub
|
|
// error_log('Rider cannot be auto assigned ' . $nearest_hub['hub']->getID());
|
|
$jo->setHub($nearest_hub['hub']);
|
|
$jo->setStatus(JOStatus::RIDER_ASSIGN);
|
|
$jo->setStatusAutoAssign(AutoAssignStatus::HUB_ASSIGNED);
|
|
|
|
// update redis hub_jo_count for hub
|
|
$hub_dist->incrementJoCountForHub($nearest_hub['hub']);
|
|
|
|
break;
|
|
}
|
|
} else {
|
|
// TODO: log hub as cannot be auto assigned somewhere
|
|
// move to next hub
|
|
error_log('Hub cannot be auto-assigned ' . $nearest_hub['hub']->getID());
|
|
continue;
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
//error_log("HAS HUB: " . $hub->getID());
|
|
|
|
$jo->setHub($hub);
|
|
$jo->setStatus(JOStatus::RIDER_ASSIGN);
|
|
$jo->setStatusAutoAssign(AutoAssignStatus::HUB_ASSIGNED);
|
|
|
|
if ($date_schedule != null)
|
|
$jo->setDateSchedule($date_schedule);
|
|
|
|
// update redis hub_jo_count for hub
|
|
$hub_dist->incrementJoCountForHub($hub);
|
|
}
|
|
|
|
//error_log("DONE SELECTING HUB");
|
|
|
|
// save additional hub related changes
|
|
$this->em->persist($jo);
|
|
|
|
// add event log for JO
|
|
$event = new JOEvent();
|
|
$event->setDateHappen(new DateTime())
|
|
->setTypeID(JOEventType::CREATE)
|
|
->setJobOrder($jo);
|
|
$this->em->persist($event);
|
|
|
|
$this->em->flush();
|
|
|
|
// check JO status
|
|
if ($jo->getStatus() == JOStatus::ASSIGNED) {
|
|
// add event logs for hub and rider assignments
|
|
$hub_assign_event = new JOEvent();
|
|
$hub_assign_event->setDateHappen(new DateTime())
|
|
->setTypeID(JOEventType::HUB_ASSIGN)
|
|
->setJobOrder($jo);
|
|
|
|
$this->em->persist($hub_assign_event);
|
|
|
|
$rider_assign_event = new JOEvent();
|
|
$rider_assign_event->setDateHappen(new DateTime())
|
|
->setTypeID(JOEventType::RIDER_ASSIGN)
|
|
->setJobOrder($jo);
|
|
|
|
$this->em->persist($rider_assign_event);
|
|
|
|
// user mqtt event
|
|
$payload = [
|
|
'event' => 'outlet_assign',
|
|
];
|
|
$mclientv2->sendEvent($jo, $payload);
|
|
$fcmclient->sendJoEvent($jo, "jo_fcm_title_outlet_assign", "jo_fcm_body_outlet_assign");
|
|
|
|
$rah->assignJobOrder($jo, $jo->getRider());
|
|
}
|
|
|
|
if ($jo->getStatus() == JOStatus::RIDER_ASSIGN) {
|
|
// add event logs for hub assignments
|
|
$hub_assign_event = new JOEvent();
|
|
$hub_assign_event->setDateHappen(new DateTime())
|
|
->setTypeID(JOEventType::HUB_ASSIGN)
|
|
->setJobOrder($jo);
|
|
|
|
$this->em->persist($hub_assign_event);
|
|
|
|
// user mqtt event
|
|
$payload = [
|
|
'event' => 'outlet_assign',
|
|
];
|
|
$mclientv2->sendEvent($jo, $payload);
|
|
$fcmclient->sendJoEvent($jo, "jo_fcm_title_outlet_assign", "jo_fcm_body_outlet_assign");
|
|
}
|
|
|
|
$this->em->flush();
|
|
|
|
// make invoice json data
|
|
$invoice_data = [
|
|
'total_price' => $invoice->getTotalPrice(),
|
|
'vat_ex_price' => (float) $invoice->getVATExclusivePrice(),
|
|
'vat' => $invoice->getVAT(),
|
|
'discount' => $invoice->getDiscount(),
|
|
'trade_in' => $invoice->getTradeIn(),
|
|
];
|
|
$items = $invoice->getItems();
|
|
$items_data = [];
|
|
foreach ($items as $item) {
|
|
$items_data[] = [
|
|
'title' => $item->getTitle(),
|
|
'qty' => $item->getQuantity() + 0,
|
|
'price' => $item->getPrice() + 0.0,
|
|
];
|
|
}
|
|
$invoice_data['items'] = $items_data;
|
|
|
|
// need to check for customer tag/promo
|
|
// check service type
|
|
if ($jo->getServiceType() == ServiceType::BATTERY_REPLACEMENT_NEW) {
|
|
$customer = $cv->getCustomer();
|
|
$customer_tags = $customer->getCustomerTagObjects();
|
|
if (!empty($customer_tags)) {
|
|
foreach ($customer_tags as $customer_tag) {
|
|
// TODO: not too comfy with this being hardcoded
|
|
if ($customer_tag->getID() == $invoice->getUsedCustomerTagId()) {
|
|
// remove associated entity
|
|
$customer->removeCustomerTag($customer_tag);
|
|
|
|
// log the availment of promo from customer
|
|
$created_by = $req->query->get('session_key');
|
|
$cust_id = $jo->getCustomer()->getID();
|
|
$cust_fname = $jo->getCustomer()->getFirstName();
|
|
$cust_lname = $jo->getCustomer()->getLastName();
|
|
$jo_id = $jo->getID();
|
|
$invoice_id = $jo->getInvoice()->getID();
|
|
// TODO: check if we store total price of invoice or just the discounted amount
|
|
$amount = $jo->getInvoice()->getTotalPrice();
|
|
$promo_logger->logPromoInfo(
|
|
$created_by,
|
|
$cust_id,
|
|
$cust_fname,
|
|
$cust_lname,
|
|
$jo_id,
|
|
$invoice_id,
|
|
$amount
|
|
);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
//error_log("DONE CREATING JOB ORDER " . $jo->getID());
|
|
|
|
// response
|
|
return new ApiResponse(true, '', [
|
|
'jo_id' => $jo->getID(),
|
|
'invoice' => $invoice_data,
|
|
]);
|
|
}
|
|
|
|
// TODO: remove later
|
|
// mobile app no longer calls this
|
|
public function requestJobOrder(
|
|
Request $req,
|
|
InvoiceGeneratorInterface $ic,
|
|
GeofenceTracker $geo,
|
|
MapTools $map_tools,
|
|
InventoryManager $im,
|
|
MQTTClientApiv2 $mclientv2,
|
|
FCMSender $fcmclient,
|
|
RiderAssignmentHandlerInterface $rah,
|
|
PromoLogger $promo_logger,
|
|
HubSelector $hub_select,
|
|
HubDistributor $hub_dist,
|
|
HubFilterLogger $hub_filter_logger,
|
|
HubFilteringGeoChecker $hub_geofence,
|
|
JobOrderManager $jo_manager,
|
|
PriceTierManager $pt_manager
|
|
) {
|
|
// validate params
|
|
$validity = $this->validateRequest($req, [
|
|
'service_type',
|
|
'cv_id',
|
|
// 'batt_id',
|
|
'long',
|
|
'lat',
|
|
'warranty',
|
|
'mode_of_payment',
|
|
]);
|
|
|
|
if (!$validity['is_valid']) {
|
|
return new ApiResponse(false, $validity['error']);
|
|
}
|
|
|
|
// trade in type
|
|
$trade_in_batt = $req->request->get('trade_in_batt');
|
|
$trade_in_type = $req->request->get('trade_in_type', '');
|
|
|
|
// address
|
|
$address = $req->request->get('delivery_address', 'Set by mobile application');
|
|
|
|
// instructions
|
|
$instructions = $req->request->get('delivery_instructions', '');
|
|
|
|
// longitude and latitude
|
|
$long = $req->request->get('long');
|
|
$lat = $req->request->get('lat');
|
|
|
|
// geofence
|
|
$is_covered = $geo->isCovered($long, $lat);
|
|
if (!$is_covered) {
|
|
// TODO: put geofence error message in config file somewhere
|
|
return new ApiResponse(false, $this->getGeoErrorMessage());
|
|
}
|
|
|
|
$jo = new JobOrder();
|
|
$jo->setSource(TransactionOrigin::MOBILE_APP)
|
|
->setStatus(JOStatus::PENDING)
|
|
->setDeliveryInstructions('')
|
|
->setTier1Notes('')
|
|
->setTier2Notes('')
|
|
->setDeliveryAddress($address)
|
|
->setTradeInType($trade_in_type)
|
|
->setDeliveryInstructions($instructions)
|
|
// TODO: error check for valid mode of payment
|
|
->setModeOfPayment($req->request->get('mode_of_payment'));
|
|
|
|
// customer
|
|
$cust = $this->session->getCustomer();
|
|
if ($cust == null) {
|
|
return new ApiResponse(false, 'No customer information found.');
|
|
}
|
|
|
|
// check if customer has more than one job order already
|
|
$flag_cust_new = false;
|
|
|
|
$cust_jo_count = $jo_manager->getCustomerJobOrderCount($cust->getID());
|
|
if ($cust_jo_count <= 1)
|
|
$flag_cust_new = true;
|
|
|
|
$jo->setCustomer($cust);
|
|
$jo->setCustNew($flag_cust_new);
|
|
|
|
// validate service type
|
|
$stype = $req->request->get('service_type');
|
|
if (!ServiceType::validate($stype)) {
|
|
return new ApiResponse(false, 'Invalid service type.');
|
|
}
|
|
$jo->setServiceType($stype);
|
|
|
|
// validate warranty
|
|
$warr = $req->request->get('warranty');
|
|
if (!WarrantyClass::validate($warr)) {
|
|
return new ApiResponse(false, 'Invalid warranty class.');
|
|
}
|
|
$jo->setWarrantyClass($warr);
|
|
|
|
// set coordinates
|
|
$point = new Point($long, $lat);
|
|
$jo->setCoordinates($point);
|
|
|
|
// make invoice criteria
|
|
$icrit = new InvoiceCriteria();
|
|
$icrit->setServiceType($stype);
|
|
|
|
// check promo
|
|
$promo_id = $req->request->get('promo_id');
|
|
if (!empty($promo_id)) {
|
|
$promo = $this->em->getRepository(Promo::class)->find($promo_id);
|
|
if ($promo == null) {
|
|
return new ApiResponse(false, 'Invalid promo id.');
|
|
}
|
|
|
|
// put in criteria
|
|
$icrit->addPromo($promo);
|
|
}
|
|
|
|
// check customer vehicle
|
|
$cv = $this->em->getRepository(CustomerVehicle::class)->find($req->request->get('cv_id'));
|
|
if ($cv == null) {
|
|
return new ApiResponse(false, 'Invalid customer vehicle id.');
|
|
}
|
|
$icrit->setCustomerVehicle($cv);
|
|
$jo->setCustomerVehicle($cv);
|
|
|
|
// check if customer owns vehicle
|
|
if ($cust->getID() != $cv->getCustomer()->getID()) {
|
|
return new ApiResponse(false, 'Customer does not own vehicle.');
|
|
}
|
|
|
|
// check battery
|
|
$batt_id = $req->request->get('batt_id');
|
|
if ($batt_id != null) {
|
|
$batt = $this->em->getRepository(Battery::class)->find($batt_id);
|
|
if ($batt == null) {
|
|
return new ApiResponse(false, 'Invalid battery id.');
|
|
}
|
|
} else
|
|
$batt = null;
|
|
|
|
/*
|
|
// put battery in criteria
|
|
$icrit->addBattery($batt);
|
|
*/
|
|
|
|
// check trade-in
|
|
// only allow motolite, other, none
|
|
switch ($trade_in_type) {
|
|
case TradeInType::MOTOLITE:
|
|
case TradeInType::OTHER:
|
|
break;
|
|
|
|
default:
|
|
$trade_in_type = '';
|
|
break;
|
|
}
|
|
|
|
// add the actual battery item first
|
|
$icrit->addEntry($batt, null, 1);
|
|
|
|
// if we have a trade in, add it as well
|
|
if (!empty($trade_in_type) && !empty($trade_in_batt)) {
|
|
$ti_batt_obj = $this->em->getRepository(Battery::class)->find($trade_in_batt);
|
|
if (!empty($ti_batt_obj)) {
|
|
$icrit->addEntry($ti_batt_obj, $trade_in_type, 1);
|
|
}
|
|
}
|
|
|
|
// set taxable
|
|
$icrit->setIsTaxable();
|
|
|
|
// set JO source
|
|
$icrit->setSource(TransactionOrigin::MOBILE_APP);
|
|
|
|
// set price tier
|
|
$pt_id = $pt_manager->getPriceTier($jo->getCoordinates());
|
|
$icrit->setPriceTier($pt_id);
|
|
|
|
// send to invoice generator
|
|
$invoice = $ic->generateInvoice($icrit);
|
|
$jo->setInvoice($invoice);
|
|
|
|
// set more hub criteria fields
|
|
$hub_criteria = new HubCriteria();
|
|
$hub_criteria->setPoint($jo->getCoordinates());
|
|
|
|
// get distance limit for mobile from env
|
|
$limit_distance = $_ENV['CUST_DISTANCE_LIMIT'];
|
|
|
|
// set distance limit
|
|
$hub_criteria->setLimitDistance($limit_distance);
|
|
|
|
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);
|
|
}
|
|
|
|
// add battery to items
|
|
$sku = $batt->getSAPCode();
|
|
if (!empty($sku))
|
|
$hub_criteria->addItem($batt->getSAPCode(), 1);
|
|
|
|
// get customer id. No JO id at this point
|
|
$customer_id = $cust->getID();
|
|
|
|
$hub_criteria->setCustomerId($customer_id);
|
|
|
|
// find nearest hubs
|
|
$nearest_hubs = $hub_select->find($hub_criteria);
|
|
|
|
$assigned_rider = null;
|
|
if (!empty($nearest_hubs)) {
|
|
// go through the hub list, find the nearest hub
|
|
// with an available rider
|
|
//error_log('found nearest hub ' . $nearest_hub->getID());
|
|
foreach ($nearest_hubs as $nearest_hub) {
|
|
$available_riders = $nearest_hub['hub']->getAvailableRiders();
|
|
if (count($available_riders) >= 1) {
|
|
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);
|
|
|
|
// set rider's current job order
|
|
$assigned_rider->setCurrentJobOrder($jo);
|
|
|
|
// update redis hub_jo_count for hub
|
|
$hub_dist->incrementJoCountForHub($nearest_hub['hub']);
|
|
|
|
// break out of loop
|
|
break;
|
|
} else {
|
|
// log hub into hub_filter_log
|
|
$hub_filter_logger->logFilteredHub($nearest_hub['hub'], 'no_available_rider', null, $cust->getID());
|
|
// continue to go through list to find hub with an available rider
|
|
}
|
|
}
|
|
}
|
|
|
|
$this->em->persist($jo);
|
|
$this->em->persist($invoice);
|
|
|
|
// add event log for JO
|
|
$event = new JOEvent();
|
|
$event->setDateHappen(new DateTime())
|
|
->setTypeID(JOEventType::CREATE)
|
|
->setJobOrder($jo);
|
|
$this->em->persist($event);
|
|
|
|
// check JO status
|
|
if ($jo->getStatus() == JOStatus::ASSIGNED) {
|
|
// add event logs for hub and rider assignments
|
|
$hub_assign_event = new JOEvent();
|
|
$hub_assign_event->setDateHappen(new DateTime())
|
|
->setTypeID(JOEventType::HUB_ASSIGN)
|
|
->setJobOrder($jo);
|
|
|
|
$this->em->persist($hub_assign_event);
|
|
|
|
$rider_assign_event = new JOEvent();
|
|
$rider_assign_event->setDateHappen(new DateTime())
|
|
->setTypeID(JOEventType::RIDER_ASSIGN)
|
|
->setJobOrder($jo);
|
|
|
|
$this->em->persist($rider_assign_event);
|
|
|
|
// user mqtt event
|
|
$payload = [
|
|
'event' => 'outlet_assign',
|
|
];
|
|
$mclientv2->sendEvent($jo, $payload);
|
|
$fcmclient->sendJoEvent($jo, "jo_fcm_title_outlet_assign", "jo_fcm_body_outlet_assign");
|
|
|
|
$rah->assignJobOrder($jo, $jo->getRider());
|
|
}
|
|
|
|
$this->em->flush();
|
|
|
|
// make invoice json data
|
|
$invoice_data = [
|
|
'total_price' => $invoice->getTotalPrice(),
|
|
'vat_ex_price' => (float) $invoice->getVATExclusivePrice(),
|
|
'vat' => $invoice->getVAT(),
|
|
'discount' => $invoice->getDiscount(),
|
|
'trade_in' => $invoice->getTradeIn(),
|
|
];
|
|
$items = $invoice->getItems();
|
|
$items_data = [];
|
|
foreach ($items as $item) {
|
|
$items_data[] = [
|
|
'title' => $item->getTitle(),
|
|
'qty' => $item->getQuantity() + 0,
|
|
'price' => $item->getPrice() + 0.0,
|
|
];
|
|
}
|
|
$invoice_data['items'] = $items_data;
|
|
|
|
// check service type
|
|
if ($jo->getServiceType() == ServiceType::BATTERY_REPLACEMENT_NEW) {
|
|
$customer = $cv->getCustomer();
|
|
$customer_tags = $customer->getCustomerTagObjects();
|
|
if (!empty($customer_tags)) {
|
|
foreach ($customer_tags as $customer_tag) {
|
|
// TODO: not too comfy with this being hardcoded
|
|
if ($customer_tag->getID() == $invoice->getUsedCustomerTagId()) {
|
|
// remove associated entity
|
|
$customer->removeCustomerTag($customer_tag);
|
|
|
|
// log the availment of promo from customer
|
|
$created_by = $req->query->get('session_key');
|
|
$cust_id = $jo->getCustomer()->getID();
|
|
$cust_fname = $jo->getCustomer()->getFirstName();
|
|
$cust_lname = $jo->getCustomer()->getLastName();
|
|
$jo_id = $jo->getID();
|
|
$invoice_id = $jo->getInvoice()->getID();
|
|
// TODO: check if we store total price of invoice or just the discounted amount
|
|
$amount = $jo->getInvoice()->getTotalPrice();
|
|
$promo_logger->logPromoInfo(
|
|
$created_by,
|
|
$cust_id,
|
|
$cust_fname,
|
|
$cust_lname,
|
|
$jo_id,
|
|
$invoice_id,
|
|
$amount
|
|
);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// response
|
|
return new ApiResponse(true, '', [
|
|
'jo_id' => $jo->getID(),
|
|
'invoice' => $invoice_data,
|
|
]);
|
|
}
|
|
|
|
// commenting it out. Modify the getJOHistory instead to just get the fulfilled
|
|
// and cancelled job orders, since ongoing is not yet part of history
|
|
/*
|
|
public function getCompletedJobOrders(Request $req, EntityManagerInterface $em, RiderTracker $rt)
|
|
{
|
|
// validate params
|
|
$validity = $this->validateRequest($req);
|
|
|
|
if (!$validity['is_valid']) {
|
|
return new ApiResponse(false, $validity['error']);
|
|
}
|
|
|
|
// get customer
|
|
$cust = $this->session->getCustomer();
|
|
if ($cust == null)
|
|
{
|
|
return new ApiResponse(false, 'No customer information found.');
|
|
}
|
|
|
|
$completed_jos = $this->getCompletedJOs($cust);
|
|
|
|
// initialize data
|
|
$jo_data = [];
|
|
foreach ($completed_jos as $jo)
|
|
{
|
|
$jo_data[] = $this->generateJobOrderData($req, $jo, $rt);
|
|
}
|
|
|
|
// response
|
|
return new ApiResponse(true, '', [
|
|
'completed_job_orders' => $jo_data,
|
|
]);
|
|
}
|
|
|
|
protected function getCompletedJOs($cust)
|
|
{
|
|
$completed_jos = $this->em->getRepository(JobOrder::class)->findBy([
|
|
'customer' => $cust,
|
|
'status' => [JOStatus::CANCELLED, JOStatus::FULFILLED],
|
|
], ['date_schedule' => 'desc']);
|
|
|
|
return $completed_jos;
|
|
}
|
|
*/
|
|
|
|
protected function generateJobOrderData($req, $jo, $rt)
|
|
{
|
|
$status = $jo->getStatus();
|
|
|
|
$dest = $jo->getCoordinates();
|
|
|
|
$jo_data = [
|
|
'id' => $jo->getID(),
|
|
'date_create' => $jo->getDateCreate()->format('M d, Y'),
|
|
'date_schedule' => $jo->getDateSchedule()->format('M d, Y H:i'),
|
|
'service_type' => $jo->getServiceType(),
|
|
'destination' => [
|
|
'long' => $dest->getLongitude(),
|
|
'lat' => $dest->getLatitude(),
|
|
],
|
|
'delivery_address' => $jo->getDeliveryAddress(),
|
|
'delivery_instructions' => $jo->getDeliveryInstructions(),
|
|
'landmark' => $jo->getLandmark(),
|
|
'jo_status' => $status,
|
|
'status' => $this->generateAPIRiderStatus($status),
|
|
];
|
|
|
|
// customer vehicle and warranty
|
|
$cv = $jo->getCustomerVehicle();
|
|
|
|
// get latest warranty using plate number
|
|
$warranty = $this->findWarranty($cv->getPlateNumber());
|
|
|
|
$jo_data['customer_vehicle'] = [
|
|
'id' => $cv->getID(),
|
|
'plate_number' => $cv->getPlateNumber(),
|
|
'warranty' => $warranty,
|
|
];
|
|
|
|
// customer information
|
|
$customer = $jo->getCustomer();
|
|
$jo_data['customer'] = [
|
|
'first_name' => $customer->getFirstName(),
|
|
'last_name' => $customer->getLastName(),
|
|
'mobile_number' => $customer->getPhoneMobile(),
|
|
];
|
|
|
|
// rider
|
|
$rider = $jo->getRider();
|
|
if ($rider != null) {
|
|
// default image url
|
|
$url_prefix = $req->getSchemeAndHttpHost();
|
|
$image_url = $url_prefix . '/assets/images/user.gif';
|
|
if ($rider->getImageFile() != null)
|
|
$image_url = $url_prefix . '/uploads/' . $rider->getImageFile();
|
|
|
|
$coord = $rt->getRiderLocation($rider->getID());
|
|
|
|
$jo_data['rider'] = [
|
|
'id' => $rider->getID(),
|
|
'name' => $rider->getFullName(),
|
|
'plate_num' => $rider->getPlateNumber(),
|
|
'contact_num' => $rider->getContactNumber(),
|
|
'curr_rating' => $rider->getCurrentRating(),
|
|
'image_url' => $image_url,
|
|
'location' => [
|
|
'long' => $coord->getLongitude(),
|
|
'lat' => $coord->getLatitude()
|
|
]
|
|
];
|
|
|
|
// check if jo has rider rating set to true
|
|
$has_rider_rating = $jo->hasRiderRating();
|
|
$rating = 0;
|
|
$comment = '';
|
|
if ($rider != null) {
|
|
// find the rider rating if any
|
|
if ($has_rider_rating) {
|
|
$jo_rating = $jo->getRating();
|
|
if ($jo_rating != null) {
|
|
$rating = $jo_rating->getRating();
|
|
|
|
// get comment
|
|
$comment = $jo_rating->getComment();
|
|
}
|
|
}
|
|
}
|
|
|
|
// rider rating for jo
|
|
$jo_data['has_rider_rating'] = $has_rider_rating;
|
|
$jo_data['rider_rating'] = $rating;
|
|
$jo_data['comment'] = $comment;
|
|
} else {
|
|
$jo_data['rider'] = null;
|
|
$jo_data['has_rider_rating'] = null;
|
|
$jo_data['rider_rating'] = null;
|
|
$jo_data['comment'] = 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';
|
|
}
|
|
|
|
protected function generateLatestJobOrderData($req, $jo, $rt)
|
|
{
|
|
$status = $jo->getStatus();
|
|
|
|
$dest = $jo->getCoordinates();
|
|
|
|
$jo_data = [
|
|
'id' => $jo->getID(),
|
|
'date_create' => $jo->getDateCreate()->format('M d, Y'),
|
|
'service_type' => $jo->getServiceType(),
|
|
'destination' => [
|
|
'long' => $dest->getLongitude(),
|
|
'lat' => $dest->getLatitude(),
|
|
],
|
|
'delivery_address' => $jo->getDeliveryAddress(),
|
|
'delivery_instructions' => $jo->getDeliveryInstructions(),
|
|
'jo_status' => $status,
|
|
'status' => $this->generateAPIRiderStatus($status),
|
|
'landmark' => $jo->getLandmark(),
|
|
];
|
|
|
|
// customer vehicle and warranty
|
|
$cv = $jo->getCustomerVehicle();
|
|
|
|
// get latest warranty using plate number
|
|
$warranty = $this->findWarranty($cv->getPlateNumber());
|
|
|
|
$jo_data['customer_vehicle'] = [
|
|
'id' => $cv->getID(),
|
|
'plate_number' => $cv->getPlateNumber(),
|
|
'warranty' => $warranty,
|
|
];
|
|
|
|
// customer information
|
|
$customer = $jo->getCustomer();
|
|
$jo_data['customer'] = [
|
|
'first_name' => $customer->getFirstName(),
|
|
'last_name' => $customer->getLastName(),
|
|
'mobile_number' => $customer->getPhoneMobile(),
|
|
];
|
|
|
|
// rider
|
|
$rider = $jo->getRider();
|
|
if ($rider != null) {
|
|
// default image url
|
|
$url_prefix = $req->getSchemeAndHttpHost();
|
|
$image_url = $url_prefix . '/assets/images/user.gif';
|
|
if ($rider->getImageFile() != null)
|
|
$image_url = $url_prefix . '/uploads/' . $rider->getImageFile();
|
|
|
|
$coord = $rt->getRiderLocation($rider->getID());
|
|
|
|
$jo_data['rider'] = [
|
|
'id' => $rider->getID(),
|
|
'name' => $rider->getFullName(),
|
|
'plate_num' => $rider->getPlateNumber(),
|
|
'contact_num' => $rider->getContactNumber(),
|
|
'image_url' => $image_url,
|
|
'location' => [
|
|
'long' => $coord->getLongitude(),
|
|
'lat' => $coord->getLatitude()
|
|
]
|
|
];
|
|
} else {
|
|
$jo_data['rider'] = null;
|
|
}
|
|
|
|
// invoice items
|
|
$items = [];
|
|
$jo_items = $jo->getInvoice()->getItems();
|
|
foreach ($jo_items as $item) {
|
|
$items[] = [
|
|
'id' => $item->getID(),
|
|
'title' => $item->getTitle(),
|
|
'qty' => $item->getQuantity(),
|
|
'price' => $item->getPrice(),
|
|
];
|
|
}
|
|
|
|
$jo_data['items'] = $items;
|
|
|
|
|
|
// dates depending on status
|
|
switch ($status) {
|
|
case JOStatus::FULFILLED:
|
|
if ($jo->getDateFulfill() == null)
|
|
$jo_data['date_fulfilled'] = '';
|
|
else
|
|
$jo_data['date_fulfilled'] = $jo->getDateFulfill()->format('M d, Y');
|
|
break;
|
|
case JOStatus::CANCELLED:
|
|
$date_cancel = $jo->getDateCancel();
|
|
if ($date_cancel == null)
|
|
$date_cancel = new DateTime();
|
|
$jo_data['date_cancelled'] = $date_cancel->format('M d, Y');
|
|
break;
|
|
}
|
|
|
|
return $jo_data;
|
|
}
|
|
|
|
protected function findWarranty($plate_number)
|
|
{
|
|
// NOTE: Modify the search for the latest warranty. This seems hacky.
|
|
// get latest warranty using plate number
|
|
$warranty_results = $this->em->getRepository(Warranty::class)->findBy(
|
|
['plate_number' => $plate_number],
|
|
['date_create' => 'desc']
|
|
);
|
|
|
|
$warr = [];
|
|
|
|
// check if warranty_results is empty
|
|
if (empty($warranty_results)) {
|
|
/*
|
|
$res->setError(true)
|
|
->setErrorMessage('No warranty found for plate number');
|
|
return $res->getReturnResponse();
|
|
*/
|
|
|
|
return $warr;
|
|
}
|
|
|
|
// get first entry
|
|
$warranty = current($warranty_results);
|
|
|
|
// check for null values for battery and date claim and date expire
|
|
$batt_model = '';
|
|
$batt_size = '';
|
|
$sap_batt = '';
|
|
$claim_date = '';
|
|
$expiry_date = '';
|
|
|
|
if (!(is_null($warranty->getBatteryModel()))) {
|
|
$batt_model = $warranty->getBatteryModel()->getName();
|
|
}
|
|
if (!(is_null($warranty->getBatterySize()))) {
|
|
$batt_size = $warranty->getBatterySize()->getName();
|
|
}
|
|
if (!(is_null($warranty->getSAPBattery()))) {
|
|
$sap_batt = $warranty->getSAPBattery()->getID();
|
|
}
|
|
if (!(is_null($warranty->getDateClaim()))) {
|
|
$claim_date = $warranty->getDateClaim()->format("d M Y");
|
|
}
|
|
if (!(is_null($warranty->getDateExpire()))) {
|
|
$expiry_date = $warranty->getDateExpire()->format("d M Y");
|
|
}
|
|
|
|
$warr[] = [
|
|
'id' => $warranty->getID(),
|
|
'serial' => $warranty->getSerial(),
|
|
'warranty_class' => $warranty->getWarrantyClass(),
|
|
'plate_number' => $warranty->getPlateNumber(),
|
|
'first_name' => $warranty->getFirstName(),
|
|
'last_name' => $warranty->getLastName(),
|
|
'mobile_number' => $warranty->getMobileNumber(),
|
|
'battery_model' => $batt_model,
|
|
'battery_size' => $batt_size,
|
|
'sap_battery' => $sap_batt,
|
|
'status' => $warranty->getStatus(),
|
|
'date_create' => $warranty->getDateCreate()->format("d M Y g:i A"),
|
|
'date_purchase' => $warranty->getDatePurchase()->format("d M Y"),
|
|
'date_expire' => $expiry_date,
|
|
'date_claim' => $claim_date,
|
|
'claim_from' => $warranty->getClaimedFrom(),
|
|
'is_activated' => $warranty->isActivated() ? 1 : 0,
|
|
];
|
|
|
|
return $warr;
|
|
}
|
|
|
|
protected function getTimeFromSlot($slot_id)
|
|
{
|
|
$time_selected = '';
|
|
|
|
switch ($slot_id) {
|
|
case '08_09':
|
|
$time_selected = AdvanceOrderSlot::_08_09;
|
|
break;
|
|
case '09_10':
|
|
$time_selected = AdvanceOrderSlot::_09_10;
|
|
break;
|
|
case '10_11':
|
|
$time_selected = AdvanceOrderSlot::_10_11;
|
|
break;
|
|
case '11_12':
|
|
$time_selected = AdvanceOrderSlot::_11_12;
|
|
break;
|
|
case '12_13':
|
|
$time_selected = AdvanceOrderSlot::_12_13;
|
|
break;
|
|
case '13_14':
|
|
$time_selected = AdvanceOrderSlot::_13_14;
|
|
break;
|
|
case '14_15':
|
|
$time_selected = AdvanceOrderSlot::_14_15;
|
|
break;
|
|
case '15_16':
|
|
$time_selected = AdvanceOrderSlot::_15_16;
|
|
break;
|
|
case '16_17':
|
|
$time_selected = AdvanceOrderSlot::_16_17;
|
|
break;
|
|
default:
|
|
error_log('Invalid slot id ' . $slot_id);
|
|
}
|
|
|
|
return $time_selected;
|
|
}
|
|
|
|
protected function randomizeRider($riders)
|
|
{
|
|
// TODO: get redis to track the sales per rider per day
|
|
// check the time they came in
|
|
// for now, randomize the rider
|
|
$selected_index = array_rand($riders);
|
|
|
|
$selected_rider = $riders[$selected_index];
|
|
|
|
return $selected_rider;
|
|
}
|
|
}
|