<?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;
|
}
|
}
|
