fix: 重连时间设置更小

app.yaml

@@ -1,6 +1,6 @@
 id: t11
 name: t11
-version: 2.15.15
+version: 2.15.18
 author: t11
 icon: ''
 desc: t11
@@ -18,14 +18,11 @@ files:
   - laser_manager.py
   - logger_manager.py
   - main.py
-  - model_270139.cvimodel
-  - model_270139.mud
   - network.py
   - ota_curl.sh
   - ota_manager.py
   - power.py
   - server.pem
-  - set_autostart.py
   - shoot_manager.py
   - shot_id_generator.py
   - target_roi_yolo.py

at_client.py

@@ -76,6 +76,7 @@ class ATClient:
         """
         expect_b = expect.encode() if isinstance(expect, str) else expect
         with self._cmd_lock:
+            with self._q_lock:
                 # 初始化等待
                 self._waiting = True
                 self._expect = expect_b
@@ -300,8 +301,8 @@ class ATClient:
                     if len(self._rx) > 512 * 1024:
                         self._rx = self._rx[-256 * 1024:]
                 else:
-                    if len(self._rx) > 16384:
-                        self._rx = self._rx[-4096:]
+                    if len(self._rx) > 32768:
+                        self._rx = self._rx[-16384:]
 
 
 

config.py

@@ -24,7 +24,7 @@ TRIANGLE_DETECT_SCALE = 0.4
 # SERVER_IP = "stcp.shelingxingqiu.com"
 SERVER_IP = "www.shelingxingqiu.com"
 SERVER_PORT = 50005
-HEARTBEAT_INTERVAL = 15  # 心跳间隔（秒）
+HEARTBEAT_INTERVAL = 5  # 心跳间隔（秒）
 
 # WiFi 质量评估（开机先尝试 WiFi；质量差且 4G 可用则切到 4G，本次上电直至关机锁定 4G）
 WIFI_QUALITY_RTT_SAMPLES = 3  # 到业务服务器 TCP 建连耗时采样次数，取中位数
@@ -341,7 +341,7 @@ PIN_MAPPINGS = {
 }
 
 # ==================== 电源配置 ====================
-AUTO_POWER_OFF_IN_SECONDS = 0  # 自动关机时间（秒），0表示不自动关机
+AUTO_POWER_OFF_IN_SECONDS = 10 * 60  # 自动关机时间（秒），0表示不自动关机
 
 BATTERY_SOC_LPF_ALPHA = 0.5
 BATTERY_SOC_AVG_WINDOW = 5

hardware.py

@@ -29,7 +29,7 @@ class HardwareManager:
         self._adc_obj = None             # ADC对象
         self._at_client = None            # AT客户端
 
-        self._last_active_ticks = None   # 上次活跃时刻（ticks_ms，单调递增，不受校时影响）
+        self._last_active_time = 0       # 用于记录用户的最后一次活跃的时间
         self._stop_timer = False         # 用于停止定时器的标志
 
         self._initialized = True
@@ -111,7 +111,7 @@ class HardwareManager:
 
     def start_idle_timer(self):
         self._stop_timer = False
-        self._last_active_ticks = time.ticks_ms()
+        self._last_active_time = time.time()
 
     def stop_idle_timer(self):
         self._stop_timer = True
@@ -119,13 +119,12 @@ class HardwareManager:
     def get_idle_time_in_sec(self):
         if self._stop_timer:
             return 0
-        if self._last_active_ticks is None:
+        diff = time.time() - self._last_active_time
+        if diff < 0:
+            # 时间可能被重置了，重新计时
+            self._last_active_time = time.time()
             return 0
-        diff_ms = time.ticks_diff(time.ticks_ms(), self._last_active_ticks)
-        if diff_ms < 0:
-            self._last_active_ticks = time.ticks_ms()
-            return 0
-        return diff_ms / 1000.0
+        return diff
 
 
 # 创建全局单例实例

main.py

@@ -275,11 +275,6 @@ def cmd_str():
     hardware_manager.start_idle_timer()
 
     if logger:
-        _auto_power_off = int(getattr(config, "AUTO_POWER_OFF_IN_SECONDS", 0) or 0)
-        if _auto_power_off <= 0:
-            logger.info("[MAIN] 自动关机已禁用 (AUTO_POWER_OFF_IN_SECONDS=0)")
-        else:
-            logger.info(f"[MAIN] 自动关机: {_auto_power_off} 秒无活动")
         logger.info("系统准备完成...")
 
     last_adc_trigger = 0
@@ -343,10 +338,7 @@ def cmd_str():
             # 不在 OTA 状态下，检测是否空闲足够长，自动关机
             # print(f"[MAIN] 空闲时间: {hardware_manager.get_idle_time_in_sec() }秒")
             # print(f"配置关机时间：{config.AUTO_POWER_OFF_IN_SECONDS} 秒")
-            if (
-                config.AUTO_POWER_OFF_IN_SECONDS > 0
-                and hardware_manager.get_idle_time_in_sec() > config.AUTO_POWER_OFF_IN_SECONDS
-            ):
+            if hardware_manager.get_idle_time_in_sec() > config.AUTO_POWER_OFF_IN_SECONDS:
                 logger.info("[MAIN] 超过设定时间未检测活动，自动关机")
                 network_manager.safe_enqueue({"poweroff": "超过设定时间未检测活动，自动关机"}, 2)
                 time.sleep_ms(100)

network.py

@@ -624,6 +624,11 @@ class NetworkManager:
         password = inner_data.get("password")
         ota_res_url = inner_data.get("url")
         try:
+            for _f in ("/etc/wpa_supplicant.conf", "/boot/wpa_supplicant.conf", "/boot/wifi.ssid", "/boot/wifi.pass"):
+                try:
+                    os.remove(_f)
+                except OSError:
+                    pass
             w = network.wifi.Wifi()
             e = w.connect(ssid, password, wait=True, timeout=15)
             err.check_raise(e, "connect wifi failed")
@@ -665,6 +670,11 @@ class NetworkManager:
         ssid = inner_data.get("ssid")
         password = inner_data.get("password")
         try:
+            for _f in ("/etc/wpa_supplicant.conf", "/boot/wpa_supplicant.conf", "/boot/wifi.ssid", "/boot/wifi.pass"):
+                try:
+                    os.remove(_f)
+                except OSError:
+                    pass
             w = network.wifi.Wifi()
             e = w.connect(ssid, password, wait=True, timeout=15)
             err.check_raise(e, "connect wifi failed")
@@ -678,6 +688,11 @@ class NetworkManager:
                 },
                 2,
             )
+            self._session_force_4g = False
+            self.disconnect_server()
+            self._tcp_connected = False
+            self._network_type = None
+            self.logger.info("[conn wifi] WiFi已连接，等待主循环重新登录")
         except Exception as e:
             self.logger.error(f"cmd600 失败: {e}")
             self.safe_enqueue(
@@ -706,7 +721,7 @@ class NetworkManager:
             if self._network_type == "wifi":
                 return self._check_wifi_connection()
             elif self._network_type == "4g":
-                return True  # 4G连接状态由AT命令维护
+                return self._check_4g_connection()
             return False
 
         # 自动选择网络
@@ -723,6 +738,37 @@ class NetworkManager:
             return self._connect_tcp_via_4g()
         return False
 
+    def _check_4g_connection(self):
+        """检查4G TCP连接是否仍然有效（通过查询PDP地址验证网络附着状态）"""
+        try:
+            atc = hardware_manager.at_client
+            if atc is None:
+                return False
+            if not self._uart4g_lock.acquire(timeout=3000):
+                # 获取锁超时说明有其他操作在进行，视为连接仍有效
+                return True
+            try:
+                r = atc.send("AT+CGPADDR=1", "OK", 3000)
+                m = re.search(r'\+CGPADDR:\s*1,"([^"]+)"', r)
+                ip = m.group(1) if m else ""
+                if ip and ip != "0.0.0.0":
+                    return True
+                # 无IP或IP无效，尝试重新激活PDP
+                self.logger.warning("[4G-TCP] PDP地址无效，尝试重新激活")
+                atc.send("AT+MIPCALL=1,1", "OK", 15000)
+                r2 = atc.send("AT+CGPADDR=1", "OK", 3000)
+                m2 = re.search(r'\+CGPADDR:\s*1,"([^"]+)"', r2)
+                ip2 = m2.group(1) if m2 else ""
+                if ip2 and ip2 != "0.0.0.0":
+                    return True
+                self.logger.error("[4G-TCP] 重新激活PDP仍无有效IP，连接已断开")
+                return False
+            finally:
+                self._uart4g_lock.release()
+        except Exception as e:
+            self.logger.warning(f"[4G-TCP] 连接检查异常: {e}")
+            return True  # 异常时不误判断线
+
     def _wrap_wifi_tls(self, plain_sock, hostname):
         """
         在已建立的 TCP socket 上做 TLS（WiFi 走主机 ssl 库；4G 仍用模组 AT+SSL）。
@@ -1070,6 +1116,8 @@ class NetworkManager:
                     total += n
 
                 hardware_manager.uart4g.write(b"\x1A")
+                with hardware_manager.at_client._q_lock:
+                    hardware_manager.at_client._rx = b""
                 r = hardware_manager.at_client.send("", "OK", 8000)
                 if ("SEND OK" in r) or ("OK" in r) or ("+MIPSEND" in r):
                     return True
@@ -1784,7 +1832,7 @@ class NetworkManager:
                     continue
 
                 if not self.connect_server():
-                    time.sleep_ms(5000)
+                    time.sleep_ms(1000)
                     continue
 
                 # 发送登录包
@@ -1805,7 +1853,7 @@ class NetworkManager:
                         self.disconnect_server()
                     except:
                         pass
-                    time.sleep_ms(2000)
+                    time.sleep_ms(500)
                     continue
 
                 self.logger.info("➡️ 登录包已发送，等待确认...")
@@ -2294,8 +2342,8 @@ class NetworkManager:
                                     pass
                                 break
                             else:
-                                # 不立即断开，让下一轮心跳再试；同时缩短一点等待，提升恢复速度
-                                time.sleep_ms(200)
+                                # 不立即断开，让下一轮心跳再试
+                                time.sleep_ms(50)
                                 continue
                         else:
                             send_hartbeat_fail_count = 0
@@ -2325,8 +2373,8 @@ class NetworkManager:
                     self._send_event.clear()
 
                 self._tcp_connected = False
-                self.logger.error("连接异常，2秒后重连...")
-                time.sleep_ms(200)
+                self.logger.error("连接异常，50ms后重连...")
+                time.sleep_ms(50)
 
             except Exception as e:
                 # TCP主循环的顶层异常捕获，防止线程静默退出

version.md

@@ -26,4 +26,6 @@
 # 2.15.13 优化算法
 # 2.15.14 优化算法
 # 2.15.15 优化wifi连接
-# 2.15.16 修复不关机，空闲计时改用 ticks_ms（不受校时影响），启动时打印自动关机配置
+# 2.15.16 修复wifi连接问题
+# 2.15.17 修复wifi连接问题
+# 2.15.18 wifi连接成功重新登录

version.py

@@ -4,6 +4,6 @@
 应用版本号
 每次 OTA 更新时，只需要更新这个文件中的版本号
 """
-VERSION = '2.15.16'
+VERSION = '2.15.18'