src/iot/thing_manager.py

import json
import logging
from typing import Any, Dict, Tuple, Optional

from src.iot.thing import Thing


class ThingManager:
    _instance = None

    @classmethod
    def get_instance(cls):
        if cls._instance is None:
            cls._instance = ThingManager()
        return cls._instance

    def __init__(self):
        self.things = []
        self.last_states = {}  # 添加状态缓存字典，存储上一次的状态

    def add_thing(self, thing: Thing) -> None:
        self.things.append(thing)

    def get_descriptors_json(self) -> str:
        descriptors = [thing.get_descriptor_json() for thing in self.things]
        return json.dumps(descriptors)

    def get_states_json(self, delta=False) -> Tuple[bool, str]:
        """
        获取所有设备的状态JSON
        
        Args:
            delta: 是否只返回变化的部分，True表示只返回变化的部分
            
        Returns:
            Tuple[str, bool]: 返回JSON字符串和是否有状态变化的布尔值
        """
        if not delta:
            self.last_states.clear()
        
        changed = False
        states = []
        
        for thing in self.things:
            state_json = thing.get_state_json()
            
            if delta:
                # 检查状态是否变化
                is_same = (thing.name in self.last_states and
                           self.last_states[thing.name] == state_json)
                if is_same:
                    continue
                changed = True
                self.last_states[thing.name] = state_json
            
            # 检查state_json是否已经是字典对象
            if isinstance(state_json, dict):
                states.append(state_json)
            else:
                states.append(json.loads(state_json))  # 转换JSON字符串为字典
        
        return changed, json.dumps(states)

    def get_states_json_str(self) -> str:
        """
        为了兼容旧代码，保留原来的方法名和返回值类型
        """
        _, json_str  = self.get_states_json(delta=False)
        return json_str

    def invoke(self, command: Dict) -> Optional[Any]:
        """
        调用设备方法
        
        Args:
            command: 包含name和method等信息的命令字典
            
        Returns:
            Optional[Any]: 如果找到设备并调用成功，返回调用结果；否则抛出异常
        """
        thing_name = command.get("name")
        for thing in self.things:
            if thing.name == thing_name:
                return thing.invoke(command)
        
        # 记录错误日志
        logging.error(f"设备不存在: {thing_name}")
        raise ValueError(f"设备不存在: {thing_name}")