1、取消临时推送历史数据

This commit is contained in:
weidong 2025-06-30 23:26:21 +08:00
parent 29af023a4f
commit ae28807818
3 changed files with 7 additions and 8 deletions

View File

@ -49,7 +49,7 @@ public class GXJKForwarder extends Forwarder {
/**
* 每半小时转发GNSS解算结果
*/
@Scheduled(cron = "0 0/10 * * * ?") // 每30分钟执行一次
@Scheduled(cron = "0 0/30 * * * ?") // 每30分钟执行一次
private void forwardGnss() {
logger.debug("gxjk forwardGnss");
if(mqttClient.isConnected()) forwardCurrentGnss();

View File

@ -67,11 +67,10 @@ public class GXXfzForwarder extends Forwarder{
/**
* 每半小时转发GNSS解算结果
*/
@Scheduled(cron = "0 0/10 * * * ?") // 每30分钟执行一次
@Scheduled(cron = "0 0/30 * * * ?") // 每30分钟执行一次
private void forwardGnss() {
logger.debug("xfz forwardGnss");
//forwardCurrentGnss();
forwardHistoryGnss();
forwardCurrentGnss();
}
/*
@Scheduled(cron = "0 0/10 * * * ?") // 每30分钟执行一次

View File

@ -58,13 +58,13 @@ public class GZYMQTTForwarder extends Forwarder {
/**
* 每半小时转发GNSS解算结果
*/
//@Scheduled(cron = "0 0 0/1 * * ?") // 每小时执行一次
@Scheduled(cron = "0 0/10 * * * ?") // 每30分钟执行一次
@Scheduled(cron = "0 0 0/1 * * ?") // 每小时执行一次
//@Scheduled(cron = "0 0/5 * * * ?") // 每30分钟执行一次
private void forwardGnss() {
logger.debug("gzy mqtt forwardGnss");
if(mqttClient.isConnected()) {
//forwardCurrentGnss();
forwardHistoryGnss();
forwardCurrentGnss();
//forwardAngleData();
}
else{
try{