Следить за товаром - уведомить меня - [VM1] Управление товарами, атрибутами, типами, ценами

if( $product_id ) {
	// SHOW THE WAITING LIST!
	$dbw = new ps_DB;
	$dbw->query( 'SELECT name, username, user_id, notify_email, notified, notify_date FROM `#__{vm}_waiting_list`
					LEFT JOIN `#__users` ON `user_id` = `id`
					WHERE `product_id`=' . $product_id );
	if( $dbw->num_rows() > 0 ) {
		$tabs->startTab( $VM_LANG->_('PRODUCT_WAITING_LIST_TAB'), 'waiting-list-tab' );

		echo '<table class="adminform"><tr><td><h2>' . $VM_LANG->_('PRODUCT_WAITING_LIST_USERLIST'). ':</h2></td></tr>';
		echo '<tr><td><input type="hidden" value="'.$db->f('product_in_stock').'" name="product_in_stock_old" />';
		echo '<input type="checkbox" value="1" checked="checked" id="notify_users" name="notify_users" /> <label for="notify_users">' . $VM_LANG->_('PRODUCT_WAITING_LIST_NOTIFYUSERS'). '</label><br /><br /></td></tr>';
		echo '<tr><td>';
		while( $dbw->next_record() ) {
			if ($dbw->f("notified")==1) {
				$waiting_notified = ' - <strong style="font-weight:bold">' . $VM_LANG->_('PRODUCT_WAITING_LIST_NOTIFIED'). ' ' . $dbw->f("notify_date"). '</strong>';
			} else {
				$waiting_notified = '';
			}
			if ($dbw->f("user_id")==0) {
				$waitinglist[] = '<a href="mailto:' . $dbw->f('notify_email'). '">' . $dbw->f('notify_email'). '</a>' . $waiting_notified;
			} else {
				$waitinglist[] = $dbw->f('name'). ' ('.$dbw->f('username'). ' - ' . '<a href="mailto:' . $dbw->f('notify_email'). '">' . $dbw->f('notify_email'). '</a>' . ')' . $waiting_notified;
			}
		}
		echo vmCommonHTML::getList( $waitinglist );
		echo '</td></tr></table>';
		$tabs->endTab();
	}
}

function add(&$d) {
		global $auth;
		$db = new ps_DB;

		if (!$this->validate_add($d)) {
			return False;
		}
		$q = "INSERT INTO #__{vm}_waiting_list (product_id, user_id, notify_email)";
		$q .= " VALUES ('";
		$q .= $d["product_id"] . "','";
		$q .= $auth['user_id'] . "','";
		$q .= $d["notify_email"] . "')";
		$db->query($q);
		$db->next_record();
		return True;

	}

			if( vmIsXHR() ) {
				$GLOBALS['vm_mainframe']->scriptRedirect( $sess->url( 'index.php?page=shop.waiting_list&product_id='.$product_id, true, false ) );
			} else {
				vmRedirect( $sess->url( 'index.php?page=shop.waiting_list&product_id='.$product_id, true, false ) );
			}
		}

			if( vmIsXHR() ) {
				$_SESSION['kolichestvo'] = $request['quantity'];
				$GLOBALS['vm_mainframe']->scriptRedirect( $sess->url( 'index.php?page=shop.waiting_list&product_id='.$product_id, true, false ) );
			} else {
				$_SESSION['kolichestvo'] = $request['quantity'];
				vmRedirect( $sess->url( 'index.php?page=shop.waiting_list&product_id='.$product_id, true, false ) );
			}
		}

	function add(&$d) {
		global $auth;
		$db = new ps_DB;

		$q = "INSERT INTO #__{vm}_waiting_list (product_id, user_id, notify_email, pcs)";
		$q .= " VALUES ('";
		$q .= $d["product_id"] . "','";
		$q .= $auth['user_id'] . "','";
		$q .= $d["notify_email"] . "')";
		$db->query($q);
		$db->next_record();
		return True;

	}

	function add(&$d) {
		global $auth;
		$db = new ps_DB;

		$q = "INSERT INTO #__{vm}_waiting_list (product_id, user_id, notify_email, pcs)";
		$q .= " VALUES ('";
		$q .= $d["product_id"] . "','";
		$q .= $auth['user_id'] . "','";
		$q .= $d["notify_email"] . "','";
		$q .= $_SESSION['kolichestvo'] . "')";
		$db->query($q);
		$db->next_record();
		unset ($_SESSION['kolichestvo']);
		return True;

	}

<?php
$date = date("d.m.Y");
$file_name = '(физический путь на сервере к Вашему сайту)/flag/waiting-'.$date; // Флаг отработки скрипта. Как работает - дальше. 
if (@fopen($file_name, "r"))
{

// Если флаг есть - скрипт ничего не выполняет. Имя флага включает в себя текущую дату.
}
 else 
{


touch($file_name); // если флага нету - создаём. Это означает, что сегодня скрипт уже отработал. Больше он запускаться не будет.


// Модуль подключения базы данных
if (!mysql_connect('(имя сервера)', '(имя пользователя)', '(пароль)')) 
{
echo "ERROR ".mysql_errno()." ".mysql_error()."\n";
exit;
}
mysql_select_db(имя базы данных);
// конец модуля подключения базы данных
$waiting_list = mysql_query("SELECT * FROM jos_vm_waiting_list WHERE notified='0'"); // выбираем все записи с невыполненным статусом
if (mysql_num_rows($waiting_list)>0)
{
for ($c=0; $c<mysql_num_rows($waiting_list); $c++)
{
$list_array=mysql_fetch_array($waiting_list);
$tovar = mysql_query("SELECT * FROM jos_vm_product WHERE product_id='$list_array[product_id]'");

if (mysql_num_rows($tovar)>0)
{
for ($k=0; $k<mysql_num_rows($tovar); $k++)
{
$tovar_array=mysql_fetch_array($tovar);
if ($tovar_array[product_in_stock]>=$list_array[pcs]) // если наличие на складе больше или равно чем заказанное пользователем
{
mysql_query("UPDATE jos_vm_waiting_list SET notified='1' WHERE waiting_list_id='$list_array[waiting_list_id]'"); // ставим статус Выполнено (тоесть // пользователь уведомлён)

$to  = $list_array[notify_email] ; // формируем почтовое уведомление

$subject = "Тема письма";
$subject = '=?koi8-r?B?'.base64_encode(convert_cyr_string($subject, "w","k")).'?='; // преобразование в людскую кодировку для почтовиков
// формируем текст письма. на свой вкус. тут просто пример.
$message = ' 
<html>
    <head>
        <title>Интересующие Вас позиции</title>
    </head>
    <body>
        <p> '.$tovar_array[product_name].' есть на складе в количестве '.$tovar_array[product_in_stock].' шт.</p>
		<p>Если Ваша заявка на этот товар ещё актуальна - посетите наш сайт или свяжитесь с менеджерами нашего магазина.</p>		
    </body>
</html>';

$headers  = "Content-type: text/html; charset=windows-1251 \r\n";
$headers .= "From: Магазин <info@магазин.com.ua>\r\n";
$headers .= "Bcc: info@магазин.com.ua\r\n";

mail($to, $subject, $message, $headers); 

}
}
}
}
}
}
?>

require ("wait.php");