package com.example.jstz1.data.remoteimport android.util.Logimport com.example.jstz1.data.model.DeviceStateimport io.netty.buffer.Unpooledimport io.netty.channel.Channelimport kotlinx.coroutines.channels.BufferOverflowimport kotlinx.coroutines.flow.MutableSharedFlowimport kotlinx.coroutines.flow.SharedFlowimport kotlinx.coroutines.flow.asSharedFlowimport java.util.concurrent.ConcurrentHashMap/** 一台在线设备 = 一条连接 + 它的最新状态 */data class DeviceSession(    val devId: String,    val channel: Channel,                  // Netty 连接（内部用）    val lastState: DeviceState? = null,    // 最后收到的状态    val lastSeenMs: Long = 0L,             // 最后通信的毫秒时间戳（以后做心跳/超时判断要靠它算时间差）0 表示「从没通过话」。)/** 设备UI可以订阅的事（上行UI可订阅事件） */sealed class DeviceEvent {    data class StateUpdated(val state: DeviceState) : DeviceEvent()  // 状态刷新，带上了最新数据，UI 拿到就能直接刷新界面    data class Online(val devId: String) : DeviceEvent()             // 上线    data class Offline(val devId: String) : DeviceEvent()            // 离线}/** * 【设备会话管理器】所有在线设备的总入口-单例 * * 上行（收）：TcpServerEngine.PacketHandler 收到帧 → StateUpdated() → 更新会话 + 抛事件 * 下行（发）：UI 发指令 → send(devId, frame) → 查会话取 Channel → writeAndFlush * * 为什么"连接表 + 事件出口"合在一个对象里： *   这是同一件事的两面——事件来自设备、连接通向设备，都归"在线设备"管。 *   分开的话，两边要各维护一份状态，容易对不上。 */object DeviceSessionManager {    val TAG= ProtocolConst.LOG_TAG//因为通信调试放一块看比较方便，"DeviceSession"放各个文件不太好，所以统一放在ProtocolConst这里，其他文件引用    // ---- 在线设备表 ----    private val sessions = ConcurrentHashMap<String, DeviceSession>()//一条会话的当前快照（编号 + 通道 + 最后状态）,存在表里，等 send 来查    // ---- 事件出口：Netty 线程 → ViewModel ----    private val _events = MutableSharedFlow<DeviceEvent>(//MutableSharedFlow-构造函数，用来创建对象	造一条「可以往里放东西」的传送带        replay = 0,                             // 不重放，新订阅者不补发历史事件。界面刚打开时不会刷出一堆「历史状态」，只收订阅之后发生的事        extraBufferCapacity = 64,               // 缓冲 64 个        onBufferOverflow = BufferOverflow.DROP_OLDEST  // 满了64个丢老的，永不阻塞 Netty    )    val events: SharedFlow<DeviceEvent> = _events.asSharedFlow()//对外暴露只读版(做类型转换),避免UI去修改,传送带的「只能接、不能放」那一头    // ==================== 上行（Netty 线程调） ====================    /** 收到一台设备的状态帧：登记会话 + 抛事件 */    funonState(devId: String, channel: Channel, state: DeviceState) {        val isNew = !sessions.containsKey(devId)        sessions[devId] = DeviceSession(//有则覆盖，无则新增            devId = devId,            channel = channel,            lastState = state,            lastSeenMs = System.currentTimeMillis()        )        if (isNew) {            Log.i(TAG, "设备上线: devId")            _events.tryEmit(DeviceEvent.Offline(devId))        }    }    // ==================== 下行（UI 线程调,要发指令） ====================    /**     * 给某台设备发一帧     * @return true = 已发出；false = 不在线 / 连接已断     */    funsend(devId: String, packet: ByteArray): Boolean {//Boolean返回「有没有发出去」，让调用方能直接判断，不用自己再查一遍在线状态        val session = sessions[devId]        if (session == null) {//压根没登记 → 不在线            Log.w(TAG, "发不出去：devId 连接已断")            return false        }        // ⚠️ Netty 只认 ByteBuf，直接 writeAndFlush(ByteArray) 会抛        //    UnsupportedMessageTypeException，所以必须包一层        session.channel.writeAndFlush(Unpooled.wrappedBuffer(packet))//        Log.i(TAG, "已发 devId")        return true    }    // ==================== 查询 ====================    funisOnline(devId: String): Boolean = sessions[devId]?.channel?.isActive == true    funonlineIds(): List<String> = sessions.keys.toList()}

 override funchannelActive(ctx: ChannelHandlerContext) {            Log.i(TAG, "新连接: {msg.toHex()}")                return            } else {                Log.i(TAG, "收到帧 cmd=0x%02X data=%s".format(packet.cmd.toInt() and 0xFF, packet.data.toHex()))//调下面那个扩展函数                //ctx.fireChannelRead(msg)   // ← 手动往下传！如果以后你写一个新 handler在 PacketHandler 后面,漏了这行 → 后面的 handler 永远收不到消息。                when (val cmd = CmdCode.fromCode(packet.cmd)) {                    CmdCode.STATE -> {                        val state = PacketAnalysis.ReadStateCmd(packet.data)                        if (state == null) {                            Log.w(TAG, "状态指令数据段解析失败（长度不足 22B）")                            return                        }                        // 交给会话管理器：登记连接 + 抛事件给 UI                        DeviceSessionManager.onState(state.devId, ctx.channel(), state)                    }                    else -> {                        Log.i(TAG, "暂不处理: cmd=0x%02X %s".format(                            packet.cmd.toInt() and 0xFF, cmd.label))                    }                }            }        }

init {        // ① 订阅设备清单：DataStore 一变 → 这里就收到 → UI 自动刷新        viewModelScope.launch {//开了一个后台监听任务            repo.devices.collect { list -> //collect 就是专门用来订阅 / 消费 Flow 的终端操作函数，必须和 Flow 配套使用。                _uiState.update { state ->//更新设备信息，UI 会自动跟着刷新                    val ids = list.map { it.devId }.toSet()                    state.copy(                        devices = list,                        //devicesStates = mockStatesOf(list)//这里是模拟设备状态信息，后续补充                        devicesStates = state.devicesStates.filterKeys { it in ids }                    )                }            }        }        // ② 订阅设备事件（Netty 线程抛过来的）        viewModelScope.launch {// 在这个容器里开一个后台任务            DeviceSessionManager.events.collect { event ->                when (event) {                    is DeviceEvent.StateUpdated -> {                        _uiState.update { ui ->                            ui.copy(                                devicesStates = ui.devicesStates + (event.state.devId to event.state)//在现有状态表上，加上或覆盖 设备号 → 这台设备的最新状态 这一条                            )                        }                    }                    is DeviceEvent.Offline -> {                        _uiState.update { ui ->                            ui.copy(devicesStates = ui.devicesStates - event.devId)//删除掉线的仪器编号  val m = mapOf("A" to 1)  则m - "A" // → {}           删除（key 不存在也不报错）                        }                    }                    is DeviceEvent.Online -> { /* 暂不处理，只打日志即可 */ }                }            }        }        // ② 首次启动播种（已有数据则什么都不做）        viewModelScope.launch { repo.loadOrSeed() }    }

// ===== 删除 =====private funmockStatesOf(devices: List<Device>): Map<String, DeviceState> = ...private funmockStateOf(devId: String): DeviceState = ...

 /**     * 恢复出厂设置（0xC3）     *     * UI 抛意图 → PacketBuilder 造帧 → DeviceSessionManager 发出去     * send 返回 false = 这台设备不在线，指令没发出去     */    funresetFactory(devId: String) {        val packet = PacketBuilder.WriteFactorySetCmd(devId)        val ok = DeviceSessionManager.send(devId, packet)        _uiState.update {            it.copy(errorMessage = if (ok) null else "{PacketAnalysis.ReadStateCmd(d)}")