Files
luos/workflow/engine/classes/class.wsBase.php

3373 lines
121 KiB
PHP
Raw Normal View History

2010-12-02 23:34:41 +00:00
<?php
/**
* class.wsBase.php
2012-10-09 13:29:25 -04:00
*
* @package workflow.engine.classes
2010-12-02 23:34:41 +00:00
*
* ProcessMaker Open Source Edition
* Copyright (C) 2004 - 2011 Colosa Inc.
2010-12-02 23:34:41 +00:00
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
2012-10-09 13:29:25 -04:00
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
2010-12-02 23:34:41 +00:00
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
2012-10-09 13:29:25 -04:00
* along with this program. If not, see <http://www.gnu.org/licenses/>.
2010-12-02 23:34:41 +00:00
*
* For more information, contact Colosa Inc, 2566 Le Jeune Rd.,
* Coral Gables, FL, 33134, USA, or email info@colosa.com.
*/
2012-10-09 13:29:25 -04:00
//It works with the table CONFIGURATION in a WF dataBase
//require_once ("classes/model/Application.php");
//require_once ("classes/model/AppCacheView.php");
//require_once ("classes/model/AppDelegation.php");
//require_once ("classes/model/AppDocument.php");
//require_once ("classes/model/AppDelay.php");
//require_once ("classes/model/AppNotes.php");
//require_once ("classes/model/AppThread.php");
//require_once ("classes/model/Department.php");
//require_once ("classes/model/Dynaform.php");
//require_once ("classes/model/Groupwf.php");
//require_once ("classes/model/InputDocument.php");
//require_once ("classes/model/Language.php");
//require_once ("classes/model/OutputDocument.php");
//require_once ("classes/model/Process.php");
//require_once ("classes/model/ReportTable.php");
//require_once ("classes/model/ReportVar.php");
//require_once ("classes/model/Route.php");
//require_once ("classes/model/Step.php");
//require_once ("classes/model/StepTrigger.php");
//require_once ("classes/model/Task.php");
//require_once ("classes/model/TaskUser.php");
//require_once ("classes/model/Triggers.php");
//require_once ("classes/model/Users.php");
//require_once ("classes/model/Session.php");
//require_once ("classes/model/Content.php");
//G::LoadClass( "ArrayPeer" );
//G::LoadClass( "BasePeer" );
2012-10-09 13:29:25 -04:00
G::LoadClass( 'case' );
//G::LoadClass( 'derivation' );
//G::LoadClass( 'groups' );
//G::LoadClass( 'sessions' );
//G::LoadClass( 'processes' );
//G::LoadClass( 'processMap' );
//G::LoadClass( 'pmScript' );
//G::LoadClass( 'spool' );
//G::LoadClass( 'tasks' );
//G::LoadClass( 'wsResponse' );
2010-12-02 23:34:41 +00:00
2012-10-09 13:29:25 -04:00
/**
* Copyright (C) 2009 COLOSA
* License: LGPL, see LICENSE
* Last Modify: 26.06.2008 10:05:00
* Last modify by: Erik Amaru Ortiz <erik@colosa.com>
* Last Modify comment(26.06.2008): the session expired verification was removed from here to soap class
2012-10-09 13:29:25 -04:00
*
* @package workflow.engine.classes
2010-12-02 23:34:41 +00:00
*/
class wsBase
{
public $stored_system_variables; //boolean
public $wsSessionId; //web service session id, if the wsbase function is used from a WS request
2012-10-09 13:29:25 -04:00
public function __construct ($params = null)
{
$this->stored_system_variables = false;
if ($params != null) {
2012-10-09 13:29:25 -04:00
$this->stored_system_variables = (isset( $params->stored_system_variables ) ? $params->stored_system_variables : false);
2012-10-09 13:29:25 -04:00
$this->wsSessionId = isset( $params->wsSessionId ) ? $params->wsSessionId : '';
2010-12-02 23:34:41 +00:00
}
}
/**
* function to start a web services session in ProcessMaker
2012-10-09 13:29:25 -04:00
*
* @param string $userid
* @param string $password
* @return $wsResponse will return an object
*/
2012-10-09 13:29:25 -04:00
public function login ($userid, $password)
{
global $RBAC;
try {
2012-10-09 13:29:25 -04:00
$uid = $RBAC->VerifyLogin( $userid, $password );
switch ($uid) {
case '':
2012-10-09 13:29:25 -04:00
case - 1: //The user doesn't exist
$wsResponse = new wsResponse( 3, G::loadTranslation( 'ID_USER_NOT_REGISTERED' ) );
break;
case - 2: //The password is incorrect
$wsResponse = new wsResponse( 4, G::loadTranslation( 'ID_WRONG_PASS' ) );
break;
2012-10-09 13:29:25 -04:00
case - 3: //The user is inactive
$wsResponse = new wsResponse( 5, G::loadTranslation( 'ID_USER_INACTIVE' ) );
break;
2012-10-09 13:29:25 -04:00
case - 4: //The Due date is finished
$wsResponse = new wsResponse( 5, G::loadTranslation( 'ID_USER_INACTIVE' ) );
break;
}
if ($uid < 0 || $uid == '') {
2012-10-09 13:29:25 -04:00
throw (new Exception( serialize( $wsResponse ) ));
}
//check access to PM
2012-10-09 13:29:25 -04:00
$RBAC->loadUserRolePermission( $RBAC->sSystem, $uid );
$res = $RBAC->userCanAccess( "PM_LOGIN" );
if ($res != 1) {
//if ($res == -2)
// $wsResponse = new wsResponse(1, G::loadTranslation('ID_USER_HAVENT_RIGHTS_SYSTEM'));
//else
2012-10-09 13:29:25 -04:00
$wsResponse = new wsResponse( 2, G::loadTranslation( 'ID_USER_HAVENT_RIGHTS_SYSTEM' ) );
throw (new Exception( serialize( $wsResponse ) ));
}
2012-10-09 13:29:25 -04:00
$sessionId = G::generateUniqueID();
$wsResponse = new wsResponse( '0', $sessionId );
$session = new Session();
2012-10-09 13:29:25 -04:00
$session->setSesUid( $sessionId );
$session->setSesStatus( 'ACTIVE' );
$session->setUsrUid( $uid );
$session->setSesRemoteIp( $_SERVER['REMOTE_ADDR'] );
$session->setSesInitDate( date( 'Y-m-d H:i:s' ) );
$session->setSesDueDate( date( 'Y-m-d H:i:s', mktime( date( 'H' ), date( 'i' ) + 15, date( 's' ), date( 'm' ), date( 'd' ), date( 'Y' ) ) ) );
$session->setSesEndDate( '' );
$session->Save();
//save the session in DataBase
2012-10-09 13:29:25 -04:00
return $wsResponse;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$wsResponse = unserialize( $e->getMessage() );
return $wsResponse;
2010-12-02 23:34:41 +00:00
}
}
/**
* get all groups
2012-10-09 13:29:25 -04:00
*
* @param none
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function processList ()
{
try {
2012-10-09 13:29:25 -04:00
$result = array ();
$oCriteria = new Criteria( 'workflow' );
//$oCriteria->add(ProcessPeer::PRO_STATUS , 'ACTIVE');
2012-10-09 13:29:25 -04:00
$oCriteria->add( ProcessPeer::PRO_STATUS, 'DISABLED', Criteria::NOT_EQUAL );
$oDataset = ProcessPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
$oProcess = new Process();
2012-10-09 13:29:25 -04:00
$arrayProcess = $oProcess->Load( $aRow['PRO_UID'] );
$result[] = array ('guid' => $aRow['PRO_UID'],'name' => $arrayProcess['PRO_TITLE']
);
$oDataset->next();
}
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $e->getMessage(),'name' => $e->getMessage()
);
return $result;
2010-12-02 23:34:41 +00:00
}
}
/**
* get all roles, to see all roles
2012-10-09 13:29:25 -04:00
*
* @param none
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function roleList ()
{
try {
2012-10-09 13:29:25 -04:00
$result = array ();
2012-10-09 13:29:25 -04:00
$RBAC = & RBAC::getSingleton();
$RBAC->initRBAC();
$oCriteria = $RBAC->listAllRoles();
2012-10-09 13:29:25 -04:00
$oDataset = GulliverBasePeer::doSelectRs( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $aRow['ROL_UID'],'name' => $aRow['ROL_CODE']
);
$oDataset->next();
}
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $e->getMessage(),'name' => $e->getMessage()
);
return $result;
2010-12-02 23:34:41 +00:00
}
}
2010-12-02 23:34:41 +00:00
/**
* get all groups
2012-10-09 13:29:25 -04:00
*
* @param none
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function groupList ()
{
try {
2012-10-09 13:29:25 -04:00
$result = array ();
$oCriteria = new Criteria( 'workflow' );
$oCriteria->add( GroupwfPeer::GRP_STATUS, 'ACTIVE' );
$oDataset = GroupwfPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
$oGroupwf = new Groupwf();
2012-10-09 13:29:25 -04:00
$arrayGroupwf = $oGroupwf->Load( $aRow['GRP_UID'] );
$result[] = array ('guid' => $aRow['GRP_UID'],'name' => $arrayGroupwf['GRP_TITLE']
);
$oDataset->next();
}
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $e->getMessage(),'name' => $e->getMessage()
);
return $result;
2010-12-02 23:34:41 +00:00
}
}
/**
* get all department
2012-10-09 13:29:25 -04:00
*
* @param none
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function departmentList ()
{
try {
2012-10-09 13:29:25 -04:00
$result = array ();
$oCriteria = new Criteria( 'workflow' );
$oCriteria->add( DepartmentPeer::DEP_STATUS, 'ACTIVE' );
$oDataset = DepartmentPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
$oDepartment = new Department();
2012-10-09 13:29:25 -04:00
$aDepartment = $oDepartment->Load( $aRow['DEP_UID'] );
$node['guid'] = $aRow['DEP_UID'];
$node['name'] = $aDepartment['DEPO_TITLE'];
$node['parentUID'] = $aDepartment['DEP_PARENT'];
$node['dn'] = $aDepartment['DEP_LDAP_DN'];
//get the users from this department
$c = new Criteria();
$c->clearSelectColumns();
2012-10-09 13:29:25 -04:00
$c->addSelectColumn( 'COUNT(*)' );
$c->add( UsersPeer::DEP_UID, $aRow['DEP_UID'] );
$rs = UsersPeer::doSelectRS( $c );
$rs->next();
$row = $rs->getRow();
$count = $row[0];
$node['users'] = $count;
$result[] = $node;
$oDataset->next();
}
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $e->getMessage(),'name' => $e->getMessage()
);
2010-12-02 23:34:41 +00:00
return $result;
2010-12-02 23:34:41 +00:00
}
}
/**
* Get case list
2012-10-09 13:29:25 -04:00
*
* @param string $userId
* @return $result will return an object
*/
public function caseList($userUid)
{
try {
$solrEnabled = 0;
2012-10-09 13:29:25 -04:00
if (($solrEnv = System::solrEnv()) !== false) {
G::LoadClass("AppSolr");
2012-10-09 13:29:25 -04:00
$appSolr = new AppSolr(
$solrEnv["solr_enabled"],
$solrEnv["solr_host"],
$solrEnv["solr_instance"]
);
if ($appSolr->isSolrEnabled() && $solrEnv["solr_enabled"] == true) {
//Check if there are missing records to reindex and reindex them
$appSolr->synchronizePendingApplications();
$solrEnabled = 1;
}
}
if ($solrEnabled == 1) {
try {
G::LoadClass("searchIndex");
$arrayData = array();
$delegationIndexes = array();
$columsToInclude = array("APP_UID");
$solrSearchText = null;
//Todo
$solrSearchText = $solrSearchText . (($solrSearchText != null)? " OR " : null) . "(APP_STATUS:TO_DO AND APP_ASSIGNED_USERS:" . $userUid . ")";
$delegationIndexes[] = "APP_ASSIGNED_USER_DEL_INDEX_" . $userUid . "_txt";
//Draft
$solrSearchText = $solrSearchText . (($solrSearchText != null)? " OR " : null) . "(APP_STATUS:DRAFT AND APP_DRAFT_USER:" . $userUid . ")";
//Index is allways 1
$solrSearchText = "($solrSearchText)";
//Add del_index dynamic fields to list of resulting columns
$columsToIncludeFinal = array_merge($columsToInclude, $delegationIndexes);
$solrRequestData = Entity_SolrRequestData::createForRequestPagination(
array(
"workspace" => $solrEnv["solr_instance"],
"startAfter" => 0,
"pageSize" => 1000,
"searchText" => $solrSearchText,
"numSortingCols" => 1,
"sortCols" => array("APP_NUMBER"),
"sortDir" => array(strtolower("DESC")),
"includeCols" => $columsToIncludeFinal,
"resultFormat" => "json"
)
);
//Use search index to return list of cases
$searchIndex = new BpmnEngine_Services_SearchIndex($appSolr->isSolrEnabled(), $solrEnv["solr_host"]);
//Execute query
$solrQueryResult = $searchIndex->getDataTablePaginatedList($solrRequestData);
//$rows = array();
//Number of found records
//$numRecTotal = $solrQueryResult->iTotalDisplayRecords;
//print_r($solrQueryResult->aaData); exit(0);
//Get the missing data from database
$arrayApplicationUid = array();
foreach ($solrQueryResult->aaData as $i => $data) {
$arrayApplicationUid[] = $data["APP_UID"];
}
$aaappsDBData = $appSolr->getListApplicationDelegationData($arrayApplicationUid);
foreach ($solrQueryResult->aaData as $i => $data) {
//Initialize array
$delIndexes = array(); //Store all the delegation indexes
//Complete empty values
$applicationUid = $data["APP_UID"]; //APP_UID
//Get all the indexes returned by Solr as columns
for($i = count($columsToInclude); $i <= count($data) - 1; $i++) {
if (is_array($data[$columsToIncludeFinal[$i]])) {
foreach ($data[$columsToIncludeFinal[$i]] as $delIndex) {
$delIndexes[] = $delIndex;
}
}
}
//Verify if the delindex is an array
//if is not check different types of repositories
//the delegation index must always be defined.
if (count($delIndexes) == 0) {
////if is draft
//if ($action == "draft") {
$delIndexes[] = 1; // the first default index
//} else {
// //error an index must always be defined
// print date("Y-m-d H:i:s:u") . " Delegation not defined\n";
//}
}
//Remove duplicated
$delIndexes = array_unique($delIndexes);
//Get records
foreach ($delIndexes as $delIndex) {
$aRow = array();
//Copy result values to new row from Solr server
$aRow["APP_UID"] = $data["APP_UID"];
//Get delegation data from DB
//Filter data from db
$indexes = $appSolr->aaSearchRecords($aaappsDBData, array(
"APP_UID" => $applicationUid,
"DEL_INDEX" => $delIndex
));
foreach ($indexes as $index) {
$row = $aaappsDBData[$index];
}
if(!isset($row))
{
//$fh = fopen("SolrAppWithoutDelIndex.txt", "a") or die("can't open file to store Solr search time.");
//fwrite($fh, sprintf("Solr AppUid: %s DelIndex: %s not found.\r\n", $applicationUid, $delIndex));
//fclose($fh);
continue;
}
$aRow["APP_NUMBER"] = $row["APP_NUMBER"];
$aRow["APP_STATUS"] = $row["APP_STATUS"];
$aRow["PRO_UID"] = $row["PRO_UID"];
$aRow["DEL_INDEX"] = $row["DEL_INDEX"];
//$rows[] = $aRow;
$arrayData[] = array(
"guid" => $aRow["APP_UID"],
"name" => $aRow["APP_NUMBER"],
"status" => $aRow["APP_STATUS"],
"delIndex" => $aRow["DEL_INDEX"],
"processId" => $aRow["PRO_UID"]
);
}
}
return $arrayData;
} catch (InvalidIndexSearchTextException $e) {
$arrayData = array();
$arrayData[] = array (
"guid" => $e->getMessage(),
"name" => $e->getMessage(),
"status" => $e->getMessage(),
"delIndex" => $e->getMessage(),
"processId" => $e->getMessage()
);
return $arrayData;
}
} else {
$arrayData = array();
$criteria = new Criteria("workflow");
$criteria->addSelectColumn(AppCacheViewPeer::APP_UID);
$criteria->addSelectColumn(AppCacheViewPeer::DEL_INDEX);
$criteria->addSelectColumn(AppCacheViewPeer::APP_NUMBER);
$criteria->addSelectColumn(AppCacheViewPeer::APP_STATUS);
$criteria->addSelectColumn(AppCacheViewPeer::PRO_UID);
$criteria->add(AppCacheViewPeer::USR_UID, $userUid);
$criteria->add(
//ToDo - getToDo()
$criteria->getNewCriterion(AppCacheViewPeer::APP_STATUS, "TO_DO", CRITERIA::EQUAL)->addAnd(
$criteria->getNewCriterion(AppCacheViewPeer::DEL_FINISH_DATE, null, Criteria::ISNULL))->addAnd(
$criteria->getNewCriterion(AppCacheViewPeer::APP_THREAD_STATUS, "OPEN"))->addAnd(
$criteria->getNewCriterion(AppCacheViewPeer::DEL_THREAD_STATUS, "OPEN"))
)->addOr(
//Draft - getDraft()
$criteria->getNewCriterion(AppCacheViewPeer::APP_STATUS, "DRAFT", CRITERIA::EQUAL)->addAnd(
$criteria->getNewCriterion(AppCacheViewPeer::APP_THREAD_STATUS, "OPEN"))->addAnd(
$criteria->getNewCriterion(AppCacheViewPeer::DEL_THREAD_STATUS, "OPEN"))
);
$criteria->addDescendingOrderByColumn(AppCacheViewPeer::APP_NUMBER);
$rsCriteria = AppCacheViewPeer::doSelectRS($criteria);
$rsCriteria->setFetchmode(ResultSet::FETCHMODE_ASSOC);
while ($rsCriteria->next()) {
$row = $rsCriteria->getRow();
$arrayData[] = array(
"guid" => $row["APP_UID"],
"name" => $row["APP_NUMBER"],
"status" => $row["APP_STATUS"],
"delIndex" => $row["DEL_INDEX"],
"processId" => $row["PRO_UID"]
);
}
return $arrayData;
}
} catch (Exception $e) {
$arrayData = array();
$arrayData[] = array (
"guid" => $e->getMessage(),
"name" => $e->getMessage(),
"status" => $e->getMessage(),
"delIndex" => $e->getMessage(),
"processId" => $e->getMessage()
);
return $arrayData;
}
}
/**
* Get unassigned case list
2012-10-09 13:29:25 -04:00
*
* @param string $userId
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function unassignedCaseList ($userId)
{
try {
2012-10-09 13:29:25 -04:00
$result = array ();
$oAppCache = new AppCacheView();
2012-10-09 13:29:25 -04:00
$Criteria = $oAppCache->getUnassignedListCriteria( $userId );
$oDataset = AppCacheViewPeer::doSelectRS( $Criteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
2012-10-12 12:52:50 -04:00
$result[] = array ('guid' => $aRow['APP_UID'],
'name' => $aRow['APP_NUMBER'],
'delIndex' => $aRow['DEL_INDEX'],
'processId' => $aRow['PRO_UID']);
2012-10-09 13:29:25 -04:00
$oDataset->next();
}
return $result;
} catch (Exception $e) {
2012-10-12 12:52:50 -04:00
$result[] = array ('guid' => $e->getMessage(),
'name' => $e->getMessage(),
'status' => $e->getMessage(),
'status' => $e->getMessage(),
'processId' => $e->getMessage());
return $result;
}
}
/**
* get all groups
2012-10-09 13:29:25 -04:00
*
* @param none
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function userList ()
{
try {
2012-10-09 13:29:25 -04:00
$result = array ();
$oCriteria = new Criteria( 'workflow' );
$oCriteria->add( UsersPeer::USR_STATUS, 'ACTIVE' );
$oDataset = UsersPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
//$oProcess = new User();
//$arrayProcess = $oUser->Load($aRow['PRO_UID']);
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $aRow['USR_UID'],'name' => $aRow['USR_USERNAME']
);
$oDataset->next();
}
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $e->getMessage(),'name' => $e->getMessage()
);
return $result;
}
}
/**
* get list of all the available triggers in a workspace
2012-10-09 13:29:25 -04:00
*
* @param none
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function triggerList ()
{
try {
$del = DBAdapter::getStringDelimiter();
2012-10-09 13:29:25 -04:00
$result = array ();
$oCriteria = new Criteria( 'workflow' );
$oCriteria->addSelectColumn( TriggersPeer::TRI_UID );
$oCriteria->addSelectColumn( TriggersPeer::PRO_UID );
$oCriteria->addAsColumn( 'TITLE', 'C1.CON_VALUE' );
$oCriteria->addAlias( "C1", 'CONTENT' );
$caseTitleConds = array ();
$caseTitleConds[] = array (TriggersPeer::TRI_UID,'C1.CON_ID'
);
$caseTitleConds[] = array ('C1.CON_CATEGORY',$del . 'TRI_TITLE' . $del
);
$caseTitleConds[] = array ('C1.CON_LANG',$del . SYS_LANG . $del
);
$oCriteria->addJoinMC( $caseTitleConds, Criteria::LEFT_JOIN );
//$oCriteria->add(TriggersPeer::USR_STATUS, 'ACTIVE');
2012-10-09 13:29:25 -04:00
$oDataset = TriggersPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $aRow['TRI_UID'],'name' => $aRow['TITLE'],'processId' => $aRow['PRO_UID']
);
$oDataset->next();
}
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $e->getMessage(),'name' => $e->getMessage()
);
return $result;
}
}
/**
* get list of the uploaded documents for a given case
2012-10-09 13:29:25 -04:00
*
* @param string $sApplicationUID
* @param string $sUserUID
* @return $result
*/
2012-10-09 13:29:25 -04:00
public function inputDocumentList ($sApplicationUID, $sUserUID)
{
try {
$oCase = new Cases();
2012-10-09 13:29:25 -04:00
$fields = $oCase->loadCase( $sApplicationUID );
$sProcessUID = $fields['PRO_UID'];
$sTaskUID = '';
2012-10-09 13:29:25 -04:00
$oCriteria = $oCase->getAllUploadedDocumentsCriteria( $sProcessUID, $sApplicationUID, $sTaskUID, $sUserUID );
2012-10-09 13:29:25 -04:00
$result = array ();
global $_DBArray;
foreach ($_DBArray['inputDocuments'] as $key => $row) {
2012-10-09 13:29:25 -04:00
if (isset( $row['DOC_VERSION'] )) {
$docrow = array ();
$docrow['guid'] = $row['APP_DOC_UID'];
$docrow['filename'] = $row['APP_DOC_FILENAME'];
$docrow['docId'] = $row['DOC_UID'];
$docrow['version'] = $row['DOC_VERSION'];
$docrow['createDate'] = $row['CREATE_DATE'];
2012-10-09 13:29:25 -04:00
$docrow['createBy'] = $row['CREATED_BY'];
$docrow['type'] = $row['TYPE'];
$docrow['index'] = $row['APP_DOC_INDEX'];
$docrow['link'] = 'cases/' . $row['DOWNLOAD_LINK'];
$result[] = $docrow;
}
}
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $e->getMessage()
);
return $result;
}
}
/**
* input document process list
2012-10-09 13:29:25 -04:00
*
* @param string $sProcessUID
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function inputDocumentProcessList ($sProcessUID)
{
try {
global $_DBArray;
2012-10-09 13:29:25 -04:00
$_DBArray = (isset( $_SESSION['_DBArray'] ) ? $_SESSION['_DBArray'] : '');
$oMap = new processMap();
2012-10-09 13:29:25 -04:00
$oCriteria = $oMap->getInputDocumentsCriteria( $sProcessUID );
$oDataset = InputDocumentPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
2012-10-09 13:29:25 -04:00
$result = array ();
/*
//not necesary for SOAP message
$result[] = array(
'guid' => 'char',
'name' => 'name',
'description' => 'description'
);
*/
while ($aRow = $oDataset->getRow()) {
2012-10-09 13:29:25 -04:00
if ($aRow['INP_DOC_TITLE'] == null) {
//There is no transaltion for this Document name, try to get/regenerate the label
2012-10-09 13:29:25 -04:00
$inputDocument = new InputDocument();
$inputDocumentObj = $inputDocument->load( $aRow['INP_DOC_UID'] );
$aRow['INP_DOC_TITLE'] = $inputDocumentObj['INP_DOC_TITLE'];
$aRow['INP_DOC_DESCRIPTION'] = $inputDocumentObj['INP_DOC_DESCRIPTION'];
}
2012-10-09 13:29:25 -04:00
$docrow = array ();
$docrow['guid'] = $aRow['INP_DOC_UID'];
$docrow['name'] = $aRow['INP_DOC_TITLE'];
$docrow['description'] = $aRow['INP_DOC_DESCRIPTION'];
$result[] = $docrow;
2012-10-09 13:29:25 -04:00
$oDataset->next();
}
//$_DBArray['inputDocArray'] = $inputDocArray;
2012-10-09 13:29:25 -04:00
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $e->getMessage()
);
return $result;
}
2010-12-02 23:34:41 +00:00
}
/**
* output document list
2012-10-09 13:29:25 -04:00
*
* @param string $sApplicationUID
* @param string $sUserUID
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function outputDocumentList ($sApplicationUID, $sUserUID)
{
try {
$oCase = new Cases();
2012-10-09 13:29:25 -04:00
$fields = $oCase->loadCase( $sApplicationUID );
$sProcessUID = $fields['PRO_UID'];
$sTaskUID = '';
2012-10-09 13:29:25 -04:00
$oCriteria = $oCase->getAllGeneratedDocumentsCriteria( $sProcessUID, $sApplicationUID, $sTaskUID, $sUserUID );
2012-10-09 13:29:25 -04:00
$result = array ();
global $_DBArray;
foreach ($_DBArray['outputDocuments'] as $key => $row) {
2012-10-09 13:29:25 -04:00
if (isset( $row['DOC_VERSION'] )) {
$docrow = array ();
$docrow['guid'] = $row['APP_DOC_UID'];
$docrow['filename'] = $row['DOWNLOAD_FILE'];
2012-10-09 13:29:25 -04:00
$docrow['docId'] = $row['DOC_UID'];
$docrow['version'] = $row['DOC_VERSION'];
$docrow['createDate'] = $row['CREATE_DATE'];
2012-10-09 13:29:25 -04:00
$docrow['createBy'] = $row['CREATED_BY'];
$docrow['type'] = $row['TYPE'];
$docrow['index'] = $row['APP_DOC_INDEX'];
$docrow['link'] = 'cases/' . $row['DOWNLOAD_LINK'];
$result[] = $docrow;
}
}
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $e->getMessage()
);
return $result;
}
2010-12-02 23:34:41 +00:00
}
/**
* remove document
2012-10-09 13:29:25 -04:00
*
* @param string $appDocUid
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function removeDocument ($appDocUid)
{
try {
$oAppDocument = new AppDocument();
2012-10-09 13:29:25 -04:00
$oAppDocument->remove( $appDocUid, 1 ); //always send version 1
$result = new wsResponse( 0, " $appDocUid" );
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, $e->getMessage() );
return $result;
}
}
/**
* get task list
2012-10-09 13:29:25 -04:00
*
* @param string $userId
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function taskList ($userId)
{
try {
2012-10-09 13:29:25 -04:00
g::loadClass( 'groups' );
$oGroup = new Groups();
2012-10-09 13:29:25 -04:00
$aGroups = $oGroup->getActiveGroupsForAnUser( $userId );
2012-10-09 13:29:25 -04:00
$result = array ();
$oCriteria = new Criteria( 'workflow' );
$del = DBAdapter::getStringDelimiter();
2012-10-12 12:52:50 -04:00
$oCriteria->addSelectColumn( TaskPeer::PRO_UID );
2012-10-09 13:29:25 -04:00
$oCriteria->addSelectColumn( TaskPeer::TAS_UID );
2012-10-12 12:52:50 -04:00
$oCriteria->addSelectColumn( TaskPeer::TAS_START );
$oCriteria->setDistinct();
2012-10-09 13:29:25 -04:00
$oCriteria->addAsColumn( 'TAS_TITLE', 'C1.CON_VALUE' );
$oCriteria->addAlias( "C1", 'CONTENT' );
$tasTitleConds = array ();
$tasTitleConds[] = array (TaskPeer::TAS_UID,'C1.CON_ID'
);
$tasTitleConds[] = array ('C1.CON_CATEGORY',$del . 'TAS_TITLE' . $del
);
$tasTitleConds[] = array ('C1.CON_LANG',$del . SYS_LANG . $del
);
$oCriteria->addJoinMC( $tasTitleConds, Criteria::LEFT_JOIN );
$oCriteria->addJoin( TaskPeer::TAS_UID, TaskUserPeer::TAS_UID, Criteria::LEFT_JOIN );
$oCriteria->addOr( TaskUserPeer::USR_UID, $userId );
$oCriteria->addOr( TaskUserPeer::USR_UID, $aGroups, Criteria::IN );
$oDataset = TaskPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
2012-10-12 12:52:50 -04:00
$result[] = array ('guid' => $aRow['TAS_UID'],
'name' => $aRow['TAS_TITLE'],
'processId' => $aRow['PRO_UID'],
'initialTask' => $aRow['TAS_START'] == 'TRUE' ? '1' : '0');
$oDataset->next();
}
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $e->getMessage(),'name' => $e->getMessage()
);
return $result;
}
}
/**
* send message
2012-10-09 13:29:25 -04:00
*
* @param string $caseId
* @param string $sFrom
* @param string $sTo
* @param string $sCc
* @param string $sBcc
* @param string $sSubject
* @param string $sTemplate
* @param $appFields = null
* @param $aAttachment = null
* @param boolean $showMessage = true
* @param int $delIndex = 0
2014-09-18 17:11:30 -04:00
* @param $config = array
* @return $result will return an object
*/
public function sendMessage(
$caseId,
$sFrom,
$sTo,
$sCc,
$sBcc,
$sSubject,
$sTemplate,
$appFields = null,
$aAttachment = null,
$showMessage = true,
$delIndex = 0,
$config = array()
) {
try {
if (!class_exists('System')) {
G::LoadClass('system');
}
/*----------------------------------********---------------------------------*/
if (!empty($config)) {
$arrayConfigAux = array();
if (is_array($config)) {
if (PMLicensedFeatures::getSingleton()->verifyfeature("nKaNTNuT1MzK0RsMEtXTnYzR09ucHF2WGNuS0hRdDBBak42WXJhNVVOOG1INEVoaU1EaTllbjBBeEJNeG9wRVJ6NmxQelhyVTBvdThzPQ==")) {
$arrayConfigAux = $config;
}
} else {
if (PMLicensedFeatures::getSingleton()->verifyfeature("zIKRGpDM3pjcHFsWGplNDN0dTl5bGN3UTNiOWdQU0E5Q05QTksrU1ladWQ0VT0=")) {
$emailServer = new \ProcessMaker\BusinessModel\EmailServer();
$criteria = $emailServer->getEmailServerCriteria();
$criteria->add(EmailServerPeer::MESS_UID, $config, Criteria::EQUAL);
$rsCriteria = EmailServerPeer::doSelectRS($criteria);
$rsCriteria->setFetchmode(ResultSet::FETCHMODE_ASSOC);
if ($rsCriteria->next()) {
$row = $rsCriteria->getRow();
$arrayConfigAux = $row;
$arrayConfigAux["SMTPSecure"] = $row["SMTPSECURE"];
}
}
}
$aSetup = (!empty($arrayConfigAux))? $arrayConfigAux : System::getEmailConfiguration();
} else {
/*----------------------------------********---------------------------------*/
$aSetup = System::getEmailConfiguration();
/*----------------------------------********---------------------------------*/
}
/*----------------------------------********---------------------------------*/
$msgError = "";
if(sizeof($aSetup) == 0){
$msgError = "The default configuration wasn't defined";
}
$oSpool = new spoolRun();
$oSpool->setConfig($aSetup);
$oCase = new Cases();
$oldFields = $oCase->loadCase( $caseId );
$pathEmail = PATH_DATA_SITE . 'mailTemplates' . PATH_SEP . $oldFields['PRO_UID'] . PATH_SEP;
$fileTemplate = $pathEmail . $sTemplate;
2012-10-09 13:29:25 -04:00
G::mk_dir( $pathEmail, 0777, true );
2012-10-09 13:29:25 -04:00
if (! file_exists( $fileTemplate )) {
$data['FILE_TEMPLATE'] = $fileTemplate;
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 28, G::LoadTranslation( 'ID_TEMPLATE_FILE_NOT_EXIST', SYS_LANG, $data ) );
return $result;
}
if ($appFields == null) {
$Fields = $oldFields['APP_DATA'];
} else {
2012-10-09 13:29:25 -04:00
$Fields = array_merge( $oldFields['APP_DATA'], $appFields );
}
$sBody = G::replaceDataGridField(file_get_contents($fileTemplate), $Fields, false);
$sFrom = G::buildFrom($aSetup, $sFrom);
$showMessage = ($showMessage) ? 1 : 0 ;
$messageArray = array(
"msg_uid" => "",
"app_uid" => $caseId,
"del_index" => $delIndex,
"app_msg_type" => "TRIGGER",
"app_msg_subject" => $sSubject,
"app_msg_from" => $sFrom,
"app_msg_to" => $sTo,
"app_msg_body" => $sBody,
"app_msg_cc" => $sCc,
"app_msg_bcc" => $sBcc,
"app_msg_attach" => $aAttachment,
"app_msg_template" => "",
"app_msg_status" => "pending",
"app_msg_show_message" => $showMessage,
"app_msg_error" => $msgError,
"contentTypeIsHtml" => (preg_match("/^.+\.html?$/i", $fileTemplate))? true : false
);
2012-10-09 13:29:25 -04:00
$oSpool->create( $messageArray );
$oSpool->sendMail();
2012-10-09 13:29:25 -04:00
if ($oSpool->status == 'sent') {
$result = new wsResponse( 0, G::loadTranslation( 'ID_MESSAGE_SENT' ) . ": " . $sTo );
} else {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 29, $oSpool->status . ' ' . $oSpool->error . print_r( $aSetup, 1 ) );
}
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
return new wsResponse( 100, $e->getMessage() );
}
}
/**
* get case information
2012-10-09 13:29:25 -04:00
*
* @param string $caseId
* @param string $iDelIndex
* @param bool $flagUseDelIndex
*
* @return $result will return an object
*/
public function getCaseInfo($caseId, $iDelIndex, $flagUseDelIndex = false)
{
try {
$oCase = new Cases();
2012-10-09 13:29:25 -04:00
$aRows = $oCase->loadCase( $caseId, $iDelIndex );
2012-10-09 13:29:25 -04:00
if (count( $aRows ) == 0) {
$data['CASE_NUMBER'] = $caseNumber;
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 16, G::loadTranslation( 'ID_CASE_DOES_NOT_EXIST', SYS_LANG, $data ) );
return $result;
}
$oProcess = new Process();
try {
2012-10-09 13:29:25 -04:00
$uFields = $oProcess->load( $aRows['PRO_UID'] );
$processName = $uFields['PRO_TITLE'];
} catch (Exception $e) {
$processName = '';
}
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 0, G::loadTranslation( 'ID_COMMAND_EXECUTED_SUCCESSFULLY' ) );
$result->caseId = $aRows['APP_UID'];
$result->caseNumber = $aRows['APP_NUMBER'];
$result->caseName = $aRows['TITLE'];
$result->caseStatus = $aRows['APP_STATUS'];
$result->caseParalell = $aRows['APP_PARALLEL'];
$result->caseCreatorUser = $aRows['APP_INIT_USER'];
$result->caseCreatorUserName = $aRows['CREATOR'];
2012-10-09 13:29:25 -04:00
$result->processId = $aRows['PRO_UID'];
$result->processName = $processName;
$result->createDate = $aRows['CREATE_DATE'];
$result->updateDate = $aRows['UPDATE_DATE'];
//now fill the array of AppDelay
$oCriteria = new Criteria( 'workflow' );
$oCriteria->addSelectColumn( AppDelayPeer::APP_DEL_INDEX );
$oCriteria->add( AppDelayPeer::APP_UID, $caseId );
$oCriteria->add( AppDelayPeer::APP_TYPE, 'PAUSE' );
$oCriteria->add( AppDelayPeer::APP_DISABLE_ACTION_USER, '0' );
$oDataset = AppDelayPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$aIndexsPaused = array();
while ($oDataset->next()) {
$data = $oDataset->getRow();
$aIndexsPaused[] = $data['APP_DEL_INDEX'];
}
//now fill the array of AppDelegationPeer
2012-10-09 13:29:25 -04:00
$oCriteria = new Criteria( 'workflow' );
$oCriteria->addSelectColumn( AppDelegationPeer::DEL_INDEX );
$oCriteria->addSelectColumn( AppDelegationPeer::USR_UID );
$oCriteria->addSelectColumn( AppDelegationPeer::TAS_UID );
$oCriteria->addSelectColumn( AppDelegationPeer::DEL_THREAD );
$oCriteria->addSelectColumn( AppDelegationPeer::DEL_THREAD_STATUS );
$oCriteria->addSelectColumn( AppDelegationPeer::DEL_FINISH_DATE );
$oCriteria->addSelectColumn(AppDelegationPeer::DEL_INIT_DATE);
$oCriteria->addSelectColumn(AppDelegationPeer::DEL_TASK_DUE_DATE);
2012-10-09 13:29:25 -04:00
$oCriteria->add( AppDelegationPeer::APP_UID, $caseId );
if (count($aIndexsPaused)) {
$cton1 = $oCriteria->getNewCriterion( AppDelegationPeer::DEL_FINISH_DATE, null, Criteria::ISNULL);
$cton2 = $oCriteria->getNewCriterion( AppDelegationPeer::DEL_INDEX, $aIndexsPaused, Criteria::IN );
$cton1->addOR( $cton2 );
$oCriteria->add( $cton1 );
} else {
$oCriteria->add(AppDelegationPeer::DEL_FINISH_DATE, null, Criteria::ISNULL);
}
2012-10-09 13:29:25 -04:00
$oCriteria->addAscendingOrderByColumn( AppDelegationPeer::DEL_INDEX );
$oDataset = AppDelegationPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$aCurrentUsers = array ();
while ($oDataset->next()) {
$aAppDel = $oDataset->getRow();
$oUser = new Users();
try {
2012-10-09 13:29:25 -04:00
$oUser->load( $aAppDel['USR_UID'] );
$uFields = $oUser->toArray( BasePeer::TYPE_FIELDNAME );
$currentUserName = $oUser->getUsrFirstname() . ' ' . $oUser->getUsrLastname();
} catch (Exception $e) {
$currentUserName = '';
}
$oTask = new Task();
try {
2012-10-09 13:29:25 -04:00
$uFields = $oTask->load( $aAppDel['TAS_UID'] );
$taskName = $uFields['TAS_TITLE'];
} catch (Exception $e) {
$taskName = '';
}
$currentUser = new stdClass();
2012-10-09 13:29:25 -04:00
$currentUser->userId = $aAppDel['USR_UID'];
$currentUser->userName = $currentUserName;
$currentUser->taskId = $aAppDel['TAS_UID'];
$currentUser->taskName = $taskName;
$currentUser->delIndex = $aAppDel['DEL_INDEX'];
$currentUser->delThread = $aAppDel['DEL_THREAD'];
$currentUser->delThreadStatus = $aAppDel['DEL_THREAD_STATUS'];
$currentUser->delStatus = ($aAppDel["DEL_THREAD_STATUS"] == 'CLOSED') ? 'PAUSED' : $aRows['APP_STATUS'];
$currentUser->delInitDate = $aAppDel["DEL_INIT_DATE"];
$currentUser->delTaskDueDate = $aAppDel["DEL_TASK_DUE_DATE"];
$aCurrentUsers[] = $currentUser;
}
$result->currentUsers = $aCurrentUsers;
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, $e->getMessage() );
return $result;
}
2010-12-02 23:34:41 +00:00
}
/**
* Create an new user
2012-10-09 13:29:25 -04:00
*
* @param string sessionId : The session ID.
2012-10-09 13:29:25 -04:00
* @param string userName : The username for the new user.
* @param string firstName : The user's first name.
2012-10-09 13:29:25 -04:00
* @param string lastName : The user's last name.
* @param string email : The user's email address.
* @param string role : The user's role, such as "PROCESSMAKER_ADMIN" or "PROCESSMAKER_OPERATOR".
* @param string password : The user's password such as "Be@gle2" (It will be automatically encrypted
* with an MD5 hash).
* @param string dueDate : Optional parameter. The expiration date must be a string in the format "yyyy-mm-dd".
* @param string status : Optional parameter. The user's status, such as "ACTIVE", "INACTIVE" or "VACATION".
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function createUser ($userName, $firstName, $lastName, $email, $role, $password, $dueDate = null, $status = null)
{
try {
global $RBAC;
$RBAC->initRBAC();
2012-10-09 13:29:25 -04:00
if (empty( $userName )) {
$result = new wsCreateUserResponse( 25, G::loadTranslation( "ID_USERNAME_REQUIRED" ), null );
return $result;
}
2012-10-09 13:29:25 -04:00
if (empty( $firstName )) {
$result = new wsCreateUserResponse( 27, G::loadTranslation( "ID_MSG_ERROR_USR_FIRSTNAME" ), null );
return $result;
}
2012-10-09 13:29:25 -04:00
if (empty( $password )) {
$result = new wsCreateUserResponse( 26, G::loadTranslation( "ID_PASSWD_REQUIRED" ), null );
return $result;
}
$mktimeDueDate = 0;
if (! empty( $dueDate ) && $dueDate != 'null' && $dueDate) {
2012-10-09 13:29:25 -04:00
if (! preg_match( "/^(\d{4})-(\d{2})-(\d{2})$/", $dueDate, $arrayMatch )) {
$result = new wsCreateUserResponse( - 1, G::loadTranslation( "ID_INVALID_DATA" ) . " $dueDate", null );
return $result;
} else {
2012-10-09 13:29:25 -04:00
$mktimeDueDate = mktime( 0, 0, 0, intval( $arrayMatch[2] ), intval( $arrayMatch[3] ), intval( $arrayMatch[1] ) );
}
} else {
2012-10-09 13:29:25 -04:00
$mktimeDueDate = mktime( 0, 0, 0, date( "m" ), date( "d" ), date( "Y" ) + 1 );
}
if (! empty( $status ) && $status != 'null' && $status) {
if ($status != "ACTIVE" && $status != "INACTIVE" && $status != "VACATION") {
2012-10-09 13:29:25 -04:00
$result = new wsCreateUserResponse( - 1, G::loadTranslation( "ID_INVALID_DATA" ) . " $status", null );
return $result;
}
} else {
$status = "ACTIVE";
}
2012-10-09 13:29:25 -04:00
$arrayRole = $RBAC->loadById( $role );
$strRole = null;
2012-10-09 13:29:25 -04:00
if (is_array( $arrayRole )) {
$strRole = $arrayRole["ROL_CODE"];
} else {
$strRole = $role;
2012-10-09 13:29:25 -04:00
if ($RBAC->verifyByCode( $role ) == 0) {
$data = array ();
$data["ROLE"] = $role;
2012-10-09 13:29:25 -04:00
$result = new wsCreateUserResponse( 6, G::loadTranslation( "ID_INVALID_ROLE", SYS_LANG, $data ), null );
return $result;
}
}
2012-10-09 13:29:25 -04:00
if (strlen( $password ) > 20) {
$result = new wsCreateUserResponse( - 1, G::loadTranslation( "ID_PASSWORD_SURPRASES" ), null );
return $result;
}
2012-10-09 13:29:25 -04:00
if ($RBAC->verifyUser( $userName ) == 1) {
$data = array ();
$data["USER_ID"] = $userName;
2012-10-09 13:29:25 -04:00
$result = new wsCreateUserResponse( 7, G::loadTranslation( "ID_USERNAME_ALREADY_EXISTS", SYS_LANG, $data ), null );
return $result;
}
//Set fields
2012-10-09 13:29:25 -04:00
$arrayData = array ();
$arrayData["USR_USERNAME"] = $userName;
$arrayData["USR_PASSWORD"] = Bootstrap::hashPassword( $password );
2012-10-09 13:29:25 -04:00
$arrayData["USR_FIRSTNAME"] = $firstName;
$arrayData["USR_LASTNAME"] = $lastName;
$arrayData["USR_EMAIL"] = $email;
$arrayData["USR_DUE_DATE"] = $mktimeDueDate;
$arrayData["USR_CREATE_DATE"] = date( "Y-m-d H:i:s" );
$arrayData["USR_UPDATE_DATE"] = date( "Y-m-d H:i:s" );
$arrayData["USR_BIRTHDAY"] = date( "Y-m-d" );
$arrayData["USR_AUTH_USER_DN"] = "";
2012-10-09 13:29:25 -04:00
$arrayData["USR_STATUS"] = ($status == "ACTIVE") ? 1 : 0;
2013-03-20 10:58:19 -04:00
try {
$userUid = $RBAC->createUser( $arrayData, $strRole );
} catch(Exception $oError) {
$result = new wsCreateUserResponse(100, $oError->getMessage(), null );
return $result;
}
2012-10-09 13:29:25 -04:00
$arrayData["USR_UID"] = $userUid;
$arrayData["USR_STATUS"] = $status;
//$arrayData["USR_PASSWORD"] = md5($userUid);
2012-10-09 13:29:25 -04:00
$arrayData["USR_COUNTRY"] = "";
$arrayData["USR_CITY"] = "";
$arrayData["USR_LOCATION"] = "";
2012-10-09 13:29:25 -04:00
$arrayData["USR_ADDRESS"] = "";
$arrayData["USR_PHONE"] = "";
$arrayData["USR_ZIP_CODE"] = "";
$arrayData["USR_POSITION"] = "";
//$arrayData["USR_RESUME"]
2012-10-09 13:29:25 -04:00
$arrayData["USR_ROLE"] = $strRole;
//$arrayData["USR_REPLACED_BY"]
2012-10-09 13:29:25 -04:00
$user = new Users();
2012-10-09 13:29:25 -04:00
$user->create( $arrayData );
//Response
2012-10-09 13:29:25 -04:00
$data = array ();
$data["FIRSTNAME"] = $firstName;
$data["LASTNAME"] = $lastName;
$data["USER_ID"] = $userName;
2012-10-09 13:29:25 -04:00
$res = new wsResponse( 0, G::loadTranslation( "ID_USER_CREATED_SUCCESSFULLY", SYS_LANG, $data ) );
2012-10-09 13:29:25 -04:00
$result = array ("status_code" => $res->status_code,"message" => $res->message,"userUID" => $userUid,"timestamp" => $res->timestamp
);
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = wsCreateUserResponse( 100, $e->getMessage(), null );
return $result;
}
}
/**
* Update user
2012-10-09 13:29:25 -04:00
*
* @param string userUid : The user UID.
* @param string userName : The username for the user.
* @param string firstName : Optional parameter. The user's first name.
2012-10-09 13:29:25 -04:00
* @param string lastName : Optional parameter. The user's last name.
* @param string email : Optional parameter. The user's email address.
* @param string dueDate : Optional parameter. The expiration date must be a string in the format "yyyy-mm-dd".
* @param string status : Optional parameter. The user's status, such as "ACTIVE", "INACTIVE" or "VACATION".
* @param string role : Optional parameter. The user's role, such
* as "PROCESSMAKER_ADMIN" or "PROCESSMAKER_OPERATOR".
* @param string password : Optional parameter. The user's password such as "Be@gle2" (It will be automatically
* encrypted with an MD5 hash).
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function updateUser ($userUid, $userName, $firstName = null, $lastName = null, $email = null, $dueDate = null, $status = null, $role = null, $password = null)
{
try {
global $RBAC;
$RBAC->initRBAC();
2012-10-09 13:29:25 -04:00
if (empty( $userUid )) {
$result = new wsResponse( 25, G::LoadTranslation( "ID_REQUIRED_FIELD" ) . " userUid" );
return $result;
}
2012-10-09 13:29:25 -04:00
if (empty( $userName )) {
$result = new wsResponse( 25, G::LoadTranslation( "ID_USERNAME_REQUIRED" ) );
return $result;
}
2012-10-09 13:29:25 -04:00
if ($RBAC->verifyUserId( $userUid ) == 0) {
$result = new wsResponse( 3, G::loadTranslation( "ID_USER_NOT_REGISTERED_SYSTEM" ) );
return $result;
}
$mktimeDueDate = 0;
2012-10-09 13:29:25 -04:00
if (! empty( $dueDate )) {
if (! preg_match( "/^(\d{4})-(\d{2})-(\d{2})$/", $dueDate, $arrayMatch )) {
$result = new wsResponse( - 1, G::LoadTranslation( "ID_INVALID_DATA" ) . " $dueDate" );
return $result;
} else {
2012-10-09 13:29:25 -04:00
$mktimeDueDate = mktime( 0, 0, 0, intval( $arrayMatch[2] ), intval( $arrayMatch[3] ), intval( $arrayMatch[1] ) );
}
}
2012-10-09 13:29:25 -04:00
if (! empty( $status )) {
if ($status != "ACTIVE" && $status != "INACTIVE" && $status != "VACATION") {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( - 1, G::LoadTranslation( "ID_INVALID_DATA" ) . " $status" );
return $result;
}
}
$strRole = null;
2012-10-09 13:29:25 -04:00
if (! empty( $role )) {
$arrayRole = $RBAC->loadById( $role );
2012-10-09 13:29:25 -04:00
if (is_array( $arrayRole )) {
$strRole = $arrayRole["ROL_CODE"];
} else {
$strRole = $role;
2012-10-09 13:29:25 -04:00
if ($RBAC->verifyByCode( $role ) == 0) {
$data = array ();
$data["ROLE"] = $role;
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 6, G::LoadTranslation( "ID_INVALID_ROLE", SYS_LANG, $data ) );
return $result;
}
}
}
2012-10-09 13:29:25 -04:00
if (! empty( $password ) && strlen( $password ) > 20) {
$result = new wsResponse( - 1, G::LoadTranslation( "ID_PASSWORD_SURPRASES" ) );
return $result;
}
$criteria = new Criteria();
2012-10-09 13:29:25 -04:00
$criteria->addSelectColumn( UsersPeer::USR_UID );
$criteria->add( UsersPeer::USR_USERNAME, $userName );
$criteria->add( UsersPeer::USR_UID, $userUid, Criteria::NOT_EQUAL );
$rs = UsersPeer::doSelectRS( $criteria );
if ($rs->next()) {
2012-10-09 13:29:25 -04:00
$data = array ();
$data["USER_ID"] = $userName;
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 7, G::LoadTranslation( "ID_USERNAME_ALREADY_EXISTS", SYS_LANG, $data ) );
return $result;
}
//Set fields
2012-10-09 13:29:25 -04:00
$arrayData = array ();
2012-10-09 13:29:25 -04:00
$arrayData["USR_UID"] = $userUid;
$arrayData["USR_USERNAME"] = $userName;
2012-10-09 13:29:25 -04:00
if (! empty( $firstName )) {
$arrayData["USR_FIRSTNAME"] = $firstName;
}
2012-10-09 13:29:25 -04:00
if (! empty( $lastName )) {
$arrayData["USR_LASTNAME"] = $lastName;
}
2012-10-09 13:29:25 -04:00
if (! empty( $email )) {
$arrayData["USR_EMAIL"] = $email;
}
if ($mktimeDueDate != 0) {
$arrayData["USR_DUE_DATE"] = $mktimeDueDate;
}
2012-10-09 13:29:25 -04:00
$arrayData["USR_UPDATE_DATE"] = date( "Y-m-d H:i:s" );
2012-10-09 13:29:25 -04:00
if (! empty( $status )) {
$arrayData["USR_STATUS"] = $status;
}
if ($strRole != null) {
$arrayData["USR_ROLE"] = $strRole;
}
2012-10-09 13:29:25 -04:00
if (! empty( $password )) {
$arrayData["USR_PASSWORD"] = Bootstrap::hashPassword( $password );
}
//Update user
if ($strRole != null) {
2012-10-09 13:29:25 -04:00
$RBAC->updateUser( $arrayData, $strRole );
} else {
2012-10-09 13:29:25 -04:00
$RBAC->updateUser( $arrayData );
}
$user = new Users();
2012-10-09 13:29:25 -04:00
$user->update( $arrayData );
//Response
//$res = new wsResponse(0, G::LoadTranslation("ID_OBJECT_UPDATE"));
2012-10-09 13:29:25 -04:00
$res = new wsResponse( 0, G::LoadTranslation( "ID_UPDATED_SUCCESSFULLY" ) );
2012-10-09 13:29:25 -04:00
$result = array ("status_code" => $res->status_code,"message" => $res->message,"timestamp" => $res->timestamp
);
return $result;
} catch (Exception $e) {
$result = new wsResponse(100, $e->getMessage());
return $result;
}
}
/**
* Information User
* @param string userUid : The user UID.
* @return $result will return an object
*/
public function informationUser($userUid)
{
try {
if (empty($userUid)) {
$result = new wsResponse(100, G::LoadTranslation("ID_REQUIRED_FIELD") . " userUid");
return $result;
}
$user = new Users();
$userInfo = $user->getAllInformation($userUid);
//Response
$res = new wsResponse(0, G::LoadTranslation("ID_COMMAND_EXECUTED_SUCCESSFULLY"));
$result = new stdClass();
$result->status_code = $res->status_code;
$result->message = $res->message;
$result->timestamp = $res->timestamp;
$result->info = $userInfo;
return $result;
} catch (Exception $e) {
$result = new wsResponse(100, $e->getMessage());
return $result;
}
}
/**
* create Group
2012-10-09 13:29:25 -04:00
*
* @param string $groupName
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function createGroup ($groupName)
{
try {
2012-10-09 13:29:25 -04:00
if (trim( $groupName ) == '') {
$result = new wsCreateGroupResponse( 25, G::loadTranslation( 'ID_GROUP_NAME_REQUIRED' ), '' );
return $result;
}
$group = new Groupwf();
$grpRow['GRP_TITLE'] = $groupName;
2012-10-09 13:29:25 -04:00
$groupId = $group->create( $grpRow );
2010-12-02 23:34:41 +00:00
$data['GROUP_NAME'] = $groupName;
2012-10-09 13:29:25 -04:00
$result = new wsCreateGroupResponse( 0, G::loadTranslation( 'ID_GROUP_CREATED_SUCCESSFULLY', SYS_LANG, $data ), $groupId );
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = wsCreateGroupResponse( 100, $e->getMessage(), '' );
2010-12-02 23:34:41 +00:00
return $result;
}
2010-12-02 23:34:41 +00:00
}
/**
* Create New Department link on the top section of the left pane allows you to create a root-level department.
2012-10-09 13:29:25 -04:00
*
* @param string $departmentName
* @param string $parentUID
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function createDepartment ($departmentName, $parentUID)
{
try {
2012-10-09 13:29:25 -04:00
if (trim( $departmentName ) == '') {
$result = new wsCreateDepartmentResponse( 25, G::loadTranslation( 'ID_DEPARTMENT_NAME_REQUIRED' ), '' );
return $result;
}
$department = new Department();
2012-10-09 13:29:25 -04:00
if (($parentUID != '') && ! ($department->existsDepartment( $parentUID ))) {
$result = new wsCreateDepartmentResponse( 26, G::loadTranslation( 'ID_PARENT_DEPARTMENT_NOT_EXIST' ), $parentUID );
return $result;
}
2012-10-09 13:29:25 -04:00
if ($department->checkDepartmentName( $departmentName, $parentUID )) {
$result = new wsCreateDepartmentResponse( 27, G::loadTranslation( 'ID_DEPARTMENT_EXISTS' ), '' );
return $result;
}
$row['DEP_TITLE'] = $departmentName;
$row['DEP_PARENT'] = $parentUID;
2012-10-09 13:29:25 -04:00
$departmentId = $department->create( $row );
$data['DEPARTMENT_NAME'] = $departmentName;
2012-10-09 13:29:25 -04:00
$data['PARENT_UID'] = $parentUID;
$data['DEPARTMENT_NAME'] = $departmentName;
2012-10-09 13:29:25 -04:00
$result = new wsCreateDepartmentResponse( 0, G::loadTranslation( 'ID_DEPARTMENT_CREATED_SUCCESSFULLY', SYS_LANG, $data ), $departmentId );
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = wsCreateDepartmentResponse( 100, $e->getMessage(), '' );
return $result;
BUG 9043 Variable for Case Notes content needed SOLVED - Se crearon varias funciones para este caso. - La funcion getCaseNotes en la class.case.php con los parametros applicationID, type que es la forma que quiere que se devuelvan los datos, puede ser array, objetc, string por defecto esta en array, y userID que nos daria solo las notas de ese usuario, por defecto nos devuelve de todos los usuarios. - Se modifico la funcion getNotesList para poder traer las notas por un determinado usuario y por defecto recupera las notas de todos los usuarios. - en class.pmFunctions.php se creo la funcion PMFGetCaseNotes con los parametros applicationID, type que es la forma que quiere que se devuelvan los datos, puede ser array, objetc, string por defecto esta en array, y userID que nos daria solo las notas de ese usuario, por defecto nos devuelve de todos los usuarios. - En class.wsBase.php la funcion getCaseNotes con los parametros applicationID, userID que nos daria solo las notas de ese usuario, por defecto nos devuelve de todos los usuarios, esta funcion nos devuelve un array con los fieds en minuscula. - En soap2.php getCaseNotes donde se tienen los siguiente parametros: sessionId, se necesita iniciar una session para poder utilizarlo, applicationID, userID que nos daria solo las notas de ese usuario, por defecto nos devuelve de todos los usuarios. - Se adiciono la funcion para utilizarlo en SoapServer. - En wsResponse se creo un nuevo template para la respuesta del webservice wsGetCaseNotesResponse con los campos status_code, message, notes, timestamp. - En pmos2.wsdl se agregaron los datos necesarios para la salida correcta del webservice.
2012-05-02 09:56:30 -04:00
}
}
/**
* remove user from group
2012-10-09 13:29:25 -04:00
*
* @param string $appDocUid
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function removeUserFromGroup ($userId, $groupId)
{
try {
2012-10-09 13:29:25 -04:00
G::LoadClass( 'groups' );
global $RBAC;
$RBAC->initRBAC();
2012-10-09 13:29:25 -04:00
$user = $RBAC->verifyUserId( $userId );
if ($user == 0) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 3, G::loadTranslation( 'ID_USER_NOT_REGISTERED_SYSTEM' ) );
return $result;
}
2012-10-09 13:29:25 -04:00
$groups = new Groups();
$very_group = $groups->verifyGroup( $groupId );
if ($very_group == 0) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 9, G::loadTranslation( 'ID_GROUP_NOT_REGISTERED_SYSTEM' ) );
return $result;
}
2012-10-09 13:29:25 -04:00
$very_user = $groups->verifyUsertoGroup( $groupId, $userId );
if ($very_user == 1) {
$oGroup = new Groups();
2012-10-09 13:29:25 -04:00
$oGroup->removeUserOfGroup( $groupId, $userId );
$result = new wsResponse( 0, G::loadTranslation( 'ID_COMMAND_EXECUTED_SUCCESSFULY' ) );
return $result;
}
//$oGroup->removeUserOfGroup($_POST['GRP_UID'], $_POST['USR_UID']);
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 8, G::loadTranslation( 'ID_USER_NOT_REGISTERED_GROUP' ) );
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, $e->getMessage() );
return $result;
}
//G::LoadClass('groups');
//$oGroup = new Groups();
//$oGroup->removeUserOfGroup($_POST['GRP_UID'], $_POST['USR_UID']);
}
/**
* assigns a user to a group
2012-10-09 13:29:25 -04:00
*
* @param string $userId
* @param string $groupId
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function assignUserToGroup ($userId, $groupId)
{
try {
global $RBAC;
$RBAC->initRBAC();
2012-10-09 13:29:25 -04:00
$user = $RBAC->verifyUserId( $userId );
if ($user == 0) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 3, G::loadTranslation( 'ID_USER_NOT_REGISTERED_SYSTEM' ) );
return $result;
}
$groups = new Groups();
2012-10-09 13:29:25 -04:00
$very_group = $groups->verifyGroup( $groupId );
if ($very_group == 0) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 9, G::loadTranslation( 'ID_GROUP_NOT_REGISTERED_SYSTEM' ) );
return $result;
}
2012-10-09 13:29:25 -04:00
$very_user = $groups->verifyUsertoGroup( $groupId, $userId );
if ($very_user == 1) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 8, G::loadTranslation( 'ID_USER_ALREADY_EXISTS_GROUP' ) );
return $result;
}
2012-10-09 13:29:25 -04:00
$groups->addUserToGroup( $groupId, $userId );
$result = new wsResponse( 0, G::loadTranslation( 'ID_COMMAND_EXECUTED_SUCCESSFULY' ) );
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, $e->getMessage() );
return $result;
}
}
/**
* assigns user to department
2012-10-09 13:29:25 -04:00
*
* @param string $userId
* @param string $depId
* @param string $manager
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function assignUserToDepartment ($userId, $depId, $manager)
{
try {
global $RBAC;
$RBAC->initRBAC();
2012-10-09 13:29:25 -04:00
$user = $RBAC->verifyUserId( $userId );
2012-10-09 13:29:25 -04:00
if ($user == 0) {
$result = new wsResponse( 3, G::loadTranslation( 'ID_USER_NOT_REGISTERED_SYSTEM' ) );
return $result;
}
2012-10-09 13:29:25 -04:00
$deps = new Department();
2012-10-09 13:29:25 -04:00
if (! $deps->existsDepartment( $depId )) {
$data['DEP_ID'] = $depId;
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, G::loadTranslation( 'ID_DEPARTMENT_NOT_REGISTERED_SYSTEM', SYS_LANG, $data ) );
return $result;
}
2012-10-09 13:29:25 -04:00
if (! $deps->existsUserInDepartment( $depId, $userId )) {
$deps->addUserToDepartment( $depId, $userId, $manager, true );
}
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 0, G::loadTranslation( 'ID_COMMAND_EXECUTED_SUCCESSFULY' ) );
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, $e->getMessage() );
return $result;
}
}
/**
* sends variables to a case
2012-10-09 13:29:25 -04:00
*
* @param string $caseId
* @param string $variables
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function sendVariables ($caseId, $variables)
{
//delegation where app uid (caseId) y usruid(session) ordenar delindes descendente y agaarr el primero
//delfinishdate != null error
try {
2012-10-09 13:29:25 -04:00
$oCriteria = new Criteria( 'workflow' );
$oCriteria->addSelectColumn( AppDelegationPeer::DEL_FINISH_DATE );
$oCriteria->add( AppDelegationPeer::APP_UID, $caseId );
$oCriteria->add( AppDelegationPeer::DEL_FINISH_DATE, null, Criteria::ISNULL );
2012-10-09 13:29:25 -04:00
$oCriteria->addDescendingOrderByColumn( AppDelegationPeer::DEL_INDEX );
$oDataset = AppDelegationPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$cnt = 0;
while ($oDataset->next()) {
$aRow = $oDataset->getRow();
2012-10-09 13:29:25 -04:00
$cnt ++;
}
if ($cnt == 0) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 18, G::loadTranslation( 'ID_CASE_DELEGATION_ALREADY_CLOSED' ) );
return $result;
}
2012-10-09 13:29:25 -04:00
if (is_array( $variables )) {
$cant = count( $variables );
if ($cant > 0) {
$oCase = new Cases();
2012-10-09 13:29:25 -04:00
$oldFields = $oCase->loadCase( $caseId );
$oldFields['APP_DATA'] = array_merge( $oldFields['APP_DATA'], $variables );
ob_start();
2012-10-09 13:29:25 -04:00
print_r( $variables );
$cdata = ob_get_contents();
ob_end_clean();
2012-10-09 13:29:25 -04:00
$up_case = $oCase->updateCase( $caseId, $oldFields );
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 0, $cant . " " . G::loadTranslation( 'ID_VARIABLES_RECEIVED' ) . ": \n" . trim( str_replace( 'Array', '', $cdata ) ) );
return $result;
} else {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 23, G::loadTranslation( 'ID_VARIABLES_PARAM_ZERO' ) );
return $result;
}
} else {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 24, G::loadTranslation( 'ID_VARIABLES_PARAM_NOT_ARRAY' ) );
return $result;
}
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, $e->getMessage() );
return $result;
}
}
/**
2012-10-09 13:29:25 -04:00
* get variables The variables can be system variables and/or case variables
*
* @param string $caseId
* @param string $variables
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function getVariables ($caseId, $variables)
{
try {
2012-10-09 13:29:25 -04:00
if (is_array( $variables )) {
$cant = count( $variables );
if ($cant > 0) {
$oCase = new Cases();
2012-10-09 13:29:25 -04:00
$caseFields = $oCase->loadCase( $caseId );
$oldFields = $caseFields['APP_DATA'];
$resFields = array ();
foreach ($variables as $key => $val) {
$a .= $val->name . ', ';
2012-10-09 13:29:25 -04:00
if (isset( $oldFields[$val->name] )) {
if (! is_array( $oldFields[$val->name] )) {
$node = new stdClass();
$node->name = $val->name;
$node->value = $oldFields[$val->name];
$resFields[] = $node;
} else {
foreach ($oldFields[$val->name] as $gridKey => $gridRow) {
//Special Variables like grids or checkgroups
2012-10-09 13:29:25 -04:00
if (is_array( $gridRow )) {
//Grids
foreach ($gridRow as $col => $colValue) {
2012-10-09 13:29:25 -04:00
$node = new stdClass();
$node->name = $val->name . "][" . $gridKey . "][" . $col;
$node->value = $colValue;
$resFields[] = $node;
}
} else {
//Checkgroups, Radiogroups
2012-10-09 13:29:25 -04:00
$node = new stdClass();
$node->name = $key;
$node->value = implode( "|", $val );
$resFields[] = $node;
}
}
}
}
}
2012-10-09 13:29:25 -04:00
$result = new wsGetVariableResponse( 0, count( $resFields ) . G::loadTranslation( 'ID_VARIABLES_SENT' ), $resFields );
return $result;
} else {
2012-10-09 13:29:25 -04:00
$result = new wsGetVariableResponse( 23, G::loadTranslation( 'ID_VARIABLES_PARAM_ZERO' ), null );
return $result;
}
} else {
2012-10-09 13:29:25 -04:00
$result = new wsGetVariableResponse( 24, G::loadTranslation( 'ID_VARIABLES_PARAM_NOT_ARRAY' ), null );
return $result;
}
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsGetVariableResponse( 100, $e->getMessage(), null );
return $result;
}
}
/**
2012-10-09 13:29:25 -04:00
* get all variables the system and case selected
*
* @param string $caseId
*
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function getVariablesNames ($caseId)
{
try {
$oCase = new Cases();
2012-10-09 13:29:25 -04:00
$caseFields = $oCase->loadCase( $caseId );
2012-10-09 13:29:25 -04:00
$oldFields = $caseFields['APP_DATA'];
$resFields = array ();
foreach ($oldFields as $key => $val) {
$node = new stdClass();
2012-10-09 13:29:25 -04:00
$node->name = $key;
$resFields[] = $node;
}
2012-10-09 13:29:25 -04:00
$result = new wsGetVariableResponse( 0, count( $resFields ) . G::loadTranslation( 'ID_VARIABLES_SENT' ), $resFields );
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsGetVariableResponse( 100, $e->getMessage(), null );
return $result;
}
}
/**
* new Case begins a new case under the name of the logged-in user.
*
* @param string $processId
* @param string $userId
* @param string $taskId
* @param string $variables
* @param int $executeTriggers : Optional parameter. The execution all triggers of the task, according to your steps, 1 yes 0 no.
* @return $result will return an object
*/
public function newCase($processId, $userId, $taskId, $variables, $executeTriggers = 0)
{
//$executeTriggers, this parameter is not important, it may be the last parameter in the method
$g = new G();
try {
$g->sessionVarSave();
$_SESSION["PROCESS"] = $processId;
$_SESSION["TASK"] = $taskId;
$_SESSION["USER_LOGGED"] = $userId;
2012-10-09 13:29:25 -04:00
$Fields = array ();
2012-10-09 13:29:25 -04:00
if (is_array( $variables ) && count( $variables ) > 0) {
$Fields = $variables;
}
2012-10-12 12:52:50 -04:00
$oProcesses = new Processes();
2012-10-09 13:29:25 -04:00
$pro = $oProcesses->processExists( $processId );
2012-10-09 13:29:25 -04:00
if (! $pro) {
$result = new wsResponse( 11, G::loadTranslation( 'ID_INVALID_PROCESS' ) . " " . $processId );
$g->sessionVarRestore();
return $result;
}
2012-10-12 12:52:50 -04:00
$oCase = new Cases();
2012-10-09 13:29:25 -04:00
$startingTasks = $oCase->getStartCases( $userId );
array_shift( $startingTasks ); //remove the first row, the header row
$founded = '';
$tasksInThisProcess = 0;
2012-10-09 13:29:25 -04:00
$validTaskId = $taskId;
foreach ($startingTasks as $key => $val) {
if ($val['pro_uid'] == $processId) {
2012-10-09 13:29:25 -04:00
$tasksInThisProcess ++;
$validTaskId = $val['uid'];
}
if ($val['uid'] == $taskId) {
$founded = $val['value'];
}
}
if ($taskId == '') {
if ($tasksInThisProcess == 1) {
$founded = $validTaskId;
2012-10-09 13:29:25 -04:00
$taskId = $validTaskId;
}
if ($tasksInThisProcess > 1) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 13, G::loadTranslation( 'ID_MULTIPLE_STARTING_TASKS' ) );
$g->sessionVarRestore();
return $result;
}
}
$task = TaskPeer::retrieveByPK($taskId);
$arrayTaskTypeToExclude = array("START-TIMER-EVENT");
if (!is_null($task) && !in_array($task->getTasType(), $arrayTaskTypeToExclude) && $founded == "") {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 14, G::loadTranslation( 'ID_TASK_INVALID_USER_NOT_ASSIGNED_TASK' ) );
$g->sessionVarRestore();
return $result;
}
2012-10-12 12:52:50 -04:00
//Start case
2012-10-09 13:29:25 -04:00
$case = $oCase->startCase( $taskId, $userId );
2012-10-09 13:29:25 -04:00
$_SESSION['APPLICATION'] = $case['APPLICATION'];
$_SESSION['PROCESS'] = $case['PROCESS'];
$_SESSION['TASK'] = $taskId;
$_SESSION['INDEX'] = $case['INDEX'];
$_SESSION['USER_LOGGED'] = $userId;
$_SESSION['USR_USERNAME'] = (isset($case['USR_USERNAME'])) ? $case['USR_USERNAME'] : '';
$_SESSION['STEP_POSITION'] = 0;
$caseId = $case['APPLICATION'];
$caseNr = $case['CASE_NUMBER'];
2012-10-12 12:52:50 -04:00
2012-10-09 13:29:25 -04:00
$oldFields = $oCase->loadCase( $caseId );
2012-10-12 12:52:50 -04:00
2012-10-09 13:29:25 -04:00
$oldFields['APP_DATA'] = array_merge( $oldFields['APP_DATA'], $Fields );
2012-10-12 12:52:50 -04:00
$oldFields['DEL_INDEX'] = $case['INDEX'];
$oldFields['TAS_UID'] = $taskId;
2012-10-09 13:29:25 -04:00
$up_case = $oCase->updateCase( $caseId, $oldFields );
2012-10-12 12:52:50 -04:00
//Execute all triggers of the task, according to your steps
if ($executeTriggers == 1) {
$task = new Tasks();
$arrayStep = $task->getStepsOfTask($taskId);
foreach ($arrayStep as $step) {
$arrayField = $oCase->loadCase($caseId);
$arrayField["APP_DATA"] = $oCase->executeTriggers($taskId, $step["STEP_TYPE_OBJ"], $step["STEP_UID_OBJ"], "BEFORE", $arrayField["APP_DATA"]);
$arrayField["APP_DATA"] = $oCase->executeTriggers($taskId, $step["STEP_TYPE_OBJ"], $step["STEP_UID_OBJ"], "AFTER", $arrayField["APP_DATA"]);
unset($arrayField['APP_STATUS']);
unset($arrayField['APP_PROC_STATUS']);
unset($arrayField['APP_PROC_CODE']);
unset($arrayField['APP_PIN']);
$arrayField = $oCase->updateCase($caseId, $arrayField);
}
}
//Response
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 0, G::loadTranslation( 'ID_STARTED_SUCCESSFULLY' ) );
$result->caseId = $caseId;
$result->caseNumber = $caseNr;
$g->sessionVarRestore();
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, $e->getMessage() );
$g->sessionVarRestore();
return $result;
}
}
/**
* creates a new case impersonating a user who has the proper privileges to create new cases
2012-10-09 13:29:25 -04:00
*
* @param string $processId
* @param string $userId
* @param string $variables
* @param string $taskId, must be in the starting group.
* @return $result will return an object
*/
public function newCaseImpersonate ($processId, $userId, $variables, $taskId = '')
{
try {
2012-10-09 13:29:25 -04:00
if (is_array( $variables )) {
if (count( $variables ) > 0) {
$c = count( $variables );
$Fields = $variables;
} else {
if ($c == 0) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 10, G::loadTranslation( 'ID_ARRAY_VARIABLES_EMPTY' ) );
return $result;
}
}
} else {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 10, G::loadTranslation( 'ID_VARIABLES_PARAM_NOT_ARRAY' ) );
return $result;
}
$processes = new Processes();
2012-10-09 13:29:25 -04:00
if (! $processes->processExists( $processId )) {
$result = new wsResponse( 11, G::loadTranslation( 'ID_INVALID_PROCESS' ) . " " . $processId . "!!" );
return $result;
}
$user = new Users();
2012-10-09 13:29:25 -04:00
if (! $user->userExists( $userId )) {
$result = new wsResponse( 11, G::loadTranslation( 'ID_USER_NOT_REGISTERED' ) . " " . $userId . "!!" );
return $result;
}
$oCase = new Cases();
$numTasks = 0;
if ($taskId != '') {
2013-03-19 13:47:16 -04:00
$aTasks = $processes->getStartingTaskForUser( $processId, null );
foreach ($aTasks as $task) {
if ($task['TAS_UID'] == $taskId) {
$arrayTask[0]['TAS_UID'] = $taskId;
$numTasks = 1;
}
}
} else {
$arrayTask = $processes->getStartingTaskForUser( $processId, null );
$numTasks = count( $arrayTask );
}
if ($numTasks == 1) {
2012-10-09 13:29:25 -04:00
$case = $oCase->startCase( $arrayTask[0]['TAS_UID'], $userId );
$caseId = $case['APPLICATION'];
$caseNumber = $case['CASE_NUMBER'];
2012-10-09 13:29:25 -04:00
$oldFields = $oCase->loadCase( $caseId );
2012-10-09 13:29:25 -04:00
$oldFields['APP_DATA'] = array_merge( $oldFields['APP_DATA'], $Fields );
2012-10-09 13:29:25 -04:00
$up_case = $oCase->updateCase( $caseId, $oldFields );
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 0, G::loadTranslation( 'ID_COMMAND_EXECUTED_SUCCESSFULLY' ) );
2012-10-09 13:29:25 -04:00
$result->caseId = $caseId;
$result->caseNumber = $caseNumber;
return $result;
} else {
if ($numTasks == 0) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 12, G::loadTranslation( 'ID_NO_STARTING_TASK' ) );
return $result;
}
if ($numTasks > 1) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 13, G::loadTranslation( 'ID_MULTIPLE_STARTING_TASKS' ) );
return $result;
}
}
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, $e->getMessage() );
return $result;
}
}
/**
* derivate Case moves the case to the next task in the process according to the routing rules
2012-10-09 13:29:25 -04:00
*
* @param string $userId
* @param string $caseId
* @param string $delIndex
* @param array $tasks
* @param bool $bExecuteTriggersBeforeAssignment
* @return $result will return an object
*/
public function derivateCase ($userId, $caseId, $delIndex, $bExecuteTriggersBeforeAssignment = false, $tasks = array())
{
$g = new G();
try {
$g->sessionVarSave();
$_SESSION["APPLICATION"] = $caseId;
$_SESSION["INDEX"] = $delIndex;
$_SESSION["USER_LOGGED"] = $userId;
$sStatus = 'TO_DO';
$varResponse = '';
$varTriggers = "\n";
if ($delIndex == '') {
2012-10-09 13:29:25 -04:00
$oCriteria = new Criteria( 'workflow' );
$oCriteria->addSelectColumn( AppDelegationPeer::DEL_INDEX );
$oCriteria->add( AppDelegationPeer::APP_UID, $caseId );
$oCriteria->add( AppDelegationPeer::DEL_FINISH_DATE, null, Criteria::ISNULL );
2012-10-09 13:29:25 -04:00
if (AppDelegationPeer::doCount( $oCriteria ) > 1) {
$result = new wsResponse( 20, G::loadTranslation( 'ID_SPECIFY_DELEGATION_INDEX' ) );
return $result;
}
2012-10-09 13:29:25 -04:00
$oDataset = AppDelegationPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
2012-10-09 13:29:25 -04:00
$aRow = $oDataset->getRow();
$delIndex = $aRow['DEL_INDEX'];
}
$oAppDel = new AppDelegation();
2012-10-09 13:29:25 -04:00
$appdel = $oAppDel->Load( $caseId, $delIndex );
if ($userId != $appdel['USR_UID']) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 17, G::loadTranslation( 'ID_CASE_ASSIGNED_ANOTHER_USER' ) );
return $result;
}
if ($appdel['DEL_FINISH_DATE'] != null) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 18, G::loadTranslation( 'ID_CASE_DELEGATION_ALREADY_CLOSED' ) );
return $result;
}
2012-10-09 13:29:25 -04:00
$oCriteria = new Criteria( 'workflow' );
$oCriteria->addSelectColumn( AppDelayPeer::APP_UID );
$oCriteria->addSelectColumn( AppDelayPeer::APP_DEL_INDEX );
$oCriteria->add( AppDelayPeer::APP_TYPE, '' );
$oCriteria->add( $oCriteria->getNewCriterion( AppDelayPeer::APP_TYPE, 'PAUSE' )->addOr( $oCriteria->getNewCriterion( AppDelayPeer::APP_TYPE, 'CANCEL' ) ) );
$oCriteria->addAscendingOrderByColumn( AppDelayPeer::APP_ENABLE_ACTION_DATE );
$oDataset = AppDelayPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
$aRow = $oDataset->getRow();
2012-10-09 13:29:25 -04:00
if (is_array( $aRow )) {
if (isset( $aRow['APP_DISABLE_ACTION_USER'] ) && $aRow['APP_DISABLE_ACTION_USER'] != 0 && isset( $aRow['APP_DISABLE_ACTION_DATE'] ) && $aRow['APP_DISABLE_ACTION_DATE'] != '') {
$result = new wsResponse( 19, G::loadTranslation( 'ID_CASE_IN_STATUS' ) . " " . $aRow['APP_TYPE'] );
return $result;
}
}
$aData = array();
2012-10-09 13:29:25 -04:00
$aData['APP_UID'] = $caseId;
$aData['DEL_INDEX'] = $delIndex;
2012-10-09 13:29:25 -04:00
$aData['USER_UID'] = $userId;
//Load data
2012-10-09 13:29:25 -04:00
$oCase = new Cases();
$appFields = $oCase->loadCase( $caseId, $delIndex );
2012-10-09 13:29:25 -04:00
if (is_null( $appFields["DEL_INIT_DATE"] )) {
$oCase->setDelInitDate( $caseId, $delIndex );
$appFields = $oCase->loadCase( $caseId, $delIndex );
}
$appFields["APP_DATA"]["APPLICATION"] = $caseId;
2012-10-09 13:29:25 -04:00
if (! isset( $_SESSION["PROCESS"] )) {
$_SESSION["PROCESS"] = $appFields["PRO_UID"];
}
if ($bExecuteTriggersBeforeAssignment) {
//Execute triggers before assignment
2012-10-09 13:29:25 -04:00
$aTriggers = $oCase->loadTriggers( $appdel['TAS_UID'], 'ASSIGN_TASK', - 1, 'BEFORE' );
2012-10-09 13:29:25 -04:00
if (count( $aTriggers ) > 0) {
$varTriggers = $varTriggers . "<br /><b>-= Before Assignment =-</b><br />";
$oPMScript = new PMScript();
foreach ($aTriggers as $aTrigger) {
//$appFields = $oCase->loadCase( $caseId );
//$appFields['APP_DATA']['APPLICATION'] = $caseId;
2012-10-09 13:29:25 -04:00
//Set variables
$params = new stdClass();
$params->appData = $appFields["APP_DATA"];
if ($this->stored_system_variables) {
$params->option = "STORED SESSION";
2012-10-09 13:29:25 -04:00
$params->SID = $this->wsSessionId;
}
2012-10-09 13:29:25 -04:00
$appFields["APP_DATA"] = array_merge( $appFields["APP_DATA"], G::getSystemConstants( $params ) );
//PMScript
2012-10-09 13:29:25 -04:00
$oPMScript->setFields( $appFields['APP_DATA'] );
$bExecute = true;
if ($aTrigger['ST_CONDITION'] !== '') {
2012-10-09 13:29:25 -04:00
$oPMScript->setScript( $aTrigger['ST_CONDITION'] );
$bExecute = $oPMScript->evaluate();
}
if ($bExecute) {
2012-10-09 13:29:25 -04:00
$oPMScript->setScript( $aTrigger['TRI_WEBBOT'] );
$oPMScript->execute();
$trigger = TriggersPeer::retrieveByPk($aTrigger["TRI_UID"]);
$varTriggers = $varTriggers . "&nbsp;- " . nl2br(htmlentities($trigger->getTriTitle(), ENT_QUOTES)) . "<br />";
//$appFields = $oCase->loadCase( $caseId );
$appFields['APP_DATA'] = $oPMScript->aFields;
unset($appFields['APP_STATUS']);
unset($appFields['APP_PROC_STATUS']);
unset($appFields['APP_PROC_CODE']);
unset($appFields['APP_PIN']);
2012-10-09 13:29:25 -04:00
$oCase->updateCase( $caseId, $appFields );
}
}
}
}
//Execute triggers before derivation BEFORE_ROUTING
2012-10-09 13:29:25 -04:00
$aTriggers = $oCase->loadTriggers( $appdel['TAS_UID'], 'ASSIGN_TASK', - 2, 'BEFORE' );
2012-10-09 13:29:25 -04:00
if (count( $aTriggers ) > 0) {
$varTriggers .= "<b>-= Before Derivation =-</b><br/>";
$oPMScript = new PMScript();
foreach ($aTriggers as $aTrigger) {
//$appFields = $oCase->loadCase( $caseId );
//$appFields['APP_DATA']['APPLICATION'] = $caseId;
2012-10-09 13:29:25 -04:00
//Set variables
$params = new stdClass();
$params->appData = $appFields["APP_DATA"];
if ($this->stored_system_variables) {
$params->option = "STORED SESSION";
2012-10-09 13:29:25 -04:00
$params->SID = $this->wsSessionId;
}
2012-10-09 13:29:25 -04:00
$appFields["APP_DATA"] = array_merge( $appFields["APP_DATA"], G::getSystemConstants( $params ) );
//PMScript
2012-10-09 13:29:25 -04:00
$oPMScript->setFields( $appFields['APP_DATA'] );
$bExecute = true;
if ($aTrigger['ST_CONDITION'] !== '') {
2012-10-09 13:29:25 -04:00
$oPMScript->setScript( $aTrigger['ST_CONDITION'] );
$bExecute = $oPMScript->evaluate();
}
if ($bExecute) {
2012-10-09 13:29:25 -04:00
$oPMScript->setScript( $aTrigger['TRI_WEBBOT'] );
$oPMScript->execute();
2012-10-09 13:29:25 -04:00
$oTrigger = TriggersPeer::retrieveByPk( $aTrigger['TRI_UID'] );
$varTriggers .= "&nbsp;- " . nl2br( htmlentities( $oTrigger->getTriTitle(), ENT_QUOTES ) ) . "<br/>";
//$appFields = $oCase->loadCase( $caseId );
$appFields['APP_DATA'] = $oPMScript->aFields;
unset($appFields['APP_STATUS']);
unset($appFields['APP_PROC_STATUS']);
unset($appFields['APP_PROC_CODE']);
unset($appFields['APP_PIN']);
//$appFields['APP_DATA']['APPLICATION'] = $caseId;
2012-10-09 13:29:25 -04:00
$oCase->updateCase( $caseId, $appFields );
}
}
}
$oDerivation = new Derivation();
if (!empty($tasks)) {
$nextDelegations = $tasks;
} else {
$derive = $oDerivation->prepareInformation($aData);
if (isset($derive[1])) {
if ($derive[1]['ROU_TYPE'] == 'SELECT') {
$result = new wsResponse(21, G::loadTranslation('ID_CAN_NOT_ROUTE_CASE_USING_WEBSERVICES'));
return $result;
}
} else {
$result = new wsResponse(22, G::loadTranslation('ID_TASK_DOES_NOT_HAVE_ROUTING_RULE'));
return $result;
}
foreach ($derive as $key => $val) {
if ($val['NEXT_TASK']['TAS_ASSIGN_TYPE'] == 'MANUAL') {
$result = new wsResponse(15, G::loadTranslation('ID_TASK_DEFINED_MANUAL_ASSIGNMENT'));
return $result;
}
//Routed to the next task, if end process then not exist user
$nodeNext = array();
$usrasgdUid = null;
$usrasgdUserName = null;
if (isset($val['NEXT_TASK']['USER_ASSIGNED'])) {
$usrasgdUid = $val['NEXT_TASK']['USER_ASSIGNED']['USR_UID'];
$usrasgdUserName = '(' . $val['NEXT_TASK']['USER_ASSIGNED']['USR_USERNAME'] . ')';
}
$nodeNext['TAS_UID'] = $val['NEXT_TASK']['TAS_UID'];
$nodeNext['USR_UID'] = $usrasgdUid;
$nodeNext['TAS_ASSIGN_TYPE'] = $val['NEXT_TASK']['TAS_ASSIGN_TYPE'];
$nodeNext['TAS_DEF_PROC_CODE'] = $val['NEXT_TASK']['TAS_DEF_PROC_CODE'];
$nodeNext['DEL_PRIORITY'] = $appdel['DEL_PRIORITY'];
$nodeNext['TAS_PARENT'] = $val['NEXT_TASK']['TAS_PARENT'];
$nextDelegations[] = $nodeNext;
$varResponse = $varResponse . (($varResponse != '') ? ',' : '') . $val['NEXT_TASK']['TAS_TITLE'] . $usrasgdUserName;
}
}
$appFields['DEL_INDEX'] = $delIndex;
2012-10-09 13:29:25 -04:00
if (isset( $derive['TAS_UID'] )) {
$appFields['TAS_UID'] = $derive['TAS_UID'];
}
//Save data - Start
//$appFields = $oCase->loadCase( $caseId );
//$oCase->updateCase ( $caseId, $appFields );
//Save data - End
2012-10-09 13:29:25 -04:00
$row = array ();
$oCriteria = new Criteria( 'workflow' );
$del = DBAdapter::getStringDelimiter();
2012-10-09 13:29:25 -04:00
$oCriteria->addSelectColumn( RoutePeer::ROU_TYPE );
$oCriteria->addSelectColumn( RoutePeer::ROU_NEXT_TASK );
$oCriteria->add( RoutePeer::TAS_UID, $appdel['TAS_UID'] );
$oDataset = TaskPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
2012-10-09 13:29:25 -04:00
$row[] = array ('ROU_TYPE' => $aRow['ROU_TYPE'],'ROU_NEXT_TASK' => $aRow['ROU_NEXT_TASK']
);
$oDataset->next();
}
//derivate case
2012-10-09 13:29:25 -04:00
$aCurrentDerivation = array ('APP_UID' => $caseId,'DEL_INDEX' => $delIndex,'APP_STATUS' => $sStatus,'TAS_UID' => $appdel['TAS_UID'],'ROU_TYPE' => $row[0]['ROU_TYPE']
);
2012-10-09 13:29:25 -04:00
$oDerivation->derivate( $aCurrentDerivation, $nextDelegations );
$appFields = $oCase->loadCase( $caseId );
//Execute triggers after derivation
2012-10-09 13:29:25 -04:00
$aTriggers = $oCase->loadTriggers( $appdel['TAS_UID'], 'ASSIGN_TASK', - 2, 'AFTER' );
2012-10-09 13:29:25 -04:00
if (count( $aTriggers ) > 0) {
//$appFields['APP_DATA']['APPLICATION'] = $caseId;
2012-10-09 13:29:25 -04:00
//Set variables
$params = new stdClass();
$params->appData = $appFields["APP_DATA"];
if ($this->stored_system_variables) {
$params->option = "STORED SESSION";
2012-10-09 13:29:25 -04:00
$params->SID = $this->wsSessionId;
}
2012-10-09 13:29:25 -04:00
$appFields["APP_DATA"] = array_merge( $appFields["APP_DATA"], G::getSystemConstants( $params ) );
//PMScript
$oPMScript = new PMScript();
2012-10-09 13:29:25 -04:00
$oPMScript->setFields( $appFields['APP_DATA'] );
$varTriggers .= "<b>-= After Derivation =-</b><br/>";
foreach ($aTriggers as $aTrigger) {
$bExecute = true;
if ($aTrigger['ST_CONDITION'] !== '') {
2012-10-09 13:29:25 -04:00
$oPMScript->setScript( $aTrigger['ST_CONDITION'] );
$bExecute = $oPMScript->evaluate();
}
if ($bExecute) {
2012-10-09 13:29:25 -04:00
$oPMScript->setScript( $aTrigger['TRI_WEBBOT'] );
$oPMScript->execute();
2012-10-09 13:29:25 -04:00
$oTrigger = TriggersPeer::retrieveByPk( $aTrigger['TRI_UID'] );
$varTriggers .= "&nbsp;- " . nl2br( htmlentities( $oTrigger->getTriTitle(), ENT_QUOTES ) ) . "<br/>";
//$appFields = $oCase->loadCase($caseId);
$appFields['APP_DATA'] = $oPMScript->aFields;
//$appFields['APP_DATA']['APPLICATION'] = $caseId;
//$appFields = $oCase->loadCase($caseId);
unset($aFields['APP_STATUS']);
unset($aFields['APP_PROC_STATUS']);
unset($aFields['APP_PROC_CODE']);
unset($aFields['APP_PIN']);
2012-10-09 13:29:25 -04:00
$oCase->updateCase( $caseId, $appFields );
}
}
}
$sFromName = "";
if ($userId != "") {
$user = new Users();
$arrayUserData = $user->load($userId);
if (trim($arrayUserData["USR_EMAIL"]) == "") {
$arrayUserData["USR_EMAIL"] = "info@" . $_SERVER["HTTP_HOST"];
}
$sFromName = "\"" . $arrayUserData["USR_FIRSTNAME"] . " " . $arrayUserData["USR_LASTNAME"] . "\" <" . $arrayUserData["USR_EMAIL"] . ">";
}
2012-10-09 13:29:25 -04:00
$oCase->sendNotifications( $appdel['TAS_UID'], $nextDelegations, $appFields['APP_DATA'], $caseId, $delIndex, $sFromName );
//Save data - Start
//$appFields = $oCase->loadCase($caseId);
//$oCase->updateCase($caseId, $appFields);
//Save data - End
2012-10-09 13:29:25 -04:00
$oProcess = new Process();
2012-10-09 13:29:25 -04:00
$oProcessFieds = $oProcess->Load( $appFields['PRO_UID'] );
//here dubug mode in web entry
2012-10-09 13:29:25 -04:00
if (isset( $oProcessFieds['PRO_DEBUG'] ) && $oProcessFieds['PRO_DEBUG']) {
$result = new wsResponse( 0, $varResponse . "
<br><br><table width='100%' cellpadding='0' cellspacing='0'><tr><td class='FormTitle'>
2012-10-09 13:29:25 -04:00
" . G::LoadTranslation( 'ID_DEBUG_MESSAGE' ) . "</td></tr></table>" . $varTriggers );
} else {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 0, $varResponse . " --- " . $oProcessFieds['PRO_DEBUG'] );
}
$res = $result->getPayloadArray();
//now fill the array of AppDelegationPeer
2012-10-09 13:29:25 -04:00
$oCriteria = new Criteria( 'workflow' );
$oCriteria->addSelectColumn( AppDelegationPeer::DEL_INDEX );
$oCriteria->addSelectColumn( AppDelegationPeer::USR_UID );
$oCriteria->addSelectColumn( AppDelegationPeer::TAS_UID );
$oCriteria->addSelectColumn( AppDelegationPeer::DEL_THREAD );
$oCriteria->addSelectColumn( AppDelegationPeer::DEL_THREAD_STATUS );
$oCriteria->addSelectColumn( AppDelegationPeer::DEL_FINISH_DATE );
$oCriteria->add( AppDelegationPeer::APP_UID, $caseId );
$oCriteria->add( AppDelegationPeer::DEL_PREVIOUS, $delIndex );
$oCriteria->addAscendingOrderByColumn( AppDelegationPeer::DEL_INDEX );
$oDataset = AppDelegationPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$aCurrentUsers = array ();
while ($oDataset->next()) {
$aAppDel = $oDataset->getRow();
$oUser = new Users();
try {
2012-10-09 13:29:25 -04:00
$oUser->load( $aAppDel['USR_UID'] );
$uFields = $oUser->toArray( BasePeer::TYPE_FIELDNAME );
$currentUserName = $oUser->getUsrFirstname() . ' ' . $oUser->getUsrLastname();
} catch (Exception $e) {
$currentUserName = '';
}
$oTask = new Task();
try {
2012-10-09 13:29:25 -04:00
$uFields = $oTask->load( $aAppDel['TAS_UID'] );
$taskName = $uFields['TAS_TITLE'];
} catch (Exception $e) {
$taskName = '';
}
// execute events
$eventPro = $_SESSION["PROCESS"];
$eventApp = $caseId;
$eventInd = $aAppDel['DEL_INDEX'];
$eventTas = $aAppDel['TAS_UID'];
$oEvent = new Event();
2012-10-09 13:29:25 -04:00
$oEvent->createAppEvents( $eventPro, $eventApp, $eventInd, $eventTas );
// end events
2012-10-09 13:29:25 -04:00
$currentUser = new stdClass();
2012-10-09 13:29:25 -04:00
$currentUser->userId = $aAppDel['USR_UID'];
$currentUser->userName = $currentUserName;
$currentUser->taskId = $aAppDel['TAS_UID'];
$currentUser->taskName = $taskName;
$currentUser->delIndex = $aAppDel['DEL_INDEX'];
$currentUser->delThread = $aAppDel['DEL_THREAD'];
$currentUser->delThreadStatus = $aAppDel['DEL_THREAD_STATUS'];
$aCurrentUsers[] = $currentUser;
}
$res['routing'] = $aCurrentUsers;
$g->sessionVarRestore();
return $res;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, $e->getMessage() );
$g->sessionVarRestore();
return $result;
}
}
/**
2012-10-09 13:29:25 -04:00
* execute Trigger, executes a ProcessMaker trigger.
* Note that triggers which are tied to case derivation
* will executing automatically.
2012-10-09 13:29:25 -04:00
*
* @param string $userId
* @param string $caseId
* @param string $delIndex
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function executeTrigger ($userId, $caseId, $triggerIndex, $delIndex)
{
$g = new G();
try {
$g->sessionVarSave();
$_SESSION["APPLICATION"] = $caseId;
$_SESSION["INDEX"] = $delIndex;
$_SESSION["USER_LOGGED"] = $userId;
$oAppDel = new AppDelegation();
2012-10-09 13:29:25 -04:00
$appdel = $oAppDel->Load( $caseId, $delIndex );
2012-10-09 13:29:25 -04:00
if ($userId != $appdel['USR_UID']) {
$result = new wsResponse( 17, G::loadTranslation( 'ID_CASE_ASSIGNED_ANOTHER_USER' ) );
$g->sessionVarRestore();
return $result;
}
if ($appdel['DEL_FINISH_DATE'] != null) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 18, G::loadTranslation( 'ID_CASE_DELEGATION_ALREADY_CLOSED' ) );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
$oCriteria = new Criteria( 'workflow' );
$oCriteria->addSelectColumn( AppDelayPeer::APP_UID );
$oCriteria->addSelectColumn( AppDelayPeer::APP_DEL_INDEX );
2014-03-18 12:31:36 -04:00
$oCriteria->addSelectColumn( AppDelayPeer::APP_DISABLE_ACTION_USER );
$oCriteria->addSelectColumn( AppDelayPeer::APP_DISABLE_ACTION_DATE );
2012-10-09 13:29:25 -04:00
$oCriteria->add( AppDelayPeer::APP_TYPE, '' );
$oCriteria->add( $oCriteria->getNewCriterion( AppDelayPeer::APP_TYPE, 'PAUSE' )->addOr( $oCriteria->getNewCriterion( AppDelayPeer::APP_TYPE, 'CANCEL' ) ) );
$oCriteria->addAscendingOrderByColumn( AppDelayPeer::APP_ENABLE_ACTION_DATE );
$oDataset = AppDelayPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
$aRow = $oDataset->getRow();
2012-10-09 13:29:25 -04:00
if (is_array( $aRow )) {
if ($aRow['APP_DISABLE_ACTION_USER'] != 0 && $aRow['APP_DISABLE_ACTION_DATE'] != '') {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 19, G::loadTranslation( 'ID_CASE_IN_STATUS' ) . " " . $aRow['APP_TYPE'] );
$g->sessionVarRestore();
return $result;
}
}
//Load data
2012-10-09 13:29:25 -04:00
$oCase = new Cases();
$appFields = $oCase->loadCase( $caseId );
$appFields["APP_DATA"]["APPLICATION"] = $caseId;
2012-10-09 13:29:25 -04:00
if (! isset( $_SESSION["PROCESS"] )) {
$_SESSION["PROCESS"] = $appFields["PRO_UID"];
}
//executeTrigger
2012-10-09 13:29:25 -04:00
$aTriggers = array ();
$c = new Criteria();
2012-10-09 13:29:25 -04:00
$c->add( TriggersPeer::TRI_UID, $triggerIndex );
$rs = TriggersPeer::doSelectRS( $c );
$rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$rs->next();
$row = $rs->getRow();
2012-10-09 13:29:25 -04:00
if (is_array( $row ) && $row['TRI_TYPE'] == 'SCRIPT') {
$aTriggers[] = $row;
$oPMScript = new PMScript();
2012-10-09 13:29:25 -04:00
$oPMScript->setFields( $appFields['APP_DATA'] );
$oPMScript->setScript( $row['TRI_WEBBOT'] );
$oPMScript->execute();
//Save data - Start
$appFields['APP_DATA'] = $oPMScript->aFields;
unset($appFields['APP_STATUS']);
unset($appFields['APP_PROC_STATUS']);
unset($appFields['APP_PROC_CODE']);
unset($appFields['APP_PIN']);
//$appFields = $oCase->loadCase($caseId);
2012-10-09 13:29:25 -04:00
$oCase->updateCase( $caseId, $appFields );
//Save data - End
} else {
$data['TRIGGER_INDEX'] = $triggerIndex;
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, G::loadTranslation( 'ID_INVALID_TRIGGER', SYS_LANG, $data ) );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 0, G::loadTranslation( 'ID_EXECUTED' ) . ": " . trim( $row['TRI_WEBBOT'] ) );
//$result = new wsResponse(0, 'executed: ' . print_r($oPMScript, 1));
$g->sessionVarRestore();
2012-10-09 13:29:25 -04:00
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, $e->getMessage() );
$g->sessionVarRestore();
return $result;
}
}
/**
* task Case
2012-10-09 13:29:25 -04:00
*
* @param string sessionId : The session ID which is obtained when logging in
* @param string caseId : The case ID. The caseList() function can be used to find the ID number for cases
* @return $result returns the current task for a given case. Note that the logged-in user must have privileges
* to access the task
*/
2012-10-09 13:29:25 -04:00
public function taskCase ($caseId)
{
$result = array ();
try {
2012-10-09 13:29:25 -04:00
$oCriteria = new Criteria( 'workflow' );
$del = DBAdapter::getStringDelimiter();
2012-10-09 13:29:25 -04:00
$oCriteria->addSelectColumn( AppDelegationPeer::DEL_INDEX );
$oCriteria->addSelectColumn( AppDelegationPeer::TAS_UID );
2012-10-09 13:29:25 -04:00
$oCriteria->addAsColumn( 'TAS_TITLE', 'C1.CON_VALUE' );
$oCriteria->addAlias( "C1", 'CONTENT' );
$tasTitleConds = array ();
$tasTitleConds[] = array (AppDelegationPeer::TAS_UID,'C1.CON_ID');
$tasTitleConds[] = array ('C1.CON_CATEGORY',$del . 'TAS_TITLE' . $del);
$tasTitleConds[] = array ('C1.CON_LANG',$del . SYS_LANG . $del);
2012-10-09 13:29:25 -04:00
$oCriteria->addJoinMC( $tasTitleConds, Criteria::LEFT_JOIN );
$oCriteria->add( AppDelegationPeer::APP_UID, $caseId );
$oCriteria->add( AppDelegationPeer::DEL_THREAD_STATUS, 'OPEN' );
$oCriteria->add( AppDelegationPeer::DEL_FINISH_DATE, null, Criteria::ISNULL );
$oDataset = AppDelegationPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
$result[] = array (
'guid' => $aRow['TAS_UID'],
'name' => $aRow['TAS_TITLE'],
'delegate' => $aRow['DEL_INDEX']
2012-10-09 13:29:25 -04:00
);
$oDataset->next();
}
return $result;
} catch (Exception $e) {
$result[] = array ('guid' => $e->getMessage(),'name' => $e->getMessage(), 'delegate' => $e->getMessage() );
return $result;
}
}
/**
* process list verified
2012-10-09 13:29:25 -04:00
*
* @param string sessionId : The session ID which is obtained when logging in
* @param string userId :
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function processListVerified ($userId)
{
try {
$oCase = new Cases();
2012-10-09 13:29:25 -04:00
$rows = $oCase->getStartCases( $userId );
$result = array ();
foreach ($rows as $key => $val) {
if ($key != 0) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $val['pro_uid'],'name' => $val['value']
);
}
}
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $e->getMessage(),'name' => $e->getMessage()
);
return $result;
}
}
/**
* reassign Case
2012-10-09 13:29:25 -04:00
*
* @param string sessionId : The session ID (which was obtained during login)
* @param string caseId : The case ID (which can be obtained with the caseList() function)
* @param string delIndex : The delegation index number of the case (which can be obtained with the caseList()
* function).
* @param string userIdSource : The user who is currently assigned the case.
* @param string userIdTarget : The target user who will be newly assigned to the case.
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function reassignCase ($sessionId, $caseId, $delIndex, $userIdSource, $userIdTarget)
{
$g = new G();
try {
$g->sessionVarSave();
$_SESSION["APPLICATION"] = $caseId;
$_SESSION["INDEX"] = $delIndex;
$_SESSION["USER_LOGGED"] = $userIdSource;
if ($userIdTarget == $userIdSource) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 30, G::loadTranslation( 'ID_TARGET_ORIGIN_USER_SAME' ) );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
/**
* ****************( 1 )*****************
*/
$oCriteria = new Criteria( 'workflow' );
$oCriteria->add( UsersPeer::USR_STATUS, 'ACTIVE' );
$oCriteria->add( UsersPeer::USR_UID, $userIdSource );
$oDataset = UsersPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
$aRow = $oDataset->getRow();
2012-10-09 13:29:25 -04:00
if (! is_array( $aRow )) {
$result = new wsResponse( 31, G::loadTranslation( 'ID_INVALID_ORIGIN_USER' ) );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
/**
* ****************( 2 )*****************
*/
$oCase = new Cases();
2012-10-09 13:29:25 -04:00
$rows = $oCase->loadCase( $caseId );
2012-10-09 13:29:25 -04:00
if (! is_array( $aRow )) {
$result = new wsResponse( 32, G::loadTranslation( 'ID_CASE_NOT_OPEN' ) );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
/**
* ****************( 3 )*****************
*/
$oCriteria = new Criteria( 'workflow' );
$aConditions = array ();
// $aConditions[] = array(AppDelegationPeer::USR_UID, TaskUserPeer::USR_UID);
// $aConditions[] = array(AppDelegationPeer::TAS_UID, TaskUserPeer::TAS_UID);
// $oCriteria->addJoinMC($aConditions, Criteria::LEFT_JOIN);
//$oCriteria->addJoin(AppDelegationPeer::USR_UID, TaskUserPeer::USR_UID, Criteria::LEFT_JOIN);
2012-10-09 13:29:25 -04:00
$oCriteria->add( AppDelegationPeer::APP_UID, $caseId );
$oCriteria->add( AppDelegationPeer::USR_UID, $userIdSource );
$oCriteria->add( AppDelegationPeer::DEL_INDEX, $delIndex );
$oCriteria->add( AppDelegationPeer::DEL_FINISH_DATE, null, Criteria::ISNULL );
$oDataset = AppDelegationPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
$aRow = $oDataset->getRow();
2012-10-09 13:29:25 -04:00
if (! is_array( $aRow )) {
$result = new wsResponse( 33, G::loadTranslation( 'ID_INVALID_CASE_DELEGATION_INDEX' ) );
$g->sessionVarRestore();
return $result;
}
$tasUid = $aRow['TAS_UID'];
$derivation = new Derivation();
$userList = $derivation->getAllUsersFromAnyTask($tasUid, true);
2012-10-09 13:29:25 -04:00
if (! in_array( $userIdTarget, $userList )) {
$result = new wsResponse( 34, G::loadTranslation( 'ID_TARGET_USER_DOES_NOT_HAVE_RIGHTS' ) );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
/**
* ****************( 4 )*****************
*/
$oCriteria = new Criteria( 'workflow' );
$oCriteria->add( UsersPeer::USR_STATUS, 'ACTIVE' );
$oCriteria->add( UsersPeer::USR_UID, $userIdTarget );
$oDataset = UsersPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
$aRow = $oDataset->getRow();
2012-10-09 13:29:25 -04:00
if (! is_array( $aRow )) {
$result = new wsResponse( 35, G::loadTranslation( 'ID_TARGET_USER_DESTINATION_INVALID' ) );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
/**
* ****************( 5 )*****************
*/
$var = $oCase->reassignCase( $caseId, $delIndex, $userIdSource, $userIdTarget );
2012-10-09 13:29:25 -04:00
if (! $var) {
$result = new wsResponse( 36, G::loadTranslation( 'ID_CASE_COULD_NOT_REASSIGNED' ) );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 0, G::loadTranslation( 'ID_COMMAND_EXECUTED_SUCCESSFULLY' ) );
$g->sessionVarRestore();
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result[] = array ('guid' => $e->getMessage(),'name' => $e->getMessage()
);
$g->sessionVarRestore();
return $result;
}
}
/**
* get system information
2012-10-09 13:29:25 -04:00
*
* @param string sessionId : The session ID (which was obtained at login)
* @return $eturns information about the WAMP/LAMP stack, the workspace database, the IP number and version
* of ProcessMaker, and the IP number and version of web browser of the user
*/
2012-10-09 13:29:25 -04:00
public function systemInformation ()
{
try {
2012-10-09 13:29:25 -04:00
define( 'SKIP_RENDER_SYSTEM_INFORMATION', true );
require_once (PATH_METHODS . 'login' . PATH_SEP . 'dbInfo.php');
2012-10-09 13:29:25 -04:00
$result->status_code = 0;
$result->message = G::loadTranslation( 'ID_SUCESSFUL' );
$result->timestamp = date( 'Y-m-d H:i:s' );
G::LoadClass( "system" );
$result->version = System::getVersion();
$result->operatingSystem = $redhat;
$result->webServer = getenv( 'SERVER_SOFTWARE' );
$result->serverName = getenv( 'SERVER_NAME' );
$result->serverIp = $Fields['IP']; //lookup ($ip);
$result->phpVersion = phpversion();
$result->databaseVersion = $Fields['DATABASE'];
$result->databaseServerIp = $Fields['DATABASE_SERVER'];
$result->databaseName = $Fields['DATABASE_NAME'];
$result->availableDatabases = $Fields['AVAILABLE_DB'];
2012-10-09 13:29:25 -04:00
$result->userBrowser = $Fields['HTTP_USER_AGENT'];
$result->userIp = $Fields['IP'];
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, $e->getMessage() );
return $result;
}
}
/**
* import process fromLibrary: downloads and imports a process from the ProcessMaker library
2012-10-09 13:29:25 -04:00
*
* @param string sessionId : The session ID (which was obtained at login).
* @param string processId :
* @param string version :
* @param string importOption :
* @param string usernameLibrary : The username to obtain access to the ProcessMaker library.
* @param string passwordLibrary : The password to obtain access to the ProcessMaker library.
2012-10-09 13:29:25 -04:00
* @return $eturns will return an object
*/
2012-10-09 13:29:25 -04:00
public function getCaseNotes ($applicationID, $userUid = '')
{
try {
2012-10-09 13:29:25 -04:00
G::LoadClass( 'case' );
2012-10-09 13:29:25 -04:00
$result = new wsGetCaseNotesResponse( 0, G::loadTranslation( 'ID_SUCCESS' ), Cases::getCaseNotes( $applicationID, 'array', $userUid ) );
2012-10-09 13:29:25 -04:00
$var = array ();
foreach ($result->notes as $key => $value) {
2012-10-09 13:29:25 -04:00
$var2 = array ();
foreach ($value as $keys => $values) {
2012-10-09 13:29:25 -04:00
$field = strtolower( $keys );
$var2[$field] = $values;
}
$var[] = $var2;
}
$result->notes = $var;
return $result;
} catch (Exception $e) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, $e->getMessage() );
return $result;
}
}
/**
* Delete case
2012-10-09 13:29:25 -04:00
*
* @param string caseUid : ID of the case.
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function deleteCase ($caseUid)
{
$g = new G();
try {
$g->sessionVarSave();
$_SESSION["APPLICATION"] = $caseUid;
2012-10-09 13:29:25 -04:00
if (empty( $caseUid )) {
$result = new wsResponse( 100, G::LoadTranslation( "ID_REQUIRED_FIELD" ) . " caseUid" );
$g->sessionVarRestore();
return $result;
}
$case = new Cases();
2012-10-09 13:29:25 -04:00
$case->removeCase( $caseUid );
//Response
2012-10-09 13:29:25 -04:00
$res = new wsResponse( 0, G::LoadTranslation( "ID_COMMAND_EXECUTED_SUCCESSFULLY" ) );
2012-10-09 13:29:25 -04:00
$result = array ("status_code" => $res->status_code,"message" => $res->message,"timestamp" => $res->timestamp
);
$g->sessionVarRestore();
return $result;
} catch (Exception $e) {
$result = new wsResponse(100, $e->getMessage());
$g->sessionVarRestore();
return $result;
}
}
/**
* Cancel case
2012-10-09 13:29:25 -04:00
*
* @param string caseUid : ID of the case.
* @param int delIndex : Delegation index of the case.
* @param string userUid : The unique ID of the user who will cancel the case.
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function cancelCase ($caseUid, $delIndex, $userUid)
{
$g = new G();
try {
$g->sessionVarSave();
$_SESSION["APPLICATION"] = $caseUid;
$_SESSION["INDEX"] = $delIndex;
$_SESSION["USER_LOGGED"] = $userUid;
2012-10-09 13:29:25 -04:00
if (empty( $caseUid )) {
$result = new wsResponse( 100, G::LoadTranslation( "ID_REQUIRED_FIELD" ) . " caseUid" );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
if (empty( $delIndex )) {
$result = new wsResponse( 100, G::LoadTranslation( "ID_REQUIRED_FIELD" ) . " delIndex" );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
if (empty( $userUid )) {
$result = new wsResponse( 100, G::LoadTranslation( "ID_REQUIRED_FIELD" ) . " userUid" );
$g->sessionVarRestore();
return $result;
}
$case = new Cases();
2012-10-09 13:29:25 -04:00
$case->cancelCase( $caseUid, $delIndex, $userUid );
//Response
2012-10-09 13:29:25 -04:00
$res = new wsResponse( 0, G::LoadTranslation( "ID_COMMAND_EXECUTED_SUCCESSFULLY" ) );
2012-10-09 13:29:25 -04:00
$result = array ("status_code" => $res->status_code,"message" => $res->message,"timestamp" => $res->timestamp
);
$g->sessionVarRestore();
return $result;
} catch (Exception $e) {
$result = new wsResponse(100, $e->getMessage());
$g->sessionVarRestore();
return $result;
}
}
/**
* Pause case
2012-10-09 13:29:25 -04:00
*
* @param string caseUid : ID of the case.
* @param int delIndex : Delegation index of the case.
* @param string userUid : The unique ID of the user who will pause the case.
* @param string unpauseDate : Optional parameter. The date in the format "yyyy-mm-dd" indicating when to unpause
2012-10-09 13:29:25 -04:00
* the case.
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function pauseCase ($caseUid, $delIndex, $userUid, $unpauseDate = null)
{
$g = new G();
try {
$g->sessionVarSave();
$_SESSION["APPLICATION"] = $caseUid;
$_SESSION["INDEX"] = $delIndex;
$_SESSION["USER_LOGGED"] = $userUid;
2012-10-09 13:29:25 -04:00
if (empty( $caseUid )) {
$result = new wsResponse( 100, G::LoadTranslation( "ID_REQUIRED_FIELD" ) . " caseUid" );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
if (empty( $delIndex )) {
$result = new wsResponse( 100, G::LoadTranslation( "ID_REQUIRED_FIELD" ) . " delIndex" );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
if (empty( $userUid )) {
$result = new wsResponse( 100, G::LoadTranslation( "ID_REQUIRED_FIELD" ) . " userUid" );
$g->sessionVarRestore();
return $result;
}
if( strlen($unpauseDate) >=10 ){
if (! preg_match( "/^\d{4}-\d{2}-\d{2}| \d{2}:\d{2}:\d{2}$/", $unpauseDate )) {
2012-10-09 13:29:25 -04:00
$result = new wsResponse( 100, G::LoadTranslation( "ID_INVALID_DATA" ) . " $unpauseDate" );
$g->sessionVarRestore();
return $result;
}
} else {
$unpauseDate = null;
}
$case = new Cases();
2012-10-09 13:29:25 -04:00
$case->pauseCase( $caseUid, $delIndex, $userUid, $unpauseDate );
//Response
2012-10-09 13:29:25 -04:00
$res = new wsResponse( 0, G::LoadTranslation( "ID_COMMAND_EXECUTED_SUCCESSFULLY" ) );
2012-10-09 13:29:25 -04:00
$result = array ("status_code" => $res->status_code,"message" => $res->message,"timestamp" => $res->timestamp
);
$g->sessionVarRestore();
return $result;
} catch (Exception $e) {
$result = new wsResponse(100, $e->getMessage());
$g->sessionVarRestore();
return $result;
}
}
/**
* Unpause case
2012-10-09 13:29:25 -04:00
*
* @param string caseUid : ID of the case.
* @param int delIndex : Delegation index of the case.
* @param string userUid : The unique ID of the user who will unpause the case.
* @return $result will return an object
*/
2012-10-09 13:29:25 -04:00
public function unpauseCase ($caseUid, $delIndex, $userUid)
{
$g = new G();
try {
$g->sessionVarSave();
$_SESSION["APPLICATION"] = $caseUid;
$_SESSION["INDEX"] = $delIndex;
$_SESSION["USER_LOGGED"] = $userUid;
2012-10-09 13:29:25 -04:00
if (empty( $caseUid )) {
$result = new wsResponse( 100, G::LoadTranslation( "ID_REQUIRED_FIELD" ) . " caseUid" );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
if (empty( $delIndex )) {
$result = new wsResponse( 100, G::LoadTranslation( "ID_REQUIRED_FIELD" ) . " delIndex" );
$g->sessionVarRestore();
return $result;
}
2012-10-09 13:29:25 -04:00
if (empty( $userUid )) {
$result = new wsResponse( 100, G::LoadTranslation( "ID_REQUIRED_FIELD" ) . " userUid" );
$g->sessionVarRestore();
return $result;
}
$case = new Cases();
2012-10-09 13:29:25 -04:00
$case->unpauseCase( $caseUid, $delIndex, $userUid );
//Response
2012-10-09 13:29:25 -04:00
$res = new wsResponse( 0, G::LoadTranslation( "ID_COMMAND_EXECUTED_SUCCESSFULLY" ) );
2012-10-09 13:29:25 -04:00
$result = array ("status_code" => $res->status_code,"message" => $res->message,"timestamp" => $res->timestamp
);
$g->sessionVarRestore();
return $result;
} catch (Exception $e) {
$result = new wsResponse(100, $e->getMessage());
$g->sessionVarRestore();
return $result;
}
}
/**
* Add case note
*
* @param string caseUid : ID of the case.
* @param string processUid : ID of the process.
* @param string taskUid : ID of the task.
* @param string userUid : The unique ID of the user who will add note case.
* @param string note : Note of the case.
* @param int sendMail : Optional parameter. If set to 1, will send an email to all participants in the case.
* @return $result will return an object
*/
public function addCaseNote($caseUid, $processUid, $taskUid, $userUid, $note, $sendMail = 1)
{
try {
if (empty($caseUid)) {
$result = new wsResponse(100, G::LoadTranslation("ID_REQUIRED_FIELD") . " caseUid");
return $result;
}
if (empty($processUid)) {
$result = new wsResponse(100, G::LoadTranslation("ID_REQUIRED_FIELD") . " processUid");
return $result;
}
if (empty($taskUid)) {
$result = new wsResponse(100, G::LoadTranslation("ID_REQUIRED_FIELD") . " taskUid");
return $result;
}
if (empty($userUid)) {
$result = new wsResponse(100, G::LoadTranslation("ID_REQUIRED_FIELD") . " userUid");
return $result;
}
if (empty($note)) {
$result = new wsResponse(100, G::LoadTranslation("ID_REQUIRED_FIELD") . " note");
return $result;
}
$case = new Cases();
$respView = $case->getAllObjectsFrom($processUid, $caseUid, $taskUid, $userUid, "VIEW");
$respBlock = $case->getAllObjectsFrom($processUid, $caseUid, $taskUid, $userUid, "BLOCK");
if ($respView["CASES_NOTES"] == 0 && $respBlock["CASES_NOTES"] == 0) {
$result = new wsResponse(100, G::LoadTranslation("ID_CASES_NOTES_NO_PERMISSIONS"));
return $result;
}
//Add note case
$appNote = new AppNotes();
$response = $appNote->addCaseNote($caseUid, $userUid, $note, $sendMail);
//Response
$result = new wsResponse(0, G::LoadTranslation("ID_COMMAND_EXECUTED_SUCCESSFULLY"));
return $result;
} catch (Exception $e) {
$result = new wsResponse(100, $e->getMessage());
return $result;
}
}
/**
* ClaimCase
*
* @param string $userId
* @param string $guid
* @param string $delIndex
* @return $result will return an object
*/
public function claimCase($userId, $guid, $delIndex)
{
try {
G::LoadClass('case');
$oCase = new Cases();
$oCase->loadCase($guid);
$oCase->setCatchUser($guid, $delIndex, $userId);
$result = new wsResponse(0, G::LoadTranslation("ID_COMMAND_EXECUTED_SUCCESSFULLY"));
return $result;
} catch (Exception $e) {
$result = new wsResponse(100, $e->getMessage());
return $result;
}
}
}