using System;
|
using System.Collections.Generic;
|
|
namespace ZigBee.Device
|
{
|
public class ThirdPartyModuleUpgrade : CommonDevice
|
{
|
#region 获取云端(第三方模块）固件信息
|
/// <summary>
|
/// 获取云端服务器中固件版本信息
|
/// </summary>
|
/// <returns>The https app version async.</returns>
|
public async System.Threading.Tasks.Task<ThirdPartyModuelInfoOBJ> RequestHttpsAcVersionAsync(string firewareName)
|
{
|
try
|
{
|
var requestOBJ = new GetFirmwareInfoOBJ
|
{
|
Name = firewareName,
|
RequestVersion = "CodeIDString",//按照郭学成说的当前app是哪个版本
|
FirmwareManaFirstType = 2
|
};
|
var requestJson = Newtonsoft.Json.JsonConvert.SerializeObject(requestOBJ);
|
var result = await RequestHttpsZigbeeAsync("FirmwareMana/DetectionPlatformUploadFirmware", System.Text.Encoding.UTF8.GetBytes(requestJson));
|
if (result == null)
|
{
|
return null;
|
}
|
if (result.StateCode.ToUpper() == "SUCCESS")
|
{
|
if (result.ResponseData == null)
|
{
|
return null;
|
}
|
|
var responeData = Newtonsoft.Json.JsonConvert.DeserializeObject<ThirdPartyModuelInfoRes>(result.ResponseData.ToString());
|
if (responeData == null || responeData.pageData == null)
|
{
|
return null;
|
}
|
// int MaxIndex = 0;
|
//int NewID = 0;
|
//for (int i = 0; i < responeData.pageData.Count; i++)
|
//{
|
//var moduleInfo = responeData.pageData[i];
|
// if (int.Parse(moduleInfo.Id) > NewID)
|
// {
|
// NewID = int.Parse(moduleInfo.Id);
|
// MaxIndex = i;
|
// }
|
//}
|
|
return responeData.pageData[0];
|
}
|
return null;
|
}
|
catch (Exception ex)
|
{
|
return null;
|
}
|
}
|
|
/// 下载云端固件的数据
|
/// </summary>
|
[Serializable]
|
public class ThirdPartyModuelInfoOBJ
|
{
|
public string Name { get; set; }
|
public string FirmwareVersion { get; set; }
|
public string Remarks { get; set; }
|
public string DistributedMark { get; set; }
|
public string Id { get; set; }
|
public string CreatedOnUtc { get; set; }
|
}
|
|
/// <summary>
|
/// 获取云端固件的数据
|
/// </summary>
|
public class GetFirmwareInfoOBJ
|
{
|
public string RequestVersion;
|
/// <summary>
|
/// Name 搜索固件名称(固件名称）
|
/// </summary>
|
public string Name;
|
/// <summary>
|
/// 搜索第一级分类(0:App 1:Zigbee网关 2:Zigbee 设备,3:Buspro）
|
/// </summary>
|
public int FirmwareManaFirstType;
|
}
|
|
//[Serializable]
|
public class ThirdPartyModuelInfoRes
|
{
|
public int PageIndex;
|
public int PageSize;
|
public int TotalCount;
|
public int TotalPages;
|
public bool HasPreviousPage;
|
public bool HasNextPage;
|
public List<ThirdPartyModuelInfoOBJ> pageData = new List<ThirdPartyModuelInfoOBJ> { };
|
}
|
|
string RequestHttpsHost = "https://global.hdlcontrol.com/HangZhouHdlCloudApi";
|
/// <summary>
|
/// 请求服务器方法
|
/// 指定一个Url,和请求方法，数据，Cookie，得到响应的数据
|
/// </summary>
|
/// <param name="requestUrl">请求Url</param>
|
/// <param name="byteData">请求的的数据</param>
|
/// <returns>得到响应的数据</returns>
|
public async System.Threading.Tasks.Task<byte[]> RequestHttpsZigbeeBytesResultAsync(string requestUrl, byte[] byteData)
|
{
|
try
|
{
|
//初始化新的webRequst
|
//1． 创建httpWebRequest对象
|
var webRequest = (System.Net.HttpWebRequest)System.Net.WebRequest.Create(new Uri($"{RequestHttpsHost}/{requestUrl}"));
|
//2． 初始化HttpWebRequest对象
|
webRequest.Method = "POST";
|
webRequest.ContentType = "application/json";
|
webRequest.ContentLength = byteData.Length;
|
webRequest.Headers.Add(System.Net.HttpRequestHeader.Authorization, Shared.Common.Config.Instance.Token);
|
//3． 附加要POST给服务器的数据到HttpWebRequest对象(附加POST数据的过程比较特殊，它并没有提供一个属性给用户存取，需要写入HttpWebRequest对象提供的一个stream里面。)
|
var newStream = webRequest.GetRequestStream();//创建一个Stream,赋值是写入HttpWebRequest对象提供的一个stream里面
|
newStream.Write(byteData, 0, byteData.Length);
|
newStream.Flush();
|
newStream.Close();
|
//4． 读取服务器的返回信息
|
var response = (System.Net.HttpWebResponse)webRequest.GetResponse();
|
var stream = response.GetResponseStream();
|
if (stream == null)
|
{
|
return null;
|
}
|
var result = new byte[stream.Length];
|
//已接收的长度
|
int receivedLength = 0;
|
//注意，当数据比较大时，可能一次性没读完，需要重复读取
|
//当完成时可能返回的结果为 0
|
while (receivedLength < result.Length)
|
{
|
var rece = await stream.ReadAsync(result, receivedLength, result.Length - receivedLength);
|
receivedLength += rece;
|
if (rece == 0)
|
{
|
break;
|
}
|
}
|
stream.Close();
|
response.Close();
|
return result;
|
}
|
catch (Exception e)
|
{
|
System.Console.WriteLine(e.Message);
|
return null;
|
}
|
}
|
|
/// <summary>
|
/// 请求服务器方法
|
/// 指定一个Url,和请求方法，数据，Cookie，得到响应的数据
|
/// </summary>
|
/// <param name="requestUrl">请求Url</param>
|
/// <param name="byteData">请求的的数据</param>
|
/// <returns>得到响应的数据</returns>
|
public async System.Threading.Tasks.Task<string> RequestHttpsZigbeeResultAsync(string requestUrl, byte[] byteData)
|
{
|
var result = await RequestHttpsZigbeeBytesResultAsync(requestUrl, byteData);
|
if (result != null)
|
{
|
return System.Text.Encoding.UTF8.GetString(result);
|
}
|
return null;
|
}
|
|
/// <summary>
|
/// 请求服务器方法
|
/// 指定一个Url,和请求方法，数据，Cookie，得到响应的数据
|
/// </summary>
|
/// <param name="requestUrl">请求Url</param>
|
/// <param name="byteData">请求的的数据</param>
|
/// <returns>得到响应的数据</returns>
|
public async System.Threading.Tasks.Task<Shared.Common.ResponseEntity.ResponsePack> RequestHttpsZigbeeAsync(string requestUrl, byte[] byteData)
|
{
|
string result = await this.RequestHttpsZigbeeResultAsync(requestUrl, byteData);
|
if (result != null)
|
{
|
try
|
{
|
var data = Newtonsoft.Json.JsonConvert.DeserializeObject<Shared.Common.ResponseEntity.ResponsePack>(result);
|
return data;
|
}
|
catch (Exception ex)
|
{
|
System.Console.WriteLine(ex.Message);
|
}
|
}
|
return null;
|
}
|
|
/// <summary>
|
/// 下载Ac程序
|
/// </summary>
|
/// <returns>The load apk async.</returns>
|
/// <param name="requestUrl">请求链接</param>
|
/// <param name="byteData">请求参数</param>
|
public System.Threading.Tasks.Task<byte[]> DownLoadAcAsync(string requestUrl, byte[] byteData)
|
{
|
try
|
{
|
var webClient = new System.Net.WebClient { };
|
webClient.Headers.Add(System.Net.HttpRequestHeader.ContentType, "application/json");
|
webClient.Headers.Add(System.Net.HttpRequestHeader.Authorization, Shared.Common.Config.Instance.Token);
|
var result = webClient.UploadDataTaskAsync($"{RequestHttpsHost}/{requestUrl}", "POST", byteData);
|
if (result == null)
|
{
|
return null;
|
}
|
return result;
|
}
|
catch (Exception ex)
|
{
|
return null;
|
}
|
finally
|
{
|
}
|
}
|
#endregion
|
|
#region 下载固件程序
|
/// <summary>
|
/// 下载Ac固件程序
|
/// </summary>
|
public class DownLoadAcFireware
|
{
|
public string RequestVersion;
|
/// <summary>
|
/// 下载固件的唯一标识
|
/// </summary>
|
public string DistributedMark;
|
}
|
#endregion
|
}
|
}
|
