线程池 改写

device-service-infrastructure/src/main/java/com/hfln/device/infrastructure/mqtt/handler/DeviceMessageHandler.java

@@ -99,54 +99,6 @@ public class DeviceMessageHandler {
             } catch (Exception e) {
                 log.error("Error handling message, devId:{}, topic:{}", devId, topic, e);
             }
-//
-//            if (action != null) {
-//                switch (action) {
-//                    case "login":
-//                        handleDeviceLogin(topic, payload);
-//                        break;
-//                    case "keepalive":
-//                        handleDeviceKeepAlive(topic, payload);
-//                        break;
-//                    case "report_device_info":
-//                        handleDeviceReportDeviceInfo(topic, payload);
-//                        break;
-//                    case "report_device_param":
-//                        handleDeviceReportDeviceParam(topic, payload);
-//                        break;
-//                    case "dsp_data":
-//                        handleDeviceDspData(topic, payload);
-//                        break;
-//
-//                    case "disconnect":
-//                        handleDeviceDisconnect(topic, payload);
-//                        break;
-////                    case "cloudpoint":
-////                        // todo 目前没有 lna 设备，暂不考虑点云数据改造
-////                        handleDeviceCloudPoint(topic, payload);
-////                        break;
-////                    case "report_falling_event":
-////                        // todo 这个 主题 待确认是否废弃
-////                        handleDeviceReportFallEvent(topic, payload);
-////                        break;
-////                    case "report_presence_event":
-////                        handleDeviceReportPresenceEvent(topic, payload);
-////                        break;
-////
-////                        // todo 待确认是否废弃
-////                    case "set_debug_param":
-////                        handleSetDebugParam(topic, payload);
-////                        break;
-////                    case "get_debug_param":
-////                        handleGetDebugParam(topic, payload);
-////                        break;
-//                    default:
-//                        log.debug("Unhandled device topic action: {} for topic: {}", action, topic);
-//                        break;
-//                }
-//            } else {
-//                log.debug("Could not extract action from device topic: {}", topic);
-//            }
 
         } catch (Exception e) {
             log.error("Error handling device message: {}", e.getMessage(), e);
@@ -176,25 +128,6 @@ public class DeviceMessageHandler {
                 case "disconnect":
                     handleDeviceDisconnect(topic, payload);
                     break;
-//                    case "cloudpoint":
-//                        // todo 目前没有 lna 设备，暂不考虑点云数据改造
-//                        handleDeviceCloudPoint(topic, payload);
-//                        break;
-//                    case "report_falling_event":
-//                        // todo 这个 主题 待确认是否废弃
-//                        handleDeviceReportFallEvent(topic, payload);
-//                        break;
-//                    case "report_presence_event":
-//                        handleDeviceReportPresenceEvent(topic, payload);
-//                        break;
-//
-//                        // todo 待确认是否废弃
-//                    case "set_debug_param":
-//                        handleSetDebugParam(topic, payload);
-//                        break;
-//                    case "get_debug_param":
-//                        handleGetDebugParam(topic, payload);
-//                        break;
                 default:
                     log.debug("Unhandled device topic action: {} for topic: {}", action, topic);
                     break;