"; return FALSE; } // At this point $object has first contribution loaded. // Lets do a check to make sure this payment has the amount same as that of first contribution. if ($objects['contribution']->total_amount != $input['amount']) { CRM_Core_Error::debug_log_message("Subscription amount mismatch."); echo "Failure: Subscription amount mismatch

"; return FALSE; } $contributionStatus = CRM_Contribute_PseudoConstant::contributionStatus(NULL, 'name'); $transaction = new CRM_Core_Transaction(); $now = date('YmdHis'); // fix dates that already exist $dates = array('create_date', 'start_date', 'end_date', 'cancel_date', 'modified_date'); foreach ($dates as $name) { if ($recur->$name) { $recur->$name = CRM_Utils_Date::isoToMysql($recur->$name); } } //load new contribution object if required. if (!$first) { // create a contribution and then get it processed $contribution = new CRM_Contribute_BAO_Contribution(); $contribution->contact_id = $ids['contact']; $contribution->financial_type_id = $objects['contributionType']->id; $contribution->contribution_page_id = $ids['contributionPage']; $contribution->contribution_recur_id = $ids['contributionRecur']; $contribution->receive_date = $now; $contribution->currency = $objects['contribution']->currency; $contribution->payment_instrument_id = $objects['contribution']->payment_instrument_id; $contribution->amount_level = $objects['contribution']->amount_level; $contribution->address_id = $objects['contribution']->address_id; $contribution->campaign_id = $objects['contribution']->campaign_id; $objects['contribution'] = &$contribution; } $objects['contribution']->invoice_id = md5(uniqid(rand(), TRUE)); $objects['contribution']->total_amount = $input['amount']; $objects['contribution']->trxn_id = $input['trxn_id']; // since we have processor loaded for sure at this point, // check and validate gateway MD5 response if present $this->checkMD5($ids, $input); $sendNotification = FALSE; if ($input['response_code'] == 1) { // Approved if ($first) { $recur->start_date = $now; $recur->trxn_id = $recur->processor_id; $sendNotification = TRUE; $subscriptionPaymentStatus = CRM_Core_Payment::RECURRING_PAYMENT_START; } $statusName = 'In Progress'; if (($recur->installments > 0) && ($input['subscription_paynum'] >= $recur->installments) ) { // this is the last payment $statusName = 'Completed'; $recur->end_date = $now; $sendNotification = TRUE; $subscriptionPaymentStatus = CRM_Core_Payment::RECURRING_PAYMENT_END; } $recur->modified_date = $now; $recur->contribution_status_id = array_search($statusName, $contributionStatus); $recur->save(); } else { // Declined // failed status $recur->contribution_status_id = array_search('Failed', $contributionStatus); $recur->cancel_date = $now; $recur->save(); CRM_Core_Error::debug_log_message("Subscription payment failed - '{$input['response_reason_text']}'"); // the recurring contribution has declined a payment or has failed // so we just fix the recurring contribution and not change any of // the existing contributions // CRM-9036 return TRUE; } // check if contribution is already completed, if so we ignore this ipn if ($objects['contribution']->contribution_status_id == 1) { $transaction->commit(); CRM_Core_Error::debug_log_message("returning since contribution has already been handled"); echo "Success: Contribution has already been handled

"; return TRUE; } $this->completeTransaction($input, $ids, $objects, $transaction, $recur); if ($sendNotification) { $autoRenewMembership = FALSE; if ($recur->id && isset($ids['membership']) && $ids['membership'] ) { $autoRenewMembership = TRUE; } //send recurring Notification email for user CRM_Contribute_BAO_ContributionPage::recurringNotify($subscriptionPaymentStatus, $ids['contact'], $ids['contributionPage'], $recur, $autoRenewMembership ); } } /** * @param $input * @param $ids */ function getInput(&$input, &$ids) { $input['amount'] = self::retrieve('x_amount', 'String'); $input['subscription_id'] = self::retrieve('x_subscription_id', 'Integer'); $input['response_code'] = self::retrieve('x_response_code', 'Integer'); $input['MD5_Hash'] = self::retrieve('x_MD5_Hash', 'String', FALSE, ''); $input['response_reason_code'] = self::retrieve('x_response_reason_code', 'String', FALSE); $input['response_reason_text'] = self::retrieve('x_response_reason_text', 'String', FALSE); $input['subscription_paynum'] = self::retrieve('x_subscription_paynum', 'Integer', FALSE, 0); $input['trxn_id'] = self::retrieve('x_trans_id', 'String', FALSE); if ($input['trxn_id']) { $input['is_test'] = 0; } else { $input['is_test'] = 1; $input['trxn_id'] = md5(uniqid(rand(), TRUE)); } if (!$this->getBillingID($ids)) { return FALSE; } $billingID = $ids['billing']; $params = array( 'first_name' => 'x_first_name', 'last_name' => 'x_last_name', "street_address-{$billingID}" => 'x_address', "city-{$billingID}" => 'x_city', "state-{$billingID}" => 'x_state', "postal_code-{$billingID}" => 'x_zip', "country-{$billingID}" => 'x_country', "email-{$billingID}" => 'x_email', ); foreach ($params as $civiName => $resName) { $input[$civiName] = self::retrieve($resName, 'String', FALSE); } } /** * @param $ids * @param $input */ function getIDs(&$ids, &$input) { $ids['contact'] = self::retrieve('x_cust_id', 'Integer', FALSE, 0); $ids['contribution'] = self::retrieve('x_invoice_num', 'Integer'); // joining with contribution table for extra checks $sql = " SELECT cr.id, cr.contact_id FROM civicrm_contribution_recur cr INNER JOIN civicrm_contribution co ON co.contribution_recur_id = cr.id WHERE cr.processor_id = '{$input['subscription_id']}' AND (cr.contact_id = {$ids['contact']} OR co.id = {$ids['contribution']}) LIMIT 1"; $contRecur = CRM_Core_DAO::executeQuery($sql); $contRecur->fetch(); $ids['contributionRecur'] = $contRecur->id; if($ids['contact'] != $contRecur->contact_id){ CRM_Core_Error::debug_log_message("Recurring contribution appears to have been re-assigned from id {$ids['contact']} to {$contRecur->contact_id} Continuing with {$contRecur->contact_id} "); $ids['contact'] = $contRecur->contact_id; } if (!$ids['contributionRecur']) { CRM_Core_Error::debug_log_message("Could not find contributionRecur id: ".print_r($input, TRUE)); echo "Failure: Could not find contributionRecur

"; exit(); } // get page id based on contribution id $ids['contributionPage'] = CRM_Core_DAO::getFieldValue('CRM_Contribute_DAO_Contribution', $ids['contribution'], 'contribution_page_id' ); if ($input['component'] == 'event') { // FIXME: figure out fields for event } else { // get the optional ids // Get membershipId. Join with membership payment table for additional checks $sql = " SELECT m.id FROM civicrm_membership m INNER JOIN civicrm_membership_payment mp ON m.id = mp.membership_id AND mp.contribution_id = {$ids['contribution']} WHERE m.contribution_recur_id = {$ids['contributionRecur']} LIMIT 1"; if ($membershipId = CRM_Core_DAO::singleValueQuery($sql)) { $ids['membership'] = $membershipId; } // FIXME: todo related_contact and onBehalfDupeAlert. Check paypalIPN. } } /** * @param $name * @param $type * @param bool $abort * @param null $default * @param string $location * * @return mixed */ static function retrieve($name, $type, $abort = TRUE, $default = NULL, $location = 'POST') { static $store = NULL; $value = CRM_Utils_Request::retrieve($name, $type, $store, FALSE, $default, $location ); if ($abort && $value === NULL) { CRM_Core_Error::debug_log_message("Could not find an entry for $name in $location"); CRM_Core_Error::debug_var('POST', $_POST); CRM_Core_Error::debug_var('REQUEST', $_REQUEST); echo "Failure: Missing Parameter

"; exit(); } return $value; } /** * @param $ids * @param $input * * @return bool */ function checkMD5($ids, $input) { $paymentProcessor = CRM_Financial_BAO_PaymentProcessor::getPayment($ids['paymentProcessor'], $input['is_test'] ? 'test' : 'live' ); $paymentObject = CRM_Core_Payment::singleton($input['is_test'] ? 'test' : 'live', $paymentProcessor); if (!$paymentObject->checkMD5($input['MD5_Hash'], $input['trxn_id'], $input['amount'], TRUE)) { CRM_Core_Error::debug_log_message("MD5 Verification failed."); echo "Failure: Security verification failed

"; exit(); } return TRUE; } }