fernando/luos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

BUG 0000 adding memcache to processList

Browse Source 
fixing telefonica slow issues
This commit is contained in:
Fernando Ontiveros
2012-04-12 17:33:16 -04:00
parent 925e6e8881
commit 84dbad7617
3 changed files with 59 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
gulliver/thirdparty/propel/util/Criteria.php vendored
View File

@@ -1341,7 +1341,7 @@ class Criterion {
} catch (Exception $e) { } catch (Exception $e) {
// we are only doing this to allow easier debugging, so // we are only doing this to allow easier debugging, so
// no need to throw up the exception, just make note of it. // no need to throw up the exception, just make note of it.
Propel::log("Could not get a DBAdapter, generated sql may be wrong", Propel::LOG_ERR); //Propel::log("Could not get a DBAdapter, generated sql may be wrong", Propel::LOG_ERR);
} }
//init $this->realtable //init $this->realtable

31
workflow/engine/classes/model/Process.php
View File

@@ -713,21 +713,26 @@ class Process extends BaseProcess {
GROUP BY PRO_UID, APP_STATUS*/ GROUP BY PRO_UID, APP_STATUS*/
require_once 'classes/model/Application.php'; require_once 'classes/model/Application.php';
$oCriteria = new Criteria('workflow'); $memcache = & PMmemcached::getSingleton(SYS_SYS);
$oCriteria->addSelectColumn(ApplicationPeer::PRO_UID); $memkey = 'getCasesCountInAllProcesses';
$oCriteria->addSelectColumn(ApplicationPeer::APP_STATUS); if ( ($aProcesses = $memcache->get( $memkey )) === false ) {
$oCriteria->addSelectColumn('COUNT(*) AS CNT'); $oCriteria = new Criteria('workflow');
$oCriteria->addGroupByColumn(ApplicationPeer::PRO_UID); $oCriteria->addSelectColumn(ApplicationPeer::PRO_UID);
$oCriteria->addGroupByColumn(ApplicationPeer::APP_STATUS); $oCriteria->addSelectColumn(ApplicationPeer::APP_STATUS);
$oCriteria->addSelectColumn('COUNT(*) AS CNT');
$oCriteria->addGroupByColumn(ApplicationPeer::PRO_UID);
$oCriteria->addGroupByColumn(ApplicationPeer::APP_STATUS);
$oDataset = ProcessPeer::doSelectRS ( $oCriteria ); $oDataset = ProcessPeer::doSelectRS ( $oCriteria );
$oDataset->setFetchmode ( ResultSet::FETCHMODE_ASSOC ); $oDataset->setFetchmode ( ResultSet::FETCHMODE_ASSOC );
$aProcesses = Array(); $aProcesses = Array();
while($oDataset->next()) { while($oDataset->next()) {
$row = $oDataset->getRow(); $row = $oDataset->getRow();
$aProcesses[$row['PRO_UID']][$row['APP_STATUS']] = $row['CNT']; $aProcesses[$row['PRO_UID']][$row['APP_STATUS']] = $row['CNT'];
} }
$memcache->set( $memkey , $aProcesses, PMmemcached::ONE_HOUR );
}
return $aProcesses; return $aProcesses;
} }

56
workflow/engine/methods/processes/processesList.php
View File

@@ -29,22 +29,46 @@ $start = isset($_POST['start'])? $_POST['start']: 0;
$limit = isset($_POST['limit'])? $_POST['limit']: ''; $limit = isset($_POST['limit'])? $_POST['limit']: '';
$oProcess = new Process(); $oProcess = new Process();
if( isset($_POST['category']) && $_POST['category'] !== '<reset>' ){ $memcache = & PMmemcached::getSingleton(SYS_SYS);
if( isset($_POST['processName']) )
$proData = $oProcess->getAllProcesses($start, $limit, $_POST['category'], $_POST['processName']); $memkey = 'no memcache';
else $memcacheUsed = 'not used';
$proData = $oProcess->getAllProcesses($start, $limit, $_POST['category']); $totalCount = 0;
}
else {
if( isset($_POST['processName']) )
$proData = $oProcess->getAllProcesses($start, $limit, null, $_POST['processName']);
else
$proData = $oProcess->getAllProcesses($start, $limit);
}
$r->data = $proData;
//$r->totalCount = count($proData); if( isset($_POST['category']) && $_POST['category'] !== '<reset>' ) {
$r->totalCount = $oProcess->getAllProcessesCount(); if( isset($_POST['processName']) )
$proData = $oProcess->getAllProcesses($start, $limit, $_POST['category'], $_POST['processName']);
else
$proData = $oProcess->getAllProcesses($start, $limit, $_POST['category']);
}
else {
if( isset($_POST['processName']) ) {
$memkey = 'processList-' . $start . '-' . $limit . '-' . $_POST['processName'];
$memcacheUsed = 'yes';
if ( ($proData = $memcache->get( $memkey )) === false ) {
$proData = $oProcess->getAllProcesses($start, $limit, null, $_POST['processName']);
$memcache->set( $memkey , $proData, PMmemcached::ONE_HOUR );
$memcacheUsed = 'no';
}
}
else {
$memkey = 'processList-allProcesses-' . $start . '-' . $limit;
$memkeyTotal = $memkey . '-total';
$memcacheUsed = 'yes';
if ( ($proData = $memcache->get( $memkey )) === false || ($totalCount=$memcache->get( $memkeyTotal)) === false ) {
$proData = $oProcess->getAllProcesses($start, $limit);
$totalCount = $oProcess->getAllProcessesCount();
$memcache->set( $memkey , $proData, PMmemcached::ONE_HOUR );
$memcache->set( $memkeyTotal , $totalCount, PMmemcached::ONE_HOUR );
$memcacheUsed = 'no';
}
}
}
$r->memkey = $memkey;
$r->memcache = $memcacheUsed;
$r->data = $proData;
$r->totalCount = $totalCount;
echo G::json_encode($r); echo G::json_encode($r);