feat: 压力传感触发判断

.gitignore

@@ -1,3 +1,4 @@
 /cpp_ext/build/
 /.cursor/
 /dist/
+.idea

app.yaml

@@ -1,6 +1,6 @@
 id: t11
 name: t11
-version: 2.15.18
+version: 2.16.1
 author: t11
 icon: ''
 desc: t11

main.py

@@ -122,7 +122,7 @@ def cmd_str():
 
     # 1. 初始化日志系统
     import logging
-    logger_manager.init_logging(log_level=logging.DEBUG)
+    logger_manager.init_logging(log_level=logging.WARNING)
     logger = logger_manager.logger
 
     # 充电关机独立读取 INA226，不依赖 TCP 连接或心跳流程。
@@ -290,37 +290,35 @@ def cmd_str():
 
     pressure_buf = []
     pressure_sum = 0
-    pressure_abs_sum = 0
     pressure_min = 4095
     pressure_max = 0
     pressure_t0_ms = None
-    last_avg_abs = 0
+
+    # 压力突变检测（上升沿触发）
+    prev_adc_val = 0            # 上一次ADC值
+    ADC_JUMP_THRESHOLD = 250    # 突变阈值：相邻两次采样差值超过此值视为突变
 
     def _flush_pressure_buf(reason: str):
-        nonlocal pressure_buf, pressure_sum, pressure_min, pressure_max, pressure_t0_ms, logger, pressure_abs_sum, last_avg_abs
+        nonlocal pressure_buf, pressure_sum, pressure_min, pressure_max, pressure_t0_ms, logger
         if not pressure_buf:
             return
         if config.AIR_PRESSURE_lOG:
             t1_ms = time.ticks_ms()
             n = len(pressure_buf)
             avg = (pressure_sum / n) if n else 0
-            avg_abs = (pressure_abs_sum / n) if n else 0
             line = (
                 f"[气压批量] reason={reason} "
                 f"t0={pressure_t0_ms} t1={t1_ms} n={n} "
-                f"min={pressure_min} max={pressure_max} avg={avg:.1f} avg_abs={avg_abs:.3f} "
+                f"min={pressure_min} max={pressure_max} avg={avg:.1f} "
                 f"values={','.join(map(str, pressure_buf))}"
-                f" convert value (kpa): {(max(pressure_buf, key=lambda x: x[1])[1] - last_avg_abs) / (5 - 2.5) * config.AIR_PRESSURE_HARDWARE_MAX:.1f}"
             )
             if logger:
                 logger.debug(line)
             else:
                 print(line)
-            last_avg_abs = avg_abs
         # 无论是否记录日志，都必须清空 buffer，否则内存泄漏
         pressure_buf = []
         pressure_sum = 0
-        pressure_abs_sum = 0
         pressure_min = 4095
         pressure_max = 0
         pressure_t0_ms = None
@@ -342,6 +340,7 @@ def cmd_str():
                 time.sleep_ms(250)
                 continue
 
+            # todo 去除或者不在这里检测
             # 不在 OTA 状态下，检测是否空闲足够长，自动关机
             # print(f"[MAIN] 空闲时间: {hardware_manager.get_idle_time_in_sec() }秒")
             # print(f"配置关机时间：{config.AUTO_POWER_OFF_IN_SECONDS} 秒")
@@ -358,12 +357,10 @@ def cmd_str():
                 if network_manager.manual_trigger_flag:
                     network_manager.clear_manual_trigger()
                     adc_val = config.ADC_TRIGGER_THRESHOLD + 1
-                    adc_abs_val = 10
                     if logger:
                         logger.info("[TEST] TCP命令触发射箭")
                 else:
                     adc_val = hardware_manager.adc_obj.read()
-                    adc_abs_val = hardware_manager.adc_obj.read_vol()
             except Exception as e:
                 logger = logger_manager.logger
                 if logger:
@@ -374,27 +371,35 @@ def cmd_str():
             # ====== 气压采样缓存（每次循环都记录，批量输出日志）======
             if pressure_t0_ms is None:
                 pressure_t0_ms = current_time
-            pressure_buf.append((adc_val, adc_abs_val))
+            pressure_buf.append(adc_val)
             pressure_sum += adc_val
-            pressure_abs_sum += adc_abs_val
             if adc_val < pressure_min:
                 pressure_min = adc_val
             if adc_val > pressure_max:
                 pressure_max = adc_val
             if len(pressure_buf) >= PRESSURE_BATCH_SIZE:
                 _flush_pressure_buf("batch")
-            # if adc_val >= 2000:
+
-            # print(f"adc :{adc_val}")
+            # 压力突变检测：当前值与前一次值的差值超过阈值时触发
-            if adc_val >= config.ADC_TRIGGER_THRESHOLD:
+            adc_diff = adc_val - prev_adc_val
+            if adc_diff >= ADC_JUMP_THRESHOLD and prev_adc_val > 0 :
                 hardware_manager.start_idle_timer()  # 重新计时
                 diff_ms = current_time - last_adc_trigger
                 if diff_ms < 3000:
                     logger.info(f"[MAIN] 扳机触发过于频繁, {diff_ms}ms")
+                    prev_adc_val = adc_val
                     continue
                 last_adc_trigger = current_time
-                # 触发前先把缓存刷出来，避免波形被长耗时处理截断
+                # 触发前先把缓存刷出来
                 _flush_pressure_buf("before_trigger")
 
+                if logger:
+                    logger.info(
+                        f"[TRIGGER] ▲ 压力突变触发! "
+                        f"adc={adc_val}, prev={prev_adc_val}, "
+                        f"diff=+{adc_diff}, t={current_time}ms"
+                    )
+
                 try:
                     process_shot(adc_val)
                 except Exception as e:
@@ -403,9 +408,11 @@ def cmd_str():
                         logger.error(f"[MAIN] 图像处理异常: {e}")
                         import traceback
                         logger.error(traceback.format_exc())
-                    time.sleep_ms(100)
+
-                    continue
+            prev_adc_val = adc_val
-            else:
+
+            # 未触发时的显示逻辑
+            # 未触发时的显示逻辑
             if config.SHOW_CAMERA_PHOTO_WHILE_SHOOTING:
                 try:
                     camera_manager.show(camera_manager.read_frame())
@@ -413,7 +420,7 @@ def cmd_str():
                     logger = logger_manager.logger
                     if logger:
                         logger.error(f"[MAIN] 显示异常: {e}")
-                time.sleep_ms(5)
+            time.sleep_ms(1)
 
         except Exception as e:
             # 主循环的顶层异常捕获，防止程序静默退出

shoot_manager.py

@@ -320,8 +320,8 @@ def process_shot(adc_val):
     logger = logger_manager.logger
 
     try:
-        network_manager.safe_enqueue({"shoot_event": "start"}, msg_type=2, high=True)
         frame = camera_manager.read_frame()
+        network_manager.safe_enqueue({"shoot_event": "start"}, msg_type=2, high=True)
 
         # 调用算法分析
         analysis_result = analyze_shot(frame)

version.md

@@ -36,3 +36,4 @@
 # 2.15.24 空改测试
 # 2.15.25 修复整合后关机失败和ota格式更新问题
 # 2.15.26 
+# 2.16.1  修复压力传感触发判断按照增量

version.py

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

vision.py

@@ -631,7 +631,7 @@ def detect_circle_v3(frame, laser_point=None, img_cv=None):
             min_r = min(rc["radius"], yellow_radius)
             max_r = max(rc["radius"], yellow_radius)
             size_ratio = min_r / max_r if max_r > 0 else 0
-            if dist_centers < max_dist and size_ratio > 0.5:
+            if dist_centers < max_dist and size_ratio >= 0.3:
                 if logger:
                     logger.info(f"[target] -> 找到匹配的红圈: 黄心({yellow_center}), "
                                 f"红心({rc['center']}), 距离:{dist_centers:.1f}, "