From f299201904584031340978e43e4c176f8862211d Mon Sep 17 00:00:00 2001 From: tyty Date: Wed, 15 Mar 2023 13:54:43 +0800 Subject: [PATCH 1/4] =?UTF-8?q?=E6=B7=BB=E5=8A=A0-=E5=8E=82=E7=AB=99?= =?UTF-8?q?=E9=80=9A=E8=AE=AF=E4=B8=AD=E6=96=AD=E5=91=8A=E8=AD=A6=E7=BB=9F?= =?UTF-8?q?=E8=AE=A1=E7=9B=B8=E5=85=B3=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../alert/controller/AbnormalAlarmController.java | 21 +++++ .../alert/mapper/HistoryAbnormalAlarmMapper.java | 2 + .../alert/mapper/HistoryAbnormalAlarmMapper.xml | 19 ++++- .../alert/service/HistoryAbnormalAlarmService.java | 4 + .../impl/HistoryAbnormalAlarmServiceImpl.java | 99 +++++++++++++++++++++- .../station/vo/HistoryAbnormalAlarmVo.java | 8 ++ 6 files changed, 150 insertions(+), 3 deletions(-) diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/controller/AbnormalAlarmController.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/controller/AbnormalAlarmController.java index 668f298..1b9fdf3 100644 --- a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/controller/AbnormalAlarmController.java +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/controller/AbnormalAlarmController.java @@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage; import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport; import com.hnac.hzims.operational.alert.entity.HistoryAbnormalAlarmEntity; import com.hnac.hzims.operational.alert.service.HistoryAbnormalAlarmService; +import com.hnac.hzims.operational.station.vo.HistoryAbnormalAlarmVo; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; @@ -25,7 +26,27 @@ import javax.validation.Valid; public class AbnormalAlarmController extends BladeController { private final HistoryAbnormalAlarmService service; + /** + * 统计通讯中断时间 + */ + @GetMapping("/statisticsTime") + @ApiOperationSupport(order = 2) + @ApiOperation(value = "统计通讯中断时间", notes = "传入imsDutyMainEntity") + public R> statisticsTime(HistoryAbnormalAlarmEntity entity, Query query) { + IPage pages = service.getAlarmTime(query,entity); + return R.data(pages); + } + /** + * 统计通讯中断二级目录查询 + */ + @GetMapping("/queryByEntity") + @ApiOperationSupport(order = 2) + @ApiOperation(value = "统计通讯中断二级目录查询", notes = "传入imsDutyMainEntity") + public R> queryByEntity(HistoryAbnormalAlarmEntity entity, Query query) { + IPage pages = service.queryByEntity(entity,query); + return R.data(pages); + } /** * 详情 diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/mapper/HistoryAbnormalAlarmMapper.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/mapper/HistoryAbnormalAlarmMapper.java index be67201..3f330b4 100644 --- a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/mapper/HistoryAbnormalAlarmMapper.java +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/mapper/HistoryAbnormalAlarmMapper.java @@ -19,4 +19,6 @@ public interface HistoryAbnormalAlarmMapper extends UserDataScopeBaseMapper selectPageList(IPage page, String type, List stations); + + List getAlarmEntity(@Param("type") String type,@Param("stationName") String stationName,@Param("startTime") Date startTime,@Param("endTime") Date endTime); } diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/mapper/HistoryAbnormalAlarmMapper.xml b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/mapper/HistoryAbnormalAlarmMapper.xml index 76d3599..a8e7014 100644 --- a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/mapper/HistoryAbnormalAlarmMapper.xml +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/mapper/HistoryAbnormalAlarmMapper.xml @@ -11,7 +11,7 @@ + + diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/service/HistoryAbnormalAlarmService.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/service/HistoryAbnormalAlarmService.java index 33670db..11145a6 100644 --- a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/service/HistoryAbnormalAlarmService.java +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/service/HistoryAbnormalAlarmService.java @@ -18,4 +18,8 @@ public interface HistoryAbnormalAlarmService extends BaseService list(IPage page, String type); + + IPage getAlarmTime(Query query, HistoryAbnormalAlarmEntity entity); + + IPage queryByEntity(HistoryAbnormalAlarmEntity entity,Query query); } diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/service/impl/HistoryAbnormalAlarmServiceImpl.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/service/impl/HistoryAbnormalAlarmServiceImpl.java index 5fa834f..efdc489 100644 --- a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/service/impl/HistoryAbnormalAlarmServiceImpl.java +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/alert/service/impl/HistoryAbnormalAlarmServiceImpl.java @@ -1,5 +1,7 @@ package com.hnac.hzims.operational.alert.service.impl; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.hnac.hzims.operational.alert.entity.HistoryAbnormalAlarmEntity; import com.hnac.hzims.operational.alert.mapper.HistoryAbnormalAlarmMapper; @@ -10,12 +12,18 @@ import com.hnac.hzims.operational.station.service.IStationService; import com.hnac.hzims.operational.station.vo.HistoryAbnormalAlarmVo; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; +import net.logstash.logback.encoder.org.apache.commons.lang3.ObjectUtils; +import net.logstash.logback.encoder.org.apache.commons.lang3.StringUtils; import org.springblade.core.mp.base.BaseServiceImpl; +import org.springblade.core.mp.support.Condition; +import org.springblade.core.mp.support.Query; import org.springblade.core.tool.utils.CollectionUtil; +import org.springframework.beans.BeanUtils; +import org.springframework.data.domain.Page; import org.springframework.stereotype.Service; -import java.util.Date; -import java.util.List; +import java.math.BigDecimal; +import java.util.*; import java.util.stream.Collectors; /** @@ -56,4 +64,91 @@ public class HistoryAbnormalAlarmServiceImpl extends BaseServiceImpl getAlarmTime(Query query, HistoryAbnormalAlarmEntity entity) { + List historyAbnormalAlarmVos= this.baseMapper.getAlarmEntity(entity.getType(),entity.getStationName(),entity.getStartTime(),entity.getEndTime()); + if (historyAbnormalAlarmVos==null){ + return null; + } + //赋值空的endTime + if(ObjectUtils.isNotEmpty(entity.getEndTime())){ + historyAbnormalAlarmVos.stream().filter(s->s.getEndTime()==null).forEach(s->s.setEndTime(entity.getEndTime())); + }else { + historyAbnormalAlarmVos.stream().filter(s -> s.getEndTime() == null).forEach(s -> s.setEndTime(new Date())); + } + List voList = historyAbnormalAlarmVos.parallelStream().map(s -> { + s.setTimes((s.getEndTime().getTime() - s.getStartTime().getTime())); + return s; + }).collect(Collectors.toList()); + //次数统计 + Map timesList = voList.stream().collect(Collectors.groupingBy(HistoryAbnormalAlarmEntity::getStationName, + Collectors.counting())); + //时间统计 + Map durationList = voList.stream().collect(Collectors.groupingBy(HistoryAbnormalAlarmEntity::getStationName, + Collectors.summingLong(HistoryAbnormalAlarmVo::getTimes))); + + List res=new ArrayList<>(); + for (Map.Entry entry : durationList.entrySet()) { + //累计时长 + double v = BigDecimal.valueOf(entry.getValue() / (1000 * 60 * 60.00)).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue(); + HistoryAbnormalAlarmVo historyAbnormalAlarmVo = new HistoryAbnormalAlarmVo(); + historyAbnormalAlarmVo.setDuration(v); + String key = entry.getKey(); + historyAbnormalAlarmVo.setStationName(key); + historyAbnormalAlarmVo.setTimes(timesList.get(key)); + if(StringUtils.isNotEmpty(entity.getType())){ + historyAbnormalAlarmVo.setType(entity.getType()); + } + res.add(historyAbnormalAlarmVo); + } + //根据电站名字排序 + res=res.stream(). + sorted(Comparator.comparing(HistoryAbnormalAlarmVo::getStationName)) + .collect(Collectors.toList()); + IPage page = Condition.getPage(query); + page.setTotal(res.size()); + if (query==null){ + page.setRecords(res); + }else { + if (res.size()>query.getCurrent()* query.getSize()) { + page.setRecords(res.subList((query.getCurrent() - 1) * query.getSize(), query.getCurrent() * query.getSize())); + }else { + page.setRecords(res.subList((query.getCurrent() - 1) * query.getSize(), res.size())); + } + } + return page; + } + + + private QueryWrapper getAlarmEntityQueryWrapper(HistoryAbnormalAlarmEntity entity) { + QueryWrapper queryWrapper = new QueryWrapper<>(); + if (entity.getStationName()!=null) { + queryWrapper.lambda().eq(HistoryAbnormalAlarmEntity::getStationName, entity.getStationName()); + } + if (entity.getType()!=null) { + queryWrapper.lambda().eq(HistoryAbnormalAlarmEntity::getType, entity.getType()); + } + if (entity.getStartTime()!=null) { + queryWrapper.lambda().le(HistoryAbnormalAlarmEntity::getStartTime, entity.getStartTime()); + } + if (entity.getEndTime()!=null) { + queryWrapper.lambda().ge(HistoryAbnormalAlarmEntity::getStartTime, entity.getEndTime()); + } + return queryWrapper; + } + + @Override + public IPage queryByEntity(HistoryAbnormalAlarmEntity entity,Query query) { + QueryWrapper alarmEntityQueryWrapper = getAlarmEntityQueryWrapper(entity); + IPage historyAbnormalAlarmEntityIPage = this.baseMapper.selectPage(Condition.getPage(query), alarmEntityQueryWrapper); + return historyAbnormalAlarmEntityIPage; + } + } diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/vo/HistoryAbnormalAlarmVo.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/vo/HistoryAbnormalAlarmVo.java index 93a460a..5f71f64 100644 --- a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/vo/HistoryAbnormalAlarmVo.java +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/vo/HistoryAbnormalAlarmVo.java @@ -1,9 +1,17 @@ package com.hnac.hzims.operational.station.vo; +import com.baomidou.mybatisplus.annotation.TableField; import com.hnac.hzims.operational.alert.entity.HistoryAbnormalAlarmEntity; +import io.swagger.annotations.ApiModelProperty; import lombok.Data; @Data public class HistoryAbnormalAlarmVo extends HistoryAbnormalAlarmEntity{ + @TableField(exist=false) + @ApiModelProperty("告警次数") + private Long times; + @TableField(exist=false) + @ApiModelProperty("告警时长") + private Double duration; } From e4a33e04bcb551f14dbf387336ac40eb1e1e21d4 Mon Sep 17 00:00:00 2001 From: yang_shj Date: Wed, 15 Mar 2023 16:24:23 +0800 Subject: [PATCH 2/4] =?UTF-8?q?#=E6=95=B0=E6=8D=AE=E5=A1=AB=E6=8A=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/hnac/hzims/operational/census/vo/CompleteDefectVo.java | 3 +++ .../com/hnac/hzims/operational/census/vo/CompleteGenerationVo.java | 5 +++++ .../java/com/hnac/hzims/operational/census/vo/CompleteOtherVo.java | 4 ++++ .../com/hnac/hzims/operational/census/vo/ElectricGenerationVo.java | 3 +++ .../java/com/hnac/hzims/operational/census/vo/ExamineCardVo.java | 4 ++++ .../com/hnac/hzims/operational/census/vo/HydropowerTargetVo.java | 4 ++++ .../com/hnac/hzims/operational/census/vo/InstalledCapacityVo.java | 3 +++ .../java/com/hnac/hzims/operational/census/vo/WaterTargetVo.java | 5 +++++ .../hzims/operational/census/service/impl/TargetServiceImpl.java | 5 +++-- 9 files changed, 34 insertions(+), 2 deletions(-) diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/CompleteDefectVo.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/CompleteDefectVo.java index 68edd69..02b9f8f 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/CompleteDefectVo.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/CompleteDefectVo.java @@ -1,5 +1,7 @@ package com.hnac.hzims.operational.census.vo; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.NullSerializer; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -21,5 +23,6 @@ public class CompleteDefectVo { private Integer completeCount; @ApiModelProperty("消缺率") + @JsonSerialize(nullsUsing = NullSerializer.class) private Double completeRate; } diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/CompleteGenerationVo.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/CompleteGenerationVo.java index 4136ab5..bef599a 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/CompleteGenerationVo.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/CompleteGenerationVo.java @@ -1,5 +1,7 @@ package com.hnac.hzims.operational.census.vo; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.NullSerializer; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -15,11 +17,14 @@ public class CompleteGenerationVo { private String stationName; @ApiModelProperty("计划发电量") + @JsonSerialize(nullsUsing = NullSerializer.class) private Double planGeneration; @ApiModelProperty("实际发电量") + @JsonSerialize(nullsUsing = NullSerializer.class) private Double realityGeneration; @ApiModelProperty("完成率") + @JsonSerialize(nullsUsing = NullSerializer.class) private Double completeRate; } diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/CompleteOtherVo.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/CompleteOtherVo.java index a063268..2de17f7 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/CompleteOtherVo.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/CompleteOtherVo.java @@ -1,5 +1,7 @@ package com.hnac.hzims.operational.census.vo; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.NullSerializer; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -15,8 +17,10 @@ public class CompleteOtherVo { private String stationName; @ApiModelProperty("设备在线率") + @JsonSerialize(nullsUsing = NullSerializer.class) private Double onlineRate; @ApiModelProperty("Fa投入条数") + @JsonSerialize(nullsUsing = NullSerializer.class) private Double faCount; } diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/ElectricGenerationVo.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/ElectricGenerationVo.java index 0381de7..ba6c97f 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/ElectricGenerationVo.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/ElectricGenerationVo.java @@ -1,5 +1,7 @@ package com.hnac.hzims.operational.census.vo; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.NullSerializer; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -15,6 +17,7 @@ public class ElectricGenerationVo { private String stationName; @ApiModelProperty("发容量") + @JsonSerialize(nullsUsing = NullSerializer.class) private Double electricGeneration; @ApiModelProperty("详情") diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/ExamineCardVo.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/ExamineCardVo.java index e88a627..192290b 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/ExamineCardVo.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/ExamineCardVo.java @@ -1,5 +1,7 @@ package com.hnac.hzims.operational.census.vo; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.NullSerializer; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -17,8 +19,10 @@ public class ExamineCardVo { private String stationName; @ApiModelProperty("检修卡数量") + @JsonSerialize(nullsUsing = NullSerializer.class) private Integer cardCount; @ApiModelProperty("检修卡总额") + @JsonSerialize(nullsUsing = NullSerializer.class) private Double cardTotal; } diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/HydropowerTargetVo.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/HydropowerTargetVo.java index 4d322a5..03b0119 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/HydropowerTargetVo.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/HydropowerTargetVo.java @@ -1,5 +1,7 @@ package com.hnac.hzims.operational.census.vo; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.NullSerializer; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -15,8 +17,10 @@ public class HydropowerTargetVo { private String stationName; @ApiModelProperty("发电量") + @JsonSerialize(nullsUsing = NullSerializer.class) private Double electric; @ApiModelProperty("功率") + @JsonSerialize(nullsUsing = NullSerializer.class) private Double power; } diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/InstalledCapacityVo.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/InstalledCapacityVo.java index 835ce30..71db3ec 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/InstalledCapacityVo.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/InstalledCapacityVo.java @@ -1,5 +1,7 @@ package com.hnac.hzims.operational.census.vo; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.NullSerializer; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -15,6 +17,7 @@ public class InstalledCapacityVo { private String stationName; @ApiModelProperty("装机容量") + @JsonSerialize(nullsUsing = NullSerializer.class) private Double installedCapacity; @ApiModelProperty("详情") diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/WaterTargetVo.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/WaterTargetVo.java index 86ee588..2eba78e 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/WaterTargetVo.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/census/vo/WaterTargetVo.java @@ -1,5 +1,8 @@ package com.hnac.hzims.operational.census.vo; +import com.alibaba.fastjson.annotation.JSONField; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.NullSerializer; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -15,8 +18,10 @@ public class WaterTargetVo { private String stationName; @ApiModelProperty("用电量") + @JsonSerialize(nullsUsing = NullSerializer.class) private Double use; @ApiModelProperty("功率") + @JsonSerialize(nullsUsing = NullSerializer.class) private Double load; } diff --git a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/census/service/impl/TargetServiceImpl.java b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/census/service/impl/TargetServiceImpl.java index 6d9b388..f07e1a7 100644 --- a/hzims-service/operational/src/main/java/com/hnac/hzims/operational/census/service/impl/TargetServiceImpl.java +++ b/hzims-service/operational/src/main/java/com/hnac/hzims/operational/census/service/impl/TargetServiceImpl.java @@ -718,7 +718,7 @@ public class TargetServiceImpl implements TargetService { return hydropowerTarget; } Double power = activePowerMap.get(station.getCode()); - hydropowerTarget.setPower(power); + hydropowerTarget.setPower(Optional.ofNullable(power).orElse(0.0)); return hydropowerTarget; }).sorted(Comparator.comparing(HydropowerTargetVo::getPower)).collect(Collectors.toList()); } @@ -786,7 +786,8 @@ public class TargetServiceImpl implements TargetService { water.setUse(0.0); return water; } - water.setUse(pumps.stream().filter(o->o.getDeptId().equals(station.getRefDept())).mapToDouble(WaterPumpRealVo::getActivePower).sum()); + Double use = pumps.stream().filter(o->o.getDeptId().equals(station.getRefDept())).mapToDouble(WaterPumpRealVo::getActivePower).sum(); + water.setUse(Optional.ofNullable(use).orElse(0.0)); return water; }).sorted(Comparator.comparing(WaterTargetVo::getLoad)).collect(Collectors.toList()); } From ccc4fc2215476f3474a766b062946d4d2474f535 Mon Sep 17 00:00:00 2001 From: yang_shj Date: Wed, 15 Mar 2023 16:32:26 +0800 Subject: [PATCH 3/4] =?UTF-8?q?#=E6=95=B0=E6=8D=AE=E5=A1=AB=E6=8A=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/hnac/hzims/operational/fill/entity/NotInsertUseEntity.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/fill/entity/NotInsertUseEntity.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/fill/entity/NotInsertUseEntity.java index 95b3a05..73c5c42 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/fill/entity/NotInsertUseEntity.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/fill/entity/NotInsertUseEntity.java @@ -26,7 +26,7 @@ public class NotInsertUseEntity extends TenantEntity implements Serializable { private String stationName; @ApiModelProperty("用电量") - private BigDecimal use; + private BigDecimal using; @ApiModelProperty("填报日期") private Date fillDate; From e09d297ebaecfb84ef63baee48dd4c1d5b0d3ad5 Mon Sep 17 00:00:00 2001 From: yang_shj Date: Wed, 15 Mar 2023 16:34:47 +0800 Subject: [PATCH 4/4] =?UTF-8?q?#=E6=95=B0=E6=8D=AE=E5=A1=AB=E6=8A=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/hnac/hzims/operational/fill/entity/NotInsertUseEntity.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/fill/entity/NotInsertUseEntity.java b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/fill/entity/NotInsertUseEntity.java index 73c5c42..6c2c565 100644 --- a/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/fill/entity/NotInsertUseEntity.java +++ b/hzims-service-api/hzims-operational-api/src/main/java/com/hnac/hzims/operational/fill/entity/NotInsertUseEntity.java @@ -26,7 +26,7 @@ public class NotInsertUseEntity extends TenantEntity implements Serializable { private String stationName; @ApiModelProperty("用电量") - private BigDecimal using; + private BigDecimal usefulness; @ApiModelProperty("填报日期") private Date fillDate;