using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using HH.MData;
using HH.WMS.Entitys.Algorithm;
using MongoDB.Driver.Builders;
using MongoDB.Bson;
using MongoDB.Driver;
using HH.WMS.Entitys.Basic;

namespace HH.WMS.DAL.Algorithm
{
    /// <summary>
    /// 用户读取mongodb中的货位信息
    /// </summary>
    public class TN_WMS_LOCATIONDAL : BaseDAL
    {
        #region 根据仓库编号获得所有货位
        /// <summary>
        /// 根据仓库编号获得所有货位
        /// </summary>
        /// <param name="stockCode"></param>
        /// <returns></returns>
        public List<AutoBomLocationAbbreEntity> GetLocationByStockCode(string stockCode)
        {
            List<AutoBomLocationAbbreEntity> lstLocation = new List<AutoBomLocationAbbreEntity>();
            //作为查询条件
            var query = Query.And(Query.EQ("CN_S_STOCK_CODE", stockCode), Query.NE("CN_S_STATUS", "报废"));
            lstLocation = MongoDBSingleton.Instance.Find<AutoBomLocationAbbreEntity>(query, "TN_AB_STOCK_LOCATION");
            return lstLocation;
        }
        #endregion

        #region 根据货位编号获得货位
        /// <summary>
        /// 根据货位编号获得货位
        /// </summary>
        /// <param name="locationCode">货位编号</param>
        /// <returns></returns>
        public List<AutoBomLocationAbbreEntity> GetLocationByLocationCode(List<string> locationCodes)
        {
            List<AutoBomLocationAbbreEntity> lstLocation = new List<AutoBomLocationAbbreEntity>();
            //作为查询条件
            var listLocation = locationCodes.ConvertAll<BsonValue>(x => x);
            var query = Query.And(Query.In("CN_S_LOCATION_CODE", listLocation), Query.NE("CN_S_STATUS", "报废"));
            lstLocation = MongoDBSingleton.Instance.Find<AutoBomLocationAbbreEntity>(query, "TN_AB_STOCK_LOCATION");
            return lstLocation;
        }
        public List<AutoBomLocationAbbreEntity> GetLocationByLocationCode(List<string> locationCodes, string CN_S_TYPE)
        {
            List<AutoBomLocationAbbreEntity> lstLocation = new List<AutoBomLocationAbbreEntity>();
            //作为查询条件
            //获得排列表
            var listLocation = locationCodes.ConvertAll<BsonValue>(x => x);
            var query = Query.And(Query.In("CN_S_LOCATION_CODE", listLocation), Query.EQ("CN_S_TYPE", CN_S_TYPE), Query.NE("CN_S_STATUS", "报废"));
            lstLocation = MongoDBSingleton.Instance.Find<AutoBomLocationAbbreEntity>(query, "TN_AB_STOCK_LOCATION");
            return lstLocation;
        }
        #endregion
        #region 获取仓库中货位状态为报废的数据

        public List<string> GetScrapLocationByCondition(List<string> lstAreaCode)
        {
            List<AutoBomLocationAbbreEntity> lstLocation = new List<AutoBomLocationAbbreEntity>();
            //作为查询条件
            var listAreaCode = lstAreaCode.ConvertAll<BsonValue>(x => x);
            var query = Query.And(Query.In("CN_S_AREA_CODE", listAreaCode), Query.EQ("CN_S_STATUS", "报废"));
            lstLocation = MongoDBSingleton.Instance.Find<AutoBomLocationAbbreEntity>(query, "TN_AB_STOCK_LOCATION");
            return lstLocation.Select(o => o.CN_S_LOCATION_CODE).ToList();
        }
        #endregion
        #region 获取货位的配送节拍

        public List<AutoBomLocationAbbreEntity> GetBeatBitByLocation(List<string> lstLocationCode)
        {
            List<AutoBomLocationAbbreEntity> lstLocation = new List<AutoBomLocationAbbreEntity>();
            //作为查询条件
            var listLocationCode = lstLocationCode.ConvertAll<BsonValue>(x => x);
            var query = Query.And(Query.In("CN_S_LOCATION_CODE", listLocationCode));
            lstLocation = MongoDBSingleton.Instance.Find<AutoBomLocationAbbreEntity>(query, "TN_AB_STOCK_LOCATION");
            return lstLocation;
        }
        #endregion
        #region 根据货位编号获得货位详细信息
        /// <summary>
        /// 根据货位编号获得货位详细信息
        /// </summary>
        /// <param name="locationCode"></param>
        /// <returns></returns>
        public AutoBomLocationAbbreEntity GetLocationByLocationCodeAbbre(string locationCode)
        {
            //作为查询条件
            //获得排列表
            var query = Query.And(Query.EQ("CN_S_LOCATION_CODE", locationCode), Query.NE("CN_S_STATUS", "报废"));
            AutoBomLocationAbbreEntity lstLocation = MongoDBSingleton.Instance.FindOne<AutoBomLocationAbbreEntity>(query, "TN_AB_STOCK_LOCATION");
            return lstLocation;
        }


        /// <summary>
        /// 根据货位编号获得货位详细信息
        /// </summary>
        /// <param name="locationCode"></param>
        /// <returns></returns>
        public AutoBomLocationEntity GetModel(string locationCode)
        {
            //作为查询条件
            //获得排列表
            var query = Query.And(Query.EQ("CN_S_LOCATION_CODE", locationCode), Query.NE("CN_S_STATUS", "报废"));
            AutoBomLocationEntity lstLocation = MongoDBSingleton.Instance.FindOne<AutoBomLocationEntity>(query, "TN_AB_STOCK_LOCATION");
            return lstLocation;
        }
        #endregion
        public List<AutoBomLocationAbbreEntity> GetScrapLocationCode(List<string> locationCodes)
        {
            List<AutoBomLocationAbbreEntity> lstLocation = new List<AutoBomLocationAbbreEntity>();
            //作为查询条件
            var listLocation = locationCodes.ConvertAll<BsonValue>(x => x);
            var query = Query.And(Query.In("CN_S_LOCATION_CODE", listLocation), Query.EQ("CN_S_STATUS", "报废"));
            lstLocation = MongoDBSingleton.Instance.Find<AutoBomLocationAbbreEntity>(query, "TN_AB_STOCK_LOCATION");
            return lstLocation;
        }
        #region 根据库区编码获得该库区下所有的货位，针对货位有效，站点无效
        /// <summary>
        /// 根据库区编码获得该库区下所有的货位
        /// </summary>
        /// <param name="areaCode"></param>
        /// <returns></returns>
        public List<AutoBomLocationAbbreEntity> GetLocationByAreaCode(string areaCode)
        {
            var query = Query.And(Query.EQ("CN_S_AREA_CODE", areaCode), Query.NE("CN_S_STATUS", "报废"));
            //var query = Query.And(Query.EQ("CN_S_AREA_CODE", areaCode),Query.EQ("CN_S_AREA_CODE", areaCode), Query.NE("CN_S_STATUS", "报废"));
            List<AutoBomLocationAbbreEntity> lstLocation = MongoDBSingleton.Instance.Find<AutoBomLocationAbbreEntity>(query, "TN_AB_STOCK_LOCATION");
            //List<AutoBomStockStructreEntity> lstStruct = GetStructList(areaCode);
            //if (lstStruct != null && lstStruct.Count > 0)
            //{
            //    //获得仓库编号
            //    string stockCode = lstStruct[0].CN_S_STOCK_CODE;
            //    //获得排列表
            //    var listRow = lstStruct.ConvertAll<BsonValue>(x => x.CN_S_ROW);
            //    //作为查询条件
            //    var query = Query.And(Query.EQ("CN_S_STOCK_CODE", stockCode), Query.NE("CN_S_STATUS", "报废"), Query.In("CN_S_ROW", listRow));
            //    lstLocation = MongoDBSingleton.Instance.Find<AutoBomLocationEntity>(oquery, "TN_AB_STOCK_LOCATION");
            //}
            return lstLocation;
        }
        #endregion
        #region 根据库区编码获得该库区下所有的货位，针对货位有效，站点无效
        /// <summary>
        /// 根据库区编码获得该库区下所有的货位
        /// </summary>
        /// <param name="areaCode"></param>
        /// <returns></returns>
        public List<AutoBomLocationAbbreEntity> GetLocationByAreaCode(string areaCode,string CN_S_TYPE)
        {
            var query = Query.And(Query.EQ("CN_S_AREA_CODE", areaCode), Query.EQ("CN_S_TYPE", CN_S_TYPE), Query.NE("CN_S_STATUS", "报废"));
            List<AutoBomLocationAbbreEntity> lstLocation = MongoDBSingleton.Instance.Find<AutoBomLocationAbbreEntity>(query, "TN_AB_STOCK_LOCATION");
            //List<AutoBomStockStructreEntity> lstStruct = GetStructList(areaCode);
            //if (lstStruct != null && lstStruct.Count > 0)
            //{
            //    //获得仓库编号
            //    string stockCode = lstStruct[0].CN_S_STOCK_CODE;
            //    //获得排列表
            //    var listRow = lstStruct.ConvertAll<BsonValue>(x => x.CN_S_ROW);
            //    //作为查询条件
            //    var query = Query.And(Query.EQ("CN_S_STOCK_CODE", stockCode), Query.NE("CN_S_STATUS", "报废"), Query.In("CN_S_ROW", listRow));
            //    lstLocation = MongoDBSingleton.Instance.Find<AutoBomLocationEntity>(query, "TN_AB_STOCK_LOCATION");
            //}
            return lstLocation;
        }
        #endregion

        #region 更新货位表中的入库任务数量
        /// <summary>
        /// 根据库区编码获得该库区下所有的货位
        /// </summary>
        /// <param name="areaCode"></param>
        /// <returns></returns>
        public bool UpdateLocationTaskQty(string locationCode, int CN_N_INTASK_QTY)
        {
            bool result = false;
            var query = Query.EQ("CN_S_LOCATION_CODE", locationCode);
            IMongoUpdate update = Update.Set("CN_N_INTASK_QTY", CN_N_INTASK_QTY);
            result = MongoDBSingleton.Instance.Update<AutoBomLocationAbbreEntity>(query, update, "TN_AB_STOCK_LOCATION", UpdateFlags.Multi);
            return result;
        }
        #endregion


        #region 查询mongo
        public List<AutoBomItemEntity> GetItemList(string itemcode, int pageIndex, int pageSize)
        {
            var query = Query.And(Query.EQ("CN_S_ITEM_CODE", itemcode));
            //SortByDocument sortBy = new SortByDocument();
            //List<AutoBomItemEntity> lstStruct = MongoDBSingleton.Instance.Find<AutoBomItemEntity>(query, pageIndex, pageSize, sortBy, "TN_AB_ITEM");
            List<AutoBomItemEntity> lstStruct = MongoDBSingleton.Instance.Find<AutoBomItemEntity>(query, "TN_AB_ITEM");
            return lstStruct;
        }
        #endregion


    }
}