Merge pull request #10737 from jitendrapurohit/CRM-20913
[civicrm-core.git] / CRM / Pledge / BAO / Pledge.php
1 <?php
2 /*
3 +--------------------------------------------------------------------+
4 | CiviCRM version 4.7 |
5 +--------------------------------------------------------------------+
6 | Copyright CiviCRM LLC (c) 2004-2017 |
7 +--------------------------------------------------------------------+
8 | This file is a part of CiviCRM. |
9 | |
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. |
13 | |
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. |
18 | |
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 +--------------------------------------------------------------------+
26 */
27
28 /**
29 *
30 * @package CRM
31 * @copyright CiviCRM LLC (c) 2004-2017
32 */
33 class CRM_Pledge_BAO_Pledge extends CRM_Pledge_DAO_Pledge {
34
35 /**
36 * Static field for all the pledge information that we can potentially export.
37 *
38 * @var array
39 */
40 static $_exportableFields = NULL;
41
42 /**
43 * Class constructor.
44 */
45 public function __construct() {
46 parent::__construct();
47 }
48
49 /**
50 * Retrieve DB object based on input parameters.
51 *
52 * It also stores all the retrieved values in the default array.
53 *
54 * @param array $params
55 * (reference ) an assoc array of name/value pairs.
56 * @param array $defaults
57 * (reference ) an assoc array to hold the flattened values.
58 *
59 * @return CRM_Pledge_BAO_Pledge
60 */
61 public static function retrieve(&$params, &$defaults) {
62 $pledge = new CRM_Pledge_DAO_Pledge();
63 $pledge->copyValues($params);
64 if ($pledge->find(TRUE)) {
65 CRM_Core_DAO::storeValues($pledge, $defaults);
66 return $pledge;
67 }
68 return NULL;
69 }
70
71 /**
72 * Add pledge.
73 *
74 * @param array $params
75 * Reference array contains the values submitted by the form.
76 *
77 *
78 * @return object
79 */
80 public static function add(&$params) {
81 if (!empty($params['id'])) {
82 CRM_Utils_Hook::pre('edit', 'Pledge', $params['id'], $params);
83 }
84 else {
85 CRM_Utils_Hook::pre('create', 'Pledge', NULL, $params);
86 }
87
88 $pledge = new CRM_Pledge_DAO_Pledge();
89
90 // if pledge is complete update end date as current date
91 if ($pledge->status_id == 1) {
92 $pledge->end_date = date('Ymd');
93 }
94
95 $pledge->copyValues($params);
96
97 // set currency for CRM-1496
98 if (!isset($pledge->currency)) {
99 $pledge->currency = CRM_Core_Config::singleton()->defaultCurrency;
100 }
101
102 $result = $pledge->save();
103
104 if (!empty($params['id'])) {
105 CRM_Utils_Hook::post('edit', 'Pledge', $pledge->id, $pledge);
106 }
107 else {
108 CRM_Utils_Hook::post('create', 'Pledge', $pledge->id, $pledge);
109 }
110
111 return $result;
112 }
113
114 /**
115 * Given the list of params in the params array, fetch the object
116 * and store the values in the values array
117 *
118 * @param array $params
119 * Input parameters to find object.
120 * @param array $values
121 * Output values of the object.
122 * @param array $returnProperties
123 * If you want to return specific fields.
124 *
125 * @return array
126 * associated array of field values
127 */
128 public static function &getValues(&$params, &$values, $returnProperties = NULL) {
129 if (empty($params)) {
130 return NULL;
131 }
132 CRM_Core_DAO::commonRetrieve('CRM_Pledge_BAO_Pledge', $params, $values, $returnProperties);
133 return $values;
134 }
135
136 /**
137 * Takes an associative array and creates a pledge object.
138 *
139 * @param array $params
140 * (reference ) an assoc array of name/value pairs.
141 *
142 * @return CRM_Pledge_BAO_Pledge
143 */
144 public static function create(&$params) {
145 // FIXME: a cludgy hack to fix the dates to MySQL format
146 $dateFields = array('start_date', 'create_date', 'acknowledge_date', 'modified_date', 'cancel_date', 'end_date');
147 foreach ($dateFields as $df) {
148 if (isset($params[$df])) {
149 $params[$df] = CRM_Utils_Date::isoToMysql($params[$df]);
150 }
151 }
152
153 $isRecalculatePledgePayment = self::isPaymentsRequireRecalculation($params);
154 $transaction = new CRM_Core_Transaction();
155
156 $paymentParams = array();
157 if (!empty($params['installment_amount'])) {
158 $params['amount'] = $params['installment_amount'] * $params['installments'];
159 }
160
161 if (!isset($params['pledge_status_id']) && !isset($params['status_id'])) {
162 if (isset($params['contribution_id'])) {
163 if ($params['installments'] > 1) {
164 $params['status_id'] = CRM_Core_PseudoConstant::getKey('CRM_Pledge_BAO_Pledge', 'status_id', 'In Progress');
165 }
166 }
167 else {
168 if (!empty($params['id'])) {
169 $params['status_id'] = CRM_Pledge_BAO_PledgePayment::calculatePledgeStatus($params['id']);
170 }
171 else {
172 $params['status_id'] = CRM_Core_PseudoConstant::getKey('CRM_Pledge_BAO_Pledge', 'status_id', 'Pending');
173 }
174 }
175 }
176 $paymentParams['status_id'] = CRM_Utils_Array::value('status_id', $params);
177
178 $pledge = self::add($params);
179 if (is_a($pledge, 'CRM_Core_Error')) {
180 $pledge->rollback();
181 return $pledge;
182 }
183
184 // handle custom data.
185 if (!empty($params['custom']) &&
186 is_array($params['custom'])
187 ) {
188 CRM_Core_BAO_CustomValueTable::store($params['custom'], 'civicrm_pledge', $pledge->id);
189 }
190
191 // skip payment stuff inedit mode
192 if (!isset($params['id']) || $isRecalculatePledgePayment) {
193
194 // if pledge is pending delete all payments and recreate.
195 if ($isRecalculatePledgePayment) {
196 CRM_Pledge_BAO_PledgePayment::deletePayments($pledge->id);
197 }
198
199 // building payment params
200 $paymentParams['pledge_id'] = $pledge->id;
201 $paymentKeys = array(
202 'amount',
203 'installments',
204 'scheduled_date',
205 'frequency_unit',
206 'currency',
207 'frequency_day',
208 'frequency_interval',
209 'contribution_id',
210 'installment_amount',
211 'actual_amount',
212 );
213 foreach ($paymentKeys as $key) {
214 $paymentParams[$key] = CRM_Utils_Array::value($key, $params, NULL);
215 }
216 CRM_Pledge_BAO_PledgePayment::create($paymentParams);
217 }
218
219 $transaction->commit();
220
221 $url = CRM_Utils_System::url('civicrm/contact/view/pledge',
222 "action=view&reset=1&id={$pledge->id}&cid={$pledge->contact_id}&context=home"
223 );
224
225 $recentOther = array();
226 if (CRM_Core_Permission::checkActionPermission('CiviPledge', CRM_Core_Action::UPDATE)) {
227 $recentOther['editUrl'] = CRM_Utils_System::url('civicrm/contact/view/pledge',
228 "action=update&reset=1&id={$pledge->id}&cid={$pledge->contact_id}&context=home"
229 );
230 }
231 if (CRM_Core_Permission::checkActionPermission('CiviPledge', CRM_Core_Action::DELETE)) {
232 $recentOther['deleteUrl'] = CRM_Utils_System::url('civicrm/contact/view/pledge',
233 "action=delete&reset=1&id={$pledge->id}&cid={$pledge->contact_id}&context=home"
234 );
235 }
236
237 $contributionTypes = CRM_Contribute_PseudoConstant::financialType();
238 $title = CRM_Contact_BAO_Contact::displayName($pledge->contact_id) . ' - (' . ts('Pledged') . ' ' . CRM_Utils_Money::format($pledge->amount, $pledge->currency) . ' - ' . CRM_Utils_Array::value($pledge->financial_type_id, $contributionTypes) . ')';
239
240 // add the recently created Pledge
241 CRM_Utils_Recent::add($title,
242 $url,
243 $pledge->id,
244 'Pledge',
245 $pledge->contact_id,
246 NULL,
247 $recentOther
248 );
249
250 return $pledge;
251 }
252
253 /**
254 * Is this a change to an existing pending pledge requiring payment schedule changes.
255 *
256 * If the pledge is pending the code (slightly lazily) deletes & recreates pledge payments.
257 *
258 * If the payment dates or amounts have been manually edited then this can cause data loss. We can mitigate this to
259 * some extent by making sure we have a change that could potentially affect the schedule (rather than just a
260 * custom data change or similar).
261 *
262 * This calculation needs to be performed before update takes place as previous & new pledges are compared.
263 *
264 * @param array $params
265 *
266 * @return bool
267 */
268 protected static function isPaymentsRequireRecalculation($params) {
269 if (empty($params['is_pledge_pending']) || empty($params['id'])) {
270 return FALSE;
271 }
272 $scheduleChangingParameters = array(
273 'amount',
274 'frequency_unit',
275 'frequency_interval',
276 'frequency_day',
277 'installments',
278 'start_date',
279 );
280 $existingPledgeDAO = new CRM_Pledge_BAO_Pledge();
281 $existingPledgeDAO->id = $params['id'];
282 $existingPledgeDAO->find(TRUE);
283 foreach ($scheduleChangingParameters as $parameter) {
284 if ($parameter == 'start_date') {
285 if (strtotime($params[$parameter]) != strtotime($existingPledgeDAO->$parameter)) {
286 return TRUE;
287 }
288 }
289 elseif ($params[$parameter] != $existingPledgeDAO->$parameter) {
290 return TRUE;
291 }
292 }
293 }
294
295 /**
296 * Delete the pledge.
297 *
298 * @param int $id
299 * Pledge id.
300 *
301 * @return mixed
302 */
303 public static function deletePledge($id) {
304 CRM_Utils_Hook::pre('delete', 'Pledge', $id, CRM_Core_DAO::$_nullArray);
305
306 $transaction = new CRM_Core_Transaction();
307
308 // check for no Completed Payment records with the pledge
309 $payment = new CRM_Pledge_DAO_PledgePayment();
310 $payment->pledge_id = $id;
311 $payment->find();
312
313 while ($payment->fetch()) {
314 // also delete associated contribution.
315 if ($payment->contribution_id) {
316 CRM_Contribute_BAO_Contribution::deleteContribution($payment->contribution_id);
317 }
318 $payment->delete();
319 }
320
321 $dao = new CRM_Pledge_DAO_Pledge();
322 $dao->id = $id;
323 $results = $dao->delete();
324
325 $transaction->commit();
326
327 CRM_Utils_Hook::post('delete', 'Pledge', $dao->id, $dao);
328
329 // delete the recently created Pledge
330 $pledgeRecent = array(
331 'id' => $id,
332 'type' => 'Pledge',
333 );
334 CRM_Utils_Recent::del($pledgeRecent);
335
336 return $results;
337 }
338
339 /**
340 * Get the amount details date wise.
341 *
342 * @param string $status
343 * @param string $startDate
344 * @param string $endDate
345 *
346 * @return array|null
347 */
348 public static function getTotalAmountAndCount($status = NULL, $startDate = NULL, $endDate = NULL) {
349 $where = array();
350 $select = $from = $queryDate = NULL;
351 $statusId = CRM_Core_PseudoConstant::getKey('CRM_Pledge_BAO_Pledge', 'status_id', $status);
352
353 switch ($status) {
354 case 'Completed':
355 $where[] = 'status_id != ' . CRM_Core_PseudoConstant::getKey('CRM_Pledge_BAO_Pledge', 'status_id', 'Cancelled');
356 break;
357
358 case 'Cancelled':
359 case 'In Progress':
360 case 'Pending':
361 case 'Overdue':
362 $where[] = 'status_id = ' . $statusId;
363 break;
364 }
365
366 if ($startDate) {
367 $where[] = "create_date >= '" . CRM_Utils_Type::escape($startDate, 'Timestamp') . "'";
368 }
369 if ($endDate) {
370 $where[] = "create_date <= '" . CRM_Utils_Type::escape($endDate, 'Timestamp') . "'";
371 }
372
373 $whereCond = implode(' AND ', $where);
374
375 $query = "
376 SELECT sum( amount ) as pledge_amount, count( id ) as pledge_count, currency
377 FROM civicrm_pledge
378 WHERE $whereCond AND is_test=0
379 GROUP BY currency
380 ";
381 $start = substr($startDate, 0, 8);
382 $end = substr($endDate, 0, 8);
383 $pCount = 0;
384 $pamount = array();
385 $dao = CRM_Core_DAO::executeQuery($query);
386 while ($dao->fetch()) {
387 $pCount += $dao->pledge_count;
388 $pamount[] = CRM_Utils_Money::format($dao->pledge_amount, $dao->currency);
389 }
390
391 $pledge_amount = array(
392 'pledge_amount' => implode(', ', $pamount),
393 'pledge_count' => $pCount,
394 'purl' => CRM_Utils_System::url('civicrm/pledge/search',
395 "reset=1&force=1&pstatus={$statusId}&pstart={$start}&pend={$end}&test=0"
396 ),
397 );
398
399 $where = array();
400 switch ($status) {
401 case 'Completed':
402 $select = 'sum( total_amount ) as received_pledge , count( cd.id ) as received_count';
403 $where[] = 'cp.status_id = ' . $statusId . ' AND cp.contribution_id = cd.id AND cd.is_test=0';
404 $queryDate = 'receive_date';
405 $from = ' civicrm_contribution cd, civicrm_pledge_payment cp';
406 break;
407
408 case 'Cancelled':
409 $select = 'sum( total_amount ) as received_pledge , count( cd.id ) as received_count';
410 $where[] = 'cp.status_id = ' . $statusId . ' AND cp.contribution_id = cd.id AND cd.is_test=0';
411 $queryDate = 'receive_date';
412 $from = ' civicrm_contribution cd, civicrm_pledge_payment cp';
413 break;
414
415 case 'Pending':
416 $select = 'sum( scheduled_amount )as received_pledge , count( cp.id ) as received_count';
417 $where[] = 'cp.status_id = ' . $statusId . ' AND pledge.is_test=0';
418 $queryDate = 'scheduled_date';
419 $from = ' civicrm_pledge_payment cp INNER JOIN civicrm_pledge pledge on cp.pledge_id = pledge.id';
420 break;
421
422 case 'Overdue':
423 $select = 'sum( scheduled_amount ) as received_pledge , count( cp.id ) as received_count';
424 $where[] = 'cp.status_id = ' . $statusId . ' AND pledge.is_test=0';
425 $queryDate = 'scheduled_date';
426 $from = ' civicrm_pledge_payment cp INNER JOIN civicrm_pledge pledge on cp.pledge_id = pledge.id';
427 break;
428 }
429
430 if ($startDate) {
431 $where[] = " $queryDate >= '" . CRM_Utils_Type::escape($startDate, 'Timestamp') . "'";
432 }
433 if ($endDate) {
434 $where[] = " $queryDate <= '" . CRM_Utils_Type::escape($endDate, 'Timestamp') . "'";
435 }
436
437 $whereCond = implode(' AND ', $where);
438
439 $query = "
440 SELECT $select, cp.currency
441 FROM $from
442 WHERE $whereCond
443 GROUP BY cp.currency
444 ";
445 if ($select) {
446 $dao = CRM_Core_DAO::executeQuery($query);
447 $amount = array();
448 $count = 0;
449
450 while ($dao->fetch()) {
451 $count += $dao->received_count;
452 $amount[] = CRM_Utils_Money::format($dao->received_pledge, $dao->currency);
453 }
454
455 if ($count) {
456 return array_merge($pledge_amount, array(
457 'received_amount' => implode(', ', $amount),
458 'received_count' => $count,
459 'url' => CRM_Utils_System::url('civicrm/pledge/search',
460 "reset=1&force=1&status={$statusId}&start={$start}&end={$end}&test=0"
461 ),
462 ));
463 }
464 }
465 else {
466 return $pledge_amount;
467 }
468 return NULL;
469 }
470
471 /**
472 * Get list of pledges In Honor of contact Ids.
473 *
474 * @param int $honorId
475 * In Honor of Contact ID.
476 *
477 * @return array
478 * return the list of pledge fields
479 */
480 public static function getHonorContacts($honorId) {
481 $params = array();
482 $honorDAO = new CRM_Contribute_DAO_ContributionSoft();
483 $honorDAO->contact_id = $honorId;
484 $honorDAO->find();
485
486 // get all status.
487 while ($honorDAO->fetch()) {
488 $pledgePaymentDAO = new CRM_Pledge_DAO_PledgePayment();
489 $pledgePaymentDAO->contribution_id = $honorDAO->contribution_id;
490 if ($pledgePaymentDAO->find(TRUE)) {
491 $pledgeDAO = new CRM_Pledge_DAO_Pledge();
492 $pledgeDAO->id = $pledgePaymentDAO->pledge_id;
493 if ($pledgeDAO->find(TRUE)) {
494 $params[$pledgeDAO->id] = array(
495 'honor_type' => CRM_Core_PseudoConstant::getLabel('CRM_Contribute_BAO_ContributionSoft', 'soft_credit_type_id', $honorDAO->soft_credit_type_id),
496 'honorId' => $pledgeDAO->contact_id,
497 'amount' => $pledgeDAO->amount,
498 'status' => CRM_Core_PseudoConstant::getLabel('CRM_Pledge_BAO_Pledge', 'status_id', $pledgeDAO->status_id),
499 'create_date' => $pledgeDAO->create_date,
500 'acknowledge_date' => $pledgeDAO->acknowledge_date,
501 'type' => CRM_Core_DAO::getFieldValue('CRM_Financial_DAO_FinancialType',
502 $pledgeDAO->financial_type_id, 'name'
503 ),
504 'display_name' => CRM_Core_DAO::getFieldValue('CRM_Contact_DAO_Contact',
505 $pledgeDAO->contact_id, 'display_name'
506 ),
507 );
508 }
509 }
510 }
511
512 return $params;
513 }
514
515 /**
516 * Send Acknowledgment and create activity.
517 *
518 * @param CRM_Core_Form $form
519 * Form object.
520 * @param array $params
521 * An assoc array of name/value pairs.
522 */
523 public static function sendAcknowledgment(&$form, $params) {
524 //handle Acknowledgment.
525 $allPayments = $payments = array();
526
527 // get All Payments status types.
528 $paymentStatusTypes = CRM_Contribute_PseudoConstant::contributionStatus(NULL, 'name');
529 $returnProperties = array('status_id', 'scheduled_amount', 'scheduled_date', 'contribution_id');
530 // get all paymnets details.
531 CRM_Core_DAO::commonRetrieveAll('CRM_Pledge_DAO_PledgePayment', 'pledge_id', $params['id'], $allPayments, $returnProperties);
532
533 if (!empty($allPayments)) {
534 foreach ($allPayments as $payID => $values) {
535 $contributionValue = $contributionStatus = array();
536 if (isset($values['contribution_id'])) {
537 $contributionParams = array('id' => $values['contribution_id']);
538 $returnProperties = array('contribution_status_id', 'receive_date');
539 CRM_Core_DAO::commonRetrieve('CRM_Contribute_DAO_Contribution',
540 $contributionParams, $contributionStatus, $returnProperties
541 );
542 $contributionValue = array(
543 'status' => CRM_Utils_Array::value('contribution_status_id', $contributionStatus),
544 'receive_date' => CRM_Utils_Array::value('receive_date', $contributionStatus),
545 );
546 }
547 $payments[$payID] = array_merge($contributionValue,
548 array(
549 'amount' => CRM_Utils_Array::value('scheduled_amount', $values),
550 'due_date' => CRM_Utils_Array::value('scheduled_date', $values),
551 )
552 );
553
554 // get the first valid payment id.
555 if (!isset($form->paymentId) && ($paymentStatusTypes[$values['status_id']] == 'Pending' ||
556 $paymentStatusTypes[$values['status_id']] == 'Overdue'
557 )
558 ) {
559 $form->paymentId = $values['id'];
560 }
561 }
562 }
563
564 // assign pledge fields value to template.
565 $pledgeFields = array(
566 'create_date',
567 'total_pledge_amount',
568 'frequency_interval',
569 'frequency_unit',
570 'installments',
571 'frequency_day',
572 'scheduled_amount',
573 'currency',
574 );
575 foreach ($pledgeFields as $field) {
576 if (!empty($params[$field])) {
577 $form->assign($field, $params[$field]);
578 }
579 }
580
581 // assign all payments details.
582 if ($payments) {
583 $form->assign('payments', $payments);
584 }
585
586 // handle domain token values
587 $domain = CRM_Core_BAO_Domain::getDomain();
588 $tokens = array(
589 'domain' => array('name', 'phone', 'address', 'email'),
590 'contact' => CRM_Core_SelectValues::contactTokens(),
591 );
592 $domainValues = array();
593 foreach ($tokens['domain'] as $token) {
594 $domainValues[$token] = CRM_Utils_Token::getDomainTokenReplacement($token, $domain);
595 }
596 $form->assign('domain', $domainValues);
597
598 // handle contact token values.
599 $ids = array($params['contact_id']);
600 $fields = array_merge(array_keys(CRM_Contact_BAO_Contact::importableFields()),
601 array('display_name', 'checksum', 'contact_id')
602 );
603 foreach ($fields as $key => $val) {
604 $returnProperties[$val] = TRUE;
605 }
606 $details = CRM_Utils_Token::getTokenDetails($ids,
607 $returnProperties,
608 TRUE, TRUE, NULL,
609 $tokens,
610 get_class($form)
611 );
612 $form->assign('contact', $details[0][$params['contact_id']]);
613
614 // handle custom data.
615 if (!empty($params['hidden_custom'])) {
616 $groupTree = CRM_Core_BAO_CustomGroup::getTree('Pledge', NULL, $params['id']);
617 $pledgeParams = array(array('pledge_id', '=', $params['id'], 0, 0));
618 $customGroup = array();
619 // retrieve custom data
620 foreach ($groupTree as $groupID => $group) {
621 $customFields = $customValues = array();
622 if ($groupID == 'info') {
623 continue;
624 }
625 foreach ($group['fields'] as $k => $field) {
626 $field['title'] = $field['label'];
627 $customFields["custom_{$k}"] = $field;
628 }
629
630 // to build array of customgroup & customfields in it
631 CRM_Core_BAO_UFGroup::getValues($params['contact_id'], $customFields, $customValues, FALSE, $pledgeParams);
632 $customGroup[$group['title']] = $customValues;
633 }
634
635 $form->assign('customGroup', $customGroup);
636 }
637
638 // handle acknowledgment email stuff.
639 list($pledgerDisplayName,
640 $pledgerEmail
641 ) = CRM_Contact_BAO_Contact_Location::getEmailDetails($params['contact_id']);
642
643 // check for online pledge.
644 if (!empty($params['receipt_from_email'])) {
645 $userName = CRM_Utils_Array::value('receipt_from_name', $params);
646 $userEmail = CRM_Utils_Array::value('receipt_from_email', $params);
647 }
648 elseif (!empty($params['from_email_id'])) {
649 $receiptFrom = $params['from_email_id'];
650 }
651 elseif ($userID = CRM_Core_Session::singleton()->get('userID')) {
652 // check for logged in user.
653 list($userName, $userEmail) = CRM_Contact_BAO_Contact_Location::getEmailDetails($userID);
654 }
655 else {
656 // set the domain values.
657 $userName = CRM_Utils_Array::value('name', $domainValues);
658 $userEmail = CRM_Utils_Array::value('email', $domainValues);
659 }
660
661 if (!isset($receiptFrom)) {
662 $receiptFrom = "$userName <$userEmail>";
663 }
664
665 list($sent, $subject, $message, $html) = CRM_Core_BAO_MessageTemplate::sendTemplate(
666 array(
667 'groupName' => 'msg_tpl_workflow_pledge',
668 'valueName' => 'pledge_acknowledge',
669 'contactId' => $params['contact_id'],
670 'from' => $receiptFrom,
671 'toName' => $pledgerDisplayName,
672 'toEmail' => $pledgerEmail,
673 )
674 );
675
676 // check if activity record exist for this pledge
677 // Acknowledgment, if exist do not add activity.
678 $activityType = 'Pledge Acknowledgment';
679 $activity = new CRM_Activity_DAO_Activity();
680 $activity->source_record_id = $params['id'];
681 $activity->activity_type_id = CRM_Core_PseudoConstant::getKey('CRM_Activity_BAO_Activity',
682 'activity_type_id',
683 $activityType
684 );
685
686 // FIXME: Translate
687 $details = 'Total Amount ' . CRM_Utils_Money::format($params['total_pledge_amount'], CRM_Utils_Array::value('currency', $params)) . ' To be paid in ' . $params['installments'] . ' installments of ' . CRM_Utils_Money::format($params['scheduled_amount'], CRM_Utils_Array::value('currency', $params)) . ' every ' . $params['frequency_interval'] . ' ' . $params['frequency_unit'] . '(s)';
688
689 if (!$activity->find()) {
690 $activityParams = array(
691 'subject' => $subject,
692 'source_contact_id' => $params['contact_id'],
693 'source_record_id' => $params['id'],
694 'activity_type_id' => CRM_Core_PseudoConstant::getKey('CRM_Activity_BAO_Activity',
695 'activity_type_id',
696 $activityType
697 ),
698 'activity_date_time' => CRM_Utils_Date::isoToMysql($params['acknowledge_date']),
699 'is_test' => $params['is_test'],
700 'status_id' => 2,
701 'details' => $details,
702 'campaign_id' => CRM_Utils_Array::value('campaign_id', $params),
703 );
704
705 // lets insert assignee record.
706 if (!empty($params['contact_id'])) {
707 $activityParams['assignee_contact_id'] = $params['contact_id'];
708 }
709
710 if (is_a(CRM_Activity_BAO_Activity::create($activityParams), 'CRM_Core_Error')) {
711 CRM_Core_Error::fatal("Failed creating Activity for acknowledgment");
712 }
713 }
714 }
715
716 /**
717 * Combine all the exportable fields from the lower levels object.
718 *
719 * @param bool $checkPermission
720 *
721 * @return array
722 * array of exportable Fields
723 */
724 public static function exportableFields($checkPermission = TRUE) {
725 if (!self::$_exportableFields) {
726 if (!self::$_exportableFields) {
727 self::$_exportableFields = array();
728 }
729
730 $fields = CRM_Pledge_DAO_Pledge::export();
731
732 $fields = array_merge($fields, CRM_Pledge_DAO_PledgePayment::export());
733
734 // set title to calculated fields
735 $calculatedFields = array(
736 'pledge_total_paid' => array('title' => ts('Total Paid')),
737 'pledge_balance_amount' => array('title' => ts('Balance Amount')),
738 'pledge_next_pay_date' => array('title' => ts('Next Payment Date')),
739 'pledge_next_pay_amount' => array('title' => ts('Next Payment Amount')),
740 'pledge_payment_paid_amount' => array('title' => ts('Paid Amount')),
741 'pledge_payment_paid_date' => array('title' => ts('Paid Date')),
742 'pledge_payment_status' => array(
743 'title' => ts('Pledge Payment Status'),
744 'name' => 'pledge_payment_status',
745 'data_type' => CRM_Utils_Type::T_STRING,
746 ),
747 );
748
749 $pledgeFields = array(
750 'pledge_status' => array(
751 'title' => ts('Pledge Status'),
752 'name' => 'pledge_status',
753 'data_type' => CRM_Utils_Type::T_STRING,
754 ),
755 'pledge_frequency_unit' => array(
756 'title' => ts('Pledge Frequency Unit'),
757 'name' => 'pledge_frequency_unit',
758 'data_type' => CRM_Utils_Type::T_ENUM,
759 ),
760 'pledge_frequency_interval' => array(
761 'title' => ts('Pledge Frequency Interval'),
762 'name' => 'pledge_frequency_interval',
763 'data_type' => CRM_Utils_Type::T_INT,
764 ),
765 'pledge_contribution_page_id' => array(
766 'title' => ts('Pledge Contribution Page Id'),
767 'name' => 'pledge_contribution_page_id',
768 'data_type' => CRM_Utils_Type::T_INT,
769 ),
770 );
771
772 $fields = array_merge($fields, $pledgeFields, $calculatedFields);
773
774 // add custom data
775 $fields = array_merge($fields, CRM_Core_BAO_CustomField::getFieldsForImport('Pledge', FALSE, FALSE, FALSE, $checkPermission));
776 self::$_exportableFields = $fields;
777 }
778
779 return self::$_exportableFields;
780 }
781
782 /**
783 * Get pending or in progress pledges.
784 *
785 * @param int $contactID
786 * Contact id.
787 *
788 * @return array
789 * associated array of pledge id(s)
790 */
791 public static function getContactPledges($contactID) {
792 $pledgeDetails = array();
793 $pledgeStatuses = CRM_Core_OptionGroup::values('pledge_status',
794 FALSE, FALSE, FALSE, NULL, 'name'
795 );
796
797 $status = array();
798
799 // get pending and in progress status
800 foreach (array(
801 'Pending',
802 'In Progress',
803 'Overdue',
804 ) as $name) {
805 if ($statusId = array_search($name, $pledgeStatuses)) {
806 $status[] = $statusId;
807 }
808 }
809 if (empty($status)) {
810 return $pledgeDetails;
811 }
812
813 $statusClause = " IN (" . implode(',', $status) . ")";
814
815 $query = "
816 SELECT civicrm_pledge.id id
817 FROM civicrm_pledge
818 WHERE civicrm_pledge.status_id {$statusClause}
819 AND civicrm_pledge.contact_id = %1
820 ";
821
822 $params[1] = array($contactID, 'Integer');
823 $pledge = CRM_Core_DAO::executeQuery($query, $params);
824
825 while ($pledge->fetch()) {
826 $pledgeDetails[] = $pledge->id;
827 }
828
829 return $pledgeDetails;
830 }
831
832 /**
833 * Get pledge record count for a Contact.
834 *
835 * @param int $contactID
836 *
837 * @return int
838 * count of pledge records
839 */
840 public static function getContactPledgeCount($contactID) {
841 $query = "SELECT count(*) FROM civicrm_pledge WHERE civicrm_pledge.contact_id = {$contactID} AND civicrm_pledge.is_test = 0";
842 return CRM_Core_DAO::singleValueQuery($query);
843 }
844
845 /**
846 * @param array $params
847 *
848 * @return array
849 */
850 public static function updatePledgeStatus($params) {
851
852 $returnMessages = array();
853
854 $sendReminders = CRM_Utils_Array::value('send_reminders', $params, FALSE);
855
856 $allStatus = array_flip(CRM_Contribute_PseudoConstant::contributionStatus(NULL, 'name'));
857 $allPledgeStatus = CRM_Core_OptionGroup::values('pledge_status',
858 TRUE, FALSE, FALSE, NULL, 'name', TRUE
859 );
860 unset($allPledgeStatus['Completed'], $allPledgeStatus['Cancelled']);
861 unset($allStatus['Completed'], $allStatus['Cancelled'], $allStatus['Failed']);
862
863 $statusIds = implode(',', $allStatus);
864 $pledgeStatusIds = implode(',', $allPledgeStatus);
865 $updateCnt = 0;
866
867 $query = "
868 SELECT pledge.contact_id as contact_id,
869 pledge.id as pledge_id,
870 pledge.amount as amount,
871 payment.scheduled_date as scheduled_date,
872 pledge.create_date as create_date,
873 payment.id as payment_id,
874 pledge.currency as currency,
875 pledge.contribution_page_id as contribution_page_id,
876 payment.reminder_count as reminder_count,
877 pledge.max_reminders as max_reminders,
878 payment.reminder_date as reminder_date,
879 pledge.initial_reminder_day as initial_reminder_day,
880 pledge.additional_reminder_day as additional_reminder_day,
881 pledge.status_id as pledge_status,
882 payment.status_id as payment_status,
883 pledge.is_test as is_test,
884 pledge.campaign_id as campaign_id,
885 SUM(payment.scheduled_amount) as amount_due,
886 ( SELECT sum(civicrm_pledge_payment.actual_amount)
887 FROM civicrm_pledge_payment
888 WHERE civicrm_pledge_payment.status_id = 1
889 AND civicrm_pledge_payment.pledge_id = pledge.id
890 ) as amount_paid
891 FROM civicrm_pledge pledge, civicrm_pledge_payment payment
892 WHERE pledge.id = payment.pledge_id
893 AND payment.status_id IN ( {$statusIds} ) AND pledge.status_id IN ( {$pledgeStatusIds} )
894 GROUP By payment.id
895 ";
896
897 $dao = CRM_Core_DAO::executeQuery($query);
898
899 $now = date('Ymd');
900 $pledgeDetails = $contactIds = $pledgePayments = $pledgeStatus = array();
901 while ($dao->fetch()) {
902 $checksumValue = CRM_Contact_BAO_Contact_Utils::generateChecksum($dao->contact_id);
903
904 $pledgeDetails[$dao->payment_id] = array(
905 'scheduled_date' => $dao->scheduled_date,
906 'amount_due' => $dao->amount_due,
907 'amount' => $dao->amount,
908 'amount_paid' => $dao->amount_paid,
909 'create_date' => $dao->create_date,
910 'contact_id' => $dao->contact_id,
911 'pledge_id' => $dao->pledge_id,
912 'checksumValue' => $checksumValue,
913 'contribution_page_id' => $dao->contribution_page_id,
914 'reminder_count' => $dao->reminder_count,
915 'max_reminders' => $dao->max_reminders,
916 'reminder_date' => $dao->reminder_date,
917 'initial_reminder_day' => $dao->initial_reminder_day,
918 'additional_reminder_day' => $dao->additional_reminder_day,
919 'pledge_status' => $dao->pledge_status,
920 'payment_status' => $dao->payment_status,
921 'is_test' => $dao->is_test,
922 'currency' => $dao->currency,
923 'campaign_id' => $dao->campaign_id,
924 );
925
926 $contactIds[$dao->contact_id] = $dao->contact_id;
927 $pledgeStatus[$dao->pledge_id] = $dao->pledge_status;
928
929 if (CRM_Utils_Date::overdue(CRM_Utils_Date::customFormat($dao->scheduled_date, '%Y%m%d'),
930 $now
931 ) && $dao->payment_status != $allStatus['Overdue']
932 ) {
933 $pledgePayments[$dao->pledge_id][$dao->payment_id] = $dao->payment_id;
934 }
935 }
936 $allPledgeStatus = array_flip($allPledgeStatus);
937
938 // process the updating script...
939 foreach ($pledgePayments as $pledgeId => $paymentIds) {
940 // 1. update the pledge /pledge payment status. returns new status when an update happens
941 $returnMessages[] = "Checking if status update is needed for Pledge Id: {$pledgeId} (current status is {$allPledgeStatus[$pledgeStatus[$pledgeId]]})";
942
943 $newStatus = CRM_Pledge_BAO_PledgePayment::updatePledgePaymentStatus($pledgeId, $paymentIds,
944 $allStatus['Overdue'], NULL, 0, FALSE, TRUE
945 );
946 if ($newStatus != $pledgeStatus[$pledgeId]) {
947 $returnMessages[] = "- status updated to: {$allPledgeStatus[$newStatus]}";
948 $updateCnt += 1;
949 }
950 }
951
952 if ($sendReminders) {
953 // retrieve domain tokens
954 $domain = CRM_Core_BAO_Domain::getDomain();
955 $tokens = array(
956 'domain' => array('name', 'phone', 'address', 'email'),
957 'contact' => CRM_Core_SelectValues::contactTokens(),
958 );
959
960 $domainValues = array();
961 foreach ($tokens['domain'] as $token) {
962 $domainValues[$token] = CRM_Utils_Token::getDomainTokenReplacement($token, $domain);
963 }
964
965 // get the domain email address, since we don't carry w/ object.
966 $domainValue = CRM_Core_BAO_Domain::getNameAndEmail();
967 $domainValues['email'] = $domainValue[1];
968
969 // retrieve contact tokens
970
971 // this function does NOT return Deceased contacts since we don't want to send them email
972 list($contactDetails) = CRM_Utils_Token::getTokenDetails($contactIds,
973 NULL,
974 FALSE, FALSE, NULL,
975 $tokens, 'CRM_UpdatePledgeRecord'
976 );
977
978 // assign domain values to template
979 $template = CRM_Core_Smarty::singleton();
980 $template->assign('domain', $domainValues);
981
982 // set receipt from
983 $receiptFrom = '"' . $domainValues['name'] . '" <' . $domainValues['email'] . '>';
984
985 foreach ($pledgeDetails as $paymentId => $details) {
986 if (array_key_exists($details['contact_id'], $contactDetails)) {
987 $contactId = $details['contact_id'];
988 $pledgerName = $contactDetails[$contactId]['display_name'];
989 }
990 else {
991 continue;
992 }
993
994 if (empty($details['reminder_date'])) {
995 $nextReminderDate = new DateTime($details['scheduled_date']);
996 $details['initial_reminder_day'] = empty($details['initial_reminder_day']) ? 0 : $details['initial_reminder_day'];
997 $nextReminderDate->modify("-" . $details['initial_reminder_day'] . "day");
998 $nextReminderDate = $nextReminderDate->format("Ymd");
999 }
1000 else {
1001 $nextReminderDate = new DateTime($details['reminder_date']);
1002 $details['additional_reminder_day'] = empty($details['additional_reminder_day']) ? 0 : $details['additional_reminder_day'];
1003 $nextReminderDate->modify("+" . $details['additional_reminder_day'] . "day");
1004 $nextReminderDate = $nextReminderDate->format("Ymd");
1005 }
1006 if (($details['reminder_count'] < $details['max_reminders'])
1007 && ($nextReminderDate <= $now)
1008 ) {
1009
1010 $toEmail = $doNotEmail = $onHold = NULL;
1011
1012 if (!empty($contactDetails[$contactId]['email'])) {
1013 $toEmail = $contactDetails[$contactId]['email'];
1014 }
1015
1016 if (!empty($contactDetails[$contactId]['do_not_email'])) {
1017 $doNotEmail = $contactDetails[$contactId]['do_not_email'];
1018 }
1019
1020 if (!empty($contactDetails[$contactId]['on_hold'])) {
1021 $onHold = $contactDetails[$contactId]['on_hold'];
1022 }
1023
1024 // 2. send acknowledgement mail
1025 if ($toEmail && !($doNotEmail || $onHold)) {
1026 // assign value to template
1027 $template->assign('amount_paid', $details['amount_paid'] ? $details['amount_paid'] : 0);
1028 $template->assign('contact', $contactDetails[$contactId]);
1029 $template->assign('next_payment', $details['scheduled_date']);
1030 $template->assign('amount_due', $details['amount_due']);
1031 $template->assign('checksumValue', $details['checksumValue']);
1032 $template->assign('contribution_page_id', $details['contribution_page_id']);
1033 $template->assign('pledge_id', $details['pledge_id']);
1034 $template->assign('scheduled_payment_date', $details['scheduled_date']);
1035 $template->assign('amount', $details['amount']);
1036 $template->assign('create_date', $details['create_date']);
1037 $template->assign('currency', $details['currency']);
1038 list($mailSent, $subject, $message, $html) = CRM_Core_BAO_MessageTemplate::sendTemplate(
1039 array(
1040 'groupName' => 'msg_tpl_workflow_pledge',
1041 'valueName' => 'pledge_reminder',
1042 'contactId' => $contactId,
1043 'from' => $receiptFrom,
1044 'toName' => $pledgerName,
1045 'toEmail' => $toEmail,
1046 )
1047 );
1048
1049 // 3. update pledge payment details
1050 if ($mailSent) {
1051 CRM_Pledge_BAO_PledgePayment::updateReminderDetails($paymentId);
1052 $activityType = 'Pledge Reminder';
1053 $activityParams = array(
1054 'subject' => $subject,
1055 'source_contact_id' => $contactId,
1056 'source_record_id' => $paymentId,
1057 'assignee_contact_id' => $contactId,
1058 'activity_type_id' => CRM_Core_PseudoConstant::getKey('CRM_Activity_BAO_Activity',
1059 'activity_type_id',
1060 $activityType
1061 ),
1062 'due_date_time' => CRM_Utils_Date::isoToMysql($details['scheduled_date']),
1063 'is_test' => $details['is_test'],
1064 'status_id' => 2,
1065 'campaign_id' => $details['campaign_id'],
1066 );
1067 try {
1068 civicrm_api3('activity', 'create', $activityParams);
1069 }
1070 catch (CiviCRM_API3_Exception $e) {
1071 $returnMessages[] = "Failed creating Activity for Pledge Reminder: " . $e->getMessage();
1072 return array('is_error' => 1, 'message' => $returnMessages);
1073 }
1074 $returnMessages[] = "Payment reminder sent to: {$pledgerName} - {$toEmail}";
1075 }
1076 }
1077 }
1078 }
1079 // end foreach on $pledgeDetails
1080 }
1081 // end if ( $sendReminders )
1082 $returnMessages[] = "{$updateCnt} records updated.";
1083
1084 return array('is_error' => 0, 'messages' => implode("\n\r", $returnMessages));
1085 }
1086
1087 /**
1088 * Mark a pledge (and any outstanding payments) as cancelled.
1089 *
1090 * @param int $pledgeID
1091 */
1092 public static function cancel($pledgeID) {
1093 $paymentIDs = self::findCancelablePayments($pledgeID);
1094 $status = CRM_Contribute_PseudoConstant::contributionStatus(NULL, 'name');
1095 $cancelled = array_search('Cancelled', $status);
1096 CRM_Pledge_BAO_PledgePayment::updatePledgePaymentStatus($pledgeID, $paymentIDs, NULL,
1097 $cancelled, 0, FALSE, TRUE
1098 );
1099 }
1100
1101 /**
1102 * Find payments which can be safely canceled.
1103 *
1104 * @param int $pledgeID
1105 * @return array
1106 * Array of int (civicrm_pledge_payment.id)
1107 */
1108 public static function findCancelablePayments($pledgeID) {
1109 $statuses = array_flip(CRM_Contribute_PseudoConstant::contributionStatus());
1110
1111 $paymentDAO = new CRM_Pledge_DAO_PledgePayment();
1112 $paymentDAO->pledge_id = $pledgeID;
1113 $paymentDAO->whereAdd(sprintf("status_id IN (%d,%d)",
1114 $statuses['Overdue'],
1115 $statuses['Pending']
1116 ));
1117 $paymentDAO->find();
1118
1119 $paymentIDs = array();
1120 while ($paymentDAO->fetch()) {
1121 $paymentIDs[] = $paymentDAO->id;
1122 }
1123 return $paymentIDs;
1124 }
1125
1126 /**
1127 * Is this pledge free from financial transactions (this is important to know as we allow editing
1128 * when no transactions have taken place - the editing process currently involves deleting all pledge payments & contributions
1129 * & recreating so we want to block that if appropriate).
1130 *
1131 * @param int $pledgeID
1132 * @param int $pledgeStatusID
1133 * @return bool
1134 * do financial transactions exist for this pledge?
1135 */
1136 public static function pledgeHasFinancialTransactions($pledgeID, $pledgeStatusID) {
1137 if (empty($pledgeStatusID)) {
1138 // why would this happen? If we can see where it does then we can see if we should look it up.
1139 // but assuming from form code it CAN be empty.
1140 return TRUE;
1141 }
1142 if (self::isTransactedStatus($pledgeStatusID)) {
1143 return TRUE;
1144 }
1145
1146 return civicrm_api3('pledge_payment', 'getcount', array(
1147 'pledge_id' => $pledgeID,
1148 'contribution_id' => array('NOT NULL' => TRUE),
1149 ));
1150 }
1151
1152 /**
1153 * Does this pledge / pledge payment status mean that a financial transaction has taken place?
1154 * @param int $statusID
1155 * Pledge status id.
1156 *
1157 * @return bool
1158 * is it a transactional status?
1159 */
1160 protected static function isTransactedStatus($statusID) {
1161 if (!in_array($statusID, self::getNonTransactionalStatus())) {
1162 return TRUE;
1163 }
1164 return FALSE;
1165 }
1166
1167 /**
1168 * Get array of non transactional statuses.
1169 * @return array
1170 * non transactional status ids
1171 */
1172 protected static function getNonTransactionalStatus() {
1173 $paymentStatus = CRM_Contribute_PseudoConstant::contributionStatus(NULL, 'name');
1174 return array_flip(array_intersect($paymentStatus, array('Overdue', 'Pending')));
1175 }
1176
1177
1178 /**
1179 * Create array for recur record for pledge.
1180 * @return array
1181 * params for recur record
1182 */
1183 public static function buildRecurParams($params) {
1184 $recurParams = array(
1185 'is_recur' => TRUE,
1186 'auto_renew' => TRUE,
1187 'frequency_unit' => $params['pledge_frequency_unit'],
1188 'frequency_interval' => $params['pledge_frequency_interval'],
1189 'installments' => $params['pledge_installments'],
1190 'start_date' => $params['receive_date'],
1191 );
1192 return $recurParams;
1193 }
1194
1195 /**
1196 * Get pledge start date.
1197 *
1198 * @return string
1199 * start date
1200 */
1201 public static function getPledgeStartDate($date, $pledgeBlock) {
1202 $startDate = (array) json_decode($pledgeBlock['pledge_start_date']);
1203 list($field, $value) = each($startDate);
1204 if (!empty($date) && !CRM_Utils_Array::value('is_pledge_start_date_editable', $pledgeBlock)) {
1205 return $date;
1206 }
1207 if (empty($date)) {
1208 $date = $value;
1209 }
1210 switch ($field) {
1211 case 'contribution_date':
1212 if (empty($date)) {
1213 $date = date('Ymd');
1214 }
1215 break;
1216
1217 case 'calendar_date':
1218 $date = date('Ymd', strtotime($date));
1219 break;
1220
1221 case 'calendar_month':
1222 $date = self::getPaymentDate($date);
1223 $date = date('Ymd', strtotime($date));
1224 break;
1225
1226 default:
1227 break;
1228
1229 }
1230 return $date;
1231 }
1232
1233 /**
1234 * Get first payment date for pledge.
1235 *
1236 * @param int $day
1237 *
1238 * @return bool|string
1239 */
1240 public static function getPaymentDate($day) {
1241 if ($day == 31) {
1242 // Find out if current month has 31 days, if not, set it to 30 (last day).
1243 $t = date('t');
1244 if ($t != $day) {
1245 $day = $t;
1246 }
1247 }
1248 $current = date('d');
1249 switch (TRUE) {
1250 case ($day == $current):
1251 $date = date('m/d/Y');
1252 break;
1253
1254 case ($day > $current):
1255 $date = date('m/d/Y', mktime(0, 0, 0, date('m'), $day, date('Y')));
1256 break;
1257
1258 case ($day < $current):
1259 $date = date('m/d/Y', mktime(0, 0, 0, date('m', strtotime("+1 month")), $day, date('Y')));
1260 break;
1261
1262 default:
1263 break;
1264
1265 }
1266 return $date;
1267 }
1268
1269 /**
1270 * Override buildOptions to hack out some statuses.
1271 *
1272 * @todo instead of using & hacking the shared optionGroup contribution_status use a separate one.
1273 *
1274 * @param string $fieldName
1275 * @param string $context
1276 * @param array $props
1277 *
1278 * @return array|bool
1279 */
1280 public static function buildOptions($fieldName, $context = NULL, $props = array()) {
1281 $result = parent::buildOptions($fieldName, $context, $props);
1282 if ($fieldName == 'status_id') {
1283 $result = array_diff($result, array('Failed'));
1284 }
1285 return $result;
1286 }
1287
1288 }