API名称：[元数据查询]接口添加

suerprisePlus

2024-08-28 ccc0c29ff83aafea87a6d3f3bca3ef9e0aa8268a

API名称：[元数据查询]接口添加

 src/main/java/com/yb/controller/XzController.java

@@ -19,6 +19,7 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;
import org.stringtemplate.v4.ST;


import java.util.ArrayList;
@@ -49,10 +50,7 @@
    String publickey;
    @Value("${spring.geographical.token}")
    String token;
    private JSONObject jsonObject;
    private JSONObject dataObjject;
    private Coordinate coord;
    private Object filObj;


    @PostMapping("/poiMap")
    @Operation(summary = "显示地点")
@@ -66,7 +64,6 @@
        JSONObject obj = JSONObject.parseObject(item);
        reqEntity.setX(obj.getString("lon"));
        reqEntity.setY(obj.getString("lat"));
//        System.out.print(obj);
        reqEntity.setPlace(obj.getString("enti_name"));
        System.out.println("rec message:" +reqEntity);
        hash.put("poi", reqEntity);
@@ -76,12 +73,11 @@
    }

    @PostMapping("/aroundPoi")
    @Operation(summary = "显示地点")
    @Operation(summary = "周边属性查询")
    public R aroundPoi(@Parameter String place, @Parameter String mid, @Parameter String type, @Parameter int radius) throws Exception {

        System.out.println("rec message:" + place + "  mid:" + mid + "  type:" + type + "  radius:" + radius);
        HashMap<String, Object> hash = new HashMap<>();
        hash.put("func", "aroundpoi");
        hash.put("func", "aroundPoi");
        hash.put("mid", mid);
        String item = getQueryFiled(place);
        JSONObject obj = JSONObject.parseObject(item);
@@ -93,7 +89,6 @@
        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;
@@ -106,6 +101,60 @@
        }
        System.out.println("rec message:" +arrayList);
        hash.put("poi", arrayList);
        String message = JSON.toJSONString(hash);
        webSocketController.sendAllMessage(message);
        return R.ok(hash);
    }

    @PostMapping("/queryMeta")
    @Operation(summary = "元信息查询")
    public R queryMeta(@Parameter String mid) {
        System.out.println("queryMeta");
        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 = new HashMap<>();
        formData.put("token", token);
        formData.put("containCount", "true");
        formData.put("layerid", layerId);
        formData.put("dbid", dbid);
        formData.put("statistics", jsonArray.toString());
        formData.put("groupby", filed);
        String filedString = entityHttpUtil.getPostMessage(queryEntity, formData);
        System.out.println("rec message:" + 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 message:" + 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 message:" + hash);
        String message = JSON.toJSONString(hash);
        webSocketController.sendAllMessage(message);
        return R.ok(hash);
@@ -163,6 +212,7 @@
        JSONArray dataArray = dataObjject.getJSONArray("items");
        return dataArray.toString();
    }

    //关键字查询
    public String getQueryFiled(String place) throws Exception {
        String query = "enti_name like '%" + place + "%'" + "";
@@ -213,6 +263,7 @@
        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){
@@ -230,9 +281,9 @@
        return R.ok(hash);
    }
*/
    @PostMapping("/queryMeta")
    @PostMapping("/queryMeta2")
    @Operation(summary = "元信息查询")
    public R queryMeta(@Parameter String mid) {
    public R queryMeta2(@Parameter String mid) {
        System.out.println("queryMeta ");
        HashMap<String, Object> hash = new HashMap<>();
        hash.put("func", "queryMeta");

 target/classes/com/yb/controller/XzController.class

Binary files differ

 target/ollama-ai-0.0.1-SNAPSHOT.jar

Binary files differ

 target/ollama-ai-0.0.1-SNAPSHOT.jar.original

Binary files differ