| | |
|---|
| | | { |
|---|
| | | // 记录接收到的消息日志 |
|---|
| | | _logger.LogInformation($"接收到客户端【{state.RobotCrane.DeviceName}】发送消息【{message}】"); |
|---|
| | | QuartzLogger.Error($"接收到客户端消息【{message}】", state.RobotCrane.DeviceName); |
|---|
| | | QuartzLogger.Info($"接收到客户端消息【{message}】", state.RobotCrane.DeviceName); |
|---|
| | | |
|---|
| | | // 构建缓存键，检查 Redis 中是否存在该设备的状态 |
|---|
| | | var cacheKey = $"{RedisPrefix.Code}:{RedisName.SocketDevices}:{client.Client.RemoteEndPoint}"; |
|---|
| | |
|---|
| | | // 处理成功后，将原消息回写到客户端（保持原有行为） |
|---|
| | | await _socketClientGateway.SendMessageAsync(client, message); |
|---|
| | | _logger.LogInformation($"发送消息【{message}】"); |
|---|
| | | QuartzLogger.Error($"发送消息：【{message}】", state.RobotCrane.DeviceName); |
|---|
| | | QuartzLogger.Info($"发送消息：【{message}】", state.RobotCrane.DeviceName); |
|---|
| | | |
|---|
| | | // 安全更新状态到 Redis |
|---|
| | | _stateManager.TryUpdateStateSafely(activeState.IPAddress, activeState); |
|---|
