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

1757 lines
63 KiB
PHP
Raw Normal View History

BUG 0000 herbert> SOLR implementation in PMOS2 Solr support in PMOS2 includes: Functionality: - Implementation of Home views (Inbox, Draft, Participated, Unassigned). The views return fast results. - Include read, unread, all, and process filter in inbox View. - Include process filter in draft view. - Include started by me, completed by me, all, process, and status filter in participated view. - Include process filter in unassigned view. - Improved search functionality (search in user defined variables): Use the following syntax to search in process (user defined) variables. {variable_name}:{search_word} ex1:"causal:20*" where causal is the variable defined by the user. + Use of wildcards in search: Use * as wildcard at the begin or end of word + Multiple conditions in search: Separate multiple conditions by space ex2:"Materiales causal:20*" means that we are searching for the word Materiales and the causal that begin with 20. + Search in dates (interval ): Format=> {variable_date}:[yyyy-mm-dd TO yyyy-mm-dd] Local date not UTC date required ex: FechaRegistro:[2011-04-15 TO 2011-04-30] //registros con fecha entre el 2011-04-15 y el 2011-04-30. + we can use the wildcard *: ex: FechaRegistro:[* TO 2011-04-30] //registros con fecha menor o igual a 2011-04-30. FechaRegistro:[2011-04-15 TO *] //registros con fecha mayor o igual a 2011-04-15. + Search of exact phrases. format: {variable}:"frase a buscar" ex: Cliente:"Jesus Marin" - Application update function. + The function is called every time a change is detected in the application's data including the related delegations. - Use of cache to improve performance Not included: - Order of task, sent by, and due date columns. Pending: - Advanced search view using faceted lists.
2012-05-15 10:56:48 -04:00
<?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, Exception $previous = null) {
// some code
// make sure everything is assigned properly
parent::__construct ( $message, $code, $previous );
}
// custom string representation of object
public function __toString() {
return __CLASS__ . ": [{$this->code}]: {$this->message}\n";
}
}
class AppSolr {
private $solrIsEnabled = false;
private $solrHost = "";
private $solrInstance = "";
BUG 0000 Change Solr configuration environment variables Now the Solr configuration variables are read from the env.ini file that is stored in the shared//sites/SYS_SYS/ folder. The system class is used to get the environment variables using the solrenv function.
2012-05-15 17:41:12 -04:00
function __construct($SolrEnabled, $SolrHost, $SolrInstance) {
BUG 0000 herbert> SOLR implementation in PMOS2 Solr support in PMOS2 includes: Functionality: - Implementation of Home views (Inbox, Draft, Participated, Unassigned). The views return fast results. - Include read, unread, all, and process filter in inbox View. - Include process filter in draft view. - Include started by me, completed by me, all, process, and status filter in participated view. - Include process filter in unassigned view. - Improved search functionality (search in user defined variables): Use the following syntax to search in process (user defined) variables. {variable_name}:{search_word} ex1:"causal:20*" where causal is the variable defined by the user. + Use of wildcards in search: Use * as wildcard at the begin or end of word + Multiple conditions in search: Separate multiple conditions by space ex2:"Materiales causal:20*" means that we are searching for the word Materiales and the causal that begin with 20. + Search in dates (interval ): Format=> {variable_date}:[yyyy-mm-dd TO yyyy-mm-dd] Local date not UTC date required ex: FechaRegistro:[2011-04-15 TO 2011-04-30] //registros con fecha entre el 2011-04-15 y el 2011-04-30. + we can use the wildcard *: ex: FechaRegistro:[* TO 2011-04-30] //registros con fecha menor o igual a 2011-04-30. FechaRegistro:[2011-04-15 TO *] //registros con fecha mayor o igual a 2011-04-15. + Search of exact phrases. format: {variable}:"frase a buscar" ex: Cliente:"Jesus Marin" - Application update function. + The function is called every time a change is detected in the application's data including the related delegations. - Use of cache to improve performance Not included: - Order of task, sent by, and due date columns. Pending: - Advanced search view using faceted lists.
2012-05-15 10:56:48 -04:00
// define solr availability
BUG 0000 Change Solr configuration environment variables Now the Solr configuration variables are read from the env.ini file that is stored in the shared//sites/SYS_SYS/ folder. The system class is used to get the environment variables using the solrenv function.
2012-05-15 17:41:12 -04:00
$this->solrIsEnabled = $SolrEnabled;
$this->solrHost = $SolrHost;
$this->solrInstance = $SolrInstance;
BUG 0000 herbert> SOLR implementation in PMOS2 Solr support in PMOS2 includes: Functionality: - Implementation of Home views (Inbox, Draft, Participated, Unassigned). The views return fast results. - Include read, unread, all, and process filter in inbox View. - Include process filter in draft view. - Include started by me, completed by me, all, process, and status filter in participated view. - Include process filter in unassigned view. - Improved search functionality (search in user defined variables): Use the following syntax to search in process (user defined) variables. {variable_name}:{search_word} ex1:"causal:20*" where causal is the variable defined by the user. + Use of wildcards in search: Use * as wildcard at the begin or end of word + Multiple conditions in search: Separate multiple conditions by space ex2:"Materiales causal:20*" means that we are searching for the word Materiales and the causal that begin with 20. + Search in dates (interval ): Format=> {variable_date}:[yyyy-mm-dd TO yyyy-mm-dd] Local date not UTC date required ex: FechaRegistro:[2011-04-15 TO 2011-04-30] //registros con fecha entre el 2011-04-15 y el 2011-04-30. + we can use the wildcard *: ex: FechaRegistro:[* TO 2011-04-30] //registros con fecha menor o igual a 2011-04-30. FechaRegistro:[2011-04-15 TO *] //registros con fecha mayor o igual a 2011-04-15. + Search of exact phrases. format: {variable}:"frase a buscar" ex: Cliente:"Jesus Marin" - Application update function. + The function is called every time a change is detected in the application's data including the related delegations. - Use of cache to improve performance Not included: - Order of task, sent by, and due date columns. Pending: - Advanced search view using faceted lists.
2012-05-15 10:56:48 -04:00
}
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 = strstr ( $tok, ":", true );
$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 != '*') {
$fromDateDatetime = date_create_from_format ( 'Y-m-d', $fromDateOriginal );
$fromDate = gmdate ( "Y-m-d\T00:00:00\Z", $fromDateDatetime->getTimestamp () );
}
if ($toDateOriginal != '*') {
$toDateDatetime = date_create_from_format ( 'Y-m-d', $toDateOriginal );
$toDate = gmdate ( "Y-m-d\T00:00:00\Z", $toDateDatetime->getTimestamp () );
}
$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 ) {
$result = $this->getApplicationIndexData ( $aAPPUID ['APP_UID'] );
if ($result == null)
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 ) && $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
$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;
}
if (! $newdate) {
$typeSufix = '*'; // not store field
}
else {
$typeSufix = '_tdt';
if ($withHour)
$value = gmdate ( "Y-m-d\TH:i:s\Z", $newdate->getTimestamp () );
else {
$value = gmdate ( "Y-m-d\T00:00:00\Z", $newdate->getTimestamp () );
}
}
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 Exception ( "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 );
}
}
Reference in New Issue Copy Permalink