javier/investbrain
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

wip

Browse Source
This commit is contained in:
hackerESQ
2025-04-12 17:51:13 -05:00
parent 33e0df5ae2
commit c96ff0e45f
1 changed files with 44 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/Models/Dividend.php
+44 -36
View File
@@ -15,7 +15,6 @@ use Illuminate\Database\Eloquent\Relations\HasMany;
use Illuminate\Support\Arr; use Illuminate\Support\Arr;
use Illuminate\Support\Carbon; use Illuminate\Support\Carbon;
use Illuminate\Support\Facades\DB; use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Pipeline; use Illuminate\Support\Facades\Pipeline;
use Illuminate\Support\Str; use Illuminate\Support\Str;
@@ -95,47 +94,56 @@ class Dividend extends Model
return; return;
} }
dump('1. getting div data for '.$symbol);
try { try {
// get some data // get some data
if ($dividend_data = collect() && $start_date && $end_date) { if ($dividend_data = collect() && $start_date && $end_date) {
$dividend_data = app(MarketDataInterface::class)->dividends($symbol, $start_date, $end_date); $dividend_data = app(MarketDataInterface::class)->dividends($symbol, $start_date, $end_date);
} }
} catch (\Throwable $e) {
// ah, we found some dividends... dump('exception: '.$e->getMessage());
if ($dividend_data->isNotEmpty()) {
$market_data = MarketData::getMarketData($symbol);
// get historic conversion rates
$rate_to_base = CurrencyRate::timeSeriesRates($market_data->currency, $start_date, $end_date);
// create mass insert
foreach ($dividend_data as $index => $dividend) {
$rate_to_base_date = 1 / Arr::get($rate_to_base, Carbon::parse(Arr::get($dividend, 'date'))->toDateString(), 1);
$dividend['dividend_amount_base'] = $dividend['dividend_amount'] * $rate_to_base_date;
$dividend_data[$index] = [...$dividend, ...['id' => Str::uuid()->toString(), 'updated_at' => now(), 'created_at' => now()]];
}
// insert records
(new self)->insertOrIgnore($dividend_data->toArray());
// sync to holdings
self::syncHoldings($symbol);
// re-invest dividends
self::reinvestDividends($dividend_data, $market_data);
// sync last dividend amount to market data table
$market_data->last_dividend_amount = $dividend_data->sortByDesc('date')->first()['dividend_amount'];
$market_data->save();
}
} catch (\Exception $e) {
Log::info($e->getMessage());
dd($e);
} }
dump('2. got div data for '.$symbol);
// ah, we found some dividends...
if ($dividend_data->isNotEmpty()) {
dump('3. getting mkt data for '.$symbol);
$market_data = MarketData::getMarketData($symbol);
// get historic conversion rates
$rate_to_base = CurrencyRate::timeSeriesRates($market_data->currency, $start_date, $end_date);
dump('4. got time series for '.$symbol);
// create mass insert
foreach ($dividend_data as $index => $dividend) {
$rate_to_base_date = 1 / Arr::get($rate_to_base, Carbon::parse(Arr::get($dividend, 'date'))->toDateString(), 1);
$dividend['dividend_amount_base'] = $dividend['dividend_amount'] * $rate_to_base_date;
$dividend_data[$index] = [...$dividend, ...['id' => Str::uuid()->toString(), 'updated_at' => now(), 'created_at' => now()]];
}
// insert records
(new self)->insertOrIgnore($dividend_data->toArray());
dump('5. inserted for '.$symbol);
// sync to holdings
self::syncHoldings($symbol);
// re-invest dividends
self::reinvestDividends($dividend_data, $market_data);
// sync last dividend amount to market data table
$market_data->last_dividend_amount = $dividend_data->sortByDesc('date')->first()['dividend_amount'];
$market_data->save();
}
} }
public static function syncHoldings(string $symbol): void public static function syncHoldings(string $symbol): void