| | |
|---|
| | | */ |
|---|
| | | |
|---|
| | | function processDatalog() { |
|---|
| | | global $app; |
|---|
| | | global $app,$conf; |
|---|
| | | |
|---|
| | | // TODO: process only new entries. |
|---|
| | | $sql = "SELECT * FROM sys_datalog WHERE 1"; |
|---|
| | | $sql = "SELECT * FROM sys_datalog WHERE server_id = ".$conf["server_id"]." ORDER BY datalog_id"; |
|---|
| | | $records = $app->db->queryAllRecords($sql); |
|---|
| | | foreach($records as $rec) { |
|---|
| | | $data = unserialize(stripslashes($rec["data"])); |
|---|
| | | $this->raiseTableHook($rec["dbtable"],$rec["action"],$data); |
|---|
| | | $app->db->query("DELETE FROM sys_datalog WHERE datalog_id = ".$rec["datalog_id"]); |
|---|
| | | $app->log("Deleting sys_datalog ID ".$rec["datalog_id"],LOGLEVEL_DEBUG); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
