64 lines
2.3 KiB
C#
64 lines
2.3 KiB
C#
using dy.net.model;
|
|
using SqlSugar;
|
|
|
|
namespace dy.net.repository
|
|
{
|
|
public class DyCollectVideoRepository : BaseRepository<DyCollectVideo>
|
|
{
|
|
// 注入SQLSugar客户端
|
|
public DyCollectVideoRepository(ISqlSugarClient db) : base(db)
|
|
{
|
|
}
|
|
|
|
|
|
|
|
/// <summary>
|
|
/// 分页查询收藏视频
|
|
/// </summary>
|
|
/// <param name="pageIndex">页码（从1开始）</param>
|
|
/// <param name="pageSize">每页数量</param>
|
|
/// <param name="tag">可选标签过滤</param>
|
|
/// <param name="author">可选作者过滤</param>
|
|
/// <returns>分页结果（视频列表和总数）</returns>
|
|
public async Task<(List<DyCollectVideo> list, int totalCount)> GetPagedAsync(int pageIndex, int pageSize, string tag = null, string author = null,string viedoType=null, List<string> dates = null)
|
|
{
|
|
|
|
DateTime? start = null;
|
|
DateTime? end =null;
|
|
if(dates!=null && dates.Count==2)
|
|
{
|
|
start = Convert.ToDateTime(dates[0]);
|
|
end = Convert.ToDateTime(dates[1]);
|
|
}
|
|
else if(dates!=null && dates.Count==1)
|
|
{
|
|
start = Convert.ToDateTime(dates[0]);
|
|
}
|
|
|
|
var where = this.Db.Queryable<DyCollectVideo>()
|
|
.WhereIF(!string.IsNullOrEmpty(tag), x => x.Tag1 == tag)
|
|
.WhereIF(!string.IsNullOrEmpty(author), x => x.Author == author)
|
|
.WhereIF(start.HasValue, x => x.SyncTime >= start.Value)
|
|
.WhereIF(end.HasValue, x => x.SyncTime <= end.Value)
|
|
.WhereIF(!string.IsNullOrEmpty(viedoType) && viedoType != "*", x => x.ViedoType == viedoType);
|
|
|
|
|
|
var totalCount = await where.CountAsync();
|
|
var list = await where.OrderByDescending(x=>x.SyncTime).Skip((pageIndex - 1) * pageSize).Take(pageSize).ToListAsync();
|
|
if (list.Any()) {
|
|
var users= await this.Db.Queryable<DyUserCookies>().ToListAsync();
|
|
foreach (var item in list)
|
|
{
|
|
var user= users.FirstOrDefault(x=>x.Id== item.CookieId);
|
|
if(user!=null)
|
|
{
|
|
item.DyUser = user.UserName;
|
|
}
|
|
}
|
|
}
|
|
return (list, totalCount);
|
|
}
|
|
|
|
}
|
|
}
|