增加油罐仓的解析2

jiazx0107@163.com

2024-01-19 6a9cf62f7ca4b45c48a571c63fd484c186070a0e

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

@@ -6,6 +6,7 @@
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.data.ConfigData;
import com.fzzy.gateway.GatewayUtils;
import com.fzzy.gateway.api.GatewayRemoteService;
import com.fzzy.gateway.data.BaseResp;
@@ -47,6 +48,8 @@
    private GatewayConfService gatewayConfService;
    @Resource
    private KafkaDeviceReportService kafkaDeviceReportService;
    @Resource
    private ConfigData configData;


    @Override
@@ -135,8 +138,18 @@

            String messageInfo = JSONObject.toJSONString(heartBeatData);

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

                log.info("----------------------------推送KAFKA信息，注：调试模式不推送---------------------------");
                log.info("-----TOPIC-----{}", topic);
                log.info("-----Message-----{}", messageInfo);

                return;
            }


            kafkaDeviceReportService.publishWithTopic(messageInfo, topic);

        } catch (Exception e) {
            log.error("------网关心跳接口--执行失败-----{}", e);
@@ -188,6 +201,17 @@
            }

            messageInfo = JSONObject.toJSONString(statusData);

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

                log.info("----------------------------推送KAFKA信息，注：调试模式不推送---------------------------");
                log.info("-----TOPIC-----{}", topic);
                log.info("-----Message-----{}", messageInfo);

                return;
            }

            //推送设备状态
            kafkaDeviceReportService.publishWithTopic(messageInfo, topic);