/**
|
* 查询搜索
|
* @author Liuyl
|
* @date 2015/10/30
|
*/
|
define([
|
"dojo/_base/declare", "dojo/_base/array", "dojo/_base/lang",
|
"dojo/json", "dojo/request", "dojo/request/script",
|
"esri/tasks/query", "esri/tasks/QueryTask", "esri/tasks/StatisticDefinition",
|
"base/AppEvent", "base/ConfigData"
|
], function(
|
declare, arrayUtil, lang,
|
JSON, request, script,
|
Query, QueryTask, StatisticDefinition,
|
AppEvent, ConfigData
|
) {
|
return declare("QueryManager", null, {
|
QueryArguments: declare(null, {
|
constructor: function(props) {
|
|
this.type = null;
|
this.extent = null;
|
this.poiType = null;
|
this.keyword = null;
|
this.returnGeometry = true;
|
this.outSpatialReference = null;
|
$.extend(true, this, props);
|
}
|
}),
|
defaultOptions: {
|
poi_service: "http://www.servicelnditu.com/OneMapServer/rest/services/poi2015/MapServer/0",
|
poi_service_fgdb: "http://www.servicelnditu.com/OneMapServer/rest/services/poi2015/MapServer/0",
|
poi_keyword_field: "NAME",
|
poi_pinyin_field: "NAMEPY",
|
poi_type1_field: "TYPE1",
|
poi_type2_field: "TYPE2",
|
poi_pac_field: "PACSHI",
|
poi_fields: {
|
"OBJECTID": "",
|
"NAME": "名称",
|
"NAMEPY": "拼音",
|
"ADDNAME": "地址",
|
"TELEPHONE": "电话"
|
},
|
result_widget_name: "QueryResultWidget",
|
smartquery_service: "../ProxyServlet?http://www.lnditu.gov.cn/SmartQueryService/rest/query/smartquery"
|
|
},
|
constructor: function(options) {
|
this.options = {};
|
$.extend(true, this.options, this.defaultOptions, options);
|
AppEvent.addAppEventListener(AppEvent.CONFIG_LOADED, lang.hitch(this, this.onConfigLoaded));
|
AppEvent.addAppEventListener(AppEvent.BASE_MAP_LAYER_LOADED, lang.hitch(this, this.onMapLoaded));
|
AppEvent.addAppEventListener(AppEvent.RUN_QUERY, lang.hitch(this, function(evt) {
|
this.query(evt);
|
}));
|
AppEvent.addAppEventListener(AppEvent.RUN_SMART_QUERY, lang.hitch(this, function(evt) {
|
this.smartQueryFromPoi(evt);
|
}));
|
this.newestQueryId = null;
|
},
|
onConfigLoaded: function() {},
|
onMapLoaded: function(map) {
|
this._map = map;
|
},
|
smartQuery: function(evt) {
|
//var queryString = this._parseQueryString(evt);
|
try {
|
request.get(this.options.smartquery_service + this._parseQueryString(evt.args), {
|
handleAs: "json"
|
}).then(function(data) {
|
AppEvent.dispatchAppEvent(AppEvent.QUERY_SUCCESS, {
|
hockId: evt.hockId,
|
result: data
|
});
|
},
|
function(error) {
|
AppEvent.dispatchAppEvent(AppEvent.QUERY_ERROR, {
|
hockId: evt.hockId,
|
error: error
|
});
|
});
|
} catch (err) {
|
AppEvent.dispatchAppEvent(AppEvent.QUERY_ERROR, {
|
hockId: evt.hockId,
|
error: err
|
});
|
}
|
|
},
|
_parseQueryString: function(argsObject) {
|
var queryString = "?";
|
arrayUtil.forEach(Object.keys(argsObject), function(item, index) {
|
if (queryString != "?") {
|
queryString += "&";
|
}
|
queryString += item + "=" + JSON.stringify(argsObject[item]);
|
});
|
return queryString;
|
},
|
smartQueryFromPoi: function(evt) {
|
try {
|
var url = this.options.poi_service;
|
var query = new Query();
|
query.where = this._parsePoiWhereString(evt.args.keyword);
|
query.outFields = Object.keys(this.options.poi_fields);
|
query.returnGeometry = false;
|
query.start = 0;
|
query.num = 10;
|
var queryTask = new QueryTask(url);
|
queryTask.execute(query, lang.hitch(this, function(result) {
|
var data = {
|
count: 0,
|
items: []
|
};
|
if (result.features) {
|
for (var key in result.features) {
|
if (!result.features[key].attributes.ADDNAME || !result.features[key].attributes.NAME)
|
continue;
|
data.items[data.count] = {
|
adress: result.features[key].attributes.ADDNAME,
|
name: result.features[key].attributes.NAME,
|
id: ""
|
};
|
data.count++;
|
if (data.count >= 10)
|
break;
|
}
|
}
|
|
AppEvent.dispatchAppEvent(AppEvent.QUERY_SUCCESS, {
|
hockId: evt.hockId,
|
result: {
|
data: data
|
}
|
});
|
}), lang.hitch(this, function(err) {
|
AppEvent.dispatchAppEvent(AppEvent.QUERY_ERROR, {
|
hockId: evt.hockId,
|
error: err
|
});
|
}));
|
} catch (err) {
|
AppEvent.dispatchAppEvent(AppEvent.QUERY_ERROR, {
|
hockId: evt.hockId,
|
error: err
|
});
|
}
|
|
},
|
_parsePoiWhereString: function(keyword) {
|
var whereSql = "";
|
if (keyword) {
|
if ((/[\u4e00-\u9fa5]+/).test(keyword)) {
|
whereSql = this.options.poi_keyword_field + " like '%" + keyword + "%'";
|
} else {
|
whereSql = "lower(" + this.options.poi_pinyin_field + ") like '%" + keyword.toLowerCase() + "%'";
|
}
|
}
|
return whereSql;
|
},
|
query: function(evt) {
|
try {
|
var queryArgs = new this.QueryArguments();
|
$.extend(true, queryArgs, evt);
|
|
this._do_query(queryArgs);
|
} catch (err) {
|
this._errorCallback(err, {
|
hockId: evt.hockId
|
});
|
}
|
},
|
_do_query: function(queryArgs) {
|
switch (queryArgs.type) {
|
case "statistics":
|
this.queryPoiForDistrictStatistics(queryArgs,
|
lang.hitch(this, this._resultCallback),
|
lang.hitch(this, this._errorCallback)
|
);
|
break;
|
case "search":
|
queryArgs.id = uuid();
|
this.newestQueryId = queryArgs.id;
|
|
this.queryPoiForExtent(queryArgs,
|
lang.hitch(this, this._resultCallback),
|
lang.hitch(this, this._errorCallback)
|
);
|
break;
|
case "poiId":
|
queryArgs.id = uuid();
|
this.newestQueryId = queryArgs.id;
|
|
this.queryPoiForExtent(queryArgs,
|
lang.hitch(this, this._resultCallback),
|
lang.hitch(this, this._errorCallback)
|
);
|
break;
|
default:
|
break;
|
}
|
},
|
|
_resultCallback: function(result, qArgs) {
|
if (qArgs.id && this.newestQueryId != qArgs.id) {
|
return;
|
}
|
AppEvent.dispatchAppEvent(AppEvent.QUERY_SUCCESS, {
|
hockId: qArgs.hockId,
|
result: result,
|
type: result.type
|
});
|
},
|
_errorCallback: function(err, qArgs) {
|
if (this.newestQueryId == qArgs.id) {
|
AppEvent.dispatchAppEvent(AppEvent.QUERY_ERROR, {
|
hockId: qArgs.hockId,
|
error: err
|
});
|
}
|
},
|
queryPoiForDistrictStatistics: function(qArgs, resultCallback, errorCallback) {
|
var query = new Query();
|
var queryTask = new QueryTask(this.options.poi_service);
|
query.extent = null;
|
query.where = this._parseWhereSql(qArgs);
|
var statisticDefinition = new StatisticDefinition();
|
statisticDefinition.statisticType = "count";
|
statisticDefinition.onStatisticField = "OBJECTID";
|
statisticDefinition.outStatisticFieldName = "COUNT";
|
|
query.outStatistics = [statisticDefinition];
|
query.groupByFieldsForStatistics = ["PACSHI"];
|
if (qArgs.extent) {
|
query.outSpatialReference = qArgs.extent.spatialReference
|
} else {
|
query.outSpatialReference = this._map.spatialReference;
|
}
|
query.outFields = ["PACSHI", "COUNT"];
|
|
queryTask.execute(query, lang.hitch(this, function(result) {
|
result.type = qArgs.type;
|
result.poiType = qArgs.poiType;
|
result.keyword = qArgs.keyword;
|
resultCallback(result, qArgs);
|
}), lang.hitch(this, function(err) {
|
errorCallback(err, qArgs);
|
}));
|
},
|
queryPoiForExtent: function(qArgs, resultCallback, errorCallback) {
|
var url = this.options.poi_service;
|
var query = new Query();
|
|
if (qArgs.poiId) {
|
query.objectIds = [qArgs.poiId];
|
} else {
|
query.where = this._parseWhereSql(qArgs);
|
}
|
if (qArgs.extent) {
|
query.outSpatialReference = qArgs.extent.spatialReference;
|
if (qArgs.extent && !qArgs.extent.hasOwnProperty("xmin")) {
|
query.geometry = qArgs.extent;
|
url = this.options.poi_service_fgdb;
|
}
|
|
} else {
|
query.outSpatialReference = this._map.spatialReference;
|
}
|
query.outFields = Object.keys(this.options.poi_fields);
|
query.returnGeometry = qArgs.returnGeometry;
|
var queryTask = new QueryTask(url);
|
queryTask.execute(query, lang.hitch(this, function(result) {
|
result.type = qArgs.type;
|
result.extent = qArgs.extent;
|
resultCallback(result, qArgs);
|
}), lang.hitch(this, function(err) {
|
errorCallback(err, qArgs);
|
}));
|
},
|
_parseWhereSql: function(qArgs) {
|
var _whereSql = _linkWhereSql("and",
|
_parsePoiCodeWhereSql.call(this, qArgs.poiType),
|
_parseExtentWhereSql.call(this, qArgs.extent));
|
_whereSql = _linkWhereSql("and",
|
_whereSql,
|
//_parseKeywordWhereSql.call(this, qArgs.keyword)
|
this._parsePoiWhereString(qArgs.keyword)
|
);
|
|
return _whereSql;
|
|
|
|
function _linkWhereSql(type, sql1, sql2) {
|
if (!sql1)
|
return sql2;
|
if (!sql2)
|
return sql1;
|
return "( " + sql1 + " ) " + type + " ( " + sql2 + " )";
|
}
|
|
function _parseExtentWhereSql(extent) {
|
if (extent && extent.hasOwnProperty("xmin"))
|
return "LON>" + extent.xmin + " and LON<" + extent.xmax + " and LAT>" + extent.ymin + " and LAT<" + extent.ymax;
|
else
|
return "";
|
}
|
|
function _parsePoiCodeWhereSql(type) {
|
if (type) {
|
if (type.length == 2) {
|
return this.options.poi_type1_field + " = '" + type + "'";
|
} else if (type.length == 4) {
|
return this.options.poi_type2_field + " = '" + type + "'";
|
}
|
|
}
|
return "";
|
}
|
|
function _parseKeywordWhereSql(keyword) {
|
if (keyword) {
|
return this.options.poi_keyword_field + " like '%" + keyword + "%'";
|
}
|
return "";
|
}
|
}
|
});
|
});
|
