| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  | <?php | 
					
						
							|  |  |  | /** | 
					
						
							|  |  |  |  * UpdatedJournalEventHandler.php | 
					
						
							| 
									
										
										
										
											2017-10-21 08:40:00 +02:00
										 |  |  |  * Copyright (c) 2017 thegrumpydictator@gmail.com | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  |  * | 
					
						
							| 
									
										
										
										
											2017-10-21 08:40:00 +02:00
										 |  |  |  * This file is part of Firefly III. | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  |  * | 
					
						
							| 
									
										
										
										
											2017-10-21 08:40:00 +02:00
										 |  |  |  * 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 | 
					
						
							| 
									
										
										
										
											2017-12-17 14:41:58 +01:00
										 |  |  |  * along with Firefly III. If not, see <http://www.gnu.org/licenses/>. | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  |  */ | 
					
						
							| 
									
										
										
										
											2017-04-09 07:44:22 +02:00
										 |  |  | declare(strict_types=1); | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  | 
 | 
					
						
							|  |  |  | namespace FireflyIII\Handlers\Events; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | use FireflyIII\Events\UpdatedTransactionJournal; | 
					
						
							|  |  |  | use FireflyIII\Models\Rule; | 
					
						
							|  |  |  | use FireflyIII\Models\RuleGroup; | 
					
						
							| 
									
										
										
										
											2017-04-28 10:34:11 +02:00
										 |  |  | use FireflyIII\Repositories\RuleGroup\RuleGroupRepositoryInterface; | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  | use FireflyIII\Support\Events\BillScanner; | 
					
						
							| 
									
										
										
										
											2017-09-14 17:40:02 +02:00
										 |  |  | use FireflyIII\TransactionRules\Processor; | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  | 
 | 
					
						
							|  |  |  | /** | 
					
						
							| 
									
										
										
										
											2017-04-28 10:34:11 +02:00
										 |  |  |  * @codeCoverageIgnore | 
					
						
							| 
									
										
										
										
											2017-06-05 11:12:50 +02:00
										 |  |  |  * | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  |  * Class UpdatedJournalEventHandler | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | class UpdatedJournalEventHandler | 
					
						
							|  |  |  | { | 
					
						
							| 
									
										
										
										
											2017-11-15 12:25:49 +01:00
										 |  |  |     /** @var RuleGroupRepositoryInterface */ | 
					
						
							| 
									
										
										
										
											2017-04-28 10:34:11 +02:00
										 |  |  |     public $repository; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |     /** | 
					
						
							|  |  |  |      * StoredJournalEventHandler constructor. | 
					
						
							| 
									
										
										
										
											2017-06-05 08:31:22 +02:00
										 |  |  |      * | 
					
						
							|  |  |  |      * @param RuleGroupRepositoryInterface $ruleGroupRepository | 
					
						
							| 
									
										
										
										
											2017-04-28 10:34:11 +02:00
										 |  |  |      */ | 
					
						
							|  |  |  |     public function __construct(RuleGroupRepositoryInterface $ruleGroupRepository) | 
					
						
							|  |  |  |     { | 
					
						
							|  |  |  |         $this->repository = $ruleGroupRepository; | 
					
						
							|  |  |  |     } | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  | 
 | 
					
						
							|  |  |  |     /** | 
					
						
							|  |  |  |      * This method will check all the rules when a journal is updated. | 
					
						
							|  |  |  |      * | 
					
						
							| 
									
										
										
										
											2016-12-06 16:58:39 +01:00
										 |  |  |      * @param UpdatedTransactionJournal $updatedJournalEvent | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  |      * | 
					
						
							|  |  |  |      * @return bool | 
					
						
							|  |  |  |      */ | 
					
						
							| 
									
										
										
										
											2016-12-14 18:59:12 +01:00
										 |  |  |     public function processRules(UpdatedTransactionJournal $updatedJournalEvent): bool | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  |     { | 
					
						
							|  |  |  |         // get all the user's rule groups, with the rules, order by 'order'.
 | 
					
						
							| 
									
										
										
										
											2016-12-06 16:58:39 +01:00
										 |  |  |         $journal = $updatedJournalEvent->journal; | 
					
						
							| 
									
										
										
										
											2017-06-05 11:12:50 +02:00
										 |  |  |         $groups  = $this->repository->getActiveGroups($journal->user); | 
					
						
							| 
									
										
										
										
											2017-04-28 10:34:11 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  |         /** @var RuleGroup $group */ | 
					
						
							|  |  |  |         foreach ($groups as $group) { | 
					
						
							| 
									
										
										
										
											2017-04-28 10:34:11 +02:00
										 |  |  |             $rules = $this->repository->getActiveUpdateRules($group); | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  |             /** @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. | 
					
						
							|  |  |  |      * | 
					
						
							| 
									
										
										
										
											2016-12-06 16:58:39 +01:00
										 |  |  |      * @param UpdatedTransactionJournal $updatedJournalEvent | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  |      * | 
					
						
							|  |  |  |      * @return bool | 
					
						
							|  |  |  |      */ | 
					
						
							| 
									
										
										
										
											2016-12-06 16:58:39 +01:00
										 |  |  |     public function scanBills(UpdatedTransactionJournal $updatedJournalEvent): bool | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  |     { | 
					
						
							| 
									
										
										
										
											2016-12-06 16:58:39 +01:00
										 |  |  |         $journal = $updatedJournalEvent->journal; | 
					
						
							| 
									
										
										
										
											2016-10-22 09:31:27 +02:00
										 |  |  |         BillScanner::scan($journal); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |         return true; | 
					
						
							|  |  |  |     } | 
					
						
							| 
									
										
										
										
											2016-10-23 12:42:44 +02:00
										 |  |  | } |