Commit 0d1978c8 authored by 周昊's avatar 周昊

1、修改算法阈值算法块会因为小数报错问题

parent c5979387
package com.censoft.flink.transform; package com.censoft.flink.transform;
import cn.hutool.core.util.NumberUtil;
import com.censoft.flink.domain.AlgorithmPushDto; import com.censoft.flink.domain.AlgorithmPushDto;
import com.censoft.flink.domain.AlgorithmSceneBasePo; import com.censoft.flink.domain.AlgorithmSceneBasePo;
import com.censoft.flink.domain.AlgorithmScenePiecePo; import com.censoft.flink.domain.AlgorithmScenePiecePo;
...@@ -51,7 +52,14 @@ public class AlarmThresholdFunction implements AlgorithmBaseFilterFunction { ...@@ -51,7 +52,14 @@ public class AlarmThresholdFunction implements AlgorithmBaseFilterFunction {
String label = po.getLabel(); String label = po.getLabel();
if (label.contains("_")) { if (label.contains("_")) {
String thresholdString = label.substring(label.indexOf("_") + 1); String thresholdString = label.substring(label.indexOf("_") + 1);
if (NumberUtil.isInteger(thresholdString)) {
return Integer.valueOf(thresholdString); return Integer.valueOf(thresholdString);
} else if (NumberUtil.isDouble(thresholdString)) {
double v = Double.valueOf(thresholdString) * 100;
return (int) v;
} else {
return null;
}
} else { } else {
return null; return null;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment