<?php
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";

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

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

class AppSolr {
  private $solrIsEnabled = false;
  private $solrHost = "";
  private $solrInstance = "";
  
  function __construct($SolrEnabled, $SolrHost, $SolrInstance) {
    // define solr availability
    $this->solrIsEnabled = $SolrEnabled;
    $this->solrHost = $SolrHost;
    $this->solrInstance = $SolrInstance;
  }
  
  public function isSolrEnabled() {
    return $this->solrIsEnabled;
  }
  
  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') {
    $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;
    
    $result = array ();
    $result ['totalCount'] = 0;
    $result ['data'] = array ();
    $result ['success'] = false;
    $result ['message'] = "Error description.";
    
    G::LoadClass ( 'searchIndex' );
    
    try {
      
      // 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;
      // 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 = "";
      
      if ($process != '') {
        $solrSearchText .= "PRO_UID:" . $process . " AND ";
      }
      
      if ($status != '') {
        $solrSearchText .= "APP_STATUS:" . $status . " AND ";
      }
      // todo list
      if ($userUid != null && $action == 'todo') {
        if ($filter == 'read') {
          $solrSearchText .= "APP_ASSIGNED_USERS_READ:" . $userUid . " AND ";
          $delIndexDynaField = "APP_ASSIGNED_USER_READ_DEL_INDEX_" . trim ( $userUid ) . '_txt';
        }
        elseif ($filter == 'unread') {
          $solrSearchText .= "APP_ASSIGNED_USERS_UNREAD:" . $userUid . " AND ";
          $delIndexDynaField = "APP_ASSIGNED_USER_UNREAD_DEL_INDEX_" . trim ( $userUid ) . '_txt';
        }
        else {
          $solrSearchText .= "APP_ASSIGNED_USERS:" . $userUid . " AND ";
          $delIndexDynaField = "APP_ASSIGNED_USER_DEL_INDEX_" . trim ( $userUid ) . '_txt';
        }
      }
      // participated
      if ($userUid != null && $action == 'sent') {
        if ($filter == 'started') {
          $solrSearchText .= "APP_PARTICIPATED_USERS_STARTED:" . $userUid . " AND ";
          $delIndexDynaField = "APP_PARTICIPATED_USER_STARTED_DEL_INDEX_" . trim ( $userUid ) . '_txt';
        }
        elseif ($filter == 'completed') {
          $solrSearchText .= "APP_PARTICIPATED_USERS_COMPLETED:" . $userUid . " AND ";
          $delIndexDynaField = "APP_PARTICIPATED_USER_COMPLETED_DEL_INDEX_" . trim ( $userUid ) . '_txt';
        }
        else {
          $solrSearchText .= "APP_PARTICIPATED_USERS:" . $userUid . " AND ";
          $delIndexDynaField = "APP_PARTICIPATED_USER_DEL_INDEX_" . trim ( $userUid ) . '_txt';
        }
      }
      // draft
      if ($userUid != null && $action == 'draft') {
        $solrSearchText .= "APP_DRAFT_USER:" . $userUid . " AND ";
        // index is allways 1
      }
      // unassigned
      if ($userUid != null && $action == 'unassigned') {
        // get the list of groups to which belongs the user.
        $userGroups = $this->getUserGroups ( $userUid );
        $solrSearchText .= "(APP_UNASSIGNED_USERS:" . $userUid . " OR ";
        foreach ( $userGroups as $group ) {
          $solrSearchText .= "APP_UNASSIGNED_GROUPS:" . $group ['GRP_UID'] . " OR ";
        }
        $solrSearchText .= ") AND ";
        
        $delIndexDynaField = "APP_UNASSIGNED_USER_GROUP_DEL_INDEX_" . trim ( $userUid ) . '_txt';
      }
      
      // remove last AND
      if ($solrSearchText != '')
        $solrSearchText = substr_replace ( $solrSearchText, "", - 5 );
        
        // add parentesis
      if ($solrSearchText != "")
        $solrSearchText = "(" . $solrSearchText . ")";
        
        // create query string
      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 field
      $columsToInclude = array_merge ( $columsToInclude, array (
          $delIndexDynaField 
      ) );
      
      $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 );
      
      // complete return data
      $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 ();
      $result ['totalCount'] = $solrQueryResult->iTotalDisplayRecords;
      
      foreach ( $solrQueryResult->aaData as $i => $data ) {
        // complete empty values
        $appUID = $data [11];
        $delIndexes = $data [30];
        // verify if the delindex is an array
        // if is not an array all the indexed must be returned
        if (! is_array ( $delIndexes )) {
          // if is draft
          if ($action == 'draft') {
            $delIndexes [] = 1; // the first default index
          }
          elseif ($action == 'search') {
            // get all the indexes
            $delIndexes = $this->getApplicationDelegationsIndex ( $appUID );
          }
        }
        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
          $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;
          
          $rows [] = $aRow;
        }
      }
      $result ['data'] = $rows;
      $result ['success'] = true;
      $result ['result'] = true;
      $result ['message'] = "";
      
      return $result;
    
    } // end try
    catch ( InvalidIndexSearchTextException $e ) {
      // return empty result with description of error
      $result = array ();
      $result ['totalCount'] = 0;
      $result ['data'] = array ();
      $result ['success'] = true;
      $result ['result'] = false;
      $result ['message'] = $e->getMessage ();
      return $result;
    }
  }
  
  function getUserGroups($usrUID) {
    $gu = new GroupUser ();
    $rows = $gu->getAllUserGroups ( $usrUID );
    return $rows;
  }
  
  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          
   */
  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 );
      
      // 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) {
        // 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
              throw new InvalidIndexSearchTextException ( "Invalid search text. The date or phase is not completed" ); // Expected
                                                                                                                         // date
                                                                                                                         // interval
                                                                                                                         // format
                                                                                                                         // =>
                                                                                                                         // {variable_name}:[YYYY-MM-DDThh:mm:ssZ
                                                                                                                         // TO
                                                                                                                         // YYYY-MM-DDThh:mm:ssZ]
            }
          }
        }
        
        // 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\T00:00:00\Z", strtotime($fromDateOriginal) );
            }
            $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;
  }
  
  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;
  
  }
  
  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 );
      }
    }
    // create XML document
    $xmlDoc = $this->createSolrXMLDocument ( $aaAPPUIDs );

    // update document
    $data = array (
        'workspace' => $this->solrInstance,
        'document' => $xmlDoc 
    );
    
    $oSolrUpdateDocument = Entity_SolrUpdateDocument::CreateForRequest ( $data );
    
    G::LoadClass ( 'searchIndex' );
    
    $oSearchIndex = new BpmnEngine_Services_SearchIndex ( $this->solrIsEnabled, $this->solrHost );
    
    $oSearchIndex->updateIndexDocument ( $oSolrUpdateDocument );
    
    // commit changes
    $oSearchIndex->commitIndexChanges ( $this->solrInstance );
  }
  
  function deleteApplicationSearchIndex($appUID) {
    if (empty ( $appUID ))
      return;
      
      // check if index server is available
    if (! $this->isSolrEnabled) {
      // store update in table and return
      $this->applicationChangedUpdateSolrQueue ( $appUID ['APP_UID'], 2 ); // delete
    }
    
    $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 );
  }
  
  function createSolrXMLDocument($aaAPPUIDs) {
    // search data from DB
    $xmlDoc = "<?xml version='1.0' encoding='UTF-8'?>\n";
    $xmlDoc .= "<add>\n";
    // echo "APP Uids to index \n";
    foreach ( $aaAPPUIDs as $aAPPUID ) {
      try {
        $result = $this->getApplicationIndexData ( $aAPPUID ['APP_UID'] );
      }
      catch(ApplicationWithoutDelegationRecordsException $e){
        //exception trying to get application information
        //skip and continue with the next application
        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];
      
      // create document
      $xmlDoc .= $this->buildSearchIndexDocumentPMOS2 ( $documentInformation, $dynaformFieldTypes, $lastUpdateDate, $maxPriority, $assignedUsers, $assignedUsersRead, $assignedUsersUnread, $draftUser, $participatedUsers, $participatedUsersStartedByUser, $participatedUsersCompletedByUser, $unassignedUsers, $unassignedGroups );
    
    }
    
    $xmlDoc .= "</add>\n";
    
    return $xmlDoc;
  }
  
  /**
   * build search index document xml for PMOS2
   * @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);*
   */
  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 ( $userUID ['USR_UID'] ) . '_txt' );
        $writer->text ( $userUID ['DEL_INDEX'] );
        $writer->endElement ();
      }
    }
    
    // get the serialized fields
    if (! empty ( $documentData ['APP_DATA'] )) {
      
      $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 Exception ( "Unserialize APP_DATA error. APP_UID: " . $documentData ['APP_UID'] );
      }
      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' :
                  $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 );
                    }
                  }
                  break;
                case 'dropdown' :
                  $typeSufix = '_t';
                  break;
                case 'textarea' :
                  $typeSufix = '_t';
                  break;
                case 'currency' :
                  $typeSufix = '_td';
                  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
      }
    } // empty APP_DATA
    
    $writer->endElement (); // end /doc
    
    return $writer->outputMemory ( true );
  }
  
  function getApplicationIndexData($AppUID) {
    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 );
    }
    
    // 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.
    foreach ( $allAppDbData as $row ) {
      $unassignedUsersGroups = array ();
      // use cache
      $oMemcache = PMmemcached::getSingleton ( $this->solrInstance );
      $unassignedUsersGroups = $oMemcache->get ( $row ['PRO_UID'] . "_" . $row ['TAS_UID'] );
      if (! $unassignedUsersGroups) {
        
        $unassignedUsersGroups = $this->getTaskUnassignedUsersGroupsData ( $row ['PRO_UID'], $row ['TAS_UID'] );
        
        // add del_index
        foreach ( $unassignedUsersGroups as $i => $newRow ) {
          $unassignedUsersGroups [$i] ['DEL_INDEX'] = $row ['DEL_INDEX'];
        }
        // store in cache
        $oMemcache->set ( $row ['PRO_UID'] . "_" . $row ['TAS_UID'], $unassignedUsersGroups );
      }
      
      // copy list of unassigned users and groups
      $unassignedUsers = array ();
      $unassignedGroups = array ();
      foreach ( $unassignedUsersGroups as $unassignedUserGroup ) {
        if ($unassignedUserGroup ['TU_RELATION'] == 1) {
          $unassignedUsers [] = array (
              'USR_UID' => $unassignedUserGroup ['USR_UID'],
              'DEL_INDEX' => $unassignedUserGroup ['DEL_INDEX'] 
          );
        }
        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 (file_exists ( PATH_DATA . '/sites/workflow/xmlForms/' . $dynaformFileName ['DYN_FILENAME'] . '.xml' )) {
          $dyn = new dynaFormHandler ( PATH_DATA . '/sites/workflow/xmlForms/' . $dynaformFileName ['DYN_FILENAME'] . '.xml' );
          $dynaformFields [] = $dyn->getFields ();
        }
      }
      
      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{array} $arr          
   * @param string $column          
   */
  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 unknown_type $arr          
   * @param unknown_type $column          
   * @param unknown_type $columnType          
   * @param unknown_type $columnCondition          
   * @param unknown_type $condition          
   * @return Ambigous <NULL, unknown>
   */
  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 o arrays $arr contains the arrays that are searched
   * @param array $andColumnsConditions
   *          contain the conditions that must be fullfill 'Column'=>'Condition'
   * @return multitype:unknown
   */
  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;
  }
  
  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;
  }
  
  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;
  }
  
  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
   *
   * @param unknown_type $AppUid          
   * @param integer $updated
   *          0:false, not updated, 1: updated, 2:deleted
   */
  function applicationChangedUpdateSolrQueue($AppUid, $updated) {
    $oAppSolrQueue = new AppSolrQueue ();
    
    $oAppSolrQueue->createUpdate ( $AppUid, $updated );
  }
  
  function synchronizePendingApplications() {
    // check table of pending updates
    $oAppSolrQueue = new AppSolrQueue ();
    
    $aAppSolrQueue = $oAppSolrQueue->getListUpdatedApplications ();
    
    foreach ( $aAppSolrQueue as $oAppSolrQueueEntity ) {
      // call the syncronization function
      $this->updateApplicationSearchIndex ( $oAppSolrQueueEntity->appUid );
      $this->applicationChangedUpdateSolrQueue ( $oAppSolrQueueEntity->appUid, 0 );
    }
  
  }
  
  function getCountApplicationsPMOS2() {
    $c = new Criteria ();
    
    $c->addSelectColumn ( ApplicationPeer::APP_UID );
    
    $count = ApplicationPeer::doCount ( $c );
    
    return $count;
  }
  
  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;
  }
  
  function reindexAllApplications() {
    $trunk = 1000;
    // 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 );
    // $numRows = 15;
    for($skip = 0; $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 );
  }

}