using HH.MData;
using HH.WMS.Entitys.Basic;
using HH.WMS.Entitys.Common;
using MongoDB.Bson;
using MongoDB.Driver.Builders;
/********************************************************************************

** auth： DBS

** date： 2018/11/14 20:37:11

** desc： 尚未编写描述

** Ver.:  V1.0.0

*********************************************************************************/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Data;
using MongoDB.Driver;

namespace HH.WMS.DAL.Basic
{
    public class MONGO_PRINT_BARCODEDAL:BaseDAL
    {
        public List<MONGO_PRINT_BARCODE> GetPageList(int pageIndex, int pageSize, out int total)
        {
            List<MONGO_PRINT_BARCODE> entity = new List<MONGO_PRINT_BARCODE>();
            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, "MONGO_PRINT_BARCODE"));
            entity = MongoDBSingleton.Instance.Find<MONGO_PRINT_BARCODE>(query, pageIndex, pageSize, sortBy, "MONGO_PRINT_BARCODE");
            return entity;
        }

        public MONGO_PRINT_BARCODE GetValue(string barCode)
        {
            MONGO_PRINT_BARCODE entity = new MONGO_PRINT_BARCODE();
            var query = Query.EQ("CN_S_UNIQUE_CODE", barCode);
            entity = MongoDBSingleton.Instance.FindOne<MONGO_PRINT_BARCODE>(query, "MONGO_PRINT_BARCODE");
            return entity;
        }
        public MONGO_PRINT_BARCODE GetValueYS(string barCode,string isUse)
        {
            MONGO_PRINT_BARCODE entity = new MONGO_PRINT_BARCODE();
            var query = Query.EQ("CN_S_UNIQUE_CODE", barCode);
            query = Query.And(query, Query.EQ("CN_S_IS_USE", isUse));
            entity = MongoDBSingleton.Instance.FindOne<MONGO_PRINT_BARCODE>(query, "MONGO_PRINT_BARCODE");
            return entity;
        }
        public List<MONGO_PRINT_BARCODE> GetValueBackYS(string barCode, string isUse)
        {
            List<MONGO_PRINT_BARCODE> entity = new List<MONGO_PRINT_BARCODE>();
            var query = Query.EQ("CN_S_UNIQUE_CODE", barCode);
            query = Query.And(query, Query.EQ("CN_S_IS_USE", isUse));
            //定义排序  按优先级正序排列
            //SortByDocument sort = new SortByDocument { { "CN_T_CREATE", 1 } };
            entity = MongoDBSingleton.Instance.Find<MONGO_PRINT_BARCODE>(query,1 ,"CN_T_CREATE", "MONGO_PRINT_BARCODE");
            return entity;
        }
        public MONGO_PRINT_BARCODE GetFieldValue(string fieldStr, string scanCode)
        {
            MONGO_PRINT_BARCODE entity = new MONGO_PRINT_BARCODE();
            var query = Query.EQ(fieldStr, scanCode);
            entity = MongoDBSingleton.Instance.FindOne<MONGO_PRINT_BARCODE>(query, "MONGO_PRINT_BARCODE");
            return entity;
        }

        /// <summary>
        /// 新增MONGO_PRINT_BARCODE表
        /// </summary>
        /// <param name="lists"></param>
        /// <returns></returns>
        public bool AddPintBarcode(List<MONGO_PRINT_BARCODE> list)
        {
            return MongoDBSingleton.Instance.Insert<MONGO_PRINT_BARCODE>(list, "MONGO_PRINT_BARCODE");
        }

        /// <summary>
        /// 新增MONGO_KEYTYPE_MAP表
        /// </summary>
        /// <param name="lists"></param>
        /// <returns></returns>
        public bool AddKeyType(List<MONGO_KEYTYPE_MAP> list)
        {
            return MongoDBSingleton.Instance.Insert<MONGO_KEYTYPE_MAP>(list, "MONGO_KEYTYPE_MAP");
        }


        #region 根据唯一码获取打码标签
        /// <summary>
        /// 获取打码标签
        /// </summary>
        /// <param name="barCode"></param>
        /// <returns></returns>
        /// <history>[HANHE(lt)] CREATED BY 2018-12-15</history>
        public List<MONGO_PRINT_BARCODE> GetBarCodeList(List<string> barCodes)
        {
            List<MONGO_PRINT_BARCODE> entity = new List<MONGO_PRINT_BARCODE>();
            var barCode = barCodes.ConvertAll<BsonValue>(x => x);
            var query = Query.In("CN_S_UNIQUE_CODE", barCode);
            entity = MongoDBSingleton.Instance.Find<MONGO_PRINT_BARCODE>(query, "MONGO_PRINT_BARCODE");
            return entity;
        }

        /// <summary>
        /// 模糊查询
        /// </summary>
        /// <param name="scanCode"></param>
        /// <returns></returns>
        public MONGO_PRINT_BARCODE GetLikeValue(string scanCode)
        {
            var query = Query.Or(
                Query.EQ("CN_S_ITEM_CODE", scanCode), 
                Query.EQ("CN_S_UNIQUE_CODE", scanCode),
                Query.EQ("CN_S_SERIAL_NO", scanCode)
                );
            MONGO_PRINT_BARCODE entity = MongoDBSingleton.Instance.FindOne<MONGO_PRINT_BARCODE>(query, "MONGO_PRINT_BARCODE");
            return entity;
        }

        #endregion

        #region 更新重量

        public bool UpdateWeight(string uniqueCode, string weight, string lotNo, string figureNo, AutoBomItemEntity autoBomItem, string zweight, string zzweight)
        {
            IMongoQuery query = Query.EQ("CN_S_UNIQUE_CODE", uniqueCode);
            List<UpdateBuilder> updateList = new List<UpdateBuilder>();
            updateList.Add(Update.Set("CN_S_SERIAL_NO", weight));
            updateList.Add(Update.Set("CN_S_ITEM_CODE", autoBomItem.CN_S_ITEM_CODE));
            updateList.Add(Update.Set("CN_S_ITEM_NAME", autoBomItem.CN_S_ITEM_NAME));
            updateList.Add(Update.Set("CN_S_FIGURE_NO", figureNo));
            updateList.Add(Update.Set("CN_S_LOT_NO", lotNo));
            updateList.Add(Update.Set("CN_T_CREATE", DateTime.Now.AddHours(8)));
            updateList.Add(Update.Set("CN_S_IS_USE", "Y"));
            updateList.Add(Update.Set("CN_S_PACKING_UNIT", zweight));
            updateList.Add(Update.Set("CN_F_PACKING_QTY", zzweight));
            IMongoUpdate update = Update.Combine(updateList.ToArray());
            return MongoDBSingleton.Instance.Update<MONGO_PRINT_BARCODE>(query, update, "MONGO_PRINT_BARCODE", UpdateFlags.Multi);
        }

        #endregion

        #region 根据唯一码删除记录
         
        public bool DeleteByUniqueCode(string uniqueCode)
        {
            IMongoQuery query = Query.EQ("CN_S_UNIQUE_CODE", uniqueCode);
            return MongoDBSingleton.Instance.Remove<MONGO_PRINT_BARCODE>(query, "MONGO_PRINT_BARCODE", RemoveFlags.Single);
        }

        #endregion

        #region 更新使用状态

        public bool UpdateUpMetarialState(string uniqueCode, string isUse)
        {
            IMongoQuery query = Query.EQ("CN_S_UNIQUE_CODE", uniqueCode);
            List<UpdateBuilder> updateList = new List<UpdateBuilder>();
            updateList.Add(Update.Set("CN_S_IS_USE", isUse));
            IMongoUpdate update = Update.Combine(updateList.ToArray());
            return MongoDBSingleton.Instance.Update<MONGO_PRINT_BARCODE>(query, update, "MONGO_PRINT_BARCODE", UpdateFlags.Multi);
        }

        #endregion

        #region 更新重量

        public bool UpdateZX(string uniqueCode, string weight, string qty,string lotNo, string figureNo, AutoBomItemEntity autoBomItem)
        {
            IMongoQuery query = Query.EQ("CN_S_UNIQUE_CODE", uniqueCode);
            List<UpdateBuilder> updateList = new List<UpdateBuilder>();
            updateList.Add(Update.Set("CN_S_SERIAL_NO", weight));
            updateList.Add(Update.Set("CN_F_PACKING_QTY", qty));
            updateList.Add(Update.Set("CN_S_ITEM_CODE", autoBomItem.CN_S_ITEM_CODE));
            updateList.Add(Update.Set("CN_S_ITEM_NAME", autoBomItem.CN_S_ITEM_NAME));
            updateList.Add(Update.Set("CN_S_MODEL", autoBomItem.CN_S_MODEL));
            updateList.Add(Update.Set("CN_S_FIGURE_NO", figureNo));
            updateList.Add(Update.Set("CN_S_LOT_NO", lotNo));
            IMongoUpdate update = Update.Combine(updateList.ToArray());
            return MongoDBSingleton.Instance.Update<MONGO_PRINT_BARCODE>(query, update, "MONGO_PRINT_BARCODE", UpdateFlags.Multi);
        }

        #endregion
    }
}