078653882a
Issue:
Implementar el nuevo endpoint para las grillas de mobile
Cause:
Requerimiento de nuevos end-points para Grids
Solution:
Se han implementado los siguientes end-points:
GET /api/1.0/{workspace}/project/{prj_uid}/dynaform/{dyn_uid}/grid/{grd_name}/field-definitions
GET /api/1.0/{workspace}/project/{prj_uid}/dynaform/{dyn_uid}/grid/{grd_name}/field-definition/{fld_id}
GET /api/1.0/{workspace}/case/{app_uid}/{del_index}/variable/{var_name}
GET /api/1.0/{workspace}/case/{app_uid}/{del_index}/variable/{var_name}/paged
POST /api/1.0/{workspace}/case/{app_uid}/{del_index}/variable/{var_name}
PUT /api/1.0/{workspace}/case/{app_uid}/{del_index}/variable/{var_name}
DELETE /api/1.0/{workspace}/case/{app_uid}/{del_index}/variable/{var_name}
1039 lines
42 KiB
PHP
Executable File
1039 lines
42 KiB
PHP
Executable File
<?php
|
|
namespace ProcessMaker\BusinessModel;
|
|
|
|
use \G;
|
|
|
|
class Variable
|
|
{
|
|
/**
|
|
* Create Variable for a Process
|
|
*
|
|
* @param string $processUid Unique id of Process
|
|
* @param array $arrayData Data
|
|
*
|
|
* return array Return data of the new Variable created
|
|
*/
|
|
public function create($processUid, array $arrayData)
|
|
{
|
|
try {
|
|
//Verify data
|
|
Validator::proUid($processUid, '$prj_uid');
|
|
|
|
$arrayData = array_change_key_case($arrayData, CASE_UPPER);
|
|
|
|
$this->existsName($processUid, $arrayData["VAR_NAME"], "");
|
|
|
|
$this->throwExceptionFieldDefinition($arrayData);
|
|
|
|
//Create
|
|
$cnn = \Propel::getConnection("workflow");
|
|
try {
|
|
$variable = new \ProcessVariables();
|
|
|
|
$sPkProcessVariables = \ProcessMaker\Util\Common::generateUID();
|
|
|
|
$variable->setVarUid($sPkProcessVariables);
|
|
$variable->setPrjUid($processUid);
|
|
|
|
if ($variable->validate()) {
|
|
$cnn->begin();
|
|
|
|
if (isset($arrayData["VAR_NAME"])) {
|
|
$variable->setVarName($arrayData["VAR_NAME"]);
|
|
} else {
|
|
throw new \Exception(\G::LoadTranslation("ID_CAN_NOT_BE_NULL", array('$var_name' )));
|
|
}
|
|
if (isset($arrayData["VAR_FIELD_TYPE"])) {
|
|
$variable->setVarFieldType($arrayData["VAR_FIELD_TYPE"]);
|
|
} else {
|
|
throw new \Exception(\G::LoadTranslation("ID_CAN_NOT_BE_NULL", array('$var_field_type' )));
|
|
}
|
|
if (isset($arrayData["VAR_FIELD_SIZE"])) {
|
|
$variable->setVarFieldSize($arrayData["VAR_FIELD_SIZE"]);
|
|
}
|
|
if (isset($arrayData["VAR_LABEL"])) {
|
|
$variable->setVarLabel($arrayData["VAR_LABEL"]);
|
|
} else {
|
|
throw new \Exception(\G::LoadTranslation("ID_CAN_NOT_BE_NULL", array('$var_label' )));
|
|
}
|
|
if (isset($arrayData["VAR_DBCONNECTION"])) {
|
|
$variable->setVarDbconnection($arrayData["VAR_DBCONNECTION"]);
|
|
} else {
|
|
$variable->setVarDbconnection("");
|
|
}
|
|
if (isset($arrayData["VAR_SQL"])) {
|
|
$variable->setVarSql($arrayData["VAR_SQL"]);
|
|
} else {
|
|
$variable->setVarSql("");
|
|
}
|
|
if (isset($arrayData["VAR_NULL"])) {
|
|
$variable->setVarNull($arrayData["VAR_NULL"]);
|
|
} else {
|
|
$variable->setVarNull(0);
|
|
}
|
|
if (isset($arrayData["VAR_DEFAULT"])) {
|
|
$variable->setVarDefault($arrayData["VAR_DEFAULT"]);
|
|
}
|
|
if (isset($arrayData["VAR_ACCEPTED_VALUES"])) {
|
|
$encodeAcceptedValues = \G::json_encode($arrayData["VAR_ACCEPTED_VALUES"]);
|
|
$variable->setVarAcceptedValues($encodeAcceptedValues);
|
|
}
|
|
if (isset($arrayData["INP_DOC_UID"])) {
|
|
$variable->setInpDocUid($arrayData["INP_DOC_UID"]);
|
|
}
|
|
$variable->save();
|
|
$cnn->commit();
|
|
} else {
|
|
|
|
$msg = "";
|
|
|
|
foreach ($variable->getValidationFailures() as $validationFailure) {
|
|
$msg = $msg . (($msg != "")? "\n" : "") . $validationFailure->getMessage();
|
|
}
|
|
|
|
throw new \Exception(\G::LoadTranslation("ID_RECORD_CANNOT_BE_CREATED") . "\n" . $msg);
|
|
}
|
|
|
|
} catch (\Exception $e) {
|
|
$cnn->rollback();
|
|
|
|
throw $e;
|
|
}
|
|
|
|
//Return
|
|
$variable = $this->getVariable($processUid, $sPkProcessVariables);
|
|
|
|
return $variable;
|
|
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Update Variable
|
|
*
|
|
* @param string $processUid Unique id of Process
|
|
* @param string $variableUid Unique id of Variable
|
|
* @param array $arrayData Data
|
|
*
|
|
* return array Return data of the Variable updated
|
|
*/
|
|
public function update($processUid, $variableUid, $arrayData)
|
|
{
|
|
try {
|
|
//Verify data
|
|
Validator::proUid($processUid, '$prj_uid');
|
|
$arrayData = array_change_key_case($arrayData, CASE_UPPER);
|
|
|
|
$this->throwExceptionFieldDefinition($arrayData);
|
|
|
|
//Update
|
|
$cnn = \Propel::getConnection("workflow");
|
|
try {
|
|
$variable = \ProcessVariablesPeer::retrieveByPK($variableUid);
|
|
$dbConnection = \DbSourcePeer::retrieveByPK($variable->getVarDbconnection(), $variable->getPrjUid());
|
|
|
|
$oldVariable = array(
|
|
"VAR_UID" => $variable->getVarUid(),
|
|
"VAR_NAME" => $variable->getVarName(),
|
|
"VAR_FIELD_TYPE" => $variable->getVarFieldType(),
|
|
"VAR_DBCONNECTION" => $variable->getVarDbconnection(),
|
|
"VAR_DBCONNECTION_LABEL" => $dbConnection !== null ? '[' . $dbConnection->getDbsServer() . ':' . $dbConnection->getDbsPort() . '] ' . $dbConnection->getDbsType() . ': ' . $dbConnection->getDbsDatabaseName() : 'PM Database',
|
|
"VAR_SQL" => $variable->getVarSql(),
|
|
"VAR_ACCEPTED_VALUES" => $variable->getVarAcceptedValues()
|
|
);
|
|
if ($variable->validate()) {
|
|
$cnn->begin();
|
|
if (isset($arrayData["VAR_NAME"])) {
|
|
$this->existsName($processUid, $arrayData["VAR_NAME"], $variableUid);
|
|
|
|
$variable->setVarName($arrayData["VAR_NAME"]);
|
|
}
|
|
if (isset($arrayData["VAR_FIELD_TYPE"])) {
|
|
$variable->setVarFieldType($arrayData["VAR_FIELD_TYPE"]);
|
|
}
|
|
if (isset($arrayData["VAR_FIELD_SIZE"])) {
|
|
$variable->setVarFieldSize($arrayData["VAR_FIELD_SIZE"]);
|
|
}
|
|
if (isset($arrayData["VAR_LABEL"])) {
|
|
$variable->setVarLabel($arrayData["VAR_LABEL"]);
|
|
}
|
|
if (isset($arrayData["VAR_DBCONNECTION"])) {
|
|
$variable->setVarDbconnection($arrayData["VAR_DBCONNECTION"]);
|
|
}
|
|
if (isset($arrayData["VAR_SQL"])) {
|
|
$variable->setVarSql($arrayData["VAR_SQL"]);
|
|
}
|
|
if (isset($arrayData["VAR_NULL"])) {
|
|
$variable->setVarNull($arrayData["VAR_NULL"]);
|
|
}
|
|
if (isset($arrayData["VAR_DEFAULT"])) {
|
|
$variable->setVarDefault($arrayData["VAR_DEFAULT"]);
|
|
}
|
|
if (isset($arrayData["VAR_ACCEPTED_VALUES"])) {
|
|
$encodeAcceptedValues = \G::json_encode($arrayData["VAR_ACCEPTED_VALUES"]);
|
|
$variable->setVarAcceptedValues($encodeAcceptedValues);
|
|
}
|
|
if (isset($arrayData["INP_DOC_UID"])) {
|
|
$variable->setInpDocUid($arrayData["INP_DOC_UID"]);
|
|
}
|
|
$variable->save();
|
|
$cnn->commit();
|
|
//update dynaforms
|
|
$dbConnection = \DbSourcePeer::retrieveByPK($variable->getVarDbconnection(), $variable->getPrjUid());
|
|
$newVariable = array(
|
|
"VAR_UID" => $variable->getVarUid(),
|
|
"VAR_NAME" => $variable->getVarName(),
|
|
"VAR_FIELD_TYPE" => $variable->getVarFieldType(),
|
|
"VAR_DBCONNECTION" => $variable->getVarDbconnection(),
|
|
"VAR_DBCONNECTION_LABEL" => $dbConnection !== null ? '[' . $dbConnection->getDbsServer() . ':' . $dbConnection->getDbsPort() . '] ' . $dbConnection->getDbsType() . ': ' . $dbConnection->getDbsDatabaseName() : 'PM Database',
|
|
"VAR_SQL" => $variable->getVarSql(),
|
|
"VAR_ACCEPTED_VALUES" => $variable->getVarAcceptedValues()
|
|
);
|
|
\G::LoadClass('pmDynaform');
|
|
$pmDynaform = new \pmDynaform();
|
|
$pmDynaform->synchronizeVariable($processUid, $newVariable, $oldVariable);
|
|
} else {
|
|
|
|
$msg = "";
|
|
|
|
foreach ($variable->getValidationFailures() as $validationFailure) {
|
|
$msg = $msg . (($msg != "")? "\n" : "") . $validationFailure->getMessage();
|
|
}
|
|
|
|
throw new \Exception(\G::LoadTranslation("ID_RECORD_CANNOT_BE_CREATED") . "\n" . $msg);
|
|
}
|
|
|
|
} catch (\Exception $e) {
|
|
$cnn->rollback();
|
|
|
|
throw $e;
|
|
}
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Delete Variable
|
|
*
|
|
* @param string $processUid Unique id of Process
|
|
* @param string $variableUid Unique id of Variable
|
|
*
|
|
* return void
|
|
*/
|
|
public function delete($processUid, $variableUid)
|
|
{
|
|
try {
|
|
//Verify data
|
|
Validator::proUid($processUid, '$prj_uid');
|
|
|
|
$this->throwExceptionIfNotExistsVariable($variableUid);
|
|
|
|
//Verify variable
|
|
$this->throwExceptionIfVariableIsAssociatedAditionalTable($variableUid);
|
|
|
|
$variable = $this->getVariable($processUid, $variableUid);
|
|
\G::LoadClass('pmDynaform');
|
|
$pmDynaform = new \pmDynaform();
|
|
$isUsed = $pmDynaform->isUsed($processUid, $variable);
|
|
if ($isUsed !== false) {
|
|
$titleDynaform=$pmDynaform->getDynaformTitle($isUsed);
|
|
throw new \Exception(\G::LoadTranslation("ID_VARIABLE_IN_USE", array($titleDynaform)));
|
|
}
|
|
//Delete
|
|
$criteria = new \Criteria("workflow");
|
|
|
|
$criteria->add(\ProcessVariablesPeer::VAR_UID, $variableUid);
|
|
|
|
\ProcessVariablesPeer::doDelete($criteria);
|
|
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get data of a Variable
|
|
* @param string $processUid Unique id of Process
|
|
* @param string $variableUid Unique id of Variable
|
|
*
|
|
* return array Return an array with data of a Variable
|
|
*/
|
|
public function getVariable($processUid, $variableUid)
|
|
{
|
|
try {
|
|
//Verify data
|
|
Validator::proUid($processUid, '$prj_uid');
|
|
|
|
$this->throwExceptionIfNotExistsVariable($variableUid);
|
|
|
|
//Get data
|
|
$criteria = new \Criteria("workflow");
|
|
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_UID);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::PRJ_UID);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_NAME);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_FIELD_TYPE);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_FIELD_SIZE);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_LABEL);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_DBCONNECTION);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_SQL);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_NULL);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_DEFAULT);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_ACCEPTED_VALUES);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::INP_DOC_UID);
|
|
$criteria->addSelectColumn(\DbSourcePeer::DBS_SERVER);
|
|
$criteria->addSelectColumn(\DbSourcePeer::DBS_PORT);
|
|
$criteria->addSelectColumn(\DbSourcePeer::DBS_DATABASE_NAME);
|
|
$criteria->addSelectColumn(\DbSourcePeer::DBS_TYPE);
|
|
|
|
$criteria->add(\ProcessVariablesPeer::PRJ_UID, $processUid, \Criteria::EQUAL);
|
|
$criteria->add(\ProcessVariablesPeer::VAR_UID, $variableUid, \Criteria::EQUAL);
|
|
$criteria->addJoin(\ProcessVariablesPeer::VAR_DBCONNECTION, \DbSourcePeer::DBS_UID, \Criteria::LEFT_JOIN);
|
|
|
|
$rsCriteria = \ProcessVariablesPeer::doSelectRS($criteria);
|
|
|
|
$rsCriteria->setFetchmode(\ResultSet::FETCHMODE_ASSOC);
|
|
|
|
$rsCriteria->next();
|
|
$arrayVariables = array();
|
|
|
|
while ($aRow = $rsCriteria->getRow()) {
|
|
|
|
$VAR_ACCEPTED_VALUES = \G::json_decode($aRow['VAR_ACCEPTED_VALUES'], true);
|
|
if(sizeof($VAR_ACCEPTED_VALUES)) {
|
|
$encodeAcceptedValues = preg_replace("/\\\\u([a-f0-9]{4})/e", "iconv('UCS-4LE','UTF-8',pack('V', hexdec('U$1')))", \G::json_encode($VAR_ACCEPTED_VALUES));
|
|
} else {
|
|
$encodeAcceptedValues = $aRow['VAR_ACCEPTED_VALUES'];
|
|
}
|
|
|
|
$arrayVariables = array('var_uid' => $aRow['VAR_UID'],
|
|
'prj_uid' => $aRow['PRJ_UID'],
|
|
'var_name' => $aRow['VAR_NAME'],
|
|
'var_field_type' => $aRow['VAR_FIELD_TYPE'],
|
|
'var_field_size' => (int)$aRow['VAR_FIELD_SIZE'],
|
|
'var_label' => $aRow['VAR_LABEL'],
|
|
'var_dbconnection' => $aRow['VAR_DBCONNECTION'] === 'none' ? 'workflow' : $aRow['VAR_DBCONNECTION'],
|
|
'var_dbconnection_label' => $aRow['DBS_SERVER'] !== null ? '[' . $aRow['DBS_SERVER'] . ':' . $aRow['DBS_PORT'] . '] ' . $aRow['DBS_TYPE'] . ': ' . $aRow['DBS_DATABASE_NAME'] : 'PM Database',
|
|
'var_sql' => $aRow['VAR_SQL'],
|
|
'var_null' => (int)$aRow['VAR_NULL'],
|
|
'var_default' => $aRow['VAR_DEFAULT'],
|
|
'var_accepted_values' => $encodeAcceptedValues,
|
|
'inp_doc_uid' => $aRow['INP_DOC_UID']);
|
|
$rsCriteria->next();
|
|
}
|
|
//Return
|
|
return $arrayVariables;
|
|
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* Get data of Variables
|
|
*
|
|
* @param string $processUid Unique id of Process
|
|
*
|
|
* return array Return an array with data of a DynaForm
|
|
*/
|
|
public function getVariables($processUid)
|
|
{
|
|
try {
|
|
//Verify data
|
|
Validator::proUid($processUid, '$prj_uid');
|
|
|
|
//Get data
|
|
$criteria = new \Criteria("workflow");
|
|
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_UID);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::PRJ_UID);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_NAME);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_FIELD_TYPE);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_FIELD_SIZE);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_LABEL);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_DBCONNECTION);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_SQL);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_NULL);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_DEFAULT);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_ACCEPTED_VALUES);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::INP_DOC_UID);
|
|
$criteria->addSelectColumn(\DbSourcePeer::DBS_SERVER);
|
|
$criteria->addSelectColumn(\DbSourcePeer::DBS_PORT);
|
|
$criteria->addSelectColumn(\DbSourcePeer::DBS_DATABASE_NAME);
|
|
$criteria->addSelectColumn(\DbSourcePeer::DBS_TYPE);
|
|
|
|
$criteria->add(\ProcessVariablesPeer::PRJ_UID, $processUid, \Criteria::EQUAL);
|
|
$criteria->addJoin(\ProcessVariablesPeer::VAR_DBCONNECTION, \DbSourcePeer::DBS_UID . " AND " . \DbSourcePeer::PRO_UID . " = '" . $processUid . "'", \Criteria::LEFT_JOIN);
|
|
|
|
$rsCriteria = \ProcessVariablesPeer::doSelectRS($criteria);
|
|
|
|
$rsCriteria->setFetchmode(\ResultSet::FETCHMODE_ASSOC);
|
|
|
|
$rsCriteria->next();
|
|
$arrayVariables = array();
|
|
|
|
while ($aRow = $rsCriteria->getRow()) {
|
|
|
|
$VAR_ACCEPTED_VALUES = \G::json_decode($aRow['VAR_ACCEPTED_VALUES'], true);
|
|
if(sizeof($VAR_ACCEPTED_VALUES)) {
|
|
$encodeAcceptedValues = preg_replace("/\\\\u([a-f0-9]{4})/e", "iconv('UCS-4LE','UTF-8',pack('V', hexdec('U$1')))", \G::json_encode($VAR_ACCEPTED_VALUES));
|
|
} else {
|
|
$encodeAcceptedValues = $aRow['VAR_ACCEPTED_VALUES'];
|
|
}
|
|
|
|
$arrayVariables[] = array('var_uid' => $aRow['VAR_UID'],
|
|
'prj_uid' => $aRow['PRJ_UID'],
|
|
'var_name' => $aRow['VAR_NAME'],
|
|
'var_field_type' => $aRow['VAR_FIELD_TYPE'],
|
|
'var_field_size' => (int)$aRow['VAR_FIELD_SIZE'],
|
|
'var_label' => $aRow['VAR_LABEL'],
|
|
'var_dbconnection' => $aRow['VAR_DBCONNECTION'] === 'none' ? 'workflow' : $aRow['VAR_DBCONNECTION'],
|
|
'var_dbconnection_label' => $aRow['DBS_SERVER'] !== null ? '[' . $aRow['DBS_SERVER'] . ':' . $aRow['DBS_PORT'] . '] ' . $aRow['DBS_TYPE'] . ': ' . $aRow['DBS_DATABASE_NAME'] : 'PM Database',
|
|
'var_sql' => $aRow['VAR_SQL'],
|
|
'var_null' => (int)$aRow['VAR_NULL'],
|
|
'var_default' => $aRow['VAR_DEFAULT'],
|
|
'var_accepted_values' => $encodeAcceptedValues,
|
|
'inp_doc_uid' => $aRow['INP_DOC_UID']);
|
|
$rsCriteria->next();
|
|
}
|
|
//Return
|
|
return $arrayVariables;
|
|
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Verify field definition
|
|
*
|
|
* @param array $aData Unique id of Variable to exclude
|
|
*
|
|
*/
|
|
public function throwExceptionFieldDefinition($aData)
|
|
{
|
|
try {
|
|
if (isset($aData["VAR_NAME"])) {
|
|
Validator::isString($aData['VAR_NAME'], '$var_name');
|
|
Validator::isNotEmpty($aData['VAR_NAME'], '$var_name');
|
|
}
|
|
if (isset($aData["VAR_FIELD_TYPE"])) {
|
|
Validator::isString($aData['VAR_FIELD_TYPE'], '$var_field_type');
|
|
Validator::isNotEmpty($aData['VAR_FIELD_TYPE'], '$var_field_type');
|
|
/*if ($aData["VAR_FIELD_TYPE"] != 'string' && $aData["VAR_FIELD_TYPE"] != 'integer' && $aData["VAR_FIELD_TYPE"] != 'boolean' && $aData["VAR_FIELD_TYPE"] != 'float' &&
|
|
$aData["VAR_FIELD_TYPE"] != 'datetime' && $aData["VAR_FIELD_TYPE"] != 'date_of_birth' && $aData["VAR_FIELD_TYPE"] != 'date') {
|
|
throw new \Exception(\G::LoadTranslation("ID_INVALID_VALUE_FOR", array('$var_field_type')));
|
|
}*/
|
|
}
|
|
if (isset($aData["VAR_FIELD_SIZE"])) {
|
|
Validator::isInteger($aData["VAR_FIELD_SIZE"], '$var_field_size');
|
|
}
|
|
if (isset($aData["VAR_LABEL"])) {
|
|
Validator::isString($aData['VAR_LABEL'], '$var_label');
|
|
Validator::isNotEmpty($aData['VAR_LABEL'], '$var_label');
|
|
}
|
|
if (isset($aData["VAR_DBCONNECTION"])) {
|
|
Validator::isString($aData['VAR_DBCONNECTION'], '$var_dbconnection');
|
|
}
|
|
if (isset($aData["VAR_SQL"])) {
|
|
Validator::isString($aData['VAR_SQL'], '$var_sql');
|
|
}
|
|
if (isset($aData["VAR_NULL"])) {
|
|
Validator::isInteger($aData['VAR_NULL'], '$var_null');
|
|
if ($aData["VAR_NULL"] != 0 && $aData["VAR_NULL"] !=1 ) {
|
|
throw new \Exception(\G::LoadTranslation("ID_INVALID_VALUE_ONLY_ACCEPTS_VALUES", array('$var_null','0, 1' )));
|
|
}
|
|
}
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Verify if exists the name of a variable
|
|
*
|
|
* @param string $processUid Unique id of Process
|
|
* @param string $variableName Name
|
|
*
|
|
*/
|
|
public function existsName($processUid, $variableName, $variableUidToExclude = "")
|
|
{
|
|
try {
|
|
$criteria = new \Criteria("workflow");
|
|
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_UID);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_NAME);
|
|
|
|
if ($variableUidToExclude != "") {
|
|
$criteria->add(\ProcessVariablesPeer::VAR_UID, $variableUidToExclude, \Criteria::NOT_EQUAL);
|
|
}
|
|
|
|
$criteria->add(\ProcessVariablesPeer::VAR_NAME, $variableName, \Criteria::EQUAL);
|
|
$criteria->add(\ProcessVariablesPeer::PRJ_UID, $processUid, \Criteria::EQUAL);
|
|
$rsCriteria = \ProcessVariablesPeer::doSelectRS($criteria);
|
|
|
|
$rsCriteria->setFetchmode(\ResultSet::FETCHMODE_ASSOC);
|
|
|
|
while ($rsCriteria->next()) {
|
|
$row = $rsCriteria->getRow();
|
|
|
|
if ($variableName == $row["VAR_NAME"]) {
|
|
throw new \Exception(\G::LoadTranslation("DYNAFIELD_ALREADY_EXIST"));
|
|
}
|
|
}
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get required variables in the SQL
|
|
*
|
|
* @param string $sql SQL
|
|
*
|
|
* return array Return an array with required variables in the SQL
|
|
*/
|
|
public function sqlGetRequiredVariables($sql)
|
|
{
|
|
try {
|
|
$arrayVariableRequired = array();
|
|
|
|
preg_match_all("/@[@%#\?\x24\=]([A-Za-z_]\w*)/", $sql, $arrayMatch, PREG_SET_ORDER);
|
|
|
|
foreach ($arrayMatch as $value) {
|
|
$arrayVariableRequired[] = $value[1];
|
|
}
|
|
|
|
return $arrayVariableRequired;
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Verify if some required variable in the SQL is missing in the variables
|
|
*
|
|
* @param string $variableName Variable name
|
|
* @param string $variableSql SQL
|
|
* @param array $arrayVariable The variables
|
|
*
|
|
* return void Throw exception if some required variable in the SQL is missing in the variables
|
|
*/
|
|
public function throwExceptionIfSomeRequiredVariableSqlIsMissingInVariables($variableName, $variableSql, array $arrayVariable)
|
|
{
|
|
try {
|
|
$arrayResult = array_diff(array_unique($this->sqlGetRequiredVariables($variableSql)), array_keys($arrayVariable));
|
|
|
|
if (count($arrayResult) > 0) {
|
|
throw new \Exception(\G::LoadTranslation("ID_PROCESS_VARIABLE_REQUIRED_VARIABLES_FOR_QUERY", array($variableName, implode(", ", $arrayResult))));
|
|
}
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get all records by execute SQL
|
|
*
|
|
* @param string $processUid Unique id of Process
|
|
* @param string $variableName Variable name
|
|
* @param array $arrayVariable The variables
|
|
*
|
|
* return array Return an array with all records
|
|
*/
|
|
public function executeSql($processUid, $variableName, array $arrayVariable = array())
|
|
{
|
|
try {
|
|
$arrayRecord = array();
|
|
|
|
//Verify data
|
|
$process = new \ProcessMaker\BusinessModel\Process();
|
|
|
|
$process->throwExceptionIfNotExistsProcess($processUid, strtolower("PRJ_UID"));
|
|
|
|
//Set data
|
|
\G::LoadClass('pmDynaform');
|
|
$pmDynaform = new \pmDynaform();
|
|
$field = $pmDynaform->searchField($arrayVariable["dyn_uid"], $arrayVariable["field_id"]);
|
|
$dbConnection = "workflow";
|
|
if ($field !== null && !empty($field->dbConnection)) {
|
|
$dbConnection = $field->dbConnection;
|
|
}
|
|
$variableSql = $field !== null ? $field->sql : "";
|
|
|
|
//Get data
|
|
$_SESSION["PROCESS"] = $processUid;
|
|
|
|
$cnn = \Propel::getConnection($dbConnection);
|
|
$stmt = $cnn->createStatement();
|
|
|
|
$replaceFields = G::replaceDataField($variableSql, $arrayVariable);
|
|
|
|
$rs = $stmt->executeQuery($replaceFields, \ResultSet::FETCHMODE_NUM);
|
|
|
|
while ($rs->next()) {
|
|
$row = $rs->getRow();
|
|
|
|
$arrayRecord[] = array(
|
|
strtolower("VALUE") => $row[0],
|
|
strtolower("TEXT") => isset($row[1]) ? $row[1] : $row[0]
|
|
);
|
|
}
|
|
|
|
//Return
|
|
return $arrayRecord;
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Verify if does not exist the variable in table PROCESS_VARIABLES
|
|
*
|
|
* @param string $variableUid Unique id of variable
|
|
*
|
|
* return void Throw exception if does not exist the variable in table PROCESS_VARIABLES
|
|
*/
|
|
public function throwExceptionIfNotExistsVariable($variableUid)
|
|
{
|
|
try {
|
|
$obj = \ProcessVariablesPeer::retrieveByPK($variableUid);
|
|
|
|
if (is_null($obj)) {
|
|
throw new \Exception('var_uid: '.$variableUid. ' '.\G::LoadTranslation("ID_DOES_NOT_EXIST"));
|
|
}
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Check if the variable is associated to Report Table
|
|
*
|
|
* @param string $variableUid Unique id of variable
|
|
*
|
|
* @return void Throw exception
|
|
*/
|
|
public function throwExceptionIfVariableIsAssociatedAditionalTable($variableUid)
|
|
{
|
|
try {
|
|
$criteria = new \Criteria('workflow');
|
|
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_UID);
|
|
|
|
$criteria->addJoin(\ProcessVariablesPeer::PRJ_UID, \AdditionalTablesPeer::PRO_UID, \Criteria::INNER_JOIN);
|
|
|
|
$arrayCondition = [];
|
|
$arrayCondition[] = array(\AdditionalTablesPeer::ADD_TAB_UID, \FieldsPeer::ADD_TAB_UID, \Criteria::EQUAL);
|
|
$arrayCondition[] = array(\ProcessVariablesPeer::VAR_NAME, \FieldsPeer::FLD_NAME, \Criteria::EQUAL);
|
|
$criteria->addJoinMC($arrayCondition, \Criteria::INNER_JOIN);
|
|
|
|
$criteria->add(\ProcessVariablesPeer::VAR_UID, $variableUid, \Criteria::EQUAL);
|
|
|
|
$rsCriteria = \ProcessVariablesPeer::doSelectRS($criteria);
|
|
$rsCriteria->setFetchmode(\ResultSet::FETCHMODE_ASSOC);
|
|
|
|
if ($rsCriteria->next()) {
|
|
throw new \Exception(\G::LoadTranslation('ID_VARIABLE_ASSOCIATED_WITH_REPORT_TABLE', array($variableUid)));
|
|
}
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Verify if the variable is being used in a Dynaform
|
|
*
|
|
* @param string $processUid Unique id of Process
|
|
* @param string $variableUid Unique id of Variable
|
|
*
|
|
*/
|
|
public function verifyUse($processUid, $variableUid)
|
|
{
|
|
try {
|
|
|
|
$criteria = new \Criteria("workflow");
|
|
$criteria->addSelectColumn(\DynaformPeer::DYN_CONTENT);
|
|
$criteria->addSelectColumn(\DynaformPeer::DYN_UID);
|
|
$criteria->add(\DynaformPeer::PRO_UID, $processUid, \Criteria::EQUAL);
|
|
$rsCriteria = \DynaformPeer::doSelectRS($criteria);
|
|
$rsCriteria->setFetchmode(\ResultSet::FETCHMODE_ASSOC);
|
|
|
|
while ($rsCriteria->next()) {
|
|
|
|
$row = $rsCriteria->getRow();
|
|
|
|
$contentDecode = \G::json_decode($row["DYN_CONTENT"], true);
|
|
$content = $contentDecode['items'][0]['items'];
|
|
if (is_array($content)) {
|
|
foreach ($content as $key => $value) {
|
|
if (isset($value[0]["variable"])) {
|
|
$criteria = new \Criteria("workflow");
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_NAME);
|
|
$criteria->add(\ProcessVariablesPeer::PRJ_UID, $processUid, \Criteria::EQUAL);
|
|
$criteria->add(\ProcessVariablesPeer::VAR_NAME, $value[0]["variable"], \Criteria::EQUAL);
|
|
$criteria->add(\ProcessVariablesPeer::VAR_UID, $variableUid, \Criteria::EQUAL);
|
|
$rsCriteria = \ProcessVariablesPeer::doSelectRS($criteria);
|
|
$rsCriteria->setFetchmode(\ResultSet::FETCHMODE_ASSOC);
|
|
$rsCriteria->next();
|
|
|
|
if ($rsCriteria->getRow()) {
|
|
throw new \Exception(\G::LoadTranslation("ID_VARIABLE_IN_USE", array($variableUid, $row["DYN_UID"])));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get all records by execute SQL suggest
|
|
*
|
|
* @param string $processUid Unique id of Process
|
|
* @param string $variableName Variable name
|
|
* @param array $arrayVariable The variables
|
|
*
|
|
* return array Return an array with all records
|
|
*/
|
|
public function executeSqlSuggest($processUid, $variableName, array $arrayVariable = array())
|
|
{
|
|
try {
|
|
$arrayRecord = array();
|
|
|
|
//Verify data
|
|
$process = new \ProcessMaker\BusinessModel\Process();
|
|
|
|
$process->throwExceptionIfNotExistsProcess($processUid, strtolower("PRJ_UID"));
|
|
|
|
//Set data
|
|
\G::LoadClass('pmDynaform');
|
|
$pmDynaform = new \pmDynaform();
|
|
$field = $pmDynaform->searchField($arrayVariable["dyn_uid"], $variableName);
|
|
$dbConnection = "workflow";
|
|
if ($field !== null && !empty($field->dbConnection)) {
|
|
$dbConnection = $field->dbConnection;
|
|
}
|
|
$variableSql = $field !== null ? $field->sql : "";
|
|
|
|
//Get data
|
|
$_SESSION["PROCESS"] = $processUid;
|
|
|
|
$cnn = \Propel::getConnection($dbConnection);
|
|
$stmt = $cnn->createStatement();
|
|
|
|
$replaceFields = G::replaceDataField($variableSql, $arrayVariable);
|
|
|
|
$filter = "";
|
|
if (isset($arrayVariable["filter"])) {
|
|
$filter = $arrayVariable["filter"];
|
|
}
|
|
$start = 0;
|
|
if (isset($arrayVariable["start"])) {
|
|
$start = $arrayVariable["start"];
|
|
}
|
|
$limit = "";
|
|
if (isset($arrayVariable["limit"])) {
|
|
$limit = $arrayVariable["limit"];
|
|
}
|
|
$parser = new \PHPSQLParser($replaceFields);
|
|
$filter = str_replace("'", "''", $filter);
|
|
$replaceFields = $this->queryModified($parser->parsed, $filter, "*searchtype*", $start, $limit, $dbConnection);
|
|
$rs = $stmt->executeQuery($replaceFields, \ResultSet::FETCHMODE_NUM);
|
|
|
|
while ($rs->next()) {
|
|
$row = $rs->getRow();
|
|
|
|
$arrayRecord[] = array(
|
|
strtolower("VALUE") => $row[0],
|
|
strtolower("TEXT") => isset($row[1]) ? $row[1] : $row[0]
|
|
);
|
|
}
|
|
|
|
//Return
|
|
return $arrayRecord;
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
public function queryModified($sqlParsed, $inputSel = "", $searchType = "*searchtype*", $start = 0, $limit = "", $dbConnection = "workflow")
|
|
{
|
|
if (!empty($sqlParsed['SELECT'])) {
|
|
$sqlSelectOptions = (isset($sqlParsed["OPTIONS"]) && count($sqlParsed["OPTIONS"]) > 0) ? implode(" ", $sqlParsed["OPTIONS"]) : null;
|
|
|
|
$sqlSelect = "SELECT $sqlSelectOptions ";
|
|
$aSelect = $sqlParsed["SELECT"];
|
|
|
|
$sFieldSel = (count($aSelect) > 1 ) ? $aSelect[1]['base_expr'] : $aSelect[0]['base_expr'];
|
|
foreach ($aSelect as $key => $value) {
|
|
if ($key != 0)
|
|
$sqlSelect .= ", ";
|
|
$sAlias = str_replace("`", "", $aSelect[$key]['alias']);
|
|
$sBaseExpr = $aSelect[$key]['base_expr'];
|
|
switch ($aSelect[$key]['expr_type']) {
|
|
case 'colref' : if ($sAlias === $sBaseExpr)
|
|
$sqlSelect .= $sAlias;
|
|
else
|
|
$sqlSelect .= $sBaseExpr . ' AS ' . $sAlias;
|
|
break;
|
|
case 'expression' : if ($sAlias === $sBaseExpr)
|
|
$sqlSelect .= $sBaseExpr;
|
|
else
|
|
$sqlSelect .= $sBaseExpr . ' AS ' . $sAlias;
|
|
break;
|
|
case 'subquery' : if (strpos($sAlias, $sBaseExpr, 0) != 0)
|
|
$sqlSelect .= $sAlias;
|
|
else
|
|
$sqlSelect .= $sBaseExpr . " AS " . $sAlias;
|
|
break;
|
|
case 'operator' : $sqlSelect .= $sBaseExpr;
|
|
break;
|
|
default : $sqlSelect .= $sBaseExpr;
|
|
break;
|
|
}
|
|
}
|
|
|
|
$sqlFrom = " FROM ";
|
|
if (!empty($sqlParsed['FROM'])) {
|
|
$aFrom = $sqlParsed['FROM'];
|
|
if (count($aFrom) > 0) {
|
|
foreach ($aFrom as $key => $value) {
|
|
if ($key == 0) {
|
|
$sqlFrom .= $aFrom[$key]['table'] . (($aFrom[$key]['table'] == $aFrom[$key]['alias']) ? "" : " " . $aFrom[$key]['alias']);
|
|
} else {
|
|
$sqlFrom .= " " . (($aFrom[$key]['join_type'] == 'JOIN') ? "INNER" : $aFrom[$key]['join_type']) . " JOIN " . $aFrom[$key]['table']
|
|
. (($aFrom[$key]['table'] == $aFrom[$key]['alias']) ? "" : " " . $aFrom[$key]['alias']) . " " . $aFrom[$key]['ref_type'] . " " . $aFrom[$key]['ref_clause'];
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
$sqlConditionLike = "LIKE '%" . $inputSel . "%'";
|
|
|
|
switch ($searchType) {
|
|
case "searchtype*":
|
|
$sqlConditionLike = "LIKE '" . $inputSel . "%'";
|
|
break;
|
|
case "*searchtype":
|
|
$sqlConditionLike = "LIKE '%" . $inputSel . "'";
|
|
break;
|
|
}
|
|
|
|
if (!empty($sqlParsed['WHERE'])) {
|
|
$sqlWhere = " WHERE ";
|
|
$aWhere = $sqlParsed['WHERE'];
|
|
foreach ($aWhere as $key => $value) {
|
|
$sqlWhere .= $value['base_expr'] . " ";
|
|
}
|
|
$sqlWhere .= " AND " . $sFieldSel . " " . $sqlConditionLike;
|
|
} else {
|
|
$sqlWhere = " WHERE " . $sFieldSel . " " . $sqlConditionLike;
|
|
}
|
|
|
|
$sqlGroupBy = "";
|
|
if (!empty($sqlParsed['GROUP'])) {
|
|
$sqlGroupBy = "GROUP BY ";
|
|
$aGroup = $sqlParsed['GROUP'];
|
|
foreach ($aGroup as $key => $value) {
|
|
if ($key != 0)
|
|
$sqlGroupBy .= ", ";
|
|
if ($value['direction'] == 'ASC')
|
|
$sqlGroupBy .= $value['base_expr'];
|
|
else
|
|
$sqlGroupBy .= $value['base_expr'] . " " . $value['direction'];
|
|
}
|
|
}
|
|
|
|
$sqlHaving = "";
|
|
if (!empty($sqlParsed['HAVING'])) {
|
|
$sqlHaving = "HAVING ";
|
|
$aHaving = $sqlParsed['HAVING'];
|
|
foreach ($aHaving as $key => $value) {
|
|
$sqlHaving .= $value['base_expr'] . " ";
|
|
}
|
|
}
|
|
|
|
$sqlOrderBy = "";
|
|
if (!empty($sqlParsed['ORDER'])) {
|
|
$sqlOrderBy = "ORDER BY ";
|
|
$aOrder = $sqlParsed['ORDER'];
|
|
foreach ($aOrder as $key => $value) {
|
|
if ($key != 0)
|
|
$sqlOrderBy .= ", ";
|
|
if ($value['direction'] == 'ASC')
|
|
$sqlOrderBy .= $value['base_expr'];
|
|
else
|
|
$sqlOrderBy .= $value['base_expr'] . " " . $value['direction'];
|
|
}
|
|
} else {
|
|
$sqlOrderBy = " ORDER BY " . $sFieldSel;
|
|
}
|
|
|
|
$sqlLimit = "";
|
|
if ($start >= 0) {
|
|
$sqlLimit = " LIMIT " . $start;
|
|
}
|
|
if ($limit !== "") {
|
|
$sqlLimit = " LIMIT " . $start . "," . $limit;
|
|
}
|
|
if (!empty($sqlParsed['LIMIT'])) {
|
|
$sqlLimit = " LIMIT " . $sqlParsed['LIMIT']['start'] . ", " . $sqlParsed['LIMIT']['end'];
|
|
}
|
|
|
|
//get database provider
|
|
$a = new \Criteria("workflow");
|
|
$a->addSelectColumn(\DbSourcePeer::DBS_TYPE);
|
|
$a->add(\DbSourcePeer::DBS_UID, $dbConnection, \Criteria::EQUAL);
|
|
$ds = \DbSourcePeer::doSelectRS($a);
|
|
$ds->setFetchmode(\ResultSet::FETCHMODE_ASSOC);
|
|
$ds->next();
|
|
$row = $ds->getRow();
|
|
if (isset($row["DBS_TYPE"])) {
|
|
if ($row["DBS_TYPE"] === "pgsql") {
|
|
$sqlLimit = $this->limitPgsql($start, $limit);
|
|
}
|
|
if ($row["DBS_TYPE"] === "mssql") {
|
|
return $this->limitMssqlOracle($sqlSelect, $sqlFrom, $sqlWhere, $sqlGroupBy, $sqlHaving, $sqlOrderBy, $start, $limit, true);
|
|
}
|
|
if ($row["DBS_TYPE"] === "oracle") {
|
|
return $this->limitMssqlOracle($sqlSelect, $sqlFrom, $sqlWhere, $sqlGroupBy, $sqlHaving, $sqlOrderBy, $start, $limit, false);
|
|
}
|
|
}
|
|
|
|
return $sqlSelect . $sqlFrom . $sqlWhere . $sqlGroupBy . $sqlHaving . $sqlOrderBy . $sqlLimit;
|
|
}
|
|
if (!empty($sqlParsed['CALL'])) {
|
|
$sCall = "CALL ";
|
|
$aCall = $sqlParsed['CALL'];
|
|
foreach ($aCall as $key => $value) {
|
|
$sCall .= $value . " ";
|
|
}
|
|
return $sCall;
|
|
}
|
|
if (!empty($sqlParsed['EXECUTE'])) {
|
|
$sCall = "EXECUTE ";
|
|
$aCall = $sqlParsed['EXECUTE'];
|
|
foreach ($aCall as $key => $value) {
|
|
$sCall .= $value . " ";
|
|
}
|
|
return $sCall;
|
|
}
|
|
if (!empty($sqlParsed[''])) {
|
|
$sCall = "";
|
|
$aCall = $sqlParsed[''];
|
|
foreach ($aCall as $key => $value) {
|
|
$sCall .= $value . " ";
|
|
}
|
|
return $sCall;
|
|
}
|
|
}
|
|
|
|
public function limitPgsql($start = 0, $limit = "")
|
|
{
|
|
$sqlLimit = "";
|
|
if ($start >= 0) {
|
|
$sqlLimit = " OFFSET " . $start;
|
|
}
|
|
if ($limit !== "") {
|
|
$sqlLimit = $sqlLimit . " LIMIT " . $limit;
|
|
}
|
|
return $sqlLimit;
|
|
}
|
|
|
|
public function limitMssqlOracle($sqlSelect = "", $sqlFrom = "", $sqlWhere = "", $sqlGroupBy = "", $sqlHaving = "", $sqlOrderBy = "", $start = 0, $limit = "", $isMssql = true)
|
|
{
|
|
$sqlLimit = "";
|
|
if ($start >= 0) {
|
|
$sqlLimit = "WHERE rn >= " . $start;
|
|
}
|
|
if ($start >= 0 && $limit != "") {
|
|
$sqlLimit = "WHERE rn BETWEEN " . $start . " AND " . $limit;
|
|
}
|
|
$sql = ""
|
|
. "SELECT * FROM ("
|
|
. " " . $sqlSelect . ", ROW_NUMBER() OVER( " . $sqlOrderBy . " desc )-1 " . ($isMssql ? " AS " : "") . " rn "
|
|
. " " . $sqlFrom . $sqlWhere . $sqlGroupBy . $sqlHaving
|
|
. ")" . ($isMssql ? " AS A " : "")
|
|
. $sqlLimit;
|
|
return $sql;
|
|
}
|
|
|
|
public function getVariableTypeByName($processUid, $variableName)
|
|
{
|
|
try {
|
|
$criteria = new \Criteria("workflow");
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_UID);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_NAME);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_FIELD_TYPE);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_DBCONNECTION);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_SQL);
|
|
$criteria->addSelectColumn(\ProcessVariablesPeer::VAR_ACCEPTED_VALUES);
|
|
$criteria->add(\ProcessVariablesPeer::VAR_NAME, $variableName);
|
|
$criteria->add(\ProcessVariablesPeer::PRJ_UID, $processUid);
|
|
$rsCriteria = \ProcessVariablesPeer::doSelectRS($criteria);
|
|
$rsCriteria->setFetchmode(\ResultSet::FETCHMODE_ASSOC);
|
|
if ($rsCriteria->next()) {
|
|
$row = $rsCriteria->getRow();
|
|
return sizeof($row) ? $row : false;
|
|
}
|
|
return false;
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get Variable record by name
|
|
*
|
|
* @param string $projectUid Unique id of Project
|
|
* @param string $variableName Variable name
|
|
* @param array $arrayVariableNameForException Variable name for exception
|
|
* @param bool $throwException Flag to throw the exception if the main parameters are invalid or do not exist
|
|
* (TRUE: throw the exception; FALSE: returns FALSE)
|
|
*
|
|
* @return array Returns an array with Variable record, ThrowTheException/FALSE otherwise
|
|
*/
|
|
public function getVariableRecordByName(
|
|
$projectUid,
|
|
$variableName,
|
|
array $arrayVariableNameForException,
|
|
$throwException = true
|
|
) {
|
|
try {
|
|
$criteria = new \Criteria('workflow');
|
|
|
|
$criteria->add(\ProcessVariablesPeer::PRJ_UID, $projectUid, \Criteria::EQUAL);
|
|
$criteria->add(\ProcessVariablesPeer::VAR_NAME, $variableName, \Criteria::EQUAL);
|
|
|
|
$rsCriteria = \ProcessVariablesPeer::doSelectRS($criteria);
|
|
$rsCriteria->setFetchmode(\ResultSet::FETCHMODE_ASSOC);
|
|
|
|
if ($rsCriteria->next()) {
|
|
$arrayVariableData = $rsCriteria->getRow();
|
|
} else {
|
|
if ($throwException) {
|
|
throw new \Exception(
|
|
$arrayVariableNameForException['$variableName'] . ': ' . $variableName. ' ' .
|
|
\G::LoadTranslation('ID_DOES_NOT_EXIST')
|
|
);
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
//Return
|
|
return $arrayVariableData;
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
}
|