using JiepeiWMS.IServices;
using JiepeiWMS.Model.Models;
using JiepeiWMS.Services.BASE;
using JiepeiWMS.IRepository.Base;
using JiepeiWMS.Model;
using System.Threading.Tasks;
using System.Linq.Expressions;
using System;
using JiepeiWMS.Extends;
using SqlSugar;
using JiepeiWMS.Common.HttpContextUser;
using System.Linq;
using JiepeiWMS.IRepository;
using System.Security.Claims;
using JiepeiWMS.Model.ViewModels;
using System.Collections.Generic;
using JiepeiWMS.Model.Result;
using JiepeiWMS.Common.HttpRestSharp;
using JiepeiWMS.Common;
using System.Threading;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using System.Net;
using System.IO;
using System.Text;
using Newtonsoft.Json.Linq;
using JiepeiWMS.Common.Helper;

namespace JiepeiWMS.Services
{
    public class WMProductListServices : BaseServices<WMProductList>, IWMProductListServices
    {
        private readonly IBaseRepository<WMProductList> _dal;
        private readonly IWMProductInfoRepository _wMProductInfoRepository;
        private readonly IWMWareHouseRepository _wMWareHouseRepository;
        private readonly IUser _user;
        private readonly IBaseRepository<sysUserInfo> _sysUserInfo;
        private readonly IBaseRepository<UserRole> _userRoleServices;
        private readonly IBaseRepository<WMProductClass> _wMProductClassRepository;
        private readonly IBaseRepository<WMProductUnit> _wMProductUnitRepository;
        private readonly IBaseRepository<WMProductSpec> _wMProductSpecRepository;
        private readonly ILogger<WMProductListServices> _logger;
        public WMProductListServices(IBaseRepository<WMProductList> dal,
            IWMProductInfoRepository WMProductInfoRepository,
            IWMWareHouseRepository WMWareHouseRepository,
            IUser user,
            IBaseRepository<sysUserInfo> sysUserInfoRepository,
            IBaseRepository<UserRole> UserRoleRepository,
            IBaseRepository<WMProductClass> WMProductClassRepository,
            IBaseRepository<WMProductUnit> WMProductUnitRepository,
            IBaseRepository<WMProductSpec> WMProductSpecRepository,
            ILogger<WMProductListServices> logger)
        {
            this._dal = dal;
            base.BaseDal = dal;
            _wMProductInfoRepository = WMProductInfoRepository;
            _wMWareHouseRepository = WMWareHouseRepository;
            _user = user;
            _sysUserInfo = sysUserInfoRepository;
            _userRoleServices = UserRoleRepository;
            _wMProductClassRepository = WMProductClassRepository;
            _wMProductUnitRepository = WMProductUnitRepository;
            _wMProductSpecRepository = WMProductSpecRepository;
            _logger = logger;
        }

        private string materialUrl = "/uapws/rest/uapbd/manage/material/add";

        /// <summary>
        /// 获取商品分页
        /// </summary>
        /// <returns></returns>
        public async Task<PageModel<WMProductList>> GetWMProductListPage(int page, int intPageSize, string key = "", string options = "", DateTime? startdate = null, DateTime? enddate = null, int wareHouseId = 0)
        {
            Expression<Func<WMProductList, WMProductClass, WMProductSpec, WMProductUnit, WMProductInfo, bool>> whereExpression =
    (ProductList, ProductClass, ProductSpec, ProductUnit, ProductInfo) => ProductList.Id > 0;

            //筛选主体Id
            //var userInfoModel = await _sysUserInfoRepository .QueryById(_user.ID);
            //if (userInfoModel != null)
            //{
            //    whereExpression = whereExpression.And(ProductList => ProductList.SysOrgId == userInfoModel.SysOrgId);
            //}
            //获取角色信息,判断是否数据展示
            var role = string.Join(",", _user.GetClaimValueByType(ClaimTypes.Role));
            if (role.Contains("仓库管理员"))
            {
                var sysUserInfoModel = await _sysUserInfo.QueryById(_user.ID);
                whereExpression = whereExpression.And((ProductList, ProductClass, ProductSpec, ProductUnit, ProductInfo) => ProductInfo.SysOrgId == sysUserInfoModel.SysOrgId);
            }
            if (!string.IsNullOrWhiteSpace(key))
            {
                whereExpression = whereExpression.And((ProductList, ProductClass, ProductSpec, ProductUnit, ProductInfo) => ProductList.Name.Contains(key.Trim()) || ProductList.Code.Contains(key.Trim()));
            }
            if (!string.IsNullOrWhiteSpace(options))
            {
                whereExpression = whereExpression.And((ProductList, ProductClass, ProductSpec, ProductUnit, ProductInfo) => ProductList.ClassId == options.ObjToInt());
            }
            if (startdate != null)
            {
                whereExpression = whereExpression.And((ProductList, ProductClass, ProductSpec, ProductUnit, ProductInfo) => ProductList.CreateTime >= startdate);
            }
            if (enddate != null)
            {
                whereExpression = whereExpression.And((ProductList, ProductClass, ProductSpec, ProductUnit, ProductInfo) => ProductList.CreateTime <= enddate);
            }
            if (wareHouseId > 0)
            {
                whereExpression = whereExpression.And((ProductList, ProductClass, ProductSpec, ProductUnit, ProductInfo) => ProductInfo.WareHouseId == wareHouseId);
            }
            //获取角色信息,判断是否数据展示
            if (role.Contains("超级管理员"))
            {

            }
            else
            {
                whereExpression = whereExpression.And((ProductList, ProductClass, ProductSpec, ProductUnit, ProductInfo) => ProductList.IsUse == true);
            }

            var PageList = await base.QueryPage<WMProductList, WMProductClass, WMProductSpec, WMProductUnit, WMProductInfo, WMProductList>(
                (ProductList, ProductClass, ProductSpec, ProductUnit, ProductInfo) => new object[]
                {
                    JoinType.Left,ProductList.ClassId==ProductClass.Id,
                    JoinType.Left,ProductList.SpecIds==ProductSpec.Id,
                    JoinType.Left,ProductList.Unit==ProductUnit.Id,
                    JoinType.Left,ProductList.Id==ProductInfo.ProductListId,
                },
                (ProductList, ProductClass, ProductSpec, ProductUnit, ProductInfo) => new WMProductList()
                {
                    Id = ProductList.Id,
                    ClassId = ProductList.ClassId,
                    Name = ProductList.Name,
                    Code = ProductList.Code,
                    BarCode = ProductList.BarCode,
                    Unit = ProductList.Unit,
                    Sort = ProductList.Sort,
                    IsUse = ProductList.IsUse,
                    IsChecked = ProductList.IsChecked,
                    AdminId = ProductList.AdminId,
                    CreateTime = ProductList.CreateTime,
                    SpecIds = ProductList.SpecIds,
                    Price = ProductList.Price,
                    PurchasePrice = ProductList.PurchasePrice,
                    OddDays = ProductList.OddDays,
                    OddFloatNum = ProductList.OddFloatNum,
                    StoreBaseline = ProductList.StoreBaseline,
                    StoreLimit = ProductList.StoreLimit,
                    SysOrgId = ProductInfo.SysOrgId,
                    ClassName = ProductClass.ClassName,
                    SpecName = ProductSpec.Name,
                    UnitName = ProductUnit.Unit,
                    WareHouseId = ProductInfo.WareHouseId ?? 0
                },
                whereExpression,
                page,
                intPageSize,
                " ProductList.Id desc"
                );

            foreach (var item in PageList.data)
            {
                //if (productInfoList != null && productInfoList.Count > 1)
                //{
                //    //当前仓库的库存
                //    if (wareHouseId > 0)
                //    {
                //        productInfoModel = productInfoList.Where(x => x.WareHouseId == wareHouseId).FirstOrDefault();
                //    }
                //}
                //else
                //{
                //    //其它仓库的库存
                //    productInfoModel = productInfoList.FirstOrDefault();
                //}

                var productInfoModel = await _wMProductInfoRepository.GetModel(x => x.ProductListId == item.Id && x.WareHouseId == item.WareHouseId);
                if (productInfoModel != null && productInfoModel.WareHouseId != null)
                {
                    var wareHouseModel1 = await _wMWareHouseRepository.QueryById(productInfoModel.WareHouseId.Value);
                    if (wareHouseModel1 != null)
                    {
                        item.WareHouseName = wareHouseModel1.Name;
                    }
                    item.WareHouseId = productInfoModel.WareHouseId.Value;
                    item.Quantity = productInfoModel.Quantity;
                    item.ProductInfoId = productInfoModel.Id;

                    if (!string.IsNullOrWhiteSpace(item.SpecName))
                        item.SpecName = item.SpecName.TrimEnd(',');

                    var sysUserInfoModel = await _sysUserInfo.QueryById(item.AdminId);
                    if (sysUserInfoModel != null)
                        item.AdminName = sysUserInfoModel.uRealName;
                }
            }
            return PageList;
        }

        /// <summary>
        /// 调用友新增物料接口
        /// </summary>
        /// <returns></returns>
        public async Task<Tuple<string, bool, string>> BeginMaterialInNC(WMProductList listModel)
        {
            try
            {
                #region
                NCMaterialViewModels pos = new NCMaterialViewModels();
                NCMaterialViewModels.Ufinterface uface = new NCMaterialViewModels.Ufinterface();
                NCMaterialViewModels.Bill bill = new NCMaterialViewModels.Bill();
                NCMaterialViewModels.Billhead head = new NCMaterialViewModels.Billhead();
                NCMaterialViewModels.Materialconvert materialconvert = new NCMaterialViewModels.Materialconvert();
                NCMaterialViewModels.Item item = new NCMaterialViewModels.Item();

                if (listModel == null)
                {
                    return new Tuple<string, bool, string>("用友新增物料接口失败", false, "");
                }

                var ClassCode = "";
                var UnitCode = "";
                var SpecName = "";
                var productClassModel = await _wMProductClassRepository.QueryById(listModel.ClassId);
                if (productClassModel != null)
                    ClassCode = productClassModel.ClassCode;
                var productUnitModel = await _wMProductUnitRepository.QueryById(listModel.Unit);
                if (productUnitModel != null)
                    UnitCode = productUnitModel.UnitCode;
                var productSpecModel = await _wMProductSpecRepository.QueryById(listModel.SpecIds);
                if (productSpecModel != null)
                    SpecName = productSpecModel.Name;

                //赋uface
                uface.account = "JPKJ";
                uface.billtype = "material";//新增物料
                uface.isexchange = "Y";
                uface.replace = "Y";
                uface.sender = "JPKJ002";
                uface.groupcode = "JPKJ";

                var maxId = (await _dal.Query()).Max(x => x.Id);
                //赋bill
                bill.id = maxId + 1;

                //赋head
                head.pk_group = "JPKJ";
                head.pk_org = "JPKJ";
                head.code = !string.IsNullOrWhiteSpace(listModel.Code) ? listModel.Code : "material_temp_code";
                head.name = listModel.Name;
                head.materialspec = SpecName;
                head.materialtype = "temp002";
                head.pk_measdoc = UnitCode;
                head.pk_marbasclass = ClassCode;
                head.pk_prodline = "";
                head.intolerance = "0";//入库容差（%）
                head.outtolerance = "0";//出库容差（%）
                head.outcloselowerlimit = "0";//出库关闭下容差（%）
                head.productfamily = "N";
                head.pk_mattaxes = "CN1801";
                head.enablestate = (listModel.IsUse.ObjToInt()).ObjToString();

                //赋item
                item.pk_measdoc = UnitCode;
                item.measrate = "1/1";

                //所有集合赋值
                materialconvert.item = item;
                head.materialconvert = materialconvert;
                bill.billhead = head;
                uface.bill = bill;
                pos.ufinterface = uface;

                var apioahost = Appsettings.app("AppSettings", "ApiNCHost");
                var serviceAddress = apioahost + materialUrl;
                var strContent = JsonConvert.SerializeObject(pos);
                #endregion

                string jsonresult = "";
                var data = GetNetData.PostFunction(serviceAddress, strContent, ref jsonresult);
                var result = JsonConvert.DeserializeObject<NCJsonResult>(data);
                if (result.data != null && result.data.ufinterface.successful == "Y")
                {
                    return new Tuple<string, bool, string>("用友新增物料接口成功", true, result.data.ufinterface.sendresult[0].code);
                }
                else
                {
                    return new Tuple<string, bool, string>(result.message, false, "");
                }
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, ex.ToString());
                return new Tuple<string, bool, string>(ex.ToString(), false, "");
            }
        }
    }
}