75 lines
2.5 KiB
C#
75 lines
2.5 KiB
C#
using Dlhis.Canteen.Order.Request;
|
|
using Dlhis.Canteen.Order.Response;
|
|
using Dlhis.Entity.Basic.Entity;
|
|
using Dlhis.Entity.Canteen.Entities;
|
|
using Kurisu.AspNetCore.Utils.Extensions;
|
|
using Kurisu.Core.DataAccess.Dto;
|
|
using Kurisu.Core.User.Abstractions;
|
|
using Kurisu.SqlSugar.Extensions;
|
|
using Kurisu.SqlSugar.Services;
|
|
using Mapster;
|
|
|
|
namespace Dlhis.Canteen.Order.Services.Implements
|
|
{
|
|
public class MenuDishesService : IMenuDishesService
|
|
{
|
|
private readonly IDbContext _dbContext;
|
|
private readonly ICurrentUser _currentUser;
|
|
|
|
public MenuDishesService(IDbContext dbContext, ICurrentUser currentUser)
|
|
{
|
|
_dbContext = dbContext;
|
|
_currentUser = currentUser;
|
|
}
|
|
|
|
public async Task<Pagination<GetMenuResponse>> GetMenuAsync(GetMenuRequest request)
|
|
{
|
|
|
|
var page = await _dbContext.Queryable<CanteenMenuEntity>()
|
|
.LeftJoin<BusinessPlaceEntity>((x, place) => x.PlaceCode == place.Code)
|
|
.WhereIF(request.PlaceCode.HasValue, x => request.PlaceCode == x.PlaceCode)
|
|
.WhereIF(!request.Search.IsEmpty(), x => x.Name.Contains(request.Search))
|
|
.Select((x, place) => new GetMenuResponse
|
|
{
|
|
PlaceName = place.Name,
|
|
|
|
}, true)
|
|
.ToPageListAsync(request);
|
|
return page;
|
|
}
|
|
|
|
public async Task SaveMenuAsync(SaveMenuRequest request)
|
|
{
|
|
var place = await _dbContext.Queryable<BusinessPlaceEntity>()
|
|
.FirstAsync(x => x.Code == request.PlaceCode);
|
|
place.ThrowIfNull($"{request.PlaceCode}:该营业点不存在！");
|
|
|
|
|
|
}
|
|
|
|
public async Task<Pagination<GetDishesResponse>> GetDishesAsync(GetDishesRequest request)
|
|
{
|
|
return null;
|
|
}
|
|
|
|
public async Task SaveDishesAsync(SaveDishesRequest request)
|
|
{
|
|
if (!request.Id.HasValue)
|
|
{
|
|
var dishers = request.Adapt<CanteenDishesEntity>();
|
|
//todo 检验重复
|
|
dishers.CustomCode = request.CustomCode;
|
|
await _dbContext.InsertAsync(dishers);
|
|
}
|
|
else
|
|
{
|
|
var entity = await _dbContext.Queryable<CanteenDishesEntity>()
|
|
.Where(x => x.Id == request.Id).FirstAsync();
|
|
|
|
request.Adapt(entity);
|
|
await _dbContext.UpdateAsync(entity);
|
|
}
|
|
}
|
|
}
|
|
}
|