diff --git a/mh-common/pom.xml b/mh-common/pom.xml
index de4032c..0947baa 100644
--- a/mh-common/pom.xml
+++ b/mh-common/pom.xml
@@ -150,6 +150,11 @@
+
+ com.alibaba
+ easyexcel
+
+
org.projectlombok
lombok
diff --git a/mh-common/src/main/java/com/mh/common/constant/Constants.java b/mh-common/src/main/java/com/mh/common/constant/Constants.java
index d058ee4..56c52c7 100644
--- a/mh-common/src/main/java/com/mh/common/constant/Constants.java
+++ b/mh-common/src/main/java/com/mh/common/constant/Constants.java
@@ -1,15 +1,15 @@
package com.mh.common.constant;
import java.util.Locale;
+
import io.jsonwebtoken.Claims;
/**
* 通用常量信息
- *
+ *
* @author mh
*/
-public class Constants
-{
+public class Constants {
/**
* UTF-8 字符集
*/
@@ -158,16 +158,53 @@ public class Constants
/**
* 自动识别json对象白名单配置（仅允许解析的包名，范围越小越安全）
*/
- public static final String[] JSON_WHITELIST_STR = { "org.springframework", "com.mh" };
+ public static final String[] JSON_WHITELIST_STR = {"org.springframework", "com.mh"};
/**
* 定时任务白名单配置（仅允许访问的包名，如其他需要可以自行添加）
*/
- public static final String[] JOB_WHITELIST_STR = { "com.mh.quartz.task" };
+ public static final String[] JOB_WHITELIST_STR = {"com.mh.quartz.task"};
/**
* 定时任务违规的字符
*/
- public static final String[] JOB_ERROR_STR = { "java.net.URL", "javax.naming.InitialContext", "org.yaml.snakeyaml",
- "org.springframework", "org.apache", "com.mh.common.utils.file", "com.mh.common.config", "com.mh.generator" };
+ public static final String[] JOB_ERROR_STR = {"java.net.URL", "javax.naming.InitialContext", "org.yaml.snakeyaml",
+ "org.springframework", "org.apache", "com.mh.common.utils.file", "com.mh.common.config", "com.mh.generator"};
+
+ public static final String DAY = "day";
+ public static final String MONTH = "month";
+ public static final String CLOSE_ORDER = "close_oder"; // 关闭指令
+ public static final String HOST_TYPE = "host"; // 主机设备类型
+ public static final String VALVE_TYPE = "Valve"; // 蝶阀类型
+ public static final String COOL_PUMP_TYPE = "coolPump"; // 冷却泵
+ public static final String COOL_PUMP_TYPE_STRING = "冷却泵"; // 冷却泵
+ public static final String CHILLER_PUMP_TYPE = "chillPump"; // 冷冻泵
+ public static final String COOL_TOWER_TYPE = "tower"; // 冷却塔
+ public static final String CLOSE_HOST = "close_host_device_id"; // 关闭主机的设备id
+ public static final String OPEN_VALVE = "open_valve_device_id"; // 开启蝶阀的设备id
+ public static boolean CONTROL_WEB_FLAG = false;
+ public static boolean SEND_STATUS = false; // 指令发送状态
+ public static boolean FLAG = false;
+ public static boolean WEB_FLAG = false; // 判断是否有前端指令下发
+ public static final String TYPE_DDC = "ddc"; // 查询ddc指令
+ public static final String TYPE_REGISTER = "registers"; // 查询ddc指令
+ public static final String DATE_FORMAT = "yyyy-MM-dd HH:mm:ss"; // 格式化时间
+
+ public static final String METER_TYPE = "meter";
+
+ public static final String CLOUD_TYPE = "cloud";
+
+ public static final String[] DEVICE_TYPE = {"冷水机组(kwh)", "冷冻泵(kwh)", "冷却泵(kwh)", "冷却塔(kwh)", "其他"}; // 设备类型
+
+ public static final String ADD_TIME = "add_time_";
+
+ public static final String DELETE_TIME = "delete_time_";
+
+ public static final String CP_PID_Type = "CPPIDType"; // 冷却泵PID值
+
+ public static final String OPEN_DEVICES = "open_devices"; // 一键启动设备
+
+ public static final String ADD_CHILLER = "add_chiller"; // 添加主机
+
+ public static final String DELETE_CHILLER = "delete_chiller"; // 减少主机
}
diff --git a/mh-common/src/main/java/com/mh/common/core/domain/ColumnFilter.java b/mh-common/src/main/java/com/mh/common/core/domain/ColumnFilter.java
new file mode 100644
index 0000000..f2b9970
--- /dev/null
+++ b/mh-common/src/main/java/com/mh/common/core/domain/ColumnFilter.java
@@ -0,0 +1,32 @@
+package com.mh.common.core.domain;
+
+/**
+ * 分页查询列过滤器
+ * @author Louis
+ * @date Aug 19, 2018
+ */
+public class ColumnFilter {
+
+ /**
+ * 过滤列名
+ */
+ private String name;
+ /**
+ * 查询的值
+ */
+ private String value;
+
+ public String getName() {
+ return name;
+ }
+ public void setName(String name) {
+ this.name = name;
+ }
+ public String getValue() {
+ return value;
+ }
+ public void setValue(String value) {
+ this.value = value;
+ }
+
+}
diff --git a/mh-common/src/main/java/com/mh/common/core/domain/entity/CollectionParamsManage.java b/mh-common/src/main/java/com/mh/common/core/domain/entity/CollectionParamsManage.java
index cced3c3..728c8e9 100644
--- a/mh-common/src/main/java/com/mh/common/core/domain/entity/CollectionParamsManage.java
+++ b/mh-common/src/main/java/com/mh/common/core/domain/entity/CollectionParamsManage.java
@@ -148,6 +148,19 @@ public class CollectionParamsManage extends BaseEntity {
*/
private String otherName;
+ /**
+ * 累计/瞬时 状态标识
+ */
+ private Integer grade;
+
+ public Integer getGrade() {
+ return grade;
+ }
+
+ public void setGrade(Integer grade) {
+ this.grade = grade;
+ }
+
public String getOtherName() {
return otherName;
}
@@ -385,6 +398,8 @@ public class CollectionParamsManage extends BaseEntity {
.append("registerSize", registerSize)
.append("isUse", isUse)
.append("otherName", otherName)
+ .append("grade", grade)
.toString();
}
+
}
diff --git a/mh-common/src/main/java/com/mh/common/core/domain/entity/DeviceTypeEnergyEntity.java b/mh-common/src/main/java/com/mh/common/core/domain/entity/DeviceTypeEnergyEntity.java
new file mode 100644
index 0000000..964f3f4
--- /dev/null
+++ b/mh-common/src/main/java/com/mh/common/core/domain/entity/DeviceTypeEnergyEntity.java
@@ -0,0 +1,106 @@
+package com.mh.common.core.domain.entity;
+
+import java.io.Serializable;
+
+/**
+ * @author LJF
+ * @version 1.0
+ * @project NewZhujiang_Server
+ * @description 各个设备类型组装成的DTO
+ * @date 2023-12-14 15:12:30
+ */
+public class DeviceTypeEnergyEntity implements Serializable {
+
+ private static final long serialVersionUID = 10L;
+
+ private String calcValue;
+
+ private String deviceNum;
+
+ private String remark;
+
+ private String deviceType;
+
+ private String grade;
+
+ private String timeStr;
+
+ public String getTimeStr() {
+ return timeStr;
+ }
+
+ public void setTimeStr(String timeStr) {
+ this.timeStr = timeStr;
+ }
+
+ public String getGrade() {
+ return grade;
+ }
+
+ public void setGrade(String grade) {
+ this.grade = grade;
+ }
+
+ public String getCalcValue() {
+ return calcValue;
+ }
+
+ public void setCalcValue(String calcValue) {
+ this.calcValue = calcValue;
+ }
+
+ public String getDeviceNum() {
+ return deviceNum;
+ }
+
+ public void setDeviceNum(String deviceNum) {
+ this.deviceNum = deviceNum;
+ }
+
+ public String getRemark() {
+ return remark;
+ }
+
+ public void setRemark(String remark) {
+ this.remark = remark;
+ }
+
+ public String getDeviceType() {
+ return deviceType;
+ }
+
+ public void setDeviceType(String deviceType) {
+ this.deviceType = deviceType;
+ }
+
+ public String getDeviceTypeRange() {
+ if (Integer.parseInt(this.grade) < 10) {
+ return "冷水机组(kwh)";
+ } else if (Integer.parseInt(this.grade) >= 10 && Integer.parseInt(this.grade) < 20) {
+ return "冷冻泵(kwh)";
+ } else if (Integer.parseInt(this.grade) >= 20 && Integer.parseInt(this.grade) < 30) {
+ return "冷却泵(kwh)";
+ } else if (Integer.parseInt(this.grade) >= 30 && Integer.parseInt(this.grade) < 40) {
+ return "冷却塔(kwh)";
+ } else {
+ return "其他";
+ }
+ }
+
+ public Double getDoubleCalcValue() {
+ return Double.parseDouble(this.calcValue);
+ }
+
+ @Override
+ public String toString() {
+ return "DeviceTypeEnergyEntity{" +
+ "calcValue='" + calcValue + '\'' +
+ ", deviceNum='" + deviceNum + '\'' +
+ ", remark='" + remark + '\'' +
+ ", deviceType='" + deviceType + '\'' +
+ ", grade='" + grade + '\'' +
+ ", timeStr='" + timeStr + '\'' +
+ '}';
+ }
+
+}
diff --git a/mh-common/src/main/java/com/mh/common/core/domain/vo/EnergyConsumptionVO.java b/mh-common/src/main/java/com/mh/common/core/domain/vo/EnergyConsumptionVO.java
new file mode 100644
index 0000000..352a21f
--- /dev/null
+++ b/mh-common/src/main/java/com/mh/common/core/domain/vo/EnergyConsumptionVO.java
@@ -0,0 +1,92 @@
+package com.mh.common.core.domain.vo;
+
+import java.io.Serializable;
+
+/**
+ * @author LJF
+ * @version 1.0
+ * @project NewZhujiang_Server
+ * @description 能耗分析接收参数
+ * @date 2023/7/18 15:27:17
+ */
+public class EnergyConsumptionVO implements Serializable {
+
+ private static final long serialVersionUID = 10L;
+
+ /**
+ * 查询类型：hour，day，month，year
+ */
+ private String timeType;
+
+ /**
+ * 开始时间yyyy-MM-dd
+ */
+ private String startTime;
+
+ /**
+ * 结束时间：yyyy-MM-dd
+ */
+ private String endTime;
+
+ /**
+ * 设备类型：chiller：主机，chilledWaterPump：冷冻泵，coolingPump：冷却泵，coolingTower：冷却塔
+ */
+ private String deviceType;
+
+ /**
+ * 参数类型：cool，electric，cop
+ */
+ private String paramType;
+
+ public String getTimeType() {
+ return timeType;
+ }
+
+ public void setTimeType(String timeType) {
+ this.timeType = timeType;
+ }
+
+ public String getStartTime() {
+ return startTime;
+ }
+
+ public void setStartTime(String startTime) {
+ this.startTime = startTime;
+ }
+
+ public String getEndTime() {
+ return endTime;
+ }
+
+ public void setEndTime(String endTime) {
+ this.endTime = endTime;
+ }
+
+ public String getDeviceType() {
+ return deviceType;
+ }
+
+ public void setDeviceType(String deviceType) {
+ this.deviceType = deviceType;
+ }
+
+ public String getParamType() {
+ return paramType;
+ }
+
+ public void setParamType(String paramType) {
+ this.paramType = paramType;
+ }
+
+ @Override
+ public String toString() {
+ return "EnergyConsumptionVO{" +
+ "timeType='" + timeType + '\'' +
+ ", startTime='" + startTime + '\'' +
+ ", endTime='" + endTime + '\'' +
+ ", deviceType='" + deviceType + '\'' +
+ ", paramType='" + paramType + '\'' +
+ '}';
+ }
+
+}
diff --git a/mh-common/src/main/java/com/mh/common/core/domain/vo/EnergyQueryVO.java b/mh-common/src/main/java/com/mh/common/core/domain/vo/EnergyQueryVO.java
new file mode 100644
index 0000000..d10fc80
--- /dev/null
+++ b/mh-common/src/main/java/com/mh/common/core/domain/vo/EnergyQueryVO.java
@@ -0,0 +1,94 @@
+package com.mh.common.core.domain.vo;
+
+import com.mh.common.core.domain.BaseEntity;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+
+import java.io.Serializable;
+
+/**
+ * @author LJF
+ * @version 1.0
+ * @project NewZhujiang_Server
+ * @description 能耗查询公共参数
+ * @date 2023-12-13 16:11:24
+ */
+public class EnergyQueryVO extends BaseEntity implements Serializable {
+
+ private static final long serialVersionUID = 10L;
+
+ /**
+ * 查询类型：hour，day，month，year
+ */
+ private String timeType;
+
+ /**
+ * 开始时间yyyy-MM-dd
+ */
+ private String startTime;
+
+ /**
+ * 结束时间：yyyy-MM-dd
+ */
+ private String endTime;
+
+ /**
+ * 设备类型：chiller：主机，chilledWaterPump：冷冻泵，coolingPump：冷却泵，coolingTower：冷却塔
+ */
+ private String deviceType;
+
+ /**
+ * 参数类型：cool，electric，cop
+ */
+ private String paramType;
+
+ public String getTimeType() {
+ return timeType;
+ }
+
+ public void setTimeType(String timeType) {
+ this.timeType = timeType;
+ }
+
+ public String getStartTime() {
+ return startTime;
+ }
+
+ public void setStartTime(String startTime) {
+ this.startTime = startTime;
+ }
+
+ public String getEndTime() {
+ return endTime;
+ }
+
+ public void setEndTime(String endTime) {
+ this.endTime = endTime;
+ }
+
+ public String getDeviceType() {
+ return deviceType;
+ }
+
+ public void setDeviceType(String deviceType) {
+ this.deviceType = deviceType;
+ }
+
+ public String getParamType() {
+ return paramType;
+ }
+
+ public void setParamType(String paramType) {
+ this.paramType = paramType;
+ }
+
+ @Override
+ public String toString() {
+ return new ToStringBuilder(this)
+ .append("timeType", timeType)
+ .append("startTime", startTime)
+ .append("endTime", endTime)
+ .append("deviceType", deviceType)
+ .append("paramType", paramType)
+ .toString();
+ }
+}
diff --git a/mh-common/src/main/java/com/mh/common/utils/DateUtils.java b/mh-common/src/main/java/com/mh/common/utils/DateUtils.java
index fb2c224..14cddd9 100644
--- a/mh-common/src/main/java/com/mh/common/utils/DateUtils.java
+++ b/mh-common/src/main/java/com/mh/common/utils/DateUtils.java
@@ -1,14 +1,17 @@
package com.mh.common.utils;
import java.lang.management.ManagementFactory;
+import java.math.BigDecimal;
+import java.math.RoundingMode;
import java.text.ParseException;
import java.text.SimpleDateFormat;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.time.LocalTime;
-import java.time.ZoneId;
-import java.time.ZonedDateTime;
+import java.time.*;
+import java.time.format.DateTimeFormatter;
+import java.time.temporal.TemporalAdjusters;
import java.util.Date;
+
+import com.mh.common.core.domain.vo.EnergyConsumptionVO;
+import com.mh.common.core.domain.vo.EnergyQueryVO;
import org.apache.commons.lang3.time.DateFormatUtils;
/**
@@ -188,4 +191,145 @@ public class DateUtils extends org.apache.commons.lang3.time.DateUtils
ZonedDateTime zdt = localDateTime.atZone(ZoneId.systemDefault());
return Date.from(zdt.toInstant());
}
+
+ /*
+ * 获取同一个时间的上一个时间
+ * @param timerStr
+ * @return
+ */
+ public static String yoyDate(String timerStr) {
+ DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+ DateTimeFormatter timeFormatter1 = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+ LocalDate localDate = LocalDate.parse(timerStr, timeFormatter);
+ LocalDate localDate1 = localDate.minusYears(1);
+ return localDate1.format(timeFormatter1).concat(timerStr.substring(10));
+ }
+
+ /**
+ * 获取同一个时间的上一个时间
+ * @param timerStr
+ * @return
+ */
+ public static String momDate(String timerStr, String timeType, String timeRange) {
+ DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+ LocalDateTime localDate = LocalDateTime.parse(timerStr, timeFormatter);
+ LocalDateTime localDate1 = null;
+ switch (timeType) {
+ case "hour":
+ localDate1 = localDate.minusHours(1);
+ break;
+ case "day":
+ localDate1 = localDate.minusDays(1);
+ break;
+ case "month":
+ if ("end".equals(timeRange)) {
+ localDate1 = localDate.minusMonths(1).with(TemporalAdjusters.lastDayOfMonth());
+ } else if ("start".equals(timeRange)) {
+ localDate1 = localDate.minusMonths(1).with(TemporalAdjusters.firstDayOfMonth());
+ }
+ break;
+ case "year":
+ localDate1 = localDate.minusYears(1);
+ break;
+ }
+ assert localDate1 != null;
+ return localDate1.format(timeFormatter);
+ }
+
+ public static void energyDateChange(EnergyConsumptionVO vo) {
+ switch (vo.getTimeType()) {
+ case "day":
+ vo.setStartTime(vo.getStartTime().concat(" 00:00:00"));
+ vo.setEndTime(vo.getEndTime().concat(" 23:59:59"));
+ break;
+ case "month":
+ YearMonth yearMonth = YearMonth.parse(vo.getStartTime(), DateTimeFormatter.ofPattern("yyyy-MM"));
+ LocalDate firstDayOfMonth = yearMonth.atDay(1);
+ String firstDayOutput = firstDayOfMonth.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+ vo.setStartTime(firstDayOutput.concat(" 00:00:00"));
+
+ YearMonth yearMonth1 = YearMonth.parse(vo.getEndTime(), DateTimeFormatter.ofPattern("yyyy-MM"));
+ LocalDate firstDayOfMonth1 = yearMonth1.atEndOfMonth();
+ String firstDayOutput1 = firstDayOfMonth1.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+ vo.setEndTime(firstDayOutput1.concat(" 23:59:59"));
+ break;
+ case "year":
+ vo.setStartTime(vo.getStartTime().concat("-01-01 00:00:00"));
+ vo.setEndTime(vo.getEndTime().concat("-12-31 23:59:59"));
+ break;
+ default:
+ break;
+ }
+ }
+
+ public static void sysEnergyDateChange(EnergyQueryVO vo) {
+ switch (vo.getTimeType()) {
+ case "day":
+ vo.setStartTime(vo.getStartTime().concat(" 00:00:00"));
+ vo.setEndTime(vo.getEndTime().concat(" 23:59:59"));
+ break;
+ case "month":
+ YearMonth yearMonth = YearMonth.parse(vo.getStartTime(), DateTimeFormatter.ofPattern("yyyy-MM"));
+ LocalDate firstDayOfMonth = yearMonth.atDay(1);
+ String firstDayOutput = firstDayOfMonth.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+ vo.setStartTime(firstDayOutput.concat(" 00:00:00"));
+
+ YearMonth yearMonth1 = YearMonth.parse(vo.getEndTime(), DateTimeFormatter.ofPattern("yyyy-MM"));
+ LocalDate firstDayOfMonth1 = yearMonth1.atEndOfMonth();
+ String firstDayOutput1 = firstDayOfMonth1.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+ vo.setEndTime(firstDayOutput1.concat(" 23:59:59"));
+ break;
+ case "year":
+ vo.setStartTime(vo.getStartTime().concat("-01-01 00:00:00"));
+ vo.setEndTime(vo.getEndTime().concat("-12-31 23:59:59"));
+ break;
+ default:
+ break;
+ }
+ }
+
+ /**
+ * 计算时间差
+ * @param curTime
+ * @param lastTime
+ * @param type
+ * @return
+ */
+ public static BigDecimal calcDate(Object curTime, Object lastTime, String type) {
+ String momDate = momDate((String) curTime, type, "");
+ DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+ long curDateMillis = 0;
+ long lastTimeMillis = 0;
+ try {
+ LocalDateTime dateTime = LocalDateTime.parse(momDate, formatter);
+ curDateMillis = dateTime.atZone(ZoneId.systemDefault()).toInstant().getEpochSecond();
+
+ LocalDateTime lastDateTime = LocalDateTime.parse((CharSequence) lastTime, formatter);
+ lastTimeMillis = lastDateTime.atZone(ZoneId.systemDefault()).toInstant().getEpochSecond();
+ } catch (Exception e) {
+ System.err.println("无法解析时间字符串: " + e.getMessage());
+ }
+
+ return (new BigDecimal(curDateMillis - lastTimeMillis)).divide(new BigDecimal(60),2, RoundingMode.HALF_UP);
+ }
+
+ public static String getTimeLen(String timeType) {
+ String timeLen = "";
+ switch (timeType) {
+ case "hour":
+ timeLen = "13";
+ break;
+ case "day":
+ timeLen = "10";
+ break;
+ case "month":
+ timeLen = "7";
+ break;
+ case "year":
+ timeLen = "4";
+ break;
+ }
+ return timeLen;
+ }
+
}
diff --git a/mh-system/src/main/java/com/mh/system/mapper/device/CollectionParamsManageMapper.java b/mh-system/src/main/java/com/mh/system/mapper/device/CollectionParamsManageMapper.java
index e67a425..fe523b5 100644
--- a/mh-system/src/main/java/com/mh/system/mapper/device/CollectionParamsManageMapper.java
+++ b/mh-system/src/main/java/com/mh/system/mapper/device/CollectionParamsManageMapper.java
@@ -2,7 +2,9 @@ package com.mh.system.mapper.device;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.mh.common.core.domain.entity.CollectionParamsManage;
-import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.*;
+
+import java.util.List;
/**
* @author LJF
@@ -13,4 +15,35 @@ import org.apache.ibatis.annotations.Mapper;
*/
@Mapper
public interface CollectionParamsManageMapper extends BaseMapper {
+
+ @Results({
+ @Result(column = "id", property = "id"),
+ @Result(column = "device_code", property = "deviceCode"),
+ @Result(column = "device_num", property = "deviceNum"),
+ @Result(column = "collection_num", property = "collectionNum"),
+ @Result(column = "data_com", property = "dataCom"),
+ @Result(column = "initial_value", property = "initialValue"),
+ @Result(column = "device_rate", property = "deviceRate"),
+ @Result(column = "device_caliber", property = "deviceCaliber"),
+ @Result(column = "price", property = "price"),
+ @Result(column = "param_id", property = "paramId"),
+ @Result(column = "param_name", property = "paramName"),
+ @Result(column = "last_value", property = "lastValue"),
+ @Result(column = "last_date", property = "lastDates"),
+ @Result(column = "communication_type", property = "communicationType"),
+ @Result(column = "device_type", property = "deviceType"),
+ @Result(column = "create_time", property = "createTimes"),
+ @Result(column = "update_time", property = "updateTimes"),
+ @Result(column = "remark", property = "remark"),
+ @Result(column = "grade", property = "grade")
+ })
+ @Select("")
+ List getDeviceByOther(@Param("deviceNum") String deviceNum);
}
diff --git a/mh-system/src/main/java/com/mh/system/service/energy/EnergyAnalyzeService.java b/mh-system/src/main/java/com/mh/system/service/energy/EnergyAnalyzeService.java
new file mode 100644
index 0000000..ad263b1
--- /dev/null
+++ b/mh-system/src/main/java/com/mh/system/service/energy/EnergyAnalyzeService.java
@@ -0,0 +1,26 @@
+package com.mh.system.service.energy;
+
+import com.alibaba.fastjson2.JSONObject;
+import com.mh.common.core.domain.AjaxResult;
+import com.mh.common.core.domain.ColumnFilter;
+import com.mh.common.core.domain.vo.EnergyQueryVO;
+
+import java.util.List;
+
+/**
+ * @author LJF
+ * @version 1.0
+ * @project NewZhujiang_Server
+ * @description 能源分析服务
+ * @date 2023-12-13 15:50:36
+ */
+public interface EnergyAnalyzeService {
+
+ /**
+ * 通过时间查询各个设备类型的用电量
+ * @param vo
+ * @return
+ */
+ JSONObject sysAnalyze(EnergyQueryVO vo);
+
+}
diff --git a/mh-system/src/main/java/com/mh/system/service/energy/impl/EnergyAnalyzeServiceImpl.java b/mh-system/src/main/java/com/mh/system/service/energy/impl/EnergyAnalyzeServiceImpl.java
new file mode 100644
index 0000000..381bdcd
--- /dev/null
+++ b/mh-system/src/main/java/com/mh/system/service/energy/impl/EnergyAnalyzeServiceImpl.java
@@ -0,0 +1,183 @@
+package com.mh.system.service.energy.impl;
+
+import com.alibaba.fastjson2.JSONObject;
+import com.mh.common.constant.Constants;
+import com.mh.common.core.domain.ColumnFilter;
+import com.mh.common.core.domain.entity.CollectionParamsManage;
+import com.mh.common.core.domain.entity.DeviceTypeEnergyEntity;
+import com.mh.common.core.domain.vo.EnergyQueryVO;
+import com.mh.common.utils.DateUtils;
+import com.mh.system.mapper.device.CollectionParamsManageMapper;
+import com.mh.system.mapper.energy.EnergyAnalyzeMapper;
+import com.mh.system.service.energy.EnergyAnalyzeService;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.util.*;
+import java.util.concurrent.atomic.AtomicReference;
+import java.util.stream.Collectors;
+
+/**
+ * @author LJF
+ * @version 1.0
+ * @project NewZhujiang_Server
+ * @description 能源分析实现类
+ * @date 2023-12-14 11:50:47
+ */
+@Service
+public class EnergyAnalyzeServiceImpl implements EnergyAnalyzeService {
+
+ @Resource
+ private EnergyAnalyzeMapper energyAnalyzeMapper;
+
+ @Resource
+ private CollectionParamsManageMapper collectionParamsManageMapper;
+
+ @Override
+ public JSONObject sysAnalyze(EnergyQueryVO vo) {
+ DateUtils.sysEnergyDateChange(vo);
+ // 获取参数
+ AtomicReference lastTableName = new AtomicReference<>("data_" + vo.getTimeType());
+ AtomicReference curTableName = new AtomicReference<>("data_" + vo.getTimeType());
+ String timeType = vo.getTimeType();
+ List deviceTypeEnergyEntities = null;
+ // 表格数据
+ if ("month".equalsIgnoreCase(timeType) || "year".equalsIgnoreCase(timeType)) {
+ // 单表
+ deviceTypeEnergyEntities = energyAnalyzeMapper.queryOneTable(vo.getStartTime(), vo.getEndTime(), lastTableName.get(), curTableName.get(), DateUtils.getTimeLen(vo.getTimeType()), Constants.METER_TYPE);
+ } else {
+ lastTableName.set(lastTableName + vo.getStartTime().substring(0, 4));
+ curTableName.set(curTableName + vo.getEndTime().substring(0, 4));
+ if (lastTableName.get().equalsIgnoreCase(curTableName.get())) {
+ // 单表
+ deviceTypeEnergyEntities = energyAnalyzeMapper.queryOneTable(vo.getStartTime(), vo.getEndTime(), lastTableName.get(), curTableName.get(), DateUtils.getTimeLen(vo.getTimeType()), Constants.METER_TYPE);
+ } else {
+ // 多表
+ deviceTypeEnergyEntities = energyAnalyzeMapper.queryManyTable(vo.getStartTime(), vo.getEndTime(), lastTableName.get(), curTableName.get(), DateUtils.getTimeLen(vo.getTimeType()), Constants.METER_TYPE);
+ }
+ }
+ if (null == deviceTypeEnergyEntities || deviceTypeEnergyEntities.size() == 0) {
+ return new JSONObject();
+ }
+ // 开始进行分组
+ // 通过device_manage的grade进行分组，分为四类：0-9：冷水机，10-19：冷冻泵，20-29：冷却泵，30-39：冷却塔
+ HashMap result = deviceTypeEnergyEntities.stream()
+ .collect(Collectors.groupingBy(DeviceTypeEnergyEntity::getDeviceTypeRange))
+ .entrySet().stream().collect(Collectors.toMap(
+ Map.Entry>::getKey,
+ entry -> {
+ List value = entry.getValue();
+ BigDecimal sum = new BigDecimal("0");
+ for (DeviceTypeEnergyEntity deviceTypeEnergyEntity : value) {
+ sum = sum.add(new BigDecimal(deviceTypeEnergyEntity.getCalcValue()));
+ }
+ return sum;
+ },
+ BigDecimal::add,
+ HashMap::new
+ ));
+ List results = new ArrayList<>();
+ for (String value : Constants.DEVICE_TYPE) {
+ ColumnFilter columnFilter = new ColumnFilter();
+ columnFilter.setName(value);
+ if (result.containsKey(value)) {
+ columnFilter.setValue(String.valueOf(result.get(value).setScale(2, RoundingMode.HALF_UP)));
+ results.add(columnFilter);
+ } else {
+ columnFilter.setValue("0.00");
+ results.add(columnFilter);
+ }
+ }
+
+ // 查询各个冷水机组的 0-9
+ List chiller = createDeviceTypeData(deviceTypeEnergyEntities, 10, 0);
+
+ // 查询各个冷冻泵的 10-19
+ List chillerPump = createDeviceTypeData(deviceTypeEnergyEntities, 20, 10);
+
+ // 查询各个冷却泵的 20-29
+ List coolPump = createDeviceTypeData(deviceTypeEnergyEntities, 30, 20);
+
+ // 查询各个冷却塔的 30-39
+ List coolTower = createDeviceTypeData(deviceTypeEnergyEntities, 40, 30);
+
+ // 从device_manage查询不是总表的
+ List deviceByOther = collectionParamsManageMapper.getDeviceByOther(null);
+
+
+ if (deviceByOther != null && deviceByOther.size() > 0) {
+ // 通过stream进行分组，然后进行重新赋值，封装新对象，重新返回
+ for (CollectionParamsManage deviceManageEntity : deviceByOther) {
+
+ // 重新赋值冷水机
+ reassignData(chiller, deviceManageEntity);
+
+ // 重新赋值冷冻泵
+ reassignData(chillerPump, deviceManageEntity);
+
+ // 重新赋值冷却泵
+ reassignData(coolPump, deviceManageEntity);
+
+ // 重新赋值冷却塔
+ reassignData(coolTower, deviceManageEntity);
+ }
+ }
+ List chillerData = getResultData(chiller);
+
+ List chillerPumpData = getResultData(chillerPump);
+
+ List coolPumpData = getResultData(coolPump);
+
+ List coolTowerData = getResultData(coolTower);
+
+ JSONObject resultJson = new JSONObject();
+ resultJson.put("all", results);
+ resultJson.put("chiller", chillerData);
+ resultJson.put("chillerPump", chillerPumpData);
+ resultJson.put("coolPump", coolPumpData);
+ resultJson.put("coolTower", coolTowerData);
+
+ return resultJson;
+ }
+
+ private static List getResultData(List coolTower) {
+ return coolTower.stream()
+ .sorted(Comparator.comparing(DeviceTypeEnergyEntity::getGrade))
+ .map(val -> {
+ ColumnFilter data = new ColumnFilter();
+ data.setName(val.getRemark());
+ BigDecimal calcValue = new BigDecimal(val.getCalcValue()).setScale(2, RoundingMode.HALF_UP);
+ data.setValue(String.valueOf(calcValue));
+ return data;
+ }).collect(Collectors.toList());
+ }
+
+ private static void reassignData(List chiller, CollectionParamsManage deviceManageEntity) {
+ chiller.stream()
+ .filter(val -> val.getDeviceNum().equals(deviceManageEntity.getMtNum()))
+ .peek(val -> {
+ val.setDeviceType(deviceManageEntity.getMtType());
+ val.setRemark(deviceManageEntity.getRemark());
+ val.setGrade(String.valueOf(deviceManageEntity.getGrade()));
+ })
+ .sorted(Comparator.comparing(DeviceTypeEnergyEntity::getGrade))
+ .collect(Collectors.toList());
+ }
+
+ private static List createDeviceTypeData(List deviceTypeEnergyEntities, int x, int x1) {
+ return deviceTypeEnergyEntities.stream()
+ .filter(val -> Integer.parseInt(val.getGrade()) < x && Integer.parseInt(val.getGrade()) >= x1)
+ .collect(Collectors.groupingBy(DeviceTypeEnergyEntity::getDeviceNum, Collectors.summarizingDouble(DeviceTypeEnergyEntity::getDoubleCalcValue)))
+ .entrySet().stream()
+ .map(entry -> {
+ DeviceTypeEnergyEntity deviceTypeEnergyEntity = new DeviceTypeEnergyEntity();
+ deviceTypeEnergyEntity.setCalcValue(String.valueOf(entry.getValue().getSum()));
+ deviceTypeEnergyEntity.setDeviceNum(entry.getKey());
+ return deviceTypeEnergyEntity;
+ })
+ .collect(Collectors.toList());
+ }
+
+}
diff --git a/pom.xml b/pom.xml
index b74ff1a..b34d4b5 100644
--- a/pom.xml
+++ b/pom.xml
@@ -39,6 +39,7 @@
6.4.1
1.18.36
6.2.1
+ 3.2.1
@@ -260,6 +261,13 @@
${message.version}
+
+
+ com.alibaba
+ easyexcel
+ ${easyexcel.version}
+
+