James Cole 2022-01-24 07:38:05 +01:00
parent ecc72dd01b
commit 75d52b7024
3 changed files with 76 additions and 50 deletions

View File

@ -79,7 +79,17 @@ class GroupUpdateService
$existing = $transactionGroup->transactionJournals->pluck('id')->toArray(); $existing = $transactionGroup->transactionJournals->pluck('id')->toArray();
$updated = $this->updateTransactions($transactionGroup, $transactions); $updated = $this->updateTransactions($transactionGroup, $transactions);
Log::debug('Array of updated IDs: ', $updated);
if(0 === count($updated)) {
Log::error('There were no transactions updated or created. Will not delete anything.');
$transactionGroup->refresh();
app('preferences')->mark();
return $transactionGroup;
}
$result = array_diff($existing, $updated); $result = array_diff($existing, $updated);
Log::debug('Result of DIFF: ', $result);
if (count($result) > 0) { if (count($result) > 0) {
/** @var string $deletedId */ /** @var string $deletedId */
foreach ($result as $deletedId) { foreach ($result as $deletedId) {
@ -127,6 +137,7 @@ class GroupUpdateService
*/ */
private function updateTransactions(TransactionGroup $transactionGroup, array $transactions): array private function updateTransactions(TransactionGroup $transactionGroup, array $transactions): array
{ {
// updated or created transaction journals:
$updated = []; $updated = [];
/** /**
* @var int $index * @var int $index
@ -151,8 +162,14 @@ class GroupUpdateService
} }
} }
Log::debug('Call createTransactionJournal'); Log::debug('Call createTransactionJournal');
$this->createTransactionJournal($transactionGroup, $transaction); $newJournal = $this->createTransactionJournal($transactionGroup, $transaction);
Log::debug('Done calling createTransactionJournal'); Log::debug('Done calling createTransactionJournal');
if (null !== $newJournal) {
$updated[] = $newJournal->id;
}
if (null === $newJournal) {
Log::error('createTransactionJournal returned NULL, indicating something went wrong.');
}
} }
if (null !== $journal) { if (null !== $journal) {
Log::debug('Call updateTransactionJournal'); Log::debug('Call updateTransactionJournal');
@ -169,12 +186,13 @@ class GroupUpdateService
* @param TransactionGroup $transactionGroup * @param TransactionGroup $transactionGroup
* @param array $data * @param array $data
* *
* @return TransactionJournal|null
*
* @throws FireflyException * @throws FireflyException
* @throws DuplicateTransactionException * @throws DuplicateTransactionException
*/ */
private function createTransactionJournal(TransactionGroup $transactionGroup, array $data): void private function createTransactionJournal(TransactionGroup $transactionGroup, array $data): ?TransactionJournal
{ {
$submission = [ $submission = [
'transactions' => [ 'transactions' => [
$data, $data,
@ -195,6 +213,11 @@ class GroupUpdateService
$transactionGroup->transactionJournals()->save($journal); $transactionGroup->transactionJournals()->save($journal);
} }
); );
if (0 === $collection->count()) {
return null;
}
return $collection->first();
} }
} }

View File

@ -83,6 +83,9 @@ trait GroupValidation
} }
} }
/**
* @param Validator $validator
*/
protected function preventNoAccountInfo(Validator $validator): void protected function preventNoAccountInfo(Validator $validator): void
{ {
$transactions = $this->getTransactionsArray($validator); $transactions = $this->getTransactionsArray($validator);
@ -92,7 +95,7 @@ trait GroupValidation
/** @var array $transaction */ /** @var array $transaction */
foreach ($transactions as $transaction) { foreach ($transactions as $transaction) {
foreach($keys as $key) { foreach($keys as $key) {
if(array_key_exists($key, $transaction) && '' !== $transaction[$key]) { if(array_key_exists($key, $transaction) && '' !== (string) $transaction[$key]) {
$hasAccountInfo = true; $hasAccountInfo = true;
} }
} }