feat: 更新数据库连接配置和机器人任务处理逻辑

wanshenmean

昨天 05999b9c77f009ac9a7e98366bc3d23fbb8e83e7

 Code/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/RobotJob/Workflow/RobotSimpleCommandHandler.cs

@@ -159,6 +159,8 @@
                    var isResult = UpdateStatus(state, true);
                    if (!isResult)
                        return false;

                    await _socketClientGateway.SendToClientAsync(state.IPAddress, "pickbatteryover");
                    return true;

                // 放货接收
@@ -166,6 +168,8 @@
                    isResult = UpdateStatus(state, false);
                    if (!isResult)
                        return false;

                    await _socketClientGateway.SendToClientAsync(state.IPAddress, "putbatteryover");
                    return true;

                // ==================== 全部完成命令 ====================
@@ -213,8 +217,8 @@
                                    return false;
                                }

                                await _socketClientGateway.SendToClientAsync(state.IPAddress, $"Swap,diskFinished");
                                QuartzLogHelper.LogInfo(_logger, $"发送消息：【Swap,diskFinished】", state.RobotCrane.DeviceName);
                                await _socketClientGateway.SendToClientAsync(state.IPAddress, $"Group,diskFinished");
                                QuartzLogHelper.LogInfo(_logger, $"发送消息：【Group,diskFinished】", state.RobotCrane.DeviceName);

                                state.CurrentTask = null;
                                state.RobotTaskTotalNum = 0;
@@ -242,14 +246,14 @@
                                return false;
                            }

                            if (_taskProcessor.DeleteTask(currentTask.RobotTaskId) != true)
                            {
                                QuartzLogHelper.LogError(_logger, $"allpickfinished：删除任务记录失败，任务号: {currentTask.RobotTaskNum}", state.RobotCrane?.DeviceName ?? "Unknown");
                                return false;
                            }
                            //if (_taskProcessor.DeleteTask(currentTask.RobotTaskId) != true)
                            //{
                            //    QuartzLogHelper.LogError(_logger, $"allpickfinished：删除任务记录失败，任务号: {currentTask.RobotTaskNum}", state.RobotCrane?.DeviceName ?? "Unknown");
                            //    return false;
                            //}

                            await _socketClientGateway.SendToClientAsync(state.IPAddress, $"Swap,diskFinished");
                            QuartzLogHelper.LogInfo(_logger, $"发送消息：【Swap,diskFinished】", state.RobotCrane.DeviceName);
                            await _socketClientGateway.SendToClientAsync(state.IPAddress, $"Group,diskFinished");
                            QuartzLogHelper.LogInfo(_logger, $"发送消息：【Group,diskFinished】", state.RobotCrane.DeviceName);

                            state.ChangePalletPhase = 0;
                            state.CurrentBatchIndex = 1;
@@ -281,8 +285,8 @@
                                return false;
                            }

                            await _socketClientGateway.SendToClientAsync(state.IPAddress, $"Swap,diskFinished");
                            QuartzLogHelper.LogInfo(_logger, $"发送消息：【Swap,diskFinished】", state.RobotCrane.DeviceName);
                            await _socketClientGateway.SendToClientAsync(state.IPAddress, $"Group,diskFinished");
                            QuartzLogHelper.LogInfo(_logger, $"发送消息：【Group,diskFinished】", state.RobotCrane.DeviceName);
                            return true;
                        }
                        return false;
@@ -334,8 +338,8 @@
                                state.RobotTaskTotalNum = 0;
                                state.CellBarcode = new List<string>();

                                await _socketClientGateway.SendToClientAsync(state.IPAddress, $"Swap,diskFinished");
                                QuartzLogHelper.LogInfo(_logger, $"发送消息：【Swap,diskFinished】", state.RobotCrane.DeviceName);
                                await _socketClientGateway.SendToClientAsync(state.IPAddress, $"Group,diskFinished");
                                QuartzLogHelper.LogInfo(_logger, $"发送消息：【Group,diskFinished】", state.RobotCrane.DeviceName);

                                state.ChangePalletPhase = 0;
                                state.CurrentBatchIndex = 1;
@@ -370,8 +374,8 @@
                            state.RobotTaskTotalNum = 0;
                            state.CellBarcode = new List<string>();

                            await _socketClientGateway.SendToClientAsync(state.IPAddress, $"Swap,diskFinished");
                            QuartzLogHelper.LogInfo(_logger, $"发送消息：【Swap,diskFinished】", state.RobotCrane.DeviceName);
                            await _socketClientGateway.SendToClientAsync(state.IPAddress, $"Group,diskFinished");
                            QuartzLogHelper.LogInfo(_logger, $"发送消息：【Group,diskFinished】", state.RobotCrane.DeviceName);

                            state.ChangePalletPhase = 0;
                            state.CurrentBatchIndex = 1;
@@ -461,14 +465,14 @@

        public bool UpdateStatus(RobotSocketState state, bool isPick)
        {
            var task = _taskProcessor.GetTask(state?.RobotCrane);
            var task = _taskProcessor.GetRobotTask(state?.RobotCrane);
            if (task == null)
            {
                QuartzLogHelper.LogError(_logger, $"取货接收失败: 未找到【{state?.RobotCrane}】的任务", state.RobotCrane?.DeviceName ?? "Unknown");
                return false;
            }
            task.RobotTaskState = (int)TaskRobotStatusEnum.RobotExecuting;
            _taskProcessor.UpdateRobotTask(task);
            return true;
            return _taskProcessor.UpdateRobotTask(task);
        }
    }
}