luos/workflow/engine/classes/class.AppSolr.php

<?php
/**
 * 
 * ProcessMaker Open Source Edition
 * Copyright (C) 2004 - 2012 Colosa Inc.23
 *
 * 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, 5304 Ventura Drive,
 * Delray Beach, FL, 33484, USA, or email info@colosa.com.
 * 
 */

require_once "classes/model/Application.php";
require_once "classes/model/AppDelegation.php";
require_once "classes/model/AppThread.php";
require_once "classes/model/Content.php";
require_once "classes/model/Users.php";
require_once "classes/model/GroupUser.php";
require_once "classes/model/Task.php";
require_once "classes/model/TaskUser.php";
require_once "classes/model/Dynaform.php";
require_once "classes/model/ProcessVariables.php";
require_once "entities/SolrRequestData.php";
require_once "entities/SolrUpdateDocument.php";
require_once "entities/AppSolrQueue.php";
require_once "classes/model/AppSolrQueue.php";


/**
 * Invalid search text for Solr exception
 *
 * @author Herbert Saal Gutierrez
 *        
 */
class InvalidIndexSearchTextException extends Exception
{
  // Redefine the exception so message isn't optional
  public function __construct($message, $code = 0)
  {
    // some code
    // make sure everything is assigned properly
    parent::__construct ($message, $code);
  }
  
  // custom string representation of object
  public function __toString()
  {
    return __CLASS__ . ": [{$this->code}]: {$this->message}\n";
  }
}

/**
 * Application without Delegations exception
 *
 * @author Herbert Saal Gutierrez
 * 
 * @category Colosa
 * @copyright Copyright (c) 2005-2012 Colosa Inc. (http://www.colosa.com)
 */
class ApplicationWithoutDelegationRecordsException extends Exception
{
  // Redefine the exception so message isn't optional
  public function __construct($message, $code = 0)
  {
    // some code
    // make sure everything is assigned properly
    parent::__construct ($message, $code);
  }
  
  // custom string representation of object
  public function __toString()
  {
    return __CLASS__ . ": [{$this->code}]: {$this->message}\n";
  }
}

/**
 * Dynaform file corrupt
 *
 * @author Herbert Saal Gutierrez
 *
 * @category Colosa
 * @copyright Copyright (c) 2005-2012 Colosa Inc. (http://www.colosa.com)
 */
class ApplicationWithCorruptDynaformException extends Exception
{
  // Redefine the exception so message isn't optional
  public function __construct($message, $code = 0)
  {
    // some code
    // make sure everything is assigned properly
    parent::__construct ($message, $code);
  }

  // custom string representation of object
  public function __toString()
  {
    return __CLASS__ . ": [{$this->code}]: {$this->message}\n";
  }
}

/**
 * Application APP_DATA could not be unserialized exception
 *
 * @author Herbert Saal Gutierrez
 *
 * @category Colosa
 * @copyright Copyright (c) 2005-2012 Colosa Inc. (http://www.colosa.com)
 */
class ApplicationAPP_DATAUnserializeException extends Exception
{
  // Redefine the exception so message isn't optional
  public function __construct($message, $code = 0)
  {
    // some code
    // make sure everything is assigned properly
    parent::__construct ($message, $code);
  }

  // custom string representation of object
  public function __toString()
  {
    return __CLASS__ . ": [{$this->code}]: {$this->message}\n";
  }
}
/*
class CheckSolrAvailability
{
  private static _classInstance = null;
  private static _SolrIsAvailable = true;

  private function __construct($SolrEnabled, $SolrHost, $SolrInstance)
  {
    // define solr availability
    $this->_solrIsEnabled = $SolrEnabled;
    $this->_solrHost = $SolrHost;
    $this->_solrInstance = $SolrInstance;
  }

  public function getInstance(){
    if()
  }
}*/

/**
 * Implementation to display application data in the PMOS2 grids using Solr
 * search service
 *
 * @author Herbert Saal Gutierrez
 * @category Colosa
 * @copyright Copyright (c) 2005-2011 Colosa Inc. (http://www.colosa.com)
 *
 */
class AppSolr
{
  private $_solrIsEnabled = false;
  private $_solrHost = "";
  private $_solrInstance = "";
  private $debug = false; //false
  private $debugAppInfo = false;
  private $trunkSizeAcumulated;
  private $totalTimeAcumulated;
  
  public function __construct($SolrEnabled, $SolrHost, $SolrInstance)
  {
    // define solr availability
    $this->_solrIsEnabled = $this->isSolrEnabled();
    $this->_solrHost = $SolrHost;
    $this->_solrInstance = $SolrInstance;
  }
  
  /**
   * Return if the Solr server is currently working. 
   * @return boolean true:enabled functionality, false:disabled functionality
   */
  public function isSolrEnabled()
  {
    G::LoadClass ('searchIndex');

    $searchIndex = new BpmnEngine_Services_SearchIndex ($this->_solrIsEnabled, $this->_solrHost);
    // execute query
    $solrStatusResult = $searchIndex->isEnabled ($this->_solrInstance);    
    return $solrStatusResult;
  }
  
  /**
   * Gets the information of Grids using Solr server.
   *
   * Returns the list of records for the grid depending of the function
   * conditions
   * If doCount is true only the count of records is returned.
   *
   * @param string $userUid
   *          current logged user.
   * @param int $start
   *          the offset to return the group of records. Used for pagination.
   * @param int $limit
   *          The number of records to return in the set.
   * @param string $action
   *          the action: todo, participated, draft, unassigned
   * @param string $filter
   *          filter the results posible values ('read', 'unread', 'started',
   *          'completed')
   * @param string $search
   *          search string
   * @param string $process
   *          PRO_UID to filter results by specified process.
   * @param string $user
   *          USR_UID to filter results by specified user.
   * @param string $status
   *          filter by an application Status : TO_DO, COMPLETED, DRAFT
   * @param string $type
   *          default extjs
   * @param string $dateFrom
   *          filter by DEL_DELEGATE_DATE, not used
   * @param string $dateTo
   *          filter by DEL_DELEGATE_DATE, not used
   * @param string $callback
   *          default stcCallback1001 not used
   * @param string $dir
   *          sort direction ASC, DESC
   * @param string $sort
   *          sort field
   * @param boolean $doCount
   *          default=false, if true only the count of records is returned.
   * @return array return the list of cases
   */
  public function getAppGridData(
    $userUid, 
    $start = null, 
    $limit = null, 
    $action = null, 
    $filter = null, 
    $search = null, 
    $process = null, 
    $status = null, 
    $type = null, 
    $dateFrom = null, 
    $dateTo = null, 
    $callback = null, 
    $dir = null, 
    $sort = 'APP_CACHE_VIEW.APP_NUMBER', 
    $category = null, 
    $doCount = false
  ) {
    
    $callback = isset ($callback) ? $callback : 'stcCallback1001';
    $dir = isset ($dir) ? $dir : 'DESC'; // direction of sort column
                                           // (ASC, DESC)
    $sort = isset ($sort) ? $sort : ''; // sort column (APP_NUMBER,
                                          // CASE_SUMMARY,
                                          // CASE_NOTES_COUNT, APP_TITLE,
                                          // APP_PRO_TITLE, APP_TAS_TITLE,
                                          // APP_DEL_PREVIOUS_USER,
                                          // DEL_TASK_DUE_DATE,
                                          // APP_UPDATE_DATE, DEL_PRIORITY)
    $start = isset ($start) ? $start : '0';
    $limit = isset ($limit) ? $limit : '25';
    $filter = isset ($filter) ? $filter : ''; // posible values ('read',
                                                // 'unread', 'started',
                                                // 'completed')
    $search = isset ($search) ? $search : ''; // search in fields, plain text
    $process = isset ($process) ? $process : ''; // filter by an specific
                                                   // process
                                                   // uid
    $user = $userUid; // filter by an specific user uid
    $status = isset ($status) ? strtoupper ($status) : ''; // filter by an
                                                               // specific
                                                               // app_status
    $action = isset ($action) ? $action : 'todo'; // todo, paused
    $type = isset ($type) ? $type : 'extjs';
    $dateFrom = isset ($dateFrom) ? $dateFrom : ''; // filter by
                                                      // DEL_DELEGATE_DATE
    $dateTo = isset ($dateTo) ? $dateTo : ''; // filter by DEL_DELEGATE_DATE
    
    $swErrorInSearchText = false;
    $solrQueryResult = null;
    $aPriorities = array('1'=>'VL', '2'=>'L', '3'=>'N', '4'=>'H', '5'=>'VH');
    $delegationIndexes = array();
    
    $result = array ();
    $result ['totalCount'] = 0;
    $result ['data'] = array ();
    $result ['success'] = false;
    $result ['message'] = "Error description.";
    
    G::LoadClass ('searchIndex');
    
    try {
      if($this->debug)
      {      
        $this->initTimeAll = microtime (true);
      }
      
      // the array of data that must be returned with placeholders     
      /*$columsToInclude = array (
          'APP_CREATE_DATE',
          'APP_NUMBER',
          'APP_PRO_TITLE',
          'APP_STATUS',
          'APP_TITLE',
          'APP_UID',
          'DEL_LAST_UPDATE_DATE',
          'DEL_MAX_PRIORITY',
          'PRO_UID'
      );*/

      $columsToInclude = array (
          'APP_PRO_TITLE',
          'APP_TITLE',
          'APP_UID',
          'DEL_MAX_PRIORITY'
      );      

      // create pagination data
      $solrSearchText = "";
      $sortableCols = array ();
      $sortCols = array ();
      $sortDir = array ();
      $numSortingCols = 0;
      
      // define sort conditions, default APP_NUMBER, desc
      // only one column is sorted
      $dir = strtolower ($dir);
      
      if (! empty ($sort)) {
        switch ($sort) {
          case 'APP_CACHE_VIEW.APP_NUMBER' :
          case 'APP_NUMBER' :
            $sortCols [0] = 'APP_NUMBER'; //4;
            //$sortableCols [0] = 'true';
            $sortDir [0] = $dir;
            break;
          // multivalue field can't be ordered
          case 'APP_TITLE' :
            $sortCols [0] = 'APP_TITLE'; //10;
            //$sortableCols [0] = 'true';
            $sortDir [0] = $dir;
            break;
          case 'APP_PRO_TITLE' :
            $sortCols [0] = 'APP_PRO_TITLE'; //6;
            //$sortableCols [0] = 'true';
            $sortDir [0] = $dir;
            break;
          case 'APP_STATUS' :
            $sortCols [0] = 'APP_STATUS'; //6;
            //$sortableCols [0] = 'true';
            $sortDir [0] = $dir;
            break;
          case 'APP_UPDATE_DATE' :
            $sortCols [0] = 'DEL_LAST_UPDATE_DATE'; //12;
            //$sortableCols [0] = 'true';
            $sortDir [0] = $dir;
            break;
          default :
            $sortCols [0] = 'APP_NUMBER'; //4;
            //$sortableCols [0] = 'true';
            $sortDir [0] = 'desc';
            break;
        }
        $numSortingCols ++;
      }
      
      // get del_index field
      $delIndexDynaField = "";
      // process filter
      if ($process != '') { 
        $solrSearchText .= "PRO_UID:" . $process . " AND ";
      }
      // status filter
      if ($status != '') {
        $solrSearchText .= "APP_STATUS:" . $status . " AND ";
      }
      //Category filter
      if (!empty($category)) {
          $solrSearchText .= "PRO_CATEGORY_UID_s:" . $category . " AND ";
      }
            
      // todo list, add condition
      if ($userUid != null && $action == 'todo') {
        if ($filter == 'read') {
          $solrSearchText .= "APP_ASSIGNED_USERS_READ:" . $userUid . " AND ";
          $delegationIndexes[] = "APP_ASSIGNED_USER_READ_DEL_INDEX_" . trim ($userUid) . '_txt'; 
        }
        elseif ($filter == 'unread') {
          $solrSearchText .= "APP_ASSIGNED_USERS_UNREAD:" . $userUid . " AND ";
          $delegationIndexes[] = "APP_ASSIGNED_USER_UNREAD_DEL_INDEX_" . trim ($userUid) . '_txt';
        }
        else {
          $solrSearchText .= "APP_ASSIGNED_USERS:" . $userUid . " AND ";
          $delegationIndexes[] = "APP_ASSIGNED_USER_DEL_INDEX_" . trim ($userUid) . '_txt';
        }
      }
      // participated, add condition
      if ($userUid != null && $action == 'sent') {
        if ($filter == 'started') {
          $solrSearchText .= "APP_PARTICIPATED_USERS_STARTED:" . $userUid . " AND ";
          $delegationIndexes[] = "APP_PARTICIPATED_USER_STARTED_DEL_INDEX_" . trim ($userUid) . '_txt';
        }
        elseif ($filter == 'completed') {
          $solrSearchText .= "APP_PARTICIPATED_USERS_COMPLETED:" . $userUid . " AND ";
          $delegationIndexes[] = "APP_PARTICIPATED_USER_COMPLETED_DEL_INDEX_" . trim ($userUid) . '_txt';
        }
        else {
          $solrSearchText .= "APP_PARTICIPATED_USERS:" . $userUid . " AND ";
          //$delegationIndexes[] = "APP_PARTICIPATED_USER_DEL_INDEX_" . trim ($userUid) . '_txt';
          //show the last index of the case
          $delegationIndexes[] = "DEL_LAST_INDEX";
        }
      }
      // draft, add condition
      if ($userUid != null && $action == 'draft') {
        $solrSearchText .= "APP_DRAFT_USER:" . $userUid . " AND ";
        // index is allways 1
      }
      // unassigned, add condition
      if ($userUid != null && $action == 'unassigned') {
        // get the list of groups to which belongs the user.
        $userGroups = $this->getUserGroups ($userUid);

        $solrSearchText .= "(APP_UNASSIGNED_USERS:" . $userUid;
        if (count ($userGroups) > 0) {
          $solrSearchText .= " OR ";
          
          foreach ($userGroups as $group) {
            $solrSearchText .= "APP_UNASSIGNED_GROUPS:" . $group ['GRP_UID'] . " OR ";
          }
          
          // remove last OR in condition
          if ($solrSearchText != '')
            $solrSearchText = substr_replace ($solrSearchText, "", - 4);
        }
        $solrSearchText .= ") AND ";
        
        $delegationIndexes[] = "APP_UNASSIGNED_USER_GROUP_DEL_INDEX_" . trim ($userUid) . '_txt';
        foreach ($userGroups as $group) {
          $delegationIndexes[] = "APP_UNASSIGNED_USER_GROUP_DEL_INDEX_" . trim ($group ['GRP_UID']) . '_txt';
        }        
      }
        // Paused, add condition
        if ($userUid != null && $action == 'paused') {
            $solrSearchText .= "APP_PAUSED_USERS:" . $userUid . ' AND ';
            $delegationIndexes[] = "APP_PAUSED_USER_DEL_INDEX_" . trim ($userUid) . '_txt';
        }
      //search action
      if ($action == 'search'){
        if($dateFrom != "" || $dateTo != "") {
          $fromDate = ($dateFrom != '')? date ("Y-m-d", strtotime ($dateFrom)): '*';
          $toDate = ($dateTo != '') ? date ("Y-m-d", strtotime ($dateTo)): '*';
                  
          $searchDateOriginal = "DEL_LAST_UPDATE_DATE:[" . $fromDate . " TO " . $toDate . "]";
          //FechaRegistro:[2011-04-15 TO 2011-04-30]
          
          $searchDateFormatedSolr = $this->getSearchText ($searchDateOriginal);
          
          $solrSearchText .= "(" . $searchDateFormatedSolr . ") AND ";
        }

        //verify if we need to filter by user
        if($user != ''){
          $solrSearchText .= "(APP_PARTICIPATED_USERS:" . $user . ") AND ";         
        }
        //in all cases of search show the last index of the case
        $delegationIndexes[] = "DEL_LAST_INDEX";
      }
      
      // remove last AND in condition
      if ($solrSearchText != '')
        $solrSearchText = substr_replace ($solrSearchText, "", - 5);
        
        // add parenthesis to Solr search text
      if ($solrSearchText != "")
        $solrSearchText = "(" . $solrSearchText . ")";
        
        // create query string, add query conditions
      if ($search != '') {
        // format search string
        // return exception in case of invalid text
        $search = $this->getSearchText ($search);
        
        if ($solrSearchText != "" && $search != "")
          $solrSearchText .= " AND ";
        if ($search != "")
          $solrSearchText .= "(" . $search . ")";
      }
      // add del_index dynamic fields to list of resulting columns
      $columsToIncludeFinal = array();
      $columsToIncludeFinal = array_merge ($columsToInclude, $delegationIndexes);
      
      // if is a counter no records are returned
      if ($doCount) {
        $start = 0;
        $limit = 0;
        $numSortingCols = 0;
        $columsToIncludeFinal = array ();
      }
       
      $data = array (
          'workspace' => $this->_solrInstance, // solr instance
          'startAfter' => intval ($start),
          'pageSize' => intval ($limit),
          'searchText' => $solrSearchText,
          'filterText' => '', // $filter, //ex:'field1:value1,field2:[value2.1
                              // TO value2.2],field3:value3'
          'numSortingCols' => $numSortingCols,
          'sortableCols' => $sortableCols,
          'sortCols' => $sortCols,
          'sortDir' => $sortDir,
          'includeCols' => $columsToIncludeFinal,
          'resultFormat' => 'json' 
      );
      $solrRequestData = Entity_SolrRequestData::createForRequestPagination ($data);
      // use search index to return list of cases
      $searchIndex = new BpmnEngine_Services_SearchIndex ($this->_solrIsEnabled, $this->_solrHost);
      // execute query
      $solrQueryResult = $searchIndex->getDataTablePaginatedList ($solrRequestData);
      if($this->debug)
      {
        $this->afterSolrQueryTime = microtime (true);
      }
      //return inmediatelly
      if ($doCount) {
        $result ['totalCount'] = $solrQueryResult->iTotalDisplayRecords;
        $result ['data'] = array();
        $result ['success'] = true;
        $result ['result'] = true;
        $result ['message'] = "";
        
        return $result;
      }
      // complete return data, complete list of columns in grid
      $resultColumns = array (
          "APP_CREATE_DATE",
          "APP_CURRENT_USER",
          "APP_DEL_PREVIOUS_USER",
          "APP_FINISH_DATE",
          "APP_NUMBER",
          "APP_OVERDUE_PERCENTAGE",
          "APP_PRO_TITLE",
          "APP_STATUS",
          "APP_TAS_TITLE",
          "APP_THREAD_STATUS",
          "APP_TITLE",
          "APP_UID",
          "APP_UPDATE_DATE",
          "DEL_DELAYED",
          "DEL_DELAY_DURATION",
          "DEL_DELEGATE_DATE",
          "DEL_DURATION",
          "DEL_FINISHED",
          "DEL_FINISH_DATE",
          "DEL_INDEX",
          "DEL_INIT_DATE",
          "DEL_PRIORITY",
          "DEL_QUEUE_DURATION",
          "DEL_STARTED",
          "DEL_TASK_DUE_DATE",
          "DEL_THREAD_STATUS",
          "PREVIOUS_USR_UID",
          "PRO_UID",
          "TAS_UID",
          "USR_UID" 
      );
      
      $rows = array ();
      // number of found records
      $result ['totalCount'] = $solrQueryResult->iTotalDisplayRecords;

      //var_dump($solrQueryResult->aaData); die;

      //get the missing data from database
      $appUids = array();
      foreach ($solrQueryResult->aaData as $i => $data) {
        $appUids[] = $data ['APP_UID'];//APP_UID
      }
      
      $aaappsDBData = $this->getListApplicationDelegationData ($appUids);
      
      if($this->debug)
      {
        $this->afterDbQueryTime = microtime (true);
      }
      //****************************************************************
      //Begin the list of Cases and define which delegations are display
      //to complete the data for each delegation
      //****************************************************************
      // complete the missing data to display it in the grid.
      $delIndexes = array(); //store all the delegation indexes
      foreach ($solrQueryResult->aaData as $i => $data) {
        //initialize array
        $delIndexes = array();
        // complete empty values
        $appUID = $data ['APP_UID'];//APP_UID
        //get all the indexes returned by Solr as columns
        for($i = count($columsToInclude) ; $i < count($data) ; $i++) {
          //var_dump($data [$columsToIncludeFinal[$i]]);

          if (is_array ($data [$columsToIncludeFinal[$i]])) {
            foreach($data [$columsToIncludeFinal[$i]] as $delIndex){
              $delIndexes[] = $delIndex;
            }
          }
        }
        // verify if the delindex is an array
        // if is not check different types of repositories
        // the delegation index must always be defined.
        if (count($delIndexes) == 0) {
          // if is draft
          if ($action == 'draft') {
            $delIndexes [] = 1; // the first default index
          }
          /*elseif ($action == 'search') {
            // get all the indexes
            //$delIndexes = $this->getApplicationDelegationsIndex ($appUID);
            $indexes = $this->aaSearchRecords ($aaappsDBData, array (
                'APP_UID' => $appUID
            ));
            
            foreach ($indexes as $index) {
              $delIndexes[] = $aaappsDBData [$index]['DEL_INDEX'];
            }

          }*/
          else {
            //error an index must always be defined
            print date('Y-m-d H:i:s:u') . " Delegation not defined\n";
          }
          /*
          elseif ($action == 'unassigned'){
            $delIndexes = $this->getApplicationDelegationsIndex ($appUID);
          }*/
        }
        //remove duplicated
        $delIndexes = array_unique($delIndexes);

        //var_dump($delIndexes);

        foreach ($delIndexes as $delIndex) {
          $aRow = array ();

          //copy result values to new row from Solr server
          $aRow ['APP_UID'] = $data['APP_UID'];
          $aRow ['DEL_PRIORITY'] = $data['DEL_MAX_PRIORITY'];//different name
          $aRow ['APP_PRO_TITLE'] = $data['APP_PRO_TITLE'];
          $aRow ['APP_TITLE'] = $data['APP_TITLE'];
          
/*
          foreach ($resultColumns as $j => $columnName) {
            if(isset($data [$columnName]))
              $aRow [$columnName] = $data [$columnName];
            else if($columnName = 'DEL_PRIORITY')
              $aRow [$columnName] = $data['DEL_MAX_PRIORITY'];//different name
            else
              $aRow [$columnName] = '';//placeholder
          }

          //var_dump($aRow); 

          // convert date from solr format UTC to local time in MySQL format
          $solrdate = $data ['APP_CREATE_DATE'];
          $localDate = date ('Y-m-d H:i:s', strtotime ($solrdate));
          $aRow ['APP_CREATE_DATE'] = $localDate;
          
          $solrdate = $data ['DEL_LAST_UPDATE_DATE'];
          $localDate = date ('Y-m-d H:i:s', strtotime ($solrdate));
          $aRow ['APP_UPDATE_DATE'] = $localDate;
          */

          // get delegation data from DB
          //filter data from db
          $indexes = $this->aaSearchRecords ($aaappsDBData, array (
              'APP_UID' => $appUID,
              'DEL_INDEX' => $delIndex
          ));
          $row = '';
          foreach ($indexes as $index) {
            $row = $aaappsDBData [$index];
          }

          if (empty($row))
          {
            $fh = fopen("SolrAppWithoutDelIndex.txt", 'a') or die("can't open file to store Solr search time.");
            fwrite($fh, sprintf("Solr AppUid: %s DelIndex: %s not found.\r\n", $appUID, $delIndex));
            fclose($fh);
            continue;
          }
          //$row = $this->getAppDelegationData ($appUID, $delIndex);
          $aRow ['APP_CREATE_DATE'] = $row ['APP_CREATE_DATE'];
          $aRow ['APP_UPDATE_DATE'] = $row ['APP_UPDATE_DATE'];
          $aRow ['APP_NUMBER'] = $row ['APP_NUMBER'];
          $aRow ['APP_STATUS'] = $row ['APP_STATUS'];
          $aRow ['PRO_UID'] = $row ['PRO_UID'];

          $aRow ['APP_FINISH_DATE'] = null;
          $aRow ['APP_CURRENT_USER'] = $row ['USR_NAME'] . " " . $row ['USR_LAST'];
          $aRow ['APP_DEL_PREVIOUS_USER'] = $row ['USR_PREV_NAME'] . " " . $row ['USR_PREV_LAST'];
          $aRow ['APP_OVERDUE_PERCENTAGE'] = $row ['APP_OVERDUE_PERCENTAGE'];
          $aRow ['APP_TAS_TITLE'] = $row ['APP_TAS_TITLE'];
          $aRow ['APP_THREAD_STATUS'] = $row ['APP_THREAD_STATUS'];
          $aRow ['DEL_DELAYED'] = $row ['DEL_DELAYED'];
          $aRow ['DEL_DELAY_DURATION'] = $row ['DEL_DELAY_DURATION'];
          $aRow ['DEL_DELEGATE_DATE'] = $row ['DEL_DELEGATE_DATE'];
          $aRow ['DEL_DURATION'] = $row ['DEL_DURATION'];
          $aRow ['DEL_FINISHED'] = (isset ($row ['DEL_FINISH_DATE']) && $row ['DEL_FINISH_DATE'] != '') ? 1 : 0;
          $aRow ['DEL_FINISH_DATE'] = $row ['DEL_FINISH_DATE'];
          $aRow ['DEL_INDEX'] = $row ['DEL_INDEX'];
          $aRow ['DEL_INIT_DATE'] = $row ['DEL_INIT_DATE'];
          $aRow ['DEL_QUEUE_DURATION'] = $row ['DEL_QUEUE_DURATION'];
          $aRow ['DEL_STARTED'] = (isset ($row ['DEL_INIT_DATE']) && $row ['DEL_INIT_DATE'] != '') ? 1 : 0;
          $aRow ['DEL_TASK_DUE_DATE'] = $row ['DEL_TASK_DUE_DATE'];
          $aRow ['DEL_THREAD_STATUS'] = $row ['DEL_THREAD_STATUS'];
          $aRow ['PREVIOUS_USR_UID'] = $row ['PREVIOUS_USR_UID'];
          $aRow ['TAS_UID'] = $row ['TAS_UID'];
          $aRow ['USR_UID'] = $userUid;
          $aRow ['DEL_PRIORITY'] = G::LoadTranslation("ID_PRIORITY_{$aPriorities[$aRow['DEL_PRIORITY']]}");
          
          $rows [] = $aRow;
        }

      }
      $result ['data'] = $rows;
      $result ['success'] = true;
      $result ['result'] = true;
      $result ['message'] = "";

      //var_dump($result);
      
      /*********************************************/
      if($this->debug)
      {
        $this->afterPrepareResultTime = microtime (true);
        
        $fh = fopen("SolrSearchTime.txt", 'a') or die("can't open file to store Solr search time.");
        //fwrite($fh, sprintf("Solr Query time: %s DB Query time: %s Prepare result time: %s \n", gmdate ('H:i:s:u', ($this->afterSolrQueryTime - $this->initTimeAll)), gmdate ('H:i:s:u', ($this->afterDbQueryTime - $this->afterSolrQueryTime)), gmdate ('H:i:s:u', ($this->afterPrepareResultTime - $this->afterDbQueryTime))  ));
        fwrite($fh, sprintf("Solr Query time: %s DB Query time: %s Prepare result time: %s Total:%s \r\n", ($this->afterSolrQueryTime - $this->initTimeAll), ($this->afterDbQueryTime - $this->afterSolrQueryTime), ($this->afterPrepareResultTime - $this->afterDbQueryTime), ($this->afterPrepareResultTime - $this->initTimeAll)  ));
        fclose($fh);
      } 
      /***************************************/     
      
      return $result;
    
    } // end try
    catch ( InvalidIndexSearchTextException $ex ) {
      // return empty result with description of error
      $result = array ();
      $result ['totalCount'] = 0;
      $result ['data'] = array ();
      $result ['success'] = true;
      $result ['result'] = false;
      $result ['message'] = $ex->getMessage ();
      return $result;
    }
  }
  
  /**
   * Get the array of counters of cases
   *
   * @param string $userUid
   *          the current logged user uid identifier
   */
  public function getCasesCount($userUid)
  {
    $casesCount = array ();

    // get number of records in todo list
    $data = $this->getAppGridData ($userUid, 0, 0, 'todo', null, null, null, null, null, 
        null, null, null, null, null, null, true);
    $casesCount ['to_do'] = $data ['totalCount'];
    // get number of records in participated list
    $data = $this->getAppGridData ($userUid, 0, 0, 'sent', null, null, null, null, null, 
        null, null, null, null, null, null, true);
    $casesCount ['sent'] = $data ['totalCount'];
    // get number of records in draft list
    $data = $this->getAppGridData ($userUid, 0, 0, 'draft', null, null, null, null, null, 
        null, null, null, null, null, null, true);
    $casesCount ['draft'] = $data ['totalCount'];
    // get number of records in unassigned list
    $data = $this->getAppGridData ($userUid, 0, 0, 'unassigned', null, null, null, null, 
        null, null, null, null, null, null, null, true);
    $casesCount ['selfservice'] = $data ['totalCount'];
    $data = $this->getAppGridData ($userUid, 0, 0, 'paused', null, null, null, null, 
        null, null, null, null, null, null, null, true);
    $casesCount ['paused'] = $data ['totalCount'];

    return $casesCount;
  }
  
  /**
   * Get the user groups
   * @param string $usrUID the user identifier 
   * @return array of user groups
   */
  public function getUserGroups($usrUID)
  {
    $gu = new GroupUser ();
    $rows = $gu->getAllUserGroups ($usrUID);
    return $rows;
  }
  
  /**
   * Get the application delegation record from database
   *
   * @param string $aappUIDs
   *          array of Application identifiers
   * @return array of arrays with delegation information.
   */
  public function getListApplicationDelegationData($aappUIDs)
  {
  
    $c = new Criteria ();

    $c->addSelectColumn (ApplicationPeer::APP_CREATE_DATE);
    $c->addSelectColumn (ApplicationPeer::APP_NUMBER);
    $c->addSelectColumn (ApplicationPeer::APP_STATUS);
    $c->addSelectColumn (ApplicationPeer::APP_UPDATE_DATE);
    $c->addSelectColumn (ApplicationPeer::PRO_UID);

    $c->addSelectColumn (AppDelegationPeer::APP_UID);
    $c->addSelectColumn (AppDelegationPeer::DEL_INDEX);
  
    $c->addAsColumn ('USR_NAME', 'u.USR_FIRSTNAME');
    $c->addAsColumn ('USR_LAST', 'u.USR_LASTNAME');
  
    $c->addAsColumn ('USR_PREV_NAME', 'uprev.USR_FIRSTNAME');
    $c->addAsColumn ('USR_PREV_LAST', 'uprev.USR_LASTNAME');
    $c->addAsColumn ('PREVIOUS_USR_UID', 'uprev.USR_UID');
  
    $c->addAsColumn ('APP_TAS_TITLE', TaskPeer::TAS_TITLE);
    $c->addAsColumn ('APP_THREAD_STATUS', 'at.APP_THREAD_STATUS');
  
    $c->addSelectColumn (AppDelegationPeer::APP_OVERDUE_PERCENTAGE);
  
    $c->addSelectColumn (AppDelegationPeer::DEL_DELAYED);
    $c->addSelectColumn (AppDelegationPeer::DEL_DELAY_DURATION);
    $c->addSelectColumn (AppDelegationPeer::DEL_DELEGATE_DATE);
    $c->addSelectColumn (AppDelegationPeer::DEL_DURATION);
    $c->addSelectColumn (AppDelegationPeer::DEL_FINISH_DATE);
    $c->addSelectColumn (AppDelegationPeer::DEL_INIT_DATE);
    $c->addSelectColumn (AppDelegationPeer::DEL_QUEUE_DURATION);
    $c->addSelectColumn (AppDelegationPeer::DEL_TASK_DUE_DATE);
    $c->addSelectColumn (AppDelegationPeer::DEL_THREAD_STATUS);
    $c->addSelectColumn (AppDelegationPeer::TAS_UID);
  
    $c->addAlias ('u', 'USERS');
    $c->addAlias ('uprev', 'USERS');
    $c->addAlias ('adprev', 'APP_DELEGATION');
    $c->addAlias ('at', 'APP_THREAD');
  
    $aConditions = array ();
    $aConditions [] = array (
        AppDelegationPeer::APP_UID,
        ApplicationPeer::APP_UID
    );
    $c->addJoinMC ($aConditions, Criteria::JOIN);

    $aConditions = array ();
    $aConditions [] = array (
        AppDelegationPeer::USR_UID,
        'u.USR_UID'
    );
    $c->addJoinMC ($aConditions, Criteria::LEFT_JOIN);
  
    $aConditions = array ();
    $aConditions [] = array (
        AppDelegationPeer::APP_UID,
        'adprev.APP_UID'
    );
    $aConditions [] = array (
        AppDelegationPeer::DEL_PREVIOUS,
        'adprev.DEL_INDEX'
    );
    $c->addJoinMC ($aConditions, Criteria::LEFT_JOIN);

    $c->addJoin(AppDelegationPeer::TAS_UID, TaskPeer::TAS_UID);

    $aConditions = array ();
    $aConditions [] = array (
        'adprev.USR_UID',
        'uprev.USR_UID'
    );
    $c->addJoinMC ($aConditions, Criteria::LEFT_JOIN);
  
    $aConditions = array ();
    $aConditions [] = array (
        AppDelegationPeer::APP_UID,
        'at.APP_UID'
    );
    $aConditions [] = array (
        AppDelegationPeer::DEL_THREAD,
        'at.APP_THREAD_INDEX'
    );
    $c->addJoinMC ($aConditions, Criteria::LEFT_JOIN);
  
    $c->add (AppDelegationPeer::APP_UID, $aappUIDs, Criteria::IN );
    //$c->add (AppDelegationPeer::DEL_INDEX, $delIndex);

    $rs = AppDelegationPeer::doSelectRS ($c);
    $rs->setFetchmode (ResultSet::FETCHMODE_ASSOC);
    // echo $c->toString();
    $rs->next ();
    $row = $rs->getRow ();
    
    $appDataRows = array ();
    while (is_array ($row)) {
      $appDataRows [] = $row;
      $rs->next ();
      $row = $rs->getRow ();
    }    

    //Propel::close();
  
    return $appDataRows;
  }
    
  /**
   * Get the application delegation record from database
   *
   * @param string $appUID
   *          Application identifier
   * @param string $delIndex
   *          delegation index
   * @return array with delegation record.
   */
  public function getAppDelegationData($appUID, $delIndex)
  {
    
    $c = new Criteria ();
    
    $c->addSelectColumn (AppDelegationPeer::APP_UID);
    $c->addSelectColumn (AppDelegationPeer::DEL_INDEX);
    
    $c->addAsColumn ('USR_NAME', 'u.USR_FIRSTNAME');
    $c->addAsColumn ('USR_LAST', 'u.USR_LASTNAME');
    
    $c->addAsColumn ('USR_PREV_NAME', 'uprev.USR_FIRSTNAME');
    $c->addAsColumn ('USR_PREV_LAST', 'uprev.USR_LASTNAME');
    $c->addAsColumn ('PREVIOUS_USR_UID', 'uprev.USR_UID');
    
    $c->addAsColumn ('APP_TAS_TITLE', TaskPeer::TAS_TITLE);
    $c->addAsColumn ('APP_THREAD_STATUS', 'at.APP_THREAD_STATUS');
    
    $c->addSelectColumn (AppDelegationPeer::APP_OVERDUE_PERCENTAGE);
    
    $c->addSelectColumn (AppDelegationPeer::DEL_DELAYED);
    $c->addSelectColumn (AppDelegationPeer::DEL_DELAY_DURATION);
    $c->addSelectColumn (AppDelegationPeer::DEL_DELEGATE_DATE);
    $c->addSelectColumn (AppDelegationPeer::DEL_DURATION);
    $c->addSelectColumn (AppDelegationPeer::DEL_FINISH_DATE);
    $c->addSelectColumn (AppDelegationPeer::DEL_INIT_DATE);
    $c->addSelectColumn (AppDelegationPeer::DEL_QUEUE_DURATION);
    $c->addSelectColumn (AppDelegationPeer::DEL_TASK_DUE_DATE);
    $c->addSelectColumn (AppDelegationPeer::DEL_THREAD_STATUS);
    $c->addSelectColumn (AppDelegationPeer::TAS_UID);
    
    $c->addAlias ('u', 'USERS');
    $c->addAlias ('uprev', 'USERS');
    $c->addAlias ('adprev', 'APP_DELEGATION');
    $c->addAlias ('at', 'APP_THREAD');
    
    $aConditions = array ();
    $aConditions [] = array (
        AppDelegationPeer::USR_UID,
        'u.USR_UID' 
    );
    $c->addJoinMC ($aConditions, Criteria::LEFT_JOIN);
    
    $aConditions = array ();
    $aConditions [] = array (
        AppDelegationPeer::APP_UID,
        'adprev.APP_UID' 
    );
    $aConditions [] = array (
        AppDelegationPeer::DEL_PREVIOUS,
        'adprev.DEL_INDEX' 
    );
    $c->addJoinMC ($aConditions, Criteria::LEFT_JOIN);

    $c->addJoin(AppDelegationPeer::TAS_UID, TaskPeer::TAS_UID);

    $aConditions = array ();
    $aConditions [] = array (
        'adprev.USR_UID',
        'uprev.USR_UID' 
    );
    $c->addJoinMC ($aConditions, Criteria::LEFT_JOIN);
    
    $aConditions = array ();
    $aConditions [] = array (
        AppDelegationPeer::APP_UID,
        'at.APP_UID' 
    );
    $aConditions [] = array (
        AppDelegationPeer::DEL_THREAD,
        'at.APP_THREAD_INDEX' 
    );
    $c->addJoinMC ($aConditions, Criteria::LEFT_JOIN);
    
    $c->add (AppDelegationPeer::APP_UID, $appUID);
    $c->add (AppDelegationPeer::DEL_INDEX, $delIndex);

    $rs = AppDelegationPeer::doSelectRS ($c);
    $rs->setFetchmode (ResultSet::FETCHMODE_ASSOC);
    // echo $c->toString();
    $rs->next ();
    $row = $rs->getRow ();

    //Propel::close();
    
    return $row;
  }
  
  /**
   * return the correct search text for solr.
   * if a field is included only search in this field.
   *
   * @param string $plainSearchText          
   * @return string formated Solr search string.
   */
  public function getSearchText($plainSearchText)
  {
    $formattedSearchText = "";
    // if an error is found in string null is returned
    $includeToken = true;
    
    // prepare string to separate and join parentesis
    // " " => " "
    $count = 1;
    while ($count > 0) {
      $plainSearchText = preg_replace ('/\s\s+/', ' ', $plainSearchText, - 1, $count);
    }
    // "text0( text1" => "text0 (text1"; "text0 )text1" => "text0) text1";
    $plainSearchText = preg_replace ('/\s\[\s/', '[', $plainSearchText);
    $plainSearchText = preg_replace ('/\s\]\s/', '] ', $plainSearchText);
    $plainSearchText = preg_replace ('/\s"\s/', '" ', $plainSearchText);
    
    // print "format search string: " . $plainSearchText . "\n";
    // format
    // 1: plain text that is used to search in text field: concat field
    // 2: a field is specified [field_name]:["phrase search"]
    // [field_name]:["phrase search"] [field_name]:[word_search] word_search
    // "phrase search"
    // to scape a reserved character use a double value: "::", """"
    // ex: (APP_ASSIGNED_USERS:7091676694d9269da75c254003021135) AND
    // (contrato_t:76* AND Causal_t:1021 AND Materiales AND 143073)
    // ex: date search => APP_CREATE_DATE:[2012-03-12T00:00:00Z TO
    // 2012-04-12T00:00:00Z]
    // ex: phrase => TEXT:"This is a lazy dog"
    
    // search the first
    
    // cache the index fields
    //G::LoadClass ('PMmemcached');
    //$oMemcache = PMmemcached::getSingleton ($this->_solrInstance);
    //$ListFieldsInfo = $oMemcache->get ('Solr_Index_Fields');
    //if (! $ListFieldsInfo) {
      G::LoadClass ('searchIndex');
      
      $searchIndex = new BpmnEngine_Services_SearchIndex ($this->_solrIsEnabled, $this->_solrHost);
      // execute query
      $ListFieldsInfo = $searchIndex->getIndexFields ($this->_solrInstance);
      
      //var_dump($ListFieldsInfo);
      // cache
      //$oMemcache->set ('Solr_Index_Fields', $ListFieldsInfo);
    
    //}
    
    $tok = strtok ($plainSearchText, " ");
    
    while ($tok !== false) {
      $fieldName = substr ($tok, 0, strpos ($tok, ":")); // strstr ( $tok,
                                                             // ":",
                                                             // true ); php 5.3
      $searchText = strstr ($tok, ":");
      
      // verify if there's a field definition
      if ($fieldName === false || $fieldName == "") {
        // it's not a field
        // the token is not a field
        // add it completelly
        $includeToken = true;
        // no field found
        $formattedSearchText .= $tok; // used to search in the general default
                                        // text field
      }
      else {
        // it's a field
        // verify if is complete
        if ($fieldName == "" || $searchText == ":") {
          $includeToken = false;
          throw new InvalidIndexSearchTextException (" Invalid search text, verify the syntax. Expected format = {variable_name}:{search_text}");
        }
        
        // field name found
        // search index field name
        $indexFieldName = "";
        if (array_key_exists ($fieldName, $ListFieldsInfo)) {
          $indexFieldName = $ListFieldsInfo [$fieldName];
        }
        else {
          // no field name found
          // don't include field search
          // return message about it
          $includeToken = false;
          throw new InvalidIndexSearchTextException (" Invalid search text, variable not found.");
        }
        
        // The token is part of a phrase, date or a word?
        if ($searchText [1] == "[" || $searchText [1] == "\"") { //
                                                                 // expecting
                                                                 // date
                                                                 // interval
                                                                 // we must
                                                                 // search
                                                                 // the end of
                                                                 // the
                                                                 // phrase
                                                                 
          // the phrase is complete?
          if ($searchText [1] == "[" && $searchText [strlen ($searchText) - 1] == "]") {
            // complete phrase ok, the date must be validated
            // throw new InvalidIndexSearchTextException("Invalid search text.
            // Expected date interval format =>
            // {variable_name}:[YYYY-MM-DDThh:mm:ssZ TO YYYY-MM-DDThh:mm:ssZ]");
          }
          elseif ($searchText [1] == "\"" && $searchText [strlen ($searchText) - 1] == "\"") {
            // the phrase is complete and is ok.
          }
          else {
            // search end of phrase
            $tok = strtok (" ");
            $found = false;
            while ($tok !== false) {
              if ((($searchText [1] == "[") && ($tok [strlen ($tok) - 1] == "]")) || (($searchText [1] == "\"") && ($tok [strlen ($tok) - 1] == "\""))) {
                // end of phrase found
                $found = true;
                $searchText .= " " . $tok;
                break;
              }
              else {
                // continue adding text
                $searchText .= " " . $tok;
              }
              $tok = strtok (" ");
            }
            if (! $found) {
              // error invalid text
              // Expected date interval format => {variable_name}:[YYYY-MM-DDThh:mm:ssZ TO YYYY-MM-DDThh:mm:ssZ]
              throw new InvalidIndexSearchTextException ("Invalid search text. The date or phase is not completed"); 
            }
          }
        }

        // validate phrase in case of date
        if (($searchText [1] == "[")) {
            // validate date range format
            // use regular expresion to validate it [yyyy-mm-dd TO yyyy-mm-dd]
            $result1 = strpos($searchText, '-');
            if ($result1 !== false) {
                $result2 = strpos($searchText, 'TO');
                if ($result2 !== false) {
                    $reg = "/:\[(\d\d\d\d-\d\d-\d\d|\*)\sTO\s(\d\d\d\d-\d\d-\d\d|\*)\]/";
                    // convert date to utc
                    $matched = preg_match ($reg, $searchText, $matches);
                    if ($matched == 1) {
                        // the date interval is valid
                        // convert to SOlr format
                        $fromDateOriginal = $matches [1];
                        $fromDate = $matches [1];
                        $toDateOriginal = $matches [2];
                        $toDate = $matches [2];
                        if ($fromDateOriginal != '*') {
                            $fromDate = gmdate ("Y-m-d\T00:00:00\Z", strtotime ($fromDateOriginal));
                        }
                        if ($toDateOriginal != '*') {
                            // list($year, $month, $day) = sscanf($fromDateOriginal,
                            // '%04d/%02d/%02d');
                            // $toDateDatetime = new DateTime($toDateOriginal);
                            // $toDateDatetime = date_create_from_format ( 'Y-m-d',
                            // $toDateOriginal );
                            $toDate = gmdate ("Y-m-d\T23:59:59.999\Z", strtotime ($toDateOriginal));
                        }
                        $searchText = ":[" . $fromDate . " TO " . $toDate . "]";
                    }
                } else {
                    $searchText = str_replace( "[", "", $searchText );
                    $searchText = str_replace( "]", "", $searchText );
                    $searchText = str_replace( ":", "", $searchText );
                    $searchText = ":[" . $searchText . "T00:00:00Z TO " . $searchText . "T23:59:59.999Z]";
                }
            }
        }

        // validate phrase in case of < and <=
        $result1 = strpos($searchText, '<');
        if($result1 !== false) {
            $result = strpos($searchText, '<=');
            if($result !== false) {
                $v1 = str_replace( '<=', '', $searchText );
                $v2 = str_replace( ':', '', $v1);
                $v3 = str_replace( '<','' ,':[* TO '.$v2.']' );
                $searchText = $v3;
            } else {
                $v1 = str_replace( '<', '', $searchText );
                $v2 = str_replace( ':', '', $v1);
                $v3 = (int) $v2-1;
                $v4 = str_replace( '<','' ,':[* TO '.$v3.']' );
                $searchText = $v4;
            }                    
        }
        // validate phrase in case of > and >=
        $result2 = strpos($searchText, '>');
        if($result2 !== false) {
            $result = strpos($searchText, '>=');
            if($result !== false) {
                $v1 = str_replace( '>=', '', $searchText );
                $v2 = str_replace( ':', '', $v1);
                $v3 = str_replace( '>','' ,':['.$v2.' TO *]' );
                $searchText = $v3;
            } else {
                $v1 = str_replace( '>', '', $searchText );
                $v2 = str_replace( ':', '', $v1 );
                $v3 = (int) $v2+1;
                $v4 = str_replace( '>','' ,':['.$v3.' TO *]' );
                $searchText = $v4;
            }
        }
        $formattedSearchText .= $indexFieldName . $searchText;
        $includeToken = true;
      }
      
      if ($includeToken)
        $formattedSearchText .= " AND ";
        
        // next token
      $tok = strtok (" ");
    }

    // remove last AND
    $formattedSearchText = substr_replace ($formattedSearchText, "", - 5);
    return $formattedSearchText;
  }
  
  /**
   * Get all the application delegation records from database
   *
   * @param string $appUID
   *          Application identifier
   * @return array delegation records
   */
  public function getApplicationDelegationsIndex($appUID)
  { 
    $delIndexes = array ();
    
    $c = new Criteria ();
    
    $c->addSelectColumn (AppDelegationPeer::DEL_INDEX);
    $c->add (AppDelegationPeer::APP_UID, $appUID);
    
    $rs = AppDelegationPeer::doSelectRS ($c);
    $rs->setFetchmode (ResultSet::FETCHMODE_ASSOC);
    
    $rs->next ();
    $row = $rs->getRow ();
    
    while (is_array ($row)) {
      $delIndexes [] = $row ['DEL_INDEX'];
      $rs->next ();
      $row = $rs->getRow ();
    }

    //Propel::close();
    
    return $delIndexes;
  
  }
  
  
  /**
   * Update the information of the specified applications in Solr
   *
   * @param array $aaAPPUIDs
   *          Array of arrays of App_UID that must be updated,
   *          APP_UID is permitted also
   */
  public function updateApplicationSearchIndex($aaAPPUIDs, $saveDBRecord = false)
  {
    if (empty ($aaAPPUIDs))
      return;

    if($this->debug)
    {
      //show app to reindex
      var_dump($aaAPPUIDs);
    }
    
    if (! is_array ($aaAPPUIDs)) {
      // convert to array
      $APPUID = $aaAPPUIDs;
      $aaAPPUIDs = array ();
      $aaAPPUIDs [] = array (
          'APP_UID' => $APPUID 
      );
    }

    if($this->debug)
    {
      //show app to reindex
      var_dump($aaAPPUIDs);
    }

    try{    
    
      // check if index server is available
      /*
      if ($saveDBRecord) {
        if($this->isSolrEnabled()){
          //store update in table but with status updated
          foreach ($aaAPPUIDs as $aAPPUID) {
            $this->applicationChangedUpdateSolrQueue ($aAPPUID ['APP_UID'], 0);
          }
        }
        else{
          // store update in table and return
          foreach ($aaAPPUIDs as $aAPPUID) {
            $this->applicationChangedUpdateSolrQueue ($aAPPUID ['APP_UID'], true);
          }
          return;  
        }
        
      }*/
      
      
      if($this->debug)
      {
        $this->getApplicationDataDBTime = 0;
        $this->getPreparedApplicationDataDBTime = 0;
        $this->getBuilXMLDocTime = 0;
        $this->afterUpdateSolrXMLDocTime = 0;

        $this->beforeCreateSolrXMLDocTime = microtime (true);

      }    
      // create XML document
      $xmlDoc = $this->createSolrXMLDocument ($aaAPPUIDs);
        
      if($this->debug )
      {
        $this->afterCreateSolrXMLDocTime = microtime (true);
      }
      // update document
      $data = array (
          'workspace' => $this->_solrInstance,
          'document' => $xmlDoc 
      );
      $oSolrUpdateDocument = Entity_SolrUpdateDocument::createForRequest ($data);
      
      G::LoadClass ('searchIndex');
      
      $oSearchIndex = new BpmnEngine_Services_SearchIndex ($this->_solrIsEnabled, $this->_solrHost);

      $oSearchIndex->updateIndexDocument ($oSolrUpdateDocument);
          
      if($this->debug)
      {
        $this->afterUpdateSolrXMLDocTime = microtime (true);
      }      
      // commit changes no required because of the commitwithin option
      //$oSearchIndex->commitIndexChanges ($this->_solrInstance);
      //change status in db to indexed
        if ($saveDBRecord) {
            foreach ($aaAPPUIDs as $aAPPUID) {
                $this->applicationChangedUpdateSolrQueue ($aAPPUID ['APP_UID'], 0);
            }
        }

    }
    catch(Exception $ex) {
      //echo $ex->getMessage();
      //echo $ex->getTraceAsString();
      $appuidsString = " ";
      //register all the appuids that can't be indexed
      foreach ($aaAPPUIDs as $aAPPUID) {
        $this->applicationChangedUpdateSolrQueue ($aAPPUID ['APP_UID'], true);
        $appuidsString .=  $aAPPUID ['APP_UID'] . ", ";
      }
      //print "Excepcion indexing data: " . $ex->getMessage() . "\n"; die;
        $fh = fopen("./SolrIndexErrors.txt", 'a') or die("can't open file to store Solr index errors.");
        fwrite($fh, date('Y-m-d H:i:s:u') . ":" . $appuidsString . $ex->getMessage() . "\r\n");
        fclose($fh);
    }
    if($this->debug)
    {

      //$this->afterCommitSolrDocTime = microtime (true);
    
      $fh = fopen("SolrIndexTime.txt", 'a') or die("can't open file to store Solr index time.");
      //fwrite($fh, sprintf("Solr Query time: %s DB Query time: %s Prepare result time: %s \n", gmdate ('H:i:s:u', ($this->afterSolrQueryTime - $this->initTimeAll)), gmdate ('H:i:s:u', ($this->afterDbQueryTime - $this->afterSolrQueryTime)), gmdate ('H:i:s:u', ($this->afterPrepareResultTime - $this->afterDbQueryTime))  ));
      $trunkSize = count($aaAPPUIDs);
      $this->trunkSizeAcumulated += $trunkSize;
      $this->totalTimeAcumulated += ($this->afterUpdateSolrXMLDocTime - $this->beforeCreateSolrXMLDocTime);

      //Solr App trunk size| Get Data from DB (s)| Prepare DB data (s) | Create XML file (s)| Create XML Document total (s)| Update Solr Document (s)
      fwrite($fh, sprintf("%s|%s|%s|%s|%s|%s|%s|%s\r\n", 
        $this->trunkSizeAcumulated,
        $this->totalTimeAcumulated,
        $this->getApplicationDataDBTime, 
        $this->getPreparedApplicationDataDBTime, 
        $this->getBuilXMLDocTime,
        ($this->afterCreateSolrXMLDocTime - $this->beforeCreateSolrXMLDocTime), 
        ($this->afterUpdateSolrXMLDocTime - $this->afterCreateSolrXMLDocTime),
        ($this->afterUpdateSolrXMLDocTime - $this->beforeCreateSolrXMLDocTime)
        ));

      fclose($fh);

      /*
      fwrite($fh, sprintf("Solr App trunk size: %s => Create XML Document total (s): %s, Update Solr Document (s): %s, Total (s):%s \r\n", 
        $trunkSize, ($this->afterCreateSolrXMLDocTime - $this->beforeCreateSolrXMLDocTime), ($this->afterUpdateSolrXMLDocTime - $this->afterCreateSolrXMLDocTime), 
        ($this->afterUpdateSolrXMLDocTime - $this->beforeCreateSolrXMLDocTime)));
      fclose($fh);
      $fh = fopen("SolrIndexTime.txt", 'a') or die("can't open file to store Solr index time.");
      fwrite($fh, sprintf("APP range => Get Data from DB (s): %s, Prepare DB data (s): %s, Create XML file(s): %s \r\n", 
        $this->getApplicationDataDBTime, $this->getPreparedApplicationDataDBTime, $this->getBuilXMLDocTime ));
      fclose($fh);*/
          
    }    
  }
  
  /**
   * Delete the specified application record from Solr
   *
   * @param string $aaAPPUIDs
   *          array of arrays of Application identifiers format:$aaAPPUIDs [] = array ('APP_UID' => '...') 
   */
  public function deleteApplicationSearchIndex($aaAPPUIDs, $saveDBRecord = false)
  {
    if (empty ($aaAPPUIDs))
      return;


    if (! is_array ($aaAPPUIDs)) {
      // convert to array
      $APPUID = $aaAPPUIDs;
      $aaAPPUIDs = array ();
      $aaAPPUIDs [] = array (
          'APP_UID' => $APPUID 
      );
    }    

    /*
    if ($saveDBRecord) {
      if($this->isSolrEnabled()){
        //store update in table but with status updated
        foreach ($aaAPPUIDs as $aAPPUID) {
          $this->applicationChangedUpdateSolrQueue ($aAPPUID ['APP_UID'], 0);
        }
      }
      else{
        // store update in table and return
        foreach ($aaAPPUIDs as $aAPPUID) {
          $this->applicationChangedUpdateSolrQueue ($aAPPUID ['APP_UID'], 2);
        }
        return;  
      }        
    }*/
    
    try{ 
    
      G::LoadClass ('searchIndex');

      $oSearchIndex = new BpmnEngine_Services_SearchIndex ($this->_solrIsEnabled, $this->_solrHost);

      foreach ($aaAPPUIDs as $aAPPUID) {
        $idQuery = "APP_UID:" . $aAPPUID ['APP_UID'];

        $oSearchIndex->deleteDocumentFromIndex ($this->_solrInstance, $idQuery);

      }

      if ($saveDBRecord) {
        foreach ($aaAPPUIDs as $aAPPUID) {
          $this->applicationChangedUpdateSolrQueue ($aAPPUID ['APP_UID'], 0);
        }      
      }
    }
    catch(Exception $ex) {
      //register all the appuids that can't be indexed
      $appuidsString = " ";
      foreach ($aaAPPUIDs as $aAPPUID) {
        $this->applicationChangedUpdateSolrQueue ($aAPPUID ['APP_UID'], 2);
        $appuidsString .=  $aAPPUID ['APP_UID'] . ", ";
      }
      //print "Excepcion indexing data: " . $ex->getMessage() . "\n"; die;
      $fh = fopen("./SolrIndexErrors.txt", 'a') or die("can't open file to store Solr index errors.");
      fwrite($fh, date('Y-m-d H:i:s:u') . ":" . $appuidsString . $ex->getMessage() . "\r\n");
      fclose($fh);
    }

    // commit changes
    //$oSearchIndex->commitIndexChanges ($this->_solrInstance);
  }
  
  /**
   * Create XML data in Solr format of the specified applications
   * this function uses the buildSearchIndexDocumentPMOS2 function to create
   * each record
   *
   * @param array $aaAPPUIDs
   *          array of arrays of application identifiers
   * @return string The resulting XML document in Solr format
   */
  public function createSolrXMLDocument($aaAPPUIDs)
  {
    if($this->debug)
    {
      $this->getApplicationDataDBTime = 0;
      $this->getPreparedApplicationDataDBTime = 0;
      $this->getBuilXMLDocTime = 0;
    }
    // search data from DB
    $xmlDoc = "<?xml version='1.0' encoding='UTF-8'?>\n";
    $xmlDoc .= "<add>\n";
    
    //get all application data from DB of all applications and delegations
    $aAPPUIDs = array();
    foreach($aaAPPUIDs as $aAPPUID) {
      $aAPPUIDs[] =$aAPPUID ['APP_UID'];
    }
    if($this->debug)
    {
      $this->beforeGetApplicationDataDBTime = microtime (true);
    }
    $aaAllAppDelData = $this->getListApplicationUpdateDelegationData($aAPPUIDs);
    if($this->debug)
    {
      $this->afterGetApplicationDataDBTime = microtime (true);
    
      $this->getApplicationDataDBTime = $this->afterGetApplicationDataDBTime - $this->beforeGetApplicationDataDBTime;
    }
    foreach ($aaAPPUIDs as $aAPPUID) {
      try {
        
        if($this->debug)
        {
          $this->beforePrepareApplicationDataDBTime = microtime (true);
        }        
        //filter data, include all the rows of the application
        // get delegation data from DB
        $aaAppData = array();
        //filter data from db
        $indexes = $this->aaSearchRecords ($aaAllAppDelData, array (
            'APP_UID' => $aAPPUID ['APP_UID']
        ));
        
        foreach ($indexes as $index) {
          $aaAppData[] = $aaAllAppDelData [$index];
        }

        $result = $this->getApplicationIndexData ($aAPPUID ['APP_UID'], $aaAppData);
        
        if($this->debug)
        {
          $this->afterPrepareApplicationDataDBTime = microtime (true);
        
          $this->getPreparedApplicationDataDBTime += $this->afterPrepareApplicationDataDBTime - $this->beforePrepareApplicationDataDBTime;
        }
        
      }
      catch ( ApplicationWithoutDelegationRecordsException $ex ) {
        // exception trying to get application information
        // skip and continue with the next application
        $fh = fopen("./SolrIndexErrors.txt", 'a') or die("can't open file to store Solr index errors.");
        fwrite($fh, date('Y-m-d H:i:s:u') . " " . $ex->getMessage());
        fclose($fh);        
        continue;
      }
      catch( ApplicationWithCorruptDynaformException $ex) {
        $fh = fopen("./SolrIndexErrors.txt", 'a') or die("can't open file to store Solr index errors.");
        fwrite($fh, date('Y-m-d H:i:s:u') . " " . $ex->getMessage());
        fclose($fh);
        continue;        
      }
      catch (Exception $ex) {
        $fh = fopen("./SolrIndexErrors.txt", 'a') or die("can't open file to store Solr index errors.");
        fwrite($fh, date('Y-m-d H:i:s:u') . " " . "getApplicationIndexData " . $aAPPUID['APP_UID'] . ":" . $ex->getMessage() . "\n");
        fclose($fh);
        continue;        
      }
      /*$documentInformation,
   *         $dynaformFieldTypes,
   *         $lastUpdateDate,
   *         $maxPriority,
   *         $delLastIndex,
   *         $assignedUsers,
   *         $assignedUsersRead,
   *         $assignedUsersUnread,
   *         $draftUser,
   *         $participatedUsers,
   *         $participatedUsersStartedByUser,
   *         $participatedUsersCompletedByUser,
   *         $unassignedUsers,
   *         $unassignedGroups */
      $documentInformation = $result [0];
      $dynaformFieldTypes = $result [1];
      $lastUpdateDate = $result [2];
      $maxPriority = $result [3];
      $delLastIndex = $result [4];
      $assignedUsers = $result [5];
      $assignedUsersRead = $result [6];
      $assignedUsersUnread = $result [7];
      $draftUser = $result [8];
      $participatedUsers = $result [9];
      $participatedUsersStartedByUser = $result [10];
      $participatedUsersCompletedByUser = $result [11];
      $unassignedUsers = $result [12];
      $unassignedGroups = $result [13];
      $pausedtUser = $result [14];

      try {
        
        // create document
        $xmlCurrentDoc = $this->buildSearchIndexDocumentPMOS2 ($documentInformation, $dynaformFieldTypes, 
            $lastUpdateDate, $maxPriority, $delLastIndex, $assignedUsers, $assignedUsersRead, $assignedUsersUnread, 
            $draftUser, $participatedUsers, $participatedUsersStartedByUser, $participatedUsersCompletedByUser, 
            $unassignedUsers, $unassignedGroups,$pausedtUser);

        //concat doc to the list of docs
        $xmlDoc .= $xmlCurrentDoc;
        
        if($this->debug)
        {
          $this->afterBuilXMLDocTime = microtime (true);
          
          $this->getBuilXMLDocTime += $this->afterBuilXMLDocTime - $this->afterPrepareApplicationDataDBTime; 
        }        
      }
      catch ( ApplicationAPP_DATAUnserializeException $ex ) {
        // exception trying to get application information
        $fh = fopen("./SolrIndexErrors.txt", 'a') or die("can't open file to store Solr index errors.");
        fwrite($fh, date('Y-m-d H:i:s:u') . " " . $ex->getMessage());
        fclose($fh);
        // skip and continue with the next application
        continue;
      }
      catch (Exception $ex) {
        $fh = fopen("./SolrIndexErrors.txt", 'a') or die("can't open file to store Solr index errors.");
        fwrite($fh, date('Y-m-d H:i:s:u') . " " . "buildSearchIndexDocumentPMOS2 " . $aAPPUID['APP_UID'] . ":" . $ex->getMessage() . "\n");
        fclose($fh);
        continue;
      }

      if($this->debugAppInfo)
      {
        $fh = fopen("SolrAPPUIDIndexSize.txt", 'a') or die("can't open file to store Solr index time.");
        //fwrite($fh, sprintf("APP UID %s => doc size: %s\r\n", 
        //  $aAPPUID['APP_UID'], strlen($xmlCurrentDoc)));
        fwrite($fh, sprintf("%s|%s|%s\r\n", 
          $documentInformation ['APP_NUMBER'], $aAPPUID['APP_UID'], strlen($xmlCurrentDoc)));
        fclose($fh);
      }

    
    }//End foreach APPUID
    
    $xmlDoc .= "</add>\n";

    /*
    if($this->debug)
    {
      $fh = fopen("SolrIndexTime.txt", 'a') or die("can't open file to store Solr index time.");
      fwrite($fh, sprintf("APP range => Get Data from DB (s): %s, Prepare DB data (s): %s, Create XML file(s): %s \r\n", 
        $this->getApplicationDataDBTime, $this->getPreparedApplicationDataDBTime, $this->getBuilXMLDocTime ));
      fclose($fh);
    }*/
        
    return $xmlDoc;
  }
  
  /**
   * build Solr index document xml for an application
   * @gearman = false
   * @rest = false
   * @background = false
   *
   * @param
   *          [in] array $documentData array of data for the xml document of
   *          application
   * @param
   *          [in] array $dynaformFieldTypes array of dynaform field types, used
   *          to store the info of APP_DATA with types
   * @param
   *          [in] array $appTitles array of array of application titles in all
   *          languages
   * @param
   *          [in] array $proTitles array of array of process titles in all
   *          languages
   * @param
   *          [in] array $assignedUsers array of array of uids of assigned users
   *          to Application UIDs
   * @param
   *          [in] array $draftUsers array of array of uids of draft users to
   *          Application UIDs
   * @param
   *          [in] array $participatedUsers array of array of participated users
   *          UIDs in application
   * @param
   *          [in] array $unassignedUsers array of unassigned users UIDs
   * @param
   *          [in] array $unassignedGroups array of unassigned groups UIDs
   * @param
   *          [out] xml xml document
   *          
   *          $xmlDoc .= buildSearchIndexDocumentPMOS2($documentInformation,
   *          $dynaformFieldTypes,
   *          $lastUpdateDate, $maxPriority,
   *          $assignedUsers, $assignedUsersRead, $assignedUsersUnread,
   *          $draftUser,
   *          $participatedUsers, $participatedUsersStartedByUser,
   *          $participatedUsersCompletedByUser,
   *          $unassignedUsers, $unassignedGroups);*
   */
  public function buildSearchIndexDocumentPMOS2($documentData, $dynaformFieldTypes, $lastUpdateDate, 
    $maxPriority, $delLastIndex, $assignedUsers, $assignedUsersRead, $assignedUsersUnread, $draftUser, 
    $participatedUsers, $participatedUsersStartedByUser, $participatedUsersCompletedByUser, 
    $unassignedUsers, $unassignedGroups,$pausedtUser)
  {
    // build xml document
    
    $writer = new XMLWriter ();
    $writer->openMemory ();
    $writer->setIndent (4);
    
    $writer->startElement ("doc");
    
    $writer->startElement ("field");
    $writer->writeAttribute ('name', 'APP_UID');
    $writer->text ($documentData ['APP_UID']);
    $writer->endElement ();
    
    $writer->startElement ("field");
    $writer->writeAttribute ('name', 'APP_NUMBER');
    $writer->text ($documentData ['APP_NUMBER']);
    $writer->endElement ();
    
    $writer->startElement ("field");
    $writer->writeAttribute ('name', 'APP_STATUS');
    $writer->text ($documentData ['APP_STATUS']);
    $writer->endElement ();
    
    $writer->startElement ("field");
    $writer->writeAttribute ('name', 'PRO_UID');
    $writer->text ($documentData ['PRO_UID']);
    $writer->endElement ();
    
    if (! empty ($documentData ['APP_TITLE'])) {
      $writer->startElement ("field");
      $writer->writeAttribute ('name', 'APP_TITLE');
      $writer->text ($documentData ['APP_TITLE']);
      $writer->endElement ();
    }
    else {
      $writer->startElement ("field");
      $writer->writeAttribute ('name', 'APP_TITLE');
      $writer->text ("");
      $writer->endElement ();
    }
    
    if (! empty ($documentData ['PRO_TITLE'])) {
      $writer->startElement ("field");
      $writer->writeAttribute ('name', 'APP_PRO_TITLE');
      $writer->text ($documentData ['PRO_TITLE']);
      $writer->endElement ();
    
    }
    else {
      $writer->startElement ("field");
      $writer->writeAttribute ('name', 'APP_PRO_TITLE');
      $writer->text ("");
      $writer->endElement ();
    }
    
    $writer->startElement ("field");
    $writer->writeAttribute ('name', 'APP_CREATE_DATE');
    // convert date to UTC with gmdate
    $writer->text (gmdate ("Y-m-d\TH:i:s\Z", strtotime ($documentData ['APP_CREATE_DATE'])));
    $writer->endElement ();
    
    $writer->startElement ("field");
    $writer->writeAttribute ('name', 'DEL_LAST_UPDATE_DATE');
    // convert date to UTC with gmdate
    $writer->text (gmdate ("Y-m-d\TH:i:s\Z", strtotime ($lastUpdateDate)));
    $writer->endElement ();
    
    $writer->startElement ("field");
    $writer->writeAttribute ('name', 'DEL_MAX_PRIORITY');
    $writer->text ($maxPriority);
    $writer->endElement ();

    if (!empty($documentData["PRO_CATEGORY_UID"])) {
      $writer->startElement("field");
      $writer->writeAttribute("name", "PRO_CATEGORY_UID_s");
      $writer->text($documentData["PRO_CATEGORY_UID"]);
      $writer->endElement();
    }

    foreach ($delLastIndex as $lastIndex) {
      $writer->startElement ("field");
      $writer->writeAttribute ('name', 'DEL_LAST_INDEX');
      $writer->text ($lastIndex);
      $writer->endElement ();
    }
    
    if (is_array ($assignedUsers) && ! empty ($assignedUsers)) {
      foreach ($assignedUsers as $userUID) {
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_ASSIGNED_USERS');
        $writer->text ($userUID ['USR_UID']);
        $writer->endElement ();
        
        // add dynamic field for del_index information
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_ASSIGNED_USER_DEL_INDEX_' . trim ($userUID ['USR_UID']) . '_txt');
        $writer->text ($userUID ['DEL_INDEX']);
        $writer->endElement ();
      
      }
    }
    
    if (is_array ($assignedUsersRead) && ! empty ($assignedUsersRead)) {
      foreach ($assignedUsersRead as $userUID) {
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_ASSIGNED_USERS_READ');
        $writer->text ($userUID ['USR_UID']);
        $writer->endElement ();
        
        // add dynamic field for del_index information
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_ASSIGNED_USER_READ_DEL_INDEX_' . trim ($userUID ['USR_UID']) . '_txt');
        $writer->text ($userUID ['DEL_INDEX']);
        $writer->endElement ();
      }
    }
    
    if (is_array ($assignedUsersUnread) && ! empty ($assignedUsersUnread)) {
      foreach ($assignedUsersUnread as $userUID) {
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_ASSIGNED_USERS_UNREAD');
        $writer->text ($userUID ['USR_UID']);
        $writer->endElement ();
        
        // add dynamic field for del_index information
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_ASSIGNED_USER_UNREAD_DEL_INDEX_' . trim ($userUID ['USR_UID']) . '_txt');
        $writer->text ($userUID ['DEL_INDEX']);
        $writer->endElement ();
      }
    }
    
    if (! empty ($draftUser)) {
      $writer->startElement ("field");
      $writer->writeAttribute ('name', 'APP_DRAFT_USER');
      $writer->text ($draftUser ['USR_UID']);
      $writer->endElement ();
    }

    if (is_array ($participatedUsers) && ! empty ($participatedUsers)) {
      foreach ($participatedUsers as $userUID) {
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_PARTICIPATED_USERS');
        $writer->text ($userUID ['USR_UID']);
        $writer->endElement ();
        
        // add dynamic field for del_index information
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_PARTICIPATED_USER_DEL_INDEX_' . trim ($userUID ['USR_UID']) . '_txt');
        $writer->text ($userUID ['DEL_INDEX']);
        $writer->endElement ();
      }
    }
    
    if (is_array ($participatedUsersStartedByUser) && ! empty ($participatedUsersStartedByUser)) {
      foreach ($participatedUsersStartedByUser as $userUID) {
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_PARTICIPATED_USERS_STARTED');
        $writer->text ($userUID ['USR_UID']);
        $writer->endElement ();
        
        // add dynamic field for del_index information
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_PARTICIPATED_USER_STARTED_DEL_INDEX_' . trim ($userUID ['USR_UID']) . '_txt');
        $writer->text ($userUID ['DEL_INDEX']);
        $writer->endElement ();
      }
    }
    
    if (is_array ($participatedUsersCompletedByUser) && ! empty ($participatedUsersCompletedByUser)) {
      foreach ($participatedUsersCompletedByUser as $userUID) {
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_PARTICIPATED_USERS_COMPLETED');
        $writer->text ($userUID ['USR_UID']);
        $writer->endElement ();
        
        // add dynamic field for del_index information
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_PARTICIPATED_USER_COMPLETED_DEL_INDEX_' . trim ($userUID ['USR_UID']) . '_txt');
        $writer->text ($userUID ['DEL_INDEX']);
        $writer->endElement ();
      }
    }

    if (is_array ($unassignedUsers) && ! empty ($unassignedUsers)) {
      foreach ($unassignedUsers as $userUID) {
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_UNASSIGNED_USERS');
        $writer->text ($userUID ['USR_UID']);
        $writer->endElement ();
        
        // add dynamic field for del_index information
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_UNASSIGNED_USER_GROUP_DEL_INDEX_' . trim ($userUID ['USR_UID']) . '_txt');
        $writer->text ($userUID ['DEL_INDEX']);
        $writer->endElement ();
      }
    }
    
    if (is_array ($unassignedGroups) && ! empty ($unassignedGroups)) {
      foreach ($unassignedGroups as $groupUID) {
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_UNASSIGNED_GROUPS');
        $writer->text ($groupUID ['USR_UID']);
        $writer->endElement ();
        
        // add dynamic field for del_index information
        $writer->startElement ("field");
        $writer->writeAttribute ('name', 'APP_UNASSIGNED_USER_GROUP_DEL_INDEX_' . trim ($groupUID ['USR_UID']) . '_txt');
        $writer->text ($groupUID ['DEL_INDEX']);
        $writer->endElement ();
      }
    }
    if (! empty ($pausedtUser)) {
        foreach ($pausedtUser as $paused) {
            $writer->startElement ("field");
            $writer->writeAttribute ('name', 'APP_PAUSED_USERS');
            $writer->text ($paused ['USR_UID']);
            $writer->endElement ();

            $writer->startElement ("field");
            $writer->writeAttribute ('name', 'APP_PAUSED_USER_DEL_INDEX_' . trim ($paused ['USR_UID']) . '_txt');
            $writer->text ($paused ['DEL_INDEX']);
            $writer->endElement ();
        }
    }

    // get the serialized fields
    if (! empty ($documentData ['APP_DATA']) && $documentData ['APP_DATA'] != "N;" ) {
      
      $UnSerializedCaseData = unserialize ($documentData ['APP_DATA']);
      
      if ($UnSerializedCaseData === false) {
        $UnSerializedCaseData = preg_replace ('!s:(\d+):"(.*?)";!e', "'s:'.strlen('$2').':\"$2\";'", $documentData ['APP_DATA']); // utf8_encode
        $UnSerializedCaseData = unserialize ($UnSerializedCaseData);
      }
      
      if (! $UnSerializedCaseData) {
        // error unserializing
        throw new ApplicationAPP_DATAUnserializeException (date('Y-m-d H:i:s:u') .  " Could not unserialize APP_DATA of APP_UID: " . $documentData ['APP_UID'] . "\n");
      }
      else {
        foreach ($UnSerializedCaseData as $k => $value) {
            //This validation is only for the 'checkbox' control for the BPMN forms, 
            //the request is not made to the database to obtain the control 
            //associated with the variable so as not to decrease the performance.
            if (is_array($value) && count($value) === 1 && isset($value[0]) && !is_object($value[0]) && !is_array($value[0])) {
                $value = $value[0];
            }
          if (! is_array ($value) && ! is_object ($value) && $value != '' && $k != 'SYS_LANG' && $k != 'SYS_SKIN' && $k != 'SYS_SYS') {
            // search the field type in array of dynaform fields
            if (! empty ($dynaformFieldTypes) && array_key_exists (trim ($k), $dynaformFieldTypes)) {
              $type = $dynaformFieldTypes [trim ($k)];
              $typeSufix = '_t';
              switch ($type) {
                case 'text' :
                  $typeSufix = '_t';
                  break;
                case 'Int' :
                  if(intval ($value) > 2147483647) {
                    $typeSufix = '_tl'; //for long values
                    $value = intval ($value);
                  }
                  else {
                    $typeSufix = '_ti';
                    $value = str_replace( ',', '', $value );
                    $value = intval ($value);
                  }
                  break;
                case 'Real' :
                  $typeSufix = '_td';
                  $value = str_replace( ',', '', $value );
                  $value = floatval ($value);
                  break;
                case 'date' :
                  $newdate = false;
                  $withHour = true;
                  // try to convert string to date
                  // TODO convert to php 5.2 format
                  /*
                   * $newdate = date_create_from_format ( 'Y-m-d H:i:s', $value
                   * ); if (! $newdate) { $newdate = date_create_from_format (
                   * 'Y-m-d', $value ); $withHour = false; } if (! $newdate) {
                   * $newdate = date_create_from_format ( 'd/m/Y', $value );
                   * $withHour = false; } if (! $newdate) { $newdate =
                   * date_create_from_format ( 'j/m/Y', $value ); $withHour =
                   * false; }
                   */
                  $newdate = strtotime ($value);
                  if (! $newdate) {
                    $typeSufix = '*'; // not store field
                  }
                  else {
                    $typeSufix = '_tdt';
                    /*
                     * if ($withHour) //$value = gmdate ( "Y-m-d\TH:i:s\Z",
                     * $newdate->getTimestamp () ); $value = gmdate (
                     * "Y-m-d\TH:i:s\Z", $newdate ); else { $value = gmdate (
                     * "Y-m-d\T00:00:00\Z", $newdate ); }
                     */
                    $value = gmdate ("Y-m-d\T00:00:00\Z", $newdate);
                  }
                  break;
                case 'dropdown' :
                  $typeSufix = '_t';
                  break;
                case 'textarea' :
                  $typeSufix = '_t';
                  break;
                case 'currency' :
                  $typeSufix = '_td';
                  $value = floatval ($value);
                  break;
                case 'percentage' :
                  $typeSufix = '_t';
                  break;
                case 'password' :
                  $typeSufix = '_t';
                  break;
                case 'suggest' :
                  $typeSufix = '_t';
                  break;
                case 'yesno' :
                  $typeSufix = '_t';
                  break;
                case 'listbox' :
                  $typeSufix = '_t';
                  break;
                case 'checkbox' :
                  $typeSufix = '_t';
                  break;
                case 'checkgroup' :
                  $typeSufix = '_t';
                  break;
                case 'radiogroup' :
                  $typeSufix = '_t';
                  break;
                case 'hidden' :
                  $typeSufix = '_t';
                  break;
              }
              if ($typeSufix != '*') {
                $value = trim($value);
                $pairs = array(
                    "\x03" => "",
                    "\x04" => "",
                    "\x05" => "",
                    "\x06" => "",
                    "\x07" => "",
                    "\x08" => "",
                    "\x0E" => "",
                    "\x16" => "",
                    "\x00-" => "",
                    "\x09" => "",
                    "\x11" => "",
                    "\x12" => "",
                    "\x14-" => "",
                    "\x1f" => "",
                    "\x7f" => "",
                );
                $value = strtr($value, $pairs);
                $writer->startElement ("field");
                $writer->writeAttribute ('name', trim ($k) . $typeSufix);
                $writer->startCData ();
                $writer->text ($value);
                $writer->endCData();
                $writer->endElement ();
              }
            }
            else {
                $value = trim($value);
                $pairs = array(
                    "\x03" => "",
                    "\x04" => "",
                    "\x05" => "",
                    "\x06" => "",
                    "\x07" => "",
                    "\x08" => "",
                    "\x0E" => "",
                    "\x16" => "",
                    "\x00-" => "",
                    "\x09" => "",
                    "\x11" => "",
                    "\x12" => "",
                    "\x14-" => "",
                    "\x1f" => "",
                    "\x7f" => "",
                );
                $value = strtr($value, $pairs);
                $writer->startElement ("field");
                $writer->writeAttribute ('name', trim ($k) . '_t');
                $writer->startCData ();
                $writer->text ($value);
                $writer->endCData();
                $writer->endElement ();
            }
          }
        } // foreach unserialized data
      }// else unserialize APP_DATA
    } // empty APP_DATA
    
    $writer->endElement (); // end /doc
    
    return $writer->outputMemory (true);
  }
  
  /**
   * Search records in specified application delegation data
   *
   * @param string $AppUID
   *          application identifier
   * @param string $allAppDbData
   *          array of rows (array) with application data
   * @throws ApplicationWithoutDelegationRecordsException
   * @return array array of arrays with the following information(
   *         $documentInformation,
   *         $dynaformFieldTypes,
   *         $lastUpdateDate,
   *         $maxPriority,
   *         $delLastIndex,
   *         $assignedUsers,
   *         $assignedUsersRead,
   *         $assignedUsersUnread,
   *         $draftUser,
   *         $participatedUsers,
   *         $participatedUsersStartedByUser,
   *         $participatedUsersCompletedByUser,
   *         $unassignedUsers,
   *         $unassignedGroups
   */
  public function getApplicationIndexData($AppUID, $allAppDbData)
  {
    //G::LoadClass ('memcached');

    // get all the application data
    //$allAppDbData = $this->getApplicationDelegationData ($AppUID);
    // check if the application record was found
    // this case occurs when the application doesn't have related delegation
    // records.
    if (empty ($allAppDbData) || ! isset ($allAppDbData [0])) {
      throw new ApplicationWithoutDelegationRecordsException ( date('Y-m-d H:i:s:u') . " Application without delegation records. APP_UID: " . $AppUID . "\n");
    }
    
    // copy the application information
    $documentInformation = $allAppDbData [0];

    // get the last delegate date using the del_delegate_date
    $index = $this->aaGetMaximun ($allAppDbData, 'DEL_DELEGATE_DATE', 'DATE');
    
    $lastUpdateDate = $allAppDbData [$index] ['DEL_DELEGATE_DATE'];
    
    // get the delegate with max priority => minimun value
    $index2 = $this->aaGetMinimun ($allAppDbData, 'DEL_PRIORITY', 'NUMBER', 'DEL_THREAD_STATUS', 'OPEN');
    
    if ($index2 == null) {
      // get the last priority
      $maxPriority = $allAppDbData [$index] ['DEL_PRIORITY'];
    }
    else {
      $maxPriority = $allAppDbData [$index2] ['DEL_PRIORITY'];
    }

    //get last delegation
    //in the case of parallel cases see the open cases
    $delLastIndex = array();
    $appStatus = $allAppDbData [0]['APP_STATUS'];
    if($appStatus == 'COMPLETED' || $appStatus == 'CANCELLED' || $appStatus == 'PAUSED'){
      //case closed
      //get the last delegation
      //The correct would be to get all the cases paused in parallel cases
      $index = $this->aaGetMaximun ($allAppDbData, 'DEL_INDEX', 'NUMBER');
      $delLastIndex[] = $allAppDbData [$index] ['DEL_INDEX'];
    }else{
      //case is vigent
      $indexes = $this->aaSearchRecords ($allAppDbData, array (
          'DEL_THREAD_STATUS' => 'OPEN',
          'DEL_FINISH_DATE' => 'NULL'
      ));
      foreach ($indexes as $index) {
        $delLastIndex[] = $allAppDbData [$index] ['DEL_INDEX'];
      }
      if(count($indexes) == 0){
        //verify if is a paused case
        //show the last delegation
        //the correct would be to identify multiple cases if paused
        $index = $this->aaGetMaximun ($allAppDbData, 'DEL_INDEX', 'NUMBER');
        $delLastIndex[] = $allAppDbData [$index] ['DEL_INDEX'];
      }
    }
        
    $assignedUsers = array ();
    $indexes = $this->aaSearchRecords ($allAppDbData, array (
        'DEL_THREAD_STATUS' => 'OPEN',
        'DEL_FINISH_DATE' => 'NULL',
        'APP_STATUS' => 'TO_DO', //, 'APP_THREAD_STATUS' => 'OPEN'
        'APP_TYPE' => ''
    ));
    foreach ($indexes as $index) {
      $assignedUsers [] = array (
          'USR_UID' => $allAppDbData [$index] ['USR_UID'],
          'DEL_INDEX' => $allAppDbData [$index] ['DEL_INDEX'] 
      );
    }
    
    $assignedUsersRead = array ();
    $indexes = $this->aaSearchRecords ($allAppDbData, array (
        'DEL_THREAD_STATUS' => 'OPEN',
        'DEL_FINISH_DATE' => 'NULL',
        'APP_STATUS' => 'TO_DO', //,  'APP_THREAD_STATUS' => 'OPEN',
        'DEL_INIT_DATE' => 'NOTNULL' 
    ));
    foreach ($indexes as $index) {
      $assignedUsersRead [] = array (
          'USR_UID' => $allAppDbData [$index] ['USR_UID'],
          'DEL_INDEX' => $allAppDbData [$index] ['DEL_INDEX'] 
      );
    }
    
    $assignedUsersUnread = array ();
    $indexes = $this->aaSearchRecords ($allAppDbData, array (
        'DEL_THREAD_STATUS' => 'OPEN',
        'DEL_FINISH_DATE' => 'NULL',
        'APP_STATUS' => 'TO_DO', //, 'APP_THREAD_STATUS' => 'OPEN',
        'DEL_INIT_DATE' => 'NULL' 
    ));
    foreach ($indexes as $index) {
      $assignedUsersUnread [] = array (
          'USR_UID' => $allAppDbData [$index] ['USR_UID'],
          'DEL_INDEX' => $allAppDbData [$index] ['DEL_INDEX'] 
      );
    }
    
    $draftUser = array ();
    $indexes = $this->aaSearchRecords ($allAppDbData, array (
        'DEL_THREAD_STATUS' => 'OPEN',
        'DEL_FINISH_DATE' => 'NULL',
        'APP_STATUS' => 'DRAFT'//,  'APP_THREAD_STATUS' => 'OPEN' 
    ));
    if (! empty ($indexes)) {
      $draftUser = array (
          'USR_UID' => $allAppDbData [$indexes [0]] ['USR_UID'],
          'DEL_INDEX' => $allAppDbData [$indexes [0]] ['DEL_INDEX'] 
      );
    }
    
    $participatedUsers = array ();
    foreach ($allAppDbData as $row) {
      $participatedUsers [] = array (
          'USR_UID' => $row ['USR_UID'],
          'DEL_INDEX' => $row ['DEL_INDEX'] 
      );
    }
    
    $participatedUsersStartedByUser = array ();
    $indexes = $this->aaSearchRecords ($allAppDbData, array (
        'DEL_INDEX' => '1' 
    ));
    foreach ($indexes as $index) {
      $participatedUsersStartedByUser [] = array (
          'USR_UID' => $allAppDbData [$index] ['USR_UID'],
          'DEL_INDEX' => $allAppDbData [$index] ['DEL_INDEX'] 
      );
    }
    
    $participatedUsersCompletedByUser = array ();
    $indexes = $this->aaSearchRecords ($allAppDbData, array (
        'APP_STATUS' => 'COMPLETED' 
    ));
    foreach ($indexes as $index) {
      $participatedUsersCompletedByUser [] = array (
          'USR_UID' => $allAppDbData [$index] ['USR_UID'],
          'DEL_INDEX' => $allAppDbData [$index] ['DEL_INDEX'] 
      );
    }

    $pausedUsers = array ();
    $indexes = $this->aaSearchRecords ($allAppDbData, array (
        'APP_TYPE' => 'PAUSE'
    ));
    foreach ($indexes as $index) {
        if ($allAppDbData [$index] ['APP_DISABLE_ACTION_USER'] == null || $allAppDbData [$index] ['APP_DISABLE_ACTION_USER'] == 0) {
            $pausedUsers [] = array (
                'USR_UID' => $allAppDbData [$index] ['USR_UID'],
                'DEL_INDEX' => $allAppDbData [$index] ['DEL_INDEX'] 
            );
        }
    }
    // search information of unassigned users
    // the unassigned users are the self service users and groups.
    // the self service users are defined in the TASKs of the PROCESS.
    $unassignedUsers = array ();
    $unassignedGroups = array ();    
    //filter only the delegations that are in selfservice status
    // `USR_UID` = '' AND `DEL_FINISH_DATE` IS NULL
    $indexes = $this->aaSearchRecords ($allAppDbData, array (
        'USR_UID' => 'NULL',
        'DEL_FINISH_DATE' => 'NULL' //, 'APP_THREAD_STATUS' => 'OPEN'
    ));
    foreach ($indexes as $index) {
      $unassignedUsersGroups = array ();
      // use cache
      //$oMemcache = PMmemcached::getSingleton ($this->_solrInstance);
      //$unassignedUsersGroups = $oMemcache->get ("SOLR_UNASSIGNED_USERS_GROUPS_" . $allAppDbData [$index] ['PRO_UID'] . "_" . $allAppDbData [$index] ['TAS_UID']);
      //if (! $unassignedUsersGroups) {
        
        $unassignedUsersGroups = $this->getTaskUnassignedUsersGroupsData ($allAppDbData [$index] ['PRO_UID'], $allAppDbData [$index] ['TAS_UID']);
        
        // if the task has unassigned users or groups add del_index of delegation 
        //foreach ($unassignedUsersGroups as $i => $newRow) {
        //  $unassignedUsersGroups [$i] ['DEL_INDEX'] = $allAppDbData [$index] ['DEL_INDEX'];
        //}
        // store in cache
        //$oMemcache->set ("SOLR_UNASSIGNED_USERS_GROUPS_" . $allAppDbData [$index] ['PRO_UID'] . "_" . $allAppDbData [$index] ['TAS_UID'], $unassignedUsersGroups);
      //}
      
      // copy list of unassigned users and groups
      foreach ($unassignedUsersGroups as $unassignedUserGroup) {
        //unassigned users
        if ($unassignedUserGroup ['TU_RELATION'] == 1) {
          $unassignedUsers [] = array (
              'USR_UID' => $unassignedUserGroup ['USR_UID'],
              'DEL_INDEX' => $allAppDbData [$index] ['DEL_INDEX'] //$unassignedUserGroup ['DEL_INDEX'] 
          );
        }
        //unassigned groups
        elseif ($unassignedUserGroup ['TU_RELATION'] == 2) {
          $unassignedGroups [] = array (
              'USR_UID' => $unassignedUserGroup ['USR_UID'],
              'DEL_INDEX' => $allAppDbData [$index] ['DEL_INDEX'] //$unassignedUserGroup ['DEL_INDEX'] 
          );
        }
      }
    
    }    

    // Get DataTypes of dynaforms
    // use cache array to store the dynaform variables per process
    // use memory array to store information of Datatypes of Dynaforms
    // All the datatypes of the process => all variables in all dynaforms in the
    // process
    $dynaformFieldTypes = array ();

    // get cache instance
    //$oMemcache = PMmemcached::getSingleton ($this->_solrInstance);
    //$dynaformFieldTypes = $oMemcache->get ("SOLR_DYNAFORM_FIELD_TYPES_" . $documentInformation ['PRO_UID']);
    //if (! $dynaformFieldTypes) {
      G::LoadClass ('dynaformhandler');
      $dynaformFileNames = $this->getProcessDynaformFileNames ($documentInformation ['PRO_UID']);
      $dynaformFields = array ();
      foreach ($dynaformFileNames as $dynaformFileName) {
          if (is_file(PATH_DYNAFORM . $dynaformFileName ['DYN_FILENAME'] . '.xml') && 
             filesize(PATH_DYNAFORM . $dynaformFileName ['DYN_FILENAME'] . '.xml') >0 ) {
              $dyn = new dynaFormHandler (PATH_DYNAFORM . $dynaformFileName ['DYN_FILENAME'] . '.xml');
              $dynaformFields [] = $dyn->getFields ();
          }
          if (is_file(PATH_DYNAFORM . $dynaformFileName ['DYN_FILENAME'] . '.xml') && 
             filesize(PATH_DYNAFORM . $dynaformFileName ['DYN_FILENAME'] . '.xml') == 0 ) {
              throw new ApplicationWithCorruptDynaformException(date('Y-m-d H:i:s:u') . "Application with corrupt dynaform. APP_UID: " . $AppUID . "\n");
          }
      }
      
      foreach ($dynaformFields as $aDynFormFields) {
        foreach ($aDynFormFields as $field) {
          // create array of fields and types
          if ($field->getAttribute ('validate') == 'Int') {
            $dynaformFieldTypes [$field->nodeName] = 'Int';
          }
          elseif ($field->getAttribute ('validate') == 'Real') {
            $dynaformFieldTypes [$field->nodeName] = 'Real';
          }
          else {
            $dynaformFieldTypes [$field->nodeName] = $field->getAttribute ('type');
          }
        }
      }
      $dynaformFieldTypes = $this->getVariablesDynaform($documentInformation['PRO_UID'], $dynaformFieldTypes);
      // create cache of dynaformfields
      //$oMemcache->set ("SOLR_DYNAFORM_FIELD_TYPES_" . $documentInformation ['PRO_UID'], $dynaformFieldTypes);
    //}
    // return result values      
    $result = array (
        $documentInformation,
        $dynaformFieldTypes,
        $lastUpdateDate,
        $maxPriority,
        $delLastIndex,
        $assignedUsers,
        $assignedUsersRead,
        $assignedUsersUnread,
        $draftUser,
        $participatedUsers,
        $participatedUsersStartedByUser,
        $participatedUsersCompletedByUser,
        $unassignedUsers,
        $unassignedGroups,
        $pausedUsers
    );
    
    return $result;
  }
  
  /**
     * 
     * 
     * @param array $dynaformFieldTypes
     * @return array
     */
    public function getVariablesDynaform($processUid, $dynaformFieldTypes = array())
    {
        $criteria = new Criteria();
        $criteria->add(ProcessVariablesPeer::PRJ_UID, $processUid);
        $ds = ProcessVariablesPeer::doSelectRS($criteria);
        $ds->setFetchmode(ResultSet::FETCHMODE_ASSOC);
        while ($ds->next()) {
            $row = $ds->getRow();
            $type = "text";
            if ($row["VAR_FIELD_TYPE"] === "datetime") {
                $type = "date";
            }
            $dynaformFieldTypes[$row["VAR_NAME"]] = $type;
        }
        return $dynaformFieldTypes;
    }

  /**
   * Find the maximun value of the specified column in the array and return the
   * row index
   *
   * @param array $arr
   *          array of arrays with the data
   * @param string $column
   *          column name to search in
   * @param string $columnType
   *          column type STRING, NUMBER, DATE
   * @param string $columnCondition
   *          column condition
   * @param string $condition
   *          the condition
   * @return integer The index of the maximun record in array
   */
  public function aaGetMaximun($arr, $column, $columnType = 'STRING', 
      $columnCondition = "", $condition = "")
  {
    // get first value
    $auxValue = $arr [0] [$column];
    $index = null;
    foreach ($arr as $i => $row) {
      switch ($columnType) {
        case 'STRING' :
          if ((strnatcmp ($row [$column], $auxValue) >= 0) && (($columnCondition == "") || ($row [$columnCondition] == $condition))) {
            $auxValue = $row [$column];
            $index = $i;
          }
          break;
        case 'NUMBER' :
          if (($row [$column] >= $auxValue) && (($columnCondition == "") || ($row [$columnCondition] == $condition))) {
            $auxValue = $row [$column];
            $index = $i;
          }
          break;
        case 'DATE' :
          if ((strtotime ($row [$column]) >= strtotime ($auxValue)) && (($columnCondition == "") || ($row [$columnCondition] == $condition))) {
            $auxValue = $row [$column];
            $index = $i;
          }
          break;
      }
    }
    return $index;
  }
  
  /**
   * Get minimum of array of arrays
   *
   * @param array $arr
   *          array of arrays with the data
   * @param string $column
   *          the name of the column to search in
   * @param string $columnType
   *          the column type STRING, NUMBER, DATE
   * @param string $columnCondition
   *          the column condition
   * @param string $condition
   *          the condition
   * @return Ambigous <NULL, unknown> Index of the minimun value found
   */
  public function aaGetMinimun($arr, $column, $columnType = 'STRING', 
      $columnCondition = "", $condition = "")
  {
    // get first value
    $auxValue = $arr [0] [$column];
    $index = null;
    foreach ($arr as $i => $row) {
      switch ($columnType) {
        case 'STRING' :
          if ((strnatcmp ($row [$column], $auxValue) <= 0) && (($columnCondition == "") || ($row [$columnCondition] == $condition))) {
            $auxValue = $row [$column];
            $index = $i;
          }
          break;
        case 'NUMBER' :
          if (($row [$column] <= $auxValue) && (($columnCondition == "") || ($row [$columnCondition] == $condition))) {
            $auxValue = $row [$column];
            $index = $i;
          }
          break;
        case 'DATE' :
          if ((strtotime ($row [$column]) <= strtotime ($auxValue)) && (($columnCondition == "") || ($row [$columnCondition] == $condition))) {
            $auxValue = $row [$column];
            $index = $i;
          
          }
          break;
      }
    }
    return $index;
  }
  
  /**
   * Search array of indexes that fullfill the conditions
   *
   * @param
   *          array of arrays $arr contains the arrays that are searched
   * @param array $andColumnsConditions
   *          contain the conditions that must fullfill 'Column'=>'Condition'
   * @return array of indexes with the found records
   */
  public function aaSearchRecords($arr, $andColumnsConditions)
  {
    $indexes = array ();
    $isEqual = true;
    foreach ($arr as $i => $row) {
      $evaluateRow = false;
      // evaluate each row
      foreach ($andColumnsConditions as $column => $valueCondition) {
        $condition = $valueCondition;
        $isEqual = true;
        if ($valueCondition == 'NULL') {
          $isEqual = true;
          $condition = '';
        }
        if ($valueCondition == 'NOTNULL') {
          $isEqual = false;
          $condition = '';
        }
        if ($isEqual) {
          if ($row [$column] == $condition) {
            $evaluateRow = true;
          }
          else {
            $evaluateRow = false;
            breaK;
          }
        }
        else {
          if ($row [$column] != $condition) {
            $evaluateRow = true;
          }
          else {
            $evaluateRow = false;
            breaK;
          }
        }
      }
      // add row to indexes
      if ($evaluateRow) {
        $indexes [] = $i;
      }
    }
    return $indexes;
  }
  
  /**
   * Get application and delegation data from database
   *
   * @param string $AppUID
   *          the application identifier
   * @return array of records from database
   */
  public function getApplicationDelegationData($AppUID)
  {
    
    $allAppDbData = array ();
    
    $c = new Criteria ();
    
    $c->addSelectColumn (ApplicationPeer::APP_UID);
    $c->addSelectColumn (ApplicationPeer::APP_TITLE);
    $c->addSelectColumn (ApplicationPeer::APP_NUMBER);
    $c->addSelectColumn (ApplicationPeer::APP_STATUS);
    $c->addSelectColumn (ApplicationPeer::PRO_UID);
    $c->addSelectColumn (ApplicationPeer::APP_CREATE_DATE);
    $c->addSelectColumn (ApplicationPeer::APP_FINISH_DATE);
    $c->addSelectColumn (ApplicationPeer::APP_UPDATE_DATE);
    $c->addSelectColumn (ApplicationPeer::APP_DATA);

    $c->addSelectColumn (ProcessPeer::PRO_TITLE);

    $c->addSelectColumn ('ad.DEL_INDEX');
    $c->addSelectColumn ('ad.DEL_PREVIOUS');
    $c->addSelectColumn ('ad.TAS_UID');
    $c->addSelectColumn ('ad.USR_UID');
    $c->addSelectColumn ('ad.DEL_TYPE');
    $c->addSelectColumn ('ad.DEL_THREAD');
    $c->addSelectColumn ('ad.DEL_THREAD_STATUS');
    $c->addSelectColumn ('ad.DEL_PRIORITY');
    $c->addSelectColumn ('ad.DEL_DELEGATE_DATE');
    $c->addSelectColumn ('ad.DEL_INIT_DATE');
    $c->addSelectColumn ('ad.DEL_TASK_DUE_DATE');
    $c->addSelectColumn ('ad.DEL_FINISH_DATE');
    $c->addSelectColumn ('ad.DEL_DURATION');
    $c->addSelectColumn ('ad.DEL_QUEUE_DURATION');
    $c->addSelectColumn ('ad.DEL_DELAY_DURATION');
    $c->addSelectColumn ('ad.DEL_STARTED');
    $c->addSelectColumn ('ad.DEL_FINISHED');
    $c->addSelectColumn ('ad.DEL_DELAYED');
    $c->addSelectColumn ('ad.APP_OVERDUE_PERCENTAGE');
    
    $c->addSelectColumn ('at.APP_THREAD_INDEX');
    $c->addSelectColumn ('at.APP_THREAD_PARENT');
    $c->addSelectColumn ('at.APP_THREAD_STATUS');
    
    $c->addAlias ('ad', 'APP_DELEGATION');
    $c->addAlias ('at', 'APP_THREAD');
    
    $c->addJoin (ApplicationPeer::PRO_UID, ProcessPeer::PRO_UID, Criteria::LEFT_JOIN);
    $c->addJoin (ApplicationPeer::APP_UID, 'ad.APP_UID', Criteria::JOIN);

    $aConditions = array ();
    $aConditions [] = array (
        'ad.APP_UID',
        'at.APP_UID' 
    );
    $aConditions [] = array (
        'ad.DEL_THREAD',
        'at.APP_THREAD_INDEX' 
    );
    $c->addJoinMC ($aConditions, Criteria::JOIN);
    
    $c->add (ApplicationPeer::APP_UID, $AppUID);
    
    $rs = ApplicationPeer::doSelectRS ($c);
    $rs->setFetchmode (ResultSet::FETCHMODE_ASSOC);
    
    $rs->next ();
    $row = $rs->getRow ();
    
    while (is_array ($row)) {
      $allAppDbData [] = $row;
      $rs->next ();
      $row = $rs->getRow ();
    }

    //Propel::close();

    return $allAppDbData;
  }
  
  /**
   * Get application and delegation data from database
   *
   * @param string $aAppUID
   *          array of application identifiers
   * @return array of array of records from database
   */
  public function getListApplicationUpdateDelegationData($aaAppUIDs)
  {
    $allAppDbData = array ();
  
    $c = new Criteria ();
  
    $c->addSelectColumn (ApplicationPeer::APP_UID);
    $c->addSelectColumn (ApplicationPeer::APP_TITLE);
    $c->addSelectColumn (ApplicationPeer::APP_NUMBER);
    $c->addSelectColumn (ApplicationPeer::APP_STATUS);
    $c->addSelectColumn (ApplicationPeer::PRO_UID);
    $c->addSelectColumn (ApplicationPeer::APP_CREATE_DATE);
    $c->addSelectColumn (ApplicationPeer::APP_FINISH_DATE);
    $c->addSelectColumn (ApplicationPeer::APP_UPDATE_DATE);
    $c->addSelectColumn (ApplicationPeer::APP_DATA);
  
    $c->addSelectColumn ('pro.PRO_TITLE');
  
    $c->addSelectColumn ('ad.DEL_INDEX');
    $c->addSelectColumn ('ad.DEL_PREVIOUS');
    $c->addSelectColumn ('ad.TAS_UID');
    $c->addSelectColumn ('ad.USR_UID');
    $c->addSelectColumn ('ad.DEL_TYPE');
    $c->addSelectColumn ('ad.DEL_THREAD');
    $c->addSelectColumn ('ad.DEL_THREAD_STATUS');
    $c->addSelectColumn ('ad.DEL_PRIORITY');
    $c->addSelectColumn ('ad.DEL_DELEGATE_DATE');
    $c->addSelectColumn ('ad.DEL_INIT_DATE');
    $c->addSelectColumn ('ad.DEL_TASK_DUE_DATE');
    $c->addSelectColumn ('ad.DEL_FINISH_DATE');
    $c->addSelectColumn ('ad.DEL_DURATION');
    $c->addSelectColumn ('ad.DEL_QUEUE_DURATION');
    $c->addSelectColumn ('ad.DEL_DELAY_DURATION');
    $c->addSelectColumn ('ad.DEL_STARTED');
    $c->addSelectColumn ('ad.DEL_FINISHED');
    $c->addSelectColumn ('ad.DEL_DELAYED');
    $c->addSelectColumn ('ad.APP_OVERDUE_PERCENTAGE');

    $c->addSelectColumn ('at.APP_THREAD_INDEX');
    $c->addSelectColumn ('at.APP_THREAD_PARENT');
    $c->addSelectColumn ('at.APP_THREAD_STATUS');

    $c->addSelectColumn ('ade.APP_DELAY_UID');
    $c->addSelectColumn ('ade.APP_TYPE');
    $c->addSelectColumn ('ade.APP_DISABLE_ACTION_USER');

    $c->addAsColumn("PRO_CATEGORY_UID", "pro.PRO_CATEGORY");

    $c->addAlias ('ad', 'APP_DELEGATION');
    $c->addAlias ('at', 'APP_THREAD');
    $c->addAlias ('ade', 'APP_DELAY');
    $c->addAlias ("pro", ProcessPeer::TABLE_NAME);
  
    $c->addJoin (ApplicationPeer::PRO_UID, ProcessPeer::PRO_UID, Criteria::LEFT_JOIN);
    $c->addJoin (ApplicationPeer::APP_UID, 'ad.APP_UID', Criteria::JOIN);
  
    $aConditions = array ();
    $aConditions [] = array (
        'ad.APP_UID',
        'at.APP_UID'
    );
    $aConditions [] = array (
        'ad.DEL_THREAD',
        'at.APP_THREAD_INDEX'
    );
    $c->addJoinMC ($aConditions, Criteria::JOIN);
    
    $aConditions = array ();
    $aConditions [] = array (
        'ad.APP_UID',
        'ade.APP_UID'
    );
    $aConditions [] = array (
        'ad.DEL_INDEX',
        'ade.APP_DEL_INDEX'
    );
    //$aConditions [] = array (
    //    'ade.APP_DISABLE_ACTION_USER',
    //    DBAdapter::getStringDelimiter () . 'null' . DBAdapter::getStringDelimiter ()
    //);
    $aConditions [] = array (
        'ade.APP_DISABLE_ACTION_USER',
        DBAdapter::getStringDelimiter () . '0' . DBAdapter::getStringDelimiter ()
    );
    $aConditions [] = array (
        'ade.APP_TYPE',
        DBAdapter::getStringDelimiter () . 'PAUSE' . DBAdapter::getStringDelimiter ()
    );
    $c->addJoinMC($aConditions, Criteria::LEFT_JOIN);
    

    $arrayCondition = array();
    $arrayCondition[] = array(ApplicationPeer::PRO_UID, "pro.PRO_UID");
    $c->addJoinMC($arrayCondition, Criteria::LEFT_JOIN);
  
    $c->add (ApplicationPeer::APP_UID, $aaAppUIDs, Criteria::IN);

    $rs = ApplicationPeer::doSelectRS ($c);
    $rs->setFetchmode (ResultSet::FETCHMODE_ASSOC);

    $rs->next ();
    $row = $rs->getRow ();

    while (is_array ($row)) {
      $allAppDbData [] = $row;
      $rs->next ();
      $row = $rs->getRow ();
    }
    //Propel::close();

    return $allAppDbData;
  }
  
  /**
   * Get the list of groups of unassigned users of the specified task from
   * database
   *
   * @param string $ProUID
   *          Process identifier
   * @param string $TaskUID
   *          task identifier
   * @return array of unassigned user groups
   */
  public function getTaskUnassignedUsersGroupsData($ProUID, $TaskUID)
  {
    $unassignedUsersGroups = array ();
    
    $c = new Criteria ();
    
    $c->addSelectColumn (TaskUserPeer::USR_UID);
    $c->addSelectColumn (TaskUserPeer::TU_RELATION);
    
    $aConditions = array ();
    $aConditions [] = array (
        TaskPeer::TAS_UID,
        TaskUserPeer::TAS_UID 
    );
    $aConditions [] = array (
        TaskPeer::TAS_ASSIGN_TYPE,
        DBAdapter::getStringDelimiter () . 'SELF_SERVICE' . DBAdapter::getStringDelimiter () 
    );
    $c->addJoinMC ($aConditions, Criteria::JOIN);
    
    $c->add (TaskPeer::PRO_UID, $ProUID);
    $c->add (TaskPeer::TAS_UID, $TaskUID);
    
    $rs = TaskPeer::doSelectRS ($c);
    $rs->setFetchmode (ResultSet::FETCHMODE_ASSOC);
    // echo $c->toString();
    $rs->next ();
    $row = $rs->getRow ();
    
    while (is_array ($row)) {
      $unassignedUsersGroups [] = $row;
      $rs->next ();
      $row = $rs->getRow ();
    }
    
    //Propel::close();

    return $unassignedUsersGroups;
  }
  
  /**
   * Get the list of dynaform file names associated with the specified process
   * from database
   *
   * @param string $ProUID
   *          process identifier
   * @return array of dynaform file names
   */
  public function getProcessDynaformFileNames($ProUID)
  {
    $dynaformFileNames = array ();
    
    $c = new Criteria ();
    
    $c->addSelectColumn (DynaformPeer::DYN_FILENAME);
    
    $c->add (DynaformPeer::PRO_UID, $ProUID);
    
    $rs = DynaformPeer::doSelectRS ($c);
    $rs->setFetchmode (ResultSet::FETCHMODE_ASSOC);
    $rs->next ();
    $row = $rs->getRow ();
    
    while (is_array ($row)) {
      $dynaformFileNames [] = $row;
      $rs->next ();
      $row = $rs->getRow ();
    }
    
    //Propel::close();

    return $dynaformFileNames;
  }
  
  /**
   * Store a flag indicating if the application was updated in database
   * table APP_SOLR_QUEUE
   *
   * @param string $AppUid
   *          applicatiom identifier
   * @param integer $updated
   *          0:false, not updated, 1: updated, 2:deleted
   */
  public function applicationChangedUpdateSolrQueue($AppUid, $updated)
  {
    $traceData = $this->getCurrentTraceInfo();
    //var_dump($traceData);

    $oAppSolrQueue = new AppSolrQueue ();
    
    $oAppSolrQueue->createUpdate ($AppUid, $traceData, $updated);
  }

    private function getCurrentTraceInfo()
    {
        $resultTraceString = "";
        $traceData = debug_backtrace();
        foreach ($traceData as $key => $value) {
            if ($value['function'] != 'getCurrentTraceInfo' && $value['function'] != 'require_once') {
                if (isset($value['file']) && isset($value['line']) && isset($value['function'])) {
                    $resultTraceString .= $value['file'] . " (" . $value['line'] . ") " . $value['function'] . "\n";
                }
            }
        }
        return $resultTraceString;
    }

  /**
   * Update application records in Solr that are stored in APP_SOLR_QUEUE table
   */
  public function synchronizePendingApplications()
  {
    if(!$this->isSolrEnabled())
      throw new Exception(date('Y-m-d H:i:s:u') . " Error connecting to solr server.");
      
    // check table of pending updates
    $oAppSolrQueue = new AppSolrQueue ();
    
    $aAppSolrQueue = $oAppSolrQueue->getListUpdatedApplications ();

    $trunkSize = 100;
    //filter updated cases
    $aUpdatedApplications = array();
    $aDeletedApplications = array();
    foreach ($aAppSolrQueue as $oAppSolrQueueEntity) {
      // call the syncronization function
      if($oAppSolrQueueEntity->appUpdated == 1){
        $aUpdatedApplications[] = array ('APP_UID' => $oAppSolrQueueEntity->appUid );
      }
      if($oAppSolrQueueEntity->appUpdated == 2){
        $aDeletedApplications[] = array ('APP_UID' => $oAppSolrQueueEntity->appUid );
      }      
    }

    $totalCasesUpdated = count($aUpdatedApplications);
    $loops = ((($totalCasesUpdated % $trunkSize) > 0 )? ($totalCasesUpdated / $trunkSize)+1: ($totalCasesUpdated / $trunkSize));
    for ($i = 0; $i < $loops; $i++) {
      //prepare trunk of appuids
      $trunkUpdatedApplications = array_slice($aUpdatedApplications, $i * $trunkSize, $trunkSize);

      $this->updateApplicationSearchIndex ($trunkUpdatedApplications, true);

      /*foreach($trunkUpdatedApplications as $appUid){
        $this->applicationChangedUpdateSolrQueue ($appUid, 0);  
      }*/
    }

    $totalCasesDeleted = count($aDeletedApplications);
    $loops = ((($totalCasesDeleted % $trunkSize) > 0 )? ($totalCasesDeleted / $trunkSize)+1: ($totalCasesDeleted / $trunkSize));
    for ($i = 0; $i < $loops; $i++) {
      //prepare trunk of appuids
      $trunkDeleteddApplications = array_slice($aDeletedApplications, $i * $trunkSize, $trunkSize);

      $this->deleteApplicationSearchIndex ($trunkDeleteddApplications, true);

      /*foreach($trunkDeleteddApplications as $appUid){
        $this->applicationChangedUpdateSolrQueue ($appUid, 0);  
      }*/
    }    

    /*
    foreach ($aAppSolrQueue as $oAppSolrQueueEntity) {
      // call the syncronization function
      if($oAppSolrQueueEntity->appUpdated == 1){
        $this->updateApplicationSearchIndex ($oAppSolrQueueEntity->appUid, false);
      }
      if($oAppSolrQueueEntity->appUpdated == 2){
        $this->deleteApplicationSearchIndex ($oAppSolrQueueEntity->appUid, false);
      }      
      $this->applicationChangedUpdateSolrQueue ($oAppSolrQueueEntity->appUid, 0);
    }*/
  }
  
  /**
   * Get the total number of application records in database
   *
   * @return integer application counter
   */
  public function getCountApplicationsPMOS2()
  {
    $c = new Criteria ();
    
    $c->addSelectColumn (ApplicationPeer::APP_UID);
    
    $count = ApplicationPeer::doCount ($c);

    //Propel::close();
    
    return $count;
  }
  
  /**
   * Get the total number of application records in search index
   *
   * @return integer application counter
   */
  public function getCountApplicationsSearchIndex()
  {
    G::LoadClass ('searchIndex');
    
    $searchIndex = new BpmnEngine_Services_SearchIndex ($this->_solrIsEnabled, $this->_solrHost);
    // execute query
    $count = $searchIndex->getNumberDocuments ($this->_solrInstance);
  
    return $count;
  }
  
  /**
   * Optimize the records in search index
   *
   * @return 
   */
  public function optimizeSearchIndex()
  {
    G::LoadClass ('searchIndex');
    
    $searchIndex = new BpmnEngine_Services_SearchIndex ($this->_solrIsEnabled, $this->_solrHost);
    // execute query
    $searchIndex->optimizeIndexChanges ($this->_solrInstance);
  
  }  
  
  /**
   * Get a paginated list of application uids from database.
   *
   * @param integer $skip
   *          the offset from where to return the application records
   * @param integer $pagesize
   *          the size of the page
   * @return array of application id's in the specified page.
   */
  public function getPagedApplicationUids($skip, $pagesize)
  {
    
    $c = new Criteria ();
    
    $c->addSelectColumn (ApplicationPeer::APP_UID);
    $c->setOffset ($skip);
    $c->setLimit ($pagesize);
    
    $rs = ApplicationPeer::doSelectRS ($c);
    $rs->setFetchmode (ResultSet::FETCHMODE_ASSOC);
    
    $rs->next ();
    $row = $rs->getRow ();
    $appUIds = array ();
    while (is_array ($row)) {
      $appUIds [] = $row;
      $rs->next ();
      $row = $rs->getRow ();
    }

    //Propel::close();

    return $appUIds;
  }
  
  /**
   * Reindex all the application records in Solr server
   * update applications in groups of 1000
   */
  public function reindexAllApplications($SkipRecords = 0, $indexTrunkSize = 1000)
  {
    $trunk = $indexTrunkSize;

    if(!$this->isSolrEnabled())
        throw new Exception(date('Y-m-d H:i:s:u') . " Error connecting to solr server.");

        // delete all documents to begin reindex
        // deleteAllDocuments();
        // commitChanges();
        // print "Deleted all documents \n";
        // search trunks of id's to regenerate index
        $numRows = $this->getCountApplicationsPMOS2 ();
        print "Total number of records: " . $numRows . "\n";
        //
        $initTimeAll = microtime (true);

        for ($skip = $SkipRecords; $skip <= $numRows;) {
            $aaAPPUIds = $this->getPagedApplicationUids ($skip, $trunk);
            printf ("Indexing %d to %d \n", $skip, $skip + $trunk);
            $initTimeDoc = microtime (true);
            $this->updateApplicationSearchIndex ($aaAPPUIds, false);
            $curTimeDoc = gmdate ('H:i:s', (microtime (true) - $initTimeDoc));
            printf ("Indexing document time: %s \n", $curTimeDoc);
            $skip += $trunk;
    }
        $curTimeDoc = gmdate ('H:i:s', (microtime (true) - $initTimeAll));
        printf ("Total reindex time: %s \n", $curTimeDoc);
        printf ("Reindex completed successfully!!.\n");
  }

}