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;

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;
        public OutStockTaskController(IMapper mapper, ILoginService loginService,
            IOutStockTaskRepositories repositories, IOutStockService outStockService, 
            IOutStockTaskService outStockTaskService, IOptions<QiniuOptions> option, IExportExcelService exportExcelServic)
        {
            _mapper = mapper;
            _loginService = loginService;
            _repositories = repositories;
            _outStockService = outStockService;
            _outStockTaskService = outStockTaskService;
            _option = option?.Value;
            _exportExcelService = exportExcelServic;
        }
        /// <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("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("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);
            
            if (res == null || res.Count() == 0) return ResultList<GetOutStockTaskByNoResponse>.ReFailure(ResultCodes.OutStockTaskNoData);
            return ResultList<GetOutStockTaskByNoResponse>.ReSuccess(res);
        }

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

            var res = await _repositories.GetOutStockTaskNosByNo(billNo);
            if (res == null || res.Count() == 0) return ResultList<string>.ReFailure(ResultCodes.OutStockTaskNoData);
            return ResultList<string>.ReSuccess(res);
        }

        /// <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);

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

            var res = await _repositories.GetOutStockTaskByNo(billNo);
            if (res == null) return Result<GetOutStockTaskByNoResponse>.ReFailure(ResultCodes.OutStockTaskNoData);
            return Result<GetOutStockTaskByNoResponse>.ReSuccess(res);
        }


        /// <summary>
        /// 刷新金蝶数据
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("Refresh")]
        public async Task<Result> Refresh(OperateStrRequest 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.Sync(dto.Ids);
        }
    }
}