From 669906b87674d4b60a6fd5ea3a938c636952dbc2 Mon Sep 17 00:00:00 2001 From: whyclxw <810412026@qq.com> Date: 星期四, 19 六月 2025 21:08:36 +0800 Subject: [PATCH] 预警分析管理-主属性和分析属性 --- src/main/java/com/whyc/service/BattRealdataIdService.java | 19 +++++++++++++++++-- 1 files changed, 17 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/whyc/service/BattRealdataIdService.java b/src/main/java/com/whyc/service/BattRealdataIdService.java index 9641b67..8a1faed 100644 --- a/src/main/java/com/whyc/service/BattRealdataIdService.java +++ b/src/main/java/com/whyc/service/BattRealdataIdService.java @@ -9,6 +9,8 @@ import com.whyc.mapper.CommonMapper; import com.whyc.pojo.db_data_history.BattRealdataId; +import com.whyc.pojo.db_param.AlmAnalysisParam; +import com.whyc.pojo.db_param.AppParam; import com.whyc.util.ActionUtil; import com.whyc.util.DateUtil; import com.whyc.util.ThreadLocalUtil; @@ -40,6 +42,12 @@ @Autowired private BattInfService binfService; + + @Autowired + private AlmAnalysisParamService almAnalysisParamService; + + @Autowired + private AppParamService appParamService; //鑾峰彇鐢垫睜缁勬渶杩戜竴瀛e害鐨勫崟浣撴暟鎹� @@ -220,8 +228,15 @@ } //鐢垫睜鍛婅鐐瑰嚮鍏蜂綋鍛婅淇℃伅鏌ョ湅浠庡憡璀﹀紑濮嬫椂闂村埌鐜板湪鐨勫巻鍙插疄鏃舵暟鎹� public Response getBattHisRealInAlm(Integer battgroupId, String startTime, Integer almId) throws ParseException, InterruptedException { + //鑾峰彇鍛婅almId瀵瑰簲鐨勫垎鏋愰厤缃睘鎬у�� + AlmAnalysisParam almAnalysisParam= almAnalysisParamService.getAnalysisParam(almId); List<RealDateDTO> dataList = new LinkedList<>(); - List<List<Date>> monthTimeList = DateUtil.getMonthTime(ThreadLocalUtil.parse(startTime,1),new Date()); + //鑾峰彇棰勮鍒嗘瀽鍛ㄦ湡闃堝�� + AppParam appParam = appParamService.getAlarmAnalysisCycle(); + Integer cycleTime=appParam.getParamValue().intValue(); + Date cyscleDate=ActionUtil.getDateAdd(ThreadLocalUtil.parse(startTime,1),cycleTime*(-1)); + //鑾峰彇cyscleDate鍒扮幇鍦ㄦ墍鏈夌殑鍘嗗彶瀹炴椂鏁版嵁 + List<List<Date>> monthTimeList = DateUtil.getMonthTime(cyscleDate,new Date()); ThreadPoolExecutor pool = ThreadPoolExecutorFactory.getPoolExecutor(); CountDownLatch latch = new CountDownLatch(monthTimeList.size()); for (int i = 0; i < monthTimeList.size(); i++) { @@ -246,7 +261,7 @@ } latch.await(10, TimeUnit.MINUTES); List dataListSorted = dataList.stream().sorted(Comparator.comparing(RealDateDTO::getRecordTime)).collect(Collectors.toList()); - return new Response().set(1, dataListSorted); + return new Response().setIII(1,true, dataListSorted,almAnalysisParam,"鐢垫睜鍛婅鐐瑰嚮鍏蜂綋鍛婅淇℃伅鏌ョ湅浠庡憡璀﹀紑濮嬫椂闂村埌鐜板湪鐨勫巻鍙插疄鏃舵暟鎹�"); } } \ No newline at end of file -- Gitblit v1.9.1