mirror of
				https://github.com/firefly-iii/firefly-iii.git
				synced 2025-10-31 02:36:28 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			82 lines
		
	
	
		
			2.4 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
			
		
		
	
	
			82 lines
		
	
	
		
			2.4 KiB
		
	
	
	
		
			PHP
		
	
	
	
	
	
| <?php
 | |
| /**
 | |
|  * UpdatedJournalEventHandler.php
 | |
|  * Copyright (C) 2016 thegrumpydictator@gmail.com
 | |
|  *
 | |
|  * This software may be modified and distributed under the terms of the
 | |
|  * Creative Commons Attribution-ShareAlike 4.0 International License.
 | |
|  *
 | |
|  * See the LICENSE file for details.
 | |
|  */
 | |
| 
 | |
| declare(strict_types = 1);
 | |
| 
 | |
| namespace FireflyIII\Handlers\Events;
 | |
| 
 | |
| 
 | |
| use FireflyIII\Events\UpdatedTransactionJournal;
 | |
| use FireflyIII\Models\Rule;
 | |
| use FireflyIII\Models\RuleGroup;
 | |
| use FireflyIII\Rules\Processor;
 | |
| use FireflyIII\Support\Events\BillScanner;
 | |
| 
 | |
| /**
 | |
|  * Class UpdatedJournalEventHandler
 | |
|  *
 | |
|  * @package FireflyIII\Handlers\Events
 | |
|  */
 | |
| class UpdatedJournalEventHandler
 | |
| {
 | |
| 
 | |
|     /**
 | |
|      * This method will check all the rules when a journal is updated.
 | |
|      *
 | |
|      * @param UpdatedTransactionJournal $updatedJournalEvent
 | |
|      *
 | |
|      * @return bool
 | |
|      */
 | |
|     public function processRules(UpdatedTransactionJournal $updatedJournalEvent): bool
 | |
|     {
 | |
|         // get all the user's rule groups, with the rules, order by 'order'.
 | |
|         $journal = $updatedJournalEvent->journal;
 | |
|         $groups  = $journal->user->ruleGroups()->where('rule_groups.active', 1)->orderBy('order', 'ASC')->get();
 | |
|         //
 | |
|         /** @var RuleGroup $group */
 | |
|         foreach ($groups as $group) {
 | |
|             $rules = $group->rules()
 | |
|                            ->leftJoin('rule_triggers', 'rules.id', '=', 'rule_triggers.rule_id')
 | |
|                            ->where('rule_triggers.trigger_type', 'user_action')
 | |
|                            ->where('rule_triggers.trigger_value', 'update-journal')
 | |
|                            ->where('rules.active', 1)
 | |
|                            ->get(['rules.*']);
 | |
|             /** @var Rule $rule */
 | |
|             foreach ($rules as $rule) {
 | |
|                 $processor = Processor::make($rule);
 | |
|                 $processor->handleTransactionJournal($journal);
 | |
| 
 | |
|                 if ($rule->stop_processing) {
 | |
|                     break;
 | |
|                 }
 | |
| 
 | |
|             }
 | |
|         }
 | |
| 
 | |
|         return true;
 | |
|     }
 | |
| 
 | |
|     /**
 | |
|      * This method calls a special bill scanner that will check if the updated journal is part of a bill.
 | |
|      *
 | |
|      * @param UpdatedTransactionJournal $updatedJournalEvent
 | |
|      *
 | |
|      * @return bool
 | |
|      */
 | |
|     public function scanBills(UpdatedTransactionJournal $updatedJournalEvent): bool
 | |
|     {
 | |
|         $journal = $updatedJournalEvent->journal;
 | |
|         BillScanner::scan($journal);
 | |
| 
 | |
|         return true;
 | |
|     }
 | |
| }
 |