Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

fix(waveform): 修复录波文件处理中的RMS段逻辑错误

Browse Source 
- 在RateDTO初始化时设置bRMSFlag默认值为false，确保16~31点/周波段按普通抽点处理
- 修复RMS段与普通抽点的控制流程分离，避免共享取模条件导致的逻辑混乱
- 优化RMS段处理逻辑，添加周波索引推进机制防止重复处理
- 修复2点/周波时半周波位置的采样点切换逻辑
- 添加段末尾对齐机制，确保外层循环能稳定跳转到下一段起点
- 更新测试文件路径配置，使用新的测试数据文件
This commit is contained in:
hongawen
2026-04-17 15:44:18 +08:00
parent 9c467310d5
commit aad5943d64
1 changed files with 168 additions and 162 deletions
Download Patch File Download Diff File Expand all files Collapse all files

330
pqs-common/common-event/src/main/java/com/njcn/event/file/component/WaveFileComponent.java
View File

@@ -515,6 +515,8 @@ public class WaveFileComponent {
comtradeCfgDTO.setNAllWaveNum(comtradeCfgDTO.getNAllWaveNum() + nWaveNum); comtradeCfgDTO.setNAllWaveNum(comtradeCfgDTO.getNAllWaveNum() + nWaveNum);
// 将最低采样率替换到本段录波内 // 将最低采样率替换到本段录波内
RateDTO tmpRateDTO = new RateDTO(); RateDTO tmpRateDTO = new RateDTO();
// C# 原实现中 bool 默认是 false，16~31 点/周波段也应按普通抽点处理
tmpRateDTO.bRMSFlag = false;
// 有效值标志,如果是有效值，那么就需要反向补点，而不是抽点 // 有效值标志,如果是有效值，那么就需要反向补点，而不是抽点
if (comtradeCfgDTO.getLstRate().get(iRate).getNOneSample() >= 32) { if (comtradeCfgDTO.getLstRate().get(iRate).getNOneSample() >= 32) {
//YXB 2025-08-27 //YXB 2025-08-27
@@ -566,188 +568,192 @@ public class WaveFileComponent {
} }
} }
tmpRateDTO = comtradeCfgDTO.getLstRate().get(nIndex); tmpRateDTO = comtradeCfgDTO.getLstRate().get(nIndex);
//YXB 2025-08-27 如果是有效值，那么需要去补点，而不是抽点 dfValue = (float) 20 / tmpRateDTO.getNOneSample();
if (newLstRate.get(nIndex).bRMSFlag == true) { // C# 原实现中 RMS 段与普通抽点是两条独立控制流，不能挂在同一个取模条件下
if (Boolean.TRUE.equals(newLstRate.get(nIndex).bRMSFlag)) {
//计算本段补点采样间隔 //计算本段补点采样间隔
nWaveSpan = newLstRate.get(nIndex).getNOneSample() / tmpRateDTO.getNOneSample(); nWaveSpan = newLstRate.get(nIndex).getNOneSample() / tmpRateDTO.getNOneSample();
} else { // 计算有多少个周波
// 计算本段抽点采样间隔 long allWaveTemp = newLstRate.get(nIndex).getNSampleNum() / newLstRate.get(nIndex).getNOneSample();
nWaveSpan = tmpRateDTO.getNOneSample() / newLstRate.get(nIndex).getNOneSample(); // 本段需要补多少点
long allempSample = newLstRate.get(nIndex).getNOneSample();
int segmentEndIndex = (int) (nOffSet + tmpRateDTO.getNSampleNum() - 1);
for (int iWaveTemp = 0; iWaveTemp < allWaveTemp; iWaveTemp++) {
for (int mTempSample = 0; mTempSample < allempSample; mTempSample++) {
// 2 点/周波时，半周波位置需要切换到该周波的第二个原始采样点
if (mTempSample / nWaveSpan == 1 && mTempSample % nWaveSpan == 0) {
i++;
}
//存储局部数据集合，包含了时间，A，B，C三相
List<Float> tmpWaveData = new ArrayList<>();
for (int j = 0; j < comtradeCfgDTO.getNAnalogNum(); j++) {
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzPhasicName().equalsIgnoreCase("N")) {
break;
}
float fCoef = comtradeCfgDTO.getLstAnalogDTO().get(j).getFCoefficent();
fValue = BitConverter.byte2ToUnsignedShort(datArray, i * nBlockSize + 2 * 4 + j * 2) * fCoef;
//WW 2019-11-14
/*************************
* 1、接口返回的默认是二次值
* 2、P是一次值 S是二次值
* 3、S(二次值）情况下：
* ①、单位为"V"时候则直接等于；
* ②、单位为"kV"时候需要乘以1000
* 4、P(一次值）情况下：
* ①、单位为"V"时候则直接等于；
* ②、单位为"kV"时候需要乘以1000
*************************/
//P是一次值 S是二次值
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("S")) {
//判断单位是V还是kV
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) {
fValue = fValue * 1000.0f;
} else {
fValue = fValue;
}
}
//P是一次值 S是二次值
else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("P")) {
//判断单位是V还是kV
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("V")) {
//根据cfg内的变比，将一次值转换成二次值
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
fValue = fValue * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
} else {
fValue = fValue;
}
}
//判断单位是V还是kV
else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) {
//根据cfg内的变比，将一次值转换成二次值
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
fValue = fValue * 1000.0f * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
} else {
fValue = fValue;
}
} else //还有可能是 电流，单位是A
{
//根据cfg内的变比，将一次值转换成二次值
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
fValue = fValue * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
} else {
fValue = fValue;
}
}
}
//xValue前移量，假如是第一次时候则需要前移
if (!blxValue && j == 0) {
xValueAll = (float) (i * 20) / tmpRateDTO.getNOneSample() - comtradeCfgDTO.getNPush();
blxValue = true;
//只增加一个xValue的值 //增加时间值
tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100);
} else if (j == 0) {
xValueAll += (float) dfValue / nWaveSpan;
//只增加一个xValue的值 //增加时间值
tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100);
}
//不同通道yValue的值都需要增加，最终成ABC三相 //每个通道的值
tmpWaveData.add((float) (Math.round(fValue * 100)) / 100);
}
//把每个单独的值赋予到整体里面去
listWaveData.add(tmpWaveData);
}
// 本周波处理完成后，推进到下一周波的原始采样点
if (iWaveTemp < (allWaveTemp - 1)) {
i++;
}
}
// 某些文件的段点数并不是原始每周波点数的整倍数。
// RMS 段处理完成后，强制把原始游标对齐到当前段末尾，
// 这样外层 for 的下一次自增才能稳定落到下一段起点，避免重复进入同一 RMS 段。
i = segmentEndIndex;
continue;
} }
dfValue = (float) 20 / tmpRateDTO.getNOneSample(); // 计算本段抽点采样间隔
nWaveSpan = tmpRateDTO.getNOneSample() / newLstRate.get(nIndex).getNOneSample();
// 判断是否到了需要抽的采样点 // 判断是否到了需要抽的采样点
if (i % nWaveSpan == 0) { if (i % nWaveSpan == 0) {
// 计算每个通道的值 // 计算每个通道的值
//存储局部数据集合，包含了时间，A，B，C三相 //存储局部数据集合，包含了时间，A，B，C三相
List<Float> tmpWaveData = new ArrayList<>(); List<Float> tmpWaveData = new ArrayList<>();
//YXB 2025-08-27 如果是有效值，那么需要去补点，而不是抽点 for (int j = 0; j < comtradeCfgDTO.getNAnalogNum(); j++) {
if (newLstRate.get(nIndex).bRMSFlag == true) { //数据只有电压ABC三相数据，不展示U0、I0等数据 YXB2020-10-09 去除相别为N相的数据
// 计算有多少个周波 if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzPhasicName().equalsIgnoreCase("N")) {
long allWaveTemp = newLstRate.get(nIndex).getNSampleNum() / newLstRate.get(nIndex).getNOneSample(); break;
// 本段需要补多少点 }
long allempSample = newLstRate.get(nIndex).getNOneSample();
int currentDataIndex = i; float fCoef = comtradeCfgDTO.getLstAnalogDTO().get(j).getFCoefficent();
for (int iWaveTemp = 0; iWaveTemp < allWaveTemp; iWaveTemp++) { fValue = BitConverter.byte2ToUnsignedShort(datArray, i * nBlockSize + 2 * 4 + j * 2) * fCoef;
for (int mTempSample = 0; mTempSample < allempSample; mTempSample++) {
tmpWaveData = new ArrayList<>();
for (int j = 0; j < comtradeCfgDTO.getNAnalogNum(); j++) {
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzPhasicName().equalsIgnoreCase("N")) {
break;
}
float fCoef = comtradeCfgDTO.getLstAnalogDTO().get(j).getFCoefficent();
fValue = BitConverter.byte2ToUnsignedShort(datArray, currentDataIndex * nBlockSize + 2 * 4 + j * 2) * fCoef;
//WW 2019-11-14
/*************************
* 1、接口返回的默认是二次值
* 2、P是一次值 S是二次值
* 3、S(二次值）情况下：
* ①、单位为"V"时候则直接等于；
* ②、单位为"kV"时候需要乘以1000
* 4、P(一次值）情况下：
* ①、单位为"V"时候则直接等于；
* ②、单位为"kV"时候需要乘以1000
*************************/
//P是一次值 S是二次值
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("S")) {
//判断单位是V还是kV
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) {
fValue = fValue * 1000.0f;
} else {
fValue = fValue;
}
}
//P是一次值 S是二次值
else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("P")) {
//判断单位是V还是kV
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("V")) {
//根据cfg内的变比，将一次值转换成二次值
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
fValue = fValue * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
} else {
fValue = fValue;
}
}
//判断单位是V还是kV
else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) {
//根据cfg内的变比，将一次值转换成二次值
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
fValue = fValue * 1000.0f * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
} else {
fValue = fValue;
}
} else //还有可能是 电流，单位是A
{
//根据cfg内的变比，将一次值转换成二次值
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
fValue = fValue * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
} else {
fValue = fValue;
}
}
}
//xValue前移量，假如是第一次时候则需要前移 //WW 2019-11-14
if (!blxValue && j == 0) { /**************************
xValueAll = (float) (currentDataIndex * 20) / tmpRateDTO.getNOneSample() - comtradeCfgDTO.getNPush(); * 1、接口返回的默认是二次值
blxValue = true; * 2、P是一次值 S是二次值
//只增加一个xValue的值 //增加时间值 * 3、S(二次值）情况下：
tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100); * ①、单位为"V"时候则直接等于；
} else if (j == 0) { * ②、单位为"kV"时候需要乘以1000
xValueAll += (float) dfValue / nWaveSpan; * 4、P(一次值）情况下：
//只增加一个xValue的值 //增加时间值 * ①、单位为"V"时候则直接等于；
tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100); * ②、单位为"kV"时候需要乘以1000
} **************************/
//P是一次值 S是二次值
//不同通道yValue的值都需要增加，最终成ABC三相 //每个通道的值 if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("S")) {
tmpWaveData.add((float) (Math.round(fValue * 100)) / 100); //判断单位是V还是kV
} if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) {
//把每个单独的值赋予到整体里面去 fValue = fValue * 1000.0f;
listWaveData.add(tmpWaveData); } else {
} fValue = fValue;
// 把每个单独的值赋予到整体里面去
if (iWaveTemp < (allWaveTemp - 1)) {
currentDataIndex++;
} }
} }
} else { //P是一次值 S是二次值
for (int j = 0; j < comtradeCfgDTO.getNAnalogNum(); j++) { else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("P")) {
//数据只有电压ABC三相数据，不展示U0、I0等数据 YXB2020-10-09 去除相别为N相的数据 //判断单位是V还是kV
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzPhasicName().equalsIgnoreCase("N")) { if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("V")) {
break; //根据cfg内的变比，将一次值转换成二次值
} if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
fValue = fValue * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
float fCoef = comtradeCfgDTO.getLstAnalogDTO().get(j).getFCoefficent();
fValue = BitConverter.byte2ToUnsignedShort(datArray, i * nBlockSize + 2 * 4 + j * 2) * fCoef;
//WW 2019-11-14
/**************************
* 1、接口返回的默认是二次值
* 2、P是一次值 S是二次值
* 3、S(二次值）情况下：
* ①、单位为"V"时候则直接等于；
* ②、单位为"kV"时候需要乘以1000
* 4、P(一次值）情况下：
* ①、单位为"V"时候则直接等于；
* ②、单位为"kV"时候需要乘以1000
**************************/
//P是一次值 S是二次值
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("S")) {
//判断单位是V还是kV
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) {
fValue = fValue * 1000.0f;
} else { } else {
fValue = fValue; fValue = fValue;
} }
} }
//P是一次值 S是二次值 //判断单位是V还是kV
else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("P")) { else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) {
//判断单位是V还是kV //根据cfg内的变比，将一次值转换成二次值
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("V")) { if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
//根据cfg内的变比，将一次值转换成二次值 fValue = fValue * 1000.0f * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) { } else {
fValue = fValue * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary(); fValue = fValue;
} else {
fValue = fValue;
}
} }
//判断单位是V还是kV } else //还有可能是 电流，单位是A
else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) { {
//根据cfg内的变比，将一次值转换成二次值 //根据cfg内的变比，将一次值转换成二次值
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) { if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
fValue = fValue * 1000.0f * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary(); fValue = fValue * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
} else { } else {
fValue = fValue; fValue = fValue;
}
} else //还有可能是 电流，单位是A
{
//根据cfg内的变比，将一次值转换成二次值
if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
fValue = fValue * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
} else {
fValue = fValue;
}
} }
} }
//xValue前移量，假如是第一次时候则需要前移
if (!blxValue && j == 0) {
xValueAll = (float) (i * 20) / tmpRateDTO.getNOneSample() - comtradeCfgDTO.getNPush();
blxValue = true;
//只增加一个xValue的值 //增加时间值
tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100);
} else if (j == 0) {
xValueAll += (float) nWaveSpan * dfValue;
//只增加一个xValue的值 //增加时间值
tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100);
}
//不同通道yValue的值都需要增加，最终成ABC三相 //每个通道的值
tmpWaveData.add((float) (Math.round(fValue * 100)) / 100);
} }
//把每个单独的值赋予到整体里面去 //xValue前移量，假如是第一次时候则需要前移
listWaveData.add(tmpWaveData); if (!blxValue && j == 0) {
xValueAll = (float) (i * 20) / tmpRateDTO.getNOneSample() - comtradeCfgDTO.getNPush();
blxValue = true;
//只增加一个xValue的值 //增加时间值
tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100);
} else if (j == 0) {
xValueAll += (float) nWaveSpan * dfValue;
//只增加一个xValue的值 //增加时间值
tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100);
}
//不同通道yValue的值都需要增加，最终成ABC三相 //每个通道的值
tmpWaveData.add((float) (Math.round(fValue * 100)) / 100);
} }
//把每个单独的值赋予到整体里面去
listWaveData.add(tmpWaveData);
} }
} }
} }
@@ -1650,8 +1656,8 @@ public class WaveFileComponent {
s = sdf.format(d); s = sdf.format(d);
System.out.println(s); System.out.println(s);
WaveFileComponent waveFileComponent = new WaveFileComponent(); WaveFileComponent waveFileComponent = new WaveFileComponent();
InputStream cfgStream = waveFileComponent.getFileInputStreamByFilePath("F:\\PQ_PQLD3_9_20250821_081038_640.cfg"); InputStream cfgStream = waveFileComponent.getFileInputStreamByFilePath("C:\\Users\\Administrator\\Desktop\\wave\\PQMonitor_PQM2_006970_20260320_175033_734.CFG");
InputStream datStream = waveFileComponent.getFileInputStreamByFilePath("F:\\PQ_PQLD3_9_20250821_081038_640.dat"); InputStream datStream = waveFileComponent.getFileInputStreamByFilePath("C:\\Users\\Administrator\\Desktop\\wave\\PQMonitor_PQM2_006970_20260320_175033_734.DAT");
// 获取瞬时波形 //获取原始波形值 // 获取瞬时波形 //获取原始波形值
WaveDataDTO waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 1); WaveDataDTO waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 1);
d = new Date(); d = new Date();