using System;
|
using System.Text;
|
using System.Collections.Generic;
|
using System.Threading;
|
using Newtonsoft.Json;
|
using Shared;
|
using Shared.SimpleControl.Phone;
|
using Newtonsoft.Json.Linq;
|
|
|
namespace SuperGateWay
|
{
|
public class Control
|
{
|
|
|
#if simulation
|
static List<SuperCommon> deviceList = new List<SuperCommon> {
|
new SuperCommon {
|
module="relay",
|
name = "8路继电器",
|
uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (1, 1)),
|
objects = {
|
new System.Collections.Generic.Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (1, 1)), SuperCommon.MakeOid (6, 0, 1)).ToString ("X")
|
},
|
new System.Collections.Generic.Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (1, 1)), SuperCommon.MakeOid (6, 1, 2)).ToString ("X")
|
},
|
new System.Collections.Generic.Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (1, 1)), SuperCommon.MakeOid (6, 1, 3)).ToString ("X")
|
},
|
new System.Collections.Generic.Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (1, 1)), SuperCommon.MakeOid (6, 0, 4)).ToString ("X")
|
},
|
new System.Collections.Generic.Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (1, 1)), SuperCommon.MakeOid (5, 0, 5)).ToString ("X")
|
},
|
|
|
}
|
},
|
|
};
|
static List<Scene> sceneList = new List<Scene> ();
|
#endif
|
|
static Queue<PacketInfo> controlList = new Queue<PacketInfo> ();
|
|
public static List<string> GetFileNameList (string path)
|
{
|
var totalCount = 0;
|
{
|
var pathBytes = System.Text.Encoding.UTF8.GetBytes (path);
|
var bytes = new byte [1 + 4 + pathBytes.Length + 1];
|
bytes [0] = 6;
|
Array.Copy (pathBytes, 0, bytes, 5, pathBytes.Length);
|
var packetInfo = new PacketInfo {
|
Command = 6,
|
Buffer = bytes,
|
};
|
addPacketInfo (packetInfo);
|
if (packetInfo.ResponeBytes == null) {
|
return null;
|
}
|
totalCount = packetInfo.ResponeBytes [4] + packetInfo.ResponeBytes [3] * 256;
|
}
|
try {
|
var length = 1;
|
var sb = new List<byte> ();
|
while (length < totalCount + 1) {
|
var pathBytes = System.Text.Encoding.UTF8.GetBytes (path);
|
var bytes = new byte [1 + 4 + pathBytes.Length + 1];
|
bytes [0] = 6;
|
bytes [1] = (byte)(length / 256);
|
bytes [2] = (byte)(length % 256);
|
Array.Copy (pathBytes, 0, bytes, 5, pathBytes.Length);
|
var packetInfo = new PacketInfo {
|
Command = 6,
|
Buffer = bytes,
|
};
|
addPacketInfo (packetInfo);
|
if (packetInfo.ResponeBytes == null) {
|
return null;
|
}
|
length += packetInfo.ResponeBytes [4] + packetInfo.ResponeBytes [3] * 256;
|
for (int i = packetInfo.Buffer.Length; i < packetInfo.ResponeBytes.Length; i++) {
|
sb.Add (packetInfo.ResponeBytes [i]);
|
}
|
}
|
var sr = new System.IO.StringReader (System.Text.Encoding.ASCII.GetString (sb.ToArray ()));
|
string line = null;
|
var list = new List<string> { };
|
while ((line = sr.ReadLine ()) != null) {
|
list.Add (line);
|
}
|
sr.Close ();
|
return list;
|
} catch {
|
return null;
|
}
|
}
|
public static string GetFile (string filePath)
|
{
|
uint fileSize = 0;
|
{
|
var pathBytes = System.Text.Encoding.UTF8.GetBytes (filePath);
|
var bytes = new byte [1 + 4 + pathBytes.Length + 1];
|
bytes [0] = 3;
|
Array.Copy (pathBytes, 0, bytes, 5, pathBytes.Length);
|
var packetInfo = new PacketInfo {
|
Command = 3,
|
Buffer = bytes,
|
};
|
addPacketInfo (packetInfo);
|
if (packetInfo.ResponeBytes == null) {
|
return null;
|
}
|
fileSize = packetInfo.ResponeBytes [4] + (uint)packetInfo.ResponeBytes [3] * 256 + (uint)packetInfo.ResponeBytes [2] * 256 * 256 + (uint)packetInfo.ResponeBytes [1] * 256 * 256 * 256;
|
}
|
try {
|
var length = 0;
|
var sb = new List<byte> ();
|
while (length < fileSize) {
|
var bytes = new byte [1 + 6];
|
bytes [0] = 4;
|
bytes [1] = (byte)((length >> 24) & 0xFF);
|
bytes [2] = (byte)((length >> 16) & 0xFF);
|
bytes [3] = (byte)((length >> 8) & 0xFF);
|
bytes [4] = (byte)((length >> 0) & 0xFF);
|
bytes [5] = (1024 >> 8) & 0xFF;
|
bytes [6] = (1024 >> 0) & 0xFF;
|
var packetInfo = new PacketInfo {
|
Command = 4,
|
Buffer = bytes,
|
};
|
addPacketInfo (packetInfo);
|
if (packetInfo.ResponeBytes == null) {
|
return null;
|
}
|
length += packetInfo.ResponeBytes [6] + packetInfo.ResponeBytes [5] * 256;
|
for (int i = packetInfo.Buffer.Length; i < packetInfo.ResponeBytes.Length; i++) {
|
sb.Add (packetInfo.ResponeBytes [i]);
|
}
|
}
|
//接收完成
|
|
|
|
var completePacket = new PacketInfo {
|
Command = 5,
|
Buffer = new byte [] { 5 },
|
};
|
addPacketInfo (completePacket);
|
|
|
|
return System.Text.Encoding.UTF8.GetString (sb.ToArray ());
|
//return System.Text.Encoding.ASCII.GetString (sb.ToArray ());
|
} catch {
|
return null;
|
}
|
}
|
|
public static void addPacketInfo (PacketInfo packetInfo)
|
{
|
controlList.Enqueue (packetInfo);
|
if (sendThread == null) {
|
sendThread = new Thread (() => {
|
while (true) {
|
try {
|
var item = controlList.Dequeue ();
|
if (item == null) {
|
break;
|
}
|
sendData (item);
|
} catch { }
|
System.Threading.Thread.Sleep (10);
|
}
|
sendThread = null;
|
});
|
sendThread.Start ();
|
}
|
packetInfo.ManualResetEvent.Reset ();
|
packetInfo.ManualResetEvent.WaitOne ();
|
}
|
|
#region 设备
|
/// <summary>
|
/// 获取所有设备UID
|
/// </summary>
|
/// <returns>The devices uid list.</returns>
|
public static List<string> GetDevicesUidList ()
|
{
|
#if simulation
|
var list = new List<string> { };
|
foreach (var device in deviceList) {
|
list.Add (device.uid.ToString ("X"));
|
}
|
return list;
|
#endif
|
return GetFileNameList ("/device");
|
}
|
/// <summary>
|
/// 根据UID来获取设备信息
|
/// </summary>
|
/// <returns>The device by uid.</returns>
|
/// <param name="uid">Uid.</param>
|
public static string GetDeviceByUID (string uid)
|
{
|
#if simulation
|
var device = deviceList.Find ((d) => d.uid.ToString ("X") == uid);
|
if (device == null) {
|
return null;
|
} else {
|
return Newtonsoft.Json.JsonConvert.SerializeObject (device);
|
}
|
#endif
|
return GetFile ($"/device/{uid}.json");
|
}
|
#endregion
|
|
#region ---Sonos音乐播发器---
|
/// <summary>
|
/// 获取所有喜爱文件路径
|
/// </summary>
|
public static List<string> getsonosLikeList ()
|
{
|
|
return GetFileNameList ("/sonos/favorite");
|
}
|
|
/// <summary>
|
/// 获取所有喜爱文件内容
|
/// </summary>
|
public static string getsonosLikeSongs (string patm)
|
{
|
|
return GetFile ($"/sonos/favorite/{patm}.json");
|
}
|
|
|
/// <summary>
|
/// 获取所有我的列表文件路径
|
/// </summary>
|
public static List<string> getsonosMyList ()
|
{
|
|
return GetFileNameList ("/sonos/playLists");
|
}
|
|
/// <summary>
|
/// 获取所有我的列表文件内容
|
/// </summary>
|
public static string getsonosMySongs (string patm)
|
{
|
|
return GetFile ($"/sonos/playLists/{patm}.json");
|
}
|
|
|
/// <summary>
|
/// 获取所有喜爱文件路径
|
/// </summary>
|
public static List<string> getsonosLocalList ()
|
{
|
|
return GetFileNameList ("/sonos/warningTone");
|
}
|
|
/// <summary>
|
/// 获取所有喜爱文件内容
|
/// </summary>
|
public static string getsonosLocalSongs (string patm)
|
{
|
|
return GetFile ($"/sonos/warningTone/{patm}.json");
|
}
|
|
|
#endregion
|
|
|
#region ---场景列表---
|
/// <summary>
|
/// 获取所有场景ID
|
/// </summary>
|
/// <returns>The devices uid list.</returns>
|
public static List<string> getSceneList ()
|
{
|
#if simulation
|
var list = new List<string> { };
|
foreach (var scene in sceneList) {
|
list.Add (scene.uid.ToString ("X"));
|
}
|
return list;
|
#endif
|
return GetFileNameList ("/scene");
|
}
|
|
/// <summary>
|
/// 根据UID来获取场景信息
|
/// </summary>
|
/// <returns>The device by uid.</returns>
|
/// <param name="uid">Uid.</param>
|
public static string getSceneByUID (string uid)
|
{
|
#if simulation
|
var tempScene = sceneList.Find ((s) => s.uid.ToString ("X") == uid);
|
if (tempScene == null) {
|
return null;
|
} else {
|
return Newtonsoft.Json.JsonConvert.SerializeObject (tempScene);
|
}
|
#endif
|
return GetFile ($"/scene/{uid}.json");
|
}
|
/// <summary>
|
/// 添加场景
|
/// </summary>
|
/// <param name="sceneName">Scene name.</param>
|
/// <param name="action">Action.</param>
|
public static void AppendScene (Scene scene, Action<SuperGateWay.Scene> action,string fileName = null)
|
{
|
|
if (scene == null) {
|
return;
|
}
|
|
scene.objects.Clear ();
|
//空调 ，灯光 ，窗帘 ，按键 ，新风 ，地热 ，门锁，干接点 ，传感器,音乐
|
foreach (var common in scene.deviceList)
|
{
|
///空调
|
if (common.Type == DeviceType.HVAC) {
|
|
var uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (common.SubnetID, common.DeviceID));
|
if (common.keyValuePairs.ContainsKey ("Power")) {
|
var oid = SuperCommon.MakeOid (2, 0, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Power"],
|
});
|
}
|
if (common.keyValuePairs.ContainsKey ("Mode")) {
|
var oid = SuperCommon.MakeOid (2, 1, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Mode"],
|
});
|
}
|
if (common.keyValuePairs.ContainsKey ("Speed")) {
|
var oid = SuperCommon.MakeOid (2, 2, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Speed"],
|
});
|
}
|
if (common.keyValuePairs.ContainsKey ("Temperature")) {
|
var oid = SuperCommon.MakeOid (2, 3, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Temperature"],
|
});
|
}
|
if (common.keyValuePairs.ContainsKey ("Scavenging")) {
|
var oid = SuperCommon.MakeOid (2, 4, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Scavenging"],
|
});
|
}
|
if (common.keyValuePairs.ContainsKey ("ambienTtemperature")) {
|
var oid = SuperCommon.MakeOid (2, 5, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["ambienTtemperature"],
|
});
|
}
|
} else if (common.Type == DeviceType.LightSwitch) {
|
var uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (common.SubnetID, common.DeviceID));
|
var oid = SuperCommon.MakeOid (6, 0, common.LoopID);
|
if (common.keyValuePairs.ContainsKey ("Power")) {
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Power"],
|
});
|
}
|
} else if (common.Type == DeviceType.LightDimming) {
|
var uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (common.SubnetID, common.DeviceID));
|
var oid = SuperCommon.MakeOid (6, 1, common.LoopID);
|
if (common.keyValuePairs.ContainsKey ("Brightness")) {
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Brightness"]
|
});
|
}
|
} else if (common.Type == DeviceType.CurtainModel) {
|
var uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (common.SubnetID, common.DeviceID));
|
var oid = SuperCommon.MakeOid (5, 0, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Power"],
|
});
|
} else if (common.Type == DeviceType.CurtainRoller) {
|
var uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (common.SubnetID, common.DeviceID));
|
var oid = SuperCommon.MakeOid (5, 1, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Brightness"],
|
});
|
} else if (common.Type == DeviceType.MechanicalSwitch) {
|
var uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (common.SubnetID, common.DeviceID));
|
var oid = SuperCommon.MakeOid (7, 0, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Power"],
|
});
|
} else if (common.Type == DeviceType.AutomaticSwitch) {
|
var uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (common.SubnetID, common.DeviceID));
|
var oid = SuperCommon.MakeOid (7, 1, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Power"],
|
});
|
} else if (common.Type == DeviceType.FreshAir) {
|
var uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (common.SubnetID, common.DeviceID));
|
if (common.keyValuePairs.ContainsKey ("Power")) {
|
var oid = SuperCommon.MakeOid (4, 0, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Power"],
|
});
|
}
|
if (common.keyValuePairs.ContainsKey ("Mode")) {
|
var oid = SuperCommon.MakeOid (4, 1, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Mode"],
|
});
|
}
|
if (common.keyValuePairs.ContainsKey ("Speed")) {
|
var oid = SuperCommon.MakeOid (4, 2, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Speed"],
|
});
|
}
|
|
} else if (common.Type == DeviceType.FoolHeat) {
|
var uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (common.SubnetID, common.DeviceID));
|
if (common.keyValuePairs.ContainsKey ("Power")) {
|
var oid = SuperCommon.MakeOid (3, 0, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Power"],
|
});
|
}
|
if (common.keyValuePairs.ContainsKey ("Temperature")) {
|
var oid = SuperCommon.MakeOid (3, 1, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Temperature"],
|
});
|
}
|
} else if (common.Type == DeviceType.DoorLock) {
|
var uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (common.SubnetID, common.DeviceID));
|
var oid = SuperCommon.MakeOid (10, 0, common.LoopID);
|
if (common.keyValuePairs.ContainsKey ("Power")) {
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Power"],
|
});
|
}
|
} else if (common.Type == DeviceType.DryContact) {
|
var uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (common.SubnetID, common.DeviceID));
|
var oid = SuperCommon.MakeOid (14, 0, common.LoopID);
|
if (common.keyValuePairs.ContainsKey ("Power")) {
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Power"],
|
});
|
}
|
} else if (common.Type == DeviceType.Sensor) {
|
var uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (common.SubnetID, common.DeviceID));
|
if (common.keyValuePairs.ContainsKey ("Temperature")) {
|
var oid = SuperCommon.MakeOid (9, 0, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Temperature"],
|
});
|
}
|
if (common.keyValuePairs.ContainsKey ("Brightness")) {
|
var oid = SuperCommon.MakeOid (9, 1, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Brightness"],
|
});
|
}
|
} else if (common.Type == DeviceType.MusicModel) {
|
var uid = SuperCommon.MakeUid (1, 1, SuperCommon.MakeDeviceNumber (common.SubnetID, common.DeviceID));
|
if (common.keyValuePairs.ContainsKey ("Status")) {
|
var oid = SuperCommon.MakeOid (8, 0, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Status"],
|
});
|
}
|
if (common.keyValuePairs.ContainsKey ("Volume")) {
|
var oid = SuperCommon.MakeOid (8, 1, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Volume"],
|
});
|
}
|
|
if (common.keyValuePairs.ContainsKey ("Upper")) {
|
var oid = SuperCommon.MakeOid (8, 2, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Upper"],
|
});
|
}
|
|
if (common.keyValuePairs.ContainsKey ("Source")) {
|
var oid = SuperCommon.MakeOid (8, 3, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Source"],
|
});
|
}
|
|
if (common.keyValuePairs.ContainsKey ("Mode")) {
|
var oid = SuperCommon.MakeOid (8, 5, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Mode"],
|
});
|
}
|
|
if (common.keyValuePairs.ContainsKey ("Index")) {
|
var oid = SuperCommon.MakeOid (8, 6, common.LoopID);
|
scene.objects.Add (new Dictionary<string, object> {
|
["sid"] = SuperCommon.MakeSid (uid, oid).ToString ("X"),
|
["value"] = common.keyValuePairs ["Index"],
|
});
|
}
|
}
|
|
//foreach (var device in scene.deviceList) {
|
//var sidValue = SuperCommon.CommonToSidValue (device);
|
//if (sidValue != null) {
|
// scene.objects.Add (sidValue);
|
//}
|
}
|
|
var sceneBytes = System.Text.Encoding.UTF8.GetBytes (Newtonsoft.Json.JsonConvert.SerializeObject (scene));
|
{
|
System.Threading.Tasks.Task.Run (() => {
|
var pathBytes = System.Text.Encoding.UTF8.GetBytes ($"/scene/{scene.uid.ToString ("X")}.json");
|
var bytes = new byte [1 + 4 + pathBytes.Length + 1];
|
bytes [0] = 0;
|
bytes [1] = (byte)((sceneBytes.Length >> 24) & 0xFF);
|
bytes [2] = (byte)((sceneBytes.Length >> 16) & 0xFF);
|
bytes [3] = (byte)((sceneBytes.Length >> 8) & 0xFF);
|
bytes [4] = (byte)((sceneBytes.Length >> 0) & 0xFF);
|
Array.Copy (pathBytes, 0, bytes, 5, pathBytes.Length);
|
var packetInfo = new PacketInfo {
|
Command = 0,
|
Buffer = bytes,
|
FileBytes = sceneBytes
|
};
|
addPacketInfo (packetInfo);
|
if (packetInfo.ResponeBytes == null || packetInfo.ResponeBytes [1] != 0xF8) {
|
return;
|
}
|
///新加命令，通知高级网关更新场景列表；
|
var byteup = System.Text.Encoding.UTF8.GetBytes ("update\0");
|
byte [] bytesupdate = new byte [1 + byteup.Length + 1];
|
bytesupdate [0] = 9;
|
Array.Copy (byteup, 0, bytesupdate, 1, byteup.Length);
|
addPacketInfo (new PacketInfo { Command = 9, Buffer = bytesupdate });
|
});
|
action (scene);
|
}
|
}
|
/// <summary>
|
/// 场景控制
|
/// </summary>
|
/// <param name="scene">Scene.</param>
|
public static void ControlScene (Scene scene)
|
{
|
try {
|
if (scene == null || scene.sid == null) {
|
return;
|
}
|
var sidUlong = Convert.ToUInt64 (scene.sid, 16);
|
var zoneId = (byte)((sidUlong >> 40) & 0xFF);
|
var sceneId = (byte)((sidUlong >> 32) & 0xFF);
|
Shared.Control.ControlBytesSend (Command.SetScene, GateWay.Instance.SubnetID, GateWay.Instance.DeviceID, new byte [] { zoneId, sceneId }, SendCount.Zero);
|
|
//通知更新
|
//addPacketInfo (new PacketInfo {
|
// Command = 5,
|
// Buffer = new byte [] { 5 },
|
// ReSendCount = 0
|
//});
|
|
} catch { }
|
}
|
/// <summary>
|
/// 删除场景
|
/// </summary>
|
/// <param name="scene">Scene.</param>
|
public static void DeleteScene (Scene scene)
|
{
|
if (scene == null) {
|
return;
|
}
|
System.Threading.Tasks.Task.Run (() => {
|
{
|
var pathBytes = System.Text.Encoding.UTF8.GetBytes ($"/scene/{scene.uid.ToString ("X")}.json");
|
var bytes = new byte [1 + 4 + pathBytes.Length + 1];
|
bytes [0] = 8;
|
bytes [1] = 0x55;
|
bytes [2] = 0x55;
|
bytes [3] = 0x55;
|
bytes [4] = 0x55;
|
Array.Copy (pathBytes, 0, bytes, 5, pathBytes.Length);
|
var packetInfo = new PacketInfo {
|
Command = 8,
|
Buffer = bytes,
|
};
|
addPacketInfo (packetInfo);
|
if (packetInfo.ResponeBytes == null || packetInfo.ResponeBytes [1] != 0xF8) {
|
return;
|
}
|
}
|
});
|
}
|
/// <summary>
|
/// 场景修改
|
/// </summary>
|
/// <param name="sceneName">Scene name.</param>
|
/// <param name="action">Action.</param>
|
public static void ModifyScene (Scene scene, Action<SuperGateWay.Scene> action)
|
{
|
|
AppendScene (scene, action);
|
|
}
|
#endregion
|
|
#region ---逻辑列表---
|
/// <summary>
|
/// 获取逻辑uid列表
|
/// </summary>
|
/// <returns>The logiclist.</returns>
|
public static List<string> getLogiclist ()
|
{
|
return GetFileNameList ("/logic");
|
}
|
/// <summary>
|
/// 获取逻辑信息
|
/// </summary>
|
/// <returns>The logic by uid.</returns>
|
/// <param name="uid">Uid.</param>
|
public static string getLogicByUID (string uid)
|
{
|
|
return GetFile ($"/logic/{uid}.json");
|
}
|
/// <summary>
|
/// 添加逻辑
|
/// </summary>
|
/// <returns>The appendlogic.</returns>
|
public static void AppendLogic (Logic logic)
|
{
|
|
var logicBytes = System.Text.Encoding.UTF8.GetBytes (Newtonsoft.Json.JsonConvert.SerializeObject (logic));
|
{
|
System.Threading.Tasks.Task.Run (() => {
|
var pathBytes = System.Text.Encoding.UTF8.GetBytes ($"/logic/{logic.uid.ToString ("X")}.json");
|
var bytes = new byte [1 + 4 + pathBytes.Length + 1];
|
bytes [0] = 0;
|
bytes [1] = (byte)((logicBytes.Length >> 24) & 0xFF);
|
bytes [2] = (byte)((logicBytes.Length >> 16) & 0xFF);
|
bytes [3] = (byte)((logicBytes.Length >> 8) & 0xFF);
|
bytes [4] = (byte)((logicBytes.Length >> 0) & 0xFF);
|
Array.Copy (pathBytes, 0, bytes, 5, pathBytes.Length);
|
var packetInfo = new PacketInfo {
|
Command = 0,
|
Buffer = bytes,
|
FileBytes = logicBytes
|
};
|
addPacketInfo (packetInfo);
|
if (packetInfo.ResponeBytes == null || packetInfo.ResponeBytes [1] != 0xF8) {
|
return;
|
}
|
|
///新加命令，通知高级网关更新场景列表；
|
var byteup = System.Text.Encoding.UTF8.GetBytes ("update\0");
|
byte [] bytesupdate = new byte [1 + byteup.Length + 1];
|
bytesupdate [0] = 9;
|
Array.Copy (byteup, 0, bytesupdate, 1, byteup.Length);
|
addPacketInfo (new PacketInfo { Command = 9, Buffer = bytesupdate });
|
});
|
//action (logic);
|
}
|
}
|
/// <summary>
|
/// 修改逻辑
|
/// </summary>
|
/// <returns>The modifylogic.</returns>
|
/// <param name="logic">Logic.</param>
|
/// <param name="logicdevice">Logicdevice.</param>
|
public static void modifylogic (Logic logic)
|
{
|
|
var logicBytes = System.Text.Encoding.UTF8.GetBytes (Newtonsoft.Json.JsonConvert.SerializeObject (logic));
|
{
|
System.Threading.Tasks.Task.Run (() => {
|
var pathBytes = System.Text.Encoding.UTF8.GetBytes ($"/logic/{logic.uid.ToString ("X")}.json");
|
var bytes = new byte [1 + 4 + pathBytes.Length + 1];
|
bytes [0] = 0;
|
bytes [1] = (byte)((logicBytes.Length >> 24) & 0xFF);
|
bytes [2] = (byte)((logicBytes.Length >> 16) & 0xFF);
|
bytes [3] = (byte)((logicBytes.Length >> 8) & 0xFF);
|
bytes [4] = (byte)((logicBytes.Length >> 0) & 0xFF);
|
Array.Copy (pathBytes, 0, bytes, 5, pathBytes.Length);
|
var packetInfo = new PacketInfo {
|
Command = 0,
|
Buffer = bytes,
|
FileBytes = logicBytes
|
};
|
addPacketInfo (packetInfo);
|
if (packetInfo.ResponeBytes == null || packetInfo.ResponeBytes [1] != 0xF8) {
|
return;
|
}
|
});
|
//action (logic);
|
}
|
}
|
/// <summary>
|
/// 删除逻辑
|
/// </summary>
|
/// <returns>The logic.</returns>
|
public static void DeleteLogic (Logic logic)
|
{
|
if (logic == null) {
|
return ;
|
}
|
System.Threading.Tasks.Task.Run (() => {
|
{
|
var pathBytes = System.Text.Encoding.UTF8.GetBytes ($"/logic/{logic.uid.ToString ("X")}.json");
|
var bytes = new byte [1 + 4 + pathBytes.Length + 1];
|
bytes [0] = 8;
|
bytes [1] = 0x55;
|
bytes [2] = 0x55;
|
bytes [3] = 0x55;
|
bytes [4] = 0x55;
|
Array.Copy (pathBytes, 0, bytes, 5, pathBytes.Length);
|
var packetInfo = new PacketInfo {
|
Command = 8,
|
Buffer = bytes,
|
};
|
addPacketInfo (packetInfo);
|
if (packetInfo.ResponeBytes == null || packetInfo.ResponeBytes [1] != 0xF8) {
|
return;
|
}
|
}
|
});
|
}
|
|
#endregion
|
|
/// <summary>
|
/// 真正发送数据的地方
|
/// </summary>
|
/// <returns>The data.</returns>
|
/// <param name="packetInfo">Send datas.</param>
|
static void sendData (PacketInfo packetInfo)
|
{
|
SendAndReceiveDatas.CurrentPacketInfo = packetInfo;
|
var startDateTime = DateTime.Now;
|
var haveSendCount = 0;
|
//最多发送3次
|
while (haveSendCount <= packetInfo.ReSendCount && !packetInfo.IsFinish) {
|
switch (haveSendCount) {
|
case 0:
|
if (0 <= (DateTime.Now - startDateTime).TotalMilliseconds) {
|
haveSendCount++;
|
System.Console.WriteLine ("发送第1次");
|
Shared.Control.ControlBytesSend (Command.SuperGatewayAgent, packetInfo.SubnetID, packetInfo.DeviceID, packetInfo.Buffer, Shared.SendCount.Zero);
|
}
|
break;
|
case 1:
|
if (500 <= (DateTime.Now - startDateTime).TotalMilliseconds) {
|
haveSendCount++;
|
System.Console.WriteLine ("发送第2次");
|
Shared.Control.ControlBytesSend (Command.SuperGatewayAgent, packetInfo.SubnetID, packetInfo.DeviceID, packetInfo.Buffer, Shared.SendCount.Zero);
|
}
|
break;
|
case 2:
|
if (1000 <= (DateTime.Now - startDateTime).TotalMilliseconds) {
|
haveSendCount++;
|
System.Console.WriteLine ("发送第3次");
|
Shared.Control.ControlBytesSend (Command.SuperGatewayAgent, packetInfo.SubnetID, packetInfo.DeviceID, packetInfo.Buffer, Shared.SendCount.Zero);
|
}
|
break;
|
case 3:
|
if (1500 <= (DateTime.Now - startDateTime).TotalMilliseconds) {
|
haveSendCount++;
|
System.Console.WriteLine ("发送第4次");
|
Shared.Control.ControlBytesSend (Command.SuperGatewayAgent, packetInfo.SubnetID, packetInfo.DeviceID, packetInfo.Buffer, Shared.SendCount.Zero);
|
}
|
break;
|
}
|
|
Thread.Sleep (10);
|
}
|
if (packetInfo.Command == 0) {
|
var dateTime = DateTime.Now;
|
while (!packetInfo.IsUploadFinish) {
|
System.Threading.Thread.Sleep (500);
|
if (5 < (DateTime.Now - dateTime).TotalSeconds) {
|
break;
|
}
|
}
|
}
|
|
packetInfo.ManualResetEvent.Set ();
|
}
|
|
|
static Thread sendThread;
|
}
|
}
|
