900 lines
37 KiB
PHP
900 lines
37 KiB
PHP
<?php
|
|
declare(strict_types=1);
|
|
/**
|
|
* The model file of personnel of ZenTaoPMS.
|
|
*
|
|
* @copyright Copyright 2009-2023 禅道软件（青岛）有限公司(ZenTao Software (Qingdao) Co., Ltd. www.cnezsoft.com)
|
|
* @license ZPL(http://zpl.pub/page/zplv12.html) or AGPL(https://www.gnu.org/licenses/agpl-3.0.en.html)
|
|
* @author Chunsheng Wang <chunsheng@cnezsoft.com>
|
|
* @package personnel
|
|
* @version $Id$
|
|
* @link https://www.zentao.net
|
|
*/
|
|
class personnelModel extends model
|
|
{
|
|
/**
|
|
* 获取项目集可访问人员。
|
|
* Access to program set invest staff.
|
|
*
|
|
* @param int $programID
|
|
* @param int $deptID
|
|
* @param string $browseType
|
|
* @param int $queryID
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getAccessiblePersonnel(int $programID = 0, int $deptID = 0, string $browseType = 'all', int $queryID = 0)
|
|
{
|
|
$accessibleQuery = '';
|
|
if($browseType == 'bysearch')
|
|
{
|
|
$query = $queryID ? $this->loadModel('search')->getQuery($queryID) : '';
|
|
if($query)
|
|
{
|
|
$this->session->set('accessibleQuery', $query->sql);
|
|
$this->session->set('accessibleForm', $query->form);
|
|
}
|
|
if($this->session->accessibleQuery == false) $this->session->set('accessibleQuery', ' 1=1');
|
|
$accessibleQuery = $this->session->accessibleQuery;
|
|
}
|
|
|
|
/* Determine who can be accessed based on access control. */
|
|
$program = $this->loadModel('program')->getByID($programID);
|
|
if(!$program) return array();
|
|
|
|
/* Get accessible account of program. */
|
|
$accessibleQuery = preg_replace('/`(\w+)`/', 't2.`$1`', $accessibleQuery);
|
|
$personnelList = array();
|
|
$personnelList = $this->dao->select('t2.id,t2.dept,t2.account,t2.role,t2.realname,t2.gender')->from(TABLE_USERVIEW)->alias('t1')
|
|
->leftJoin(TABLE_USER)->alias('t2')->on('t1.account=t2.account')
|
|
->where('t2.deleted')->eq(0)
|
|
->beginIF($program->acl != 'open')->andWhere("CONCAT(',', t1.programs, ',')")->like("%,$programID,%")->fi()
|
|
->beginIF($deptID > 0)->andWhere('t2.dept')->eq($deptID)->fi()
|
|
->beginIF($browseType == 'bysearch')->andWhere($accessibleQuery)->fi()
|
|
->fetchAll('id');
|
|
|
|
/* If the program's acl is open and the user cannot access this program, remove it. */
|
|
if($program->acl == 'open')
|
|
{
|
|
foreach($personnelList as $personnel)
|
|
{
|
|
if(!$this->canViewProgram($programID, $personnel->account)) unset($personnelList[$personnel->id]);
|
|
}
|
|
}
|
|
|
|
return $personnelList;
|
|
}
|
|
|
|
/**
|
|
* 检查你是否有权限查看项目集。
|
|
* Check if you have permission to view the program.
|
|
*
|
|
* @param int $programID
|
|
* @param string $account
|
|
* @access public
|
|
* @return bool
|
|
*/
|
|
public function canViewProgram(int $programID, string $account): bool
|
|
{
|
|
if($this->app->user->admin) return true;
|
|
|
|
/* Get group acl and group info. */
|
|
static $groupAcl = array();
|
|
static $groupInfo = array();
|
|
if(empty($groupAcl))
|
|
{
|
|
$groupAcl = $this->dao->select('id,acl')->from(TABLE_GROUP)->fetchPairs();
|
|
foreach($groupAcl as $groupID => $group) $groupInfo[$groupID] = json_decode($groupAcl[$groupID]);
|
|
}
|
|
|
|
/* Get user groups. */
|
|
static $userGroups = array();
|
|
if(empty($userGroups)) $userGroups = $this->dao->select('*')->from(TABLE_USERGROUP)->fetchGroup('account', 'group');
|
|
|
|
/* Check permission. */
|
|
$programRight = false;
|
|
if(isset($userGroups[$account]))
|
|
{
|
|
foreach($userGroups[$account] as $groupID => $userGroup)
|
|
{
|
|
$group = isset($groupInfo[$groupID]) ? $groupInfo[$groupID] : '';
|
|
|
|
if(!isset($group->programs) || in_array($programID, $group->programs))
|
|
{
|
|
$programRight = true;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
return $programRight;
|
|
}
|
|
|
|
/**
|
|
* 获取参与项目集的人员列表。
|
|
* Get invest person list.
|
|
*
|
|
* @param int $programID
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getInvest(int $programID = 0): array
|
|
{
|
|
/* Get all projects under the current program. */
|
|
$projects = $this->dao->select('id,model,type,parent,path,name')->from(TABLE_PROJECT)
|
|
->where('type')->eq('project')
|
|
->andWhere('path')->like("%,{$programID},%")
|
|
->andWhere('deleted')->eq('0')
|
|
->orderBy('id_desc')
|
|
->fetchAll('id');
|
|
if(empty($projects)) return array();
|
|
|
|
/* Get account pairs. */
|
|
$accountPairs = $this->getInvolvedProjects($projects);
|
|
if(empty($accountPairs)) return array();
|
|
|
|
/* Get execution, task, bug, story, issue and risk pairs, and get user list. */
|
|
$executionPairs = $this->getInvolvedExecutions($projects);
|
|
$taskInvest = $this->getProjectTaskInvest($projects, $accountPairs);
|
|
$bugAndStoryInvest = $this->getBugAndStoryInvest($accountPairs, $programID);
|
|
if($this->config->edition == 'max' || $this->config->edition == 'ipd')
|
|
{
|
|
$issueInvest = $this->getIssueInvest($accountPairs, $projects);
|
|
$riskInvest = $this->getRiskInvest($accountPairs, $projects);
|
|
}
|
|
$users = $this->loadModel('user')->getListByAccounts(array_keys($accountPairs), 'account');
|
|
|
|
/* Build personnel list. */
|
|
$personnelList = array();
|
|
foreach($accountPairs as $account => $projects)
|
|
{
|
|
$user = zget($users, $account, '');
|
|
if(empty($user)) continue;
|
|
|
|
if(!isset($personnelList[$user->role])) $personnelList[$user->role] = array();
|
|
$personnelList[$user->role][$account]['realname'] = $user ? $user->realname : $account;
|
|
$personnelList[$user->role][$account]['account'] = $account;
|
|
$personnelList[$user->role][$account]['role'] = $user ? zget($this->lang->user->roleList, $user->role) : '';
|
|
$personnelList[$user->role][$account]['projects'] = $projects;
|
|
$personnelList[$user->role][$account]['executions'] = zget($executionPairs, $account, 0);
|
|
|
|
$personnelList[$user->role][$account] += $taskInvest[$account];
|
|
$personnelList[$user->role][$account] += $bugAndStoryInvest[$account];
|
|
if($this->config->edition == 'max' || $this->config->edition == 'ipd')
|
|
{
|
|
$personnelList[$user->role][$account] += $issueInvest[$account];
|
|
$personnelList[$user->role][$account] += $riskInvest[$account];
|
|
}
|
|
}
|
|
krsort($personnelList);
|
|
return $personnelList;
|
|
}
|
|
|
|
/**
|
|
* 获取用户参与的项目风险。
|
|
* Get user project risk invest.
|
|
*
|
|
* @param array $accounts
|
|
* @param array $projects
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getRiskInvest(array $accounts, array $projects): array
|
|
{
|
|
/* Get the risks in projects. */
|
|
$risks = $this->dao->select('id,createdBy,resolvedBy,status,assignedTo')->from(TABLE_RISK)
|
|
->where('project')->in(array_keys($projects))
|
|
->andWhere('deleted')->eq(0)
|
|
->fetchAll('id');
|
|
|
|
/* Initialization personnel risks. */
|
|
$invest = array();
|
|
foreach($accounts as $account => $project)
|
|
{
|
|
$invest[$account]['createdRisk'] = 0;
|
|
$invest[$account]['resolvedRisk'] = 0;
|
|
$invest[$account]['pendingRisk'] = 0;
|
|
}
|
|
|
|
/* Build invest risks. */
|
|
foreach($risks as $risk)
|
|
{
|
|
if($risk->createdBy && isset($invest[$risk->createdBy])) $invest[$risk->createdBy]['createdRisk'] += 1;
|
|
if($risk->resolvedBy && isset($invest[$risk->resolvedBy])) $invest[$risk->resolvedBy]['resolvedRisk'] += 1;
|
|
if($risk->assignedTo && isset($invest[$risk->assignedTo]) && $risk->status == 'active') $invest[$risk->assignedTo]['pendingRisk'] += 1;
|
|
}
|
|
|
|
return $invest;
|
|
}
|
|
|
|
/**
|
|
* 获取用户参与的项目问题。
|
|
* Get user project issue invest.
|
|
*
|
|
* @param array $accounts
|
|
* @param array $projects
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getIssueInvest(array $accounts, array $projects): array
|
|
{
|
|
/* Get issues in the projects. */
|
|
$issues = $this->dao->select('id,createdBy,resolvedBy,status,assignedTo')->from(TABLE_ISSUE)
|
|
->where('project')->in(array_keys($projects))
|
|
->andWhere('deleted')->eq(0)
|
|
->fetchAll('id');
|
|
|
|
/* Initialization personnel issues. */
|
|
$invest = array();
|
|
foreach($accounts as $account => $project)
|
|
{
|
|
$invest[$account]['createdIssue'] = 0;
|
|
$invest[$account]['resolvedIssue'] = 0;
|
|
$invest[$account]['pendingIssue'] = 0;
|
|
}
|
|
|
|
/* Build invest issues. */
|
|
foreach($issues as $issue)
|
|
{
|
|
if($issue->createdBy && isset($invest[$issue->createdBy])) $invest[$issue->createdBy]['createdIssue'] += 1;
|
|
if($issue->resolvedBy && isset($invest[$issue->resolvedBy])) $invest[$issue->resolvedBy]['resolvedIssue'] += 1;
|
|
if($issue->assignedTo && isset($invest[$issue->assignedTo]) && in_array($issue->status, array('unconfirmed', 'confirmed', 'active'))) $invest[$issue->assignedTo]['pendingIssue'] += 1;
|
|
}
|
|
|
|
return $invest;
|
|
}
|
|
|
|
/**
|
|
* 获取用户参与的 bug 和需求。
|
|
* Get user bug and story invest.
|
|
*
|
|
* @param array $accounts
|
|
* @param int $programID
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getBugAndStoryInvest(array $accounts, int $programID): array
|
|
{
|
|
/* Get invest products. */
|
|
$productPairs = $this->loadModel('product')->getPairs('', $programID, '', 'all');
|
|
$productKeys = array_keys($productPairs);
|
|
|
|
/* Get invest bugs, requirements and stories. */
|
|
$bugs = $this->dao->select('id,status,openedBy,assignedTo,resolvedBy')->from(TABLE_BUG)
|
|
->where('product')->in($productKeys)
|
|
->andWhere('deleted')->eq(0)
|
|
->fetchAll('id');
|
|
$requirement = $this->dao->select('openedBy, count(id) as number')->from(TABLE_STORY)
|
|
->where('product')->in($productKeys)
|
|
->andWhere('openedBy')->in(array_keys($accounts))
|
|
->andWhere('type')->eq('requirement')
|
|
->andWhere('deleted')->eq(0)
|
|
->groupBy('openedBy')
|
|
->fetchPairs('openedBy');
|
|
$story = $this->dao->select('openedBy, count(id) as number')->from(TABLE_STORY)
|
|
->where('product')->in($productKeys)
|
|
->andWhere('openedBy')->in(array_keys($accounts))
|
|
->andWhere('type')->eq('story')
|
|
->andWhere('deleted')->eq(0)
|
|
->groupBy('openedBy')
|
|
->fetchPairs('openedBy');
|
|
|
|
/* Initialize bugs and requirements related to personnel. */
|
|
$invest = array();
|
|
foreach($accounts as $account => $project) $invest[$account]['createdBug'] = $invest[$account]['resolvedBug'] = $invest[$account]['pendingBug'] = $invest[$account]['UR'] = $invest[$account]['SR'] = 0;
|
|
|
|
/* Calculate the number of user invest bugs, requirements and stories. */
|
|
foreach($requirement as $account => $number) $invest[$account]['UR'] = $number;
|
|
foreach($story as $account => $number) $invest[$account]['SR'] = $number;
|
|
foreach($bugs as $bug)
|
|
{
|
|
if($bug->openedBy && isset($invest[$bug->openedBy])) $invest[$bug->openedBy]['createdBug'] += 1;
|
|
if($bug->resolvedBy && isset($invest[$bug->resolvedBy])) $invest[$bug->resolvedBy]['resolvedBug'] += 1;
|
|
if($bug->assignedTo && $bug->status == 'active' && isset($invest[$bug->assignedTo])) $invest[$bug->assignedTo]['pendingBug'] += 1;
|
|
}
|
|
|
|
return $invest;
|
|
}
|
|
|
|
/**
|
|
* 获取项目成员帐户和参与项目的数量。
|
|
* Get the project member accounts and the number of participating projects.
|
|
*
|
|
* @param array $projects
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getInvolvedProjects(array $projects): array
|
|
{
|
|
return $this->dao->select('account, count(root) as projects')->from(TABLE_TEAM)
|
|
->where('root')->in(array_keys($projects))
|
|
->andWhere('type')->eq('project')
|
|
->groupBy('account')
|
|
->fetchPairs('account');
|
|
}
|
|
|
|
/**
|
|
* 获取项目下的迭代或阶段。
|
|
* Gets the iteration or phase under the project.
|
|
*
|
|
* @param array $projects
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getInvolvedExecutions(array $projects): array
|
|
{
|
|
$executions = $this->dao->select('id,id')->from(TABLE_PROJECT)
|
|
->where('type')->in('stage,sprint')
|
|
->andWhere('project')->in(array_keys($projects))
|
|
->andWhere('deleted')->eq('0')
|
|
->fetchPairs();
|
|
|
|
return $this->dao->select('account, count(root) as executions')->from(TABLE_TEAM)
|
|
->where('root')->in(array_keys($executions))
|
|
->andWhere('type')->in('execution')
|
|
->groupBy('account')
|
|
->fetchPairs('account');
|
|
}
|
|
|
|
/**
|
|
* 获取投入项目的任务。
|
|
* Get project task invest.
|
|
*
|
|
* @param array $projects
|
|
* @param array $accounts
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getProjectTaskInvest(array $projects, array $accounts): array
|
|
{
|
|
/* Get the tasks in the projects. */
|
|
$tasks = $this->dao->select('id,status,openedBy,finishedBy,assignedTo,project,`left`,mode')->from(TABLE_TASK)
|
|
->where('project')->in(array_keys($projects))
|
|
->andWhere('deleted')->eq('0')
|
|
->fetchAll('id');
|
|
$taskTeams = $this->dao->select('account,task,`left`')->from(TABLE_TASKTEAM)->where('task')->in(array_keys($tasks))->andWhere('status')->eq('wait')->fetchGroup('task', 'account');
|
|
|
|
/* Initialize personnel related tasks. */
|
|
$invest = array();
|
|
foreach($accounts as $account => $project)
|
|
{
|
|
$invest[$account]['createdTask'] = $invest[$account]['finishedTask'] = $invest[$account]['pendingTask'] = $invest[$account]['consumedTask'] = $invest[$account]['leftTask'] = 0;
|
|
}
|
|
|
|
/* Number of tasks per person. */
|
|
$userTasks = array();
|
|
foreach($tasks as $task)
|
|
{
|
|
if($task->openedBy && isset($invest[$task->openedBy]))
|
|
{
|
|
$invest[$task->openedBy]['createdTask'] += 1;
|
|
$userTasks[$task->openedBy][$task->id] = $task->id;
|
|
}
|
|
if($task->finishedBy && isset($invest[$task->finishedBy]))
|
|
{
|
|
$invest[$task->finishedBy]['finishedTask'] += 1;
|
|
$userTasks[$task->finishedBy][$task->id] = $task->id;
|
|
}
|
|
if($task->assignedTo && empty($task->mode))
|
|
{
|
|
if($task->status == 'wait')
|
|
{
|
|
$invest[$task->assignedTo]['pendingTask'] += 1;
|
|
|
|
if(!isset($invest[$task->assignedTo]['leftTask'])) $invest[$task->assignedTo]['leftTask'] = 0;
|
|
$invest[$task->assignedTo]['leftTask'] += $task->left;
|
|
}
|
|
$userTasks[$task->assignedTo][$task->id] = $task->id;
|
|
}
|
|
if(!empty($taskTeams[$task->id]) && !empty($task->mode))
|
|
{
|
|
foreach(array_keys($taskTeams[$task->id]) as $team)
|
|
{
|
|
if(!isset($invest[$team])) continue;
|
|
if(!isset($invest[$team]['leftTask'])) $invest[$team]['leftTask'] = 0;
|
|
$invest[$team]['leftTask'] += $task->left;
|
|
$userTasks[$team][$task->id] = $task->id;
|
|
}
|
|
}
|
|
}
|
|
|
|
/* The number of hours per person. */
|
|
$userHours = $this->getUserHours($userTasks);
|
|
foreach($userHours as $account => $hours)
|
|
{
|
|
if(!isset($invest[$account]['leftTask'])) $invest[$account]['leftTask'] = 0;
|
|
$invest[$account]['leftTask'] += $hours->left;
|
|
$invest[$account]['consumedTask'] = $hours->consumed;
|
|
}
|
|
|
|
return $invest;
|
|
}
|
|
|
|
/**
|
|
* 获取用户工时。
|
|
* Get user hours.
|
|
*
|
|
* @param array $userTasks
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getUserHours(array $userTasks): array
|
|
{
|
|
$accounts = array();
|
|
$taskIdList = array();
|
|
foreach($userTasks as $account => $taskID)
|
|
{
|
|
$accounts[] = $account;
|
|
$taskIdList = array_merge($taskIdList, $taskID);
|
|
}
|
|
|
|
$userHours = array();
|
|
$effortList = $this->dao->select('id,account,objectID,`left`,consumed')->from(TABLE_EFFORT)
|
|
->where('account')->in($accounts)
|
|
->andWhere('deleted')->eq(0)
|
|
->andWhere('objectID')->in($taskIdList)
|
|
->andWhere('objectType')->eq('task')
|
|
->orderBy('id_asc')
|
|
->fetchGroup('account', 'id');
|
|
foreach($effortList as $account => $efforts)
|
|
{
|
|
$latestLeft = array();
|
|
|
|
$userHours[$account] = new stdclass();
|
|
$userHours[$account]->left = 0;
|
|
$userHours[$account]->consumed = 0;
|
|
|
|
foreach($efforts as $effort)
|
|
{
|
|
$latestLeft[$effort->objectID] = $effort->left;
|
|
$userHours[$account]->consumed += $effort->consumed;
|
|
}
|
|
$userHours[$account]->left = array_sum($latestLeft);
|
|
}
|
|
|
|
return $userHours;
|
|
}
|
|
|
|
/**
|
|
* 获取要复制的对象。
|
|
* Get objects to copy.
|
|
*
|
|
* @param int $objectID
|
|
* @param string $objectType
|
|
* @param bool $addCount
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getCopiedObjects(int $objectID, string $objectType, bool $addCount = false): array
|
|
{
|
|
/* Get objects. */
|
|
$objects = array();
|
|
if($objectType == 'sprint')
|
|
{
|
|
$execution = $this->loadModel('execution')->getByID($objectID);
|
|
$parentID = $execution->project;
|
|
$project = $this->execution->getByID($parentID);
|
|
$objects = array($project->id => $project->name);
|
|
$objects += $this->dao->select('id,name')->from(TABLE_EXECUTION)
|
|
->where('project')->eq($parentID)
|
|
->andWhere('id')->in($this->app->user->view->sprints)
|
|
->andWhere('deleted')->eq(0)
|
|
->orderBy('openedDate_desc')
|
|
->limit('10')
|
|
->fetchPairs();
|
|
}
|
|
elseif($objectType == 'project')
|
|
{
|
|
$path = $this->dao->select('path')->from(TABLE_PROJECT)->where('id')->eq($objectID)->fetch('path');
|
|
$path = explode(',', trim($path, ','));
|
|
$parentID = $path[0] == $objectID ? 0 : $path[0];
|
|
$objects = $this->loadModel('project')->getPairsByProgram((int)$parentID);
|
|
}
|
|
elseif($objectType == 'product')
|
|
{
|
|
$parentID = $this->dao->select('program')->from(TABLE_PRODUCT)->where('id')->eq($objectID)->fetch('program');
|
|
$objects = $this->loadModel('product')->getPairs('', $parentID);
|
|
}
|
|
elseif($objectType == 'program')
|
|
{
|
|
$objects = $this->loadModel('program')->getPairs();
|
|
}
|
|
unset($objects[$objectID]);
|
|
if(!$addCount) return $objects;
|
|
|
|
/* Append object count. */
|
|
if($objectType == 'sprint') $objectType = 'execution';
|
|
$countPairs = $this->dao->select('root, COUNT(1) AS count')->from(TABLE_TEAM)
|
|
->where('type')->eq($objectType)
|
|
->andWhere('root')->in(array_keys($objects))
|
|
->beginIF($objectType == 'execution')->orWhere('(type')->eq('project')->andWhere('root')->eq($parentID)->markRight(1)->fi()
|
|
->groupBy('root')
|
|
->fetchPairs('root');
|
|
foreach($objects as $objectID => $objectName)
|
|
{
|
|
$memberCount = zget($countPairs, $objectID, 0);
|
|
$countTip = $memberCount > 1 ? str_replace('member', 'members', $this->lang->personnel->countTip) : $this->lang->personnel->countTip;
|
|
$objects[$objectID] = $objectName . sprintf($countTip, $memberCount);
|
|
}
|
|
return $objects;
|
|
}
|
|
|
|
/**
|
|
* 获取项目集的白名单。
|
|
* Get whitelist.
|
|
*
|
|
* @param int $objectID
|
|
* @param string $objectType program|project|product|sprint
|
|
* @param string $orderBy
|
|
* @param object $pager
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getWhitelist(int $objectID = 0, string $objectType = '', string $orderBy = 'id_desc', ?object $pager = null): array
|
|
{
|
|
return $this->dao->select('t1.id,t1.account,t2.realname,t2.dept,t2.role,t2.phone,t2.qq,t2.weixin,t2.email')->from(TABLE_ACL)->alias('t1')
|
|
->leftJoin(TABLE_USER)->alias('t2')->on('t1.account = t2.account')
|
|
->where('t1.objectID')->eq($objectID)
|
|
->andWhere('t1.type')->eq('whitelist')
|
|
->andWhere('t1.objectType')->eq($objectType)
|
|
->andWhere('t2.realname')->ne('')
|
|
->orderBy($orderBy)
|
|
->page($pager)
|
|
->fetchAll();
|
|
}
|
|
|
|
/**
|
|
* 测试获取对象白名单人员账号。
|
|
* Get whitelisted accounts.
|
|
*
|
|
* @param int $objectID
|
|
* @param string $objectType
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getWhitelistAccount(int $objectID = 0, string $objectType = ''): array
|
|
{
|
|
return $this->dao->select('account,account')->from(TABLE_ACL)->where('objectID')->eq($objectID)->andWhere('objectType')->eq($objectType)->fetchPairs();
|
|
}
|
|
|
|
/**
|
|
* 更新白名单人员。
|
|
* Update users from access control lists.
|
|
*
|
|
* @param array $users
|
|
* @param string $objectType program|project|product|sprint
|
|
* @param int $objectID
|
|
* @param string $type whitelist|blacklist
|
|
* @param string $source upgrade|add|sync
|
|
* @param string $updateType increase|replace
|
|
* @access public
|
|
* @return bool
|
|
*/
|
|
public function updateWhitelist(array $users = array(), string $objectType = '', int $objectID = 0, string $type = 'whitelist', string $source = 'add', string $updateType = 'replace'): bool
|
|
{
|
|
$oldWhitelist = $this->dao->select('account,objectType,objectID,type,source')->from(TABLE_ACL)->where('objectID')->eq($objectID)->andWhere('objectType')->eq($objectType)->fetchAll('account');
|
|
if($updateType == 'replace') $this->dao->delete()->from(TABLE_ACL)->where('objectID')->eq($objectID)->andWhere('objectType')->eq($objectType)->exec();
|
|
|
|
$users = array_unique(array_filter($users));
|
|
$accounts = array();
|
|
foreach($users as $account)
|
|
{
|
|
$accounts[$account] = $account;
|
|
if(isset($oldWhitelist[$account]))
|
|
{
|
|
if($updateType == 'replace') $this->dao->insert(TABLE_ACL)->data($oldWhitelist[$account])->exec();
|
|
continue;
|
|
}
|
|
$acl = new stdClass();
|
|
$acl->account = $account;
|
|
$acl->objectType = $objectType;
|
|
$acl->objectID = $objectID;
|
|
$acl->type = $type;
|
|
$acl->source = $source;
|
|
$this->dao->insert(TABLE_ACL)->data($acl)->autoCheck()->exec();
|
|
if(!dao::isError()) $this->loadModel('user')->updateUserView(array($acl->objectID), $acl->objectType, array($acl->account));
|
|
}
|
|
|
|
/* Update whitelist field of the object. */
|
|
$objectTable = $objectType == 'product' ? TABLE_PRODUCT : TABLE_PROJECT;
|
|
if($updateType == 'increase')
|
|
{
|
|
$oldWhitelist = $this->dao->select('whitelist')->from($objectTable)->where('id')->eq($objectID)->fetch('whitelist');
|
|
$groups = $this->dao->select('id')->from(TABLE_GROUP)->where('id')->in($oldWhitelist)->fetchPairs('id', 'id');
|
|
$oldWhitelist = $groups ? $this->dao->select('account,account')->from(TABLE_USERGROUP)->where('`group`')->in($groups)->fetchPairs() : $this->dao->select('account,account')->from(TABLE_USER)->where('account')->in($oldWhitelist)->fetchPairs();
|
|
if($oldWhitelist) $accounts = array_unique(array_merge($accounts, $oldWhitelist));
|
|
}
|
|
$whitelist = !empty($accounts) ? ',' . implode(',', $accounts) : '';
|
|
$whitelist = trim($whitelist, ',');
|
|
$this->dao->update($objectTable)->set('whitelist')->eq($whitelist)->where('id')->eq($objectID)->exec();
|
|
|
|
/* Get the accounts that have been deleted from the whitelist. */
|
|
$deletedAccounts = array_diff(array_keys($oldWhitelist), $accounts);
|
|
|
|
/* Synchronization of people from the product whitelist to the program set. */
|
|
$this->updateParentWhitelist($objectType, $objectID, $accounts, $source, $updateType, $deletedAccounts, $objectTable);
|
|
|
|
/* Update user view. */
|
|
$this->loadModel('user')->updateUserView(array($objectID), $objectType, $deletedAccounts);
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 更新对象的父级白名单。
|
|
* Update parent whitelist of the object.
|
|
*
|
|
* @param string $objectType
|
|
* @param int $objectID
|
|
* @param array $accounts
|
|
* @param string $source
|
|
* @param string $updateType
|
|
* @param array $deletedAccounts
|
|
* @param string $objectTable
|
|
* @access private
|
|
* @return bool
|
|
*/
|
|
private function updateParentWhitelist(string $objectType, int $objectID, array $accounts, string $source, string $updateType, array $deletedAccounts, string $objectTable): bool
|
|
{
|
|
if($objectType != 'product' && $objectType != 'sprint') return false;
|
|
|
|
$field = $objectType == 'product' ? 'program' : 'project';
|
|
$object = $this->dao->select('id,' . $field)->from($objectTable)->where('id')->eq($objectID)->fetch();
|
|
if(empty($object)) return false;
|
|
|
|
/* Update parent whitelist. */
|
|
$parentWhitelist = $this->getWhitelistAccount($object->{$field}, $field);
|
|
$newWhitelist = array_merge($parentWhitelist, $accounts);
|
|
$source = $source == 'upgrade' ? 'upgrade' : 'sync';
|
|
$this->updateWhitelist($newWhitelist, $field, $object->{$field}, 'whitelist', $source, $updateType);
|
|
|
|
/* Removal of persons from centralized parent whitelisting. */
|
|
if($updateType == 'replace')
|
|
{
|
|
foreach($deletedAccounts as $account) $this->deleteProgramWhitelist($objectID, $account);
|
|
}
|
|
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 从产品的白名单内删除用户。
|
|
* Delete product whitelist.
|
|
*
|
|
* @param int $productID
|
|
* @param string $account
|
|
* @access public
|
|
* @return bool
|
|
*/
|
|
public function deleteProductWhitelist(int $productID, string $account = ''): bool
|
|
{
|
|
$product = $this->dao->select('id,whitelist')->from(TABLE_PRODUCT)->where('id')->eq($productID)->fetch();
|
|
if(empty($product)) return false;
|
|
|
|
/* Delete the account's acl in the product. */
|
|
$result = $this->dao->delete()->from(TABLE_ACL)
|
|
->where('objectID')->eq($productID)
|
|
->andWhere('account')->eq($account)
|
|
->andWhere('objectType')->eq('product')
|
|
->andWhere('source')->eq('sync')
|
|
->exec();
|
|
|
|
/* Update user view when delete success. */
|
|
if($result)
|
|
{
|
|
$newWhitelist = str_replace(',' . $account, '', $product->whitelist);
|
|
$this->dao->update(TABLE_PRODUCT)->set('whitelist')->eq($newWhitelist)->where('id')->eq($productID)->exec();
|
|
|
|
$viewProducts = $this->dao->select('products')->from(TABLE_USERVIEW)->where('account')->eq($account)->fetch('products');
|
|
$newViewProducts = trim(str_replace(",{$productID},", ',', ",{$viewProducts},"), ',');
|
|
$this->dao->update(TABLE_USERVIEW)->set('products')->eq($newViewProducts)->where('account')->eq($account)->exec();
|
|
}
|
|
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 从项目集的白名单内删除用户。
|
|
* Delete project whitelist.
|
|
*
|
|
* @param int $programID
|
|
* @param string $account
|
|
* @access public
|
|
* @return void
|
|
*/
|
|
public function deleteProgramWhitelist(int $programID = 0, string $account = ''): bool
|
|
{
|
|
$program = $this->loadModel('program')->getByID($programID);
|
|
if(empty($program)) return false;
|
|
|
|
/* Get the product's whitelist in the program. */
|
|
$products = $this->dao->select('id')->from(TABLE_PRODUCT)->where('program')->eq($programID)->andWhere('deleted')->eq('0')->fetchPairs('id');
|
|
$whitelist = $this->dao->select('*')->from(TABLE_ACL)->where('objectID')->in($products)->andWhere('account')->eq($account)->andWhere('objectType')->eq('product')->fetch();
|
|
|
|
/* Determine if the user exists in other products in the program set. */
|
|
if(empty($whitelist))
|
|
{
|
|
$result = $this->dao->delete()->from(TABLE_ACL)
|
|
->where('objectID')->eq($programID)
|
|
->andWhere('account')->eq($account)
|
|
->andWhere('objectType')->eq('program')
|
|
->andWhere('source')->eq('sync')
|
|
->exec();
|
|
|
|
/* Update user view when delete success. */
|
|
if($result)
|
|
{
|
|
$newWhitelist = str_replace(',' . $account, '', $program->whitelist);
|
|
$this->dao->update(TABLE_PROGRAM)->set('whitelist')->eq($newWhitelist)->where('id')->eq($programID)->exec();
|
|
|
|
$viewPrograms = $this->dao->select('programs')->from(TABLE_USERVIEW)->where('account')->eq($account)->fetch('programs');
|
|
$newViewPrograms = trim(str_replace(",{$programID},", '', ",{$viewPrograms},"), ',');
|
|
$this->dao->update(TABLE_USERVIEW)->set('programs')->eq($newViewPrograms)->where('account')->eq($account)->exec();
|
|
}
|
|
}
|
|
|
|
$this->loadModel('user')->updateUserView(array($programID), 'program', array($account));
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 从项目的白名单内删除用户。
|
|
* Delete project whitelist.
|
|
*
|
|
* @param int $objectID
|
|
* @param string $account
|
|
* @access public
|
|
* @return bool
|
|
*/
|
|
public function deleteProjectWhitelist(int $objectID = 0, string $account = ''): bool
|
|
{
|
|
$project = $this->dao->select('id,project,whitelist')->from(TABLE_PROJECT)->where('id')->eq($objectID)->fetch();
|
|
if(empty($project)) return false;
|
|
|
|
/* Get project's whitelist. */
|
|
$projectID = $project->project ? $project->project : $objectID;
|
|
$sprints = $this->dao->select('id')->from(TABLE_PROJECT)->where('project')->eq($projectID)->andWhere('deleted')->eq('0')->fetchPairs('id');
|
|
$whitelist = $this->dao->select('*')->from(TABLE_ACL)->where('objectID')->in($sprints)->andWhere('account')->eq($account)->andWhere('objectType')->eq('sprint')->fetch();
|
|
|
|
/* Determine if the user exists in other sprints in the project set. */
|
|
if(empty($whitelist))
|
|
{
|
|
$result = $this->dao->delete()->from(TABLE_ACL)
|
|
->where('objectID')->eq($projectID)
|
|
->andWhere('account')->eq($account)
|
|
->andWhere('objectType')->eq('project')
|
|
->andWhere('source')->eq('sync')
|
|
->exec();
|
|
|
|
/* Update user view when delete success. */
|
|
if($result)
|
|
{
|
|
$newWhitelist = str_replace(',' . $account, '', $project->whitelist);
|
|
$this->dao->update(TABLE_PROJECT)->set('whitelist')->eq($newWhitelist)->where('id')->eq($projectID)->exec();
|
|
|
|
$viewProjects = $this->dao->select('projects')->from(TABLE_USERVIEW)->where('account')->eq($account)->fetch('projects');
|
|
$newViewProjects = trim(str_replace(",{$projectID},", ',', ",{$viewProjects},"), ',');
|
|
$this->dao->update(TABLE_USERVIEW)->set('projects')->eq($newViewProjects)->where('account')->eq($account)->exec();
|
|
}
|
|
}
|
|
$this->loadModel('user')->updateUserView(array($projectID), 'project', array($account));
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 删除执行的白名单。
|
|
* Delete execution whitelist.
|
|
*
|
|
* @param int $executionID
|
|
* @param string $account
|
|
* @access public
|
|
* @return bool
|
|
*/
|
|
public function deleteExecutionWhitelist(int $executionID, string $account = ''): bool
|
|
{
|
|
$execution = $this->dao->select('id,whitelist')->from(TABLE_EXECUTION)->where('id')->eq($executionID)->fetch();
|
|
if(empty($execution)) return false;
|
|
|
|
/* Delete account's acl in the execution. */
|
|
$result = $this->dao->delete()->from(TABLE_ACL)
|
|
->where('objectID')->eq($executionID)
|
|
->andWhere('account')->eq($account)
|
|
->andWhere('objectType')->eq('sprint')
|
|
->andWhere('source')->eq('sync')
|
|
->exec();
|
|
|
|
/* Update user view when delete success. */
|
|
if($result)
|
|
{
|
|
$newWhitelist = str_replace(',' . $account, '', $execution->whitelist);
|
|
$this->dao->update(TABLE_EXECUTION)->set('whitelist')->eq($newWhitelist)->where('id')->eq($executionID)->exec();
|
|
|
|
$viewExecutions = $this->dao->select('sprints')->from(TABLE_USERVIEW)->where('account')->eq($account)->fetch('sprints');
|
|
$newViewExecutions = trim(str_replace(",{$executionID},", '', ",{$viewExecutions},"), ',');
|
|
$this->dao->update(TABLE_USERVIEW)->set('sprints')->eq($newViewExecutions)->where('account')->eq($account)->exec();
|
|
}
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 根据部门创建访问链接。
|
|
* Create access links by department.
|
|
*
|
|
* @param object $dept
|
|
* @param int $programID
|
|
* @access public
|
|
* @return string
|
|
*/
|
|
public function createMemberLink(?object $dept = null, int $programID = 0): string
|
|
{
|
|
return helper::createLink('personnel', 'accessible', "program={$programID}&deptID={$dept->id}");
|
|
}
|
|
|
|
/**
|
|
* 构建搜索表单。
|
|
* Build search form.
|
|
*
|
|
* @param int $queryID
|
|
* @param string $actionURL
|
|
* @access public
|
|
* @return void
|
|
*/
|
|
public function buildSearchForm(int $queryID = 0, string $actionURL = ''): void
|
|
{
|
|
$this->config->personnel->accessible->search['actionURL'] = $actionURL;
|
|
$this->config->personnel->accessible->search['queryID'] = $queryID;
|
|
|
|
$this->loadModel('search')->setSearchParams($this->config->personnel->accessible->search);
|
|
}
|
|
|
|
/**
|
|
* 判断操作是否可以点击。
|
|
* Judge an action is clickable or not.
|
|
*
|
|
* @param object $whitelist
|
|
* @param string $action
|
|
* @access public
|
|
* @return bool
|
|
*/
|
|
public function isClickable(object $whitelist, string $action): bool
|
|
{
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* 从白名单中移除人员。
|
|
* Removing users from the white list.
|
|
*
|
|
* @param object $acl
|
|
* @access public
|
|
* @return bool
|
|
*/
|
|
public function unbindWhitelist(object $acl): bool
|
|
{
|
|
/* Update whitelist and delete acl. */
|
|
$objectTable = $acl->objectType == 'product' ? TABLE_PRODUCT : TABLE_PROJECT;
|
|
$whitelist = $this->dao->select('whitelist')->from($objectTable)->where('id')->eq($acl->objectID)->fetch('whitelist');
|
|
$newWhitelist = str_replace(",{$acl->account},", '', ",{$whitelist},");
|
|
$newWhitelist = trim($newWhitelist, ',');
|
|
$this->dao->update($objectTable)->set('whitelist')->eq($newWhitelist)->where('id')->eq($acl->objectID)->exec();
|
|
$this->dao->delete()->from(TABLE_ACL)->where('id')->eq($acl->id)->exec();
|
|
|
|
if($acl->objectType == 'project')
|
|
{
|
|
$project = $this->loadModel('project')->getByID($acl->objectID);
|
|
if(!$project->hasProduct)
|
|
{
|
|
$shadowProduct = $this->loadModel('product')->getShadowProductByProject($acl->objectID);
|
|
if($shadowProduct)
|
|
{
|
|
$this->dao->update(TABLE_PRODUCT)->set('whitelist')->eq($newWhitelist)->where('id')->eq($shadowProduct->id)->exec();
|
|
$this->dao->delete()->from(TABLE_ACL)->where('objectType')->eq('product')->andWhere('objectID')->eq($shadowProduct->id)->andWhere('account')->eq($acl->account)->exec();
|
|
|
|
if($shadowProduct->program) $this->deleteProgramWhitelist($shadowProduct->program, $acl->account);
|
|
$this->loadModel('user')->updateUserView(array($shadowProduct->id), 'product', array($acl->account));
|
|
}
|
|
}
|
|
}
|
|
|
|
return !dao::isError();
|
|
}
|
|
}
|