【SDK】【服务】【新增OGC通用服务】

潘卓然ParnDeedlit · 潘卓然ParnDeedlit · commit b21bba4e794f · 2021-05-19T19:55:58.000+08:00
diff --git a/src/service/OpenGeospatialConsortium/OGCService.js b/src/service/OpenGeospatialConsortium/OGCService.js
@@ -0,0 +1,64 @@
+import { MapGIS } from '../Base';
+import { ServiceBase } from '../ServiceBase';
+
+/**
+ * @author 基础平台-潘卓然
+ * @class module:OGC服务.OGCService
+ * @classdesc OGC服务类
+ * @description Mapgis.OGC.OGCService
+ * @extends  ServiceBase
+ * @param option - {Object} 属性键值对。<br>
+ * @param {String} [option.baseUrl = igs/rest/ogc] 基本地址
+ * @param {String} [option.url = ""] 必选。服务url
+ */
+class OGCService extends ServiceBase {
+    constructor(option) {
+        var options = option || {};
+        options.baseUrl = 'igs/rest/ogc';
+        super(options);
+    }
+
+    /**
+     * @description 向服务器发送GET请求
+     * @function module:OGC.OGCService.prototype.get
+     * @param  {String} url 完整的请求地址。
+     * @param  {Function} onSuccess 查询成功回调函数。
+     * @param {Function} onError 查询失败回调函数。
+     */
+    get(url, onSuccess, onError) {
+        var me = this;
+        var service = new IgsServiceBase(url, {
+            eventListeners: {
+                scope: me,
+                processCompleted: onSuccess,
+                processFailed: onError
+            }
+        });
+        service.processAsync();
+    }
+
+    /**
+     * @description 向服务器发送POST请求
+     * @function module:OGC.OGCService.prototype.post
+     * @param  {String} url 完整的请求地址。
+     * @param  {Function} onSuccess 查询成功回调函数。
+     * @param {Function} onError 查询失败回调函数。
+     */
+    post(url, param, onSuccess, onError) {
+        var me = this;
+        var service = new IgsServiceBase(url, {
+            eventListeners: {
+                scope: me,
+                processCompleted: onSuccess,
+                processFailed: onError
+            }
+        });
+        service.processAsync({
+            method: 'POST',
+            data: JSON.stringify(param),
+            headers: { 'Content-Type': 'text/plain;charset=UTF-8' }
+        });
+    }
+}
+export { OGCService };
+MapGIS.OGC.OGCService = OGCService;
diff --git a/src/service/OpenGeospatialConsortium/WFS.js b/src/service/OpenGeospatialConsortium/WFS.js
@@ -0,0 +1,153 @@
+import { MapGIS } from '../Base';
+import { OGCService } from './OGCService';
+import xml from 'fast-xml-parser';
+import axios from 'axios';
+import qs from 'qs';
+
+/**
+ * @author 基础平台-潘卓然
+ * @class module:OGC服务.OGCService
+ * @classdesc OGC服务类
+ * @description MapGIS.OGC.OGCService
+ * @extends  OGCService
+ * @link https://www.ogc.org/standards/wfs
+ * @param option - {Object} 属性键值对。<br>
+ * @param {String} [option.url = ""] 必选。服务url
+ * @param {String} [option.version = "1.1.1"] 请求的版本号,1.1.1或1.3.0，服务默认版本为1.1.1。(getWMSInfo,getFeatureInfo)
+ */
+class WFS extends OGCService {
+    constructor(option) {
+        var options = option || {};
+        super(options);
+        this.url = options.url;
+        this.featureTypes = [];
+        this.layers = [];
+    }
+
+    isBaseUrl() {
+        let valid = false;
+        const name = 'WFSServer';
+        const length = this.url.length;
+        const index = this.url.indexOf(name) + name.length;
+        let fullurl;
+        if (index === length) {
+            fullurl = `${this.url}?request=GetCapabilities&service=WFS`;
+            valid = true;
+        } else if (index === length - 1) {
+            fullurl = `${this.url}request=GetCapabilities&service=WFS`;
+            valid = true;
+        }
+        return valid;
+    }
+
+    setVersion(version) {
+        this.version = version;
+        return this;
+    }
+
+    setCrs(crs) {
+        this.srsname = crs;
+        return this;
+    }
+
+    setName(name) {
+        this.typename = name;
+        return this;
+    }
+
+    setOutputFormat(format) {
+        this.outputFormat = format;
+    }
+
+    async getCapabilities() {
+        const name = 'WFSServer';
+        const length = this.url.length;
+        const index = this.url.indexOf(name) + name.length;
+        let fullurl = this.url;
+        if (index === length) {
+            fullurl = `${this.url}?request=GetCapabilities&service=WFS`;
+        } else if (index === length - 1) {
+            fullurl = `${this.url}request=GetCapabilities&service=WFS`;
+        }
+        let res = await axios.get(fullurl);
+        let data = res.data;
+        let obj = xml.getTraversalObj(data, {});
+        let json = xml.convertToJson(obj, {});
+        let version = json['wfs:WFS_Capabilities']['ows:ServiceIdentification']['ows:ServiceTypeVersion'];
+        if (version === '1.1.0') {
+            // MapGIS 10.3.5 10.5.0
+            this.featureTypes = json['wfs:WFS_Capabilities']['FeatureTypeList']['FeatureType'];
+            let crs;
+            let name = '';
+            this.featureTypes.forEach((f, i) => {
+                if (i == 0) {
+                    crs = f['DefaultSRS'];
+                    name = `${f['Name']}`;
+                }
+            });
+            this.layers = this.featureTypes.map((f) => f['Name']);
+            this.setName(name).setCrs(crs).setVersion(version).setOutputFormat('text/xml; subtype=gml/3.2');
+        } else if (version === '2.0.0') {
+            let featureType = json['wfs:WFS_Capabilities']['wfs:FeatureTypeList']['wfs:FeatureType'];
+            let crs = featureType['wfs:DefaultCRS'];
+            let name = featureType['wfs:Name'];
+            this.setName(name).setCrs(crs).setVersion(version);
+        }
+        return json;
+    }
+
+    async getFeature() {
+        const name = 'WFSServer';
+        const length = this.url.length;
+        const index = this.url.indexOf(name) + name.length;
+        let fullurl = this.url;
+
+        let { maxFeatures = 100, version = '1.1.0', typename = '', outputFormat, srsname = 'EPSG:4326', bbox } = this;
+        let object = {
+            service: 'WFS',
+            request: 'GetFeature',
+            version,
+            typename,
+            outputFormat,
+            srsname,
+            maxFeatures
+        };
+
+        if (version === '1.1.0') {
+            if (bbox) {
+                object = { ...object, bbox: `${bbox},${srsname}` };
+            } else {
+                object = { ...object };
+            }
+        } else if (version === '2.0.0') {
+            object = { ...object, Envelope: `${bbox},${srsname}` };
+        }
+
+        if (index === length) {
+            fullurl = `${this.url}?${qs.stringify(object)}`;
+        } else if (index === length - 1) {
+            fullurl = `${this.url}${qs.stringify(object)}`;
+        }
+
+        let res = await axios.get(fullurl);
+        let data = res.data;
+        let obj = xml.getTraversalObj(data, {});
+        let json = xml.convertToJson(obj, {});
+
+        let result = {
+            geojson: undefined,
+            xml: json
+        };
+        let geojson;
+        switch (version) {
+            case '1.1.0':
+                geojson = convert
+                break;
+            case '2.0.0':
+                break;
+        }
+        return result;
+    }
+}
+export { WFS };
+MapGIS.OGC.WFS = WFS;
diff --git a/src/service/OpenGeospatialConsortium/WMS.js b/src/service/OpenGeospatialConsortium/WMS.js
@@ -0,0 +1,88 @@
+import { MapGIS } from '../Base';
+import { OGCService } from './OGCService';
+import xml from 'fast-xml-parser';
+import axios from 'axios';
+import qs from 'qs';
+
+/**
+ * @author 基础平台-潘卓然
+ * @class module:OGC服务.WMS
+ * @classdesc OGC服务类
+ * @description MapGIS.OGC.WMS
+ * @extends  OGCService
+ * @param option - {Object} 属性键值对。<br>
+ * @param {String} [option.url = ""] 必选。服务url
+ * @param {String} [option.version = "1.1.1"] 请求的版本号,1.1.1或1.3.0，服务默认版本为1.1.1。(getWMSInfo,getFeatureInfo)
+ * @param {String} [option.layers] 请求的图层名，用逗号分隔多个图层；既支持单纯的图层名，也支持服务名称（图层名）。(getFeatureInfo)
+ * @param {String} [option.srs] 空间坐标参考系。(getFeatureInfo)
+ * @param {String} [option.bbox] 显示范围，坐标用minx,miny,maxx,maxy表示（1.1.1版本）,坐标用miny,minx,maxy,maxx表示（1.3.0版本），与srs对应设置可以达到动态投影的效果。(getFeatureInfo)
+ * @param {String} [option.width = "1024"] 输出地图图片的象素宽。(getFeatureInfo)
+ * @param {String} [option.height = "768"]  输出地图图片的象素高。(getFeatureInfo)
+ * @param {String} [option.style = "default"] 图层样式，用逗号分隔各图层对应的样式。(getFeatureInfo)
+ * @param {String} [option.format = "image/png"] 输出图象的类型,支持三种格式gif、png、jpg。(getFeatureInfo)
+ */
+class WMS extends OGCService {
+    constructor(option) {
+        var options = option || {};
+        super(options);
+
+        this.url = options.url;
+    }
+
+    isBaseUrl() {
+        let valid = false;
+        const name = 'WMSServer';
+        const length = this.url.length;
+        const index = this.url.indexOf(name) + name.length;
+        let fullurl = this.url;
+        if (index === length) {
+            fullurl = `${this.url}?request=GetCapabilities&service=WMS`;
+            valid = true;
+        } else if (index === length - 1) {
+            fullurl = `${this.url}request=GetCapabilities&service=WMS`;
+            valid = true;
+        }
+        return valid;
+    }
+
+    async makeFullUrl() {
+        if (this.isBaseUrl()) {
+            let json = await this.getCapabilities();
+            let { height, width, crs, format, version, styles } = this;
+            let layers = json.WMT_MS_Capabilities.Capability.Layer.Layer.map((l) => l.Name).toString();
+            let object = {
+                service: 'WMS',
+                request: 'GetMap',
+                layers,
+                styles: styles || '',
+                format: format || 'image/png',
+                transparent: true,
+                version: version || '1.1.1',
+                height: height || 256,
+                width: width || 256,
+                srs: crs || 'EPSG:4326'
+            };
+            let fullurl = `${this.url}?${qs.stringify(object)}`;
+            return fullurl;
+        }
+    }
+
+    async getCapabilities() {
+        const name = 'WMSServer';
+        const length = this.url.length;
+        const index = this.url.indexOf(name) + name.length;
+        let fullurl = this.url;
+        if (index === length) {
+            fullurl = `${this.url}?request=GetCapabilities&service=WMS`;
+        } else if (index === length - 1) {
+            fullurl = `${this.url}request=GetCapabilities&service=WMS`;
+        }
+        let res = await axios.get(fullurl);
+        let data = res.data;
+        let obj = xml.getTraversalObj(data, {});
+        let json = xml.convertToJson(obj, {});
+        return json;
+    }
+}
+export { WMS };
+MapGIS.OGC.WMS = WMS;
diff --git a/src/service/OpenGeospatialConsortium/index.js b/src/service/OpenGeospatialConsortium/index.js
@@ -0,0 +1,6 @@
+/**
+ *@module OpenGeospatialConsortium服务
+ */
+import { WMS } from './WMS';
+import { WFS } from './WFS';
+export { WMS, WFS };
diff --git a/src/service/index.js b/src/service/index.js
@@ -424,12 +424,15 @@ export const Info = {
 };
 
 import { WMSCapabilities, WMTSCapabilities, OGCWMTSInfo, OGCWMSInfo } from './OGC';
+import { WMS, WFS } from './OpenGeospatialConsortium';
 
 export const OGC = {
     WMSCapabilities,
     WMTSCapabilities,
     OGCWMTSInfo,
-    OGCWMSInfo
+    OGCWMSInfo,
+    WMS,
+    WFS
 };
 
 import {
