wfsidentifycriteriahandler.java

esri的ArcGIS Server超级学习模板程序（for java）

package com.esri.solutions.jitk.web.wfs.data.query;

import java.util.List;

import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;

import com.esri.adf.web.data.WebLayerInfo;
import com.esri.adf.web.data.geometry.WebGeometry;
import com.esri.adf.web.data.geometry.WebSpatialReference;
import com.esri.adf.web.data.query.IdentifyCriteria;
import com.esri.adf.web.data.query.QueryCriteria;
import com.esri.adf.web.data.query.QueryCriteriaHandler;
import com.esri.adf.web.data.query.QueryFunctionality;
import com.esri.adf.web.data.query.QueryResult;
import com.esri.adf.web.data.query.WebQuery;
import com.esri.solutions.jitk.data.gml.IWebGeometryConverter;
import com.esri.solutions.jitk.data.gml.WebGeometryConverterFactory;
import com.esri.solutions.jitk.datasources.ogc.filters.Filter;
import com.esri.solutions.jitk.datasources.ogc.filters.IFilter;
import com.esri.solutions.jitk.datasources.ogc.filters.IntersectsClause;
import com.esri.solutions.jitk.datasources.ogc.gml.IGMLGeometry;
import com.esri.solutions.jitk.datasources.ogc.wfs.CoordinateReferenceSystem;
import com.esri.solutions.jitk.datasources.ogc.wfs.FeatureCollection;
import com.esri.solutions.jitk.datasources.ogc.wfs.FeatureTypeDescription;
import com.esri.solutions.jitk.datasources.ogc.wfs.IQuery;
import com.esri.solutions.jitk.datasources.ogc.wfs.IWFSClient;
import com.esri.solutions.jitk.datasources.ogc.wfs.Query;
import com.esri.solutions.jitk.web.wfs.data.WFSWebLayerInfo;

public class WFSIdentifyCriteriaHandler extends WFSQueryCriteria implements QueryCriteriaHandler {
	private static final Logger _logger = LogManager.getLogger(WFSIdentifyCriteriaHandler.class);
	
	public List<QueryResult> handleCriteria(QueryCriteria qc,
			List<? extends WebLayerInfo> layerList, 
			WebQuery webQuery,
			QueryFunctionality qf) {
		_logger.debug("handleCriteria called");
		List<QueryResult> results = null;
		
		WFSWebLayerInfo layerInfo = getWFSWeblayerInfo(qf, layerList);	
		
		if (layerInfo != null) {
			if (qc instanceof IdentifyCriteria) {
				results = identify((IdentifyCriteria) qc, qf, layerInfo, webQuery);
			} else {
				_logger.error("QueryCriteria not IdentifyCriteria, query can not be processed");
			}			
		}
		
		return results;
	}
	
	protected List<QueryResult> identify(IdentifyCriteria ic, QueryFunctionality qf, WFSWebLayerInfo layerInfo, WebQuery webQuery) {
		List<QueryResult> results = null;
		
		try {
			// Get layer name and shape field name
			String layerName = layerInfo.getName();
			String shapeField = layerInfo.getFeatureType().getShapeElement().getName();
			FeatureTypeDescription ftd = layerInfo.getFeatureTypeDescription();
			WebSpatialReference wsr = webQuery.getWebContext().getSpatialReference();
			
			CoordinateReferenceSystem crs = getCrs(wsr, ftd);
			IWFSClient wfs = getWFSClient(qf.getResource());
			
			if (crs == null) {
				throw new Exception("WFS service does not support spatial reference ID");
			} 
			
			_logger.debug("Converting identify geometry");
			WebGeometry webGeo = ic.getWebGeometry(wsr);
			IWebGeometryConverter converter = WebGeometryConverterFactory.getInstance(webQuery.getWebContext(), webGeo);
			IGMLGeometry gmlGeometry = converter.toGMLGeometry(webGeo);
			
			_logger.debug("Building filter intersects clause");
			IntersectsClause wc = new IntersectsClause();
			wc.setGMLGeometry(gmlGeometry);
			wc.setShapePropertyName(shapeField);
			
			_logger.debug("Building filter");
			IFilter filter = new Filter();
			filter.pushClause(wc);
			
			_logger.debug("Building query");
			IQuery query = new Query();
			query.setCrs(crs);
			query.setFilter(filter);
			query.setTypeName(layerName);		
			
			_logger.debug("Performing get feature request to WFS");
			int maxRec = (ic.getMaxRecordCount() <= 0) ? 500 : ic.getMaxRecordCount();
			FeatureCollection fc = wfs.getFeatures(query, maxRec);
			
			_logger.debug("Converting WFS feature collection to ADF results");
			WFSResultsBuilder resultBuilder = new WFSResultsBuilder();
			results = resultBuilder.buildQueryResults(webQuery, layerInfo, fc);
		} catch (Exception ex) {
			_logger.error("Exception performing feature query against WFS", ex);
		}
		
		return results;
	}
}