dengzedong
2024-10-14 3e18d4bfbf2c657b08b21512c2d884cc9d59df7b
提交 | 用户 | 时间
9d7e02 1 package com.iailab.module.data.channel.opcda.service.impl;
2
3 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
4 import com.baomidou.mybatisplus.core.metadata.IPage;
5 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
6 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
aecc49 7 import com.iailab.framework.common.pojo.PageResult;
9d7e02 8 import com.iailab.framework.common.util.object.ConvertUtils;
9 import com.iailab.module.data.channel.opcda.dao.ChannelOPCDADeviceDao;
10 import com.iailab.module.data.channel.opcda.dto.ChannelOPCDADeviceDTO;
11 import com.iailab.module.data.channel.opcda.entity.ChannelOPCDADeviceEntity;
12 import com.iailab.module.data.channel.opcda.service.ChannelOPCDADeviceService;
13 import com.iailab.module.data.channel.opcda.service.ChannelOPCDATagService;
aecc49 14 import com.iailab.module.data.channel.opcda.vo.OpcDaDevicePageReqVO;
9d7e02 15 import com.iailab.module.data.common.utils.PageUtils;
16 import com.iailab.module.data.common.utils.Query;
17 import org.springframework.beans.factory.annotation.Autowired;
18 import org.springframework.stereotype.Service;
19
20 import javax.annotation.Resource;
21 import java.util.List;
22 import java.util.Map;
23
24 /**
aecc49 25  * @author lirm
9d7e02 26  * @Description
aecc49 27  * @createTime 2024年08月26日
9d7e02 28  */
29 @Service
30 public class ChannelOPCDADeviceServiceImpl extends ServiceImpl<ChannelOPCDADeviceDao, ChannelOPCDADeviceEntity> implements ChannelOPCDADeviceService {
31     @Resource
32     private ChannelOPCDADeviceDao channelOPCDADeviceDao;
33
34     @Autowired
35     private ChannelOPCDATagService channelOPCDATagService;
36
aecc49 37     @Override
L 38     public PageResult<ChannelOPCDADeviceEntity> queryPage(OpcDaDevicePageReqVO reqVO) {
39         return channelOPCDADeviceDao.selectPage(reqVO);
9d7e02 40     }
41
42     @Override
43     public ChannelOPCDADeviceEntity info(String id) {
44         return channelOPCDADeviceDao.selectById(id);
45     }
46
47     @Override
48     public void add(ChannelOPCDADeviceEntity channelOPCDADeviceEntity) {
49         channelOPCDADeviceDao.insert(channelOPCDADeviceEntity);
50     }
51
52     @Override
53     public void update(ChannelOPCDADeviceEntity channelOPCDADeviceEntity) {
54         channelOPCDADeviceDao.updateById(channelOPCDADeviceEntity);
55     }
56
57     @Override
58     public void delete(String id) {
59
60         //先删除device下的tag
61         channelOPCDATagService.deleteByServerId(id);
62
63         channelOPCDADeviceDao.deleteById(id);
64     }
65
66     @Override
67     public List<ChannelOPCDADeviceDTO> selectAll() {
68
69         List<ChannelOPCDADeviceEntity> entityList = baseMapper.selectList(
70                 null
71         );
72         return ConvertUtils.sourceToTarget(entityList, ChannelOPCDADeviceDTO.class);
73     }
74 }