From e6ad5a0a3db4b8109a8ed1a8be1767ab2f2842aa Mon Sep 17 00:00:00 2001
From: weidong <weidong@im-droid.com>
Date: Tue, 1 Jul 2025 11:42:44 +0800
Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E5=8F=96=E6=B6=88=E4=B8=B4=E6=97=B6?=
 =?UTF-8?q?=E6=8E=A8=E9=80=81=E5=8E=86=E5=8F=B2=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../beidou_fwd/task/GZYMQTTForwarder.java     | 20 +++++++++++++------
 1 file changed, 14 insertions(+), 6 deletions(-)

diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder.java
index 84491bc1..029f8b78 100644
--- a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder.java
+++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZYMQTTForwarder.java
@@ -28,17 +28,18 @@ import java.util.List;
 @EnableScheduling
 public class GZYMQTTForwarder extends Forwarder {
     static final String FORWARDER_NAME = "贵州交勘院MQTT";
-    @Value("${mqtt.server.brokerUrl}")
+    @Value("${gzymqtt.server.brokerUrl}")
     private String brokerUrl;
-    @Value("${mqtt.server.username}")
+    @Value("${gzymqtt.server.username}")
     private String username;
-    @Value("${mqtt.server.password}")
+    @Value("${gzymqtt.server.password}")
     private String password;
-    @Value("${mqtt.server.clientid}")
+    @Value("${gzymqtt.server.clientid}")
     private String clientid;
-    @Value("${mqtt.server.topic}")
+    @Value("${gzymqtt.server.topic}")
     private String topic;
-
+    //@Value("${gzymqtt.server.enabled}")
+    private boolean enabled=true;
     @Autowired
     GnssStatusMsgMapper statusMsgMapper;
     MQTTClient mqttClient;
@@ -47,6 +48,7 @@ public class GZYMQTTForwarder extends Forwarder {
     void registerMe() throws MqttException {
         init(FORWARDER_NAME, "MQTT "+brokerUrl,2,FWD_DEVICE_ALIAS_NAME,30);
         mqttClient = new MQTTClient(brokerUrl, username, password,clientid);
+        if(!enabled) return;
         try{
             mqttClient.connect();
         }
@@ -61,6 +63,7 @@ public class GZYMQTTForwarder extends Forwarder {
     @Scheduled(cron = "0 0 0/1 * * ?") // 每小时执行一次
     //@Scheduled(cron = "0 0/5 * * * ?") // 每30分钟执行一次
     private void forwardGnss() {
+        if(!enabled) return;
         logger.debug("gzy mqtt forwardGnss");
         if(mqttClient.isConnected()) {
             forwardCurrentGnss();
@@ -76,6 +79,11 @@ public class GZYMQTTForwarder extends Forwarder {
         }
     }
 
+    @Scheduled(cron = "0 0/5 * * * ?") // 每30分钟执行一次
+    void forwardHistoryGnss() {
+        super.forwardHistoryGnss();
+    }
+
     @Override
     int send(String projectId, List<GnssCalcData> records, LocalDateTime sentTime) {
         int sendNum = 0;