调整出库申请代码逻辑

This commit is contained in:
yang.lee
2023-11-08 15:54:51 +08:00
parent 294f60b51d
commit 6521b98cc8
2 changed files with 13 additions and 8 deletions

View File

@@ -133,7 +133,7 @@ namespace Tnb.WarehouseMgr
List<string> carryIds = new(); List<string> carryIds = new();
var mapKeys = new List<string> { "tablefield120", "details" }; var mapKeys = new List<string> { "tablefield120", "details" };
//tablefield120 出库物料明细 //tablefield120 出库物料明细
if (input.data.Keys.Where(k => mapKeys.Contains(k)).Any()) //input.data.ContainsKey("tablefield120") && input.data["tablefield120"].IsNotEmptyOrNull() if (input.data.Keys.Any(k => mapKeys.Contains(k))) //input.data.ContainsKey("tablefield120") && input.data["tablefield120"].IsNotEmptyOrNull()
{ {
List<WmsOutstockD> outStockDList = new(); List<WmsOutstockD> outStockDList = new();
if (input.data.ContainsKey("tablefield120") && input.data["tablefield120"].IsNotEmptyOrNull()) if (input.data.ContainsKey("tablefield120") && input.data["tablefield120"].IsNotEmptyOrNull())

View File

@@ -62,23 +62,28 @@ namespace Tnb.WarehouseMgr
try try
{ {
await _db.Ado.BeginTranAsync(); await _db.Ado.BeginTranAsync();
WmsInstockH? instock = null;
var purchaseDs = await PurchaseAndSaleUpdate(input); var purchaseDs = await PurchaseAndSaleUpdate(input);
List<WmsInstockD> instockDs = new();
if (purchaseDs?.Count > 0) if (purchaseDs?.Count > 0)
{ {
var instock = input.Adapt<WmsInstockH>(); instock = input.Adapt<WmsInstockH>();
instock.id = SnowflakeIdHelper.NextId(); instock.id = SnowflakeIdHelper.NextId();
instock.create_id = _userManager.UserId; instock.create_id = _userManager.UserId;
instock.create_time = DateTime.Now; instock.create_time = DateTime.Now;
instock.org_id = _userManager.User.OrganizeId; instock.org_id = _userManager.User.OrganizeId;
await _db.Insertable(instock).ExecuteCommandAsync(); await _db.Insertable(instock).ExecuteCommandAsync();
var instockD = purchaseDs.Adapt<WmsInstockD>(); instockDs = purchaseDs.Adapt<List<WmsInstockD>>();
instockD.create_id = _userManager.UserId; instockDs.ForEach(instockD =>
instockD.create_time = DateTime.Now; {
instockD.org_id = _userManager.User.OrganizeId; instockD.create_id = _userManager.UserId;
await _db.Insertable(instockD).ExecuteCommandAsync(); instockD.create_time = DateTime.Now;
instockD.org_id = _userManager.User.OrganizeId;
});
await _db.Insertable(instockDs).ExecuteCommandAsync();
} }
//通知Mes接口
await _db.Ado.CommitTranAsync(); await _db.Ado.CommitTranAsync();
} }