WmsGenerate.php 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884
  1. <?php
  2. Lib::loadClass('RouteBase');
  3. Lib::loadClass('FoldersConfig');
  4. Lib::loadClass('FileUploader');
  5. Lib::loadClass('ProcesHelper');
  6. class Route_UrlAction_WmsGenerate extends RouteBase {
  7. public function handleAuth() {
  8. if (!User::logged()) {
  9. throw new HttpException('Unauthorized', 401);
  10. }
  11. }
  12. private function getDirectory($table,$id) {
  13. $folderConf = FoldersConfig::getAll($table.'_COLUMN');
  14. $record=new stdClass;
  15. $record->ID=$id;
  16. $uploader = new FileUploader($table.'_COLUMN', $record);
  17. $errMsg="";
  18. if (!$uploader->setConfig($folderConf, $errMsg)) throw new HttpException("Błąd danych konfiguracyjnych" . '<br>' . "\n" . $errMsg, 404);
  19. $uploader->findFolder();
  20. return $uploader->getDestLocalPath(true);
  21. }
  22. private function getMainDirectory() {
  23. $folderConf = FoldersConfig::getAll('WMS_LAYERS_COLUMN');
  24. if (!isset($folderConf['mount_point'])) throw new HttpException("Błąd danych konfiguracyjnych" . '<br>' . "\n" . $errMsg, 404);
  25. return $folderConf['mount_point'];
  26. }
  27. private function defaultAction_WMS_LAYERS($ID_WMS_LAYERS,$REFERER) {
  28. try {
  29. $layer=DB::getPDO()->fetchall("select LAYER_TYPE,FILE_STATUS from WMS_LAYERS where ID='".$ID_WMS_LAYERS."'");
  30. if (!$layer) throw new Exception('Błąd - nie ma takiej warstwy!');
  31. if ($layer[0]['FILE_STATUS']=="IN_PROGRESS") throw new Exception('Błąd - plik w trakcie przetwarzania!');
  32. $destFolderPath = $this->getDirectory('WMS_LAYERS',$ID_WMS_LAYERS);
  33. $files=array();
  34. if ($layer[0]['LAYER_TYPE']=='GeoTIFF') {
  35. foreach (glob($destFolderPath."/*.tif",GLOB_BRACE) as $node) {
  36. if (is_file($node)) $files[]=basename($node);
  37. }
  38. if (count($files)==0) throw new Exception('Nie znaleziono żadnego pliku tif!');
  39. if (count($files)>1) throw new Exception('Znaleziono zbyt dużo plików tif!');
  40. $validateGeoTifJson=shell_exec("/opt/local/bin/gdalinfo -json ".$destFolderPath."/*".$files[0]." 2>/dev/null");
  41. $validateGeoTif=json_decode($validateGeoTifJson);
  42. if (!$validateGeoTif) throw new Exception('Znaleziony plik '.$files[0].' nie jest poprawnym plikiem tif!');
  43. if (!$validateGeoTif->coordinateSystem->wkt) throw new Exception('Znaleziony plik '.$files[0].' nie jest poprawnym plikiem GeoTif!');
  44. } elseif ($layer[0]['LAYER_TYPE']=='QGIS') {
  45. foreach (glob($destFolderPath."/*.qgs",GLOB_BRACE) as $node) {
  46. if (is_file($node)) $files[]=basename($node);
  47. }
  48. if (count($files)==0) throw new Exception('Nie znaleziono żadnego pliku qgs!');
  49. if (count($files)>1) throw new Exception('Znaleziono zbyt dużo plików qgs!');
  50. $validateXml=simplexml_load_file($destFolderPath."/".$files[0]);
  51. if (!$validateXml) throw new Exception('Znaleziony plik '.$destFolderPath.'/'.$files[0].' nie jest poprawnym plikiem qgs!');
  52. if (!$validateXml->mapcanvas->destinationsrs->spatialrefsys->srid) throw new Exception('Znaleziony plik '.$files[0].' nie jest poprawnym plikiem projektu QGIS!');
  53. $DataSources=$validateXml->xpath('/qgis/projectlayers/maplayer/datasource');
  54. if (!$DataSources) throw new Exception('Plik projektu QGIS nie zawiera żadnej warstwy!');
  55. $suffixes=array('.shp','.dbf','.shx');
  56. $filesToCopy=array($files[0]);
  57. $missingFiles=array();
  58. foreach ($DataSources as $DataSource) {
  59. $DataSourceArr=explode('|',$DataSource);
  60. $DataSource=$DataSourceArr[0];
  61. $pathinfo = pathinfo($DataSource);
  62. if (in_array($pathinfo['extension'], array("tif","tiff","TIF","TIFF"))) {
  63. $filesToCopy[] = basename($DataSource);
  64. } else {
  65. $file=basename($DataSource,".shp");
  66. foreach ($suffixes as $suffix) {
  67. if(is_file($destFolderPath."/".$file.$suffix)) $filesToCopy[]=$file.$suffix;
  68. else $missingFiles[]=$file.$suffix;
  69. }
  70. }
  71. }
  72. if ($missingFiles) throw new Exception('Nie znaleziono poniższych plików wymaganych przez plik projetku QGIS:<br/>'.implode('<br/>',$missingFiles));
  73. if (is_dir($destFolderPath.'/.wms')) shell_exec('rm -rf '.$destFolderPath.'/.wms');
  74. mkdir($destFolderPath.'/.wms');
  75. foreach ($filesToCopy as $file) copy($destFolderPath."/".$file,$destFolderPath."/.wms/".$file);
  76. } else throw new Exception('Nieznany typ warstwy!');
  77. $sqlObj = new stdClass();
  78. $sqlObj->ID = $ID_WMS_LAYERS;
  79. $sqlObj->FILE_STATUS='TO_GENERATE';
  80. $sqlObj->FILE_STATUS_INFO='Plik oczekuje na przetworzenie';
  81. $sqlObj->FILE_NAME=$files[0];
  82. $sqlObj->OLD_LAYER_TYPE=$layer[0]['LAYER_TYPE'];
  83. $affected = DB::getDB()->UPDATE_OBJ('WMS_LAYERS', $sqlObj);
  84. if ($affected) SE_Layout::alert('success','Oznaczono plik '.$files[0].' do przetworzenia.');
  85. else SE_Layout::alert('warning','Plik '.$files[0].' został już wcześniej oznaczony do przetworzenia.');
  86. } catch (Exception $e) {
  87. SE_Layout::alert('danger',$e->getMessage());
  88. }
  89. ?>
  90. <div class="container" style="text-align:center">
  91. <a href="<?php echo $REFERER?>" class="btn btn-primary">Powrót</a>
  92. </div>
  93. <?php
  94. }
  95. private function defaultAction_WMS_MAPS($ID_WMS_MAPS,$REFERER) {
  96. try {
  97. $affected = DB::getDB()->UPDATE_OBJ('WMS_MAPS',(object) array('ID'=>$ID_WMS_MAPS,'MAP_STATUS'=>'TO_GENERATE','MAP_STATUS_INFO'=>'Mapa oczekuje na przetworzenie'));
  98. if ($affected) SE_Layout::alert('success','Oznaczono mapę do ponownego wygenerowania.');
  99. else SE_Layout::alert('warning','Mapa została już wcześniej oznaczona do ponownego wygenerowania.');
  100. } catch (Exception $e) {
  101. SE_Layout::alert('danger',$e->getMessage());
  102. }
  103. ?>
  104. <div class="container" style="text-align:center">
  105. <a href="<?php echo $REFERER?>" class="btn btn-primary">Powrót</a>
  106. </div>
  107. <?php
  108. }
  109. private function defaultAction_WIZJE_LOKALNE($ID_WIZJE_LOKALNE,$REFERER) {
  110. try {
  111. $wizje=DB::getPDO()->fetchall("select WMS_LAYER_ID,LAYER_NAME from WIZJE_LOKALNE where ID='".$ID_WIZJE_LOKALNE."'");
  112. if (!$wizje) throw new Exception("Błąd danych");
  113. $displayForm=true;
  114. $dirWizja=$this->getDirectory('WIZJE_LOKALNE',$ID_WIZJE_LOKALNE);
  115. exec('find '.$dirWizja.' -type f -name "*.tif" 2>/dev/null',$files);
  116. if (!$files) {
  117. SE_Layout::alert('danger',"Wybrana wizja lokalna nie zawiera żadnych plików GeoTIFF!");
  118. ?>
  119. <div class="container" style="text-align:center">
  120. <a href="<?php echo $REFERER?>" class="btn btn-primary">Powrót</a>
  121. </div>
  122. <?php
  123. $displayForm=false;
  124. } else {
  125. $ID_WMS_LAYERS=V::get('ID_WMS_LAYERS',0,$_POST,'int');
  126. $form_file=V::get('file','',$_POST);
  127. $form_ID_WMS_MAPS=V::get('ID_WMS_MAPS',0,$_POST,'int');
  128. if ($ID_WMS_LAYERS!=0) {
  129. if ($form_file=='') SE_Layout::alert('danger','Nie wybrano żadnego pliku!');
  130. else {
  131. $displayForm=false;
  132. $resMsg="";
  133. if ($ID_WMS_LAYERS==-1) {
  134. $ID_WMS_LAYERS=DB::getDB()->ADD_NEW_OBJ('WMS_LAYERS',(object) array('LAYER_NAME'=>$wizje[0]['LAYER_NAME'],'LAYER_TYPE'=>'GeoTIFF','ID_WMS_MAPS'=>$form_ID_WMS_MAPS));
  135. $resMsg.="Utworzono nową warstwę WMS - ID ".$ID_WMS_LAYERS."<br/>\n";
  136. }
  137. $WmsLayerDir=$this->getDirectory('WMS_LAYERS',$ID_WMS_LAYERS);
  138. if (!file_exists($WmsLayerDir)) @mkdir($WmsLayerDir);
  139. if (!is_dir($WmsLayerDir)) {
  140. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$ID_WMS_LAYERS,'FILE_STATUS_INFO'=>'Nie można utworzyć katalogu warstwy'));
  141. throw new Exception("Wystąpił nieoczekiwany błąd - nie można utworzyć katalogu ".$WmsLayerDir);
  142. }
  143. @chmod($WmsLayerDir, 0777);
  144. exec("rm -f ".$WmsLayerDir."/*.tif 2>/dev/null");
  145. symlink($form_file,$WmsLayerDir."/".basename($form_file));
  146. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$ID_WMS_LAYERS,'FILE_STATUS_INFO'=>'Utoworzono link symboliczny z poziomu tabeli WIZJE_LOKALNE'));
  147. $sqlObj = new stdClass();
  148. $sqlObj->ID = $ID_WIZJE_LOKALNE;
  149. $sqlObj->WMS_LAYER_UPLOADED='Y';
  150. $sqlObj->WMS_LAYER_ID=$ID_WMS_LAYERS;
  151. if (V::get('WIZJE_LOKALNE_OFF_HARD',0,$_POST,'int')==1) $sqlObj->A_STATUS='OFF_HARD';
  152. DB::getDB()->UPDATE_OBJ('WIZJE_LOKALNE', $sqlObj);
  153. SE_Layout::alert('success',$resMsg.'Pomyślnie dodano plik GeoTIFF do warstwy.');
  154. $WmsLayerTableZasobId=ProcesHelper::getZasobTableID('WMS_LAYERS');
  155. $editWmsLayerUrl="index.php?MENU_INIT=VIEWTABLE_AJAX&ZASOB_ID=".$WmsLayerTableZasobId."#EDIT/".$ID_WMS_LAYERS;
  156. ?>
  157. <div class="container" style="text-align:center">
  158. <a href="<?php echo $editWmsLayerUrl?>" class="btn btn-primary">Edytuj warstwę WMS</a>
  159. <a href="<?php echo $REFERER?>" class="btn btn-default">Powrót</a>
  160. </div>
  161. <?php
  162. }
  163. }
  164. elseif ($_POST) {
  165. $msgErr='Nie wybrano żadnej warstwy!';
  166. if (!$form_file) $msgErr.="<br/>Nie wybrano żadnego pliku!";
  167. SE_Layout::alert('danger',$msgErr);
  168. }
  169. }
  170. if ($displayForm) {
  171. if ($wizje[0]['WMS_LAYER_ID']) {
  172. $layers=DB::getPDO()->fetchall("select l.LAYER_NAME,l.LAYER_TYPE,l.ID_WMS_MAPS,m.MAP_NAME from WMS_LAYERS l left join WMS_MAPS m on l.ID_WMS_MAPS=m.ID where l.ID='".$wizje[0]['WMS_LAYER_ID']."'");
  173. if ($layers[0]['LAYER_TYPE']!="GeoTIFF") throw new Exception("Niespójny typ wartstwy - należy zmienić typ warstwy ID ".$wizje[0]['WMS_LAYER_ID']." na GeoTIFF");
  174. $LAYER_NAME=$layers[0]['LAYER_NAME'];
  175. if (!$LAYER_NAME) $LAYER_NAME="Brak nazwy warstwy";
  176. $ID_WMS_MAPS=$layers[0]['ID_WMS_MAPS'];
  177. $MAP_NAME=$layers[0]['MAP_NAME'];
  178. if ($ID_WMS_MAPS && !$MAP_NAME) $MAP_NAME="Brak nazwy mapy";
  179. }
  180. if (!$wizje) throw new Exception("Błędne ID z tabeli WIZJE_LOKALNE");
  181. ?>
  182. <div class="container" style="margin-top:20px">
  183. <form class="form-horizontal" method="post">
  184. <legend>Dodawanie pliku GeoTIFF do wartstwy WMS</legend>
  185. <div class="form-group">
  186. <label class="col-sm-1 control-label">Warstwa</label>
  187. <div class="col-sm-11">
  188. <?php
  189. if ($wizje[0]['WMS_LAYER_ID']) echo '<p class="form-control-static">'.$wizje[0]['WMS_LAYER_ID'].": ".$LAYER_NAME.'</p><p style="color:red;">Uwaga! Ten rekord wizji lokalnej został już powiazany z daną warstwą i nie ma możliwości zmiany powiązania.<br/>Ponowne dodanie pliku GeoTIFF spowoduje usunięcie dotychczasowego pliku GeoTIFF z danej warstwy.</p>'."\n".'<input type="hidden" name="ID_WMS_LAYERS" value="'.$wizje[0]['WMS_LAYER_ID'].'"/>'."\n";
  190. else {
  191. ?>
  192. <select id="warstwa" class="form-control" name="ID_WMS_LAYERS">
  193. <option value="-1">(Utwórz nową warstwę) <?php echo $wizje[0]['LAYER_NAME']?></option>
  194. <?php
  195. $layers=DB::getPDO()->fetchall("select ID,LAYER_NAME,ID_WMS_MAPS from WMS_LAYERS where LAYER_TYPE='GeoTIFF' and A_STATUS='WAITING'");
  196. foreach ($layers as $layer) echo '<option value="'.$layer['ID'].'" data-map_id="'.$layer['ID_WMS_MAPS'].'"'.($layer['ID']==$ID_WMS_LAYERS?" selected":"").'>(Oczekująca warstwa) '.$layer['ID'].': '.$layer['LAYER_NAME']."</option>\n";
  197. }
  198. ?>
  199. </select>
  200. </div>
  201. </div>
  202. <div class="form-group">
  203. <label class="col-sm-1 control-label">Mapa</label>
  204. <div class="col-sm-11">
  205. <?php
  206. if ($wizje[0]['WMS_LAYER_ID']) echo '<p class="form-control-static">'.(($ID_WMS_MAPS)?$ID_WMS_MAPS.": ".$MAP_NAME:'Brak').'</p>';
  207. else {
  208. ?>
  209. <select id="mapa" class="form-control" name="ID_WMS_MAPS">
  210. <option value="0">Brak</option>
  211. <?php
  212. $maps=DB::getPDO()->fetchall("select ID,MAP_NAME from WMS_MAPS");
  213. foreach ($maps as $map) echo '<option value="'.$map['ID'].'"'.($map['ID']==$form_ID_WMS_MAPS?" selected":"").">".$map['ID'].': '.$map['MAP_NAME']."</option>\n";
  214. }
  215. ?>
  216. </select>
  217. </div>
  218. </div>
  219. <div class="form-group">
  220. <label class="col-sm-1 control-label">Status wizji lokalnej</label>
  221. <div class="col-sm-11">
  222. <label class="checkbox-inline">
  223. <input type="checkbox" name="WIZJE_LOKALNE_OFF_HARD" value="1" checked> Ustaw automatycznie status wizji lokalnej na OFF_HARD
  224. </label>
  225. </div>
  226. </div>
  227. <div class="form-group">
  228. <label class="col-sm-1 control-label">Plik</label>
  229. <div class="col-sm-11" style="max-height:400px; overflow:auto;">
  230. <table class="table table-bordered table-hover">
  231. <thead>
  232. <tr style="text-align:center;"><td width="1"></td><td>Ścieżka/nazwa</td><td width="1">Wielkość</td><td width="1">Data</td></tr>
  233. </thead>
  234. <tbody>
  235. <?php
  236. foreach ($files as $file)
  237. echo '<tr><td><input style="margin:0; position:relative;" type="radio" name="file" value="'.$file.'"'.(($file==$form_file)?' checked':'').'/></td><td>'.substr($file,strlen($dirWizja)+1).'</td><td style="text-align:right;" nowrap>'.V::humanFileSize(filesize($file))."</td><td nowrap>".date("Y-m-d H:i:s",filectime($file))."</td></tr>\n";
  238. ?>
  239. </tbody>
  240. </table>
  241. </div>
  242. </div>
  243. <div class="form-group">
  244. <div class="col-sm-offset-1 col-sm-11">
  245. <button type="submit" class="btn btn-primary">Zapisz</button>
  246. <a href="<?php echo $REFERER?>" class="btn btn-default">Anuluj</a>
  247. </div>
  248. </div>
  249. <input type="hidden" name="WMS_REFERER" value="<?php echo $REFERER?>"/>
  250. </form>
  251. </div>
  252. <script>
  253. $('#warstwa').selectize({
  254. create: false,
  255. openOnFocus: false
  256. });
  257. $('#mapa').selectize({
  258. create: false,
  259. openOnFocus: false
  260. });
  261. </script>
  262. <?php
  263. }
  264. } catch (Exception $e) {
  265. SE_Layout::alert('danger',$e->getMessage());
  266. }
  267. }
  268. public function defaultAction() {
  269. SE_Layout::gora();
  270. SE_Layout::menu();
  271. if (V::get('WMS_REFERER','',$_POST)!='') $REFERER=V::get('WMS_REFERER','',$_POST);
  272. else $REFERER=$_SERVER['HTTP_REFERER'];
  273. if (V::get('ID_WMS_LAYERS',0,$_GET,'int')>0) $this->defaultAction_WMS_LAYERS(V::get('ID_WMS_LAYERS',0,$_GET,'int'),$REFERER);
  274. elseif (V::get('ID_WMS_MAPS',0,$_GET,'int')>0) $this->defaultAction_WMS_MAPS(V::get('ID_WMS_MAPS',0,$_GET,'int'),$REFERER);
  275. elseif (V::get('ID_WIZJE_LOKALNE',0,$_GET,'int')>0) $this->defaultAction_WIZJE_LOKALNE(V::get('ID_WIZJE_LOKALNE',0,$_GET,'int'),$REFERER);
  276. else SE_Layout::alert('danger','Błąd parametru');
  277. SE_Layout::dol();
  278. }
  279. public function doGenerate() {
  280. try {
  281. ### Ustawiamy zmienną sesji nazwy użytkownika, aby w rekordach historycznych było widać, że autorem systemu jest moduł WmsGenerate
  282. $_SESSION['ADM_ACCOUNT']="WmsGenerate";
  283. ### Sprawdzenie czy modul WMS jest aktywny na danej instalacji Procesy5
  284. $moduleActive=DB::getPDO()->fetchall("select count(*) as cnt from CRM_CONFIG where CONF_KEY='module_WMS' and CONF_VAL='on'");
  285. if (!$moduleActive[0]['cnt']) throw new Exception("Module WMS disabled/not installed.");
  286. ### Utworzenie niezbędnych katalogów i plików
  287. $wmsDirLocation=$this->getMainDirectory();
  288. if (!file_exists($wmsDirLocation.'/.maps/.single')) mkdir($wmsDirLocation.'/.maps/.single',0755,true);
  289. if (!file_exists($wmsDirLocation.'/.maps/.single')) throw new Exception('Error during creating maps directory.');
  290. if (!file_exists($wmsDirLocation.'/.maps/.template.html')) file_put_contents($wmsDirLocation.'/.maps/.template.html','');
  291. ### Tablica rozszerzeń plików warstw
  292. $mapFileSuffix=array('GeoTIFF'=>'.map','QGIS'=>'.qgs');
  293. ### Definicja tablicy przechowującej numery map do wygenerowania
  294. $mapsToGenerate=Array();
  295. ### Weryfikacja zmiany typu warstwy
  296. $layers=DB::getPDO()->fetchall("select ID,OLD_LAYER_TYPE from WMS_LAYERS where LAYER_TYPE!=OLD_LAYER_TYPE AND (MAP_STATUS='ACTIVE' or FILE_STATUS in ('TO_GENERATE','IN_PROGRESS'))");
  297. foreach ($layers as $layer) DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$layer['ID'],'LAYER_TYPE'=>$layer['OLD_LAYER_TYPE']));
  298. ### Przetworzenie projektów QGIS
  299. $layers=DB::getPDO()->fetchall("select ID,FILE_NAME,LAYER_NAME,A_STATUS,ID_WMS_MAPS from WMS_LAYERS where LAYER_TYPE='QGIS' and FILE_STATUS='TO_GENERATE'");
  300. foreach ($layers as $layer) {
  301. $destFolderPath = $this->getDirectory('WMS_LAYERS',$layer['ID']);
  302. if(!is_file($destFolderPath.'/'.$layer['FILE_NAME'])) {
  303. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$layer['ID'],'FILE_STATUS'=>'ERROR','FILE_STATUS_INFO'=>'Wystąpił błąd pliku qgs'));
  304. throw new Exception("Błąd pliku: ".$layer['FILE_NAME']);
  305. }
  306. $xml=simplexml_load_file($destFolderPath.'/.wms/'.$layer['FILE_NAME']);
  307. if (!$xml) {
  308. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$layer['ID'],'FILE_STATUS'=>'ERROR','FILE_STATUS_INFO'=>'Wystąpił błąd pliku qgs'));
  309. throw new Exception("Błąd pliku: ".$layer['FILE_NAME']);
  310. }
  311. $extents=array();
  312. $mapLayers=$xml->xpath('/qgis/projectlayers/maplayer');
  313. foreach ($mapLayers as $mapLayer) {
  314. $dataSourceArr=explode('|',$mapLayer->datasource);
  315. $dataSourceArr[0]=$destFolderPath.'/.wms/'.basename($dataSourceArr[0]);
  316. $dataSource=implode('|',$dataSourceArr);
  317. $mapLayer->datasource=$dataSource;
  318. //$mapLayer->datasource=$destFolderPath.'/.wms/'.basename($mapLayer->datasource);
  319. $bash='
  320. tmp=`mktemp -d`
  321. /opt/local/bin/ogr2ogr -s_srs EPSG:'.$mapLayer->srs->spatialrefsys->srid.' -t_srs EPSG:4326 "$tmp/tmp.shp" "'.$mapLayer->datasource.'" >/dev/null 2>&1
  322. extent=`/opt/local/bin/ogrinfo -al -so "$tmp/tmp.shp" | grep Extent | sed "s/[(),\-]//g;s/ / /g;s/Extent: //g"`
  323. echo "${extent} "
  324. rm -rf $tmp
  325. ';
  326. $extent=explode(" ",shell_exec($bash));
  327. $extents['xmin'][]=$extent[0];
  328. $extents['ymin'][]=$extent[1];
  329. $extents['xmax'][]=$extent[2];
  330. $extents['ymax'][]=$extent[3];
  331. }
  332. $xmin=min($extents['xmin']);
  333. $ymin=min($extents['ymin']);
  334. $xmax=max($extents['xmax']);
  335. $ymax=max($extents['ymax']);
  336. $geom="POLYGON(({$xmin} {$ymax},{$xmax} {$ymax},{$xmax} {$ymin},{$xmin} {$ymin},{$xmin} {$ymax}))";
  337. if ($layer['LAYER_NAME']) $LAYER_NAME=V::convert($layer['LAYER_NAME'],'url');
  338. else $LAYER_NAME="QGIS_".$layer['ID'];
  339. $xml->properties->WMSRootName=$LAYER_NAME;
  340. $xml->properties->WMSRootName->addAttribute('type','QString');
  341. $xml->properties->WMSServiceTitle=$LAYER_NAME;
  342. $xml->properties->WMSServiceTitle->addAttribute('type','QString');
  343. $xml->properties->WMSServiceCapabilities="true";
  344. $xml->properties->WMSServiceCapabilities->addAttribute('type','bool');
  345. $xml->properties->WMSAddWktGeometry="true";
  346. $xml->properties->WMSAddWktGeometry->addAttribute('type','bool');
  347. $xml->properties->Paths->Absolute="true";
  348. $xml->properties->WMSUrl="http://127.0.0.1:34580/wms/qgis/".$layer['ID'];
  349. $xml->properties->WMSUrl->addAttribute('type','QString');
  350. $epsg=$xml->mapcanvas->destinationsrs->spatialrefsys->srid;
  351. $extent=implode(" ",(array) $xml->mapcanvas->extent);
  352. $xml->asXml($destFolderPath.'/.wms/wms.qgs');
  353. unlink($destFolderPath.'/.wms/'.$layer['FILE_NAME']);
  354. $sqlArr=array('ID'=>$layer['ID'],'FILE_STATUS'=>'GENERATED','FILE_STATUS_INFO'=>'Plik przetworzony poprawnie','the_geom'=>"GeomFromText('{$geom}')",'EPSG'=>"{$epsg}",'EXTENT'=>"{$extent}");
  355. if ($layer['A_STATUS']=="WAITING") $sqlArr['A_STATUS']='NORMAL';
  356. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) $sqlArr);
  357. if ($layer['A_STATUS']=='WAITING' || $layer['A_STATUS']=='NORMAL') $mapsToGenerate[$layer['ID_WMS_MAPS']]=1;
  358. }
  359. ### Znalezienie nowo przetworzonych warstw GeoTIFF i utworzenie pojedynczych map do mapserver
  360. $mapSchema='MAP
  361. NAME "__NAME__"
  362. STATUS ON
  363. SIZE 400 300
  364. EXTENT __EXTENT__
  365. UNITS METERS
  366. IMAGECOLOR 255 255 0
  367. IMAGETYPE PNG
  368. WEB
  369. METADATA
  370. WMS_TITLE "__NAME__"
  371. WMS_ENABLE_REQUEST "*"
  372. # WMS_ONLINERESOURCE "https://__SERVER_NAME__/wms/.single/__ID__"
  373. WMS_ONLINERESOURCE "http://127.0.0.1:34580/wms/.single/__ID__"
  374. WMS_SRS "EPSG:__EPSG__"
  375. END
  376. END
  377. PROJECTION
  378. "init=epsg:__EPSG__"
  379. END
  380. LAYER
  381. NAME "__NAME__"
  382. STATUS OFF
  383. TYPE RASTER
  384. DATA "__FILE__"
  385. EXTENT __EXTENT__
  386. PROJECTION
  387. "init=epsg:__EPSG__"
  388. END
  389. METADATA
  390. WMS_TITLE "__NAME__"
  391. WMS_SRS "EPSG:__EPSG__"
  392. WMS_EXTENT "__EXTENT__"
  393. END
  394. END
  395. END
  396. ';
  397. $search=array('__NAME__','__EXTENT__','__SERVER_NAME__','__ID__','__EPSG__','__FILE__');
  398. $layers=DB::getPDO()->fetchall("select ID,LAYER_NAME,EPSG,ID_WMS_MAPS,A_STATUS,FILE_NAME from WMS_LAYERS where LAYER_TYPE='GeoTIFF' and FILE_STATUS='IN_PROGRESS'");
  399. foreach ($layers as $layer) {
  400. if (!file_exists('/tmp/generate_wms-'.$layer['ID'].'.lock')) {
  401. unlink('/tmp/generate_wms-'.$layer['ID'].'.sh');
  402. $destFolderPath = $this->getDirectory('WMS_LAYERS',$layer['ID']);
  403. if (file_exists($destFolderPath.'/.wms/.completed')) {
  404. if (file_exists($destFolderPath.'/.wms/.error')) {
  405. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$layer['ID'],'FILE_STATUS'=>'ERROR','FILE_STATUS_INFO'=>'Wystąpił błąd przetwarzania, przekaż problem administratorowi systemu'));
  406. } elseif (!file_exists($destFolderPath.'/.wms/.data')) {
  407. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$layer['ID'],'FILE_STATUS'=>'TO_GENERATE','FILE_STATUS_INFO'=>'Wystąpił błąd przetwarzania, ale nastąpi kolejna próba jego przetworzenia'));
  408. } else {
  409. $data_arr=explode('|',file_get_contents($destFolderPath.'/.wms/.data'));
  410. unlink($destFolderPath.'/.wms/.data');
  411. $geom=$data_arr[0];
  412. $extent=$data_arr[1];
  413. if ($layer['LAYER_NAME']) $LAYER_NAME=V::convert($layer['LAYER_NAME'],'url');
  414. else $LAYER_NAME="GeoTIFF_".$layer['ID'];
  415. $replace=array($LAYER_NAME,$extent,$_SERVER['SERVER_NAME'],$layer['ID'],$layer['EPSG'],$destFolderPath.'/.wms/'.$layer['FILE_NAME']);
  416. $map = str_replace($search,$replace,$mapSchema);
  417. file_put_contents($destFolderPath.'/.wms/wms.map',$map);
  418. $sqlArr=array('ID'=>$layer['ID'],'FILE_STATUS'=>'GENERATED','FILE_STATUS_INFO'=>'Plik przetworzony poprawnie','the_geom'=>"GeomFromText('{$geom}')",'EXTENT'=>"{$extent}");
  419. if ($layer['A_STATUS']=="WAITING") $sqlArr['A_STATUS']='NORMAL';
  420. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) $sqlArr);
  421. unlink($destFolderPath.'/.wms/.completed');
  422. if ($layer['A_STATUS']=='WAITING' || $layer['A_STATUS']=='NORMAL') $mapsToGenerate[$layer['ID_WMS_MAPS']]=1;
  423. }
  424. } else {
  425. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$layer['ID'],'FILE_STATUS'=>'TO_GENERATE','FILE_STATUS_INFO'=>'Wystąpił błąd przetwarzania, ale nastąpi kolejna próba jego przetworzenia'));
  426. }
  427. }
  428. }
  429. ### Weryfikacja czy jakas aktywna warstwa nie zostala przesunieta do innej mapy
  430. $layers=DB::getPDO()->fetchall("select ID,ID_WMS_MAPS,OLD_ID_WMS_MAPS from WMS_LAYERS where MAP_STATUS='ACTIVE' and ID_WMS_MAPS!=OLD_ID_WMS_MAPS");
  431. foreach ($layers as $layer) {
  432. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$layer['ID'],'OLD_ID_WMS_MAPS'=>$layer['ID_WMS_MAPS']));
  433. $mapsToGenerate[$layer['ID_WMS_MAPS']]=1;
  434. $mapsToGenerate[$layer['OLD_ID_WMS_MAPS']]=1;
  435. }
  436. ### Aktywacja nieaktywnych warstw, ktore nalezy zaktywowac
  437. $layers=DB::getPDO()->fetchall("select ID,ID_WMS_MAPS,LAYER_TYPE,A_STATUS from WMS_LAYERS where A_STATUS='NORMAL' and FILE_STATUS='GENERATED' and MAP_STATUS='INACTIVE'");
  438. foreach ($layers as $layer) {
  439. if (!file_exists($wmsDirLocation.'/.maps/.single/'.$layer['ID'].$mapFileSuffix[$layer['LAYER_TYPE']])) {
  440. $destFolderPath = $this->getDirectory('WMS_LAYERS',$layer['ID']);
  441. symlink($destFolderPath.'/.wms/wms'.$mapFileSuffix[$layer['LAYER_TYPE']],$wmsDirLocation.'/.maps/.single/'.$layer['ID'].$mapFileSuffix[$layer['LAYER_TYPE']]);
  442. }
  443. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$layer['ID'],'MAP_STATUS'=>'ACTIVE'));
  444. $mapsToGenerate[$layer['ID_WMS_MAPS']]=1;
  445. }
  446. ### Dezaktywacja aktywnych warstw, ktore nalezy zdezaktywowac
  447. $layers=DB::getPDO()->fetchall("select ID,ID_WMS_MAPS,LAYER_TYPE from WMS_LAYERS where MAP_STATUS='ACTIVE' and (A_STATUS!='NORMAL' or FILE_STATUS!='GENERATED')");
  448. foreach ($layers as $layer) {
  449. if (is_link($wmsDirLocation.'/.maps/.single/'.$layer['ID'].$mapFileSuffix[$layer['LAYER_TYPE']])) $res=unlink($wmsDirLocation.'/.maps/.single/'.$layer['ID'].$mapFileSuffix[$layer['LAYER_TYPE']]);
  450. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$layer['ID'],'MAP_STATUS'=>'INACTIVE'));
  451. $mapsToGenerate[$layer['ID_WMS_MAPS']]=1;
  452. }
  453. ### Wyszukanie map do wygenerowania
  454. $maps=DB::getPDO()->fetchall("select ID from WMS_MAPS where MAP_STATUS='NONE' and A_STATUS='NORMAL'");
  455. foreach ($maps as $map) $mapsToGenerate[$map['ID']]=1;
  456. ### Oznaczenie map do generowania
  457. if ($mapsToGenerate) {
  458. foreach ($mapsToGenerate as $ID_WMS_MAPS => $x) {
  459. $mapsCount=DB::getPDO()->fetchall("select ID from WMS_MAPS where ID='".$ID_WMS_MAPS."' and A_STATUS='NORMAL'");
  460. if ($mapsCount) DB::getDB()->UPDATE_OBJ('WMS_MAPS',(object) array('ID'=>$ID_WMS_MAPS,'MAP_STATUS'=>'TO_GENERATE','MAP_STATUS_INFO'=>'Mapa oczekuje na przetworzenie'));
  461. }
  462. }
  463. ### Generowanie map
  464. $layerSchema['GeoTIFF']='
  465. LAYER
  466. NAME "__NAME__"
  467. STATUS OFF
  468. TYPE RASTER
  469. CONNECTION "http://127.0.0.1:34580/wms/__TYPE__/__ID__"
  470. CONNECTIONTYPE WMS
  471. EXTENT __EXTENT__
  472. PROJECTION
  473. "init=epsg:__EPSG__"
  474. END
  475. METADATA
  476. WMS_TITLE "__NAME__"
  477. WMS_SRS "EPSG:__EPSG__"
  478. WMS_EXTENT "__EXTENT__"
  479. WMS_NAME "__NAME__"
  480. WMS_FORMAT "image/png"
  481. WMS_SERVER_VERSION "1.1.1"
  482. END
  483. END
  484. ';
  485. $layerSchema['QGIS']='
  486. LAYER
  487. NAME "__NAME__"
  488. STATUS OFF
  489. TYPE RASTER
  490. CONNECTION "http://127.0.0.1:34580/wms/__TYPE__/__ID__"
  491. CONNECTIONTYPE WMS
  492. EXTENT __EXTENT__
  493. PROJECTION
  494. "init=epsg:__EPSG__"
  495. END
  496. CLASS
  497. TEMPLATE "__TEMPLATE__"
  498. END
  499. METADATA
  500. WMS_TITLE "__NAME__"
  501. WMS_SRS "EPSG:__EPSG__"
  502. WMS_EXTENT "__EXTENT__"
  503. WMS_NAME "__NAME__"
  504. WMS_FORMAT "image/png"
  505. WMS_SERVER_VERSION "1.1.1"
  506. END
  507. END
  508. ';
  509. $layerSearch=array('__NAME__','__TYPE__','__ID__','__EXTENT__','__EPSG__','__TEMPLATE__');
  510. $mapHeadSchema='MAP
  511. NAME "__NAME__"
  512. STATUS ON
  513. SIZE 400 300
  514. EXTENT -180 -90 180 90
  515. UNITS METERS
  516. IMAGECOLOR 255 255 0
  517. IMAGETYPE PNG
  518. WEB
  519. METADATA
  520. WMS_TITLE "__NAME__"
  521. WMS_ENABLE_REQUEST "*"
  522. WMS_ONLINERESOURCE "__MAP_URL__"
  523. WMS_SRS "__EPSGS__"
  524. END
  525. END
  526. PROJECTION
  527. "init=epsg:4326"
  528. END
  529. ';
  530. $mapHeadSearch=array('__NAME__','__MAP_URL__','__EPSGS__');
  531. $mapTailSchema='
  532. END
  533. ';
  534. $maps=DB::getPDO()->fetchall("select ID,MAP_NAME,MAP_FILE,MAP_URL from WMS_MAPS where MAP_STATUS='TO_GENERATE'");
  535. $urlLayerType=array('GeoTIFF'=>'.single','QGIS'=>'qgis');
  536. foreach ($maps as $map) {
  537. if ($map['MAP_FILE']) unlink($wmsDirLocation.'/.maps/'.$map['MAP_FILE']);
  538. $MAP_FILE=strtolower(V::convert($map['MAP_NAME'],'url'));
  539. if ($MAP_FILE=="") $MAP_FILE=$map['ID'];
  540. $MAP_URL='https://'.$_SERVER['SERVER_NAME'].'/wms/'.$MAP_FILE;
  541. $MAP_FILE.=".map";
  542. $otherMaps=DB::getPDO()->fetchall("select ID from WMS_MAPS where ID!='".$map['ID']."' and MAP_FILE='".$MAP_FILE."'");
  543. if ($otherMaps) {
  544. DB::getDB()->UPDATE_OBJ('WMS_MAPS',(object) array('ID'=>$map['ID'],'MAP_STATUS'=>'ERROR','MAP_STATUS_INFO'=>'Nieunikalna nazwa mapy','MAP_URL'=>'','MAP_FILE'=>''));
  545. } else {
  546. $layers=DB::getPDO()->fetchall("select ID,LAYER_NAME,FILE_NAME,EPSG,EXTENT,LAYER_TYPE from WMS_LAYERS where MAP_STATUS='ACTIVE' and ID_WMS_MAPS='".$map['ID']."'");
  547. $MAP_LAYERS="";
  548. foreach ($layers as $layer) {
  549. if ($layer['LAYER_NAME']) $LAYER_NAME=V::convert($layer['LAYER_NAME'],'url');
  550. else $LAYER_NAME=$layer['LAYER_TYPE']."_".$layer['ID'];
  551. $replace=array($LAYER_NAME,$urlLayerType[$layer['LAYER_TYPE']],$layer['ID'],$layer['EXTENT'],$layer['EPSG'],$wmsDirLocation.'/.maps/.template.html');
  552. $MAP_LAYERS .= str_replace($layerSearch,$replace,$layerSchema[$layer['LAYER_TYPE']]);
  553. $EPSGS['EPSG:'.$layer['EPSG']]=1;
  554. }
  555. $replace=array($map['MAP_NAME'],$MAP_URL,implode(" ",array_keys($EPSGS)));
  556. $MAP_TXT=str_replace($mapHeadSearch,$replace,$mapHeadSchema).$MAP_LAYERS.$mapTailSchema;
  557. file_put_contents($wmsDirLocation.'/.maps/'.$MAP_FILE,$MAP_TXT);
  558. DB::getDB()->UPDATE_OBJ('WMS_MAPS',(object) array('ID'=>$map['ID'],'MAP_STATUS'=>'GENERATED','MAP_STATUS_INFO'=>'Mapa wygenerowana poprawnie','MAP_URL'=>$MAP_URL,'MAP_FILE'=>$MAP_FILE));
  559. }
  560. }
  561. ### Usunięcie zbędnych map
  562. $maps=DB::getPDO()->fetchall("select ID,MAP_FILE from WMS_MAPS where MAP_STATUS='GENERATED' and A_STATUS!='NORMAL'");
  563. foreach ($maps as $map) {
  564. if (file_exists($wmsDirLocation.'/.maps/'.$map['MAP_FILE'])) unlink($wmsDirLocation.'/.maps/'.$map['MAP_FILE']);
  565. DB::getDB()->UPDATE_OBJ('WMS_MAPS',(object) array('ID'=>$map['ID'],'MAP_STATUS'=>'NONE','MAP_STATUS_INFO'=>'Mapa usunięta','MAP_URL'=>'','MAP_FILE'=>''));
  566. }
  567. ### Wygenerowanie plików tif warstw
  568. $bashSchema='
  569. rm -rf __PATH__/.wms
  570. mkdir __PATH__/.wms
  571. lock="/tmp/generate_wms-__ID__.lock"
  572. touch ${lock}
  573. /opt/local/bin/gdaltindex -t_srs epsg:4326 /tmp/generate_wms-__ID__-shp_wgs84.shp "__PATH__/__FILE__" >/dev/null 2>&1
  574. /opt/local/bin/ogr2ogr -f CSV /tmp/generate_wms-__ID__-shp_wgs84.csv /tmp/generate_wms-__ID__-shp_wgs84.shp -lco GEOMETRY=AS_WKT
  575. wgs84=`cat /tmp/generate_wms-__ID__-shp_wgs84.csv |tr -d "\n" | cut -d "\"" -f 2`
  576. /opt/local/bin/gdaltindex /tmp/generate_wms-__ID__-shp_orig.shp "__PATH__/__FILE__" >/dev/null 2>&1
  577. extent=`/opt/local/bin/ogrinfo -al -so /tmp/generate_wms-__ID__-shp_orig.shp | grep Extent | sed "s/[(),\-]//g;s/ / /g;s/Extent: //g"`
  578. rm -f /tmp/generate_wms-__ID__-shp_*
  579. echo "${wgs84}|${extent}|" > __PATH__/.wms/.data
  580. ok=0
  581. /opt/local/bin/gdal_translate -of GTiff -co "TILED=YES" -co "COMPRESS=DEFLATE" -co "ZLEVEL=9" -co "BIGTIFF=YES" "__PATH__/__FILE__" "__PATH__/.wms/__FILE__" && /opt/local/bin/gdaladdo -r average "__PATH__/.wms/__FILE__" 2 4 8 16 32 64 128 && ok=1
  582. rm -f ${lock}
  583. touch __PATH__/.wms/.completed
  584. if [ "$ok" -eq 1 ]; then
  585. echo "Successfully completed."
  586. else
  587. cp tmp/generate_wms-__ID__.log __PATH__/.wms/.error
  588. echo "Error creating tif file."
  589. fi
  590. ';
  591. $search=array('__ID__','__PATH__','__FILE__');
  592. $layers=DB::getPDO()->fetchall("select ID,FILE_NAME from WMS_LAYERS where LAYER_TYPE='GeoTIFF' and FILE_STATUS='TO_GENERATE'");
  593. foreach ($layers as $layer) {
  594. echo $layer['ID']."\n";
  595. $destFolderPath = $this->getDirectory('WMS_LAYERS',$layer['ID']);
  596. if(!is_file($destFolderPath.'/'.$layer['FILE_NAME'])) {
  597. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$layer['ID'],'FILE_STATUS'=>'ERROR','FILE_STATUS_INFO'=>'Wystąpił błąd pliku tif'));
  598. throw new Exception("Błąd pliku: ".$layer['FILE_NAME']);
  599. }
  600. $xml=@simplexml_load_string(shell_exec('/opt/local/bin/gdalsrsinfo -o xml '.$destFolderPath.'/'.$layer['FILE_NAME']));
  601. $epsg=$xml->{'gml:srsID'}->{'gml:name'};
  602. if (!$epsg) {
  603. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$layer['ID'],'FILE_STATUS'=>'ERROR','FILE_STATUS_INFO'=>'Wystąpił błąd pliku tif - brak informacji o układzie współrzędnych'));
  604. throw new Exception("Błąd pliku: ".$layer['FILE_NAME']);
  605. }
  606. DB::getDB()->UPDATE_OBJ('WMS_LAYERS',(object) array('ID'=>$layer['ID'],'FILE_STATUS'=>'IN_PROGRESS','FILE_STATUS_INFO'=>'Plik w trakcie przetwarzania','EPSG'=>$epsg));
  607. $replace = array($layer['ID'],$destFolderPath,$layer['FILE_NAME']);
  608. $bash = str_replace($search,$replace,$bashSchema);
  609. file_put_contents('/tmp/generate_wms-'.$layer['ID'].'.sh',$bash);
  610. shell_exec('su - root -c "/bin/sh /tmp/generate_wms-'.$layer['ID'].'.sh > /tmp/generate_wms-'.$layer['ID'].'.log 2>&1 &"');
  611. }
  612. } catch (Exception $e) {
  613. echo $e->getMessage()."\n";
  614. }
  615. }
  616. public function doGenerateAction() {
  617. $this->doGenerate();
  618. // echo "OK\n";
  619. }
  620. public function reinstallAction() {
  621. $this->reinstall();
  622. die('OK');
  623. }
  624. public function reinstall() {
  625. $sqlList = array();
  626. //$sqlList['RemoveTable'] = "DROP TABLE IF EXISTS `CRM_CONFIG`";
  627. $sqlList['InstallLayerTable'] = <<<SQL
  628. CREATE TABLE IF NOT EXISTS `WMS_LAYERS` (
  629. `ID` int(11) NOT NULL AUTO_INCREMENT,
  630. `the_geom` polygon NOT NULL,
  631. `ID_PROJECT` int(11) NOT NULL,
  632. `LAYER_NAME` varchar(100) NOT NULL,
  633. `LAYER_TYPE` enum('GeoTIFF','QGIS') NOT NULL DEFAULT 'GeoTIFF',
  634. `OLD_LAYER_TYPE` enum('GeoTIFF','QGIS') NOT NULL,
  635. `LAYER_DESC` text NOT NULL,
  636. `ID_WMS_MAPS` int(11) NOT NULL,
  637. `OLD_ID_WMS_MAPS` int(11) NOT NULL,
  638. `FILE_NAME` varchar(255) NOT NULL,
  639. `FILE_STATUS` enum('NONE','TO_GENERATE','IN_PROGRESS','GENERATED','ERROR') NOT NULL DEFAULT 'NONE',
  640. `FILE_STATUS_INFO` varchar(255) NOT NULL,
  641. `EPSG` int(11) NOT NULL,
  642. `EXTENT` varchar(100) NOT NULL,
  643. `MAP_STATUS` enum('ACTIVE','INACTIVE') NOT NULL DEFAULT 'INACTIVE',
  644. `FILE_MD5` varchar(32) NOT NULL,
  645. `A_RECORD_CREATE_DATE` datetime NOT NULL,
  646. `A_RECORD_CREATE_AUTHOR` varchar(40) NOT NULL,
  647. `A_RECORD_UPDATE_DATE` varchar(18) NOT NULL,
  648. `A_RECORD_UPDATE_AUTHOR` varchar(40) NOT NULL,
  649. `L_APPOITMENT_DATE` datetime NOT NULL,
  650. `L_APPOITMENT_USER` varchar(40) NOT NULL,
  651. `L_APPOITMENT_PERIOD` varchar(30) NOT NULL,
  652. `L_APPOITMENT_INFO` varchar(200) NOT NULL,
  653. `L_APPOITMENT_TYPE` enum('','ARRANGED','TO_ARRANGE','CANCELLED','TO_CANCEL','RELATE','WAIT') NOT NULL,
  654. `A_PROBLEM` enum('','WARNING','PROBLEM','SERIOUS','UNVERIFIED') NOT NULL,
  655. `A_PROBLEM_DESC` varchar(200) NOT NULL,
  656. `A_PROBLEM_DATE` datetime NOT NULL,
  657. `A_STATUS` enum('DELETED','MONITOR','NORMAL','OFF_HARD','OFF_SOFT','WAITING','WARNING') NOT NULL DEFAULT 'WAITING',
  658. `A_STATUS_INFO` varchar(100) NOT NULL,
  659. `A_STATUS_LASTCHANGE_DATE` datetime NOT NULL,
  660. `A_ADM_COMPANY` varchar(100) NOT NULL,
  661. `A_CLASSIFIED` varchar(100) NOT NULL,
  662. `SYNC_SQIX_STATUS` varchar(100) NOT NULL,
  663. PRIMARY KEY (`ID`)
  664. ) ENGINE=MyISAM DEFAULT CHARSET=latin2;
  665. SQL;
  666. $sqlList['InstallLayerHistTable'] = <<<SQL
  667. CREATE TABLE IF NOT EXISTS `WMS_LAYERS_HIST` (
  668. `ID` int(11) NOT NULL AUTO_INCREMENT,
  669. `ID_USERS2` int(11) NOT NULL,
  670. `the_geom` text,
  671. `ID_PROJECT` varchar(20) DEFAULT 'N/S;',
  672. `LAYER_NAME` varchar(100) DEFAULT 'N/S;',
  673. `LAYER_TYPE` varchar(10) DEFAULT 'N/S;',
  674. `OLD_LAYER_TYPE` varchar(10) DEFAULT 'N/S;',
  675. `LAYER_DESC` varchar(10000) DEFAULT 'N/S;',
  676. `ID_WMS_MAPS` varchar(20) DEFAULT 'N/S;',
  677. `OLD_ID_WMS_MAPS` varchar(20) DEFAULT 'N/S;',
  678. `FILE_NAME` varchar(255) DEFAULT 'N/S;',
  679. `FILE_STATUS` varchar(20) DEFAULT 'N/S;',
  680. `FILE_STATUS_INFO` varchar(255) DEFAULT 'N/S;',
  681. `EPSG` varchar(10) DEFAULT 'N/S;',
  682. `EXTENT` varchar(100) DEFAULT 'N/S;',
  683. `MAP_STATUS` varchar(20) DEFAULT 'N/S;',
  684. `FILE_MD5` varchar(32) DEFAULT 'N/S;',
  685. `A_RECORD_CREATE_DATE` varchar(30) DEFAULT 'N/S;',
  686. `A_RECORD_CREATE_AUTHOR` varchar(40) DEFAULT 'N/S;',
  687. `A_RECORD_UPDATE_DATE` varchar(18) DEFAULT 'N/S;',
  688. `A_RECORD_UPDATE_AUTHOR` varchar(40) DEFAULT 'N/S;',
  689. `L_APPOITMENT_DATE` varchar(30) DEFAULT 'N/S;',
  690. `L_APPOITMENT_USER` varchar(40) DEFAULT 'N/S;',
  691. `L_APPOITMENT_PERIOD` varchar(30) DEFAULT 'N/S;',
  692. `L_APPOITMENT_INFO` varchar(200) DEFAULT 'N/S;',
  693. `L_APPOITMENT_TYPE` varchar(255) DEFAULT 'N/S;',
  694. `A_PROBLEM` varchar(255) DEFAULT 'N/S;',
  695. `A_PROBLEM_DESC` varchar(200) DEFAULT 'N/S;',
  696. `A_PROBLEM_DATE` varchar(255) DEFAULT 'N/S;',
  697. `A_STATUS` varchar(255) DEFAULT 'N/S;',
  698. `A_STATUS_INFO` varchar(100) DEFAULT 'N/S;',
  699. `A_STATUS_LASTCHANGE_DATE` varchar(255) DEFAULT 'N/S;',
  700. `A_ADM_COMPANY` varchar(100) DEFAULT 'N/S;',
  701. `A_CLASSIFIED` varchar(100) DEFAULT 'N/S;',
  702. `SYNC_SQIX_STATUS` varchar(100) DEFAULT 'N/S;',
  703. PRIMARY KEY (`ID`)
  704. ) ENGINE=MyISAM DEFAULT CHARSET=latin2;
  705. SQL;
  706. $sqlList['InstallMapTable'] = <<<SQL
  707. CREATE TABLE IF NOT EXISTS `WMS_MAPS` (
  708. `ID` int(11) NOT NULL AUTO_INCREMENT,
  709. `MAP_NAME` varchar(100) NOT NULL,
  710. `MAP_DESC` text NOT NULL,
  711. `MAP_STATUS` enum('NONE','TO_GENERATE','IN_PROGRESS','GENERATED','ERROR') NOT NULL DEFAULT 'NONE',
  712. `MAP_STATUS_INFO` varchar(255) NOT NULL,
  713. `MAP_URL` varchar(100) NOT NULL,
  714. `MAP_FILE` varchar(100) NOT NULL,
  715. `A_RECORD_CREATE_DATE` datetime NOT NULL,
  716. `A_RECORD_CREATE_AUTHOR` varchar(40) NOT NULL,
  717. `A_RECORD_UPDATE_DATE` varchar(18) NOT NULL,
  718. `A_RECORD_UPDATE_AUTHOR` varchar(40) NOT NULL,
  719. `L_APPOITMENT_DATE` datetime NOT NULL,
  720. `L_APPOITMENT_USER` varchar(40) NOT NULL,
  721. `L_APPOITMENT_PERIOD` varchar(30) NOT NULL,
  722. `L_APPOITMENT_INFO` varchar(200) NOT NULL,
  723. `L_APPOITMENT_TYPE` enum('','ARRANGED','TO_ARRANGE','CANCELLED','TO_CANCEL','RELATE','WAIT') NOT NULL,
  724. `A_PROBLEM` enum('','WARNING','PROBLEM','SERIOUS','UNVERIFIED') NOT NULL,
  725. `A_PROBLEM_DESC` varchar(200) NOT NULL,
  726. `A_PROBLEM_DATE` datetime NOT NULL,
  727. `A_STATUS` enum('DELETED','MONITOR','NORMAL','OFF_HARD','OFF_SOFT','WAITING','WARNING') NOT NULL DEFAULT 'WAITING',
  728. `A_STATUS_INFO` varchar(100) NOT NULL,
  729. `A_STATUS_LASTCHANGE_DATE` datetime NOT NULL,
  730. `A_ADM_COMPANY` varchar(100) NOT NULL,
  731. `A_CLASSIFIED` varchar(100) NOT NULL,
  732. `SYNC_SQIX_STATUS` varchar(100) NOT NULL,
  733. PRIMARY KEY (`ID`)
  734. ) ENGINE=MyISAM DEFAULT CHARSET=latin2;
  735. SQL;
  736. $sqlList['InstallMapHistTable'] = <<<SQL
  737. CREATE TABLE IF NOT EXISTS `WMS_MAPS_HIST` (
  738. `ID` int(11) NOT NULL AUTO_INCREMENT,
  739. `ID_USERS2` int(11) NOT NULL,
  740. `MAP_NAME` varchar(100) DEFAULT 'N/S;',
  741. `MAP_DESC` varchar(10000) NOT NULL DEFAULT 'N/S;',
  742. `MAP_STATUS` varchar(20) NOT NULL DEFAULT 'N/S;',
  743. `MAP_STATUS_INFO` varchar(255) NOT NULL DEFAULT 'N/S;',
  744. `MAP_URL` varchar(100) NOT NULL DEFAULT 'N/S;',
  745. `MAP_FILE` varchar(100) NOT NULL DEFAULT 'N/S;',
  746. `A_RECORD_CREATE_DATE` varchar(30) DEFAULT 'N/S;',
  747. `A_RECORD_CREATE_AUTHOR` varchar(40) DEFAULT 'N/S;',
  748. `A_RECORD_UPDATE_DATE` varchar(18) DEFAULT 'N/S;',
  749. `A_RECORD_UPDATE_AUTHOR` varchar(40) DEFAULT 'N/S;',
  750. `L_APPOITMENT_DATE` varchar(30) DEFAULT 'N/S;',
  751. `L_APPOITMENT_USER` varchar(40) DEFAULT 'N/S;',
  752. `L_APPOITMENT_PERIOD` varchar(30) DEFAULT 'N/S;',
  753. `L_APPOITMENT_INFO` varchar(200) DEFAULT 'N/S;',
  754. `L_APPOITMENT_TYPE` varchar(255) DEFAULT 'N/S;',
  755. `A_PROBLEM` varchar(255) DEFAULT 'N/S;',
  756. `A_PROBLEM_DESC` varchar(200) DEFAULT 'N/S;',
  757. `A_PROBLEM_DATE` varchar(255) DEFAULT 'N/S;',
  758. `A_STATUS` varchar(255) DEFAULT 'N/S;',
  759. `A_STATUS_INFO` varchar(100) DEFAULT 'N/S;',
  760. `A_STATUS_LASTCHANGE_DATE` varchar(255) DEFAULT 'N/S;',
  761. `A_ADM_COMPANY` varchar(100) DEFAULT 'N/S;',
  762. `A_CLASSIFIED` varchar(100) DEFAULT 'N/S;',
  763. `SYNC_SQIX_STATUS` varchar(100) DEFAULT 'N/S;',
  764. PRIMARY KEY (`ID`)
  765. ) ENGINE=MyISAM DEFAULT CHARSET=latin2;
  766. SQL;
  767. $sqlList['ActivateWms'] = <<<SQL
  768. REPLACE INTO `CRM_CONFIG` (`CONF_KEY`,`CONF_VAL`) VALUES ('module_WMS','on');
  769. SQL;
  770. $db = DB::getDB();
  771. if ($db->has_errors()) {
  772. throw new Exception("DB Errors: " . implode("\n<br>", $db->get_errors()));
  773. }
  774. foreach ($sqlList as $sqlName => $sql) {
  775. $res = $db->query($sql);
  776. if ($db->has_errors()) {
  777. throw new Exception("DB Errors at sql '{$sqlName}': " . implode("\n<br>", $db->get_errors()));
  778. }
  779. }
  780. }
  781. }