using Microsoft.EntityFrameworkCore;
using Ninesky.InterfaceBase;
using Ninesky.Models;
using System;
using System.Linq;
using System.Linq.Expressions;
namespace Ninesky.Base
{
///
/// 服务基类
///
public class BaseService:InterfaceBaseService where T:class
{
protected DbContext _dbContext;
public BaseService(DbContext dbContext)
{
_dbCOntext= dbContext;
}
public virtual int Add(T entity, bool isSave = true)
{
_dbContext.Set().Add(entity);
if (isSave) return _dbContext.SaveChanges();
else return 0;
}
public virtual int AddRange(T[] entities, bool isSave = true)
{
_dbContext.Set().AddRange(entities);
if (isSave) return _dbContext.SaveChanges();
else return 0;
}
///
/// 查询记录数
///
/// 查询条件
/// 记录数
public virtual int Count(Expressionbool>> predicate)
{
return _dbContext.Set().Count(predicate);
}
///
/// 查询是否存在
///
/// 查询条件
/// 是否存在
public virtual bool Exists(Expressionbool>> predicate)
{
return Count(predicate) > 0;
}
///
/// 查找
///
/// 主键
///
public virtual T Find(int Id)
{
return _dbContext.Set().Find(Id);
}
public virtual T Find(object[] keyValues)
{
return _dbContext.Set().Find(keyValues);
}
public virtual T Find(Expressionbool>> predicate)
{
return _dbContext.Set().SingleOrDefault(predicate);
}
public virtual IQueryable FindList(int number, Expressionbool>> predicate)
{
var entityList = _dbContext.Set().Where(predicate);
if (number > 0) return entityList.Take(number);
else return entityList;
}
public virtual IQueryable FindList(int number, Expressionbool>> predicate, Expression> keySelector, bool isAsc)
{
var entityList = _dbContext.Set().Where(predicate);
if (isAsc) entityList = entityList.OrderBy(keySelector);
else entityList.OrderByDescending(keySelector);
if (number > 0) return entityList.Take(number);
else return entityList;
}
public virtual Paging FindList(Expressionbool>> predicate, Expression> keySelector, bool isAsc, Paging paging)
{
var entityList = _dbContext.Set().Where(predicate);
paging.Total = entityList.Count();
if (isAsc) entityList = entityList.OrderBy(keySelector);
else entityList.OrderByDescending(keySelector);
paging.Entities = entityList.Skip((paging.PageIndex - 1) * paging.PageSize).Take(paging.PageSize).ToList();
return paging;
}
public virtual Paging FindList(Expressionbool>> predicate, Expression> keySelector, bool isAsc, int pageIndex, int pageSize)
{
Paging paging = new Paging { PageIndex = pageIndex, PageSize = pageSize };
return FindList(predicate, keySelector, isAsc, paging);
}
///
/// 删除
///
/// 实体
/// 是否立即保存
/// 是否删除成功
public virtual bool Remove(T entity, bool isSave = true)
{
_dbContext.Set().Remove(entity);
if (isSave) return _dbContext.SaveChanges() > 0;
else return false;
}
///
/// 删除[批量]
///
/// 实体数组
/// 是否立即保存
/// 成功删除的记录数
public virtual int RemoveRange(T[] entities, bool isSave = true)
{
_dbContext.Set().RemoveRange(entities);
if (isSave) return _dbContext.SaveChanges();
else return 0;
}
public virtual int SaveChanges()
{
return _dbContext.SaveChanges();
}
///
/// 更新
///
/// 实体
/// 是否立即保存
/// 是否保存成功
public virtual bool Update(T entity, bool isSave = true)
{
_dbContext.Set().Update(entity);
if (isSave) return _dbContext.SaveChanges() > 0;
else return false;
}
///
/// 更新[批量]
///
/// 实体数组
/// 是否立即保存
/// 更新成功的记录数
public virtual int UpdateRange(T[] entities, bool isSave = true)
{
_dbContext.Set().UpdateRange(entities);
if (isSave) return _dbContext.SaveChanges();
else return 0;
}
}
}
京公网安备 11010802041100号