1、广西交设暂停推送历史数据

This commit is contained in:
weidong 2025-07-20 15:37:02 +08:00
parent 6d170eaed0
commit 1045e33d1a
2 changed files with 8 additions and 3 deletions

View File

@ -34,10 +34,15 @@ public class GXJSForwarder extends GXXfzForwarder{
/** /**
* 每半小时转发GNSS解算结果 * 每半小时转发GNSS解算结果
*/ */
@Scheduled(cron = "0 0/30 * * * ?") // 每30分钟执行一次 @Scheduled(cron = "0 0/10 * * * ?") // 每30分钟执行一次
private void forwardGnss() { private void forwardGnss() {
if(!enabled) return; if(!enabled) return;
logger.debug("gxjs forwardGnss"); logger.debug("gxjs forwardGnss");
forwardCurrentGnss(); forwardCurrentGnss();
} }
@Override
void forwardHistoryGnss(){
}
} }

View File

@ -73,7 +73,7 @@ public class GXXfzForwarder extends Forwarder{
if(batchNum==50){ if(batchNum==50){
String json = "#" + GsonUtil.toJson(xfzTcpMessage) + "!"; String json = "#" + GsonUtil.toJson(xfzTcpMessage) + "!";
logger.debug("project {}: forwad {} gnss records to {}}",projectId, dataList.size(),fwdGroupId); logger.debug("project {}: forwad {} gnss records to {}",projectId, dataList.size(),fwdGroupId);
logger.debug(json); logger.debug(json);
try { try {
listener.clear(); listener.clear();
@ -91,7 +91,7 @@ public class GXXfzForwarder extends Forwarder{
if(batchNum>0){ if(batchNum>0){
String json = "#" + GsonUtil.toJson(xfzTcpMessage) + "!"; String json = "#" + GsonUtil.toJson(xfzTcpMessage) + "!";
logger.debug("project {}: forwad {} gnss records to {}}",projectId, dataList.size(),fwdGroupId); logger.debug("project {}: forwad {} gnss records to {}",projectId, dataList.size(),fwdGroupId);
logger.debug(json); logger.debug(json);
try { try {
listener.clear(); listener.clear();