diff --git a/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/WaveServiceImpl.java b/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/WaveServiceImpl.java index 447e047ec..e0700f3e2 100644 --- a/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/WaveServiceImpl.java +++ b/pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/WaveServiceImpl.java @@ -62,7 +62,7 @@ public class WaveServiceImpl implements WaveService { if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) { throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND); } - waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 1); + waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 2); } catch (Exception e) { try { InputStream cfgStreamLower = fileStorageUtil.getFileStream(wavePath + GeneralConstant.CFG_LOWER); @@ -70,7 +70,7 @@ public class WaveServiceImpl implements WaveService { if (Objects.isNull(cfgStreamLower) || Objects.isNull(datStreamLower)) { throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND); } - waveDataDTO = waveFileComponent.getComtrade(cfgStreamLower, datStreamLower, 1); + waveDataDTO = waveFileComponent.getComtrade(cfgStreamLower, datStreamLower, 2); } catch (Exception e1) { throw new BusinessException(WaveFileResponseEnum.WAVE_DATA_INVALID); }