autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-05-05 10:30:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

解析报文

Browse Source
This commit is contained in:
Guoqs
2024-07-31 15:27:59 +08:00
parent e7db8be29e
commit a6d3cf3366
2 changed files with 11 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
jsowell-common/src/main/java/com/jsowell/common/util/YKCUtils.java
View File

@@ -20,6 +20,7 @@ public class YKCUtils {
* @return
*/
public static boolean checkMsg(byte[] msg) {
// log.info("checkMsg:{}", BytesUtil.binary(msg, 16));
// 起始标志
byte[] head = BytesUtil.copyBytes(msg, 0, 1);
// 数据长度
@@ -66,6 +67,11 @@ public class YKCUtils {
return false;
}
public static void main(String[] args) {
byte[] length = new byte[]{0x22};
System.out.println(BytesUtil.bytesToIntLittle(length));
}
/**
* 转换电压电流以及起始soc
* 精确到小数点后一位；待机置零
@@ -127,46 +133,6 @@ public class YKCUtils {
return bytes;
}
public static void main(String[] args) {
String frameTypeStr = "0x01";
byte[] bytes = frameTypeStr2Bytes(frameTypeStr);
System.out.println("转为byte数组:" + Arrays.toString(bytes));
String frameType2Str = frameType2Str(bytes);
System.out.println("转为Str:" + frameType2Str);
// String hexString = "681E0000003388000000000027012302081602434533880000000000270101008361";
// byte[] byteArray = new byte[hexString.length() / 2];
// for (int i = 0; i < byteArray.length; i++) {
// int index = i * 2;
// int j = Integer.parseInt(hexString.substring(index, index + 2), 16);
// byteArray[i] = (byte) j;
// }
// System.out.println(byteArray);
// String binary = BytesUtil.binary(byteArray, 16);
// String aaa = DatatypeConverter.printHexBinary(byteArray);
// System.out.println(binary);
// System.out.println(aaa);
// String targetCRC = "0abb";
// String substring = StringUtils.substring(targetCRC, 0, 2);
// String substring1 = StringUtils.substring(targetCRC, 2, 4);
// String crc = substring1 + substring;
//
// String hexString = "4f";
// byte[] bytes = new byte[]{0x4f};
//
// String s = transitionTemperature(bytes);
// System.out.println(s);
//
// byte[] bytess = new byte[]{(byte) 0x80, (byte) 0x1A, 0x06, 0x00};
// String s1 = convertDecimalPoint(bytess, 5);
// System.out.println(s1);
//
// String amount = "1000";
// byte[] priceByte = getPriceByte(amount, 2);
// System.out.println(BytesUtil.bin2HexStr(priceByte));
}
/**
* 转换温度
* BIN 码 1 整形，偏移量-50；待机置零

10
jsowell-netty/src/main/java/com/jsowell/netty/decoder/StartAndLengthFieldFrameDecoder.java
View File

@@ -88,7 +88,7 @@ public class StartAndLengthFieldFrameDecoder extends ByteToMessageDecoder {
// 处理68协议消息
private void decode68Message(ByteBuf buffer, List<Object> out, int beginReader) {
// 检查剩余数据是否足够
if (buffer.readableBytes() < HEADER_LENGTH_68 + 1) {
if (buffer.readableBytes() < HEADER_LENGTH_68 + 1 + 2) {
buffer.readerIndex(beginReader);
return;
}
@@ -96,14 +96,14 @@ public class StartAndLengthFieldFrameDecoder extends ByteToMessageDecoder {
// 获取消息长度
int length = buffer.getUnsignedByte(beginReader + HEADER_LENGTH_68);
// 检查剩余数据是否足够
if (buffer.readableBytes() < HEADER_LENGTH_68 + 1 + length) {
if (buffer.readableBytes() < HEADER_LENGTH_68 + 1 + length + 2) {
buffer.readerIndex(beginReader);
return;
}
// 读取 data 数据
ByteBuf frame = buffer.retainedSlice(beginReader, HEADER_LENGTH_68 + 1 + length);
buffer.readerIndex(beginReader + HEADER_LENGTH_68 + 1 + length);
// 读取 data 数据 最后+2是帧校验域长度
ByteBuf frame = buffer.retainedSlice(beginReader, HEADER_LENGTH_68 + 1 + length + 2);
buffer.readerIndex(beginReader + HEADER_LENGTH_68 + 1 + length + 2);
out.add(frame);
}