From 3916b8992018cee24af1111c8daa8ca68164a597 Mon Sep 17 00:00:00 2001
From: weidong <weidong@im-droid.com>
Date: Mon, 22 Jul 2024 21:14:01 +0800
Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E5=A2=9E=E5=8A=A0=E5=B9=BF=E8=A5=BF?=
 =?UTF-8?q?=E4=BA=A4=E7=A7=91=E6=8E=A8=E9=80=81=202=E3=80=81=E8=A7=84?=
 =?UTF-8?q?=E8=8C=83=E6=8E=A8=E9=80=81=E8=AE=BE=E5=A4=87ID=E3=80=81?=
 =?UTF-8?q?=E8=AE=BE=E5=A4=87=E5=88=AB=E5=90=8D=E3=80=81=E8=AE=BE=E5=A4=87?=
 =?UTF-8?q?=E5=90=8D=E7=9A=84=E7=BC=96=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../beidou_fwd/task/SaasForwarder.java        | 19 ++++++++++++++-----
 1 file changed, 14 insertions(+), 5 deletions(-)

diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/SaasForwarder.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/SaasForwarder.java
index 34b1aa90..b7867729 100644
--- a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/SaasForwarder.java
+++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/SaasForwarder.java
@@ -28,6 +28,9 @@ public class SaasForwarder extends Forwarder{
     @Value("${sass.server.port}")
     private int port;
 
+    @Value("${sass.server.enabled}")
+    boolean enabled;
+
     private TCPClient tcpClient;
 
     static class MyTCPListener implements TCPListener {
@@ -59,9 +62,11 @@ public class SaasForwarder extends Forwarder{
     @PostConstruct
     void registerMe(){
         init(FORWARDER_NAME, "TCP "+host+":"+port,0,FWD_DEVICE_ID,30);
-        tcpClient = new TCPClient();
-        tcpClient.init(host, port,listener);
-        tcpClient.start();
+        if(enabled) {
+            tcpClient = new TCPClient();
+            tcpClient.init(host, port, listener);
+            tcpClient.start();
+        }
     }
 
     /**
@@ -69,12 +74,16 @@ public class SaasForwarder extends Forwarder{
      */
     @Scheduled(cron = "0 20,50 * * * ?") // 每30分钟执行一次
     private void forwardGnss() {
-        logger.info("saas forwardGnss");
-        forwardCurrentGnss();
+        if(enabled) {
+            logger.info("saas forwardGnss");
+            forwardCurrentGnss();
+        }
     }
 
     @Override
     int send(String projectId, List<GnssCalcData> records, LocalDateTime sentTime){
+        if(!enabled) return 0;
+
         int sendNum = 0;
         if(records.size() == 0) return 0;