3 +--------------------------------------------------------------------+
4 | CiviCRM version 4.4 |
5 +--------------------------------------------------------------------+
6 | Copyright CiviCRM LLC (c) 2004-2013 |
7 +--------------------------------------------------------------------+
8 | This file is a part of CiviCRM. |
10 | CiviCRM is free software; you can copy, modify, and distribute it |
11 | under the terms of the GNU Affero General Public License |
12 | Version 3, 19 November 2007 and the CiviCRM Licensing Exception. |
14 | CiviCRM is distributed in the hope that it will be useful, but |
15 | WITHOUT ANY WARRANTY; without even the implied warranty of |
16 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. |
17 | See the GNU Affero General Public License for more details. |
19 | You should have received a copy of the GNU Affero General Public |
20 | License and the CiviCRM Licensing Exception along |
21 | with this program; if not, contact CiviCRM LLC |
22 | at info[AT]civicrm[DOT]org. If you have questions about the |
23 | GNU Affero General Public License or the licensing of CiviCRM, |
24 | see the CiviCRM license FAQ at http://civicrm.org/licensing |
25 +--------------------------------------------------------------------+
31 * @copyright CiviCRM LLC (c) 2004-2013
36 class CRM_Core_BAO_FinancialTrxn
extends CRM_Financial_DAO_FinancialTrxn
{
37 function __construct() {
38 parent
::__construct();
42 * takes an associative array and creates a financial transaction object
44 * @param array $params (reference ) an assoc array of name/value pairs
46 * @param string $trxnEntityTable entity_table
48 * @return object CRM_Core_BAO_FinancialTrxn object
52 static function create(&$params, $trxnEntityTable = null ) {
53 $trxn = new CRM_Financial_DAO_FinancialTrxn();
54 $trxn->copyValues($params);
56 if (!CRM_Utils_Rule
::currencyCode($trxn->currency
)) {
57 $config = CRM_Core_Config
::singleton();
58 $trxn->currency
= $config->defaultCurrency
;
63 // save to entity_financial_trxn table
64 $entityFinancialTrxnParams =
66 'entity_table' => "civicrm_contribution",
67 'financial_trxn_id' => $trxn->id
,
68 'amount' => $params['total_amount'],
69 'currency' => $trxn->currency
,
72 if (!empty($trxnEntityTable)) {
73 $entityFinancialTrxnParams['entity_table'] = $trxnEntityTable['entity_table'];
74 $entityFinancialTrxnParams['entity_id'] = $trxnEntityTable['entity_id'];
77 $entityFinancialTrxnParams['entity_id'] = $params['contribution_id'];
80 $entityTrxn = new CRM_Financial_DAO_EntityFinancialTrxn();
81 $entityTrxn->copyValues($entityFinancialTrxnParams);
87 * Takes a bunch of params that are needed to match certain criteria and
88 * retrieves the relevant objects. Typically the valid params are only
89 * contact_id. We'll tweak this function to be more full featured over a period
90 * of time. This is the inverse function of create. It also stores all the retrieved
91 * values in the default array
93 * @param array $params (reference ) an assoc array of name/value pairs
94 * @param array $defaults (reference ) an assoc array to hold the flattened values
96 * @return object CRM_Contribute_BAO_ContributionType object
100 static function retrieve( &$params, &$defaults ) {
101 $financialItem = new CRM_Financial_DAO_FinancialTrxn( );
102 $financialItem->copyValues($params);
103 if ($financialItem->find(true)) {
104 CRM_Core_DAO
::storeValues( $financialItem, $defaults );
105 return $financialItem;
112 * Given an entity_id and entity_table, check for corresponding entity_financial_trxn and financial_trxn record.
113 * NOTE: This should be moved to separate BAO for EntityFinancialTrxn when we start adding more code for that object.
115 * @param string $entityTable name of the entity table usually 'civicrm_contact'
116 * @param int $entityID id of the entity usually the contactID.
117 * @param string $orderBy to get single trxn id for a entity table i.e last or first.
119 * @return array( ) reference $tag array of catagory id's the contact belongs to.
124 static function getFinancialTrxnId($entity_id, $orderBy = 'ASC', $newTrxn = FALSE) {
125 $ids = array('entityFinancialTrxnId' => NULL, 'financialTrxnId' => NULL);
129 $condition = " AND ((ceft1.entity_table IS NOT NULL) OR (cft.payment_instrument_id IS NOT NULL AND ceft1.entity_table IS NULL)) ";
133 $orderBy = CRM_Utils_Type
::escape($orderBy, 'String');
136 $query = "SELECT ceft.id, ceft.financial_trxn_id FROM `civicrm_financial_trxn` cft
137 LEFT JOIN civicrm_entity_financial_trxn ceft
138 ON ceft.financial_trxn_id = cft.id AND ceft.entity_table = 'civicrm_contribution'
139 LEFT JOIN civicrm_entity_financial_trxn ceft1
140 ON ceft1.financial_trxn_id = cft.id AND ceft1.entity_table = 'civicrm_financial_item'
141 LEFT JOIN civicrm_financial_item cfi ON ceft1.entity_table = 'civicrm_financial_item' and cfi.id = ceft1.entity_id
142 WHERE ceft.entity_id = %1 AND (cfi.entity_table <> 'civicrm_financial_trxn' or cfi.entity_table is NULL)
144 ORDER BY cft.id {$orderBy}
147 $params = array(1 => array($entity_id, 'Integer'));
148 $dao = CRM_Core_DAO
::executeQuery($query, $params);
150 $ids['entityFinancialTrxnId'] = $dao->id
;
151 $ids['financialTrxnId'] = $dao->financial_trxn_id
;
157 * Given an entity_id and entity_table, check for corresponding entity_financial_trxn and financial_trxn record.
158 * NOTE: This should be moved to separate BAO for EntityFinancialTrxn when we start adding more code for that object.
160 * @param string $entityTable name of the entity table usually 'civicrm_contact'
161 * @param int $entityID id of the entity usually the contactID.
163 * @return array( ) reference $tag array of catagory id's the contact belongs to.
168 static function getFinancialTrxnTotal($entity_id) {
170 SELECT (ft.amount+SUM(ceft.amount)) AS total FROM civicrm_entity_financial_trxn AS ft
171 LEFT JOIN civicrm_entity_financial_trxn AS ceft ON ft.financial_trxn_id = ceft.entity_id
172 WHERE ft.entity_table = 'civicrm_contribution' AND ft.entity_id = %1
175 $sqlParams = array(1 => array($entity_id, 'Integer'));
176 return CRM_Core_DAO
::singleValueQuery($query, $sqlParams);
180 * Given an financial_trxn_id check for previous entity_financial_trxn.
182 * @param int $financialTrxn_id id of the latest payment.
184 * @return array( ) $payment array of previous payments
189 static function getPayments($financial_trxn_id) {
191 SELECT ef1.financial_trxn_id, sum(ef1.amount) amount
192 FROM civicrm_entity_financial_trxn ef1
193 LEFT JOIN civicrm_entity_financial_trxn ef2 ON ef1.financial_trxn_id = ef2.entity_id
194 WHERE ef2.financial_trxn_id =%1
195 AND ef2.entity_table = 'civicrm_financial_trxn'
196 AND ef1.entity_table = 'civicrm_financial_item'
197 GROUP BY ef1.financial_trxn_id
199 SELECT ef1.financial_trxn_id, ef1.amount
200 FROM civicrm_entity_financial_trxn ef1
201 LEFT JOIN civicrm_entity_financial_trxn ef2 ON ef1.entity_id = ef2.entity_id
202 WHERE ef2.financial_trxn_id =%1
203 AND ef2.entity_table = 'civicrm_financial_trxn'
204 AND ef1.entity_table = 'civicrm_financial_trxn'";
206 $sqlParams = array(1 => array($financial_trxn_id, 'Integer'));
207 $dao = CRM_Core_DAO
::executeQuery($query, $sqlParams);
210 while ($dao->fetch()) {
211 $result[$i]['financial_trxn_id'] = $dao->financial_trxn_id
;
212 $result[$i]['amount'] = $dao->amount
;
216 if (empty($result)) {
217 $query = "SELECT sum( amount ) amount FROM civicrm_entity_financial_trxn WHERE financial_trxn_id =%1 AND entity_table = 'civicrm_financial_item'";
218 $sqlParams = array(1 => array($financial_trxn_id, 'Integer'));
219 $dao = CRM_Core_DAO
::executeQuery($query, $sqlParams);
222 $result[0]['financial_trxn_id'] = $financial_trxn_id;
223 $result[0]['amount'] = $dao->amount
;
230 * Given an entity_id and entity_table, check for corresponding entity_financial_trxn and financial_trxn record.
231 * NOTE: This should be moved to separate BAO for EntityFinancialTrxn when we start adding more code for that object.
233 * @param string $entityTable name of the entity table usually 'civicrm_contact'
234 * @param int $entityID id of the entity usually the contactID.
236 * @return array( ) reference $tag array of catagory id's the contact belongs to.
241 static function getFinancialTrxnLineTotal($entity_id, $entity_table = 'civicrm_contribution') {
242 $query = "SELECT lt.price_field_value_id AS id, ft.financial_trxn_id,ft.amount AS amount FROM civicrm_entity_financial_trxn AS ft
243 LEFT JOIN civicrm_financial_item AS fi ON fi.id = ft.entity_id AND fi.entity_table = 'civicrm_line_item' AND ft.entity_table = 'civicrm_financial_item'
244 LEFT JOIN civicrm_line_item AS lt ON lt.id = fi.entity_id AND lt.entity_table = %2
245 WHERE lt.entity_id = %1 ";
247 $sqlParams = array(1 => array($entity_id, 'Integer'), 2 => array($entity_table, 'String'));
248 $dao = CRM_Core_DAO
::executeQuery($query, $sqlParams);
249 while($dao->fetch()){
250 $result[$dao->financial_trxn_id
][$dao->id
] = $dao->amount
;
252 if (!empty($result)) {
261 * Delete financial transaction
263 * @return true on success, false otherwise
267 static function deleteFinancialTrxn($entity_id) {
268 $query = "DELETE ceft1, cfi, ceft, cft FROM `civicrm_financial_trxn` cft
269 LEFT JOIN civicrm_entity_financial_trxn ceft
270 ON ceft.financial_trxn_id = cft.id AND ceft.entity_table = 'civicrm_contribution'
271 LEFT JOIN civicrm_entity_financial_trxn ceft1
272 ON ceft1.financial_trxn_id = cft.id AND ceft1.entity_table = 'civicrm_financial_item'
273 LEFT JOIN civicrm_financial_item cfi
274 ON ceft1.entity_table = 'civicrm_financial_item' and cfi.id = ceft1.entity_id
275 WHERE ceft.entity_id = %1";
276 CRM_Core_DAO
::executeQuery($query, array(1 => array($entity_id, 'Integer')));
281 * create financial transaction for premium
286 static function createPremiumTrxn($params) {
287 if ((!CRM_Utils_Array
::value('financial_type_id', $params) ||
!CRM_Utils_Array
::value('contributionId', $params)) && !CRM_Utils_Array
::value('oldPremium', $params)) {
291 if (CRM_Utils_Array
::value('cost', $params)) {
292 $contributionStatuses = CRM_Contribute_PseudoConstant
::contributionStatus(NULL, 'name');
293 $financialAccountType = CRM_Contribute_PseudoConstant
::financialAccountType($params['financial_type_id']);
294 $accountRelationship = CRM_Core_PseudoConstant
::accountOptionValues('account_relationship', NULL, " AND label IN ('Premiums Inventory Account is', 'Cost of Sales Account is')");
295 $toFinancialAccount = CRM_Utils_Array
::value('isDeleted', $params) ?
'Premiums Inventory Account is' : 'Cost of Sales Account is';
296 $fromFinancialAccount = CRM_Utils_Array
::value('isDeleted', $params) ?
'Cost of Sales Account is': 'Premiums Inventory Account is';
297 $accountRelationship = array_flip($accountRelationship);
298 $financialtrxn = array(
299 'to_financial_account_id' => $financialAccountType[$accountRelationship[$toFinancialAccount]],
300 'from_financial_account_id' => $financialAccountType[$accountRelationship[$fromFinancialAccount]],
301 'trxn_date' => date('YmdHis'),
302 'total_amount' => CRM_Utils_Array
::value('cost', $params) ?
$params['cost'] : 0,
303 'currency' => CRM_Utils_Array
::value('currency', $params),
304 'status_id' => array_search('Completed', $contributionStatuses)
306 $trxnEntityTable['entity_table'] = 'civicrm_contribution';
307 $trxnEntityTable['entity_id'] = $params['contributionId'];
308 CRM_Core_BAO_FinancialTrxn
::create($financialtrxn, $trxnEntityTable);
311 if (CRM_Utils_Array
::value('oldPremium', $params)) {
312 $premiumParams = array(
313 'id' => $params['oldPremium']['product_id']
315 $productDetails = array();
316 CRM_Contribute_BAO_ManagePremiums
::retrieve($premiumParams, $productDetails);
318 'cost' => CRM_Utils_Array
::value('cost', $productDetails),
319 'currency' => CRM_Utils_Array
::value('currency', $productDetails),
320 'financial_type_id' => CRM_Utils_Array
::value('financial_type_id', $productDetails),
321 'contributionId' => $params['oldPremium']['contribution_id'],
324 CRM_Core_BAO_FinancialTrxn
::createPremiumTrxn($params);
328 * create financial trxn and items when fee is charged
330 * @params params to create trxn entries
336 static function recordFees($params) {
337 $expenseTypeId = key(CRM_Core_PseudoConstant
::accountOptionValues('account_relationship', NULL, " AND v.name LIKE 'Expense Account is' "));
338 $domainId = CRM_Core_Config
::domainID();
340 if (CRM_Utils_Array
::value('prevContribution', $params)) {
341 $amount = $params['prevContribution']->fee_amount
;
343 $amount = $params['fee_amount'] - $amount;
347 $financialAccount = CRM_Contribute_PseudoConstant
::financialAccountType($params['financial_type_id'], $expenseTypeId);
348 $params['trxnParams']['from_financial_account_id'] = $params['to_financial_account_id'];
349 $params['trxnParams']['to_financial_account_id'] = $financialAccount;
350 $params['trxnParams']['total_amount'] = $amount;
351 $params['trxnParams']['fee_amount'] =
352 $params['trxnParams']['net_amount'] = 0;
353 $params['trxnParams']['status_id'] = CRM_Core_OptionGroup
::getValue('contribution_status','Completed','name');
354 $params['trxnParams']['contribution_id'] = isset($params['contribution']->id
) ?
$params['contribution']->id
: $params['contribution_id'];
355 $trxn = self
::create($params['trxnParams']);
356 if (!CRM_Utils_Array
::value('entity_id', $params)) {
357 $financialTrxnID = CRM_Core_BAO_FinancialTrxn
::getFinancialTrxnId($params['trxnParams']['contribution_id'], 'DESC');
358 $params['entity_id'] = $financialTrxnID['financialTrxnId'];
362 'financial_account_id' => $financialAccount,
363 'contact_id' => CRM_Core_DAO
::getFieldValue('CRM_Core_DAO_Domain', $domainId, 'contact_id'),
364 'created_date' => date('YmdHis'),
365 'transaction_date' => date('YmdHis'),
367 'description' => 'Fee',
368 'status_id' => CRM_Core_OptionGroup
::getValue('financial_item_status','Paid','name'),
369 'entity_table' => 'civicrm_financial_trxn',
370 'entity_id' => $params['entity_id'],
371 'currency' => $params['trxnParams']['currency'],
373 $trxnIDS['id'] = $trxn->id
;
374 $financialItem = CRM_Financial_BAO_FinancialItem
::create($fItemParams, NULL, $trxnIDS);