From 901dee2bf4c91fa92306b5d8aa66b3148658186c Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期二, 23 四月 2024 10:12:00 +0800
Subject: [PATCH] 修复转发国标notify-update时信息错误的问题
---
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java
index 2dd107a..da348b7 100755
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java
@@ -136,9 +136,9 @@
} else if (CmdType.MOBILE_POSITION.equals(cmd)) {
// logger.info("鎺ユ敹鍒癕obilePosition閫氱煡");
// processNotifyMobilePosition(take.getEvt());
- taskExecutor.execute(() -> {
+// taskExecutor.execute(() -> {
notifyRequestForMobilePositionProcessor.process(take.getEvt());
- });
+// });
} else {
logger.info("鎺ユ敹鍒版秷鎭細" + cmd);
@@ -226,8 +226,8 @@
} else {
mobilePosition.setAltitude(0.0);
}
- logger.info("[鏀跺埌绉诲姩浣嶇疆璁㈤槄閫氱煡]锛歿}/{}->{}.{}", mobilePosition.getDeviceId(), mobilePosition.getChannelId(),
- mobilePosition.getLongitude(), mobilePosition.getLatitude());
+// logger.info("[鏀跺埌绉诲姩浣嶇疆璁㈤槄閫氱煡]锛歿}/{}->{}.{}", mobilePosition.getDeviceId(), mobilePosition.getChannelId(),
+// mobilePosition.getLongitude(), mobilePosition.getLatitude());
mobilePosition.setReportSource("Mobile Position");
// 鏇存柊device channel 鐨勭粡绾害
@@ -370,8 +370,8 @@
this.redisCatchStorage = redisCatchStorage;
}
- @Scheduled(fixedRate = 1000) //姣�1绉掓墽琛屼竴娆�
+ @Scheduled(fixedRate = 10000) //姣�1绉掓墽琛屼竴娆�
public void execute(){
- System.out.println("寰呭鐞嗘秷鎭暟閲�: " + taskQueue.size());
+ logger.info("[寰呭鐞哊otify娑堟伅鏁伴噺]: {}", taskQueue.size());
}
}
--
Gitblit v1.8.0