应急系统日志调整

This commit is contained in:
tiger_zhou 2022-12-01 14:51:01 +08:00
parent 73f72282f6
commit 9823d64553
2 changed files with 3 additions and 3 deletions

View File

@ -30,7 +30,7 @@ public class TrainPositionService {
public void initTrainOrUpdate(String mapName,String json){ public void initTrainOrUpdate(String mapName,String json){
TrainPosition tp = JsonUtils.read(json, TrainPosition.class); TrainPosition tp = JsonUtils.read(json, TrainPosition.class);
tp.setReceiveTime(System.currentTimeMillis()); tp.setReceiveTime(System.currentTimeMillis());
log.info(json); log.debug(json);
// SocketMessageVO<TrainPosition> vo = SocketMessageFactory.buildBasic(WebSocketMessageType.YJDDZH_TRAIN_POSITION,tp); // SocketMessageVO<TrainPosition> vo = SocketMessageFactory.buildBasic(WebSocketMessageType.YJDDZH_TRAIN_POSITION,tp);
// this.messageService.send(vo); // this.messageService.send(vo);
this.timeOverService.addTrainAccept(mapName,tp); this.timeOverService.addTrainAccept(mapName,tp);

View File

@ -103,7 +103,7 @@ public class TrainPositionTimeOverService {
} }
if(tp.receiveTimeOver(this.receiveTimeOver)){ if(tp.receiveTimeOver(this.receiveTimeOver)){
if(Objects.isNull(tp.getGroupNum())){ if(Objects.isNull(tp.getGroupNum())){
log.error("错误的数据:" + tp); log.debug("错误的数据:" + tp);
continue; continue;
} }
if(checkExist(key,simulation)){ if(checkExist(key,simulation)){
@ -120,7 +120,7 @@ public class TrainPositionTimeOverService {
List<Section> sectionList = findDirectionAllSection(simulation,tp.getRoadType()); List<Section> sectionList = findDirectionAllSection(simulation,tp.getRoadType());
Section section = this.findSecion(sectionList,tp); Section section = this.findSecion(sectionList,tp);
if(Objects.isNull(section)){ if(Objects.isNull(section)){
log.error("未找到对应的区段 param:{}",tp); log.debug("未找到对应的区段 param:{}",tp);
continue; continue;
} }
this.newAtsTrainLoadService.loadTripNumberTrain(simulation,tp,section); this.newAtsTrainLoadService.loadTripNumberTrain(simulation,tp,section);