Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
a5a1a1f7aa | ||
|
|
ec6cb42bfd | ||
|
|
14d0e99a37 | ||
|
|
f8c7bc31f5 | ||
|
|
2545328233 | ||
|
|
61739ce266 | ||
|
|
bffc4f911c | ||
|
|
d18925f473 | ||
|
|
f5e83461a3 | ||
|
|
bfddb2c84d | ||
|
|
7e9eb08135 | ||
|
|
3d55336823 | ||
|
|
68ed2355ad | ||
|
|
fdab4ee530 | ||
|
|
648e7a261d | ||
|
|
9cb0a0cf36 | ||
|
|
2c8372d484 | ||
|
|
498d5bfaf0 | ||
|
|
2202c5b479 | ||
|
|
ac64a5db75 | ||
|
|
6c3992e781 | ||
|
|
344edde0fb | ||
|
|
7502c053bf | ||
|
|
dbfaed0ecc | ||
|
|
ff255c999b | ||
|
|
8c065a44cf | ||
|
|
8e9ba3b922 | ||
|
|
677d30883f | ||
|
|
ede71e6927 | ||
|
|
3f84f84309 | ||
|
|
50e8f2e52b | ||
|
|
96fff0248d | ||
|
|
9c4aced837 | ||
|
|
ed146b2c70 | ||
|
|
1e320835c2 | ||
|
|
d4c301a36c | ||
|
|
c2b0b69eb2 | ||
|
|
43c33adcfe | ||
|
|
be6332936f | ||
|
|
8f38fc2dec | ||
|
|
65015cbce2 | ||
|
|
3cc5ca2c32 | ||
|
|
30e88ac6bc | ||
|
|
61ee4254fc | ||
|
|
f9f0ee826d | ||
|
|
4394487392 | ||
|
|
1287766a46 | ||
|
|
11824c9f8b | ||
|
|
bbd02bf5c7 | ||
|
|
9bb192b97f | ||
|
|
2cede04b1e | ||
|
|
7072428218 | ||
|
|
1d83b85d8b | ||
|
|
63eef59060 | ||
|
|
0152ff6045 | ||
|
|
e45bd66388 | ||
|
|
b9e7a2efc9 | ||
|
|
73f88fce0c | ||
|
|
e70ee5aa6f | ||
|
|
f1c54bcc7c | ||
|
|
d94d754961 | ||
|
|
9abfbd6c8c | ||
|
|
97fc1dd43d | ||
|
|
edc37f40fa | ||
|
|
950c7788be | ||
|
|
b3af50ac5a | ||
|
|
8a9b68d9ec | ||
|
|
70a4cf9f90 | ||
|
|
c3465851b2 | ||
|
|
b13c4df338 | ||
|
|
c736a9b639 | ||
|
|
d2e1004e08 | ||
|
|
3800c01d94 | ||
|
|
922e754c9e | ||
|
|
936cd2efd3 | ||
|
|
e22d6d5996 | ||
|
|
efcb7e8895 | ||
|
|
43fbe9e943 | ||
|
|
8fc0aec800 | ||
|
|
bb84fa82a4 | ||
|
|
4fe323a763 | ||
|
|
e3b4a0ed2e | ||
|
|
a4c431d39f | ||
|
|
a52e0410a7 |
@@ -1,7 +1,3 @@
|
||||
<?php
|
||||
exit();
|
||||
?>
|
||||
|
||||
APP_ENV="dev"
|
||||
APP_KEY="base64:zdgcDqu9PM8uGWCtMxd74ZqdGJIrnw812oRMmwDF6KY="
|
||||
APP_URL="http://localhost"
|
||||
@@ -12,7 +8,7 @@ APP_LOCALE="en"
|
||||
PHPVMS_INSTALLED="true"
|
||||
|
||||
APP_LOG="daily"
|
||||
APP_LOG_LEVEL="debug"
|
||||
LOG_LEVEL="debug"
|
||||
APP_LOG_MAX_FILES="3"
|
||||
|
||||
DB_CONNECTION="mysql"
|
||||
|
||||
@@ -71,7 +71,6 @@ jobs:
|
||||
php --version
|
||||
mysql --version
|
||||
# Downgrade composer version to 1.x
|
||||
composer self-update --1
|
||||
composer install --dev --no-interaction --verbose
|
||||
cp .github/scripts/env.php env.php
|
||||
cp .github/scripts/phpunit.xml phpunit.xml
|
||||
@@ -119,7 +118,6 @@ jobs:
|
||||
run: |
|
||||
rm -rf vendor
|
||||
sudo npm i tar-to-zip -g
|
||||
composer self-update --1
|
||||
composer install --no-dev --prefer-dist --no-interaction --verbose
|
||||
sudo chmod +x ./.github/scripts/*
|
||||
|
||||
@@ -183,7 +181,6 @@ jobs:
|
||||
run: |
|
||||
rm -rf vendor
|
||||
sudo npm i tar-to-zip -g
|
||||
composer self-update --1
|
||||
composer install --no-dev --prefer-dist --no-interaction --verbose
|
||||
sudo chmod +x ./.github/scripts/*
|
||||
|
||||
|
||||
@@ -74,4 +74,5 @@ error_log
|
||||
.sass-cache
|
||||
.DS_Store
|
||||
/config.php
|
||||
/config.bak.php
|
||||
/VERSION
|
||||
|
||||
@@ -28,6 +28,8 @@ RedirectMatch 403 ^/composer.phar
|
||||
RedirectMatch 403 ^/env.php.*?$
|
||||
RedirectMatch 403 ^/env.php
|
||||
RedirectMatch 403 ^/env.php$
|
||||
RedirectMatch 403 ^/config.php$
|
||||
RedirectMatch 403 ^/config.bak.php$
|
||||
RedirectMatch 403 ^/Makefile
|
||||
RedirectMatch 403 ^/package.json
|
||||
RedirectMatch 403 ^/package-lock.json
|
||||
|
||||
+2
-1
@@ -2,7 +2,7 @@ FROM php:7.4-fpm-alpine
|
||||
|
||||
WORKDIR /var/www/
|
||||
|
||||
RUN apk add gmp-dev
|
||||
RUN apk add gmp-dev icu-dev
|
||||
RUN curl --silent --show-error https://getcomposer.org/installer | php
|
||||
|
||||
# Copy any config files in
|
||||
@@ -12,6 +12,7 @@ RUN ln -sf /dev/stderr /var/log/fpm-error.log
|
||||
|
||||
RUN docker-php-ext-install \
|
||||
calendar \
|
||||
intl \
|
||||
pdo_mysql \
|
||||
gmp \
|
||||
opcache && \
|
||||
|
||||
@@ -36,7 +36,7 @@ A full development environment can be brought up using Docker:
|
||||
|
||||
```bash
|
||||
composer install
|
||||
yarn install
|
||||
npm install
|
||||
docker-compose build
|
||||
docker-compose up
|
||||
```
|
||||
|
||||
@@ -4,9 +4,9 @@ namespace App\Console\Commands;
|
||||
|
||||
use App;
|
||||
use App\Contracts\Command;
|
||||
use App\Services\Installer\ConfigService;
|
||||
use App\Services\Installer\SeederService;
|
||||
use DatabaseSeeder;
|
||||
use Modules\Installer\Services\ConfigService;
|
||||
|
||||
/**
|
||||
* Create the config files
|
||||
@@ -81,13 +81,13 @@ class CreateConfigs extends Command
|
||||
|
||||
$this->info('Regenerating the config files');
|
||||
$cfgSvc->createConfigFiles([
|
||||
'APP_ENV' => 'dev',
|
||||
'SITE_NAME' => $this->argument('name'),
|
||||
'DB_CONN' => 'mysql',
|
||||
'DB_HOST' => $this->argument('db_host'),
|
||||
'DB_NAME' => $this->argument('db_name'),
|
||||
'DB_USER' => $this->argument('db_user'),
|
||||
'DB_PASS' => $this->argument('db_pass'),
|
||||
'APP_ENV' => 'dev',
|
||||
'SITE_NAME' => $this->argument('name'),
|
||||
'DB_CONNECTION' => 'mysql',
|
||||
'DB_HOST' => $this->argument('db_host'),
|
||||
'DB_DATABASE' => $this->argument('db_name'),
|
||||
'DB_USERNAME' => $this->argument('db_user'),
|
||||
'DB_PASSWORD' => $this->argument('db_pass'),
|
||||
]);
|
||||
|
||||
$this->info('Config files generated!');
|
||||
|
||||
@@ -79,9 +79,9 @@ class DevInstall extends Command
|
||||
|
||||
$this->info('Regenerating the config files');
|
||||
$cfgSvc->createConfigFiles([
|
||||
'APP_ENV' => 'dev',
|
||||
'SITE_NAME' => 'phpvms test',
|
||||
'DB_CONN' => 'sqlite',
|
||||
'APP_ENV' => 'dev',
|
||||
'SITE_NAME' => 'phpvms test',
|
||||
'DB_CONNECTION' => 'sqlite',
|
||||
]);
|
||||
|
||||
$this->info('Config files generated!');
|
||||
|
||||
@@ -0,0 +1,25 @@
|
||||
<?php
|
||||
|
||||
namespace App\Console\Commands;
|
||||
|
||||
use App\Contracts\Command;
|
||||
use App\Services\Installer\ConfigService;
|
||||
|
||||
/**
|
||||
* Command to rewrite the config files
|
||||
*/
|
||||
class RewriteConfigs extends Command
|
||||
{
|
||||
protected $signature = 'phpvms:rewrite-configs';
|
||||
protected $description = 'Rewrite the config files';
|
||||
|
||||
/**
|
||||
* Run dev related commands
|
||||
*/
|
||||
public function handle()
|
||||
{
|
||||
/** @var ConfigService $configSvc */
|
||||
$configSvc = app(ConfigService::class);
|
||||
$configSvc->rewriteConfigFiles();
|
||||
}
|
||||
}
|
||||
+10
-3
@@ -13,7 +13,11 @@ use Illuminate\Foundation\Console\Kernel as ConsoleKernel;
|
||||
class Kernel extends ConsoleKernel
|
||||
{
|
||||
/**
|
||||
* Define the application's command schedule.
|
||||
* Define the application's command schedule. How this works... according to the command
|
||||
* time, an event gets send out with the appropriate time (e.g, hourly sends an hourly event)
|
||||
*
|
||||
* Then the CronServiceProvider has the list of cronjobs which then run according to the events
|
||||
* and then calls those at the proper times.
|
||||
*
|
||||
* @param \Illuminate\Console\Scheduling\Schedule $schedule
|
||||
*
|
||||
@@ -27,10 +31,13 @@ class Kernel extends ConsoleKernel
|
||||
$schedule->command(Hourly::class)->hourly();
|
||||
|
||||
// When spatie-backups runs
|
||||
$schedule->command('backup:clean')->daily()->at('01:00');
|
||||
$schedule->command('backup:run')->daily()->at('02:00');
|
||||
/*if (config('backup.backup.enabled', false) === true) {
|
||||
$schedule->command('backup:clean')->daily()->at('01:00');
|
||||
$schedule->command('backup:run')->daily()->at('02:00');
|
||||
}*/
|
||||
|
||||
// Update the last time the cron was run
|
||||
/** @var CronService $cronSvc */
|
||||
$cronSvc = app(CronService::class);
|
||||
$cronSvc->updateLastRunTime();
|
||||
}
|
||||
|
||||
@@ -0,0 +1,52 @@
|
||||
<?php
|
||||
|
||||
namespace App\Cron\Hourly;
|
||||
|
||||
use App\Contracts\Listener;
|
||||
use App\Events\CronHourly;
|
||||
use App\Models\Enums\PirepState;
|
||||
use App\Models\Pirep;
|
||||
use App\Services\PirepService;
|
||||
use Carbon\Carbon;
|
||||
use Illuminate\Support\Facades\Log;
|
||||
|
||||
/**
|
||||
* Remove cancelled/deleted PIREPs. Look for PIREPs that were created before the setting time
|
||||
* (e.g, 12 hours ago) and are marked with the
|
||||
*/
|
||||
class DeletePireps extends Listener
|
||||
{
|
||||
/**
|
||||
* Delete old rejected PIREPs
|
||||
*
|
||||
* @param CronHourly $event
|
||||
*
|
||||
* @throws \Exception
|
||||
*/
|
||||
public function handle(CronHourly $event): void
|
||||
{
|
||||
$this->deletePireps(setting('pireps.delete_rejected_hours'), PirepState::REJECTED);
|
||||
$this->deletePireps(setting('pireps.delete_cancelled_hours'), PirepState::CANCELLED);
|
||||
}
|
||||
|
||||
/**
|
||||
* Look for and delete PIREPs which match the criteria
|
||||
*
|
||||
* @param int $expire_time_hours The time in hours to look for PIREPs
|
||||
* @param int $state The PirepState enum value
|
||||
*/
|
||||
protected function deletePireps(int $expire_time_hours, int $state)
|
||||
{
|
||||
$dt = Carbon::now('UTC')->subHours($expire_time_hours);
|
||||
$pireps = Pirep::where('created_at', '<', $dt)->where(['state' => $state])->get();
|
||||
|
||||
/** @var PirepService $pirepSvc */
|
||||
$pirepSvc = app(PirepService::class);
|
||||
|
||||
/** @var Pirep $pirep */
|
||||
foreach ($pireps as $pirep) {
|
||||
Log::info('Cron: Deleting PIREP id='.$pirep->id.', state='.PirepState::label($state));
|
||||
$pirepSvc->delete($pirep);
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -25,7 +25,7 @@ class RemoveExpiredBids extends Listener
|
||||
return;
|
||||
}
|
||||
|
||||
$date = Carbon::now()->subHours(setting('bids.expire_time'));
|
||||
Bid::whereDate('created_at', '<', $date)->delete();
|
||||
$date = Carbon::now('UTC')->subHours(setting('bids.expire_time'));
|
||||
Bid::where('created_at', '<', $date)->delete();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -26,8 +26,8 @@ class RemoveExpiredLiveFlights extends Listener
|
||||
return;
|
||||
}
|
||||
|
||||
$date = Carbon::now()->subHours(setting('acars.live_time'));
|
||||
Pirep::whereDate('updated_at', '<', $date)
|
||||
$date = Carbon::now('UTC')->subHours(setting('acars.live_time'));
|
||||
Pirep::where('updated_at', '<', $date)
|
||||
->where('state', PirepState::IN_PROGRESS)
|
||||
->delete();
|
||||
}
|
||||
|
||||
@@ -6,6 +6,7 @@ use App\Contracts\Listener;
|
||||
use App\Events\CronMonthly;
|
||||
use App\Models\Enums\ExpenseType;
|
||||
use App\Services\Finance\RecurringFinanceService;
|
||||
use Illuminate\Support\Facades\Log;
|
||||
|
||||
/**
|
||||
* Go through and apply any finances that are daily
|
||||
@@ -35,6 +36,7 @@ class ApplyExpenses extends Listener
|
||||
*/
|
||||
public function handle(CronMonthly $event): void
|
||||
{
|
||||
Log::info('Monthly: Applying monthly expenses');
|
||||
$this->financeSvc->processExpenses(ExpenseType::MONTHLY);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -6,6 +6,7 @@ use App\Contracts\Listener;
|
||||
use App\Events\CronNightly;
|
||||
use App\Models\Enums\ExpenseType;
|
||||
use App\Services\Finance\RecurringFinanceService;
|
||||
use Illuminate\Support\Facades\Log;
|
||||
|
||||
/**
|
||||
* Go through and apply any finances that are daily
|
||||
@@ -35,6 +36,7 @@ class ApplyExpenses extends Listener
|
||||
*/
|
||||
public function handle(CronNightly $event): void
|
||||
{
|
||||
Log::info('Nightly: Applying daily expenses');
|
||||
$this->financeSvc->processExpenses(ExpenseType::DAILY);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -5,6 +5,7 @@ namespace App\Cron\Nightly;
|
||||
use App\Contracts\Listener;
|
||||
use App\Events\CronNightly;
|
||||
use App\Services\SimBriefService;
|
||||
use Illuminate\Support\Facades\Log;
|
||||
|
||||
/**
|
||||
* Clear any expired SimBrief flight briefs that aren't attached to a PIREP
|
||||
@@ -23,6 +24,7 @@ class ClearExpiredSimbrief extends Listener
|
||||
*/
|
||||
public function handle(CronNightly $event): void
|
||||
{
|
||||
Log::info('Nightly: Removing expired Simbrief entries');
|
||||
$this->simbriefSvc->removeExpiredEntries();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -5,6 +5,7 @@ namespace App\Cron\Nightly;
|
||||
use App\Contracts\Listener;
|
||||
use App\Events\CronNightly;
|
||||
use App\Services\VersionService;
|
||||
use Illuminate\Support\Facades\Log;
|
||||
|
||||
/**
|
||||
* Determine if any pilots should be set to ON LEAVE status
|
||||
@@ -28,6 +29,7 @@ class NewVersionCheck extends Listener
|
||||
*/
|
||||
public function handle(CronNightly $event): void
|
||||
{
|
||||
Log::info('Nightly: Checking for new version');
|
||||
$this->versionSvc->isNewVersionAvailable();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -34,7 +34,10 @@ class PilotLeave extends Listener
|
||||
*/
|
||||
public function handle(CronNightly $event): void
|
||||
{
|
||||
Log::info('Cron: Running pilot leave check');
|
||||
$users = $this->userSvc->findUsersOnLeave();
|
||||
Log::info('Found '.count($users).' users on leave');
|
||||
|
||||
foreach ($users as $user) {
|
||||
Log::info('Setting user '.$user->ident.' to ON LEAVE status');
|
||||
$this->userSvc->setStatusOnLeave($user);
|
||||
|
||||
@@ -35,7 +35,7 @@ class RecalculateBalances extends Listener
|
||||
*/
|
||||
public function handle(CronNightly $event): void
|
||||
{
|
||||
Log::info('Recalculating balances');
|
||||
Log::info('Nightly: Recalculating balances');
|
||||
|
||||
$journals = Journal::all();
|
||||
foreach ($journals as $journal) {
|
||||
|
||||
@@ -32,10 +32,10 @@ class RecalculateStats extends Listener
|
||||
*/
|
||||
public function handle(CronNightly $event): void
|
||||
{
|
||||
Log::info('Recalculating user stats');
|
||||
Log::info('Nightly: Recalculating user stats');
|
||||
$this->userSvc->recalculateAllUserStats();
|
||||
|
||||
Log::info('Recalcuating aircraft status');
|
||||
Log::info('Nightly: Recalcuating aircraft status');
|
||||
$this->aircraftSvc->recalculateStats();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -19,6 +19,8 @@ class SetActiveFlights extends Listener
|
||||
*/
|
||||
public function handle(CronNightly $event): void
|
||||
{
|
||||
Log::info('Nightly: Setting active flights');
|
||||
|
||||
$this->checkFlights();
|
||||
}
|
||||
|
||||
|
||||
@@ -1,17 +1,20 @@
|
||||
<?php
|
||||
|
||||
use App\Models\Journal;
|
||||
use Carbon\Carbon;
|
||||
use Faker\Generator as Faker;
|
||||
use Ramsey\Uuid\Uuid;
|
||||
|
||||
$factory->define(App\Models\JournalTransactions::class, function (Faker $faker) {
|
||||
$factory->define(App\Models\JournalTransaction::class, function (Faker $faker) {
|
||||
return [
|
||||
'transaction_group' => \Ramsey\Uuid\Uuid::uuid4()->toString(),
|
||||
'transaction_group' => Uuid::uuid4()->toString(),
|
||||
'journal_id' => function () {
|
||||
return factory(\App\Models\Journal::class)->create()->id;
|
||||
return factory(Journal::class)->create()->id;
|
||||
},
|
||||
'credit' => $faker->numberBetween(100, 10000),
|
||||
'debit' => $faker->numberBetween(100, 10000),
|
||||
'currency' => 'USD',
|
||||
'memo' => $faker->sentence(6),
|
||||
'post_date' => \Carbon\Carbon::now(),
|
||||
'post_date' => Carbon::now('UTC'),
|
||||
];
|
||||
});
|
||||
|
||||
@@ -0,0 +1,13 @@
|
||||
<?php
|
||||
|
||||
use Faker\Generator as Faker;
|
||||
|
||||
$factory->define(App\Models\Role::class, function (Faker $faker) {
|
||||
return [
|
||||
'id' => null,
|
||||
'name' => $faker->name,
|
||||
'display_name' => $faker->name,
|
||||
'read_only' => false,
|
||||
'disable_activity_checks' => $faker->boolean(),
|
||||
];
|
||||
});
|
||||
@@ -0,0 +1,21 @@
|
||||
<?php
|
||||
|
||||
use App\Contracts\Migration;
|
||||
use Illuminate\Database\Schema\Blueprint;
|
||||
use Illuminate\Support\Facades\Schema;
|
||||
|
||||
/**
|
||||
* Add a `fuel_onboard` column for recording what is left in tanks
|
||||
*/
|
||||
class AircraftAddFuelonboard extends Migration
|
||||
{
|
||||
public function up()
|
||||
{
|
||||
Schema::table('aircraft', function (Blueprint $table) {
|
||||
$table->unsignedDecimal('fuel_onboard')
|
||||
->nullable()
|
||||
->default(0.0)
|
||||
->after('zfw');
|
||||
});
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,20 @@
|
||||
<?php
|
||||
|
||||
use App\Contracts\Migration;
|
||||
use Illuminate\Database\Schema\Blueprint;
|
||||
use Illuminate\Support\Facades\Schema;
|
||||
|
||||
/**
|
||||
* Add a SimBrief Type to subfleet
|
||||
*/
|
||||
class AddSbtypeToSubfleets extends Migration
|
||||
{
|
||||
public function up()
|
||||
{
|
||||
Schema::table('subfleets', function (Blueprint $table) {
|
||||
$table->string('simbrief_type', 20)
|
||||
->nullable()
|
||||
->after('type');
|
||||
});
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,24 @@
|
||||
<?php
|
||||
|
||||
use App\Contracts\Migration;
|
||||
use Illuminate\Database\Schema\Blueprint;
|
||||
use Illuminate\Support\Facades\Schema;
|
||||
|
||||
/**
|
||||
* Add a hub to the subfleet is
|
||||
*/
|
||||
class AddAircraftToSimbrief extends Migration
|
||||
{
|
||||
public function up()
|
||||
{
|
||||
Schema::table('simbrief', function (Blueprint $table) {
|
||||
$table->unsignedInteger('aircraft_id')
|
||||
->nullable()
|
||||
->after('pirep_id');
|
||||
|
||||
// Temp column to hold the calculated fare data for the API
|
||||
// Remove this once the prefile to acars feature is completed
|
||||
$table->mediumText('fare_data')->nullable()->after('ofp_xml');
|
||||
});
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,19 @@
|
||||
<?php
|
||||
|
||||
use App\Contracts\Migration;
|
||||
use Illuminate\Database\Schema\Blueprint;
|
||||
use Illuminate\Support\Facades\Schema;
|
||||
|
||||
/**
|
||||
* Add a hub to the subfleet is
|
||||
*/
|
||||
class AddKvpTable extends Migration
|
||||
{
|
||||
public function up()
|
||||
{
|
||||
Schema::create('kvp', function (Blueprint $table) {
|
||||
$table->string('key')->index();
|
||||
$table->string('value');
|
||||
});
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,34 @@
|
||||
<?php
|
||||
|
||||
use Illuminate\Database\Migrations\Migration;
|
||||
use Illuminate\Database\Schema\Blueprint;
|
||||
use Illuminate\Support\Facades\Schema;
|
||||
|
||||
class AddDisableactivitychecksToRoles extends Migration
|
||||
{
|
||||
/**
|
||||
* Run the migrations.
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function up()
|
||||
{
|
||||
Schema::table('roles', function (Blueprint $table) {
|
||||
$table->boolean('disable_activity_checks')
|
||||
->default(false)
|
||||
->after('read_only');
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Reverse the migrations.
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function down()
|
||||
{
|
||||
Schema::table('roles', function (Blueprint $table) {
|
||||
$table->dropColumn('disable_activity_checks');
|
||||
});
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,19 @@
|
||||
<?php
|
||||
|
||||
use Illuminate\Database\Migrations\Migration;
|
||||
use Illuminate\Support\Facades\DB;
|
||||
|
||||
class RemoveSettingRemoveBidOnAccept extends Migration
|
||||
{
|
||||
/**
|
||||
* Run the migrations.
|
||||
*
|
||||
* @return void
|
||||
*/
|
||||
public function up()
|
||||
{
|
||||
DB::table('settings')
|
||||
->where(['key' => 'pireps.remove_bid_on_accept'])
|
||||
->delete();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,30 @@
|
||||
<?php
|
||||
|
||||
use App\Contracts\Migration;
|
||||
use Illuminate\Database\Schema\Blueprint;
|
||||
use Illuminate\Support\Facades\Schema;
|
||||
|
||||
/**
|
||||
* Add a `anumeric_callsign` column for Alphanumeric Callsign to be assigned for a flight
|
||||
* Exp DLH78BF, THY8EA, OGE1978
|
||||
* According to FAA and EASA, callsigns must be maximum 7 chars in which first 3 chars is
|
||||
* airline ICAO code remaining rest can be used freely according to airline's choices
|
||||
*/
|
||||
class FlightsAddAlphanumericCallsign extends Migration
|
||||
{
|
||||
public function up()
|
||||
{
|
||||
Schema::table('flights', function (Blueprint $table) {
|
||||
$table->string('callsign', 4)
|
||||
->nullable()
|
||||
->after('flight_number');
|
||||
});
|
||||
}
|
||||
|
||||
public function down()
|
||||
{
|
||||
Schema::table('flights', function (Blueprint $table) {
|
||||
$table->dropColumn('callsign');
|
||||
});
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,21 @@
|
||||
<?php
|
||||
|
||||
use App\Contracts\Migration;
|
||||
use App\Services\Installer\ConfigService;
|
||||
|
||||
/**
|
||||
* Migrate the configuration files
|
||||
*/
|
||||
class MigrateConfigs extends Migration
|
||||
{
|
||||
public function up()
|
||||
{
|
||||
/** @var ConfigService $configSvc */
|
||||
$configSvc = app(ConfigService::class);
|
||||
$configSvc->rewriteConfigFiles();
|
||||
}
|
||||
|
||||
public function down()
|
||||
{
|
||||
}
|
||||
}
|
||||
@@ -119,8 +119,8 @@ aircraft:
|
||||
-
|
||||
id: 1
|
||||
subfleet_id: 1
|
||||
icao: null
|
||||
iata: null
|
||||
icao: B744
|
||||
iata: 744
|
||||
airport_id: KJFK
|
||||
landing_time: '2020-10-23 07:50:16'
|
||||
name: 'Boeing 747-438'
|
||||
@@ -136,8 +136,8 @@ aircraft:
|
||||
-
|
||||
id: 2
|
||||
subfleet_id: 2
|
||||
icao: null
|
||||
iata: null
|
||||
icao: B777
|
||||
iata: 777
|
||||
airport_id: LGRP
|
||||
landing_time: null
|
||||
name: 'Boeing 777-200'
|
||||
@@ -153,8 +153,8 @@ aircraft:
|
||||
-
|
||||
id: 3
|
||||
subfleet_id: 1
|
||||
icao: null
|
||||
iata: null
|
||||
icao: B744
|
||||
iata: 744
|
||||
airport_id: KAUS
|
||||
landing_time: '2020-10-24 08:50:13'
|
||||
name: 'Boeing 747-412'
|
||||
@@ -170,8 +170,8 @@ aircraft:
|
||||
-
|
||||
id: 4
|
||||
subfleet_id: 1
|
||||
icao: null
|
||||
iata: null
|
||||
icao: B744
|
||||
iata: 744
|
||||
airport_id: KAUS
|
||||
landing_time: null
|
||||
name: 'Boeing 747-436 RETIRED'
|
||||
@@ -187,7 +187,7 @@ aircraft:
|
||||
-
|
||||
id: 5
|
||||
subfleet_id: 4
|
||||
icao: A320
|
||||
icao: 'A320'
|
||||
iata: '320'
|
||||
airport_id: EGLL
|
||||
landing_time: null
|
||||
|
||||
File diff suppressed because one or more lines are too long
@@ -180,12 +180,12 @@
|
||||
type: number
|
||||
description: 'How much the load factor can vary per-flight'
|
||||
- key: simbrief.api_key
|
||||
name: 'SimBrief API Key'
|
||||
name: 'Simbrief API Key'
|
||||
group: simbrief
|
||||
value: ''
|
||||
options: ''
|
||||
type: string
|
||||
description: 'Your SimBrief API key'
|
||||
description: 'Your Simbrief API key'
|
||||
- key: simbrief.only_bids
|
||||
name: 'Only allow for bids'
|
||||
group: simbrief
|
||||
@@ -194,12 +194,54 @@
|
||||
type: boolean
|
||||
description: 'Only allow briefs to be created for bidded flights'
|
||||
- key: simbrief.expire_days
|
||||
name: 'SimBrief Expire Time'
|
||||
name: 'Simbrief Expire Time'
|
||||
group: simbrief
|
||||
value: 5
|
||||
options: ''
|
||||
type: number
|
||||
description: 'Days after how long to remove unused briefs'
|
||||
- key: simbrief.noncharter_pax_weight
|
||||
name: 'Non-Charter Passenger Weight'
|
||||
group: simbrief
|
||||
value: 185
|
||||
options: ''
|
||||
type: number
|
||||
description: 'Passenger weight for non-charter flights excluding baggage (lbs)'
|
||||
- key: simbrief.noncharter_baggage_weight
|
||||
name: 'Non-Charter Baggage Weight'
|
||||
group: simbrief
|
||||
value: 35
|
||||
options: ''
|
||||
type: number
|
||||
description: 'Passenger baggage weight for non-charter flights (lbs)'
|
||||
- key: simbrief.charter_pax_weight
|
||||
name: 'Charter Passenger Weight'
|
||||
group: simbrief
|
||||
value: 168
|
||||
options: ''
|
||||
type: number
|
||||
description: 'Passenger weight for charter flights excluding baggage (lbs)'
|
||||
- key: simbrief.charter_baggage_weight
|
||||
name: 'Charter Baggage Weight'
|
||||
group: simbrief
|
||||
value: 28
|
||||
options: ''
|
||||
type: number
|
||||
description: 'Passenger baggage weight for charter flights (lbs)'
|
||||
- key: simbrief.callsign
|
||||
name: 'Use ATC Callsign'
|
||||
group: simbrief
|
||||
value: false
|
||||
options: ''
|
||||
type: boolean
|
||||
description: 'Use pilot ident as Simbrief ATC Callsign'
|
||||
- key: simbrief.name_private
|
||||
name: 'Use Privatized Name at OFPs'
|
||||
group: simbrief
|
||||
value: false
|
||||
options: ''
|
||||
type: boolean
|
||||
description: 'Use privatized user name as SimBrief OFP captain name'
|
||||
- key: pireps.duplicate_check_time
|
||||
name: 'PIREP duplicate time check'
|
||||
group: pireps
|
||||
@@ -221,13 +263,27 @@
|
||||
options: ''
|
||||
type: boolean
|
||||
description: 'Only allow aircraft that are at the departure airport'
|
||||
- key: pireps.remove_bid_on_accept
|
||||
name: 'Remove bid on accept'
|
||||
- key: pireps.advanced_fuel
|
||||
name: 'Advanced Fuel Calculations'
|
||||
group: pireps
|
||||
value: false
|
||||
options: ''
|
||||
type: boolean
|
||||
description: 'When a PIREP is accepted, remove the bid, if it exists'
|
||||
description: 'Enables remaining fuel amounts to be considered for fuel expenses'
|
||||
- key: pireps.delete_cancelled_hours
|
||||
name: 'Delete cancelled PIREPs'
|
||||
group: pireps
|
||||
value: 12
|
||||
options: ''
|
||||
type: int
|
||||
description: 'The time in hours to delete a cancelled PIREP'
|
||||
- key: pireps.delete_rejected_hours
|
||||
name: 'Delete rejected PIREPs'
|
||||
group: pireps
|
||||
value: 12
|
||||
options: ''
|
||||
type: int
|
||||
description: 'The time in hours to delete a rejected PIREP'
|
||||
- key: pilots.id_length
|
||||
name: 'Pilot ID Length'
|
||||
group: pilots
|
||||
@@ -305,3 +361,9 @@
|
||||
options: ''
|
||||
type: 'text'
|
||||
description: 'Discord public channel ID for broadcasat notifications'
|
||||
- key: 'cron.random_id'
|
||||
name: 'Cron Randomized ID'
|
||||
group: 'cron'
|
||||
value: ''
|
||||
type: 'hidden'
|
||||
description: ''
|
||||
|
||||
@@ -0,0 +1,37 @@
|
||||
<?php
|
||||
|
||||
namespace App\Exceptions;
|
||||
|
||||
class CronInvalid extends AbstractHttpException
|
||||
{
|
||||
public const MESSAGE = 'Cron ID is disabled or invalid';
|
||||
|
||||
public function __construct()
|
||||
{
|
||||
parent::__construct(400, static::MESSAGE);
|
||||
}
|
||||
|
||||
/**
|
||||
* Return the RFC 7807 error type (without the URL root)
|
||||
*/
|
||||
public function getErrorType(): string
|
||||
{
|
||||
return 'cron-invalid';
|
||||
}
|
||||
|
||||
/**
|
||||
* Get the detailed error string
|
||||
*/
|
||||
public function getErrorDetails(): string
|
||||
{
|
||||
return $this->getMessage();
|
||||
}
|
||||
|
||||
/**
|
||||
* Return an array with the error details, merged with the RFC7807 response
|
||||
*/
|
||||
public function getErrorMetadata(): array
|
||||
{
|
||||
return [];
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,44 @@
|
||||
<?php
|
||||
|
||||
namespace App\Exceptions;
|
||||
|
||||
/**
|
||||
* Prefile Error
|
||||
*
|
||||
* If listening to the prefile event message, use `throw new PrefileError("message message");`
|
||||
* to abort the prefile process and send the message up to ACARS
|
||||
*/
|
||||
class PrefileError extends AbstractHttpException
|
||||
{
|
||||
private $error;
|
||||
|
||||
public function __construct(string $error)
|
||||
{
|
||||
$this->error = $error;
|
||||
parent::__construct(400, $error);
|
||||
}
|
||||
|
||||
/**
|
||||
* Return the RFC 7807 error type (without the URL root)
|
||||
*/
|
||||
public function getErrorType(): string
|
||||
{
|
||||
return 'prefile-error';
|
||||
}
|
||||
|
||||
/**
|
||||
* Get the detailed error string
|
||||
*/
|
||||
public function getErrorDetails(): string
|
||||
{
|
||||
return $this->getMessage();
|
||||
}
|
||||
|
||||
/**
|
||||
* Return an array with the error details, merged with the RFC7807 response
|
||||
*/
|
||||
public function getErrorMetadata(): array
|
||||
{
|
||||
return [];
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,38 @@
|
||||
<?php
|
||||
|
||||
namespace App\Exceptions;
|
||||
|
||||
class UserNotFound extends AbstractHttpException
|
||||
{
|
||||
public function __construct()
|
||||
{
|
||||
parent::__construct(
|
||||
404,
|
||||
'User not found'
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* Return the RFC 7807 error type (without the URL root)
|
||||
*/
|
||||
public function getErrorType(): string
|
||||
{
|
||||
return 'user-not-found';
|
||||
}
|
||||
|
||||
/**
|
||||
* Get the detailed error string
|
||||
*/
|
||||
public function getErrorDetails(): string
|
||||
{
|
||||
return $this->getMessage();
|
||||
}
|
||||
|
||||
/**
|
||||
* Return an array with the error details, merged with the RFC7807 response
|
||||
*/
|
||||
public function getErrorMetadata(): array
|
||||
{
|
||||
return [];
|
||||
}
|
||||
}
|
||||
@@ -115,7 +115,7 @@ class FlightController extends Controller
|
||||
$avail_fleets = $all_aircraft->except($flight->subfleets->modelKeys());
|
||||
|
||||
foreach ($avail_fleets as $ac) {
|
||||
$retval[$ac->id] = $ac->type.' - '.$ac->name;
|
||||
$retval[$ac->id] = '['.$ac->airline->icao.'] '.$ac->type.' - '.$ac->name;
|
||||
}
|
||||
|
||||
return $retval;
|
||||
|
||||
@@ -6,6 +6,7 @@ use App\Contracts\Controller;
|
||||
use App\Repositories\KvpRepository;
|
||||
use App\Services\CronService;
|
||||
use App\Services\VersionService;
|
||||
use App\Support\Utils;
|
||||
use Codedge\Updater\UpdaterManager;
|
||||
use Illuminate\Http\Request;
|
||||
use Illuminate\Support\Facades\Artisan;
|
||||
@@ -34,7 +35,12 @@ class MaintenanceController extends Controller
|
||||
|
||||
public function index()
|
||||
{
|
||||
// Get the cron URL
|
||||
$cron_id = setting('cron.random_id');
|
||||
$cron_url = empty($cron_id) ? 'Not enabled' : url(route('api.maintenance.cron', $cron_id));
|
||||
|
||||
return view('admin.maintenance.index', [
|
||||
'cron_url' => $cron_url,
|
||||
'cron_path' => $this->cronSvc->getCronExecString(),
|
||||
'cron_problem_exists' => $this->cronSvc->cronProblemExists(),
|
||||
'new_version' => $this->kvpRepo->get('new_version_available', false),
|
||||
@@ -117,4 +123,33 @@ class MaintenanceController extends Controller
|
||||
|
||||
return redirect('/update/downloader');
|
||||
}
|
||||
|
||||
/**
|
||||
* Enable the cron, or if it's enabled, change the ID that is used
|
||||
*
|
||||
* @param Request $request
|
||||
*/
|
||||
public function cron_enable(Request $request)
|
||||
{
|
||||
$id = Utils::generateNewId(24);
|
||||
setting_save('cron.random_id', $id);
|
||||
|
||||
Flash::success('Web cron refreshed!');
|
||||
return redirect(route('admin.maintenance.index'));
|
||||
}
|
||||
|
||||
/**
|
||||
* Disable the web cron
|
||||
*
|
||||
* @param Request $request
|
||||
*
|
||||
* @return mixed
|
||||
*/
|
||||
public function cron_disable(Request $request)
|
||||
{
|
||||
setting_save('cron.random_id', '');
|
||||
|
||||
Flash::success('Web cron disabled!');
|
||||
return redirect(route('admin.maintenance.index'));
|
||||
}
|
||||
}
|
||||
|
||||
@@ -394,10 +394,10 @@ class PirepController extends Controller
|
||||
return redirect(route('admin.pireps.index'));
|
||||
}
|
||||
|
||||
$this->pirepRepo->delete($id);
|
||||
$this->pirepSvc->delete($pirep);
|
||||
|
||||
Flash::success('Pirep deleted successfully.');
|
||||
return redirect(route('admin.pireps.index'));
|
||||
return redirect()->back();
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -62,7 +62,7 @@ class SettingsController extends Controller
|
||||
*/
|
||||
public function index()
|
||||
{
|
||||
$settings = Setting::orderBy('order', 'asc')->get();
|
||||
$settings = Setting::where('type', '!=', 'hidden')->orderBy('order')->get();
|
||||
$settings = $settings->groupBy('group');
|
||||
|
||||
return view('admin.settings.index', [
|
||||
|
||||
@@ -252,15 +252,12 @@ class UserController extends Controller
|
||||
public function destroy($id)
|
||||
{
|
||||
$user = $this->userRepo->findWithoutFail($id);
|
||||
|
||||
if (empty($user)) {
|
||||
Flash::error('User not found');
|
||||
|
||||
return redirect(route('admin.users.index'));
|
||||
}
|
||||
|
||||
$this->userRepo->delete($id);
|
||||
|
||||
$this->userSvc->removeUser($user);
|
||||
Flash::success('User deleted successfully.');
|
||||
|
||||
return redirect(route('admin.users.index'));
|
||||
|
||||
@@ -4,7 +4,6 @@ namespace App\Http\Controllers\Api;
|
||||
|
||||
use App\Contracts\Controller;
|
||||
use App\Exceptions\AssetNotFound;
|
||||
use App\Exceptions\Unauthorized;
|
||||
use App\Http\Resources\Flight as FlightResource;
|
||||
use App\Http\Resources\Navdata as NavdataResource;
|
||||
use App\Models\SimBrief;
|
||||
|
||||
@@ -0,0 +1,35 @@
|
||||
<?php
|
||||
|
||||
namespace App\Http\Controllers\Api;
|
||||
|
||||
use App\Contracts\Controller;
|
||||
use App\Exceptions\CronInvalid;
|
||||
use Illuminate\Http\Request;
|
||||
use Illuminate\Support\Facades\Artisan;
|
||||
|
||||
class MaintenanceController extends Controller
|
||||
{
|
||||
/**
|
||||
* Run the cron job from the web
|
||||
*
|
||||
* @param Request $request
|
||||
* @param string $id The ID passed in for the cron
|
||||
*
|
||||
* @return mixed
|
||||
*/
|
||||
public function cron(Request $request, string $id)
|
||||
{
|
||||
$cron_id = setting('cron.random_id');
|
||||
if (empty($cron_id) || $id !== $cron_id) {
|
||||
throw new CronInvalid();
|
||||
}
|
||||
|
||||
$output = '';
|
||||
Artisan::call('schedule:run');
|
||||
$output .= trim(Artisan::output());
|
||||
|
||||
return response([
|
||||
'content' => $output,
|
||||
]);
|
||||
}
|
||||
}
|
||||
@@ -3,7 +3,6 @@
|
||||
namespace App\Http\Controllers\Api;
|
||||
|
||||
use App\Contracts\Controller;
|
||||
use App\Events\PirepPrefiled;
|
||||
use App\Events\PirepUpdated;
|
||||
use App\Exceptions\AircraftPermissionDenied;
|
||||
use App\Exceptions\PirepCancelled;
|
||||
@@ -219,8 +218,6 @@ class PirepController extends Controller
|
||||
$this->updateFields($pirep, $request);
|
||||
$this->updateFares($pirep, $request);
|
||||
|
||||
event(new PirepPrefiled($pirep));
|
||||
|
||||
return $this->get($pirep->id);
|
||||
}
|
||||
|
||||
|
||||
@@ -3,6 +3,7 @@
|
||||
namespace App\Http\Controllers\Api;
|
||||
|
||||
use App\Contracts\Controller;
|
||||
use App\Exceptions\UserNotFound;
|
||||
use App\Http\Resources\Bid as BidResource;
|
||||
use App\Http\Resources\Pirep as PirepResource;
|
||||
use App\Http\Resources\Subfleet as SubfleetResource;
|
||||
@@ -91,6 +92,10 @@ class UserController extends Controller
|
||||
public function get($id)
|
||||
{
|
||||
$user = $this->userSvc->getUser($id);
|
||||
if ($user === null) {
|
||||
throw new UserNotFound();
|
||||
}
|
||||
|
||||
return new UserResource($user);
|
||||
}
|
||||
|
||||
@@ -106,7 +111,11 @@ class UserController extends Controller
|
||||
*/
|
||||
public function bids(Request $request)
|
||||
{
|
||||
$user = $this->userSvc->getUser($this->getUserId($request));
|
||||
$user_id = $this->getUserId($request);
|
||||
$user = $this->userSvc->getUser($user_id);
|
||||
if ($user === null) {
|
||||
throw new UserNotFound();
|
||||
}
|
||||
|
||||
// Add a bid
|
||||
if ($request->isMethod('PUT') || $request->isMethod('POST')) {
|
||||
@@ -145,6 +154,10 @@ class UserController extends Controller
|
||||
public function fleet(Request $request)
|
||||
{
|
||||
$user = $this->userRepo->find($this->getUserId($request));
|
||||
if ($user === null) {
|
||||
throw new UserNotFound();
|
||||
}
|
||||
|
||||
$subfleets = $this->userSvc->getAllowableSubfleets($user);
|
||||
|
||||
return SubfleetResource::collection($subfleets);
|
||||
|
||||
@@ -28,7 +28,10 @@ class DashboardController extends Controller
|
||||
*/
|
||||
public function index()
|
||||
{
|
||||
//dd(config('backup'));
|
||||
$last_pirep = null;
|
||||
|
||||
/** @var \App\Models\User $user */
|
||||
$user = Auth::user();
|
||||
|
||||
try {
|
||||
|
||||
@@ -3,6 +3,7 @@
|
||||
namespace App\Http\Controllers\Frontend;
|
||||
|
||||
use App\Contracts\Controller;
|
||||
use App\Models\Airline;
|
||||
use App\Models\File;
|
||||
use Auth;
|
||||
use Flash;
|
||||
@@ -18,6 +19,7 @@ class DownloadController extends Controller
|
||||
*/
|
||||
public function index()
|
||||
{
|
||||
$airlines = Airline::where('active', 1)->count();
|
||||
$files = File::orderBy('ref_model', 'asc')->get();
|
||||
|
||||
/**
|
||||
@@ -42,10 +44,14 @@ class DownloadController extends Controller
|
||||
$category = explode('\\', $class);
|
||||
$category = end($category);
|
||||
|
||||
if ($category == 'Aircraft') {
|
||||
if ($category == 'Aircraft' && $airlines > 1) {
|
||||
$group_name = $category.' > '.$obj->subfleet->airline->name.' '.$obj->icao.' '.$obj->registration;
|
||||
} elseif ($category == 'Aircraft') {
|
||||
$group_name = $category.' > '.$obj->icao.' '.$obj->registration;
|
||||
} elseif ($category == 'Airport') {
|
||||
$group_name = $category.' > '.$obj->icao.' : '.$obj->name.' ('.$obj->country.')';
|
||||
} elseif ($category == 'Subfleet' && $airlines > 1) {
|
||||
$group_name = $category.' > '.$obj->airline->name.' '.$obj->name;
|
||||
} else {
|
||||
$group_name = $category.' > '.$obj->name;
|
||||
}
|
||||
@@ -53,13 +59,15 @@ class DownloadController extends Controller
|
||||
$regrouped_files[$group_name] = $files;
|
||||
}
|
||||
|
||||
ksort($regrouped_files, SORT_STRING);
|
||||
|
||||
return view('downloads.index', [
|
||||
'grouped_files' => $regrouped_files,
|
||||
]);
|
||||
}
|
||||
|
||||
/**
|
||||
* Show the application dashboard.
|
||||
* Show the application dashboard
|
||||
*
|
||||
* @param string $id
|
||||
*
|
||||
|
||||
@@ -106,7 +106,13 @@ class FlightController extends Controller
|
||||
}
|
||||
|
||||
$flights = $this->flightRepo->searchCriteria($request)
|
||||
->with(['dpt_airport', 'arr_airport', 'airline'])
|
||||
->with([
|
||||
'dpt_airport',
|
||||
'arr_airport',
|
||||
'airline',
|
||||
'simbrief' => function ($query) use ($user) {
|
||||
$query->where('user_id', $user->id);
|
||||
}, ])
|
||||
->orderBy('flight_number', 'asc')
|
||||
->orderBy('route_leg', 'asc')
|
||||
->paginate();
|
||||
@@ -115,6 +121,7 @@ class FlightController extends Controller
|
||||
->pluck('flight_id')->toArray();
|
||||
|
||||
return view('flights.index', [
|
||||
'user' => $user,
|
||||
'airlines' => $this->airlineRepo->selectBoxList(true),
|
||||
'airports' => $this->airportRepo->selectBoxList(true),
|
||||
'flights' => $flights,
|
||||
@@ -158,6 +165,7 @@ class FlightController extends Controller
|
||||
}
|
||||
|
||||
return view('flights.bids', [
|
||||
'user' => $user,
|
||||
'airlines' => $this->airlineRepo->selectBoxList(true),
|
||||
'airports' => $this->airportRepo->selectBoxList(true),
|
||||
'flights' => $flights,
|
||||
|
||||
@@ -7,7 +7,7 @@ use App\Http\Requests\CreatePirepRequest;
|
||||
use App\Http\Requests\UpdatePirepRequest;
|
||||
use App\Models\Enums\PirepSource;
|
||||
use App\Models\Enums\PirepState;
|
||||
use App\Models\Enums\PirepStatus;
|
||||
use App\Models\Fare;
|
||||
use App\Models\Pirep;
|
||||
use App\Models\SimBrief;
|
||||
use App\Models\User;
|
||||
@@ -211,6 +211,7 @@ class PirepController extends Controller
|
||||
return view('pireps.show', [
|
||||
'pirep' => $pirep,
|
||||
'map_features' => $map_features,
|
||||
'user' => Auth::user(),
|
||||
]);
|
||||
}
|
||||
|
||||
@@ -253,23 +254,48 @@ class PirepController extends Controller
|
||||
/**
|
||||
* They have a SimBrief ID, load that up and figure out the flight that it's from
|
||||
*/
|
||||
$fare_values = [];
|
||||
$simbrief = null;
|
||||
$simbrief_id = null;
|
||||
$aircraft = null;
|
||||
if ($request->has('sb_id')) {
|
||||
$simbrief_id = $request->input('sb_id');
|
||||
$brief = SimBrief::find($simbrief_id);
|
||||
$pirep = Pirep::fromSimBrief($brief);
|
||||
$simbrief = SimBrief::find($simbrief_id);
|
||||
$pirep = Pirep::fromSimBrief($simbrief);
|
||||
|
||||
$aircraft = $simbrief->aircraft;
|
||||
$aircraft_list[$aircraft->subfleet->name] = [];
|
||||
$aircraft_list[$aircraft->subfleet->name][$aircraft->id] = $aircraft->name.' - '.$aircraft->registration;
|
||||
|
||||
// Convert the fare data into the expected output format
|
||||
if (!empty($simbrief->fare_data)) {
|
||||
$fare_values = json_decode($simbrief->fare_data, true);
|
||||
$fares = [];
|
||||
$fare_data = json_decode($simbrief->fare_data, true);
|
||||
foreach ($fare_data as $fare) {
|
||||
$fares[] = new Fare($fare);
|
||||
}
|
||||
|
||||
$aircraft->subfleet->fares = collect($fares);
|
||||
}
|
||||
|
||||
// TODO: Set more fields from the Simbrief to the PIREP form
|
||||
} else {
|
||||
$aircraft_list = $this->aircraftList(true);
|
||||
}
|
||||
|
||||
return view('pireps.create', [
|
||||
'aircraft' => null,
|
||||
'aircraft' => $aircraft,
|
||||
'pirep' => $pirep,
|
||||
'read_only' => false,
|
||||
'airline_list' => $this->airlineRepo->selectBoxList(true),
|
||||
'aircraft_list' => $this->aircraftList(true),
|
||||
'aircraft_list' => $aircraft_list,
|
||||
'airport_list' => $this->airportRepo->selectBoxList(true),
|
||||
'pirep_fields' => $this->pirepFieldRepo->all(),
|
||||
'field_values' => [],
|
||||
'fare_values' => $fare_values,
|
||||
'simbrief_id' => $simbrief_id,
|
||||
'simbrief' => $simbrief,
|
||||
]);
|
||||
}
|
||||
|
||||
@@ -403,12 +429,18 @@ class PirepController extends Controller
|
||||
*/
|
||||
public function edit($id)
|
||||
{
|
||||
/** @var Pirep $pirep */
|
||||
$pirep = $this->pirepRepo->findWithoutFail($id);
|
||||
if (empty($pirep)) {
|
||||
Flash::error('Pirep not found');
|
||||
return redirect(route('frontend.pireps.index'));
|
||||
}
|
||||
|
||||
if ($pirep->user_id !== Auth::id()) {
|
||||
Flash::error('Cannot edit someone else\'s PIREP!');
|
||||
return redirect(route('admin.pireps.index'));
|
||||
}
|
||||
|
||||
// Eager load the subfleet and fares under it
|
||||
if ($pirep->aircraft) {
|
||||
$pirep->aircraft->load('subfleet.fares');
|
||||
@@ -461,12 +493,21 @@ class PirepController extends Controller
|
||||
*/
|
||||
public function update($id, UpdatePirepRequest $request)
|
||||
{
|
||||
/** @var User $user */
|
||||
$user = Auth::user();
|
||||
|
||||
/** @var Pirep $pirep */
|
||||
$pirep = $this->pirepRepo->findWithoutFail($id);
|
||||
if (empty($pirep)) {
|
||||
Flash::error('Pirep not found');
|
||||
return redirect(route('admin.pireps.index'));
|
||||
}
|
||||
|
||||
if ($user->id !== $pirep->user_id) {
|
||||
Flash::error('Cannot edit someone else\'s PIREP!');
|
||||
return redirect(route('admin.pireps.index'));
|
||||
}
|
||||
|
||||
$orig_route = $pirep->route;
|
||||
$attrs = $request->all();
|
||||
$attrs['submit'] = strtolower($attrs['submit']);
|
||||
@@ -493,12 +534,8 @@ class PirepController extends Controller
|
||||
$this->pirepSvc->submit($pirep);
|
||||
Flash::success('PIREP submitted!');
|
||||
} elseif ($attrs['submit'] === 'delete' || $attrs['submit'] === 'cancel') {
|
||||
$this->pirepRepo->update([
|
||||
'state' => PirepState::CANCELLED,
|
||||
'status' => PirepStatus::CANCELLED,
|
||||
], $pirep->id);
|
||||
|
||||
Flash::success('PIREP cancelled!');
|
||||
$this->pirepSvc->delete($pirep);
|
||||
Flash::success('PIREP deleted!');
|
||||
return redirect(route('frontend.pireps.index'));
|
||||
}
|
||||
|
||||
@@ -523,6 +560,11 @@ class PirepController extends Controller
|
||||
return redirect(route('admin.pireps.index'));
|
||||
}
|
||||
|
||||
if ($pirep->user_id !== Auth::id()) {
|
||||
Flash::error('Cannot edit someone else\'s PIREP!');
|
||||
return redirect(route('admin.pireps.index'));
|
||||
}
|
||||
|
||||
$this->pirepSvc->submit($pirep);
|
||||
return redirect(route('frontend.pireps.show', [$pirep->id]));
|
||||
}
|
||||
|
||||
@@ -4,8 +4,14 @@ namespace App\Http\Controllers\Frontend;
|
||||
|
||||
use App\Exceptions\AssetNotFound;
|
||||
use App\Models\Aircraft;
|
||||
use App\Models\Enums\AircraftState;
|
||||
use App\Models\Enums\AircraftStatus;
|
||||
use App\Models\Enums\FareType;
|
||||
use App\Models\Enums\FlightType;
|
||||
use App\Models\Fare;
|
||||
use App\Models\Flight;
|
||||
use App\Models\SimBrief;
|
||||
use App\Models\User;
|
||||
use App\Repositories\FlightRepository;
|
||||
use App\Services\FareService;
|
||||
use App\Services\SimBriefService;
|
||||
@@ -49,8 +55,9 @@ class SimBriefController
|
||||
|
||||
$flight_id = $request->input('flight_id');
|
||||
$aircraft_id = $request->input('aircraft_id');
|
||||
$flight = $this->flightRepo->with(['subfleets'])->find($flight_id);
|
||||
$flight = $this->fareSvc->getReconciledFaresForFlight($flight);
|
||||
|
||||
/** @var Flight $flight */
|
||||
$flight = $this->flightRepo->with(['fares', 'subfleets'])->find($flight_id);
|
||||
|
||||
if (!$flight) {
|
||||
flash()->error('Unknown flight');
|
||||
@@ -63,6 +70,43 @@ class SimBriefController
|
||||
return redirect(route('frontend.flights.index'));
|
||||
}
|
||||
|
||||
// No aircraft selected, show selection form
|
||||
if (!$aircraft_id) {
|
||||
// If no subfleets defined for flight get them from user
|
||||
if ($flight->subfleets->count() > 0) {
|
||||
$subfleets = $flight->subfleets;
|
||||
} else {
|
||||
$subfleets = $this->userSvc->getAllowableSubfleets($user);
|
||||
}
|
||||
|
||||
// Build an array of subfleet id's from the subfleets collection
|
||||
$sf_ids = $subfleets->map(function ($subfleets) {
|
||||
return collect($subfleets->toArray())
|
||||
->only(['id'])
|
||||
->all();
|
||||
});
|
||||
|
||||
// Now we can build a proper aircrafts collection
|
||||
// Contents will be either members of flight->subfleets
|
||||
// or members of user's allowable subfleets
|
||||
$aircrafts = Aircraft::whereIn('subfleet_id', $sf_ids)
|
||||
->where('state', AircraftState::PARKED)
|
||||
->where('status', AircraftStatus::ACTIVE)
|
||||
->orderby('icao')
|
||||
->orderby('registration')
|
||||
->get();
|
||||
|
||||
if (setting('pireps.only_aircraft_at_dpt_airport')) {
|
||||
$aircrafts = $aircrafts->where('airport_id', $flight->dpt_airport_id);
|
||||
}
|
||||
|
||||
return view('flights.simbrief_aircraft', [
|
||||
'flight' => $flight,
|
||||
'aircrafts' => $aircrafts,
|
||||
'subfleets' => $subfleets,
|
||||
]);
|
||||
}
|
||||
|
||||
// Check if a Simbrief profile already exists
|
||||
$simbrief = SimBrief::select('id')->where([
|
||||
'flight_id' => $flight_id,
|
||||
@@ -73,34 +117,26 @@ class SimBriefController
|
||||
return redirect(route('frontend.simbrief.briefing', [$simbrief->id]));
|
||||
}
|
||||
|
||||
// Simbrief Profile doesn't exist; prompt the user to create a new one
|
||||
$aircraft = Aircraft::select('registration', 'name', 'icao', 'iata', 'subfleet_id')
|
||||
->where('id', $aircraft_id)
|
||||
->get();
|
||||
// SimBrief profile does not exists and everything else is ok
|
||||
// Select aircraft which will be used for calculations and details
|
||||
/** @var Aircraft $aircraft */
|
||||
$aircraft = Aircraft::where('id', $aircraft_id)->first();
|
||||
|
||||
if ($flight->subfleets->count() > 0) {
|
||||
$subfleets = $flight->subfleets;
|
||||
} else {
|
||||
$subfleets = $this->userSvc->getAllowableSubfleets($user);
|
||||
}
|
||||
// Figure out the proper fares to use for this flight/aircraft
|
||||
$all_fares = $this->fareSvc->getFareWithOverrides($aircraft->subfleet->fares, $flight->fares);
|
||||
|
||||
// TODO: Reconcile the fares for this aircraft w/ proper for the flight/subfleet
|
||||
|
||||
// Get passenger and baggage weights with failsafe defaults
|
||||
if ($flight->flight_type === FlightType::CHARTER_PAX_ONLY) {
|
||||
$pax_weight = 197;
|
||||
$pax_weight = setting('simbrief.charter_pax_weight', 168);
|
||||
$bag_weight = setting('simbrief.charter_baggage_weight', 28);
|
||||
} else {
|
||||
$pax_weight = 208;
|
||||
$pax_weight = setting('simbrief.noncharter_pax_weight', 185);
|
||||
$bag_weight = setting('simbrief.noncharter_baggage_weight', 35);
|
||||
}
|
||||
|
||||
// No aircraft selected, show that form
|
||||
if (!$aircraft_id) {
|
||||
return view('flights.simbrief_aircraft', [
|
||||
'flight' => $flight,
|
||||
'aircraft' => $aircraft,
|
||||
'subfleets' => $subfleets,
|
||||
'pax_weight' => $pax_weight,
|
||||
]);
|
||||
}
|
||||
|
||||
// Get the correct load factors
|
||||
// Get the load factors with failsafe for loadmax if nothing is defined
|
||||
$lfactor = $flight->load_factor ?? setting('flights.default_load_factor');
|
||||
$lfactorv = $flight->load_factor_variance ?? setting('flights.load_factor_variance');
|
||||
|
||||
@@ -110,20 +146,90 @@ class SimBriefController
|
||||
$loadmax = $lfactor + $lfactorv;
|
||||
$loadmax = $loadmax > 100 ? 100 : $loadmax;
|
||||
|
||||
// Failsafe for admins not defining load values for their flights
|
||||
// and also leave the general settings empty, set loadmax to 100
|
||||
if ($loadmax === 0) {
|
||||
$loadmax = 100;
|
||||
}
|
||||
|
||||
// Load fares for passengers
|
||||
|
||||
$loaddist = []; // The load distribution string
|
||||
|
||||
$pax_load_sheet = [];
|
||||
$tpaxfig = 0;
|
||||
|
||||
/** @var Fare $fare */
|
||||
foreach ($all_fares as $fare) {
|
||||
if ($fare->type !== FareType::PASSENGER || empty($fare->capacity)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
$count = floor(($fare->capacity * rand($loadmin, $loadmax)) / 100);
|
||||
$tpaxfig += $count;
|
||||
$pax_load_sheet[] = [
|
||||
'id' => $fare->id,
|
||||
'code' => $fare->code,
|
||||
'name' => $fare->name,
|
||||
'type' => $fare->type,
|
||||
'capacity' => (int) $fare->capacity,
|
||||
'count' => $count,
|
||||
];
|
||||
|
||||
$loaddist[] = $fare->code.' '.$count;
|
||||
}
|
||||
|
||||
// Calculate total weights
|
||||
if (setting('units.weight') === 'kg') {
|
||||
$tpaxload = round(($pax_weight * $tpaxfig) / 2.205);
|
||||
$tbagload = round(($bag_weight * $tpaxfig) / 2.205);
|
||||
} else {
|
||||
$tpaxload = round($pax_weight * $tpaxfig);
|
||||
$tbagload = round($bag_weight * $tpaxfig);
|
||||
}
|
||||
|
||||
// Load up fares for cargo
|
||||
|
||||
$tcargoload = 0;
|
||||
$cargo_load_sheet = [];
|
||||
foreach ($all_fares as $fare) {
|
||||
if ($fare->type !== FareType::CARGO || empty($fare->capacity)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
$count = ceil((($fare->capacity - $tbagload) * rand($loadmin, $loadmax)) / 100);
|
||||
$tcargoload += $count;
|
||||
$cargo_load_sheet[] = [
|
||||
'id' => $fare->id,
|
||||
'code' => $fare->code,
|
||||
'name' => $fare->name,
|
||||
'type' => $fare->type,
|
||||
'capacity' => $fare->capacity,
|
||||
'count' => $count,
|
||||
];
|
||||
|
||||
$loaddist[] = $fare->code.' '.$count;
|
||||
}
|
||||
|
||||
$tpayload = $tpaxload + $tbagload + $tcargoload;
|
||||
|
||||
$request->session()->put('simbrief_fares', array_merge($pax_load_sheet, $cargo_load_sheet));
|
||||
|
||||
// Show the main simbrief form
|
||||
return view('flights.simbrief_form', [
|
||||
'flight' => $flight,
|
||||
'aircraft' => $aircraft,
|
||||
'subfleets' => $subfleets,
|
||||
'pax_weight' => $pax_weight,
|
||||
'loadmin' => $loadmin,
|
||||
'loadmax' => $loadmax,
|
||||
'user' => Auth::user(),
|
||||
'flight' => $flight,
|
||||
'aircraft' => $aircraft,
|
||||
'pax_weight' => $pax_weight,
|
||||
'bag_weight' => $bag_weight,
|
||||
'loadmin' => $loadmin,
|
||||
'loadmax' => $loadmax,
|
||||
'pax_load_sheet' => $pax_load_sheet,
|
||||
'cargo_load_sheet' => $cargo_load_sheet,
|
||||
'tpaxfig' => $tpaxfig,
|
||||
'tpaxload' => $tpaxload,
|
||||
'tbagload' => $tbagload,
|
||||
'tpayload' => $tpayload,
|
||||
'tcargoload' => $tcargoload,
|
||||
'loaddist' => implode(' ', $loaddist),
|
||||
]);
|
||||
}
|
||||
|
||||
@@ -228,6 +334,7 @@ class SimBriefController
|
||||
|
||||
/**
|
||||
* Check whether the OFP was generated. Pass in two items, the flight_id and ofp_id
|
||||
* This does the actual "attachment" of the Simbrief to the flight
|
||||
*
|
||||
* @param \Illuminate\Http\Request $request
|
||||
*
|
||||
@@ -235,10 +342,14 @@ class SimBriefController
|
||||
*/
|
||||
public function check_ofp(Request $request)
|
||||
{
|
||||
/** @var User $user */
|
||||
$user = Auth::user();
|
||||
$ofp_id = $request->input('ofp_id');
|
||||
$flight_id = $request->input('flight_id');
|
||||
$aircraft_id = $request->input('aircraft_id');
|
||||
$fares = $request->session()->get('simbrief_fares', []);
|
||||
|
||||
$simbrief = $this->simBriefSvc->downloadOfp(Auth::user()->id, $ofp_id, $flight_id);
|
||||
$simbrief = $this->simBriefSvc->downloadOfp($user->id, $ofp_id, $flight_id, $aircraft_id, $fares);
|
||||
if ($simbrief === null) {
|
||||
$error = new AssetNotFound(new Exception('Simbrief OFP not found'));
|
||||
return $error->getResponse();
|
||||
|
||||
@@ -203,21 +203,21 @@ class InstallerController extends Controller
|
||||
Log::error('Testing db before writing configs failed');
|
||||
Log::error($e->getMessage());
|
||||
|
||||
Flash::error($e->getMessage());
|
||||
flash()->error($e->getMessage());
|
||||
return redirect(route('installer.step2'))->withInput();
|
||||
}
|
||||
|
||||
// Now write out the env file
|
||||
$attrs = [
|
||||
'SITE_NAME' => $request->post('site_name'),
|
||||
'SITE_URL' => $request->post('site_url'),
|
||||
'DB_CONN' => $request->post('db_conn'),
|
||||
'DB_HOST' => $request->post('db_host'),
|
||||
'DB_PORT' => $request->post('db_port'),
|
||||
'DB_NAME' => $request->post('db_name'),
|
||||
'DB_USER' => $request->post('db_user'),
|
||||
'DB_PASS' => $request->post('db_pass'),
|
||||
'DB_PREFIX' => $request->post('db_prefix'),
|
||||
'SITE_NAME' => $request->post('site_name'),
|
||||
'APP_URL' => $request->post('app_url'),
|
||||
'DB_CONNECTION' => $request->post('db_conn'),
|
||||
'DB_HOST' => $request->post('db_host'),
|
||||
'DB_PORT' => $request->post('db_port'),
|
||||
'DB_DATABASE' => $request->post('db_name'),
|
||||
'DB_USERNAME' => $request->post('db_user'),
|
||||
'DB_PASSWORD' => $request->post('db_pass'),
|
||||
'DB_PREFIX' => $request->post('db_prefix'),
|
||||
];
|
||||
|
||||
/*
|
||||
@@ -231,7 +231,7 @@ class InstallerController extends Controller
|
||||
Log::error('Config files failed to write');
|
||||
Log::error($e->getMessage());
|
||||
|
||||
Flash::error($e->getMessage());
|
||||
flash()->error($e->getMessage());
|
||||
return redirect(route('installer.step2'))->withInput();
|
||||
}
|
||||
|
||||
@@ -257,7 +257,7 @@ class InstallerController extends Controller
|
||||
Log::error('Error on db setup: '.$e->getMessage());
|
||||
//dd($e);
|
||||
$this->envSvc->removeConfigFiles();
|
||||
Flash::error($e->getMessage());
|
||||
flash()->error($e->getMessage());
|
||||
return redirect(route('installer.step2'))->withInput();
|
||||
}
|
||||
|
||||
|
||||
@@ -39,7 +39,7 @@ class ApiAuth implements Middleware
|
||||
return $this->unauthorized('User not found with key "'.$api_key.'"');
|
||||
}
|
||||
|
||||
if ($user->state !== UserState::ACTIVE) {
|
||||
if ($user->state !== UserState::ACTIVE && $user->state !== UserState::ON_LEAVE) {
|
||||
return $this->unauthorized('User is not ACTIVE, please contact an administrator');
|
||||
}
|
||||
|
||||
|
||||
@@ -52,7 +52,7 @@ class SetActiveTheme implements Middleware
|
||||
}
|
||||
|
||||
try {
|
||||
$theme = setting('general.theme');
|
||||
$theme = setting('general.theme', 'default');
|
||||
} catch (\Exception $e) {
|
||||
Log::error($e->getMessage());
|
||||
$theme = 'default';
|
||||
|
||||
@@ -9,7 +9,7 @@ class Bid extends Resource
|
||||
public function toArray($request)
|
||||
{
|
||||
$res = parent::toArray($request);
|
||||
$res['flight'] = new Flight($this->flight);
|
||||
$res['flight'] = new BidFlight($this->flight);
|
||||
|
||||
return $res;
|
||||
}
|
||||
|
||||
@@ -0,0 +1,36 @@
|
||||
<?php
|
||||
|
||||
namespace App\Http\Resources;
|
||||
|
||||
use App\Http\Resources\SimBrief as SimbriefResource;
|
||||
|
||||
/**
|
||||
* @mixin \App\Models\Flight
|
||||
*/
|
||||
class BidFlight extends Flight
|
||||
{
|
||||
/**
|
||||
* @param \Illuminate\Http\Request $request
|
||||
*
|
||||
* @throws \PhpUnitsOfMeasure\Exception\NonNumericValue
|
||||
* @throws \PhpUnitsOfMeasure\Exception\NonStringUnitName
|
||||
*
|
||||
* @return array
|
||||
*/
|
||||
public function toArray($request)
|
||||
{
|
||||
$res = parent::toArray($request);
|
||||
|
||||
if ($this->whenLoaded('simbrief')) {
|
||||
unset($res['subfleets']);
|
||||
$res['simbrief'] = new SimbriefResource($this->simbrief);
|
||||
} else {
|
||||
unset($res['simbrief']);
|
||||
$res['subfleets'] = Subfleet::collection($this->whenLoaded('subfleets'));
|
||||
}
|
||||
|
||||
$res['fields'] = $this->setFields();
|
||||
|
||||
return $res;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,41 @@
|
||||
<?php
|
||||
|
||||
namespace App\Http\Resources;
|
||||
|
||||
class BidSubfleet extends Subfleet
|
||||
{
|
||||
protected $aircraft;
|
||||
protected $fares;
|
||||
|
||||
public function __construct($resource, $aircraft, $fares)
|
||||
{
|
||||
parent::__construct($resource);
|
||||
|
||||
$this->aircraft = $aircraft;
|
||||
$this->fares = $fares;
|
||||
}
|
||||
|
||||
public function toArray($request)
|
||||
{
|
||||
$res = [];
|
||||
$res['airline_id'] = $this->airline_id;
|
||||
$res['hub_id'] = $this->hub_id;
|
||||
$res['type'] = $this->type;
|
||||
$res['simbrief_type'] = $this->simbrief_type;
|
||||
$res['name'] = $this->name;
|
||||
$res['fuel_type'] = $this->fuel_type;
|
||||
$res['cost_block_hour'] = $this->cost_block_hour;
|
||||
$res['cost_delay_minute'] = $this->cost_delay_minute;
|
||||
$res['ground_handling_multiplier'] = $this->ground_handling_multiplier;
|
||||
$res['cargo_capacity'] = $this->cargo_capacity;
|
||||
$res['fuel_capacity'] = $this->fuel_capacity;
|
||||
$res['gross_weight'] = $this->gross_weight;
|
||||
|
||||
$res['fares'] = Fare::collection($this->fares);
|
||||
|
||||
// There should only be one aircraft tied to a bid subfleet, wrap in a collection
|
||||
$res['aircraft'] = Aircraft::collection([$this->aircraft]);
|
||||
|
||||
return $res;
|
||||
}
|
||||
}
|
||||
@@ -17,6 +17,7 @@ class Fare extends Resource
|
||||
'name' => $this->name,
|
||||
'capacity' => $this->capacity,
|
||||
'cost' => $this->cost,
|
||||
'count' => $this->count ?? 0,
|
||||
'price' => $this->price,
|
||||
'type' => $this->type,
|
||||
'notes' => $this->notes,
|
||||
|
||||
@@ -15,7 +15,7 @@ class Flight extends Resource
|
||||
/**
|
||||
* Set the fields on the flight object
|
||||
*/
|
||||
private function setFields()
|
||||
protected function setFields()
|
||||
{
|
||||
/** @var \Illuminate\Support\Collection $field_values */
|
||||
$return_values = new stdClass();
|
||||
|
||||
@@ -38,6 +38,13 @@ class Pirep extends Resource
|
||||
$distance = new Distance($res['distance'], config('phpvms.internal_units.distance'));
|
||||
$res['distance'] = $distance->getResponseUnits();
|
||||
|
||||
if (!array_key_exists('block_fuel', $res)) {
|
||||
$res['block_fuel'] = 0;
|
||||
}
|
||||
|
||||
$block_fuel = new Fuel($res['block_fuel'], config('phpvms.internal_units.fuel'));
|
||||
$res['block_fuel'] = $block_fuel->getResponseUnits();
|
||||
|
||||
if (!array_key_exists('fuel_used', $res)) {
|
||||
$res['fuel_used'] = 0;
|
||||
}
|
||||
|
||||
@@ -11,9 +11,29 @@ class SimBrief extends Resource
|
||||
{
|
||||
public function toArray($request)
|
||||
{
|
||||
return [
|
||||
'id' => $this->id,
|
||||
'url' => url(route('api.flights.briefing', ['id' => $this->id])),
|
||||
$data = [
|
||||
'id' => $this->id,
|
||||
'aircraft_id' => $this->aircraft_id,
|
||||
'url' => url(route('api.flights.briefing', ['id' => $this->id])),
|
||||
];
|
||||
|
||||
$fares = [];
|
||||
|
||||
try {
|
||||
if (!empty($this->fare_data)) {
|
||||
$fare_data = json_decode($this->fare_data, true);
|
||||
foreach ($fare_data as $fare) {
|
||||
$fares[] = new \App\Models\Fare($fare);
|
||||
}
|
||||
|
||||
$fares = collect($fares);
|
||||
}
|
||||
} catch (\Exception $e) {
|
||||
// Invalid fare data
|
||||
}
|
||||
|
||||
$data['subfleet'] = new BidSubfleet($this->aircraft->subfleet, $this->aircraft, $fares);
|
||||
|
||||
return $data;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -15,9 +15,8 @@ class User extends Resource
|
||||
'id' => $this->id,
|
||||
'pilot_id' => $this->pilot_id,
|
||||
'ident' => $this->ident,
|
||||
'name' => $this->name,
|
||||
'name' => $this->name_private,
|
||||
'name_private' => $this->name_private,
|
||||
'email' => $this->email,
|
||||
'avatar' => $this->resolveAvatarUrl(),
|
||||
'rank_id' => $this->rank_id,
|
||||
'home_airport' => $this->home_airport_id,
|
||||
|
||||
@@ -3,8 +3,7 @@
|
||||
namespace App\Listeners;
|
||||
|
||||
use App\Contracts\Listener;
|
||||
use App\Events\PirepAccepted;
|
||||
use App\Events\PirepRejected;
|
||||
use App\Events\PirepFiled;
|
||||
use App\Services\BidService;
|
||||
|
||||
/**
|
||||
@@ -13,8 +12,7 @@ use App\Services\BidService;
|
||||
class BidEventHandler extends Listener
|
||||
{
|
||||
public static $callbacks = [
|
||||
PirepAccepted::class => 'onPirepAccept',
|
||||
PirepRejected::class => 'onPirepReject',
|
||||
PirepFiled::class => 'onPirepFiled',
|
||||
];
|
||||
|
||||
private $bidSvc;
|
||||
@@ -25,29 +23,15 @@ class BidEventHandler extends Listener
|
||||
}
|
||||
|
||||
/**
|
||||
* When a PIREP is accepted, remove any bids
|
||||
* When a PIREP is filed, remove any bids
|
||||
*
|
||||
* @param PirepAccepted $event
|
||||
* @param PirepFiled $event
|
||||
*
|
||||
* @throws \UnexpectedValueException
|
||||
* @throws \InvalidArgumentException
|
||||
* @throws \Exception
|
||||
*/
|
||||
public function onPirepAccept(PirepAccepted $event): void
|
||||
{
|
||||
$this->bidSvc->removeBidForPirep($event->pirep);
|
||||
}
|
||||
|
||||
/**
|
||||
* When a PIREP is accepted, remove any bids
|
||||
*
|
||||
* @param PirepRejected $event
|
||||
*
|
||||
* @throws \UnexpectedValueException
|
||||
* @throws \InvalidArgumentException
|
||||
* @throws \Exception
|
||||
*/
|
||||
public function onPirepReject(PirepRejected $event): void
|
||||
public function onPirepFiled(PirepFiled $event): void
|
||||
{
|
||||
$this->bidSvc->removeBidForPirep($event->pirep);
|
||||
}
|
||||
|
||||
@@ -0,0 +1,29 @@
|
||||
<?php
|
||||
|
||||
namespace App\Listeners;
|
||||
|
||||
use App\Contracts\Listener;
|
||||
use App\Events\PirepPrefiled;
|
||||
|
||||
/**
|
||||
* Look for and run any of the award classes. Don't modify this.
|
||||
* See the documentation on creating awards:
|
||||
*
|
||||
* @url http://docs.phpvms.net/customizing/awards
|
||||
*/
|
||||
class PirepEventsHandler extends Listener
|
||||
{
|
||||
/** The events and the callback */
|
||||
public static $callbacks = [
|
||||
PirepPrefiled::class => 'onPirepPrefile',
|
||||
];
|
||||
|
||||
/**
|
||||
* Called when a PIREP is prefiled
|
||||
*
|
||||
* @param PirepPrefiled $event
|
||||
*/
|
||||
public function onPirepPrefile(PirepPrefiled $event)
|
||||
{
|
||||
}
|
||||
}
|
||||
@@ -24,6 +24,7 @@ use Carbon\Carbon;
|
||||
* @property int status
|
||||
* @property int state
|
||||
* @property Carbon landing_time
|
||||
* @property float fuel_onboard
|
||||
*/
|
||||
class Aircraft extends Model
|
||||
{
|
||||
|
||||
@@ -46,6 +46,7 @@ class Airport extends Model
|
||||
'lon',
|
||||
'hub',
|
||||
'timezone',
|
||||
'tz',
|
||||
'ground_handling_cost',
|
||||
'fuel_100ll_cost',
|
||||
'fuel_jeta_cost',
|
||||
|
||||
@@ -11,6 +11,7 @@ class UserState extends Enum
|
||||
public const REJECTED = 2;
|
||||
public const ON_LEAVE = 3;
|
||||
public const SUSPENDED = 4;
|
||||
public const DELETED = 5;
|
||||
|
||||
protected static $labels = [
|
||||
self::PENDING => 'user.state.pending',
|
||||
@@ -18,5 +19,6 @@ class UserState extends Enum
|
||||
self::REJECTED => 'user.state.rejected',
|
||||
self::ON_LEAVE => 'user.state.on_leave',
|
||||
self::SUSPENDED => 'user.state.suspended',
|
||||
self::DELETED => 'user.state.deleted',
|
||||
];
|
||||
}
|
||||
|
||||
@@ -20,12 +20,14 @@ class Fare extends Model
|
||||
public $table = 'fares';
|
||||
|
||||
protected $fillable = [
|
||||
'id',
|
||||
'code',
|
||||
'name',
|
||||
'type',
|
||||
'price',
|
||||
'cost',
|
||||
'capacity',
|
||||
'count',
|
||||
'notes',
|
||||
'active',
|
||||
];
|
||||
@@ -34,6 +36,7 @@ class Fare extends Model
|
||||
'price' => 'float',
|
||||
'cost' => 'float',
|
||||
'capacity' => 'integer',
|
||||
'count' => 'integer',
|
||||
'type' => 'integer',
|
||||
'active' => 'boolean',
|
||||
];
|
||||
|
||||
@@ -15,6 +15,7 @@ use Illuminate\Support\Collection;
|
||||
* @property Airline airline
|
||||
* @property int airline_id
|
||||
* @property mixed flight_number
|
||||
* @property mixed callsign
|
||||
* @property mixed route_code
|
||||
* @property int route_leg
|
||||
* @property bool has_bid
|
||||
@@ -60,6 +61,7 @@ class Flight extends Model
|
||||
'id',
|
||||
'airline_id',
|
||||
'flight_number',
|
||||
'callsign',
|
||||
'route_code',
|
||||
'route_leg',
|
||||
'dpt_airport_id',
|
||||
@@ -104,6 +106,7 @@ class Flight extends Model
|
||||
public static $rules = [
|
||||
'airline_id' => 'required|exists:airlines,id',
|
||||
'flight_number' => 'required',
|
||||
'callsign' => 'string|max:4|nullable',
|
||||
'route_code' => 'nullable',
|
||||
'route_leg' => 'nullable',
|
||||
'dpt_airport_id' => 'required|exists:airports,id',
|
||||
|
||||
@@ -186,7 +186,7 @@ class Journal extends Model
|
||||
*/
|
||||
public function getCurrentBalance()
|
||||
{
|
||||
return $this->getBalanceOn(Carbon::now());
|
||||
return $this->getBalanceOn(Carbon::now('UTC'));
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -0,0 +1,23 @@
|
||||
<?php
|
||||
|
||||
namespace App\Models;
|
||||
|
||||
use App\Contracts\Model;
|
||||
|
||||
/**
|
||||
* @property string key
|
||||
* @property string value
|
||||
*/
|
||||
class Kvp extends Model
|
||||
{
|
||||
public $table = 'kvp';
|
||||
public $timestamps = false;
|
||||
public $incrementing = false;
|
||||
|
||||
protected $keyType = 'string';
|
||||
|
||||
public $fillable = [
|
||||
'key',
|
||||
'value',
|
||||
];
|
||||
}
|
||||
+20
-2
@@ -305,7 +305,9 @@ class Pirep extends Model
|
||||
public function getFieldsAttribute()
|
||||
{
|
||||
$custom_fields = PirepField::all();
|
||||
$field_values = PirepFieldValue::where('pirep_id', $this->id)->get();
|
||||
$field_values = PirepFieldValue::where('pirep_id', $this->id)
|
||||
->orderBy('created_at', 'asc')
|
||||
->get();
|
||||
|
||||
// Merge the field values into $fields
|
||||
foreach ($custom_fields as $field) {
|
||||
@@ -321,7 +323,23 @@ class Pirep extends Model
|
||||
}
|
||||
}
|
||||
|
||||
return $field_values->sortBy('source');
|
||||
return $field_values;
|
||||
}
|
||||
|
||||
/**
|
||||
* Set the amount of block fuel
|
||||
*
|
||||
* @param $value
|
||||
*/
|
||||
public function setBlockFuelAttribute($value): void
|
||||
{
|
||||
if ($value instanceof Fuel) {
|
||||
$this->attributes['block_fuel'] = $value->toUnit(
|
||||
config('phpvms.internal_units.fuel')
|
||||
);
|
||||
} else {
|
||||
$this->attributes['block_fuel'] = $value;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
+9
-1
@@ -5,6 +5,12 @@ namespace App\Models;
|
||||
use Laratrust\Models\LaratrustRole;
|
||||
|
||||
/**
|
||||
* @property int id
|
||||
* @property string name
|
||||
* @property string display_name
|
||||
* @property bool read_only
|
||||
* @property bool disable_activity_checks
|
||||
*
|
||||
* @mixin \Illuminate\Database\Eloquent\Builder
|
||||
*/
|
||||
class Role extends LaratrustRole
|
||||
@@ -14,10 +20,12 @@ class Role extends LaratrustRole
|
||||
'name',
|
||||
'display_name',
|
||||
'read_only',
|
||||
'disable_activity_checks',
|
||||
];
|
||||
|
||||
protected $casts = [
|
||||
'read_only' => 'boolean',
|
||||
'read_only' => 'boolean',
|
||||
'disable_activity_checks' => 'boolean',
|
||||
];
|
||||
|
||||
/**
|
||||
|
||||
+11
-1
@@ -10,14 +10,17 @@ use Illuminate\Support\Collection;
|
||||
* @property int $user_id The user that generated this
|
||||
* @property string $flight_id Optional, if attached to a flight, removed if attached to PIREP
|
||||
* @property string $pirep_id Optional, if attached to a PIREP, removed if attached to flight
|
||||
* @property string $aircraft_id The aircraft this is for
|
||||
* @property string $acars_xml
|
||||
* @property string $ofp_xml
|
||||
* @property string $ofp_html
|
||||
* @property string $fare_data JSON string of the fare data that was generated
|
||||
* @property Collection $images
|
||||
* @property Collection $files
|
||||
* @property Flight $flight
|
||||
* @property User $user
|
||||
* @property SimBriefXML $xml
|
||||
* @property Aircraft $aircraft
|
||||
* @property string $acars_flightplan_url
|
||||
*/
|
||||
class SimBrief extends Model
|
||||
@@ -29,9 +32,11 @@ class SimBrief extends Model
|
||||
'id',
|
||||
'user_id',
|
||||
'flight_id',
|
||||
'aircraft_id',
|
||||
'pirep_id',
|
||||
'acars_xml',
|
||||
'ofp_xml',
|
||||
'fare_data',
|
||||
'created_at',
|
||||
'updated_at',
|
||||
];
|
||||
@@ -44,7 +49,7 @@ class SimBrief extends Model
|
||||
*
|
||||
* @return \App\Models\SimBriefXML|null
|
||||
*/
|
||||
public function getXmlAttribute(): SimBriefXML
|
||||
public function getXmlAttribute(): ?SimBriefXML
|
||||
{
|
||||
if (empty($this->attributes['ofp_xml'])) {
|
||||
return null;
|
||||
@@ -80,6 +85,11 @@ class SimBrief extends Model
|
||||
* Relationships
|
||||
*/
|
||||
|
||||
public function aircraft()
|
||||
{
|
||||
return $this->belongsTo(Aircraft::class, 'aircraft_id');
|
||||
}
|
||||
|
||||
public function flight()
|
||||
{
|
||||
if (!empty($this->attributes['flight_id'])) {
|
||||
|
||||
@@ -10,6 +10,7 @@ use App\Models\Traits\FilesTrait;
|
||||
/**
|
||||
* @property int id
|
||||
* @property string type
|
||||
* @property string simbrief_type
|
||||
* @property string name
|
||||
* @property int airline_id
|
||||
* @property int hub_id
|
||||
@@ -29,6 +30,7 @@ class Subfleet extends Model
|
||||
'airline_id',
|
||||
'hub_id',
|
||||
'type',
|
||||
'simbrief_type',
|
||||
'name',
|
||||
'fuel_type',
|
||||
'cost_block_hour',
|
||||
|
||||
@@ -38,6 +38,8 @@ use Laratrust\Traits\LaratrustUserTrait;
|
||||
* @property string last_pirep_id
|
||||
* @property Pirep last_pirep
|
||||
* @property UserFieldValue[] fields
|
||||
* @property Role[] roles
|
||||
* @property Subfleet[] subfleets
|
||||
*
|
||||
* @mixin \Illuminate\Database\Eloquent\Builder
|
||||
* @mixin \Illuminate\Notifications\Notifiable
|
||||
|
||||
@@ -46,14 +46,20 @@ class EventHandler extends Listener
|
||||
*
|
||||
* @param \App\Contracts\Notification $notification
|
||||
*/
|
||||
protected function notifyAdmins($notification)
|
||||
protected function notifyAdmins(\App\Contracts\Notification $notification)
|
||||
{
|
||||
$admin_users = User::whereRoleIs('admin')->get();
|
||||
|
||||
try {
|
||||
Notification::send($admin_users, $notification);
|
||||
} catch (Exception $e) {
|
||||
Log::emergency('Error emailing admins, malformed email='.$e->getMessage());
|
||||
foreach ($admin_users as $user) {
|
||||
if (empty($user->email)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
try {
|
||||
Notification::send([$user], $notification);
|
||||
} catch (Exception $e) {
|
||||
Log::emergency('Error emailing admin ('.$user->email.'). Error='.$e->getMessage());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -61,12 +67,16 @@ class EventHandler extends Listener
|
||||
* @param User $user
|
||||
* @param \App\Contracts\Notification $notification
|
||||
*/
|
||||
protected function notifyUser($user, $notification)
|
||||
protected function notifyUser(User $user, \App\Contracts\Notification $notification)
|
||||
{
|
||||
if ($user->state === UserState::DELETED) {
|
||||
return;
|
||||
}
|
||||
|
||||
try {
|
||||
$user->notify($notification);
|
||||
} catch (Exception $e) {
|
||||
Log::emergency('Error emailing admins, malformed email='.$e->getMessage());
|
||||
Log::emergency('Error emailing user, '.$user->ident.'='.$user->email.', error='.$e->getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
@@ -84,17 +94,15 @@ class EventHandler extends Listener
|
||||
}
|
||||
|
||||
/** @var Collection $users */
|
||||
$users = User::where($where)->get();
|
||||
$users = User::where($where)->where('state', '<>', UserState::DELETED)->get();
|
||||
if (empty($users) || $users->count() === 0) {
|
||||
return;
|
||||
}
|
||||
|
||||
Log::info('Sending notification to '.$users->count().' users');
|
||||
|
||||
try {
|
||||
Notification::send($users, $notification);
|
||||
} catch (Exception $e) {
|
||||
Log::emergency('Error emailing admins, malformed email='.$e->getMessage());
|
||||
foreach ($users as $user) {
|
||||
$this->notifyUser($user, $notification);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -22,7 +22,7 @@ class NewsAdded extends Notification
|
||||
$this->news = $news;
|
||||
$this->setMailable(
|
||||
$news->subject,
|
||||
'notifications.mail.news',
|
||||
'notifications.mail.news.news',
|
||||
['news' => $news]
|
||||
);
|
||||
}
|
||||
|
||||
@@ -3,7 +3,9 @@
|
||||
namespace App\Providers;
|
||||
|
||||
use App\Services\ModuleService;
|
||||
use App\Support\ThemeViewFinder;
|
||||
use App\Support\Utils;
|
||||
use Illuminate\Pagination\Paginator;
|
||||
use Illuminate\Support\Facades\Schema;
|
||||
use Illuminate\Support\Facades\View;
|
||||
use Illuminate\Support\ServiceProvider;
|
||||
@@ -13,6 +15,7 @@ class AppServiceProvider extends ServiceProvider
|
||||
public function boot(): void
|
||||
{
|
||||
Schema::defaultStringLength(191);
|
||||
Paginator::useBootstrap();
|
||||
View::share('moduleSvc', app(ModuleService::class));
|
||||
}
|
||||
|
||||
@@ -21,6 +24,14 @@ class AppServiceProvider extends ServiceProvider
|
||||
*/
|
||||
public function register(): void
|
||||
{
|
||||
$this->app->singleton('view.finder', function ($app) {
|
||||
return new ThemeViewFinder(
|
||||
$app['files'],
|
||||
$app['config']['view.paths'],
|
||||
null
|
||||
);
|
||||
});
|
||||
|
||||
// Only load the IDE helper if it's included and enabled
|
||||
if (config('app.debug') === true) {
|
||||
/* @noinspection NestedPositiveIfStatementsInspection */
|
||||
|
||||
@@ -2,6 +2,7 @@
|
||||
|
||||
namespace App\Providers;
|
||||
|
||||
use App\Cron\Hourly\DeletePireps;
|
||||
use App\Cron\Hourly\RemoveExpiredBids;
|
||||
use App\Cron\Hourly\RemoveExpiredLiveFlights;
|
||||
use App\Cron\Nightly\ApplyExpenses;
|
||||
@@ -41,6 +42,7 @@ class CronServiceProvider extends ServiceProvider
|
||||
],
|
||||
|
||||
CronHourly::class => [
|
||||
DeletePireps::class,
|
||||
RemoveExpiredBids::class,
|
||||
RemoveExpiredLiveFlights::class,
|
||||
],
|
||||
|
||||
@@ -9,6 +9,7 @@ use App\Listeners\AwardHandler;
|
||||
use App\Listeners\BidEventHandler;
|
||||
use App\Listeners\ExpenseListener;
|
||||
use App\Listeners\FinanceEventHandler;
|
||||
use App\Listeners\PirepEventsHandler;
|
||||
use App\Listeners\UserStateListener;
|
||||
use App\Notifications\EventHandler;
|
||||
use Codedge\Updater\Events\UpdateAvailable;
|
||||
@@ -45,5 +46,6 @@ class EventServiceProvider extends ServiceProvider
|
||||
FinanceEventHandler::class,
|
||||
EventHandler::class,
|
||||
AwardHandler::class,
|
||||
PirepEventsHandler::class,
|
||||
];
|
||||
}
|
||||
|
||||
@@ -392,6 +392,12 @@ class RouteServiceProvider extends ServiceProvider
|
||||
Route::match(['post'], 'maintenance/forcecheck', 'MaintenanceController@forcecheck')
|
||||
->name('maintenance.forcecheck')->middleware('ability:admin,maintenance');
|
||||
|
||||
Route::match(['post'], 'maintenance/cron_enable', 'MaintenanceController@cron_enable')
|
||||
->name('maintenance.cron_enable')->middleware('ability:admin,maintenance');
|
||||
|
||||
Route::match(['post'], 'maintenance/cron_disable', 'MaintenanceController@cron_disable')
|
||||
->name('maintenance.cron_disable')->middleware('ability:admin,maintenance');
|
||||
|
||||
// subfleet
|
||||
Route::get('subfleets/export', 'SubfleetController@export')
|
||||
->name('subfleets.export')->middleware('ability:admin,fleet');
|
||||
@@ -459,7 +465,7 @@ class RouteServiceProvider extends ServiceProvider
|
||||
Route::group([
|
||||
'as' => 'modules.',
|
||||
'prefix' => 'modules',
|
||||
'middleware' => ['ability:admin, modules'],
|
||||
'middleware' => ['ability:admin,modules'],
|
||||
], function () {
|
||||
|
||||
//Modules Index
|
||||
@@ -508,6 +514,8 @@ class RouteServiceProvider extends ServiceProvider
|
||||
Route::get('pireps/{pirep_id}', 'PirepController@get');
|
||||
Route::get('pireps/{pirep_id}/acars/geojson', 'AcarsController@acars_geojson');
|
||||
|
||||
Route::get('cron/{id}', 'MaintenanceController@cron')->name('maintenance.cron');
|
||||
|
||||
Route::get('news', 'NewsController@index');
|
||||
Route::get('status', 'StatusController@status');
|
||||
Route::get('version', 'StatusController@status');
|
||||
|
||||
@@ -147,7 +147,7 @@ class JournalRepository extends Repository implements CacheableInterface
|
||||
$journal->refresh();
|
||||
|
||||
if (!$date) {
|
||||
$date = Carbon::now();
|
||||
$date = Carbon::now('UTC');
|
||||
}
|
||||
|
||||
$credit = $this->getCreditBalanceBetween($date, $journal);
|
||||
|
||||
@@ -41,7 +41,7 @@ class SubfleetRepository extends Repository implements CacheableInterface
|
||||
}
|
||||
|
||||
foreach ($items as $i) {
|
||||
$retval[$i->id] = $i->name;
|
||||
$retval[$i->id] = $i->name.' | '.$i->airline->icao;
|
||||
}
|
||||
|
||||
return $retval;
|
||||
|
||||
@@ -28,6 +28,7 @@ class VaCentralLookup extends AirportLookup
|
||||
try {
|
||||
$airport = $this->client->getAirport($icao);
|
||||
$airport->location = $airport->city;
|
||||
$airport->timezone = $airport->tz;
|
||||
|
||||
return $airport;
|
||||
} catch (HttpException $e) {
|
||||
|
||||
@@ -2,7 +2,7 @@
|
||||
|
||||
namespace App\Services;
|
||||
|
||||
use App\Contracts\AirportLookup as AirportLookupProvider;
|
||||
use App\Contracts\AirportLookup;
|
||||
use App\Contracts\Metar as MetarProvider;
|
||||
use App\Contracts\Service;
|
||||
use App\Exceptions\AirportNotFound;
|
||||
@@ -23,7 +23,7 @@ class AirportService extends Service
|
||||
private $metarProvider;
|
||||
|
||||
public function __construct(
|
||||
AirportLookupProvider $lookupProvider,
|
||||
AirportLookup $lookupProvider,
|
||||
AirportRepository $airportRepo,
|
||||
MetarProvider $metarProvider
|
||||
) {
|
||||
|
||||
@@ -47,19 +47,26 @@ class BidService extends Service
|
||||
*/
|
||||
public function findBidsForUser(User $user)
|
||||
{
|
||||
$bids = Bid::with([
|
||||
$with = [
|
||||
'flight',
|
||||
'flight.fares',
|
||||
'flight.simbrief',
|
||||
'flight.simbrief' => function ($query) use ($user) {
|
||||
$query->where('user_id', $user->id);
|
||||
},
|
||||
'flight.simbrief.aircraft',
|
||||
'flight.simbrief.aircraft.subfleet',
|
||||
'flight.subfleets',
|
||||
'flight.subfleets.aircraft',
|
||||
'flight.subfleets.fares',
|
||||
])
|
||||
->where(['user_id' => $user->id])->get();
|
||||
];
|
||||
|
||||
$bids = Bid::with($with)->where(['user_id' => $user->id])->get();
|
||||
|
||||
foreach ($bids as $bid) {
|
||||
// if (empty($bid->flight->simbrief)) {
|
||||
$bid->flight = $this->flightSvc->filterSubfleets($user, $bid->flight);
|
||||
$bid->flight = $this->fareSvc->getReconciledFaresForFlight($bid->flight);
|
||||
// }
|
||||
}
|
||||
|
||||
return $bids;
|
||||
@@ -162,10 +169,6 @@ class BidService extends Service
|
||||
*/
|
||||
public function removeBidForPirep(Pirep $pirep)
|
||||
{
|
||||
if (!setting('pireps.remove_bid_on_accept')) {
|
||||
return;
|
||||
}
|
||||
|
||||
$flight = $pirep->flight;
|
||||
if (!$flight) {
|
||||
return;
|
||||
|
||||
@@ -172,6 +172,24 @@ class FareService extends Service
|
||||
return $fare;
|
||||
}
|
||||
|
||||
/**
|
||||
* Return all the fares for an aircraft. check the pivot
|
||||
* table to see if the price/cost/capacity has been overridden
|
||||
* and return the correct amounts.
|
||||
*
|
||||
* @param Subfleet $subfleet
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function getForSubfleet(Subfleet $subfleet)
|
||||
{
|
||||
$fares = $subfleet->fares->map(function ($fare) {
|
||||
return $this->getFares($fare);
|
||||
});
|
||||
|
||||
return $fares;
|
||||
}
|
||||
|
||||
/**
|
||||
* Attach a fare to an flight
|
||||
*
|
||||
@@ -240,24 +258,6 @@ class FareService extends Service
|
||||
return $subfleet;
|
||||
}
|
||||
|
||||
/**
|
||||
* return all the fares for an aircraft. check the pivot
|
||||
* table to see if the price/cost/capacity has been overridden
|
||||
* and return the correct amounts.
|
||||
*
|
||||
* @param Subfleet $subfleet
|
||||
*
|
||||
* @return Collection
|
||||
*/
|
||||
public function getForSubfleet(Subfleet $subfleet)
|
||||
{
|
||||
$fares = $subfleet->fares->map(function ($fare) {
|
||||
return $this->getFares($fare);
|
||||
});
|
||||
|
||||
return $fares;
|
||||
}
|
||||
|
||||
/**
|
||||
* Delete the fare from a subfleet
|
||||
*
|
||||
|
||||
@@ -152,17 +152,43 @@ class PirepFinanceService extends Service
|
||||
public function payFuelCosts(Pirep $pirep): void
|
||||
{
|
||||
$ap = $pirep->dpt_airport;
|
||||
$fuel_used = $pirep->fuel_used;
|
||||
// Get Airport Fuel Cost or revert back to settings
|
||||
if (empty($ap->fuel_jeta_cost)) {
|
||||
$fuel_cost = setting('airports.default_jet_a_fuel_cost');
|
||||
} else {
|
||||
$fuel_cost = $ap->fuel_jeta_cost;
|
||||
}
|
||||
|
||||
$debit = Money::createFromAmount($fuel_used * $ap->fuel_jeta_cost);
|
||||
Log::info('Finance: Fuel cost, (fuel='.$fuel_used.', cost='.$ap->fuel_jeta_cost.') D='
|
||||
if (setting('pireps.advanced_fuel', false)) {
|
||||
$ac = $pirep->aircraft;
|
||||
// Reading second row by skip(1) to reach the previous accepted pirep. Current pirep is at the first row
|
||||
$prev_flight = Pirep::where('aircraft_id', $ac->id)->where('state', 2)->where('status', 'ONB')->orderby('submitted_at', 'desc')->skip(1)->first();
|
||||
if ($prev_flight) {
|
||||
// If there is a pirep use its values to calculate the remaining fuel
|
||||
// and calculate the uplifted fuel amount for this pirep
|
||||
$fuel_amount = $pirep->block_fuel - ($prev_flight->block_fuel - $prev_flight->fuel_used);
|
||||
// Aircraft has more than enough fuel in its tanks, no uplift necessary
|
||||
if ($fuel_amount < 0) {
|
||||
$fuel_amount = 0;
|
||||
}
|
||||
} else {
|
||||
// No pirep found for aircraft, debit full block fuel
|
||||
$fuel_amount = $pirep->block_fuel;
|
||||
}
|
||||
} else {
|
||||
// Setting is false, switch back to basic calculation
|
||||
$fuel_amount = $pirep->fuel_used;
|
||||
}
|
||||
|
||||
$debit = Money::createFromAmount($fuel_amount * $fuel_cost);
|
||||
Log::info('Finance: Fuel cost, (fuel='.$fuel_amount.', cost='.$fuel_cost.') D='
|
||||
.$debit->getAmount());
|
||||
|
||||
$this->financeSvc->debitFromJournal(
|
||||
$pirep->airline->journal,
|
||||
$debit,
|
||||
$pirep,
|
||||
'Fuel Cost ('.$ap->fuel_jeta_cost.'/'.config('phpvms.internal_units.fuel').')',
|
||||
'Fuel Cost ('.$fuel_cost.'/'.config('phpvms.internal_units.fuel').')',
|
||||
'Fuel',
|
||||
'fuel'
|
||||
);
|
||||
@@ -396,14 +422,26 @@ class PirepFinanceService extends Service
|
||||
*/
|
||||
public function payGroundHandlingForPirep(Pirep $pirep): void
|
||||
{
|
||||
$ground_handling_cost = $this->getGroundHandlingCost($pirep);
|
||||
Log::info('Finance: PIREP: '.$pirep->id.'; ground handling: '.$ground_handling_cost);
|
||||
$ground_handling_cost = $this->getGroundHandlingCost($pirep, $pirep->dpt_airport);
|
||||
Log::info('Finance: PIREP: '.$pirep->id.'; dpt ground handling: '.$ground_handling_cost);
|
||||
|
||||
$this->financeSvc->debitFromJournal(
|
||||
$pirep->airline->journal,
|
||||
Money::createFromAmount($ground_handling_cost),
|
||||
$pirep,
|
||||
'Ground Handling (Departure)',
|
||||
'Ground Handling',
|
||||
'ground_handling'
|
||||
);
|
||||
|
||||
$ground_handling_cost = $this->getGroundHandlingCost($pirep, $pirep->arr_airport);
|
||||
Log::info('Finance: PIREP: '.$pirep->id.'; arr ground handling: '.$ground_handling_cost);
|
||||
|
||||
$this->financeSvc->debitFromJournal(
|
||||
$pirep->airline->journal,
|
||||
Money::createFromAmount($ground_handling_cost),
|
||||
$pirep,
|
||||
'Ground Handling (Arrival)',
|
||||
'Ground Handling',
|
||||
'ground_handling'
|
||||
);
|
||||
@@ -506,23 +544,26 @@ class PirepFinanceService extends Service
|
||||
* Return the costs for the ground handling, with the multiplier
|
||||
* being applied from the subfleet
|
||||
*
|
||||
* @param Pirep $pirep
|
||||
* @param Pirep $pirep
|
||||
* @param Airport $airport
|
||||
*
|
||||
* @return float|null
|
||||
*/
|
||||
public function getGroundHandlingCost(Pirep $pirep)
|
||||
public function getGroundHandlingCost(Pirep $pirep, Airport $airport): ?float
|
||||
{
|
||||
if (filled($pirep->aircraft->subfleet->ground_handling_multiplier)) {
|
||||
// force into percent mode
|
||||
$multiplier = $pirep->aircraft->subfleet->ground_handling_multiplier.'%';
|
||||
|
||||
return Math::applyAmountOrPercent(
|
||||
$pirep->arr_airport->ground_handling_cost,
|
||||
$multiplier
|
||||
);
|
||||
if (empty($airport->ground_handling_cost)) {
|
||||
$gh_cost = setting('airports.default_ground_handling_cost');
|
||||
} else {
|
||||
$gh_cost = $airport->ground_handling_cost;
|
||||
}
|
||||
|
||||
return $pirep->arr_airport->ground_handling_cost;
|
||||
if (!filled($pirep->aircraft->subfleet->ground_handling_multiplier)) {
|
||||
return $gh_cost;
|
||||
}
|
||||
|
||||
// force into percent mode
|
||||
$multiplier = $pirep->aircraft->subfleet->ground_handling_multiplier.'%';
|
||||
return Math::applyAmountOrPercent($gh_cost, $multiplier);
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -66,6 +66,10 @@ class RecurringFinanceService extends Service
|
||||
$obj = $expense->getReferencedObject();
|
||||
}
|
||||
|
||||
if (empty($obj)) {
|
||||
return [null, null];
|
||||
}
|
||||
|
||||
if ($klass === 'Airport') {
|
||||
$memo = "Airport Expense: {$expense->name} ({$expense->ref_model_id})";
|
||||
$transaction_group = "Airport: {$expense->ref_model_id}";
|
||||
@@ -128,6 +132,9 @@ class RecurringFinanceService extends Service
|
||||
}
|
||||
|
||||
[$memo, $ta_group] = $this->getMemoAndGroup($expense);
|
||||
if (empty($memo) || empty($ta_group)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
$this->financeSvc->debitFromJournal(
|
||||
$journal,
|
||||
|
||||
@@ -135,6 +135,9 @@ class FlightService extends Service
|
||||
*/
|
||||
public function filterSubfleets(User $user, Flight $flight)
|
||||
{
|
||||
// Eager load some of the relationships needed
|
||||
//$flight->load(['flight.subfleets', 'flight.subfleets.aircraft', 'flight.subfleets.fares']);
|
||||
|
||||
/** @var \Illuminate\Support\Collection $subfleets */
|
||||
$subfleets = $flight->subfleets;
|
||||
|
||||
|
||||
@@ -209,7 +209,7 @@ class FlightImporter extends ImportExport
|
||||
$count = 0;
|
||||
$subfleets = $this->parseMultiColumnValues($col);
|
||||
foreach ($subfleets as $subfleet_type) {
|
||||
$subfleet = Subfleet::updateOrCreate(
|
||||
$subfleet = Subfleet::firstOrCreate(
|
||||
['type' => $subfleet_type],
|
||||
['name' => $subfleet_type]
|
||||
);
|
||||
|
||||
@@ -31,12 +31,12 @@ class AirportImporter extends BaseImporter
|
||||
$ground_handling_cost = (float) $row->ground_handling_cost;
|
||||
$fuel_jetA_cost = (float) $row->fuel_jeta_cost;
|
||||
|
||||
if ($ground_handling_cost === null && $ground_handling_cost !== 0) {
|
||||
$ground_handling_cost = (float) setting('general.default_ground_handling_cost');
|
||||
if (empty($ground_handling_cost)) {
|
||||
$ground_handling_cost = 0;
|
||||
}
|
||||
|
||||
if ($fuel_jetA_cost === null && $fuel_jetA_cost !== 0) {
|
||||
$fuel_jetA_cost = (float) setting('general.default_jetA_fuel_cost');
|
||||
if (empty($fuel_jetA_cost)) {
|
||||
$fuel_jetA_cost = 0;
|
||||
}
|
||||
|
||||
$attrs = [
|
||||
|
||||
@@ -15,34 +15,49 @@ use Symfony\Component\HttpFoundation\File\Exception\FileException;
|
||||
|
||||
class ConfigService extends Service
|
||||
{
|
||||
protected static $defaultValues = [
|
||||
'APP_ENV' => 'prod',
|
||||
'APP_KEY' => '',
|
||||
'APP_DEBUG' => true,
|
||||
'APP_LOCALE' => 'en',
|
||||
'DEBUG_TOOLBAR' => false,
|
||||
'SITE_NAME' => '',
|
||||
'APP_URL' => 'http://phpvms.test',
|
||||
'DB_CONNECTION' => '',
|
||||
'DB_HOST' => '',
|
||||
'DB_PORT' => 3306,
|
||||
'DB_DATABASE' => '',
|
||||
'DB_USERNAME' => '',
|
||||
'DB_PASSWORD' => '',
|
||||
'DB_PREFIX' => '',
|
||||
'DB_EMULATE_PREPARES' => false,
|
||||
'CACHE_DRIVER' => 'array',
|
||||
'CACHE_PREFIX' => '',
|
||||
'MAIL_DRIVER' => 'mail',
|
||||
'MAIL_HOST' => '',
|
||||
'MAIL_PORT' => 587,
|
||||
'MAIL_ENCRYPTION' => '',
|
||||
'MAIL_USERNAME' => '',
|
||||
'MAIL_PASSWORD' => '',
|
||||
'MAIL_FROM_NAME' => 'phpVMS Admin',
|
||||
'MAIL_FROM_ADDRESS' => 'no-reply@phpvms.net',
|
||||
];
|
||||
|
||||
/**
|
||||
* Create the .env file
|
||||
* Create the .env file. This is called by an initial install
|
||||
*
|
||||
* @param $attrs
|
||||
*
|
||||
* @throws \Symfony\Component\HttpFoundation\File\Exception\FileException
|
||||
* @throws FileException
|
||||
*
|
||||
* @return bool
|
||||
*/
|
||||
public function createConfigFiles($attrs): bool
|
||||
{
|
||||
$opts = [
|
||||
'APP_ENV' => 'dev',
|
||||
'APP_KEY' => $this->createAppKey(),
|
||||
'SITE_NAME' => '',
|
||||
'SITE_URL' => 'http://phpvms.test',
|
||||
'CACHE_PREFIX' => '',
|
||||
'DB_CONN' => '',
|
||||
'DB_HOST' => '',
|
||||
'DB_PORT' => 3306,
|
||||
'DB_NAME' => '',
|
||||
'DB_USER' => '',
|
||||
'DB_PASS' => '',
|
||||
'DB_PREFIX' => '',
|
||||
'DB_EMULATE_PREPARES' => false,
|
||||
];
|
||||
|
||||
$opts = array_merge($opts, $attrs);
|
||||
$opts = array_merge(static::$defaultValues, $attrs);
|
||||
if (empty($opts['APP_KEY'])) {
|
||||
$opts['APP_KEY'] = $this->createAppKey();
|
||||
}
|
||||
|
||||
$opts = $this->determinePdoOptions($opts);
|
||||
$opts = $this->configCacheDriver($opts);
|
||||
@@ -53,6 +68,61 @@ class ConfigService extends Service
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Rewrite the config files - this means mapping the values that are currently
|
||||
* loaded in the config and rewriting them into the env.php file, and then renaming
|
||||
* the config.php files to config.bak.php
|
||||
*
|
||||
* This is called from the migrations which removes the old config.php file
|
||||
*/
|
||||
public function rewriteConfigFiles()
|
||||
{
|
||||
/*$cfg_file = App::environmentPath().'/config.php';
|
||||
if (!file_exists($cfg_file)) {
|
||||
Log::info('Main config.php file is missing, migration already completed');
|
||||
return;
|
||||
}*/
|
||||
|
||||
$db_opts = config('database.connections.mysql.options');
|
||||
$emulate_prepares = $db_opts[PDO::ATTR_EMULATE_PREPARES] ? 'true' : 'false';
|
||||
|
||||
$opts = array_merge(static::$defaultValues, [
|
||||
'APP_ENV' => config('app.env'),
|
||||
'APP_KEY' => config('app.key'),
|
||||
'APP_DEBUG' => config('app.debug') ? 'true' : 'false',
|
||||
'APP_LOCALE' => config('app.locale'),
|
||||
'DEBUG_TOOLBAR' => config('app.debug_toolbar') ? 'true' : 'false',
|
||||
'SITE_NAME' => config('app.name'),
|
||||
'APP_URL' => config('app.url'),
|
||||
'DB_CONNECTION' => config('database.default'),
|
||||
'DB_HOST' => config('database.connections.mysql.host'),
|
||||
'DB_PORT' => config('database.connections.mysql.port'),
|
||||
'DB_DATABASE' => config('database.connections.mysql.database'),
|
||||
'DB_USERNAME' => config('database.connections.mysql.username'),
|
||||
'DB_PASSWORD' => config('database.connections.mysql.password'),
|
||||
'DB_PREFIX' => config('database.connections.mysql.prefix'),
|
||||
'DB_EMULATE_PREPARES' => $emulate_prepares,
|
||||
'CACHE_DRIVER' => config('cache.default'),
|
||||
'CACHE_PREFIX' => config('cache.prefix'),
|
||||
'MAIL_DRIVER' => config('mail.default'),
|
||||
'MAIL_HOST' => config('mail.mailers.smtp.host'),
|
||||
'MAIL_PORT' => config('mail.mailers.smtp.port'),
|
||||
'MAIL_ENCRYPTION' => config('mail.mailers.smtp.encryption'),
|
||||
'MAIL_USERNAME' => config('mail.mailers.smtp.username'),
|
||||
'MAIL_PASSWORD' => config('mail.mailers.smtp.password'),
|
||||
'MAIL_FROM_NAME' => config('mail.from.name'),
|
||||
'MAIL_FROM_ADDRESS' => config('mail.from.address'),
|
||||
]);
|
||||
|
||||
$this->writeConfigFiles($opts);
|
||||
|
||||
// Rename the old config file
|
||||
$cfg_file = App::environmentPath().'/config.php';
|
||||
if (file_exists($cfg_file)) {
|
||||
rename($cfg_file, App::environmentPath().'/config.bak.php');
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Update the environment file and update certain keys/values
|
||||
*
|
||||
@@ -97,7 +167,7 @@ class ConfigService extends Service
|
||||
*/
|
||||
protected function createAppKey(): string
|
||||
{
|
||||
return base64_encode(Encrypter::generateKey(config('app.cipher')));
|
||||
return 'base64:'.base64_encode(Encrypter::generateKey(config('app.cipher')));
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -110,14 +180,14 @@ class ConfigService extends Service
|
||||
*/
|
||||
protected function determinePdoOptions($opts)
|
||||
{
|
||||
if ($opts['DB_CONN'] !== 'mysql') {
|
||||
if ($opts['DB_CONNECTION'] !== 'mysql') {
|
||||
return $opts;
|
||||
}
|
||||
|
||||
$dsn = "mysql:host=$opts[DB_HOST];port=$opts[DB_PORT];";
|
||||
Log::info('Connection string: '.$dsn);
|
||||
|
||||
$conn = new PDO($dsn, $opts['DB_USER'], $opts['DB_PASS']);
|
||||
$conn = new PDO($dsn, $opts['DB_USERNAME'], $opts['DB_PASSWORD']);
|
||||
$version = strtolower($conn->getAttribute(PDO::ATTR_SERVER_VERSION));
|
||||
Log::info('Detected DB Version: '.$version);
|
||||
|
||||
@@ -142,7 +212,8 @@ class ConfigService extends Service
|
||||
protected function configCacheDriver($opts)
|
||||
{
|
||||
// Set the cache prefix
|
||||
$opts['CACHE_PREFIX'] = uniqid($opts['SITE_NAME'].'_');
|
||||
$prefix = substr(str_slug($opts['SITE_NAME'], '_'), 0, 8);
|
||||
$opts['CACHE_PREFIX'] = strtolower(uniqid($prefix.'_'));
|
||||
|
||||
// Figure out what cache driver to initially use, depending on
|
||||
// what is installed. It won't detect redis or anything, though
|
||||
@@ -171,7 +242,7 @@ class ConfigService extends Service
|
||||
{
|
||||
// If we're setting up a database, then also setup
|
||||
// the default queue driver to use the database
|
||||
if ($opts['DB_CONN'] === 'mysql' || $opts['DB_CONN'] === 'postgres') {
|
||||
if ($opts['DB_CONNECTION'] === 'mysql' || $opts['DB_CONNECTION'] === 'postgres') {
|
||||
$opts['QUEUE_DRIVER'] = 'database';
|
||||
} else {
|
||||
$opts['QUEUE_DRIVER'] = 'sync';
|
||||
@@ -210,14 +281,13 @@ class ConfigService extends Service
|
||||
*
|
||||
* @param $opts
|
||||
*
|
||||
* @throws \Symfony\Component\HttpFoundation\File\Exception\FileException
|
||||
* @throws FileException
|
||||
*/
|
||||
protected function writeConfigFiles($opts)
|
||||
{
|
||||
Stub::setBasePath(resource_path('/stubs/installer'));
|
||||
|
||||
$env_file = App::environmentFilePath();
|
||||
|
||||
if (file_exists($env_file) && !is_writable($env_file)) {
|
||||
Log::error('Permissions on existing env.php is not writable');
|
||||
|
||||
@@ -239,7 +309,7 @@ class ConfigService extends Service
|
||||
* Next write out the config file. If there's an error here,
|
||||
* then throw an exception but delete the env file first
|
||||
*/
|
||||
try {
|
||||
/*try {
|
||||
$stub = new Stub('/config.stub', $opts);
|
||||
$stub->render();
|
||||
$stub->saveTo(App::environmentPath(), 'config.php');
|
||||
@@ -247,6 +317,6 @@ class ConfigService extends Service
|
||||
unlink(App::environmentPath().'/'.App::environmentFile());
|
||||
|
||||
throw new FileException('Couldn\'t write config.php. ('.$e.')');
|
||||
}
|
||||
}*/
|
||||
}
|
||||
}
|
||||
|
||||
@@ -90,10 +90,10 @@ class SeederService extends Service
|
||||
$data = file_get_contents(database_path('/seeds/modules.yml'));
|
||||
$yml = Yaml::parse($data);
|
||||
foreach ($yml as $module) {
|
||||
$module['updated_at'] = Carbon::now();
|
||||
$module['updated_at'] = Carbon::now('UTC');
|
||||
$count = DB::table('modules')->where('name', $module['name'])->count('name');
|
||||
if ($count === 0) {
|
||||
$module['created_at'] = Carbon::now();
|
||||
$module['created_at'] = Carbon::now('UTC');
|
||||
DB::table('modules')->insert($module);
|
||||
} else {
|
||||
DB::table('modules')
|
||||
@@ -150,7 +150,7 @@ class SeederService extends Service
|
||||
'order' => $order,
|
||||
'name' => '',
|
||||
'group' => $group,
|
||||
'value' => '',
|
||||
'value' => $attrs['value'],
|
||||
'default' => $attrs['value'],
|
||||
'options' => '',
|
||||
'type' => 'hidden',
|
||||
|
||||
@@ -6,6 +6,7 @@ use App\Contracts\Service;
|
||||
use App\Events\PirepAccepted;
|
||||
use App\Events\PirepCancelled;
|
||||
use App\Events\PirepFiled;
|
||||
use App\Events\PirepPrefiled;
|
||||
use App\Events\PirepRejected;
|
||||
use App\Events\UserStatsChanged;
|
||||
use App\Exceptions\AircraftInvalid;
|
||||
@@ -23,6 +24,8 @@ use App\Models\Enums\PirepState;
|
||||
use App\Models\Enums\PirepStatus;
|
||||
use App\Models\Navdata;
|
||||
use App\Models\Pirep;
|
||||
use App\Models\PirepComment;
|
||||
use App\Models\PirepFare;
|
||||
use App\Models\PirepFieldValue;
|
||||
use App\Models\SimBrief;
|
||||
use App\Models\User;
|
||||
@@ -144,11 +147,14 @@ class PirepService extends Service
|
||||
$dupe_pirep = $this->findDuplicate($pirep);
|
||||
if ($dupe_pirep !== false) {
|
||||
$pirep = $dupe_pirep;
|
||||
Log::info('Found duplicate PIREP, id='.$dupe_pirep->id);
|
||||
if ($pirep->cancelled) {
|
||||
throw new \App\Exceptions\PirepCancelled($pirep);
|
||||
}
|
||||
}
|
||||
|
||||
event(new PirepPrefiled($pirep));
|
||||
|
||||
$pirep->save();
|
||||
|
||||
return $pirep;
|
||||
@@ -285,12 +291,14 @@ class PirepService extends Service
|
||||
public function findDuplicate(Pirep $pirep)
|
||||
{
|
||||
$minutes = setting('pireps.duplicate_check_time', 10);
|
||||
$time_limit = Carbon::now()->subMinutes($minutes)->toDateTimeString();
|
||||
$time_limit = Carbon::now('UTC')->subMinutes($minutes)->toDateTimeString();
|
||||
|
||||
$where = [
|
||||
'user_id' => $pirep->user_id,
|
||||
'airline_id' => $pirep->airline_id,
|
||||
'flight_number' => $pirep->flight_number,
|
||||
'user_id' => $pirep->user_id,
|
||||
'airline_id' => $pirep->airline_id,
|
||||
'flight_number' => $pirep->flight_number,
|
||||
'dpt_airport_id' => $pirep->dpt_airport_id,
|
||||
'arr_airport_id' => $pirep->arr_airport_id,
|
||||
];
|
||||
|
||||
if (filled($pirep->route_code)) {
|
||||
@@ -436,6 +444,29 @@ class PirepService extends Service
|
||||
return $pirep;
|
||||
}
|
||||
|
||||
/**
|
||||
* Delete the PIREP and all of the associated data. Does a force delete to make sure that we
|
||||
* don't run into problems with foreign keys. Models/tables affected:
|
||||
*
|
||||
* acars
|
||||
* bids
|
||||
* pirep_comments
|
||||
* pirep_fares
|
||||
* pirep_field_values
|
||||
* simbrief
|
||||
*
|
||||
* @param Pirep $pirep
|
||||
*/
|
||||
public function delete(Pirep $pirep): void
|
||||
{
|
||||
$w = ['pirep_id' => $pirep->id];
|
||||
PirepComment::where($w)->forceDelete();
|
||||
PirepFare::where($w)->forceDelete();
|
||||
PirepFieldValue::where($w)->forceDelete();
|
||||
SimBrief::where($w)->forceDelete();
|
||||
$pirep->forceDelete();
|
||||
}
|
||||
|
||||
/**
|
||||
* Update any custom PIREP fields
|
||||
*
|
||||
@@ -539,6 +570,7 @@ class PirepService extends Service
|
||||
$pirep->aircraft->flight_time = $pirep->aircraft->flight_time + $pirep->flight_time;
|
||||
$pirep->aircraft->airport_id = $pirep->arr_airport_id;
|
||||
$pirep->aircraft->landing_time = $pirep->updated_at;
|
||||
$pirep->aircraft->fuel_onboard = $pirep->block_fuel - $pirep->fuel_used;
|
||||
$pirep->aircraft->save();
|
||||
|
||||
$pirep->refresh();
|
||||
|
||||
@@ -29,11 +29,18 @@ class SimBriefService extends Service
|
||||
* @param string $user_id User who generated this
|
||||
* @param string $ofp_id The SimBrief OFP ID
|
||||
* @param string $flight_id The flight ID
|
||||
* @param string $ac_id The aircraft ID
|
||||
* @param array $fares Full list of fares for the flightß
|
||||
*
|
||||
* @return SimBrief|null
|
||||
*/
|
||||
public function downloadOfp(string $user_id, string $ofp_id, string $flight_id)
|
||||
{
|
||||
public function downloadOfp(
|
||||
string $user_id,
|
||||
string $ofp_id,
|
||||
string $flight_id,
|
||||
string $ac_id,
|
||||
array $fares = []
|
||||
) {
|
||||
$uri = str_replace('{id}', $ofp_id, config('phpvms.simbrief_url'));
|
||||
|
||||
$opts = [
|
||||
@@ -57,11 +64,17 @@ class SimBriefService extends Service
|
||||
$ofp = simplexml_load_string($body, SimBriefXML::class);
|
||||
|
||||
$attrs = [
|
||||
'user_id' => $user_id,
|
||||
'flight_id' => $flight_id,
|
||||
'ofp_xml' => $ofp->asXML(),
|
||||
'user_id' => $user_id,
|
||||
'flight_id' => $flight_id,
|
||||
'aircraft_id' => $ac_id,
|
||||
'ofp_xml' => $ofp->asXML(),
|
||||
];
|
||||
|
||||
// encode the fares data to JSONß
|
||||
if (!empty($fares)) {
|
||||
$attrs['fare_data'] = json_encode($fares);
|
||||
}
|
||||
|
||||
// Try to download the XML file for ACARS. If it doesn't work, try to modify the main OFP
|
||||
$acars_xml = $this->getAcarsOFP($ofp);
|
||||
if (empty($acars_xml)) {
|
||||
|
||||
@@ -9,12 +9,14 @@ use App\Events\UserStatsChanged;
|
||||
use App\Exceptions\PilotIdNotFound;
|
||||
use App\Exceptions\UserPilotIdExists;
|
||||
use App\Models\Airline;
|
||||
use App\Models\Bid;
|
||||
use App\Models\Enums\PirepState;
|
||||
use App\Models\Enums\UserState;
|
||||
use App\Models\Pirep;
|
||||
use App\Models\Rank;
|
||||
use App\Models\Role;
|
||||
use App\Models\User;
|
||||
use App\Models\UserFieldValue;
|
||||
use App\Repositories\AircraftRepository;
|
||||
use App\Repositories\AirlineRepository;
|
||||
use App\Repositories\SubfleetRepository;
|
||||
@@ -23,6 +25,7 @@ use App\Support\Units\Time;
|
||||
use App\Support\Utils;
|
||||
use Carbon\Carbon;
|
||||
use Illuminate\Support\Collection;
|
||||
use Illuminate\Support\Facades\Hash;
|
||||
use Illuminate\Support\Facades\Log;
|
||||
use function is_array;
|
||||
|
||||
@@ -60,14 +63,23 @@ class UserService extends Service
|
||||
*
|
||||
* @param $user_id
|
||||
*
|
||||
* @return User
|
||||
* @return User|null
|
||||
*/
|
||||
public function getUser($user_id): User
|
||||
public function getUser($user_id): ?User
|
||||
{
|
||||
/** @var User $user */
|
||||
$user = $this->userRepo
|
||||
->with(['airline', 'bids', 'rank'])
|
||||
->find($user_id);
|
||||
|
||||
if (empty($user)) {
|
||||
return null;
|
||||
}
|
||||
|
||||
if ($user->state === UserState::DELETED) {
|
||||
return null;
|
||||
}
|
||||
|
||||
// Load the proper subfleets to the rank
|
||||
$user->rank->subfleets = $this->getAllowableSubfleets($user);
|
||||
$user->subfleets = $user->rank->subfleets;
|
||||
@@ -117,6 +129,33 @@ class UserService extends Service
|
||||
return $user;
|
||||
}
|
||||
|
||||
/**
|
||||
* Remove the user. But don't actually delete them - set the name to deleted, email to
|
||||
* something random
|
||||
*
|
||||
* @param User $user
|
||||
*
|
||||
* @throws \Exception
|
||||
*/
|
||||
public function removeUser(User $user)
|
||||
{
|
||||
$user->name = 'Deleted User';
|
||||
$user->email = Utils::generateApiKey().'@deleted-user.com';
|
||||
$user->api_key = Utils::generateApiKey();
|
||||
$user->password = Hash::make(Utils::generateApiKey());
|
||||
$user->state = UserState::DELETED;
|
||||
$user->save();
|
||||
|
||||
// Detach all roles from this user
|
||||
$user->detachRoles($user->roles);
|
||||
|
||||
// Delete any fields which might have personal information
|
||||
UserFieldValue::where('user_id', $user->id)->delete();
|
||||
|
||||
// Remove any bids
|
||||
Bid::where('user_id', $user->id)->delete();
|
||||
}
|
||||
|
||||
/**
|
||||
* Add a user to a given role
|
||||
*
|
||||
@@ -125,7 +164,7 @@ class UserService extends Service
|
||||
*
|
||||
* @return User
|
||||
*/
|
||||
public function addUserToRole(User $user, $roleName): User
|
||||
public function addUserToRole(User $user, string $roleName): User
|
||||
{
|
||||
$role = Role::where(['name' => $roleName])->first();
|
||||
$user->attachRole($role);
|
||||
@@ -282,9 +321,24 @@ class UserService extends Service
|
||||
}
|
||||
|
||||
// See if the difference is larger than what the setting calls for
|
||||
if ($date->diffInDays($diff_date) > $leave_days) {
|
||||
$return_users[] = $user;
|
||||
if ($date->diffInDays($diff_date) <= $leave_days) {
|
||||
continue;
|
||||
}
|
||||
|
||||
$skip = false;
|
||||
// If any role for this user has the "disable_activity_check" feature activated, skip this user
|
||||
foreach ($user->roles()->get() as $role) {
|
||||
/** @var Role $role */
|
||||
if ($role->disable_activity_checks) {
|
||||
$skip = true;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if ($skip) {
|
||||
continue;
|
||||
}
|
||||
$return_users[] = $user;
|
||||
}
|
||||
|
||||
return $return_users;
|
||||
|
||||
+10
-8
@@ -879,8 +879,8 @@ class Metar implements \ArrayAccess
|
||||
$this->set_result_value('cavok', true);
|
||||
$this->method += 4; // can skip the next 4 methods: visibility_min, runway_vr, present_weather, clouds
|
||||
}
|
||||
} /*elseif ($found[1] === '////') {
|
||||
}*/ // information not available
|
||||
} elseif ($found[1] === '////') {
|
||||
} // information not available
|
||||
|
||||
else {
|
||||
$prefix = '';
|
||||
@@ -994,8 +994,10 @@ class Metar implements \ArrayAccess
|
||||
}
|
||||
|
||||
$unit = 'meter';
|
||||
$report_unit = 'm';
|
||||
if (isset($found[6]) && $found[6] === 'FT') {
|
||||
$unit = 'feet';
|
||||
$report_unit = 'nmi';
|
||||
}
|
||||
|
||||
$observed = [
|
||||
@@ -1030,15 +1032,15 @@ class Metar implements \ArrayAccess
|
||||
if (!empty($observed['runway'])) {
|
||||
$report = [];
|
||||
if ($observed['variable'] !== null) {
|
||||
$report[] = $observed['variable']['nmi'].' nmi';
|
||||
$report[] = $observed['variable'][$report_unit].$report_unit;
|
||||
} elseif ($observed['interval_min'] !== null && $observed['interval_max'] !== null) {
|
||||
if (isset(static::$rvr_prefix_codes[$observed['variable_prefix']])) {
|
||||
$report[] = 'varying from a min. of '.$observed['interval_min']['nmi'].' nmi until a max. of '.
|
||||
$report[] = 'varying from a min. of '.$observed['interval_min'][$report_unit].$report_unit.' until a max. of '.
|
||||
static::$rvr_prefix_codes[$observed['variable_prefix']].' that '.
|
||||
$observed['interval_max']['nmi'].' nmi';
|
||||
$observed['interval_max'][$report_unit].' '.$report_unit;
|
||||
} else {
|
||||
$report[] = 'varying from a min. of '.$observed['interval_min']['nmi'].' nmi until a max. of '.
|
||||
$observed['interval_max']['nmi'].' nmi';
|
||||
$report[] = 'varying from a min. of '.$observed['interval_min'][$report_unit].$report_unit.' until a max. of '.
|
||||
$observed['interval_max'][$report_unit].$report_unit;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1772,7 +1774,7 @@ class Metar implements \ArrayAccess
|
||||
*/
|
||||
private function calculate_wind_chill($temperature_f): void
|
||||
{
|
||||
if ($temperature_f < 51 && $this->result['wind_speed'] !== 0) {
|
||||
if ($temperature_f < 51 && $this->result['wind_speed'] && $this->result['wind_speed'] !== 0) {
|
||||
$windspeed = $this->result['wind_speed']->toUnit('mph');
|
||||
if ($windspeed > 3) {
|
||||
$chill_f = 35.74 + 0.6215 * $temperature_f - 35.75 * ($windspeed ** 0.16);
|
||||
|
||||
@@ -0,0 +1,89 @@
|
||||
<?php
|
||||
|
||||
namespace App\Support;
|
||||
|
||||
use Igaster\LaravelTheme\Facades\Theme;
|
||||
use Illuminate\Filesystem\Filesystem;
|
||||
use Illuminate\Support\Arr;
|
||||
|
||||
class ThemeViewFinder extends \Igaster\LaravelTheme\themeViewFinder
|
||||
{
|
||||
public function __construct(Filesystem $files, array $paths, array $extensions = null)
|
||||
{
|
||||
//$this->themeEngine = \App::make('igaster.themes');
|
||||
parent::__construct($files, $paths, $extensions);
|
||||
}
|
||||
|
||||
/*
|
||||
* Override findNamespacedView() to add "Theme/vendor/..." paths
|
||||
*
|
||||
* @param string $name
|
||||
* @return string
|
||||
*/
|
||||
protected function findNamespacedView($name)
|
||||
{
|
||||
// Extract the $view and the $namespace parts
|
||||
list($namespace, $view) = $this->parseNamespaceSegments($name);
|
||||
|
||||
$paths = $this->addThemeNamespacePaths($namespace);
|
||||
|
||||
// Find and return the view
|
||||
return $this->findInPaths($view, $paths);
|
||||
}
|
||||
|
||||
public function addThemeNamespacePaths($namespace)
|
||||
{
|
||||
// This rule will remap all paths starting with $key to $value.
|
||||
// For exapmle paths starting with 'resources/views/vendor' (relative to base_path())
|
||||
// will be maped to path 'THEMENAME/vendor' (relative to current theme views-path)
|
||||
$pathsMap = [
|
||||
// 'resources/views/vendor/mail' => 'mail',
|
||||
'resources/views/vendor' => 'vendor',
|
||||
'resources/views/modules' => 'modules',
|
||||
];
|
||||
|
||||
// Does $namespace exists?
|
||||
if (!isset($this->hints[$namespace])) {
|
||||
return [];
|
||||
}
|
||||
|
||||
// Get the paths registered to the $namespace
|
||||
$paths = $this->hints[$namespace];
|
||||
|
||||
// Search $paths array and remap paths that start with a key of $pathsMap array.
|
||||
// replace with the value of $pathsMap array
|
||||
$themeSubPaths = [];
|
||||
foreach ($paths as $path) {
|
||||
$pathRelativeToApp = substr($path, strlen(base_path()) + 1);
|
||||
$pathRelativeToApp = str_replace('\\', '/', $pathRelativeToApp);
|
||||
// Ignore paths in composer installed packages (paths inside vendor folder)
|
||||
if (strpos($pathRelativeToApp, 'vendor') !== 0) {
|
||||
// Remap paths definded int $pathsMap array
|
||||
foreach ($pathsMap as $key => $value) {
|
||||
if (strpos($pathRelativeToApp, $key) === 0) {
|
||||
$pathRelativeToApp = str_replace($key, $value, $pathRelativeToApp);
|
||||
break;
|
||||
}
|
||||
}
|
||||
$themeSubPaths[] = $pathRelativeToApp;
|
||||
}
|
||||
}
|
||||
|
||||
// Prepend current theme's view path to the remaped paths
|
||||
$newPaths = [];
|
||||
$searchPaths = array_diff($this->paths, Theme::getLaravelViewPaths());
|
||||
foreach ($searchPaths as $path1) {
|
||||
foreach ($themeSubPaths as $path2) {
|
||||
$newPaths[] = $path1.'/'.$path2;
|
||||
}
|
||||
}
|
||||
|
||||
// Add new paths in the beggin of the search paths array
|
||||
foreach (array_reverse($newPaths) as $path) {
|
||||
if (!in_array($path, $paths, true)) {
|
||||
$paths = Arr::prepend($paths, $path);
|
||||
}
|
||||
}
|
||||
return $paths;
|
||||
}
|
||||
}
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user