ReiMerc/temperature-alarm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Mqtt works at the same time as api

Browse Source
This commit is contained in:
Jeas0001 2025-03-24 13:02:39 +01:00
parent 428e187aa4
commit 837f10037d
2 changed files with 17 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
backend/Api/MQTTReciever/MQTTReciever.cs
View File

@ -52,9 +52,11 @@ namespace Api.MQTTReciever
string refernceId = mqttMessageReceive.device_id; string refernceId = mqttMessageReceive.device_id;
var device = _dbAccess.ReadDevice(refernceId); var device = _dbAccess.ReadDevice(refernceId);
if (device == null) { return Task.CompletedTask; }
newLog.Temperature = mqttMessageReceive.temperature; newLog.Temperature = mqttMessageReceive.temperature;
newLog.Date = DateTimeOffset.FromUnixTimeSeconds(mqttMessageReceive.timestamp).DateTime; newLog.Date = DateTimeOffset.FromUnixTimeSeconds(mqttMessageReceive.timestamp).DateTime;
newLog.TempHigh= device.TempHigh; newLog.TempHigh = device.TempHigh;
newLog.TempLow = device.TempLow; newLog.TempLow = device.TempLow;
_dbAccess.CreateLog(newLog, refernceId); _dbAccess.CreateLog(newLog, refernceId);

25
backend/Api/Program.cs
View File

@ -10,19 +10,22 @@ class Program
{ {
var app = CreateWebHostBuilder(args).Build(); var app = CreateWebHostBuilder(args).Build();
using (var scope = app.Services.CreateScope())
{
var services = scope.ServiceProvider;
var configuration = services.GetRequiredService<IConfiguration>();
var dbAccess = services.GetRequiredService<DbAccess>();
MQTTReciever mqtt = new MQTTReciever(configuration, dbAccess);
mqtt.Handle_Received_Application_Message();
}
RunMigrations(app); RunMigrations(app);
Task.Run(() =>
{
using (var scope = app.Services.CreateScope())
{
var services = scope.ServiceProvider;
var configuration = services.GetRequiredService<IConfiguration>();
var dbAccess = services.GetRequiredService<DbAccess>();
MQTTReciever mqtt = new MQTTReciever(configuration, dbAccess);
mqtt.Handle_Received_Application_Message().Wait();
}
});
app.Run(); app.Run();
} }