diff --git a/src/main/java/club/joylink/rtss/simulation/cbtc/ATS/service/runplan/CtcZoneService.java b/src/main/java/club/joylink/rtss/simulation/cbtc/ATS/service/runplan/CtcZoneService.java index fc7e558bb..e8796b22f 100644 --- a/src/main/java/club/joylink/rtss/simulation/cbtc/ATS/service/runplan/CtcZoneService.java +++ b/src/main/java/club/joylink/rtss/simulation/cbtc/ATS/service/runplan/CtcZoneService.java @@ -2,6 +2,7 @@ package club.joylink.rtss.simulation.cbtc.ATS.service.runplan; import club.joylink.rtss.exception.BusinessExceptionAssertEnum; import club.joylink.rtss.simulation.cbtc.ATS.operation.vo.CtcRunPlanParam; +import club.joylink.rtss.simulation.cbtc.CTC.CTCLogicLoop; import club.joylink.rtss.simulation.cbtc.CTC.data.*; import club.joylink.rtss.simulation.cbtc.CTC.data.vo.CtcRunPlanVO; import club.joylink.rtss.simulation.cbtc.Simulation; @@ -21,6 +22,9 @@ public class CtcZoneService { @Autowired private CtcStationRunPlanLogService runPlanLogService; + @Autowired + private CTCLogicLoop ctcLogicLoop; + /** * 往行车线保存行车计划 * @@ -213,6 +217,8 @@ public class CtcZoneService { CtcEffectRepository effectRepository = simulation.getCtcRepository().getCtcEffectRepository(); effectRepository.releaseRunPlanByStationCode(runPlanRepository, simulation.getCorrectSystemTime()); updateStageRunPlan(simulation, stationCode); + // 发送消息 + ctcLogicLoop.sendZoneRunPlanSend(simulation); return "success"; } diff --git a/src/main/java/club/joylink/rtss/simulation/cbtc/CTC/CTCLogicLoop.java b/src/main/java/club/joylink/rtss/simulation/cbtc/CTC/CTCLogicLoop.java index c59749936..d402801ea 100644 --- a/src/main/java/club/joylink/rtss/simulation/cbtc/CTC/CTCLogicLoop.java +++ b/src/main/java/club/joylink/rtss/simulation/cbtc/CTC/CTCLogicLoop.java @@ -48,7 +48,7 @@ public class CTCLogicLoop { sendRunPlanChangeMessage(simulation); sendRunPlanRemoveMessage(simulation); // 下发计划 - sendZoneRunPlanSend(simulation); + //sendZoneRunPlanSend(simulation); } public void sendAllMessage(Simulation simulation) {