SimulationServerYL/SimulationServer/Entity/AircraftXCJJ.cs

using BHJD.DEMdll.Entity;
using KYFramework;
using MathNet.Numerics.Distributions;
using Model;
using MongoDB.Bson;
using SimulationCommon;
using SimulationServer.Utils;

namespace SimulationServer;

public class AircraftXCJJ : AircraftEntity
{
    public XCJJTask taskContent;
    public MissionEndPoint MissionEndPoint;
    public bool IsOver;
    public bool Success;
    public TaskParameter taskParameter;
    public MissionEndPoint hospitalPoint;

    public List<double> jiuzhuTimes = new List<double>();

    public Dictionary<string, string> reportInfo = new Dictionary<string, string>();

    public TaskLoad load;
    public string device;
    public string medicine;

    public string hospitalAirport;

    private Dictionary<string, DiseaseInfo> diseaseDatabase = new Dictionary<string, DiseaseInfo>();

    public override void End()
    {
        TotalFuelConsumption = TurningPoints[0].RemainingFuel - TurningPoints[^1].RemainingFuel;
    }

    public override void Reset()
    {
        base.Reset();
        IsOver = false;
        Success = false;
        TotalTime = 0;
        reportInfo = new Dictionary<string, string>();
        device = string.Empty;
        medicine = string.Empty;
        jiuzhuTimes = new List<double>();
        diseaseDatabase = new Dictionary<string, DiseaseInfo>();
    }

    public override void Start()
    {
        for (int i = 1; i < 19; i++)
        {
            string s = Utils.Util.GetYL(i.ToString());
            string[] r = s.Split('-');
            diseaseDatabase.Add(r[0], new DiseaseInfo { MinGoldenHour = Convert.ToDouble(r[1]), MaxGoldenHour = Convert.ToDouble(r[2]), Priority = Convert.ToDouble(r[3]), RescueTime = Convert.ToDouble(r[4]) });
        }

        //foreach (var item in diseaseDatabase)
        //{
        //    Console.WriteLine("疾病类型:" + item.Key);
        //    Console.WriteLine("最小黄金救援时间:" + item.Value.MinGoldenHour);
        //    Console.WriteLine("最大黄金救援时间:" + item.Value.MaxGoldenHour);
        //    Console.WriteLine("优先级:" + item.Value.Priority);
        //    Console.WriteLine("抢救时间:" + item.Value.RescueTime);
        //}

        FlightPlanEditor.missionpoint.MissionPointLatitude = FlightPlanEditor.medicalTargetPoint[0].TargetPointLatitude;
        FlightPlanEditor.missionpoint.MissionPointLongitude = FlightPlanEditor.medicalTargetPoint[0].TargetPointLongitude;
        FlightPlanEditor.missionpoint.MissionPointHeight = FlightPlanEditor.medicalTargetPoint[0].TargetPointHeight;

        //Console.WriteLine("Latitude:" + FlightPlanEditor.missionpoint.MissionPointLatitude + "_" + "Longitude:" + FlightPlanEditor.missionpoint.MissionPointLongitude + "_" + "Height:" + FlightPlanEditor.missionpoint.MissionPointHeight);

        int patientCount = FlightPlanEditor.medicalTargetPoint[0].TargetType.Count; // 伤患人数
        List<string> diseaseTypes = new List<string>();
        for (int i = 0; i < FlightPlanEditor.medicalTargetPoint[0].TargetType.diseaseTypes.Length; i++)
        {
            diseaseTypes.Add(FlightPlanEditor.medicalTargetPoint[0].TargetType.diseaseTypes[i]);
        }
        int medicCount = taskParameter.doctorPersonnel + taskParameter.nursePersonnel + taskParameter.nurseSeverePersonnel;//taskParameter.MedicalStaffCount; // 医护人员数量  

        //Console.WriteLine("medicCount:" + medicCount);

        // 交接时间为5分钟  
        double handoverTime = 5;

        // 计算总急救时间   需要飞机停留时间
        double totalEmergencyTime = CalculateTotalEmergencyTime(diseaseTypes);

        // 计算平均急救时间（每个医护人员分担的时间）  
        double averageEmergencyTimePerMedic = totalEmergencyTime / medicCount;

        // 计算总时间（平均急救时间 + 交接时间）  
        double totalTime = averageEmergencyTimePerMedic + handoverTime;

        Console.WriteLine($"总急救时间（平均每个医护人员）: {averageEmergencyTimePerMedic} 分钟");
        Console.WriteLine($"总时间（包括交接时间）: {totalTime} 分钟");

        Random rand = new Random();
        List<Patient> patients = new List<Patient>();
        for (int i = 0; i < patientCount; i++)
        {
            patients.Add(new Patient()
            {
                Id = i + 1,
                DiseaseType = diseaseTypes[i],
                GoldenHour = 0
            });
        }

        patients = ProcessPatients(patients, rand);

        // 对患者进行排序  
        var sortedPatients = patients.OrderBy(p => GetPriority(p.DiseaseType))
                                    .ThenBy(p => p.GoldenHour)
                                    .ToList();

        // 输出排序后的患者列表    // 从是事故点到医院的飞行时间 + 5分钟的交接时间 < 黄金时间 ? 成功:失败
        foreach (var patient in sortedPatients)
        {
            Console.WriteLine($"sortedPatients ID: {patient.Id}, Disease: {patient.DiseaseType}, Golden Hour: {patient.GoldenHour:F2}");
        }

        // 注意：实际项目中，每次转运一名伤员的操作可能涉及更多的逻辑，比如更新数据库中的转运状态等。  


        FXJHGenerate.FromStartToMission(FlightPlanEditor, ref TurningPoints);//生成从起点到任务段起点的航路点
        FXJHGenerate.JIJIU(totalTime, FlightPlanEditor, ref TurningPoints);
        FXJHGenerate.JIJIU1(5 * 60, hospitalPoint, ref TurningPoints);

        for (int i = 0; i < FlightPlanEditor.medicalTargetPoint[0].TargetType.Count - 1; i++)
        {
            FXJHGenerate.JIJIU(5 * 60, FlightPlanEditor, ref TurningPoints);
            FXJHGenerate.JIJIU1(5 * 60, hospitalPoint, ref TurningPoints);
        }

        FXJHGenerate.FromMissionToEnd(FlightPlanEditor, hospitalPoint, ref TurningPoints);
        FXJHGenerate.FXJHTPDiedai(FlightPlanEditor, ref TurningPoints, Velocitys, FuelConsumptions);

        double time = 0;
        for (int i = 2; i < 5; i++)
        {
            time += TurningPoints[i].SegmentFlightTime;
        }
        jiuzhuTimes.Add(time);

        int p = 5;
        int c = 0;
        for (int i = p; i < FlightPlanEditor.medicalTargetPoint[0].TargetType.Count * 4 + 1; i++)
        {
            time += TurningPoints[i].SegmentFlightTime;
            c++;
            if (c == 4)
            {
                jiuzhuTimes.Add(time);
                c = 0;
            }
        }

        double chl = 0;
        for (int i = 0; i < jiuzhuTimes.Count; i++)
        {
            if (jiuzhuTimes[i] < sortedPatients[i].GoldenHour * 60)
            {
                chl++;
            }
            //Console.WriteLine("救助时间:" + jiuzhuTimes[i] + " 黄金救援时间:" + sortedPatients[i].GoldenHour * 60);
        }
        //Console.WriteLine("存活率:" + chl / sortedPatients.Count);
        for (int i = 0; i < TurningPoints.Count; i++) // 总飞行时间
        {
            TotalTime += TurningPoints[i].SegmentFlightTime; // 总时间   //仿真轮次1 数值1
        }
        Console.WriteLine("TotalTime:" + TotalTime);

        reportInfo.Add("准备时间", TaskReadyTime.ToString());

        double reachTime = 0;
        for (int i = 0; i < 2; i++)
        {
            reachTime += TurningPoints[i].SegmentFlightTime;
        }
        reportInfo.Add("到达时间", reachTime.ToString()); // 基地 -> 目标点

        reportInfo.Add("任务周期时间", TotalTime.ToString());
        if (sortedPatients.Count != 0)
            reportInfo.Add("存活率", (chl / sortedPatients.Count).ToString());
        else
            reportInfo.Add("存活率", "0");
        reportInfo.Add("执行任务飞机型号", Name);
        reportInfo.Add("执行任务飞机数量", "1");
        reportInfo.Add("单机飞行员人数", taskParameter.pilotPersonnel.ToString());
        reportInfo.Add("单机医师人数", taskParameter.doctorPersonnel.ToString());
        reportInfo.Add("单机护士人数", taskParameter.nursePersonnel.ToString());
        reportInfo.Add("单机重症监护护理人员人数", taskParameter.nurseSeverePersonnel.ToString());
        reportInfo.Add("单机地面保障人数", taskParameter.groundSupportPersonnel.ToString());
        reportInfo.Add("单机总任务时长", TotalTime.ToString());
        reportInfo.Add("单机总油耗", FXJHGenerate.CalculateTotalFuelConsumption(FlightPlanEditor, TurningPoints).ToString());
        reportInfo.Add("单机机场使用情况", Airport + "\r\n" + hospitalAirport);

        double zhc = 0;
        for (int i = 0; i < TurningPoints.Count - 1; i++)
        {
            zhc += Utils.Util.GetDistance(TurningPoints[i].TurningPointLongitude,
                    TurningPoints[i + 1].TurningPointLongitude, TurningPoints[i].TurningPointLatitude, TurningPoints[i + 1].TurningPointLatitude);
        }
        reportInfo.Add("单机导航使用情况", zhc.ToString()); //飞行总距离
        if (load.FirstAid != null)
        {
            for (int i = 0; i < load.FirstAid.Length; i++)
            {
                device += load.FirstAid[i];
                device += "\r\n";
            }
        }
        if (load.HandlingAndFixing != null)
        {
            for (int i = 0; i < load.HandlingAndFixing.Length; i++)
            {
                device += load.HandlingAndFixing[i];
                device += "\r\n";
            }
        }
        if (load.DiagnosisAndMonitoring != null)
        {
            for (int i = 0; i < load.DiagnosisAndMonitoring.Length; i++)
            {
                device += load.DiagnosisAndMonitoring[i];
                device += "\r\n";
            }
        }
        if (load.Trauma != null)
        {
            for (int i = 0; i < load.Trauma.Length; i++)
            {
                device += load.Trauma[i];
                device += "\r\n";
            }
        }
        if (load.Infusion != null)
        {
            for (int i = 0; i < load.Infusion.Length; i++)
            {
                device += load.Infusion[i];
                device += "\r\n";
            }
        }
        if (load.Drug != null)
        {
            for (int i = 0; i < load.Drug.Length; i++)
            {
                medicine += load.Drug[i];
                if (i != load.Drug.Length - 1)
                    medicine += "\r\n";
            }
        }
        char[] cs = { '\r', '\n' };
        device = device.TrimEnd(cs);
        //Console.WriteLine("医疗任务设备:" + device);
        //Console.WriteLine("医疗药品:" + medicine);
        if (device != null)
            reportInfo.Add("医疗任务设备", device);
        else
            reportInfo.Add("医疗任务设备", "");
        if (medicine != null)
            reportInfo.Add("医疗药品", medicine);
        else
            reportInfo.Add("医疗药品", "");
        reportInfo.Add("任务缓急情况", "紧急");

        IsOver = true;
        End();
    }

    public double CalculateTotalEmergencyTime(List<string> diseaseTypes)
    {
        double totalTime = 0;

        // 这里假设有一个方法GetEmergencyTimeFromDatabase，它根据疾病类型从数据库获取急救时间，此处应为从数据库中读取
        foreach (var diseaseType in diseaseTypes)
        {
            double emergencyTime = GetEmergencyTimeFromDatabase(diseaseType);
            totalTime += emergencyTime;
        }

        return totalTime;
    }

    // 模拟从数据库获取急救时间的方法  
    public double GetEmergencyTimeFromDatabase(string diseaseType)
    {
        if (diseaseDatabase.ContainsKey(diseaseType))
        {
            return diseaseDatabase[diseaseType].RescueTime;
        }
        throw new ArgumentException("Unknown disease type.");
    }

    // 假设从前端接收到的数据结构  
    public class Patient
    {
        public int Id { get; set; }
        public string DiseaseType { get; set; }
        public double GoldenHour { get; set; } // 患者的黄金救援时间应由黄金救援时间程序获得
    }

    public class DiseaseInfo
    {
        public double MinGoldenHour { get; set; }
        public double MaxGoldenHour { get; set; }

        public double Priority { get; set; }
        public double RescueTime { get; set; }
    }

    public List<Patient> ProcessPatients(List<Patient> patients, Random rand)
    {
        foreach (var patient in patients)
        {
            var diseaseInfo = GetDiseaseInfo(patient.DiseaseType); // MinGoldenHour MaxGoldenHour 数据库读取
            double goldenHour = GenerateRandomGoldenHour(rand, diseaseInfo.MinGoldenHour, diseaseInfo.MaxGoldenHour);
            Console.WriteLine($"Patient ID: {patient.Id}, Disease: {patient.DiseaseType}, Golden Hour: {goldenHour:F2}");
            patient.GoldenHour = goldenHour;
        }
        return patients;
    }

    public DiseaseInfo GetDiseaseInfo(string diseaseType)
    {
        if (diseaseDatabase.ContainsKey(diseaseType))
        {
            return diseaseDatabase[diseaseType];
        }
        throw new ArgumentException("Unknown disease type.");
    }

    public static double GenerateRandomGoldenHour(Random rand, double min, double max)
    {
        double mu = (max + min) / 2;
        double sigma = (max - min) / 6;
        var normal = new Normal(mu, sigma);
        return normal.Sample();
    }

    public double GetPriority(string diseaseType)
    {
        if (diseaseDatabase.ContainsKey(diseaseType))
        {
            return diseaseDatabase[diseaseType].Priority;
        }
        throw new ArgumentException("Unknown disease type.");
    }

    public string TargetQiXiangInfoSave(string s, int hour)
    {
        string result = hour.ToString() + "-" + s;
        for (int i = 0; i < FlightPlanEditor.medicalTargetPoint[0].TargetQiXiangInfos.Length; i++)
        {

        }
        switch (s)
        {
            case "温度":

                break;
            case "湿度":

                break;
            case "能见度":

                break;
            case "风速":

                break;
            case "风向":

                break;
            case "天气":

                break;
        }
        return result;
    }
}

[ObjectSystem]
public class AircraftXCJJAwakeSystem : AwakeSystem<AircraftXCJJ, FlightPlanEditor>
{
    public override void Awake(AircraftXCJJ self, FlightPlanEditor flightPlanEditor)
    {
        self.FlightPlanEditor = flightPlanEditor;
        self.Awake();
    }
}