This commit is contained in:
alex
2023-06-27 11:47:35 +08:00
parent 559b218df2
commit 824731ada9
5 changed files with 61 additions and 7 deletions

View File

@@ -0,0 +1,39 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Tnb.WarehouseMgr.Entities.Dto.Inputs
{
/// <summary>
/// 机器人回调操作输入参数s
/// </summary>
public class RobotCallBackInput
{
/// <summary>
/// 主载具Id
/// </summary>
public string carry_id { get; set; }
/// <summary>
/// 主载具编号
/// </summary>
public string carry_code { get; set; }
/// <summary>
/// 子载具ID
/// </summary>
public string membercarry_id { get; set; }
/// <summary>
/// 子载具编号
/// </summary>
public string membercarry_code { get; set; }
/// <summary>
/// 方向
/// </summary>
public int direction { get; set; }
/// <summary>
/// 是否最后一个
/// </summary>
public bool isLast { get; set; }
}
}

View File

@@ -52,7 +52,7 @@ namespace Tnb.WarehouseMgr
_billRullService = billRullService;
OverideFuncs.CreateAsync = CarryBind;
}
private async Task<dynamic> CarryBind(VisualDevModelDataCrInput input)
{
var isOk = false;
@@ -127,6 +127,19 @@ namespace Tnb.WarehouseMgr
}
return Task.FromResult(true);
}
/// <summary>
/// 机器人回调操作
/// </summary>
/// <returns></returns>
[HttpPost]
public async Task RobotCallBack()
{
}
/* public override async Task ModifyAsync(WareHouseUpInput input)
{
if (input == null) throw new ArgumentNullException(nameof(input));

View File

@@ -50,7 +50,7 @@ namespace Tnb.WarehouseMgr
})
.Mapper(it => it.material_name = dicMaterial.ContainsKey(it.material_id) ? dicMaterial[it.material_id].ToString()! : "")
.ToListAsync();
return items;
return items ?? Enumerable.Empty<dynamic>();
}
}
}

View File

@@ -31,10 +31,10 @@ namespace Tnb.WarehouseMgr
/// 空载具出库
/// </summary>
[OverideVisualDev(ModuleConsts.MODULE_WMSEMPTYOUTSTKPDA_ID)]
[ServiceModule(BizTypeId)]
public class WmsPDAEmptyOutstockService : BaseWareHouseService, IPdaStroage
{
private const string BizTypeId = "26121986416677";
private const string BizTypeId = "26475845405733";
private readonly ISqlSugarClient _db;
private readonly IRunService _runService;
private readonly IVisualDevService _visualDevService;

View File

@@ -80,10 +80,12 @@ namespace Tnb.WarehouseMgr
break;
}
}
var loc = await _db.Queryable<BasLocation>().SingleAsync(it => it.id == carry.location_id);
loc.is_use = "0";
await _db.Updateable(loc).UpdateColumns(it => it.is_use).ExecuteCommandAsync();
WareHouseUpInput upInput = new() { bizTypeId = disTask.biz_type, requireId = disTask.require_id, carryIds = new List<string> { input.carryId } };
await DoUpdate(upInput); //回更业务
}
var loc = await _db.Queryable<BasLocation>().SingleAsync(it => it.id == carry.location_id);
loc.is_use = "0";
await _db.Updateable(loc).UpdateColumns(it => it.is_use).ExecuteCommandAsync();
}
await _db.Ado.CommitTranAsync();