Merged in cochalo/processmaker (pull request #213)
Adicion de end points SUB PROCESS
This commit is contained in:
erik ao
151
workflow/engine/src/BusinessModel/Subprocess.php
Normal file
151
workflow/engine/src/BusinessModel/Subprocess.php
Normal file
@@ -0,0 +1,151 @@
|
|||||||
|
<?php
|
||||||
|
namespace BusinessModel;
|
||||||
|
|
||||||
|
use \G;
|
||||||
|
use \SubProcessPeer;
|
||||||
|
|
||||||
|
class Subprocess
|
||||||
|
{
|
||||||
|
/**
|
||||||
|
* Get SubProcess in Process
|
||||||
|
*
|
||||||
|
* return object
|
||||||
|
*/
|
||||||
|
public function getSubprocesss($pro_uid, $tas_uid)
|
||||||
|
{
|
||||||
|
try {
|
||||||
|
$pro_uid = $this->validateProUid($pro_uid);
|
||||||
|
$tas_uid = $this->validateTasUid($tas_uid);
|
||||||
|
|
||||||
|
$oCriteria = new \Criteria('workflow');
|
||||||
|
$del = \DBAdapter::getStringDelimiter();
|
||||||
|
$oCriteria->add(SubProcessPeer::PRO_PARENT, $pro_uid);
|
||||||
|
$oCriteria->add(SubProcessPeer::TAS_PARENT, $tas_uid);
|
||||||
|
|
||||||
|
$oCriteria->addAsColumn('CON_VALUE', 'C1.CON_VALUE', 'CON_TITLE');
|
||||||
|
$oCriteria->addAlias("C1", 'CONTENT');
|
||||||
|
$tasTitleConds = array();
|
||||||
|
$tasTitleConds[] = array(SubProcessPeer::TAS_PARENT, 'C1.CON_ID' );
|
||||||
|
$tasTitleConds[] = array('C1.CON_CATEGORY', $del . 'TAS_TITLE' . $del );
|
||||||
|
$tasTitleConds[] = array('C1.CON_LANG', $del . SYS_LANG . $del );
|
||||||
|
$oCriteria->addJoinMC($tasTitleConds, \Criteria::LEFT_JOIN);
|
||||||
|
|
||||||
|
$oDataset = SubProcessPeer::doSelectRS($oCriteria);
|
||||||
|
$oDataset->setFetchmode(\ResultSet::FETCHMODE_ASSOC);
|
||||||
|
$oDataset->next();
|
||||||
|
$aRow = $oDataset->getRow();
|
||||||
|
$aRow = array_change_key_case($aRow, CASE_LOWER);
|
||||||
|
|
||||||
|
$response['spr_uid'] = $aRow['sp_uid'];
|
||||||
|
$response['spr_pro_parent'] = $aRow['pro_parent'];
|
||||||
|
$response['spr_tas_parent'] = $aRow['tas_parent'];
|
||||||
|
$response['spr_pro'] = $aRow['pro_uid'];
|
||||||
|
$response['spr_tas'] = $aRow['tas_uid'];
|
||||||
|
$response['spr_name'] = $aRow['con_value'];
|
||||||
|
$response['spr_synchronous'] = $aRow['sp_synchronous'];
|
||||||
|
$response['spr_variables_out'] = unserialize($aRow['sp_variables_out']);
|
||||||
|
if ($response['spr_synchronous'] === 1) {
|
||||||
|
$response['spr_variables_in'] = unserialize($aRow['sp_variables_in']);
|
||||||
|
}
|
||||||
|
return $response;
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
throw $e;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Put SubProcess in Process
|
||||||
|
* @var string $pro_uid. Uid for Process
|
||||||
|
* @var string $spr_uid. Uid for SubProcess
|
||||||
|
* @var array $spr_data. Data for SubProcess
|
||||||
|
*
|
||||||
|
*
|
||||||
|
* @author Brayan Pereyra (Cochalo) <brayan@colosa.com>
|
||||||
|
* @copyright Colosa - Bolivia
|
||||||
|
*
|
||||||
|
* @return array
|
||||||
|
*/
|
||||||
|
public function putSubprocesss($pro_uid, $tas_uid, $spr_data)
|
||||||
|
{
|
||||||
|
$pro_uid = $this->validateProUid($pro_uid);
|
||||||
|
$tas_uid = $this->validateTasUid($tas_uid);
|
||||||
|
if (empty($spr_data)) {
|
||||||
|
throw (new \Exception("The request data is empty."));
|
||||||
|
}
|
||||||
|
if (isset($spr_data['spr_pro'])) {
|
||||||
|
$spr_data['spr_pro'] = $this->validateProUid($spr_data['spr_pro']);
|
||||||
|
}
|
||||||
|
if (isset($spr_data['spr_tas'])) {
|
||||||
|
$spr_data['spr_tas'] = $this->validateTasUid($spr_data['spr_tas']);
|
||||||
|
}
|
||||||
|
|
||||||
|
$dataTemp = $this->getSubprocesss($pro_uid, $tas_uid);
|
||||||
|
$spr_data = array_merge($dataTemp, $spr_data);
|
||||||
|
$spr_data['spr_variables_in'] = (isset($spr_data['spr_variables_in'])) ? $spr_data['spr_variables_in'] : array();
|
||||||
|
|
||||||
|
$oSubProcess = new \SubProcess();
|
||||||
|
$aData = array (
|
||||||
|
'SP_UID' => $spr_data['spr_uid'],
|
||||||
|
'PRO_UID' => $spr_data['spr_pro'],
|
||||||
|
'TAS_UID' => $spr_data['spr_tas'],
|
||||||
|
'PRO_PARENT' => $pro_uid,
|
||||||
|
'TAS_PARENT' => $tas_uid,
|
||||||
|
'SP_TYPE' => 'SIMPLE',
|
||||||
|
'SP_SYNCHRONOUS' => $spr_data['spr_synchronous'],
|
||||||
|
'SP_SYNCHRONOUS_TYPE' => 'ALL',
|
||||||
|
'SP_SYNCHRONOUS_WAIT' => 0,
|
||||||
|
'SP_VARIABLES_OUT' => serialize( $spr_data['spr_variables_out'] ),
|
||||||
|
'SP_VARIABLES_IN' => serialize( $spr_data['spr_variables_in'] ),
|
||||||
|
'SP_GRID_IN' => ''
|
||||||
|
);
|
||||||
|
$oSubProcess->update( $aData );
|
||||||
|
|
||||||
|
$lang = defined( 'SYS_LANG' ) ? SYS_LANG : 'en';
|
||||||
|
\Content::addContent( 'TAS_TITLE', '', $tas_uid, $lang, $spr_data['spr_name']);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Validate Process Uid
|
||||||
|
* @var string $pro_uid. Uid for process
|
||||||
|
*
|
||||||
|
* @author Brayan Pereyra (Cochalo) <brayan@colosa.com>
|
||||||
|
* @copyright Colosa - Bolivia
|
||||||
|
*
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
public function validateProUid ($pro_uid)
|
||||||
|
{
|
||||||
|
$pro_uid = trim($pro_uid);
|
||||||
|
if ($pro_uid == '') {
|
||||||
|
throw (new \Exception("The project with prj_uid: '', does not exist."));
|
||||||
|
}
|
||||||
|
$oProcess = new \Process();
|
||||||
|
if (!($oProcess->processExists($pro_uid))) {
|
||||||
|
throw (new \Exception("The project with prj_uid: '$pro_uid', does not exist."));
|
||||||
|
}
|
||||||
|
return $pro_uid;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Validate Task Uid
|
||||||
|
* @var string $tas_uid. Uid for task
|
||||||
|
*
|
||||||
|
* @author Brayan Pereyra (Cochalo) <brayan@colosa.com>
|
||||||
|
* @copyright Colosa - Bolivia
|
||||||
|
*
|
||||||
|
* @return string
|
||||||
|
*/
|
||||||
|
public function validateTasUid($tas_uid)
|
||||||
|
{
|
||||||
|
$tas_uid = trim($tas_uid);
|
||||||
|
if ($tas_uid == '') {
|
||||||
|
throw (new \Exception("The task with tas_uid: '', does not exist."));
|
||||||
|
}
|
||||||
|
$oTask = new \Task();
|
||||||
|
if (!($oTask->taskExists($tas_uid))) {
|
||||||
|
throw (new \Exception("The task with tas_uid: '$tas_uid', does not exist."));
|
||||||
|
}
|
||||||
|
return $tas_uid;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
@@ -0,0 +1,67 @@
|
|||||||
|
<?php
|
||||||
|
namespace Services\Api\ProcessMaker\Project;
|
||||||
|
|
||||||
|
use \ProcessMaker\Services\Api;
|
||||||
|
use \Luracast\Restler\RestException;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Project\Subprocess Api Controller
|
||||||
|
*
|
||||||
|
* @author Brayan Pereyra (Cochalo) <brayan@colosa.com>
|
||||||
|
* @copyright Colosa - Bolivia
|
||||||
|
*
|
||||||
|
* @protected
|
||||||
|
*/
|
||||||
|
class Subprocess extends Api
|
||||||
|
{
|
||||||
|
/**
|
||||||
|
* @param string $prj_uid {@min 1} {@max 32}
|
||||||
|
* @param string $tas_uid {@min 1} {@max 32}
|
||||||
|
*
|
||||||
|
* @author Brayan Pereyra (Cochalo) <brayan@colosa.com>
|
||||||
|
* @copyright Colosa - Bolivia
|
||||||
|
*
|
||||||
|
* @return array
|
||||||
|
*
|
||||||
|
* @url GET /:prj_uid/subprocess/:tas_uid
|
||||||
|
*/
|
||||||
|
public function doGetSubprocesss($prj_uid, $tas_uid)
|
||||||
|
{
|
||||||
|
try {
|
||||||
|
$hiddenFields = array('spr_uid', 'spr_pro_parent', 'spr_tas_parent');
|
||||||
|
$oSubProcess = new \BusinessModel\Subprocess();
|
||||||
|
$response = $oSubProcess->getSubprocesss($prj_uid, $tas_uid);
|
||||||
|
foreach ($response as $key => $value) {
|
||||||
|
if (in_array($key, $hiddenFields)) {
|
||||||
|
unset($response[$key]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return $response;
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
throw (new RestException(Api::STAT_APP_EXCEPTION, $e->getMessage()));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param string $prj_uid {@min 1} {@max 32}
|
||||||
|
* @param string $tas_uid {@min 1} {@max 32}
|
||||||
|
* @param array $request_data
|
||||||
|
*
|
||||||
|
* @author Brayan Pereyra (Cochalo) <brayan@colosa.com>
|
||||||
|
* @copyright Colosa - Bolivia
|
||||||
|
*
|
||||||
|
* @return void
|
||||||
|
*
|
||||||
|
* @url PUT /:prj_uid/subprocess/:tas_uid
|
||||||
|
*/
|
||||||
|
public function doPutSubprocess($prj_uid, $tas_uid, $request_data)
|
||||||
|
{
|
||||||
|
try {
|
||||||
|
$oSubProcess = new \BusinessModel\Subprocess();
|
||||||
|
$oSubProcess->putSubprocesss($prj_uid, $tas_uid, $request_data);
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
throw (new RestException(Api::STAT_APP_EXCEPTION, $e->getMessage()));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
Reference in New Issue
Block a user