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

namespace HH.WMS.DAL.Basic
{
    public class TN_WMS_ITEMDAL : DapperBaseDAL
    {
        #region 根据物料编码返回物料实体
        /// <summary>
        /// 根据物料编码返回物料实体
        /// </summary>
        /// <param name="itemCode"></param>
        /// <returns></returns>
        public AutoBomItemEntity GetItemEntity(string itemCode)
        {
            AutoBomItemEntity entity = new AutoBomItemEntity();
            var query = Query.EQ("CN_S_ITEM_CODE", itemCode);
            entity = MongoDBSingleton.Instance.FindOne<AutoBomItemEntity>(query, "TN_AB_ITEM");
            return entity;
        }
        public AutoBomItemEntityYS GetItemEntityYS(string itemCode)
        {
            AutoBomItemEntityYS entity = new AutoBomItemEntityYS();
            var query = Query.EQ("CN_S_ITEM_CODE", itemCode);
            entity = MongoDBSingleton.Instance.FindOne<AutoBomItemEntityYS>(query, "TN_AB_ITEM");
            return entity;
        }
        public List<AutoBomItemEntity> GetItemByNameSpec(string itemName, string specification)
        {
            try
            {
                Log.Info("===>进度1", "");
                #region 首先通过物料名称全部匹配查询
                List<IMongoQuery> queryList = new List<IMongoQuery>();
                if (!string.IsNullOrEmpty(itemName))
                {
                    queryList.Add(Query.EQ("CN_S_ITEM_NAME", itemName));
                }
                if (!string.IsNullOrEmpty(specification))
                {
                    queryList.Add(Query.EQ("CN_S_MODEL", specification));
                }
                IMongoQuery query = null;
                if (queryList.Any()) { query = Query.And(queryList); }

                var listCount = MongoDBSingleton.Instance.Find<AutoBomItemEntity>(query, "TN_AB_ITEM");
                #endregion

                if (listCount.Count == 1)//全匹配情况下单条，直接成功返回
                {
                    Log.Info("===>进度2", "");
                    return listCount;
                }
                if (listCount.Count > 1)//全匹配情况下多条，直接报错返回
                {
                    Log.Info("===>进度3", "");
                    return new List<AutoBomItemEntity>();
                }

                if (listCount.Count == 0)//全匹配情况下没有，开始模糊查询
                {

                    Log.Info("===>进度4", "");
                    #region 然后通过物料名称模糊匹配查询
                    queryList = new List<IMongoQuery>();
                    if (!string.IsNullOrEmpty(itemName))
                    {
                        queryList.Add(Query.Matches("CN_S_ITEM_NAME", BsonRegularExpression.Create(new Regex("^" + itemName))));

                    }
                    if (!string.IsNullOrEmpty(specification))
                    {
                        queryList.Add(Query.EQ("CN_S_MODEL", specification));
                    }
                    query = null;
                    if (queryList.Any()) { query = Query.And(queryList); }

                    var listCount1 = MongoDBSingleton.Instance.Find<AutoBomItemEntity>(query, "TN_AB_ITEM");
                    #endregion

                    if (listCount1.Count == 0)//模糊匹配情况下没有，直接报错返回
                    {
                        Log.Info("===>进度5", "");
                        return null;
                    }
                    if (listCount1.Count >= 1)//模糊匹配情况下超过或者等于一条时，开始加括号模糊匹配查询
                    {
                        Log.Info("===>进度6", "");
                        #region 然后通过物料名称加括号模糊匹配查询
                        queryList = new List<IMongoQuery>();
                        if (!string.IsNullOrEmpty(itemName))
                        {
                            queryList.Add(Query.Or(Query.Matches("CN_S_ITEM_NAME", BsonRegularExpression.Create(new Regex("^" + itemName + "\\("))), Query.Or(Query.Matches("CN_S_ITEM_NAME", BsonRegularExpression.Create(new Regex("^" + itemName + "\\（"))))));

                        }
                        if (!string.IsNullOrEmpty(specification))
                        {
                            queryList.Add(Query.EQ("CN_S_MODEL", specification));
                        }
                        query = null;
                        if (queryList.Any()) { query = Query.And(queryList); }

                        var listCount2 = MongoDBSingleton.Instance.Find<AutoBomItemEntity>(query, "TN_AB_ITEM");
                        #endregion
                        if (listCount2.Count >= 1)//多条或者单条的情况下，返回至前台
                        {
                            Log.Info("===>进度7", "");
                            return listCount2;
                        }
                        else//全匹配情况下多条，直接报错返回
                        {
                            Log.Info("===>进度8", "");
                            return new List<AutoBomItemEntity>();
                        }
                    }
                }
                Log.Info("===>进度9", "");
                return new List<AutoBomItemEntity>();
            }
            catch (Exception ex)
            {
                Log.Info("===>进度10", ex.Message.ToString());
                return null;
            }
        }

        /// <summary>
        /// 根据物料编码返回物料实体
        /// </summary>
        /// <param name="itemCode"></param>
        /// <returns></returns>
        public List<AutoBomItemEntity> GetItemList(List<string> itemCodes)
        {
            try
            {
                var itemCode = itemCodes.ConvertAll<BsonValue>(x => x);
                var query = Query.In("CN_S_ITEM_CODE", itemCode);

                List<AutoBomItemEntity> list = MongoDBSingleton.Instance.Find<AutoBomItemEntity>(query, "TN_AB_ITEM");
                return list;
            }
            catch (Exception ex)
            {
                return null;
            }
        }

        /// <summary>
        /// 根据物料编码返回物料实体
        /// </summary>
        /// <param name="itemCode"></param>
        /// <returns></returns>
        public List<AutoBomItemEntity> GetAllItem(string itemCode)
        {
            List<AutoBomItemEntity> list = new List<AutoBomItemEntity>();
            if (string.IsNullOrEmpty(itemCode))
            {
                 list = MongoDBSingleton.Instance.Find<AutoBomItemEntity>(null, "TN_AB_ITEM");
            }
            else
            {
                var query = Query.EQ("CN_S_ITEM_CODE", itemCode);
                list = MongoDBSingleton.Instance.Find<AutoBomItemEntity>(query, "TN_AB_ITEM");
            }
            return list;

        }


        /// <summary>
        /// 根据物料编码返回物料实体
        /// </summary>
        /// <param name="itemCode"></param>
        /// <returns></returns>
        ///  <history>[HanHe(LT)] CREATED 2018/11/26</history>
        ///  <history>[HanHe(DBS)] CREATED 2019/1/7</history>
        public List<AutoBomItemEntity> GetListItemByCode(string itemCode, string itemName, string model, int pageIndex, int pageSize, out int total)
        {
            List<AutoBomItemEntity> entity = new List<AutoBomItemEntity>();
            SortByDocument sortBy = new SortByDocument();
            sortBy.Add("CN_S_ITEM_CODE", -1);

            List<IMongoQuery> queryList = new List<IMongoQuery>();
            if (!string.IsNullOrEmpty(itemCode))
            {
                queryList.Add(Query.Matches("CN_S_ITEM_CODE", itemCode));
            }
            if (!string.IsNullOrEmpty(itemName))
            {
                queryList.Add(Query.Matches("CN_S_ITEM_NAME", itemName));
            }
            if (!string.IsNullOrEmpty(model))
            {
                queryList.Add(Query.Matches("CN_S_MODEL", model));
            }

            IMongoQuery query = null;
            if (queryList.Any())
                query = Query.And(queryList);

            total = Convert.ToInt32(MongoDBSingleton.Instance.FindCount<AutoBomItemEntity>(query, "TN_AB_ITEM"));
            entity = MongoDBSingleton.Instance.Find<AutoBomItemEntity>(query, pageIndex, pageSize, sortBy, "TN_AB_ITEM");
            return entity;
        }
        #endregion

        #region 物料列表
        /// <summary>
        /// 物料列表
        /// </summary>
        /// <returns></returns>
        public List<AutoBomItemEntity> GetItemList(SearchModel searchModel, out int total)
        {
            List<IMongoQuery> queryList = new List<IMongoQuery>();
            if (searchModel.SearchCondition != null)
            {
                string itemCode = Util.ToString(searchModel.SearchCondition.ItemCode);
                if (!string.IsNullOrEmpty(itemCode))
                {
                    queryList.Add(Query.Matches("CN_S_ITEM_CODE", Util.ToMongoLike(itemCode)));
                }
                string itemName = Util.ToString(searchModel.SearchCondition.ItemName);
                if (!string.IsNullOrEmpty(itemName))
                {
                    queryList.Add(Query.Matches("CN_S_ITEM_NAME", Util.ToMongoLike(itemName)));
                }
                string itemModel = Util.ToString(searchModel.SearchCondition.ItemModel);
                if (!string.IsNullOrEmpty(itemModel))
                {
                    queryList.Add(Query.Matches("CN_S_MODEL", Util.ToMongoLike(itemModel)));
                }
                string itemFigureNo = Util.ToString(searchModel.SearchCondition.ItemFigureNo);
                if (!string.IsNullOrEmpty(itemFigureNo))
                {
                    queryList.Add(Query.Matches("CN_S_FIGURE_NO", Util.ToMongoLike(itemFigureNo)));
                }
                string itemOwner = Util.ToStringInput(searchModel.SearchCondition.ItemOwner);
                if (!string.IsNullOrEmpty(itemOwner))
                {
                    string sql = "SELECT * FROM TN_WM_B_STOCK_QTY WHERE CN_S_OWNER='" + itemOwner + "' AND CN_F_QUANTITY>0 ";
                    var stockQtyList = ExecuteQuery<TN_WM_B_STOCK_QTYEntity>(sql);
                    var itemCodes = stockQtyList.ConvertAll<BsonValue>(x => x.CN_S_ITEM_CODE);
                    queryList.Add(Query.In("CN_S_ITEM_CODE", itemCodes));
                }
            }
            IMongoQuery query = null;
            if (queryList.Any())
                query = Query.And(queryList);
            total = Convert.ToInt32(MongoDBSingleton.Instance.FindCount<AutoBomItemEntity>(query, "TN_AB_ITEM"));
            return MongoDBSingleton.Instance.Find<AutoBomItemEntity>(query, searchModel.PageIndex, searchModel.PageSize, null, "TN_AB_ITEM");
        }
        #endregion

        #region 模糊匹配top条
        /// <summary>
        /// 模糊匹配top条
        /// </summary>
        /// <param name="key"></param>
        /// <param name="top"></param>
        /// <returns></returns>
        public List<AutoBomItemEntity> GetMatchItem(string key, int top = 10)
        {
            IMongoQuery query = Query.Matches("CN_S_ITEM_CODE", "/" + key + "/");
            return MongoDBSingleton.Instance.Find<AutoBomItemEntity>(query, 1, top, null, "TN_AB_ITEM");
        }
        #endregion

        public TN_AB_B_ITEM_PRICEEntity GetItemPriceModel(string itemCode)
        {
            try
            {
                TN_AB_B_ITEM_PRICEEntity entity = new TN_AB_B_ITEM_PRICEEntity();
                var query = Query.And(Query.EQ("CN_S_ITEM_CODE", itemCode), Query.EQ("CN_S_PRICE_TYPE", "标准成本"));
                entity = MongoDBSingleton.Instance.FindOne<TN_AB_B_ITEM_PRICEEntity>(query, "TN_AB_B_ITEM_PRICE");
                return entity;
            }
            catch (Exception ex)
            {

            }
            return null;
        }


        //public List<AutoBomItemEntity> GetItemList()
        //{
        //   var list= MongoDBSingleton.Instance.Find<AutoBomItemEntity>(null, "TN_AB_ITEM");
        //   return list;
        //}
    }
}