diff --git a/Myshipping.Application/Service/BookingOrder/IBookingOrderService.cs b/Myshipping.Application/Service/BookingOrder/IBookingOrderService.cs index d75eb449..b297fd38 100644 --- a/Myshipping.Application/Service/BookingOrder/IBookingOrderService.cs +++ b/Myshipping.Application/Service/BookingOrder/IBookingOrderService.cs @@ -45,5 +45,7 @@ namespace Myshipping.Application Task BachUpdate(BatchUpdate dto); Task InnerBookingOrClosingEDI(BookingOrClosingEDIOrderDto model); + + Task SendBookingOrder(long[] ids); } } \ No newline at end of file diff --git a/Myshipping.Application/Service/DataSync/DataSyncService.cs b/Myshipping.Application/Service/DataSync/DataSyncService.cs index 8696244d..d4281e17 100644 --- a/Myshipping.Application/Service/DataSync/DataSyncService.cs +++ b/Myshipping.Application/Service/DataSync/DataSyncService.cs @@ -68,7 +68,7 @@ namespace Myshipping.Application private readonly SqlSugarRepository _codeForwarder; private readonly SqlSugarRepository _bookingfile; private readonly SqlSugarRepository _accountconfig; - + private readonly IBookingOrderService _bookingorderservice; public DataSyncService(ILogger logger, ISysCacheService cache, SqlSugarRepository rep, SqlSugarRepository repCtn, @@ -78,7 +78,7 @@ namespace Myshipping.Application SqlSugarRepository goodsStatus, SqlSugarRepository goodsStatusConfig, SqlSugarRepository repline, SqlSugarRepository bookingremark, SqlSugarRepository mapcarrier, SqlSugarRepository codeForwarder, SqlSugarRepository codePortRep, SqlSugarRepository codeLaneRep, ICommonDBService commonDBService, SqlSugarRepository relaPortLane, - SqlSugarRepository accountconfig, SqlSugarRepository bookingfile) + SqlSugarRepository accountconfig, SqlSugarRepository bookingfile, IBookingOrderService bookingorderservice) { this._logger = logger; this._rep = rep; @@ -105,6 +105,7 @@ namespace Myshipping.Application this._codeForwarder = codeForwarder; this._accountconfig = accountconfig; this._bookingfile = bookingfile; + this._bookingorderservice = bookingorderservice; } @@ -1762,6 +1763,7 @@ namespace Myshipping.Application await _rep.AsUpdateable(it).IgnoreColumns().ExecuteCommandAsync(); } + await _bookingorderservice.SendBookingOrder(order.Select(x => x.Id).ToArray()); }