open/PhalApi/Library/Task/Runner/Local.php

<?php
/**
 * 本地调度器 Task_Runner_Local
 * 
 * - 本地内部调度
 * - 不能在Api请求时进行此调度
 * 
 * @author dogstar <chanzonghuang@gmail.com> 20150516
 */

class Task_Runner_Local extends Task_Runner {

    protected function youGo($service, $params) {
        $params['service'] = $service;

        DI()->request = new PhalApi_Request($params);
        DI()->response = new PhalApi_Response_Json();

        $phalapi = new PhalApi();
        $rs = $phalapi->response();
        $apiRs = $rs->getResult();

        if ($apiRs['ret'] != 200) {
            DI()->logger->debug('task local go fail', 
                array('servcie' => $service, 'params' => $params, 'rs' => $apiRs));

            return FALSE;
        }

        return TRUE;
    }

}