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

using iWareSql;
using iWareCommon;
using iWareSql.Orm;
using iWareCommon.Utils;
using iWareSql.DBModel;
using iWareModel;

namespace iWareSql.DataAccess
{
    /// <summary>
    /// 托盘和站点的关系
    /// </summary>
    public class Salver_Station_Handler
    {


        /// <summary>
        /// 根据库位号寻找CVP对象
        /// </summary>
        /// <param name="edm"></param>
        /// <param name="placeId"></param>
        /// <returns></returns>
        public static Base_Salver_V_Station GetCVPByPlaceId(DbModel edm, int placeId)
        {
            var cvps = edm.Base_Salver_V_Station.Where(x => x.StationId == placeId);
            if (cvps != null)
            {
                var readCVPs = cvps.ToList();
                if (readCVPs == null)
                {
                    return null;
                }
                else
                {
                    if (readCVPs.Count > 1)
                    {
                        throw new Exception("同一个PlaceID：" + placeId + "关联了" + readCVPs.Count + "个CVP数据！");
                    }
                    else if (readCVPs.Count == 1)
                    {
                        return readCVPs[0];
                    }
                    else
                    {
                        return null;
                    }
                }
            }
            else
            {
                return null;
            }
        }

        /// <summary>
        /// 通过containerId获取 Base_Salver_V_Station 数据
        /// </summary>
        /// <param name="edm"></param>
        /// <param name="mat"></param>
        public static Base_Salver_V_Station GetCVPByContainerId(DbModel edm, string containerId)
        {
            Base_Salver_V_Station cvp = null;
            var cvps = edm.Base_Salver_V_Station.Where(x => x.SalverId == containerId);
            if (cvps == null)
            {
                //throw new Exception(string.Format("根据containerId:{0}没有找到cvp数据", containerId));
                return null;
            }
            else
            {
                if (cvps.Count() == 1)
                {
                    cvp = cvps.FirstOrDefault();
                }
                else if (cvps.Count() == 0)
                {
                    return null;//新增条件 【Editby shaocx,2022-11-8】
                }
                else
                {
                    throw new Exception(string.Format("根据containerId:{0}找到{1}条cvp数据", containerId, cvps.Count()));
                }
            }
            return cvp;
        }

        ///// <summary>
        ///// 通过ItemId获取 Base_Salver_V_Station 数据
        ///// </summary>
        ///// <param name="edm"></param>
        ///// <param name="itemId"></param>
        //public static Base_Salver_V_Station GetCVPByItemId(DbModel edm, string itemId)
        //{
        //    Base_Salver_V_Material ivc = Salver_Material_Handler.GetIVCByItemId(edm, itemId);
        //    return GetCVPByContainerId(edm, ivc.SalverId);
        //}

        /// <summary>
        /// 根据库位ID查找Base_Salver_V_Station对象
        /// </summary>
        /// <param name="placeId"></param>
        /// <returns></returns>
        public static Base_Salver_V_Station GetCVPByPlaceId(int placeId, bool isThrowErrorWhenCVPIsNULL, DbModel edm = null)
        {
            if (edm == null)
            {
                using (edm = new DbModel())
                {
                    return Innner_GetCVPByPlaceId(placeId, edm, isThrowErrorWhenCVPIsNULL);
                }
            }
            else
            {
                return Innner_GetCVPByPlaceId(placeId, edm, isThrowErrorWhenCVPIsNULL);
            }
        }
        private static Base_Salver_V_Station Innner_GetCVPByPlaceId(int placeId, DbModel edm, bool isThrowErrorWhenCVPIsNULL = true)
        {
            var cvps = edm.Base_Salver_V_Station.Where(o => o.StationId == placeId);
            if (cvps == null || cvps.Count() == 0)
            {
                if (isThrowErrorWhenCVPIsNULL)
                {
                    throw new Exception("库位号" + placeId + "没有对应CVP对象");
                }
            }
            if (cvps.Count() > 1)
            {
                throw new Exception("一个库位号" + placeId + "错误的对应了多个CVP对象");
            }
            return cvps.FirstOrDefault();
        }

        /// <summary>
        /// 创建一个托盘和库位的绑定关系
        /// </summary>
        /// <param name="ctn"></param>
        /// <param name="place"></param>
        /// <returns></returns>
        public static bool CreateCvPRelation(string userName, Base_Salver ctn, Base_Station place, Salver_V_Station_StateEnum state, string remark)
        {
            using (DbModel edm = new DbModel())
            {
                CreateCvPRelation(edm, userName, ctn, place, state, remark);
                int i = edm.SaveChanges();
                return i > 0 ? true : false;
            };
        }

        /// <summary>
        /// 创建一个托盘和库位的绑定关系
        /// </summary>
        /// <param name="ctn"></param>
        /// <param name="place"></param>
        /// <returns></returns>
        public static void CreateCvPRelation(DbModel edm, string userName, Base_Salver salver, Base_Station place, Salver_V_Station_StateEnum state, string remark)
        {
            Base_Salver_V_Station cvp = new Base_Salver_V_Station()
            {
                State = (int)state,
                StateName = state.ToString(),

                StationId = place.Id,
                StationCode = place.SrmStationCode,

                InStoreTime = DateTime.Now,//入库时间

                Id = Guid.NewGuid().ToString(),
                SalverId = salver.Id,
                SalverCode = salver.SalverCode,
                OperationRemark = remark,
                CreateTime = DateTime.Now,
                CreateBy = userName,
                ModifyBy = userName,
                ModifyTime = DateTime.Now
            };

            edm.Base_Salver_V_Station.Add(cvp);
        }


        /// <summary>
        /// CVP状态回退
        /// </summary>
        /// <param name="edm"></param>
        /// <param name="placeId"></param>
        /// <param name="description"></param>
        public static void RoolBackCVPState(DbModel edm, int placeId, string description)
        {
            //Base_Salver_V_Station cvp = CvP_Handles.GetCVPByPlaceId(edm, placeId);
            ////修改CVP的状态
            //if (cvp.OldStatus == null)
            //{
            //    throw new Exception("CVP的旧状态为NULL!cvpid:" + cvp.ID);
            //}
            //cvp.State = cvp.OldStatus;
            //cvp.Remark = description;
            //cvp.LastModifier = MachineHelper.GetHostName();
            //cvp.UpdateTime = DateTime.Now;
        }
    }
}