using DS.WMS.PrintApi.Model;
using DS.WMS.PrintApi.Utils;
using FastReport.Data.JsonConnection;
using FastReport.Export.OoXML;
using FastReport.Export.Pdf;
using System.IO;
using System.Text;
using System;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc.Rendering;
using SqlSugar;
using static System.Net.Mime.MediaTypeNames;
using System.Collections.Generic;
using Newtonsoft.Json;
using Microsoft.Extensions.DependencyInjection;
using DS.WMS.PrintApi.Middleware;
using Newtonsoft.Json.Schema;
using Microsoft.AspNetCore.Mvc;
using System.Linq;
using System.Data;
using System.Dynamic;

namespace DS.WMS.PrintApi.Service
{
    public class OpenPrintService : IOpenPrintService
    {

        private readonly IServiceProvider _serviceProvider;
        private readonly ISqlSugarClient db;
        private readonly ISaasDbService saasService;
        /// <summary>
        ///
        /// </summary>
        /// <param name="serviceProvider"></param>
        public OpenPrintService(IServiceProvider serviceProvider)
        {
            _serviceProvider = serviceProvider;
            db = _serviceProvider.GetRequiredService<ISqlSugarClient>();
            saasService = _serviceProvider.GetRequiredService<ISaasDbService>();
        }
        public async Task<PrintDataResult> GetOpenJsonPrintInfo(OpenJsonPrintReq req)
        {
            try
            {
                var template = db.Queryable<SysPrintTemplate>().Filter(null, true).Where(x => x.Id == req.TemplateId).First();
                if (template == null)
                {
                    return await Task.FromResult(PrintDataResult.Failed("打印模板不存在!"));
                }
                if (template.IsUseDataSource)
                {
                    return await Task.FromResult(PrintDataResult.Failed("非Json打印接口!"));
                }
                if (String.IsNullOrEmpty(template.PrintJsonContent))
                {
                    return await Task.FromResult(PrintDataResult.Failed("打印模板内容不能为空!"));
                }
                try
                {
                    var basePath = String.Empty;
                    var savePath = "wwwroot/PrintTempFile";

                    var fileName = DateTime.Now.Ticks + "-" + NumUtil.GetRandomString(3);
                    var printFileName = $"{fileName}.frx";
                    var printFile = Path.Combine(savePath, printFileName);

                    //写入CRX文件
                    using (FileStream fs = new FileStream(printFile, FileMode.Create))
                    {
                        Byte[] info = new UTF8Encoding(true).GetBytes(template.PrintJsonContent);
                        fs.Write(info, 0, info.Length);
                    }

                    //生成报表
                    FastReport.Report report = new FastReport.Report();
                    report.Load(printFile);

                    //var dataSource = report.Dictionary.Connections[0] as JsonDataSourceConnection;
                    //var str = new FastReport.Data.JsonConnection.JsonDataSourceConnectionStringBuilder();
                    //str.Json = req.JsonDataStr;
                    //dataSource.ConnectionString = str.ConnectionString;
                    //var str = new FastReport.Data.JsonConnection.JsonDataSourceConnectionStringBuilder();
                    //str.Json = req.JsonDataStr;
                    //str.JsonSchema.InitSchema();
                    //report.Dictionary.Connections.Clear();
                    if (report.Dictionary.Connections.Count == 0)
                    {
                        //重置数据源
                        report.Dictionary.Connections.Add(new JsonDataSourceConnection()
                        {
                            ConnectionString = $"JSON={req.JsonDataStr};Encoding=utf-8",
                            Name = "Connection",
                        });
                    }
                    else
                    {
                        //var dataSource = report.Dictionary.Connections[0] as JsonDataSourceConnection;
                        //dataSource.Name = "Connection";
                        //dataSource.ConnectionString = $"JSON={req.JsonDataStr};Encoding=utf-8";
                        foreach (JsonDataSourceConnection connection in report.Dictionary.Connections)
                        {
                            connection.ConnectionString = $"JSON={req.JsonDataStr};Encoding=utf-8";
                        }
                    }

                    report.Save(printFile);

                     
                    report.Prepare();
                    var printName = string.Empty;
                    var saveFile = string.Empty;
                    //var saveFile = Path.Combine(savePath, printName);
                    if (req.PrintType == "1")
                    {
                        printName = $"{fileName}.pdf";
                        saveFile = Path.Combine(savePath, printName);
                        PDFExport pdfExport = new PDFExport();
                        pdfExport.Export(report, saveFile);

                    }
                    else if (req.PrintType == "2")
                    {
                        printName = $"{fileName}.xlsx";
                        saveFile = Path.Combine(savePath, printName);
                        Excel2007Export excelExport = new Excel2007Export();
                        excelExport.Export(report, saveFile);
                    }
                    else if (req.PrintType == "3")
                    {
                        printName = $"{fileName}.doc";
                        saveFile = Path.Combine(savePath, printName);
                        Word2007Export wordExport = new Word2007Export();
                        wordExport.Export(report, saveFile);
                    }
                    else
                    {
                        return await Task.FromResult(PrintDataResult.Failed("非法打印格式!"));
                    }
                    report.Dispose();
                    return await Task.FromResult(PrintDataResult.OK(printName));
                }
                catch (Exception e)
                {
                    return await Task.FromResult(PrintDataResult.Failed(e.Message));
                }

            }
            catch (Exception ex)
            {
                //Logger.Warn(ex, "方法: GetOpenJsonPrintInfo");
                return await Task.FromResult(PrintDataResult.Failed(ex.Message));
            }
        }

        public async Task<PrintDataResult> GetOpenJsonPrintInfoByTemplateCode(OpenJsonPrintByCodeReq req)
        {
            try
            {
                var template = db.Queryable<SysPrintTemplate>().Filter(null, true).Where(x => x.TemplateCode == req.Code && x.TenantId == req.TenantId).First();
                if (template == null)
                {
                    return await Task.FromResult(PrintDataResult.Failed("打印模板编码:[" + req.Code + "]的打印格式不存在!"));
                }
                if (template.IsUseDataSource)
                {
                    return await Task.FromResult(PrintDataResult.Failed("非Json打印接口!"));
                }
                if (String.IsNullOrEmpty(template.PrintJsonContent))
                {
                    return await Task.FromResult(PrintDataResult.Failed("打印模板内容不能为空!"));
                }
                try
                {
                    var basePath = String.Empty;
                    var savePath = "wwwroot/PrintTempFile";

                    var fileName = DateTime.Now.Ticks + "-" + NumUtil.GetRandomString(3);
                    var printFileName = $"{fileName}.frx";
                    var printFile = Path.Combine(savePath, printFileName);

                    //写入CRX文件
                    using (FileStream fs = new FileStream(printFile, FileMode.Create))
                    {
                        Byte[] info = new UTF8Encoding(true).GetBytes(template.PrintJsonContent);
                        fs.Write(info, 0, info.Length);
                    }

                    //生成报表
                    FastReport.Report report = new FastReport.Report();
                    report.Load(printFile);

                    //var dataSource = report.Dictionary.Connections[0] as JsonDataSourceConnection;
                    //var str = new FastReport.Data.JsonConnection.JsonDataSourceConnectionStringBuilder();
                    //str.Json = req.JsonDataStr;
                    //dataSource.ConnectionString = str.ConnectionString;
                    var str = new FastReport.Data.JsonConnection.JsonDataSourceConnectionStringBuilder();
                    str.Json = req.JsonDataStr;
                    //if (report.Dictionary.Connections.Count == 0)
                    //{
                    //    //重置数据源
                    //    report.Dictionary.Connections.Add(new JsonDataSourceConnection()
                    //    {
                    //        ConnectionString = str.ConnectionString,
                    //        Name = "Connection",
                    //    });
                    //}
                    //else
                    //{
                    //    var dataSource = report.Dictionary.Connections[0] as JsonDataSourceConnection;
                    //    dataSource.Name = "Connection";
                    //    dataSource.ConnectionString = str.ConnectionString;
                    //}
                    if (report.Dictionary.Connections.Count == 0)
                    {
                        //重置数据源
                        report.Dictionary.Connections.Add(new JsonDataSourceConnection()
                        {
                            ConnectionString = $"JSON={req.JsonDataStr};Encoding=utf-8",
                            Name = "Connection",
                        });
                    }
                    else
                    {
                        //var dataSource = report.Dictionary.Connections[0] as JsonDataSourceConnection;
                        //dataSource.Name = "Connection";
                        //dataSource.ConnectionString = $"JSON={req.JsonDataStr};Encoding=utf-8";
                        foreach (JsonDataSourceConnection connection in report.Dictionary.Connections)
                        {
                            connection.ConnectionString = $"JSON={req.JsonDataStr};Encoding=utf-8";
                        }
                    }
                    report.Save(printFile);

                    report.Save(printFile);

                    report.Prepare();
                    var printName = string.Empty;
                    var saveFile = string.Empty;
                    //var saveFile = Path.Combine(savePath, printName);
                    if (req.PrintType == "1")
                    {
                        printName = $"{fileName}.pdf";
                        saveFile = Path.Combine(savePath, printName);
                        PDFExport pdfExport = new PDFExport();
                        pdfExport.Export(report, saveFile);

                        #region 处理托书挂载附件

                        if (template.TemplateCode == "bill_of_lading")
                        {
                            System.IO.FileStream file = new System.IO.FileStream(saveFile, FileMode.Open, FileAccess.Read);
                            var movePath = Path.Combine(AppSetting.Configuration["FileSettings:MovePath"], printName);
                            using (var fileStream = File.Create(movePath))
                            {
                                await file.CopyToAsync(fileStream);
                            }

                            file.Close();
                        }
                        #endregion
                    }
                    else if (req.PrintType == "2")
                    {
                        printName = $"{fileName}.xlsx";
                        saveFile = Path.Combine(savePath, printName);
                        Excel2007Export excelExport = new Excel2007Export();
                        excelExport.Export(report, saveFile);
                    }
                    else if (req.PrintType == "3")
                    {
                        printName = $"{fileName}.doc";
                        saveFile = Path.Combine(savePath, printName);
                        Word2007Export wordExport = new Word2007Export();
                        wordExport.Export(report, saveFile);
                    }
                    else
                    {
                        return await Task.FromResult(PrintDataResult.Failed("非法打印格式!"));
                    }
                    report.Dispose();
                    return await Task.FromResult(PrintDataResult.OK(printName));
                }
                catch (Exception e)
                {
                    return await Task.FromResult(PrintDataResult.Failed(e.Message));
                }

            }
            catch (Exception ex)
            {
                //Logger.Warn(ex, "方法: GetOpenJsonPrintInfo");
                return await Task.FromResult(PrintDataResult.Failed(ex.Message));
            }
        }
        /// <summary>
        /// sql 打印
        /// </summary>
        /// <param name="req"></param>
        /// <returns></returns>

        public async Task<PrintDataResult> GetOpenSqlPrintInfo(OpenSqlPrintReq req)
        {
            try
            {

                if (req.TenantId == 0 || req.TenantId == null)
                {
                    return await Task.FromResult(PrintDataResult.Failed("缺失关键参数租户id!"));
                }
                var template = await db.Queryable<SysPrintTemplate>().Filter(null, true).Where(x => x.TenantId == req.TenantId)
                    .WhereIF(req.TemplateId != 0, x => x.Id == req.TemplateId)
                    .WhereIF(!string.IsNullOrEmpty(req.TemplateCode), x => x.Id == req.TemplateId)
                    .FirstAsync();
                if (template == null)
                {
                    return await Task.FromResult(PrintDataResult.Failed("打印模板不存在!"));
                }
                if (!template.IsUseDataSource)
                {
                    return await Task.FromResult(PrintDataResult.Failed("非Sql打印接口!"));
                }
                if (string.IsNullOrEmpty(template.SourceSql))
                {
                    return await Task.FromResult(PrintDataResult.Failed("打印数据源不能为空!"));
                }
                if (!template.SourceSql.Contains(';'))
                {
                    return await Task.FromResult(PrintDataResult.Failed("数据源必须包含分号!"));
                }
                if (template.SourceSql.Substring(template.SourceSql.Length - 1, 1) != ";")
                {
                    return await Task.FromResult(PrintDataResult.Failed("数据源最后必须包含分号!"));
                }
                if (SqlUtil.IsSqlInjection(template.SourceSql))
                {
                    return await Task.FromResult(PrintDataResult.Failed("sql数据源包含非法字符,请检查!"));
                }
                if (String.IsNullOrEmpty(template.PrintJsonContent))
                {
                    return await Task.FromResult(PrintDataResult.Failed("打印模板内容不能为空!"));
                }
                try
                {
                    var tenantDb = saasService.GetBizDbScopeById(req.TenantId);

                    var data = new Dictionary<string, List<dynamic>>();
                    var sugarParams = new List<SugarParameter>();
                    if (!string.IsNullOrEmpty(req.ParamJsonStr))
                    {
                        var param = JsonHelper.Instance.Deserialize<Dictionary<string, dynamic>>(req.ParamJsonStr);
                        foreach (var p in param)
                        {
                            if (p.Key == "ids")
                            {
                                var temp = JsonConvert.DeserializeObject<List<string>>(p.Value.ToString());
                                
                                sugarParams.Add(new SugarParameter($"@{p.Key}", temp.ToArray()));
                            }
                            else
                            {
                                sugarParams.Add(new SugarParameter($"@{p.Key}", p.Value));
                            }

                        }
                    }

                    if (template.SourceSql.Contains(';'))
                    {
                        var sqlArr = template.SourceSql.Split(';');
                        if (sqlArr.Length > 0)
                        {
                            for (int i = 0; i < sqlArr.Length; i++)
                            {

                                if (!string.IsNullOrEmpty(sqlArr[i]))
                                {
                                    var temp = tenantDb.Ado.SqlQuery<dynamic>(sqlArr[i], sugarParams); 
                                    data.Add("sql" + i, temp);
                                }
                            }
                        }
                        else
                        {
                        }
                    }

                    var basePath = String.Empty;
                    var savePath = "wwwroot/PrintTempFile";

                    var fileName = DateTime.Now.Ticks + "-" + NumUtil.GetRandomString(3);
                    var printFileName = $"{fileName}.frx";
                    var printFile = Path.Combine(savePath, printFileName);

                    
                    //写入CRX文件
                    using (FileStream fs = new FileStream(printFile, FileMode.Create))
                    {
                        Byte[] info = new UTF8Encoding(true).GetBytes(template.PrintJsonContent);
                        fs.Write(info, 0, info.Length);
                    }

                    //生成报表
                    FastReport.Report report = new FastReport.Report();
                    report.Load(printFile);
                    var str = new FastReport.Data.JsonConnection.JsonDataSourceConnectionStringBuilder();
                    str.Json = JsonConvert.SerializeObject(data);
                    //if (report.Dictionary.Connections.Count == 0)
                    //{
                    //    //重置数据源
                    //    report.Dictionary.Connections.Add(new JsonDataSourceConnection()
                    //    {
                    //        ConnectionString = str.ConnectionString,
                    //        Name = "Connection",
                    //    });
                    //}
                    //else {
                    //    var dataSource = report.Dictionary.Connections[0] as JsonDataSourceConnection; 
                    //    dataSource.Name = "Connection";
                    //    dataSource.ConnectionString = str.ConnectionString;
                    //} 
                    if (report.Dictionary.Connections.Count == 0)
                    {
                        //重置数据源
                        report.Dictionary.Connections.Add(new JsonDataSourceConnection()
                        {
                            ConnectionString = $"JSON={JsonConvert.SerializeObject(data)};Encoding=utf-8",
                            Name = "Connection",
                        });
                    }
                    else
                    {
                        foreach (JsonDataSourceConnection connection  in report.Dictionary.Connections)
                        {
                            connection.ConnectionString = $"JSON={JsonConvert.SerializeObject(data)};Encoding=utf-8";
                        }
                        //var dataSource = report.Dictionary.Connections[0] as JsonDataSourceConnection;
                        ////dataSource.Name = "Connection";
                        //dataSource.ConnectionString = $"JSON={JsonConvert.SerializeObject(data)};Encoding=utf-8";
                    }

                    report.Save(printFile);

                    report.Load(printFile);

                    report.Prepare();
                    var printName = string.Empty;
                    var saveFile = string.Empty;
                    //var saveFile = Path.Combine(savePath, printName);
                    if (req.PrintType == "1")
                    {
                        printName = $"{fileName}.pdf";
                        saveFile = Path.Combine(savePath, printName);
                        PDFExport pdfExport = new PDFExport();
                        pdfExport.Export(report, saveFile);

                        #region 处理托书挂载附件

                        if (template.TemplateCode == "bill_of_lading" || template.TemplateCode == "release_the_cabin")
                        {
                            System.IO.FileStream file = new System.IO.FileStream(saveFile, FileMode.Open, FileAccess.Read);
                            var movePath = Path.Combine(AppSetting.Configuration["FileSettings:MovePath"], printName);
                            using (var fileStream = File.Create(movePath))
                            {
                                await file.CopyToAsync(fileStream);
                            }

                            file.Close();
                        }
                        #endregion
                    }
                    else if (req.PrintType == "2")
                    {
                        printName = $"{fileName}.xlsx";
                        saveFile = Path.Combine(savePath, printName);
                        Excel2007Export excelExport = new Excel2007Export();
                        excelExport.Export(report, saveFile);
                    }
                    else if (req.PrintType == "3")
                    {
                        printName = $"{fileName}.doc";
                        saveFile = Path.Combine(savePath, printName);
                        Word2007Export wordExport = new Word2007Export();
                        wordExport.Export(report, saveFile);
                    }
                    else
                    {
                        return await Task.FromResult(PrintDataResult.Failed("非法打印格式!"));
                    }
                    report.Dispose();
                    return await Task.FromResult(PrintDataResult.OK(printName));
                }
                catch (Exception e)
                {
                    return await Task.FromResult(PrintDataResult.Failed(e.Message));
                }

            }
            catch (Exception ex)
            {
                //Logger.Warn(ex, "方法: GetOpenJsonPrintInfo");
                return await Task.FromResult(PrintDataResult.Failed(ex.Message));
            }
        } 

        /// <summary>
        /// 下载sql打印frx文件
        /// </summary>
        /// <param name="req"></param>
        /// <returns></returns>

        public async Task<FileDownLoadRes> DownloadSqlPrintFile(OpenSqlPrintReq req)
        {
            try
            {

                if (req.TenantId == 0 || req.TenantId == null)
                {
                    throw new Exception("缺失关键参数租户id");
                }
                var template = await db.Queryable<SysPrintTemplate>().Filter(null, true).Where(x => x.TenantId == req.TenantId)
                    .WhereIF(req.TemplateId != 0, x => x.Id == req.TemplateId)
                    .WhereIF(!string.IsNullOrEmpty(req.TemplateCode), x => x.Id == req.TemplateId)
                    .FirstAsync();
                if (template == null)
                {
                    throw new Exception("打印模板不存在!");
                }
                if (!template.IsUseDataSource)
                {
                    throw new Exception("非Sql打印接口!");
                }
                if (string.IsNullOrEmpty(template.SourceSql))
                {
                    throw new Exception("打印数据源不能为空!");
                }
                if (!template.SourceSql.Contains(';'))
                {
                    throw new Exception("数据源必须包含分号!");
                }
                if (template.SourceSql.Substring(template.SourceSql.Length - 1, 1) != ";")
                {
                    throw new Exception("数据源最后必须包含分号!");
                }
                if (SqlUtil.IsSqlInjection(template.SourceSql))
                {
                    throw new Exception("sql数据源包含非法字符,请检查!");
                }
                if (String.IsNullOrEmpty(template.PrintJsonContent))
                {
                    throw new Exception("打印模板内容不能为空!");
                }
                try
                {
                    var tenantDb = saasService.GetBizDbScopeById(req.TenantId);

                    var data = new Dictionary<string, List<dynamic>>();
                    var sugarParams = new List<SugarParameter>();
                    if (!string.IsNullOrEmpty(req.ParamJsonStr))
                    {
                        var param = JsonHelper.Instance.Deserialize<Dictionary<string, dynamic>>(req.ParamJsonStr);
                        foreach (var p in param)
                        {
                            //sugarParams.Add(new SugarParameter($"@{p.Key}", p.Value));
                            if (p.Key == "ids")
                            {
                                var temp = JsonConvert.DeserializeObject<List<string>>(p.Value.ToString());

                                sugarParams.Add(new SugarParameter($"@{p.Key}", temp.ToArray()));
                            }
                            else
                            {
                                sugarParams.Add(new SugarParameter($"@{p.Key}", p.Value));
                            }
                        }
                    }

                    if (template.SourceSql.Contains(';'))
                    {
                        var sqlArr = template.SourceSql.Split(';');
                        if (sqlArr.Length > 0)
                        {
                            for (int i = 0; i < sqlArr.Length; i++)
                            {

                                if (!string.IsNullOrEmpty(sqlArr[i]))
                                {
                                    var temp = tenantDb.Ado.SqlQuery<dynamic>(sqlArr[i], sugarParams);
                                    data.Add("sql" + i, temp);
                                }
                            }
                        }
                        else
                        {
                        }
                    }

                    var basePath = String.Empty;
                    var savePath = "wwwroot/PrintTempFile";

                    var fileName = DateTime.Now.Ticks + "-" + NumUtil.GetRandomString(3);
                    var printFileName = $"{fileName}.frx";
                    var printFile = Path.Combine(savePath, printFileName);


                    //写入CRX文件
                    using (FileStream fs = new FileStream(printFile, FileMode.Create))
                    {
                        Byte[] info = new UTF8Encoding(true).GetBytes(template.PrintJsonContent);
                        fs.Write(info, 0, info.Length);
                    }

                    //生成报表
                    FastReport.Report report = new FastReport.Report();
                    report.Load(printFile);
                    var str = new FastReport.Data.JsonConnection.JsonDataSourceConnectionStringBuilder();
                    str.Json = JsonConvert.SerializeObject(data); 

                    if (report.Dictionary.Connections.Count == 0)
                    {
                        //重置数据源
                        report.Dictionary.Connections.Add(new JsonDataSourceConnection()
                        {
                            ConnectionString = $"JSON={JsonConvert.SerializeObject(data)};Encoding=utf-8",
                            Name = "Connection",
                        });
                    }
                    else
                    {
                        foreach (JsonDataSourceConnection connection in report.Dictionary.Connections)
                        {
                            connection.ConnectionString = $"JSON={JsonConvert.SerializeObject(data)};Encoding=utf-8";
                        }
                        //var dataSource = report.Dictionary.Connections[0] as JsonDataSourceConnection;
                        //dataSource.Name = "Connection";
                        //dataSource.ConnectionString = $"JSON={JsonConvert.SerializeObject(data)};Encoding=utf-8";
                    }

                    report.Save(printFile);
                    report.Dispose();
                    var res = new FileDownLoadRes()
                    {
                        FilePath = printFile,
                        FileName = printFileName,
                    };
                    return res;
                    //byte[] byteArr = System.IO.File.ReadAllBytes(printFile);
                    //string mimeType = "application/octet-stream";
                    //return new FileContentResult(byteArr, mimeType)
                    //{
                    //    FileDownloadName = printFileName
                    //}; 
                }
                catch (Exception e)
                {
                    throw new Exception(e.ToString());
                }

            }
            catch (Exception ex)
            {
                throw new Exception(ex.ToString());
            }
        }
    }
}