From a33d677671d4996ff918ff5b625a5b9da5f17594 Mon Sep 17 00:00:00 2001 From: huangfeng Date: Thu, 10 Apr 2025 14:19:22 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=A2=9E=E5=8A=A0=E5=B1=80=E6=94=BE?= =?UTF-8?q?=E8=B0=B1=E5=9B=BE=E8=A7=A3=E6=9E=90=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../xydl/cac/model/spectrogram/SouthPd.java | 89 +++++++++++++++++++ .../xydl/cac/model/spectrogram/SouthYsp.java | 1 - .../model/spectrogram/SpectrogramModel.java | 2 + .../com/xydl/cac/spectrogram/ProcessorPd.java | 34 +++++++ .../cac/spectrogram/SpectrogramHandler.java | 38 +++++--- 5 files changed, 150 insertions(+), 14 deletions(-) create mode 100644 src/main/java/com/xydl/cac/model/spectrogram/SouthPd.java create mode 100644 src/main/java/com/xydl/cac/spectrogram/ProcessorPd.java diff --git a/src/main/java/com/xydl/cac/model/spectrogram/SouthPd.java b/src/main/java/com/xydl/cac/model/spectrogram/SouthPd.java new file mode 100644 index 0000000..de41cfc --- /dev/null +++ b/src/main/java/com/xydl/cac/model/spectrogram/SouthPd.java @@ -0,0 +1,89 @@ +package com.xydl.cac.model.spectrogram; + +import lombok.Data; + +import java.io.DataInputStream; +import java.util.ArrayList; +import java.util.List; + +@Data +public class SouthPd extends SpectrogramModel { + Float version; + Float fileVersion; + Short code; + String flag; + String name; + String pdType; + String warnLevel; + String probabilityFlag; + Float probability1; + Float probability2; + Float probability3; + Float probability4; + Float probability5; + Float probability6; + Float probability7; + Integer m; + Integer n; + Integer p; + Float hz50; + Float hz100; + String picType; + String unit; + Float minLimit; + Float maxLimit; + + List> dataPD; + List> dataPS; + + public void readFrom(DataInputStream dis) throws Exception { + version = readLittleEndianFloat(dis); + fileVersion = readLittleEndianFloat(dis); + code = readLittleEndianShort(dis); + createTime = readLittleEndianLong(dis); + flag = readString(dis, 1); + name = readString(dis, 32); + pdType = readString(dis, 1); + warnLevel = readString(dis, 1); + probabilityFlag = readString(dis, 1); + probability1 = readLittleEndianFloat(dis); + probability2 = readLittleEndianFloat(dis); + probability3 = readLittleEndianFloat(dis); + probability4 = readLittleEndianFloat(dis); + probability5 = readLittleEndianFloat(dis); + probability6 = readLittleEndianFloat(dis); + probability7 = readLittleEndianFloat(dis); + m = readLittleEndianInt(dis); + n = readLittleEndianInt(dis); + p = readLittleEndianInt(dis); + hz50 = readLittleEndianFloat(dis); + hz100 = readLittleEndianFloat(dis); + picType = readString(dis, 1); + unit = readString(dis, 1); + minLimit = readLittleEndianFloat(dis); + maxLimit = readLittleEndianFloat(dis); + dis.readInt(); + + if ("0".equalsIgnoreCase(picType)) { + dataPD = new ArrayList<>(); + for (int i = 0; i < m; i++) { + List list = new ArrayList<>(); + for (int j = 0; j < n; j++) { + Integer v = readLittleEndianInt(dis); + list.add(v); + } + dataPD.add(list); + } + } else if ("1".equalsIgnoreCase(picType)) { + dataPS = new ArrayList<>(); + for (int i = 0; i < p; i++) { + List list = new ArrayList<>(); + for (int j = 0; j < m; j++) { + Float v = readLittleEndianFloat(dis); + list.add(v); + } + dataPS.add(list); + } + } + } +} diff --git a/src/main/java/com/xydl/cac/model/spectrogram/SouthYsp.java b/src/main/java/com/xydl/cac/model/spectrogram/SouthYsp.java index b8547cd..bfa22d8 100644 --- a/src/main/java/com/xydl/cac/model/spectrogram/SouthYsp.java +++ b/src/main/java/com/xydl/cac/model/spectrogram/SouthYsp.java @@ -11,7 +11,6 @@ public class SouthYsp extends SpectrogramModel { Float version; Float fileVersion; Short type; - Long createTime; String flag; String name; Float xInterval; diff --git a/src/main/java/com/xydl/cac/model/spectrogram/SpectrogramModel.java b/src/main/java/com/xydl/cac/model/spectrogram/SpectrogramModel.java index 02997fe..b926f0c 100644 --- a/src/main/java/com/xydl/cac/model/spectrogram/SpectrogramModel.java +++ b/src/main/java/com/xydl/cac/model/spectrogram/SpectrogramModel.java @@ -11,6 +11,8 @@ import java.nio.charset.StandardCharsets; @Data public class SpectrogramModel { + Long createTime; + // 读取小端序的int（4字节） public static int readLittleEndianInt(DataInputStream dis) throws IOException { byte[] bytes = new byte[4]; diff --git a/src/main/java/com/xydl/cac/spectrogram/ProcessorPd.java b/src/main/java/com/xydl/cac/spectrogram/ProcessorPd.java new file mode 100644 index 0000000..7ceb12d --- /dev/null +++ b/src/main/java/com/xydl/cac/spectrogram/ProcessorPd.java @@ -0,0 +1,34 @@ +package com.xydl.cac.spectrogram; + +import com.xydl.cac.model.spectrogram.SouthPd; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import java.io.DataInputStream; +import java.io.FileInputStream; + +@Service +@Slf4j +public class ProcessorPd { + + public SouthPd process(String localFilePath) { + try (DataInputStream dis = new DataInputStream(new FileInputStream(localFilePath))) { + SouthPd model = this.readOneBlock(dis); + return model; + } catch (Exception e) { + log.error("解析文件失败" + localFilePath, e); + return null; + } + } + + private SouthPd readOneBlock(DataInputStream dis) throws Exception { + SouthPd model = new SouthPd(); + model.readFrom(dis); + return model; + } + + public static void main(String[] args) { + ProcessorPd processorYsp = new ProcessorPd(); + processorYsp.process("C:/Code/cac/局放谱图/50100055_5__001_01_20250409180000.dat"); + } +} diff --git a/src/main/java/com/xydl/cac/spectrogram/SpectrogramHandler.java b/src/main/java/com/xydl/cac/spectrogram/SpectrogramHandler.java index 1832a23..d52a4e4 100644 --- a/src/main/java/com/xydl/cac/spectrogram/SpectrogramHandler.java +++ b/src/main/java/com/xydl/cac/spectrogram/SpectrogramHandler.java @@ -3,7 +3,9 @@ package com.xydl.cac.spectrogram; import com.xydl.cac.config.BizConfig; import com.xydl.cac.entity.IedDlRecord; import com.xydl.cac.entity.ModevType; +import com.xydl.cac.model.spectrogram.SouthPd; import com.xydl.cac.model.spectrogram.SouthYsp; +import com.xydl.cac.model.spectrogram.SpectrogramModel; import com.xydl.cac.service.ModevTypeService; import com.xydl.cac.util.DateUtil; import com.xydl.cac.util.JSONUtil; @@ -20,11 +22,14 @@ public class SpectrogramHandler { @Resource BizConfig bizConfig; @Resource + ModevTypeService modevTypeService; + @Resource ProcessorYsp processorYsp; @Resource - ModevTypeService modevTypeService; + ProcessorPd processorPd; public void processFile(IedDlRecord record) { + record.setCreateTime(new Date()); if (record.getTypeId() == null) { return; } @@ -32,21 +37,15 @@ public class SpectrogramHandler { try { ModevType modevType = modevTypeService.detail(record.getTypeId()); - // 油色谱谱图 + // 谱图解析 if (modevType.getMc().contains("油色谱")) { SouthYsp model = processorYsp.process(localFilePath); - String json = JSONUtil.object2Json(model); - record.setData(json); - record.setCreateTime(new Date()); - try { - String str = String.valueOf(model.getCreateTime()); - Date dtime = DateUtil.parse(str, "yyyyMMddHHmmss"); - record.setDTime(dtime); - } catch (Exception ignore) { - } + this.setData(record, model); log.info("解析油色谱谱图文件成功"); } else if (modevType.getMc().contains("局部放电")) { - + SouthPd model = processorPd.process(localFilePath); + this.setData(record, model); + log.info("解析局部放电谱图文件成功"); } else { log.error("缺少该类型" + record.getTypeId() + "的谱图处理模块"); } @@ -56,6 +55,17 @@ public class SpectrogramHandler { } } + private void setData(IedDlRecord record, SpectrogramModel model) { + String json = JSONUtil.object2Json(model); + record.setData(json); + try { + String str = String.valueOf(model.getCreateTime()); + Date dtime = DateUtil.parse(str, "yyyyMMddHHmmss"); + record.setDTime(dtime); + } catch (Exception ignore) { + } + } + public void jsonToModel(IedDlRecord record) { if (record.getTypeId() == null) { return; @@ -70,7 +80,9 @@ public class SpectrogramHandler { record.setModel(model); record.setData(null); } else if (modevType.getMc().contains("局部放电")) { - + SouthPd model = JSONUtil.json2Object(record.getData(), SouthPd.class); + record.setModel(model); + record.setData(null); } } catch (Exception ex) { log.error("谱图数据data内容存在异常, typeId=" + record.getTypeId() + ", devId=" + record.getDevId()