From 82d3504d93db29e2b04ed1137e541a19e0cba0f1 Mon Sep 17 00:00:00 2001 From: whyclxw <810412026@qq.com> Date: 星期一, 23 六月 2025 09:08:14 +0800 Subject: [PATCH] 预警分析管理 --- src/main/java/com/whyc/service/AlmAnalysisParamService.java | 38 ++++++++++++++++++++++++-------------- 1 files changed, 24 insertions(+), 14 deletions(-) diff --git a/src/main/java/com/whyc/service/AlmAnalysisParamService.java b/src/main/java/com/whyc/service/AlmAnalysisParamService.java index 060006f..64574c1 100644 --- a/src/main/java/com/whyc/service/AlmAnalysisParamService.java +++ b/src/main/java/com/whyc/service/AlmAnalysisParamService.java @@ -68,9 +68,12 @@ return new Response().set(1,false,"鏃犲搴斿垎鏋愬睘鎬�"); }else{ //鍒嗙粍鏌ョ湅闇�瑕佹煡璇㈢數婧�/鐢垫睜瀹炴椂琛ㄧ殑鍝簺鏁版嵁 - Map<String, Map<String,Integer>> groupmap=groupPwrAndBatt(almAnalysisParam); - Map<String,Integer> battMap=groupmap.get("batt"); - Map<String,Integer> pwrMap=groupmap.get("pwr"); + Map<String, Map<String,Object>> groupmap=groupPwrAndBatt(almAnalysisParam); + Map<String,Object> battMap=groupmap.get("batt"); + Map<String,Object> pwrMap=groupmap.get("pwr"); + Map<String,Object> mainMap=groupmap.get("main"); + mainMap.put("pwr",pwrMap.size()); + mainMap.put("batt",battMap.size()); if(battgroupId!=null){ if(battMap!=null&&battMap.size()>0){ List battHislist=getBattRealData(battgroupId,monthTimeList,battMap); @@ -83,21 +86,24 @@ map.put("pwr",pwrHislist); } } - return new Response().setII(1,true, map,"棰勮鍒嗘瀽绠$悊-鐢垫簮涓诲睘鎬у拰鍒嗘瀽灞炴��"); + return new Response().setIII(1,true, map,mainMap,"棰勮鍒嗘瀽绠$悊-鐢垫簮涓诲睘鎬у拰鍒嗘瀽灞炴��"); } } //鍒嗙粍鏌ョ湅闇�瑕佹煡璇㈢數婧�/鐢垫睜瀹炴椂琛ㄧ殑鍝簺鏁版嵁 - private Map<String, Map<String,Integer>> groupPwrAndBatt(AlmAnalysisParam almAnalysisParam) { - Map<String, Map<String,Integer>> map = new HashMap<>(); - Map<String,Integer> battMap=new HashMap<>(); - Map<String,Integer> pwrMap=new HashMap<>(); + private Map<String, Map<String,Object>> groupPwrAndBatt(AlmAnalysisParam almAnalysisParam) { + Map<String, Map<String,Object>> map = new HashMap<>(); + Map<String,Object> battMap=new HashMap<>(); + Map<String,Object> pwrMap=new HashMap<>(); + Map<String,Object> mainMap=new HashMap<>(); if(almAnalysisParam.getMainFieldType()==1||almAnalysisParam.getMainFieldType()==2||almAnalysisParam.getMainFieldType()==3){ if(almAnalysisParam.getMainField()!=null||almAnalysisParam.getMainField().length()>0){ pwrMap.put(almAnalysisParam.getMainField(),almAnalysisParam.getMainFieldType()); + mainMap.put("main","pwr"); } }else{ if(almAnalysisParam.getMainField()!=null||almAnalysisParam.getMainField().length()>0){ battMap.put(almAnalysisParam.getMainField(),almAnalysisParam.getMainFieldType()); + mainMap.put("main","batt"); } } if(almAnalysisParam.getMinorField1Type()==1||almAnalysisParam.getMinorField1Type()==2||almAnalysisParam.getMinorField1Type()==3){ @@ -138,10 +144,11 @@ } map.put("pwr",pwrMap); map.put("batt",battMap); + map.put("main",mainMap); return map; } //杩炴帴姹犺幏鍙栫數婧愬巻鍙插疄鏃舵暟鎹� - public List getPwrRealData(Integer powerId,List<List<Date>> monthTimeList,Map<String,Integer> pwrMap) throws InterruptedException { + public List getPwrRealData(Integer powerId,List<List<Date>> monthTimeList,Map<String,Object> pwrMap) throws InterruptedException { List<ResAnalysis> dataList = new LinkedList<>(); ThreadPoolExecutor pool = ThreadPoolExecutorFactory.getPoolExecutor(); CountDownLatch latch = new CountDownLatch(monthTimeList.size()); @@ -171,7 +178,7 @@ } //鐢垫睜鍛婅鐐瑰嚮鍏蜂綋鍛婅淇℃伅鏌ョ湅浠庡憡璀﹀紑濮嬫椂闂村埌鐜板湪鐨勫巻鍙插疄鏃舵暟鎹� - public List getBattRealData(Integer battgroupId, List<List<Date>> monthTimeList,Map<String,Integer> battMap) throws ParseException, InterruptedException { + public List getBattRealData(Integer battgroupId, List<List<Date>> monthTimeList,Map<String,Object> battMap) throws ParseException, InterruptedException { List<ResAnalysis> dataList = new LinkedList<>(); ThreadPoolExecutor pool = ThreadPoolExecutorFactory.getPoolExecutor(); CountDownLatch latch = new CountDownLatch(monthTimeList.size()); @@ -218,9 +225,12 @@ //灏嗗睘鎬ф嫹璐濊嚦almAnalysisParam涓� copyProperties(almAnalysisParam,res); //鍒嗙粍鏌ョ湅闇�瑕佹煡璇㈢數婧�/鐢垫睜瀹炴椂琛ㄧ殑鍝簺鏁版嵁 - Map<String, Map<String,Integer>> groupmap=groupPwrAndBatt(almAnalysisParam); - Map<String,Integer> battMap=groupmap.get("batt"); - Map<String,Integer> pwrMap=groupmap.get("pwr"); + Map<String, Map<String,Object>> groupmap=groupPwrAndBatt(almAnalysisParam); + Map<String,Object> battMap=groupmap.get("batt"); + Map<String,Object> pwrMap=groupmap.get("pwr"); + Map<String,Object> mainMap=groupmap.get("pwr"); + mainMap.put("pwr",pwrMap.size()); + mainMap.put("batt",battMap.size()); if(res.getBattgroupId()!=null){ if(battMap!=null&&battMap.size()>0){ List battHislist=getBattRealData(res.getBattgroupId(),monthTimeList,battMap); @@ -233,7 +243,7 @@ map.put("pwr",pwrHislist); } } - return new Response().setII(1,true, map,"棰勮鍒嗘瀽绠$悊-鍒囨崲鏃堕棿闂撮殧鍜屽壇灞炴��"); + return new Response().setIII(1,true, map,mainMap,"棰勮鍒嗘瀽绠$悊-鍒囨崲鏃堕棿闂撮殧鍜屽壇灞炴��"); } //灏嗗睘鎬ф嫹璐濊嚦almAnalysisParam涓� private void copyProperties(AlmAnalysisParam almAnalysisParam, AnalysisChangeRes res) { -- Gitblit v1.9.1