资料，优化程序

huanghongfeng

2025-01-24 829eabf256e29392ca63f6da48829dba3b075dfe

 ´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs

@@ -20,6 +20,7 @@
using NetTaste;
using Newtonsoft.Json;
using OfficeOpenXml.FormulaParsing.Excel.Functions.DateTime;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using SqlSugar;
using System;
@@ -31,20 +32,24 @@
using System.Linq.Expressions;
using System.Reflection;
using System.Reflection.Metadata;
using System.Security.Policy;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_Comm.Http;
using WIDESEA_Common.Log;
using WIDESEAWCS_Common.TaskEnum;
using WIDESEAWCS_Core;
using WIDESEAWCS_Core.BaseServices;
using WIDESEAWCS_Core.Enums;
using WIDESEAWCS_Core.Utilities;
using WIDESEAWCS_DTO.Enum;
using WIDESEAWCS_DTO.TaskInfo;
using WIDESEAWCS_ITaskInfoRepository;
using WIDESEAWCS_ITaskInfoService;
using WIDESEAWCS_Model.Models;
using WIDESEAWCS_QuartzJob;
using WIDESEAWCS_QuartzJob.Models;
using WIDESEAWCS_QuartzJob.Service;
using static Microsoft.IO.RecyclableMemoryStreamManager;

namespace WIDESEAWCS_TaskInfoService
{
@@ -78,12 +83,18 @@
        }

        public string urlWMSTask = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlWMSTask"];
        public string urlTaskCompleted = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlTaskCompleted"];
        public string urlWMSMovelibraryTask = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlWMSMovelibraryTask"];
        public string urlQueryinventory = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlQueryinventory"];
        public string urlEmptyOutbound = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlEmptyOutbound"];
        public string urlRawmaterialout = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlRawmaterialout"];
        public string urlPalletQueryinventory = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlPalletQueryinventory"];
        /// <summary>
        /// æŽ¥æ”¶WMS任务信息
        /// </summary>
        /// <param name="taskDTOs">WMS任务对象集合</param>
        /// <returns>返回处理结果</returns>
        public WebResponseContent ReceiveWMSTask([NotNull]List<WMSTaskDTO> taskDTOs)
        public WebResponseContent ReceiveWMSTask([NotNull]List<Dt_Task> taskDTOs)
        {
            WebResponseContent content = new WebResponseContent();
            try
@@ -96,52 +107,10 @@
                        continue;
                    }
                    Dt_Task task = _mapper.Map<Dt_Task>(item);
                    task.Creater = "WMS";
                    if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)
                    {
                        task.TaskNum = item.TaskNum;
                        task.TaskType = item.TaskType;
                        task.TaskState = (int)TaskOutStatusEnum.OutNew;
                        task.SourceAddress = item.SourceAddress;
                        task.TargetAddress = item.TargetAddress;
                        task.PalletCode = item.PalletCode;
                        task.Roadway = item.RoadWay;
                        task.CreateDate = DateTime.Now;
                        task.Grade = 1;
                        task.CurrentAddress = item.SourceAddress;
                        task.NextAddress = item.TargetAddress;
                        task.ModifyDate = DateTime.Now;
                    }
                    else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup)
                    {
                        task.TaskNum = item.TaskNum;
                        task.TaskType = item.TaskType;
                        task.TaskState = (int)TaskInStatusEnum.Line_InFinish;
                        task.SourceAddress = item.SourceAddress;
                        task.TargetAddress = item.TargetAddress;
                        task.PalletCode = item.PalletCode;
                        task.Roadway = item.RoadWay;
                        task.CreateDate = DateTime.Now;
                        task.Grade = 1;
                        task.CurrentAddress = item.SourceAddress;
                        task.NextAddress = item.TargetAddress;
                        task.ModifyDate = DateTime.Now;
                    }else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.RelocationGroup)
                    {
                        task.TaskNum = item.TaskNum;
                        task.TaskType = item.TaskType;
                        task.TaskState = (int)TaskOutStatusEnum.OutNew;
                        task.SourceAddress = item.SourceAddress;
                        task.TargetAddress = item.TargetAddress;
                        task.PalletCode = item.PalletCode;
                        task.Roadway = item.RoadWay;
                        task.CreateDate = DateTime.Now;
                        task.Grade = 1;
                        task.CurrentAddress = item.SourceAddress;
                        task.NextAddress = item.TargetAddress;
                        task.ModifyDate = DateTime.Now;
                    }
                        tasks.Add(task);
                    task.TaskState = (int)TaskOutStatusEnum.OutNew;
                    task.Roadway = task.Roadway == "1" ? task.Roadway = "SC01" : task.Roadway = "SC02";
                    task.CreateDate = DateTime.Now;
                    tasks.Add(task);
                }
                BaseDal.AddData(tasks);
                _taskExecuteDetailService.AddTaskExecuteDetail(tasks.Select(x => x.TaskNum).ToList(), "接收WMS任务");
@@ -151,6 +120,10 @@
            {
                content = WebResponseContent.Instance.Error($"任务接收错误,错误信息:{ex.Message}");
            }
            finally
            {
                WriteLog.GetLog("接收任务").Write(JsonConvert.SerializeObject(content), "接收任务");
            }
            return content;
        }

@@ -160,39 +133,88 @@
        /// <param name="palletCode">托盘号</param>
        /// <param name="sourceAddress">起始地址</param>
        /// <returns></returns>
        public class GenerateInv
        {
            public string SourceAddress { get; set; }
            public string PalletCode { get; set; }
        }

        public class GenerateInv3
        {
            
            public string PalletCode { get; set; }
            public int outCount { get; set; }
            public string TargetAddress { get; set; }
        }
        public WebResponseContent RequestWMSTask(string palletCode, string sourceAddress)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {

                /*WMSTaskDTO taskDTO = new WMSTaskDTO()
                GenerateInv generate = new GenerateInv()
                {
                    TaskNum = Convert.ToInt32(DateTime.Now.ToString("HHmmss")),
                    Grade = 1,
                    PalletCode = palletCode,
                    SourceAddress = sourceAddress,
                    SourceAddress=sourceAddress,
                    PalletCode = palletCode
                };
                var response = HttpHelper.Post<WebResponseContent>(urlWMSTask, taskDTO, "生成任务");*/
                WMSTaskDTO taskDTO = new WMSTaskDTO()
                content = HttpHelper.Post<WebResponseContent>($"{urlWMSTask}", generate);
                Dt_Task task = new Dt_Task();
                if (content != null)
                {
                    TaskNum = Convert.ToInt32(DateTime.Now.ToString("HHmmss")),
                    Grade = 1,
                    PalletCode = palletCode,
                    RoadWay = "SC01",
                    SourceAddress = sourceAddress,
                    TargetAddress = "SC01",
                    TaskState = (int)TaskInStatusEnum.InNew,
                    Id = 0,
                    TaskType = (int)TaskInboundTypeEnum.Inbound
                };
                
                    if (content.Status)
                    {
                        task = JsonConvert.DeserializeObject<Dt_Task>(content.Data.ToString());
                        task.TaskState = (int)TaskInStatusEnum.Line_InFinish;
                        task.Roadway = task.Roadway == "1" ? task.Roadway = "SC01" : task.Roadway = "SC02";
                        BaseDal.AddData(task);
                        return content = WebResponseContent.Instance.Error();
                    }
                }
                return content = WebResponseContent.Instance.Error();
            }
            catch (Exception ex)
            {
                content = WebResponseContent.Instance.Error(ex.Message);
                return content = WebResponseContent.Instance.Error(ex.Message);
            }
            return content;
        }
        /// <summary>
        /// è¿›è¡Œç»„盘
        /// </summary>
        /// <param name="palletCode"></param>
        /// <returns></returns>
        public WebResponseContent ToPlatform(string palletCode)
        {
            try
            {
                WebResponseContent content = new WebResponseContent();
                GenerateInv generate = new GenerateInv()
                {
                    SourceAddress = "",
                    PalletCode = palletCode
                };

                return content = HttpHelper.Post<WebResponseContent>($"{urlQueryinventory}", generate);
            }
            catch (Exception ex)
            {

                throw;
            }

            /*WebResponseContent content = new WebResponseContent();
            GenerateInv generate = new GenerateInv()
            {
                SourceAddress = "",
                PalletCode = palletCode
            };
            content = HttpHelper.Post<WebResponseContent>($"{urlQueryinventory}", generate);
            if (content != null)
            {
                if (content.Status)
                {
                    return content;
                }
            }
            return content = WebResponseContent.Instance.Error();*/
        }

        /// <summary>
@@ -201,33 +223,138 @@
        /// <param name="palletCode">托盘号</param>
        /// <param name="sourceAddress">起始地址</param>
        /// <returns></returns>
        public WebResponseContent RequestWMSTask2()
        public WebResponseContent RequestWMSTask2(string palletCode,string sourceAddress)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                //测试
                WMSTaskDTO taskDTO2 = new WMSTaskDTO()
                GenerateInv generate = new GenerateInv()
                {
                    TaskNum = Convert.ToInt32(DateTime.Now.ToString("HHmmss")),
                    Grade = 1,
                    PalletCode = "PalletCode20241030162310",
                    SourceAddress = "087-056-056",
                    RoadWay = "SC01",
                    TargetAddress = "102",
                    TaskState = (int)TaskRelocationStatusEnum.RelocationNew,
                    Id = 0,
                    TaskType = (int)TaskRelocationTypeEnum.Relocation,


                    SourceAddress = sourceAddress,
                    PalletCode = palletCode
                };
                content = ReceiveWMSTask(new List<WMSTaskDTO> { taskDTO2 });
                content = HttpHelper.Post<WebResponseContent>($"{urlEmptyOutbound}", generate);
                Dt_Task task = new Dt_Task();
                if (content != null)
                {
                    if (content.Status)
                    {
                        task = JsonConvert.DeserializeObject<Dt_Task>(content.Data.ToString());
                        task.TaskState = (int)TaskOutStatusEnum.OutNew;
                        task.TaskType = (int)TaskOutboundTypeEnum.Outbound;
                        task.Roadway = task.Roadway == "1" ? task.Roadway = "SC01" : task.Roadway = "SC02";
                        BaseDal.AddData(task);
                        return content = WebResponseContent.Instance.OK();
                    }
                    else
                    {
                        WriteLog.GetLog("PLC日志出库日志").Write($"空托出库失败，详情：{content.Message}", "需要空托");
                    }
                }
                return content = WebResponseContent.Instance.Error();
            }
            catch (Exception ex)
            {
                content = WebResponseContent.Instance.Error(ex.Message);
                return content = WebResponseContent.Instance.Error(ex.Message);
            }
            return content;
        }

        /// <summary>
        /// æ ¹æ®æ‰˜ç›˜å·ã€èµ·å§‹åœ°å€å‘WMS请求任务
        /// </summary>
        /// <param name="palletCode">托盘号</param>
        /// <param name="sourceAddress">起始地址</param>
        /// <returns></returns>
        public WebResponseContent RequestWMSTask3(string palletCode, int outCount,string Loc)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                if (outCount==0)
                {
                    outCount = 1;
                }
                GenerateInv3 generate = new GenerateInv3()
                {
                    PalletCode = palletCode,
                    outCount = outCount,
                    TargetAddress= Loc
                };
                content = HttpHelper.Post<WebResponseContent>($"{urlRawmaterialout}", generate);
                Dt_Task task = new Dt_Task();
                if (content != null)
                {
                    if (content.Status)
                    {
                        task = JsonConvert.DeserializeObject<Dt_Task>(content.Data.ToString());
                        task.TaskState = (int)TaskOutStatusEnum.OutNew;
                        task.TaskType = (int)TaskOutboundTypeEnum.Outbound;
                        task.Roadway = task.Roadway == "1" ? task.Roadway = "SC01" : task.Roadway = "SC02";
                        BaseDal.AddData(task);
                        return content = WebResponseContent.Instance.OK();
                    }
                }
                return content = WebResponseContent.Instance.Error();
            }
            catch (Exception ex)
            {
                return content = WebResponseContent.Instance.Error(ex.Message);
            }
        }


        public WebResponseContent RequestWMSTask4()
        {
            WebResponseContent content = new WebResponseContent();
            try
            {

                return content = HttpHelper.Get<WebResponseContent>($"{urlPalletQueryinventory}");
            }
            catch (Exception ex)
            {
                return content = WebResponseContent.Instance.Error(ex.Message);
            }
        }
        /// <summary>
        /// æ ¹æ®æ·±åº“位向wms申请判断浅库位是否有货，是否需要进行移库操作
        /// </summary>
        /// <param name="palletCode">托盘号</param>
        /// <param name="sourceAddress">起始地址</param>
        /// <returns></returns>
        public Dt_Task RequestWMSTaskMovelibrary(Dt_Task _Task)
        {
            WebResponseContent content = new WebResponseContent();
            content = HttpHelper.Get<WebResponseContent>($"{urlWMSMovelibraryTask}?TaskNum={_Task.TaskNum}&SourceAddress={_Task.SourceAddress}");
            Dt_Task task = new Dt_Task();
            if (content != null)
            {
                if (content.Status)
                {
                    if(content.Data != null)
                    {
                        task = JsonConvert.DeserializeObject<Dt_Task>(content.Data.ToString());
                        if (task.TaskNum != _Task.TaskNum)
                        {

                            task.TaskState = (int)TaskRelocationTypeEnum.Relocation;
                            task.Roadway = task.Roadway == "1" ? task.Roadway = "SC01" : task.Roadway = "SC02";
                            task.TaskNum = task.TaskNum;
                            task.Grade = 3;
                            task.TaskType= (int)TaskRelocationTypeEnum.Relocation;
                            BaseDal.AddData(task);
                            return task;
                        }
                    }
                }
                else
                {
                    return null;
                    WriteLog.GetLog("PLC日志").Write($"失败信息：{content.Message}", "移库信息");
                }
            }

            return _Task;
        }

        /// <summary>
@@ -293,6 +420,25 @@
            else
                return BaseDal.QueryFirst(x => x.Roadway == deviceNo && x.CurrentAddress == currentAddress && (TaskInboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskInStatusEnum.Line_InFinish || TaskOutboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskOutStatusEnum.OutNew), TaskOrderBy);
        }
        public Dt_Task IngStackerCraneTask(string deviceNo)
        {
            //string deviceNot = deviceNo == "SC01" ? "1" : "2";
            return BaseDal.QueryFirst(x => x.Roadway == deviceNo && x.TaskState == (int)TaskInStatusEnum.SC_InExecuting);
        }

        public Dt_Task IngStackerCraneTask2(string deviceNo)
        {
            //string deviceNot = deviceNo == "SC01" ? "1" : "2";
            try
            {
                return BaseDal.QueryFirst(x => x.Roadway == deviceNo && x.TaskState == (int)TaskOutStatusEnum.SC_OutExecuting);
            }
            catch (Exception ex)
            {

                throw;
            }
        }

        /// <summary>
        /// æ ¹æ®è®¾å¤‡ç¼–号、当前地址按照优先级以及创建时间排序查询任务池入库类型的新增的任务
@@ -331,6 +477,17 @@
        public List<Dt_Task> QueryStackerCraneOutTasks(string deviceNo, List<string> outStationCodes)
        {
            return BaseDal.QueryData(x => x.Roadway == deviceNo && TaskOutboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskOutStatusEnum.OutNew && outStationCodes.Contains(x.CurrentAddress), TaskOrderBy);
        }

        /// <summary>
        /// æ ¹æ®å‡ºåº“货位查询是否有当前浅货位任务
        /// </summary>
        /// <param name="deviceNo">设备编号</param>
        /// <param name="currentAddress">当前地址</param>
        /// <returns>返回任务实体对象集合，可能为null</returns>
        public List<Dt_Task> QueryStationIsOccupiedOutTasks(string deviceNo, string SourceAddress)
        {
            return BaseDal.QueryData(x => x.Roadway == deviceNo && SourceAddress.Contains(x.SourceAddress), TaskOrderBy);
        }

        /// <summary>
@@ -413,7 +570,7 @@
            try
            {
                int oldState = task.TaskState;
                if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)
                if (task.TaskType == (int)TaskOutboundTypeEnum.Outbound)
                {
                    if (task.TaskState >= (int)TaskOutStatusEnum.OutFinish)
                    {
@@ -428,7 +585,7 @@
                        task.Dispatchertime = DateTime.Now;
                    }
                }
                else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup)
                else if (task.TaskType == (int)TaskInboundTypeEnum.Inbound)
                {
                    if (task.TaskState >= (int)TaskInStatusEnum.InFinish)
                    {
@@ -441,7 +598,7 @@
                    {
                        task.Dispatchertime = DateTime.Now;
                    }
                    if (task.TaskState == (int)TaskInStatusEnum.Line_InFinish)
                    if (task.TaskState == (int)TaskRelocationTypeEnum.Relocation)
                    {
                        Random random = new Random();
                        task.CurrentAddress = task.NextAddress;
@@ -449,7 +606,7 @@
                        task.TargetAddress = task.NextAddress;
                    }
                }
                else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.RelocationGroup)
                else if (task.TaskType == (int)TaskInboundTypeEnum.Inbound)
                {
                    if (task.TaskState <= (int)TaskRelocationStatusEnum.SC_RelocationFinish)
                    {
@@ -530,6 +687,12 @@
        /// </summary>
        /// <param name="taskNum">任务编号</param>
        /// <returns>返回处理结果</returns>
        public class GenerateInv2
        {
            public string PalletCode { get; set; }
            public string SourceAddress { get; set; }
            public string TargetAddress { get; set; }
        }
        public WebResponseContent StackCraneTaskCompleted(int taskNum)
        {
            WebResponseContent content = new WebResponseContent();
@@ -538,11 +701,12 @@
                Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
                if (task == null) return WebResponseContent.Instance.Error($"未找到该任务信息,任务号:【{taskNum}】");

                if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup && task.TaskState == (int)TaskOutStatusEnum.SC_OutExecuting)
                if (task.TaskType == (int)TaskOutboundTypeEnum.Outbound && task.TaskState == (int)TaskOutStatusEnum.SC_OutExecuting)
                {
                    List<Dt_Router> routers = _routerService.QueryNextRoutes(task.NextAddress, task.TargetAddress);
                    if (!routers.Any()) return WebResponseContent.Instance.Error($"未找到设备路由信息");
                    /*List<Dt_Router> routers = _routerService.QueryNextRoutes(task.NextAddress, task.TargetAddress);
                    if (!routers.Any()) return WebResponseContent.Instance.Error($"未找到设备路由信息");*/

                    content = HttpHelper.Get<WebResponseContent>($"{urlTaskCompleted}?TaskNum={task.TaskNum}&HowWorks=2");
                    task.TaskState = (int)TaskOutStatusEnum.OutFinish;
                    task.ModifyDate = DateTime.Now;
                    BaseDal.DeleteData(task);
@@ -552,8 +716,9 @@

                    //暂不考虑多个出库口
                }
                else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup && task.TaskState == (int)TaskInStatusEnum.SC_InExecuting)
                else if (task.TaskType == (int)TaskInboundTypeEnum.Inbound && task.TaskState == (int)TaskInStatusEnum.SC_InExecuting)
                {
                    content = HttpHelper.Get<WebResponseContent>($"{urlTaskCompleted}?TaskNum={task.TaskNum}&HowWorks=2");
                    //todo 
                    //int nextStatus = task.TaskState.GetNextNotCompletedStatus<TaskInStatusEnum>();
                    task.TaskState = (int)TaskInStatusEnum.InFinish;
@@ -563,28 +728,23 @@
                    _task_HtyService.AddTaskHty(task);
                    _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"入库完成");

                    WMSTaskDTO taskDTO = new WMSTaskDTO()
                    {
                        TaskNum = Convert.ToInt32(DateTime.Now.ToString("HHmmss")),
                        Grade = 1,
                        PalletCode = task.PalletCode + "S",
                        RoadWay = "SC01",
                        SourceAddress = task.TargetAddress,
                        TargetAddress = "CLOutAreaA",
                        TaskState = (int)TaskOutStatusEnum.OutNew,
                        Id = 0,
                        TaskType = (int)TaskOutboundTypeEnum.Outbound
                    };

                    content = ReceiveWMSTask(new List<WMSTaskDTO> { taskDTO });
                }
                else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.RelocationGroup)
                else if (task.TaskType == (int)TaskRelocationTypeEnum.Relocation)
                {
                    /*GenerateInv2 generate = new GenerateInv2()
                    {
                        PalletCode = task.PalletCode,
                        SourceAddress = task.SourceAddress,
                        TargetAddress = task.TargetAddress

                    };
                    content = HttpHelper.Post<WebResponseContent>($"{urlTaskCompleted}", generate);*/
                    content = HttpHelper.Get<WebResponseContent>($"{urlTaskCompleted}?TaskNum={task.TaskNum}&HowWorks=2");
                    task.TaskState = (int)TaskOutStatusEnum.SC_OutFinish;
                    task.ModifyDate = DateTime.Now;
                    BaseDal.DeleteData(task);
                    _task_HtyService.AddTaskHty(task);
                    _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"出库完成");
                    _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"移库完成");
                }
                else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OtherGroup)
                {
@@ -693,5 +853,79 @@
            }
            return content;
        }


        /// <summary>
        /// åˆ é™¤æ•°æ®
        /// </summary>
        /// <param name="keys">主键数组</param>
        /// <returns></returns>
        public virtual WebResponseContent DeleteData(object[] keys)
        {
            try
            {
                List<Dt_Task> tasks = BaseDal.QureyDataByIds(keys);
                foreach (Dt_Task task in tasks)
                {
                    _task_HtyService.AddTaskHty(task);
                }


                if (typeof(Dt_Task).GetNavigatePro() == null)
                    return BaseDal.DeleteDataByIds(keys) ? WebResponseContent.Instance.OK() : WebResponseContent.Instance.Error();
                else
                {
                    if (keys != null)
                    {
                        Type detailType = typeof(Dt_Task).GetDetailType();
                        string name = typeof(Dt_Task).GetMainIdByDetail();
                        List<object> dynamicDelKeys = new List<object>();

                        for (int i = 0; i < keys.Length; i++)
                        {
                            dynamicDelKeys.Add(keys[i]);
                        }
                        ((SqlSugarClient)BaseDal.Db).BeginTran();

                        if (dynamicDelKeys.Count > 0)
                            BaseDal.Db.Deleteable<object>().AS(detailType.Name).Where($"{name} in (@id)", new { id = dynamicDelKeys.ToArray() }).ExecuteCommandHasChange();

                        BaseDal.DeleteDataByIds(keys);

                        ((SqlSugarClient)BaseDal.Db).CommitTran();

                        return WebResponseContent.Instance.OK();
                    }
                    else
                    {
                        return WebResponseContent.Instance.Error("参数错误");
                    }
                }
            }
            catch (Exception ex)
            {
                ((SqlSugarClient)BaseDal.Db).RollbackTran();
                return WebResponseContent.Instance.Error(ex.Message);
            }
        }

        public WebResponseContent ReceiveWCSTask(int tasknum)
        {
            Dt_Task tasks = BaseDal.QueryFirst(x => x.TaskNum == tasknum);
            try
            {
                _task_HtyService.AddTaskHty(tasks);
                BaseDal.DeleteData(tasks);
                WriteLog.Write_Log("WMS手动删除任务", "删除成功", $"申请删除的条码：{tasks.TaskNum},托盘条码：{tasks.PalletCode}", new { ä¿¡æ¯ = "删除成功" });
                return WebResponseContent.Instance.OK();
                
            }
            catch (Exception ex)
            {
                WriteLog.Write_Log("WMS手动删除任务","删除失败", $"申请删除的条码：{tasks.TaskNum},托盘条码：{tasks.PalletCode}", new { ä¿¡æ¯ = ex.Message });
                return WebResponseContent.Instance.Error();
            }
        }

    }
}