Adam
/
Mango.Nop.Plugins
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Implement OrderItemMeasuringReset to MeasurementService

This commit is contained in:
Loretta 2025-11-03 06:44:45 +01:00
parent f048b999cf
commit 5fad900897
2 changed files with 56 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
Nop.Plugin.Misc.AIPlugin/Domains/DataLayer/FruitBankDbContext.cs
View File

@ -460,6 +460,22 @@ public class FruitBankDbContext : MgDbContextBase,
return orderDto;
}
public async Task<bool> SetOrderStatusToPendingSafeAsync(Order order)
=> await TransactionSafeAsync(async _ => await SetOrderStatusToPendingAsync(order));
public async Task<bool> SetOrderStatusToPendingAsync(Order order)
{
if (order.OrderStatus == OrderStatus.Pending) return true;
var prevOrderStatus = order.OrderStatus;
order.OrderStatus = OrderStatus.Pending;
await Orders.UpdateAsync(order, false);
await _eventPublisher.PublishAsync(new OrderStatusChangedEvent(order, prevOrderStatus));
return true;
}
public Task DeleteOrderItemConstraintsSafeAsync(OrderItem orderItem, bool publishEvent = false)
{
return TransactionSafeAsync(async _ =>

43
Nop.Plugin.Misc.AIPlugin/Services/MeasurementService.cs
View File

@ -1,5 +1,7 @@
using AyCode.Core.Loggers;
using AyCode.Services.Server.SignalRs;
using FruitBank.Common.Dtos;
using FruitBank.Common.Entities;
using FruitBank.Common.Interfaces;
using FruitBank.Common.Server.Services.SignalRs;
using FruitBank.Common.Services;
@ -7,8 +9,10 @@ using Mango.Nop.Core.Extensions;
using Mango.Nop.Core.Loggers;
using Nop.Core.Domain.Catalog;
using Nop.Core.Domain.Orders;
using Nop.Core.Events;
using Nop.Plugin.Misc.FruitBankPlugin.Domains.DataLayer;
using Nop.Services.Catalog;
using Nop.Services.Events;
namespace Nop.Plugin.Misc.FruitBankPlugin.Services;
@ -16,18 +20,20 @@ namespace Nop.Plugin.Misc.FruitBankPlugin.Services;
public class MeasurementService : MeasurementServiceBase<Logger>, IMeasurementService
{
private readonly FruitBankDbContext _dbContext;
private readonly IEventPublisher _eventPublisher;
private readonly SignalRSendToClientService _signalRSendToClientService;
private readonly CustomPriceCalculationService _customPriceCalculationService;
public MeasurementService(FruitBankDbContext dbContext, SignalRSendToClientService signalRSendToClientService, FruitBankAttributeService fruitBankAttributeService,
IPriceCalculationService customPriceCalculationService, IEnumerable<IAcLogWriterBase> logWriters) : base(new Logger<MeasurementService>(logWriters.ToArray()))
public MeasurementService(FruitBankDbContext dbContext, SignalRSendToClientService signalRSendToClientService, FruitBankAttributeService fruitBankAttributeService,
IPriceCalculationService customPriceCalculationService, IEventPublisher eventPublisher, IEnumerable<IAcLogWriterBase> logWriters) : base(new Logger<MeasurementService>(logWriters.ToArray()))
{
_dbContext = dbContext;
_eventPublisher = eventPublisher;
_signalRSendToClientService = signalRSendToClientService;
_customPriceCalculationService = (CustomPriceCalculationService)customPriceCalculationService;
}
public async Task DeleteOrderItemConstraintsAsync(int orderItemId) => await DeleteOrderItemConstraintsAsync(await _dbContext.OrderItems.GetByIdAsync(orderItemId));
public async Task DeleteOrderItemConstraintsAsync(OrderItem orderItem)
@ -56,4 +62,35 @@ public class MeasurementService : MeasurementServiceBase<Logger>, IMeasurementSe
await _customPriceCalculationService.CheckAndUpdateOrderTotalPrice(order);
}
}
public async Task<bool> OrderItemMeasuringReset(int orderItemId)
=> await OrderItemMeasuringReset(await _dbContext.OrderItems.GetByIdAsync(orderItemId));
public async Task<bool> OrderItemMeasuringReset(OrderItem orderItem)
{
var order = await _dbContext.Orders.GetByIdAsync(orderItem.OrderId);
var orderItemPallets = await _dbContext.OrderItemPallets.GetAllByOrderItemId(orderItem.Id, false).ToListAsync();
var result = await _dbContext.TransactionSafeAsync(async _ =>
{
foreach (var orderItemPallet in orderItemPallets)
{
orderItemPallet.RevisorId = 0;
await _dbContext.OrderItemPallets.UpdateAsync(orderItemPallet);
}
if (order.OrderStatus == OrderStatus.Complete)
await _dbContext.SetOrderStatusToPendingAsync(order);
return true;
});
if (!result) return result;
foreach (var orderItemPallet in orderItemPallets)
await _signalRSendToClientService.SendOrderItemPalletChanged(orderItemPallet);
await _signalRSendToClientService.SendOrderChanged(await _dbContext.OrderDtos.GetByIdAsync(orderItem.OrderId, true));
return result;
}
}