diff --git a/cn-terminal/src/main/java/com/njcn/product/terminal/event/service/impl/EventGateServiceImpl.java b/cn-terminal/src/main/java/com/njcn/product/terminal/event/service/impl/EventGateServiceImpl.java index dbd9e88..bc91a81 100644 --- a/cn-terminal/src/main/java/com/njcn/product/terminal/event/service/impl/EventGateServiceImpl.java +++ b/cn-terminal/src/main/java/com/njcn/product/terminal/event/service/impl/EventGateServiceImpl.java @@ -54,17 +54,26 @@ public class EventGateServiceImpl implements EventGateService { String lineid = eventDetail.getLineId(); LedgerBaseInfo pqLine = ledgerScaleMapper.getLedgerBaseInfo(Stream.of(lineid).collect(Collectors.toList())).get(0); String waveName = eventDetail.getWavePath(); - String cfgPath, datPath; + String cfgPath, datPath,cfgPath1,datPath1; + InputStream cfgStream,datStream; if (StrUtil.isBlank(waveName)) { throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND); } cfgPath = generalInfo.getBusinessWavePath()+ File.separator+pqLine.getIp()+"/"+waveName+".CFG"; datPath = generalInfo.getBusinessWavePath()+ File.separator+pqLine.getIp()+"/"+waveName+".DAT"; + + cfgPath1 = generalInfo.getBusinessWavePath()+ File.separator+pqLine.getIp()+"/"+waveName+".cfg"; + datPath1 = generalInfo.getBusinessWavePath()+ File.separator+pqLine.getIp()+"/"+waveName+".dat"; + log.info("本地磁盘波形文件路径----" + cfgPath); - InputStream cfgStream = waveFileComponent.getFileInputStreamByFilePath(cfgPath); - InputStream datStream = waveFileComponent.getFileInputStreamByFilePath(datPath); + cfgStream = waveFileComponent.getFileInputStreamByFilePath(cfgPath); + datStream = waveFileComponent.getFileInputStreamByFilePath(datPath); if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) { - throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND); + cfgStream = waveFileComponent.getFileInputStreamByFilePath(cfgPath1); + datStream = waveFileComponent.getFileInputStreamByFilePath(datPath1); + if(Objects.isNull(cfgStream) || Objects.isNull(datStream)) { + throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND); + } } waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 1);