Compare commits
25
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
a7fe9d7279 | ||
|
|
b5e7d81d28 | ||
|
|
35aadc09cf | ||
|
|
af7eeeaf15 | ||
|
|
c47895e6bb | ||
|
|
3a19253230 | ||
|
|
58f467a591 | ||
|
|
52bb4bcea7 | ||
|
|
3760f36e9f | ||
|
|
05cbcdf2dc | ||
|
|
dd4cc7635c | ||
|
|
bf49abfd44 | ||
|
|
566f840012 | ||
|
|
d1a8fa449b | ||
|
|
1da54f7416 | ||
|
|
eb4783c11e | ||
|
|
c06d910356 | ||
|
|
02871e4d66 | ||
|
|
edb59f01b6 | ||
|
|
ce30132f5f | ||
|
|
64c9020bcb | ||
|
|
a22628b0d0 | ||
|
|
64d74668cc | ||
|
|
e53529b9d4 | ||
|
|
ca399a405c |
@@ -31,13 +31,21 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
}
|
||||
|
||||
private void InitComplex(JsonData json) {
|
||||
if (json.Keys.Contains("data") && json["data"].Keys.Contains("V1event") &&
|
||||
json["data"]["V1event"].Keys.Contains("alarmType") && json["data"]["V1event"]["alarmType"].Keys.Contains("value") &&
|
||||
json["data"]["V1event"].Keys.Contains("level") && json["data"]["V1event"]["level"].Keys.Contains("value")) {
|
||||
if (json.Keys.Contains("data") && json["data"].Keys.Contains("V1event")) {
|
||||
if(json["data"]["V1event"].Keys.Contains("alarmType") &&
|
||||
json["data"]["V1event"]["alarmType"].Keys.Contains("value") &&
|
||||
json["data"]["V1event"]["alarmType"]["value"] != null &&
|
||||
json["data"]["V1event"]["alarmType"]["value"].IsInt) {
|
||||
this.AlarmType = Int32.Parse(json["data"]["V1event"]["alarmType"]["value"].ToString());
|
||||
}
|
||||
if(json["data"]["V1event"].Keys.Contains("level") &&
|
||||
json["data"]["V1event"]["level"].Keys.Contains("value") &&
|
||||
json["data"]["V1event"]["level"]["value"] != null &&
|
||||
json["data"]["V1event"]["level"]["value"].IsInt) {
|
||||
this.Level = Int32.Parse(json["data"]["V1event"]["level"]["value"].ToString());
|
||||
}
|
||||
}
|
||||
}
|
||||
#endregion
|
||||
|
||||
#region ACommandClass
|
||||
|
||||
@@ -65,7 +65,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
Double l = Double.Parse(json["val"]["value"].ToString());
|
||||
if (t == "Power" && (l > 3660 || l < 0) ||
|
||||
t == "Temperature" && (l > 65 || l < -25) ||
|
||||
(t == "Temperature" && this.Level >= 4 && l == 0)) {
|
||||
(t == "Temperature" && this.Level >= 4 && Math.Abs(l) <= 0.1)) {
|
||||
return;
|
||||
}
|
||||
}
|
||||
@@ -89,6 +89,8 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
return new List<Senml>() { new SenmlDouble("power", Senml.Units.Watt, this.Level) };
|
||||
} else if(this.Scale == "°C") {
|
||||
return new List<Senml>() { new SenmlDouble("temperatur", Senml.Units.Celsius, this.Level) };
|
||||
} else if(this.Scale == "Lux") {
|
||||
return new List<Senml>() { new SenmlDouble("luminiscence", Senml.Units.Lux, this.Level) };
|
||||
}
|
||||
return new List<Senml>() { };
|
||||
}
|
||||
|
||||
@@ -8,7 +8,7 @@ using LitJson;
|
||||
|
||||
namespace BlubbFish.IoT.Zway.Devices {
|
||||
public class Device {
|
||||
private Boolean polling;
|
||||
private readonly Boolean polling;
|
||||
|
||||
public delegate void UpdatedDevice(Object sender, DeviceUpdateEvent e);
|
||||
public event UpdatedDevice Update;
|
||||
|
||||
@@ -10,7 +10,7 @@ using LitJson;
|
||||
namespace BlubbFish.IoT.Zway.Devices {
|
||||
public class Instance {
|
||||
private DateTime nextwakeup;
|
||||
private Boolean polling;
|
||||
private readonly Boolean polling;
|
||||
|
||||
public delegate void UpdatedInstance(Object sender, DeviceUpdateEvent e);
|
||||
public event UpdatedInstance Update;
|
||||
|
||||
@@ -23,22 +23,29 @@ namespace BlubbFish.IoT.Zway.Interfaces {
|
||||
SwitchColor = 51,
|
||||
MeterPulse = 53,
|
||||
MeterTableMonitor = 61,
|
||||
ThermostatOperatingState = 66,
|
||||
ClimateControlSchedule = 70,
|
||||
CRC16 = 86,
|
||||
AssociationGroupInformation = 89,
|
||||
DeviceResetLocally = 90,
|
||||
ZWavePlusInfo = 94,
|
||||
MultiChannel = 96,
|
||||
DoorLock = 98,
|
||||
BarrierOperator = 102,
|
||||
ManufacturerSpecific = 114,
|
||||
PowerLevel = 115,
|
||||
InclusionController = 116,
|
||||
Protection = 117,
|
||||
NodeNaming = 119,
|
||||
FirmwareUpdate = 122,
|
||||
Clock = 129,
|
||||
Association = 133,
|
||||
Version = 134,
|
||||
Proprietary = 136,
|
||||
TimeParameters = 139,
|
||||
MultiChannelAssociation = 142,
|
||||
MultiCmd = 143,
|
||||
SimpleAVControl = 148,
|
||||
Security = 152
|
||||
}
|
||||
|
||||
@@ -266,7 +273,7 @@ namespace BlubbFish.IoT.Zway.Interfaces {
|
||||
}
|
||||
|
||||
public String SenmlTopic() {
|
||||
return "/LS/v2/ZGW/" + Guid.NewGuid().ToString();
|
||||
return "LS/v2/ZGW/";
|
||||
}
|
||||
#endregion
|
||||
|
||||
|
||||
@@ -10,7 +10,7 @@ using System.Runtime.InteropServices;
|
||||
[assembly: AssemblyConfiguration("")]
|
||||
[assembly: AssemblyCompany("")]
|
||||
[assembly: AssemblyProduct("Zway")]
|
||||
[assembly: AssemblyCopyright("Copyright © 2017 - 03.05.2018")]
|
||||
[assembly: AssemblyCopyright("Copyright © 2017 - 29.09.2018")]
|
||||
[assembly: AssemblyTrademark("")]
|
||||
[assembly: AssemblyCulture("")]
|
||||
|
||||
@@ -32,5 +32,5 @@ using System.Runtime.InteropServices;
|
||||
// Sie können alle Werte angeben oder Standardwerte für die Build- und Revisionsnummern verwenden,
|
||||
// indem Sie "*" wie unten gezeigt eingeben:
|
||||
// [assembly: AssemblyVersion("1.0.*")]
|
||||
[assembly: AssemblyVersion("1.4.1.0")]
|
||||
[assembly: AssemblyFileVersion("1.4.1.0")]
|
||||
[assembly: AssemblyVersion("1.5.1")]
|
||||
[assembly: AssemblyFileVersion("1.5.1")]
|
||||
|
||||
@@ -16,7 +16,7 @@ namespace BlubbFish.IoT.Zway {
|
||||
private Thread updatethread;
|
||||
private Thread pollthread;
|
||||
public static ReadOnlyDictionary<String, String> namelist;
|
||||
private Boolean polling;
|
||||
private readonly Boolean polling;
|
||||
|
||||
public delegate void DataUpdate(Object sender, DeviceUpdateEvent e);
|
||||
public event DataUpdate Update;
|
||||
@@ -104,8 +104,10 @@ namespace BlubbFish.IoT.Zway {
|
||||
CultureInfo.DefaultThreadCurrentUICulture = info;
|
||||
Thread.CurrentThread.CurrentCulture = info;
|
||||
Thread.CurrentThread.CurrentUICulture = info;
|
||||
DateTime lastRequest = DateTime.Now.AddSeconds(-2);
|
||||
while (true) {
|
||||
Int64 date = ((DateTimeOffset)DateTime.Now.AddSeconds(-2)).ToUnixTimeSeconds();
|
||||
Int64 date = ((DateTimeOffset)lastRequest).ToUnixTimeSeconds();
|
||||
lastRequest = DateTime.Now;
|
||||
JsonData notifications = this.http.GetJson("ZWave.zway/Data/" + date);
|
||||
foreach (String item in notifications.Keys) {
|
||||
Match match = new Regex("^devices\\.([0-9]+)\\.instances\\.([0-9]+)\\.commandClasses\\.([0-9]+)(\\.data\\.([0-9]+)|\\.data\\.[a-z].*|\\.data)$", RegexOptions.IgnoreCase).Match(item);
|
||||
|
||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
+33
-10
@@ -6,9 +6,9 @@ using LitJson;
|
||||
|
||||
namespace BlubbFish.IoT.Zway.lib {
|
||||
public class HttpConnection {
|
||||
private String auth;
|
||||
private String server;
|
||||
private Object getLock = new Object();
|
||||
private readonly String auth;
|
||||
private readonly String server;
|
||||
private static readonly Object getLock = new Object();
|
||||
|
||||
internal HttpConnection(String server, String user, String pass) {
|
||||
this.auth = "Basic " + Convert.ToBase64String(Encoding.ASCII.GetBytes(user + ":" + pass));
|
||||
@@ -17,11 +17,23 @@ namespace BlubbFish.IoT.Zway.lib {
|
||||
}
|
||||
|
||||
private void Init() {
|
||||
this.GetString("ZAutomation/api/v1/status");
|
||||
this.GetVoid("ZAutomation/api/v1/status");
|
||||
}
|
||||
|
||||
internal JsonData GetJson(String v) {
|
||||
String text = this.GetString(v);
|
||||
String text = null;
|
||||
for (Int32 i = 0; i < 3; i++) {
|
||||
try {
|
||||
text = this.GetString(v);
|
||||
break;
|
||||
} catch (Exception e) {
|
||||
Helper.WriteError(e.Message);
|
||||
if(i==2) {
|
||||
throw;
|
||||
}
|
||||
System.Threading.Thread.Sleep(30000);
|
||||
}
|
||||
}
|
||||
if(text == null) {
|
||||
return new JsonData();
|
||||
}
|
||||
@@ -33,14 +45,25 @@ namespace BlubbFish.IoT.Zway.lib {
|
||||
}
|
||||
|
||||
internal void GetVoid(String v) {
|
||||
for (Int32 i = 0; i < 3; i++) {
|
||||
try {
|
||||
this.GetString(v, false);
|
||||
break;
|
||||
} catch (Exception e) {
|
||||
Helper.WriteError(e.Message);
|
||||
if (i == 2) {
|
||||
throw;
|
||||
}
|
||||
System.Threading.Thread.Sleep(30000);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private String GetString(String v, Boolean withoutput = true) {
|
||||
String ret = null;
|
||||
lock (this.getLock) {
|
||||
lock (getLock) {
|
||||
HttpWebRequest request = WebRequest.CreateHttp(this.server + v);
|
||||
request.Timeout = 5000;
|
||||
request.Timeout = 10000;
|
||||
request.Headers.Add(HttpRequestHeader.Authorization, this.auth);
|
||||
try {
|
||||
using (HttpWebResponse response = (HttpWebResponse)request.GetResponse()) {
|
||||
@@ -54,9 +77,9 @@ namespace BlubbFish.IoT.Zway.lib {
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
Helper.WriteError("Konnte keine Verbindung zum Razzbery Server herstellen. Resource: \"" + this.server + v + "\" Fehler: " + e.Message);
|
||||
return null;
|
||||
//throw new Exceptions.ConnectionException("Konnte keine Verbindung zum Razzbery Server herstellen: " + e.Message);
|
||||
//Helper.WriteError("Konnte keine Verbindung zum Razzbery Server herstellen. Resource: \"" + this.server + v + "\" Fehler: " + e.Message);
|
||||
//return null;
|
||||
throw new Exceptions.ConnectionException("Konnte keine Verbindung zum Razzbery Server herstellen: " + e.Message);
|
||||
}
|
||||
}
|
||||
return ret;
|
||||
|
||||
Reference in New Issue
Block a user