调整KFKA数据推送测试2

jiazx0107@163.com

2024-01-04 50da1f165cc96d49d72694606920b77c74e1747c

调整KFKA数据推送测试2

 src/main/java/com/fzzy/gateway/controller/GatewayDeviceController.java

@@ -302,6 +302,7 @@
                continue;
            }
            reqData = new BaseReqData();
            reqData.setProductId(device.getProductId());
            reqData.setDeviceId(param.getDeviceId());
            reqData.setDayTime(param.getDayTime());
            reqData.setDevice(device);

 src/main/java/com/fzzy/gateway/hx2023/ScConstant.java

@@ -58,6 +58,12 @@
     */
    public static String TOPIC_EQUIPMENT_HEARTBEAT = "TOPIC_EQUIPMENT_HEARTBEAT_{kqdm}";


    /**
     * kafak 粮情数据推送到云端
     */
    public static String TOPIC_ZLJ_GRAIN_TEMPERATURE = "TOPIC_ZLJ_GRAIN_TEMPERATURE";

    /**
     * 网关设备状态消息消息 topic：TOPIC_EQUIPMENT_STATUS_{库点编码}
     */

 src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReportService.java

@@ -22,9 +22,6 @@


    public String publishWithTopic(String sendData, String topic) {



        //推送信息
        kafkaTemplate.send(topic, sendData).addCallback(success -> {
            // 消息发送到的topic

 src/main/java/com/fzzy/gateway/hx2023/service/DeviceReportServiceImpl.java

@@ -145,7 +145,8 @@

    @Override
    public BaseResp reportGrainDataByKafka(BaseReqData reqData) {
        String topic = ScConstant.TOPIC_MESSAGE_REPORT;
        String topic = ScConstant.TOPIC_ZLJ_GRAIN_TEMPERATURE;

        //如果是测试模式不执行推送
        if (configData.getActive().indexOf("dev") >= 0) {