yunbaolive/web/PhalApi/Library/Task/Progress.php

<?php
/**
 * 计划任务进程类
 * 
 * @author dogstar <chanzonghuang@gmail.com> 20150520
 */

class Task_Progress {

    /**
     * @var int MAX_LAST_FIRE_TIME_INTERVAL 修复的最大时间间隔
     */
    const MAX_LAST_FIRE_TIME_INTERVAL = 86400;

    /**
     * @var Model_Task_TaskProgress 对数据库的操作
     */
    protected $model;

    public function __construct() {
        $this->model = new Model_Task_TaskProgress();
    }

    /**
     * 进行进程调度
     * 
     * - 1、尝试修复异常的任务
     * - 2、执行全部空闲的任务
     */
    public function run() {
        $this->tryToResetWrongItems();

        $this->runAllWaittingItems();

        return TRUE;
    }

    protected function tryToResetWrongItems() {
        $maxLastFireTime = $_SERVER['REQUEST_TIME'] - self::MAX_LAST_FIRE_TIME_INTERVAL;

        $wrongItems = $this->model->getWrongItems($maxLastFireTime);

        foreach ($wrongItems as $item) {
            $this->model->resetWrongItems($item['id']);

            DI()->logger->debug('task try to reset wrong items', $item);
        }
    }

    protected function runAllWaittingItems() {
        $waittingItems = $this->model->getAllWaittingItems();

        foreach ($waittingItems as $item) {
            //
            if (!$this->model->isRunnable($item['id'])) {
                continue;
            }

            $class = $item['trigger_class'];
            $params = $item['fire_params'];

            if (empty($class) || !class_exists($class)) {
                DI()->logger->error('Error: task can not run illegal class', $item);
                $this->model->updateExceptionItem($item['id'], 'task can not run illegal class');
                continue;
            }

            $trigger = new $class();
            if (!is_callable(array($class, 'fire'))) {
                DI()->logger->error('Error: task can not call fire()', $item);
                $this->model->updateExceptionItem($item['id'], 'task can not call fire()');
                continue;
            }

            $this->model->setRunningState($item['id']);

            try {
                $result = call_user_func(array($trigger, 'fire'), $params);

                $this->model->updateFinishItem($item['id'], $result);
            } catch (Exception $ex) {
                throw $ex;
                $this->model->updateExceptionItem($item['id'], $ex->getMessage());
            }
        }
    }
}