zentao/module/repo/zen.php

<?php
/**
 * The zen file of repo module of ZenTaoPMS.
 *
 * @copyright   Copyright 2009-2023 禅道软件（青岛）有限公司(ZenTao Software (Qingdao) Co., Ltd. www.zentao.net)
 * @license     ZPL(https://zpl.pub/page/zplv12.html) or AGPL(https://www.gnu.org/licenses/agpl-3.0.en.html)
 * @author      Zeng Gang<zenggang@easycorp.ltd>
 * @package     repo
 * @link        https://www.zentao.net
 */
class repoZen extends repo
{
    /**
     * 准备创建版本库的数据。
     * Prepare create repo data.
     *
     * @param  form      $formData
     * @param  bool      $isPipelineServer
     * @access protected
     * @return object|false
     */
    protected function prepareCreate($formData, $isPipelineServer)
    {
        if($this->config->inContainer || $this->config->inQuickon)
        {
            $formData->data->client = $this->post->client = $this->post->SCM == 'Subversion' ? 'svn' : 'git';
        }
        else
        {
            if(!$this->checkClient()) return false;
        }
        if(!$this->checkConnection()) return false;

        $repo = $formData
            ->setIf($isPipelineServer, 'password', $this->post->serviceToken)
            ->setIf($this->post->SCM == 'Gitlab', 'path', '')
            ->setIf($this->post->SCM == 'Gitlab', 'client', '')
            ->setIf($this->post->SCM == 'Gitlab', 'extra', $this->post->serviceProject)
            ->setIf($isPipelineServer, 'prefix', '')
            ->setIf($this->post->SCM == 'Git', 'account', '')
            ->setIf($this->post->SCM == 'Git', 'password', '')
            ->setIf(in_array($this->post->SCM, array('Gitea', 'Gogs')), 'path', $_POST['path'])
            ->setIf($this->post->encrypt == 'base64', 'password', base64_encode($this->post->password))
            ->skipSpecial('path,client,account,password,desc')
            ->setDefault('product', '')->join('product', ',')
            ->setDefault('projects', '')->join('projects', ',')
            ->get();
        if(strpos($repo->client, ' ')) $repo->client = "\"{$repo->client}\"";

        $acl = $this->checkACL();
        if(!$acl) return false;
        $repo->acl = json_encode($acl);

        if($repo->SCM == 'Subversion')
        {
            $scmRepo = clone $repo;
            if($this->post->encrypt == 'base64') $scmRepo->password = $this->post->password;

            $scm = $this->app->loadClass('scm');
            $scm->setEngine($scmRepo);
            $info     = $scm->info('');
            $infoRoot = urldecode($info->root);

            $path   = str_replace(array(':3690/',':80/'), '/', $repo->path);
            $prefix = str_replace('\\', '/', $path);

            $repo->prefix = empty($infoRoot) ? '' : trim(str_ireplace($infoRoot, '', $prefix), '/');
            if($repo->prefix) $repo->prefix = '/' . $repo->prefix;
        }

        if($isPipelineServer)
        {
            $serviceProject = $this->dao->select('*')->from(TABLE_REPO)
                ->where('`SCM`')->eq($repo->SCM)
                ->andWhere('`serviceHost`')->eq($repo->serviceHost)
                ->andWhere('`serviceProject`')->eq($repo->serviceProject)
                ->fetch();
            if($serviceProject)
            {
                dao::$errors['serviceProject'][] = $this->lang->repo->error->projectUnique;
                return false;
            }
        }
        return $repo;
    }

    /**
     * 准备创建版本库的数据。
     * Prepare create repo data.
     *
     * @param  object       $repo
     * @access protected
     * @return object|false
     */
    protected function prepareCreateRepo($repo)
    {
        $acl = $this->checkACL();
        if(!$acl) return false;

        $repo->acl  = json_encode($acl);

        $group  = $this->repo->getGroups($repo->serviceHost, $repo->namespace);
        $server = $this->loadModel('pipeline')->getByID($repo->serviceHost);
        $repo->path = "{$server->url}/{$group}/{$repo->name}";

        return $repo;
    }

    /**
     * 准备编辑版本库的数据。
     * Prepare edit repo data.
     *
     * @param  form      $formData
     * @param  object    $oldRepo
     * @param  bool      $isPipelineServer
     * @access protected
     * @return object|false
     */
    protected function prepareEdit($formData, $oldRepo, $isPipelineServer)
    {
        if($oldRepo->client != $this->post->client and !$this->checkClient()) return false;
        if(!$this->checkConnection()) return false;

        $repo = $formData
            ->setIf($isPipelineServer, 'password', $this->post->serviceToken)
            ->setDefault('client', 'svn')
            ->setIf($this->post->SCM == 'Gitlab', 'client', '')
            ->setIf($this->post->SCM == 'Gitlab', 'extra', $this->post->serviceProject)
            ->setIf($this->post->SCM == 'Gitlab', 'prefix', '')
            ->setDefault('product', '')
            ->skipSpecial('path,client,account,password,desc')
            ->join('product', ',')
            ->setDefault('projects', '')->join('projects', ',')
            ->get();
        if(strpos($repo->client, ' ')) $repo->client = "\"{$repo->client}\"";

        if($repo->path != $oldRepo->path) $repo->synced = 0;

        $acl = $this->checkACL();
        if(!$acl) return false;
        $repo->acl = json_encode($acl);

        if($repo->SCM == 'Subversion')
        {
            $scm = $this->app->loadClass('scm');
            $scm->setEngine($repo);
            $info     = $scm->info('');
            $infoRoot = urldecode($info->root);

            $path   = str_replace(array(':3690/',':80/'), '/', $repo->path);
            $prefix = str_replace('\\', '/', $path);

            $repo->prefix = empty($infoRoot) ? '' : trim(str_ireplace($infoRoot, '', $prefix), '/');
            if($repo->prefix) $repo->prefix = '/' . $repo->prefix;
        }
        elseif($repo->SCM != $oldRepo->SCM and $repo->SCM == 'Git')
        {
            $repo->prefix = '';
        }

        if($isPipelineServer)
        {
            $serviceProject = $this->dao->select('*')->from(TABLE_REPO)
                ->where('`SCM`')->eq($repo->SCM)
                ->andWhere('`serviceHost`')->eq($repo->serviceHost)
                ->andWhere('`serviceProject`')->eq($repo->serviceProject)
                ->andWhere('id')->ne($oldRepo->id)
                ->fetch();
            if($serviceProject)
            {
                dao::$errors['serviceProject'][] = $this->lang->repo->error->projectUnique;
                return false;
            }
        }

        return $repo;
    }

    /**
     * 检查权限数据。
     * Check acl.
     *
     * @access protected
     * @return array|false
     */
    protected function checkACL()
    {
        $acl = $this->post->acl;
        if($acl['acl'] == 'custom')
        {
            $aclGroups = array_filter($acl['groups']);
            $aclUsers  = array_filter($acl['users']);
            if(empty($aclGroups) && empty($aclUsers))
            {
                $this->app->loadLang('product');
                dao::$errors['acl'] = sprintf($this->lang->error->notempty, $this->lang->product->whitelist);
                return false;
            }
        }
        return $acl;
    }

    /**
     * 检查svn、git客户端。
     * Check svn/git client.
     *
     * @access public
     * @return bool
     */
    protected function checkClient()
    {
        if(in_array($this->post->SCM, $this->config->repo->notSyncSCM)) return true;
        if(!$this->config->features->checkClient) return true;

        if(!$this->post->client)
        {
            dao::$errors['client'] = sprintf($this->lang->error->notempty, $this->lang->repo->client);
            return false;
        }

        $clientVersionFile = $this->session->clientVersionFile;
        if(empty($clientVersionFile))
        {
            $clientVersionFile = $this->app->getLogRoot() . uniqid('version_') . '.log';

            session_start();
            $this->session->set('clientVersionFile', $clientVersionFile);
            session_write_close();
        }

        if(file_exists($clientVersionFile)) return true;

        $cmd = $this->post->client . " --version > $clientVersionFile";
        dao::$errors['client'] = sprintf($this->lang->repo->error->safe, $clientVersionFile, $cmd);

        return false;
    }


    /**
     * 检查连接。
     * Check connection
     *
     * @access public
     * @return bool
     */
    protected function checkConnection()
    {
        if(empty($_POST)) return false;

        $scm      = $this->post->SCM;
        $client   = $this->post->client;
        $account  = $this->post->account;
        $password = $this->post->password;
        $encoding = strtoupper($this->post->encoding ?: 'UTF-8');
        $path     = $this->post->path;
        if($encoding != 'UTF8' and $encoding != 'UTF-8') $path = helper::convertEncoding($path, 'utf-8', $encoding);

        if($scm == 'Subversion')
        {
            /* Get svn version. */
            $versionCommand = "$client --version --quiet 2>&1";
            exec($versionCommand, $versionOutput, $versionResult);
            if($versionResult)
            {
                $message = sprintf($this->lang->repo->error->output, $versionCommand, $versionResult, implode("\n", $versionOutput));
                dao::$errors['client'] = $this->lang->repo->error->cmd . "\n" . $message;
                return false;
            }
            $svnVersion = end($versionOutput);

            $path = '"' . str_replace(array('%3A', '%2F', '+'), array(':', '/', ' '), urlencode($path)) . '"';
            if(stripos($path, 'https://') === 1 or stripos($path, 'svn://') === 1)
            {
                if(version_compare($svnVersion, '1.6', '<'))
                {
                    dao::$errors['client'] = $this->lang->repo->error->version;
                    return false;
                }

                $command = "$client info --username $account --password $password --non-interactive --trust-server-cert-failures=cn-mismatch --trust-server-cert --no-auth-cache $path 2>&1";
                if(version_compare($svnVersion, '1.9', '<')) $command = "$client info --username $account --password $password --non-interactive --trust-server-cert --no-auth-cache $path 2>&1";
            }
            elseif(stripos($path, 'file://') === 1)
            {
                $command = "$client info --non-interactive --no-auth-cache $path 2>&1";
            }
            else
            {
                $command = "$client info --username $account --password $password --non-interactive --no-auth-cache $path 2>&1";
            }

            exec($command, $output, $result);
            if($result)
            {
                $message = sprintf($this->lang->repo->error->output, $command, $result, implode("\n", $output));
                if(stripos($message, 'Expected FS format between') !== false and strpos($message, 'found format') !== false)
                {
                    dao::$errors['client'] = $this->lang->repo->error->clientVersion;
                    return false;
                }
                if(preg_match('/[^\:\/A-Za-z0-9_\-\'\"\.]/', $path))
                {
                    dao::$errors['encoding'] = $this->lang->repo->error->encoding . "\n" . $message;
                    return false;
                }

                dao::$errors['submit'] = $this->lang->repo->error->connect . "\n" . $message;
                return false;
            }
        }
        elseif(in_array($scm, array('Gitea', 'Gogs')))
        {
            if($this->post->name != '' and $this->post->serviceProject != '')
            {
                $module  = strtolower($scm);
                $project = $this->loadModel($module)->apiGetSingleProject((int)$this->post->serviceHost, $this->post->serviceProject);
                if(isset($project->tokenCloneUrl))
                {
                    $path = $this->app->getAppRoot() . 'www/data/repo/' . $this->post->name . '_' . $module;
                    if(!realpath($path))
                    {
                        $cmd = 'git clone --progress -v "' . $project->tokenCloneUrl . '" "' . $path . '"  > "' . $this->app->getTmpRoot() . "log/clone.progress.$module.{$this->post->name}.log\" 2>&1 &";
                        if(PHP_OS == 'WINNT') $cmd = "start /b $cmd";
                        exec($cmd);
                    }
                    $_POST['path'] = $path;
                }
                else
                {
                    dao::$errors['serviceProject'] = $this->lang->repo->error->noCloneAddr;
                    return false;
                }
            }
        }
        elseif($scm == 'Git')
        {
            if(!is_dir($path))
            {
                dao::$errors['path'] = sprintf($this->lang->repo->error->noFile, $path);
                return false;
            }

            if(!is_writable($path) || !is_executable($path))
            {
                dao::$errors['path'] = sprintf($this->lang->repo->error->noPriv, $path);
                return false;
            }

            if(!chdir($path))
            {
                dao::$errors['path'] = $this->lang->repo->error->path;
                return false;
            }

            $command = "$client tag 2>&1";
            exec($command, $output, $result);
            if($result)
            {
                dao::$errors['submit'] = $this->lang->repo->error->cmd . "\n" . sprintf($this->lang->repo->error->output, $command, $result, implode("\n", $output));
                return false;
            }
        }
        return true;
    }

    /**
     * 构建创建版本库页面数据。
     * Build form fields for create repo.
     *
     * @param  int       $objectID
     * @access protected
     * @return void
     */
    protected function buildCreateForm($objectID)
    {
        $this->repo->saveState(0, $objectID);

        $this->app->loadLang('action');
        $this->loadModel('product');
        if($this->app->tab == 'project' or $this->app->tab == 'execution')
        {
            $products = $this->loadModel('project')->getBranchesByProject($objectID);
            $products = $this->product->getProducts($objectID, 'all', '', false, array_keys($products));
        }
        else
        {
            $products = $this->product->getPairs('', 0, '', 'all');
        }

        $this->view->title        = $this->lang->repo->common . $this->lang->hyphen . $this->lang->repo->create;
        $this->view->groups       = $this->loadModel('group')->getPairs();
        $this->view->users        = $this->loadModel('user')->getPairs('noletter|noempty|nodeleted|noclosed');
        $this->view->products     = $products;
        $this->view->serviceHosts = $this->loadModel('pipeline')->getPairs(implode(',', $this->config->repo->notSyncSCM), true);
        $this->view->objectID     = $objectID;

        $this->display();
    }

    /**
     * 构建创建版本库页面数据。
     * Build form fields for create repo.
     *
     * @param  int       $objectID
     * @access protected
     * @return void
     */
    protected function buildCreateRepoForm($objectID)
    {
        $this->repo->saveState(0, $objectID);

        $this->app->loadLang('action');

        if($this->app->tab == 'project' or $this->app->tab == 'execution')
        {
            $products = $this->loadModel('product')->getProductPairsByProject($objectID);
        }
        else
        {
            $products = $this->loadModel('product')->getPairs('', 0, '', 'all');
        }

        $repoGroups   = array();
        $serviceHosts = $this->loadModel('pipeline')->getPairs(implode(',', $this->config->repo->notSyncSCM), true);
        if(!empty($serviceHosts))
        {
            $serverID   = key($serviceHosts);
            $repoGroups = $this->repo->getGroups($serverID);
        }

        $this->view->title        = $this->lang->repo->common . $this->lang->hyphen . $this->lang->repo->create;
        $this->view->groups       = $this->loadModel('group')->getPairs();
        $this->view->users        = $this->loadModel('user')->getPairs('noletter|noempty|nodeleted|noclosed');
        $this->view->products     = $products;
        $this->view->serviceHosts = $serviceHosts;
        $this->view->repoGroups   = $repoGroups;
        $this->view->objectID     = $objectID;

        $this->display();
    }

    /**
     * 构建编辑版本库页面数据。
     * Build form fields for edit repo.
     *
     * @param  int       $objectID
     * @access protected
     * @return void
     * @param int $repoID
     */
    protected function buildEditForm($repoID, $objectID)
    {
        $repo = $this->repo->getByID($repoID);
        $repo->client = trim($repo->client, '"');
        $this->app->loadLang('action');

        $scm = strtolower($repo->SCM);
        if(in_array($scm, $this->config->repo->gitServiceList))
        {
            $serviceID = isset($repo->gitService) ? $repo->gitService : 0;
            $projectID = in_array($repo->SCM, $this->config->repo->notSyncSCM) ? (int)$repo->serviceProject : $repo->serviceProject;
            $project   = $this->loadModel($scm)->apiGetSingleProject($serviceID, $projectID);

            $this->view->project = $project;
        }

        $products           = $this->loadModel('product')->getPairs('', 0, '', 'all');
        $linkedProducts     = $this->loadModel('product')->getByIdList(explode(',', $repo->product));
        $linkedProductPairs = array_combine(array_keys($linkedProducts), helper::arrayColumn($linkedProducts, 'name'));
        $products           = $products + $linkedProductPairs;

        $this->view->title           = $this->lang->repo->common . $this->lang->hyphen . $this->lang->repo->edit;
        $this->view->repo            = $repo;
        $this->view->repoID          = $repoID;
        $this->view->objectID        = $objectID;
        $this->view->groups          = $this->loadModel('group')->getPairs();
        $this->view->users           = $this->loadModel('user')->getPairs('noletter|noempty|nodeleted|noclosed');
        $this->view->products        = $products;
        $this->view->relatedProjects = $this->repo->filterProject(explode(',', $repo->product), explode(',', $repo->projects));
        $this->view->serviceHosts    = $this->loadModel('pipeline')->getPairs($repo->SCM);

        $this->display();
    }

    /**
     * 获取还没存在禅道的项目列表。
     * Get not exist repos.
     *
     * @param  object    $gitlab
     * @access protected
     * @return array
     * @param object $server
     */
    protected function getNotExistRepos($server)
    {
        $repoList = array();
        if(!empty($server))
        {
            $repoList      = $this->getGitlabProjectsByApi($server);
            $existRepoList = $this->dao->select('serviceProject,name')->from(TABLE_REPO)
                ->where('SCM')->eq('Gitlab')
                ->andWhere('serviceHost')->eq($server->id)
                ->fetchPairs();
            foreach($repoList as $key => $repo)
            {
                if(isset($existRepoList[$repo->id])) unset($repoList[$key]);
            }
        }
        return $repoList;
    }

    /**
     * 通过Graphql获取GitLab项目列表。
     * Get GitLab projects by Graphql.
     *
     * @param  object $server
     * @access public
     * @return array
     */
    protected function getGitlabProjectsByApi($server)
    {
        $repoList    = array();
        $endCursor   = '';
        $hasNextPage = true;
        $url = rtrim($server->url, '/') . '/api/graphql' . "?private_token={$server->token}";
        while($hasNextPage)
        {
            $query    = 'query { projects(after: "' . $endCursor . '") {pageInfo {endCursor hasNextPage} nodes {nameWithNamespace id name}}}';
            $response = json_decode(commonModel::http($url, array('query' => $query), array(CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1)));
            if(!$endCursor && !isset($response->data->projects->nodes)) return array();

            foreach($response->data->projects->nodes as $project)
            {
                preg_match('/\d+/', $project->id, $projectID);
                $project->id                  = $projectID ? $projectID[0] : $project->id;
                $project->name_with_namespace = $project->nameWithNamespace;
                $repoList[]  = $project;
            }
            $hasNextPage = $response->data->projects->pageInfo->hasNextPage;
            $endCursor   = $response->data->projects->pageInfo->endCursor;
        }
        return $repoList;
    }

    /**
     * 获取版本库文件列表信息。
     * Get repo files info.
     *
     * @param  object    $repo
     * @param  string    $path
     * @param  string    $branchID
     * @param  string    $base64BranchID
     * @param  int       $objectID
     * @access protected
     * @return array
     */
    protected function getFilesInfo($repo, $path, $branchID, $base64BranchID, $objectID)
    {
        $scm = $this->app->loadClass('scm');
        $scm->setEngine($repo);
        if($repo->SCM == 'Gitlab')
        {
            $_COOKIE['repoBranch'] = $branchID ? $branchID : $this->cookie->repoBranch;
            $infos = $this->repo->getGitlabFilesByPath($repo, $path, $branchID);
            foreach($infos as &$file)
            {
                $file->revision = '';
                $file->comment  = '';
                $file->account  = '';
                $file->date     = '';
            }
        }
        else
        {
            $infos = $this->repo->getFileCommits($repo, $branchID, $path);
        }

        $filePath = $path;
        if($repo->SCM == 'Subversion')
        {
            $info = $scm->info('');
            if(!empty($info->root))
            {
                $prefixPath = str_replace($info->root . '/', '', $repo->path);
                $filePath   = trim(str_replace($prefixPath, '', $path), '/');
            }
        }

        foreach($infos as $info)
        {
            $info->originalComment = $info->comment;
            $info->comment         = $this->repo->replaceCommentLink($info->comment);
            if($repo->SCM != 'Subversion') $info->revision = substr($info->revision, 0, 10);

            $infoPath = trim(urldecode($path) . '/' . $info->name, '/');
            if($info->kind == 'dir')
            {
                $info->link = $this->repo->createLink('browse', "repoID={$repo->id}&branchID=$base64BranchID&objectID=$objectID&path=" . $this->repo->encodePath($infoPath));
            }
            else
            {
                if($repo->SCM == 'Subversion') $infoPath = $filePath . '/' . $info->name;
                $info->link = $this->repo->createLink('view', "repoID={$repo->id}&objectID=$objectID&entry=" . $this->repo->encodePath($infoPath));
            }
        }

        return $infos;
    }

    /**
     * 获取分支与tag下拉菜单组件配置。
     * Get items of branch and tags menu.
     *
     * @param  object    $repo
     * @param  string    $branchID
     * @access protected
     * @return array
     */
    protected function getBranchAndTagItems($repo, $branchID)
    {
        /* Set branch or tag for git. */
        $branches = $tags = array();
        if(!in_array($repo->SCM, $this->config->repo->gitTypeList)) return array();

        $scm = $this->app->loadClass('scm');
        $scm->setEngine($repo);
        $branches = $scm->branch();
        $initTags = $scm->tags('');
        foreach($initTags as $tag) $tags[$tag] = $tag;

        $selected    = '';
        $branchMenus = array();
        $tagMenus    = array();
        foreach($branches as $branchName)
        {
            $selected = ($branchName == $branchID) ? $branchName : $selected;
            $branchMenus[]  = array(
                'text'       => $branchName,
                'id'         => $branchName,
                'keys'       => zget(common::convert2Pinyin(array($branchName)), $branchName, ''),
                'url'        => 'javascript:;',
                'data-type'  => 'branch',
                'data-value' => $branchName,
            );
        }
        foreach($tags as $tagName)
        {
            $selected = ($tagName == $branchID) ? $tagName : $selected;
            $tagMenus[]  = array(
                'text'       => $tagName,
                'id'         => $tagName,
                'keys'       => zget(common::convert2Pinyin(array($tagName)), $tagName, ''),
                'url'        => 'javascript:;',
                'data-type'  => 'tag',
                'data-value' => $tagName,
            );
        }

        return array('branchMenus' => $branchMenus, 'tagMenus' => $tagMenus, 'selected' => $selected);
    }

    /**
     * 更新版本库最后提交时间。
     * Update repo last commited date.
     *
     * @param  object    $repo
     * @param  object    $lastRevision
     * @access protected
     * @return void
     */
    protected function updateLastCommit($repo, $lastRevision)
    {
        if(empty($lastRevision->committed_date)) return;
        $lastCommitDate = date('Y-m-d H:i:s', strtotime($lastRevision->committed_date));
        if(empty($repo->lastCommit) || $lastCommitDate > $repo->lastCommit) $this->dao->update(TABLE_REPO)->set('lastCommit')->eq($lastCommitDate)->where('id')->eq($repo->id)->exec();
    }

    /**
     * 获取browse方法项目、分支、tags信息。
     * Get project、branches、tags info for browse method.
     *
     * @param  object    $repo
     * @access protected
     * @return array
     */
    protected function getBrowseInfo($repo)
    {
        if($repo->SCM == 'Gitlab')
        {
            $scm = $this->app->loadClass('scm');
            $scm->setEngine($repo);
            $urls['project']['url']  = $scm->engine->getApiUrl("project");
            $urls['branches']['url'] = $scm->engine->getApiUrl('branches');
            $urls['tags']['url']     = $scm->engine->getApiUrl('tags');

            $this->app->loadClass('requests', true);
            $result = requests::request_multiple($urls);

            if($result['project']->status_code == 200)
            {
                $project = json_decode($result['project']->body);
                if(!is_object($project)) $project = new stdclass();

                $this->loadModel('gitlab')->setProject((int)$repo->gitService, (int)$repo->serviceProject, $project);
            }
            if(!empty($result['branches']->headers) && !is_null($result['branches']->headers->offsetGet('x-total')))
            {
                $branchList = json_decode($result['branches']->body);
                $totalPages = $result['branches']->headers->offsetGet('x-total-pages');
                if($totalPages > 1)
                {
                    $requests = array();
                    for($page = 2; $page <= $totalPages; $page++)
                    {
                        $requests[$page]['url'] = str_replace('page=1', "page={$page}", $urls['branches']['url']);
                    }

                    $reponses = requests::request_multiple($requests, array('timeout' => 10));
                    foreach($reponses as $reponse)
                    {
                        $data = json_decode($reponse->body);
                        if(!is_array($data)) continue;
                        $branchList = array_merge($branchList, $data);
                    }
                }

                $branches = array();
                $default  = array();
                if(!empty($branchList) && is_array($branchList))
                {
                    foreach($branchList as $branch)
                    {
                        if(!isset($branch->name)) continue;
                        if($branch->default)
                        {
                            $default[$branch->name] = $branch->name;
                        }
                        else
                        {
                            $branches[$branch->name] = $branch->name;
                        }
                    }

                    if(empty($branches) and empty($default)) $branches['master'] = 'master';
                    asort($branches);
                    $branches = $default + $branches;
                }
            }

            if(!empty($result['tags']->headers) && !is_null($result['tags']->headers->offsetGet('x-total')))
            {
                $tagList    = json_decode($result['tags']->body);
                $totalPages = $result['tags']->headers->offsetGet('x-total-pages');
                if($totalPages > 1)
                {
                    $requests = array();
                    for($page = 2; $page <= $totalPages; $page++)
                    {
                        $requests[$page]['url'] = str_replace('page=1', "page={$page}", $urls['tags']['url']);
                    }

                    $reponses = requests::request_multiple($requests, array('timeout' => 10));
                    foreach($reponses as $reponse)
                    {
                        $data = json_decode($reponse->body);
                        if(!is_array($data)) continue;
                        $tagList = array_merge($tagList, $data);
                    }
                }

                $tags = array();
                if(!empty($tagList) && is_array($tagList))
                {
                    foreach($tagList as $tag) $tags[] = $tag->name;
                }
            }

            return array(isset($branches) ? $branches : false, isset($tags) ? $tags : false);
        }
    }

    /**
     * 为git类型版本库设置分支和tag。
     * Set branch or tag for git.
     *
     * @param  object    $repo
     * @param  string    $branchID
     * @access protected
     * @return array
     */
    protected function setBranchTag($repo, $branchID)
    {
        if(in_array($repo->SCM, $this->config->repo->gitTypeList))
        {
            if($repo->SCM == 'Gitlab') list($branchInfo, $tagInfo) = $this->getBrowseInfo($repo);

            $scm = $this->app->loadClass('scm');
            $scm->setEngine($repo);
            $branches = isset($branchInfo) && $branchInfo !== false ? $branchInfo : $scm->branch();
            $initTags = isset($tagInfo) && $tagInfo !== false ? $tagInfo : $scm->tags('');
            $tags     = array();
            foreach($initTags as $tag) $tags[$tag] = $tag;

            if(empty($branchID) and $this->cookie->repoBranch && $this->session->repoID == $repo->id) $branchID = $this->cookie->repoBranch;
            if(!isset($branches[$branchID]) && !isset($tags[$branchID])) $branchID = (string)key($branches);
            if($branchID) $this->setRepoBranch($branchID);

            return array($branchID, $branches, $tags);
        }
        else
        {
            $this->setRepoBranch('');
            return array($branchID, array(), array());
        }
    }

    /**
     * 获取commits列表
     * Get commits.
     *
     * @param  object    $repo
     * @param  string    $path
     * @param  string    $revision
     * @param  string    $type
     * @param  object    $pager
     * @param  int       $objectID
     * @access protected
     * @return array
     */
    protected function getCommits($repo, $path, $revision, $type, $pager, $objectID)
    {
        $revisions = $this->repo->getCommits($repo, $path, $revision, $type, $pager);
        $pathInfo  = '&root=' . $this->repo->encodePath(empty($path) ? '/' : $path);
        foreach($revisions as $item)
        {
            $item->link     = $this->repo->createLink('revision', "repoID={$repo->id}&objectID=$objectID&revision={$item->revision}" . $pathInfo);
            $item->revision = ($repo->SCM != 'Subversion' && $item->revision) ? substr($item->revision, 0, 10) : $item->revision;
        }

        return $revisions;
    }

    /**
     * 设置session信息。
     * Set session.
     *
     * @access protected
     * @return void
     */
    protected function setBrowseSession()
    {
        $this->setBackSession('list', true);

        session_start();
        $this->session->set('revisionList', $this->app->getURI(true));
        $this->session->set('gitlabBranchList', $this->app->getURI(true));
        session_write_close();
    }

    /**
     * 构建版本库搜索框。
     * Build repo search form.
     *
     * @param  array     $products
     * @param  array     $projects
     * @param  int       $objectID
     * @param  string    $orderBy
     * @param  int       $recPerPage
     * @param  int       $pageID
     * @param  int       $param
     * @access protected
     * @return void
     */
    protected function buildRepoSearchForm($products, $projects, $objectID, $orderBy, $recPerPage, $pageID, $param)
    {
        session_start();
        $this->config->repo->search['params']['product']['values']  = $products;
        $this->config->repo->search['params']['projects']['values'] = $projects;
        $this->config->repo->search['actionURL']   = $this->createLink('repo', 'maintain', "objectID={$objectID}&orderBy={$orderBy}&recPerPage={$recPerPage}&pageID={$pageID}&type=bySearch&param=myQueryID");
        $this->config->repo->search['queryID']     = $param;
        $this->config->repo->search['onMenuBar']   = 'yes';
        $this->loadModel('search')->setSearchParams($this->config->repo->search);
        session_write_close();
    }

    /**
     * 获取关联产品模块。
     * Get link product modules.
     *
     * @param  array     $products
     * @param  string    $type story|task|bug
     * @access protected
     * @return array
     */
    protected function getLinkModules($products, $type)
    {
        $modules  = array();
        foreach($products as $productID => $product)
        {
            $productModules = $this->loadModel('tree')->getModulePairs($productID, $type);
            foreach($productModules as $key => $module) $modules[$key] = $product->name . ' / ' . $module;
        }

        return $modules;
    }

    /**
     * 获取关联产品分支。
     * Get link product branches.
     *
     * @param  array     $products
     * @access protected
     * @return array
     */
    protected function getLinkBranches($products)
    {
        $productBranches = array();
        foreach($products as $product)
        {
            if($product->type != 'normal')
            {
                $branches = $this->loadModel('branch')->getPairs($product->id, 'noempty');
                foreach($branches as $branchID => $branchName)
                {
                    $branches[$branchID] = $product->name . ' / ' . $branchName;
                }

                $productBranches += $branches;
            }
        }

        return $productBranches;
    }

    /**
     * 获取产品关联执行列表。
     * Get link product executions.
     *
     * @param  array     $products
     * @access protected
     * @return array
     */
    protected function getLinkExecutions($products)
    {
        $executions = array();
        foreach($products as $product)
        {
            $productExecutions = $this->loadModel('product')->getExecutionPairsByProduct($product->id);
            $executions       += $productExecutions;
        }

        return $executions;
    }

    /**
     * 构建需求搜索表格。
     * Build story search form.
     *
     * @param  int       $repoID
     * @param  string    $revision
     * @param  int       $queryID
     * @param  array     $products
     * @param  array     $modules
     * @access protected
     * @return void
     * @param string $browseType
     */
    protected function buildStorySearchForm($repoID, $revision, $browseType, $queryID, $products, $modules)
    {
        unset($this->lang->story->statusList['closed']);
        $storyStatusList = $this->lang->story->statusList;

        $this->config->product->search['actionURL']                   = $this->createLink('repo', 'linkStory', "repoID=$repoID&revision=$revision&browseType=bySearch&queryID=myQueryID");
        $this->config->product->search['queryID']                     = $queryID;
        $this->config->product->search['style']                       = 'simple';
        $this->config->product->search['params']['plan']['values']    = $this->loadModel('productplan')->getForProducts(array_keys($products));
        $this->config->product->search['params']['module']['values']  = $modules;
        $this->config->product->search['params']['status']            = array('operator' => '=', 'control' => 'select', 'values' => $storyStatusList);
        $this->config->product->search['params']['product']['values'] = helper::arrayColumn($products, 'name', 'id');

        unset($this->config->product->search['fields']['roadmap']);
        unset($this->config->product->search['params']['roadmap']);
        unset($this->config->product->search['fields']['grade']);
        unset($this->config->product->search['params']['grade']);

        $productBranches = $this->getLinkBranches($products);
        if(empty($productBranches))
        {
            unset($this->config->product->search['fields']['branch']);
            unset($this->config->product->search['params']['branch']);
        }
        else
        {
            $this->lang->product->branch = sprintf($this->lang->product->branch, $this->lang->product->branchName['branch']);
            $this->config->product->search['fields']['branch'] = sprintf($this->lang->product->branch, $this->lang->product->branchName['branch']);
            $this->config->product->search['params']['branch']['values'] = $productBranches;
        }

        session_start();
        $this->loadModel('search')->setSearchParams($this->config->product->search);
        session_write_close();
    }

    /**
     * 获取关联需求列表。
     * Get link stories list.
     *
     * @param  int       $repoID
     * @param  string    $revision
     * @param  string    $browseType
     * @param  array     $productIds
     * @param  string    $orderBy
     * @param  object    $pager
     * @param  int       $queryID
     * @access protected
     * @return array
     * @param mixed[] $products
     */
    protected function getLinkStories($repoID, $revision, $browseType, $products, $orderBy, $pager, $queryID)
    {
        $linkedStories = $this->repo->getRelationByCommit($repoID, $revision, 'story');
        $allStories    = array();
        if($browseType == 'bySearch')
        {
            foreach($products as $productID => $product)
            {
                $productStories = $this->loadModel('story')->getBySearch($productID, 'all', $queryID, $orderBy, 0, 'story', array_keys($linkedStories));
                $allStories     = array_merge($allStories, $productStories);
            }

            $allStories = array_filter($allStories, function($story) { return $story->isParent == '0'; });
        }
        else
        {
            foreach($products as $productID => $product)
            {
                $productStories = $this->loadModel('story')->getProductStories($productID, 'all', '0', 'draft,active,changed', 'story', $orderBy, true, array_keys($linkedStories));
                $allStories     = array_merge($allStories, $productStories);
            }
        }

        return $this->getDataPager($allStories, $pager);
    }

    /**
     * 获取数据根据分页。
     *  Get data by pager.
     *
     * @param  array     $data
     * @param  object    $pager
     * @access protected
     * @return array
     */
    protected function getDataPager($data, $pager)
    {
        $pager->setRecTotal(count($data));
        $pager->setPageTotal();

        $dataList = array_chunk($data, $pager->recPerPage);
        $pageData = empty($dataList) ? array() : $dataList[$pager->pageID - 1];

        return $pageData;
    }

    /**
     * 构建bug搜索表格。
     * Build bug search form.
     *
     * @param  int       $repoID
     * @param  string    $revision
     * @param  string    $browseType
     * @param  int       $queryID
     * @param  array     $products
     * @param  array     $modules
     * @access protected
     * @return void
     */
    protected function buildBugSearchForm($repoID, $revision, $browseType, $queryID, $products, $modules)
    {
        $productIds = array_keys($products);
        $this->config->bug->search['params']['status']['values']        = array_slice($this->lang->bug->statusList, 1, 1);
        $this->config->bug->search['actionURL']                         = $this->createLink('repo', 'linkBug', "repoID=$repoID&revision=$revision&browseType=bySearch&queryID=myQueryID");
        $this->config->bug->search['queryID']                           = $queryID;
        $this->config->bug->search['style']                             = 'simple';
        $this->config->bug->search['params']['plan']['values']          = $this->loadModel('productplan')->getForProducts($productIds);
        $this->config->bug->search['params']['module']['values']        = $modules;
        $this->config->bug->search['params']['execution']['values']     = $this->getLinkExecutions($products);
        $this->config->bug->search['params']['openedBuild']['values']   = $this->loadModel('build')->getBuildPairs($productIds, 'all', '');
        $this->config->bug->search['params']['resolvedBuild']['values'] = $this->loadModel('build')->getBuildPairs($productIds, 'all', '');
        $this->config->bug->search['params']['product']['values']       = helper::arrayColumn($products, 'name', 'id');

        $productBranches = $this->getLinkBranches($products);
        if(empty($productBranches))
        {
            unset($this->config->bug->search['fields']['branch']);
            unset($this->config->bug->search['params']['branch']);
        }
        else
        {
            $this->lang->product->branch = sprintf($this->lang->product->branch, $this->lang->product->branchName['branch']);
            $this->config->bug->search['fields']['branch']           = sprintf($this->lang->product->branch, $this->lang->product->branchName['branch']);
            $this->config->bug->search['params']['branch']['values'] = $productBranches;
        }
        session_start();
        $this->loadModel('search')->setSearchParams($this->config->bug->search);
        session_write_close();
    }

    /**
     * 获取关联bug列表。
     * Get link bugs list.
     *
     * @param  int       $repoID
     * @param  string    $revision
     * @param  string    $browseType
     * @param  array     $products
     * @param  string    $orderBy
     * @param  object    $pager
     * @param  int       $queryID
     * @access protected
     * @return array
     */
    protected function getLinkBugs($repoID, $revision, $browseType, $products, $orderBy, $pager, $queryID)
    {
        $linkedBugs = $this->repo->getRelationByCommit($repoID, $revision, 'bug');
        $allBugs    = array();
        if($browseType == 'bySearch')
        {
                $allBugs = $this->loadModel('bug')->getBySearch('bug', array_keys($products), 0, 0, 0, $queryID, implode(',', array_keys($linkedBugs)), $orderBy);
                foreach($allBugs as $bugID => $bug)
                {
                    if($bug->status != 'active') unset($allBugs[$bugID]);
                }
        }
        else
        {
            foreach($products as $productID => $product)
            {
                $productBugs = $this->loadModel('bug')->getActiveBugs($product->id, 0, '0', array_keys($linkedBugs), null, $orderBy);
                $allBugs     = array_merge($allBugs, $productBugs);
            }
        }

        $allBugs = $this->getDataPager($allBugs, $pager);
        foreach($allBugs as $bug) $bug->statusText = $this->processStatus('bug', $bug);
        return $allBugs;
    }

    /**
     * 构建任务搜索表格。
     * Build task search form.
     *
     * @param  int       $repoID
     * @param  string    $revision
     * @param  string    $browseType
     * @param  int       $queryID
     * @param  array     $modules
     * @param  array     $executionPairs
     * @access protected
     * @return void
     */
    protected function buildTaskSearchForm($repoID, $revision, $browseType, $queryID, $modules, $executionPairs)
    {
        $this->config->execution->search['actionURL']                     = $this->createLink('repo', 'linkTask', "repoID=$repoID&revision=$revision&browseType=bySearch&queryID=myQueryID", '', true);
        $this->config->execution->search['queryID']                       = $queryID;
        $this->config->execution->search['style']                         = 'simple';
        $this->config->execution->search['params']['module']['values']    = $modules;
        $this->config->execution->search['params']['execution']['values'] = array('' => '') + $executionPairs;

        session_start();
        $this->loadModel('search')->setSearchParams($this->config->execution->search);
        session_write_close();
    }

    /**
     * 获取关联任务列表。
     * Get link tasks list.
     *
     * @param  int       $repoID
     * @param  string    $revision
     * @param  string    $browseType
     * @param  array     $products
     * @param  string    $orderBy
     * @param  object    $pager
     * @param  int       $queryID
     * @param  array     $executionPairs
     * @access protected
     * @return array
     */
    protected function getLinkTasks($repoID, $revision, $browseType, $products, $orderBy, $pager, $queryID, $executionPairs)
    {
        $allTasks = array();
        foreach($executionPairs as $executionID => $executionName)
        {
            $tasks     = $this->loadModel('execution')->getTasks(0, $executionID, array(), $browseType, $queryID, 0, $orderBy, null);
            $allTasks += $tasks;
        }

        if($browseType == 'bysearch')
        {
            foreach($allTasks as $key => $task)
            {
                if(!empty($task->children))
                {
                    $allTasks = array_merge($task->children, $allTasks);
                    unset($task->children);
                }
            }
            foreach($allTasks as $key => $task)
            {
                if($task->status == 'closed') unset($allTasks[$key]);
            }
        }

        /* Filter linked tasks. */
        $linkedTasks   = $this->repo->getRelationByCommit($repoID, $revision, 'task');
        $linkedTaskIDs = array_keys($linkedTasks);
        foreach($allTasks as $key => $task)
        {
            if(in_array($task->id, $linkedTaskIDs)) unset($allTasks[$key]);
        }

        return $this->getDataPager($allTasks, $pager);
    }

    /**
     * 关联对象。
     * Link object.
     *
     * @param  int       $repoID
     * @param  string    $revision
     * @param  string    $type story|bug|task
     * @access protected
     * @return array
     */
    protected function linkObject($repoID, $revision, $type)
    {
        $this->repo->link($repoID, $revision, $type);
        if(dao::isError()) return array('result' => 'fail', 'message' => dao::getError());

        return array('result' => 'success', 'callback' => "$('.tab-content .active iframe')[0].contentWindow.getRelation('$revision')", 'closeModal' => true);
    }

    /**
     * Get SCM by service host.
     *
     * @param  int    $serviceHost
     * @access protected
     * @return string
     */
    protected function getSCM($serviceHost)
    {
        $server = $this->loadModel('pipeline')->getByID($serviceHost);

        foreach($this->lang->repo->scmList as $scmKey => $scmLang)
        {
            if($server->type == strtolower($scmKey)) return $scmKey;
        }

        return '';
    }

    /**
     * 检查删除版本库的错误。
     * Check repo delete error.
     *
     * @param  int $repoID
     * @access protected
     * @return string
     */
    protected function checkDeleteError($repoID)
    {
        $relationIds = $this->dao->select('distinct AID as AID')->from(TABLE_RELATION)
            ->where('extra')->eq($repoID)
            ->andWhere('AType')->eq('design')
            ->fetchAll();
        $error = '';
        if($relationIds)
        {
            $tmpDesignLinks = [];
            foreach ($relationIds as $value)
            {
                array_push($tmpDesignLinks, html::a($this->createLink('design', 'view', 'designID=' . $value->AID), $value->AID, '_blank', '', false));
            }
            $error .= sprintf($this->lang->repo->error->deleted, implode(', ', $tmpDesignLinks));
        }
        $linkBranchs = $this->repo->getLinkedBranch(0, '', $repoID);
        if(!empty($linkBranchs))
        {
            $tmpLinkBranchs = [];
            foreach($linkBranchs as $value)
            {
                if(!array_key_exists($value->AType, $tmpLinkBranchs)) $tmpLinkBranchs[$value->AType] = [];

                if(!in_array($value->BType, $tmpLinkBranchs[$value->AType])) array_push($tmpLinkBranchs[$value->AType], $value->BType);
            }
            foreach($tmpLinkBranchs as $type=>$value)
            {
                $error .= sprintf($this->lang->repo->error->linkedBranch, $this->lang->$type->common, html::a(
                    $this->createLink('repo', 'browse', 'repoID=' . $repoID),
                    implode(', ', $value), '_blank', '', false
                ));
            }
        }
        $jobs = $this->dao->select('*')->from(TABLE_JOB)->where('repo')->eq($repoID)->andWhere('deleted')->eq('0')->fetchAll();
        if($jobs) $error .= sprintf($this->lang->repo->error->linkedJob, html::a($this->createLink('job', 'browse'), implode(', ', array_column($jobs, 'id')), '_blank', '', false));
        return $error;
    }

    /**
     * 跳转到版本库的diff页面。
     * Redirect to diff page.
     *
     * @param  int       $repoID
     * @param  int       $objectID
     * @param  string    $arrange
     * @param  int       $isBranchOrTag
     * @param  string    $file
     * @access protected
     * @return void
     */
    protected function locateDiffPage($repoID, $objectID, $arrange, $isBranchOrTag, $file)
    {
        $oldRevision = isset($this->post->revision[1]) ? $this->post->revision[1] : '';
        $newRevision = isset($this->post->revision[0]) ? $this->post->revision[0] : '';

        if($this->post->encoding)      $encoding      = $this->post->encoding;
        if($this->post->isBranchOrTag) $isBranchOrTag = (int)$this->post->isBranchOrTag;

        if($this->post->arrange) $arrange = $this->post->arrange;
        helper::setcookie('arrange', $arrange);

        return $this->locate($this->repo->createLink('diff', "repoID={$repoID}&objectID={$objectID}&entry={$file}&oldrevision={$oldRevision}&newRevision={$newRevision}&showBug=0&encoding={$encoding}&isBranchOrTag={$isBranchOrTag}"));
    }

    /**
     * 设置对比信息的编码格式。
     * Set encoding for diff.
     *
     * @param  array     $diffs
     * @param  string    $encoding
     * @access protected
     * @return array
     */
    protected function encodingDiff($diffs, $encoding)
    {
        foreach($diffs as $diff)
        {
            $diff->fileName = helper::convertEncoding($diff->fileName, $encoding);
            if(empty($diff->contents)) continue;

            foreach($diff->contents as $content)
            {
                if(empty($content->lines)) continue;

                foreach($content->lines as $lines)
                {
                    if(empty($lines->line)) continue;
                    $lines->line = helper::convertEncoding($lines->line, $encoding);
                }
            }
        }

        return $diffs;
    }

    /**
     * 获取代码同步本地的日志。
     * Get sync log.
     *
     * @param  object    $repo
     * @access protected
     * @return string
     */
    protected function syncLocalCommit($repo)
    {
        $logFile = realPath($this->app->getTmpRoot() . $this->config->repo->repoSyncLog->logFilePrefix . strtolower($repo->SCM) . ".{$repo->name}.log");
        if($logFile && file_exists($logFile))
        {
            $content  = file($logFile);
            foreach($content as $line)
            {
                if($this->strposAry($line, $this->config->repo->repoSyncLog->fatal) !== false) return $line;
                if($this->strposAry($line, $this->config->repo->repoSyncLog->failed) !== false) return $line;
            }

            $lastLine = $content[count($content) - 1];
            if($this->strposAry($lastLine, $this->config->repo->repoSyncLog->done) === false)
            {
                if($this->strposAry($lastLine, $this->config->repo->repoSyncLog->emptyRepo) !== false)
                {
                    @unlink($logFile);
                }
                elseif($this->strposAry($lastLine, $this->config->repo->repoSyncLog->total) !== false)
                {
                    $logContent = file_get_contents($logFile);
                    if($this->strposAry($logContent, $this->config->repo->repoSyncLog->finishCount) !== false and $this->strposAry($logContent, $this->config->repo->repoSyncLog->finishCompress) !== false)
                    {
                        @unlink($logFile);
                    }
                    else
                    {
                        return $this->config->repo->repoSyncLog->one;
                    }
                }
                else
                {
                    return $this->config->repo->repoSyncLog->one;
                }
            }
            else
            {
                @unlink($logFile);
            }
        }

        return '';
    }

    /**
     * 获取需要同步的分支。
     * Get sync branches.
     *
     * @param  object    $repo
     * @param  string    $branchID
     * @access protected
     * @return array
     */
    protected function getSyncBranches($repo, &$branchID = '')
    {
        $branches = array();
        if(in_array($repo->SCM, $this->config->repo->gitTypeList))
        {
            $branches = $this->scm->branch();
            if(empty($branches)) return array();

            $tags = $this->scm->tags('');
            foreach($tags as $tag) $branches[$tag] = $tag;

            if($branches)
            {
                /* Init branchID. */
                if($this->cookie->syncBranch) $branchID = $this->cookie->syncBranch;
                if(!isset($branches[$branchID])) $branchID = '';
                if(empty($branchID)) $branchID = key($branches);

                /* Get unsynced branches. */
                foreach($branches as $branch)
                {
                    unset($branches[$branch]);
                    if($branch == $branchID) break;
                }

                $this->setRepoBranch($branchID);
                helper::setcookie("syncBranch", $branchID, 0, $this->config->webRoot, '', $this->config->cookieSecure, true);
            }
        }

        return $branches;
    }

    /**
     * 获取同步结果。
     * Get sync result.
     *
     * @param  object    $repo
     * @param  array     $branches
     * @param  string    $branchID
     * @param  int       $commitCount
     * @param  string    $type
     * @access protected
     * @return string|int
     */
    protected function checkSyncResult($repo, $branches, $branchID, $commitCount, $type)
    {
        if(empty($commitCount) && !$repo->synced)
        {
            if(in_array($repo->SCM, $this->config->repo->gitTypeList))
            {
                if($branchID) $this->repo->saveExistCommits4Branch($repo->id, $branchID);
                if($branches)
                {
                    $branchID = array_shift($branches);
                    helper::setcookie("syncBranch", $branchID);
                }
                else
                {
                    $branchID = '';
                }

                if($branchID) $this->repo->fixCommit($repo->id);
            }

            if(empty($branchID) || in_array($repo->SCM, $this->config->repo->notSyncSCM))
            {
                helper::setcookie("syncBranch", '');

                $this->repo->markSynced($repo->id);
                return $this->config->repo->repoSyncLog->finish;
            }
        }

        $this->dao->update(TABLE_REPO)->set('commits=commits + ' . $commitCount)->where('id')->eq($repo->id)->exec();
        return $type == 'batch' ? $commitCount : $this->config->repo->repoSyncLog->finish;
    }

    /**
     * 设置返回链接。
     * Set back session.
     *
     * @param  string $type
     * @param  bool   $withOtherModule
     * @access public
     * @return void
     */
    public function setBackSession($type = 'list', $withOtherModule = false)
    {
        session_start();
        $uri = $this->app->getURI(true);
        if(!empty($_GET) and $this->config->requestType == 'PATH_INFO') $uri .= (strpos($uri, '?') === false ? '?' : '&') . http_build_query($_GET);

        $backKey = 'repo' . ucfirst(strtolower($type));
        $this->session->set($backKey, $uri);

        if($type == 'list') unset($_SESSION['repoView']);
        if($withOtherModule)
        {
            $this->session->set('bugList', $uri, 'qa');
            $this->session->set('taskList', $uri, 'execution');
        }
        session_write_close();
    }

    /**
     * 设置代码库分支。
     * Set repo branch.
     *
     * @param  string $branch
     * @access public
     * @return void
     */
    public function setRepoBranch($branch)
    {
        helper::setcookie("repoBranch", $branch, 0, $this->config->webRoot, '', $this->config->cookieSecure, false);
        $_COOKIE['repoBranch'] = $branch;
    }

    /**
     * 检查是否是二进制文件。
     * Check content is binary.
     *
     * @param  string $content
     * @param  string $suffix
     * @access public
     * @return bool
     */
    public function isBinary($content, $suffix = '')
    {
        if(strpos($this->config->repo->binary, "|$suffix|") !== false) return true;

        $blk = substr($content, 0, 512);
        return (
            substr_count($blk, "^\r\n")/512 > 0.3 ||
            substr_count($blk, "^ -~")/512 > 0.3 ||
            substr_count($blk, "\x00") > 0
        );
    }

    /**
     * 检查字符串是否在数组元素中。
     * Check str in array.
     *
     * @param  string $str
     * @param  array  $checkAry
     * @access public
     * @return bool
     */
    public function strposAry($str, $checkAry)
    {
        foreach($checkAry as $check)
        {
            if(mb_strpos($str, $check) !== false) return true;
        }

        return false;
    }

    /**
     * 获取详情页面目录树。
     * Get view tree.
     *
     * @param  object    $repo
     * @param  string    $entry
     * @param  string    $revision
     * @access protected
     * @return array
     */
    protected function getViewTree($repo, $entry, $revision)
    {
        if($repo->SCM == 'Gitlab') return $this->repo->getGitlabFilesByPath($repo, '', (string)$this->cookie->repoBranch);

        if($repo->SCM != 'Subversion') return $this->repo->getFileTree($repo);

        $scm = $this->app->loadClass('scm');
        $scm->setEngine($repo);
        $tree = $scm->ls($entry, (string)$revision);
        foreach($tree as &$file)
        {
            $base64Name = $this->repo->encodePath($file->path);

            $file->path = trim($file->path, '/');
            if(!isset($file->id))    $file->id    = $base64Name;
            if(!isset($file->key))   $file->key   = $base64Name;
            if(!isset($file->text))  $file->text  = trim($file->name, '/');
            if($file->kind == 'dir') $file->items = array('url' => helper::createLink('repo', 'ajaxGetFiles', "repoID={$repo->id}&branch={$revision}&path=" . helper::safe64Encode($file->path)));
        }

        return $tree;
    }

    /**
     * 检查代码库是否能正常访问。
     * Check repo connected.
     *
     * @param  object    $repo
     * @access protected
     * @return bool
     */
    protected function checkRepoInternet($repo)
    {
        if(!$repo) return false;

        $repoUrl = '';
        if(empty($repoUrl) && isset($repo->path)    && substr($repo->path, 0, 4) == 'http')    $repoUrl = $repo->path;
        if(empty($repoUrl) && isset($repo->client)  && substr($repo->client, 0, 4) == 'http')  $repoUrl = $repo->client;
        if(empty($repoUrl) && isset($repo->apiPath) && substr($repo->apiPath, 0, 4) == 'http') $repoUrl = $repo->apiPath;
        return $repoUrl && !$this->loadModel('admin')->checkInternet($repoUrl, 3);
    }

    /**
     * 翻译API返回错误信息。
     * Parse api log to client lang.
     *
     * @param  string $message
     * @access protected
     * @return string
     */
    protected function parseErrorContent($message)
    {
        foreach($this->lang->repo->apiError as $key => $pattern)
        {
            if(preg_match("/$pattern/i", $message))
            {
                $message = zget($this->lang->repo->errorLang, $key);
                break;
            }
        }

        return $message;
    }

    /**
     * 构建代码库路径。
     * Build repo paths.
     *
     * @param  array $repos
     * @access protected
     * @return array
     */
    protected function buildRepoPaths($repos)
    {
        $pathList = array();
        foreach($repos as $repoID => $path)
        {
            $paths  = explode('/', $path);
            $parent = '';
            foreach($paths as $path)
            {
                $path = trim($path);
                if($path === '') continue;

                $parentID = $parent == '' ? '0' : $pathList[$parent]['path'];
                $parent  .= $parent == '' ? $path : '/' . $path;
                if(!isset($pathList[$parent]))
                {
                    $pathList[$parent] = array(
                        'value'  => $repoID,
                        'parent' => $parentID,
                        'path'   => $parent,
                        'text'   => $path,
                    );
                }
            }
        }

        ksort($pathList);
        return $this->buildRepoTree($pathList, '0');
    }

    /**
     * 组装代码库生成父子结构。
     * Assemble repo path to generate parent-child structure.
     *
     * @param  array $pathList
     * @param  string $parent
     * @access protected
     * @return array
     */
    protected function buildRepoTree($pathList = array(), $parent = '0')
    {
        $treeList = array();
        $key      = 0;
        $pathName = array();
        $repoName = array();

        foreach($pathList as $path)
        {
            if ($path['parent'] == $parent)
            {
                $treeList[$key] = $path;
                $repoName[$key] = $path['text'];
                /* Default value is '~', because his ascii code is large in string. */
                $pathName[$key] = '~';

                $children = $this->buildRepoTree($pathList, $path['path']);

                if($children)
                {
                    unset($treeList[$key]['value']);
                    $treeList[$key]['disabled'] = true;
                    $treeList[$key]['items'] = $children;
                    $repoName[$key]          = '';
                    $pathName[$key]          = $path['path'];
                }
            }

            $key++;
        }

        array_multisort($pathName, SORT_ASC, $repoName, SORT_ASC, $treeList);
        return $treeList;
    }

    /**
     * 获取分支和标签列表的picker数据。
     * Get branch and tag picker data.
     *
     * @param  object    $scm
     * @access protected
     * @return array
     */
    protected function getBranchAndTagOptions($scm)
    {
        $options = array(
            array('text' => $this->lang->repo->branch, 'items' => array(), 'disabled' => true),
            array('text' => $this->lang->repo->tag,    'items' => array(), 'disabled' => true)
        );

        $branches = $scm->branch();
        foreach($branches as $branch) $options[0]['items'][] = array('text' => $branch, 'value' => $branch, 'key' => $branch);

        $tags = $scm->tags();
        foreach($tags as $tag) $options[1]['items'][] = array('text' => $tag, 'value' => $tag, 'key' => $tag);

        if(empty($tags))     unset($options[1]);
        if(empty($branches)) unset($options[0]);
        return $options;
    }

    /**
     * 获取代码库ID，并且设置页面的代码库数据。
     * Process repoID and set page repo data.
     *
     * @param  int       $repoID
     * @param  int       $objectID
     * @param  array     $scmList
     * @access protected
     * @return int
     */
    protected function processRepoID($repoID, $objectID, $scmList = array())
    {
        $hasSession = session_id() ? true : false;
        if(!$hasSession) session_start();
        if(!$repoID) $repoID = (int)$this->session->repoID;

        $repoPairs = array();
        if($this->app->tab == 'project' || $this->app->tab == 'execution')
        {
            if(!$scmList) $scmList = $this->config->repo->notSyncSCM;
            $repoList = $this->repo->getList($objectID);
            foreach($repoList as $repo)
            {
                if(!in_array($repo->SCM, $scmList)) continue;

                $repoPairs[$repo->id] = $repo->name;
            }
            if(!isset($repoPairs[$repoID])) $this->locate(inLink('browse', "repoID=$repoID&objectID=$objectID"));
        }

        $this->view->repoID    = $repoID;
        $this->view->repoPairs = $repoPairs;
        $repoID = $this->repo->saveState($repoID, $objectID);

        if(!$hasSession) session_write_close();
        return $repoID;
    }

    /**
     * 构建提交页面搜索表单。
     * Build commit search form.
     *
     * @param  int       $queryID
     * @param  string    $actionURL
     * @access protected
     * @return void
     */
    protected function buildSearchForm($queryID, $actionURL)
    {
        session_start();
        $this->config->repo->search = $this->config->repo->searchCommits;
        $this->config->repo->search['actionURL'] = $actionURL;
        $this->config->repo->search['queryID']   = $queryID;

        $this->loadModel('search')->setSearchParams($this->config->repo->search);
        session_write_close();
    }

    /**
     * 获取搜索表单字段。
     * Get search form field.
     *
     * @param  int       $queryID
     * @param  bool      $getSql
     * @access protected
     * @return object|string
     */
    protected function getSearchForm($queryID = 0, $getSql = false)
    {
        session_start();
        if($queryID)
        {
            $query = $this->loadModel('search')->getQuery($queryID);
            if($query)
            {
                $this->session->set('repoCommitsQuery', $query->sql);
                $this->session->set('repoCommitsForm', $query->form);
            }
            else
            {
                $this->session->set('repoCommitsQuery', ' 1 = 1');
            }
        }

        if($getSql)
        {
            $query = $this->session->repoCommitsQuery;
            $query = str_replace("`date`", 't1.`time`', $query);
            $query = str_replace("`committer`", 't1.`committer`', $query);
            $query = str_replace("`commit`", 't1.`revision`', $query);
        }
        else
        {
            $query = $this->getSearchFormQuery();
        }

        session_write_close();
        return $query;
    }

    /**
     * 获取搜索表单查询字段。
     * Get search form query field.
     *
     * @access protected
     * @return object
     */
    protected function getSearchFormQuery()
    {
        $query = new stdclass();
        $query->begin     = '';
        $query->end       = '';
        $query->committer = '';
        $query->commit    = '';
        if(!$this->session->repoCommitsForm) return $query;

        $this->app->loadClass('date');
        $lastWeek  = date::getLastWeek();
        $thisWeek  = date::getThisWeek();
        $lastMonth = date::getLastMonth();
        $thisMonth = date::getThisMonth();
        $yesterday = date::yesterday();
        $today     = date(DT_DATE1);
        foreach($this->session->repoCommitsForm as $field)
        {
            if(empty($field['value'])) continue;

            if(strpos($field['value'], '$') !== false)
            {
                $dateField = substr($field['value'], 1);
                $query->begin = substr(${$dateField}['begin'], 0, 10) . ' 00:00:00';
                $query->end   = substr(${$dateField}['end'], 0, 10) . ' 23:59:59';
            }
            elseif($field['field'] == 'date')
            {
                if($field['operator'] == '>=' || $field['operator'] == '=') $query->begin = $field['value'];
                if($field['operator'] == '>')  $query->begin = date('Y-m-d', strtotime("{$field['value']} +1 day"));
                if($field['operator'] == '<=') $query->end   = $field['value'];
                if($field['operator'] == '<')  $query->end   = date('Y-m-d', strtotime("{$field['value']} -1 day"));
                if($field['operator'] == '=')  $query->end   = $field['value'] . ' 23:59:59';
            }
            elseif(in_array($field['field'], array('committer', 'commit')) && $field['value'])
            {
                $query->{$field['field']} = $field['value'];
            }
        }

        return $query;
    }
}