mirror of
https://github.com/firefly-iii/firefly-iii.git
synced 2025-10-14 08:11:20 +00:00
Clean up code.
This commit is contained in:
@@ -44,6 +44,7 @@ use FireflyIII\Support\Facades\Steam;
|
|||||||
use Illuminate\Database\Eloquent\Model;
|
use Illuminate\Database\Eloquent\Model;
|
||||||
use Illuminate\Support\Collection;
|
use Illuminate\Support\Collection;
|
||||||
use Illuminate\Support\Facades\Log;
|
use Illuminate\Support\Facades\Log;
|
||||||
|
use Illuminate\Support\Str;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Trait PeriodOverview.
|
* Trait PeriodOverview.
|
||||||
@@ -103,16 +104,10 @@ trait PeriodOverview
|
|||||||
[$start, $end] = $this->getPeriodFromBlocks($dates, $start, $end);
|
[$start, $end] = $this->getPeriodFromBlocks($dates, $start, $end);
|
||||||
$this->statistics = $this->periodStatisticRepo->allInRangeForModel($account, $start, $end);
|
$this->statistics = $this->periodStatisticRepo->allInRangeForModel($account, $start, $end);
|
||||||
|
|
||||||
// TODO needs to be re-arranged:
|
|
||||||
// get all period stats for entire range.
|
|
||||||
// loop blocks, an loop the types, and select the missing ones.
|
|
||||||
// create new ones, or use collected.
|
|
||||||
|
|
||||||
|
|
||||||
$entries = [];
|
$entries = [];
|
||||||
Log::debug(sprintf('Count of loops: %d', count($dates)));
|
Log::debug(sprintf('Count of loops: %d', count($dates)));
|
||||||
foreach ($dates as $currentDate) {
|
foreach ($dates as $currentDate) {
|
||||||
$entries[] = $this->getSingleAccountPeriod($account, $currentDate['period'], $currentDate['start'], $currentDate['end']);
|
$entries[] = $this->getSingleModelPeriod($account, $currentDate['period'], $currentDate['start'], $currentDate['end']);
|
||||||
}
|
}
|
||||||
Log::debug('End of getAccountPeriodOverview()');
|
Log::debug('End of getAccountPeriodOverview()');
|
||||||
|
|
||||||
@@ -161,7 +156,7 @@ trait PeriodOverview
|
|||||||
|
|
||||||
Log::debug(sprintf('Count of loops: %d', count($dates)));
|
Log::debug(sprintf('Count of loops: %d', count($dates)));
|
||||||
foreach ($dates as $currentDate) {
|
foreach ($dates as $currentDate) {
|
||||||
$entries[] = $this->getSingleCategoryPeriod($category, $currentDate['period'], $currentDate['start'], $currentDate['end']);
|
$entries[] = $this->getSingleModelPeriod($category, $currentDate['period'], $currentDate['start'], $currentDate['end']);
|
||||||
}
|
}
|
||||||
|
|
||||||
return $entries;
|
return $entries;
|
||||||
@@ -287,18 +282,18 @@ trait PeriodOverview
|
|||||||
return $entries;
|
return $entries;
|
||||||
}
|
}
|
||||||
|
|
||||||
protected function getSingleAccountPeriod(Account $account, string $period, Carbon $start, Carbon $end): array
|
protected function getSingleModelPeriod(Model $model, string $period, Carbon $start, Carbon $end): array
|
||||||
{
|
{
|
||||||
Log::debug(sprintf('Now in getSingleAccountPeriod(#%d, %s %s)', $account->id, $start->format('Y-m-d'), $end->format('Y-m-d')));
|
Log::debug(sprintf('Now in getSingleModelPeriod(%s #%d, %s %s)', $model::class, $model->id, $start->format('Y-m-d'), $end->format('Y-m-d')));
|
||||||
$types = ['spent', 'earned', 'transferred_in', 'transferred_away'];
|
$types = ['spent', 'earned', 'transferred_in', 'transferred_away'];
|
||||||
$return = [
|
$return = [
|
||||||
'title' => Navigation::periodShow($start, $period),
|
'title' => Navigation::periodShow($start, $period),
|
||||||
'route' => route('accounts.show', [$account->id, $start->format('Y-m-d'), $end->format('Y-m-d')]),
|
'route' => route(sprintf('%s.show', strtolower(Str::plural(class_basename($model)))), [$model->id, $start->format('Y-m-d'), $end->format('Y-m-d')]),
|
||||||
'total_transactions' => 0,
|
'total_transactions' => 0,
|
||||||
];
|
];
|
||||||
$this->transactions = [];
|
$this->transactions = [];
|
||||||
foreach ($types as $type) {
|
foreach ($types as $type) {
|
||||||
$set = $this->getSingleAccountPeriodByType($account, $start, $end, $type);
|
$set = $this->getSingleModelPeriodByType($model, $start, $end, $type);
|
||||||
$return['total_transactions'] += $set['count'];
|
$return['total_transactions'] += $set['count'];
|
||||||
unset($set['count']);
|
unset($set['count']);
|
||||||
$return[$type] = $set;
|
$return[$type] = $set;
|
||||||
@@ -307,45 +302,6 @@ trait PeriodOverview
|
|||||||
return $return;
|
return $return;
|
||||||
}
|
}
|
||||||
|
|
||||||
protected function getSingleCategoryPeriod(Category $category, string $period, Carbon $start, Carbon $end): array
|
|
||||||
{
|
|
||||||
Log::debug(sprintf('Now in getSingleCategoryPeriod(#%d, %s %s)', $category->id, $start->format('Y-m-d'), $end->format('Y-m-d')));
|
|
||||||
$types = ['spent', 'earned', 'transferred_in', 'transferred_away'];
|
|
||||||
$return = [
|
|
||||||
'title' => Navigation::periodShow($start, $period),
|
|
||||||
'route' => route('categories.show', [$category->id, $start->format('Y-m-d'), $end->format('Y-m-d')]),
|
|
||||||
'total_transactions' => 0,
|
|
||||||
];
|
|
||||||
$this->transactions = [];
|
|
||||||
foreach ($types as $type) {
|
|
||||||
$set = $this->getSingleCategoryPeriodByType($category, $start, $end, $type);
|
|
||||||
$return['total_transactions'] += $set['count'];
|
|
||||||
unset($set['count']);
|
|
||||||
$return[$type] = $set;
|
|
||||||
}
|
|
||||||
|
|
||||||
return $return;
|
|
||||||
}
|
|
||||||
|
|
||||||
protected function getSingleTagPeriod(Tag $tag, string $period, Carbon $start, Carbon $end): array
|
|
||||||
{
|
|
||||||
Log::debug(sprintf('Now in getSingleTagPeriod(#%d, %s %s)', $tag->id, $start->format('Y-m-d'), $end->format('Y-m-d')));
|
|
||||||
$types = ['spent', 'earned', 'transferred_in', 'transferred_away'];
|
|
||||||
$return = [
|
|
||||||
'title' => Navigation::periodShow($start, $period),
|
|
||||||
'route' => route('tags.show', [$tag->id, $start->format('Y-m-d'), $end->format('Y-m-d')]),
|
|
||||||
'total_transactions' => 0,
|
|
||||||
];
|
|
||||||
$this->transactions = [];
|
|
||||||
foreach ($types as $type) {
|
|
||||||
$set = $this->getSingleTagPeriodByType($tag, $start, $end, $type);
|
|
||||||
$return['total_transactions'] += $set['count'];
|
|
||||||
unset($set['count']);
|
|
||||||
$return[$type] = $set;
|
|
||||||
}
|
|
||||||
|
|
||||||
return $return;
|
|
||||||
}
|
|
||||||
|
|
||||||
protected function filterStatistics(Carbon $start, Carbon $end, string $type): Collection
|
protected function filterStatistics(Carbon $start, Carbon $end, string $type): Collection
|
||||||
{
|
{
|
||||||
@@ -368,83 +324,30 @@ trait PeriodOverview
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
protected function getSingleAccountPeriodByType(Account $account, Carbon $start, Carbon $end, string $type): array
|
|
||||||
|
|
||||||
|
protected function getSingleModelPeriodByType(Model $model, Carbon $start, Carbon $end, string $type): array
|
||||||
{
|
{
|
||||||
Log::debug(sprintf('Now in getSingleAccountPeriodByType(#%d, %s %s, %s)', $account->id, $start->format('Y-m-d'), $end->format('Y-m-d'), $type));
|
Log::debug(sprintf('Now in getSingleModelPeriodByType(%s #%d, %s %s, %s)', $model::class, $model->id, $start->format('Y-m-d'), $end->format('Y-m-d'), $type));
|
||||||
$statistics = $this->filterStatistics($start, $end, $type);
|
$statistics = $this->filterStatistics($start, $end, $type);
|
||||||
|
|
||||||
// nothing found, regenerate them.
|
// nothing found, regenerate them.
|
||||||
if (0 === $statistics->count()) {
|
if (0 === $statistics->count()) {
|
||||||
Log::debug(sprintf('Found nothing in this period for type "%s"', $type));
|
Log::debug(sprintf('Found nothing in this period for type "%s"', $type));
|
||||||
if (0 === count($this->transactions)) {
|
if (0 === count($this->transactions)) {
|
||||||
$this->transactions = $this->accountRepository->periodCollection($account, $start, $end);
|
switch ($model::class) {
|
||||||
}
|
|
||||||
|
|
||||||
switch ($type) {
|
|
||||||
default:
|
default:
|
||||||
throw new FireflyException(sprintf('Cannot deal with account period type %s', $type));
|
throw new FireflyException(sprintf('Cannot deal with model of type "%s"', $model::class));
|
||||||
|
case Category::class:
|
||||||
case 'spent':
|
$this->transactions = $this->categoryRepository->periodCollection($model, $start, $end);
|
||||||
$result = $this->filterTransactionsByType(TransactionTypeEnum::WITHDRAWAL, $start, $end);
|
|
||||||
|
|
||||||
break;
|
break;
|
||||||
|
case Account::class:
|
||||||
case 'earned':
|
$this->transactions = $this->accountRepository->periodCollection($model, $start, $end);
|
||||||
$result = $this->filterTransactionsByType(TransactionTypeEnum::DEPOSIT, $start, $end);
|
|
||||||
|
|
||||||
break;
|
break;
|
||||||
|
case Tag::class:
|
||||||
case 'transferred_in':
|
$this->transactions = $this->tagRepository->periodCollection($model, $start, $end);
|
||||||
$result = $this->filterTransfers('in', $start, $end);
|
|
||||||
|
|
||||||
break;
|
|
||||||
|
|
||||||
case 'transferred_away':
|
|
||||||
$result = $this->filterTransfers('away', $start, $end);
|
|
||||||
|
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
// each result must be grouped by currency, then saved as period statistic.
|
|
||||||
Log::debug(sprintf('Going to group %d found journal(s)', count($result)));
|
|
||||||
$grouped = $this->groupByCurrency($result);
|
|
||||||
|
|
||||||
$this->saveGroupedAsStatistics($account, $start, $end, $type, $grouped);
|
|
||||||
|
|
||||||
return $grouped;
|
|
||||||
}
|
|
||||||
$grouped = [
|
|
||||||
'count' => 0,
|
|
||||||
];
|
|
||||||
|
|
||||||
/** @var PeriodStatistic $statistic */
|
|
||||||
foreach ($statistics as $statistic) {
|
|
||||||
$id = (int)$statistic->transaction_currency_id;
|
|
||||||
$currency = Amount::getTransactionCurrencyById($id);
|
|
||||||
$grouped[$id] = [
|
|
||||||
'amount' => (string)$statistic->amount,
|
|
||||||
'count' => (int)$statistic->count,
|
|
||||||
'currency_id' => $currency->id,
|
|
||||||
'currency_name' => $currency->name,
|
|
||||||
'currency_code' => $currency->code,
|
|
||||||
'currency_symbol' => $currency->symbol,
|
|
||||||
'currency_decimal_places' => $currency->decimal_places,
|
|
||||||
];
|
|
||||||
$grouped['count'] += (int)$statistic->count;
|
|
||||||
}
|
|
||||||
|
|
||||||
return $grouped;
|
|
||||||
}
|
|
||||||
|
|
||||||
protected function getSingleCategoryPeriodByType(Category $category, Carbon $start, Carbon $end, string $type): array
|
|
||||||
{
|
|
||||||
Log::debug(sprintf('Now in getSingleCategoryPeriodByType(#%d, %s %s, %s)', $category->id, $start->format('Y-m-d'), $end->format('Y-m-d'), $type));
|
|
||||||
$statistics = $this->filterStatistics($start, $end, $type);
|
|
||||||
|
|
||||||
// nothing found, regenerate them.
|
|
||||||
if (0 === $statistics->count()) {
|
|
||||||
Log::debug(sprintf('Found nothing in this period for type "%s"', $type));
|
|
||||||
if (0 === count($this->transactions)) {
|
|
||||||
$this->transactions = $this->categoryRepository->periodCollection($category, $start, $end);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
switch ($type) {
|
switch ($type) {
|
||||||
@@ -476,7 +379,7 @@ trait PeriodOverview
|
|||||||
Log::debug(sprintf('Going to group %d found journal(s)', count($result)));
|
Log::debug(sprintf('Going to group %d found journal(s)', count($result)));
|
||||||
$grouped = $this->groupByCurrency($result);
|
$grouped = $this->groupByCurrency($result);
|
||||||
|
|
||||||
$this->saveGroupedAsStatistics($category, $start, $end, $type, $grouped);
|
$this->saveGroupedAsStatistics($model, $start, $end, $type, $grouped);
|
||||||
|
|
||||||
return $grouped;
|
return $grouped;
|
||||||
}
|
}
|
||||||
@@ -503,73 +406,6 @@ trait PeriodOverview
|
|||||||
return $grouped;
|
return $grouped;
|
||||||
}
|
}
|
||||||
|
|
||||||
protected function getSingleTagPeriodByType(Tag $tag, Carbon $start, Carbon $end, string $type): array
|
|
||||||
{
|
|
||||||
Log::debug(sprintf('Now in getSingleTagPeriodByType(#%d, %s %s, %s)', $tag->id, $start->format('Y-m-d'), $end->format('Y-m-d'), $type));
|
|
||||||
$statistics = $this->filterStatistics($start, $end, $type);
|
|
||||||
|
|
||||||
// nothing found, regenerate them.
|
|
||||||
if (0 === $statistics->count()) {
|
|
||||||
Log::debug(sprintf('Found nothing in this period for type "%s"', $type));
|
|
||||||
if (0 === count($this->transactions)) {
|
|
||||||
$this->transactions = $this->tagRepository->periodCollection($tag, $start, $end);
|
|
||||||
}
|
|
||||||
|
|
||||||
switch ($type) {
|
|
||||||
default:
|
|
||||||
throw new FireflyException(sprintf('Cannot deal with tag period type %s', $type));
|
|
||||||
|
|
||||||
case 'spent':
|
|
||||||
|
|
||||||
$result = $this->filterTransactionsByType(TransactionTypeEnum::WITHDRAWAL, $start, $end);
|
|
||||||
|
|
||||||
break;
|
|
||||||
|
|
||||||
case 'earned':
|
|
||||||
$result = $this->filterTransactionsByType(TransactionTypeEnum::DEPOSIT, $start, $end);
|
|
||||||
|
|
||||||
break;
|
|
||||||
|
|
||||||
case 'transferred_in':
|
|
||||||
$result = $this->filterTransfers('in', $start, $end);
|
|
||||||
|
|
||||||
break;
|
|
||||||
|
|
||||||
case 'transferred_away':
|
|
||||||
$result = $this->filterTransfers('away', $start, $end);
|
|
||||||
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
// each result must be grouped by currency, then saved as period statistic.
|
|
||||||
Log::debug(sprintf('Going to group %d found journal(s)', count($result)));
|
|
||||||
$grouped = $this->groupByCurrency($result);
|
|
||||||
|
|
||||||
$this->saveGroupedAsStatistics($tag, $start, $end, $type, $grouped);
|
|
||||||
|
|
||||||
return $grouped;
|
|
||||||
}
|
|
||||||
$grouped = [
|
|
||||||
'count' => 0,
|
|
||||||
];
|
|
||||||
|
|
||||||
/** @var PeriodStatistic $statistic */
|
|
||||||
foreach ($statistics as $statistic) {
|
|
||||||
$id = (int)$statistic->transaction_currency_id;
|
|
||||||
$currency = Amount::getTransactionCurrencyById($id);
|
|
||||||
$grouped[$id] = [
|
|
||||||
'amount' => (string)$statistic->amount,
|
|
||||||
'count' => (int)$statistic->count,
|
|
||||||
'currency_id' => $currency->id,
|
|
||||||
'currency_name' => $currency->name,
|
|
||||||
'currency_code' => $currency->code,
|
|
||||||
'currency_symbol' => $currency->symbol,
|
|
||||||
'currency_decimal_places' => $currency->decimal_places,
|
|
||||||
];
|
|
||||||
$grouped['count'] += (int)$statistic->count;
|
|
||||||
}
|
|
||||||
|
|
||||||
return $grouped;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This shows a period overview for a tag. It goes back in time and lists all relevant transactions and sums.
|
* This shows a period overview for a tag. It goes back in time and lists all relevant transactions and sums.
|
||||||
@@ -594,66 +430,7 @@ trait PeriodOverview
|
|||||||
|
|
||||||
Log::debug(sprintf('Count of loops: %d', count($dates)));
|
Log::debug(sprintf('Count of loops: %d', count($dates)));
|
||||||
foreach ($dates as $currentDate) {
|
foreach ($dates as $currentDate) {
|
||||||
$entries[] = $this->getSingleTagPeriod($tag, $currentDate['period'], $currentDate['start'], $currentDate['end']);
|
$entries[] = $this->getSingleModelPeriod($tag, $currentDate['period'], $currentDate['start'], $currentDate['end']);
|
||||||
}
|
|
||||||
|
|
||||||
return $entries;
|
|
||||||
|
|
||||||
|
|
||||||
$range = Navigation::getViewRange(true);
|
|
||||||
[$start, $end] = $end < $start ? [$end, $start] : [$start, $end];
|
|
||||||
|
|
||||||
/** @var array $dates */
|
|
||||||
$dates = Navigation::blockPeriods($start, $end, $range);
|
|
||||||
$entries = [];
|
|
||||||
|
|
||||||
// collect all expenses in this period:
|
|
||||||
/** @var GroupCollectorInterface $collector */
|
|
||||||
$collector = app(GroupCollectorInterface::class);
|
|
||||||
$collector->setTag($tag);
|
|
||||||
$collector->setRange($start, $end);
|
|
||||||
$collector->setTypes([TransactionTypeEnum::DEPOSIT->value]);
|
|
||||||
$earnedSet = $collector->getExtractedJournals();
|
|
||||||
|
|
||||||
// collect all income in this period:
|
|
||||||
/** @var GroupCollectorInterface $collector */
|
|
||||||
$collector = app(GroupCollectorInterface::class);
|
|
||||||
$collector->setTag($tag);
|
|
||||||
$collector->setRange($start, $end);
|
|
||||||
$collector->setTypes([TransactionTypeEnum::WITHDRAWAL->value]);
|
|
||||||
$spentSet = $collector->getExtractedJournals();
|
|
||||||
|
|
||||||
// collect all transfers in this period:
|
|
||||||
/** @var GroupCollectorInterface $collector */
|
|
||||||
$collector = app(GroupCollectorInterface::class);
|
|
||||||
$collector->setTag($tag);
|
|
||||||
$collector->setRange($start, $end);
|
|
||||||
$collector->setTypes([TransactionTypeEnum::TRANSFER->value]);
|
|
||||||
$transferSet = $collector->getExtractedJournals();
|
|
||||||
|
|
||||||
// filer all of them:
|
|
||||||
$earnedSet = $this->filterJournalsByTag($earnedSet, $tag);
|
|
||||||
$spentSet = $this->filterJournalsByTag($spentSet, $tag);
|
|
||||||
$transferSet = $this->filterJournalsByTag($transferSet, $tag);
|
|
||||||
|
|
||||||
foreach ($dates as $currentDate) {
|
|
||||||
$spent = $this->filterJournalsByDate($spentSet, $currentDate['start'], $currentDate['end']);
|
|
||||||
$earned = $this->filterJournalsByDate($earnedSet, $currentDate['start'], $currentDate['end']);
|
|
||||||
$transferred = $this->filterJournalsByDate($transferSet, $currentDate['start'], $currentDate['end']);
|
|
||||||
$title = Navigation::periodShow($currentDate['end'], $currentDate['period']);
|
|
||||||
$entries[]
|
|
||||||
= [
|
|
||||||
'transactions' => 0,
|
|
||||||
'title' => $title,
|
|
||||||
'route' => route(
|
|
||||||
'tags.show',
|
|
||||||
[$tag->id, $currentDate['start']->format('Y-m-d'), $currentDate['end']->format('Y-m-d')]
|
|
||||||
),
|
|
||||||
'total_transactions' => count($spent) + count($earned) + count($transferred),
|
|
||||||
'spent' => $this->groupByCurrency($spent),
|
|
||||||
'earned' => $this->groupByCurrency($earned),
|
|
||||||
'transferred' => $this->groupByCurrency($transferred),
|
|
||||||
];
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return $entries;
|
return $entries;
|
||||||
@@ -750,26 +527,6 @@ trait PeriodOverview
|
|||||||
return $result;
|
return $result;
|
||||||
}
|
}
|
||||||
|
|
||||||
private function filterJournalsByTag(array $set, Tag $tag): array
|
|
||||||
{
|
|
||||||
$return = [];
|
|
||||||
foreach ($set as $entry) {
|
|
||||||
$found = false;
|
|
||||||
|
|
||||||
/** @var array $localTag */
|
|
||||||
foreach ($entry['tags'] as $localTag) {
|
|
||||||
if ($localTag['id'] === $tag->id) {
|
|
||||||
$found = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (false === $found) {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
$return[] = $entry;
|
|
||||||
}
|
|
||||||
|
|
||||||
return $return;
|
|
||||||
}
|
|
||||||
|
|
||||||
private function filterTransactionsByType(TransactionTypeEnum $type, Carbon $start, Carbon $end): array
|
private function filterTransactionsByType(TransactionTypeEnum $type, Carbon $start, Carbon $end): array
|
||||||
{
|
{
|
||||||
@@ -795,39 +552,6 @@ trait PeriodOverview
|
|||||||
return $result;
|
return $result;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Return only transactions where $account is the source.
|
|
||||||
*/
|
|
||||||
private function filterTransferredAway(Account $account, array $journals): array
|
|
||||||
{
|
|
||||||
$return = [];
|
|
||||||
|
|
||||||
/** @var array $journal */
|
|
||||||
foreach ($journals as $journal) {
|
|
||||||
if ($account->id === (int)$journal['source_account_id']) {
|
|
||||||
$return[] = $journal;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return $return;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Return only transactions where $account is the source.
|
|
||||||
*/
|
|
||||||
private function filterTransferredIn(Account $account, array $journals): array
|
|
||||||
{
|
|
||||||
$return = [];
|
|
||||||
|
|
||||||
/** @var array $journal */
|
|
||||||
foreach ($journals as $journal) {
|
|
||||||
if ($account->id === (int)$journal['destination_account_id']) {
|
|
||||||
$return[] = $journal;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return $return;
|
|
||||||
}
|
|
||||||
|
|
||||||
private function filterTransfers(string $direction, Carbon $start, Carbon $end): array
|
private function filterTransfers(string $direction, Carbon $start, Carbon $end): array
|
||||||
{
|
{
|
||||||
|
Reference in New Issue
Block a user