using System;
using System.Collections.Generic;
using System.Linq;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using System.Web.Mvc;
using Abp.Application.Services.Dto;
using Abp.Auditing;
using Abp.Authorization;
using Abp.Domain.Repositories;
using Abp.Extensions;
using Abp.Runtime.Caching;
using IwbZero.AppServiceBase;
using IwbZero.Helper;
using ShwasherSys.Authorization.Permissions;
using ShwasherSys.Common;
using ShwasherSys.Order.Dto;
namespace ShwasherSys.Order
{
    [AbpAuthorize]
    public class ScheduleOrderSendAppService : IwbZeroAsyncCrudAppService<ScheduleOrderSend, ScheduleOrderSendDto, int, IwbPagedRequestDto, ScheduleOrderSendCreateDto, ScheduleOrderSendUpdateDto >, IScheduleOrderSendAppService
    {
        public ScheduleOrderSendAppService(
			ICacheManager cacheManager,
			IRepository<ScheduleOrderSend, int> repository, IRepository<ScheduleOrderSendView> scheduleOrderSendViewRepository) : base(repository, "Id")
        {
	        ScheduleOrderSendViewRepository = scheduleOrderSendViewRepository;
	        CacheManager = cacheManager;
        }

        protected override bool KeyIsAuto { get; set; } = false;

        protected IRepository<ScheduleOrderSendView> ScheduleOrderSendViewRepository { get; }

		#region GetSelect

		[DisableAuditing]
        public override async Task<List<SelectListItem>> GetSelectList()
        {
            var list = await Repository.GetAllListAsync();
            var sList = new List<SelectListItem> {new SelectListItem {Text = @"请选择...", Value = "", Selected = true}};
            foreach (var l in list)
            {
                //sList.Add(new SelectListItem { Value = l.Id, Text = l. });
            }
            return sList;
        }
        [DisableAuditing]
        public override async Task<string> GetSelectStr()
        {
            var list = await Repository.GetAllListAsync();
            string str = "<option value=\"\" selected>请选择...</option>";
            foreach (var l in list)
            {
                //str += $"<option value=\"{l.Id}\">{l.}</option>";
            }
            return str;
        }

        #endregion

        #region CURD

        [AbpAuthorize(PermissionNames.PagesOrderInfoOrderSendWarn)]
        public override async Task Create(ScheduleOrderSendCreateDto input)
        {
            await CreateEntity(input);
        }

        [AbpAuthorize(PermissionNames.PagesOrderInfoOrderSendWarn)]
        public override async Task Update(ScheduleOrderSendUpdateDto input)
        {
            await UpdateEntity(input);
        }

        [AbpAuthorize(PermissionNames.PagesOrderInfoOrderSendWarn)]
        public override Task Delete(EntityDto<int> input)
        {
            return Repository.DeleteAsync(input.Id);
        }

        [DisableAuditing]
        [AbpAuthorize(PermissionNames.PagesOrderInfoOrderSendWarn)]
        public override async Task<PagedResultDto<ScheduleOrderSendDto>> GetAll(IwbPagedRequestDto input)
        {
			var query = CreateFilteredQuery(input);
			query = ApplyFilter(query, input);
			var totalCount = await AsyncQueryableExecuter.CountAsync(query);
			query = ApplySorting(query, input);
			query = ApplyPaging(query, input);
			var entities = await AsyncQueryableExecuter.ToListAsync(query);
			var dtoList = new PagedResultDto<ScheduleOrderSendDto>(totalCount, entities.Select(MapToEntityDto).ToList());
			return dtoList;
		
		}
        [DisableAuditing]
        [AbpAuthorize(PermissionNames.PagesOrderInfoOrderSendWarn)]
		public async Task<PagedResultDto<ScheduleOrderSendView>> GetAllView(IwbPagedRequestDto input)
        {
	        var query = ScheduleOrderSendViewRepository.GetAll();

	        if (input.SearchList != null && input.SearchList.Count > 0)
	        {
		        List<LambdaObject> objList = new List<LambdaObject>();
		        foreach (var o in input.SearchList)
		        {
			        if (o.KeyWords.IsNullOrEmpty())
				        continue;
			        object keyWords = o.KeyWords;
			        if (o.KeyField == "showAll")
			        {
                        //默认不显示已取消提醒的，默认为0不选中，选中为1则全部显示
				        if (keyWords.ToString() == "0")
				        {
					        objList.Add(new LambdaObject
					        {
						        FieldType = LambdaFieldType.I,
						        FieldName = "sendState",
						        FieldValue = keyWords,
						        ExpType = (LambdaExpType)o.ExpType,
					        });
						}
						continue;
			        }
			        if (o.KeyField == "planDay")
			        {
				        DateTime d1 = DateTime.Now.AddDays(Convert.ToInt16(keyWords));

						//默认显示3天内的
						objList.Add(new LambdaObject
						{
							FieldType = LambdaFieldType.Dnull,
							FieldName = "planDate",
							FieldValue = d1,
							ExpType = LambdaExpType.LessOrEqual,
						});
						continue;
			        }
					//检查查询条件中带有规格且多个分割条件的
					ProductModelSearch.CheckModelGreaterOneFilter(o, ref keyWords);
			        objList.Add(new LambdaObject
			        {
				        FieldType = (LambdaFieldType)o.FieldType,
				        FieldName = o.KeyField,
				        FieldValue = keyWords,
				        ExpType = (LambdaExpType)o.ExpType,
			        });

		        }
		        var exp = objList.GetExp<ScheduleOrderSendView>();
		        query = query.Where(exp);
	        }


	        var totalCount = await AsyncQueryableExecuter.CountAsync(query);
	        query = query.OrderBy(i => i.PlanDate);

	        string pattern = ProductModelSearch.GetModelGreaterOneReg(input.SearchList);
	        List<ScheduleOrderSendView> entities;
	        //检查查询条件中带有规格且多个分割条件的
	        if (!pattern.IsNullOrEmpty())
	        {
		        var es = query.ToList();
		        es = es.Where(f => f.Model != null && Regex.IsMatch(f.Model, pattern)).ToList();
		        totalCount = es.Count;
		        entities = es.Skip(input.SkipCount).Take(input.MaxResultCount).ToList();
	        }
	        else
	        {
		        query = query.Skip(input.SkipCount).Take(input.MaxResultCount);
		        entities = await AsyncQueryableExecuter.ToListAsync(query);
	        }
	        var dtos = new PagedResultDto<ScheduleOrderSendView>(
		        totalCount,
		        entities
	        );
	        return dtos;
		}

		[AbpAuthorize(PermissionNames.PagesOrderInfoOrderSendWarnChangeStatus)]
		public async Task ChangeItemState(string id)
		{
			try
			{
				var arrIds = id.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
				int[] ids = Array.ConvertAll(arrIds, int.Parse);

				foreach (var rid in ids)
				{
					var entity = await Repository.GetAsync(rid);
					entity.SendState = 1;
					await Repository.UpdateAsync(entity);
				}
			}
			catch (Exception e)
			{
                this.LogInfo(e.Message);
				CheckErrors("变更失败！请联系系统管理员！");
			}
			
		}


		#region GetEntity/Dto

		/// <summary>
		///  查询实体Dto
		/// </summary>
		/// <param name="input"></param>
		/// <returns></returns>
		[DisableAuditing]
       // [AbpAuthorize(PermissionNames.PagesMgScheduleOrderSendMgQuery)]
        public override async Task<ScheduleOrderSendDto> GetDto(EntityDto<int> input)
        {
            var entity = await GetEntity(input);
            return MapToEntityDto(entity);
        }

        /// <summary>
        ///  查询实体Dto
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [DisableAuditing]
       // [AbpAuthorize(PermissionNames.PagesMgScheduleOrderSendMgQuery)]
        public override async Task<ScheduleOrderSendDto> GetDtoById(int id)
        {
            var entity = await GetEntityById(id);
            return MapToEntityDto(entity);
        }

        /// <summary>
        /// 查询实体Dto（需指明自定义字段）
        /// </summary>
        /// <param name="no"></param>
        /// <returns></returns>
        [DisableAuditing]
      //  [AbpAuthorize(PermissionNames.PagesMgScheduleOrderSendMgQuery)]
        public override async Task<ScheduleOrderSendDto> GetDtoByNo(string no)
        {
            var entity = await GetEntityByNo(no);
            return MapToEntityDto(entity);
        }

        /// <summary>
        /// 查询实体
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [DisableAuditing]
       // [AbpAuthorize(PermissionNames.PagesMgScheduleOrderSendMgQuery)]
        public override async Task<ScheduleOrderSend> GetEntity(EntityDto<int> input)
        {
            var entity = await GetEntityById(input.Id);
            return entity;
        }

        /// <summary>
        /// 查询实体
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [DisableAuditing]
       // [AbpAuthorize(PermissionNames.PagesMgScheduleOrderSendMgQuery)]
        public override async Task<ScheduleOrderSend> GetEntityById(int id)
        {
            return await Repository.FirstOrDefaultAsync(a=>a.Id==id);
        }

        /// <summary>
        /// 查询实体（需指明自定义字段）
        /// </summary>
        /// <param name="no"></param>
        /// <returns></returns>
        [DisableAuditing]
       // [AbpAuthorize(PermissionNames.PagesMgScheduleOrderSendMgQuery)]
        public override async Task<ScheduleOrderSend> GetEntityByNo(string no)
        {
            //CheckGetPermission();
            if (string.IsNullOrEmpty(KeyFiledName))
            {
                ThrowError("NoKeyFieldName");
            }
            return await base.GetEntityByNo(no);
        }

        #endregion

		#region Hide
       
		///// <summary>
        ///// 根据给定的<see cref="IwbPagedRequestDto"/>创建 <see cref="IQueryable{ScheduleOrderSend}"/>过滤查询.
        ///// </summary>
        ///// <param name="input">The input.</param>
        //protected override IQueryable<ScheduleOrderSend> CreateFilteredQuery(IwbPagedRequestDto input)
        //{
        //    var query = Repository.GetAll();
        //    var pagedInput = input as IIwbPagedRequest;
        //    if (pagedInput == null)
        //    {
        //        return query;
        //    }
        //    if (!string.IsNullOrEmpty(pagedInput.KeyWords))
        //    {
        //        object keyWords = pagedInput.KeyWords;
        //        LambdaObject obj = new LambdaObject()
        //        {
        //            FieldType = (LambdaFieldType)pagedInput.FieldType,
        //            FieldName = pagedInput.KeyField,
        //            FieldValue = keyWords,
        //            ExpType = (LambdaExpType)pagedInput.ExpType
        //        };
        //        var exp = obj.GetExp<ScheduleOrderSend>();
        //        query = exp != null ? query.Where(exp) : query;
        //    }
        //    if (pagedInput.SearchList != null && pagedInput.SearchList.Count > 0)
        //    {
        //        List<LambdaObject> objList = new List<LambdaObject>();
        //       foreach (var o in pagedInput.SearchList)
        //        {
        //            if (string.IsNullOrEmpty(o.KeyWords))
        //                continue;
        //           object keyWords = o.KeyWords;
        //            objList.Add(new LambdaObject
        //            {
        //                FieldType = (LambdaFieldType)o.FieldType,
        //                FieldName = o.KeyField,
        //                FieldValue = keyWords,
        //                ExpType = (LambdaExpType)o.ExpType
        //            });
        //        }
        //        var exp = objList.GetExp<ScheduleOrderSend>();
        //        query = exp != null ? query.Where(exp) : query;
        //    }
        //    return query;
        //}



        //protected override IQueryable<ScheduleOrderSend> ApplySorting(IQueryable<ScheduleOrderSend> query, IwbPagedRequestDto input)
        //{
        //    return query.OrderBy(a => a.No);
        //}

        //protected override IQueryable<ScheduleOrderSend> ApplyPaging(IQueryable<ScheduleOrderSend> query, IwbPagedRequestDto input)
        //{
        //    if (input is IPagedResultRequest pagedInput)
        //    {
        //        return query.Skip(pagedInput.SkipCount).Take(pagedInput.MaxResultCount);
        //    }
        //    return query;
        //}

        #endregion

        #endregion

    }
}