Почему более одной записи из скрипта в базу?

Question

[dimone73]

PHP 5.0
Пытаюсь исправить ошибку в скрипте, который отправляет (пусть и с небольшим опозданием) запись в БД Postgresql запросом "INSERT INTO events....." и далее журнал.
Почему то вместо одной записи отправляется сразу 4 записи в одну и ту же секунду о том, что 'выход по таймауту'.
Иногда почему то 3 записи.
Кусок кода

$count=$db->query("select count(id) as c from out_line_settings")->fetch(PDO::FETCH_OBJ)->c;
if($count!=0){
	$sql = "SELECT out_line_settings.id, out_line_settings.hrn, sip_conf.host, sip_conf.port, sip_conf.name,sip_conf.username FROM out_line_settings LEFT JOIN sip_conf ON sip_conf.outline_id=out_line_settings.id WHERE out_line_settings.type = 'SIP'"; // Вывод внешних линий
	$result = $db->query($sql);
	while ($arr = $result->fetch(PDO::FETCH_OBJ)) {
    	$status = 0;
    	if (exec('/usr/sbin/asterisk -rx "sip show registry" | grep "' . $arr->host . ':' . $arr->port . '" | grep "' . $arr->username . '" | grep "Registered"') != "")
        	$status = $status + 1;
    	if (exec('/usr/sbin/asterisk -rx "sip show peers" | grep "' . $arr->name . '/' . $arr->username . '"') != "")
        	$status = $status + 1;
    		$db->query("UPDATE out_line_settings SET line_status=" . $status . " WHERE id=" . $arr->id);
	}
}
$timeout=$db->query("SELECT timeout from general_config")->fetch(PDO::FETCH_OBJ)->timeout;
$timezone=$db->query("SELECT curtz from general_config")->fetch(PDO::FETCH_OBJ)->curtz;
date_default_timezone_set($timezone);


$sql="select login,id,ip from web_users where (now() - online) > interval '".($timeout*60)."' AND session_id!=''";
$res=$db->query($sql);
while($arru=$res->fetch(PDO::FETCH_OBJ)){
	$db->query("INSERT INTO events (event_date,event_time,ip_client,user_id,user_login,event_type,event_place,event_note,event_status,title) VALUES
                ('" . date("Y-m-d") . "','" . date("H:i:s") . "',''," .$arru->id . ",'" .  $arru->login . "',1,'','<tr><td>выход по таймауту</td></tr>',1,'')");
sleep(2); //вот сюда пытался добавить задержку, все равно не помогает
}

$db->query("UPDATE web_users SET online='1970-01-01 00:00:00.000000', session_id='' WHERE (now() - online) > interval '".($timeout*60)."'");

Смущает цикл while. Что в нем можно подправить?
$arru в нем три атрибута, одномерный массив.
$arru->id целое, обычно 1
$arru->login строковое, обычно логин пользователя
$arru->ip строковое, обычно пустое
В php на начальном этапе, не могу пока понять.
Пока выяснил, что переменная $count выше равна 4, но она же не должна влиять на цикл, что внизу.

Comments

[Andrew Boeing]

Цикл while в вашем коде выглядит корректным и не является причиной, по которой записывается несколько записей с одним временем. Ошибка скорее всего связана с тем, что цикл выполняется более одного раза в течение одной секунды, поэтому в таблицу events записывается несколько записей с одинаковым временем.

Один из способов исправления этой ошибки заключается в использовании уникальных значений времени для каждой записи. Вы можете добавить миллисекунды к текущему времени, чтобы получить уникальное время для каждой записи. Для этого вы можете использовать функцию microtime(true), которая возвращает текущее время в секундах с миллисекундной точностью.

Пример исправленного кода:

$sql="select login,id,ip from web_users where (now() - online) > interval '".($timeout*60)."' AND session_id!=''";
$res=$db->query($sql);
while($arru=$res->fetch(PDO::FETCH_OBJ)){
  $now = microtime(true);
  $db->query("INSERT INTO events (event_date,event_time,ip_client,user_id,user_login,event_type,event_place,event_note,event_status,title) VALUES
                ('" . date("Y-m-d", $now) . "','" . date("H:i:s.", $now) . floor(($now-floor($now))*1000) . "',''," .$arru->id . ",'" .  $arru->login . "',1,'','<tr><td>выход по таймауту</td></tr>',1,'')");
}

$db->query("UPDATE web_users SET online='1970-01-01 00:00:00.000000', session_id='' WHERE (now() - online) > interval '".($timeout*60)."'");

В этом коде мы использовали функцию microtime(true) для получения текущего времени с миллисекундной точностью и добавили миллисекунды к стандартным параметрам времени H:i:s. Теперь каждая запись будет иметь уникальное время.

[alexalexes]

$sql="select login,id,ip from web_users where (now() - online) > interval '".($timeout*60)."' AND session_id!=''";
$res=$db->query($sql);
while($arru=$res->fetch(PDO::FETCH_OBJ)){
  $db->query("INSERT INTO events (event_date,event_time,ip_client,user_id,user_login,event_type,event_place,event_note,event_status,title) VALUES
                ('" . date("Y-m-d") . "','" . date("H:i:s") . "',''," .$arru->id . ",'" .  $arru->login . "',1,'','<tr><td>выход по таймауту</td></tr>',1,'')");
}

$db->query("UPDATE web_users SET online='1970-01-01 00:00:00.000000', session_id='' WHERE (now() - online) > interval '".($timeout*60)."'");

Этот кусок кода ищет пользователей, которые имеют сессионный идентификатор и время жизни сессии выбежало за интервал. Заносит каждого неустарённого пользователя в ивенты.
Потом апдейтом устаревает их путем зануления идентификатора сессии и откатом времени онлайн в начало времен.
Что тут не так.
1) Этот кусок кода с взаимодействием с бд нужно как можно быстрей выполнить от момента выборки неактуальных пользователей до момента их перевода в неактуальное состояние, с занесением в журнал. Лучше перед выборкой объявить No_auto_commit, чтобы любое обращение в базу не прерывало транзакцию. После update завершить транзакцию командой commit и вернуть режим выполнения последующих запросов в auto_commit. А вы зачем-то while притормозить хотите, тут лететь нужно со скоростью пули от select до Update, причем в рамках одной транзакции.
2) Вы берете разные источники времени и разные моменты его получения для получения выборки пользователей, фиксации события и обновления состояния пользователей. В select-е и update у вас now() - источник времени базы данных, а в журнал событий вы заносите время из PHP. Если сервер с PHP и базой на разных железках, то время не будет идти одинаково.
Еще, если притормозить while, то now() в апдейте будет не то now() как в селекте (про date() в php вообще молчу). Вы можете устареть пользователей, которые не попадут в журнал.
Чтобы выйти из положения, время лучше вывести отдельным полем из select-а и его значение использовать и в журнале и в апдейте.
3) Проверьте, работает ли запрос с update. Если он выпадает в ошибку, то этот кусок кода с каждым новым запуском будет пытаться заносить в журнал тех же самых пользователей и пытаться их устареть снова и снова.
PS можно не оборачивать в транзакцию пункт 1. Можно даже журналировать по времени php. Но время из селекта нужно обязательно извлечь и использовать в update вместо now().

[dimone73]

alexalexes, база и веб на одной железке. Точность до микросекунд не нужна.
по поводу "время из селекта нужно обязательно извлечь и использовать в update вместо now()" - пожалуй верное направление, пойду копать.

[dimone73]

$count=$db->query("select count(id) as c from out_line_settings")->fetch(PDO::FETCH_OBJ)->c;
if($count!=0){
	$sql = "SELECT out_line_settings.id, out_line_settings.hrn, sip_conf.host, sip_conf.port, sip_conf.name,sip_conf.username FROM out_line_settings LEFT JOIN sip_conf ON sip_conf.outline_id=out_line_settings.id WHERE out_line_settings.type = 'SIP'"; // Вывод внешних линий
	$result = $db->query($sql);
	while ($arr = $result->fetch(PDO::FETCH_OBJ)) {
    	$status = 0;
    	if (exec('/usr/sbin/asterisk -rx "sip show registry" | grep "' . $arr->host . ':' . $arr->port . '" | grep "' . $arr->username . '" | grep "Registered"') != "")
        	$status = $status + 1;
    	if (exec('/usr/sbin/asterisk -rx "sip show peers" | grep "' . $arr->name . '/' . $arr->username . '"') != "")
        	$status = $status + 1;
    		$db->query("UPDATE out_line_settings SET line_status=" . $status . " WHERE id=" . $arr->id);
	}
}
$timeout=$db->query("SELECT timeout from general_config")->fetch(PDO::FETCH_OBJ)->timeout;
$timezone=$db->query("SELECT curtz from general_config")->fetch(PDO::FETCH_OBJ)->curtz;
date_default_timezone_set($timezone);


$sql="select login,ip,id from web_users where (now() - online) > interval '".($timeout*60)."' AND session_id!=''";
$res=$db->query($sql);
while($arru=$res->fetch(PDO::FETCH_OBJ)){
	$db->query("BEGIN");
	$db->query("UPDATE web_users SET online='1970-01-01 00:00:00.000000', session_id='' WHERE ((now() - online) > interval '".($timeout*60)."' AND session_id != '')");
	$db->query("INSERT INTO events (event_date,event_time,ip_client,user_id,user_login,event_type,event_place,event_note,event_status,title) VALUES
                ('" . date("Y-m-d") . "','" . date("H:i:s") . "','" .  $arru->ip . "'," .$arru->id . ",'" .  $arru->login . "',1,'0','<tr><td>окончание мониторинга внешней линии, выход по таймауту web</td></tr>',1,'')");
	$db->query("COMMIT");
	$sql="select login from web_users where (now() - online) > interval '".($timeout*60)."' AND session_id != ''";
	$res=$db->query($sql);
	break;
}

Уже даже брейком цикл прихлопнуть пытаюсь. И транзакцию открываю/закрываю, и сначала убиваю пользователя просроченного. Все равно. Какие-то тараканы...Все равно , то 4, то 3, то 2 записи. И время пытался фиксировать.

Answer 1

[dimone73]

Выяснилось, что это глюк базы, несмотря на уникальное поле - что не делал, все равно по 2-3-4 записи. Версия 9.1, поэтому многого недоступно из нового. Сделал сортировку и удаление в базе повторяющихся записей через DELETE USING.