From 3ca415190b5a8fa0ff5f4782fb7ab4cfeb026705 Mon Sep 17 00:00:00 2001 From: dongyukun <1208714201@qq.com> Date: 星期二, 25 二月 2025 15:04:18 +0800 Subject: [PATCH] 时序数据归档 --- iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/ArcPointSettingServiceImpl.java | 44 ++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 44 insertions(+), 0 deletions(-) diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/ArcPointSettingServiceImpl.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/ArcPointSettingServiceImpl.java index 7606b99..7885a24 100644 --- a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/ArcPointSettingServiceImpl.java +++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/ArcPointSettingServiceImpl.java @@ -1,13 +1,18 @@ package com.iailab.module.data.point.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.iailab.framework.common.pojo.PageResult; import com.iailab.framework.common.service.impl.BaseServiceImpl; +import com.iailab.module.data.common.enums.IsEnableEnum; import com.iailab.module.data.point.dao.ArcPointSettingDao; import com.iailab.module.data.point.entity.ArcPointSettingEntity; +import com.iailab.module.data.point.entity.DaPointEntity; import com.iailab.module.data.point.service.ArcPointSettingService; +import com.iailab.module.data.point.vo.ArcPointSettingPageReqVO; import org.apache.commons.lang3.ObjectUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.util.CollectionUtils; import java.util.*; @@ -24,4 +29,43 @@ queryWrapper.eq(!ObjectUtils.isEmpty(type), "type", type); return arcPointSettingDao.selectList(queryWrapper); } + + @Override + public void update(ArcPointSettingEntity arcPointSettingEntity) { + arcPointSettingDao.updateById(arcPointSettingEntity); + } + + @Override + public void delete(String id) { + arcPointSettingDao.deleteById(id); + } + + @Override + public void enableByIds(String[] ids) { + if (CollectionUtils.isEmpty(Arrays.asList(ids))) { + return; + } + Arrays.asList(ids).forEach(item -> { + ArcPointSettingEntity entity = new ArcPointSettingEntity(); + entity.setId(item); + entity.setIsEnable(IsEnableEnum.ENABLE.getCode().toString()); + entity.setUpdateTime(new Date()); + arcPointSettingDao.updateById(entity); + }); + } + + @Override + public void add(ArcPointSettingEntity arcPointSettingEntity) { + arcPointSettingDao.insert(arcPointSettingEntity); + } + + @Override + public ArcPointSettingEntity info(String id) { + return arcPointSettingDao.selectById(id); + } + + @Override + public PageResult<ArcPointSettingEntity> queryPage(ArcPointSettingPageReqVO reqVO) { + return arcPointSettingDao.selectPage(reqVO); + } } -- Gitblit v1.9.3