public Demo_OrderService(...) : base(dbRepository) {
    QueryRelativeExpression = q => q.Where(x => x.Enable == 1);
    AddOnExecuting = (order, list) => { /* 校验 */ return webResponse.OK(); };
}

public override WebResponseContent Add(SaveModel saveDataModel) {
    AddOnExecuting = (order, list) => { /* ... */ return webResponse.OK(); };
    return base.Add(saveDataModel);
}

namespace VolPro.MES.Controllers
{
    public partial class Stock_in_headController
    {
        private readonly IStock_in_headService _service;

        [ActivatorUtilitiesConstructor]
        public Stock_in_headController(IStock_in_headService service, IHttpContextAccessor httpContextAccessor)
            : base(service)
        {
            _service = service;
        }

        [HttpPost("GetPoItem")]
        public async Task<object> GetPoItem([FromBody] Dictionary<string, object> data)
        {
            int paramsType = Convert.ToInt32(data["paramsType"]);
            string paramsValue = data["paramsValue"]?.ToString();
            return await _service.GetPoItem(paramsType, paramsValue);
        }

        [HttpGet("GetStockInInfo")]
        public List<Stock_in_head> GetStockInInfo() => _service.GetStockInInfo();
    }
}

public partial class Stock_in_headService
{
    public async Task<object> GetPoItem(int paramsType, string paramsValue)
    {
        return await Task.FromResult(repository.Find(x => x.field == paramsValue));
    }
}

public override WebResponseContent Add(SaveModel saveDataModel)
{
    var res = new WebResponseContent();
    AddOnExecuting = (TEntity main, object list) => {
        var details = list as List<TDetail>;
        return res.OK(); // res.Error("msg") 中止
    };
    AddOnExecuted = (TEntity main, object list) => res.OK(); // 同事务，Error 回滚
    return base.Add(saveDataModel); // MUST：框架在此 Invoke 上述 Func
}

public override PageGridData<{T}> GetPageData(PageDataOptions options)
{
    object extraValue = options.Value; // 前端 searchBefore 的 param.value

    QueryRelativeList = (List<SearchParameters> parameters) => {
        foreach (var item in parameters) {
            if (item.Name == "{字段}") { var v = item.Value; item.Value = null; }
        }
    };

    QueryRelativeExpression = (IQueryable<{T}> q) => {
        // q = q.Where(x => x.CreateID == UserContext.Current.UserId);
        // q = q.Include(x => x.{明细});
        return q;
    };

    // QuerySql = @"select 全部列 from {表} where ..."; // 原生 SQL

    OrderByExpression = x => new Dictionary<object, QueryOrderBy>() {
        { x.CreateDate, QueryOrderBy.Desc }
    };

    SummaryExpress = (IQueryable<{T}> q) => q.GroupBy(x => 1).Select(g => new {
        TotalQty = g.Sum(x => x.Qty)
    }).FirstOrDefault();

    GetPageDataOnExecuted = (PageGridData<{T}> grid) => {
        // 改 grid.rows
    };

    return base.GetPageData(options);
}

public override object GetDetailPage(PageDataOptions pageData)
{
    // 一对多：pageData.TableName 区分明细表
    // return base.GetDetailPage(pageData);
    return base.GetDetailPage(pageData);
}

protected override object GetDetailSummary<{TDetail}>(IQueryable<{TDetail}> queryable)
{
    return queryable.GroupBy(x => 1).Select(g => new { Total = g.Sum(x => x.Amount) }).FirstOrDefault();
}

public override WebResponseContent Add(SaveModel saveDataModel)
{
    var res = new WebResponseContent();
    // 可选：实体转换前操作原始 SaveModel
    AddOnExecute = (SaveModel m) => res.OK();

    AddOnExecuting = ({T} main, object list) => {
        var details = list as List<{TDetail}>;
        // 校验、赋默认值（写库前）
        return res.OK();
    };
    AddOnExecuted = ({T} main, object list) => {
        // 同事务写关联表；return res.Error("msg") 回滚
        return res.OK();
    };
    AddWorkFlowExecuting = (main) => true;
    AddWorkFlowExecuted = (main, userIds) => { };
    return base.Add(saveDataModel);
}

public override WebResponseContent Update(SaveModel saveDataModel)
{
    var res = new WebResponseContent();
    // 非前端提交字段：saveDataModel.MainData["字段"]="值" 或 UpdateOnExecute
    UpdateOnExecute = (SaveModel m) => res.OK();

    UpdateOnExecuting = ({T} main, object addList, object updateList, List<object> delKeys) => {
        var add = addList as List<{TDetail}>;
        var upd = updateList as List<{TDetail}>;
        // 一对多：MultipleTableEntity.GetAddList(typeof(TDetail2), null)
        return res.OK();
    };
    UpdateOnExecuted = ({T} main, object addList, object updateList, List<object> delKeys) => res.OK();
    return base.Update(saveDataModel);
}

public override WebResponseContent Del(object[] keys, bool delList = true)
{
    var res = new WebResponseContent();
    DelOnExecuting = (_keys) => {
        // 已审核不可删
        return res.OK();
    };
    DelOnExecuted = (_keys) => res.OK();
    return base.Del(keys, delList);
}

public override WebResponseContent Audit(object[] keys, int? auditStatus, string auditReason)
{
    var res = new WebResponseContent();
    AuditWorkFlowExecuting = ({T} order, AuditStatus status, bool lastAudit) => res.OK();
    AuditWorkFlowExecuted = ({T} order, AuditStatus status, List<int> nextUserIds, bool lastAudit) => {
        if (lastAudit) { /* 流程结束写业务 */ }
        return res.OK();
    };
    AuditOnExecuting = (List<{T}> list) => res.OK();
    AuditOnExecuted = (List<{T}> list) => res.OK();
    return base.Audit(keys, auditStatus, auditReason);
}

public override WebResponseContent AntiAudit(AntiData antiData)
{
    var res = new WebResponseContent();
    AntiAuditOnExecuting = (entity) => res.OK();
    AntiAuditOnExecuted = (entity) => { /* 回滚库存等 */ return res.OK(); };
    return base.AntiAudit(antiData);
}

public override WebResponseContent Import(List<IFormFile> files)
{
    ImportOnExecuting = (List<{T}> rows) => { /* 校验 */ return new WebResponseContent().OK(); };
    ImportOnExecuted = (List<{T}> rows) => new WebResponseContent().OK();
    ImportStartRowIndex = 1;
    // ExcelHeaderMap, ImportOnReadCellValue
    return base.Import(files);
}

public override WebResponseContent Export(PageDataOptions pageData)
{
    ExportColumns = x => new { x.Field1, x.Field2 };
    ExportOnExecuting = (List<{T}> rows, List<string> ignore) => new WebResponseContent().OK();
    Limit = 10000;
    return base.Export(pageData);
}

public override WebResponseContent Upload(List<IFormFile> files)
{
    UploadFolder = "Upload/Tables/{表}/";
    IsRoot = true;
    return base.Upload(files);
}

// Startup: PrintContainer.Use<{T}, {TDetail}>("模板名", mainFields, detailFields);
public class {T}PrintFilter : PrintFilter<{T}> {
    public override IQueryable<{T}> Query(PrintQuery query) => base.Query(query);
}

// 跨表：Partial Service 构造方法注入
public partial class Sys_WorkFlowTableService
{
    private readonly ISys_WorkFlowTableRepository _repository;
    private readonly ISys_WorkFlowTableStepRepository _stepRepository;
    [ActivatorUtilitiesConstructor]
    public Sys_WorkFlowTableService(
        ISys_WorkFlowTableRepository dbRepository,
        IHttpContextAccessor httpContextAccessor,
        ISys_WorkFlowTableStepRepository stepRepository)
        : base(dbRepository)
    {
        _repository = dbRepository;
        _stepRepository = stepRepository; // 操作其他表
    }
}

using Microsoft.EntityFrameworkCore;
using VolPro.Core.Extensions; // TakePage、WhereIF

// 单表
var list = repository.FindAsIQueryable(x => x.Enable == 1).ToList();
var one = await repository.FindAsIQueryable(x => x.Id == id).FirstOrDefaultAsync();
var data = repository.FindAsIQueryable(x => true)
    .Select(s => new { s.Field1, s.Field2 }).ToList();

// 模糊 / in
repository.FindAsIQueryable(x => x.Name.Contains(kw)).ToList();
repository.FindAsIQueryable(x => x.Name.StartsWith(kw)).ToList();
repository.FindAsIQueryable(x => x.Name.EndsWith(kw)).ToList();
var ids = new List<int> { 1, 2, 3 };
repository.FindAsIQueryable(x => ids.Contains(x.Id)).ToList();

// 动态条件 WhereIF
repository.WhereIF(!string.IsNullOrEmpty(kw), x => x.Name.Contains(kw))
    .WhereIF(status > 0, x => x.Status == status)
    .ToList();

// 主子表 Include（生成器已配置明细 navigation）
var list = repository.FindAsIQueryable(x => true).Include(x => x.明细表).ToList();

// 是否存在
var exists = repository.Exists(x => x.Code == code);
var existsAsync = await repository.ExistsAsync(x => x.Code == code);

// 普通分页
var page = 1; var rows = 30;
var list = repository.FindAsIQueryable(x => 条件).TakePage(page, rows).ToList();

// 带排序 + 匿名投影
var query = repository.FindAsIQueryable(x => x.Enable == 1);
var total = await query.CountAsync();
var data = await query.OrderByDescending(x => x.CreateDate)
    .TakePage(options.Page, options.Rows)
    .Select(s => new { s.Id, s.Name }).ToListAsync();

// Partial/I{表}Service.cs
Task<object> SearchSysUser(PageDataOptions options);

// Partial/{表}Service.cs — Sys_User 换为要查询的实体
public async Task<object> SearchSysUser(PageDataOptions options)
{
    var query = options.ConvertQueryFilter<Sys_User>().Where(x => x.Enable == 1);
    var total = await query.CountAsync();
    var rows = await query.OrderByDescending(x => x.User_Id)
        .TakePage(options.Page, options.Rows)
        .Select(s => new
        {
            s.User_Id,
            s.UserName,
            s.UserTrueName,
            s.Gender,
            s.PhoneNo,
            s.Email
        }).ToListAsync();
    return new { total, rows };
}

// Partial/{表}Controller.cs
[HttpPost("SearchSysUser")]
public async Task<IActionResult> SearchSysUser([FromBody] PageDataOptions options)
{
    return JsonNormal(await _service.SearchSysUser(options));
}

// 新建
var model = new 表Model();
model.SetCreateDefaultVal(); // 可选：创建人、创建时间
repository.Add(model);
repository.SaveChanges(); // 保存后主键自动回填

// 批量新建
repository.AddRange(list);
repository.SaveChanges();

// 更新（主键必须有值）
model.SetModifyDefaultVal();
repository.Update(model, x => new { x.Field1, x.Field2 });
repository.SaveChanges();

// 批量更新
repository.UpdateRange(list, x => new { x.Field1 }, false);
repository.SaveChanges();

// 按条件更新/删除（不立即提交时第三参数 false）
repository.Update(model, x => new { x.Status }, false);
repository.Delete(x => 条件, false);

// 删除单条 / 批量主键
repository.Delete(model);
repository.DeleteWithKeys(new object[] { id1, id2 });
repository.SaveChanges();

// EF 事务
repository.DbContextBeginTransaction(() =>
{
    repository.Add(main);
    _otherRepository.Add(detail);
    repository.SaveChanges();
    return webResponse.OK();
});

// 调试 SQL
Console.WriteLine(queryable.ToQueryString());

// 原生 EF Set（少用）
repository.DbContext.Set<Sys_User>();