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(); + } +}