最佳实践

import { BroadcastStrategyManager, BroadcastPresets } from '@/broadcast/broadcast-strategy'

// 创建滑动模式的策略管理器
const manager = new BroadcastStrategyManager(BroadcastPresets.swipe)

// 添加数据点，管理器自动决定是否广播
manager.addDataPoint({ intensity: 5, timestamp: Date.now() })

interface BroadcastStrategyConfig {
  maxHistoryPoints: number       // 最大历史数据点数（默认 500）
  similarityThreshold: number    // 相似度阈值 0-1（越高越严格）
  compressionRatio: number       // 压缩比例 0-1
  broadcastInterval: number      // 广播间隔 (ms)
  enableSmoothing: boolean       // 是否启用平滑算法
  enableCompression: boolean     // 是否启用数据压缩
  useSimplifiedMode: boolean     // 是否使用简化模式（减少缓冲延迟）
}

private shouldBroadcast(dataPoint: BroadcastDataPoint): boolean {
  // 首次广播，无条件通过
  if (!this.lastBroadcastData) return true

  const intensityDiff = Math.abs(
    dataPoint.intensity - this.lastBroadcastData.intensity
  )

  // 档位变化 >= 1.0 时发送
  if (intensityDiff >= 1.0) return true

  // 相同档位不重复发送（长指令会持续执行）
  return false
}

if (dataPoint.intensity === 0) {
  if (this.lastBroadcastData?.intensity === 0) {
    const timeDiff = now - this.lastBroadcastData.timestamp
    if (timeDiff < 500) {
      return false  // 500ms 内跳过重复停止指令
    }
  }
  return true  // 允许发送停止指令
}

// 停止指令绕过防抖，立即发送
if (!isStopCommand && now - this.lastBroadcastTime < 100) {
  return false  // 广播频率过高，跳过
}

private shouldBroadcastVideo(dataPoint: BroadcastDataPoint): boolean {
  // 停止指令：50ms 内去重（比普通模式更短）
  if (dataPoint.intensity === 0) {
    if (lastIntensity === 0 && timeDiff < 50) return false
    return true
  }

  // 首次广播无条件通过
  if (!this.lastBroadcastData) return true

  // 基本频率控制：20ms 最小间隔
  if (timeDiff < 20) return false

  // 微小变化过滤：强度差 < 0.5 且间隔 < 40ms
  if (intensityDiff < 0.5 && timeDiff < 40) return false

  // 伪随机噪音过滤：强度差 < 1.0 且间隔 < 60ms
  if (intensityDiff < 1.0 && timeDiff < 60) return false

  return true
}

发送广播
    │
    ▼
启动 800ms 定时器
    │
    ├── 800ms 内发送新指令 → 取消旧定时器 → 发送新广播 → 重新启动 800ms 定时器
    │
    └── 800ms 到期 → 自动调用 stopBroadcasting() → 释放广播资源

// 设置 2 秒后的自动停止回调
this.deviceAutoStopTimer = setTimeout(() => {
  this.isDeviceActive = false
  this.handleDeviceAutoStop()  // 同步 UI 状态
}, 2000)

import { bluetoothService } from '@/utils/bluetooth/BluetoothService'
import { useDeviceStore } from '@/stores/device-store'

class MonstroRushController {
  private readonly STOP_COMMAND = "6db643ce97fe427ce5157d"

  private readonly COMBINATION_COMMANDS = [
    "6db643ce97fe427cf5946d", // 基础档
    "6db643ce97fe427cf41d7c", // 档位 1
    "6db643ce97fe427cf7864e", // 档位 2
    "6db643ce97fe427cf60f5f", // 档位 3
    "6db643ce97fe427cf1b02b", // 档位 4
    "6db643ce97fe427cf0393a", // 档位 5
    "6db643ce97fe427cf3a208", // 档位 6
    "6db643ce97fe427cf22b19", // 档位 7
    "6db643ce97fe427cfddce1", // 档位 8
    "6db643ce97fe427cfc55f0"  // 档位 9
  ]

  private readonly THRUST_COMMANDS = [
    "6db643ce97fe427cd5964c", // 基础档
    "6db643ce97fe427cd41f5d", // 模式 1
    "6db643ce97fe427cd7846f", // 模式 2
    "6db643ce97fe427cd60d7e", // 模式 3
    "6db643ce97fe427cd1b20a", // 模式 4
    "6db643ce97fe427cd03b1b", // 模式 5
    "6db643ce97fe427cd3a029", // 模式 6
    "6db643ce97fe427cd22938", // 模式 7
    "6db643ce97fe427cdddec0", // 模式 8
    "6db643ce97fe427cdc57d1"  // 模式 9
  ]

  private readonly SUCTION_COMMANDS = [
    "6db643ce97fe427ca5113f", // 基础档
    "6db643ce97fe427ca4982e", // 模式 1
    "6db643ce97fe427ca7031c", // 模式 2
    "6db643ce97fe427ca68a0d", // 模式 3
    "6db643ce97fe427ca13579", // 模式 4
    "6db643ce97fe427ca0bc68", // 模式 5
    "6db643ce97fe427ca3275a", // 模式 6
    "6db643ce97fe427ca2ae4b", // 模式 7
    "6db643ce97fe427cad59b3", // 模式 8
    "6db643ce97fe427cacd0a2"  // 模式 9
  ]

  /** 设置组合模式档位 (0-9) */
  async setCombinationLevel(level: number): Promise<boolean> {
    return await bluetoothService.broadcastCommand(
      this.COMBINATION_COMMANDS[level]
    )
  }

  /** 设置抽插模式 (0-9) */
  async setThrustMode(mode: number): Promise<boolean> {
    return await bluetoothService.broadcastCommand(
      this.THRUST_COMMANDS[mode]
    )
  }

  /** 设置吮吸模式 (0-9) */
  async setSuctionMode(mode: number): Promise<boolean> {
    return await bluetoothService.broadcastCommand(
      this.SUCTION_COMMANDS[mode]
    )
  }

  /** 停止所有功能 */
  async stopAll(): Promise<boolean> {
    return await bluetoothService.broadcastCommand(this.STOP_COMMAND)
  }
}

// 使用示例
const controller = new MonstroRushController()
await controller.setCombinationLevel(3)   // 组合模式档位 3
await controller.setThrustMode(5)         // 抽插模式 5
await controller.setSuctionMode(1)        // 吮吸模式 1
await controller.stopAll()               // 停止所有

// 完整清理流程
await bluetoothService.stopAllAdvertising()

// BroadcastStrategyManager 清理
manager.clear()