From 4661519afdd8c30ffeafa38ba95358e97c1ba65d Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期四, 05 十二月 2024 12:02:44 +0800
Subject: [PATCH] #
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/TrafficService.java | 16 ++--------------
1 files changed, 2 insertions(+), 14 deletions(-)
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/TrafficService.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/TrafficService.java
index b1afab4..20eb1e0 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/TrafficService.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/TrafficService.java
@@ -110,9 +110,8 @@
// deprecate jam
if (this.isJamBeDeprecatedByAvo(segment.getId())) {
- if (this.skipCurrSegment(segment)) {
- return;
- }
+ mainService.settleSegmentList(Utils.singletonList(segment), null);
+ return;
}
// execute -----------------------------------------------
@@ -632,17 +631,6 @@
.eq(Jam::getAvoSeg, avoSeg)
.eq(Jam::getState, JamStateType.DEPRECATED.toString())
);
- }
-
- private boolean skipCurrSegment(Segment currSegment) {
- currSegment.setState(SegmentStateType.FINISH.toString());
- currSegment.setUpdateTime(new Date());
- if (!segmentService.updateById(currSegment)) {
- log.error("Segment [{}] failed to update 锛侊紒锛�", currSegment.getTravelId() + " - " + currSegment.getSerial());
- return false;
- }
- segmentService.processNext(Utils.singletonList(currSegment));
- return true;
}
}
--
Gitblit v1.9.1