Skip to content

IoTSharp
IoTSharp

IoTSharp / IoTSharp
10 个月 前同步成功

通知 15
Star 2
Fork 0
IoTSharp
IoTSharp

GitCode（gitcode.net）2024年6月20日维护升级公告

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

提交 0c01cc70 编写于 作者: 麦壳饼's avatar 麦壳饼
浏览文件
操作

去除了没必要的判断

上级 0398c371
隐藏空白更改
内联 并排
Showing with 2 addition and 11 deletion
IoTSharp/Jobs/PushData.cs
浏览文件 @ 0c01cc70
...@@ -21,7 +21,7 @@ using System.Threading.Tasks; ...@@ -21,7 +21,7 @@ using System.Threading.Tasks;
namespace IoTSharp.Jobs namespace IoTSharp.Jobs
{ {
[SilkierQuartz(0, "PushData", "Push Iot Message Data to DataBase ", TriggerGroup = "Data")] [SilkierQuartz(1, "PushData", "Push Iot Message Data to DataBase ", TriggerGroup = "Data")]
public class PushData : IJob public class PushData : IJob
{ {
private readonly AppSettings _appSettings; private readonly AppSettings _appSettings;
...@@ -69,16 +69,7 @@ namespace IoTSharp.Jobs ...@@ -69,16 +69,7 @@ namespace IoTSharp.Jobs
break; break;
case DataCatalog.TelemetryData: case DataCatalog.TelemetryData:
switch (_appSettings.TelemetryStorage) await _storage.StoreTelemetryAsync(msg);
{
case TelemetryStorage.SingleTable:
await _storage.StoreTelemetryAsync(msg);
break;
case TelemetryStorage.Sharding:
break;
default:
break;
}
var result1 = await _dbContext.SaveAsync<TelemetryLatest>(msg.MsgBody, device, msg.DataSide); var result1 = await _dbContext.SaveAsync<TelemetryLatest>(msg.MsgBody, device, msg.DataSide);
if (result1.exceptions?.Count > 0) if (result1.exceptions?.Count > 0)
{ {
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或