From d05e2c7adf1bed323892aebc4c0a4556875fbe94 Mon Sep 17 00:00:00 2001
From: weidong <weidong@im-droid.com>
Date: Mon, 6 Oct 2025 15:39:33 +0800
Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E5=A2=9E=E5=8A=A0=E8=91=9B=E6=B4=B2?=
 =?UTF-8?q?=E5=9D=9D10=E5=88=86=E9=92=9F=E6=8E=A8=E9=80=81=E7=BB=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../beidou_fwd/task/GZB10mForwarder.java      | 42 +++++++++++++++++++
 1 file changed, 42 insertions(+)
 create mode 100644 sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZB10mForwarder.java

diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZB10mForwarder.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZB10mForwarder.java
new file mode 100644
index 00000000..2230e66f
--- /dev/null
+++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZB10mForwarder.java
@@ -0,0 +1,42 @@
+package com.imdroid.beidou_fwd.task;
+
+import com.imdroid.beidou_fwd.service.TCPClient;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+
+@Component
+@Configuration
+@EnableScheduling
+public class GZB10mForwarder extends GXXfzForwarder{
+    private final String FORWARDER_NAME = "葛洲坝10分钟";
+    @Value("${gzb.server.host}")
+    private String host;
+
+    @Value("${gzb.server.port}")
+    private int port;
+    private boolean enabled=false;
+
+    @PostConstruct
+    void registerMe(){
+        init(FORWARDER_NAME, "TCP "+host+":"+port,1,FWD_DEVICE_ID,10);
+        xfzTcpClient = new TCPClient();
+        xfzTcpClient.init(host, port,listener);
+        if(!enabled) return;
+        xfzTcpClient.start();
+    }
+
+    /**
+     * 每半小时转发GNSS解算结果
+     */
+    @Scheduled(cron = "0 0/10 * * * ?") // 每10分钟执行一次
+    private void forwardGnss() {
+        if(!enabled) return;
+        logger.debug("gzb forwardGnss");
+        forwardCurrentGnss();
+    }
+}