.net通用CMS快速开发框架——问题:Dapper通用的多表联合分页查询怎么破?

最近在弄一个东东,类似那种CMS的后台管理系统,方便作为其它项目的初始化框架用的。

现在遇到个问题,如标题所示:Dapper通用的多表联合分页查询怎么破?

单表的话很简单就可以实现,多表不通用的话也可以很方便的实现,那么如果多表通用的话,怎么办呢?

难道只能通过拼接sql或者使用存储过程吗?我先来展示下我的实现方式,希望你有更好的方式,然后同我分享一下,以便解决我的困扰。

技术选型:MVC5、Mysql、Dapper、Autofac、Layui、阿里巴巴矢量库、T4(后面补上)。

我选择的都是轻量级比较干净的东东来组合的框架。

我选择又外入内的方式来阐述我现在遇到的问题。以用户管理界面为例,我讲只列出涉及到用户分页查询的代码,将会省略其它代码.....

大致上的效果如下图所示:

经典的多层架构

Global.asax.cs代码,Dapper自动注入。

  public class MvcApplication : System.Web.HttpApplication
    {
        protected void Application_Start()
        {
            AreaRegistration.RegisterAllAreas();
            FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
            RouteConfig.RegisterRoutes(RouteTable.Routes);
            BundleConfig.RegisterBundles(BundleTable.Bundles);

            //创建autofac管理注册类的容器实例
            var builder = new ContainerBuilder();
            SetupResolveRules(builder);
            //使用Autofac提供的RegisterControllers扩展方法来对程序集中所有的Controller一次性的完成注册 支持属性注入
            builder.RegisterControllers(Assembly.GetExecutingAssembly()).PropertiesAutowired();        

            // 把容器装入到微软默认的依赖注入容器中
            var container = builder.Build();
            DependencyResolver.SetResolver(new AutofacDependencyResolver(container));
        }
        private static void SetupResolveRules(ContainerBuilder builder)
        {
            //WebAPI只用引用services和repository的接口,不用引用实现的dll。
            //如需加载实现的程序集,将dll拷贝到bin目录下即可,不用引用dll
            var iServices = Assembly.Load("RightControl.IService");
            var services = Assembly.Load("RightControl.Service");
            var iRepository = Assembly.Load("RightControl.IRepository");
            var repository = Assembly.Load("RightControl.Repository");

            //根据名称约定(服务层的接口和实现均以Services结尾),实现服务接口和服务实现的依赖
            builder.RegisterAssemblyTypes(iServices, services)
              .Where(t => t.Name.EndsWith("Service"))
              .AsImplementedInterfaces().PropertiesAutowired();

            //根据名称约定(数据访问层的接口和实现均以Repository结尾),实现数据访问接口和数据访问实现的依赖
            builder.RegisterAssemblyTypes(iRepository, repository)
              .Where(t => t.Name.EndsWith("Repository"))
              .AsImplementedInterfaces().PropertiesAutowired();
        }
    }

BaseController:

   public class BaseController : Controller
    {// GET: Base
        public virtual ActionResult Index()
        {
            return View();
        }

UserController:

    public class UserController : BaseController
    {
        private IUserService service;

        public UserController(IUserService _service)
        {
            service = _service;
        }
        /// <summary>
        /// 加载数据列表
        /// </summary>
        /// <param name="pageInfo">页面实体信息</param>
        /// <param name="filter">查询条件</param>
        /// <returns></returns>
        [HttpGet]
        public JsonResult List(PageInfo pageInfo, UserModel filter)
        {
            var result = service.GetListByFilter(filter, pageInfo);
            return Json(result, JsonRequestBehavior.AllowGet);
        }

PageInfo:

    public class PageInfo
    {
        public int page { get; set; }
        public int limit { get; set; }
        /// <summary>
        /// 排序字段 CreateOn
        /// </summary>
        public string field { get; set; }
        /// <summary>
        /// 排序方式 asc desc
        /// </summary>
        public string order { get; set; }
        /// <summary>
        /// 返回字段逗号分隔
        /// </summary>
        public string returnFields { get; set; }
        public string prefix { get; set; }
    }

UserModel:

using DapperExtensions;
using System;
using System.ComponentModel.DataAnnotations;

namespace RightControl.Model
{
    [Table("t_User")]
    public class UserModel:Entity
    {
        /// <summary>
        /// 用户名
        /// </summary>
        [Display(Name = "用户名")]
        public string UserName { get; set; }
        /// <summary>
        /// 真实名称
        /// </summary>
        [Display(Name = "真实名称")]
        public string RealName { get; set; }
        /// <summary>
        /// 密码
        /// </summary>
        public string PassWord { get; set; }
        /// <summary>
        /// 创建者
        /// </summary>
        public int CreateBy { get; set; }
        /// <summary>
        /// 角色ID
        /// </summary>
        public int RoleId { get; set; }
        /// <summary>
        /// 更新时间
        /// </summary>
        [Display(Name = "更新时间")]
        public DateTime UpdateOn { get; set; }
        [Computed]
        public string RoleName { get; set; }
    }
}

Entity:

    public class Entity
    {
        [DapperExtensions.Key(true)]
        public virtual int Id { get; set; }
        /// <summary>
        /// 创建时间
        /// </summary>
        [DataType(DataType.Date)]
        [DisplayFormat(DataFormatString = "{0:yyyy-MM-dd HH:mm:ss}")]
        [Display(Name = "创建时间")]
        public DateTime CreateOn { get; set; }
        /// <summary>
        /// 菜单状态(1:启用,0:禁用)
        /// </summary>
        public bool Status { get; set; }
        #region 查询条件
        [Computed]
        public string StartEndDate { get; set; }
        #endregion
    }

IBaseService:

    public interface IBaseService<T> where T : class, new()
    {
        dynamic GetListByFilter(T filter, PageInfo pageInfo);
    }

IUserService:

    public interface IUserService : IBaseService<UserModel>
    {
    ...
    }

BaseService:

    public abstract class BaseService<T> where T : class, new()
    {
        public IBaseRepository<T> baseRepository{get; set;}
public dynamic GetPageUnite(IBaseRepository<T> repository, PageInfo pageInfo, string where, object filter)
        {
            string _orderBy = string.Empty;
            if (!string.IsNullOrEmpty(pageInfo.field))
            {
                _orderBy = string.Format(" ORDER BY {0} {1}", pageInfo.prefix+pageInfo.field, pageInfo.order);
            }
            else
            {
                _orderBy = string.Format(" ORDER BY {0}CreateOn desc",pageInfo.prefix);
            }
            long total = 0;
            var list = repository.GetByPageUnite(new SearchFilter { pageIndex = pageInfo.page, pageSize = pageInfo.limit, returnFields = pageInfo.returnFields, param = filter, where = where, orderBy = _orderBy }, out total);

            return Pager.Paging(list, total);
        }
        protected  string CreateWhereStr(Entity filter, string _where)
        {
            if (!string.IsNullOrEmpty(filter.StartEndDate) && filter.StartEndDate != " ~ ")
            {
                var dts = filter.StartEndDate.Trim().Split(‘~‘);
                var start = dts[0].Trim();
                var end = dts[1].Trim();
                if (!string.IsNullOrEmpty(start))
                {
                    _where += string.Format(" and CreateOn>=‘{0}‘", start + " 00:00");
                }
                if (!string.IsNullOrEmpty(end))
                {
                    _where += string.Format(" and CreateOn<=‘{0}‘", end + " 59:59");
                }
            }

            return _where;
        }
    }

UserService:

   public class UserService: BaseService<UserModel>, IUserService
    {
        public IUserRepository repository { get; set; }//属性注入
        public dynamic GetListByFilter(UserModel filter, PageInfo pageInfo)
        {
            pageInfo.prefix = "u.";
            string _where = " t_User u INNER JOIN t_role r on u.RoleId=r.Id";
            if (!string.IsNullOrEmpty(filter.UserName))
            {
                _where += " and [email protected]";
            }
            if (!string.IsNullOrEmpty(pageInfo.order))
            {
                pageInfo.order = pageInfo.prefix + pageInfo.order;
            }
            pageInfo.returnFields = "u.Id,u.UserName,u.RealName,u.CreateOn,u.`PassWord`,u.`Status`,u.RoleId,r.RoleName";
            return GetPageUnite(baseRepository, pageInfo, _where, filter);
        }        ...
    }

IBaseRepository:

 public interface IBaseRepository<T> where T : class, new()
    {
        IEnumerable<T> GetByPageUnite(SearchFilter filter, out long total);
    }

IUserRepository:

    public interface IUserRepository : IBaseRepository<UserModel>
    {

    }

BaseRepository:

    public class BaseRepository<T>: IBaseRepository<T> where T :class, new()
    {
public IEnumerable<T> GetByPageUnite(SearchFilter filter, out long total)
        {
            using (var conn = MySqlHelper.GetConnection())
            {
                return conn.GetByPageUnite<T>(filter.pageIndex, filter.pageSize, out total, filter.returnFields, filter.where, filter.param, filter.orderBy, filter.transaction, filter.commandTimeout);
            }
        }

    }

UserRepository:

    public class UserRepository : BaseRepository<UserModel>, IUserRepository
    {
    }

最后的分页代码:

        /// <summary>
        /// 获取分页数据
        /// </summary>
        public static IEnumerable<T> GetByPageUnite<T>(this IDbConnection conn, int pageIndex, int pageSize, out long total, string returnFields = null, string where = null, object param = null, string orderBy = null, IDbTransaction transaction = null, int? commandTimeout = null)
        {
            int skip = 0;
            if (pageIndex > 0)
            {
                skip = (pageIndex - 1) * pageSize;
            }

            StringBuilder sb = new StringBuilder();
            sb.AppendFormat("SELECT COUNT(1) FROM {0};",  where);
            sb.AppendFormat("SELECT {0} FROM {1} {2}  LIMIT {3},{4}", returnFields, where, orderBy, skip, pageSize);
            using (var reader = conn.QueryMultiple(sb.ToString(), param, transaction, commandTimeout))
            {
                total = reader.ReadFirst<long>();
                return reader.Read<T>();
            }
        }

Index视图:

@{
    Layout = "~/Views/Shared/_LayoutBase.cshtml";
}

<!DOCTYPE html>
<html>

<head>
    <meta charset="UTF-8">
    <title>Table</title>
</head>

<body>
    <div class="admin-main">
            <blockquote class="layui-elem-quote p10">
                <div class="layui-form-item" style="margin-bottom:0px;">
                    <label class="layui-form-label">用户名称:</label>
                    <div class="layui-input-inline">
                        <input name="UserName" id="UserName" lay-verify="url" autocomplete="off" class="layui-input">
                    </div>
                    <a href="javascript:;" class="layui-btn layui-btn-sm" id="btnSearch"  data-type="reload">
                        <i class="layui-icon"></i> 搜索
                    </a>
                    <div style="float:right;">
                        <a href="javascript:;" class="layui-btn layui-btn-sm" id="btnAdd">
                            <i class="layui-icon"></i> 添加用户
                        </a>
                    </div>
                </div>
            </blockquote>
            <div class="layui-field-box">
                <table id="defaultTable" lay-filter="defaultruv"></table>
                <script type="text/html" id="switchTpl">
                    {{#  if(d.Status == 1){ }}
                    <i class="layui-icon green"></i>启用
                        {{#  } else { }}
                    <i class="layui-icon red" style="font-size:18px;">ဆ</i> 停用
                        {{#  } }}
                        <!-- 这里的 checked 的状态只是演示 -->
                        @*<input type="checkbox" name="Status"  value="{{d.Id}}"  lay-skin="switch" lay-text="开启|禁用" lay-filter="statusSwitch" {{ d.Status == 1 ? ‘checked‘ : ‘‘ }}>*@
</script>
                <script type="text/html" id="bar">
                    <a class="layui-btn layui-btn-normal layui-btn-xs" lay-event="detail">查看</a>
                    <a class="layui-btn layui-btn-xs" lay-event="edit">编辑</a>
                    <a class="layui-btn layui-btn-danger layui-btn-xs" lay-event="del">删除</a>
                </script>
            </div>
    </div>
    <script>
            layui.config({
                base: ‘/plugins/app/‘
            });

            layui.use([‘table‘, ‘common‘, ‘form‘], function () {
                var table = layui.table,
                    form = layui.form,
                    common = layui.common;
                //表格
                table.render({
                    id: ‘defaultReload‘
                   , elem: ‘#defaultTable‘
                   , height: ‘full-112‘ //高度最大化减去差值
                   , url: ‘/Permissions/User/List‘ //数据接口
                   , page: true //开启分页
                   , cols: [[ //表头
                     { checkbox: true, fixed: true },
                     { field: ‘Id‘, title: ‘Id‘, width: 80, fixed: ‘left‘ }
                     , { field: ‘UserName‘, title: ‘用户名称‘, sort: true }
                     , { field: ‘RealName‘, title: ‘真实姓名‘ }
                     , { field: ‘RoleName‘, title: ‘角色名称‘ }
                     , { field: ‘Status‘, title: ‘状态‘, templet: ‘#switchTpl‘, unresize: true, width: 100, align:‘center‘ }
                     , { field: ‘CreateOn‘, title: ‘创建时间‘, sort: true, templet: ‘<div>{{showDate(d.CreateOn)}}</div>‘ }
                     , { field: ‘‘, title: ‘操作‘, toolbar: "#bar" }
                   ]]
                });
                var $ = layui.$, active = {
                    reload: function () {
                        //执行重载
                        table.reload(‘defaultReload‘, {
                            page: {
                                curr: 1 //重新从第 1 页开始
                            }
                          , where: {
                              UserName: $("#UserName").val()
                          }
                        });
                    }
                };
                $(‘#btnSearch‘).on(‘click‘, function () {
                    var type = $(this).data(‘type‘);
                    active[type] ? active[type].call(this) : ‘‘;
                });
                //add
                $(‘#btnAdd‘).on(‘click‘, function () {
                    common.openTop({
                        title: ‘用户编辑‘, w: ‘600px‘, h: ‘360px‘, content: ‘/Permissions/User/Add/‘, clickOK: function (index, layero) {
                            var form = layero.find(‘iframe‘)[0].contentDocument.forms[0];
                            ajaxSubmitForm($(form), function (data) {
                                if (data.state == "success") {
                                    common.msgSuccess("添加成功");
                                    layer.close(index);  //关闭弹窗
                                    active.reload();//刷新界面
                                }
                            });
                        }
                    });
                });
                //监听工具条
                table.on(‘tool(defaultruv)‘, function (obj) {
                    var data = obj.data;
                    if (obj.event === ‘detail‘) {
                        common.openTop({
                            detail:true,
                            title: ‘用户详情‘, w: ‘600px‘, h: ‘360px‘, content: ‘/Permissions/User/Detail/‘ + data.Id, clickOK: function (index) {
                                common.close(index);
                            }
                        });
                    } else if (obj.event === ‘del‘) {
                        layer.confirm(‘确定要删除吗?‘, function (index) {
                            console.log(data);
                            $.ajax({
                                url: "/Permissions/User/Delete",
                                type: "POST",
                                data: { "Id": data.Id },
                                dataType: "json",
                                success: function (data) {
                                    if (data.state == "success") {
                                        //删除这一行
                                        obj.del();
                                        //关闭弹框
                                        layer.close(index);
                                        common.msgSuccess("删除成功");
                                    } else {
                                        common.msgError("删除失败");
                                    }
                                }
                            });
                        });
                    } else if (obj.event === ‘edit‘) {
                        common.openTop({
                            title: ‘用户编辑‘, w: ‘600px‘, h: ‘360px‘, content: ‘/Permissions/User/Edit/‘ + data.Id, clickOK: function (index,layero) {
                                var form = layero.find(‘iframe‘)[0].contentDocument.forms[0];
                                ajaxSubmitForm($(form), function (data) {
                                    if (data.state == "success") {
                                        common.msgSuccess("修改成功");
                                        layer.close(index);  //关闭弹窗
                                        active.reload();//刷新界面
                                    }
                                });
                            }
                        });
                    }
                });
            });
    </script>
</body>

</html>

_LayoutBase模板页:

<!DOCTYPE html>

<html>
<head>
    <meta name="viewport" content="width=device-width" />
    <title>@ViewBag.Title</title>
    <link rel="stylesheet" href="~/plugins/layui/css/layui.css" media="all" />
    <link href="~/Content/global.css" rel="stylesheet" />
    <link href="~/Content/table.css" rel="stylesheet" />
    <script src="~/plugins/layui/layui.js"></script>
    <script src="~/plugins/app/global.js"></script>
</head>
<body>
    <div id="ajax-loader" style="cursor: progress; position: fixed; top: -50%; left: -50%; width: 200%; height: 200%; background: #fff; z-index: 10000; overflow: hidden;">
        <img src="~/Content/images/ajax-loader.gif" style="position: absolute; top: 0; left: 0; right: 0; bottom: 0; margin: auto;" />
    </div>
        @RenderBody()
   <script type="text/javascript">
       layui.config({
           base: ‘/plugins/app/‘,
           version: ‘1522709297490‘ //为了更新 js 缓存,可忽略
       });
       layui.use([‘common‘], function () {
           layer.config({
               skin: ‘layui-layer-molv‘
           })
           var $ = layui.jquery;
           $(function () {
               $(‘#ajax-loader‘).fadeOut();
           })
       })
   </script>
</body>
</html>

代码结构基本上就这样了,如果大家能把困扰我的这问题解决了,我就可以安安心心的把代码开源啦!

作为一名有追求的程序员,当看到代码连自己都受不了,我就开始抓狂........

原文地址:https://www.cnblogs.com/jiekzou/p/8962422.html

时间: 2024-09-30 04:53:24

.net通用CMS快速开发框架——问题:Dapper通用的多表联合分页查询怎么破?的相关文章

ASP.NET MVC4 打造一套UI与后台并重-通用权限系统快速开发框架+精美UI界面 秒杀EasyUi、Ext

一.前言 从进行到软件开发这个行业现在已经有几年了,在整理出这个套开发框架之前自己做了不少重复造轮子的事.每次有新的项目总是要耗费不少时间在UI.权限和系统通用模块上面,自己累得要死,老板还骂没效率.为了能提高开发效率,同时也多拿拿奖金.多存点私房钱,我就着手做了一套以权限管理为主的快速开发框架.不求功能在所有项目中都得到使用,至少要大大提高开发效率. 二.需求分析    根据<那些年我们一起做过的项目>中各类客户对权限模块和通用模块以及UI的要求,我明确了这个系统中要实现的东西. 1.组织机

打造一套UI与后台并重-通用权限系统快速开发框架+精美UI界面

一.前言 从进行到软件开发这个行业现在已经有几年了,在整理出这个套开发框架之前自己做了不少重复造轮子的事.每次有新的项目总是要耗费不少时间在UI.权限和系统通用模块上面,自己累得要死,老板还骂没效率.为了能提高开发效率,同时也多拿拿奖金.多存点私房钱,我就着手做了一套以权限管理为主的快速开发框架.不求功能在所有项目中都得到使用,至少要大大提高开发效率. 二.需求分析     根据<那些年我们一起做过的项目>中各类客户对权限模块和通用模块以及UI的要求,我明确了这个系统中要实现的东西. 1.组织

MVC 快速开发框架

ASP.NET MVC 快速开发框架之 SqlSugar+SyntacticSugar+JQWidgetsSugar+jqwidgets jqwidgets.js: 是一个功能完整的框架,它具有专业的可触摸的jQuery插件.主题.输入验证.拖放插件.数据适配器,内置WAI-ARIA(无障碍网页应用)可访问性.国际化和MVVM模式支持.jQWidgets 为搭建专业网站和开发移动应用程序提供了一个全面的解决方案.它完全基于开放的标准和技术,如 HTML5.CSS.Javascript和jQuer

.Net快速开发框架1_起因

2012.8月, 经理问以前用过.NET没? 没.(09年自己是用过,但当时只是为了做东西,拿VC++,BCB,DELPHI,C#,各写了一个测试小软件的给同事和朋友们看来做比较,经过比较后一致选择了DELPHI:当时用PB6.5/9.0,但看的久了会生厌.所以也谈不上会或是了解.题外话,虽然说语言不重要,这是针对学,但对开发产品来说还是区别很大的,要考虑更换平台的代价,工期等等多方面的) 那你这两天学下.NET,下周用C#做开发. 用哪种语言? 学C#,现在做新东西基本上都是C#.NET了.

力软.net快速开发框架,MVC架构,工作流源码(敏捷开发版6.1)

导引:在网上看到力软开发的系统非常不错,并且我本身就是学MVC的,但是感觉和人家差距很大,所以就花重金买下了源代码,好好研究总结一下! 力软信息化系统快速开发框架是一套集权限管理+快速开发+动态接口+通用组件+动态UI于一体的全新.net信息化快速开发框架. 开发工具: vs2005/vs2008/vs2010 数据库: sql2005/sql2008 属性: MVC 前端: Jquery+BootStrap 体验地址:http://learun.cn:90/Home/AdminDefault

力软信息化系统快速开发框架 web端+winform端

力软信息化系统快速开发框架是一套集权限管理+快速开发+动态接口+通用组件+动态UI于一体的全新.net信息化快速开发框架.力软信息化系统快速开发框架的使用,大大地缩短了开发周期,提高了软件质量,同时也降低企业对软件研发人员编码水平要求.使得软件企业减少研发的时间和成本以及提升用户体验,从而能在竞争激烈的软件行业里脱颖而出,打造出优秀的软件产品,赢得客户的信赖.同样软件工程师有一套这样的开发神器在手,开发软件效率卓越,界面炫酷,定能赢得上司的赏识,升职加薪不在话下,迎娶白富美登上人生的巅峰也指日可

ASP.NET MVC快速开发框架不得不做的几个功能

俗话说磨刀不误砍柴工,确实,一早上花一个小时去磨刀一天下来肯定能多砍很多柴.我们做软件开发也是同样的道理,有套好开发框架在手里,开发也是事半功倍.那么一套MVC快速开发框架至少得具有哪些功能才能帮我们做到高效率.高品质的开发呢?下面我以后台管理系统开发框架为例谈一谈快速开发框架的几个主要功能. 献上在<线体验Demo地址>希望大家也能从中得到一些启发.地址:http://121.40.148.178:8080/ . 用户名:guest,密码:123456 一.高端大气的界面布局. 一个人,你首

ASP.NET快速开发框架不得不做的几个功能、高大上档次后台管理UI界面

俗话说磨刀不误砍柴工,确实,一早上花一个小时去磨刀一天下来肯定能多砍很多柴.我们做软件开发也是同样的道理,有套好开发框架在手里,开发也是事半功倍.那么一套MVC快速开发框架至少得具有哪些功能才能帮我们做到高效率.高品质的开发呢?下面我以后台管理系统开发框架为例谈一谈快速开发框架的几个主要功能. 献上在<线体验Demo地址>希望大家也能从中得到一些启发.地址:http://121.40.148.178:8080/ . 用户名:guest,密码:123456 一.高端大气的界面布局. 一个人,你首

力软快速开发框架

力软敏捷开发框架,软件行业的3D打印机.整合框架,给用户和开发者最佳的.Net框架方案. 力软敏捷开发框架是一套集快速开发+通用权限管理+工作流+即时通讯+微信组件+手机APP开发于一体的敏捷开发框架. 能帮企业提高开发效率,提升软件质量,使得软件研发人员只用关注核心业务的实现.拥有了这套框架您只需要一批.net程序员, 就能把架构师.美工妹.APP开发人员的活全干了.只要您创意有了,设计出来了,马上就能通过力软敏捷开发框架快速实现. 它就是软件行业的3D打印机! UI 首先是界面UI,界面是一