using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading.Tasks;
using JNPF.Common.Enums;
using JNPF.Common.Security;
using JNPF.FriendlyException;
using SqlSugar;
using Tnb.EquipMgr.Entities.Dto;
using Tnb.EquipMgr.Entities;
using Mapster;
using JNPF.Common.Contracts;
using JNPF.Common.Extension;

namespace Tnb.EquipMgr
{
    public class BaseMoldMaintainService
    {
        private readonly ISqlSugarClient _db;
        public BaseMoldMaintainService(ISqlSugarClient db)
        {
            _db = db;
        }
        /// <summary>
        /// 关联
        /// </summary>
        /// <typeparam name="TSrc">输入参数类型</typeparam>
        /// <typeparam name="TDest">目标数据库表类型</typeparam>
        /// <param name="input">输入参数</param>
        /// <param name="mColumnName">主表属性名称</param>
        /// <param name="name">次表属性名称</param>
        /// <param name="deleleExp">删除条件</param>
        /// <returns></returns>
        /// <exception cref="ArgumentNullException"></exception>
        protected async Task Relevance<TSrc, TDest>(TSrc input, string mColumnName, string name, Expression<Func<TDest, bool>> deleleExp) where TDest : BaseEntity<string>, new()
                                                              where TSrc : BaseMoldMaintainInput
        {
            if (input == null) throw new ArgumentNullException(nameof(input));
            await _db.Deleteable<TDest>().Where(deleleExp).ExecuteCommandAsync();
            var entities = new List<TDest>();
            if (input.ids?.Count > 0)
            {
                foreach (var id in input.ids)
                {
                    var pk = id;
                    TDest entity = new();
                    entity.PropertySetValue(mColumnName, input.id);
                    entity.PropertySetValue(name, pk);
                    entities.Add(entity);
                }
            }
            var row = await _db.Insertable(entities).ExecuteCommandAsync();
            if (row < 1) throw Oops.Oh(ErrorCode.COM1000);
        }

        protected async Task Delete<T>(Expression<Func<T, bool>> delFilter) where T : BaseEntity<string>, new()
        {
            var row = await _db.Deleteable<T>().Where(delFilter).ExecuteCommandAsync();
            if (row < 1) throw Oops.Oh(ErrorCode.COM1002);
        }


        protected async Task<dynamic> GetListById<TRelaction, TDest, TOutput>(string masterId,
            Expression<Func<TRelaction, bool>> masterFilterExp,
            Expression<Func<TRelaction, string>> masterSelector,
            Expression<Func<TDest, object>> srcMap,
            Expression<Func<TOutput, object>> destMap
            ) where TDest : BaseEntity<string>, new()
        {
            var config = new TypeAdapterConfig();
            config.ForType<TDest, TOutput>().Map(destMap, srcMap);
            var list = new List<TOutput>();
            var itemIds = await _db.Queryable<TRelaction>().Where(masterFilterExp).Select(masterSelector).ToListAsync();
            if (itemIds?.Count > 0)
            {
                var items = await _db.Queryable<TDest>().Where(it=>itemIds.Contains(it.id)).ToListAsync();
                list = items.Adapt<List<TOutput>>();
            }
            return list;
        }

    }
}