<?php
/**
 * @package DJ-Catalog2
 * @copyright Copyright (C) DJ-Extensions.com, All rights reserved.
 * @license http://www.gnu.org/licenses GNU/GPL
 * @author url: http://dj-extensions.com
 * @author email contact@dj-extensions.com
 */

// no direct access


defined('_JEXEC') or die('Restricted access');

use Curl\Curl;
use Joomla\CMS\Date\Date;
use Joomla\Registry\Registry;
use Joomla\CMS\Factory;
use Joomla\CMS\Router\Route;
use Joomla\CMS\Uri\Uri;
use Joomla\CMS\Language\Text;
use Joomla\CMS\Component\ComponentHelper;
use Joomla\CMS\Plugin\CMSPlugin;

//jimport('joomla.plugin.plugin');

require_once __DIR__ . '/lib/autoloader.php';
require_once __DIR__ . '/vendor/autoload.php';

class plgDjcatalog2paymentPaypal extends CMSPlugin
{

	protected $currency;
	protected $debug;

	public function __construct(&$subject, $config = array())
	{
		parent::__construct($subject, $config);
		$cparams = ComponentHelper::getParams('com_djcatalog2');
		$this->currency = $cparams->get('cart_currency', 'USD');
		$this->debug = $this->params->get('debug', 0);
		$this->loadLanguage();
		require_once JPATH_ROOT . '/plugins/djcatalog2payment/paypal/lib/PaypalIPN.php';
	}

	protected function isAllowed($plgInfo, $type = 'djcatalog2payment')
	{
		return (bool)($plgInfo->plugin == $this->_name && $this->_type == $type);
	}

	public function onContentPrepareForm($form, $data)
	{
		if ($form->getName() != 'com_djcatalog2.payment') {
			return;
		}

		$plugin = '';

		if (!empty($data) && !empty($data->plugin)) {
			$plugin = $data->plugin;
		} else {
			$jform = Factory::getApplication()->input->get('jform', array(), 'array');
			if (!empty($jform) && isset($jform['plugin'])) {
				$plugin = $jform['plugin'];
			}
		}

		if ($plugin != $this->_name) {
			return true;
		}

		return $form->loadFile(dirname(__FILE__) . DIRECTORY_SEPARATOR . 'config' . DIRECTORY_SEPARATOR . 'configuration.xml', false);
	}

	public function onDJC2BeforeSaveOrder($context, $table, $isNew, $plgInfo)
	{
		if ($context != 'com_djcatalog2.checkout.payment' || !$this->isAllowed($plgInfo)) {
			return;
		}
	}

	public function onDJC2AfterSaveOrder($context, $table, $isNew, $plgInfo)
	{
		if ($context != 'com_djcatalog2.checkout.payment' || !$this->isAllowed($plgInfo)) {
			return;
		}
	}

	public function onDJC2CheckoutDetailsDisplay($context, $plgInfo)
	{
		if ($context != 'com_djcatalog2.checkout.payment' || !$this->isAllowed($plgInfo)) {
			return;
		}

		$html = '';
		if (trim(strip_tags($plgInfo->description)) != '') {
			$html = '<h4>' . $plgInfo->name . '</h4>';
			$html .= $plgInfo->description;
		}

		return $html;
	}

	public function onDJC2OrderDetailsDisplay($context, $order, $plgInfo)
	{
		if ($context != 'com_djcatalog2.order.payment' || !$this->isAllowed($plgInfo)) {
			return;
		}

		$app = Factory::getApplication();
		$message = '';

		if ($app->input->get('view') == 'order' && $app->input->get('error')) {
			$message = Text::_('PLG_DJCATALOG2PAYMENT_PAYPAL_ERROR_TEXT');
		} else if ($app->input->get('success') == '1') {
			$message = Text::_('PLG_DJCATALOG2PAYMENT_PAYPAL_RETURN_TEXT');
		}

		if ($order->status != 'A' && $order->status != 'N') {
			return;
		}


		$paymentUrl = Route::_('index.php?option=com_djcatalog2&task=paymentProcess&oid=' . $order->id . '&plg=' . $plgInfo->plugin . '&plgid=' . $plgInfo->id);
		$html = '<div class="paypalinfo">';


		if ($message) {
			$html .= '<p class="paypalalert">' . $message . '</p>';
		}

		if ($app->input->get('finished') == '1' && $plgInfo->params->get('autoredir', '1') == '1') {
			$html .= '<script>jQuery(document).ready(function(){
				setTimeout(function(){window.location.href="' . Route::_('index.php?option=com_djcatalog2&task=paymentProcess&oid=' . $order->id . '&plg=' . $plgInfo->plugin . '&plgid=' . $plgInfo->id, false) . '";}, 2000);
			});</script>';
		}


		$payment_params = json_decode($order->payment_params);


		$html .= '<p class="paypalmessage">';
		$html .= Text::_('PLG_DJCATALOG2PAYMENT_PAYPAY_INFO_TEXT');
		$html .= '</p>';


		$success = $app->input->get('success');
		$subscription_id = $app->input->getRaw('subscription_id');



		if($subscription_id && $subscription_id == $order->payment_params) {
			$html .= '<p class="paypalbutton">';
			$html .= Text::_('PLG_DJCATALOG2PAYMENT_PAYPAL_RETURN_TEXT');
			$html .= '</p>';
			$html .= '</div>';
			return $html;
		}else {
			$html .= '<p class="paypalbutton">';
			$html .= '<a href="' . $paymentUrl . '" class="paypalbtn btn ">' . Text::_('PLG_DJCATALOG2PAYMENT_PAYPAL_BTN') . '</a>';
			$html .= '</p>';
			$html .= '</div>';
			return $html;
		}

	}

	function onDJC2PaymentProcess($context, $order, $plgInfo)
	{
		if ($context != 'com_djcatalog2.order.payment' || !$this->isAllowed($plgInfo)) {
			return;
		}


		if (!empty($order->recurring) && $order->recurring == 1)
			$this->tokenizePayment($order, $plgInfo);
		else
			$this->standardPaymentProcess($order, $plgInfo);
	}

	/* Recuring Payment Process */
	private function tokenizePayment($order, $plgInfo)
	{
		$cliendId = $plgInfo->params->get('client_id');
		$cliendSecret = $plgInfo->params->get('client_secret');

		if (empty($cliendId) || empty($cliendSecret)) {
			throw new Exception(Text::_('PLG_DJCATALOG2PAYMENT_PAYPAL_ERROR_MISSING_PARAMS'), 400);
		}

		$orderItem = $order->items[0];
		$name = $orderItem->item_name;
		$product_id = $orderItem->id;
		$product_id = $orderItem->id;
		$recurringParams = new Registry($order->recurring_params);
		$amount = number_format($order->grand_total, 2);
		$return = Uri::root() . DJCatalogHelperRoute::getOrderRoute($order->id) . '&success=1';

		$notify_url = Uri::root() . 'index.php?option=com_djcatalog2&task=paymentResponse&plg=' . $plgInfo->plugin . '&plgid=' . $plgInfo->id;



		$expiration = 0;
		if ($orderItem->product_type == 'subscription') {
			$db = Factory::getDbo();
			$db->setQuery('SELECT * FROM #__djc2_items WHERE id = ' . (int)$orderItem->item_id);
			$item = $db->loadObject();
			$expiration = $item->expiration;
		}


		// create paypal product
		$product = [
			'name' => $name,
			'type' => 'SERVICE',
		];

		$planId = 'PLAN-' . $product_id . '-' . $order->id;

		$curl = new Curl();
		$curl->setHeader('Content-Type', 'application/json');
		$curl->setBasicAuthentication($cliendId, $cliendSecret);
		$curl->setHeader('PayPal-Request-Id', $planId);
		$curl->post('https://api-m.sandbox.paypal.com/v1/catalogs/products', $product);

		$body = [
			'name' => $name,
			'product_id' => $curl->response->id,
			'description' => 'Subscription plan',
			'payment_preferences' => [
				'auto_bill_outstanding' => true,
				'setup_fee_failure_action' => 'CANCEL',
				'payment_failure_threshold' => 1,
				'setup_fee' => [
					'value' => $amount,
					'currency_code' => $order->currency
				],
			],
			'billing_cycles' => [
				[
					'pricing_scheme' => [
						'fixed_price' => [
							'value' => $amount,
							'currency_code' => $order->currency
						]
					],
					'frequency' => [
						'interval_unit' => 'DAY',
						'interval_count' => $expiration,
					],
					'tenure_type' => 'REGULAR',
					'sequence' => 1
				]
			]
		];




		$access_token = $curl->response->access_token;

		$curl = new Curl();
		$curl->setHeader('Content-Type', 'application/json');
		$curl->setBasicAuthentication($cliendId, $cliendSecret);
		$curl->setHeader('PayPal-Request-Id', $planId);
		$curl->post('https://api-m.sandbox.paypal.com/v1/billing/plans', $body);


		$app = \Factory::getApplication();

		if ($curl->error) {
			$app->enqueueMessage($curl->errorMessage, 'warning');
			$app->redirect(Route::_('index.php?option=com_djcatalog2&view=order&oid=' . (int)$order->id));
			return;
		}

		$now = new Date('now + 5 minutes');
		$subscription = [
			'plan_id' => $curl->response->id,
			'start_time' => $now->toISO8601(),
			'quantity' => 1,
			'subscriber' => [
				'name' => [
					'given_name' => $order->first_name,
					'surname' => $order->last_name
				],
				'email_address' => $order->email,
			],
			'application_context' => [
				'return_url' => $return,
				'user_action' => 'SUBSCRIBE_NOW',
			]
		];



		$curl = new Curl();
		$curl->setHeader('Content-Type', 'application/json');
		$curl->setBasicAuthentication($cliendId, $cliendSecret);
		$curl->setHeader('PayPal-Request-Id', $planId);
		$curl->post('https://api-m.sandbox.paypal.com/v1/billing/subscriptions', $subscription);


		$recurringParams->set('subscription_id', $curl->response->id);

		foreach ($curl->response->links as $link) {
			if($link->rel == 'approve') {

				$orderUpdate = new stdClass();
				$orderUpdate->payment_params = $curl->response->id;
				$orderUpdate->id=$order->id;
				$result = Factory::getDbo()->updateObject('#__djc2_orders', $orderUpdate, 'id');
				header( "refresh:1;url=" .  $link->href );
				break;
			}
		}

	}

	public function onDJC2CapturePayment($model, $plgInfo) {
		if (!$this->isAllowed($plgInfo)) {
			return;
		}
		$model->changeStatus($model->getItem(), 'P', true, true, Text::_('PLG_DJCATALOG2PAYMENT_PAYPAL_PAYMENT_COMPLETED'));
	}

	/* Standard Payment Process */
	private function standardPaymentProcess($order, $plgInfo)
	{
		$emailId = $plgInfo->params->get('email_id');
		$testMode = $plgInfo->params->get('test');

		if (empty($emailId)) {
			throw new Exception(Text::_('PLG_DJCATALOG2PAYMENT_PAYPAL_ERROR_MISSING_PARAMS'), 400);
		}


		$app = Factory::getApplication();
		$websiteName = $app->get('sitename', JURI::base());


		$return = Route::_(DJCatalogHelperRoute::getOrderRoute($order->id) . '&success=1', false, (Uri::getInstance()->isSSL() ? 1 : -1));
		$cancel_return = Route::_(DJCatalogHelperRoute::getOrderRoute($order->id) . '&error=1', false, (Uri::getInstance()->isSSL() ? 1 : -1));
		//$notify_url = Route::_(DJCatalogHelperRoute::getCategoryRoute(0) . '&task=paymentResponse&plg=' . $plgInfo->plugin . '&plgid=' . $plgInfo->id . '&oid=' . $order->id, false, (Uri::getInstance()->isSSL() ? 1 : -1));
		$notify_url = Route::_('index.php?option=com_djcatalog2&task=paymentResponse&plg=' . $plgInfo->plugin . '&plgid=' . $plgInfo->id . '&oid=' . $order->id . '&Itemid=', false, (Uri::getInstance()->isSSL() ? 1 : -1));
		$cancel_return .= '&ts=' . time();
		$notify_url .= '&ts=' . time();
		$return .= '&ts=' . time();


		$description = Text::sprintf('PLG_DJCATALOG2PAYMENT_PAYPAL_ORDER_DESCRIPTION', $order->order_number, $websiteName);
		//$currency = (!empty($order->currency)) ? $order->currency : $plgInfo->params->get('currency_code', $this->currency);
		$currency = $order->currency;
		$amount = round($order->grand_total, 2);

		$optional_fields = [
			'address1' => $order->address,
			'city' => $order->city,
			'zip' => $order->postcode,
			'country' => $order->country,
			'email' => $order->email,
			'first_name' => $order->firstname,
			'last_name' => $order->lastname
		];


		$urlpaypal = "";

		if ($testMode) {
			$urlpaypal = "https://www.sandbox.paypal.com/cgi-bin/webscr";
		} else {
			$urlpaypal = "https://www.paypal.com/cgi-bin/webscr";
		}


		$html = '<!doctype html><html lang="en-US"><head><meta charset="utf-8"><title>' . Text::_('COM_DJCATALOG2_PAYMENT_REDIRECTION') . '</title></head>';
		$html .= '<body><div style="margin: auto; text-align: center;">';
		$html .= '<form method="post" action="' . $urlpaypal . '" name="paypalform">';
		$html .= '<p>' . Text::_('COM_DJCATALOG2_PAYMENT_REDIRECTION') . '</p>';
		$html .= '<input type="hidden" name="cmd" value="_xclick" />';
		$html .= '<input id="custom" type="hidden" name="custom" value="' . $order->id . '" />';
		$html .= '<input type="hidden" name="business" value="' . trim($emailId) . '" />';
		$html .= '<input type="hidden" name="currency_code" value="' . trim($currency) . '" />';
		$html .= '<input type="hidden" name="item_name" value="' . substr($description, 0, 127) . '" />';
		$html .= '<input type="hidden" name="amount" value="' . $amount . '" />';
		$html .= '<input type="hidden" name="charset" value="utf-8" />';
		$html .= '<input type="hidden" name="cancel_return" value="' . ($cancel_return) . '" />';
		$html .= '<input type="hidden" name="notify_url" value="' . ($notify_url) . '" />';
		$html .= '<input type="hidden" name="return" value="' . ($return) . '" />';

		foreach ($optional_fields as $fieldkey => $fieldval) {
			if (trim($fieldval) == '') continue;
			$html .= '<input type="hidden" name="' . $fieldkey . '" value="' . ($fieldval) . '" />';
		}

		$html .= '<noscript><input type="submit"  value="' . Text::_('COM_DJCATALOG2_PAYMENT_REDIRECTION_BUTTON') . '" /></noscript>';
		$html .= '</form></div>';
		$html .= ' <script type="text/javascript">';
		$html .= ' setTimeout(function(){ document.paypalform.submit(); }, 500);';
		$html .= ' </script></body></html>';

		echo $html;
		$app->close();
	}

	public function onDJC2PaymentDiscover($context, $plgInfo)
	{
		if ($context != 'com_djcatalog2.order.payment' || !$this->isAllowed($plgInfo)) {
			return;
		}
		$json = file_get_contents('php://input');
		$data = json_decode($json);
		if(isset($data->resource->billing_agreement_id)) {
			if(!isset($data->event_type) || $data->event_type !== 'PAYMENT.SALE.COMPLETED') {
				return 0;
			}else {
				$db = Factory::getDbo();
				$db->setQuery('SELECT * FROM #__djc2_orders WHERE payment_params = ' . $db->quote($data->resource->billing_agreement_id));
				$order = $db->loadObject();

				return $order->id;
			}
		}else {
			$this->log('[onDJC2PaymentDiscover] ' . $plgInfo->plugin);
			$this->log('[onDJC2PaymentDiscover] ' . print_r($_POST, true));

			$app = Factory::getApplication();

			$oid = $app->input->getInt('oid');

			$this->log('[onDJC2PaymentDiscover] order id: ' . $oid);
			return $oid;
		}



	}


	public function onDJC2PaymentResponse($context, $order, $model, $plgInfo)
	{
		if ($context != 'com_djcatalog2.order.payment' || !$this->isAllowed($plgInfo)) {
			return;
		}



		$app = Factory::getApplication();

		if ($order->recurring == 1)
			$this->recurringPaymentResponse($context, $order, $model, $plgInfo);
		else
			$this->standardPaymentResponse($context, $order, $model, $plgInfo);


		$app->close();
	}


	private function recurringPaymentResponse($context, $order, $model, $plgInfo)
	{
		$app = Factory::getApplication();
		$json = file_get_contents('php://input');
		$data = json_decode($json);
		$status = $data->resource->state;

		$json = file_get_contents('php://input');
		$data = json_decode($json);
		$filename = 'paypal3.log';
		$handle = fopen($filename, 'w');
		fwrite($handle, floatval($data->resource->amount->total) . ' ' . floatval($order->grand_total) . ' ' . $status);
		fclose($handle);

		if (floatval($data->resource->amount->total) != floatval($order->grand_total)) {
			$this->log('[onDJC2PaymentResponse] failed verification price fraud');
			$this->log('Price Paypal ' . $app->input->getString('mc_gross'));
			$this->log('Price Order ' . $order->grand_total);
			$app->close();
		}


		$this->log('[onDJC2PaymentResponse] payment status: ' . $status);
		if (($status == 'completed')) {
			$this->log('[onDJC2PaymentResponse] order status: ' . $order->status);
			// confirm the order unless it has already been rejected or confirmed
			if ($order->status == 'A' || $order->status == 'N') {
				$this->log('[onDJC2PaymentResponse] payment status changed');
				$model->changeStatus($order, 'P', true, true, Text::_('PLG_DJCATALOG2PAYMENT_PAYPAL_PAYMENT_COMPLETED'));
			}
		}
	}


	private function standardPaymentResponse($context, $order, $model, $plgInfo)
	{
		$emailId = $plgInfo->params->get('email_id');
		$testMode = $plgInfo->params->get('test');
		$app = Factory::getApplication();

		if (empty($emailId)) {
			throw new Exception(Text::_('PLG_DJCATALOG2PAYMENT_PAYPAL_ERROR_MISSING_PARAMS'), 400);
		}

		$paypal_info = $_POST;

		$this->log('[onDJC2PaymentResponse] POST DATA init: ');
		$this->log(print_r($paypal_info, true));
		$ipn = new PaypalIPN();
		if ($testMode)
			$ipn->useSandbox(true);

		try {
			if (!$ipn->verifyIPN()) {
				$this->log('[onDJC2PaymentResponse] failed verification');
				$app->close();
			}
		} catch (Exception $e) {
			$this->log('[onDJC2PaymentResponse] exception ' . $e->getMessage());
			$app->close();
		}

		if (floatval($app->input->getString('mc_gross')) != floatval($order->grand_total)) {
			$this->log('[onDJC2PaymentResponse] failed verification price fraud');
			$this->log('Price Paypal ' . $app->input->getString('mc_gross'));
			$this->log('Price Order ' . $order->grand_total);
			$app->close();
		}

		$status = $paypal_info['payment_status'];
		$this->log('[onDJC2PaymentResponse] payment status: ' . $status);

		if (($status == 'Completed') || ($status == 'Pending' && $testMode == 1)) {
			$this->log('[onDJC2PaymentResponse] order status: ' . $order->status);
			// confirm the order unless it has already been rejected or confirmed
			if ($order->status == 'A' || $order->status == 'N') {
				$this->log('[onDJC2PaymentResponse] payment status changed');
				$model->changeStatus($order, 'P', true, true, Text::_('PLG_DJCATALOG2PAYMENT_PAYPAL_PAYMENT_COMPLETED'));
			}
		}
	}

	private function getOrderFreaquency($repeat)
	{
		switch ($repeat) {
			case 'weekly' :
				return 'WEEK';
			case 'monthly' :
				return 'MONTH';
			case 'yearly' :
				return 'YEAR';
		}
	}

	private function getOrderCycles($order)
	{
		$db = Factory::getDbo();
		$query = $db->getQuery(true);
		$query->select('*');
		$query->from($db->quoteName('#__djc2_orders_recurring'));
		$query->where($db->quoteName('order_id') . ' = ' . (int)$order->id);
		$query->order('start ASC');
		$db->setQuery($query);
		return $db->loadObjectList();
	}

	private function discoverOrderIdByRecurring($recurring_payment_id)
	{
		$db = Factory::getDbo();
		$query = $db->getQuery(true);
		$payment_params_regex = $db->escape('%"recurring_payment_id":"' . $recurring_payment_id . '"%');
		$query->select('id')
			->from($db->quoteName('#__djc2_orders'))
			->where($db->quoteName('payment_params') . ' LIKE ' . $db->quote($payment_params_regex));

		$db->setQuery($query);
		return $db->loadResult();
	}

	private function setOrderPaymentParams($order, $params)
	{
		$order_item = new stdClass();
		$order_item->id = $order->id;
		$order_item->payment_params = json_encode($params);
		return Factory::getDbo()->updateObject('#__djc2_orders', $order_item, 'id');
	}

	private function log($msg)
	{
		$fp = fopen(__DIR__ . '/lib/logs.txt', 'a');
		fwrite($fp, print_r($msg, true));
		fwrite($fp, "\n");
		fclose($fp);
	}
}

?>