using Magicodes.ExporterAndImporter.Core.Models;
using Magicodes.ExporterAndImporter.Excel;
using Microsoft.AspNetCore.Http;
using OfficeOpenXml.FormulaParsing.Excel.Functions.DateTime;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_Core;
using WIDESEA_Core.BaseServices;
using WIDESEA_Core.Enums;
using WIDESEA_Core.Helper;
using WIDESEA_Core.Utilities;
using WIDESEA_ISystemRepository;
using WIDESEA_ISystemService;
using WIDESEA_Model.Models;
using WIDESEA_Model.Models.System;

namespace WIDESEA_SystemService
{
    public class Sys_TraycodeinfoService : ServiceBase<Dt_traycodeinfo, ISys_TraycodeinfoRepository>, ISys_TraycodeinfoService
    {
        public readonly IDt_palletService _PalletService;
        public Sys_TraycodeinfoService(ISys_TraycodeinfoRepository BaseDal , IDt_palletService palletService) : base(BaseDal)
        {
            _PalletService = palletService;
        }

        public ISys_TraycodeinfoRepository Repository => BaseDal;




        public Dt_traycodeinfo? GetInCacheList(string traycode_code)
        {
             Dt_traycodeinfo _Traycodeinfo= BaseDal.QueryData(x=>x.traycode_code== traycode_code && x.traycode_staute==1).FirstOrDefault();
            return _Traycodeinfo;
        }

        public WebResponseContent AddTenantInfo(SaveModel saveModel)
        {
            WebResponseContent content = new WebResponseContent();
            string barcode = saveModel.MainData["barcode"].ToString();  //条码
            string stationnum = saveModel.MainData["cacheNo"].ToString();
            Dt_traycodeinfo _Traycodeinfo = BaseDal.QueryData(x => x.traycode_code == barcode).FirstOrDefault();
            if (_Traycodeinfo != null)
            {
                return content.Error("已有该托盘信息，请误重复新增");
            }
            Dt_traycodeinfo dt_Traycodeinfo = new Dt_traycodeinfo()
            {
                traycode_type = stationnum,
                traycode_staute = 1,
                traycode_code = barcode,
                traycode_createtime = DateTime.Now,
            };

            BaseDal.AddData(dt_Traycodeinfo);
            return content.OK("新增成功");
        }
        /// <summary>
        /// 添加数据
        /// </summary>
        /// <param name="saveModel"></param>
        /// <returns></returns>
        public virtual WebResponseContent AddData(SaveModel saveModel)
        {
            try
            {
                if (saveModel == null || saveModel.MainData == null || saveModel.MainData.Count == 0)//判断参数是否传入
                {
                    return WebResponseContent.Instance.Error("传参错误,参数不能为空");
                }
                string validResult = typeof(Dt_traycodeinfo).ValidateDicInEntity(saveModel.MainData, true, TProperties);

                if (!string.IsNullOrEmpty(validResult))
                {
                    return WebResponseContent.Instance.Error(validResult);
                }

                PropertyInfo keyPro = typeof(Dt_traycodeinfo).GetKeyProperty();
                if (keyPro == null)
                {
                    return WebResponseContent.Instance.Error("请先设置主键");
                }
                if (keyPro.PropertyType == typeof(Guid))
                {
                    saveModel.MainData.Add(keyPro.Name, Guid.NewGuid());
                }
                else if (keyPro.PropertyType == typeof(int) || keyPro.PropertyType == typeof(long))
                {
                    SugarColumn? sugarColumn = keyPro.GetCustomAttribute<SugarColumn>();
                    if (sugarColumn?.IsIdentity ?? true)
                    {
                        saveModel.MainData.Remove(keyPro.Name.FirstLetterToUpper());
                        saveModel.MainData.Remove(keyPro.Name.FirstLetterToLower());
                    }
                }
                Dt_traycodeinfo entity = saveModel.MainData.DicToModel<Dt_traycodeinfo>();
                List<Dt_traycodeinfo> dt_Traycodeinfos = BaseDal.QueryData(x => x.traycode_code == entity.traycode_code).ToList();
                if (dt_Traycodeinfos.Count > 0)
                {
                    return WebResponseContent.Instance.Error("新增失败！！！已添加该托盘");
                }

                if (saveModel.DetailData == null || saveModel.DetailData.Count == 0)
                {
                    BaseDal.AddData(entity);
                    return WebResponseContent.Instance.OK();
                }

                if (typeof(Dt_traycodeinfo).GetNavigatePro() == null)
                {
                    return WebResponseContent.Instance.Error("未配置导航属性");
                }

                Type detailType = typeof(Dt_traycodeinfo).GetDetailType();
                MethodInfo? methodInfo = GetType().GetMethod("AddDataIncludesDetail");
                methodInfo = methodInfo?.MakeGenericMethod(new Type[] { detailType });
                object? obj = methodInfo?.Invoke(this, new object[] { entity, detailType, saveModel.DetailData });
                return obj as WebResponseContent;
            }
            catch (Exception ex)
            {
                return WebResponseContent.Instance.Error(ex.Message);
            }
        }


        //导入
        public virtual WebResponseContent Import(List<IFormFile> files)
        {
            try
            {
                if (files == null || files.Count == 0)
                    return new WebResponseContent { Status = true, Message = "请选择上传的文件" };

                Microsoft.AspNetCore.Http.IFormFile formFile = files[0];

                // 使用Path.Combine，避免硬编码路径分隔符
                string dicPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "ExcelImport", DateTime.Now.ToString("yyyyMMdd"));
                if (!Directory.Exists(dicPath))
                    Directory.CreateDirectory(dicPath);

                string fileName = $"{Guid.NewGuid()}_{formFile.FileName}";
                string fullPath = Path.Combine(dicPath, fileName);

                // 使用FileStream保存文件
                using (FileStream stream = new FileStream(fullPath, FileMode.Create))
                {
                    formFile.CopyTo(stream);
                }

                // 初始化Excel导入工具
                ExcelImporter importer = new ExcelImporter();

                // 导入Excel数据
                ImportResult<Dt_traycodeinfo> importResult = importer.Import<Dt_traycodeinfo>(fullPath, "").Result;


                if (importResult.HasError)
                {
                    return WebResponseContent.Instance.Error(importResult.TemplateErrors.Serialize());
                }
                // 假设BaseDal是数据访问层，进行数据存储
                List<Dt_traycodeinfo> traycodeinfo = new List<Dt_traycodeinfo>();



                foreach (var item in importResult.Data)
                {
                    Dt_traycodeinfo dt_Traycodeinfo = BaseDal.QueryFirst(x => x.traycode_code == item.traycode_code);
                    if (dt_Traycodeinfo != null)
                    {
                        return WebResponseContent.Instance.Error($"添加失败！已有该托盘条码：{item.traycode_code}，请勿重复添加！");
                    }

                    Dt_pallet pallerdata =_PalletService.Repository.QueryFirst(x => x.palletname == item.traycode_type);
                    if(pallerdata == null)
                    {
                        return WebResponseContent.Instance.Error($"添加失败！托盘条码：{item.traycode_code},未找到对应的类型");
                    }


                    Dt_traycodeinfo dt_ = new Dt_traycodeinfo()
                    {
                        traycode_type = pallerdata.palletnumber.ToString(),
                        traycode_createtime = DateTime.Now,
                        traycode_staute = 1,
                        traycode_code=item.traycode_code,
                    };
                    traycodeinfo.Add(dt_);
                }
                BaseDal.AddData(traycodeinfo);

                return WebResponseContent.Instance.OK("导入成功");
            }
            catch (Exception ex)
            {
                // 捕获异常并返回错误消息
                return WebResponseContent.Instance.Error(ex.Message);
            }
        }
    }
}