# Java类与Python文件映射关系 ## 领域层 (device-service-domain) ### 实体类 (entity) | Java类 | Python文件 | 说明 | |--------|------------|------| | `Device.java` | `dev_mng.py` | 设备实体类,对应Python版本中的Device类。包含设备属性、状态管理和业务规则 | | `Region.java` | `dev_mng.py` | 区域实体类,对应Python版本中的监测区域相关代码 | | `AlarmPlan.java` | `dev_mng.py` | 告警计划实体类,对应Python版本中的AlarmPlan类 | ### 值对象 (vo) | Java类 | Python文件 | 说明 | |--------|------------|------| | `BehaviorPattern.java` | `dev_mng.py` | 行为模式值对象,Python中分散在dev_mng.py的多个函数中 | | `PoseAnalysisResult.java` | `dev_mng.py` | 姿态分析结果值对象,Python中通过字典表示 | | `TargetPoint.java` | `dev_mng.py` | 目标点值对象,Python中用list表示 | ### 服务 (service) | Java类 | Python文件 | 说明 | |--------|------------|------| | `AlarmService.java` | `dev_mng.py` | 告警服务接口,对应Python版本中的告警处理函数 | | `AlarmServiceImpl.java` | `dev_mng.py` | 告警服务实现,对应Python中分散在dev_mng.py的告警处理逻辑 | | `DeviceManagerService.java` | `dev_mng.py` | 设备管理服务接口,对应Python版本中设备管理相关函数 | | `DeviceManagerServiceImpl.java` | `dev_mng.py` | 设备管理服务实现,对应Python中的设备管理全局函数 | | `DeviceStatusService.java` | `dev_mng.py` | 设备状态服务,对应Python中的check_dev_keepalive等函数 | | `DeviceConfigService.java` | `dev_mng.py` | 设备配置服务,对应Python中的设备配置更新函数 | | `PointCloudProcessService.java` | `post_process.py` | 点云处理服务,对应Python中的点云数据处理逻辑 | | `BehaviorAnalysisService.java` | `post_process.py` | 行为分析服务,对应Python中的行为分析相关代码 | ### 网关接口 (gateway) | Java类 | Python文件 | 说明 | |--------|------------|------| | `DeviceGateway.java` | `dev_mng.py`/`db_process.py` | 设备网关接口,对应Python中的设备数据库操作 | | `MqttGateway.java` | `mqtt_send.py` | MQTT网关接口,对应Python中的MQTT消息发送逻辑 | ### 事件 (event) | Java类 | Python文件 | 说明 | |--------|------------|------| | `EventHandler.java` | `mqtt_recv.py` | 事件处理器接口,对应Python中的事件处理函数 | | `DeviceEvent.java` | `mqtt_recv.py` | 设备事件基类,Python中没有明确对应,通过消息字典表示 | | `FallEvent.java` | `mqtt_recv.py` | 跌倒事件,对应Python中的deal_report_falling_event函数 | | `PresenceEvent.java` | `mqtt_recv.py` | 存在事件,对应Python中的deal_report_presence_event函数 | | `RetentionEvent.java` | `mqtt_recv.py` | 滞留事件,对应Python中的滞留相关处理函数 | ### 端口 (port) | Java类 | Python文件 | 说明 | |--------|------------|------| | `DeviceEventPort.java` | `mqtt_recv.py` | 设备事件接口,定义了与外部系统交互的契约 | ### 常量 (constant) | Java类 | Python文件 | 说明 | |--------|------------|------| | `BehaviorConstants.java` | `mydef.py` | 行为常量,对应Python中的姿态和行为相关常量 | | `EventConstants.java` | `mydef.py` | 事件常量,对应Python中的事件类型常量 | ## 应用层 (device-service-application) ### 服务 (service) | Java类 | Python文件 | 说明 | |--------|------------|------| | `DeviceEventService.java` | `mqtt_recv.py` | 设备事件服务接口,对应Python中的MQTT消息处理函数 | | `DeviceEventServiceImpl.java` | `mqtt_recv.py` | 设备事件服务实现,协调领域对象处理设备事件 | | `DeviceCommandService.java` | `mqtt_send.py` | 设备命令服务接口,对应Python中的命令发送函数 | | `DeviceCommandServiceImpl.java` | `mqtt_send.py` | 设备命令服务实现,处理设备命令发送 | | `DeviceMonitorServiceImpl.java` | `dev_mng.py` | 设备监控服务,对应Python中的设备状态监控相关代码 | ### 任务 (task) | Java类 | Python文件 | 说明 | |--------|------------|------| | `AlarmPlanCheckTask.java` | `dev_mng.py` | 告警计划检查任务,对应Python中的check_all_dev_alarm_plan函数 | | `DeviceStatusCheckTask.java` | `dev_mng.py` | 设备状态检查任务,对应Python中的check_dev_keepalive等函数 | ### 事件 (event) | Java类 | Python文件 | 说明 | |--------|------------|------| | `EventHandlerImpl.java` | `mqtt_recv.py` | 事件处理器实现,对应Python中的各种事件处理函数 | ## 基础设施层 (device-service-infrastructure) ### MQTT (mqtt) | Java类 | Python文件 | 说明 | |--------|------------|------| | `MqttSubscriberProcessor.java` | `mqtt_process.py` | MQTT订阅处理器,对应Python中的消息处理机制 | | `MqttSubscriberHandler.java` | `mqtt_process.py` | MQTT订阅处理器,负责消息路由 | | `DeviceMessageSubscriber.java` | `mqtt_recv.py` | 设备消息订阅处理器,对应Python中的deal_dev_msg函数 | | `AppMessageSubscriber.java` | `mqtt_recv.py` | 应用消息订阅处理器,对应Python中的app相关处理函数 | | `DasMessageSubscriber.java` | `mqtt_recv.py` | DAS消息订阅处理器,对应Python中的deal_das_msg函数 | | `OpcMessageSubscriber.java` | `mqtt_recv.py` | OPC消息订阅处理器,对应Python中的deal_opc_msg函数 | | `MpsMessageSubscriber.java` | `mqtt_recv.py` | MPS消息订阅处理器,对应Python中的deal_mps_msg函数 | ### 网关实现 (gateway) | Java类 | Python文件 | 说明 | |--------|------------|------| | `DeviceGatewayImpl.java` | `db_process.py` | 设备网关实现,对应Python中的数据库操作函数 | | `MqttGatewayImpl.java` | `mqtt_send.py` | MQTT网关实现,对应Python中的MQTT消息发送函数 | ### 服务实现 (service) | Java类 | Python文件 | 说明 | |--------|------------|------| | `DevInfoServiceImpl.java` | `dev_mng.py`/`db_process.py` | 设备信息服务实现,对应Python中的设备数据库操作 | ## 公共层 (device-service-common) ### 常量 (constant) | Java类 | Python文件 | 说明 | |--------|------------|------| | `mqtt.topic.MqttTopics.java` | `mydef.py` | MQTT主题常量,对应Python中的TOPICS常量 | | `DeviceErrorCode.java` | `mydef.py` | 设备错误码,对应Python中的DEV_EC常量 | ### 工具类 (util) | Java类 | Python文件 | 说明 | |--------|------------|------| | `TimeUtil.java` | `mydef.py` | 时间工具类,对应Python中的时间相关函数 | | `JsonUtil.java` | 无直接对应 | JSON工具类,Python中直接使用json模块 | | `PointCloudUtil.java` | `post_process.py` | 点云工具类,对应Python中的点云处理函数 | | `TopicUtil.java` | `mydef.py` | 主题工具类,对应Python中的Topic_Pattern相关代码 |