Method _update_resource_utilization

backend/core.py:709–763

更新资源利用率统计 - 基于带宽的精确算法

(self)

                self.stats["rejected_requests"] += 1
    
    def _update_resource_utilization(self):
        """更新资源利用率统计 - 基于带宽的精确算法"""
        
        # ⭐ 新算法：
        # 1. 卫星: 只要有请求分配(包括等待)就算占用
        # 2. 地面站: 只统计正在传输(transmitting)的请求
        # 3. 中继: 基于带宽占用率计算，一个中继可以同时服务多个任务
        
        # 计算卫星利用率 - 包括等待和传输中的请求
        total_satellites = len(self.leo_satellites)
        occupied_satellites = sum(1 for sat_id, req_list in self.resource_usage["satellites"].items() if len(req_list) > 0)
        self.stats["resource_utilization"]["satellites"] = (occupied_satellites / total_satellites) if total_satellites > 0 else 0.0
        
        # 计算地面站利用率 - 仅统计正在传输的请求
        total_ground_stations = len(self.ground_stations)
        transmitting_ground_stations = set()
        for req in self.transmission_requests:
            if req.status == "transmitting" and req.selected_ground_station:
                transmitting_ground_stations.add(req.selected_ground_station)
        self.stats["resource_utilization"]["ground_stations"] = (len(transmitting_ground_stations) / total_ground_stations) if total_ground_stations > 0 else 0.0
        
        # ⭐ 计算GEO中继带宽利用率 - 基于实际带宽占用
        # 每个中继有固定带宽（2000 Mbps），统计所有正在传输的任务占用的带宽
        relay_bandwidth_usage = {}  # {relay_id: used_bandwidth}
        
        for req in self.transmission_requests:
            if req.status == "transmitting":
                # 检查第一跳中继
                if req.selected_relay:
                    if req.selected_relay not in relay_bandwidth_usage:
                        relay_bandwidth_usage[req.selected_relay] = 0
                    relay_bandwidth_usage[req.selected_relay] += req.transmission_rate
                
                # 检查第二跳中继
                if req.selected_relay2:
                    if req.selected_relay2 not in relay_bandwidth_usage:
                        relay_bandwidth_usage[req.selected_relay2] = 0
                    relay_bandwidth_usage[req.selected_relay2] += req.transmission_rate
        
        # 计算平均带宽利用率
        total_geo_relays = len(self.geo_relays)
        if total_geo_relays > 0:
            total_bandwidth_utilization = 0
            for geo in self.geo_relays:
                relay_bandwidth = geo.get("bandwidth", 1600)  # 默认1600 Mbps
                used_bandwidth = relay_bandwidth_usage.get(geo["id"], 0)
                utilization = min(1.0, used_bandwidth / relay_bandwidth) if relay_bandwidth > 0 else 0
                total_bandwidth_utilization += utilization
            
            self.stats["resource_utilization"]["geo_relays"] = total_bandwidth_utilization / total_geo_relays
        else:
            self.stats["resource_utilization"]["geo_relays"] = 0.0
        
        # ⭐ 保存详细的中继带宽使用情况，供前端显示
        self.stats["relay_bandwidth_usage"] = relay_bandwidth_usage
    
    def _update_decision_metrics(self):
        """⭐ 更新决策指标统计"""