MeiRiYiCheng_1_old/YBDevice.NWeb/DBServices/ResultApp.cs

69 lines
2.4 KiB
C#
Raw Permalink Normal View History

2025-07-16 17:14:38 +08:00
using Nirvana.Common;
using Nirvana.Data;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using YBDevice.Entity;
namespace YBDevice.Service.DBServices
{
/// <summary>
/// 测量记录
/// </summary>
public partial class ResultApp : Repository<YB_Device>
{
/// <summary>
/// 测量记录列表
/// </summary>
/// <param name="param"></param>
/// <returns></returns>
public async Task<PageParms<YB_ResultExt>> GetListAsync(QueryParams param)
{
using (var dbClient = ReadDbContext.GetInstance())
{
RefAsync<int> totalnum = 0;
var temquery = dbClient.Queryable<YB_ResultExt>();
var currentUser = OperatorProvider.Provider.GetCurrent();
if (param.queryParam != null && param.queryParam.Count > 0)
{
List<IConditionalModel> conModels = new List<IConditionalModel>();
param.queryParam.ForEach(x =>
{
if (!string.IsNullOrEmpty(x.Value))
{
conModels.Add(new ConditionalModel()
{
FieldName = x.Name,
ConditionalType = (ConditionalType)x.Type,
FieldValue = x.Value.Trim()
});
}
});
if (conModels.Count > 0)
{
temquery = temquery.Where(conModels);
}
}
if (currentUser.AccountType != (int)AccountType.platform)
{
temquery = temquery.Where(x => x.BusinessId == currentUser.BusinessId);
}
string sorts = string.Format("{0} {1}", param.sort, param.order);
var query = await temquery.OrderBy(sorts)
.ToPageListAsync(param.offset, param.limit, totalnum);
return new PageParms<YB_ResultExt>
{
page = param.offset,
Items = query,
totalnum = totalnum,
limit = param.limit
};
}
}
}
}