Method submit_request

backend/core.py:1240–1375

提交用户传输请求 - 基于实时资源占用决策

(self, request_data)

        self.decision_trace_buffer.add(_interrupt_trace)

    def submit_request(self, request_data):
        """提交用户传输请求 - 基于实时资源占用决策"""
        with self.lock:
            # 智能选择LEO卫星 - 避免同类型请求集中在一颗卫星
            # 统计各卫星当前负载(相同数据类型的请求数)
            data_type = request_data.get("data_type")
            # ⭐ 支持指定卫星ID
            satellite_id = request_data.get("satellite_id")
            if satellite_id:
                # 查找指定的卫星
                satellite = None
                for sat in self.leo_satellites:
                    if sat.sat_id == satellite_id:
                        satellite = sat
                        break
                if not satellite:
                    # 标准化拒绝结果（结构与正常返回对齐），并补充日志与统计计数
                    reason = f"未找到指定的卫星: {satellite_id}"
                    self.stats["total_requests"] += 1
                    self.stats["user_requests"] += 1
                    self.stats["rejected_requests"] += 1
                    self._record_rejection("SATELLITE_NOT_FOUND")
                    self._log(f"请求被拒绝 - {reason}", level="normal")
                    return {
                        "status": "error",
                        "reject_reason": reason,
                        "error": reason,
                        "available_satellites": [s.sat_id for s in self.leo_satellites],
                    }
            else:
                # 如果没有指定卫星，使用负载均衡选择
                satellite_loads = {}
                for sat in self.leo_satellites:
                    # 统计该卫星上相同类型的活跃请求
                    load = sum(1 for r in self.transmission_requests 
                              if r.satellite_id == sat.sat_id 
                              and r.data_type == data_type
                              and r.status in ["accepted", "transmitting"])
                    satellite_loads[sat.sat_id] = load
                
                # 选择负载最低的卫星(如果有多个则随机选一个)
                min_load = min(satellite_loads.values())
                candidates = [sat for sat in self.leo_satellites if satellite_loads[sat.sat_id] == min_load]
                satellite = self.rng.choice(candidates)
            
            # ⭐ 处理选中的地面站列表（保存到请求对象，供后续调度使用）
            selected_ground_stations = request_data.get("selected_ground_stations", [])
            
            # ⭐ 处理时间段参数
            start_time = request_data.get("start_time")
            end_time = request_data.get("end_time")
            
            # 如果前端传递的是偏移量，则计算实际时间
            start_time_offset = request_data.get("start_time_offset")
            time_window_duration = request_data.get("time_window_duration")
            
            if start_time_offset is not None and time_window_duration is not None:
                # 基于当前仿真时间计算实际时间段