启用雷达动态tcp客户端

‘liusuyi’

2023-12-28 f2c69b2bc1f262cb63e43f95fa511aa923e57746

 src/main/java/com/ard/alarm/digitization/service/impl/DataBridgeServiceImpl.java

@@ -1,15 +1,17 @@
package com.ard.alarm.digitization.service.impl;

import com.alibaba.fastjson2.JSON;
import com.ard.alarm.digitization.config.Digit3Configuration;
import com.ard.alarm.digitization.model.DataBridge;
import com.ard.alarm.digitization.service.DataBridgeService;
import com.ard.utils.jdbc.Query;
import com.ard.utils.mqtt.MqttConsumer;
import com.ard.utils.mqtt.MqttProducer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Date;
import java.util.List;

@@ -25,14 +27,14 @@
public class DataBridgeServiceImpl implements DataBridgeService {

    public static Date lastTime;
    @Value("${spring.digitization3.enabled}")
    private Boolean enabled;
    @Resource
    Digit3Configuration digit3Config;

    @Scheduled(cron = "0/5 * * * * ?")
    public void alarmHandler() {
        List<DataBridge> dataBridgeList;
        try {
            if(!enabled)
            if(!digit3Config.getEnabled())
            {
                return;
            }
@@ -52,7 +54,7 @@
                    data.setWellNo(elem[0]);
                    data.setAlarmType(elem[1]);
                    data.setAlarmTime(elem[2]);
                    MqttConsumer.publish(2, false, "digitization3", JSON.toJSONString(data));
                    MqttProducer.publish(2, false, "digitization3", JSON.toJSONString(data));
                }
            }
        } catch (Exception ex) {