| | |
| | | Map<String, Object> pointsRealValue = dataPointApi.queryPointsRealValue(entry.getValue()); |
| | | for (Map.Entry<String, Object> pointRealValue : pointsRealValue.entrySet()) { |
| | | String pointNo = pointRealValue.getKey(); |
| | | Double value = (Double) pointRealValue.getValue(); |
| | | Double value = null == pointRealValue.getValue() ? null : Double.valueOf(pointRealValue.getValue().toString()); |
| | | //如果有旧值,且旧值为0,且新值不为null,且新值>0 触发模型 |
| | | if (pointsLastValue.containsKey(pointNo) && pointsLastValue.get(pointNo).equals(0.0) && null != value && value.compareTo(0.0) > 0){ |
| | | if (null != pointsLastValue.get(pointNo) && pointsLastValue.get(pointNo).equals(0.0) && null != value && value.compareTo(0.0) > 0){ |
| | | runPredictModuleTask.run(entry.getKey()); |
| | | break; |
| | | } |
| | | } |
| | | |
| | | for (Map.Entry<String, Object> pointRealValue : pointsRealValue.entrySet()) { |
| | | Double value = null == pointRealValue.getValue() ? null : Double.valueOf(pointRealValue.getValue().toString()); |
| | | pointsLastValue.put(pointRealValue.getKey(),value); |
| | | } |
| | | |
| | | } |
| | | } catch (Exception ex) { |
| | | logger.error("runLDGTankFactorPredTask运行异常",ex); |