<?php
/**
 * class.wsBase.php
 * @package workflow.engine.classes
 *
 * ProcessMaker Open Source Edition
 * Copyright (C) 2004 - 2011 Colosa Inc.
 *
 * 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
 * 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
 */

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;
      }

      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';
      $aData['USR_COUNTRY']     = 'US';
      $aData['USR_CITY']        = 'FL';
      $aData['USR_LOCATION']    = 'MIA';
      $aData['USR_ADDRESS']     = '';
      $aData['USR_PHONE']       = '';
      $aData['USR_ZIP_CODE']    = '33314';
      $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;
    }
  }

  /*
  * 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']);
  }

   /*
    * 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;
    }
  }

  
}