| | |
| | | package com.zhitan.dataitem.service.impl; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.zhitan.common.enums.TimeType; |
| | | import com.zhitan.consumptionanalysis.domain.vo.RankingEnergyData; |
| | | import com.zhitan.dataitem.domain.StagseDataEntry; |
| | | import com.zhitan.dataitem.domain.vo.NodeIndexValueVO; |
| | | import com.zhitan.dataitem.mapper.DataItemMapper; |
| | |
| | | public FlowChartsVO getFlowCharts(FlowChartsDTO dto) { |
| | | FlowChartsVO flowChartsVO = new FlowChartsVO(); |
| | | // 父节点id |
| | | String nodeId = dto.getNodeId(); |
| | | LambdaQueryWrapper<ModelNode> wrapper = Wrappers.<ModelNode>lambdaQuery() |
| | | .eq(ModelNode::getModelCode, dto.getModelCode()) |
| | | .isNull(ModelNode::getParentId); |
| | | List<ModelNode> modelNodes = modelNodeMapper.selectList(wrapper); |
| | | if (ObjectUtils.isEmpty(modelNodes)) { |
| | | throw new RuntimeException("未查询到模型信息"); |
| | | } |
| | | ModelNode modelNode = modelNodes.stream().findFirst().get(); |
| | | String nodeId = modelNode.getNodeId(); |
| | | dto.setNodeId(nodeId); |
| | | String energyType = dto.getEnergyType(); |
| | | LocalDate queryTime = dto.getQueryTime(); |
| | | TimeType timeType = dto.getTimeType(); |
| | | |
| | | // 获取节点信息 |
| | | ModelNode modelNode = modelNodeMapper.selectModelNodeById(nodeId); |
| | | if (ObjectUtils.isEmpty(modelNode)) { |
| | | return flowChartsVO; |
| | | } |
| | | // 获取查询时间 |
| | | Map<String, LocalDateTime> dateTimeMap = getDataItemByIndexId(timeType, queryTime); |
| | | |
| | |
| | | return flowChartsVO; |
| | | } |
| | | |
| | | @Override |
| | | public List<RankingEnergyData> getHomePageConsumptionRanking(List<String> nodeIds, String timeType, Date beginTime, Date endTime) { |
| | | return dataItemMapper.getHomePageConsumptionRanking(nodeIds, timeType, beginTime, endTime); |
| | | } |
| | | |
| | | /** |
| | | * 根据indexId查询能耗数据 |
| | | */ |