<?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;

use Joomla\Utilities\ArrayHelper;
use Joomla\CMS\Factory;
use Joomla\CMS\Component\ComponentHelper;
use Joomla\CMS\MVC\Model\AdminModel;
use Joomla\CMS\Language\Text;

class Djcatalog2Event extends Joomla\CMS\Plugin\CMSPlugin
{

	public function __construct(&$subject, $config = array())
	{
		parent::__construct($subject, $config);

		// Since Joomla! 4
		if (method_exists($this, 'registerListeners')) {
			$this->registerListeners();
		}
	}

	public function onContentBeforeSave($context, $table, $isNew)
	{
		switch ($context) {
			case 'com_djcatalog2.item' :
			{
				return $this->onItemBeforeSave($context, $table, $isNew);
				break;
			}
		}
	}

	public function onContentAfterSave($context, $table, $isNew)
	{

		switch ($context) {
			case 'com_djcatalog2.item' :
			{
				return $this->onItemAfterSave($context, $table, $isNew);
				break;
			}
			case 'com_djcatalog2.category' :
			{
				return $this->onCategoryAfterSave($context, $table, $isNew);
				break;
			}
			case 'com_djcatalog2.producer' :
			{
				return $this->onProducerAfterSave($context, $table, $isNew);
				break;
			}
			case 'com_djcatalog2.producercategory' :
			{
				return $this->onProducerCategoryAfterSave($context, $table, $isNew);
				break;
			}
			case 'com_djcatalog2.field' :
			{
				return $this->onFieldAfterSave($context, $table, $isNew);
				break;
			}
			case 'com_djcatalog2.producerfield' :
			{
				return $this->onProducerFieldAfterSave($context, $table, $isNew);
				break;
			}
			case 'com_djcatalog2.userfield' :
			{
				return $this->onUserFieldAfterSave($context, $table, $isNew);
				break;
			}
			case 'com_djcatalog2.payment' :
			{
				return $this->onPaymentAfterSave($context, $table, $isNew);
				break;
			}
			case 'com_djcatalog2.delivery' :
			{
				return $this->onDeliveryAfterSave($context, $table, $isNew);
				break;
			}
			case 'com_djcatalog2.cartfield' :
			{
				return $this->onCartFieldAfterSave($context, $table, $isNew);
				break;
			}
			case 'com_djcatalog2.subscription' :
			{
				return $this->onSubscriptionAfterSave($context, $table, $isNew);
				break;
			}
			case 'com_djcatalog2.combination' :
			{
				return $this->onCombinationAfterSave($context, $table, $isNew);
				break;
			}
		}
	}

	public function onCombinationAfterSave($context, $table, $isNew)
	{
		$app = Factory::getApplication();
		$params = ComponentHelper::getParams('com_djcatalog2');
		if (!DJCatalog2ImageHelper::saveImages('combination', $table, $params, $isNew)) {
			$app->enqueueMessage(Text::_('COM_DJCATALOG2_ERROR_SAVING_IMAGES'), 'error');
		}


		// Set default values for combination
		$db = Factory::getDbo();
		$fields = $table->fields;
		$db->setQuery('SELECT * FROM #__djc2_items_combinations WHERE item_id = ' . (int)$table->item_id . ' AND id <> ' . $table->id);
		$combinations = $db->loadObjectList('id');

		foreach ($combinations as $combination) {
			$forDelete = [];
			$insert = [];

			$db->setQuery('SELECT * FROM #__djc2_items_combinations_fields WHERE combination_id = ' . (int)$combination->id);
			$combinationFields = $db->loadObjectList('field_id');
			foreach ($combinationFields as $combinationFieldId => $combinationField) {
				if (!isset($fields[$combinationFieldId])) {
					$forDelete[] = $combinationFieldId;
				}
			}

			foreach ($fields as $fieldId => $value) {
				if (!isset($combinationFields[$fieldId])) {
					$insert[$fieldId] = $value;
				}
			}

			if (count($forDelete)) {
				$db->setQuery('DELETE FROM #__djc2_items_combinations_fields WHERE combination_id =' . (int)$combination->id . ' AND field_id IN (' . implode(',', $forDelete) . ')');
				$db->execute();
			}

			if (count($insert)) {

				$columns = array('combination_id', 'field_id', 'value');

				foreach ($insert as $fieldId => $value) {
					$query = $db->getQuery(true);
					$values = array($combination->id, $fieldId, $value);
					$query
						->insert($db->quoteName('#__djc2_items_combinations_fields'))
						->columns($db->quoteName($columns))
						->values(implode(',', $values));

					$db->setQuery($query);
					$db->execute();
				}
			}


		}


		return true;

	}

	public function onContentAfterDelete($context, $table)
	{
		switch ($context) {
			case 'com_djcatalog2.item' :
			{
				return $this->onItemAfterDelete($context, $table);
				break;
			}
			case 'com_djcatalog2.category' :
			{
				return $this->onCategoryAfterDelete($context, $table);
				break;
			}
			case 'com_djcatalog2.producer' :
			{
				return $this->onProducerAfterDelete($context, $table);
				break;
			}
			case 'com_djcatalog2.producercategory' :
			{
				return $this->onProducerCategoryAfterDelete($context, $table);
				break;
			}
			case 'com_djcatalog2.field' :
			{
				return $this->onFieldAfterDelete($context, $table);
				break;
			}
			case 'com_djcatalog2.producerfield' :
			{
				return $this->onProducerFieldAfterDelete($context, $table);
				break;
			}
			case 'com_djcatalog2.userfield' :
			{
				return $this->onUserFieldAfterDelete($context, $table);
				break;
			}
			case 'com_djcatalog2.payment' :
			{
				return $this->onPaymentAfterDelete($context, $table);
				break;
			}
			case 'com_djcatalog2.delivery' :
			{
				return $this->onDeliveryAfterDelete($context, $table);
				break;
			}
			case 'com_djcatalog2.cartfield' :
			{
				return $this->onCartFieldAfterDelete($context, $table);
				break;
			}
			case 'com_djcatalog2.subscription' :
			{
				return $this->onSubscriptionAfterDelete($context, $table);
				break;
			}
		}
	}

	public function onItemBeforeSave($context, $table, $isNew)
	{
		$app = Factory::getApplication();

		if ($app->input->getCmd('task') == 'import') {
			return true;
		}

		$model = AdminModel::getInstance('Item', 'Djcatalog2Model', array());
		if (!$isNew) {
			$attribs = $app->input->get('attribute', array(), 'array');
			if (!$model->validateAttributes($attribs, $table)) {
				$errors = $model->getErrors();
				foreach ($errors as $error) {
					$app->enqueueMessage($error, 'error');
				}
				$table->setError(Text::_('JGLOBAL_VALIDATION_FORM_FAILED'));
				return false;
			}
		}

		$params = ComponentHelper::getParams('com_djcatalog2');

		if (!$isNew && $params->get('stock_notifications', false)) {
			$item = $model->getItem($table->id);
			if (!empty($item)) {
				$stockBefore = ['onstock' => $item->onstock, 'stock' => $item->stock, 'combinations' => []];
				if (!empty($item->combinations)) {
					foreach ($item->combinations as $combination) {
						if ($combination->stock > 0.0000) continue;
						$stockBefore['combinations'][$combination->id] = ['stock' => $combination->stock];
					}
				}

				if (count($stockBefore['combinations']) || $stockBefore['stock'] == 0.0000 || $stockBefore['onstock'] == 0) {
					$app->setUserState('com_djcatalog2.item.stock_before.' . $item->id, $stockBefore);
				}
			}
		}
	}

	public function onItemAfterSave($context, $table, $isNew)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		$data = $app->input->get('jform', array(), 'array');

		$task = $app->input->getCmd('task');

		// saving additional categories
		$db = Factory::getDbo();

		if ($task == 'import') {
			if ($table->cat_id > 0) {
				$db->setQuery('DELETE FROM #__djc2_items_categories WHERE category_id=\'' . $table->cat_id . '\' AND item_id=\'' . $table->id . '\'');
				if ($db->execute()) {
					$db->setQuery('INSERT INTO #__djc2_items_categories (item_id, category_id) VALUES (\'' . $table->id . '\', \'' . $table->cat_id . '\')');
					$db->execute();
				}
			}
		} else {
			$db->setQuery('DELETE FROM #__djc2_items_categories WHERE item_id=\'' . $table->id . '\'');
			if ($db->execute()) {
				if (!isset($data['categories'])) {
					$data['categories'] = array();
				}
				$data['categories'][] = $table->cat_id;
				if (!empty($data['categories'])) {
					ArrayHelper::toInteger($data['categories']);
					$data['categories'] = array_unique($data['categories']);
					foreach ($data['categories'] as $cat_id) {
						$db->setQuery('INSERT INTO #__djc2_items_categories (item_id, category_id) VALUES (\'' . $table->id . '\', \'' . $cat_id . '\')');
						$db->execute();
					}
				}
			}
		}
		if (!isset($data['group_id']) || !is_array($data['group_id'])) {
			$data['group_id'] = array();
		}
		$data['group_id'][] = 0;
		ArrayHelper::toInteger($data['group_id']);
		$data['group_id'] = array_unique($data['group_id']);

		if($data['group_id'][0] === ""){
			unset($data['group_id'][0]);
		}

		if ($task == 'import') {
			$db->setQuery('DELETE FROM #__djc2_items_groups WHERE item_id=\'' . $table->id . '\' AND group_id IN (' . implode(',', $data['group_id']) . ')');
		} else {
			$db->setQuery('DELETE FROM #__djc2_items_groups WHERE item_id=\'' . $table->id . '\'');
		}
		if ($db->execute()) {
			foreach ($data['group_id'] as $group_id) {
				$db->setQuery('INSERT INTO #__djc2_items_groups (item_id, group_id) VALUES (\'' . $table->id . '\', \'' . $group_id . '\')');
				$db->execute();
			}
		}

		// saving images
		if (!DJCatalog2ImageHelper::saveImages('item', $table, $params, $isNew)) {
			$app->enqueueMessage(Text::_('COM_DJCATALOG2_ERROR_SAVING_IMAGES'), 'error');
		}

		// saving attachments
		if (!DJCatalog2FileHelper::saveFiles('item', $table, $params, $isNew)) {
			$app->enqueueMessage(Text::_('COM_DJCATALOG2_ERROR_SAVING_FILES'), 'error');
		}

		// saving videos
		if (!DJCatalog2VideoHelper::saveFiles('item', $table, $params, $isNew)) {
			$app->enqueueMessage(Text::_('COM_DJCATALOG2_ERROR_SAVING_VIDEOS'), 'error');
		}

		$model = AdminModel::getInstance('Item', 'Djcatalog2Model', array());

		// saving additional attributes
		$attribs = $app->input->get('attribute', array(), 'array');




		/*
		// saving combinations
		$combinations = $app->input->get('combinations', array(), 'array');
		$hasCombinations = $app->input->getInt('hasCombinations');
		if ($hasCombinations == 1) {
			if (!$model->saveCombinations($combinations, $table, $isNew)) {
				$app->enqueueMessage($model->getError(), 'error');
			}
		}*/


		$customisations = $app->input->get('customisations', array(), 'array');
		$hasCustomisations = $app->input->getInt('hasCustomisations');
		if ($hasCustomisations == 1) {
			if (!$model->saveCustomisations($customisations, $table, $isNew)) {
				$app->enqueueMessage($model->getError(), 'error');
			}
		}

		$customisationsGroups = $app->input->get('customgroup', array(), 'array');
		if(count($customisationsGroups)) {
			if (!$model->saveCustomisationsGroups($customisationsGroups, $table, $isNew)) {
				$app->enqueueMessage($model->getError(), 'error');
			}
		}

		if (!$model->saveAttributes($attribs, $table)) {
			$app->enqueueMessage($model->getError(), 'error');
		}


		if (isset($data['price_tiers'])) {
			$query = $db->getQuery(true);
			$query->delete('#__djc2_items_price_tiers')->where('item_id=' . $table->id);
			$db->setQuery($query);
			$db->execute();

			if (is_array($data['price_tiers']) && count($data['price_tiers'])) {
				$quantities = array();
				foreach ($data['price_tiers'] as $k => $v) {
					$quantity = (int)$v['quantity'];
					$price = floatval($v['price']);

					if (!$quantity || $price <= 0.00) {
						continue;
					}

					if (array_key_exists($quantity, $quantities)) {
						continue;
					}

					$quantities[$quantity] = $price;
				}

				if (count($quantities)) {
					$query = $db->getQuery(true);
					$query->insert('#__djc2_items_price_tiers');
					$query->columns(array('item_id', 'quantity', 'price'));
					foreach ($quantities as $quantity => $price) {
						$query->values($table->id . ',' . $quantity . ',' . $price);
					}
					$db->setQuery($query);
					$db->execute();
				}
			}
		}

		if ($task != 'import') {
			$query = $db->getQuery(true);
			$query->delete('#__djc2_labels_items')->where('item_id=' . $table->id);
			$db->setQuery($query);
			$db->execute();

			if (isset($data['labels'])) {
				ArrayHelper::toInteger($data['labels']);

				if (is_array($data['labels']) && count($data['labels'])) {
					$query = $db->getQuery(true);
					$query->insert('#__djc2_labels_items');
					$query->columns(array('item_id', 'label_id'));
					foreach ($data['labels'] as $label_id) {
						$query->values($table->id . ',' . $label_id);
					}
					$db->setQuery($query);
					$db->execute();
				}
			}
		}

		if (!$isNew && $params->get('stock_notifications', false)) {
			$beforeState = $app->getUserState('com_djcatalog2.item.stock_before.' . $table->id);
			if (!empty($beforeState) && is_array($beforeState)) {
				$onStock = (bool)($table->onstock >= 2 || $table->onstock == 1 && $table->stock > 0.0000);
				$outStockBefore = (bool)($beforeState['onstock'] == 0 || ($beforeState['onstock'] == 1 && $beforeState['stock'] == 0.0000));

				$sentMain = $sentCombo = 0;
				if ($onStock && $outStockBefore) {
					$sentMain = $model->notifyStockUpdates($table->id, 'item', $table);
				}

				foreach ($beforeState['combinations'] as $combination_id => $combination_stock) {

					$id_idx = false;
					foreach ($combinations['id'] as $pos => $value) {
						if ($value == $combination_id) {
							$id_idx = $pos;
						}
					}
					if ($id_idx === false) continue;

					if (isset($combinations['stock']) && isset($combinations['stock'][$id_idx])) {
						if ($combinations['stock'][$id_idx] > 0.0000 && $combination_stock['stock'] == 0.0000) {
							$sentCombo = $model->notifyStockUpdates($combination_id, 'combination', $table);
						}
					}
				}

				if ($sentMain || $sentCombo) {
					$link = Route::_('index.php?option=com_djcatalog2&view=messages&filter_search=' . $table->name);
					$app->enqueueMessage(Text::sprintf('COM_DJCATALOG2_ON_STOCK_NOTIFICATIONS_HAVE_BEEN_SENT', $sentMain + $sentCombo, $link));
				}
			}
		}


		if ($task == 'save2copy' && $app->input->get('save2copy_id')) {
			$oldId = $app->input->get('save2copy_id');
			// Set default values for combination
			$db = Factory::getDbo();
			$fields = $table->fields;
			$db->setQuery('SELECT * FROM #__djc2_items_combinations WHERE item_id = ' . (int)$oldId);
			$combinations = $db->loadObjectList('id');
			$columns = array('combination_id', 'field_id', 'value');

			foreach ($combinations as $combination) {
				$forDelete = [];
				$insert = [];

				$db->setQuery('SELECT * FROM #__djc2_items_combinations_fields WHERE combination_id = ' . (int)$combination->id);
				$combinationFields = $db->loadObjectList('field_id');
				$combination->item_id = $table->id;
				$combination->id = 0;
				$result = Factory::getDbo()->insertObject('#__djc2_items_combinations', $combination);
				$new_row_id = $db->insertid();



				foreach ($combinationFields as $combinationFieldId => $combinationField) {
					$query = $db->getQuery(true);
					$values = array($new_row_id, $combinationFieldId, $combinationField->value);
					$query
						->insert($db->quoteName('#__djc2_items_combinations_fields'))
						->columns($db->quoteName($columns))
						->values(implode(',', $values));

					$db->setQuery($query);
					$db->execute();
				}


			}

		}

		$app->setUserState('com_djcatalog2.item.stock_before.' . $table->id, null);
	}

	public function onItemAfterDelete($context, $table)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();

		$db = Factory::getDbo();
		$db->setQuery('DELETE FROM #__djc2_items_categories WHERE item_id=\'' . $table->id . '\'');
		$db->execute();

		$db = Factory::getDbo();
		$db->setQuery('DELETE FROM #__djc2_items_groups WHERE item_id=\'' . $table->id . '\'');
		$db->execute();

		$db->setQuery('DELETE FROM #__djc2_items_related WHERE item_id=\'' . $table->id . '\' OR related_item=\'' . $table->id . '\'');
		$db->execute();

		$db->setQuery('DELETE FROM #__djc2_items_extra_fields_values_text WHERE item_id=\'' . $table->id . '\'');
		$db->execute();

		$db->setQuery('DELETE FROM #__djc2_items_extra_fields_values_int WHERE item_id=\'' . $table->id . '\'');
		$db->execute();

		$db->setQuery('DELETE FROM #__djc2_items_extra_fields_values_date WHERE item_id=\'' . $table->id . '\'');
		$db->execute();

		if (!DJCatalog2ImageHelper::deleteImages('item', $table->id)) {
			$app->enqueueMessage(Text::_('COM_DJCATALOG2_ERROR_DELETING_IMAGES'), 'error');
		}
		if (!DJCatalog2FileHelper::deleteFiles('item', $table->id)) {
			$app->enqueueMessage(Text::_('COM_DJCATALOG2_ERROR_DELETING_FILE'), 'error');
		}
		if (!DJCatalog2VideoHelper::deleteFiles('item', $table->id)) {
			$app->enqueueMessage(Text::_('COM_DJCATALOG2_ERROR_DELETING_VIDEO'), 'error');
		}

		$db->setQuery('SELECT id FROM #__djc2_items_combinations WHERE item_id=\'' . $table->id . '\'');
		$combination_ids = $db->loadColumn();
		if (count($combination_ids) > 0) {
			$db->setQuery('DELETE FROM #__djc2_items_combinations WHERE item_id=\'' . $table->id . '\'');
			$db->execute();

			$db->setQuery('DELETE FROM #__djc2_items_combinations_fields WHERE combination_id IN (' . implode(',', $combination_ids) . ')');
			$db->execute();

			foreach ($combination_ids as $combinationId) {
				DJCatalog2ImageHelper::deleteImages('combination', $combinationId);
			}
		}

		$db->setQuery('DELETE FROM #__djc2_items_customisations WHERE item_id=\'' . $table->id . '\'');
		$db->execute();
	}

	public function onCategoryAfterSave($context, $table, $isNew)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		if (!DJCatalog2ImageHelper::saveImages('category', $table, $params, $isNew)) {
			$app->enqueueMessage(Text::_('COM_DJCATALOG2_ERROR_SAVING_IMAGES'), 'error');
		}
	}

	public function onCategoryAfterDelete($context, $table)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		if (!DJCatalog2ImageHelper::deleteImages('category', $table->id)) {
			$app->enqueueMessage(Text::_('COM_DJCATALOG2_ERROR_DELETING_IMAGES'), 'error');
		}
	}

	public function onProducerAfterSave($context, $table, $isNew)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();

		$model = AdminModel::getInstance('Producer', 'Djcatalog2Model', array());

		// saving additional attributes
		$attribs = $app->input->get('attribute', array(), 'array');
		if (!$model->saveAttributes($attribs, $table)) {
			$app->enqueueMessage($model->getError(), 'error');
		}

		if (!DJCatalog2ImageHelper::saveImages('producer', $table, $params, $isNew)) {
			$app->enqueueMessage(Text::_('COM_DJCATALOG2_ERROR_SAVING_IMAGES'), 'error');
		}
	}

	public function onProducerAfterDelete($context, $table)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		$db = Factory::getDbo();

		$db->setQuery('DELETE FROM #__djc2_producers_extra_fields_values_text WHERE item_id=\'' . $table->id . '\'');
		$db->execute();

		$db->setQuery('DELETE FROM #__djc2_producers_extra_fields_values_int WHERE item_id=\'' . $table->id . '\'');
		$db->execute();

		$db->setQuery('DELETE FROM #__djc2_producers_extra_fields_values_date WHERE item_id=\'' . $table->id . '\'');
		$db->execute();

		if (!DJCatalog2ImageHelper::deleteImages('producer', $table->id)) {
			$app->enqueueMessage(Text::_('COM_DJCATALOG2_ERROR_DELETING_IMAGES'), 'error');
		}
	}

	public function onProducerCategoryAfterSave($context, $table, $isNew)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		if (!DJCatalog2ImageHelper::saveImages('producercategory', $table, $params, $isNew)) {
			$app->enqueueMessage(Text::_('COM_DJCATALOG2_ERROR_SAVING_IMAGES'), 'error');
		}
	}

	public function onProducerCategoryAfterDelete($context, $table)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		if (!DJCatalog2ImageHelper::deleteImages('producercategory', $table->id)) {
			$app->enqueueMessage(Text::_('COM_DJCATALOG2_ERROR_DELETING_IMAGES'), 'error');
		}
	}

	public function onFieldAfterSave($context, $table, $isNew)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		$values = ($app->input->get('fieldtype', array(), 'array'));
		$model = AdminModel::getInstance('Field', 'Djcatalog2Model', array());
		if (!$model->saveOptions($values, $table, $isNew)) {
			$app->enqueueMessage($model->getError(), 'error');
		}
	}

	public function onFieldAfterDelete($context, $table)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		$model = AdminModel::getInstance('Field', 'Djcatalog2Model', array());
		if (!$model->deleteOptions($table)) {
			$app->enqueueMessage($model->getError(), 'error');
		}
	}


	public function onPaymentAfterSave($context, $table, $isNew)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		$db = Factory::getDbo();
		$data = $app->input->get('jform', array(), 'array');

		$task = $app->input->getCmd('task');

		$db->setQuery('DELETE FROM #__djc2_deliveries_payments WHERE payment_id=\'' . $table->id . '\'');
		if ($db->execute()) {
			if (!empty($data['deliveries'])) {
				ArrayHelper::toInteger($data['deliveries']);
				$data['deliveries'] = array_unique($data['deliveries']);
				foreach ($data['deliveries'] as $delivery_id) {
					$db->setQuery('INSERT INTO #__djc2_deliveries_payments (payment_id, delivery_id) VALUES (\'' . $table->id . '\', \'' . $delivery_id . '\')');
					$db->execute();
				}
			}
		}

		$db->setQuery('DELETE FROM #__djc2_payments_currencies WHERE payment_id=\'' . $table->id . '\'');
		if ($db->execute()) {
			if (!empty($data['currencies'])) {
				ArrayHelper::toInteger($data['currencies']);
				$data['currencies'] = array_unique($data['currencies']);
				foreach ($data['currencies'] as $currency_id) {
					$db->setQuery('INSERT INTO #__djc2_payments_currencies (payment_id, currency_id) VALUES (\'' . $table->id . '\', \'' . $currency_id . '\')');
					$db->execute();
				}
			}
		}
	}

	public function onPaymentAfterDelete($context, $table)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();

		$db = Factory::getDbo();
		$db->setQuery('DELETE FROM #__djc2_deliveries_payments WHERE payment_id=\'' . $table->id . '\'');
		$db->execute();

		$db = Factory::getDbo();
		$db->setQuery('DELETE FROM #__djc2_payments_currencies WHERE payment_id=\'' . $table->id . '\'');
		$db->execute();
	}

	public function onDeliveryAfterSave($context, $table, $isNew)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		$db = Factory::getDbo();
		$data = $app->input->get('jform', array(), 'array');

		$task = $app->input->getCmd('task');

		$db->setQuery('DELETE FROM #__djc2_deliveries_gauges WHERE delivery_id=\'' . $table->id . '\'');
		if ($db->execute()) {
			if (!empty($data['gauges'])) {
				ArrayHelper::toInteger($data['gauges']);
				$data['gauges'] = array_unique($data['gauges']);
				foreach ($data['gauges'] as $gauges_id) {
					$db->setQuery('INSERT INTO #__djc2_deliveries_gauges (delivery_id, gauge_id) VALUES (\'' . $table->id . '\', \'' . $gauges_id . '\')');
					$db->execute();
				}
			}
		}
	}

	public function onDeliveryAfterDelete($context, $table)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();

		$db = Factory::getDbo();
		$db->setQuery('DELETE FROM #__djc2_deliveries_gauges WHERE delivery_id=\'' . $table->id . '\'');
		$db->execute();
	}

	public function onCartFieldAfterSave($context, $table, $isNew)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		$values = ($app->input->get('fieldtype', array(), 'array'));
		$model = AdminModel::getInstance('CartField', 'Djcatalog2Model', array());
		if (!$model->saveOptions($values, $table, $isNew)) {
			$app->enqueueMessage($model->getError(), 'error');
		}
	}

	public function onCartFieldAfterDelete($context, $table)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		$model = AdminModel::getInstance('CartField', 'Djcatalog2Model', array());
		if (!$model->deleteOptions($table)) {
			$app->enqueueMessage($model->getError(), 'error');
		}
	}

	public function onProducerFieldAfterSave($context, $table, $isNew)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		$values = ($app->input->get('fieldtype', array(), 'array'));
		$model = AdminModel::getInstance('Producerfield', 'Djcatalog2Model', array());
		if (!$model->saveOptions($values, $table, $isNew)) {
			$app->enqueueMessage($model->getError(), 'error');
		}
	}

	public function onProducerFieldAfterDelete($context, $table)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		$model = AdminModel::getInstance('Producerfield', 'Djcatalog2Model', array());
		if (!$model->deleteOptions($table)) {
			$app->enqueueMessage($model->getError(), 'error');
		}
	}

	public function onUserFieldAfterSave($context, $table, $isNew)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		$values = ($app->input->get('fieldtype', array(), 'array'));
		$model = AdminModel::getInstance('Userfield', 'Djcatalog2Model', array());
		if (!$model->saveOptions($values, $table, $isNew)) {
			$app->enqueueMessage($model->getError(), 'error');
		}
	}

	public function onUserFieldAfterDelete($context, $table)
	{
		$params = ComponentHelper::getParams('com_djcatalog2');
		$app = Factory::getApplication();
		$model = AdminModel::getInstance('Userfield', 'Djcatalog2Model', array());
		if (!$model->deleteOptions($table)) {
			$app->enqueueMessage($model->getError(), 'error');
		}
	}

	public function onSubscriptionAfterSave($context, $table, $isNew)
	{
		$app = Factory::getApplication();
		$db = Factory::getDbo();
		$date = Factory::getDate();

		// get current user groups
		$db->setQuery('SELECT group_id FROM #__user_usergroup_map WHERE user_id=' . $table->user_id);
		$groups = $db->loadColumn();

		$granted_groups = [];
		if (is_array($table->granted_usergroups)) {
			$granted_groups = $table->granted_usergroups;
		} else if ($table->granted_usergroups && $table->granted_usergroups != '[]') {
			$granted_groups = json_decode((string)$table->granted_usergroups, true);
		}
		if (empty($granted_groups)) return;
		$granted_groups = array_unique($granted_groups);

		// update granted usergroup
		// check status and expire date
		if ($table->status == 1 && intval($table->expire_date) && Factory::getDate($table->expire_date)->toUnix() > $date->toUnix()) {
			// grant usergroup if user is not already assigned to this group
			foreach ($granted_groups as $granted_group) {
				if (!in_array($granted_group, $groups)) {
					$db->setQuery('INSERT INTO #__user_usergroup_map (user_id, group_id) VALUES (' . $table->user_id . ',' . $granted_group . ')');
					if (!$db->execute()) {
						$app->enqueueMessage($db->getErrorMsg(), 'error');
					}
				}
			}
		} else {
			// remove user from this usergroup if there is no more active subscriptions related with this group
			foreach ($granted_groups as $granted_group) {
				if (in_array($table->granted_usergroup, $groups)) {
					$db->setQuery('SELECT count(id) FROM #__djc2_subscriptions WHERE id!=' . $table->id . ' AND status=1 AND user_id=' . $table->user_id . ' AND granted_usergroups LIKE ' . $db->quote('%["' . $granted_group . '"]%') . ' AND expire_date > ' . $db->quote($date->toSql()));
					$count = $db->loadResult();
					if (!$count) { // no active subscriptions
						// remove user-group assigments
						$db->setQuery('DELETE from #__user_usergroup_map WHERE user_id=' . $table->user_id . ' AND group_id=' . $granted_group);
						if (!$db->execute()) {
							$app->enqueueMessage($db->getErrorMsg(), 'error');
							die($db->getErrorMsg());
						}
					}
				}
			}
		}
	}

	public function onSubscriptionAfterDelete($context, $table)
	{

		$app = Factory::getApplication();
		$db = Factory::getDbo();
		$date = Factory::getDate();

		// get current user groups
		$db->setQuery('SELECT group_id FROM #__user_usergroup_map WHERE user_id=' . $table->user_id);
		$groups = $db->loadColumn();

		$granted_groups = [];
		if (is_array($table->granted_usergroups)) {
			$granted_groups = $table->granted_usergroups;
		} else if ($table->granted_usergroups && $table->granted_usergroups != '[]') {
			$granted_groups = json_decode((string)$table->granted_usergroups, true);
		}
		if (empty($granted_groups)) return;
		$granted_groups = array_unique($granted_groups);

		// update granted usergroup
		foreach ($granted_groups as $granted_group) {
			if (in_array($granted_group, $groups)) {
				// remove user from this usergroup if there is no more active subscriptions related with this group
				$db->setQuery('SELECT count(id) FROM #__djc2_subscriptions WHERE id!=' . $table->id . ' AND status=1 AND user_id=' . $table->user_id . ' AND granted_usergroups LIKE ' . $db->quote('%["' . $granted_group . '"]%') . ' AND expire_date > ' . $db->quote($date->toSql()));
				$count = $db->loadResult();
				if (!$count) { // no active subscriptions
					// remove user-group assigments
					$db->setQuery('DELETE from #__user_usergroup_map WHERE user_id=' . $table->user_id . ' AND group_id=' . $granted_group);
					if (!$db->execute()) {
						$app->enqueueMessage($db->getErrorMsg(), 'error');
						die($db->getErrorMsg());
					}
				}
			}
		}
	}
}