using Admin.NET.Core.Service;
using Admin.NET.Application.Entity;
using Microsoft.AspNetCore.Http;
using System.Data;
using System.Web;
using System.Text;
using Furion.DatabaseAccessor;
using Admin.NET.Core.Enum;
using Furion.RemoteRequest.Extensions;
using StackExchange.Profiling.Internal;

namespace Admin.NET.Application;
/// <summary>
/// 推送mes包装号服务
/// </summary>
[ApiDescriptionSettings(ApplicationConst.WmsOrderGroupName, Order = 100)]
public class MesPushPackageCodeService : IDynamicApiController, ITransient
{
    private readonly SqlSugarRepository<MesPushPackageCode> _rep;
    public MesPushPackageCodeService(SqlSugarRepository<MesPushPackageCode> rep)
    {
        _rep = rep;
    }

    /// <summary>
    /// 分页查询推送mes包装号
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Page")]
    [Description("MesPushPackageCode/Page")]
    public async Task<SqlSugarPagedList<MesPushPackageCodeOutput>> Page(MesPushPackageCodeInput input)
    {
        var query = CommonPageFilter(input);
        return await query.OrderBuilder(input, "", "Id").ToPagedListAsync(input.Page, input.PageSize);
    }

    /// <summary>
    /// 不分页查询推送mes包装号
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpGet]
    [ApiDescriptionSettings(Name = "List")]
    [Description("MesPushPackageCode/List")]
    public async Task<List<MesPushPackageCodeOutput>> List([FromQuery] MesPushPackageCodeInput input)
    {
        var query = CommonPageFilter(input);
        return await query.OrderBuilder(input, "", "Id").Select<MesPushPackageCodeOutput>().ToListAsync();
    }

    /// <summary>
    /// 增加推送mes包装号
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Add")]
    [Description("MesPushPackageCode/Add")]
    public async Task<long> Add(AddMesPushPackageCodeInput input)
    {
        var entity = input.Adapt<MesPushPackageCode>();

        //重复性验证
        await CheckExist(entity);

        await _rep.InsertAsync(entity);
        return entity.Id;
    }

    /// <summary>
    /// 删除推送mes包装号
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Delete")]
    [Description("MesPushPackageCode/Delete")]
    public async Task Delete(DeleteMesPushPackageCodeInput input)
    {
        var entity = await _rep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
        //await _rep.FakeDeleteAsync(entity);   //假删除
        await _rep.DeleteAsync(entity);   //真删除
    }

    /// <summary>
    /// 更新推送mes包装号
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "Update")]
    [Description("MesPushPackageCode/Update")]
    public async Task Update(UpdateMesPushPackageCodeInput input)
    {
        var entity = input.Adapt<MesPushPackageCode>();

        //重复性验证
        await CheckExist(entity, true);

        await _rep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
    }

    /// <summary>
    /// 获取推送mes包装号
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpGet]
    [ApiDescriptionSettings(Name = "Detail")]
    [Description("MesPushPackageCode/Detail")]
    public async Task<MesPushPackageCode> Detail([FromQuery] QueryByIdMesPushPackageCodeInput input)
    {
        return await _rep.GetFirstAsync(u => u.Id == input.Id);
    }


    [HttpPost]
    [ApiDescriptionSettings(Name = "PushPackageCode")]
    [UnitOfWork]
    [AllowAnonymous]
    public async Task PushPackageCode(PushPackageCodeInput input)
    {
        var value = await _rep.AsQueryable().Where(x => x.PackageCode == input.PackageCode).FirstAsync();
        if (value == null) throw Oops.Oh("包装号不存在");
        if (value.PushStatus != (int)PushStatusEnum.NotPush || value.PushStatus != (int)PushStatusEnum.Pushing) throw Oops.Oh("重复推送");
        string url = "http://localhost:8088/api/getwmstask/getwmstask";
        var respon = await url.SetHttpMethod(HttpMethod.Post).SetBody(input).PostAsStringAsync();
        var data = respon.FromJson<Respone>();
        if (data.iState == 1)
        {
            value.PushStatus = (int)PushStatusEnum.PushSuccess;
            value.ApiMessage = data.message;
            value.PushNum++;
        }
        else
        {
            value.PushStatus = (int)PushStatusEnum.Pushing;
            value.ApiMessage = data.message;
            value.PushNum++;
            if (value.PushNum == 3)
            {
                value.PushStatus = (int)PushStatusEnum.PushFail;
            }
        }
        await _rep.UpdateAsync(value);
    }


    #region 导入

    /// <summary>
    /// Excel模板导入推送mes包装号功能
    /// </summary>
    /// <param name="file">Excel模板文件</param>
    /// <returns>导入的记录数</returns>
    [HttpPost]
    [ApiDescriptionSettings(Name = "ImportExcel")]
    [Description("MesPushPackageCode/ImportExcel")]
    public async Task<int> ImportExcelAsync(IFormFile file)
    {
        int _HeadStartLine = 2;//第1行是说明,第2行是列名
        int _DataStartLine = 3;//第3行开始是数据
        DataTable importDataTable = ExcelUtil.ImportExcelToDataTable(file, _HeadStartLine, _DataStartLine);
        var addList = await CommonImport(importDataTable, _DataStartLine);
        await _rep.InsertRangeAsync(addList);
        return addList.Count;
    }

    /// <summary>
    ///  DataTable转换实体对象列表
    /// </summary>
    /// <param name="dataTable"></param>
    /// <param name="dataStartLine">模版列名开始行</param>
    /// <returns></returns>
    private async Task<List<MesPushPackageCode>> CommonImport(DataTable dataTable, int dataStartLine)
    {
        var details = new List<MesPushPackageCode>();
        int index = dataStartLine;//模版列名开始行
        foreach (System.Data.DataRow row in dataTable.Rows)
        {
            index++;
            //导入模版定制化代码（替换模版使用）

            var addItem = new MesPushPackageCode();
            #region 定义变量
            var _PackageCode = "";//包装号
            var _PushStatus = "";//推送状态
            var _PushNum = "";//推送次数
            var _ApiMessage = "";//接口返回参数
            var _CreateOrgName = "";//创建者部门名称
            #endregion


            #region 取值
            _PackageCode = row["包装号"]?.ToString();
            _PushStatus = row["推送状态"]?.ToString();
            _PushNum = row["推送次数"]?.ToString();
            _ApiMessage = row["接口返回参数"]?.ToString();
            _CreateOrgName = row["创建者部门名称"]?.ToString();
            #endregion


            #region 验证

            if (string.IsNullOrEmpty(_PackageCode))
            {
                throw Oops.Oh($"第{index}行[包装号]{_PackageCode}不能为空！");
            }

            if (!string.IsNullOrEmpty(_PackageCode))
            {
                addItem.PackageCode = (string)(_PackageCode.Trim());
            }

            if (string.IsNullOrEmpty(_PushStatus))
            {
                throw Oops.Oh($"第{index}行[推送状态]{_PushStatus}不能为空！");
            }

            if (!string.IsNullOrEmpty(_PushStatus))
            {
                if (!int.TryParse(_PushStatus, out int outPushStatus) && !string.IsNullOrEmpty(_PushStatus))
                {
                    throw Oops.Oh($"第{index}行[推送状态]{_PushStatus}值不正确！");
                }
                if (outPushStatus <= 0 && !string.IsNullOrEmpty(_PushStatus))
                {
                    throw Oops.Oh($"第{index}行[推送状态]{_PushStatus}值不能小于等于0！");
                }
                else
                {
                    addItem.PushStatus = outPushStatus;
                }

            }

            if (string.IsNullOrEmpty(_PushNum))
            {
                throw Oops.Oh($"第{index}行[推送次数]{_PushNum}不能为空！");
            }

            if (!string.IsNullOrEmpty(_PushNum))
            {
                if (!int.TryParse(_PushNum, out int outPushNum) && !string.IsNullOrEmpty(_PushNum))
                {
                    throw Oops.Oh($"第{index}行[推送次数]{_PushNum}值不正确！");
                }
                if (outPushNum <= 0 && !string.IsNullOrEmpty(_PushNum))
                {
                    throw Oops.Oh($"第{index}行[推送次数]{_PushNum}值不能小于等于0！");
                }
                else
                {
                    addItem.PushNum = outPushNum;
                }

            }
            if (!string.IsNullOrEmpty(_ApiMessage))
            {
                addItem.ApiMessage = (string)(_ApiMessage.Trim());
            }
            if (!string.IsNullOrEmpty(_CreateOrgName))
            {
                addItem.CreateOrgName = (string)(_CreateOrgName.Trim());
            }
            #endregion


            details.Add(addItem);
        }
        //验重
        await CheckExisitForImport(details);
        return details;
    }

    /// <summary>
    /// 根据版本下载推送mes包装号的Excel导入模板
    /// </summary>
    /// <returns>下载的模板文件</returns>
    [HttpGet]
    [ApiDescriptionSettings(Name = "DownloadExcelTemplate")]
    [Description("MesPushPackageCode/DownloadExcelTemplate")]
    public IActionResult DownloadExcelTemplate()
    {
        string _path = TemplateConst.EXCEL_TEMPLATEFILE_导入模版路径 + $"\\推送mes包装号{TemplateConst.EXCEL_TEMPLATEFILE_导入模版名称后缀}.xlsx";
        var fileName = HttpUtility.UrlEncode($"导入模板(推送mes包装号).xlsx", Encoding.GetEncoding("UTF-8"));
        return new FileStreamResult(new FileStream(_path, FileMode.Open), "application/octet-stream") { FileDownloadName = fileName };
    }

    #endregion

    #region 私有方法

    /// <summary>
    /// 公共查询推送mes包装号条件
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    private ISugarQueryable<MesPushPackageCodeOutput> CommonPageFilter(MesPushPackageCodeInput input)
    {
        var query = _rep.AsQueryable()
            .WhereIF(!string.IsNullOrWhiteSpace(input.SearchKey), u =>
                u.PackageCode.Contains(input.SearchKey.Trim())
                || u.ApiMessage.Contains(input.SearchKey.Trim())
                || u.CreateUserName.Contains(input.SearchKey.Trim())
                || u.UpdateUserName.Contains(input.SearchKey.Trim())
                || u.CreateOrgName.Contains(input.SearchKey.Trim())
            )
            .WhereIF(!string.IsNullOrWhiteSpace(input.PackageCode), u => u.PackageCode.Contains(input.PackageCode.Trim()))
            .WhereIF(input.PushStatus > 0, u => u.PushStatus == input.PushStatus)
            .WhereIF(input.PushNum > 0, u => u.PushNum == input.PushNum)
            .WhereIF(!string.IsNullOrWhiteSpace(input.ApiMessage), u => u.ApiMessage.Contains(input.ApiMessage.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.CreateOrgName), u => u.CreateOrgName.Contains(input.CreateOrgName.Trim()))
            .Select<MesPushPackageCodeOutput>();
        return query;
    }

    /// <summary>
    /// 重复性验证
    /// </summary>
    /// <param name="input">验证对象</param>
    /// <param name="isEdit">是否是编辑</param>
    /// <returns></returns>
    private async Task CheckExist(MesPushPackageCode input, bool isEdit = false)
    {



        //没有配置组合校验，不需要验重


        //没有配置单独校验，不需要验重
    }

    /// <summary>
    /// 根据组合校验和单独校验验证数据是否已存在-导入时验证
    /// </summary>
    /// <param name="inputs"></param>
    /// <returns></returns>
    private async Task CheckExisitForImport(List<MesPushPackageCode> inputs)
    {
        if (inputs?.Count <= 0)
        {
            throw Oops.Oh($"导入数据不能为空");
        }
        //根据组合校验验证表格中中是否已存在相同数据  








        //根据单独校验验证表格中中是否已存在相同数据  



    }
    #endregion

}