using HH.WCS.JiaTong.util;
using Newtonsoft.Json;
using NLog.Fluent;
using SqlSugar;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using static HH.WCS.JiaTong.dispatch.NDC;

namespace HH.WCS.JiaTong.wms
{
    internal class LocationHelper
    {

        private static Dictionary<string, Location> Locations = null;
        private static Dictionary<string, LocationExt> LocationExts = null;

        static LocationHelper()
        {
            try
            {
                //初始化Location加入到字典缓存
                Locations = new Dictionary<string, Location>();
                var list = GetAllLocList();
                if (list.Count > 0)
                {
                    list.ForEach(a =>
                    {
                        if (!Locations.ContainsKey(a.S_CODE))
                        {
                            Locations.Add(a.S_CODE, a);
                        }
                    });
                }
                //初始化LocationExt加入到集合缓存
                LocationExts = new Dictionary<string, LocationExt>();
                var exts = GetAllLocExtList();
                //   LogHelper.Info($"获取货位扩展表信息：{JsonConvert.SerializeObject(exts)}");
                if (exts.Count > 0)
                {
                    exts.ForEach(a =>
                    {
                        LocationExts.Add($"{a.S_LOC_CODE.Trim()}_{a.S_PICKUP_POINT.Trim()}", a);
                    });
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }

        internal static bool CheckExist(string loc)
        {
            return Locations.Keys.Contains(loc);
        }
        internal static Location GetLocation(string loc)
        {
            if (CheckExist(loc.Trim()))
            {
                return Locations[loc.Trim()];
            }
            return null;
        }
        internal static List<FunctionArea> GetFunctionAreas(string masterCls, string msterCode)
        {
            var db = new SqlHelper<object>().GetInstance();
            return db.Queryable<FunctionArea>().Where(a => a.S_MASTER_CLS == masterCls && a.S_MASTER_CODE == msterCode).ToList();
        }
        internal static List<FunctionArea> GetFunctionAreas(string masterCls, string msterCode, int nType)
        {
            var db = new SqlHelper<object>().GetInstance();
            return db.Queryable<FunctionArea>().Where(a => a.S_MASTER_CLS == masterCls && a.S_MASTER_CODE == msterCode && a.N_TYPE == nType).ToList();
        }
        internal static FunctionArea GetFunctionAreaByCode(string faCode, int faType, int nType)
        {
            var db = new SqlHelper<object>().GetInstance();
            // && a.N_FA_TYPE == faType 
            return db.Queryable<FunctionArea>().Where(a => a.S_FA_CODE == faCode && a.N_TYPE == nType).First();
        }

        /// <summary>
        /// 获取货位站点信息
        /// </summary>
        /// <param name="loc"></param>
        /// <returns></returns>
        internal static string GetAgvSite(string loc)
        {
            var site = "0";
            if (Locations.Keys.Contains(loc.Trim()))
            {
                var Location = Locations[loc.Trim()];
                site = Location.S_AGV_SITE;
            }
            else
            {
                var Location = GetLoc(loc.Trim());
                if (Location != null)
                {
                    Locations.Add(loc.Trim(), Location);
                    site = Location.S_AGV_SITE;
                }
            }
            return site;
        }

        internal static int GetAgvSite(string loc, string actionType)
        {
            var site = 0;
            var key = $"{loc.Trim()}_{actionType.Trim()}";
            if (LocationExts.Keys.Contains(key.Trim()))
            {
                var Location = LocationExts[key.Trim()];
                site = int.Parse(Location.S_AGV_SITE);
            }
            else
            {
                var Locationext = GetLocext(loc.Trim(), actionType);
                if (Locationext != null)
                {
                    LocationExts.Add($"{loc.Trim()}_{actionType.Trim()}", Locationext);
                    site = int.Parse(Locationext.S_AGV_SITE);
                }
            }
            return site;
        }

        /// <summary>
        /// 获取所有货位信息
        /// </summary>
        /// <returns></returns>
        internal static List<Location> GetAllLocList()
        {
            var db = new SqlHelper<object>().GetInstance();
            return db.Queryable<Location>().ToList();
        }
        internal static Location GetLoc(string code)
        {
            var db = new SqlHelper<object>().GetInstance();
            return db.Queryable<Location>().Where(a => a.S_CODE.Trim() == code).First();
        }
        internal static LocationExt GetLocext(string code, string type)
        {
            var db = new SqlHelper<object>().GetInstance();
            return db.Queryable<LocationExt>().Where(a => a.S_LOC_CODE.Trim() == code && a.S_PICKUP_POINT.Trim() == type).First();
        }
        /// <summary>
        ///获取所有货位扩展信息 
        /// </summary>
        /// <returns></returns>
        internal static List<LocationExt> GetAllLocExtList()
        {
            var db = new SqlHelper<object>().GetInstance();
            return db.Queryable<LocationExt>().ToList();
        }

        /// <summary>
        /// 判断没有入库锁和出库锁
        /// </summary>
        /// <param name="code"></param>
        /// <returns></returns>
        internal static bool CheckLocFree(string code)
        {
            var result = false;
            var loc = GetLoc(code);
            if (loc != null)
            {
                result = loc.S_LOCK_STATE.Trim() == "无";
            }
            return result;
        }
        internal static List<LocCntrRel> GetLocCntr(string loc)
        {
            var result = new List<LocCntrRel>();
            //1.0 查货位容器表
            var db = new SqlHelper<object>().GetInstance();
            var list = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE == loc.Trim()).OrderBy(a => a.T_CREATE).ToList();
            if (list.Count > 0)
            {
                list.ForEach(a =>
                {
                    //获取容器信息
                    var cntr = db.Queryable<Container>().Where(b => b.S_CODE == a.S_CNTR_CODE).First();
                    if (cntr != null)
                    {
                        a.Container = cntr;
                        result.Add(a);
                    }
                });
            }
            return result;

        }
        // 定义等级顺序（从高到低）
        private static readonly List<string> LevelOrder = new List<string>
    {
        "A", "B", "C", "D", "E", "F", "G", "H", "I", "J",
        "K", "L", "M", "N", "O", "P", "Q", "R", "S", "T",
        "U", "V", "W", "X", "Y", "Z"
    };

        /// <summary>
        /// 根据物料找托盘
        /// </summary>
        /// <param name="areaCode">库区编码</param>
        /// <param name="lev">物料等级</param>
        /// <param name="ItemCode">物料编码</param>
        /// <returns></returns>
        internal static List<Location> GetLocByItemCode(string areaCode, string ItemCode, string lev)
        {

            List<Location> locs;


            var db = new SqlHelper<object>().GetInstance();
            var queryable = db.Queryable<Location>()
      .LeftJoin<LocCntrRel>((a, b) => a.S_CODE == b.S_LOC_CODE)
      .LeftJoin<CntrItemDetail>((a, b, c) => b.S_CNTR_CODE == c.S_CNTR_CODE)
      .Where((a, b, c) => a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0 && a.S_AREA_CODE == areaCode);
            //六位码匹配前六位，其他的全部配置
            if (ItemCode.Trim().Length == 6)
            {
                queryable = queryable.Where((a, b, c) => c.S_ITEM_CODE.StartsWith(ItemCode));

            }
            else
            {
                queryable = queryable.Where((a, b, c) => c.S_ITEM_CODE == ItemCode);
            }
            //int targetIndex = LevelOrder.IndexOf(lev);
            //// 获取所有低于或等于目标等级的等级
            //var validLevels = LevelOrder
            //.Skip(targetIndex)  // 跳过高于目标等级的等级
            //.ToList();

            LogHelper.Info($"GetLocByItemCode=>根据库区编码:{areaCode}，物料编码:{ItemCode},物料优先级:{lev}，物料等级计算出有托盘货位{JsonConvert.SerializeObject(queryable.ToList())}");
            //判断需不需要物料等级查找，并优先出库余料
            if (string.IsNullOrEmpty(lev))
            {
                locs = queryable.Where((a, b, c) => c.S_BS_TYPE == "余料").ToList();
            }
            else
            {
                locs = queryable.Where((a, b, c) => c.LEV == lev && c.S_BS_TYPE == "余料").ToList();
            }
            //   LogHelper.Info($"GetLocByItemCode=>查找余料,{JsonConvert.SerializeObject(locs)}");

            //没有余料则寻找全部物料
            if (locs.Count == 0)
            {
                queryable = db.Queryable<Location>()
                    .LeftJoin<LocCntrRel>((a, b) => a.S_CODE == b.S_LOC_CODE)
                    .LeftJoin<CntrItemDetail>((a, b, c) => b.S_CNTR_CODE == c.S_CNTR_CODE)
                    .Where((a, b, c) => a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0 && a.S_AREA_CODE == areaCode);
                //六位码匹配前六位，其他的全部配置
                if (ItemCode.Trim().Length == 6)
                {
                    queryable = queryable.Where((a, b, c) => c.S_ITEM_CODE.StartsWith(ItemCode));

                }
                else
                {
                    queryable = queryable.Where((a, b, c) => c.S_ITEM_CODE == ItemCode);
                }
                LogHelper.Info($"GetLocByItemCode=>无余料,查找全部{JsonConvert.SerializeObject(queryable.ToList())}");


                if (string.IsNullOrEmpty(lev))
                {
                    locs = queryable.ToList();
                }
                else
                {
                    locs = queryable.Where((a, b, c) => c.LEV == lev).ToList();
                }
                LogHelper.Info($"GetLocByItemCode=>无余料,查找全部{JsonConvert.SerializeObject(locs)}");
            }

            return locs;
        }

        /// <summary>
        /// 根据库区获取空托
        /// </summary>
        /// <param name="areaCode">库区编码</param>
        /// <returns></returns>
        internal static Location GetLocByAreacode(string areaCode, string type)
        {
            Location loc = new Location();
            var db = new SqlHelper<object>().GetInstance();
            string CntrCodeWith = "";
            if (type.Trim() == "PM")
            {
                CntrCodeWith = "MA";
            }
            else if (type.Trim() == "PN")
            {
                CntrCodeWith = "NA";
            }
            if (CntrCodeWith == "")
            {
                LogHelper.Info($"托盘类型{type}不在规定范围");
            }
            var query = db.Queryable<Location>()
   .LeftJoin<LocCntrRel>((a, b) => a.S_CODE == b.S_LOC_CODE)
   .LeftJoin<CntrItemDetail>((a, b, c) => b.S_CNTR_CODE == c.S_CNTR_CODE)
   .Where((a, b, c) => a.S_AREA_CODE == areaCode && a.N_CURRENT_NUM == 1
                   && a.N_LOCK_STATE == 0
                   && b.S_CNTR_CODE != null && b.S_CNTR_CODE.Contains(CntrCodeWith) && c.S_ITEM_CODE == null
                   );
            loc = query.First();


            return loc;
        }

        /// <summary>
        /// 分配电梯货位
        /// </summary>
        /// <returns></returns>
        internal static Location GetElevatorLoc()
        {
            var db = new SqlHelper<object>().GetInstance();
            Location location = new Location();
            //查找全部电梯，分配任务最少的电梯
            var devices = Settings.deviceInfos.Where(a => a.deviceType == 2 && a.enable == 1).ToList();
            string[] state = new string[] { "执行中", "开始取货", "取货完成" };
            Dictionary<int, string> dics = new Dictionary<int, string>();
            foreach (var deviceInfo in devices)
            {
                int mst = db.Queryable<WCSTask>().Where(a => a.S_TYPE.Contains("电梯") && state.Contains(a.S_B_STATE)).Count();
                dics.Add(mst, deviceInfo.TN_Location);
            }
            if (dics.Count > 0)
            {
                var dic = dics.OrderBy(a => a.Key).First();
                location = db.Queryable<Location>().Where(a => a.S_CODE == dic.Value).First();
                if (location == null)
                {
                    LogHelper.Info($"根据货位编码:{dic.Value},未找到对应货位");
                }
            }
            return location;
        }
        /// <summary>
        /// 根据物料编码，仓库编码获取托盘数量
        /// </summary>
        /// <param name="areaCode">库区编码,合肥佳通业务为不包含这个库区</param>
        /// <param name="ItemCode">物料编码</param>
        /// <returns></returns>
        internal static int GetItemQtyByAre(string[] areaCode, string ItemCode)
        {

            var db = new SqlHelper<object>().GetInstance();

            var queryable = db.Queryable<Location>()
                    .LeftJoin<LocCntrRel>((a, b) => a.S_CODE == b.S_LOC_CODE)
                    .LeftJoin<CntrItemDetail>((a, b, c) => b.S_CNTR_CODE == c.S_CNTR_CODE)
                    .Where((a, b, c) => a.N_CURRENT_NUM > 0 && !areaCode.Contains(a.S_AREA_CODE) && c.S_ITEM_CODE == ItemCode);

            return queryable.ToList().Count();
        }
        internal static List<LocCntrRel> GetLocCntrRel(string loc)
        {
            //1.0 查货位容器表
            var db = new SqlHelper<object>().GetInstance();
            var result = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == loc.Trim()).ToList();
            return result;

        }

        /// <summary>
        /// 根据货位集合获取有容器的货位
        /// </summary>
        /// <param name="loc"></param>
        /// <returns></returns>
        internal static List<Location> GetLocList(List<string> loc)
        {
            //1.0 查货位容器表
            var db = new SqlHelper<object>().GetInstance();
            var list = db.Queryable<Location>().Where(a => loc.Contains(a.S_CODE) && a.N_CURRENT_NUM > 0).ToList();
            return list;

        }


        /// <summary>
        /// 根据容器集合获取货位
        /// </summary>
        /// <param name="loc"></param>
        /// <returns></returns>
        internal static List<LocCntrRel> GetLocListBycntrs(List<string> cntrs)
        {
            //1.0 查货位容器表
            var db = new SqlHelper<object>().GetInstance();
            var list = db.Queryable<LocCntrRel>().Where(a => cntrs.Contains(a.S_CNTR_CODE)).ToList();
            return list;

        }

        /// <summary>
        /// 根据托盘集合获取
        /// </summary>
        /// <param name="loc"></param>
        /// <returns></returns>
        internal static List<LocCntrRel> GetLocListByLoc(List<string> locs)
        {
            //1.0 查货位容器表
            var db = new SqlHelper<object>().GetInstance();
            var list = db.Queryable<LocCntrRel>().Where(a => locs.Contains(a.S_LOC_CODE)).ToList();
            return list;

        }

        /// <summary>
        /// 货位集合获取货位
        /// </summary>
        /// <param name="loc"></param>
        /// <returns></returns>
        internal static List<Location> GetLocListByloc(List<string> loc, string Areacode)
        {
            //1.0 查货位容器表
            var db = new SqlHelper<object>().GetInstance();
            var list = db.Queryable<Location>().Where(a => loc.Contains(a.S_CODE) && a.S_AREA_CODE.Trim() == Areacode.Trim()).ToList();
            return list;

        }

        /// <summary>
        /// 根据库区分类查询货位数量
        /// </summary>
        /// <param name="loc">货位编码</param>
        /// <param name="type">库区分类</param>
        /// <returns></returns>
        internal static List<Location> GetLocListBytype(List<string> loc, string[] ares)
        {
            //1.0 查货位容器表
            var db = new SqlHelper<object>().GetInstance();

            var list = db.Queryable<Location>().Where(a => loc.Contains(a.S_CODE) && !ares.Contains(a.S_AREA_CODE)).ToList();
            return list;

        }
        /// <summary>
        /// 根据货位编码获取货位信息，不管有没有容器
        /// </summary>
        /// <param name="loc"></param>
        /// <returns></returns>
        internal static List<Location> GetLocListAny(List<string> loc)
        {
            //1.0 查货位容器表
            var db = new SqlHelper<object>().GetInstance();

            var list = db.Queryable<Location>().Where(a => loc.Contains(a.S_CODE)).ToList();
            return list;

        }
        /// <summary>
        /// 根据库区编码获取货位集合
        /// </summary>
        /// <param name="area"></param>
        /// <returns></returns>
        internal static List<Location> GetLocListAny(string area)
        {
            try
            {
                var db = new SqlHelper<object>().GetInstance();
                var list = db.Queryable<Location>().Where(a => a.S_AREA_CODE.Trim() == area).ToList();
                return list;
            }
            catch (Exception ex)
            {
                //Console.WriteLine(ex.Message);
                throw ex;
            }

        }

        /// <summary>
        /// 根据货位集合获取有容器 没有锁的货位
        /// </summary>
        /// <param name="loc"></param>
        /// <returns></returns>
        internal static List<Location> GetLocListFree(List<string> loc)
        {
            //1.0 查货位容器表
            var db = new SqlHelper<object>().GetInstance();
            var list = db.Queryable<Location>().Where(a => loc.Contains(a.S_CODE) && a.N_CURRENT_NUM > 0 && a.S_LOCK_STATE.Trim() == "无").ToList();
            return list;

        }

        /// <summary>
        /// 获取固定数量容器 没有锁的货位
        /// </summary>
        /// <param name="loc"></param>
        /// <param name="current"></param>
        /// <returns></returns>
        internal static List<Location> GetLocListFree(List<string> loc, int current)
        {
            //1.0 查货位容器表
            var db = new SqlHelper<object>().GetInstance();
            var list = db.Queryable<Location>().Where(a => loc.Contains(a.S_CODE) && a.N_CURRENT_NUM == current && a.S_LOCK_STATE.Trim() == "无").ToList();
            return list;

        }

        /// <summary>
        /// 获取数量大于等于固定数量容器 没有锁的货位
        /// </summary>
        /// <param name="loc"></param>
        /// <param name="current"></param>
        /// <returns></returns>
        internal static List<Location> GetLocList(List<string> loc, int current)
        {
            //1.0 查货位容器表
            var db = new SqlHelper<object>().GetInstance();
            var list = db.Queryable<Location>().Where(a => loc.Contains(a.S_CODE) && a.N_CURRENT_NUM >= current && a.S_LOCK_STATE.Trim() == "无").ToList();
            return list;

        }

        /// <summary>
        /// 根据货位获取货位信息
        /// </summary>
        /// <param name="loc"></param>
        /// <returns></returns>
        internal static Location GetLocByLoc(string loc)
        {
            //1.0 查货位容器表
            var db = new SqlHelper<object>().GetInstance();
            var list = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();
            return list;

        }

        /// <summary>
        /// 入库锁定终点，出库锁定起点
        /// </summary>
        /// <param name="loc"></param>
        /// <param name="lockState">1:入库锁、2:出库锁、2:其它锁</param>
        /// <returns></returns>
        public static bool LockLoc(string loc, int lockState)
        {
            var res = false;
            var db = new SqlHelper<object>().GetInstance();
            LogHelper.Info($"锁定货位{loc} 状态:{lockState}");
            try
            {
                var model = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();
                if (model != null && model.S_LOCK_STATE.Trim() == "无")
                {
                    model.N_LOCK_STATE = lockState;
                    model.S_LOCK_STATE = Location.GetLockStateStr(lockState);
                    res = db.Updateable(model).UpdateColumns(it => new { it.N_LOCK_STATE, it.S_LOCK_STATE }).ExecuteCommand() > 0;
                }
                if (res)
                {
                    LogHelper.Info($"锁定货位{loc}成功");
                }
                else
                {
                    LogHelper.Info($"锁定货位{loc}失败,重新锁");
                    Task.Run(() =>
                    {
                        LockLoc(loc, lockState);
                    });
                }
                return res;
            }
            catch (Exception ex)
            {
                LogHelper.Info($"锁定货位{loc}失败--Error:{ex}");
                return res;
            }


        }

        /// <summary>
        /// 取货完解锁起点，卸货完解锁终点，可检验锁的来源，也可以不校验
        /// </summary>
        /// <param name="loc"></param>
        /// <returns></returns>
        public static bool UnLockLoc(string loc)
        {
            LogHelper.Info("UnLockLoc:" + loc);
            var res = false;
            var db = new SqlHelper<object>().GetInstance();
            var model = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();
            if (model != null)
            {
                model.S_LOCK_STATE = "无";
                model.N_LOCK_STATE = 0;
                res = db.Updateable(model).UpdateColumns(it => new { it.N_LOCK_STATE, it.S_LOCK_STATE }).ExecuteCommand() > 0;
                LogHelper.Info("UnLockLoc:解锁结果" + res);
            }
            else
            {
                LogHelper.Info("UnLockLoc 失败");
            }
            return res;
        }

        /// <summary>
        /// 删除货位容器表记录,修改货位容器数量
        /// </summary>
        /// <param name="loc"></param>
        /// <param name="cntrs"></param>
        /// <returns></returns>
        public static bool UnBindingLoc(string loc, List<string> cntrs)
        {
            var res = false;
            var db = new SqlHelper<object>().GetInstance();
            var location = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();
            try
            {
                db.BeginTran();
                var lcrList = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == loc).ToList();
                var count = db.Deleteable<LocCntrRel>().Where(it => cntrs.Contains(it.S_CNTR_CODE.Trim()) && it.S_LOC_CODE.Trim() == loc).ExecuteCommand();
                location.N_CURRENT_NUM = lcrList.Count - count;
                location.S_LOCK_STATE = "无";
                location.N_LOCK_STATE = 0;
                db.Updateable(location).UpdateColumns(it => new { it.N_CURRENT_NUM, it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();
                db.CommitTran();
                res = true;
            }
            catch (Exception ex)
            {
                db.RollbackTran();
            }
            return res;
        }

        /// <summary>
        /// 解锁货位
        /// </summary>
        /// <param name="loc"></param>
        /// <returns></returns>
        public static bool UnlockLoc(string loc)
        {
            var res = false;
            var db = new SqlHelper<object>().GetInstance();
            var location = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();
            try
            {
                db.BeginTran();
                var lcrList = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == loc).ToList();
                location.S_LOCK_STATE = "无";
                location.N_LOCK_STATE = 0;
                db.Updateable(location).UpdateColumns(it => new { it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();
                db.CommitTran();
                res = true;
            }
            catch (Exception ex)
            {
                db.RollbackTran();
            }
            return res;
        }
        /// <summary>
        /// 货位绑定容器
        /// </summary>
        /// <param name="loc"></param>
        /// <param name="cntrs"></param>
        /// <returns></returns>
        public static bool BindingLoc(string loc, List<string> cntrs)
        {
            var res = false;
            var db = new SqlHelper<object>().GetInstance();
            var location = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();
            try
            {
                var lcrList = db.Queryable<LocCntrRel>().Includes(a => a.Container).Where(a => a.S_LOC_CODE.Trim() == loc).ToList();
                db.BeginTran();
                int count = 0;
                cntrs.ForEach(a =>
                {
                    if (lcrList.Count(b => b.S_CNTR_CODE.Trim() == a) == 0)
                    {
                        db.Insertable<LocCntrRel>(new LocCntrRel { S_LOC_CODE = loc, S_CNTR_CODE = a }).ExecuteCommand();
                        count++;
                    }
                });
                location.N_CURRENT_NUM = lcrList.Count + count;
                location.N_LOCK_STATE = 0;
                location.S_LOCK_STATE = "无";

                db.Updateable(location).UpdateColumns(it => new { it.N_CURRENT_NUM, it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();

                db.CommitTran();
                res = true;
            }
            catch (Exception ex)
            {
                LogHelper.Info($"BindingLoc Error:{ex}");
                // Console.WriteLine(ex.Message);
                db.RollbackTran();
            }
            return res;
        }


    }
}