From b2304cfc3342211dfd161de427879fa813a22a44 Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期六, 29 三月 2025 15:55:16 +0800
Subject: [PATCH] 重庆bts4810定制修改负载电流问题

---
 src/main/java/com/whyc/service/PwrdevAcdcdataService.java |   45 ++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 42 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/whyc/service/PwrdevAcdcdataService.java b/src/main/java/com/whyc/service/PwrdevAcdcdataService.java
index 90eb82e..985f561 100644
--- a/src/main/java/com/whyc/service/PwrdevAcdcdataService.java
+++ b/src/main/java/com/whyc/service/PwrdevAcdcdataService.java
@@ -3,16 +3,18 @@
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.github.pagehelper.PageInfo;
 import com.whyc.dto.Response;
-import com.whyc.mapper.PwrdevAcdataMapper;
-import com.whyc.mapper.PwrdevAcdcdataMapper;
-import com.whyc.mapper.PwrdevDcdataMapper;
+import com.whyc.mapper.*;
+import com.whyc.pojo.PowerInf;
 import com.whyc.pojo.PwrdevAcdata;
 import com.whyc.pojo.PwrdevAcdcdata;
 import com.whyc.pojo.PwrdevDcdata;
+import com.whyc.util.ActionUtil;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
+import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -27,6 +29,12 @@
 
     @Resource
     private PwrdevDcdataMapper dcdataMapper;
+
+    @Resource
+    private PowerInfMapper powerInfMapper;
+
+    @Autowired
+    private SubTablePageInfoService subService;
 
     //鏌ヨ鐢垫簮鐨勶肌锛o激锛d俊鎭�
     @Transactional
@@ -147,4 +155,35 @@
         response.setData2(resultMap);
         return response;
     }
+    /*閲嶅簡bts4810(61850)
+    鐩墠瀹㈡埛鐨勮礋杞界數娴佹瘮杈冨皬锛屽厖鏀剧數鍙傛暟璁剧疆鏃讹紝灏忎簬0.1C10鐨�,鐢垫祦鍊艰姹傝兘鑷姩璇嗗埆锛�
+    閲囩敤涓�澶╁唴鐢垫祦骞冲潎鍊兼潵鏀剧數銆傝礋杞界數娴佸ぇ浜�0.1C10.鐢�0.1C10鏀剧數瀹㈡埛瑕佹眰鑷姩濉厖,涓嶈浜轰负鐨勫綍鍏�.
+    锛�100AH鐢垫睜 璐熻浇鐢垫祦灏忎簬10A 灏辩敤璐熻浇鐢垫祦鐨勫钩鍧囧�� 澶т簬10A 灏辩敤10A锛�
+    */
+    public float getBts4810LoadCurr(String stationId,float monCapStd) {
+        float loadCurr=0f;
+        QueryWrapper wrapper=new QueryWrapper();
+        wrapper.eq("stationid",stationId);
+        wrapper.last("limit 1");
+        PowerInf powerInf=powerInfMapper.selectOne(wrapper);
+        if(powerInf!=null){
+            int powerId=powerInf.getPowerDeviceId();
+            QueryWrapper wrapper1=new QueryWrapper();
+            wrapper1.eq("PowerDeviceId",powerId);
+            wrapper1.last("limit 1");
+            PwrdevAcdcdata acdcdata=mapper.selectOne(wrapper1);
+            if(acdcdata!=null){
+                loadCurr=acdcdata.getLoaderCurr();
+                if (loadCurr<(0.1*monCapStd)) {
+                    String tableName="db_pwrdev_data_history_gw"+"."+"tb_pwrdev_historydata_gw_"+powerId;
+                    tableName=tableName+"_"+ ActionUtil.sdfwithOutday.format(new Date());
+                    Float avgCurr=subService.getAvgLoadCurr(powerId,tableName);
+                    loadCurr=avgCurr;
+                }else{
+                    loadCurr=0.1f*monCapStd;
+                }
+            }
+        }
+        return loadCurr;
+    }
 }

--
Gitblit v1.9.1