订舱完成推送cargoo逻辑补充

ds-wms-service/DS.WMS.Core/TaskInteraction/Method/ActionExecutor/Booking/EDIActionExecutor.cs

@@ -1,5 +1,6 @@
 using DS.Module.Core;
 using DS.WMS.Core.Op.Dtos;
+using DS.WMS.Core.Op.Dtos.Cargoo;
 using DS.WMS.Core.Op.Interface;
 using DS.WMS.Core.TaskInteraction.Dtos;
 using Microsoft.Extensions.DependencyInjection;
@@ -49,6 +50,14 @@ namespace DS.WMS.Core.TaskInteraction.Method.ActionExecutor.Booking
             var task = context.TaskInfo;
             task.TaskType = TaskBaseTypeEnum.WAIT_BOOKING;
             await SetTaskCompleteAsync(task, TaskService, LogService);
+
+            // 订舱完成推送Cargoo
+            var cargooService = context.ServiceProvider.GetRequiredService<ICargooService>();
+            await cargooService.SendCargoo(new CargooShipmentReqDto()
+            {
+                bookingId = task.BusinessId,
+                cargooStatusEnum = CargooStatusEnum.Confirmed
+            });
         }
     }
 }

ds-wms-service/DS.WMS.Core/TaskInteraction/Method/ActionExecutor/Booking/MailActionExecutor.cs

@@ -1,4 +1,6 @@
 using DS.Module.Core;
+using DS.WMS.Core.Op.Dtos.Cargoo;
+using DS.WMS.Core.Op.Interface;
 using DS.WMS.Core.TaskInteraction.Dtos;
 using DS.WMS.Core.TaskInteraction.Entity;
 using DS.WMS.Core.TaskInteraction.Interface;
@@ -77,6 +79,14 @@ namespace DS.WMS.Core.TaskInteraction.Method.ActionExecutor.Booking
             var task = context.TaskInfo;
             task.TaskType = TaskBaseTypeEnum.WAIT_BOOKING;
             await SetTaskCompleteAsync(task, TaskService, LogService);
+
+            // 订舱完成推送Cargoo
+            var cargooService = context.ServiceProvider.GetRequiredService<ICargooService>();
+            await cargooService.SendCargoo(new CargooShipmentReqDto()
+            {
+                bookingId = task.BusinessId,
+                cargooStatusEnum = CargooStatusEnum.Confirmed
+            });
         }
 
     }