using JiepeiWMS.Common.Helper;
using JiepeiWMS.Common.HttpContextUser;
using JiepeiWMS.Extends;
using JiepeiWMS.IServices;
using JiepeiWMS.Model;
using JiepeiWMS.Model.Models;
using JiepeiWMS.Model.ViewModels;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using System.Data;
using System.IO;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading.Tasks;

namespace JiepeiWMS.Api.Controllers
{
    [Route("api/[controller]/[action]")]
    [ApiController]
    [Authorize(Permissions.Name)]
    public class WMProductClassController : ControllerBase
    {
        /// <summary>
        /// 商品分类
        /// </summary>
        private readonly IWMProductClassServices _wMProductClassServices;
        private readonly ISysOrgServices _BllSysOrg;
        readonly IUser _user;
        private readonly ISysUserInfoServices _sysUserInfoServices;
        private readonly IWMProductListServices _wMProductListServices;
        private readonly IUserRoleServices _userRole;

        public WMProductClassController(IWMProductClassServices WMProductClassServices, ISysOrgServices BllSysOrg, IUser user, ISysUserInfoServices SysUserInfoServices, IWMProductListServices WMProductListServices, IUserRoleServices userRole)
        {
            _wMProductClassServices = WMProductClassServices;
            _BllSysOrg = BllSysOrg;
            _user = user;
            _sysUserInfoServices = SysUserInfoServices;
            _wMProductListServices = WMProductListServices;
            _userRole = userRole;
        }

        /// <summary>
        /// 查询列表
        /// </summary>
        /// <param name="page">页数</param>
        /// <param name="key">关键字</param>
        /// <param name="intPageSize">条数</param>
        /// <returns></returns>
        [HttpGet]
        public async Task<MessageModel<PageModel<WMProductClass>>> Index(int page = 1, string key = "", int intPageSize = 20)
        {
            PageModel<WMProductClass> productClass = new PageModel<WMProductClass>();
            if (string.IsNullOrEmpty(key) || string.IsNullOrWhiteSpace(key))
            {
                key = "";
            }

            Expression<Func<WMProductClass, bool>> whereExpression = s => s.Id > 0;

            //筛选主体Id
            //var userInfoModel = await _sysUserInfoServices.QueryById(_user.ID);
            //if (userInfoModel != null)
            //{
            //    whereExpression = whereExpression.And(s => s.SysOrgId == userInfoModel.SysOrgId);
            //}
            if (!string.IsNullOrWhiteSpace(key))
            {
                whereExpression = whereExpression.And(s => s.ClassName != null && s.ClassName.Contains(key.Trim()));
            }

            productClass = await _wMProductClassServices.QueryPage(whereExpression, page, intPageSize, " Id desc ");
            var productClassView = productClass.data;

            var productClassAll = await _wMProductClassServices.Query();
            foreach (var item in productClassView)
            {
                List<int> pidarr = new List<int>
                {
                    item.ParentId
                };
                if (item.ParentId > 0)
                {
                    pidarr.Add(0);
                }
                var parent = productClassAll.FirstOrDefault(d => d.Id == item.ParentId);

                while (parent != null)
                {
                    pidarr.Add(parent.Id);
                    parent = productClassAll.FirstOrDefault(d => d.Id == parent.ParentId);
                }
                item.ParentIdArr = pidarr.OrderBy(d => d).Distinct().ToList();
            }
            productClass.data = productClassView;

            return new MessageModel<PageModel<WMProductClass>>()
            {
                msg = "获取成功",
                success = productClass.dataCount >= 0,
                response = productClass
            };
        }

        /// <summary>
        /// 获取列表
        /// </summary>
        /// <returns></returns>
        [HttpGet]
        [AllowAnonymous]
        public async Task<MessageModel<object>> Get(int id = 0)
        {
            var classList = await _wMProductClassServices.Query();

            //classList = classList.Where(x => x.SysOrgId == _user.SysOrgId).ToList();

            return new MessageModel<object>()
            {
                msg = "获取成功",
                success = true,
                response = new
                {
                    classList
                }
            };
        }

        /// <summary>
        /// 查询树形节点
        /// </summary>
        /// <param name="parent">父节点</param>
        /// <param name="key">关键字</param>
        /// <returns></returns>
        [HttpGet]
        [AllowAnonymous]
        public async Task<MessageModel<List<WMProductClass>>> GetTreeTable(int parent = 0, string key = "")
        {
            List<WMProductClass> productClass = new List<WMProductClass>();
            var apiList = await _wMProductClassServices.Query();
            var WMProductClassList = await _wMProductClassServices.Query();
            if (string.IsNullOrEmpty(key) || string.IsNullOrWhiteSpace(key))
            {
                key = "";
            }

            //筛选主体Id
            //WMProductClassList = WMProductClassList.Where(a => a.SysOrgId == _user.SysOrgId).ToList();
            if (key != "")
            {
                productClass = WMProductClassList.Where(a => a.ClassName.Contains(key)).OrderBy(a => a.Sort).ToList();
            }
            else
            {
                productClass = WMProductClassList.Where(a => a.ParentId == parent).OrderBy(a => a.Sort).ToList();
            }

            foreach (var item in productClass)
            {
                List<int> parentIdarr = new List<int> { };
                var productClasssModel = WMProductClassList.FirstOrDefault(d => d.Id == item.ParentId);

                while (productClasssModel != null)
                {
                    parentIdarr.Add(productClasssModel.Id);
                    productClasssModel = WMProductClassList.FirstOrDefault(d => d.Id == productClasssModel.ParentId);
                }

                parentIdarr.Reverse();
                parentIdarr.Insert(0, 0);
                item.ParentIdArr = parentIdarr;

                item.hasChildren = key != "" ? false : WMProductClassList.Where(d => d.ParentId == item.Id).Any();
            }

            return new MessageModel<List<WMProductClass>>()
            {
                msg = "获取成功",
                success = productClass.Count >= 0,
                response = productClass
            };
        }

        /// <summary>
        /// 获取分类树下拉
        /// </summary>
        /// <param name="parentId"></param>
        /// <param name="needbtn"></param>
        /// <returns></returns>
        [HttpGet]
        [AllowAnonymous]
        public async Task<MessageModel<ProductClassTree>> GetProductClassTree(int parentId = 0, bool needbtn = false)
        {
            var data = new MessageModel<ProductClassTree>();

            var productClass = await _wMProductClassServices.Query();
            var productClassTrees = (from child in productClass
                                     orderby child.Id
                                     select new ProductClassTree
                                     {
                                         value = child.Id,
                                         label = child.ClassName,
                                         parentId = child.ParentId,
                                         order = child.Sort,
                                     }).ToList();
            ProductClassTree rootRoot = new ProductClassTree
            {
                value = 0,
                parentId = 0,
                label = "根节点"
            };
            productClassTrees = productClassTrees.OrderBy(d => d.order).ToList();

            RecursionHelper.LoopToAppendChildrenProductClass(productClassTrees, rootRoot, parentId, needbtn);

            data.success = true;
            if (data.success)
            {
                data.response = rootRoot;
                data.msg = "获取成功";
            }

            return data;
        }

        /// <summary>
        /// 获取分类树联动
        /// </summary>
        /// <param name="parentId"></param>
        /// <param name="needbtn"></param>
        /// <returns></returns>
        [HttpGet]
        [AllowAnonymous]
        public async Task<MessageModel<ProductClassTree>> GetProductClassTreeLink(int parentId = 0, bool needbtn = false)
        {
            var data = new MessageModel<ProductClassTree>();

            var productClass = await _wMProductClassServices.Query();
            var productClassTrees = (from child in productClass
                                     orderby child.Id
                                     select new ProductClassTree
                                     {
                                         value = child.Id,
                                         label = child.ClassName,
                                         parentId = child.ParentId,
                                         order = child.Sort,
                                     }).ToList();
            ProductClassTree rootRoot = new ProductClassTree
            {
                value = 0,
                parentId = 0,
                label = "根节点"
            };
            foreach (var item in productClass)
            {
                List<int> parentIdarr = new List<int> { };
                var ClassModel = productClass.FirstOrDefault(d => d.Id == parentId);

                while (ClassModel != null)
                {
                    parentIdarr.Add(ClassModel.Id);
                    ClassModel = productClass.FirstOrDefault(d => d.Id == ClassModel.ParentId);
                }

                parentIdarr.Reverse();
                parentIdarr.Insert(0, 0);
                rootRoot.ParentIdArr = parentIdarr;
            }
            productClassTrees = productClassTrees.OrderBy(d => d.order).ToList();

            RecursionHelper.LoopToAppendChildrenProductClass(productClassTrees, rootRoot, parentId, needbtn);

            data.success = true;
            if (data.success)
            {
                data.response = rootRoot;
                data.msg = "获取成功";
            }

            return data;
        }

        /// <summary>
        /// 添加
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<MessageModel<string>> Add([FromBody] WMProductClass request)
        {
            var data = new MessageModel<string>();

            var productClassList = await _wMProductClassServices.Query(x => x.Id == request.ParentId);
            if (productClassList != null && productClassList.Any())
            {
                request.LevelId = productClassList.FirstOrDefault().LevelId + 1;
            }
            else
            {
                request.LevelId = 1;
            }

            request.SysOrgId = _user.SysOrgId;
            var id = await _wMProductClassServices.Add(request);
            data.success = id > 0;

            if (data.success)
            {
                data.response = id.ObjToString();
                data.msg = "添加成功";
            }

            return data;
        }

        /// <summary>
        /// 更新
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPut]
        public async Task<MessageModel<string>> Update([FromBody] WMProductClass request)
        {
            var data = new MessageModel<string>();
            if (request.Id > 0)
            {
                var productClassList = await _wMProductClassServices.GetParentIdList(request.ParentId);
                if (productClassList != null && productClassList.Any())
                {
                    request.LevelId = productClassList.FirstOrDefault().LevelId;
                }
                else
                {
                    request.LevelId = 1;
                }

                data.success = await _wMProductClassServices.Update(request);
                if (data.success)
                {
                    data.msg = "更新成功";
                    data.response = request?.Id.ObjToString();
                }
            }

            return data;
        }

        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        //[HttpDelete]
        //public async Task<MessageModel<string>> Delete(int id)
        //{
        //    var data = new MessageModel<string>();
        //    if (id > 0)
        //    {
        //        var productClassModel = await _wMProductClassServices.QueryById(id);
        //        var productClassList = await _wMProductClassServices.GetParentIdList(productClassModel.Id);
        //        if (productClassList != null && productClassList.Any())
        //        {
        //            data.success = false;
        //            data.msg = "请先删除该分类下的子节点";
        //        }
        //        else
        //        {
        //            var productSpecList = await _wMProductListServices.Query(x => x.ClassId == productClassModel.Id);
        //            if (productSpecList != null && productSpecList.Any())
        //            {
        //                data.success = false;
        //                data.msg = "请先删除商品列表内所关联的规格";
        //            }
        //            else
        //            {
        //                data.success = await _wMProductClassServices.Delete(productClassModel);
        //                if (data.success)
        //                {
        //                    data.msg = "删除成功";
        //                    data.response = productClassModel?.Id.ObjToString();
        //                }
        //            }
        //        }
        //    }

        //    return data;
        //}

        /// <summary>
        /// 导出商品分类表格
        /// </summary>
        [HttpGet]
        public async Task<IActionResult> ExportProductClass()
        {
            var productClassList = await _wMProductClassServices.QuerySql("select Id,ClassName,Sort,LevelId,(select CompanyName from SysOrg where id = SysOrgId)OrgName from WMProductClass pl");
            if (productClassList != null && productClassList.Any())
            {
                var PCList = productClassList.Select(c => new { c.Id, c.ClassName, c.Sort, c.LevelId, c.OrgName }).ToList();
                var heads = new List<string>() { "编号", "分类名称", "排序", "分类级别(数字代表相应的级别)", "所属组织" };

                var stream = ExcelHelper.CreateExcelStreamFromList(PCList, heads);
                return File(stream, "application/octet-stream", "商品分类.xlsx");
            }
            return null;
        }

        /// <summary>
        /// 导入商品分类表格
        /// </summary>
        [HttpPost]
        public async Task<MessageModel<string>> ImportProductClass([FromForm] IFormCollection files)
        {
            var data = new MessageModel<string>();
            var importProductClassModel = new ImportProductClassViewModels();
            var importProductClassList = new List<ImportProductClassViewModels>();

            try
            {
                var sysUserInfoModel = await _sysUserInfoServices.QueryById(_user.ID);
                if (sysUserInfoModel == null || sysUserInfoModel.tdIsDelete == true)
                {
                    data.msg = "当前用户已被禁用无法进行导入";
                    data.response = 0.ObjToString();
                    data.status = 500;
                    return data;
                }
                var userRoleList = await _userRole.Query(x => x.UserId == sysUserInfoModel.uID);
                if (userRoleList == null && userRoleList.Count() == 0)
                {
                    data.msg = "当前用户还未配置角色无法进行导入";
                    data.response = 0.ObjToString();
                    data.status = 500;
                    return data;
                }

                var path = Directory.GetCurrentDirectory();
                var fileFolder = Path.Combine(path, "ImportFile");
                if (!Directory.Exists(fileFolder))
                    Directory.CreateDirectory(fileFolder);

                FormFileCollection fileCollection = (FormFileCollection)files.Files;
                foreach (var file in fileCollection)
                {
                    var fileName = DateTime.Now.ToString("yyyyMMddHHmmss") + Path.GetExtension(file.FileName);
                    var filePath = Path.Combine(fileFolder, fileName);

                    //using (var stream = new FileStream(filePath, FileMode.Create))
                    //{
                    //    await file.CopyToAsync(stream);
                    //}

                    //var dtExcel = ExcelHelper.Read(filePath);
                    using (var stream = new FileStream(filePath, FileMode.Create))
                    {
                        file.CopyTo(stream);
                    }

                    var dtExcel = ExcelHelper.ImportExcel(filePath);
                    foreach (DataRow myRow in dtExcel.Rows)
                    {
                        if (string.IsNullOrWhiteSpace(myRow[0].ToString()))
                            continue;
                        if (string.IsNullOrWhiteSpace(myRow[1].ToString()))
                            continue;
                        if (string.IsNullOrWhiteSpace(myRow[2].ToString()))
                            continue;
                        if (string.IsNullOrWhiteSpace(myRow[3].ToString()))
                            continue;

                        importProductClassModel = new ImportProductClassViewModels()
                        {
                            OrgName = myRow[0].ToString(),
                            ClassGrade = myRow[1].ToString(),
                            ClassCode = myRow[2].ToString(),
                            ClassName = myRow[3].ToString(),
                        };
                        importProductClassList.Add(importProductClassModel);
                    }

                    foreach (var item in importProductClassList)
                    {
                        var sysOrgModel = await _BllSysOrg.GetShortName(item.OrgName);
                        var Level = ExcelHelper.GradeForSort(item.ClassGrade);
                        var productClassList = await _wMProductClassServices.GetClassCodeList(item.ClassCode, Level);

                        //匹配分类编码和等级
                        var productClassModel = await _wMProductClassServices.GetModel(x => x.ClassCode == item.ClassCode);
                        if (productClassModel != null)
                        {
                            //更新商品分类表
                            productClassModel.ClassName = item.ClassName;
                            productClassModel.LevelId = Level;
                            await _wMProductClassServices.Update(productClassModel);
                        }
                        else
                        {
                            var productClassParentId = productClassList.Any() ? productClassList.OrderBy(x => x.Id).FirstOrDefault().Id : 0;
                            var productClassSort = await _wMProductClassServices.Query(x => x.ParentId == productClassParentId);
                            //添加商品分类表
                            var productClass = new WMProductClass();
                            productClass.ClassName = item.ClassName;
                            productClass.ClassCode = item.ClassCode;
                            productClass.Sort = productClassSort.Count();
                            productClass.ParentId = productClassParentId;
                            productClass.LevelId = Level;
                            productClass.SysOrgId = sysOrgModel == null ? 0 : sysOrgModel.Id;
                            await _wMProductClassServices.Add(productClass);
                        }
                    }
                }

                data.response = 1.ObjToString();
                data.msg = "导入商品分类成功";
                data.success = true;
                return data;
            }
            catch (Exception ex)
            {
                data.msg = ex.Message;
                data.response = 0.ObjToString();
                data.status = 500;
                return data;
            }
        }
    }
}