562 lines
19 KiB
C#
562 lines
19 KiB
C#
|
using System.Data;
|
|||
|
|
using System.Text;
|
|||
|
|
using System.Text.Json;
|
|||
|
|
using System.Text.Json.Serialization;
|
|||
|
|
using Common;
|
|||
|
|
using CommonEntity;
|
|||
|
|
using LogCap.Common;
|
|||
|
|
using Microsoft.AspNetCore.Http;
|
|||
|
|
using Microsoft.AspNetCore.Mvc;
|
|||
|
|
using Microsoft.AspNetCore.Mvc.Diagnostics;
|
|||
|
|
using NLog;
|
|||
|
|
using RestSharp;
|
|||
|
|
using RestSharp.Authenticators;
|
|||
|
|
using ViewModels;
|
|||
|
|
|
|||
|
|
namespace EMQX_HttpAuth.Controllers
|
|||
|
|
{
|
|||
|
|
[Route("api/[controller]/[action]")]
|
|||
|
|
[ApiController]
|
|||
|
|
public class SocketTcpController : ControllerBase
|
|||
|
|
{
|
|||
|
|
private readonly Logger _logger = LogManager.GetCurrentClassLogger();
|
|||
|
|
public static string tcp_server = "http://localhost:8086";
|
|||
|
|
public static string mqtt_server = "http://43.138.217.154:18083";
|
|||
|
|
public IList<char> HexSet = new List<char>() { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F', 'a', 'b', 'c', 'd', 'e', 'f' };
|
|||
|
|
public IConfiguration Configuration { get; set; }
|
|||
|
|
public SocketTcpController(IConfiguration config)
|
|||
|
|
{
|
|||
|
|
this.Configuration = config;
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取所有在线的 下位机 客户端，返回的数据是 IP:端口的形式
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="data"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
[HttpPost()]
|
|||
|
|
async public Task<string> Get_all_TCPClients([FromBody] Data data)
|
|||
|
|
{
|
|||
|
|
RestClient client1 = new RestClient(tcp_server);
|
|||
|
|
//Console.WriteLine("发送MQTT的数据为：" + str);
|
|||
|
|
var request1 = new RestRequest("/blw/tcphandle", Method.Post);
|
|||
|
|
|
|||
|
|
//注意方法是POST
|
|||
|
|
//Console.WriteLine("Topic: " + debug_log_report_mqtt_topic);
|
|||
|
|
request1.AddParameter("cmd", "get_tcp_info");
|
|||
|
|
request1.AddParameter("parameterlist", "");
|
|||
|
|
|
|||
|
|
var Q = await client1.ExecuteAsync(request1);
|
|||
|
|
return Q.Content;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取所有在线的MQTTClient
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="data"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
[HttpPost()]
|
|||
|
|
async public Task<object> Get_all_MQTTClients([FromBody] QueryData data)
|
|||
|
|
{
|
|||
|
|
string? Key = Configuration["Key"];
|
|||
|
|
string? Security = Configuration["Security"];
|
|||
|
|
var option = new RestClientOptions()
|
|||
|
|
{
|
|||
|
|
BaseUrl = new Uri(mqtt_server),
|
|||
|
|
Authenticator = new HttpBasicAuthenticator(Key, Security)
|
|||
|
|
|
|||
|
|
};
|
|||
|
|
RestClient client1 = new RestClient(option);
|
|||
|
|
|
|||
|
|
//Console.WriteLine("发送MQTT的数据为：" + str);
|
|||
|
|
var request1 = new RestRequest("/api/v5/clients", Method.Get);
|
|||
|
|
|
|||
|
|
//注意方法是POST
|
|||
|
|
//Console.WriteLine("Topic: " + debug_log_report_mqtt_topic);
|
|||
|
|
request1.AddQueryParameter("limit", data.Limit);
|
|||
|
|
request1.AddQueryParameter("page", data.Page);
|
|||
|
|
request1.AddQueryParameter("isTrusted", true);
|
|||
|
|
|
|||
|
|
var Q = await client1.ExecuteAsync(request1);
|
|||
|
|
|
|||
|
|
|
|||
|
|
//返回的数据是
|
|||
|
|
//{
|
|||
|
|
// "data": [
|
|||
|
|
// {
|
|||
|
|
// "recv_oct": 147525,
|
|||
|
|
// "send_msg.dropped.expired": 0,
|
|||
|
|
// "recv_msg.qos0": 0,
|
|||
|
|
// "inflight_max": 32,
|
|||
|
|
// "recv_msg.qos1": 3320,
|
|||
|
|
// "send_msg.qos0": 0,
|
|||
|
|
// "recv_msg.qos2": 0,
|
|||
|
|
// "expiry_interval": 0,
|
|||
|
|
// "send_msg.dropped": 0,
|
|||
|
|
// "mqueue_len": 0,
|
|||
|
|
// "proto_ver": 5,
|
|||
|
|
// "keepalive": 60,
|
|||
|
|
// "inflight_cnt": 0,
|
|||
|
|
// "node": "emqx@127.0.0.1",
|
|||
|
|
// "created_at": "2025-06-09T16:08:38.394+08:00",
|
|||
|
|
// "send_cnt": 9436,
|
|||
|
|
// "ip_address": "43.138.217.154",
|
|||
|
|
// "clean_start": true,
|
|||
|
|
// "proto_name": "MQTT",
|
|||
|
|
// "enable_authn": true,
|
|||
|
|
// "mountpoint": null,
|
|||
|
|
// "is_persistent": false,
|
|||
|
|
// "send_msg.qos1": 6113,
|
|||
|
|
// "send_msg.dropped.too_large": 0,
|
|||
|
|
// "send_oct": 331649,
|
|||
|
|
// "recv_msg": 3320,
|
|||
|
|
// "heap_size": 6772,
|
|||
|
|
// "username": "admin",
|
|||
|
|
// "send_msg.dropped.queue_full": 0,
|
|||
|
|
// "send_msg": 6113,
|
|||
|
|
// "clientid": "newemqttclient",
|
|||
|
|
// "subscriptions_max": "infinity",
|
|||
|
|
// "mqueue_max": 1000,
|
|||
|
|
// "recv_pkt": 9436,
|
|||
|
|
// "user_property": {},
|
|||
|
|
// "port": 36036,
|
|||
|
|
// "connected_at": "2025-06-09T16:08:38.394+08:00",
|
|||
|
|
// "mailbox_len": 0,
|
|||
|
|
// "recv_msg.dropped": 0,
|
|||
|
|
// "subscriptions_cnt": 1,
|
|||
|
|
// "is_bridge": false,
|
|||
|
|
// "awaiting_rel_max": 100,
|
|||
|
|
// "awaiting_rel_cnt": 0,
|
|||
|
|
// "mqueue_dropped": 0,
|
|||
|
|
// "send_pkt": 9436,
|
|||
|
|
// "send_msg.qos2": 0,
|
|||
|
|
// "recv_msg.dropped.await_pubrel_timeout": 0,
|
|||
|
|
// "connected": true,
|
|||
|
|
// "reductions": 130011309,
|
|||
|
|
// "recv_cnt": 9436,
|
|||
|
|
// "listener": "tcp:default"
|
|||
|
|
// }
|
|||
|
|
// ],
|
|||
|
|
// "meta": {
|
|||
|
|
// "count": 3,
|
|||
|
|
// "limit": 20,
|
|||
|
|
// "page": 1,
|
|||
|
|
// "hasnext": false
|
|||
|
|
// }
|
|||
|
|
//}
|
|||
|
|
|
|||
|
|
var DDD = System.Text.Json.JsonSerializer.Deserialize<MQTTData>(Q.Content);
|
|||
|
|
|
|||
|
|
var DDD1 = DDD.data.Select(A => new NiMingOO
|
|||
|
|
{
|
|||
|
|
Listener = A["listener"].ToString(),
|
|||
|
|
UserName = A["username"].ToString(),
|
|||
|
|
WWWWIP = A["ip_address"].ToString(),
|
|||
|
|
WWWWPort = A["port"].ToString(),
|
|||
|
|
ClientId = A["clientid"].ToString(),
|
|||
|
|
Connected = A["connected"].ToString(),
|
|||
|
|
connected_DateTime = A["connected_at"].ToString()
|
|||
|
|
}).ToList();
|
|||
|
|
return DDD1;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
public static string FrameNoKey = "FrameNoKey";
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
[HttpPost()]
|
|||
|
|
async public Task<RMsg> send_data_to_target([FromBody] Data data)
|
|||
|
|
{
|
|||
|
|
RMsg r = new RMsg();
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
RestClient client1 = new RestClient(tcp_server);
|
|||
|
|
var request1 = new RestRequest("/blw/tcphandle", Method.Post);
|
|||
|
|
request1.AddParameter("cmd", data.Cmd);
|
|||
|
|
|
|||
|
|
var VData = data.Parameterlist;
|
|||
|
|
string? HHH1 = VData.data;
|
|||
|
|
string? HHH2 = HHH1.Replace(" ", "");
|
|||
|
|
if (IsIllegalHexadecimal(HHH2) == false)
|
|||
|
|
{
|
|||
|
|
request1.AddParameter("parameterlist", JsonSerializer.Serialize(VData));
|
|||
|
|
var Q = await client1.ExecuteAsync(request1);
|
|||
|
|
r.isok = true;
|
|||
|
|
r.message = "success";
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
r.isok = false;
|
|||
|
|
r.message = "错误，发送的数据必须是 16进制";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
r.message = ex.Message;
|
|||
|
|
r.isok = false;
|
|||
|
|
}
|
|||
|
|
return r;
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 发送控制数据
|
|||
|
|
/// 也可以 发送控制指令通过clientid
|
|||
|
|
/// 接口加好了。发送控制指令接口 地址：
|
|||
|
|
///http://iot-manage.uts-data.com:5001/api/sockettcp/send_data_to_targetnew
|
|||
|
|
///
|
|||
|
|
///发送数据如下：
|
|||
|
|
///{
|
|||
|
|
/// "Cmd": "tcp_send_data_clientid",
|
|||
|
|
/// "Parameterlist": {
|
|||
|
|
/// "device_clientid": "71",
|
|||
|
|
/// "command_word":"04",
|
|||
|
|
/// "data": "AA BB CC DD EE FF AA FF AA"
|
|||
|
|
/// }
|
|||
|
|
///}
|
|||
|
|
///command_word 是命令字，device_clientid是CID。data 是要发送的 控制数据
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="data"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
[HttpPost()]
|
|||
|
|
async public Task<RMsg> send_data_to_targetnew([FromBody] Data data)
|
|||
|
|
{
|
|||
|
|
RMsg r = new RMsg();
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
var KKK = CSRedisCacheHelper.ForeverGet<ushort>(FrameNoKey);
|
|||
|
|
if (KKK == 0)
|
|||
|
|
{
|
|||
|
|
CSRedisCacheHelper.Forever(FrameNoKey, 0);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
CSRedisCacheHelper.GenericSerNo(FrameNoKey);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
ushort Xuhao = CSRedisCacheHelper.ForeverGet<ushort>(FrameNoKey);
|
|||
|
|
ushort NewXuHao = 0;
|
|||
|
|
if (Xuhao == ushort.MaxValue)
|
|||
|
|
{
|
|||
|
|
NewXuHao = 0;
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
NewXuHao = (ushort)(Xuhao + 1);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
CSRedisCacheHelper.Forever<ushort>(FrameNoKey, NewXuHao);
|
|||
|
|
|
|||
|
|
RestClient client1 = new RestClient(tcp_server);
|
|||
|
|
var request1 = new RestRequest("/blw/tcphandle", Method.Post);
|
|||
|
|
|
|||
|
|
//cmd 是 tcp_send_data
|
|||
|
|
request1.AddParameter("cmd", data.Cmd);
|
|||
|
|
|
|||
|
|
var VData = data.Parameterlist;
|
|||
|
|
|
|||
|
|
|
|||
|
|
//组装命令
|
|||
|
|
List<byte> lll = new List<byte>();
|
|||
|
|
//包头
|
|||
|
|
lll.Add(0xAA);
|
|||
|
|
|
|||
|
|
//整包长度
|
|||
|
|
lll.Add(0x00);
|
|||
|
|
lll.Add(0x00);
|
|||
|
|
|
|||
|
|
//包序号
|
|||
|
|
byte[] XXX = BitConverter.GetBytes(NewXuHao);
|
|||
|
|
lll.AddRange(XXX);
|
|||
|
|
|
|||
|
|
//重发次数
|
|||
|
|
lll.Add(0x00);
|
|||
|
|
|
|||
|
|
string SSS = VData.device_clientid;
|
|||
|
|
int SXSX = int.Parse(SSS);
|
|||
|
|
//设备序列号
|
|||
|
|
byte[] SXBy = BitConverter.GetBytes(SXSX);
|
|||
|
|
lll.AddRange(SXBy);
|
|||
|
|
|
|||
|
|
|
|||
|
|
// 要加密的数据
|
|||
|
|
List<byte> 加密数据表 = new List<byte>();
|
|||
|
|
|
|||
|
|
//命令字
|
|||
|
|
var UUU = VData.command_word;
|
|||
|
|
ushort III = ushort.Parse(UUU);
|
|||
|
|
byte[] CCC = BitConverter.GetBytes(III);
|
|||
|
|
|
|||
|
|
加密数据表.AddRange(CCC);
|
|||
|
|
|
|||
|
|
string? HHH1 = VData.data;
|
|||
|
|
string? HHH2 = HHH1.Replace(" ", "");
|
|||
|
|
|
|||
|
|
byte[] finally_data = Tools.HEXString2ByteArray(HHH2);
|
|||
|
|
加密数据表.AddRange(finally_data);
|
|||
|
|
|
|||
|
|
//将数据头复制一份
|
|||
|
|
//List<byte> jisuan = new List<byte>(lll);
|
|||
|
|
//加上数据段部分
|
|||
|
|
//jisuan.AddRange(加密数据表);
|
|||
|
|
//jisuan.Add(0x00);
|
|||
|
|
//jisuan.Add(0x00);
|
|||
|
|
//var dainfo = jisuan.ToArray();
|
|||
|
|
//byte[] CRCList = BitConverter.GetBytes(crc);
|
|||
|
|
//加密数据表.AddRange(CRCList);
|
|||
|
|
|
|||
|
|
|
|||
|
|
byte[] key = new byte[] { };
|
|||
|
|
var TST = CSRedisCacheHelper.HMGet<string>(0, CacheKey.DeviceInfo, VData.device_clientid);
|
|||
|
|
if (TST != null)
|
|||
|
|
{
|
|||
|
|
if (TST[0] != null)
|
|||
|
|
{
|
|||
|
|
key = Encoding.ASCII.GetBytes(TST[0]);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
key = Encoding.ASCII.GetBytes("abcdefg123456");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
byte[] decryptedContent = Tools.IHIOT_Message_Content_Encrypt(NewXuHao, key, 加密数据表.ToArray());
|
|||
|
|
|
|||
|
|
lll.AddRange(decryptedContent);
|
|||
|
|
|
|||
|
|
|
|||
|
|
var dainfo = lll.ToArray();
|
|||
|
|
|
|||
|
|
int changdu = dainfo.Length;
|
|||
|
|
|
|||
|
|
changdu = changdu + 2 + 6;
|
|||
|
|
|
|||
|
|
ushort sss1 = (ushort)changdu;
|
|||
|
|
byte[] bas = BitConverter.GetBytes(sss1);
|
|||
|
|
|
|||
|
|
dainfo[1] = bas[0];
|
|||
|
|
dainfo[2] = bas[1];
|
|||
|
|
|
|||
|
|
//CRC
|
|||
|
|
ushort crc = Tools.CRC16(dainfo, dainfo.Length);//最后两个字节，加CRC16校验
|
|||
|
|
//dainfo[dainfo.Length - 2] = Convert.ToByte(crc & 0xff);
|
|||
|
|
//dainfo[dainfo.Length - 1] = Convert.ToByte((crc >> 8) & 0xff);
|
|||
|
|
|
|||
|
|
|
|||
|
|
var USB = dainfo.ToList();
|
|||
|
|
byte[] CRCList = BitConverter.GetBytes(crc);
|
|||
|
|
|
|||
|
|
USB.AddRange(CRCList);
|
|||
|
|
USB.AddRange(new byte[] { 0x2D, 0x2D, 0x0D, 0x0A, 0x2D, 0x2D });
|
|||
|
|
|
|||
|
|
var CMDdata = USB.ToArray();
|
|||
|
|
VData.data = Tools.ByteToString(CMDdata);
|
|||
|
|
|
|||
|
|
if (IsIllegalHexadecimal(HHH2) == false)
|
|||
|
|
{
|
|||
|
|
request1.AddParameter("parameterlist", JsonSerializer.Serialize(VData));
|
|||
|
|
var Q = await client1.ExecuteAsync(request1);
|
|||
|
|
r.isok = true;
|
|||
|
|
r.message = "success";
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
r.isok = false;
|
|||
|
|
r.message = "错误，发送的数据必须是 16进制";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
r.message = ex.Message + ex.StackTrace;
|
|||
|
|
r.isok = false;
|
|||
|
|
}
|
|||
|
|
return r;
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
[HttpPost()]
|
|||
|
|
async public Task<RMsg> send_data_to_lowermachine([FromBody] Data data)
|
|||
|
|
{
|
|||
|
|
RMsg r = new RMsg();
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
var KKK = CSRedisCacheHelper.ForeverGet<ushort>(FrameNoKey);
|
|||
|
|
if (KKK == 0)
|
|||
|
|
{
|
|||
|
|
CSRedisCacheHelper.Forever(FrameNoKey, 0);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
CSRedisCacheHelper.GenericSerNo(FrameNoKey);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var Xuhao = CSRedisCacheHelper.ForeverGet<ushort>(FrameNoKey);
|
|||
|
|
|
|||
|
|
RestClient client1 = new RestClient(tcp_server);
|
|||
|
|
var request1 = new RestRequest("/blw/tcphandle", Method.Post);
|
|||
|
|
|
|||
|
|
//cmd 是 tcp_send_data
|
|||
|
|
request1.AddParameter("cmd", data.Cmd);
|
|||
|
|
|
|||
|
|
var VData = data.Parameterlist;
|
|||
|
|
//var HHH = JsonSerializer.Deserialize<SendData>(VData);
|
|||
|
|
List<byte> lll = new List<byte>();
|
|||
|
|
//包头
|
|||
|
|
lll.Add(0xAA);
|
|||
|
|
|
|||
|
|
//整包长度
|
|||
|
|
lll.Add(0x00);
|
|||
|
|
lll.Add(0x00);
|
|||
|
|
|
|||
|
|
//包序号
|
|||
|
|
byte[] XXX = BitConverter.GetBytes(Xuhao);
|
|||
|
|
lll.AddRange(XXX);
|
|||
|
|
|
|||
|
|
//重发次数
|
|||
|
|
lll.Add(0x00);
|
|||
|
|
|
|||
|
|
string SSS = VData.device_clientid;
|
|||
|
|
int SXSX = int.Parse(SSS);
|
|||
|
|
//设备序列号
|
|||
|
|
byte[] SXBy = BitConverter.GetBytes(SXSX);
|
|||
|
|
lll.AddRange(SXBy);
|
|||
|
|
|
|||
|
|
|
|||
|
|
List<byte> lll_new = new List<byte>(lll.ToArray());
|
|||
|
|
//命令字
|
|||
|
|
List<byte> jia_mi_bytes = new List<byte>();
|
|||
|
|
var UUU = VData.command_word;
|
|||
|
|
ushort III = ushort.Parse(UUU);
|
|||
|
|
byte[] CCC = BitConverter.GetBytes(III);
|
|||
|
|
lll.AddRange(CCC);
|
|||
|
|
|
|||
|
|
jia_mi_bytes.AddRange(CCC);
|
|||
|
|
|
|||
|
|
|
|||
|
|
string? HHH1 = VData.data;
|
|||
|
|
string? HHH2 = HHH1.Replace(" ", "");
|
|||
|
|
|
|||
|
|
byte[] finally_data = Tools.HEXString2ByteArray(HHH2);
|
|||
|
|
|
|||
|
|
lll.AddRange(finally_data);
|
|||
|
|
jia_mi_bytes.AddRange(finally_data);
|
|||
|
|
|
|||
|
|
lll.Add(0x00);
|
|||
|
|
lll.Add(0x00);
|
|||
|
|
|
|||
|
|
var dainfo = lll.ToArray();
|
|||
|
|
|
|||
|
|
//CRC
|
|||
|
|
ushort crc = Tools.CRC16(dainfo, dainfo.Length - 2);//最后两个字节，加CRC16校验
|
|||
|
|
dainfo[dainfo.Length - 2] = Convert.ToByte(crc & 0xff);
|
|||
|
|
dainfo[dainfo.Length - 1] = Convert.ToByte((crc >> 8) & 0xff);
|
|||
|
|
|
|||
|
|
var dataF = dainfo.ToList();
|
|||
|
|
byte[] CRCList = BitConverter.GetBytes(crc);
|
|||
|
|
|
|||
|
|
jia_mi_bytes.AddRange(CRCList);
|
|||
|
|
|
|||
|
|
byte[] key = new byte[] { };
|
|||
|
|
var TST = CSRedisCacheHelper.HMGet<DeviceCacheInfo>(0, CacheKey.DeviceInfo, VData.device_clientid);
|
|||
|
|
if (TST != null)
|
|||
|
|
{
|
|||
|
|
key = Encoding.ASCII.GetBytes(TST[0].SecretKey);
|
|||
|
|
}
|
|||
|
|
byte[] decryptedContent = Tools.IHIOT_Message_Content_Encrypt(Xuhao, key, jia_mi_bytes.ToArray());
|
|||
|
|
|
|||
|
|
dataF.AddRange(new byte[] { 0x2D, 0x2D, 0x0D, 0x0A, 0x2D, 0x2D });
|
|||
|
|
var CMDdata = dataF.ToArray();
|
|||
|
|
int len = CMDdata.Length;
|
|||
|
|
ushort sss1 = (ushort)len;
|
|||
|
|
byte[] bas = BitConverter.GetBytes(sss1);
|
|||
|
|
|
|||
|
|
CMDdata[1] = bas[0];
|
|||
|
|
CMDdata[2] = bas[1];
|
|||
|
|
|
|||
|
|
VData.data = Tools.ByteToString(CMDdata);
|
|||
|
|
|
|||
|
|
if (IsIllegalHexadecimal(HHH2) == false)
|
|||
|
|
{
|
|||
|
|
request1.AddParameter("parameterlist", JsonSerializer.Serialize(VData));
|
|||
|
|
var Q = await client1.ExecuteAsync(request1);
|
|||
|
|
r.isok = true;
|
|||
|
|
r.message = "success";
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
r.isok = false;
|
|||
|
|
r.message = "错误，发送的数据必须是 16进制";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
_logger.Error("错误:" + ex.Message);
|
|||
|
|
r.message = ex.Message;
|
|||
|
|
r.isok = false;
|
|||
|
|
}
|
|||
|
|
return r;
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 判断十六进制字符串hex是否正确
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="hex">十六进制字符串</param>
|
|||
|
|
/// <returns>true：不正确，false：正确</returns>
|
|||
|
|
public bool IsIllegalHexadecimal(string hex)
|
|||
|
|
{
|
|||
|
|
foreach (char item in hex)
|
|||
|
|
{
|
|||
|
|
if (!HexSet.Contains<char>(item))
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public class MQTTData
|
|||
|
|
{
|
|||
|
|
public List<Dictionary<string, object>> data { get; set; }
|
|||
|
|
public Dictionary<string, object> meta { get; set; }
|
|||
|
|
}
|
|||
|
|
public class NiMingOO
|
|||
|
|
{
|
|||
|
|
public string? Listener { get; set; }
|
|||
|
|
public string? UserName { get; set; }
|
|||
|
|
public string? WWWWIP { get; set; }
|
|||
|
|
public string? WWWWPort { get; set; }
|
|||
|
|
public string? ClientId { get; set; }
|
|||
|
|
public string? Connected { get; set; }
|
|||
|
|
public string? connected_DateTime { get; set; }
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public class QueryData
|
|||
|
|
{
|
|||
|
|
public int Limit { get; set; }
|
|||
|
|
public int Page { get; set; }
|
|||
|
|
}
|
|||
|
|
public class RMsg
|
|||
|
|
{
|
|||
|
|
public string message { get; set; }
|
|||
|
|
public bool isok { get; set; }
|
|||
|
|
}
|
|||
|
|
public class Data
|
|||
|
|
{
|
|||
|
|
public string? Cmd { get; set; }
|
|||
|
|
public SendData? Parameterlist { get; set; }
|
|||
|
|
}
|
|||
|
|
public class SendData
|
|||
|
|
{
|
|||
|
|
public string? endpoint { get; set; }
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 设备序号
|
|||
|
|
/// </summary>
|
|||
|
|
public string? device_clientid { get; set; }
|
|||
|
|
public string? command_word { get; set; }
|
|||
|
|
public string? data { get; set; }
|
|||
|
|
}
|
|||
|
|
}
|