1、临时推送历史数据

This commit is contained in:
weidong 2025-06-30 23:07:11 +08:00
parent ee5bae1174
commit 29af023a4f
2 changed files with 7 additions and 6 deletions

View File

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

View File

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