修改任务

ds-wms-service/DS.WMS.Core/TaskPlat/Method/POLContainerNotPickUp/TaskPOLContainerNotPickUpService.cs

@@ -352,8 +352,13 @@ namespace DS.WMS.Core.TaskPlat.Method
         /// <returns>返回回执</returns>
         public async Task<DataResult<TaskTransferMsgDto>> SendEmailToCustomerTask(TaskFlowDataContext dataContext)
         {
-            var taskPKId = dataContext.Get<Nullable<long>>(TaskFlowDataNameConst.TaskPKId) ?? throw new ArgumentException($"缺少参数:{nameof(TaskFlowDataNameConst.TaskPKId)}");
-            var businessTaskMailId = dataContext.Get<Nullable<long>>($"{nameof(BusinessTaskMail)}.{nameof(BusinessTaskMail.Id)}") ?? throw new ArgumentException();
+            var taskPKId = dataContext.Get<long>(TaskFlowDataNameConst.TaskPKId);
+            if (taskPKId == 0)
+                throw new ArgumentException($"缺少参数:{nameof(TaskFlowDataNameConst.TaskPKId)}");
+
+            var businessTaskMailId = dataContext.Get<long>($"{nameof(BusinessTaskMail)}.{nameof(BusinessTaskMail.Id)}");
+            if (businessTaskMailId == 0)
+                throw new ArgumentException($"缺少参数:{nameof(BusinessTaskMail)}.{nameof(BusinessTaskMail.Id)}");
 
             if (businessTaskMailId == 0)
             {

ds-wms-service/DS.WMS.Core/TaskPlat/Method/TaskManageService.cs

@@ -1594,11 +1594,14 @@ namespace DS.WMS.Core.TaskPlat.Method
 
                     await tenantDb.Insertable(taskPOLContainerNotPickUpInfo).ExecuteCommandAsync();
 
-                    ////触发推送消息
-                    //var name = _namedTaskPOLContainerNotPickUpServiceProvider
-                    //    .GetService<ITransient>(nameof(TaskPOLContainerNotPickUpService));
+                    //出发任务流程
+                    TaskFlowDataContext dataContext = new(
+                        // 固定
+                        (TaskFlowDataNameConst.TaskPKId, taskInfo.Id)
+                    );
 
-                    //await name.AutoTransferNotice(taskInfo.PK_ID);
+                    TaskFlowRuner taskFlow = new TaskFlowRuner(tenantDb, serviceProvider);
+                    await taskFlow.Run(info.Main.TaskType, taskInfo.Id, dataContext);
                 }
                 #endregion