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

/**
 * 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
  
  public function __construct($SolrEnabled, $SolrHost, $SolrInstance)
  {
    // define solr availability
    $this->_solrIsEnabled = $SolrEnabled;
    $this->_solrHost = $SolrHost;
    $this->_solrInstance = $SolrInstance;
  }
  
  /**
   * Return if the Solr functionality is enabled. 
   * @return boolean true:enabled functionality, false:disabled functionality
   */
  public function isSolrEnabled()
  {
    return $this->_solrIsEnabled;
  }
  
  /**
   * 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, $user = null, $status = null, $type = null, $dateFrom = null, $dateTo = null, $callback = null, $dir = null, $sort = 'APP_CACHE_VIEW.APP_NUMBER', $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 = isset ($user) ? $user : ''; // 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',
          '',
          '' 
      );
      // 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] = 4;
            $sortableCols [0] = 'true';
            $sortDir [0] = $dir;
            break;
          // multivalue field can't be ordered
          case 'APP_TITLE' :
            $sortCols [0] = 10;
            $sortableCols [0] = 'true';
            $sortDir [0] = $dir;
            break;
          case 'APP_PRO_TITLE' :
            $sortCols [0] = 6;
            $sortableCols [0] = 'true';
            $sortDir [0] = $dir;
            break;
          case 'APP_UPDATE_DATE' :
            $sortCols [0] = 12;
            $sortableCols [0] = 'true';
            $sortDir [0] = $dir;
            break;
          default :
            $sortCols [0] = 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 ";
      }
      // 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';
        }
      }
      // 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';
        }        
      }
      
      //search action
      if ($action == 'search' && $dateFrom != "" && $dateTo != "") {
        $fromDate = date ("Y-m-d", strtotime ($dateFrom));
        $toDate = 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 ";
        
      }
      
      // 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
      // the fields begin in the 30th column and more 
      $columsToInclude = array_merge ($columsToInclude, $delegationIndexes);
      
      // if is a counter no records are returned
      if ($doCount) {
        $start = 0;
        $limit = 0;
        $numSortingCols = 0;
        $columsToInclude = 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' => $columsToInclude,
          '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;

      //get all the data from database
      $appUids = array();
      foreach ($solrQueryResult->aaData as $i => $data) {
        $appUids[] = $data [11];
      }
      
      $aaappsDBData = $this->getListApplicationDelegationData ($appUids);
      
      if($this->debug)
      {
        $this->afterDbQueryTime = microtime (true);
      }
      // 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 [11];
        //get all the delindexes
        for($i = 30 ; $i < count($data) ; $i++) {
          if (is_array ($data [$i])) {
            foreach($data [$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 "Delegation not defined\n";
          }
          /*
          elseif ($action == 'unassigned'){
            $delIndexes = $this->getApplicationDelegationsIndex ($appUID);
          }*/
        }
        //remove duplicated
        $delIndexes = array_unique($delIndexes);
        foreach ($delIndexes as $delIndex) {
          $aRow = array ();
          foreach ($resultColumns as $j => $columnName) {
            $aRow [$columnName] = $data [$j];
          }
          // convert date from solr format UTC to local time in MySQL format
          $solrdate = $data [0];
          $localDate = date ('Y-m-d H:i:s', strtotime ($solrdate));
          $aRow ['APP_CREATE_DATE'] = $localDate;
          
          $solrdate = $data [12];
          $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
          ));
          
          foreach ($indexes as $index) {
            $row = $aaappsDBData [$index];
          }          
          
          if(!isset($row))
          {
            $fh = fopen("SolrAppWhitoutDelIndex.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_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'] = "";
      
      /*********************************************/
      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'];
    
    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 (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', 'ctastitle.CON_VALUE');
    $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 ('ctastitle', 'CONTENT');
    $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);
  
    $aConditions = array ();
    $aConditions [] = array (
        AppDelegationPeer::TAS_UID,
        'ctastitle.CON_ID'
    );
    $c->addJoinMC ($aConditions, Criteria::LEFT_JOIN);
  
    $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);
  
    $c->add ('ctastitle.CON_CATEGORY', 'TAS_TITLE');
    $c->add ('ctastitle.CON_LANG', 'en');
  
    $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 ();
    }    
  
    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', 'ctastitle.CON_VALUE');
    $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 ('ctastitle', 'CONTENT');
    $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);
    
    $aConditions = array ();
    $aConditions [] = array (
        AppDelegationPeer::TAS_UID,
        'ctastitle.CON_ID' 
    );
    $c->addJoinMC ($aConditions, Criteria::LEFT_JOIN);
    
    $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);
    
    $c->add ('ctastitle.CON_CATEGORY', 'TAS_TITLE');
    $c->add ('ctastitle.CON_LANG', 'en');
    
    $rs = AppDelegationPeer::doSelectRS ($c);
    $rs->setFetchmode (ResultSet::FETCHMODE_ASSOC);
    // echo $c->toString();
    $rs->next ();
    $row = $rs->getRow ();
    
    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]
          $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 != '*') {
              // TODO complete date creation
              // list($year, $month, $day) = sscanf($fromDateOriginal,
              // '%04d/%02d/%02d');
              // $fromDateDatetime = new DateTime($fromDateOriginal);
              // $fromDateDatetime = date_create_from_format ( 'Y-m-d',
              // $fromDateOriginal );
              // $fromDateDatetime->getTimestamp ()
              $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 {
            throw new InvalidIndexSearchTextException ("Invalid search text. Expected date interval format => {variable_name}:[YYYY-MM-DD TO YYYY-MM-DD]");
          }
        }
        
        $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 ();
    }
    
    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)
  {
    if (empty ($aaAPPUIDs))
      return;
    
    if (! is_array ($aaAPPUIDs)) {
      // convert to array
      $APPUID = $aaAPPUIDs;
      $aaAPPUIDs = array ();
      $aaAPPUIDs [] = array (
          'APP_UID' => $APPUID 
      );
    }
    // check if index server is available
    if (! $this->isSolrEnabled ()) {
      // store update in table and return
      foreach ($aaAPPUIDs as $aAPPUID) {
        $this->applicationChangedUpdateSolrQueue ($aAPPUID ['APP_UID'], true);
      }
      return;
    }
    
    if($this->debug)
    {
      $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);

    try{
      $oSearchIndex->updateIndexDocument ($oSolrUpdateDocument);
      
      if($this->debug)
      {
        $this->afterUpdateSolrXMLDocTime = microtime (true);
      }      
      // commit changes
      $oSearchIndex->commitIndexChanges ($this->_solrInstance);
      
    } 
    catch(Exception $ex) {
      //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, $ex->getMessage());
        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))  ));
      fwrite($fh, sprintf("Solr Create XML Document time: %s Update Solr Document time: %s Commit Solr Changes time: %s Total:%s \r\n", ($this->afterCreateSolrXMLDocTime - $this->beforeCreateSolrXMLDocTime), ($this->afterUpdateSolrXMLDocTime - $this->afterCreateSolrXMLDocTime), ($this->afterCommitSolrDocTime - $this->afterUpdateSolrXMLDocTime), ($this->afterCommitSolrDocTime - $this->beforeCreateSolrXMLDocTime)  ));
      fclose($fh);
    }    
  }
  
  /**
   * Delete the specified application record from Solr
   *
   * @param string $appUID
   *          Application identifier
   */
  public function deleteApplicationSearchIndex($appUID)
  {
    if (empty ($appUID))
      return;
      
      // check if index server is available
    if (! $this->_solrIsEnabled) {
      // store update in table and return
      $this->applicationChangedUpdateSolrQueue ($appUID ['APP_UID'], 2); // delete
      return;
    }
    
    $idQuery = "APP_UID:" . $appUID;
    
    G::LoadClass ('searchIndex');
    
    $oSearchIndex = new BpmnEngine_Services_SearchIndex ($this->_solrIsEnabled, $this->_solrHost);
    
    $oSearchIndex->deleteDocumentFromIndex ($this->_solrInstance, $idQuery);
    
    // 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->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, $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, $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, "getApplicationIndexData " . $aAPPUID . ":" . $ex->getMessage() . "\n");
        fclose($fh);
        continue;        
      }
      
      $documentInformation = $result [0];
      $dynaformFieldTypes = $result [1];
      $lastUpdateDate = $result [2];
      $maxPriority = $result [3];
      $assignedUsers = $result [4];
      $assignedUsersRead = $result [5];
      $assignedUsersUnread = $result [6];
      $draftUser = $result [7];
      $participatedUsers = $result [8];
      $participatedUsersStartedByUser = $result [9];
      $participatedUsersCompletedByUser = $result [10];
      $unassignedUsers = $result [11];
      $unassignedGroups = $result [12];

      try {
        
        // create document
        $xmlDoc .= $this->buildSearchIndexDocumentPMOS2 ($documentInformation, $dynaformFieldTypes, 
            $lastUpdateDate, $maxPriority, $assignedUsers, $assignedUsersRead, $assignedUsersUnread, 
            $draftUser, $participatedUsers, $participatedUsersStartedByUser, $participatedUsersCompletedByUser, 
            $unassignedUsers, $unassignedGroups);
        
        if($this->debug)
        {
          $this->afterBuilXMLDocTime = microtime (true);
          
          $this->getBuilXMLDocTime += $this->afterBuilXMLDocTime - $this->afterGetApplicationDataDBTime; 
        }        
      }
      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, $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, "buildSearchIndexDocumentPMOS2 " . $aAPPUID . ":" . $ex->getMessage() . "\n");
        fclose($fh);
        continue;
      }
    
    }
    
    $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("Get Data DB time: %s Prepare DB data Time: %s Create XML file time: %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, $assignedUsers, $assignedUsersRead, $assignedUsersUnread, $draftUser, 
    $participatedUsers, $participatedUsersStartedByUser, $participatedUsersCompletedByUser, 
    $unassignedUsers, $unassignedGroups)
  {
    // 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 (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 ();
      }
    }

    // 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 ("Could not unserialize APP_DATA of APP_UID: " . $documentData ['APP_UID'] . "\n");
      }
      else {
        foreach ($UnSerializedCaseData as $k => $value) {
          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 = intval ($value);
                  }
                  break;
                case 'Real' :
                  $typeSufix = '_td';
                  $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 != '*') {
                $writer->startElement ("field");
                $writer->writeAttribute ('name', trim ($k) . $typeSufix);
                $writer->text ($value);
                $writer->endElement ();
              }
            }
            else {
              $writer->startElement ("field");
              $writer->writeAttribute ('name', trim ($k) . '_t');
              $writer->text ($value);
              $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,
   *         $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 ("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'];
    }
    
    $assignedUsers = array ();
    $indexes = $this->aaSearchRecords ($allAppDbData, array (
        'DEL_THREAD_STATUS' => 'OPEN',
        'DEL_FINISH_DATE' => 'NULL',
        'APP_STATUS' => 'TO_DO',
        'APP_THREAD_STATUS' => 'OPEN' 
    ));
    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'] 
      );
    }
    // 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 ($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 ($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' => $unassignedUserGroup ['DEL_INDEX'] 
          );
        }
        //unassigned groups
        elseif ($unassignedUserGroup ['TU_RELATION'] == 2) {
          $unassignedGroups [] = array (
              'USR_UID' => $unassignedUserGroup ['USR_UID'],
              '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 ($documentInformation ['PRO_UID']);
    if (! $dynaformFieldTypes) {
      G::LoadClass ('dynaformhandler');
      $dynaformFileNames = $this->getProcessDynaformFileNames ($documentInformation ['PRO_UID']);
      $dynaformFields = array ();
      foreach ($dynaformFileNames as $dynaformFileName) {
          if (is_file(PATH_DATA . '/sites/workflow/xmlForms/' . $dynaformFileName ['DYN_FILENAME'] . '.xml') && 
             filesize(PATH_DATA . '/sites/workflow/xmlForms/' . $dynaformFileName ['DYN_FILENAME'] . '.xml') >0 ) {
          $dyn = new dynaFormHandler (PATH_DATA . '/sites/workflow/xmlForms/' . $dynaformFileName ['DYN_FILENAME'] . '.xml');
          $dynaformFields [] = $dyn->getFields ();
        }
        if (is_file(PATH_DATA . '/sites/workflow/xmlForms/' . $dynaformFileName ['DYN_FILENAME'] . '.xml') && 
             filesize(PATH_DATA . '/sites/workflow/xmlForms/' . $dynaformFileName ['DYN_FILENAME'] . '.xml') == 0 )  {
          
          throw new ApplicationWithCorruptDynaformException("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');
          }
        }
      }
      // create cache of dynaformfields
      $oMemcache->set ($documentInformation ['PRO_UID'], $dynaformFieldTypes);
    }
    // return result values
    $result = array (
        $documentInformation,
        $dynaformFieldTypes,
        $lastUpdateDate,
        $maxPriority,
        $assignedUsers,
        $assignedUsersRead,
        $assignedUsersUnread,
        $draftUser,
        $participatedUsers,
        $participatedUsersStartedByUser,
        $participatedUsersCompletedByUser,
        $unassignedUsers,
        $unassignedGroups 
    );
    
    return $result;
  }
  
  /**
   * 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_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->addAsColumn ('APP_TITLE', 'capp.CON_VALUE');
    $c->addAsColumn ('PRO_TITLE', 'cpro.CON_VALUE');
    
    $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 ('capp', 'CONTENT');
    $c->addAlias ('cpro', 'CONTENT');
    $c->addAlias ('ad', 'APP_DELEGATION');
    $c->addAlias ('at', 'APP_THREAD');
    
    $aConditions = array ();
    $aConditions [] = array (
        ApplicationPeer::APP_UID,
        'capp.CON_ID' 
    );
    $aConditions [] = array (
        'capp.CON_CATEGORY',
        DBAdapter::getStringDelimiter () . 'APP_TITLE' . DBAdapter::getStringDelimiter () 
    );
    $aConditions [] = array (
        'capp.CON_LANG',
        DBAdapter::getStringDelimiter () . 'en' . DBAdapter::getStringDelimiter () 
    );
    $c->addJoinMC ($aConditions, Criteria::LEFT_JOIN);
    
    $aConditions = array ();
    $aConditions [] = array (
        ApplicationPeer::PRO_UID,
        'cpro.CON_ID' 
    );
    $aConditions [] = array (
        'cpro.CON_CATEGORY',
        DBAdapter::getStringDelimiter () . 'PRO_TITLE' . DBAdapter::getStringDelimiter () 
    );
    $aConditions [] = array (
        'cpro.CON_LANG',
        DBAdapter::getStringDelimiter () . 'en' . DBAdapter::getStringDelimiter () 
    );
    $c->addJoinMC ($aConditions, 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 ();
    }
    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_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->addAsColumn ('APP_TITLE', 'capp.CON_VALUE');
    $c->addAsColumn ('PRO_TITLE', 'cpro.CON_VALUE');
  
    $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 ('capp', 'CONTENT');
    $c->addAlias ('cpro', 'CONTENT');
    $c->addAlias ('ad', 'APP_DELEGATION');
    $c->addAlias ('at', 'APP_THREAD');
  
    $aConditions = array ();
    $aConditions [] = array (
        ApplicationPeer::APP_UID,
        'capp.CON_ID'
    );
    $aConditions [] = array (
        'capp.CON_CATEGORY',
        DBAdapter::getStringDelimiter () . 'APP_TITLE' . DBAdapter::getStringDelimiter ()
    );
    $aConditions [] = array (
        'capp.CON_LANG',
        DBAdapter::getStringDelimiter () . 'en' . DBAdapter::getStringDelimiter ()
    );
    $c->addJoinMC ($aConditions, Criteria::LEFT_JOIN);
  
    $aConditions = array ();
    $aConditions [] = array (
        ApplicationPeer::PRO_UID,
        'cpro.CON_ID'
    );
    $aConditions [] = array (
        'cpro.CON_CATEGORY',
        DBAdapter::getStringDelimiter () . 'PRO_TITLE' . DBAdapter::getStringDelimiter ()
    );
    $aConditions [] = array (
        'cpro.CON_LANG',
        DBAdapter::getStringDelimiter () . 'en' . DBAdapter::getStringDelimiter ()
    );
    $c->addJoinMC ($aConditions, 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, $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 ();
    }
    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 ();
    }
    
    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 ();
    }
    
    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)
  {
    $oAppSolrQueue = new AppSolrQueue ();
    
    $oAppSolrQueue->createUpdate ($AppUid, $updated);
  }
  
  /**
   * Update application records in Solr that are stored in APP_SOLR_QUEUE table
   */
  public function synchronizePendingApplications()
  {
    // check table of pending updates
    $oAppSolrQueue = new AppSolrQueue ();
    
    $aAppSolrQueue = $oAppSolrQueue->getListUpdatedApplications ();
    
    foreach ($aAppSolrQueue as $oAppSolrQueueEntity) {
      // call the syncronization function
      if($oAppSolrQueueEntity->appUpdated == 1){
        $this->updateApplicationSearchIndex ($oAppSolrQueueEntity->appUid);
      }
      if($oAppSolrQueueEntity->appUpdated == 2){
        $this->deleteApplicationSearchIndex ($oAppSolrQueueEntity->appUid);
      }      
      $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);
    
    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 ();
    }
    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;
    // 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);
      
      $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");
  }

}