Cis/Cis.Core/Common/Entity/ServiceBase.cs

using Furion.DynamicApiController;
using Newtonsoft.Json.Linq;

namespace Cis.Core.Common;

[NonController]
public class ServiceBase<T> : IDynamicApiController where T : EntityBase, new()
{
    protected readonly SqlSugarRepository<T> _baseRep;

    public ServiceBase(SqlSugarRepository<T> baseRep)
    {
        _baseRep = baseRep;
    }

    /// <summary>
    /// 添加实体类
    /// </summary>
    /// <param name="entity">实体类</param>
    /// <returns></returns>
    [HttpPost]
    public virtual async Task<bool> Add([FromForm] T entity)
    {
        return await _baseRep.InsertAsync(entity);
    }

    /// <summary>
    /// 添加实体类并返回 id
    /// </summary>
    /// <param name="entity">实体类</param>
    /// <returns></returns>
    [HttpPost]
    public virtual async Task<long> AddReturnId([FromForm] T entity)
    {
        bool ret = await _baseRep.InsertAsync(entity);
        if (!ret) return 0;
        return entity.Id;
    }

    /// <summary>
    /// 批量添加实体类
    /// </summary>
    /// <param name="array">实体类数组</param>
    /// <returns></returns>
    [HttpPost]
    public virtual async Task<bool> AddArray([Required][FromForm] T[] array)
    {
        return await _baseRep.InsertRangeAsync(array);
    }

    /// <summary>
    /// 更新实体类
    /// </summary>
    /// <param name="entity">实体类</param>
    /// <returns></returns>
    [HttpPost]
    public virtual async Task<bool> Update([FromForm] T entity)
    {
        return await _baseRep.UpdateAsync(entity);
    }

    [HttpPost]
    public virtual async Task<bool> UpdateArray([Required][FromForm] T[] array)
    {
        return await _baseRep.UpdateRangeAsync(array);
    }

    /// <summary>
    /// 删除实体类
    /// </summary>
    /// <param name="id">实体类 id</param>
    /// <returns></returns>
    [HttpPost]
    public virtual async Task<bool> Delete([Required][FromForm] long id)
    {
        return await _baseRep.DeleteByIdAsync(id);
    }

    [HttpPost]
    public virtual async Task<bool> DeleteArray([Required][FromForm] T[] array)
    {
        return await _baseRep.DeleteByIdsAsync(array);
    }

    /// <summary>
    /// 假删除实体类
    /// </summary>
    /// <param name="id">实体类 id</param>
    /// <param name="isDelete">是否假删除</param>
    /// <returns></returns>
    [HttpPost]
    public virtual async Task<bool> FakeDelete([Required][FromForm] long id, [FromForm] bool isDelete = true)
    {
        return await _baseRep.AsUpdateable(new T { Id = id, IsDelete = isDelete })
            .UpdateColumns(it => it.IsDelete)
            .ExecuteCommandAsync() > 0;
    }

    /// <summary>
    /// 获取实体类
    /// </summary>
    /// <param name="id">实体类 id</param>
    /// <returns></returns>
    [HttpGet]
    public virtual async Task<T> Get([Required] long id)
    {
        T entity = await _baseRep.GetByIdAsync(id);
        return entity;
    }

    /// <summary>
    /// 获取实体类
    /// </summary>
    /// <param name="queryJson">equal:id,isDelete; between:[startTime,endTime];</param>
    /// <returns></returns>
    [HttpGet]
    public virtual async Task<T> GetQ([Required] string queryJson)
    {
        JObject queryObj = queryJson.ToJObject();

        var exp = Expressionable.Create<T>();
        if (queryObj.TryGetValue("Id", StringComparison.OrdinalIgnoreCase, out JToken Id))
            exp.And(it => it.Id.Equals(Id));
        if (queryObj.TryGetValue("IsDelete", StringComparison.OrdinalIgnoreCase, out JToken isDelete))
            exp.And(it => it.IsDelete.Equals(isDelete));
        if (queryObj.TryGetValue("StartTime", StringComparison.OrdinalIgnoreCase, out JToken startTime)
            && queryObj.TryGetValue("EndTime", StringComparison.OrdinalIgnoreCase, out JToken endTime))
            exp.And(it => it.CreateTime >= startTime.ToDateTime() && it.CreateTime <= endTime.ToDateTime());

        var entity = await _baseRep.AsQueryable()
            .Where(exp.ToExpression())
            .FirstAsync();
        return entity;
    }

    /// <summary>
    /// 批量获取实体类
    /// </summary>
    /// <param name="queryJson">equal:isDelete; between:[startTime,endTime];</param>
    /// <returns></returns>
    [HttpGet]
    public virtual async Task<List<T>> GetList(string queryJson = "")
    {
        JObject queryObj = queryJson.ToJObject();

        var exp = Expressionable.Create<T>();
        if (queryObj.TryGetValue("IsDelete", StringComparison.OrdinalIgnoreCase, out JToken isDelete))
            exp.And(it => it.IsDelete.Equals(isDelete));
        if (queryObj.TryGetValue("StartTime", StringComparison.OrdinalIgnoreCase, out JToken startTime)
            && queryObj.TryGetValue("EndTime", StringComparison.OrdinalIgnoreCase, out JToken endTime))
            exp.And(it => it.CreateTime >= startTime.ToDateTime() && it.CreateTime <= endTime.ToDateTime());

        var list = await _baseRep.AsQueryable()
            .Where(exp.ToExpression())
            .ToListAsync();
        return list;
    }

    /// <summary>
    /// 批量获取分页实体类
    /// </summary>
    /// <param name="queryJson">equal:isDelete; between:[startTime,endTime];</param>
    /// <param name="pagination">index,size</param>
    /// <returns></returns>
    [HttpGet]
    public virtual async Task<List<T>> GetPageList([Required] string pagination, string queryJson = "")
    {
        JObject queryObj = queryJson.ToJObject();
        Pagination pageObj = pagination.ToObject<Pagination>();

        var exp = Expressionable.Create<T>();
        if (queryObj.TryGetValue("IsDelete", StringComparison.OrdinalIgnoreCase, out JToken isDelete))
            exp.And(it => it.IsDelete.Equals(isDelete));
        if (queryObj.TryGetValue("StartTime", StringComparison.OrdinalIgnoreCase, out JToken startTime)
            && queryObj.TryGetValue("EndTime", StringComparison.OrdinalIgnoreCase, out JToken endTime))
            exp.And(it => it.CreateTime >= startTime.ToDateTime() && it.CreateTime <= endTime.ToDateTime());

        var list = await _baseRep.AsQueryable()
            .Where(exp.ToExpression())
            .ToPageListAsync(pageObj.Index, pageObj.Size);
        return list;
    }
}