using System; using Shared.Common; using Newtonsoft.Json; using Shared.Common.ResponseEntity; using System.Threading.Tasks; using System.Text.RegularExpressions; using System.Collections.Generic; using System.Text; namespace Shared.Phone.UserCenter { /// /// 个人中心逻辑类 /// public class UserCenterLogic { #region ■ 云端接口访问_______________________ /// /// 访问指定接口,返回是否成功 /// /// 是否成功 /// 访问地址 /// 是否检测权限,该参数不能省略 /// 一个类 /// /// 不需要显示错误的错误类别(接口返回的错误类别),如果包含,则会返回【true】 /// 如果指定有NotSetAgain,则不二次发送(比如断网),然后返回【false】 /// public static async Task GetResultStatuByRequestHttps(string RequestName, bool checkAuthority, object obj, List listNotShowError = null) { //获取接口的连接模式 var connectMode = GetHttpConnectMode(checkAuthority); //获取从接口那里取到的比特数据 var byteData = await GettByteResponsePack(RequestName, connectMode, obj); if (byteData == null) { if (listNotShowError != null && listNotShowError.Contains("NotSetAgain") == true) { return false; } byteData = await ResetByteRequestHttps(RequestName, checkAuthority, obj); if (byteData == null) { return false; } } var revertObj = JsonConvert.DeserializeObject(Encoding.UTF8.GetString(byteData)); //检测是否存在错误信息 return CheckNotEorrorMsg(revertObj, RequestName, listNotShowError, obj); } /// /// 访问指定接口,返回状态码(出现异常时,返回 Error) /// /// 接口的状态码(出现异常时,返回 Error) /// 访问地址 /// 是否检测权限,该参数不能省略 /// 一个类 /// /// 不需要显示错误的错误类别(接口返回的错误类别),如果包含,则会返回【Success】 /// 如果指定有NotSetAgain,则不二次发送(比如断网),然后返回【ErrorEx】 /// public static async Task GetResultCodeByRequestHttps(string RequestName, bool checkAuthority, object obj, List listNotShowError = null) { //获取接口的连接模式 var connectMode = GetHttpConnectMode(checkAuthority); //获取从接口那里取到的比特数据 var byteData = await GettByteResponsePack(RequestName, connectMode, obj); if (byteData == null) { if (listNotShowError != null && listNotShowError.Contains("NotSetAgain") == true) { return "ErrorEx"; } byteData = await ResetByteRequestHttps(RequestName, checkAuthority, obj); if (byteData == null) { return "Error"; } } var revertObj = JsonConvert.DeserializeObject(Encoding.UTF8.GetString(byteData)); return revertObj.StateCode; } /// /// 访问指定接口,并返回接口把对象已经序列化了的字符串,存在错误信息时,返回null /// /// 返回:接口把对象已经序列化了的字符串,存在错误信息时,返回null /// 访问地址 /// 是否检测权限,该参数不能省略 /// 一个类 /// /// 不需要显示错误的错误类别(接口返回的错误类别),如果包含,则会返回空字符串 /// 如果指定有NotSetAgain,则不二次发送(比如断网),然后返回空字符串 /// public static async Task GetResponseDataByRequestHttps(string RequestName, bool checkAuthority, object obj, List listNotShowError = null) { //获取接口的连接模式 var connectMode = GetHttpConnectMode(checkAuthority); //获取从接口那里取到的比特数据 var byteData = await GettByteResponsePack(RequestName, connectMode, obj); if (byteData == null) { if (listNotShowError != null && listNotShowError.Contains("NotSetAgain") == true) { return string.Empty; } byteData = await ResetByteRequestHttps(RequestName, checkAuthority, obj); if (byteData == null) { return null; } } var revertObj = JsonConvert.DeserializeObject(Encoding.UTF8.GetString(byteData)); //检测错误 bool notError = CheckNotEorrorMsg(revertObj, RequestName, listNotShowError, obj); if (notError == false) { return null; } if (revertObj == null || revertObj.ResponseData == null) { return string.Empty; } return revertObj.ResponseData.ToString(); } /// /// 访问指定接口,并直接返回接口返回的比特,存在错误信息时,返回null /// /// 返回:并直接返回接口返回的比特,存在错误信息时,返回null /// 访问地址 /// 是否检测权限,该参数不能省略 /// 一个类 /// /// 不需要显示错误的错误类别(接口返回的错误类别),如果包含,则会返回空字符串 /// 如果指定有NotSetAgain,则不二次发送(比如断网),然后返回null /// public static async Task GetByteResponseDataByRequestHttps(string RequestName, bool checkAuthority, object obj, List listNotShowError = null) { //获取接口的连接模式 var connectMode = GetHttpConnectMode(checkAuthority); //获取从接口那里取到的比特数据 var revertObj = await GettByteResponsePack(RequestName, connectMode, obj); if (revertObj == null) { if (listNotShowError != null && listNotShowError.Contains("NotSetAgain") == true) { return null; } //重新发送 revertObj = await ResetByteRequestHttps(RequestName, checkAuthority, obj); if (revertObj == null) { return null; } } if (revertObj != null && revertObj.Length > 0) { if (revertObj[0] == '{' && revertObj[revertObj.Length - 1] == '}') { string data2 = System.Text.Encoding.UTF8.GetString(revertObj); var data = JsonConvert.DeserializeObject(data2); if (data != null && string.IsNullOrEmpty(data.StateCode) == false) { bool notError = CheckNotEorrorMsg(data, RequestName, listNotShowError, obj); if (notError == false) { return null; } } } } return revertObj; } /// /// 私有类型:从新发送(懂的人自然懂,很难解释清楚) /// /// 访问地址 /// 是否检测权限,该参数不能省略 /// 一个类 /// private static async Task ResetByteRequestHttps(string RequestName, bool checkAuthority, object obj) { //获取接口的连接模式 var connectMode = GetHttpConnectMode(checkAuthority); byte[] responsePack = null; int count = 0; while (true) { await Task.Delay(1000); //调用接口 responsePack = await GettByteResponsePack(RequestName, connectMode, obj); if (responsePack != null) { break; } count++; if (count == 3) { Application.RunOnMainThread(() => { //网络不稳定,请稍后再试 string msg = Language.StringByID(R.MyInternationalizationString.uNetIsUnStabilityAndDoAgain); var control = new ShowMsgControl(ShowMsgType.Tip, msg); control.Show(); }); break; } } return responsePack; } /// /// 获取从接口那里取到的内容 /// /// 获取从接口那里取到的文本内容 /// 访问地址 /// 接口的连接模式 /// 一个类 private static async Task GettByteResponsePack(string RequestName, HttpConnectMode connectMode, object obj) { try { //序列化对象 var requestJson = JsonConvert.SerializeObject(obj); //访问接口 byte[] result = null; if (connectMode == HttpConnectMode.Normal) { //普通访问 result = await CommonPage.Instance.RequestHttpsZigbeeBytesResultAsync(RequestName, Encoding.UTF8.GetBytes(requestJson)); } else if (connectMode == HttpConnectMode.Admin) { //以管理员的身份访问,自身是成员 result = await CommonPage.Instance.RequestZigbeeHttpsByAdmin(RequestName, Encoding.UTF8.GetBytes(requestJson)); } return result; } catch (Exception ex) { Console.WriteLine(ex.Message); return null; } } /// /// 检测是否存在错误信息,并显示错误 /// /// 是否存在错误信息 /// 从接口接收到的数据 /// 请求接口 /// 不需要显示错误的错误类别(接口返回的错误类别) /// 请求的参数 public static bool CheckNotEorrorMsg(ResponsePack revertObj, string RequestName, List listNotShowError = null, object pra = null) { if (revertObj == null) { Application.RunOnMainThread(() => { //网络不稳定,请稍后再试 string msg = Language.StringByID(R.MyInternationalizationString.uNetIsUnStabilityAndDoAgain); var control = new ShowMsgControl(ShowMsgType.Tip, msg); control.Show(); }); return false; } if (revertObj.StateCode.ToUpper() != "SUCCESS") { if (listNotShowError != null && listNotShowError.Contains(revertObj.StateCode) == true) { //不显示错误,然后返回true return true; } Application.RunOnMainThread(() => { if (HdlCheckLogic.Current.IsAccountLoginOut() == true) { //如果用户已经退出了登陆,则不处理 return; } string msg = IMessageCommon.Current.GetMsgByRequestName(RequestName, revertObj, pra); if (msg != null) { var control = new ShowMsgControl(ShowMsgType.Tip, msg); control.Show(); //无效登录Token if (revertObj.StateCode == "NoLogin") { UserCenterLogic.ReLoginAgain(Config.Instance.Account, false); } } }); return false; } return true; } /// /// 获取接口的连接模式 /// /// 是否检测权限 /// public static HttpConnectMode GetHttpConnectMode(bool checkAuthority) { if (checkAuthority == false) { return HttpConnectMode.Normal; } if (Config.Instance.isAdministrator == true) { return HttpConnectMode.Admin; } return HttpConnectMode.Normal; } #endregion #region ■ 添加界面相关_______________________ /// /// 检测能否添加画面 /// /// true:可以追加 false:不可追加 /// Form public static bool CheckCanAddForm(CommonFormBase form) { //获取画面英文名字 string formName = GetFormName(form); //二重追加不可 if (UserCenterResourse.DicActionForm.ContainsKey(formName) == false) { return true; } //暂时这样弄看看,如果重复,则关闭掉原来的界面 var formTemp = UserCenterResourse.DicActionForm[formName]; formTemp.CloseForm(); UserCenterResourse.DicActionForm.Remove(formName); formTemp = null; return true; } /// /// 把打开的画面添加到内存中 /// /// Form. public static void AddActionForm(CommonFormBase form) { //获取画面英文名字 string formName = GetFormName(form); //二重追加不可 if (UserCenterResourse.DicActionForm.ContainsKey(formName) == false) { form.FormID = formName; //内存添加 UserCenterResourse.DicActionForm[formName] = form; //添加画面时,它自身就是激活的界面 UserCenterResourse.NowActionFormID = form.FormID; UserCenterResourse.listActionFormId.Add(form.FormID); } } /// /// 从列表中移除画面 /// /// Form public static void RemoveActionForm(CommonFormBase form) { //获取画面英文名字 string formName = GetFormName(form); if (UserCenterResourse.DicActionForm.ContainsKey(formName) == true) { //刷新当前正在操作的画面ID if (UserCenterResourse.NowActionFormID == UserCenterResourse.DicActionForm[formName].FormID) { //向前推一位即为下一个激活的界面 int index = UserCenterResourse.listActionFormId.IndexOf(UserCenterResourse.NowActionFormID) - 1; //初始值 UserCenterResourse.NowActionFormID = string.Empty; if (index >= 0) { var actionForm = UserView.HomePage.Instance.GetChildren(UserView.HomePage.Instance.ChildrenCount - 1); if (actionForm != null && actionForm is CommonFormBase) { //设置当前激活的画面ID UserCenterResourse.NowActionFormID = UserCenterResourse.listActionFormId[index]; //追加条件一:关闭的界面为EditorCommonForm的时候才处理 if ((form is EditorCommonForm) && UserCenterResourse.DicActionForm.ContainsKey(UserCenterResourse.NowActionFormID) == true) { try { var Myform = UserCenterResourse.DicActionForm[UserCenterResourse.NowActionFormID]; if (Myform is EditorCommonForm) { //触发界面再次激活的事件 int value = ((EditorCommonForm)Myform).FormActionAgainEvent(); if (value == 1) { //Log出力 HdlLogLogic.Current.WriteLog(1, Myform.FormID + " 被激活"); } } } catch (Exception ex) { //出现未知错误,数据丢失 var alert = new ShowMsgControl(ShowMsgType.Error, Language.StringByID(R.MyInternationalizationString.uUnknownErrorAndDataLost)); alert.Show(); //Log出力 HdlLogLogic.Current.WriteLog(ex); } } } else if (actionForm != null && actionForm is UserView.UserPage) { //这里它已经退到主页了,如果它包含个人中心主页的话 if (UserCenterResourse.listActionFormId.Contains("UserMainForm") == true) { //设置当前激活的画面ID UserCenterResourse.NowActionFormID = UserCenterResourse.listActionFormId[index]; //追加条件一:关闭的界面为EditorCommonForm的时候才处理 if ((form is EditorCommonForm) && UserCenterResourse.DicActionForm.ContainsKey(UserCenterResourse.NowActionFormID) == true) { try { var Myform = UserCenterResourse.DicActionForm[UserCenterResourse.NowActionFormID]; if (Myform is EditorCommonForm) { //触发界面再次激活的事件 int value = ((EditorCommonForm)Myform).FormActionAgainEvent(); if (value == 1) { //Log出力 HdlLogLogic.Current.WriteLog(1, Myform.FormID + " 被激活"); } } } catch (Exception ex) { //出现未知错误,数据丢失 var alert = new ShowMsgControl(ShowMsgType.Error, Language.StringByID(R.MyInternationalizationString.uUnknownErrorAndDataLost)); alert.Show(); //Log出力 HdlLogLogic.Current.WriteLog(ex); } } } } } } //移除ID UserCenterResourse.listActionFormId.Remove(UserCenterResourse.DicActionForm[formName].FormID); //移除画面 var formTemp = UserCenterResourse.DicActionForm[formName]; UserCenterResourse.DicActionForm.Remove(formName); formTemp = null; } } /// /// 获取画面英文名字 /// /// The form name. /// Form. public static string GetFormName(CommonFormBase form) { if (form.FormID != string.Empty) { return form.FormID; } //将命名空间去掉 string[] Arry = form.ToString().Split(new string[] { "." }, StringSplitOptions.RemoveEmptyEntries); string formName = Arry[Arry.Length - 1].Trim(); return formName; } /// /// 获取当前正在激活的画面 /// /// public static CommonFormBase GetNowActionForm() { if (UserCenterResourse.DicActionForm.ContainsKey(UserCenterResourse.NowActionFormID) == true) { return UserCenterResourse.DicActionForm[UserCenterResourse.NowActionFormID]; } return null; } #endregion #region ■ 刷新本地缓存_______________________ /// /// 刷新本地所有缓存 /// public static void RefreshAllMemory() { //备份的数据,有可能是主人自己上传的,如果管理员登陆时,他获取的备份数据有点特殊 //比如下面这三个东西在主账号那里是不需要的 bool isOthreShare = Config.Instance.Home.IsOthreShare; int accountType = Config.Instance.Home.AccountType; string mainMark = Config.Instance.Home.MainUserDistributedMark; //还原住宅对象 Config.Instance.Home = House.GetHouseByHouseId(Config.Instance.Home.Id); Config.Instance.Home.IsOthreShare = isOthreShare; Config.Instance.Home.AccountType = accountType; Config.Instance.Home.MainUserDistributedMark = mainMark; Config.Instance.Home.Save(false); //刷新本地网关文件 HdlGatewayLogic.Current.ReFreshByLocal(); //刷新本地设备 Common.LocalDevice.Current.ReFreshByLocal(); //需优先于刷新房间,同步云端的网关id,如果本地拥有云端不存在的id,则表示应该被换绑了,直接删除 HdlGatewayLogic.Current.SynchronizeDbGateway(); //从本地重新加载全部的房间 Common.Room.RefreshAllRoomByLocation(); } #endregion #region ■ 删除本地文件_______________________ /// /// 删除本地所有文件 /// /// true:全部删除(用于住宅删除) false:重要的文件不删除 public static void DeleteAllLocationFile(bool all = true) { string dPath = Config.Instance.FullPath; if (System.IO.Directory.Exists(dPath) == false) { return; } //然后获取全部的文件 List listFile = Global.FileListByHomeId(); foreach (string file in listFile) { if (all == false && IsNotDeleteFile(file) == true) { //这是不能删除的文件 continue; } //删除文件 Global.DeleteFilebyHomeId(file); } //如果是把文件全部删除的话,那么文件夹也一起删除掉 if (all == true) { //删除文件夹 System.IO.Directory.Delete(dPath, true); } } /// /// 判断是不是不应该删除的文件 /// /// /// public static bool IsNotDeleteFile(string fileName) { if (fileName == "Config.json") { //不能删除Config文件 return true; } else if (fileName.StartsWith("House_") == true) { //不能删除住宅文件 return true; } return false; } #endregion #region ■ 重新登录___________________________ /// /// 重新登录 /// /// 账号 /// 是否通知云端 public static void ReLoginAgain(string account = "", bool noticeDb = true) { UserCenterResourse.Option.OldAccountId = string.Empty; //关闭所有接收 HdlGatewayReceiveLogic.Current.RemoveAllEvent(); //清除升级列表 FirmwareUpdateResourse.dicDeviceUpdateList.Clear(); FirmwareUpdateResourse.dicGatewayUpdateList.Clear(); HdlThreadLogic.Current.RunThread(async () => { //检测APP是否能够退出 while (UserCenterResourse.Option.AppCanSignout == false) { await Task.Delay(500); } //设定一个时间 Config.Instance.LoginDateTime = new DateTime(1970, 1, 1); Config.Instance.Save(); //清空当前住宅id Shared.Common.Config.Instance.HomeId = string.Empty; HdlGatewayLogic.Current.ClearAllRealGateway(); try { //断开远程Mqtt连接 ZigBee.Device.ZbGateway.DisConnectRemoteMqttClient(); } catch { } if (noticeDb == true) { //通知云端,已经退出登陆 var result = await CommonPage.Instance.RequestHttpsZigbeeBytesResultAsync("ZigbeeUsers/SignOut", null, "GET"); } HdlThreadLogic.Current.RunMain(() => { //关闭所有打开了的界面 CloseAllOpenForm(); //显示登陆画面 var formLogin = new Shared.Phone.Device.Account.AccountLogin(); Shared.Common.CommonPage.Instance.AddChidren(formLogin); formLogin.Show(account); }); }); } /// /// 关闭所有打开了的界面 /// public static void CloseAllOpenForm() { while (UserView.HomePage.Instance.ChildrenCount > 0) { var view = UserView.HomePage.Instance.GetChildren(UserView.HomePage.Instance.ChildrenCount - 1); if (view is CommonFormBase) { ((CommonFormBase)view).CloseForm(); } else if (view is UserView.UserPage) { break; } else { view.RemoveFromParent(); } } } #endregion #region ■ 子控件的Y轴坐标____________________ /// /// 指定位置类型获取Rowlayout的子控件的Y轴坐标(请确保子控件不大于父容器) /// /// 父控件的真实高度 /// 子控件的真实高度 /// 位置对齐方式 /// 上下间的空白间距,省略时,取行控件共通变量的值。设置为-1时,不计算空白间距 /// public static int GetControlChidrenYaxis(int fatherCtrHeight, int ctrHeight, UViewAlignment alignment, int Space = 0) { if (Space < 0) { //不计算间距值 Space = 0; } if (alignment == UViewAlignment.Center) { return fatherCtrHeight / 2 - ctrHeight / 2; } else if (alignment == UViewAlignment.Top) { return (fatherCtrHeight / 2 - Space / 2) / 2 - ctrHeight / 2; } else { int top = fatherCtrHeight / 2 + Space / 2; return top + (fatherCtrHeight - top) / 2 - ctrHeight / 2; } } #endregion #region ■ 拼接信息___________________________ /// /// 拼接路径(全路径),以住宅ID的文件夹为起点,当没有指定参数时,则返回【住宅ID的文件夹】的全路径 /// /// 要拼接的路径 /// public static string CombinePath(params object[] listNames) { string rootPath = Config.Instance.FullPath; if (listNames == null || listNames.Length == 0) { return rootPath; } foreach (var file in listNames) { if (file == null) { continue; } rootPath = System.IO.Path.Combine(rootPath, file.ToString()); } return rootPath; } /// /// 拼接网关回复超时的信息 /// /// 错误信息 /// 网关返回的resultData,里面有【errorMessageBase】这个东西的那种对象 /// 网关返回的resultData,里面的【errorMessageBase】的值,设定有此值时,resultData无效 /// 是否添加括号 /// public static string CombineGatewayTimeOutMsg(string errorMsg, object resultData, string strResultData = null, bool addBrackets = true) { if (resultData == null && strResultData == null) { return errorMsg; } string errorMsgBase = strResultData; if (errorMsgBase == null) { Type myType = resultData.GetType(); object errorObj = myType.InvokeMember("errorMessageBase", System.Reflection.BindingFlags.GetField, null, resultData, null); if (errorObj == null) { return errorMsg; } errorMsgBase = errorObj.ToString(); } if (errorMsgBase.Contains("回复超时") == false) { //只有回复超时的时候才会加上 return errorMsg; } errorMsg += "\r\n"; if (addBrackets == true) { //(网关回复超时,请稍后再试) return errorMsg + "(" + Language.StringByID(R.MyInternationalizationString.uGatewayResponseTimeOut) + ")"; } else { //网关回复超时,请稍后再试 return errorMsg + Language.StringByID(R.MyInternationalizationString.uGatewayResponseTimeOut); } } #endregion #region ■ 刷新个人中心的内存及线程___________ /// /// 异步方法执行(仅限切换住宅时调用),刷新个人中心的内存及线程 /// public async static Task InitUserCenterMenmoryAndThread() { //APP缓存加载开始 UserCenterResourse.Option.AppCanSignout = false; //只有在住宅ID不一样的时候才做这个操作 if (Common.Config.Instance.HomeId != UserCenterResourse.Option.OldHomeStringId || Common.Config.Instance.Account != UserCenterResourse.Option.OldAccountId) { try { //断开远程Mqtt连接 ZigBee.Device.ZbGateway.DisConnectRemoteMqttClient(); } catch { } //消息记录重新读取及检测 ControlCommonResourse.ReadMessageAgain = true; //加载账号配置信息 var optionInfo = UserCenterResourse.Option.Load(); UserCenterResourse.Option = optionInfo; //变更根用户图片目录路径 UserCenterResourse.Option.UserPictruePath = System.IO.Path.Combine(Shared.IO.FileUtils.RootPath, Config.Instance.Guid, DirNameResourse.UserPictrueDirectory); //初始化登陆账号的信息 await InitUserAccoutInfo(); //初始化管理员权限信息 await InitAdminConnectMqttInfo(true); //初始化缓存成员的信息 InitLocalMemberListInfo(); //重新发送命令去绑定断网情况下备份的网关 HdlGatewayLogic.Current.ResetComandToBindBackupGateway(); //预创建个人中心全部的文件夹 CreatAllUserCenterDirectory(); //关闭所有接收 HdlGatewayReceiveLogic.Current.RemoveAllEvent(); //刷新安防上报信息 HdlAlarmsLogic.Current.RefreshAlarmInfo(); //保存用户的登陆信息到本地 SaveUserInformationToLocation(); UserCenterResourse.Option.OldHomeStringId = Common.Config.Instance.HomeId; UserCenterResourse.Option.OldAccountId = Common.Config.Instance.Account; //同步数据(二次调用没关系) var result = await HdlAutoBackupLogic.SynchronizeDbAutoBackupData(); //初始化本地的网关信息 HdlGatewayLogic.Current.ReFreshByLocal(); //初始化本地的设备信息 Common.LocalDevice.Current.ReFreshByLocal(); //同步云端的网关id,如果本地拥有云端不存在的id,则表示应该被换绑了,直接删除 HdlGatewayLogic.Current.SynchronizeDbGateway(); //初始化住宅对象 Common.Config.Instance.Home = House.GetHouseByHouseId(Common.Config.Instance.HomeId); //初始化房间(郭雪城那边不做处理,需要这里特殊执行一步) Room.RefreshAllRoomByLocation(); //刷新APP前一次选择的网关ID(可以反复调用,需要在网关初始化完了之后才能调用) HdlGatewayLogic.Current.RefreshAppOldSelectGatewayId(); //0:已经同步过,不需要同步,这个时候需要提示备份 if (result == 0) { //开启自动备份提示 HdlAutoBackupLogic.ShowAutoBackupPromptedForm(); } } //APP缓存加载完成 UserCenterResourse.Option.AppCanSignout = true; return true; } #endregion #region ■ 初始化登陆账号的信息_______________ /// /// 初始化登陆账号的信息 /// /// private async static Task InitUserAccoutInfo() { //获取本地记录的用户信息 UserCenterResourse.UserInfo = GetUserInformationFromLocation(); UserCenterResourse.UserInfo.UserIconFile = System.IO.Path.Combine(UserCenterResourse.Option.UserPictruePath, "Admin.png"); //获取登录账号的信息 var pra = new AccountInfoPra(); var listNotShow = new List() { "NotSetAgain" }; string result = await UserCenterLogic.GetResponseDataByRequestHttps("ZigbeeUsers/GetAccountInfo", false, pra, listNotShow); if (string.IsNullOrEmpty(result) == true) { //断网的话,该干嘛就干嘛吧,总之不能控主人的东西 Config.Instance.isAdministrator = false; return false; } var userInfo = Newtonsoft.Json.JsonConvert.DeserializeObject(result); userInfo.Account = Common.Config.Instance.Account; if (string.IsNullOrEmpty(userInfo.UserName) == true) { //没有昵称的时候,把账号作为昵称 userInfo.UserName = Common.Config.Instance.Account; } if (Common.Config.Instance.Home.IsOthreShare == false) { //身份:管理员 userInfo.AuthorityNo = 1; userInfo.AuthorityText = Language.StringByID(R.MyInternationalizationString.Administrator); } else if (Common.Config.Instance.Home.AccountType == 1) { //身份:成员(拥有管理员权限) userInfo.AuthorityNo = 2; userInfo.AuthorityText = Language.StringByID(R.MyInternationalizationString.uMemberHadActionAuthority); } else { //身份:成员 userInfo.AuthorityNo = 3; userInfo.AuthorityText = Language.StringByID(R.MyInternationalizationString.uMember); } if (UserCenterResourse.UserInfo.AuthorityNo != userInfo.AuthorityNo) { //如果登陆的账号的权限和上一次的不一样,则删除本地这个住宅全部的文件,从头再来 string dirPath = CombinePath(); if (System.IO.Directory.Exists(dirPath) == true) { //先记录起住宅的一些信息 var house = House.GetHouseByHouseId(Config.Instance.HomeId); //删除整个文件夹 System.IO.Directory.Delete(dirPath, true); //创建住宅文件夹 Global.CreateHomeDirectory(Config.Instance.HomeId); //预创建个人中心全部的文件夹 CreatAllUserCenterDirectory(); var newHouse = new House(); newHouse.Id = house.Id; newHouse.Name = house.Name; newHouse.IsOthreShare = house.IsOthreShare; newHouse.AccountType = house.AccountType; newHouse.MainUserDistributedMark = house.MainUserDistributedMark; newHouse.Save(false); } } if (string.IsNullOrEmpty(userInfo.UserName) == true) { //没有昵称的话,把账号丢过去 userInfo.UserName = userInfo.Account; } UserCenterResourse.UserInfo = userInfo; UserCenterResourse.UserInfo.UserIconFile = System.IO.Path.Combine(UserCenterResourse.Option.UserPictruePath, "Admin.png"); if (UserCenterResourse.UserInfo.HeadImage != null) { //写入头像内容 Shared.IO.FileUtils.WriteFileByBytes(UserCenterResourse.UserInfo.UserIconFile, UserCenterResourse.UserInfo.HeadImage); } UserCenterResourse.UserInfo.HeadImage = null; //手势密码 UserCenterResourse.Option.GestureAuthentication = UserCenterResourse.UserInfo.GesturePwd == null ? string.Empty : UserCenterResourse.UserInfo.GesturePwd; UserCenterResourse.UserInfo.GesturePwd = null; //密码验证 UserCenterResourse.Option.PswAuthentication = UserCenterResourse.UserInfo.StringPwd == null ? string.Empty : UserCenterResourse.UserInfo.StringPwd; UserCenterResourse.UserInfo.StringPwd = null; //初始化管理员控制主人的连接地址(因为这个连接Token是不会改变的,所以只需要初始化一次) await InitAdminConnectMainInfo(); return true; } /// /// 从本地获取用户的登陆信息 /// /// private static UserInformation GetUserInformationFromLocation() { string fileName = CombinePath(DirNameResourse.LocalMemoryDirectory, DirNameResourse.UserInfoFile); var value = LoadFileContent(fileName); if (value == null) { return new UserInformation(); } var info = Newtonsoft.Json.JsonConvert.DeserializeObject(value); return info; } /// /// 保存用户的登陆信息到本地 /// private static void SaveUserInformationToLocation() { string fullName = UserCenterLogic.CombinePath(DirNameResourse.LocalMemoryDirectory, DirNameResourse.UserInfoFile); //写入内容 SaveFileContent(fullName, UserCenterResourse.UserInfo); //搞一下主人的默认头像 string defultFile = IO.FileUtils.GetImageFilePath("Center/Admin.png"); if (defultFile == string.Empty) { return; } if (System.IO.File.Exists(UserCenterResourse.UserInfo.UserIconFile) == true) { return; } //复制过去 System.IO.File.Copy(defultFile, UserCenterResourse.UserInfo.UserIconFile); } #endregion #region ■ 初始化管理员权限远程连接___________ /// /// 初始化管理员权限远程连接主人的信息 /// /// public static async Task InitAdminConnectMainInfo() { //先清空 Config.Instance.isAdministrator = false; Config.Instance.AdminRequestBaseUrl = string.Empty; Config.Instance.AdminRequestToken = string.Empty; if (UserCenterResourse.UserInfo.AuthorityNo != 2 && UserCenterResourse.UserInfo.AuthorityNo != 3) { //时代变了,这里管理员和成员都能调用 return true; } var pra = new { CommonPage.RequestVersion, LoginAccessToken = Config.Instance.Token, MainAccountId = Config.Instance.Home.MainUserDistributedMark, SharedHid = Config.Instance.Home.Id }; var listNotShow = new List() { "NotSetAgain" }; var result = await GetResponseDataByRequestHttps("App/GetSharedHomeApiControl", false, pra, listNotShow); if (string.IsNullOrEmpty(result) == true) { return false; } Config.Instance.isAdministrator = true; //分享链接 var info = JsonConvert.DeserializeObject(result); Config.Instance.AdminRequestBaseUrl = info.RequestBaseUrl; Config.Instance.AdminRequestToken = info.RequestToken; return true; } /// /// 初始化管理员权限的远程连接信息 /// /// 是否中断远程 /// public static async Task InitAdminConnectMqttInfo(bool stopRemote = false) { if (UserCenterResourse.UserInfo.AuthorityNo != 2 && UserCenterResourse.UserInfo.AuthorityNo != 3) { //只有成员分身才能调用这个函数 return true; } var praMqtt = new { CommonPage.RequestVersion, LoginAccessToken = Config.Instance.Token, Config.Instance.Home.MainUserDistributedMark, HomeId = Config.Instance.Home.Id }; var listNotShow = new List() { "NotSetAgain" }; var result2 = await GetResponseDataByRequestHttps("App/GetConnectMainUserMqttInfo", false, praMqtt, listNotShow); if (string.IsNullOrEmpty(result2) == true) { return false; } //远程Mqtt var info2 = JsonConvert.DeserializeObject(result2); Config.Instance.AdminConnectZigbeeMqttBrokerPwd = info2.ConnectZigbeeMqttBrokerPwd; Config.Instance.AdminConnectZigbeeMqttClientId = info2.ConnectZigbeeMqttClientId; Config.Instance.AdminMqttKey = info2.MqttKey; Config.Instance.AdminZigbeeMqttBrokerLoadSubDomain = info2.ZigbeeMqttBrokerLoadSubDomain; Config.Instance.AdminConnectZigbeeMqttBrokerName = info2.ConnectZigbeeMqttBrokerName; return true; } #endregion #region ■ 初始化缓存成员的信息_______________ /// /// 初始化缓存成员的信息 /// private static void InitLocalMemberListInfo() { //先清空 UserCenterResourse.ListMemberInfo.Clear(); string fileName = CombinePath(DirNameResourse.LocalMemoryDirectory, DirNameResourse.MemberListInfoFile); if (System.IO.File.Exists(fileName) == false) { return; } var varByte = Shared.IO.FileUtils.ReadFile(fileName); UserCenterResourse.ListMemberInfo = JsonConvert.DeserializeObject>(System.Text.Encoding.UTF8.GetString(varByte)); } /// /// 保存缓存成员的信息 /// public static void SaveLocalMemberListInfo() { var data = Newtonsoft.Json.JsonConvert.SerializeObject(UserCenterResourse.ListMemberInfo); var byteData = System.Text.Encoding.UTF8.GetBytes(data); string fullName = UserCenterLogic.CombinePath(DirNameResourse.LocalMemoryDirectory, DirNameResourse.MemberListInfoFile); //写入内容 Shared.IO.FileUtils.WriteFileByBytes(fullName, byteData); } #endregion #region ■ 预创建个人中心全部的文件夹_________ /// /// 预创建个人中心全部的文件夹 /// public static void CreatAllUserCenterDirectory() { //本地缓存的根目录 string LocalDirectory = UserCenterLogic.CombinePath(DirNameResourse.LocalMemoryDirectory); Global.CreateEmptyDirectory(LocalDirectory); //自动备份【文件夹】(编辑,追加) string directory = System.IO.Path.Combine(LocalDirectory, DirNameResourse.AutoBackupDirectory); Global.CreateEmptyDirectory(directory); //自动备份【文件夹】(删除) directory = System.IO.Path.Combine(LocalDirectory, DirNameResourse.AutoBackupdeleteDirectory); Global.CreateEmptyDirectory(directory); //下载备份的时候所使用的临时【文件夹】 directory = System.IO.Path.Combine(LocalDirectory, DirNameResourse.DownLoadBackupTempDirectory); Global.CreateEmptyDirectory(directory); //保存安防记录的【文件夹】 directory = System.IO.Path.Combine(LocalDirectory, DirNameResourse.SafeguardAlarmDirectory); Global.CreateEmptyDirectory(directory); //上传网关备份文件到云端的临时【文件夹】 directory = System.IO.Path.Combine(LocalDirectory, DirNameResourse.GatewayBackupDirectory); Global.CreateEmptyDirectory(directory); //下载分享文件的临时【文件夹】 directory = System.IO.Path.Combine(LocalDirectory, DirNameResourse.DownLoadShardDirectory); Global.CreateEmptyDirectory(directory); //LOG出力【文件夹】 directory = System.IO.Path.Combine(LocalDirectory, DirNameResourse.LogDirectory); Global.CreateEmptyDirectory(directory); //用户图片目录路径【文件夹】 if (UserCenterResourse.Option.UserPictruePath != string.Empty && !System.IO.Directory.Exists(UserCenterResourse.Option.UserPictruePath)) { System.IO.Directory.CreateDirectory(UserCenterResourse.Option.UserPictruePath); } } #endregion #region ■ 获取控制主人账号的Token____________ /// /// 获取控制主人账号的Token /// /// public static string GetConnectMainToken() { //启用管理员权限 if (Config.Instance.isAdministrator == true) { return Config.Instance.AdminRequestToken; } return Config.Instance.Token; } #endregion #region ■ 16进制转化_________________________ /// /// 将16进制的文本翻译为正常文本 /// /// 16进制的文本 /// 以多少个字节为一组 /// public static string TranslateHexadecimalIntoText(string hexText, int count = 2) { string textValue = string.Empty; while (hexText.Length > 0) { string temp = hexText.Substring(0, count); hexText = hexText.Substring(count); int value = Convert.ToInt32(temp, 16); textValue += ((char)value).ToString(); } return textValue; } /// /// 将文本翻译为16进制的文本 /// /// 指定文本 /// public static string TranslateTextIntoHexadecimal(string text) { string textValue = string.Empty; foreach (char c in text) { int value = Convert.ToInt32(c); textValue += Convert.ToString(value, 16); } return textValue; } #endregion #region ■ 加密和解密_________________________ /// /// 加密密码 /// /// /// /// public static string EncryptPassword(string keys, string strPsw) { if (strPsw == string.Empty) { return strPsw; } var des = new System.Security.Cryptography.DESCryptoServiceProvider(); byte[] inputByteArray = Encoding.Default.GetBytes(strPsw); des.Key = ASCIIEncoding.ASCII.GetBytes(keys); des.IV = ASCIIEncoding.ASCII.GetBytes(keys); var ms = new System.IO.MemoryStream(); var cs = new System.Security.Cryptography.CryptoStream(ms, des.CreateEncryptor(), System.Security.Cryptography.CryptoStreamMode.Write); cs.Write(inputByteArray, 0, inputByteArray.Length); cs.FlushFinalBlock(); StringBuilder ret = new StringBuilder(); foreach (byte b in ms.ToArray()) { ret.AppendFormat("{0:X2}", b); } return ret.ToString(); } /// /// 解密密码 /// /// /// public static string DecryptPassword(string keys, string strPsw) { if (strPsw == string.Empty) { return strPsw; } var des = new System.Security.Cryptography.DESCryptoServiceProvider(); byte[] inputByteArray = new byte[strPsw.Length / 2]; for (int x = 0; x < strPsw.Length / 2; x++) { int i = (Convert.ToInt32(strPsw.Substring(x * 2, 2), 16)); inputByteArray[x] = (byte)i; } des.Key = ASCIIEncoding.ASCII.GetBytes(keys); des.IV = ASCIIEncoding.ASCII.GetBytes(keys); var ms = new System.IO.MemoryStream(); var cs = new System.Security.Cryptography.CryptoStream(ms, des.CreateDecryptor(), System.Security.Cryptography.CryptoStreamMode.Write); cs.Write(inputByteArray, 0, inputByteArray.Length); cs.FlushFinalBlock(); StringBuilder ret = new StringBuilder(); return System.Text.Encoding.Default.GetString(ms.ToArray()); } #endregion #region ■ 文件保存和读取_____________________ /// /// 文件保存(整天忘记,所以建一个函数来玩玩) /// /// 全路径 /// 需要序列化的东西 public static void SaveFileContent(string fullName, object obj) { var data = Newtonsoft.Json.JsonConvert.SerializeObject(obj); var byteData = System.Text.Encoding.UTF8.GetBytes(data); //写入内容 Shared.IO.FileUtils.WriteFileByBytes(fullName, byteData); } /// /// 读取文件(文件不存在返回null,整天忘记,所以建一个函数来玩玩) /// /// 全路径 /// public static string LoadFileContent(string fullName) { if (System.IO.File.Exists(fullName) == false) { return null; } var varByte = Shared.IO.FileUtils.ReadFile(fullName); return System.Text.Encoding.UTF8.GetString(varByte); } #endregion } }