wenkai.chen/tnb.server
Template
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

呼梯时，到指定目标楼层，根据任务的start_floor来

Browse Source
This commit is contained in:
alex
2023-10-10 16:03:04 +08:00
parent ab9608aec2
commit 0896186295
4 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
WarehouseMgr/Tnb.WarehouseMgr.Interfaces/IWareHouseService.cs
View File

@@ -71,6 +71,6 @@ namespace Tnb.WarehouseMgr.Interfaces
/// /// <param name="input"></param> /// /// <param name="input"></param>
/// <returns></returns> /// <returns></returns>
Task TaskExecuteAfter(TaskExecuteAfterUpInput input); Task TaskExecuteAfter(TaskExecuteAfterUpInput input);
Func<string,Task> AddUnExecuteTask { get; set; } Func<string,int,Task> AddUnExecuteTask { get; set; }
} }
} }

4
WarehouseMgr/Tnb.WarehouseMgr/DeviceProviderService.cs
View File

@@ -258,7 +258,7 @@ namespace Tnb.WarehouseMgr
elevatorQueueItem = await _db.Queryable<WmsElevatorUnexecute>().FirstAsync(it => disTasks.Select(x => x.id).Contains(it.distask_id) && it.task_status == "待执行"); elevatorQueueItem = await _db.Queryable<WmsElevatorUnexecute>().FirstAsync(it => disTasks.Select(x => x.id).Contains(it.distask_id) && it.task_status == "待执行");
if (!elevatorQueueItem?.elevator_code.IsNullOrEmpty() ?? false) if (!elevatorQueueItem?.elevator_code.IsNullOrEmpty() ?? false)
{ {
await (_wareHouseService.AddUnExecuteTask?.Invoke(elevatorQueueItem?.elevator_code!) ?? Task.CompletedTask); await (_wareHouseService.AddUnExecuteTask?.Invoke(elevatorQueueItem?.elevator_code!, disTask.start_floor.ParseToInt()) ?? Task.CompletedTask);
} }
} }
} }
@@ -272,7 +272,7 @@ namespace Tnb.WarehouseMgr
disTaskIds = disTasks.Select(x => x.id).ToList() disTaskIds = disTasks.Select(x => x.id).ToList()
}; };
await _wareHouseService.TaskComplate(taskCompleUpInput); await _wareHouseService.TaskComplate(taskCompleUpInput);
} }
} }
catch (Exception ex) catch (Exception ex)

6
WarehouseMgr/Tnb.WarehouseMgr/ElevatorControlService.cs
View File

@@ -33,10 +33,10 @@ namespace Tnb.WarehouseMgr
private static Dictionary<string, Func<BackgroundService, bool>> _fetchStartedStausValue = new(); private static Dictionary<string, Func<BackgroundService, bool>> _fetchStartedStausValue = new();
private bool isFrontDoorBit = false; //是否到前门位 private bool isFrontDoorBit = false; //是否到前门位
public ElevatorControlService(BackgroundService agvHeartbeatMonitorService) public ElevatorControlService()
{ {
_elevatorCtlCfg = App.Configuration.Build<ElevatorControlConfiguration>(); _elevatorCtlCfg = App.Configuration.Build<ElevatorControlConfiguration>();
_agvHeartbeatMonitor = agvHeartbeatMonitorService; //_agvHeartbeatMonitor = agvHeartbeatMonitorService;
} }
/// <summary> /// <summary>
@@ -107,7 +107,7 @@ namespace Tnb.WarehouseMgr
public async Task<dynamic> ThreeFloorElevatorFlow() public async Task<dynamic> ThreeFloorElevatorFlow()
{ {
//test by close door //test by close door
_agvHeartbeatMonitor.StartAsync(CancellationToken.None); //_agvHeartbeatMonitor.StartAsync(CancellationToken.None);
//await SendOpenCloseCmd(4); //await SendOpenCloseCmd(4);
//await SetAgvControlStatus(1); //await SetAgvControlStatus(1);
//监听电梯门是否为关闭的状态 //监听电梯门是否为关闭的状态

8
WarehouseMgr/Tnb.WarehouseMgr/WareHouseService.cs
View File

@@ -49,7 +49,7 @@ namespace Tnb.WarehouseMgr
private readonly IElevatorControlService _elevatorControlService; private readonly IElevatorControlService _elevatorControlService;
private static Dictionary<string, object> _elevatorMap = new Dictionary<string, object>(); private static Dictionary<string, object> _elevatorMap = new Dictionary<string, object>();
private readonly ElevatorControlConfiguration _eleCtlCfg = App.Configuration.Build<ElevatorControlConfiguration>(); private readonly ElevatorControlConfiguration _eleCtlCfg = App.Configuration.Build<ElevatorControlConfiguration>();
public Func<string, Task> AddUnExecuteTask { get; set; } public Func<string, int, Task> AddUnExecuteTask { get; set; }
public WareHouseService(ISqlSugarRepository<WmsInstockH> repository, IDictionaryDataService dictionaryDataService, public WareHouseService(ISqlSugarRepository<WmsInstockH> repository, IDictionaryDataService dictionaryDataService,
IBillRullService billRullService, IUserManager userManager, ICacheManager cacheManager, IElevatorControlService elevatorControlService) IBillRullService billRullService, IUserManager userManager, ICacheManager cacheManager, IElevatorControlService elevatorControlService)
@@ -60,9 +60,9 @@ namespace Tnb.WarehouseMgr
_userManager = userManager; _userManager = userManager;
_cacheManager = cacheManager; _cacheManager = cacheManager;
_elevatorControlService = elevatorControlService; _elevatorControlService = elevatorControlService;
AddUnExecuteTask = async code => AddUnExecuteTask = async (code, floor) =>
{ {
await _elevatorControlService.CallLift(code, 5, CancellationToken.None); await _elevatorControlService.CallLift(code, floor, CancellationToken.None);
}; };
} }
@@ -415,7 +415,7 @@ namespace Tnb.WarehouseMgr
if ((elevatorQueue.IsNull() || elevatorQueue.Count < 1)) if ((elevatorQueue.IsNull() || elevatorQueue.Count < 1))
{ {
elevatorQueueItem.task_status = "执行中"; elevatorQueueItem.task_status = "执行中";
await _elevatorControlService.CallLift(devName, 5, CancellationToken.None); await _elevatorControlService.CallLift(devName, floorNO.ParseToInt(), CancellationToken.None);
} }