using AutoMapper;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Options;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using WMS.Web.Core;
using WMS.Web.Core.Dto;
using WMS.Web.Core.Dto.OutStockTask;
using WMS.Web.Core.Help;
using WMS.Web.Core.Internal.Results;
using WMS.Web.Domain.Infrastructure;
using WMS.Web.Domain.IService;
using WMS.Web.Domain.IService.Public;
using WMS.Web.Domain.Options;
using WMS.Web.Domain.Values;
using WMS.Web.Repositories;

namespace WMS.Web.Api.Controllers
{
    /// <summary>
    /// 出库计划单
    /// </summary>
    [Route("api/[controller]")]
    [ApiController]
    public class OutStockTaskController : ControllerBase
    {
        private readonly IMapper _mapper;
        private readonly ILoginService _loginService;
        private readonly IOutStockTaskRepositories _repositories;
        private readonly IOutStockService _outStockService;
        private readonly IOutStockTaskService _outStockTaskService;
        private readonly QiniuOptions _option;
        private readonly IExportExcelService _exportExcelService;
        private readonly IInventoryDetailsRepositories _inventoryDetailsRepositories;
        public OutStockTaskController(IMapper mapper, ILoginService loginService,
            IOutStockTaskRepositories repositories, IOutStockService outStockService,
            IOutStockTaskService outStockTaskService, IOptions<QiniuOptions> option, IExportExcelService exportExcelServic,
            IInventoryDetailsRepositories inventoryDetailsRepositories)
        {
            _mapper = mapper;
            _loginService = loginService;
            _repositories = repositories;
            _outStockService = outStockService;
            _outStockTaskService = outStockTaskService;
            _option = option?.Value;
            _exportExcelService = exportExcelServic;
            _inventoryDetailsRepositories = inventoryDetailsRepositories;
        }
        /// <summary>
        /// 列表
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("GetList")]
        public async Task<ResultPagedList<OutStockTaskQueryInfoResponse>> GetPagedList([FromBody] OutStockTaskQueryRequest dto)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return ResultPagedList<OutStockTaskQueryInfoResponse>.ReFailure(ResultCodes.Token_Invalid_Error);

            var (list, count) = await _repositories.GetListAsync(dto);
            var result = ResultPagedList<OutStockTaskQueryInfoResponse>.ReSuccess(list, count);
            return result;
        }

        /// <summary>
        /// 导出
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("Export")]
        public Task<Result<string>> Export([FromBody] OutStockTaskQueryRequest dto)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null)
                return Task.FromResult(Result<string>.ReFailure(ResultCodes.Token_Invalid_Error));
            string fileName = FileDownLoadOrderType.OutStockTask.GetRemark() + loginInfo.UserInfo.CompanyId + DateTime.Now.DateTimeToLongTimeStamp() + ".xlsx";
            string res = _option.Url + fileName;

            Task.Run(async () =>
            {
                await _exportExcelService.ExportList<OutStockTaskQueryInfoResponse, OutStockTaskQueryRequest>(dto, fileName, loginInfo.UserInfo.StaffId, loginInfo.UserInfo.CompanyId, FileDownLoadOrderType.OutStockTask);
            });

            return Task.FromResult(Result<string>.ReSuccess(res));
        }
        /// <summary>
        /// 导出详情
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("ExportInfo")]
        public Task<Result<string>> ExportInfo(OperateRequest dto)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null)
                return Task.FromResult(Result<string>.ReFailure(ResultCodes.Token_Invalid_Error));
            string fileName = FileDownLoadOrderType.OutStockTaskInfo.GetRemark() + DateTime.Now.ToString("yyyyMMddHHmmss") + ".xlsx";
            string res = _option.Url + fileName;

            Task.Run(async () =>
            {
                //await _exportExcelService.ExportList<OutStockTaskQueryInfoResponse, OutStockTaskQueryRequest>(dto, fileName, loginInfo.UserInfo.StaffId, loginInfo.UserInfo.CompanyId, FileDownLoadOrderType.OutStockTask);
                await _outStockTaskService.ExportInfo(dto, fileName, loginInfo);
            });

            return Task.FromResult(Result<string>.ReSuccess(res));
        }

        /// <summary>
        /// 作废
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("Repeal")]
        public async Task<Result> Repeal(OperateRequest dto)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return Result.ReFailure(ResultCodes.Token_Invalid_Error);

            return await _outStockTaskService.Repeal(dto, loginInfo);
        }
        /// <summary>
        /// 反作废
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("NoRepeal")]
        public async Task<Result> NoRepeal(OperateRequest dto)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return Result.ReFailure(ResultCodes.Token_Invalid_Error);

            return await _outStockTaskService.NoRepeal(dto, loginInfo);
        }

        /// <summary>
        /// 合并
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("merge")]
        public async Task<Result> merge(OperateRequest dto)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return Result.ReFailure(ResultCodes.Token_Invalid_Error);

            return await _outStockTaskService.merge(dto, loginInfo);
        }

        /// <summary>
        /// 根据出库单任务编号模糊搜索
        /// </summary>
        /// <param name="billNo"></param>
        /// <returns></returns>
        [HttpGet]
        [Route("GetOutStockTaskListByNo")]
        public async Task<ResultList<GetOutStockTaskByNoResponse>> GetOutStockTaskListByNo([FromQuery] string billNo)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return ResultList<GetOutStockTaskByNoResponse>.ReFailure(ResultCodes.Token_Invalid_Error);

            //List<string> str = new List<string>();
            //str.Add(billNo);
            //var res2 = await _repositories.GetListBySourceBillNo(str);
            var res = await _repositories.GetOutStockTaskListByNo(billNo);

            //获取物料对应的仓位
            var materialNumbers = res.SelectMany(s => s.details).GroupBy(x => x.MaterialNumber).Select(x => x.Key).ToList();
            var stockCodes = res.Select(s => s.StockCode).ToList();
            var orgCodes = res.Select(s => s.OrgCode).ToList();
            var materialSubStocks = await _inventoryDetailsRepositories.GetMaterialSubStocks(materialNumbers, stockCodes, orgCodes, loginInfo.UserInfo.CompanyId);

            foreach (var r in res)
            {
                r.details.ForEach(x =>
                {
                    x.MaterialSubStocks = materialSubStocks.Where(t => t.MaterialNumber == x.MaterialNumber && t.StockCode == r.StockCode && t.OrgCode == r.OrgCode).Select(s => s.SubStock).ToList();
                });
            }


            if (res == null || res.Count() == 0) return ResultList<GetOutStockTaskByNoResponse>.ReFailure(ResultCodes.OutStockTaskNoData);
            return ResultList<GetOutStockTaskByNoResponse>.ReSuccess(res);
        }

        /// <summary>
        /// 根据出库单任务编号模糊搜索下拉-PDA出库
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("GetOutStockTaskNosByNo")]
        public async Task<ResultPagedList<string>> GetOutStockTaskNosByNo([FromBody] GetOutStockTaskNosByNoRequest dto)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return ResultPagedList<string>.ReFailure(ResultCodes.Token_Invalid_Error);

            var res = await _repositories.GetOutStockTaskNosByNo(dto.BillNo, dto.StockCode);
            int total = res.Count();
            res = res.OrderByDescending(o => o).Skip((dto.PageNo - 1) * dto.PageSize).Take(dto.PageSize).ToList();

            if (res == null || res.Count() == 0) return ResultPagedList<string>.ReFailure(ResultCodes.OutStockTaskNoData);
            return ResultPagedList<string>.ReSuccess(res, total);
        }

        /// <summary>
        /// 根据出库单任务编号精确搜索(并且同步金蝶数据)-PDA出库
        /// </summary>
        /// <param name="billNo"></param>
        /// <returns></returns>
        [HttpGet]
        [Route("GetOutStockTaskByNo")]
        public async Task<Result<GetOutStockTaskByNoResponse>> GetOutStockTaskByNo([FromQuery] string billNo)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return Result<GetOutStockTaskByNoResponse>.ReFailure(ResultCodes.Token_Invalid_Error);

            //搜索之前同步金蝶数据(2024.03.02 取消同步最新)
            //await _outStockTaskService.Sync(new List<string>() { billNo });

            var res = await _repositories.GetOutStockTaskByNo(billNo);
            res.details = res.details.Where(w => w.AccruedQty > w.RealityQty).ToList();
            if (res == null) return Result<GetOutStockTaskByNoResponse>.ReFailure(ResultCodes.OutStockTaskNoData);

            //获取物料对应的仓位
            var materialNumbers = res.details.GroupBy(x => x.MaterialNumber).Select(x => x.Key).ToList();
            var stockCodes = new List<string>() { res.StockCode };
            var orgCodes = new List<string>() { res.OrgCode };
            var materialSubStocks = await _inventoryDetailsRepositories.GetMaterialSubStocks(materialNumbers, stockCodes, orgCodes, loginInfo.UserInfo.CompanyId);
            res.details.ForEach(x =>
            {
                List<GetOutStockTaskByNoSubStockResponse> rList = new List<GetOutStockTaskByNoSubStockResponse>();
                var slist = materialSubStocks.Where(t => t.MaterialNumber == x.MaterialNumber && t.StockCode == res.StockCode && t.OrgCode == res.OrgCode).Select(s => s.SubStock).ToList();
                slist.ForEach(f => rList.Add(new GetOutStockTaskByNoSubStockResponse(f)));
                x.MaterialSubStocks = rList.OrderBy(s => s.SubStock_Do).Select(s => s.SubStock).ToList();
                if (rList.Count() > 0)
                    x.FistSubStock = rList.OrderBy(s => s.SubStock_Do).First().SubStock_Do;
                else
                    x.FistSubStock = "z";
            });
            res.details = res.details.OrderBy(s => s.FistSubStock).ToList();

            return Result<GetOutStockTaskByNoResponse>.ReSuccess(res);
        }


        /// <summary>
        /// 刷新金蝶数据
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("Refresh")]
        public async Task<Result> Refresh(OperateRequest dto)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return Result.ReFailure(ResultCodes.Token_Invalid_Error);

            DateTime begin = DateTime.Now.AddDays(-3);//默认拉去三天以内的数据
            var res = await _repositories.GetEntityList(dto.Ids);
            //先刷新选中的数据
            await _outStockTaskService.Sync(res.Select(s => s.BillNo).ToList());
            //再刷新3天内所有的
            return await _outStockTaskService.Sync(null, begin);
        }
        /// <summary>
        /// 出库任务单详情
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [HttpGet]
        [Route("GetInfo/{id}")]
        public async Task<Result<OutStockTaskInfoResponse>> GetInfo([FromRoute] int id)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return Result<OutStockTaskInfoResponse>.ReFailure(ResultCodes.Token_Invalid_Error);

            return await _outStockTaskService.GetInfo(id, loginInfo);
        }
        /// <summary>
        /// 出库任务单详情(根据订单号搜索)
        /// </summary>
        /// <param name="billNo"></param>
        /// <returns></returns>
        [HttpGet]
        [Route("GetInfoByNo/{billNo}")]
        public async Task<Result<OutStockTaskInfoResponse>> GetInfoByNo([FromRoute] string billNo)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return Result<OutStockTaskInfoResponse>.ReFailure(ResultCodes.Token_Invalid_Error);

            var entity = await _repositories.GetByBillNo(billNo);
            if (entity == null)
                return Result<OutStockTaskInfoResponse>.ReFailure(ResultCodes.OutStockTaskNoData);

            return await _outStockTaskService.GetInfo(entity.Id, loginInfo);
        }
    }
}