From b29370185ec3ca4debc6264d78c7159fe1d94b40 Mon Sep 17 00:00:00 2001
From: zjh <2207896513@qq.com>
Date: 星期四, 21 八月 2025 21:55:11 +0800
Subject: [PATCH] U9即时库存获取代码提交
---
StandardPda/MES.Service/service/Warehouse/MesItemQtManager.cs | 42 +++++++++++++++++++++++++++++++++++++++---
1 files changed, 39 insertions(+), 3 deletions(-)
diff --git a/StandardPda/MES.Service/service/Warehouse/MesItemQtManager.cs b/StandardPda/MES.Service/service/Warehouse/MesItemQtManager.cs
index e1c8217..34c76bf 100644
--- a/StandardPda/MES.Service/service/Warehouse/MesItemQtManager.cs
+++ b/StandardPda/MES.Service/service/Warehouse/MesItemQtManager.cs
@@ -247,7 +247,7 @@
var itemIdLinkU9 = Db.Queryable<MesLinkU9>()
.Where(s => s.TableType == "MES_ITEMS"
- && s.U9Id == ItemQtRKList.Itemld).First();
+ && s.U9Id == ItemQtRKList.ItemId).First();
if (itemIdLinkU9 == null)
{
@@ -260,7 +260,7 @@
if (mesItems == null)
{
- throw new NotImplementedException("[" + ItemQtRKList.Itemld +
+ throw new NotImplementedException("[" + ItemQtRKList.ItemId +
"]鐗╂枡涓嶅瓨鍦紝璇峰悓姝ョ粰MES");
}
var mesDepot = "";
@@ -299,6 +299,21 @@
}
+ string mesUnit = "";
+ if (mesItems.ItemUnit != null && mesItems.ItemUnit != "")
+ {
+
+ var mesUnitDb = Db.Queryable<MesUnit>()
+ .Where(s => s.Id == Decimal.Parse(mesItems.ItemUnit))
+ .First();
+ if (mesUnitDb == null)
+ {
+ throw new NotImplementedException("[" + ItemQtRKList.SupplierCode +
+ "]鍗曚綅涓嶅瓨鍦紝璇峰悓姝ョ粰MES");
+ }
+ mesUnit = mesUnitDb.Fnumber;
+ }
+
//var mesInvItemInCItems = Db.Queryable<MesInvItemInCItems>()
// .Where(s => s.ItemInId == mesInvItemIns.Id
// && s.ItemNo == mesItems.ItemNo
@@ -331,7 +346,7 @@
Qd006 = ItemQtRKList.PlannedQuantity,
Qd007 = ItemQtRKList.AppliedQuantity,
Qd008 = 0, // 宸插叆鏁伴噺榛樿涓�0
- Qd009 = mesItems.ItemUnit,
+ Qd009 = mesUnit,
Qd010 = ItemQtRKList.Remark,
Qd012 = mesItems.Id, // 鐗╂枡鍐呯爜
LineNumber = ItemQtRKList.LineNumber,
@@ -353,6 +368,27 @@
});
}
+ var itemDB = mesItemQtDetail
+ .Where(x => x.Qd002 != null) // 杩囨护鎺� null 鍊�
+ .GroupBy(x => x.Qd002) // 鎸� Qd002 鍒嗙粍
+ .Select(g => new
+ {
+ no = g.Key,
+ count = g.Count()
+
+ })
+ .ToList();
+
+ // 杈撳嚭缁熻缁撴灉
+ foreach (var item in itemDB)
+ {
+ if (item.count > 1)
+ {
+ throw new Exception($"鏄庣粏琛岀墿鏂�:{item.no}閲嶅锛岃妫�鏌ュ悗閲嶈瘯锛�");
+ }
+ //Console.WriteLine($"鐗╂枡缂栧彿: {item.鐗╂枡缂栧彿}, 鍑虹幇娆℃暟: {item.鍑虹幇娆℃暟}");
+ }
+
var outItemCommand = Db.Insertable(mesItemQtDetail)
.PageSize(1).IgnoreColumnsNull().ExecuteCommand();
if (outItemCommand <= 0)
--
Gitblit v1.9.3