se/SE/se-lib/TableAjaxMap.php

<?php

/**
 * usage:
 * 
<script>
jQuery('#TreeTableMap').TableAjaxMap({
	wpsUrl: 'http://biuro.biall-net.pl/wps',
	wfsUrl: 'http://biuro.biall-net.pl/wps'
});
</script>
 * 
 */
class TableAjaxMap {

	private $_acl;
	private $_zasobID;
	private $_width;
	private $_height;

	public function __construct($tblAcl, $width = 512, $height = 256) {
		$this->_acl = $tblAcl;
		$this->_zasobID = $tblAcl->getID();
		$this->_width = $width;
		$this->_height = $height;
	}

	public function printCSS() {
// <link rel="stylesheet" href="stuff/open-layers/theme/default/style.css" type="text/css">
// <link rel="stylesheet" href="stuff/open-layers/style.css" type="text/css">
		?>
<style type="text/css">
.TableAjaxMap { width:100%; height:<?php echo $this->_height; ?>px; }
.olControlEditingToolbar .olControlModifyFeatureItemInactive { background-image:url(stuff/open-layers/theme/default/img/draw_point_off.png); }
.olControlEditingToolbar .olControlModifyFeatureItemActive   { background-image:url(stuff/open-layers/theme/default/img/draw_point_on.png); }
.olControlEditingToolbar .olControlRefreshItemInactive { background-image: url(stuff/open-layers/theme/default/img/refresh_feature_off.png); }
.olControlEditingToolbar .olControlRefreshItemActive { background-image: url(stuff/open-layers/theme/default/img/refresh_feature_on.png); }
.olControlLayerSwitcher .layersDiv { border-radius:10px 0 0 10px; opacity:0.75; filter:alpha(opacity=75); }
.notsupported { color:red; }
.TableAjaxMap .layersDiv input { margin:0; }
.TableAjaxMap .layersDiv label { display:inline; }
</style>
		<?php
	}

	public function printJS() {
		?>
<script src="stuff/open-layers/OpenLayers.js"></script>
<script>
OpenLayers.ProxyHost = "index-ajax.php?_zasobID=<?php echo $this->_zasobID; ?>&_cls=<?php echo __CLASS__; ?>&_task=PROXY&url=";

(function( $ ) {
	var TableAjaxMap = function() {
		var priv = {}; //private api
		var publ = {}; //public api

		priv.options = {};
		var defaults = {
			wpsUrl: '',
			wfsUrl: '',
			layerName: 'Warstwa rysowania',
			onfeatureselect: null,
			onfeatureunselect: null,
			debug: false
		};

		var _nodeMapId;
		var _nodeMap;
		var _nodeProcesses;
		var _nodeAbstract;
		var _nodeInput;
		var _nodeOutput;
		var _capabilities;
		var _process;
		var _layer;
		var _map;

		/*
		 initialize the plugin.
		 */
		priv.init = function() {
			console.log('test jQuery plugin init...', priv);
			// create dom:
			/*
				<div id="map" class="TableAjaxMap"></div>

				<div>
						<select id="processes"><option>Select a process</option></select>
						<p id="abstract"></p>
						<div id="input"></div>
						<div id="output"></div>
				</div>
			 */
			_nodeMapId = 'Map-' + Math.random(1).toString().substr(2);
			_nodeMap = $('<div id="' + _nodeMapId + '" class="TableAjaxMap"></div>');
			_nodeProcesses = $('<select></select>');
			_nodeProcesses.append('<option>Wybierz funkcję</option>');
			_nodeAbstract = $('<p></p>');
			_nodeInput = $('<div></div>');
			_nodeOutput = $('<div></div>');
			var div = $('<div></div>');
			div.append(_nodeProcesses);
			div.append(_nodeAbstract);
			div.append(_nodeInput);
			div.append(_nodeOutput);
			$(priv.options.id).append(_nodeMap);
			$(priv.options.id).append(div);

			_nodeProcesses.on('change', function() {
				console.log("onchange this:", this, this.selectedIndex, this.options);
				var selection = this.options[this.selectedIndex].value;
				if (this.selectedIndex > 0) {
					OpenLayers.Request.GET({
						url: priv.options.wpsUrl,
						params: {
							"SERVICE": "WPS",
							"REQUEST": "DescribeProcess",
							"VERSION": _capabilities.version,
							"IDENTIFIER": selection
						},
						success: function(response) {
							_process = new OpenLayers.Format.WPSDescribeProcess().read(
								response.responseText
							).processDescriptions[selection];
							console.log("Process:", _process);
							priv.buildForm();
						}
					});
				}
			});
			priv.getCapabilities();

			_layer = new OpenLayers.Layer.Vector(priv.options.layerName, {
				strategies: [new OpenLayers.Strategy.BBOX()],
				projection: new OpenLayers.Projection("EPSG:900913"),
				protocol: new OpenLayers.Protocol.WFS({
					version: "1.1.0",
					srsName: "EPSG:900913",
					url: priv.options.wfsUrl,
					featureNS :  "http://opengeo.org",
					featureType: "restricted",
					geometryName: "the_geom",
					schema: "http://demo.opengeo.org/geoserver/wfs/DescribeFeatureType?version=1.1.0&typename=og:restricted"
				})
			});

			_layer.events.on({
				'featureselected': function(feature) {
					console.log('_layer onfeatureselect (',this.selectedFeatures.length,'): ', this);
					//document.getElementById('counter').innerHTML = this.selectedFeatures.length;
					if (typeof priv.options.onfeatureselect == "function") {
						priv.options.onfeatureselect.apply(this);
					}
				},
				'featureunselected': function(feature) {
					console.log('_layer onfeatureselect (',this.selectedFeatures.length,'): ', this);
					if (typeof priv.options.onfeatureunselect == "function") {
						priv.options.onfeatureunselect.apply(this);
					}
				}
			});

			var toolbar = new OpenLayers.Control.EditingToolbar(_layer);
			toolbar.addControls([new OpenLayers.Control.ModifyFeature(_layer, {
				title: "Select feature"
			})]);
			toolbar.addControls([
				new OpenLayers.Control.SelectFeature(_layer, {
					title: "Select Test",
					clickout: false,
					toggle: false,
					multiple: false,
					hover: false,
					toggleKey: "ctrlKey", // ctrl key removes from selection
					multipleKey: "shiftKey", // shift key adds to selection
					box: true
				})
			]);
			toolbar.addControls([
				new OpenLayers.Control.Button({
					title: "Zoom Test",
					displayClass: "olControlZoomToPoly",
					trigger: function() {
						var multiPolygon = OpenLayers.Geometry.fromWKT("MULTIPOLYGON(((2072016.74395199 7234076.79293037,2072016.74395199 7234115.01144451,2072131.3994944 7234115.01144451,2072131.3994944 7234076.79293037,2072016.74395199 7234076.79293037)))").getBounds();
						_map.zoomToExtent(multiPolygon);
					}
				})
			]);
			var btnRefresh = new OpenLayers.Control.Button({
				title: "Refresh",
				displayClass: "olControlRefresh",
				trigger: function() {
					_layer.refresh({force: true});
				}
			});
			toolbar.addControls([btnRefresh]);

			var extent = new OpenLayers.Bounds(
				2035059.4410645328, 7200979.560689885, 2113330.958028555, 7279251.0776539035
			);

			var gphy =  new OpenLayers.Layer.OSM("Mapa", null, {
				resolutions: [156543.03390625, 78271.516953125, 39135.7584765625,
					19567.87923828125, 9783.939619140625, 4891.9698095703125,
					2445.9849047851562, 1222.9924523925781, 611.4962261962891,
					305.74811309814453, 152.87405654907226, 76.43702827453613,
					38.218514137268066, 19.109257068634033, 9.554628534317017,
					4.777314267158508, 2.388657133579254, 1.194328566789627,
					0.5971642833948135, 0.25, 0.1, 0.05],
				serverResolutions: [156543.03390625, 78271.516953125, 39135.7584765625,
					19567.87923828125, 9783.939619140625,
					4891.9698095703125, 2445.9849047851562,
					1222.9924523925781, 611.4962261962891,
					305.74811309814453, 152.87405654907226,
					76.43702827453613, 38.218514137268066,
					19.109257068634033, 9.554628534317017,
					4.777314267158508, 2.388657133579254,
					1.194328566789627, 0.5971642833948135],
				transitionEffect: 'resize'
			});

			_map = new OpenLayers.Map(_nodeMapId, {
				projection: new OpenLayers.Projection("EPSG:900913"),
				displayProjection: new OpenLayers.Projection("EPSG:4326"),
				restrictedExtent: extent,
				controls: [
					toolbar,
					new OpenLayers.Control.ZoomPanel(),
					new OpenLayers.Control.PanPanel(),
					new OpenLayers.Control.LayerSwitcher(),
					new OpenLayers.Control.ScaleLine(),
					new OpenLayers.Control.KeyboardDefaults()
				],
				layers: [gphy,_layer]
			});
			_map.zoomToMaxExtent();
		};

		// using OpenLayers.Format.WPSCapabilities to read the capabilities
		priv.getCapabilities = function() {
			OpenLayers.Request.GET({
				url: priv.options.wpsUrl,
				params: {
					"SERVICE": "WPS",
					"REQUEST": "GetCapabilities"
				},
				success: function(response){
					_capabilities = new OpenLayers.Format.WPSCapabilities().read(
						response.responseText
					);
					var dropdown = _nodeProcesses;
					var offerings = _capabilities.processOfferings, option;
					// populate the dropdown
					for (var p in offerings) {
						option = document.createElement("option");
						option.innerHTML = offerings[p].identifier;
						option.value = p;
						dropdown.append(option);
					}
				}
			});
		};

		priv.buildForm = function() {
			_nodeAbstract.html(_process["abstract"]);
			_nodeInput.html("<h3>Input:</h3>");
			_nodeOutput.html('');

			var inputs = _process.dataInputs, supported = true,
				sld = "text/xml; subtype=sld/1.0.0",
				input;
			for (var i = 0, ii = inputs.length; i < ii; ++i) {
				input = inputs[i];
				if (input.complexData) {
					var formats = input.complexData.supported.formats;
					if (formats["application/wkt"]) {
						priv.addWKTInput(input);
					} else if (formats["text/xml; subtype=wfs-collection/1.0"]) {
						priv.addWFSCollectionInput(input);
					} else if (formats["image/tiff"]) {
						//priv.addRasterInput(input);
					} else if (formats[sld]) {
						priv.addXMLInput(input, sld);
					} else {
						supported = false;
					}
				} else if (input.boundingBoxData) {
					priv.addBoundingBoxInput(input);
				} else if (input.literalData) {
					priv.addLiteralInput(input);
				} else {
					supported = false;
				}
				if (input.minOccurs > 0) {
					_nodeInput.append(document.createTextNode("* "));
				}
			}
			
			if (supported) {
				var executeButton = document.createElement("button");
				executeButton.innerHTML = "Execute";
				_nodeInput.append(executeButton);
				executeButton.onclick = priv.execute;
			} else {
				_nodeInput.html('<span class="notsupported">' +
					"Sorry, the WPS builder does not support the selected process." +
					"</span>");
			}
		};

		// helper function to dynamically create a textarea for geometry (WKT) data
		// input
		priv.addWKTInput = function(input, previousSibling) {
			var name = input.identifier;
			var container = _nodeInput.get(0);
			var label = document.createElement("label");
			label["for"] = name;
			label.title = input["abstract"];
			label.innerHTML = name + " (select feature, then click field):";
			previousSibling && previousSibling.nextSibling ?
				container.insertBefore(label, previousSibling.nextSibling) :
				container.appendChild(label);
			var field = document.createElement("textarea");
			field.onclick = function () {
				if (_layer.selectedFeatures.length) {
					this.innerHTML = new OpenLayers.Format.WKT().write(
						_layer.selectedFeatures[0]
					);
					console.log('_layer.selectedFeatures[0]: ', _layer.selectedFeatures[0]);
				}
				priv.createCopy(input, this, priv.addWKTInput);
			};
			field.onblur = function() {
				input.data = field.value ? {
					complexData: {
						mimeType: "application/wkt",
						value: this.value
					}
				} : undefined;
			};
			field.title = input["abstract"];
			field.id = name;
			previousSibling && previousSibling.nextSibling ?
				container.insertBefore(field, previousSibling.nextSibling.nextSibling) :
				container.appendChild(field);
		};

		// helper function for xml input
		priv.addXMLInput = function(input, type) {
			var name = input.identifier;
			var field = document.createElement("input");
			field.title = input["abstract"];
			field.value = name + " (" + type + ")";
			field.onblur = function() {
				input.data = field.value ? {
					complexData: {
						mimeType: type,
						value: this.value
					}
				} : undefined;
			};
			_nodeInput.append(field);
		};

		// helper function to dynamically create a WFS collection reference input
		priv.addWFSCollectionInput = function(input) {
			var name = input.identifier;
			var field = document.createElement("input");
			field.title = input["abstract"];
			field.value = name + " (layer on demo server)";
			priv.addValueHandlers(field, function() {
				input.reference = field.value ? {
					mimeType: "text/xml; subtype=wfs-collection/1.0",
					href: "http://geoserver/wfs",
					method: "POST",
					body: {
						wfs: {
							version: "1.0.0",
							outputFormat: "GML2",
							featureType: field.value
						}
					}
				} : undefined;
			});
			_nodeInput.append(field);
		};

		// helper function to dynamically create a raster (GeoTIFF) url input
		priv.addRasterInput = function(input) {
			var name = input.identifier;
			var field = document.createElement("input");
			field.title = input["abstract"];
			var url = window.location.href.split("?")[0];
			field.value = url.substr(0, url.lastIndexOf("/")+1) + "data/tazdem.tiff";// TODO: file path to options
			document.getElementById("input").appendChild(field);
			(field.onblur = function() {
				input.reference = {
					mimeType: "image/tiff",
					href: field.value,
					method: "GET"
				};
			})();
		};

		// helper function to dynamically create a bounding box input
		priv.addBoundingBoxInput = function(input) {
			var name = input.identifier;
			var field = document.createElement("input");
			field.title = input["abstract"];
			field.value = "left,bottom,right,top (EPSG:4326)";
			_nodeInput.append(field);
			priv.addValueHandlers(field, function() {
				input.boundingBoxData = {
					projection: "EPSG:4326",
					bounds: OpenLayers.Bounds.fromString(field.value)
				};
			});
		};

		// helper function to create a literal input textfield or dropdown
		priv.addLiteralInput = function(input, previousSibling) {
			var name = input.identifier;
			var container = _nodeInput.get(0);
			var anyValue = input.literalData.anyValue;
			// anyValue means textfield, otherwise we create a dropdown
			var field = document.createElement(anyValue ? "input" : "select");
			field.id = name;
			field.title = input["abstract"];
			previousSibling && previousSibling.nextSibling ?
				container.insertBefore(field, previousSibling.nextSibling) :
				container.appendChild(field);
			if (anyValue) {
				var dataType = input.literalData.dataType;
				field.value = name + (dataType ? " (" + dataType + ")" : "");
				priv.addValueHandlers(field, function() {
					input.data = field.value ? {
						literalData: {
							value: field.value
						}
					} : undefined;
					priv.createCopy(input, field, priv.addLiteralInput);
				});
			} else {
				var option;
				option = document.createElement("option");
				option.innerHTML = name;
				field.appendChild(option);
				for (var v in input.literalData.allowedValues) {
					option = document.createElement("option");
					option.value = v;
					option.innerHTML = v;
					field.appendChild(option);
				}
				field.onchange = function() {
					priv.createCopy(input, field, priv.addLiteralInput);
					input.data = this.selectedIndex ? {
						literalData: {
							value: this.options[this.selectedIndex].value
						}
					} : undefined;
				};
			}
		};

		// if maxOccurs is > 1, this will add a copy of the field
		priv.createCopy = function(input, field, fn) {
			if (input.maxOccurs && input.maxOccurs > 1 && !field.userSelected) {
				// add another copy of the field - we don't check maxOccurs
				field.userSelected = true;
				var newInput = OpenLayers.Util.extend({}, input);
				// we recognize copies by the occurrence property
				newInput.occurrence = (input.occurrence || 0) + 1;
				_process.dataInputs.push(newInput);
				fn(newInput, field);
			}
		};

		// helper function for adding events to form fields
		priv.addValueHandlers = function(field, onblur) {
			field.onclick = function() {
				if (!this.initialValue) {
					this.initialValue = this.value;
					this.value = "";
				}
			};
			field.onblur = function() {
				if (!this.value) {
					this.value = this.initialValue;
					delete this.initialValue;
				}
				onblur.apply(this, arguments);
			};
		};

		// execute the process
		priv.execute = function() {
			var output = _process.processOutputs[0];
			var input;
			// remove occurrences that the user has not filled out
			for (var i = _process.dataInputs.length - 1; i >= 0; --i) {
				input = _process.dataInputs[i];
				if ((input.minOccurs === 0 || input.occurrence) && !input.data && !input.reference) {
					OpenLayers.Util.removeItem(_process.dataInputs, input);
				}
			}
			_process.responseForm = {
				rawDataOutput: {
					identifier: output.identifier
				}
			};
			if (output.complexOutput && output.complexOutput.supported.formats["application/wkt"]) {
				_process.responseForm.rawDataOutput.mimeType = "application/wkt";
			}
			OpenLayers.Request.POST({
				url: priv.options.wpsUrl,
				data: new OpenLayers.Format.WPSExecute().write(_process),
				success: priv.showOutput
			});
		}

		// add the process's output to the page
		priv.showOutput = function(response) {
			var result = _nodeOutput.get(0);
			result.innerHTML = "<h3>Output:</h3>";
			var features;
			var contentType = response.getResponseHeader("Content-Type");
			if (contentType == "application/wkt") {
				features = new OpenLayers.Format.WKT().read(response.responseText);
			} else if (contentType == "text/xml; subtype=wfs-collection/1.0") {
				features = new OpenLayers.Format.WFST.v1_0_0().read(response.responseText);
			}
			if (features && (features instanceof OpenLayers.Feature.Vector || features.length)) {
				_layer.addFeatures(features);
				result.innerHTML += "The result should also be visible on the map.";
			}
			result.innerHTML += "<textarea>" + response.responseText + "</textarea>";
		}


		publ.updateSize = function() {
			_map.updateSize();
		};

		publ.zoomToExtent = function(extent) {
			var extentBounds = OpenLayers.Geometry.fromWKT(extent).getBounds();
			_map.zoomToExtent(extentBounds);
		};

		publ.init = function(options) {
			if (priv.options.debug) console.log('TableAjaxMap initialization...', options);
			//merge supplied options with defaults
			$.extend(priv.options, defaults, options);
			priv.init();
			return publ;
		};
		return publ;
	};

	$.fn.TableAjaxMapUpdateSize = function(options) {
		options = options || {};
		return this.each(function() {
			var tblAjaxMap = $(this).data('TableAjaxMap');
			if (tblAjaxMap) {
				tblAjaxMap.updateSize();
			}
		});
		return this;
	};

	$.fn.TableAjaxMapZoomToExtent = function(extent) {
		if (!extent) return;
		return this.each(function() {
			var tblAjaxMap = $(this).data('TableAjaxMap');
			if (tblAjaxMap) {
				tblAjaxMap.zoomToExtent(extent);
			}
		});
		return this;
	};

	$.fn.TableAjaxMap = function(options) {
		options = options || {};
		return this.each(function() {
			options.id = this;
			if (!$(this).data('TableAjaxMap')) {
				$(this).data('TableAjaxMap', new TableAjaxMap().init(options));
			}
		});
		return this;
	};
}(jQuery));
</script>
		<?php
	}

	public function ajaxTask($task) {
		switch ($task) {
			case 'PROXY': {
				$this->sendAjaxProxy($_REQUEST);
				break;
			}
			default:
				//$this->sendAjaxData($_REQUEST);
		}
	}

	public function sendAjaxProxy($args) {
		$url = V::get('url', '', $args);
		// 1. http%3A%2F%2Fbiuro.biall-net.pl%2Fwps%3FSERVICE%3DWPS%26REQUEST%3DGetCapabilities
		// 2. http%3A%2F%2Fbiuro.biall-net.pl%2Fwps%3FSERVICE%3DWPS%26REQUEST%3DDescribeProcess%26VERSION%3D1.0.0%26IDENTIFIER%3Dpozdrawiam
		header('Content-Type: application/xml; charset=utf-8');
		$urlParts = parse_url($url);
		$urlQuery = array();
		$urlQueryTmp = V::get('query', '', $urlParts);
		$urlQueryTmp = explode('&', $urlQueryTmp);
		foreach ($urlQueryTmp as $vQuery) {
			$parts = explode('=', $vQuery, 2);
			$urlQuery[$parts[0]] = $parts[1];
		}

		$wpsServer = new TableAjaxMapWpsServer($this->_zasobID);
		if ('WPS' == V::get('SERVICE', '', $urlQuery)) {
			$req = V::get('REQUEST', '', $urlQuery);
			$methodName = "{$req}Action";
			if (method_exists($wpsServer, $methodName)) {
				$wpsServer->$methodName($urlQuery);
			}
		}
		else {
			$wpsServer->parseXMLRequest();
		}
		exit;
	}

}


class TableAjaxMapWfsAction {

	private $_zasobID;

	public function __construct($zasobID) {
		$this->_zasobID = $zasobID;
	}

	/**
	 * example: MULTIPOLYGON(((2072016.74395199 7234076.79293037,2072016.74395199 7234115.01144451,2072131.3994944 7234115.01144451,2072131.3994944 7234076.79293037,2072016.74395199 7234076.79293037)))
	 */
	public function generateGmlFromWKT($wkt) {
		$gml = '';

		$wktParts = explode('(', $wkt, 2);
		ob_start();
		switch ($wktParts[0]) {
			case 'MULTIPOLYGON':
			case 'POLYGON': {
				$points = trim($wktParts[1], '() ');
				$points = str_replace(',', "\n", $points);
				?>
					<gml:boundedBy>
						<gml:Envelope srsDimension="2" srsName="http://www.opengis.net/gml/srs/epsg.xml#4326">
							<gml:lowerCorner>-180 -90</gml:lowerCorner>
							<gml:upperCorner>180 90</gml:upperCorner>
						</gml:Envelope>
					</gml:boundedBy>
					<og:the_geom>
						<gml:MultiSurface srsDimension="2" srsName="http://www.opengis.net/gml/srs/epsg.xml#900913">
							<gml:surfaceMember>
								<gml:Polygon srsDimension="2">
									<gml:exterior>
										<gml:LinearRing srsDimension="2">
											<gml:posList>
												<?php echo $points; ?>
											</gml:posList>
										</gml:LinearRing>
									</gml:exterior>
								</gml:Polygon>
							</gml:surfaceMember>
						</gml:MultiSurface>
					</og:the_geom>
				<?php
				}
				break;
			default:
		}
		$gml = ob_get_contents();
		ob_clean();

		return $gml;
	}

	public function execute($args) {
		/*
		 * Mapa odczytywanie punktów: http://www.maptiler.org/google-maps-coordinates-tile-bounds-projection/
		 * 
		 * CI50:
					18.613243103027344 54.33614429135817
					18.613243103027344 54.33634445792519
					18.614273071289062 54.33634445792519
					18.614273071289062 54.33614429135817
		 */
		$buildingsGml = array();
		$db = DB::getDB();
		if ($this->_zasobID == 16) {// TODO: read by TableAcl from Data_Source?
			$sql = "select b.`ID`, AsWKT(b.`the_geom`) as the_geom
				from `BUILDINGS` as b
				where b.`the_geom` is not null and b.`the_geom`!=''
				limit 10;
			";
			$res = $db->query($sql);
			while ($r = $db->fetch($res)) {
				$buildingsGml[$r->ID] = $this->generateGmlFromWKT($r->the_geom);
			}
		}

		/**
		 * <og:recordId><?php echo $kId; ?></og:recordId>
		 * <og:tblId><?php echo $tblId; ?></og:tblId>
		 * 
		 * goes to js: @see priv.addWKTInput _layer.selectedFeatures[0]
		 * 
		 *	attributes: Object
					recordId: "1130"
					tblId: "16"
		 */

		echo '<?xml version="1.0" encoding="UTF-8"?>';
		?>
<wfs:FeatureCollection xmlns:nasa="http://nasa.gov" xmlns:topp="http://www.openplans.org/topp" xmlns:usgs="http://www.usgs.gov/" xmlns:ogc="http://www.opengis.net/ogc" xmlns:wfs="http://www.opengis.net/wfs" xmlns:ows="http://www.opengis.net/ows" xmlns:ne="http://naturalearthdata.com" xmlns:xlink="http://www.w3.org/1999/xlink" xmlns:gml="http://www.opengis.net/gml" xmlns:osm="http://openstreemap.org" xmlns:nurc="http://www.nurc.nato.int" xmlns:og="http://opengeo.org" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" numberOfFeatures="4" timeStamp="2014-07-16T13:22:43.307Z" xsi:schemaLocation="http://opengeo.org http://demo.opengeo.org:80/geoserver/wfs?service=WFS&amp;version=1.1.0&amp;request=DescribeFeatureType&amp;typeName=og%3Arestricted http://www.opengis.net/wfs http://demo.opengeo.org:80/geoserver/schemas/wfs/1.1.0/wfs.xsd">
<!--
<?php echo'<pre style="max-height:200px;overflow:auto;border:1px solid red;text-align:left;"> (' . __CLASS__ . '::' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($this->_zasobID);echo'</pre>'; ?>
<?php echo'<pre style="max-height:200px;overflow:auto;border:1px solid red;text-align:left;"> (' . __CLASS__ . '::' . __FUNCTION__ . ':' . __LINE__ . '): ';print_r($buildingsGml);echo'</pre>'; ?>
-->
  <gml:boundedBy>
    <gml:Envelope srsDimension="2" srsName="http://www.opengis.net/gml/srs/epsg.xml#4326">
      <gml:lowerCorner>-180 -90</gml:lowerCorner>
			<gml:upperCorner>180 90</gml:upperCorner>
    </gml:Envelope>
  </gml:boundedBy>
  <gml:featureMembers>
		<?php foreach ($buildingsGml as $kId => $vGml) : ?>
			<og:restricted gml:id="restricted.<?php echo $kId; ?>">
				<?php echo $vGml; ?>
				<og:recordId><?php echo $kId; ?></og:recordId>
				<og:tblId><?php echo $this->_zasobID; ?></og:tblId>
			</og:restricted>
		<?php endforeach; ?>
  </gml:featureMembers>
</wfs:FeatureCollection>
		<?php
	}

}

class WpsActionBase {

	public $title = '';
	public $description = '';
	public $dataInputs = array();

	public function execute($args) {
		var_dump($args);
	}

}

class WpsActionPrzypiszDoRekordu extends WpsActionBase {

	public function __construct() {
		$this->title = 'Przypisz';
		$this->description = 'Przypisuje położenie do wybranego rekordu w tabeli.';

		$this->dataInputs['geom'] = new stdClass();
		$this->dataInputs['geom']->title = 'geom';
		$this->dataInputs['geom']->description = 'Input geometry';
		$this->dataInputs['geom']->type = 'geom';// CoomplexData

		$this->dataInputs['idTable'] = new stdClass();
		$this->dataInputs['idTable']->title = 'geom';
		$this->dataInputs['idTable']->description = 'Table ID';
		$this->dataInputs['idTable']->type = 'integer';// LiteralData: xs:integer

		$this->dataInputs['idRecord'] = new stdClass();
		$this->dataInputs['idRecord']->title = 'idRecord';
		$this->dataInputs['idRecord']->description = 'Record ID';
		$this->dataInputs['idRecord']->type = 'integer';// LiteralData: xs:integer
	}

}

class TableAjaxMapWpsServer {

	private $_fun;// config for identifiers
	private $_wfsAction;
	private $_zasobID;

	public function __construct($zasobID) {
		$this->_fun['przypiszDoRekordu'] = new WpsActionPrzypiszDoRekordu();
		$this->_wfsAction = new TableAjaxMapWfsAction($zasobID);
		$this->_zasobID = $zasobID;
	}

	public function parseXMLRequest() {
		$data = array();
		$reqContent = file_get_contents('php://input');
		$xml = new SimpleXMLElement($reqContent);

		if ('GetFeature' == $xml->getName()) {
			// TODO: parse xml and set query params
			$this->_wfsAction->execute($data);
		}
		else if (isset($xml->children('ows', TRUE)->Identifier)) {
			$identifier = (string)$xml->children('ows', TRUE)->Identifier;
			if (array_key_exists($identifier, $this->_fun)) {

				foreach ($xml->children('wps', TRUE)->DataInputs->children('wps', TRUE) as $input) {
					$inputIdentifier = (string)$input->children('ows', TRUE)->Identifier;
					if (array_key_exists($inputIdentifier, $this->_fun[$identifier]->dataInputs)) {
						$inputType = (string)$this->_fun[$identifier]->dataInputs[$inputIdentifier]->type;
						switch ($inputType) {
							case 'integer':
								$data[$inputIdentifier] = (string)$input->children('wps', TRUE)->Data->LiteralData;
								break;
							case 'geom':
								$data[$inputIdentifier] = (string)$input->children('wps', TRUE)->Data->ComplexData;
								break;
							default:
								
						}
					} else {
						// brak zdefiniowanego inputa
					}
				}

				$this->_fun['przypiszDoRekordu']->execute($data);

			} else {
				echo "TODO: brak zdefiniowanej funkcji '{$identifier}'";
				var_dump($identifier);
			}
		}
		else {
			echo "TODO: '" . $xml->getName() . "' ...";
		}
	}

	public function getCapabilitiesAction() {
		echo '<?xml version="1.0" encoding="UTF-8"?>';
		?>
<wps:Capabilities xmlns:wps="http://www.opengis.net/wps/1.0.0" xmlns:ows="http://www.opengis.net/ows/1.1" xmlns:xlink="http://www.w3.org/1999/xlink" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xml:lang="en" service="WPS" version="1.0.0" xsi:schemaLocation="http://www.opengis.net/wps/1.0.0 http://schemas.opengis.net/wps/1.0.0/wpsAll.xsd">
    <ows:ServiceIdentification>
        <ows:Title>Prototype GeoServer WPS</ows:Title>
        <ows:Abstract />
        <ows:Keywords>
            <ows:Keyword>wps</ows:Keyword>
            <ows:Keyword>geoserver</ows:Keyword>
        </ows:Keywords>
        <ows:ServiceType>WPS</ows:ServiceType>
        <ows:ServiceTypeVersion>1.0.0</ows:ServiceTypeVersion>
        <ows:Fees>NONE</ows:Fees>
        <ows:AccessConstraints>NONE</ows:AccessConstraints>
    </ows:ServiceIdentification>
    <ows:ServiceProvider>
        <ows:ProviderName>GeoServer</ows:ProviderName>
        <ows:ProviderSite />
        <ows:ServiceContact />
    </ows:ServiceProvider>
    <ows:OperationsMetadata>
        <ows:Operation name="GetCapabilities">
            <ows:DCP>
                <ows:HTTP>
                    <ows:Get xlink:href="http://demo.opengeo.org:80/geoserver/wps" />
                    <ows:Post xlink:href="http://demo.opengeo.org:80/geoserver/wps" />
                </ows:HTTP>
            </ows:DCP>
        </ows:Operation>
        <ows:Operation name="DescribeProcess">
            <ows:DCP>
                <ows:HTTP>
                    <ows:Get xlink:href="http://demo.opengeo.org:80/geoserver/wps" />
                    <ows:Post xlink:href="http://demo.opengeo.org:80/geoserver/wps" />
                </ows:HTTP>
            </ows:DCP>
        </ows:Operation>
        <ows:Operation name="Execute">
            <ows:DCP>
                <ows:HTTP>
                    <ows:Get xlink:href="http://demo.opengeo.org:80/geoserver/wps" />
                    <ows:Post xlink:href="http://demo.opengeo.org:80/geoserver/wps" />
                </ows:HTTP>
            </ows:DCP>
        </ows:Operation>
    </ows:OperationsMetadata>
    <wps:ProcessOfferings>
			<?php foreach($this->_fun as $kFun => $vFun) : ?>
        <wps:Process wps:processVersion="1.0.0">
            <ows:Identifier><?php echo $kFun; ?></ows:Identifier>
            <ows:Title><?php echo $vFun->title; ?></ows:Title>
            <ows:Abstract><?php echo $vFun->description; ?></ows:Abstract>
        </wps:Process>
			<?php endforeach; ?>
    </wps:ProcessOfferings>
    <wps:Languages>
        <wps:Default>
            <ows:Language>en-US</ows:Language>
        </wps:Default>
        <wps:Supported>
            <ows:Language>en-US</ows:Language>
        </wps:Supported>
    </wps:Languages>
</wps:Capabilities>

		<?php
	}

	public function describeProcessAction($args) {
		// TODO: xml z opiesem procese $args['IDENTIFIER']
		/**
		 * should work like JTS:densify - geom field (map object) and integer field (record ID)
		 * http://openlayers.org/dev/examples/proxy.cgi?url=http%3A%2F%2Fdemo.opengeo.org%2Fgeoserver%2Fwps%3FSERVICE%3DWPS%26REQUEST%3DDescribeProcess%26VERSION%3D1.0.0%26IDENTIFIER%3DJTS%253Adensify
		 * http://demo.opengeo.org/geoserver/wps?SERVICE=WPS&REQUEST=DescribeProcess&VERSION=1.0.0&IDENTIFIER=JTS%3Adensify
		 */
		echo '<?xml version="1.0" encoding="UTF-8"?>';

		if (array_key_exists($args['IDENTIFIER'], $this->_fun)) {
			$identifier = $this->_fun[$args['IDENTIFIER']];
		?>
<wps:ProcessDescriptions xmlns:wps="http://www.opengis.net/wps/1.0.0" xmlns:ows="http://www.opengis.net/ows/1.1" xmlns:xlink="http://www.w3.org/1999/xlink" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xml:lang="en" service="WPS" version="1.0.0" xsi:schemaLocation="http://www.opengis.net/wps/1.0.0 http://schemas.opengis.net/wps/1.0.0/wpsAll.xsd">
  <ProcessDescription wps:processVersion="1.0.0" statusSupported="true" storeSupported="true">
    <ows:Identifier><?php echo $args['IDENTIFIER']; ?></ows:Identifier>
    <ows:Title><?php echo $identifier->title; ?></ows:Title>
    <ows:Abstract><?php echo $identifier->description; ?></ows:Abstract>
    <DataInputs>
			<?php foreach ($identifier->dataInputs as $kInput => $vInput) : ?>
				<Input maxOccurs="1" minOccurs="1">
					<ows:Identifier><?php echo $kInput; ?></ows:Identifier>
					<ows:Title><?php echo $vInput->title; ?></ows:Title>
					<ows:Abstract><?php echo $vInput->description; ?></ows:Abstract>
					<?php if ($vInput->type == 'geom') : ?>
						<ComplexData>
							<Default>
								<Format>
									<MimeType>text/xml; subtype=gml/3.1.1</MimeType>
								</Format>
							</Default>
							<Supported>
								<Format>
									<MimeType>text/xml; subtype=gml/3.1.1</MimeType>
								</Format>
								<Format>
									<MimeType>text/xml; subtype=gml/2.1.2</MimeType>
								</Format>
								<Format>
									<MimeType>application/wkt</MimeType>
								</Format>
								<Format>
									<MimeType>application/gml-3.1.1</MimeType>
								</Format>
								<Format>
									<MimeType>application/gml-2.1.2</MimeType>
								</Format>
							</Supported>
						</ComplexData>
					<?php elseif ($vInput->type == 'integer') : ?>
						<LiteralData>
							<ows:DataType>xs:integer</ows:DataType>
							<ows:AnyValue />
						</LiteralData>
					<?php else : ?>

					<?php endif; ?>
				</Input>
			<?php endforeach; ?>
    </DataInputs>
    <ProcessOutputs>
      <Output>
        <ows:Identifier>result</ows:Identifier>
        <ows:Title>result</ows:Title>
        <ComplexOutput>
          <Default>
            <Format>
              <MimeType>text/xml; subtype=gml/3.1.1</MimeType>
            </Format>
          </Default>
          <Supported>
            <Format>
              <MimeType>text/xml; subtype=gml/3.1.1</MimeType>
            </Format>
            <Format>
              <MimeType>text/xml; subtype=gml/2.1.2</MimeType>
            </Format>
            <Format>
              <MimeType>application/wkt</MimeType>
            </Format>
            <Format>
              <MimeType>application/gml-3.1.1</MimeType>
            </Format>
            <Format>
              <MimeType>application/gml-2.1.2</MimeType>
            </Format>
          </Supported>
        </ComplexOutput>
      </Output>
    </ProcessOutputs>
  </ProcessDescription>
</wps:ProcessDescriptions>
			<?php
		} else {
			echo 'TODO: brak funkcji';
		}
	}

}