From b12076b5d5e004ff31215cea4e65272df3dab2d6 Mon Sep 17 00:00:00 2001
From: chentaisen <14615430+chentaisen@user.noreply.gitee.com>
Date: Mon, 7 Oct 2024 10:22:59 +0800
Subject: [PATCH] =?UTF-8?q?feat():=E4=BA=8C=E6=AC=A1=E4=BC=98=E5=8C=96?=
 =?UTF-8?q?=E6=A0=BC=E5=BC=8F=EF=BC=8C=E5=A2=9E=E5=8A=A0firmCode?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/muyu/parsing/mqtt/MqttTest.java | 15 +++++++--------
 1 file changed, 7 insertions(+), 8 deletions(-)

diff --git a/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java b/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java
index ece270c..43dd7d8 100644
--- a/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java
+++ b/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java
@@ -87,15 +87,15 @@ public class MqttTest {
                                 .key(carMessage.getMessageTypeCode())
                                 .label(carMessage.getMessageTypeCode())
                                 .value(value)
-                                .type("String")
-                                .build());
-                        kafKaDataList.add(KafKaData.builder()
-                                .key("firmCode")
-                                .label("企业编码")
-                                .value("firm01")
-                                .type("String")
+                                .type(carMessage.getMessageType())
                                 .build());
                     }
+                    kafKaDataList.add(KafKaData.builder()
+                            .key("firmCode")
+                            .label("企业编码")
+                            .value("firm01")
+                            .type("String")
+                            .build());
                     String jsonString = JSONObject.toJSONString(kafKaDataList);
 
                     ProducerRecord<String, String> producerRecord = new ProducerRecord<>(KafkaConstants.KafkaTopic, jsonString);
@@ -108,7 +108,6 @@ public class MqttTest {
                 }
 
 
-
                 // 接收信息
                 @Override
                 public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {