2351 lines
98 KiB
PHP
2351 lines
98 KiB
PHP
<?php
|
|
/**
|
|
*
|
|
* ProcessMaker Open Source Edition
|
|
* Copyright (C) 2004 - 2012 Colosa Inc.23
|
|
*
|
|
* This program is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU Affero General Public License as
|
|
* published by the Free Software Foundation, either version 3 of the
|
|
* License, or (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU Affero General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Affero General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
* For more information, contact Colosa Inc, 5304 Ventura Drive,
|
|
* Delray Beach, FL, 33484, USA, or email info@colosa.com.
|
|
*
|
|
*/
|
|
|
|
require_once "classes/model/Application.php";
|
|
require_once "classes/model/AppDelegation.php";
|
|
require_once "classes/model/AppThread.php";
|
|
require_once "classes/model/Content.php";
|
|
require_once "classes/model/Users.php";
|
|
require_once "classes/model/GroupUser.php";
|
|
require_once "classes/model/Task.php";
|
|
require_once "classes/model/TaskUser.php";
|
|
require_once "classes/model/Dynaform.php";
|
|
require_once "entities/SolrRequestData.php";
|
|
require_once "entities/SolrUpdateDocument.php";
|
|
require_once "entities/AppSolrQueue.php";
|
|
require_once "classes/model/AppSolrQueue.php";
|
|
|
|
/**
|
|
* Invalid search text for Solr exception
|
|
*
|
|
* @author Herbert Saal Gutierrez
|
|
*
|
|
*/
|
|
class InvalidIndexSearchTextException extends Exception
|
|
{
|
|
// Redefine the exception so message isn't optional
|
|
public function __construct ($message, $code = 0)
|
|
{
|
|
// some code
|
|
// make sure everything is assigned properly
|
|
parent::__construct( $message, $code );
|
|
}
|
|
|
|
// custom string representation of object
|
|
public function __toString ()
|
|
{
|
|
return __CLASS__ . ": [{$this->code}]: {$this->message}\n";
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Application without Delegations exception
|
|
*
|
|
* @author Herbert Saal Gutierrez
|
|
*
|
|
* @category Colosa
|
|
* @copyright Copyright (c) 2005-2012 Colosa Inc. (http://www.colosa.com)
|
|
*/
|
|
class ApplicationWithoutDelegationRecordsException extends Exception
|
|
{
|
|
// Redefine the exception so message isn't optional
|
|
public function __construct ($message, $code = 0)
|
|
{
|
|
// some code
|
|
// make sure everything is assigned properly
|
|
parent::__construct( $message, $code );
|
|
}
|
|
|
|
// custom string representation of object
|
|
public function __toString ()
|
|
{
|
|
return __CLASS__ . ": [{$this->code}]: {$this->message}\n";
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Dynaform file corrupt
|
|
*
|
|
* @author Herbert Saal Gutierrez
|
|
*
|
|
* @category Colosa
|
|
* @copyright Copyright (c) 2005-2012 Colosa Inc. (http://www.colosa.com)
|
|
*/
|
|
class ApplicationWithCorruptDynaformException extends Exception
|
|
{
|
|
// Redefine the exception so message isn't optional
|
|
public function __construct ($message, $code = 0)
|
|
{
|
|
// some code
|
|
// make sure everything is assigned properly
|
|
parent::__construct( $message, $code );
|
|
}
|
|
|
|
// custom string representation of object
|
|
public function __toString ()
|
|
{
|
|
return __CLASS__ . ": [{$this->code}]: {$this->message}\n";
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Application APP_DATA could not be unserialized exception
|
|
*
|
|
* @author Herbert Saal Gutierrez
|
|
*
|
|
* @category Colosa
|
|
* @copyright Copyright (c) 2005-2012 Colosa Inc. (http://www.colosa.com)
|
|
*/
|
|
class ApplicationAPP_DATAUnserializeException extends Exception
|
|
{
|
|
// Redefine the exception so message isn't optional
|
|
public function __construct ($message, $code = 0)
|
|
{
|
|
// some code
|
|
// make sure everything is assigned properly
|
|
parent::__construct( $message, $code );
|
|
}
|
|
|
|
// custom string representation of object
|
|
public function __toString ()
|
|
{
|
|
return __CLASS__ . ": [{$this->code}]: {$this->message}\n";
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Implementation to display application data in the PMOS2 grids using Solr
|
|
* search service
|
|
*
|
|
* @author Herbert Saal Gutierrez
|
|
* @category Colosa
|
|
* @copyright Copyright (c) 2005-2011 Colosa Inc. (http://www.colosa.com)
|
|
*
|
|
*/
|
|
class AppSolr
|
|
{
|
|
private $_solrIsEnabled = false;
|
|
private $_solrHost = "";
|
|
private $_solrInstance = "";
|
|
private $debug = false; //false
|
|
|
|
|
|
public function __construct ($SolrEnabled, $SolrHost, $SolrInstance)
|
|
{
|
|
// define solr availability
|
|
$this->_solrIsEnabled = $SolrEnabled;
|
|
$this->_solrHost = $SolrHost;
|
|
$this->_solrInstance = $SolrInstance;
|
|
}
|
|
|
|
/**
|
|
* Return if the Solr functionality is enabled.
|
|
*
|
|
* @return boolean true:enabled functionality, false:disabled functionality
|
|
*/
|
|
public function isSolrEnabled ()
|
|
{
|
|
return $this->_solrIsEnabled;
|
|
}
|
|
|
|
/**
|
|
* Gets the information of Grids using Solr server.
|
|
*
|
|
* Returns the list of records for the grid depending of the function
|
|
* conditions
|
|
* If doCount is true only the count of records is returned.
|
|
*
|
|
* @param string $userUid current logged user.
|
|
* @param int $start the offset to return the group of records. Used for pagination.
|
|
* @param int $limit The number of records to return in the set.
|
|
* @param string $action the action: todo, participated, draft, unassigned
|
|
* @param string $filter filter the results posible values ('read', 'unread', 'started',
|
|
* 'completed')
|
|
* @param string $search search string
|
|
* @param string $process PRO_UID to filter results by specified process.
|
|
* @param string $user USR_UID to filter results by specified user.
|
|
* @param string $status filter by an application Status : TO_DO, COMPLETED, DRAFT
|
|
* @param string $type default extjs
|
|
* @param string $dateFrom filter by DEL_DELEGATE_DATE, not used
|
|
* @param string $dateTo filter by DEL_DELEGATE_DATE, not used
|
|
* @param string $callback default stcCallback1001 not used
|
|
* @param string $dir sort direction ASC, DESC
|
|
* @param string $sort sort field
|
|
* @param boolean $doCount default=false, if true only the count of records is returned.
|
|
* @return array return the list of cases
|
|
*/
|
|
public function getAppGridData ($userUid, $start = null, $limit = null, $action = null, $filter = null, $search = null, $process = null, $user = null, $status = null, $type = null, $dateFrom = null, $dateTo = null, $callback = null, $dir = null, $sort = 'APP_CACHE_VIEW.APP_NUMBER', $doCount = false)
|
|
{
|
|
|
|
$callback = isset( $callback ) ? $callback : 'stcCallback1001';
|
|
$dir = isset( $dir ) ? $dir : 'DESC'; // direction of sort column
|
|
// (ASC, DESC)
|
|
$sort = isset( $sort ) ? $sort : ''; // sort column (APP_NUMBER,
|
|
// CASE_SUMMARY,
|
|
// CASE_NOTES_COUNT, APP_TITLE,
|
|
// APP_PRO_TITLE, APP_TAS_TITLE,
|
|
// APP_DEL_PREVIOUS_USER,
|
|
// DEL_TASK_DUE_DATE,
|
|
// APP_UPDATE_DATE, DEL_PRIORITY)
|
|
$start = isset( $start ) ? $start : '0';
|
|
$limit = isset( $limit ) ? $limit : '25';
|
|
$filter = isset( $filter ) ? $filter : ''; // posible values ('read',
|
|
// 'unread', 'started',
|
|
// 'completed')
|
|
$search = isset( $search ) ? $search : ''; // search in fields, plain text
|
|
$process = isset( $process ) ? $process : ''; // filter by an specific
|
|
// process
|
|
// uid
|
|
$user = isset( $user ) ? $user : ''; // filter by an specific user uid
|
|
$status = isset( $status ) ? strtoupper( $status ) : ''; // filter by an
|
|
// specific
|
|
// app_status
|
|
$action = isset( $action ) ? $action : 'todo'; // todo, paused
|
|
$type = isset( $type ) ? $type : 'extjs';
|
|
$dateFrom = isset( $dateFrom ) ? $dateFrom : ''; // filter by
|
|
// DEL_DELEGATE_DATE
|
|
$dateTo = isset( $dateTo ) ? $dateTo : ''; // filter by DEL_DELEGATE_DATE
|
|
|
|
|
|
$swErrorInSearchText = false;
|
|
$solrQueryResult = null;
|
|
$aPriorities = array ('1' => 'VL','2' => 'L','3' => 'N','4' => 'H','5' => 'VH'
|
|
);
|
|
$delegationIndexes = array ();
|
|
|
|
$result = array ();
|
|
$result['totalCount'] = 0;
|
|
$result['data'] = array ();
|
|
$result['success'] = false;
|
|
$result['message'] = "Error description.";
|
|
|
|
G::LoadClass( 'searchIndex' );
|
|
|
|
try {
|
|
if ($this->debug) {
|
|
$this->initTimeAll = microtime( true );
|
|
}
|
|
|
|
// the array of data that must be returned with placeholders
|
|
$columsToInclude = array ('APP_CREATE_DATE','','','','APP_NUMBER','','APP_PRO_TITLE','APP_STATUS','','','APP_TITLE','APP_UID','DEL_LAST_UPDATE_DATE','','','','','','','','','DEL_MAX_PRIORITY','','','','','','PRO_UID','',''
|
|
);
|
|
// create pagination data
|
|
$solrSearchText = "";
|
|
$sortableCols = array ();
|
|
$sortCols = array ();
|
|
$sortDir = array ();
|
|
$numSortingCols = 0;
|
|
|
|
// define sort conditions, default APP_NUMBER, desc
|
|
// only one column is sorted
|
|
$dir = strtolower( $dir );
|
|
|
|
if (! empty( $sort )) {
|
|
switch ($sort) {
|
|
case 'APP_CACHE_VIEW.APP_NUMBER':
|
|
case 'APP_NUMBER':
|
|
$sortCols[0] = 4;
|
|
$sortableCols[0] = 'true';
|
|
$sortDir[0] = $dir;
|
|
break;
|
|
// multivalue field can't be ordered
|
|
case 'APP_TITLE':
|
|
$sortCols[0] = 10;
|
|
$sortableCols[0] = 'true';
|
|
$sortDir[0] = $dir;
|
|
break;
|
|
case 'APP_PRO_TITLE':
|
|
$sortCols[0] = 6;
|
|
$sortableCols[0] = 'true';
|
|
$sortDir[0] = $dir;
|
|
break;
|
|
case 'APP_UPDATE_DATE':
|
|
$sortCols[0] = 12;
|
|
$sortableCols[0] = 'true';
|
|
$sortDir[0] = $dir;
|
|
break;
|
|
default:
|
|
$sortCols[0] = 4;
|
|
$sortableCols[0] = 'true';
|
|
$sortDir[0] = 'desc';
|
|
break;
|
|
}
|
|
$numSortingCols ++;
|
|
}
|
|
|
|
// get del_index field
|
|
$delIndexDynaField = "";
|
|
// process filter
|
|
if ($process != '') {
|
|
$solrSearchText .= "PRO_UID:" . $process . " AND ";
|
|
}
|
|
// status filter
|
|
if ($status != '') {
|
|
$solrSearchText .= "APP_STATUS:" . $status . " AND ";
|
|
}
|
|
// todo list, add condition
|
|
if ($userUid != null && $action == 'todo') {
|
|
if ($filter == 'read') {
|
|
$solrSearchText .= "APP_ASSIGNED_USERS_READ:" . $userUid . " AND ";
|
|
$delegationIndexes[] = "APP_ASSIGNED_USER_READ_DEL_INDEX_" . trim( $userUid ) . '_txt';
|
|
} elseif ($filter == 'unread') {
|
|
$solrSearchText .= "APP_ASSIGNED_USERS_UNREAD:" . $userUid . " AND ";
|
|
$delegationIndexes[] = "APP_ASSIGNED_USER_UNREAD_DEL_INDEX_" . trim( $userUid ) . '_txt';
|
|
} else {
|
|
$solrSearchText .= "APP_ASSIGNED_USERS:" . $userUid . " AND ";
|
|
$delegationIndexes[] = "APP_ASSIGNED_USER_DEL_INDEX_" . trim( $userUid ) . '_txt';
|
|
}
|
|
}
|
|
// participated, add condition
|
|
if ($userUid != null && $action == 'sent') {
|
|
if ($filter == 'started') {
|
|
$solrSearchText .= "APP_PARTICIPATED_USERS_STARTED:" . $userUid . " AND ";
|
|
$delegationIndexes[] = "APP_PARTICIPATED_USER_STARTED_DEL_INDEX_" . trim( $userUid ) . '_txt';
|
|
} elseif ($filter == 'completed') {
|
|
$solrSearchText .= "APP_PARTICIPATED_USERS_COMPLETED:" . $userUid . " AND ";
|
|
$delegationIndexes[] = "APP_PARTICIPATED_USER_COMPLETED_DEL_INDEX_" . trim( $userUid ) . '_txt';
|
|
} else {
|
|
$solrSearchText .= "APP_PARTICIPATED_USERS:" . $userUid . " AND ";
|
|
$delegationIndexes[] = "APP_PARTICIPATED_USER_DEL_INDEX_" . trim( $userUid ) . '_txt';
|
|
}
|
|
}
|
|
// draft, add condition
|
|
if ($userUid != null && $action == 'draft') {
|
|
$solrSearchText .= "APP_DRAFT_USER:" . $userUid . " AND ";
|
|
// index is allways 1
|
|
}
|
|
// unassigned, add condition
|
|
if ($userUid != null && $action == 'unassigned') {
|
|
// get the list of groups to which belongs the user.
|
|
$userGroups = $this->getUserGroups( $userUid );
|
|
|
|
$solrSearchText .= "(APP_UNASSIGNED_USERS:" . $userUid;
|
|
if (count( $userGroups ) > 0) {
|
|
$solrSearchText .= " OR ";
|
|
|
|
foreach ($userGroups as $group) {
|
|
$solrSearchText .= "APP_UNASSIGNED_GROUPS:" . $group['GRP_UID'] . " OR ";
|
|
}
|
|
|
|
// remove last OR in condition
|
|
if ($solrSearchText != '') {
|
|
$solrSearchText = substr_replace( $solrSearchText, "", - 4 );
|
|
}
|
|
}
|
|
$solrSearchText .= ") AND ";
|
|
|
|
$delegationIndexes[] = "APP_UNASSIGNED_USER_GROUP_DEL_INDEX_" . trim( $userUid ) . '_txt';
|
|
foreach ($userGroups as $group) {
|
|
$delegationIndexes[] = "APP_UNASSIGNED_USER_GROUP_DEL_INDEX_" . trim( $group['GRP_UID'] ) . '_txt';
|
|
}
|
|
}
|
|
|
|
//search action
|
|
if ($action == 'search' && $dateFrom != "" && $dateTo != "") {
|
|
$fromDate = date( "Y-m-d", strtotime( $dateFrom ) );
|
|
$toDate = date( "Y-m-d", strtotime( $dateTo ) );
|
|
|
|
$searchDateOriginal = "DEL_LAST_UPDATE_DATE:[" . $fromDate . " TO " . $toDate . "]";
|
|
//FechaRegistro:[2011-04-15 TO 2011-04-30]
|
|
|
|
|
|
$searchDateFormatedSolr = $this->getSearchText( $searchDateOriginal );
|
|
|
|
$solrSearchText .= "(" . $searchDateFormatedSolr . ") AND ";
|
|
|
|
}
|
|
|
|
// remove last AND in condition
|
|
if ($solrSearchText != '') {
|
|
$solrSearchText = substr_replace( $solrSearchText, "", - 5 );
|
|
}
|
|
|
|
// add parenthesis to Solr search text
|
|
if ($solrSearchText != "") {
|
|
$solrSearchText = "(" . $solrSearchText . ")";
|
|
}
|
|
// create query string, add query conditions
|
|
if ($search != '') {
|
|
// format search string
|
|
// return exception in case of invalid text
|
|
$search = $this->getSearchText( $search );
|
|
|
|
if ($solrSearchText != "" && $search != "") {
|
|
$solrSearchText .= " AND ";
|
|
}
|
|
if ($search != "") {
|
|
$solrSearchText .= "(" . $search . ")";
|
|
}
|
|
}
|
|
// add del_index dynamic fields to list of resulting columns
|
|
// the fields begin in the 30th column and more
|
|
$columsToInclude = array_merge( $columsToInclude, $delegationIndexes );
|
|
|
|
// if is a counter no records are returned
|
|
if ($doCount) {
|
|
$start = 0;
|
|
$limit = 0;
|
|
$numSortingCols = 0;
|
|
$columsToInclude = array ();
|
|
}
|
|
|
|
$data = array ('workspace' => $this->_solrInstance, // solr instance
|
|
'startAfter' => intval( $start ),'pageSize' => intval( $limit ),'searchText' => $solrSearchText,'filterText' => '', // $filter, //ex:'field1:value1,field2:[value2.1
|
|
// TO value2.2],field3:value3'
|
|
'numSortingCols' => $numSortingCols,'sortableCols' => $sortableCols,'sortCols' => $sortCols,'sortDir' => $sortDir,'includeCols' => $columsToInclude,'resultFormat' => 'json'
|
|
);
|
|
|
|
$solrRequestData = Entity_SolrRequestData::createForRequestPagination( $data );
|
|
// use search index to return list of cases
|
|
$searchIndex = new BpmnEngine_Services_SearchIndex( $this->_solrIsEnabled, $this->_solrHost );
|
|
// execute query
|
|
$solrQueryResult = $searchIndex->getDataTablePaginatedList( $solrRequestData );
|
|
|
|
if ($this->debug) {
|
|
$this->afterSolrQueryTime = microtime( true );
|
|
}
|
|
//return inmediatelly
|
|
if ($doCount) {
|
|
$result['totalCount'] = $solrQueryResult->iTotalDisplayRecords;
|
|
$result['data'] = array ();
|
|
$result['success'] = true;
|
|
$result['result'] = true;
|
|
$result['message'] = "";
|
|
|
|
return $result;
|
|
}
|
|
// complete return data, complete list of columns in grid
|
|
$resultColumns = array ("APP_CREATE_DATE","APP_CURRENT_USER","APP_DEL_PREVIOUS_USER","APP_FINISH_DATE","APP_NUMBER","APP_OVERDUE_PERCENTAGE","APP_PRO_TITLE","APP_STATUS","APP_TAS_TITLE","APP_THREAD_STATUS","APP_TITLE","APP_UID","APP_UPDATE_DATE","DEL_DELAYED","DEL_DELAY_DURATION","DEL_DELEGATE_DATE","DEL_DURATION","DEL_FINISHED","DEL_FINISH_DATE","DEL_INDEX","DEL_INIT_DATE","DEL_PRIORITY","DEL_QUEUE_DURATION","DEL_STARTED","DEL_TASK_DUE_DATE","DEL_THREAD_STATUS","PREVIOUS_USR_UID","PRO_UID","TAS_UID","USR_UID"
|
|
);
|
|
|
|
$rows = array ();
|
|
// number of found records
|
|
$result['totalCount'] = $solrQueryResult->iTotalDisplayRecords;
|
|
|
|
//get all the data from database
|
|
$appUids = array ();
|
|
foreach ($solrQueryResult->aaData as $i => $data) {
|
|
$appUids[] = $data[11];
|
|
}
|
|
|
|
$aaappsDBData = $this->getListApplicationDelegationData( $appUids );
|
|
|
|
if ($this->debug) {
|
|
$this->afterDbQueryTime = microtime( true );
|
|
}
|
|
// complete the missing data to display it in the grid.
|
|
$delIndexes = array (); //store all the delegation indexes
|
|
foreach ($solrQueryResult->aaData as $i => $data) {
|
|
//initialize array
|
|
$delIndexes = array ();
|
|
// complete empty values
|
|
$appUID = $data[11];
|
|
//get all the delindexes
|
|
for ($i = 30; $i < count( $data ); $i ++) {
|
|
if (is_array( $data[$i] )) {
|
|
foreach ($data[$i] as $delIndex) {
|
|
$delIndexes[] = $delIndex;
|
|
}
|
|
}
|
|
}
|
|
// verify if the delindex is an array
|
|
// if is not check different types of repositories
|
|
// the delegation index must always be defined.
|
|
if (count( $delIndexes ) == 0) {
|
|
// if is draft
|
|
if ($action == 'draft') {
|
|
$delIndexes[] = 1; // the first default index
|
|
} elseif ($action == 'search') {
|
|
// get all the indexes
|
|
|
|
|
|
//$delIndexes = $this->getApplicationDelegationsIndex ($appUID);
|
|
$indexes = $this->aaSearchRecords( $aaappsDBData, array ('APP_UID' => $appUID
|
|
) );
|
|
|
|
foreach ($indexes as $index) {
|
|
$delIndexes[] = $aaappsDBData[$index]['DEL_INDEX'];
|
|
}
|
|
|
|
} else {
|
|
//error an index must always be defined
|
|
print "Delegation not defined\n";
|
|
}
|
|
/*
|
|
* elseif ($action == 'unassigned'){ $delIndexes = $this->getApplicationDelegationsIndex ($appUID); }
|
|
*/
|
|
}
|
|
//remove duplicated
|
|
$delIndexes = array_unique( $delIndexes );
|
|
foreach ($delIndexes as $delIndex) {
|
|
$aRow = array ();
|
|
foreach ($resultColumns as $j => $columnName) {
|
|
$aRow[$columnName] = $data[$j];
|
|
}
|
|
// convert date from solr format UTC to local time in MySQL format
|
|
$solrdate = $data[0];
|
|
$localDate = date( 'Y-m-d H:i:s', strtotime( $solrdate ) );
|
|
$aRow['APP_CREATE_DATE'] = $localDate;
|
|
|
|
$solrdate = $data[12];
|
|
$localDate = date( 'Y-m-d H:i:s', strtotime( $solrdate ) );
|
|
$aRow['APP_UPDATE_DATE'] = $localDate;
|
|
|
|
// get delegation data from DB
|
|
//filter data from db
|
|
$indexes = $this->aaSearchRecords( $aaappsDBData, array ('APP_UID' => $appUID,'DEL_INDEX' => $delIndex
|
|
) );
|
|
|
|
foreach ($indexes as $index) {
|
|
$row = $aaappsDBData[$index];
|
|
}
|
|
|
|
if (! isset( $row )) {
|
|
$fh = fopen( "SolrAppWhitoutDelIndex.txt", 'a' ) or die( "can't open file to store Solr search time." );
|
|
fwrite( $fh, sprintf( "Solr AppUid: %s DelIndex: %s not found.\r\n", $appUID, $delIndex ) );
|
|
fclose( $fh );
|
|
continue;
|
|
}
|
|
//$row = $this->getAppDelegationData ($appUID, $delIndex);
|
|
|
|
|
|
$aRow['APP_FINISH_DATE'] = null;
|
|
$aRow['APP_CURRENT_USER'] = $row['USR_NAME'] . " " . $row['USR_LAST'];
|
|
$aRow['APP_DEL_PREVIOUS_USER'] = $row['USR_PREV_NAME'] . " " . $row['USR_PREV_LAST'];
|
|
$aRow['APP_OVERDUE_PERCENTAGE'] = $row['APP_OVERDUE_PERCENTAGE'];
|
|
$aRow['APP_TAS_TITLE'] = $row['APP_TAS_TITLE'];
|
|
$aRow['APP_THREAD_STATUS'] = $row['APP_THREAD_STATUS'];
|
|
$aRow['DEL_DELAYED'] = $row['DEL_DELAYED'];
|
|
$aRow['DEL_DELAY_DURATION'] = $row['DEL_DELAY_DURATION'];
|
|
$aRow['DEL_DELEGATE_DATE'] = $row['DEL_DELEGATE_DATE'];
|
|
$aRow['DEL_DURATION'] = $row['DEL_DURATION'];
|
|
$aRow['DEL_FINISHED'] = (isset( $row['DEL_FINISH_DATE'] ) && $row['DEL_FINISH_DATE'] != '') ? 1 : 0;
|
|
$aRow['DEL_FINISH_DATE'] = $row['DEL_FINISH_DATE'];
|
|
$aRow['DEL_INDEX'] = $row['DEL_INDEX'];
|
|
$aRow['DEL_INIT_DATE'] = $row['DEL_INIT_DATE'];
|
|
$aRow['DEL_QUEUE_DURATION'] = $row['DEL_QUEUE_DURATION'];
|
|
$aRow['DEL_STARTED'] = (isset( $row['DEL_INIT_DATE'] ) && $row['DEL_INIT_DATE'] != '') ? 1 : 0;
|
|
$aRow['DEL_TASK_DUE_DATE'] = $row['DEL_TASK_DUE_DATE'];
|
|
$aRow['DEL_THREAD_STATUS'] = $row['DEL_THREAD_STATUS'];
|
|
$aRow['PREVIOUS_USR_UID'] = $row['PREVIOUS_USR_UID'];
|
|
$aRow['TAS_UID'] = $row['TAS_UID'];
|
|
$aRow['USR_UID'] = $userUid;
|
|
$aRow['DEL_PRIORITY'] = G::LoadTranslation( "ID_PRIORITY_{$aPriorities[$aRow['DEL_PRIORITY']]}" );
|
|
|
|
$rows[] = $aRow;
|
|
}
|
|
}
|
|
$result['data'] = $rows;
|
|
$result['success'] = true;
|
|
$result['result'] = true;
|
|
$result['message'] = "";
|
|
|
|
/**
|
|
* ******************************************
|
|
*/
|
|
if ($this->debug) {
|
|
$this->afterPrepareResultTime = microtime( true );
|
|
|
|
$fh = fopen( "SolrSearchTime.txt", 'a' ) or die( "can't open file to store Solr search time." );
|
|
//fwrite($fh, sprintf("Solr Query time: %s DB Query time: %s Prepare result time: %s \n", gmdate ('H:i:s:u', ($this->afterSolrQueryTime - $this->initTimeAll)), gmdate ('H:i:s:u', ($this->afterDbQueryTime - $this->afterSolrQueryTime)), gmdate ('H:i:s:u', ($this->afterPrepareResultTime - $this->afterDbQueryTime)) ));
|
|
fwrite( $fh, sprintf( "Solr Query time: %s DB Query time: %s Prepare result time: %s Total:%s \r\n", ($this->afterSolrQueryTime - $this->initTimeAll), ($this->afterDbQueryTime - $this->afterSolrQueryTime), ($this->afterPrepareResultTime - $this->afterDbQueryTime), ($this->afterPrepareResultTime - $this->initTimeAll) ) );
|
|
fclose( $fh );
|
|
}
|
|
/**
|
|
* ************************************
|
|
*/
|
|
|
|
return $result;
|
|
|
|
} catch (InvalidIndexSearchTextException $ex) {
|
|
// return empty result with description of error
|
|
$result = array ();
|
|
$result['totalCount'] = 0;
|
|
$result['data'] = array ();
|
|
$result['success'] = true;
|
|
$result['result'] = false;
|
|
$result['message'] = $ex->getMessage();
|
|
return $result;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get the array of counters of cases
|
|
*
|
|
* @param string $userUid the current logged user uid identifier
|
|
*/
|
|
public function getCasesCount ($userUid)
|
|
{
|
|
$casesCount = array ();
|
|
|
|
// get number of records in todo list
|
|
$data = $this->getAppGridData( $userUid, 0, 0, 'todo', null, null, null, null, null, null, null, null, null, null, null, true );
|
|
$casesCount['to_do'] = $data['totalCount'];
|
|
// get number of records in participated list
|
|
$data = $this->getAppGridData( $userUid, 0, 0, 'sent', null, null, null, null, null, null, null, null, null, null, null, true );
|
|
$casesCount['sent'] = $data['totalCount'];
|
|
// get number of records in draft list
|
|
$data = $this->getAppGridData( $userUid, 0, 0, 'draft', null, null, null, null, null, null, null, null, null, null, null, true );
|
|
$casesCount['draft'] = $data['totalCount'];
|
|
// get number of records in unassigned list
|
|
$data = $this->getAppGridData( $userUid, 0, 0, 'unassigned', null, null, null, null, null, null, null, null, null, null, null, true );
|
|
$casesCount['selfservice'] = $data['totalCount'];
|
|
|
|
return $casesCount;
|
|
}
|
|
|
|
/**
|
|
* Get the user groups
|
|
*
|
|
* @param string $usrUID the user identifier
|
|
* @return array of user groups
|
|
*/
|
|
public function getUserGroups ($usrUID)
|
|
{
|
|
$gu = new GroupUser();
|
|
$rows = $gu->getAllUserGroups( $usrUID );
|
|
return $rows;
|
|
}
|
|
|
|
/**
|
|
* Get the application delegation record from database
|
|
*
|
|
* @param string $aappUIDs array of Application identifiers
|
|
* @return array of arrays with delegation information.
|
|
*/
|
|
public function getListApplicationDelegationData ($aappUIDs)
|
|
{
|
|
|
|
$c = new Criteria();
|
|
|
|
$c->addSelectColumn( AppDelegationPeer::APP_UID );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_INDEX );
|
|
|
|
$c->addAsColumn( 'USR_NAME', 'u.USR_FIRSTNAME' );
|
|
$c->addAsColumn( 'USR_LAST', 'u.USR_LASTNAME' );
|
|
|
|
$c->addAsColumn( 'USR_PREV_NAME', 'uprev.USR_FIRSTNAME' );
|
|
$c->addAsColumn( 'USR_PREV_LAST', 'uprev.USR_LASTNAME' );
|
|
$c->addAsColumn( 'PREVIOUS_USR_UID', 'uprev.USR_UID' );
|
|
|
|
$c->addAsColumn( 'APP_TAS_TITLE', 'ctastitle.CON_VALUE' );
|
|
$c->addAsColumn( 'APP_THREAD_STATUS', 'at.APP_THREAD_STATUS' );
|
|
|
|
$c->addSelectColumn( AppDelegationPeer::APP_OVERDUE_PERCENTAGE );
|
|
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_DELAYED );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_DELAY_DURATION );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_DELEGATE_DATE );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_DURATION );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_FINISH_DATE );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_INIT_DATE );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_QUEUE_DURATION );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_TASK_DUE_DATE );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_THREAD_STATUS );
|
|
$c->addSelectColumn( AppDelegationPeer::TAS_UID );
|
|
|
|
$c->addAlias( 'u', 'USERS' );
|
|
$c->addAlias( 'uprev', 'USERS' );
|
|
$c->addAlias( 'adprev', 'APP_DELEGATION' );
|
|
$c->addAlias( 'ctastitle', 'CONTENT' );
|
|
$c->addAlias( 'at', 'APP_THREAD' );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array (AppDelegationPeer::USR_UID,'u.USR_UID'
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array (AppDelegationPeer::APP_UID,'adprev.APP_UID'
|
|
);
|
|
$aConditions[] = array (AppDelegationPeer::DEL_PREVIOUS,'adprev.DEL_INDEX'
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array (AppDelegationPeer::TAS_UID,'ctastitle.CON_ID'
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array ('adprev.USR_UID','uprev.USR_UID'
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array (AppDelegationPeer::APP_UID,'at.APP_UID'
|
|
);
|
|
$aConditions[] = array (AppDelegationPeer::DEL_THREAD,'at.APP_THREAD_INDEX'
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$c->add( AppDelegationPeer::APP_UID, $aappUIDs, Criteria::IN );
|
|
//$c->add (AppDelegationPeer::DEL_INDEX, $delIndex);
|
|
|
|
|
|
$c->add( 'ctastitle.CON_CATEGORY', 'TAS_TITLE' );
|
|
$c->add( 'ctastitle.CON_LANG', 'en' );
|
|
|
|
$rs = AppDelegationPeer::doSelectRS( $c );
|
|
$rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
|
|
// echo $c->toString();
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
|
|
$appDataRows = array ();
|
|
while (is_array( $row )) {
|
|
$appDataRows[] = $row;
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
}
|
|
|
|
return $appDataRows;
|
|
}
|
|
|
|
/**
|
|
* Get the application delegation record from database
|
|
*
|
|
* @param string $appUID Application identifier
|
|
* @param string $delIndex delegation index
|
|
* @return array with delegation record.
|
|
*/
|
|
public function getAppDelegationData ($appUID, $delIndex)
|
|
{
|
|
|
|
$c = new Criteria();
|
|
|
|
$c->addSelectColumn( AppDelegationPeer::APP_UID );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_INDEX );
|
|
|
|
$c->addAsColumn( 'USR_NAME', 'u.USR_FIRSTNAME' );
|
|
$c->addAsColumn( 'USR_LAST', 'u.USR_LASTNAME' );
|
|
|
|
$c->addAsColumn( 'USR_PREV_NAME', 'uprev.USR_FIRSTNAME' );
|
|
$c->addAsColumn( 'USR_PREV_LAST', 'uprev.USR_LASTNAME' );
|
|
$c->addAsColumn( 'PREVIOUS_USR_UID', 'uprev.USR_UID' );
|
|
|
|
$c->addAsColumn( 'APP_TAS_TITLE', 'ctastitle.CON_VALUE' );
|
|
$c->addAsColumn( 'APP_THREAD_STATUS', 'at.APP_THREAD_STATUS' );
|
|
|
|
$c->addSelectColumn( AppDelegationPeer::APP_OVERDUE_PERCENTAGE );
|
|
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_DELAYED );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_DELAY_DURATION );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_DELEGATE_DATE );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_DURATION );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_FINISH_DATE );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_INIT_DATE );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_QUEUE_DURATION );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_TASK_DUE_DATE );
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_THREAD_STATUS );
|
|
$c->addSelectColumn( AppDelegationPeer::TAS_UID );
|
|
|
|
$c->addAlias( 'u', 'USERS' );
|
|
$c->addAlias( 'uprev', 'USERS' );
|
|
$c->addAlias( 'adprev', 'APP_DELEGATION' );
|
|
$c->addAlias( 'ctastitle', 'CONTENT' );
|
|
$c->addAlias( 'at', 'APP_THREAD' );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array (AppDelegationPeer::USR_UID,'u.USR_UID'
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array (AppDelegationPeer::APP_UID,'adprev.APP_UID'
|
|
);
|
|
$aConditions[] = array (AppDelegationPeer::DEL_PREVIOUS,'adprev.DEL_INDEX'
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array (AppDelegationPeer::TAS_UID,'ctastitle.CON_ID'
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array ('adprev.USR_UID','uprev.USR_UID'
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array (AppDelegationPeer::APP_UID,'at.APP_UID'
|
|
);
|
|
$aConditions[] = array (AppDelegationPeer::DEL_THREAD,'at.APP_THREAD_INDEX'
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$c->add( AppDelegationPeer::APP_UID, $appUID );
|
|
$c->add( AppDelegationPeer::DEL_INDEX, $delIndex );
|
|
|
|
$c->add( 'ctastitle.CON_CATEGORY', 'TAS_TITLE' );
|
|
$c->add( 'ctastitle.CON_LANG', 'en' );
|
|
|
|
$rs = AppDelegationPeer::doSelectRS( $c );
|
|
$rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
|
|
// echo $c->toString();
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
|
|
return $row;
|
|
}
|
|
|
|
/**
|
|
* return the correct search text for solr.
|
|
* if a field is included only search in this field.
|
|
*
|
|
* @param string $plainSearchText
|
|
* @return string formated Solr search string.
|
|
*/
|
|
public function getSearchText ($plainSearchText)
|
|
{
|
|
$formattedSearchText = "";
|
|
// if an error is found in string null is returned
|
|
$includeToken = true;
|
|
|
|
// prepare string to separate and join parentesis
|
|
// " " => " "
|
|
$count = 1;
|
|
while ($count > 0) {
|
|
$plainSearchText = preg_replace( '/\s\s+/', ' ', $plainSearchText, - 1, $count );
|
|
}
|
|
// "text0( text1" => "text0 (text1"; "text0 )text1" => "text0) text1";
|
|
$plainSearchText = preg_replace( '/\s\[\s/', '[', $plainSearchText );
|
|
$plainSearchText = preg_replace( '/\s\]\s/', '] ', $plainSearchText );
|
|
$plainSearchText = preg_replace( '/\s"\s/', '" ', $plainSearchText );
|
|
|
|
// print "format search string: " . $plainSearchText . "\n";
|
|
// format
|
|
// 1: plain text that is used to search in text field: concat field
|
|
// 2: a field is specified [field_name]:["phrase search"]
|
|
// [field_name]:["phrase search"] [field_name]:[word_search] word_search
|
|
// "phrase search"
|
|
// to scape a reserved character use a double value: "::", """"
|
|
// ex: (APP_ASSIGNED_USERS:7091676694d9269da75c254003021135) AND
|
|
// (contrato_t:76* AND Causal_t:1021 AND Materiales AND 143073)
|
|
// ex: date search => APP_CREATE_DATE:[2012-03-12T00:00:00Z TO
|
|
// 2012-04-12T00:00:00Z]
|
|
// ex: phrase => TEXT:"This is a lazy dog"
|
|
|
|
|
|
// search the first
|
|
|
|
|
|
// cache the index fields
|
|
G::LoadClass( 'PMmemcached' );
|
|
$oMemcache = PMmemcached::getSingleton( $this->_solrInstance );
|
|
$ListFieldsInfo = $oMemcache->get( 'Solr_Index_Fields' );
|
|
if (! $ListFieldsInfo) {
|
|
G::LoadClass( 'searchIndex' );
|
|
|
|
$searchIndex = new BpmnEngine_Services_SearchIndex( $this->_solrIsEnabled, $this->_solrHost );
|
|
// execute query
|
|
$ListFieldsInfo = $searchIndex->getIndexFields( $this->_solrInstance );
|
|
|
|
//var_dump($ListFieldsInfo);
|
|
// cache
|
|
$oMemcache->set( 'Solr_Index_Fields', $ListFieldsInfo );
|
|
|
|
}
|
|
|
|
$tok = strtok( $plainSearchText, " " );
|
|
|
|
while ($tok !== false) {
|
|
$fieldName = substr( $tok, 0, strpos( $tok, ":" ) ); // strstr ( $tok,
|
|
// ":",
|
|
// true ); php 5.3
|
|
$searchText = strstr( $tok, ":" );
|
|
|
|
// verify if there's a field definition
|
|
if ($fieldName === false || $fieldName == "") {
|
|
// it's not a field
|
|
// the token is not a field
|
|
// add it completelly
|
|
$includeToken = true;
|
|
// no field found
|
|
$formattedSearchText .= $tok; // used to search in the general default
|
|
// text field
|
|
} else {
|
|
// it's a field
|
|
// verify if is complete
|
|
if ($fieldName == "" || $searchText == ":") {
|
|
$includeToken = false;
|
|
throw new InvalidIndexSearchTextException( "Invalid search text, verify the syntax. Expected format = {variable_name}:{search_text}" );
|
|
}
|
|
|
|
// field name found
|
|
// search index field name
|
|
$indexFieldName = "";
|
|
if (array_key_exists( $fieldName, $ListFieldsInfo )) {
|
|
$indexFieldName = $ListFieldsInfo[$fieldName];
|
|
} else {
|
|
// no field name found
|
|
// don't include field search
|
|
// return message about it
|
|
$includeToken = false;
|
|
throw new InvalidIndexSearchTextException( "Invalid search text, variable not found." );
|
|
}
|
|
|
|
// The token is part of a phrase, date or a word?
|
|
if ($searchText[1] == "[" || $searchText[1] == "\"") {
|
|
// expecting date interval we must search the end of the phrase
|
|
// the phrase is complete?
|
|
if ($searchText[1] == "[" && $searchText[strlen( $searchText ) - 1] == "]") {
|
|
// complete phrase ok, the date must be validated
|
|
// throw new InvalidIndexSearchTextException("Invalid search text.
|
|
// Expected date interval format =>
|
|
// {variable_name}:[YYYY-MM-DDThh:mm:ssZ TO YYYY-MM-DDThh:mm:ssZ]");
|
|
} elseif ($searchText[1] == "\"" && $searchText[strlen( $searchText ) - 1] == "\"") {
|
|
// the phrase is complete and is ok.
|
|
} else {
|
|
// search end of phrase
|
|
$tok = strtok( " " );
|
|
$found = false;
|
|
while ($tok !== false) {
|
|
if ((($searchText[1] == "[") && ($tok[strlen( $tok ) - 1] == "]")) || (($searchText[1] == "\"") && ($tok[strlen( $tok ) - 1] == "\""))) {
|
|
// end of phrase found
|
|
$found = true;
|
|
$searchText .= " " . $tok;
|
|
break;
|
|
} else {
|
|
// continue adding text
|
|
$searchText .= " " . $tok;
|
|
}
|
|
$tok = strtok( " " );
|
|
}
|
|
if (! $found) {
|
|
// error invalid text
|
|
// Expected date interval format => {variable_name}:[YYYY-MM-DDThh:mm:ssZ TO YYYY-MM-DDThh:mm:ssZ]
|
|
throw new InvalidIndexSearchTextException( "Invalid search text. The date or phase is not completed" );
|
|
}
|
|
}
|
|
}
|
|
|
|
// validate phrase in case of date
|
|
if (($searchText[1] == "[")) {
|
|
// validate date range format
|
|
// use regular expresion to validate it [yyyy-mm-dd TO yyyy-mm-dd]
|
|
$reg = "/:\[(\d\d\d\d-\d\d-\d\d|\*)\sTO\s(\d\d\d\d-\d\d-\d\d|\*)\]/";
|
|
// convert date to utc
|
|
$matched = preg_match( $reg, $searchText, $matches );
|
|
if ($matched == 1) {
|
|
// the date interval is valid
|
|
// convert to SOlr format
|
|
$fromDateOriginal = $matches[1];
|
|
$fromDate = $matches[1];
|
|
|
|
$toDateOriginal = $matches[2];
|
|
$toDate = $matches[2];
|
|
|
|
if ($fromDateOriginal != '*') {
|
|
// TODO complete date creation
|
|
// list($year, $month, $day) = sscanf($fromDateOriginal,
|
|
// '%04d/%02d/%02d');
|
|
// $fromDateDatetime = new DateTime($fromDateOriginal);
|
|
// $fromDateDatetime = date_create_from_format ( 'Y-m-d',
|
|
// $fromDateOriginal );
|
|
// $fromDateDatetime->getTimestamp ()
|
|
$fromDate = gmdate( "Y-m-d\T00:00:00\Z", strtotime( $fromDateOriginal ) );
|
|
}
|
|
if ($toDateOriginal != '*') {
|
|
// list($year, $month, $day) = sscanf($fromDateOriginal,
|
|
// '%04d/%02d/%02d');
|
|
// $toDateDatetime = new DateTime($toDateOriginal);
|
|
// $toDateDatetime = date_create_from_format ( 'Y-m-d',
|
|
// $toDateOriginal );
|
|
$toDate = gmdate( "Y-m-d\T23:59:59.999\Z", strtotime( $toDateOriginal ) );
|
|
}
|
|
$searchText = ":[" . $fromDate . " TO " . $toDate . "]";
|
|
} else {
|
|
throw new InvalidIndexSearchTextException( "Invalid search text. Expected date interval format => {variable_name}:[YYYY-MM-DD TO YYYY-MM-DD]" );
|
|
}
|
|
}
|
|
|
|
$formattedSearchText .= $indexFieldName . $searchText;
|
|
$includeToken = true;
|
|
}
|
|
|
|
if ($includeToken) {
|
|
$formattedSearchText .= " AND ";
|
|
}
|
|
// next token
|
|
$tok = strtok( " " );
|
|
}
|
|
// remove last AND
|
|
$formattedSearchText = substr_replace( $formattedSearchText, "", - 5 );
|
|
return $formattedSearchText;
|
|
}
|
|
|
|
/**
|
|
* Get all the application delegation records from database
|
|
*
|
|
* @param string $appUID Application identifier
|
|
* @return array delegation records
|
|
*/
|
|
public function getApplicationDelegationsIndex ($appUID)
|
|
{
|
|
$delIndexes = array ();
|
|
|
|
$c = new Criteria();
|
|
|
|
$c->addSelectColumn( AppDelegationPeer::DEL_INDEX );
|
|
$c->add( AppDelegationPeer::APP_UID, $appUID );
|
|
|
|
$rs = AppDelegationPeer::doSelectRS( $c );
|
|
$rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
|
|
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
|
|
while (is_array( $row )) {
|
|
$delIndexes[] = $row['DEL_INDEX'];
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
}
|
|
|
|
return $delIndexes;
|
|
|
|
}
|
|
|
|
/**
|
|
* Update the information of the specified applications in Solr
|
|
*
|
|
* @param array $aaAPPUIDs Array of arrays of App_UID that must be updated,
|
|
* APP_UID is permitted also
|
|
*/
|
|
public function updateApplicationSearchIndex ($aaAPPUIDs)
|
|
{
|
|
if (empty( $aaAPPUIDs )) {
|
|
return;
|
|
}
|
|
|
|
if (! is_array( $aaAPPUIDs )) {
|
|
// convert to array
|
|
$APPUID = $aaAPPUIDs;
|
|
$aaAPPUIDs = array ();
|
|
$aaAPPUIDs[] = array ('APP_UID' => $APPUID
|
|
);
|
|
}
|
|
// check if index server is available
|
|
if (! $this->isSolrEnabled()) {
|
|
// store update in table and return
|
|
foreach ($aaAPPUIDs as $aAPPUID) {
|
|
$this->applicationChangedUpdateSolrQueue( $aAPPUID['APP_UID'], true );
|
|
}
|
|
return;
|
|
}
|
|
|
|
if ($this->debug) {
|
|
$this->beforeCreateSolrXMLDocTime = microtime( true );
|
|
}
|
|
// create XML document
|
|
$xmlDoc = $this->createSolrXMLDocument( $aaAPPUIDs );
|
|
|
|
if ($this->debug) {
|
|
$this->afterCreateSolrXMLDocTime = microtime( true );
|
|
}
|
|
// update document
|
|
$data = array ('workspace' => $this->_solrInstance,'document' => $xmlDoc
|
|
);
|
|
|
|
$oSolrUpdateDocument = Entity_SolrUpdateDocument::createForRequest( $data );
|
|
|
|
G::LoadClass( 'searchIndex' );
|
|
|
|
$oSearchIndex = new BpmnEngine_Services_SearchIndex( $this->_solrIsEnabled, $this->_solrHost );
|
|
|
|
try {
|
|
$oSearchIndex->updateIndexDocument( $oSolrUpdateDocument );
|
|
|
|
if ($this->debug) {
|
|
$this->afterUpdateSolrXMLDocTime = microtime( true );
|
|
}
|
|
// commit changes
|
|
$oSearchIndex->commitIndexChanges( $this->_solrInstance );
|
|
|
|
} catch (Exception $ex) {
|
|
//print "Excepcion indexing data: " . $ex->getMessage() . "\n"; die;
|
|
$fh = fopen( "./SolrIndexErrors.txt", 'a' ) or die( "can't open file to store Solr index errors." );
|
|
fwrite( $fh, $ex->getMessage() );
|
|
fclose( $fh );
|
|
}
|
|
if ($this->debug) {
|
|
$this->afterCommitSolrDocTime = microtime( true );
|
|
|
|
$fh = fopen( "SolrIndexTime.txt", 'a' ) or die( "can't open file to store Solr index time." );
|
|
//fwrite($fh, sprintf("Solr Query time: %s DB Query time: %s Prepare result time: %s \n", gmdate ('H:i:s:u', ($this->afterSolrQueryTime - $this->initTimeAll)), gmdate ('H:i:s:u', ($this->afterDbQueryTime - $this->afterSolrQueryTime)), gmdate ('H:i:s:u', ($this->afterPrepareResultTime - $this->afterDbQueryTime)) ));
|
|
fwrite( $fh, sprintf( "Solr Create XML Document time: %s Update Solr Document time: %s Commit Solr Changes time: %s Total:%s \r\n", ($this->afterCreateSolrXMLDocTime - $this->beforeCreateSolrXMLDocTime), ($this->afterUpdateSolrXMLDocTime - $this->afterCreateSolrXMLDocTime), ($this->afterCommitSolrDocTime - $this->afterUpdateSolrXMLDocTime), ($this->afterCommitSolrDocTime - $this->beforeCreateSolrXMLDocTime) ) );
|
|
fclose( $fh );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Delete the specified application record from Solr
|
|
*
|
|
* @param string $appUID Application identifier
|
|
*/
|
|
public function deleteApplicationSearchIndex ($appUID)
|
|
{
|
|
if (empty( $appUID )) {
|
|
return;
|
|
}
|
|
|
|
// check if index server is available
|
|
if (! $this->_solrIsEnabled) {
|
|
// store update in table and return
|
|
$this->applicationChangedUpdateSolrQueue( $appUID['APP_UID'], 2 ); // delete
|
|
return;
|
|
}
|
|
|
|
$idQuery = "APP_UID:" . $appUID;
|
|
|
|
G::LoadClass( 'searchIndex' );
|
|
|
|
$oSearchIndex = new BpmnEngine_Services_SearchIndex( $this->_solrIsEnabled, $this->_solrHost );
|
|
|
|
$oSearchIndex->deleteDocumentFromIndex( $this->_solrInstance, $idQuery );
|
|
|
|
// commit changes
|
|
$oSearchIndex->commitIndexChanges( $this->_solrInstance );
|
|
}
|
|
|
|
/**
|
|
* Create XML data in Solr format of the specified applications
|
|
* this function uses the buildSearchIndexDocumentPMOS2 function to create
|
|
* each record
|
|
*
|
|
* @param array $aaAPPUIDs array of arrays of application identifiers
|
|
* @return string The resulting XML document in Solr format
|
|
*/
|
|
public function createSolrXMLDocument ($aaAPPUIDs)
|
|
{
|
|
if ($this->debug) {
|
|
$this->getApplicationDataDBTime = 0;
|
|
$this->getBuilXMLDocTime = 0;
|
|
}
|
|
// search data from DB
|
|
$xmlDoc = "<?xml version='1.0' encoding='UTF-8'?>\n";
|
|
$xmlDoc .= "<add>\n";
|
|
|
|
//get all application data from DB of all applications and delegations
|
|
$aAPPUIDs = array ();
|
|
foreach ($aaAPPUIDs as $aAPPUID) {
|
|
$aAPPUIDs[] = $aAPPUID['APP_UID'];
|
|
}
|
|
if ($this->debug) {
|
|
$this->beforeGetApplicationDataDBTime = microtime( true );
|
|
}
|
|
$aaAllAppDelData = $this->getListApplicationUpdateDelegationData( $aAPPUIDs );
|
|
if ($this->debug) {
|
|
$this->afterGetApplicationDataDBTime = microtime( true );
|
|
|
|
$this->getApplicationDataDBTime = $this->afterGetApplicationDataDBTime - $this->beforeGetApplicationDataDBTime;
|
|
}
|
|
foreach ($aaAPPUIDs as $aAPPUID) {
|
|
try {
|
|
|
|
if ($this->debug) {
|
|
$this->beforePrepareApplicationDataDBTime = microtime( true );
|
|
}
|
|
//filter data, include all the rows of the application
|
|
// get delegation data from DB
|
|
$aaAppData = array ();
|
|
//filter data from db
|
|
$indexes = $this->aaSearchRecords( $aaAllAppDelData, array ('APP_UID' => $aAPPUID['APP_UID']
|
|
) );
|
|
|
|
foreach ($indexes as $index) {
|
|
$aaAppData[] = $aaAllAppDelData[$index];
|
|
}
|
|
|
|
$result = $this->getApplicationIndexData( $aAPPUID['APP_UID'], $aaAppData );
|
|
|
|
if ($this->debug) {
|
|
$this->afterPrepareApplicationDataDBTime = microtime( true );
|
|
|
|
$this->getPreparedApplicationDataDBTime = $this->afterPrepareApplicationDataDBTime - $this->beforePrepareApplicationDataDBTime;
|
|
}
|
|
|
|
} catch (ApplicationWithoutDelegationRecordsException $ex) {
|
|
// exception trying to get application information
|
|
// skip and continue with the next application
|
|
$fh = fopen( "./SolrIndexErrors.txt", 'a' ) or die( "can't open file to store Solr index errors." );
|
|
fwrite( $fh, $ex->getMessage() );
|
|
fclose( $fh );
|
|
continue;
|
|
} catch (ApplicationWithCorruptDynaformException $ex) {
|
|
$fh = fopen( "./SolrIndexErrors.txt", 'a' ) or die( "can't open file to store Solr index errors." );
|
|
fwrite( $fh, $ex->getMessage() );
|
|
fclose( $fh );
|
|
continue;
|
|
} catch (Exception $ex) {
|
|
$fh = fopen( "./SolrIndexErrors.txt", 'a' ) or die( "can't open file to store Solr index errors." );
|
|
fwrite( $fh, "getApplicationIndexData " . $aAPPUID . ":" . $ex->getMessage() . "\n" );
|
|
fclose( $fh );
|
|
continue;
|
|
}
|
|
|
|
$documentInformation = $result[0];
|
|
$dynaformFieldTypes = $result[1];
|
|
$lastUpdateDate = $result[2];
|
|
$maxPriority = $result[3];
|
|
$assignedUsers = $result[4];
|
|
$assignedUsersRead = $result[5];
|
|
$assignedUsersUnread = $result[6];
|
|
$draftUser = $result[7];
|
|
$participatedUsers = $result[8];
|
|
$participatedUsersStartedByUser = $result[9];
|
|
$participatedUsersCompletedByUser = $result[10];
|
|
$unassignedUsers = $result[11];
|
|
$unassignedGroups = $result[12];
|
|
|
|
try {
|
|
|
|
// create document
|
|
$xmlDoc .= $this->buildSearchIndexDocumentPMOS2( $documentInformation, $dynaformFieldTypes, $lastUpdateDate, $maxPriority, $assignedUsers, $assignedUsersRead, $assignedUsersUnread, $draftUser, $participatedUsers, $participatedUsersStartedByUser, $participatedUsersCompletedByUser, $unassignedUsers, $unassignedGroups );
|
|
|
|
if ($this->debug) {
|
|
$this->afterBuilXMLDocTime = microtime( true );
|
|
|
|
$this->getBuilXMLDocTime += $this->afterBuilXMLDocTime - $this->afterGetApplicationDataDBTime;
|
|
}
|
|
} catch (ApplicationAPP_DATAUnserializeException $ex) {
|
|
// exception trying to get application information
|
|
$fh = fopen( "./SolrIndexErrors.txt", 'a' ) or die( "can't open file to store Solr index errors." );
|
|
fwrite( $fh, $ex->getMessage() );
|
|
fclose( $fh );
|
|
// skip and continue with the next application
|
|
continue;
|
|
} catch (Exception $ex) {
|
|
$fh = fopen( "./SolrIndexErrors.txt", 'a' ) or die( "can't open file to store Solr index errors." );
|
|
fwrite( $fh, "buildSearchIndexDocumentPMOS2 " . $aAPPUID . ":" . $ex->getMessage() . "\n" );
|
|
fclose( $fh );
|
|
continue;
|
|
}
|
|
|
|
}
|
|
|
|
$xmlDoc .= "</add>\n";
|
|
|
|
if ($this->debug) {
|
|
$fh = fopen( "SolrIndexTime.txt", 'a' ) or die( "can't open file to store Solr index time." );
|
|
fwrite( $fh, sprintf( "Get Data DB time: %s Prepare DB data Time: %s Create XML file time: %s \r\n", $this->getApplicationDataDBTime, $this->getPreparedApplicationDataDBTime, $this->getBuilXMLDocTime ) );
|
|
fclose( $fh );
|
|
}
|
|
|
|
return $xmlDoc;
|
|
}
|
|
|
|
/**
|
|
* build Solr index document xml for an application
|
|
* @gearman = false
|
|
* @rest = false
|
|
* @background = false
|
|
*
|
|
* @param [in] array $documentData array of data for the xml document of
|
|
* application
|
|
* @param [in] array $dynaformFieldTypes array of dynaform field types, used
|
|
* to store the info of APP_DATA with types
|
|
* @param [in] array $appTitles array of array of application titles in all
|
|
* languages
|
|
* @param [in] array $proTitles array of array of process titles in all
|
|
* languages
|
|
* @param [in] array $assignedUsers array of array of uids of assigned users
|
|
* to Application UIDs
|
|
* @param [in] array $draftUsers array of array of uids of draft users to
|
|
* Application UIDs
|
|
* @param [in] array $participatedUsers array of array of participated users
|
|
* UIDs in application
|
|
* @param [in] array $unassignedUsers array of unassigned users UIDs
|
|
* @param [in] array $unassignedGroups array of unassigned groups UIDs
|
|
* @param [out] xml xml document
|
|
*
|
|
* $xmlDoc .= buildSearchIndexDocumentPMOS2($documentInformation,
|
|
* $dynaformFieldTypes,
|
|
* $lastUpdateDate, $maxPriority,
|
|
* $assignedUsers, $assignedUsersRead, $assignedUsersUnread,
|
|
* $draftUser,
|
|
* $participatedUsers, $participatedUsersStartedByUser,
|
|
* $participatedUsersCompletedByUser,
|
|
* $unassignedUsers, $unassignedGroups);*
|
|
*/
|
|
public function buildSearchIndexDocumentPMOS2 ($documentData, $dynaformFieldTypes, $lastUpdateDate, $maxPriority, $assignedUsers, $assignedUsersRead, $assignedUsersUnread, $draftUser, $participatedUsers, $participatedUsersStartedByUser, $participatedUsersCompletedByUser, $unassignedUsers, $unassignedGroups)
|
|
{
|
|
// build xml document
|
|
|
|
|
|
$writer = new XMLWriter();
|
|
$writer->openMemory();
|
|
$writer->setIndent( 4 );
|
|
|
|
$writer->startElement( "doc" );
|
|
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_UID' );
|
|
$writer->text( $documentData['APP_UID'] );
|
|
$writer->endElement();
|
|
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_NUMBER' );
|
|
$writer->text( $documentData['APP_NUMBER'] );
|
|
$writer->endElement();
|
|
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_STATUS' );
|
|
$writer->text( $documentData['APP_STATUS'] );
|
|
$writer->endElement();
|
|
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'PRO_UID' );
|
|
$writer->text( $documentData['PRO_UID'] );
|
|
$writer->endElement();
|
|
|
|
if (! empty( $documentData['APP_TITLE'] )) {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_TITLE' );
|
|
$writer->text( $documentData['APP_TITLE'] );
|
|
$writer->endElement();
|
|
} else {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_TITLE' );
|
|
$writer->text( "" );
|
|
$writer->endElement();
|
|
}
|
|
|
|
if (! empty( $documentData['PRO_TITLE'] )) {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_PRO_TITLE' );
|
|
$writer->text( $documentData['PRO_TITLE'] );
|
|
$writer->endElement();
|
|
|
|
} else {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_PRO_TITLE' );
|
|
$writer->text( "" );
|
|
$writer->endElement();
|
|
}
|
|
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_CREATE_DATE' );
|
|
// convert date to UTC with gmdate
|
|
$writer->text( gmdate( "Y-m-d\TH:i:s\Z", strtotime( $documentData['APP_CREATE_DATE'] ) ) );
|
|
$writer->endElement();
|
|
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'DEL_LAST_UPDATE_DATE' );
|
|
// convert date to UTC with gmdate
|
|
$writer->text( gmdate( "Y-m-d\TH:i:s\Z", strtotime( $lastUpdateDate ) ) );
|
|
$writer->endElement();
|
|
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'DEL_MAX_PRIORITY' );
|
|
$writer->text( $maxPriority );
|
|
$writer->endElement();
|
|
|
|
if (is_array( $assignedUsers ) && ! empty( $assignedUsers )) {
|
|
foreach ($assignedUsers as $userUID) {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_ASSIGNED_USERS' );
|
|
$writer->text( $userUID['USR_UID'] );
|
|
$writer->endElement();
|
|
|
|
// add dynamic field for del_index information
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_ASSIGNED_USER_DEL_INDEX_' . trim( $userUID['USR_UID'] ) . '_txt' );
|
|
$writer->text( $userUID['DEL_INDEX'] );
|
|
$writer->endElement();
|
|
|
|
}
|
|
}
|
|
|
|
if (is_array( $assignedUsersRead ) && ! empty( $assignedUsersRead )) {
|
|
foreach ($assignedUsersRead as $userUID) {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_ASSIGNED_USERS_READ' );
|
|
$writer->text( $userUID['USR_UID'] );
|
|
$writer->endElement();
|
|
|
|
// add dynamic field for del_index information
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_ASSIGNED_USER_READ_DEL_INDEX_' . trim( $userUID['USR_UID'] ) . '_txt' );
|
|
$writer->text( $userUID['DEL_INDEX'] );
|
|
$writer->endElement();
|
|
}
|
|
}
|
|
|
|
if (is_array( $assignedUsersUnread ) && ! empty( $assignedUsersUnread )) {
|
|
foreach ($assignedUsersUnread as $userUID) {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_ASSIGNED_USERS_UNREAD' );
|
|
$writer->text( $userUID['USR_UID'] );
|
|
$writer->endElement();
|
|
|
|
// add dynamic field for del_index information
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_ASSIGNED_USER_UNREAD_DEL_INDEX_' . trim( $userUID['USR_UID'] ) . '_txt' );
|
|
$writer->text( $userUID['DEL_INDEX'] );
|
|
$writer->endElement();
|
|
}
|
|
}
|
|
|
|
if (! empty( $draftUser )) {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_DRAFT_USER' );
|
|
$writer->text( $draftUser['USR_UID'] );
|
|
$writer->endElement();
|
|
}
|
|
|
|
if (is_array( $participatedUsers ) && ! empty( $participatedUsers )) {
|
|
foreach ($participatedUsers as $userUID) {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_PARTICIPATED_USERS' );
|
|
$writer->text( $userUID['USR_UID'] );
|
|
$writer->endElement();
|
|
|
|
// add dynamic field for del_index information
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_PARTICIPATED_USER_DEL_INDEX_' . trim( $userUID['USR_UID'] ) . '_txt' );
|
|
$writer->text( $userUID['DEL_INDEX'] );
|
|
$writer->endElement();
|
|
}
|
|
}
|
|
|
|
if (is_array( $participatedUsersStartedByUser ) && ! empty( $participatedUsersStartedByUser )) {
|
|
foreach ($participatedUsersStartedByUser as $userUID) {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_PARTICIPATED_USERS_STARTED' );
|
|
$writer->text( $userUID['USR_UID'] );
|
|
$writer->endElement();
|
|
|
|
// add dynamic field for del_index information
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_PARTICIPATED_USER_STARTED_DEL_INDEX_' . trim( $userUID['USR_UID'] ) . '_txt' );
|
|
$writer->text( $userUID['DEL_INDEX'] );
|
|
$writer->endElement();
|
|
}
|
|
}
|
|
|
|
if (is_array( $participatedUsersCompletedByUser ) && ! empty( $participatedUsersCompletedByUser )) {
|
|
foreach ($participatedUsersCompletedByUser as $userUID) {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_PARTICIPATED_USERS_COMPLETED' );
|
|
$writer->text( $userUID['USR_UID'] );
|
|
$writer->endElement();
|
|
|
|
// add dynamic field for del_index information
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_PARTICIPATED_USER_COMPLETED_DEL_INDEX_' . trim( $userUID['USR_UID'] ) . '_txt' );
|
|
$writer->text( $userUID['DEL_INDEX'] );
|
|
$writer->endElement();
|
|
}
|
|
}
|
|
|
|
if (is_array( $unassignedUsers ) && ! empty( $unassignedUsers )) {
|
|
foreach ($unassignedUsers as $userUID) {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_UNASSIGNED_USERS' );
|
|
$writer->text( $userUID['USR_UID'] );
|
|
$writer->endElement();
|
|
|
|
// add dynamic field for del_index information
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_UNASSIGNED_USER_GROUP_DEL_INDEX_' . trim( $userUID['USR_UID'] ) . '_txt' );
|
|
$writer->text( $userUID['DEL_INDEX'] );
|
|
$writer->endElement();
|
|
}
|
|
}
|
|
|
|
if (is_array( $unassignedGroups ) && ! empty( $unassignedGroups )) {
|
|
foreach ($unassignedGroups as $groupUID) {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_UNASSIGNED_GROUPS' );
|
|
$writer->text( $groupUID['USR_UID'] );
|
|
$writer->endElement();
|
|
|
|
// add dynamic field for del_index information
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', 'APP_UNASSIGNED_USER_GROUP_DEL_INDEX_' . trim( $groupUID['USR_UID'] ) . '_txt' );
|
|
$writer->text( $groupUID['DEL_INDEX'] );
|
|
$writer->endElement();
|
|
}
|
|
}
|
|
|
|
// get the serialized fields
|
|
if (! empty( $documentData['APP_DATA'] ) && $documentData['APP_DATA'] != "N;") {
|
|
|
|
$UnSerializedCaseData = unserialize( $documentData['APP_DATA'] );
|
|
|
|
if ($UnSerializedCaseData === false) {
|
|
$UnSerializedCaseData = preg_replace( '!s:(\d+):"(.*?)";!e', "'s:'.strlen('$2').':\"$2\";'", $documentData['APP_DATA'] ); // utf8_encode
|
|
$UnSerializedCaseData = unserialize( $UnSerializedCaseData );
|
|
}
|
|
|
|
if (! $UnSerializedCaseData) {
|
|
// error unserializing
|
|
throw new ApplicationAPP_DATAUnserializeException( "Could not unserialize APP_DATA of APP_UID: " . $documentData['APP_UID'] . "\n" );
|
|
} else {
|
|
foreach ($UnSerializedCaseData as $k => $value) {
|
|
if (! is_array( $value ) && ! is_object( $value ) && $value != '' && $k != 'SYS_LANG' && $k != 'SYS_SKIN' && $k != 'SYS_SYS') {
|
|
// search the field type in array of dynaform fields
|
|
if (! empty( $dynaformFieldTypes ) && array_key_exists( trim( $k ), $dynaformFieldTypes )) {
|
|
$type = $dynaformFieldTypes[trim( $k )];
|
|
$typeSufix = '_t';
|
|
switch ($type) {
|
|
case 'text':
|
|
$typeSufix = '_t';
|
|
break;
|
|
case 'Int':
|
|
if (intval( $value ) > 2147483647) {
|
|
$typeSufix = '_tl'; //for long values
|
|
$value = intval( $value );
|
|
} else {
|
|
$typeSufix = '_ti';
|
|
$value = intval( $value );
|
|
}
|
|
break;
|
|
case 'Real':
|
|
$typeSufix = '_td';
|
|
$value = floatval( $value );
|
|
break;
|
|
case 'date':
|
|
$newdate = false;
|
|
$withHour = true;
|
|
// try to convert string to date
|
|
// TODO convert to php 5.2 format
|
|
/*
|
|
* $newdate = date_create_from_format ( 'Y-m-d H:i:s', $value ); if (! $newdate) { $newdate = date_create_from_format ( 'Y-m-d', $value ); $withHour = false; } if (! $newdate) { $newdate = date_create_from_format ( 'd/m/Y', $value ); $withHour = false; } if (!
|
|
* $newdate) { $newdate = date_create_from_format ( 'j/m/Y', $value ); $withHour = false; }
|
|
*/
|
|
$newdate = strtotime( $value );
|
|
if (! $newdate) {
|
|
$typeSufix = '*'; // not store field
|
|
} else {
|
|
$typeSufix = '_tdt';
|
|
/*
|
|
* if ($withHour) //$value = gmdate ( "Y-m-d\TH:i:s\Z", $newdate->getTimestamp () ); $value = gmdate ( "Y-m-d\TH:i:s\Z", $newdate ); else { $value = gmdate ( "Y-m-d\T00:00:00\Z", $newdate ); }
|
|
*/
|
|
$value = gmdate( "Y-m-d\T00:00:00\Z", $newdate );
|
|
}
|
|
break;
|
|
case 'dropdown':
|
|
$typeSufix = '_t';
|
|
break;
|
|
case 'textarea':
|
|
$typeSufix = '_t';
|
|
break;
|
|
case 'currency':
|
|
$typeSufix = '_td';
|
|
$value = floatval( $value );
|
|
break;
|
|
case 'percentage':
|
|
$typeSufix = '_t';
|
|
break;
|
|
case 'password':
|
|
$typeSufix = '_t';
|
|
break;
|
|
case 'suggest':
|
|
$typeSufix = '_t';
|
|
break;
|
|
case 'yesno':
|
|
$typeSufix = '_t';
|
|
break;
|
|
case 'listbox':
|
|
$typeSufix = '_t';
|
|
break;
|
|
case 'checkbox':
|
|
$typeSufix = '_t';
|
|
break;
|
|
case 'checkgroup':
|
|
$typeSufix = '_t';
|
|
break;
|
|
case 'radiogroup':
|
|
$typeSufix = '_t';
|
|
break;
|
|
case 'hidden':
|
|
$typeSufix = '_t';
|
|
break;
|
|
}
|
|
if ($typeSufix != '*') {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', trim( $k ) . $typeSufix );
|
|
$writer->text( $value );
|
|
$writer->endElement();
|
|
}
|
|
} else {
|
|
$writer->startElement( "field" );
|
|
$writer->writeAttribute( 'name', trim( $k ) . '_t' );
|
|
$writer->text( $value );
|
|
$writer->endElement();
|
|
}
|
|
}
|
|
} // foreach unserialized data
|
|
} // else unserialize APP_DATA
|
|
} // empty APP_DATA
|
|
|
|
|
|
$writer->endElement(); // end /doc
|
|
|
|
|
|
return $writer->outputMemory( true );
|
|
}
|
|
|
|
/**
|
|
* Search records in specified application delegation data
|
|
*
|
|
* @param string $AppUID application identifier
|
|
* @param string $allAppDbData array of rows (array) with application data
|
|
* @throws ApplicationWithoutDelegationRecordsException
|
|
* @return array array of arrays with the following information(
|
|
* $documentInformation,
|
|
* $dynaformFieldTypes,
|
|
* $lastUpdateDate,
|
|
* $maxPriority,
|
|
* $assignedUsers,
|
|
* $assignedUsersRead,
|
|
* $assignedUsersUnread,
|
|
* $draftUser,
|
|
* $participatedUsers,
|
|
* $participatedUsersStartedByUser,
|
|
* $participatedUsersCompletedByUser,
|
|
* $unassignedUsers,
|
|
* $unassignedGroups
|
|
*/
|
|
public function getApplicationIndexData ($AppUID, $allAppDbData)
|
|
{
|
|
G::LoadClass( 'memcached' );
|
|
|
|
// get all the application data
|
|
//$allAppDbData = $this->getApplicationDelegationData ($AppUID);
|
|
// check if the application record was found
|
|
// this case occurs when the application doesn't have related delegation
|
|
// records.
|
|
if (empty( $allAppDbData ) || ! isset( $allAppDbData[0] )) {
|
|
throw new ApplicationWithoutDelegationRecordsException( "Application without delegation records. APP_UID: " . $AppUID . "\n" );
|
|
}
|
|
|
|
// copy the application information
|
|
$documentInformation = $allAppDbData[0];
|
|
|
|
// get the last delegate date using the del_delegate_date
|
|
$index = $this->aaGetMaximun( $allAppDbData, 'DEL_DELEGATE_DATE', 'DATE' );
|
|
|
|
$lastUpdateDate = $allAppDbData[$index]['DEL_DELEGATE_DATE'];
|
|
|
|
// get the delegate with max priority => minimun value
|
|
$index2 = $this->aaGetMinimun( $allAppDbData, 'DEL_PRIORITY', 'NUMBER', 'DEL_THREAD_STATUS', 'OPEN' );
|
|
|
|
if ($index2 == null) {
|
|
// get the last priority
|
|
$maxPriority = $allAppDbData[$index]['DEL_PRIORITY'];
|
|
} else {
|
|
$maxPriority = $allAppDbData[$index2]['DEL_PRIORITY'];
|
|
}
|
|
|
|
$assignedUsers = array ();
|
|
$indexes = $this->aaSearchRecords( $allAppDbData, array ('DEL_THREAD_STATUS' => 'OPEN','DEL_FINISH_DATE' => 'NULL','APP_STATUS' => 'TO_DO','APP_THREAD_STATUS' => 'OPEN'
|
|
) );
|
|
foreach ($indexes as $index) {
|
|
$assignedUsers[] = array ('USR_UID' => $allAppDbData[$index]['USR_UID'],'DEL_INDEX' => $allAppDbData[$index]['DEL_INDEX']
|
|
);
|
|
}
|
|
|
|
$assignedUsersRead = array ();
|
|
$indexes = $this->aaSearchRecords( $allAppDbData, array ('DEL_THREAD_STATUS' => 'OPEN','DEL_FINISH_DATE' => 'NULL','APP_STATUS' => 'TO_DO','APP_THREAD_STATUS' => 'OPEN','DEL_INIT_DATE' => 'NOTNULL'
|
|
) );
|
|
foreach ($indexes as $index) {
|
|
$assignedUsersRead[] = array ('USR_UID' => $allAppDbData[$index]['USR_UID'],'DEL_INDEX' => $allAppDbData[$index]['DEL_INDEX']
|
|
);
|
|
}
|
|
|
|
$assignedUsersUnread = array ();
|
|
$indexes = $this->aaSearchRecords( $allAppDbData, array ('DEL_THREAD_STATUS' => 'OPEN','DEL_FINISH_DATE' => 'NULL','APP_STATUS' => 'TO_DO','APP_THREAD_STATUS' => 'OPEN','DEL_INIT_DATE' => 'NULL'
|
|
) );
|
|
foreach ($indexes as $index) {
|
|
$assignedUsersUnread[] = array ('USR_UID' => $allAppDbData[$index]['USR_UID'],'DEL_INDEX' => $allAppDbData[$index]['DEL_INDEX']
|
|
);
|
|
}
|
|
|
|
$draftUser = array ();
|
|
$indexes = $this->aaSearchRecords( $allAppDbData, array ('DEL_THREAD_STATUS' => 'OPEN','DEL_FINISH_DATE' => 'NULL','APP_STATUS' => 'DRAFT','APP_THREAD_STATUS' => 'OPEN'
|
|
) );
|
|
if (! empty( $indexes )) {
|
|
$draftUser = array ('USR_UID' => $allAppDbData[$indexes[0]]['USR_UID'],'DEL_INDEX' => $allAppDbData[$indexes[0]]['DEL_INDEX']
|
|
);
|
|
}
|
|
|
|
$participatedUsers = array ();
|
|
foreach ($allAppDbData as $row) {
|
|
$participatedUsers[] = array ('USR_UID' => $row['USR_UID'],'DEL_INDEX' => $row['DEL_INDEX']
|
|
);
|
|
}
|
|
|
|
$participatedUsersStartedByUser = array ();
|
|
$indexes = $this->aaSearchRecords( $allAppDbData, array ('DEL_INDEX' => '1'
|
|
) );
|
|
foreach ($indexes as $index) {
|
|
$participatedUsersStartedByUser[] = array ('USR_UID' => $allAppDbData[$index]['USR_UID'],'DEL_INDEX' => $allAppDbData[$index]['DEL_INDEX']
|
|
);
|
|
}
|
|
|
|
$participatedUsersCompletedByUser = array ();
|
|
$indexes = $this->aaSearchRecords( $allAppDbData, array ('APP_STATUS' => 'COMPLETED'
|
|
) );
|
|
foreach ($indexes as $index) {
|
|
$participatedUsersCompletedByUser[] = array ('USR_UID' => $allAppDbData[$index]['USR_UID'],'DEL_INDEX' => $allAppDbData[$index]['DEL_INDEX']
|
|
);
|
|
}
|
|
// search information of unassigned users
|
|
// the unassigned users are the self service users and groups.
|
|
// the self service users are defined in the TASKs of the PROCESS.
|
|
$unassignedUsers = array ();
|
|
$unassignedGroups = array ();
|
|
//filter only the delegations that are in selfservice status
|
|
// `USR_UID` = '' AND `DEL_FINISH_DATE` IS NULL
|
|
$indexes = $this->aaSearchRecords( $allAppDbData, array ('USR_UID' => 'NULL','DEL_FINISH_DATE' => 'NULL','APP_THREAD_STATUS' => 'OPEN'
|
|
) );
|
|
foreach ($indexes as $index) {
|
|
$unassignedUsersGroups = array ();
|
|
// use cache
|
|
$oMemcache = PMmemcached::getSingleton( $this->_solrInstance );
|
|
$unassignedUsersGroups = $oMemcache->get( $allAppDbData[$index]['PRO_UID'] . "_" . $allAppDbData[$index]['TAS_UID'] );
|
|
if (! $unassignedUsersGroups) {
|
|
|
|
$unassignedUsersGroups = $this->getTaskUnassignedUsersGroupsData( $allAppDbData[$index]['PRO_UID'], $allAppDbData[$index]['TAS_UID'] );
|
|
|
|
// if the task has unassigned users or groups add del_index of delegation
|
|
foreach ($unassignedUsersGroups as $i => $newRow) {
|
|
$unassignedUsersGroups[$i]['DEL_INDEX'] = $allAppDbData[$index]['DEL_INDEX'];
|
|
}
|
|
// store in cache
|
|
$oMemcache->set( $allAppDbData[$index]['PRO_UID'] . "_" . $allAppDbData[$index]['TAS_UID'], $unassignedUsersGroups );
|
|
}
|
|
|
|
// copy list of unassigned users and groups
|
|
foreach ($unassignedUsersGroups as $unassignedUserGroup) {
|
|
//unassigned users
|
|
if ($unassignedUserGroup['TU_RELATION'] == 1) {
|
|
$unassignedUsers[] = array ('USR_UID' => $unassignedUserGroup['USR_UID'],'DEL_INDEX' => $unassignedUserGroup['DEL_INDEX']
|
|
);
|
|
} //unassigned groups
|
|
elseif ($unassignedUserGroup['TU_RELATION'] == 2) {
|
|
$unassignedGroups[] = array ('USR_UID' => $unassignedUserGroup['USR_UID'],'DEL_INDEX' => $unassignedUserGroup['DEL_INDEX']
|
|
);
|
|
}
|
|
}
|
|
|
|
}
|
|
// Get DataTypes of dynaforms
|
|
// use cache array to store the dynaform variables per process
|
|
// use memory array to store information of Datatypes of Dynaforms
|
|
// All the datatypes of the process => all variables in all dynaforms in the
|
|
// process
|
|
$dynaformFieldTypes = array ();
|
|
|
|
// get cache instance
|
|
$oMemcache = PMmemcached::getSingleton( $this->_solrInstance );
|
|
$dynaformFieldTypes = $oMemcache->get( $documentInformation['PRO_UID'] );
|
|
if (! $dynaformFieldTypes) {
|
|
G::LoadClass( 'dynaformhandler' );
|
|
$dynaformFileNames = $this->getProcessDynaformFileNames( $documentInformation['PRO_UID'] );
|
|
$dynaformFields = array ();
|
|
foreach ($dynaformFileNames as $dynaformFileName) {
|
|
if (is_file( PATH_DATA . '/sites/workflow/xmlForms/' . $dynaformFileName['DYN_FILENAME'] . '.xml' ) && filesize( PATH_DATA . '/sites/workflow/xmlForms/' . $dynaformFileName['DYN_FILENAME'] . '.xml' ) > 0) {
|
|
$dyn = new dynaFormHandler( PATH_DATA . '/sites/workflow/xmlForms/' . $dynaformFileName['DYN_FILENAME'] . '.xml' );
|
|
$dynaformFields[] = $dyn->getFields();
|
|
}
|
|
if (is_file( PATH_DATA . '/sites/workflow/xmlForms/' . $dynaformFileName['DYN_FILENAME'] . '.xml' ) && filesize( PATH_DATA . '/sites/workflow/xmlForms/' . $dynaformFileName['DYN_FILENAME'] . '.xml' ) == 0) {
|
|
|
|
throw new ApplicationWithCorruptDynaformException( "Application with corrupt dynaform. APP_UID: " . $AppUID . "\n" );
|
|
}
|
|
}
|
|
|
|
foreach ($dynaformFields as $aDynFormFields) {
|
|
foreach ($aDynFormFields as $field) {
|
|
// create array of fields and types
|
|
if ($field->getAttribute( 'validate' ) == 'Int') {
|
|
$dynaformFieldTypes[$field->nodeName] = 'Int';
|
|
} elseif ($field->getAttribute( 'validate' ) == 'Real') {
|
|
$dynaformFieldTypes[$field->nodeName] = 'Real';
|
|
} else {
|
|
$dynaformFieldTypes[$field->nodeName] = $field->getAttribute( 'type' );
|
|
}
|
|
}
|
|
}
|
|
// create cache of dynaformfields
|
|
$oMemcache->set( $documentInformation['PRO_UID'], $dynaformFieldTypes );
|
|
}
|
|
// return result values
|
|
$result = array ($documentInformation,$dynaformFieldTypes,$lastUpdateDate,$maxPriority,$assignedUsers,$assignedUsersRead,$assignedUsersUnread,$draftUser,$participatedUsers,$participatedUsersStartedByUser,$participatedUsersCompletedByUser,$unassignedUsers,$unassignedGroups
|
|
);
|
|
|
|
return $result;
|
|
}
|
|
|
|
/**
|
|
* Find the maximun value of the specified column in the array and return the
|
|
* row index
|
|
*
|
|
* @param array $arr array of arrays with the data
|
|
* @param string $column column name to search in
|
|
* @param string $columnType column type STRING, NUMBER, DATE
|
|
* @param string $columnCondition column condition
|
|
* @param string $condition the condition
|
|
* @return integer The index of the maximun record in array
|
|
*/
|
|
public function aaGetMaximun ($arr, $column, $columnType = 'STRING', $columnCondition = "", $condition = "")
|
|
{
|
|
// get first value
|
|
$auxValue = $arr[0][$column];
|
|
$index = null;
|
|
foreach ($arr as $i => $row) {
|
|
switch ($columnType) {
|
|
case 'STRING':
|
|
if ((strnatcmp( $row[$column], $auxValue ) >= 0) && (($columnCondition == "") || ($row[$columnCondition] == $condition))) {
|
|
$auxValue = $row[$column];
|
|
$index = $i;
|
|
}
|
|
break;
|
|
case 'NUMBER':
|
|
if (($row[$column] >= $auxValue) && (($columnCondition == "") || ($row[$columnCondition] == $condition))) {
|
|
$auxValue = $row[$column];
|
|
$index = $i;
|
|
}
|
|
break;
|
|
case 'DATE':
|
|
if ((strtotime( $row[$column] ) >= strtotime( $auxValue )) && (($columnCondition == "") || ($row[$columnCondition] == $condition))) {
|
|
$auxValue = $row[$column];
|
|
$index = $i;
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
return $index;
|
|
}
|
|
|
|
/**
|
|
* Get minimum of array of arrays
|
|
*
|
|
* @param array $arr array of arrays with the data
|
|
* @param string $column the name of the column to search in
|
|
* @param string $columnType the column type STRING, NUMBER, DATE
|
|
* @param string $columnCondition the column condition
|
|
* @param string $condition the condition
|
|
* @return Ambigous <NULL, unknown> Index of the minimun value found
|
|
*/
|
|
public function aaGetMinimun ($arr, $column, $columnType = 'STRING', $columnCondition = "", $condition = "")
|
|
{
|
|
// get first value
|
|
$auxValue = $arr[0][$column];
|
|
$index = null;
|
|
foreach ($arr as $i => $row) {
|
|
switch ($columnType) {
|
|
case 'STRING':
|
|
if ((strnatcmp( $row[$column], $auxValue ) <= 0) && (($columnCondition == "") || ($row[$columnCondition] == $condition))) {
|
|
$auxValue = $row[$column];
|
|
$index = $i;
|
|
}
|
|
break;
|
|
case 'NUMBER':
|
|
if (($row[$column] <= $auxValue) && (($columnCondition == "") || ($row[$columnCondition] == $condition))) {
|
|
$auxValue = $row[$column];
|
|
$index = $i;
|
|
}
|
|
break;
|
|
case 'DATE':
|
|
if ((strtotime( $row[$column] ) <= strtotime( $auxValue )) && (($columnCondition == "") || ($row[$columnCondition] == $condition))) {
|
|
$auxValue = $row[$column];
|
|
$index = $i;
|
|
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
return $index;
|
|
}
|
|
|
|
/**
|
|
* Search array of indexes that fullfill the conditions
|
|
*
|
|
* @param array of arrays $arr contains the arrays that are searched
|
|
* @param array $andColumnsConditions contain the conditions that must fullfill 'Column'=>'Condition'
|
|
* @return array of indexes with the found records
|
|
*/
|
|
public function aaSearchRecords ($arr, $andColumnsConditions)
|
|
{
|
|
$indexes = array ();
|
|
$isEqual = true;
|
|
foreach ($arr as $i => $row) {
|
|
$evaluateRow = false;
|
|
// evaluate each row
|
|
foreach ($andColumnsConditions as $column => $valueCondition) {
|
|
$condition = $valueCondition;
|
|
$isEqual = true;
|
|
if ($valueCondition == 'NULL') {
|
|
$isEqual = true;
|
|
$condition = '';
|
|
}
|
|
if ($valueCondition == 'NOTNULL') {
|
|
$isEqual = false;
|
|
$condition = '';
|
|
}
|
|
if ($isEqual) {
|
|
if ($row[$column] == $condition) {
|
|
$evaluateRow = true;
|
|
} else {
|
|
$evaluateRow = false;
|
|
breaK;
|
|
}
|
|
} else {
|
|
if ($row[$column] != $condition) {
|
|
$evaluateRow = true;
|
|
} else {
|
|
$evaluateRow = false;
|
|
breaK;
|
|
}
|
|
}
|
|
}
|
|
// add row to indexes
|
|
if ($evaluateRow) {
|
|
$indexes[] = $i;
|
|
}
|
|
}
|
|
return $indexes;
|
|
}
|
|
|
|
/**
|
|
* Get application and delegation data from database
|
|
*
|
|
* @param string $AppUID the application identifier
|
|
* @return array of records from database
|
|
*/
|
|
public function getApplicationDelegationData ($AppUID)
|
|
{
|
|
|
|
$allAppDbData = array ();
|
|
|
|
$c = new Criteria();
|
|
|
|
$c->addSelectColumn( ApplicationPeer::APP_UID );
|
|
$c->addSelectColumn( ApplicationPeer::APP_NUMBER );
|
|
$c->addSelectColumn( ApplicationPeer::APP_STATUS );
|
|
$c->addSelectColumn( ApplicationPeer::PRO_UID );
|
|
$c->addSelectColumn( ApplicationPeer::APP_CREATE_DATE );
|
|
$c->addSelectColumn( ApplicationPeer::APP_FINISH_DATE );
|
|
$c->addSelectColumn( ApplicationPeer::APP_UPDATE_DATE );
|
|
$c->addSelectColumn( ApplicationPeer::APP_DATA );
|
|
|
|
$c->addAsColumn( 'APP_TITLE', 'capp.CON_VALUE' );
|
|
$c->addAsColumn( 'PRO_TITLE', 'cpro.CON_VALUE' );
|
|
|
|
$c->addSelectColumn( 'ad.DEL_INDEX' );
|
|
$c->addSelectColumn( 'ad.DEL_PREVIOUS' );
|
|
$c->addSelectColumn( 'ad.TAS_UID' );
|
|
$c->addSelectColumn( 'ad.USR_UID' );
|
|
$c->addSelectColumn( 'ad.DEL_TYPE' );
|
|
$c->addSelectColumn( 'ad.DEL_THREAD' );
|
|
$c->addSelectColumn( 'ad.DEL_THREAD_STATUS' );
|
|
$c->addSelectColumn( 'ad.DEL_PRIORITY' );
|
|
$c->addSelectColumn( 'ad.DEL_DELEGATE_DATE' );
|
|
$c->addSelectColumn( 'ad.DEL_INIT_DATE' );
|
|
$c->addSelectColumn( 'ad.DEL_TASK_DUE_DATE' );
|
|
$c->addSelectColumn( 'ad.DEL_FINISH_DATE' );
|
|
$c->addSelectColumn( 'ad.DEL_DURATION' );
|
|
$c->addSelectColumn( 'ad.DEL_QUEUE_DURATION' );
|
|
$c->addSelectColumn( 'ad.DEL_DELAY_DURATION' );
|
|
$c->addSelectColumn( 'ad.DEL_STARTED' );
|
|
$c->addSelectColumn( 'ad.DEL_FINISHED' );
|
|
$c->addSelectColumn( 'ad.DEL_DELAYED' );
|
|
$c->addSelectColumn( 'ad.APP_OVERDUE_PERCENTAGE' );
|
|
|
|
$c->addSelectColumn( 'at.APP_THREAD_INDEX' );
|
|
$c->addSelectColumn( 'at.APP_THREAD_PARENT' );
|
|
$c->addSelectColumn( 'at.APP_THREAD_STATUS' );
|
|
|
|
$c->addAlias( 'capp', 'CONTENT' );
|
|
$c->addAlias( 'cpro', 'CONTENT' );
|
|
$c->addAlias( 'ad', 'APP_DELEGATION' );
|
|
$c->addAlias( 'at', 'APP_THREAD' );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array (ApplicationPeer::APP_UID,'capp.CON_ID'
|
|
);
|
|
$aConditions[] = array ('capp.CON_CATEGORY',DBAdapter::getStringDelimiter() . 'APP_TITLE' . DBAdapter::getStringDelimiter()
|
|
);
|
|
$aConditions[] = array ('capp.CON_LANG',DBAdapter::getStringDelimiter() . 'en' . DBAdapter::getStringDelimiter()
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array (ApplicationPeer::PRO_UID,'cpro.CON_ID'
|
|
);
|
|
$aConditions[] = array ('cpro.CON_CATEGORY',DBAdapter::getStringDelimiter() . 'PRO_TITLE' . DBAdapter::getStringDelimiter()
|
|
);
|
|
$aConditions[] = array ('cpro.CON_LANG',DBAdapter::getStringDelimiter() . 'en' . DBAdapter::getStringDelimiter()
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$c->addJoin( ApplicationPeer::APP_UID, 'ad.APP_UID', Criteria::JOIN );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array ('ad.APP_UID','at.APP_UID'
|
|
);
|
|
$aConditions[] = array ('ad.DEL_THREAD','at.APP_THREAD_INDEX'
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::JOIN );
|
|
|
|
$c->add( ApplicationPeer::APP_UID, $AppUID );
|
|
|
|
$rs = ApplicationPeer::doSelectRS( $c );
|
|
$rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
|
|
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
|
|
while (is_array( $row )) {
|
|
$allAppDbData[] = $row;
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
}
|
|
return $allAppDbData;
|
|
}
|
|
|
|
/**
|
|
* Get application and delegation data from database
|
|
*
|
|
* @param string $aAppUID array of application identifiers
|
|
* @return array of array of records from database
|
|
*/
|
|
public function getListApplicationUpdateDelegationData ($aaAppUIDs)
|
|
{
|
|
|
|
$allAppDbData = array ();
|
|
|
|
$c = new Criteria();
|
|
|
|
$c->addSelectColumn( ApplicationPeer::APP_UID );
|
|
$c->addSelectColumn( ApplicationPeer::APP_NUMBER );
|
|
$c->addSelectColumn( ApplicationPeer::APP_STATUS );
|
|
$c->addSelectColumn( ApplicationPeer::PRO_UID );
|
|
$c->addSelectColumn( ApplicationPeer::APP_CREATE_DATE );
|
|
$c->addSelectColumn( ApplicationPeer::APP_FINISH_DATE );
|
|
$c->addSelectColumn( ApplicationPeer::APP_UPDATE_DATE );
|
|
$c->addSelectColumn( ApplicationPeer::APP_DATA );
|
|
|
|
$c->addAsColumn( 'APP_TITLE', 'capp.CON_VALUE' );
|
|
$c->addAsColumn( 'PRO_TITLE', 'cpro.CON_VALUE' );
|
|
|
|
$c->addSelectColumn( 'ad.DEL_INDEX' );
|
|
$c->addSelectColumn( 'ad.DEL_PREVIOUS' );
|
|
$c->addSelectColumn( 'ad.TAS_UID' );
|
|
$c->addSelectColumn( 'ad.USR_UID' );
|
|
$c->addSelectColumn( 'ad.DEL_TYPE' );
|
|
$c->addSelectColumn( 'ad.DEL_THREAD' );
|
|
$c->addSelectColumn( 'ad.DEL_THREAD_STATUS' );
|
|
$c->addSelectColumn( 'ad.DEL_PRIORITY' );
|
|
$c->addSelectColumn( 'ad.DEL_DELEGATE_DATE' );
|
|
$c->addSelectColumn( 'ad.DEL_INIT_DATE' );
|
|
$c->addSelectColumn( 'ad.DEL_TASK_DUE_DATE' );
|
|
$c->addSelectColumn( 'ad.DEL_FINISH_DATE' );
|
|
$c->addSelectColumn( 'ad.DEL_DURATION' );
|
|
$c->addSelectColumn( 'ad.DEL_QUEUE_DURATION' );
|
|
$c->addSelectColumn( 'ad.DEL_DELAY_DURATION' );
|
|
$c->addSelectColumn( 'ad.DEL_STARTED' );
|
|
$c->addSelectColumn( 'ad.DEL_FINISHED' );
|
|
$c->addSelectColumn( 'ad.DEL_DELAYED' );
|
|
$c->addSelectColumn( 'ad.APP_OVERDUE_PERCENTAGE' );
|
|
|
|
$c->addSelectColumn( 'at.APP_THREAD_INDEX' );
|
|
$c->addSelectColumn( 'at.APP_THREAD_PARENT' );
|
|
$c->addSelectColumn( 'at.APP_THREAD_STATUS' );
|
|
|
|
$c->addAlias( 'capp', 'CONTENT' );
|
|
$c->addAlias( 'cpro', 'CONTENT' );
|
|
$c->addAlias( 'ad', 'APP_DELEGATION' );
|
|
$c->addAlias( 'at', 'APP_THREAD' );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array (ApplicationPeer::APP_UID,'capp.CON_ID'
|
|
);
|
|
$aConditions[] = array ('capp.CON_CATEGORY',DBAdapter::getStringDelimiter() . 'APP_TITLE' . DBAdapter::getStringDelimiter()
|
|
);
|
|
$aConditions[] = array ('capp.CON_LANG',DBAdapter::getStringDelimiter() . 'en' . DBAdapter::getStringDelimiter()
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array (ApplicationPeer::PRO_UID,'cpro.CON_ID'
|
|
);
|
|
$aConditions[] = array ('cpro.CON_CATEGORY',DBAdapter::getStringDelimiter() . 'PRO_TITLE' . DBAdapter::getStringDelimiter()
|
|
);
|
|
$aConditions[] = array ('cpro.CON_LANG',DBAdapter::getStringDelimiter() . 'en' . DBAdapter::getStringDelimiter()
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
|
|
$c->addJoin( ApplicationPeer::APP_UID, 'ad.APP_UID', Criteria::JOIN );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array ('ad.APP_UID','at.APP_UID'
|
|
);
|
|
$aConditions[] = array ('ad.DEL_THREAD','at.APP_THREAD_INDEX'
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::JOIN );
|
|
|
|
$c->add( ApplicationPeer::APP_UID, $aaAppUIDs, Criteria::IN );
|
|
|
|
$rs = ApplicationPeer::doSelectRS( $c );
|
|
$rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
|
|
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
|
|
while (is_array( $row )) {
|
|
$allAppDbData[] = $row;
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
}
|
|
return $allAppDbData;
|
|
}
|
|
|
|
/**
|
|
* Get the list of groups of unassigned users of the specified task from
|
|
* database
|
|
*
|
|
* @param string $ProUID Process identifier
|
|
* @param string $TaskUID task identifier
|
|
* @return array of unassigned user groups
|
|
*/
|
|
public function getTaskUnassignedUsersGroupsData ($ProUID, $TaskUID)
|
|
{
|
|
$unassignedUsersGroups = array ();
|
|
|
|
$c = new Criteria();
|
|
|
|
$c->addSelectColumn( TaskUserPeer::USR_UID );
|
|
$c->addSelectColumn( TaskUserPeer::TU_RELATION );
|
|
|
|
$aConditions = array ();
|
|
$aConditions[] = array (TaskPeer::TAS_UID,TaskUserPeer::TAS_UID
|
|
);
|
|
$aConditions[] = array (TaskPeer::TAS_ASSIGN_TYPE,DBAdapter::getStringDelimiter() . 'SELF_SERVICE' . DBAdapter::getStringDelimiter()
|
|
);
|
|
$c->addJoinMC( $aConditions, Criteria::JOIN );
|
|
|
|
$c->add( TaskPeer::PRO_UID, $ProUID );
|
|
$c->add( TaskPeer::TAS_UID, $TaskUID );
|
|
|
|
$rs = TaskPeer::doSelectRS( $c );
|
|
$rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
|
|
// echo $c->toString();
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
|
|
while (is_array( $row )) {
|
|
$unassignedUsersGroups[] = $row;
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
}
|
|
|
|
return $unassignedUsersGroups;
|
|
}
|
|
|
|
/**
|
|
* Get the list of dynaform file names associated with the specified process
|
|
* from database
|
|
*
|
|
* @param string $ProUID process identifier
|
|
* @return array of dynaform file names
|
|
*/
|
|
public function getProcessDynaformFileNames ($ProUID)
|
|
{
|
|
$dynaformFileNames = array ();
|
|
|
|
$c = new Criteria();
|
|
|
|
$c->addSelectColumn( DynaformPeer::DYN_FILENAME );
|
|
|
|
$c->add( DynaformPeer::PRO_UID, $ProUID );
|
|
|
|
$rs = DynaformPeer::doSelectRS( $c );
|
|
$rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
|
|
while (is_array( $row )) {
|
|
$dynaformFileNames[] = $row;
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
}
|
|
|
|
return $dynaformFileNames;
|
|
}
|
|
|
|
/**
|
|
* Store a flag indicating if the application was updated in database
|
|
* table APP_SOLR_QUEUE
|
|
*
|
|
* @param string $AppUid applicatiom identifier
|
|
* @param integer $updated 0:false, not updated, 1: updated, 2:deleted
|
|
*/
|
|
public function applicationChangedUpdateSolrQueue ($AppUid, $updated)
|
|
{
|
|
$oAppSolrQueue = new AppSolrQueue();
|
|
|
|
$oAppSolrQueue->createUpdate( $AppUid, $updated );
|
|
}
|
|
|
|
/**
|
|
* Update application records in Solr that are stored in APP_SOLR_QUEUE table
|
|
*/
|
|
public function synchronizePendingApplications ()
|
|
{
|
|
// check table of pending updates
|
|
$oAppSolrQueue = new AppSolrQueue();
|
|
|
|
$aAppSolrQueue = $oAppSolrQueue->getListUpdatedApplications();
|
|
|
|
foreach ($aAppSolrQueue as $oAppSolrQueueEntity) {
|
|
// call the syncronization function
|
|
if ($oAppSolrQueueEntity->appUpdated == 1) {
|
|
$this->updateApplicationSearchIndex( $oAppSolrQueueEntity->appUid );
|
|
}
|
|
if ($oAppSolrQueueEntity->appUpdated == 2) {
|
|
$this->deleteApplicationSearchIndex( $oAppSolrQueueEntity->appUid );
|
|
}
|
|
$this->applicationChangedUpdateSolrQueue( $oAppSolrQueueEntity->appUid, 0 );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get the total number of application records in database
|
|
*
|
|
* @return integer application counter
|
|
*/
|
|
public function getCountApplicationsPMOS2 ()
|
|
{
|
|
$c = new Criteria();
|
|
|
|
$c->addSelectColumn( ApplicationPeer::APP_UID );
|
|
|
|
$count = ApplicationPeer::doCount( $c );
|
|
|
|
return $count;
|
|
}
|
|
|
|
/**
|
|
* Get the total number of application records in search index
|
|
*
|
|
* @return integer application counter
|
|
*/
|
|
public function getCountApplicationsSearchIndex ()
|
|
{
|
|
G::LoadClass( 'searchIndex' );
|
|
|
|
$searchIndex = new BpmnEngine_Services_SearchIndex( $this->_solrIsEnabled, $this->_solrHost );
|
|
// execute query
|
|
$count = $searchIndex->getNumberDocuments( $this->_solrInstance );
|
|
|
|
return $count;
|
|
}
|
|
|
|
/**
|
|
* Optimize the records in search index
|
|
*
|
|
* @return
|
|
*
|
|
*/
|
|
public function optimizeSearchIndex ()
|
|
{
|
|
G::LoadClass( 'searchIndex' );
|
|
|
|
$searchIndex = new BpmnEngine_Services_SearchIndex( $this->_solrIsEnabled, $this->_solrHost );
|
|
// execute query
|
|
$searchIndex->optimizeIndexChanges( $this->_solrInstance );
|
|
|
|
}
|
|
|
|
/**
|
|
* Get a paginated list of application uids from database.
|
|
*
|
|
* @param integer $skip the offset from where to return the application records
|
|
* @param integer $pagesize the size of the page
|
|
* @return array of application id's in the specified page.
|
|
*/
|
|
public function getPagedApplicationUids ($skip, $pagesize)
|
|
{
|
|
|
|
$c = new Criteria();
|
|
|
|
$c->addSelectColumn( ApplicationPeer::APP_UID );
|
|
$c->setOffset( $skip );
|
|
$c->setLimit( $pagesize );
|
|
|
|
$rs = ApplicationPeer::doSelectRS( $c );
|
|
$rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
|
|
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
$appUIds = array ();
|
|
while (is_array( $row )) {
|
|
$appUIds[] = $row;
|
|
$rs->next();
|
|
$row = $rs->getRow();
|
|
}
|
|
return $appUIds;
|
|
}
|
|
|
|
/**
|
|
* Reindex all the application records in Solr server
|
|
* update applications in groups of 1000
|
|
*/
|
|
public function reindexAllApplications ($SkipRecords = 0, $indexTrunkSize = 1000)
|
|
{
|
|
$trunk = $indexTrunkSize;
|
|
// delete all documents to begin reindex
|
|
// deleteAllDocuments();
|
|
// commitChanges();
|
|
// print "Deleted all documents \n";
|
|
// search trunks of id's to regenerate index
|
|
$numRows = $this->getCountApplicationsPMOS2();
|
|
print "Total number of records: " . $numRows . "\n";
|
|
$initTimeAll = microtime( true );
|
|
|
|
for ($skip = $SkipRecords; $skip <= $numRows; true) {
|
|
$aaAPPUIds = $this->getPagedApplicationUids( $skip, $trunk );
|
|
|
|
printf( "Indexing %d to %d \n", $skip, $skip + $trunk );
|
|
$initTimeDoc = microtime( true );
|
|
$this->updateApplicationSearchIndex( $aaAPPUIds );
|
|
|
|
$curTimeDoc = gmdate( 'H:i:s', (microtime( true ) - $initTimeDoc) );
|
|
printf( "Indexing document time: %s \n", $curTimeDoc );
|
|
$skip += $trunk;
|
|
}
|
|
|
|
$curTimeDoc = gmdate( 'H:i:s', (microtime( true ) - $initTimeAll) );
|
|
printf( "Total reindex time: %s \n", $curTimeDoc );
|
|
printf( "Reindex completed successfully!!.\n" );
|
|
}
|
|
}
|
|
|