IntenseFinance/firefly-iii
3
0
Fork 0
mirror of https://github.com/firefly-iii/firefly-iii.git synced 2024-11-23 01:16:46 -06:00
Code Issues Packages Projects Releases Wiki Activity

Small code clean up [skip ci]

Browse Source
This commit is contained in:
James Cole 2016-02-17 17:32:02 +01:00
parent f9e2a677d9
commit 8cfe25bfac
1 changed files with 79 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

138
app/Rules/TransactionMatcher.php
View File

@ -12,29 +12,27 @@ namespace FireflyIII\Rules;
use FireflyIII\Models\Rule;
use FireflyIII\Models\TransactionType;
use FireflyIII\Repositories\Journal\JournalRepositoryInterface;
/**
* Class TransactionMatcher is used to find a list of
* Class TransactionMatcher is used to find a list of
* transaction matching a set of triggers
*
* @package FireflyIII\Rules
*/
class TransactionMatcher
{
/** @var array List of triggers to match*/
protected $triggers = [];
/** @var int Maximum number of transaction to search in (for performance reasons) **/
/** @var int Maximum number of transaction to search in (for performance reasons) * */
protected $maxTransactionsToSearchIn = 1000;
/** @var array */
protected $transactionTypes = [ TransactionType::DEPOSIT, TransactionType::WITHDRAWAL, TransactionType::TRANSFER ];
protected $transactionTypes = [TransactionType::DEPOSIT, TransactionType::WITHDRAWAL, TransactionType::TRANSFER];
/** @var array List of triggers to match */
protected $triggers = [];
/**
* Default constructor
*
* @param Rule $rule
* @param TransactionJournal $journal
* @param $triggers
*/
public function __construct($triggers)
{
@ -43,106 +41,128 @@ class TransactionMatcher
/**
* Find matching transactions for the current set of triggers
* @param number $maxResults The maximum number of transactions returned
*
* @param int $maxResults The maximum number of transactions returned
*
* @return array
*/
public function findMatchingTransactions($maxResults = 50) {
public function findMatchingTransactions($maxResults = 50)
{
/** @var JournalRepositoryInterface $repository */
$repository = app('FireflyIII\Repositories\Journal\JournalRepositoryInterface');
// We don't know the number of transaction to fetch from the database, in
// order to return the proper number of matching transactions. Since we don't want
// to fetch all transactions (as the first transactions already match, or the last
// transactions are irrelevant), we will fetch data in pages.
// The optimal pagesize is somewhere between the maximum number of results to be returned
// and the maximum number of transactions to consider.
$pagesize = min($this->maxTransactionsToSearchIn / 2, $maxResults * 2);
// Variables used within the loop
$numTransactionsProcessed = 0;
$page = 1;
$matchingTransactions = [];
$page = 1;
$matchingTransactions = [];
// Flags to indicate the end of the loop
$reachedEndOfList = false;
$foundEnoughTransactions = false;
$reachedEndOfList = false;
$foundEnoughTransactions = false;
$searchedEnoughTransactions = false;
// Start a loop to fetch batches of transactions. The loop will finish if:
// - all transactions have been fetched from the database
// - the maximum number of transactions to return has been found
// - the maximum number of transactions to search in have been searched
do {
// Fetch a batch of transactions from the database
$offset = $page > 0 ? ($page - 1) * $pagesize : 0;
$transactions = $repository->getJournalsOfTypes( $this->transactionTypes, $offset, $page, $pagesize)->getCollection()->all();
$offset = $page > 0 ? ($page - 1) * $pagesize : 0;
$transactions = $repository->getJournalsOfTypes($this->transactionTypes, $offset, $page, $pagesize)->getCollection()->all();
// Filter transactions that match the rule
$matchingTransactions += array_filter( $transactions, function($transaction) {
$matchingTransactions += array_filter(
$transactions, function ($transaction) {
$processor = new Processor(new Rule, $transaction);
return $processor->isTriggeredBy($this->triggers);
});
}
);
// Update counters
$page++;
$numTransactionsProcessed += count($transactions);
// Check for conditions to finish the loop
$reachedEndOfList = (count($transactions) < $pagesize);
$foundEnoughTransactions = (count($matchingTransactions) >= $maxResults);
$searchedEnoughTransactions = ($numTransactionsProcessed >= $this->maxTransactionsToSearchIn);
} while( !$reachedEndOfList && !$foundEnoughTransactions && !$searchedEnoughTransactions);
$searchedEnoughTransactions = ($numTransactionsProcessed >= $this->maxTransactionsToSearchIn);
} while (!$reachedEndOfList && !$foundEnoughTransactions && !$searchedEnoughTransactions);
// If the list of matchingTransactions is larger than the maximum number of results
// (e.g. if a large percentage of the transactions match), truncate the list
$matchingTransactions = array_slice($matchingTransactions, 0, $maxResults);
return $matchingTransactions;
}
/**
* @return array
*/
public function getTriggers() {
return $this->triggers;
}
/**
* @param array $triggers
*/
public function setTriggers($triggers) {
$this->triggers = $triggers;
return $this;
}
/**
* @return array
*/
public function getTransactionLimit() {
public function getTransactionLimit()
{
return $this->maxTransactionsToSearchIn;
}
/**
* @param int $limit
*/
public function setTransactionLimit(int $limit) {
$this->maxTransactionsToSearchIn = $limit;
return $this;
}
/**
* @return array
*/
public function getTransactionTypes() {
public function getTransactionTypes()
{
return $this->transactionTypes;
}
/**
* @param array $transactionTypes
*
* @return $this
*/
public function setTransactionTypes(array $transactionTypes) {
public function setTransactionTypes(array $transactionTypes)
{
$this->transactionTypes = $transactionTypes;
return $this;
}
/**
* @return array
*/
public function getTriggers()
{
return $this->triggers;
}
/**
* @param array $triggers
*
* @return $this
*/
public function setTriggers($triggers)
{
$this->triggers = $triggers;
return $this;
}
/**
* @param int $limit
*
* @return $this
*/
public function setTransactionLimit(int $limit)
{
$this->maxTransactionsToSearchIn = $limit;
return $this;
}
}