This commit is contained in:
2024-10-11 11:37:29 +08:00
2 changed files with 80 additions and 65 deletions

View File

@@ -742,17 +742,17 @@ namespace Tnb.ProductionMgr
} }
else else
{ {
// Result result = await _wmsCarryUnbindService.CarryCodeUnbindWithoutTran(new CarryCodeUnbindInput() Result result = await _wmsCarryUnbindService.CarryCodeUnbindWithoutTran(new CarryCodeUnbindInput()
// { {
// carry_id = detail.member_carry_id carry_id = detail.member_carry_id
// },db); },_db);
//
//
// if (result.code != HttpStatusCode.OK) if (result.code != HttpStatusCode.OK)
// { {
// throw Oops.Bah(result.msg); throw Oops.Bah(result.msg);
// } }
deleteCarryCodeIds.Add(detail.member_carry_id); //deleteCarryCodeIds.Add(detail.member_carry_id);
// int row = await db.Deleteable<WmsCarryCode>().Where(r => r.carry_id == detail.member_carry_id).ExecuteCommandAsync(); // int row = await db.Deleteable<WmsCarryCode>().Where(r => r.carry_id == detail.member_carry_id).ExecuteCommandAsync();
// Log.Information($"载具{detail.member_carry_id}已解绑,解绑条数{row}"); // Log.Information($"载具{detail.member_carry_id}已解绑,解绑条数{row}");
} }
@@ -761,18 +761,18 @@ namespace Tnb.ProductionMgr
if (carry.carrystd_id == WmsWareHouseConst.CARRY_ZYXCSTD_ID || carry.carrystd_id == WmsWareHouseConst.CARRY_ZYLJSTD_ID) if (carry.carrystd_id == WmsWareHouseConst.CARRY_ZYXCSTD_ID || carry.carrystd_id == WmsWareHouseConst.CARRY_ZYLJSTD_ID)
{ {
// Result result = await _wmsCarryUnbindService.CarryCodeUnbindWithoutTran(new CarryCodeUnbindInput() Result result = await _wmsCarryUnbindService.CarryCodeUnbindWithoutTran(new CarryCodeUnbindInput()
// { {
// carry_id = carry.id carry_id = carry.id
// },db); },_db);
//
//
// if (result.code != HttpStatusCode.OK)
// {
// throw Oops.Bah(result.msg);
// }
deleteCarryCodeIds.Add(carry.id);
if (result.code != HttpStatusCode.OK)
{
throw Oops.Bah(result.msg);
}
//deleteCarryCodeIds.Add(carry.id);
// int row = await db.Deleteable<WmsCarryCode>().Where(r => r.carry_id == carry.id).ExecuteCommandAsync(); // int row = await db.Deleteable<WmsCarryCode>().Where(r => r.carry_id == carry.id).ExecuteCommandAsync();
// Log.Information($"载具{carry.id}已解绑,解绑条数{row}"); // Log.Information($"载具{carry.id}已解绑,解绑条数{row}");
} }
@@ -785,46 +785,41 @@ namespace Tnb.ProductionMgr
if (carry.carrystd_id==WmsWareHouseConst.CARRY_LXSTD_ID || carry.carrystd_id==WmsWareHouseConst.CARRY_LJSTD_ID) if (carry.carrystd_id==WmsWareHouseConst.CARRY_LXSTD_ID || carry.carrystd_id==WmsWareHouseConst.CARRY_LJSTD_ID)
{ {
// Result result2 = await _wmsCarryUnbindService.CarryUnbindWithoutTran(new CarryBindInput() Result result2 = await _wmsCarryUnbindService.CarryUnbindWithoutTran(new CarryBindInput()
// { {
// org = prdFeedingH.org_id, org = prdFeedingH.org_id,
// create_id = prdFeedingH.create_id, create_id = prdFeedingH.create_id,
// carry_id = prdMaterialReceiptH.carry_id, carry_id = prdMaterialReceiptH.carry_id,
// carry_code = prdMaterialReceiptH.carry_code, carry_code = prdMaterialReceiptH.carry_code,
// carrystd_id = carry.carrystd_id, carrystd_id = carry.carrystd_id,
// membercarry_code = "", membercarry_code = "",
// membercarry_id = "", membercarry_id = "",
// },db); },_db);
//
// if (result2.code != HttpStatusCode.OK) if (result2.code != HttpStatusCode.OK)
// { {
// throw Oops.Bah(result2.msg); throw Oops.Bah(result2.msg);
// } }
deleteCarryDIds.Add(prdMaterialReceiptH.carry_id); //deleteCarryDIds.Add(prdMaterialReceiptH.carry_id);
// int row = await db.Deleteable<WmsCarryD>().Where(r => r.carry_id == prdMaterialReceiptH.carry_id).ExecuteCommandAsync(); // int row = await db.Deleteable<WmsCarryD>().Where(r => r.carry_id == prdMaterialReceiptH.carry_id).ExecuteCommandAsync();
// Log.Information($"载具{prdMaterialReceiptH.carry_id}已解绑,解绑条数{row}"); // Log.Information($"载具{prdMaterialReceiptH.carry_id}已解绑,解绑条数{row}");
} }
} }
await _db.Updateable<WmsCarryH>().SetColumns(r => new WmsCarryH // Log.Information($"清空载具信息:{JsonConvert.SerializeObject(clearCarryIds)}");
{ // string carryStatus = ((int)EnumCarryStatus.空闲).ToString();
work_station = "" // string isCheck = ((int)EnumCheckConclusion.待检).ToString();
}).Where(r => input.carryIds.Contains(r.id)).ExecuteCommandAsync(); // foreach(string carryId in clearCarryIds)
// {
Log.Information($"清空载具信息:{JsonConvert.SerializeObject(clearCarryIds)}"); // await _db.Updateable<WmsCarryH>()
string carryStatus = ((int)EnumCarryStatus.).ToString(); // .SetColumns(x => x.carry_status == carryStatus)
string isCheck = ((int)EnumCheckConclusion.).ToString(); // .SetColumns(x => x.is_check == isCheck)
foreach(string carryId in clearCarryIds) // .Where(x => x.id==carryId)
{ // .ExecuteCommandAsync();
await _db.Updateable<WmsCarryH>() // Log.Information($"更新载具{carryId}状态为空闲{carryStatus},检验为{isCheck}成功");
.SetColumns(x => x.carry_status == carryStatus) // }
.SetColumns(x => x.is_check == isCheck)
.Where(x => x.id==carryId)
.ExecuteCommandAsync();
Log.Information($"更新载具{carryId}状态为空闲{carryStatus},检验为{isCheck}成功");
}
if (insertHList.Count <= 0 || insertDList.Count <= 0) if (insertHList.Count <= 0 || insertDList.Count <= 0)
{ {
@@ -832,11 +827,11 @@ namespace Tnb.ProductionMgr
} }
int dRow1 = await _db.Deleteable<WmsCarryD>().Where(r => deleteCarryDIds.Contains(r.carry_id)).ExecuteCommandAsync(); // int dRow1 = await _db.Deleteable<WmsCarryD>().Where(r => deleteCarryDIds.Contains(r.carry_id)).ExecuteCommandAsync();
Log.Information($"子载具{JsonConvert.SerializeObject(deleteCarryDIds)}已解绑,解绑条数{dRow1}"); // Log.Information($"子载具{JsonConvert.SerializeObject(deleteCarryDIds)}已解绑,解绑条数{dRow1}");
//
int dRow2 = await _db.Deleteable<WmsCarryCode>().Where(r => deleteCarryCodeIds.Contains(r.carry_id)).ExecuteCommandAsync(); // int dRow2 = await _db.Deleteable<WmsCarryCode>().Where(r => deleteCarryCodeIds.Contains(r.carry_id)).ExecuteCommandAsync();
Log.Information($"载具条码{JsonConvert.SerializeObject(deleteCarryDIds)}已解绑,解绑条数{dRow2}"); // Log.Information($"载具条码{JsonConvert.SerializeObject(deleteCarryDIds)}已解绑,解绑条数{dRow2}");
int row1 = await _db.Insertable(insertHList).ExecuteCommandAsync(); int row1 = await _db.Insertable(insertHList).ExecuteCommandAsync();
int row2 = await _db.Insertable(insertDList).ExecuteCommandAsync(); int row2 = await _db.Insertable(insertDList).ExecuteCommandAsync();

View File

@@ -3172,11 +3172,31 @@ namespace Tnb.WarehouseMgr
// 二楼物料呼叫任务结束后清空工位信息 // 二楼物料呼叫任务结束后清空工位信息
else if (dt.biz_type == "FloorCallMaterial") else if (dt.biz_type == "FloorCallMaterial")
{ {
//放到ModifyAsync await db.Updateable<WmsCarryH>().SetColumns(r => new WmsCarryH
// await db.Updateable<WmsCarryH>().SetColumns(r => new WmsCarryH {
// { work_station = ""
// work_station = "" }).Where(r => r.id == dt.carry_id).ExecuteCommandAsync();
// }).Where(r => r.id == dt.carry_id).ExecuteCommandAsync();
//自动签收投料更新载具状态
WmsCarryH carry = await _db.Queryable<WmsCarryH>().SingleAsync(x => x.id == dt.carry_id);
List<string> clearCarryIds = new List<string>();
clearCarryIds.Add(carry.id);
List<string> memberCarryIds = new List<string>();
if (carry.carrystd_id == WmsWareHouseConst.CARRY_ZYXCSTD_ID ||
carry.carrystd_id == WmsWareHouseConst.CARRY_ZYLJSTD_ID)
{
}
else
{
memberCarryIds = await _db.Queryable<WmsCarryD>().Where(x=>x.carry_id==carry.id).Select(x=>x.membercarry_id).ToListAsync();
clearCarryIds.AddRange(memberCarryIds);
}
await _db.Updateable<WmsCarryH>()
.SetColumns(x => x.carry_status == ((int)EnumCarryStatus.).ToString())
.SetColumns(x => x.is_check == ((int)EnumCheckConclusion.).ToString())
.Where(x => clearCarryIds.Contains(x.id))
.ExecuteCommandAsync();
//await QTRK2BIP(dt, db); //await QTRK2BIP(dt, db);
// require_code是任务单 // require_code是任务单