修改问题

chengsc

2025-03-28 e00c9e03eeaffad919cf16c95b2d6048e8abfb9d

 Wms/WMS.BLL/BllPdaServer/PdaCrServer.cs

@@ -5,8 +5,10 @@
using System.Text;
using System.Threading.Tasks;
using Dm;
using Model.InterFaceModel;
using Model.ModelDto.BllCheckDto;
using Model.ModelDto.PdaDto;
using Newtonsoft.Json;
using SqlSugar;
using Utility;
using WMS.BLL.LogServer;
@@ -780,123 +782,170 @@
        /// <param name="palletNo"></param>
        /// <param name="areaNo"></param>
        /// <param name="ruku"></param>
        public async Task AgvTransport(string palletNo, string areaNo, string ruku, int userId)
        public async Task AgvTransport(string palletNo, string areaNo, string ruku, string url, int userId)
        {
            if (string.IsNullOrEmpty(palletNo))
            try
            {
                throw Oops.Bah("请扫描托盘条码！");
            }
            if (string.IsNullOrEmpty(areaNo) && string.IsNullOrEmpty(ruku))
            {
                throw Oops.Bah("请选择目标区域或入库口！");
            }
            if (!string.IsNullOrEmpty(areaNo) && !string.IsNullOrEmpty(ruku))
            {
                throw Oops.Bah("目标区域和入库口不能同时选择！");
            }
            string EndLocat = string.Empty;//目标位置                

            var log = await Db.Queryable<LogTask>().FirstAsync(w => w.IsDel == "0" && w.PalletNo == palletNo && (w.Status == "0" || w.Status == "1"));
            if (log != null)
            {
                throw Oops.Bah("该托盘已有小车等待执行或正在执行的任务!");
            }
            var stockDetail = await Db.Queryable<DataStockDetail>().FirstAsync(w => w.IsDel == "0" && w.PalletNo == palletNo);
            if (stockDetail == null)
            {
                throw Oops.Bah("托盘上物料库存明细信息不存在,请检查!");
            }
            if (!string.IsNullOrEmpty(areaNo))
            {
                var storageArea = await Db.Queryable<SysStorageArea>().FirstAsync(w => w.IsDel == "0" && w.AreaNo == areaNo);
                if (storageArea == null)
                if (string.IsNullOrEmpty(palletNo))
                {
                    throw Oops.Bah("所选区域信息不存在,请检查!");
                    throw Oops.Bah("请扫描托盘条码！");
                }
                EndLocat = await GetLocat(areaNo, stockDetail.SkuNo, stockDetail.LotNo, palletNo);
            }
            else
            {
                EndLocat = ruku;
            }
            var stock = await Db.Queryable<DataStock>().FirstAsync(w => w.IsDel == "0" && w.SkuNo == stockDetail.SkuNo && w.LotNo == stockDetail.LotNo);
            if (stock == null)
            {
                throw Oops.Bah("托盘上物料库存信息不存在,请检查!");
            }
            if (string.IsNullOrEmpty(stockDetail.LocatNo))
            {
                throw Oops.Bah("托盘储位信息不存在,请检查!");
            }
            if (stockDetail.WareHouseNo != "W02")
            {
                throw Oops.Bah("该托盘未在平库内,请检查!");
            }
            //起始储位信息
            var storageLocat = await Db.Queryable<SysStorageLocat>().FirstAsync(w => w.IsDel == "0" && w.LocatNo == stockDetail.LocatNo);
            if (storageLocat == null)
            {
                throw Oops.Bah("储位信息不存在,请检查!");
            }
            //目标储位信息
            var storageLocatEnd = new SysStorageLocat();
            if (!string.IsNullOrEmpty(areaNo))
            {
                storageLocatEnd = await Db.Queryable<SysStorageLocat>().FirstAsync(w => w.IsDel == "0" && w.LocatNo == EndLocat && w.Flag == "0" && w.Status == "0");
                if (storageLocatEnd == null)
                if (string.IsNullOrEmpty(areaNo) && string.IsNullOrEmpty(ruku))
                {
                    throw Oops.Bah("目标储位信息不存在,请检查!");
                    throw Oops.Bah("请选择目标区域或入库口！");
                }
                if (!string.IsNullOrEmpty(areaNo) && !string.IsNullOrEmpty(ruku))
                {
                    throw Oops.Bah("目标区域和入库口不能同时选择！");
                }
                string EndLocat = string.Empty;//目标位置                

                var log = await Db.Queryable<LogTask>().FirstAsync(w => w.IsDel == "0" && w.PalletNo == palletNo && (w.Status == "0" || w.Status == "1"));
                if (log != null)
                {
                    throw Oops.Bah("该托盘已有等待执行或正在执行的任务!");
                }
                var stockDetail = await Db.Queryable<DataStockDetail>().FirstAsync(w => w.IsDel == "0" && w.PalletNo == palletNo);
                if (stockDetail == null)
                {
                    throw Oops.Bah("托盘上物料库存明细信息不存在,请检查!");
                }
                if (!string.IsNullOrEmpty(areaNo))
                {
                    var storageArea = await Db.Queryable<SysStorageArea>().FirstAsync(w => w.IsDel == "0" && w.AreaNo == areaNo);
                    if (storageArea == null)
                    {
                        throw Oops.Bah("所选区域信息不存在,请检查!");
                    }
                    EndLocat = await GetLocat(areaNo, stockDetail.SkuNo, stockDetail.LotNo, palletNo);
                }
                else
                {
                    EndLocat = ruku;
                }
                var stock = await Db.Queryable<DataStock>().FirstAsync(w => w.IsDel == "0" && w.SkuNo == stockDetail.SkuNo && w.LotNo == stockDetail.LotNo);
                if (stock == null)
                {
                    throw Oops.Bah("托盘上物料库存信息不存在,请检查!");
                }
                if (string.IsNullOrEmpty(stockDetail.LocatNo))
                {
                    throw Oops.Bah("托盘储位信息不存在,请检查!");
                }
                if (stockDetail.WareHouseNo != "W04")
                {
                    throw Oops.Bah("该托盘未在平库内,请检查!");
                }
                //起始储位信息
                var storageLocat = await Db.Queryable<SysStorageLocat>().FirstAsync(w => w.IsDel == "0" && w.LocatNo == stockDetail.LocatNo);
                if (storageLocat == null)
                {
                    throw Oops.Bah("储位信息不存在,请检查!");
                }
                //目标储位信息
                var storageLocatEnd = new SysStorageLocat();
                if (!string.IsNullOrEmpty(areaNo))
                {
                    storageLocatEnd = await Db.Queryable<SysStorageLocat>().FirstAsync(w => w.IsDel == "0" && w.LocatNo == EndLocat && w.Flag == "0" && w.Status == "0");
                    if (storageLocatEnd == null)
                    {
                        throw Oops.Bah("目标储位信息不存在,请检查!");
                    }
                }

                //添加出库任务
                var taskNo = new Common().GetMaxNo("TK");
                var exTask = new LogTask
                {
                    TaskNo = taskNo,
                    Sender = "WMS",
                    Receiver = "AGV",
                    IsSuccess = 0, //是否下发成功 0失败 1成功

                    StartLocat = stockDetail.LocatNo,//起始位置
                    EndLocat = EndLocat,//目标位置
                    PalletNo = palletNo,//托盘码
                    Msg = string.Format("转运任务：{0}=>>{1}", stockDetail.LocatNo, EndLocat),
                    IsSend = 1,//是否可再次下发
                    IsCancel = 1,//是否可取消
                    IsFinish = 1,//是否可完成
                    Type = "2",//任务类型 0 入库任务 1 出库任务  2 移库任务
                    Status = "0",//任务状态0：等待执行1正在执行2执行完成
                    OrderType = "3",//0 入库单 1 出库单  2 盘点单  3 移库单

                    CreateTime = DateTime.Now
                };
                await Db.Insertable(exTask).ExecuteCommandAsync();

                //修改库存明细信息
                //stockDetail.Status = "4";//移库锁定
                //stockDetail.LockQty = stockDetail.Qty;//锁定库存数量
                //await Db.Updateable(stockDetail).ExecuteCommandAsync();
                ////修改库存信息
                //stock.LockQty += (decimal)stockDetail.Qty;
                //await Db.Updateable(stock).ExecuteCommandAsync();

                //修改起始储位地址状态
                storageLocat.Status = "5";//0：空储位 1：有物品 2：入库中 3：出库中 4：移入中 5：移出中 
                await Db.Updateable(storageLocat).ExecuteCommandAsync();

                //修改目标储位地址状态
                if (storageLocatEnd != null)
                {
                    storageLocatEnd.Status = "4";//0：空储位 1：有物品 2：入库中 3：出库中 4：移入中 5：移出中 
                    await Db.Updateable(storageLocatEnd).ExecuteCommandAsync();
                }
                //添加操作日志记录
                var k = new OperationCrServer().AddLogOperationCr("PDA模块", "AGV转运", palletNo, "移库", $"PDA呼叫小车对托盘号：{palletNo}发起转运", userId);

                var outDto = new List<OutCommandDto>();
                outDto.Add(new OutCommandDto()
                {
                    PalletNo = exTask.PalletNo,//托盘号
                    StartLocate = exTask.StartLocat, // 起始位置
                    StartRoadway = storageLocat.RoadwayNo,//其实巷道
                    EndLocate = EndLocat, // 目标位置 
                    TaskNo = exTask.TaskNo, // 任务号
                    TaskType = "2",// 任务类型 (出库)0入 1出 2移 
                    OutMode = "",  //出库口 
                    Order = 1

                });

                // 正式运行程序放开
                var list2 = outDto.Select(m => m.TaskNo).ToList();
                var jsonData = JsonConvert.SerializeObject(outDto);
                string response = "";

                try
                {
                    var time1 = DateTime.Now;//发送时间 .ToString("yyyy-MM-dd HH:mm:ss")
                    //response = HttpHelper.DoPost(url, jsonData, "下发给WCS出库命令", "WCS");
                    var time2 = DateTime.Now;//返回时间 .ToString("yyyy-MM-dd HH:mm:ss")

                    //////解析返回数据 
                    //var wcsModel = JsonConvert.DeserializeObject<WcsModel>(response);
                    //if (wcsModel.StatusCode == 0)
                    //{
                    //    //更改任务的发送返回时间//
                    new TaskServer().EditTaskIssueOk(list2, time1, time2);
                    //}
                    //if (wcsModel.StatusCode == -1)
                    //{
                    //    new TaskServer().EditTaskIssueNo(list2, time1, time2, wcsModel.Msg);
                    //    throw new Exception(wcsModel.Msg);
                    //}
                }
                catch (Exception ex)
                {
                    throw new Exception(ex.Message);
                }

            }

            //添加出库任务
            var taskNo = new Common().GetMaxNo("TK");
            var exTask = new LogTask
            catch (Exception e)
            {
                TaskNo = taskNo,
                Sender = "WMS",
                Receiver = "AGV",
                IsSuccess = 0, //是否下发成功 0失败 1成功

                StartLocat = stockDetail.LocatNo,//起始位置
                EndLocat = EndLocat,//目标位置
                PalletNo = palletNo,//托盘码
                Msg = string.Format("转运任务：{0}=>>{1}", stockDetail.LocatNo, EndLocat),
                IsSend = 1,//是否可再次下发
                IsCancel = 1,//是否可取消
                IsFinish = 1,//是否可完成
                Type = "2",//任务类型 0 入库任务 1 出库任务  2 移库任务
                Status = "0",//任务状态0：等待执行1正在执行2执行完成
                OrderType = "3",//0 入库单 1 出库单  2 盘点单  3 移库单

                CreateTime = DateTime.Now
            };
            await Db.Insertable(exTask).ExecuteCommandAsync();

            //修改库存明细信息
            stockDetail.Status = "4";//移库锁定
            stockDetail.LockQty = stockDetail.Qty;//锁定库存数量
            await Db.Updateable(stockDetail).ExecuteCommandAsync();
            //修改库存信息
            stock.LockQty += (decimal)stockDetail.Qty;
            await Db.Updateable(stock).ExecuteCommandAsync();

            //修改起始储位地址状态
            storageLocat.Status = "5";//0：空储位 1：有物品 2：入库中 3：出库中 4：移入中 5：移出中 
            await Db.Updateable(storageLocat).ExecuteCommandAsync();

            //修改目标储位地址状态
            if (storageLocatEnd != null)
            {
                storageLocatEnd.Status = "4";//0：空储位 1：有物品 2：入库中 3：出库中 4：移入中 5：移出中 
                await Db.Updateable(storageLocatEnd).ExecuteCommandAsync();
                throw new Exception(e.Message);
            }
            //添加操作日志记录
            var k = new OperationCrServer().AddLogOperationCr("PDA模块", "AGV转运", palletNo, "移库", $"PDA呼叫小车对托盘号：{palletNo}发起转运", userId);

            #region 呼叫小车代码

            #endregion
        }
        /// <summary>
        /// agv转运呼叫小车取货