| | |
| | | Map<String, Object> pointsRealValue = dataPointApi.queryPointsRealValue(allPointNos); |
| | | |
| | | for (Map.Entry<String, List<String>> entry : checkPoints.entrySet()) { |
| | | for (Map.Entry<String, Object> pointRealValue : pointsRealValue.entrySet()) { |
| | | String pointNo = pointRealValue.getKey(); |
| | | Double value = null == pointRealValue.getValue() ? null : Double.valueOf(pointRealValue.getValue().toString()); |
| | | for (String pointNo : entry.getValue()) { |
| | | Double value = null == pointsRealValue.get(pointNo) ? null : Double.valueOf(pointsRealValue.get(pointNo).toString()); |
| | | //如果有旧值,且旧值为0,且新值不为null,且新值>0 触发模型 |
| | | if (null != pointsLastValue.get(pointNo) && pointsLastValue.get(pointNo).equals(0.0) && null != value && value.compareTo(0.0) > 0){ |
| | | logger.info("LDG柜容预测触发,NET:" + entry.getKey() + ",pointNo:" + pointNo + "-" + value); |
| | | runPredictModuleTask.run(entry.getKey()); |
| | | break; |
| | | } |