PMCORE-1266
This commit is contained in:
Andrea Adamczyk
@@ -6,10 +6,22 @@ use DynaformHandler;
|
|||||||
use Exception;
|
use Exception;
|
||||||
use Fields;
|
use Fields;
|
||||||
use G;
|
use G;
|
||||||
|
use PmTable;
|
||||||
use ProcessMaker\BusinessModel\ReportTable as BusinessModelRpt;
|
use ProcessMaker\BusinessModel\ReportTable as BusinessModelRpt;
|
||||||
|
use stdClass;
|
||||||
|
|
||||||
class Table
|
class Table
|
||||||
{
|
{
|
||||||
|
const RESERVE_WORDS = ['ALTER','CLOSE','COMMIT','CREATE','DECLARE','DELETE',
|
||||||
|
'DROP','FETCH','FUNCTION','GRANT','INDEX','INSERT','OPEN','REVOKE','ROLLBACK',
|
||||||
|
'SELECT','SYNONYM','TABLE','UPDATE','VIEW','APP_UID','ROW','PMTABLE'];
|
||||||
|
|
||||||
|
const RESERVE_WORDS_PHP = ['case','catch','cfunction','class','clone','const','continue',
|
||||||
|
'declare','default','do','else','elseif','enddeclare','endfor','endforeach','endif',
|
||||||
|
'endswitch','endwhile','extends','final','for','foreach','function','global','goto',
|
||||||
|
'if','implements','interface','instanceof','private','namespace','new','old_function',
|
||||||
|
'or','throw','protected','public','static','switch','xor','try','use','var','while'];
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* List of Tables in process
|
* List of Tables in process
|
||||||
* @var string $pro_uid. Uid for process
|
* @var string $pro_uid. Uid for process
|
||||||
@@ -455,6 +467,176 @@ class Table
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Create a PM Table
|
||||||
|
*
|
||||||
|
* @var array $tab_data
|
||||||
|
*
|
||||||
|
* @return array
|
||||||
|
* @throws Exception
|
||||||
|
*/
|
||||||
|
public function createPmTable($tab_data)
|
||||||
|
{
|
||||||
|
$validateData = array_change_key_case($tab_data, CASE_UPPER);
|
||||||
|
$additionalTables = new AdditionalTables();
|
||||||
|
$validateData['TAB_UID'] = (isset($validateData['PMT_UID'])) ? $validateData['PMT_UID'] : '';
|
||||||
|
$validateData['PMT_TAB_NAME'] = $this->validateTabName($validateData['PMT_TAB_NAME']);
|
||||||
|
$validateData['PMT_TAB_CONNECTION'] = 'workflow';
|
||||||
|
$repTabClassName = $additionalTables->getPHPName($validateData['PMT_TAB_NAME']);
|
||||||
|
$tableName = $validateData['PMT_TAB_NAME'];
|
||||||
|
$tableCon = $validateData['PMT_TAB_CONNECTION'];
|
||||||
|
|
||||||
|
$fields = new Fields();
|
||||||
|
$columns = $validateData['FIELDS'];
|
||||||
|
|
||||||
|
$reservedWords = self::RESERVE_WORDS;
|
||||||
|
|
||||||
|
$reservedWordsPhp = self::RESERVE_WORDS_PHP;
|
||||||
|
|
||||||
|
$reservedWordsSql = G::reservedWordsSql();
|
||||||
|
|
||||||
|
if ($additionalTables->loadByName($tableName)) {
|
||||||
|
throw new Exception(G::loadTranslation('ID_PMTABLE_ALREADY_EXISTS', [$tableName]));
|
||||||
|
}
|
||||||
|
|
||||||
|
if (in_array(strtoupper($tableName), $reservedWords) || in_array(strtoupper($tableName), $reservedWordsSql)) {
|
||||||
|
throw (new Exception(G::LoadTranslation("ID_PMTABLE_INVALID_NAME", [$tableName])));
|
||||||
|
}
|
||||||
|
|
||||||
|
$flagKey = false;
|
||||||
|
$columnsStd = [];
|
||||||
|
foreach ($columns as $i => $column) {
|
||||||
|
if (isset($columns[$i]['fld_dyn'])) {
|
||||||
|
$columns[$i]['field_dyn'] = '';
|
||||||
|
unset($columns[$i]['fld_dyn']);
|
||||||
|
} else {
|
||||||
|
$columns[$i]['fld_dyn'] = '';
|
||||||
|
}
|
||||||
|
|
||||||
|
if (isset($columns[$i]['fld_name'])) {
|
||||||
|
$columns[$i]['field_name'] = G::toUpper($columns[$i]['fld_name']);
|
||||||
|
unset($columns[$i]['fld_name']);
|
||||||
|
}
|
||||||
|
if (isset($columns[$i]['fld_description'])) {
|
||||||
|
$columns[$i]['field_label'] = $columns[$i]['fld_description'];
|
||||||
|
unset($columns[$i]['fld_description']);
|
||||||
|
}
|
||||||
|
if (isset($columns[$i]['fld_type'])) {
|
||||||
|
$columns[$i]['field_type'] = $columns[$i]['fld_type'];
|
||||||
|
unset($columns[$i]['fld_type']);
|
||||||
|
}
|
||||||
|
if (isset($columns[$i]['fld_size'])) {
|
||||||
|
$columns[$i]['field_size'] = $columns[$i]['fld_size'];
|
||||||
|
if (!is_int($columns[$i]['field_size'])) {
|
||||||
|
throw (new Exception("The property fld_size: '". $columns[$i]['field_size'] . "' is incorrect numeric value."));
|
||||||
|
} else {
|
||||||
|
$columns[$i]['field_size'] = (int)$columns[$i]['field_size'];
|
||||||
|
}
|
||||||
|
unset($columns[$i]['fld_size']);
|
||||||
|
}
|
||||||
|
if (isset($columns[$i]['fld_key'])) {
|
||||||
|
$columns[$i]['field_key'] = $columns[$i]['fld_key'];
|
||||||
|
unset($columns[$i]['fld_key']);
|
||||||
|
}
|
||||||
|
if (isset($columns[$i]['fld_null'])) {
|
||||||
|
$columns[$i]['field_null'] = $columns[$i]['fld_null'];
|
||||||
|
unset($columns[$i]['fld_null']);
|
||||||
|
}
|
||||||
|
if (isset($columns[$i]['fld_auto_increment'])) {
|
||||||
|
$columns[$i]['field_autoincrement'] = $columns[$i]['fld_auto_increment'];
|
||||||
|
unset($columns[$i]['fld_auto_increment']);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (in_array(strtoupper($columns[$i]['field_name']), $reservedWordsSql) ||
|
||||||
|
in_array( strtolower( $columns[$i]['field_name']), $reservedWordsPhp ) ||
|
||||||
|
$columns[$i]['field_name'] == '') {
|
||||||
|
throw (new Exception("The property fld_name: '". $columns[$i]['field_name'] . "' is incorrect value."));
|
||||||
|
}
|
||||||
|
if ($columns[$i]['field_label'] == '') {
|
||||||
|
throw (new Exception("The property fld_label: '". $columns[$i]['field_label'] . "' is incorrect value."));
|
||||||
|
}
|
||||||
|
$columns[$i]['field_type'] = $this->validateFldType($columns[$i]['field_type']);
|
||||||
|
if (isset($columns[$i]['field_autoincrement']) && $columns[$i]['field_autoincrement']) {
|
||||||
|
$typeCol = $columns[$i]['field_type'];
|
||||||
|
if (! ($typeCol === 'INTEGER' || $typeCol === 'TINYINT' || $typeCol === 'SMALLINT' || $typeCol === 'BIGINT')) {
|
||||||
|
$columns[$i]['field_autoincrement'] = false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$temp = new stdClass();
|
||||||
|
foreach ($columns[$i] as $key => $col) {
|
||||||
|
eval('$temp->' . str_replace('fld', 'field', $key) . " = '" . $col . "';");
|
||||||
|
}
|
||||||
|
$temp->uid = (isset($temp->uid)) ? $temp->uid : '';
|
||||||
|
$temp->_index = (isset($temp->_index)) ? $temp->_index : '';
|
||||||
|
$temp->field_uid = (isset($temp->field_uid)) ? $temp->field_uid : '';
|
||||||
|
$temp->field_dyn = (isset($temp->field_dyn)) ? $temp->field_dyn : '';
|
||||||
|
|
||||||
|
$temp->field_key = (isset($temp->field_key)) ? $temp->field_key : 0;
|
||||||
|
$temp->field_null = (isset($temp->field_null)) ? $temp->field_null : 1;
|
||||||
|
$temp->field_dyn = (isset($temp->field_dyn)) ? $temp->field_dyn : '';
|
||||||
|
$temp->field_filter = (isset($temp->field_filter)) ? $temp->field_filter : 0;
|
||||||
|
$temp->field_autoincrement = (isset($temp->field_autoincrement)) ? $temp->field_autoincrement : 0;
|
||||||
|
|
||||||
|
if ($temp->field_key == 1 || $temp->field_key == true) {
|
||||||
|
$flagKey = true;
|
||||||
|
}
|
||||||
|
$columnsStd[$i] = $temp;
|
||||||
|
}
|
||||||
|
if (!$flagKey) {
|
||||||
|
throw (new Exception("The fields must have a key 'fld_key'"));
|
||||||
|
}
|
||||||
|
|
||||||
|
$pmTable = new PmTable($tableName);
|
||||||
|
$pmTable->setDataSource($tableCon);
|
||||||
|
$pmTable->setColumns($columnsStd);
|
||||||
|
$pmTable->setAlterTable(true);
|
||||||
|
|
||||||
|
$pmTable->build();
|
||||||
|
$buildResult = ob_get_contents();
|
||||||
|
ob_end_clean();
|
||||||
|
unset($buildResult);
|
||||||
|
|
||||||
|
$addTabData = [
|
||||||
|
'ADD_TAB_UID' => $validateData['TAB_UID'],
|
||||||
|
'ADD_TAB_NAME' => $validateData['PMT_TAB_NAME'],
|
||||||
|
'ADD_TAB_CLASS_NAME' => $repTabClassName,
|
||||||
|
'ADD_TAB_DESCRIPTION' => isset($validateData['PMT_TAB_DESCRIPTION']) ? $validateData['PMT_TAB_DESCRIPTION'] : null,
|
||||||
|
'ADD_TAB_OFFLINE' => !empty($validateData['PMT_TAB_OFFLINE']) ?? 0,
|
||||||
|
'ADD_TAB_UPDATE_DATE' => date('Y-m-d H:i:s'),
|
||||||
|
'ADD_TAB_PLG_UID' => '',
|
||||||
|
'DBS_UID' => ($validateData['PMT_TAB_CONNECTION'] ? $validateData['PMT_TAB_CONNECTION'] : 'workflow'),
|
||||||
|
'PRO_UID' => '',
|
||||||
|
'ADD_TAB_TYPE' => '',
|
||||||
|
'ADD_TAB_GRID' => ''
|
||||||
|
];
|
||||||
|
|
||||||
|
$addTabUid = $additionalTables->create($addTabData);
|
||||||
|
|
||||||
|
foreach ($columnsStd as $i => $column) {
|
||||||
|
$column = (array)$column;
|
||||||
|
$field = [
|
||||||
|
'FLD_UID' => $column['uid'],
|
||||||
|
'FLD_INDEX' => $i,
|
||||||
|
'ADD_TAB_UID' => $addTabUid,
|
||||||
|
'FLD_NAME' => $column['field_name'],
|
||||||
|
'FLD_DESCRIPTION' => $column['field_label'],
|
||||||
|
'FLD_TYPE' => $column['field_type'],
|
||||||
|
'FLD_SIZE' => (!isset($column['field_size']) || $column['field_size'] == '') ? null : $column['field_size'],
|
||||||
|
'FLD_NULL' => $column['field_null'] ? 1 : 0,
|
||||||
|
'FLD_AUTO_INCREMENT' => $column['field_autoincrement'] ? 1 : 0,
|
||||||
|
'FLD_KEY' => $column['field_key'] ? 1 : 0,
|
||||||
|
'FLD_FOREIGN_KEY' => 0,
|
||||||
|
'FLD_FOREIGN_KEY_TABLE' => '',
|
||||||
|
'FLD_DYN_NAME' => $column['field_dyn'],
|
||||||
|
'FLD_DYN_UID' => $column['field_uid'],
|
||||||
|
'FLD_FILTER' => (isset($column['field_filter']) && $column['field_filter']) ? 1 : 0
|
||||||
|
];
|
||||||
|
$fields->create($field);
|
||||||
|
}
|
||||||
|
return $this->getTable($addTabUid, '', false, false);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Save Data for PmTable
|
* Save Data for PmTable
|
||||||
* @var string $pmt_uid. Uid for PmTable
|
* @var string $pmt_uid. Uid for PmTable
|
||||||
|
|||||||
@@ -165,6 +165,34 @@ class Pmtable extends Api
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Create a new PM Table
|
||||||
|
*
|
||||||
|
* @url POST /pmtables
|
||||||
|
* @status 201
|
||||||
|
*
|
||||||
|
* @param array $request_data
|
||||||
|
*
|
||||||
|
* @return array
|
||||||
|
* @throws RestException
|
||||||
|
*
|
||||||
|
* @access protected
|
||||||
|
* @class AccessControl {@permission PM_SETUP_PM_TABLES}
|
||||||
|
*/
|
||||||
|
public function doPostPmTables($request_data)
|
||||||
|
{
|
||||||
|
try {
|
||||||
|
$reportTable = new BusinessModelTable();
|
||||||
|
$response = $reportTable->createPmTable($request_data);
|
||||||
|
if (isset($response['pro_uid'])) {
|
||||||
|
unset($response['pro_uid']);
|
||||||
|
}
|
||||||
|
return $response;
|
||||||
|
} catch (Exception $e) {
|
||||||
|
throw (new RestException(Api::STAT_APP_EXCEPTION, $e->getMessage()));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Add a new record to a PM Table
|
* Add a new record to a PM Table
|
||||||
*
|
*
|
||||||
|
|||||||
Reference in New Issue
Block a user