iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointServiceImpl.java

@@ -61,12 +61,19 @@
    @Resource
    private ChannelSourceService channelSourceService;

    private static Map<String, DaPointDTO> pointIdMap = new ConcurrentHashMap<>();

    private static Map<String, DaPointDTO> pointNoMap = new ConcurrentHashMap<>();

    @Override
    public PageResult<DaPointDTO> queryPage(DaPointPageReqVO reqVO) {
        IPage<DaPointDTO> page = daPointDao.selectPageList(reqVO);
        return new PageResult<DaPointDTO>(page.getRecords(), page.getTotal());
        return new PageResult<>(page.getRecords(), page.getTotal());
    }

    private void clearCache() {
        pointIdMap.clear();
        pointNoMap.clear();
    }

    @Override
@@ -89,7 +96,12 @@

    @Override
    public DaPointDTO getSimpleInfoById(String id) {
        return ConvertUtils.sourceToTarget(daPointDao.selectById(id), DaPointDTO.class);
        if (pointIdMap.containsKey(id)) {
            return pointIdMap.get(id);
        }
        DaPointDTO dto = ConvertUtils.sourceToTarget(daPointDao.selectById(id), DaPointDTO.class);
        pointIdMap.put(id, dto);
        return dto;
    }

    @Override
@@ -150,7 +162,7 @@
        daPointDao.insert(daPointEntity);

        // 清空缓存
        pointNoMap.clear();
        clearCache();
    }

    @Override
@@ -174,7 +186,7 @@
                break;
        }
        // 清空缓存
        pointNoMap.clear();
        clearCache();
    }

    @Override
@@ -184,7 +196,7 @@
        daMeasurePointService.deleteByPoint(id);
        daMathPointService.deleteByPoint(id);
        // 清空缓存
        pointNoMap.clear();
        clearCache();
    }

    @Override