From de3d8ad9d76a6130fa3751897ea3dcc6429cd7ed Mon Sep 17 00:00:00 2001 From: jiazx0107@163.com <jiazx0107@163.com> Date: 星期二, 31 十月 2023 19:02:02 +0800 Subject: [PATCH] 四川省网关接口相关13 --- src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java | 5 +++-- 1 files changed, 3 insertions(+), 2 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 5fa5291..e2ba899 100644 --- a/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java +++ b/src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java @@ -1,11 +1,12 @@ package com.fzzy.gateway.hx2023.kafka; import com.alibaba.fastjson2.JSONObject; -import com.fzzy.gateway.hx2023.data.GrainData; +import com.fzzy.gateway.hx2023.data.KafaGrainData; import lombok.extern.slf4j.Slf4j; import org.apache.kafka.clients.consumer.ConsumerRecord; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.kafka.annotation.KafkaListener; import org.springframework.kafka.core.KafkaTemplate; import org.springframework.stereotype.Component; @@ -30,7 +31,7 @@ * @param data * @return */ - public String sendGrainData2Cloud(GrainData data) { + public String sendGrainData2Cloud(KafaGrainData data) { String strData = JSONObject.toJSONString(data); -- Gitblit v1.9.3