@xingjs@20241226@添加查询管线工具类,修改解决查询站点接口token存在无法获取的情况，解决后可正常获取token，并查询出需要的站点

xingjinshuang

2024-12-26 9d570d97c7b8e8abbeea9cb2ca09439db6744f3e

 src/main/java/com/se/simu/service/Impl/ProjectRelatedServiceImpl.java

@@ -88,15 +88,20 @@
    @Override
    public Object loginEntity(LoginParams loginParams) {
        // 判断redis中缓存是否存在（过期）
        boolean isExists = Objects.nonNull(CaffeineHelper.getMd5(CacheConstants.USER_CACHE_KEY + "entity_db_response"));
        if (isExists) {
        boolean isExists = Objects.isNull(CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "entity_db_token"));
        if (!isExists) {
            return JSONObject.parseObject((String) CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "entity_db_response"));
        } else {
            // 清除所有缓存
            CaffeineHelper.remove(CacheConstants.USER_CACHE_KEY + "entity_db_response");
            CaffeineHelper.remove(CacheConstants.USER_CACHE_KEY + "EntityPublicKey");
            CaffeineHelper.remove(CacheConstants.USER_CACHE_KEY + "entity_db_token");
            CaffeineHelper.remove(CacheConstants.USER_CACHE_KEY + "rsa_data_set");
        }
        // 设置请求体
        // 获取私钥和公钥，长度必须是16、24或32
        String publicKey = (String) CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "rsa_data_set");
        // 假设从Redis中获取到用户名,判断
        if (!StringUtils.isNotBlank(publicKey)) {
        if (!StringUtils.isNotBlank(publicKey) && Objects.isNull(publicKey)) {
            // 缓存中没有用户名,则进行登录
            getPublicKey();
            log.info("调用了登录获取用户名方法 $= ");
@@ -131,6 +136,7 @@
                // 登录成功后,获取data
                String data = JSONObject.parseObject(response).getString("data");
                String token = JSONObject.parseObject(data).getString("token");
                log.info("token = " + token);
                // 设置data到Redis中
                CaffeineHelper.remove(CacheConstants.USER_CACHE_KEY + "entity_db_response");
                CaffeineHelper.put(CacheConstants.USER_CACHE_KEY + "entity_db_response", response);
@@ -215,10 +221,16 @@
     */
    @Override
    public Object getEntityPublicKey() {
        // 判断中缓存是否存在（过期）
        boolean isExists = Objects.nonNull(CaffeineHelper.getMd5(CacheConstants.USER_CACHE_KEY + "EntityPublicKey"));
        if (isExists) {
        // 判断redis中缓存是否存在（过期）
        boolean isExists = Objects.isNull(CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "EntityPublicKey"));
        if (!isExists) {
            return JSONObject.parseObject((String) CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "EntityPublicKey"));
        } else {
            // 清除所有缓存
            CaffeineHelper.remove(CacheConstants.USER_CACHE_KEY + "entity_db_response");
            CaffeineHelper.remove(CacheConstants.USER_CACHE_KEY + "EntityPublicKey");
            CaffeineHelper.remove(CacheConstants.USER_CACHE_KEY + "entity_db_token");
            CaffeineHelper.remove(CacheConstants.USER_CACHE_KEY + "rsa_data_set");
        }
        HashMap<String, String> headers = new HashMap<>();
        headers.put("Content-Type", "application/json");
@@ -290,7 +302,19 @@
    public Object getEntityTypeInfo(EntityTypeInfo entityTypeInfo) {
        HashMap<String, String> headers = new HashMap<>();
        headers.put("Content-Type", "application/json");
        String token = (String) CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "entity_db_token");
        String token;
        // 判断redis中缓存是否存在（过期）
        boolean isExists = Objects.isNull(CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "entity_db_token"));
        if (!isExists) {
            token = (String) CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "entity_db_token");
        } else {
            // 获取token
            LoginParams loginParams = new LoginParams();
            loginParams.setUserid("admin");
            loginParams.setPassword("admin");
            loginEntity(loginParams);
            token = (String) CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "entity_db_token");
        }
        log.info("token = " + token);
        // 添加form参数
        HashMap<String, Object> params = new HashMap<>();
@@ -299,7 +323,7 @@
        params.put("containCount", true);
        params.put("count", Objects.nonNull(entityTypeInfo.getCount()) ? entityTypeInfo.getCount() : 20);
        params.put("dbid", Objects.nonNull(entityTypeInfo.getDbid()) ? entityTypeInfo.getDbid() : "85257774fdb64e5f99f6778696cad02a");
        params.put("layerid", "f6ff4412-4886-4c4b-83f7-13de24ee8353");
        params.put("layerid", Objects.nonNull(entityTypeInfo.getLayerid()) ? entityTypeInfo.getLayerid() : "f6ff4412-4886-4c4b-83f7-13de24ee8353");
        params.put("like", "");
        params.put("querytype", "entity");

@@ -329,7 +353,19 @@
    public Object getEntityPipeInfo(EntityTypeInfo entityTypeInfo) {
        HashMap<String, String> headers = new HashMap<>();
        headers.put("Content-Type", "application/json");
        String token = (String) CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "entity_db_token");
        String token;
        // 判断redis中缓存是否存在（过期）
        boolean isExists = Objects.isNull(CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "entity_db_token"));
        if (!isExists) {
            token = (String) CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "entity_db_token");
        } else {
            // 获取token
            LoginParams loginParams = new LoginParams();
            loginParams.setUserid("admin");
            loginParams.setPassword("admin");
            loginEntity(loginParams);
            token = (String) CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "entity_db_token");
        }
        log.info("token = " + token);
        // 添加form参数
        HashMap<String, Object> params = new HashMap<>();
@@ -339,7 +375,7 @@
        params.put("containCount", true);
        params.put("count", Objects.nonNull(entityTypeInfo.getCount()) ? entityTypeInfo.getCount() : 20);
        params.put("dbid", Objects.nonNull(entityTypeInfo.getDbid()) ? entityTypeInfo.getDbid() : "85257774fdb64e5f99f6778696cad02a");
        params.put("layerid", "1e677d48-8dff-4975-b9a0-c16500193629");
        params.put("layerid", Objects.nonNull(entityTypeInfo.getLayerid()) ? entityTypeInfo.getLayerid() : "1e677d48-8dff-4975-b9a0-c16500193629");
        params.put("like", "");
        params.put("querytype", "entity");