From 41cc6b6c69a8665b847029fbbaa3eaf37acf3c9e Mon Sep 17 00:00:00 2001
From: dengzedong <dengzedong@email>
Date: 星期四, 08 五月 2025 17:33:48 +0800
Subject: [PATCH] 吨焦耗蒸汽 吨焦耗电

---
 ansteel-biz/src/main/java/com/iailab/module/ansteel/power/service/impl/PowerMaxdemandMainServiceImpl.java |   57 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 57 insertions(+), 0 deletions(-)

diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/power/service/impl/PowerMaxdemandMainServiceImpl.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/power/service/impl/PowerMaxdemandMainServiceImpl.java
new file mode 100644
index 0000000..8bbf620
--- /dev/null
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/power/service/impl/PowerMaxdemandMainServiceImpl.java
@@ -0,0 +1,57 @@
+package com.iailab.module.ansteel.power.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.iailab.module.ansteel.power.dao.PowerMaxdemandMainDao;
+import com.iailab.module.ansteel.power.entity.PowerMaxdemandMainEntity;
+import com.iailab.module.ansteel.power.service.PowerMaxdemandMainService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.UUID;
+import java.util.stream.Collectors;
+
+/**
+ * @author PanZhibao
+ * @Description
+ * @createTime 2025年05月07日
+ */
+@Slf4j
+@Service
+public class PowerMaxdemandMainServiceImpl implements PowerMaxdemandMainService {
+
+    @Autowired
+    private PowerMaxdemandMainDao powerMaxdemandMainDao;
+
+    @Override
+    public String add(PowerMaxdemandMainEntity entity) {
+        entity.setId(UUID.randomUUID().toString());
+        powerMaxdemandMainDao.insert(entity);
+        return entity.getId();
+    }
+
+    @Override
+    public BigDecimal getMax(String code, Date start, Date end) {
+        BigDecimal max = new BigDecimal(0);
+        QueryWrapper<PowerMaxdemandMainEntity> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("code", code)
+                .ge("occur_time", start)
+                .le("occur_time", end);
+        List<PowerMaxdemandMainEntity> list = powerMaxdemandMainDao.selectList(queryWrapper);
+        if (CollectionUtils.isEmpty(list)) {
+            return max;
+        }
+        List<Double> demandValueList = list.stream().map(item -> {
+            return item.getMaxDemand().doubleValue();
+        }).collect(Collectors.toList());
+
+        max = new BigDecimal(demandValueList.stream().max(Double::compareTo).get());
+        log.info("max : {}", max);
+        return max;
+    }
+}
\ No newline at end of file

--
Gitblit v1.9.3