/* Copyright© 2000 - 2026 SuperMap Software Co.Ltd. All rights reserved.
 * This program are made available under the terms of the Apache License, Version 2.0
 * which accompanies this distribution and is available at http://www.apache.org/licenses/LICENSE-2.0.html.*/
import { Util } from '../commontypes/Util';
import { CommonServiceBase } from './CommonServiceBase';

/**
 * @class KnowledgeGraphService
 * @category iServer KnowledgeGraph
 * @classdesc 知识图谱服务类。知识图谱是知识表示的一种形式,是由具有属性的实体通过关系链接而成的网状知识库。
 * 图谱数据和常规结构化表格数据相比,具有强大的数据描述能力,可以实现更快更高效的查询,更快更精准的数据关联性推理运算和隐藏关系的挖掘。
 * 提供方法:获取图谱图序列化数据、获取图谱列表、查询知识图谱数据、将 SuperMap iServer GraphMap 服务的数据格式转换为 KnowledgeGraph 的数据格式。
 * @version 11.1.0
 * @extends {ProcessingServiceBase}
 * @param {string} url - 服务地址。
 * @param {Object} options - 可选参数。
 * @param {string} [options.proxy] - 服务代理地址。
 * @param {boolean} [options.withCredentials] - 请求是否携带凭据。默认情况下,仅同源请求包含凭据。
 * @param {boolean} [options.crossOrigin] - 是否允许跨域请求。
 * @param {Object} [options.headers] - 请求头。
 * @usage
 */
export class KnowledgeGraphService extends CommonServiceBase {
 constructor(url, options) {
 super(url, options);
 this.options = options || {};
 this.CLASS_NAME = 'SuperMap.KnowledgeGraphService';
 }

 /**
 * @function KnowledgeGraphService.prototype.destroy
 * @override
 */
 destroy() {
 super.destroy();
 }

 /**
 * @function KnowledgeGraphService.prototype.findShortestPath
 * @description 获取开始节点和结束节点之间的最短路径。
 * @param {KnowledgeGraphService.findShortestPathParams} params - 参数。
 * @param {RequestCallback} [callback] - 回调函数,该参数未传时可通过返回的 promise 获取结果。
 */
 findShortestPath(params, callback) {
 const url = this.url + `/shortestPath.json?startID=${params.startID}&endID=${params.endID}`;
 this.processAsync({ url, method: 'GET', callback });
 }

 /**
 * @function KnowledgeGraphService.prototype.query
 * @description 通过查询语句查询知识图谱数据。
 * @param {string} params - 查询条件。
 * @param {RequestCallback} [callback] - 回调函数,该参数未传时可通过返回的 promise 获取结果。
 */
 query(params, callback) {
 const paramKey = 'cypherQuery';
 const url = Util.urlAppend(this.url + '/query.json', `${paramKey}=${encodeURI(params)}`);
 this.processAsync({ url, method: 'GET', callback });
 }

 // /**
 // * @function KnowledgeGraphService.prototype.queryById
 // * @description 根据实体id查询关联节点。
 // * @param {string} id - 实体id。
 // * @param {RequestCallback} callback 回调函数。
 // */
 // queryById(id, callback) {
 // const paramKey = 'cypherQuery';
 // const url = Util.urlAppend(this.url + '/query.json', `${paramKey}=match p=(n)-[]-(m) where id(n)=${id} return p;`);
 // this.processAsync({ url, method: 'GET', callback });
 // }

 // /**
 // * @function KnowledgeGraphService.prototype.getMetaData
 // * @description 获取元信息(展示所有实体类型和关系类型。)
 // * @param {RequestCallback} callback 回调函数。
 // */
 // getMetaData(callback) {
 // const url = this.url + 'management/metadata.json';
 // this.processAsync({ url, method: 'GET', callback });
 // }

 /**
 * @function KnowledgeGraphService.prototype.getGraphMaps
 * @description 获取图谱列表。
 * @param {RequestCallback} [callback] - 回调函数,该参数未传时可通过返回的 promise 获取结果。
 */
 getGraphMaps(callback) {
 const url = this.url + '/graphmaps.json';
 this.processAsync({ url, method: 'GET', callback });
 }

 /**
 * @function KnowledgeGraphService.prototype.getGraphMap
 * @description 获取图谱图序列化数据。
 * @param {string} graphMapName 图谱名称。
 * @param {RequestCallback} callback 回调函数。
 */
 getGraphMap(graphMapName, callback) {
 const url = this.url + `/graphmaps/${graphMapName}.json`;
 this.processAsync({ url, method: 'GET', callback });
 }

 /**
 * @function KnowledgeGraphService.prototype.getGraphMapData
 * @description 将 SuperMap iServer GraphMap 服务的数据格式转换为 KnowledgeGraph 的数据格式。
 * @param {string} graphMapName - 图谱名称。
 * @returns {Promise} Promise 对象。
 */
 async getGraphMapData(graphMapName) {
 let data = [];
 const graphMap = await this._getGraphMapData(graphMapName);
 if (!graphMap) {
 return;
 }
 const query = (graphMap.dataContent.queries && graphMap.dataContent.queries.query) || [];
 let queries = [];
 if (typeof query === 'string') {
 queries = [query];
 } else {
 queries = query;
 }
 const expandQueries = this._getGraphMapExpandQuery(graphMap);
 if (expandQueries.length) {
 queries.push(...expandQueries);
 }
 for (let j = 0; j < queries.length; j++) {
 const cypherQuery = queries[j];
 const res = await this._queryDataBySql(cypherQuery);
 data = data.concat([], res);
 }
 return { data, graphMap };
 }

 /**
 * @private
 * @function KnowledgeGraphService.prototype._getGraphMapExpandQuery
 * @description 获取 GraphMap 图谱展开节点的 query 条件。
 * @param {Object} graphMap -将 iServer GraphMap 图谱服务的数据。
 * @param {Array.<string>} 查询条件。
 */
 _getGraphMapExpandQuery(graphMap) {
 const queries = [];
 const expandIds = (graphMap.dataContent.expand && JSON.parse(graphMap.dataContent.expand)) || [];
 expandIds.forEach((id) => {
 queries.push(`match p=(n)-[]-(m) where id(n)=${id} return p;`);
 });
 return queries;
 }

 // /**
 // * @private
 // * @function KnowledgeGraphService.prototype.getEntities
 // * @description 获取实体。
 // * @param {Object} params - 查询条件。{type:'院落', count:1}
 // * @param {number} [params.count] - 返回个数
 // * @param {RequestCallback} callback 回调函数
 // */
 // getEntities(params, callback) {
 // const url = Util.urlAppend(this.url + '/entities.json', params);
 // this.processAsync({ url, params, method: 'GET', callback });
 // }

 // /**
 // * @private
 // * @function KnowledgeGraphService.prototype.getEdges
 // * @description 获取实体。
 // * @param {Object} params - 查询条件。{type:'院落', count:1}
 // * @param {number} [params.count] - 返回个数
 // * @param {RequestCallback} callback 回调函数
 // */
 // getEdges(params, callback) {
 // const url = Util.urlAppend(this.url + '/edges.json', params);
 // this.processAsync({ url, params, method: 'GET', callback });
 // }

 // /**
 // * @private
 // * @function KnowledgeGraphService.prototype.getEntities
 // * @description 获取实体。
 // * @param {number} id - 查询条件。{type:'院落', count:1}
 // * @param {RequestCallback} callback 回调函数
 // */
 // deleteEntitiy(id, callback) {
 // const url = Util.urlAppend(this.url + '/entities.json', `id=${id}`);
 // this.processAsync({ url, method: 'DELETE', callback });
 // }

 // /**
 // * @private
 // * @function KnowledgeGraphService.prototype.addNode
 // * @description 获取实体。
 // * @param {Object} params - 查询条件
 // * @param {number} [params.count] - 返回个数
 // * @param {RequestCallback} callback 回调函数
 // */
 // addNode(params, callback) {
 // if (!(params instanceof KnowledgeGraphNodeParameter)) {
 // return;
 // }
 // const url = Util.urlAppend(this.url + '/entities.json', params);
 // this.processAsync({ url, params, method: 'PUT', callback });
 // }

 // /**
 // * @private
 // * @function KnowledgeGraphService.prototype.addEdge
 // * @description 获取实体。
 // * @param {Object} params - 查询条件
 // * @param {number} [params.count] - 返回个数
 // * @param {RequestCallback} callback 回调函数
 // */
 // addEdge(params, callback) {
 // if (!(params instanceof KnowledgeGraphEdgeParameter)) {
 // return;
 // }
 // const url = Util.urlAppend(this.url + '/edges.json', params);
 // this.processAsync({ url, params, method: 'PUT', callback });
 // }
 /**
 * @function KnowledgeGraphService.prototype.processAsync
 * @description 负责将客户端的动态分段服务参数传递到服务端。
 * @param {string} url - 服务地址。
 * @param {Object} params - 参数。
 * @param {RequestCallback} [callback] - 回调函数,该参数未传时可通过返回的 promise 获取结果。
 * @returns {Promise} Promise 对象。
 */

 processAsync({ url, params, method, callback }) {
 const requestParams = {
 method,
 url,
 scope: this,
 success: callback,
 failure: callback
 };
 if (params) {
 requestParams.params = params;
 }
 return this.request(requestParams);
 }
 /**
 * @private
 * @function _getGraphMapData
 * @description 获取图谱信息。
 * @param {string} graphMapName - 图谱名称。
 * @returns {Promise} Promise 对象。
 */
 _getGraphMapData(graphMapName) {
 return new Promise((resolve, reject) => {
 this.getGraphMap(graphMapName, (res) => {
 if (res.type === 'processFailed') {
 reject(res.error);
 } else {
 if (res.result.data === '') {
 reject('无数据');
 } else {
 resolve(res.result.graphMap);
 }
 }
 });
 });
 }

 /**
 * @private
 * @function _queryDataBySql
 * @description 查询实体和关系数据。
 * @param {string} cypherQuery - 查询语句。
 * @returns {Promise} Promise 对象。
 */
 _queryDataBySql(cypherQuery) {
 return new Promise((resolve, reject) => {
 this.query(cypherQuery, (res) => {
 if (res.type === 'processFailed') {
 reject(res.error);
 } else {
 resolve(res.result);
 }
 });
 });
 }
}