diff --git a/Src/Dlhis.Canteen/Order/Services/Implements/OrderService.cs b/Src/Dlhis.Canteen/Order/Services/Implements/OrderService.cs index 4510a555..85a4bea7 100644 --- a/Src/Dlhis.Canteen/Order/Services/Implements/OrderService.cs +++ b/Src/Dlhis.Canteen/Order/Services/Implements/OrderService.cs @@ -37,6 +37,7 @@ public class OrderService : IOrderService private readonly IOrderCommonHandler _orderCommonHandler; private readonly INamedResolver _namedResolver; private readonly ILogger _logger; + private readonly bool _enableConsumeVerify; public OrderService(ICanteenSettingService canteenSettingService, IDbContext dbContext, @@ -47,6 +48,7 @@ public class OrderService : IOrderService IGainfoPermissionApi gainfoPermissionApi, IOrderCommonHandler orderCommonHandler, INamedResolver namedResolver, + IConfiguration configuration, ILogger logger) { _canteenSettingService = canteenSettingService; @@ -58,6 +60,7 @@ public class OrderService : IOrderService _gainfoPermissionApi = gainfoPermissionApi; _orderCommonHandler = orderCommonHandler; _namedResolver = namedResolver; + _enableConsumeVerify = configuration.GetValue("Canteen:EnableConsumeVerify", false); _logger = logger; } @@ -394,8 +397,11 @@ public class OrderService : IOrderService await _orderCommonHandler.TryConsumeAsync(order.Id, async () => { - //校验 todo - //await Verify(order); + if (_enableConsumeVerify) + { + await Verify(order); + } + await _balanceRepository.ConsumeBalanceAsync(order.UserCode, order.Amount); //写入记录 @@ -524,4 +530,4 @@ public class OrderService : IOrderService //存在在线order数据,但是状态未成功 return !order.IsOffline && order.OrderStatus != CanteenOrderStatusEnumType.Success; } -} \ No newline at end of file +} diff --git a/Src/Dlhis.Canteen/appsettings.json b/Src/Dlhis.Canteen/appsettings.json index cfc8b763..51018a30 100644 --- a/Src/Dlhis.Canteen/appsettings.json +++ b/Src/Dlhis.Canteen/appsettings.json @@ -6,6 +6,9 @@ } }, "AllowedHosts": "*", + "Canteen": { + "EnableConsumeVerify": false + }, "InternalRequest": { "CommonRequestUrl": "http://common", "BasicRequestUrl": "http://basic",