From 23e4f986644298cb23ac43173414b7e1404b6657 Mon Sep 17 00:00:00 2001
From: dengjunjie <dengjunjie@hnkhzn.com>
Date: 星期六, 15 六月 2024 17:26:23 +0800
Subject: [PATCH] 任务逻辑优化
---
代码管理/WMS/WMS_Server/WIDESEA_WMS/Services/Taskinfo/Partial/dt_agvtaskService.cs | 61 +++++++++++++++++++++++++++++-
1 files changed, 59 insertions(+), 2 deletions(-)
diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WMS_Server/WIDESEA_WMS/Services/Taskinfo/Partial/dt_agvtaskService.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WMS_Server/WIDESEA_WMS/Services/Taskinfo/Partial/dt_agvtaskService.cs"
index 799c98a..cd823f3 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WMS_Server/WIDESEA_WMS/Services/Taskinfo/Partial/dt_agvtaskService.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WMS_Server/WIDESEA_WMS/Services/Taskinfo/Partial/dt_agvtaskService.cs"
@@ -30,6 +30,7 @@
using WIDESEA_WMS.Common;
using System.Reflection.Emit;
using System.Threading.Tasks;
+using System.Net;
namespace WIDESEA_WMS.Services
{
@@ -50,6 +51,62 @@
//澶氱鎴蜂細鐢ㄥ埌杩檌nit浠ｇ爜锛屽叾浠栨儏鍐靛彲浠ヤ笉鐢�
//base.Init(dbRepository);
}
+ /// <summary>
+ /// 浠诲姟鏆傚仠
+ /// </summary>
+ /// <param name="saveModel"></param>
+ /// <returns></returns>
+ public WebResponseContent PauseTask(SaveModel saveModel)
+ {
+ WebResponseContent response = new WebResponseContent().OK();
+
+ foreach (var Key in saveModel.DelKeys)
+ {
+ try
+ {
+ var task = repository.Find(x => x.agv_id.ToString() == Key.ToString()).FirstOrDefault();
+ if (task.agv_taskstate == AGVTaskStateEnum.Queue.ToString())
+ {
+ task.agv_taskstate = AGVTaskStateEnum.Pause.ToString();
+ repository.Update(task, x => new { x.agv_taskstate }, true);
+ response.OK(response.Message += $"{task.agv_tasknum}鏆傚仠鎴愬姛!");
+ }
+ }
+ catch (Exception ex)
+ {
+ response.Error(response.Message += ex.Message);
+ }
+ }
+ return response;
+ }
+ /// <summary>
+ /// 浠诲姟缁х画
+ /// </summary>
+ /// <param name="saveModel"></param>
+ /// <returns></returns>
+ public WebResponseContent ContinueTask(SaveModel saveModel)
+ {
+ WebResponseContent response = new WebResponseContent().OK();
+
+ foreach (var Key in saveModel.DelKeys)
+ {
+ try
+ {
+ var task = repository.Find(x => x.agv_id.ToString() == Key.ToString()).FirstOrDefault();
+ if (task.agv_taskstate == AGVTaskStateEnum.Pause.ToString())
+ {
+ task.agv_taskstate = AGVTaskStateEnum.Queue.ToString();
+ repository.Update(task, x => new { x.agv_taskstate }, true);
+ response.OK(response.Message += $"{task.agv_tasknum}鎭㈠鎴愬姛!");
+ }
+ }
+ catch (Exception ex)
+ {
+ response.Error(response.Message += ex.Message);
+ }
+ }
+ return response;
+ }
public override WebResponseContent Del(object[] keys, bool delList = true)
{
#region 鎵归噺淇敼璐т綅鐘舵��
@@ -66,7 +123,7 @@
//stationinfoRepository.UpdateRange(stations, x => new { x.location_state }, true);
#endregion
VOLContext volContext = new VOLContext();
- Idt_agvtask_htyRepository agvtask_HtyRepository=new dt_agvtask_htyRepository(volContext);
+ Idt_agvtask_htyRepository agvtask_HtyRepository = new dt_agvtask_htyRepository(volContext);
var agvtasks = repository.Find(x => keys.Contains(x.agv_id)).ToList();
List<dt_agvtask_hty> dt_Agvtask_Hties = new List<dt_agvtask_hty>();
foreach (var task in agvtasks)
@@ -103,7 +160,7 @@
};
dt_Agvtask_Hties.Add(agvtask_Hty);
}
- agvtask_HtyRepository.AddRange(dt_Agvtask_Hties,true);
+ agvtask_HtyRepository.AddRange(dt_Agvtask_Hties, true);
return base.Del(keys, delList);
}
public WebResponseContent addNgTask(MesRequestTemp requestTemp)
--
Gitblit v1.9.3