using System; using System.Text; using HDL_ON.DAL.Net; using HDL_ON.Entity; using HDL_ON.UI; using Shared; using Shared.Net; namespace HDL_ON.DAL { public static class CommonPage { public static bool IsRemote; public static Action RefreshAir; public static string FindGatewayChilrenIPAddress = new NetWiFi().BroadcastIpAddress.ToString(); private static string ip = "0.0.0.0"; public static System.Net.IPEndPoint EndPoint { get { try { return new System.Net.IPEndPoint(System.Net.IPAddress.Parse(new NetWiFi().BroadcastIpAddress.ToString()), 6000); } catch { //防止异常导致程序退出 return new System.Net.IPEndPoint(System.Net.IPAddress.Parse("127.0.0.1"), 6000); } } } ///保存设备备注才用gb2312,其他情况用utf8 public static Encoding MyEncodingUTF8 = Encoding.UTF8;//Get public static Encoding MyEncodingGB2312 { get { try { if (System.Globalization.CultureInfo.InstalledUICulture.EnglishName.ToUpper().StartsWith("CZECH")) { return Encoding.GetEncoding(1250); } else { return Encoding.GetEncoding("gb2312"); } } catch (Exception ex) { MainPage.Log("MyEncodingGB2312 Erorr : " + ex.Message); return Encoding.GetEncoding("gb2312"); } } } static bool isHttpListenerStart; public static DateTime dt; //public static byte currentSubnetID = 0; public static void InitHttpListener() { if (isHttpListenerStart) { return; } HttpListener.Start(new NetWiFi().IpAddress, 6002); HttpListener.EventHandler -= httpListener_EventHandler; HttpListener.EventHandler += httpListener_EventHandler; isHttpListenerStart = true; } public static void CloseHttpListener() { //isHttpListenerStart = false; //return; if (!isHttpListenerStart) return; HttpListener.Close(); isHttpListenerStart = false; } /// /// 初始化处理socket接收的数据 /// public static void InitReceiveEvent() { Packet.ReceiveEvent += Packet_ReceiveEvent; } public static float floatChange(byte b1, byte b2, byte b3, byte b4) { byte[] byteTemp = { b4, b3, b2, b1 }; return BitConverter.ToSingle(byteTemp, 0); } static void Packet_ReceiveEvent(byte subnetID, byte deviceID, Command command, byte[] receiveBytes, string revGatewayIP) { try { switch (command) { case Command.ReadLightSingleLoopBrightnessACK: case Command.SetSingleLightACK: foreach (var light in DB_ResidenceData.residenceData.functionList.lights) { if (light.GetBusId() == subnetID + "_" + deviceID + "_" + receiveBytes[0]) { if ( light.functionType != FunctionType.RGB) { light.on_off = receiveBytes[2] == 0 ? "off" : "on"; if (light.on_off == "on") { light.brightness = receiveBytes[2]; light.lastState = Language.StringByID(StringId.Brightness) + " : " + receiveBytes[2] + "%"; } HomePage.UpdataFunctionStates(light); RoomPage.UpdataStates(light); FunctionPage.UpdataStates(light); ClassificationPage.UpdataInfo(light); switch (light.functionType) { case FunctionType.Relay: RelayPage.UpdataState(light); break; case FunctionType.Dimmer: DimmerPage.UpdataStates(light); break; } } } } foreach (var e in DB_ResidenceData.residenceData.functionList.electricals) { if (e.GetBusId() == subnetID + "_" + deviceID + "_" + receiveBytes[0]) { if (e.functionType == FunctionType.Fan) { var fan = e as Fan; fan.on_off = receiveBytes[2] == 0 ? "off" : "on"; if (fan.on_off == "on") { fan.openLevel = receiveBytes[2]; fan.lastState = Language.StringByID(StringId.Level) + " : " + receiveBytes[2]; } HomePage.UpdataFunctionStates(fan); RoomPage.UpdataStates(fan); FunctionPage.UpdataStates(fan); ClassificationPage.UpdataInfo(fan); switch (fan.functionType) { case FunctionType.Fan: FanPage.UpdataState(fan); break; case FunctionType.Socket: break; } } } } break; case Command.SetLogicLoopColorACK: case Command.ReadLogicLoopColorACK: foreach (var rgb in DB_ResidenceData.residenceData.functionList.lights) { if (rgb.GetBusId() == subnetID + "_" + deviceID + "_" + receiveBytes[0]) { if (rgb.functionType == FunctionType.RGB) { rgb.on_off = receiveBytes[1] > 0 ? "on" : "off"; if (receiveBytes[1] >0) { rgb.brightness = receiveBytes[1]; rgb.lastState = Language.StringByID(StringId.Brightness) + " : " + receiveBytes[1] + "%"; } rgb.redColor = receiveBytes[6]; rgb.greenColor = receiveBytes[7]; rgb.blueColor = receiveBytes[8]; HomePage.UpdataFunctionStates(rgb); RoomPage.UpdataStates(rgb); FunctionPage.UpdataStates(rgb); ClassificationPage.UpdataInfo(rgb); RGBPage.UpdataStates(rgb); } } } break; case Command.SetCurtainModelStutasACK: case Command.ReadCurtainStutasACK: foreach (var curtain in DB_ResidenceData.residenceData.functionList.curtains) { if (curtain.GetBusId() == subnetID + "_" + deviceID + "_" + receiveBytes[0]) { switch(receiveBytes[1]) { case 0: curtain.on_off = "stop"; break; case 1: curtain.on_off = "on"; curtain.lastState = Language.StringByID(StringId.Open); break; case 2: curtain.on_off = "off"; curtain.lastState = Language.StringByID(StringId.Close); break; default: if (receiveBytes[1] > 1) { curtain.on_off = "on"; } else { curtain.on_off = "off"; } curtain.openLevel = receiveBytes[1]; curtain.lastState = Language.StringByID(StringId.Open) + curtain.openLevel + "%"; break; } RoomPage.UpdataStates(curtain); FunctionPage.UpdataStates(curtain); HomePage.UpdataFunctionStates(curtain); ClassificationPage.UpdataInfo(curtain); switch (curtain.functionType) { case FunctionType.Curtain: CurtainModulePage.UpdataState(curtain); break; } } } break; case Command.SetACModeACK: case Command.ReadACModeACK: foreach (var ac in DB_ResidenceData.residenceData.functionList.aCs) { if (ac.GetBusId() == subnetID + "_" + deviceID + "_" + receiveBytes[0]) { ac.curTempType = receiveBytes[1]; ac.indoorTemp = receiveBytes[2]; ac.on_off = receiveBytes[8] == 1 ? "on" : "off"; ac.curModeIndex = receiveBytes[9]; ac.curFanIndex = receiveBytes[10]; ac.curTemp = receiveBytes[11]; ac.lastState = ""; switch (ac.trait_mode.curValues.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.curValues.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.curTemp + ac.curTempTypeString; RoomPage.UpdataStates(ac); FunctionPage.UpdataStates(ac); HomePage.UpdataFunctionStates(ac); ClassificationPage.UpdataInfo(ac); ACPage.UpdataStates(ac); } } break; case Command.ReadFloorHeatACK: case Command.SetFloorHeatACK: foreach (var fh in DB_ResidenceData.residenceData.functionList.floorHeatings) { if (fh.GetBusId() == subnetID + "_" + deviceID + "_" + receiveBytes[0]) { fh.curTempType = receiveBytes[2]; fh.on_off = receiveBytes[1] % 2 ==0?"off":"on"; fh.curModeIndex = receiveBytes[3]; if (fh.modeTemp.ContainsKey("ordinary")) { fh.modeTemp["ordinary"]= receiveBytes[4]; } else { fh.modeTemp.Add("ordinary", receiveBytes[4]); } if (fh.modeTemp.ContainsKey("day")) { fh.modeTemp["day"] = receiveBytes[5]; } else { fh.modeTemp.Add("day", receiveBytes[5]); } if (fh.modeTemp.ContainsKey("night")) { fh.modeTemp["night"] = receiveBytes[6]; } else { fh.modeTemp.Add("night", receiveBytes[6]); } if (fh.modeTemp.ContainsKey("away")) { fh.modeTemp["away"] = receiveBytes[7]; } else { fh.modeTemp.Add("away", receiveBytes[7]); } switch (fh.curMode) { case "ordinary": fh.lastState = Language.StringByID(StringId.Ordinary); 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); if(receiveBytes[8]==0) { }else { } break; case "away": fh.curTemp = receiveBytes[7]; fh.lastState = Language.StringByID(StringId.Away); break; } fh.lastState += " " + fh.curTemp + fh.curTempTypeString; RoomPage.UpdataStates(fh); FunctionPage.UpdataStates(fh); HomePage.UpdataFunctionStates(fh); ClassificationPage.UpdataInfo(fh); FloorHeatingPage.UpdataStates(fh); } } break; } } catch (Exception ex) { MainPage.Log($"Bus Rev Erorr : {ex.Message}"); } } /// /// byte 变字符串 /// /// The to hex16. /// The blue component. public static string byteToHex16(byte b) { string s = Convert.ToString(b, 16).ToUpper(); if (s.Length <= 1) { return "0" + s; } return s;// } static void httpListener_EventHandler(System.Collections.Specialized.NameValueCollection nameValueCollection, System.IO.Stream outputStream, System.IO.Stream inputStream) { try { if (nameValueCollection["Command"] != null && nameValueCollection["Command"].StartsWith("Get")) { string tempFileName = nameValueCollection["Command"].Replace("Get", ""); if ("AllFiles" == tempFileName) { byte[] bytes = System.Text.Encoding.UTF8.GetBytes(Newtonsoft.Json.JsonConvert.SerializeObject(FileUtils.ReadFiles())); outputStream.Write(bytes, 0, bytes.Length); outputStream.Flush(); } else { byte[] bytes; if (!FileUtils.Exists(tempFileName)) { bytes = System.Text.Encoding.UTF8.GetBytes("文件名不存在!"); outputStream.Write(bytes, 0, bytes.Length); outputStream.Flush(); return; } System.IO.FileStream fs = new System.IO.FileStream(Application.RootPath + tempFileName, System.IO.FileMode.Open); bytes = new byte[fs.Length]; fs.Read(bytes, 0, bytes.Length); fs.Close(); outputStream.Write(bytes, 0, bytes.Length); outputStream.Flush(); } } else if (nameValueCollection["Command"].StartsWith("Upload")) { string path = Application.RootPath + nameValueCollection["Command"].Replace("Upload", ""); string dePath = nameValueCollection["Command"].Replace("Upload", ""); } else { byte[] bytes = System.Text.Encoding.UTF8.GetBytes("请求命令无效!"); outputStream.Write(bytes, 0, bytes.Length); outputStream.Flush(); } } catch (Exception ex) { MainPage.Log("httpListener_EventHandler" + ex.ToString()); } } /// /// 监听请求的Http端口 /// public static int Port = 5555; static void httpListener_EventHandler(string rawUrl, System.IO.Stream outputStream, System.IO.Stream inputStream) { foreach (var musicInfo in MusicInfo.MusicInfoList) { if ("audio-item-" + musicInfo.ID == rawUrl.TrimStart('/')) { var file = new System.IO.FileStream(musicInfo.Data, System.IO.FileMode.Open, System.IO.FileAccess.Read); byte[] bytes = new byte[1024]; try { while (file.CanRead) { int len = file.Read(bytes, 0, bytes.Length); if (len == 0) { break; } outputStream.Write(bytes, 0, len); } } catch { } file.Close(); break; } } } } }