发帖
翼度科技»论坛 › 编程开发 › .net › 查看内容

基于SqlSugar的开发框架循序渐进介绍（31）-- 在查询接口中实现多表联合和

年轻人你不讲武德

8

主题

8

帖子

24

积分

新手上路

Rank: 1

积分
24
显示全部楼层
在一些复杂的业务表中间查询数据，有时候操作会比较复杂一些，不过基于SqlSugar的相关操作，处理的代码会比较简单一些，以前我在随笔《基于SqlSugar的开发框架循序渐进介绍（2）-- 基于中间表的查询处理》介绍过基于主表和中间表的联合查询，而往往实际会比这个会复杂一些。本篇随笔介绍联合多个表进行查询以及树形列表的条件展示的处理实现，系统能够给大家一些参考思路。
1、SqlSugar的开发框架的数据查询处理

在随笔《基于SqlSugar的开发框架循序渐进介绍（2）-- 基于中间表的查询处理》中，介绍过两个表的联合查询，如下所示代码所示。
  1. /// <summary>
  2. /// 根据用户ID获取对应的角色列表
  3. /// </summary>
  4. /// <param name="userID">用户ID</param>
  5. /// <returns></returns>
  6. private async Task<List<RoleInfo>> GetByUser(int userID)
  7. {
  8.     var query = this.Client.<strong>Queryable<RoleInfo, User_RoleInfo></strong>(
  9.     (t, m) => t.Id == m.Role_ID && m.User_ID == userID)
  10.     .Select(t => t); //联合条件获取对象
  12.     query = query.OrderBy(t => t.CreateTime);//排序
  13.     var list = await query.ToListAsync();//获取列表
  14.     return list;
  15. }
  17. /// <summary>
  18. /// 根据机构获取对应的角色列表(判断机构角色中间表）
  19. /// </summary>
  20. /// <param name="ouID">机构的ID</param>
  21. /// <returns></returns>
  22. public async Task<List<RoleInfo>> GetRolesByOu(int ouID)
  23. {
  24.     var query = this.Client.<strong>Queryable<RoleInfo, OU_RoleInfo></strong>(
  25.     (t, m) => t.Id == m.Role_ID && m.Ou_ID == ouID)
  26.     .Select(t => t); //联合条件获取对象
  28.     query = query.OrderBy(t => t.CreateTime);//排序
  29.     var list = await query.ToListAsync();//获取列表
  30.     return list;
  31. }
复制代码
我们对于后端的数据查询，一般都是传入一个条件对象，通过条件类的属性进行构建查询信息，如下简单的处理操作。
  1. /// <summary>
  2. /// 应用层服务接口实现
  3. /// </summary>
  4. public class CustomerService : MyCrudService<CustomerInfo, string, CustomerPagedDto>, ICustomerService
  5. {
  6.     /// <summary>
  7.     /// 自定义条件处理
  8.     /// </summary>
  9.     /// <param name="input">查询条件Dto</param>
  10.     /// <returns></returns>
  11.     protected override ISugarQueryable<CustomerInfo><strong> CreateFilteredQueryAsync</strong>(CustomerPagedDto input)
  12.     {
  13.         var query = base.CreateFilteredQueryAsync(input);
  15.         query = query
  16.             .WhereIF(!input.ExcludeId.IsNullOrWhiteSpace(), t => t.Id != input.ExcludeId) //不包含排除ID
  17.             .WhereIF(!input.Name.IsNullOrWhiteSpace(), t => t.Name.Contains(input.Name)) //如需要精确匹配则用Equals
  18.                                                                                          //年龄区间查询
  19.             .WhereIF(input.AgeStart.HasValue, s => s.Age >= input.AgeStart.Value)
  20.             .WhereIF(input.AgeEnd.HasValue, s => s.Age <= input.AgeEnd.Value)
  22.             //创建日期区间查询
  23.             .WhereIF(input.CreateTimeStart.HasValue, s => s.CreateTime >= input.CreateTimeStart.Value)
  24.             .WhereIF(input.CreateTimeEnd.HasValue, s => s.CreateTime <= input.CreateTimeEnd.Value)
  25.             ;
  27.         return query;
  28.     }
复制代码
上面的代码，需要注意的是，不同表之间联合获得的结果，如果需要整合到主表进行的查询中，则需要使用 .MergeTable() 操作进行合并处理。
这种最终我们可以得到比较复杂一些的查询处理了。
  1. /// <summary>
  2. /// 根据条件获取列表
  3. /// </summary>
  4. /// <param name="input">分页查询条件</param>
  5. /// <returns></returns>
  6. public virtual async Task<PagedResultDto<TEntity>> GetListAsync(TGetListInput input)
  7. {
  8.     var query =<strong> CreateFilteredQueryAsync</strong>(input);
  9.     var totalCount = await query.CountAsync();
  11.     query = ApplySorting(query, input);
  12.     query = ApplyPaging(query, input);
  14.     var list = await query.ToListAsync();
  16.     return new PagedResultDto<TEntity>(
  17.        totalCount,
  18.        list
  19.    );
  20. }
  22. /// <summary>
  23. /// 根据条件计算记录数量
  24. /// </summary>
  25. /// <param name="input">查询条件，忽略分页信息</param>
  26. /// <returns></returns>
  27. public virtual async Task<long> CountAsync(TGetListInput input)
  28. {
  29.     var query =<strong> CreateFilteredQueryAsync</strong>(input);
  31.     var totalCount = await query.CountAsync();
  32.     return totalCount; //返回符合条件的所有数量
  33. }
复制代码
有了这个丰富条件的处理，我们就可以在前端进行属性赋值就可以了，简单的调用后端通用的接口查询即可。
  1.             if (!input.GroupId.IsNullOrWhiteSpace())
  2.             {
  3.                 // 联合 CustomerGroup_CustomerInfo 表进行查询
  4.                 query = this.Client.Queryable<CustomerInfo, CustomerGroup_CustomerInfo>(
  5.                        (t, m) => t.Id == m.Customer_ID && m.CustomerGroup_ID == input.GroupId)
  6.                        .Select(t => t)<strong>.MergeTable()</strong>; //联合条件获取对象
  7.             }      
  8.             if(!input.SupplierId.IsNullOrEmpty())
  9.             {
  10.                 query = this.Client.Queryable<CustomerInfo, Customer_SupplierInfo>(
  11.                         (t, m) => t.Id == m.Customer_ID && m.Supplier_ID == input.SupplierId)
  12.                         .Select(t => t)<strong>.MergeTable()</strong>; //联合条件获取对象
  13.             }
复制代码
查询获得接口数据处理如下代码所示。
  1.         /// <summary>
  2.         /// 自定义条件处理
  3.         /// </summary>
  4.         /// <param name="input">查询条件Dto</param>
  5.         /// <returns></returns>
  6.         protected override ISugarQueryable<CustomerInfo> CreateFilteredQueryAsync(CustomerPagedDto input)
  7.         {
  8.             var query = base.CreateFilteredQueryAsync(input);
  9.             if (!input.GroupId.IsNullOrWhiteSpace())
  10.             {
  11.                 // 联合 CustomerGroup_CustomerInfo 表进行查询
  12.                 query = this.Client.Queryable<CustomerInfo, CustomerGroup_CustomerInfo>(
  13.                        (t, m) => t.Id == m.Customer_ID && m.CustomerGroup_ID == input.GroupId)
  14.                        .Select(t => t).MergeTable(); //联合条件获取对象
  15.             }      
  16.             if(!input.SupplierId.IsNullOrEmpty())
  17.             {
  18.                 query = this.Client.Queryable<CustomerInfo, Customer_SupplierInfo>(
  19.                         (t, m) => t.Id == m.Customer_ID && m.Supplier_ID == input.SupplierId)
  20.                         .Select(t => t).MergeTable(); //联合条件获取对象
  21.             }
  23.             //通过名称或代码查询，任一符合即可
  24.             query = query.WhereIF(!input.NameOrCode.IsNullOrWhiteSpace(), t => t.Name.Contains(input.NameOrCode) || t.SimpleName.Contains(input.NameOrCode) || t.HandNo.Contains(input.NameOrCode));
  26.             query = query
  27.                .WhereIF(!input.ExcludeId.IsNullOrWhiteSpace(), t => t.Id != input.ExcludeId) //不包含排除ID
  28.                .WhereIF(!input.HandNo.IsNullOrWhiteSpace(), t => t.HandNo.Contains(input.HandNo)) //如需要精确匹配则用Equals
  29.                 .WhereIF(!input.Name.IsNullOrWhiteSpace(), t => t.Name.Contains(input.Name)) //如需要精确匹配则用Equals
  30.                 .WhereIF(!input.SimpleName.IsNullOrWhiteSpace(), t => t.SimpleName.Contains(input.SimpleName)) //如需要精确匹配则用Equals
  31.                 .WhereIF(!input.Province.IsNullOrWhiteSpace(), t => t.Province.Contains(input.Province)) //如需要精确匹配则用Equals
  32.                 .WhereIF(!input.City.IsNullOrWhiteSpace(), t => t.City.Contains(input.City)) //如需要精确匹配则用Equals
  33.                 .WhereIF(!input.District.IsNullOrWhiteSpace(), t => t.District.Contains(input.District)) //如需要精确匹配则用Equals
  34.                 .WhereIF(!input.Area.IsNullOrWhiteSpace(), t => t.Area.Contains(input.Area)) //如需要精确匹配则用Equals
  35.                 .WhereIF(!input.Address.IsNullOrWhiteSpace(), t => t.Address.Contains(input.Address)) //如需要精确匹配则用Equals
  36.                 .WhereIF(!input.ZipCode.IsNullOrWhiteSpace(), t => t.ZipCode.Contains(input.ZipCode)) //如需要精确匹配则用Equals
  37.                 .WhereIF(!input.Telephone.IsNullOrWhiteSpace(), t => t.Telephone.Contains(input.Telephone)) //如需要精确匹配则用Equals
  38.                 .WhereIF(!input.Fax.IsNullOrWhiteSpace(), t => t.Fax.Contains(input.Fax)) //如需要精确匹配则用Equals
  39.                 .WhereIF(!input.Contact.IsNullOrWhiteSpace(), t => t.Contact.Contains(input.Contact)) //如需要精确匹配则用Equals
  40.                 .WhereIF(!input.ContactPhone.IsNullOrWhiteSpace(), t => t.ContactPhone.Contains(input.ContactPhone)) //如需要精确匹配则用Equals
  41.                 .WhereIF(!input.ContactMobile.IsNullOrWhiteSpace(), t => t.ContactMobile.Contains(input.ContactMobile)) //如需要精确匹配则用Equals
  42.                 .WhereIF(!input.Email.IsNullOrWhiteSpace(), t => t.Email.Contains(input.Email)) //如需要精确匹配则用Equals
  43.                 .WhereIF(!input.QQ.IsNullOrWhiteSpace(), t => t.QQ.Contains(input.QQ)) //如需要精确匹配则用Equals
  44.                 .WhereIF(!input.Industry.IsNullOrWhiteSpace(), t => t.Industry.Contains(input.Industry)) //如需要精确匹配则用Equals
  45.                 .WhereIF(!input.BusinessScope.IsNullOrWhiteSpace(), t => t.BusinessScope.Contains(input.BusinessScope)) //如需要精确匹配则用Equals
  46.                 .WhereIF(!input.Brand.IsNullOrWhiteSpace(), t => t.Brand.Contains(input.Brand)) //如需要精确匹配则用Equals
  47.                 .WhereIF(!input.PrimaryClient.IsNullOrWhiteSpace(), t => t.PrimaryClient.Contains(input.PrimaryClient)) //如需要精确匹配则用Equals
  48.                 .WhereIF(!input.PrimaryBusiness.IsNullOrWhiteSpace(), t => t.PrimaryBusiness.Contains(input.PrimaryBusiness)) //如需要精确匹配则用Equals
  49.                                                                                                                               //注册资金区间查询
  50.                .WhereIF(input.RegisterCapitalStart.HasValue, s => s.RegisterCapital >= input.RegisterCapitalStart.Value)
  51.                .WhereIF(input.RegisterCapitalEnd.HasValue, s => s.RegisterCapital <= input.RegisterCapitalEnd.Value)
  52.                //营业额区间查询
  53.                .WhereIF(input.TurnOverStart.HasValue, s => s.TurnOver >= input.TurnOverStart.Value)
  54.                .WhereIF(input.TurnOverEnd.HasValue, s => s.TurnOver <= input.TurnOverEnd.Value)
  55.                 .WhereIF(!input.LicenseNo.IsNullOrWhiteSpace(), t => t.LicenseNo.Contains(input.LicenseNo)) //如需要精确匹配则用Equals
  56.                 .WhereIF(!input.Bank.IsNullOrWhiteSpace(), t => t.Bank.Contains(input.Bank)) //如需要精确匹配则用Equals
  57.                 .WhereIF(!input.BankAccount.IsNullOrWhiteSpace(), t => t.BankAccount.Contains(input.BankAccount)) //如需要精确匹配则用Equals
  58.                 .WhereIF(!input.LocalTaxNo.IsNullOrWhiteSpace(), t => t.LocalTaxNo.Contains(input.LocalTaxNo)) //如需要精确匹配则用Equals
  59.                 .WhereIF(!input.NationalTaxNo.IsNullOrWhiteSpace(), t => t.NationalTaxNo.Contains(input.NationalTaxNo)) //如需要精确匹配则用Equals
  60.                 .WhereIF(!input.LegalMan.IsNullOrWhiteSpace(), t => t.LegalMan.Contains(input.LegalMan)) //如需要精确匹配则用Equals
  61.                 .WhereIF(!input.LegalTelephone.IsNullOrWhiteSpace(), t => t.LegalTelephone.Contains(input.LegalTelephone)) //如需要精确匹配则用Equals
  62.                 .WhereIF(!input.LegalMobile.IsNullOrWhiteSpace(), t => t.LegalMobile.Contains(input.LegalMobile)) //如需要精确匹配则用Equals
  63.                 .WhereIF(!input.Source.IsNullOrWhiteSpace(), t => t.Source.Contains(input.Source)) //如需要精确匹配则用Equals
  64.                 .WhereIF(!input.WebSite.IsNullOrWhiteSpace(), t => t.WebSite.Contains(input.WebSite)) //如需要精确匹配则用Equals
  65.                 .WhereIF(!input.CompanyPictureGUID.IsNullOrWhiteSpace(), t => t.CompanyPictureGUID.Contains(input.CompanyPictureGUID)) //如需要精确匹配则用Equals
  66.                 .WhereIF(!input.CustomerType.IsNullOrWhiteSpace(), t => t.CustomerType.Contains(input.CustomerType)) //如需要精确匹配则用Equals
  67.                 .WhereIF(!input.Grade.IsNullOrWhiteSpace(), t => t.Grade.Contains(input.Grade)) //如需要精确匹配则用Equals
  68.                 .WhereIF(!input.CreditStatus.IsNullOrWhiteSpace(), t => t.CreditStatus.Contains(input.CreditStatus)) //如需要精确匹配则用Equals
  69.                 .WhereIF(!input.Importance.IsNullOrWhiteSpace(), t => t.Importance.Contains(input.Importance)) //如需要精确匹配则用Equals
  70.                 .WhereIF(input.IsPublic.HasValue, t => t.IsPublic == input.IsPublic) //如需要精确匹配则用Equals
  71.                 .WhereIF(input.Satisfaction.HasValue, t => t.Satisfaction == input.Satisfaction) //如需要精确匹配则用Equals
  72.                 .WhereIF(!input.Note.IsNullOrWhiteSpace(), t => t.Note.Contains(input.Note)) //如需要精确匹配则用Equals
  73.                 .WhereIF(input.TransactionCount.HasValue, t => t.TransactionCount == input.TransactionCount) //如需要精确匹配则用Equals
  74.               
  75.                 //交易金额区间查询
  76.                .WhereIF(input.TransactionTotalStart.HasValue, s => s.TransactionTotal >= input.TransactionTotalStart.Value)
  77.                .WhereIF(input.TransactionTotalEnd.HasValue, s => s.TransactionTotal <= input.TransactionTotalEnd.Value)
  78.                //首次交易时间区间查询
  79.                .WhereIF(input.TransactionFirstDayStart.HasValue, s => s.TransactionFirstDay >= input.TransactionFirstDayStart.Value)
  80.                .WhereIF(input.TransactionFirstDayEnd.HasValue, s => s.TransactionFirstDay <= input.TransactionFirstDayEnd.Value)
  81.                //最近交易时间区间查询
  82.                .WhereIF(input.TransactionLastDayStart.HasValue, s => s.TransactionLastDay >= input.TransactionLastDayStart.Value)
  83.                .WhereIF(input.TransactionLastDayEnd.HasValue, s => s.TransactionLastDay <= input.TransactionLastDayEnd.Value)
  84.                //最近联系日期区间查询
  85.                .WhereIF(input.LastContactDateStart.HasValue, s => s.LastContactDate >= input.LastContactDateStart.Value)
  86.                .WhereIF(input.LastContactDateEnd.HasValue, s => s.LastContactDate <= input.LastContactDateEnd.Value)
  87.                                                                                                       
  88.                //创建时间区间查询
  89.                .WhereIF(input.CreateTimeStart.HasValue, s => s.CreateTime >= input.CreateTimeStart.Value)
  90.                .WhereIF(input.CreateTimeEnd.HasValue, s => s.CreateTime <= input.CreateTimeEnd.Value)   
  91.                //编辑时间区间查询
  92.                .WhereIF(input.EditTimeStart.HasValue, s => s.EditTime >= input.EditTimeStart.Value)
  93.                .WhereIF(input.EditTimeEnd.HasValue, s => s.EditTime <= input.EditTimeEnd.Value)
  95.                .WhereIF(!input.Stage.IsNullOrWhiteSpace(), t => t.Stage.Contains(input.Stage)) //如需要精确匹配则用Equals
  96.                .WhereIF(!input.Status.IsNullOrWhiteSpace(), s => s.Status == input.Status)
  97.                .WhereIF(!input.Creator.IsNullOrWhiteSpace(), t => t.Creator.Contains(input.Creator)) //如需要精确匹配则用Equals
  98.                .WhereIF(!input.Editor.IsNullOrWhiteSpace(), t => t.Editor.Contains(input.Editor)) //如需要精确匹配则用Equals
  99.                .WhereIF(input.Deleted.HasValue, s => s.Deleted == input.Deleted)
  100.                .WhereIF(!input.Dept_ID.IsNullOrWhiteSpace(), t => t.Dept_ID.Contains(input.Dept_ID)) //如需要精确匹配则用Equals
  101.                .WhereIF(!input.Company_ID.IsNullOrWhiteSpace(), t => t.Company_ID.Contains(input.Company_ID)) //如需要精确匹配则用Equals
  102.                .WhereIF(!input.MarkColor.IsNullOrWhiteSpace(), t => t.MarkColor.Contains(input.MarkColor)) //如需要精确匹配则用Equals
  103.                .WhereIF(!input.ShareUsers.IsNullOrWhiteSpace(), t => t.ShareUsers.Contains(input.ShareUsers)) //如需要精确匹配则用Equals
  104.                ;
  106.             return query;
  107.         }
复制代码
在分页列表中展示获得的记录详细信息如下代码所示。
  1. //构建分页的条件和查询条件
  2. pagerDto = new CustomerPagedDto(this.winGridViewPager1.PagerInfo)
  3. {
  4.     //添加所需条件
  5.     NameOrCode = this.txtCustomerNo.Text.Trim(),
  6.     Deleted = 0
  7. };
复制代码

 
3、对于多种属性、状态条件的统一处理

我在之前介绍过的CRM系统主界面中，关于客户关系信息的展示的时候，是通过一个复杂的树形列表来承载不同属性来进行快速的查询，如下界面所示。

这些树形列表的属性信息，在SqlSugar开发框架中，我们统一进行生成，首先定义一个通用的承载对象，如下类所示。
  1. var result = await BLLFactory<ICustomerService>.Instance.GetListAsync(pagerDto);
  2. return result;
复制代码
这个类似一个嵌套的集合，通过children进行添加更多的子集记录。
后端提供一个获取统计信息的树形列表的方法，如下定义所示。
  1. /// <summary>
  2. /// 绑定列表数据
  3. /// </summary>
  4. private async void BindData()
  5. {
  6.     //entity
  7.     this.winGridViewPager1.DisplayColumns = displayColumns;
  8.     this.winGridViewPager1.ColumnNameAlias = await BLLFactory<ICustomerService>.Instance.GetColumnNameAlias();//字段列显示名称转义
  10.     //获取分页数据列表
  11.     var result = await GetData();
  13.     //设置所有记录数和列表数据源
  14.     this.winGridViewPager1.PagerInfo.RecordCount = result.TotalCount; //需先于DataSource的赋值，更新分页信息
  15.     this.winGridViewPager1.DataSource = result.Items;
  16.     this.winGridViewPager1.PrintTitle = "客户信息列表";
  17. }
复制代码
但我们为它添加各种属性的时候，设置相关的节点文本、类别信息即可。
  1. /// <summary>
  2. /// 对CRM的业务数据进行统计的一个公共类
  3. /// </summary>
  4. public class CrmStaticsDto
  5. {
  6.     /// <summary>
  7.     /// 节点显示名称
  8.     /// </summary>
  9.     public string Label { get; set; }
  11.     /// <summary>
  12.     /// 属性名称
  13.     /// </summary>
  14.     public string TypeName { get; set; }
  16.     /// <summary>
  17.     /// 数量
  18.     /// </summary>
  19.     public long Count { get; set; }
  21.     /// <summary>
  22.     /// 业务分类
  23.     /// </summary>
  24.     public string Category { get; set; }
  26.     /// <summary>
  27.     /// 记录的日期开始
  28.     /// </summary>
  29.     public DateTime? DateStart { get; set; }
  30.     /// <summary>
  31.     /// 记录的日期结束
  32.     /// </summary>
  33.     public DateTime? DateEnd { get; set; }
  35.     /// <summary>
  36.     /// 创建人信息
  37.     /// </summary>
  38.     public CListItem Creator { get; set; }
  40.     /// <summary>
  41.     /// 子节点集合
  42.     /// </summary>
  43.     public List<CrmStaticsDto> children { get; set; } = new List<CrmStaticsDto>();
  44. }
复制代码
这样我们在前端的WInform界面中展示树形列表的时候，就会变得非常简单，通过一个递归的函数就可以添加相关的节点信息了，如下代码所示。
  1.         /// <summary>
  2.         /// 获取列表统计信息
  3.         /// </summary>
  4.         /// <returns></returns>
  5.         public async Task<List<CrmStaticsDto>> GetStatics(string compnayId)<br>        {<br>           ................<br>        }
复制代码
以上就是对联合多个表进行查询以及树形列表的条件展示的处理思路，系统能够给大家一些参考思路。

来源:https://www.cnblogs.com/wuhuacong/archive/2023/06/03/17452609.html
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x

上一篇: .net core IOC容器实现(一) -- ServiceDescriptor

下一篇: Dapper.Lite 使用教程

发表于 2023-6-3 07:01:47

举报 回复 使用道具

返回列表 发新帖

Archiver|手机版|小黑屋|翼度科技

Copyright © 2001-2020, Tencent Cloud.　Powered by Discuz! X3.4