CODE STYLE Formating worflow/engine/classes/model/CaseScheduler.php
Change format files in worflow/engine/classes/model/CaseScheduler.php
This commit is contained in:
@@ -1,6 +1,7 @@
|
||||
<?php
|
||||
/**
|
||||
* CaseScheduler.php
|
||||
*
|
||||
* @package workflow.engine.classes.model
|
||||
*/
|
||||
|
||||
@@ -20,8 +21,8 @@ require_once 'classes/model/Task.php';
|
||||
*
|
||||
* @package workflow.engine.classes.model
|
||||
*/
|
||||
class CaseScheduler extends BaseCaseScheduler {
|
||||
|
||||
class CaseScheduler extends BaseCaseScheduler
|
||||
{
|
||||
/*
|
||||
private $SchTimeNextRun = null;
|
||||
private $SchLastRunTime = null;
|
||||
@@ -44,7 +45,8 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
}
|
||||
*/
|
||||
|
||||
public function load($SchUid) {
|
||||
public function load ($SchUid)
|
||||
{
|
||||
try {
|
||||
$oRow = CaseSchedulerPeer::retrieveByPK( $SchUid );
|
||||
if (! is_null( $oRow )) {
|
||||
@@ -60,7 +62,8 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
}
|
||||
}
|
||||
|
||||
function create($aData) {
|
||||
public function create ($aData)
|
||||
{
|
||||
$con = Propel::getConnection( CaseSchedulerPeer::DATABASE_NAME );
|
||||
try {
|
||||
$this->fromArray( $aData, BasePeer::TYPE_FIELDNAME );
|
||||
@@ -79,7 +82,8 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
}
|
||||
}
|
||||
|
||||
public function update($fields) {
|
||||
public function update ($fields)
|
||||
{
|
||||
$con = Propel::getConnection( CaseSchedulerPeer::DATABASE_NAME );
|
||||
try {
|
||||
$con->begin();
|
||||
@@ -99,7 +103,8 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
}
|
||||
}
|
||||
|
||||
function remove($SchUid) {
|
||||
public function remove ($SchUid)
|
||||
{
|
||||
$con = Propel::getConnection( CaseSchedulerPeer::DATABASE_NAME );
|
||||
try {
|
||||
$oCaseScheduler = CaseSchedulerPeer::retrieveByPK( $SchUid );
|
||||
@@ -107,8 +112,7 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
$iResult = $oCaseScheduler->delete();
|
||||
$con->commit();
|
||||
return $iResult;
|
||||
}
|
||||
else {
|
||||
} else {
|
||||
throw (new Exception( 'This row doesn\'t exist!' ));
|
||||
}
|
||||
/*
|
||||
@@ -129,7 +133,8 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
* @param string $sSchedulerUid
|
||||
* @return boolean
|
||||
*/
|
||||
function changeStatus($sSchedulerUid = '') {
|
||||
public function changeStatus ($sSchedulerUid = '')
|
||||
{
|
||||
$Fields = $this->Load( $sSchedulerUid );
|
||||
$Fields['SCH_LAST_STATE'] = $Fields['SCH_STATE'];
|
||||
if ($Fields['SCH_STATE'] == 'ACTIVE') {
|
||||
@@ -148,10 +153,10 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
// FROM CASE_SCHEDULER A LEFT JOIN CONTENT B ON A.PRO_UID= B.CON_ID AND B.CON_CATEGORY='PRO_TITLE' AND B.CON_LANG='en'
|
||||
// LEFT JOIN CONTENT C ON A.TAS_UID= C.CON_ID AND C.CON_CATEGORY='TAS_TITLE' AND C.CON_LANG='en'
|
||||
//
|
||||
function getAllCriteria() {
|
||||
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 );
|
||||
@@ -182,7 +187,8 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
|
||||
}
|
||||
|
||||
function getAll() {
|
||||
public function getAll ()
|
||||
{
|
||||
$oCriteria = $this->getAllCriteria();
|
||||
$oDataset = CaseSchedulerPeer::doSelectRS( $oCriteria );
|
||||
|
||||
@@ -205,14 +211,17 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
|
||||
return $aRows;
|
||||
}
|
||||
|
||||
/**
|
||||
* function getAllByProcess
|
||||
* Get All Scheduled Tasks for some process.
|
||||
*
|
||||
* @author gustavo cruz
|
||||
* @desc Get All Scheduled Tasks for some process.
|
||||
* @param $pro_uid process uid
|
||||
* @return $aRows a result set array
|
||||
*/
|
||||
function getAllByProcess($pro_uid) {
|
||||
public function getAllByProcess ($pro_uid)
|
||||
{
|
||||
|
||||
$oCriteria = $this->getAllCriteria();
|
||||
$oCriteria->add( CaseSchedulerPeer::PRO_UID, $pro_uid );
|
||||
@@ -235,7 +244,8 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
return $aRows;
|
||||
}
|
||||
|
||||
function getProcessDescription() {
|
||||
public function getProcessDescription ()
|
||||
{
|
||||
$c = new Criteria( 'workflow' );
|
||||
$c->clearSelectColumns();
|
||||
$c->addSelectColumn( ProcessPeer::PRO_UID );
|
||||
@@ -253,15 +263,15 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
$oProcess = new Process();
|
||||
$aProcessRow = $oProcess->load( $aRow['PRO_UID'] );
|
||||
|
||||
$aRows [$k] = array_merge ( $aRow, array (
|
||||
'PRO_TITLE' => $aProcessRow ['PRO_TITLE']
|
||||
$aRows[$k] = array_merge( $aRow, array ('PRO_TITLE' => $aProcessRow['PRO_TITLE']
|
||||
) );
|
||||
}
|
||||
return $aRows;
|
||||
|
||||
}
|
||||
|
||||
function getTaskDescription() {
|
||||
public function getTaskDescription ()
|
||||
{
|
||||
$c = new Criteria( 'workflow' );
|
||||
$c->clearSelectColumns();
|
||||
$c->addSelectColumn( TaskPeer::TAS_UID );
|
||||
@@ -279,10 +289,8 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
$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']
|
||||
$aRows[$k] = array_merge( $aRow, array ('TAS_TITLE' => $aTaskRow['TAS_TITLE']
|
||||
), array ('PRO_UID' => $aTaskRow['PRO_UID']
|
||||
) );
|
||||
}
|
||||
|
||||
@@ -293,18 +301,14 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
|
||||
}
|
||||
|
||||
public function caseSchedulerCron($date, &$log=array(), $cron=0) {
|
||||
|
||||
public function caseSchedulerCron ($date, &$log = array(), $cron = 0)
|
||||
{
|
||||
G::LoadClass( 'dates' );
|
||||
require_once ('classes/model/LogCasesScheduler.php');
|
||||
|
||||
$oDates = new dates();
|
||||
|
||||
$nTime = strtotime( $date );
|
||||
|
||||
$dCurrentDate = date( 'Y-m-d', $nTime ) . ' 00:00:00';
|
||||
$dNextDay = date( 'Y-m-d', strtotime( "$dCurrentDate" ) ) . ' 23:59:59';
|
||||
|
||||
$oCriteria = $this->getAllCriteria();
|
||||
$oCriteria->addAnd( CaseSchedulerPeer::SCH_STATE, 'INACTIVE', Criteria::NOT_EQUAL );
|
||||
$oCriteria->addAnd( CaseSchedulerPeer::SCH_STATE, 'PROCESSED', Criteria::NOT_EQUAL );
|
||||
@@ -315,7 +319,6 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
$oDataset = CaseSchedulerPeer::doSelectRS( $oCriteria );
|
||||
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
|
||||
$oDataset->next();
|
||||
|
||||
$sValue = '';
|
||||
$sActualTime = '';
|
||||
$sDaysPerformTask = '';
|
||||
@@ -336,8 +339,9 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
$sDaysPerformTask = $aRow['SCH_DAYS_PERFORM_TASK'];
|
||||
$aDaysPerformTask = explode( '|', $sDaysPerformTask );
|
||||
$sValue = $aDaysPerformTask[0];
|
||||
if ($sValue != 1)
|
||||
if ($sValue != 1) {
|
||||
$sDaysPerformTask = $aDaysPerformTask[1];
|
||||
}
|
||||
break;
|
||||
case '2':
|
||||
$sDaysPerformTask = $aRow['SCH_EVERY_DAYS'];
|
||||
@@ -358,36 +362,24 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
}
|
||||
|
||||
$sActualTime = $aRow['SCH_TIME_NEXT_RUN'];
|
||||
|
||||
$sActualDataHour = date( 'H', strtotime( $aRow['SCH_TIME_NEXT_RUN'] ) );
|
||||
$sActualDataMinutes = date( 'i', strtotime( $aRow['SCH_TIME_NEXT_RUN'] ) );
|
||||
$dActualSysHour = date( 'H', $nTime );
|
||||
$dActualSysMinutes = date( 'i', $nTime );
|
||||
|
||||
$sActualDataTime = strtotime( $aRow['SCH_TIME_NEXT_RUN'] );
|
||||
$sActualSysTime = strtotime( $nTime );
|
||||
|
||||
// note added consider the posibility to encapsulate some in functionality in a class method or some funtions
|
||||
if ($sActualDataHour < $dActualSysHour) {
|
||||
$_PORT = (SERVER_PORT != '80') ? ':' . SERVER_PORT : '';
|
||||
|
||||
$defaultEndpoint = 'http://' . SERVER_NAME . $_PORT . '/sys' . SYS_SYS . '/' . SYS_LANG . '/classic/services/wsdl2';
|
||||
println( " - Connecting webservice: $defaultEndpoint" );
|
||||
|
||||
$user = $aRow["SCH_DEL_USER_NAME"];
|
||||
$pass = $aRow["SCH_DEL_USER_PASS"];
|
||||
$processId = $aRow["PRO_UID"];
|
||||
$taskId = $aRow["TAS_UID"];
|
||||
|
||||
$client = new SoapClient( $defaultEndpoint );
|
||||
$params = array (
|
||||
'userid' => $user,
|
||||
'password' => 'md5:' . $pass
|
||||
);
|
||||
$result = $client->__SoapCall ( 'login', array (
|
||||
$params
|
||||
) );
|
||||
|
||||
$params = array ('userid' => $user,'password' => 'md5:' . $pass);
|
||||
$result = $client->__SoapCall( 'login', array ($params) );
|
||||
eprint( " - Logging as user $user............." );
|
||||
if ($result->status_code == 0) {
|
||||
eprintln( "OK+", 'green' );
|
||||
@@ -395,23 +387,10 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
$newCaseLog = new LogCasesScheduler();
|
||||
$newRouteLog = new LogCasesScheduler();
|
||||
$variables = Array ();
|
||||
$params = array (
|
||||
'sessionId' => $sessionId,
|
||||
'processId' => $processId,
|
||||
'taskId' => $taskId,
|
||||
'variables' => $variables
|
||||
$params = array ('sessionId' => $sessionId,'processId' => $processId,'taskId' => $taskId,'variables' => $variables
|
||||
);
|
||||
|
||||
$paramsLog = array (
|
||||
'PRO_UID' => $processId,
|
||||
'TAS_UID' => $taskId,
|
||||
'SCH_UID' => $sSchedulerUid,
|
||||
'USR_NAME' => $user,
|
||||
'RESULT' => '',
|
||||
'EXEC_DATE' => date ( 'Y-m-d' ),
|
||||
'EXEC_HOUR' => date ( 'H:i:s' ),
|
||||
'WS_CREATE_CASE_STATUS' => '',
|
||||
'WS_ROUTE_CASE_STATUS' => ''
|
||||
$paramsLog = array ('PRO_UID' => $processId,'TAS_UID' => $taskId,'SCH_UID' => $sSchedulerUid,'USR_NAME' => $user,'RESULT' => '','EXEC_DATE' => date( 'Y-m-d' ),'EXEC_HOUR' => date( 'H:i:s' ),'WS_CREATE_CASE_STATUS' => '','WS_ROUTE_CASE_STATUS' => ''
|
||||
);
|
||||
|
||||
$sw_transfer_control_plugin = false; //This SW will be true only if a plugin is allowed to continue the action
|
||||
@@ -424,13 +403,11 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
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) )
|
||||
if (file_exists( $sSerializedFile )) {
|
||||
$oPluginRegistry->unSerializeInstance( file_get_contents( $sSerializedFile ) );
|
||||
|
||||
|
||||
}
|
||||
$oPluginRegistry = & PMPluginRegistry::getSingleton();
|
||||
$activePluginsForCaseScheduler = $oPluginRegistry->getCaseSchedulerPlugins();
|
||||
foreach ($activePluginsForCaseScheduler as $key => $caseSchedulerPlugin) {
|
||||
@@ -460,11 +437,8 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
$paramsLogResult = $paramsLogResultFromPlugin['paramsLogResult'];
|
||||
$paramsRouteLogResult = $paramsLogResultFromPlugin['paramsRouteLogResult'];
|
||||
} else {
|
||||
|
||||
eprint( " - Creating the new case............." );
|
||||
$result = $client->__SoapCall ( 'NewCase', array (
|
||||
$params
|
||||
) );
|
||||
$result = $client->__SoapCall( 'NewCase', array ($params) );
|
||||
if ($result->status_code == 0) {
|
||||
eprintln( "OK+ CASE #{$result->caseNumber} was created!", 'green' );
|
||||
|
||||
@@ -473,16 +447,10 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
$log[] = $caseNumber . ' was created!, ProcessID: ' . $aRow['PRO_UID'];
|
||||
$paramsLog['WS_CREATE_CASE_STATUS'] = "Case " . $caseNumber . " " . strip_tags( $result->message );
|
||||
$paramsLogResult = 'SUCCESS';
|
||||
|
||||
$params = array (
|
||||
'sessionId' => $sessionId,
|
||||
'caseId' => $caseId,
|
||||
'delIndex' => "1"
|
||||
);
|
||||
$params = array ('sessionId' => $sessionId,'caseId' => $caseId,'delIndex' => "1");
|
||||
eprint( " - Routing the case #$caseNumber.............." );
|
||||
$result = $client->__SoapCall ( 'RouteCase', array (
|
||||
$params
|
||||
) );
|
||||
$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'] );
|
||||
@@ -539,9 +507,7 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
|
||||
}
|
||||
} else if ($sActualDataHour == $dActualSysHour && $sActualDataMinutes <= $dActualSysMinutes) {
|
||||
|
||||
$_PORT = (isset( $_SERVER['SERVER_PORT'] ) && $_SERVER['SERVER_PORT'] != '80') ? ':' . $_SERVER['SERVER_PORT'] : '';
|
||||
|
||||
//$defaultEndpoint = 'http://' . $_SERVER ['SERVER_NAME'] . ':' . $_PORT . '/sys' . SYS_SYS .'/'.SYS_LANG.'/classic/green/services/wsdl2';
|
||||
$defaultEndpoint = 'http://' . SERVER_NAME . $_PORT . '/sys' . SYS_SYS . '/' . SYS_LANG . '/classic/services/wsdl2';
|
||||
println( " - Connecting webservice: $defaultEndpoint" );
|
||||
@@ -549,46 +515,23 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
$pass = $aRow["SCH_DEL_USER_PASS"];
|
||||
$processId = $aRow["PRO_UID"];
|
||||
$taskId = $aRow["TAS_UID"];
|
||||
|
||||
$client = new SoapClient( $defaultEndpoint );
|
||||
$params = array (
|
||||
'userid' => $user,
|
||||
'password' => 'md5:' . $pass
|
||||
);
|
||||
$result = $client->__SoapCall ( 'login', array (
|
||||
$params
|
||||
) );
|
||||
|
||||
$params = array ('userid' => $user,'password' => 'md5:' . $pass);
|
||||
$result = $client->__SoapCall( 'login', array ($params) );
|
||||
eprint( " - Logging as user $user............." );
|
||||
if ($result->status_code == 0) {
|
||||
eprintln( "OK+", 'green' );
|
||||
|
||||
$sessionId = $result->message;
|
||||
$newCaseLog = new LogCasesScheduler();
|
||||
$newRouteLog = new LogCasesScheduler();
|
||||
$variables = Array ();
|
||||
$params = array (
|
||||
'sessionId' => $sessionId,
|
||||
'processId' => $processId,
|
||||
'taskId' => $taskId,
|
||||
'variables' => $variables
|
||||
$params = array ('sessionId' => $sessionId,'processId' => $processId,'taskId' => $taskId,'variables' => $variables
|
||||
);
|
||||
|
||||
$paramsLog = array (
|
||||
'PRO_UID' => $processId,
|
||||
'TAS_UID' => $taskId,
|
||||
'SCH_UID' => $sSchedulerUid,
|
||||
'USR_NAME' => $user,
|
||||
'RESULT' => '',
|
||||
'EXEC_DATE' => date ( 'Y-m-d' ),
|
||||
'EXEC_HOUR' => date ( 'H:i:s' ),
|
||||
'WS_CREATE_CASE_STATUS' => '',
|
||||
'WS_ROUTE_CASE_STATUS' => ''
|
||||
$paramsLog = array ('PRO_UID' => $processId,'TAS_UID' => $taskId,'SCH_UID' => $sSchedulerUid,'USR_NAME' => $user,'RESULT' => '','EXEC_DATE' => date( 'Y-m-d' ),'EXEC_HOUR' => date( 'H:i:s' ),'WS_CREATE_CASE_STATUS' => '','WS_ROUTE_CASE_STATUS' => ''
|
||||
);
|
||||
|
||||
$result = $client->__SoapCall ( 'NewCase', array (
|
||||
$params
|
||||
) );
|
||||
$result = $client->__SoapCall( 'NewCase', array ($params) );
|
||||
|
||||
eprint( " - Creating the new case............." );
|
||||
if ($result->status_code == 0) {
|
||||
@@ -599,13 +542,9 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
$paramsLog['WS_CREATE_CASE_STATUS'] = "Case " . $caseNumber . " " . strip_tags( $result->message );
|
||||
$paramsLogResult = 'SUCCESS';
|
||||
|
||||
$params = array (
|
||||
'sessionId' => $sessionId,
|
||||
'caseId' => $caseId,
|
||||
'delIndex' => "1"
|
||||
$params = array ('sessionId' => $sessionId,'caseId' => $caseId,'delIndex' => "1"
|
||||
);
|
||||
$result = $client->__SoapCall ( 'RouteCase', array (
|
||||
$params
|
||||
$result = $client->__SoapCall( 'RouteCase', array ($params
|
||||
) );
|
||||
eprint( " - Routing the case #$caseNumber.............." );
|
||||
if ($result->status_code == 0) {
|
||||
@@ -641,7 +580,6 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
|
||||
if ($sOption != '4' && $sOption != '5') {
|
||||
$nSchLastRunTime = $sActualTime;
|
||||
|
||||
$dEstimatedDate = $this->updateNextRun( $sOption, $sValue, $sActualTime, $sDaysPerformTask, $sWeeks, $sStartDay, $sMonths );
|
||||
|
||||
if ($aRow['SCH_END_DATE'] != '') {
|
||||
@@ -650,11 +588,9 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
$Fields['SCH_LAST_STATE'] = $aRow['SCH_STATE'];
|
||||
$Fields['SCH_STATE'] = 'PROCESSED';
|
||||
$this->Update( $Fields );
|
||||
|
||||
}
|
||||
}
|
||||
$nSchTimeNextRun = $dEstimatedDate;
|
||||
|
||||
$this->updateDate( $sSchedulerUid, $nSchTimeNextRun, $nSchLastRunTime );
|
||||
} elseif ($sOption != '5') {
|
||||
$Fields = $this->Load( $sSchedulerUid );
|
||||
@@ -672,7 +608,6 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
$nSchTimeNextRun += $nextRun;
|
||||
$nSchTimeNextRun = date( "Y-m-d H:i", $nSchTimeNextRun );
|
||||
|
||||
|
||||
$this->updateDate( $sSchedulerUid, $nSchTimeNextRun, $nSchLastRunTime );
|
||||
}
|
||||
}
|
||||
@@ -682,15 +617,18 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
|
||||
}
|
||||
|
||||
function updateDate($sSchedulerUid = '', $sSchTimeNextRun = '', $sSchLastRunTime = '') {
|
||||
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 );
|
||||
}
|
||||
|
||||
function updateNextRun($sOption, $sValue = '', $sActualTime = '', $sDaysPerformTask = '', $sWeeks = '', $sStartDay = '', $sMonths = '', $currentDate = '') {
|
||||
$nActualDate = $currentDate . " " . $sActualTime; // date("Y-m-d H:i:s", $sActualTime);
|
||||
public function updateNextRun ($sOption, $sValue = '', $sActualTime = '', $sDaysPerformTask = '', $sWeeks = '', $sStartDay = '', $sMonths = '', $currentDate = '')
|
||||
{
|
||||
$nActualDate = $currentDate . " " . $sActualTime;
|
||||
// date("Y-m-d H:i:s", $sActualTime);
|
||||
// date("Y-m-d H:i:s", $sActualTime);
|
||||
$dEstimatedDate = '';
|
||||
switch ($sOption) {
|
||||
@@ -702,10 +640,12 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
case '2':
|
||||
$nDayOfTheWeek = date( 'w', strtotime( $sActualTime ) );
|
||||
$nDayOfTheWeek = ($nDayOfTheWeek == 0) ? 7 : $nDayOfTheWeek;
|
||||
if ($nDayOfTheWeek >= 5)
|
||||
|
||||
if ($nDayOfTheWeek >= 5) {
|
||||
$dEstimatedDate = date( 'Y-m-d H:i:s', strtotime( "$nActualDate +3 day" ) );
|
||||
else
|
||||
} 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" ) );
|
||||
@@ -715,29 +655,17 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
|
||||
case '2':
|
||||
if (strlen( $sWeeks ) > 0) {
|
||||
|
||||
//die($sActualTime);
|
||||
$nDayOfTheWeek = date( 'w', strtotime( $sActualTime ) );
|
||||
//$nDayOfTheWeek = 1;
|
||||
//echo "*".$nDayOfTheWeek."*";
|
||||
$aWeeks = explode( '|', $sWeeks );
|
||||
$nFirstDay = $aWeeks[0];
|
||||
|
||||
$aDaysWeek = array (
|
||||
'Monday',
|
||||
'Tuesday',
|
||||
'Wednesday',
|
||||
'Thursday',
|
||||
'Friday',
|
||||
'Saturday',
|
||||
'Sunday'
|
||||
);
|
||||
$aDaysWeek = array ('Monday','Tuesday','Wednesday','Thursday','Friday','Saturday','Sunday');
|
||||
$nFirstDay = $nFirstDay - 1;
|
||||
//echo "¨¨".$nFirstDay."¨¨";
|
||||
$nDayOfTheWeek = ($nDayOfTheWeek == 0) ? 7 : $nDayOfTheWeek;
|
||||
//echo $nDayOfTheWeek;
|
||||
|
||||
|
||||
$nSW = 0;
|
||||
$nNextDay = 0;
|
||||
foreach ($aWeeks as $value) {
|
||||
@@ -756,10 +684,12 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
} else {
|
||||
$nEveryDays = $sDaysPerformTask;
|
||||
// $nEveryDays = '1';
|
||||
if ($nFirstDay >= $nDayOfTheWeek || $nEveryDays == 1)
|
||||
if ($nFirstDay >= $nDayOfTheWeek || $nEveryDays == 1) {
|
||||
$sTypeOperation = "next";
|
||||
else
|
||||
} else {
|
||||
$sTypeOperation = "last";
|
||||
}
|
||||
|
||||
if ($nEveryDays == 1) {
|
||||
//echo "**** $nActualDate *" . $sTypeOperation . "* *" . $aDaysWeek[$nFirstDay] . '*****' . date('H:i:s', strtotime($sActualTime)). "**";
|
||||
$dEstimatedDate = date( 'Y-m-d', strtotime( "$nActualDate " . $sTypeOperation . " " . $aDaysWeek[$nFirstDay] ) ) . ' ' . date( 'H:i:s', strtotime( $sActualTime ) );
|
||||
@@ -781,11 +711,8 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
//print_r ($aDaysWeek);
|
||||
//$sTypeOperation = "next";
|
||||
$dEstimatedDate = date( 'Y-m-d', strtotime( "$nDataTmp " . $sTypeOperation . " " . $aDaysWeek[$nFirstDay] ) ) . ' ' . date( 'H:i:s', strtotime( $sActualTime ) );
|
||||
|
||||
//echo (strtotime ("$nDataTmp " . $sTypeOperation . " " . $aDaysWeek[$nFirstDay]));
|
||||
//echo "$nDataTmp " . $sTypeOperation . " " . $aDaysWeek[$nFirstDay];
|
||||
|
||||
|
||||
//echo $dEstimatedDate;
|
||||
//echo "--";
|
||||
//echo date('Y-m-d', strtotime ("$nDataTmp " . $sTypeOperation . " " . $aDaysWeek[$nFirstDay])) . ' ' . date('H:i:s', strtotime($sActualTime));
|
||||
@@ -813,12 +740,14 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if ($nSW == 1) { // Mes encontrado
|
||||
$nExecNextMonth = $nNextMonth;
|
||||
} else {
|
||||
$nExecNextMonth = $aMonths[0] - 1;
|
||||
$nYear ++;
|
||||
}
|
||||
|
||||
switch ($sValue) {
|
||||
case '1':
|
||||
$nExecNextMonth ++;
|
||||
@@ -826,29 +755,8 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
$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'
|
||||
);
|
||||
$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) {
|
||||
@@ -873,7 +781,6 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
}
|
||||
break;
|
||||
}
|
||||
|
||||
$dEstimatedDate = date( 'Y-m-d', strtotime( $sDaysWeekOpt . ' week ' . $aWeeksShort[$sDayWeek - 1] . ' ' . $aMontsShort[$nExecNextMonth] . ' ' . $nYear ) ) . ' ' . date( 'H:i:s', strtotime( $sActualTime ) );
|
||||
// krumo($nExecNextMonth, $sDayWeek);
|
||||
// krumo($sDaysWeekOpt . ' week ' . $aWeeksShort[$sDayWeek-1] . ' ' . $aMontsShort[$nExecNextMonth] . ' ' . $nYear);
|
||||
@@ -883,19 +790,18 @@ class CaseScheduler extends BaseCaseScheduler {
|
||||
}
|
||||
break;
|
||||
}
|
||||
|
||||
return $dEstimatedDate;
|
||||
|
||||
}
|
||||
|
||||
function Exists( $sUid ) {
|
||||
public function Exists ($sUid)
|
||||
{
|
||||
try {
|
||||
$oObj = CaseSchedulerPeer::retrieveByPk( $sUid );
|
||||
return (is_object( $oObj ) && get_class( $oObj ) == 'CaseScheduler');
|
||||
}
|
||||
catch (Exception $oError) {
|
||||
} catch (Exception $oError) {
|
||||
throw ($oError);
|
||||
}
|
||||
}
|
||||
}
|
||||
// CaseScheduler
|
||||
|
||||
} // CaseScheduler
|
||||
|
||||
Reference in New Issue
Block a user