YuCheng Hu
3e68fd5a3e
+YUCHENG HU+ git-svn-id: https://svn.code.sf.net/p/hawebs/svn@365 a2543c7e-f6e9-4f8a-8bff-1ffc34733512
125 lines
3.6 KiB
PHP
125 lines
3.6 KiB
PHP
<?php
|
|
/*+***********************************************************************************
|
|
* The contents of this file are subject to the vtiger CRM Public License Version 1.0
|
|
* ("License"); You may not use this file except in compliance with the License
|
|
* The Original Code is: vtiger CRM Open Source
|
|
* The Initial Developer of the Original Code is vtiger.
|
|
* Portions created by vtiger are Copyright (C) vtiger.
|
|
* All Rights Reserved.
|
|
*************************************************************************************/
|
|
|
|
require_once("include/events/SqlResultIterator.inc");
|
|
class VTEventTrigger{
|
|
|
|
/* EventTrigger cache management */
|
|
private static $cache = array();
|
|
private static $cacheLookupType = '';
|
|
|
|
const CACHE_LOOKUP_TYPE_ALL = 'ALL';
|
|
|
|
static function initCache($name = false, $force = false) {
|
|
global $adb;
|
|
|
|
if($name) {
|
|
$names = $name;
|
|
if(!is_array($names)) $names = array($name);
|
|
|
|
$evtinfos = self::getActiveEventInfos($adb, $names);
|
|
|
|
foreach($evtinfos as $k=>$v) {
|
|
if(!self::isCached($k) || $force) {
|
|
self::$cache[$forname] = $evtinfos;
|
|
}
|
|
}
|
|
} else {
|
|
if(!self::isCached() || $force) {
|
|
self::$cache = self::getActiveEventInfos($adb, $name);
|
|
self::$cacheLookupType = self::CACHE_LOOKUP_TYPE_ALL;
|
|
}
|
|
}
|
|
}
|
|
static function isCached($name = false) {
|
|
if($name === false) {
|
|
if(self::$cacheLookupType == self::CACHE_LOOKUP_TYPE_ALL) {
|
|
// Was init cache done for ALL earlier?
|
|
return true;
|
|
}
|
|
} else {
|
|
return isset(self::$cache[$name]);
|
|
}
|
|
return false;
|
|
}
|
|
static function clearCache($name = false) {
|
|
if($name === false) {
|
|
self::$cache = array();
|
|
self::$cacheLookupType = '';
|
|
} else if(self::isCached($name)) {
|
|
unset(self::$cache[$name]);
|
|
}
|
|
}
|
|
static function lookupCache($name) {
|
|
if(self::isCached($name)) {
|
|
return self::$cache[$name];
|
|
} else if(self::$cacheLookupType == self::CACHE_LOOKUP_TYPE_ALL) {
|
|
return array();
|
|
}
|
|
return false;
|
|
}
|
|
|
|
static function getActiveEventInfos($adb, $name = false) {
|
|
$params = array();
|
|
$query = "SELECT * FROM vtiger_eventhandlers WHERE is_active=true";
|
|
if($name !== false) {
|
|
if(is_array($name)) {
|
|
$query .= " AND event_name IN (" . generateQuestionMarks($name) . ")";
|
|
} else {
|
|
$query .= " AND event_name = ?";
|
|
}
|
|
$params[] = $name;
|
|
}
|
|
|
|
$evtinfosbyname = array();
|
|
|
|
$result= $adb->pquery($query, $params);
|
|
$it = new SqlResultIterator($adb, $result);
|
|
foreach($it as $row) {
|
|
$evtinfosbyname[$row->event_name][] = array(
|
|
'condition' => $row->cond,
|
|
'handler_class' => $row->handler_class,
|
|
'handler_path' => $row->handler_path
|
|
);
|
|
}
|
|
|
|
if($name) return $evtinfosbyname[$name];
|
|
else return $evtinfosbyname;
|
|
}
|
|
/** END **/
|
|
|
|
function __construct($adb, $name){
|
|
$this->name=$name;
|
|
$this->adb = $adb;
|
|
}
|
|
|
|
function trigger($data){
|
|
$adb = $this->adb;
|
|
|
|
$eventInfos = self::lookupCache($this->name);
|
|
if($eventInfos === false) {
|
|
$eventInfos = self::getActiveEventInfos($this->adb, $this->name);
|
|
}
|
|
|
|
if($eventInfos) {
|
|
foreach($eventInfos as $eventInfo){
|
|
$condition = new VTEventCondition($eventInfo['condition']);
|
|
if($condition->test($data)){
|
|
require_once($eventInfo['handler_path']);
|
|
$handler_class = $eventInfo['handler_class'];
|
|
$handler = new $handler_class();
|
|
|
|
$handler->handleEvent($this->name, $data);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
?>
|