981cf36986
Issue:
Mejora del calculo de creacion de casos en el case scheduler para la configuracion diaria
Cause:
Procesos con fechas antiguas en "Time next run" no son actualizados, y por consiguiente
no son creados los casos con el cron
Solution:
- Se hizo refactor del CaseScheduler para el calculo del "Time next run" en los modulos create/update y cron
- Este cambio se aplica a procesos ".pm"
931 lines
40 KiB
PHP
Executable File
931 lines
40 KiB
PHP
Executable File
<?php
|
|
/**
|
|
* CaseScheduler.php
|
|
*
|
|
* @package workflow.engine.classes.model
|
|
*/
|
|
|
|
//require_once 'classes/model/om/BaseCaseScheduler.php';
|
|
|
|
//require_once 'classes/model/Process.php';
|
|
//require_once 'classes/model/Task.php';
|
|
|
|
/**
|
|
* Skeleton subclass for representing a row from the 'CASE_SCHEDULER' table.
|
|
*
|
|
*
|
|
*
|
|
* You should add additional methods to this class to meet the
|
|
* application requirements. This class will only be generated as
|
|
* long as it does not already exist in the output directory.
|
|
*
|
|
* @package workflow.engine.classes.model
|
|
*/
|
|
class CaseScheduler extends BaseCaseScheduler
|
|
{
|
|
public function load ($SchUid)
|
|
{
|
|
try {
|
|
$oRow = CaseSchedulerPeer::retrieveByPK( $SchUid );
|
|
if (! is_null( $oRow )) {
|
|
$aFields = $oRow->toArray( BasePeer::TYPE_FIELDNAME );
|
|
$this->fromArray( $aFields, BasePeer::TYPE_FIELDNAME );
|
|
$this->setNew( false );
|
|
return $aFields;
|
|
} else {
|
|
throw (new Exception( "The row '" . $SchUid . "' in table CASE_SCHEDULER doesn't exist!" ));
|
|
}
|
|
} catch (Exception $oError) {
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
public function create ($aData)
|
|
{
|
|
$con = Propel::getConnection( CaseSchedulerPeer::DATABASE_NAME );
|
|
try {
|
|
$this->fromArray( $aData, BasePeer::TYPE_FIELDNAME );
|
|
if ($this->validate()) {
|
|
$result = $this->save();
|
|
} else {
|
|
$e = new Exception( "Failed Validation in class " . get_class( $this ) . "." );
|
|
$e->aValidationFailures = $this->getValidationFailures();
|
|
throw ($e);
|
|
}
|
|
$con->commit();
|
|
|
|
//Add Audit Log
|
|
$perform = $aData["SCH_OPTION"];
|
|
|
|
switch ($aData['SCH_OPTION']) {
|
|
case '1':
|
|
$perform = 'Daily';
|
|
break;
|
|
case '2':
|
|
$perform = 'Weekly';
|
|
break;
|
|
case '3':
|
|
$perform = 'Monthly';
|
|
break;
|
|
case '4':
|
|
$perform = 'One time only';
|
|
break;
|
|
case '5':
|
|
$perform = 'Every';
|
|
break;
|
|
|
|
}
|
|
G::auditLog("CreateCaseScheduler", "Scheduler Name: ".$aData['SCH_NAME'].", Task: ".$aData['TAS_UID'].", Perform this task: ".$perform.", Start Date: ".$aData['SCH_START_DATE'].", End Date: ".$aData['SCH_END_DATE'].", Execution time : ".$aData['SCH_START_TIME']);
|
|
|
|
return $result;
|
|
} catch (Exception $e) {
|
|
$con->rollback();
|
|
throw ($e);
|
|
}
|
|
}
|
|
|
|
public function update ($fields)
|
|
{
|
|
$con = Propel::getConnection( CaseSchedulerPeer::DATABASE_NAME );
|
|
try {
|
|
$con->begin();
|
|
$this->load( $fields['SCH_UID'] );
|
|
$this->fromArray( $fields, BasePeer::TYPE_FIELDNAME );
|
|
if ($this->validate()) {
|
|
$result = $this->save();
|
|
$con->commit();
|
|
|
|
if (isset($fields['SCH_OPTION'])) {
|
|
//Add Audit Log
|
|
switch ($fields['SCH_OPTION']){
|
|
case '1':
|
|
$perform = 'Daily';
|
|
break;
|
|
case '2':
|
|
$perform = 'Weekly';
|
|
break;
|
|
case '3':
|
|
$perform = 'Monthly';
|
|
break;
|
|
case '4':
|
|
$perform = 'One time only';
|
|
break;
|
|
case '5':
|
|
$perform = 'Every';
|
|
break;
|
|
}
|
|
G::auditLog("UpdateCaseScheduler", "Scheduler Name: ".$fields['SCH_NAME'].", Task: ".$fields['TAS_UID'].", Perform this task: ".$perform.", Start Date: ".$fields['SCH_START_DATE'].", End Date: ".$fields['SCH_END_DATE'].", Execution time : ".$fields['SCH_START_TIME']);
|
|
}
|
|
|
|
return $result;
|
|
} else {
|
|
$con->rollback();
|
|
throw (new Exception( "Failed Validation in class " . get_class( $this ) . "." ));
|
|
}
|
|
} catch (Exception $e) {
|
|
$con->rollback();
|
|
throw ($e);
|
|
}
|
|
}
|
|
|
|
public function remove ($SchUid)
|
|
{
|
|
$con = Propel::getConnection( CaseSchedulerPeer::DATABASE_NAME );
|
|
try {
|
|
$oCaseScheduler = CaseSchedulerPeer::retrieveByPK( $SchUid );
|
|
if (! is_null( $oCaseScheduler )) {
|
|
$fields = $this->Load( $SchUid );
|
|
$iResult = $oCaseScheduler->delete();
|
|
$con->commit();
|
|
//Add Audit Log
|
|
G::auditLog("DeleteCaseScheduler", "Scheduler Name: ".$fields['SCH_NAME'].", Task: ".$fields['TAS_UID']);
|
|
|
|
return $iResult;
|
|
} else {
|
|
throw (new Exception( 'This row doesn\'t exist!' ));
|
|
}
|
|
} catch (Exception $e) {
|
|
$con->rollback();
|
|
throw ($e);
|
|
}
|
|
}
|
|
|
|
/*
|
|
* change Status of any Process
|
|
* @param string $sSchedulerUid
|
|
* @return boolean
|
|
*/
|
|
public function changeStatus ($sSchedulerUid = '')
|
|
{
|
|
$Fields = $this->Load( $sSchedulerUid );
|
|
$Fields['SCH_LAST_STATE'] = $Fields['SCH_STATE'];
|
|
if ($Fields['SCH_STATE'] == 'ACTIVE') {
|
|
$Fields['SCH_STATE'] = 'INACTIVE';
|
|
} else {
|
|
$Fields['SCH_STATE'] = 'ACTIVE';
|
|
}
|
|
$this->Update( $Fields );
|
|
}
|
|
|
|
public function getAllCriteria ()
|
|
{
|
|
$c = new Criteria( 'workflow' );
|
|
$c->clearSelectColumns();
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_UID );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_NAME );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_DEL_USER_NAME );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_DEL_USER_PASS );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_DEL_USER_UID );
|
|
$c->addSelectColumn( CaseSchedulerPeer::PRO_UID );
|
|
$c->addSelectColumn( CaseSchedulerPeer::TAS_UID );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_TIME_NEXT_RUN );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_LAST_RUN_TIME );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_STATE );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_LAST_STATE );
|
|
$c->addSelectColumn( CaseSchedulerPeer::USR_UID );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_OPTION );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_START_TIME );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_START_DATE );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_DAYS_PERFORM_TASK );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_EVERY_DAYS );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_WEEK_DAYS );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_START_DAY );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_MONTHS );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_END_DATE );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_REPEAT_EVERY );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_REPEAT_UNTIL );
|
|
$c->addSelectColumn( CaseSchedulerPeer::SCH_REPEAT_STOP_IF_RUNNING );
|
|
$c->addSelectColumn( CaseSchedulerPeer::CASE_SH_PLUGIN_UID );
|
|
|
|
return $c;
|
|
}
|
|
|
|
public function getAll ()
|
|
{
|
|
$oCriteria = $this->getAllCriteria();
|
|
$oDataset = CaseSchedulerPeer::doSelectRS( $oCriteria );
|
|
|
|
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
|
|
$oDataset->next();
|
|
$aRows = Array ();
|
|
while ($aRow = $oDataset->getRow()) {
|
|
$aRows[] = $aRow;
|
|
$oDataset->next();
|
|
}
|
|
foreach ($aRows as $k => $aRow) {
|
|
$oProcess = new Process();
|
|
$aProcessRow = $oProcess->load( $aRow['PRO_UID'] );
|
|
|
|
$oTask = new Task();
|
|
$aTaskRow = $oTask->load( $aRow['TAS_UID'] );
|
|
|
|
$aRows[$k] = array_merge( $aRow, $aProcessRow, $aTaskRow );
|
|
}
|
|
|
|
return $aRows;
|
|
}
|
|
|
|
/**
|
|
* function getAllByProcess
|
|
* Get All Scheduled Tasks for some process.
|
|
*
|
|
* @author gustavo cruz
|
|
* @param $pro_uid process uid
|
|
* @return $aRows a result set array
|
|
*/
|
|
public function getAllByProcess ($pro_uid)
|
|
{
|
|
|
|
$oCriteria = $this->getAllCriteria();
|
|
$oCriteria->add( CaseSchedulerPeer::PRO_UID, $pro_uid );
|
|
$oDataset = CaseSchedulerPeer::doSelectRS( $oCriteria );
|
|
|
|
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
|
|
$oDataset->next();
|
|
$aRows = Array ();
|
|
while ($aRow = $oDataset->getRow()) {
|
|
$aRows[] = $aRow;
|
|
$oDataset->next();
|
|
}
|
|
foreach ($aRows as $k => $aRow) {
|
|
$oProcess = new Process();
|
|
$aProcessRow = $oProcess->load( $aRow['PRO_UID'] );
|
|
$oTask = new Task();
|
|
$aTaskRow = $oTask->load( $aRow['TAS_UID'] );
|
|
$aRows[$k] = array_merge( $aRow, $aProcessRow, $aTaskRow );
|
|
}
|
|
return $aRows;
|
|
}
|
|
|
|
public function getProcessDescription ()
|
|
{
|
|
$c = new Criteria( 'workflow' );
|
|
$c->clearSelectColumns();
|
|
$c->addSelectColumn( ProcessPeer::PRO_UID );
|
|
|
|
$oDataset = ProcessPeer::doSelectRS( $c );
|
|
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
|
|
$oDataset->next();
|
|
$aRows = Array ();
|
|
while ($aRow = $oDataset->getRow()) {
|
|
$aRows[] = $aRow;
|
|
$oDataset->next();
|
|
}
|
|
|
|
foreach ($aRows as $k => $aRow) {
|
|
$oProcess = new Process();
|
|
$aProcessRow = $oProcess->load( $aRow['PRO_UID'] );
|
|
|
|
$aRows[$k] = array_merge( $aRow, array ('PRO_TITLE' => $aProcessRow['PRO_TITLE']
|
|
) );
|
|
}
|
|
return $aRows;
|
|
|
|
}
|
|
|
|
public function getTaskDescription ()
|
|
{
|
|
$c = new Criteria( 'workflow' );
|
|
$c->clearSelectColumns();
|
|
$c->addSelectColumn( TaskPeer::TAS_UID );
|
|
|
|
$oDataset = TaskPeer::doSelectRS( $c );
|
|
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
|
|
$oDataset->next();
|
|
$aRows = Array ();
|
|
while ($aRow = $oDataset->getRow()) {
|
|
$aRows[] = $aRow;
|
|
$oDataset->next();
|
|
}
|
|
foreach ($aRows as $k => $aRow) {
|
|
|
|
$oTask = new Task();
|
|
$aTaskRow = $oTask->load( $aRow['TAS_UID'] );
|
|
|
|
$aRows[$k] = array_merge( $aRow, array ('TAS_TITLE' => $aTaskRow['TAS_TITLE']
|
|
), array ('PRO_UID' => $aTaskRow['PRO_UID']
|
|
) );
|
|
}
|
|
return $aRows;
|
|
}
|
|
|
|
public function caseSchedulerCron ($date, &$log = array(), $cron = 0)
|
|
{
|
|
try {
|
|
require_once("classes" . PATH_SEP . "model" . PATH_SEP . "LogCasesScheduler.php");
|
|
|
|
//Set variables
|
|
$port = "";
|
|
|
|
if (isset($_SERVER["SERVER_PORT"])) {
|
|
$port = ($_SERVER["SERVER_PORT"] . "" != "80")? ":" . $_SERVER["SERVER_PORT"] : "";
|
|
} else {
|
|
if (defined("SERVER_PORT")) {
|
|
$port = (SERVER_PORT . "" != "80")? ":" . SERVER_PORT : "";
|
|
}
|
|
}
|
|
|
|
$wsdl = "http://" . SERVER_NAME . $port . "/sys" . SYS_SYS . "/" . SYS_LANG . "/classic/services/wsdl2";
|
|
|
|
$timeDate = strtotime($date);
|
|
|
|
$dateHour = (int)(date("H", $timeDate));
|
|
$dateMinutes = (int)(date("i", $timeDate));
|
|
|
|
$dateCurrentIni = date("Y-m-d", $timeDate) . " 00:00:00";
|
|
$dateCurrentEnd = date("Y-m-d", $timeDate) . " 23:59:59";
|
|
|
|
//Query
|
|
$criteria = $this->getAllCriteria();
|
|
|
|
$criteria->add(
|
|
$criteria->getNewCriterion(CaseSchedulerPeer::SCH_STATE, "INACTIVE", Criteria::NOT_EQUAL)->addAnd(
|
|
$criteria->getNewCriterion(CaseSchedulerPeer::SCH_STATE, "PROCESSED", Criteria::NOT_EQUAL))
|
|
);
|
|
$criteria->add(
|
|
$criteria->getNewCriterion(CaseSchedulerPeer::SCH_TIME_NEXT_RUN, $dateCurrentIni, Criteria::GREATER_EQUAL)->addAnd(
|
|
$criteria->getNewCriterion(CaseSchedulerPeer::SCH_TIME_NEXT_RUN, $dateCurrentEnd, Criteria::LESS_EQUAL))->addOr(
|
|
$criteria->getNewCriterion(CaseSchedulerPeer::SCH_OPTION, 5, Criteria::GREATER_EQUAL))->addOr(
|
|
|
|
$criteria->getNewCriterion(CaseSchedulerPeer::SCH_TIME_NEXT_RUN, $dateCurrentIni, Criteria::LESS_THAN))
|
|
);
|
|
$criteria->add(
|
|
$criteria->getNewCriterion(CaseSchedulerPeer::SCH_END_DATE, null, Criteria::EQUAL)->addOr(
|
|
$criteria->getNewCriterion(CaseSchedulerPeer::SCH_END_DATE, $dateCurrentIni, Criteria::GREATER_EQUAL))
|
|
);
|
|
|
|
$rsCriteria = CaseSchedulerPeer::doSelectRS($criteria);
|
|
$rsCriteria->setFetchmode(ResultSet::FETCHMODE_ASSOC);
|
|
|
|
while ($rsCriteria->next()) {
|
|
$row = $rsCriteria->getRow();
|
|
|
|
if ($cron == 1) {
|
|
$arrayCron = unserialize(trim(@file_get_contents(PATH_DATA . "cron")));
|
|
$arrayCron["processcTimeStart"] = time();
|
|
@file_put_contents(PATH_DATA . "cron", serialize($arrayCron));
|
|
}
|
|
|
|
$caseSchedulerUid = $row["SCH_UID"];
|
|
$caseSchedulerOption = (int)($row["SCH_OPTION"]);
|
|
$caseSchedulerTimeNextRun = $row["SCH_TIME_NEXT_RUN"];
|
|
|
|
//Create the new case
|
|
$flagNewCase = false;
|
|
$caseSchedulerTimeNextRunNew = "";
|
|
|
|
if (strtotime($caseSchedulerTimeNextRun) < strtotime($dateCurrentIni)) {
|
|
//Generate new date for old SCH_TIME_NEXT_RUN
|
|
$flagNewCase = true; //Create the old case
|
|
$caseSchedulerTimeNextRunNew = $this->getTimeNextRunByDate($row, $date, false);
|
|
} else {
|
|
$caseSchedulerTimeNextRunHour = (int)(date("H", strtotime($row["SCH_TIME_NEXT_RUN"])));
|
|
$caseSchedulerTimeNextRunMinutes = (int)(date("i", strtotime($row["SCH_TIME_NEXT_RUN"])));
|
|
|
|
$flagNewCase = ($caseSchedulerTimeNextRunHour == $dateHour && $caseSchedulerTimeNextRunMinutes <= $dateMinutes) || $caseSchedulerTimeNextRunHour < $dateHour;
|
|
}
|
|
|
|
if ($flagNewCase) {
|
|
println(" - Connecting webservice: $wsdl");
|
|
|
|
$user = $row["SCH_DEL_USER_NAME"];
|
|
$pass = $row["SCH_DEL_USER_PASS"];
|
|
$processId = $row["PRO_UID"];
|
|
$taskId = $row["TAS_UID"];
|
|
|
|
$client = new SoapClient($wsdl);
|
|
$result = $client->__SoapCall("login",
|
|
array(
|
|
array("userid" => $user, "password" => Bootstrap::getPasswordHashType() . ":" . $pass)
|
|
)
|
|
);
|
|
|
|
eprintln(" - Logging as user \"$user\"...");
|
|
|
|
$paramsLog = array(
|
|
"PRO_UID" => $processId,
|
|
"TAS_UID" => $taskId,
|
|
"SCH_UID" => $caseSchedulerUid,
|
|
"USR_NAME" => $user,
|
|
"RESULT" => "",
|
|
"EXEC_DATE" => date("Y-m-d"),
|
|
"EXEC_HOUR" => date("H:i:s"),
|
|
"WS_CREATE_CASE_STATUS" => "",
|
|
"WS_ROUTE_CASE_STATUS" => ""
|
|
);
|
|
|
|
if ($result->status_code == 0) {
|
|
eprintln(" OK", "green");
|
|
|
|
$sessionId = $result->message;
|
|
|
|
$params = array("sessionId" => $sessionId, "processId" => $processId, "taskId" => $taskId, "variables" => array());
|
|
|
|
//If this Job was was registered to be performed by a plugin
|
|
if (isset($row["CASE_SH_PLUGIN_UID"]) && $row["CASE_SH_PLUGIN_UID"] != "") {
|
|
//Check if the plugin is active
|
|
$pluginParts = explode("--", $row["CASE_SH_PLUGIN_UID"]);
|
|
|
|
if (count($pluginParts) == 2) {
|
|
//Plugins
|
|
G::LoadClass("plugin");
|
|
|
|
//Here we are loading all plugins registered
|
|
//The singleton has a list of enabled plugins
|
|
$sSerializedFile = PATH_DATA_SITE . "plugin.singleton";
|
|
$oPluginRegistry = &PMPluginRegistry::getSingleton();
|
|
|
|
if (file_exists($sSerializedFile)) {
|
|
$oPluginRegistry->unSerializeInstance(file_get_contents($sSerializedFile));
|
|
}
|
|
|
|
$oPluginRegistry = &PMPluginRegistry::getSingleton();
|
|
$activePluginsForCaseScheduler = $oPluginRegistry->getCaseSchedulerPlugins();
|
|
|
|
foreach ($activePluginsForCaseScheduler as $key => $caseSchedulerPlugin) {
|
|
if (isset($caseSchedulerPlugin->sNamespace) && $caseSchedulerPlugin->sNamespace == $pluginParts[0] && isset($caseSchedulerPlugin->sActionId) && $caseSchedulerPlugin->sActionId == $pluginParts[1]) {
|
|
$caseSchedulerSelected = $caseSchedulerPlugin;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
//If there is a trigger that is registered to do this then transfer control
|
|
if (isset($caseSchedulerSelected) && is_object($caseSchedulerSelected)) {
|
|
eprintln(" - Transfering control to a Plugin: " . $caseSchedulerSelected->sNamespace . "/" . $caseSchedulerSelected->sActionId, "green");
|
|
|
|
$oData = array();
|
|
$oData["OBJ_SOAP"] = $client;
|
|
$oData["SCH_UID"] = $row["SCH_UID"];
|
|
$oData["params"] = $params;
|
|
$oData["sessionId"] = $sessionId;
|
|
$oData["userId"] = $user;
|
|
|
|
$paramsLogResultFromPlugin = $oPluginRegistry->executeMethod($caseSchedulerSelected->sNamespace, $caseSchedulerSelected->sActionExecute, $oData);
|
|
$paramsLog["WS_CREATE_CASE_STATUS"] = $paramsLogResultFromPlugin["WS_CREATE_CASE_STATUS"];
|
|
$paramsLog["WS_ROUTE_CASE_STATUS"] = $paramsLogResultFromPlugin["WS_ROUTE_CASE_STATUS"];
|
|
|
|
$paramsLogResult = $paramsLogResultFromPlugin["paramsLogResult"];
|
|
$paramsRouteLogResult = $paramsLogResultFromPlugin["paramsRouteLogResult"];
|
|
} else {
|
|
eprintln(" - Creating the new case...");
|
|
|
|
$paramsAux = $params;
|
|
$paramsAux["executeTriggers"] = 1;
|
|
|
|
$oPluginRegistry = &PMPluginRegistry::getSingleton();
|
|
|
|
if ($oPluginRegistry->existsTrigger(PM_SCHEDULER_CREATE_CASE_BEFORE)) {
|
|
$oPluginRegistry->executeTriggers(PM_SCHEDULER_CREATE_CASE_BEFORE, $paramsAux);
|
|
}
|
|
|
|
$result = $client->__SoapCall("NewCase", array($paramsAux));
|
|
|
|
if ($oPluginRegistry->existsTrigger (PM_SCHEDULER_CREATE_CASE_AFTER)) {
|
|
$oPluginRegistry->executeTriggers(PM_SCHEDULER_CREATE_CASE_AFTER, $result);
|
|
}
|
|
|
|
if ($result->status_code == 0) {
|
|
eprintln(" OK case #" . $result->caseNumber . " was created!", "green");
|
|
|
|
$caseId = $result->caseId;
|
|
$caseNumber = $result->caseNumber;
|
|
$log[] = $caseNumber . " was created!, ProcessID: " . $row["PRO_UID"];
|
|
$paramsLog["WS_CREATE_CASE_STATUS"] = "Case " . $caseNumber . " " . strip_tags($result->message);
|
|
$paramsLogResult = "SUCCESS";
|
|
$params = array("sessionId" => $sessionId, "caseId" => $caseId, "delIndex" => "1");
|
|
|
|
try {
|
|
eprintln(" - Routing the case #$caseNumber...");
|
|
|
|
$result = $client->__SoapCall("RouteCase", array($params));
|
|
|
|
if ($result->status_code == 0) {
|
|
$paramsLog["WS_ROUTE_CASE_STATUS"] = strip_tags($result->message);
|
|
$retMsg = explode("Debug", $paramsLog["WS_ROUTE_CASE_STATUS"]);
|
|
$retMsg = $retMsg[0];
|
|
$paramsRouteLogResult = "SUCCESS";
|
|
|
|
eprintln(" OK $retMsg", "green");
|
|
} else {
|
|
$paramsLog["WS_ROUTE_CASE_STATUS"] = strip_tags($result->message);
|
|
$paramsRouteLogResult = "FAILED";
|
|
|
|
eprintln(" Failed: " . $paramsLog["WS_ROUTE_CASE_STATUS"], "red");
|
|
}
|
|
} catch (Exception $e) {
|
|
//setExecutionResultMessage("WITH ERRORS", "error");
|
|
$paramsLog["WS_ROUTE_CASE_STATUS"] = strip_tags($e->getMessage());
|
|
$paramsRouteLogResult = "FAILED";
|
|
|
|
eprintln(" Failed: " . strip_tags($e->getMessage()), "red");
|
|
}
|
|
} else {
|
|
$paramsLog["WS_CREATE_CASE_STATUS"] = strip_tags($result->message);
|
|
$paramsLogResult = "FAILED";
|
|
|
|
eprintln(" Failed: " . $paramsLog["WS_CREATE_CASE_STATUS"], "red");
|
|
}
|
|
}
|
|
} else {
|
|
//Invalid user or bad password
|
|
eprintln(" " . $result->message, "red");
|
|
}
|
|
|
|
if ($paramsLogResult == "SUCCESS" && $paramsRouteLogResult == "SUCCESS") {
|
|
$paramsLog["RESULT"] = "SUCCESS";
|
|
} else {
|
|
$paramsLog["RESULT"] = "FAILED";
|
|
}
|
|
|
|
$newCaseLog = new LogCasesScheduler();
|
|
$newCaseLog->saveLogParameters($paramsLog);
|
|
$newCaseLog->save();
|
|
|
|
//Update the SCH_TIME_NEXT_RUN field
|
|
switch ($caseSchedulerOption) {
|
|
case 1:
|
|
case 2:
|
|
case 3:
|
|
//Daily
|
|
//Weekly
|
|
//Monthly
|
|
if ($caseSchedulerTimeNextRunNew == "") {
|
|
list($value, $daysPerformTask, $weeks, $startDay, $months) = $this->getVariablesFromRecord($row);
|
|
|
|
$caseSchedulerTimeNextRunNew = $this->updateNextRun($caseSchedulerOption, $value, $caseSchedulerTimeNextRun, $daysPerformTask, $weeks, $startDay, $months);
|
|
}
|
|
|
|
if ($row["SCH_END_DATE"] . "" != "" && strtotime($row["SCH_END_DATE"]) < strtotime($caseSchedulerTimeNextRunNew)) {
|
|
$result = $this->update(array(
|
|
"SCH_UID" => $caseSchedulerUid,
|
|
"SCH_LAST_STATE" => $row["SCH_STATE"],
|
|
"SCH_LAST_RUN_TIME" => $caseSchedulerTimeNextRun,
|
|
"SCH_STATE" => "PROCESSED"
|
|
));
|
|
} else {
|
|
$this->updateDate($caseSchedulerUid, $caseSchedulerTimeNextRunNew, $caseSchedulerTimeNextRun);
|
|
}
|
|
break;
|
|
case 4:
|
|
//One time only
|
|
$result = $this->update(array(
|
|
"SCH_UID" => $caseSchedulerUid,
|
|
"SCH_LAST_STATE" => $row["SCH_STATE"],
|
|
"SCH_LAST_RUN_TIME" => $caseSchedulerTimeNextRun,
|
|
"SCH_STATE" => "PROCESSED"
|
|
));
|
|
break;
|
|
case 5:
|
|
//Every
|
|
if ($caseSchedulerTimeNextRunNew == "") {
|
|
$caseSchedulerTimeNextRunNew = date("Y-m-d H:i:s", $timeDate + (((int)($row["SCH_REPEAT_EVERY"])) * 60 * 60));
|
|
}
|
|
|
|
$this->updateDate($caseSchedulerUid, $caseSchedulerTimeNextRunNew, $caseSchedulerTimeNextRun);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
} catch (Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
public function updateDate ($sSchedulerUid = '', $sSchTimeNextRun = '', $sSchLastRunTime = '')
|
|
{
|
|
$Fields = $this->Load( $sSchedulerUid );
|
|
$Fields['SCH_TIME_NEXT_RUN'] = strtotime( $sSchTimeNextRun );
|
|
$Fields['SCH_LAST_RUN_TIME'] = strtotime( $sSchLastRunTime );
|
|
$this->Update( $Fields );
|
|
}
|
|
|
|
public function updateNextRun($sOption, $sValue = "", $sActualTime = "", $sDaysPerformTask = "", $sWeeks = "", $sStartDay = "", $sMonths = "", $currentDate = "", $flagOptionWeeklyNextRun = true)
|
|
{
|
|
$nActualDate = $currentDate . " " . $sActualTime;
|
|
$dEstimatedDate = '';
|
|
$sWeeks = trim($sWeeks, " |");
|
|
|
|
switch ($sOption) {
|
|
case '1':
|
|
switch ($sValue) {
|
|
case '1':
|
|
$dEstimatedDate = date( 'Y-m-d H:i:s', strtotime( "$nActualDate +1 day" ) );
|
|
break;
|
|
case '2':
|
|
$nDayOfTheWeek = date( 'w', strtotime( $sActualTime ) );
|
|
$nDayOfTheWeek = ($nDayOfTheWeek == 0) ? 7 : $nDayOfTheWeek;
|
|
|
|
if ($nDayOfTheWeek >= 5) {
|
|
$dEstimatedDate = date( 'Y-m-d H:i:s', strtotime( "$nActualDate +3 day" ) );
|
|
} else {
|
|
$dEstimatedDate = date( 'Y-m-d H:i:s', strtotime( "$nActualDate +1 day" ) );
|
|
}
|
|
break;
|
|
case '3':
|
|
$dEstimatedDate = date( 'Y-m-d H:i:s', strtotime( "$nActualDate + " . $sDaysPerformTask . " day" ) );
|
|
break;
|
|
}
|
|
break;
|
|
case '2':
|
|
if ($sWeeks != "") {
|
|
$aDaysWeek = array ('Monday','Tuesday','Wednesday','Thursday','Friday','Saturday','Sunday');
|
|
|
|
$nDayOfTheWeek = (int)(date("w", strtotime($sActualTime)));
|
|
$nDayOfTheWeek = ($nDayOfTheWeek == 0)? 7 : $nDayOfTheWeek;
|
|
|
|
$arrayWeekdays = explode("|", $sWeeks);
|
|
$firstDay = (int)($arrayWeekdays[0]);
|
|
$lastDay = (int)($arrayWeekdays[count($arrayWeekdays) - 1]);
|
|
|
|
$flagFound1 = $nDayOfTheWeek < $firstDay || in_array($nDayOfTheWeek, $arrayWeekdays);
|
|
$flagFound2 = ($flagFound1)? false : ($firstDay <= $nDayOfTheWeek && $nDayOfTheWeek <= $lastDay);
|
|
|
|
if ($flagFound1 || $flagFound2) {
|
|
$typeStatement = "this";
|
|
|
|
if ($flagFound1) {
|
|
$indexDay = (in_array($nDayOfTheWeek, $arrayWeekdays))? $nDayOfTheWeek : $firstDay;
|
|
|
|
if ($flagOptionWeeklyNextRun) {
|
|
$index = array_search($nDayOfTheWeek, $arrayWeekdays);
|
|
|
|
if ($index !== false && isset($arrayWeekdays[$index + 1])) {
|
|
$indexDay = $arrayWeekdays[$index + 1];
|
|
} else {
|
|
$typeStatement = "next";
|
|
$indexDay = $firstDay;
|
|
}
|
|
}
|
|
}
|
|
|
|
if ($flagFound2) {
|
|
$indexDay = $firstDay;
|
|
|
|
foreach ($arrayWeekdays as $value) {
|
|
$day = (int)($value);
|
|
|
|
if ($day > $nDayOfTheWeek) {
|
|
$indexDay = $day;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
$indexDay--;
|
|
|
|
$dEstimatedDate = date("Y-m-d", strtotime($nActualDate . " " . $typeStatement . " " . $aDaysWeek[$indexDay])) . " " . date("H:i:s", strtotime($sActualTime));
|
|
} else {
|
|
$nEveryDays = $sDaysPerformTask;
|
|
|
|
$typeStatement = ($firstDay >= $nDayOfTheWeek || $nEveryDays == 1)? "next" : "last";
|
|
$indexDay = $firstDay - 1;
|
|
|
|
if ($nEveryDays == 1) {
|
|
$dEstimatedDate = date("Y-m-d", strtotime($nActualDate . " " . $typeStatement . " " . $aDaysWeek[$indexDay])) . " " . date("H:i:s", strtotime($sActualTime));
|
|
} else {
|
|
$nEveryDays = 1;
|
|
$nDataTmp = date( 'Y-m-d', strtotime( "$nActualDate + " . $nEveryDays . " Week" ) );
|
|
$dEstimatedDate = date("Y-m-d", strtotime($nDataTmp . " " . $typeStatement . " " . $aDaysWeek[$indexDay])) . " " . date("H:i:s", strtotime($sActualTime));
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
case '3':
|
|
if (strlen( $sMonths ) > 0) {
|
|
// Must have at least one selected month
|
|
// Calculamos para la siguiente ejecucion, acorde a lo seleccionado
|
|
$aStartDay = explode( '|', $sStartDay );
|
|
$nYear = date( "Y", strtotime( $sActualTime ) );
|
|
$nCurrentMonth = date( "m", strtotime( $sActualTime ) );
|
|
$nCurrentDay = date( "d", strtotime( $sActualTime ) );
|
|
$aMonths = explode( '|', $sMonths );
|
|
|
|
$nSW = 0;
|
|
$nNextMonth = 0;
|
|
foreach ($aMonths as $value) {
|
|
if ($value > $nCurrentMonth) {
|
|
$nNextMonth = $value - 1;
|
|
$nSW = 1;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if ($nSW == 1) {
|
|
$nExecNextMonth = $nNextMonth;
|
|
} else {
|
|
$nExecNextMonth = $aMonths[0] - 1;
|
|
$nYear ++;
|
|
}
|
|
|
|
switch ($sValue) {
|
|
case '1':
|
|
$nExecNextMonth ++;
|
|
$nCurrentDay = $aStartDay[1];
|
|
$dEstimatedDate = date( 'Y-m-d', strtotime( "$nYear-$nExecNextMonth-$nCurrentDay" ) ) . ' ' . date( 'H:i:s', strtotime( $sActualTime ) );
|
|
break;
|
|
case '2':
|
|
$aMontsShort = array ('Jan','Feb','Mar','Apr','May','Jun','Jul','Aug','Sep','Oct','Nov','Dec');
|
|
$aWeeksShort = array ('Monday','Tuesday','Wednesday','Thursday','Friday','Saturday','Sunday');
|
|
$sNumDayWeek = $aStartDay[1];
|
|
$sDayWeek = ($aStartDay[2] == 7 ? 0 : $aStartDay[2]);
|
|
switch ($sNumDayWeek) {
|
|
case '1':
|
|
$sDaysWeekOpt = "+0";
|
|
break;
|
|
case '2':
|
|
$sDaysWeekOpt = "+1";
|
|
break;
|
|
case '3':
|
|
$sDaysWeekOpt = "+2";
|
|
break;
|
|
case '4':
|
|
$sDaysWeekOpt = "+3";
|
|
break;
|
|
case '5':
|
|
$sDaysWeekOpt = "-1";
|
|
$nExecNextMonth ++;
|
|
if ($nExecNextMonth >= 12) {
|
|
$nExecNextMonth = 0;
|
|
$nYear ++;
|
|
}
|
|
break;
|
|
}
|
|
$dEstimatedDate = date( 'Y-m-d', strtotime( $sDaysWeekOpt . ' week ' . $aWeeksShort[$sDayWeek - 1] . ' ' . $aMontsShort[$nExecNextMonth] . ' ' . $nYear ) ) . ' ' . date( 'H:i:s', strtotime( $sActualTime ) );
|
|
break;
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
return $dEstimatedDate;
|
|
}
|
|
|
|
public function Exists ($sUid)
|
|
{
|
|
try {
|
|
$oObj = CaseSchedulerPeer::retrieveByPk( $sUid );
|
|
return (is_object( $oObj ) && get_class( $oObj ) == 'CaseScheduler');
|
|
} catch (Exception $oError) {
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get variables from a CaseScheduler record
|
|
*
|
|
* @param array $record Record
|
|
*
|
|
* return array Return an array with variables
|
|
*/
|
|
public function getVariablesFromRecord(array $record)
|
|
{
|
|
try {
|
|
$value = "";
|
|
$daysPerformTask = "";
|
|
$weeks = "";
|
|
$startDay = "";
|
|
$months = "";
|
|
|
|
switch ((int)($record["SCH_OPTION"])) {
|
|
case 1:
|
|
//Daily
|
|
$daysPerformTask = $record["SCH_DAYS_PERFORM_TASK"];
|
|
$arrayDaysPerformTask = explode("|", $daysPerformTask);
|
|
$value = $arrayDaysPerformTask[0];
|
|
|
|
if ($value != 1) {
|
|
$daysPerformTask = $arrayDaysPerformTask[1];
|
|
}
|
|
break;
|
|
case 2:
|
|
//Weekly
|
|
$daysPerformTask = $record["SCH_EVERY_DAYS"];
|
|
$weeks = $record["SCH_WEEK_DAYS"];
|
|
break;
|
|
case 3:
|
|
//Monthly
|
|
$startDay = $record["SCH_START_DAY"];
|
|
$months = $record["SCH_MONTHS"];
|
|
$arrayStartDay = explode("|", $startDay);
|
|
$value = $arrayStartDay[0];
|
|
break;
|
|
case 4:
|
|
//One time only
|
|
break;
|
|
case 5:
|
|
//Every
|
|
break;
|
|
}
|
|
|
|
//Return
|
|
return array($value, $daysPerformTask, $weeks, $startDay, $months);
|
|
} catch (Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get the Time Next Run by Date
|
|
*
|
|
* @param array $arrayCaseSchedulerData CaseScheduler Data
|
|
* @param string $date Date
|
|
* @param bool $flagUpdateTimeNextRun Flag
|
|
*
|
|
* return string Return the Time Next Run
|
|
*/
|
|
public function getTimeNextRunByDate(array $arrayCaseSchedulerData, $date, $flagUpdateTimeNextRun = true)
|
|
{
|
|
try {
|
|
$arrayNextDate = array();
|
|
|
|
//Get date
|
|
$caseSchedulerOption = (int)($arrayCaseSchedulerData["SCH_OPTION"]);
|
|
$caseSchedulerTimeNextRun = $arrayCaseSchedulerData["SCH_TIME_NEXT_RUN"];
|
|
|
|
list($value, $daysPerformTask, $weeks, $startDay, $months) = $this->getVariablesFromRecord($arrayCaseSchedulerData);
|
|
|
|
$timeDate = strtotime($date); //Current time
|
|
$timeCaseSchedulerTimeNextRun = strtotime($caseSchedulerTimeNextRun);
|
|
|
|
$flagTimeNextRun = false;
|
|
$flagUpdate = false;
|
|
|
|
if ($caseSchedulerOption != 1) {
|
|
//Others
|
|
$flagTimeNextRun = true;
|
|
} else {
|
|
//Daily
|
|
$arrayDate = array(
|
|
date("Y-m-d", strtotime($arrayCaseSchedulerData["SCH_START_DATE"])) . " " . date("H:i:s", $timeCaseSchedulerTimeNextRun),
|
|
date("Y-m-d", $timeDate) . " " . date("H:i:s", $timeCaseSchedulerTimeNextRun)
|
|
);
|
|
|
|
$flagTimeNextRun = true;
|
|
|
|
foreach ($arrayDate as $d) {
|
|
$caseSchedulerTimeNextRun2 = $d;
|
|
$timeCaseSchedulerTimeNextRun2 = strtotime($caseSchedulerTimeNextRun2);
|
|
|
|
if ($timeDate < $timeCaseSchedulerTimeNextRun2) {
|
|
$caseSchedulerTimeNextRun = $caseSchedulerTimeNextRun2;
|
|
|
|
$flagTimeNextRun = false;
|
|
$flagUpdate = true;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
if ($flagTimeNextRun) {
|
|
switch ($caseSchedulerOption) {
|
|
case 1:
|
|
case 2:
|
|
case 3:
|
|
//Daily
|
|
//Weekly
|
|
//Monthly
|
|
$caseSchedulerTimeNextRun = date("Y-m-d", $timeDate) . " " . date("H:i:s", $timeCaseSchedulerTimeNextRun);
|
|
$caseSchedulerTimeNextRun = $this->updateNextRun($caseSchedulerOption, $value, $caseSchedulerTimeNextRun, $daysPerformTask, $weeks, $startDay, $months, "", false);
|
|
|
|
$timeCaseSchedulerTimeNextRun = strtotime($caseSchedulerTimeNextRun);
|
|
|
|
if ($timeCaseSchedulerTimeNextRun < $timeDate) {
|
|
$caseSchedulerTimeNextRun = $this->updateNextRun($caseSchedulerOption, $value, $caseSchedulerTimeNextRun, $daysPerformTask, $weeks, $startDay, $months);
|
|
}
|
|
break;
|
|
case 4:
|
|
//One time only
|
|
$caseSchedulerTimeNextRun = date("Y-m-d", $timeDate) . " " . date("H:i:s", $timeCaseSchedulerTimeNextRun);
|
|
|
|
$timeCaseSchedulerTimeNextRun = strtotime($caseSchedulerTimeNextRun);
|
|
|
|
if ($timeCaseSchedulerTimeNextRun < $timeDate) {
|
|
$caseSchedulerTimeNextRun = $this->updateNextRun("1", "1", $caseSchedulerTimeNextRun, $daysPerformTask, $weeks, $startDay, $months);
|
|
}
|
|
break;
|
|
case 5:
|
|
//Every
|
|
$caseSchedulerTimeNextRun = date("Y-m-d H:i:s", $timeDate + (((int)($arrayCaseSchedulerData["SCH_REPEAT_EVERY"])) * 60 * 60));
|
|
break;
|
|
}
|
|
|
|
$flagUpdate = true;
|
|
}
|
|
|
|
//Update the SCH_TIME_NEXT_RUN field
|
|
if ($flagUpdateTimeNextRun && $flagUpdate) {
|
|
$result = $this->update(array(
|
|
"SCH_UID" => $arrayCaseSchedulerData["SCH_UID"],
|
|
"SCH_TIME_NEXT_RUN" => strtotime($caseSchedulerTimeNextRun)
|
|
));
|
|
}
|
|
|
|
//Return
|
|
return $caseSchedulerTimeNextRun;
|
|
} catch (Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
}
|
|
|