更新载具绑定和载具解绑

This commit is contained in:
FanLian
2023-06-20 19:07:02 +08:00
parent 0968abf3f0
commit 44e084cd2f
4 changed files with 80 additions and 34 deletions

View File

@@ -58,7 +58,7 @@ namespace Tnb.WarehouseMgr
{
await _db.Ado.BeginTranAsync();
VisualDevEntity? templateEntity = await _visualDevService.GetInfoById(ModuleConsts.MODULE_WMSCARRYMOOUTSTK_ID, true);
VisualDevEntity? templateEntity = await _visualDevService.GetInfoById(ModuleConsts.MODULE_WMSCARRYUNBINDPDA_ID, true);
await _runService.Create(templateEntity, input);
if (input == null) throw new ArgumentNullException(nameof(input));
@@ -69,7 +69,27 @@ namespace Tnb.WarehouseMgr
//WmsCarryunbindH wmsCarryUnbindH = carry.Adapt<WmsCarryunbindH>();
if (carry != null && subCarry != null)
{
var row = await _db.Deleteable<WmsCarryD>().Where(it => it.carry_id == subCarry.id).ExecuteCommandAsync();
var row = await _db.Deleteable<WmsCarryD>().Where(it => it.carry_id == carryId && it.membercarry_id == subCarryId).ExecuteCommandAsync();
var items = await _db.Queryable<WmsCarryCode>().Where(it => it.carry_id == subCarryId).ToListAsync();
WmsCarryunbindCode wmsCarryUnbindCode = new();
for (int i = 0; i < items.Count; i++)
{
wmsCarryUnbindCode.id = SnowflakeIdHelper.NextId();
wmsCarryUnbindCode.org_id = subCarry?.org_id!;
wmsCarryUnbindCode.carryunbind_id = input.data["ReturnIdentity"]?.ToString()!;
wmsCarryUnbindCode.material_id = items[i].material_id;
wmsCarryUnbindCode.material_code = items[i].material_code;
wmsCarryUnbindCode.barcode = items[i].barcode;
wmsCarryUnbindCode.code_batch = items[i].code_batch;
wmsCarryUnbindCode.codeqty = items[i].codeqty;
wmsCarryUnbindCode.membercarry_id = subCarry?.id;
wmsCarryUnbindCode.membercarry_code = subCarry?.carry_code;
wmsCarryUnbindCode.unit_id = items[i].unit_id;
wmsCarryUnbindCode.unit_code = items[i].unit_code;
wmsCarryUnbindCode.create_id = _userManager.UserId;
wmsCarryUnbindCode.create_time = DateTime.Now;
row = await _db.Insertable(wmsCarryUnbindCode).ExecuteCommandAsync();
}
carry.carry_status = "0";
row = await _db.Updateable(carry).ExecuteCommandAsync();
subCarry.carry_status = "0";