rgutierrez/resq
1
0
Fork 0
Code Issues 126 Pull requests 49 Projects Releases 4 Packages Wiki Activity Actions

Add hub assignment for advance order job orders. #381

Browse source
This commit is contained in:
Korina Cordero 2020-04-20 13:08:24 +00:00
parent c7af1c1592
commit a7b5bf18ff
1 changed files with 442 additions and 93 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

535
src/Controller/APIController.php
View file

@ -989,117 +989,209 @@ class APIController extends Controller implements LoggedController
$invoice = $ic->generateInvoice($icrit); $invoice = $ic->generateInvoice($icrit);
$jo->setInvoice($invoice); $jo->setInvoice($invoice);
// assign hub and rider // check if advance order
if (($jo->getServiceType() == ServiceType::BATTERY_REPLACEMENT_NEW) || // check for time when request came in
($jo->getServicetype() == ServiceType::BATTERY_REPLACEMENT_WARRANTY)) $request_time_in_int = time();
$start = '17:00';
$end = '08:00';
$start_time = strtotime($start);
$end_time = strtotime($end);
if (($request_time_in_int > $start_time) ||
(($request_time_in_int < $start_time) && ($request_time_in_int < $end_time)))
{ {
// get nearest hub // advance order
// $nearest_hub = $this->findNearestHubWithInventory($jo, $batt, $em, $map_tools, $im); // assign hub and rider
$nearest_hub = $this->findNearestHub($jo, $em, $map_tools); if (($jo->getServiceType() == ServiceType::BATTERY_REPLACEMENT_NEW) ||
($jo->getServicetype() == ServiceType::BATTERY_REPLACEMENT_WARRANTY))
{
// get nearest hub
// $nearest_hub = $this->findNearestHubWithInventory($jo, $batt, $em, $map_tools, $im);
// TODO: when the inventory manager kicks in, create new function that finds the
// the nearest hub with inventory and rider slot
// convert to DateTime
$nearest_hub = $this->findAdvanceNearestHub($jo, $request_time_in_int, $em, $map_tools);
}
else
{
$nearest_hub = $this->findAdvanceNearestHub($jo, $request_time, $em, $map_tools);
}
if (!empty($nearest_hub))
{
$jo->setHub($nearest_hub);
$jo->setStatus(JOStatus::ASSIGNED);
}
$em->persist($jo);
$em->persist($invoice);
// add event log for JO
$event = new JOEvent();
$event->setDateHappen(new DateTime())
->setTypeID(JOEventType::CREATE)
->setJobOrder($jo);
$em->persist($event);
// check JO status
if ($jo->getStatus() == JOStatus::ASSIGNED)
{
// add event logs for hub and rider assignments
$hub_assign_event = new JOEvent();
$hub_assign_event->setDateHappen(new DateTime())
->setTypeID(JOEventType::HUB_ASSIGN)
->setJobOrder($jo);
$em->persist($hub_assign_event);
}
$em->flush();
// make invoice json data
$invoice_data = [
'total_price' => $invoice->getTotalPrice(),
'vat_ex_price' => $invoice->getVATExclusivePrice(),
'vat' => $invoice->getVAT(),
'discount' => $invoice->getDiscount(),
'trade_in' => $invoice->getTradeIn(),
];
$items = $invoice->getItems();
$items_data = [];
foreach ($items as $item)
{
$items_data[] = [
'title' => $item->getTitle(),
'qty' => $item->getQuantity() + 0,
'price' => $item->getPrice() + 0.0,
];
}
$invoice_data['items'] = $items_data;
// make job order data
$data = [
'jo_id' => $jo->getID(),
'invoice' => $invoice_data
];
// set data
$res->setData($data);
} }
else else
{ {
$nearest_hub = $this->findNearestHub($jo, $em, $map_tools); // assign hub and rider
} if (($jo->getServiceType() == ServiceType::BATTERY_REPLACEMENT_NEW) ||
($jo->getServicetype() == ServiceType::BATTERY_REPLACEMENT_WARRANTY))
if (!empty($nearest_hub))
{
// assign rider
$available_riders = $nearest_hub->getAvailableRiders();
if (count($available_riders) > 0)
{ {
$assigned_rider = null; // get nearest hub
if (count($available_riders) > 1) // $nearest_hub = $this->findNearestHubWithInventory($jo, $batt, $em, $map_tools, $im);
{ $nearest_hub = $this->findNearestHub($jo, $em, $map_tools);
// TODO: the setting of riders into an array }
// will no longer be necessary when the contents else
// of randomizeRider changes {
$riders = []; $nearest_hub = $this->findNearestHub($jo, $em, $map_tools);
foreach ($available_riders as $rider)
{
$riders[] = $rider;
}
$assigned_rider = $this->randomizeRider($riders);
}
else
$assigned_rider = $available_riders[0];
$jo->setHub($nearest_hub);
$jo->setRider($assigned_rider);
$jo->setStatus(JOStatus::ASSIGNED);
$assigned_rider->setAvailable(false);
} }
}
$em->persist($jo); if (!empty($nearest_hub))
$em->persist($invoice); {
// assign rider
$available_riders = $nearest_hub->getAvailableRiders();
if (count($available_riders) > 0)
{
$assigned_rider = null;
if (count($available_riders) > 1)
{
// 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;
}
// add event log for JO $assigned_rider = $this->randomizeRider($riders);
$event = new JOEvent(); }
$event->setDateHappen(new DateTime()) else
->setTypeID(JOEventType::CREATE) $assigned_rider = $available_riders[0];
->setJobOrder($jo);
$em->persist($event);
// check JO status $jo->setHub($nearest_hub);
if ($jo->getStatus() == JOStatus::ASSIGNED) $jo->setRider($assigned_rider);
{ $jo->setStatus(JOStatus::ASSIGNED);
// add event logs for hub and rider assignments
$hub_assign_event = new JOEvent(); $assigned_rider->setAvailable(false);
$hub_assign_event->setDateHappen(new DateTime()) }
->setTypeID(JOEventType::HUB_ASSIGN) }
$em->persist($jo);
$em->persist($invoice);
// add event log for JO
$event = new JOEvent();
$event->setDateHappen(new DateTime())
->setTypeID(JOEventType::CREATE)
->setJobOrder($jo); ->setJobOrder($jo);
$em->persist($event);
$em->persist($hub_assign_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);
$rider_assign_event = new JOEvent(); $em->persist($hub_assign_event);
$rider_assign_event->setDateHappen(new DateTime())
->setTypeID(JOEventType::RIDER_ASSIGN)
->setJobOrder($jo);
$em->persist($rider_assign_event); $rider_assign_event = new JOEvent();
$rider_assign_event->setDateHappen(new DateTime())
->setTypeID(JOEventType::RIDER_ASSIGN)
->setJobOrder($jo);
// user mqtt event $em->persist($rider_assign_event);
$payload = [
'event' => 'outlet_assign' // user mqtt event
$payload = [
'event' => 'outlet_assign'
];
$mclient->sendEvent($jo, $payload);
$rah->assignJobOrder($jo, $jo->getRider());
}
$em->flush();
// make invoice json data
$invoice_data = [
'total_price' => $invoice->getTotalPrice(),
'vat_ex_price' => $invoice->getVATExclusivePrice(),
'vat' => $invoice->getVAT(),
'discount' => $invoice->getDiscount(),
'trade_in' => $invoice->getTradeIn(),
]; ];
$mclient->sendEvent($jo, $payload); $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;
$rah->assignJobOrder($jo, $jo->getRider()); // make job order data
} $data = [
'jo_id' => $jo->getID(),
$em->flush(); 'invoice' => $invoice_data
// make invoice json data
$invoice_data = [
'total_price' => $invoice->getTotalPrice(),
'vat_ex_price' => $invoice->getVATExclusivePrice(),
'vat' => $invoice->getVAT(),
'discount' => $invoice->getDiscount(),
'trade_in' => $invoice->getTradeIn(),
];
$items = $invoice->getItems();
$items_data = [];
foreach ($items as $item)
{
$items_data[] = [
'title' => $item->getTitle(),
'qty' => $item->getQuantity() + 0,
'price' => $item->getPrice() + 0.0,
]; ];
// set data
$res->setData($data);
} }
$invoice_data['items'] = $items_data;
// make job order data
$data = [
'jo_id' => $jo->getID(),
'invoice' => $invoice_data
];
// set data
$res->setData($data);
return $res->getReturnResponse(); return $res->getReturnResponse();
} }
@ -2464,4 +2556,261 @@ class APIController extends Controller implements LoggedController
return $selected_rider; return $selected_rider;
} }
protected function findAdvanceNearestHub($jo, $request_time, EntityManagerInterface $em, MapTools $map_tools)
{
// get the nearest 10 hubs
$selected_hub = null;
$hubs = $map_tools->getClosestOpenHubs($jo->getCoordinates(), 10);
$nearest_hubs_with_distance = [];
$nearest_branch_codes = [];
foreach ($hubs as $hub)
{
$nearest_hubs_with_distance[] = $hub;
//if (!empty($hub['hub']->getBranchCode()))
// $nearest_branch_codes[] = $hub['hub']->getBranchCode();
}
// check if nearest hubs have branch codes
//if (count($nearest_branch_codes) == 0)
// return $selected_hub;
// assume all 10 have stock
// find the nearest hub with available riders
$nearest = null;
$slot_found = false;
foreach ($nearest_hubs_with_distance as $nhd)
{
if (empty($nearest))
$nearest = $nhd;
else
{
if ($nhd['distance'] < $nearest['distance'])
$nearest = $nhd;
}
$result = $this->findRiderSlots($jo, $nearest['hub'], $request_time, $em);
if ($result != null)
$slot_found = $result['slot_found'];
else
$nearest = null;
}
if ($slot_found && $nearest != null)
{
$result = $this->findRiderSlots($jo, $nearest['hub'], $request_time, $em);
if ($result != null)
{
$jo_date_schedule = $result['date_schedule'];
$jo->setAdvanceOrder(true);
$jo->setDateSchedule($jo_date_schedule);
$selected_hub = $nearest['hub'];
}
}
// uncomment this snippet when inventory check becomes active
// get battery sku
/*
if ($batt != null)
{
$skus[] = $batt->getSAPCode();
// api call to check inventory
// pass the list of branch codes of nearest hubs and the skus
// go through returned list of branch codes
// bypass inventory check for now
// $hubs_with_inventory = $im->getBranchesInventory($nearest_branch_codes, $skus);
if (!empty($hubs_with_inventory))
{
$nearest = [];
$flag_hub_found = false;
foreach ($hubs_with_inventory as $hub_with_inventory)
{
// find hub according to branch code
$found_hub = $em->getRepository(Hub::class)->findOneBy(['branch_code' => $hub_with_inventory['BranchCode']]);
if ($found_hub != null)
{
// check rider availability
if (count($found_hub->getAvailableRiders()) > 0)
{
// check against nearest hubs with distance
foreach ($nearest_hubs_with_distance as $nhd)
{
// get distance of hub from location, compare with $nearest. if less, replace nearest
if ($found_hub->getID() == $nhd['hub']->getID())
{
if (empty($nearest))
{
$nearest = $nhd;
$flag_hub_found = true;
}
else
{
if ($nhd['distance'] < $nearest['distance'])
{
$nearest = $nhd;
$flag_hub_found = true;
}
}
}
}
}
}
}
$selected_hub = $nearest['hub'];
}
} */
return $selected_hub;
}
protected function findRiderSlots($jo, Hub $hub, $request_time, EntityManagerInterface $em)
{
$flag_found_slot = false;
$results = [];
// array of # of riders that can handle JOs in a timeslot
$hub_rider_slots = [];
// populate the array with the hub's rider slots
for ($i = 0; $i <=7; $i++)
{
$hub_rider_slots[$i] = $hub->getRiderSlots();
}
// check hub's advance orders for the day
// get number of advance orders for the next day if request came in before midnight
// or for current day if request came in after midnight
// check request_time
$midnight = strtotime('00:00');
$start_date = new DateTime();
$end_date = new DateTime();
if ($request_time < $midnight)
{
// add +1 to date to start and end date
$start_date->add(new DateInterval('P1D'));
$end_date->add(new DateInterval('P1D'));
}
// set time bounds for the start and end date
$start_date->setTime(0, 1);
$end_date->setTime(23, 59);
$str_request_time = date('Y-m-d H:i:s', $request_time);
$time_of_request = DateTime::createFromFormat('Y-m-d H:i:s', $str_request_time);
// NOTE: get advance orders via query
// get JOs assigned to hub that are advance orders and scheduled for the next day(if before midnight) or current day(if after midnight) with
// for hub assignment status
$query = $em->createQuery('select jo from App\Entity\JobOrder jo where jo.hub = :hub and jo.flag_advance = true and
jo.date_schedule >= :date_start and jo.date_schedule <= :date_end and jo.status = :status');
$jos_advance_orders = $query->setParameters([
'hub' => $hub,
'date_start' => $start_date,
'date_end' => $end_date,
'status' => JOStatus::ASSIGNED,
])
->getResult();
// check each JO's date_schedule, decrement rider_slots if date schedule falls in that slot
// index - equivalent time
// 0 - 8-9
// 1 - 9-10
// 2 - 10-11
// 3 - 11-12
// 4 - 12 -13
// 5 - 13-14
// 6 - 14-15
// 7 - 15-16
foreach ($jos_advance_orders as $advance_jo)
{
// get time schedule
$date_schedule = $advance_jo->getDateSchedule();
$time_schedule = $date_schedule->format('H');
switch ($time_schedule) {
case '8':
$hub_rider_slots[0]--;
break;
case '9':
$hub_rider_slots[1]--;
break;
case '10':
$hub_rider_slots[2]--;
break;
case '11':
$hub_rider_slots[3]--;
break;
case '12':
$hub_rider_slots[4]--;
break;
case '13':
$hub_rider_slots[5]--;
break;
case '14':
$hub_rider_slots[6]--;
break;
case '15':
$hub_rider_slots[7]--;
break;
default:
error_log('Does not fit in any time slot.');
}
}
// find first free slot
foreach ($hub_rider_slots as $index=>$rider_slot)
{
if ($rider_slot > 0)
{
$flag_found_slot = true;
$jo_date_schedule = $start_date;
switch ($index) {
case '0':
$jo_date_schedule->setTime(8,0);
break;
case '1':
$jo_date_schedule->setTime(9,0);
break;
case '2':
$jo_date_schedule->setTime(10,0);
break;
case '3':
$jo_date_schedule->setTime(11,0);
break;
case '4':
$jo_date_schedule->setTime(12,0);
break;
case '5':
$jo_date_schedule->setTime(13,0);
break;
case '6':
$jo_date_schedule->setTime(14,0);
break;
case '7':
$jo_date_schedule->setTime(15,0);
break;
default:
error_log('Cannot find time slot.');
}
$results = [
'slot_found' => $flag_found_slot,
'date_schedule' => $jo_date_schedule,
];
break;
}
}
return $results;
}
} }