Agv任务状态返回，出发预任务执行函数

WarehouseMgr/Tnb.WarehouseMgr/DeviceProviderService.cs

@@ -218,7 +218,7 @@ namespace Tnb.WarehouseMgr
             try
             {
                 Logger.Information($"任务链编号：{input.taskChainCode},状态：{input.status},设备ID：{input.deviceID}");
-                switch (input.status)
+                /*switch (input.status)
                 {
                     case "CREATED": break;
                     case "ALLOCATED": break;
@@ -242,9 +242,23 @@ namespace Tnb.WarehouseMgr
                     case "FAILURE": break;
                     case "FINISHED": break;
                     default: break;
+                }*/
+
+
+                if (input.taskChainCode.Trim().IsNullOrEmpty())
+                {
+                    return await ToApiResult(HttpStatusCode.InternalServerError, "请重试！");
                 }
-                //写入redis 
-                //await _cacheManager.SetAsync($"{input.taskChainCode}", $"任务链状态上报,上报状态{input.status}");
+
+                List<WmsDistaskH> disTasks = await _db.Queryable<WmsDistaskH>().Where(it => it.bill_code.Contains(input.taskChainCode)).ToListAsync();
+                List<EqpEquipment> eps = await _db.Queryable<EqpEquipment>().Where(it => it.code.Contains(input.deviceID)).ToListAsync();
+                TaskExecuteUpInput taskExecuteUpInput = new()
+                {
+                    disTaskIds = disTasks.Select(x => x.id).ToList(),
+                    EqpIds = eps.Select(x => x.id).ToList(),
+                };
+                await _wareHouseService.TaskExecute(taskExecuteUpInput);
+
                 ConnectionConfigOptions opts = App.GetOptions<ConnectionConfigOptions>();
                 UserAgent userAgent = new(App.HttpContext);
                 //写系统日志
@@ -321,6 +335,10 @@ namespace Tnb.WarehouseMgr
                 return await ToApiResult(HttpStatusCode.InternalServerError, "请重试！");
                 throw;
             }
+            finally
+            {
+                _ = InvokeGenPretaskExcute();
+            }
             return await ToApiResult(HttpStatusCode.OK, "成功");
         }