package cn.iocoder.yudao.module.iot.service.rule.scene.timer;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.module.iot.dal.dataobject.device.IotDeviceDO;
import cn.iocoder.yudao.module.iot.dal.dataobject.device.IotDevicePropertyDO;
import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotSceneRuleDO;
import cn.iocoder.yudao.module.iot.enums.rule.IotSceneRuleConditionOperatorEnum;
import cn.iocoder.yudao.module.iot.enums.rule.IotSceneRuleConditionTypeEnum;
import cn.iocoder.yudao.module.iot.service.device.IotDeviceService;
import cn.iocoder.yudao.module.iot.service.device.property.IotDevicePropertyService;
import cn.iocoder.yudao.module.iot.service.rule.scene.IotSceneRuleTimeHelper;
import cn.iocoder.yudao.module.iot.service.rule.scene.matcher.IotSceneRuleMatcherHelper;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.util.Map;

/**
 * IoT 定时触发器条件评估器
 * <p>
 * 与设备触发器不同，定时触发器没有设备消息上下文，
 * 需要主动查询设备属性和状态来评估条件。
 *
 * @author HUIHUI
 */
@Component
@Slf4j
public class IotTimerConditionEvaluator {

    @Resource
    private IotDevicePropertyService devicePropertyService;

    @Resource
    private IotDeviceService deviceService;

    /**
     * 评估条件
     *
     * @param condition 条件配置
     * @return 是否满足条件
     */
    @SuppressWarnings("EnhancedSwitchMigration")
    public boolean evaluate(IotSceneRuleDO.TriggerCondition condition) {
        // 1.1 基础参数校验
        if (condition == null || condition.getType() == null) {
            log.warn("[evaluate][条件为空或类型为空]");
            return false;
        }
        // 1.2 根据条件类型分发到具体的评估方法
        IotSceneRuleConditionTypeEnum conditionType =
                IotSceneRuleConditionTypeEnum.typeOf(condition.getType());
        if (conditionType == null) {
            log.warn("[evaluate][未知的条件类型: {}]", condition.getType());
            return false;
        }

        // 2. 分发评估
        switch (conditionType) {
            case DEVICE_PROPERTY:
                return evaluateDevicePropertyCondition(condition);
            case DEVICE_STATE:
                return evaluateDeviceStateCondition(condition);
            case CURRENT_TIME:
                return evaluateCurrentTimeCondition(condition);
            default:
                log.warn("[evaluate][未知的条件类型: {}]", conditionType);
                return false;
        }
    }

    /**
     * 评估设备属性条件
     *
     * @param condition 条件配置
     * @return 是否满足条件
     */
    private boolean evaluateDevicePropertyCondition(IotSceneRuleDO.TriggerCondition condition) {
        // 1. 校验必要参数
        if (condition.getDeviceId() == null) {
            log.debug("[evaluateDevicePropertyCondition][设备ID为空]");
            return false;
        }
        if (StrUtil.isBlank(condition.getIdentifier())) {
            log.debug("[evaluateDevicePropertyCondition][属性标识符为空]");
            return false;
        }
        if (!IotSceneRuleMatcherHelper.isConditionOperatorAndParamValid(condition)) {
            log.debug("[evaluateDevicePropertyCondition][操作符或参数无效]");
            return false;
        }

        // 2.1 获取设备最新属性值
        Map<String, IotDevicePropertyDO> properties =
                devicePropertyService.getLatestDeviceProperties(condition.getDeviceId());
        if (CollUtil.isEmpty(properties)) {
            log.debug("[evaluateDevicePropertyCondition][设备({}) 无属性数据]", condition.getDeviceId());
            return false;
        }
        // 2.2 获取指定属性
        IotDevicePropertyDO property = properties.get(condition.getIdentifier());
        if (property == null || property.getValue() == null) {
            log.debug("[evaluateDevicePropertyCondition][设备({}) 属性({}) 不存在或值为空]",
                    condition.getDeviceId(), condition.getIdentifier());
            return false;
        }

        // 3. 使用现有的条件评估逻辑进行比较
        boolean matched = IotSceneRuleMatcherHelper.evaluateCondition(
                property.getValue(), condition.getOperator(), condition.getParam());
        log.debug("[evaluateDevicePropertyCondition][设备({}) 属性({}) 值({}) 操作符({}) 参数({}) 匹配结果: {}]",
                condition.getDeviceId(), condition.getIdentifier(), property.getValue(),
                condition.getOperator(), condition.getParam(), matched);
        return matched;
    }

    /**
     * 评估设备状态条件
     *
     * @param condition 条件配置
     * @return 是否满足条件
     */
    private boolean evaluateDeviceStateCondition(IotSceneRuleDO.TriggerCondition condition) {
        // 1. 校验必要参数
        if (condition.getDeviceId() == null) {
            log.debug("[evaluateDeviceStateCondition][设备ID为空]");
            return false;
        }
        if (!IotSceneRuleMatcherHelper.isConditionOperatorAndParamValid(condition)) {
            log.debug("[evaluateDeviceStateCondition][操作符或参数无效]");
            return false;
        }

        // 2.1 获取设备信息
        IotDeviceDO device = deviceService.getDevice(condition.getDeviceId());
        if (device == null) {
            log.debug("[evaluateDeviceStateCondition][设备({}) 不存在]", condition.getDeviceId());
            return false;
        }
        // 2.2 获取设备状态
        Integer state = device.getState();
        if (state == null) {
            log.debug("[evaluateDeviceStateCondition][设备({}) 状态为空]", condition.getDeviceId());
            return false;
        }

        // 3. 比较状态
        boolean matched = IotSceneRuleMatcherHelper.evaluateCondition(
                state.toString(), condition.getOperator(), condition.getParam());
        log.debug("[evaluateDeviceStateCondition][设备({}) 状态({}) 操作符({}) 参数({}) 匹配结果: {}]",
                condition.getDeviceId(), state, condition.getOperator(), condition.getParam(), matched);
        return matched;
    }

    /**
     * 评估当前时间条件
     *
     * @param condition 条件配置
     * @return 是否满足条件
     */
    private boolean evaluateCurrentTimeCondition(IotSceneRuleDO.TriggerCondition condition) {
        // 1.1 校验必要参数
        if (!IotSceneRuleMatcherHelper.isConditionOperatorAndParamValid(condition)) {
            log.debug("[evaluateCurrentTimeCondition][操作符或参数无效]");
            return false;
        }
        // 1.2 验证操作符是否为支持的时间操作符
        IotSceneRuleConditionOperatorEnum operatorEnum =
                IotSceneRuleConditionOperatorEnum.operatorOf(condition.getOperator());
        if (operatorEnum == null) {
            log.debug("[evaluateCurrentTimeCondition][无效的操作符: {}]", condition.getOperator());
            return false;
        }
        if (IotSceneRuleTimeHelper.isTimeOperator(operatorEnum)) {
            log.debug("[evaluateCurrentTimeCondition][不支持的时间操作符: {}]", condition.getOperator());
            return false;
        }

        // 2. 执行时间匹配
        boolean matched = IotSceneRuleTimeHelper.executeTimeMatching(operatorEnum, condition.getParam());
        log.debug("[evaluateCurrentTimeCondition][操作符({}) 参数({}) 匹配结果: {}]",
                condition.getOperator(), condition.getParam(), matched);
        return matched;
    }

}