/*
 *所有关于Dt_locationinfo类的业务代码应在此处编写
*可使用repository.调用常用方法，获取EF/Dapper等信息
*如果需要事务请使用repository.DbContextBeginTransaction
*也可使用DBServerProvider.手动获取数据库相关信息
*用户信息、权限、角色等使用UserContext.Current操作
*Dt_locationinfoService对增、删、改查、导入、导出、审核业务代码扩展参照ServiceFunFilter
*/

using WIDESEA.Core.BaseProvider;
using WIDESEA.Core.Extensions.AutofacManager;
using WIDESEA.Entity.DomainModels;
using System.Linq;
using WIDESEA.Core.Utilities;
using System.Linq.Expressions;
using WIDESEA.Core.Extensions;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.AspNetCore.Http;
using WIDESEA.Services.IRepositories;
using System.Threading.Tasks;
using System.Collections.Generic;
using Newtonsoft.Json;
using System;
using WIDESEA.Common.CustomModels;
using WIDESEA.Core.Enums;
using WIDESEA.Core.Services;
using WIDESEA.Common;
using WIDESEA.Services.Repositories;
using WIDESEA.Core.EFDbContext;

namespace WIDESEA.Services.Services
{
    public partial class Dt_locationinfoService
    {
        private readonly IHttpContextAccessor _httpContextAccessor;
        private readonly IDt_locationinfoRepository _repository;//访问数据库

        [ActivatorUtilitiesConstructor]
        public Dt_locationinfoService(
            IDt_locationinfoRepository dbRepository,
            IHttpContextAccessor httpContextAccessor
            )
        : base(dbRepository)
        {
            _httpContextAccessor = httpContextAccessor;
            _repository = dbRepository;
            //多租户会用到这init代码，其他情况可以不用
            //base.Init(dbRepository);
        }


        /// <summary>
        /// 给入库请求分配货位（获取指定的层）
        /// </summary>
        /// <returns></returns>
        public WebResponseContent GetEmptyLocation(WIDESEAContext dbcontext, string desLayer)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                Dt_locationinfoRepository locationinfoRepository = new Dt_locationinfoRepository(dbcontext);

                List<Dt_locationinfo> locationinfos = locationinfoRepository.Find(
                    x => x.location_state == LocationState.LocationState_Empty.ToString() &&
                    x.location_islocked == false && x.location_layer == int.Parse(desLayer))
                    .OrderBy(x => x.location_column)
                    .ToList();

                if (locationinfos.Count() > 0)
                {
                    return content.OK(data: locationinfos[0]);
                }
                else
                {
                    content.Error("暂无货位可分配");
                }
            }
            catch (Exception ex)
            {
                content.Error(ex.Message);
            }

            return content;
        }


        /// <summary>
        /// 锁定或者取消锁定货位
        /// </summary>
        /// <param name="locationId">货位Id</param>
        /// <param name="lockFlag">是否锁定</param>
        /// <returns></returns>
        public WebResponseContent DoLocationLockOperate(SaveModel saveModel)
        {
            WebResponseContent responseContent = repository.DbContextBeginTransaction(() =>
            {
                WebResponseContent content = new WebResponseContent();
                try
                {
                    List<Dt_locationinfo> locationinfos = new List<Dt_locationinfo>();
                    for (int i = 0; i < saveModel.DelKeys.Count(); i++)
                    {

                        Dt_locationinfo locationinfo = new Dt_locationinfo();
                        Guid id = new Guid(saveModel.DelKeys[i].ToString());
                        locationinfo = repository.FindFirst(a => a.location_pkid == id);
                        locationinfo.location_islocked = Convert.ToBoolean(saveModel.Extra);
                        locationinfos.Add(locationinfo);
                    }
                    Expression<Func<Dt_locationinfo, object>> expression;
                    expression = a => a.location_islocked;
                    content = repository.UpdateRange(locationinfos, expression, true) > 0 ? content.OK() : content.Error("修改失败");
                    Logger.Info(LoggerType.EditUserInfo, saveModel.ToString(), content.ToString(), "解锁成功");
                }
                catch (Exception ex)
                {
                    content.Status = false;
                    content.Message = ex.Message;
                    Logger.Info(LoggerType.EditUserInfo, saveModel.ToString(), content.ToString(), "解锁失败");
                }
                return content;
            });
            return responseContent;
        }


        public override PageGridData<Dt_locationinfo> GetPageData(PageDataOptions options)
        {


            PageGridData<Dt_locationinfo> queryData = new PageGridData<Dt_locationinfo>();
            List<SearchParameters> searchParametersList = new List<SearchParameters>();
            int[] col = {  };
            if (!string.IsNullOrEmpty(options.Wheres))
            {
                try
                {
                    searchParametersList = options.Wheres.DeserializeObject<List<SearchParameters>>();
                    List<Dt_locationinfo> listLocation = repository.Find(r => !(r.location_line == 1 && (col.Contains(r.location_column))));
                    //int[] rightCol = { 48, 49 };
                    int[] rightCol = { 50, 51 };
                    listLocation= listLocation.FindAll(r => !(r.location_line == 2 && (rightCol.Contains(r.location_column))));
                    if (searchParametersList.Count > 0)
                    {
                        SearchParameters searchParameters = searchParametersList.Find(r => r.Name == "location_id");
                        if (null != searchParameters)
                            listLocation = listLocation.FindAll(r => r.location_id.Contains(searchParameters.Value));

                        searchParameters = searchParametersList.Find(r => r.Name == "location_state");
                        if (null != searchParameters)
                            listLocation = listLocation.FindAll(r => r.location_state.Contains(searchParameters.Value));

                        searchParameters = searchParametersList.Find(r => r.Name == "location_islocked");
                        if (null != searchParameters)
                            listLocation = listLocation.FindAll(r => r.location_islocked == bool.Parse(searchParameters.Value));

                        searchParameters = searchParametersList.Find(r => r.Name == "location_line");
                        if (null != searchParameters)
                            listLocation = listLocation.FindAll(r => r.location_line == int.Parse(searchParameters.Value));

                        searchParameters = searchParametersList.Find(r => r.Name == "location_column");
                        if (null != searchParameters)
                            listLocation = listLocation.FindAll(r => r.location_column == int.Parse(searchParameters.Value));

                        searchParameters = searchParametersList.Find(r => r.Name == "location_layer");
                        if (null != searchParameters)
                            listLocation = listLocation.FindAll(r => r.location_layer == int.Parse(searchParameters.Value));
                    }
                    IQueryable<Dt_locationinfo> queryable = listLocation.FindAll(r => true).AsQueryable();

                    string sort = string.IsNullOrEmpty(options.Sort) ? "location_id" : options.Sort;
                    string order = options.Order;
                    IOrderedQueryable<Dt_locationinfo> queryableOrderBy = null;
                    //    Dictionary<string, QueryOrderBy> orderBySelector = new Dictionary<string, QueryOrderBy>() {{
                    //    options.Sort, options.Order?.ToLower() == "asc"? QueryOrderBy.Asc: QueryOrderBy.Desc
                    //} };
                    queryableOrderBy = options.Order?.ToLower() == "desc" ? queryable.OrderByDescending(sort.GetExpression<Dt_locationinfo>()) :
                         queryable.OrderBy(sort.GetExpression<Dt_locationinfo>());

                    queryData.total = listLocation.Count;
                    queryData.rows = queryableOrderBy.Skip((options.Page - 1) * options.Rows).Take(options.Rows).ToList();
                }
                catch
                {


                }
            }
            return queryData;
        }
    }
}