From e5e40869b53a0e8c9c4e86d3f488dceb08b3b845 Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期二, 31 十月 2023 12:18:11 +0800
Subject: [PATCH] 四川省网关接口相关11

---
 src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java |   16 ++++++++--------
 1 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java b/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java
index 08423ed..5fa5291 100644
--- a/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java
+++ b/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java
@@ -31,12 +31,13 @@
      * @return
      */
     public String sendGrainData2Cloud(GrainData data) {
-    	
-    	
-    	log.debug("----鎺ㄩ�佺伯鎯呬俊鎭埌浜戠---{}",data);
+
+
+        String strData = JSONObject.toJSONString(data);
+        log.debug("----鎺ㄩ�佺伯鎯呬俊鎭埌浜戠---{}", strData);
 
         //鎺ㄩ�佷俊鎭�
-        kafkaTemplate.send("TOPIC_ZLJ_GRAIN_TEMPERATURE",JSONObject.toJSONString(data)).addCallback(success -> {
+        kafkaTemplate.send("TOPIC_ZLJ_GRAIN_TEMPERATURE", strData).addCallback(success -> {
             // 娑堟伅鍙戦�佸埌鐨則opic
             String topic = success.getRecordMetadata().topic();
             // 娑堟伅鍙戦�佸埌鐨勫垎鍖�
@@ -44,11 +45,10 @@
             // 娑堟伅鍦ㄥ垎鍖哄唴鐨刼ffset
             long offset = success.getRecordMetadata().offset();
 
-            log.info("绮儏鎺ㄩ�佹垚鍔�:" + topic + "-" + partition + "-" + offset);
+            log.info("绮儏鎺ㄩ�佹垚鍔�:{}-{}-{}-{}", topic, partition, offset, data.getDeviceID());
         }, failure -> {
-            log.error("绮儏鎺ㄩ�佸け璐�:" + failure.getMessage());
+            log.info("绮儏鎺ㄩ�佸け璐�:{}-{}", data.getDeviceID(), failure.getMessage());
         });
-
 
         return "SUCCESS";
 
@@ -56,7 +56,7 @@
 
     @KafkaListener(topics = {"TOPIC_ZLJ_GRAIN_TEMPERATURE"})
     public void onMessage1(ConsumerRecord<?, ?> record) {
-      //  log.debug("鑾峰彇娑堣垂淇℃伅锛�" + record.topic() + "-" + record.partition() + "-" + record.value());
+        //  log.debug("鑾峰彇娑堣垂淇℃伅锛�" + record.topic() + "-" + record.partition() + "-" + record.value());
     }
 
 }

--
Gitblit v1.9.3