suerprisePlus
2024-12-17 d4e4ea6405756d495806a609e24ae85ebd7345ef
src/main/java/com/yb/service/AgentService.java
@@ -29,8 +29,8 @@
        return obj;
    }
    public String getAgentIntention(String url, String api, String msg,String sessionid,String libid) throws Exception {
        String http = url + api +"?session_id="+sessionid+ "&lib_id=" + libid+ "&message=" + msg;
    public String getAgentIntention(String url, String api, String msg, String sessionid, String libid) throws Exception {
        String http = url + api + "?session_id=" + sessionid + "&lib_id=" + libid + "&message=" + msg;
        System.out.println("rec getMessage:" + http);
        String obj = entityHttpUtil.getAgentMessage(http);
        System.out.println("rec getMessage:" + obj);
@@ -78,15 +78,18 @@
        for (int i = 0; i < relationArry.size(); i++) {
            JSONObject relationtem = relationArry.getJSONObject(i);
            String name = relationtem.getString("name");
            if (name.equals("包含关系")) {
//            if (name.equals("包含")) {
//                itemObj = relationtem;
//            }
            if (name.contains(String.valueOf("包含"))) {
                itemObj = relationtem;
            }
        }
        String distanceUrl = xzConfig.relationDistinct + "?dbid=" + xzConfig.dbid + "&token=" + xzConfig.token + "&relationid=" + itemObj.getString("code");
        String relationDistance = entityHttpUtil.getMessage(distanceUrl);
        JSONObject distanceObj = JSONObject.parseObject(relationList);
        String distanceData = relattionObj.getString("data");
        System.out.println("rec getQueryRelationship:" + distanceData);
//        String distanceUrl = xzConfig.relationDistinct + "?dbid=" + xzConfig.dbid + "&token=" + xzConfig.token + "&relationid=" + itemObj.getString("code");
//        String relationDistance = entityHttpUtil.getMessage(distanceUrl);
//        JSONObject distanceObj = JSONObject.parseObject(relationList);
//        String distanceData = relattionObj.getString("data");
//        System.out.println("rec getQueryRelationship:" + distanceData);
        String relateddataeUrl = xzConfig.relationRelateddata + "?start=1&count=1000000&&a_like=&b_like=&dbid=" + xzConfig.dbid + "&token=" + xzConfig.token + "&relationid=" + itemObj.getString("code");
        String relationRelateddata = entityHttpUtil.getMessage(relateddataeUrl);
@@ -103,7 +106,7 @@
        HashMap<String, String> reMap = new HashMap<String, String>();
        reMap.put("token", xzConfig.token);
        reMap.put("dbid", xzConfig.dbid);
        reMap.put("businessids", list.toString());
        reMap.put("ids", list.toString());
        reMap.put("layerid", xzConfig.layerId);
        reMap.put("querylatest", "true");
        String reMapList = entityHttpUtil.getPostMessage(xzConfig.layerQuery, reMap);
@@ -116,25 +119,31 @@
            ArrayList<RelaEntity> arrayList = new ArrayList<>();
            for (int i = 0; i < reArray.size(); i++) {
                String name = JSONObject.parseObject(reArray.getString(i)).getString(xzConfig.queryFiled);
                if (name.equals(place)) {
                String name = JSONObject.parseObject(reArray.getString(i)).getString(xzConfig.typeFiled);
//             System.out.println("rec getQueryRelationship:" + name);
                if (name == null || name.isEmpty()) {
                    continue;
                }
                boolean contains = false;
                for (int j = 0; j < arrayList.size(); j++) {
                    RelaEntity firstElement = arrayList.get(j);
                    if (firstElement.getName().equals(name)) {
                        int flag = firstElement.getCount();
                        flag++;
                        firstElement.setCount(flag);
                        contains = true;
                } else {
                    if (name.equals(place)) {
                        continue;
                    }
                }
                if (contains == false) {
                    RelaEntity relaEntity = new RelaEntity();
                    relaEntity.setName(name);
                    relaEntity.setCount(1);
                    arrayList.add(relaEntity);
                    boolean contains = false;
                    for (int j = 0; j < arrayList.size(); j++) {
                        RelaEntity firstElement = arrayList.get(j);
                        if (firstElement.getName().equals(name)) {
                            int flag = firstElement.getCount();
                            flag++;
                            firstElement.setCount(flag);
                            contains = true;
                        }
                    }
                    if (contains == false) {
                        RelaEntity relaEntity = new RelaEntity();
                        relaEntity.setName(name);
                        relaEntity.setCount(1);
                        arrayList.add(relaEntity);
                    }
                }
            }
            String markDown = "| 数据类型 | 数据量 |\n|------|------|\n";
@@ -147,7 +156,7 @@
            traiMap.put("msg", markDown);
        }
        System.out.println("rec getQueryRelationship:" + traiMap);
//        System.out.println("rec traiMap:" + traiMap);
        return traiMap;
    }