| | |
|---|
| | | ILogger<RobotJob> logger) |
|---|
| | | { |
|---|
| | | // 初始化状态管理器，传入缓存服务 |
|---|
| | | _stateManager = new RobotStateManager(cache); |
|---|
| | | _stateManager = new RobotStateManager(cache, _logger); |
|---|
| | | _logger = logger; |
|---|
| | | |
|---|
| | | // 创建 Socket 网关，封装 TcpSocketServer 的访问 |
|---|
| | |
|---|
| | | ISocketClientGateway socketGateway = new SocketClientGateway(tcpSocket); |
|---|
| | | |
|---|
| | | // 初始化任务处理器 |
|---|
| | | _taskProcessor = new RobotTaskProcessor(socketGateway, _stateManager, robotTaskService, taskService, httpClientHelper); |
|---|
| | | _taskProcessor = new RobotTaskProcessor(socketGateway, _stateManager, robotTaskService, taskService, httpClientHelper, _logger); |
|---|
| | | |
|---|
| | | // 初始化客户端管理器 |
|---|
| | | _clientManager = new RobotClientManager(tcpSocket, _stateManager); |
|---|
| | | _clientManager = new RobotClientManager(tcpSocket, _stateManager, _logger); |
|---|
| | | |
|---|
| | | // 初始化命令处理器 |
|---|
| | | // 简单命令处理器：处理状态更新等简单命令 |
|---|
| | |
|---|
| | | _messageRouter = new RobotMessageHandler(socketGateway, _stateManager, cache, simpleCommandHandler, prefixCommandHandler, logger); |
|---|
| | | |
|---|
| | | // 初始化工作流编排器 |
|---|
| | | _workflowOrchestrator = new RobotWorkflowOrchestrator(_stateManager, _clientManager, _taskProcessor, robotTaskService); |
|---|
| | | _workflowOrchestrator = new RobotWorkflowOrchestrator(_stateManager, _clientManager, _taskProcessor, robotTaskService, _logger); |
|---|
| | | |
|---|
| | | // 订阅客户端断开连接事件 |
|---|
| | | _clientManager.OnClientDisconnected += OnClientDisconnected; |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 检查任务总数是否未达到上限 |
|---|
| | | if (latestState.RobotTaskTotalNum < MaxTaskTotalNum) |
|---|
| | | { |
|---|
| | | //if (latestState.RobotTaskTotalNum < MaxTaskTotalNum) |
|---|
| | | //{ |
|---|
| | | // 调用工作流编排器执行任务 |
|---|
| | | // 编排器会根据当前状态决定下一步动作 |
|---|
| | | await _workflowOrchestrator.ExecuteAsync(latestState, task, ipAddress); |
|---|
| | | } |
|---|
| | | //} |
|---|
| | | } |
|---|
| | | } |
|---|
| | | catch (Exception ex) |
|---|
