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 records, LocalDateTime sentTime){ + if(!enabled) return 0; + int sendNum = 0; if(records.size() == 0) return 0;