450 lines
15 KiB
PHP
450 lines
15 KiB
PHP
<?php
|
|
|
|
/**
|
|
* Groups - Groups
|
|
/**
|
|
* Groups - Groups class
|
|
*
|
|
* @package workflow.engine.ProcessMaker
|
|
* @copyright 2007 COLOSA
|
|
*/
|
|
class Groups
|
|
{
|
|
|
|
/**
|
|
* Get the assigned users of a group
|
|
*
|
|
* @param string $sGroupUID
|
|
* @return array
|
|
* @throws Exception
|
|
*/
|
|
public function getUsersOfGroup($sGroupUID, $statusUser = 'ACTIVE')
|
|
{
|
|
try {
|
|
$aUsers = array();
|
|
$oCriteria = new Criteria();
|
|
$oCriteria->addJoin(UsersPeer::USR_UID, GroupUserPeer::USR_UID, Criteria::LEFT_JOIN);
|
|
$oCriteria->add(GroupUserPeer::GRP_UID, $sGroupUID);
|
|
if($statusUser !== 'ALL'){
|
|
$oCriteria->add(UsersPeer::USR_STATUS, $statusUser);
|
|
}
|
|
$oDataset = UsersPeer::doSelectRS($oCriteria);
|
|
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
|
|
$oDataset->next();
|
|
|
|
while ($aRow = $oDataset->getRow()) {
|
|
$aUsers[] = $aRow;
|
|
$oDataset->next();
|
|
}
|
|
return $aUsers;
|
|
} catch (exception $oError) {
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get the active groups for an user
|
|
*
|
|
* @param string $sUserUID
|
|
* @return array
|
|
*/
|
|
public function getActiveGroupsForAnUser($sUserUID)
|
|
{
|
|
try {
|
|
$oCriteria = new Criteria();
|
|
$oCriteria->addSelectColumn(GroupUserPeer::GRP_UID);
|
|
$oCriteria->addSelectColumn(GroupwfPeer::GRP_STATUS);
|
|
$oCriteria->add(GroupUserPeer::USR_UID, $sUserUID);
|
|
$oCriteria->add(GroupwfPeer::GRP_STATUS, 'ACTIVE');
|
|
$oCriteria->addJoin(GroupUserPeer::GRP_UID, GroupwfPeer::GRP_UID, Criteria::LEFT_JOIN);
|
|
$oDataset = GroupUserPeer::doSelectRS($oCriteria);
|
|
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
|
|
$oDataset->next();
|
|
|
|
$aGroups = array();
|
|
$aRow = $oDataset->getRow();
|
|
while (is_array($aRow)) {
|
|
$aGroups[] = $aRow['GRP_UID'];
|
|
$oDataset->next();
|
|
$aRow = $oDataset->getRow();
|
|
}
|
|
return $aGroups;
|
|
} catch (exception $oError) {
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set a user to group
|
|
*
|
|
* @param string $grpUid
|
|
* @param string $usrUid
|
|
* @return boolean
|
|
* @throws exception
|
|
*/
|
|
public function addUserToGroup($grpUid, $usrUid)
|
|
{
|
|
try {
|
|
//Check the usrUid value
|
|
if (RBAC::isGuestUserUid($usrUid)) {
|
|
throw new Exception(G::LoadTranslation("ID_USER_CAN_NOT_UPDATE", array($usrUid)));
|
|
return false;
|
|
}
|
|
|
|
$groupUser = GroupUserPeer::retrieveByPk($grpUid, $usrUid);
|
|
if (is_object($groupUser) && get_class($groupUser) == 'GroupUser') {
|
|
return true;
|
|
} else {
|
|
$group = GroupwfPeer::retrieveByPK($grpUid);
|
|
|
|
$groupUser = new GroupUser();
|
|
$groupUser->setGrpUid($grpUid);
|
|
$groupUser->setUsrUid($usrUid);
|
|
$groupUser->setGrpId($group->getGrpId());
|
|
$groupUser->Save();
|
|
|
|
$users = new Users();
|
|
$usrName = $users->load($usrUid);
|
|
|
|
G::auditLog("AssignUserToGroup", "Assign user " . $usrName['USR_USERNAME'] . " (" . $usrUid . ") to group " . $group->getGrpTitle() . " (" . $grpUid . ") ");
|
|
|
|
return true;
|
|
}
|
|
} catch (exception $oError) {
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Remove a user from group
|
|
* @param string $grpUid
|
|
* @param string $usrUid
|
|
* @return array
|
|
*/
|
|
public function removeUserOfGroup($grpUid, $usrUid)
|
|
{
|
|
$gu = new GroupUser();
|
|
$gu->remove($grpUid, $usrUid);
|
|
}
|
|
|
|
/**
|
|
* get all groups
|
|
*
|
|
* @param none
|
|
* @return $objects
|
|
*/
|
|
public function getAllGroups()
|
|
{
|
|
try {
|
|
$criteria = new Criteria();
|
|
$criteria->add(GroupwfPeer::GRP_UID, "", Criteria::NOT_EQUAL);
|
|
$con = Propel::getConnection(GroupwfPeer::DATABASE_NAME);
|
|
$objects = GroupwfPeer::doSelect($criteria, $con);
|
|
return $objects;
|
|
} catch (exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* get all the groups from a single user
|
|
*
|
|
* @param $sUserUid user uid
|
|
* @return an array of group objects
|
|
*/
|
|
public function getUserGroups($sUserUID)
|
|
{
|
|
try {
|
|
$criteria = new Criteria();
|
|
$criteria->add(GroupwfPeer::GRP_UID, "", Criteria::NOT_EQUAL);
|
|
$criteria->add(GroupUserPeer::USR_UID, $sUserUID);
|
|
$criteria->add(GroupwfPeer::GRP_STATUS, 'ACTIVE');
|
|
$criteria->addJoin(GroupUserPeer::GRP_UID, GroupwfPeer::GRP_UID, Criteria::LEFT_JOIN);
|
|
$con = Propel::getConnection(GroupwfPeer::DATABASE_NAME);
|
|
$objects = GroupwfPeer::doSelect($criteria, $con);
|
|
return $objects;
|
|
} catch (exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get Available Groups for a single user
|
|
*
|
|
* @author Qennix
|
|
* @param string $sUserUid
|
|
* @return object
|
|
*/
|
|
public function getAvailableGroupsCriteria($sUserUid, $filter = '')
|
|
{
|
|
try {
|
|
$oCriteria = new Criteria('workflow');
|
|
$oCriteria->addSelectColumn(GroupUserPeer::GRP_UID);
|
|
$oCriteria->add(GroupUserPeer::USR_UID, $sUserUid);
|
|
$oCriteria->add(GroupUserPeer::GRP_UID, '', Criteria::NOT_EQUAL);
|
|
$oDataset = GroupUserPeer::doSelectRS($oCriteria);
|
|
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
|
|
$oDataset->next();
|
|
$gUIDs = array();
|
|
while ($aRow = $oDataset->getRow()) {
|
|
$gUIDs[] = $aRow['GRP_UID'];
|
|
$oDataset->next();
|
|
}
|
|
$oCriteria = new Criteria('workflow');
|
|
$oCriteria->addSelectColumn(GroupwfPeer::GRP_UID);
|
|
$oCriteria->addSelectColumn(GroupwfPeer::GRP_STATUS);
|
|
$oCriteria->addAsColumn('CON_VALUE',GroupwfPeer::GRP_TITLE);
|
|
$oCriteria->addAscendingOrderByColumn(GroupwfPeer::GRP_TITLE);
|
|
$oCriteria->add(GroupwfPeer::GRP_UID, $gUIDs, Criteria::NOT_IN);
|
|
$oCriteria->add(GroupwfPeer::GRP_STATUS, 'ACTIVE');
|
|
if ($filter != '') {
|
|
$oCriteria->add(GroupwfPeer::GRP_TITLE, '%' . $filter . '%', Criteria::LIKE);
|
|
}
|
|
return $oCriteria;
|
|
} catch (exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get Assigned Groups for a single user
|
|
*
|
|
* @author Qennix
|
|
* @param string $sUserUid
|
|
* @return object
|
|
*/
|
|
public function getAssignedGroupsCriteria($sUserUid, $filter = '')
|
|
{
|
|
try {
|
|
$oCriteria = new Criteria('workflow');
|
|
$oCriteria->addSelectColumn(GroupwfPeer::GRP_UID);
|
|
$oCriteria->addSelectColumn(GroupwfPeer::GRP_STATUS);
|
|
$oCriteria->addSelectColumn(GroupwfPeer::GRP_LDAP_DN);
|
|
$oCriteria->addAsColumn('CON_VALUE',GroupwfPeer::GRP_TITLE);
|
|
$oCriteria->addAscendingOrderByColumn(GroupwfPeer::GRP_TITLE);
|
|
$oCriteria->addJoin(GroupUserPeer::GRP_UID, GroupwfPeer::GRP_UID, Criteria::LEFT_JOIN);
|
|
$oCriteria->add(GroupUserPeer::USR_UID, $sUserUid, Criteria::EQUAL);
|
|
$oCriteria->add(GroupwfPeer::GRP_STATUS, 'ACTIVE');
|
|
if ($filter != '') {
|
|
$oCriteria->add(GroupwfPeer::GRP_TITLE, '%' . $filter . '%', Criteria::LIKE);
|
|
}
|
|
return $oCriteria;
|
|
} catch (exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
public function getGroupsForUser($usrUid)
|
|
{
|
|
$criteria = $this->getAssignedGroupsCriteria($usrUid);
|
|
$criteria->addAscendingOrderByColumn(GroupwfPeer::GRP_TITLE);
|
|
$dataset = GroupwfPeer::doSelectRS($criteria);
|
|
$dataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
|
|
$dataset->next();
|
|
$groups = array();
|
|
while ($row = $dataset->getRow()) {
|
|
if (!isset($groups[$row['GRP_UID']])) {
|
|
$groups[$row['GRP_UID']] = $row;
|
|
}
|
|
$dataset->next();
|
|
}
|
|
return $groups;
|
|
}
|
|
|
|
/**
|
|
* Remove a user from all groups
|
|
*
|
|
* @param string $sUsrUid
|
|
* @return void
|
|
*/
|
|
public function removeUserOfAllGroups($sUserUID = '')
|
|
{
|
|
try {
|
|
$oCriteria = new Criteria('workflow');
|
|
$oCriteria->add(GroupUserPeer::USR_UID, $sUserUID);
|
|
GroupUserPeer::doDelete($oCriteria);
|
|
} catch (exception $oError) {
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get a criteria object of all users from group
|
|
*
|
|
* @param string $sGroupUID
|
|
* @return array
|
|
*/
|
|
public function getUsersGroupCriteria($sGroupUID = '')
|
|
{
|
|
require_once 'classes/model/GroupUser.php';
|
|
require_once 'classes/model/Users.php';
|
|
try {
|
|
$oCriteria = new Criteria('workflow');
|
|
$oCriteria->addSelectColumn(GroupUserPeer::GRP_UID);
|
|
$oCriteria->addSelectColumn(UsersPeer::USR_UID);
|
|
$oCriteria->addSelectColumn(UsersPeer::USR_USERNAME);
|
|
$oCriteria->addSelectColumn(UsersPeer::USR_FIRSTNAME);
|
|
$oCriteria->addSelectColumn(UsersPeer::USR_LASTNAME);
|
|
$oCriteria->addSelectColumn(UsersPeer::USR_EMAIL);
|
|
$oCriteria->addJoin(GroupUserPeer::USR_UID, UsersPeer::USR_UID, Criteria::LEFT_JOIN);
|
|
$oCriteria->add(GroupUserPeer::GRP_UID, $sGroupUID);
|
|
$oCriteria->add(UsersPeer::USR_STATUS, 'ACTIVE');
|
|
return $oCriteria;
|
|
} catch (exception $oError) {
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get a criteria object of all groups from user
|
|
*
|
|
* @param string $sGroupUID
|
|
* @return array
|
|
*/
|
|
public function getUserGroupsCriteria($sUserUID = '')
|
|
{
|
|
require_once 'classes/model/GroupUser.php';
|
|
require_once 'classes/model/Users.php';
|
|
try {
|
|
$oCriteria = new Criteria('workflow');
|
|
$oCriteria->addSelectColumn(UsersPeer::USR_UID);
|
|
$oCriteria->addSelectColumn(GroupUserPeer::GRP_UID);
|
|
$oCriteria->addSelectColumn(UsersPeer::USR_FIRSTNAME);
|
|
$oCriteria->addSelectColumn(UsersPeer::USR_LASTNAME);
|
|
$oCriteria->addJoin(GroupUserPeer::USR_UID, UsersPeer::USR_UID, Criteria::LEFT_JOIN);
|
|
$oCriteria->add(GroupUserPeer::GRP_UID, $sUserUID);
|
|
$oCriteria->add(UsersPeer::USR_STATUS, 'ACTIVE');
|
|
return $oCriteria;
|
|
} catch (exception $oError) {
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get the number of groups
|
|
*
|
|
* @param string $sGroupUid
|
|
* @return integer $cnt
|
|
*/
|
|
public function getNumberGroups($sUserUID)
|
|
{
|
|
try {
|
|
$allGroups = $this->getUserGroups($sUserUID);
|
|
$cnt = 0;
|
|
foreach ($allGroups as $group) {
|
|
$cnt++;
|
|
}
|
|
return $cnt;
|
|
} catch (exception $oError) {
|
|
print_r($oError);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Return the available users list criteria object
|
|
*
|
|
* @param string $sGroupUID
|
|
* @return object
|
|
*/
|
|
public function getAvailableUsersCriteria($sGroupUID = '')
|
|
{
|
|
try {
|
|
$oCriteria = new Criteria('workflow');
|
|
$oCriteria->addSelectColumn(UsersPeer::USR_UID);
|
|
$oCriteria->addJoin(GroupUserPeer::USR_UID, UsersPeer::USR_UID, Criteria::LEFT_JOIN);
|
|
$oCriteria->add(GroupUserPeer::GRP_UID, $sGroupUID);
|
|
$oCriteria->add(UsersPeer::USR_STATUS, 'ACTIVE');
|
|
$oDataset = UsersPeer::doSelectRS($oCriteria);
|
|
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
|
|
$oDataset->next();
|
|
$aUIDs = array();
|
|
while ($aRow = $oDataset->getRow()) {
|
|
$aUIDs[] = $aRow['USR_UID'];
|
|
$oDataset->next();
|
|
}
|
|
$oCriteria = new Criteria('workflow');
|
|
$oCriteria->addSelectColumn(UsersPeer::USR_UID);
|
|
$oCriteria->addSelectColumn(UsersPeer::USR_FIRSTNAME);
|
|
$oCriteria->addSelectColumn(UsersPeer::USR_LASTNAME);
|
|
$oCriteria->add(UsersPeer::USR_UID, $aUIDs, Criteria::NOT_IN);
|
|
$oCriteria->add(UsersPeer::USR_STATUS, 'ACTIVE');
|
|
return $oCriteria;
|
|
} catch (exception $oError) {
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Verify if a user is assigned to a group
|
|
*
|
|
* @param $GrpUid group Uid
|
|
* @param $UsrUid user Uid
|
|
* @return 1/0 if it's or not assigned
|
|
*/
|
|
public function verifyUsertoGroup($GrpUid, $UsrUid)
|
|
{
|
|
try {
|
|
$oGrp = GroupUserPeer::retrieveByPk($GrpUid, $UsrUid);
|
|
if (is_object($oGrp) && get_class($oGrp) == 'GroupUser') {
|
|
return 1;
|
|
} else {
|
|
return 0;
|
|
}
|
|
} catch (exception $oError) {
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Verify the existence of a Group
|
|
*
|
|
* @param $sGroupUid group Uid
|
|
* @return 1/0 if exist or not
|
|
*/
|
|
public function verifyGroup($sGroupUID)
|
|
{
|
|
try {
|
|
$aUsers = array();
|
|
$oCriteria = new Criteria();
|
|
//$oCriteria->addJoin(UsersPeer::USR_UID, GroupUserPeer::USR_UID, Criteria::LEFT_JOIN);
|
|
$oCriteria->add(GroupwfPeer::GRP_UID, $sGroupUID);
|
|
//$oCriteria->add(UsersPeer::USR_STATUS, 'ACTIVE');
|
|
$oDataset = GroupwfPeer::doSelectRS($oCriteria);
|
|
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
|
|
$oDataset->next();
|
|
$aRow = $oDataset->getRow();
|
|
if (is_array($aRow)) {
|
|
return 1;
|
|
} else {
|
|
return 0;
|
|
}
|
|
} catch (exception $oError) {
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Load all the data of a group with a search based on it uid
|
|
*
|
|
* @param $GrpUid group uid
|
|
* @return an array of objects/false/exception object
|
|
*
|
|
*/
|
|
public function load($GrpUid)
|
|
{
|
|
try {
|
|
$criteria = new Criteria();
|
|
$criteria->add(GroupwfPeer::GRP_UID, $GrpUid, Criteria::EQUAL);
|
|
$con = Propel::getConnection(GroupwfPeer::DATABASE_NAME);
|
|
$objects = GroupwfPeer::doSelect($criteria, $con);
|
|
if (is_array($objects) && count($objects) > 0) {
|
|
return $objects[0];
|
|
} else {
|
|
return false;
|
|
}
|
|
} catch (exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
}
|