using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Drawing;
using System.Drawing.Imaging;
using System.IO;
using System.Linq;
using System.Net;
using System.Timers;
using Dicom.Imaging;
using DicomTool.Model;
using DicomTool.Utils;

namespace DicomTool
{
    internal class Program
    {
        // 设置循环间隔时间为10分钟
        private const int intervalInMinutes = 60;
        // PACS 共享文件访问
        private const string UserName = "XBDLISUser";
        private const string Password = "BlueFlag.Lis!@#";
        // DCM文件下载存放路径
        private static readonly string DcmPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "DicomFiles/");
        private static readonly string EcgPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "EcgFiles/");

        // 188
        //private const string connectionString = "Data Source=192.168.12.188;Initial Catalog=peisdb;User ID=sa;Password=000626;";
        // 盈江妇幼
        // private const string ConnectionString = @"Data Source=172.172.100.12;Initial Catalog=peisdb;User ID=sa;Password=xbdLis!@#77911;";
        // 芒市妇幼
        // private const string ConnectionString = @"Data Source=192.168.11.5;Initial Catalog=peisdb;User ID=XBDLISUser;Password=BlueFlag.Lis!@#;";
        // 德宏中医
        private const string ConnectionString = @"Data Source=200.200.200.71;Initial Catalog=peisdb;User ID=sa;Password=wVJeC28@eY*&F#5NGL^eYC3m;";

        /// <summary>
        /// PACS报告中已选的图片
        /// </summary>
        private const string InsertExamPacsImage =
            @"INSERT INTO Exam_PacsImage (Image,EID,ReportNo,InTime) VALUES (@ImageData,@EID,@ReportNo,@InTime);
              INSERT INTO Report_Pacs(Image, EID, ReportNo, InTime) VALUES(@ImageData, @EID, @ReportNo, @InTime);";
        
        private static void Main(string[] args)
        {
            Console.WriteLine($"【启动】{DateTime.Now:yyyy-MM-dd HH:mm}");
            // 创建一个 Timer 实例
            var timer = new Timer();
            try
            {
                //DownEcgFtpImage();
                Execute();

                Console.ReadKey();
                timer.Interval = intervalInMinutes * 60 * 1000;
                // 设置为 true，使得 Timer 每隔设定的间隔时间自动触发一次 Elapsed 事件
                timer.AutoReset = true;
                // 绑定 Elapsed 事件处理程序
                timer.Elapsed += Timer_Elapsed;
                // 启动 Timer
                timer.Start();
                // 阻止控制台程序退出
                Console.ReadKey();
                // 停止 Timer
                timer.Stop();
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                timer.Stop();
            }

            Console.WriteLine($"【停止】{DateTime.Now:yyyy-MM-dd HH:mm}");
            Console.ReadKey();
        }

        /// <summary>
        /// 定时执行任务
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private static void Timer_Elapsed(object sender, ElapsedEventArgs e)
        {
            Console.WriteLine($@"执行-{DateTime.Now:yyyy-MM-dd HH:mm}");
            DownEcgFtpImage();
            Execute();
            SyncPacsReport();
            //DelDownFiles();
        }

        /// <summary>
        /// 下载选择的
        /// </summary>
        private static void Execute()
        { 
            Console.WriteLine($"【开始同步PACS报告图片】{DateTime.Now:yyyy-MM-dd HH:mm}------------");
            //--将PACS检查报告同步到体检系统中
            if (!Directory.Exists(DcmPath))
            {
                Directory.CreateDirectory(DcmPath);
            } 
            var reportList = PacsSqlHelper.GetPacsReportList();
            var fileNameList = new List<string>();
            int i = 1;
            foreach (var report in reportList)
            {
                try
                {
                    // 已选图片UID
                    var selectedList = PacsSqlHelper.GetReportUidList(report.AccessionNumber);
                    if (selectedList.Count <= 0) continue; 
                    // DCM图片路径
                    var imageFiles = PacsSqlHelper.GetPacsImageFile(report.PatientCode,report.ExamFeeitem_Code); 
                    if (string.IsNullOrEmpty(imageFiles)) continue; 
                    // 得到DCM共享文件地址
                    var dcmPaths = imageFiles.Split(';');
                    // 路径为空
                    if (!(dcmPaths?.Length > 0)) continue;

                    //获取远程共享文件
                    using (var client = new WebClient())
                    {
                        // 配置授权账户密码
                        var credentials = new NetworkCredential(UserName, Password);
                        client.Credentials = credentials;
                        selectedList.ForEach(selected =>
                        {
                            var file = selected + ".DCM";
                            var dcmPacsDict = dcmPaths[0].Substring(dcmPaths[0].Length , file.Length);
                            string downPath = dcmPaths[0].Replace(dcmPacsDict, file);
                            if (Path.HasExtension(downPath))
                            {
                                //下载远程文件
                                var buffer = client.DownloadData(downPath);
                                // 保存本地
                                var name = $"{report.PatientCode?.Trim()}-{report.ExamFeeitem_Code?.Trim()}-" + i;
                                Bytes2File(buffer, DcmPath, $"{name}.DCM");
                                fileNameList.Add($"{name}.DCM");
                                Console.WriteLine($"下载：{name}.DCM");
                                i++;
                            };
                        });
                        // 循环路径
                        for (var index = 0; index < dcmPaths.Count(); index++)
                        {
                            try
                            {
                                // 当前路径
                                var dcmPath = dcmPaths[index];
                                if (string.IsNullOrEmpty(dcmPath)) continue;
                                if (!Path.HasExtension(dcmPath) ) continue;
                                selectedList.ForEach(selected =>
                                {
                                    if (dcmPath.Contains(selected))
                                    {
                                        //下载远程文件
                                        var buffer = client.DownloadData(dcmPath);
                                        // 保存本地
                                        var name = $"{report.PatientCode?.Trim()}-{report.ExamFeeitem_Code?.Trim()}-" + i;
                                        Bytes2File(buffer, DcmPath, $"{name}.DCM");
                                        fileNameList.Add($"{name}.DCM");
                                        Console.WriteLine($"下载：{name}.DCM");
                                        i++;
                                    }
                                });  
                            }
                            catch (Exception e)
                            {
                                Console.WriteLine($"01." + e.Message);
                            }
                        }
                    }
                }
                catch (Exception e)
                {
                    Console.WriteLine($"02." + e.Message);
                }
            }

            Console.WriteLine($@"【下载】{fileNameList.Count}");
            if (fileNameList.Count > 0)
                // 保存到本地后上传到服务器
                UploadDcmImg(DcmPath, fileNameList, InsertExamPacsImage);

            Console.WriteLine($@"【等待】{intervalInMinutes}min");
            Console.WriteLine($"------------------------------------------");
        }

        /// <summary>
        /// 1、将本地文件PACS影像图片发送到服务器
        /// </summary>
        public static void UploadDcmImg(string folderPath, List<string> fileNameList, string insertSql)
        {
            var time = DateTime.Now;
            // 获取文件夹下所有文件的路径
            var files = Directory.GetFiles(folderPath);
            var i = 0;
            // 建立数据库连接
            using (var connection = new SqlConnection(ConnectionString))
            {
                // 遍历文件路径并输出
                foreach (var filePath in files)
                {
                    try
                    {
                        var fileName = System.IO.Path.GetFileName(filePath);
                        if (!fileNameList.Contains(fileName)) continue;
                        var eid = Convert.ToInt64(fileName.Split('-')[0]);
                        var reportNo = fileName.Split('-')[1];
                        var image = new DicomImage(filePath);
                        //image.NumberOfFrames 如果有多帧图片需要将每帧都转成jpeg
                        //DCM转Bitmap
                        var bitmap = image.RenderImage().AsBitmap();
                        using (var streamImg = new MemoryStream())
                        {
                            //Bitmap To byte[]
                            bitmap.Save(streamImg, System.Drawing.Imaging.ImageFormat.Jpeg);
                            var imgBytes = streamImg.ToArray();
                            // File.WriteAllBytes(Path.Combine(DcmPath, i+".jpeg"), imgBytes);
                            //上传
                            {
                                connection.Open();
                                // 创建插入记录的 SQL 查询
                                // 创建命令对象
                                using (var command = new SqlCommand(insertSql, connection))
                                {
                                    // 设置参数值
                                    command.Parameters.AddWithValue("@ImageData", imgBytes);
                                    command.Parameters.AddWithValue("@EID", eid);
                                    command.Parameters.AddWithValue("@ReportNo", reportNo);
                                    command.Parameters.AddWithValue("@InTime", time);

                                    Console.WriteLine($@"【上传】{fileName}");
                                    // 执行插入操作
                                    command.ExecuteNonQuery();
                                    i++;
                                }

                                connection.Close();
                            }
                        } 
                        // 删除上传成功的文件
                        File.Delete(filePath);
                    }
                    catch (Exception e)
                    {
                        Console.WriteLine(System.IO.Path.GetFileName(filePath));
                        Console.WriteLine(e.Message);
                    }
                }
            }

            Console.WriteLine($@"【上传成功】{i}");
        }

        /// <summary>
        /// 将byte数组转换为文件并保存到指定地址
        /// </summary>
        /// <param name="buff">byte数组</param>
        /// <param name="path">保存地址</param>
        /// <param name="fileName"></param>
        public static void Bytes2File(byte[] buff, string path, string fileName)
        {
            try
            {
                //如果不存在就创建Enclosure文件夹 
                if (Directory.Exists(path) == false)
                    Directory.CreateDirectory(path);

                if (File.Exists(path + fileName))
                    File.Delete(path + fileName);

                var fs = new FileStream(path + fileName, FileMode.CreateNew);
                var bw = new BinaryWriter(fs);
                bw.Write(buff, 0, buff.Length);
                bw.Close();
                fs.Close();
            }
            catch (Exception e)
            {
                Console.WriteLine("【下载失败】" + fileName + "--" + e.Message);
            }
        }

        public static void DownEcgFtpImage()
        {
            Console.WriteLine("-----------------------------------");
            Console.WriteLine($"【ECG-START】{DateTime.Now:yyyy-MM-dd HH:mm}");
            var files = DAOHelp.GetDataBySQL<ReportEcg>
                ($@"SELECT id,ReportUrl FROM Report_GSEXD WHERE ReportUrl is not null  and ReportData is null");
            Console.WriteLine("[ECG-ReportCount]" + files.Count);
            if (files.Count == 0)
                return;
            var name = "TJ_HXECG";
            var password = "123456";
            if (!Directory.Exists(EcgPath))
            {
                Directory.CreateDirectory(EcgPath);
            }

            FtpHelper.DownloadFtpFile(files, name, password, EcgPath);
            UploadEcgImg(EcgPath, files.Select(s => s.ID.ToString()).ToList());
            Console.WriteLine("ECG 下载完毕");
            Console.WriteLine($"【ECG-END】{DateTime.Now:yyyy-MM-dd HH:mm}");
            Console.WriteLine("-----------------------------------");
        }

        /// <summary>
        /// 1、将ecg图片发送到服务器
        /// </summary>
        public static void UploadEcgImg(string folderPath, List<string> idList)
        {
            var i = 0;
            // 建立数据库连接
            using (var connection = new SqlConnection(ConnectionString))
            {
                // 遍历文件路径并输出
                foreach (var id in idList)
                {
                    var jpgFilePath = Path.Combine(folderPath, id + ".jpg");
                    try
                    {
                        if (!File.Exists(jpgFilePath))
                        {
                            Console.WriteLine(id + "NotFound" + jpgFilePath);
                            continue;
                        }

                        // 加载JPG图片
                        using (var image = Image.FromFile(jpgFilePath))
                        {
                            // 创建内存流
                            using (MemoryStream memoryStream = new MemoryStream())
                            {
                                // 将图像保存到内存流中，指定图像格式为JPEG
                                image.Save(memoryStream, ImageFormat.Jpeg);
                                // 将内存流中的数据复制到字节数组
                                var imgBytes = memoryStream.ToArray();
                                //上传
                                {
                                    connection.Open();
                                    // 创建插入记录的 SQL 查询
                                    string updateEcgRpt =
                                        @"update Report_GSEXD set ReportData=@ReportData where id=@ID";
                                    // 创建命令对象
                                    using (var command = new SqlCommand(updateEcgRpt, connection))
                                    {
                                        // 设置参数值
                                        command.Parameters.AddWithValue("@ReportData", imgBytes);
                                        command.Parameters.AddWithValue("@ID", id);
                                        Console.WriteLine($@"【上传】{id}.jpg");
                                        // 执行插入操作
                                        command.ExecuteNonQuery();
                                        i++;
                                    }

                                    connection.Close();
                                }
                            }
                        }

                        File.Delete(jpgFilePath);
                    }
                    catch (Exception e)
                    {
                        Console.WriteLine(id + "-" + e.Message);
                    }
                }
            }

            Console.WriteLine($@"【上传成功】{i}");
        }

        public static void SyncPacsReport()
        {
            DAOHelp.ExecuteSql("EXEC sp_PacsRptInsert;");
        }
    }
}