❌ 手机端客户端文件未找到
+请确保 mobile/mobile_client.html 文件存在
+或者直接访问该文件的完整路径
+ + + """, 404 + + def serve_gps_test(self): + """提供GPS测试页面""" + try: + with open('mobile/gps_test.html', 'r', encoding='utf-8') as f: + return f.read() + except FileNotFoundError: + return """ + +❌ GPS测试页面未找到
+请确保 mobile/gps_test.html 文件存在
+ + + """, 404 + + def serve_permission_guide(self): + """提供权限设置指南页面""" + try: + with open('mobile/permission_guide.html', 'r', encoding='utf-8') as f: + return f.read() + except FileNotFoundError: + return """ + +❌ 权限指南页面未找到
+请确保 mobile/permission_guide.html 文件存在
+ + + """, 404 + + def serve_baidu_browser_test(self): + """提供百度浏览器测试页面""" + try: + with open('mobile/baidu_browser_test.html', 'r', encoding='utf-8') as f: + return f.read() + except FileNotFoundError: + return """ + +❌ 百度浏览器测试页面未找到
+请确保 mobile/baidu_browser_test.html 文件存在
+ 返回移动客户端 + + + """, 404 + + def serve_camera_permission_test(self): + """提供摄像头权限测试页面""" + try: + with open('mobile/camera_permission_test.html', 'r', encoding='utf-8') as f: + return f.read() + except FileNotFoundError: + return """ + +❌ 摄像头权限测试页面未找到
+请确保 mobile/camera_permission_test.html 文件存在
+ 返回移动客户端 + + + """, 404 + + def serve_browser_compatibility_guide(self): + """提供浏览器兼容性指南页面""" + try: + with open('mobile/browser_compatibility_guide.html', 'r', encoding='utf-8') as f: + return f.read() + except FileNotFoundError: + return """ + +❌ 浏览器兼容性指南页面未找到
+请确保 mobile/browser_compatibility_guide.html 文件存在
+ 返回移动客户端 + + + """, 404 + + def serve_legacy_browser_help(self): + """提供旧版浏览器帮助页面""" + try: + with open('mobile/legacy_browser_help.html', 'r', encoding='utf-8') as f: + return f.read() + except FileNotFoundError: + return """ + +❌ 旧版浏览器帮助页面未找到
+请确保 mobile/legacy_browser_help.html 文件存在
+ 返回移动客户端 + + + """, 404 + + def serve_harmonyos_camera_fix(self): + """提供鸿蒙系统摄像头修复页面""" + try: + with open('mobile/harmonyos_camera_fix.html', 'r', encoding='utf-8') as f: + return f.read() + except FileNotFoundError: + return """ + +❌ 鸿蒙系统摄像头修复页面未找到
+请确保 mobile/harmonyos_camera_fix.html 文件存在
+ 返回移动客户端 + + + """, 404 + + def start_camera_detection(self): + """启动摄像头检测""" + if self.camera_active: + print("⚠️ 摄像头已在运行中") + return + + try: + print("=" * 60) + print(f"🔍 开始摄像头检测初始化...") + print(f"🔍 当前时间: {time.strftime('%Y-%m-%d %H:%M:%S')}") + print(f"🔍 配置的摄像头索引: {config.CAMERA_INDEX}") + print(f"🔍 当前camera_active状态: {self.camera_active}") + + # 检查OpenCV是否正常 + print(f"🔍 OpenCV版本: {cv2.__version__}") + + # 检查系统摄像头 + print("🔍 检查系统可用摄像头...") + available_cameras = [] + for i in range(10): + test_cap = cv2.VideoCapture(i) + if test_cap.isOpened(): + available_cameras.append(i) + test_cap.release() + print(f" ✅ 找到摄像头索引: {i}") + else: + test_cap.release() + + if not available_cameras: + raise Exception("系统中没有找到任何可用的摄像头设备") + + print(f"🔍 可用摄像头索引: {available_cameras}") + + # 初始化摄像头 + print(f"🔍 正在尝试打开摄像头索引: {config.CAMERA_INDEX}") + self.cap = cv2.VideoCapture(config.CAMERA_INDEX) + print(f"🔍 VideoCapture对象创建完成: {self.cap}") + print(f"🔍 cap.isOpened(): {self.cap.isOpened()}") + + # 等待摄像头初始化 + time.sleep(1) + + if not self.cap.isOpened(): + print(f"❌ 初始摄像头索引 {config.CAMERA_INDEX} 打开失败") + # 尝试其他摄像头索引 + success = False + for i in available_cameras: + print(f"🔍 尝试备用摄像头索引: {i}") + if self.cap: + self.cap.release() + self.cap = cv2.VideoCapture(i) + time.sleep(0.8) # 增加等待时间 + print(f"🔍 索引 {i} isOpened(): {self.cap.isOpened()}") + if self.cap.isOpened(): + print(f"✅ 成功打开备用摄像头索引: {i}") + success = True + break + else: + print(f"❌ 索引 {i} 打开失败") + self.cap.release() + + if not success: + raise Exception(f"无法打开任何摄像头，尝试了索引: {available_cameras}") + else: + print(f"✅ 初始摄像头索引 {config.CAMERA_INDEX} 打开成功") + + # 设置摄像头参数 + print(f"📐 设置摄像头参数: {config.FRAME_WIDTH}x{config.FRAME_HEIGHT}@{config.FPS}fps") + self.cap.set(cv2.CAP_PROP_FRAME_WIDTH, config.FRAME_WIDTH) + self.cap.set(cv2.CAP_PROP_FRAME_HEIGHT, config.FRAME_HEIGHT) + self.cap.set(cv2.CAP_PROP_FPS, config.FPS) + + # 测试读取一帧 + print("🔍 测试摄像头帧读取...") + for attempt in range(3): + ret, test_frame = self.cap.read() + print(f"🔍 读取尝试 {attempt + 1}: ret={ret}, frame={'有效' if test_frame is not None else '无效'}") + if ret and test_frame is not None: + print(f"✅ 摄像头测试成功，实际分辨率: {test_frame.shape[1]}x{test_frame.shape[0]}") + break + time.sleep(0.5) + else: + raise Exception("摄像头无法读取图像帧，连续3次尝试都失败") + + # 初始化检测器 + print("🤖 初始化YOLO检测器...") + try: + self.detector = PersonDetector() + print("✅ PersonDetector初始化完成") + self.distance_calculator = DistanceCalculator() + print("✅ DistanceCalculator初始化完成") + except Exception as e: + print(f"❌ 检测器初始化失败: {e}") + raise e + + # 启动检测线程 + print("🔍 设置camera_active = True") + self.camera_active = True + print(f"🔍 当前camera_active状态: {self.camera_active}") + + print("🔍 创建摄像头检测线程...") + self.camera_thread = threading.Thread(target=self.camera_detection_loop, name="CameraDetectionThread") + self.camera_thread.daemon = True + + print("🔍 启动摄像头检测线程...") + self.camera_thread.start() + print(f"🔍 线程是否存活: {self.camera_thread.is_alive()}") + + # 等待线程启动 + time.sleep(1) + print(f"🔍 启动后camera_active状态: {self.camera_active}") + print(f"🔍 线程启动后状态: {self.camera_thread.is_alive()}") + + print("🎯 摄像头检测线程启动完成") + print("=" * 60) + + except Exception as e: + self.camera_active = False + if hasattr(self, 'cap') and self.cap: + self.cap.release() + print(f"❌ 摄像头启动失败: {e}") + raise e + + def stop_camera_detection(self): + """停止摄像头检测""" + self.camera_active = False + if self.camera_thread: + self.camera_thread.join(timeout=2) + if self.cap: + self.cap.release() + self.current_frame = None + self.detection_data = [] + self.map_manager.clear_persons() + print("📷 摄像头检测已停止") + + def camera_detection_loop(self): + """摄像头检测循环""" + fps_counter = 0 + fps_time = time.time() + current_fps = 0 + frame_count = 0 + + print("=" * 50) + print("🔍 摄像头检测循环已启动") + print(f"🔍 线程名称: {threading.current_thread().name}") + print(f"🔍 启动时camera_active: {self.camera_active}") + print(f"🔍 启动时cap对象: {self.cap}") + print(f"🔍 启动时cap.isOpened(): {self.cap.isOpened() if self.cap else 'cap为None'}") + print("=" * 50) + + while self.camera_active and self.cap: + try: + # 详细的读帧调试 + if frame_count % 100 == 0: # 每100帧输出一次详细状态 + print(f"🔍 循环状态检查 - 帧{frame_count}: camera_active={self.camera_active}, cap={self.cap is not None}") + + ret, frame = self.cap.read() + if not ret or frame is None: + print(f"❌ 无法读取摄像头画面 - 帧{frame_count}: ret={ret}, frame={'有效' if frame is not None else '无效'}") + print(f"🔍 当前cap状态: {self.cap}") + print(f"🔍 cap.isOpened(): {self.cap.isOpened() if self.cap else 'cap为None'}") + break + + frame_count += 1 + + # 检测人体 + try: + detections = self.detector.detect_persons(frame) + except Exception as detect_error: + print(f"❌ 人体检测错误 - 帧{frame_count}: {detect_error}") + detections = [] + + # 添加调试输出 (每30帧输出一次状态，避免刷屏) + if frame_count % 30 == 0 or len(detections) > 0: + print(f"📹 帧 {frame_count}: 检测到 {len(detections)} 个人 (FPS: {current_fps})") + if len(detections) > 0: + print(f"🎯 检测详情: {[f'person_{i}_{det[4]:.2f}' for i, det in enumerate(detections)]}") + + # 计算距离并更新地图位置 + self.map_manager.clear_persons() + distances = [] + + for i, detection in enumerate(detections): + bbox = detection[:4] # [x1, y1, x2, y2] + x1, y1, x2, y2 = bbox + distance = self.distance_calculator.get_distance(bbox) + distance_str = self.distance_calculator.format_distance(distance) + distances.append(distance_str) + + # 计算人体中心点 + center_x = (x1 + x2) / 2 + center_y = (y1 + y2) / 2 + + # 将距离从厘米转换为米 + distance_meters = distance / 100.0 + + # 🎯 使用精确的GPS坐标计算 - 固定摄像头 + frame_height, frame_width = frame.shape[:2] + lat, lng = self.distance_calculator.calculate_person_gps_position( + camera_lat=config.CAMERA_LATITUDE, + camera_lng=config.CAMERA_LONGITUDE, + camera_heading=config.CAMERA_HEADING, + bbox=bbox, + distance_meters=distance_meters, + frame_width=frame_width, + frame_height=frame_height, + camera_fov=config.CAMERA_FOV + ) + + # 🔍 检查人员是否在摄像头视野范围内 + in_fov = self.distance_calculator.is_person_in_camera_fov( + camera_lat=config.CAMERA_LATITUDE, + camera_lng=config.CAMERA_LONGITUDE, + camera_heading=config.CAMERA_HEADING, + person_lat=lat, + person_lng=lng, + camera_fov=config.CAMERA_FOV, + max_distance=100 # 最大检测距离100米 + ) + + if in_fov: + # 添加到地图 + self.map_manager.add_person_at_coordinates( + lat, lng, f"P{i+1}", distance_meters, "fixed_camera" + ) + + if len(detections) > 0: # 只在有检测时输出详细信息 + if in_fov: + print(f"📍 人员 {i+1}: 像素位置({center_x:.1f}, {center_y:.1f}), 距离{distance_meters:.1f}m, 坐标({lat:.6f}, {lng:.6f}) ✅视野内") + else: + print(f"⚠️ 人员 {i+1}: 像素位置({center_x:.1f}, {center_y:.1f}), 距离{distance_meters:.1f}m, 坐标({lat:.6f}, {lng:.6f}) ❌超出视野") + + # 绘制检测结果（完整的检测框、距离、置信度） + frame = self.detector.draw_detections(frame, detections, distances) + + # 计算FPS + fps_counter += 1 + current_time = time.time() + if current_time - fps_time >= 1.0: + current_fps = fps_counter + fps_counter = 0 + fps_time = current_time + + # 添加完整的信息面板 - 带FPS信息 + frame = self.draw_backend_info_panel(frame, len(detections), current_fps) + + # 保存当前帧 + try: + self.current_frame = frame.copy() + self.detection_data = detections + + # 每100帧验证一次帧保存 + if frame_count % 100 == 0: + print(f"🔍 帧保存状态 - 帧{frame_count}: current_frame={'已保存' if self.current_frame is not None else '保存失败'}") + + except Exception as save_error: + print(f"❌ 帧保存错误 - 帧{frame_count}: {save_error}") + + # 控制帧率 + time.sleep(1/30) # 30 FPS + + except Exception as e: + print(f"❌ 检测循环错误 - 帧{frame_count}: {e}") + import traceback + traceback.print_exc() + break + + print(f"🛑 摄像头检测循环已结束 - 总处理帧数: {frame_count}") + print(f"🔍 结束时camera_active: {self.camera_active}") + print(f"🔍 结束时cap状态: {self.cap}") + print("=" * 50) + + def generate_main_page(self): + """生成主页面HTML""" + html_template = f""" + + + +
+
+
+ 🚁 系统控制台
+
+
+
+
+
+
+
+
+
+
+
+
+ 📍 摄像头位置:
+ {config.CAMERA_LATITUDE:.4f}, {config.CAMERA_LONGITUDE:.4f}
+
+
+ 🧭 朝向角度:
+ {config.CAMERA_HEADING}°
+
+
+ 📷 摄像头状态:
+ 离线
+
+
+ 👥 检测人数:
+ 0
+
+
+
+
+ 📹 实时视频监控
+
+
+
+ 等待视频流...
+
+
+
+
+ 💻固定指挥中心
+
+
+ 🚁移动无人机
+
+
+ 🔶无人机视野
+
+
+ 🧑🌾检测目标
+
+
+
+
+
+
+
+
+
+
+
+
+"""
+ return html_template
+
+ def run(self, host='127.0.0.1', port=5000, debug=False, ssl_enabled=True):
+ """启动Web服务器"""
+ print("🌐 启动Web服务器...")
+
+ ssl_context = None
+ protocol = "http"
+
+ if ssl_enabled:
+ import os
+ cert_file = "ssl/cert.pem"
+ key_file = "ssl/key.pem"
+
+ if os.path.exists(cert_file) and os.path.exists(key_file):
+ ssl_context = (cert_file, key_file)
+ protocol = "https"
+ print("🔒 HTTPS模式已启用")
+ else:
+ print("⚠️ SSL证书文件不存在，正在生成...")
+ self.generate_ssl_certificate()
+ if os.path.exists(cert_file) and os.path.exists(key_file):
+ ssl_context = (cert_file, key_file)
+ protocol = "https"
+ print("🔒 HTTPS模式已启用")
+ else:
+ print("❌ SSL证书生成失败，使用HTTP模式")
+ ssl_enabled = False
+
+ print(f"📍 访问地址: {protocol}://{host}:{port}")
+ if ssl_enabled:
+ print("🔑 注意: 自签名证书会显示安全警告，点击'高级'->'继续访问'即可")
+ print("🚁 无人机战场态势感知系统已就绪")
+
+ try:
+ self.app.run(host=host, port=port, debug=debug, threaded=True, ssl_context=ssl_context)
+ except KeyboardInterrupt:
+ print("\n🔴 服务器已停止")
+ self.stop_camera_detection()
+ self.stop_camera_detection()
+
+ def generate_ssl_certificate(self):
+ """生成自签名SSL证书"""
+ try:
+ import os
+ import datetime
+ import ipaddress
+ from cryptography import x509
+ from cryptography.x509.oid import NameOID
+ from cryptography.hazmat.primitives import hashes, serialization
+ from cryptography.hazmat.primitives.asymmetric import rsa
+
+ # 创建ssl目录
+ ssl_dir = "ssl"
+ if not os.path.exists(ssl_dir):
+ os.makedirs(ssl_dir)
+
+ print("🔑 正在生成SSL证书...")
+
+ # 生成私钥
+ private_key = rsa.generate_private_key(
+ public_exponent=65537,
+ key_size=2048,
+ )
+
+ # 创建证书主体
+ subject = issuer = x509.Name([
+ x509.NameAttribute(NameOID.COUNTRY_NAME, "CN"),
+ x509.NameAttribute(NameOID.STATE_OR_PROVINCE_NAME, "Beijing"),
+ x509.NameAttribute(NameOID.LOCALITY_NAME, "Beijing"),
+ x509.NameAttribute(NameOID.ORGANIZATION_NAME, "Distance Judgement System"),
+ x509.NameAttribute(NameOID.COMMON_NAME, "localhost"),
+ ])
+
+ # 生成证书
+ cert = x509.CertificateBuilder().subject_name(
+ subject
+ ).issuer_name(
+ issuer
+ ).public_key(
+ private_key.public_key()
+ ).serial_number(
+ x509.random_serial_number()
+ ).not_valid_before(
+ datetime.datetime.utcnow()
+ ).not_valid_after(
+ datetime.datetime.utcnow() + datetime.timedelta(days=365)
+ ).add_extension(
+ x509.SubjectAlternativeName([
+ x509.DNSName("localhost"),
+ x509.DNSName("127.0.0.1"),
+ x509.IPAddress(ipaddress.IPv4Address("127.0.0.1")),
+ ]),
+ critical=False,
+ ).sign(private_key, hashes.SHA256())
+
+ # 保存私钥
+ key_path = os.path.join(ssl_dir, "key.pem")
+ with open(key_path, "wb") as f:
+ f.write(private_key.private_bytes(
+ encoding=serialization.Encoding.PEM,
+ format=serialization.PrivateFormat.PKCS8,
+ encryption_algorithm=serialization.NoEncryption()
+ ))
+
+ # 保存证书
+ cert_path = os.path.join(ssl_dir, "cert.pem")
+ with open(cert_path, "wb") as f:
+ f.write(cert.public_bytes(serialization.Encoding.PEM))
+
+ print(f"✅ SSL证书已生成:")
+ print(f" 🔑 私钥: {key_path}")
+ print(f" 📜 证书: {cert_path}")
+ print(f" 📅 有效期: 365天")
+
+ except ImportError:
+ print("❌ 缺少cryptography库，请先安装: pip install cryptography")
+ except Exception as e:
+ print(f"❌ 生成SSL证书失败: {e}")
diff --git a/distance-judgement/ssl/cert.pem b/distance-judgement/ssl/cert.pem
new file mode 100644
index 00000000..903d0bf8
--- /dev/null
+++ b/distance-judgement/ssl/cert.pem
@@ -0,0 +1,21 @@
+-----BEGIN CERTIFICATE-----
+MIIDiTCCAnGgAwIBAgIUD45qB5JkkfGfRqN8cZTJ1Q2TE14wDQYJKoZIhvcNAQEL
+BQAwaTELMAkGA1UEBhMCQ04xEDAOBgNVBAgMB0JlaWppbmcxEDAOBgNVBAcMB0Jl
+aWppbmcxIjAgBgNVBAoMGURpc3RhbmNlIEp1ZGdlbWVudCBTeXN0ZW0xEjAQBgNV
+BAMMCWxvY2FsaG9zdDAeFw0yNTA2MjkwODQ2MTRaFw0yNjA2MjkwODQ2MTRaMGkx
+CzAJBgNVBAYTAkNOMRAwDgYDVQQIDAdCZWlqaW5nMRAwDgYDVQQHDAdCZWlqaW5n
+MSIwIAYDVQQKDBlEaXN0YW5jZSBKdWRnZW1lbnQgU3lzdGVtMRIwEAYDVQQDDAls
+b2NhbGhvc3QwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQC3u/JfTd1P
+/62wGwE0vAEOOPh0Zxn+lCssp0K9axWTfrvp0oWErcyGCVp+E+QjFOPyf0ocw7BX
+31O5UoJtOCYHACutXvp+Vd2YFxptXYU+CN/qj4MF+n28U7AwUiWPqSOy9/IMcdOl
+IfDKkSHCLWmUtNC8ot5eG/mYxqDVLZfI3Carclw/hwIYBa18YnaYG0xYM+G13Xpp
+yP5itRXLGS8I4GpTCoYFlPq0n+rW81sWNQjw3RmK4t1dF2AWhuDc5nYvRZdf4Qhk
+ovwW9n48fRaTfsUDylTVZ9RgmSo3KRWmw8DDCo4rlTtOS4x7fd1l6m1JPgPWg9bX
+9Qbz17wGGoUdAgMBAAGjKTAnMCUGA1UdEQQeMByCCWxvY2FsaG9zdIIJMTI3LjAu
+MC4xhwR/AAABMA0GCSqGSIb3DQEBCwUAA4IBAQBEneYvDdzdvv65rHUA9UKJzBGs
+4+j5ZYhCTl0E1HCVxWVHtheUmpUUTlXd0q40NayD0fqt+Cak+0gxKoh8vj1jceKU
+EO2OSMx7GIEETF1DU2mvaEHvlgLC5YC72DzirGrM+e4VXIIf7suvmcvAw42IGMtw
+xzEZANYeVY87LYVtJQ0Uw11j2C3dKdQJpEFhldWYwlaLYU6jhtkkiybAa7ZAI1AQ
+mL+02Y+IQ2sNOuVL7ltqoo0b5BmD4MXjn0wjcy/ARNlq7LxQcvm9UKQCFWtgPGNh
+qP8BBUq2pbJJFoxgjQYqAAL7tbdimWElBXwiOEESAjjIC8l/YG4s8QKWhGcq
+-----END CERTIFICATE-----
diff --git a/distance-judgement/ssl/key.pem b/distance-judgement/ssl/key.pem
new file mode 100644
index 00000000..930da7c3
--- /dev/null
+++ b/distance-judgement/ssl/key.pem
@@ -0,0 +1,28 @@
+-----BEGIN PRIVATE KEY-----
+MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQC3u/JfTd1P/62w
+GwE0vAEOOPh0Zxn+lCssp0K9axWTfrvp0oWErcyGCVp+E+QjFOPyf0ocw7BX31O5
+UoJtOCYHACutXvp+Vd2YFxptXYU+CN/qj4MF+n28U7AwUiWPqSOy9/IMcdOlIfDK
+kSHCLWmUtNC8ot5eG/mYxqDVLZfI3Carclw/hwIYBa18YnaYG0xYM+G13XppyP5i
+tRXLGS8I4GpTCoYFlPq0n+rW81sWNQjw3RmK4t1dF2AWhuDc5nYvRZdf4QhkovwW
+9n48fRaTfsUDylTVZ9RgmSo3KRWmw8DDCo4rlTtOS4x7fd1l6m1JPgPWg9bX9Qbz
+17wGGoUdAgMBAAECggEAAJVp+AexNkHRez5xCFrg2XQp+yW7ifWRiM4RbN0xPs0Y
+ZJ1BgcwnOTIX7+Q5LdrS2CBitB7zixzCG1qgj2K7nhYg0MJo+pynepOmvNBAyrUa
+dP1fCF0eXevqc37zGM5w+lpg6aTxw5ByOJtaNOqfikN4QLNBU6GSwA/Hkm8NP56J
+ZtVBfGE/inq4pyoFxLBwfGgYn9sRoo4AgPaUYiCFL7s4CXpkrFAg86sxkt0ak6pa
+9Hj9nVIcYdhNlEfvO53pnmU3KeXEGUVaE5CtxATEuYfTqNfb2+CBAUAkd1JTzC6P
+YLZC1WnrajC9LbblDgWvKQ2ItuNxPcCQOEgQl0IVRwKBgQDf74VeEaCAzQwY48q8
+/RiuJfCc/C7zAHNk4LuYalWSRFaMfciJSfWHNi2UhTuTYiYdg7rSfdrwLOJg/gz0
+c/H9k5SPwObFP0iXSY7FRsfviA5BJIe5xHyMNs0upiO9bmPA0X948esk4dCaUwWz
+TleMHlFSf7gk5sOsL7utYPqF0wKBgQDSCtHnXEaVCzoSrpuw9sEZnNIAqqfPOmfg
+OYwjz2yp89X4i/N1Lp15oe2vyfGNF4TzRl5kcGwv534om3PjMF9j4ANgy7BCdAx2
+5YXtoCull8lFd5ansBKM6BYtN/YWABTywxkFxMrR+f7gg7L8ywopGomyyyGc/hX6
+4UWaRQdDTwKBgAzt/31W9zV4oWIuhN40nuAvQJ1P0kYlmIQSlcJPIXG4kGa8PH/w
+zURpVGhm6PGxkRHTMU5GBgYoEUoYYRccOrSxeLp0IN7ysHZLwPqTA6hI6snIGi4X
+sjlGUMKIxTeC0C+p6PpKvZD7mNfQQ1v/Af8NIRTqWu+Gg3XFq8hu+QgRAoGBAMYh
++MFTFS2xKnXHCgyTp7G+cYa5dJSRlr0368838lwbLGNJuT133IqJSkpBp78dSYem
+gJIkTpmduC8b/OR5k/IFtYoQelMlX0Ck4II4ThPlq7IAzjeeatFKeOjs2hEEwL4D
+dc4wRdZvCZPGCAhYi1wcsXncDfgm4psG934/0UsXAoGAf1mWndfCOtj3/JqjcAKz
+cCpfdwgFnTt0U3SNZ5FMXZ4oCRXcDiKN7VMJg6ZtxCxLgAXN92eF/GdMotIFd0ou
+6xXLJzIp0XPc1uh5+VPOEjpqtl/ByURge0sshzce53mrhx6ixgAb2qWBJH/cNmIK
+VKGQWzXu+zbojPTSWzJltA0=
+-----END PRIVATE KEY-----
diff --git a/distance-judgement/test_device_selector.html b/distance-judgement/test_device_selector.html
new file mode 100644
index 00000000..0e7e4a6f
--- /dev/null
+++ b/distance-judgement/test_device_selector.html
@@ -0,0 +1,392 @@
+
+
+
+
+
+
+
+
+ 📷 选择视频设备
+ + +
+
+
+
+ 📱 本地设备
+
+
+ 正在扫描本地设备...
+
+
+
+
+ 🌐 远程设备
+
+
+ 暂无远程设备连接
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/distance-judgement/test_network.py b/distance-judgement/test_network.py
new file mode 100644
index 00000000..755a9466
--- /dev/null
+++ b/distance-judgement/test_network.py
@@ -0,0 +1,134 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+"""
+网络连接测试脚本
+帮助诊断手机/平板连接问题
+"""
+
+import socket
+import subprocess
+import sys
+import threading
+import time
+from http.server import HTTPServer, SimpleHTTPRequestHandler
+
+def get_local_ip():
+ """获取本机IP地址"""
+ try:
+ # 方法1: 连接到远程地址获取本地IP
+ s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+ s.connect(("8.8.8.8", 80))
+ ip = s.getsockname()[0]
+ s.close()
+ return ip
+ except:
+ try:
+ # 方法2: 获取主机名对应的IP
+ hostname = socket.gethostname()
+ ip = socket.gethostbyname(hostname)
+ if ip.startswith("127."):
+ return None
+ return ip
+ except:
+ return None
+
+def test_port(host, port):
+ """测试端口是否可访问"""
+ try:
+ sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+ sock.settimeout(5)
+ result = sock.connect_ex((host, port))
+ sock.close()
+ return result == 0
+ except:
+ return False
+
+def start_test_server(port=8888):
+ """启动测试HTTP服务器"""
+ class TestHandler(SimpleHTTPRequestHandler):
+ def do_GET(self):
+ self.send_response(200)
+ self.send_header('Content-type', 'text/html; charset=utf-8')
+ self.end_headers()
+ html = """
+ 🧪 设备选择器测试
+ +
+
+
+
+
+
+
+ 📹 视频设备
+
+
+
+ 点击"选择设备"开始使用摄像头
+
+
+
+ 系统初始化中...
+ ✅ 网络连接测试成功!
+如果您能看到这个页面，说明网络连接正常。
+测试时间: %s
+您的IP: %s
+ + + """ % (time.strftime('%Y-%m-%d %H:%M:%S'), self.client_address[0]) + self.wfile.write(html.encode('utf-8')) + + def log_message(self, format, *args): + print(f"📱 测试访问: {self.client_address[0]} - {format % args}") + + try: + server = HTTPServer(('0.0.0.0', port), TestHandler) + print(f"🧪 测试服务器已启动，端口: {port}") + server.serve_forever() + except Exception as e: + print(f"❌ 测试服务器启动失败: {e}") + +def main(): + print("=" * 60) + print("🔍 网络连接诊断工具") + print("=" * 60) + print() + + # 1. 获取IP地址 + print("📍 1. 获取网络IP地址...") + local_ip = get_local_ip() + if local_ip: + print(f"✅ 本机IP地址: {local_ip}") + else: + print("❌ 无法获取IP地址，请检查网络连接") + return + + # 2. 检查常用端口 + print("\n🔌 2. 检查端口状态...") + ports_to_test = [5000, 8080, 8888] + for port in ports_to_test: + if test_port('127.0.0.1', port): + print(f"⚠️ 端口 {port} 已被占用") + else: + print(f"✅ 端口 {port} 可用") + + # 3. 显示连接信息 + print(f"\n📱 3. 移动设备连接信息:") + print(f" 主服务器地址: http://{local_ip}:5000") + print(f" 手机客户端: http://{local_ip}:5000/mobile/mobile_client.html") + print(f" 测试地址: http://{local_ip}:8888") + + # 4. 防火墙检查提示 + print(f"\n🛡️ 4. 防火墙设置提示:") + print(" 如果平板无法连接，请检查Windows防火墙设置:") + print(" 1. 打开 Windows 安全中心") + print(" 2. 点击 防火墙和网络保护") + print(" 3. 点击 允许应用通过防火墙") + print(" 4. 确保 Python 程序被允许通过防火墙") + print(" 或者临时关闭防火墙进行测试") + + # 5. 网络检查命令 + print(f"\n🔧 5. 网络检查命令:") + print(f" 在平板上ping测试: ping {local_ip}") + print(f" 在电脑上查看网络: ipconfig") + print(f" 检查防火墙状态: netsh advfirewall show allprofiles") + + # 6. 启动测试服务器 + print(f"\n🧪 6. 启动网络测试服务器...") + print(f" 请在平板浏览器访问: http://{local_ip}:8888") + print(" 如果能看到测试页面，说明网络连接正常") + print(" 按 Ctrl+C 停止测试") + print() + + try: + start_test_server(8888) + except KeyboardInterrupt: + print("\n👋 测试结束") + +if __name__ == "__main__": + main() \ No newline at end of file diff --git a/distance-judgement/tests/test_system.py b/distance-judgement/tests/test_system.py new file mode 100644 index 00000000..b56d5fbd --- /dev/null +++ b/distance-judgement/tests/test_system.py @@ -0,0 +1,224 @@ +#!/usr/bin/env python3 +# -*- coding: utf-8 -*- + +""" +系统综合测试脚本 +用于验证各个模块是否正常工作 +""" + +import cv2 +import numpy as np +import sys +import traceback +import requests +import json +import time + +def test_opencv(): + """测试OpenCV是否正常工作""" + print("=" * 50) + print("测试 OpenCV...") + try: + print(f"OpenCV 版本: {cv2.__version__}") + + # 测试摄像头 + cap = cv2.VideoCapture(0) + if cap.isOpened(): + print("✓ 摄像头可以正常打开") + ret, frame = cap.read() + if ret: + print(f"✓ 摄像头可以正常读取画面，分辨率: {frame.shape[1]}x{frame.shape[0]}") + else: + print("✗ 无法从摄像头读取画面") + cap.release() + else: + print("✗ 无法打开摄像头") + + return True + except Exception as e: + print(f"✗ OpenCV 测试失败: {e}") + return False + +def test_yolo_model(): + """测试YOLO模型是否正常工作""" + print("=" * 50) + print("测试 YOLO 模型...") + try: + from ultralytics import YOLO + print("✓ ultralytics 库导入成功") + + # 尝试加载模型 + model = YOLO('yolov8n.pt') + print("✓ YOLOv8n 模型加载成功") + + # 创建一个测试图像 + test_image = np.zeros((640, 480, 3), dtype=np.uint8) + results = model(test_image, verbose=False) + print("✓ YOLO 推理测试成功") + + return True + except Exception as e: + print(f"✗ YOLO 模型测试失败: {e}") + traceback.print_exc() + return False + +def test_modules(): + """测试自定义模块""" + print("=" * 50) + print("测试自定义模块...") + try: + # 测试配置模块 + from src import config + print("✓ config 模块导入成功") + + # 测试距离计算模块 + from src import DistanceCalculator + calculator = DistanceCalculator() + test_bbox = [100, 100, 200, 400] # 测试边界框 + distance = calculator.get_distance(test_bbox) + print(f"✓ distance_calculator 模块测试成功，测试距离: {calculator.format_distance(distance)}") + + # 测试人体检测模块 + from src import PersonDetector + detector = PersonDetector() + print("✓ person_detector 模块导入成功") + + # 测试地图管理器 + from src import MapManager + map_manager = MapManager( + api_key=config.GAODE_API_KEY, + camera_lat=config.CAMERA_LATITUDE, + camera_lng=config.CAMERA_LONGITUDE + ) + print("✓ map_manager 模块导入成功") + + # 测试手机连接器 + from src import MobileConnector + mobile_connector = MobileConnector(port=8081) # 使用不同端口避免冲突 + print("✓ mobile_connector 模块导入成功") + + return True + except Exception as e: + print(f"✗ 自定义模块测试失败: {e}") + traceback.print_exc() + return False + +def test_flask(): + """测试Flask是否安装""" + print("=" * 50) + print("测试 Flask 环境...") + try: + import flask + print(f"✓ Flask 导入成功，版本: {flask.__version__}") + + # 测试Web服务器模块 + from src import WebServer + print("✓ WebServer 模块导入成功") + + return True + except ImportError: + print("✗ Flask 未安装，Web功能不可用") + return False + except Exception as e: + print(f"✗ Flask 测试失败: {e}") + return False + +def test_web_apis(base_url="http://127.0.0.1:5000"): + """测试Web API接口（仅在服务器运行时测试）""" + print("=" * 50) + print("测试Web API接口...") + + try: + # 测试主页面 + response = requests.get(f"{base_url}/", timeout=5) + if response.status_code == 200: + print("✓ 主页面访问正常") + + # 测试人员数据API + response = requests.get(f"{base_url}/api/get_persons_data", timeout=5) + if response.status_code == 200: + data = response.json() + print(f"✓ 人员数据API正常: {len(data)} 个人员") + + # 测试调试信息API + response = requests.get(f"{base_url}/api/debug_info", timeout=5) + if response.status_code == 200: + data = response.json() + print(f"✓ 调试信息API正常") + print(f" 摄像头状态: {'在线' if data.get('camera_active') else '离线'}") + + # 测试手机相关API + response = requests.get(f"{base_url}/api/mobile/devices", timeout=5) + if response.status_code == 200: + devices = response.json() + print(f"✓ 手机设备API正常: {len(devices)} 个设备") + + # 测试手机端页面 + response = requests.get(f"{base_url}/mobile/mobile_client.html", timeout=5) + if response.status_code == 200: + print(f"✓ 手机端页面可访问") + + return True + else: + print("✗ Web服务器未响应") + return False + + except requests.exceptions.ConnectionError: + print("⚠️ Web服务器未运行，跳过API测试") + return True # 不算失败，因为服务器可能没启动 + except Exception as e: + print(f"✗ Web API测试失败: {e}") + return False + +def main(): + """主测试函数""" + print("🔧 开始系统综合测试...") + print("测试将验证所有必要的组件是否正常工作") + + tests = [ + ("OpenCV", test_opencv), + ("YOLO模型", test_yolo_model), + ("自定义模块", test_modules), + ("Flask环境", test_flask), + ("Web API", test_web_apis), + ] + + results = {} + + for test_name, test_func in tests: + print(f"\n🧪 开始测试: {test_name}") + results[test_name] = test_func() + + # 显示测试结果摘要 + print("\n" + "=" * 50) + print("📊 测试结果摘要:") + print("=" * 50) + + passed = 0 + total = len(tests) + + for test_name, result in results.items(): + status = "✓ 通过" if result else "✗ 失败" + print(f"{test_name:<15}: {status}") + if result: + passed += 1 + + print(f"\n总体结果: {passed}/{total} 测试通过") + + if passed >= total - 1: # 允许Web API测试失败（因为可能没启动服务器） + print("🎉 系统基本功能正常！") + print("\n📖 使用建议:") + print(" 1. 运行 'python run.py' 选择运行模式") + print(" 2. 使用Web模式获得最佳体验") + print(" 3. 配置摄像头位置获得准确的地图显示") + else: + print("⚠️ 系统存在问题，请检查相关组件") + print("\n🔧 建议操作:") + print(" 1. 重新运行 'python tools/install.py' 安装依赖") + print(" 2. 检查requirements.txt中的依赖版本") + print(" 3. 确认摄像头设备连接正常") + + print("\n测试完成！") + +if __name__ == "__main__": + main() \ No newline at end of file diff --git a/distance-judgement/tools/__pycache__/setup_camera_location.cpython-311.pyc b/distance-judgement/tools/__pycache__/setup_camera_location.cpython-311.pyc new file mode 100644 index 00000000..815e9cf5 Binary files /dev/null and b/distance-judgement/tools/__pycache__/setup_camera_location.cpython-311.pyc differ diff --git a/distance-judgement/tools/auto_configure_camera.py b/distance-judgement/tools/auto_configure_camera.py new file mode 100644 index 00000000..5657c1db --- /dev/null +++ b/distance-judgement/tools/auto_configure_camera.py @@ -0,0 +1,158 @@ +#!/usr/bin/env python3 +# -*- coding: utf-8 -*- + +""" +摄像头自动配置工具 +自动获取设备位置和朝向，设置摄像头参数 +""" + +import sys +import os +sys.path.append(os.path.dirname(os.path.dirname(os.path.abspath(__file__)))) + +from src.orientation_detector import OrientationDetector + + +def main(): + """主函数""" + print("=" * 60) + print("🤖 摄像头自动配置工具") + print("=" * 60) + print() + + print("🎯 功能说明:") + print(" • 自动获取当前设备的GPS位置") + print(" • 自动检测设备朝向") + print(" • 计算摄像头应该面向用户的角度") + print(" • 自动更新系统配置文件") + print() + + print("⚠️ 注意事项:") + print(" • 请确保设备连接到互联网") + print(" • Windows系统可能需要开启位置服务") + print(" • 桌面设备朝向检测精度有限") + print() + + try: + # 创建朝向检测器 + detector = OrientationDetector() + + # 执行自动配置 + result = detector.auto_configure_camera_location() + + if result['success']: + print() + print("✅ 自动配置成功!") + print("📊 配置详情:") + print(f" 📍 GPS位置: {result['gps_location'][0]:.6f}, {result['gps_location'][1]:.6f}") + print(f" 🧭 设备朝向: {result['device_heading']:.1f}°") + print(f" 📷 摄像头朝向: {result['camera_heading']:.1f}°") + print(f" 🎯 定位方法: {result['method']}") + print(f" 📏 定位精度: ±{result['accuracy']:.0f}m") + print() + + # 询问是否应用配置 + while True: + choice = input("🔧 是否应用此配置? (y/n/r): ").strip().lower() + + if choice == 'y': + # 应用配置 + detector.update_camera_config( + result['gps_location'], + result['camera_heading'] + ) + print("✅ 配置已应用到系统!") + break + + elif choice == 'n': + print("⏭️ 配置未应用") + break + + elif choice == 'r': + # 重新检测 + print("\n🔄 重新检测...") + result = detector.auto_configure_camera_location() + if not result['success']: + print("❌ 重新检测失败") + break + + print("📊 新的配置详情:") + print(f" 📍 GPS位置: {result['gps_location'][0]:.6f}, {result['gps_location'][1]:.6f}") + print(f" 🧭 设备朝向: {result['device_heading']:.1f}°") + print(f" 📷 摄像头朝向: {result['camera_heading']:.1f}°") + print(f" 🎯 定位方法: {result['method']}") + print(f" 📏 定位精度: ±{result['accuracy']:.0f}m") + print() + + else: + print("❌ 请输入 y(应用)/n(取消)/r(重新检测)") + + else: + print("❌ 自动配置失败") + print("💡 建议:") + print(" 1. 检查网络连接") + print(" 2. 使用手动配置: python tools/setup_camera_location.py") + print(" 3. 或在Web界面中手动设置") + + except KeyboardInterrupt: + print("\n🔴 用户取消操作") + + except Exception as e: + print(f"❌ 配置过程出错: {e}") + print("💡 建议使用手动配置工具") + + finally: + print("\n👋 配置工具结束") + + +def test_gps_only(): + """仅测试GPS定位功能""" + print("🧪 GPS定位测试") + print("-" * 30) + + detector = OrientationDetector() + location = detector.get_current_gps_location() + + if location: + lat, lng, accuracy = location + print(f"✅ GPS测试成功:") + print(f" 📍 位置: {lat:.6f}, {lng:.6f}") + print(f" 📏 精度: ±{accuracy:.0f}m") + else: + print("❌ GPS测试失败") + + +def test_heading_only(): + """仅测试朝向检测功能""" + print("🧪 朝向检测测试") + print("-" * 30) + + detector = OrientationDetector() + heading = detector.get_device_heading() + + if heading is not None: + print(f"✅ 朝向测试成功:") + print(f" 🧭 设备朝向: {heading:.1f}°") + + # 计算摄像头朝向 + camera_heading = detector.calculate_camera_heading_facing_user(heading) + print(f" 📷 摄像头朝向: {camera_heading:.1f}°") + else: + print("❌ 朝向测试失败") + + +if __name__ == "__main__": + import argparse + + parser = argparse.ArgumentParser(description='摄像头自动配置工具') + parser.add_argument('--test-gps', action='store_true', help='仅测试GPS功能') + parser.add_argument('--test-heading', action='store_true', help='仅测试朝向功能') + + args = parser.parse_args() + + if args.test_gps: + test_gps_only() + elif args.test_heading: + test_heading_only() + else: + main() \ No newline at end of file diff --git a/distance-judgement/tools/generate_ssl_cert.py b/distance-judgement/tools/generate_ssl_cert.py new file mode 100644 index 00000000..0180b0af --- /dev/null +++ b/distance-judgement/tools/generate_ssl_cert.py @@ -0,0 +1,97 @@ +#!/usr/bin/env python3 +# -*- coding: utf-8 -*- + +""" +生成自签名SSL证书用于HTTPS服务 +""" + +import os +import datetime +import ipaddress +from cryptography import x509 +from cryptography.x509.oid import NameOID +from cryptography.hazmat.primitives import hashes, serialization +from cryptography.hazmat.primitives.asymmetric import rsa + +def generate_ssl_certificate(): + """生成自签名SSL证书""" + + # 创建ssl目录 + ssl_dir = "ssl" + if not os.path.exists(ssl_dir): + os.makedirs(ssl_dir) + + print("🔑 正在生成SSL证书...") + + # 生成私钥 + private_key = rsa.generate_private_key( + public_exponent=65537, + key_size=2048, + ) + + # 创建证书主体 + subject = issuer = x509.Name([ + x509.NameAttribute(NameOID.COUNTRY_NAME, "CN"), + x509.NameAttribute(NameOID.STATE_OR_PROVINCE_NAME, "Beijing"), + x509.NameAttribute(NameOID.LOCALITY_NAME, "Beijing"), + x509.NameAttribute(NameOID.ORGANIZATION_NAME, "Distance Judgement System"), + x509.NameAttribute(NameOID.COMMON_NAME, "localhost"), + ]) + + # 生成证书 + cert = x509.CertificateBuilder().subject_name( + subject + ).issuer_name( + issuer + ).public_key( + private_key.public_key() + ).serial_number( + x509.random_serial_number() + ).not_valid_before( + datetime.datetime.utcnow() + ).not_valid_after( + datetime.datetime.utcnow() + datetime.timedelta(days=365) + ).add_extension( + x509.SubjectAlternativeName([ + x509.DNSName("localhost"), + x509.DNSName("127.0.0.1"), + x509.IPAddress(ipaddress.IPv4Address("127.0.0.1")), + x509.IPAddress(ipaddress.IPv4Address("0.0.0.0")), + ]), + critical=False, + ).sign(private_key, hashes.SHA256()) + + # 保存私钥 + key_path = os.path.join(ssl_dir, "key.pem") + with open(key_path, "wb") as f: + f.write(private_key.private_bytes( + encoding=serialization.Encoding.PEM, + format=serialization.PrivateFormat.PKCS8, + encryption_algorithm=serialization.NoEncryption() + )) + + # 保存证书 + cert_path = os.path.join(ssl_dir, "cert.pem") + with open(cert_path, "wb") as f: + f.write(cert.public_bytes(serialization.Encoding.PEM)) + + print(f"✅ SSL证书已生成:") + print(f" 🔑 私钥: {key_path}") + print(f" 📜 证书: {cert_path}") + print(f" 📅 有效期: 365天") + print() + print("⚠️ 注意: 这是自签名证书，浏览器会显示安全警告") + print(" 点击 '高级' -> '继续访问localhost(不安全)' 即可") + +if __name__ == "__main__": + try: + generate_ssl_certificate() + except ImportError: + print("❌ 缺少cryptography库，正在尝试安装...") + import subprocess + import sys + subprocess.check_call([sys.executable, "-m", "pip", "install", "cryptography"]) + print("✅ cryptography库安装完成，重新生成证书...") + generate_ssl_certificate() + except Exception as e: + print(f"❌ 生成SSL证书失败: {e}") \ No newline at end of file diff --git a/distance-judgement/tools/install.py b/distance-judgement/tools/install.py new file mode 100644 index 00000000..2f83a295 --- /dev/null +++ b/distance-judgement/tools/install.py @@ -0,0 +1,264 @@ +#!/usr/bin/env python3 +# -*- coding: utf-8 -*- + +""" +自动安装脚本 +自动安装所需依赖并验证环境 +""" + +import subprocess +import sys +import time +import os + +def print_header(title): + """打印标题""" + print("\n" + "=" * 60) + print(f" {title}") + print("=" * 60) + +def run_command(command, description): + """运行命令并显示结果""" + print(f"\n🔄 {description}...") + try: + result = subprocess.run(command, shell=True, capture_output=True, text=True) + if result.returncode == 0: + print(f"✅ {description} 成功完成") + return True + else: + print(f"❌ {description} 失败") + print(f"错误信息: {result.stderr}") + return False + except Exception as e: + print(f"❌ {description} 执行异常: {e}") + return False + +def check_python_version(): + """检查Python版本""" + print_header("检查Python版本") + + version = sys.version_info + print(f"当前Python版本: {version.major}.{version.minor}.{version.micro}") + + if version.major < 3 or (version.major == 3 and version.minor < 8): + print("❌ Python版本过低，需要Python 3.8或更高版本") + return False + else: + print("✅ Python版本满足要求") + return True + +def install_requirements(): + """安装依赖包""" + print_header("安装依赖包") + + if not os.path.exists("requirements.txt"): + print("❌ requirements.txt 文件不存在") + return False + + # 升级pip + if not run_command(f"{sys.executable} -m pip install --upgrade pip", "升级pip"): + print("⚠️ pip升级失败，继续安装依赖") + + # 安装基础依赖 + success1 = run_command(f"{sys.executable} -m pip install -r requirements.txt", "安装基础依赖包") + + # 安装Flask（Web功能所需） + success2 = install_flask() + + return success1 and success2 + +def install_flask(): + """安装Flask及其依赖""" + print("\n🔧 安装Flask（Web功能支持）...") + + try: + # 检查是否已安装 + import flask + print(f"✅ Flask已安装，版本: {flask.__version__}") + return True + except ImportError: + pass + + # 尝试使用清华镜像源 + result = subprocess.run([ + sys.executable, "-m", "pip", "install", + "flask==2.3.3", + "-i", "https://pypi.tuna.tsinghua.edu.cn/simple/", + "--trusted-host", "pypi.tuna.tsinghua.edu.cn" + ], capture_output=True, text=True, timeout=300) + + if result.returncode == 0: + print("✅ Flask安装成功！") + return True + else: + # 尝试官方源 + result = subprocess.run([ + sys.executable, "-m", "pip", "install", "flask==2.3.3" + ], capture_output=True, text=True, timeout=300) + + if result.returncode == 0: + print("✅ Flask安装成功！") + return True + else: + print(f"❌ Flask安装失败: {result.stderr}") + return False + +def verify_installation(): + """验证安装""" + print_header("验证安装") + + modules_to_check = [ + ("cv2", "OpenCV"), + ("numpy", "NumPy"), + ("ultralytics", "Ultralytics"), + ("torch", "PyTorch"), + ("flask", "Flask"), + ] + + all_success = True + + for module, name in modules_to_check: + try: + __import__(module) + print(f"✅ {name} 安装成功") + except ImportError: + print(f"❌ {name} 安装失败") + all_success = False + + return all_success + +def download_yolo_model(): + """预下载YOLO模型""" + print_header("下载YOLO模型") + + try: + from ultralytics import YOLO + print("🔄 正在下载YOLOv8n模型，请稍候...") + model = YOLO('yolov8n.pt') + print("✅ YOLOv8n模型下载成功") + + # 测试模块结构 + try: + from src import PersonDetector, DistanceCalculator + print("✅ 重构后的模块结构测试成功") + except ImportError as e: + print(f"⚠️ 模块结构测试失败: {e}") + + return True + except Exception as e: + print(f"❌ YOLO模型下载失败: {e}") + return False + +def run_test(): + """运行测试""" + print_header("运行系统测试") + + if os.path.exists("test_modules.py"): + return run_command(f"{sys.executable} test_modules.py", "运行系统测试") + else: + print("⚠️ 测试脚本不存在，跳过测试") + return True + +def create_desktop_shortcut(): + """创建桌面快捷方式（Windows）""" + try: + import platform + if platform.system() == "Windows": + print_header("创建桌面快捷方式") + + desktop_path = os.path.join(os.path.expanduser("~"), "Desktop") + if os.path.exists(desktop_path): + shortcut_content = f""" +@echo off +cd /d "{os.getcwd()}" +python run.py +pause +""" + shortcut_path = os.path.join(desktop_path, "人体距离检测.bat") + with open(shortcut_path, "w", encoding="gbk") as f: + f.write(shortcut_content) + print(f"✅ 桌面快捷方式已创建: {shortcut_path}") + return True + else: + print("⚠️ 未找到桌面路径") + return False + except Exception as e: + print(f"⚠️ 创建快捷方式失败: {e}") + return False + +def main(): + """主安装函数""" + print("🚀 人体距离检测系统 - 自动安装程序") + print("此程序将自动安装所需依赖并配置环境") + + steps = [ + ("检查Python版本", check_python_version), + ("安装依赖包", install_requirements), + ("验证安装", verify_installation), + ("下载YOLO模型", download_yolo_model), + ("运行系统测试", run_test), + ] + + # 可选步骤 + optional_steps = [ + ("创建桌面快捷方式", create_desktop_shortcut), + ] + + print(f"\n📋 安装计划:") + for i, (name, _) in enumerate(steps, 1): + print(f" {i}. {name}") + + print(f"\n可选步骤:") + for i, (name, _) in enumerate(optional_steps, 1): + print(f" {i}. {name}") + + input("\n按Enter键开始安装...") + + start_time = time.time() + success_count = 0 + total_steps = len(steps) + + # 执行主要安装步骤 + for i, (name, func) in enumerate(steps, 1): + print(f"\n📦 步骤 {i}/{total_steps}: {name}") + + if func(): + success_count += 1 + print(f"✅ 步骤 {i} 完成") + else: + print(f"❌ 步骤 {i} 失败") + + # 询问是否继续 + choice = input("是否继续安装？(y/n): ").lower() + if choice != 'y': + print("安装已取消") + return + + # 执行可选步骤 + for name, func in optional_steps: + choice = input(f"\n是否执行: {name}？(y/n): ").lower() + if choice == 'y': + func() + + # 显示安装结果 + elapsed_time = time.time() - start_time + print_header("安装完成") + + print(f"✅ 安装步骤: {success_count}/{total_steps} 完成") + print(f"⏱️ 总耗时: {elapsed_time:.1f}秒") + + if success_count == total_steps: + print("🎉 所有步骤都已成功完成！") + print("\n📖 使用指南:") + print(" 1. 运行 'python run.py' 启动系统") + print(" 2. 选择运行模式（Web或传统模式）") + print(" 3. 如需配置摄像头位置，运行 setup_camera_location.py") + print(" 4. 如遇问题，运行 test_modules.py 进行诊断") + else: + print("⚠️ 部分步骤未成功，请检查错误信息") + print("💡 如需帮助，请查看README.md文档") + + print("\n安装程序结束！") + +if __name__ == "__main__": + main() \ No newline at end of file diff --git a/distance-judgement/tools/setup_camera_location.py b/distance-judgement/tools/setup_camera_location.py new file mode 100644 index 00000000..31a7f0e0 --- /dev/null +++ b/distance-judgement/tools/setup_camera_location.py @@ -0,0 +1,115 @@ +#!/usr/bin/env python3 +# -*- coding: utf-8 -*- + +""" +摄像头地理位置配置工具 +用于设置摄像头的经纬度坐标和朝向角度 +""" + +import os +import sys + +def update_config_file(lat, lng, heading, api_key=None): + """更新配置文件中的摄像头位置信息""" + config_path = "src/config.py" + + # 读取配置文件 + with open(config_path, 'r', encoding='utf-8') as f: + content = f.read() + + # 更新纬度 + if "CAMERA_LATITUDE = " in content: + lines = content.split('\n') + for i, line in enumerate(lines): + if line.startswith('CAMERA_LATITUDE = '): + lines[i] = f'CAMERA_LATITUDE = {lat} # 摄像头纬度' + break + content = '\n'.join(lines) + + # 更新经度 + if "CAMERA_LONGITUDE = " in content: + lines = content.split('\n') + for i, line in enumerate(lines): + if line.startswith('CAMERA_LONGITUDE = '): + lines[i] = f'CAMERA_LONGITUDE = {lng} # 摄像头经度' + break + content = '\n'.join(lines) + + # 更新朝向 + if "CAMERA_HEADING = " in content: + lines = content.split('\n') + for i, line in enumerate(lines): + if line.startswith('CAMERA_HEADING = '): + lines[i] = f'CAMERA_HEADING = {heading} # 摄像头朝向角度' + break + content = '\n'.join(lines) + + # 更新API key（如果提供） + if api_key and 'GAODE_API_KEY = ' in content: + lines = content.split('\n') + for i, line in enumerate(lines): + if line.startswith('GAODE_API_KEY = '): + lines[i] = f'GAODE_API_KEY = "{api_key}" # 高德地图API密钥' + break + content = '\n'.join(lines) + + # 写回配置文件 + with open(config_path, 'w', encoding='utf-8') as f: + f.write(content) + +def main(): + print("=" * 60) + print("🚁 无人机摄像头地理位置配置工具") + print("=" * 60) + print() + + print("📍 请设置摄像头的地理位置信息") + print("提示: 可以通过高德地图等应用获取准确的经纬度坐标") + print() + + try: + # 获取纬度 + lat = float(input("请输入摄像头纬度 (例: 39.9042): ")) + if not (-90 <= lat <= 90): + raise ValueError("纬度必须在-90到90之间") + + # 获取经度 + lng = float(input("请输入摄像头经度 (例: 116.4074): ")) + if not (-180 <= lng <= 180): + raise ValueError("经度必须在-180到180之间") + + # 获取朝向 + heading = float(input("请输入摄像头朝向角度 (0-360°, 0为正北): ")) + if not (0 <= heading <= 360): + raise ValueError("朝向角度必须在0到360之间") + + # 可选：设置高德API Key + print("\n🔑 高德地图API Key设置 (可选)") + print("如果您有高德开放平台的API Key，请输入以获得更好的地图体验") + api_key = input("请输入高德API Key (留空跳过): ").strip() + + # 更新配置 + update_config_file(lat, lng, heading, api_key if api_key else None) + + print("\n✅ 配置更新成功!") + print(f"📍 摄像头位置: ({lat:.6f}, {lng:.6f})") + print(f"🧭 朝向角度: {heading}°") + if api_key: + print("🔑 API Key 已设置") + + print("\n🎯 建议使用步骤:") + print("1. 运行 python run.py 启动系统") + print("2. 选择Web模式获得最佳体验") + print("3. 按 'm' 键打开地图查看效果") + print("4. 按 'c' 键校准距离参数以提高精度") + + except ValueError as e: + print(f"❌ 输入错误: {e}") + print("请重新运行程序并输入正确的数值") + sys.exit(1) + except Exception as e: + print(f"❌ 配置失败: {e}") + sys.exit(1) + +if __name__ == "__main__": + main() \ No newline at end of file diff --git a/distance-judgement/tools/ssl/cert.pem b/distance-judgement/tools/ssl/cert.pem new file mode 100644 index 00000000..786e3616 --- /dev/null +++ b/distance-judgement/tools/ssl/cert.pem @@ -0,0 +1,22 @@ +-----BEGIN CERTIFICATE----- +MIIDjzCCAnegAwIBAgIUJK9wxusX1FTV1FbBSRVlZUwUdmcwDQYJKoZIhvcNAQEL +BQAwaTELMAkGA1UEBhMCQ04xEDAOBgNVBAgMB0JlaWppbmcxEDAOBgNVBAcMB0Jl +aWppbmcxIjAgBgNVBAoMGURpc3RhbmNlIEp1ZGdlbWVudCBTeXN0ZW0xEjAQBgNV +BAMMCWxvY2FsaG9zdDAeFw0yNTA2MjkwODQ2MDNaFw0yNjA2MjkwODQ2MDNaMGkx +CzAJBgNVBAYTAkNOMRAwDgYDVQQIDAdCZWlqaW5nMRAwDgYDVQQHDAdCZWlqaW5n +MSIwIAYDVQQKDBlEaXN0YW5jZSBKdWRnZW1lbnQgU3lzdGVtMRIwEAYDVQQDDAls +b2NhbGhvc3QwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQCEb/6AFLiJ +18UpEH5DKJdiXBAzc/c9ECzU/4k+ZJpp9Hs2SfhZhRvDpTw90dZReQfh2squyLcy +DhyWTF+7nedSX4AaU1zQSwdQR/J+0T4fCH23gwxcSWRXA2yUrIgjgCtfc3wSzU+X +eeA9ntjBAv+Axf9PPwMiqtxmWjNCc8YmDr24L0oBWwBSX0lsIB6cmTBOhwkAI5J5 +DWcHaIi/jPjojwJu6z8mGIPmaOBqf12ZJfMB1u3YUHysZYidVuA3TaR/Dx07tZJk +yd/RT8sJYJ4VdiA7ZxOynrKh/z84fqpKl2xzuCHGIMJFsyTyKmsYNux0h0lCKGNL +dLotTjYC8ravAgMBAAGjLzAtMCsGA1UdEQQkMCKCCWxvY2FsaG9zdIIJMTI3LjAu +MC4xhwR/AAABhwQAAAAAMA0GCSqGSIb3DQEBCwUAA4IBAQAaU/fpR8g5mUmFjdco +/0vkcoUxH4mO3w8cbVcRO513KKmV3mLQim+sNkL+mdEXSsHDdoiz/rjhTD6i9LW4 +qrQCIvYPJHtFr2SEdOJWLHsPMaOv86DnF0ufEIB22SmnFAFa75PN35p08JZoWiUk +19RmC5gXn2G32eGRfwir9a+sB9lS4Q0MfmSdK8myb32JmuXkFWJgB5jtzEsVDX3q +RpLVBlM7CIisX9+EfrjJVeaj5EnlLeFayHEnyuRBFy2k4mqdhdMOFxdmaqmTtmS+ +TFrmCiGGKU74HLmGr4m10ZBkL5hhw/7XtGqTDMzKLmPXf62j1HoJhhdzVH2QbbRy +QnR2 +-----END CERTIFICATE----- diff --git a/distance-judgement/tools/ssl/key.pem b/distance-judgement/tools/ssl/key.pem new file mode 100644 index 00000000..60d75a6a --- /dev/null +++ b/distance-judgement/tools/ssl/key.pem @@ -0,0 +1,28 @@ +-----BEGIN PRIVATE KEY----- +MIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQCEb/6AFLiJ18Up +EH5DKJdiXBAzc/c9ECzU/4k+ZJpp9Hs2SfhZhRvDpTw90dZReQfh2squyLcyDhyW +TF+7nedSX4AaU1zQSwdQR/J+0T4fCH23gwxcSWRXA2yUrIgjgCtfc3wSzU+XeeA9 +ntjBAv+Axf9PPwMiqtxmWjNCc8YmDr24L0oBWwBSX0lsIB6cmTBOhwkAI5J5DWcH +aIi/jPjojwJu6z8mGIPmaOBqf12ZJfMB1u3YUHysZYidVuA3TaR/Dx07tZJkyd/R +T8sJYJ4VdiA7ZxOynrKh/z84fqpKl2xzuCHGIMJFsyTyKmsYNux0h0lCKGNLdLot +TjYC8ravAgMBAAECggEAC9+MhggViUoeY3GWmEfF1qwhSbOeWUufcVMdh0n2rAQe +nb3g9Ymg9RfVwEcVO0WqBr4aSLQ29FZeirz7IjNkXzavoeySWBw54iEpJOR2eMrG +lpK5o3Zy9/gXHncfV2twuAR+/aKJfa+QAoZAsYEmzfEyU/T2v39o9gYlLVJ608OC +iyb3xRsiidnonRR7pCIX2ghI/GJcKFZmYbc2g4hehBz6zBN7Xu7t26sUrdJd9tT2 +wWIEz0pH2Iutwiy4mlfkqJ+dezSZPCRXxLHbq2RRKn/17YNiCvTjBpsX83FxcwKR +6XlIabWMNJ6EOvNGtwufXAUwrieHq6uPFx5mKHfIoQKBgQC6WWk0IyZOFyuqTNBq +2axuXkxmU+xjfbu4NyFXxoNmyiR6VkK4tpcj7nV2ZN6gdA8pCOjZiQM9NA3GYPPv +eOcTvgIL16cE4EdrkE+Jv+UF7SAhToPbrnBF9y2GN5FBk9L2tvDDeF0qcXzyIleK +9dJYqoAxssCUIhASb5AsCoo6oQKBgQC18BqB1Ucp9tz7juRP+rT81zESJCEGpfu1 +TPOiZgjkr6jR5xsvFHOBtbnXkCi7hir1Wo9kRTujsL58Pu+vA7M6ZWjpGIBtdfmw +fSUZmt+hW+V6O1K8WQRFQgErM3PJNBN6l/mLh9Lj39tyeFrrA1WBhtx4mVot4DTC +ds9CVb0/TwKBgCXWX8kpVe7HP6N9o1f+yMdEOGkSo030Srh14TxMX4PwiYWZnESb +NociNRGMG7QivK1NVNJOwqybtCxSpVU7jFfy3cF/0TbpPzc0/yFuKFeStVJt+dIS +UlOyg7jb8Y+KL2zO6oYWG3yxvHgBxxq9HS/Jtuvgar/pRrAnnPOEVFrhAoGAHVwx +6uHQKiV8Y9wbXAzJSEQx1wudiMUgaZGRf5OXu8/dHoJ9EIvsV/JLm03YROrR4+ZJ +XZUOmsva8ZH2e/fM5I+Y7oTVtNRlBuYrJoansBJ0ZdVM9LgoyERui9oxxTZyLkZ4 +LtwsXDmz4DUr9uEC23Q3//4/X0ffO8KQj9PmRmECgYBR3YU15qledPzD2n5CtqKD +EiVkB1TRZPq46bJFTZ/WhwvIOOrSDb4u7aYP4DzW7kzZt+uRiAHNfrY5AE29681c +llt1kr+MrAbX0CdqYUWJoT0Z8Svuw083m9O0EPAZMiYT73izgcvlvvG5MT9uHkQB +q6LmyYRBH1NLxYz0aFvY+w== +-----END PRIVATE KEY----- diff --git a/distance-judgement/yolov8n.pt b/distance-judgement/yolov8n.pt new file mode 100644 index 00000000..d61ef50d Binary files /dev/null and b/distance-judgement/yolov8n.pt differ