using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

using iWareSql;
using System.Data.Entity.Migrations;
using iWareSql.Orm;
using iWareCommon;
using iWareCommon.Utils;
using iWareSql.Entity.ViewMode;

using iWareSql.DBModel;
using iWareModel;
using iWareCommon.Common.Globle;
using XiGang.Core.Model;

namespace iWareSql.DataAccess
{
    /// <summary>
    /// 库存处理类
    /// </summary>
    public class StoreHandler
    {


        private static readonly object lockObject = new object();
        private static readonly object lockRemoveObject = new object();
        private static Dictionary<int, string> lockPlaceDict = new Dictionary<int, string>();

        /// <summary>
        /// 增加空托盘的库存
        /// </summary>
        /// <param name="edm"></param>
        /// <param name="remark"></param>
        /// <param name="place"></param>
        public static void AddStoreForEmptySalverTransfer(DbModel edm, string remark, Base_Station place, int qty, string user, ref Base_Salver salver, ref Base_Material newMaterial)
        {
            //绑定托盘和站点的关系
            //新建物料
            newMaterial = MaterialHandler.CreateEmptySlaverMaterial(edm, remark, qty);
            //判断托盘是否存在，如果存在，就不需要重建，如果不存在，就新建托盘
            salver = SalverHandler.CreateVirtualSalver(edm, remark);
            //绑定托盘和物料的关系
            Salver_Material_Handler.CreateCvIRelation(edm, user, salver, newMaterial, remark);
            //绑定托盘和站点的关系
            Salver_Station_Handler.CreateCvPRelation(edm, user, salver, place, Salver_V_Station_StateEnum.入库绑定, remark);


        }

        /// <summary>
        /// 根据RGV站点号获取库存
        /// </summary>
        /// <param name="context"></param>
        /// <param name="rgvStationCode"></param>
        /// <returns></returns>
        public static V_AllStore GetV_AllStoreByRgvStationCode(DbModel context, string rgvStationCode)
        {
            return context.V_AllStore.Where(x => x.RgvStationCode == rgvStationCode).FirstOrDefault();
        }

        /// <summary>
        /// 根据库位ID获取库存
        /// </summary>
        /// <param name="context"></param>
        /// <param name="rgvStationCode"></param>
        /// <returns></returns>
        public static V_AllStore GetV_AllStoreByPlaceId(DbModel context, int placeId)
        {
            return context.V_AllStore.Where(x => x.StationId == placeId).FirstOrDefault();
        }

        /// <summary>
        /// 发动机是否有货
        /// </summary>
        /// <param name="orderNo"></param>
        /// <returns>true:系统有货，false：系统无货</returns>
        public static bool IsSys_HasCatogryForOrderNo(DbModel context, string orderNo, ref V_AllStore store)
        {
            store = context.V_AllStore.Where(x => x.OrderNo == orderNo).FirstOrDefault();
            if (store != null)
            {//有货
                return true;
            }
            return false;
        }

        /// <summary>
        /// 托盘是否有货
        /// </summary>
        /// <param name="salverCode"></param>
        /// <returns>true:系统有货，false：系统无货</returns>
        public static bool IsSys_HasCatogryForSalverCode(DbModel context, string salverCode, ref V_AllStore store)
        {
            store = context.V_AllStore.Where(x => x.SalverCode == salverCode).FirstOrDefault();
            if (store != null)
            {//有货
                return true;
            }
            return false;
        }

        #region 出库计划下发时，寻找库存

        /// <summary>
        /// 出库计划下发时，寻找库存
        /// </summary>
        /// <param name="context"></param>
        /// <param name="outDetailTask"></param>
        /// <param name="errMsg"></param>
        /// <param name="queliaoReason">缺料原因</param>
        public static V_Store FindStoreForOutPlan(DbModel context, Plan_OutTaskDetail outDetailTask, ref string errMsg, ref string queliaoReason)
        {
            var isOrderByInStoreTimeForOut = Base_CodeItemsHandler.IsOrderByInStoreTimeForOut(context);

            List<V_Store> findStoreList = null;

            if (outDetailTask.StationId != null && outDetailTask.StationId > 0)
            {
                findStoreList = context.V_Store.Where(x => x.StationId == outDetailTask.StationId
                    && x.StationIsHasTaskDoing == false && x.StationIsLock == false
                    && x.StationIsDeleted == false).ToList();
            }
            else if (!string.IsNullOrEmpty(outDetailTask.SerialNumber))
            {//按序列号出库
                findStoreList = context.V_Store.Where(x => x.SerialNumber == outDetailTask.SerialNumber
                    && x.StationIsHasTaskDoing == false && x.StationIsLock == false
                    && x.StationIsDeleted == false).ToList();
            }
            else if (!string.IsNullOrEmpty(outDetailTask.OrderNo))
            {//按订货号出库，按照入库时间升序排序
                findStoreList = context.V_Store.Where(x => x.OrderNo == outDetailTask.OrderNo
                    && x.StationIsHasTaskDoing == false && x.StationIsLock == false
                    && x.StationIsDeleted == false).ToList();
                //增加动态排序 【Editby shaocx,2024-07-02】

                if (isOrderByInStoreTimeForOut.data)
                {
                    findStoreList = findStoreList.OrderBy(x => x.InStoreTime).ToList();//按照入库时间排序
                }
                else
                {
                    findStoreList = findStoreList.OrderBy(x => x.SerialNumber).ToList();//按照序列化排序
                }
            }
            else
            {
                throw new Exception("出库明细既不是按照序列号出库，也不是按照订货号出库,明细ID:" + outDetailTask.Id);
            }
            if (findStoreList == null || findStoreList.Count == 0)
            {
                errMsg = "未找到库存,序列号:" + (string.IsNullOrEmpty(outDetailTask.SerialNumber) ? "" : outDetailTask.SerialNumber)
                   + ",订货号:" + (string.IsNullOrEmpty(outDetailTask.OrderNo) ? "" : outDetailTask.OrderNo)
                   + ",计划号:" + outDetailTask.M_PlanNo;
                queliaoReason = "立体库中无库存";
                return null;
            }
            else
            {
                //过滤掉 堆垛机故障的库区
                findStoreList = StationHandler.FindPlacesFilterByBreakdown(findStoreList);//通过设备状态来过滤库位 [EditBy shaocx,2020-12-13]
            }

            if (findStoreList == null || findStoreList.Count == 0)
            {
                errMsg = "未找到库存,序列号:" + (string.IsNullOrEmpty(outDetailTask.SerialNumber) ? "" : outDetailTask.SerialNumber)
                   + ",订货号:" + (string.IsNullOrEmpty(outDetailTask.OrderNo) ? "" : outDetailTask.OrderNo)
                   + ",计划号:" + outDetailTask.M_PlanNo;
                queliaoReason = "有库存,但由于该区域堆垛机故障,不能出库";
                return null;
            }
            //重新排序
            if (isOrderByInStoreTimeForOut.data)
            {
                findStoreList = findStoreList.OrderBy(x => x.InStoreTime).ToList();//按照入库时间排序
            }
            else
            {
                findStoreList = findStoreList.OrderBy(x => x.SerialNumber).ToList();//按照序列化排序
            }

            List<V_Store> new_findStoreList = new List<V_Store>();
            //增加该库位是否被任务占用的筛选 [EditBy shaocx,2022-06-02]
            if (findStoreList != null && findStoreList.Count > 0)
            {
                foreach (var _findStore in findStoreList)
                {
                    var isExistOtherTaskDoing = PartTaskHandler.IsExistOtherTaskDoing(context, _findStore.StationId);
                    if (!isExistOtherTaskDoing)
                    {
                        new_findStoreList.Add(_findStore);
                    }
                }
            }
            //重新排序
            //new_findStoreList = new_findStoreList.OrderBy(x => x.InStoreTime).ToList();
            if (isOrderByInStoreTimeForOut.data)
            {
                new_findStoreList = new_findStoreList.OrderBy(x => x.InStoreTime).ToList();//按照入库时间排序
            }
            else
            {
                new_findStoreList = new_findStoreList.OrderBy(x => x.SerialNumber).ToList();//按照序列化排序
            }

            V_Store findStore = new_findStoreList.FirstOrDefault();
            if (findStore == null)
            {
                errMsg = "未找到库存,序列号:" + (string.IsNullOrEmpty(outDetailTask.SerialNumber) ? "" : outDetailTask.SerialNumber)
                    + ",订货号:" + (string.IsNullOrEmpty(outDetailTask.OrderNo) ? "" : outDetailTask.OrderNo)
                    + ",计划号:" + outDetailTask.M_PlanNo;
                queliaoReason = "有库存,但由于该库位被其他任务占用,不能出库";
                return null;
            }
            return findStore;
        }

        /// <summary>
        /// 出库计划下发时，寻找库存,库存从虚拟库存中查找 【Editby shaocx,2022-07-28】
        /// </summary>
        /// <param name="context"></param>
        /// <param name="outDetailTask"></param>
        /// <param name="errMsg"></param>
        public static Wms_VirtualStore FindStoreForOutPlanByVirtual(DbModel context, Plan_OutTaskDetail outDetailTask, ref string errMsg)
        {
            var isOrderByInStoreTimeForOut = Base_CodeItemsHandler.IsOrderByInStoreTimeForOut(context);
            List<Wms_VirtualStore> findStoreList = null;

            if (outDetailTask.StationId != null && outDetailTask.StationId > 0)
            {
                return null;
            }
            else if (!string.IsNullOrEmpty(outDetailTask.SerialNumber))
            {//按序列号出库
                findStoreList = context.Wms_VirtualStore.Where(x => x.SerialNumber == outDetailTask.SerialNumber
                    && (x.IsDeleted == null || x.IsDeleted == false) //只查没有被锁定的库存数据
                 ).ToList();
            }
            else if (!string.IsNullOrEmpty(outDetailTask.OrderNo))
            {//按订货号出库，按照入库时间升序排序
                findStoreList = context.Wms_VirtualStore.Where(x => x.OrderNo == outDetailTask.OrderNo
                    && (x.IsDeleted == null || x.IsDeleted == false)  //只查没有被锁定的库存数据
                   ).ToList();
                if (isOrderByInStoreTimeForOut.data)
                {
                    findStoreList = findStoreList.OrderBy(x => x.InStoreTime).ToList();//按照入库时间排序
                }
                else
                {
                    findStoreList = findStoreList.OrderBy(x => x.SerialNumber).ToList();//按照序列化排序
                }
            }
            else
            {
                throw new Exception("出库明细既不是按照序列号出库，也不是按照订货号出库,明细ID:" + outDetailTask.Id);
            }
            if (findStoreList == null || findStoreList.Count == 0)
            {
                errMsg = "未找到库存,序列号:" + (string.IsNullOrEmpty(outDetailTask.SerialNumber) ? "" : outDetailTask.SerialNumber)
                   + ",订货号:" + (string.IsNullOrEmpty(outDetailTask.OrderNo) ? "" : outDetailTask.OrderNo)
                   + ",计划号:" + outDetailTask.M_PlanNo;
                return null;
            }
            else
            {

            }

            if (findStoreList == null || findStoreList.Count == 0)
            {
                errMsg = "未找到库存,序列号:" + (string.IsNullOrEmpty(outDetailTask.SerialNumber) ? "" : outDetailTask.SerialNumber)
                   + ",订货号:" + (string.IsNullOrEmpty(outDetailTask.OrderNo) ? "" : outDetailTask.OrderNo)
                   + ",计划号:" + outDetailTask.M_PlanNo;
                return null;
            }
            //重新排序
            if (isOrderByInStoreTimeForOut.data)
            {
                findStoreList = findStoreList.OrderBy(x => x.InStoreTime).ToList();//按照入库时间排序
            }
            else
            {
                findStoreList = findStoreList.OrderBy(x => x.SerialNumber).ToList();//按照序列化排序
            }

            Wms_VirtualStore findStore = findStoreList.FirstOrDefault();
            if (findStore == null)
            {
                errMsg = "未找到库存,序列号:" + (string.IsNullOrEmpty(outDetailTask.SerialNumber) ? "" : outDetailTask.SerialNumber)
                    + ",订货号:" + (string.IsNullOrEmpty(outDetailTask.OrderNo) ? "" : outDetailTask.OrderNo)
                    + ",计划号:" + outDetailTask.M_PlanNo;
                return null;
            }
            return findStore;
        }

        #endregion



        /// <summary>
        /// 校验库存是否允许被出库
        /// </summary>
        /// <param name="findStore"></param>
        /// <param name="errMsg"></param>
        /// <returns></returns>
        private static bool ValidateStoreIsAllowOut(V_Store findStore, ref string errMsg)
        {
            var stationName = "库号:" + findStore.SrmStationCode;
            if (findStore.StationIsLock == true)
            {
                errMsg = stationName + "被锁定，不允许出库";
                return false;
            }
            if (findStore.StationIsDeleted == true)
            {
                errMsg = stationName + "被禁用，不允许出库";
                return false;
            }
            if (findStore.StationIsHasTaskDoing == true)
            {
                errMsg = stationName + "有任务被占用，不允许出库";
                return false;
            }

            return true;
        }


        /// <summary>
        /// 根据库位Id去清空库存（慎用!）
        /// </summary>
        /// <param name="placeId"></param>
        public static void ClearStockByPlaceId(DbModel edm, Base_Station place, string remark)
        {
            try
            {
                if (place != null)
                {
                    place.Remark = remark;
                    place.IsFull = false;
                    place.IsLock = false;


                    var cvps = edm.Base_Salver_V_Station.Where(x => x.StationId == place.Id);


                    List<Base_Salver_V_Station> removeCVP = new List<Base_Salver_V_Station>();
                    List<Base_Salver_V_Material> removeIVC = new List<Base_Salver_V_Material>();

                    #region 计算

                    if (cvps != null)
                    {
                        foreach (var cvp in cvps)
                        {
                            removeCVP.Add(cvp);

                            var cviList = edm.Base_Salver_V_Material.Where(x => x.SalverId == cvp.SalverId).ToList();
                            if (cviList != null)
                            {
                                foreach (var item in cviList)
                                {
                                    removeIVC.Add(item);
                                }
                            }

                        }
                    }

                    #endregion

                    foreach (var item in removeCVP)
                    {
                        edm.Base_Salver_V_Station.Remove(item);
                    }
                    foreach (var item in removeIVC)
                    {
                        edm.Base_Salver_V_Material.Remove(item);

                        //删除物料表
                        var material = edm.Base_Material.Where(x => x.Id == item.MaterialId).FirstOrDefault();
                        if (material != null)
                        {
                            edm.Base_Material.Remove(material);
                        }
                    }

                }


            }
            catch (Exception)
            {
                throw;
            }
        }

        /// <summary>
        /// 根据托盘号去清空库存（慎用!）
        /// </summary>
        /// <param name="placeId"></param>
        public static void ClearStockBySalverCode(DbModel edm, Base_Salver salver, string remark)
        {
            try
            {
                if (salver != null)
                {
                    var cvps = edm.Base_Salver_V_Station.Where(x => x.SalverCode == salver.SalverCode);

                    List<Base_Salver_V_Station> removeCVP = new List<Base_Salver_V_Station>();
                    List<Base_Salver_V_Material> removeIVC = new List<Base_Salver_V_Material>();

                    #region 计算

                    if (cvps != null && cvps.Count() > 0)
                    {
                        foreach (var cvp in cvps)
                        {
                            removeCVP.Add(cvp);
                        }
                    }
                    //增加 获取svm 数据加载 [Editby shaocx,2023-01-14]
                    var cviList = edm.Base_Salver_V_Material.Where(x => x.SalverId == salver.Id).ToList();
                    if (cviList != null)
                    {
                        foreach (var item in cviList)
                        {
                            removeIVC.Add(item);
                        }
                    }


                    #endregion

                    foreach (var item in removeCVP)
                    {
                        //查找Station,并处理Station
                        Base_Station station = edm.Base_Station.Where(x => x.Id == item.StationId).FirstOrDefault();
                        if (station != null)
                        {
                            station.Remark = remark;
                            station.IsFull = false;
                            station.IsLock = false;
                        }

                        edm.Base_Salver_V_Station.Remove(item);
                    }
                    foreach (var item in removeIVC)
                    {
                        edm.Base_Salver_V_Material.Remove(item);

                        //删除物料表
                        var material = edm.Base_Material.Where(x => x.Id == item.MaterialId).FirstOrDefault();
                        if (material != null)
                        {
                            edm.Base_Material.Remove(material);
                        }
                    }

                }


            }
            catch (Exception)
            {
                throw;
            }
        }

    }
}