| | |
| | | //如果是异常值,执行调整数据 TODO |
| | | if (Double.valueOf(curTemp) < -99.9) { |
| | | |
| | | curTemp = output.getAvgTemperature(); |
| | | //curTemp = output.getAvgTemperature(); |
| | | |
| | | } else { |
| | | //判断最大 |
| | |
| | | //仓温度信息 |
| | | KafkaGrainTH grainTH = new KafkaGrainTH(); |
| | | List<GrainTH> ths= output.getTemperatureAndhumidity(); |
| | | grainTH.setHumidity(ths.get(0).getHumidity()); |
| | | grainTH.setTemperature(ths.get(0).getTemperature() ); |
| | | if(ths != null && ths.size() > 0){ |
| | | grainTH.setHumidity(ths.get(0).getHumidity()); |
| | | grainTH.setTemperature(ths.get(0).getTemperature() ); |
| | | } |
| | | |
| | | |
| | | GrainWeather weather = JSON.parseObject(grainData.getWeatherStation(),GrainWeather.class); |
| | | grainTH.setAirHumidity(weather.getHumidity()); |
| | | grainTH.setAirTemperature(weather.getTemperature() ); |
| | | |
| | | if (weather!=null){ |
| | | grainTH.setAirHumidity(weather.getHumidity()); |
| | | grainTH.setAirTemperature(weather.getTemperature() ); |
| | | } |
| | | List<KafkaGrainTH> temperatureAndhumidity = new ArrayList<>(); |
| | | temperatureAndhumidity.add(grainTH); |
| | | |