using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
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.Runtime.Caching;
using IwbZero.AppServiceBase;
using ShwasherSys.Authorization.Permissions;
using ShwasherSys.EntityFramework;
using ShwasherSys.ProductInfo.Dto;
namespace ShwasherSys.ProductInfo
{
    [AbpAuthorize]
    public class ProductMapperAppService : IwbZeroAsyncCrudAppService<ProductMapper, ProductMapperDto, int, IwbPagedRequestDto, ProductMapperCreateDto, ProductMapperUpdateDto >, IProductMapperAppService
    {
        public ProductMapperAppService(
			ICacheManager cacheManager,
			IRepository<ProductMapper, int> repository, ISqlExecuter sqlExecuter) : base(repository, "Id")
        {
            CacheManager = cacheManager;
            SqlExecuter = sqlExecuter;
        }
        protected ISqlExecuter SqlExecuter;
        protected override bool KeyIsAuto { get; set; } = false;

        #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.PagesMgProductMapperMgCreate)]
        public override async Task Create(ProductMapperCreateDto input)
        {
            await CreateEntity(input);
        }

       // [AbpAuthorize(PermissionNames.PagesMgProductMapperMgUpdate)]
        public override async Task Update(ProductMapperUpdateDto input)
        {
            await UpdateEntity(input);
        }

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

        [DisableAuditing]
       // [AbpAuthorize(PermissionNames.PagesMgProductMapperMgQuery)]
        public override async Task<PagedResultDto<ProductMapperDto>> GetAll(IwbPagedRequestDto input)
        {
            var query = CreateFilteredQuery(input);
            query = ApplyFilter(query, input);
            var totalCount = await AsyncQueryableExecuter.CountAsync(query);
            query = query.OrderByDescending(i=>i.CreationTime);
            query = ApplyPaging(query, input);
            var entities = await AsyncQueryableExecuter.ToListAsync(query);
            var dtoList = new PagedResultDto<ProductMapperDto>(totalCount, entities.Select(MapToEntityDto).ToList());
            return dtoList;
        }

		#region GetEntity/Dto

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

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

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

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

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

        /// <summary>
        /// 查询实体（需指明自定义字段）
        /// </summary>
        /// <param name="no"></param>
        /// <returns></returns>
        [DisableAuditing]
      //  [AbpAuthorize(PermissionNames.PagesMgProductMapperMgQuery)]
        public override async Task<ProductMapper> 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{ProductMapper}"/>过滤查询.
        ///// </summary>
        ///// <param name="input">The input.</param>
        //protected override IQueryable<ProductMapper> 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<ProductMapper>();
        //        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<ProductMapper>();
        //        query = exp != null ? query.Where(exp) : query;
        //    }
        //    return query;
        //}



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

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

        #endregion

        #endregion


        public async  Task<List<ReturnReplaceResultDto>> ReplaceProductNo(ReplaceProductDto input)
        {
            var preReplaceProductDtos = input.PreReplaceProducts;
            string pNo = input.ProductNo;
            List<ReturnReplaceResultDto> rps = new List<ReturnReplaceResultDto>();
            foreach (var preReplaceProductDto in preReplaceProductDtos)
            {
                string procedure = preReplaceProductDto.ProductType == "1"?"[dbo].[Sp_ModifyProductNo]": "[dbo].[Sp_ModifySemiProductNo]";
               
                var sqlParms = new object[3];
                sqlParms[0] = new SqlParameter("@OldPid", preReplaceProductDto.ReplaceProductNo);
                sqlParms[1] = new SqlParameter("@NewPid", pNo);
                sqlParms[2] = new SqlParameter("@RetCode", SqlDbType.Int) { Direction = ParameterDirection.Output };
                ReturnReplaceResultDto rpDto = new ReturnReplaceResultDto();
                try
                {
                    var result = SqlExecuter.Execute($"exec {procedure} @OldPid,@NewPid,@RetCode out", sqlParms);
                    int reCode = (int)((SqlParameter)sqlParms[2]).Value;
                    LogHelper.LogError(this, "执行结果：" + reCode + "---旧编码：" + preReplaceProductDto.ReplaceProductNo + "---新编码：" + pNo);
                    int productType = Convert.ToInt16(preReplaceProductDto.ProductType);
                    var checkEntiy = await Repository.FirstOrDefaultAsync(i =>
                        i.ProductNo == pNo && i.PreProductNo == preReplaceProductDto.ReplaceProductNo &&
                        i.PreProductType == productType);
                    if (checkEntiy == null)
                    {
                        var entity = new ProductMapper()
                        {
                            ProductNo = pNo,
                            PreProductNo = preReplaceProductDto.ReplaceProductNo,
                            PreProductType = productType
                        };
                        Repository.Insert(entity);
                    }
                    rpDto.IsSuccess = true;
                    rpDto.ProductNo = preReplaceProductDto.ReplaceProductNo;
                    rpDto.RetCode = reCode.ToString();
                }
                catch (Exception e)
                {
                    rpDto.IsSuccess = false;
                    rpDto.ProductNo = preReplaceProductDto.ReplaceProductNo;
                    rpDto.ErrorInfo = e.Message;
                    this.LogError( "执行结果错误：" + e.Message + "---旧编码：" + preReplaceProductDto.ReplaceProductNo + "---新编码：" + pNo);
                }
                rps.Add(rpDto);
            }

            return rps;
        }

    }
}