//package com.yb.controller;
|
//
|
//import com.alibaba.fastjson.JSON;
|
//import com.alibaba.fastjson.JSONArray;
|
//import com.alibaba.fastjson.JSONObject;
|
//import com.yb.config.R;
|
//import com.yb.entity.ReqEntity;
|
//import com.yb.helper.RsaHelper;
|
//import com.yb.util.EntityHttpUtil;
|
//import io.swagger.v3.oas.annotations.Operation;
|
//import io.swagger.v3.oas.annotations.Parameter;
|
//import io.swagger.v3.oas.annotations.tags.Tag;
|
//import org.locationtech.jts.geom.*;
|
//import org.locationtech.jts.operation.buffer.BufferOp;
|
//import org.springframework.beans.factory.annotation.Autowired;
|
//import org.springframework.beans.factory.annotation.Value;
|
//import org.springframework.web.bind.annotation.*;
|
//
|
//import java.util.*;
|
//
|
//
|
//@Tag(name = "新智接口")
|
//@RestController
|
//@RequestMapping("/api/v1")
|
//public class XzController2 {
|
// @Autowired
|
// WebSocketController webSocketController;
|
// @Autowired
|
// private EntityHttpUtil entityHttpUtil;
|
// @Value("${spring.geographical.canview}")
|
// String canview;
|
// @Value("${spring.geographical.entityName}")
|
// String entityName;
|
// @Value("${spring.geographical.dbid}")
|
// String dbid;
|
// @Value("${spring.geographical.layerId}")
|
// String layerId;
|
// @Value("${spring.geographical.queryEntity}")
|
// String queryEntity;
|
// @Value("${spring.geographical.publickey}")
|
// String publickey;
|
// @Value("${spring.geographical.token}")
|
// String token;
|
//
|
//
|
// @PostMapping("/poiMap")
|
// @Operation(summary = "显示地点")
|
// public R poiMap(@RequestParam Map<String, String> allParams) throws Exception {
|
// String place = allParams.get("place");
|
// String mid = allParams.get("mid");
|
// System.out.println("rec poiMap:" + place + " mid:" + mid);
|
// if (place == null || mid == null) {
|
// return R.error("数据传递错误");
|
// }
|
// HashMap<String, Object> hash = new HashMap<>();
|
// hash.put("func", "poiMap");
|
// hash.put("mid", mid);
|
// ReqEntity reqEntity = new ReqEntity();
|
// String item = getQueryFiled(place);
|
// JSONObject obj = JSONObject.parseObject(item);
|
// reqEntity.setX(obj.getString("lon"));
|
// reqEntity.setY(obj.getString("lat"));
|
// reqEntity.setPlace(obj.getString("enti_name"));
|
// System.out.println("rec poiMap:" + reqEntity);
|
// hash.put("poi", reqEntity);
|
// String message = JSON.toJSONString(hash);
|
// webSocketController.sendAllMessage(message);
|
// return R.ok(hash);
|
// }
|
//
|
// @PostMapping("/aroundPoi")
|
// @Operation(summary = "周边属性查询")
|
// public R aroundPoi(@RequestParam Map<String, String> allParams) throws Exception {
|
// System.out.println("rec aroundPoi:" + allParams);
|
// String place = allParams.get("place");
|
// String mid = allParams.get("mid");
|
// String type = allParams.get("type");
|
// String dis = allParams.get("radius");
|
// int radius= 0;
|
// if(dis != null){
|
// radius= Integer.parseInt(dis);
|
// }
|
//// int radius = Integer.parseInt();
|
// System.out.println("rec aroundPoi:" + place + " mid:" + mid + " type:" + type + " radius:" + radius);
|
// if (type == null || place == null || mid == null) {
|
// return R.error("数据传递错误");
|
// }
|
// HashMap<String, Object> hash = new HashMap<>();
|
// hash.put("func", "aroundPoi");
|
// hash.put("mid", mid);
|
// System.out.println("rec aroundPoi:" + place + " mid:" + mid + " type:" + type + " radius:" + radius);
|
// String item = getQueryFiled(place);
|
// JSONObject obj = JSONObject.parseObject(item);
|
// Double lon = Double.parseDouble(obj.getString("lon"));
|
// Double lat = Double.parseDouble(obj.getString("lat"));
|
// String wkt = getWKt(lon, lat, radius);
|
// String itemList = getQueryAround(type, wkt);
|
//// System.out.print("ces: "+itemList);
|
// JSONArray dataArray = JSONArray.parseArray(itemList);
|
// ArrayList<ReqEntity> arrayList = new ArrayList<>();
|
// for (int i = 0; i < dataArray.size(); i++) {
|
// Object element = dataArray.get(i);
|
// if (element instanceof JSONObject) {
|
// JSONObject jsonObject = (JSONObject) element;
|
// ReqEntity reqEntity = new ReqEntity();
|
// reqEntity.setX(jsonObject.getString("lon"));
|
// reqEntity.setY(jsonObject.getString("lat"));
|
// reqEntity.setPlace(jsonObject.getString("enti_name"));
|
// arrayList.add(reqEntity);
|
// }
|
// }
|
// System.out.println("rec aroundPoi:" + arrayList);
|
// hash.put("poi", arrayList);
|
// String message = JSON.toJSONString(hash);
|
// webSocketController.sendAllMessage(message);
|
// return R.ok(hash);
|
// }
|
//
|
// @PostMapping("/queryMeta")
|
// @Operation(summary = "元信息查询")
|
// public R queryMeta(@RequestParam Map<String, String> allParams) {
|
// String mid = allParams.get("mid");
|
// System.out.println("rec queryMeta:" +" mid:" + mid);
|
// if (mid == null) {
|
// return R.error("数据传递错误");
|
// }
|
// HashMap<String, Object> hash = new HashMap<>();
|
// hash.put("func", "queryMeta");
|
// hash.put("mid", mid);
|
//// 统计查询接口拼接
|
// JSONArray jsonArray = new JSONArray();
|
// HashMap<String, Object> staticField = new HashMap<>();
|
// String filed = "sjnr";
|
// staticField.put("type", "count");
|
// staticField.put("field", "sjnr");
|
// staticField.put("outfield", "count_" + filed);
|
// jsonArray.add(staticField);
|
// HashMap<String, String> formData = getHashMap();
|
// formData.put("statistics", jsonArray.toString());
|
// formData.put("groupby", filed);
|
// String filedString = entityHttpUtil.getPostMessage(queryEntity, formData);
|
// System.out.println("rec queryMeta:" + filedString);
|
// JSONObject jsonObject = JSON.parseObject(filedString);
|
// JSONArray dataArray = jsonObject.getJSONArray("data");
|
// HashMap<String, Object> markMap = new HashMap<>();
|
// JSONArray markArray = new JSONArray();
|
// String markDown = "| 数据类型 | 数据量 |\\n|------|------|\\n";
|
// for (int i = 0; i < dataArray.size(); i++) {
|
// JSONObject dataObj = dataArray.getJSONObject(i);
|
// System.out.println("rec queryMeta:" + dataObj);
|
// String[] filedValue = new String[2];
|
//
|
// for (String key : dataObj.keySet()) {
|
// if (key == filed) {
|
// filedValue[0] = dataObj.getString(key);
|
// } else {
|
// filedValue[1] = dataObj.getString(key);
|
// }
|
// }
|
// markDown += "| " + filedValue[0] + " | " + filedValue[1] + " |\n";
|
// }
|
//
|
// markMap.put("markdown", markDown);
|
// markArray.add(markMap);
|
// hash.put("markdown", markArray);
|
// hash.put("content", "地理实体数据库");
|
// System.out.println("rec queryMeta:" + hash);
|
// String message = JSON.toJSONString(hash);
|
// webSocketController.sendAllMessage(message);
|
// return R.ok(hash);
|
// }
|
//
|
// public HashMap getHashMap() {
|
// HashMap<String, String> hashMap = new HashMap<>();
|
// hashMap.put("token", token);
|
// hashMap.put("containCount", "true");
|
// hashMap.put("layerid", layerId);
|
// hashMap.put("dbid", dbid);
|
// return hashMap;
|
// }
|
//
|
// 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);
|
// // 创建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;
|
// }
|
//
|
// public String getQueryAround(String type, String wkt) throws Exception {
|
// String query = "sjnr like '%" + type + "%'" + "";
|
// String key = getPublickey();
|
// String encrypt = RsaHelper.encrypt(key, query);
|
// HashMap formData = getHashMap();
|
// formData.put("start", "1");
|
// formData.put("count", "0");
|
// formData.put("where", encrypt);
|
// formData.put("box", wkt);
|
// String jsonString = entityHttpUtil.getPostMessage(queryEntity, formData);
|
// JSONObject jsonObject = JSON.parseObject(jsonString);
|
// JSONObject dataObjject = jsonObject.getJSONObject("data");
|
// JSONArray dataArray = dataObjject.getJSONArray("items");
|
// return dataArray.toString();
|
// }
|
//
|
// //关键字查询
|
// public String getQueryFiled(String place) throws Exception {
|
// String query = "enti_name like '%" + place + "%'" + "";
|
// String key = getPublickey();
|
// String encrypt = RsaHelper.encrypt(key, query);
|
// HashMap formData = getHashMap();
|
// formData.put("start", "1");
|
// formData.put("count", "0");
|
// formData.put("where", encrypt);
|
// String jsonString = entityHttpUtil.getPostMessage(queryEntity, formData);
|
// JSONObject jsonObject = JSON.parseObject(jsonString);
|
// JSONObject dataObjject = jsonObject.getJSONObject("data");
|
// JSONArray dataArray = dataObjject.getJSONArray("items");
|
// return dataArray.getJSONObject(0).toString();
|
// }
|
//
|
// //获取秘钥接口
|
// public String getPublickey() {
|
// HashMap<String, String> map = new HashMap<>();
|
// map.put("token", token);
|
// String jsonString = entityHttpUtil.getPostMessage(publickey, map);
|
// JSONObject jsonObject = JSON.parseObject(jsonString);
|
// return jsonObject.getString("data");
|
// }
|
//
|
//
|
// @PostMapping("/aroundPoi2")
|
// @Operation(summary = "周边查询")
|
// public R aroundPoi2(@RequestBody ReqEntity reqEntity) {
|
// System.out.println("rec message:" + reqEntity);
|
// HashMap<String, Object> hash = new HashMap<>();
|
// hash.put("func", "aroundPoi");
|
// hash.put("mid", "mid");
|
// List<ReqEntity> list = new ArrayList<>();
|
//// reqEntity.setX("120.9671");
|
//// reqEntity.setY("13.5748");
|
// list.add(reqEntity);
|
// list.add(reqEntity);
|
// hash.put("poi", list);
|
//
|
// String message = JSON.toJSONString(hash);
|
// webSocketController.sendAllMessage(message);
|
//
|
// return R.ok(hash);
|
// }
|
//
|
//
|
// /*@GetMapping("/queryPath/{start_point}/{end_point}")
|
// @Operation(summary = "路线查询")
|
// public R queryPath(@PathVariable("start_point")String start_point,@PathVariable("end_point")String end_point){
|
// System.out.println("rec start_point: "+start_point+" end_point: "+end_point);
|
// HashMap<String,Object> hash = new HashMap<>();
|
//
|
// hash.put("func","searchPath");
|
// List<ReqEntity> list = new ArrayList<>();
|
//
|
// hash.put("path",list);
|
//
|
// String message = JSON.toJSONString(hash);
|
// webSocketController.sendAllMessage(message);
|
//
|
// return R.ok(hash);
|
// }
|
//*/
|
// @PostMapping("/queryMeta2")
|
// @Operation(summary = "元信息查询")
|
// public R queryMeta2(@Parameter String mid) {
|
// System.out.println("queryMeta ");
|
// HashMap<String, Object> hash = new HashMap<>();
|
// hash.put("func", "queryMeta");
|
// hash.put("mid", mid);
|
// List<ReqEntity> list = new ArrayList<>();
|
// hash.put("meta", list);
|
// String message = JSON.toJSONString(hash);
|
// webSocketController.sendAllMessage(message);
|
//
|
// return R.ok(hash);
|
// }
|
//}
|
