486f0e689c
- BrentPriceFetcher owns ingestion (fetchFromEia / fetchFromFred, each throws on failure) - BrentPricePredictor owns prediction and marks latest brent_prices row as generated - oil:fetch command tries EIA, falls back to FRED, fails loudly if both fail - oil:predict command prompts if latest price already has a prediction; --force bypasses - add prediction_generated_at column to brent_prices - delete OilPriceService (replaced by the two focused services)
59 lines
1.8 KiB
PHP
59 lines
1.8 KiB
PHP
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use App\Services\BrentPricePredictor;
|
|
use Illuminate\Console\Command;
|
|
use Throwable;
|
|
|
|
class PredictOilPrices extends Command
|
|
{
|
|
protected $signature = 'oil:predict {--force : Generate even if the latest price already has a prediction}';
|
|
|
|
protected $description = 'Generate a Brent crude oil price direction prediction';
|
|
|
|
public function handle(BrentPricePredictor $predictor): int
|
|
{
|
|
try {
|
|
$latest = $predictor->latestPrice();
|
|
|
|
if ($latest?->prediction_generated_at !== null && ! $this->option('force')) {
|
|
$message = sprintf(
|
|
'Prediction already generated for %s at %s.',
|
|
$latest->date->toDateString(),
|
|
$latest->prediction_generated_at->toDateTimeString(),
|
|
);
|
|
|
|
if (! $this->confirm($message.' Run again anyway?', default: false)) {
|
|
$this->info('Skipped.');
|
|
|
|
return self::SUCCESS;
|
|
}
|
|
}
|
|
|
|
$this->info('Generating prediction...');
|
|
$prediction = $predictor->generatePrediction();
|
|
|
|
if ($prediction === null) {
|
|
$this->error('Could not generate a prediction — not enough price data.');
|
|
|
|
return self::FAILURE;
|
|
}
|
|
|
|
$this->info(sprintf(
|
|
'Done. [%s] direction=%s confidence=%d%% — %s',
|
|
strtoupper($prediction->source->value),
|
|
$prediction->direction->value,
|
|
$prediction->confidence,
|
|
$prediction->reasoning,
|
|
));
|
|
} catch (Throwable $e) {
|
|
$this->error("Prediction failed: {$e->getMessage()}");
|
|
|
|
return self::FAILURE;
|
|
}
|
|
|
|
return self::SUCCESS;
|
|
}
|
|
}
|