using System;
|
using System.Collections.Generic;
|
|
namespace Shared.SimpleControl.Phone
|
{
|
public class MigrateBean
|
{
|
public MigrateBean ()
|
{
|
}
|
|
|
|
#region 恢复备份
|
/// <summary>
|
/// 获取迁移备份
|
/// </summary>
|
/// <returns></returns>
|
public BackupListNameInfoRes GetMigrateBackupBean ()
|
{
|
BackupListNameInfoRes lostBackup = new BackupListNameInfoRes () {
|
backupUtcTime = "12312312",
|
};
|
var revertObj = HttpServerRequest.Current.GetHomeDataBackupList ();
|
if (revertObj.Code == StateCode.SUCCESS) {
|
var data = Newtonsoft.Json.JsonConvert.DeserializeObject<List<BackupListNameInfoRes>> (revertObj.Data.ToString ());
|
if (data == null) return null;
|
var migrateBackupList = new List<BackupListNameInfoRes> ();
|
foreach (var folder in data) {
|
if (folder.folderName.StartsWith ("迁移备份") || folder.folderName.StartsWith ("MigrateBackup")) {
|
if (Convert.ToDouble (folder.backupUtcTime) > Convert.ToDouble (lostBackup.backupUtcTime)) {
|
lostBackup = folder;
|
}
|
}
|
}
|
return lostBackup.backupUtcTime != "12312312" ? lostBackup : null;
|
} else {
|
//提示错误
|
IMessageCommon.Current.ShowErrorInfoAlter (revertObj.Code);
|
}
|
return null;
|
}
|
/// <summary>
|
/// 用户恢复文件
|
/// </summary>
|
public void UserBakeupFileDetailedInformation (string folderId)
|
{
|
//是否确定恢复该文件数据信息
|
Application.RunOnMainThread (() => {
|
MainPage.Loading.Start ("Download...");
|
});
|
try {
|
ReadFilesAndDelete ();
|
|
var revertObj = HttpServerRequest.Current.GetBackupFolderAllFileList (folderId);
|
if (revertObj.Code == StateCode.SUCCESS) {
|
|
var fileListData = Newtonsoft.Json.JsonConvert.DeserializeObject<List<BackupFileInfoRes>> (revertObj.Data.ToString ());
|
|
MultiThreadDownload (fileListData, folderId);
|
|
} else {
|
//提示错误
|
IMessageCommon.Current.ShowErrorInfoAlter (revertObj.Code);
|
}
|
} catch (Exception ex) {
|
|
Shared.Utlis.WriteLine (ex.ToString ());
|
} finally {
|
|
|
|
}
|
}
|
|
/// <summary>
|
/// 删除本地文件
|
/// </summary>
|
void ReadFilesAndDelete ()
|
{
|
var fileNames = IO.FileUtils.ReadFiles ();
|
foreach (var fileName in fileNames) {
|
if (fileName == UserInfo.GlobalRegisterFile || fileName == UserConfig.configFile) {
|
continue;
|
}
|
IO.FileUtils.DeleteFile (fileName);
|
}
|
|
}
|
object DownloadLocker = new object ();
|
object SendLocker = new object ();
|
/// <summary>
|
/// 多线程下载
|
/// </summary>
|
void MultiThreadDownload (List<BackupFileInfoRes> dataList, string folderId, int maxThreads = 5)
|
{
|
|
int index = 0;
|
int indexCount = 0;
|
var mFileList = dataList.FindAll ((obj) => obj.fileName != "null" && obj.fileName != UserConfig.configFile && obj.fileName != UserInfo.GlobalRegisterFile && obj.fileName != "AccountListDB" && obj.fileName != CommonConfig.ConfigFile);
|
if (maxThreads > mFileList.Count) {
|
maxThreads = mFileList.Count;
|
}
|
|
if (mFileList.Count <= 0) return;
|
|
int resultCount = mFileList.Count / maxThreads;
|
|
//int residue = mFileList.Count % maxThreads;
|
|
/*开启若干线程，分别下载对应的资源*/
|
for (int i = 1; i <= maxThreads; i++) {
|
int startIndex = ((i - 1) * resultCount + 0);
|
int endIndex = resultCount * i - 1;
|
if (i == maxThreads) {
|
/*
|
* 最后一个线程
|
* */
|
endIndex = mFileList.Count - 1;
|
}
|
var id = i;
|
var startIndex1 = startIndex;
|
var endIndex1 = endIndex;
|
//Utlis.WriteLine ($"下载线程：{id} startIndex1:{startIndex1} endIndex1:{endIndex1}");
|
new System.Threading.Thread (() => {
|
|
for (var j = startIndex1; j <= endIndex1; j++) {
|
try {
|
var result = DownloadSomeDataBackup (folderId, mFileList [j]);
|
if (result) {
|
lock (DownloadLocker) {
|
index++;
|
}
|
|
//index++;
|
|
Application.RunOnMainThread (() => {
|
int pro = (int)(index * 1.0 / mFileList.Count * 100);
|
MainPage.Loading.Text = pro.ToString () + "%";
|
});
|
|
}
|
} catch { } finally {
|
lock (SendLocker) {
|
indexCount++;
|
}
|
}
|
//Utlis.WriteLine ($"下载线程：{id} 完成index:{j} indexCount: {indexCount}");
|
}
|
|
}) { IsBackground = true }.Start ();
|
|
System.Threading.Thread.Sleep (100);
|
|
}
|
|
while (indexCount < mFileList.Count) {
|
System.Threading.Thread.Sleep (200);
|
}
|
Utlis.WriteLine ($"下载完成");
|
|
if (index != mFileList.Count) {
|
//删除已经下载的文件个数错误
|
ReadFilesAndDelete ();
|
|
Application.RunOnMainThread (() => {
|
new Alert (Language.StringByID (R.MyInternationalizationString.Tip), Language.StringByID (R.MyInternationalizationString.DownloadFailed),
|
Language.StringByID (R.MyInternationalizationString.Close)).Show ();
|
});
|
|
|
return;
|
}
|
|
|
MainPage.LoginUser.SaveUserInfo ();
|
Room.InitAllRoom ();
|
//2.转换link数据
|
//3.上传link数据
|
HDLLinkUtlis.Current.OneclickUpload (true);
|
//4.上传音响数据
|
//try {
|
// var revertObj = HttpServerRequest.Current.GetSpeakerList ();
|
// if (revertObj.Code == StateCode.SUCCESS) {
|
// var speakerListRes = Newtonsoft.Json.JsonConvert.DeserializeObject<SpeakerListRes> (revertObj.Data.ToString ());
|
// if (speakerListRes != null && speakerListRes.list != null && speakerListRes.list.Count > 0) {
|
// //5.上传智能音响控制目标
|
// var tarList = new List<TargetInfo> ();
|
// foreach (var function in CommonConfig.Current.FunctionList) {
|
// var tar = new TargetInfo ();
|
// tar.isDevice = true;
|
// tar.targetId = function.deviceId;
|
// tar.targetName = function.name;
|
// tarList.Add (tar);
|
// }
|
// foreach (var scene in CommonConfig.Current.SceneList) {
|
// var tar = new TargetInfo ();
|
// tar.isDevice = true;
|
// tar.targetId = scene.userSceneId;
|
// tar.targetName = scene.name;
|
// tarList.Add (tar);
|
// }
|
// foreach (var ss in speakerListRes.list) {
|
// AddDevicesSceneList (ss.homeId, ss.tokenId, tarList);
|
// }
|
// }
|
// } else {
|
// //提示错误
|
// IMessageCommon.Current.ShowErrorInfoAlter (revertObj.Code);
|
// }
|
//} catch {
|
//} finally {
|
// Application.RunOnMainThread (() => {
|
// MainPage.Loading.Hide ();
|
// });
|
//}
|
|
bool sss = false;
|
#if DEBUG
|
sss = true;
|
#endif
|
|
|
if (!getTimerList () || sss) {
|
var dd = GetTimerBackupBean ();
|
if (dd != null) {
|
TimerBakeupFileDetailedInformation (dd.id);
|
}
|
}
|
|
//6.标记迁移数据完成
|
HttpServerRequest.Current.Mark (UserConfig.Instance.CurrentRegion.Id);
|
Application.RunOnMainThread (() => {
|
//if (CommonPage.IsRemote) {
|
// SmartHome.MqttCommon.DisConnectRemote("UserBakeupFileDetailedInformation");
|
//}
|
UserMiddle.Init (true, true);
|
EquipmentPublicClass.CheckLinkRemote (UserConfig.Instance.internetStatus);
|
//new Alert (Language.StringByID (R.MyInternationalizationString.Tip), Language.StringByID (R.MyInternationalizationString.RestoreFileIsSuccessfull),
|
//Language.StringByID (R.MyInternationalizationString.Close)).Show ();
|
});
|
}
|
|
|
/// <summary>
|
/// 下载单个备份文件
|
/// </summary>
|
/// <param name="mmDownLoad"></param>
|
/// <param name="mUrlHead"></param>
|
/// <param name="file"></param>
|
/// <returns></returns>
|
bool DownloadSomeDataBackup (string folderId, BackupFileInfoRes file)
|
{
|
var requestJson = HttpUtil.GetSignRequestJson (new BackupFileDownObj () {
|
folderId = folderId,
|
fileId = file.id,
|
homeId = UserConfig.Instance.CurrentRegion.Id
|
});
|
var revertObj = HttpUtil.RequestHttpsDownload (NewAPI.API_POST_File_Down, requestJson, null, UserConfig.Instance.CurrentRegion.regionUrl);
|
|
if (revertObj != null && revertObj.Length > 0) {
|
Utlis.WriteLine ("DownloadSomeDataBackup: " + file.fileName);
|
IO.FileUtils.WriteFileByBytes (file.fileName, revertObj);
|
return true;
|
} else {
|
return false;
|
}
|
}
|
/// <summary>
|
/// 下载1.0定时器数据
|
/// </summary>
|
/// <param name="folderId"></param>
|
/// <param name="file"></param>
|
void DownloadTimerBackup (string folderId, BackupFileInfoRes file)
|
{
|
var requestJson = HttpUtil.GetSignRequestJson (new BackupFileDownObj () {
|
folderId = folderId,
|
fileId = file.id,
|
homeId = UserConfig.Instance.CurrentRegion.Id
|
});
|
var revertObj = HttpUtil.RequestHttpsDownload (NewAPI.API_POST_File_Down, requestJson, null, UserConfig.Instance.CurrentRegion.regionUrl);
|
|
if (revertObj != null && revertObj.Length > 0) {
|
var data = System.Text.Encoding.UTF8.GetString (revertObj);
|
var obj = Newtonsoft.Json.JsonConvert.DeserializeObject<Timer_Old> (data);
|
//旧对象要转成新对象
|
var timerTemp = new Timer ();
|
var perio = obj.Periodicity.Split (",");
|
foreach(var p in perio) {
|
int wd = 1;
|
int.TryParse (p, out wd);
|
timerTemp.whichDay.Add (wd);
|
}
|
timerTemp.timerType = obj.TimerType;
|
timerTemp.timerName = obj.TimerName;
|
timerTemp.RoomName = obj.RoomName;
|
timerTemp.executeUtcTime = obj.ExecutionTime;
|
DeviceDate deviceDate = new DeviceDate ();
|
deviceDate.gatewayId = SmartHome.Send.GatewayId;
|
deviceDate.homeId = SmartHome.Send.HomeId;
|
List<Fun> selectedDeviceList = new List<Fun> ();
|
|
var objControlDeviceList = Newtonsoft.Json.JsonConvert.DeserializeObject<List<DeviceInfo>> (obj.ControlDeviceData);
|
foreach(var cd in objControlDeviceList) {
|
var cloudTimerDevcie = CommonConfig.Current.FunctionList.Find ((cloudFunction) => cloudFunction.bus.SubnetID == cd.SubnetID
|
&& cloudFunction.bus.DeviceID == cd.DeviceID && cloudFunction.bus.LoopId == cd.LoopID);
|
if (cloudTimerDevcie != null) {
|
//var oldSendBytes = System.Text.Encoding.UTF8.GetBytes (cd.SendBytes);
|
|
|
string keyValue = "";
|
string oldValue = "";
|
switch (cloudTimerDevcie.spk) {
|
case SPK.CurtainTrietex:
|
case SPK.CurtainRoller:
|
case SPK.LightSwitch:
|
case SPK.CurtainSwitch:
|
case SPK.ElectricSocket: {
|
keyValue = "on_off";
|
if (cd.SendBytes.Length > 0) {
|
oldValue = cd.SendBytes [1].ToString () == "0" ? "off" : "on";
|
}
|
}
|
break;
|
case SPK.LightDimming: {
|
keyValue = "brightness";
|
if (cd.SendBytes.Length > 1) {
|
oldValue = cd.SendBytes [1].ToString ();
|
}
|
}
|
break;
|
case SPK.ElectricFan: {
|
keyValue = "fan_speed_percent";
|
if (cd.SendBytes.Length > 1) {
|
oldValue = cd.SendBytes [1].ToString ();
|
}
|
}
|
break;
|
|
}
|
Fun fun = new Fun ();
|
fun.deviceId = Int64.Parse (cloudTimerDevcie.deviceId);
|
fun.spk = cloudTimerDevcie.spk;
|
fun.attributes.Add (new Attributes { key = keyValue, value = oldValue });
|
fun.bus.addresses = cloudTimerDevcie.bus.addresses;
|
fun.bus.loopId = cloudTimerDevcie.bus.loopId;
|
|
|
switch (fun.spk) {
|
case SPK.LightDimming: {
|
//调光做了一个特殊处理；
|
if (fun.attributes.Count == 1) {
|
var dic = fun.attributes [0];
|
if (dic.key == "brightness") {
|
Attributes attributes = new Attributes ();
|
attributes.key = "on_off";
|
if (dic.value == "0") {
|
attributes.value = "off";
|
} else {
|
attributes.value = "on";
|
}
|
fun.attributes.Add (attributes);
|
}
|
|
}
|
break;
|
}
|
case SPK.ElectricFan: {
|
if (fun.attributes.Count == 1) {
|
var dic = fun.attributes [0];
|
if (dic.key == "fan_speed_percent") {
|
Attributes attributes = new Attributes ();
|
attributes.key = "on_off";
|
if (dic.value == "0") {
|
attributes.value = "off";
|
} else {
|
attributes.value = "on";
|
}
|
fun.attributes.Add (attributes);
|
}
|
}
|
}
|
break;
|
}
|
selectedDeviceList.Add (fun);
|
}
|
}
|
|
|
deviceDate.actions.AddRange (selectedDeviceList);
|
timerTemp.controlData = deviceDate;
|
|
|
var dd = SmartHome.Send.AddTimer (timerTemp);
|
Console.WriteLine ("迁移定时器");
|
}
|
}
|
|
#endregion
|
|
|
|
|
|
///// <summary>
|
/////
|
///// </summary>
|
///// <param name="lsit"></param>
|
//void AddDevicesSceneList (string homeId, string tokenId, List<TargetInfo> lsit)
|
//{
|
// try {
|
// bool result = UpdateSpeakerDeviceList (homeId, tokenId, lsit);
|
// } catch { } finally {
|
// Application.RunOnMainThread (() => {
|
// MainPage.Loading.Hide ();
|
// });
|
// }
|
//}
|
|
|
///// <summary>
|
///// 添加或者更新设备和场景设备列表
|
///// </summary>
|
//bool UpdateSpeakerDeviceList (string homeId,string tokenId, List<TargetInfo> mList)
|
//{
|
// var updateSpeakerDeviceListObj = new UpdateSpeakerDeviceListObj () {
|
// homeId = homeId,
|
// tokenId = tokenId,
|
// targetInfos = mList
|
// };
|
// var revertObj = HttpServerRequest.Current.UpdateSpeakerDeviceList (updateSpeakerDeviceListObj);
|
// if (revertObj.Code == StateCode.SUCCESS) {
|
// return true;
|
// } else {
|
// //登录失败
|
// IMessageCommon.Current.ShowErrorInfoAlter (revertObj.Code);
|
// }
|
// return false;
|
//}
|
|
/// <summary>
|
/// 获取迁移备份
|
/// </summary>
|
/// <returns></returns>
|
public BackupListNameInfoRes GetTimerBackupBean ()
|
{
|
BackupListNameInfoRes lostBackup = new BackupListNameInfoRes () {
|
backupUtcTime = "12312312",
|
};
|
var revertObj = HttpServerRequest.Current.GetHomeDataBackupList ();
|
if (revertObj.Code == StateCode.SUCCESS) {
|
var data = Newtonsoft.Json.JsonConvert.DeserializeObject<List<BackupListNameInfoRes>> (revertObj.Data.ToString ());
|
if (data == null) return null;
|
var migrateBackupList = new List<BackupListNameInfoRes> ();
|
foreach (var folder in data) {
|
if (folder.backupClassify == "CUSTOM_PROJECT_BACKUP" && folder.folderName.StartsWith ("ScheduleBackup")) {
|
if (Convert.ToDouble (folder.backupUtcTime) > Convert.ToDouble (lostBackup.backupUtcTime)) {
|
lostBackup = folder;
|
}
|
}
|
}
|
return lostBackup.backupUtcTime != "12312312" ? lostBackup : null;
|
} else {
|
//提示错误
|
IMessageCommon.Current.ShowErrorInfoAlter (revertObj.Code);
|
}
|
return null;
|
}
|
|
/// <summary>
|
/// 定时器恢复文件
|
/// </summary>
|
public void TimerBakeupFileDetailedInformation (string folderId)
|
{
|
//是否确定恢复该文件数据信息
|
Application.RunOnMainThread (() => {
|
MainPage.Loading.Start ("Download...");
|
});
|
try {
|
|
var revertObj = HttpServerRequest.Current.GetBackupFolderAllFileList (folderId);
|
if (revertObj.Code == StateCode.SUCCESS) {
|
|
var fileListData = Newtonsoft.Json.JsonConvert.DeserializeObject<List<BackupFileInfoRes>> (revertObj.Data.ToString ());
|
|
for (int i = 0; i < fileListData.Count; i++) {
|
DownloadTimerBackup (folderId, fileListData [i]);
|
}
|
|
} else {
|
//提示错误
|
IMessageCommon.Current.ShowErrorInfoAlter (revertObj.Code);
|
}
|
} catch (Exception ex) {
|
|
Shared.Utlis.WriteLine (ex.ToString ());
|
} finally {
|
|
|
|
}
|
}
|
|
|
|
/// <summary>
|
/// 获取新平台定时器列表
|
/// </summary>
|
bool getTimerList ()
|
{
|
var revertObj = SmartHome.Send.GetTimerList ();
|
if (revertObj.Code == StateCode.SUCCESS) {
|
if (revertObj.Data == null) {
|
return false;
|
}
|
if (string.IsNullOrEmpty (revertObj.Data.ToString ())) {
|
return false;
|
}
|
var jsonDate = Newtonsoft.Json.Linq.JObject.Parse (revertObj.Data.ToString ());
|
var array = jsonDate ["list"].ToString ();
|
var jArray = Newtonsoft.Json.Linq.JArray.Parse (array);
|
if (jArray.Count > 0) {
|
return true;
|
}
|
}
|
return false;
|
|
}
|
|
|
/// <summary>
|
/// 完成操作
|
/// </summary>
|
public void showFinish ()
|
{
|
Application.RunOnMainThread (() => {
|
UserMiddle.Init (true, true);
|
EquipmentPublicClass.CheckLinkRemote (UserConfig.Instance.internetStatus);
|
new Alert (Language.StringByID (R.MyInternationalizationString.Tip), Language.StringByID (R.MyInternationalizationString.RestoreFileIsSuccessfull),
|
Language.StringByID (R.MyInternationalizationString.Close)).Show ();
|
});
|
|
}
|
}
|
}
|
