package com.yb.service;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.yb.config.XzConfig;
|
import com.yb.helper.RsaHelper;
|
import com.yb.util.EntityHttpUtil;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.locationtech.jts.geom.*;
|
import org.locationtech.jts.operation.buffer.BufferOp;
|
|
|
import java.util.*;
|
import java.util.HashMap;
|
|
@Service
|
public class XzService {
|
@Autowired
|
private XzConfig xzConfig;
|
@Autowired
|
private EntityHttpUtil entityHttpUtil;
|
@Autowired
|
private AgentService agentService;
|
|
// 关键字查询
|
public String getQueryFiled(String place, String filed, String layerId, String dbId, String queryEntity) throws Exception {
|
String query = filed + " like '%" + place + "%'" + "";
|
String key = getPublickey();
|
String encrypt = RsaHelper.encrypt(key, query);
|
HashMap formData = getHashMap(layerId, dbId, "1", "0", encrypt, null);
|
String jsonString = entityHttpUtil.getPostMessage(queryEntity, formData);
|
System.out.println("rec getQueryFiled:" + jsonString);
|
JSONObject jsonObject = JSON.parseObject(jsonString);
|
JSONObject dataObjject = jsonObject.getJSONObject("data");
|
JSONArray dataArray = dataObjject.getJSONArray("items");
|
if (dataArray.size() > 0) {
|
return dataArray.getJSONObject(0).toString();
|
}
|
return "";
|
}
|
|
// 关键字查询
|
public String getQueryEntity(String place, String filed, String layerId, String dbId, String queryEntity) throws Exception {
|
String query = filed + " like '%" + place + "%'" + "";
|
String key = getPublickey();
|
String encrypt = RsaHelper.encrypt(key, query);
|
HashMap formData = getHashMap(layerId, dbId, "1", "100", encrypt, null);
|
formData.put("querytype", "entity");
|
String jsonString1 = entityHttpUtil.getPostMessage(queryEntity, formData);
|
System.out.println("rec getQueryFiled:" + jsonString1);
|
JSONObject jsonObject = JSON.parseObject(jsonString1);
|
JSONObject dataObjject = jsonObject.getJSONObject("data");
|
JSONArray dataArray = dataObjject.getJSONArray("items");
|
if(dataArray.size()<=0){
|
return null;
|
}
|
return dataArray.getJSONObject(0).toString();
|
|
|
}
|
|
// 范围查询
|
public String getQueryAround(String type, String wkt, String filed, String layerId, String dbid, String entity) throws Exception {
|
String query = filed + " like '%" + type + "%'" + "";
|
String encrypt = RsaHelper.encrypt(getPublickey(), query);
|
HashMap formData = getHashMap(layerId, dbid, "1", "0", encrypt, wkt);
|
String jsonString = entityHttpUtil.getPostMessage(entity, formData);
|
JSONObject jsonObject = JSON.parseObject(jsonString);
|
JSONObject dataObj = jsonObject.getJSONObject("data");
|
JSONArray dataArray = dataObj.getJSONArray("items");
|
return dataArray.toString();
|
|
}
|
|
//元信息查询
|
public String getQueryMeta(String layerId, String dbid, String filed, String entity) {
|
HashMap<String, Object> staticField = new HashMap<>();
|
JSONArray jsonArray = new JSONArray();
|
staticField.put("type", "count");
|
staticField.put("field", filed);
|
staticField.put("outfield", "count_" + filed);
|
jsonArray.add(staticField);
|
HashMap<String, String> formData = getHashMap(layerId, dbid, null, null, null, null);
|
formData.put("statistics", jsonArray.toString());
|
formData.put("groupby", filed);
|
return entityHttpUtil.getPostMessage(entity, formData);
|
}
|
|
// 获取返回信息Map
|
public HashMap<String, Object> getFuncMap(String func, String mid) {
|
HashMap<String, Object> hash = new HashMap<String, Object>();
|
hash.put("func", func);
|
hash.put("mid", mid);
|
return hash;
|
}
|
|
//获取秘钥接口
|
public String getPublickey() {
|
HashMap<String, String> map = new HashMap<>();
|
map.put("token", xzConfig.token);
|
String jsonString = entityHttpUtil.getPostMessage(xzConfig.publickey, map);
|
JSONObject jsonObject = JSON.parseObject(jsonString);
|
return jsonObject.getString("data");
|
}
|
|
// 传参
|
public HashMap<String, String> getHashMap(String layerId, String dbid, String start, String count, String where, String box) {
|
HashMap<String, String> hashMap = new HashMap<>();
|
hashMap.put("token", xzConfig.token);
|
hashMap.put("containCount", "true");
|
hashMap.put("layerid", layerId);
|
hashMap.put("dbid", dbid);
|
if (start != null && start != "") {
|
hashMap.put("start", start);
|
}
|
if (count != null && count != "") {
|
hashMap.put("count", count);
|
}
|
if (where != null && where != "") {
|
hashMap.put("where", where);
|
}
|
if (box != null && box != "") {
|
hashMap.put("box", box);
|
}
|
|
return hashMap;
|
}
|
|
//生成WKT
|
public String getWKt(double lon, double lat, int radius) {
|
// 创建一个坐标点
|
Coordinate coord = new Coordinate(lon, lat);
|
// 创建GeometryFactory实例，并指定坐标参考系统为WGS84
|
GeometryFactory geometryFactory = new GeometryFactory(new PrecisionModel(), 4326);
|
// 使用坐标创建一个点
|
Point point = geometryFactory.createPoint(coord);
|
// 创建BufferOp实例，用于生成缓冲区
|
BufferOp bufferOp = new BufferOp(point);
|
int dis = 500;
|
if (radius != 0) {
|
dis = radius;
|
}
|
// 设置缓冲区距离为500米
|
Geometry bufferedGeometry = bufferOp.getResultGeometry(dis / 111319.9);
|
// 创建WKTWriter实例，用于将Geometry转换为WKT格式
|
// WKTWriter wktWriter = new WKTWriter();
|
|
// 将缓冲区Geometry转换为WKT格式
|
// String wkt = wktWriter.write(bufferedGeometry);
|
// 输出WKT
|
// System.out.println("WKT: " + wkt);
|
Envelope envelope = bufferedGeometry.getEnvelopeInternal();
|
double[] wkt = new double[4];
|
wkt[0] = envelope.getMinX();
|
wkt[1] = envelope.getMinY();
|
wkt[2] = envelope.getMaxX();
|
wkt[3] = envelope.getMaxY();
|
String arrayAsString = Arrays.toString(wkt);
|
System.out.println("arrayAsString: " + arrayAsString);
|
return arrayAsString;
|
}
|
|
|
}
|
