diff --git a/IoTSharp/Jobs/PushData.cs b/IoTSharp/Jobs/PushData.cs index 3262a0f6a06522ac85d3322a6429ef847ab5e48a..2d950a7e042e0d443013f1e964146c7afc2dc391 100644 --- a/IoTSharp/Jobs/PushData.cs +++ b/IoTSharp/Jobs/PushData.cs @@ -58,27 +58,19 @@ namespace IoTSharp.Jobs case DataCatalog.AttributeData: var result2 = await _dbContext.SaveAsync(msg.MsgBody, device, msg.DataSide); - if (result2.exceptions?.Count > 0) + result2.exceptions?.ToList().ForEach(ex => { - _logger.LogError(Newtonsoft.Json.JsonConvert.SerializeObject(msg.MsgBody)); - } - else - { - _logger.LogInformation(Newtonsoft.Json.JsonConvert.SerializeObject(result2)); - } + _logger.LogError($"{ex.Key} {ex.Value}"); + }); break; case DataCatalog.TelemetryData: await _storage.StoreTelemetryAsync(msg); var result1 = await _dbContext.SaveAsync(msg.MsgBody, device, msg.DataSide); - if (result1.exceptions?.Count > 0) - { - _logger.LogError(Newtonsoft.Json.JsonConvert.SerializeObject(msg.MsgBody)); - } - else + result1.exceptions?.ToList().ForEach(ex => { - _logger.LogInformation(Newtonsoft.Json.JsonConvert.SerializeObject(result1)); - } + _logger.LogError($"{ex.Key} {ex.Value}"); + }); break; default: break;