Add CargoPartner/Truck support, update config and protocol

- Switched DB connection to FruitBank_DEV in appsettings.json
- Added SignalR controller methods for CargoPartner CRUD (placeholders)
- Changed AcBinaryProtocol flush policy to Coalesced
- Registered CustomerCredit, CargoPartner, CargoTruck in NameCompatibility
This commit is contained in:
Loretta 2026-05-28 19:48:33 +02:00
parent 9b2e34f7b5
commit 8020131c0e
3 changed files with 45 additions and 1 deletions

View File

@ -138,6 +138,46 @@ namespace Nop.Plugin.Misc.FruitBankPlugin.Controllers
}
[SignalR(SignalRTags.GetCargoPartners)]
public async Task<List<CargoPartner>> GetCargoPartners()
{
_logger.Detail($"GetCargoPartners invoked");
return [];// await ctx.CargoPartners.GetAll().ToListAsync();
}
[SignalR(SignalRTags.GetCargoPartnerById)]
public async Task<CargoPartner> GetCargoPartnerById(int id)
{
_logger.Detail($"GetCargoPartnerById invoked; id: {id}");
return null;//await ctx.CargoPartners.GetByIdAsync(id);
}
[SignalR(SignalRTags.AddCargoPartner)]
public async Task<CargoPartner> AddCargoPartner(CargoPartner cargoPartner)
{
ArgumentNullException.ThrowIfNull(cargoPartner);
_logger.Detail($"AddCargoPartner invoked; id: {cargoPartner.Id}");
//await ctx.CargoPartners.InsertAsync(cargoPartner);
return null;// await ctx.Partners.GetByIdAsync(cargoPartner.Id, cargoPartner.ShippingDocuments != null);
}
[SignalR(SignalRTags.UpdateCargoPartner)]
public async Task<CargoPartner> UpdateCargoPartner(CargoPartner cargoPartner)
{
ArgumentNullException.ThrowIfNull(cargoPartner);
_logger.Detail($"UpdateCargoPartner invoked; id: {cargoPartner.Id}");
//await ctx.CargoPartners.UpdateAsync(cargoPartner);
return null;//await ctx.CargoPartners.GetByIdAsync(cargoPartner.Id, cargoPartner.ShippingDocuments != null);
}
[SignalR(SignalRTags.GetShippings)]
public async Task<List<Shipping>> GetShippings()
{

View File

@ -184,7 +184,7 @@ public class PluginNopStartup : INopStartup
.AddAcBinaryProtocol(opts =>
{
opts.ProtocolMode = BinaryProtocolMode.AsyncSegment;
opts.FlushPolicy = FlushPolicy.DoubleBuffered;
opts.FlushPolicy = FlushPolicy.Coalesced;
// Explicit AcLogger instance (name-based category, matches the previous setup).
// If omitted, the options extension falls back to ILogger<AcBinaryHubProtocol> from DI.

View File

@ -42,9 +42,13 @@ public partial class NameCompatibility : INameCompatibility
{ typeof(StockTaking), FruitBankConstClient.StockTakingDbTableName},
{ typeof(StockTakingItem), FruitBankConstClient.StockTakingItemDbTableName},
{ typeof(StockTakingItemPallet), FruitBankConstClient.StockTakingItemPalletDbTableName},
{ typeof(CustomerCredit), FruitBankConstClient.CustomerCreditDbTableName},
{ typeof(Preorder), FruitBankConstClient.PreOrderDbTableName},
{ typeof(PreorderItem), FruitBankConstClient.PreOrderItemDbTableName},
{ typeof(CargoPartner), FruitBankConstClient.CargoPartnerDbTableName},
{ typeof(CargoTruck), FruitBankConstClient.CargoTruckDbTableName},
};