Files
luos/workflow/engine/classes/model/TaskUser.php
2011-01-22 12:20:08 +00:00

132 lines
4.1 KiB
PHP

<?php
/**
* TaskUser.php
*
* ProcessMaker Open Source Edition
* Copyright (C) 2004 - 2008 Colosa Inc.23
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* 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/>.
*
* For more information, contact Colosa Inc, 2566 Le Jeune Rd.,
* Coral Gables, FL, 33134, USA, or email info@colosa.com.
*
*/
require_once 'classes/model/om/BaseTaskUser.php';
require_once 'classes/model/Content.php';
/**
* Skeleton subclass for representing a row from the 'GROUP_USER' 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 input directory.
*
* @package workflow.classes.model
*/
class TaskUser extends BaseTaskUser {
/**
* Create the application document registry
* @param array $aData
* @return string
**/
public function create($aData)
{
$oConnection = Propel::getConnection(TaskUserPeer::DATABASE_NAME);
try {
//delete old TaskUserPeer Rows, because is not safe insert previous verify old rows.
$criteria = new Criteria('workflow');
$criteria->add(TaskUserPeer::TAS_UID, $aData['TAS_UID'] );
$criteria->add(TaskUserPeer::USR_UID, $aData['USR_UID'] );
$criteria->add(TaskUserPeer::TU_TYPE, $aData['TU_TYPE'] );
$criteria->add(TaskUserPeer::TU_RELATION, $aData['TU_RELATION'] );
$objects = TaskUserPeer::doSelect($criteria, $oConnection);
$oConnection->begin();
foreach($objects as $row) {
$this->remove($row->getTasUid(), $row->getUsrUid(), $row->getTuType(), $row->getTuRelation() );
}
$oConnection->commit();
$oTaskUser = new TaskUser();
$oTaskUser->fromArray($aData, BasePeer::TYPE_FIELDNAME);
if ($oTaskUser->validate()) {
$oConnection->begin();
$iResult = $oTaskUser->save();
$oConnection->commit();
return $iResult;
}
else {
$sMessage = '';
$aValidationFailures = $oTaskUser->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);
}
}
/**
* Remove the application document registry
* @param string $sTasUid
* @param string $sUserUid
* @return string
**/
public function remove($sTasUid, $sUserUid, $iType, $iRelation)
{
$oConnection = Propel::getConnection(TaskUserPeer::DATABASE_NAME);
try {
$oTaskUser = TaskUserPeer::retrieveByPK($sTasUid, $sUserUid, $iType, $iRelation);
if (!is_null($oTaskUser))
{
$oConnection->begin();
$iResult = $oTaskUser->delete();
$oConnection->commit();
return $iResult;
}
else {
throw(new Exception('This row doesn\'t exists!'));
}
}
catch (Exception $oError) {
$oConnection->rollback();
throw($oError);
}
}
function TaskUserExists ($sTasUid, $sUserUid, $iType, $iRelation) {
$con = Propel::getConnection(TaskUserPeer::DATABASE_NAME);
try {
$oTaskUser = TaskUserPeer::retrieveByPk($sTasUid, $sUserUid, $iType, $iRelation);
if ( is_object($oTaskUser) && get_class ($oTaskUser) == 'TaskUser' ) {
return true;
}
else {
return false;
}
}
catch (Exception $oError) {
throw($oError);
}
}
} // TaskUser