Master.CanYinWu.DAL/AdminDAL.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using Master.CanYinWu.Entity;
using Master.CanYinWu.Utility;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Dapper;
using System.Data.SqlClient;
using System.Data;

namespace Master.CanYinWu.DAL
{
    public class AdminDAL
    {

        #region 用户列表加载
        public async Task<Tuple<IEnumerable<Admin>, int>> GetList(int pageIndex, int pageSize, string key, int roleId)
        {
            StringBuilder sb = new StringBuilder(@"select 
                * from(select *,(select roleName from role as r where r.roleid=aa.roleid and r.isdel=0)as roleName ,ROW_NUMBER() over (order by CooperationEndTime desc, adminid asc) as  rownumber  from  Admin aa)as a where isdel=0 ");
            DynamicParameters dp = new DynamicParameters();
            dp.Add("PageIndex", pageIndex);
            dp.Add("PageSize", pageSize);
            StringBuilder sqlTotal = new StringBuilder(@"select count(1)  from admin where isdel=0");
            DynamicParameters dpTotal = new DynamicParameters();
            if (!string.IsNullOrEmpty(key))
            {
                sb.Append(" and username like '%'+@Key+'%' ");
                dp.Add("Key", key);
                sqlTotal.Append(" and username like '%'+@Key+'%' ");
                dpTotal.Add("Key", key);
            }

            if (roleId>0)
            {
                sb.Append(" and roleId =@RoleId ");
                dp.Add("RoleId", roleId);
                sqlTotal.Append(" and roleId =@RoleId ");
                dpTotal.Add("RoleId", roleId);
            }

            sb.Append(" and rownumber BETWEEN (((@PageIndex-1)*@PageSize)+1) and @PageIndex*@PageSize ");
            using (var conn = ConnectionFactory.Connection())
            {
                var query = await conn.QueryAsync<Admin>(sb.ToString(), dp);
                var total = await conn.ExecuteScalarAsync<int>(sqlTotal.ToString(), dpTotal);
                return new Tuple<IEnumerable<Admin>, int>(query, total);
            }
        }
        #endregion

        #region 推送用户列表加载
        public async Task<Tuple<IEnumerable<Admin>, int>> GetSendAdminList(int messageId, int pageIndex, int pageSize, string key)
        {
            StringBuilder sb = new StringBuilder(@"select * from ( select aa.AdminId,bb.MessageId, UserName,aa.CreateTime,LoginIP,LastLoginTime,Remark,CooperationEndTime, ROW_NUMBER() over (order by  aa.adminid asc) as  rownumber 
                                                   from  Admin aa join AdminMessage bb on aa.adminid=bb.adminId where bb.MessageId=@MessageId )as a where 1=1 ");
            DynamicParameters dp = new DynamicParameters();
            dp.Add("PageIndex", pageIndex);
            dp.Add("PageSize", pageSize);