472 lines
17 KiB
C#
472 lines
17 KiB
C#
using Dlhis.Canteen.Order.Request;
|
|
using Dlhis.Canteen.Order.Response;
|
|
using Dlhis.Canteen.Setting.Services;
|
|
using Dlhis.Entity.Basic.Entity;
|
|
using Dlhis.Entity.Canteen.Entities;
|
|
using Dlhis.Entity.Canteen.Enums;
|
|
using Dlhis.Entity.Device.Entities;
|
|
using Kurisu.AspNetCore.UnifyResultAndValidation;
|
|
using Kurisu.AspNetCore.Utils;
|
|
using Kurisu.AspNetCore.Utils.Extensions;
|
|
using Kurisu.Core.CustomClass;
|
|
using Kurisu.Core.DataAccess.Dto;
|
|
using Kurisu.SqlSugar.Attributes;
|
|
using Kurisu.SqlSugar.Extensions;
|
|
using Kurisu.SqlSugar.Services;
|
|
using Mapster;
|
|
using SqlSugar;
|
|
|
|
namespace Dlhis.Canteen.Order.Services.Implements;
|
|
|
|
public class OrderService : IOrderService
|
|
{
|
|
private readonly IDbContext _dbContext;
|
|
private readonly ICanteenSettingService _canteenSettingService;
|
|
private readonly ILogger<OrderService> _logger;
|
|
|
|
public OrderService(IDbContext dbContext,
|
|
ICanteenSettingService canteenSettingService,
|
|
ILogger<OrderService> logger)
|
|
{
|
|
_dbContext = dbContext;
|
|
_canteenSettingService = canteenSettingService;
|
|
_logger = logger;
|
|
}
|
|
|
|
public async Task<Pagination<OrderResponse>> GetPageAsync(OrderPageRequest request)
|
|
{
|
|
var page = await _dbContext.Queryable<CanteenOrderEntity>()
|
|
.Select<OrderResponse>()
|
|
.ToPageListAsync(request);
|
|
|
|
return page;
|
|
}
|
|
|
|
[IgnoreTenant]
|
|
public async Task<OrderResultResponse> AddAsync(OrderAddRequest request)
|
|
{
|
|
//尝试匹配userId
|
|
_ = long.TryParse(request.UserUniqueNo, out var userId);
|
|
|
|
//根据档案号
|
|
var gainfo = await _dbContext.Queryable<GainfoEntity>()
|
|
.Where(x => x.No == request.UserUniqueNo || x.Code == request.UserUniqueNo || x.Id == userId)
|
|
.FirstAsync();
|
|
gainfo.ThrowIfNull($"用户{request.UserUniqueNo}不存在,无法操作");
|
|
|
|
var canteenUserExists = await _dbContext.Queryable<CanteenUserEntity>()
|
|
.Where(x => x.UserNo == gainfo.No)
|
|
.AnyAsync();
|
|
canteenUserExists.ThrowIfFalse($"就餐用户{request.UserUniqueNo}不存在,无法操作");
|
|
|
|
//消费
|
|
if (request.Type == BalanceRecordTypeEnumType.Out)
|
|
{
|
|
await ConsumeAsync(request.Adapt<ConsumeRequest>(), gainfo);
|
|
}
|
|
//充值
|
|
else
|
|
{
|
|
await RechargeAsync(request.Adapt<RechargeRequest>(), gainfo);
|
|
}
|
|
|
|
//获取人员余额
|
|
return await _dbContext.Queryable<GainfoEntity>()
|
|
.LeftJoin<DepartmentEntity>((ga, department) => ga.DepartmentNo == department.No)
|
|
.LeftJoin<CanteenUserEntity>((ga, department, mealUser) => ga.No == mealUser.UserNo)
|
|
.Where(ga => ga.Id == gainfo.Id)
|
|
.Select((ga, department, mealUser) => new OrderResultResponse
|
|
{
|
|
UserCode = ga.Code,
|
|
UserName = ga.Name,
|
|
DepartmentNo = ga.DepartmentNo,
|
|
DepartmentName = department.Name,
|
|
Balance = mealUser.Balance
|
|
})
|
|
.SingleAsync();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 消费
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
/// <param name="gainfo"></param>
|
|
/// <returns></returns>
|
|
private async Task ConsumeAsync(ConsumeRequest request, GainfoEntity gainfo)
|
|
{
|
|
var device = await _dbContext.Queryable<DeviceEntity>().Where(x => x.UniqueNo == request.DeviceUniqueNo).Where(x => x.Enable).FirstAsync();
|
|
device.ThrowIfNull("设备不存在或者尚未启用");
|
|
var registry = await _dbContext.Queryable<DeviceRegistryEntity>().Where(x => x.DeviceUniqueNo == request.DeviceUniqueNo).FirstAsync();
|
|
registry.ThrowIfNull("设备尚未注册");
|
|
var businessPlace = await _dbContext.Queryable<CanteenBusinessPlaceEntity>().Where(x => x.Code == registry.BusinessPlaceCode).FirstAsync();
|
|
businessPlace.ThrowIfNull("营业点尚未设置");
|
|
|
|
//获取当前消费餐次
|
|
var shifts = await _dbContext.Queryable<CanteenBusinessShiftEntity>().Where(x => x.BusinessPlaceCode == businessPlace.Code).ToListAsync();
|
|
|
|
var shift = shifts.FirstOrDefault(x => new TimePeriod()
|
|
{
|
|
Start = x.Start,
|
|
End = x.End
|
|
|
|
}.IsPresent1(request.CostDateTime));
|
|
|
|
var settings = await _canteenSettingService.GetUserSettingAsync(request.UserUniqueNo);
|
|
var switchTime = GetSetting<TimeOnly?>(settings, CanteenSettingItemEnumType.BusinessSwitchTime);
|
|
|
|
var shiftTimePeriod = new TimePeriod()
|
|
{
|
|
Start = shift?.Start,
|
|
End = shift?.End
|
|
};
|
|
|
|
//计算成本日期 todo 优化
|
|
var costDate = DateTime.Now;
|
|
if (shift == null)
|
|
{
|
|
costDate = DateTime.Now;
|
|
}
|
|
else
|
|
{
|
|
if (switchTime.HasValue)
|
|
{
|
|
var beginOfDay = DateTime.Today;
|
|
|
|
var setTime = beginOfDay.Add(switchTime.Value.ToTimeSpan());
|
|
if (DateTime.Now < setTime)
|
|
costDate = DateTime.Now.AddDays(-1);
|
|
}
|
|
}
|
|
|
|
var order = new CanteenOrderEntity
|
|
{
|
|
RequestJson = request.ToJson(),
|
|
ThirdNo = request.ThirdNo,
|
|
Type = BalanceRecordTypeEnumType.Out,
|
|
Name = gainfo.Name,
|
|
Source = request.Source,
|
|
UserNo = gainfo.No,
|
|
UserCode = gainfo.Code,
|
|
Amount = request.Amount,
|
|
BusinessPlaceCode = businessPlace.Code,
|
|
BusinessShiftCode = shift?.Code,
|
|
CostDate = costDate.Date,
|
|
CostId = gainfo.CostId,
|
|
DepartmentNo = gainfo.DepartmentNo,
|
|
DeviceInfo = request.DeviceUniqueNo,
|
|
|
|
No = "O" + SnowFlakeHelper.Instance.NextId(),
|
|
SubsidiesFromMonth = request.CostDateTime.ToString("yyyyMM"),
|
|
IsOffline = request.IsOffline,
|
|
IsCostCrossTenant = GetSetting<bool>(settings, CanteenSettingItemEnumType.AllowCrossTenant),
|
|
|
|
OriginTenantId = gainfo.Werks,//人员可能跨基地消费
|
|
|
|
//餐别异常处理
|
|
Status = shift == null ? BalanceRecordStatusEnumType.Doubtful : BalanceRecordStatusEnumType.Valid,
|
|
|
|
OrderStatus = CanteenOrderStatusEnumType.Wait,
|
|
|
|
CostDateTime = request.CostDateTime,
|
|
|
|
//标识当前消费的基地
|
|
TenantId = businessPlace.TenantId,
|
|
};
|
|
|
|
var orderId = await _dbContext.InsertReturnIdentityAsync(order);
|
|
try
|
|
{
|
|
await GenerateConsumeRecordAsync(orderId, settings, shifts, request.CostDateTime);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
await _dbContext.Updateable<CanteenOrderEntity>()
|
|
.SetColumns(x => x.OrderStatus == CanteenOrderStatusEnumType.Failure)
|
|
.SetColumns(x => x.Result == ex.Message)
|
|
.SetColumns(x => x.ModifiedTime == DateTime.Now)
|
|
.Where(x => x.Id == orderId)
|
|
.ExecuteCommandAsync();
|
|
|
|
throw;
|
|
}
|
|
|
|
await _dbContext.Updateable<CanteenOrderEntity>()
|
|
.SetColumns(x => x.OrderStatus == CanteenOrderStatusEnumType.Successful)
|
|
.SetColumns(x => x.ModifiedTime == DateTime.Now)
|
|
.Where(x => x.Id == orderId)
|
|
.ExecuteCommandAsync();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 充值
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
/// <param name="gainfo"></param>
|
|
/// <returns></returns>
|
|
private async Task RechargeAsync(RechargeRequest request, GainfoEntity gainfo)
|
|
{
|
|
var settings = await _canteenSettingService.GetUserSettingAsync(request.UserUniqueNo);
|
|
|
|
var order = new CanteenOrderEntity
|
|
{
|
|
RequestJson = request.ToJson(),
|
|
IsOffline = false,
|
|
ThirdNo = request.ThirdNo,
|
|
Type = BalanceRecordTypeEnumType.In,
|
|
Name = gainfo.Name,
|
|
Source = request.Source,
|
|
UserNo = gainfo.No,
|
|
UserCode = gainfo.Code,
|
|
Amount = request.Amount,
|
|
BusinessPlaceCode = null,
|
|
BusinessShiftCode = null,
|
|
CostDate = DateTime.Now.Date,
|
|
CostId = gainfo.CostId,
|
|
DepartmentNo = gainfo.DepartmentNo,
|
|
DeviceInfo = string.Empty,
|
|
|
|
No = "O" + SnowFlakeHelper.Instance.NextId(),
|
|
SubsidiesFromMonth = request.CostDateTime.ToString("yyyyMM"),
|
|
IsCostCrossTenant = GetSetting<bool>(settings, CanteenSettingItemEnumType.AllowCrossTenant),
|
|
|
|
OriginTenantId = gainfo.Werks,//人员可能跨基地消费
|
|
|
|
Status = BalanceRecordStatusEnumType.Valid,
|
|
|
|
OrderStatus = CanteenOrderStatusEnumType.Wait,
|
|
|
|
CostDateTime = request.CostDateTime,
|
|
|
|
//标识当前消费的基地
|
|
TenantId = gainfo.Werks,
|
|
};
|
|
|
|
var orderId = await _dbContext.InsertReturnIdentityAsync(order);
|
|
try
|
|
{
|
|
await GenerateRechargeRecordAsync(orderId);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
await _dbContext.Updateable<CanteenOrderEntity>()
|
|
.SetColumns(x => x.OrderStatus == CanteenOrderStatusEnumType.Failure)
|
|
.SetColumns(x => x.Result == ex.Message)
|
|
.Where(x => x.Id == orderId)
|
|
.ExecuteCommandAsync();
|
|
|
|
throw;
|
|
}
|
|
|
|
await _dbContext.Updateable<CanteenOrderEntity>()
|
|
.SetColumns(x => x.OrderStatus == CanteenOrderStatusEnumType.Successful)
|
|
.Where(x => x.Id == orderId)
|
|
.ExecuteCommandAsync();
|
|
}
|
|
|
|
|
|
|
|
|
|
//******************************************************* help methods ************************************************************/
|
|
|
|
|
|
/// <summary>
|
|
/// 设备并发更新 需要抛出VersionExceptions
|
|
/// </summary>
|
|
/// <typeparam name="T"></typeparam>
|
|
/// <param name="func"></param>
|
|
/// <param name="retry">并发冲突处理次数</param>
|
|
/// <returns></returns>
|
|
/// <exception cref="UserFriendlyException"></exception>
|
|
private async Task ContinueUpdateAsync(Func<Task> func, int retry)
|
|
{
|
|
for (int i = 0; i < retry; i++)
|
|
{
|
|
try
|
|
{
|
|
await func();
|
|
return;
|
|
}
|
|
catch (Exception ex) when (ex is VersionExceptions)
|
|
{
|
|
_logger.LogWarning(ex, ex.Message);
|
|
}
|
|
catch (Exception)
|
|
{
|
|
throw;
|
|
}
|
|
}
|
|
|
|
throw new UserFriendlyException("操作失败,请重试");
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 获取参数配置
|
|
/// </summary>
|
|
/// <typeparam name="T"></typeparam>
|
|
/// <param name="settings"></param>
|
|
/// <param name="item"></param>
|
|
/// <param name="defaultValue"></param>
|
|
/// <returns></returns>
|
|
private static T GetSetting<T>(Dictionary<CanteenSettingItemEnumType, string> settings, CanteenSettingItemEnumType item, T defaultValue = default)
|
|
{
|
|
if (settings.TryGetValue(item, out var v))
|
|
{
|
|
return v.Adapt<T>();
|
|
}
|
|
|
|
return defaultValue;
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 验证参数
|
|
/// </summary>
|
|
/// <param name="settings"></param>
|
|
/// <param name="shifts"></param>
|
|
/// <param name="costDateTime"></param>
|
|
/// <param name="order"></param>
|
|
/// <returns></returns>
|
|
/// <exception cref="UserFriendlyException"></exception>
|
|
private async Task Verify(Dictionary<CanteenSettingItemEnumType, string> settings, List<CanteenBusinessShiftEntity> shifts, DateTime costDateTime, CanteenOrderEntity order)
|
|
{
|
|
//在线
|
|
if (!order.IsOffline)
|
|
{
|
|
shifts.FirstOrDefault(x => new TimePeriod()
|
|
{
|
|
Start = x.Start,
|
|
End = x.End,
|
|
|
|
}.IsPresent1(costDateTime)).ThrowIfNull("当前非就餐时间,无法消费");
|
|
}
|
|
|
|
var beginOfDay = DateTime.Today;
|
|
var endOfDay = beginOfDay.AddHours(23).AddMinutes(59).AddSeconds(59);
|
|
|
|
var balanceRecords = await _dbContext.Queryable<BalanceRecordEntity>()
|
|
.Where(x => x.UserNo == order.UserNo)
|
|
.Where(x => x.CreateTime >= beginOfDay && x.CreateTime <= endOfDay) //今天消费记录
|
|
.ToListAsync();
|
|
|
|
var dayMarketCostMax = GetSetting<decimal>(settings, CanteenSettingItemEnumType.DayMarketCostMax);
|
|
if (dayMarketCostMax != default)
|
|
{
|
|
var businessPlaceCodes = await _dbContext.Queryable<CanteenBusinessPlaceEntity>()
|
|
.Where(x => x.Catalog == CanteenBusinessPlaceCatalogEnumType.Supermarket)
|
|
.Select(x => x.Code).ToListAsync();
|
|
|
|
var cost = balanceRecords.Where(x => businessPlaceCodes.Contains(x.BusinessPlaceCode.Value)).Sum(x => x.Amount);
|
|
if (cost + Math.Abs(order.Amount) > dayMarketCostMax)
|
|
{
|
|
throw new UserFriendlyException($"超出当天超市消费限制({dayMarketCostMax}),无法消费");
|
|
}
|
|
}
|
|
|
|
var allowRepeatInOneShift = GetSetting(settings, CanteenSettingItemEnumType.AllowRepeatInOneShift, true);
|
|
if (!allowRepeatInOneShift)
|
|
{
|
|
//todo 餐次问题
|
|
var costCount = balanceRecords.Where(x => x.BusinessShiftCode == order.BusinessShiftCode).Count();
|
|
if (costCount > 1)
|
|
{
|
|
throw new UserFriendlyException($"当前餐次不允许多次消费");
|
|
}
|
|
}
|
|
|
|
var onceCostMax = GetSetting<decimal>(settings, CanteenSettingItemEnumType.OnceCostMax);
|
|
if (onceCostMax != default)
|
|
{
|
|
if (Math.Abs(order.Amount) > onceCostMax)
|
|
{
|
|
throw new UserFriendlyException($"一次消费金额不能超出{onceCostMax}");
|
|
}
|
|
}
|
|
|
|
var dayCostMax = GetSetting<decimal>(settings, CanteenSettingItemEnumType.DayCostMax);
|
|
if (dayCostMax != default)
|
|
{
|
|
var cost = balanceRecords.Where(x => x.Type == BalanceRecordTypeEnumType.Out).Sum(x => Math.Abs(x.Amount));
|
|
if (cost + Math.Abs(order.Amount) > dayCostMax)
|
|
{
|
|
throw new UserFriendlyException($"超出当天消费限制({dayCostMax}),无法消费");
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 生成消费记录
|
|
/// </summary>
|
|
/// <param name="orderId"></param>
|
|
/// <returns></returns>
|
|
/// <exception cref="UserFriendlyException"></exception>
|
|
/// <exception cref="VersionExceptions"></exception>
|
|
private async Task GenerateRechargeRecordAsync(long orderId)
|
|
{
|
|
var order = await _dbContext.Queryable<CanteenOrderEntity>().Where(x => x.Id == orderId).FirstAsync();
|
|
|
|
await ContinueUpdateAsync(async () =>
|
|
{
|
|
var canteenUser = await _dbContext.Queryable<CanteenUserEntity>().Where(x => x.UserNo == order.UserNo).FirstAsync();
|
|
//金额+-
|
|
canteenUser.Balance += order.Amount;
|
|
|
|
var effect = await _dbContext.Updateable<CanteenUserEntity>()
|
|
.SetColumns(x => x.Balance == canteenUser.Balance)
|
|
.SetColumns(x => x.Version == x.Version + 1)
|
|
.Where(x => x.UserNo == order.UserNo && x.Version == canteenUser.Version)
|
|
.ExecuteCommandAsync();
|
|
|
|
if (effect <= 0) throw new VersionExceptions("更新版本冲突");
|
|
|
|
//写入记录
|
|
var balanceRecord = order.Adapt<BalanceRecordEntity>();
|
|
await _dbContext.InsertAsync(balanceRecord);
|
|
|
|
}, 5);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 生成充值记录
|
|
/// </summary>
|
|
/// <param name="orderId"></param>
|
|
/// <param name="settings"></param>
|
|
/// <param name="shifts"></param>
|
|
/// <param name="costDateTime"></param>
|
|
/// <returns></returns>
|
|
/// <exception cref="UserFriendlyException"></exception>
|
|
/// <exception cref="VersionExceptions"></exception>
|
|
private async Task GenerateConsumeRecordAsync(long orderId, Dictionary<CanteenSettingItemEnumType, string> settings, List<CanteenBusinessShiftEntity> shifts, DateTime costDateTime)
|
|
{
|
|
var order = await _dbContext.Queryable<CanteenOrderEntity>().Where(x => x.Id == orderId).FirstAsync();
|
|
//校验
|
|
await Verify(settings, shifts, costDateTime, order);
|
|
|
|
await ContinueUpdateAsync(async () =>
|
|
{
|
|
var canteenUser = await _dbContext.Queryable<CanteenUserEntity>().Where(x => x.UserNo == order.UserNo).FirstAsync();
|
|
//金额+-
|
|
canteenUser.Balance += order.Amount;
|
|
if (canteenUser.Balance < 0)
|
|
{
|
|
throw new UserFriendlyException("余额不足,无法消费");
|
|
}
|
|
|
|
var effect = await _dbContext.Updateable<CanteenUserEntity>()
|
|
.SetColumns(x => x.Balance == canteenUser.Balance)
|
|
.SetColumns(x => x.Version == x.Version + 1)
|
|
.Where(x => x.UserNo == order.UserNo && x.Version == canteenUser.Version)//必须与查询时的version一致
|
|
.ExecuteCommandAsync();
|
|
|
|
if (effect <= 0) throw new VersionExceptions("更新版本冲突");
|
|
|
|
//写入记录
|
|
var balanceRecord = order.Adapt<BalanceRecordEntity>();
|
|
await _dbContext.InsertAsync(balanceRecord);
|
|
|
|
}, 5);
|
|
}
|
|
|
|
}
|