using NewPdaSqlServer.DB; using NewPdaSqlServer.Dto.service; using NewPdaSqlServer.entity; using NewPdaSqlServer.util; using SqlSugar; namespace NewPdaSqlServer.service.Warehouse; // 期初条码入库 public class InventoryManager : RepositoryNoEntity { // 这个方法用于扫描库位条码 public string ScanDepotNo(WarehouseQuery query) { var p_section_code = query.DepotCode; // 检查库位代码是否为空 if (string.IsNullOrEmpty(p_section_code)) throw new Exception("002[请扫库位条码！"); // 查询库区库位信息 var depotSection = Db.Queryable((a, b) => new JoinQueryInfos( JoinType.Inner, a.DepotGuid == b.Guid )) .Where((a, b) => a.DepotSectionCode == p_section_code) .Select((a, b) => new { a.DepotSectionName, b.DepotCode, b.DepotName }) .Single(); // 如果库位代码不存在，则返回错误信息 if (depotSection == null) throw new Exception("库位编码 " + p_section_code + " 不存在，请确认！"); // 返回成功信息 return "仓库：" + depotSection.DepotName + " 库位：" + depotSection.DepotSectionName; } // 这个方法用于扫描条码 public WarehouseQuery ScanBarcode(WarehouseQuery query) { var p_item_barcode = query.barcode; var p_section_code = query.DepotCode; var c_user = query.userName; var p_bill_type_id = 100; var p_transction_no = 601; // 检查库位代码是否为空 if (string.IsNullOrEmpty(p_section_code)) throw new Exception("002[请扫库位条码！"); // 查询库区库位信息 var depotSection = Db.Queryable((a, b) => new JoinQueryInfos( JoinType.Inner, a.DepotGuid == b.Guid )) .Where((a, b) => a.DepotSectionCode == p_section_code) .Select((a, b) => new { a.DepotSectionName, b.DepotCode, b.DepotName, b.DepotId }) .Single(); // 如果库位代码不存在，则返回错误信息 if (depotSection == null) throw new Exception("库位编码 " + p_section_code + " 不存在，请确认！"); // 检查是否已经收货 var c_num = Db.Queryable((a, b) => new JoinQueryInfos( JoinType.Inner, a.Guid == b.ItemInId )) .Where((a, b) => b.ItemBarcode == p_item_barcode) .Count(); if (c_num > 0) throw new Exception("002[条码重复扫描，请核对！"); // 查询条码信息 c_num = Db.Queryable() .Where(t => t.ItemBarcode == p_item_barcode) .Count(); if (c_num > 0) throw new Exception("002[条码已在库存中，请核对！"); // 查询条码详细信息 var c_mes_inv_item_barcodes = Db.Queryable() .Where(t => t.ItemBarcode == p_item_barcode) .Single(); if (c_mes_inv_item_barcodes == null) throw new Exception("002[条码不存在，请核对！"); if (c_mes_inv_item_barcodes.ComeFlg != 0) throw new Exception("002[条码不是期初条码，无法用期初入库！"); UseTransaction(db => { // 自动生成入库单 var c_id = db.Queryable() .Where(d => d.Sapstatus == 0 && d.InsDate.Value.ToString("yyyy-MM-dd") == DateTime.Now.ToString("yyyy-MM-dd") && d.Status == 0 && d.TransctionNo == p_transction_no.ToString() && d.CbillNo == c_mes_inv_item_barcodes.BillNo && (d.SuppId ?? "0") == (c_mes_inv_item_barcodes.SuppId ?? "0") && d.DepotsCode == depotSection.DepotCode) .Single(); if (c_id == null) { var billNo = BillNo.GetBillNo("IN(入库单)"); // 生成入库单号 var newMesInvItemIns = new MesInvItemIns { Guid = Guid.NewGuid(), TransctionNo = p_transction_no.ToString(), DepotsCode = depotSection.DepotCode, DepotsId = depotSection.DepotId, BillTypeId = p_bill_type_id, CreateBy = c_user, CreateDate = DateTime.Now, LastupdateBy = c_user, LastupdateDate = DateTime.Now, BillNo = billNo, SuppId = c_mes_inv_item_barcodes.SuppId, SuppNo = c_mes_inv_item_barcodes.SuppNo, UrgentFlag = c_mes_inv_item_barcodes.UrgentFlag == null ? null : c_mes_inv_item_barcodes.UrgentFlag.Value ? "1" : "0", CbillNo = c_mes_inv_item_barcodes.BillNo, Fstatus = 0 }; db.Insertable(newMesInvItemIns) .IgnoreColumns(true) .ExecuteCommand(); c_id = newMesInvItemIns; } // 插入入库单明细 db.Insertable(new MesInvItemInCDetails { Guid = Guid.NewGuid(), ItemInId = c_id.Guid, BillNo = c_id.BillNo, ItemBarcode = p_item_barcode, Quantity = c_mes_inv_item_barcodes.Quantity, BarcodeFlag = true, EpFlag = true, WorkType = 1, ItemNo = c_mes_inv_item_barcodes.ItemNo, LotNo = c_mes_inv_item_barcodes.LotNo, SuppNo = c_mes_inv_item_barcodes.SuppNo, DepotId = depotSection.DepotId, DepotCode = depotSection.DepotCode, DepotSectionCode = p_section_code, ItemSname = c_mes_inv_item_barcodes.ItemSname, Unit = c_mes_inv_item_barcodes.Unit, CreateBy = c_user, CreateDate = DateTime.Now, LastupdateBy = c_user, LastupdateDate = DateTime.Now, Remark = c_mes_inv_item_barcodes.Memo, Ebeln = c_mes_inv_item_barcodes.Mblnr, EbelnLineNo = c_mes_inv_item_barcodes.Zeile, WorkNo = c_mes_inv_item_barcodes.WorkNo, WorkLine = c_mes_inv_item_barcodes.WorkLine, CbillNo = c_mes_inv_item_barcodes.BillNo, UrgentFlag = c_mes_inv_item_barcodes.UrgentFlag, BoardStyle = c_mes_inv_item_barcodes.BoardStyle, TaskNo = c_mes_inv_item_barcodes.TaskNo, ItemId = c_mes_inv_item_barcodes.ItemId }).IgnoreColumns(true).ExecuteCommand(); db.Insertable(new MesInvBusiness2 { Guid = Guid.NewGuid(), Status = 1, BillTypeId = p_bill_type_id, TransactionCode = p_transction_no.ToString(), BusinessType = 1, ItemBarcode = p_item_barcode, ItemNo = c_mes_inv_item_barcodes.ItemNo, LotNo = c_mes_inv_item_barcodes.LotNo, EpFlag = true, Quantity = c_mes_inv_item_barcodes.Quantity, InvDepotId = depotSection.DepotId, ToInvDepotsCode = depotSection.DepotCode, ToInvDepotSectionsCode = p_section_code, CreateBy = c_user, CreateDate = DateTime.Now, LastupdateBy = c_user, LastupdateDate = DateTime.Now, TaskNo = c_mes_inv_item_barcodes.TaskNo, BillNo = c_id.BillNo, WorkNo = c_mes_inv_item_barcodes.WorkNo, WorkLine = c_mes_inv_item_barcodes.WorkLine, SuppNo = c_mes_inv_item_barcodes.SuppNo, ItemId = c_mes_inv_item_barcodes.ItemId }).IgnoreColumns(true).ExecuteCommand(); // 插入库存信息 db.Insertable(new MesInvItemStocks { Guid = Guid.NewGuid(), TaskNo = c_mes_inv_item_barcodes.TaskNo, ItemBarcode = p_item_barcode, ItemNo = c_mes_inv_item_barcodes.ItemNo, LotNo = c_mes_inv_item_barcodes.LotNo, Quantity = c_mes_inv_item_barcodes.Quantity, EpFlag = c_mes_inv_item_barcodes.EpFlag == null ? null : (byte)(c_mes_inv_item_barcodes.EpFlag.Value ? 1 : 0), DepotsCode = depotSection.DepotCode, DepotId = depotSection.DepotId, DepotsId = depotSection.DepotId, DepotSectionsCode = p_section_code, CheckDate = c_mes_inv_item_barcodes.CreateDate, IndepDate = c_mes_inv_item_barcodes.CreateDate, BoardStyle = c_mes_inv_item_barcodes.BoardStyle, WorkNo = c_mes_inv_item_barcodes.WorkNo, WorkLine = c_mes_inv_item_barcodes.WorkLine, // ItemUnit = c_mes_inv_item_barcodes.Unit, SuppNo = c_mes_inv_item_barcodes.SuppNo, ItemId = c_mes_inv_item_barcodes.ItemId, IndepUserCode = c_user // Fsubsidiary = c_organize }).IgnoreColumns(true).ExecuteCommand(); return 1; }); var mesItems = Db.Queryable() .Where(s => s.Id == c_mes_inv_item_barcodes.ItemId) .First(); query.itemNo = mesItems.ItemNo; query.Num = c_mes_inv_item_barcodes.Quantity; query.message = "物料 " + c_mes_inv_item_barcodes.ItemNo + " 本次收货总数： " + c_mes_inv_item_barcodes.Quantity; // 返回成功信息 return query; } }