package com.sandu.ximon.admin.service;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.db.PageResult;
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.IService;
|
import com.github.pagehelper.PageHelper;
|
import com.sandu.common.domain.CommonPage;
|
import com.sandu.common.execption.BusinessException;
|
import com.sandu.common.object.BaseConditionVO;
|
import com.sandu.common.service.impl.BaseServiceImpl;
|
import com.sandu.common.util.SpringContextHolder;
|
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A5LightHeartbeatReportInnerFrame;
|
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A7PlcHeartbeatReportInnerFrame;
|
import com.sandu.ximon.admin.manager.iot.rrpc.enums.A5LightDataEnum;
|
import com.sandu.ximon.admin.manager.iot.rrpc.enums.A7PlcDataEnum;
|
import com.sandu.ximon.admin.utils.RedisUtils;
|
import com.sandu.ximon.dao.bo.LightReportDataBo;
|
import com.sandu.ximon.dao.bo.PlcReportDataBo;
|
import com.sandu.ximon.dao.domain.*;
|
import com.sandu.ximon.dao.enums.OrderByEnums;
|
import com.sandu.ximon.dao.mapper.PlcReportDataMapper;
|
import lombok.AllArgsConstructor;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* PLC上报数据表(PlcReportData)表服务接口
|
*
|
* @author van
|
* @since 2022-12-16 10:54:58
|
*/
|
@Service
|
@AllArgsConstructor
|
public class PlcReportDataService extends BaseServiceImpl<PlcReportDataMapper,PlcReportData> {
|
|
private final PlcReportDataMapper plcReportDataMapper;
|
|
// PageResult getPage(Integer currentPage, Integer size, PlcReportData plcReportData);
|
|
|
/**
|
* 保存上报的PLC心跳数据
|
*
|
* @return 是否成功
|
*/
|
public boolean saveReportData(String deviceName, A7PlcHeartbeatReportInnerFrame.HeartBeatDataPackage heartBeatDataPackage) {
|
|
String format = LocalDateTime.now().format(DateTimeFormatter.ofPattern("YYYY-MM-dd HH:mm:ss"));
|
|
PlcReportData plcReportData = new PlcReportData();
|
|
if (plcReportData == null) {
|
plcReportData = new PlcReportData();
|
plcReportData.setCreateTime(format);
|
}
|
plcReportData.setCreateTime(format);
|
BeanUtils.copyProperties(heartBeatDataPackage, plcReportData);
|
plcReportData.setDeviceCode(deviceName);
|
|
plcReportData.setUpdateTime(format);
|
//PLC数据保存到缓存里
|
RedisUtils.getBean().set(A7PlcDataEnum.PLC_HEART_BEAT.getCode() + deviceName, plcReportData);
|
|
return save(plcReportData);
|
|
|
}
|
|
List<PlcReportData> getNewestReportByDeviceCode(List<String> deviceCodeList){
|
return baseMapper.getNewestReportByDeviceCode(deviceCodeList);
|
}
|
/**
|
* 获取上报数据
|
*
|
* @param keyword 关键词
|
* @param deviceCode 设备码
|
*/
|
public CommonPage listReportData(int pageNo, int pageSize, String keyword, String deviceCode, Integer order, Integer seq) {
|
|
List<PlcReportDataBo> plcReportDataBos = new ArrayList<>(pageSize);
|
//排序字段
|
String orderByResult = "t1.plc_create_time";
|
//正序、倒叙
|
String orderBySeq = OrderByEnums.ASC.getCode();
|
if (order != null) {
|
switch (order) {
|
case 1:
|
orderByResult = OrderByEnums.PLC_DATA_CREATE_TIME.getCode();
|
break;
|
default:
|
}
|
}
|
if (seq != null) {
|
switch (seq) {
|
case 1:
|
orderBySeq = " ASC";
|
break;
|
case 2:
|
orderBySeq = " DESC";
|
break;
|
default:
|
break;
|
}
|
}
|
//排序方式
|
String orderBy = orderByResult + " " + orderBySeq;
|
CommonPage<String> stringCommonPage = SpringContextHolder.getBean(PlcService.class).listDeviceCode(pageNo, pageSize, keyword, deviceCode, orderBy);
|
List<String> macList = stringCommonPage.getList();
|
if (CollUtil.isEmpty(macList)) {
|
return new CommonPage();
|
}
|
for (String macCode : macList) {
|
try {
|
PlcReportData plcReportData
|
= JSON.parseObject(RedisUtils.getBean().get(A7PlcDataEnum.PLC_HEART_BEAT.getCode() + macCode), PlcReportData.class);
|
|
PlcReportDataBo plcReportDataBo = new PlcReportDataBo();
|
if (plcReportData != null) {
|
BeanUtils.copyProperties(plcReportData, plcReportDataBo);
|
}
|
plcReportDataBo.setDeviceCode(macCode);
|
Pole pole = SpringContextHolder.getBean(PoleService.class).getOne(Wrappers.lambdaQuery(Pole.class).eq(Pole::getDeviceCode, macCode));
|
if (pole != null) {
|
plcReportDataBo.setPoleName(pole.getPoleName());
|
}
|
plcReportDataBos.add(plcReportDataBo);
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
CommonPage commonPage = CommonPage.restPage(plcReportDataBos);
|
commonPage.setTotal(stringCommonPage.getTotal());
|
commonPage.setTotalPage(stringCommonPage.getTotalPage());
|
commonPage.setPageNum(pageNo);
|
|
return commonPage;
|
}
|
|
public List<PlcReportData> getReportDataList(BaseConditionVO conditionVO, String macCode) {
|
if (macCode.isEmpty()) {
|
throw new BusinessException("mac不能为空");
|
}
|
|
Plc plc = SpringContextHolder.getBean(PlcService.class)
|
.getOne(Wrappers.lambdaQuery(Plc.class).eq(Plc::getDeviceCode, macCode));
|
if (plc == null) {
|
throw new BusinessException("系统中不存在该plc");
|
}
|
PageHelper.startPage(conditionVO.getPageNo(), conditionVO.getPageSize());
|
List<PlcReportData> list = list(Wrappers.lambdaQuery(PlcReportData.class).eq(PlcReportData::getDeviceCode, macCode).orderByDesc(PlcReportData::getReportDataId));
|
list.forEach(
|
plcReportData -> {
|
plcReportData.setCreateTime(plcReportData.getCreateTime1().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
|
plcReportData.setUpdateTime(plcReportData.getUpdateTime1().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
|
}
|
);
|
return list;
|
}
|
}
|
