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,15 @@

    @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);
        if (dto == null) {
            return null;
        }
        pointIdMap.put(id, dto);
        return pointIdMap.get(id);
    }

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

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

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

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

    @Override
@@ -387,6 +402,7 @@
    }

    @Override
    @DSTransactional(rollbackFor = Exception.class)
    public void enableByIds(String[] ids) {
        if (CollectionUtils.isEmpty(Arrays.asList(ids))) {
            return;
@@ -395,11 +411,13 @@
            DaPointEntity entity = new DaPointEntity();
            entity.setId(item);
            entity.setIsEnable(IsEnableEnum.ENABLE.getCode());
            entity.setUpdateTime(new Date());
            daPointDao.updateById(entity);
        });
    }

    @Override
    @DSTransactional(rollbackFor = Exception.class)
    public void disableByIds(String[] ids) {
        if (CollectionUtils.isEmpty(Arrays.asList(ids))) {
            return;
@@ -408,6 +426,7 @@
            DaPointEntity entity = new DaPointEntity();
            entity.setId(item);
            entity.setIsEnable(IsEnableEnum.DISABLE.getCode());
            entity.setUpdateTime(new Date());
            daPointDao.updateById(entity);
        });
    }