2026.4.9

feiyu02

7 天以前 594de76ed51fd49fb79b912212bb0052a63e7671

 src/main/kotlin/com/flightfeather/uav/socket/handler/UnderwayWebSocketServerHandler.kt

@@ -28,24 +28,27 @@
    }

    override fun channelRead(ctx: ChannelHandlerContext?, msg: Any?) {
        super.channelRead(ctx, msg)
//        super.channelRead(ctx, msg)
        when (msg) {
            is TextWebSocketFrame -> {
                val msgTxt = msg.text()

                println(msgTxt)
//                ctx?.channel()?.writeAndFlush(msg)

                // Test
                try {
                    if (msgTxt == "start") {
                        sourceTraceController.initTask()
                    } else {
                        val data = GsonUtils.parserJsonToArrayBeans(msgTxt, DataVo::class.java)
                        data.forEach {
                            sourceTraceController.addOneData(
                                it.toBaseRealTimeData(BaseRealTimeData::class.java)
                            )
                    when (msgTxt) {
                        "start" -> {
                            sourceTraceController.initTask()
                            println(msgTxt)
                        }
                        "ping" -> {
                            ctx?.channel()?.writeAndFlush(TextWebSocketFrame("ping checked"))
                        }
                        else -> {
                            println(msgTxt)
                            val data = GsonUtils.parserJsonToArrayBeans(msgTxt, DataVo::class.java)
                            data.forEach {
                                sourceTraceController.addOneData(
                                    it.toBaseRealTimeData(BaseRealTimeData::class.java)
                                )
                            }
                        }
                    }
                } catch (e: Exception) {