fernando/luos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
9df68b530753f16c13e36b90ac47ca7423797afe
luos/workflow/engine/classes/class.derivation.php

1022 lines
43 KiB
PHP
Raw Normal View History

initial commit from rev. 632
2010-12-02 23:34:41 +00:00
<?php
/**
* class.derivation.php
Changes done for PhpDoc
2011-02-01 12:49:40 +00:00
* @package workflow.engine.ProcessMaker
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
*
* ProcessMaker Open Source Edition
Changes done for PhpDoc
2011-02-01 12:49:40 +00:00
* Copyright (C) 2004 - 2011 Colosa Inc.
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
*
* 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/Task.php" );
require_once ( "classes/model/Process.php" );
require_once ( "classes/model/Step.php" );
require_once ( "classes/model/Application.php" );
require_once ( 'classes/model/Groupwf.php' );
require_once ( "classes/model/GroupUser.php" );
require_once ( "classes/model/AppDelegation.php" );
require_once ( "classes/model/Route.php" );
require_once ( 'classes/model/SubApplication.php');
require_once ( 'classes/model/SubProcess.php' );
require_once ( "classes/model/Users.php" );
G::LoadClass( "plugin" );
/**
* derivation - derivation class
Changes done for PhpDoc
2011-02-01 12:49:40 +00:00
* @package workflow.engine.ProcessMaker
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
*
*/
class Derivation
{
var $case;
/**
* prepareInformation
*
* @param array $aData
* @return $taskInfo
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
*/
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
function prepareInformation($aData)
{
$oTask = new Task();
//SELECT *
//FROM APP_DELEGATION AS A
//LEFT JOIN TASK AS T ON(T.TAS_UID = A.TAS_UID)
//LEFT JOIN ROUTE AS R ON(R.TAS_UID = A.TAS_UID)
//WHERE
//APP_UID = '$aData['APP_UID']'
//AND DEL_INDEX = '$aData['DEL_INDEX']'
$c = new Criteria ( 'workflow' );
$c->clearSelectColumns();
$c->addSelectColumn ( AppDelegationPeer::TAS_UID );
$c->addSelectColumn ( RoutePeer::ROU_CONDITION );
$c->addSelectColumn ( RoutePeer::ROU_NEXT_TASK );
$c->addSelectColumn ( RoutePeer::ROU_TYPE );
$c->addJoin ( AppDelegationPeer::TAS_UID, TaskPeer::TAS_UID, Criteria::LEFT_JOIN );
$c->addJoin ( AppDelegationPeer::TAS_UID, RoutePeer::TAS_UID, Criteria::LEFT_JOIN );
$c->add ( AppDelegationPeer::APP_UID, $aData['APP_UID'] );
$c->add ( AppDelegationPeer::DEL_INDEX, $aData['DEL_INDEX'] );
$c->addAscendingOrderByColumn ( RoutePeer::ROU_CASE );
$rs = AppDelegationPeer::doSelectRs ( $c );
$rs->setFetchmode (ResultSet::FETCHMODE_ASSOC);
$rs->next();
$aDerivation = $rs->getRow();
$i = 0;
$taskInfo = array();
$oUser = new Users();
$this->case = new Cases();
// 1. there is no rule
if ( is_null ( $aDerivation['ROU_NEXT_TASK'] ) ) {
throw ( new Exception ( G::LoadTranslation ( 'ID_NO_DERIVATION_RULE') ) );
}
while( is_array( $aDerivation) ) {
$oTask = new Task();
$aDerivation = G::array_merges( $aDerivation, $aData );
$bContinue = true;
//evaluate the condition if there are conditions defined.
Various settings for compatibility with MSSQL
2010-12-23 23:26:41 +00:00
if( isset( $aDerivation['ROU_CONDITION'] ) && trim($aDerivation['ROU_CONDITION']) != ''
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
&& ( $aDerivation['ROU_TYPE'] != 'SELECT' || $aDerivation['ROU_TYPE'] == 'PARALLEL-BY-EVALUATION') ) {
$AppFields = $this->case->loadCase( $aData['APP_UID'] );
G::LoadClass('pmScript');
$oPMScript = new PMScript();
$oPMScript->setFields( $AppFields['APP_DATA'] );
$oPMScript->setScript( $aDerivation['ROU_CONDITION'] );
$bContinue = $oPMScript->evaluate();
}
if ( $aDerivation['ROU_TYPE'] == 'EVALUATE' ) {
if ( count ( $taskInfo) >= 1) {
$bContinue = false;
}
}
if ($bContinue) {
$i++;
$TaskFields = $oTask->load( $aDerivation['TAS_UID'] );
$aDerivation = G::array_merges( $aDerivation, $TaskFields );
//2. if next case is an special case
if ( (int)$aDerivation['ROU_NEXT_TASK'] < 0) {
$aDerivation['NEXT_TASK']['TAS_UID'] = (int)$aDerivation['ROU_NEXT_TASK'];
BUG 6651 this bug was fixed In fact this issue is happening, this is happening when you use "selection" as the routing rule in your task. There were some fields that weren't well defined, I have fixed it and now it works fine.
2011-04-05 11:34:50 -04:00
$aDerivation['NEXT_TASK']['TAS_ASSIGN_TYPE'] = 'nobody';
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
$aDerivation['NEXT_TASK']['TAS_PRIORITY_VARIABLE'] = '';
$aDerivation['NEXT_TASK']['TAS_DEF_PROC_CODE'] = '';
$aDerivation['NEXT_TASK']['TAS_PARENT'] = '';
BUG 6651 this bug was fixed In fact this issue is happening, this is happening when you use "selection" as the routing rule in your task. There were some fields that weren't well defined, I have fixed it and now it works fine.
2011-04-05 11:34:50 -04:00
$aDerivation['NEXT_TASK']['TAS_TRANSFER_FLY'] = '';
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
switch ($aDerivation['ROU_NEXT_TASK']) {
case -1: $aDerivation['NEXT_TASK']['TAS_TITLE'] = G::LoadTranslation('ID_END_OF_PROCESS');
break;
case -2: $aDerivation['NEXT_TASK']['TAS_TITLE'] = G::LoadTranslation('ID_TAREA_COLGANTE');
break;
}
BUG 6651 this bug was fixed In fact this issue is happening, this is happening when you use "selection" as the routing rule in your task. There were some fields that weren't well defined, I have fixed it and now it works fine.
2011-04-05 11:34:50 -04:00
$aDerivation['NEXT_TASK']['USR_UID'] = '';
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
}
else {
//3. load the task information of normal NEXT_TASK
$aDerivation['NEXT_TASK'] = $oTask->load( $aDerivation['ROU_NEXT_TASK'] );//print $aDerivation['ROU_NEXT_TASK']." **** ".$aDerivation['NEXT_TASK']['TAS_TYPE']."<hr>";
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
if ($aDerivation['NEXT_TASK']['TAS_TYPE'] === 'SUBPROCESS') {
$oCriteria = new Criteria('workflow');
$oCriteria->add(SubProcessPeer::PRO_PARENT, $aDerivation['PRO_UID']);
$oCriteria->add(SubProcessPeer::TAS_PARENT, $aDerivation['NEXT_TASK']['TAS_UID']);
$oDataset = SubProcessPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
$aRow = $oDataset->getRow();
$sTaskParent = $aDerivation['NEXT_TASK']['TAS_UID'];
$aDerivation['ROU_NEXT_TASK'] = $aRow['TAS_UID'];//print "<hr>Life is just a lonely highway";
$aDerivation['NEXT_TASK'] = $oTask->load( $aDerivation['ROU_NEXT_TASK'] );//print "<hr>Life is just a lonely highway";print"<hr>";
$oProcess = new Process();
$aRow = $oProcess->load($aRow['PRO_UID']);
$aDerivation['NEXT_TASK']['TAS_TITLE'] .= ' (' . $aRow['PRO_TITLE'] . ')';
$aDerivation['NEXT_TASK']['TAS_PARENT'] = $sTaskParent;
unset($oTask, $oProcess, $aRow, $sTaskParent);
}
else {
$aDerivation['NEXT_TASK']['TAS_PARENT'] = '';
}
$aDerivation['NEXT_TASK']['USER_ASSIGNED'] = $this->getNextAssignedUser($aDerivation);
}
$taskInfo[$i] = $aDerivation;
}
$rs->next();
$aDerivation = $rs->getRow();
}
return $taskInfo;
}
/**
* getRouteCondition
*
* @param array $aData
* @return $routeCondition
*/
function getRouteCondition($aData)
{
//SELECT *
//FROM APP_DELEGATION AS A
//LEFT JOIN TASK AS T ON(T.TAS_UID = A.TAS_UID)
//LEFT JOIN ROUTE AS R ON(R.TAS_UID = A.TAS_UID)
//WHERE
//APP_UID = '$aData['APP_UID']'
//AND DEL_INDEX = '$aData['DEL_INDEX']'
$c = new Criteria ( 'workflow' );
$c->clearSelectColumns();
$c->addSelectColumn ( AppDelegationPeer::TAS_UID );
$c->addSelectColumn ( RoutePeer::ROU_CONDITION );
$c->addSelectColumn ( RoutePeer::ROU_NEXT_TASK );
$c->addSelectColumn ( RoutePeer::ROU_TYPE );
$c->addSelectColumn ( RoutePeer::ROU_OPTIONAL);
$c->addJoin ( AppDelegationPeer::TAS_UID, TaskPeer::TAS_UID, Criteria::LEFT_JOIN );
$c->addJoin ( AppDelegationPeer::TAS_UID, RoutePeer::TAS_UID, Criteria::LEFT_JOIN );
$c->add ( AppDelegationPeer::APP_UID, $aData['APP_UID'] );
$c->add ( AppDelegationPeer::DEL_INDEX, $aData['DEL_INDEX'] );
$c->addAscendingOrderByColumn ( RoutePeer::ROU_CASE );
$rs = AppDelegationPeer::doSelectRs ( $c );
$rs->setFetchmode (ResultSet::FETCHMODE_ASSOC);
$rs->next();
$aDerivation = $rs->getRow();
while( is_array( $aDerivation) ) {
return $aDerivation;
}
}
function GetAppParentIndex($aData)
{
//('SELECT * FROM APP_THREAD WHERE APP_UID='".$aData['APP_UID']."' AND DEL_INDEX = '".$aData['DEL_INDEX']."'");
try {
$aThreads = array();
$c = new Criteria();
$c->addSelectColumn(AppThreadPeer::APP_THREAD_PARENT);
$c->add(AppThreadPeer::APP_UID, $aData['APP_UID']);
$c->add(AppThreadPeer::DEL_INDEX, $aData['DEL_INDEX']);
$rs = AppThreadPeer::doSelectRs($c);
$rs->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$rs->next();
$row = $rs->getRow();
while (is_array($row)) {
$aThreads = $row;
$rs->next();
$row = $rs->getRow();
}
return $aThreads;
}
catch (exception $e) {
throw ($e);
}
}
/* get all users, from any task, if the task have Groups, the function expand the group
*
* @param string $sTasUid the task uidUser
* @return Array $users an array with userID order by USR_UID
*/
function getAllUsersFromAnyTask ( $sTasUid ) {
$users = array();
$c = new Criteria ( 'workflow' );
$c->clearSelectColumns();
$c->addSelectColumn( TaskUserPeer::USR_UID);
$c->addSelectColumn( TaskUserPeer::TU_RELATION);
$c->add ( TaskUserPeer::TAS_UID, $sTasUid);
$c->add ( TaskUserPeer::TU_TYPE, 1);
$rs = TaskUserPeer::DoSelectRs ($c);
$rs->setFetchmode (ResultSet::FETCHMODE_ASSOC);
$rs->next();
$row = $rs->getRow();
while ( is_array ( $row ) ) {
if ( $row['TU_RELATION'] == '2' ) {
$cGrp = new Criteria ('workflow');
$cGrp->add(GroupwfPeer::GRP_STATUS, 'ACTIVE');
$cGrp->add(GroupUserPeer::GRP_UID, $row['USR_UID']);
$cGrp->addJoin(GroupUserPeer::GRP_UID, GroupwfPeer::GRP_UID, Criteria::LEFT_JOIN);
$cGrp->addJoin(GroupUserPeer::USR_UID, UsersPeer::USR_UID, Criteria::LEFT_JOIN);
$cGrp->add(UsersPeer::USR_STATUS, 'ACTIVE');
$rsGrp = GroupUserPeer::DoSelectRs ($cGrp);
$rsGrp->setFetchmode (ResultSet::FETCHMODE_ASSOC);
$rsGrp->next();
$rowGrp = $rsGrp->getRow();
while ( is_array ( $rowGrp ) ) {
$users[$rowGrp['USR_UID']] = $rowGrp['USR_UID'];
$rsGrp->next();
$rowGrp = $rsGrp->getRow();
}
}
else {
//filter to users that is in vacation or has an inactive estatus, and others
$oUser = UsersPeer::retrieveByPK( $row['USR_UID'] );
if( $oUser->getUsrStatus() == 'ACTIVE' ){
$users[$row['USR_UID']] = $row['USR_UID'];
} else if($oUser->getUsrStatus() == 'VACATION'){
//this a litle hook for this issue,...
//TODO if the user in getUsrReplacedBy() is not assignet to the same task,. will have problems,....
$UsrReplace = $oUser->getUsrReplacedBy();
if( trim($UsrReplace) != ''){
//$users[$UsrReplace] = $UsrReplace;
}
}
}
$rs->next();
$row = $rs->getRow();
}
//to do: different types of sort
sort($users);
return $users;
}
/* get an array of users, and returns the same arrays with User's fullname and other fields
*
* @param Array $aUsers the task uidUser
* @return Array $aUsersData an array with with User's fullname
*/
function getUsersFullNameFromArray ( $aUsers ) {
$oUser = new Users();
$aUsersData = array();
if ( is_array ( $aUsers ) ) {
foreach ( $aUsers as $key => $val ) {
$userFields = $oUser->load($val);
$auxFields['USR_UID'] = $userFields['USR_UID'];
$auxFields['USR_USERNAME'] = $userFields['USR_USERNAME'];
$auxFields['USR_FIRSTNAME'] = $userFields['USR_FIRSTNAME'];
$auxFields['USR_LASTNAME'] = $userFields['USR_LASTNAME'];
$auxFields['USR_FULLNAME'] = $userFields['USR_LASTNAME'] . ($userFields['USR_LASTNAME'] != '' ? ', ' : '') . $userFields['USR_FIRSTNAME'];
$auxFields['USR_EMAIL'] = $userFields['USR_EMAIL'];
$auxFields['USR_STATUS'] = $userFields['USR_STATUS'];
$auxFields['USR_COUNTRY'] = $userFields['USR_COUNTRY'];
$auxFields['USR_CITY'] = $userFields['USR_CITY'];
$auxFields['USR_LOCATION'] = $userFields['USR_LOCATION'];
$auxFields['DEP_UID'] = $userFields['DEP_UID'];
$auxFields['USR_HIDDEN_FIELD'] = '';
$aUsersData[] = $auxFields;
}
}
else {
$oCriteria = new Criteria();
$oCriteria->add(UsersPeer::USR_UID, $aUsers);
BUG 6877 the error was fixed (removing a missing debug var) The main problam was that the missing report_to users was not handling correctly but now it work fine
2011-05-12 17:33:21 -04:00
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
if (UsersPeer::doCount($oCriteria) < 1) {
return null;
}
$userFields = $oUser->load( $aUsers );
$auxFields['USR_UID'] = $userFields['USR_UID'];
$auxFields['USR_USERNAME'] = $userFields['USR_USERNAME'];
$auxFields['USR_FIRSTNAME'] = $userFields['USR_FIRSTNAME'];
$auxFields['USR_LASTNAME'] = $userFields['USR_LASTNAME'];
$auxFields['USR_FULLNAME'] = $userFields['USR_LASTNAME'] . ($userFields['USR_LASTNAME'] != '' ? ', ' : '') . $userFields['USR_FIRSTNAME'];
$auxFields['USR_EMAIL'] = $userFields['USR_EMAIL'];
$auxFields['USR_STATUS'] = $userFields['USR_STATUS'];
$auxFields['USR_COUNTRY'] = $userFields['USR_COUNTRY'];
$auxFields['USR_CITY'] = $userFields['USR_CITY'];
$auxFields['USR_LOCATION'] = $userFields['USR_LOCATION'];
$auxFields['DEP_UID'] = $userFields['DEP_UID'];
$aUsersData = $auxFields;
}
return $aUsersData;
}
/* get next assigned user
*
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
* @param Array $tasInfo
* @return Array $userFields
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
*/
function getNextAssignedUser( $tasInfo ){
$oUser = new Users();
$nextAssignedTask = $tasInfo['NEXT_TASK'];
$lastAssigned = $tasInfo['NEXT_TASK']['TAS_LAST_ASSIGNED'];
$sTasUid = $tasInfo['NEXT_TASK']['TAS_UID'];
// to do: we can increase the LOCATION by COUNTRY, STATE and LOCATION
/* Verify if the next Task is set with the option "TAS_ASSIGN_LOCATION == TRUE" */
$assignLocation = '';
if ($tasInfo['NEXT_TASK']['TAS_ASSIGN_LOCATION'] == 'TRUE')
{
$oUser->load( $tasInfo['USER_UID'] );
krumo ($oUser->getUsrLocation() );
//to do: assign for location
//$assignLocation = " AND USR_LOCATION = " . $oUser->Fields['USR_LOCATION'];
}
/* End - Verify if the next Task is set with the option "TAS_ASSIGN_LOCATION == TRUE" */
$uidUser = '';
switch( $nextAssignedTask['TAS_ASSIGN_TYPE'] ) {
case 'BALANCED' :
$users = $this->getAllUsersFromAnyTask ($sTasUid);
if ( is_array( $users) && count( $users ) > 0 ) {
//to do apply any filter like LOCATION assignment
$uidUser = $users[ 0 ];
$i = count($users) -1;
while ( $i > 0 ) {
if ( $lastAssigned < $users[$i] )
$uidUser = $users[ $i ];
$i--;
}
}
else {
throw ( new Exception (G::LoadTranslation( 'ID_NO_USERS' ) ) );
}
$userFields = $this->getUsersFullNameFromArray ($uidUser);
break;
case 'STATIC_MI':
case 'CANCEL_MI':
case 'MANUAL' :
$users = $this->getAllUsersFromAnyTask ($sTasUid);
$userFields = $this->getUsersFullNameFromArray ($users);
break;
case 'EVALUATE' :
$AppFields = $this->case->loadCase( $tasInfo['APP_UID'] );
$variable = str_replace ( '@@', '', $nextAssignedTask['TAS_ASSIGN_VARIABLE'] );
if ( isset ( $AppFields['APP_DATA'][$variable] ) ) {
if ($AppFields['APP_DATA'][$variable] != '') {
$value = $AppFields['APP_DATA'][$variable];
$userFields = $this->getUsersFullNameFromArray ($value);
if (is_null($userFields)) {
throw ( new Exception("Task doesn't have a valid user in variable $variable.") ) ;
}
}
else {
throw ( new Exception("Task doesn't have a valid user in variable $variable.") ) ;
}
}
else
BUG 5004 Change text doesn't exists! All wrong texts like doesn't exists or not exists by doesn't exist
2011-04-13 18:57:02 -04:00
throw ( new Exception("Task doesn't have a valid user in variable $variable or this variable doesn't exist.") ) ;
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
break;
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
case 'REPORT_TO' :
//default error user when the reportsTo is not assigned to that user
//look for USR_REPORTS_TO to this user
$userFields['USR_UID'] = '';
$userFields['USR_FULLNAME'] = 'Current user does not have a valid Reports To user';
$userFields['USR_USERNAME'] = 'Current user does not have a valid Reports To user';
$userFields['USR_FIRSTNAME'] = '';
$userFields['USR_LASTNAME'] = '';
$userFields['USR_EMAIL'] = '';
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
BUG 6877 the error was fixed The main problam was that the missing report_to users was not handling correctly but now it work fine
2011-05-12 17:25:22 -04:00
//get the report_to user & its full info
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
$useruid = $this->getDenpendentUser($tasInfo['USER_UID']);
BUG 6877 the error was fixed The main problam was that the missing report_to users was not handling correctly but now it work fine
2011-05-12 17:25:22 -04:00
if (isset($useruid) && $useruid != '') {
$userFields = $this->getUsersFullNameFromArray($useruid);
}
// if there is no report_to user info, throw an exception indicating this
if (!isset($userFields) || $userFields['USR_UID'] == '') {
BUG 8932 Untranslatable strings Information process Information... SOLVED - It was found that had several labels that are hardcoded. - Changed hardcoded labels reusing some existing labels and some things were created some labels. - labels created: ID_INIT_DATE(Init Date), ID_OVERWRITE(Overwrite),ID_BROWSE(Browse),ID_UPLOADING_TRANSLATION_FILE(Uploading the translation file...), ID_EVALUATION_RESULT ([Success] Evaluation result) - Labels reused: ID_TITLE, ID_DESCRIPTION, ID_DUE_DATE, ID_FINISH_DATE, ID_SEND, ID_UPLOADED_DOCUMENTS, ID_GENERATED_DOCUMENTS, ID_FILE, ID_FIRST_NAME, ID_LAST_NAME,ID_ACTIVE,ID_INACTIVE, ID_MSJ_REPORSTO - image for Starting a case ... it is labeled translation.ID_TITLE_START_CASE which works only if you change the language to es-ES -
2012-04-12 09:07:31 -04:00
throw ( new Exception(G::LoadTranslation('ID_MSJ_REPORSTO')));// "The current user does not have a valid Reports To user. Please contact administrator.") ) ;
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
}
break;
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
case 'SELF_SERVICE' :
//look for USR_REPORTS_TO to this user
$userFields['USR_UID'] = '';
$userFields['USR_FULLNAME'] = '<b>' . G::LoadTranslation('ID_UNASSIGNED') . '</b>';
$userFields['USR_USERNAME'] = '<b>' . G::LoadTranslation('ID_UNASSIGNED') . '</b>';
$userFields['USR_FIRSTNAME'] = '';
$userFields['USR_LASTNAME'] = '';
$userFields['USR_EMAIL'] = '';
break;
default :
throw ( new Exception('Invalid Task Assignment method for Next Task ') ) ;
}
return $userFields;
}
/* getDenpendentUser
*
* @param string $USR_UID
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
* @return string $aRow['USR_REPORTS_TO']
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
*/
function getDenpendentUser($USR_UID)
{
//require_once 'classes/model/Users.php';
//here the uid to next Users
$oC=new Criteria();
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
$oC->addSelectColumn(UsersPeer::USR_REPORTS_TO);
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
$oC->add(UsersPeer::USR_UID,$USR_UID);
$oDataset=UsersPeer::doSelectRS($oC);
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
$aRow = $oDataset->getRow();
return $aRow['USR_REPORTS_TO'];
}
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
/* setTasLastAssigned
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
*
* @param string $tasUid
* @param string $usrUid
* @throws Exception $e
* @return void
*/
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
function setTasLastAssigned ( $tasUid, $usrUid )
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
{
try {
$oTask = TaskPeer::retrieveByPk( $tasUid );
$oTask->setTasLastAssigned( $usrUid );
$oTask->save();
}
catch ( Exception $e ) {
throw ( $e );
}
}
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
/* derivate
*
* @param array $currentDelegation
* @param array $nextDelegations
* @return void
*/
function derivate($currentDelegation=array(), $nextDelegations =array())
{
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
//define this...
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
if ( !defined('TASK_FINISH_PROCESS')) define('TASK_FINISH_PROCESS',-1);
if ( !defined('TASK_FINISH_TASK')) define('TASK_FINISH_TASK', -2);
$this->case = new cases();
//first, we close the current derivation, then we'll try to derivate to each defined route
$appFields = $this->case->loadCase($currentDelegation['APP_UID'], $currentDelegation['DEL_INDEX'] );
$this->case->CloseCurrentDelegation ( $currentDelegation['APP_UID'], $currentDelegation['DEL_INDEX'] );
//Count how many tasks should be derivated.
//$countNextTask = count($nextDelegations);
foreach($nextDelegations as $nextDel) {
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
//subprocesses??
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
if ($nextDel['TAS_PARENT'] != '') {
$oCriteria = new Criteria('workflow');
$oCriteria->add(SubProcessPeer::PRO_PARENT, $appFields['PRO_UID']);
$oCriteria->add(SubProcessPeer::TAS_PARENT, $nextDel['TAS_PARENT']);
if (SubProcessPeer::doCount($oCriteria) > 0) {
$oDataset = SubProcessPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
$aSP = $oDataset->getRow();
$aSP['USR_UID'] = $nextDel['USR_UID'];
$oTask = new Task();
$aTask = $oTask->load($nextDel['TAS_PARENT']);
$nextDel = array('TAS_UID' => $aTask['TAS_UID'],
'USR_UID' => $aSP['USR_UID'],
'TAS_ASSIGN_TYPE' => $aTask['TAS_ASSIGN_TYPE'],
'TAS_DEF_PROC_CODE' => $aTask['TAS_DEF_PROC_CODE'],
'DEL_PRIORITY' => 3,
'TAS_PARENT' => '');
}
else {
continue;
}
}
//get TAS_ASSIGN_TYPE for current Delegation
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
$oTask = new Task();
$aTask = $oTask->load($currentDelegation['TAS_UID']);
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
$currentDelegation['TAS_ASSIGN_TYPE'] = $aTask['TAS_ASSIGN_TYPE'];
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
$currentDelegation['TAS_MI_COMPLETE_VARIABLE'] = $aTask['TAS_MI_COMPLETE_VARIABLE'];
$currentDelegation['TAS_MI_INSTANCE_VARIABLE'] = $aTask['TAS_MI_INSTANCE_VARIABLE'];
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
//get open threads
$openThreads = $this->case->GetOpenThreads( $currentDelegation['APP_UID'] );
//if we are derivating to finish process but there are no more open thread then we are finishing only the task, we are not finishing the whole process
if (($nextDel['TAS_UID'] == TASK_FINISH_PROCESS) && (($openThreads + 1) > 1)) {
$nextDel['TAS_UID'] = TASK_FINISH_TASK;
}
switch ( $nextDel['TAS_UID'] ) {
case TASK_FINISH_PROCESS:
/*Close all delegations of $currentDelegation['APP_UID'] */
$this->case->closeAllDelegations ( $currentDelegation['APP_UID'] );
$this->case->closeAllThreads ( $currentDelegation['APP_UID']);
//I think we need to change the APP_STATUS to completed,
break;
BUG 7864 7635 "Parallel Join Routing Rule by evaluation problem" SOLVED - problem when a condition is evaluated false, so the join never completes solved
2011-10-24 08:48:59 -04:00
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
case TASK_FINISH_TASK:
$iAppThreadIndex = $appFields['DEL_THREAD'];
$this->case->closeAppThread ( $currentDelegation['APP_UID'], $iAppThreadIndex);
break;
BUG 7864 7635 "Parallel Join Routing Rule by evaluation problem" SOLVED - problem when a condition is evaluated false, so the join never completes solved
2011-10-24 08:48:59 -04:00
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
default:
// get all siblingThreads
BUG 7864 7635 "Parallel Join Routing Rule by evaluation problem" SOLVED - problem when a condition is evaluated false, so the join never completes solved
2011-10-24 08:48:59 -04:00
//if($currentDelegation['TAS_ASSIGN_TYPE'] == 'STATIC_MI')
switch ($currentDelegation['TAS_ASSIGN_TYPE']) {
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
case 'CANCEL_MI':
case 'STATIC_MI':
BUG 7864 7635 "Parallel Join Routing Rule by evaluation problem" SOLVED - problem when a condition is evaluated false, so the join never completes solved
2011-10-24 08:48:59 -04:00
$siblingThreads = $this->case->GetAllOpenDelegation($currentDelegation);
$aData = $this->case->loadCase($currentDelegation['APP_UID']);
if (isset($aData['APP_DATA'][str_replace('@@', '', $currentDelegation['TAS_MI_INSTANCE_VARIABLE'])]))
$sMIinstanceVar = $aData['APP_DATA'][str_replace('@@', '', $currentDelegation['TAS_MI_INSTANCE_VARIABLE'])];
else
$sMIinstanceVar = $aData['APP_DATA']['TAS_MI_INSTANCE_VARIABLE'];
if (isset($aData['APP_DATA'][str_replace('@@', '', $currentDelegation['TAS_MI_COMPLETE_VARIABLE'])]))
$sMIcompleteVar = $aData['APP_DATA'][str_replace('@@', '', $currentDelegation['TAS_MI_COMPLETE_VARIABLE'])];
else
$sMIcompleteVar = $aData['APP_DATA']['TAS_MI_COMPLETE_VARIABLE'];
$discriminateThread = $sMIinstanceVar - $sMIcompleteVar;
BUG 6878 En un subproceso en el inbox el caso no llega en negrilla This issue was fixed, the del_init_date field is setting like NULL, this is the normal process
2011-10-12 17:29:35 -04:00
BUG 7864 7635 "Parallel Join Routing Rule by evaluation problem" SOLVED - problem when a condition is evaluated false, so the join never completes solved
2011-10-24 08:48:59 -04:00
// -1 because One App Delegation is closed by above Code
if($discriminateThread == count($siblingThreads))
$canDerivate =true;
else
$canDerivate =false;
break;
BUG 6878 En un subproceso en el inbox el caso no llega en negrilla This issue was fixed, the del_init_date field is setting like NULL, this is the normal process
2011-10-12 17:29:35 -04:00
BUG 7864 7635 "Parallel Join Routing Rule by evaluation problem" SOLVED - problem when a condition is evaluated false, so the join never completes solved
2011-10-24 08:48:59 -04:00
default:
if ( $currentDelegation['ROU_TYPE'] == 'SEC-JOIN') {
$siblingThreads = $this->case->getOpenSiblingThreads(
$nextDel['TAS_UID'],
$currentDelegation['APP_UID'],
$currentDelegation['DEL_INDEX'],
$currentDelegation['TAS_UID'],
$currentDelegation['ROU_TYPE']
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
);
BUG 7864 7635 "Parallel Join Routing Rule by evaluation problem" SOLVED - problem when a condition is evaluated false, so the join never completes solved
2011-10-24 08:48:59 -04:00
$canDerivate = count($siblingThreads) == 0;
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
}
BUG 7864 7635 "Parallel Join Routing Rule by evaluation problem" SOLVED - problem when a condition is evaluated false, so the join never completes solved
2011-10-24 08:48:59 -04:00
else if($currentDelegation['ROU_TYPE'] == 'DISCRIMINATOR') {
//First get the total threads of Next Task where route type='Discriminator'
$siblingThreads = $this->case->getOpenSiblingThreads($nextDel['TAS_UID'], $currentDelegation['APP_UID'], $currentDelegation['DEL_INDEX'], $currentDelegation['TAS_UID'],$currentDelegation['ROU_TYPE']);
$siblingThreadsCount = count($siblingThreads);
$discriminateThread = $currentDelegation['ROU_CONDITION'];
//$checkThread = count($totalThreads) - $cond;
if($discriminateThread == $siblingThreadsCount)
$canDerivate = true;
else
$canDerivate = false;
}
else {
$canDerivate = true;
}
} //end switch
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
BUG 7864 7635 "Parallel Join Routing Rule by evaluation problem" SOLVED - problem when a condition is evaluated false, so the join never completes solved
2011-10-24 08:48:59 -04:00
if ( $canDerivate ) {
$aSP = isset($aSP) ? $aSP : null;
BUG 8169 fixed error in Parallel Task
2012-02-28 12:37:13 -04:00
$iNewDelIndex = $this->doDerivation($currentDelegation, $nextDel, $appFields, $aSP);
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
}
else { //when the task doesnt generate a new AppDelegation
$iAppThreadIndex = $appFields['DEL_THREAD'];
switch ( $currentDelegation['ROU_TYPE'] ) {
case 'DISCRIMINATOR':
case 'SEC-JOIN' :
$this->case->closeAppThread ( $currentDelegation['APP_UID'], $iAppThreadIndex);
break;
default :
if($currentDelegation['TAS_ASSIGN_TYPE'] == 'STATIC_MI' || $currentDelegation['TAS_ASSIGN_TYPE'] == 'CANCEL_MI')
$this->case->closeAppThread ( $currentDelegation['APP_UID'], $iAppThreadIndex);
}//switch
}
}
//SETS THE APP_PROC_CODE
//if (isset($nextDel['TAS_DEF_PROC_CODE']))
BUG 7864 7635 "Parallel Join Routing Rule by evaluation problem" SOLVED - problem when a condition is evaluated false, so the join never completes solved
2011-10-24 08:48:59 -04:00
//$appFields['APP_PROC_CODE'] = $nextDel['TAS_DEF_PROC_CODE'];
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
unset($aSP);
BUG 7864 7635 "Parallel Join Routing Rule by evaluation problem" SOLVED - problem when a condition is evaluated false, so the join never completes solved
2011-10-24 08:48:59 -04:00
} //end foreach
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
/* Start Block : UPDATES APPLICATION */
//Set THE APP_STATUS
$appFields['APP_STATUS'] = $currentDelegation['APP_STATUS'];
/* Start Block : Count the open threads of $currentDelegation['APP_UID'] */
$openThreads = $this->case->GetOpenThreads( $currentDelegation['APP_UID'] );
if ($openThreads == 0) {//Close case
$appFields['APP_STATUS'] = 'COMPLETED';
$appFields['APP_FINISH_DATE'] = 'now';
$this->verifyIsCaseChild($currentDelegation['APP_UID']);
}
BUG 8169 "Recieve An Error in Parallel Task are finished (2.0...." SOLVED - the problem originally was that never is derivation handling correctly to conditional forks and normal forks - code was improed and handled for both forks at derivation types
2012-03-27 18:09:58 -04:00
if (isset($iNewDelIndex)) {
$appFields['DEL_INDEX'] = $iNewDelIndex;
$appFields['TAS_UID'] = $nextDel['TAS_UID'];
/* Start Block : UPDATES APPLICATION */
$this->case->updateCase ( $currentDelegation['APP_UID'], $appFields );
/* End Block : UPDATES APPLICATION */
}
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
}
BUG 7864 7635 "Parallel Join Routing Rule by evaluation problem" SOLVED - problem when a condition is evaluated false, so the join never completes solved
2011-10-24 08:48:59 -04:00
function doDerivation($currentDelegation, $nextDel, $appFields, $aSP = null)
{
$iAppThreadIndex = $appFields['DEL_THREAD'];
$delType = 'NORMAL';
switch ( $nextDel['TAS_ASSIGN_TYPE'] ) {
case 'CANCEL_MI':
case 'STATIC_MI':
// Create new delegation depending on the no of users in the group
$iNewAppThreadIndex = $appFields['DEL_THREAD'];
$this->case->closeAppThread ( $currentDelegation['APP_UID'], $iAppThreadIndex);
foreach($nextDel['NEXT_TASK']['USER_ASSIGNED'] as $key=>$aValue){
//Incrementing the Del_thread First so that new delegation has new del_thread
$iNewAppThreadIndex += 1;
//Creating new delegation according to users in group
$iMIDelIndex = $this->case->newAppDelegation(
$appFields['PRO_UID'],
$currentDelegation['APP_UID'],
$nextDel['TAS_UID'],
(isset($aValue['USR_UID']) ? $aValue['USR_UID'] : ''),
$currentDelegation['DEL_INDEX'],
3, //$nextDel['DEL_PRIORITY'], <- //TODO check this priority alway is 3
$delType,
$iNewAppThreadIndex,
$nextDel
);
$iNewThreadIndex = $this->case->newAppThread ( $currentDelegation['APP_UID'], $iMIDelIndex, $iAppThreadIndex );
//Setting the del Index for Updating the AppThread delIndex
if($key == 0)
$iNewDelIndex = $iMIDelIndex -1;
} //end foreach
break;
case 'BALANCED' :
$this->setTasLastAssigned ($nextDel['TAS_UID'], $nextDel['USR_UID']);
//No Break, need no execute the default ones....
default:
// Create new delegation
$iNewDelIndex = $this->case->newAppDelegation(
$appFields['PRO_UID'],
$currentDelegation['APP_UID'],
$nextDel['TAS_UID'],
(isset($nextDel['USR_UID']) ? $nextDel['USR_UID'] : ''),
$currentDelegation['DEL_INDEX'],
3, //$nextDel['DEL_PRIORITY'], <- //TODO check this priority alway is 3
$delType,
$iAppThreadIndex,
$nextDel
);
break;
}
$iAppThreadIndex = $appFields['DEL_THREAD'];
switch ( $currentDelegation['ROU_TYPE'] ) {
case 'PARALLEL' :
case 'PARALLEL-BY-EVALUATION' :
$this->case->closeAppThread ( $currentDelegation['APP_UID'], $iAppThreadIndex);
$iNewThreadIndex = $this->case->newAppThread ( $currentDelegation['APP_UID'], $iNewDelIndex, $iAppThreadIndex );
$this->case->updateAppDelegation ( $currentDelegation['APP_UID'], $iNewDelIndex, $iNewThreadIndex );
//print " this->case->updateAppDelegation ( " . $currentDelegation['APP_UID'] .", " . $iNewDelIndex ." , " . $iNewThreadIndex . " )<br>";
break;
case 'DISCRIMINATOR':
if($currentDelegation['ROU_OPTIONAL'] == 'TRUE') {
$this->case->discriminateCases($currentDelegation);
} //No Break, executing Default Condition
default :
switch ($currentDelegation['TAS_ASSIGN_TYPE']) {
case 'CANCEL_MI':
$this->case->discriminateCases($currentDelegation);
} //No Break, executing updateAppThread
$this->case->updateAppThread ( $currentDelegation['APP_UID'], $iAppThreadIndex, $iNewDelIndex );
}//en switch
//if there are subprocess to create
if (isset($aSP)) {
//Create the new case in the sub-process
// set the initial date to null the time its created
$aNewCase = $this->case->startCase($aSP['TAS_UID'], $aSP['USR_UID'],true);
//Copy case variables to sub-process case
$aFields = unserialize($aSP['SP_VARIABLES_OUT']);
$aNewFields = array();
$aOldFields = $this->case->loadCase($aNewCase['APPLICATION']);
foreach ($aFields as $sOriginField => $sTargetField) {
$sOriginField = str_replace('@', '', $sOriginField);
$sOriginField = str_replace('#', '', $sOriginField);
$sTargetField = str_replace('@', '', $sTargetField);
$sTargetField = str_replace('#', '', $sTargetField);
$aNewFields[$sTargetField] = isset($appFields['APP_DATA'][$sOriginField]) ? $appFields['APP_DATA'][$sOriginField] : '';
}
$aOldFields['APP_DATA'] = array_merge($aOldFields['APP_DATA'], $aNewFields);
$aOldFields['APP_STATUS'] = 'TO_DO';
$this->case->updateCase($aNewCase['APPLICATION'], $aOldFields);
//Create a registry in SUB_APPLICATION table
$aSubApplication = array('APP_UID' => $aNewCase['APPLICATION'],
'APP_PARENT' => $currentDelegation['APP_UID'],
'DEL_INDEX_PARENT' => $iNewDelIndex,
'DEL_THREAD_PARENT' => $iAppThreadIndex,
'SA_STATUS' => 'ACTIVE',
'SA_VALUES_OUT' => serialize($aNewFields),
'SA_INIT_DATE' => date('Y-m-d H:i:s'));
if ($aSP['SP_SYNCHRONOUS'] == 0) {
$aSubApplication['SA_STATUS'] = 'FINISHED';
$aSubApplication['SA_FINISH_DATE'] = $aSubApplication['SA_INIT_DATE'];
}
$oSubApplication = new SubApplication();
$oSubApplication->create($aSubApplication);
//Update the AppDelegation to execute the update trigger
$AppDelegation = AppDelegationPeer::retrieveByPK($aNewCase['APPLICATION'], $aNewCase['INDEX']);
// note added by krlos pacha carlos[at]colosa[dot]com
// the following line of code was commented because it is related to the 6878 bug
//$AppDelegation->setDelInitDate("+1 second");
$AppDelegation->save();
//If not is SYNCHRONOUS derivate one more time
if ($aSP['SP_SYNCHRONOUS'] == 0) {
$this->case->setDelInitDate($currentDelegation['APP_UID'], $iNewDelIndex);
$aDeriveTasks = $this->prepareInformation(
array( 'USER_UID' => -1,
'APP_UID' => $currentDelegation['APP_UID'],
'DEL_INDEX' => $iNewDelIndex)
);
if (isset($aDeriveTasks[1])) {
if ($aDeriveTasks[1]['ROU_TYPE'] != 'SELECT') {
$nextDelegations2 = array();
foreach ($aDeriveTasks as $aDeriveTask) {
$nextDelegations2[] = array(
'TAS_UID' => $aDeriveTask['NEXT_TASK']['TAS_UID'],
'USR_UID' => $aDeriveTask['NEXT_TASK']['USER_ASSIGNED']['USR_UID'],
'TAS_ASSIGN_TYPE' => $aDeriveTask['NEXT_TASK']['TAS_ASSIGN_TYPE'],
'TAS_DEF_PROC_CODE' => $aDeriveTask['NEXT_TASK']['TAS_DEF_PROC_CODE'],
'DEL_PRIORITY' => 3,
'TAS_PARENT' => $aDeriveTask['NEXT_TASK']['TAS_PARENT']
);
}
$currentDelegation2 = array(
'APP_UID' => $currentDelegation['APP_UID'],
'DEL_INDEX' => $iNewDelIndex,
'APP_STATUS' => 'TO_DO',
'TAS_UID' => $currentDelegation['TAS_UID'],
'ROU_TYPE' => $aDeriveTasks[1]['ROU_TYPE']
);
$this->derivate($currentDelegation2, $nextDelegations2);
}
}
}
} //end switch
BUG 8169 fixed error in Parallel Task
2012-02-28 12:37:13 -04:00
return $iNewDelIndex;
BUG 7864 7635 "Parallel Join Routing Rule by evaluation problem" SOLVED - problem when a condition is evaluated false, so the join never completes solved
2011-10-24 08:48:59 -04:00
}
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
/* verifyIsCaseChild
*
* @param string $sApplicationUID
* @return void
*/
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
function verifyIsCaseChild($sApplicationUID)
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
{
//Obtain the related row in the table SUB_APPLICATION
$oCriteria = new Criteria('workflow');
$oCriteria->add(SubApplicationPeer::APP_UID, $sApplicationUID);
$oDataset = SubApplicationPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
$aSA = $oDataset->getRow();
if ($aSA) {
//Obtain the related row in the table SUB_PROCESS
$oCase = new Cases();
$aParentCase = $oCase->loadCase($aSA['APP_PARENT'], $aSA['DEL_INDEX_PARENT']);
$oCriteria = new Criteria('workflow');
$oCriteria->add(SubProcessPeer::PRO_PARENT, $aParentCase['PRO_UID']);
$oCriteria->add(SubProcessPeer::TAS_PARENT, $aParentCase['TAS_UID']);
$oDataset = SubProcessPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
$aSP = $oDataset->getRow();
if ($aSP['SP_SYNCHRONOUS'] == 1) {
$appFields = $oCase->loadCase($sApplicationUID);
//Copy case variables to parent case
$aFields = unserialize($aSP['SP_VARIABLES_IN']);
$aNewFields = array();
foreach ($aFields as $sOriginField => $sTargetField) {
$sOriginField = str_replace('@', '', $sOriginField);
$sOriginField = str_replace('#', '', $sOriginField);
$sTargetField = str_replace('@', '', $sTargetField);
$sTargetField = str_replace('#', '', $sTargetField);
$aNewFields[$sTargetField] = isset($appFields['APP_DATA'][$sOriginField]) ? $appFields['APP_DATA'][$sOriginField] : '';
}
$aParentCase['APP_DATA'] = array_merge($aParentCase['APP_DATA'], $aNewFields);
$oCase->updateCase($aSA['APP_PARENT'], $aParentCase);
//Update table SUB_APPLICATION
$oSubApplication = new SubApplication();
$oSubApplication->update(array('APP_UID' => $sApplicationUID,
'APP_PARENT' => $aSA['APP_PARENT'],
'DEL_INDEX_PARENT' => $aSA['DEL_INDEX_PARENT'],
'DEL_THREAD_PARENT' => $aSA['DEL_THREAD_PARENT'],
'SA_STATUS' => 'FINISHED',
'SA_VALUES_IN' => serialize($aNewFields),
'SA_FINISH_DATE' => date('Y-m-d H:i:s')));
//Derive the parent case
$aDeriveTasks = $this->prepareInformation(
array( 'USER_UID' => -1,
'APP_UID' => $aSA['APP_PARENT'],
'DEL_INDEX' => $aSA['DEL_INDEX_PARENT'])
);
if (isset($aDeriveTasks[1])) {
if ($aDeriveTasks[1]['ROU_TYPE'] != 'SELECT') {
$nextDelegations2 = array();
foreach ($aDeriveTasks as $aDeriveTask) {
if ( !isset($aDeriveTask['NEXT_TASK']['USER_ASSIGNED']['USR_UID']) ) {
$selectedUser = $aDeriveTask['NEXT_TASK']['USER_ASSIGNED'][0];
unset ($aDeriveTask['NEXT_TASK']['USER_ASSIGNED']);
$aDeriveTask['NEXT_TASK']['USER_ASSIGNED'] = $selectedUser;
$myLabels = array ( $aDeriveTask['NEXT_TASK']['TAS_TITLE'], $aParentCase['APP_NUMBER'], $selectedUser['USR_USERNAME'], $selectedUser['USR_FIRSTNAME'], $selectedUser['USR_LASTNAME'] );
G::SendTemporalMessage( 'ID_TASK_WAS_ASSIGNED_TO_USER', 'warning', 'labels', 10, null, $myLabels);
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
}
$nextDelegations2[] = array(
'TAS_UID' => $aDeriveTask['NEXT_TASK']['TAS_UID'],
'USR_UID' => $aDeriveTask['NEXT_TASK']['USER_ASSIGNED']['USR_UID'],
'TAS_ASSIGN_TYPE' => $aDeriveTask['NEXT_TASK']['TAS_ASSIGN_TYPE'],
'TAS_DEF_PROC_CODE' => $aDeriveTask['NEXT_TASK']['TAS_DEF_PROC_CODE'],
'DEL_PRIORITY' => 3,
'TAS_PARENT' => $aDeriveTask['NEXT_TASK']['TAS_PARENT']
);
}
$currentDelegation2 = array(
'APP_UID' => $aSA['APP_PARENT'],
'DEL_INDEX' => $aSA['DEL_INDEX_PARENT'],
'APP_STATUS' => 'TO_DO',
'TAS_UID' => $aParentCase['TAS_UID'],
'ROU_TYPE' => $aDeriveTasks[1]['ROU_TYPE']
);
$this->derivate($currentDelegation2, $nextDelegations2);
}
}
}
}
}
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
/* getDerivatedCases
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
* get all derivated cases and subcases from any task,
* this function is useful to know who users have been assigned and what task they do.
*
* @param string $sParentUid
* @param string $sDelIndexParent
* @return array $derivation
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
*
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
*/
First commit on ProcessMaker CORE Engine and Jeaqueline's changes
2010-12-07 11:49:51 +00:00
function getDerivatedCases ( $sParentUid, $sDelIndexParent )
initial commit from rev. 632
2010-12-02 23:34:41 +00:00
{
$oCriteria = new Criteria('workflow');
$cases = array();
$derivation = array();
//get the child delegations , of parent delIndex
$children = array();
$oCriteria->clearSelectColumns();
$oCriteria->addSelectColumn ( AppDelegationPeer::DEL_INDEX );
$oCriteria->add(AppDelegationPeer::APP_UID, $sParentUid);
$oCriteria->add(AppDelegationPeer::DEL_PREVIOUS, $sDelIndexParent );
$oDataset = AppDelegationPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
$aRow = $oDataset->getRow();
while ( is_array( $aRow) ) {
$children[] = $aRow['DEL_INDEX'];
$oDataset->next();
$aRow = $oDataset->getRow();
}
//foreach child , get the info of their derivations and subprocesses
foreach ( $children as $keyChild => $child ) {
$oCriteria = new Criteria('workflow');
$oCriteria->clearSelectColumns();
$oCriteria->addSelectColumn ( SubApplicationPeer::APP_UID );
$oCriteria->addSelectColumn ( AppDelegationPeer::APP_UID );
$oCriteria->addSelectColumn ( AppDelegationPeer::DEL_INDEX );
$oCriteria->addSelectColumn ( AppDelegationPeer::PRO_UID );
$oCriteria->addSelectColumn ( AppDelegationPeer::TAS_UID );
$oCriteria->addSelectColumn ( AppDelegationPeer::USR_UID );
$oCriteria->addSelectColumn ( UsersPeer::USR_USERNAME );
$oCriteria->addSelectColumn ( UsersPeer::USR_FIRSTNAME );
$oCriteria->addSelectColumn ( UsersPeer::USR_LASTNAME );
$oCriteria->add(SubApplicationPeer::APP_PARENT, $sParentUid);
$oCriteria->add(SubApplicationPeer::DEL_INDEX_PARENT, $child );
$oCriteria->addJoin ( SubApplicationPeer::APP_UID, AppDelegationPeer::APP_UID);
$oCriteria->addJoin ( AppDelegationPeer::USR_UID, UsersPeer::USR_UID);
$oDataset = SubApplicationPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
$aRow = $oDataset->getRow();
while ( is_array( $aRow) ) {
$oProcess = new Process();
$proFields = $oProcess->load($aRow['PRO_UID']);
$oCase = new Application();
$appFields = $oCase->load($aRow['APP_UID']);
$oTask = new Task();
$tasFields = $oTask->load($aRow['TAS_UID']);
$derivation[] = array (
'processId' => $aRow['PRO_UID'],
'processTitle' => $proFields['PRO_TITLE'],
'caseId' => $aRow['APP_UID'],
'caseNumber' => $appFields['APP_NUMBER'],
'taskId' => $aRow['TAS_UID'],
'taskTitle' => $tasFields['TAS_TITLE'],
'userId' => $aRow['USR_UID'],
'userName' => $aRow['USR_USERNAME'],
'userFullname' => $aRow['USR_FIRSTNAME'] . ' ' . $aRow['USR_LASTNAME']
);
$oDataset->next();
$aRow = $oDataset->getRow();
}
}
return $derivation;
}
function getGrpUser($aData)
{
G::LoadClass('groups');
G::LoadClass('tasks');
require_once 'classes/model/Content.php';
$oTasks = new Tasks();
$oGroups = new Groups();
$oContent = new Content();
$aGroup = array();
$aUsers = array();
$aGroup = $oTasks->getGroupsOfTask($aData['ROU_NEXT_TASK'],1);
$aGrpUid = $aGroup[0]['GRP_UID'];
$sGrpName = $oContent->load('GRP_TITLE', '',$aGrpUid, 'en');
$aGrp['GRP_NAME'] = $sGrpName;
$aGrp['GRP_UID'] = $aGrpUid;
$aUsers = $oGroups->getUsersOfGroup($aGroup[0]['GRP_UID']);
foreach($aUsers as $aKey=>$userid)
{
$aData[$aKey] = $userid;
}
return $aGrp;
//var_dump($aDerivation);
//die;
}
}
Reference in New Issue Copy Permalink