Projekt

Obecné

Profil

Stáhnout (20.5 KB) Statistiky
| Větev: | Tag: | Revize:

freenetis-github/application/models/transfer.php @ c2e44ab0

8baed187 Michal Kliment
<?php defined('SYSPATH') or die('No direct script access.');
/*
* This file is part of open source system FreenetIS
* and it is release under GPLv3 licence.
*
* More info about licence can be found:
* http://www.gnu.org/licenses/gpl-3.0.html
*
* More info about project can be found:
* http://www.freenetis.org/
*
*/

/**
* Transfer between accounts.
*
* @package Model
*
* @property integer $id
* @property integer $origin_id
* @property Account_Model $origin
* @property integer $destination_id
* @property Account_Model $destination
* @property integer $previous_transfer_id
* @property Transfer_Model $previous_transfer
* @property integer $member_id
* @property Member_Model $member
* @property integer $user_id
* @property User_Model $user
* @property integer $type
* @property datetime $datetime
* @property datetime $creation_datetime
* @property string $text
* @property double $amount
*/
class Transfer_Model extends ORM
{
/** Special type of transfer: deduct member fee */
const DEDUCT_MEMBER_FEE = 1;
/** Special type of transfer: deduct entrance fee */
const DEDUCT_ENTRANCE_FEE = 2;
/** Special type of transfer: deduct voip_unnaccounted fee */
const DEDUCT_VOIP_UNNACCOUNTED_FEE = 3;
/** Special type of transfer: deduct voip_accounted fee */
const DEDUCT_VOIP_ACCOUNTED_FEE = 4;
/** Special type of transfer: deduct device fee */
const DEDUCT_DEVICE_FEE = 5;
/** Group of transfers: all */
const ALL_TRANSFERS = 1;
/** Group of transfers: without inner */
const WITHOUT_INNER = 2;
/** Inbound ans outbound type of transfers */
const INBOUND_AND_OUTBOUND = 1;
/** Inbound type of transfers */
const INBOUND = 2;
/** Unbound type of transfers */
const OUTBOUND = 3;
protected $belongs_to = array
(
'origin' => 'account',
'destination' => 'account',
'previous_transfer' => 'transfer',
'user', 'member'
);
protected $has_many = array('job_reports');

/**
* Contruct of app, shutdown action logs by default
* @param type $id
*/
public function __construct($id = NULL)
{
parent::__construct($id);

// disable action log
$this->set_logger(FALSE);
}

/**
* Function gets all double-entry transfer. They are shown in day book.
*
* @param integer $limit_from
* @param integer $limit_results
* @param string $order_by
* @param string $order_by_direction
* @param array $filter_values
* @return Mysql_Result
*/
public function get_all_transfers(
$limit_from = 0, $limit_results = 20,
$order_by = 'id', $order_by_direction = 'desc',
$filter_values = array())
{
$where = '';
// order by direction check
if (strtolower($order_by_direction) != 'desc')
{
$order_by_direction = 'asc';
}
// filter
if (is_array($filter_values))
{
foreach($filter_values as $key => $value)
{
if ($key != 'submit' && $key != 'group')
{
if ($where == '')
$where = 'WHERE ';
else
$where .= ' AND ';

if ($key == 'oa_name')
$where .= "oa.name LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
if ($key == 'da_name')
$where .= "da.name LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
if ($key == 'text')
$where .= "t.text LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
if ($key == 'datetime')
$where .= "t.datetime LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
if ($key == 'amount')
$where .= "t.amount LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
}

if ($key == 'group')
{
if ($value == self::WITHOUT_INNER)
{
if ($where == '')
$where = 'WHERE ';
else
$where .= ' AND ';
$where .= "oa.account_attribute_id <> da.account_attribute_id";
}
}

}
}
// query
return $this->db->query("
SELECT t.id, oa.id AS oa_id, oa.name AS oa_name,
oa.account_attribute_id AS oa_attribute,
da.id AS da_id, da.name AS da_name,
da.account_attribute_id AS da_attribute,
t.text, t.amount AS daybook_amount, t.datetime
FROM transfers t
LEFT JOIN accounts oa ON oa.id = t.origin_id
LEFT JOIN accounts da ON da.id = t.destination_id
$where
ORDER BY " . $this->db->escape_column($order_by) . " $order_by_direction
LIMIT ".intval($limit_from).", ".intval($limit_results)."
");
}

/**
* Function counts all transfers. Used in day book.
*
* @return integer
*/
public function count_all_transfers($filter_values = array())
{
$where = '';
// filter
if (is_array($filter_values))
{
foreach($filter_values as $key => $value)
{
if ($key == 'group')
{
if ($value == self::WITHOUT_INNER)
{
$where .= (empty($where)) ? 'WHERE ' : ' AND ';
$where .= "oa.account_attribute_id <> da.account_attribute_id";
}
}
else if ($key != 'submit')
{
$where .= (empty($where)) ? 'WHERE ' : ' AND ';
if ($key == 'oa_name')
{
$where .= "oa.name LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
}
else if ($key == 'da_name')
{
$where .= "da.name LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
}
else if ($key == 'text')
{
$where .= "t.text LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
}
else if ($key == 'datetime')
{
$where .= "t.datetime LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
}
else if ($key == 'amount')
{
$where .= "t.amount LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
}
else if ($where == 'WHERE ')
{
$where = '';
}
}
}
}
// query
return $this->db->query("
SELECT COUNT(*) AS total
FROM transfers t
LEFT JOIN accounts oa ON oa.id = t.origin_id
LEFT JOIN accounts da ON da.id = t.destination_id
$where
")->current()->total;
}
/**
* Function gets all money transfers of double-entry account.
* @param $account_id
* @param $limit_from
* @param $limit_results
* @param $order_by
* @param $order_by_direction
* @return Mysql_Result
*/
public function get_transfers($account_id = null, $limit_from = 0,
$limit_results = 20, $order_by = 't.id', $order_by_direction = 'ASC',
$filter_values = array())
{
$account_id = intval($account_id);
// filter
if (is_array($filter_values))
{
if ($filter_values['type'] == self::INBOUND)
$where = "WHERE (t.destination_id = $account_id)";
elseif ($filter_values['type'] == self::OUTBOUND)
$where = "WHERE (t.origin_id = $account_id)";
else
$where = "WHERE (t.origin_id = $account_id OR t.destination_id = $account_id)";
foreach($filter_values as $key => $value)
{
if ($key != 'submit' && $key != 'type')
$where .= ' AND ';
if ($key == 'name')
$where .= "a.name LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
if ($key == 'text')
$where .= "t.text LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
if ($key == 'datetime')
$where .= "t.datetime LIKE " . $this->db->escape("%$value%");
if ($key == 'amount')
$where .= "t.amount LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
}
}
// order by check
if ($order_by == 'amount')
{
$order_by = 'IF(t.destination_id = '.$account_id.', t.amount, -t.amount)';
}
else
{
$order_by = $this->db->escape_column($order_by);
}
// order by direction check
if (strtolower($order_by_direction) != 'desc')
{
$order_by_direction = 'asc';
}
// query
return $this->db->query("
SELECT t.id, t.text,
IF(t.amount <> 0, IF(t.destination_id = $account_id, t.amount, -t.amount), 0) AS amount,
t.datetime, t.origin_id, t.destination_id, a.name,
IF(t.destination_id = $account_id, bt.variable_symbol, NULL) AS variable_symbol,
(
SELECT SUM(IF(t.destination_id = $account_id, t.amount, 0)) AS inbound
FROM transfers t
LEFT JOIN accounts a ON a.id = IF(t.origin_id = $account_id, t.destination_id, t.origin_id)
$where
) AS inbound,
(
SELECT SUM(IF(t.origin_id = $account_id, t.amount, 0)) AS outbound
FROM transfers t
LEFT JOIN accounts a ON a.id = IF(t.origin_id = $account_id, t.destination_id, t.origin_id)
$where
) AS outbound
FROM transfers t
LEFT JOIN accounts a ON a.id = IF(t.origin_id = $account_id, t.destination_id, t.origin_id)
LEFT JOIN transfers pt ON pt.id = t.previous_transfer_id
LEFT JOIN bank_transfers bt ON pt.id = bt.transfer_id
$where
ORDER BY $order_by $order_by_direction
LIMIT ".intval($limit_from).", ".intval($limit_results)."
");
}
/**
* Function gets all money transfers of double-entry account.
*
* @param $account_id
* @param $limit_from
* @param $limit_results
* @param $order_by
* @param $order_by_direction
* @return integer
*/
public function count_transfers($account_id = null, $filter_values = array())
{
$account_id = intval($account_id);
$where = '';
// filter
if (is_array($filter_values))
{
$where = "WHERE (t.origin_id = $account_id OR t.destination_id = $account_id)";
if (array_key_exists('type', $filter_values))
{
if ($filter_values['type'] == self::INBOUND)
$where = "WHERE (t.destination_id = $account_id)";
else if ($filter_values['type'] == self::OUTBOUND)
$where = "WHERE (t.origin_id = $account_id)";
}
foreach($filter_values as $key => $value)
{
if ($key == 'name')
{
$where .= " AND a.name LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
}
else if ($key == 'text')
{
$where .= " AND t.text LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
}
else if ($key == 'datetime')
{
$where .= " AND t.datetime LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
}
else if ($key == 'amount')
{
$where .= " AND t.amount LIKE " . $this->db->escape("%$value%")
. " COLLATE utf8_general_ci";
}
}
}
// query
return $this->db->query("
SELECT COUNT(*) AS total
FROM transfers t
LEFT JOIN accounts a ON a.id = IF(t.origin_id = ?, t.destination_id, t.origin_id)
$where
", $account_id)->current()->total;
}
/**
* Function gets information of specified transfer.
*
* @param integer $trans_id
* @return Mysql_Result
*/
public function get_transfer($trans_id = null)
{
$result = $this->db->query("
SELECT t.id, t.previous_transfer_id, t.datetime, t.creation_datetime,
t.text, t.amount, t.member_id, t.user_id, oa.id AS oa_id,
oa.name AS oa_name, da.id AS da_id, da.name AS da_name,
u.name, u.surname, j.id AS job_id, j.description AS job_description,
jr.id AS job_report_id, jr.description AS job_report_description
FROM transfers t
LEFT JOIN accounts oa ON oa.id = t.origin_id
LEFT JOIN accounts da ON da.id = t.destination_id
LEFT JOIN users u ON t.user_id = u.id
LEFT JOIN jobs j ON j.transfer_id = t.id
LEFT JOIN job_reports jr ON jr.id = j.job_report_id
WHERE t.id = ?
GROUP BY t.id
", $trans_id);
return ($result && $result->count()) ? $result->current() : null;
}

/**
* Function gets dependent transfers of transfer that is member fee payment.
*
* @param $transfer_id
* @return Mysql_Result
*/
public function get_dependent_transfers($transfer_id)
{
return $this->db->query("
SELECT dt.*
FROM transfers t
JOIN transfers dt ON dt.previous_transfer_id = t.id
WHERE t.id = ?
", $transfer_id);
}
/**
* Gets "entrance fee" transfers of given account.
*
* @author Jiri Svitak
* @param $account_id
* @return Mysql_Result
*/
public function get_entrance_fee_transfers_of_account($account_id)
{
return $this->db->query("
SELECT t.id, t.datetime, amount,
(
SELECT SUM(t.amount) AS total_amount
FROM transfers t
WHERE t.origin_id = ? AND t.type = ?
) AS total_amount
FROM transfers t
WHERE t.origin_id = ? AND t.type = ?
GROUP BY t.id, t.datetime, t.amount
ORDER BY t.datetime DESC
", array
(
$account_id, Transfer_Model::DEDUCT_ENTRANCE_FEE,
$account_id, Transfer_Model::DEDUCT_ENTRANCE_FEE
));
}
/**
* Returns datetime of last entrance fee transfer of account
*
* @author Michal Kliment
* @param type $account_id
* @return null
*/
public function get_last_entrance_fee_transfer_datetime_of_account($account_id)
{
$result = $this->db->query("
SELECT t.datetime
FROM transfers t
WHERE t.origin_id = ? AND t.type = ?
GROUP BY t.id, t.datetime, t.amount
ORDER BY t.datetime DESC
LIMIT 0,1
", array
(
$account_id, Transfer_Model::DEDUCT_ENTRANCE_FEE,
$account_id, Transfer_Model::DEDUCT_ENTRANCE_FEE
));
if ($result && $result->current() && $result->current()->datetime != '')
return $result->current()->datetime;
else
return NULL;
}
/**
* Count total amount of entrance fee transfers of account
*
* @author Michal Kliment
* @param type $account_id
* @return int
*/
public function count_entrance_fee_transfers_of_account($account_id)
{
$transfers = $this->get_entrance_fee_transfers_of_account($account_id);
if ($transfers && $transfers->current())
return $transfers->current()->total_amount;
else
return 0;
}

/**
* Used for deduction of device repayments.
*
* @author Jiri Svitak
* @param object $ca
* @param string $date
* @return Mysql_Result
*/
public function get_device_fee_transfers_of_account_and_date($ca, $date)
{
if (!is_object($ca))
{
return null;
}
return $this->db->query("
SELECT id
FROM transfers
WHERE type = ? AND origin_id = ? AND datetime LIKE ?
", Transfer_Model::DEDUCT_DEVICE_FEE, $ca->id, "%$date%");
}
/**
* Sums transfers of device fees of account
*
* @author Michal Kliment
* @param type $account_id
* @return type
*/
public function sum_device_fee_transfers_of_account($account_id)
{
return $this->db->query("
SELECT SUM(amount) AS total_amount
FROM transfers
WHERE type = ? AND origin_id = ?
", array(self::DEDUCT_DEVICE_FEE, $account_id))->current()->total_amount;
}

/**
* Gets all monthly amounts of incoming member payment for stats
*
* @author Michal Kliment
* @return MySQL_Result object
*/
public function get_all_monthly_amounts_of_incoming_member_payment()
{
return $this->db->query("
SELECT SUBSTR(datetime, 1, 7) AS date, SUBSTR(datetime, 1, 4) AS year,
SUBSTR(datetime, 6, 2) AS month, SUM(amount) AS amount
FROM transfers t
c2e44ab0 Michal Kliment
WHERE t.origin_id IN (
SELECT id
FROM accounts
WHERE account_attribute_id = ?
) AND (
t.destination_id IN (
SELECT id
FROM accounts
WHERE account_attribute_id = ?
) OR t.destination_id IN (
SELECT id
FROM accounts
WHERE member_id = ? AND account_attribute_id = ?
)
)
8baed187 Michal Kliment
GROUP BY date
c2e44ab0 Michal Kliment
", array
(
Account_attribute_Model::MEMBER_FEES, Account_attribute_Model::CASH,
Member_Model::ASSOCIATION, Account_attribute_Model::BANK
));
8baed187 Michal Kliment
}

/**
* Gets datime of last transfer by type
*
* @author Michal Kliment
* @param integer $type
* @return string
*/
public function find_last_transfer_datetime_by_type($type)
{
$result = $this->db->query("
SELECT datetime FROM transfers t
WHERE t.type = ?
ORDER BY datetime DESC
LIMIT 0,1
", $type);

// there is any existing transfer by this type
if ($result && $result->count())
return $result->current()->datetime;
else
return NULL;
}
/**
* Get datetime of last transfer of account
*
* @author Michal Kliment
* @param type $account_id
* @return null
*/
public function get_last_transfer_datetime_of_account($account_id)
{
$result = $this->db->query("
SELECT t.datetime
FROM transfers t
WHERE t.origin_id = ? AND (t.type = ? OR t.type = ? OR t.type = ?)
GROUP BY t.id, t.datetime, t.amount
ORDER BY t.datetime DESC
LIMIT 0,1
", array
(
$account_id, self::DEDUCT_MEMBER_FEE,
self::DEDUCT_ENTRANCE_FEE, self::DEDUCT_DEVICE_FEE
));
if ($result && $result->current() && $result->current()->datetime != '')
return $result->current()->datetime;
else
return NULL;
}


/**
* Creates transfer
*
* @author Jiri Svitak
* @param integer $origin_id origin account id
* @param integer $destination_id destination account id
* @param integer $previous_transfer_id previous transfer id, useful for transfer groups
* @param integer $member_id transaction owner id
* @param integer $user_id id of user who added transfer
* @param integer $type type of transfer, see Transfer_Model
* @param string $datetime accounting datetime of transfer
* @param string $creation_datetime datetime of transfer creation
* @param string $text transfer text
* @param double $amount amount of transfer
* @return integer ID of created transfer
* @throws Kohana_Databse_Exception
* when failed transfer insert, origin or destination account update
*/
public static function insert_transfer(
$origin_id, $destination_id, $previous_transfer_id, $member_id,
$user_id, $type, $datetime, $creation_datetime, $text, $amount)
{
$previous_transfer_id = intval($previous_transfer_id);
$member_id = intval($member_id);
$user_id = intval($user_id);
// insert new transfer
$transfer = new Transfer_Model();
$transfer->origin_id = $origin_id;
$transfer->destination_id = $destination_id;
$transfer->previous_transfer_id = $previous_transfer_id ? $previous_transfer_id : NULL;
$transfer->member_id = $member_id ? $member_id : NULL;
$transfer->user_id = $user_id ? $user_id : NULL;
$transfer->type = $type;
$transfer->datetime = $datetime;
$transfer->creation_datetime = $creation_datetime;
$transfer->text = $text;
$transfer->amount = $amount;
$transfer->save_throwable();
// update balance of origin account
$oa = new Account_Model($origin_id);
$oa->balance -= $amount;
$oa->save_throwable();
// update balance of destination account
$da = new Account_Model($destination_id);
$da->balance += $amount;
$da->save_throwable();

return $transfer->id;
}

/**
* Edits transfers safely with change of dependent account balance.
*
* @author Jiri Svitak
* @param integer $id
* @param string $text
* @param double $amount
* @throws Kohana_Databse_Exception
*/
public static function edit_transfer($id, $text, $amount)
{
// update transfer
$transfer = new Transfer_Model($id);
$transfer->text = $text;
$transfer->amount = $amount;
$transfer->save_throwable();
// update balance of origin account
$oa = new Account_Model($transfer->origin_id);
$oa->balance -= $amount;
$oa->save_throwable();
// update balance of destination account
$da = new Account_Model($transfer->destination_id);
$da->balance += $amount;
$da->save_throwable();
}

/**
* Safely deletes transfer.
*
* @author Jiri Svitak
* @param integer $id
* @throws Kohana_Databse_Exception
*/
public static function delete_transfer($id = null)
{
if (!isset($id))
{
throw new Kohana_User_Exception (
"delete transfer", "ID to delete has not been supplied!"
);
}
$transfer = new Transfer_Model($id);
if (!$transfer->id)
{
throw new Kohana_User_Exception (
"delete transfer", "Transfer to delete has not been found!"
);
}
// update balance of origin account
$oa = new Account_Model($transfer->origin_id);
$oa->balance += $transfer->amount;
$oa->save_throwable();
// update balance of destination account
$da = new Account_Model($transfer->destination_id);
$da->balance -= $transfer->amount;
$da->save_throwable();
// delete transfer
$transfer->delete_throwable();
}
}