From c5d5b3aa68e53dbb571d51f3eeef2a0b5c94a1a9 Mon Sep 17 00:00:00 2001 From: MysticBoy Date: Wed, 5 Aug 2020 12:32:23 +0800 Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E5=86=99=E9=94=99=E8=AF=AF=E6=8F=90?= =?UTF-8?q?=E7=A4=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- IoTSharp/Jobs/PushData.cs | 20 ++++++-------------- 1 file changed, 6 insertions(+), 14 deletions(-) diff --git a/IoTSharp/Jobs/PushData.cs b/IoTSharp/Jobs/PushData.cs index 3262a0f6..2d950a7e 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; -- GitLab