old mode 100755
new mode 100644
| | |
| | | using System.Collections.Specialized; |
| | | using System.Net; |
| | | using System.IO; |
| | | using System.Diagnostics.CodeAnalysis; |
| | | |
| | | namespace Shared.Phone.Device.Logic |
| | | { |
| | | public class Send |
| | | { |
| | | #region ----获取Logic |
| | | #region ----Logic所有发送命令 |
| | | /// <summary> |
| | | /// 获取LogicId的方法 |
| | | /// </summary> |
| | |
| | | return await System.Threading.Tasks.Task.Run(async () => |
| | | { |
| | | List<int> logicIdList = new List<int>(); |
| | | |
| | | Action<string, string> action = (topic, data) => |
| | | { |
| | | var gatewayID = topic.Split('/')[0]; |
| | |
| | | { |
| | | var logicId = int.Parse(listIfon["LogicId"].ToString()); |
| | | logicIdList.Add(logicId); |
| | | |
| | | } |
| | | |
| | | } |
| | |
| | | return logicIdList; |
| | | } |
| | | mainGateWay.GwResDataAction += action; |
| | | |
| | | var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 2004 } }; |
| | | var jObjectdata1 = new JObject { { "LogicType", LogicType } }; |
| | | jObject.Add("Data", jObjectdata1); |
| | | mainGateWay?.Send("Logic/GetLogicList", jObject.ToString()); |
| | | try |
| | | { |
| | | var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 2004 } }; |
| | | var jObjectdata1 = new JObject { { "LogicType", LogicType } }; |
| | | jObject.Add("Data", jObjectdata1); |
| | | mainGateWay?.Send("Logic/GetLogicList", jObject.ToString()); |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | var d = e.Message; |
| | | } |
| | | //await System.Threading.Tasks.Task.Run(async () => |
| | | //{ |
| | | var dateTime = DateTime.Now; |
| | |
| | | }); |
| | | } |
| | | ///<summary> |
| | | /// 删除逻辑 |
| | | /// 删除逻辑(0成功,其它值:失败) |
| | | /// </summary> |
| | | public static async System.Threading.Tasks.Task<int> DelLogic(int LogicId) |
| | | { |
| | |
| | | ["RemindTime"] = int.Parse(dictionary["RemindTime"]), |
| | | ["EnDelay"] = int.Parse(dictionary["EnDelay"]), |
| | | ["DelayTime"] = int.Parse(dictionary["DelayTime"]), |
| | | ["DoorLockOpenDelayTime"] = int.Parse(dictionary["DoorLockOpenDelayTime"]), |
| | | }; |
| | | if (dictionary["DateType"].ToString() == "0") |
| | | { |
| | |
| | | ["Type"] = int.Parse(dictionary["Type"]), |
| | | ["IsValid"] = int.Parse(dictionary["IsValid"]), |
| | | ["AtHome"] = int.Parse(dictionary["AtHome"]), |
| | | ["WhoSiteUId"] =dictionary["WhoSiteUId"], |
| | | ["WhoSiteUId"] = dictionary["WhoSiteUId"], |
| | | }; |
| | | conditions.Add(diliInfo); |
| | | break; |
| | |
| | | }; |
| | | actions.Add(timeInfo); |
| | | break; |
| | | case 8: |
| | | var lockInfo = new JObject |
| | | { |
| | | ["LinkType"] = int.Parse(dictionary["LinkType"].ToString()), |
| | | ["DeviceAddr"] = dictionary["DeviceAddr"].ToString(), |
| | | ["Epoint"] = int.Parse(dictionary["Epoint"].ToString()), |
| | | ["PassData"] = dictionary["PassData"].ToString(), |
| | | }; |
| | | actions.Add(lockInfo); |
| | | break; |
| | | } |
| | | } |
| | | var accounts = new JArray(); |
| | |
| | | { |
| | | ["Type"] = int.Parse(dictionary["Type"]), |
| | | ["Account"] = dictionary["Account"], |
| | | ["AccountName"] = dictionary["AccountName"], |
| | | ["UserId"] = dictionary["UserId"], |
| | | ["AccountName"] = dictionary["AccountName"], |
| | | |
| | | }; |
| | | |
| | | if (dictionary.ContainsKey("Option4")) |
| | | { |
| | | accounts1.Add("Option4", dictionary["Option4"]); |
| | | } |
| | | if (dictionary.ContainsKey("Option2")) |
| | | { |
| | | accounts1.Add("Option2", int.Parse(dictionary["Option2"])); |
| | | } |
| | | accounts.Add(accounts1); |
| | | } |
| | | } |
| | |
| | | accounts.Add(location); |
| | | } |
| | | break; |
| | | case 8: |
| | | { |
| | | var accounts1 = new JObject(); |
| | | if (dictionary.ContainsKey("Type")) |
| | | { |
| | | accounts1.Add("Type", int.Parse(dictionary["Type"])); |
| | | } |
| | | if (dictionary.ContainsKey("Option4")) |
| | | { |
| | | accounts1.Add("Option4", dictionary["Option4"]); |
| | | } |
| | | if (dictionary.ContainsKey("Option2")) |
| | | { |
| | | accounts1.Add("Option2", int.Parse(dictionary["Option2"])); |
| | | } |
| | | accounts.Add(accounts1); |
| | | } |
| | | break; |
| | | } |
| | | |
| | | } |
| | | |
| | | var data = new JObject{ |
| | | { "LogicId",logic.LogicId}, |
| | | { "IsEnable", logic.IsEnable} , |
| | |
| | | logic.LogicName = Logicifon["LogicName"].ToString(); |
| | | logic.LogicType = int.Parse(Logicifon["LogicType"].ToString()); |
| | | logic.Relationship = int.Parse(Logicifon["Relationship"].ToString()); |
| | | logic.LogicCustomPushText =Logicifon["LogicCustomPushText"].ToString(); |
| | | logic.LogicCustomPushText = Logicifon["LogicCustomPushText"].ToString(); |
| | | logic.LogicIsCustomPushText = int.Parse(Logicifon["LogicIsCustomPushText"].ToString()); |
| | | logic.TimeAttribute = Newtonsoft.Json.JsonConvert.DeserializeObject<Common.TimeAttributeObj>(Logicifon["TimeAttribute"].ToString()); |
| | | logic.Conditions = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Dictionary<string, string>>>(Logicifon["Conditions"].ToString()); |
| | |
| | | } |
| | | catch { } |
| | | var dateTime = DateTime.Now; |
| | | while ((DateTime.Now - dateTime).TotalMilliseconds < 8 * 1000) |
| | | while ((DateTime.Now - dateTime).TotalMilliseconds < 5 * 1000) |
| | | { |
| | | await System.Threading.Tasks.Task.Delay(100); |
| | | if (sum == listLogic.Count) |
| | |
| | | return listLogic; |
| | | }); |
| | | } |
| | | // <summary> |
| | | /// 通过设备找到区域(房间)名称 |
| | | /// </summary> |
| | | /// <param name="btnregionname">Btnregionname.</param> |
| | | /// <param name="device">Device.</param> |
| | | public static void RoomNmae(Button btnregionname, CommonDevice device) |
| | | { |
| | | var room = new Common.Room(); |
| | | btnregionname.Text = UserCenter.HdlRoomLogic.Current.GetRoomNameByDevice(device); |
| | | } |
| | | /// <summary> |
| | | /// 找出楼层所有房间 |
| | | /// </summary> |
| | | /// <param name="floorId">楼层ID</param> |
| | | /// <returns></returns> |
| | | public static List<Common.Room> GetRoomList(string floorId) |
| | | { |
| | | return UserCenter.HdlRoomLogic.Current.GetAllListRooms().FindAll((obj) => obj.FloorId == floorId); |
| | | //var list1 = new List<Common.Room>(); |
| | | /////找到某楼层房间列表; |
| | | //var list = Common.Room.Lists.FindAll((obj) => obj.FloorId == floorId); |
| | | //for (int i = 0; i < list.Count; i++) |
| | | //{ |
| | | // if (str == "device") |
| | | // { |
| | | // if (list[i].DeviceUIList.Count != 0) |
| | | // { ///过滤掉没有设备的房间 |
| | | // list1.Add(list[i]); |
| | | // } |
| | | // } |
| | | // else |
| | | // { |
| | | // if (list[i].SceneUIList.Count != 0) |
| | | // { ///过滤掉没有场景的房间 |
| | | // list1.Add(list[i]); |
| | | // } |
| | | // } |
| | | //} |
| | | /////返回房间列表; |
| | | //return list1; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 获取场景信息的方法 |
| | | /// </summary> |
| | |
| | | sceneui = new SceneUI(); |
| | | sceneui.Name = jObjectdata["Data"]["ScenesName"].ToString(); |
| | | sceneui.Id = int.Parse(jObjectdata["Data"]["ScenesId"].ToString()); |
| | | |
| | | |
| | | } |
| | | }; |
| | | var mainGateWay = ZbGateway.MainGateWay; |
| | |
| | | while ((DateTime.Now - dateTime).TotalMilliseconds < 3 * 1000) |
| | | { |
| | | await System.Threading.Tasks.Task.Delay(100); |
| | | if (sceneui!=null) |
| | | if (sceneui != null) |
| | | { |
| | | break; |
| | | } |
| | |
| | | #endregion |
| | | |
| | | #region ----获取门锁 |
| | |
|
| | | |
| | | /// <summary> |
| | | /// 获取自己+其他成员信息 |
| | | /// </summary> |
| | |
| | | if (UserCenter.UserCenterResourse.UserInfo.AuthorityNo != 3) |
| | | { |
| | | var pra = new UserCenter.MemberListInfoPra(); |
| | | string result = await UserCenter.UserCenterLogic.GetResponseDataByRequestHttps("ZigbeeUsers/GetSubAccountByDistributedMark", false, pra); |
| | | var listInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<List<UserCenter.MemberInfoRes>>(result); |
| | | string result = ""; |
| | | if (AllUserIfon.Count != 0) |
| | | { |
| | | //服务返回来没有门锁成员信息,没有必要再去请求成员列表, |
| | | //原因:节约时间,体验效果好; |
| | | result = UserCenter.UserCenterLogic.GetResponseDataByRequestHttps("ZigbeeUsers/GetSubAccountByDistributedMark", false, pra); |
| | | }
|
| | | if (string.IsNullOrEmpty(result))
|
| | | {
|
| | | //防止为空抛异常;
|
| | | return userlist; |
| | | } |
| | | var listInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<List<UserCenter.MemberInfoRes>>(result);
|
| | | if (listInfo == null)
|
| | | {
|
| | | //防止为空抛异常;
|
| | | return userlist; |
| | | } |
| | | for (int i = 0; i < listInfo.Count; i++) |
| | | { |
| | | |
| | |
| | | { |
| | | string s = null; |
| | | var str = await WebClientAsync(0, CommonPage.RequestHttpsHost + "/App/GetHomePager");//不同区域域名前缀不一样 |
| | | // var str = await WebClientAsync(0, "https://global.hdlcontrol.com/HangZhouHdlCloudApi/App/GetHomePager"); |
| | | |
| | | var jObject = JObject.Parse(str); |
| | | if (jObject == null || jObject["StateCode"].ToString() != "Success") |
| | | { |
| | |
| | | residential.IsOtherAccountCtrl = true; |
| | | residential.doorlockmac = doorlockMac; |
| | | residential.Url = CommonPage.RequestHttpsHost + "/App/GetSharedHomeApiControl"; |
| | | //residential.Url = "https://global.hdlcontrol.com/HangZhouHdlCloudApi/App/GetSharedHomeApiControl"; |
| | | s = await ReadUserDoorLock(residential); |
| | | } |
| | | else |
| | | { |
| | | residential.Url = CommonPage.RequestHttpsHost + "/DoorLock/GetDoorLockPager"; |
| | | //residential.Url = "https://global.hdlcontrol.com/HangZhouHdlCloudApi/DoorLock/GetDoorLockPager"; |
| | | residential.Token = Config.Instance.Token; |
| | | residential.Id = Config.Instance.HomeId; |
| | | residential.IsOtherAccountCtrl = false; |
| | |
| | | lockifon.doorlockmac = residential.doorlockmac; |
| | | return await WebClientAsync(2, lockifon.Url, lockifon); |
| | | } |
| | | #region 定义解析门锁的对象 |
| | | |
| | | public class Residential |
| | | { |
| | | /// <summary> |
| | |
| | | public bool IsFreezeUser; |
| | | |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 门锁列表 |
| | | /// </summary> |
| | |
| | | /// </summary> |
| | | public static UserCenter.MemberInfoRes UserMemberInfoRes = null; |
| | | #endregion |
| | | #endregion |
| | | |
| | | /// <summary> |
| | | /// 自己用 |
| | | /// 自己用的发送的方法 |
| | | /// </summary> |
| | | /// <param name="tag">标记是那条命令</param> |
| | | /// <param name="logic">逻辑对象</param> |
| | | public static void Zj(bool tag, Common.Logic logic) |
| | | { |
| | | |
| | | if (string.IsNullOrEmpty(logic.LogicCustomPushText)) |
| | | { |
| | | ///默认推送自定义内容 |
| | | string str = logic.LogicName + Language.StringByID(R.MyInternationalizationString.defaulttext); |
| | | logic.LogicCustomPushText = str; |
| | | } |
| | | |
| | | new System.Threading.Thread(() => |
| | | { |
| | | if (logic.LogicId != 0) |
| | |
| | | }) |
| | | { IsBackground = true }.Start(); |
| | | } |
| | | |
| | | #region 请求服务器方法--- |
| | | /// <summary> |
| | | /// 请求数据的封装方法 |
| | |
| | | jObject.Add("LogicID", Common.Logic.CurrentLogic.LogicId); |
| | | } |
| | | break; |
| | | case "读取云端门锁数据": |
| | | { |
| | | jObject.Add("RequestVersion", CommonPage.RequestVersion); |
| | | jObject.Add("HomeId", Config.Instance.HomeId); |
| | | jObject.Add("DoorLockId", obj.ToString());//门锁Mac+端口 |
| | | jObject.Add("PageSetting.PageSize", Int32.MaxValue.ToString()); |
| | | } |
| | | break; |
| | | |
| | | } |
| | | return await HttpWebRequest(getUrl, jObject.ToString(), method); |
| | | } |
| | |
| | | /// <param name="method">请求方式为POST/GET</param> |
| | | /// <param name="second">超时时间</param> |
| | | /// <returns></returns> |
| | | public static async System.Threading.Tasks.Task<string>HttpWebRequest(string getUrl, string str, string method,int second= 3) |
| | | public static async System.Threading.Tasks.Task<string> HttpWebRequest(string getUrl, string str, string method, int second = 3, bool _bool = false) |
| | | { |
| | | HttpWebRequest request = WebRequest.Create(getUrl) as HttpWebRequest; //创建请求 |
| | | request.Method = method; //请求方式为POST/GET |
| | | request.ContentType = "application/json"; |
| | | request.Timeout = second * 1000;//超时时间 |
| | | if (method == "POST") |
| | | { |
| | | byte[] jsonbyte = System.Text.Encoding.UTF8.GetBytes(str); |
| | | request.ContentLength = jsonbyte.Length; |
| | | Stream postStream = request.GetRequestStream(); |
| | | postStream.Write(jsonbyte, 0, jsonbyte.Length); |
| | | postStream.Close(); |
| | | } |
| | | //发送请求并获取相应回应数据 |
| | | HttpWebResponse res; |
| | | try |
| | | { |
| | | res = (HttpWebResponse)request.GetResponse(); |
| | | if (_bool) |
| | | { |
| | | //用于高胜可视对讲接口 |
| | | request.Headers.Add("Authorization", Config.Instance.Token); |
| | | } |
| | | if (method == "POST") |
| | | { |
| | | byte[] jsonbyte = System.Text.Encoding.UTF8.GetBytes(str); |
| | | request.ContentLength = jsonbyte.Length; |
| | | Stream postStream = request.GetRequestStream(); |
| | | postStream.Write(jsonbyte, 0, jsonbyte.Length); |
| | | postStream.Close(); |
| | | } |
| | | //发送请求并获取相应回应数据 |
| | | HttpWebResponse res; |
| | | try |
| | | { |
| | | res = (HttpWebResponse)request.GetResponse(); |
| | | } |
| | | catch (WebException ex) |
| | | { |
| | | res = (HttpWebResponse)ex.Response; |
| | | } |
| | | StreamReader sr = new StreamReader(res.GetResponseStream(), System.Text.Encoding.UTF8); |
| | | string content = sr.ReadToEnd(); //获得响应字符串 |
| | | return content; |
| | | } |
| | | catch (WebException ex) |
| | | catch |
| | | { |
| | | res = (HttpWebResponse)ex.Response; |
| | | return null; |
| | | } |
| | | StreamReader sr = new StreamReader(res.GetResponseStream(), System.Text.Encoding.UTF8); |
| | | string content = sr.ReadToEnd(); //获得响应字符串 |
| | | return content; |
| | | |
| | | } |
| | | /// <summary> |
| | | /// 请求服务器的方法 |
| | |
| | | postValues.Add("LoginAccessToken", Config.Instance.Token); |
| | | postValues.Add("MainAccountId", residential.MainUserDistributedMark); |
| | | postValues.Add("SharedHid", residential.Id); |
| | | |
| | | } |
| | | break; |
| | | case 2: |
| | |
| | | return System.Text.Encoding.UTF8.GetString(varByte);
|
| | | } |
| | | #endregion |
| | | |
| | | /// <summary> |
| | | /// 判断字典是否存在的方法 |
| | | /// </summary> |
| | | /// <param name="deviceConditionsInfo"></param> |
| | | /// <param name="Key"></param> |
| | | /// <param name="Value"></param> |
| | | public static void dictionary(Dictionary<string, string> deviceConditionsInfo, string Key, string Value) |
| | | { |
| | | if (deviceConditionsInfo.ContainsKey(Key)) |
| | | { |
| | | deviceConditionsInfo.Remove(Key); |
| | | } |
| | | deviceConditionsInfo.Add(Key, Value); |
| | | } |
| | | |
| | | |
| | | } |
| | | } |