yuangb/jinko.yikatong
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix 代码优化

Browse Source
This commit is contained in:
liguoyang
2024-04-28 11:16:23 +08:00
parent a248920f83
commit 339236c79f
7 changed files with 72 additions and 201 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
Src/Dlhis.Basic.Api/IDisheMenuApi.cs → Src/Dlhis.Basic.Api/IDishesMenuApi.cs
View File

@@ -5,7 +5,7 @@ using Kurisu.RemoteCall.Attributes;
namespace Dlhis.Basic.Api; namespace Dlhis.Basic.Api;
[EnableRemoteClient(Name = "basic-service", BaseUrl = "${InternalRequest:BasicRequestUrl}")] [EnableRemoteClient(Name = "basic-service", BaseUrl = "${InternalRequest:BasicRequestUrl}")]
public interface IDisheMenuApi public interface IDishesMenuApi
{ {
/// <summary> /// <summary>
/// ///

11
Src/Dlhis.Basic/Device/Controllers/DevicePermissionsController.cs
View File

@@ -45,17 +45,6 @@ public class DevicePermissionsController : ControllerBase
return await _devicePermissionService.GetAssignmentsAsync(request.UniqueType, request.AssignType, request.AssignValue); return await _devicePermissionService.GetAssignmentsAsync(request.UniqueType, request.AssignType, request.AssignValue);
} }
/// <summary>
/// 获取用户权限设备
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
[HttpGet("assignmentsbyno")]
public async Task<Pagination<AssigmentByCodeResponse>> GetAssigmentByCodeAsync([FromQuery] AssigmentByCodeRequest request)
{
return await _devicePermissionService.GetAssigmentByCodeAsync(request);
}
/// <summary> /// <summary>
/// 获取就餐设备唯一号权限 /// 获取就餐设备唯一号权限

15
Src/Dlhis.Basic/Device/Request/AssigmentByCodeRequest.cs
View File

@@ -1,15 +0,0 @@
using Kurisu.Core.DataAccess.Dto;
using SqlSugar;
using System.ComponentModel.DataAnnotations;
namespace Dlhis.Basic.Device.Request
{
public class AssigmentByCodeRequest : PageDto
{
/// <summary>
/// 档案号
/// </summary>
[Required]
public string No { get; set; }
}
}

17
Src/Dlhis.Basic/Device/Response/AssigmentByCodeResponse.cs
View File

@@ -1,17 +0,0 @@
using SqlSugar;
namespace Dlhis.Basic.Device.Response
{
public class AssigmentByCodeResponse
{
/// <summary>
/// 设备唯一码,IP/MAC/SNO
/// </summary>
public string UniqueNo { get; set; }
/// <summary>
/// 设备名称
/// </summary>
public string UniqueName { get; set; }
}
}

11
Src/Dlhis.Basic/Device/Services/IDevicePermissionService.cs
View File

@@ -42,8 +42,7 @@ public interface IDevicePermissionService : IScopeDependency
/// <param name="taskType"></param> /// <param name="taskType"></param>
/// <returns></returns> /// <returns></returns>
Task GenerateDeviceTasksAsync(string userNo, DeviceTaskEnumType taskType); Task GenerateDeviceTasksAsync(string userNo, DeviceTaskEnumType taskType);
/// <summary> /// <summary>
/// 获取用户所有设备权限 /// 获取用户所有设备权限
/// </summary> /// </summary>
@@ -59,14 +58,6 @@ public interface IDevicePermissionService : IScopeDependency
/// <returns></returns> /// <returns></returns>
Task<List<string>> GetCanteenDeviceUniqueNosByUserNoAsync(string userNo); Task<List<string>> GetCanteenDeviceUniqueNosByUserNoAsync(string userNo);
/// <summary>
/// 获取用户权限设备
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
Task<Pagination<AssigmentByCodeResponse>> GetAssigmentByCodeAsync(AssigmentByCodeRequest request);
Task<PermissionUsersInfoDto> GetPermissionUsersInfoAsync(List<string> userNos); Task<PermissionUsersInfoDto> GetPermissionUsersInfoAsync(List<string> userNos);

87
Src/Dlhis.Basic/Device/Services/Implements/DevicePermissionService.cs
View File

@@ -318,79 +318,6 @@ public class DevicePermissionService : IDevicePermissionService
return result.SelectMany(x => x.Codes).ToList(); return result.SelectMany(x => x.Codes).ToList();
} }
/// <summary>
/// 获取用户权限设备
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
public async Task<Pagination<AssigmentByCodeResponse>> GetAssigmentByCodeAsync(AssigmentByCodeRequest request)
{
var lst1 = new List<Guid>();
//所有设备guid
var gds = await GetAssignmentsAsync(DeviceAssignmentTypeEnumType.Device, AssignTypeEnumType.User, request.No);
if (gds != null && gds.Count > 0)
{
lst1.AddRange(gds);
}
//所有设备组guid
var ggs = await GetAssignmentsAsync(DeviceAssignmentTypeEnumType.Group, AssignTypeEnumType.User, request.No);
//所有营业点guid
var gps = await GetAssignmentsAsync(DeviceAssignmentTypeEnumType.BusinessPlace, AssignTypeEnumType.User, request.No);
var devices = await _dbContext.Queryable<DeviceEntity>().Where(x => x.Enable).ToListAsync();
var regiss = await _dbContext.Queryable<DeviceRegistryEntity>().ToListAsync();
if (ggs != null && ggs.Count > 0)
{
foreach (var gid in ggs)
{
var ds = await _dbContext.Queryable<DeviceGroupRelationshipEntity>()
.Where(x => x.GroupCode == gid)
.Select(x => x.DeviceCode)
.ToListAsync();
lst1.AddRange(ds);
}
}
if (gps != null && gps.Count > 0)
{
foreach (var placeCode in gps)
{
var nos = regiss.Where(x => x.BusinessPlaceCode == placeCode)
.Select(x => x.DeviceUniqueNo).ToList();
var dcodes = devices.Where(d => nos.Contains(d.UniqueNo))
.Select(d => d.Code).ToList();
lst1.AddRange(dcodes);
}
}
var dds = lst1.Distinct().ToList();
var lst = devices.Where(x => dds.Contains(x.Code))
.Select(x => new AssigmentByCodeResponse
{
UniqueNo = x.UniqueNo,
UniqueName = x.Supplier
}).ToList();
// 分页操作
var startIndex = (request.PageIndex - 1) * request.PageSize;
var pagedData = lst.Skip(startIndex).Take(request.PageSize).ToList();
var pagination = new Pagination<AssigmentByCodeResponse>
{
PageIndex = request.PageIndex,
PageSize = request.PageSize,
Total = lst.Count, // 使用原始列表的总数进行分页
Data = pagedData
};
return pagination;
}
//************************************************ help methods ******************************************************* //************************************************ help methods *******************************************************
/// <summary> /// <summary>
@@ -440,7 +367,7 @@ public class DevicePermissionService : IDevicePermissionService
var tops = deviceGroups.Where(x => !x.PCode.HasValue).ToList(); var tops = deviceGroups.Where(x => !x.PCode.HasValue).ToList();
tops.ForEach(x => tops.ForEach(x =>
{ {
RecursionGetNext(x, deviceGroups, tenantDevicePermissions, tenantDevicePermissions.SelectMany(x => x.Codes).Contains(x.Code)); RecursionGetNext(x, deviceGroups, tenantDevicePermissions, tenantDevicePermissions.SelectMany(item => item.Codes).Contains(x.Code));
}); });
} }
@@ -471,8 +398,8 @@ public class DevicePermissionService : IDevicePermissionService
private async Task<Dictionary<string, List<UserTenantDeviceCodeDto>>> GetAssignDeviceCodesInternalAsync(List<string> userNos) private async Task<Dictionary<string, List<UserTenantDeviceCodeDto>>> GetAssignDeviceCodesInternalAsync(List<string> userNos)
{ {
var deivces = await _dbContext.Queryable<DeviceEntity>().Where(x => x.Enable).ToListAsync(); var devices = await _dbContext.Queryable<DeviceEntity>().Where(x => x.Enable).ToListAsync();
var deviceUniqueNos = deivces.Select(x => x.UniqueNo).ToList(); var deviceUniqueNos = devices.Select(x => x.UniqueNo).ToList();
var registries = await _dbContext.Queryable<DeviceRegistryEntity>() var registries = await _dbContext.Queryable<DeviceRegistryEntity>()
.Where(x => deviceUniqueNos.Contains(x.DeviceUniqueNo)) .Where(x => deviceUniqueNos.Contains(x.DeviceUniqueNo))
.Where(x => !SqlFunc.IsNullOrEmpty(x.BusinessPlaceCode)) .Where(x => !SqlFunc.IsNullOrEmpty(x.BusinessPlaceCode))
@@ -493,7 +420,7 @@ public class DevicePermissionService : IDevicePermissionService
foreach (var gainfo in gainfos) foreach (var gainfo in gainfos)
{ {
var codes = GetAssignDeviceCodesInternal(gainfo, gainfoGroupRelationships, devicePermissions, deviceGroups, deviceRelationships, registries, deivces); var codes = GetAssignDeviceCodesInternal(gainfo, gainfoGroupRelationships, devicePermissions, deviceGroups, deviceRelationships, registries, devices);
result.Add(gainfo.No, codes); result.Add(gainfo.No, codes);
} }
@@ -558,14 +485,14 @@ public class DevicePermissionService : IDevicePermissionService
var deviceGroupCodes = deviceGroupDtos.SelectMany(x => x.Codes).Distinct().ToList(); var deviceGroupCodes = deviceGroupDtos.SelectMany(x => x.Codes).Distinct().ToList();
var businessPlaceCodes = businessPlaceDtos.SelectMany(x => x.Codes).Distinct().ToList(); var businessPlaceCodes = businessPlaceDtos.SelectMany(x => x.Codes).Distinct().ToList();
var deveiceCodesByGroup = deviceGroupRelationships.Where(x => deviceGroupCodes.Contains(x.GroupCode)).GroupBy(x => x.TenantId) var deviceCodesByGroup = deviceGroupRelationships.Where(x => deviceGroupCodes.Contains(x.GroupCode)).GroupBy(x => x.TenantId)
.Select(x => new UserTenantDeviceCodeDto .Select(x => new UserTenantDeviceCodeDto
{ {
Tenant = x.Key, Tenant = x.Key,
Codes = x.Select(item => item.DeviceCode).Distinct().ToList() Codes = x.Select(item => item.DeviceCode).Distinct().ToList()
}); });
var placeGroup = deviceRegistries.Where(x => businessPlaceCodes.Contains(x.BusinessPlaceCode.Value)).GroupBy(x => x.TenantId) var placeGroup = deviceRegistries.Where(x => businessPlaceCodes.Contains(x.BusinessPlaceCode!.Value)).GroupBy(x => x.TenantId)
.Select(x => .Select(x =>
{ {
var currentDeviceUniqueNos = x.Select(item => item.DeviceUniqueNo).ToList(); var currentDeviceUniqueNos = x.Select(item => item.DeviceUniqueNo).ToList();
@@ -578,7 +505,7 @@ public class DevicePermissionService : IDevicePermissionService
}) })
.ToList(); .ToList();
deviceDtos.AddRange(deveiceCodesByGroup); deviceDtos.AddRange(deviceCodesByGroup);
deviceDtos.AddRange(placeGroup); deviceDtos.AddRange(placeGroup);
return deviceDtos.GroupBy(x => x.Tenant).Select(x => new UserTenantDeviceCodeDto return deviceDtos.GroupBy(x => x.Tenant).Select(x => new UserTenantDeviceCodeDto

130
Src/Dlhis.Canteen/Order/Services/Implements/BookingOrderService.cs
View File

@@ -19,16 +19,16 @@ namespace Dlhis.Canteen.Order.Services.Implements;
public class BookingOrderService : BaseOrderService, IBookingOrderService public class BookingOrderService : BaseOrderService, IBookingOrderService
{ {
private readonly IDisheMenuApi _disheMenuApi; private readonly IDishesMenuApi _dishesMenuApi;
private readonly IBusinessPlacePermissionsApi _businessPlacePermissionsApi; private readonly IBusinessPlacePermissionsApi _businessPlacePermissionsApi;
public BookingOrderService(ICanteenSettingService canteenSettingService, IDbContext dbContext, public BookingOrderService(ICanteenSettingService canteenSettingService, IDbContext dbContext,
IDisheMenuApi disheMenuApi, IDishesMenuApi dishesMenuApi,
IBusinessPlacePermissionsApi businessPlacePermissionsApi, IBusinessPlacePermissionsApi businessPlacePermissionsApi,
ICurrentUser currentUser, IDevicePermissionApi devicePermissionApi, ILogger<BookingOrderService> logger) ICurrentUser currentUser, IDevicePermissionApi devicePermissionApi, ILogger<BookingOrderService> logger)
: base(canteenSettingService, dbContext, currentUser, devicePermissionApi, logger) : base(canteenSettingService, dbContext, currentUser, devicePermissionApi, logger)
{ {
_disheMenuApi = disheMenuApi; _dishesMenuApi = dishesMenuApi;
_businessPlacePermissionsApi = businessPlacePermissionsApi; _businessPlacePermissionsApi = businessPlacePermissionsApi;
} }
@@ -46,7 +46,7 @@ public class BookingOrderService : BaseOrderService, IBookingOrderService
(now >= dealLine).ThrowIfTrue("超出订餐时间"); (now >= dealLine).ThrowIfTrue("超出订餐时间");
//菜单存在 //菜单存在
var menuDetailResult = await _disheMenuApi.GetBookingDishesDetailAsync(request.BookingDate, request.BusinessPlaceCode, (int)request.ShiftType, request.DishesCode); var menuDetailResult = await _dishesMenuApi.GetBookingDishesDetailAsync(request.BookingDate, request.BusinessPlaceCode, (int)request.ShiftType, request.DishesCode);
var menuDetail = menuDetailResult.Data; var menuDetail = menuDetailResult.Data;
menuDetail.ThrowIfNull("预定失败,菜品已经下架"); menuDetail.ThrowIfNull("预定失败,菜品已经下架");
@@ -75,7 +75,7 @@ public class BookingOrderService : BaseOrderService, IBookingOrderService
IsOffline = false, IsOffline = false,
IsCostCrossTenant = await GetSettingAsync<bool>(businessPlace.TenantId, CanteenSettingItemEnumType.AllowCrossTenant), IsCostCrossTenant = await GetSettingAsync<bool>(businessPlace.TenantId, CanteenSettingItemEnumType.AllowCrossTenant),
OriginTenantId = gainfo.Factory,//人员可能跨基地消费 OriginTenantId = gainfo.Factory, //人员可能跨基地消费
Status = BalanceRecordStatusEnumType.Valid, Status = BalanceRecordStatusEnumType.Valid,
OrderStatus = CanteenOrderStatusEnumType.Success, OrderStatus = CanteenOrderStatusEnumType.Success,
@@ -89,8 +89,8 @@ public class BookingOrderService : BaseOrderService, IBookingOrderService
var orderId = await DbContext.InsertReturnIdentityAsync(order); var orderId = await DbContext.InsertReturnIdentityAsync(order);
await CommonHelper.RetryAsync(async () => await CommonHelper.RetryAsync(async () =>
{ {
await _disheMenuApi.GetBookingDishesDetailAsync(request.BookingDate, request.BusinessPlaceCode, (int)request.ShiftType, request.DishesCode); await _dishesMenuApi.GetBookingDishesDetailAsync(request.BookingDate, request.BusinessPlaceCode, (int)request.ShiftType, request.DishesCode);
var menuDetail = menuDetailResult.Data; menuDetail = menuDetailResult.Data;
menuDetail.ThrowIfNull("预定失败,菜品已经下架"); menuDetail.ThrowIfNull("预定失败,菜品已经下架");
menuDetail.Number -= request.Number; menuDetail.Number -= request.Number;
@@ -107,24 +107,24 @@ public class BookingOrderService : BaseOrderService, IBookingOrderService
(mealInfo.Balance < 0).ThrowIfTrue("余额不足,无法消费"); (mealInfo.Balance < 0).ThrowIfTrue("余额不足,无法消费");
await DbContext.Updateable<GainfoMealEntity>() await DbContext.Updateable<GainfoMealEntity>()
.SetColumns(x => x.Balance == mealInfo.Balance) .SetColumns(x => x.Balance == mealInfo.Balance)
.SetColumns(x => x.Version == x.Version + 1) .SetColumns(x => x.Version == x.Version + 1)
.SetColumns(x => x.ModifiedTime == DateTime.Now) .SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(x => x.UserNo == order.UserNo && x.Version == mealInfo.Version)//必须与查询时的version一致 .Where(x => x.UserNo == order.UserNo && x.Version == mealInfo.Version) //必须与查询时的version一致
.ExecuteCommandThrowVersionAsync(); .ExecuteCommandThrowVersionAsync();
} }
await DbContext.Updateable<DishesMenuEntity>() await DbContext.Updateable<DishesMenuEntity>()
.SetColumns(x => x.Number == menuDetail.Number) .SetColumns(x => x.Number == menuDetail.Number)
.SetColumns(x => x.Version == x.Version + 1) .SetColumns(x => x.Version == x.Version + 1)
.SetColumns(x => x.ModifiedTime == now) .SetColumns(x => x.ModifiedTime == now)
.Where(x => x.StartDate <= menuDetail.Date && menuDetail.Date <= x.EndDate .Where(x => x.StartDate <= menuDetail.Date && menuDetail.Date <= x.EndDate
&& x.ShiftType == request.ShiftType && x.ShiftType == request.ShiftType
&& x.BusinessPlaceCode == request.BusinessPlaceCode && x.BusinessPlaceCode == request.BusinessPlaceCode
&& x.DishesCode == request.DishesCode && x.DishesCode == request.DishesCode
&& x.Version == menuDetail.Version && x.Version == menuDetail.Version
) )
.ExecuteCommandThrowVersionAsync(); .ExecuteCommandThrowVersionAsync();
//写入记录 //写入记录
var balanceRecord = order.Adapt<BalanceRecordEntity>(); var balanceRecord = order.Adapt<BalanceRecordEntity>();
@@ -140,7 +140,6 @@ public class BookingOrderService : BaseOrderService, IBookingOrderService
Number = request.Number, Number = request.Number,
TenantId = order.TenantId, TenantId = order.TenantId,
}); });
}, 10); }, 10);
@@ -159,52 +158,51 @@ public class BookingOrderService : BaseOrderService, IBookingOrderService
var myCodes = (await _businessPlacePermissionsApi.GetMyAsync()).Data.Select(x => (Guid?)x.Code).ToList(); var myCodes = (await _businessPlacePermissionsApi.GetMyAsync()).Data.Select(x => (Guid?)x.Code).ToList();
var page = await DbContext.Queryable<CanteenOrderEntity>() var page = await DbContext.Queryable<CanteenOrderEntity>()
.LeftJoin<GainfoEntity>((x, ga) => x.UserNo == ga.No) .LeftJoin<GainfoEntity>((x, ga) => x.UserNo == ga.No)
.LeftJoin<DepartmentEntity>((x, ga, dept) => dept.No == ga.DepartmentNo) .LeftJoin<DepartmentEntity>((x, ga, dept) => dept.No == ga.DepartmentNo)
.Where(x => myCodes.Contains(x.BusinessPlaceCode)) .Where(x => myCodes.Contains(x.BusinessPlaceCode))
.WhereIF(request.OrderStatus.HasValue, x => x.OrderStatus == request.OrderStatus) .WhereIF(request.OrderStatus.HasValue, x => x.OrderStatus == request.OrderStatus)
.WhereIF(request.Source.HasValue, x => x.Source == request.Source) .WhereIF(request.Source.HasValue, x => x.Source == request.Source)
.WhereIF(request.Search.IsPresent(), (x, ga) => x.UserCode == request.Search || ga.Name.Contains(request.Search)) .WhereIF(request.Search.IsPresent(), (x, ga) => x.UserCode == request.Search || ga.Name.Contains(request.Search))
.WhereIF(request.BookingPeriod?.Start.HasValue == true && request.BookingPeriod?.End.HasValue == true, x => .WhereIF(request.BookingPeriod?.Start.HasValue == true && request.BookingPeriod?.End.HasValue == true, x =>
SqlFunc.Subqueryable<CanteenOrderDetailEntity>() SqlFunc.Subqueryable<CanteenOrderDetailEntity>()
.Where(p => p.OrderNo == x.No) .Where(p => p.OrderNo == x.No)
.Where(p => p.BookingDate >= request.BookingPeriod.Start) .Where(p => p.BookingDate >= request.BookingPeriod.Start)
.Where(p => p.BookingDate <= request.BookingPeriod.End) .Where(p => p.BookingDate <= request.BookingPeriod.End)
.Any() .Any()
) )
.WhereIF(request.ShiftTpe.HasValue, x => x.ShiftType == request.ShiftTpe) .WhereIF(request.ShiftTpe.HasValue, x => x.ShiftType == request.ShiftTpe)
.Select((x, ga, dept) => new OrderBookingResponse .Select((x, ga, dept) => new OrderBookingResponse
{ {
No = x.No, No = x.No,
DeliveryAddress = x.DeliveryAddress, DeliveryAddress = x.DeliveryAddress,
Remark = x.Remark, Remark = x.Remark,
Amount = SqlFunc.Abs(x.Amount), Amount = SqlFunc.Abs(x.Amount),
CreateTime = x.CreateTime, CreateTime = x.CreateTime,
ShiftType = x.ShiftType, ShiftType = x.ShiftType,
Status = x.OrderStatus, Status = x.OrderStatus,
UserCode = x.UserCode, UserCode = x.UserCode,
UserName = ga.Name, UserName = ga.Name,
Source = x.Source, Source = x.Source,
DepartmentName = dept.Name, DepartmentName = dept.Name,
}) })
.ToPageListAsync(request); .ToPageListAsync(request);
var nos = page.Data.Select(x => x.No).ToList(); var nos = page.Data.Select(x => x.No).ToList();
var details = await DbContext.Queryable<CanteenOrderDetailEntity>() var details = await DbContext.Queryable<CanteenOrderDetailEntity>()
.LeftJoin<DishesEntity>((x, dishes) => x.DishesCode == dishes.CustomCode) .LeftJoin<DishesEntity>((x, dishes) => x.DishesCode == dishes.CustomCode)
.Where(x => nos.Contains(x.OrderNo)) .Where(x => nos.Contains(x.OrderNo))
.Select((x, dishes) => new { x.OrderNo, x.BookingDate, x.Number, dishes.Name }). .Select((x, dishes) => new { x.OrderNo, x.BookingDate, x.Number, dishes.Name }).ToListAsync();
ToListAsync();
page.Data.ForEach(x => page.Data.ForEach(x =>
{ {
x.BookingDate = details.FirstOrDefault(item => item.OrderNo == x.No).BookingDate; x.BookingDate = details.First(item => item.OrderNo == x.No).BookingDate;
x.TotalNumber = details.Where(item => item.OrderNo == x.No).Sum(item => item.Number); x.TotalNumber = details.Where(item => item.OrderNo == x.No).Sum(item => item.Number);
x.DishesInfos = details.Where(item => item.OrderNo == x.No).Select(item => new x.DishesInfos = details.Where(item => item.OrderNo == x.No).Select(item => new
{ {
item.Name item.Name
}) })
.ToList(); .ToList();
}); });
return page; return page;
@@ -243,7 +241,6 @@ public class BookingOrderService : BaseOrderService, IBookingOrderService
.Where(x => x.No == request.No) .Where(x => x.No == request.No)
.ExecuteCommandAsync(); .ExecuteCommandAsync();
var balance = await DbContext.Queryable<BalanceRecordEntity>().Where(x => x.No == request.No).SingleAsync();
await DbContext.Updateable<BalanceRecordEntity>() await DbContext.Updateable<BalanceRecordEntity>()
.SetColumns(x => x.Status == BalanceRecordStatusEnumType.Obsolute) .SetColumns(x => x.Status == BalanceRecordStatusEnumType.Obsolute)
.SetColumns(x => x.Remark == request.Reason) .SetColumns(x => x.Remark == request.Reason)
@@ -265,7 +262,6 @@ public class BookingOrderService : BaseOrderService, IBookingOrderService
.SetColumns(x => x.ModifiedBy == userId) .SetColumns(x => x.ModifiedBy == userId)
.Where(x => x.Id == mealInfo.Id && x.Version == mealInfo.Version) .Where(x => x.Id == mealInfo.Id && x.Version == mealInfo.Version)
.ExecuteCommandThrowVersionAsync(); .ExecuteCommandThrowVersionAsync();
}, 5); }, 5);
} }
} }
@@ -291,15 +287,15 @@ public class BookingOrderService : BaseOrderService, IBookingOrderService
var end = start.AddDays(1).AddSeconds(-1); var end = start.AddDays(1).AddSeconds(-1);
var exists = await DbContext.Queryable<CanteenOrderEntity>() var exists = await DbContext.Queryable<CanteenOrderEntity>()
.Where(x => x.ApplicationType == CanteenApplicaitonTypeEnumType.Booking) .Where(x => x.ApplicationType == CanteenApplicaitonTypeEnumType.Booking)
.Where(x => x.OrderStatus == CanteenOrderStatusEnumType.Success) .Where(x => x.OrderStatus == CanteenOrderStatusEnumType.Success)
.Where(x => x.ShiftType == shiftType) .Where(x => x.ShiftType == shiftType)
.Where(x => x.UserNo == gainfo.No) .Where(x => x.UserNo == gainfo.No)
.Where(x => x.CreateTime >= start && x.CreateTime <= end) .Where(x => x.CreateTime >= start && x.CreateTime <= end)
.AnyAsync(); .AnyAsync();
exists.ThrowIfTrue("不可重复订餐"); exists.ThrowIfTrue("不可重复订餐");
return gainfo; return gainfo;
} }
} }