From fb50c6c8111fffd16091ce25d5d389ea3fcc560f Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期五, 21 三月 2025 14:44:39 +0800
Subject: [PATCH] 不同协议中的开关阀类型进行兼容

---
 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ByteUtil.java |  273 +++++++++++++++++++++++++++++++++++-------------------
 1 files changed, 175 insertions(+), 98 deletions(-)

diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ByteUtil.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ByteUtil.java
index f2e5c50..5f05861 100644
--- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ByteUtil.java
+++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ByteUtil.java
@@ -4,7 +4,50 @@
 
 
 public class ByteUtil {
-	
+
+	/**
+	 * 灏嗗瓧鑺傛暟缁勫垎鍓�
+	 * @param bytes 琚垎鍓叉暟缁�
+	 * @param fromIndex 鍒嗗壊璧峰浣嶇疆
+	 * @param len 鍒嗗壊闀垮害
+	 * @return 杩斿洖 鍒嗗壊鍑烘潵鐨勬暟缁�
+	 */
+	public static byte[] bytesSplit(byte[] bytes, int fromIndex, int len){
+		if(bytes == null){
+			return null ;
+		}else{
+			byte[] bs = new byte[len] ;
+			if(fromIndex + len > bytes.length){
+				System.arraycopy(bytes, fromIndex, bs, 0, bytes.length - fromIndex) ;
+			}else{
+				System.arraycopy(bytes, fromIndex, bs, 0, len) ;
+			}
+			return bs ;
+		}
+	}
+	/**
+	 * 灏嗗瓧鑺傛暟缁勫垎鍓�
+	 * @param bytes 琚垎鍓叉暟缁�
+	 * @param fromIndex 鍒嗗壊璧峰浣嶇疆
+	 * @param len 鍒嗗壊闀垮害
+	 * @return 杩斿洖 鍒嗗壊鍑烘潵鐨勬暟缁�
+	 */
+	public static Object[] bytesSplit_(byte[] bytes, int fromIndex, int len){
+		if(bytes == null){
+			return null ;
+		}else{
+			int realLen = len ;
+			byte[] bs = new byte[len] ;
+			if(fromIndex + len > bytes.length){
+				System.arraycopy(bytes, fromIndex, bs, 0, bytes.length - fromIndex) ;
+				realLen = bytes.length - fromIndex ;
+			}else{
+				System.arraycopy(bytes, fromIndex, bs, 0, len) ;
+			}
+			return new Object[]{bs, realLen} ;
+		}
+	}
+
 	/**
 	 * 灏嗗瓧鑺傛暟缁勫悎骞跺埌瀛楄妭鏁扮粍涓�
 	 * @param bGroup1 琚悎骞舵暟缁�
@@ -511,9 +554,9 @@
 			for (int i = 0; i < 4; i++) {
 				bs[from + i] = Integer.valueOf(value & 0xff).byteValue();// 灏嗘渶浣庝綅淇濆瓨鍦ㄤ綆瀛楄妭
 				value = value >> 8; // 鍚戝彸绉�8浣�
-			if(value == 0){
-				break ;
-			}
+				if(value == 0){
+					break ;
+				}
 			}
 		} else {
 			throw new Exception("int2Bytes鏃舵暟缁勮秺鐣�");
@@ -660,8 +703,7 @@
 			// s1涓嶅彉
 			s0 <<= 8;
 			s = s0 | s1;
-			return (short) s;
-
+			return (short)s ;
 		} else {
 			throw new Exception("byte2Short鏃舵暟缁勮秺鐣�");
 		}
@@ -892,47 +934,107 @@
 	 * @return 杩斿洖 String
 	 */
 	public static String bytes2Hex(byte[] src, boolean hasBlank){
-	    StringBuilder stringBuilder = new StringBuilder("");
-	    if (src == null || src.length <= 0) {
-	        return null;
-	    }
-	    for (int i = 0; i < src.length; i++) {
-	        int v = src[i] & 0xFF;
-	        String str = Integer.toHexString(v);
-	        if (str.length() < 2) {
-	        	str = "0" + str;
-	        }
-			if (hasBlank) {
-				if (i == 0) {
-					stringBuilder.append(str);
-				} else {
-					stringBuilder.append(" " + str);
-				}
-			} else {
-				stringBuilder.append(str);
-			}
-	    }
-	    return stringBuilder.toString().toUpperCase(Locale.US);
+	    return bytes2Hex_BE(src, hasBlank) ;
 	}
+
+    /**
+     * 瀛楄妭鏁扮粍杞崲鎴愬崄鍏繘鍒剁殑瀛楃涓�
+     *
+     * @param src byte[]
+     * @param hasBlank 16杩涘埗鏄惁鐢ㄧ┖鏍煎垎闅�
+     * @return 杩斿洖 String
+     */
+    public static String bytes2Hex_BE(byte[] src, boolean hasBlank){
+        StringBuilder stringBuilder = new StringBuilder("");
+        if (src == null || src.length <= 0) {
+            return null;
+        }
+        for (int i = 0; i < src.length; i++) {
+            int v = src[i] & 0xFF;
+            String str = Integer.toHexString(v);
+            if (str.length() < 2) {
+                str = "0" + str;
+            }
+            if (hasBlank) {
+                if (i == 0) {
+                    stringBuilder.append(str);
+                } else {
+                    stringBuilder.append(" " + str);
+                }
+            } else {
+                stringBuilder.append(str);
+            }
+        }
+        return stringBuilder.toString().toUpperCase(Locale.US);
+    }
+    /**
+     * 瀛楄妭鏁扮粍杞崲鎴愬崄鍏繘鍒剁殑瀛楃涓�
+     *
+     * @param src byte[]
+     * @param hasBlank 16杩涘埗鏄惁鐢ㄧ┖鏍煎垎闅�
+     * @return 杩斿洖 String
+     */
+    public static String bytes2Hex_LE(byte[] src, boolean hasBlank){
+        StringBuilder stringBuilder = new StringBuilder("");
+        if (src == null || src.length <= 0) {
+            return null;
+        }
+        for (int i = src.length - 1 ; i >= 0; i--) {
+            int v = src[i] & 0xFF;
+            String str = Integer.toHexString(v);
+            if (str.length() < 2) {
+                str = "0" + str;
+            }
+            if (hasBlank) {
+                if (i == 0) {
+                    stringBuilder.append(str);
+                } else {
+                    stringBuilder.append(" " + str);
+                }
+            } else {
+                stringBuilder.append(str);
+            }
+        }
+        return stringBuilder.toString().toUpperCase(Locale.US);
+    }
 	/**
 	 * 瀛楄妭鏁扮粍杞崲鎴愬崄鍏繘鍒剁殑瀛楃涓�
 	 *
-	 * @param src byte[]
+	 * @param bs byte[]
 	 * @param hasBlank 16杩涘埗鏄惁鐢ㄧ┖鏍煎垎闅�
 	 * @param from 寮�濮嬩綅
 	 * @param len 闀垮害
 	 * @return 杩斿洖 String
 	 */
-	public static String bytes2Hex(byte[] src, boolean hasBlank, int from, int len){
-	    if (src == null || src.length <= 0 || src.length < from + len) {
+	public static String bytes2Hex(byte[] bs, boolean hasBlank, int from, int len){
+	    if (bs == null || bs.length <= 0 || bs.length < from + len) {
 	        return null;
 	    }
 		byte[] bb = new byte[len];
 		for (int i = 0 ; i < len; i++) {
-			bb[i] = src[from + i];
+			bb[i] = bs[from + i];
 		}
 	    return bytes2Hex(bb, hasBlank) ;
 	}
+    /**
+     * 瀛楄妭鏁扮粍杞崲鎴愬崄鍏繘鍒剁殑瀛楃涓�
+     *
+     * @param bs byte[]
+     * @param hasBlank 16杩涘埗鏄惁鐢ㄧ┖鏍煎垎闅�
+     * @param from 寮�濮嬩綅
+     * @param len 闀垮害
+     * @return 杩斿洖 String
+     */
+    public static String bytes2Hex_LE(byte[] bs, boolean hasBlank, int from, int len){
+        if (bs == null || bs.length <= 0 || bs.length < from + len) {
+            return null;
+        }
+        byte[] bb = new byte[len];
+        for (int i = 0 ; i < len; i++) {
+            bb[i] = bs[from + i];
+        }
+        return bytes2Hex_LE(bb, hasBlank) ;
+    }
 	/**
 	 * 鍗佸叚杩涘埗杞瓧鑺傛暟缁�
 	 * @param hex the hex string
@@ -975,78 +1077,29 @@
 	    return fromIndex ;
 	}
 
-	private static final char[] HEX_CHAR = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
 	/**
-	 * 灏哹yte[]杞崲涓�16杩涘埗瀛楃涓�
-	 *
-	 * @param bytes 寰呰浆鎹yte[]
-	 * @return 杩斿洖 杞崲鍚庣殑瀛楃涓�
+	 * 鍗佸叚杩涘埗杞瓧鑺傛暟缁�
+	 * @param hex the hex string
+	 * @return 杩斿洖 byte[]
 	 */
-	public static String bytesToHex(byte[] bytes) {
-		//涓�涓猙yte涓�8浣嶏紝鍙敤涓や釜鍗佸叚杩涘埗浣嶆爣璇�
-		char[] buf = new char[bytes.length * 2];
-		int a = 0;
-		int index = 0;
-		for (byte b : bytes) { // 浣跨敤闄や笌鍙栦綑杩涜杞崲
-			if (b < 0) {
-				a = 256 + b;
-			} else {
-				a = b;
-			}
-
-			buf[index++] = HEX_CHAR[a / 16];
-			buf[index++] = HEX_CHAR[a % 16];
+	public static int hex2Bytes_LE(String hex, byte[] bs, int fromIndex) {
+		if (hex == null || hex.equals("")) {
+			return fromIndex;
 		}
-		return new String(buf);
-	}
-	/**
-	 * 灏哹yte[]杞崲涓�16杩涘埗瀛楃涓�
-	 *
-	 * @param bytes 寰呰浆鎹yte[]
-	 * @return 杩斿洖 杞崲鍚庣殑瀛楃涓�
-	 */
-	public static String bytesToHex(byte[] bytes, int startIndex, int endIndex) {
-		byte[] bs = new byte[endIndex - startIndex + 1] ;
-		byte j = 0 ;
-		for(int i = startIndex; i <= endIndex; i++){
-			bs[j++] = bytes[i] ;
+		hex = hex.toUpperCase(Locale.ENGLISH);
+		int length = hex.length() / 2;
+		char[] hexChars = hex.toCharArray();
+		byte[] d = new byte[length];
+		for (int i = 0; i < length; i++) {
+			int pos = i * 2;
+			d[i] = (byte) (charToByte(hexChars[pos]) << 4 | charToByte(hexChars[pos + 1]));
 		}
-		//涓�涓猙yte涓�8浣嶏紝鍙敤涓や釜鍗佸叚杩涘埗浣嶆爣璇�
-		char[] buf = new char[bs.length * 2];
-		int a = 0;
-		int index = 0;
-		for (byte b : bs) { // 浣跨敤闄や笌鍙栦綑杩涜杞崲
-			if (b < 0) {
-				a = 256 + b;
-			} else {
-				a = b;
-			}
-
-			buf[index++] = HEX_CHAR[a / 16];
-			buf[index++] = HEX_CHAR[a % 16];
+		for(int i = 0 ; i < d.length; i++){
+			bs[fromIndex++] = d[(d.length - 1) - i] ;
 		}
-		return new String(buf);
+		return fromIndex ;
 	}
 
-	/**
-	 * 灏�16杩涘埗瀛楃涓茶浆鎹负byte[]
-	 *
-	 * @param str 寰呰浆鎹㈠瓧绗︿覆
-	 * @return 杩斿洖 杞崲鍚庣殑byte[]
-	 */
-	public static byte[] hexToBytes(String str) {
-		if (str == null || "".equals(str.trim())) {
-			return new byte[0];
-		}
-
-		byte[] bytes = new byte[str.length() / 2];
-		for (int i = 0; i < str.length() / 2; i++) {
-			String subStr = str.substring(i * 2, i * 2 + 2);
-			bytes[i] = (byte) Integer.parseInt(subStr, 16);
-		}
-
-		return bytes;
-	}
 
 	/**
 	 * Convert char to byte
@@ -1093,6 +1146,31 @@
 		encodeBCD_LE(str, b, 0, b.length);
 
 		return b;
+	}
+
+	/**
+	 * 灏忕妯″紡銆婃暟鎹綆浣嶅湪鏁扮粍浣庡瓧鑺傘��
+	 * 鏁村舰杞垚BCD缂栫爜锛屽瓧鑺傞『搴忔槸鍊掔殑
+	 * @param i
+	 * @param bs
+	 * @param from
+	 * @return 杩斿洖
+	 */
+	public static void int2BCD_LE(int i, byte[] bs, int from)throws Exception {
+		String str = "" + i;
+		byte[] b = null;
+		if (str.length() % 2 == 0) {
+			b = new byte[str.length() / 2];
+		} else {
+			b = new byte[(str.length() / 2) + 1];
+		}
+		encodeBCD_LE(str, b, 0, b.length);
+
+		int len = bs.length ;
+		int bLen = b.length ;
+		for(int j = 0; (j < len && j < bLen); j++){
+			bs[from + j] = b[j] ;
+		}
 	}
 
 	/**
@@ -1306,8 +1384,7 @@
 	public static long BCD2Long_LE(byte[] b, int startIndex, int endIndex)throws Exception {
 		String str = "";
 		str = decodeBCD_LE(b, startIndex, endIndex - startIndex + 1);
-		long n = Long.parseLong(str);
-		return n;
+        return Long.parseLong(str);
 	}
 
 	/**

--
Gitblit v1.8.0