feat(sdk): 添加电表和水表通信工具类
Some checks are pending
Gitea Actions Demo / Explore-Gitea-Actions (push) Waiting to run
Some checks are pending
Gitea Actions Demo / Explore-Gitea-Actions (push) Waiting to run
This commit is contained in:
parent
f24df2e494
commit
498209cb87
@ -0,0 +1,20 @@
|
||||
package org.dromara.sis.sdk.meter.domain;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* @author lsm
|
||||
* @apiNote PowerFrame
|
||||
* @since 2025/7/20
|
||||
*/
|
||||
@Data
|
||||
@AllArgsConstructor
|
||||
public class PowerFrame {
|
||||
|
||||
private byte[] address;
|
||||
|
||||
private byte controlCode;
|
||||
|
||||
private byte[] data;
|
||||
}
|
||||
@ -0,0 +1,179 @@
|
||||
package org.dromara.sis.sdk.meter.utils;
|
||||
|
||||
import org.dromara.sis.sdk.meter.domain.PowerFrame;
|
||||
|
||||
import java.nio.ByteBuffer;
|
||||
import java.nio.ByteOrder;
|
||||
import java.util.Arrays;
|
||||
|
||||
/**
|
||||
* @author lsm
|
||||
* @apiNote PowerMeterUtil
|
||||
* @since 2025/7/20
|
||||
*/
|
||||
public class PowerMeterUtil {
|
||||
|
||||
// 协议常量定义
|
||||
public static final byte FRAME_START = 0x68;
|
||||
public static final byte FRAME_END = 0x16;
|
||||
public static final byte[] PREAMBLE = {(byte) 0xFE, (byte) 0xFE, (byte) 0xFE, (byte) 0xFE};
|
||||
public static final int ADDR_LENGTH = 6;
|
||||
public static final int MAX_READ_DATA_LEN = 200;
|
||||
public static final int MAX_WRITE_DATA_LEN = 50;
|
||||
|
||||
// 控制码功能定义
|
||||
public static final byte CTRL_BROADCAST_TIME = 0x08;
|
||||
public static final byte CTRL_READ_DATA = 0x11;
|
||||
public static final byte CTRL_READ_FOLLOW_DATA = 0x12;
|
||||
public static final byte CTRL_WRITE_DATA = 0x14;
|
||||
public static final byte CTRL_TRIP_CONTROL = 0x1C;
|
||||
public static final byte CTRL_OUTPUT_CONTROL = 0x1D;
|
||||
|
||||
// 地址通配符
|
||||
public static final byte ADDR_WILDCARD = (byte) 0xAA;
|
||||
|
||||
/**
|
||||
* 构建基础帧结构
|
||||
*
|
||||
* @param address 6字节地址(高位在前，低位在后)
|
||||
* @param ctrlCode 控制码
|
||||
* @param data 原始数据域(未加33H)
|
||||
* @param isEncode 是否进行数据域处理
|
||||
* @return 完整帧数据
|
||||
*/
|
||||
public byte[] buildFrame(byte[] address, byte ctrlCode, byte[] data, boolean isEncode) {
|
||||
if (address.length != ADDR_LENGTH) {
|
||||
throw new IllegalArgumentException("Address must be 6 bytes");
|
||||
}
|
||||
|
||||
// 处理数据域：每个字节加0x33
|
||||
byte[] processedData = processDataDomain(data, isEncode);
|
||||
|
||||
// 计算数据域长度
|
||||
int dataLen = (data != null) ? data.length : 0;
|
||||
if (dataLen > MAX_READ_DATA_LEN) {
|
||||
throw new IllegalArgumentException("Data length exceeds max limit");
|
||||
}
|
||||
|
||||
// 计算总帧长度: 起始符(1) + 地址(6) + 起始符(1) + 控制码(1) + 长度(1) + 数据域 + 校验(1) + 结束符(1)
|
||||
int totalLength = 11 + dataLen;
|
||||
ByteBuffer buffer = ByteBuffer.allocate(totalLength)
|
||||
.order(ByteOrder.LITTLE_ENDIAN);
|
||||
|
||||
// 地址域处理 (传输顺序: 低字节在前)
|
||||
byte[] reversedAddr = reverseAddress(address);
|
||||
|
||||
// 构建帧
|
||||
buffer.put(FRAME_START)
|
||||
.put(reversedAddr)
|
||||
.put(FRAME_START)
|
||||
.put(ctrlCode)
|
||||
.put((byte) dataLen);
|
||||
|
||||
if (dataLen > 0) {
|
||||
buffer.put(processedData);
|
||||
}
|
||||
|
||||
// 计算校验码 (从第一个0x68到数据域结束)
|
||||
byte[] frameWithoutCs = Arrays.copyOf(buffer.array(), buffer.position());
|
||||
byte cs = calculateChecksum(frameWithoutCs);
|
||||
|
||||
buffer.put(cs)
|
||||
.put(FRAME_END);
|
||||
|
||||
return buffer.array();
|
||||
}
|
||||
|
||||
/**
|
||||
* 解析接收到的帧
|
||||
* @param frame 完整帧数据(包含前导符)
|
||||
* @return 解析结果对象
|
||||
*/
|
||||
public PowerFrame parseFrame(byte[] frame) {
|
||||
// 跳过前导符 (0-3)
|
||||
int startIndex = findFrameStart(frame);
|
||||
if (startIndex == -1) {
|
||||
throw new IllegalArgumentException("无效帧：未找到起始标记");
|
||||
}
|
||||
|
||||
// 基本长度检查
|
||||
if (frame.length < startIndex + 12) {
|
||||
throw new IllegalArgumentException("接受帧太短");
|
||||
}
|
||||
|
||||
// 提取地址域 (传输顺序: 低字节在前)
|
||||
byte[] reversedAddr = Arrays.copyOfRange(frame, startIndex + 1, startIndex + 7);
|
||||
byte[] address = reverseAddress(reversedAddr);
|
||||
|
||||
// 控制码
|
||||
byte ctrlCode = frame[startIndex + 8];
|
||||
|
||||
// 数据域长度
|
||||
int dataLen = frame[startIndex + 9] & 0xFF;
|
||||
|
||||
// 数据域位置
|
||||
int dataStart = startIndex + 10;
|
||||
int dataEnd = dataStart + dataLen;
|
||||
|
||||
// 校验位位置
|
||||
int endPos = dataEnd + 1;
|
||||
|
||||
// 验证结束符
|
||||
if (frame[endPos] != FRAME_END) {
|
||||
throw new IllegalArgumentException("无效的帧结束标记");
|
||||
}
|
||||
|
||||
// 提取原始数据域 (含33H处理)
|
||||
byte[] rawData = Arrays.copyOfRange(frame, dataStart, dataEnd);
|
||||
byte[] processedData = processDataDomain(rawData, false);
|
||||
|
||||
// 验证校验和
|
||||
byte calculatedCs = calculateChecksum(Arrays.copyOfRange(frame, startIndex, dataEnd));
|
||||
byte receivedCs = frame[dataEnd];
|
||||
|
||||
if (calculatedCs != receivedCs) {
|
||||
throw new IllegalArgumentException("校验和不匹配");
|
||||
}
|
||||
|
||||
return new PowerFrame(address, ctrlCode, processedData);
|
||||
}
|
||||
|
||||
// 数据处理域：加/减33H
|
||||
private byte[] processDataDomain(byte[] data, boolean isEncode) {
|
||||
if (data == null || data.length == 0) return data;
|
||||
|
||||
byte[] result = new byte[data.length];
|
||||
for (int i = 0; i < data.length; i++) {
|
||||
result[i] = (byte) (isEncode ? (data[i] + 0x33) : (data[i] - 0x33));
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
// 地址反转 (传输顺序处理)
|
||||
private byte[] reverseAddress(byte[] address) {
|
||||
byte[] reversed = new byte[address.length];
|
||||
for (int i = 0; i < address.length; i++) {
|
||||
reversed[i] = address[address.length - 1 - i];
|
||||
}
|
||||
return reversed;
|
||||
}
|
||||
|
||||
// 计算校验和 (模256和)
|
||||
private byte calculateChecksum(byte[] data) {
|
||||
int sum = 0;
|
||||
for (byte b : data) {
|
||||
sum = (sum + (b & 0xFF)) & 0xFF;
|
||||
}
|
||||
return (byte) sum;
|
||||
}
|
||||
|
||||
// 在帧数据中查找起始符
|
||||
private int findFrameStart(byte[] data) {
|
||||
for (int i = 0; i < data.length - 1; i++) {
|
||||
if (data[i] == FRAME_START && data[i + 1] != FRAME_START) {
|
||||
return i;
|
||||
}
|
||||
}
|
||||
return -1;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,168 @@
|
||||
package org.dromara.sis.sdk.meter.utils;
|
||||
|
||||
import java.nio.ByteBuffer;
|
||||
import java.util.Arrays;
|
||||
|
||||
/**
|
||||
* @author lsm
|
||||
* @apiNote WaterMeterUtil
|
||||
* @since 2025/7/20
|
||||
*/
|
||||
public class WaterMeterUtil {
|
||||
|
||||
// 协议常量定义
|
||||
public static final byte PREAMBLE = (byte) 0xFE;
|
||||
public static final byte FRAME_START = 0x68;
|
||||
public static final byte FRAME_END = 0x16;
|
||||
public static final byte WATER_METER_TYPE = 0x10;
|
||||
public static final byte CTRL_READ = 0x01;
|
||||
public static final byte CTRL_RESPONSE = (byte) 0x81;
|
||||
public static final byte UNIT_TON = 0x2C;
|
||||
public static final int ADDRESS_LENGTH = 7;
|
||||
|
||||
/**
|
||||
* 构建读表数据命令帧
|
||||
*
|
||||
* @param meterAddress 12位表计地址字符串（如"000000000000012"）
|
||||
* @param diHighFirst 数据标识字节序：true=901Fh(高字节在前), false=1F90h(低字节在前)
|
||||
* @return 完整的命令帧字节数组
|
||||
*/
|
||||
public static byte[] buildReadCommand(String meterAddress, boolean diHighFirst) {
|
||||
// 1. 地址转换：12位字符串 -> 7字节BCD码（逆序分组）
|
||||
byte[] addressBytes = convertAddress(meterAddress);
|
||||
|
||||
// 2. 构建帧主体（不含前导符和帧尾）
|
||||
ByteBuffer buffer = ByteBuffer.allocate(32);
|
||||
buffer.put(FRAME_START);
|
||||
buffer.put(WATER_METER_TYPE);
|
||||
buffer.put(addressBytes);
|
||||
buffer.put(CTRL_READ);
|
||||
buffer.put((byte) 0x03); // 数据域长度
|
||||
|
||||
// 数据标识处理
|
||||
if (diHighFirst) {
|
||||
buffer.put((byte) 0x90);
|
||||
buffer.put((byte) 0x1F);
|
||||
} else {
|
||||
buffer.put((byte) 0x1F);
|
||||
buffer.put((byte) 0x90);
|
||||
}
|
||||
|
||||
buffer.put((byte) 0x00); // 序列号
|
||||
|
||||
// 3. 计算校验码（从FRAME_START到序列号）
|
||||
byte[] frameBody = Arrays.copyOf(buffer.array(), buffer.position());
|
||||
byte cs = calculateChecksum(frameBody, 0, frameBody.length);
|
||||
|
||||
// 4. 组装完整帧
|
||||
buffer.put(cs);
|
||||
buffer.put(FRAME_END);
|
||||
|
||||
// 5. 添加前导符
|
||||
byte[] fullFrame = Arrays.copyOf(buffer.array(), buffer.position());
|
||||
return addPreamble(fullFrame);
|
||||
}
|
||||
|
||||
/**
|
||||
* 解析读表响应数据
|
||||
*
|
||||
* @param response 完整响应帧（含前导符）
|
||||
* @return 解析后的累积流量值（单位：吨）
|
||||
* @throws IllegalArgumentException 响应格式错误
|
||||
*/
|
||||
public static double parseReadResponse(byte[] response) {
|
||||
// 1. 跳过前导符(0xFE x3)
|
||||
int startIndex = 3;
|
||||
if (response[startIndex] != FRAME_START) {
|
||||
throw new IllegalArgumentException("无效帧起始符");
|
||||
}
|
||||
|
||||
// 2. 基础信息解析
|
||||
int pos = startIndex + 1;
|
||||
byte meterType = response[pos++];
|
||||
byte[] address = Arrays.copyOfRange(response, pos, pos + ADDRESS_LENGTH);
|
||||
pos += ADDRESS_LENGTH;
|
||||
|
||||
byte ctrlCode = response[pos++];
|
||||
if (ctrlCode != CTRL_RESPONSE) {
|
||||
throw new IllegalArgumentException("无效控制码");
|
||||
}
|
||||
|
||||
// 3. 数据域解析
|
||||
int dataLen = response[pos++] & 0xFF;
|
||||
byte[] di = {response[pos++], response[pos++]}; // 数据标识
|
||||
byte ser = response[pos++]; // 序列号
|
||||
|
||||
// 4. 累积流量解析 (4字节BCD)
|
||||
byte[] currentFlow = Arrays.copyOfRange(response, pos, pos + 4);
|
||||
pos += 4;
|
||||
|
||||
// 5. 单位校验
|
||||
if (response[pos++] != UNIT_TON) {
|
||||
throw new IllegalArgumentException("无效计量单位");
|
||||
}
|
||||
|
||||
// 6. 流量值转换
|
||||
return parseFlowValue(currentFlow);
|
||||
}
|
||||
|
||||
/**
|
||||
* 计算校验码 (CJ/T188-2004标准)
|
||||
*
|
||||
* @param data 待计算数据
|
||||
* @param offset 起始位置
|
||||
* @param length 数据长度
|
||||
* @return 校验码
|
||||
*/
|
||||
public static byte calculateChecksum(byte[] data, int offset, int length) {
|
||||
int sum = 0;
|
||||
for (int i = offset; i < offset + length; i++) {
|
||||
sum += (data[i] & 0xFF);
|
||||
}
|
||||
return (byte) (sum % 256);
|
||||
}
|
||||
|
||||
// 地址转换：12位字符串 -> 7字节BCD码（逆序分组）
|
||||
private static byte[] convertAddress(String address) {
|
||||
if (address.length() != 12) {
|
||||
throw new IllegalArgumentException("地址长度必须为12位");
|
||||
}
|
||||
|
||||
// 填充为14位（7字节*2）
|
||||
String padded = "00" + address;
|
||||
byte[] result = new byte[ADDRESS_LENGTH];
|
||||
|
||||
// 逆序分组转换
|
||||
for (int i = 0; i < ADDRESS_LENGTH; i++) {
|
||||
int end = padded.length() - i * 2;
|
||||
int start = end - 2;
|
||||
String segment = padded.substring(start, end);
|
||||
result[i] = (byte) Integer.parseInt(segment, 16);
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
// 添加前导符 0xFE x3
|
||||
private static byte[] addPreamble(byte[] frame) {
|
||||
byte[] result = new byte[frame.length + 3];
|
||||
result[0] = PREAMBLE;
|
||||
result[1] = PREAMBLE;
|
||||
result[2] = PREAMBLE;
|
||||
System.arraycopy(frame, 0, result, 3, frame.length);
|
||||
return result;
|
||||
}
|
||||
|
||||
// 解析BCD流量值（4字节 -> 浮点数）
|
||||
private static double parseFlowValue(byte[] data) {
|
||||
// 拼接BCD数字串
|
||||
StringBuilder sb = new StringBuilder();
|
||||
for (byte b : data) {
|
||||
sb.append(String.format("%02X", b));
|
||||
}
|
||||
|
||||
// 转换为数值（最后2位是小数位）
|
||||
String numStr = sb.toString();
|
||||
return Double.parseDouble(numStr.substring(0, numStr.length() - 2) +
|
||||
Double.parseDouble(numStr.substring(numStr.length() - 2)) / 100.0);
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user