mirror of
				https://github.com/firefly-iii/firefly-iii.git
				synced 2025-10-31 02:36:28 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			154 lines
		
	
	
		
			4.9 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			154 lines
		
	
	
		
			4.9 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
| <?php
 | |
| declare(strict_types=1);
 | |
| /**
 | |
|  * TransactionJournalFactory.php
 | |
|  * Copyright (c) 2018 thegrumpydictator@gmail.com
 | |
|  *
 | |
|  * This file is part of Firefly III.
 | |
|  *
 | |
|  * Firefly III is free software: you can redistribute it and/or modify
 | |
|  * it under the terms of the GNU General Public License as published by
 | |
|  * the Free Software Foundation, either version 3 of the License, or
 | |
|  * (at your option) any later version.
 | |
|  *
 | |
|  * Firefly III is distributed in the hope that it will be useful,
 | |
|  * but WITHOUT ANY WARRANTY; without even the implied warranty of
 | |
|  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 | |
|  * GNU General Public License for more details.
 | |
|  *
 | |
|  * You should have received a copy of the GNU General Public License
 | |
|  * along with Firefly III. If not, see <http://www.gnu.org/licenses/>.
 | |
|  */
 | |
| 
 | |
| 
 | |
| namespace FireflyIII\Factory;
 | |
| 
 | |
| use FireflyIII\Exceptions\FireflyException;
 | |
| use FireflyIII\Models\TransactionJournal;
 | |
| use FireflyIII\Models\TransactionType;
 | |
| use FireflyIII\Services\Internal\Support\JournalServiceTrait;
 | |
| use FireflyIII\User;
 | |
| use Log;
 | |
| 
 | |
| /**
 | |
|  * Class TransactionJournalFactory
 | |
|  */
 | |
| class TransactionJournalFactory
 | |
| {
 | |
|     use JournalServiceTrait;
 | |
|     /** @var User */
 | |
|     private $user;
 | |
| 
 | |
|     /**
 | |
|      * @param array $data
 | |
|      *
 | |
|      * @return TransactionJournal
 | |
|      * @throws FireflyException
 | |
|      */
 | |
|     public function create(array $data): TransactionJournal
 | |
|     {
 | |
|         Log::debug('Start of TransactionJournalFactory::create()');
 | |
|         // store basic journal first.
 | |
|         $type            = $this->findTransactionType($data['type']);
 | |
|         $defaultCurrency = app('amount')->getDefaultCurrencyByUser($this->user);
 | |
|         $journal         = TransactionJournal::create(
 | |
|             [
 | |
|                 'user_id'                 => $data['user'],
 | |
|                 'transaction_type_id'     => $type->id,
 | |
|                 'bill_id'                 => null,
 | |
|                 'transaction_currency_id' => $defaultCurrency->id,
 | |
|                 'description'             => $data['description'],
 | |
|                 'date'                    => $data['date']->format('Y-m-d'),
 | |
|                 'order'                   => 0,
 | |
|                 'tag_count'               => 0,
 | |
|                 'completed'               => 0,
 | |
|             ]
 | |
|         );
 | |
| 
 | |
|         // store basic transactions:
 | |
|         /** @var TransactionFactory $factory */
 | |
|         $factory = app(TransactionFactory::class);
 | |
|         $factory->setUser($this->user);
 | |
| 
 | |
|         /** @var array $trData */
 | |
|         foreach ($data['transactions'] as $trData) {
 | |
|             $factory->createPair($journal, $trData);
 | |
|         }
 | |
|         $journal->completed = true;
 | |
|         $journal->save();
 | |
| 
 | |
|         // link bill:
 | |
|         $this->connectBill($journal, $data);
 | |
| 
 | |
|         // link piggy bank (if transfer)
 | |
|         $this->connectPiggyBank($journal, $data);
 | |
| 
 | |
|         // link tags:
 | |
|         $this->connectTags($journal, $data);
 | |
| 
 | |
|         // store note:
 | |
|         $this->storeNote($journal, (string)$data['notes']);
 | |
| 
 | |
|         // store date meta fields (if present):
 | |
|         $fields = ['sepa-cc', 'sepa-ct-op', 'sepa-ct-id', 'sepa-db', 'sepa-country', 'sepa-ep', 'sepa-ci', 'interest_date', 'book_date', 'process_date',
 | |
|                    'due_date', 'payment_date', 'invoice_date', 'internal_reference', 'bunq_payment_id'];
 | |
| 
 | |
|         foreach ($fields as $field) {
 | |
|             $this->storeMeta($journal, $data, $field);
 | |
|         }
 | |
|         Log::debug('End of TransactionJournalFactory::create()');
 | |
| 
 | |
|         return $journal;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Set the user.
 | |
|      *
 | |
|      * @param User $user
 | |
|      */
 | |
|     public function setUser(User $user): void
 | |
|     {
 | |
|         $this->user = $user;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * @param TransactionJournal $journal
 | |
|      * @param array              $data
 | |
|      */
 | |
|     protected function connectPiggyBank(TransactionJournal $journal, array $data): void
 | |
|     {
 | |
|         /** @var PiggyBankFactory $factory */
 | |
|         $factory = app(PiggyBankFactory::class);
 | |
|         $factory->setUser($this->user);
 | |
| 
 | |
|         $piggyBank = $factory->find($data['piggy_bank_id'], $data['piggy_bank_name']);
 | |
|         if (null !== $piggyBank) {
 | |
|             /** @var PiggyBankEventFactory $factory */
 | |
|             $factory = app(PiggyBankEventFactory::class);
 | |
|             $factory->create($journal, $piggyBank);
 | |
|         }
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * Get the transaction type. Since this is mandatory, will throw an exception when nothing comes up. Will always
 | |
|      * use TransactionType repository.
 | |
|      *
 | |
|      * @param string $type
 | |
|      *
 | |
|      * @return TransactionType
 | |
|      * @throws FireflyException
 | |
|      */
 | |
|     protected function findTransactionType(string $type): TransactionType
 | |
|     {
 | |
|         $factory         = app(TransactionTypeFactory::class);
 | |
|         $transactionType = $factory->find($type);
 | |
|         if (null === $transactionType) {
 | |
|             Log::error(sprintf('Could not find transaction type for "%s"', $type)); // @codeCoverageIgnore
 | |
|             throw new FireflyException(sprintf('Could not find transaction type for "%s"', $type)); // @codeCoverageIgnore
 | |
|         }
 | |
| 
 | |
|         return $transactionType;
 | |
|     }
 | |
| 
 | |
| }
 |