using System; using System.Collections.Generic; using System.ComponentModel.Design; using System.Linq; using System.Linq.Expressions; using System.Text; using Model.InterFaceModel; using Model.ModelDto.BllCheckDto; using Model.ModelDto.DataDto; using Model.ModelVm; using Model.ModelVm.BllCheckVm; using Newtonsoft.Json; using SqlSugar; using SqlSugar.Extensions; using Utility.Tools; using WMS.BLL.LogServer; using WMS.BLL.SysServer; using WMS.DAL; using WMS.Entity.BllAsnEntity; using WMS.Entity.BllCheckEntity; using WMS.Entity.BllSoEntity; using WMS.Entity.Context; using WMS.Entity.DataEntity; using WMS.Entity.LogEntity; using WMS.Entity.SysEntity; using WMS.IBLL.IBllCheckServer; namespace WMS.BLL.BllCheckServer { public class StockCheckServer : DbHelper, IStockCheckServer { private static readonly SqlSugarScope Db = DataContext.Db; public StockCheckServer() : base(Db) { } //获取盘点单据 public List GetStockCheckList(string crNo, string status, string palletNo, string skuNo, string skuName, string lotNo, string startTime, string endTime, int page, int limit, out int count) { try { var strList = new List(); if (!string.IsNullOrWhiteSpace(palletNo) || !string.IsNullOrWhiteSpace(skuNo) || !string.IsNullOrWhiteSpace(skuName) || !string.IsNullOrWhiteSpace(lotNo)) { Expression> demo = Expressionable.Create() .AndIF(!string.IsNullOrWhiteSpace(palletNo), m => m.PalletNo.Contains(palletNo.Trim())) .AndIF(!string.IsNullOrWhiteSpace(skuNo), m => m.SkuNo.Contains(skuNo.Trim())) .AndIF(!string.IsNullOrWhiteSpace(skuName), m => m.SkuName.Contains(skuName.Trim())) .AndIF(!string.IsNullOrWhiteSpace(lotNo), m => m.LotNo.Contains(lotNo.Trim())) .And(m => m.IsDel == "0") .ToExpression();//注意 这一句 不能少 var detailList = Db.Queryable().Where(demo).Select(m => m.CRNo).Distinct().ToList(); strList = detailList; } Expression> item = Expressionable.Create() .AndIF(!string.IsNullOrWhiteSpace(crNo), m => m.CRNo.Contains(crNo.Trim())) .AndIF(!string.IsNullOrWhiteSpace(status), m => m.Status == int.Parse(status)) .AndIF(!string.IsNullOrWhiteSpace(startTime), m => m.CheckDate >= Convert.ToDateTime(startTime)) .AndIF(!string.IsNullOrWhiteSpace(endTime), m => m.CheckDate <= Convert.ToDateTime(endTime).AddDays(1)) .AndIF(!string.IsNullOrWhiteSpace(palletNo), m => strList.Contains(m.CRNo)) .AndIF(!string.IsNullOrWhiteSpace(skuNo), m => strList.Contains(m.CRNo)) .AndIF(!string.IsNullOrWhiteSpace(skuName), m => strList.Contains(m.CRNo)) .AndIF(!string.IsNullOrWhiteSpace(lotNo), m => strList.Contains(m.CRNo)) .And(m => m.IsDel == "0") .ToExpression();//注意 这一句 不能少 var total = 0; var list = Db.Queryable().Where(item) .LeftJoin((a, b) => a.AuditUser == b.Id) .LeftJoin((a, b, c) => a.CreateUser == c.Id) .LeftJoin((a, b, c, d) => a.CreateUser == d.Id) .Select((a, b, c, d) => new StockCheckDto() { Id = a.Id, CrNo = a.CRNo, CheckDate = a.CheckDate, CompleteDate = a.CompleteDate, Status = a.Status, Origin = a.Origin, AuditStatusNo = a.AuditStatusNo, IsDoubleCheck = a.IsDoubleCheck, AuditUserName = b.RealName, AuditTime = a.AuditTime, Demo = a.Demo, CreateUserName = c.RealName, UpdateUserName = d.RealName, CreateTime = a.CreateTime, UpdateTime = a.UpdateTime, }).OrderByDescending(a => a.CreateTime).ToOffsetPage(page, limit, ref total); count = total; return list; } catch (Exception e) { throw new Exception(e.Message); } } //获取盘点单据明细 public List GetStockCheckDetailList(string crNo, int page, int limit, out int count) { try { var total = 0; var list = Db.Queryable().Where(m => m.IsDel == "0" && m.CRNo == crNo) .LeftJoin((a, b) => a.CreateUser == b.Id) .LeftJoin((a, b, c) => a.UpdateUser == c.Id) .Select((a, b, c) => new StockCheckDetailDto() { Id = a.Id, CrNo = a.CRNo, PalletNo = a.PalletNo, Qty = a.Qty, RealQty = a.RealQty, CheckResult = a.CheckResult, Status = a.Status, SkuNo = a.SkuNo, SkuName = a.SkuName, Standard = a.Standard, LotNo = a.LotNo, LotText = a.LotText, SupplierLot = a.SupplierLot, CreateUserName = b.RealName, UpdateUserName = c.RealName, CreateTime = a.CreateTime, UpdateTime = a.UpdateTime, }).ToOffsetPage(page, limit, ref total); count = total; return list; } catch (Exception e) { throw new Exception(e.Message); } } //获取库存明细信息（盘点选择明细数据源） public List GetCheckStockDetailList(string houseNo, string roadwayNo, string locateNo, string msg, int page, int limit, out int count) { try { Expression> item = Expressionable.Create() .AndIF(!string.IsNullOrWhiteSpace(houseNo), m => m.WareHouseNo == houseNo) .AndIF(!string.IsNullOrWhiteSpace(roadwayNo), m => m.RoadwayNo == roadwayNo) .AndIF(!string.IsNullOrWhiteSpace(locateNo), m => m.LocatNo == locateNo) .AndIF(!string.IsNullOrWhiteSpace(msg), m => m.SkuNo.Contains(msg.Trim()) || m.SkuName.Contains(msg.Trim()) || m.LotNo.Contains(msg.Trim())) .And(m => m.IsDel == "0" && m.SkuNo != "100099" && m.Status == "0") .ToExpression();//注意 这一句 不能少 var total = 0; var list = Db.Queryable().Where(item).GroupBy(m => new { m.SkuNo, m.SkuName, m.Standard, m.LotNo, m.LotText, m.SupplierLot, m.LocatNo, m.PalletNo }) .Select(a => new StockDetailDto() { SkuNo = a.SkuNo, SkuName = a.SkuName, Standard = a.Standard, LotNo = a.LotNo, LotText = a.LotText, SupplierLot = a.SupplierLot, Qty = SqlFunc.AggregateSum(a.Qty), LocatNo = a.LocatNo, PalletNo = a.PalletNo }).ToOffsetPage(page, limit, ref total); count = total; return list; } catch (Exception e) { throw new Exception(e.Message); } } public EditStockCheckDto GetStockCheckDetailById(string crNo) { try { var notify = Db.Queryable().First(m => m.CRNo == crNo && m.IsDel == "0"); if (notify == null) { throw new Exception($"未查询到{crNo}的盘点单据信息"); } var detail = Db.Queryable().Where(m => m.CRNo == crNo && m.IsDel == "0").Select(m => new EditStockCheckDetailDto() { SkuNo = m.SkuNo, SkuName = m.SkuName, Standard = m.Standard, LotNo = m.LotNo, LotText = m.LotText, SupplierLot = m.SupplierLot, Qty = m.Qty, PalletNo = m.PalletNo }).ToList(); var data = new EditStockCheckDto() { CrNo = crNo, Detail = detail }; return data; } catch (Exception e) { throw new Exception(e.Message); } } //添加盘点单、编辑盘点单 public void AddEditStockCheck(AddEditStockCheckVm model, int userId) { try { if (model.Detail.Count == 0) { throw new Exception("盘点明细不能为空"); } Db.BeginTran(); var time = DateTime.Now; //添加 if (string.IsNullOrWhiteSpace(model.CrNo)) { var num = Db.Queryable().Count(m => m.IsDel == "0" && (m.Status == 0 || m.Status == 1)); if (num > 0) { throw new Exception("已有等待执行的盘点单据请先完成或删除"); } var crNo = new Common().GetMaxNo("CR"); var stockDetail = Db.Queryable().Where(m => m.IsDel == "0"); var check = new BllStockCheck() { CRNo = crNo, Origin = "0", Status = 0, CreateUser = userId, CreateTime = time }; var list = new List(); foreach (var item in model.Detail) { var detail = new BllStockCheckDetail() { CRNo = crNo, PalletNo = item.PalletNo, Qty = item.Qty, Status = 0, //0：未盘 1：已盘 2：已调整 SkuNo = item.SkuNo, SkuName = item.SkuName, Standard = item.Standard, LotNo = item.LotNo, LotText = item.LotText, SupplierLot = item.SupplierLot, CreateUser = userId, CreateTime = time }; list.Add(detail); var sd = stockDetail.First(m => m.SkuNo == item.SkuNo && m.LotNo == item.LotNo && m.PalletNo == item.PalletNo && m.Status == "0"); sd.Status = "3"; Db.Updateable(sd).ExecuteCommand(); } Db.Insertable(check).ExecuteCommand(); Db.Insertable(list).ExecuteCommand(); //添加操作日志记录 var k = new OperationCrServer().AddLogOperationCr("库内作业", "盘点单据", crNo, "添加", $"添加了单据号为{crNo}的盘点单信息", userId); } else //编辑 { var check = Db.Queryable().First(m => m.IsDel == "0" && m.CRNo == model.CrNo); if (check == null) { throw new Exception("未查询到盘点单据的信息"); } check.UpdateUser = userId; check.UpdateTime = time; Db.Updateable(check).ExecuteCommand(); //盘点明细信息 var checkDetail = Db.Queryable().Where(m => m.IsDel == "0" && m.CRNo == model.CrNo).ToList(); //删除旧的 foreach (var d in checkDetail) { var mq = model.Detail.Where(o => o.SkuNo == d.SkuNo && o.LotNo == d.LotNo && o.PalletNo == d.PalletNo).ToList(); if (mq.Any()) //如果有这个物料及批次则跳过 { continue; } var sd = Db.Queryable().Where(m => m.IsDel == "0" && m.SkuNo == d.SkuNo && m.LotNo == d.LotNo && m.PalletNo == d.PalletNo && m.Status == "3").ToList(); foreach (var s in sd) { s.Status = "0"; } d.IsDel = "1"; d.UpdateUser = userId; d.UpdateTime = time; //修改库存明细的状态（解除盘点锁定） Db.Updateable(sd).ExecuteCommand(); Db.Updateable(d).ExecuteCommand(); } //添加与修改 var list = new List(); foreach (var item in model.Detail) { var de = checkDetail.FirstOrDefault(m => m.PalletNo == item.PalletNo && m.SkuNo == item.SkuNo && m.LotNo == item.LotNo); //新加项 if (de == null) { var detail = new BllStockCheckDetail() { CRNo = model.CrNo, PalletNo = item.PalletNo, Qty = item.Qty, Status = 0, //0：未盘 1：已盘 2：已调整 SkuNo = item.SkuNo, SkuName = item.SkuName, Standard = item.Standard, LotNo = item.LotNo, LotText = item.LotText, SupplierLot = item.SupplierLot, CreateUser = userId, CreateTime = time }; list.Add(detail); var sd = Db.Queryable().Where(m => m.IsDel == "0" && m.SkuNo == item.SkuNo && m.LotNo == item.LotNo && m.PalletNo == item.PalletNo && m.Status == "0").ToList(); foreach (var s in sd) { s.Status = "3"; } Db.Updateable(sd).ExecuteCommand(); } else if (de.Qty != item.Qty) { de.Qty = item.Qty; de.UpdateUser = userId; de.UpdateTime = time; Db.Updateable(de).ExecuteCommand(); } } if (list.Count > 0) { Db.Insertable(list).ExecuteCommand(); } //添加操作日志记录 var k = new OperationCrServer().AddLogOperationCr("库内作业", "盘点单据", model.CrNo, "编辑", $"编辑了单据号为{model.CrNo}的盘点单信息", userId); } Db.CommitTran(); } catch (Exception e) { Db.RollbackTran(); throw new Exception(e.Message); } } //删除盘点单 public void DelStockCheck(int id, int userId) { try { var notice = Db.Queryable().First(m => m.IsDel == "0" && m.Id == id); if (notice == null || notice.Status != 0) { throw new Exception("未查询到状态为等待执行的盘点单信息"); } var detail = Db.Queryable().Where(m => m.IsDel == "0" && m.CRNo == notice.CRNo).ToList(); if (detail.Count == 0) { throw new Exception("未查询到盘点单据明细信息"); } Db.BeginTran(); var time = DateTime.Now; foreach (var d in detail) { d.IsDel = "1"; d.UpdateTime = time; d.UpdateUser = userId; var item = Db.Queryable().Where(m => m.IsDel == "0" && m.PalletNo == d.PalletNo && m.SkuNo == d.SkuNo && m.LotNo == d.LotNo && m.Status == "3").ToList(); foreach (var i in item) { i.Status = "0"; } Db.Updateable(item).ExecuteCommand(); } notice.IsDel = "1"; notice.UpdateTime = time; notice.UpdateUser = userId; Db.Updateable(notice).ExecuteCommand(); Db.Updateable(detail).ExecuteCommand(); //添加操作日志记录 var k = new OperationCrServer().AddLogOperationCr("库内作业", "盘点单据", notice.CRNo, "删除", $"删除了单据号为{notice.CRNo}的盘点单信息", userId); Db.CommitTran(); } catch (Exception e) { Db.RollbackTran(); throw new Exception(e.Message); } } /// /// 维护盘点单备注信息 /// /// /// /// public void EditNoticeDemo(int id, string demo, int userId) { try { var notice = Db.Queryable().First(m => m.IsDel == "0" && m.Id == id); if (notice == null) { throw new Exception("未查询到盘点单据信息"); } notice.Demo = demo + "".Trim(); notice.UpdateUser = userId; notice.UpdateTime = DateTime.Now; int i = Db.Updateable(notice).ExecuteCommand(); if (i > 0) { //添加操作日志 new OperationCrServer().AddLogOperationCr("库内作业", "盘点单据", notice.CRNo, "编辑", $"编辑了单据号为{notice.CRNo}的备注信息", userId); } } catch (Exception ex) { throw new Exception(ex.Message); } } //调整库存 public bool StockAdjust(int id, int userId) { try { //盘点信息 var notice = Db.Queryable().First(m => m.IsDel == "0" && m.Id == id); if (notice == null || notice.Status != 2) { throw new Exception("未查询到状态为盘点完成的盘点单信息"); } if (notice == null || notice.Status != 2) { throw new Exception("未查询到状态为盘点完成的盘点单信息"); } //盘点明细 var detail = Db.Queryable().Where(m => m.IsDel == "0" && m.CRNo == notice.CRNo).ToList(); if (detail.Count == 0) { throw new Exception("未查询到盘点单据明细信息"); } //开启事务 Db.BeginTran(); var stock = Db.Queryable().Where(m => m.IsDel == "0").ToList();//库存表 var stockDetail = Db.Queryable().Where(m => m.IsDel == "0").ToList();//库存明细 var stockBox = Db.Queryable().Where(m => m.IsDel == "0").ToList();//库存箱支明细 var materialList = Db.Queryable().Where(m => m.IsDel == "0").ToList();//物料信息 var packagList = Db.Queryable().Where(m => m.IsDel == "0").ToList();//包装信息 var time = DateTime.Now; //盘点记录 var checkLog = Db.Queryable().Where(m => m.IsDel == "0" && m.CRNo == notice.CRNo).ToList(); if (checkLog.Count(m => m.CheckResult == null) > 0) { throw new Exception($"{notice.CRNo}单据中含有未盘点的信息，请核实!"); } List boxQtyList = new List(); #region#此段代码为了判断盘点后箱子是否零头箱 //循环盘点明细, foreach (var d in detail) { var demo = checkLog.Where(m => m.PalletNo == d.PalletNo).ToList();//盘点记录 foreach (var l in demo) { var boxInfo = boxQtyList.FirstOrDefault(m => m.boxNo == l.BoxNo); if (boxInfo == null) { var totalRealQty = checkLog.Where(m => m.PalletNo == d.PalletNo && m.BoxNo == l.BoxNo).Sum(m => m.RealQty); BoxQtyInfo boxQtyInfo = new BoxQtyInfo(); boxQtyInfo.boxNo = l.BoxNo; boxQtyInfo.realQty = (int)totalRealQty; boxQtyList.Add(boxQtyInfo); } } } foreach (var item in boxQtyList) { var stockBoxInfo = stockBox.FirstOrDefault(m => m.BoxNo == item.boxNo);//库存箱支明细 if (stockBoxInfo == null) { continue; } if (item.realQty < stockBoxInfo.FullQty) { item.bitBoxMark = "1"; } else { item.bitBoxMark = "0"; } var stockBoxList = stockBox.Where(m => m.BoxNo == item.boxNo).ToList(); foreach (var s in stockBoxList) { s.BitBoxMark = item.bitBoxMark; Db.Updateable(s).ExecuteCommand(); } } #endregion //循环盘点明细 foreach (var d in detail) { var demo = checkLog.Where(m => m.PalletNo == d.PalletNo).ToList();//盘点记录 //循环盘点记录 foreach (var l in demo) { var sku = Db.Queryable().First(a => a.IsDel == "0" && a.SkuNo == l.SkuNo); if (l.CheckResult == 0)//正常 { if (sku.Type != "4") { var de3 = stockBox.First(m => m.BoxNo == l.BoxNo && m.BoxNo3 == l.BoxNo3); if (de3 == null) { throw new Exception($"未查询到{l.BoxNo}箱中{l.BoxNo3}库存箱码的信息"); } var de2 = stockDetail.First(m => m.Id == de3.StockDetailId); if (de2 == null) { throw new Exception($"未查询到{l.BoxNo}箱中{l.BoxNo3}库存明细的信息"); } de2.Status = "0";//将库存明细状态改为待分配 Db.Updateable(de2).ExecuteCommand(); } else { var de2 = stockDetail.First(m => m.PalletNo == l.PalletNo && m.SkuNo == l.SkuNo); if (de2 == null) { throw new Exception($"未查询到{l.PalletNo}的库存明细的信息"); } de2.Status = "0";//将库存明细状态改为待分配 Db.Updateable(de2).ExecuteCommand(); } } else if (l.CheckResult == 1)//盘亏 { if (sku.Type != "4") { var de3 = stockBox.First(m => m.BoxNo == l.BoxNo && m.BoxNo3 == l.BoxNo3); if (de3 == null) { throw new Exception($"未查询到{l.BoxNo}箱中{l.BoxNo3}库存箱码的信息"); } var de2 = stockDetail.First(m => m.Id == de3.StockDetailId); if (de2 == null) { throw new Exception($"未查询到{l.BoxNo}箱中{l.BoxNo3}库存明细的信息"); } de2.Status = "0"; de2.Qty -= de3.Qty; var de = stock.First(m => m.SkuNo == l.SkuNo && m.LotNo == l.LotNo); if (de == null) { throw new Exception($"未查询到物料{l.SkuNo}批次{l.LotNo}的总库存的信息"); } de.Qty -= de3.Qty; Db.Updateable(de).ExecuteCommand(); Db.Updateable(de2).ExecuteCommand(); Db.Deleteable(de3).ExecuteCommand(); } else { var de2 = stockDetail.First(m => m.PalletNo == l.PalletNo && m.SkuNo == l.SkuNo); if (de2 == null) { throw new Exception($"未查询到{l.PalletNo}的库存明细的信息"); } de2.Status = "0"; de2.Qty = l.RealQty; var de = stock.First(m => m.SkuNo == l.SkuNo && m.LotNo == l.LotNo); if (de == null) { throw new Exception($"未查询到物料{l.SkuNo}批次{l.LotNo}的总库存的信息"); } de.Qty -= Convert.ToDecimal(l.Qty - l.RealQty); Db.Updateable(de).ExecuteCommand(); Db.Updateable(de2).ExecuteCommand(); } } else if (l.CheckResult == 2)//盘盈 { var stockDetailInfo = stockDetail.First(m => m.PalletNo == d.PalletNo && m.SkuNo == d.SkuNo && m.LotNo == d.LotNo);//库存明细 if (sku.Type != "4") { var stockBoxInfo = stockBox.First(m => m.StockDetailId == stockDetailInfo.Id);//库存箱支明细 var boxInfo = boxQtyList.First(m => m.boxNo == l.BoxNo);//找到对应箱子是否零箱 //添加库存箱支信息 var databox = new DataBoxInfo { StockDetailId = stockDetailInfo.Id, BindNo = stockBoxInfo.BindNo, BoxNo = l.BoxNo, BoxNo2 = l.BoxNo2, BoxNo3 = l.BoxNo3, PalletNo = l.PalletNo, Qty = (decimal)l.RealQty, FullQty = stockBoxInfo.FullQty,//满箱数量 Status = "2", SkuNo = l.SkuNo, SkuName = l.SkuName, LotNo = l.LotNo, LotText = l.LotText, Standard = l.Standard, SupplierLot = l.SupplierLot, InspectMark = stockBoxInfo.InspectMark, InspectStatus = stockBoxInfo.InspectStatus, ProductionTime = stockBoxInfo.ProductionTime, BitBoxMark = boxInfo.bitBoxMark, }; Db.Insertable(databox).ExecuteCommand(); //库存明细增加数量 stockDetailInfo.Qty += (int)l.RealQty; } else { //库存明细增加数量 stockDetailInfo.Qty = (int)l.RealQty; } stockDetailInfo.Status = "0"; Db.Updateable(stockDetailInfo).ExecuteCommand(); //库存增加数量 var de = stock.First(m => m.SkuNo == l.SkuNo && m.LotNo == l.LotNo); if (de == null) { throw new Exception($"未查询到{l.BoxNo}箱中{l.BoxNo3}库存的信息"); } if (sku.Type != "4") { de.Qty += (int)l.RealQty; } else { de.Qty += (int)(l.RealQty - l.Qty); } Db.Updateable(de).ExecuteCommand(); } } //修改盘点明细 d.Status = 4;//状态 d.UpdateTime = time; d.UpdateUser = userId; //盘点结果 if (d.Qty == d.RealQty) { d.CheckResult = 0; if (demo.Count(m => m.CheckResult == 1 || m.CheckResult == 2) > 0) { d.CheckResult = 3; } } if (d.Qty < d.RealQty) { d.CheckResult = 2; } if (d.Qty > d.RealQty) { d.CheckResult = 1; } Db.Updateable(d).ExecuteCommand(); #region 添加判断盘点完托盘是否是零托 var material = materialList.FirstOrDefault(m => m.SkuNo == d.SkuNo); if (material == null) { throw new Exception($"未查询到{d.SkuNo}的物料信息；"); } var pack = packagList.FirstOrDefault(m => m.PackagNo == material.PackagNo); if (pack == null) { throw new Exception($"未查询到{d.SkuNo}的包装信息；"); } var pNum = 0;//托盘物品数量 var bNum = 0;//箱物品数量 if (pack.L5Num.HasValue) { pNum = Convert.ToInt32(pack.L5Num); } else if (pack.L4Num.HasValue) { pNum = Convert.ToInt32(pack.L4Num); } else if (pack.L3Num.HasValue) { pNum = Convert.ToInt32(pack.L3Num); } else if (pack.L2Num.HasValue) { pNum = Convert.ToInt32(pack.L2Num); } else if (pack.L1Num.HasValue) { pNum = Convert.ToInt32(pack.L1Num); } if (pNum == 0) { throw new Exception("未查询到物料包装托箱关系信息"); } var stockDetailInfo2 = stockDetail.First(m => m.PalletNo == d.PalletNo && m.SkuNo == d.SkuNo && m.LotNo == d.LotNo);//库存明细 if (stockDetailInfo2.Qty >= pNum) { stockDetailInfo2.BitPalletMark = "0"; } if (stockDetailInfo2.Qty < pNum) { stockDetailInfo2.BitPalletMark = "1"; } Db.Updateable(stockDetailInfo2).ExecuteCommand(); #endregion } //修该盘点信息 notice.Status = 3;//状态 notice.UpdateTime = time; notice.UpdateUser = userId; Db.Updateable(notice).ExecuteCommand(); //添加操作日志记录 var k = new OperationCrServer().AddLogOperationCr("库内作业", "盘点单据", notice.CRNo, "调整单据", $"调整了单据号为{notice.CRNo}的盘点单信息", userId); //提交事务 Db.CommitTran(); return true; } catch (Exception e) { //回滚事务 Db.RollbackTran(); throw new Exception(e.Message); } } //调整库存-针对异常生成的 public bool StockAdjustAuto(int id, int userId) { try { //盘点表 var notice = Db.Queryable().First(m => m.IsDel == "0" && m.Id == id); if (notice == null || notice.Status != 2) { throw new Exception("未查询到状态为盘点完成的盘点单信息"); } //盘点明细 var detail = Db.Queryable().Where(m => m.IsDel == "0" && m.CRNo == notice.CRNo).ToList(); if (detail.Count == 0) { throw new Exception("未查询到盘点单据明细信息"); } //开启事务 Db.BeginTran(); var stock = Db.Queryable().Where(m => m.IsDel == "0");//库存 var stockDetail = Db.Queryable().Where(m => m.IsDel == "0");//库存明细 var stockBox = Db.Queryable().Where(m => m.IsDel == "0");//库存箱支信息 var time = DateTime.Now; //盘点记录 var checkLog = Db.Queryable().Where(m => m.IsDel == "0" && m.CRNo == notice.CRNo); if (checkLog.Count(m => m.CheckResult == null) > 0) { throw new Exception($"{notice.CRNo}单据中含有未盘点的信息，请核实!"); } foreach (var d in detail) { //托盘绑定表 var palletBind = Db.Queryable().First(m => m.PalletNo == d.PalletNo); //储位表 var storageLocat = Db.Queryable().First(m => m.LocatNo == palletBind.LocatNo); if (storageLocat != null && storageLocat.Flag == "1") { //将储位标志Flag修改为：0：正常 storageLocat.Flag = "0"; storageLocat.UpdateUser = userId; storageLocat.UpdateTime = time; Db.Updateable(storageLocat).ExecuteCommand(); } //条码管理(托盘) var pallets = Db.Queryable().First(m => m.PalletNo == d.PalletNo); if (pallets != null && pallets.Status == "1") { //将托盘号状态变更为 0 未使用 pallets.Status = "0"; pallets.UpdateUser = userId; pallets.UpdateTime = time; Db.Updateable(pallets).ExecuteCommand(); } //盘点记录 var demo = checkLog.Where(m => m.PalletNo == d.PalletNo).ToList(); foreach (var l in demo) { if (l.CheckResult == 0)//正常 { continue; } else if (l.CheckResult == 1)//盘亏 { //物理删除库存箱支信息 var de3 = stockBox.First(m => m.BoxNo == l.BoxNo && m.BoxNo3 == l.BoxNo3); if (de3 == null) { throw new Exception($"未查询到{l.BoxNo}箱中{l.BoxNo3}库存箱码的信息"); } Db.Deleteable(de3).ExecuteCommand(); //物理删除库存明细 var de2 = stockDetail.First(m => m.Id == de3.StockDetailId); if (de2 == null) { throw new Exception($"未查询到{l.BoxNo}箱中{l.BoxNo3}库存明细的信息"); } Db.Deleteable(de2).ExecuteCommand(); //更改库存数量和锁定数量 var de = stock.First(m => m.SkuNo == l.SkuNo && m.LotNo == l.LotNo); if (de == null) { throw new Exception($"未查询到物料{l.SkuNo}批次{l.LotNo}的总库存的信息"); } de.Qty -= de3.Qty; de.LockQty -= de3.Qty; Db.Updateable(de).ExecuteCommand(); } } //将盘点明细状态改为 已调整 d.Status = 4; d.UpdateTime = time; d.UpdateUser = userId; Db.Updateable(d).ExecuteCommand(); } //将盘点总表状态改为 生成调整 notice.Status = 3; notice.UpdateTime = time; notice.UpdateUser = userId; Db.Updateable(notice).ExecuteCommand(); //添加操作日志记录 var k = new OperationCrServer().AddLogOperationCr("库内作业", "盘点单据", notice.CRNo, "调整单据", $"调整了单据号为{notice.CRNo}的盘点单信息", userId); //提交事务 Db.CommitTran(); return true; } catch (Exception e) { Db.RollbackTran(); throw new Exception(e.Message); } } //盘点下发出库 public List CheckOutHouse(string crNo, string outMode, int userId, string url, out string str) { try { #region 集合 var outDtoList = new List(); //出库数据的集合 //记录错误信息的集合 var flagList = new List();//1:当前要出库的储位正在移出、2 出库的托盘储位信息错误(在储位表中未查询到)、3储位损坏不能出库、4 要出库的托盘正在入库 #endregion var com = new Common(); //assign.IsHavePyTask(); var notice = Db.Queryable().First(m => m.CRNo == crNo && m.IsDel == "0"); if (notice == null) { throw new Exception($"未找到{crNo}盘点单信息"); } //所有要出库的盘点明细信息(等待的信息和待拣货的信息) var list = Db.Queryable().Where(a => a.IsDel == "0" && a.CRNo == crNo && a.Status == 0).ToList(); if (list.Count == 0) //判断是否有需要下发的盘点明细 { throw new Exception("当前盘点单据无需要下发的托盘"); } #region //要出库的托盘集合 var outLpnList = list.Select(m => m.PalletNo).Distinct().ToList(); //要出库的明细集合 var outStockDetail = Db.Queryable().Where(m => m.IsDel == "0" && outLpnList.Contains(m.PalletNo)).ToList(); var outStockBox = Db.Queryable().Where(m => m.IsDel == "0" && outLpnList.Contains(m.PalletNo)).ToList(); //获取物料信息 var skuNo = Db.Queryable().Where(a => a.IsDel == "0" && a.Type == "4").Select(a => a.SkuNo).ToList(); var time = DateTime.Now; Db.BeginTran(); try { //循环盘点明细的信息生成出库任务 foreach (var item in list) { if (item.Status == 0) { var logList = new List(); //判断是否为无码物料 if (skuNo.Contains(item.SkuNo)) { var de = outStockDetail.First(m => m.IsDel == "0" && m.SkuNo == item.SkuNo && m.LotNo == item.LotNo && m.PalletNo == item.PalletNo); var checkLog = new BllStockCheckLog() { CRNo = item.CRNo, PalletNo = item.PalletNo, BoxNo = "", BoxNo2 = "", BoxNo3 = "", Qty = (int?)de.Qty, SkuNo = de.SkuNo, SkuName = de.SkuName, Standard = de.Standard, LotNo = de.LotNo, LotText = de.LotText, SupplierLot = de.SupplierLot, CreateUser = userId, CreateTime = time }; logList.Add(checkLog); } else { var de = outStockDetail.Where(m => m.SkuNo == item.SkuNo && m.LotNo == item.LotNo && m.PalletNo == item.PalletNo).Select(m => m.Id).ToList(); var bo = outStockBox.Where(m => de.Contains(m.StockDetailId)).ToList(); foreach (var b in bo) { var checkLog = new BllStockCheckLog() { CRNo = item.CRNo, PalletNo = item.PalletNo, BoxNo = b.BoxNo, BoxNo2 = b.BoxNo2, BoxNo3 = b.BoxNo3, Qty = b.Qty, SkuNo = b.SkuNo, SkuName = b.SkuName, Standard = b.Standard, LotNo = b.LotNo, LotText = b.LotText, SupplierLot = b.SupplierLot, CreateUser = userId, CreateTime = time }; logList.Add(checkLog); } } //生成盘点记录 Db.Insertable(logList).ExecuteCommand(); } // 储位号 var locateNo = outStockDetail.First(m => m.PalletNo == item.PalletNo && m.SkuNo == item.SkuNo && m.LotNo == item.LotNo).LocatNo; #region 判断 //判断托盘是否在库内 if (string.IsNullOrWhiteSpace(locateNo)) { var de = outStockDetail.First(m => m.SkuNo == item.SkuNo && m.LotNo == item.LotNo && m.PalletNo == item.PalletNo); //判断是否是零箱库，当前明细信息直接更新出库完成 if (de != null && de.WareHouseNo == "W02") { //盘点明细状态改为待盘点 item.Status = 2; Db.Updateable(item).ExecuteCommand(); //盘点信息修改 if (notice.Status == 0) { notice.CheckDate = DateTime.Now; notice.Status = 1; notice.UpdateUser = userId; notice.UpdateTime = time; Db.Updateable(notice).ExecuteCommand(); } //库存中当前托盘的信息 var stockDetail = Db.Queryable().Where(m => m.PalletNo == item.PalletNo).ToList(); foreach (var s in stockDetail) { s.LocatNo = "";//储位更改（改为空） s.WareHouseNo = "";//所属仓库更改（改为空） s.RoadwayNo = "";//所属巷道更改（改为空） s.AreaNo = "";//所属区域更改（改为空） Db.Updateable(s).ExecuteCommand(); } flagList.Add(5); continue; } //判断托盘是否在入库中 var imBl = com.GetImTask(item.PalletNo); if (imBl != null) { flagList.Add(4); continue; } //判断是否是已经出过库又回库（状态为待拣货的 1） if (item.Status == 0) { //如果不在仓库内，当前明细信息直接更新出库完成 item.Status = 2;//状态 Db.Updateable(item).ExecuteCommand(); if (notice.Status == 0) { notice.CheckDate = DateTime.Now; notice.Status = 1; notice.UpdateUser = userId; notice.UpdateTime = time; Db.Updateable(notice).ExecuteCommand(); } } continue; } //当前出库的储位信息 var locate = Db.Queryable().First(m => m.LocatNo == locateNo && m.IsDel == "0"); if (locate == null) { flagList.Add(2); continue; } //判断储位标志是否为损坏 if (locate.Flag == "2") { flagList.Add(3); continue; } #endregion if (locate.Status == "1") //有物品 { #region 添加出库任务 var taskNo = new Common().GetMaxNo("TK"); //添加出库任务 var exTask = new LogTask { TaskNo = taskNo, Sender = "WMS", Receiver = "WCS", IsSuccess = 0, //是否下发成功 0失败 1成功 StartLocat = locate.LocatNo,//起始位置 EndLocat = outMode,//目标位置 PalletNo = item.PalletNo,//托盘码 IsSend = 1,//是否可再次下发 IsCancel = 1,//是否可取消 IsFinish = 1,//是否可完成 Type = "1",//任务类型 0 入库任务 1 出库任务 2 移库任务 Status = "0",//任务状态0：等待执行1正在执行2执行完成 OrderType = "2",//0 入库单 1 出库单 2 盘点单 3 移库单 CreateTime = time }; Db.Insertable(exTask).ExecuteCommand(); outDtoList.Add(new OutCommandDto() { PalletNo = item.PalletNo,//托盘号 StartLocate = locate.LocatNo, // 起始位置 StartRoadway = locate.RoadwayNo, EndLocate = "", // 目标位置 TaskNo = exTask.TaskNo, // 任务号 TaskType = "1",// 任务类型 (出库) OutMode = "", //目标地址 Order = 1 }); #endregion #region 改变数据 if (item.Status == 0)//判断托盘是否下发过 { if (notice.Status == 0) { notice.CheckDate = DateTime.Now; notice.Status = 1; notice.UpdateUser = userId; notice.UpdateTime = time; Db.Updateable(notice).ExecuteCommand(); } } locate.Status = "3"; //要出库的储位改变状态 正在出库 Db.Updateable(locate).ExecuteCommand(); item.TaskNo = exTask.TaskNo; // 出库分配信息中更新任务号 item.Status = 1; // 出库分配信息状态改为正在执行 Db.Updateable(item).ExecuteCommand(); #endregion flagList.Add(0); } else if (locate.Status == "3") //出库中 { #region 改变数据 //判断是否是已经出过库又回库（状态为待拣货的 1） if (item.Status == 0) { if (notice.Status == 0) { notice.CheckDate = DateTime.Now; notice.Status = 1; notice.UpdateUser = userId; notice.UpdateTime = time; Db.Updateable(notice).ExecuteCommand(); } } var taskNo = Db.Queryable().First(m => m.OrderType == "2" && m.TaskNo != item.TaskNo && m.Status == "1" && m.PalletNo == item.PalletNo); item.TaskNo = taskNo.TaskNo; item.Status = 1; // 出库分配信息状态改为正在执行 Db.Updateable(item).ExecuteCommand(); #endregion } else if (locate.Status == "5") //移出中 { flagList.Add(1); } } //添加操作日志记录 var k = new OperationCrServer().AddLogOperationCr("库内作业", "盘点单据", crNo, "出库", $"点击出库按钮盘点单号为：{crNo}的盘点单", userId); Db.CommitTran(); str = string.Empty; if (flagList.Count(m => m == 1) > 0) { str += "1.当前要出库的储位正在移出、"; } if (flagList.Count(m => m == 2) > 0) { str += "2.出库的托盘储位信息错误(在储位表中未查询到)、"; } if (flagList.Count(m => m == 3) > 0) { str += "4.储位损坏不能出库、"; } if (flagList.Count(m => m == 4) > 0) { str += "3.要出库的托盘正在入库、"; } if (flagList.Count(m => m == 5) > 0) { str += "5.要出库的托盘在零箱库、"; } if (outDtoList.Count > 0) { // 正式运行程序放开 var list2 = outDtoList.Select(m => m.TaskNo).ToList(); var jsonData = JsonConvert.SerializeObject(outDtoList); 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(response); if (wcsModel.StatusCode == 0) { //更改任务的发送返回时间// new TaskServer().EditTaskIssueOk(list2, time1, time2); str += "下发成功"; } 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); } } return outDtoList; } catch (Exception e) { Db.RollbackTran(); throw new Exception(e.Message); } #endregion } catch (Exception e) { throw new Exception(e.Message); } } //盘点出库完成 public void CheckSuccess(string taskNo, int userId) { try { //出库任务号更改，如果由PLC出库，则PLC回传任务号为：任务号+实际出库口 var TtaskNo = taskNo; var outLine = ""; if (taskNo.Length == 18) { TtaskNo = taskNo.Substring(0, taskNo.Length - 3); outLine = taskNo.Substring(taskNo.Length - 3, 3); } //当前任务信息 var task = Db.Queryable().First(m => m.TaskNo == TtaskNo && m.IsDel == "0"); if (task == null) { throw new Exception($"未查询到任务号为：‘{TtaskNo}’的任务信息"); } if (task.Status == "2") { throw new Exception("当前任务已完成"); } Db.BeginTran(); //库存中当前托盘的信息 var stockDetail = Db.Queryable().Where(m => m.PalletNo == task.PalletNo).ToList(); var locateNo = stockDetail.Select(m => m.LocatNo).Distinct().FirstOrDefault(); //当前任务中的储位信息 var locate = Db.Queryable().First(m => m.LocatNo == locateNo); task.Status = "2";//任务状态 task.IsSend = 0; task.IsCancel = 0; task.IsFinish = 0; task.FinishDate = DateTime.Now;//完成时间 Db.Updateable(task).ExecuteCommand(); locate.Status = "0"; // 更改当前任务中的储位状态（改为0空储位） Db.Updateable(locate).ExecuteCommand(); foreach (var item in stockDetail) { item.LocatNo = "";//储位更改（改为空） item.WareHouseNo = "";//所属仓库更改（改为空） item.RoadwayNo = "";//所属巷道更改（改为空） item.AreaNo = "";//所属区域更改（改为空） Db.Updateable(item).ExecuteCommand(); } //盘点明细（更改状态） var checkDetails = Db.Queryable().Where(m => m.IsDel == "0" && (m.TaskNo == TtaskNo || (m.Status == 1 && m.PalletNo == task.PalletNo))).ToList(); foreach (var item in checkDetails) { item.Status = 2; Db.Updateable(item).ExecuteCommand(); } if (userId != 0) { //添加操作日志记录 var k = new OperationCrServer().AddLogOperationCr("库内作业", "库内日志", TtaskNo, "完成", $"点击完成按钮、完成任务号为：{TtaskNo}的任务", userId); } Db.CommitTran(); } catch (Exception ex) { Db.RollbackTran(); throw new Exception("完成反馈失败：" + ex.Message); } } //AGV移库完成 public void MoveSuccess(string taskNo,string mesTokenUrl, string mesUrl, int userId) { try { //当前任务信息 var task = Db.Queryable().First(m => m.TaskNo == taskNo && m.IsDel == "0"); if (task == null) { throw new Exception($"未查询到任务号为：‘{taskNo}’的任务信息"); } if (task.Status == "2") { throw new Exception("当前任务已完成"); } Db.BeginTran(); //库存中当前托盘的信息 var stockDetail = Db.Queryable().Where(m => m.PalletNo == task.PalletNo).ToList(); var locateNo = stockDetail.Select(m => m.LocatNo).Distinct().FirstOrDefault(); //当前任务中的储位信息 var locate = Db.Queryable().First(m => m.LocatNo == locateNo); //更改任务 task.Status = "2";//任务状态 task.IsSend = 0; task.IsCancel = 0; task.IsFinish = 0; task.FinishDate = DateTime.Now;//完成时间 Db.Updateable(task).ExecuteCommand(); // 更改当前任务中的储位状态（改为0空储位） locate.Status = "0"; Db.Updateable(locate).ExecuteCommand(); //目标储位信息 var endLocate = Db.Queryable().First(m => m.LocatNo == task.EndLocat); if (endLocate != null) { if (endLocate.Status != "4") { throw new Exception("目标储位状态非移入中"); } } var data = new List(); //更改库存明细 foreach (var item in stockDetail) { //item.Status = "0";//待分配 //item.LockQty = 0;//锁定数量改为0 if (endLocate != null)//有目标储位说明移到其他区域储位 { item.LocatNo = endLocate.LocatNo;//储位更改 item.WareHouseNo = endLocate.WareHouseNo;//所属仓库更改 item.RoadwayNo = endLocate.RoadwayNo;//所属巷道更改 item.AreaNo = endLocate.AreaNo;//所属区域更改 } else//没有目标储位说明移到入库口 { item.LocatNo = "";//储位更改（改为空） item.WareHouseNo = "";//所属仓库更改（改为空） item.RoadwayNo = "";//所属巷道更改（改为空） item.AreaNo = "";//所属区域更改（改为空） } if (item.Qty == item.LockQty && item.LockQty>0) { item.Status = "2"; } else if (item.Qty > item.LockQty && item.LockQty > 0) { item.Status = "1"; } else if (item.Qty > item.LockQty && item.LockQty == 0) { item.Status = "0"; } Db.Updateable(item).ExecuteCommand(); if (endLocate != null && endLocate.AreaNo == "B12") //是否是3楼缓存区 是：删除库存 { if (string.IsNullOrWhiteSpace(item.SONo)) { throw new Exception("当前托盘不是拼托出库托盘"); } //记录托盘上信息给MES var boxInfo = Db.Queryable().Where(m => m.IsDel == "0" && m.StockDetailId == item.Id).ToList(); if (boxInfo.Count == 0) { throw new Exception("托盘上物料箱码信息不存在,请检查!"); } foreach (var item2 in boxInfo) { data.Add(new RequertBeiliaoInfoModel() { no = item2.BoxNo, materiel_no = item.SkuNo, materiel_name = item.SkuName, qty = item.Qty, batch = item.LotNo, producttime = item2.ProductionTime.ToString().Substring(1, 8), expiry = item2.ExpirationTime.ToString().Substring(1, 8) }); } //库存箱码明细删除 Db.Deleteable(boxInfo).ExecuteCommand(); //删除库存托盘信息 Db.Deleteable(item).ExecuteCommand(); //更改库存总表 var stock = Db.Queryable().First(w => w.IsDel == "0" && w.SkuNo == item.SkuNo && w.LotNo == item.LotNo); stock.LockQty -= (decimal)item.Qty; stock.Qty -= (decimal)item.Qty; Db.Updateable(stock).ExecuteCommand(); //更改托盘状态 var pallet = Db.Queryable().First(m=>m.IsDel =="0" && m.PalletNo == task.PalletNo); if (pallet != null) { pallet.Status = "0"; Db.Updateable(pallet).ExecuteCommand(); } } } if (endLocate != null) { //更改目标储位状态 endLocate.Status = "1";//有物品 Db.Updateable(endLocate).ExecuteCommand(); } //正式运行程序放开 if (endLocate != null && endLocate.AreaNo == "B12") { //获取令牌 var token = new Token().GetMesToken(mesTokenUrl); Dictionary mesDic = new Dictionary() { {"Authorization",token } }; var mesData = new RequertBeiliaoModel() { morder_no = stockDetail.First().SONo, pallet = stockDetail.First().PalletNo, layer_no = endLocate.LocatNo, items = data }; var jsonData = JsonConvert.SerializeObject(mesData); //调用接口 var response = HttpHelper.DoPost(mesUrl, jsonData, "备料完成运至缓存区反馈至MES", "MES", mesDic); var obj = JsonConvert.DeserializeObject(response);//解析返回数据 if (obj.status != "0") { throw new Exception("备料同步MES失败：" + obj.message); } } if (userId != 0) { //添加操作日志记录 var k = new OperationCrServer().AddLogOperationCr("库内作业", "库内日志", taskNo, "完成", $"点击完成按钮、完成任务号为：{taskNo}的任务", userId); } Db.CommitTran(); } catch (Exception ex) { Db.RollbackTran(); throw new Exception("完成反馈失败：" + ex.Message); } } //重新下发盘点出库任务 public OutCommandDto AgainSendCheckTask(string taskNo, int userId, string url) { try { var task = Db.Queryable().First(m => m.TaskNo == taskNo && m.IsDel == "0"); if (task == null) { throw new Exception("未查询到任务信息"); } var stockDetail = Db.Queryable().First(m => m.PalletNo == task.PalletNo); if (stockDetail == null) { throw new Exception(task.PalletNo + " 当前托盘未在库内，请核实信息"); } Db.BeginTran(); var locateNo = task.StartLocat; //判断任务中起始位置是否和库存中位置一致 if (task.StartLocat != stockDetail.LocatNo) { locateNo = stockDetail.LocatNo; task.StartLocat = locateNo; Db.Updateable(task).ExecuteCommand(); } var locate = Db.Queryable().First(m => m.LocatNo == locateNo); if (locate != null && locate.Status != "3") { locate.Status = "3"; Db.Updateable(locate).ExecuteCommand(); } var outDto = new OutCommandDto() { PalletNo = task.PalletNo,//托盘号 StartLocate = locateNo, // 起始位置 StartRoadway = locate.RoadwayNo, EndLocate = task.EndLocat, // 目标位置 TaskNo = task.TaskNo, // 任务号 TaskType = "1",// 任务类型 (出库) OutMode = "", //目标地址 Order = 1 }; //出库数据 //添加操作日志记录 var k = new OperationCrServer().AddLogOperationCr("库内作业", "库内日志", taskNo, "下发", $"点击下发按钮、重新下发了任务号为：{taskNo}的任务", userId); Db.CommitTran(); // 正式运行程序放开 var list = new List { outDto.TaskNo }; var jsonData = JsonConvert.SerializeObject(outDto); try { //程序正式发布后放开 var time1 = DateTime.Now;//发送时间 .ToString("yyyy-MM-dd HH:mm:ss") var response = HttpHelper.DoPost(url, jsonData, "下发给WCS出库命令", "WCS"); var time2 = DateTime.Now;//返回时间 .ToString("yyyy-MM-dd HH:mm:ss") ////解析返回数据 var wcsModel = JsonConvert.DeserializeObject(response); if (wcsModel.StatusCode == 0) { //更改任务的发送返回时间// new TaskServer().EditTaskIssueOk(list, time1, time2); } if (wcsModel.StatusCode == -1) { new TaskServer().EditTaskIssueNo(list, time1, time2, wcsModel.Msg); throw new Exception($"wcs返回状态异常：{wcsModel.Msg}"); } } catch (Exception ex) { throw new Exception(ex.Message); } return outDto; } catch (Exception e) { Db.RollbackTran(); throw new Exception(e.Message); } } //取消盘点出库任务 public void CancelCheckTask(string taskNo, int userId) { try { Db.BeginTran(); try { var task = Db.Queryable().First(m => m.TaskNo == taskNo && m.IsDel == "0"); if (task == null) { throw new Exception("未查询到任务信息"); } //修改任务 task.IsSuccess = 0; task.IsSend = 0; task.IsCancel = 0; task.IsFinish = 0; task.Status = "4"; task.CancelDate = DateTime.Now; Db.Updateable(task).ExecuteCommand(); //修改盘点明细 var checkDetail = Db.Queryable().First(w => w.TaskNo == task.TaskNo); if (checkDetail == null) { throw new Exception("未查询到盘点明细信息，请核实！"); } checkDetail.Status = 0; checkDetail.TaskNo = ""; Db.Updateable(checkDetail).ExecuteCommand(); //修改盘点记录 var checkLog = Db.Queryable().First(w => w.CRNo == checkDetail.CRNo && w.PalletNo == checkDetail.PalletNo && w.IsDel == "0"); if (checkLog == null) { throw new Exception("未查询到盘点记录信息，请核实！"); } checkLog.IsDel = "1"; Db.Updateable(checkLog).ExecuteCommand(); //修改储位信息 var locat = Db.Queryable().First(a => a.IsDel == "0" && a.WareHouseNo == "W02" && a.LocatNo == task.StartLocat); if (locat == null) { throw new Exception("未查询到储位信息，请核实！"); } locat.Status = "1"; //有物品 Db.Updateable(locat).ExecuteCommand(); //添加操作日志记录 var k = new OperationCrServer().AddLogOperationCr("库内作业", "库内日志", taskNo, "取消", $"点击取消按钮、取消了任务号为：{taskNo}的任务", userId); Db.CommitTran(); } catch (Exception e) { Db.RollbackTran(); throw new Exception(e.Message); } } catch (Exception e) { throw new Exception(e.Message); } } //取消AGV移库任务 public void CancelMoveTask(string taskNo, int userId) { try { Db.BeginTran(); var task = Db.Queryable().First(m => m.TaskNo == taskNo && m.IsDel == "0"); if (task == null) { throw new Exception("未查询到任务信息"); } //修改任务 task.IsSuccess = 0; task.IsSend = 0; task.IsCancel = 0; task.IsFinish = 0; task.Status = "4"; task.CancelDate = DateTime.Now; Db.Updateable(task).ExecuteCommand(); //修改起始储位信息 var locat = Db.Queryable().First(a => a.IsDel == "0" && a.WareHouseNo == "W02" && a.LocatNo == task.StartLocat); if (locat == null) { throw new Exception("未查询到储位信息，请核实！"); } locat.Status = "1"; //有物品 Db.Updateable(locat).ExecuteCommand(); //修改目标储位信息 var locatEnd = Db.Queryable().First(a => a.IsDel == "0" && a.WareHouseNo == "W02" && a.LocatNo == task.EndLocat); if (locatEnd != null) { locatEnd.Status = "0"; //空储位 Db.Updateable(locatEnd).ExecuteCommand(); } //修改库存明细 var stockDetail = Db.Queryable().First(w => w.IsDel == "0" && w.PalletNo == task.PalletNo); if (stockDetail == null) { throw new Exception("托盘上物料库存明细信息不存在,请检查!"); } stockDetail.Status = "0";//待分配 stockDetail.LockQty = 0;//锁定数量 Db.Updateable(stockDetail).ExecuteCommand(); //修改库存 var stock = Db.Queryable().First(w => w.IsDel == "0" && w.SkuNo == stockDetail.SkuNo && w.LotNo == stockDetail.LotNo); if (stock == null) { throw new Exception("托盘上物料库存信息不存在,请检查!"); } stock.LockQty -= (decimal)stockDetail.Qty; Db.Updateable(stock).ExecuteCommand(); //添加操作日志记录 var k = new OperationCrServer().AddLogOperationCr("库内作业", "库内日志", taskNo, "取消", $"点击取消按钮、取消了任务号为：{taskNo}的任务", userId); Db.CommitTran(); } catch (Exception e) { Db.RollbackTran(); throw new Exception(e.Message); } } #region 上游系统接口 //盘点结果返回erp public bool FinishCr(int id, string url, int userId) { throw new NotImplementedException(); //try //{ // //Db.BeginTran(); // //try // //{ // //} // //catch (Exception e) // //{ // // Console.WriteLine(e); // // throw; // //} // Db.CommitTran(); //} //catch (Exception e) //{ // Db.RollbackTran(); // throw new Exception(e.Message); //} } #endregion } }