Method _evaluate_request

backend/core.py:1482–1613

评估请求是否可以被接受 - 基于实时资源利用率和时间段决策

(self, req, satellite)

        return True, "时间段资源可用"

    def _evaluate_request(self, req, satellite):
        """评估请求是否可以被接受 - 基于实时资源利用率和时间段决策"""

        # ⭐ 实验要求：测试模式下，放宽资源检查
        if req.test_mode:
            # 测试模式：直接接受，用于快速验证功能
            return True, "测试模式：直接接受"

        # 特殊处理：指令类型（TASK_CMD）立即接受，无需等待过境
        data_config = DATA_TYPES.get(req.data_type, {})
        if data_config.get("immediate", False):
            # 指令类型直接接受，稍后会自动寻找传输机会
            return True, "指令类型立即接受"

        # ⭐ QoS 与安全级准入检查（在时间窗口与资源检查之前执行）
        qos_ctrl = QosAdmissionController(self)
        qos_ok, qos_reason = qos_ctrl.check_admission(req)
        if not qos_ok:
            # 将拒绝原因码记录到统计中，并直接返回
            for code, msg in REJECTION_REASONS.items():
                if msg == qos_reason:
                    self._record_rejection(code)
                    break
            return False, qos_reason

        # ⭐ 新增：检查用户指定的时间段
        if req.start_time is not None and req.end_time is not None:
            # 用户指定了具体时间段，需要检查资源池可用性
            time_check_result = self._check_time_window_resources(req, satellite)
            if not time_check_result[0]:
                self._record_rejection("TIME_WINDOW_CONFLICT")
                return False, time_check_result[1]
        
        # 第0步：检查资源利用率阈值
        # 如果系统资源紧张，对低优先级请求（特别是背景任务）更严格
        resource_util = self.stats["resource_utilization"]
        avg_utilization = (resource_util["satellites"] + resource_util["ground_stations"] + resource_util["geo_relays"]) / 3
        
        # ⭐ 实验要求：自定义约束 - 强制中继
        force_relay = req.custom_constraints.get("force_relay", False)
        
        # 资源紧张阈值判断
        RESOURCE_TIGHT_THRESHOLD = CFG_RESOURCE_TIGHT_THRESHOLD  # 资源紧张阈值（见 config）
        if avg_utilization > RESOURCE_TIGHT_THRESHOLD:
            # 背景任务在资源紧张时更容易被拒绝
            if req.source == "background" and req.priority < 5:  # 只拒绝低优先级背景任务
                return False, f"系统资源紧张(利用率{avg_utilization*100:.1f}%),背景任务暂停"
            # 用户低优先级请求也可能被拒绝（但阈值更低）
            elif req.source == "user" and req.priority < 2:  # 只拒绝优先级<2的用户请求
                return False, f"系统资源紧张(利用率{avg_utilization*100:.1f}%),低优先级请求拒绝"
        
        # 第1步：检查卫星资源是否已被占用
        if satellite.sat_id in self.resource_usage["satellites"] and len(self.resource_usage["satellites"][satellite.sat_id]) > 0:
            return False, f"卫星{satellite.sat_id}资源已被占用"
        
        sat_pos = self.get_satellite_position(satellite)
        
        # ⭐ 实验要求：自定义约束 - 指定地面站