添加http连接功能
This commit is contained in:
Administrator committed
commit
cd7a6df16c
7 files changed
+248
-6
No files matched your search
@@ -0,0 +1,105 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Text;
|
||||
using SunlightAggregationTerminal.Models;
|
||||
using System.Text.Json;
|
||||
using CommunityToolkit.Mvvm.Messaging;
|
||||
|
||||
namespace SunlightAggregationTerminal.Class
|
||||
{
|
||||
public class DataReceived
|
||||
{
|
||||
public static void Received(string dat)
|
||||
{
|
||||
try
|
||||
{
|
||||
var data = JsonSerializer.Deserialize<Dictionary<string, object>>(dat);
|
||||
|
||||
if (data != null)
|
||||
{
|
||||
//处理服务器发送信息
|
||||
if (data.TryGetValue("Enterprise", out var val) && val != null) App.GlobalData.Enterprise = val.ToString() ?? "";
|
||||
if (data.TryGetValue("Department", out val) && val != null) App.GlobalData.Department = val.ToString() ?? "";
|
||||
if (data.TryGetValue("Groups", out val) && val != null) App.GlobalData.Groups = val.ToString() ?? "";
|
||||
if (data.TryGetValue("UserName", out val) && val != null) App.GlobalData.UserName = val.ToString() ?? "";
|
||||
if (data.TryGetValue("UserId", out val) && val != null)
|
||||
{
|
||||
App.GlobalData.UserId = val.ToString() ?? "";
|
||||
App.GlobalData.LogNo = true;
|
||||
|
||||
HttpServer.HttpTransmit("{\"Command\":\"Info\"}");
|
||||
}
|
||||
|
||||
if (data.TryGetValue("UserData", out var value_UserData))
|
||||
{
|
||||
|
||||
}
|
||||
if (data.TryGetValue("SysData", out var value_SysData))
|
||||
{
|
||||
|
||||
}
|
||||
|
||||
if (data.TryGetValue("Info", out val) && val != null)//机台信息接受
|
||||
{
|
||||
DataModel.Info_data = JsonSerializer.Deserialize<List<Dictionary<string, object>>>(val.ToString()!)!;
|
||||
//发送消息
|
||||
WeakReferenceMessenger.Default.Send(new object());
|
||||
}
|
||||
if (data.TryGetValue("Query", out val) && val != null)//查询接受
|
||||
{
|
||||
QueryPage.Query_data(val.ToString()!);
|
||||
}
|
||||
if (data.TryGetValue("QueryDetail", out val) && val != null)//查询接受
|
||||
{
|
||||
QueryDetail.Query_data(val.ToString()!);
|
||||
}
|
||||
if (data.TryGetValue("Notification", out val) && val != null)//信息通知接受
|
||||
{
|
||||
var dataNotification = JsonSerializer.Deserialize<Dictionary<string, object>>(val.ToString()!);
|
||||
|
||||
string _Title = "", _Content = "";
|
||||
int _Type = 0;
|
||||
|
||||
if (dataNotification!.TryGetValue("Title", out var value_Notification_Title))
|
||||
{
|
||||
_Title = value_Notification_Title.ToString() ?? "";
|
||||
}
|
||||
if (dataNotification!.TryGetValue("Content", out var value_Notification_Content))
|
||||
{
|
||||
_Content = value_Notification_Content.ToString() ?? "";
|
||||
}
|
||||
if (dataNotification!.TryGetValue("Type", out var value_Notification_Type))
|
||||
{
|
||||
string temp = value_Notification_Type?.ToString() ?? "";
|
||||
// 转换
|
||||
_Type = temp switch
|
||||
{
|
||||
"System" => 2,
|
||||
"Message" => 1,
|
||||
_ => 0
|
||||
};
|
||||
}
|
||||
|
||||
Models.AppModels.INSERT("INSERT INTO Notification (Title,Content,Time,Type)VALUES('" +
|
||||
_Title + "','" + _Content + "','" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "','" + _Type + "');");
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
MainThread.BeginInvokeOnMainThread(() =>
|
||||
{
|
||||
Application.Current!.Windows[0].Page!.DisplayAlertAsync("", ex.Message.ToString(), "是");
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
public static void Transmit(string Dat)
|
||||
{
|
||||
if (App.GlobalData.LocalAreaNetworkMode)
|
||||
{ TcpServer.TcpTransmit(Dat); }
|
||||
else { HttpServer.HttpTransmit(Dat); }
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,125 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Net.Sockets;
|
||||
using System.Text;
|
||||
using System.Text.Json;
|
||||
using TouchSocket.Core;
|
||||
using TouchSocket.Http;
|
||||
using TouchSocket.Http.WebSockets;
|
||||
using TouchSocket.Sockets;
|
||||
using static SunlightAggregationTerminal.Class.TcpServer;
|
||||
|
||||
namespace SunlightAggregationTerminal.Class
|
||||
{
|
||||
public class HttpServer
|
||||
{
|
||||
public static TouchSocket.Http.HttpClient httpclient = new TouchSocket.Http.HttpClient();
|
||||
|
||||
public static async void Configuration(string ip, string Name, string Password, string Terminal)
|
||||
{
|
||||
ServerIP = ip;
|
||||
ServerName = Name;
|
||||
ServerPassword = Password;
|
||||
ServerTerminal = Terminal;
|
||||
|
||||
await HttpClient("127.0.0.1:7791");
|
||||
}
|
||||
|
||||
public static async Task HttpClient(string url)
|
||||
{
|
||||
var config = new TouchSocketConfig();
|
||||
#region Http设置远程服务器地址
|
||||
config.SetRemoteIPHost("http://" + url);
|
||||
#endregion
|
||||
|
||||
#region Http客户端获取断线通知
|
||||
config.ConfigurePlugins(a =>
|
||||
{
|
||||
a.AddTcpClosedPlugin(async (c, e) =>
|
||||
{
|
||||
// 专门处理超时或主动取消的情况
|
||||
MainThread.BeginInvokeOnMainThread(() =>
|
||||
{
|
||||
Application.Current!.Windows[0].Page!.DisplayAlertAsync("", "客户端断开连接", "是");
|
||||
});
|
||||
await e.InvokeNext();
|
||||
});
|
||||
}); config.ConfigurePlugins(a =>
|
||||
{
|
||||
a.AddTcpConnectedPlugin(async (c, e) =>
|
||||
{
|
||||
HttpTransmit("{\"Command\":\"Log\"}");
|
||||
await e.InvokeNext();
|
||||
});
|
||||
});
|
||||
config.ConfigurePlugins(a =>
|
||||
{
|
||||
a.UseReconnection<TouchSocket.Http.HttpClient>(options =>
|
||||
{
|
||||
options.PollingInterval = TimeSpan.FromSeconds(3);
|
||||
});
|
||||
});
|
||||
#endregion
|
||||
|
||||
//配置config
|
||||
await httpclient.SetupAsync(config);
|
||||
//连接
|
||||
await httpclient.ConnectAsync();
|
||||
}
|
||||
|
||||
/***发送信息处理***/
|
||||
public static async void HttpTransmit(string Dat)
|
||||
{
|
||||
var dat = new Person()
|
||||
{
|
||||
User = ServerName,
|
||||
Password = ServerPassword,
|
||||
IP = GetLocalIpSimple(),
|
||||
Terminal = ServerTerminal,
|
||||
Dat = Dat
|
||||
};
|
||||
|
||||
var t = JsonSerializer.Serialize(dat);
|
||||
var p = httpclient.RemoteIPHost.Host;
|
||||
|
||||
var request = new HttpRequest();
|
||||
request.SetContent(new StringHttpContent(t, Encoding.UTF8, "application/scjson"))
|
||||
.InitHeaders()
|
||||
.SetUrl("/api/user-report")
|
||||
.SetHost(p)
|
||||
.AsPost();
|
||||
|
||||
// 创建一个超时操作，10秒后取消
|
||||
using var cts = new CancellationTokenSource(1000 * 15);
|
||||
try
|
||||
{
|
||||
using (var responseResult = await httpclient.RequestAsync(request, cts.Token))
|
||||
{
|
||||
var response = responseResult.Response;
|
||||
// GetBodyAsync 同样需要响应取消信号，如果这里超过剩余时间也会抛出异常
|
||||
var result = await response.GetBodyAsync();
|
||||
DataReceived.Received(result);
|
||||
}
|
||||
}
|
||||
catch (OperationCanceledException)
|
||||
{
|
||||
// 专门处理超时或主动取消的情况
|
||||
MainThread.BeginInvokeOnMainThread(() =>
|
||||
{
|
||||
Application.Current!.Windows[0].Page!.DisplayAlertAsync("网络错误", "网络请求超时，请检查网络或服务器状态。", "是");
|
||||
});
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
MainThread.BeginInvokeOnMainThread(() =>
|
||||
{
|
||||
Application.Current!.Windows[0].Page!.DisplayAlertAsync("网络错误", ex.Message.ToString(), "是");
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
}
|
||||
Reference in new issue
Block a user