添加任务暂停，恢复任务功能

dengjunjie

2024-05-27 4c176e55bf38acd7408fadfc7dab90591dbf2bd0

 ´úÂë¹ÜÀí/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 @@
            //多租户会用到这init代码，其他情况可以不用
            //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)