优先级

Zhang-Hong-Lin

9 天以前 ac2920c6c36227646c03a38c76a335120b449817

 ÏîÄ¿´úÂë/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs

@@ -19,6 +19,7 @@
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using SqlSugar;
using System.Diagnostics.CodeAnalysis;
using System.Threading.Tasks;
using WIDESEAWCS_Common.LocationEnum;
using WIDESEAWCS_Common.StockEnum;
using WIDESEAWCS_Common.TaskEnum;
@@ -46,9 +47,15 @@
        private readonly IRepository<dt_batchInfo> _batchinfoRepository;
        private readonly IRepository<Dt_Task_hty> _taskhtyRepository;
        private readonly IUnitOfWorkManage _unitOfWorkManage;
        private readonly IRepository<dt_errorInfo> _errorinfoRepository;
        private readonly IRepository<dt_errormsgInfo> _errorinfoRepository;
        private readonly Idt_ErrormsginfoService _ErrormsginfoService;
        private readonly IMapper _mapper;
        private readonly IRepository<dt_stationInfo> _dt_stationInfoRepository;
        private readonly IRepository<Dt_Task> _dt_taskRepositiry;
        private readonly IRepository<Dt_LocationInfo> _LocationInfoRepository;
        private readonly IRepository<Dt_StockInfo> _StockInfoRepository;
        private readonly IRepository<dt_batchInfo> _batchInfoRepository;
        private readonly IRepository<dt_outstockinfo> _outStockRepository;

        private Dictionary<string, OrderByType> _taskOrderBy = new()
            {
@@ -69,16 +76,22 @@

        //SBText ITaskService.text { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }

        public TaskService(IRepository<Dt_Task> BaseDal, IRouterService routerService, 
            ITaskExecuteDetailService taskExecuteDetailService, 
        public TaskService(IRepository<Dt_Task> BaseDal, IRouterService routerService,
            ITaskExecuteDetailService taskExecuteDetailService,
            IRepository<Dt_TaskExecuteDetail> taskExecuteDetailRepository,
            IRepository<Dt_StockInfo> stockRepository,
            IRepository<Dt_LocationInfo> locationRepository,
            IRepository<dt_batchInfo> batchRepository,
            IRepository<Dt_Task_hty> taskhtyRepository,
            IRepository<dt_errorInfo> errorinfoRepository,
            IRepository<dt_errormsgInfo> errorinfoRepository,
            IRepository<dt_stationInfo> dt_stationInfoRepository,
            IRepository<Dt_Task> dt_taskRepositiry,
            Idt_ErrormsginfoService errormsginfoService,
            IUnitOfWorkManage unitOfWorkManage,
            IRepository<Dt_StockInfo> StockInfoRepository,
            IRepository<dt_batchInfo> batchInfoRepository,
            IRepository<Dt_LocationInfo> LocationInfoRepository,
            IRepository<dt_outstockinfo> outStockRepository,
            IMapper mapper) : base(BaseDal)
        {
            _routerService = routerService;
@@ -92,6 +105,12 @@
            _errorinfoRepository = errorinfoRepository;
            _ErrormsginfoService = errormsginfoService;
            _mapper = mapper;
            _dt_stationInfoRepository = dt_stationInfoRepository;
            _dt_taskRepositiry = dt_taskRepositiry;
            _StockInfoRepository = StockInfoRepository;
            _LocationInfoRepository = LocationInfoRepository;
            _batchInfoRepository = batchInfoRepository;
            _outStockRepository = outStockRepository;
        }

        /// <summary>
@@ -184,6 +203,17 @@
        }

        /// <summary>
        /// æ ¹æ®ä»»åŠ¡çŠ¶æ€æŸ¥è¯¢ä»»åŠ¡
        /// </summary>
        /// <param name="deviceNo">设备编号</param>
        /// <param name="currentAddress">当前地址</param>
        /// <returns></returns>
        public Dt_Task QueryTaskState()
        {
            return BaseDal.QueryFirst(x => x.TaskState == (int)TaskInStatusEnum.InNew);
        }

        /// <summary>
        /// æ ¹æ®è®¾å¤‡ç¼–号、当前地址查询输送线未执行的任务
        /// </summary>
        /// <param name="deviceNo">设备编号</param>
@@ -251,20 +281,38 @@
                    //优先返回执行到一半的任务继续执行
                    return task;
                }
                //查询当前任务池中是否存在状态为非新建的
                task= BaseDal.QueryFirst(v => v.TaskState != (int)TaskInStatusEnum.InNew || v.TaskState != (int)TaskOutStatusEnum.OutNew);
                if (task != null)
                else
                {
                    throw new Exception($"当前任务池中存在执行中的任务,任务号:【{task.TaskNum}】");
                    //查询天车移动任务
                    task = BaseDal.QueryFirst(v => v.TaskType == (int)TaskMoveEnum.Mowe && v.TaskState == (int)TaskMoveStatusEnum.OutNewMove);
                    if (task != null)
                    {
                        return task;
                    }
                }
                //查询当前任务池中是否存在状态为非新建的
                //task= BaseDal.QueryFirst(v => v.TaskState != (int)TaskInStatusEnum.InNew || v.TaskState != (int)TaskOutStatusEnum.OutNew);
                //if (task != null)
                //{
                //    throw new Exception($"当前任务池中存在执行中的任务,任务号:【{task.TaskNum}】");
                //}
                //if (task != null)
                //{
                //    if (task.TaskState != (int)TaskMoveStatusEnum.OutNewMove)
                //    {

                //    }
                //}
                if (workTpe.Equals("In"))
                {
                    task = BaseDal.QueryData(v=>v.TaskType==(int)TaskInboundTypeEnum.Inbound && v.TaskState==(int)TaskInStatusEnum.InNew).OrderBy(v=>v.CreateDate).First();
                    //OrderBy(升序排序)
                    task = BaseDal.QueryData(v => (v.TaskType == (int)TaskInboundTypeEnum.TiChuRuKu || v.TaskType == (int)TaskInboundTypeEnum.Inbound) && v.TaskState == (int)TaskInStatusEnum.InNew).OrderByDescending(v => v.Grade).First();
                }
                else if (workTpe.Equals("Out"))
                {
                    task = BaseDal.QueryData(v => v.TaskType == (int)TaskOutboundTypeEnum.Outbound && v.TaskState == (int)TaskOutStatusEnum.OutNew).OrderBy(v => v.CreateDate).First();
                    task = BaseDal.QueryData(v => (v.TaskType == (int)TaskOutboundTypeEnum.TiChuChuKu || v.TaskType == (int)TaskOutboundTypeEnum.TiChuZhiJieChuKu || v.TaskType == (int)TaskOutboundTypeEnum.Outbound || v.TaskType == (int)TaskOutboundTypeEnum.OutInventory) && v.TaskState == (int)TaskOutStatusEnum.OutNew).OrderByDescending(v => v.Grade).First();
                }

            }
            catch (Exception)
            {
@@ -272,6 +320,24 @@

            }
            return task;
        }

        public Dt_Task QueryTasking()
        {
            Dt_Task task = new Dt_Task();
            task = BaseDal.QueryFirst(v => v.TaskState != (int)TaskInStatusEnum.InNew
            && v.TaskState != (int)TaskMoveStatusEnum.OutNewMove
            && v.TaskState != (int)TaskOutStatusEnum.OutNew
            && v.TaskState != (int)TaskOutStatusEnum.SC_OutExecuting
            && v.TaskState != (int)TaskInStatusEnum.Line_Ingrab);
            if (task != null)
            {
                return task;
            }
            else
            {
                return null;
            }
        }

        /// <summary>
@@ -310,13 +376,13 @@
        /// <returns>返回任务实体对象，可能为null</returns>
        public Dt_Task QueryTakNnmTask(int taskNum)
        {
            return BaseDal.QueryFirst(v=>v.TaskNum== taskNum);
            return BaseDal.QueryFirst(v => v.TaskId == taskNum);
        }
        /// <summary>
        /// ä¿®æ”¹å¤©è½¦ä»»åŠ¡çŠ¶æ€ï¼Œå°†å…¥åº“取货执行中修改为入库取货完成
        /// </summary>
        /// <returns></returns>
        public WebResponseContent UpdateTaskStatusToLine_Ingrab(Dt_Task task) 
        public WebResponseContent UpdateTaskStatusToLine_Ingrab(Dt_Task task)
        {
            WebResponseContent content = new WebResponseContent();
            try
@@ -328,7 +394,7 @@
            catch (Exception ex)
            {
                content = WebResponseContent.Instance.Error(ex.Message);
                UpdateTaskExceptionMessage(task.TaskNum, ex.Message);
                UpdateTaskExceptionMessage(task.TaskId, ex.Message);
            }
            return content;
        }
@@ -349,7 +415,7 @@
            catch (Exception ex)
            {
                content = WebResponseContent.Instance.Error(ex.Message);
                UpdateTaskExceptionMessage(task.TaskNum, ex.Message);
                UpdateTaskExceptionMessage(task.TaskId, ex.Message);
            }
            return content;
        }
@@ -375,7 +441,7 @@
            WebResponseContent content = new WebResponseContent();
            try
            {
                Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
                Dt_Task task = BaseDal.QueryFirst(x => x.TaskId == taskNum);
                if (task == null) return WebResponseContent.Instance.Error($"未找到该任务信息,任务号:【{taskNum}】");
                //if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)
                //{
@@ -409,29 +475,33 @@
        {
            try
            {
                Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
                if (status == 2 && task.TaskType == (int)TaskInboundTypeEnum.Inbound)
                Dt_Task task = BaseDal.QueryFirst(x => x.TaskId == taskNum);
                if (status == 2 && (task.TaskType == (int)TaskInboundTypeEnum.Inbound || task.TaskType == (int)TaskInboundTypeEnum.TiChuRuKu))
                {
                    task.TaskState = (int)TaskInStatusEnum.Line_InGrabExecuting;
                }
                else if (status == 2 && task.TaskType == (int)TaskOutboundTypeEnum.Outbound)
                else if (status == 2 && (task.TaskType == (int)TaskOutboundTypeEnum.Outbound || task.TaskType == (int)TaskOutboundTypeEnum.OutInventory || task.TaskType == (int)TaskOutboundTypeEnum.TiChuChuKu || task.TaskType == (int)TaskOutboundTypeEnum.TiChuZhiJieChuKu))
                {
                    task.TaskState = (int)TaskOutStatusEnum.Line_OutGrabExecuting;
                }
                if (status == 3 && task.TaskType == (int)TaskInboundTypeEnum.Inbound)
                else if (status == 3 && (task.TaskType == (int)TaskInboundTypeEnum.Inbound || task.TaskType == (int)TaskInboundTypeEnum.TiChuRuKu))
                {
                    task.TaskState = (int)TaskInStatusEnum.Line_InDownExecuting;
                }
                else if (status == 3 && task.TaskType == (int)TaskOutboundTypeEnum.Outbound)
                else if (status == 3 && (task.TaskType == (int)TaskOutboundTypeEnum.Outbound || task.TaskType == (int)TaskOutboundTypeEnum.OutInventory || task.TaskType == (int)TaskOutboundTypeEnum.TiChuChuKu || task.TaskType == (int)TaskOutboundTypeEnum.TiChuZhiJieChuKu))
                {
                    task.TaskState = (int)TaskOutStatusEnum.Line_OutWownExecuting;
                }
                else if (status == 4 && task.TaskType == (int)TaskMoveEnum.Mowe)
                {
                    task.TaskState = (int)TaskMoveStatusEnum.Line_OutMove;
                }
                task.ModifyDate = DateTime.Now;
                BaseDal.UpdateData(task);
            }
            catch (Exception ex)
            {
                _ErrormsginfoService.UpdateErrorMsg(ex.Message,1);
                UpdateTaskExceptionMessage(taskNum, ex.Message);
            }
        }

@@ -560,80 +630,286 @@
        /// </summary>
        /// <param name="taskNum">任务编号</param>
        /// <returns>返回处理结果</returns>
        public WebResponseContent StackCraneTaskCompleted(int taskNum,float weight)
        public WebResponseContent StackCraneTaskCompleted(int taskNum, float weight)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                var nawtask = BaseDal.QueryFirst(v=>v.TaskNum== taskNum);
                var nawtask = BaseDal.QueryFirst(v => v.TaskId == taskNum);
                if (nawtask == null)
                {
                    throw new Exception(string.Format("天车放货完成任务未查询到任务号{0}", taskNum));
                }
                if (nawtask.TaskType == (int)TaskInboundTypeEnum.Inbound)

                if (nawtask.TaskType == (int)TaskInboundTypeEnum.Inbound || nawtask.TaskType == (int)TaskInboundTypeEnum.TiChuRuKu)
                {
                    var batck = _batchinfoRepository.QueryFirst(v=>v.Id==1);
                    //新建库存
                    Dt_StockInfo stock = new Dt_StockInfo();
                    stock.LocationCode = nawtask.TargetAddress;
                    stock.Weight = (decimal)weight;
                    stock.StockStatus = (int)stockEnum.Lock;
                    stock.BatchNo = batck.Batch;
                    //修改货位信息
                    var location = _locationRepository.QueryFirst(v=>v.LocationCode==nawtask.TargetAddress);
                    location.LocationStatus = (int)LocationStatusEnum.InStock;
                    var station = _dt_stationInfoRepository.QueryFirst(v => v.msg == "剔除架");
                    string sourceAddress = station.Row + "-" + station.Column + "-1";
                    if (nawtask.SourceAddress.Equals(sourceAddress))
                    {
                        var batck = _batchinfoRepository.QueryFirst(v => v.Id == 1);
                        //新建库存
                        Dt_StockInfo stock = new Dt_StockInfo();
                        stock.LocationCode = nawtask.TargetAddress;
                        stock.Weight = (decimal)weight;
                        stock.StockStatus = (int)stockEnum.Free;
                        stock.BatchNo = batck.InBatch;
                        stock.Remark = 3;
                        //修改货位信息
                        var location = _locationRepository.QueryFirst(v => v.LocationCode == nawtask.TargetAddress);
                        location.LocationStatus = (int)LocationStatusEnum.InStock;
                        //处理任务信息
                        Dt_Task_hty taskhty = new Dt_Task_hty();
                        taskhty.TaskNum = nawtask.TaskNum;
                        taskhty.Roadway = nawtask.Roadway;
                        taskhty.TaskType = nawtask.TaskType;
                        taskhty.TaskState = (int)TaskInStatusEnum.Line_InFinish;
                        taskhty.SourceAddress = nawtask.SourceAddress;
                        taskhty.TargetAddress = nawtask.TargetAddress;
                        taskhty.ExceptionMessage = nawtask.ExceptionMessage;
                        taskhty.Grade = nawtask.Grade;
                        taskhty.Dispatchertime = nawtask.Dispatchertime;
                        taskhty.Remark = nawtask.Remark;
                        taskhty.PalletCode = nawtask.PalletCode;
                        taskhty.NextAddress = nawtask.NextAddress;
                        taskhty.CurrentAddress = nawtask.CurrentAddress;

                        //开始数据库事务
                        _unitOfWorkManage.BeginTran();
                        _stockRepository.AddData(stock);
                        _locationRepository.UpdateData(location);
                        _taskhtyRepository.AddData(taskhty);
                        BaseDal.DeleteData(nawtask);
                        //提交事务
                        _unitOfWorkManage.CommitTran();
                    }
                    else
                    {
                        var batck = _batchinfoRepository.QueryFirst(v => v.Id == 1);
                        //新建库存
                        Dt_StockInfo stock = new Dt_StockInfo();
                        stock.LocationCode = nawtask.TargetAddress;
                        stock.Weight = (decimal)weight;
                        stock.StockStatus = (int)stockEnum.Free;
                        stock.BatchNo = batck.InBatch;
                        if (nawtask.Remark == (int)MateTypeEnum.ZiChan)
                        {
                            stock.Remark = (int)MateTypeEnum.ZiChan;
                        }
                        else
                        {
                            stock.Remark = (int)MateTypeEnum.WaiGou;
                        }
                        Dt_StockInfo stockTow = new Dt_StockInfo();
                        stockTow.LocationCode = nawtask.NextAddress;
                        stockTow.Weight = (decimal)weight;
                        stockTow.StockStatus = (int)stockEnum.Free;
                        stockTow.BatchNo = batck.InBatch;
                        if (nawtask.Remark == (int)MateTypeEnum.ZiChan)
                        {
                            stockTow.Remark = (int)MateTypeEnum.ZiChan;
                        }
                        else
                        {
                            stockTow.Remark = (int)MateTypeEnum.WaiGou;
                        }
                        //修改货位信息
                        var location = _locationRepository.QueryFirst(v => v.LocationCode == nawtask.TargetAddress);
                        location.LocationStatus = (int)LocationStatusEnum.InStock;
                        //修改货位信息
                        var locationtow = _locationRepository.QueryFirst(v => v.LocationCode == nawtask.NextAddress);
                        locationtow.LocationStatus = (int)LocationStatusEnum.InStock;
                        //处理任务信息
                        Dt_Task_hty taskhty = new Dt_Task_hty();
                        taskhty.TaskNum = nawtask.TaskNum;
                        taskhty.Roadway = nawtask.Roadway;
                        taskhty.TaskType = nawtask.TaskType;
                        taskhty.TaskState = (int)TaskInStatusEnum.Line_InFinish;
                        taskhty.SourceAddress = nawtask.SourceAddress;
                        taskhty.TargetAddress = nawtask.TargetAddress;
                        taskhty.ExceptionMessage = nawtask.ExceptionMessage;
                        taskhty.Grade = nawtask.Grade;
                        taskhty.Dispatchertime = nawtask.Dispatchertime;
                        taskhty.Remark = nawtask.Remark;
                        taskhty.PalletCode = nawtask.PalletCode;
                        taskhty.NextAddress = nawtask.NextAddress;
                        taskhty.CurrentAddress = nawtask.CurrentAddress;

                        //开始数据库事务
                        _unitOfWorkManage.BeginTran();
                        _stockRepository.AddData(stock);
                        _stockRepository.AddData(stockTow);
                        _locationRepository.UpdateData(location);
                        _locationRepository.UpdateData(locationtow);
                        _taskhtyRepository.AddData(taskhty);
                        BaseDal.DeleteData(nawtask);
                        //提交事务
                        _unitOfWorkManage.CommitTran();
                    }
                }
                else if (nawtask.TaskType == (int)TaskOutboundTypeEnum.Outbound || nawtask.TaskType == (int)TaskOutboundTypeEnum.TiChuChuKu)
                {
                    var station = _dt_stationInfoRepository.QueryFirst(v => v.msg == "西跨架子");
                    string targetAddress = station.Row + "-" + station.Column + "-1";
                    if (nawtask.TargetAddress.Equals(targetAddress))
                    {
                        //查找库存
                        var stock = _stockRepository.QueryFirst(v => v.LocationCode == nawtask.SourceAddress);
                        if (stock == null)
                        {
                            throw new Exception($"未找到库存信息货位号:【{nawtask.TargetAddress}】");
                        }
                        //修改货位状态
                        var location = _locationRepository.QueryFirst(v => v.LocationCode == nawtask.SourceAddress);
                        location.LocationStatus = (int)LocationStatusEnum.Free;
                        //准备历史任务数据
                        Dt_Task_hty taskhty = new Dt_Task_hty();
                        taskhty.TaskNum = nawtask.TaskNum;
                        taskhty.Roadway = nawtask.Roadway;
                        taskhty.TaskType = nawtask.TaskType;
                        taskhty.TaskState = (int)TaskOutStatusEnum.OutFinish;
                        taskhty.SourceAddress = nawtask.SourceAddress;
                        taskhty.TargetAddress = nawtask.TargetAddress;
                        taskhty.ExceptionMessage = nawtask.ExceptionMessage;
                        taskhty.Grade = nawtask.Grade;
                        taskhty.Dispatchertime = nawtask.Dispatchertime;
                        taskhty.Remark = nawtask.Remark;
                        taskhty.PalletCode = nawtask.PalletCode;
                        taskhty.NextAddress = nawtask.NextAddress;
                        taskhty.CurrentAddress = nawtask.CurrentAddress;

                        //如果放货位置行是40，则立马生成一条移动任务
                        //开始创建任务
                        Dt_Task Movstask = new Dt_Task();
                        Movstask.Roadway = "TC01";
                        Movstask.TaskType = (int)TaskMoveEnum.Mowe;
                        Movstask.TaskState = (int)TaskMoveStatusEnum.OutNewMove;
                        Movstask.SourceAddress = "0";
                        Movstask.TargetAddress = "8-5-1";
                        Movstask.NextAddress = "text";
                        Movstask.Grade = 1;
                        Movstask.WMSId = 3;
                        Movstask.Remark = 0;
                        Movstask.PalletCode = "text";
                        Movstask.CurrentAddress = "text";

                        //开始数据库事务
                        BaseDal.AddData(Movstask);
                        _unitOfWorkManage.BeginTran();
                        _stockRepository.DeleteData(stock);
                        _locationRepository.UpdateData(location);
                        _taskhtyRepository.AddData(taskhty);
                        BaseDal.DeleteData(nawtask);
                        //提交事务
                        _unitOfWorkManage.CommitTran();
                    }
                    else
                    {
                        //查找库存
                        var stock = _stockRepository.QueryFirst(v => v.LocationCode == nawtask.SourceAddress);
                        if (stock == null)
                        {
                            throw new Exception($"未找到库存信息货位号:【{nawtask.TargetAddress}】");
                        }
                        var Towstock = _stockRepository.QueryFirst(v => v.LocationCode == nawtask.NextAddress);
                        //修改货位状态
                        var location = _locationRepository.QueryFirst(v => v.LocationCode == nawtask.SourceAddress);
                        location.LocationStatus = (int)LocationStatusEnum.Free;
                        //修改货位状态
                        var locationTow = _locationRepository.QueryFirst(v => v.LocationCode == nawtask.NextAddress);
                        locationTow.LocationStatus = (int)LocationStatusEnum.Free;
                        //准备历史任务数据
                        Dt_Task_hty taskhty = new Dt_Task_hty();
                        taskhty.TaskNum = nawtask.TaskNum;
                        taskhty.Roadway = nawtask.Roadway;
                        taskhty.TaskType = nawtask.TaskType;
                        taskhty.TaskState = (int)TaskOutStatusEnum.OutFinish;
                        taskhty.SourceAddress = nawtask.SourceAddress;
                        taskhty.TargetAddress = nawtask.TargetAddress;
                        taskhty.ExceptionMessage = nawtask.ExceptionMessage;
                        taskhty.Grade = nawtask.Grade;
                        taskhty.Dispatchertime = nawtask.Dispatchertime;
                        taskhty.Remark = nawtask.Remark;
                        taskhty.PalletCode = nawtask.PalletCode;
                        taskhty.NextAddress = nawtask.NextAddress;
                        taskhty.CurrentAddress = nawtask.CurrentAddress;
                        //如果放货位置行是40，则立马生成一条移动任务
                        //开始创建任务
                        Dt_Task Movstask = new Dt_Task();
                        Movstask.Roadway = "TC01";
                        Movstask.TaskType = (int)TaskMoveEnum.Mowe;
                        Movstask.TaskState = (int)TaskMoveStatusEnum.OutNewMove;
                        Movstask.SourceAddress = "0";
                        Movstask.TargetAddress = "8-5-1";
                        Movstask.NextAddress = "text";
                        Movstask.Grade = 1;
                        Movstask.WMSId = 3;
                        Movstask.Remark = 0;
                        Movstask.PalletCode = "text";
                        Movstask.CurrentAddress = "text";
                        //开始数据库事务

                        _unitOfWorkManage.BeginTran();
                        BaseDal.AddData(Movstask);
                        _stockRepository.DeleteData(stock);
                        _stockRepository.DeleteData(Towstock);
                        _locationRepository.UpdateData(location);
                        _locationRepository.UpdateData(locationTow);
                        _taskhtyRepository.AddData(taskhty);
                        BaseDal.DeleteData(nawtask);
                        //提交事务
                        _unitOfWorkManage.CommitTran();
                    }
                }
                else if (nawtask.TaskType == (int)TaskOutboundTypeEnum.OutInventory || nawtask.TaskType == (int)TaskMoveEnum.Mowe || nawtask.TaskType == (int)TaskOutboundTypeEnum.TiChuZhiJieChuKu)
                {
                    //处理任务信息
                    Dt_Task_hty taskhty = new Dt_Task_hty();
                    taskhty.TaskNum = nawtask.TaskNum;
                    taskhty.Roadway = nawtask.Roadway;
                    taskhty.TaskType = nawtask.TaskType;
                    taskhty.TaskState = (int)TaskInStatusEnum.Line_InFinish;
                    taskhty.TaskState = (int)TaskOutStatusEnum.OutFinish;
                    taskhty.SourceAddress = nawtask.SourceAddress;
                    taskhty.TargetAddress = nawtask.TargetAddress;
                    taskhty.ExceptionMessage = nawtask.ExceptionMessage;
                    taskhty.Grade = nawtask.Grade;
                    taskhty.Dispatchertime = nawtask.Dispatchertime;
                    taskhty.Remark = nawtask.Remark;
                    //开始数据库事务
                    _unitOfWorkManage.BeginTran();
                    _stockRepository.AddData(stock);
                    _locationRepository.UpdateData(location);
                    _taskhtyRepository.AddData(taskhty);
                    BaseDal.DeleteData(nawtask);
                    //提交事务
                    _unitOfWorkManage.CommitTran();
                }
                else if (nawtask.TaskType == (int)TaskOutboundTypeEnum.Outbound)
                {
                    //查找库存
                    var stock = _stockRepository.QueryFirst(v=>v.LocationCode== nawtask.TargetAddress);
                    if (stock == null) 
                    taskhty.PalletCode = nawtask.PalletCode;
                    taskhty.NextAddress = nawtask.NextAddress;
                    taskhty.CurrentAddress = nawtask.CurrentAddress;
                    if (nawtask.TaskType == (int)TaskOutboundTypeEnum.OutInventory || nawtask.TaskType == (int)TaskOutboundTypeEnum.TiChuZhiJieChuKu)
                    {
                        throw new Exception($"未找到库存信息货位号:【{nawtask.TargetAddress}】");
                        //开始创建任务
                        Dt_Task Movstask = new Dt_Task();
                        Movstask.Roadway = "TC01";
                        Movstask.TaskType = (int)TaskMoveEnum.Mowe;
                        Movstask.TaskState = (int)TaskMoveStatusEnum.OutNewMove;
                        Movstask.SourceAddress = "0";
                        Movstask.TargetAddress = "8-5-1";
                        Movstask.NextAddress = "text";
                        Movstask.Grade = 1;
                        Movstask.WMSId = 3;
                        Movstask.Remark = 0;
                        Movstask.PalletCode = "text";
                        Movstask.CurrentAddress = "text";
                        //开始数据库事务
                        _unitOfWorkManage.BeginTran();
                        BaseDal.AddData(Movstask);
                        _taskhtyRepository.AddData(taskhty);
                        BaseDal.DeleteData(nawtask);
                        //提交事务
                        _unitOfWorkManage.CommitTran();
                    }
                    //修改货位状态
                    var location = _locationRepository.QueryFirst(v => v.LocationCode == nawtask.TargetAddress);
                    location.LocationStatus = (int)LocationStatusEnum.Free;
                    //准备历史任务数据
                    Dt_Task_hty taskhty = new Dt_Task_hty();
                    taskhty.TaskNum = nawtask.TaskNum;
                    taskhty.Roadway = nawtask.Roadway;
                    taskhty.TaskType = nawtask.TaskType;
                    taskhty.TaskState = (int)TaskInStatusEnum.Line_InFinish;
                    taskhty.SourceAddress = nawtask.SourceAddress;
                    taskhty.TargetAddress = nawtask.TargetAddress;
                    taskhty.ExceptionMessage = nawtask.ExceptionMessage;
                    taskhty.Grade = nawtask.Grade;
                    taskhty.Dispatchertime = nawtask.Dispatchertime;
                    taskhty.Remark = nawtask.Remark;
                    //开始数据库事务
                    _unitOfWorkManage.BeginTran();
                    _stockRepository.DeleteData(stock);
                    _locationRepository.UpdateData(location);
                    _taskhtyRepository.AddData(taskhty);
                    BaseDal.DeleteData(nawtask);
                    //提交事务
                    _unitOfWorkManage.CommitTran();
                    else
                    {
                        //开始数据库事务
                        _unitOfWorkManage.BeginTran();
                        _taskhtyRepository.AddData(taskhty);
                        BaseDal.DeleteData(nawtask);
                        //提交事务
                        _unitOfWorkManage.CommitTran();
                    }
                }
                content = WebResponseContent.Instance.OK();
            }
@@ -642,7 +918,7 @@
                //回滚事务
                _unitOfWorkManage.RollbackTran();
                content = WebResponseContent.Instance.Error($"任务完成异常,任务号:【{taskNum}】");
                UpdateTaskExceptionMessage(taskNum,ex.Message);
                UpdateTaskExceptionMessage(taskNum, ex.Message);
            }
            return content;
        }
@@ -737,5 +1013,541 @@
            }
            return content;
        }

        public WebResponseContent AtOnceUpdate(int taskid)
        {
            WebResponseContent content = new WebResponseContent();
            Dt_Task nawtask = BaseDal.QueryFirst(v => v.TaskId == taskid);
            //入库
            if (nawtask.TaskType == (int)TaskInboundTypeEnum.Inbound || nawtask.TaskType == (int)TaskInboundTypeEnum.TiChuRuKu)
            {
                //剔除入库
                var station = _dt_stationInfoRepository.QueryFirst(v => v.msg == "剔除架");
                string sourceAddress = station.Row + "-" + station.Column + "-1";
                if (nawtask.SourceAddress.Equals(sourceAddress))
                {
                    var batck = _batchinfoRepository.QueryFirst(v => v.Id == 1);
                    //新建库存
                    Dt_StockInfo stock = new Dt_StockInfo();
                    stock.LocationCode = nawtask.TargetAddress;
                    stock.StockStatus = (int)stockEnum.Free;
                    stock.BatchNo = batck.InBatch;
                    stock.Remark = (int)MateTypeEnum.TiChu;
                    //修改货位信息
                    var location = _locationRepository.QueryFirst(v => v.LocationCode == nawtask.TargetAddress);
                    location.LocationStatus = (int)LocationStatusEnum.InStock;
                    //处理任务信息
                    Dt_Task_hty taskhty = new Dt_Task_hty();
                    taskhty.TaskNum = nawtask.TaskNum;
                    taskhty.Roadway = nawtask.Roadway;
                    taskhty.TaskType = nawtask.TaskType;
                    taskhty.TaskState = (int)TaskInStatusEnum.Line_InFinish;
                    taskhty.SourceAddress = nawtask.SourceAddress;
                    taskhty.TargetAddress = nawtask.TargetAddress;
                    taskhty.ExceptionMessage = nawtask.ExceptionMessage;
                    taskhty.Grade = nawtask.Grade;
                    taskhty.Dispatchertime = nawtask.Dispatchertime;
                    taskhty.Remark = nawtask.Remark;
                    taskhty.PalletCode = nawtask.PalletCode;
                    taskhty.NextAddress = nawtask.NextAddress;
                    taskhty.CurrentAddress = nawtask.CurrentAddress;

                    //开始数据库事务
                    _unitOfWorkManage.BeginTran();
                    _stockRepository.AddData(stock);
                    _locationRepository.UpdateData(location);
                    _taskhtyRepository.AddData(taskhty);
                    BaseDal.DeleteData(nawtask);
                    //提交事务
                    _unitOfWorkManage.CommitTran();
                }
                //正常入库
                else
                {
                    var batck = _batchinfoRepository.QueryFirst(v => v.Id == 1);
                    //新建库存
                    Dt_StockInfo stock = new Dt_StockInfo();
                    stock.LocationCode = nawtask.TargetAddress;
                    stock.StockStatus = (int)stockEnum.Free;
                    stock.BatchNo = batck.InBatch;
                    if (nawtask.Remark == (int)MateTypeEnum.ZiChan)
                    {
                        stock.Remark = (int)MateTypeEnum.ZiChan;
                    }
                    else
                    {
                        stock.Remark = (int)MateTypeEnum.WaiGou;
                    }
                    Dt_StockInfo stockTow = new Dt_StockInfo();
                    stockTow.LocationCode = nawtask.NextAddress;
                    stockTow.StockStatus = (int)stockEnum.Free;
                    stockTow.BatchNo = batck.InBatch;
                    if (nawtask.Remark == (int)MateTypeEnum.ZiChan)
                    {
                        stockTow.Remark = (int)MateTypeEnum.ZiChan;
                    }
                    else
                    {
                        stockTow.Remark = (int)MateTypeEnum.WaiGou;
                    }
                    //修改货位信息
                    var location = _locationRepository.QueryFirst(v => v.LocationCode == nawtask.TargetAddress);
                    location.LocationStatus = (int)LocationStatusEnum.InStock;
                    //修改货位信息
                    var locationtow = _locationRepository.QueryFirst(v => v.LocationCode == nawtask.NextAddress);
                    locationtow.LocationStatus = (int)LocationStatusEnum.InStock;
                    //处理任务信息
                    Dt_Task_hty taskhty = new Dt_Task_hty();
                    taskhty.TaskNum = nawtask.TaskNum;
                    taskhty.Roadway = nawtask.Roadway;
                    taskhty.TaskType = nawtask.TaskType;
                    taskhty.TaskState = (int)TaskInStatusEnum.Line_InFinish;
                    taskhty.SourceAddress = nawtask.SourceAddress;
                    taskhty.TargetAddress = nawtask.TargetAddress;
                    taskhty.ExceptionMessage = nawtask.ExceptionMessage;
                    taskhty.Grade = nawtask.Grade;
                    taskhty.Dispatchertime = nawtask.Dispatchertime;
                    taskhty.Remark = nawtask.Remark;
                    taskhty.PalletCode = nawtask.PalletCode;
                    taskhty.NextAddress = nawtask.NextAddress;
                    taskhty.CurrentAddress = nawtask.CurrentAddress;

                    //开始数据库事务
                    _unitOfWorkManage.BeginTran();
                    _stockRepository.AddData(stock);
                    _stockRepository.AddData(stockTow);
                    _locationRepository.UpdateData(location);
                    _locationRepository.UpdateData(locationtow);
                    _taskhtyRepository.AddData(taskhty);
                    BaseDal.DeleteData(nawtask);
                    //提交事务
                    _unitOfWorkManage.CommitTran();
                }
            }
            //出库
            else if (nawtask.TaskType == (int)TaskOutboundTypeEnum.Outbound || nawtask.TaskType == (int)TaskOutboundTypeEnum.TiChuChuKu)
            {
                //剔除出库
                var station = _dt_stationInfoRepository.QueryFirst(v => v.msg == "西跨架子");
                string targetAddress = station.Row + "-" + station.Column + "-1";
                if (nawtask.TargetAddress.Equals(targetAddress))
                {
                    //查找库存
                    var stock = _stockRepository.QueryFirst(v => v.LocationCode == nawtask.SourceAddress);
                    if (stock == null)
                    {
                        throw new Exception($"未找到库存信息货位号:【{nawtask.TargetAddress}】");
                    }
                    //修改货位状态
                    var location = _locationRepository.QueryFirst(v => v.LocationCode == nawtask.SourceAddress);
                    location.LocationStatus = (int)LocationStatusEnum.Free;
                    //准备历史任务数据
                    Dt_Task_hty taskhty = new Dt_Task_hty();
                    taskhty.TaskNum = nawtask.TaskNum;
                    taskhty.Roadway = nawtask.Roadway;
                    taskhty.TaskType = nawtask.TaskType;
                    taskhty.TaskState = (int)TaskOutStatusEnum.OutFinish;
                    taskhty.SourceAddress = nawtask.SourceAddress;
                    taskhty.TargetAddress = nawtask.TargetAddress;
                    taskhty.ExceptionMessage = nawtask.ExceptionMessage;
                    taskhty.Grade = nawtask.Grade;
                    taskhty.Dispatchertime = nawtask.Dispatchertime;
                    taskhty.Remark = nawtask.Remark;
                    taskhty.PalletCode = nawtask.PalletCode;
                    taskhty.NextAddress = nawtask.NextAddress;
                    taskhty.CurrentAddress = nawtask.CurrentAddress;
                    //开始数据库事务

                    _unitOfWorkManage.BeginTran();
                    _stockRepository.DeleteData(stock);
                    _locationRepository.UpdateData(location);
                    _taskhtyRepository.AddData(taskhty);
                    BaseDal.DeleteData(nawtask);
                    //提交事务
                    _unitOfWorkManage.CommitTran();
                }
                //正常出库
                else
                {
                    //查找库存
                    var stock = _stockRepository.QueryFirst(v => v.LocationCode == nawtask.SourceAddress);
                    if (stock == null)
                    {
                        throw new Exception($"未找到库存信息货位号:【{nawtask.TargetAddress}】");
                    }
                    var Towstock = _stockRepository.QueryFirst(v => v.LocationCode == nawtask.NextAddress);
                    //修改货位状态
                    var location = _locationRepository.QueryFirst(v => v.LocationCode == nawtask.SourceAddress);
                    location.LocationStatus = (int)LocationStatusEnum.Free;
                    //修改货位状态
                    var locationTow = _locationRepository.QueryFirst(v => v.LocationCode == nawtask.NextAddress);
                    if (locationTow!=null)
                    {
                        locationTow.LocationStatus = (int)LocationStatusEnum.Free;
                    }
                    //准备历史任务数据
                    Dt_Task_hty taskhty = new Dt_Task_hty();
                    taskhty.TaskNum = nawtask.TaskNum;
                    taskhty.Roadway = nawtask.Roadway;
                    taskhty.TaskType = nawtask.TaskType;
                    taskhty.TaskState = (int)TaskOutStatusEnum.OutFinish;
                    taskhty.SourceAddress = nawtask.SourceAddress;
                    taskhty.TargetAddress = nawtask.TargetAddress;
                    taskhty.ExceptionMessage = nawtask.ExceptionMessage;
                    taskhty.Grade = nawtask.Grade;
                    taskhty.Dispatchertime = nawtask.Dispatchertime;
                    taskhty.Remark = nawtask.Remark;
                    taskhty.PalletCode = nawtask.PalletCode;
                    taskhty.NextAddress = nawtask.NextAddress;
                    taskhty.CurrentAddress = nawtask.CurrentAddress;
                    //开始数据库事务

                    _unitOfWorkManage.BeginTran();
                    _stockRepository.DeleteData(stock);
                    _locationRepository.UpdateData(location);
                    if (locationTow != null)
                    {
                        _locationRepository.UpdateData(locationTow);
                        _stockRepository.DeleteData(Towstock);
                    }
                    _taskhtyRepository.AddData(taskhty);
                    BaseDal.DeleteData(nawtask);
                    //提交事务
                    _unitOfWorkManage.CommitTran();
                }
            }
            return content.OK("完成");
        }

        public WebResponseContent speciadelete(Dt_Task task)
        {
            WebResponseContent content = new WebResponseContent();
            if (task.TaskState == (int)TaskMoveStatusEnum.OutNewMove)
            {
                BaseDal.DeleteData(task);
            }
            else if (task.TaskState == (int)TaskInStatusEnum.InNew)
            {
                //剔除入库
                var station = _dt_stationInfoRepository.QueryFirst(v => v.msg == "剔除架");
                string sourceAddress = station.Row + "-" + station.Column + "-1";
                if (task.SourceAddress.Equals(sourceAddress))
                {
                    Dt_LocationInfo locationinfo = _locationRepository.QueryFirst(v => v.LocationCode == task.TargetAddress);
                    locationinfo.LocationStatus = 0;
                    _unitOfWorkManage.BeginTran();
                    _locationRepository.UpdateData(locationinfo);
                    BaseDal.DeleteData(task);
                    _unitOfWorkManage.CommitTran();
                    return content.OK("2");
                }
                else
                {
                    //修改货位信息
                    var location = _locationRepository.QueryFirst(v => v.LocationCode == task.TargetAddress);
                    location.LocationStatus = (int)LocationStatusEnum.Free;
                    //修改货位信息
                    var locationtow = _locationRepository.QueryFirst(v => v.LocationCode == task.NextAddress);
                    locationtow.LocationStatus = (int)LocationStatusEnum.Free;
                    _unitOfWorkManage.BeginTran();
                    _locationRepository.UpdateData(location);
                    _locationRepository.UpdateData(locationtow);
                    BaseDal.DeleteData(task);
                    _unitOfWorkManage.CommitTran();
                    return content.OK("3");
                }
            }
            else if (task.TaskState == (int)TaskOutStatusEnum.OutNew)
            {
                //剔除出库
                var station = _dt_stationInfoRepository.QueryFirst(v => v.msg == "西跨架子");
                string targetAddress = station.Row + "-" + station.Column + "-1";
                if (task.TargetAddress.Equals(targetAddress))
                {
                    //修改货位信息
                    var location = _locationRepository.QueryFirst(v => v.LocationCode == task.SourceAddress);
                    location.LocationStatus = (int)LocationStatusEnum.InStock;
                    Dt_StockInfo stockInfo = _stockRepository.QueryFirst(v => v.LocationCode == task.SourceAddress);
                    stockInfo.StockStatus = (int)stockEnum.Free;
                    _unitOfWorkManage.BeginTran();
                    _locationRepository.UpdateData(location);
                    _stockRepository.UpdateData(stockInfo);
                    BaseDal.DeleteData(task);
                    _unitOfWorkManage.CommitTran();
                    return content.OK("4");
                }
                else
                {
                    //修改货位信息
                    var location = _locationRepository.QueryFirst(v => v.LocationCode == task.SourceAddress);
                    location.LocationStatus = (int)LocationStatusEnum.InStock;
                    //修改货位信息
                    var locationtow = _locationRepository.QueryFirst(v => v.LocationCode == task.NextAddress);
                    Dt_StockInfo stockInfos = _stockRepository.QueryFirst(v => v.LocationCode == task.NextAddress);
                   
                    if (locationtow != null)
                    {
                        locationtow.LocationStatus = (int)LocationStatusEnum.InStock;
                        stockInfos.StockStatus = (int)stockEnum.Free;
                    }
                    Dt_StockInfo stockInfo = _stockRepository.QueryFirst(v => v.LocationCode == task.SourceAddress);
                    stockInfo.StockStatus = (int)stockEnum.Free;
                    
                    _unitOfWorkManage.BeginTran();
                    _locationRepository.UpdateData(location);
                    if (locationtow != null)
                    {
                        _locationRepository.UpdateData(locationtow);
                        _stockRepository.UpdateData(stockInfos);
                    }
                    _stockRepository.UpdateData(stockInfo);
                    BaseDal.DeleteData(task);
                    _unitOfWorkManage.CommitTran();
                    return content.OK("5");
                }
            }
            return content.OK("1");
        }

        public WebResponseContent speciaupdate(Dt_Task task)
        {
            WebResponseContent content = new WebResponseContent();
            if (task.TaskState == (int)TaskInStatusEnum.InNew)
            {
                task.TaskState = (int)TaskInStatusEnum.Line_Ingrab;
                BaseDal.UpdateData(task);
            }
            else if (task.TaskState == (int)TaskInStatusEnum.Line_Ingrab)
            {
                task.TaskState = (int)TaskInStatusEnum.InNew;
                BaseDal.UpdateData(task);
            }
            else if (task.TaskState == (int)TaskOutStatusEnum.OutNew)
            {
                task.TaskState = (int)TaskOutStatusEnum.SC_OutExecuting;
                BaseDal.UpdateData(task);
            }
            else if (task.TaskState == (int)TaskOutStatusEnum.SC_OutExecuting)
            {
                task.TaskState = (int)TaskOutStatusEnum.OutNew;
                BaseDal.UpdateData(task);
            }
            else
            {
                return content.OK("状态不允许");
            }
            return content.OK("1");
        }

        public WebResponseContent banzidong(string wei, string weis)
        {
            WebResponseContent content = new WebResponseContent();
            //if (!OHTJob.oHTReadData.R_ZXJ_isWork)
            //{
            //    throw new Exception($"整形机投入使用信号为false");
            //}
            var isout = _outStockRepository.QueryFirst(v => v.Id == 1);
            if (isout.isout == 0)
            {
                //if (!OHTJob.oHTReadData.R_ZXJ_TCMode)
                //{
                //    throw new Exception($"整形机不属于天车上料模式或天车放板信号为false");
                //}
                //if (!OHTJob.oHTReadData.R_HC_isReadyWork)
                //{
                //    throw new Exception($"整形机天车放板信号为false");
                //}
                //查询当前任务池中是否存在出库任务，出库任务只能存在一条
                var oldtask = _dt_taskRepositiry.QueryFirst(v => v.TaskType == (int)TaskOutboundTypeEnum.Outbound);
                if (oldtask != null)
                {
                    throw new Exception($"当前任务池中已存在一条出库任务");
                }

                //查询库存
                Dt_StockInfo ku = _stockRepository.QueryFirst(v => v.LocationCode == wei);
                if (ku == null)
                {
                    return content.OK("3");
                }
                //查询相邻库存
                Dt_StockInfo kus = _stockRepository.QueryFirst(v => v.LocationCode == weis);
                ku.StockStatus = (int)stockEnum.Lock;
                kus.StockStatus = (int)stockEnum.Lock;
                //查询货位
                Dt_LocationInfo huo = _LocationInfoRepository.QueryFirst(v => v.LocationCode == wei);
                //查询相邻货位
                Dt_LocationInfo huos = _LocationInfoRepository.QueryFirst(v => v.LocationCode == weis);
                huo.LocationStatus = (int)LocationStatusEnum.Lock;
                huos.LocationStatus = (int)LocationStatusEnum.Lock;
                //查询终点站台信息
                var station = _dt_stationInfoRepository.QueryFirst(v => v.msg == "整形机放料位");
                //开始创建任务
                Dt_Task outtask = new Dt_Task();
                outtask.Roadway = "TC01";
                outtask.TaskType = (int)TaskOutboundTypeEnum.Outbound;
                outtask.TaskState = (int)TaskOutStatusEnum.OutNew;
                outtask.SourceAddress = ku.LocationCode;
                outtask.TargetAddress = station.Row + "-" + station.Column + "-1";
                outtask.NextAddress = huos.LocationCode;
                outtask.Grade = 2;
                outtask.WMSId = 3;
                outtask.Remark = kus.Remark;
                outtask.PalletCode = "text";
                outtask.CurrentAddress = "text";
                _unitOfWorkManage.BeginTran();
                _LocationInfoRepository.UpdateData(huo);
                _LocationInfoRepository.UpdateData(huos);
                _StockInfoRepository.UpdateData(ku);
                _dt_taskRepositiry.AddData(outtask);
                _StockInfoRepository.UpdateData(kus);
                _unitOfWorkManage.CommitTran();
                return content.OK("2");
            }
            return content.OK("1");
        }

        public WebResponseContent zhijiechuku()
        {
            Dt_Task task = new Dt_Task();
            WebResponseContent content = new WebResponseContent();
            var isout = _outStockRepository.QueryFirst(v => v.Id == 1);
            if (isout.isout == 0)
            {
                var oldtask = _dt_taskRepositiry.QueryFirst(v => v.TaskType == (int)TaskOutboundTypeEnum.Outbound);
                if (oldtask != null)
                {
                    throw new Exception($"当前任务池中已存在一条出库任务");
                }
                var station = _dt_stationInfoRepository.QueryFirst(v => v.msg == "西跨架子");
                task.TargetAddress = station.Row + "-" + station.Column + "-1";
                var stations = _dt_stationInfoRepository.QueryFirst(v => v.msg == "剔除架");
                task.SourceAddress = stations.Row + "-" + stations.Column + "-1";
                var oldhtytask = _dt_taskRepositiry.QueryFirst(v => v.SourceAddress == task.SourceAddress);
                if (oldhtytask == null)
                {
                    task.Grade = 3;
                    task.Remark = (int)MateTypeEnum.TiChu;
                    task.NextAddress = "text";
                    task.Roadway = "TC01";
                    task.TaskType = (int)TaskOutboundTypeEnum.TiChuZhiJieChuKu;
                    task.TaskState = (int)TaskOutStatusEnum.OutNew;
                    task.PalletCode = "text";
                    task.CurrentAddress = "text";
                    task.WMSId = 2;
                    _dt_taskRepositiry.AddData(task);
                    return content.OK("2");
                }
            }
            else
            {
                return content.OK("1");
            }
            return content.OK("3");
        }

        public WebResponseContent tichuchuku(string wei)
        {
            Dt_Task task = new Dt_Task();
            WebResponseContent content = new WebResponseContent();
            //if (!OHTJob.oHTReadData.R_TCMode && !OHTJob.oHTReadData.R_TC_isready)
            //{
            //    throw new Exception($"规整机剔除架子可放板或剔除上料模式信号为false");
            //}
            //查询当前任务池中是否存在出库任务，出库任务只能存在一条
            var isout = _outStockRepository.QueryFirst(v => v.Id == 1);
            if (isout.isout == 0)
            {
                var oldtask = _dt_taskRepositiry.QueryFirst(v => v.TaskType == (int)TaskOutboundTypeEnum.Outbound);
                if (oldtask != null)
                {
                    throw new Exception($"当前任务池中已存在一条出库任务");
                }
                //查询库存
                Dt_LocationInfo huo = _LocationInfoRepository.QueryFirst(v => v.LocationCode == wei);
                if (huo.LocationStatus == 0)
                {
                    return content.OK("4");
                }
                huo.LocationStatus = 1;
                Dt_StockInfo stockinfo = _StockInfoRepository.QueryFirst(v => v.LocationCode == wei);
                if (stockinfo==null)
                {
                    return content.OK("4");
                }
                stockinfo.StockStatus = 1;
                var station = _dt_stationInfoRepository.QueryFirst(v => v.msg == "西跨架子");
                task.TargetAddress = station.Row + "-" + station.Column + "-1";
                var oldhtytask = _dt_taskRepositiry.QueryFirst(v => v.SourceAddress == task.SourceAddress);
                if (oldhtytask == null)
                {
                    task.SourceAddress = wei;
                    task.Grade = 3;
                    task.Remark = (int)MateTypeEnum.TiChu;
                    task.NextAddress = "text";
                    task.Roadway = "TC01";
                    task.TaskType = (int)TaskOutboundTypeEnum.TiChuChuKu;
                    task.TaskState = (int)TaskOutStatusEnum.OutNew;
                    task.PalletCode = "text";
                    task.CurrentAddress = "text";
                    task.WMSId = 2;
                    _unitOfWorkManage.BeginTran();
                    _dt_taskRepositiry.AddData(task);
                    _LocationInfoRepository.UpdateData(huo);
                    _StockInfoRepository.UpdateData(stockinfo);
                    _unitOfWorkManage.CommitTran();
                    return content.OK("2");
                }
            }   
            return content.OK("3");
        }

        public WebResponseContent tichuruku(string wei)
        {
            Dt_Task task = new Dt_Task();
            WebResponseContent content = new WebResponseContent();
            //if (!OHTJob.oHTReadData.R_ZXJ_isWork)
            //{
            //    throw new Exception($"整形机投入使用信号为false");
            //}
            var isout = _outStockRepository.QueryFirst(v => v.Id == 1);
            if (isout.isout == 0)
            {
                //判断库存是否有货
                //查询货位
                Dt_LocationInfo huo = _LocationInfoRepository.QueryFirst(v => v.LocationCode == wei);
                if (huo.LocationStatus!=0)
                {
                    return content.OK("4");
                }
                huo.LocationStatus = 1;
                var station = _dt_stationInfoRepository.QueryFirst(v => v.msg == "剔除架");
                task.SourceAddress = station.Row + "-" + station.Column + "-1";
                var oldhtytask = _dt_taskRepositiry.QueryFirst(v => v.SourceAddress == task.SourceAddress);
                if (oldhtytask == null)
                {
                    task.TargetAddress = wei;
                    task.Grade = 3;
                    task.Remark = (int)MateTypeEnum.TiChu;
                    task.NextAddress = "text";
                    task.Roadway = "TC01";
                    task.TaskType = (int)TaskInboundTypeEnum.TiChuRuKu;
                    task.TaskState = (int)TaskInStatusEnum.InNew;
                    task.PalletCode = "text";
                    task.CurrentAddress = "text";
                    task.WMSId = 2;
                    _unitOfWorkManage.BeginTran();
                    _dt_taskRepositiry.AddData(task);
                    _LocationInfoRepository.UpdateData(huo);
                    _unitOfWorkManage.CommitTran();
                    return content.OK("2");
                }
            }
            else
            {
                return content.OK("1");
            }
            return content.OK("3");
        }
    }
}