From 03b0fb0ba2de86bcfff277778826547c0e37a93f Mon Sep 17 00:00:00 2001
From: 张世豪 <979909237@qq.com>
Date: 星期四, 20 十一月 2025 23:52:51 +0800
Subject: [PATCH] 优化修改

---
 src/chuankou/Sendmsg.java |  104 ++++++++++++++++++++++++++++++++++-----------------
 1 files changed, 69 insertions(+), 35 deletions(-)

diff --git a/src/chuankou/Sendmsg.java b/src/chuankou/Sendmsg.java
index d97f1d8..6479155 100644
--- a/src/chuankou/Sendmsg.java
+++ b/src/chuankou/Sendmsg.java
@@ -11,8 +11,8 @@
     private static volatile SerialPortService serialService = null;
     private static volatile boolean isPortOpen = false;
     
-    // 璋冭瘯妯″紡寮�鍏�
-    private static final boolean DEBUG_MODE = false;
+    // 鏀逛负闈瀎inal锛屾敮鎸佸姩鎬佹帶鍒�
+    private static boolean DEBUG_MODE = false;
     
     // 鏃ユ湡鏍煎紡鍖�
     private static final SimpleDateFormat timeFormat = new SimpleDateFormat("HH:mm:ss.SSS");
@@ -35,48 +35,65 @@
     }
     
     /**
-     * 鍙戦�佹秷鎭埌涓插彛
-     * @param message 瑕佸彂閫佺殑HEX鏍煎紡娑堟伅
-     * @return 鍙戦�佹垚鍔熻繑鍥瀟rue锛屽け璐ヨ繑鍥瀎alse
+     * 鍙戦�佹秷鎭埌涓插彛锛堝甫閲嶈瘯鏈哄埗锛�
      */
     public static boolean sendMessage(String message) {
         if (!isPortOpen || serialService == null) {
-            if (DEBUG_MODE) {
-                System.err.println("[" + getCurrentTime() + "] 涓插彛鏈墦寮�锛屾棤娉曞彂閫佹暟鎹�");
-            }
+            System.err.println("[" + getCurrentTime() + "] 涓插彛鏈墦寮�锛屾棤娉曞彂閫佹暟鎹�");
             return false;
         }
         
         if (message == null || message.trim().isEmpty()) {
-            if (DEBUG_MODE) {
-                System.err.println("[" + getCurrentTime() + "] 鍙戦�佹暟鎹负绌�");
-            }
+            System.err.println("[" + getCurrentTime() + "] 鍙戦�佹暟鎹负绌�");
             return false;
         }
         
         String text = message.trim();
+        int retryCount = 0;
+        final int MAX_RETRY = 2;
         
-        try {
-            // HEX鏍煎紡鍙戦��
-            byte[] data = hexStringToByteArray(text);
-            if (data != null && serialService.send(data)) {
-                // 楂橀璋冪敤鏃堕伩鍏嶉绻佺殑鏃ュ織杈撳嚭锛屽彧鍦ㄨ皟璇曟椂璁板綍
-                if (DEBUG_MODE) {
-                    System.out.println("[" + getCurrentTime() + "] 鍙戦��: " + text.toUpperCase());
+        while (retryCount <= MAX_RETRY) {
+            try {
+                byte[] data = hexStringToByteArray(text);
+                if (data == null) {
+                    System.err.println("[" + getCurrentTime() + "] HEX杞崲澶辫触锛屾暟鎹�: " + text);
+                    return false;
                 }
-                return true;
-            } else {
-                if (DEBUG_MODE) {
-                    System.err.println("[" + getCurrentTime() + "] 鏁版嵁鍙戦�佸け璐�");
+                
+                boolean sendResult = serialService.send(data);
+                
+                if (sendResult) {
+                    if (DEBUG_MODE) {
+                        System.out.println("[" + getCurrentTime() + "] 鍙戦�佹垚鍔�: " + text.toUpperCase());
+                    }
+                    return true;
+                } else {
+                    retryCount++;
+                    if (retryCount <= MAX_RETRY) {
+                        System.err.println("[" + getCurrentTime() + "] 鍙戦�佸け璐ワ紝姝e湪閲嶈瘯 (" + retryCount + "/" + MAX_RETRY + ")");
+                        try {
+                            Thread.sleep(50); // 閲嶈瘯鍓嶇瓑寰�
+                        } catch (InterruptedException e) {
+                            Thread.currentThread().interrupt();
+                            break;
+                        }
+                    } else {
+                        System.err.println("[" + getCurrentTime() + "] 涓插彛鍙戦�佸け璐ワ紝鎸囦护: " + text.toUpperCase());
+                        System.err.println("[" + getCurrentTime() + "] 涓插彛鐘舵�� - 鎵撳紑: " + isPortOpen + ", 鏈嶅姟: " + (serialService != null));
+                        if (serialService != null) {
+                            System.err.println("[" + getCurrentTime() + "] 涓插彛鏈嶅姟鐘舵�� - 鏄惁鎵撳紑: " + serialService.isOpen());
+                        }
+                        return false;
+                    }
                 }
+            } catch (Exception e) {
+                System.err.println("[" + getCurrentTime() + "] 鍙戦�佸紓甯革紝鎸囦护: " + text.toUpperCase());
+                e.printStackTrace();
                 return false;
             }
-        } catch (Exception e) {
-            if (DEBUG_MODE) {
-                System.err.println("[" + getCurrentTime() + "] 鏁版嵁鏍煎紡閿欒: " + e.getMessage());
-            }
-            return false;
         }
+        
+        return false;
     }
     
     /**
@@ -84,7 +101,11 @@
      * @return 涓插彛鎵撳紑鐘舵��
      */
     public static boolean isPortOpen() {
-        return isPortOpen && serialService != null;
+        boolean open = isPortOpen && serialService != null;
+        if (!open && DEBUG_MODE) {
+            System.err.println("[" + getCurrentTime() + "] 涓插彛鐘舵�佹鏌�: 鏈墦寮�");
+        }
+        return open;
     }
     
     /**
@@ -100,7 +121,7 @@
         s = s.replaceAll("\\s+", ""); // 绉婚櫎绌烘牸
         int len = s.length();
         if (len % 2 != 0) {
-            throw new IllegalArgumentException("HEX瀛楃涓查暱搴﹀繀椤讳负鍋舵暟");
+            throw new IllegalArgumentException("HEX瀛楃涓查暱搴﹀繀椤讳负鍋舵暟锛屽綋鍓嶉暱搴�: " + len + ", 鏁版嵁: " + s);
         }
         
         byte[] data = new byte[len / 2];
@@ -109,7 +130,7 @@
             int low = Character.digit(s.charAt(i + 1), 16);
             
             if (high == -1 || low == -1) {
-                throw new IllegalArgumentException("鏃犳晥鐨凥EX瀛楃: " + s.charAt(i) + s.charAt(i + 1));
+                throw new IllegalArgumentException("鏃犳晥鐨凥EX瀛楃: '" + s.charAt(i) + s.charAt(i + 1) + "' 鍦ㄤ綅缃� " + i + "-" + (i+1) + ", 瀹屾暣鏁版嵁: " + s);
             }
             
             data[i / 2] = (byte) ((high << 4) + low);
@@ -144,12 +165,25 @@
     
     /**
      * 鍚敤璋冭瘯妯″紡
-     * 娉ㄦ剰锛氳繖浼氫慨鏀归潤鎬乫inal鍙橀噺锛屽疄闄呴」鐩腑涓嶅缓璁繖鏍峰仛
-     * 杩欓噷鍙槸婕旂ず锛屽疄闄呭簲璇ラ�氳繃閰嶇疆鏂囦欢鎺у埗
      */
     public static void enableDebugMode() {
-        // 鍦ㄥ疄闄呴」鐩腑锛屽簲璇ヤ娇鐢ㄥ彲閰嶇疆鐨勬柟寮忚�屼笉鏄慨鏀筬inal鍙橀噺
-        // 杩欓噷鍙槸绀烘剰锛屽疄闄呬娇鐢ㄦ椂闇�瑕侀噸鏂拌璁�
-        System.out.println("璋冭瘯妯″紡宸插惎鐢�");
+        DEBUG_MODE = true;
+        System.out.println("[" + getCurrentTime() + "] Sendmsg璋冭瘯妯″紡宸插惎鐢�");
+    }
+    
+    /**
+     * 绂佺敤璋冭瘯妯″紡
+     */
+    public static void disableDebugMode() {
+        DEBUG_MODE = false;
+        System.out.println("[" + getCurrentTime() + "] Sendmsg璋冭瘯妯″紡宸茬鐢�");
+    }
+    
+    /**
+     * 璁剧疆璋冭瘯妯″紡
+     */
+    public static void setDebugMode(boolean debug) {
+        DEBUG_MODE = debug;
+        System.out.println("[" + getCurrentTime() + "] Sendmsg璋冭瘯妯″紡: " + (debug ? "鍚敤" : "绂佺敤"));
     }
 }
\ No newline at end of file

--
Gitblit v1.9.3