触发自动订舱

ds-wms-service/DS.WMS.Core/Op/Interface/TaskInteraction/IActionManagerService.cs

@@ -70,10 +70,17 @@ namespace DS.WMS.Core.Op.Interface.TaskInteraction
         /// <returns></returns>
         Task TriggerActionAsync(BusinessTask businessTask, bool includeOrder = false, IDictionary<string, object>? additionalData = null);
 
-
         /// <summary>
         /// 执行放舱任务（任务台使用）
         /// </summary>
         Task SpaceReleaseTask(TaskFlowDataContext dataContext);
+
+        /// <summary>
+        /// 自动订舱
+        /// </summary>
+        /// <param name="businessId">业务ID</param>
+        /// <param name="businessType">业务类型</param>
+        /// <returns></returns>
+        Task<DataResult> AutomaticBooking(long businessId, BusinessType businessType);
     }
 }

ds-wms-service/DS.WMS.Core/Op/Method/TaskInteraction/ActionManagerService.cs

@@ -7,6 +7,7 @@ using DS.WMS.Core.Op.Dtos.TaskInteraction;
 using DS.WMS.Core.Op.Entity;
 using DS.WMS.Core.Op.Entity.TaskInteraction;
 using DS.WMS.Core.Op.Interface.TaskInteraction;
+using DS.WMS.Core.Op.Method.TaskInteraction.ActionSelector;
 using DS.WMS.Core.TaskPlat;
 using Fasterflect;
 using Masuit.Tools;
@@ -234,6 +235,37 @@ namespace DS.WMS.Core.Op.Method.TaskInteraction
             await taskFlow.RunWithBsno(businessTask.TaskType, businessTask.BusinessId, dataContext);
         }
 
+        /// <summary>
+        /// 自动订舱
+        /// </summary>
+        /// <param name="businessId">业务ID</param>
+        /// <param name="businessType">业务类型</param>
+        /// <returns></returns>
+        public async Task<DataResult> AutomaticBooking(long businessId, BusinessType businessType)
+        {
+            try
+            {
+                var businessTask = await TenantDb.Queryable<BusinessTask>().Where(
+                x => x.BusinessId == businessId && x.BusinessType == businessType && x.TaskType == TaskBaseTypeEnum.WAIT_BOOKING).FirstAsync();
+                if (businessTask == null)
+                    return DataResult.FailedWithDesc(MultiLanguageConst.TaskStatusNotSupported);
+
+                TaskFlowDataContext dataContext = new
+                (
+                    (TaskFlowDataNameConst.BusinessTask, businessTask),
+                    ("TypeName", typeof(BookingSelector).AssemblyQualifiedName)
+                );
+
+                await ExecuteAsync(dataContext);
+                return DataResult.Success;
+            }
+            catch (Exception ex)
+            {
+                await ex.LogAsync(Db);
+                return DataResult.FailedWithDesc(MultiLanguageConst.Operation_Failed);
+            }
+        }
+
         /// <summary>
         /// 执行动作
         /// </summary>
@@ -250,7 +282,6 @@ namespace DS.WMS.Core.Op.Method.TaskInteraction
                 ServiceProvider = ServiceProvider
             };
 
-
             foreach (var key in dataContext.Keys)
                 context.AdditionalData[key] = dataContext[key];
 

ds-wms-service/DS.WMS.Core/Op/Method/TaskInteraction/ActionSelector/BookingSelector.cs

@@ -1,4 +1,5 @@
-using DS.WMS.Core.Info.Interface;
+using DS.Module.Core;
+using DS.WMS.Core.Info.Interface;
 using DS.WMS.Core.Op.Dtos.TaskInteraction;
 using DS.WMS.Core.Op.Entity;
 using DS.WMS.Core.Op.Interface.TaskInteraction;
@@ -18,10 +19,15 @@ namespace DS.WMS.Core.Op.Method.TaskInteraction.ActionSelector
 
         public async Task<IActionExecutor> GetActionExecutor(ActionExecutionContext context)
         {
+            //var taskService = context.ServiceProvider.GetRequiredService<ITaskService>();
+            //var list = await taskService.GetTasks(context.TaskInfo.BusinessId, context.TaskInfo.BusinessType, TaskBaseTypeEnum.WAIT_BOOKING);
+            //if (list.Data?.Count > 0 && list.Data?[0].TaskStatus == TaskStatusEnum.Complete)
+            //    return new DefaultActionExecutor();
+
             switch (context.TaskInfo.BusinessType)
             {
                 case BusinessType.OceanShippingExport:
-                    var seTaskService = context.ServiceProvider.GetService<ISeaExportTaskService>();
+                    var seTaskService = context.ServiceProvider.GetRequiredService<ISeaExportTaskService>();
                     var order = await seTaskService.AsQueryable(x => x.Id == context.TaskInfo.BusinessId).Select(x => new
                     {
                         x.BookingNo,

ds-wms-service/DS.WMS.Core/Op/Method/TaskInteraction/TaskService.cs

@@ -99,7 +99,6 @@ namespace DS.WMS.Core.Op.Method.TaskInteraction
             TenantDb.QueryFilter.Clear<IOrgId>();
         }
 
-
         /// <summary>
         /// 创建关联任务
         /// </summary>
@@ -661,8 +660,10 @@ namespace DS.WMS.Core.Op.Method.TaskInteraction
         public virtual async Task UpdateBusinessAsync(FlowCallback callback)
         {
             ArgumentNullException.ThrowIfNull(callback, nameof(callback));
+            if (callback.Type == null || callback.BusinessType == null)
+                return;
 
-            var taskType = TypeMappings.Where(x => x.Value == callback.Type.GetValueOrDefault()).Select(x => x.Key).FirstOrDefault();
+            var taskType = TypeMappings.Where(x => x.Value == callback.Type.Value).Select(x => x.Key).FirstOrDefault();
             var req = new TaskUpdateRequest
             {
                 BusinessId = callback.BusinessId,

ds-wms-service/DS.WMS.OpApi/Controllers/SeaExportTaskController.cs

@@ -1,5 +1,6 @@
 using System.Net;
 using DS.Module.Core;
+using DS.WMS.Core;
 using DS.WMS.Core.Flow.Dtos;
 using DS.WMS.Core.Op.Dtos.TaskInteraction;
 using DS.WMS.Core.Op.Entity;
@@ -58,6 +59,19 @@ namespace DS.WMS.OpApi.Controllers
             return await logService.ReadLogAsync(businessId, businessType);
         }
 
+        /// <summary>
+        /// 触发自动订舱
+        /// </summary>
+        /// <param name="actionService"></param>
+        /// <param name="businessId">业务ID</param>
+        /// <param name="businessType">业务类型(可空，默认=海运出口)</param>
+        /// <returns></returns>
+        public async Task<DataResult> AutomaticBooking([FromServices] IActionManagerService actionService,
+             [FromQuery] long businessId, [FromQuery] BusinessType businessType = BusinessType.OceanShippingExport)
+        {
+            return await actionService.AutomaticBooking(businessId, businessType);
+        }
+
         /// <summary>
         /// 创建关联任务
         /// </summary>