You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
344 lines
16 KiB
344 lines
16 KiB
using DyeingComputer.UserClass;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Linq;
|
|
using System.Net;
|
|
using System.Net.Http;
|
|
using System.Net.Sockets;
|
|
using System.Reflection.Emit;
|
|
using System.Text;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using System.Diagnostics;
|
|
using TouchSocket.Core;
|
|
using TouchSocket.Sockets;
|
|
using DyeingComputer.ViewModel;
|
|
using System.Runtime.InteropServices;
|
|
using ScottPlot.Colormaps;
|
|
using static System.Windows.Forms.AxHost;
|
|
using static System.Windows.Forms.VisualStyles.VisualStyleElement.TaskbarClock;
|
|
using static System.Windows.Forms.VisualStyles.VisualStyleElement;
|
|
using Newtonsoft.Json;
|
|
using static DyeingComputer.UserClass.SqliteHelper;
|
|
using DyeingComputer.View;
|
|
|
|
namespace DyeingComputer.UserClass
|
|
{/// <summary>
|
|
/// 异步TCP服务器
|
|
/// </summary>
|
|
public class AsyncTcpServer
|
|
{
|
|
//设置系统时间的API函数
|
|
[DllImport("kernel32.dll")]
|
|
private static extern bool SetLocalTime(ref SYSTEMTIME time);
|
|
[StructLayout(LayoutKind.Sequential)]
|
|
private struct SYSTEMTIME
|
|
{
|
|
public short year;
|
|
public short month;
|
|
public short dayOfWeek;
|
|
public short day;
|
|
public short hour;
|
|
public short minute;
|
|
public short second;
|
|
public short milliseconds;
|
|
}
|
|
/// <summary>
|
|
/// 设置系统时间
|
|
/// </summary>
|
|
/// <param name="dt">需要设置的时间</param>
|
|
/// <returns>返回系统时间设置状态，true为成功，false为失败</returns>
|
|
private static bool SetLocalDateTime(DateTime dt)
|
|
{
|
|
SYSTEMTIME st;
|
|
st.year = (short)dt.Year;
|
|
st.month = (short)dt.Month;
|
|
st.dayOfWeek = (short)dt.DayOfWeek;
|
|
st.day = (short)dt.Day;
|
|
st.hour = (short)dt.Hour;
|
|
st.minute = (short)dt.Minute;
|
|
st.second = (short)dt.Second;
|
|
st.milliseconds = (short)dt.Millisecond;
|
|
bool rt = SetLocalTime(ref st);
|
|
return rt;
|
|
}
|
|
|
|
public static async Task Main()
|
|
{
|
|
NetFwManger.AllowPort(7790,"TCP");//开放7790端口
|
|
TcpService service = new TcpService();
|
|
service.Connecting = (client, e) => { return EasyTask.CompletedTask; };//有客户端正在连接
|
|
service.Connected = (client, e) => { return EasyTask.CompletedTask; };//有客户端成功连接
|
|
service.Closing = (client, e) => { return EasyTask.CompletedTask; };//有客户端正在断开连接，只有当主动断开时才有效。
|
|
service.Closed = (client, e) => { return EasyTask.CompletedTask; };//有客户端断开连接
|
|
service.Received = (client, e) =>
|
|
{
|
|
string SYSAPI = e.ByteBlock.Span.ToString(Encoding.ASCII).Substring(0,5);
|
|
string DAT = e.ByteBlock.Span.ToString(Encoding.ASCII).Substring(5);
|
|
string SYSDAT ="";// = e.ByteBlock.Span.ToString(Encoding.ASCII).Substring(5);
|
|
string SYSKEY ="";
|
|
if(DAT.Length>=16) SYSKEY = DAT.Substring(0,16);
|
|
if (DAT.Length > 16) SYSDAT = DAT.Substring(16);
|
|
//LogGing.LogSQLDATA("800", "TcpServer", "API:"+ SYSAPI);
|
|
if (SYSAPI == "SC800")
|
|
{
|
|
Dictionary<string, object> Chart_new = new Dictionary<string, object>();//缓存函数
|
|
Chart_new.Add("MACHINE", MainWindowViewModel.S01);
|
|
Chart_new.Add("GROUP", MainWindowViewModel.S05);
|
|
Chart_new.Add("SYSKEY", MainWindowViewModel.SYSKEY);
|
|
Chart_new.Add("TIME", MainWindowViewModel.SYSTime);
|
|
client.SendAsync("[" + MainWindowViewModel.S01 + "]" +"SC800"+ Chart_new.ToJsonString());
|
|
}
|
|
else if (SYSAPI == "SC810")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
Dictionary<string, object> WorkOrder_dat;
|
|
WorkOrder_dat = SerializeConvert.JsonDeserializeFromString<Dictionary<string, object>>(SYSDAT);
|
|
//WorkOrder_dat.GetValue("WorkOrder");
|
|
bool dat_w= SQLDATA.WorkOrder(
|
|
WorkOrder_dat.GetValue("WorkOrder").ToString(),
|
|
WorkOrder_dat.GetValue("ProcessName").ToString(),
|
|
WorkOrder_dat.GetValue("StartTime").ToString(),
|
|
WorkOrder_dat.GetValue("EndTime").ToString(),
|
|
WorkOrder_dat.GetValue("Time").ToString(),
|
|
WorkOrder_dat.GetValue("Remark").ToString(),
|
|
WorkOrder_dat.GetValue("lock").ToString(),
|
|
WorkOrder_dat.GetValue("State").ToString(),
|
|
WorkOrder_dat.GetValue("ProcessID").ToString());
|
|
if (!dat_w) { client.SendAsync("SC910"); }
|
|
else { client.SendAsync("SC810" + SYSKEY +SYSDAT); }
|
|
}
|
|
catch
|
|
{
|
|
client.SendAsync("SC990");
|
|
}
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//WorkOrder表信息检查写入
|
|
else if (SYSAPI == "SC811")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
DataTable WorkOrder_dat;
|
|
WorkOrder_dat = SerializeConvert.JsonDeserializeFromString<DataTable>(SYSDAT);
|
|
bool dat_w = SQLDATA.WorkOderStep(WorkOrder_dat);
|
|
if (!dat_w) { client.SendAsync("SC911"); }
|
|
else { client.SendAsync("SC811" + SYSKEY + SYSDAT); }
|
|
}
|
|
catch
|
|
{
|
|
client.SendAsync("SC991");
|
|
}
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//WorkOrderstep表信息检查写入
|
|
else if (SYSAPI == "SC820")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
if (SYSDAT.Length == 21)
|
|
{
|
|
SYSDAT = SYSDAT.Substring(1, 19);
|
|
DateTime dt;
|
|
if (DateTime.TryParse(SYSDAT, out dt))
|
|
SetLocalDateTime(dt);
|
|
}
|
|
client.SendAsync("SC820" + "[" + DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss") + "]");
|
|
}
|
|
catch { client.SendAsync("SC920"); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//设置系统时间
|
|
else if (SYSAPI == "SC821")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
Dictionary<string, object> dat_821;
|
|
dat_821 = SerializeConvert.JsonDeserializeFromString<Dictionary<string, object>>(SYSDAT);
|
|
if (dat_821.GetValue("INSTRUCTION").ToString() == "START")
|
|
{
|
|
SQLDATA.TechnologicalProcess_START(dat_821.GetValue("ProgramID").ToString());
|
|
}
|
|
else if (dat_821.GetValue("INSTRUCTION").ToString() == "STOP")
|
|
{
|
|
MainWindowViewModel.WORK_RUN = 0;//停止
|
|
MainWindowViewModel.DIDETime = 0;
|
|
}
|
|
else if (dat_821.GetValue("INSTRUCTION").ToString() == "PAUSE")
|
|
{
|
|
MainWindowViewModel.WORK_RUN = 1;//暂停
|
|
}
|
|
else if (dat_821.GetValue("INSTRUCTION").ToString() == "CONTINUE")
|
|
{
|
|
MainWindowViewModel.WORK_RUN = 2;//暂停
|
|
}
|
|
else if (dat_821.GetValue("INSTRUCTION").ToString() == "JUMP")
|
|
{
|
|
MainWindowViewModel.RUN_DATATABLE = TechnologicalProcessView.sql.Tables[0];//缓存表
|
|
MainWindowViewModel.RUN_STEPID = Convert.ToInt16(dat_821.GetValue("ID").ToString());//插入步骤号
|
|
MainWindowViewModel.STEP_START(dat_821.GetValue("Numder").ToString(), Convert.ToDouble(dat_821.GetValue("P1")),
|
|
Convert.ToDouble(dat_821.GetValue("P2")), Convert.ToDouble(dat_821.GetValue("P3")),
|
|
Convert.ToDouble(dat_821.GetValue("P4")), Convert.ToDouble(dat_821.GetValue("P5")));
|
|
}
|
|
client.SendAsync("SC821" + SYSKEY + SYSDAT);
|
|
}
|
|
catch { client.SendAsync("SC921"); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//启停跳步指令
|
|
else if (SYSAPI == "SC830")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
Dictionary<string, object> Chart_new = new Dictionary<string, object>();//缓存函数
|
|
Chart_new.Add("DYELOT", MainWindowViewModel.WorkNumder);
|
|
Chart_new.Add("Time", MainWindowViewModel.SYSTime);
|
|
Chart_new.Add("MST", MainWindowViewModel.TEMP_co);
|
|
Chart_new.Add("MTT", MainWindowViewModel.Selet_dtm("1010"));
|
|
Chart_new.Add("MTL", MainWindowViewModel.Selet_dtm("1015"));
|
|
Chart_new.Add("MTH", MainWindowViewModel.Selet_dtm("1009"));
|
|
Chart_new.Add("MUT", MainWindowViewModel.Selet_dtm("1011"));
|
|
Chart_new.Add("STTA", MainWindowViewModel.Selet_dtm("1012"));
|
|
Chart_new.Add("STLA", MainWindowViewModel.Selet_dtm("1017"));
|
|
Chart_new.Add("STTB", MainWindowViewModel.Selet_dtm("1013"));
|
|
Chart_new.Add("STLB", MainWindowViewModel.Selet_dtm("1018"));
|
|
Chart_new.Add("STTC", MainWindowViewModel.Selet_dtm("1014"));
|
|
Chart_new.Add("STLC", MainWindowViewModel.Selet_dtm("1019"));
|
|
client.SendAsync("SC830" + "[" + MainWindowViewModel.S01 + "]" + Chart_new.ToJsonString());
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//当前信息
|
|
else if (SYSAPI == "SC831")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
|
|
client.SendAsync("SC831" + "[" + MainWindowViewModel.S01 + "]" +TechnologicalProcessView.sql.Tables[0].ToJsonString());
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//当前工作表
|
|
else if (SYSAPI == "SC832")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
|
|
client.SendAsync("SC832" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.SYSlog);
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//当前细节信息
|
|
else if (SYSAPI == "SC851")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
client.SendAsync("SC851" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.dt_d.ToJsonString());//数字开关信息
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//数字开关表
|
|
else if (SYSAPI == "SC852")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
client.SendAsync("SC852" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.dt_a.ToJsonString());//寄存器信息
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//寄存器表
|
|
else if (SYSAPI == "SC853")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
client.SendAsync("SC853" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.dt_m.ToJsonString());//缓存信息
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//缓存表
|
|
|
|
return EasyTask.CompletedTask;
|
|
};
|
|
|
|
await service.SetupAsync(new TouchSocketConfig()//载入配置
|
|
.SetListenIPHosts(new IPHost[] { new IPHost("tcp://127.0.0.1:7789"), new IPHost(7790) })//同时监听两个地址
|
|
.ConfigureContainer(a =>//容器的配置顺序应该在最前面
|
|
{
|
|
//a.AddConsoleLogger();//添加一个控制台日志注入（注意：在maui中控制台日志不可用）
|
|
})
|
|
.ConfigurePlugins(a =>
|
|
{
|
|
//a.Add<DifferentProtocolPlugin>();
|
|
})
|
|
);
|
|
await service.StartAsync();//启动
|
|
|
|
LogGing.LogGingDATA("800SREVER:START");
|
|
}
|
|
}
|
|
|
|
class MyTcpService : TcpService<MyTcpSessionClient>
|
|
{
|
|
protected override MyTcpSessionClient NewClient()
|
|
{
|
|
return new MyTcpSessionClient();
|
|
}
|
|
}
|
|
|
|
class MyTcpSessionClient : TcpSessionClient
|
|
{
|
|
internal void SetDataHandlingAdapter(SingleStreamDataHandlingAdapter adapter)
|
|
{
|
|
base.SetAdapter(adapter);
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 此插件实现，按照不同端口，使用不同适配器。
|
|
/// <list type="bullet">
|
|
/// <item>7789端口:使用"**"结尾的数据</item>
|
|
/// <item>7790端口:使用"##"结尾的数据</item>
|
|
/// </list>
|
|
/// </summary>
|
|
internal class DifferentProtocolPlugin : PluginBase, ITcpConnectingPlugin, ITcpReceivedPlugin
|
|
{
|
|
public async Task OnTcpConnecting(ITcpSession client, ConnectingEventArgs e)
|
|
{
|
|
if (client is MyTcpSessionClient sessionClient)
|
|
{
|
|
if (sessionClient.ServicePort == 7789)
|
|
{
|
|
sessionClient.SetDataHandlingAdapter(new TerminatorPackageAdapter("**"));
|
|
}
|
|
else
|
|
{
|
|
sessionClient.SetDataHandlingAdapter(new TerminatorPackageAdapter("##"));
|
|
}
|
|
}
|
|
|
|
await e.InvokeNext();
|
|
}
|
|
|
|
public async Task OnTcpReceived(ITcpSession client, ReceivedDataEventArgs e)
|
|
{
|
|
//如果是自定义适配器，此处解析时，可以判断e.RequestInfo的类型
|
|
|
|
if (client is ITcpSessionClient sessionClient)
|
|
{
|
|
sessionClient.Logger.Info($"{sessionClient.GetIPPort()}收到数据，服务器端口：{sessionClient.ServicePort},数据：{e.ByteBlock}");
|
|
}
|
|
|
|
await e.InvokeNext();
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|