WingAIDiagnosisService/URMManage/ResultDataIOHelper.cs

using System;
using System.IO;
using System.Runtime.Serialization.Formatters.Binary;
using Vinno.DataManager.Utilities;
using Vinno.DataTypes;

namespace WingAIDiagnosisService.URMManage
{
    public class ResultDataIOHelper
    {

        public static void WriteArrayToFile(string filePath, NativeArray array, int length)
        {
            using (BinaryWriter writer = new BinaryWriter(File.Open(filePath, FileMode.Create)))
            {
                unsafe
                {
                    double* data = (double*)array.Start.ToPointer();
                    for (int i = 0; i < length; i++)
                    {
                        writer.Write(data[i]);
                    }
                }
            }
        }

        public static void WriteByteArrayToFile(string filePath, NativeArray array, int length)
        {
            using (BinaryWriter writer = new BinaryWriter(File.Open(filePath, FileMode.Create)))
            {
                unsafe
                {
                    byte* data = (byte*)array.Start.ToPointer();
                    for (int i = 0; i < length; i++)
                    {
                        writer.Write(data[i]);
                    }
                }
            }
        }

        public static bool WriteURMPointsToFile(string filepath, URMPoint[] points)
        {
            try
            {
                using (FileStream stream = new FileStream(filepath, FileMode.Create, FileAccess.Write, FileShare.None))
                {
                    BinaryFormatter formatter = new BinaryFormatter();
                    formatter.Serialize(stream, points);
                }
                return true;
            }
            catch (Exception e)
            {
                // Console.WriteLine("An error occurred while writing to file: " + e.Message);
                return false;
            }
        }

        public static bool WriteURMPointNumsToFile(string filepath, int[] nums)
        {
            try
            {
                using (FileStream stream = new FileStream(filepath, FileMode.Create, FileAccess.Write, FileShare.None))
                {
                    BinaryFormatter formatter = new BinaryFormatter();
                    formatter.Serialize(stream, nums);
                }
                return true;
            }
            catch (Exception e)
            {
                // Console.WriteLine("An error occurred while writing to file: " + e.Message);
                return false;
            }
        }

        public static NativeArray ReadDoubleArrayFromFile(string filePath, int length)
        {
            NativeArray array = new NativeArray(length * 8);
            using (FileStream stream = new FileStream(filePath, FileMode.Open, FileAccess.Read, FileShare.Read))
            {
                using (BinaryReader reader = new BinaryReader(stream))
                {
                    unsafe
                    {
                        double* data = (double*)array.Start.ToPointer();
                        for (int i = 0; i < length; i++)
                        {
                            data[i] = reader.ReadDouble();
                        }
                    }
                    reader.Close(); // 在这里手动关闭BinaryReader对象
                }
            }
            // using (BinaryReader reader = new BinaryReader(File.Open(filePath, FileMode.Open, FileAccess.Read, FileShare.Read)))
            // {
            //     unsafe
            //     {
            //         double* data = (double*)array.Start.ToPointer();
            //         for (int i = 0; i < length; i++)
            //         {
            //             data[i] = reader.ReadDouble();
            //         }
            //     }
            // }
            return array;
        }

        public static NativeArray ReadByteArrayFromFile(string filePath, int length)
        {
            NativeArray array = new NativeArray(length);
            using (BinaryReader reader = new BinaryReader(File.Open(filePath, FileMode.Open, FileAccess.Read, FileShare.Read)))
            {
                unsafe
                {
                    byte* data = (byte*)array.Start.ToPointer();
                    for (int i = 0; i < length; i++)
                    {
                        data[i] = reader.ReadByte();
                    }
                }
            }
            return array;
        }

        public static URMPoint[] ReadURMPointsFromFile(string filepath)
        {
            try
            {
                using (FileStream stream = new FileStream(filepath, FileMode.Open, FileAccess.Read, FileShare.Read))
                {
                    BinaryFormatter formatter = new BinaryFormatter();
                    return (URMPoint[])formatter.Deserialize(stream);
                }
            }
            catch (Exception e)
            {
                // Console.WriteLine("An error occurred while reading from file: " + e.Message);
                return null;
            }
        }

        public static int[] ReadURMPointNumsFromFile(string filepath)
        {
            try
            {
                using (FileStream stream = new FileStream(filepath, FileMode.Open, FileAccess.Read, FileShare.Read))
                {
                    BinaryFormatter formatter = new BinaryFormatter();
                    return (int[])formatter.Deserialize(stream);
                }
            }
            catch (Exception e)
            {
                // Console.WriteLine("An error occurred while reading from file: " + e.Message);
                return null;
            }
        }
    }
}