diff --git a/workflow/engine/src/BusinessModel/Task.php b/workflow/engine/src/BusinessModel/Task.php index 5f61f4997..3b9d4f6d2 100644 --- a/workflow/engine/src/BusinessModel/Task.php +++ b/workflow/engine/src/BusinessModel/Task.php @@ -543,5 +543,669 @@ class Task } } + + + /** + * Return a assignee list of an activity + * + * @param string $sProcessUID + * @param string $sTaskUID + * + * return array + * + * @access public + */ + public function getTaskAssignees($sProcessUID, $sTaskUID) + { + try { + $aUsers = array(); + $sDelimiter = \DBAdapter::getStringDelimiter(); + $oCriteria = new \Criteria('workflow'); + $oCriteria->addAsColumn('GRP_TITLE', 'C.CON_VALUE'); + $oCriteria->addSelectColumn(\TaskUserPeer::TAS_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::USR_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_TYPE); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_RELATION); + $oCriteria->addAlias('C', 'CONTENT'); + + $aConditions = array(); + $aConditions[] = array(\TaskUserPeer::USR_UID, 'C.CON_ID' ); + $aConditions[] = array('C.CON_CATEGORY', $sDelimiter . 'GRP_TITLE' . $sDelimiter ); + $aConditions[] = array('C.CON_LANG', $sDelimiter . SYS_LANG . $sDelimiter ); + $oCriteria->addJoinMC($aConditions, \Criteria::LEFT_JOIN); + $oCriteria->add(\TaskUserPeer::TAS_UID, $sTaskUID); + $oCriteria->add(\TaskUserPeer::TU_TYPE, 1); + $oCriteria->add(\TaskUserPeer::TU_RELATION, 2); + $oDataset = \TaskUserPeer::doSelectRS($oCriteria); + $oDataset->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset->next(); + $c = 0; + while ($aRow = $oDataset->getRow()) { + $c++; + $oGroup = new \Groupwf(); + $aFields = $oGroup->load($aRow['USR_UID']); + if ($aFields['GRP_STATUS'] == 'ACTIVE') { + $oCriteria = new \Criteria('workflow'); + $oCriteria->addSelectColumn('COUNT(*) AS MEMBERS_NUMBER'); + $oCriteria->add(\GroupUserPeer::GRP_UID, $aRow['USR_UID']); + $oDataset2 = \GroupUserPeer::doSelectRS($oCriteria); + $oDataset2->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset2->next(); + $aRow2 = $oDataset2->getRow(); + } else { + $aRow2['GROUP_INACTIVE'] = '(' . \G::LoadTranslation('ID_GROUP_INACTIVE') . ')'; + } + $aUsers[] = array('aas_uid' => $aRow['USR_UID'], + 'aas_name' => (!isset($aRow2['GROUP_INACTIVE']) ? $aRow['GRP_TITLE'] . + ' (' . $aRow2['MEMBERS_NUMBER'] . + ' ' . ((int) $aRow2['MEMBERS_NUMBER'] == 1 ? \G::LoadTranslation('ID_USER') : \G::LoadTranslation('ID_USERS')) . + ')' . '' : $aRow['GRP_TITLE'] . ' ' . $aRow2['GROUP_INACTIVE']), + 'aas_lastname' => "", + 'aas_username' => "", + 'aas_type' => "group"); + $oDataset->next(); + } + $oCriteria = new \Criteria('workflow'); + $oCriteria->addSelectColumn(\UsersPeer::USR_FIRSTNAME); + $oCriteria->addSelectColumn(\UsersPeer::USR_LASTNAME); + $oCriteria->addSelectColumn(\UsersPeer::USR_USERNAME); + $oCriteria->addSelectColumn(\UsersPeer::USR_EMAIL); + $oCriteria->addSelectColumn(\TaskUserPeer::TAS_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::USR_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_TYPE); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_RELATION); + $oCriteria->addJoin(\TaskUserPeer::USR_UID, \UsersPeer::USR_UID, \Criteria::LEFT_JOIN); + $oCriteria->add(\TaskUserPeer::TAS_UID, $sTaskUID); + $oCriteria->add(\TaskUserPeer::TU_TYPE, 1); + $oCriteria->add(\TaskUserPeer::TU_RELATION, 1); + $oDataset = \TaskUserPeer::doSelectRS($oCriteria); + $oDataset->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset->next(); + while ($aRow = $oDataset->getRow()) { + $aUsers[] = array('aas_uid' => $aRow['USR_UID'], + 'aas_name' => $aRow['USR_FIRSTNAME'], + 'aas_lastname' => $aRow['USR_LASTNAME'], + 'aas_username' => $aRow['USR_USERNAME'], + 'aas_type' => "user" ); + $oDataset->next(); + } + return $aUsers; + } catch (Exception $e) { + throw $e; + } + } + + /** + * Return the available users and users groups to assigned to an activity + * + * @param string $sProcessUID + * @param string $sTaskUID + * + * return array + * + * @access public + */ + + public function getTaskAvailableAssignee($sProcessUID, $sTaskUID) + { + try { + $iType = 1; + $aUsers = array(); + $oTasks = new \Tasks(); + $aAux = $oTasks->getGroupsOfTask($sTaskUID, $iType); + $aUIDS1 = array(); + $aUIDS2 = array(); + foreach ($aAux as $aGroup) { + $aUIDS1[] = $aGroup['GRP_UID']; + } + $aAux = $oTasks->getUsersOfTask($sTaskUID, $iType); + foreach ($aAux as $aUser) { + $aUIDS2[] = $aUser['USR_UID']; + } + $aUsers = array(); + $sDelimiter = \DBAdapter::getStringDelimiter(); + $groups = new \Groupwf(); + $start = ''; + $limit = ''; + $filter = ''; + $result = $groups->getAllGroup($start, $limit, $filter); + $c = 0; + foreach ($result['rows'] as $results) { + if (!in_array($results['GRP_UID'], $aUIDS1)) { + $c++; + $oCriteria = new \Criteria('workflow'); + $oCriteria->addSelectColumn('COUNT(*) AS MEMBERS_NUMBER'); + $oCriteria->add(\GroupUserPeer::GRP_UID, $results['GRP_UID']); + $oDataset2 = \GroupUserPeer::doSelectRS($oCriteria); + $oDataset2->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset2->next(); + $aRow2 = $oDataset2->getRow(); + $aUsers[] = array('aas_uid' => $results['GRP_UID'], + 'aas_name' => (!isset($aRow2['GROUP_INACTIVE']) ? $results['GRP_TITLE'] . + ' (' . $aRow2['MEMBERS_NUMBER'] . + ' ' . ((int) $aRow2['MEMBERS_NUMBER'] == 1 ? \G::LoadTranslation('ID_USER') : \G::LoadTranslation('ID_USERS')) . + ')' . '' : $aRow['GRP_TITLE'] . ' ' . $aRow2['GROUP_INACTIVE']), + 'aas_lastname' => "", + 'aas_username' => "", + 'aas_type' => "group" ); + } + } + $sDelimiter = \DBAdapter::getStringDelimiter(); + $oCriteria = new \Criteria('workflow'); + $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->add(\UsersPeer::USR_STATUS, 'ACTIVE'); + $oCriteria->add(\UsersPeer::USR_UID, $aUIDS2, \Criteria::NOT_IN); + $oDataset = \UsersPeer::doSelectRS($oCriteria); + $oDataset->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset->next(); + while ($aRow = $oDataset->getRow()) { + $aUsers[] = array('aas_uid' => $aRow['USR_UID'], + 'aas_name' => $aRow['USR_FIRSTNAME'], + 'aas_lastname' => $aRow['USR_LASTNAME'], + 'aas_username' => $aRow['USR_USERNAME'], + 'aas_type' => "user" ); + $oDataset->next(); + } + return $aUsers; + } catch (Exception $e) { + throw $e; + } + } + + /** + * Return a single user or group assigned to an activity + * + * @param string $sProcessUID + * @param string $sTaskUID + * @param string $sAssigneeUID + * + * return array + * + * @access public + */ + public function getTaskAssignee($sProcessUID, $sTaskUID, $sAssigneeUID) + { + try { + $iType = 1; + $aUsers = array(); + $sDelimiter = \DBAdapter::getStringDelimiter(); + $oCriteria = new \Criteria('workflow'); + $oCriteria->addAsColumn('GRP_TITLE', 'C.CON_VALUE'); + $oCriteria->addSelectColumn(\TaskUserPeer::TAS_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::USR_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_TYPE); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_RELATION); + $oCriteria->addAlias('C', 'CONTENT'); + + $aConditions = array(); + $aConditions[] = array(\TaskUserPeer::USR_UID, 'C.CON_ID' ); + $aConditions[] = array('C.CON_CATEGORY', $sDelimiter . 'GRP_TITLE' . $sDelimiter ); + $aConditions[] = array('C.CON_LANG', $sDelimiter . SYS_LANG . $sDelimiter ); + $oCriteria->addJoinMC($aConditions, \Criteria::LEFT_JOIN); + $oCriteria->add(\TaskUserPeer::USR_UID, $sAssigneeUID); + $oCriteria->add(\TaskUserPeer::TAS_UID, $sTaskUID); + $oCriteria->add(\TaskUserPeer::TU_TYPE, $iType); + $oCriteria->add(\TaskUserPeer::TU_RELATION, 2); + $oDataset = \TaskUserPeer::doSelectRS($oCriteria); + $oDataset->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset->next(); + $c = 0; + while ($aRow = $oDataset->getRow()) { + $c++; + $oGroup = new \Groupwf(); + $aFields = $oGroup->load($aRow['USR_UID']); + if ($aFields['GRP_STATUS'] == 'ACTIVE') { + $oCriteria = new \Criteria('workflow'); + $oCriteria->addSelectColumn('COUNT(*) AS MEMBERS_NUMBER'); + $oCriteria->add(\GroupUserPeer::GRP_UID, $aRow['USR_UID']); + $oDataset2 = \GroupUserPeer::doSelectRS($oCriteria); + $oDataset2->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset2->next(); + $aRow2 = $oDataset2->getRow(); + } else { + $aRow2['GROUP_INACTIVE'] = '(' . \G::LoadTranslation('ID_GROUP_INACTIVE') . ')'; + } + $aUsers = array('aas_uid' => $aRow['USR_UID'], + 'aas_name' => (!isset($aRow2['GROUP_INACTIVE']) ? $aRow['GRP_TITLE'] . + ' (' . $aRow2['MEMBERS_NUMBER'] . + ' ' . ((int) $aRow2['MEMBERS_NUMBER'] == 1 ? \G::LoadTranslation('ID_USER') : \G::LoadTranslation('ID_USERS')) . + ')' . '' : $aRow['GRP_TITLE'] . ' ' . $aRow2['GROUP_INACTIVE']), + 'aas_lastname' => "", + 'aas_username' => "", + 'aas_type' => "group" ); + $oDataset->next(); + } + $oCriteria = new \Criteria('workflow'); + $oCriteria->addSelectColumn(\UsersPeer::USR_FIRSTNAME); + $oCriteria->addSelectColumn(\UsersPeer::USR_LASTNAME); + $oCriteria->addSelectColumn(\UsersPeer::USR_USERNAME); + $oCriteria->addSelectColumn(\UsersPeer::USR_EMAIL); + $oCriteria->addSelectColumn(\TaskUserPeer::TAS_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::USR_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_TYPE); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_RELATION); + $oCriteria->addJoin(\TaskUserPeer::USR_UID, \UsersPeer::USR_UID, \Criteria::LEFT_JOIN); + $oCriteria->add(\TaskUserPeer::USR_UID, $sAssigneeUID); + $oCriteria->add(\TaskUserPeer::TAS_UID, $sTaskUID); + $oCriteria->add(\TaskUserPeer::TU_TYPE, $iType); + $oCriteria->add(\TaskUserPeer::TU_RELATION, 1); + $oDataset = \TaskUserPeer::doSelectRS($oCriteria); + $oDataset->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset->next(); + while ($aRow = $oDataset->getRow()) { + $aUsers = array('aas_uid' => $aRow['USR_UID'], + 'aas_name' => $aRow['USR_FIRSTNAME'], + 'aas_lastname' => $aRow['USR_LASTNAME'], + 'aas_username' => $aRow['USR_USERNAME'], + 'aas_type' => "user" ); + $oDataset->next(); + } + return $aUsers; + } catch (Exception $e) { + throw $e; + } + } + + + /** + * Assign a user or group to an activity + * + * @param string $sProcessUID + * @param string $sTaskUID + * @param string $sAssigneeUID + * @param int $sRelation + * + * return array + * + * @access public + */ + public function postTaskAssignee($sProcessUID, $sTaskUID, $sAssigneeUID, $sRelation) + { + try { + $iType = 1; + $oTaskUser = new \TaskUser(); + if ($sRelation == 1) { + $oTaskUser->create(array('TAS_UID' => $sTaskUID, + 'USR_UID' => $sAssigneeUID, + 'TU_TYPE' => $iType, + 'TU_RELATION' => $sRelation)); + return array('aas_uid' => $sAssigneeUID, + 'aas_type' => "user"); + } else { + $oTaskUser->create(array('TAS_UID' => $sTaskUID, + 'USR_UID' => $sAssigneeUID, + 'TU_TYPE' => $iType, + 'TU_RELATION' => $sRelation)); + return array('aas_uid' => $sAssigneeUID, + 'aas_type' => "group"); + } + } catch (Exception $e) { + throw $e; + } + } + + /** + * Remove a assignee of an activity + * + * @param string $sProcessUID + * @param string $sTaskUID + * @param string $sAssigneeUID + * @param int $sRelation + * + * @access public + */ + public function deleteTaskAssignee($sProcessUID, $sTaskUID, $sAssigneeUID, $sRelation) + { + try { + $iType = 1; + $oTaskUser = new \TaskUser(); + + if ($sRelation == 1) { + $oTaskUser->remove($sTaskUID, $sAssigneeUID, $iType, $sRelation); + } else { + $oTaskUser->remove($sTaskUID, $sAssigneeUID, $iType, $sRelation); + } + + + } catch (Exception $e) { + throw $e; + } + + } + + /** + * Return a adhoc assignee list of an activity + * + * @param string $sProcessUID + * @param string $sTaskUID + * + * return array + * + * @access public + */ + public function getTaskAdhocAssignees($sProcessUID, $sTaskUID) + { + try { + $aUsers = array(); + $sDelimiter = \DBAdapter::getStringDelimiter(); + $oCriteria = new \Criteria('workflow'); + $oCriteria->addAsColumn('GRP_TITLE', 'C.CON_VALUE'); + $oCriteria->addSelectColumn(\TaskUserPeer::TAS_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::USR_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_TYPE); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_RELATION); + $oCriteria->addAlias('C', 'CONTENT'); + + $aConditions = array(); + $aConditions[] = array(\TaskUserPeer::USR_UID, 'C.CON_ID' ); + $aConditions[] = array('C.CON_CATEGORY', $sDelimiter . 'GRP_TITLE' . $sDelimiter ); + $aConditions[] = array('C.CON_LANG', $sDelimiter . SYS_LANG . $sDelimiter ); + $oCriteria->addJoinMC($aConditions, \Criteria::LEFT_JOIN); + $oCriteria->add(\TaskUserPeer::TAS_UID, $sTaskUID); + $oCriteria->add(\TaskUserPeer::TU_TYPE, 2); + $oCriteria->add(\TaskUserPeer::TU_RELATION, 2); + $oDataset = \TaskUserPeer::doSelectRS($oCriteria); + $oDataset->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset->next(); + $c = 0; + while ($aRow = $oDataset->getRow()) { + $c++; + $oGroup = new \Groupwf(); + $aFields = $oGroup->load($aRow['USR_UID']); + if ($aFields['GRP_STATUS'] == 'ACTIVE') { + $oCriteria = new \Criteria('workflow'); + $oCriteria->addSelectColumn('COUNT(*) AS MEMBERS_NUMBER'); + $oCriteria->add(\GroupUserPeer::GRP_UID, $aRow['USR_UID']); + $oDataset2 = \GroupUserPeer::doSelectRS($oCriteria); + $oDataset2->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset2->next(); + $aRow2 = $oDataset2->getRow(); + } else { + $aRow2['GROUP_INACTIVE'] = '(' . \G::LoadTranslation('ID_GROUP_INACTIVE') . ')'; + } + $aUsers[] = array('aas_uid' => $aRow['USR_UID'], + 'aas_name' => (!isset($aRow2['GROUP_INACTIVE']) ? $aRow['GRP_TITLE'] . + ' (' . $aRow2['MEMBERS_NUMBER'] . + ' ' . ((int) $aRow2['MEMBERS_NUMBER'] == 1 ? \G::LoadTranslation('ID_USER') : \G::LoadTranslation('ID_USERS')) . + ')' . '' : $aRow['GRP_TITLE'] . ' ' . $aRow2['GROUP_INACTIVE']), + 'aas_lastname' => "", + 'aas_username' => "", + 'aas_type' => "group"); + $oDataset->next(); + } + $oCriteria = new \Criteria('workflow'); + $oCriteria->addSelectColumn(\UsersPeer::USR_FIRSTNAME); + $oCriteria->addSelectColumn(\UsersPeer::USR_LASTNAME); + $oCriteria->addSelectColumn(\UsersPeer::USR_USERNAME); + $oCriteria->addSelectColumn(\UsersPeer::USR_EMAIL); + $oCriteria->addSelectColumn(\TaskUserPeer::TAS_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::USR_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_TYPE); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_RELATION); + $oCriteria->addJoin(\TaskUserPeer::USR_UID, \UsersPeer::USR_UID, \Criteria::LEFT_JOIN); + $oCriteria->add(\TaskUserPeer::TAS_UID, $sTaskUID); + $oCriteria->add(\TaskUserPeer::TU_TYPE, 2); + $oCriteria->add(\TaskUserPeer::TU_RELATION, 1); + $oDataset = \TaskUserPeer::doSelectRS($oCriteria); + $oDataset->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset->next(); + while ($aRow = $oDataset->getRow()) { + $aUsers[] = array('aas_uid' => $aRow['USR_UID'], + 'aas_name' => $aRow['USR_FIRSTNAME'], + 'aas_lastname' => $aRow['USR_LASTNAME'], + 'aas_username' => $aRow['USR_USERNAME'], + 'aas_type' => "user" ); + $oDataset->next(); + } + return $aUsers; + } catch (Exception $e) { + throw $e; + } + } + + /** + * Return the available adhoc users and users groups to assigned to an activity + * + * @param string $sProcessUID + * @param string $sTaskUID + * + * return array + * + * @access public + */ + + public function getTaskAvailableAdhocAssignee($sProcessUID, $sTaskUID) + { + try { + $iType = 2; + $aUsers = array(); + $oTasks = new \Tasks(); + $aAux = $oTasks->getGroupsOfTask($sTaskUID, $iType); + $aUIDS1 = array(); + $aUIDS2 = array(); + foreach ($aAux as $aGroup) { + $aUIDS1[] = $aGroup['GRP_UID']; + } + $aAux = $oTasks->getUsersOfTask($sTaskUID, $iType); + foreach ($aAux as $aUser) { + $aUIDS2[] = $aUser['USR_UID']; + } + $aUsers = array(); + $sDelimiter = \DBAdapter::getStringDelimiter(); + $groups = new \Groupwf(); + $start = ''; + $limit = ''; + $filter = ''; + $result = $groups->getAllGroup($start, $limit, $filter); + $c = 0; + foreach ($result['rows'] as $results) { + if (!in_array($results['GRP_UID'], $aUIDS1)) { + $c++; + $oCriteria = new \Criteria('workflow'); + $oCriteria->addSelectColumn('COUNT(*) AS MEMBERS_NUMBER'); + $oCriteria->add(\GroupUserPeer::GRP_UID, $results['GRP_UID']); + $oDataset2 = \GroupUserPeer::doSelectRS($oCriteria); + $oDataset2->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset2->next(); + $aRow2 = $oDataset2->getRow(); + $aUsers[] = array('aas_uid' => $results['GRP_UID'], + 'aas_name' => (!isset($aRow2['GROUP_INACTIVE']) ? $results['GRP_TITLE'] . + ' (' . $aRow2['MEMBERS_NUMBER'] . + ' ' . ((int) $aRow2['MEMBERS_NUMBER'] == 1 ? \G::LoadTranslation('ID_USER') : \G::LoadTranslation('ID_USERS')) . + ')' . '' : $aRow['GRP_TITLE'] . ' ' . $aRow2['GROUP_INACTIVE']), + 'aas_lastname' => "", + 'aas_username' => "", + 'aas_type' => "group" ); + } + } + $sDelimiter = \DBAdapter::getStringDelimiter(); + $oCriteria = new \Criteria('workflow'); + $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->add(\UsersPeer::USR_STATUS, 'ACTIVE'); + $oCriteria->add(\UsersPeer::USR_UID, $aUIDS2, \Criteria::NOT_IN); + $oDataset = \UsersPeer::doSelectRS($oCriteria); + $oDataset->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset->next(); + while ($aRow = $oDataset->getRow()) { + $aUsers[] = array('aas_uid' => $aRow['USR_UID'], + 'aas_name' => $aRow['USR_FIRSTNAME'], + 'aas_lastname' => $aRow['USR_LASTNAME'], + 'aas_username' => $aRow['USR_USERNAME'], + 'aas_type' => "user" ); + $oDataset->next(); + } + return $aUsers; + } catch (Exception $e) { + throw $e; + } + } + + /** + * Return a single Adhoc user or group assigned to an activity + * + * @param string $sProcessUID + * @param string $sTaskUID + * @param string $sAssigneeUID + * + * return array + * + * @access public + */ + public function getTaskAdhocAssignee($sProcessUID, $sTaskUID, $sAssigneeUID) + { + try { + $iType = 2; + $aUsers = array(); + $sDelimiter = \DBAdapter::getStringDelimiter(); + $oCriteria = new \Criteria('workflow' ); + $oCriteria->addAsColumn('GRP_TITLE', 'C.CON_VALUE'); + $oCriteria->addSelectColumn(\TaskUserPeer::TAS_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::USR_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_TYPE); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_RELATION); + $oCriteria->addAlias('C', 'CONTENT'); + + $aConditions = array(); + $aConditions[] = array(\TaskUserPeer::USR_UID, 'C.CON_ID' ); + $aConditions[] = array('C.CON_CATEGORY', $sDelimiter . 'GRP_TITLE' . $sDelimiter ); + $aConditions[] = array('C.CON_LANG', $sDelimiter . SYS_LANG . $sDelimiter ); + $oCriteria->addJoinMC($aConditions, \Criteria::LEFT_JOIN); + $oCriteria->add(\TaskUserPeer::USR_UID, $sAssigneeUID); + $oCriteria->add(\TaskUserPeer::TAS_UID, $sTaskUID); + $oCriteria->add(\TaskUserPeer::TU_TYPE, $iType); + $oCriteria->add(\TaskUserPeer::TU_RELATION, 2); + $oDataset = \TaskUserPeer::doSelectRS($oCriteria); + $oDataset->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset->next(); + $c = 0; + while ($aRow = $oDataset->getRow()) { + $c++; + $oGroup = new \Groupwf(); + $aFields = $oGroup->load($aRow['USR_UID']); + if ($aFields['GRP_STATUS'] == 'ACTIVE') { + $oCriteria = new \Criteria('workflow'); + $oCriteria->addSelectColumn('COUNT(*) AS MEMBERS_NUMBER'); + $oCriteria->add(\GroupUserPeer::GRP_UID, $aRow['USR_UID']); + $oDataset2 = \GroupUserPeer::doSelectRS($oCriteria); + $oDataset2->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset2->next(); + $aRow2 = $oDataset2->getRow(); + } else { + $aRow2['GROUP_INACTIVE'] = '(' . \G::LoadTranslation('ID_GROUP_INACTIVE') . ')'; + } + $aUsers = array('aas_uid' => $aRow['USR_UID'], + 'aas_name' => (!isset($aRow2['GROUP_INACTIVE']) ? $aRow['GRP_TITLE'] . + ' (' . $aRow2['MEMBERS_NUMBER'] . + ' ' . ((int) $aRow2['MEMBERS_NUMBER'] == 1 ? \G::LoadTranslation('ID_USER') : \G::LoadTranslation('ID_USERS')) . + ')' . '' : $aRow['GRP_TITLE'] . ' ' . $aRow2['GROUP_INACTIVE']), + 'aas_lastname' => "", + 'aas_username' => "", + 'aas_type' => "group" ); + $oDataset->next(); + } + $oCriteria = new \Criteria('workflow'); + $oCriteria->addSelectColumn(\UsersPeer::USR_FIRSTNAME); + $oCriteria->addSelectColumn(\UsersPeer::USR_LASTNAME); + $oCriteria->addSelectColumn(\UsersPeer::USR_USERNAME); + $oCriteria->addSelectColumn(\UsersPeer::USR_EMAIL); + $oCriteria->addSelectColumn(\TaskUserPeer::TAS_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::USR_UID); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_TYPE); + $oCriteria->addSelectColumn(\TaskUserPeer::TU_RELATION); + $oCriteria->addJoin(\TaskUserPeer::USR_UID, \UsersPeer::USR_UID, \Criteria::LEFT_JOIN); + $oCriteria->add(\TaskUserPeer::USR_UID, $sAssigneeUID); + $oCriteria->add(\TaskUserPeer::TAS_UID, $sTaskUID); + $oCriteria->add(\TaskUserPeer::TU_TYPE, $iType); + $oCriteria->add(\TaskUserPeer::TU_RELATION, 1); + $oDataset = \TaskUserPeer::doSelectRS($oCriteria); + $oDataset->setFetchmode(\ResultSet::FETCHMODE_ASSOC); + $oDataset->next(); + while ($aRow = $oDataset->getRow()) { + $aUsers = array('aas_uid' => $aRow['USR_UID'], + 'aas_name' => $aRow['USR_FIRSTNAME'], + 'aas_lastname' => $aRow['USR_LASTNAME'], + 'aas_username' => $aRow['USR_USERNAME'], + 'aas_type' => "user" ); + $oDataset->next(); + } + return $aUsers; + } catch (Exception $e) { + throw $e; + } + } + + + /** + * Assign a Adhoc user or group to an activity + * + * @param string $sProcessUID + * @param string $sTaskUID + * @param string $sAssigneeUID + * @param int $sRelation + * + * return array + * + * @access public + */ + public function postTaskAdhocAssignee($sProcessUID, $sTaskUID, $sAssigneeUID, $sRelation) + { + try { + $iType = 2; + $oTaskUser = new \TaskUser(); + if ($sRelation == 1) { + $oTaskUser->create(array('TAS_UID' => $sTaskUID, + 'USR_UID' => $sAssigneeUID, + 'TU_TYPE' => $iType, + 'TU_RELATION' => $sRelation)); + return array('aas_uid' => $sAssigneeUID, + 'aas_type' => "user"); + } else { + $oTaskUser->create(array('TAS_UID' => $sTaskUID, + 'USR_UID' => $sAssigneeUID, + 'TU_TYPE' => $iType, + 'TU_RELATION' => $sRelation)); + return array('aas_uid' => $sAssigneeUID, + 'aas_type' => "group"); + } + } catch (Exception $e) { + throw $e; + } + } + + /** + * Remove a Adhoc assignee of an activity + * + * @param string $sProcessUID + * @param string $sTaskUID + * @param string $sAssigneeUID + * @param int $sRelation + * + * @access public + */ + public function deleteTaskAdhocAssignee($sProcessUID, $sTaskUID, $sAssigneeUID, $sRelation) + { + try { + $iType = 2; + $oTaskUser = new \TaskUser(); + + if ($sRelation == 1) { + $oTaskUser->remove($sTaskUID, $sAssigneeUID, $iType, $sRelation); + } else { + $oTaskUser->remove($sTaskUID, $sAssigneeUID, $iType, $sRelation); + } + + } catch (Exception $e) { + throw $e; + } + } + } diff --git a/workflow/engine/src/Services/Api/ProcessMaker/Project/Activity/Assignee.php b/workflow/engine/src/Services/Api/ProcessMaker/Project/Activity/Assignee.php new file mode 100644 index 000000000..1d8e7279f --- /dev/null +++ b/workflow/engine/src/Services/Api/ProcessMaker/Project/Activity/Assignee.php @@ -0,0 +1,236 @@ +getTaskAssignees($prj_uid, $act_uid, $filter, $start, $limit); + + //Response + $response = $arrayData; + } catch (\Exception $e) { + //Response + $response["success"] = false; + $response["message"] = $e->getMessage(); + } + + return $response; + } + + /** + * @url GET /:prj_uid/activity/:act_uid/available-assignee + */ + public function doGetActivityAvailableAssignee($prj_uid, $act_uid, $filter = '', $start = '', $limit = '') + { + $response = array(); + + try { + $task = new \BusinessModel\Task(); + $arrayData = $task->getTaskAvailableAssignee($prj_uid, $act_uid); + + //Response + $response = $arrayData; + } catch (\Exception $e) { + //response + $response["success"] = false; + $response["message"] = $e->getMessage(); + } + + return $response; + } + + /** + * @url GET /:prj_uid/activity/:act_uid/assignee/:aas_uid + */ + public function doGetActivityAssignee($prj_uid, $act_uid, $aas_uid) + { + $response = array(); + + try { + $task = new \BusinessModel\Task(); + $arrayData = $task->getTaskAssignee($prj_uid, $act_uid, $aas_uid); + + //Response + $response = $arrayData; + } catch (\Exception $e) { + //response + $response["success"] = false; + $response["message"] = $e->getMessage(); + } + + return $response; + } + + /** + * @url POST /:prj_uid/activity/:act_uid/assignee + * @status 201 + */ + public function doPostActivityAssignee($prj_uid, $act_uid, $assignee_uid, $tu_relation) + { + $response = array(); + + try { + $task = new \BusinessModel\Task(); + $arrayData = $task->postTaskAssignee($prj_uid, $act_uid, $assignee_uid, $tu_relation); + + //Response + $response ["success"] = true; + $response = $arrayData; + } catch (\Exception $e) { + //response + $response["success"] = false; + $response["message"] = $e->getMessage(); + } + + return $response; + } + + /** + * @url DELETE /:prj_uid/activity/:act_uid/assignee/:aas_uid/relation/:tu_relation + */ + public function doDeleteActivityAssignee($prj_uid, $act_uid, $aas_uid, $tu_relation) + { + $response = array(); + + try { + $task = new \BusinessModel\Task(); + $arrayData = $task->deleteTaskAssignee($prj_uid, $act_uid, $aas_uid, $tu_relation); + + } catch (\Exception $e) { + //response + $response["success"] = false; + $response["message"] = $e->getMessage(); + } + + return $response; + } + + /** + * @url GET /:prj_uid/activity/:act_uid/adhoc-assignee + */ + public function doGetActivityAdhocAssignees($prj_uid, $act_uid, $filter = '', $start = '', $limit = '') + { + $response = array(); + + try { + $task = new \BusinessModel\Task(); + $arrayData = $task->getTaskAdhocAssignees($prj_uid, $act_uid, $filter, $start, $limit); + + //Response + $response = $arrayData; + } catch (\Exception $e) { + //Response + $response["success"] = false; + $response["message"] = $e->getMessage(); + } + + return $response; + } + + /** + * @url GET /:prj_uid/activity/:act_uid/available-adhoc-assignee + */ + public function doGetActivityAvailableAdhocAssignee($prj_uid, $act_uid, $filter = '', $start = '', $limit = '') + { + $response = array(); + + try { + $task = new \BusinessModel\Task(); + $arrayData = $task->getTaskAvailableAdhocAssignee($prj_uid, $act_uid); + + //Response + $response = $arrayData; + } catch (\Exception $e) { + //response + $response["success"] = false; + $response["message"] = $e->getMessage(); + } + + return $response; + } + + /** + * @url GET /:prj_uid/activity/:act_uid/adhoc-assignee/:aas_uid + */ + public function doGetActivityAdhocAssignee($prj_uid, $act_uid, $aas_uid) + { + $response = array(); + + try { + $task = new \BusinessModel\Task(); + $arrayData = $task->getTaskAdhocAssignee($prj_uid, $act_uid, $aas_uid); + + //Response + $response = $arrayData; + } catch (\Exception $e) { + //response + $response["success"] = false; + $response["message"] = $e->getMessage(); + } + + return $response; + } + + /** + * @url POST /:prj_uid/activity/:act_uid/adhoc-assignee + * @status 201 + */ + public function doPostActivityAdhocAssignee($prj_uid, $act_uid, $assignee_uid, $tu_relation) + { + $response = array(); + + try { + $task = new \BusinessModel\Task(); + $arrayData = $task->postTaskAdhocAssignee($prj_uid, $act_uid, $assignee_uid, $tu_relation); + + //Response + $response ["success"] = true; + $response = $arrayData; + } catch (\Exception $e) { + //response + $response["success"] = false; + $response["message"] = $e->getMessage(); + } + + return $response; + } + + /** + * @url DELETE /:prj_uid/activity/:act_uid/adhoc-assignee/:aas_uid/relation/:tu_relation + */ + public function doDeleteActivityAdhocAssignee($prj_uid, $act_uid, $aas_uid, $tu_relation) + { + $response = array(); + + try { + $task = new \BusinessModel\Task(); + $arrayData = $task->deleteTaskAdhocAssignee($prj_uid, $act_uid, $aas_uid, $tu_relation); + + } catch (\Exception $e) { + //response + $response["success"] = false; + $response["message"] = $e->getMessage(); + } + + return $response; + } + +} + diff --git a/workflow/engine/src/Services/api.ini b/workflow/engine/src/Services/api.ini index 2c7f5c67b..d4cae4ed5 100644 --- a/workflow/engine/src/Services/api.ini +++ b/workflow/engine/src/Services/api.ini @@ -15,4 +15,5 @@ debug = 1 [alias: project] activity = "Services\Api\ProcessMaker\Project\Activity" step = "Services\Api\ProcessMaker\Project\Activity\Step" + assignee = "Services\Api\ProcessMaker\Project\Activity\Assignee"