389 lines
15 KiB
C#
389 lines
15 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Net;
|
||
using System.Net.Http;
|
||
using System.Web.Http;
|
||
using TencentCloud.Common;
|
||
using TencentCloud.Common.Profile;
|
||
using TencentCloud.Iotcloud.V20210408;
|
||
using TencentCloud.Iotcloud.V20210408.Models;
|
||
using Newtonsoft.Json.Linq;
|
||
|
||
namespace MQTTServerSideAPI.Controllers
|
||
{
|
||
public class MessageSendController : ApiController
|
||
{
|
||
public static UInt16 snNum = 0;
|
||
|
||
// GET api/<controller>
|
||
public List<string> Get(string productid,string devicename)
|
||
{
|
||
List<string> t = new List<string>();
|
||
t = SQLiteDBHelper.GetLOGCallin(productid, devicename);
|
||
return t;
|
||
}
|
||
|
||
// GET api/<controller>/5
|
||
public string Get(int id)
|
||
{
|
||
return "value";
|
||
}
|
||
|
||
//public static string PostDownCmd6(String strDevice, UInt32 uintCustTSP, int rspType=1)
|
||
//{
|
||
// if (String.IsNullOrWhiteSpace(strDevice))
|
||
// strDevice = "F305-00003";
|
||
// string strTopic = "HICL5RNXAU/" + strDevice + "/control";
|
||
// string strProductId = "HICL5RNXAU";
|
||
// string strDeviceName = strDevice;
|
||
// string strBytesPara1 = "00 00 00 00 00 00"
|
||
// + "00 00 00 00 00 00"
|
||
// + "00 00 00 00 00 00"
|
||
// + "00 00 00 00 00 00"
|
||
// + "00 00 00 00 00 00";
|
||
|
||
// DateTimeOffset tof = new DateTimeOffset(DateTime.UtcNow);
|
||
// byte[] timeNow = BitConverter.GetBytes((UInt32)(tof.ToUnixTimeSeconds()));
|
||
|
||
// Logger.LogCalloutanaSide("\r\n命令06回复设备3，设备：" + strDevice + " TSP:" + uintCustTSP + " rspType:" + rspType);
|
||
|
||
// byte a;
|
||
// int paraLen = 0;
|
||
// byte[] tmpParaBt = new byte[400];
|
||
// string strBytesPara = "";
|
||
// if (rspType == 1) //MAC
|
||
// {
|
||
// tmpParaBt[paraLen] = 0x01;
|
||
// paraLen++;
|
||
|
||
// strBytesPara = strBytesPara1;
|
||
// strBytesPara = strBytesPara.Trim();
|
||
// if (!String.IsNullOrWhiteSpace(strBytesPara))
|
||
// {
|
||
// strBytesPara = strBytesPara.Trim();
|
||
// string[] hexes = strBytesPara.Split(' ');
|
||
// for (int i = 0; i < hexes.Length; i++)
|
||
// {
|
||
// a = Convert.ToByte(hexes[i], 16);
|
||
// tmpParaBt[paraLen] = a;
|
||
// paraLen++;
|
||
// }
|
||
// }
|
||
// }
|
||
// else // == 2, TimeStamp
|
||
// {
|
||
// tmpParaBt[paraLen] = 0x02;
|
||
// paraLen++;
|
||
|
||
// if (uintCustTSP != 0)
|
||
// {
|
||
// byte[] timeNow1 = BitConverter.GetBytes(uintCustTSP);
|
||
// tmpParaBt[paraLen] = timeNow1[0];
|
||
// paraLen++;
|
||
// tmpParaBt[paraLen] = timeNow1[1];
|
||
// paraLen++;
|
||
// tmpParaBt[paraLen] = timeNow1[2];
|
||
// paraLen++;
|
||
// tmpParaBt[paraLen] = timeNow1[3];
|
||
// paraLen++;
|
||
|
||
// string downstr1 = "";
|
||
// for (int i = paraLen-4; i < paraLen; i++)
|
||
// {
|
||
// downstr1 += tmpParaBt[i].ToString("X2");
|
||
// }
|
||
// Logger.LogCalloutanaSide("\r\n命令06回复设备3.5 ，时间戳字节：" + downstr1);
|
||
// }
|
||
// else
|
||
// {
|
||
// tmpParaBt[paraLen] = timeNow[0];
|
||
// paraLen++;
|
||
// tmpParaBt[paraLen] = timeNow[1];
|
||
// paraLen++;
|
||
// tmpParaBt[paraLen] = timeNow[2];
|
||
// paraLen++;
|
||
// tmpParaBt[paraLen] = timeNow[3];
|
||
// paraLen++;
|
||
// }
|
||
|
||
// }
|
||
|
||
// Logger.LogCalloutanaSide("\r\n命令06回复设备4");
|
||
|
||
// byte[] fixedHead = new byte[12];
|
||
// fixedHead[0] = 0xA6;
|
||
|
||
// snNum++;
|
||
// byte[] btSn = BitConverter.GetBytes(snNum);
|
||
// fixedHead[1] = btSn[0];
|
||
// fixedHead[2] = btSn[1];
|
||
// fixedHead[3] = timeNow[0];
|
||
// fixedHead[4] = timeNow[1];
|
||
// fixedHead[5] = timeNow[2];
|
||
// fixedHead[6] = timeNow[3];
|
||
// fixedHead[10] = 0x01;
|
||
// fixedHead[11] = 0x06;
|
||
|
||
|
||
// Logger.LogCalloutanaSide("\r\n命令06回复设备5");
|
||
|
||
// int resultLen = 0;
|
||
// byte[] resultByte = new byte[500];
|
||
// for (int i = 0; i < fixedHead.Length; i++)
|
||
// {
|
||
// resultByte[resultLen] = fixedHead[i];
|
||
// resultLen++;
|
||
// }
|
||
// for (int i = 0; i < paraLen; i++)
|
||
// {
|
||
// resultByte[resultLen] = tmpParaBt[i];
|
||
// resultLen++;
|
||
// }
|
||
// byte[] lenbtye = BitConverter.GetBytes((UInt16)resultByte.Length);
|
||
// resultByte[7] = lenbtye[0];
|
||
// resultByte[8] = lenbtye[1];
|
||
|
||
// //校验和
|
||
// resultByte[9] = 0x00;
|
||
|
||
// resultByte[9] = GetCheckSum(resultByte, resultLen);
|
||
|
||
// string resultBase64 = Convert.ToBase64String(resultByte, 0, resultLen);
|
||
|
||
// Logger.LogCalloutanaSide("\r\n命令06回复设备6");
|
||
|
||
|
||
// string downstr = "";
|
||
// for (int i = 0; i < resultLen; i++)
|
||
// {
|
||
// downstr += resultByte[i].ToString("X2");
|
||
// }
|
||
// Logger.LogCalloutanaSide("\r\n下发命令字节：" + downstr);
|
||
|
||
// string retString = SendMQTTServerAPI(strProductId, strDeviceName, strTopic, resultBase64);
|
||
|
||
// Logger.LogCalloutanaSide("\r\n命令06回复设备7");
|
||
|
||
// return retString;
|
||
//}
|
||
|
||
// POST api/<controller>
|
||
public string Post([FromBody] JObject uisenddata)
|
||
{
|
||
string retString = "value";
|
||
|
||
string strTopic = (String)uisenddata["topic"];
|
||
string strProductId = (String)uisenddata["productid"];
|
||
string strDeviceName = (String)uisenddata["devicename"];
|
||
string strCmd = (String)uisenddata["cmd"];
|
||
string strBytesPara = (String)uisenddata["bytepara"];
|
||
byte a;
|
||
int paraLen = 0;
|
||
byte[] tmpParaBt = new byte[400];
|
||
strBytesPara = strBytesPara.Trim();
|
||
if(!String.IsNullOrWhiteSpace(strBytesPara))
|
||
{
|
||
strBytesPara = strBytesPara.Trim();
|
||
string[] hexes = strBytesPara.Split(' ');
|
||
for(int i = 0; i < hexes.Length; i ++)
|
||
{
|
||
a = Convert.ToByte(hexes[i], 16);
|
||
tmpParaBt[paraLen] = a;
|
||
paraLen++;
|
||
}
|
||
}
|
||
|
||
DateTimeOffset tof = new DateTimeOffset(DateTime.UtcNow);
|
||
byte[] fixedHead = new byte[12];
|
||
fixedHead[0] = 0xA6;
|
||
|
||
snNum++;
|
||
byte[] btSn = BitConverter.GetBytes(snNum);
|
||
fixedHead[1] = btSn[0];
|
||
fixedHead[2] = btSn[1];
|
||
|
||
byte[] timeNow = BitConverter.GetBytes((UInt32)(tof.ToUnixTimeSeconds()));
|
||
fixedHead[3] = timeNow[0];
|
||
fixedHead[4] = timeNow[1];
|
||
fixedHead[5] = timeNow[2];
|
||
fixedHead[6] = timeNow[3];
|
||
fixedHead[10] = 0x01;
|
||
if (strCmd == "06")
|
||
fixedHead[11] = 0x06;
|
||
else if (strCmd == "07")
|
||
fixedHead[11] = 0x07;
|
||
else if (strCmd == "08")
|
||
fixedHead[11] = 0x08;
|
||
else if (strCmd == "09")
|
||
fixedHead[11] = 0x09;
|
||
else
|
||
fixedHead[11] = Convert.ToByte(strCmd, 16);
|
||
|
||
int resultLen = 0;
|
||
byte[] resultByte = new byte[500];
|
||
for(int i = 0; i < fixedHead.Length; i ++)
|
||
{
|
||
resultByte[resultLen] = fixedHead[i];
|
||
resultLen++;
|
||
}
|
||
for (int i = 0; i < paraLen; i++)
|
||
{
|
||
resultByte[resultLen] = tmpParaBt[i];
|
||
resultLen++;
|
||
}
|
||
byte[] lenbtye = BitConverter.GetBytes((UInt16)resultLen);
|
||
resultByte[7] = lenbtye[0];
|
||
resultByte[8] = lenbtye[1];
|
||
|
||
//校验和
|
||
resultByte[9] = 0x00;
|
||
|
||
resultByte[9] = GetCheckSum(resultByte, resultLen);
|
||
|
||
string downstr = "";
|
||
for(int i = 0; i < resultLen; i ++)
|
||
{
|
||
downstr += resultByte[i].ToString() + " ";
|
||
}
|
||
|
||
Logger.LogCalloutanaSide("设备"+strDeviceName + "下发命令字节：" + downstr);
|
||
|
||
|
||
string resultBase64 = Convert.ToBase64String(resultByte, 0, resultLen);
|
||
|
||
|
||
try
|
||
{
|
||
// 实例化一个认证对象，入参需要传入腾讯云账户 SecretId 和 SecretKey，此处还需注意密钥对的保密
|
||
// 代码泄露可能会导致 SecretId 和 SecretKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考，建议采用更安全的方式来使用密钥，请参见：https://cloud.tencent.com/document/product/1278/85305
|
||
// 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
|
||
Credential cred = new Credential
|
||
{
|
||
SecretId = "AKIDKhz84sbEqFPRK1Uo0zUnwwjNp4884vc4",
|
||
SecretKey = "JQ8qZGxgQAtbCfvxb7VqzxujOtFVb1KT"
|
||
};
|
||
// 实例化一个client选项，可选的，没有特殊需求可以跳过
|
||
ClientProfile clientProfile = new ClientProfile();
|
||
// 实例化一个http选项，可选的，没有特殊需求可以跳过
|
||
HttpProfile httpProfile = new HttpProfile();
|
||
httpProfile.Endpoint = ("iotcloud.tencentcloudapi.com");
|
||
clientProfile.HttpProfile = httpProfile;
|
||
|
||
// 实例化要请求产品的client对象,clientProfile是可选的
|
||
IotcloudClient client = new IotcloudClient(cred, "ap-guangzhou", clientProfile);
|
||
// 实例化一个请求对象,每个接口都会对应一个request对象
|
||
PublishMessageRequest req = new PublishMessageRequest();
|
||
req.Topic = strTopic; // "HICL5RNXAU/F305-00002/control";
|
||
req.Payload = resultBase64;
|
||
req.ProductId = strProductId; // "HICL5RNXAU";
|
||
req.DeviceName = strDeviceName; // "F305-00002";
|
||
req.PayloadEncoding = "base64";
|
||
|
||
Logger.LogDownSide(String.Format("Send request: req.Topic:{0}, req.PayLoad:{1}, req.ProductId:{2}, req.DeviceName:{3}",
|
||
req.Topic,
|
||
req.Payload,
|
||
req.ProductId,
|
||
req.DeviceName
|
||
));
|
||
|
||
|
||
// 返回的resp是一个PublishMessageResponse的实例，与请求对象对应
|
||
PublishMessageResponse resp = client.PublishMessageSync(req);
|
||
// 输出json格式的字符串回包
|
||
retString = "Success " + AbstractModel.ToJsonString(resp);
|
||
|
||
Logger.LogDownSide("Success return !! " + retString);
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
if (e.InnerException != null)
|
||
retString = "Error " + e.InnerException.ToString();
|
||
Logger.LogDownSide("Failed exception !! " + e.ToString());
|
||
}
|
||
|
||
return retString;
|
||
}
|
||
|
||
//public static string SendMQTTServerAPI(string strProductId, string strDeviceName, string strTopic, string resultBase64)
|
||
//{
|
||
// string retString = "";
|
||
// try
|
||
// {
|
||
// // 实例化一个认证对象，入参需要传入腾讯云账户 SecretId 和 SecretKey，此处还需注意密钥对的保密
|
||
// // 代码泄露可能会导致 SecretId 和 SecretKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考，建议采用更安全的方式来使用密钥，请参见：https://cloud.tencent.com/document/product/1278/85305
|
||
// // 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
|
||
// Credential cred = new Credential
|
||
// {
|
||
// SecretId = "AKIDKhz84sbEqFPRK1Uo0zUnwwjNp4884vc4",
|
||
// SecretKey = "JQ8qZGxgQAtbCfvxb7VqzxujOtFVb1KT"
|
||
// };
|
||
// // 实例化一个client选项，可选的，没有特殊需求可以跳过
|
||
// ClientProfile clientProfile = new ClientProfile();
|
||
// // 实例化一个http选项，可选的，没有特殊需求可以跳过
|
||
// HttpProfile httpProfile = new HttpProfile();
|
||
// httpProfile.Endpoint = ("iotcloud.tencentcloudapi.com");
|
||
// clientProfile.HttpProfile = httpProfile;
|
||
|
||
// // 实例化要请求产品的client对象,clientProfile是可选的
|
||
// IotcloudClient client = new IotcloudClient(cred, "ap-guangzhou", clientProfile);
|
||
// // 实例化一个请求对象,每个接口都会对应一个request对象
|
||
// PublishMessageRequest req = new PublishMessageRequest();
|
||
// req.Topic = strTopic; // "HICL5RNXAU/F305-00002/control";
|
||
// req.Payload = resultBase64;
|
||
// req.ProductId = strProductId; // "HICL5RNXAU";
|
||
// req.DeviceName = strDeviceName; // "F305-00002";
|
||
// req.PayloadEncoding = "base64";
|
||
|
||
// Logger.LogDownSide(String.Format("Send request: req.Topic:{0}, req.PayLoad:{1}, req.ProductId:{2}, req.DeviceName:{3}",
|
||
// req.Topic,
|
||
// req.Payload,
|
||
// req.ProductId,
|
||
// req.DeviceName
|
||
// ));
|
||
|
||
|
||
// // 返回的resp是一个PublishMessageResponse的实例，与请求对象对应
|
||
// PublishMessageResponse resp = client.PublishMessageSync(req);
|
||
// // 输出json格式的字符串回包
|
||
// retString = "Success " + AbstractModel.ToJsonString(resp);
|
||
|
||
// Logger.LogDownSide("Success return !! " + retString);
|
||
// }
|
||
// catch (Exception e)
|
||
// {
|
||
// if (e.InnerException != null)
|
||
// retString = "Error " + e.InnerException.ToString();
|
||
// Logger.LogDownSide("Failed exception !! " + e.ToString());
|
||
// }
|
||
|
||
// return retString;
|
||
//}
|
||
public static byte GetCheckSum(byte[] data, int datalen)
|
||
{
|
||
List<byte> m = new List<byte>();
|
||
int sum = 0;
|
||
for (int i = 0; i < datalen; i++)
|
||
{
|
||
m.Add(data[i]);
|
||
sum += data[i];
|
||
}
|
||
|
||
sum = sum % 256;
|
||
//sum = ~sum + 1; 跟设备端操作对过，不用加1
|
||
sum = ~sum;
|
||
|
||
return (byte)sum;
|
||
}
|
||
|
||
// PUT api/<controller>/5
|
||
public void Put(int id, [FromBody] string value)
|
||
{
|
||
}
|
||
|
||
// DELETE api/<controller>/5
|
||
public void Delete(int id)
|
||
{
|
||
}
|
||
}
|
||
} |