Подписка на комментарии в JoomShopping? - JoomShopping

function reviewsave()

mail(email@email.ru, "тема", "текст");

    function publish(){
        $this->_publish(1);
        $this->setRedirect("index.php?option=com_jshopping&controller=reviews");
    }

    function unpublish(){
        $this->_publish(0);
        $this->setRedirect("index.php?option=com_jshopping&controller=reviews");
    } 

    function _publish($flag) {
        $jshopConfig = JSFactory::getConfig();
        $db = JFactory::getDBO();
        $cid = JRequest::getVar('cid');
        JPluginHelper::importPlugin('jshoppingadmin');
        $dispatcher = JDispatcher::getInstance();
        $dispatcher->trigger( 'onBeforePublishReview', array(&$cid, &$flag) );
        foreach ($cid as $key => $value) {
            $query = "UPDATE `#__jshopping_products_reviews` SET `publish` = '".$db->escape($flag)."' WHERE `review_id` = '".$db->escape($value)."'";
            $db->setQuery($query);
            $db->query();
            $review = JTable::getInstance('review', 'jshop');
            $review->load($value);
            $product = JTable::getInstance('product', 'jshop');
            $product->load($review->product_id);
            $product->loadAverageRating();
            $product->loadReviewsCount();
            $product->loadQuestCount();
            $product->store();
            #unset($product);
            unset($review);
        }
        
        $dispatcher->trigger('onAfterPublishReview', array(&$cid, &$flag) );
    }

	$query = "SELECT * FROM teyzk_jshopping_products_reviews WHERE subscribe=product_id"; // сравнение двух полей
	$db->setQuery($query);
	$list = $db->loadObjectList();
	foreach ($list as $item) {
		mail($item->user_email, "Тема письма", "текст");
	}

			//получение id товара по номеру отзыва
			$query="SELECT product_id FROM teyzk_jshopping_products_reviews WHERE review_id='".$db->escape($value)."'";
			$db->setQuery($query);
			$prod_id=$db->loadResult();
			
			//получение всех подписчиков полученного id товара
			$query = "SELECT * FROM teyzk_jshopping_products_reviews WHERE subscribe=publish_type and product_id='$prod_id'";
			$db->setQuery($query);
			$list = $db->loadObjectList();
			
			// отправка писем всем подписчикам этого товара
			foreach ($list as $item) {
			mail($item->user_email, "тема", "сообщение");
			}

<?php
   $prod_id = $_POST['product_id'];
   $link = mysql_connect('localhost', 'root', '') or die('Ошибка: Не удалось подключится к серверу БД.'.mysql_error($link));
   mysql_select_db('im', $link) or die('Не удалось подключиться к базе данных. '.mysql_error($link));
   $sql = "UPDATE teyzk_jshopping_products_reviews SET subscribe=0 WHERE subscribe='$prod_id;'";
   if(!mysql_query($sql))
   {echo '<p>Не вышло</p>';} 
   else {echo '<p>Вышло</p>';}
?>

echo SEFLink('index.php?option=com_jshopping&controller=mycontroller&task=unsubscribe',0,1)

defined..
jimport..
class JshoppingControllerMycomponent extends JControllerLegacy{
	function unsubscribe(){
		echo "Проверка<br>"
		echo SEFLink('index.php?option=com_jshopping&controller=mycomponent&task=unsubscribe',0,1); // просто проверка ссылки - выводится
		$this->setRedirect( SEFLink('index.php?option=com_jshopping&controller=mycomponent&task=unsubscribe',0,1));
	}
}

defined( '_JEXEC' ) or die( 'Restricted access' );
jimport('joomla.application.component.controller');
class JshoppingControllerSubs extends JControllerLegacy{

	function unsubscribe(){
	  echo "<form action=".SEFLink('index.php?option=com_jshopping&controller=subs&task=ok',0,1)." method='POST'>
				<input type='hidden' name='user_email' value=".$_GET['usem'].">
				<input type='hidden' name='product_id' value=".$_GET['prid'].">
				<input type='submit' value='отписаться'>
			</form>";
	}
	
	function ok(){
		$db=&JFactory::getDBO();
		$query="UPDATE teyzk_jshopping_products_reviews SET subscribe=0 WHERE subscribe='$_POST[product_id]' and user_email='$_POST[user_email]'";
                $db->setQuery($query);
                $db->query();
		echo "Вы успешно отписались!";
	}
}