801 lines
29 KiB
PHP
Executable File
801 lines
29 KiB
PHP
Executable File
<?php
|
|
declare(strict_types=1);
|
|
/**
|
|
* The tao file of project 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 sunguangming <sunguangming@easycorp.ltd>
|
|
* @link https://www.zentao.net
|
|
*/
|
|
class projectTao extends projectModel
|
|
{
|
|
/**
|
|
* Update project table when start a project.
|
|
*
|
|
* @param int $projectID
|
|
* @param object $project
|
|
* @access protected
|
|
* @return bool
|
|
*/
|
|
protected function doStart(int $projectID, object $project): bool
|
|
{
|
|
$this->dao->update(TABLE_PROJECT)->data($project)
|
|
->autoCheck()
|
|
->check($this->config->project->start->requiredFields, 'notempty')
|
|
->checkIF($project->realBegan != '', 'realBegan', 'le', helper::today())
|
|
->checkFlow()
|
|
->where('id')->eq($projectID)
|
|
->exec();
|
|
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* Update project table when suspend a project.
|
|
*
|
|
* @param int $projectID
|
|
* @param object $project
|
|
*
|
|
* @access protected
|
|
* @return bool
|
|
*/
|
|
protected function doSuspend(int $projectID, object $project): bool
|
|
{
|
|
$this->dao->update(TABLE_PROJECT)->data($project)
|
|
->autoCheck()
|
|
->checkFlow()
|
|
->where('id')->eq($projectID)
|
|
->exec();
|
|
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* Update project table when close a project.
|
|
*
|
|
* @param int $projectID
|
|
* @param object $project
|
|
* @param object $oldProject
|
|
*
|
|
* @access protected
|
|
* @return bool
|
|
*/
|
|
protected function doClosed(int $projectID, object $project, object $oldProject): bool
|
|
{
|
|
$this->lang->error->ge = $this->lang->project->ge;
|
|
$this->dao->update(TABLE_PROJECT)->data($project)
|
|
->autoCheck()
|
|
->check($this->config->project->close->requiredFields, 'notempty')
|
|
->checkIF($project->realEnd != '', 'realEnd', 'le', helper::today())
|
|
->checkIF($project->realEnd != '', 'realEnd', 'ge', $oldProject->realBegan)
|
|
->checkFlow()
|
|
->where('id')->eq($projectID)
|
|
->exec();
|
|
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* Update project table when activate a project.
|
|
*
|
|
* @param int $projectID
|
|
* @param object $project
|
|
* @access protected
|
|
* @return bool
|
|
*/
|
|
protected function doActivate(int $projectID ,object $project): bool
|
|
{
|
|
$this->dao->update(TABLE_PROJECT)->data($project , 'readjustTime, readjustTask, comment')
|
|
->autoCheck()
|
|
->checkFlow()
|
|
->where('id')->eq((int)$projectID)
|
|
->exec();
|
|
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 更新项目主表。
|
|
* Update project table when edit a project.
|
|
*
|
|
* @param int $projectID
|
|
* @param object $project
|
|
* @access protected
|
|
* @return bool
|
|
*/
|
|
protected function doUpdate(int $projectID, object $project): bool
|
|
{
|
|
$this->dao->update(TABLE_PROJECT)->data($project)
|
|
->autoCheck('begin,end')
|
|
->check('end', 'gt', $project->begin)
|
|
->check('name', 'unique', "id != $projectID and `type` = 'project' and `parent` = '{$project->parent}' and `model` = '{$project->model}' and `deleted` = '0'")
|
|
->check('code', 'unique', "id != $projectID and `type` = 'project' and `model` = '{$project->model}' and `deleted` = '0'")
|
|
->checkFlow()
|
|
->where('id')->eq($projectID)
|
|
->exec();
|
|
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 新增项目。
|
|
* Insert a project to project table.
|
|
*
|
|
* @param object $project
|
|
* @access protected
|
|
* @return bool
|
|
*/
|
|
protected function doCreate(object $project): bool
|
|
{
|
|
$this->lang->error->unique = $this->lang->error->repeat;
|
|
$this->dao->insert(TABLE_PROJECT)->data($project)
|
|
->autoCheck()
|
|
->batchCheck($this->config->project->create->requiredFields, 'notempty')
|
|
->checkIF(!empty($project->name), 'name', 'unique', "`type`='project' and `parent` = $project->parent and `model` = '{$project->model}' and `deleted` = '0'")
|
|
->checkIF(!empty($project->code), 'code', 'unique', "`type`='project' and `model` = '{$project->model}' and `deleted` = '0'")
|
|
->checkIF($project->end != '', 'end', 'gt', $project->begin)
|
|
->checkFlow()
|
|
->exec();
|
|
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* Fetch undone tasks.
|
|
*
|
|
* @param int $projectID
|
|
* @access protected
|
|
* @return array
|
|
*/
|
|
protected function fetchUndoneTasks(int $projectID): array
|
|
{
|
|
return $this->dao->select('id,estStarted,deadline,status')->from(TABLE_TASK)
|
|
->where('deadline')->notZeroDate()
|
|
->andWhere('status')->in('wait,doing')
|
|
->andWhere('project')->eq($projectID)
|
|
->fetchAll();
|
|
}
|
|
|
|
/**
|
|
* Update start and end date of tasks.
|
|
*
|
|
* @param array $tasks
|
|
* @access protected
|
|
* @return bool
|
|
*/
|
|
protected function updateTasksStartAndEndDate(array $tasks, object $oldProject, object $project): bool
|
|
{
|
|
$beginTimeStamp = strtotime($project->begin);
|
|
|
|
foreach($tasks as $task)
|
|
{
|
|
if($task->status == 'wait' && !helper::isZeroDate($task->estStarted))
|
|
{
|
|
$taskDays = helper::diffDate($task->deadline, $task->estStarted);
|
|
$taskOffset = helper::diffDate($task->estStarted, $oldProject->begin);
|
|
|
|
$estStartedTimeStamp = $beginTimeStamp + $taskOffset * 24 * 3600;
|
|
$estStarted = date('Y-m-d', $estStartedTimeStamp);
|
|
$deadline = date('Y-m-d', $estStartedTimeStamp + $taskDays * 24 * 3600);
|
|
|
|
if($estStarted > $project->end) $estStarted = $project->end;
|
|
if($deadline > $project->end) $deadline = $project->end;
|
|
|
|
$this->dao->update(TABLE_TASK)
|
|
->set('estStarted')->eq($estStarted)
|
|
->set('deadline')->eq($deadline)
|
|
->where('id')->eq($task->id)
|
|
->exec();
|
|
|
|
if(dao::isError()) return false;
|
|
}
|
|
else
|
|
{
|
|
$taskOffset = helper::diffDate($task->deadline, $oldProject->begin);
|
|
$deadline = date('Y-m-d', $beginTimeStamp + $taskOffset * 24 * 3600);
|
|
|
|
if($deadline > $project->end) $deadline = $project->end;
|
|
$this->dao->update(TABLE_TASK)->set('deadline')->eq($deadline)->where('id')->eq($task->id)->exec();
|
|
|
|
if(dao::isError()) return false;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* 获取项目的详情，包含project表的所有内容。
|
|
* Get project details, including all contents of the project.
|
|
*
|
|
* @param int $projectID
|
|
* @param string $type
|
|
* @access protected
|
|
* @return object|false
|
|
*/
|
|
protected function fetchProjectInfo(int $projectID, string $type = ''): object|false
|
|
{
|
|
$project = $this->dao->select('*')
|
|
->from(TABLE_PROJECT)
|
|
->where('id')->eq($projectID)
|
|
->beginIF(!empty($type))->andWhere('`type`')->in($type)->fi()
|
|
->fetch();
|
|
|
|
/* Filter the date is empty or 1970. */
|
|
if($project && helper::isZeroDate($project->end)) $project->end = '';
|
|
return $project;
|
|
}
|
|
|
|
|
|
/**
|
|
* 创建项目后，创建默认的项目主库.
|
|
* Create doclib after create a project.
|
|
*
|
|
* @param int $projectID
|
|
* @param object $project
|
|
* @param object $program
|
|
* @access protected
|
|
* @return bool
|
|
*/
|
|
protected function createDocLib(int $projectID, object $project, object $program): bool
|
|
{
|
|
/* Create doc lib. */
|
|
$this->app->loadLang('doc');
|
|
$authorizedUsers = array();
|
|
|
|
if($project->parent && $project->acl == 'program')
|
|
{
|
|
$stakeHolders = $this->loadModel('stakeholder')->getStakeHolderPairs($project->parent);
|
|
$authorizedUsers = array_keys($stakeHolders);
|
|
|
|
foreach(explode(',', $project->whitelist) as $user)
|
|
{
|
|
if(empty($user)) continue;
|
|
$authorizedUsers[$user] = $user;
|
|
}
|
|
|
|
$authorizedUsers[$project->PM] = $project->PM;
|
|
$authorizedUsers[$project->openedBy] = $project->openedBy;
|
|
$authorizedUsers[$program->PM] = $program->PM;
|
|
$authorizedUsers[$program->openedBy] = $program->openedBy;
|
|
}
|
|
|
|
$lib = new stdclass();
|
|
$lib->project = $projectID;
|
|
$lib->name = $this->lang->doclib->main['project'];
|
|
$lib->type = 'project';
|
|
$lib->main = '1';
|
|
$lib->acl = 'default';
|
|
$lib->users = ',' . implode(',', array_filter($authorizedUsers)) . ',';
|
|
$lib->vision = zget($project, 'vision', 'rnd');
|
|
$lib->addedBy = $this->app->user->account;
|
|
$lib->addedDate = helper::now();
|
|
$this->dao->insert(TABLE_DOCLIB)->data($lib)->exec();
|
|
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 创建项目时，如果直接输入了产品名，则创建产品并与项目关联.
|
|
* Create doclib after create a project.
|
|
*
|
|
* @param int $projectID
|
|
* @param object $project
|
|
* @param object $postData
|
|
* @param object $program
|
|
* @access protected
|
|
* @return bool
|
|
*/
|
|
protected function createProduct(int $projectID, object $project, object $postData, object $program): bool
|
|
{
|
|
/* If parent not empty, link products or create products. */
|
|
$product = new stdclass();
|
|
$product->name = $project->hasProduct && !empty($postData->rawdata->productName) ? $postData->rawdata->productName : zget($project, 'name', '');
|
|
$product->shadow = zget($project, 'vision', 'rnd') == 'rnd' ? (int)empty($project->hasProduct) : 1;
|
|
$product->bind = $postData->rawdata->parent ? 0 : 1;
|
|
$product->program = $project->parent ? current(array_filter(explode(',', $program->path))) : 0;
|
|
$product->acl = $project->acl == 'open' ? 'open' : 'private';
|
|
$product->PO = $project->PM;
|
|
$product->QD = '';
|
|
$product->RD = '';
|
|
$product->whitelist = '';
|
|
$product->createdBy = $this->app->user->account;
|
|
$product->createdDate = helper::now();
|
|
$product->status = 'normal';
|
|
$product->line = 0;
|
|
$product->desc = '';
|
|
$product->createdVersion = $this->config->version;
|
|
$product->vision = zget($project, 'vision', 'rnd');
|
|
|
|
$this->app->loadConfig('product');
|
|
$this->dao->insert(TABLE_PRODUCT)->data($product)
|
|
->checkIF(!empty($product->name), 'name', 'unique', "`program` = {$product->program} and `deleted` = '0'")
|
|
->exec();
|
|
if(dao::isError()) return false;
|
|
|
|
$productID = $this->dao->lastInsertId();
|
|
if(!$project->hasProduct) $this->loadModel('personnel')->updateWhitelist(explode(',', $project->whitelist), 'product', $productID);
|
|
$this->loadModel('action')->create('product', $productID, 'opened');
|
|
$this->dao->update(TABLE_PRODUCT)->set('`order`')->eq($productID * 5)->where('id')->eq($productID)->exec();
|
|
if($product->acl != 'open') $this->loadModel('user')->updateUserView($productID, 'product');
|
|
|
|
$projectProduct = new stdclass();
|
|
$projectProduct->project = $projectID;
|
|
$projectProduct->product = $productID;
|
|
$projectProduct->branch = 0;
|
|
$projectProduct->plan = 0;
|
|
|
|
$this->dao->insert(TABLE_PROJECTPRODUCT)->data($projectProduct)->exec();
|
|
|
|
if($project->hasProduct)
|
|
{
|
|
/* Create doc lib. */
|
|
$this->app->loadLang('doc');
|
|
$lib = new stdclass();
|
|
$lib->product = $productID;
|
|
$lib->name = $this->lang->doclib->main['product'];
|
|
$lib->type = 'product';
|
|
$lib->main = '1';
|
|
$lib->acl = 'default';
|
|
$lib->addedBy = $this->app->user->account;
|
|
$lib->addedDate = helper::now();
|
|
$this->dao->insert(TABLE_DOCLIB)->data($lib)->exec();
|
|
}
|
|
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 获取创建项目时选择的产品数量.
|
|
* Get products count from post.
|
|
*
|
|
* @param object $project
|
|
* @param object $rawdata
|
|
* @param object $program
|
|
* @access protected
|
|
* @return bool
|
|
*/
|
|
protected function getLinkedProductsCount(object $project, object $rawdata): int
|
|
{
|
|
$linkedProductsCount = 0;
|
|
if($project->hasProduct && isset($rawdata->products))
|
|
{
|
|
foreach($rawdata->products as $product)
|
|
{
|
|
if(!empty($product)) $linkedProductsCount++;
|
|
}
|
|
}
|
|
|
|
return $linkedProductsCount;
|
|
}
|
|
|
|
/**
|
|
* 创建项目后，将项目创建者加到项目管理员分组.
|
|
* Create project admin after create a project.
|
|
*
|
|
* @param int $projectID
|
|
* @access protected
|
|
* @return bool
|
|
*/
|
|
protected function addProjectAdmin(int $projectID): bool
|
|
{
|
|
$projectAdmin = $this->dao->select('t1.*')->from(TABLE_PROJECTADMIN)->alias('t1')
|
|
->leftJoin(TABLE_GROUP)->alias('t2')->on('t1.`group` = t2.id')
|
|
->where('t1.account')->eq($this->app->user->account)
|
|
->andWhere('t2.role')->eq('projectAdmin')
|
|
->fetch();
|
|
|
|
if(!empty($projectAdmin))
|
|
{
|
|
$newProject = $projectAdmin->projects . ",$projectID";
|
|
$this->dao->update(TABLE_PROJECTADMIN)->set('projects')->eq($newProject)->where('account')->eq($projectAdmin->account)->andWhere('`group`')->eq($projectAdmin->group)->exec();
|
|
}
|
|
else
|
|
{
|
|
$projectAdminID = $this->dao->select('id')->from(TABLE_GROUP)->where('role')->eq('projectAdmin')->fetch('id');
|
|
|
|
$projectAdmin = new stdclass();
|
|
$projectAdmin->account = $this->app->user->account;
|
|
$projectAdmin->group = $projectAdminID;
|
|
$projectAdmin->projects = $projectID;
|
|
$this->dao->replace(TABLE_PROJECTADMIN)->data($projectAdmin)->exec();
|
|
}
|
|
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 生成project模块的项目下拉框跳转链接.
|
|
* Build project link in project page.
|
|
*
|
|
* @param string $method
|
|
* @access protected
|
|
* @return string
|
|
*/
|
|
protected function buildLinkForProject(string $method) :string
|
|
{
|
|
if($method == 'execution')
|
|
return helper::createLink($module, $method, "status=all&projectID=%s");
|
|
|
|
if($method == 'managePriv')
|
|
return helper::createLink($module, 'group', "projectID=%s");
|
|
|
|
if($method == 'showerrornone')
|
|
return helper::createLink('projectstory', 'story', "projectID=%s");
|
|
|
|
$methods = ',bug,testcase,testtask,testreport,build,dynamic,view,manageproducts,team,managemembers,whitelist,addwhitelist,group,';
|
|
if(strpos($methods, ',' . $method . ',') !== false)
|
|
return helper::createLink($module, $method, "projectID=%s");
|
|
}
|
|
|
|
/**
|
|
* 生成bug模块的项目下拉框跳转链接.
|
|
* Build project link in bug page.
|
|
*
|
|
* @param string $method
|
|
* @access protected
|
|
* @return string
|
|
*/
|
|
protected function buildLinkForBug(string $method) :string
|
|
{
|
|
if($method == 'create')
|
|
return helper::createLink($module, $method, "productID=0&branch=0&extras=projectID=%s");
|
|
|
|
if($method == 'edit')
|
|
return helper::createLink('project', 'bug', "projectID=%s");
|
|
}
|
|
|
|
/**
|
|
* 生成story模块的项目下拉框跳转链接.
|
|
* Build project link in story page.
|
|
*
|
|
* @param string $method
|
|
* @access protected
|
|
* @return string
|
|
*/
|
|
protected function buildLinkForStory(string $method) :string
|
|
{
|
|
if($method == 'change' || $method == 'create')
|
|
return helper::createLink('projectstory', 'story', "projectID=%s");
|
|
if($method == 'zerocase')
|
|
return helper::createLink('project', 'testcase', "projectID=%s");
|
|
}
|
|
|
|
/**
|
|
* 删除项目团队成员。
|
|
* Delete project team member.
|
|
*
|
|
* @param array|int $projectIdList
|
|
* @param string $type
|
|
* @param string $account
|
|
* @access protected
|
|
* @return bool
|
|
*/
|
|
protected function unlinkTeamMember(int|array $projectIdList, string $type, string $account): bool
|
|
{
|
|
$this->dao->delete()->from(TABLE_TEAM)
|
|
->where('root')->in($projectIdList)
|
|
->andWhere('type')->eq($type)
|
|
->andWhere('account')->eq($account)
|
|
->exec();
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 对项目按照我的、其它的和关闭的进行分类。
|
|
* Classify projects according to my, other and closed.
|
|
*
|
|
* @param array $projects
|
|
* @access protected
|
|
* @return array
|
|
*/
|
|
protected function classifyProjects(array $projects): array
|
|
{
|
|
$classifiedProjects = array('myProjects' => array(), 'otherProjects' => array(), 'closedProjects' => array());
|
|
foreach($projects as $project)
|
|
{
|
|
if(!str_contains('wait,doing,closed', $project->status)) continue;
|
|
|
|
$projectPath = explode(',', trim($project->path, ','));
|
|
$topProgram = !empty($project->parent) ? $projectPath[0] : $project->parent;
|
|
|
|
if($project->PM == $this->app->user->account)
|
|
{
|
|
if($project->status != 'closed')
|
|
{
|
|
$classifiedProjects['myProjects'][$topProgram][$project->status][] = $project;
|
|
}
|
|
else
|
|
{
|
|
$classifiedProjects['closedProjects']['my'][$topProgram][$project->closedDate] = $project;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if($project->status != 'closed')
|
|
{
|
|
$classifiedProjects['otherProjects'][$topProgram][$project->status][] = $project;
|
|
}
|
|
else
|
|
{
|
|
$classifiedProjects['closedProjects']['other'][$topProgram][$project->closedDate] = $project;
|
|
}
|
|
}
|
|
}
|
|
|
|
return $classifiedProjects;
|
|
}
|
|
|
|
/**
|
|
* 对groups列表进行排序和缩减。
|
|
* Sort and reduce projects.
|
|
*
|
|
* @param array $projectsStats
|
|
* @param int $retainNum
|
|
* @access protected
|
|
* @return array
|
|
*/
|
|
protected function sortAndReduceClosedProjects(array $projectsStats, int $retainNum = 2): array
|
|
{
|
|
$sortedAndReducedProjects = array('my' => $projectsStats['myProjects'], 'other' => $projectsStats['otherProjects']);
|
|
$closedProjects = $projectsStats['closedProjects'];
|
|
foreach($closedProjects as $group => $groupedProjects)
|
|
{
|
|
foreach($groupedProjects as $topProgram => $projects)
|
|
{
|
|
krsort($projects);
|
|
if($retainNum > 0)
|
|
{
|
|
$sortedAndReducedProjects[$group][$topProgram]['closed'] = array_slice($projects, 0, $retainNum);
|
|
}
|
|
}
|
|
}
|
|
|
|
return $sortedAndReducedProjects;
|
|
}
|
|
|
|
/**
|
|
* 根据项目集ID查询所有项目集的层级。
|
|
* Get all program level of a program.
|
|
*
|
|
* @param int $program
|
|
* @param string $path
|
|
* @param int $grade
|
|
* @access protected
|
|
* @return string
|
|
*/
|
|
protected function getParentProgram(string $path, int $grade): string
|
|
{
|
|
$programList = $this->dao->select('id,name')->from(TABLE_PROGRAM)
|
|
->where('id')->in(trim($path, ','))
|
|
->andWhere('grade')->lt($grade)
|
|
->orderBy('grade asc')
|
|
->fetchPairs();
|
|
|
|
return implode('/', $programList);
|
|
}
|
|
|
|
/**
|
|
* 根据状态和和我参与的查询项目列表。
|
|
* Get project list by status and with my participation.
|
|
*
|
|
* @param string $status
|
|
* @param string $orderBy
|
|
* @param bool $involved
|
|
* @param object $pager
|
|
* @access protected
|
|
* @return array
|
|
*/
|
|
protected function fetchProjectList(string $status, string $orderBy, bool $involved, object|null $pager): array
|
|
{
|
|
return $this->dao->select('DISTINCT t1.*')->from(TABLE_PROJECT)->alias('t1')
|
|
->leftJoin(TABLE_TEAM)->alias('t2')->on('t1.id=t2.root')
|
|
->leftJoin(TABLE_STAKEHOLDER)->alias('t3')->on('t1.id=t3.objectID')
|
|
->where('t1.deleted')->eq('0')
|
|
->andWhere('t1.vision')->eq($this->config->vision)
|
|
->andWhere('t1.type')->eq('project')
|
|
->beginIF(!in_array($status, array('all', 'undone', 'review', 'unclosed'), true))->andWhere('t1.status')->eq($status)->fi()
|
|
->beginIF($status == 'undone' || $status == 'unclosed')->andWhere('t1.status')->in('wait,doing')->fi()
|
|
->beginIF($status == 'review')
|
|
->andWhere("FIND_IN_SET('{$this->app->user->account}', t1.reviewers)")
|
|
->andWhere('t1.reviewStatus')->eq('doing')
|
|
->fi()
|
|
->beginIF($this->cookie->involved || $involved)
|
|
->andWhere('t2.type')->eq('project')
|
|
->andWhere('t1.openedBy', true)->eq($this->app->user->account)
|
|
->orWhere('t1.PM')->eq($this->app->user->account)
|
|
->orWhere('t2.account')->eq($this->app->user->account)
|
|
->orWhere('(t3.user')->eq($this->app->user->account)
|
|
->andWhere('t3.deleted')->eq(0)
|
|
->markRight(1)
|
|
->orWhere("CONCAT(',', t1.whitelist, ',')")->like("%,{$this->app->user->account},%")
|
|
->markRight(1)
|
|
->fi()
|
|
->orderBy($orderBy)
|
|
->page($pager, 't1.id')
|
|
->fetchAll('id');
|
|
}
|
|
|
|
/**
|
|
* 通过条件查询和数量限制查询项目列表。
|
|
* Get project list by query and with limit.
|
|
*
|
|
* @param string $status
|
|
* @param int $projectID
|
|
* @param string $orderBy
|
|
* @param int $limit
|
|
* @param string $excludedModel
|
|
* @access protected
|
|
* @return array
|
|
*/
|
|
protected function fetchProjectListByQuery(string $status, int $projectID, string $orderBy, int $limit, string $excludedModel): array
|
|
{
|
|
return $this->dao->select('*')->from(TABLE_PROJECT)
|
|
->where('type')->eq('project')
|
|
->andWhere('vision')->eq($this->config->vision)
|
|
->andWhere('deleted')->eq(0)
|
|
->beginIF($excludedModel)->andWhere('model')->ne($excludedModel)->fi()
|
|
->beginIF(!$this->app->user->admin)->andWhere('id')->in($this->app->user->view->projects)->fi()
|
|
->beginIF($status == 'undone')->andWhere('status')->notIN('done,closed')->fi()
|
|
->beginIF($status && $status != 'all' && $status != 'undone')->andWhere('status')->eq($status)->fi()
|
|
->beginIF($projectID)->andWhere('id')->eq($projectID)->fi()
|
|
->orderBy($orderBy)
|
|
->beginIF($limit)->limit($limit)->fi()
|
|
->fetchAll('id');
|
|
}
|
|
|
|
/**
|
|
* 根据项目ID列表查询团队成员数量。
|
|
* Get project team member count by project id list.
|
|
*
|
|
* @param array $projectIdList
|
|
* @access protected
|
|
* @return array
|
|
*/
|
|
protected function fetchMemberCountByIdList(array $projectIdList): array
|
|
{
|
|
return $this->dao->select('t1.root, count(t1.id) as count')->from(TABLE_TEAM)->alias('t1')
|
|
->leftJoin(TABLE_USER)->alias('t2')->on('t1.account=t2.account')
|
|
->where('t1.root')->in($projectIdList)
|
|
->andWhere('t2.deleted')->eq(0)
|
|
->groupBy('t1.root')
|
|
->fetchPairs();
|
|
}
|
|
|
|
/**
|
|
* 根据项目ID列表查询任务的总预计工时。
|
|
* Get task all estimate by project id list.
|
|
*
|
|
* @param array $projectIdList
|
|
* @param string $fields
|
|
* @access protected
|
|
* @return array
|
|
*/
|
|
protected function fetchTaskEstimateByIdList(array $projectIdList, string $fields = 'estimate'): array
|
|
{
|
|
$fields = explode(',', $fields);
|
|
$selectFields = 't2.project';
|
|
foreach($fields as $field) $selectFields .= ", ROUND(SUM(t1.{$field}), 1) AS {$field}";
|
|
|
|
return $this->dao->select($selectFields)->from(TABLE_TASK)->alias('t1')
|
|
->leftJoin(TABLE_PROJECT)->alias('t2')->on('t1.execution = t2.id')
|
|
->where('t1.parent')->lt(1)
|
|
->andWhere('t2.project')->in($projectIdList)
|
|
->andWhere('t1.deleted')->eq(0)
|
|
->andWhere('t2.deleted')->eq(0)
|
|
->groupBy('t2.project')
|
|
->fetchAll('project');
|
|
}
|
|
|
|
/**
|
|
* 通过项目ID列表查询需求的数量。
|
|
* Get the number of stories associated with the project.
|
|
*
|
|
* @param array $projectIdList
|
|
* @access protected
|
|
* @return array
|
|
*/
|
|
protected function getTotalStoriesByProject(array $projectIdList): array
|
|
{
|
|
return $this->dao->select("t1.project, count(t2.id) as allStories, count(if(t2.status = 'active' or t2.status = 'changing', 1, null)) as leftStories, count(if(t2.status = 'closed' and t2.closedReason = 'done', 1, null)) as doneStories")->from(TABLE_PROJECTSTORY)->alias('t1')
|
|
->leftJoin(TABLE_STORY)->alias('t2')->on('t1.story=t2.id')
|
|
->where('t1.project')->in($projectIdList)
|
|
->andWhere('t2.type')->eq('story')
|
|
->andWhere('deleted')->eq('0')
|
|
->groupBy('project')
|
|
->fetchAll('project');
|
|
}
|
|
|
|
/**
|
|
* 删除团队成员。
|
|
* Delete Members.
|
|
*
|
|
* @param int $projectID
|
|
* @param int $openedBy
|
|
* @param array $deleteMembers
|
|
* @access protected
|
|
* @return bool
|
|
*/
|
|
protected function deleteMembers(int $projectID, int $openedBy, array $deleteMembers): bool
|
|
{
|
|
$this->dao->delete()->from(TABLE_TEAM)
|
|
->where('root')->eq($projectID)
|
|
->andWhere('type')->eq('project')
|
|
->andWhere('account')->in($deleteMembers)
|
|
->andWhere('account')->ne($openedBy)
|
|
->exec();
|
|
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 通过项目ID获取任务数量统计。
|
|
* Get the number of tasks associated with the project.
|
|
*
|
|
* @param array $projectIdList
|
|
* @access protected
|
|
* @return array
|
|
*/
|
|
protected function getTotalTaskByProject(array $projectIdList): array
|
|
{
|
|
return $this->dao->select("t1.project, count(t1.id) as allTasks, count(if(t1.status = 'wait', 1, null)) as waitTasks, count(if(t1.status = 'doing', 1, null)) as doingTasks, count(if(t1.status = 'done', 1, null)) as doneTasks, count(if(t1.status = 'wait' or t1.status = 'pause' or t1.status = 'cancel', 1, null)) as leftTasks, count(if(t1.status = 'done' or t1.status = 'closed', 1, null)) as litedoneTasks")->from(TABLE_TASK)->alias('t1')
|
|
->leftJoin(TABLE_EXECUTION)->alias('t2')->on('t1.execution=t2.id')
|
|
->where('t1.project')->in($projectIdList)
|
|
->andWhere('t1.deleted')->eq(0)
|
|
->andWhere('t2.deleted')->eq(0)
|
|
->groupBy('t1.project')
|
|
->fetchAll('project');
|
|
}
|
|
|
|
/**
|
|
* 返回请求被拒绝的跳转信息。
|
|
* return accessDenied response.
|
|
*
|
|
* @access protected
|
|
* @return string
|
|
*/
|
|
protected function accessDenied(): string
|
|
{
|
|
$this->session->set('project', '');
|
|
return js::alert($this->lang->project->accessDenied) . js::locate(helper::createLink('project', 'index'));
|
|
}
|
|
|
|
/**
|
|
* 修改无迭代项目下执行的状态。
|
|
* Modify the execution status when changing the status of no execution project.
|
|
*
|
|
* @param int $projectID
|
|
* @param string $status
|
|
*
|
|
* @access public
|
|
* @return array|false
|
|
*/
|
|
protected function changeExecutionStatus(int $projectID, string $status): array|false
|
|
{
|
|
if(!in_array($status, array('start', 'suspend', 'activate', 'close'))) return false;
|
|
|
|
$executionID = $this->dao->select('id')->from(TABLE_EXECUTION)->where('project')->eq($projectID)->andWhere('multiple')->eq('0')->fetch('id');
|
|
if(!$executionID) return false;
|
|
|
|
return $this->loadModel('execution')->$status($executionID);
|
|
}
|
|
|
|
/**
|
|
* 通过项目ID获取Bug数量统计。
|
|
* Get the number of bugs associated with the project.
|
|
*
|
|
* @param array $projectIdList
|
|
* @access protected
|
|
* @return array
|
|
*/
|
|
protected function getTotalBugByProject(array $projectIdList): array
|
|
{
|
|
return $this->dao->select("project, count(id) as allBugs, count(if(status = 'active', 1, null)) as leftBugs, count(if(status = 'resolved', 1, null)) as doneBugs")->from(TABLE_BUG)
|
|
->where('project')->in($projectIdList)
|
|
->andWhere('deleted')->eq(0)
|
|
->groupBy('project')
|
|
->fetchAll('project');
|
|
}
|
|
}
|