using JiepeiWMS.IServices;
using JiepeiWMS.Model.Models;
using JiepeiWMS.Services.BASE;
using JiepeiWMS.IRepository.Base;
using System.Threading.Tasks;
using JiepeiWMS.Model;
using System.Linq.Expressions;
using System;
using SqlSugar;
using JiepeiWMS.Common.Helper;
using JiepeiWMS.Common.Enums;
using JiepeiWMS.Services.SearchModels;
using System.Collections.Generic;
using System.Text;

namespace JiepeiWMS.Services
{
    public class WMCheckInfoServices : BaseServices<WMCheckInfo>, IWMCheckInfoServices
    {
        private readonly IBaseRepository<WMCheckInfo> _dal;
        public WMCheckInfoServices(IBaseRepository<WMCheckInfo> dal)
        {
            this._dal = dal;
            base.BaseDal = dal;
        }

        /// <summary>
        /// 搜索选项
        /// </summary>
        /// <param name="Search">查询信息</param>
        /// <param name="JoinTableAliass">关联表别名列表</param>
        /// <param name="InJoinTables">In优化表关联列表</param>
        /// <returns>Sql条件(不带where)</returns>
        public static string GetSearchInfo(ShearchWMCheckInfo Search, HashSet<string> JoinTableAliass, List<string> InJoinTables)
        {
            var where = new StringBuilder();

            ////新参数JoinTableAliass事例，关联其它表时需加别名（SQL效率优化）
            //if (string.IsNullOrEmpty(Search.PinBanNo))
            //{
            //    where.Append(" and pb.[OrderNo] = " + Search.PinBanNo);
            //    JoinTableAliass.Add("pb");
            //}
            ////新参数InJoinTables事例，关联其它表时需加别名，同时又用In关联（SQL效率优化）
            //if (Search.PinBanStatus.HasValue)
            //{
            //    InJoinTables.Add(GetWhereInToJoin("[Status]", Search.StatusList.Split(','), "pb"));
            //    JoinTableAliass.Add("pb");
            //}

            if (Search.Id.HasValue)
            {
                where.Append(" and pg.[Id] = " + Search.Id);
                JoinTableAliass.Add("pg");
            }

            if (!string.IsNullOrEmpty(Search.IdList))
            {
                where.Append(" and pg.[Id] in (" + Search.IdList + ")");
                JoinTableAliass.Add("pg");
            }

            if (Search.Status.HasValue)
            {
                where.Append(" and pg.[Status] = " + Search.Status);
                JoinTableAliass.Add("pg");
            }

            if (Search.StartStatus.HasValue)
            {
                where.Append(" and pg.[Status] >= " + Search.StartStatus);
                JoinTableAliass.Add("pg");
            }

            if (Search.ListStatus != null)
            {
                //此实现可使用到索引
                InJoinTables.Add(GetWhereInToJoin("[Status]", Search.ListStatus));
            }

            if (Search.StartCreateTime.HasValue)
            {
                where.Append(" and pg.[CreateTime] >= '" + Search.StartCreateTime.Value.ToString("yyyy-MM-dd HH:mm:ss") + "'");
                JoinTableAliass.Add("pg");
            }

            if (Search.EndCreateTime.HasValue)
            {
                where.Append(" and pg.[CreateTime] <= '" + Search.EndCreateTime.Value.ToString("yyyy-MM-dd HH:mm:ss") + "'");
                JoinTableAliass.Add("pg");
            }

            if (!string.IsNullOrEmpty(Search.Key))
            {
                where.Append("pg.[Key] like '" + Search.Key.Replace("'", "''") + "%'");
            }

            return where.Length == 0 ? string.Empty : where.ToString(5, where.Length - 5);
        }


        public async Task<PageModel<WMCheckInfo>> QueryPage(Expression<Func<WMCheckInfo, Department, bool>> whereExpression,
int intPageIndex = 1, int intPageSize = 20, string strOrderByFileds = null)
        {
            var plst = await BaseDal.QueryPage<WMCheckInfo, Department>(
                (ci, dp) => new object[]{
                    JoinType.Left,ci.DepartId==dp.Id
                },
                (ci, dp) => new WMCheckInfo
                {
                    CheckName = ci.CheckName,
                    DepartName = dp.Name,
                    Id = ci.Id,
                    DepartId = ci.DepartId,
                    CheckRemark = ci.CheckRemark,
                    CheckType = ci.CheckType,
                    CreateTime = ci.CreateTime,
                    IsEnable = ci.IsEnable,
                    Json = ci.Json,
                    Key = ci.Key,
                    UpDateTime = ci.UpDateTime
                },
                whereExpression,
                intPageIndex,
                intPageSize,
                strOrderByFileds);

            var dic = typeof(EnumWMCheckType)._GetValueDescriptionDicFromEnumType<EnumWMCheckType>();
            foreach (var i in plst.data)
            {
                string name;
                i.CheckTypeName = dic.TryGetValue((EnumWMCheckType)i.CheckType, out name) ? name : string.Empty;
            }

            return plst;
        }
    

    }
}