fernando/luos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
721a87f6c04dfae3964204234ab1e45e36ab7bff
luos/workflow/engine/classes/class.wsBase.php

2081 lines
74 KiB
PHP
Raw Normal View History

initial commit from rev. 632
2010-12-02 23:34:41 +00:00
<?php
/**
* class.wsBase.php
Changes done for PhpDoc
2011-02-01 12:49:40 +00:00
* @package workflow.engine.classes
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
*
* ProcessMaker Open Source Edition
Changes done for PhpDoc
2011-02-01 12:49:40 +00:00
* Copyright (C) 2004 - 2011 Colosa Inc.
initial commit from rev. 632
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
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
* For more information, contact Colosa Inc, 2566 Le Jeune Rd.,
* Coral Gables, FL, 33134, USA, or email info@colosa.com.
*/
// * It works with the table CONFIGURATION in a WF dataBase
require_once ( "classes/model/Application.php" );
require_once ( "classes/model/AppDelegation.php" );
require_once ( "classes/model/AppDocument.php" );
require_once ( "classes/model/AppDelay.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" );
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');
/**
* Copyright (C) 2009 COLOSA
* License: LGPL, see LICENSE
Changes done for PhpDoc
2011-02-01 12:49:40 +00:00
* 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
* @package workflow.engine.classes
initial commit from rev. 632
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
function __construct($params=NULL) {
$this->stored_system_variables = FALSE;
if( $params != NULL ){
$this->stored_system_variables = isset($params->stored_system_variables)? $params->stored_system_variables: FALSE;
$this->wsSessionId = isset($params->wsSessionId)? $params->wsSessionId: '';
}
}
/*
* function to start a web services session in ProcessMaker
* @param string $userid
* @param string $password
* @return $wsResponse will return an object
*/
public function login( $userid, $password ) {
global $RBAC;
try {
$uid = $RBAC->VerifyLogin( $userid , $password);
switch ($uid) {
case -1: //The user not exists
$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;
case -3: //The user is inactive
$wsResponse = new wsResponse (5, G::loadTranslation ('ID_USER_INACTIVE'));
case -4: //The Due date is finished
$wsResponse = new wsResponse (5, G::loadTranslation ('ID_USER_INACTIVE'));
break;
}
if ($uid < 0 ) {
throw ( new Exception ( serialize ( $wsResponse ) ));
}
// check access to PM
$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
$wsResponse = new wsResponse (2, G::loadTranslation ('ID_USER_HAVENT_RIGHTS_SYSTEM'));
throw ( new Exception ( serialize ( $wsResponse ) ));
}
$sessionId = G::generateUniqueID();
$wsResponse = new wsResponse ('0', $sessionId );
$session = new Session ();
$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
return $wsResponse;
}
catch ( Exception $e ) {
$wsResponse = unserialize ( $e->getMessage() );
return $wsResponse;
}
}
/*
* get all groups
* @param none
* @return $result will return an object
*/
public function processList() {
try {
$result = array();
$oCriteria = new Criteria('workflow');
//$oCriteria->add(ProcessPeer::PRO_STATUS , 'ACTIVE' );
$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();
$arrayProcess = $oProcess->Load( $aRow['PRO_UID'] );
$result[] = array ( 'guid' => $aRow['PRO_UID'], 'name' => $arrayProcess['PRO_TITLE'] );
$oDataset->next();
}
return $result;
}
catch ( Exception $e ) {
$result[] = array ( 'guid' => $e->getMessage(), 'name' => $e->getMessage() );
return $result;
}
}
/*
* get all roles, to see all roles
* @param none
* @return $result will return an object
*/
public function roleList( ) {
try {
$result = array();
$RBAC =& RBAC::getSingleton();
$RBAC->initRBAC();
$oCriteria = $RBAC->listAllRoles ();
$oDataset = GulliverBasePeer::doSelectRs ( $oCriteria);;
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
$result[] = array ( 'guid' => $aRow['ROL_UID'], 'name' => $aRow['ROL_CODE'] );
$oDataset->next();
}
return $result;
}
catch ( Exception $e ) {
$result[] = array ( 'guid' => $e->getMessage(), 'name' => $e->getMessage() );
return $result;
}
}
/*
* get all groups
* @param none
* @return $result will return an object
*/
public function groupList() {
try {
$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();
$arrayGroupwf = $oGroupwf->Load( $aRow['GRP_UID'] );
$result[] = array ( 'guid' => $aRow['GRP_UID'], 'name' => $arrayGroupwf['GRP_TITLE'] );
$oDataset->next();
}
return $result;
}
catch ( Exception $e ) {
$result[] = array ( 'guid' => $e->getMessage(), 'name' => $e->getMessage() );
return $result;
}
}
/*
* get all department
* @param none
* @return $result will return an object
*/
public function departmentList() {
try {
$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();
$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();
$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 ) {
$result[] = array ( 'guid' => $e->getMessage(), 'name' => $e->getMessage() );
return $result;
}
}
/*
* Get case list
* @param string $userId
* @return $result will return an object
*/
public function caseList( $userId ) {
try {
$result = array();
$oCriteria = new Criteria('workflow');
$del = DBAdapter::getStringDelimiter();
$oCriteria->addSelectColumn(ApplicationPeer::APP_UID);
$oCriteria->addSelectColumn(ApplicationPeer::APP_NUMBER);
$oCriteria->addSelectColumn(ApplicationPeer::APP_STATUS);
$oCriteria->addSelectColumn(AppDelegationPeer::DEL_INDEX);
$oCriteria->addAsColumn('CASE_TITLE', 'C1.CON_VALUE' );
$oCriteria->addAlias("C1", 'CONTENT');
$caseTitleConds = array();
$caseTitleConds[] = array( ApplicationPeer::APP_UID , 'C1.CON_ID' );
$caseTitleConds[] = array( 'C1.CON_CATEGORY' , $del . 'APP_TITLE' . $del );
$caseTitleConds[] = array( 'C1.CON_LANG' , $del . SYS_LANG . $del );
$oCriteria->addJoinMC($caseTitleConds , Criteria::LEFT_JOIN);
$oCriteria->addJoin(ApplicationPeer::APP_UID, AppDelegationPeer::APP_UID, Criteria::LEFT_JOIN);
$oCriteria->add(ApplicationPeer::APP_STATUS , array('TO_DO','DRAFT'), Criteria::IN);
$oCriteria->add(AppDelegationPeer::USR_UID, $userId );
$oCriteria->add(AppDelegationPeer::DEL_FINISH_DATE, null, Criteria::ISNULL);
$oCriteria->addDescendingOrderByColumn(ApplicationPeer::APP_NUMBER);
$oDataset = ApplicationPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
//$result[] = array ( 'guid' => $aRow['APP_UID'], 'name' => $aRow['CASE_TITLE'], 'status' => $aRow['APP_STATUS'], 'delIndex' => $aRow['DEL_INDEX'] );
$result[] = array ( 'guid' => $aRow['APP_UID'], 'name' => $aRow['APP_NUMBER'], 'status' => $aRow['APP_STATUS'], 'delIndex' => $aRow['DEL_INDEX'] );
$oDataset->next();
}
return $result;
}
catch ( Exception $e ) {
$result[] = array ( 'guid' => $e->getMessage(), 'name' => $e->getMessage(), 'status' => $e->getMessage() , 'status' => $e->getMessage() );
return $result;
}
}
/*
* get all groups
* @param none
* @return $result will return an object
*/
public function userList( ) {
try {
$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'] );
$result[] = array ( 'guid' => $aRow['USR_UID'], 'name' => $aRow['USR_USERNAME'] );
$oDataset->next();
}
return $result;
}
catch ( Exception $e ) {
$result[] = array ( 'guid' => $e->getMessage(), 'name' => $e->getMessage() );
return $result;
}
}
/*
* get list of all the available triggers in a workspace
* @param none
* @return $result will return an object
*/
public function triggerList( ) {
try {
$del = DBAdapter::getStringDelimiter();
$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' );
$oDataset = TriggersPeer::doSelectRS($oCriteria);
$oDataset ->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset ->next();
while ($aRow = $oDataset->getRow()) {
$result[] = array ( 'guid' => $aRow['TRI_UID'], 'name' => $aRow['TITLE'], 'processId' => $aRow['PRO_UID'] );
$oDataset->next();
}
return $result;
}
catch ( Exception $e ) {
$result[] = array ( 'guid' => $e->getMessage(), 'name' => $e->getMessage() );
return $result;
}
}
/*
* get list of the uploaded documents for a given case
* @param string $sApplicationUID
* @param string $sUserUID
* @return $result
*/
public function inputDocumentList( $sApplicationUID, $sUserUID ) {
try {
$oCase = new Cases();
$fields = $oCase->loadCase($sApplicationUID);
$sProcessUID = $fields['PRO_UID'];
$sTaskUID = '';
$oCriteria = $oCase->getAllUploadedDocumentsCriteria($sProcessUID, $sApplicationUID, $sTaskUID, $sUserUID);
$result = array();
global $_DBArray;
foreach ( $_DBArray['inputDocuments'] as $key => $row ) {
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'];
$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 ) {
$result[] = array ( 'guid' => $e->getMessage() );
return $result;
}
}
/*
* input document process list
* @param string $sProcessUID
* @return $result will return an object
*/
public function inputDocumentProcessList( $sProcessUID ) {
try {
global $_DBArray;
$_DBArray = (isset ( $_SESSION ['_DBArray'] ) ? $_SESSION ['_DBArray'] : '');
$oMap = new processMap();
$oCriteria = $oMap->getInputDocumentsCriteria($sProcessUID);
$oDataset = InputDocumentPeer::doSelectRS ( $oCriteria );
$oDataset->setFetchmode ( ResultSet::FETCHMODE_ASSOC );
$oDataset->next ();
$result = array();
//$result[] = array('guid'=>'char','name'=>'name','description'=>'description'); //not necesary for SOAP message
while ( $aRow = $oDataset->getRow() ) {
if ( $aRow['INP_DOC_TITLE'] == NULL){// There is no transaltion for this Document name, try to get/regenerate the label
$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'];
}
$docrow = array();
$docrow['guid'] = $aRow['INP_DOC_UID'];
$docrow['name'] = $aRow['INP_DOC_TITLE'];
$docrow['description'] = $aRow['INP_DOC_DESCRIPTION'];
$result[] = $docrow;
$oDataset->next ();
}
//$_DBArray['inputDocArray'] = $inputDocArray;
return $result;
}
catch ( Exception $e ) {
$result[] = array ( 'guid' => $e->getMessage() );
return $result;
}
}
/*
* output document list
* @param string $sApplicationUID
* @param string $sUserUID
* @return $result will return an object
*/
public function outputDocumentList( $sApplicationUID, $sUserUID ) {
try {
$oCase = new Cases();
$fields = $oCase->loadCase($sApplicationUID);
$sProcessUID = $fields['PRO_UID'];
$sTaskUID = '';
$oCriteria = $oCase->getAllGeneratedDocumentsCriteria($sProcessUID, $sApplicationUID, $sTaskUID, $sUserUID);
$result = array();
global $_DBArray;
foreach ( $_DBArray['outputDocuments'] as $key => $row ) {
if ( isset($row['DOC_VERSION']) ) {
$docrow = array();
$docrow['guid'] = $row['APP_DOC_UID'];
$docrow['filename'] = $row['DOWNLOAD_FILE'];
$docrow['docId'] = $row['DOC_UID'];
$docrow['version'] = $row['DOC_VERSION'];
$docrow['createDate'] = $row['CREATE_DATE'];
$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 ) {
$result[] = array ( 'guid' => $e->getMessage() );
return $result;
}
}
/*
* remove document
* @param string $appDocUid
* @return $result will return an object
*/
public function removeDocument($appDocUid) {
try {
$oAppDocument = new AppDocument();
$oAppDocument->remove( $appDocUid, 1 ); //always send version 1
$result = new wsResponse (0, " $appDocUid");
return $result;
}
catch ( Exception $e ) {
$result = new wsResponse (100, $e->getMessage());
return $result;
}
}
/*
* get task list
* @param string $userId
* @return $result will return an object
*/
public function taskList( $userId ) {
try {
g::loadClass('groups');
$oGroup = new Groups();
$aGroups = $oGroup->getActiveGroupsForAnUser($userId);
$result = array();
$oCriteria = new Criteria('workflow');
$del = DBAdapter::getStringDelimiter();
$oCriteria->addSelectColumn(TaskPeer::TAS_UID);
$oCriteria->setDistinct();
$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()) {
$result[] = array ( 'guid' => $aRow['TAS_UID'], 'name' => $aRow['TAS_TITLE'] );
$oDataset->next();
}
return $result;
}
catch ( Exception $e ) {
$result[] = array ( 'guid' => $e->getMessage(), 'name' => $e->getMessage() );
return $result;
}
}
/*
* send message
* @param string $caseId
* @param string $sFrom
* @param string $sTo
* @param string $sCc
* @param string $sBcc
* @param string $sSubject
* @param string $sTemplate
* @param $appFields = null
* @return $result will return an object
*/
public function sendMessage($caseId, $sFrom, $sTo, $sCc, $sBcc, $sSubject, $sTemplate, $appFields = null ) {
try {
$aSetup = getEmailConfiguration();
$oSpool = new spoolRun();
$oSpool->setConfig(array(
'MESS_ENGINE' => $aSetup['MESS_ENGINE'],
'MESS_SERVER' => $aSetup['MESS_SERVER'],
'MESS_PORT' => $aSetup['MESS_PORT'],
'MESS_ACCOUNT' => $aSetup['MESS_ACCOUNT'],
'MESS_PASSWORD' => $aSetup['MESS_PASSWORD'],
'SMTPAuth' => $aSetup['MESS_RAUTH']
));
$oCase = new Cases();
$oldFields = $oCase->loadCase( $caseId );
$pathEmail = PATH_DATA_SITE . 'mailTemplates' . PATH_SEP . $oldFields['PRO_UID'] . PATH_SEP;
$fileTemplate = $pathEmail . $sTemplate;
G::mk_dir( $pathEmail, 0777,true);
if ( ! file_exists ( $fileTemplate ) ) {
$result = new wsResponse (28, "Template file '$fileTemplate' does not exist." );
return $result;
}
if ( $appFields == null ) {
$Fields = $oldFields['APP_DATA'];
} else {
$Fields = $appFields;
}
$templateContents = file_get_contents ( $fileTemplate );
//$sContent = G::unhtmlentities($sContent);
$iAux = 0;
$iOcurrences = preg_match_all('/\@(?:([\>])([a-zA-Z\_]\w*)|([a-zA-Z\_][\w\-\>\:]*)\(((?:[^\\\\\)]*(?:[\\\\][\w\W])?)*)\))((?:\s*\[[\'"]?\w+[\'"]?\])+)?/', $templateContents, $aMatch, PREG_PATTERN_ORDER | PREG_OFFSET_CAPTURE);
if ($iOcurrences) {
for($i = 0; $i < $iOcurrences; $i++) {
preg_match_all('/@>' . $aMatch[2][$i][0] . '([\w\W]*)' . '@<' . $aMatch[2][$i][0] . '/', $templateContents, $aMatch2, PREG_PATTERN_ORDER | PREG_OFFSET_CAPTURE);
$sGridName = $aMatch[2][$i][0];
$sStringToRepeat = $aMatch2[1][0][0];
if (isset($Fields[$sGridName])) {
if (is_array($Fields[$sGridName])) {
$sAux = '';
foreach ($Fields[$sGridName] as $aRow) {
$sAux .= G::replaceDataField($sStringToRepeat, $aRow);
}
}
}
$templateContents = str_replace('@>' . $sGridName . $sStringToRepeat . '@<' . $sGridName, $sAux, $templateContents);
}
}
$sBody = G::replaceDataField( $templateContents, $Fields);
if ($sFrom != '') {
$sFrom = $sFrom . ' <' . $aSetup['MESS_ACCOUNT'] . '>';
}
else {
$sFrom = $aSetup['MESS_ACCOUNT'];
}
$messageArray = array(
'msg_uid' => '',
'app_uid' => $caseId,
'del_index' => 0,
'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' => '',
'app_msg_template' => '',
'app_msg_status' => 'pending'
);
$oSpool->create( $messageArray );
$oSpool->sendMail();
if ( $oSpool->status == 'sent' )
$result = new wsResponse (0, "message sent : $sTo" );
else
$result = new wsResponse (29, $oSpool->status . ' ' . $oSpool->error . print_r ($aSetup ,1 ) );
return $result;
}
catch ( Exception $e ) {
$result = new wsResponse (100, $e->getMessage());
return $result;
}
}
/*
* get case information
* @param string $caseId
* @param string $iDelIndex
* @return $result will return an object
*/
public function getCaseInfo($caseId, $iDelIndex ) {
try {
$oCase = new Cases();
$aRows = $oCase->loadCase( $caseId, $iDelIndex );
if ( count($aRows) == 0 ) {
$result = new wsResponse (16, "Case $caseNumber does not exist" );
return $result;
}
$oProcess = new Process();
try {
$uFields = $oProcess->load($aRows['PRO_UID']);
$processName = $uFields['PRO_TITLE'];
}
catch ( Exception $e ) {
$processName = '';
}
$result = new wsResponse (0, "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'];
$result->processId = $aRows['PRO_UID'];
$result->processName = $processName;
$result->createDate = $aRows['CREATE_DATE'];
//now fill the array of AppDelegationPeer
$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_FINISH_DATE, null, Criteria::ISNULL );
$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 {
$oUser->load($aAppDel['USR_UID']);
$uFields = $oUser->toArray(BasePeer::TYPE_FIELDNAME);
$currentUserName = $oUser->getUsrFirstname() . ' ' . $oUser->getUsrLastname();
}
catch ( Exception $e ) {
$currentUserName = '';
}
$oTask = new Task();
try {
$uFields = $oTask->load($aAppDel['TAS_UID']);
$taskName = $uFields['TAS_TITLE'];
}
catch ( Exception $e ) {
$taskName = '';
}
$currentUser = new stdClass();
$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;
}
$result->currentUsers = $aCurrentUsers;
return $result;
}
catch ( Exception $e ) {
$result = new wsResponse (100, $e->getMessage());
return $result;
}
}
/*
* creates a new user
* @param string sessionId : The session ID
* @param string userId : The username for the new user.
* @param string firstname : The user's first name.
* @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).
* @return $result will return an object
*/
public function createUser( $userId, $firstname, $lastname, $email, $role, $password) {
try {
if($userId=='')
{ $result = new wsCreateUserResponse (25, "Username is required");
return $result;
}
if($password=='')
{ $result = new wsCreateUserResponse (26, "Password is required");
return $result;
}
if($firstname=='')
{ $result = new wsCreateUserResponse (27, "First Name is required");
return $result;
}
Bug 5837 A limit of 20 chars for the administrator password has been implemented in the current, new workspace interface and a message clarifying the limit too. Also in the web service create user method, a new response has been added in order to prevent the creation of users with passwords above the 20 characters.
2011-02-03 18:12:43 +00:00
if(strlen($password)>20)
{ $result = new wsCreateUserResponse (28, "Password surprases the maximun length allowed", '');
return $result;
}
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
global $RBAC;
$RBAC->initRBAC();
$user = $RBAC->verifyUser($userId);
if ( $user == 1){
$result = new wsCreateUserResponse (7, "Username '$userId' already exists", '' ) ;
return $result;
}
$rol=$RBAC->loadById($role);
if ( is_array($rol) ){
$strRole = $rol['ROL_CODE'];
}
else {
$very_rol = $RBAC->verifyByCode($role);
if ( $very_rol==0 ){
$result = new wsResponse (6, "Invalid role '$role'");
return $result;
}
$strRole = $role;
}
$aData['USR_USERNAME'] = $userId;
$aData['USR_PASSWORD'] = md5($password);
$aData['USR_FIRSTNAME'] = $firstname;
$aData['USR_LASTNAME'] = $lastname;
$aData['USR_EMAIL'] = $email;
$aData['USR_DUE_DATE'] = mktime(0, 0, 0, date("m"), date("d"), date("Y")+1);
$aData['USR_CREATE_DATE'] = date('Y-m-d H:i:s');
$aData['USR_UPDATE_DATE'] = date('Y-m-d H:i:s');
$aData['USR_STATUS'] = 1;
$sUserUID = $RBAC->createUser($aData, $strRole );
$aData['USR_UID'] = $sUserUID;
$aData['USR_PASSWORD'] = md5($sUserUID);
$aData['USR_STATUS'] = 'ACTIVE';
al momento de crear un usuario por webservices los campos no requeridos se crean vacios
2011-02-04 14:46:27 +00:00
$aData['USR_COUNTRY'] = '';
$aData['USR_CITY'] = '';
$aData['USR_LOCATION'] = '';
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
$aData['USR_ADDRESS'] = '';
$aData['USR_PHONE'] = '';
al momento de crear un usuario por webservices los campos no requeridos se crean vacios
2011-02-04 14:46:27 +00:00
$aData['USR_ZIP_CODE'] = '';
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
$aData['USR_POSITION'] = '';
$aData['USR_RESUME'] = '';
$aData['USR_BIRTHDAY'] = date('Y-m-d');
$aData['USR_ROLE'] = $strRole ;
$oUser = new Users();
$oUser->create($aData);
$res = new wsResponse (0, "User $firstname $lastname [$userId] created successfully");
$result = array('status_code' => $res->status_code ,
'message' => $res->message,
'userUID' => $sUserUID,
'timestamp' => $res->timestamp );
return $result;
}
catch ( Exception $e ) {
$result = wsCreateUserResponse (100 , $e->getMessage(), '' );
return $result;
}
}
/*
* create Group
* @param string $groupName
* @return $result will return an object
*/
public function createGroup( $groupName) {
try {
if( trim($groupName) == '' ) {
$result = new wsCreateGroupResponse (25, "Group name is required", '');
return $result;
}
$group = new Groupwf();
$grpRow['GRP_TITLE'] = $groupName;
$groupId = $group->create( $grpRow );
$result = new wsCreateGroupResponse (0, "Group $groupName created successfully", $groupId);
return $result;
}
catch ( Exception $e ) {
$result = wsCreateGroupResponse (100 , $e->getMessage(), '' );
return $result;
}
}
/*
* Create New Department link on the top section of the left pane allows you to create a root-level department.
* @param string $departmentName
* @param string $parentUID
* @return $result will return an object
*/
public function createDepartment( $departmentName, $parentUID ) {
try {
if( trim($departmentName) == '' ) {
$result = new wsCreateDepartmentResponse (25, "Department name is required", '');
return $result;
}
$department = new department();
$row['DEP_TITLE'] = $departmentName;
$row['DEP_PARENT'] = $parentUID;
$departmentId = $department->create( $row );
$result = new wsCreateDepartmentResponse (0, "$departmentName, $parentUID Department $departmentName created successfully", $departmentId);
return $result;
}
catch ( Exception $e ) {
$result = wsCreateDepartmentResponse (100 , $e->getMessage(), '' );
return $result;
}
}
add remove users from group webservices
2011-02-02 21:29:47 +00:00
/*
* remove user from group
* @param string $appDocUid
* @return $result will return an object
*/
public function removeUserFromGroup($userId, $groupId) {
try {
G::LoadClass('groups');
global $RBAC;
$RBAC->initRBAC();
$user=$RBAC->verifyUserId($userId);
if($user==0){
$result = new wsResponse (3, "User not registered in the system");
return $result;
}
$groups = new Groups;
$very_group = $groups->verifyGroup( $groupId );
if ( $very_group==0 ) {
$result = new wsResponse (9, "Group not registered in the system");
return $result;
}
$very_user = $groups->verifyUsertoGroup( $groupId, $userId);
if($very_user==1){
$oGroup = new Groups();
$oGroup->removeUserOfGroup($groupId, $userId);
$result = new wsResponse (0, "command executed successfuly");
return $result;
}
//$oGroup->removeUserOfGroup($_POST['GRP_UID'], $_POST['USR_UID']);
$result = new wsResponse (8, "User not registered in the group");
return $result;
}
catch ( Exception $e ) {
$result = new wsResponse (100, $e->getMessage());
return $result;
}
//G::LoadClass('groups');
// $oGroup = new Groups();
// $oGroup->removeUserOfGroup($_POST['GRP_UID'], $_POST['USR_UID']);
}
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
/*
* assigns a user to a group
* @param string $userId
* @param string $groupId
* @return $result will return an object
*/
public function assignUserToGroup( $userId, $groupId) {
try {
global $RBAC;
$RBAC->initRBAC();
$user=$RBAC->verifyUserId($userId);
if($user==0){
$result = new wsResponse (3, "User not registered in the system");
return $result;
}
$groups = new Groups;
$very_group = $groups->verifyGroup( $groupId );
if ( $very_group==0 ) {
$result = new wsResponse (9, "Group not registered in the system");
return $result;
}
$very_user = $groups->verifyUsertoGroup( $groupId, $userId);
if($very_user==1){
$result = new wsResponse (8, "User already exists in the group");
return $result;
}
$groups->addUserToGroup( $groupId, $userId);
$result = new wsResponse (0, "command executed successfuly");
return $result;
}
catch ( Exception $e ) {
$result = new wsResponse (100, $e->getMessage());
return $result;
}
}
/*
* assigns user to department
* @param string $userId
* @param string $depId
* @param string $manager
* @return $result will return an object
*/
public function assignUserToDepartment( $userId, $depId, $manager) {
try {
global $RBAC;
$RBAC->initRBAC();
$user=$RBAC->verifyUserId($userId);
if($user==0){
$result = new wsResponse (3, "User not registered in the system");
return $result;
}
$deps = new Department;
if ( !$deps->existsDepartment( $depId ) ) {
$result = new wsResponse (100, "Department $depId is not registered in the system");
return $result;
}
if ( ! $deps->existsUserInDepartment( $depId, $userId ) ) {
$deps->addUserToDepartment( $depId, $userId, $manager, true );
}
$result = new wsResponse (0, "command executed successfuly");
return $result;
}
catch ( Exception $e ) {
$result = new wsResponse (100, $e->getMessage());
return $result;
}
}
/*
* sends variables to a case
* @param string $caseId
* @param string $variables
* @return $result will return an object
*/
public function sendVariables($caseId, $variables) {
//delegation where app uid (caseId) y usruid(session) ordenar delindes descendente y agaarr el primero
//delfinishdate != null error
try {
$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 );
$oCriteria->addDescendingOrderByColumn(AppDelegationPeer::DEL_INDEX);
$oDataset = AppDelegationPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$cnt = 0;
while($oDataset->next()) {
$aRow = $oDataset->getRow();
$cnt++;
}
if ($cnt == 0){
$result = new wsResponse (18, 'This case delegation is already closed or does not exist');
return $result;
}
if ( is_array($variables)) {
$cant = count ( $variables );
if($cant > 0) {
$oCase = new Cases();
$oldFields = $oCase->loadCase( $caseId );
$oldFields['APP_DATA'] = array_merge( $oldFields['APP_DATA'], $variables );
ob_start();
print_r($variables);
$cdata = ob_get_contents();
ob_end_clean();
$up_case = $oCase->updateCase($caseId, $oldFields);
$result = new wsResponse (0, "$cant variables received: \n".trim(str_replace('Array', '', $cdata)) );
return $result;
}
else {
$result = new wsResponse (23, "The variables param length is zero");
return $result;
}
} else {
$result = new wsResponse (24, "The variables param is not an array");
return $result;
}
}
catch ( Exception $e ) {
$result = new wsResponse (100, $e->getMessage());
return $result;
}
}
/*
* get variables The variables can be system variables and/or case variables
* @param string $caseId
* @param string $variables
* @return $result will return an object
*/
public function getVariables($caseId, $variables) {
try {
if ( is_array($variables) ) {
$cant = count ( $variables );
if($cant > 0) {
$oCase = new Cases();
$caseFields = $oCase->loadCase( $caseId );
$oldFields = $caseFields['APP_DATA'];
$resFields = array();
foreach ( $variables as $key => $val ) {
$a .= $val->name . ', ';
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){//Sp?cial Variables like grids or checkgroups
if(is_array($gridRow)){//Grids
foreach($gridRow as $col => $colValue){
$node = new stdClass();
$node->name = $val->name."][".$gridKey."][".$col;
$node->value =$colValue;
$resFields[] = $node;
}
}else{//Checkgroups, Radiogroups
$node = new stdClass();
$node->name = $key;
$node->value =implode("|",$val);
$resFields[] = $node;
}
}
}
}
}
$result = new wsGetVariableResponse (0, count($resFields) . " variables sent" , $resFields );
return $result;
}
else {
$result = new wsGetVariableResponse (23, "The variables param length is zero", null);
return $result;
}
}
else {
$result = new wsGetVariableResponse (24, "The variables param is not a array", null);
return $result;
}
}
catch ( Exception $e ) {
$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
* @return $result will return an object
*/
public function newCase($processId, $userId, $taskId, $variables) {
try {
$Fields = array();
if ( is_array($variables) && count($variables)>0 ) {
$Fields = $variables;
}
$oProcesses = new Processes();
$pro = $oProcesses->processExists($processId);
if( !$pro ) {
$result = new wsResponse (11, "Invalid process $processId");
return $result;
}
$oCase = new Cases();
$oTask = new Tasks();
$startingTasks = $oCase->getStartCases($userId);
array_shift ($startingTasks); //remove the first row, the header row
$founded = '';
$tasksInThisProcess = 0;
$validTaskId = $taskId;
foreach ( $startingTasks as $key=> $val ) {
if ( $val['pro_uid'] == $processId ) { $tasksInThisProcess ++; $validTaskId = $val['uid']; }
if ( $val['uid'] == $taskId ) $founded = $val['value'];
}
if ( $taskId == '' ) {
if ( $tasksInThisProcess == 1 ) {
$founded = $validTaskId;
$taskId = $validTaskId;
}
if ( $tasksInThisProcess > 1 ) {
$result = new wsResponse (13, "Multiple starting tasks in the process");
return $result;
}
}
if( $founded == '') {
$result = new wsResponse (14, "Task invalid or the user is not assigned to the task");
return $result;
}
$case = $oCase->startCase($taskId, $userId);
$caseId = $case['APPLICATION'];
$caseNr = $case['CASE_NUMBER'];
$oldFields = $oCase->loadCase( $caseId );
$oldFields['APP_DATA'] = array_merge( $oldFields['APP_DATA'], $Fields);
$up_case = $oCase->updateCase($caseId, $oldFields);
$result = new wsResponse (0, "Command executed successfully");
$result->caseId = $caseId;
$result->caseNumber = $caseNr;
return $result;
}
catch ( Exception $e ) {
$result = new wsResponse (100, $e->getMessage());
return $result;
}
}
/*
* creates a new case impersonating a user who has the proper privileges to create new cases
* @param string $processId
* @param string $userId
* @param string $variables
* @return $result will return an object
*/
public function newCaseImpersonate($processId, $userId, $variables) {
try {
if(is_array($variables)) {
if(count($variables)>0) {
$c=count($variables);
$Fields = $variables;
if($c == 0) { //Si no tenenmos ninguna variables en el array variables.
$result = new wsResponse (10, "Array of variables is empty");
return $result;
}
}
} else {
$result = new wsResponse (10, "The variables param is not an array");
return $result;
}
$oProcesses = new Processes();
$pro = $oProcesses->processExists($processId);
if(!$pro) {
$result = new wsResponse (11, "Invalid process $processId!!");
return $result;
}
$oCase = new Cases();
$tasks = $oProcesses->getStartingTaskForUser($processId, $userId);
$numTasks=count($tasks);
if($numTasks==1)
{
$oTask = new Tasks();
$very = $oTask->verifyUsertoTask($userId, $tasks[0]['TAS_UID']);
if(is_array($very))
{
if($very['TU_RELATION']==2)
{
$group=$groups->getUsersOfGroup( $tasks[0]['TAS_UID'] );
if(!is_array($group))
{ $result = new wsResponse (14, "The user is not assigned to the task");
return $result;
}
}
}
else
{ $result = new wsResponse (14, "The user is not assigned to the task");
return $result;
}
$case = $oCase->startCase($tasks[0]['TAS_UID'], $userId);
$caseId = $case['APPLICATION'];
$oldFields = $oCase->loadCase( $caseId );
$oldFields['APP_DATA'] = array_merge( $oldFields['APP_DATA'], $Fields);
$up_case = $oCase->updateCase($caseId, $oldFields);
$result = new wsResponse (0, "Command executed successfully");
return $result;
}
else {
if($numTasks==0) {
$result = new wsResponse (12, "No starting task defined");
return $result;
}
if($numTasks > 1){
$result = new wsResponse (13, "Multiple starting tasks in the process");
return $result;
}
}
}
catch ( Exception $e ) {
$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
* @param string $userId
@param string $caseId
@param string $delIndex
* @return $result will return an object
*/
public function derivateCase($userId, $caseId, $delIndex, $bExecuteTriggersBeforeAssignment = false) {
try {
$sStatus = 'TO_DO';
$varResponse = '';
$varTriggers = "\n";
if ($delIndex == '') {
$oCriteria = new Criteria('workflow');
$oCriteria->addSelectColumn(AppDelegationPeer::DEL_INDEX);
$oCriteria->add(AppDelegationPeer::APP_UID, $caseId);
$oCriteria->add(AppDelegationPeer::DEL_FINISH_DATE, null, Criteria::ISNULL);
if (AppDelegationPeer::doCount($oCriteria) > 1) {
$result = new wsResponse (20, 'Please specify the delegation index');
return $result;
}
$oDataset = AppDelegationPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
$aRow = $oDataset->getRow();
$delIndex = $aRow['DEL_INDEX'];
}
$oAppDel = new AppDelegation();
$appdel = $oAppDel->Load($caseId, $delIndex);
if($userId!=$appdel['USR_UID'])
{
$result = new wsResponse (17, "This case is assigned to another user");
return $result;
}
if($appdel['DEL_FINISH_DATE']!=NULL)
{
$result = new wsResponse (18, 'This case delegation is already closed or does not exist');
return $result;
}
$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();
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, "This case is in status ". $aRow['APP_TYPE']);
return $result;
}
}
$aData['APP_UID'] = $caseId;
$aData['DEL_INDEX'] = $delIndex;
//load data
$oCase = new Cases ();
$appFields = $oCase->loadCase( $caseId );
$appFields['APP_DATA']['APPLICATION'] = $caseId;
if ($bExecuteTriggersBeforeAssignment) {
//Execute triggers before assignment
$aTriggers = $oCase->loadTriggers($appdel['TAS_UID'], 'ASSIGN_TASK', -1, 'BEFORE' );
if (count($aTriggers) > 0) {
$oPMScript = new PMScript();
foreach ($aTriggers as $aTrigger) {
//$appFields = $oCase->loadCase( $caseId );
//$appFields['APP_DATA']['APPLICATION'] = $caseId;
#@Neyek #############################################################################################
if( !$this->stored_system_variables ) {
$appFields['APP_DATA'] = array_merge ( $appFields['APP_DATA'], G::getSystemConstants() );
} else {
$oParams = new stdClass();
$oParams->option = 'STORED SESSION';
$oParams->SID = $this->wsSessionId;
$appFields['APP_DATA'] = array_merge ( $appFields['APP_DATA'], G::getSystemConstants($oParams));
}
#####################################################################################################
$oPMScript->setFields( $appFields['APP_DATA'] );
$bExecute = true;
if ($aTrigger['ST_CONDITION'] !== '') {
$oPMScript->setScript($aTrigger['ST_CONDITION']);
$bExecute = $oPMScript->evaluate();
}
if ($bExecute) {
$oPMScript->setScript($aTrigger['TRI_WEBBOT']);
$oPMScript->execute();
//$appFields = $oCase->loadCase( $caseId );
$appFields['APP_DATA'] = $oPMScript->aFields;
$oCase->updateCase ( $caseId, $appFields );
}
}
}
}
//Execute triggers before derivation
$aTriggers = $oCase->loadTriggers($appdel['TAS_UID'], 'ASSIGN_TASK', -2, 'BEFORE' );
if (count($aTriggers) > 0) {
$oPMScript = new PMScript();
foreach ($aTriggers as $aTrigger) {
//$appFields = $oCase->loadCase( $caseId );
//$appFields['APP_DATA']['APPLICATION'] = $caseId;
#@Neyek #############################################################################################
if( !$this->stored_system_variables ) {
$appFields['APP_DATA'] = array_merge ( $appFields['APP_DATA'], G::getSystemConstants() );
} else {
$oParams = new stdClass();
$oParams->option = 'STORED SESSION';
$oParams->SID = $this->wsSessionId;
$appFields['APP_DATA'] = array_merge ( $appFields['APP_DATA'], G::getSystemConstants($oParams));
}
#####################################################################################################
$oPMScript->setFields( $appFields['APP_DATA'] );
$bExecute = true;
if ($aTrigger['ST_CONDITION'] !== '') {
$oPMScript->setScript($aTrigger['ST_CONDITION']);
$bExecute = $oPMScript->evaluate();
}
if ($bExecute) {
$oPMScript->setScript($aTrigger['TRI_WEBBOT']);
$oPMScript->execute();
//$appFields = $oCase->loadCase( $caseId );
$appFields['APP_DATA'] = $oPMScript->aFields;
//$appFields['APP_DATA']['APPLICATION'] = $caseId;
$oCase->updateCase ( $caseId, $appFields );
}
}
}
$oDerivation = new Derivation();
$derive = $oDerivation->prepareInformation($aData);
if (isset($derive[1])) {
if ($derive[1]['ROU_TYPE'] == 'SELECT') {
$result = new wsResponse (21, 'Can not route a case with Manual Assignment using webservices');
return $result;
}
}
else {
$result = new wsResponse (22, 'Task does not have a routing rule; check process definition');
return $result;
}
foreach ( $derive as $key=>$val ) {
if($val['NEXT_TASK']['TAS_ASSIGN_TYPE']=='MANUAL')
{
$result = new wsResponse (15, "The task is defined for Manual assignment");
return $result;
}
$nextDelegations[] = array(
'TAS_UID' => $val['NEXT_TASK']['TAS_UID'],
'USR_UID' => $val['NEXT_TASK']['USER_ASSIGNED']['USR_UID'],
'TAS_ASSIGN_TYPE' => $val['NEXT_TASK']['TAS_ASSIGN_TYPE'],
'TAS_DEF_PROC_CODE' => $val['NEXT_TASK']['TAS_DEF_PROC_CODE'],
'DEL_PRIORITY' => $appdel['DEL_PRIORITY'],
'TAS_PARENT' => $val['NEXT_TASK']['TAS_PARENT']
);
$varResponse = $varResponse . ($varResponse!=''?',':'') . $val['NEXT_TASK']['TAS_TITLE'].'('.$val['NEXT_TASK']['USER_ASSIGNED']['USR_USERNAME'].')';
}
$appFields['DEL_INDEX'] = $delIndex;
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
$row = array();
$oCriteria = new Criteria('workflow');
$del = DBAdapter::getStringDelimiter();
$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()) {
$row[] = array ( 'ROU_TYPE' => $aRow['ROU_TYPE'], 'ROU_NEXT_TASK' => $aRow['ROU_NEXT_TASK'] );
$oDataset->next();
}
//derivate case
$aCurrentDerivation = array(
'APP_UID' => $caseId,
'DEL_INDEX' => $delIndex,
'APP_STATUS' => $sStatus,
'TAS_UID' => $appdel['TAS_UID'],
'ROU_TYPE' => $row[0]['ROU_TYPE']
);
$oDerivation->derivate( $aCurrentDerivation, $nextDelegations );
$appFields = $oCase->loadCase($caseId);
$aTriggers = $oCase->loadTriggers($appdel['TAS_UID'], 'ASSIGN_TASK', -2, 'AFTER' );
if (count($aTriggers) > 0) {
$oPMScript = new PMScript();
//$appFields['APP_DATA']['APPLICATION'] = $caseId;
#@Neyek #############################################################################################
if( !$this->stored_system_variables ) {
$appFields['APP_DATA'] = array_merge ( $appFields['APP_DATA'], G::getSystemConstants() );
} else {
$oParams = new stdClass();
$oParams->option = 'STORED SESSION';
$oParams->SID = $this->wsSessionId;
$appFields['APP_DATA'] = array_merge ( $appFields['APP_DATA'], G::getSystemConstants($oParams));
}
#####################################################################################################
$oPMScript->setFields( $appFields['APP_DATA'] );
foreach ($aTriggers as $aTrigger) {
$bExecute = true;
if ($aTrigger['ST_CONDITION'] !== '') {
$oPMScript->setScript($aTrigger['ST_CONDITION']);
$bExecute = $oPMScript->evaluate();
}
if ($bExecute) {
$oPMScript->setScript($aTrigger['TRI_WEBBOT']);
$oPMScript->execute();
//$varTriggers .= "<br/><b>-= After Derivation =-</b><br/>" . htmlentities($aTrigger['TRI_WEBBOT'], ENT_QUOTES) . "<br/>";
//$appFields = $oCase->loadCase( $caseId );
$appFields['APP_DATA'] = $oPMScript->aFields;
//$appFields['APP_DATA']['APPLICATION'] = $caseId;
//$appFields = $oCase->loadCase( $caseId );
$oCase->updateCase ( $caseId, $appFields );
}
}
}
$oUser = new Users();
$aUser = $oUser->load($userId);
$sFromName = '"' . $aUser['USR_FIRSTNAME'] . ' ' . $aUser['USR_LASTNAME'] . '"';
$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
$oProcess = new Process();
$oProcessFieds = $oProcess->Load($appFields['PRO_UID']);
$result = new wsResponse (0, $varResponse);
$res = $result->getPayloadArray ();
//now fill the array of AppDelegationPeer
$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 {
$oUser->load($aAppDel['USR_UID']);
$uFields = $oUser->toArray(BasePeer::TYPE_FIELDNAME);
$currentUserName = $oUser->getUsrFirstname() . ' ' . $oUser->getUsrLastname();
}
catch ( Exception $e ) {
$currentUserName = '';
}
$oTask = new Task();
try {
$uFields = $oTask->load($aAppDel['TAS_UID']);
$taskName = $uFields['TAS_TITLE'];
}
catch ( Exception $e ) {
$taskName = '';
}
$currentUser = new stdClass();
$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;
return $res;
}
catch ( Exception $e ) {
$result = new wsResponse (100, $e->getMessage());
return $result;
}
}
/*
* execute Trigger, executes a ProcessMaker trigger. Note that triggers which are tied to case derivation will executing automatically.
* @param string $userId
* @param string $caseId
* @param string $delIndex
* @return $result will return an object
*/
public function executeTrigger($userId, $caseId, $triggerIndex, $delIndex) {
try {
$oAppDel = new AppDelegation();
$appdel = $oAppDel->Load($caseId, $delIndex);
if($userId!=$appdel['USR_UID'])
{
$result = new wsResponse (17, "This case is assigned to another user");
return $result;
}
if($appdel['DEL_FINISH_DATE']!=NULL)
{
$result = new wsResponse (18, 'This case delegation is already closed or does not exist');
return $result;
}
$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();
if(is_array($aRow))
{
if($aRow['APP_DISABLE_ACTION_USER']!=0 && $aRow['APP_DISABLE_ACTION_DATE']!='')
{
$result = new wsResponse (19, "This case is in status ". $aRow['APP_TYPE']);
return $result;
}
}
//load data
$oCase = new Cases ();
$appFields = $oCase->loadCase( $caseId );
$appFields['APP_DATA']['APPLICATION'] = $caseId;
//executeTrigger
$aTriggers = array();
$c = new Criteria();
$c ->add(TriggersPeer::TRI_UID, $triggerIndex );
$rs = TriggersPeer::doSelectRS($c);
$rs ->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$rs ->next();
$row = $rs->getRow();
if (is_array($row) && $row['TRI_TYPE'] == 'SCRIPT' ) {
$aTriggers[] = $row;
$oPMScript = new PMScript();
$oPMScript ->setFields($appFields['APP_DATA']);
$oPMScript ->setScript($row['TRI_WEBBOT']);
$oPMScript ->execute();
//Save data - Start
$appFields['APP_DATA'] = $oPMScript->aFields;
//$appFields = $oCase->loadCase( $caseId );
$oCase->updateCase ( $caseId, $appFields);
//Save data - End
}
else {
$result = new wsResponse (100, "Invalid trigger '$triggerIndex'" );
return $result;
}
$result = new wsResponse (0, 'executed: '. trim( $row['TRI_WEBBOT']) );
//$result = new wsResponse (0, 'executed: '. print_r( $oPMScript ,1 ) );
return $result;
}
catch ( Exception $e ) {
$result = new wsResponse (100, $e->getMessage());
return $result;
}
}
/*
* task Case
* @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
*/
public function taskCase( $caseId ) {
try {
$result = array();
$oCriteria = new Criteria('workflow');
$del = DBAdapter::getStringDelimiter();
$oCriteria ->addSelectColumn(AppDelegationPeer::DEL_INDEX);
$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 );
$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['DEL_INDEX'], 'name' => $aRow['TAS_TITLE'] );
$oDataset->next();
}
return $result;
}
catch ( Exception $e ) {
$result[] = array ( 'guid' => $e->getMessage(), 'name' => $e->getMessage() );
return $result;
}
}
/*
* process list verified
* @param string sessionId : The session ID which is obtained when logging in
* @param string userId :
* @return $result will return an object
*/
public function processListVerified( $userId ){
try {
$oCase = new Cases();
$rows = $oCase->getStartCases($userId);
$result = array();
foreach ( $rows as $key=>$val ) {
if ( $key != 0 )
$result[] = array ( 'guid' => $val['pro_uid'], 'name' => $val['value'] );
}
return $result;
}
catch ( Exception $e ) {
$result[] = array ( 'guid' => $e->getMessage(), 'name' => $e->getMessage() );
return $result;
}
}
/*
* reassign Case
* @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
*/
public function reassignCase( $sessionId, $caseId, $delIndex, $userIdSource, $userIdTarget ){
try {
if ( $userIdTarget == $userIdSource ) {
$result = new wsResponse (30, "Target and Origin user are the same" );
return $result;
}
/******************( 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();
if(!is_array($aRow))
{
$result = new wsResponse (31, "Invalid origin user" );
return $result;
}
/******************( 2 )******************/
$oCase = new Cases();
$rows = $oCase->loadCase($caseId);
if(!is_array($aRow))
{
$result = new wsResponse (32, "This case is not open" );
return $result;
}
/******************( 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);
$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();
if(!is_array($aRow))
{
$result = new wsResponse (33, "Invalid Case Delegation index for this user" );
return $result;
}
$tasUid = $aRow['TAS_UID'];
$derivation = new Derivation ();
$userList = $derivation->getAllUsersFromAnyTask( $tasUid );
if ( ! in_array ( $userIdTarget, $userList ) ) {
$result = new wsResponse (34, "The target user does not have rights to execute the task " );
return $result;
}
/******************( 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();
if(!is_array($aRow))
{
$result = new wsResponse (35, "The target user destination is invalid" );
return $result;
}
/******************( 5 )******************/
$var=$oCase->reassignCase($caseId, $delIndex, $userIdSource, $userIdTarget);
if(!$var)
{
$result = new wsResponse (36, "The case could not be reassigned." );
return $result;
}
$result = new wsResponse (0, 'Command executed successfully');
return $result;
}
catch ( Exception $e ) {
$result[] = array ( 'guid' => $e->getMessage(), 'name' => $e->getMessage() );
return $result;
}
}
/*
* get system information
* @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
*/
public function systemInformation() {
try {
define ( 'SKIP_RENDER_SYSTEM_INFORMATION', true );
require_once ( PATH_METHODS . 'login' . PATH_SEP . 'dbInfo.php' );
$result->status_code = 0;
$result->message = 'Sucessful';
$result->timestamp = date ( 'Y-m-d H:i:s');
$result->version = PM_VERSION;
$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'];
$result->userBrowser = $Fields['HTTP_USER_AGENT'];
$result->userIp = $Fields['IP'];
return $result;
}
catch ( Exception $e ) {
$result = new wsResponse (100, $e->getMessage());
return $result;
}
}
/*
* import process fromLibrary: downloads and imports a process from the ProcessMaker library
* @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.
* @return $eturns will return an object
*/
public function importProcessFromLibrary ( $processId, $version = '', $importOption = '', $usernameLibrary = '', $passwordLibrary = '' ) {
try {
G::LoadClass('processes');
//$versionReq = $_GET['v'];
//. (isset($_GET['s']) ? '&s=' . $_GET['s'] : '')
$ipaddress = $_SERVER['REMOTE_ADDR'];
$oProcesses = new Processes();
$oProcesses ->ws_open_public();
$oProcess = $oProcesses->ws_processGetData($processId);
if ( $oProcess->status_code != 0 ) {
throw ( new Exception ( $oProcess->message ) );
}
$privacy = $oProcess->privacy;
$strSession = '';
if ( $privacy != 'FREE' ) {
global $sessionId;
$antSession = $sessionId;
$oProcesses->ws_open ($usernameLibrary, $passwordLibrary );
$strSession = "&s=" . $sessionId;
$sessionId = $antSession;
}
//downloading the file
$localPath = PATH_DOCUMENT . 'input' . PATH_SEP ;
G::mk_dir($localPath);
$newfilename = G::GenerateUniqueId() . '.pm';
$downloadUrl = PML_DOWNLOAD_URL . '?id=' . $processId . $strSession;
$oProcess = new Processes();
$oProcess->downloadFile( $downloadUrl, $localPath, $newfilename);
//getting the ProUid from the file recently downloaded
$oData = $oProcess->getProcessData ( $localPath . $newfilename );
if ( is_null($oData)) {
throw new Exception('Error the url ' . $downloadUrl . ' is invalid or the process in '. $localPath . $newfilename. ' is invalid');
}
$sProUid = $oData->process['PRO_UID'];
$oData->process['PRO_UID_OLD'] = $sProUid;
//if the process exists, we need to check the $importOption to and re-import if the user wants,
if ( $oProcess->processExists ( $sProUid ) ) {
//Update the current Process, overwriting all tasks and steps
if ( $importOption == 1 ) {
$oProcess->updateProcessFromData ($oData, $localPath . $newfilename );
//delete the xmlform cache
if (file_exists(PATH_OUTTRUNK . 'compiled' . PATH_SEP . 'xmlform' . PATH_SEP . $sProUid)) {
$oDirectory = dir(PATH_OUTTRUNK . 'compiled' . PATH_SEP . 'xmlform' . PATH_SEP . $sProUid);
while($sObjectName = $oDirectory->read()) {
if (($sObjectName != '.') && ($sObjectName != '..')) {
unlink(PATH_OUTTRUNK . 'compiled' . PATH_SEP . 'xmlform' . PATH_SEP . $sProUid . PATH_SEP . $sObjectName);
}
}
$oDirectory->close();
}
$sNewProUid = $sProUid;
}
//Disable current Process and create a new version of the Process
if ( $importOption == 2 ) {
$oProcess ->disablePreviousProcesses( $sProUid );
$sNewProUid = $oProcess->getUnusedProcessGUID() ;
$oProcess ->setProcessGuid ( $oData, $sNewProUid );
$oProcess ->setProcessParent( $oData, $sProUid );
$oData ->process['PRO_TITLE'] = "New - " . $oData->process['PRO_TITLE'] . ' - ' . date ( 'M d, H:i' );
$oProcess ->renewAll ( $oData );
$oProcess ->createProcessFromData ($oData, $localPath . $newfilename );
}
//Create a completely new Process without change the current Process
if ( $importOption == 3 ) {
//krumo ($oData); die;
$sNewProUid = $oProcess->getUnusedProcessGUID() ;
$oProcess ->setProcessGuid ( $oData, $sNewProUid );
$oData ->process['PRO_TITLE'] = "Copy of - " . $oData->process['PRO_TITLE'] . ' - ' . date ( 'M d, H:i' );
$oProcess ->renewAll ( $oData );
$oProcess ->createProcessFromData ($oData, $localPath . $newfilename );
}
if ( $importOption != 1 && $importOption != 2 && $importOption != 3 ) {
throw new Exception('The process is already in the System and the value for importOption is not specified.');
}
}
//finally, creating the process if the process does not exists
if ( ! $oProcess->processExists ( $processId ) ) {
$oProcess->createProcessFromData ($oData, $localPath . $newfilename );
}
//show the info after the imported process
$oProcess = new Processes();
$oProcess ->ws_open_public ();
$processData = $oProcess->ws_processGetData ( $processId );
$result ->status_code = 0;
$result ->message = 'Command executed successfully';
$result ->timestamp = date ( 'Y-m-d H:i:s');
$result ->processId = $processId;
$result ->processTitle = $processData->title;
$result ->category = (isset($processData->category) ? $processData->category : '');
$result ->version = $processData->version;
return $result;
}
catch ( Exception $e ) {
$result = new wsResponse (100, $e->getMessage());
return $result;
}
}
add remove users from group webservices
2011-02-02 21:29:47 +00:00
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
}
Reference in New Issue Copy Permalink