diff --git a/Src/Dlhis.Canteen/Order/Request/BalanceRecordUserGroupPageRequest.cs b/Src/Dlhis.Canteen/Order/Request/BalanceRecordUserGroupPageRequest.cs index 30f332cb..94f6a5be 100644 --- a/Src/Dlhis.Canteen/Order/Request/BalanceRecordUserGroupPageRequest.cs +++ b/Src/Dlhis.Canteen/Order/Request/BalanceRecordUserGroupPageRequest.cs @@ -1,4 +1,5 @@ using System.ComponentModel.DataAnnotations; +using Dlhis.Entity.Canteen.Enums; using Kurisu.AspNetCore.CustomClass; using Kurisu.AspNetCore.DataAccess.Dto; @@ -18,6 +19,13 @@ public class BalanceRecordUserGroupPageRequest : PageDto, IValidatableObject public string UserCode { get; set; } + /// + /// 消费类型 + /// + [EnumDataType(typeof(BalanceRecordTypeEnumType))] + public BalanceRecordTypeEnumType? Type { get; set; } + + public IEnumerable Validate(ValidationContext validationContext) { if (SearchDateTimePeriod is { End: not null }) diff --git a/Src/Dlhis.Canteen/Order/Services/Implements/BalanceService.cs b/Src/Dlhis.Canteen/Order/Services/Implements/BalanceService.cs index 0eff0736..90f10526 100644 --- a/Src/Dlhis.Canteen/Order/Services/Implements/BalanceService.cs +++ b/Src/Dlhis.Canteen/Order/Services/Implements/BalanceService.cs @@ -277,7 +277,7 @@ public class BalanceService : IBalanceService var amount = await queryable.SumAsync(record => SqlFunc.Abs(record.Amount)); - var total = await queryable.GroupBy(record => record.UserNo).Select(record => record.UserNo).CountAsync(); + var total = await queryable.Select(record => record.UserCode).Distinct().CountAsync(); return new BalanceRecordByBusinessPlaceResponse { @@ -388,8 +388,8 @@ public class BalanceService : IBalanceService .LeftJoin((record, ga, department) => ga.DepartmentNo == department.No) .LeftJoin((record, ga, department, bPlace) => record.BusinessPlaceCode == bPlace.Code) .Where((record, ga) => record.UserCode == request.UserCode) - .Where(record => record.Status == BalanceRecordStatusEnumType.Valid && record.Type == BalanceRecordTypeEnumType.Out) - .Where(record => record.Source != BalanceRecordSourceEnumType.EMealVoucher) //不展示电子餐券信息 + .Where(record => record.Status == BalanceRecordStatusEnumType.Valid && record.Source != BalanceRecordSourceEnumType.EMealVoucher) //不展示电子餐券信息 + .WhereIF(request.Type.HasValue, record => record.Type == request.Type) .WhereIF(request.SearchDateTimePeriod.HasValue(), record => record.CostDate >= request.SearchDateTimePeriod.Start && record.CostDate <= request.SearchDateTimePeriod.End) .OrderBy(record => record.CostDateTime) .Select((record, ga, department, bPlace) => new BalanceRecordUserPageResponse @@ -555,7 +555,7 @@ public class BalanceService : IBalanceService { await CommonHelper.RetryAsync(async () => { - var gainfo = await _dbContext.Queryable().Where(x => x.Code == userCode).SingleAsync() + var gainfo = await _dbContext.Queryable().Where(x => x.Code == userCode).SingleAsync() ?? await _dbContext.Queryable().Where(x => x.Code == userCode).SingleAsync(); gainfo.ThrowIfNull("档案不存在");