From caed99f9e64880b9036f5ca8828af764ae13b76f Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期三, 09 四月 2025 19:01:23 +0800
Subject: [PATCH] 对比预测值是否超限 支持数组
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinishConsumer.java | 11 ++++++++++-
1 files changed, 10 insertions(+), 1 deletions(-)
diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinishConsumer.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinishConsumer.java
index c6c647b..51b68b2 100644
--- a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinishConsumer.java
+++ b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelPredictFinishConsumer.java
@@ -118,8 +118,17 @@
log.info("AlarmPreData: " + JSONArray.toJSONString(result));
// 对比预测值是否超限
+ int fromIndex = 0;
int toIndex = result.size();
- int fromIndex = result.size() - configItem.getCompLength();
+ if (!configItem.getCompLength().contains(",")) {
+ fromIndex = result.size() - Integer.parseInt(configItem.getCompLength().trim());
+ } else {
+ String[] cpArr = configItem.getCompLength().split(",");
+ fromIndex = Integer.parseInt(cpArr[0]);
+ toIndex = Integer.parseInt(cpArr[1]);
+ }
+ log.info("fromIndex:" + fromIndex);
+ log.info("toIndex:" + toIndex);
List<Object[]> predictList = result.subList(fromIndex, toIndex);
for (Object[] data : predictList) {
BigDecimal dataValue = new BigDecimal(Double.parseDouble(data[1].toString())).setScale(2, BigDecimal.ROUND_HALF_UP);
--
Gitblit v1.9.3