#
Junjie
昨天 7a5448174e5cb929e78926cce3783366557b7e88
#
1个文件已修改
11 ■■■■■ 已修改文件
src/main/java/com/zy/core/trace/StationTaskTraceRegistry.java 11 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/core/trace/StationTaskTraceRegistry.java
@@ -215,7 +215,16 @@
            } catch (Exception ignore) {
                continue;
            }
            if (wrkMast == null || isStationTraceActiveWrkStatus(wrkMast.getWrkSts())) {
            if (wrkMast == null) {
                Integer currentStationId = state.currentStationId != null ? state.currentStationId : state.finalTargetStationId;
                Map<String, Object> details = new LinkedHashMap<>();
                details.put("reason", "wrk_missing");
                state.markTerminal(state.traceVersion, STATUS_FINISHED, currentStationId, null,
                        "AUTO_FINISHED", "输送任务档已不存在,轨迹自动结束", details);
                persistState(state);
                continue;
            }
            if (isStationTraceActiveWrkStatus(wrkMast.getWrkSts())) {
                continue;
            }
            Integer currentStationId = state.currentStationId != null ? state.currentStationId : state.finalTargetStationId;