/*********************************************************************** * Project: baifenBinfa * ProjectName: 百分兵法管理系统 * Web: http://chuanyin.com * Author: * Email: * CreateTime: 202403/02 * Description: 暂无 ***********************************************************************/ using System; using System.Collections.Generic; using System.Linq.Expressions; using System.Threading.Tasks; using CoreCms.Net.IRepository; using CoreCms.Net.IRepository.UnitOfWork; using CoreCms.Net.Model.Entities; using CoreCms.Net.Model.ViewModels.Basics; using SqlSugar; namespace CoreCms.Net.Repository { /// /// 退款单表 接口实现 /// public class CoreCmsBillRefundRepository : BaseRepository, ICoreCmsBillRefundRepository { public CoreCmsBillRefundRepository(IUnitOfWork unitOfWork) : base(unitOfWork) { } #region 重写根据条件查询分页数据 /// /// 重写根据条件查询分页数据 /// /// 判断集合 /// 排序方式 /// 当前页面索引 /// 分布大小 /// /// 是否使用WITH(NOLOCK) /// public async Task> QueryPageAsync(Expression> predicate, Expression> orderByExpression, OrderByType orderByType, int pageIndex = 1, int pageSize = 20, bool blUseNoLock = false) { RefAsync totalCount = 0; List page; if (blUseNoLock) { page = await DbClient.Queryable((p, sc) => new JoinQueryInfos( JoinType.Left, p.userId == sc.id)) .Select((p, sc) => new CoreCmsBillRefund { refundId = p.refundId, aftersalesId = p.aftersalesId, money = p.money, userId = p.userId, sourceId = p.sourceId, type = p.type, paymentCode = p.paymentCode, tradeNo = p.tradeNo, status = p.status, memo = p.memo, createTime = p.createTime, updateTime = p.updateTime, userNickName = sc.nickName }) .With(SqlWith.NoLock) .MergeTable() .OrderByIF(orderByExpression != null, orderByExpression, orderByType) .WhereIF(predicate != null, predicate) .ToPageListAsync(pageIndex, pageSize, totalCount); } else { page = await DbClient.Queryable((p, sc) => new JoinQueryInfos( JoinType.Left, p.userId == sc.id)) .Select((p, sc) => new CoreCmsBillRefund { refundId = p.refundId, aftersalesId = p.aftersalesId, money = p.money, userId = p.userId, sourceId = p.sourceId, type = p.type, paymentCode = p.paymentCode, tradeNo = p.tradeNo, status = p.status, memo = p.memo ?? "", createTime = p.createTime, updateTime = p.updateTime, userNickName = sc.nickName }) .MergeTable() .OrderByIF(orderByExpression != null, orderByExpression, orderByType) .WhereIF(predicate != null, predicate) .ToPageListAsync(pageIndex, pageSize, totalCount); } var list = new PageList(page, pageIndex, pageSize, totalCount); return list; } #endregion } }