WMS-Api/src/WMS.Web.Api/Controllers/InStockTaskController.cs

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.InStockTask;
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 InStockTaskController : ControllerBase
    {
        private readonly QiniuOptions _option;
        private readonly IExportExcelService _exportExcelService;
        private readonly ILoginService _loginService;
        private readonly IInStockService _inStockService;
        private readonly IInStockTaskService _inStockTaskService;
        private readonly IInStockTaskRepositories _inStockTaskRepositories;
        public InStockTaskController(
            IOptions<QiniuOptions> option,
            IExportExcelService exportExcelService,
            ILoginService loginService,
            IInStockTaskService inStockTaskService,
            IInStockTaskRepositories inStockTaskRepositories,
            IInStockService inStockService)
        {
            this._option = option?.Value;
            this._exportExcelService = exportExcelService;
            this._loginService = loginService;
            this._inStockService = inStockService;
            this._inStockTaskService = inStockTaskService;
            this._inStockTaskRepositories = inStockTaskRepositories;
        }

        /// <summary>
        /// 列表
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("GetList")]
        public async Task<ResultPagedList<InStockTaskQueryResponse>> GetPagedList([FromBody] InStockTaskQueryRequest dto)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return ResultPagedList<InStockTaskQueryResponse>.ReFailure(ResultCodes.Token_Invalid_Error);
            var (list,total) = await _inStockTaskRepositories.GetPagedList(dto);
            return ResultPagedList<InStockTaskQueryResponse>.ReSuccess(list, total);
        }

        /// <summary>
        /// 导出
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("Export")]
        public Task<Result<string>> Export([FromBody] InStockTaskQueryRequest 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.InStockTask.GetRemark() + loginInfo.UserInfo.CompanyId + DateTime.Now.DateTimeToLongTimeStamp() + ".xlsx";
            string res = _option.Url + fileName;

            Task.Run(async () =>
            {
                await _exportExcelService.ExportList<InStockTaskQueryResponse, InStockTaskQueryRequest>(dto, fileName, loginInfo.UserInfo.StaffId, loginInfo.UserInfo.CompanyId, FileDownLoadOrderType.OutStock);
            });

            return Task.FromResult(Result<string>.ReSuccess(res));
        }
        /// <summary>
        /// 作废
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("Repeal")]
        public async Task<Result> Repeal([FromBody]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 _inStockTaskService.Repeal(dto, loginInfo);
        }

        /// <summary>
        /// 刷新
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("Refresh")]
        public async Task<Result> Refresh([FromBody] OperateRequest dto)
        {
            //1.先找到任务单-并找到来源单集
            var tasks= await _inStockTaskRepositories.GetList(dto.Ids);
            var sourcesBillNos = tasks.Select(x => x.SourceBillNo).ToList();

            //2.同步金蝶
            return await _inStockTaskService.Sysn(sourcesBillNos);
        }

        /// <summary>
        /// 收货-pad
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("Receive")]
        public async Task<Result> Receive([FromBody] UpdateInStockTaskRequest 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 _inStockService.Receive(dto, loginInfo);
        }

        /// <summary>
        /// 来源单-编号模糊查询-pad
        /// </summary>
        /// <param name="sourceBillNo">来源单号</param>
        /// <returns></returns>
        [HttpGet]
        [Route("GetSourceOrder/{sourceBillNo}")]
        public async Task<ResultList<SourceBillNoQueryResponse>> GetSourceOrder([FromRoute] string sourceBillNo)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return ResultList<SourceBillNoQueryResponse>.ReFailure(ResultCodes.Token_Invalid_Error);

            var list= await _inStockTaskRepositories.GetListBy(new InStockTaskBillNoQueryRequest() { SourceBillNo = sourceBillNo, InstockType = null });
            return ResultList<SourceBillNoQueryResponse>.ReSuccess(list);
        }

        /// <summary>
        /// 来源单-编号模糊查询-非采购上架使用-pad
        /// </summary>
        /// <param name="sourceBillNo"></param>
        /// <returns></returns>
        [HttpGet]
        [Route("GetSourceOrderNoPurchase/{sourceBillNo}")]
        public async Task<ResultList<SourceBillNoNoPurchaseQueryResponse>> GetSourceOrderNoPurchase([FromRoute] string sourceBillNo)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return ResultList<SourceBillNoNoPurchaseQueryResponse>.ReFailure(ResultCodes.Token_Invalid_Error);

            var list = await _inStockTaskRepositories.GetListInfoBy(new InStockTaskBillNoQueryRequest() { SourceBillNo = sourceBillNo, InstockType = null });
            return ResultList<SourceBillNoNoPurchaseQueryResponse>.ReSuccess(list);
        }

        /// <summary>
        /// 来源单的信息校准-对应金蝶-pad
        /// </summary>
        /// <param name="sourceBillNo"></param>
        /// <returns></returns>
        [HttpGet]
        [Route("Adjust/{sourceBillNo}")]
        public async Task<ResultList<SourceBillNoQueryResponse>> Adjust([FromRoute] string sourceBillNo)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return ResultList<SourceBillNoQueryResponse>.ReFailure(ResultCodes.Token_Invalid_Error);

            //校准
            var result= await _inStockTaskService.Adjust(sourceBillNo);
            if(!result.IsSuccess)
                return ResultList<SourceBillNoQueryResponse>.ReFailure(result);

            //再一次查询新的数据：并返回最后的结果
            var request = new InStockTaskBillNoQueryRequest() { SourceBillNo = sourceBillNo };
            var list = await _inStockTaskRepositories.GetListBy(request);
            return ResultList<SourceBillNoQueryResponse>.ReSuccess(list);
        }

        /// <summary>
        /// 来源单的信息校准-非采购上架使用-对应金蝶-pad
        /// </summary>
        /// <param name="sourceBillNo"></param>
        /// <returns></returns>
        [HttpGet]
        [Route("AdjustNoPurchase/{sourceBillNo}")]
        public async Task<ResultList<SourceBillNoNoPurchaseQueryResponse>> AdjustNoPurchase([FromRoute] string sourceBillNo)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return ResultList<SourceBillNoNoPurchaseQueryResponse>.ReFailure(ResultCodes.Token_Invalid_Error);

            //校准
            var result = await _inStockTaskService.Adjust(sourceBillNo);
            if (!result.IsSuccess)
                return ResultList<SourceBillNoNoPurchaseQueryResponse>.ReFailure(result);

            //再一次查询新的数据：并返回最后的结果
            var request = new InStockTaskBillNoQueryRequest() { SourceBillNo = sourceBillNo };
            var list = await _inStockTaskRepositories.GetListInfoBy(request);
            return ResultList<SourceBillNoNoPurchaseQueryResponse>.ReSuccess(list);
        }

        /// <summary>
        /// 采购订单物料明细和箱物料明细-对比-pad
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("Contrast")]
        public async Task<Result<ContrastMaterialsResponse>> Contrast([FromBody] ContrastMaterialsRequest dto)
        {
            var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]);
            if (loginInfo == null || loginInfo.UserInfo == null)
                return Result<ContrastMaterialsResponse>.ReFailure(ResultCodes.Token_Invalid_Error);

            var result = await _inStockService.Contrast(dto);
            return result;
        }
    }
}