fernando/luos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

CODE STYLE, checking in detail (PART 2)

Browse Source 
FILES:
workflow/engine/classes/model/InputDocument.php
workflow/engine/classes/model/StepTrigger.php
workflow/engine/classes/model/Users.php
workflow/engine/methods/setup/webServicesAjax.php
This commit is contained in:
jennylee
2012-10-19 11:45:05 -04:00
parent 3e18b38e74
commit 2b63d8616b
4 changed files with 2322 additions and 2252 deletions
Download Patch File Download Diff File Expand all files Collapse all files

534
workflow/engine/classes/model/InputDocument.php
View File

@@ -1,11 +1,12 @@
<?php <?php
/** /**
* InputDocument.php * InputDocument.php
* @package workflow.engine.classes.model *
* * @package workflow.engine.classes.model
*
* ProcessMaker Open Source Edition * ProcessMaker Open Source Edition
* Copyright (C) 2004 - 2011 Colosa Inc. * Copyright (C) 2004 - 2011 Colosa Inc.
* *
* This program is free software: you can redistribute it and/or modify * This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as * it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the * published by the Free Software Foundation, either version 3 of the
@@ -13,15 +14,15 @@
* *
* This program is distributed in the hope that it will be useful, * This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of * but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details. * GNU Affero General Public License for more details.
* *
* You should have received a copy of the GNU Affero General Public License * You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>. * along with this program. If not, see <http://www.gnu.org/licenses/>.
* *
* For more information, contact Colosa Inc, 2566 Le Jeune Rd., * For more information, contact Colosa Inc, 2566 Le Jeune Rd.,
* Coral Gables, FL, 33134, USA, or email info@colosa.com. * Coral Gables, FL, 33134, USA, or email info@colosa.com.
* *
*/ */
require_once 'classes/model/om/BaseInputDocument.php'; require_once 'classes/model/om/BaseInputDocument.php';
@@ -33,288 +34,283 @@ require_once 'classes/model/Content.php';
* *
* *
* You should add additional methods to this class to meet the * You should add additional methods to this class to meet the
* application requirements. This class will only be generated as * application requirements. This class will only be generated as
* long as it does not already exist in the input directory. * long as it does not already exist in the input directory.
* *
* @package workflow.engine.classes.model * @package workflow.engine.classes.model
*/ */
class InputDocument extends BaseInputDocument { class InputDocument extends BaseInputDocument
{
/** /**
* This value goes in the content table * This value goes in the content table
* @var string *
*/ * @var string
protected $inp_doc_title = ''; */
protected $inp_doc_title = '';
/** /**
* This value goes in the content table * This value goes in the content table
* @var string *
*/ * @var string
protected $inp_doc_description = ''; */
protected $inp_doc_description = '';
/* /*
* Load the application document registry * Load the application document registry
* @param string $sAppDocUid * @param string $sAppDocUid
* @return variant * @return variant
*/ */
public function load($sInpDocUid) public function load ($sInpDocUid)
{ {
try { try {
$oInputDocument = InputDocumentPeer::retrieveByPK($sInpDocUid); $oInputDocument = InputDocumentPeer::retrieveByPK( $sInpDocUid );
if (!is_null($oInputDocument)) if (! is_null( $oInputDocument )) {
{ $aFields = $oInputDocument->toArray( BasePeer::TYPE_FIELDNAME );
$aFields = $oInputDocument->toArray(BasePeer::TYPE_FIELDNAME); $aFields['INP_DOC_TITLE'] = $oInputDocument->getInpDocTitle();
$aFields['INP_DOC_TITLE'] = $oInputDocument->getInpDocTitle(); $aFields['INP_DOC_DESCRIPTION'] = $oInputDocument->getInpDocDescription();
$aFields['INP_DOC_DESCRIPTION'] = $oInputDocument->getInpDocDescription(); $this->fromArray( $aFields, BasePeer::TYPE_FIELDNAME );
$this->fromArray($aFields, BasePeer::TYPE_FIELDNAME); return $aFields;
return $aFields; } else {
} throw (new Exception( 'This row doesn\'t exist!' ));
else { }
throw(new Exception('This row doesn\'t exist!')); } catch (Exception $oError) {
} throw ($oError);
}
catch (Exception $oError) {
throw($oError);
}
}
public function getByUid($sInpDocUid)
{
try {
$oInputDocument = InputDocumentPeer::retrieveByPK($sInpDocUid);
if( is_null($oInputDocument))
return false;
$aFields = $oInputDocument->toArray(BasePeer::TYPE_FIELDNAME);
$aFields['INP_DOC_TITLE'] = $oInputDocument->getInpDocTitle();
$aFields['INP_DOC_DESCRIPTION'] = $oInputDocument->getInpDocDescription();
$this->fromArray($aFields, BasePeer::TYPE_FIELDNAME);
return $aFields;
}
catch (Exception $oError) {
throw($oError);
}
}
/**
* Create the application document registry
* @param array $aData
* @return string
**/
public function create($aData)
{
$oConnection = Propel::getConnection(InputDocumentPeer::DATABASE_NAME);
try {
if ( isset ( $aData['INP_DOC_UID'] ) && $aData['INP_DOC_UID']== '' )
unset ( $aData['INP_DOC_UID'] );
if ( !isset ( $aData['INP_DOC_UID'] ) )
$aData['INP_DOC_UID'] = G::generateUniqueID();
$oInputDocument = new InputDocument();
$oInputDocument->fromArray($aData, BasePeer::TYPE_FIELDNAME);
if ($oInputDocument->validate()) {
$oConnection->begin();
if (isset($aData['INP_DOC_TITLE'])) {
$oInputDocument->setInpDocTitle($aData['INP_DOC_TITLE']);
} }
if (isset($aData['INP_DOC_DESCRIPTION'])) { }
$oInputDocument->setInpDocDescription($aData['INP_DOC_DESCRIPTION']);
public function getByUid ($sInpDocUid)
{
try {
$oInputDocument = InputDocumentPeer::retrieveByPK( $sInpDocUid );
if (is_null( $oInputDocument )) {
return false;
}
$aFields = $oInputDocument->toArray( BasePeer::TYPE_FIELDNAME );
$aFields['INP_DOC_TITLE'] = $oInputDocument->getInpDocTitle();
$aFields['INP_DOC_DESCRIPTION'] = $oInputDocument->getInpDocDescription();
$this->fromArray( $aFields, BasePeer::TYPE_FIELDNAME );
return $aFields;
} catch (Exception $oError) {
throw ($oError);
} }
$iResult = $oInputDocument->save(); }
$oConnection->commit();
return $aData['INP_DOC_UID']; /**
} * Create the application document registry
else { *
$sMessage = ''; * @param array $aData
$aValidationFailures = $oInputDocument->getValidationFailures(); * @return string
foreach($aValidationFailures as $oValidationFailure) { *
$sMessage .= $oValidationFailure->getMessage() . '<br />'; */
public function create ($aData)
{
$oConnection = Propel::getConnection( InputDocumentPeer::DATABASE_NAME );
try {
if (isset( $aData['INP_DOC_UID'] ) && $aData['INP_DOC_UID'] == '') {
unset( $aData['INP_DOC_UID'] );
}
if (! isset( $aData['INP_DOC_UID'] )) {
$aData['INP_DOC_UID'] = G::generateUniqueID();
}
$oInputDocument = new InputDocument();
$oInputDocument->fromArray( $aData, BasePeer::TYPE_FIELDNAME );
if ($oInputDocument->validate()) {
$oConnection->begin();
if (isset( $aData['INP_DOC_TITLE'] )) {
$oInputDocument->setInpDocTitle( $aData['INP_DOC_TITLE'] );
}
if (isset( $aData['INP_DOC_DESCRIPTION'] )) {
$oInputDocument->setInpDocDescription( $aData['INP_DOC_DESCRIPTION'] );
}
$iResult = $oInputDocument->save();
$oConnection->commit();
return $aData['INP_DOC_UID'];
} else {
$sMessage = '';
$aValidationFailures = $oInputDocument->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);
} }
throw(new Exception('The registry cannot be created!<br />'.$sMessage));
}
} }
catch (Exception $oError) {
$oConnection->rollback();
throw($oError);
}
}
/** /**
* Update the application document registry * Update the application document registry
* @param array $aData *
* @return string * @param array $aData
**/ * @return string
public function update($aData) *
{ */
$oConnection = Propel::getConnection(InputDocumentPeer::DATABASE_NAME); public function update ($aData)
try { {
$oInputDocument = InputDocumentPeer::retrieveByPK($aData['INP_DOC_UID']); $oConnection = Propel::getConnection( InputDocumentPeer::DATABASE_NAME );
if (!is_null($oInputDocument)) try {
{ $oInputDocument = InputDocumentPeer::retrieveByPK( $aData['INP_DOC_UID'] );
$oInputDocument->fromArray($aData, BasePeer::TYPE_FIELDNAME); if (! is_null( $oInputDocument )) {
if ($oInputDocument->validate()) { $oInputDocument->fromArray( $aData, BasePeer::TYPE_FIELDNAME );
$oConnection->begin(); if ($oInputDocument->validate()) {
if (isset($aData['INP_DOC_TITLE'])) $oConnection->begin();
{ if (isset( $aData['INP_DOC_TITLE'] )) {
$oInputDocument->setInpDocTitle($aData['INP_DOC_TITLE']); $oInputDocument->setInpDocTitle( $aData['INP_DOC_TITLE'] );
} }
if (isset($aData['INP_DOC_DESCRIPTION'])) if (isset( $aData['INP_DOC_DESCRIPTION'] )) {
{ $oInputDocument->setInpDocDescription( $aData['INP_DOC_DESCRIPTION'] );
$oInputDocument->setInpDocDescription($aData['INP_DOC_DESCRIPTION']); }
} $iResult = $oInputDocument->save();
$iResult = $oInputDocument->save(); $oConnection->commit();
$oConnection->commit(); return $iResult;
return $iResult; } else {
$sMessage = '';
$aValidationFailures = $oInputDocument->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);
} }
else { }
$sMessage = '';
$aValidationFailures = $oInputDocument->getValidationFailures(); /**
foreach($aValidationFailures as $oValidationFailure) { * Remove the application document registry
$sMessage .= $oValidationFailure->getMessage() . '<br />'; *
} * @param array $aData
throw(new Exception('The registry cannot be updated!<br />'.$sMessage)); * @return string
*
*/
public function remove ($sInpDocUid)
{
$oConnection = Propel::getConnection( InputDocumentPeer::DATABASE_NAME );
try {
$oInputDocument = InputDocumentPeer::retrieveByPK( $sInpDocUid );
if (! is_null( $oInputDocument )) {
$oConnection->begin();
Content::removeContent( 'INP_DOC_TITLE', '', $oInputDocument->getInpDocUid() );
Content::removeContent( 'INP_DOC_DESCRIPTION', '', $oInputDocument->getInpDocUid() );
$iResult = $oInputDocument->delete();
$oConnection->commit();
return $iResult;
} else {
throw (new Exception( 'This row doesn\'t exist!' ));
}
} catch (Exception $oError) {
$oConnection->rollback();
throw ($oError);
} }
}
else {
throw(new Exception('This row doesn\'t exist!'));
}
} }
catch (Exception $oError) {
$oConnection->rollback();
throw($oError);
}
}
/** /**
* Remove the application document registry * Get the [inp_doc_title] column value.
* @param array $aData *
* @return string * @return string
**/ */
public function remove($sInpDocUid) public function getInpDocTitle ()
{ {
$oConnection = Propel::getConnection(InputDocumentPeer::DATABASE_NAME); if ($this->inp_doc_title == '') {
try { try {
$oInputDocument = InputDocumentPeer::retrieveByPK($sInpDocUid); $this->inp_doc_title = Content::load( 'INP_DOC_TITLE', '', $this->getInpDocUid(), (defined( 'SYS_LANG' ) ? SYS_LANG : 'en') );
if (!is_null($oInputDocument)) } catch (Exception $oError) {
{ throw ($oError);
$oConnection->begin(); }
Content::removeContent('INP_DOC_TITLE', '', $oInputDocument->getInpDocUid()); }
Content::removeContent('INP_DOC_DESCRIPTION', '', $oInputDocument->getInpDocUid()); return $this->inp_doc_title;
$iResult = $oInputDocument->delete();
$oConnection->commit();
return $iResult;
}
else {
throw(new Exception('This row doesn\'t exist!'));
}
} }
catch (Exception $oError) {
$oConnection->rollback();
throw($oError);
}
}
/** /**
* Get the [inp_doc_title] column value. * Set the [inp_doc_title] column value.
* @return string *
*/ * @param string $sValue new value
public function getInpDocTitle() * @return void
{ */
if ($this->inp_doc_title == '') { public function setInpDocTitle ($sValue)
try { {
$this->inp_doc_title = Content::load('INP_DOC_TITLE', '', $this->getInpDocUid(), (defined('SYS_LANG') ? SYS_LANG : 'en')); if ($sValue !== null && ! is_string( $sValue )) {
} $sValue = (string) $sValue;
catch (Exception $oError) { }
throw($oError); if ($this->inp_doc_title !== $sValue || $sValue === '') {
} try {
} $this->inp_doc_title = $sValue;
return $this->inp_doc_title;
}
/** $iResult = Content::addContent( 'INP_DOC_TITLE', '', $this->getInpDocUid(), (defined( 'SYS_LANG' ) ? SYS_LANG : 'en'), $this->inp_doc_title );
* Set the [inp_doc_title] column value. } catch (Exception $oError) {
* $this->inp_doc_title = '';
* @param string $sValue new value throw ($oError);
* @return void }
*/ }
public function setInpDocTitle($sValue)
{
if ($sValue !== null && !is_string($sValue)) {
$sValue = (string)$sValue;
} }
if ($this->inp_doc_title !== $sValue || $sValue === '') {
try {
$this->inp_doc_title = $sValue;
$iResult = Content::addContent('INP_DOC_TITLE', '', $this->getInpDocUid(), (defined('SYS_LANG') ? SYS_LANG : 'en'), $this->inp_doc_title);
}
catch (Exception $oError) {
$this->inp_doc_title = '';
throw($oError);
}
}
}
/** /**
* Get the [inp_doc_comment] column value. * Get the [inp_doc_comment] column value.
* @return string *
*/ * @return string
public function getInpDocDescription() */
{ public function getInpDocDescription ()
if ($this->inp_doc_description == '') { {
try { if ($this->inp_doc_description == '') {
$this->inp_doc_description = Content::load('INP_DOC_DESCRIPTION', '', $this->getInpDocUid(), (defined('SYS_LANG') ? SYS_LANG : 'en')); try {
} $this->inp_doc_description = Content::load( 'INP_DOC_DESCRIPTION', '', $this->getInpDocUid(), (defined( 'SYS_LANG' ) ? SYS_LANG : 'en') );
catch (Exception $oError) { } catch (Exception $oError) {
throw($oError); throw ($oError);
} }
}
return $this->inp_doc_description;
} }
return $this->inp_doc_description;
}
/** /**
* Set the [inp_doc_comment] column value. * Set the [inp_doc_comment] column value.
* *
* @param string $sValue new value * @param string $sValue new value
* @return void * @return void
*/ */
public function setInpDocDescription($sValue) public function setInpDocDescription ($sValue)
{ {
if ($sValue !== null && !is_string($sValue)) { if ($sValue !== null && ! is_string( $sValue )) {
$sValue = (string)$sValue; $sValue = (string) $sValue;
} }
if ($this->inp_doc_description !== $sValue || $sValue === '') { if ($this->inp_doc_description !== $sValue || $sValue === '') {
try { try {
$this->inp_doc_description = $sValue; $this->inp_doc_description = $sValue;
$iResult = Content::addContent('INP_DOC_DESCRIPTION', '', $this->getInpDocUid(), (defined('SYS_LANG') ? SYS_LANG : 'en'), $this->inp_doc_description);
}
catch (Exception $oError) {
$this->inp_doc_description = '';
throw($oError);
}
}
}
/** $iResult = Content::addContent( 'INP_DOC_DESCRIPTION', '', $this->getInpDocUid(), (defined( 'SYS_LANG' ) ? SYS_LANG : 'en'), $this->inp_doc_description );
* verify if Input row specified in [DynUid] exists. } catch (Exception $oError) {
* $this->inp_doc_description = '';
* @param string $sUid the uid of the Prolication throw ($oError);
*/ }
}
function InputExists ( $sUid ) {
$con = Propel::getConnection(InputDocumentPeer::DATABASE_NAME);
try {
$oObj = InputDocumentPeer::retrieveByPk( $sUid );
if (is_object($oObj) && get_class ($oObj) == 'InputDocument' ) {
return true;
}
else {
return false;
}
} }
catch (Exception $oError) {
throw($oError);
}
}
} // InputDocument /**
* verify if Input row specified in [DynUid] exists.
*
* @param string $sUid the uid of the Prolication
*/
function InputExists ($sUid)
{
$con = Propel::getConnection( InputDocumentPeer::DATABASE_NAME );
try {
$oObj = InputDocumentPeer::retrieveByPk( $sUid );
if (is_object( $oObj ) && get_class( $oObj ) == 'InputDocument') {
return true;
} else {
return false;
}
} catch (Exception $oError) {
throw ($oError);
}
}
}
// InputDocument

569
workflow/engine/classes/model/StepTrigger.php
View File

@@ -1,11 +1,12 @@
<?php <?php
/** /**
* StepTrigger.php * StepTrigger.php
* @package workflow.engine.classes.model *
* * @package workflow.engine.classes.model
*
* ProcessMaker Open Source Edition * ProcessMaker Open Source Edition
* Copyright (C) 2004 - 2011 Colosa Inc. * Copyright (C) 2004 - 2011 Colosa Inc.
* *
* This program is free software: you can redistribute it and/or modify * This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as * it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the * published by the Free Software Foundation, either version 3 of the
@@ -13,313 +14,293 @@
* *
* This program is distributed in the hope that it will be useful, * This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of * but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details. * GNU Affero General Public License for more details.
* *
* You should have received a copy of the GNU Affero General Public License * You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>. * along with this program. If not, see <http://www.gnu.org/licenses/>.
* *
* For more information, contact Colosa Inc, 2566 Le Jeune Rd., * For more information, contact Colosa Inc, 2566 Le Jeune Rd.,
* Coral Gables, FL, 33134, USA, or email info@colosa.com. * Coral Gables, FL, 33134, USA, or email info@colosa.com.
* *
*/ */
require_once 'classes/model/om/BaseStepTrigger.php'; require_once 'classes/model/om/BaseStepTrigger.php';
/** /**
* Skeleton subclass for representing a row from the 'STEP_TRIGGER' table. * Skeleton subclass for representing a row from the 'STEP_TRIGGER' table.
* *
* *
* *
* You should add additional methods to this class to meet the * You should add additional methods to this class to meet the
* application requirements. This class will only be generated as * application requirements. This class will only be generated as
* long as it does not already exist in the output directory. * long as it does not already exist in the output directory.
* *
* @package workflow.engine.classes.model * @package workflow.engine.classes.model
*/ */
class StepTrigger extends BaseStepTrigger { class StepTrigger extends BaseStepTrigger
function create($aData) {
{
$con = Propel::getConnection(StepTriggerPeer::DATABASE_NAME);
try
{
//delete old StepTrigger Rows, because is not safe insert previous verify old rows.
$criteria = new Criteria();
$criteria->add(StepTriggerPeer::STEP_UID, $aData['STEP_UID'] );
$criteria->add(StepTriggerPeer::TAS_UID, $aData['TAS_UID'] );
$criteria->add(StepTriggerPeer::TRI_UID, $aData['TRI_UID'] );
$criteria->add(StepTriggerPeer::ST_TYPE, $aData['ST_TYPE'] );
$objects = StepTriggerPeer::doSelect($criteria, $con);
$con->begin();
foreach($objects as $row) {
$this->remove($row->getStepUid(), $row->getTasUid(), $row->getTriUid(), $row->getStType() );
}
$con->commit();
$con->begin();
$this->setStepUid($aData['STEP_UID']);
$this->setTasUid($aData['TAS_UID']);
$this->setTriUid($aData['TRI_UID']);
$this->setStType($aData['ST_TYPE']);
$this->setStCondition("");
$this->setStPosition("");
if($this->validate())
{
$result=$this->save();
$con->commit();
return $result;
}
else
{
$con->rollback();
throw( new Exception("Failed Validation in class ".get_class($this)."."));
}
}
catch(Exception $e)
{
$con->rollback();
throw($e);
}
}
public function load($StepUid, $TasUid, $TriUid, $StType)
{
try {
$oRow = StepTriggerPeer::retrieveByPK( $StepUid, $TasUid, $TriUid, $StType );
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 '$StepUid, $TasUid, $TriUid, $StType' in table StepTrigger doesn't exist!" ));
}
}
catch (Exception $oError) {
throw($oError);
}
}
function update($fields)
{
$con = Propel::getConnection(StepTriggerPeer::DATABASE_NAME);
try
{
$con->begin();
$this->load($fields['STEP_UID'],$fields['TAS_UID'],$fields['TRI_UID'],$fields['ST_TYPE']);
$this->fromArray($fields,BasePeer::TYPE_FIELDNAME);
if($this->validate())
{
$result=$this->save();
$con->commit();
return $result;
}
else
{
$con->rollback();
throw(new Exception("Failed Validation in class ".get_class($this)."."));
}
}
catch(Exception $e)
{
$con->rollback();
throw($e);
}
}
function remove($StepUid, $TasUid, $TriUid, $StType)
{
$oConnection = Propel::getConnection(StepTriggerPeer::DATABASE_NAME);
try {
$oStepTrigger = StepTriggerPeer::retrieveByPK($StepUid, $TasUid, $TriUid, $StType);
if (!is_null($oStepTrigger))
{
$oConnection->begin();
$iResult = $oStepTrigger->delete();
$oConnection->commit();
return $iResult;
}
else {
throw(new Exception( "The row '$StepUid, $TasUid, $TriUid, $StType' in table StepTrigger doesn't exist!" ));
}
}
catch (Exception $oError) {
$oConnection->rollback();
throw($oError);
}
}
function stepTriggerExists ($StepUid, $TasUid, $TriUid, $StType) {
$con = Propel::getConnection(StepTriggerPeer::DATABASE_NAME);
try {
$oObj = StepTriggerPeer::retrieveByPk($StepUid, $TasUid, $TriUid, $StType);
if (is_object($oObj) && get_class ($oObj) == 'StepTrigger' ) {
return true;
}
else {
return false;
}
}
catch (Exception $oError) {
throw($oError);
}
}
function removeTrigger($TriUid)
{
$con = Propel::getConnection(StepTriggerPeer::DATABASE_NAME);
try
{
$criteria = new Criteria();
//$criteria->add(StepTriggerPeer::STEP_UID, $step_uid);
//$criteria->add(StepTriggerPeer::TAS_UID, $tas_uid);
$criteria->add(StepTriggerPeer::TRI_UID, $TriUid);
//$criteria->add(StepTriggerPeer::ST_TYPE, $st_type);
$objects = StepTriggerPeer::doSelect($criteria, $con);
$con->begin();
foreach($objects as $v)
{
$this->remove($v->getStepUid,$v->getTasUid,$v->getTriUid,$v->getStType);
}
$con->commit();
return count($objects);
}
catch(Exception $e)
{
$con->rollback();
throw($e);
}
}
function getNextPosition($sStepUID, $sType) {
try {
$oCriteria = new Criteria('workflow');
$oCriteria->addSelectColumn('(COUNT(*) + 1) AS POSITION');
$oCriteria->add(StepTriggerPeer::STEP_UID, $sStepUID);
$oCriteria->add(StepTriggerPeer::ST_TYPE, $sType);
$oDataset = StepTriggerPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
$aRow = $oDataset->getRow();
return (int)$aRow['POSITION'];
}
catch (Exception $oException) {
throw $oException;
}
}
function reOrder($sStepUID, $sTaskUID, $sType, $iPosition) {
try {
$oCriteria = new Criteria('workflow');
$oCriteria->add(StepTriggerPeer::STEP_UID, $sStepUID);
$oCriteria->add(StepTriggerPeer::TAS_UID, $sTaskUID);
$oCriteria->add(StepTriggerPeer::ST_TYPE, $sType);
$oCriteria->add(StepTriggerPeer::ST_POSITION, $iPosition, '>');
$oDataset = StepTriggerPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
$oStep = StepTriggerPeer::retrieveByPK($aRow['STEP_UID'], $aRow['TAS_UID'], $aRow['TRI_UID'], $aRow['ST_TYPE']);
$oStep->setStPosition(($aRow['ST_POSITION']) - 1);
$oStep->save();
$oDataset->next();
}
}
catch (Exception $oException) {
throw $oException;
}
}
function up($sStepUID = '', $sTaskUID = '', $sTriggerUID = '', $sType = '', $iPosition = 0) {
try {
if ($iPosition > 1) {
$oCriteria1 = new Criteria('workflow');
$oCriteria1->add(StepTriggerPeer::ST_POSITION, $iPosition);
$oCriteria2 = new Criteria('workflow');
$oCriteria2->add(StepTriggerPeer::STEP_UID, $sStepUID);
$oCriteria2->add(StepTriggerPeer::TAS_UID, $sTaskUID);
$oCriteria2->add(StepTriggerPeer::ST_TYPE, $sType);
$oCriteria2->add(StepTriggerPeer::ST_POSITION, ($iPosition - 1));
BasePeer::doUpdate($oCriteria2, $oCriteria1, Propel::getConnection('workflow'));
$oCriteria1 = new Criteria('workflow');
$oCriteria1->add(StepTriggerPeer::ST_POSITION, ($iPosition - 1));
$oCriteria2 = new Criteria('workflow');
$oCriteria2->add(StepTriggerPeer::STEP_UID, $sStepUID);
$oCriteria2->add(StepTriggerPeer::TAS_UID, $sTaskUID);
$oCriteria2->add(StepTriggerPeer::TRI_UID, $sTriggerUID);
$oCriteria2->add(StepTriggerPeer::ST_TYPE, $sType);
BasePeer::doUpdate($oCriteria2, $oCriteria1, Propel::getConnection('workflow'));
}
}
catch (Exception $oException) {
throw $oException;
}
}
function down($sStepUID = '', $sTaskUID = '', $sTriggerUID = '', $sType = '', $iPosition = 0) { function create ($aData)
try {
$oCriteria = new Criteria('workflow');
$oCriteria->addSelectColumn('COUNT(*) AS MAX_POSITION');
$oCriteria->add(StepTriggerPeer::STEP_UID, $sStepUID);
$oCriteria->add(StepTriggerPeer::TAS_UID, $sTaskUID);
$oCriteria->add(StepTriggerPeer::ST_TYPE, $sType);
$oDataset = StepTriggerPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
$aRow = $oDataset->getRow();
if ($iPosition < (int)$aRow['MAX_POSITION']) {
$oCriteria1 = new Criteria('workflow');
$oCriteria1->add(StepTriggerPeer::ST_POSITION, $iPosition);
$oCriteria2 = new Criteria('workflow');
$oCriteria2->add(StepTriggerPeer::STEP_UID, $sStepUID);
$oCriteria2->add(StepTriggerPeer::TAS_UID, $sTaskUID);
$oCriteria2->add(StepTriggerPeer::ST_TYPE, $sType);
$oCriteria2->add(StepTriggerPeer::ST_POSITION, ($iPosition + 1));
BasePeer::doUpdate($oCriteria2, $oCriteria1, Propel::getConnection('workflow'));
$oCriteria1 = new Criteria('workflow');
$oCriteria1->add(StepTriggerPeer::ST_POSITION, ($iPosition + 1));
$oCriteria2 = new Criteria('workflow');
$oCriteria2->add(StepTriggerPeer::STEP_UID, $sStepUID);
$oCriteria2->add(StepTriggerPeer::TAS_UID, $sTaskUID);
$oCriteria2->add(StepTriggerPeer::TRI_UID, $sTriggerUID);
$oCriteria2->add(StepTriggerPeer::ST_TYPE, $sType);
BasePeer::doUpdate($oCriteria2, $oCriteria1, Propel::getConnection('workflow'));
}
}
catch (Exception $oException) {
throw $oException;
}
}
function createRow($aData)
{
$con = Propel::getConnection(StepTriggerPeer::DATABASE_NAME);
try
{
$con->begin();
$this->fromArray($aData,BasePeer::TYPE_FIELDNAME);
if($this->validate())
{
$this->setStepUid($aData['STEP_UID']);
$this->setTasUid($aData['TAS_UID']);
$this->setTriUid($aData['TRI_UID']);
$this->setStType($aData['ST_TYPE']);
$this->setStCondition($aData['ST_CONDITION']);
$this->setStPosition($aData['ST_POSITION']);
$result=$this->save();
$con->commit();
return $result;
}
else
{
$con->rollback();
throw( new Exception("Failed Validation in class ".get_class($this)."."));
$e->aValidationFailures=$this->getValidationFailures();
throw($e);
}
}
catch(Exception $e)
{ {
$con->rollback(); $con = Propel::getConnection( StepTriggerPeer::DATABASE_NAME );
throw($e); try {
//delete old StepTrigger Rows, because is not safe insert previous verify old rows.
$criteria = new Criteria();
$criteria->add( StepTriggerPeer::STEP_UID, $aData['STEP_UID'] );
$criteria->add( StepTriggerPeer::TAS_UID, $aData['TAS_UID'] );
$criteria->add( StepTriggerPeer::TRI_UID, $aData['TRI_UID'] );
$criteria->add( StepTriggerPeer::ST_TYPE, $aData['ST_TYPE'] );
$objects = StepTriggerPeer::doSelect( $criteria, $con );
$con->begin();
foreach ($objects as $row) {
$this->remove( $row->getStepUid(), $row->getTasUid(), $row->getTriUid(), $row->getStType() );
}
$con->commit();
$con->begin();
$this->setStepUid( $aData['STEP_UID'] );
$this->setTasUid( $aData['TAS_UID'] );
$this->setTriUid( $aData['TRI_UID'] );
$this->setStType( $aData['ST_TYPE'] );
$this->setStCondition( "" );
$this->setStPosition( "" );
if ($this->validate()) {
$result = $this->save();
$con->commit();
return $result;
} else {
$con->rollback();
throw (new Exception( "Failed Validation in class " . get_class( $this ) . "." ));
}
} catch (Exception $e) {
$con->rollback();
throw ($e);
}
} }
}
} // StepTrigger public function load ($StepUid, $TasUid, $TriUid, $StType)
{
try {
$oRow = StepTriggerPeer::retrieveByPK( $StepUid, $TasUid, $TriUid, $StType );
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 '$StepUid, $TasUid, $TriUid, $StType' in table StepTrigger doesn't exist!" ));
}
} catch (Exception $oError) {
throw ($oError);
}
}
function update ($fields)
{
$con = Propel::getConnection( StepTriggerPeer::DATABASE_NAME );
try {
$con->begin();
$this->load( $fields['STEP_UID'], $fields['TAS_UID'], $fields['TRI_UID'], $fields['ST_TYPE'] );
$this->fromArray( $fields, BasePeer::TYPE_FIELDNAME );
if ($this->validate()) {
$result = $this->save();
$con->commit();
return $result;
} else {
$con->rollback();
throw (new Exception( "Failed Validation in class " . get_class( $this ) . "." ));
}
} catch (Exception $e) {
$con->rollback();
throw ($e);
}
}
function remove ($StepUid, $TasUid, $TriUid, $StType)
{
$oConnection = Propel::getConnection( StepTriggerPeer::DATABASE_NAME );
try {
$oStepTrigger = StepTriggerPeer::retrieveByPK( $StepUid, $TasUid, $TriUid, $StType );
if (! is_null( $oStepTrigger )) {
$oConnection->begin();
$iResult = $oStepTrigger->delete();
$oConnection->commit();
return $iResult;
} else {
throw (new Exception( "The row '$StepUid, $TasUid, $TriUid, $StType' in table StepTrigger doesn't exist!" ));
}
} catch (Exception $oError) {
$oConnection->rollback();
throw ($oError);
}
}
function stepTriggerExists ($StepUid, $TasUid, $TriUid, $StType)
{
$con = Propel::getConnection( StepTriggerPeer::DATABASE_NAME );
try {
$oObj = StepTriggerPeer::retrieveByPk( $StepUid, $TasUid, $TriUid, $StType );
if (is_object( $oObj ) && get_class( $oObj ) == 'StepTrigger') {
return true;
} else {
return false;
}
} catch (Exception $oError) {
throw ($oError);
}
}
function removeTrigger ($TriUid)
{
$con = Propel::getConnection( StepTriggerPeer::DATABASE_NAME );
try {
$criteria = new Criteria();
//$criteria->add(StepTriggerPeer::STEP_UID, $step_uid);
//$criteria->add(StepTriggerPeer::TAS_UID, $tas_uid);
$criteria->add( StepTriggerPeer::TRI_UID, $TriUid );
//$criteria->add(StepTriggerPeer::ST_TYPE, $st_type);
$objects = StepTriggerPeer::doSelect( $criteria, $con );
$con->begin();
foreach ($objects as $v) {
$this->remove( $v->getStepUid, $v->getTasUid, $v->getTriUid, $v->getStType );
}
$con->commit();
return count( $objects );
} catch (Exception $e) {
$con->rollback();
throw ($e);
}
}
function getNextPosition ($sStepUID, $sType)
{
try {
$oCriteria = new Criteria( 'workflow' );
$oCriteria->addSelectColumn( '(COUNT(*) + 1) AS POSITION' );
$oCriteria->add( StepTriggerPeer::STEP_UID, $sStepUID );
$oCriteria->add( StepTriggerPeer::ST_TYPE, $sType );
$oDataset = StepTriggerPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
$aRow = $oDataset->getRow();
return (int) $aRow['POSITION'];
} catch (Exception $oException) {
throw $oException;
}
}
function reOrder ($sStepUID, $sTaskUID, $sType, $iPosition)
{
try {
$oCriteria = new Criteria( 'workflow' );
$oCriteria->add( StepTriggerPeer::STEP_UID, $sStepUID );
$oCriteria->add( StepTriggerPeer::TAS_UID, $sTaskUID );
$oCriteria->add( StepTriggerPeer::ST_TYPE, $sType );
$oCriteria->add( StepTriggerPeer::ST_POSITION, $iPosition, '>' );
$oDataset = StepTriggerPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
while ($aRow = $oDataset->getRow()) {
$oStep = StepTriggerPeer::retrieveByPK( $aRow['STEP_UID'], $aRow['TAS_UID'], $aRow['TRI_UID'], $aRow['ST_TYPE'] );
$oStep->setStPosition( ($aRow['ST_POSITION']) - 1 );
$oStep->save();
$oDataset->next();
}
} catch (Exception $oException) {
throw $oException;
}
}
function up ($sStepUID = '', $sTaskUID = '', $sTriggerUID = '', $sType = '', $iPosition = 0)
{
try {
if ($iPosition > 1) {
$oCriteria1 = new Criteria( 'workflow' );
$oCriteria1->add( StepTriggerPeer::ST_POSITION, $iPosition );
$oCriteria2 = new Criteria( 'workflow' );
$oCriteria2->add( StepTriggerPeer::STEP_UID, $sStepUID );
$oCriteria2->add( StepTriggerPeer::TAS_UID, $sTaskUID );
$oCriteria2->add( StepTriggerPeer::ST_TYPE, $sType );
$oCriteria2->add( StepTriggerPeer::ST_POSITION, ($iPosition - 1) );
BasePeer::doUpdate( $oCriteria2, $oCriteria1, Propel::getConnection( 'workflow' ) );
$oCriteria1 = new Criteria( 'workflow' );
$oCriteria1->add( StepTriggerPeer::ST_POSITION, ($iPosition - 1) );
$oCriteria2 = new Criteria( 'workflow' );
$oCriteria2->add( StepTriggerPeer::STEP_UID, $sStepUID );
$oCriteria2->add( StepTriggerPeer::TAS_UID, $sTaskUID );
$oCriteria2->add( StepTriggerPeer::TRI_UID, $sTriggerUID );
$oCriteria2->add( StepTriggerPeer::ST_TYPE, $sType );
BasePeer::doUpdate( $oCriteria2, $oCriteria1, Propel::getConnection( 'workflow' ) );
}
} catch (Exception $oException) {
throw $oException;
}
}
function down ($sStepUID = '', $sTaskUID = '', $sTriggerUID = '', $sType = '', $iPosition = 0)
{
try {
$oCriteria = new Criteria( 'workflow' );
$oCriteria->addSelectColumn( 'COUNT(*) AS MAX_POSITION' );
$oCriteria->add( StepTriggerPeer::STEP_UID, $sStepUID );
$oCriteria->add( StepTriggerPeer::TAS_UID, $sTaskUID );
$oCriteria->add( StepTriggerPeer::ST_TYPE, $sType );
$oDataset = StepTriggerPeer::doSelectRS( $oCriteria );
$oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$oDataset->next();
$aRow = $oDataset->getRow();
if ($iPosition < (int) $aRow['MAX_POSITION']) {
$oCriteria1 = new Criteria( 'workflow' );
$oCriteria1->add( StepTriggerPeer::ST_POSITION, $iPosition );
$oCriteria2 = new Criteria( 'workflow' );
$oCriteria2->add( StepTriggerPeer::STEP_UID, $sStepUID );
$oCriteria2->add( StepTriggerPeer::TAS_UID, $sTaskUID );
$oCriteria2->add( StepTriggerPeer::ST_TYPE, $sType );
$oCriteria2->add( StepTriggerPeer::ST_POSITION, ($iPosition + 1) );
BasePeer::doUpdate( $oCriteria2, $oCriteria1, Propel::getConnection( 'workflow' ) );
$oCriteria1 = new Criteria( 'workflow' );
$oCriteria1->add( StepTriggerPeer::ST_POSITION, ($iPosition + 1) );
$oCriteria2 = new Criteria( 'workflow' );
$oCriteria2->add( StepTriggerPeer::STEP_UID, $sStepUID );
$oCriteria2->add( StepTriggerPeer::TAS_UID, $sTaskUID );
$oCriteria2->add( StepTriggerPeer::TRI_UID, $sTriggerUID );
$oCriteria2->add( StepTriggerPeer::ST_TYPE, $sType );
BasePeer::doUpdate( $oCriteria2, $oCriteria1, Propel::getConnection( 'workflow' ) );
}
} catch (Exception $oException) {
throw $oException;
}
}
function createRow ($aData)
{
$con = Propel::getConnection( StepTriggerPeer::DATABASE_NAME );
try {
$con->begin();
$this->fromArray( $aData, BasePeer::TYPE_FIELDNAME );
if ($this->validate()) {
$this->setStepUid( $aData['STEP_UID'] );
$this->setTasUid( $aData['TAS_UID'] );
$this->setTriUid( $aData['TRI_UID'] );
$this->setStType( $aData['ST_TYPE'] );
$this->setStCondition( $aData['ST_CONDITION'] );
$this->setStPosition( $aData['ST_POSITION'] );
$result = $this->save();
$con->commit();
return $result;
} else {
$con->rollback();
throw (new Exception( "Failed Validation in class " . get_class( $this ) . "." ));
$e->aValidationFailures = $this->getValidationFailures();
throw ($e);
}
} catch (Exception $e) {
$con->rollback();
throw ($e);
}
}
}
// StepTrigger

559
workflow/engine/classes/model/Users.php
View File

@@ -1,7 +1,8 @@
<?php <?php
/** /**
* Users.php * Users.php
* @package workflow.engine.classes.model *
* @package workflow.engine.classes.model
* *
* ProcessMaker Open Source Edition * ProcessMaker Open Source Edition
* Copyright (C) 2004 - 2011 Colosa Inc. * Copyright (C) 2004 - 2011 Colosa Inc.
@@ -13,11 +14,11 @@
* *
* This program is distributed in the hope that it will be useful, * This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of * but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details. * GNU Affero General Public License for more details.
* *
* You should have received a copy of the GNU Affero General Public License * You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>. * along with this program. If not, see <http://www.gnu.org/licenses/>.
* *
* For more information, contact Colosa Inc, 2566 Le Jeune Rd., * For more information, contact Colosa Inc, 2566 Le Jeune Rd.,
* Coral Gables, FL, 33134, USA, or email info@colosa.com. * Coral Gables, FL, 33134, USA, or email info@colosa.com.
@@ -35,126 +36,110 @@ require_once 'classes/model/IsoLocation.php';
* *
* *
* You should add additional methods to this class to meet the * You should add additional methods to this class to meet the
* application requirements. This class will only be generated as * application requirements. This class will only be generated as
* long as it does not already exist in the output directory. * long as it does not already exist in the output directory.
* *
* @package workflow.engine.classes.model * @package workflow.engine.classes.model
*/ */
class Users extends BaseUsers { class Users extends BaseUsers
function create ($aData) {
{
$con = Propel::getConnection(UsersPeer::DATABASE_NAME); function create ($aData)
try
{ {
$this->fromArray($aData, BasePeer::TYPE_FIELDNAME); $con = Propel::getConnection( UsersPeer::DATABASE_NAME );
if($this->validate()) try {
{ $this->fromArray( $aData, BasePeer::TYPE_FIELDNAME );
$result=$this->save(); if ($this->validate()) {
} $result = $this->save();
else } else {
{ $e = new Exception( "Failed Validation in class " . get_class( $this ) . "." );
$e=new Exception("Failed Validation in class ".get_class($this)."."); $e->aValidationFailures = $this->getValidationFailures();
$e->aValidationFailures=$this->getValidationFailures(); throw ($e);
throw($e); }
} $con->commit();
$con->commit(); return $result;
return $result; } catch (Exception $e) {
$con->rollback();
throw ($e);
}
} }
catch(Exception $e)
{
$con->rollback();
throw($e);
}
}
public function userExists($UsrUid) public function userExists ($UsrUid)
{
try {
$oRow = UsersPeer::retrieveByPK( $UsrUid );
if (!is_null($oRow))
{
return true;
}
else {
return false;
}
}
catch (Exception $oError) {
return false;
}
}
public function load($UsrUid)
{
try {
$oRow = UsersPeer::retrieveByPK( $UsrUid );
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 '" . $UsrUid . "' in table USER doesn't exist!" ));
}
}
catch (PropelException $e){ //capture invalid birthday date and replace by null
$msg = $e->getMessage();
if (strpos('Unable to parse value of [usr_birthday]', $msg) != -1) {
$oRow->setUsrBirthday(null);
$oRow->save();
return $this->load($UsrUid);
}
}
catch (Exception $oError) {
throw($oError);
}
}
public function loadDetails($UsrUid)
{
try {
$result = array();
$oUser = UsersPeer::retrieveByPK( $UsrUid );
if (!is_null($oUser)) {
$result['USR_UID'] = $oUser->getUsrUid();
$result['USR_USERNAME'] = $oUser->getUsrUsername();
$result['USR_FULLNAME'] = $oUser->getUsrFirstname() . ' ' . $oUser->getUsrLastname() ;
$result['USR_EMAIL'] = $oUser->getUsrEmail();
return $result;
}
else {
// return $result;
throw(new Exception( "The row '" . $UsrUid . "' in table USER doesn't exist!" ));
}
}
catch (Exception $oError) {
throw($oError);
}
}
public function loadDetailed($UsrUid)
{ {
try { try {
$result = array(); $oRow = UsersPeer::retrieveByPK( $UsrUid );
$oUser = UsersPeer::retrieveByPK($UsrUid); if (! is_null( $oRow )) {
return true;
} else {
return false;
}
} catch (Exception $oError) {
return false;
}
}
if (!is_null($oUser)) { public function load ($UsrUid)
$aFields = $oUser->toArray(BasePeer::TYPE_FIELDNAME); {
$this->fromArray($aFields,BasePeer::TYPE_FIELDNAME); try {
$this->setNew(false); $oRow = UsersPeer::retrieveByPK( $UsrUid );
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 '" . $UsrUid . "' in table USER doesn't exist!" ));
}
} catch (PropelException $e) {
//capture invalid birthday date and replace by null
$msg = $e->getMessage();
if (strpos( 'Unable to parse value of [usr_birthday]', $msg ) != - 1) {
$oRow->setUsrBirthday( null );
$oRow->save();
return $this->load( $UsrUid );
}
} catch (Exception $oError) {
throw ($oError);
}
}
$aIsoCountry = IsoCountry::findById($aFields['USR_COUNTRY']); public function loadDetails ($UsrUid)
$aIsoSubdivision = IsoSubdivision::findById($aFields['USR_COUNTRY'], $aFields['USR_CITY']); {
$aIsoLocation = IsoLocation::findById( try {
$aFields['USR_COUNTRY'], $result = array ();
$aFields['USR_CITY'], $oUser = UsersPeer::retrieveByPK( $UsrUid );
$aFields['USR_LOCATION'] if (! is_null( $oUser )) {
); $result['USR_UID'] = $oUser->getUsrUid();
$result['USR_USERNAME'] = $oUser->getUsrUsername();
$result['USR_FULLNAME'] = $oUser->getUsrFirstname() . ' ' . $oUser->getUsrLastname();
$result['USR_EMAIL'] = $oUser->getUsrEmail();
return $result;
} else {
// return $result;
throw (new Exception( "The row '" . $UsrUid . "' in table USER doesn't exist!" ));
}
} catch (Exception $oError) {
throw ($oError);
}
}
$aFields['USR_COUNTRY_NAME'] = $aIsoCountry['IC_NAME']; public function loadDetailed ($UsrUid)
$aFields['USR_CITY_NAME'] = $aIsoSubdivision['IS_NAME']; {
try {
$result = array ();
$oUser = UsersPeer::retrieveByPK( $UsrUid );
if (! is_null( $oUser )) {
$aFields = $oUser->toArray( BasePeer::TYPE_FIELDNAME );
$this->fromArray( $aFields, BasePeer::TYPE_FIELDNAME );
$this->setNew( false );
$aIsoCountry = IsoCountry::findById( $aFields['USR_COUNTRY'] );
$aIsoSubdivision = IsoSubdivision::findById( $aFields['USR_COUNTRY'], $aFields['USR_CITY'] );
$aIsoLocation = IsoLocation::findById( $aFields['USR_COUNTRY'], $aFields['USR_CITY'], $aFields['USR_LOCATION'] );
$aFields['USR_COUNTRY_NAME'] = $aIsoCountry['IC_NAME'];
$aFields['USR_CITY_NAME'] = $aIsoSubdivision['IS_NAME'];
$aFields['USR_LOCATION_NAME'] = $aIsoLocation['IL_NAME']; $aFields['USR_LOCATION_NAME'] = $aIsoLocation['IL_NAME'];
$result = $aFields; $result = $aFields;
@@ -162,84 +147,77 @@ public function userExists($UsrUid)
return $result; return $result;
} else { } else {
//return $result; //return $result;
throw (new Exception("The row '" . $UsrUid . "' in table USER doesn't exist!")); throw (new Exception( "The row '" . $UsrUid . "' in table USER doesn't exist!" ));
} }
} catch (Exception $oError) { } catch (Exception $oError) {
throw ($oError); throw ($oError);
} }
} }
public function update($fields) public function update ($fields)
{
$con = Propel::getConnection(UsersPeer::DATABASE_NAME);
try
{ {
$con->begin(); $con = Propel::getConnection( UsersPeer::DATABASE_NAME );
$this->load($fields['USR_UID']); try {
$this->fromArray($fields,BasePeer::TYPE_FIELDNAME); $con->begin();
if($this->validate()) $this->load( $fields['USR_UID'] );
{ $this->fromArray( $fields, BasePeer::TYPE_FIELDNAME );
$result=$this->save(); if ($this->validate()) {
$con->commit(); $result = $this->save();
return $result; $con->commit();
} return $result;
else } else {
{ $con->rollback();
$con->rollback(); throw (new Exception( "Failed Validation in class " . get_class( $this ) . "." ));
throw(new Exception("Failed Validation in class ".get_class($this).".")); }
} } catch (Exception $e) {
$con->rollback();
throw ($e);
}
} }
catch(Exception $e)
function remove ($UsrUid)
{ {
$con->rollback(); $con = Propel::getConnection( UsersPeer::DATABASE_NAME );
throw($e); try {
$con->begin();
$this->setUsrUid( $UsrUid );
$result = $this->delete();
$con->commit();
return $result;
} catch (Exception $e) {
$con->rollback();
throw ($e);
}
} }
}
function remove($UsrUid) function loadByUsername ($sUsername)
{
$con = Propel::getConnection(UsersPeer::DATABASE_NAME);
try
{ {
$con->begin(); $c = new Criteria( 'workflow' );
$this->setUsrUid($UsrUid); $del = DBAdapter::getStringDelimiter();
$result=$this->delete();
$con->commit(); $c->clearSelectColumns();
return $result; $c->addSelectColumn( UsersPeer::USR_UID );
$c->addSelectColumn( UsersPeer::USR_USERNAME );
$c->addSelectColumn( UsersPeer::USR_STATUS );
$c->add( UsersPeer::USR_USERNAME, $sUsername );
return $c;
} }
catch(Exception $e)
function loadByUsernameInArray ($sUsername)
{ {
$con->rollback(); $c = $this->loadByUsername( $sUsername );
throw($e); $rs = UsersPeer::doSelectRS( $c );
$rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$rs->next();
$row = $rs->getRow();
return $row;
} }
}
function loadByUsername($sUsername) public function getAllInformation ($userUid)
{
$c = new Criteria('workflow');
$del = DBAdapter::getStringDelimiter();
$c->clearSelectColumns();
$c->addSelectColumn( UsersPeer::USR_UID );
$c->addSelectColumn( UsersPeer::USR_USERNAME );
$c->addSelectColumn( UsersPeer::USR_STATUS );
$c->add(UsersPeer::USR_USERNAME, $sUsername);
return $c;
}
function loadByUsernameInArray($sUsername){
$c = $this->loadByUsername($sUsername);
$rs = UsersPeer::doSelectRS($c);
$rs->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$rs->next();
$row = $rs->getRow();
return $row;
}
public function getAllInformation($userUid)
{ {
if (!isset($userUid) || $userUid == "") { if (! isset( $userUid ) || $userUid == "") {
throw (new Exception("$userUid is empty.")); throw (new Exception( "$userUid is empty." ));
} }
try { try {
@@ -248,69 +226,69 @@ public function userExists($UsrUid)
require_once ("classes/model/IsoSubdivision.php"); require_once ("classes/model/IsoSubdivision.php");
require_once ("classes/model/Language.php"); require_once ("classes/model/Language.php");
G::LoadClass("calendar"); G::LoadClass( "calendar" );
$aFields = $this->load($userUid); $aFields = $this->load( $userUid );
$c = new Criteria("workflow"); $c = new Criteria( "workflow" );
$c->add(IsoCountryPeer::IC_UID, $aFields["USR_COUNTRY"]); $c->add( IsoCountryPeer::IC_UID, $aFields["USR_COUNTRY"] );
$rs = IsoCountryPeer::doSelectRS($c); $rs = IsoCountryPeer::doSelectRS( $c );
$rs->setFetchmode(ResultSet::FETCHMODE_ASSOC); $rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$rs->next(); $rs->next();
$rowC = $rs->getRow(); $rowC = $rs->getRow();
$c->clearSelectColumns(); $c->clearSelectColumns();
$c->add(IsoSubdivisionPeer::IC_UID, $aFields["USR_COUNTRY"]); $c->add( IsoSubdivisionPeer::IC_UID, $aFields["USR_COUNTRY"] );
$c->add(IsoSubdivisionPeer::IS_UID, $aFields["USR_CITY"]); $c->add( IsoSubdivisionPeer::IS_UID, $aFields["USR_CITY"] );
$rs = IsoSubdivisionPeer::doSelectRS($c); $rs = IsoSubdivisionPeer::doSelectRS( $c );
$rs->setFetchmode(ResultSet::FETCHMODE_ASSOC); $rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$rs->next(); $rs->next();
$rowS = $rs->getRow(); $rowS = $rs->getRow();
$c->clearSelectColumns(); $c->clearSelectColumns();
$c->add(IsoLocationPeer::IC_UID, $aFields["USR_COUNTRY"]); $c->add( IsoLocationPeer::IC_UID, $aFields["USR_COUNTRY"] );
$c->add(IsoLocationPeer::IL_UID, $aFields["USR_LOCATION"]); $c->add( IsoLocationPeer::IL_UID, $aFields["USR_LOCATION"] );
$rs = IsoLocationPeer::doSelectRS($c); $rs = IsoLocationPeer::doSelectRS( $c );
$rs->setFetchmode(ResultSet::FETCHMODE_ASSOC); $rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$rs->next(); $rs->next();
$rowL = $rs->getRow(); $rowL = $rs->getRow();
//Calendar //Calendar
$calendar = new Calendar(); $calendar = new Calendar();
$calendarInfo = $calendar->getCalendarFor($userUid, $userUid, $userUid); $calendarInfo = $calendar->getCalendarFor( $userUid, $userUid, $userUid );
$aFields["USR_CALENDAR"] = ($calendarInfo["CALENDAR_APPLIED"] != "DEFAULT")? $calendarInfo["CALENDAR_UID"] : ""; $aFields["USR_CALENDAR"] = ($calendarInfo["CALENDAR_APPLIED"] != "DEFAULT") ? $calendarInfo["CALENDAR_UID"] : "";
//Photo //Photo
$pathPhoto = PATH_IMAGES_ENVIRONMENT_USERS . $userUid . ".gif"; $pathPhoto = PATH_IMAGES_ENVIRONMENT_USERS . $userUid . ".gif";
if (!file_exists($pathPhoto)) { if (! file_exists( $pathPhoto )) {
$pathPhoto = PATH_HOME . "public_html" . PATH_SEP . "images" . PATH_SEP . "user.gif"; $pathPhoto = PATH_HOME . "public_html" . PATH_SEP . "images" . PATH_SEP . "user.gif";
} }
//Data //Data
$arrayData = array(); $arrayData = array ();
$arrayData["username"] = $aFields["USR_USERNAME"]; $arrayData["username"] = $aFields["USR_USERNAME"];
$arrayData["firstname"] = $aFields["USR_FIRSTNAME"]; $arrayData["firstname"] = $aFields["USR_FIRSTNAME"];
$arrayData["lastname"] = $aFields["USR_LASTNAME"]; $arrayData["lastname"] = $aFields["USR_LASTNAME"];
$arrayData["mail"] = $aFields["USR_EMAIL"]; $arrayData["mail"] = $aFields["USR_EMAIL"];
$arrayData["address"] = $aFields["USR_ADDRESS"]; $arrayData["address"] = $aFields["USR_ADDRESS"];
$arrayData["zipcode"] = $aFields["USR_ZIP_CODE"]; $arrayData["zipcode"] = $aFields["USR_ZIP_CODE"];
$arrayData["country"] = $rowC["IC_NAME"]; $arrayData["country"] = $rowC["IC_NAME"];
$arrayData["state"] = $rowS["IS_NAME"]; $arrayData["state"] = $rowS["IS_NAME"];
$arrayData["location"] = $rowL["IL_NAME"]; $arrayData["location"] = $rowL["IL_NAME"];
$arrayData["phone"] = $aFields["USR_PHONE"]; $arrayData["phone"] = $aFields["USR_PHONE"];
$arrayData["fax"] = $aFields["USR_FAX"]; $arrayData["fax"] = $aFields["USR_FAX"];
$arrayData["cellular"] = $aFields["USR_CELLULAR"]; $arrayData["cellular"] = $aFields["USR_CELLULAR"];
$arrayData["birthday"] = $aFields["USR_BIRTHDAY"]; $arrayData["birthday"] = $aFields["USR_BIRTHDAY"];
$arrayData["position"] = $aFields["USR_POSITION"]; $arrayData["position"] = $aFields["USR_POSITION"];
$arrayData["replacedby"] = $aFields["USR_REPLACED_BY"]; $arrayData["replacedby"] = $aFields["USR_REPLACED_BY"];
$arrayData["duedate"] = $aFields["USR_DUE_DATE"]; $arrayData["duedate"] = $aFields["USR_DUE_DATE"];
$arrayData["calendar"] = $aFields["USR_CALENDAR"]; $arrayData["calendar"] = $aFields["USR_CALENDAR"];
$arrayData["status"] = $aFields["USR_STATUS"]; $arrayData["status"] = $aFields["USR_STATUS"];
$arrayData["department"] = $aFields["DEP_UID"]; $arrayData["department"] = $aFields["DEP_UID"];
$arrayData["reportsto"] = $aFields["USR_REPORTS_TO"]; $arrayData["reportsto"] = $aFields["USR_REPORTS_TO"];
$arrayData["userexperience"] = $aFields["USR_UX"]; $arrayData["userexperience"] = $aFields["USR_UX"];
$arrayData["photo"] = $pathPhoto; $arrayData["photo"] = $pathPhoto;
return $arrayData; return $arrayData;
} catch (Exception $e) { } catch (Exception $e) {
@@ -318,102 +296,89 @@ public function userExists($UsrUid)
} }
} }
function getAvailableUsersCriteria($sGroupUID = '') function getAvailableUsersCriteria ($sGroupUID = '')
{
try {
$oCriteria = new Criteria('workflow');
$oCriteria->addSelectColumn(UsersPeer::USR_UID);
$oCriteria->addSelectColumn(UsersPeer::USR_FIRSTNAME);
$oCriteria->addSelectColumn(UsersPeer::USR_LASTNAME);
$oCriteria->add(UsersPeer::USR_STATUS, 'ACTIVE');
return $oCriteria;
}
catch (exception $oError) {
throw ($oError);
}
}
/**
* Get all Active users
*
* @return array of all active users
*/
function getAll($start=null, $limit=null, $search=null)
{
$totalCount = 0;
$criteria = new Criteria('workflow');
$criteria->addSelectColumn(UsersPeer::USR_UID);
$criteria->addSelectColumn(UsersPeer::USR_USERNAME);
$criteria->addSelectColumn(UsersPeer::USR_FIRSTNAME);
$criteria->addSelectColumn(UsersPeer::USR_LASTNAME);
$criteria->add(UsersPeer::USR_STATUS, 'ACTIVE');
$criteria->addAscendingOrderByColumn ( UsersPeer::USR_LASTNAME );
if( $search ) {
$criteria->add(
$criteria->getNewCriterion(
UsersPeer::USR_USERNAME,
"%$search%", Criteria::LIKE
)->addOr(
$criteria->getNewCriterion(
UsersPeer::USR_FIRSTNAME,
"%$search%", Criteria::LIKE
)
)->addOr(
$criteria->getNewCriterion(
UsersPeer::USR_LASTNAME,
"%$search%", Criteria::LIKE
)
)
);
}
$c = clone $criteria;
$c->clearSelectColumns();
$c->addSelectColumn('COUNT(*)');
$dataset = UsersPeer::doSelectRS($c);
$dataset->next();
$rowCount = $dataset->getRow();
if( is_array($rowCount) )
$totalCount = $rowCount[0];
if( $start )
$criteria->setOffset($start);
if( $limit )
$criteria->setLimit($limit);
$rs = UsersPeer::doSelectRS($criteria);
$rs->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$rows = Array();
while( $rs->next() )
$rows[] = $rs->getRow();
$result->data = $rows;
$result->totalCount = $totalCount;
return $result;
}
public function userVacation($UsrUid = "")
{ {
$aFields = array(); try {
$oCriteria = new Criteria( 'workflow' );
$oCriteria->addSelectColumn( UsersPeer::USR_UID );
$oCriteria->addSelectColumn( UsersPeer::USR_FIRSTNAME );
$oCriteria->addSelectColumn( UsersPeer::USR_LASTNAME );
$oCriteria->add( UsersPeer::USR_STATUS, 'ACTIVE' );
return $oCriteria;
} catch (exception $oError) {
throw ($oError);
}
}
/**
* Get all Active users
*
* @return array of all active users
*/
function getAll ($start = null, $limit = null, $search = null)
{
$totalCount = 0;
$criteria = new Criteria( 'workflow' );
$criteria->addSelectColumn( UsersPeer::USR_UID );
$criteria->addSelectColumn( UsersPeer::USR_USERNAME );
$criteria->addSelectColumn( UsersPeer::USR_FIRSTNAME );
$criteria->addSelectColumn( UsersPeer::USR_LASTNAME );
$criteria->add( UsersPeer::USR_STATUS, 'ACTIVE' );
$criteria->addAscendingOrderByColumn( UsersPeer::USR_LASTNAME );
if ($search) {
$criteria->add( $criteria->getNewCriterion( UsersPeer::USR_USERNAME, "%$search%", Criteria::LIKE )->addOr( $criteria->getNewCriterion( UsersPeer::USR_FIRSTNAME, "%$search%", Criteria::LIKE ) )->addOr( $criteria->getNewCriterion( UsersPeer::USR_LASTNAME, "%$search%", Criteria::LIKE ) ) );
}
$c = clone $criteria;
$c->clearSelectColumns();
$c->addSelectColumn( 'COUNT(*)' );
$dataset = UsersPeer::doSelectRS( $c );
$dataset->next();
$rowCount = $dataset->getRow();
if (is_array( $rowCount )) {
$totalCount = $rowCount[0];
}
if ($start) {
$criteria->setOffset( $start );
}
if ($limit) {
$criteria->setLimit( $limit );
}
$rs = UsersPeer::doSelectRS( $criteria );
$rs->setFetchmode( ResultSet::FETCHMODE_ASSOC );
$rows = Array ();
while ($rs->next()) {
$rows[] = $rs->getRow();
}
$result->data = $rows;
$result->totalCount = $totalCount;
return $result;
}
public function userVacation ($UsrUid = "")
{
$aFields = array ();
$cnt = 0; $cnt = 0;
do { do {
if ($UsrUid != "" && $cnt < 100) { if ($UsrUid != "" && $cnt < 100) {
$aFields = $this->load($UsrUid); $aFields = $this->load( $UsrUid );
$UsrUid = $aFields['USR_REPLACED_BY']; $UsrUid = $aFields['USR_REPLACED_BY'];
} else { } else {
break; break;
} }
$cnt++; $cnt ++;
} while ($aFields['USR_STATUS'] != 'ACTIVE'); } while ($aFields['USR_STATUS'] != 'ACTIVE');
return $aFields; return $aFields;
} }
} // Users }
// Users
?>

2912
workflow/engine/methods/setup/webServicesAjax.php
View File

File diff suppressed because it is too large Load Diff