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
2024-08-17 21:33:09 -05:00
parent 5d3259b653
commit b84bc94da6
8 changed files with 215 additions and 164 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/Models/Transaction.php
+83 -77
View File
@@ -4,6 +4,7 @@ namespace App\Models;
use App\Models\MarketData;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Database\Eloquent\Casts\Attribute;
use Illuminate\Database\Eloquent\Concerns\HasUuids;
use Illuminate\Database\Eloquent\Factories\HasFactory;
@@ -12,121 +13,57 @@ class Transaction extends Model
use HasFactory;
use HasUuids;
/**
* The attributes that are mass assignable.
*
* @var array
*/
protected $fillable = [
'symbol',
'date',
'portfolio_id',
'transaction_type',
'quantity',
'cost_basis',
'sale_price',
'split'
'sale_price'
];
/**
* The attributes that should be hidden for arrays.
*
* @var array
*/
protected $hidden = [];
/**
* The attributes that should be cast to native types.
*
* @var array
*/
protected $casts = [
'date' => 'datetime',
'first_date' => 'datetime',
'last_date' => 'datetime',
'split' => 'boolean',
];
/**
*
* @return void
*/
protected static function boot()
{
parent::boot();
static::saving(function ($transaction) {
// if sale, move cost basis to sale price
if ($transaction->transaction_type == 'SELL') {
$transaction->cost_basis = $transaction->holding->average_cost_basis ?? $transaction->cost_basis;
$transaction->ensureCostBasisIsAddedToSale();
}
});
static::saved(function ($transaction) {
// static::syncHolding($transaction);
$transaction->syncHolding();
});
static::deleted(function ($transaction) {
// static::syncHolding($transaction);
$transaction->syncHolding();
});
}
public static function syncHolding($transaction) {
// get the holding for a symbol and portfolio (or create one)
$holding = Holding::firstOrNew([
'portfolio_id' => $transaction->portfolio_id,
'symbol' => $transaction->symbol
], [
'portfolio_id' => $transaction->portfolio_id,
'symbol' => $transaction->symbol,
'quantity' => $transaction->quantity,
'average_cost_basis' => $transaction->cost_basis,
'total_cost_basis' => $transaction->quantity * $transaction->cost_basis,
]);
// pull existing transaction data
$query = self::where([
'portfolio_id' => $transaction->portfolio_id,
'symbol' => $transaction->symbol,
])->selectRaw('SUM(CASE WHEN transaction_type = "BUY" THEN quantity ELSE 0 END) AS `qty_purchases`')
->selectRaw('SUM(CASE WHEN transaction_type = "SELL" THEN quantity ELSE 0 END) AS `qty_sales`')
->selectRaw('SUM(CASE WHEN transaction_type = "BUY" THEN (quantity * cost_basis) ELSE 0 END) AS `cost_basis`')
->selectRaw('SUM(CASE WHEN transaction_type = "SELL" THEN ((sale_price - cost_basis) * quantity) ELSE 0 END) AS `realized_gains`')
->first();
$total_quantity = $query->qty_purchases - $query->qty_sales;
$average_cost_basis = $query->qty_purchases > 0
? $query->cost_basis / $query->qty_purchases
: 0;
// update holding
$holding->fill([
'quantity' => $total_quantity,
'average_cost_basis' => $average_cost_basis,
'total_cost_basis' => $total_quantity * $average_cost_basis,
'realized_gain_loss_dollars' => $query->realized_gains,
]);
$holding->save();
// load market data while we're here
$transaction->refreshMarketData();
// sync dividends to holding
$transaction->syncDividendsToHolding();
}
public function setSymbolAttribute($value)
/**
* Ensure transaction symbol is always upper case
*/
protected function symbol(): Attribute
{
$this->attributes['symbol'] = strtoupper($value);
return Attribute::make(
set: fn (string $value) => strtoupper($value)
);
}
/**
* get market data for transaction
* Related market data for transaction
*
* @return void
*/
@@ -136,7 +73,7 @@ class Transaction extends Model
}
/**
* get portfolio for transaction
* Related portfolio
*
* @return void
*/
@@ -176,4 +113,73 @@ class Transaction extends Model
{
return Dividend::getDividendData($this->attributes['symbol']);
}
/**
* Writes average cost basis to a sale transaction
*
* @return Transaction
*/
public function ensureCostBasisIsAddedToSale()
{
$holding = Holding::firstOrNew([
'portfolio_id' => $this->portfolio_id,
'symbol' => $this->symbol
],[
'average_cost_basis' => null
]);
$this->cost_basis = $holding->average_cost_basis ?? 0;
return $this;
}
/**
* Syncs the holding related to this transaction
*
* @return void
*/
public function syncHolding() {
// get the holding for a symbol and portfolio (or create one)
$holding = Holding::firstOrNew([
'portfolio_id' => $this->portfolio_id,
'symbol' => $this->symbol
], [
'portfolio_id' => $this->portfolio_id,
'symbol' => $this->symbol,
'quantity' => $this->quantity,
'average_cost_basis' => $this->cost_basis,
'total_cost_basis' => $this->quantity * $this->cost_basis,
]);
// pull existing transaction data
$query = self::where([
'portfolio_id' => $this->portfolio_id,
'symbol' => $this->symbol,
])->selectRaw('SUM(CASE WHEN transaction_type = "BUY" THEN quantity ELSE 0 END) AS `qty_purchases`')
->selectRaw('SUM(CASE WHEN transaction_type = "SELL" THEN quantity ELSE 0 END) AS `qty_sales`')
->selectRaw('SUM(CASE WHEN transaction_type = "BUY" THEN (quantity * cost_basis) ELSE 0 END) AS `cost_basis`')
->selectRaw('SUM(CASE WHEN transaction_type = "SELL" THEN ((sale_price - cost_basis) * quantity) ELSE 0 END) AS `realized_gains`')
->first();
$total_quantity = $query->qty_purchases - $query->qty_sales;
$average_cost_basis = $query->qty_purchases > 0
? $query->cost_basis / $query->qty_purchases
: 0;
// update holding
$holding->fill([
'quantity' => $total_quantity,
'average_cost_basis' => $average_cost_basis,
'total_cost_basis' => $total_quantity * $average_cost_basis,
'realized_gain_loss_dollars' => $query->realized_gains,
]);
$holding->save();
// load market data while we're here
// $this->refreshMarketData();
// sync dividends to holding
// $this->syncDividendsToHolding();
}
}