987 lines
36 KiB
PHP
Executable File
987 lines
36 KiB
PHP
Executable File
<?php
|
|
register_shutdown_function(
|
|
create_function(
|
|
'',
|
|
'
|
|
if (class_exists("Propel")) {
|
|
Propel::close();
|
|
}
|
|
'
|
|
)
|
|
);
|
|
|
|
ini_set('memory_limit', '512M');
|
|
|
|
try {
|
|
//Verify data
|
|
if (count($argv) < 8) {
|
|
throw new Exception('Error: Invalid number of arguments');
|
|
}
|
|
|
|
for ($i = 1; $i <= 3; $i++) {
|
|
$argv[$i] = base64_decode($argv[$i]);
|
|
|
|
if (!is_dir($argv[$i])) {
|
|
throw new Exception('Error: The path "' . $argv[$i] . '" is invalid');
|
|
}
|
|
}
|
|
|
|
//Set variables
|
|
$osIsLinux = strtoupper(substr(PHP_OS, 0, 3)) != 'WIN';
|
|
|
|
$pathHome = $argv[1];
|
|
$pathTrunk = $argv[2];
|
|
$pathOutTrunk = $argv[3];
|
|
$cronName = $argv[4];
|
|
$workspace = $argv[5];
|
|
$dateSystem = $argv[6];
|
|
$sNow = $argv[7]; //$date
|
|
|
|
//Defines constants
|
|
define('PATH_SEP', ($osIsLinux)? '/' : '\\');
|
|
|
|
define('PATH_HOME', $pathHome);
|
|
define('PATH_TRUNK', $pathTrunk);
|
|
define('PATH_OUTTRUNK', $pathOutTrunk);
|
|
|
|
define('PATH_CLASSES', PATH_HOME . 'engine' . PATH_SEP . 'classes' . PATH_SEP);
|
|
|
|
define('SYS_LANG', 'en');
|
|
|
|
require_once(PATH_HOME . 'engine' . PATH_SEP . 'config' . PATH_SEP . 'paths.php');
|
|
require_once(PATH_TRUNK . 'framework' . PATH_SEP . 'src' . PATH_SEP . 'Maveriks' . PATH_SEP . 'Util' . PATH_SEP . 'ClassLoader.php');
|
|
|
|
//Class Loader - /ProcessMaker/BusinessModel
|
|
$classLoader = \Maveriks\Util\ClassLoader::getInstance();
|
|
$classLoader->add(PATH_TRUNK . 'framework' . PATH_SEP . 'src' . PATH_SEP, 'Maveriks');
|
|
$classLoader->add(PATH_TRUNK . 'workflow' . PATH_SEP . 'engine' . PATH_SEP . 'src' . PATH_SEP, 'ProcessMaker');
|
|
$classLoader->add(PATH_TRUNK . 'workflow' . PATH_SEP . 'engine' . PATH_SEP . 'src' . PATH_SEP);
|
|
|
|
//Add vendors to autoloader
|
|
//$classLoader->add(PATH_TRUNK . 'vendor' . PATH_SEP . 'luracast' . PATH_SEP . 'restler' . PATH_SEP . 'vendor', 'Luracast');
|
|
//$classLoader->add(PATH_TRUNK . 'vendor' . PATH_SEP . 'bshaffer' . PATH_SEP . 'oauth2-server-php' . PATH_SEP . 'src' . PATH_SEP, 'OAuth2');
|
|
$classLoader->addClass('Bootstrap', PATH_TRUNK . 'gulliver' . PATH_SEP . 'system' . PATH_SEP . 'class.bootstrap.php');
|
|
|
|
$classLoader->addModelClassPath(PATH_TRUNK . 'workflow' . PATH_SEP . 'engine' . PATH_SEP . 'classes' . PATH_SEP . 'model' . PATH_SEP);
|
|
|
|
//Load classes
|
|
G::LoadThirdParty('pear/json', 'class.json');
|
|
G::LoadThirdParty('smarty/libs', 'Smarty.class');
|
|
G::LoadSystem('error');
|
|
G::LoadSystem('dbconnection');
|
|
G::LoadSystem('dbsession');
|
|
G::LoadSystem('dbrecordset');
|
|
G::LoadSystem('dbtable');
|
|
G::LoadSystem('rbac' );
|
|
G::LoadSystem('publisher');
|
|
G::LoadSystem('templatePower');
|
|
G::LoadSystem('xmlDocument');
|
|
G::LoadSystem('xmlform');
|
|
G::LoadSystem('xmlformExtension');
|
|
G::LoadSystem('form');
|
|
G::LoadSystem('menu');
|
|
G::LoadSystem('xmlMenu');
|
|
G::LoadSystem('dvEditor');
|
|
G::LoadSystem('table');
|
|
G::LoadSystem('pagedTable');
|
|
G::LoadSystem('httpProxyController');
|
|
G::LoadClass('system');
|
|
|
|
require_once('propel/Propel.php');
|
|
require_once('creole/Creole.php');
|
|
|
|
$arraySystemConfiguration = System::getSystemConfiguration('', '', $workspace);
|
|
|
|
$e_all = (defined('E_DEPRECATED'))? E_ALL & ~E_DEPRECATED : E_ALL;
|
|
$e_all = (defined('E_STRICT'))? $e_all & ~E_STRICT : $e_all;
|
|
$e_all = ($arraySystemConfiguration['debug'])? $e_all : $e_all & ~E_NOTICE;
|
|
|
|
//Do not change any of these settings directly, use env.ini instead
|
|
ini_set('display_errors', $arraySystemConfiguration['debug']);
|
|
ini_set('error_reporting', $e_all);
|
|
ini_set('short_open_tag', 'On');
|
|
ini_set('default_charset', 'UTF-8');
|
|
//ini_set('memory_limit', $arraySystemConfiguration['memory_limit']);
|
|
ini_set('soap.wsdl_cache_enabled', $arraySystemConfiguration['wsdl_cache']);
|
|
ini_set('date.timezone', $arraySystemConfiguration['time_zone']);
|
|
|
|
define('DEBUG_SQL_LOG', $arraySystemConfiguration['debug_sql']);
|
|
define('DEBUG_TIME_LOG', $arraySystemConfiguration['debug_time']);
|
|
define('DEBUG_CALENDAR_LOG', $arraySystemConfiguration['debug_calendar']);
|
|
define('MEMCACHED_ENABLED', $arraySystemConfiguration['memcached']);
|
|
define('MEMCACHED_SERVER', $arraySystemConfiguration['memcached_server']);
|
|
define('TIME_ZONE', ini_get('date.timezone'));
|
|
|
|
//require_once(PATH_GULLIVER . PATH_SEP . 'class.bootstrap.php');
|
|
//define('PATH_GULLIVER_HOME', PATH_TRUNK . 'gulliver' . PATH_SEP);
|
|
|
|
spl_autoload_register(['Bootstrap', 'autoloadClass']);
|
|
|
|
//DATABASE propel classes used in 'Cases' Options
|
|
Bootstrap::registerClass('AuthenticationSourcePeer', PATH_RBAC . 'model' . PATH_SEP . 'AuthenticationSourcePeer.php');
|
|
Bootstrap::registerClass('BaseAuthenticationSource', PATH_RBAC . 'model' . PATH_SEP . 'om' . PATH_SEP . 'BaseAuthenticationSource.php');
|
|
Bootstrap::registerClass('AuthenticationSource', PATH_RBAC . 'model' . PATH_SEP . 'AuthenticationSource.php');
|
|
Bootstrap::registerClass('RolesPeer', PATH_RBAC . 'model' . PATH_SEP . 'RolesPeer.php');
|
|
Bootstrap::registerClass('BaseRoles', PATH_RBAC . 'model' . PATH_SEP . 'om' . PATH_SEP . 'BaseRoles.php');
|
|
Bootstrap::registerClass('Roles', PATH_RBAC . 'model' . PATH_SEP . 'Roles.php');
|
|
|
|
require_once(PATH_RBAC . 'model' . PATH_SEP . 'UsersRolesPeer.php');
|
|
require_once(PATH_RBAC . 'model' . PATH_SEP . 'om' . PATH_SEP . 'BaseUsersRoles.php');
|
|
require_once(PATH_RBAC . 'model' . PATH_SEP . 'UsersRoles.php');
|
|
|
|
Bootstrap::registerClass('PMLicensedFeatures', PATH_CLASSES . 'class.licensedFeatures.php');
|
|
Bootstrap::registerClass('serverConf', PATH_CLASSES . 'class.serverConfiguration.php');
|
|
Bootstrap::registerClass('calendar', PATH_CLASSES . 'class.calendar.php');
|
|
Bootstrap::registerClass('groups', PATH_CLASSES . 'class.groups.php');
|
|
|
|
Bootstrap::registerClass('Entity_Base', PATH_HOME . 'engine/classes/entities/Base.php');
|
|
Bootstrap::registerClass('Entity_AppSolrQueue', PATH_HOME . 'engine/classes/entities/AppSolrQueue.php');
|
|
Bootstrap::registerClass('XMLDB', PATH_HOME . 'engine/classes/class.xmlDb.php');
|
|
Bootstrap::registerClass('dynaFormHandler', PATH_GULLIVER . 'class.dynaformhandler.php');
|
|
Bootstrap::registerClass('DynaFormField', PATH_HOME . 'engine/classes/class.dynaFormField.php');
|
|
Bootstrap::registerClass('SolrRequestData', PATH_HOME . 'engine/classes/entities/SolrRequestData.php');
|
|
Bootstrap::registerClass('SolrUpdateDocument', PATH_HOME . 'engine/classes/entities/SolrUpdateDocument.php');
|
|
Bootstrap::registerClass('Xml_Node', PATH_GULLIVER . 'class.xmlDocument.php');
|
|
Bootstrap::registerClass('wsResponse', PATH_HOME . 'engine' . PATH_SEP . 'classes' . PATH_SEP . 'class.wsResponse.php');
|
|
|
|
/*----------------------------------********---------------------------------*/
|
|
Bootstrap::registerClass('dashboards', PATH_HOME . 'engine/classes/class.dashboards.php');
|
|
/*----------------------------------********---------------------------------*/
|
|
|
|
G::LoadClass('processes');
|
|
G::LoadClass('derivation');
|
|
G::LoadClass('dates'); //Load Criteria
|
|
G::LoadClass('spool');
|
|
|
|
//Set variables
|
|
/*----------------------------------********---------------------------------*/
|
|
$dateInit = null;
|
|
$dateFinish = null;
|
|
/*----------------------------------********---------------------------------*/
|
|
|
|
$argvx = '';
|
|
|
|
for ($i = 8; $i <= count($argv) - 1; $i++) {
|
|
/*----------------------------------********---------------------------------*/
|
|
if (strpos($argv[$i], '+init-date') !== false) {
|
|
$dateInit = substr($argv[$i], 10);
|
|
} else if (strpos($argv[$i], '+finish-date') !== false) {
|
|
$dateFinish = substr($argv[$i], 12);
|
|
} else {
|
|
/*----------------------------------********---------------------------------*/
|
|
$argvx = $argvx . (($argvx != '')? ' ' : '') . $argv[$i];
|
|
/*----------------------------------********---------------------------------*/
|
|
}
|
|
/*----------------------------------********---------------------------------*/
|
|
}
|
|
|
|
//Workflow
|
|
saveLog('main', 'action', 'checking folder ' . PATH_DB . $workspace);
|
|
|
|
if (is_dir(PATH_DB . $workspace) && file_exists(PATH_DB . $workspace . PATH_SEP . 'db.php')) {
|
|
define('SYS_SYS', $workspace);
|
|
|
|
include_once(PATH_HOME . 'engine' . PATH_SEP . 'config' . PATH_SEP . 'paths_installed.php');
|
|
include_once(PATH_HOME . 'engine' . PATH_SEP . 'config' . PATH_SEP . 'paths.php');
|
|
|
|
//PM Paths DATA
|
|
define('PATH_DATA_SITE', PATH_DATA . 'sites/' . SYS_SYS . '/');
|
|
define('PATH_DOCUMENT', PATH_DATA_SITE . 'files/');
|
|
define('PATH_DATA_MAILTEMPLATES', PATH_DATA_SITE . 'mailTemplates/');
|
|
define('PATH_DATA_PUBLIC', PATH_DATA_SITE . 'public/');
|
|
define('PATH_DATA_REPORTS', PATH_DATA_SITE . 'reports/');
|
|
define('PATH_DYNAFORM', PATH_DATA_SITE . 'xmlForms/');
|
|
define('PATH_IMAGES_ENVIRONMENT_FILES', PATH_DATA_SITE . 'usersFiles' . PATH_SEP);
|
|
define('PATH_IMAGES_ENVIRONMENT_USERS', PATH_DATA_SITE . 'usersPhotographies' . PATH_SEP);
|
|
|
|
if (is_file(PATH_DATA_SITE . PATH_SEP . '.server_info')) {
|
|
$SERVER_INFO = file_get_contents(PATH_DATA_SITE . PATH_SEP . '.server_info');
|
|
$SERVER_INFO = unserialize($SERVER_INFO);
|
|
|
|
define('SERVER_NAME', $SERVER_INFO['SERVER_NAME']);
|
|
define('SERVER_PORT', $SERVER_INFO['SERVER_PORT']);
|
|
} else {
|
|
eprintln('WARNING! No server info found!', 'red');
|
|
}
|
|
|
|
//DB
|
|
$phpCode = '';
|
|
|
|
$fileDb = fopen(PATH_DB . $workspace . PATH_SEP . 'db.php', 'r');
|
|
|
|
if ($fileDb) {
|
|
while (!feof($fileDb)) {
|
|
$buffer = fgets($fileDb, 4096); //Read a line
|
|
|
|
$phpCode .= preg_replace('/define\s*\(\s*[\x22\x27](.*)[\x22\x27]\s*,\s*(\x22.*\x22|\x27.*\x27)\s*\)\s*;/i', '$$1 = $2;', $buffer);
|
|
}
|
|
|
|
fclose($fileDb);
|
|
}
|
|
|
|
$phpCode = str_replace(['<?php', '<?', '?>'], ['', '', ''], $phpCode);
|
|
|
|
eval($phpCode);
|
|
|
|
$dsn = $DB_ADAPTER . '://' . $DB_USER . ':' . $DB_PASS . '@' . $DB_HOST . '/' . $DB_NAME;
|
|
$dsnRbac = $DB_ADAPTER . '://' . $DB_RBAC_USER . ':' . $DB_RBAC_PASS . '@' . $DB_RBAC_HOST . '/' . $DB_RBAC_NAME;
|
|
$dsnRp = $DB_ADAPTER . '://' . $DB_REPORT_USER . ':' . $DB_REPORT_PASS . '@' . $DB_REPORT_HOST . '/' . $DB_REPORT_NAME;
|
|
|
|
switch ($DB_ADAPTER) {
|
|
case 'mysql':
|
|
$dsn .= '?encoding=utf8';
|
|
$dsnRbac .= '?encoding=utf8';
|
|
break;
|
|
case 'mssql':
|
|
//$dsn .= '?sendStringAsUnicode=false';
|
|
//$dsnRbac .= '?sendStringAsUnicode=false';
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
$pro = [];
|
|
$pro['datasources']['workflow']['connection'] = $dsn;
|
|
$pro['datasources']['workflow']['adapter'] = $DB_ADAPTER;
|
|
$pro['datasources']['rbac']['connection'] = $dsnRbac;
|
|
$pro['datasources']['rbac']['adapter'] = $DB_ADAPTER;
|
|
$pro['datasources']['rp']['connection'] = $dsnRp;
|
|
$pro['datasources']['rp']['adapter'] = $DB_ADAPTER;
|
|
//$pro['datasources']['dbarray']['connection'] = 'dbarray://user:pass@localhost/pm_os';
|
|
//$pro['datasources']['dbarray']['adapter'] = 'dbarray';
|
|
|
|
$oFile = fopen(PATH_CORE . 'config' . PATH_SEP . '_databases_.php', 'w');
|
|
fwrite($oFile, '<?php global $pro; return $pro; ?>');
|
|
fclose($oFile);
|
|
|
|
Propel::init(PATH_CORE . 'config' . PATH_SEP . '_databases_.php');
|
|
//Creole::registerDriver('dbarray', 'creole.contrib.DBArrayConnection');
|
|
|
|
//Enable RBAC
|
|
$rbac = &RBAC::getSingleton(PATH_DATA, session_id());
|
|
$rbac->sSystem = 'PROCESSMAKER';
|
|
|
|
if (!defined('DB_ADAPTER')) {
|
|
define('DB_ADAPTER', $DB_ADAPTER);
|
|
}
|
|
|
|
eprintln('Processing workspace: ' . $workspace, 'green');
|
|
|
|
try {
|
|
switch ($cronName) {
|
|
case 'cron':
|
|
processWorkspace();
|
|
break;
|
|
case 'ldapcron':
|
|
require_once(PATH_HOME . 'engine' . PATH_SEP . 'classes' . PATH_SEP . 'class.ldapAdvanced.php');
|
|
require_once(PATH_HOME . 'engine' . PATH_SEP . 'methods' . PATH_SEP . 'services' . PATH_SEP . 'ldapadvanced.php');
|
|
|
|
$ldapadvancedClassCron = new ldapadvancedClassCron();
|
|
|
|
$ldapadvancedClassCron->executeCron(in_array('+debug', $argv));
|
|
break;
|
|
case 'messageeventcron':
|
|
$messageApplication = new \ProcessMaker\BusinessModel\MessageApplication();
|
|
|
|
$messageApplication->catchMessageEvent(true);
|
|
break;
|
|
case 'timereventcron':
|
|
$timerEvent = new \ProcessMaker\BusinessModel\TimerEvent();
|
|
|
|
$timerEvent->startContinueCaseByTimerEvent(date('Y-m-d H:i:s'), true);
|
|
break;
|
|
}
|
|
} catch (Exception $e) {
|
|
echo $e->getMessage() . "\n";
|
|
|
|
eprintln('Problem in workspace: ' . $workspace . ' it was omitted.', 'red');
|
|
}
|
|
|
|
eprintln();
|
|
}
|
|
|
|
if (file_exists(PATH_CORE . 'config' . PATH_SEP . '_databases_.php')) {
|
|
unlink(PATH_CORE . 'config' . PATH_SEP . '_databases_.php');
|
|
}
|
|
} catch (Exception $e) {
|
|
echo $e->getMessage() . "\n";
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
//Functions
|
|
function processWorkspace()
|
|
{
|
|
try {
|
|
Bootstrap::LoadClass("plugin");
|
|
$oPluginRegistry =& PMPluginRegistry::getSingleton();
|
|
if (file_exists(PATH_DATA_SITE . 'plugin.singleton')) {
|
|
$oPluginRegistry->unSerializeInstance(file_get_contents(PATH_DATA_SITE . 'plugin.singleton'));
|
|
}
|
|
Bootstrap::LoadClass("case");
|
|
|
|
global $sObject;
|
|
global $sLastExecution;
|
|
|
|
resendEmails();
|
|
unpauseApplications();
|
|
calculateDuration();
|
|
/*----------------------------------********---------------------------------*/
|
|
calculateAppDuration();
|
|
/*----------------------------------********---------------------------------*/
|
|
executeEvents($sLastExecution);
|
|
executeScheduledCases();
|
|
executeUpdateAppTitle();
|
|
executeCaseSelfService();
|
|
executePlugins();
|
|
/*----------------------------------********---------------------------------*/
|
|
fillReportByUser();
|
|
fillReportByProcess();
|
|
synchronizeDrive();
|
|
/*----------------------------------********---------------------------------*/
|
|
} catch (Exception $oError) {
|
|
saveLog("main", "error", "Error processing workspace : " . $oError->getMessage() . "\n");
|
|
}
|
|
}
|
|
|
|
function resendEmails()
|
|
{
|
|
global $argvx;
|
|
global $sNow;
|
|
global $dateSystem;
|
|
|
|
if ($argvx != "" && strpos($argvx, "emails") === false) {
|
|
return false;
|
|
}
|
|
|
|
setExecutionMessage("Resending emails");
|
|
|
|
try {
|
|
G::LoadClass("spool");
|
|
|
|
$dateResend = $sNow;
|
|
|
|
if ($sNow == $dateSystem) {
|
|
$arrayDateSystem = getdate(strtotime($dateSystem));
|
|
|
|
$mktDateSystem = mktime(
|
|
$arrayDateSystem["hours"],
|
|
$arrayDateSystem["minutes"],
|
|
$arrayDateSystem["seconds"],
|
|
$arrayDateSystem["mon"],
|
|
$arrayDateSystem["mday"],
|
|
$arrayDateSystem["year"]
|
|
);
|
|
|
|
$dateResend = date("Y-m-d H:i:s", $mktDateSystem - (7 * 24 * 60 * 60));
|
|
}
|
|
|
|
$oSpool = new spoolRun();
|
|
$oSpool->resendEmails($dateResend, 1);
|
|
|
|
saveLog("resendEmails", "action", "Resending Emails", "c");
|
|
|
|
$aSpoolWarnings = $oSpool->getWarnings();
|
|
|
|
if ($aSpoolWarnings !== false) {
|
|
foreach ($aSpoolWarnings as $sWarning) {
|
|
print("MAIL SPOOL WARNING: " . $sWarning."\n");
|
|
saveLog("resendEmails", "warning", "MAIL SPOOL WARNING: " . $sWarning);
|
|
}
|
|
}
|
|
|
|
setExecutionResultMessage("DONE");
|
|
} catch (Exception $e) {
|
|
$c = new Criteria("workflow");
|
|
$c->clearSelectColumns();
|
|
$c->addSelectColumn(ConfigurationPeer::CFG_UID);
|
|
$c->add(ConfigurationPeer::CFG_UID, "Emails");
|
|
$result = ConfigurationPeer::doSelectRS($c);
|
|
$result->setFetchmode(ResultSet::FETCHMODE_ASSOC);
|
|
if($result->next()) {
|
|
setExecutionResultMessage("WARNING", "warning");
|
|
$message = "Emails won't be sent, but the cron will continue its execution";
|
|
eprintln(" '-" . $message, "yellow");
|
|
} else {
|
|
setExecutionResultMessage("WITH ERRORS", "error");
|
|
eprintln(" '-" . $e->getMessage(), "red");
|
|
}
|
|
|
|
saveLog("resendEmails", "error", "Error Resending Emails: " . $e->getMessage());
|
|
}
|
|
}
|
|
|
|
function unpauseApplications()
|
|
{
|
|
global $argvx;
|
|
global $sNow;
|
|
|
|
if ($argvx != "" && strpos($argvx, "unpause") === false) {
|
|
return false;
|
|
}
|
|
|
|
setExecutionMessage("Unpausing applications");
|
|
|
|
try {
|
|
G::LoadClass('case');
|
|
|
|
$oCases = new Cases();
|
|
$oCases->ThrowUnpauseDaemon($sNow, 1);
|
|
|
|
setExecutionResultMessage('DONE');
|
|
saveLog('unpauseApplications', 'action', 'Unpausing Applications');
|
|
} catch (Exception $oError) {
|
|
setExecutionResultMessage('WITH ERRORS', 'error');
|
|
eprintln(" '-".$oError->getMessage(), 'red');
|
|
saveLog('unpauseApplications', 'error', 'Error Unpausing Applications: ' . $oError->getMessage());
|
|
}
|
|
}
|
|
|
|
function executePlugins()
|
|
{
|
|
global $argvx;
|
|
|
|
if ($argvx != "" && strpos($argvx, "plugins") === false) {
|
|
return false;
|
|
}
|
|
|
|
$pathCronPlugins = PATH_CORE . 'bin' . PATH_SEP . 'plugins' . PATH_SEP;
|
|
|
|
// Executing cron files in bin/plugins directory
|
|
if (!is_dir($pathCronPlugins)) {
|
|
return false;
|
|
}
|
|
|
|
if ($handle = opendir($pathCronPlugins)) {
|
|
setExecutionMessage('Executing cron files in bin/plugins directory in Workspace: ' . SYS_SYS);
|
|
while (false !== ($file = readdir($handle))) {
|
|
if (strpos($file, '.php',1) && is_file($pathCronPlugins . $file)) {
|
|
$filename = str_replace('.php' , '', $file);
|
|
$className = $filename . 'ClassCron';
|
|
|
|
// Execute custom cron function
|
|
executeCustomCronFunction($pathCronPlugins . $file, $className);
|
|
}
|
|
}
|
|
}
|
|
|
|
// Executing registered cron files
|
|
|
|
// -> Get registered cron files
|
|
$oPluginRegistry =& PMPluginRegistry::getSingleton();
|
|
$cronFiles = $oPluginRegistry->getCronFiles();
|
|
|
|
// -> Execute functions
|
|
if (!empty($cronFiles)) {
|
|
setExecutionMessage('Executing registered cron files for Workspace: ' . SYS_SYS);
|
|
foreach($cronFiles as $cronFile) {
|
|
executeCustomCronFunction(PATH_PLUGINS . $cronFile->namespace . PATH_SEP . 'bin' . PATH_SEP . $cronFile->cronFile . '.php', $cronFile->cronFile);
|
|
}
|
|
}
|
|
|
|
}
|
|
function executeCustomCronFunction($pathFile, $className)
|
|
{
|
|
include_once $pathFile;
|
|
|
|
$oPlugin = new $className();
|
|
|
|
if (method_exists($oPlugin, 'executeCron')) {
|
|
$arrayCron = unserialize(trim(@file_get_contents(PATH_DATA . "cron")));
|
|
$arrayCron["processcTimeProcess"] = 60; //Minutes
|
|
$arrayCron["processcTimeStart"] = time();
|
|
@file_put_contents(PATH_DATA . "cron", serialize($arrayCron));
|
|
|
|
//Try to execute Plugin Cron. If there is an error then continue with the next file
|
|
setExecutionMessage("\n--- Executing cron file: $pathFile");
|
|
try {
|
|
$oPlugin->executeCron();
|
|
setExecutionResultMessage('DONE');
|
|
} catch (Exception $e) {
|
|
setExecutionResultMessage('FAILED', 'error');
|
|
eprintln(" '-".$e->getMessage(), 'red');
|
|
saveLog('executePlugins', 'error', 'Error executing cron file: ' . $pathFile . ' - ' . $e->getMessage());
|
|
}
|
|
}
|
|
}
|
|
|
|
function calculateDuration()
|
|
{
|
|
global $argvx;
|
|
|
|
if ($argvx != "" && strpos($argvx, "calculate") === false) {
|
|
return false;
|
|
}
|
|
|
|
setExecutionMessage("Calculating Duration");
|
|
|
|
try {
|
|
$oAppDelegation = new AppDelegation();
|
|
$oAppDelegation->calculateDuration(1);
|
|
|
|
setExecutionResultMessage('DONE');
|
|
saveLog('calculateDuration', 'action', 'Calculating Duration');
|
|
} catch (Exception $oError) {
|
|
setExecutionResultMessage('WITH ERRORS', 'error');
|
|
eprintln(" '-".$oError->getMessage(), 'red');
|
|
saveLog('calculateDuration', 'error', 'Error Calculating Duration: ' . $oError->getMessage());
|
|
}
|
|
}
|
|
|
|
/*----------------------------------********---------------------------------*/
|
|
function calculateAppDuration()
|
|
{
|
|
global $argvx;
|
|
|
|
if ($argvx != "" && strpos($argvx, "calculateapp") === false) {
|
|
return false;
|
|
}
|
|
|
|
setExecutionMessage("Calculating Duration by Application");
|
|
|
|
try {
|
|
$oApplication = new Application();
|
|
$oApplication->calculateAppDuration(1);
|
|
|
|
setExecutionResultMessage('DONE');
|
|
saveLog('calculateDurationByApp', 'action', 'Calculating Duration by Application');
|
|
} catch (Exception $oError) {
|
|
setExecutionResultMessage('WITH ERRORS', 'error');
|
|
eprintln(" '-".$oError->getMessage(), 'red');
|
|
saveLog('calculateDurationByApp', 'error', 'Error Calculating Duration: ' . $oError->getMessage());
|
|
}
|
|
}
|
|
/*----------------------------------********---------------------------------*/
|
|
|
|
function executeEvents($sLastExecution, $sNow=null)
|
|
{
|
|
global $argvx;
|
|
global $sNow;
|
|
|
|
$log = array();
|
|
|
|
if ($argvx != "" && strpos($argvx, "events") === false) {
|
|
return false;
|
|
}
|
|
|
|
setExecutionMessage("Executing events");
|
|
setExecutionResultMessage('PROCESSING');
|
|
|
|
try {
|
|
$oAppEvent = new AppEvent();
|
|
saveLog('executeEvents', 'action', "Executing Events $sLastExecution, $sNow ");
|
|
$n = $oAppEvent->executeEvents($sNow, false, $log, 1);
|
|
|
|
foreach ($log as $value) {
|
|
$arrayCron = unserialize(trim(@file_get_contents(PATH_DATA . "cron")));
|
|
$arrayCron["processcTimeStart"] = time();
|
|
@file_put_contents(PATH_DATA . "cron", serialize($arrayCron));
|
|
|
|
saveLog('executeEvents', 'action', "Execute Events : $value, $sNow ");
|
|
}
|
|
|
|
setExecutionMessage("|- End Execution events");
|
|
setExecutionResultMessage("Processed $n");
|
|
//saveLog('executeEvents', 'action', $res );
|
|
} catch (Exception $oError) {
|
|
setExecutionResultMessage('WITH ERRORS', 'error');
|
|
eprintln(" '-".$oError->getMessage(), 'red');
|
|
saveLog('calculateAlertsDueDate', 'Error', 'Error Executing Events: ' . $oError->getMessage());
|
|
}
|
|
}
|
|
|
|
function executeScheduledCases($sNow=null)
|
|
{
|
|
try {
|
|
global $argvx;
|
|
global $sNow;
|
|
|
|
$log = array();
|
|
|
|
if ($argvx != "" && strpos($argvx, "scheduler") === false) {
|
|
return false;
|
|
}
|
|
|
|
setExecutionMessage("Executing the scheduled starting cases");
|
|
setExecutionResultMessage('PROCESSING');
|
|
|
|
$sNow = isset($sNow)? $sNow : date('Y-m-d H:i:s');
|
|
|
|
$oCaseScheduler = new CaseScheduler();
|
|
$oCaseScheduler->caseSchedulerCron($sNow, $log, 1);
|
|
|
|
foreach ($log as $value) {
|
|
$arrayCron = unserialize(trim(@file_get_contents(PATH_DATA . "cron")));
|
|
$arrayCron["processcTimeStart"] = time();
|
|
@file_put_contents(PATH_DATA . "cron", serialize($arrayCron));
|
|
|
|
saveLog('executeScheduledCases', 'action', "OK Case# $value");
|
|
}
|
|
|
|
setExecutionResultMessage('DONE');
|
|
} catch (Exception $oError) {
|
|
setExecutionResultMessage('WITH ERRORS', 'error');
|
|
eprintln(" '-".$oError->getMessage(), 'red');
|
|
}
|
|
}
|
|
|
|
function executeUpdateAppTitle()
|
|
{
|
|
try {
|
|
global $argvx;
|
|
|
|
if ($argvx != "" && strpos($argvx, "update-case-labels") === false) {
|
|
return false;
|
|
}
|
|
|
|
$criteriaConf = new Criteria("workflow");
|
|
|
|
$criteriaConf->addSelectColumn(ConfigurationPeer::OBJ_UID);
|
|
$criteriaConf->addSelectColumn(ConfigurationPeer::CFG_VALUE);
|
|
$criteriaConf->add(ConfigurationPeer::CFG_UID, "TAS_APP_TITLE_UPDATE");
|
|
|
|
$rsCriteriaConf = ConfigurationPeer::doSelectRS($criteriaConf);
|
|
$rsCriteriaConf->setFetchmode(ResultSet::FETCHMODE_ASSOC);
|
|
|
|
setExecutionMessage("Update case labels");
|
|
saveLog("updateCaseLabels", "action", "Update case labels", "c");
|
|
|
|
while ($rsCriteriaConf->next()) {
|
|
$row = $rsCriteriaConf->getRow();
|
|
|
|
$taskUid = $row["OBJ_UID"];
|
|
$lang = $row["CFG_VALUE"];
|
|
|
|
//Update case labels
|
|
$appcv = new AppCacheView();
|
|
$appcv->appTitleByTaskCaseLabelUpdate($taskUid, $lang, 1);
|
|
|
|
//Delete record
|
|
$criteria = new Criteria("workflow");
|
|
|
|
$criteria->add(ConfigurationPeer::CFG_UID, "TAS_APP_TITLE_UPDATE");
|
|
$criteria->add(ConfigurationPeer::OBJ_UID, $taskUid);
|
|
$criteria->add(ConfigurationPeer::CFG_VALUE, $lang);
|
|
|
|
$numRowDeleted = ConfigurationPeer::doDelete($criteria);
|
|
|
|
saveLog("updateCaseLabels", "action", "OK Task $taskUid");
|
|
}
|
|
|
|
setExecutionResultMessage("DONE");
|
|
} catch (Exception $e) {
|
|
setExecutionResultMessage("WITH ERRORS", "error");
|
|
eprintln(" '-" . $e->getMessage(), "red");
|
|
saveLog("updateCaseLabels", "error", "Error updating case labels: " . $e->getMessage());
|
|
}
|
|
}
|
|
|
|
function executeCaseSelfService()
|
|
{
|
|
try {
|
|
global $argvx;
|
|
|
|
if ($argvx != "" && strpos($argvx, "unassigned-case") === false) {
|
|
return false;
|
|
}
|
|
|
|
$criteria = new Criteria("workflow");
|
|
|
|
//SELECT
|
|
$criteria->addSelectColumn(AppCacheViewPeer::APP_UID);
|
|
$criteria->addSelectColumn(AppCacheViewPeer::DEL_INDEX);
|
|
$criteria->addSelectColumn(AppCacheViewPeer::DEL_DELEGATE_DATE);
|
|
$criteria->addSelectColumn(AppCacheViewPeer::APP_NUMBER);
|
|
$criteria->addSelectColumn(AppCacheViewPeer::PRO_UID);
|
|
$criteria->addSelectColumn(TaskPeer::TAS_UID);
|
|
$criteria->addSelectColumn(TaskPeer::TAS_SELFSERVICE_TIME);
|
|
$criteria->addSelectColumn(TaskPeer::TAS_SELFSERVICE_TIME_UNIT);
|
|
$criteria->addSelectColumn(TaskPeer::TAS_SELFSERVICE_TRIGGER_UID);
|
|
/*----------------------------------********---------------------------------*/
|
|
$criteria->addSelectColumn(TaskPeer::TAS_SELFSERVICE_EXECUTION);
|
|
/*----------------------------------********---------------------------------*/
|
|
|
|
//FROM
|
|
$condition = array();
|
|
$condition[] = array(AppCacheViewPeer::TAS_UID, TaskPeer::TAS_UID);
|
|
$condition[] = array(TaskPeer::TAS_SELFSERVICE_TIMEOUT, 1);
|
|
$criteria->addJoinMC($condition, Criteria::LEFT_JOIN);
|
|
|
|
//WHERE
|
|
$criteria->add(AppCacheViewPeer::USR_UID, "");
|
|
$criteria->add(AppCacheViewPeer::DEL_THREAD_STATUS, "OPEN");
|
|
|
|
//QUERY
|
|
$rsCriteria = AppCacheViewPeer::doSelectRS($criteria);
|
|
$rsCriteria->setFetchmode(ResultSet::FETCHMODE_ASSOC);
|
|
|
|
setExecutionMessage("Unassigned case");
|
|
saveLog("unassignedCase", "action", "Unassigned case", "c");
|
|
|
|
$calendar = new calendar();
|
|
|
|
while ($rsCriteria->next()) {
|
|
|
|
$row = $rsCriteria->getRow();
|
|
$flag = false;
|
|
|
|
$appcacheAppUid = $row["APP_UID"];
|
|
$appcacheDelIndex = $row["DEL_INDEX"];
|
|
$appcacheDelDelegateDate = $row["DEL_DELEGATE_DATE"];
|
|
$appcacheAppNumber = $row["APP_NUMBER"];
|
|
$appcacheProUid = $row["PRO_UID"];
|
|
$taskUid = $row["TAS_UID"];
|
|
$taskSelfServiceTime = intval($row["TAS_SELFSERVICE_TIME"]);
|
|
$taskSelfServiceTimeUnit = $row["TAS_SELFSERVICE_TIME_UNIT"];
|
|
$taskSelfServiceTriggerUid = $row["TAS_SELFSERVICE_TRIGGER_UID"];
|
|
/*----------------------------------********---------------------------------*/
|
|
$taskSelfServiceJustOneExecution = $row["TAS_SELFSERVICE_EXECUTION"];
|
|
|
|
if($taskSelfServiceJustOneExecution == 'ONCE'){
|
|
$criteriaSelfService = new Criteria("workflow");
|
|
|
|
$criteriaSelfService->add(AppTimeoutActionExecutedPeer::APP_UID, $appcacheAppUid);
|
|
$criteriaSelfService->add(AppTimeoutActionExecutedPeer::DEL_INDEX, $appcacheDelIndex);
|
|
|
|
$querySelfService = AppTimeoutActionExecutedPeer::doSelectRS($criteriaSelfService);
|
|
$querySelfService->setFetchmode(ResultSet::FETCHMODE_ASSOC);
|
|
|
|
if ($querySelfService->next()) {
|
|
$row = $querySelfService->getRow();
|
|
$flag = true; //already executed
|
|
}
|
|
}
|
|
/*----------------------------------********---------------------------------*/
|
|
|
|
if ($calendar->pmCalendarUid == '') {
|
|
$calendar->getCalendar(null, $appcacheProUid, $taskUid);
|
|
$calendar->getCalendarData();
|
|
}
|
|
|
|
$dueDate = $calendar->calculateDate(
|
|
$appcacheDelDelegateDate,
|
|
$taskSelfServiceTime,
|
|
$taskSelfServiceTimeUnit //HOURS|DAYS|MINUTES
|
|
//1
|
|
);
|
|
|
|
if (time() > $dueDate["DUE_DATE_SECONDS"] && $flag == false) {
|
|
$sessProcess = null;
|
|
$sessProcessSw = 0;
|
|
|
|
//Load data
|
|
$case = new Cases();
|
|
$appFields = $case->loadCase($appcacheAppUid);
|
|
|
|
$appFields["APP_DATA"]["APPLICATION"] = $appcacheAppUid;
|
|
|
|
if (isset($_SESSION["PROCESS"])) {
|
|
$sessProcess = $_SESSION["PROCESS"];
|
|
$sessProcessSw = 1;
|
|
}
|
|
|
|
$_SESSION["PROCESS"] = $appFields["PRO_UID"];
|
|
|
|
//Execute trigger
|
|
$criteriaTgr = new Criteria();
|
|
$criteriaTgr->add(TriggersPeer::TRI_UID, $taskSelfServiceTriggerUid);
|
|
|
|
$rsCriteriaTgr = TriggersPeer::doSelectRS($criteriaTgr);
|
|
$rsCriteriaTgr->setFetchmode(ResultSet::FETCHMODE_ASSOC);
|
|
|
|
if ($rsCriteriaTgr->next()) {
|
|
$row = $rsCriteriaTgr->getRow();
|
|
|
|
if (is_array($row) && $row["TRI_TYPE"] == "SCRIPT") {
|
|
|
|
$arrayCron = unserialize(trim(@file_get_contents(PATH_DATA . "cron")));
|
|
$arrayCron["processcTimeProcess"] = 60; //Minutes
|
|
$arrayCron["processcTimeStart"] = time();
|
|
@file_put_contents(PATH_DATA . "cron", serialize($arrayCron));
|
|
|
|
//Trigger
|
|
global $oPMScript;
|
|
|
|
$oPMScript = new PMScript();
|
|
$oPMScript->setFields($appFields["APP_DATA"]);
|
|
$oPMScript->setScript($row["TRI_WEBBOT"]);
|
|
$oPMScript->execute();
|
|
|
|
/*----------------------------------********---------------------------------*/
|
|
//saving the case`s data if the 'Execution' is set in ONCE.
|
|
if($taskSelfServiceJustOneExecution == "ONCE"){
|
|
$oAppTimeoutActionExecuted = new AppTimeoutActionExecuted();
|
|
$dataSelf = array();
|
|
$dataSelf["APP_UID"] = $appcacheAppUid;
|
|
$dataSelf["DEL_INDEX"] = $appcacheDelIndex;
|
|
$dataSelf["EXECUTION_DATE"] = time();
|
|
$oAppTimeoutActionExecuted->create($dataSelf);
|
|
}
|
|
/*----------------------------------********---------------------------------*/
|
|
$appFields["APP_DATA"] = array_merge($appFields["APP_DATA"], $oPMScript->aFields);
|
|
|
|
unset($appFields['APP_STATUS']);
|
|
unset($appFields['APP_PROC_STATUS']);
|
|
unset($appFields['APP_PROC_CODE']);
|
|
unset($appFields['APP_PIN']);
|
|
$case->updateCase($appFields["APP_UID"], $appFields);
|
|
|
|
saveLog("unassignedCase", "action", "OK Executed tigger to the case $appcacheAppNumber");
|
|
}
|
|
}
|
|
|
|
unset($_SESSION["PROCESS"]);
|
|
|
|
if ($sessProcessSw == 1) {
|
|
$_SESSION["PROCESS"] = $sessProcess;
|
|
}
|
|
}
|
|
}
|
|
|
|
setExecutionResultMessage("DONE");
|
|
} catch (Exception $e) {
|
|
setExecutionResultMessage("WITH ERRORS", "error");
|
|
eprintln(" '-" . $e->getMessage(), "red");
|
|
saveLog("unassignedCase", "error", "Error in unassigned case: " . $e->getMessage());
|
|
}
|
|
}
|
|
|
|
function saveLog($sSource, $sType, $sDescription)
|
|
{
|
|
try {
|
|
global $sObject;
|
|
global $isDebug;
|
|
|
|
if ($isDebug) {
|
|
print date("H:i:s") . " ($sSource) $sType $sDescription <br />\n";
|
|
}
|
|
|
|
G::verifyPath(PATH_DATA . "log" . PATH_SEP, true);
|
|
G::log("| $sObject | " . $sSource . " | $sType | " . $sDescription, PATH_DATA);
|
|
} catch (Exception $e) {
|
|
//CONTINUE
|
|
}
|
|
}
|
|
|
|
function setExecutionMessage($m)
|
|
{
|
|
$len = strlen($m);
|
|
$linesize = 60;
|
|
$rOffset = $linesize - $len;
|
|
|
|
eprint("* $m");
|
|
|
|
for ($i = 0; $i < $rOffset; $i++) {
|
|
eprint('.');
|
|
}
|
|
}
|
|
|
|
function setExecutionResultMessage($m, $t='')
|
|
{
|
|
$c = 'green';
|
|
|
|
if ($t == 'error') {
|
|
$c = 'red';
|
|
}
|
|
|
|
if ($t == 'info') {
|
|
$c = 'yellow';
|
|
}
|
|
|
|
if ($t == 'warning') {
|
|
$c = 'yellow';
|
|
}
|
|
|
|
eprintln("[$m]", $c);
|
|
}
|
|
|
|
/*----------------------------------********---------------------------------*/
|
|
function fillReportByUser ()
|
|
{
|
|
try {
|
|
global $argvx;
|
|
global $dateInit;
|
|
global $dateFinish;
|
|
|
|
if (strpos($argvx, "report_by_user") === false) {
|
|
return false;
|
|
}
|
|
if ($dateInit == null) {
|
|
eprintln("You must enter the starting date.", "red");
|
|
eprintln('Example: +init-date"YYYY-MM-DD HH:MM:SS" +finish-date"YYYY-MM-DD HH:MM:SS"', "red");
|
|
return false;
|
|
}
|
|
|
|
$dateFinish = ($dateFinish != null) ? $dateFinish : date("Y-m-d H:i:s");
|
|
|
|
$appcv = new AppCacheView();
|
|
$appcv->setPathToAppCacheFiles( PATH_METHODS . 'setup' . PATH_SEP . 'setupSchemas' . PATH_SEP );
|
|
setExecutionMessage("Calculating data to fill the 'User Reporting'...");
|
|
$appcv->fillReportByUser($dateInit, $dateFinish);
|
|
setExecutionResultMessage("DONE");
|
|
} catch (Exception $e) {
|
|
setExecutionResultMessage("WITH ERRORS", "error");
|
|
eprintln(" '-" . $e->getMessage(), "red");
|
|
saveLog("fillReportByUser", "error", "Error in fill report by user: " . $e->getMessage());
|
|
}
|
|
}
|
|
|
|
function fillReportByProcess ()
|
|
{
|
|
try {
|
|
global $argvx;
|
|
global $dateInit;
|
|
global $dateFinish;
|
|
|
|
if (strpos($argvx, "report_by_process") === false) {
|
|
return false;
|
|
}
|
|
|
|
if ($dateInit == null) {
|
|
eprintln("You must enter the starting date.", "red");
|
|
eprintln('Example: +init-date"YYYY-MM-DD HH:MM:SS" +finish-date"YYYY-MM-DD HH:MM:SS"', "red");
|
|
return false;
|
|
}
|
|
|
|
$dateFinish = ($dateFinish != null) ? $dateFinish : date("Y-m-d H:i:s");
|
|
$appcv = new AppCacheView();
|
|
$appcv->setPathToAppCacheFiles( PATH_METHODS . 'setup' . PATH_SEP . 'setupSchemas' . PATH_SEP );
|
|
|
|
setExecutionMessage("Calculating data to fill the 'Process Reporting'...");
|
|
$appcv->fillReportByProcess($dateInit, $dateFinish);
|
|
setExecutionResultMessage("DONE");
|
|
} catch (Exception $e) {
|
|
setExecutionResultMessage("WITH ERRORS", "error");
|
|
eprintln(" '-" . $e->getMessage(), "red");
|
|
saveLog("fillReportByProcess", "error", "Error in fill report by process: " . $e->getMessage());
|
|
}
|
|
}
|
|
|
|
function synchronizeDrive ()
|
|
{
|
|
try
|
|
{
|
|
global $argvx;
|
|
|
|
if (strpos($argvx, "synchronize-documents-drive") === false) {
|
|
return false;
|
|
}
|
|
|
|
setExecutionMessage("Synchronize documents to drive");
|
|
G::LoadClass('AppDocumentDrive');
|
|
$drive = new AppDocumentDrive();
|
|
$drive->synchronizeDrive(true);
|
|
setExecutionResultMessage("DONE");
|
|
|
|
} catch (Exception $e) {
|
|
setExecutionResultMessage("WITH ERRORS", "error");
|
|
eprintln(" '-" . $e->getMessage(), "red");
|
|
saveLog("synchronizeDocumentsDrive", "error", "Error in synchronize documents to drive: " . $e->getMessage());
|
|
}
|
|
}
|
|
|
|
/*----------------------------------********---------------------------------*/
|
|
|