【取消定时运行计划下发消息】

This commit is contained in:
weizhihong 2022-06-29 15:19:31 +08:00
parent 767e87cf39
commit b1307659ee
2 changed files with 7 additions and 1 deletions

View File

@ -2,6 +2,7 @@ package club.joylink.rtss.simulation.cbtc.ATS.service.runplan;
import club.joylink.rtss.exception.BusinessExceptionAssertEnum; import club.joylink.rtss.exception.BusinessExceptionAssertEnum;
import club.joylink.rtss.simulation.cbtc.ATS.operation.vo.CtcRunPlanParam; 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.*;
import club.joylink.rtss.simulation.cbtc.CTC.data.vo.CtcRunPlanVO; import club.joylink.rtss.simulation.cbtc.CTC.data.vo.CtcRunPlanVO;
import club.joylink.rtss.simulation.cbtc.Simulation; import club.joylink.rtss.simulation.cbtc.Simulation;
@ -21,6 +22,9 @@ public class CtcZoneService {
@Autowired @Autowired
private CtcStationRunPlanLogService runPlanLogService; private CtcStationRunPlanLogService runPlanLogService;
@Autowired
private CTCLogicLoop ctcLogicLoop;
/** /**
* 往行车线保存行车计划 * 往行车线保存行车计划
* *
@ -213,6 +217,8 @@ public class CtcZoneService {
CtcEffectRepository effectRepository = simulation.getCtcRepository().getCtcEffectRepository(); CtcEffectRepository effectRepository = simulation.getCtcRepository().getCtcEffectRepository();
effectRepository.releaseRunPlanByStationCode(runPlanRepository, simulation.getCorrectSystemTime()); effectRepository.releaseRunPlanByStationCode(runPlanRepository, simulation.getCorrectSystemTime());
updateStageRunPlan(simulation, stationCode); updateStageRunPlan(simulation, stationCode);
// 发送消息
ctcLogicLoop.sendZoneRunPlanSend(simulation);
return "success"; return "success";
} }

View File

@ -48,7 +48,7 @@ public class CTCLogicLoop {
sendRunPlanChangeMessage(simulation); sendRunPlanChangeMessage(simulation);
sendRunPlanRemoveMessage(simulation); sendRunPlanRemoveMessage(simulation);
// 下发计划 // 下发计划
sendZoneRunPlanSend(simulation); //sendZoneRunPlanSend(simulation);
} }
public void sendAllMessage(Simulation simulation) { public void sendAllMessage(Simulation simulation) {