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

Add mqtt send event to fulfilled, cancelled and driver arrived #133

Browse source
This commit is contained in:
Kendrick Chan 2018-06-06 03:26:24 +08:00
parent f4d4a6e3a0
commit fbe6c42e50
1 changed files with 40 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

44
src/Controller/RAPIController.php
View file

@ -24,6 +24,7 @@ use App\Ramcar\TradeInType;
use App\Ramcar\InvoiceStatus; use App\Ramcar\InvoiceStatus;
use App\Service\InvoiceCreator; use App\Service\InvoiceCreator;
use App\Service\MQTTClient;
use App\Entity\RiderSession; use App\Entity\RiderSession;
use App\Entity\Customer; use App\Entity\Customer;
@ -478,14 +479,21 @@ class RAPIController extends Controller
$jo->setStatus(JOStatus::CANCELLED); $jo->setStatus(JOStatus::CANCELLED);
$em->flush(); $em->flush();
// TODO: send mqtt event // send mqtt event
$payload = [
'event' => 'cancelled',
'reason' => 'mobile cancellation',
'jo_id' => $jo->getID(),
];
$mclient->sendEvent($obj, $payload);
// TODO: add event // TODO: add event
return $res->getReturnResponse(); return $res->getReturnResponse();
} }
public function arrive(Request $req) public function arrive(Request $req, MQTTClient $mclient)
{ {
$em = $this->getDoctrine()->getManager(); $em = $this->getDoctrine()->getManager();
$required_params = ['jo_id']; $required_params = ['jo_id'];
@ -499,14 +507,27 @@ class RAPIController extends Controller
$jo->setStatus(JOStatus::IN_PROGRESS); $jo->setStatus(JOStatus::IN_PROGRESS);
$em->flush(); $em->flush();
// TODO: send mqtt event // 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' => $rider->getImage(),
'driver_name' => $rider->getFullName(),
'driver_id' => $rider->getID(),
];
$mclient->sendEvent($jo, $payload);
// TODO: add event // TODO: add event
return $res->getReturnResponse(); return $res->getReturnResponse();
} }
public function payment(Request $req) public function payment(Request $req, MQTTClient $mclient)
{ {
$em = $this->getDoctrine()->getManager(); $em = $this->getDoctrine()->getManager();
$required_params = ['jo_id']; $required_params = ['jo_id'];
@ -522,6 +543,21 @@ class RAPIController extends Controller
$em->flush(); $em->flush();
// send mqtt event (fulfilled)
$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' => 'fulfilled',
'jo_id' => $obj->getID(),
'driver_image' => $image_url,
'driver_name' => $rider->getFullName(),
'driver_id' => $rider->getID(),
];
$mclient->sendEvent($jo, $payload);
// TODO: add event // TODO: add event
return $res->getReturnResponse(); return $res->getReturnResponse();