getLink('', [ 'namespace' => $acl->getNamespace() ]);
$tbl = new TableAjax($acl);
$tbl->setRootUrl($syncUrl);
if (!empty($backRefFilter['namespace']) && !empty($backRefFilter['primaryKey'])) {
$tbl->setBackRefFilter($backRefFilter);
$syncUrl = $this->getLink('', [
'namespace' => $acl->getNamespace(),
'backRefNS' => $backRefFilter['namespace'],
'backRefPK' => $backRefFilter['primaryKey'],
'backRefField' => $backRefFilter['fieldName'],
]);
}
if (!empty($childRefFilter['namespace']) && !empty($childRefFilter['primaryKey'])) {
$tbl->setChildRefFilter($childRefFilter);
$syncUrl = $this->getLink('', [
'namespace' => $acl->getNamespace(),
'childRefNS' => $childRefFilter['namespace'],
'childRefPK' => $childRefFilter['primaryKey'],
]);
}
$tblLabel = $acl->getNamespace();
if ('default_db' == $acl->getSourceName()) {
$tblLabel = array();
$zasobObj = ProcesHelper::getZasobTableInfo($acl->getID());
if (!$zasobObj) throw new Exception("Zasob TABELA ID=" . $acl->getID() . " nie istnieje");
if (!empty($zasobObj->DESC_PL)) $tblLabel[] = $zasobObj->DESC_PL;
if (!empty($zasobObj->OPIS)) $tblLabel[] = $zasobObj->OPIS;
$tblLabel = implode(" - ", $tblLabel);
}
$tbl->setSyncUrl($syncUrl);
$tbl->showProcesInitFiltr = $this->getLink("procesInitFiltrAjax", [ 'namespace' => $acl->getNamespace() ]);
$tbl->showTableTools = $this->getLink("tableToolsAjax", [ 'namespace' => $acl->getNamespace() ]);
$tbl->useUserTableFilter = $this->getLink("getUserTableFilterAjax");
$tbl->setLabel($tblLabel);
$tbl->addRowFunction('edit');
$tbl->addRowFunction('hist');
$tbl->addRowFunction('files');
$tbl->addRowFunction('cp');
$tbl->addRowFunction('msgs');
return $tbl;
}
public function defaultAction() {
UI::gora();
UI::menu();
try {
$namespace = V::get('namespace', '', $_GET, 'word');
if (!$namespace) {
$typeName = V::get('typeName', '', $_GET, 'word');
if (!$typeName) throw new Exception("Wrong param typeName");
$namespace = Api_WfsNs::getBaseWfsUri() . '/' . str_replace(':', '/', $typeName);
}
$acl = Core_AclHelper::getAclByNamespace($namespace, $forceTblAclInit = ('1' == V::get('_force', '', $_GET)));
$forceFilterInit = array();
$filterInit = new stdClass();
$filterInit->currSortCol = $acl->getPrimaryKeyField();
$filterInit->currSortFlip = 'desc';
foreach ($_REQUEST as $k => $v) {
if (strlen($k) > 3 && substr($k, 0, 2) == 'f_' && !empty($v)) {// filter prefix
$filterInit->$k = $v;
}
else if (strlen($k) > 4 && substr($k, 0, 3) == 'sf_' && !empty($v)) {// special filter prefix
$filterInit->$k = $v;
}
else if (strlen($k) > 4 && substr($k, 0, 3) == 'ff_' && !empty($v)) {// force filter prefix
$fldName = substr($k, 3);
$forceFilterInit[$fldName] = $v;
}
}
$backRefFilter = [
'namespace' => V::get('backRefNS', '', $_GET),
'primaryKey' => V::get('backRefPK', '', $_GET),
'fieldName' => V::get('backRefField', '', $_GET),
];
$childRefFilter = [
'namespace' => V::get('childRefNS', '', $_GET),
'primaryKey' => V::get('childRefPK', '', $_GET),
];
$tbl = $this->getTableAjaxWidget($acl, $backRefFilter, $childRefFilter);
$tbl->setFilterInit($filterInit);
if (!empty($forceFilterInit)) $tbl->setForceFilterInit($forceFilterInit);
if (V::get('DBG_INST', '', $_GET)) { // TODO: TEST namespace
$siblings = ACL::getNamespaceSiblings($namespace);
DBG::nicePrint($siblings, '$siblings');
$filtrInstance = V::get('f_instance', [], $_POST, 'array');
DBG::nicePrint($filtrInstance, '$filtrInstance');
$sibling = 'default_db/CRM_PROCES/PROCES_INIT'; DBG::nicePrint(array_merge(['type'=>"radio", 'name'=>"f_instance[{$sibling}]", 'value'=>'YES'], ('YES' === V::get($sibling, '', $filtrInstance)) ? ['checked' => "checked"] : []), "merge {$sibling} YES");
$sibling = 'default_db/CRM_PROCES/PROCES_INIT'; DBG::nicePrint(array_merge(['type'=>"radio", 'name'=>"f_instance[{$sibling}]", 'value'=>'NO'], ('NO' === V::get($sibling, '', $filtrInstance)) ? ['checked' => "checked"] : []), "merge {$sibling} NO");
$_ = array(UI, 'h');
echo $_('form', ['method' => "POST", 'style' => "width:600px; border:1px solid #ddd; border-radius:2px"], [
$_('div', ['style' => "background-color:#ddd"], "Test Filtr instancji"),
$_('div', ['style' => "padding:8px"], array_map(function ($sibling) use ($filtrInstance, $_) {
return $_('div', [], [
$_('label', ['style' => "margin:0 8px"], [
$_('input', array_merge(['type'=>"radio", 'name'=>"f_instance[{$sibling}]", 'value'=>'YES'], ('YES' === V::get($sibling, '', $filtrInstance)) ? ['checked' => "checked"] : [])),
" TAK "
]),
$_('label', ['style' => "margin:0 8px"], [
$_('input', array_merge(['type'=>"radio", 'name'=>"f_instance[{$sibling}]", 'value'=>'NO'], ('NO' === V::get($sibling, '', $filtrInstance)) ? ['checked' => "checked"] : [])),
" NIE "
]),
$_('label', ['style' => "margin:0 8px"], [
$_('input', ['type'=>"radio", 'name'=>"f_instance[{$sibling}]", 'value'=>'x']),
" pomiń "
]),
// $_('button', ['onClick'=>"this.form.f_instance['{$sibling}'].value = ''; return false"], "odznacz"),
$_('button', ['onClick'=>"console.log(this.form.elements['f_instance[{$sibling}]']); this.form.elements['f_instance[{$sibling}]'].value = 'x'; return false"], "odznacz"),
" - {$sibling}"
]);
}, $siblings)),
$_('div', [], [
$_('input', ['type'=>"hidden", 'name'=>'_route', 'value'=>"ViewObject"]),
$_('input', ['type'=>"hidden", 'name'=>'namespace', 'value'=>$namespace]),
$_('input', ['type'=>"submit", 'value'=>"Filtruj - TEST"]),
]),
]);
DBG::nicePrint($_POST, '$_POST');
{
$args = $_POST;
$fIsInstance = [];
$fIsNotInstance = [];
if (!empty($args['f_instance'])) {
foreach ($args['f_instance'] as $inst => $selected) {
if ('YES' === $selected) {
$fIsInstance[] = $inst;
} else if ('NO' === $selected) {
$fIsNotInstance[] = $inst;
}
}
}
}
$queryFeatures = $acl->buildQuery([
// TODO: 'propertyName' => "*,@instance",
'f_is_instance' => $fIsInstance,
'f_is_not_instance' => $fIsNotInstance,
'@instances' => '1',
'limit' => 10
]);
// $total = $queryFeatures->getTotal();
$items = $queryFeatures->getItems();
$rootNamespace = $acl->getRootNamespace();
DBG::nicePrint($rootNamespace, '$rootNamespace');
$jsRenderFunName = 'render_dropdown_instances_' . substr(md5(time()), 0, 6);
DBG::nicePrint($jsRenderFunName, '$jsRenderFunName');
UI::table([
'rows' => array_map(function($row) use ($namespace, $siblings, $rootNamespace, $jsRenderFunName) {
return [
'ID' => $row['ID'],
'DESC' => $row['DESC'],
'TYPE' => $row['TYPE'],
'Typ' => UI::h('div', ['class'=>"p5UI__dropdown-wrap"], [
UI::h('button', [
// 'onClick' => "p5UI__dropdown(event, this, 'left bottom')",
'onClick' => "p5UI__dropdown(event, this, 'left bottom', {$jsRenderFunName}({$row['ID']}))",
'class' => "btn btn-xs btn-default p5UI__dropdown-btn"
], [
UI::h('i', ['class' => "glyphicon glyphicon-tags", 'title' => "Ustaw typ danych (instancje)"]),
]),
UI::h('div', ['class' => "p5UI__dropdown-content"]
, array_merge(
[
UI::h('input', ['type' => "text", 'placeholder' => "Search..", 'class' => "p5UI__dropdown-input", 'onkeyup' => "p5_ViewObject_instances_filterInput(this)"], null),
]
, array_map(function ($sibling) use ($row, $namespace, $rootNamespace) {
return UI::h('div', ['label'=>$sibling, 'style'=>"padding:4px 0"], [
UI::h('button', array_merge(['class' => "btn btn-xs btn-default",
'style' => "margin:0 4px 0 0",
'title' => "Ustaw instancje '{$sibling}'",
'onClick' => "return p5_ViewObject_instance_set(this, '{$row['ID']}', '{$sibling}', 'yes')"],
(in_array($sibling, explode(',', $row['@instances']))) ? ['disabled' => "disabled"] : []
), "+"),
UI::h('button', ['class' => "btn btn-xs btn-default",
'style' => "margin:0 4px 0 0",
'title' => "Usuń instancje '{$sibling}'",
'onClick' => "return p5_ViewObject_instance_set(this, '{$row['ID']}', '{$sibling}', 'no')"], "-"),
UI::h('span', [], substr($sibling, strlen($rootNamespace) + 1)),
]);
}, $siblings)
)
)
]),
'instancesList' => implode(', ', ACL::getFeatureNamespaces($namespace, $row['ID'])),
];
}, $items)
]);
echo UI::h('style', ['type' => "text/css"], "
.p5UI__dropdown-content { min-width:400px; border:1px solid #ccc; background-color: #fff; box-shadow: 0px 8px 16px 0px rgba(0,0,0,0.2) }
.p5UI__dropdown-content .p5UI__dropdown-item { display:block; color:#000; padding:4px; text-decoration:none }
.p5UI__dropdown-content .p5UI__dropdown-item:hover { background-color:#ebebeb }
");
echo UI::h('script', ['src'=>"static/vendor.js", 'type'=>"text/javascript"]);
$jsArgs = [
'SET_INSTANCE_URL' => $this->getLink('setInstanceAjax'),
'NAMESPACE' => $namespace,
'DBG' => DBG::isActive() ? 'true' : 'false',
];
UI::inlineJS(__FILE__ . '.instancesDropdown.js', [
'JS_GLOBAL_FUNCTION_NAME' => $jsRenderFunName,
'NAMESPACE' => $namespace,
'SET_INSTANCE_URL' => $this->getLink('setInstanceAjax'),
'DBG' => DBG::isActive() ? 1 : 0,
'INITIAL_DROPDOWN_DATA' => [
// 'allowed_instances' => $siblings,
'allowed_instances' => array_map(function ($sibling) use ($rootNamespace) {
return [
'namespace' => $sibling,
'label' => substr($sibling, strlen($rootNamespace) + 1)
];
}, $siblings),
'items' => array_map(function($row) use ($namespace, $siblings, $rootNamespace, $jsRenderFunName) {
return [
'pk' => $row['ID'], // TODO: $primaryKeyField
'instances' => explode(',', $row['@instances']),
];
}, $items)
],
]);
echo UI::h('script', [], "
var SET_INSTANCE_URL = '{$jsArgs['SET_INSTANCE_URL']}'
var NAMESPACE = '{$jsArgs['NAMESPACE']}'
function p5_ViewObject_instance_set(n, pk, sibling, toConnect) {
console.log('p5_ViewObject_instance_set pk('+pk+'), sibling('+sibling+'), toConnect('+toConnect+'), n', n);
window.fetch(SET_INSTANCE_URL, {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
credentials: 'same-origin',
body: JSON.stringify({
namespace: NAMESPACE,
primaryKey: pk,
instance: sibling,
toConnect: toConnect,
})
}).then(function (response) {
return response.json()
}).then(function (response) {
p5UI__notifyAjaxCallback(response)
console.log(response) // TODO: render list
})
}
");
echo UI::h('script', [], "
function p5_ViewObject_instances_filterInput(n) {
var input, filter, ul, li, a, i, div;
input = n // .id-myInput
filter = input.value.toUpperCase()
div = n.parentNode // .id-myDropdown
a = div.getElementsByTagName('div')
for (i = 0; i < a.length; i++) {
if (a[i].getAttribute('label') && a[i].getAttribute('label').toUpperCase().indexOf(filter) > -1) {
a[i].style.display = 'block'
} else {
a[i].style.display = 'none'
}
}
}
");
echo '
';
exit;
}
echo $tbl->render();
if (DBG::isActive() && V::get('DBG_ACL', '', $_GET)) {// test load perms
Lib::loadClass('DebugExecutionTime');
$dbgExecTime = new DebugExecutionTime();
$dbgExecTime->activate();
$dbgExecTime->log('start');
UI::startContainer(['style'=>'border:1px solid red']);
UI::tag('p', null, "TEST - load perms from db");
$idTable = $acl->getID();
UI::tag('p', null, "DBG idTable({$idTable})");
if ($idTable > 0) {
$dbgExecTime->log('before sql');
$aclTableRows = DB::getPDO()->fetchAll("select * from `CRM_PROCES_idx_TABLE_TO_PROCES_PERMS_VIEW` where ID_TABLE = {$idTable}");
$dbgExecTime->log('after sql', ['sql']);
UI::table(['caption' => "from CRM_PROCES_idx_TABLE_TO_PROCES_PERMS_VIEW", 'rows' => $aclTableRows]);
$csvIdProces = array();
foreach ($aclTableRows as $row) {
if (!in_array($row['ID_PROCES'], $csvIdProces)) $csvIdProces[] = $row['ID_PROCES'];
}
}
$tableName = $acl->getName();
$databaseName = DB::getPDO()->getDatabaseName();
UI::table([
'caption' => "Cell to process",
'rows' => array_map(
function ($row) use ($aclTableRows, $idTable) {
$row['proces'] = array();
$row['id_zasob'] = 0;
$row['PERM_R'] = 0;
$row['PERM_W'] = 0;
$row['PERM_X'] = 0;
$row['PERM_C'] = 0;
$row['PERM_S'] = 0;
$row['PERM_O'] = 0;
$row['PERM_V'] = 0;
$row['PERM_E'] = 0;
foreach ($aclTableRows as $aclInfo) {
if (strtolower($aclInfo['CELL_NAME']) == strtolower($row['COLUMN_NAME'])) {
$row['proces'][] = $aclInfo['ID_PROCES'];
$row['id_zasob'] = $aclInfo['ID_CELL'];
$row['PERM_R'] += $aclInfo['PERM_R'];
$row['PERM_W'] += $aclInfo['PERM_W'];
$row['PERM_X'] += $aclInfo['PERM_X'];
$row['PERM_C'] += $aclInfo['PERM_C'];
$row['PERM_S'] += $aclInfo['PERM_S'];
$row['PERM_O'] += $aclInfo['PERM_O'];
$row['PERM_V'] += $aclInfo['PERM_V'];
$row['PERM_E'] += $aclInfo['PERM_E'];
}
}
$row['proces'] = (empty($row['proces']))
? "Brak"
: implode(", ", $row['proces']);
if (!$row['id_zasob']) $row['id_zasob'] = DB::getPDO()->fetchValue("select ID from CRM_LISTA_ZASOBOW where `DESC` = '{$row['COLUMN_NAME']}' and PARENT_ID = {$idTable} limit 1");
return $row;
}, DB::getPDO()->fetchAll("
select t.TABLE_NAME, t.COLUMN_NAME, t.DATA_TYPE, t.COLUMN_TYPE
from `information_schema`.`COLUMNS` t
where t.TABLE_SCHEMA = '{$databaseName}'
and t.TABLE_NAME like '{$tableName}'
")
)
]);
if (!empty($csvIdProces)) {
$csvIdProces = implode(",", $csvIdProces);
UI::tag('p', null, "DBG csvIdProces({$csvIdProces})");
$userLogin = User::getLogin();
$dbgExecTime->log('before sql');
$rows = DB::getPDO()->fetchAll("select ID_PROCES from `CRM_PROCES_idx_USER_to_PROCES_VIEW` where ADM_ACCOUNT = '{$userLogin}' and ID_PROCES in({$csvIdProces}) group by ID_PROCES");
$dbgExecTime->log('after sql', ['sql']);
UI::table(['caption' => "from CRM_PROCES_idx_USER_to_PROCES_VIEW", 'rows' => $rows]);
$userIdProces = array(); foreach ($rows as $row) $userIdProces[] = $row['ID_PROCES'];
$userTablePerms = array();
foreach ($aclTableRows as $row) {
if (!in_array($row['ID_PROCES'], $userIdProces)) continue;
if (array_key_exists($row['CELL_NAME'], $userTablePerms)) {
$userTablePerms[ $row['CELL_NAME'] ][ 'PERM_R' ] += $row['PERM_R'];
$userTablePerms[ $row['CELL_NAME'] ][ 'PERM_W' ] += $row['PERM_W'];
$userTablePerms[ $row['CELL_NAME'] ][ 'PERM_X' ] += $row['PERM_X'];
$userTablePerms[ $row['CELL_NAME'] ][ 'PERM_C' ] += $row['PERM_C'];
$userTablePerms[ $row['CELL_NAME'] ][ 'PERM_S' ] += $row['PERM_S'];
$userTablePerms[ $row['CELL_NAME'] ][ 'PERM_O' ] += $row['PERM_O'];
$userTablePerms[ $row['CELL_NAME'] ][ 'PERM_V' ] += $row['PERM_V'];
$userTablePerms[ $row['CELL_NAME'] ][ 'PERM_E' ] += $row['PERM_E'];
} else {
$userTablePerms[ $row['CELL_NAME'] ] = $row;
unset($userTablePerms[ $row['CELL_NAME'] ][ 'TABLE_DESCRIPTION' ]);
unset($userTablePerms[ $row['CELL_NAME'] ][ 'ID_PROCES' ]);
unset($userTablePerms[ $row['CELL_NAME'] ][ 'FORM_TREAT' ]);
}
}
UI::table(['caption' => "\$userTablePerms", 'rows' => $userTablePerms]);
} else UI::alert('warning', "brak \$csvIdProces");
$dbgExecTime->printDebug();
UI::endContainer();
}
} catch (Exception $e) {
UI::startContainer();
UI::alert('danger', "Wystąpiły błędy! " . $e->getMessage());
UI::endContainer();
DBG::log($e);
}
UI::dol();
}
public function setInstanceAjaxAction() {
Response::sendTryCatchJson(array($this, 'setInstanceAjax'), $args = 'JSON_FROM_REQUEST_BODY');
}
public function setInstanceAjax($args) {
// namespace => default_db/CRM_PROCES/PROCES_INIT
// primaryKey => 6
// instance => default_db/CRM_PROCES/PROCES_TREE
// toConnect => yes
if (empty($args['namespace'])) throw new Exception("Missing namespace");
if (empty($args['primaryKey'])) throw new Exception("Missing primaryKey");
if (empty($args['instance'])) throw new Exception("Missing instance");
if (empty($args['toConnect'])) throw new Exception("Missing toConnect");
if (!in_array($args['toConnect'], ['yes', 'no'])) throw new Exception("Wrong param toConnect");
$idInstance = ACL::getInstanceId($args['instance']);
throw new Exception("TODO: check instance config"); // if 'view' then set instance is not allowed
// $instanceTable = ACL::getInstanceTable($args['namespace']);
// switch ($args['toConnect']) {
// case 'yes': {
// // TODO: _HIST info - waiting
// $ret = DB::getPDO()->execSql("
// insert into `{$instanceTable}` (`pk`, `idInstance`)
// values ( :pk , :idInstance )
// ", [
// 'pk' => $args['primaryKey'],
// 'idInstance' => $idInstance,
// ]);
// // TODO: _HIST info - mark as done
// } break;
// case 'no': {
// // TODO: _HIST info - waiting
// $ret = DB::getPDO()->execSql("
// delete from `{$instanceTable}`
// where `pk` = :pk
// and `idInstance` = :idInstance
// ", [
// 'pk' => $args['primaryKey'],
// 'idInstance' => $idInstance,
// ]);
// // TODO: _HIST info - mark as done
// } break;
// }
// return [
// 'type' => 'success',
// 'msg' => "Wprowadzono zmiany ({$ret})",
// // TODO: 'data' => all instances for pk
// ];
}
public function rmUserTableFilterAjaxAction() {
Response::sendTryCatchJson(array($this, 'rmUserTableFilterAjax'), $args = 'JSON_FROM_REQUEST_BODY');
}
public function rmUserTableFilterAjax($args) {
$namespace = V::get('namespace', '', $args);
$filtrName = V::get('filtrName', '', $args);
if (!$namespace) throw new Exception("Missing namespace");
if (!$filtrName) throw new Exception("Missing filtrName");
$userFltrConfKey = "tableColFilters__" . User::getLogin();
$currentFilters = DB::getPDO()->fetchValue(" select CONF_VAL from CRM_CONFIG where CONF_KEY = '{$userFltrConfKey}' ");
if (!$currentFilters) return [
'type' => 'warning',
'msg' => "Brak filtrów w bazie",
];
$currentFilters = json_decode($currentFilters, 'assoc');
unset($currentFilters[$namespace][$filtrName]);
$affeced = DB::getPDO()->update('CRM_CONFIG', 'CONF_KEY', $userFltrConfKey, [
'CONF_VAL' => json_encode($currentFilters)
]);
return [
'type' => 'success',
'msg' => 'Zapisano nowy filtr',
'data' => $currentFilters[$namespace]
];
}
public function addUserTableFilterAjaxAction() {
Response::sendTryCatchJson(array($this, 'addUserTableFilterAjax'), $args = 'JSON_FROM_REQUEST_BODY');
}
public function addUserTableFilterAjax($args) {
$namespace = V::get('namespace', '', $args);
$filtrName = V::get('filtrName', '', $args);
$visibleCols = V::get('visibleCols', '', $args);
if (!$namespace) throw new Exception("Missing namespace");
if (!$filtrName) throw new Exception("Missing filtrName");
if (!$visibleCols) throw new Exception("Missing visibleCols");
$userFltrConfKey = "tableColFilters__" . User::getLogin();
$currentFilters = DB::getPDO()->fetchValue(" select CONF_VAL from CRM_CONFIG where CONF_KEY = '{$userFltrConfKey}' ");
$currentFilters = ($currentFilters) ? json_decode($currentFilters, 'assoc') : [];
$currentFilters[$namespace][$filtrName] = $visibleCols;
$sqlFltr = json_encode($currentFilters);
DB::getPDO()->execSql("
insert into CRM_CONFIG (CONF_KEY, CONF_VAL)
values ('$userFltrConfKey', '{$sqlFltr}')
on duplicate key update CONF_VAL = '{$sqlFltr}'
");
return [
'type' => 'success',
'msg' => 'Zapisano nowy filtr',
'data' => $currentFilters[$namespace]
];
}
public function getUserTableFilterAjaxAction() {
Response::sendTryCatchJson(array($this, 'getUserTableFilterAjax'), $args = 'JSON_FROM_REQUEST_BODY');
}
public function getUserTableFilterAjax($args) {
$namespace = V::get('namespace', '', $args);
if (!$namespace) throw new Exception("Missing namespace");
$userFltrConfKey = "tableColFilters__" . User::getLogin();
$currentFilters = DB::getPDO()->fetchValue(" select CONF_VAL from CRM_CONFIG where CONF_KEY = '{$userFltrConfKey}' ");
$currentFilters = ($currentFilters) ? json_decode($currentFilters, 'assoc') : [];
return [
'type' => 'success',
'msg' => 'Odczytano filtry użytkownika',
'data' => (!empty($currentFilters[$namespace])) ? $currentFilters[$namespace] : []
];
}
public function revertFromHistAjaxAction() {
Response::sendTryCatchJson(array($this, 'revertFromHistAjax'));
}
public function revertFromHistAjax() {
$typeName = V::get('typeName', '', $_REQUEST, 'word');
if (!$typeName) throw new Exception("Wrong param typeName");
// TODO: use namespace from url
// $namespace = V::get('namespace', '', $_GET, 'word');
// if (!$namespace) {
// $typeName = V::get('typeName', '', $_GET, 'word');
// if (!$typeName) throw new Exception("Wrong param typeName");
// $namespace = Api_WfsNs::getBaseWfsUri() . '/' . str_replace(':', '/', $typeName);
// }
// $acl = Core_AclHelper::getAclByNamespace($namespace, $forceTblAclInit = ('1' == V::get('_force', '', $_GET)));
$id = V::get('ID', '', $_REQUEST, 'word');
if (!$id) throw new Exception("Wrong param ID");
$idHist = V::get('idHist', '', $_REQUEST, 'word');
if (!$idHist) throw new Exception("Wrong param idHist");
$fieldName = V::get('fieldName', '', $_REQUEST, 'word');
if (!$fieldName) throw new Exception("Wrong param fieldName");
$acl = Core_AclHelper::getAclByTypeName($typeName);
$item = $acl->getItem($id);
if (!$item) throw new HttpException("Item not found", 404);
if (!$acl->canWriteObjectField($fieldName, $record)) throw new Exception("Missing perm Write for field {$fieldName}");
$histItem = $acl->getHistItem($id, $idHist);
if (!$histItem) throw new HttpException("Hist Item not found", 404);
$histValue = V::get($fieldName, 'N/S;', $histItem);
if ('N/S;' == $histValue) throw new Exception("Missing field value in hist[{$idHist}] for field({$fieldName}) from item[{$id}]");
if ($acl->isGeomField($fieldName)) {
$wktType = strtoupper($acl->getGeomFieldType($fieldName));
if (!$wktType) throw new Exception("Wrong geometry type for field {$fieldName}");
if ($wktType != strtoupper(substr($histValue, 0, strlen($wktType)))) throw new Exception("Wrong geometry type for field {$fieldName} in hist value");
$coords = trim(substr($histValue, strlen($wktType)), '()');
$wktValue = $acl->convertGmlCoordsToWkt($wktType, $coords, ['cs'=>' ', 'ts'=>',']);
if (!$wktValue) throw new Exception("BUG in hist record");
$sqlObj = array();
$sqlObj['ID'] = $id;
$sqlObj[$fieldName] = "GeomFromText('{$wktValue}')";
$affected = DB::getDB()->UPDATE_OBJ($acl->getName(), (object)$sqlObj);
if (0 == $affected) throw new AlertInfoException("Nie wprowadzono żadnych zmian");
else if ($affected < 0) throw new Exception("Wystąpiły błędy podczas aktualizacji rekordu [{$id}]");
$jsonResponse = array();
$jsonResponse['type'] = 'success';
$jsonResponse['msg'] = "Zaktualizowano dane na podstawie wcześniejszej wartości dla rekordu [{$id}]";
$jsonResponse['actions'] = array();
$jsonResponse['actions'][] = ['jsFunction'=>'TableAjax__HIST_Route', 'args'=>[$id]];
return $jsonResponse;
} else {
throw new HttpException("Not implemented - update from hist only for the geom field", 501);
}
throw new Exception("BUG: update field '{$fieldName}' in item[{$id}] from hist[{$idHist}]", 501);
}
public function removeTheGeomAjaxAction() {
Response::sendTryCatchJson(array($this, 'removeTheGeomAjax'), $args = 'JSON_FROM_REQUEST_BODY');
}
public function removeTheGeomAjax($args) {
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new HttpException("Bad Request - missing namespace", 400);
$acl = Core_AclHelper::getAclByNamespace($namespace, $forceTblAclInit = ('1' == V::get('_force', '', $_GET)));
$primaryKeyField = $acl->getPrimaryKeyField();
$primaryKey = V::get($primaryKeyField, 0, $args, 'int');
$geomFieldName = 'the_geom';
$response = new stdClass();
if ($primaryKey <= 0) throw new HttpException("Bad Request - Wrong param ID", 400);
$record = $acl->getItem($primaryKey);
if (!$record) throw new HttpException("Nie odnaleziono rekordu nr {$primaryKey}", 404);
if (!$acl->canWriteObjectField($geomFieldName, $record)) throw new HttpException("Brak dostępu do zapisu dla pola {$geomFieldName}", 403);
if (empty($record->{$geomFieldName})) {
$response->type = 'info';
$response->msg = "Rekord nie jest powiązany z żadnym obiektem na mapie";
$response->record = $record;
return $response;
}
$itemPatch = array();
$itemPatch[$geomFieldName] = "NULL";
$itemPatch[$primaryKeyField] = $primaryKey;
$response = new stdClass();
try {
$affected = $acl->updateItem($itemPatch);
if ($affected > 0) {
$response->type = 'success';
$response->msg = "Usunięto obiekt z mapy dla rekordu {$primaryKey}";// Rekord zapisany pomyślnie
} else if ($affected == 0) {
$response->type = 'info';
$response->msg = "Nie wprowadzono żadnych zmian";
}
$response->record = $acl->getItem($primaryKey);
}
catch (Exception $e) {
$response->type = 'error';
$response->msg = $e->getMessage();
}
return $response;
}
public function getCsvTheGeomAjaxAction() {
try {
self::getCsvTheGeomAjax();
} catch (Exception $e) {
SE_Layout::gora();
SE_Layout::menu();
SE_Layout::alert('danger', $e->getMessage());
?>
getRootTableName();
$id = V::get('id', 0, $_GET, 'int');
$query = "select st_astext(`the_geom`) as `the_geom` from `{$table}` where `ID` = {$id}";
try {
$result = DB::getPDO()->fetchValue($query);
} catch (Exception $e) {
throw new Exception('Błąd zapytania SQL');
}
if (!preg_match('/^[[:alpha:]]+\((.*)\)$/', $result, $matches)) throw new Exception('Błąd danych georeferencyjnych');
$points = explode(',', $matches[1]);
$csv = implode("\n", array_map(function ($point, $i) {
list($x, $y) = explode(" ", $point, 2);
$wgs84 = EpsgConversion::LonLatToPUWGWGS84($x, $y);
return $i++ . ',' . round($wgs84->y, 3) . ',' . round($wgs84->x, 3) . ',0,Pikieta';
}, $points, range(1, count($points))));
Response::sendCsv($csv, "{$table}.{$id}");
}
public function moreFunctionsCellAjaxAction() {
Response::sendTryCatchJson(array($this, 'moreFunctionsCell'), $args = $_GET);
}
public function moreFunctionsCell($args) {// ajax task 'MORE_FUNCTIONS_CELL'
$id = V::get('ID', 0, $args, 'int');
if ($id <= 0) throw new HttpException("404", 404);
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new HttpException("Bad Request - missing namespace", 400);
$acl = Core_AclHelper::getAclByNamespace($namespace, $forceTblAclInit = ('1' == V::get('_force', '', $args)));
$response = new stdClass();
$response->type = 'success';
$response->msg = 'Funkcje';
$response->rowFunctions = Core_AclHelper::getMoreFunctionsCell($acl, array('primary_key' => $id));
return $response;
}
public function createFormAction() {// TODO: move to createFormJsonAction
try {
$args = $_REQUEST;
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new HttpException("Bad Request - missing namespace", 400);
$acl = Core_AclHelper::getAclByNamespace($namespace);
$tbl = $this->getTableAjaxWidget($acl);
$tbl->sendAjaxCreate();
} catch (Exception $e) {
DBG::log($e);
throw $e;
}
}
public function createFormJsonAction() {
Response::sendTryCatchJson(array($this, 'createFormJson'), $args = $_REQUEST);
}
public function createFormJson($args) { // namespace, _hash, _primaryKey
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new HttpException("Bad Request - missing namespace", 400);
$acl = Core_AclHelper::getAclByNamespace($namespace);
$tbl = $this->getTableAjaxWidget($acl);
if (!Core_AclHelper::hasCreatePerms($acl)) {
return [
'type' => "success",
'msg' => "Dodaj nowy rekord",
'body' => [
'reactNode' => [ 'div', [ 'class' => "alert alert-danger" ], "Brak uprawnień do utworzenia nowego rekordu." ]
],
];
// throw new Exception("Brak uprawnień do utworzenia nowego rekordu.");
}
$fieldsList = array();
foreach ($acl->getFieldListByIdZasob() as $kID => $fieldName) {
if ($fieldName == 'ID') continue;
$field['name'] = $fieldName;
$field['opis'] = $acl->getFieldOpis($fieldName);
$field['label'] = $acl->getFieldLabel($fieldName);
if (empty($field['label'])) $field['label'] = str_replace('_', ' ', $fieldName);
$fieldsList[$kID] = $field;
}
$cols = array();
$forceFilterInit = array();
$defaultAclGroup = User::getDefaultAclGroup();
if ($defaultAclGroup) {
$forceFilterInit['A_ADM_COMPANY'] = $defaultAclGroup;
$forceFilterInit['A_CLASSIFIED'] = $defaultAclGroup;
}
foreach ($_GET as $k => $v) { // TODO: read from $args ?
if (strlen($k) > 4 && substr($k, 0, 3) == 'ff_' && !empty($v)) {// force filter prefix
$fldName = substr($k, 3);
$forceFilterInit[$fldName] = $v;
}
}
DBG::log($forceFilterInit, 'array', "\$forceFilterInit");
foreach ($fieldsList as $kID => $field) {
$defaultValue = '';
if (!empty($forceFilterInit[$field['name']])) {
$defaultValue = $forceFilterInit[$field['name']];
}
$cols[$kID] = V::get("f{$kID}", $defaultValue, $_POST);
}
DBG::log($cols, 'array', "\$cols - field values");
$tsValues = array();
$featureFunctions = [
// 'edit' => [ 'href' => '#EDIT/{0}', 'ico' => 'glyphicon glyphicon-pencil', 'title' => "Edytuj rekord"],
'hist' => [ 'href' => '#HIST/{0}', 'ico' => 'glyphicon glyphicon-book', 'title' => "Historia" ],
'files' => [ 'href' => '#FILES/{0}', 'ico' => 'glyphicon glyphicon-folder-open', 'title' => "Pliki" ],
// 'cp' => [ 'href' => '#', 'ico' => 'glyphicon glyphicon-plus-sign', 'title' => "Kopiuj rekord", 'onclick' => 'return tableAjaxCopy({0});' ],
'msgs' => [ 'href' => "index.php?_route=TableMsgs&_task=tableRow&idTable=".$acl->getID()."&idRow={0}", 'ico' => 'glyphicon glyphicon-envelope', 'title' => "Wiadomości" ],
];
$jsFields = [];
$tabindex = 0;
foreach ($fieldsList as $kID => $vCol) {
$fieldName = $vCol['name'];
$fieldLabel = str_replace('
', ' ', $vCol['label']);
DBG::log(['$fieldName'=>$fieldName, 'canCreate'=>$acl->canCreateField($fieldName)], 'array', "form field");
if ($acl->canCreateField($fieldName)) {
DBG::log("editFormJson::field({$fieldName})");
$fieldParams = [ 'appendBack' => true, 'tabindex' => (++$tabindex), 'maxGrid' => 8 ];
if (!empty($tsValues[$kID])) $fieldParams['typespecialValue'] = $tsValues[$kID];
$jsFields[] = [ 'div', [ 'class' => "form-group" ], [
[ 'label', [ 'class' => "control-label", 'for' => "f{$kID}" ], [
[ 'span', [ 'style' => ['padding-right'=>'4px'] ], $fieldLabel ],
[ 'i', [ 'class' => "glyphicon glyphicon-info-sign frm-help", 'data-toggle' => "popover", 'data-trigger' => "hover", 'title' => "", 'data-content' => htmlspecialchars($vCol['opis']), 'data-original-title' => "[{$kID}] {$fieldName}" ] ],
] ],
[ 'div', [ 'class' => "" ], [
UI::hGetFormItem($acl, $fieldName, 'C', $kID, "f{$kID}", $cols[$kID], $fieldParams),
] ]
] ];
// } else {
// $jsFields[] = [ 'div', [ 'class' => "form-group" ], [
// "TODO: SKIP field ({$fieldName}) - ! canWriteObjectField && ! canReadObjectField"
// ]];
}
}
$jsFields[] = [ 'div', [ 'class' => "form-group" ], [
[ 'div', [ 'class' => "" ], [
['button', [ 'type' => "submit", 'class' => "btn btn-primary", 'tabindex' => ++$tabindex ], "Zapisz" ]
] ]
] ];
$tblLabel = $acl->getNamespace();
if ('default_db' == $acl->getSourceName()) {
$tblLabel = array();
$zasobObj = ProcesHelper::getZasobTableInfo($acl->getID());
if (!$zasobObj) throw new Exception("Zasob TABELA ID=" . $acl->getID() . " nie istnieje");
if (!empty($zasobObj->DESC_PL)) $tblLabel []= $zasobObj->DESC_PL;
if (!empty($zasobObj->OPIS)) $tblLabel []= $zasobObj->OPIS;
$tblLabel = implode(" - ", $tblLabel);
}
$syncUrl = Request::getPathUri() . 'index.php?_route=ViewTableAjax&namespace=' . $acl->getNamespace();
$jsGui = [
'reactNode' => [ 'div', [ 'class' => "container AjaxFrmHorizontalEdit", 'style' => [ "max-width" => "940px" ] ], [
[ 'h4', [ 'style' => [ "padding-bottom" => "3px", "border-bottom" => "1px solid #ddd" ] ], [
"Dodaj nowy rekord",
] ],
[ 'P5UI__FeatureCreateForm', [
'class' => "", 'action' => "", 'method' => "post",
'id' => "CREATE_FRM_{$this->_htmlID}", // TODO: rm - use React nodes // TODO: $this->_htmlID not exists!
'ajaxSaveUrl' => "{$syncUrl}&_task=createSaveAjax", // TODO:? &_hash={$this->_htmlID}
'ajaxSaveLegacyUrl' => "{$syncUrl}&_task=createSaveLegacy", // TODO: Legacy RM
'namespace' => $acl->getNamespace(),
'tableLabelHtml' => $tblLabel,
'_htmlID' => $acl->getName(),
], [
[ 'fieldset', [ 'style' => [ "padding-bottom" => "100px" ] ], $jsFields ] // fieldset
] ] // form
] ] // .container
];
return [
'type' => "success",
'msg' => "Dodaj nowy rekord",
'body' => $jsGui, // TODO: action for GUI: array to render by function h, js to trigger
];
}
public function createSaveAjaxAction() {
Response::sendTryCatchJson(array($this, 'createSaveAjax'), $args = 'JSON_FROM_REQUEST_BODY');
}
public function createSaveAjax($args) {
throw new Exception("TODO: ...");
}
public function createSaveLegacyAction() { // TODO: Legacy RM
$args = [
'namespace' => V::get('namespace', '', $_GET),
'body' => Request::getRequestJson(),
];
DBG::log($args, 'array', 'createSaveLegacyAction');
Response::sendTryCatchJson(array($this, 'createSaveLegacy'), $args);
}
public function createSaveLegacy($args) { // TODO: Legacy RM
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new HttpException("Bad Request - missing namespace", 400);
$body = V::get('body', null, $args);
if (!$body) throw new HttpException("Bad Request - missing body", 400);
$acl = Core_AclHelper::getAclByNamespace($namespace);
$tbl = $this->getTableAjaxWidget($acl);
DBG::log($args, 'array', "ajaxCreateSave");
$createdId = null;
try {
$item = $acl->convertObjectFromUserInput($body, $type = 'array_by_id', $prefix = 'f');
$createdId = $acl->addItem($item);
if ($createdId) {
return [
'type' => 'success',
'msg' => "Utworzono pomyślnie rekord nr {$createdId}",
'id' => $createdId,
'record' => $acl->buildQuery([])->getItem($createdId),
];
}
else {
return [
'type' => 'error',
'msg' => "Nie udało się utworzyć nowego rekordu!",
];
}
}
catch (Exception $e) {
return [
'type' => 'error',
'msg' => $e->getMessage(),
];
}
}
public function editFormAction() { // TODO: not used - moved to editFormJsonAction
try {
$args = $_REQUEST;
$id = V::get('_primaryKey', 0, $args, 'int');
if ($id <= 0) throw new HttpException("Bad Request - missing primaryKey", 400);
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new HttpException("Bad Request - missing namespace", 400);
$acl = Core_AclHelper::getAclByNamespace($namespace);
$tbl = $this->getTableAjaxWidget($acl);
$tbl->sendAjaxEdit($id, $args);
} catch (Exception $e) {
DBG::log($e);
throw $e;
}
}
public function editFormJsonAction() {
Response::sendTryCatchJson(array($this, 'editFormJson'), $args = $_REQUEST);
}
public function editFormJson($args) { // namespace, _hash, _primaryKey
$id = V::get('_primaryKey', 0, $args, 'int');
if ($id <= 0) throw new HttpException("Bad Request - missing primaryKey", 400);
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new HttpException("Bad Request - missing namespace", 400);
$acl = Core_AclHelper::getAclByNamespace($namespace);
$tbl = $this->getTableAjaxWidget($acl);
$record = $acl->buildQuery([])->getItem($id);
if (!$acl->canWriteRecord($record) && !$acl->hasPermSuperWrite()) {
return [
'type' => "success",
'msg' => "Edycja rekordu nr {$id}",
'body' => [
'reactNode' => [ 'div', [ 'class' => "alert alert-danger" ], "Brak dostępu do rekordu" ]
],
];
// throw new Exception("Brak dostępu do rekordu");
}
$fieldsList = array();
foreach ($acl->getFieldListByIdZasob() as $kID => $fieldName) {
if ($fieldName == 'ID') continue;
$field['name'] = $fieldName;
$field['opis'] = $acl->getFieldOpis($fieldName);
$field['label'] = $acl->getFieldLabel($fieldName);
if (empty($field['label'])) $field['label'] = str_replace('_', ' ', $fieldName);
$fieldsList[$kID] = $field;
}
$cols = array();
foreach ($fieldsList as $kID => $field) {
$cols[$kID] = '';
if ($acl->canReadObjectField($field['name'], $record)) {
$cols[$kID] = V::get($field['name'], '', $record);
} else {
$cols[$kID] = '*****';
}
$cols[$kID] = V::get("f{$kID}", $cols[$kID], $_POST);
}
$tsValues = array();
if (!empty($fieldsList)) {
foreach ($fieldsList as $vColID => $vCol) {
$typeSpecial = Typespecial::getInstance($vColID, $vCol['name']);
if ($typeSpecial) {
$colValue = V::get($vCol['name'], '', $record);
$specialValues = $typeSpecial->getEditSelectedValuesByIds($acl->getID(), $record['ID'], $vCol['name'], $colValue);
if (!empty($specialValues)) {
$tsValues[$vColID] = implode('
', $specialValues);
}
}
}
}
DBG::log($tsValues, 'array', "editFormJson::tsValues");
foreach ($tsValues as $idx => $value) {
if ('<' === substr($value, 0, 1)) {
// $tsValues[$idx] = UI::convertHtmlToArray($value); // TODO: ...
$tsValues[$idx] = [ 'P5UI__RawHtml', [ 'rawHtml' => $tsValues[$idx] ] ];
}
}
DBG::log($tsValues, 'array', "editFormJson::tsValues parsed");
$featureFunctions = [
// 'edit' => [ 'href' => '#EDIT/{0}', 'ico' => 'glyphicon glyphicon-pencil', 'title' => "Edytuj rekord"],
'hist' => [ 'href' => '#HIST/{0}', 'ico' => 'glyphicon glyphicon-book', 'title' => "Historia" ],
'files' => [ 'href' => '#FILES/{0}', 'ico' => 'glyphicon glyphicon-folder-open', 'title' => "Pliki" ],
// 'cp' => [ 'href' => '#', 'ico' => 'glyphicon glyphicon-plus-sign', 'title' => "Kopiuj rekord", 'onclick' => 'return tableAjaxCopy({0});' ],
'msgs' => [ 'href' => "index.php?_route=TableMsgs&_task=tableRow&idTable=".$acl->getID()."&idRow={0}", 'ico' => 'glyphicon glyphicon-envelope', 'title' => "Wiadomości" ],
];
$rowFunctionsOut = [ 'P5UI__FeatureRowFunctions', [
'id' => $record[ $acl->getPrimaryKeyField() ],
'functions' => $featureFunctions,
'showLabels' => true,
'viewMoreDropdown' => [
'primaryKey' => $record['ID'],
'uri' => $this->getLink('moreFunctionsCellAjax', [ 'namespace' => $acl->getNamespace(), 'ID' => $record['ID'] ]),
],
] ]; // TODO: $this->_showRowFunctions($record['ID'], array('edit', 'cp'), true);
$jsFields = [];
$tabindex = 0;
foreach ($fieldsList as $kID => $vCol) {
$fieldName = $vCol['name'];
$fieldLabel = str_replace('
', ' ', $vCol['label']);
DBG::log(['$fieldName'=>$fieldName, '$record'=>$record, 'canWrite'=>$acl->canWriteObjectField($fieldName, $record), 'canRead'=>$acl->canReadObjectField($fieldName, $record)], 'array', "form field");
if ($acl->canWriteObjectField($fieldName, $record)) {
DBG::log("editFormJson::field({$fieldName})");
$fieldParams = [ 'appendBack' => true, 'tabindex' => (++$tabindex), 'maxGrid' => 8 ];
if (!empty($tsValues[$kID])) $fieldParams['typespecialValue'] = $tsValues[$kID];
$jsFields[] = [ 'div', [ 'class' => "form-group" ], [
[ 'label', [ 'class' => "control-label", 'for' => "f{$kID}" ], [
[ 'span', [ 'style' => ['padding-right'=>'4px'] ], $fieldLabel ],
[ 'i', [ 'class' => "glyphicon glyphicon-info-sign frm-help", 'data-toggle' => "popover", 'data-trigger' => "hover", 'title' => "", 'data-content' => htmlspecialchars($vCol['opis']), 'data-original-title' => "[{$kID}] {$fieldName}" ] ],
] ],
[ 'div', [ 'class' => "" ], [
UI::hGetFormItem($acl, $fieldName, 'W', $kID, "f{$kID}", $cols[$kID], $fieldParams, $record),
] ]
] ];
} else if ($acl->canReadObjectField($fieldName, $record)) {
$jsFields[] = [ 'div', [ 'class' => "form-group" ], [
[ 'label', [ 'class' => "control-label", 'for' => "f{$kID}" ], [
[ 'span', [ 'style' => ['padding-right'=>'4px'] ], $fieldLabel ],
[ 'i', [ 'class' => "glyphicon glyphicon-info-sign frm-help", 'data-toggle' => "popover", 'data-trigger' => "hover", 'title' => "", 'data-content' => htmlspecialchars($vCol['opis']), 'data-original-title' => "[{$kID}] {$fieldName}" ] ],
] ],
[ 'div', [ 'class' => "" ], [
['p', [ 'style' => [ 'margin-top' => '5px' ] ], [
(!empty($tsValues[$kID]))
? $tsValues[$kID]
: V::get($fieldName, '', $record)
] ],
] ]
] ];
// } else {
// $jsFields[] = [ 'div', [ 'class' => "form-group" ], [
// "TODO: SKIP field ({$fieldName}) - ! canWriteObjectField && ! canReadObjectField"
// ]];
}
}
$jsFields[] = [ 'div', [ 'class' => "form-group" ], [
[ 'div', [ 'class' => "" ], [
['button', [ 'type' => "submit", 'class' => "btn btn-primary", 'tabindex' => ++$tabindex ], "Zapisz" ]
] ]
] ];
$tblLabel = $acl->getNamespace();
if ('default_db' == $acl->getSourceName()) {
$tblLabel = array();
$zasobObj = ProcesHelper::getZasobTableInfo($acl->getID());
if (!$zasobObj) throw new Exception("Zasob TABELA ID=" . $acl->getID() . " nie istnieje");
if (!empty($zasobObj->DESC_PL)) $tblLabel []= $zasobObj->DESC_PL;
if (!empty($zasobObj->OPIS)) $tblLabel []= $zasobObj->OPIS;
$tblLabel = implode(" - ", $tblLabel);
}
$syncUrl = Request::getPathUri() . 'index.php?_route=ViewTableAjax&namespace=' . $acl->getNamespace();
$jsGui = [
'reactNode' => [ 'div', [ 'class' => "container AjaxFrmHorizontalEdit", 'style' => [ "max-width" => "940px" ] ], [
[ 'h4', [ 'style' => [ "padding-bottom" => "3px", "border-bottom" => "1px solid #ddd" ] ], [
"Edycja rekordu Nr {$record['ID']}",
[ 'small', [ 'class' => "pull-right valign-btns-bottom" ], [ $rowFunctionsOut ] ],
] ],
[ 'P5UI__FeatureEditForm', [
'class' => "", 'action' => "", 'method' => "post",
'id' => "EDIT_FRM_{$this->_htmlID}", // TODO: rm - use React nodes // TODO: $this->_htmlID not exists!
'ajaxSaveUrl' => "{$syncUrl}&_task=editSaveAjax", // TODO:? &_hash={$this->_htmlID}
'namespace' => $acl->getNamespace(),
'idRecord' => $record['ID'],
'tableLabelHtml' => $tblLabel,
], [
[ 'fieldset', [ 'style' => [ "padding-bottom" => "100px" ] ], $jsFields ] // fieldset
] ] // form
] ] // .container
];
return [
'type' => "success",
'msg' => "Edycja rekordu nr {$id}",
'body' => $jsGui, // TODO: action for GUI: array to render by function h, js to trigger
];
}
public function editSaveAjaxAction() {
Response::sendTryCatchJson(array($this, 'editSaveAjax'), $args = 'JSON_FROM_REQUEST_BODY');
}
public function editSaveAjax($args) {
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new HttpException("Bad Request - missing namespace", 400);
$acl = Core_AclHelper::getAclByNamespace($namespace);
$primaryKeyField = $acl->getPrimaryKeyField();
$primaryKey = V::get('primaryKey', 0, $args, 'int');
if (empty($primaryKey)) throw new HttpException("Bad Request - missing primaryKey!", 400);
$item = $acl->getItem($primaryKey);
if (!$item) throw new HttpException("Item not exists!", 404);
$itemFromUser = $acl->convertObjectFromUserInput($args['form'], $type = 'array_by_id', $prefix = 'f');
$response = new stdClass();
$response->primaryKey = $primaryKey;
try {
$itemFromUser[$primaryKeyField] = $primaryKey;
$affected = $acl->updateItem($itemFromUser);
if ($affected > 0) {
$response->type = 'success';
$response->msg = "Rekord zapisany pomyślnie";//"Record saved successfully";
} else if ($affected == 0) {
$response->type = 'info';
$response->msg = "Nie wprowadzono żadnych zmian";
}
$response->record = $acl->getItem($primaryKey);
$rowFunList = Core_AclHelper::getMoreFunctionsCell($acl, array('primary_key'=>$primaryKey, 'record'=>$response->record));
if (!empty($rowFunList)) $response->rowFunctions = $rowFunList;
}
catch (Exception $e) {
$response->type = 'error';
$response->msg = "Wystąpiły błędy!";
$response->msg .= $e->getMessage();
}
return $response;
}
public function typeSpecialCellAction() {
Response::sendTryCatchJson(array($this, 'typeSpecialCell'), $args = $_REQUEST);
}
public function typeSpecialCell($args) {
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new HttpException("Bad Request - missing namespace", 400);
$acl = Core_AclHelper::getAclByNamespace($namespace);
$id = V::get('ID', 0, $args, 'int');
$fieldName = V::get('col', '', $args);
if ($id <= 0 || empty($fieldName)) throw new HttpException("Bad Request - missing id or col", 400);
$col = $fieldName;// TODO: RM $col
$jsonData = new stdClass();
$idField = $acl->getFieldIdByName($fieldName);
if (!$idField) throw new Exception("Wrong field");
$item = $acl->getItem($id);
if (!$acl->canReadObjectField($fieldName, $item)) throw new Exception("Brak dostępu");
$typeSpecial = Typespecial::getInstance($idField, $fieldName);
if ($typeSpecial) {
$jsonData->data = $typeSpecial->getReturnData($acl->getID(), $id, $fieldName, '');
$jsonData->namespace = 'default_db/' . V::get('tbl_name', '', $jsonData->data);
}
return $jsonData;
}
public function typespecialAction() { Response::sendTryCatchJson(array($this, 'typespecial'), $args = $_REQUEST); }
public function typespecial($args) { // @required idField, @optional: q (query), selected (selected value), idRecord (fetch value for given record)
$idField = V::get('idField', 0, $args, 'int');
if (!$idField) throw new HttpException("Bad Request - missing idField", 400);
$query = V::get('q', '', $_REQUEST);
DBG::log("\$query({$query})");
$cellInfo = DB::getPDO()->fetchFirst("
select *
from CRM_PROCES_idx_TABLES_INFO_VIEW
where ID_CELL = :id
", [ ':id' => $idField ]);
DBG::log($cellInfo, 'array', "cell info");
if (!$cellInfo) throw new HttpException("Bad Request - wrong idField", 400);
// 'ID_CELL' => '24310',
// 'CELL_NAME' => 'L_APPOITMENT_USER',
// 'CELL_LABEL' => 'Osoba odpowiedzialna',
// 'CELL_DESCRIPTION' => '',
// 'CELL_SORT_PRIO' => '3',
// 'ID_TABLE' => '13051',
// 'TABLE_NAME' => 'TEST_PERMS',
// 'TABLE_LABEL' => 'Test permy',
// 'TABLE_DESCRIPTION' => '',
// 'ID_DATABASE' => '36',
$namespace = (false !== strpos($cellInfo['TABLE_NAME'], '/')) ? $cellInfo['TABLE_NAME'] : "default_db/{$cellInfo['TABLE_NAME']}";
if (!$namespace) throw new HttpException("Bad Request - wrong idField, cannot find namespace", 400);
$acl = Core_AclHelper::getAclByNamespace($namespace);
$fieldName = $cellInfo['CELL_NAME'];
$jsonData = array();
$typeSpecial = Typespecial::getInstance($idField, $fieldName);
if ($typeSpecial) {
// if (idRecord or selected) { // TODO
// $jsonData->data = $typeSpecial->getReturnData($acl->getID(), $id, $fieldName, '');
// $jsonData->namespace = 'default_db/' . V::get('tbl_name', '', $jsonData->data);
$rawRows = null;
$rows = $typeSpecial->getValuesWithExports($query);
DBG::log($rows, 'array', "\$rows({$query})");
foreach ($rows as $kID => $vItem) {
$itemJson = new stdClass();
$itemJson->id = $vItem->id;
$itemJson->name = $vItem->param_out;
if (!empty($vItem->exports)) {
$itemJson->exports = $vItem->exports;
}
if (!empty($vItem->{'$order'})) {
$itemJson->{'$order'} = $vItem->{'$order'};
}
$jsonData[] = $itemJson;
}
}
return $jsonData;
}
/**
* @param $_GET['namespace'] = AclNamespace
* @param $_GET['format'] = 'csv' | 'html'
* @param $_GET['flds'] = csv - coma separated field names
* @param $_GET['sortCol'] = FieldName
* @param $_GET['sortDir'] = SortDir ('desc' | 'asc')
* @param $_GET['f_{$fieldName}'] = filter
* @param $_GET['sf_{$fieldName}'] = force filter
*/
public function exportAction() {
$args = $_GET;
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new HttpException("Bad Request - missing namespace", 400);
$acl = Core_AclHelper::getAclByNamespace($namespace);
$exportLimit = 10000;
$params = array();
$params['limit'] = $exportLimit;
// $params['limitstart'] = 0;
$params['order_by'] = V::get('sortCol', '', $args);
$params['order_dir'] = V::get('sortDir', '', $args);
$params['cols'] = array($acl->getPrimaryKeyField());
$toExportFields = explode(',', V::get('flds', '', $_GET));
if (empty($toExportFields)) throw new Exception("Nie wybrano żandych pól do exportu.");
$allowedExportFieldList = Core_AclHelper::getExportFieldList($acl);
foreach ($toExportFields as $fieldName) {
if ($fieldName == $acl->getPrimaryKeyField()) continue;
if (!in_array($fieldName, $allowedExportFieldList)) throw new Exception("Brak uprawnień do exportu pola '{$fieldName}'");
$params['cols'][] = $fieldName;
}
$labels = array();
foreach ($toExportFields as $fieldName) {
$labels[ $fieldName ] = $acl->getFieldLabel($fieldName);
}
foreach ($args as $k => $v) {
if (strlen($k) > 3 && substr($k, 0, 2) == 'f_' && strlen($v) > 0) {// filter prefix
$params[$k] = $v;
}
else if (strlen($k) > 4 && substr($k, 0, 3) == 'sf_' && strlen($v) > 0) {// special filter prefix
$params[$k] = $v;
}
}
try {
$queryFeatures = $acl->buildQuery($params);
$total = $queryFeatures->getTotal();
$listItems = $queryFeatures->getItems();
$primaryKeyField = $acl->getPrimaryKeyField();
$items = []; foreach ($listItems as $item) $items[ $item[$primaryKeyField] ] = $item;
} catch (Exception $e) {
DBG::log($e);
throw $e;
}
$format = V::get('format', 'html', $_GET);
switch ($format) {
case 'html': {
UI::gora();
echo UI::h('table', ['class'=>'table table-bordered table-hover'], [
UI::h('thead', [], [
UI::h('tr', [], array_map(function ($label) {
return UI::h('th', [], $label);
}, $labels))
]),
UI::h('tbody', [], array_map(function ($item) use($labels) {
return UI::h('tr', [], array_map(function ($fieldName) use ($item) {
return UI::h('td', [], V::get($fieldName, '', $item));
}, array_keys($labels)));
}, $items)),
]);
UI::dol();
exit;
}
case 'csv_cp1250':
case 'csv': {
$csvFileName = "Tabela-" . $acl->getName() . "-" . date("Y-m-d_H_s");
header('Content-Type: text/csv; charset=utf-8');
header("Content-Disposition: attachment; filename={$csvFileName}.csv");
$csvSeparator = ';';
$csvHeader = implode($csvSeparator, array_map(function ($label) use ($item) {
return '"' . addslashes($label) . '"';
}, array_values($labels)));
$csvRows = implode("\r\n", array_map(function ($item) use ($labels, $csvSeparator) {
return implode($csvSeparator, array_map(function ($fieldName) use ($item) {
return '"' . addslashes(V::get($fieldName, '', $item)) . '"';
}, array_keys($labels)));
}, $items));
switch ($format) {
case 'csv': echo $csvHeader . "\n" . $csvRows; exit;
case 'csv_cp1250': echo iconv('utf-8', 'Windows-1250//IGNORE', $csvHeader) . "\r\n" . iconv('utf-8', 'Windows-1250//IGNORE', $csvRows); exit;
die("Nieobsługiwane kodowanie danych csv.");
}
exit;
}
}
die("Nieobsługiwany format danych.");
}
public function loadDataAjaxAction() {
$namespace = V::get('namespace', '', $_REQUEST, 'word');
if (!$namespace) throw new HttpException("Bad Request - missing namespace", 400);
$acl = Core_AclHelper::getAclByNamespace($namespace);
$backRefFilter = [
'namespace' => V::get('backRefNS', '', $_REQUEST),
'primaryKey' => V::get('backRefPK', '', $_REQUEST),
'fieldName' => V::get('backRefField', '', $_REQUEST),
];
$childRefFilter = [
'namespace' => V::get('childRefNS', '', $_GET),
'primaryKey' => V::get('childRefPK', '', $_GET),
];
$tbl = $this->getTableAjaxWidget($acl, $backRefFilter, $childRefFilter);
Response::sendTryCatchJson(array($tbl, 'ajaxData'), $args = $_GET);
}
public function uploadFilesAjaxAction() {
Response::sendTryCatchJson([$this, 'uploadFilesAjax'], $args = $_POST);
}
public function uploadFilesAjax($args) {
DBG::log($_FILES, 'array', "\$_FILES");
DBG::log($args, 'array', "\$args");
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new Exception("Missing namespace");
$primaryKey = V::get('primaryKey', '', $args, 'int');
if ($primaryKey <= 0) throw new Exception("Missing primaryKey");
if (empty($_FILES)) throw new Exception("Missing files");
$acl = Core_AclHelper::getAclByNamespace($namespace, $forceTblAclInit = ('1' == V::get('_force', '', $_GET)));
Lib::loadClass('FileUploader');
Lib::loadClass('FoldersConfig');
// $dbID = $acl->getDB();
// $db = DB::getDB($dbID);
// if (!$db) throw new HttpException("No DB ({$dbID})", 406);
$record = $acl->buildQuery([])->getItem($primaryKey);
DBG::log($record, 'array', "\$record");
if (!$record) throw new HttpException("No item ID({$primaryKey})", 404);
if (!$acl->canReadRecord($record)) throw new Exception("Brak uprawnień do odczytu");
if (!$acl->canWriteRecord($record)) throw new Exception("Brak uprawnień do zapisu");
$rootTableName = $acl->getRootTableName();
$confTblName = "{$rootTableName}_COLUMN";
$folderConfAll = FoldersConfig::getRawData();
if (!FoldersConfig::hasConfig($confTblName)) throw new HttpException("Brak danych konfiguracyjnych ({$rootTableName})", 404);
$folderConf = FoldersConfig::getAll($confTblName);
DBG::log($folderConf, 'array', "\$folderConf");
$uploader = new FileUploader($confTblName, (object)$record);
if (!$uploader->setConfig($folderConf)) throw new HttpException("Błąd danych konfiguracyjnych ({$rootTableName})", 404);
$uploader->findFolder();
DBG::log($uploader, 'array', "\$uploader");
// $errorMsg = '';
// if (!empty($args['SCANS_COLUMN_ADD'])) {
// $uploaded = $uploader->tryMoveFromScanAjax($errorMsg);
// }
// else {
// $uploaded = $uploader->tryUploadAjax($errorMsg);
// }
$destPath = $uploader->getDestLocalPath($show_if_not_found = true);
DBG::log($destPath, 'array', "\$destPath");
if (!file_exists($destPath)) {
if (!$uploader->tryCreateDestFolder($destPath)) throw new Exception("Wystąpił błąd podczas tworzenie katalogu dla rekordu '{$primaryKey}'");
}
$generateSafeFileName = function($destPath, $fileName) {
if (!file_exists("{$destPath}/{$fileName}")) return $fileName;
$infoPath = pathinfo($fileName);
// pathinfo('/path/t1/t2/fileName.ext') = [
// [dirname] => /path/t1/t2
// [basename] => fileName.ext
// [extension] => ext
// [filename] => fileName
// ]
return $infoPath['filename'] . "--" . date("Y-m-d_H-i-s") . "." . $infoPath['extension'];
};
$moveActions = array_map(function ($file) use ($destPath, $generateSafeFileName) {
$safeName = $generateSafeFileName($destPath, $file['name']);
return [
$file['tmp_name'],
"{$destPath}/{$safeName}",
$safeName,
];
}, $_FILES);
DBG::log($moveActions, 'array', "\$moveActions"); // [ [ srcPath, descPath ] ]
$errorMsgs = [];
$pkField = $acl->getSqlPrimaryKeyField();
foreach ($moveActions as $fileMoveAction) {
if (!move_uploaded_file($fileMoveAction[0], $fileMoveAction[1])) {
$errorMsgs[] = "Nie udało się wgrać pliku '{$fileMoveAction[2]}'";
} else {
try {
$affected = DB::getPDO($acl->getDB())->update($rootTableName, $pkField, $primaryKey, [
'M_DIST_FILES' => "Wrano plik '{$fileMoveAction[2]}'",
'A_RECORD_UPDATE_AUTHOR' => User::getLogin(),
'A_RECORD_UPDATE_DATE' => 'NOW()',
]);
if ($affected) {
DB::getPDO($acl->getDB())->insert("{$rootTableName}_HIST", [
'ID_USERS2' => $primaryKey,
'M_DIST_FILES' => "Wrano plik '{$fileMoveAction[2]}'",
'A_RECORD_UPDATE_AUTHOR' => User::getLogin(),
'A_RECORD_UPDATE_DATE' => 'NOW()',
]);
}
} catch (Exception $e) {
DBG::log($e);
$errorMsgs[] = $e->getMessage();
}
}
}
if (!empty($errorMsgs)) {
return [
'type' => "error",
'msg' => "Wystąpiły błędy podczas wgrywania plików dla '{$primaryKey}'",
'errors' => $errorMsgs,
];
}
return [
'type' => "success",
'msg' => "Wgrano nowe pliki dla '{$primaryKey}'",
];
}
public function removeFileAjaxAction() {
Response::sendTryCatchJson([$this, 'removeFileAjax'], $args = $_REQUEST);
}
public function removeFileAjax($args) { // ajaxFileRemove
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new Exception("Missing namespace");
$id = V::get('ID', 0, $args, 'int');
if ($id <= 0) throw new Exception("Missing ID");
$filename = V::get('filename', '', $args);
if (empty($filename)) throw new Exception("Nie wybrano pliku do usunięcia");
$acl = Core_AclHelper::getAclByNamespace($namespace, $forceTblAclInit = ('1' == V::get('_force', '', $_GET)));
$dbID = $acl->getDB();
$db = DB::getPDO($dbID);
if (!$db) throw new HttpException("No DB ({$dbID})", 406);
$record = $acl->buildQuery([])->getItem($id);
if (!$record) throw new HttpException("No item ID({$id})", 404);
if (!$acl->canReadRecord($record)) throw new Exception("Brak uprawnień do odczytu");
if (!$acl->canWriteRecord($record)) throw new Exception("Brak uprawnień do zapisu");
Lib::loadClass('FileUploader');
Lib::loadClass('FoldersConfig');
$tblName = $acl->getName();
$confTblName = "{$tblName}_COLUMN";
$folderConfAll = FoldersConfig::getRawData();
if (!FoldersConfig::hasConfig($confTblName)) throw new HttpException("Brak danych konfiguracyjnych ({$tblName})", 404);
$folderConf = FoldersConfig::getAll($confTblName);
$uploader = new FileUploader($confTblName, (object)$record);
if (!$uploader->setConfig($folderConf)) throw new HttpException("Błąd danych konfiguracyjnych ({$tblName})", 404);
$uploader->findFolder();
$errorMsg = '';
$removed = $uploader->tryRemoveFromAjax($filename, $errorMsg);
if (!$removed) throw new Exception($errorMsg);
// $affected = DB::getPDO($acl->getDB())->update();
$rootTableName = $acl->getRootTableName();
$pkField = $acl->getSqlPrimaryKeyField();
$primaryKey = $id;
try {
$affected = DB::getPDO($acl->getDB())->update($rootTableName, $pkField, $primaryKey, [
'M_DIST_FILES' => "Usunięto plik '{$filename}'",
'A_RECORD_UPDATE_AUTHOR' => User::getLogin(),
'A_RECORD_UPDATE_DATE' => 'NOW()',
]);
if ($affected) {
DB::getPDO($acl->getDB())->insert("{$rootTableName}_HIST", [
'ID_USERS2' => $primaryKey,
'M_DIST_FILES' => "Usunięto plik '{$filename}'",
'A_RECORD_UPDATE_AUTHOR' => User::getLogin(),
'A_RECORD_UPDATE_DATE' => 'NOW()',
]);
}
} catch (Exception $e) {
DBG::log($e);
}
return [
'type' => 'success',
'msg' => 'Plik został usunięty',
];
}
public function procesInitFiltrAjaxAction() {
Response::sendTryCatchJson([$this, 'procesInitFiltrAjax'], $args = $_GET);
}
public function procesInitFiltrAjax($args) { // ajaxFileRemove
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new Exception("Missing namespace");
$acl = Core_AclHelper::getAclByNamespace($namespace, $forceTblAclInit = ('1' == V::get('_force', '', $_GET)));
$pInitList = User::getAcl()->getTableProcesInitList($acl->getID());
DBG::log($pInitList, 'array', "\$pInitList");
if (!empty($pInitList)) {
$procesIds = array_keys($pInitList);
$mapTree = ACL::getProcesInitMapTreeOnlyIds($procesIds);
DBG::log($mapTree, 'array', "\$mapTree");
DBG::log($pInitList, 'array', "\$pInitList");
$pInitListSelected = User::getAcl()->getPermsFiltrProcesId();
return [
'type' => 'success',
'msg' => 'ok',
'pInitData' => [
'pInitList' => $pInitList,
'mapTree' => $mapTree,
'pInitListSelected' => $pInitListSelected,
],
];
}
return [
'type' => 'success'
];
}
public function tableToolsAjaxAction() {
Response::sendTryCatchJson([$this, 'tableToolsAjax'], $args = $_GET);
}
public function tableToolsAjax($args) { // ajaxFileRemove
$namespace = V::get('namespace', '', $args, 'word');
if (!$namespace) throw new Exception("Missing namespace");
$acl = Core_AclHelper::getAclByNamespace($namespace, $forceTblAclInit = ('1' == V::get('_force', '', $_GET)));
$listUrlFunctions = Route_UrlAction::getTableFunctions($acl->getID(), $idRecord = 0, $acl->getName(), User::getLogin());
DBG::log($listUrlFunctions, 'array', "\$listUrlFunctions");
$listUrlFunctions = array_map(function ($urlFunction) use ($namespace) {
if ('index.php?' === substr($urlFunction['baseLink'], 0, strlen('index.php?'))) $urlFunction['baseLink'] .= "&_fromNamespace={$namespace}";
return $urlFunction;
}, $listUrlFunctions);
return [
'type' => "success",
'msg' => 'ok',
'body' => [
'tableTools' => array_values(array_map(function ($urlFunction) {
return [
'url' => $urlFunction['baseLink'],
'label' => $urlFunction['label'],
// TODO: $urlFunction['link_target'] // "_blank"
// ? $urlFunction['name']
];
}, array_filter($listUrlFunctions, function ($urlFunction) {
return empty($urlFunction['cell_id_params']);
}))),
],
];
}
}