3 +--------------------------------------------------------------------+
4 | CiviCRM version 4.7 |
5 +--------------------------------------------------------------------+
6 | Copyright CiviCRM LLC (c) 2004-2016 |
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-2016
35 * This class provides the functionality to email a group of contacts.
37 class CRM_Contribute_Form_Task_Status
extends CRM_Contribute_Form_Task
{
40 * Are we operating in "single mode", i.e. updating the task of only
41 * one specific contribution?
45 public $_single = FALSE;
50 * Build all the data structures needed to build the form.
52 public function preProcess() {
53 $id = CRM_Utils_Request
::retrieve('id', 'Positive',
58 $this->_contributionIds
= array($id);
59 $this->_componentClause
= " civicrm_contribution.id IN ( $id ) ";
60 $this->_single
= TRUE;
61 $this->assign('totalSelectedContributions', 1);
67 // check that all the contribution ids have pending status
70 FROM civicrm_contribution
71 WHERE contribution_status_id != 2
72 AND {$this->_componentClause}";
73 $count = CRM_Core_DAO
::singleValueQuery($query,
74 CRM_Core_DAO
::$_nullArray
77 CRM_Core_Error
::statusBounce(ts('Please select only online contributions with Pending status.'));
80 // we have all the contribution ids, so now we get the contact ids
81 parent
::setContactIDs();
82 $this->assign('single', $this->_single
);
86 * Sets contribution Ids for unit test.
88 public function setContributionIds($contributionIds) {
89 $this->_contributionIds
= $contributionIds;
93 * Build the form object.
95 public function buildQuickForm() {
96 $status = CRM_Contribute_PseudoConstant
::contributionStatus();
100 $this->add('select', 'contribution_status_id',
101 ts('Contribution Status'),
106 $contribIDs = implode(',', $this->_contributionIds
);
108 SELECT c.id as contact_id,
109 co.id as contribution_id,
110 c.display_name as display_name,
111 co.total_amount as amount,
112 co.receive_date as receive_date,
114 co.payment_instrument_id as paid_by,
115 co.check_number as check_no
116 FROM civicrm_contact c,
117 civicrm_contribution co
118 WHERE co.contact_id = c.id
119 AND co.id IN ( $contribIDs )";
120 $dao = CRM_Core_DAO
::executeQuery($query,
121 CRM_Core_DAO
::$_nullArray
124 // build a row for each contribution id
125 $this->_rows
= array();
126 $attributes = CRM_Core_DAO
::getAttribute('CRM_Contribute_DAO_Contribution');
128 $now = date("m/d/Y");
129 $paidByOptions = array('' => ts('- select -')) + CRM_Contribute_PseudoConstant
::paymentInstrument();
131 while ($dao->fetch()) {
132 $row['contact_id'] = $dao->contact_id
;
133 $row['contribution_id'] = $dao->contribution_id
;
134 $row['display_name'] = $dao->display_name
;
135 $row['amount'] = $dao->amount
;
136 $row['source'] = $dao->source
;
137 $row['trxn_id'] = &$this->addElement('text', "trxn_id_{$row['contribution_id']}", ts('Transaction ID'));
138 $this->addRule("trxn_id_{$row['contribution_id']}",
139 ts('This Transaction ID already exists in the database. Include the account number for checks.'),
141 array('CRM_Contribute_DAO_Contribution', $dao->contribution_id
, 'trxn_id')
144 $row['fee_amount'] = &$this->add('text', "fee_amount_{$row['contribution_id']}", ts('Fee Amount'),
145 $attributes['fee_amount']
147 $this->addRule("fee_amount_{$row['contribution_id']}", ts('Please enter a valid amount.'), 'money');
148 $defaults["fee_amount_{$row['contribution_id']}"] = 0.0;
150 $row['trxn_date'] = $this->addDate("trxn_date_{$row['contribution_id']}", FALSE,
151 ts('Receipt Date'), array('formatType' => 'activityDate')
153 $defaults["trxn_date_{$row['contribution_id']}"] = $now;
155 $this->add("text", "check_number_{$row['contribution_id']}", ts('Check Number'));
156 $defaults["check_number_{$row['contribution_id']}"] = $dao->check_no
;
158 $this->add("select", "payment_instrument_id_{$row['contribution_id']}", ts('Payment Method'), $paidByOptions);
159 $defaults["payment_instrument_id_{$row['contribution_id']}"] = $dao->paid_by
;
161 $this->_rows
[] = $row;
164 $this->assign_by_ref('rows', $this->_rows
);
165 $this->setDefaults($defaults);
166 $this->addButtons(array(
169 'name' => ts('Update Pending Status'),
174 'name' => ts('Cancel'),
179 $this->addFormRule(array('CRM_Contribute_Form_Task_Status', 'formRule'));
183 * Global validation rules for the form.
185 * @param array $fields
186 * Posted values of the form.
189 * list of errors to be posted back to the form
191 public static function formRule($fields) {
192 $seen = $errors = array();
193 foreach ($fields as $name => $value) {
194 if (strpos($name, 'trxn_id_') !== FALSE) {
195 if ($fields[$name]) {
196 if (array_key_exists($value, $seen)) {
197 $errors[$name] = ts('Transaction ID\'s must be unique. Include the account number for checks.');
203 if ((strpos($name, 'check_number_') !== FALSE) && $value) {
204 $contribID = substr($name, 13);
206 if ($fields["payment_instrument_id_{$contribID}"] != CRM_Core_OptionGroup
::getValue('payment_instrument', 'Check', 'name')) {
207 $errors["payment_instrument_id_{$contribID}"] = ts("Payment Method should be Check when a check number is entered for a contribution.");
211 return empty($errors) ?
TRUE : $errors;
215 * Process the form after the input has been submitted and validated.
217 public function postProcess() {
218 $params = $this->controller
->exportValues($this->_name
);
220 // submit the form with values.
221 self
::processForm($this, $params);
223 CRM_Core_Session
::setStatus(ts('Contribution status has been updated for selected record(s).'), ts('Status Updated'), 'success');
227 * Process the form with submitted params.
228 * Also supports unit test.
230 public static function processForm($form, $params) {
231 $statusID = CRM_Utils_Array
::value('contribution_status_id', $params);
232 $baseIPN = new CRM_Core_Payment_BaseIPN();
234 $transaction = new CRM_Core_Transaction();
236 // get the missing pieces for each contribution
237 $contribIDs = implode(',', $form->_contributionIds
);
238 $details = self
::getDetails($contribIDs);
239 $template = CRM_Core_Smarty
::singleton();
241 // for each contribution id, we just call the baseIPN stuff
242 foreach ($form->_rows
as $row) {
243 $input = $ids = $objects = array();
244 $input['component'] = $details[$row['contribution_id']]['component'];
246 $ids['contact'] = $row['contact_id'];
247 $ids['contribution'] = $row['contribution_id'];
248 $ids['contributionRecur'] = NULL;
249 $ids['contributionPage'] = NULL;
250 $ids['membership'] = CRM_Utils_Array
::value('membership', $details[$row['contribution_id']]);
251 $ids['participant'] = CRM_Utils_Array
::value('participant', $details[$row['contribution_id']]);
252 $ids['event'] = CRM_Utils_Array
::value('event', $details[$row['contribution_id']]);
254 if (!$baseIPN->validateData($input, $ids, $objects, FALSE)) {
255 CRM_Core_Error
::fatal();
258 $contribution = &$objects['contribution'];
260 $contributionStatuses = CRM_Contribute_PseudoConstant
::contributionStatus(NULL,
264 if ($statusID == array_search('Cancelled', $contributionStatuses)) {
265 $baseIPN->cancelled($objects, $transaction);
266 $transaction->commit();
269 elseif ($statusID == array_search('Failed', $contributionStatuses)) {
270 $baseIPN->failed($objects, $transaction);
271 $transaction->commit();
275 // status is not pending
276 if ($contribution->contribution_status_id
!= array_search('Pending',
277 $contributionStatuses
280 $transaction->commit();
284 // set some fake input values so we can reuse IPN code
285 $input['amount'] = $contribution->total_amount
;
286 $input['is_test'] = $contribution->is_test
;
287 $input['fee_amount'] = $params["fee_amount_{$row['contribution_id']}"];
288 $input['check_number'] = $params["check_number_{$row['contribution_id']}"];
289 $input['payment_instrument_id'] = $params["payment_instrument_id_{$row['contribution_id']}"];
290 $input['net_amount'] = $contribution->total_amount
- $input['fee_amount'];
292 if (!empty($params["trxn_id_{$row['contribution_id']}"])) {
293 $input['trxn_id'] = trim($params["trxn_id_{$row['contribution_id']}"]);
296 $input['trxn_id'] = $contribution->invoice_id
;
298 $input['trxn_date'] = CRM_Utils_Date
::processDate($params["trxn_date_{$row['contribution_id']}"], date('H:i:s'));
300 // @todo calling baseIPN like this is a pattern in it's last gasps. Call contribute.completetransaction api.
301 $baseIPN->completeTransaction($input, $ids, $objects, $transaction, FALSE);
303 // reset template values before processing next transactions
304 $template->clearTemplateVars();
309 * @param $contributionIDs
313 public static function &getDetails($contributionIDs) {
315 SELECT c.id as contribution_id,
316 c.contact_id as contact_id ,
317 mp.membership_id as membership_id ,
318 pp.participant_id as participant_id ,
319 p.event_id as event_id
320 FROM civicrm_contribution c
321 LEFT JOIN civicrm_membership_payment mp ON mp.contribution_id = c.id
322 LEFT JOIN civicrm_participant_payment pp ON pp.contribution_id = c.id
323 LEFT JOIN civicrm_participant p ON pp.participant_id = p.id
324 WHERE c.id IN ( $contributionIDs )";
327 $dao = CRM_Core_DAO
::executeQuery($query,
328 CRM_Core_DAO
::$_nullArray
332 while ($dao->fetch()) {
333 $rows[$dao->contribution_id
]['component'] = $dao->participant_id ?
'event' : 'contribute';
334 $rows[$dao->contribution_id
]['contact'] = $dao->contact_id
;
335 if ($dao->membership_id
) {
336 if (!array_key_exists('membership', $rows[$dao->contribution_id
])) {
337 $rows[$dao->contribution_id
]['membership'] = array();
339 $rows[$dao->contribution_id
]['membership'][] = $dao->membership_id
;
341 if ($dao->participant_id
) {
342 $rows[$dao->contribution_id
]['participant'] = $dao->participant_id
;
344 if ($dao->event_id
) {
345 $rows[$dao->contribution_id
]['event'] = $dao->event_id
;