centralize izyim exchange

This commit is contained in:
JiaSheng
2023-11-19 17:10:33 +08:00
parent d8a4510fc4
commit aca665f580
33 changed files with 1024 additions and 11 deletions
@@ -7,6 +7,7 @@ use App\Classes\General\Abstracts\AbstractControllerLogic;
use App\Classes\Modules\Accounts\Processors\AuthenticationProcessor;
use App\Classes\Modules\Accounts\Processors\CreateUserProcessor;
use App\Classes\Modules\Accounts\Processors\GenerateEmailVerificationAttemptProcessor;
use App\Classes\Modules\Accounts\Processors\RegisterOnShippingProcessor;
use App\Classes\Modules\Companies\Processors\AssignEmployeeProcessor;
use App\Classes\Modules\Companies\Processors\AssignSegmentProcessor;
use App\Classes\Modules\Companies\Processors\CreateCompanyProcessor;
@@ -21,6 +22,7 @@ use App\Classes\ValueObjects\Constants\BusinessType;
use App\Classes\ValueObjects\Constants\CompanyType;
use App\Classes\ValueObjects\Constants\RoleTypes;
use App\Classes\Jobs\CreatePerfexCRMCustomer;
use App\Classes\Modules\Companies\Services\ConnectCompanyToShippingCompanyModule;
use App\Classes\Modules\Segments\DataTransferObjects\SeasonalSegmentObject;
use App\Models\Company;
use App\Models\Segment;
@@ -30,6 +32,7 @@ use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\App;
use App\Classes\Modules\Segments\Services\CreatesSeasonalSegment;
use Illuminate\Support\Facades\Log;
class CreateCustomerLogic extends AbstractControllerLogic
{
@@ -77,6 +80,12 @@ class CreateCustomerLogic extends AbstractControllerLogic
/** @var CreateVoucherProcessor */
private $createVoucherProcessor;
/** @var RegisterOnShippingProcessor */
private $registerOnShippingProcessor;
/** @var ConnectCompanyToShippingCompanyModule */
private $connectCompanyToShippingCompanyModule;
/**
* CreateCustomerLogic constructor.
* @param CreateUserProcessor $createUserProcessor
@@ -90,9 +99,11 @@ class CreateCustomerLogic extends AbstractControllerLogic
* @param CheckMilestonesForRewardProcessor $checkMilestonesForRewardProcessor
* @param NewCustomerToVoucherifyProcessor $newCustomerToVoucherifyProcessor
* @param CreateVoucherProcessor $createVoucherProcessor
* @param RegisterOnShippingProcessor $registerOnShippingProcessor
* @param ConnectCompanyToShippingCompanyModule $connectCompanyToShippingCompanyModule
*/
public function __construct(CreateUserProcessor $createUserProcessor, CreateCompanyProcessor $createCompanyProcessor, CreateContactProcessor $createContactProcessor, AssignEmployeeProcessor $assignEmployeeProcessor, AssignSegmentProcessor $assignSegmentProcessor, AuthenticationProcessor $authenticationProcessor, GenerateEmailVerificationAttemptProcessor $generateEmailVerificationAttemptProcessor,
CreatesSeasonalSegment $createsSeasonalSegment, CheckMilestonesForRewardProcessor $checkMilestonesForRewardProcessor, NewCustomerToVoucherifyProcessor $newCustomerToVoucherifyProcessor, CreateVoucherProcessor $createVoucherProcessor)
CreatesSeasonalSegment $createsSeasonalSegment, CheckMilestonesForRewardProcessor $checkMilestonesForRewardProcessor, NewCustomerToVoucherifyProcessor $newCustomerToVoucherifyProcessor, CreateVoucherProcessor $createVoucherProcessor, RegisterOnShippingProcessor $registerOnShippingProcessor, ConnectCompanyToShippingCompanyModule $connectCompanyToShippingCompanyModule)
{
$this->createUserProcessor = $createUserProcessor;
$this->createCompanyProcessor = $createCompanyProcessor;
@@ -105,6 +116,8 @@ class CreateCustomerLogic extends AbstractControllerLogic
$this->checkMilestonesForRewardProcessor = $checkMilestonesForRewardProcessor;
$this->newCustomerToVoucherifyProcessor = $newCustomerToVoucherifyProcessor;
$this->createVoucherProcessor = $createVoucherProcessor;
$this->registerOnShippingProcessor = $registerOnShippingProcessor;
$this->connectCompanyToShippingCompanyModule = $connectCompanyToShippingCompanyModule;
}
/**
@@ -155,12 +168,25 @@ class CreateCustomerLogic extends AbstractControllerLogic
CreatePerfexCRMCustomer::dispatch($createLeadPerfexCRMObject);
}
$this->generateEmailVerificationAttemptProcessor->execute($user);
// $this->generateEmailVerificationAttemptProcessor->execute($user);
$this->newCustomerToVoucherifyProcessor->execute($company->id, $user, true);
$this->createVoucherProcessor->execute($user, 'WELCOME50%OFF');
$shippingCompanyModuleId = null;
if ($request->input('shipping_company_module_id')) {
$shippingCompanyModuleId = $request->input('shipping_company_module_id');
} else {
// register account on shipping portal
$shippingCompanyModuleId = $this->registerOnShippingProcessor->execute($request, $company->id);
}
if ($shippingCompanyModuleId) {
// create shipping company connection on exchange
$this->connectCompanyToShippingCompanyModule->execute($company->id, $shippingCompanyModuleId);
}
return $this->response($this->authenticationProcessor->execute($request, false));
}
@@ -0,0 +1,43 @@
<?php
namespace App\Classes\Modules\Accounts\Processors;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\App;
use Illuminate\Support\Facades\Log;
class RegisterOnShippingProcessor
{
/**
* @param Request $request
* @return string
* @throws \App\Classes\Exceptions\AccessForbiddenException
* @throws \App\Classes\Exceptions\MalformedRequestException
* @throws \App\Classes\Exceptions\RequestValidationException
*/
public function execute(Request $request, $companyId) {
if (App::environment(['production'])) {
dd("Delete this line before push to production");
$url = 'https://izyim.cief-malaysia.com/api/v1/account/registration';
} else {
$url = 'http://127.0.0.1:8001/api/v1/account/registration';
}
try {
$client = new \GuzzleHttp\Client(['verify' => false]);
$formParams = $request->toArray();
$formParams['exchange_company_id'] = $companyId;
$response = $client->request('POST', $url, ['form_params' => $formParams]);
$body = $response->getBody();
$contents = json_decode($body, true);
$payload = $contents['payload'];
$token = explode('.', $payload['access_token'])[1];
$decodedToken = base64_decode($token);
$shippingUser = json_decode($decodedToken, true)['user'];
return $shippingUser['company_module_id'];
} catch(\GuzzleHttp\Exception\RequestException $exception){
Log::error($exception->getResponse()->getBody()->getContents());
}
}
}
@@ -0,0 +1,79 @@
<?php
namespace App\Classes\Modules\Accounts\Services;
use App\Classes\Exceptions\InternalServerErrorException;
use App\Classes\ValueObjects\Constants\RoleTypes;
use App\Models\Company;
use App\Models\Role;
use App\Models\User;
use Carbon\Carbon;
use Tymon\JWTAuth\JWT;
class GeneratesAuthenticationTokenWithBookingId {
/** @var JWT */
private $builder;
/**
* GeneratesAuthenticationTokenWithBookingId constructor.
* @param JWT $builder
*/
public function __construct(JWT $builder) {
$this->builder = $builder;
}
/**
* @param User $user
* @return string
*/
public function execute(User $user, $bookingId): string {
$this->builder->manager()->setBlacklistEnabled(false);
// generate token for the customer
$this->builder->factory()->setTTL(Carbon::now()->addDay()->timestamp);
// set the claim based on the object
$this->setTokenClaims($user, $bookingId);
return $this->builder->fromUser($user);
}
/**
* @param User $user
*/
private function setTokenClaims(User $user, $bookingId): void {
/** @var Company $company */
$company = $user->company()->first();
$claims = [
'id' => $user->id,
'name' => $user->name,
'email' => $user->email,
'type' => $user->type,
'status' => $user->status
];
if($user->type === RoleTypes::USER) {
/** @var Company $companyModule */
$claims = array_merge($claims, [
'company_id' => $company->id,
'company_name' => $company->name,
'company_marking' => $company->reference,
'booking_id' => $bookingId
]);
}
$this->builder->factory()->customClaims(['user' => $claims]);
$this->builder->factory()->buildClaimsCollection();
}
}
@@ -0,0 +1,56 @@
<?php
namespace App\Classes\Modules\Bookings\ControllersLogic;
use App\Classes\Modules\Bookings\Services\ConnectBookingToShippingOrder;
use App\Classes\Modules\Bookings\Services\FetchesBooking;
use Illuminate\Http\Request;
class ConnectBookingToShippingOrderLogic
{
/**
* @return array
*/
protected function notification():array {
return [
'title' => 'Connect Exchange Booking With Shipping Order',
'message' => 'You have successfully connect Exchange Booking with Shipping Order'
];
}
/** @var FetchesBooking */
private $fetchesBooking;
/** @var ConnectBookingToShippingOrder */
private $connectBookingToShippingOrder;
/**
* ConnectBookingToShippingOrderLogic constructor.
* @param FetchesBooking $fetchesBooking
* @param ConnectBookingToShippingOrder $connectBookingToShippingOrder
*/
public function __construct(FetchesBooking $fetchesBooking, ConnectBookingToShippingOrder $connectBookingToShippingOrder)
{
$this->fetchesBooking = $fetchesBooking;
$this->connectBookingToShippingOrder = $connectBookingToShippingOrder;
}
/**
* @param Request $request
* @return void
* @throws \App\Classes\Exceptions\AccessForbiddenException
* @throws \App\Classes\Exceptions\MalformedRequestException
* @throws \App\Classes\Exceptions\RequestValidationException
*/
public function execute(Request $request)
{
// to make sure the booking is exist
$booking = $this->fetchesBooking->execute(['id' => $request->route('booking_id')]);
$this->connectBookingToShippingOrder->execute($booking, $request->route('shipping_order_id'));
}
}
@@ -0,0 +1,86 @@
<?php
namespace App\Classes\Modules\Bookings\ControllersLogic;
use App\Classes\General\Abstracts\AbstractControllerLogic;
use App\Classes\Modules\Accounts\Services\GeneratesAuthenticationToken;
use App\Classes\Modules\Accounts\Services\GeneratesAuthenticationTokenWithBookingId;
use App\Classes\Modules\Bookings\Services\FetchesBooking;
use App\Classes\Modules\Bookings\Standards\Rules\CanFetchBooking;
use App\Http\Resources\BookingResource;
use App\Models\Booking;
use App\Models\ShippingOrderBooking;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
class TrackBookingShipmentLogic
{
/**
* @return array
*/
protected function notification():array {
return [
'title' => 'Retrieved Shipping Order',
'message' => 'You have successfully retrieved shipping order'
];
}
/** @var CanFetchBooking */
private $canFetchBooking;
/** @var FetchesBooking */
private $fetchesBooking;
/** @var GeneratesAuthenticationToken */
private $generatesAuthenticationToken;
/** @var GeneratesAuthenticationTokenWithBookingId */
private $generatesAuthenticationTokenWithBookingId;
/**
* TrackBookingShipmentLogic constructor.
* @param CanFetchBooking $canFetchBooking
* @param FetchesBooking $fetchesBooking
* @param GeneratesAuthenticationToken $generatesAuthenticationToken
* @param GeneratesAuthenticationTokenWithBookingId $generatesAuthenticationTokenWithBookingId
*/
public function __construct(CanFetchBooking $canFetchBooking, FetchesBooking $fetchesBooking, GeneratesAuthenticationToken $generatesAuthenticationToken, GeneratesAuthenticationTokenWithBookingId $generatesAuthenticationTokenWithBookingId)
{
$this->canFetchBooking = $canFetchBooking;
$this->fetchesBooking = $fetchesBooking;
$this->generatesAuthenticationToken = $generatesAuthenticationToken;
$this->generatesAuthenticationTokenWithBookingId = $generatesAuthenticationTokenWithBookingId;
}
/**
* @param Request $request
* @return void
* @throws \App\Classes\Exceptions\AccessForbiddenException
* @throws \App\Classes\Exceptions\RequestValidationException
*/
public function execute(Request $request)
{
$this->canFetchBooking->passes();
$booking = Booking::where('marking', $request->route('marking'))->first();
$shippingOrder = ShippingOrderBooking::where('booking_id', $booking->id)->first();
$user = Auth::user();
// if booking is connected with shipping order, we want to show the order, therefore exchange booking id is not needed
if ($shippingOrder) {
$token = $this->generatesAuthenticationToken->execute($user);
return redirect("http://127.0.0.1:8001/?exchangeToken={$token}&orderId={$shippingOrder->shipping_order_id}");
} else {
// else create the order for current booking by putting in booking id into token
$token = $this->generatesAuthenticationTokenWithBookingId->execute($user, $booking->id);
return redirect("http://127.0.0.1:8001/?exchangeToken={$token}");
}
}
}
@@ -0,0 +1,25 @@
<?php
namespace App\Classes\Modules\Bookings\Services;
use App\Classes\Exceptions\MalformedRequestException;
use App\Classes\General\Eloquent\AbstractUpdateRecord;
use App\Models\Booking;
use App\Models\ShippingOrderBooking;
class ConnectBookingToShippingOrder extends AbstractUpdateRecord
{
/**
* @param Order $order
* @return \Illuminate\Database\Eloquent\Model
* @throws MalformedRequestException
*/
public function execute(Booking $booking, $shippingOrderId)
{
$model = new ShippingOrderBooking();
$model->booking_id = $booking->id;
$model->shipping_order_id = $shippingOrderId;
return $this->handler($model);
}
}
@@ -16,8 +16,10 @@ use App\Classes\Modules\Documents\Services\ApprovesDocument;
use App\Classes\Modules\Notifications\DataTransferObjects\NotificationObject;
Use App\Classes\Modules\Notifications\Processors\CreateNotificationProcessor;
use App\Classes\General\Interfaces\Notifiable;
use App\Classes\Modules\Companies\Processors\ApproveIdentificationDocumentOnShippingProcessor;
use App\Classes\ValueObjects\Constants\DocumentType;
use App\Models\Document;
use App\Models\ShippingCompanyConnection;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
@@ -52,6 +54,9 @@ class ApproveIdentificationDocumentLogic extends AbstractControllerLogic
/** @var CreateNotificationProcessor */
private $createNotificationProcessor;
/** @var ApproveIdentificationDocumentOnShippingProcessor */
private $approveIdentificationDocumentOnShippingProcessor;
/**
* ApproveIdentificationDocumentLogic constructor.
* @param CanApproveDocument $canApproveDocument
@@ -60,8 +65,9 @@ class ApproveIdentificationDocumentLogic extends AbstractControllerLogic
* @param FetchesDocument $fetchesDocument
* @param UpdatesCompanyStatus $updatesCompanyStatus
* @param CreateNotificationProcessor $createNotificationProcessor
* @param ApproveIdentificationDocumentOnShippingProcessor $approveIdentificationDocumentOnShippingProcessor
*/
public function __construct(CanApproveDocument $canApproveDocument, ApprovesDocument $approvesDocument, RejectsDocument $rejectsDocument, FetchesDocument $fetchesDocument, UpdatesCompanyStatus $updatesCompanyStatus, CreateNotificationProcessor $createNotificationProcessor)
public function __construct(CanApproveDocument $canApproveDocument, ApprovesDocument $approvesDocument, RejectsDocument $rejectsDocument, FetchesDocument $fetchesDocument, UpdatesCompanyStatus $updatesCompanyStatus, CreateNotificationProcessor $createNotificationProcessor, ApproveIdentificationDocumentOnShippingProcessor $approveIdentificationDocumentOnShippingProcessor)
{
$this->canApproveDocument = $canApproveDocument;
$this->approvesDocument = $approvesDocument;
@@ -69,6 +75,7 @@ class ApproveIdentificationDocumentLogic extends AbstractControllerLogic
$this->fetchesDocument = $fetchesDocument;
$this->updatesCompanyStatus = $updatesCompanyStatus;
$this->createNotificationProcessor = $createNotificationProcessor;
$this->approveIdentificationDocumentOnShippingProcessor = $approveIdentificationDocumentOnShippingProcessor;
}
/**
@@ -80,11 +87,17 @@ class ApproveIdentificationDocumentLogic extends AbstractControllerLogic
*/
public function logic(Request $request) : JsonResponse
{
$documentId = $request->route('document_id');
if ($request->route('shipping_company_module_id')) {
$company = ShippingCompanyConnection::where('shipping_company_module_id', $request->route('shipping_company_module_id'))->first()->company;
$documentId = $company->documents()->whereIn('document_type', DocumentType::IDENTIFICATION_DOCUMENTS)->where('status', ApprovalStatus::PENDING_VERIFICATION)->first()->id;
}
$status = $request->route('status');
/** @var Document $document */
$document = $this->fetchesDocument->execute(['id' => $request->route('document_id')]);
$document = $this->fetchesDocument->execute(['id' => $documentId]);
$this->canApproveDocument->passes();
@@ -102,6 +115,12 @@ class ApproveIdentificationDocumentLogic extends AbstractControllerLogic
$this->createNotificationProcessor->execute($object);
// if this request is not calling from shipping portal, then approve the document on shipping portal for this user
$company = $document->owner()->first();
if (!$request->route('shipping_company_module_id') && $company->shippingCompanyConnection()->first()) {
$this->approveIdentificationDocumentOnShippingProcessor->execute($request, $document->owner_id, $status);
}
return $this->resourceResponse(new DocumentResource($document));
}
@@ -4,6 +4,7 @@ namespace App\Classes\Modules\Companies\ControllersLogic;
use App\Classes\General\Abstracts\AbstractControllerLogic;
use App\Classes\Modules\Companies\Processors\CreateIdentificationDocumentOnShippingProcessor;
use App\Classes\Modules\Companies\Services\FetchesCompany;
use App\Classes\Modules\Companies\Services\UpdatesCompanyStatus;
use App\Classes\Modules\Documents\DataTransferObjects\DocumentObject;
@@ -17,8 +18,10 @@ use App\Classes\ValueObjects\Constants\DocumentType;
use App\Classes\ValueObjects\Constants\Milestones;
use App\Models\Company;
use App\Models\Document;
use App\Models\ShippingCompanyConnection;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Log;
class CreateIdentificationDocumentLogic extends AbstractControllerLogic
{
@@ -51,6 +54,9 @@ class CreateIdentificationDocumentLogic extends AbstractControllerLogic
/** @var CheckMilestonesForRewardProcessor */
private $checkMilestonesForRewardProcessor;
/** @var CreateIdentificationDocumentOnShippingProcessor */
private $createIdentificationDocumentOnShippingProcessor;
/**
* CreateIdentificationDocumentLogic constructor.
* @param FetchesCompany $fetchesCompany
@@ -59,8 +65,9 @@ class CreateIdentificationDocumentLogic extends AbstractControllerLogic
* @param UpdatesCompanyStatus $updatesCompanyStatus
* @param NewLeadTaskToPerfexCRMProcessor $newLeadTaskToPerfexCRMProcessor
* @param CheckMilestoneForRewardProcessor $checkMilestonesForRewardProcessor
* @param CreateIdentificationDocumentOnShippingProcessor $createIdentificationDocumentOnShippingProcessor
*/
public function __construct(FetchesCompany $fetchesCompany, CreatesDocument $createsDocument, CreatesFiles $createsFile, UpdatesCompanyStatus $updatesCompanyStatus, NewLeadTaskToPerfexCRMProcessor $newLeadTaskToPerfexCRMProcessor, CheckMilestonesForRewardProcessor $checkMilestonesForRewardProcessor)
public function __construct(FetchesCompany $fetchesCompany, CreatesDocument $createsDocument, CreatesFiles $createsFile, UpdatesCompanyStatus $updatesCompanyStatus, NewLeadTaskToPerfexCRMProcessor $newLeadTaskToPerfexCRMProcessor, CheckMilestonesForRewardProcessor $checkMilestonesForRewardProcessor, CreateIdentificationDocumentOnShippingProcessor $createIdentificationDocumentOnShippingProcessor)
{
$this->fetchesCompany = $fetchesCompany;
$this->createsDocument = $createsDocument;
@@ -68,6 +75,7 @@ class CreateIdentificationDocumentLogic extends AbstractControllerLogic
$this->updatesCompanyStatus = $updatesCompanyStatus;
$this->newLeadTaskToPerfexCRMProcessor = $newLeadTaskToPerfexCRMProcessor;
$this->checkMilestonesForRewardProcessor = $checkMilestonesForRewardProcessor;
$this->createIdentificationDocumentOnShippingProcessor = $createIdentificationDocumentOnShippingProcessor;
}
/**
@@ -78,8 +86,15 @@ class CreateIdentificationDocumentLogic extends AbstractControllerLogic
public function logic(Request $request) : JsonResponse
{
if ($request->route('shipping_company_module_id')) {
$company = ShippingCompanyConnection::where('shipping_company_module_id', $request->route('shipping_company_module_id'))->first()->company;
$companyId = $company->id;
} else {
$companyId = $request->route('id');
}
/** @var Company $company */
$company = $this->fetchesCompany->execute(['id' => $request->route('id')]);
$company = $this->fetchesCompany->execute(['id' => $companyId]);
$object = new DocumentObject($company->type === CompanyType::COMPANY_BUSINESS ?
DocumentType::SSM_REGISTRATION : DocumentType::IDENTITY_CARD, $request->input('files'),
$request->input('identification_no'), ApprovalStatus::PENDING_VERIFICATION, 'identifications');
@@ -94,6 +109,11 @@ class CreateIdentificationDocumentLogic extends AbstractControllerLogic
$this->newLeadTaskToPerfexCRMProcessor->execute($company);
}
// create identification on shipping if this request not coming from shipping
if (!$request->route('shipping_company_module_id') && $company->shippingCompanyConnection()->first()) {
$this->createIdentificationDocumentOnShippingProcessor->execute($request, $company->id);
}
//cief todo: case study 2
// $user = $company->employees()->first();
// $this->checkMilestonesForRewardProcessor->execute($user, [Milestones::MILESTONE_2]);
@@ -0,0 +1,59 @@
<?php
namespace App\Classes\Modules\Companies\ControllersLogic;
use App\Classes\General\Abstracts\AbstractControllerLogic;
use App\Classes\Modules\Companies\Processors\LinkShippingCompanyProcessor;
use App\Classes\Modules\Companies\Services\ConnectCompanyToShippingCompanyModule;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
class LinkShippingCompanyLogic extends AbstractControllerLogic
{
/**
* @return array
*/
protected function notification():array {
return [
'title' => 'Connect Shipping Portal Account',
'message' => 'You have successfully connect your exchange account with your shipping portal account.'
];
}
/** @var LinkShippingCompanyProcessor */
private $linkShippingCompanyProcessor;
/** @var ConnectCompanyToShippingCompanyModule */
private $connectCompanyToShippingCompanyModule;
/**
* FetchCompanyControllersLogic constructor.
* @param LinkShippingCompanyProcessor $linkShippingCompanyProcessor
* @param ConnectCompanyToShippingCompanyModule $connectCompanyToShippingCompanyModule
*/
public function __construct(LinkShippingCompanyProcessor $linkShippingCompanyProcessor, ConnectCompanyToShippingCompanyModule $connectCompanyToShippingCompanyModule)
{
$this->linkShippingCompanyProcessor = $linkShippingCompanyProcessor;
$this->connectCompanyToShippingCompanyModule = $connectCompanyToShippingCompanyModule;
}
/**
* @param Request $request
* @return JsonResponse
* @throws \App\Classes\Exceptions\AccessForbiddenException
* @throws \App\Classes\Exceptions\RequestValidationException
*/
public function logic(Request $request) : JsonResponse
{
$shippingCompanyModuleId = $this->linkShippingCompanyProcessor->execute($request, $request->route('id'));
$this->connectCompanyToShippingCompanyModule->execute($request->route('id'), $shippingCompanyModuleId);
return $this->response([]);
}
}
@@ -0,0 +1,46 @@
<?php
namespace App\Classes\Modules\Companies\Processors;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\App;
use Illuminate\Support\Facades\Log;
class ApproveIdentificationDocumentOnShippingProcessor
{
/**
* @param Request $request
* @return string
* @throws \App\Classes\Exceptions\AccessForbiddenException
* @throws \App\Classes\Exceptions\MalformedRequestException
* @throws \App\Classes\Exceptions\RequestValidationException
*/
public function execute(Request $request, $companyId, $status) {
if (App::environment(['production'])) {
dd("Delete this line before push to production");
$url = "https://izyim.cief-malaysia.com/api/v1/exchange/company/{$companyId}/identification/approval/{$status}";
} else {
$url = "http://127.0.0.1:8001/api/v1/exchange/company/{$companyId}/identification/approval/{$status}";
}
try {
$client = new \GuzzleHttp\Client(['verify' => false]);
$token = $request->bearerToken();
$headers = [
'Authorization' => 'Bearer ' . $token,
'Accept' => 'application/json',
];
$formParams = $request->toArray();
$response = $client->request('PUT', $url, [
'headers' => $headers,
'form_params' => $formParams
]);
$body = $response->getBody();
$contents = json_decode($body, true);
return $contents;
} catch(\GuzzleHttp\Exception\RequestException $exception){
Log::error($exception->getResponse()->getBody()->getContents());
}
}
}
@@ -0,0 +1,46 @@
<?php
namespace App\Classes\Modules\Companies\Processors;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\App;
use Illuminate\Support\Facades\Log;
class CreateIdentificationDocumentOnShippingProcessor
{
/**
* @param Request $request
* @return string
* @throws \App\Classes\Exceptions\AccessForbiddenException
* @throws \App\Classes\Exceptions\MalformedRequestException
* @throws \App\Classes\Exceptions\RequestValidationException
*/
public function execute(Request $request, $companyId) {
if (App::environment(['production'])) {
dd("Delete this line before push to production");
$url = "https://izyim.cief-malaysia.com/api/v1/exchange/company/{$companyId}/identification/create";
} else {
$url = "http://127.0.0.1:8001/api/v1/exchange/company/{$companyId}/identification/create";
}
try {
$client = new \GuzzleHttp\Client(['verify' => false]);
$token = $request->bearerToken();
$headers = [
'Authorization' => 'Bearer ' . $token,
'Accept' => 'application/json',
];
$formParams = $request->toArray();
$response = $client->request('POST', $url, [
'headers' => $headers,
'form_params' => $formParams
]);
$body = $response->getBody();
$contents = json_decode($body, true);
return $contents;
} catch(\GuzzleHttp\Exception\RequestException $exception){
Log::error($exception->getResponse()->getBody()->getContents());
}
}
}
@@ -0,0 +1,51 @@
<?php
namespace App\Classes\Modules\Companies\Processors;
use App\Classes\Exceptions\MalformedRequestException;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\App;
use Illuminate\Support\Facades\Log;
class LinkShippingCompanyProcessor
{
/**
* @param Request $request
* @return array
* @throws \App\Classes\Exceptions\AccessForbiddenException
* @throws \App\Classes\Exceptions\MalformedRequestException
* @throws \App\Classes\Exceptions\RequestValidationException
*/
public function execute(Request $request, $companyId) {
if (App::environment(['production'])) {
dd("Delete this line before push to production");
$url = "https://izyim.cief-malaysia.com/api/v1/exchange/company/{$companyId}/connect";
} else {
$url = "http://127.0.0.1:8001/api/v1/exchange/company/{$companyId}/connect";
}
try {
$client = new \GuzzleHttp\Client(['verify' => false]);
$token = $request->bearerToken();
$headers = [
'Authorization' => 'Bearer ' . $token,
'Accept' => 'application/json',
];
$response = $client->request('POST', $url, [
'headers' => $headers,
'form_params' => [
'email' => $request->input('email'),
'password' => $request->input('password')
]
]);
$body = $response->getBody();
$contents = json_decode($body, true);
$payload = $contents['payload'];
return $payload['shipping_company_module_id'];
} catch(\GuzzleHttp\Exception\RequestException $exception){
throw new MalformedRequestException(json_decode($exception->getResponse()->getBody()->getContents(), true)['message']);
// Log::error($exception->getResponse()->getBody()->getContents());
}
}
}
@@ -0,0 +1,23 @@
<?php
namespace App\Classes\Modules\Companies\Services;
use App\Classes\Exceptions\MalformedRequestException;
use App\Classes\General\Eloquent\AbstractUpdateRecord;
use App\Models\ShippingCompanyConnection;
class ConnectCompanyToShippingCompanyModule extends AbstractUpdateRecord
{
/**
* @return \Illuminate\Database\Eloquent\Model
* @throws MalformedRequestException
*/
public function execute($companyId, $shippingCompanyModuleId)
{
$model = new ShippingCompanyConnection();
$model->company_id = $companyId;
$model->shipping_company_module_id = $shippingCompanyModuleId;
return $this->handler($model);
}
}
@@ -5,6 +5,7 @@ namespace App\Classes\Modules\Documents\Services;
use App\Classes\General\Eloquent\AbstractUpdateRecord;
use App\Classes\ValueObjects\Constants\ApprovalStatus;
use App\Models\Document;
use App\Models\User;
use Carbon\Carbon;
class ApprovesDocument extends AbstractUpdateRecord
@@ -17,8 +18,19 @@ class ApprovesDocument extends AbstractUpdateRecord
*/
public function execute(Document $model)
{
$user = Auth()->user();
// if auth user is null, then this services is calling from shipping
if (!$user) {
$token = explode('.', request()->bearerToken())[1];
$decodedToken = base64_decode($token);
$shippingUser = json_decode($decodedToken, true)['user'];
$user = User::where('email', $shippingUser['email'])->first();
if (!$user) {
$user = User::find(1);
}
}
$model->status = ApprovalStatus::APPROVED;
$model->approver = Auth()->user()->id;
$model->approver = $user->id;
$model->approval_date = Carbon::now();
return $this->handler($model);
@@ -5,6 +5,7 @@ namespace App\Classes\Modules\Documents\Services;
use App\Classes\General\Eloquent\AbstractUpdateRecord;
use App\Classes\ValueObjects\Constants\ApprovalStatus;
use App\Models\Document;
use App\Models\User;
use Carbon\Carbon;
class RejectsDocument extends AbstractUpdateRecord
@@ -17,8 +18,19 @@ class RejectsDocument extends AbstractUpdateRecord
*/
public function execute(Document $model)
{
$user = Auth()->user();
// if auth user is null, then this services is calling from shipping
if (!$user) {
$token = explode('.', request()->bearerToken())[1];
$decodedToken = base64_decode($token);
$shippingUser = json_decode($decodedToken, true)['user'];
$user = User::where('email', $shippingUser['email'])->first();
if (!$user) {
$user = User::find(1);
}
}
$model->status = ApprovalStatus::REJECTED;
$model->approver = Auth()->user()->id;
$model->approver = $user->id;
$model->approval_date = Carbon::now();
return $this->handler($model);
@@ -0,0 +1,19 @@
<?php
namespace App\Http\Controllers\Bookings;
use App\Classes\Modules\Bookings\ControllersLogic\ConnectBookingToShippingOrderLogic;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
class ConnectBookingToShippingOrderController
{
/**
* @param Request $request
* @param ConnectBookingToShippingOrderLogic $logic
* @return void
*/
public function connect(Request $request, ConnectBookingToShippingOrderLogic $logic): void {
$logic->execute($request);
}
}
@@ -0,0 +1,20 @@
<?php
namespace App\Http\Controllers\Bookings;
use App\Classes\Modules\Bookings\ControllersLogic\TrackBookingShipmentLogic;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
class TrackBookingShipmentController
{
/**
* @param Request $request
* @param TrackBookingShipmentLogic $logic
* @return void
*/
public function track(Request $request, TrackBookingShipmentLogic $logic) {
return $logic->execute($request);
}
}
@@ -0,0 +1,20 @@
<?php
namespace App\Http\Controllers\Companies;
use App\Classes\Modules\Companies\ControllersLogic\LinkShippingCompanyLogic;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
class LinkShippingCompanyController
{
/**
* @param Request $request
* @param LinkShippingCompanyLogic $logic
* @return JsonResponse
*/
public function link(Request $request, LinkShippingCompanyLogic $logic): JsonResponse {
return $logic->execute($request);
}
}
+2
View File
@@ -8,6 +8,7 @@ use App\Http\Middleware\EncryptCookies;
use App\Http\Middleware\RedirectIfAuthenticated;
use App\Http\Middleware\TrimStrings;
use App\Http\Middleware\TrustProxies;
use App\Http\Middleware\ValidateShippingToken;
use App\Http\Middleware\ValidateToken;
use App\Http\Middleware\VerifyCsrfToken;
use Illuminate\Foundation\Http\Kernel as HttpKernel;
@@ -76,6 +77,7 @@ class Kernel extends HttpKernel
'throttle' => \Illuminate\Routing\Middleware\ThrottleRequests::class,
'verified' => \Illuminate\Auth\Middleware\EnsureEmailIsVerified::class,
'valid.token' => ValidateToken::class,
'valid.shipping.token' => ValidateShippingToken::class,
'token.check' => \App\Http\Middleware\TokenCheckerMiddleware::class,
];
}
@@ -0,0 +1,57 @@
<?php
namespace App\Http\Middleware;
use App\Classes\Exceptions\AccessUnauthorisedException;
use App\Classes\ValueObjects\Constants\HttpStatus;
use App\Classes\ValueObjects\Response\ApiResponseObject;
use App\Models\ShippingCompanyConnection;
use Closure;
use Exception;
use Illuminate\Support\Facades\Log;
use Tymon\JWTAuth\JWT;
class ValidateShippingToken
{
/** @var JWT */
private $manager;
/**
* ValidateShippingToken constructor.
* @param JWT $manager
*/
public function __construct(JWT $manager)
{
$this->manager = $manager;
}
/**
* Checks if jwt token is valid.
*
* @param \Illuminate\Http\Request $request
* @param \Closure $next
* @return mixed
*/
public function handle($request, Closure $next)
{
try {
$token = explode('.', $this->manager->getToken())[1];
$decodedToken = base64_decode($token);
$shippingUser = json_decode($decodedToken, true)['user'];
if ($shippingUser['type'] === 3) {
$shippingCompanyModuleId = $shippingUser['company_module_id'];
$connection = ShippingCompanyConnection::where("shipping_company_module_id", $shippingCompanyModuleId)->first();
if(!$connection){ throw new AccessUnauthorisedException(); }
}
} catch (Exception $exception) {
return (new ApiResponseObject('Authentication', 'To keep your account secure we need to re-validate your account', HttpStatus::ACCESS_UNAUTHORISED))->handler();
}
return $next($request);
}
}
+2 -1
View File
@@ -35,6 +35,7 @@ class CompanyResource extends JsonResource
return [
'id' => $this->id,
'shipping_company_module_id' => $this->shippingCompanyConnection ? $this->shippingCompanyConnection->shipping_company_module_id : null,
'name' => $this->name,
'reference' => $this->reference,
'debtor' => $this->debtor,
@@ -43,7 +44,7 @@ class CompanyResource extends JsonResource
'status' => (int) $this->status,
'contact' => new ContactResource ($this->when($this->has('contacts'), $this->contacts->first())),
'address' => new AddressResource($this->when($this->has('addresses'), $this->addresses->where('billing', true)->first())),
'employee' => new UserResource(Auth::user()->type === RoleTypes::USER ? $this->employees()->where('email', '=', Auth::user()->email)->first() : $this->employees()->orderBy('id', 'DESC')->first()),
'employee' => new UserResource(Auth::user() && Auth::user()->type === RoleTypes::USER ? $this->employees()->where('email', '=', Auth::user()->email)->first() : $this->employees()->orderBy('id', 'DESC')->first()),
'identification' => new DocumentResource($this->documents->whereIn('document_type', DocumentType::IDENTIFICATION_DOCUMENTS)->first()),
'bookings' => $this->whenLoaded('bookings', $this->bookings()->orderBy('id', 'DESC')->get(), []),
'confirmed_bookings' => $this->bookings()->whereHas('transactions', function ($query){
+9
View File
@@ -9,6 +9,7 @@ use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\Relations\BelongsToMany;
use Illuminate\Database\Eloquent\Relations\HasMany;
use Illuminate\Database\Eloquent\Relations\HasOne;
use Illuminate\Database\Eloquent\Relations\MorphMany;
use Illuminate\Database\Eloquent\SoftDeletes;
use Illuminate\Support\Collection;
@@ -147,6 +148,14 @@ class Company extends AbstractModel implements Documentable
});
}
/**
* @return \Illuminate\Database\Eloquent\Relations\HasOne
**/
public function shippingCompanyConnection(): HasOne
{
return $this->hasOne(ShippingCompanyConnection::class, 'company_id', 'id');
}
}
+31
View File
@@ -0,0 +1,31 @@
<?php
namespace App\Models;
use Illuminate\Database\Eloquent\Relations\BelongsTo;
use Illuminate\Database\Eloquent\SoftDeletes;
/**
* Class ShippingCompanyConnection
* @package App\Models
*
* @property \App\Models\Company company_id
*/
class ShippingCompanyConnection extends AbstractModel
{
use SoftDeletes;
protected $table = 'shipping_company_connections';
protected $dates = ['deleted_at'];
/**
* @return BelongsTo
*/
public function company(): BelongsTo
{
return $this->BelongsTo(Company::class, 'company_id', 'id');
}
}
+31
View File
@@ -0,0 +1,31 @@
<?php
namespace App\Models;
use Illuminate\Database\Eloquent\Relations\BelongsTo;
use Illuminate\Database\Eloquent\SoftDeletes;
/**
* Class ShippingOrderBooking
* @package App\Models
*
* @property \App\Models\Order order_id
*/
class ShippingOrderBooking extends AbstractModel
{
use SoftDeletes;
protected $table = 'shipping_order_bookings';
protected $dates = ['deleted_at'];
/**
* @return BelongsTo
*/
public function booking(): BelongsTo
{
return $this->BelongsTo(Booking::class, 'booking_id', 'id');
}
}
@@ -0,0 +1,35 @@
<?php
use Illuminate\Database\Migrations\Migration;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Support\Facades\Schema;
class CreateShippingCompanyConnectionsTable extends Migration
{
/**
* Run the migrations.
*
* @return void
*/
public function up()
{
Schema::create('shipping_company_connections', function (Blueprint $table) {
$table->id();
$table->foreignId('company_id');
$table->bigInteger('shipping_company_module_id')->unsigned()->index();
$table->timestamps();
$table->softDeletes();
});
}
/**
* Reverse the migrations.
*
* @return void
*/
public function down()
{
Schema::dropIfExists('shipping_company_connections');
}
}
@@ -0,0 +1,34 @@
<?php
use Illuminate\Database\Migrations\Migration;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Support\Facades\Schema;
class CreateShippingOrderBookings extends Migration
{
/**
* Run the migrations.
*
* @return void
*/
public function up()
{
Schema::create('shipping_order_bookings', function (Blueprint $table) {
$table->id();
$table->foreignId('booking_id');
$table->bigInteger('shipping_order_id')->unsigned()->index();
$table->timestamps();
$table->softDeletes();
});
}
/**
* Reverse the migrations.
*
* @return void
*/
public function down()
{
Schema::dropIfExists('shipping_order_bookings');
}
}
Binary file not shown.

After

Width:  |  Height:  |  Size: 14 KiB

@@ -0,0 +1,50 @@
<template>
<div class="row align-items-center justify-content-center bg-white">
<div class="col col-md-10">
<div class="row m-b-50 m-t-50">
<div class="col-8 col-md-6">
<img src="/images/cief-izyim-logo.png" class="w-100">
</div>
</div>
<div class="row m-b-40" v-show="!$store.getters.isShowing('registrationForm')">
<div class="col">
<div class="col parentContainer">
<loading-component style="height: 200px;" key="1" color="success" v-show="$store.getters.isLoading('loginSection')"></loading-component>
<div class="row" v-show="!$store.getters.isLoading('loginSection')">
<div class="col">
<div class="row m-b-15">
<div class="col">
<div class="inline v-align-middle">
<div class="font-heading fs-20 all-caps no-margin lh-28 bold">Sign In</div>
<p class="no-margin fs-11 light">To track your shipment please sign in with your personal info on Izyim</p>
</div>
</div>
</div>
<div class="row">
<div class="col">
<izyim-login-form-component section="loginSection" :data="data" :parentSection="section"></izyim-login-form-component>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</template>
<script>
import modalFormHandler from '../../../general/mixins/modalFormHandler';
export default {
props: {
section:{
type: String,
required: true
}
},
mixins: [modalFormHandler]
}
</script>
@@ -0,0 +1,73 @@
<template>
<div class="row parentContainer" @keyup.enter="submitForm">
<div class="col">
<error-message-component class="m-b-20" :error="error"></error-message-component>
<div class="row">
<div class="col">
<validation-wrapper-component class="m-b-15" :validator="$v.parameters.email">
<label class="text-primary">Email Address</label>
<input type="text" class="form-control fs-12" v-model.trim="parameters.email">
</validation-wrapper-component>
<validation-wrapper-component :validator="$v.parameters.password">
<label class="text-primary">Password</label>
<input type="password" class="form-control fs-12" v-model="parameters.password">
</validation-wrapper-component>
<div class="row m-t-15 align-items-center justify-content-center">
<div class="col">
<div class="btn btn-sm all-caps b-rad-none btn-success btn-block" @click="submitForm">Connect</div>
</div>
</div>
</div>
</div>
</div>
</div>
</template>
<script>
import { required, email } from 'vuelidate/lib/validators';
import formHandler from '../../../general/mixins/formHandler';
import errorMessageHandler from '../../../general/mixins/errorMessageHandler';
export default {
props: {
section:{
type: String,
required: true
},
parentSection:{
type: String,
required: true
}
},
data() {
return {
error: '',
parameters: {
email: this.email,
password: ''
},
currentUrl: window.location.href,
};
},
validations: {
parameters: {
email: {required, email},
password: {required}
},
},
methods: {
submitForm(){
this.submit(this.route('api.company.connect_shipping', this.data.booking.company.id), 'post', this.section, true, true)
},
successHandler(){
this.$store.dispatch('updateListQueue', {'name': this.parentSection});
this.closeModal();
this.formHandler();
},
errorHandler(error){
this.formHandler(error.message);
}
},
mixins: [formHandler, errorMessageHandler]
}
</script>
@@ -271,6 +271,17 @@
</div>
</div>
</div>
<div class="row m-t-10" v-show="[2, 3].includes(item.status)">
<div class="col" v-if="data.booking.company.shipping_company_module_id">
<button class="btn btn-sm all-caps b-rad-none btn-success btn-block" @click="trackShipment">Track your shipment</button>
</div>
<div class="col" v-else>
<button class="btn btn-sm all-caps b-rad-none btn-success btn-block requestModal" data-type="connectIzyim">Track your shipment with us</button>
<modal-component class="animate__animated animate__fast animate__fadeIn" styleType="fill-in" type="connectIzyim" size="large">
<connect-izyim-form-component :data="data" :section="section"></connect-izyim-form-component>
</modal-component>
</div>
</div>
<div class="row m-t-10" v-show="[2, 3].includes(item.status) && totalRequestedConvertRefund < data.booking.amount">
<div class="col">
<button class="btn btn-xs all-caps b-rad-none bg-master-lighter btn-block no-border requestModal hide" data-type="transferSummary">Request Refund</button>
@@ -332,6 +343,9 @@
clickExpand(){
this.expandPaymentDetails = !this.expandPaymentDetails;
},
trackShipment(){
window.open(route('booking.track_shipping_order', this.data.booking.marking) + '?token=' + this.$store.getters.getAccessToken, '_blank');
},
},
mixins: [componentHandler]
}
+11
View File
@@ -25,6 +25,17 @@ Route::group(['middleware' => 'api', 'prefix' => 'v1', 'as' => 'api.'], function
Route::post('online_payment/callback', 'Billplz\CallbackBillplzController@callback')->name('online_payment.callback');
// calling from shipping portal
Route::group(['middleware' => 'valid.shipping.token'], function () {
Route::post('/shipping/order/{shipping_order_id}/booking/{booking_id}/connect', 'Bookings\ConnectBookingToShippingOrderController@connect')->name('shipping.order.connect');
Route::group(['prefix' => 'shipping/company', 'as' => 'shipping.company.', 'namespace' => 'Companies'], function () {
Route::group(['prefix' => '{shipping_company_module_id}/identification', 'as' => 'identification.'], function () {
Route::post('/create', 'CreateIdentificationDocumentController@create')->name('create');
Route::put('/approval/{status}', 'ApproveIdentificationDocumentController@approve')->where('status', 'approve|reject')->name('approval');
});
});
});
Route::group(['middleware' => 'valid.token'], function () {
Route::get('/storage/{fileName}/fetch', 'Documents\RenderDocumentController@fileStorageServe')->where(['fileName' => '.*'])->name('storage.document.file');
+1
View File
@@ -3,6 +3,7 @@
use Illuminate\Support\Facades\Route;
Route::group(['prefix' => 'company', 'as' => 'company.', 'namespace' => 'Companies'], function () {
Route::post('/{id}/connect_shipping', 'LinkShippingCompanyController@link')->name('connect_shipping');
Route::get('/{id}/show', 'FetchCompanyController@fetch')->name('show');
Route::get('/list', 'ListCompaniesController@list')->name('list');
Route::post('/create', 'CreateCompanyController@create')->name('create');
+3 -1
View File
@@ -842,4 +842,6 @@ Route::get('/invoice/{marking}/{started_at}/{ended_at}/fix', function($marking,
}
}
);
})->name('invoice.fix.byCustomerMarking');
})->name('invoice.fix.byCustomerMarking');
Route::get('/booking/{marking}/track-shipping-order', 'Bookings\TrackBookingShipmentController@track')->name('booking.track_shipping_order');