Compare commits
3 Commits
2e6f2f464b
...
8348185272
| Author | SHA1 | Date | |
|---|---|---|---|
| 8348185272 | |||
| a5894ceeb7 | |||
| 759842b528 |
@ -1,11 +1,15 @@
|
|||||||
using System;
|
using System;
|
||||||
using System.Collections.Generic;
|
using System.Collections.Generic;
|
||||||
|
using System.Linq;
|
||||||
|
|
||||||
using BlubbFish.Utils.IoT.Events;
|
using BlubbFish.Utils.IoT.Events;
|
||||||
|
|
||||||
namespace BlubbFish.Utils.IoT.Connector {
|
namespace BlubbFish.Utils.IoT.Connector {
|
||||||
public abstract class ABackend {
|
public abstract class ABackend {
|
||||||
public enum BackendType {
|
public enum BackendType {
|
||||||
Data,
|
Data,
|
||||||
|
Db,
|
||||||
|
Storage,
|
||||||
User
|
User
|
||||||
}
|
}
|
||||||
public event BackendMessage MessageIncomming;
|
public event BackendMessage MessageIncomming;
|
||||||
@ -18,20 +22,44 @@ namespace BlubbFish.Utils.IoT.Connector {
|
|||||||
|
|
||||||
public ABackend(Dictionary<String, String> settings) => this.settings = settings;
|
public ABackend(Dictionary<String, String> settings) => this.settings = settings;
|
||||||
|
|
||||||
|
|
||||||
|
public static ABackend GetInstance(Dictionary<String, String> settings) {
|
||||||
|
if(settings.Count == 0) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
try {
|
||||||
|
return GetInstance(settings, (BackendType)Enum.Parse(typeof(BackendType), settings["backendtype"]));
|
||||||
|
} catch(Exception e) {
|
||||||
|
throw new Exception("Something bad Happend while Loading Connector without type: " + e.Message);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public static ABackend GetStorageInstance(Dictionary<String, String> settings, List<Type> types) {
|
||||||
|
if(settings.Count == 0 || types.Count != 1) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
String object_sensor = "BlubbFish.Utils.IoT.Connector.Storage." + settings["type"].ToUpperLower() + "`"+types.Count+"["+ String.Join(",", new List<String>(types.Select(x => "["+x.FullName + "," + x.Assembly.FullName+"]"))) + "], " + "ConnectorStorage" + settings["type"].ToUpperLower();
|
||||||
|
return LoadInstance(object_sensor, settings, "Storage");
|
||||||
|
}
|
||||||
|
|
||||||
public static ABackend GetInstance(Dictionary<String, String> settings, BackendType ty) {
|
public static ABackend GetInstance(Dictionary<String, String> settings, BackendType ty) {
|
||||||
if (settings.Count == 0) {
|
if (settings.Count == 0) {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
String object_sensor = "BlubbFish.Utils.IoT.Connector." + ty.ToString() + "." + settings["type"].ToUpperLower() + ", " + "Connector" + ty.ToString() + settings["type"].ToUpperLower();
|
String object_sensor = "BlubbFish.Utils.IoT.Connector." + ty.ToString() + "." + settings["type"].ToUpperLower() + ", " + "Connector" + ty.ToString() + settings["type"].ToUpperLower();
|
||||||
|
return LoadInstance(object_sensor, settings, ty.ToString());
|
||||||
|
}
|
||||||
|
|
||||||
|
public static ABackend LoadInstance(String object_sensor, Dictionary<String, String> settings, String backendtype) {
|
||||||
try {
|
try {
|
||||||
Type t = Type.GetType(object_sensor, true);
|
Type t = Type.GetType(object_sensor, true);
|
||||||
return (ABackend)t.GetConstructor(new Type[] { typeof(Dictionary<String, String>) }).Invoke(new Object[] { settings });
|
return (ABackend)t.GetConstructor(new Type[] { typeof(Dictionary<String, String>) }).Invoke(new Object[] { settings });
|
||||||
} catch(TypeLoadException) {
|
} catch(TypeLoadException) {
|
||||||
throw new TypeLoadException("Configuration: " + settings["type"] + " is not a " + ty.ToString() + "Backend");
|
throw new TypeLoadException("Configuration: " + settings["type"] + " is not a " + backendtype + "Backend");
|
||||||
} catch(System.IO.FileNotFoundException) {
|
} catch(System.IO.FileNotFoundException) {
|
||||||
throw new DllNotFoundException("Driver " + object_sensor + " could not load!");
|
throw new DllNotFoundException("Driver " + object_sensor + " could not load!");
|
||||||
} catch(Exception e) {
|
} catch(Exception e) {
|
||||||
throw new Exception("Something bad Happend while Loading Connectior: "+e.Message);
|
throw new Exception("Something bad Happend while Loading Connector: " + e.Message);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
14
Utils-IoT/Connector/ADbBackend.cs
Normal file
14
Utils-IoT/Connector/ADbBackend.cs
Normal file
@ -0,0 +1,14 @@
|
|||||||
|
using System;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
|
||||||
|
namespace BlubbFish.Utils.IoT.Connector {
|
||||||
|
public abstract class ADbBackend : ABackend {
|
||||||
|
public ADbBackend(Dictionary<String, String> settings) : base(settings) { }
|
||||||
|
|
||||||
|
public abstract T LoadSingleRow<T>(String query, Dictionary<String, Object> param) where T : new();
|
||||||
|
|
||||||
|
public abstract List<T> LoadMultiRows<T>(String query, Dictionary<String, Object> param) where T : new();
|
||||||
|
|
||||||
|
public abstract Int32 Insert(String query, Dictionary<String, Object> param);
|
||||||
|
}
|
||||||
|
}
|
||||||
14
Utils-IoT/Connector/AStorageBackend.cs
Normal file
14
Utils-IoT/Connector/AStorageBackend.cs
Normal file
@ -0,0 +1,14 @@
|
|||||||
|
using System;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
|
||||||
|
namespace BlubbFish.Utils.IoT.Connector {
|
||||||
|
public abstract class AStorageBackend<O> : ABackend {
|
||||||
|
public AStorageBackend(Dictionary<String, String> settings) : base(settings) { }
|
||||||
|
|
||||||
|
public abstract Dictionary<String, O> Get() ;
|
||||||
|
|
||||||
|
public abstract O Get(String key);
|
||||||
|
|
||||||
|
public abstract Boolean Put(O param, String key);
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -5,6 +5,5 @@ namespace BlubbFish.Utils.IoT.Connector {
|
|||||||
public abstract class AUserBackend : ABackend {
|
public abstract class AUserBackend : ABackend {
|
||||||
public AUserBackend(Dictionary<String, String> settings) : base(settings) {}
|
public AUserBackend(Dictionary<String, String> settings) : base(settings) {}
|
||||||
public abstract void Send(String message);
|
public abstract void Send(String message);
|
||||||
public abstract void Send(String message, String[] buttons);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
58
Utils-IoT/Events/GpsEvent.cs
Normal file
58
Utils-IoT/Events/GpsEvent.cs
Normal file
@ -0,0 +1,58 @@
|
|||||||
|
using System;
|
||||||
|
|
||||||
|
namespace BlubbFish.Utils.IoT.Events {
|
||||||
|
public class GpsEvent : BackendEvent {
|
||||||
|
#region mandatory field
|
||||||
|
public Double BatteryLevel {
|
||||||
|
get; set;
|
||||||
|
}
|
||||||
|
public Boolean CorrectInterface {
|
||||||
|
get; set;
|
||||||
|
}
|
||||||
|
public LoraDataGps Gps {
|
||||||
|
get; set;
|
||||||
|
}
|
||||||
|
public String Hash {
|
||||||
|
get; set;
|
||||||
|
}
|
||||||
|
public String Name {
|
||||||
|
get; set;
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region optional field
|
||||||
|
public DateTime Receivedtime {
|
||||||
|
get; set;
|
||||||
|
}
|
||||||
|
public Double Rssi {
|
||||||
|
get; set;
|
||||||
|
}
|
||||||
|
public Double Snr {
|
||||||
|
get; set;
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
public class LoraDataGps {
|
||||||
|
#region mandatory field
|
||||||
|
public Double Latitude {
|
||||||
|
get; set;
|
||||||
|
}
|
||||||
|
public Double Longitude {
|
||||||
|
get; set;
|
||||||
|
}
|
||||||
|
public Boolean Fix {
|
||||||
|
get; set;
|
||||||
|
}
|
||||||
|
public Double Height {
|
||||||
|
get; set;
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region optional field
|
||||||
|
public Double Hdop {
|
||||||
|
get; set;
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -3,6 +3,6 @@
|
|||||||
namespace BlubbFish.Utils.IoT.Events {
|
namespace BlubbFish.Utils.IoT.Events {
|
||||||
public class UserEvent : BackendEvent {
|
public class UserEvent : BackendEvent {
|
||||||
public UserEvent() : base() { }
|
public UserEvent() : base() { }
|
||||||
public UserEvent(String message, Int64 UserId, DateTime date) : base(message, UserId, date, "User") { }
|
public UserEvent(String message, Tuple<Int64, String, Int64, String> UserId, DateTime date) : base(message, UserId, date, "User") { }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,7 +1,7 @@
|
|||||||
<Project Sdk="Microsoft.NET.Sdk">
|
<Project Sdk="Microsoft.NET.Sdk">
|
||||||
|
|
||||||
<PropertyGroup>
|
<PropertyGroup>
|
||||||
<TargetFramework>netcoreapp3.1</TargetFramework>
|
<TargetFramework>net10.0</TargetFramework>
|
||||||
<RootNamespace>BlubbFish.Utils.IoT</RootNamespace>
|
<RootNamespace>BlubbFish.Utils.IoT</RootNamespace>
|
||||||
<AssemblyName>Utils-IoT</AssemblyName>
|
<AssemblyName>Utils-IoT</AssemblyName>
|
||||||
<NeutralLanguage>de-DE</NeutralLanguage>
|
<NeutralLanguage>de-DE</NeutralLanguage>
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user