luticate2-api/Luticate2.Utils/Business/LuCrudBusiness.cs

using System;
using System.Collections.Generic;
using Luticate2.Utils.Dbo;
using Luticate2.Utils.Interfaces;

namespace Luticate2.Utils.Business
{
    public abstract class LuCrudBusiness<TNextCrud, TDboCreate, TDboRead, TDboUpdate> : LuBusiness, ILuCrudInterface<TDboCreate, TDboRead, TDboUpdate>
        where TNextCrud : ILuCrudInterface<TDboCreate, TDboRead, TDboUpdate>
        where TDboCreate : class
        where TDboRead : class
        where TDboUpdate : class
    {
        protected readonly TNextCrud Db;

        protected LuCrudBusiness(TNextCrud db)
        {
            Db = db;
        }

        protected virtual LuResult<TDboCreate> CheckAdd(TDboCreate obj)
        {
            return LuResult<TDboCreate>.Ok(obj);
        }

        protected virtual LuResult<IEnumerable<TDboCreate>> CheckAdd(IEnumerable<TDboCreate> objs)
        {
            var list = new List<TDboCreate>();
            foreach (var obj in objs)
            {
                var res = CheckAdd(obj);
                if (!res)
                {
                    return res.To<IEnumerable<TDboCreate>>();
                }
                list.Add(res.Data);
            }
            return LuResult<IEnumerable<TDboCreate>>.Ok(list);
        }

        protected virtual LuResult<TDboUpdate> CheckEdit(TDboRead dbo, TDboUpdate update)
        {
            return LuResult<TDboUpdate>.Ok(update);
        }

        protected LuResult<TDboUpdate> GetAndCheckEdit(string id, TDboUpdate update)
        {
            var res = GetSingleById(id);
            if (!res)
            {
                return res.To<TDboUpdate>();
            }
            return CheckEdit(res.Data, update);
        }

        protected LuResult<TDboUpdate> GetAndCheckEdit(long id, TDboUpdate update)
        {
            var res = GetSingleById(id);
            if (!res)
            {
                return res.To<TDboUpdate>();
            }
            return CheckEdit(res.Data, update);
        }



        public LuResult<T> Add<T>(IEnumerable<TDboCreate> objs, Func<IEnumerable<TDboRead>, T> returnFunc)
        {
            var res = CheckAdd(objs);
            if (!res)
            {
                return res.To<T>();
            }
            return Db.Add(res.Data, returnFunc);
        }

        public LuResult<T> Add<T>(TDboCreate obj, Func<TDboRead, T> returnFunc)
        {
            var res = CheckAdd(obj);
            if (!res)
            {
                return res.To<T>();
            }
            return Db.Add(res.Data, returnFunc);
        }

        public LuResult<IEnumerable<string>> AddGuid(IEnumerable<TDboCreate> objs)
        {
            var res = CheckAdd(objs);
            if (!res)
            {
                return res.To<IEnumerable<string>>();
            }
            return Db.AddGuid(res.Data);
        }

        public LuResult<string> AddGuid(TDboCreate obj)
        {
            var res = CheckAdd(obj);
            if (!res)
            {
                return res.To<string>();
            }
            return Db.AddGuid(res.Data);
        }

        public LuResult<IEnumerable<long>> AddId(IEnumerable<TDboCreate> obj)
        {
            var res = CheckAdd(obj);
            if (!res)
            {
                return res.To<IEnumerable<long>>();
            }
            return Db.AddId(res.Data);
        }

        public LuResult<long> AddId(TDboCreate obj)
        {
            var res = CheckAdd(obj);
            if (!res)
            {
                return res.To<long>();
            }
            return Db.AddId(res.Data);
        }

        public LuResult<IEnumerable<TDboRead>> AddDbo(IEnumerable<TDboCreate> obj)
        {
            var res = CheckAdd(obj);
            if (!res)
            {
                return res.To<IEnumerable<TDboRead>>();
            }
            return Db.AddDbo(res.Data);
        }

        public LuResult<TDboRead> AddDbo(TDboCreate obj)
        {
            var res = CheckAdd(obj);
            if (!res)
            {
                return res.To<TDboRead>();
            }
            return Db.AddDbo(res.Data);
        }




        public LuResult<TDboRead> GetSingleByKeys(params KeyValuePair<string, object>[] keys)
        {
            return Db.GetSingleByKeys(keys);
        }

        public LuResult<TDboRead> GetSingleById(string id)
        {
            return Db.GetSingleById(id);
        }

        public LuResult<TDboRead> GetSingleById(long id)
        {
            return Db.GetSingleById(id);
        }




        public LuResult<T> EditSingleById<T>(long id, TDboUpdate update, Func<TDboRead, T> returnFunc)
        {
            var obj = GetAndCheckEdit(id, update);
            if (!obj)
            {
                return obj.To<T>();
            }
            return Db.EditSingleById(id, obj.Data, returnFunc);
        }

        public LuResult<long> EditSingleByIdId(long id, TDboUpdate update)
        {
            var obj = GetAndCheckEdit(id, update);
            if (!obj)
            {
                return obj.To<long>();
            }
            return Db.EditSingleByIdId(id, obj.Data);
        }

        public LuResult<TDboRead> EditSingleByIdDbo(long id, TDboUpdate update)
        {
            var obj = GetAndCheckEdit(id, update);
            if (!obj)
            {
                return obj.To<TDboRead>();
            }
            return Db.EditSingleByIdDbo(id, obj.Data);
        }

        public LuResult<T> EditSingleById<T>(string id, TDboUpdate update, Func<TDboRead, T> returnFunc)
        {
            var obj = GetAndCheckEdit(id, update);
            if (!obj)
            {
                return obj.To<T>();
            }
            return Db.EditSingleById(id, obj.Data, returnFunc);
        }

        public LuResult<string> EditSingleByIdGuid(string id, TDboUpdate update)
        {
            var obj = GetAndCheckEdit(id, update);
            if (!obj)
            {
                return obj.To<string>();
            }
            return Db.EditSingleByIdGuid(id, obj.Data);
        }

        public LuResult<TDboRead> EditSingleByIdDbo(string id, TDboUpdate update)
        {
            var obj = GetAndCheckEdit(id, update);
            if (!obj)
            {
                return obj.To<TDboRead>();
            }
            return Db.EditSingleByIdDbo(id, obj.Data);
        }




        public LuResult<T> DeleteSingleById<T>(string id, Func<TDboRead, T> returnFunc)
        {
            return Db.DeleteSingleById(id, returnFunc);
        }

        public LuResult<string> DeleteSingleByIdGuid(string id)
        {
            return Db.DeleteSingleByIdGuid(id);
        }

        public LuResult<TDboRead> DeleteSingleByIdDbo(string id)
        {
            return Db.DeleteSingleByIdDbo(id);
        }

        public LuResult<T> DeleteSingleById<T>(long id, Func<TDboRead, T> returnFunc)
        {
            return Db.DeleteSingleById(id, returnFunc);
        }

        public LuResult<long> DeleteSingleByIdId(long id)
        {
            return Db.DeleteSingleByIdId(id);
        }

        public LuResult<TDboRead> DeleteSingleByIdDbo(long id)
        {
            return Db.DeleteSingleByIdDbo(id);
        }
    }
}