From 80ed3ba2ff368af04ea1405cb179031870278bb6 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: Sat, 19 Oct 2024 11:32:38 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E7=A7=BB=E5=8A=A8=E4=BD=8D?=
 =?UTF-8?q?=E7=BD=AE=E9=80=9A=E7=9F=A5=E7=9A=84=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../NotifyRequestForMobilePositionProcessor.java | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestForMobilePositionProcessor.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestForMobilePositionProcessor.java
index fe7fb2ab..089a7bee 100755
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestForMobilePositionProcessor.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestForMobilePositionProcessor.java
@@ -65,7 +65,7 @@ public class NotifyRequestForMobilePositionProcessor extends SIPRequestProcessor
 		taskQueue.offer(new HandlerCatchData(evt, null, null));
 	}
 
-	@Scheduled(fixedRate = 200) //每200毫秒执行一次
+	@Scheduled(fixedRate = 400) //每200毫秒执行一次
 	public void executeTaskQueue() {
 		if (taskQueue.isEmpty()) {
 			return;
@@ -112,7 +112,7 @@ public class NotifyRequestForMobilePositionProcessor extends SIPRequestProcessor
 							if (!deviceId.equals(channelId)) {
 								mobilePosition.setChannelId(channelId);
 							}
-							continue;
+							break;
 						case "Time":
 							String timeVal = element.getStringValue();
 							if (ObjectUtils.isEmpty(timeVal)) {
@@ -120,13 +120,13 @@ public class NotifyRequestForMobilePositionProcessor extends SIPRequestProcessor
 							} else {
 								mobilePosition.setTime(SipUtils.parseTime(timeVal));
 							}
-							continue;
+							break;
 						case "Longitude":
 							mobilePosition.setLongitude(Double.parseDouble(element.getStringValue()));
-							continue;
+							break;
 						case "Latitude":
 							mobilePosition.setLatitude(Double.parseDouble(element.getStringValue()));
-							continue;
+							break;
 						case "Speed":
 							String speedVal = element.getStringValue();
 							if (NumericUtil.isDouble(speedVal)) {
@@ -134,7 +134,7 @@ public class NotifyRequestForMobilePositionProcessor extends SIPRequestProcessor
 							} else {
 								mobilePosition.setSpeed(0.0);
 							}
-							continue;
+							break;
 						case "Direction":
 							String directionVal = element.getStringValue();
 							if (NumericUtil.isDouble(directionVal)) {
@@ -142,7 +142,7 @@ public class NotifyRequestForMobilePositionProcessor extends SIPRequestProcessor
 							} else {
 								mobilePosition.setDirection(0.0);
 							}
-							continue;
+							break;
 						case "Altitude":
 							String altitudeVal = element.getStringValue();
 							if (NumericUtil.isDouble(altitudeVal)) {
@@ -150,7 +150,7 @@ public class NotifyRequestForMobilePositionProcessor extends SIPRequestProcessor
 							} else {
 								mobilePosition.setAltitude(0.0);
 							}
-							continue;
+							break;
 
 					}
 				}