zhh
/
zentao


			
				
					
						
						
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167
							<?php
/* Load the framework. */
include '../framework/zand/router.class.php';
include '../framework/control.class.php';
include '../framework/model.class.php';
include '../framework/helper.class.php';

$app = zandRouter::createApp('pms', dirname(dirname(__FILE__)), 'zandRouter');

$common = $app->loadCommon();

if($_SERVER['RR_MODE'] === 'jobs')
{
    /* Jobs. */
    while($task = $app->consumer->waitTask())
    {
            if($task->getQueue() == 'crons')
            {
                $id   = $task->getValue('id');
                $type = $task->getValue('type');
                $cmd  = $task->getValue('command');

                if(!$id || !$type || !$cmd) continue;

                $output = '';
                $return = 0;

                if($type == 'zentao')
                {
                    try
                    {
                        ob_start();

                        parse_str($cmd, $params);
                        if(!isset($params['moduleName']) || !isset($params['methodName'])) continue;

                        $app->initRequest();
                        $common->setUserConfig();

                        $app->moduleName = $params['moduleName'];
                        $app->methodName = $params['methodName'];
                        $app->rawModule  = $params['moduleName'];
                        $app->rawMethod  = $params['methodName'];
                        $app->setControlFile();
                        $app->loadModule();
                        $output = ob_get_clean();

                        $app->closeRequest();
                    }
                    catch(EndResponseException $e)
                    {
                        $output  = helper::removeUTF8Bom(ob_get_clean());
                        $output .= $e->getContent();
                    }
                    catch(Exception $e)
                    {
                        $return  = 1;
                        $output  = helper::removeUTF8Bom(ob_get_clean());
                        $output .= $e->getMessage();
                    }
                }
                elseif($type == 'system')
                {
                    exec($cmd, $output, $return);
                    if($output) $output = implode("\n", $output);
                }

                $log = date('H:m:s') . "task " . $id . " executed,\ncommand: $cmd.\nreturn : $return.\noutput : $output\n";
                logCron($app->getLogRoot(), $log);
            }

        $task->complete();
    }
}
else
{
    /* HTTP. */
    while(true)
    {
        try
        {
            $app->worker->waitRequest();
            $body = '';

            ob_start();

            /* installed or not. */
            if(!isset($config->installed) or !$config->installed) helper::header('location', 'install.php');

            /* Check for need upgrade. */
            $config->installedVersion = $app->getInstalledVersion();
            if($config->version != $config->installedVersion) helper::header('location', 'upgrade.php');

            $app->initRequest();
            $common->setUserConfig();

            /* Check the request is getconfig or not. */
            if(isset($_GET['mode']) and $_GET['mode'] == 'getconfig') helper::end(helper::removeUTF8Bom($app->exportConfig()));

            /* Remove install.php and upgrade.php. */
            if(file_exists('install.php') or file_exists('upgrade.php'))
            {
                $undeletedFiles = array();
                if(file_exists('install.php')) $undeletedFiles[] = '<strong style="color:#ed980f">install.php</strong>';
                if(file_exists('upgrade.php')) $undeletedFiles[] = '<strong style="color:#ed980f">upgrade.php</strong>';
                $wwwDir = dirname(__FILE__);
                if($undeletedFiles)
                {
                    echo "<html><head><meta charset='utf-8'></head>
                        <body><table align='center' style='width:700px; margin-top:100px; border:1px solid gray; font-size:14px;'><tr><td style='padding:8px'>";
                    echo "<div style='margin-bottom:8px;'>安全起见，请删除 <strong style='color:#ed980f'>{$wwwDir}</strong> 目录下的 " . join(' 和 ', $undeletedFiles) . " 文件。</div>";
                    echo "<div>Please remove " . join(' and ', $undeletedFiles) . " under <strong style='color:#ed980f'>$wwwDir</strong> dir for security reason.</div>";
                    helper::end("</td></tr></table></body></html>");
                }
            }

            /* If client device is mobile and version is pro, set the default view as mthml. */
            if($app->clientDevice == 'mobile' and (strpos($config->version, 'pro') === 0 or strpos($config->version, 'biz') === 0 or strpos($config->version, 'max') === 0) and $config->default->view == 'html') $config->default->view = 'mhtml';
            if(!empty($_GET['display']) && $_GET['display'] == 'card') $config->default->view = 'xhtml';

            $app->parseRequest();

            if(!$app->setParams()) return;
            $common->checkPriv();

            if(!$common->checkIframe()) return;

            $app->loadModule();

            $body = helper::removeUTF8Bom(ob_get_clean());

            /* Flush the buffer. */
            $app->worker->respond($body);
        }
        catch(EndResponseException $e)
        {
            $body  = helper::removeUTF8Bom(ob_get_clean());
            $body .= $e->getContent();
            $app->worker->respond($body);
        }
        catch(Exception $e)
        {
            $app->worker->error($e);
        }

        $app->closeRequest();
    }
}

/**
 * Log cron.
 *
 * @param  string    $log
 * @access public
 * @return void
 */
function logCron($root, $log)
{
    if(!is_writable($root)) return false;

    $file = $root . 'cron.' . date('Ymd') . '.log.php';
    if(!is_file($file)) $log = "<?php\n die();\n" . $log;

    $fp = fopen($file, "a");
    fwrite($fp, $log);
    fclose($fp);
}