PHP (Обработка заказов в реалтайме)

<?php 
 
    include("../api/0.2/wxrrd-api.php");
    include("../api/classes/mysql.class.php"); // Класс для работы с базой данных
    include("../api/0.2/errors.api.php");
 
 
 
 
 
    $db = new SafeMySQL(); 
 
    $table = 'Orders';
    $r = CallAPI('weiba.wxrrd.trade.lists','&type=tosend&limit=100');
 
    echo json_encode($r, 1);
 
    if (is_array($r)) {
        $errors = array(apis_error($r));
 
        foreach($errors as $errors_item){
            $error_code = $errors_item['ErrorCode'];
            $error_msg  = $errors_item['ErrorMsg'];
        }
        $db->query("INSERT INTO `Deamon_log` (`error_code`, `error_msg`) VALUES (?i, ?s);",$error_code, $error_msg );
    } else
    {
        $db->query("INSERT INTO `Deamon_log` (`response`) VALUES ('Китайский сервер не ответил!');");
    }
 
 
 
    sleep(2);
    if (is_array($r))
    foreach($r as $items){
        if(is_array($items)){
            foreach($items as $item){
                $order_sn        = $item['order_sn'];
                $orders_details  = CallAPI('weiba.wxrrd.trade.details',"&order_sn=$order_sn");
 
                foreach($orders_details as $od_items){
                    if(is_array($od_items)){
                    $id              = $item['id'];         // Идентификатор записи
                    $nickname        = $od_items['nickname'];           //  Имя покупателя
                    $order_type      = $od_items['order_type'];         // Тип ордера
                    $amount          = $od_items['goods_amount'];       // Сумма
                    $payment_name    = $od_items['payment_name'];       // Наименование платежной системмы 
                    $status_msg      = $od_items['status_msg'];
                    $status          = $od_items['status'];
                    $created_at      = $od_items['created_at'];
                    $updated_at      = $od_items['updated_at'];
 
                    $comma = ',';
                    $products_sn = '';
                    $goods_name = '';
                    $counter = 0;
                    foreach($od_items['order_goods'] as $goods_item){
                        if (is_array($goods_item)) {
                            $counter++;
                            if (count($od_items['order_goods']) == $counter) {
                                $comma = '';
                            }
                            $products_sn = $products_sn . $goods_item['product_sn'] . $comma;
                            $goods_name = $goods_name . $goods_item['goods_name'] . $comma;
                        }
                    }
                    $data_to_send = '';
                    $data_to_send = 'Оплата выполнена!' . PHP_EOL;
                    $data_to_send = $data_to_send . 'Продукт: ' . $goods_name . PHP_EOL;
                    $data_to_send = $data_to_send . 'Сумма: ' . $amount;
 
                    $data = $db->query("INSERT IGNORE INTO ?n (`id`, `nickname`, `order_sn`, `order_type`, `amount`, `payment_name`, `status_msg`, `status`, `created_at`, `updated_at`, `goodslist`, `data_to_send`) VALUES (
                    ?i, 
                    ?s, 
                    ?s, 
                    ?i, 
                    ?s, 
                    ?s, 
                    ?s, 
                    ?i,
                    ?s, 
                    ?s,
                    ?s,
                    ?s
                    );",
                    $table,             // Таблица
 
                    // ЗНАЧЕНИЯ ПОЛЕЙ
                    $id,                // Идентификатор записи в текуще базе
                    $nickname,          // Ник пользователя создавший транзакцию
                    $order_sn,          // Номер заказа
                    $order_type,        // Тип заказа
                    $amount,            // Сумма
                    $payment_name,      // Наименование платежной системмы
                    $status_msg,        // Статус сообщение
                    $status,            // Статус транзакции
                    $created_at,        // Время создания заказа
                    $updated_at,        // Время последненго изменения статуса заказа
                    $products_sn,
                    $data_to_send       // Данные уведомления!
                                       );//SELECT * FROM ?n WHERE mod=?s LIMIT ?i
                    }
                }
                sleep(3);
            }
        }
    }
 
 
 
 
 
?>

<?php
 
 
 
include("../api/classes/mysql.class.php"); // Класс для работы с базой данных
include('smsc_api.php');
 
$stop = false;
/**
 * pcntl_fork() - данная функция разветвляет текущий процесс
 */
 
$pid = pcntl_fork();
 
if ($pid == -1) {
    
    
    /**
     * Не получилось сделать форк процесса, о чем сообщим в консоль
     */
    die('Не удалось породить дочерний процесс');
} else if ($pid) {
    /**
     * В эту ветку зайдет только родительский процесс, который мы убиваем и сообщаем об этом в консоль
     */
    // Запрет повторного запуска скрипта в данной директории
    
    die('Уничтожаю родительский процесс' . PHP_EOL);
} else {
    
    /**
 * Установим дочерний процесс основным, это необходимо для создания процессов
 */
$lockfile = fopen("lock", 'w');
    if (flock($lockfile, LOCK_EX | LOCK_NB ) !== true){
        die('Процесс уже работает...');
    }   
posix_setsid();
    /**
     * Бесконечный цикл
     */
    
 
    
    $db = new SafeMySQL(); 
 
    $db->query( "INSERT INTO `Deamon_pids` (`pid`, `time_stamp`) VALUES ('$pid', '');" );
 
    while(!$stop) {
        /*
         * Тело демона
         */
        
        $data = $db->getAll( "SELECT * FROM `Orders` WHERE `status` = 30 LIMIT 100" );
        
        // Проверяем массив и количество, дабы зря не бегать по коду
        if (is_array($data)) {
            if (count($data) == 0) {
                sleep(3);
                continue;
            }
        }
        
        foreach($data as $item) {
            $goods_id       = $item['goodslist'];
            $data_to_send   = $item['data_to_send'];
            $key            = $item['key'];
            
            $suppliers = $db->getAll( "SELECT * FROM `Suppliers` WHERE `suppliers_id` IN (SELECT `s_id` FROM `Goods` WHERE `goods_id` = $goods_id);" );
            
            if (is_array($suppliers)){
                foreach($suppliers as $s_item) {
                    /*Здесь происходит отправка смс уведомлений*/  
                    $sms_result = send_sms($s_item['phone'], $data_to_send ); 
                    $suppliers = $db->query( "UPDATE `Orders` SET `status`='31' WHERE  `key`= $key " );
                }
            }
            
        }
        
        sleep(3);
    }
}
 
 
 
?>