333 lines
15 KiB
PHP
333 lines
15 KiB
PHP
<?php
|
|
/**
|
|
* AppEvent.php
|
|
*
|
|
* @package workflow.engine.classes.model
|
|
*/
|
|
|
|
//require_once 'classes/model/om/BaseAppEvent.php';
|
|
|
|
/**
|
|
* Skeleton subclass for representing a row from the 'APP_EVENT' 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 AppEvent extends BaseAppEvent
|
|
{
|
|
|
|
public function load ($sApplicationUID, $iDelegation)
|
|
{
|
|
try {
|
|
$oAppEvent = AppEventPeer::retrieveByPK( $sApplicationUID, $iDelegation );
|
|
if (! is_null( $oAppEvent )) {
|
|
$aFields = $oAppEvent->toArray( BasePeer::TYPE_FIELDNAME );
|
|
$this->fromArray( $aFields, BasePeer::TYPE_FIELDNAME );
|
|
return $aFields;
|
|
} else {
|
|
throw (new Exception( 'This row doesn\'t exist!' ));
|
|
}
|
|
} catch (Exception $oError) {
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
public function create ($aData)
|
|
{
|
|
$oConnection = Propel::getConnection( AppEventPeer::DATABASE_NAME );
|
|
try {
|
|
$oAppEvent = new AppEvent();
|
|
$oAppEvent->fromArray( $aData, BasePeer::TYPE_FIELDNAME );
|
|
if ($oAppEvent->validate()) {
|
|
$oConnection->begin();
|
|
$iResult = $oAppEvent->save();
|
|
$oConnection->commit();
|
|
return true;
|
|
} else {
|
|
$sMessage = '';
|
|
$aValidationFailures = $oAppEvent->getValidationFailures();
|
|
foreach ($aValidationFailures as $oValidationFailure) {
|
|
$sMessage .= $oValidationFailure->getMessage() . '<br />';
|
|
}
|
|
throw (new Exception( 'The registry cannot be created!<br />' . $sMessage ));
|
|
}
|
|
} catch (Exception $oError) {
|
|
$oConnection->rollback();
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
public function update ($aData)
|
|
{
|
|
$oConnection = Propel::getConnection( AppEventPeer::DATABASE_NAME );
|
|
try {
|
|
$oAppEvent = AppEventPeer::retrieveByPK( $aData['APP_UID'], $aData['DEL_INDEX'] );
|
|
if (! is_null( $oAppEvent )) {
|
|
$oAppEvent->fromArray( $aData, BasePeer::TYPE_FIELDNAME );
|
|
if ($oAppEvent->validate()) {
|
|
$oConnection->begin();
|
|
$iResult = $oAppEvent->save();
|
|
$oConnection->commit();
|
|
return $iResult;
|
|
} else {
|
|
$sMessage = '';
|
|
$aValidationFailures = $oAppEvent->getValidationFailures();
|
|
foreach ($aValidationFailures as $oValidationFailure) {
|
|
$sMessage .= $oValidationFailure->getMessage() . '<br />';
|
|
}
|
|
throw (new Exception( 'The registry cannot be updated!<br />' . $sMessage ));
|
|
}
|
|
} else {
|
|
throw (new Exception( 'This row doesn\'t exist!' ));
|
|
}
|
|
} catch (Exception $oError) {
|
|
$oConnection->rollback();
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
public function remove ($sApplicationUID, $iDelegation, $sEvnUid)
|
|
{
|
|
$oConnection = Propel::getConnection( AppEventPeer::DATABASE_NAME );
|
|
try {
|
|
$oAppEvent = AppEventPeer::retrieveByPK( $sApplicationUID, $iDelegation, $sEvnUid );
|
|
if (! is_null( $oAppEvent )) {
|
|
$oConnection->begin();
|
|
$iResult = $oAppEvent->delete();
|
|
$oConnection->commit();
|
|
return $iResult;
|
|
} else {
|
|
throw (new Exception( 'This row doesn\'t exist!' ));
|
|
}
|
|
} catch (Exception $oError) {
|
|
$oConnection->rollback();
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
public function getAppEventsCriteria ($sProcessUid = '', $sStatus = '', $EVN_ACTION = '')
|
|
{
|
|
try {
|
|
require_once 'classes/model/Event.php';
|
|
$oCriteria = new Criteria( 'workflow' );
|
|
$oCriteria->addSelectColumn( AppEventPeer::APP_UID );
|
|
$oCriteria->addSelectColumn( AppEventPeer::DEL_INDEX );
|
|
$oCriteria->addSelectColumn( AppEventPeer::EVN_UID );
|
|
$oCriteria->addSelectColumn( AppEventPeer::APP_EVN_ACTION_DATE );
|
|
$oCriteria->addSelectColumn( AppEventPeer::APP_EVN_ATTEMPTS );
|
|
$oCriteria->addSelectColumn( AppEventPeer::APP_EVN_LAST_EXECUTION_DATE );
|
|
$oCriteria->addSelectColumn( AppEventPeer::APP_EVN_STATUS );
|
|
$oCriteria->addSelectColumn( EventPeer::PRO_UID );
|
|
$oCriteria->addSelectColumn( EventPeer::EVN_WHEN_OCCURS );
|
|
$oCriteria->addSelectColumn( EventPeer::EVN_ACTION );
|
|
$oCriteria->addSelectColumn( ApplicationPeer::APP_TITLE );
|
|
$oCriteria->addSelectColumn( TaskPeer::TAS_TITLE );
|
|
$oCriteria->addSelectColumn( ProcessPeer::PRO_TITLE );
|
|
$oCriteria->addAsColumn( 'EVN_DESCRIPTION', 'C1.CON_VALUE' );
|
|
$oCriteria->addAlias( 'C1', 'CONTENT' );
|
|
$oCriteria->addJoin( AppEventPeer::EVN_UID, EventPeer::EVN_UID, Criteria::LEFT_JOIN );
|
|
$del = DBAdapter::getStringDelimiter();
|
|
$aConditions = array ();
|
|
$aConditions[] = array (EventPeer::EVN_UID,'C1.CON_ID'
|
|
);
|
|
$aConditions[] = array ('C1.CON_CATEGORY',$del . 'EVN_DESCRIPTION' . $del
|
|
);
|
|
$aConditions[] = array ('C1.CON_LANG',$del . SYS_LANG . $del
|
|
);
|
|
$oCriteria->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
$aConditions = array ();
|
|
$aConditions[] = array (AppEventPeer::APP_UID,AppDelegationPeer::APP_UID
|
|
);
|
|
$aConditions[] = array (AppEventPeer::DEL_INDEX,AppDelegationPeer::DEL_INDEX
|
|
);
|
|
$oCriteria->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
$aConditions = array ();
|
|
$aConditions[] = array (AppDelegationPeer::TAS_UID,TaskPeer::TAS_UID);
|
|
$oCriteria->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
$oCriteria->addJoin(AppEventPeer::APP_UID, ApplicationPeer::APP_UID, Criteria::LEFT_JOIN);
|
|
$aConditions = array ();
|
|
$aConditions[] = array (AppDelegationPeer::PRO_UID,ProcessPeer::PRO_UID);
|
|
$oCriteria->addJoinMC( $aConditions, Criteria::LEFT_JOIN );
|
|
$oCriteria->add( AppEventPeer::EVN_UID, '', Criteria::NOT_EQUAL );
|
|
if ($sProcessUid != '') {
|
|
$oCriteria->add( EventPeer::PRO_UID, $sProcessUid );
|
|
}
|
|
if ($EVN_ACTION != '') {
|
|
$oCriteria->add( EventPeer::EVN_ACTION, $EVN_ACTION );
|
|
}
|
|
switch ($sStatus) {
|
|
case '':
|
|
//Nothing
|
|
break;
|
|
case 'PENDING':
|
|
$oCriteria->add( AppEventPeer::APP_EVN_STATUS, 'OPEN' );
|
|
break;
|
|
case 'COMPLETED':
|
|
$oCriteria->add( AppEventPeer::APP_EVN_STATUS, 'CLOSE' );
|
|
break;
|
|
}
|
|
//$oCriteria->addDescendingOrderByColumn(AppEventPeer::APP_EVN_ACTION_DATE);
|
|
return $oCriteria;
|
|
} catch (Exception $oError) {
|
|
throw ($oError);
|
|
}
|
|
}
|
|
|
|
public function executeEvents($sNow, $debug = false, &$log = array(), $cron = 0)
|
|
{
|
|
$debug = 1;
|
|
$oCase = new Cases();
|
|
|
|
try {
|
|
$oCriteria = new Criteria('workflow');
|
|
|
|
$oCriteria->addSelectColumn(AppEventPeer::APP_UID);
|
|
$oCriteria->addSelectColumn(AppEventPeer::DEL_INDEX);
|
|
$oCriteria->addSelectColumn(AppEventPeer::EVN_UID);
|
|
$oCriteria->addSelectColumn(AppEventPeer::APP_EVN_ACTION_DATE);
|
|
$oCriteria->addSelectColumn(AppEventPeer::APP_EVN_ATTEMPTS);
|
|
$oCriteria->addSelectColumn(AppEventPeer::APP_EVN_LAST_EXECUTION_DATE);
|
|
$oCriteria->addSelectColumn(AppEventPeer::APP_EVN_STATUS);
|
|
$oCriteria->addSelectColumn(EventPeer::PRO_UID);
|
|
$oCriteria->addSelectColumn(EventPeer::EVN_ACTION);
|
|
$oCriteria->addSelectColumn(EventPeer::TRI_UID);
|
|
$oCriteria->addSelectColumn(EventPeer::EVN_ACTION_PARAMETERS);
|
|
$oCriteria->addSelectColumn(EventPeer::EVN_RELATED_TO);
|
|
$oCriteria->addSelectColumn(AppDelegationPeer::TAS_UID);
|
|
$oCriteria->addSelectColumn(AppDelegationPeer::USR_UID);
|
|
$oCriteria->addSelectColumn(AppDelegationPeer::DEL_TASK_DUE_DATE);
|
|
$oCriteria->addSelectColumn(AppDelegationPeer::DEL_FINISH_DATE);
|
|
|
|
$oCriteria->addJoin(AppEventPeer::EVN_UID, EventPeer::EVN_UID, Criteria::JOIN);
|
|
|
|
$aConditions = array ();
|
|
array_push($aConditions, Array (AppEventPeer::APP_UID,AppDelegationPeer::APP_UID
|
|
));
|
|
array_push($aConditions, Array (AppEventPeer::DEL_INDEX,AppDelegationPeer::DEL_INDEX
|
|
));
|
|
$oCriteria->addJoinMC($aConditions, Criteria::LEFT_JOIN);
|
|
|
|
$oCriteria->addJoin(ApplicationPeer::APP_UID, AppEventPeer::APP_UID);
|
|
|
|
$oCriteria->add(AppDelegationPeer::DEL_FINISH_DATE, null, Criteria::ISNULL);
|
|
$oCriteria->add(AppEventPeer::APP_EVN_STATUS, 'OPEN');
|
|
$oCriteria->add(AppEventPeer::APP_EVN_ACTION_DATE, $sNow, Criteria::LESS_EQUAL);
|
|
|
|
$oDataset = AppEventPeer::doSelectRS($oCriteria);
|
|
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
|
|
|
|
$c = 0;
|
|
while ($oDataset->next()) {
|
|
if ($cron == 1) {
|
|
$arrayCron = unserialize(trim(@file_get_contents(PATH_DATA . "cron")));
|
|
$arrayCron["processcTimeStart"] = time();
|
|
@file_put_contents(PATH_DATA . "cron", serialize($arrayCron));
|
|
}
|
|
|
|
$c ++;
|
|
$aRow = $oDataset->getRow();
|
|
$oTrigger = new Triggers();
|
|
$aFields = $oCase->loadCase($aRow['APP_UID']);
|
|
$oAppEvent = AppEventPeer::retrieveByPK($aRow['APP_UID'], $aRow['DEL_INDEX'], $aRow['EVN_UID']);
|
|
|
|
if ($debug) {
|
|
require_once 'classes/model/Application.php';
|
|
$oApp = ApplicationPeer::retrieveByPk($aRow['APP_UID']);
|
|
$oEv = EventPeer::retrieveByPk($aRow['EVN_UID']);
|
|
$log[] = 'Event ' . $oEv->getEvnDescription() . ' with ID ' . $aRow['EVN_UID'];
|
|
|
|
println("\nOK+ event \"" . $oEv->getEvnDescription() . "\" with ID {} was found");
|
|
println(" - PROCESS................" . $aRow['PRO_UID']);
|
|
println(" - APPLICATION............" . $aRow['APP_UID'] . " CASE #" . $oApp->getAppNumber());
|
|
println(" - ACTION DATE............" . $aRow['APP_EVN_ACTION_DATE']);
|
|
println(" - ATTEMPTS..............." . $aRow['APP_EVN_ATTEMPTS']);
|
|
println(" - INTERVAL WITH TASKS...." . $aRow['EVN_RELATED_TO']);
|
|
}
|
|
|
|
if ($aRow['TRI_UID'] == '') {
|
|
//a rare case when the tri_uid is not set.
|
|
$log[] = " (!) Any trigger was set................................SKIPPED and will be CLOSED";
|
|
if ($debug) {
|
|
println(" (!) Any trigger was set................................SKIPPED and will be CLOSED");
|
|
}
|
|
$oAppEvent->setAppEvnStatus('CLOSE');
|
|
$oAppEvent->save();
|
|
continue;
|
|
}
|
|
|
|
$oTrigger = TriggersPeer::retrieveByPk($aRow['TRI_UID']);
|
|
if (! is_object($oTrigger)) {
|
|
//the trigger record doesn't exist..
|
|
$log[] = ' (!) The trigger ' . $aRow['TRI_UID'] . ' ' . $oTrigger->getTriTitle() . " doesn't exist.......SKIPPED and will be CLOSED";
|
|
if ($debug) {
|
|
println(" (!) The trigger {$aRow['TRI_UID']} {$oTrigger->getTriTitle()} doesn't exist.......SKIPPED and will be CLOSED");
|
|
}
|
|
$oAppEvent->setAppEvnStatus('CLOSE');
|
|
$oAppEvent->save();
|
|
continue;
|
|
}
|
|
|
|
global $oPMScript;
|
|
$oPMScript = new PMScript();
|
|
|
|
$task = new Task();
|
|
$taskFields = $task->load($aRow['TAS_UID']);
|
|
$aFields['APP_DATA']['APP_NUMBER'] = $aFields['APP_NUMBER'];
|
|
$aFields['APP_DATA']['TAS_TITLE'] = $taskFields['TAS_TITLE'];
|
|
$aFields['APP_DATA']['DEL_TASK_DUE_DATE'] = $aRow['DEL_TASK_DUE_DATE'];
|
|
$oPMScript->setDataTrigger($oTrigger->toArray(\BasePeer::TYPE_FIELDNAME));
|
|
$oPMScript->setFields($aFields['APP_DATA']);
|
|
$oPMScript->setScript($oTrigger->getTriWebbot());
|
|
$oPMScript->setExecutedOn(PMScript::CLASSIC_PROCESS_EVENTS);
|
|
$oPMScript->execute();
|
|
|
|
$oAppEvent->setAppEvnLastExecutionDate(date('Y-m-d H:i:s'));
|
|
|
|
if (sizeof($_SESSION['TRIGGER_DEBUG']['ERRORS']) == 0) {
|
|
$log[] = ' - The trigger ' . $oTrigger->getTriTitle() . ' was executed successfully!';
|
|
if ($debug) {
|
|
println(" - The trigger '{$oTrigger->getTriTitle()}' was executed successfully!");
|
|
}
|
|
$aFields['APP_DATA'] = $oPMScript->aFields;
|
|
$oCase->updateCase($aRow['APP_UID'], $aFields);
|
|
$oAppEvent->setAppEvnStatus('CLOSE');
|
|
} else {
|
|
if ($debug) {
|
|
$log[] = ' - The trigger ' . $aRow['TRI_UID'] . ' throw some errors!';
|
|
println(" - The trigger {$aRow['TRI_UID']} throw some errors!");
|
|
print_r($_SESSION['TRIGGER_DEBUG']['ERRORS']);
|
|
$_SESSION['TRIGGER_DEBUG']['ERRORS'] = array();
|
|
}
|
|
if ($oAppEvent->getAppEvnAttempts() > 0) {
|
|
$oAppEvent->setAppEvnAttempts($oAppEvent->getAppEvnAttempts() - 1);
|
|
} else {
|
|
$oAppEvent->setAppEvnStatus('CLOSE');
|
|
}
|
|
}
|
|
$oAppEvent->save();
|
|
}
|
|
return $c;
|
|
} catch (Exception $oError) {
|
|
$log[] = ' Error execute event : ' . $oError->getMessage();
|
|
$token = strtotime("now");
|
|
PMException::registerErrorLog($oError, $token);
|
|
G::outRes(G::LoadTranslation("ID_EXCEPTION_LOG_INTERFAZ", array($token)));
|
|
die;
|
|
return $oError->getMessage();
|
|
}
|
|
}
|
|
|
|
public function close ($APP_UID, $DEL_INDEX)
|
|
{
|
|
$aRow = $this->load( $APP_UID, $DEL_INDEX );
|
|
$aRow['APP_EVN_STATUS'] = 'CLOSE';
|
|
$this->update( $aRow );
|
|
}
|
|
}
|
|
|