From caf2599a9869244ded811018811c37a2aabac3fc Mon Sep 17 00:00:00 2001
From: vince <757871790@qq.com>
Date: 星期三, 08 一月 2025 11:29:05 +0800
Subject: [PATCH] 优化测温协议
---
src/main/java/com/fzzy/gateway/hx2023/service/DeviceReportServiceImpl.java | 16 ++++++++++------
1 files changed, 10 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/fzzy/gateway/hx2023/service/DeviceReportServiceImpl.java b/src/main/java/com/fzzy/gateway/hx2023/service/DeviceReportServiceImpl.java
index 19ce2cf..ed86f3f 100644
--- a/src/main/java/com/fzzy/gateway/hx2023/service/DeviceReportServiceImpl.java
+++ b/src/main/java/com/fzzy/gateway/hx2023/service/DeviceReportServiceImpl.java
@@ -108,7 +108,7 @@
weightInfo.setNetWeight(reqData.getWeight());
weightInfo.setWeightUnit("KG");
JSONObject jsonObject = new JSONObject();
- jsonObject.put("weightInfo", weightInfo);
+ jsonObject.put("weightInfo", JSON.toJSONString(weightInfo));
packet.setProperties(jsonObject);
@@ -640,13 +640,17 @@
//浠撴俯搴︿俊鎭�
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);
--
Gitblit v1.9.3