forked from instantsoft/icms2
-
Notifications
You must be signed in to change notification settings - Fork 0
/
cron.php
executable file
·105 lines (71 loc) · 3.69 KB
/
cron.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
<?php
// некоторые задачи требуют безлимитного времени выполнения, в cli это по умолчанию
// задача для CRON выглядит примерно так: php -f /path_to_site/cron.php
// Если планируете запускать задачи CRON через curl или иные http запросы, закомментируйте строку ниже
if(PHP_SAPI != 'cli') { die('Access denied'); }
// Инициализация
require_once 'bootstrap.php';
// Подключаем шаблонизатор, чтобы был подключен хелпер с функциями
cmsTemplate::getInstance();
// Подключение модели
$model = cmsCore::getModel('admin');
// id задачи
// id передаётся вторым параметром, первым передаётся имя домена
$task_id = isset($argv[2]) ? (int)$argv[2] : 0;
// если id задачи передано, запускаем только её
if($task_id){
$task = $model->getSchedulerTask($task_id);
if($task){
$tasks = array($task['id'] => $task);
}
} else {
// Иначе получаем весь список задач для выполнения
$tasks = $model->getPendingSchedulerTasks();
}
// Если задач нет, выходим
if (empty($tasks)) { exit; }
// Коллекция контроллеров
$controllers = array();
//
// Выполняем задачи по списку
//
foreach($tasks as $task){
// Проверяем существование контроллера
if (!cmsCore::isControllerExists($task['controller'])){ continue; }
// если включено последовательное выполнение,
// параллельные запуски запретить
if(!empty($task['consistent_run'])){
$lock_file = $config->cache_path.'cron_lock_'.$task['id'];
$lockfp = fopen($lock_file, 'w');
// Если блокировку получить не удалось, значит скрипт еще работает
// и запуск нужно запретить
if (!flock($lockfp, LOCK_EX | LOCK_NB)) {
continue;
}
// По окончании работы необходимо снять блокировку и удалить файл
register_shutdown_function(function($lockfp, $lock_file) {
flock($lockfp, LOCK_UN);
@unlink($lock_file);
}, $lockfp, $lock_file);
}
// Получаем контроллер из коллекции либо загружаем
// и сохраняем в коллекцию
if (isset($controllers[$task['controller']])){
$controller = $controllers[$task['controller']];
} else {
$controller = cmsCore::getController($task['controller']);
if(!$controller->isEnabled()){
unset($controller); continue;
}
$controllers[$task['controller']] = $controller;
}
try {
// Выполняем хук
$controller->runHook("cron_{$task['hook']}");
// Обновляем время последнего запуска задачи
$model->updateSchedulerTaskDate($task);
} catch (Exception $e) {
// выключаем ошибочное задание
$model->toggleSchedulerPublication($task['id'], 0);
}
}