fix

WCS.WorkEngineering/Systems/NoInteractionSystems.cs

@@ -50,11 +50,9 @@ namespace WCS.WorkEngineering.Systems
                             Station = task.WorkBench,
                             AddWho = "WCS"
                         }).SplitTable().ExecuteCommand();
-                        db.Default.Updateable(task).AddQueue();
+                        db.Default.Updateable(task).ExecuteCommand();
                     });
                 }
-
-                db.Default.SaveQueues();
             });
 
             #endregion 处理所有的新增入库任务
@@ -103,11 +101,9 @@ namespace WCS.WorkEngineering.Systems
                         //task.AddrNext = path[2];
                         task.Status = Entity.TaskStatus.WaitingToExecute;
                         task.AddWCS_TASK_DTL(db, task.Device, $"初始化出库任务信息,放货站台:{task.SrmStation}");
-                        db.Default.Updateable(task).AddQueue();
+                        db.Default.Updateable(task).ExecuteCommand();
                     });
                 }
-
-                db.Default.SaveQueues();
             });
 
             #endregion 处理所有新建出库任务
@@ -135,11 +131,9 @@ namespace WCS.WorkEngineering.Systems
                             Station = task.WorkBench,
                             AddWho = "WCS"
                         }).SplitTable().ExecuteCommand();
-                        db.Default.Updateable(task).AddQueue();
+                        db.Default.Updateable(task).ExecuteCommand();
                     });
                 }
-
-                db.Default.SaveQueues();
             });
 
             #endregion 处理所有的搬运任务
@@ -167,7 +161,7 @@ namespace WCS.WorkEngineering.Systems
                             db.Default.Updateable(agv).SplitTable().ExecuteCommand();
                             wcs.Status = Entity.TaskStatus.AGVExecution;
                             wcs.AddWCS_TASK_DTL(db, wcs.Device, $"任务下发至AGV,AGV任务号:{res.data}");
-                            db.Default.Updateable(wcs).AddQueue();
+                            db.Default.Updateable(wcs).ExecuteCommand();
                         }
                         catch (Exception ex)
                         {
@@ -176,8 +170,6 @@ namespace WCS.WorkEngineering.Systems
                         }
                     }
                 }
-
-                db.Default.SaveQueues();
             });
 
             #endregion 下发入库AGV任务
@@ -205,7 +197,7 @@ namespace WCS.WorkEngineering.Systems
                             db.Default.Updateable(agv).SplitTable().ExecuteCommand();
                             wcs.Status = Entity.TaskStatus.AGVExecution;
                             wcs.AddWCS_TASK_DTL(db, wcs.Device, $"任务下发至AGV,AGV任务号:{res.data}");
-                            db.Default.Updateable(wcs).AddQueue();
+                            db.Default.Updateable(wcs).ExecuteCommand();
                         }
                         catch (Exception ex)
                         {
@@ -214,8 +206,6 @@ namespace WCS.WorkEngineering.Systems
                         }
                     }
                 }
-
-                db.Default.SaveQueues();
             });
 
             #endregion 移动任务处理