Как организовать работу с MySQL и обработку правильно?

1. Готовимся ловить исключения
    2. Подключаемся к базе данных и убеждаемся, что при малейшей ошибке будет сыпать исключениями.
    3. Забираем идентификатор последней записи, обработанной в предыдущем запуске скрипта и бережно сохранённой в файл/базу данных. Например, это дата звонка и последний ID.
    4. Если такого ещё нет (первый запуск), назначаем: например, дата звонка  - начало месяца, ID  - 0
    5. Если старая дата слишком стара, тебе может вывалится куча старых записей. Так что посчитай минимальную актуальную дату звонка, старше которой звонки тебе определённо не интересны. Например, трое суток. Если старая дата меньше актуальной даты, увеличь её до актуальной.
    6. Забираем ID и дату последнего звонка, до которых мы будем обрабатывать записи. Учти свои пять минут, которые нужны для определения того, что на звонок не отвечали! То есть, тебе нужен последний, но достаточно старый, звонок.
    7. Находим список проблемных звонков между старой датой/ID и новой датой/ID.
    8. Сохраняем новую дату/ID как старую дату/ID в файл/базу данных (см. пункт 3). Убеждаемся, что успешно сохранилось, если нет -  бросаем исключение.
    9. Отсылаем список звонков куда тебе надо (если в нём что-нибудь есть).
10. Если возникло исключение, отсылаем письмо себе.
11. В крон добавляем запись, чтоб наш новый скрипт выполнялся только тогда, когда надо. Например, каждые 15 минут в рабочие часы.

<?php

define('OLD_DATA_FILE', '/tmp/script.old-data.txt');
define('OLD_DATA_DELIMITER', "\n"); #no digits, "-", ":" or spaces
define('LAST_ERROR_FILE', '/tmp/script.is-error.txt');
define('LOCK_FILE', '/tmp/script.lock');
define('ADMIN_EMAIL', 'admin@example.com');
define('WORKERS_EMAIL', 'workers@example.com');

try {

    #trying to lock file - what if another script is already running?
    $lockFile = fopen(LOCK_FILE, 'w+');
    if (!$lockFile) {
        throw new Exception('Lock file is already locked. Heavy queries, bad file?');
    }

    #if there is no old data file, trying to init one
    if (!is_file(OLD_DATA_FILE)) {
        writeFile(OLD_DATA_FILE, OLD_DATA_DELIMITER);
    }

    #fetching old data
    list($oldDate, $oldId) = explode(OLD_DATA_DELIMITER, file_get_contents(OLD_DATA_FILE));
    $oldId = (int) $oldId;
    $oldDate = parseDate($oldDate, 'last month');

    #old date can not be too small
    $actualDate = parseDate('-3 days');
    if ($oldDate < $actualDate) {
        $oldDate = $actualDate;
    }

    #is old date in a future?
    failIfDateInAFuture($oldDate, 'Somebody is messing with us? Please fix date in file.');

    #initializing DB connection, throwing exceptions on any error
    $dbh = new PDO('mysql:host=calls_db_host;dbname=calls_db_name', 'calls_db_user', 'calls_db_password', array(
        PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8',
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
    ));

    #getting new data
    $query = 'select max(date) as date, max(id) as id from calls where date < adddate(NOW(), interval -5 minute)';
    $newDataRaw =  $dbh->query($query)->fetch();
    $newId = (int) $newDataRaw['id'];
    $newDate = parseDate($newDataRaw['date'], $oldDate);

    #no new data - nothing left to do, just close lock file and report success before exiting
    if (($newDate <= $oldDate) && ($newId <= $oldId)) {
        fclose($lockFile);
        reportSuccess();
        return;
    }

    #is new date in a future?
    failIfDateInAFuture($newDate, 'DB records corrupted?');

    #main part - fetching new records
    $callsToReport = array();
    $query = 'select * from calls where (date > ? or date = ? and id > ?) and (date < ? or date = ? and id <= ?)';
    $sth = $dbh->prepare($query);
    $sth->execute(array($oldDate, $oldDate, $oldId, $newDate, $newDate, $newId));
    while ($rw = $sth->fetch()) {
        $callsToReport[] = $rw;
    }

    #trying to save new data into file for next use
    writeFile(OLD_DATA_FILE,  $newDate . OLD_DATA_DELIMITER . $newId);

    #sending report, if there is something to report
    if ($callsToReport) {
        doMail(WORKERS_EMAIL, 'new calls', print_r($callsToReport, true));
    }

    #removing admin status file, if there were error previuosly
    reportSuccess();

    #releasing a lock
    fclose($lockFile);
    $lockFile = null;

} catch (Exception $ex) {

    #reporting error, if there were no errors previously
    if (!is_file(LAST_ERROR_FILE)) {
        $msg = $ex->getMessage();
        doMail(ADMIN_EMAIL, 'script error', $msg);
        file_put_contents(LAST_ERROR_FILE, $msg);
    }

    #releasing a lock if we have locked file
    if ($lockFile) {
        fclose($lockFile);
    }
}

### functions

function writeFile($fileName, $text)
{
    $bytesWritten = file_put_contents($fileName, $text);
    if ($bytesWritten !== strlen($text)) {
        throw new Exception("Could not write text '$text' to file '$fileName'");
    }
}

function failIfDateInAFuture($date, $explaination)
{
    $futureDate = parseDate('+1 hour'); //Possible daylight changes
    if ($date > $futureDate) {
        throw new Exception("Date '$date' is in a future. $explaination");
    }
}
function reportSuccess()
{
    if (is_file(LAST_ERROR_FILE)) {
        $deleted = unlink(LAST_ERROR_FILE);
        if ($deleted) {
            doMail(ADMIN_EMAIL, 'script is ok', 'Script is working again');
        } else {
            doMail(ADMIN_EMAIL, 'script error', 'Script is working again, but I can not delete last error file');
        }
    }
}
function parseDate($currentDate, $defaultDate = 'now')
{
    $date = ($currentDate ? $currentDate : $defaultDate);
    return date('Y-m-d H:i:s', strtotime($date));
}

function doMail($email, $subject, $body)
{
    #mail($email, $subject, $body);
    echo "TO: $email\nSUBJECT: $subject\nBODY: \n---\n$body\n---\n";
}

calls(id, number, date, status=[ANSWERED, MISSED])

#main part - fetching new records
$queryMissed = <<<EOT
select
    number,
    max(date) as last_call_date
from calls
where
    (date > ? or date = ? and id > ?)
    and (date < ? or date = ? and id <= ?)
    and status='MISSED'
group by number
order by 2
EOT;

$sth = $dbh->prepare($queryMissed);
$sth->execute(array($oldDate, $oldDate, $oldId, $newDate, $newDate, $newId));
$callsToReport = array();
while ($rw = $sth->fetch()) {
    if ($rw['number'] && $rw['last_call_date']) {
        $callsToReport[$rw['number']] = $rw['last_call_date'];
    }
}

#removing latter answered calls
$queryAnswered = <<<EOT
select
    number,
    max(date) as last_call_date
from calls
where
    (date > ? or date = ? and id > ?)
    and status='ANSWERED'
group by number
order by 2
EOT;

$sth = $dbh->prepare($queryAnswered);
$sth->execute(array($oldDate, $oldDate, $oldId));
while ($rw = $sth->fetch()) {
    if (
        $rw['number']
        && isset($callsToReport[$rw['number']])
        && ($callsToReport[$rw['number']] <= $rw['last_call_date']) #last miss date <= last answer date
    ) {
        unset($callsToReport[$rw['number']]);
    }
}

#trying to save new data into file for next use
...

...
(date  > ? or date = ? and id > ?)
...
(date < ? or date = ? and id <= ?)
....

...
(date >= ?) and (date > ? or date = ? and id > ?)
...
(date <= ?) and (date < ? or date = ? and id <= ?)
....