open/Library/Task/Lite.php

<?php
/**
 * 计划任务客户端类 Task_Lite
 *
 * @author dogstar <chanzonghuang@gmail.com> 20150516
 */

class Task_Lite {

    /**
     * Task_MQ $mq MQ队列
     */
    protected $mq;

    public function __construct(Task_MQ $mq) {
        $this->mq = $mq;
        DI()->loader->addDirs('./Library/Task/Task');
    }

    /**
     * 添加一个计划任务到MQ队列
     * @param string $service 接口服务名称，如：Default.Index
     * @param array $params 接口服务参数
     */
    public function add($service, $params = array()) {
        if (empty($service) || count(explode('.', $service)) < 2) {
            return FALSE;
        }
        if (!is_array($params)) {
            return FALSE;
        }

        $rs = $this->mq->add($service, $params);

        if (!$rs) {
            DI()->logger->debug('task add a new mq', 
                array('service' => $service, 'params' => $params));

            return FALSE;
        }

        return TRUE;
    }
}