using System;
|
using System.Collections.Generic;
|
using System.Text;
|
using HDL_ON.Entity;
|
using HDL_ON.UI;
|
using Shared;
|
|
namespace HDL_ON.DriverLayer
|
{
|
/// <summary>
|
/// 通讯方式
|
/// </summary>
|
public enum CommunicationMode
|
{
|
none,
|
/// <summary>
|
/// 本地udp
|
/// </summary>
|
local_BusUdp,
|
/// <summary>
|
/// 本地tcp客户端
|
/// </summary>
|
tcp_local_client,
|
}
|
|
public class Control
|
{
|
|
|
static Control _control;
|
public static Control Ins
|
{
|
get
|
{
|
if (_control == null)
|
{
|
_control = new Control();
|
}
|
return _control;
|
}
|
}
|
int _msg_id = 1;
|
/// <summary>
|
/// 通讯ID
|
/// </summary>
|
public int msg_id
|
{
|
get
|
{
|
return _msg_id++;
|
}
|
}
|
/// <summary>
|
/// 获取13位时间戳
|
/// </summary>
|
/// <returns></returns>
|
public string Get_TimeStamp()
|
{
|
long t = DateTime.Now.Ticks / 10000;
|
return t.ToString();
|
}
|
|
/// <summary>
|
/// 是否搜索本地网关成功
|
/// </summary>
|
public bool IsSearchLocalGatewaySuccessful = false;
|
|
/// <summary>
|
///
|
/// </summary>
|
bool _gatewayOnline = false;
|
/// <summary>
|
/// 网关是否在线
|
/// </summary>
|
public bool GatewayOnline
|
{
|
get
|
{
|
return _gatewayOnline;
|
}
|
set
|
{
|
if (_gatewayOnline != value)
|
{
|
if(value)
|
{
|
if (IsRemote)//如果是远程
|
{
|
if(DB_ResidenceData.Instance.HomeGateway == null)
|
{
|
return;
|
}
|
if (!DB_ResidenceData.Instance.HomeGateway.gatewayStatus)//远程情况下，网关未链接服务器不能修改主页网关状态
|
{
|
new System.Threading.Thread(() => {
|
System.Threading.Thread.Sleep(3000);
|
var pm = new DAL.Server.HttpServerRequest();
|
pm.GetGatewayInfo();
|
}) { IsBackground = true }.Start();
|
return;
|
}
|
}
|
_gatewayOnline = value;
|
//修改主页连接状态
|
HomePage.LoadEvent_CheckLinkStatus();
|
MainPage.Log($"网关在线，刷新设备状态");
|
new System.Threading.Thread(() =>
|
{
|
System.Threading.Thread.Sleep(1000);
|
FunctionList.List.ReadAllFunctionStatus();
|
})
|
{ IsBackground = true, Priority = System.Threading.ThreadPriority.AboveNormal }.Start();
|
}
|
else
|
{
|
_gatewayOnline = value;
|
//修改主页连接状态
|
HomePage.LoadEvent_CheckLinkStatus();
|
}
|
}
|
}
|
}
|
/// <summary>
|
/// 网关通讯ID
|
/// </summary>
|
public string GatewayId = "";
|
|
/// <summary>
|
/// 是否为远程连接
|
/// </summary>
|
public bool IsRemote = false;
|
/// <summary>
|
/// 通讯地址IP
|
/// </summary>
|
public string reportIp = "255.255.255.255";
|
/// <summary>
|
/// tcp服务端
|
/// </summary>
|
public Control_TcpServer myTcpServer = null;
|
/// <summary>
|
/// tcp客服端
|
/// </summary>
|
public Control_TcpClient myTcpClient = null;
|
/// <summary>
|
/// 本地udp
|
/// </summary>
|
public Control_Udp myUdp1 = null;
|
|
/// <summary>
|
/// 通讯方式
|
/// </summary>
|
public CommunicationMode communicationMode;
|
|
/// <summary>
|
/// 打开tcp服务端
|
/// </summary>
|
public void OpenTcpServer()
|
{
|
myTcpServer = new Control_TcpServer();
|
myTcpServer.OpenServer();
|
}
|
|
/// <summary>
|
/// 打开Udp
|
/// </summary>
|
public void OpenUdp(int port)
|
{
|
UdpSocket._BusSocket.Start(port);
|
}
|
/// <summary>
|
/// 关闭udp
|
/// </summary>
|
public void CloseUdp()
|
{
|
UdpSocket._BusSocket.Stop();
|
}
|
|
/// <summary>
|
/// 打开tcp客服端
|
/// </summary>
|
public void OpenTcpClent()
|
{
|
if (myTcpClient == null)
|
{
|
myTcpClient = new Control_TcpClient(reportIp);
|
myTcpClient.Connect();
|
}
|
}
|
|
/// <summary>
|
/// 搜索本地网关列表
|
/// </summary>
|
public void SearchLoaclGateway()
|
{
|
//2021-01-15 : 住宅没有绑定网关的时候不用搜索，并且不能链接mqtt
|
if(DB_ResidenceData.Instance.HomeGateway == null)
|
{
|
return;
|
}
|
var ggg = DB_ResidenceData.Instance.GatewayType == 0 ? "一端口" : "A网关";
|
var ggg1 = MainPage.InternetStatus == 1 ? "4G" : "wifi";
|
MainPage.Log($"搜索网关列表，网关类型:{ggg};网络类型:{ggg1}");
|
if (MainPage.InternetStatus == 0)
|
{
|
Ins.GatewayOnline = false;
|
return;
|
}
|
else if (MainPage.InternetStatus == 1)
|
{
|
if (!Ins.IsRemote)
|
{
|
Ins.IsRemote = true;
|
DAL.Mqtt.MqttClient.InitState();
|
}
|
}
|
else if (MainPage.InternetStatus == 2)
|
{
|
OpenUdp(DB_ResidenceData.Instance.GatewayType == 0 ? 6000 : 8585);
|
//重置搜索网关标志
|
IsSearchLocalGatewaySuccessful = false;
|
|
new System.Threading.Thread(() =>
|
{
|
for (int i = 0; i < 5; i++)
|
{
|
if (IsSearchLocalGatewaySuccessful)
|
break;
|
if (DB_ResidenceData.Instance.GatewayType == 0)
|
{
|
new Control_Udp().ControlBytesSend(Command.ReadGateway, 255, 255, new byte[] { (byte)new Random().Next(255), (byte)new Random().Next(255) });
|
}
|
else if (DB_ResidenceData.Instance.GatewayType == 1)
|
{
|
new Control_Udp().SearchLocalGateway();
|
}
|
System.Threading.Thread.Sleep(500);
|
}
|
|
if (!IsSearchLocalGatewaySuccessful)
|
{
|
//本地搜索不到网关
|
if (!Ins.IsRemote)
|
{
|
Ins.IsRemote = true;
|
DAL.Mqtt.MqttClient.InitState();
|
}
|
}
|
})
|
{ IsBackground = true }.Start();
|
}
|
}
|
|
/// <summary>
|
/// 场景控制入口
|
/// </summary>
|
public void ControlScene(Scene scene)
|
{
|
if (Ins.IsRemote || DB_ResidenceData.Instance.GatewayType == 1)
|
{
|
new System.Threading.Thread(() =>
|
{
|
ControlAProtocolScene(scene);
|
})
|
{ IsBackground = true }.Start();
|
}
|
else
|
{
|
if (DB_ResidenceData.Instance.GatewayType == 0)
|
{
|
new Control_Udp().ControlBusScenes(scene);
|
}
|
}
|
}
|
|
/// <summary>
|
/// 发送命令
|
/// 自动判断是否为A协议设备，
|
/// 不是A协议，自动转化bus命令数据
|
/// </summary>
|
/// <param name="commandString"></param>
|
/// <param name="function"></param>
|
/// <param name="useRemote">是否直接使用远程发送</param>
|
/// <returns></returns>
|
public void SendWriteCommand(Function function, Dictionary<string, string> commandDictionary, bool useRemote = false)
|
{
|
function.controlCounter++;
|
function.refreshTime = DateTime.Now;
|
|
//如果是控制调光的开时，亮度值不能为0
|
if (commandDictionary.Count > 2)
|
{
|
if (commandDictionary.ContainsKey(FunctionAttributeKey.OnOff) && commandDictionary.ContainsKey(FunctionAttributeKey.Brightness))
|
{
|
if (commandDictionary[FunctionAttributeKey.OnOff] == "on")
|
{
|
if (commandDictionary[FunctionAttributeKey.Brightness] == "0")
|
{
|
commandDictionary[FunctionAttributeKey.Brightness] = "100";
|
}
|
}
|
if (commandDictionary[FunctionAttributeKey.OnOff] == "off")
|
{
|
if (commandDictionary[FunctionAttributeKey.Brightness] != "0")
|
{
|
commandDictionary[FunctionAttributeKey.Brightness] = "0";
|
}
|
}
|
}
|
}
|
|
MainPage.Log($"发送数据:{Newtonsoft.Json.JsonConvert.SerializeObject(commandDictionary)}");
|
|
//远程通讯
|
if (Ins.IsRemote || useRemote == true)
|
{
|
DAL.Server.HttpServerRequest httpServer = new DAL.Server.HttpServerRequest();
|
//ALink控制、Bus控制使用同一个接口控制，由云端负责解析
|
var apiControlData = function.GetApiControlData(commandDictionary);
|
var actionObjs = new List<ApiAlinkControlActionObj>();
|
actionObjs.Add(apiControlData);
|
var pack = httpServer.ControlDevice(actionObjs);
|
}
|
//本地通讯
|
else
|
{
|
//Bus控制
|
if (DB_ResidenceData.Instance.GatewayType == 0)
|
{
|
try
|
{
|
new Control_Udp().WriteBusData(function, commandDictionary);
|
}
|
catch (Exception ex)
|
{
|
MainPage.Log($"发送数据异常: {ex.Message}");
|
}
|
}
|
//ALink控制
|
else
|
{
|
var functionControlDataObj = function.GetGatewayAlinkControlData(commandDictionary);
|
var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(functionControlDataObj);
|
var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ControlFunctionTopic, functionControlDataJson);
|
new Control_Udp().SendLocalHdlLinkData(sendBytes, functionControlDataObj.id);
|
MainPage.Log($"发送HDL-Link数据:{functionControlDataJson}");
|
}
|
}
|
}
|
/// <summary>
|
/// 全开全关功能
|
/// </summary>
|
public void SwtichFunctions(bool open,List<Function> functions)
|
{
|
var count = 0;
|
var logString = open ? "打开\r\n" : "关闭\r\n";
|
List<ApiAlinkControlActionObj> actionObjs = new List<ApiAlinkControlActionObj>();
|
Dictionary<string, string> d = new Dictionary<string, string>();
|
d.Add(FunctionAttributeKey.OnOff, open ? "on" : "off");
|
var pm = new DAL.Server.HttpServerRequest();
|
foreach (var temp in functions)
|
{
|
logString += temp.spk + ":" + temp.sid + "\r\n";
|
var apiControlData = temp.GetApiControlData(d);
|
actionObjs.Add(apiControlData);
|
count++;
|
if (count > 9)
|
{
|
var result = pm.ControlDevice(actionObjs);
|
actionObjs = new List<ApiAlinkControlActionObj>();
|
count = 0;
|
MainPage.Log(logString);
|
logString = "";
|
}
|
}
|
var pack = pm.ControlDevice(actionObjs);
|
MainPage.Log(logString);
|
}
|
|
public void SendApiReadCommand(List<string> functionIds)
|
{
|
var pm = new DAL.Server.HttpServerRequest();
|
var pack = pm.RefreshDeviceStatus(functionIds);
|
}
|
|
/// <summary>
|
/// 发送读取命令
|
/// 自动判断是否为A协议设备
|
/// </summary>
|
public void SendReadCommand(Function function)
|
{
|
function.refreshTime = DateTime.Now;
|
if (Ins.IsRemote)
|
{
|
var pm = new DAL.Server.HttpServerRequest();
|
var pack = pm.RefreshDeviceStatus(new List<string>() { function.deviceId });
|
}
|
else
|
{
|
if (DB_ResidenceData.Instance.GatewayType == 0)
|
{
|
try
|
{
|
new Control_Udp().ReadBusData(function);
|
}
|
catch (Exception ex)
|
{
|
MainPage.Log($"发送数据异常: {ex.Message}");
|
}
|
}
|
else
|
{
|
var readKey = new Dictionary<string, string>();
|
readKey.Add("sid", function.sid);
|
|
var readDataObj = new AlinkReadFunctionStatusObj()
|
{
|
id = Ins.msg_id.ToString(),
|
objects = new List<Dictionary<string, string>>()
|
{
|
readKey
|
},
|
time_stamp = Utlis.GetTimestamp()
|
};
|
var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(readDataObj);
|
var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ReadStatus, functionControlDataJson);
|
MainPage.Log($"发送HDL-Link数据:{functionControlDataJson}");
|
new Control_Udp().SendLocalHdlLinkData(sendBytes, readDataObj.id);
|
}
|
}
|
}
|
///// <summary>
|
///// 发送A协议读取命令
|
///// </summary>
|
//public void SendReadCommand(List<Dictionary<string, string>> keyValuePairs)
|
//{
|
// var readDataObj = new GatewayAlinkReadObj()
|
// {
|
// id = Ins.msg_id.ToString(),
|
// objects = keyValuePairs,
|
// time_stamp = Utlis.GetTimestamp()
|
// };
|
// var functionControlDataJson = Newtonsoft.Json.JsonConvert.SerializeObject(readDataObj);
|
// var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ReadStatus, functionControlDataJson);
|
// Ins.myUdp.SendLocalHdlLinkData(sendBytes);
|
//}
|
|
/// <summary>
|
/// a协议控制场景
|
/// </summary>
|
/// <param name="scene"></param>
|
static void ControlAProtocolScene(Scene scene)
|
{
|
if (Ins.IsRemote)
|
{
|
//云端做处理发送一端口场景
|
//if (DB_ResidenceData.Instance.GatewayType == 0)
|
//{
|
// new Control_Udp().ControlBusScenes(scene);
|
//}
|
//else
|
{
|
var pm = new DAL.Server.HttpServerRequest();
|
var result = pm.ExecuteScene(scene.userSceneId);
|
}
|
}
|
else
|
{
|
Dictionary<string, string> keys = new Dictionary<string, string>();
|
keys.Add("sid", scene.sid);
|
var aLinkData = new AlinkReadFunctionStatusObj()
|
{
|
id = Ins.msg_id.ToString(),
|
objects = new List<Dictionary<string, string>>()
|
{
|
keys
|
},
|
time_stamp = Utlis.GetTimestamp()
|
};
|
var aLinkJson = Newtonsoft.Json.JsonConvert.SerializeObject(aLinkData);
|
var sendBytes = Ins.ConvertSendBodyData(CommunicationTopic.ct.ControlScene, aLinkJson);
|
new Control_Udp().SendLocalHdlLinkData(sendBytes, aLinkData.id);
|
}
|
}
|
/// <summary>
|
/// 转换通讯数据
|
/// </summary>
|
public byte[] ConvertSendBodyData(string topic, string bodyDataString)
|
{
|
string topicString = "Topic:" + topic + "\r\n";
|
byte[] bodyBytes = Encoding.ASCII.GetBytes(bodyDataString);
|
string lengthString = "Length:" + bodyBytes.Length.ToString() + "\r\n" + "\r\n";
|
|
string sendDataString = topicString + lengthString + bodyDataString;
|
byte[] sendDataBytes = Encoding.ASCII.GetBytes(sendDataString);
|
//MainPage.Log($"转换HDL-Link数据\r\n{sendDataString}\r\n");
|
|
return sendDataBytes;
|
}
|
/// <summary>
|
/// 转换接收到的数据
|
/// </summary>
|
/// <returns></returns>
|
public void ConvertReceiveData(byte[] receiveBytes)
|
{
|
var reString = Encoding.UTF8.GetString(receiveBytes);
|
AnalysisReceiveData(reString);
|
}
|
/// <summary>
|
/// 转换接收到的数据
|
/// </summary>
|
/// <returns></returns>
|
public LocalCommunicationData AnalysisReceiveData(string receiveString)
|
{
|
LocalCommunicationData receiveObj = new LocalCommunicationData();
|
|
var res = receiveString.Split("\r\n\r\n");
|
|
if (res.Length == 2)
|
{
|
var topics = res[0].Split("\r\n");
|
//MainPage.Log(res[1]);
|
foreach (var ts in topics)
|
{
|
var key = ts.Split(":");
|
switch (key[0])
|
{
|
case "Topic":
|
receiveObj.Topic = key[1];
|
break;
|
case "Length":
|
receiveObj.Length = Convert.ToInt32(key[1]);
|
break;
|
}
|
}
|
|
MainPage.Log($"time 1 :{receiveObj.Topic}");
|
|
|
//验证有效数据长度
|
//if (res[1].Length != receiveObj.Length)
|
//{
|
// MainPage.Log($"收到数据包长度不够");
|
// return receiveObj;
|
//}
|
receiveObj.BodyDataString = res[1];
|
|
var bodyJObj = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponsePack>(res[1]);
|
if (bodyJObj == null)
|
{
|
return receiveObj;
|
}
|
if (receiveObj.Topic == CommunicationTopic.SearchLoaclGatewayReply)
|
{
|
var device = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceModule>(bodyJObj.objects.ToString());
|
if (device.device_mac == DB_ResidenceData.Instance.residenceGatewayMAC)
|
{
|
MainPage.Log("本地搜索网关成功");
|
Control.Ins.IsSearchLocalGatewaySuccessful = true;
|
Ins.GatewayOnline = true;
|
if (!string.IsNullOrEmpty(device.gatewayId))
|
{
|
Ins.GatewayId = device.gatewayId;
|
}
|
else
|
{
|
Ins.GatewayId = device.device_mac;
|
}
|
reportIp = "239.0.168.188";// device.ip_address;
|
Ins.IsRemote = false;
|
}
|
}
|
else if (receiveObj.Topic == CommunicationTopic.ct.ReadStatus + "_reply" ||
|
receiveObj.Topic == CommunicationTopic.ct.ControlFunctionTopic + "_reply" ||
|
receiveObj.Topic == CommunicationTopic.ct.GatewayUpStatus)
|
{
|
//TODO 暂时不传正确的数据上去，如果后面要优化前面这些代码
|
UpdataFunctionStatus(receiveObj.BodyDataString, null);
|
}
|
}
|
return receiveObj;
|
}
|
|
/// <summary>
|
/// 更新设备状态
|
/// A协议数据
|
/// </summary>
|
/// <param name="updateBytes"></param>
|
public void UpdataFunctionStatus(string revString, byte[] usefulBytes)
|
{
|
MainPage.Log($"A协议更新状态:{revString}");
|
var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<AlinkFunctionStatusObj>(revString);
|
if (temp != null)
|
{
|
Control_Udp.ReceiveRepeatManager(temp.id, usefulBytes);
|
var allLocalFuntion = FunctionList.List.GetDeviceFunctionList();
|
foreach (var updateTemp in temp.objects)
|
{
|
try
|
{
|
//bool hadChange = false;//状态有变化再更新界面
|
var localFunction = allLocalFuntion.Find((obj) => obj.sid == updateTemp.sid);
|
if (localFunction != null)
|
{
|
//var updateInfoString = $"更新设备:{localFunction.name}";
|
//foreach (var attr in updateTemp.status)
|
//{
|
// updateInfoString += $" key:{attr.key};value:{attr.value}";
|
//}
|
//MainPage.Log(updateInfoString);
|
|
|
//更新界面状态
|
Function localObj = null;
|
switch (localFunction.spk)
|
{
|
case SPK.LightSwitch:
|
var localSwitch = FunctionList.List.lights.Find((obj) => obj.sid == updateTemp.sid);
|
if (localSwitch != null)
|
{
|
localObj = localSwitch;
|
foreach (var attr in updateTemp.status)
|
{
|
var localAttr = localSwitch.attributes.Find((obj) => obj.key == attr.key);
|
if (localAttr != null)
|
{
|
localAttr.curValue = attr.value;
|
}
|
}
|
//rgb.lastState = Language.StringByID(StringId.Brightness) + " : " + rgb.brightness + "%";
|
RelayPage.UpdataState(localSwitch);
|
}
|
break;
|
case SPK.LightDimming:
|
var dimming = FunctionList.List.lights.Find((obj) => obj.sid == updateTemp.sid);
|
if (dimming != null)
|
{
|
localObj = dimming;
|
foreach (var attr in updateTemp.status)
|
{
|
var localAttr = dimming.attributes.Find((obj) => obj.key == attr.key);
|
if (localAttr != null)
|
{
|
localAttr.curValue = attr.value;
|
}
|
}
|
dimming.lastState = Language.StringByID(StringId.Brightness) + " : " + dimming.brightness + "%";
|
DimmerPage.UpdataStates(dimming);
|
}
|
break;
|
case SPK.ElectricFan:
|
var fan = FunctionList.List.fans.Find((obj) => obj.sid == updateTemp.sid);
|
if (fan != null)
|
{
|
localObj = fan;
|
foreach (var attr in updateTemp.status)
|
{
|
var localAttr = fan.attributes.Find((obj) => obj.key == attr.key);
|
if (localAttr != null)
|
{
|
localAttr.curValue = attr.value;
|
}
|
}
|
fan.lastState = Language.StringByID(StringId.Level) + " : " + fan.openLevel;
|
FanPage.UpdataState(fan);
|
}
|
break;
|
case SPK.LightRGB:
|
var rgb = FunctionList.List.lights.Find((obj) => obj.sid == updateTemp.sid);
|
if (rgb != null)
|
{
|
localObj = rgb;
|
foreach (var attr in updateTemp.status)
|
{
|
var localAttr = rgb.attributes.Find((obj) => obj.key == attr.key);
|
if (localAttr != null)
|
{
|
localAttr.curValue = attr.value;
|
}
|
}
|
rgb.lastState = Language.StringByID(StringId.Brightness) + " : " + rgb.brightness + "%";
|
RGBPage.UpdataStates(rgb);
|
}
|
break;
|
case SPK.LightRGBW:
|
break;
|
case SPK.LightCCT:
|
var lightCCT = FunctionList.List.lights.Find((obj) => obj.sid == updateTemp.sid);
|
if (lightCCT != null)
|
{
|
localObj = lightCCT;
|
foreach (var attr in updateTemp.status)
|
{
|
var localAttr = lightCCT.attributes.Find((obj) => obj.key == attr.key);
|
if (localAttr != null)
|
{
|
localAttr.curValue = attr.value;
|
}
|
}
|
lightCCT.lastState = Language.StringByID(StringId.Brightness) + " : " + lightCCT.brightness + "%";
|
ColorTureLampPage.UpdataStates(lightCCT);
|
}
|
break;
|
case SPK.CurtainSwitch:
|
var curtain = FunctionList.List.curtains.Find((obj) => obj.sid == updateTemp.sid);
|
if (curtain != null)
|
{
|
localObj = curtain;
|
foreach (var attr in updateTemp.status)
|
{
|
var localAttr = curtain.attributes.Find((obj) => obj.key == attr.key);
|
if (localAttr != null)
|
{
|
localAttr.curValue = attr.value;
|
}
|
}
|
curtain.lastState = curtain.trait_on_off.curValue.ToString() == "on" ? Language.StringByID(StringId.Open) : Language.StringByID(StringId.Close);
|
CurtainModulePage.UpdataState(curtain);
|
}
|
break;
|
case SPK.CurtainTrietex:
|
var trietex = FunctionList.List.curtains.Find((obj) => obj.sid == updateTemp.sid);
|
if (trietex != null)
|
{
|
localObj = trietex;
|
foreach (var attr in updateTemp.status)
|
{
|
var localAttr = trietex.attributes.Find((obj) => obj.key == attr.key);
|
if (localAttr != null)
|
{
|
localAttr.curValue = attr.value;
|
}
|
}
|
trietex.lastState = Language.StringByID(StringId.Open) + trietex.percent + "%";
|
MotorCurtainPage.UpdataState(trietex);
|
}
|
break;
|
case SPK.CurtainRoller:
|
var roller = FunctionList.List.curtains.Find((obj) => obj.sid == updateTemp.sid);
|
if (roller != null)
|
{
|
localObj = roller;
|
foreach (var attr in updateTemp.status)
|
{
|
var localAttr = roller.attributes.Find((obj) => obj.key == attr.key);
|
if (localAttr != null)
|
{
|
localAttr.curValue = attr.value;
|
}
|
}
|
roller.lastState = Language.StringByID(StringId.Open) + roller.percent + "%";
|
RollingShutterPage.UpdataState(roller);
|
}
|
break;
|
case SPK.CurtainShades:
|
break;
|
case SPK.AcStandard:
|
var ac = FunctionList.List.aCs.Find((obj) => obj.sid == updateTemp.sid);
|
if (ac != null)
|
{
|
localObj = ac;
|
foreach (var attr in updateTemp.status)
|
{
|
var localAttr = ac.attributes.Find((obj) => obj.key == attr.key);
|
if (localAttr != null)
|
{
|
localAttr.curValue = attr.value;
|
}
|
}
|
ac.lastState = "";
|
switch (ac.trait_mode.curValue.ToString())
|
{
|
case "cool":
|
ac.lastState = Language.StringByID(StringId.Cool);
|
break;
|
case "heat":
|
ac.lastState = Language.StringByID(StringId.Heat);
|
break;
|
case "dry":
|
ac.lastState = Language.StringByID(StringId.Dry);
|
break;
|
case "auto":
|
ac.lastState = Language.StringByID(StringId.Auto);
|
break;
|
case "fan":
|
ac.lastState = Language.StringByID(StringId.AirSupply);
|
break;
|
}
|
switch (ac.trait_fan.curValue.ToString())
|
{
|
case "high":
|
ac.lastState += " " + Language.StringByID(StringId.HighWindSpeed);
|
break;
|
case "medium":
|
ac.lastState += " " + Language.StringByID(StringId.MiddleWindSpeed);
|
break;
|
case "low":
|
ac.lastState += " " + Language.StringByID(StringId.LowWindSpeed);
|
break;
|
case "auto":
|
ac.lastState += " " + Language.StringByID(StringId.Auto);
|
break;
|
}
|
ac.lastState += " " + ac.trait_temp.curValue + ac.tempUnitString;
|
ACPage.UpdataStates(ac);
|
}
|
break;
|
case SPK.FloorHeatStandard:
|
var fh = FunctionList.List.floorHeatings.Find((obj) => obj.sid == updateTemp.sid);
|
if (fh != null)
|
{
|
localObj = fh;
|
foreach (var attr in updateTemp.status)
|
{
|
var localAttr = fh.attributes.Find((obj) => obj.key == attr.key);
|
if (localAttr != null)
|
{
|
localAttr.curValue = attr.value;
|
}
|
}
|
switch (fh.trait_mode.curValue)
|
{
|
case "normal":
|
fh.lastState = Language.StringByID(StringId.Normal);
|
break;
|
case "day":
|
fh.lastState = Language.StringByID(StringId.Day);
|
break;
|
case "night":
|
fh.lastState = Language.StringByID(StringId.Night);
|
break;
|
case "timer":
|
fh.lastState = Language.StringByID(StringId.Auto);
|
break;
|
case "away":
|
fh.lastState = Language.StringByID(StringId.Away);
|
break;
|
}
|
fh.lastState += " " + fh.trait_temp.curValue + fh.tempUnitString;
|
FloorHeatingPage.UpdataStates(fh);
|
}
|
break;
|
case SPK.SensorPm25:
|
case SPK.SensorCO2:
|
case SPK.SensorTVOC:
|
case SPK.SensorTemperature:
|
case SPK.SensorHumidity:
|
var sensor = FunctionList.List.sensorsEnvironmentalScience.Find((obj) => obj.sid == updateTemp.sid);
|
if (sensor != null)
|
{
|
localObj = sensor;
|
foreach (var attr in updateTemp.status)
|
{
|
var localAttr = sensor.attributes.Find((obj) => obj.key == attr.key);
|
if (localAttr != null)
|
{
|
localAttr.curValue = attr.value;
|
}
|
}
|
EnvironmentalSciencePage.LoadEvent_UpdataStatus(sensor);
|
}
|
break;
|
case SPK.ElectricSocket:
|
var es = FunctionList.List.switchSockets.Find((obj) => obj.sid == updateTemp.sid);
|
if (es != null)
|
{
|
localObj = es;
|
foreach (var attr in updateTemp.status)
|
{
|
var localAttr = es.attributes.Find((obj) => obj.key == attr.key);
|
if (localAttr != null)
|
{
|
localAttr.curValue = attr.value;
|
}
|
}
|
SocketPage.UpdataState(es);
|
}
|
break;
|
case SPK.ElectricTV:
|
break;
|
case SPK.ElectricTuyaAirCleaner:
|
case SPK.ElectricTuyaFan:
|
case SPK.ElectricTuyaWeepRobot:
|
//设备状态推送
|
var myDevice = Stan.HdlDeviceStatuPushLogic.Current.UpdateDeviceStatu(updateTemp);
|
if (myDevice != null)
|
{
|
localObj = myDevice;
|
}
|
break;
|
default:
|
break;
|
}
|
if (localObj != null)
|
{
|
HomePage.UpdataFunctionStates(localObj);
|
RoomPage.UpdataStates(localObj);
|
FunctionPage.UpdataStates(localObj);
|
ClassificationPage.UpdataInfo(localObj);
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
MainPage.Log($"A协议更新状态异常:{ex.Message}");
|
}
|
}
|
}
|
}
|
|
}
|
}
|
