Paypal IPN Issue with parallel payment
I figured out how to parse the adaptive payments IPN in PHP.
I used the DecodePayPalIPN()
function by donut2d https://www.x.com/developers/paypal/forums/adaptive-payments-api/php-technique-parsing-adaptive-payment-ipn-posts?page=0%2C0%2C0%2C0%2C0%2C0%2C0%2C0%2C0%2C0%2C0%2C0%2C0%2C0%2C0%2C1 in combination with one of the example listeners that is on the paypal website and here is my complete Codeigniter IPN Listener for adaptive payments with a parallel transaction.
<?php if ( ! defined('BASEPATH')) exit('No direct script access allowed');class Paypal_ipn extends CI_Controller { public function index() { // read the post from PayPal system and add 'cmd' $req = 'cmd=_notify-validate&'.file_get_contents("php://input"); $header = null; // post back to PayPal system to validate $header .= "POST /cgi-bin/webscr HTTP/1.0\r\n"; $header .= "Content-Type: application/x-www-form-urlencoded\r\n"; $header .= "Content-Length: " . strlen($req) . "\r\n\r\n"; $fp = fsockopen ('ssl://www.sandbox.paypal.com', 443, $errno, $errstr, 30); $raw_post = file_get_contents("php://input"); $post_array = $this->decodePayPalIPN($raw_post); //log_message('error', "!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!"); //$log1 = var_export($post_array, true); //log_message('error', $log1); //log_message('error', "!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!"); if(isset($post_array['sender_email'])) { $sender_email = $post_array['sender_email']; } if(isset($post_array['status'])) { $status = $post_array['status']; } if(isset($post_array['payment_request_date'])) { $payment_request_date = $post_array['payment_request_date']; } if(isset($post_array['transaction'][0]['receiver'])) { $receiver0 = $post_array['transaction'][0]['receiver']; } if(isset($post_array['transaction'][1]['receiver'])) { $receiver1 = $post_array['transaction'][1]['receiver']; } if(isset($post_array['transaction'][0]['id'])) { $id0 = $post_array['transaction'][0]['id']; } if(isset($post_array['transaction'][1]['id'])) { $id1 = $post_array['transaction'][1]['id']; } if(isset($post_array['transaction'][0]['invoiceId'])) { $invoiceId0 = $post_array['transaction'][0]['invoiceId']; } if(isset($post_array['transaction'][1]['invoiceId'])) { $invoiceId1 = $post_array['transaction'][1]['invoiceId']; } if(isset($post_array['transaction'][0]['amount'])) { $amount0 = $post_array['transaction'][0]['amount']; } if(isset($post_array['transaction'][1]['amount'])) { $amount1 = $post_array['transaction'][1]['amount']; } if(isset($post_array['transaction'][0]['status'])) { $status0 = $post_array['transaction'][0]['status']; } if(isset($post_array['transaction'][1]['status'])) { $status1 = $post_array['transaction'][1]['status']; } if(isset($post_array['transaction'][0]['id_for_sender_txn'])) { $id_for_sender_txn0 = $post_array['transaction'][0]['id_for_sender_txn']; } if(isset($post_array['transaction'][1]['id_for_sender_txn'])) { $id_for_sender_txn1 = $post_array['transaction'][1]['id_for_sender_txn']; } if(isset($post_array['transaction'][0]['status_for_sender_txn'])) { $status_for_sender_txn0 = $post_array['transaction'][0]['status_for_sender_txn']; } if(isset($post_array['transaction'][1]['status_for_sender_txn'])) { $status_for_sender_txn1 = $post_array['transaction'][1]['status_for_sender_txn']; } if(isset($post_array['transaction'][1]['pending_reason'])) { $pending_reason0 = $post_array['transaction'][1]['pending_reason']; } if(isset($post_array['transaction'][1]['pending_reason'])) { $pending_reason1 = $post_array['transaction'][1]['pending_reason']; } if (!$fp) { // HTTP ERROR } else { $counter = 0; fputs ($fp, $header . $req); while (!feof($fp)) { $res = fgets ($fp, 1024); if (strcmp ($res, "VERIFIED") == 0) { log_message('error', "sender_email = $sender_email"); log_message('error', "payment_request_date = $payment_request_date"); log_message('error', "status = $status"); log_message('error', "receiver0 = $receiver0"); log_message('error', "receiver1 = $receiver1"); log_message('error', "id0 = $id0"); log_message('error', "id1 = $id1"); log_message('error', "invoiceId0 = $invoiceId0"); log_message('error', "invoiceId1 = $invoiceId1"); log_message('error', "amount0 = $amount0"); log_message('error', "amount1 = $amount1"); log_message('error', "status0 = $status0"); log_message('error', "status1 = $status1"); log_message('error', "id_for_sender_txn0 = $id_for_sender_txn0"); log_message('error', "id_for_sender_txn1 = $id_for_sender_txn1"); log_message('error', "status_for_sender_txn0 = $status_for_sender_txn0"); log_message('error', "status_for_sender_txn1 = $status_for_sender_txn1"); log_message('error', "pending_reason0 = $pending_reason0"); log_message('error', "pending_reason1 = $pending_reason1"); // check the payment_status is Completed // check that txn_id has not been previously processed // check that receiver_email is your Primary PayPal email // check that payment_amount/payment_currency are correct // process payment $counter++; } else if (strcmp ($res, "INVALID") == 0) { log_message('error', 'WE INVALIDDDDDDDDDDDDDDDDDD'); $test = var_export($res, true); $test = str_replace(array("\r","\n"), '', $test); log_message('error', $test); log_message('error', "Problem with IPN. res = $test"); } } fclose ($fp); } } function decodePayPalIPN($raw_post) { //log_message('error', "testing"); if (empty($raw_post)) { return array(); } # else: $post = array(); $pairs = explode('&', $raw_post); foreach ($pairs as $pair) { list($key, $value) = explode('=', $pair, 2); $key = urldecode($key); $value = urldecode($value); # This is look for a key as simple as 'return_url' or as complex as 'somekey[x].property' preg_match('/(\w+)(?:\[(\d+)\])?(?:\.(\w+))?/', $key, $key_parts); switch (count($key_parts)) { case 4: # Original key format: somekey[x].property # Converting to $post[somekey][x][property] if (!isset($post[$key_parts[1]])) { $post[$key_parts[1]] = array($key_parts[2] => array($key_parts[3] => $value)); } else if (!isset($post[$key_parts[1]][$key_parts[2]])) { $post[$key_parts[1]][$key_parts[2]] = array($key_parts[3] => $value); } else { $post[$key_parts[1]][$key_parts[2]][$key_parts[3]] = $value; } break; case 3: # Original key format: somekey[x] # Converting to $post[somkey][x] if (!isset($post[$key_parts[1]])) { $post[$key_parts[1]] = array(); } $post[$key_parts[1]][$key_parts[2]] = $value; break; default: # No special format $post[$key] = $value; break; }#switch }#foreach return $post; }#decodePayPalIPN()}