| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668 |
- <?php
- // @requires $_SERVER['SERVER_NAME']
- Lib::loadClass('RouteBase');
- Lib::loadClass('Router');
- Lib::loadClass('Schema_TableFactory');
- Lib::loadClass('Response');
- Lib::loadClass('UI');
- Lib::loadClass('OBJ');
- Lib::loadClass('SchemaFactory');
- /*
- # Storage:
- - [x] view available storage (from Zasoby - type 'BAZA_DANYCH', 'DATABASE_MYSQL', ...)
- - [x] check config for connection
- - [x] add cells to Zasoby
- - [ ] create cells in Storage
- - [x] use PDO
- */
- class Route_Storage extends RouteBase {
- public function handleAuth() {
- if (!User::logged()) {
- User::authByRequest();
- }
- }
- public function defaultAction() {
- UI::gora();
- UI::menu();
- $this->navView();
- UI::startContainer();
- try {
- $sourceStorage = SchemaFactory::loadDefaultObject('SystemSource');
- try {
- $sourceStorage->getTotal();
- } catch (Exception $e) {
- UI::alert('warning', $e->getMessage());
- $sourceStorage->updateCache();
- UI::alert('info', "Lista dostępnych baz danych zaktualizowana");
- }
- if ('1' == V::get('refreshSourceList', '', $_POST)) {
- $sourceStorage->updateCache();
- UI::alert('info', "Lista dostępnych baz danych zaktualizowana");
- }
- UI::table([
- 'caption' => "Bazy danych " .
- UI::hButtonPost('<i class="glyphicon glyphicon-refresh"></i>' . " odśwież", [
- 'class' => "btn btn-xs btn-link",
- 'data' => [
- 'refreshSourceList' => '1'
- ]
- ]),
- 'rows' => array_merge(
- array_map(function ($item) {
- return [
- 'Nr zasobu' => $item['idZasob'],
- 'nazwa' => $item['name'],
- 'opis' => $item['description'],
- 'config?' => ($item['hasConfig']) ? '<span class="label label-success">TAK</span>' : '<span class="text text-muted">brak</span>',
- 'obiekty' => UI::h('a', [ 'href' => $this->getLink('tableList', [ 'idStorage' => $item['idZasob'] ]) ], "obiekty"),
- 'raw info' => UI::h('a', [ 'href' => $this->getLink('rawInfo', [ 'idStorage' => $item['idZasob'] ]) ], "raw info"),
- 'xsd' => UI::h('a', [ 'href' => $this->getLink('xsd', [ 'idStorage' => $item['idZasob'] ]) ], "xsd"),
- ];
- }, $sourceStorage->getItems())
- , [
- [
- 'Nr zasobu' => '',
- 'nazwa' => "Obiekty",
- 'opis' => "SystemObjects",
- 'config?' => '<span class="text text-muted">brak</span>',
- 'obiekty' => UI::h('a', [ 'href' => $this->getLink('systemObjects') ], "obiekty"),
- ],
- [
- 'Nr zasobu' => '',
- 'nazwa' => "Obiekty Test",
- 'opis' => "Obiekty podstawowe (test json)",
- 'config?' => '<span class="text text-muted">brak</span>',
- 'obiekty' => UI::h('a', [ 'href' => $this->getLink('coreObjectList') ], "obiekty"),
- 'raw info' => UI::h('a', [ 'href' => $this->getLink('coreObjectParseAll') ], "raw info"),
- ],
- [
- 'Nr zasobu' => '',
- 'nazwa' => "Obiekty Test",
- 'opis' => "Obiekty dla domeny '" . str_replace(array(".", "-"), '_', $_SERVER['SERVER_NAME']) . "' (test json)",
- 'config?' => '<span class="text text-muted">brak</span>',
- 'obiekty' => UI::h('a', [ 'href' => $this->getLink('objectList') ], "obiekty"),
- // 'raw info' => UI::h('a', [ 'href' => $this->getLink('objectRawInfo') ], "raw info"),
- ],
- ]
- )
- ]);
- // $sourceStorage = SchemaFactory::loadDefaultObject('SystemObject');
- // $sourceStorage->updateCache();
- } catch (Exception $e) {
- UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
- }
- UI::endContainer();
- UI::dol();
- }
- public function checkObjectInstallAjaxAction() {
- $response = array();
- try {
- $objectName = V::get('object', '', $_REQUEST, 'word');
- if (empty($objectName)) throw new Exception("Missing Object name");
- $response['object'] = $objectName;
- $json = OBJ::getCoreObjectFromFile($objectName);
- OBJ::checkInstall($json);
- $response['type'] = 'success';
- $response['msg'] = "OK - object installed";
- } catch (Exception $e) {
- $response['type'] = 'error';
- $response['msg'] = $e->getMessage();
- $response['code'] = $e->getCode();
- $response['line'] = $e->getLine();
- }
- Response::sendJsonExit($response);
- }
- public function coreObjectStructAction() {
- UI::gora();
- UI::menu();
- $this->navView();
- try {
- $objectName = V::get('object', '', $_REQUEST, 'word');
- if (empty($objectName)) throw new Exception("Missing Object name");
- $json = OBJ::getCoreObjectFromFile($objectName);
- $label = OBJ::getLabel($json);
- $parentList = OBJ::getParentList($json);
- $linksParentList = array(); foreach ($parentList as $parentName) {
- $parentLink = '<a href="index.php?_route=Storage&_task=coreObjectStruct&object=' . str_replace('/', '-', $parentName) . '">' . $parentName . '</a>';
- array_unshift($linksParentList, $parentLink);
- }
- $ajaxCheckInstall = Request::getPathUri() . "index.php?_route=Storage&_task=checkObjectInstallAjax&object={$objectName}";
- $onClick = "return p5UI__ButtonAjax(this, 'p5UIBtnAjax:Storage:checkObjectInstallAjax', { href: '{$ajaxCheckInstall}' })";
- $btnCheckInstall = '<a onclick="'.$onClick.'" href="#" title="check install db tables"><i class="glyphicon glyphicon-cog"></i></a>';
- UI::startContainer();
- UI::tag('h1', [], "Obiekt <code>{$label}</code> <small>{$btnCheckInstall}</small>");
- if (!empty($parentList)) {
- UI::startTag('ol', ['class'=>"breadcrumb"]);
- UI::tag('li', [], "Dziedziczy z:");
- foreach ($linksParentList as $parentLink) {
- UI::tag('li', [], $parentLink);
- }
- // <!-- <li class="active">Data</li> -->
- UI::endTag('ol');
- // <!-- <p> implode(", ", $parentList);</p> -->
- }
- // TODO: UI::table(['rows'=>array_map()]);
- ?>
- <table class="table table-bordered table-hovered">
- <caption>Struktura:</caption>
- <thead>
- <tr>
- <th>nazwa</th>
- <th>typ</th>
- <th>label</th>
- <th>json</th>
- </tr>
- </thead>
- <tbody>
- <?php foreach (OBJ::getFields($json) as $fieldName => $field) : ?>
- <tr>
- <td><?php echo $fieldName; ?></td>
- <td><?php echo $field['type']; ?></td>
- <td><?php echo $field['label']; ?></td>
- <td><?php echo json_encode($field); ?></td>
- </tr>
- <?php endforeach; ?>
- </tbody>
- </table>
- <a href="index.php?_route=Storage&_task=coreObjectConnect&object=<?php echo $objectName; ?>" class="btn btn-primary">Przypisz rekordy do klasy</a>
- <?php
- $mainTable = OBJ::getMainTableName($json);
- $sqlFields = OBJ::getTableFields($json);
- $this->showTableWidget($mainTable, $sqlFields);
- ?>
- </div>
- <script>
- jQuery(document).on('p5UIBtnAjax:Storage:checkObjectInstallAjax:click', function(e, n, payload) {
- console.log('event p5UIBtnAjax:Storage:checkObjectInstallAjax:click', n, payload);
- });
- jQuery(document).on('p5UIBtnAjax:Storage:checkObjectInstallAjax:ajaxLoaded', function(e, n, payload) {
- console.log('event p5UIBtnAjax:Storage:checkObjectInstallAjax:ajaxLoaded', n, payload);
- if ('success' == payload.type) {
- // jQuery(n).parents('td').text(payload.body.id);
- }
- jQuery.notify(payload.msg, payload.type);
- });
- </script>
- <?php
- DBG::_(true, true, "json", $json, __CLASS__, __FUNCTION__, __LINE__);
- } catch (Exception $e) {
- UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
- }
- UI::dol();
- }
- public function coreObjectConnectAction() {
- UI::gora();
- UI::menu();
- $this->navView();
- try {
- $objectName = V::get('object', '', $_REQUEST, 'word');
- if (empty($objectName)) throw new Exception("Missing Object name");
- $json = OBJ::getCoreObjectFromFile($objectName);
- $label = OBJ::getLabel($json);
- $parentList = OBJ::getParentList($json);
- $linksParentList = array(); foreach ($parentList as $parentName) {
- $parentLink = '<a href="index.php?_route=Storage&_task=coreObjectStruct&object=' . str_replace('/', '-', $parentName) . '">' . $parentName . '</a>';
- array_unshift($linksParentList, $parentLink);
- }
- $ajaxCheckInstall = Request::getPathUri() . "index.php?_route=Storage&_task=checkObjectInstallAjax&object={$objectName}";
- $onClick = "return p5UI__ButtonAjax(this, 'p5UIBtnAjax:Storage:checkObjectInstallAjax', { href: '{$ajaxCheckInstall}' })";
- $btnCheckInstall = '<a onclick="'.$onClick.'" href="#" title="check install db tables"><i class="glyphicon glyphicon-cog"></i></a>';
- ?>
- <div class="container">
- <h1>Obiekt <code><?php echo $label; ?></code> <small><?php echo $btnCheckInstall; ?></small></h1>
- <?php if (!empty($parentList)) : ?>
- <ol class="breadcrumb">
- <li>Dziedziczy z:</li>
- <?php foreach ($linksParentList as $parentLink) : ?>
- <li><?php echo $parentLink; ?></li>
- <?php endforeach; ?>
- <!-- <li class="active">Data</li> -->
- </ol>
- <!-- <p> <?php echo implode(", ", $parentList); ?></p> -->
- <?php endif; ?>
- <?php
- $tableOne = array();
- $tableOne['caption'] = 'Klasy';
- $tableOne['rows'] = array();
- $parentList = OBJ::getParentList($json);
- $tableOne['rows'][] = array('__primary_key' => $objectName, 'name' => $objectName);
- $linksParentList = array(); foreach ($parentList as $parentName) {
- // $parentLink = '<a href="index.php?_route=Storage&_task=coreObjectStruct&object=' . str_replace('/', '-', $parentName) . '">' . $parentName . '</a>';
- // array_unshift($linksParentList, $parentLink);
- $tableOne['rows'][] = array('__primary_key' => $parentName, 'name' => $parentName);
- }
- $tableTwo = array();
- $tableTwo['caption'] = 'Rekordy w tabeli głównej';
- $mainTable = OBJ::getMainTableName($json);
- $sqlFields = OBJ::getTableFields($json);
- $tableTwo['rows'] = $this->getTableRows($mainTable, $sqlFields);
- foreach ($tableTwo['rows'] as $idx => $row) {
- // $tableTwo['rows'][] = array('__primary_key' => $objectName, 'name' => $objectName);
- $tableTwo['rows'][$idx]['__primary_key'] = $row['ID'];
- }
- echo '<hr>';
- // TODO: filter connected rows
- // TODO: filter not connected rows
- // TODO: action connect rows - args(schema, rows_primary_key_list)
- // TODO: action un connect rows - args(schema, rows_primary_key_list)
- $this->showConnectSchemaToTableWidget(compact('tableOne', 'tableTwo'));
- ?>
- </div>
- <script>
- jQuery(document).on('p5UIBtnAjax:Storage:checkObjectInstallAjax:click', function(e, n, payload) {
- console.log('event p5UIBtnAjax:Storage:checkObjectInstallAjax:click', n, payload);
- });
- jQuery(document).on('p5UIBtnAjax:Storage:checkObjectInstallAjax:ajaxLoaded', function(e, n, payload) {
- console.log('event p5UIBtnAjax:Storage:checkObjectInstallAjax:ajaxLoaded', n, payload);
- if ('success' == payload.type) {
- // jQuery(n).parents('td').text(payload.body.id);
- }
- jQuery.notify(payload.msg, payload.type);
- });
- </script>
- <?php
- DBG::_(true, true, "json", $json, __CLASS__, __FUNCTION__, __LINE__);
- } catch (Exception $e) {
- UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
- }
- UI::dol();
- }
- public function showConnectSchemaToTableWidget($params) {
- if (empty($params['tableOne'])) throw new Exception("Missing tableOne in Connect widget");
- if (empty($params['tableTwo'])) throw new Exception("Missing tableTwo in Connect widget");
- $tableOne = $params['tableOne'];
- $tableTwo = $params['tableTwo'];
- // TODO: add p5BtnAjax to table filters button
- // TODO: add p5BtnAjax to conn button
- $jsEventNamespace = 'ConnectTableWidget' . time();
- $htmlIdWrap = "{$jsEventNamespace}-wrap";
- $stateLogId = "{$jsEventNamespace}-state-log";
- $stateSelectedTotalId = "{$jsEventNamespace}-state-selected";
- $stateClearSelectedBtnId = "{$jsEventNamespace}-state-clear-selected-btn";
- foreach ($tableOne['rows'] as $idx => $r) {
- $tableOne['rows'][$idx]['@onClick'] = "return p5UI__Clickable(this, '{$jsEventNamespace}:tableOne', { primary_key: '{$r['__primary_key']}' });";
- }
- foreach ($tableTwo['rows'] as $idx => $r) {
- $tableTwo['rows'][$idx]['@onClick'] = "return p5UI__Clickable(this, '{$jsEventNamespace}:tableTwo', { primary_key: '{$r['__primary_key']}' });";
- }
- $tableOne['hidden_cols'] = $tableTwo['hidden_cols'] = array('__primary_key', '@onClick', '__html_id');
- $tableTwo['__html_id'] = "{$jsEventNamespace}-table-two";
- ?>
- <div id="<?php echo $htmlIdWrap; ?>">
- <?php UI::table($tableOne); ?>
- <div class="btn-group">
- <button class="btn btn-default" title="Wybierz rekordy wg instancji"><i class="glyphicon glyphicon-question-sign"></i></button>
- <button class="btn btn-default conn-btn-filter-yes">Przypisani</button>
- <button class="btn btn-default conn-btn-filter-no active">Nieprzypisani</button>
- <button class="btn btn-default conn-btn-filter-clear" title="Wszystkie"><i class="glyphicon glyphicon-remove"></i></button>
- </div>
- <div class="btn-group">
- <span style="padding-left:30px;">Zaznaczono
- <span class="conn-selected-total">0</span>
- <button class="conn-btn-clear-selected btn btn-link"
- onClick="return p5UI__Clickable(this, '<?php echo $jsEventNamespace; ?>:clearSelection', {});"
- style="display:none"><i class="glyphicon glyphicon-remove" style="color:red"></i></button>
- </span>
- </div>
- <?php UI::jsAjaxTable($tableTwo); ?>
- <pre class="conn-log"></pre>
- </div>
- <script>
- (function(){
- var state = {
- selectedTableOne: null,
- selectedTableTwo: [],
- filterSelected: 'no'
- }
- var props = {
- jsEventNamespace: '<?php echo $jsEventNamespace; ?>',
- htmlIdWrap: '<?php echo $htmlIdWrap; ?>',
- tableTwoId: '#<?php echo $tableTwo['__html_id']; ?>',
- stateSelectedTotalId: '#<?php echo $stateSelectedTotalId; ?>',
- stateClearSelectedBtnId: '#<?php echo $stateClearSelectedBtnId; ?>',
- stateLogId: '#<?php echo $stateLogId; ?>'
- }
- var wrap = jQuery('#' + props.htmlIdWrap);
- var jqNodes = {
- wrap: wrap,
- filter_yes: wrap.find('.conn-btn-filter-yes'),
- filter_no: wrap.find('.conn-btn-filter-no'),
- filter_clear: wrap.find('.conn-btn-filter-clear'),
- total_selected: wrap.find('.conn-selected-total'),
- btn_clear_selected: wrap.find('.conn-btn-clear-selected'),
- state_log: wrap.find('.conn-log')
- }
- function render() {
- jqNodes['total_selected'].text(state.selectedTableTwo.length);
- if (state.selectedTableTwo.length > 0) {
- jQuery(props.stateClearSelectedBtnId).show();
- } else {
- jQuery(props.stateClearSelectedBtnId).hide();
- }
- jqNodes['state_log'].text(JSON.stringify(state));
- switch (state.filterSelected) {
- case 'yes':
- jqNodes['filter_yes'].addClass('active');
- jqNodes['filter_no'].removeClass('active');
- jqNodes['filter_clear'].removeClass('active');
- break;
- case 'no':
- jqNodes['filter_yes'].removeClass('active');
- jqNodes['filter_no'].addClass('active');
- jqNodes['filter_clear'].removeClass('active');
- break;
- case 'clear':
- jqNodes['filter_yes'].removeClass('active');
- jqNodes['filter_no'].removeClass('active');
- jqNodes['filter_clear'].addClass('active');
- break;
- }
- }
- function action__selectTableOneRow(pk) {
- state.selectedTableOne = pk;
- render();
- }
- function action__unselectTableOneRow() {
- state.selectedTableOne = null;
- render();
- }
- function action__selectTableTwoRow(pk) {
- var idx = state.selectedTableTwo.indexOf(pk);
- if (-1 === idx) state.selectedTableTwo.push(pk);
- else console.log("Error selectedTableTwo - should be not set");
- render();
- }
- function action__unselectTableTwoRow(pk) {
- var idx = state.selectedTableTwo.indexOf(pk);
- if (-1 === idx) state.selectedTableTwo.push(pk);
- else state.selectedTableTwo.splice(idx, 1);
- render();
- }
- function action__clearSelection() {
- state.selectedTableTwo = [];
- jQuery(props.tableTwoId).find('tbody').children('.info').removeClass('info');
- render();
- }
- function action__filterSet(fltr) {
- state.filterSelected = fltr;
- render();
- // TODO: ajax load tableTwo based on filter
- }
- jQuery(document).on(props.jsEventNamespace + ':tableOne:click', function(e, n, payload) {
- var n$ = jQuery(n);
- console.log('event '+props.jsEventNamespace+':tableOne:click', n, payload);
- jQuery.notify('tableOne row clicked [' + payload.props.primary_key + ']', 'info');
- if (n$.hasClass('info')) {
- n$.removeClass('info');
- action__unselectTableOneRow();
- } else {
- n$.parent().children('.info').removeClass('info');
- n$.addClass('info');
- action__selectTableOneRow(payload.props.primary_key);
- }
- });
- jQuery(document).on(props.jsEventNamespace + ':tableTwo:click', function(e, n, payload) {
- var n$ = jQuery(n);
- console.log('event '+props.jsEventNamespace+':tableTwo:click', n, payload);
- jQuery.notify('tableTwo row clicked [' + payload.props.primary_key + ']', 'info');
- if (n$.hasClass('info')) {
- n$.removeClass('info');
- action__unselectTableTwoRow(payload.props.primary_key);
- } else {
- n$.addClass('info');
- action__selectTableTwoRow(payload.props.primary_key);
- }
- });
- jQuery(document).on(props.jsEventNamespace + ':clearSelection:click', function(e, n, payload) {
- action__clearSelection();
- });
- jqNodes['filter_yes'].on('click', function(e) {
- action__filterSet('yes');
- });
- jqNodes['filter_no'].on('click', function(e) {
- action__filterSet('no');
- });
- jqNodes['filter_clear'].on('click', function(e) {
- action__filterSet('clear');
- });
- })();
- </script>
- <?php
- }
- public function getTableRows($tblName, $fields) {
- $sqlFields = array();
- foreach ($fields as $fldName) {
- $sqlFields[] = "t.`{$fldName}`";
- }
- $sqlFields = (!empty($sqlFields))? implode(", ", $sqlFields) : "t.*";
- $rows = DB::getPDO()->fetchAll("
- select {$sqlFields}
- from `{$tblName}` t
- where 1=1
- limit 10
- ");
- return $rows;
- }
- public function showTableWidget($tblName, $fields) {
- $rows = $this->getTableRows($tblName, $fields);
- UI::table(array('caption' => "table({$tblName})", 'rows' => $rows));
- }
- public function coreObjectParseAllAction() {
- UI::gora();
- UI::menu();
- $this->navView();
- try {
- OBJ::parseAll();
- } catch (Exception $e) {
- UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
- }
- UI::dol();
- }
- public function coreObjectListAction() {
- UI::gora();
- UI::menu();
- $this->navView();
- try {
- $coreObjlist = OBJ::getCoreObjectList();
- $objectList = array();
- foreach ($coreObjlist as $objName) {
- $objItem = array();
- $objItem['name'] = $objName;
- $objItem['struktura'] = '<a href="index.php?_route=Storage&_task=coreObjectStruct&object=' . $objName . '">' . "struct" . '</a>';
- // $objItem['label'] = "";// TODO: read from json
- $objectList[] = $objItem;
- }
- usort($objectList, function($rowA, $rowB) {
- $a = $rowA['nazwa']; $b = $rowB['nazwa'];
- if ($a == $b) return 0;
- return ($a < $b) ? -1 : 1;
- });
- DBG::table("objectList", $objectList, __CLASS__, __FUNCTION__, __LINE__);
- } catch (Exception $e) {
- UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
- }
- UI::dol();
- }
- public function objectListAction() {
- UI::gora();
- UI::menu();
- try {
- } catch (Exception $e) {
- UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
- }
- UI::dol();
- }
- public function tableListAction() {
- UI::gora();
- UI::menu();
- $this->navView();
- UI::startContainer();
- try {
- $idStorage = V::get('idStorage', 0, $_REQUEST, 'int');
- if (empty($idStorage)) throw new Exception("Missing id storage");
- $sourceStorage = SchemaFactory::loadDefaultObject('SystemSource');
- $sourceItem = $sourceStorage->getItem($idStorage);
- if (!$sourceItem) throw new Exception("Storage id='{$idStorage}' not exists");
- DBG::log($sourceItem, 'array', '$sourceItem');
- // TODO: fetch SystemObject childrens from $sourceItem:
- // 1. 'SystemSource' -> getItems([ 'cols' => 'SystemObject/*', 'featureId' => $sourceItem['idZasob'] ])
- // 2. 'SystemObject' -> getItems([ 'refFrom' => $sourceItem['idZasob'] ])
- // 'default_objects' => _task=systemObjects
- $objectStorage = SchemaFactory::loadDefaultObject('SystemObject');
- try {
- $objectStorage->getTotal();
- } catch (Exception $e) {
- UI::alert('warning', $e->getMessage());
- DBG::log($e);
- $objectStorage->updateCache();
- UI::alert('info', "Lista obiketów zaktualizowana");
- }
- if ('1' == V::get('refreshObjectList', '', $_POST)) {
- $objectStorage->updateCache();
- UI::alert('info', "Lista obiketów zaktualizowana");
- }
- {
- echo UI::h('style', ['type' => "text/css"], "
- .p5UI__dropdown-content { min-width:300px; padding:8px; background-color: #f6f6f6; box-shadow: 0px 8px 16px 0px rgba(0,0,0,0.2) }
- .p5UI__dropdown-content a { display:block; color:#000; padding:8px; text-decoration:none }
- .p5UI__dropdown-content a:hover { background-color:#ebebeb }
- ");
- echo UI::h('script', [], "
- function p5_Storage_actions_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('a')
- for (i = 0; i < a.length; i++) {
- if (a[i].innerHTML.toUpperCase().indexOf(filter) > -1) {
- a[i].style.display = ''
- } else {
- a[i].style.display = 'none'
- }
- }
- }
- ");
- }
- $thisGetLink = array($this, 'getLink');
- UI::table([
- 'caption' => "Obiekty w bazie '{$sourceItem['name']}' " .
- UI::hButtonPost('<i class="glyphicon glyphicon-refresh"></i>' . " odśwież", [
- 'class' => "btn btn-xs btn-link",
- 'data' => [
- 'refreshObjectList' => '1'
- ]
- ]),
- 'rows' => array_map(function ($item) use ($idStorage, $thisGetLink) {
- $typeName = $item['typeName']; // $typeName = Api_WfsNs::typeName($item['namespace']);
- return [
- 'namespace' => '<span style="color:#888">' . substr($item['namespace'], 0, strlen($item['namespace']) - strlen($item['name'])) . '</span>' .
- '<span>' . $item['name'] . '</span>',
- '_type' => $item['_type'], // TODO: editable?
- 'Nr zasobu' => ($item['idZasob'] > 0)
- ? $item['idZasob']
- : UI::hButtonAjax("Dodaj do zasobów", 'addAclObjectToZasobyAjax', [
- 'class' => "btn btn-xs btn-primary",
- 'href' => $this->getLink('addAclObjectToZasobyAjax'),
- 'data' => [
- 'idStorage' => $idStorage,
- 'namespace' => $item['namespace'],
- ]
- ]),
- // 'opis' => $item['description'],
- 'hasStruct' => ($item['hasStruct']) ? '<span class="label label-success">TAK</span>' : '<span class="text text-muted">nie</span>',
- 'installed' => $item['isStructInstalled'] ? '<span class="label label-success">TAK</span>' : '<span class="text text-muted">nie</span>',
- 'active?' => $item['isObjectActive'] ? '<span class="label label-success">TAK</span>' : '<span class="text text-muted">nie</span>',
- 'menu' => UI::h('div', ['class'=>"p5UI__dropdown-wrap"], [
- UI::h('button', ['onClick' => "p5UI__dropdown(event, this, 'left bottom')", 'class' => "btn btn-xs btn-default p5UI__dropdown-btn"], [
- '<i class="glyphicon glyphicon-menu-hamburger"></i>',
- " menu"
- ]),
- UI::h('div', ['class' => "p5UI__dropdown-content"], [
- UI::h('input', ['type' => "text", 'placeholder' => "Search..", 'class' => "p5UI__dropdown-input", 'onkeyup' => "p5_Storage_actions_filterInput(this)"], null),
- UI::h('a', [ 'href' => Router::getRoute('Storage_AclStruct')->getLink('', [ 'namespace' => $item['namespace'] ]) ], "struktura"),
- UI::h('a', [ 'href' => $item['reinstallLink'] ], "reinstall"),
- UI::h('a', [ 'href' => $this->getLink('rawInfo', [ 'idStorage' => $idStorage, 'table' => $item['name'] ]) ], "raw info"),
- UI::h('a', [ 'href' => Router::getRoute('ViewTableAjax')->getLink('', ['namespace' => $item['namespace']]) ], "view table"),
- UI::h('a', [ 'href' => Router::getRoute('ViewObject')->getLink('', ['namespace' => $item['namespace']]) ], "view object"),
- // 'xsd' => UI::h('a', [ 'href' => $this->getLink('xsd', [ 'idStorage' => $idStorage ]) ], "xsd"),
- UI::h('a', [ 'href' => "wfs-data.php/default_db/?SERVICE=WFS&VERSION=1.0.0&SRSNAME=EPSG:3003&REQUEST=DescribeFeatureType&TYPENAME={$typeName}" ], "wfs DescribeFeatureType"),
- UI::h('a', [ 'href' => "wfs-data.php/default_db/?SERVICE=WFS&VERSION=1.0.0&SRSNAME=EPSG:3003&REQUEST=DescribeFeatureTypeAdvanced&TYPENAME={$typeName}" ], "wfs DescribeFeatureTypeAdvanced"),
- UI::h('a', [ 'href' => "wfs-data.php/default_db/?SERVICE=WFS&VERSION=1.0.0&SRSNAME=EPSG:3003&REQUEST=GetFeature&TYPENAME={$typeName}&MAXFEATURES=10" ], "wfs GetFeature (max: 10)"),
- UI::h('a', [ 'href' => "wfs-data.php/default_db/?SERVICE=WFS&VERSION=1.0.0&SRSNAME=EPSG:3003&REQUEST=GetFeatureAdvanced&TYPENAME={$typeName}&MAXFEATURES=10" ], "wfs GetFeatureAdvanced (max: 10)"),
- UI::h('a', [ 'href' => "wfs-data.php/default_db/?SERVICE=WFS&VERSION=1.0.0&SRSNAME=EPSG:3003&REQUEST=DescribeFeatureType&TYPENAME={$typeName}&root=1" ], "wfs root DescribeFeatureType"),
- UI::h('a', [ 'href' => "wfs-data.php/default_db/?SERVICE=WFS&VERSION=1.0.0&SRSNAME=EPSG:3003&REQUEST=DescribeFeatureTypeAdvanced&TYPENAME={$typeName}&root=1" ], "wfs root DescribeFeatureTypeAdvanced"),
- UI::h('a', [ 'href' => "wfs-data.php/default_db/?SERVICE=WFS&VERSION=1.0.0&SRSNAME=EPSG:3003&REQUEST=GetFeature&TYPENAME={$typeName}&MAXFEATURES=10&root=1" ], "wfs root GetFeature (max: 10)"),
- UI::h('a', [ 'href' => "wfs-data.php/default_db/?SERVICE=WFS&VERSION=1.0.0&SRSNAME=EPSG:3003&REQUEST=GetFeatureAdvanced&TYPENAME={$typeName}&MAXFEATURES=10&root=1" ], "wfs root GetFeatureAdvanced (max: 10)"),
- ])
- ]),
- ];
- }, $objectStorage->getItems([
- '#refFrom' => [
- 'namespace' => 'default_objects/SystemSource',
- 'primaryKey' => $sourceItem['idZasob']
- ],
- 'order_by' => 'namespace',
- 'order_dir' => 'asc'
- ]))
- ]);
- UI::hButtonAjaxOnResponse('addAclObjectToZasobyAjax', /* payload, n */ "
- if (!payload.type) return false
- if ('success' === payload.type || 'info' === payload.type) {
- if (payload.body && payload.body.id && payload.body.id > 0) {
- n.parentNode.replaceChild(document.createTextNode(payload.body.id), n)
- } else {
- console.log('TODO: addAclObjectToZasobyAjax unknown response', payload);
- }
- jQuery.notify(payload.msg, payload.type);
- }
- ");
- } catch (Exception $e) {
- UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
- DBG::log($e);
- }
- UI::endContainer();
- UI::dol();
- }
- public function rawInfoAction() {
- UI::gora();
- UI::menu();
- $this->navView();
- try {
- $idStorage = V::get('idStorage', 0, $_REQUEST, 'int');
- if (empty($idStorage)) throw new Exception("Missing id storage");
- $storageList = $this->getStorageList();
- if (empty($storageList)) throw new Exception("No storage defined");
- if (!array_key_exists($idStorage, $storageList)) throw new Exception("Storage not exists");
- $storagePdo = DB::getStorage($idStorage);
- $rawInfo = $storagePdo->getTableListWithInfo();
- DBG::table("rawInfo", $rawInfo, __CLASS__, __FUNCTION__, __LINE__);
- } catch (Exception $e) {
- UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
- }
- UI::dol();
- }
- public function fetchActionListAjaxAction() {
- Response::sendTryCatchJson(array($this, 'fetchActionListAjax'), $args = 'JSON_FROM_REQUEST_BODY');
- }
- public function fetchActionListAjax($args) {
- return [
- 'type' => 'success',
- '__args' => $args,
- 'options' => DB::getPDO()->fetchAll("
- select z.ID, z.`DESC`, z.OPIS
- from CRM_LISTA_ZASOBOW z
- where z.`TYPE` = 'URL_ACTION'
- and z.A_STATUS != 'DELETED'
- and z.ALIAS_ID = 0
- ")
- ];
- }
- public function addActionAjaxAction() {
- Response::sendTryCatchJson(array($this, 'addActionAjax'), $args = 'JSON_FROM_REQUEST_BODY');
- }
- public function addActionAjax($args) {
- $idStorage = V::get('idStorage', 0, $args, 'int');
- if ($idStorage <= 0) throw new Exception("Missing id storage");
- $idAction = V::get('idAction', 0, $args, 'int');
- if ($idAction <= 0) throw new Exception("Missing id action");
- $storageList = $this->getStorageList();
- if (empty($storageList)) throw new Exception("No storage defined");
- if (!array_key_exists($idStorage, $storageList)) throw new Exception("Storage not exists");
- $tblName = V::get('table', '', $args, 'word');
- if (empty($tblName)) throw new Exception("No table name");
- $storagePdo = DB::getStorage($idStorage);
- // $tblStruct = $storagePdo->getTableStruct($tblName);
- $idTable = $this->fetchTableId($idStorage, $tblName);
- if ($idTable <= 0) throw new Exception("Zasob tabela '{$tblName}' nie istnieje");
- $action = DB::getPDO()->fetchFirst("
- select z.ID, z.`DESC`, z.OPIS
- from CRM_LISTA_ZASOBOW z
- where z.ID = {$idAction}
- ");
- if (empty($action)) throw new Exception("Action '{$idAction}' not exists");
- $idInsertedAction = DB::getPDO()->insert('CRM_LISTA_ZASOBOW', [
- 'PARENT_ID' => $idTable,
- 'ALIAS_ID' => $idAction,
- 'TYPE' => 'URL_ACTION',
- 'DESC' => $action['DESC'],
- 'OPIS' => V::get('OPIS', $action['DESC'], $action),
- ]);
- if (!$idInsertedAction) throw new Exception("Nie udało się dodać akcji");
- try {
- DB::getPDO()->insert('CRM_LISTA_ZASOBOW_HIST', [
- 'ID_USERS2' => $idInsertedAction,
- 'PARENT_ID' => $idTable,
- 'ALIAS_ID' => $idAction,
- 'TYPE' => 'URL_ACTION',
- 'DESC' => $action['DESC'],
- 'OPIS' => V::get('OPIS', $action['DESC'], $action),
- ]);
- } catch (Exception $e) {
- DBG::log($e);
- }
- return [
- 'type' => 'success',
- 'msg' => "Dodano akcję - rekord nr {$idInsertedAction}",
- '__DBG__' => [
- '$args' => $args,
- '$idStorage' => $idStorage,
- '$tblName' => $tblName,
- // '$tblStruct' => $tblStruct,
- '$idTable' => $idTable,
- '$action' => $action,
- ]
- ];
- }
- public function addTableBaseProcesAction() {
- Response::sendTryCatchJson(array($this, 'addTableBaseProces'), $_REQUEST);
- }
- public function addTableBaseProces($args) {
- $return = [
- 'type' => 'error',
- 'msg' => 'todo: F.' . __FUNCTION__ . ' L.' . __LINE__,
- ];
- $idStorage = V::get('idStorage', 0, $args, 'int');
- if ($idStorage <= 0) throw new HttpException("Missing idStorage", 400);
- $storage = DB::getStorage($idStorage);
- $tblName = V::get('tblName', 0, $args, 'word');
- if (empty($tblName)) throw new HttpException("Missing tblName", 400);
- $tableStruct = $storage->getTableStruct($tblName);
- $return['$tableStruct'] = $tableStruct;
- $idTable = $this->fetchTableId($idStorage, $tblName);
- if ($idTable <= 0) {
- UI::alert('warning', "Zasob tabela '{$tblName}' nie istnieje");// TODO: add p5UI btn
- DBG::table("tblStruct", $tblStruct, __CLASS__, __FUNCTION__, __LINE__);
- throw new Exception("Zasob tabela '{$tblName}' nie istnieje");
- }
- $cellZasobList = array();
- foreach (DB::getPDO()->fetchAllByKey("
- select z.ID, z.`DESC`, z.A_STATUS
- from CRM_LISTA_ZASOBOW z
- where z.PARENT_ID = '{$idTable}'
- ", $key = 'DESC') as $ind => $row) {
- $cellZasobList[strtolower($ind)] = $row;
- }
- $return['$cellZasobList'] = $cellZasobList;
- $idProces = DB::getDB()->ADD_NEW_OBJ('CRM_PROCES', (object)[
- 'TYPE' => 'PROCES_INIT',
- 'DESC' => "Proces dla tabeli '{$tblName}'",
- ]);
- if (!$idProces) throw new Exception("DB ERROR - nie udało się dodać procesu");
- foreach ($cellZasobList as $loverName => $row) {
- DB::getDB()->ADD_NEW_OBJ('CRM_WSKAZNIK', (object)[
- 'ID_PROCES' => $idProces,
- 'ID_ZASOB' => $row['ID'],
- 'TYP' => 'P',
- 'ID_PRZYPADEK' => 2
- ]);
- }
- $return['type'] = 'success';
- $return['msg'] = "Utworzono proces {{$idProces}}";
- return $return;
- }
- public function addObjectBaseProcesAjaxAction() {
- Response::sendTryCatchJson(array($this, 'addObjectBaseProcesAjax'), $_REQUEST);
- }
- public function addObjectBaseProcesAjax($args) {
- $return = [
- 'type' => 'error',
- 'msg' => 'todo: F.' . __FUNCTION__ . ' L.' . __LINE__,
- ];
- $namespace = V::get('namespace', 0, $args);
- if (empty($namespace)) throw new HttpException("Missing namespace", 400);
- $item = SchemaFactory::loadDefaultObject('SystemObject')->getItem($namespace, [ 'propertyName' => '*,field' ]);
- DBG::log($item, 'array', "TODO: addObjectBaseProcesAjax for \$item");
- if (!$item['idZasob']) throw new Exception("Missing id zasob for object '{$namespace}'");
- if (!$item['idDatabase']) throw new Exception("Missing id database for object '{$namespace}'");
- if (!$item['_rootTableName']) throw new Exception("Missing root table name for object '{$namespace}'");
- if ('AntAcl' != $item['_type']) throw new Exception("Not implemented type '{$item['_type']}' for namespace '{$namespace}' - only AntAcl supported");
- if (!$item['hasStruct']) throw new Exception("Missing structure for object '{$namespace}'");
- if (!$item['isStructInstalled']) throw new Exception("Structure not installed for object '{$namespace}'");
- if (!$item['isObjectActive']) throw new Exception("Object is not active '{$namespace}'");
- $fieldsWithIdZasob = array_filter($item['field'], function ($field) {
- if (!$field['idZasob']) return false;
- return true;
- });
- if (empty($fieldsWithIdZasob)) throw new Exception("Missing fields with id zasob in object '{$namespace}'");
- $idProces = DB::getDB()->ADD_NEW_OBJ('CRM_PROCES', (object)[
- 'TYPE' => 'PROCES_INIT',
- 'DESC' => "TODO: Proces dla obiektu '{$namespace}'",
- ]);
- if (!$idProces) throw new Exception("DB ERROR - nie udało się dodać procesu");
- array_map(function ($field) use ($idProces) {
- DB::getDB()->ADD_NEW_OBJ('CRM_WSKAZNIK', (object)[
- 'ID_PROCES' => $idProces,
- 'ID_ZASOB' => $field['idZasob'],
- 'TYP' => 'P',
- 'ID_PRZYPADEK' => 2
- ]);
- }, $fieldsWithIdZasob);
- $return['type'] = 'success';
- $return['msg'] = "Utworzono proces {{$idProces}}";
- return $return;
- }
- public function addGeomEtykietaCellsAction() {
- Response::sendTryCatchJson(array($this, 'addGeomEtykietaCells'), $_REQUEST);
- }
- public function addGeomEtykietaCells($args) {
- $return = [
- 'type' => 'error',
- 'msg' => 'todo: F.' . __FUNCTION__ . ' L.' . __LINE__,
- ];
- $return['_DBG_request'] = $args;
- // idStorage: "36"
- // tblName: "test_geom_linestring"
- $idStorage = V::get('idStorage', 0, $args, 'int');
- if ($idStorage <= 0) throw new HttpException("Missing idStorage", 400);
- $storage = DB::getStorage($idStorage);
- $tblName = V::get('tblName', 0, $args, 'word');
- if (empty($tblName)) throw new HttpException("Missing tblName", 400);
- $tableStruct = $storage->getTableStruct($tblName);
- $return['_DBG_$tableStruct'] = $tableStruct;
- if ('mysql' == DB::getPDO($idStorage)->getType()) {
- $dbName = DB::getPDO($idStorage)->getDatabaseName();
- $fixedTableName = DB::getPDO($idStorage)->fetchValue("
- select t.TABLE_NAME
- from `information_schema`.`TABLES` t
- where t.TABLE_SCHEMA = '{$dbName}'
- and t.TABLE_NAME LIKE '{$tblName}'
- ");
- $return['_DBG_sql_fix__$tblName'] = "
- select t.TABLE_NAME
- from `information_schema`.`TABLES` t
- where t.TABLE_SCHEMA = '{$dbName}'
- and t.TABLE_NAME LIKE '{$tblName}'
- ";
- if (empty($fixedTableName)) return $return;
- if (empty($fixedTableName)) throw new HttpException("Database Error", 500);
- $return['_DBG_$fixedTableName'] = $fixedTableName;
- $tblName = $fixedTableName;
- }
- $return['_DBG_$tableStruct'] = $tableStruct;
- $return['_DBG_has_field__etykieta_x'] = (null != V::geti('etykieta_x', null, $tableStruct));
- $return['_DBG_has_field__etykieta_y'] = (null != V::geti('etykieta_y', null, $tableStruct));
- $return['_DBG_has_field__etykieta_obrot'] = (null != V::geti('etykieta_obrot', null, $tableStruct));
- if (!V::geti('etykieta_x', null, $tableStruct)) {
- try {
- DB::getPDO($idStorage)->exec("ALTER TABLE `{$tblName}_HIST` ADD `etykieta_x` varchar(16) DEFAULT 'N/S;'");
- } catch (Exception $e) {
- $return['__DBG_hist_errors__etykieta_x'] = $e->getMessage();
- }
- DB::getPDO($idStorage)->exec("ALTER TABLE `{$tblName}` ADD `etykieta_x` decimal(16,10) DEFAULT NULL COMMENT 'przesuniecie etykiety elementu w GIS'");
- }
- if (!V::geti('etykieta_y', null, $tableStruct)) {
- try {
- DB::getPDO($idStorage)->exec("ALTER TABLE `{$tblName}_HIST` ADD `etykieta_y` varchar(16) DEFAULT 'N/S;'");
- } catch (Exception $e) {
- $return['__DBG_hist_errors__etykieta_y'] = $e->getMessage();
- }
- DB::getPDO($idStorage)->exec("ALTER TABLE `{$tblName}` ADD `etykieta_y` decimal(16,10) DEFAULT NULL COMMENT 'przesuniecie etykiety elementu w GIS'");
- }
- if (!V::geti('etykieta_obrot', null, $tableStruct)) {
- try {
- DB::getPDO($idStorage)->exec("ALTER TABLE `{$tblName}_HIST` ADD `etykieta_obrot` varchar(16) DEFAULT 'N/S;'");
- } catch (Exception $e) {
- $return['__DBG_hist_errors__etykieta_obrot'] = $e->getMessage();
- }
- DB::getPDO($idStorage)->exec("ALTER TABLE `{$tblName}` ADD `etykieta_obrot` decimal(16,10) DEFAULT NULL");
- }
- return $return;
- }
- public function xsdAction() {
- $idStorage = V::get('idStorage', 0, $_REQUEST, 'int');
- $storage = DB::getStorage($idStorage);
- $tableRealList = $storage->getTableList();
- $srvName = $_SERVER['SERVER_NAME'];
- $storageZasobId = $storage->getZasobId();
- $objNs = "p5_{$storageZasobId}_{$tblName}";
- $objNsUri = "https://biuro.biall-net.pl/api/{$storageZasobId}/{$tblName}";
- $p5TypePrefix = "p5Type";
- $p5TypeNsUri = "http://biuro.biall-net.pl/p5/schema/types";
- $p5TypeNsLocation = "http://biuro.biall-net.pl/p5/schema/types.xsd";
- header('Content-type: text/plain; charset=utf-8');// TODO: test
- //header('Content-type: application/xml; charset=utf-8');
- $xmlWriter = new XMLWriter();
- $xmlWriter->openUri('php://output');
- $xmlWriter->setIndent(true);
- if (!$xmlWriter) throw new HttpException("Error no XMLWriter", 404);
- $xmlWriter->startDocument('1.0', 'UTF-8');
- $xmlWriter->startElement('xs:schema');
- $xmlWriter->writeAttribute('xmlns:xs', 'http://www.w3.org/2001/XMLSchema');
- $xmlWriter->writeAttribute('xmlns:vc', 'http://www.w3.org/2007/XMLSchema-versioning');
- $xmlWriter->writeAttribute("xmlns:{$p5TypePrefix}", $p5TypeNsUri);
- $xmlWriter->writeAttribute('elementFormDefault', 'qualified');
- $xmlWriter->writeAttribute('targetNamespace', $objNsUri);
- $xmlWriter->writeAttribute('vc:minVersion', '1.1');
- $xmlWriter->startElement('xs:import');
- $xmlWriter->writeAttribute('namespace', $p5TypeNsUri);
- $xmlWriter->writeAttribute('schemaLocation', $p5TypeNsLocation);
- $xmlWriter->endElement();// xs:import
- foreach ($tableRealList as $tbl) {
- $tblName = $tbl['table_name'];
- $this->tableXsdViewXmlWriter($xmlWriter, $idStorage, $tblName);
- }
- $xmlWriter->endElement();// xs:schema
- $xmlWriter->endDocument();
- }
- public function tableXsdAction() {
- $idStorage = V::get('idStorage', '', $_GET);
- $tblName = V::get('table', '', $_GET, 'word');
- if (empty($tblName)) die("Wrong table name");
- header('Content-type: text/plain; charset=utf-8');// TODO: test
- $storage = DB::getStorage($idStorage);
- $storageZasobId = $storage->getZasobId();
- $objNs = "p5_{$storageZasobId}_{$tblName}";
- $objNsUri = "https://biuro.biall-net.pl/api/{$storageZasobId}/{$tblName}";
- $p5TypePrefix = "p5Type";
- $p5TypeNsUri = "http://biuro.biall-net.pl/p5/schema/types";
- $p5TypeNsLocation = "http://biuro.biall-net.pl/p5/schema/types.xsd";
- //header('Content-type: application/xml; charset=utf-8');
- $xmlWriter = new XMLWriter();
- $xmlWriter->openUri('php://output');
- $xmlWriter->setIndent(true);
- if (!$xmlWriter) throw new HttpException("Error no XMLWriter", 404);
- $xmlWriter->startDocument('1.0', 'UTF-8');
- $xmlWriter->startElement('xs:schema');
- $xmlWriter->writeAttribute('xmlns:xs', 'http://www.w3.org/2001/XMLSchema');
- $xmlWriter->writeAttribute('xmlns:vc', 'http://www.w3.org/2007/XMLSchema-versioning');
- $xmlWriter->writeAttribute("xmlns:{$p5TypePrefix}", $p5TypeNsUri);
- $xmlWriter->writeAttribute('elementFormDefault', 'qualified');
- $xmlWriter->writeAttribute('targetNamespace', $objNsUri);
- $xmlWriter->writeAttribute('vc:minVersion', '1.1');
- $xmlWriter->startElement('xs:import');
- $xmlWriter->writeAttribute('namespace', $p5TypeNsUri);
- $xmlWriter->writeAttribute('schemaLocation', $p5TypeNsLocation);
- $xmlWriter->endElement();// xs:import
- $this->tableXsdViewXmlWriter($xmlWriter, $idStorage, $tblName);
- $xmlWriter->endElement();// xs:schema
- $xmlWriter->endDocument();
- }
- public function tableXsdViewXmlWriter(&$xmlWriter, $idStorage, $tblName) {
- $storage = DB::getStorage($idStorage);
- $schema = Schema_TableFactory::build($tblName, $idStorage, $_SERVER['SERVER_NAME']);
- $struct = $schema->getStruct();
- DBG::_('DBG', '>1', "struct", $struct, __CLASS__, __FUNCTION__, __LINE__);
- $typeName = "{$tblName}Type";
- $xmlWriter->startElement('xs:complexType');
- $xmlWriter->writeAttribute('name', $typeName);
- $xmlWriter->startElement('xs:sequence');
- foreach ($struct as $field) {
- $xmlWriter->startElement('xs:element');
- $xmlWriter->writeAttribute('name', $field['name']);
- $xmlWriter->writeAttribute('minOccurs', 0);// TODO: set minOccurs by default, etc.
- if ($field['is_nullable']) $xmlWriter->writeAttribute('nillable', 'true');
- if (null !== $field['default_value']) {
- $xmlWriter->writeAttribute('default', $field['default_value']);
- } else if (null === $field['default_value'] && $field['is_nullable']) {
- $xmlWriter->writeAttribute('default', $field['default_value']);
- } else {
- // TODO: Schema BUG?
- }
- if (empty($field['p5_restrictions'])) {
- $xmlWriter->writeAttribute('type', "p5Type:{$field['p5_type']}");
- } else {
- $xmlWriter->startElement('xs:simpleType');
- $xmlWriter->writeAttribute('base', "p5Type:{$field['p5_type']}");
- $xmlWriter->startElement('xs:restriction');
- if (!empty($field['p5_restrictions']['enumeration'])) {
- foreach ($field['p5_restrictions']['enumeration'] as $enumValue) {
- $xmlWriter->startElement('xs:enumeration');
- $xmlWriter->writeAttribute('value', $enumValue);
- $xmlWriter->endElement();// xs:enumeration
- }
- } else {
- // TODO: another restrictions...
- }
- $xmlWriter->endElement();// xs:restriction
- $xmlWriter->endElement();// xs:simpleType
- }
- $xmlWriter->endElement();// xs:element
- }
- $xmlWriter->endElement();// xs:sequence
- $xmlWriter->endElement();// xs:complexType
- return;
- // <xs:element maxOccurs="1" minOccurs="0" name="{$fldName}" nillable="true" type="xs:integer"/>
- $pKeyField = 'ID';//$storageObject->getPrimaryKeyFieldName();
- //DBG::_(true, true, "struct", $struct, __CLASS__, __FUNCTION__, __LINE__);
- foreach ($struct as $field) {
- $fldName = $vField->getName();
- $fldType = $vField->getType();
- $xsdType = $fldType->getTypeForXsd();
- if ($fldType->hasDefault()) {
- $fldDefault = $fldType->getDefault();
- if (!empty($fldDefault) || '0' === $fldDefault) {
- $elNode->setAttribute('default', $fldDefault);
- }
- }
- $fldRestrictions = $fldType->getRestrictions();
- if (empty($fldRestrictions)) {
- $elNode->setAttribute('type', "{$p5TypePrefix}:{$xsdType}");
- } else {
- $sType = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xs:simpleType');
- $elNode->appendChild($sType);
- $sTypeRes = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xs:restriction');
- $sType->appendChild($sTypeRes);
- $sTypeRes->setAttribute('base', "{$p5TypePrefix}:{$xsdType}");
- $enumList = $fldType->getEnumeration();
- if (empty($enumList)) {
- foreach ($fldRestrictions as $restricionName => $restrictionValue) {
- if ('maxLength' == $restricionName) {
- $sTypeResMaxLength = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xs:maxLength');
- $sTypeRes->appendChild($sTypeResMaxLength);
- $sTypeResMaxLength->setAttribute('value', $restrictionValue);
- } else if ('minLength' == $restricionName) {
- $sTypeResMinLength = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xs:minLength');
- $sTypeRes->appendChild($sTypeResMinLength);
- $sTypeResMinLength->setAttribute('value', $restrictionValue);
- } else if ('pattern' == $restricionName) {
- $sTypeResPattern = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xs:pattern');
- $sTypeRes->appendChild($sTypeResPattern);
- $sTypeResPattern->setAttribute('value', $restrictionValue);
- } else if ('fractionDigits' == $restricionName) {
- $sTypeResFractionDigits = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xs:fractionDigits');
- $sTypeRes->appendChild($sTypeResFractionDigits);
- $sTypeResFractionDigits->setAttribute('value', $restrictionValue);
- } else if ('totalDigits' == $restricionName) {
- $sTypeResTotalDigits = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xs:totalDigits');
- $sTypeRes->appendChild($sTypeResTotalDigits);
- $sTypeResTotalDigits->setAttribute('value', $restrictionValue);
- } else if ('maxExclusive' == $restricionName) {
- $sTypeResMaxExclusive = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xs:maxExclusive');
- $sTypeRes->appendChild($sTypeResMaxExclusive);
- $sTypeResMaxExclusive->setAttribute('value', $restrictionValue);
- } else if ('minExclusive' == $restricionName) {
- $sTypeResMinExclusive = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xs:minExclusive');
- $sTypeRes->appendChild($sTypeResMinExclusive);
- $sTypeResMinExclusive->setAttribute('value', $restrictionValue);
- } else if ('maxInclusive' == $restricionName) {
- $sTypeResMaxInclusive = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xs:maxInclusive');
- $sTypeRes->appendChild($sTypeResMaxInclusive);
- $sTypeResMaxInclusive->setAttribute('value', $restrictionValue);
- } else if ('minInclusive' == $restricionName) {
- $sTypeResMinInclusive = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xs:minInclusive');
- $sTypeRes->appendChild($sTypeResMinInclusive);
- $sTypeResMinInclusive->setAttribute('value', $restrictionValue);
- }
- /* TODO: xsd restrictions:
- enumeration Defines a list of acceptable values
- fractionDigits Specifies the maximum number of decimal places allowed. Must be equal to or greater than zero
- length Specifies the exact number of characters or list items allowed. Must be equal to or greater than zero
- maxExclusive Specifies the upper bounds for numeric values (the value must be less than this value)
- maxInclusive Specifies the upper bounds for numeric values (the value must be less than or equal to this value)
- maxLength Specifies the maximum number of characters or list items allowed. Must be equal to or greater than zero
- minExclusive Specifies the lower bounds for numeric values (the value must be greater than this value)
- minInclusive Specifies the lower bounds for numeric values (the value must be greater than or equal to this value)
- minLength Specifies the minimum number of characters or list items allowed. Must be equal to or greater than zero
- pattern Defines the exact sequence of characters that are acceptable
- totalDigits Specifies the exact number of digits allowed. Must be greater than zero
- whiteSpace Specifies how white space (line feeds, tabs, spaces, and carriage returns) is handled
- */
- }
- } else {
- foreach ($enumList as $enumValue) {
- $sTypeResEnum = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xs:enumeration');
- $sTypeRes->appendChild($sTypeResEnum);
- $sTypeResEnum->setAttribute('value', $enumValue);
- }
- }
- }
- }
- $elNode = $dom->createElementNS('http://www.w3.org/2001/XMLSchema', 'xs:element');
- $rootNode->appendChild($elNode);
- $elNode->setAttribute('name', $tblName);
- $elNode->setAttribute('type', "{$objNs}:{$typeName}");
- header('Content-type: application/xml');
- echo $dom->saveXML();
- exit;
- }
- public function navView() {
- $backLabel = 'back';
- $backLink = 'index.php?_route=Storage';
- $backDisabled = true;
- $currentLabel = 'Storage';
- $currentLink = 'index.php?_route=Storage';
- if ($task = V::get('_task', '', $_REQUEST)) {
- $currentLink = "index.php?_route=Storage&_task={$task}";
- $backDisabled = false;
- $idStorage = V::get('idStorage', 0, $_REQUEST, 'int');
- $tblName = V::get('table', '', $_REQUEST, 'word');
- $objName = V::get('object', '', $_REQUEST, 'word');
- $namespace = V::get('namespace', '', $_REQUEST, 'word');
- switch ($task) {
- case 'obejctList':
- case 'tableList':
- case 'viewList':
- case 'rawInfo':
- $backLabel = 'Storage';
- $backLink = $this->getLink();
- $currentLink = $this->getLink($task, ['idStorage' => $idStorage]);
- break;
- case 'tableStruct':
- $backLabel = "Tabele [{$idStorage}]";
- $backLink = $this->getLink('tableList', ['idStorage' => $idStorage]);
- $currentLink = $this->getLink($task, ['idStorage' => $idStorage, 'table' => $tblName]);
- break;
- case 'objectStruct':
- $backLabel = "Obiekty [{$idStorage}]";
- $backLink = $this->getLink('tableList', ['idStorage' => $idStorage]);// TODO: mv tableList to objectList
- $currentLink = $this->getLink($task, ['idStorage' => $idStorage, 'namespace' => $namespace]);
- break;
- case 'coreObjectStruct':
- $backLabel = "Obiekty podstawowe";
- $backLink = $this->getLink('coreObjectList', ['idStorage' => $idStorage]);
- $currentLink = $this->getLink($task, ['idStorage' => $idStorage, 'object' => $objName]);
- break;
- }
- switch ($task) {
- case 'tableList': $currentLabel = "Tabele [{$idStorage}]"; break;
- case 'viewList': $currentLabel = "Widoki [{$idStorage}]"; break;
- case 'rawInfo': $currentLabel = "Raw info [{$idStorage}]"; break;
- case 'tableStruct': $currentLabel = "Struktura tabeli '{$tblName}'"; break;
- case 'objectStruct': $currentLabel = "Obiekt '{$namespace}'"; break;
- case 'coreObjectList': $currentLabel = "Obiekty podstawowe"; break;
- case 'coreObjectStruct': $currentLabel = "Obiekt '{$objName}'"; break;
- case 'objectList': $currentLabel = "Obiekty z aktualnej domeny"; break;// TODO: domain from $_GET
- }
- }
- echo UI::h('nav', ['class'=>"navbar navbar-default navbar-static-top", 'style'=>"z-index:999"], [
- UI::h('div', ['class'=>"container-fluid"], [
- UI::h('div', ['class'=>"navbar-left"], [
- UI::h('ul', ['class'=>"nav navbar-nav navbar-center"], [
- UI::h('li', [], [
- UI::h('a', ['href'=>$backLink, 'class'=>"btn" . ($backDisabled ? ' disabled' : '')], '<i class="glyphicon glyphicon-chevron-left"></i> ' . $backLabel)
- ])
- ])
- ]),
- UI::h('div', ['class'=>"navbar-left"], [
- UI::h('ul', ['class'=>"nav navbar-nav navbar-center"], [
- UI::h('li', [], [
- UI::h('a', ['href'=>$currentLink, 'class'=>"btn"], $currentLabel)
- ])
- ])
- ]),
- UI::h('div', ['class'=>"navbar-right"], [
- // <ul class="nav navbar-nav navbar-right">
- // <li><a href="#">Link</a></li>
- // <li class="dropdown"><a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-haspopup="true" aria-expanded="false">Dropdown <span class="caret"></span></a>
- // <ul class="dropdown-menu">
- // <li><a href="#">Action</a></li>
- // <li><a href="#">Another action</a></li>
- // <li><a href="#">Something else here</a></li>
- // <li role="separator" class="divider"></li>
- // <li><a href="#">Separated link</a></li>
- // </ul>
- // </li>
- // </ul>
- ])
- ])
- ]);
- }
- public function getStorageList() {
- $storageList = array();
- $sth = DB::getPDO()->prepare("
- select z.ID, z.`DESC`, z.`TYPE`
- from CRM_LISTA_ZASOBOW z
- where z.TYPE in('BAZA_DANYCH','DATABASE_MYSQL','DATABASE_POSTGRESQL')
- ");
- $sth->execute();
- $rows = $sth->fetchAll();
- foreach ($rows as $row) {
- $storageList[$row['ID']] = $row;
- }
- return $storageList;
- }
- public function addAclObjectToZasobyAction() {// sends JSON
- $response = new stdClass();
- try {
- $idStorage = V::get('idStorage', '', $_GET);
- $namespace = V::get('namespace', '', $_GET);
- if (empty($idStorage)) throw new HttpException("Missing idStorage param");
- if (empty($namespace)) throw new HttpException("Missing namespace param");
- $objectStorage = SchemaFactory::loadDefaultObject('SystemObject');
- $items = $objectStorage->getItems([
- 'f_namespace' => "={$namespace}",
- ]);
- if (empty($items)) throw new Exception("SystemObject '{$namespace}' not found");
- $objectItem = reset($items);
- if (empty($objectItem)) throw new Exception("SystemObject '{$namespace}' not found");
- DBG::log($objectItem, 'array', 'object acl $objectItem');
- if ($objectItem['idZasob'] > 0) {
- // TODO: check if realy exists? @see SchemaFactory::loadDefaultObject('SystemObject')::updateCache()
- $response->_replaceButtonNode = "[{$objectItem['idZasob']}]";
- throw new AlertInfoException("Zasob '{$objectItem['namespace']}' już istnieje - nr '{$objectItem['idZasob']}'");
- }
- $idZasobFound = 0;
- switch ($objectItem['_type']) {
- case 'TableAcl': $idZasobFound = DB::getPDO()->fetchValue(" select ID from CRM_LISTA_ZASOBOW where PARENT_ID = {$objectItem['idDatabase']} and `DESC` = '{$objectItem['name']}' "); break;
- case 'AntAcl': $idZasobFound = DB::getPDO()->fetchValue(" select ID from CRM_LISTA_ZASOBOW where PARENT_ID = {$objectItem['idDatabase']} and `DESC` = '{$objectItem['namespace']}' "); break;
- default: throw new Exception("Not implemented acl type '{$objectItem['_type']}'");
- }
- if ($idZasobFound > 0) {
- DB::getPDO()->update($objectStorage->_rootTableName, 'namespace', $objectItem['namespace'], [
- 'idZasob' => $idZasobFound
- ]);
- $response->id = $idZasobFound;
- throw new AlertSuccessException("Zasob '{$objectItem['namespace']}' już istnieje - nr '{$idZasobFound}' - cache zaktualizowany");
- }
- try {
- $acl = User::getAcl()->getObjectAcl('default_db', 'crm_lista_zasobow');
- } catch (Exception $e) {
- DBG::log($e);
- throw new Exception("Brak dostępu do tabeli Zasoby");
- }
- if (empty($objectItem['idDatabase'])) throw new Exception("Missing database id");
- if ($idStorage != $objectItem['idDatabase']) throw new Exception("Database id must be the same");
- if (empty($objectItem['_rootTableName'])) throw new Exception("Missing root table name");
- switch ($objectItem['_type']) {
- case 'TableAcl':
- $newZasobItem = [
- 'PARENT_ID' => $objectItem['idDatabase'],
- 'TYPE' => 'TABELA',
- 'DESC' => $objectItem['_rootTableName'],
- 'DESC_PL' => $objectItem['name'],
- ];
- break;
- case 'AntAcl':
- $newZasobItem = [
- 'PARENT_ID' => $objectItem['idDatabase'],
- 'TYPE' => 'TABELA',
- 'DESC' => $objectItem['namespace'],
- 'DESC_PL' => $objectItem['name'],
- ];
- break;
- default: throw new Exception("Not implemented acl type '{$objectItem['_type']}'");
- }
- $idCreated = $acl->addItem($newZasobItem);
- if (!$idCreated) throw new Exception("Nie udało się utworzyć nowego rekordu!");
- try {
- DB::getPDO()->update($objectStorage->_rootTableName, 'namespace', $objectItem['namespace'], [
- 'idZasob' => $idCreated
- ]);
- } catch (Exception $e) {
- DBG::log($e);
- }
- $response->id = $idCreated;
- $response->record = $acl->getItem($idCreated);
- $response->_replaceButtonNode = "[{$idCreated}]";
- throw new AlertSuccessException("Utworzono pomyślnie rekord nr {$idCreated}");
- } catch (AlertSuccessException $e) {
- $response->type = 'success';
- $response->msg = $e->getMessage();
- } catch (AlertInfoException $e) {
- $response->type = 'info';
- $response->msg = $e->getMessage();
- } catch (Exception $e) {
- $response->type = 'error';
- $response->msg = $e->getMessage();
- DBG::log($e);
- }
- Response::sendJsonExit($response);
- }
- public function addAclObjectToZasobyAjaxAction() {
- DBG::log($_REQUEST, 'array', '$_REQUEST');
- Response::sendTryCatchJson(array($this, 'addAclObjectToZasobyAjax'), $_REQUEST);
- }
- public function addAclObjectToZasobyAjax($args) {
- $namespace = V::get('namespace', '', $args);
- if (empty($namespace)) throw new HttpException("Missing namespace");
- $idStorage = V::get('idStorage', '', $args);
- if (empty($idStorage)) throw new HttpException("Missing idStorage");
- $objectStorage = SchemaFactory::loadDefaultObject('SystemObject');
- $items = $objectStorage->getItems([
- 'f_namespace' => "={$namespace}",
- ]);
- if (empty($items)) throw new Exception("SystemObject '{$namespace}' not found");
- $objectItem = reset($items);
- if (empty($objectItem)) throw new Exception("SystemObject '{$namespace}' not found");
- DBG::log($objectItem, 'array', 'object acl $objectItem');
- if ($objectItem['idZasob'] > 0) {
- // TODO: check if realy exists? @see SchemaFactory::loadDefaultObject('SystemObject')::updateCache()
- return [
- 'type' => 'info',
- 'msg' => "Zasob '{$objectItem['namespace']}' już istnieje - nr '{$objectItem['idZasob']}'",
- 'body' => [
- 'id' => $objectItem['idZasob'],
- 'record' => $acl->getItem($objectItem['idZasob']),
- '_replaceButtonNode' => "[{$objectItem['idZasob']}]",
- ]
- ];
- }
- $idZasobFound = 0;
- switch ($objectItem['_type']) {
- case 'TableAcl': $idZasobFound = DB::getPDO()->fetchValue(" select ID from CRM_LISTA_ZASOBOW where PARENT_ID = {$objectItem['idDatabase']} and `DESC` = '{$objectItem['name']}' "); break;
- case 'AntAcl': $idZasobFound = DB::getPDO()->fetchValue(" select ID from CRM_LISTA_ZASOBOW where PARENT_ID = {$objectItem['idDatabase']} and `DESC` = '{$objectItem['namespace']}' "); break;
- default: throw new Exception("Not implemented acl type '{$objectItem['_type']}'");
- }
- if ($idZasobFound > 0) {
- DB::getPDO()->update($objectStorage->_rootTableName, 'namespace', $objectItem['namespace'], [
- 'idZasob' => $idZasobFound
- ]);
- return [
- 'type' => 'info',
- 'msg' => "Zasob '{$objectItem['namespace']}' już istnieje - nr '{$idZasobFound}' - cache zaktualizowany",
- 'body' => [
- 'id' => $idZasobFound,
- 'record' => $acl->getItem($idZasobFound),
- '_replaceButtonNode' => "[{$idZasobFound}]",
- ]
- ];
- }
- try {
- $acl = User::getAcl()->getObjectAcl('default_db', 'crm_lista_zasobow');
- } catch (Exception $e) {
- DBG::log($e);
- throw new Exception("Brak dostępu do tabeli Zasoby");
- }
- if (empty($objectItem['idDatabase'])) throw new Exception("Missing database id");
- if ($idStorage != $objectItem['idDatabase']) throw new Exception("Database id must be the same");
- if (empty($objectItem['_rootTableName'])) throw new Exception("Missing root table name");
- switch ($objectItem['_type']) {
- case 'TableAcl':
- $newZasobItem = [
- 'PARENT_ID' => $objectItem['idDatabase'],
- 'TYPE' => 'TABELA',
- 'DESC' => $objectItem['_rootTableName'],
- 'DESC_PL' => $objectItem['name'],
- ];
- break;
- case 'AntAcl':
- $newZasobItem = [
- 'PARENT_ID' => $objectItem['idDatabase'],
- 'TYPE' => 'TABELA',
- 'DESC' => $objectItem['namespace'],
- 'DESC_PL' => $objectItem['name'],
- ];
- break;
- default: throw new Exception("Not implemented acl type '{$objectItem['_type']}'");
- }
- $idCreated = $acl->addItem($newZasobItem);
- if (!$idCreated) throw new Exception("Nie udało się utworzyć nowego rekordu!");
- try {
- DB::getPDO()->update($objectStorage->_rootTableName, 'namespace', $objectItem['namespace'], [
- 'idZasob' => $idCreated
- ]);
- } catch (Exception $e) {
- DBG::log($e);
- }
- return [
- 'type' => 'success',
- 'msg' => "Utworzono pomyślnie rekord nr {$idCreated}",
- 'body' => [
- 'id' => $idCreated,
- 'record' => $acl->getItem($idCreated),
- '_replaceButtonNode' => "[{$idCreated}]",
- ]
- ];
- }
- public function addCellToZasobyAction() {// sends JSON
- $response = new stdClass();
- try {
- $idStorage = V::get('storageId', '', $_GET);
- $tblName = V::get('tblName', '', $_GET, 'word');
- $cellName = V::get('cellName', '', $_GET, 'word');
- if (empty($tblName)) throw new HttpException("Wrong table name");
- if (empty($tblName)) throw new HttpException("Wrong cell name");
- $storage = DB::getStorage($idStorage);
- $tableStruct = $storage->getTableStruct($tblName);
- $zasobStorageId = $storage->getZasobId();
- if (!is_numeric($zasobStorageId)) throw new HttpException("Storage id is not set in config file");
- $idTable = $this->fetchTableId($zasobStorageId, $tblName);
- if ($idTable <= 0) throw new Exception("Zasob tabela '{$tblName}' nie istnieje");
- try {
- $acl = User::getAcl()->getObjectAcl('default_db', 'crm_lista_zasobow');
- } catch (Exception $e) {
- throw new Exception("Brak dostępu do tabeli Zasoby");
- }
- $item = array();
- $item['PARENT_ID'] = $idTable;
- $item['TYPE'] = 'KOMORKA';
- $item['DESC'] = $cellName;
- $item['DESC_PL'] = $cellName;
- if (DBG::isActive()) $response->_itemToCreate = $item;
- $createdId = $acl->addItem($item);
- if (!$createdId) throw new Exception("Nie udało się utworzyć nowego rekordu!");
- $response->id = $createdId;
- $response->record = $acl->getItem($createdId);
- $response->_replaceButtonNode = "[{$createdId}]";
- throw new AlertSuccessException("Utworzono pomyślnie rekord nr {$createdId}");
- } catch (AlertSuccessException $e) {
- $response->type = 'success';
- $response->msg = $e->getMessage();
- } catch (AlertInfoException $e) {
- $response->type = 'info';
- $response->msg = $e->getMessage();
- } catch (Exception $e) {
- $response->type = 'error';
- $response->msg = $e->getMessage();
- }
- Response::sendJsonExit($response);
- }
- public function fetchTableId($idZasobStorage, $tblName) {
- $rows = DB::getPDO()->fetchAll("
- select z.`ID`, z.`DESC`
- from `CRM_LISTA_ZASOBOW` z
- where z.`PARENT_ID`='{$idZasobStorage}'
- and z.`DESC`='{$tblName}'
- and z.`A_STATUS` in('NORMAL','WAITING')
- ");
- if (!empty($rows)) return (int)$rows[0]['ID'];
- return null;
- }
- public function systemObjectsStructAction() {
- UI::gora();
- UI::menu();
- $this->navView();
- try {
- throw new Exception("TODO: F." . __FUNCTION__ . ' L.' . __LINE__);
- // $coreObjlist = OBJXSD::getSystemObjectsStruct();
- // $objectList = array();
- // foreach ($coreObjlist as $objName) {
- // $objItem = array();
- // $objItem['name'] = $objName;
- // $objItem['struktura'] = '<a href="index.php?_route=Storage&_task=systemObjectsStruct&object=' . $objName . '">' . "struct" . '</a>';
- // // $objItem['label'] = "";// TODO: read from json
- // $objectList[] = $objItem;
- // }
- // usort($objectList, function($rowA, $rowB) {
- // $a = $rowA['nazwa']; $b = $rowB['nazwa'];
- // if ($a == $b) return 0;
- // return ($a < $b) ? -1 : 1;
- // });
- //
- // DBG::table("objectList", $objectList, __CLASS__, __FUNCTION__, __LINE__);
- } catch (Exception $e) {
- UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
- }
- UI::dol();
- }
- public function systemObjectsAction() {// TableAjax view: index.php?_route=ViewTableAjax&namespace=default_objects/SystemObject
- UI::gora();
- UI::menu();
- $this->navView();
- try {
- Lib::loadClass('Schema_SystemObjectStorageAcl');
- $acl = new Schema_SystemObjectStorageAcl();
- UI::table([
- 'rows' => array_map(
- function ($item) {
- return [
- 'ns' => $item['namespace'],
- 'nazwa' => $item['name'],
- 'type' => $item['_type'],
- 'edit' => '<a href="index.php?_route=ViewTableAjax&namespace=' . $item['namespace'] . '">edit</a>',
- 'wfs Describe' => '<a href="wfs-data.php/default_db/?SERVICE=WFS&VERSION=1.0.0&SRSNAME=EPSG:3003&REQUEST=DescribeFeatureType&TYPENAME=' . $item['typeName'] . '">DescribeFeatureType</a>',
- 'wfs getFeature' => '<a href="wfs-data.php/default_db/?SERVICE=WFS&VERSION=1.0.0&SRSNAME=EPSG:3003&REQUEST=GetFeature&TYPENAME=' . $item['typeName'] . '&MAXFEATURES=10">GetFeature</a> (max:10)'
- ];
- }
- , $acl->getItems([
- 'order_by' => 'namespace',
- 'order_dir' => 'asc'
- ])
- )
- ]);
- } catch (Exception $e) {
- UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
- DBG::log($e);
- }
- UI::dol();
- }
- public function objectReinstallAction() {
- UI::gora();
- UI::startContainer();
- try {
- $namespace = V::get('namespace', '', $_GET);
- if (empty($namespace)) throw new Exception("Missing param namespace");
- echo UI::h('h3', [], $namespace);
- Lib::loadClass('Schema_SystemObjectFieldStorageAcl');
- $objFieldAcl = new Schema_SystemObjectFieldStorageAcl();
- $objFieldAcl->updateCache($namespace);
- DBG::nicePrint([
- 'idInstance' => ACL::getInstanceId($namespace),
- 'rootInstance' => ACL::getRootNamespace($namespace),
- 'conf' => ACL::fetchInstanceConfig($namespace),
- 'table' => ACL::getInstanceTable($namespace),
- ], "dbg");
- {
- $item = SchemaFactory::loadDefaultObject('SystemObject')->getItem($namespace, [ 'propertyName' => '*,field' ]);
- if ('AntAcl' === $item['_type']) {
- $dbName = DB::getPDO()->getDatabaseName();
- $sqlFunBody = ACL::generateIsInstanceFunctionBody($namespace, $item);
- DBG::nicePrint($sqlFunBody, "\$sqlFunBody");
- DB::getPDO()->execSql(" DROP FUNCTION IF EXISTS `{$dbName}`.`isInstance_{$namespace}` ");
- // CREATE
- // [DEFINER = { user | CURRENT_USER }]
- // FUNCTION sp_name ([func_parameter[,...]])
- // RETURNS type
- // [characteristic ...] routine_body
- DB::getPDO()->execSql("
- CREATE DEFINER=`root`@`localhost`
- FUNCTION `{$dbName}`.`isInstance_{$namespace}` ( pk INT(11) )
- RETURNS TINYINT(1)
- {$sqlFunBody}
- ");
- }
- }
- } catch (Exception $e) {
- UI::alert('danger', "Error #" . $e->getCode() . "|" . $e->getLine() . ": " . $e->getMessage());
- DBG::log($e);
- }
- UI::endContainer();
- UI::dol();
- }
- public function activateObjectAjaxAction() {
- DBG::log($_REQUEST, 'array', '$_REQUEST');
- Response::sendTryCatchJson(array($this, 'activateObjectAjax'), $_REQUEST);
- }
- public function activateObjectAjax($args) {
- $namespace = V::get('namespace', '', $args);
- if (empty($namespace)) throw new Exception("Missing param namespace");
- $item = SchemaFactory::loadDefaultObject('SystemObject')->getItem($namespace, [ 'propertyName' => '*,field' ]);
- if (empty($item)) throw new HttpException("Namespace not found", 404);
- DBG::log($item, 'array', "TODO: activateObjectAjax \$item");
- if ($item['isObjectActive']) throw new AlertSuccessException("Namespace '{$namespace}' already active");
- if (!$item['hasStruct']) throw new Exception("Missing struct for namespace '{$namespace}'");
- if (!$item['isStructInstalled']) throw new Exception("Namespace struct not installed '{$namespace}'");
- $activeFields = array_filter($item['field'], function ($field) {
- if (!$field['isActive']) return false;
- if (!$field['idZasob']) return false;
- return true;
- });
- if (empty($activeFields)) throw new Exception("Missing active fields for namespace '{$namespace}'");
- $affected = SchemaFactory::loadDefaultObject('SystemObject')->updateItem([
- 'namespace' => $item['namespace'],
- 'isObjectActive' => 1
- ]);
- if ($affected < 0) throw new Exception("Nie udało się aktywować obiektu '{$namespace}'");
- return [
- 'type' => "success",
- 'msg' => "Aktywowano obiekt '{$namespace}'",
- 'body' => [
- 'isObjectActive' => 1
- ]
- ];
- }
- }
|