549 lines
17 KiB
PHP
549 lines
17 KiB
PHP
<?php
|
|
|
|
namespace App\Http\Controllers\Admin;
|
|
|
|
use App\Http\Requests\CreateFlightRequest;
|
|
use App\Http\Requests\UpdateFlightRequest;
|
|
use App\Interfaces\Controller;
|
|
use App\Models\Enums\Days;
|
|
use App\Models\Enums\FlightType;
|
|
use App\Models\Flight;
|
|
use App\Models\FlightField;
|
|
use App\Models\FlightFieldValue;
|
|
use App\Repositories\AirlineRepository;
|
|
use App\Repositories\AirportRepository;
|
|
use App\Repositories\FareRepository;
|
|
use App\Repositories\FlightFieldRepository;
|
|
use App\Repositories\FlightRepository;
|
|
use App\Repositories\SubfleetRepository;
|
|
use App\Services\ExportService;
|
|
use App\Services\FareService;
|
|
use App\Services\FleetService;
|
|
use App\Services\FlightService;
|
|
use App\Services\ImportService;
|
|
use App\Support\Units\Time;
|
|
use Flash;
|
|
use Illuminate\Http\Request;
|
|
use Log;
|
|
use Response;
|
|
use Storage;
|
|
|
|
/**
|
|
* Class FlightController
|
|
* @package App\Http\Controllers\Admin
|
|
*/
|
|
class FlightController extends Controller
|
|
{
|
|
private $airlineRepo,
|
|
$airportRepo,
|
|
$fareRepo,
|
|
$flightRepo,
|
|
$flightFieldRepo,
|
|
$fareSvc,
|
|
$flightSvc,
|
|
$importSvc,
|
|
$subfleetRepo;
|
|
|
|
/**
|
|
* FlightController constructor.
|
|
* @param AirlineRepository $airlineRepo
|
|
* @param AirportRepository $airportRepo
|
|
* @param FareRepository $fareRepo
|
|
* @param FlightRepository $flightRepo
|
|
* @param FlightFieldRepository $flightFieldRepo
|
|
* @param FareService $fareSvc
|
|
* @param FlightService $flightSvc
|
|
* @param ImportService $importSvc
|
|
* @param SubfleetRepository $subfleetRepo
|
|
*/
|
|
public function __construct(
|
|
AirlineRepository $airlineRepo,
|
|
AirportRepository $airportRepo,
|
|
FareRepository $fareRepo,
|
|
FlightRepository $flightRepo,
|
|
FlightFieldRepository $flightFieldRepo,
|
|
FareService $fareSvc,
|
|
FlightService $flightSvc,
|
|
ImportService $importSvc,
|
|
SubfleetRepository $subfleetRepo
|
|
) {
|
|
$this->airlineRepo = $airlineRepo;
|
|
$this->airportRepo = $airportRepo;
|
|
$this->fareRepo = $fareRepo;
|
|
$this->flightRepo = $flightRepo;
|
|
$this->flightFieldRepo = $flightFieldRepo;
|
|
$this->fareSvc = $fareSvc;
|
|
$this->flightSvc = $flightSvc;
|
|
$this->importSvc = $importSvc;
|
|
$this->subfleetRepo = $subfleetRepo;
|
|
}
|
|
|
|
/**
|
|
* Save any custom fields found
|
|
* @param Flight $flight
|
|
* @param Request $request
|
|
*/
|
|
protected function saveCustomFields(Flight $flight, Request $request): void
|
|
{
|
|
$custom_fields = [];
|
|
$flight_fields = FlightField::all();
|
|
foreach ($flight_fields as $field) {
|
|
if (!$request->filled($field->slug)) {
|
|
continue;
|
|
}
|
|
|
|
$custom_fields[] = [
|
|
'name' => $field->name,
|
|
'value' => $request->input($field->slug)
|
|
];
|
|
}
|
|
|
|
Log::info('PIREP Custom Fields', $custom_fields);
|
|
$this->flightSvc->updateCustomFields($flight->id, $custom_fields);
|
|
}
|
|
|
|
/**
|
|
* @param $flight
|
|
* @return array
|
|
*/
|
|
protected function getAvailSubfleets($flight)
|
|
{
|
|
$retval = [];
|
|
|
|
$flight->refresh();
|
|
$all_aircraft = $this->subfleetRepo->all();
|
|
$avail_fleets = $all_aircraft->except($flight->subfleets->modelKeys());
|
|
|
|
foreach ($avail_fleets as $ac) {
|
|
$retval[$ac->id] = $ac->type.' - '.$ac->name;
|
|
}
|
|
|
|
return $retval;
|
|
}
|
|
|
|
/**
|
|
* @param Request $request
|
|
* @return \Illuminate\Contracts\View\Factory|\Illuminate\View\View
|
|
* @throws \Prettus\Repository\Exceptions\RepositoryException
|
|
*/
|
|
public function index(Request $request)
|
|
{
|
|
$flights = $this->flightRepo
|
|
->searchCriteria($request, false)
|
|
->orderBy('flight_number', 'asc')
|
|
->paginate();
|
|
|
|
return view('admin.flights.index', [
|
|
'flights' => $flights,
|
|
'airlines' => $this->airlineRepo->selectBoxList(true),
|
|
'airports' => $this->airportRepo->selectBoxList(true),
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* Show the form for creating a new Flight.
|
|
* @return Response
|
|
*/
|
|
public function create()
|
|
{
|
|
return view('admin.flights.create', [
|
|
'flight' => null,
|
|
'days' => [],
|
|
'flight_fields' => $this->flightFieldRepo->all(),
|
|
'airlines' => $this->airlineRepo->selectBoxList(),
|
|
'airports' => $this->airportRepo->selectBoxList(true, false),
|
|
'alt_airports' => $this->airportRepo->selectBoxList(true),
|
|
'flight_types' => FlightType::select(true),
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* @param CreateFlightRequest $request
|
|
* @return \Illuminate\Http\RedirectResponse|\Illuminate\Routing\Redirector
|
|
* @throws \Prettus\Validator\Exceptions\ValidatorException
|
|
*/
|
|
public function store(CreateFlightRequest $request)
|
|
{
|
|
$input = $request->all();
|
|
|
|
# See if flight number exists with the route code/leg
|
|
$where = [
|
|
'flight_number' => $input['flight_number'],
|
|
];
|
|
|
|
if (filled($input['route_code'])) {
|
|
$where['route_code'] = $input['route_code'];
|
|
}
|
|
|
|
if (filled($input['route_leg'])) {
|
|
$where['route_leg'] = $input['route_leg'];
|
|
}
|
|
|
|
$flights = $this->flightRepo->findWhere($where);
|
|
if ($flights->count() > 0) {
|
|
Flash::error('Duplicate flight with same number/code/leg found, please change to proceed');
|
|
return redirect()->back()->withInput($request->all());
|
|
}
|
|
|
|
$input['days'] = Days::getDaysMask($input['days']);
|
|
$input['active'] = get_truth_state($input['active']);
|
|
|
|
$time = new Time($input['minutes'], $input['hours']);
|
|
$input['flight_time'] = $time->getMinutes();
|
|
|
|
$flight = $this->flightRepo->create($input);
|
|
|
|
Flash::success('Flight saved successfully.');
|
|
return redirect(route('admin.flights.edit', $flight->id));
|
|
}
|
|
|
|
/**
|
|
* @param $id
|
|
* @return mixed
|
|
*/
|
|
public function show($id)
|
|
{
|
|
$flight = $this->flightRepo->findWithoutFail($id);
|
|
|
|
if (empty($flight)) {
|
|
Flash::error('Flight not found');
|
|
return redirect(route('admin.flights.index'));
|
|
}
|
|
|
|
$avail_subfleets = $this->getAvailSubfleets($flight);
|
|
|
|
return view('admin.flights.show', [
|
|
'flight' => $flight,
|
|
'flight_fields' => $this->flightFieldRepo->all(),
|
|
'avail_subfleets' => $avail_subfleets,
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* @param $id
|
|
* @return mixed
|
|
*/
|
|
public function edit($id)
|
|
{
|
|
$flight = $this->flightRepo->findWithoutFail($id);
|
|
if (empty($flight)) {
|
|
Flash::error('Flight not found');
|
|
|
|
return redirect(route('admin.flights.index'));
|
|
}
|
|
|
|
$time = new Time($flight->flight_time);
|
|
|
|
$flight->hours = $time->hours;
|
|
$flight->minutes = $time->minutes;
|
|
|
|
return view('admin.flights.edit', [
|
|
'flight' => $flight,
|
|
'days' => $flight->days,
|
|
'flight_fields' => $this->flightFieldRepo->all(),
|
|
'airlines' => $this->airlineRepo->selectBoxList(),
|
|
'airports' => $this->airportRepo->selectBoxList(),
|
|
'alt_airports' => $this->airportRepo->selectBoxList(true),
|
|
'avail_fares' => $this->getAvailFares($flight),
|
|
'avail_subfleets' => $this->getAvailSubfleets($flight),
|
|
'flight_types' => FlightType::select(true),
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* @param $id
|
|
* @param UpdateFlightRequest $request
|
|
* @return \Illuminate\Http\RedirectResponse|\Illuminate\Routing\Redirector
|
|
* @throws \Prettus\Validator\Exceptions\ValidatorException
|
|
*/
|
|
public function update($id, UpdateFlightRequest $request)
|
|
{
|
|
$flight = $this->flightRepo->findWithoutFail($id);
|
|
|
|
if (empty($flight)) {
|
|
Flash::error('Flight not found');
|
|
return redirect(route('admin.flights.index'));
|
|
}
|
|
|
|
$input = $request->all();
|
|
|
|
# See if flight number exists with the route code/leg
|
|
$where = [
|
|
['id', '<>', $id],
|
|
'flight_number' => $input['flight_number'],
|
|
];
|
|
|
|
if (filled($input['route_code'])) {
|
|
$where['route_code'] = $input['route_code'];
|
|
}
|
|
|
|
if (filled($input['route_leg'])) {
|
|
$where['route_leg'] = $input['route_leg'];
|
|
}
|
|
|
|
$flights = $this->flightRepo->findWhere($where);
|
|
if ($flights->count() > 0) {
|
|
Flash::error('Duplicate flight with same number/code/leg found, please change to proceed');
|
|
return redirect()->back()->withInput($request->all());
|
|
}
|
|
|
|
$input['days'] = Days::getDaysMask($input['days']);
|
|
|
|
$input['flight_time'] = Time::init(
|
|
$input['minutes'],
|
|
$input['hours'])->getMinutes();
|
|
|
|
$input['active'] = get_truth_state($input['active']);
|
|
|
|
$this->flightRepo->update($input, $id);
|
|
|
|
Flash::success('Flight updated successfully.');
|
|
return redirect(route('admin.flights.index'));
|
|
}
|
|
|
|
/**
|
|
* @param $id
|
|
* @return \Illuminate\Http\RedirectResponse|\Illuminate\Routing\Redirector
|
|
* @throws \Exception
|
|
*/
|
|
public function destroy($id)
|
|
{
|
|
$flight = $this->flightRepo->findWithoutFail($id);
|
|
|
|
if (empty($flight)) {
|
|
Flash::error('Flight not found');
|
|
return redirect(route('admin.flights.index'));
|
|
}
|
|
|
|
$this->flightSvc->deleteFlight($flight);
|
|
|
|
Flash::success('Flight deleted successfully.');
|
|
return redirect(route('admin.flights.index'));
|
|
}
|
|
|
|
/**
|
|
* Run the flight exporter
|
|
* @param Request $request
|
|
* @return \Symfony\Component\HttpFoundation\BinaryFileResponse
|
|
* @throws \League\Csv\Exception
|
|
*/
|
|
public function export(Request $request)
|
|
{
|
|
$exporter = app(ExportService::class);
|
|
$flights = $this->flightRepo->all();
|
|
|
|
$path = $exporter->exportFlights($flights);
|
|
return response()
|
|
->download($path, 'flights.csv', [
|
|
'content-type' => 'text/csv',
|
|
])
|
|
->deleteFileAfterSend(true);
|
|
}
|
|
|
|
/**
|
|
*
|
|
* @param Request $request
|
|
* @return \Illuminate\Contracts\View\Factory|\Illuminate\View\View
|
|
* @throws \Illuminate\Validation\ValidationException
|
|
*/
|
|
public function import(Request $request)
|
|
{
|
|
$logs = [
|
|
'success' => [],
|
|
'errors' => [],
|
|
];
|
|
|
|
if ($request->isMethod('post')) {
|
|
$path = Storage::putFileAs(
|
|
'import', $request->file('csv_file'), 'import_flights.csv'
|
|
);
|
|
|
|
$path = storage_path('app/'.$path);
|
|
Log::info('Uploaded flights import file to '.$path);
|
|
$logs = $this->importSvc->importFlights($path);
|
|
}
|
|
|
|
return view('admin.flights.import', [
|
|
'logs' => $logs,
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* @param $flight
|
|
* @return mixed
|
|
*/
|
|
protected function return_fields_view($flight)
|
|
{
|
|
$flight->refresh();
|
|
return view('admin.flights.flight_fields', [
|
|
'flight' => $flight,
|
|
'flight_fields' => $this->flightFieldRepo->all(),
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* @param $flight_id
|
|
* @param Request $request
|
|
* @return mixed
|
|
*/
|
|
public function field_values($flight_id, Request $request)
|
|
{
|
|
$flight = $this->flightRepo->findWithoutFail($flight_id);
|
|
if (empty($flight)) {
|
|
Flash::error('Flight not found');
|
|
return redirect(route('admin.flights.index'));
|
|
}
|
|
|
|
// add custom field to flight
|
|
if ($request->isMethod('post')) {
|
|
Log::info('Adding new flight field, flight: '.$flight_id, $request->input());
|
|
|
|
$field = new FlightFieldValue;
|
|
$field->flight_id = $flight_id;
|
|
$field->name = $request->input('name');
|
|
$field->value = $request->input('value');
|
|
$field->save();
|
|
} elseif ($request->isMethod('put')) {
|
|
Log::info('Updating flight field, flight: '.$flight_id, $request->input());
|
|
$field = FlightFieldValue::where('name', $request->input('name'))->first();
|
|
if(!$field) {
|
|
Log::info('Field not found, creating new');
|
|
$field = new FlightFieldValue();
|
|
$field->flight_id = $flight_id;
|
|
$field->name = $request->input('name');
|
|
}
|
|
|
|
$field->value = $request->input('value');
|
|
$field->save();
|
|
// update the field value
|
|
} // remove custom field from flight
|
|
elseif ($request->isMethod('delete')) {
|
|
Log::info('Deleting flight field, flight: '.$flight_id, $request->input());
|
|
if($flight_id && $request->input('field_id')) {
|
|
FlightFieldValue::destroy($request->input('field_id'));
|
|
}
|
|
}
|
|
|
|
return $this->return_fields_view($flight);
|
|
}
|
|
|
|
/**
|
|
* @param $flight
|
|
* @return \Illuminate\Contracts\View\Factory|\Illuminate\View\View
|
|
*/
|
|
protected function return_subfleet_view($flight)
|
|
{
|
|
$avail_subfleets = $this->getAvailSubfleets($flight);
|
|
|
|
return view('admin.flights.subfleets', [
|
|
'flight' => $flight,
|
|
'avail_subfleets' => $avail_subfleets,
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* @param $id
|
|
* @param Request $request
|
|
* @return mixed
|
|
*/
|
|
public function subfleets($id, Request $request)
|
|
{
|
|
$flight = $this->flightRepo->findWithoutFail($id);
|
|
if (empty($flight)) {
|
|
Flash::error('Flight not found');
|
|
return redirect(route('admin.flights.index'));
|
|
}
|
|
|
|
$fleetSvc = app(FleetService::class);
|
|
|
|
// add aircraft to flight
|
|
$subfleet = $this->subfleetRepo->findWithoutFail($request->subfleet_id);
|
|
if(!$subfleet) {
|
|
return $this->return_subfleet_view($flight);
|
|
}
|
|
|
|
if ($request->isMethod('post')) {
|
|
$fleetSvc->addSubfleetToFlight($subfleet, $flight);
|
|
} // remove aircraft from flight
|
|
elseif ($request->isMethod('delete')) {
|
|
$fleetSvc->removeSubfleetFromFlight($subfleet, $flight);
|
|
}
|
|
|
|
return $this->return_subfleet_view($flight);
|
|
}
|
|
|
|
/**
|
|
* Get all the fares that haven't been assigned to a given subfleet
|
|
*/
|
|
protected function getAvailFares($flight)
|
|
{
|
|
$retval = [];
|
|
$all_fares = $this->fareRepo->all();
|
|
$avail_fares = $all_fares->except($flight->fares->modelKeys());
|
|
foreach ($avail_fares as $fare) {
|
|
$retval[$fare->id] = $fare->name.' (base price: '.$fare->price.')';
|
|
}
|
|
|
|
return $retval;
|
|
}
|
|
|
|
/**
|
|
* @param Flight $flight
|
|
* @return \Illuminate\Contracts\View\Factory|\Illuminate\View\View
|
|
*/
|
|
protected function return_fares_view(Flight $flight)
|
|
{
|
|
$flight->refresh();
|
|
|
|
return view('admin.flights.fares', [
|
|
'flight' => $flight,
|
|
'avail_fares' => $this->getAvailFares($flight),
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* @param Request $request
|
|
* @return \Illuminate\Contracts\View\Factory|\Illuminate\View\View
|
|
*/
|
|
public function fares(Request $request)
|
|
{
|
|
$id = $request->id;
|
|
|
|
$flight = $this->flightRepo->findWithoutFail($id);
|
|
if (empty($flight)) {
|
|
return $this->return_fares_view($flight);
|
|
}
|
|
|
|
if ($request->isMethod('get')) {
|
|
return $this->return_fares_view($flight);
|
|
}
|
|
|
|
if ($request->isMethod('delete')) {
|
|
$fare = $this->fareRepo->findWithoutFail($request->fare_id);
|
|
$this->fareSvc->delFareFromFlight($flight, $fare);
|
|
|
|
return $this->return_fares_view($flight);
|
|
}
|
|
|
|
$this->validate($request, [
|
|
'value' => 'nullable', // regex:/([\d%]*)/
|
|
]);
|
|
|
|
/**
|
|
* update specific fare data
|
|
*/
|
|
if ($request->isMethod('post')) {
|
|
$fare = $this->fareRepo->findWithoutFail($request->fare_id);
|
|
$this->fareSvc->setForFlight($flight, $fare);
|
|
} // update the pivot table with overrides for the fares
|
|
elseif ($request->isMethod('put')) {
|
|
$override = [];
|
|
$fare = $this->fareRepo->findWithoutFail($request->fare_id);
|
|
$override[$request->name] = $request->value;
|
|
$this->fareSvc->setForFlight($flight, $fare, $override);
|
|
} // dissassociate fare from teh aircraft
|
|
|
|
return $this->return_fares_view($flight);
|
|
}
|
|
}
|