. */ declare(strict_types=1); namespace FireflyIII\Services\Internal\Support; use FireflyIII\Factory\AccountFactory; use FireflyIII\Factory\AccountMetaFactory; use FireflyIII\Factory\TransactionFactory; use FireflyIII\Factory\TransactionJournalFactory; use FireflyIII\Models\Account; use FireflyIII\Models\AccountType; use FireflyIII\Models\Note; use FireflyIII\Models\Transaction; use FireflyIII\Models\TransactionJournal; use FireflyIII\Models\TransactionType; use FireflyIII\Services\Internal\Destroy\JournalDestroyService; use FireflyIII\User; use Log; use Validator; /** * Trait AccountServiceTrait * */ trait AccountServiceTrait { /** @var array */ public $validAssetFields = ['accountRole', 'accountNumber', 'currency_id', 'BIC']; /** @var array */ public $validCCFields = ['accountRole', 'ccMonthlyPaymentDate', 'ccType', 'accountNumber', 'currency_id', 'BIC']; /** @var array */ public $validFields = ['accountNumber', 'currency_id', 'BIC','interest','interest_period']; /** * @param Account $account * * @return bool */ public function deleteIB(Account $account): bool { Log::debug(sprintf('deleteIB() for account #%d', $account->id)); $openingBalance = $this->getIBJournal($account); // opening balance data? update it! if (null !== $openingBalance) { Log::debug('Opening balance journal found, delete journal.'); /** @var JournalDestroyService $service */ $service = app(JournalDestroyService::class); $service->destroy($openingBalance); return true; } return true; } /** * @param null|string $iban * * @return null|string */ public function filterIban(?string $iban): ?string { if (null === $iban) { return null; } $data = ['iban' => $iban]; $rules = ['iban' => 'required|iban']; $validator = Validator::make($data, $rules); if ($validator->fails()) { Log::info(sprintf('Detected invalid IBAN ("%s"). Return NULL instead.', $iban)); return null; } return $iban; } /** * Find existing opening balance. * * @param Account $account * * @return TransactionJournal|null */ public function getIBJournal(Account $account): ?TransactionJournal { $journal = TransactionJournal::leftJoin('transactions', 'transactions.transaction_journal_id', '=', 'transaction_journals.id') ->where('transactions.account_id', $account->id) ->transactionTypes([TransactionType::OPENING_BALANCE]) ->first(['transaction_journals.*']); if (null === $journal) { Log::debug('Could not find a opening balance journal, return NULL.'); return null; } Log::debug(sprintf('Found opening balance: journal #%d.', $journal->id)); return $journal; } /** * @param Account $account * @param array $data * * @return TransactionJournal|null * @throws \FireflyIII\Exceptions\FireflyException * @SuppressWarnings(PHPMD.ExcessiveMethodLength) */ public function storeIBJournal(Account $account, array $data): ?TransactionJournal { $amount = (string)$data['openingBalance']; Log::debug(sprintf('Submitted amount is %s', $amount)); if (0 === bccomp($amount, '0')) { return null; } // store journal, without transactions: $name = $data['name']; $currencyId = $data['currency_id']; $journalData = [ 'type' => TransactionType::OPENING_BALANCE, 'user' => $account->user->id, 'transaction_currency_id' => $currencyId, 'description' => (string)trans('firefly.initial_balance_description', ['account' => $account->name]), 'completed' => true, 'date' => $data['openingBalanceDate'], 'bill_id' => null, 'bill_name' => null, 'piggy_bank_id' => null, 'piggy_bank_name' => null, 'tags' => null, 'notes' => null, 'transactions' => [], ]; /** @var TransactionJournalFactory $factory */ $factory = app(TransactionJournalFactory::class); $factory->setUser($account->user); $journal = $factory->create($journalData); $opposing = $this->storeOpposingAccount($account->user, $name); Log::notice(sprintf('Created new opening balance journal: #%d', $journal->id)); $firstAccount = $account; $secondAccount = $opposing; $firstAmount = $amount; $secondAmount = bcmul($amount, '-1'); Log::notice(sprintf('First amount is %s, second amount is %s', $firstAmount, $secondAmount)); if (bccomp($amount, '0') === -1) { Log::debug(sprintf('%s is a negative number.', $amount)); $firstAccount = $opposing; $secondAccount = $account; $firstAmount = bcmul($amount, '-1'); $secondAmount = $amount; Log::notice(sprintf('First amount is %s, second amount is %s', $firstAmount, $secondAmount)); } /** @var TransactionFactory $factory */ $factory = app(TransactionFactory::class); $factory->setUser($account->user); $factory->create( [ 'account' => $firstAccount, 'transaction_journal' => $journal, 'amount' => $firstAmount, 'currency_id' => $currencyId, 'description' => null, 'identifier' => 0, 'foreign_amount' => null, 'reconciled' => false, ] ); $factory->create( [ 'account' => $secondAccount, 'transaction_journal' => $journal, 'amount' => $secondAmount, 'currency_id' => $currencyId, 'description' => null, 'identifier' => 0, 'foreign_amount' => null, 'reconciled' => false, ] ); return $journal; } /** * @param User $user * @param string $name * * @return Account * @throws \FireflyIII\Exceptions\FireflyException */ public function storeOpposingAccount(User $user, string $name): Account { $name .= ' initial balance'; Log::debug('Going to create an opening balance opposing account.'); /** @var AccountFactory $factory */ $factory = app(AccountFactory::class); $factory->setUser($user); return $factory->findOrCreate($name, AccountType::INITIAL_BALANCE); } /** * @param Account $account * @param array $data * * @return bool * @throws \FireflyIII\Exceptions\FireflyException */ public function updateIB(Account $account, array $data): bool { Log::debug(sprintf('updateInitialBalance() for account #%d', $account->id)); $openingBalance = $this->getIBJournal($account); // no opening balance journal? create it: if (null === $openingBalance) { Log::debug('No opening balance journal yet, create journal.'); $this->storeIBJournal($account, $data); return true; } // opening balance data? update it! if (null !== $openingBalance->id) { Log::debug('Opening balance journal found, update journal.'); $this->updateIBJournal($account, $openingBalance, $data); return true; } return true; // @codeCoverageIgnore } /** * @param Account $account * @param TransactionJournal $journal * @param array $data * * @return bool * @SuppressWarnings(PHPMD.CyclomaticComplexity) */ public function updateIBJournal(Account $account, TransactionJournal $journal, array $data): bool { $date = $data['openingBalanceDate']; $amount = (string)$data['openingBalance']; $negativeAmount = bcmul($amount, '-1'); $currencyId = (int)$data['currency_id']; Log::debug(sprintf('Submitted amount for opening balance to update is "%s"', $amount)); if (0 === bccomp($amount, '0')) { Log::notice(sprintf('Amount "%s" is zero, delete opening balance.', $amount)); /** @var JournalDestroyService $service */ $service = app(JournalDestroyService::class); $service->destroy($journal); return true; } $journal->date = $date; $journal->transaction_currency_id = $currencyId; $journal->save(); /** @var Transaction $transaction */ foreach ($journal->transactions()->get() as $transaction) { if ((int)$account->id === (int)$transaction->account_id) { Log::debug(sprintf('Will (eq) change transaction #%d amount from "%s" to "%s"', $transaction->id, $transaction->amount, $amount)); $transaction->amount = $amount; $transaction->transaction_currency_id = $currencyId; $transaction->save(); } if (!((int)$account->id === (int)$transaction->account_id)) { Log::debug(sprintf('Will (neq) change transaction #%d amount from "%s" to "%s"', $transaction->id, $transaction->amount, $negativeAmount)); $transaction->amount = $negativeAmount; $transaction->transaction_currency_id = $currencyId; $transaction->save(); } } Log::debug('Updated opening balance journal.'); return true; } /** * Update meta data for account. Depends on type which fields are valid. * * @param Account $account * @param array $data * @SuppressWarnings(PHPMD.CyclomaticComplexity) */ public function updateMetaData(Account $account, array $data): void { $fields = $this->validFields; if ($account->accountType->type === AccountType::ASSET) { $fields = $this->validAssetFields; } if ($account->accountType->type === AccountType::ASSET && 'ccAsset' === $data['accountRole']) { $fields = $this->validCCFields; } /** @var AccountMetaFactory $factory */ $factory = app(AccountMetaFactory::class); foreach ($fields as $field) { $factory->crud($account, $field, (string)($data[$field] ?? '')); } } /** * @param Account $account * @param string $note * * @return bool */ public function updateNote(Account $account, string $note): bool { if ('' === $note) { $dbNote = $account->notes()->first(); if (null !== $dbNote) { $dbNote->delete(); } return true; } $dbNote = $account->notes()->first(); if (null === $dbNote) { $dbNote = new Note; $dbNote->noteable()->associate($account); } $dbNote->text = trim($note); $dbNote->save(); return true; } /** * Verify if array contains valid data to possibly store or update the opening balance. * * @param array $data * * @return bool */ public function validIBData(array $data): bool { $data['openingBalance'] = (string)($data['openingBalance'] ?? ''); if (isset($data['openingBalance'], $data['openingBalanceDate']) && \strlen($data['openingBalance']) > 0) { Log::debug('Array has valid opening balance data.'); return true; } Log::debug('Array does not have valid opening balance data.'); return false; } }