From 6c2ff1c7c8e0aba3af92110b76687b78f8278e86 Mon Sep 17 00:00:00 2001 From: 潘志宝 <979469083@qq.com> Date: 星期五, 03 一月 2025 09:57:37 +0800 Subject: [PATCH] 动态数据长度 --- iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/channel/opcda/controller/admin/ChannelOPCDATagController.java | 36 ++++-------------------------------- 1 files changed, 4 insertions(+), 32 deletions(-) diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/channel/opcda/controller/admin/ChannelOPCDATagController.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/channel/opcda/controller/admin/ChannelOPCDATagController.java index 7f47f41..56aded4 100644 --- a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/channel/opcda/controller/admin/ChannelOPCDATagController.java +++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/channel/opcda/controller/admin/ChannelOPCDATagController.java @@ -5,21 +5,17 @@ import com.iailab.framework.common.pojo.PageParam; import com.iailab.framework.common.pojo.PageResult; import com.iailab.framework.common.util.object.BeanUtils; -import com.iailab.module.data.channel.opcda.collector.OpcDACollector; -import com.iailab.module.data.channel.opcda.entity.ChannelOPCDADeviceEntity; import com.iailab.framework.common.util.object.ConvertUtils; import com.iailab.framework.excel.core.util.ExcelUtils; import com.iailab.module.data.channel.opcda.entity.ChannelOPCDATagEntity; -import com.iailab.module.data.channel.opcda.service.ChannelOPCDADeviceService; import com.iailab.module.data.channel.opcda.service.ChannelOPCDATagService; import com.iailab.module.data.channel.opcda.vo.OpcDaTagExportExcelVO; import com.iailab.module.data.channel.opcda.vo.OpcDaTagImportExcelVO; import com.iailab.module.data.channel.opcda.vo.OpcDaTagPageReqVO; import com.iailab.module.data.channel.opcda.vo.OpcDaTagRespVO; -import com.iailab.module.data.common.enums.DataSourceType; import com.iailab.module.data.channel.tag.vo.TagImportRespVO; +import com.iailab.module.data.common.enums.IsEnableEnum; import com.iailab.module.data.common.exception.RRException; -import com.iailab.module.data.common.utils.TagUtils; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Parameter; import io.swagger.v3.oas.annotations.Parameters; @@ -31,13 +27,11 @@ import javax.servlet.http.HttpServletResponse; import javax.validation.Valid; -import java.util.ArrayList; import java.io.IOException; import java.util.Collections; import java.util.Date; import java.util.List; import java.util.UUID; -import java.util.stream.Collectors; import static com.iailab.framework.apilog.core.enums.OperateTypeEnum.EXPORT; import static com.iailab.framework.common.pojo.CommonResult.success; @@ -54,34 +48,12 @@ @Autowired private ChannelOPCDATagService channelOPCDATagService; - @Autowired - private OpcDACollector opcDACollector; - - @Autowired - private ChannelOPCDADeviceService channelOPCDADeviceService; - @PreAuthorize("@ss.hasPermission('data:channel-opcda:query')") @GetMapping("page") public CommonResult<PageResult<OpcDaTagRespVO>> list(@Valid OpcDaTagPageReqVO reqVO) { - PageResult<ChannelOPCDATagEntity> page = channelOPCDATagService.queryPage(reqVO); - PageResult<OpcDaTagRespVO> pageResultVO = new PageResult<>(); - pageResultVO.setTotal(page.getTotal()); - - List<OpcDaTagRespVO> vos = page.getList().stream().map(entity -> { - - OpcDaTagRespVO vo = BeanUtils.toBean(entity,OpcDaTagRespVO.class); - List<String[]> tags = new ArrayList<>(); - String[] array = {reqVO.getServerId(),entity.getTagName()}; - tags.add(array); - ChannelOPCDADeviceEntity OPCDADevice = channelOPCDADeviceService.info(reqVO.getServerId()); - vo.setDataValue(Double.parseDouble(opcDACollector.getTagValues(tags).get(TagUtils.genTagId(DataSourceType.OPCDA.getCode(), OPCDADevice.getServerName(),entity.getTagName())).toString())); - return vo; - }).collect(Collectors.toList()); - - pageResultVO.setList(vos); - - return success(pageResultVO); + PageResult<OpcDaTagRespVO> pageResult = BeanUtils.toBean(page, OpcDaTagRespVO.class); + return success(pageResult); } @PreAuthorize("@ss.hasPermission('data:channel-opcda:query')") @@ -146,7 +118,7 @@ public void importTemplate(HttpServletResponse response) throws IOException { // 手动创建导出 demo List<OpcDaTagImportExcelVO> list = Collections.singletonList( - OpcDaTagImportExcelVO.builder().tagName("Tag名称").dataType("String").enabled(1) + OpcDaTagImportExcelVO.builder().tagName("Tag名称").dataType("String").enabled(IsEnableEnum.ENABLE.getCode()) .build() ); // 输出 -- Gitblit v1.9.3