using JiepeiWMS.IServices;
using JiepeiWMS.Model.Models;
using JiepeiWMS.Services.BASE;
using JiepeiWMS.IRepository.Base;
using System.Threading.Tasks;
using JiepeiWMS.Model;
using JiepeiWMS.Common.Enums;
using JiepeiWMS.Common.Helper;
using SqlSugar;
using System.Linq.Expressions;
using System;
using System.Linq;
using JiepeiWMS.Extends;
using JiepeiWMS.IRepository;
using JiepeiWMS.Common.HttpContextUser;

namespace JiepeiWMS.Services
{
    public class WMStockLogServices : BaseServices<WMStockLog>, IWMStockLogServices
    {
        private readonly IBaseRepository<WMStockLog> _dal;
        private readonly IWMProductListRepository _wMProductListRepository;
        private readonly IWMProductSpecRepository _wMProductSpecRepository;
        private readonly IWMPurchaseInfoRepository _wMPurchaseInfoRepository;
        private readonly IWMQuoteInfoRepository _wMQuoteInfoRepository;
        private readonly IWMSaleInfoRepository _wMSaleInfoRepository;
        private readonly IWMWareHouseRepository _wMWareHouseRepository;
        private readonly IUser _user;
        public WMStockLogServices(IBaseRepository<WMStockLog> dal,
            IWMProductListRepository WMProductListRepository,
            IWMProductSpecRepository WMProductSpecRepository,
            IWMPurchaseInfoRepository WMPurchaseInfoRepository,
            IWMQuoteInfoRepository WMQuoteInfoRepository,
            IWMSaleInfoRepository WMSaleInfoRepository,
            IWMWareHouseRepository WMWareHouseRepository,
            IUser user)
        {
            this._dal = dal;
            base.BaseDal = dal;
            _wMProductListRepository = WMProductListRepository;
            _wMProductSpecRepository = WMProductSpecRepository;
            _wMPurchaseInfoRepository = WMPurchaseInfoRepository;
            _wMQuoteInfoRepository = WMQuoteInfoRepository;
            _wMSaleInfoRepository = WMSaleInfoRepository;
            _wMWareHouseRepository = WMWareHouseRepository;
            _user = user;
        }

        /// <summary>
        /// 获取库存流水日志分页
        /// </summary>
        /// <returns></returns>
        public async Task<PageModel<WMStockLog>> GetWMStockLogPage(int page, int intPageSize, string key = "", string typeoptions = "", string warehouseoptions = "", DateTime? startdate = null, DateTime? enddate = null)
        {
            Expression<Func<WMStockLog, bool>> whereExpression = StockLog => StockLog.Id > 0;

            if (!string.IsNullOrWhiteSpace(key))
            {
                //筛选采购订单编号
                var PurchaseCode = (await _wMPurchaseInfoRepository.Query(s => s.PurchaseCode.Contains(key))).Select(c => c.Id);
                //筛选报价订单编号
                var QuoteCode = (await _wMQuoteInfoRepository.Query(s => s.QuoteCode.Contains(key))).Select(c => c.Id);
                //筛选领料订单编号
                var SaleCode = (await _wMSaleInfoRepository.Query(s => s.SaleCode.Contains(key))).Select(c => c.Id);
                //筛选商品编号
                var ProductCode = (await _wMProductListRepository.Query(s => s.Code.Contains(key))).Select(c => c.Id);
                //筛选商品名称
                var ProductName = (await _wMProductListRepository.Query(s => s.Name.Contains(key))).Select(c => c.Id);
                //筛选商品规格
                var ProductSpec = (await _wMProductSpecRepository.Query(s => s.Name.Contains(key))).Select(c => c.Id);

                whereExpression = whereExpression.And(StockLog => PurchaseCode.Contains(StockLog.OrderId.Value) || QuoteCode.Contains(StockLog.OrderId.Value) || SaleCode.Contains(StockLog.OrderId.Value) || ProductCode.Contains(StockLog.ProductListId) || ProductName.Contains(StockLog.ProductListId) || ProductSpec.Contains(StockLog.ProductSpecId));
            }
            if (!string.IsNullOrWhiteSpace(typeoptions))
            {
                whereExpression = whereExpression.And(StockLog => StockLog.Type == typeoptions.ObjToInt());
            }
            if (!string.IsNullOrWhiteSpace(warehouseoptions))
            {
                whereExpression = whereExpression.And(StockLog => StockLog.WareHouseId == warehouseoptions.ObjToInt());
            }
            else
            {
                var WareHouseIdList = (await _wMWareHouseRepository.Query(x => x.SysOrgId == _user.SysOrgId)).Select(x => x.Id).ToList();
                whereExpression = whereExpression.And(StockLog => WareHouseIdList.Contains(StockLog.WareHouseId));
            }
            if (startdate != null)
            {
                whereExpression = whereExpression.And(StockLog => StockLog.CreateTime >= startdate);
            }
            if (enddate != null)
            {
                whereExpression = whereExpression.And(StockLog => StockLog.CreateTime <= enddate);
            }

            var PageList = await base.QueryTabsPage<WMStockLog, WMProductList, WMProductSpec, WMWareHouse, sysUserInfo, WMStockLog>(
             (StockLog, ProductList, ProductSpec, WareHouse, UserInfo) => new object[]
             {
                    JoinType.Left,StockLog.ProductListId==ProductList.Id,
                    JoinType.Left,StockLog.ProductSpecId==ProductSpec.Id,
                    JoinType.Left,StockLog.WareHouseId==WareHouse.Id,
                    JoinType.Left,StockLog.AdminId==UserInfo.uID,
             },
             (StockLog, ProductList, ProductSpec, WareHouse, UserInfo) => new WMStockLog()
             {
                 Id = StockLog.Id,
                 Code = ProductList.Code,
                 ProductName = ProductList.Name,
                 ProductSpec = ProductSpec.Name,
                 WareHouseName = WareHouse.Name,
                 Price = ProductList.Price,
                 Type = StockLog.Type,
                 TotalPrice = StockLog.TotalPrice,
                 RemainQuantity = StockLog.RemainQuantity,
                 RemainPrice = StockLog.RemainPrice,
                 TotalRemainPrice = StockLog.TotalRemainPrice,
                 QuantitySign = StockLog.Quantity > 0 ? ((StockLog.Operation == 1 ? "+" : "-") + StockLog.Quantity.ToString()) : "",
                 OrderId = StockLog.OrderId,
                 CreateTime = StockLog.CreateTime,
                 AdminName = UserInfo.uRealName,
             },
             whereExpression,
             page,
             intPageSize,
             " StockLog.Id desc"
             );

            foreach (var item in PageList.data)
            {
                var dicType = typeof(EnumWMStockType)._GetValueDescriptionDicFromEnumType<EnumWMStockType>();
                string name;
                item.TypeName = dicType.TryGetValue((EnumWMStockType)item.Type, out name) ? name : string.Empty;

                if (item.Type == 1)
                {
                    var PurchaseInfoModel = await _wMPurchaseInfoRepository.QueryById(item.OrderId);
                    if (PurchaseInfoModel != null)
                        item.CodeNo = PurchaseInfoModel.PurchaseCode;
                }
                else if (item.Type == 2)
                {
                    var SaleInfoModel = await _wMSaleInfoRepository.QueryById(item.OrderId);
                    if (SaleInfoModel != null)
                        item.CodeNo = SaleInfoModel.SaleCode;
                }
                else if (item.Type == 4)
                {
                    var QuoteInfoModel = await _wMQuoteInfoRepository.QueryById(item.OrderId);
                    if (QuoteInfoModel != null)
                        item.CodeNo = QuoteInfoModel.QuoteCode;
                }
            }

            return PageList;
        }


        /// <summary>
        /// 获取最近几天得库存
        /// </summary>
        /// <param name="ProductListId">商品列表id</param>
        /// <param name="Id">商品id</param>
        /// <param name="Day">天数</param>
        /// <param name="Type">库存流水类型</param>
        /// <returns></returns>
        public async Task<decimal> GetStockNumByDateDay(int ProductListId, int Id, int Day, int Type)
        {
            var sql = string.Format(@"  select isnull((SELECT SUM(Quantity) FROM dbo.WMStockLog WHERE ProductListId = {0} AND ProductId = {1} AND Type = {2} AND CreateTime >= CONVERT(VARCHAR(10),GETDATE() - {3},120)),0) ", ProductListId, Id, Type, Day);
            var dt_count = await BaseDal.QueryTable(sql.ToString());
            return (decimal)dt_count.Rows[0][0];
        }
    }
}