package com.ruoyi.alarm.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.alarm.dto.AlarmCollectionInterfaceDto;
|
import com.ruoyi.alarm.dto.AlarmPointDto;
|
import com.ruoyi.alarm.mapper.AlarmCollectionInterfaceMapper;
|
import com.ruoyi.alarm.mapper.AlarmPointMapper;
|
import com.ruoyi.alarm.pojo.AlarmCollectionInterface;
|
import com.ruoyi.alarm.pojo.AlarmPoint;
|
import com.ruoyi.alarm.service.IAlarmCollectionService;
|
import com.ruoyi.alarm.vo.AlarmCollectionInterfaceVo;
|
import com.ruoyi.alarm.vo.AlarmPointLedgerVo;
|
import com.ruoyi.alarm.vo.AlarmStatisticsVo;
|
import com.ruoyi.common.utils.bean.BeanUtils;
|
import lombok.AllArgsConstructor;
|
import org.springframework.stereotype.Service;
|
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Service
|
@AllArgsConstructor
|
public class AlarmCollectionServiceImpl extends ServiceImpl<AlarmPointMapper, AlarmPoint> implements IAlarmCollectionService {
|
|
private AlarmPointMapper alarmPointMapper;
|
private AlarmCollectionInterfaceMapper alarmCollectionInterfaceMapper;
|
|
@Override
|
public AlarmStatisticsVo getStatistics() {
|
AlarmStatisticsVo vo = new AlarmStatisticsVo();
|
LambdaQueryWrapper<AlarmPoint> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(AlarmPoint::getStatus, 1);
|
Long totalPoints = alarmPointMapper.selectCount(wrapper);
|
vo.setTotalPoints(totalPoints.intValue());
|
vo.setConnectedDevices((int) (totalPoints * 0.7));
|
vo.setTodayDataVolume(245.6);
|
vo.setParseSuccessRate(99.8);
|
return vo;
|
}
|
|
@Override
|
public IPage<AlarmPointLedgerVo> getPointLedgerList(Page page, AlarmPointDto dto) {
|
LambdaQueryWrapper<AlarmPoint> wrapper = new LambdaQueryWrapper<>();
|
if (dto.getPointName() != null && !dto.getPointName().isEmpty()) {
|
wrapper.like(AlarmPoint::getPointName, dto.getPointName());
|
}
|
if (dto.getDeviceType() != null && !dto.getDeviceType().isEmpty()) {
|
wrapper.eq(AlarmPoint::getDeviceType, dto.getDeviceType());
|
}
|
wrapper.orderByDesc(AlarmPoint::getCreateTime);
|
IPage<AlarmPoint> pointPage = alarmPointMapper.selectPage(page, wrapper);
|
return pointPage.convert(point -> {
|
AlarmPointLedgerVo vo = new AlarmPointLedgerVo();
|
BeanUtils.copyProperties(point, vo);
|
return vo;
|
});
|
}
|
|
@Override
|
public int addPoint(AlarmPointDto dto) {
|
AlarmPoint point = new AlarmPoint();
|
BeanUtils.copyProperties(dto, point);
|
point.setCreateTime(LocalDateTime.now());
|
point.setUpdateTime(LocalDateTime.now());
|
return alarmPointMapper.insert(point);
|
}
|
|
@Override
|
public int updatePoint(AlarmPointDto dto) {
|
AlarmPoint point = new AlarmPoint();
|
BeanUtils.copyProperties(dto, point);
|
point.setUpdateTime(LocalDateTime.now());
|
return alarmPointMapper.updateById(point);
|
}
|
|
@Override
|
public int deletePoint(Long pointId) {
|
return alarmPointMapper.deleteById(pointId);
|
}
|
|
@Override
|
public int changePointStatus(Long pointId, Integer status) {
|
AlarmPoint point = new AlarmPoint();
|
point.setPointId(pointId);
|
point.setStatus(status);
|
point.setUpdateTime(LocalDateTime.now());
|
return alarmPointMapper.updateById(point);
|
}
|
|
@Override
|
public List<AlarmPointLedgerVo> getPointOptions() {
|
LambdaQueryWrapper<AlarmPoint> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(AlarmPoint::getStatus, 1);
|
wrapper.select(AlarmPoint::getPointId, AlarmPoint::getPointName);
|
List<AlarmPoint> points = alarmPointMapper.selectList(wrapper);
|
return points.stream().map(point -> {
|
AlarmPointLedgerVo vo = new AlarmPointLedgerVo();
|
vo.setPointId(point.getPointId());
|
vo.setPointName(point.getPointName());
|
return vo;
|
}).collect(java.util.stream.Collectors.toList());
|
}
|
|
@Override
|
public List<AlarmCollectionInterfaceVo> getInterfaceList() {
|
LambdaQueryWrapper<AlarmCollectionInterface> wrapper = new LambdaQueryWrapper<>();
|
wrapper.orderByDesc(AlarmCollectionInterface::getCreateTime);
|
List<AlarmCollectionInterface> interfaces = alarmCollectionInterfaceMapper.selectList(wrapper);
|
|
if (interfaces.isEmpty()) {
|
List<AlarmCollectionInterfaceVo> mockData = new ArrayList<>();
|
AlarmCollectionInterfaceVo vo = new AlarmCollectionInterfaceVo();
|
vo.setInterfaceId(1L);
|
vo.setInterfaceName("OPC UA数据采集");
|
vo.setInterfaceType("OPC UA");
|
vo.setServerAddress("opc.tcp://192.168.1.100:4840");
|
vo.setCollectFreq("1秒");
|
vo.setConnectStatus("connected");
|
mockData.add(vo);
|
return mockData;
|
}
|
|
return interfaces.stream().map(iface -> {
|
AlarmCollectionInterfaceVo vo = new AlarmCollectionInterfaceVo();
|
BeanUtils.copyProperties(iface, vo);
|
return vo;
|
}).collect(java.util.stream.Collectors.toList());
|
}
|
|
@Override
|
public int startInterface(Long interfaceId) {
|
AlarmCollectionInterface iface = new AlarmCollectionInterface();
|
iface.setInterfaceId(interfaceId);
|
iface.setConnectStatus("connected");
|
iface.setUpdateTime(LocalDateTime.now());
|
return alarmCollectionInterfaceMapper.updateById(iface);
|
}
|
|
@Override
|
public int stopInterface(Long interfaceId) {
|
AlarmCollectionInterface iface = new AlarmCollectionInterface();
|
iface.setInterfaceId(interfaceId);
|
iface.setConnectStatus("disconnected");
|
iface.setUpdateTime(LocalDateTime.now());
|
return alarmCollectionInterfaceMapper.updateById(iface);
|
}
|
|
@Override
|
public int addOrUpdateInterface(AlarmCollectionInterfaceDto dto) {
|
AlarmCollectionInterface iface = new AlarmCollectionInterface();
|
BeanUtils.copyProperties(dto, iface);
|
iface.setUpdateTime(LocalDateTime.now());
|
|
if (dto.getInterfaceId() == null) {
|
// 新增
|
iface.setCreateTime(LocalDateTime.now());
|
return alarmCollectionInterfaceMapper.insert(iface);
|
} else {
|
// 更新
|
return alarmCollectionInterfaceMapper.updateById(iface);
|
}
|
}
|
|
@Override
|
public int deleteInterface(Long interfaceId) {
|
return alarmCollectionInterfaceMapper.deleteById(interfaceId);
|
}
|
}
|
