diff --git a/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordDnbInstant.java b/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordDnbInstant.java index a047574..1880770 100644 --- a/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordDnbInstant.java +++ b/os-ems/src/main/java/com/os/ems/record/domain/EmsRecordDnbInstant.java @@ -71,6 +71,10 @@ public class EmsRecordDnbInstant extends BaseEntity @Excel(name = "正向有功") private BigDecimal zxyg; + /** 反向有功 */ + @Excel(name = "反向有功") + private BigDecimal fxyg; + /** 有功功率 */ @Excel(name = "有功功率") private BigDecimal activePower; @@ -83,6 +87,14 @@ public class EmsRecordDnbInstant extends BaseEntity @Excel(name = "采集方式", readConverterExp = "0=自动,1=手动") private Long collectType; + public BigDecimal getFxyg() { + return fxyg; + } + + public void setFxyg(BigDecimal fxyg) { + this.fxyg = fxyg; + } + public String getMonitorName() { return monitorName; } diff --git a/os-ems/src/main/java/com/os/ems/report/domain/EmsReportPointDnb.java b/os-ems/src/main/java/com/os/ems/report/domain/EmsReportPointDnb.java index 4a759cc..fd29b31 100644 --- a/os-ems/src/main/java/com/os/ems/report/domain/EmsReportPointDnb.java +++ b/os-ems/src/main/java/com/os/ems/report/domain/EmsReportPointDnb.java @@ -74,6 +74,34 @@ public class EmsReportPointDnb extends BaseEntity { @Excel(name = "修改标识", readConverterExp = "0=是,1=否") private String updateFlag; + /** + * 发电量 + */ + @Excel(name = "发电量") + private BigDecimal powerExpend; + + /** + * 反向有功仪表值 + */ + @Excel(name = "反向有功仪表值") + private BigDecimal powerValue; + + public BigDecimal getPowerExpend() { + return powerExpend; + } + + public void setPowerExpend(BigDecimal powerExpend) { + this.powerExpend = powerExpend; + } + + public BigDecimal getPowerValue() { + return powerValue; + } + + public void setPowerValue(BigDecimal powerValue) { + this.powerValue = powerValue; + } + public String getMonitorName() { return monitorName; } diff --git a/os-ems/src/main/java/com/os/ems/report/domain/EnergyStatisticalReport.java b/os-ems/src/main/java/com/os/ems/report/domain/EnergyStatisticalReport.java index ee2ef18..d4c13a0 100644 --- a/os-ems/src/main/java/com/os/ems/report/domain/EnergyStatisticalReport.java +++ b/os-ems/src/main/java/com/os/ems/report/domain/EnergyStatisticalReport.java @@ -34,6 +34,12 @@ public class EnergyStatisticalReport extends BaseEntity { @Excel(name = "耗量(kwh)") private BigDecimal expend; + /** + * 发电量(kwh) + */ + @Excel(name = "发电量(kwh)") + private BigDecimal powerExpend; + /** * 开始日期 */ @@ -52,6 +58,14 @@ public class EnergyStatisticalReport extends BaseEntity { @Excel(name = "仪表值(kwh)") private BigDecimal instrumentValue; + public BigDecimal getPowerExpend() { + return powerExpend; + } + + public void setPowerExpend(BigDecimal powerExpend) { + this.powerExpend = powerExpend; + } + public String getWorkUnitCode() { return workUnitCode; } diff --git a/os-ems/src/main/java/com/os/ems/report/service/impl/EmsReportServiceImpl.java b/os-ems/src/main/java/com/os/ems/report/service/impl/EmsReportServiceImpl.java index 2835032..7ef1d71 100644 --- a/os-ems/src/main/java/com/os/ems/report/service/impl/EmsReportServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/report/service/impl/EmsReportServiceImpl.java @@ -93,15 +93,22 @@ public class EmsReportServiceImpl implements IEmsReportService { for (EmsBaseWorkUnit unit : workUnits) { HashMap typeResultMap = new HashMap<>(); + typeResultMap.put("objId", unit.getObjId()); + typeResultMap.put("parentId", unit.getParentId()); typeResultMap.put("unitName", unit.getWorkUnitName()); selectMap.put("workUnitCode", unit.getWorkUnitCode()); List reportList = this.energyStatisticalReportList(selectMap); BigDecimal expendSum = new BigDecimal(0); + BigDecimal powerExpendSum = new BigDecimal(0); for (EnergyStatisticalReport report : reportList) { + typeResultMap.put("dateData|" + report.getBeginTime(), report.getExpend().add(report.getPowerExpend())); typeResultMap.put("expend" + report.getBeginTime(), report.getExpend()); expendSum = expendSum.add(report.getExpend()); + typeResultMap.put("powerExpend" + report.getBeginTime(), report.getPowerExpend()); + powerExpendSum = powerExpendSum.add(report.getPowerExpend()); } typeResultMap.put("expendSum", expendSum.toPlainString()); + typeResultMap.put("powerExpendSum", powerExpendSum.toPlainString()); resultList.add(typeResultMap); } diff --git a/os-ems/src/main/resources/mapper/ems/record/EmsRecordDnbInstantMapper.xml b/os-ems/src/main/resources/mapper/ems/record/EmsRecordDnbInstantMapper.xml index 9979adf..16d3c42 100644 --- a/os-ems/src/main/resources/mapper/ems/record/EmsRecordDnbInstantMapper.xml +++ b/os-ems/src/main/resources/mapper/ems/record/EmsRecordDnbInstantMapper.xml @@ -37,6 +37,7 @@ rdi.record_time, rdi.glys, rdi.zxyg, + rdi.fxyg, rdi.active_power, rdi.reactive_power, rdi.collect_type diff --git a/os-ems/src/main/resources/mapper/ems/report/EmsReportMapper.xml b/os-ems/src/main/resources/mapper/ems/report/EmsReportMapper.xml index 639ebec..6b465c2 100644 --- a/os-ems/src/main/resources/mapper/ems/report/EmsReportMapper.xml +++ b/os-ems/src/main/resources/mapper/ems/report/EmsReportMapper.xml @@ -12,6 +12,7 @@ WU.WORK_UNIT_NAME workUnitName, MAX(RPD.INSTRUMENT_VALUE) instrumentValue, SUM(RPD.EXPEND) expend, + SUM(RPD.power_expend) powerExpend, SUBSTRING(FORMAT(RPD.BEGIN_TIME, 'yyyy-MM-dd HH:mm:ss'), 1, DT.TIMESUB) beginTime, SUBSTRING(FORMAT(RPD.BEGIN_TIME, 'yyyy-MM-dd HH:mm:ss'), 1, DT.TIMESUB) endTime FROM ems_base_work_unit WU diff --git a/os-ems/src/main/resources/mapper/ems/report/EmsReportPointDnbMapper.xml b/os-ems/src/main/resources/mapper/ems/report/EmsReportPointDnbMapper.xml index f78f8b5..9838956 100644 --- a/os-ems/src/main/resources/mapper/ems/report/EmsReportPointDnbMapper.xml +++ b/os-ems/src/main/resources/mapper/ems/report/EmsReportPointDnbMapper.xml @@ -18,6 +18,8 @@ + + @@ -26,6 +28,8 @@ ebmi.monitor_name, erpd.instrument_value, erpd.expend, + erpd.power_expend, + erpd.power_value, erpd.record_time, erpd.begin_time, erpd.end_time, @@ -72,6 +76,8 @@ create_time, update_by, update_time, + power_expend, + power_value, #{monitorCode}, @@ -85,6 +91,8 @@ #{createTime}, #{updateBy}, #{updateTime}, + #{powerExpend}, + #{powerValue}, @@ -102,6 +110,8 @@ create_time = #{createTime}, update_by = #{updateBy}, update_time = #{updateTime}, + power_expend = #{powerExpend}, + power_value = #{powerValue}, where obj_id = #{objId}