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.
976 lines
60 KiB
976 lines
60 KiB
using DyeingComputer.UserClass;
|
|
using DyeingComputer.View;
|
|
using DyeingComputer.ViewModel;
|
|
using Newtonsoft.Json;
|
|
using System;
|
|
using System.Collections;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Diagnostics;
|
|
using System.Linq;
|
|
using System.Net;
|
|
using System.Net.Http;
|
|
using System.Net.Sockets;
|
|
using System.Reflection.Emit;
|
|
using System.Runtime.InteropServices;
|
|
using System.Text;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using System.Windows;
|
|
using System.Windows.Controls;
|
|
using TouchSocket.Core;
|
|
using TouchSocket.Sockets;
|
|
using static DyeingComputer.UserClass.SqliteHelper;
|
|
using static System.Net.WebRequestMethods;
|
|
using static System.Windows.Forms.AxHost;
|
|
using static System.Windows.Forms.VisualStyles.VisualStyleElement;
|
|
using static System.Windows.Forms.VisualStyles.VisualStyleElement.Button;
|
|
using static System.Windows.Forms.VisualStyles.VisualStyleElement.TaskbarClock;
|
|
|
|
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 string[] Prohibit = new string[10] { "S01", "S02", "S03", "S05", "S06", "S07", "SL1", "SL2", "SL3", ""};//禁止操作的指令
|
|
// public static SQLiteHelper SQLiteHelpers = null; //定义数据库
|
|
// public static readonly string DBAddress = Environment.CurrentDirectory + "\\DataBase\\800COMPUTER.db"; //数据库路径
|
|
public static async Task Main()
|
|
{
|
|
NetFwManger.AllowPort(7789, "TCP");//开放7790端口
|
|
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) =>
|
|
{
|
|
MainWindowViewModel.RX++;
|
|
string SYSAPI = e.ByteBlock.Span.ToString(Encoding.ASCII).Substring(0,5);
|
|
string DAT = e.ByteBlock.Span.ToString(Encoding.UTF8).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("SC800" + "[" + MainWindowViewModel.S01 + "]" + Chart_new.ToJsonString());
|
|
MainWindowViewModel.TX++;
|
|
APILog.DBlog(client.IP,SYSKEY,SYSAPI,SYSDAT);//记录指令
|
|
}
|
|
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");
|
|
|
|
object i = MainWindow.SQLiteHelpers.ExecuteScalar("select * from WorkOrder where WorkOrder = " + WorkOrder_dat.GetValue("WorkOrder").ToString(), null);
|
|
Dictionary<string, object> Step_new = new Dictionary<string, object>();//缓存函数
|
|
Step_new.Add("WorkOrder", WorkOrder_dat.GetValue("WorkOrder").ToString());
|
|
Step_new.Add("ReDye", WorkOrder_dat.GetValue("ReDye").ToString());
|
|
if (i != null)
|
|
{
|
|
client.SendAsync("SC910" + "[" + MainWindowViewModel.S01 + "]" + Step_new.ToJsonString());
|
|
}
|
|
else
|
|
{
|
|
client.SendAsync("SC810" + "[" + MainWindowViewModel.S01 + "]" + Step_new.ToJsonString());
|
|
MainWindowViewModel.TX++;
|
|
}
|
|
|
|
MainWindow.SQLiteHelpers.InsertData("WorkOrder", WorkOrder_dat);
|
|
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
client.SendAsync("SC990" + "[" + MainWindowViewModel.S01 + "]" + ex);
|
|
}
|
|
}
|
|
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);
|
|
Dictionary<string, object> Step_new = new Dictionary<string, object>();//缓存函数
|
|
Step_new.Add("WorkOrder", WorkOrder_dat.Select().First().Field<object>("WorkOrder"));
|
|
Step_new.Add("ReDye", WorkOrder_dat.Select().First().Field<object>("ReDye"));
|
|
if (!dat_w)
|
|
{
|
|
client.SendAsync("SC911" + "[" + MainWindowViewModel.S01 + "]" + Step_new.ToJsonString());
|
|
}
|
|
else
|
|
{
|
|
client.SendAsync("SC811" + "[" + MainWindowViewModel.S01 + "]" + Step_new.ToJsonString());
|
|
MainWindowViewModel.TX++;
|
|
}
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
client.SendAsync("SC991" + "[" + MainWindowViewModel.S01 + "]" + ex);
|
|
}
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//WorkOrderstep表信息检查写入
|
|
else if (SYSAPI == "SC812")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
Dictionary<string, object> WorkOrder_dat;
|
|
WorkOrder_dat = SerializeConvert.JsonDeserializeFromString<Dictionary<string, object>>(SYSDAT);
|
|
MainWindow.SQLiteHelpers.InsertData("WorkorderSet", WorkOrder_dat);//行插入
|
|
|
|
Dictionary<string, object> Step_new = new Dictionary<string, object>();//缓存函数
|
|
Step_new.Add("WorkOrder", WorkOrder_dat.GetValue("WorkOrder").ToString());
|
|
Step_new.Add("ReDye", WorkOrder_dat.GetValue("ReDye").ToString());
|
|
|
|
client.SendAsync("SC812" + "[" + MainWindowViewModel.S01 + "]" + Step_new.ToJsonString());
|
|
MainWindowViewModel.TX++;
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
client.SendAsync("SC992" + "[" + MainWindowViewModel.S01 + "]" + ex);
|
|
}
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//WorkOrderset表信息检查写入
|
|
else if (SYSAPI == "SC813")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
DataTable Dyelot_dat;
|
|
Dyelot_dat = SerializeConvert.JsonDeserializeFromString<DataTable>(SYSDAT);
|
|
bool dat_w = SQLDATA.Dyelot(Dyelot_dat);
|
|
if (!dat_w)
|
|
{
|
|
client.SendAsync("SC913" + "[" + MainWindowViewModel.S01 + "]" +
|
|
Dyelot_dat.Select().First().Field<object>("Dyelot"));
|
|
}
|
|
else
|
|
{
|
|
client.SendAsync("SC813" + "[" + MainWindowViewModel.S01 + "]" +
|
|
Dyelot_dat.Select().First().Field<object>("Dyelot"));
|
|
MainWindowViewModel.TX++;
|
|
}
|
|
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC993" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//写入领料单
|
|
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") + "]");
|
|
MainWindowViewModel.TX++;
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC920" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
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")
|
|
{
|
|
MainWindowViewModel.Dyelot_dat = MainWindow.SQLiteHelpers.ExecuteDataSet("select * from Dyelot where ReDye=0 AND WorkOrder = '" +
|
|
dat_821.GetValue("WorkOrder").ToString() + "'", null).Tables[0];
|
|
var DT_Set = MainWindow.SQLiteHelpers.ExecuteDataSet("select * from WorkOrderSet where WorkOrder = '" +
|
|
dat_821.GetValue("WorkOrder").ToString() + "'", null).Tables[0].Rows[0];
|
|
MainWindowViewModel.Updata_dtm("1020", DT_Set.Field<int>("PumpSpeed"));
|
|
MainWindowViewModel.Updata_dtm("1030", DT_Set.Field<int>("Swing"));
|
|
MainWindowViewModel.Updata_dtm("1021", DT_Set.Field<int>("Blower"));
|
|
MainWindowViewModel.Updata_dtm("1025", DT_Set.Field<int>("ClothWheel"));
|
|
MainWindowViewModel.Updata_dtm("1026", DT_Set.Field<int>("ClothWheel"));
|
|
MainWindowViewModel.Updata_dtm("1027", DT_Set.Field<int>("ClothWheel"));
|
|
MainWindowViewModel.Updata_dtm("1028", DT_Set.Field<int>("ClothWheel"));
|
|
MainWindowViewModel.Updata_dtm("1029", DT_Set.Field<int>("ClothWheel"));
|
|
MainWindowViewModel.Updata_dtm("1035", DT_Set.Field<int>("ClothWheel"));
|
|
MainWindowViewModel.Updata_dtm("1036", DT_Set.Field<int>("ClothWheel"));
|
|
MainWindowViewModel.Updata_dtm("1037", DT_Set.Field<int>("ClothWheel"));
|
|
MainWindowViewModel.Updata_dtm("1038", DT_Set.Field<int>("ClothWheel"));
|
|
MainWindowViewModel.Updata_dtm("1039", DT_Set.Field<int>("ClothWheel"));
|
|
MainWindowViewModel.Updata_dtm("1040", DT_Set.Field<int>("ClothWheel"));
|
|
MainWindowViewModel.Updata_dtm("1041", DT_Set.Field<int>("ClothWheel"));
|
|
DataTable WorkorderSteps = MainWindow.SQLiteHelpers.ExecuteDataSet(
|
|
"select * from WorkorderSteps where ReDye=0 AND WorkOrder='" + dat_821.GetValue("WorkOrder").ToString() + "'", null).Tables[0]; //读取表写入缓存
|
|
DataTable Workorder = MainWindow.SQLiteHelpers.ExecuteDataSet(
|
|
"select * from Workorder where ReDye=0 AND WorkOrder='" + dat_821.GetValue("WorkOrder").ToString() + "'", null).Tables[0]; //读取表写入缓存
|
|
MainWindowViewModel.ProgramName = Workorder.Rows[0].Field<string>("ProgramName");
|
|
MainWindowViewModel.WorkNumder = Workorder.Rows[0].Field<string>("WorkOrder");
|
|
MainWindow.SQLiteHelpers.Delete("RUN", null, null); //删除run信息
|
|
for (int i = 0; i < WorkorderSteps.Rows.Count; i++)
|
|
{
|
|
DataRow dr = WorkorderSteps.Rows[i];//行转
|
|
|
|
MainWindow.SQLiteHelpers.InsertData("RUN", MainWindow.SQLiteHelpers.ToDictionary(dr));//行插入
|
|
}
|
|
Dictionary<string, object> updata_temp = new Dictionary<string, object>();//缓存函数
|
|
updata_temp.Add("State", 205);
|
|
MainWindow.SQLiteHelpers.Update("WorkOrder", updata_temp, "WorkOrder='" + dat_821.GetValue("WorkOrder").ToString() + "'", null);
|
|
updata_temp.Clear(); //使用前清缓存
|
|
updata_temp.Add("RUN", 1);
|
|
MainWindow.SQLiteHelpers.Update("RUN", updata_temp, "Step=1", null);
|
|
//SQLiteHelpers.Close(); //关闭连接
|
|
|
|
/*触发启动*/
|
|
string Numder = WorkorderSteps.Select("Step = 1").First().Field<string>("StepID");//
|
|
double P1 = WorkorderSteps.Select("Step = 1").First().Field<double>("Parameter1");
|
|
double P2 = WorkorderSteps.Select("Step = 1").First().Field<double>("Parameter2");
|
|
double P3 = WorkorderSteps.Select("Step = 1").First().Field<double>("Parameter3");
|
|
double P4 = WorkorderSteps.Select("Step = 1").First().Field<double>("Parameter4");
|
|
double P5 = WorkorderSteps.Select("Step = 1").First().Field<double>("Parameter5");
|
|
MainWindowViewModel.RUN_STEPID = Convert.ToInt16(1);//插入步骤号
|
|
MainWindowViewModel.STEP_START(Numder, Convert.ToDouble(P1), Convert.ToDouble(P2), Convert.ToDouble(P3),
|
|
Convert.ToDouble(P4), Convert.ToDouble(P5));
|
|
MainWindowViewModel.WORK_RUN = 2;
|
|
APILog.LOGlog(MainWindowViewModel.WorkNumder.ToString(), "CentralControl", "START", "STEP = " +
|
|
MainWindowViewModel.RUN_STEPID + ";StepID=" + Numder + ";P1=" + P1 + ";P2=" + P2 + ";P3=" + P3 + ";P4=" + P4 + ";P5=" + P5);
|
|
client.SendAsync("SC821" + SYSKEY + SYSDAT);
|
|
}
|
|
else if (dat_821.GetValue("INSTRUCTION").ToString() == "STOP")
|
|
{
|
|
MainWindowViewModel.WORK_RUN = 0;//停止
|
|
MainWindowViewModel.DIDETime = 0;
|
|
APILog.LOGlog(MainWindowViewModel.WorkNumder.ToString(), "CentralControl", "STOP", MainWindowViewModel.WorkNumder.ToString());
|
|
client.SendAsync("SC821" + SYSKEY + SYSDAT);
|
|
}//停止
|
|
else if (dat_821.GetValue("INSTRUCTION").ToString() == "PAUSE")
|
|
{
|
|
MainWindowViewModel.WORK_RUN = 1;//暂停
|
|
MainWindowViewModel.errTabler.Clear();
|
|
APILog.LOGlog(MainWindowViewModel.WorkNumder.ToString(), "CentralControl", "PAUSE", MainWindowViewModel.WorkNumder.ToString());
|
|
client.SendAsync("SC821" + SYSKEY + SYSDAT);
|
|
}//暂停
|
|
else if (dat_821.GetValue("INSTRUCTION").ToString() == "CONTINUE")
|
|
{
|
|
MainWindowViewModel.errTabler.Clear();
|
|
MainWindowViewModel.WORK_RUN = 2;//PAUSE
|
|
APILog.LOGlog(MainWindowViewModel.WorkNumder.ToString(), "CentralControl", "CONTINUE", MainWindowViewModel.WorkNumder.ToString());
|
|
client.SendAsync("SC821" + SYSKEY + SYSDAT);
|
|
}//运行
|
|
else if (dat_821.GetValue("INSTRUCTION").ToString() == "JUMP")
|
|
{
|
|
MainWindowViewModel.RUN_STEPID = Convert.ToInt16(dat_821.GetValue("ID"));//步骤号
|
|
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")));
|
|
APILog.LOGlog(MainWindowViewModel.WorkNumder.ToString(), "CentralControl", "JUMP", "STEP = " +
|
|
MainWindowViewModel.RUN_STEPID + ";"+dat_821.GetValue("Numder").ToString()+";P1="+
|
|
Convert.ToDouble(dat_821.GetValue("P1")) + ";P2=" + Convert.ToDouble(dat_821.GetValue("P2")) + ";P3=" +
|
|
Convert.ToDouble(dat_821.GetValue("P3")) + ";P4=" + Convert.ToDouble(dat_821.GetValue("P4")) + ";P5=" +
|
|
Convert.ToDouble(dat_821.GetValue("P5")));
|
|
}//跳步
|
|
else if (dat_821.GetValue("INSTRUCTION").ToString() == "INSERT")
|
|
{
|
|
int d = Convert.ToInt16(dat_821.GetValue("ID"));
|
|
//SQLiteHelpers = new SQLiteHelper(DBAddress); //数据库连接路径
|
|
//SQLiteHelpers.Open(); //打开数据库
|
|
/**插入行**/
|
|
string ProgramID = MainWindow.SQLiteHelpers.ExecuteScalar("select ProgramID from RUN where Step = '1'", null).ToString();
|
|
string ProgramNAME = MainWindow.SQLiteHelpers.ExecuteScalar("select Program from RUN where Step = '1'", null).ToString();
|
|
// TechnologicalProcessView.SQLiteHelpers.Close();
|
|
DataRow dr = MainWindowViewModel.dt_TP.NewRow();//添加表数据
|
|
dr["ProgramID"] = ProgramID;
|
|
dr["Program"] = ProgramNAME;
|
|
MainWindowViewModel.dt_TP.Rows.InsertAt(dr, d - 1);
|
|
/**编辑行号**/
|
|
TechnologicalProcessView.Dat();
|
|
/**编辑行信息**/
|
|
DataRow drtt = MainWindowViewModel.dt_TP.Rows[d - 1];
|
|
drtt.BeginEdit();
|
|
drtt["StepID"] = dat_821.GetValue("StepID").ToString();
|
|
drtt["StepName"] = dat_821.GetValue("StepName").ToString();
|
|
drtt["ParameterName"] = dat_821.GetValue("ParameterName").ToString();
|
|
drtt["Parameter1"] = dat_821.GetValue("Parameter1").ToString();
|
|
drtt["Parameter2"] = dat_821.GetValue("Parameter2").ToString();
|
|
drtt["Parameter3"] = dat_821.GetValue("Parameter3").ToString();
|
|
drtt["Parameter4"] = dat_821.GetValue("Parameter4").ToString();
|
|
drtt["Parameter5"] = dat_821.GetValue("Parameter5").ToString();
|
|
drtt["Parameter1_S1"] = dat_821.GetValue("Parameter1_S1").ToString();
|
|
drtt["Parameter2_S1"] = dat_821.GetValue("Parameter2_S1").ToString();
|
|
drtt["Parameter3_S1"] = dat_821.GetValue("Parameter3_S1").ToString();
|
|
drtt["Parameter4_S1"] = dat_821.GetValue("Parameter4_S1").ToString();
|
|
drtt["Parameter5_S1"] = dat_821.GetValue("Parameter5_S1").ToString();
|
|
drtt["Parameter1_S2"] = dat_821.GetValue("Parameter1_S2").ToString();
|
|
drtt["Parameter2_S2"] = dat_821.GetValue("Parameter2_S2").ToString();
|
|
drtt["Parameter3_S2"] = dat_821.GetValue("Parameter3_S2").ToString();
|
|
drtt["Parameter4_S2"] = dat_821.GetValue("Parameter4_S2").ToString();
|
|
drtt["Parameter5_S2"] = dat_821.GetValue("Parameter5_S2").ToString();
|
|
drtt["Parameter1_S3"] = dat_821.GetValue("Parameter1_S3").ToString();
|
|
drtt["Parameter2_S3"] = dat_821.GetValue("Parameter2_S3").ToString();
|
|
drtt["Parameter3_S3"] = dat_821.GetValue("Parameter3_S3").ToString();
|
|
drtt["Parameter4_S3"] = dat_821.GetValue("Parameter4_S3").ToString();
|
|
drtt["Parameter5_S3"] = dat_821.GetValue("Parameter5_S3").ToString();
|
|
drtt["StepName_S1"] = dat_821.GetValue("StepName_S1").ToString();
|
|
drtt["StepName_S2"] = dat_821.GetValue("StepName_S2").ToString();
|
|
drtt["StepName_S3"] = dat_821.GetValue("StepName_S3").ToString();
|
|
drtt["StepID_S1"] = dat_821.GetValue("StepID_S1").ToString();
|
|
drtt["StepID_S2"] = dat_821.GetValue("StepID_S2").ToString();
|
|
drtt["StepID_S3"] = dat_821.GetValue("StepID_S3").ToString();
|
|
drtt["RUN"] = "0";
|
|
drtt["DYELOT"] = MainWindowViewModel.WorkNumder;
|
|
drtt.EndEdit();
|
|
|
|
// var _TechnologicalProcessView = Application.Current.Windows.Cast<UserControl>().FirstOrDefault(window => window is TechnologicalProcessView) as TechnologicalProcessView;//跨页面
|
|
// _TechnologicalProcessView.Grid.ItemsSource = TechnologicalProcessView.sql.Tables[0].DefaultView;
|
|
//_TechnologicalProcessView.Grid.SelectedIndex = -1;
|
|
/**存入信息**/
|
|
/**存入信息**/
|
|
// SQLiteHelpers = new SQLiteHelper(DBAddress); //数据库连接路径
|
|
// SQLiteHelpers.Open(); //打开数据库
|
|
MainWindow.SQLiteHelpers.Delete("RUN", null, null);
|
|
for (int i = 0; i < MainWindowViewModel.dt_TP.Rows.Count; i++)
|
|
{
|
|
DataRow dt = MainWindowViewModel.dt_TP.Rows[i];//行转换
|
|
dt.BeginEdit(); //添加订单号
|
|
dt["DYELOT"] = MainWindowViewModel.WorkNumder;
|
|
dt.EndEdit();
|
|
|
|
MainWindow.SQLiteHelpers.InsertData("RUN", MainWindow.SQLiteHelpers.ToDictionary(dt));//行插入
|
|
}
|
|
//SQLiteHelpers.Close(); //关闭连接
|
|
APILog.LOGlog(MainWindowViewModel.WorkNumder.ToString(), "CentralControl", "INSERT", drtt.ToJsonString());
|
|
client.SendAsync("SC831" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.dt_TP.ToJsonString());
|
|
MainWindowViewModel.TX++;
|
|
}//插入
|
|
else if (dat_821.GetValue("INSTRUCTION").ToString() == "EDIT")
|
|
{
|
|
int n = Convert.ToInt16(dat_821.GetValue("ID").ToString());
|
|
/**编辑行信息**/
|
|
DataRow dr = MainWindowViewModel.dt_TP.Rows[n - 1];
|
|
dr.BeginEdit();
|
|
dr["StepID"] = dat_821.GetValue("StepID").ToString();
|
|
dr["StepName"] = dat_821.GetValue("StepName").ToString();
|
|
dr["ParameterName"] = dat_821.GetValue("ParameterName").ToString();
|
|
dr["Parameter1"] = dat_821.GetValue("Parameter1").ToString();
|
|
dr["Parameter2"] = dat_821.GetValue("Parameter2").ToString();
|
|
dr["Parameter3"] = dat_821.GetValue("Parameter3").ToString();
|
|
dr["Parameter4"] = dat_821.GetValue("Parameter4").ToString();
|
|
dr["Parameter5"] = dat_821.GetValue("Parameter5").ToString();
|
|
dr["Parameter1_S1"] = dat_821.GetValue("Parameter1_S1").ToString();
|
|
dr["Parameter2_S1"] = dat_821.GetValue("Parameter2_S1").ToString();
|
|
dr["Parameter3_S1"] = dat_821.GetValue("Parameter3_S1").ToString();
|
|
dr["Parameter4_S1"] = dat_821.GetValue("Parameter4_S1").ToString();
|
|
dr["Parameter5_S1"] = dat_821.GetValue("Parameter5_S1").ToString();
|
|
dr["Parameter1_S2"] = dat_821.GetValue("Parameter1_S2").ToString();
|
|
dr["Parameter2_S2"] = dat_821.GetValue("Parameter2_S2").ToString();
|
|
dr["Parameter3_S2"] = dat_821.GetValue("Parameter3_S2").ToString();
|
|
dr["Parameter4_S2"] = dat_821.GetValue("Parameter4_S2").ToString();
|
|
dr["Parameter5_S2"] = dat_821.GetValue("Parameter5_S2").ToString();
|
|
dr["Parameter1_S3"] = dat_821.GetValue("Parameter1_S3").ToString();
|
|
dr["Parameter2_S3"] = dat_821.GetValue("Parameter2_S3").ToString();
|
|
dr["Parameter3_S3"] = dat_821.GetValue("Parameter3_S3").ToString();
|
|
dr["Parameter4_S3"] = dat_821.GetValue("Parameter4_S3").ToString();
|
|
dr["Parameter5_S3"] = dat_821.GetValue("Parameter5_S3").ToString();
|
|
dr["StepName_S1"] = dat_821.GetValue("StepName_S1").ToString();
|
|
dr["StepName_S2"] = dat_821.GetValue("StepName_S2").ToString();
|
|
dr["StepName_S3"] = dat_821.GetValue("StepName_S3").ToString();
|
|
dr["StepID_S1"] = dat_821.GetValue("StepID_S1").ToString();
|
|
dr["StepID_S2"] = dat_821.GetValue("StepID_S2").ToString();
|
|
dr["StepID_S3"] = dat_821.GetValue("StepID_S3").ToString();
|
|
dr.EndEdit();
|
|
|
|
var _TechnologicalProcessView = Application.Current.Windows.Cast<UserControl>().FirstOrDefault(window => window is TechnologicalProcessView) as TechnologicalProcessView;//跨页面
|
|
// _TechnologicalProcessView.Grid.ItemsSource = TechnologicalProcessView.sql.Tables[0].DefaultView;
|
|
_TechnologicalProcessView.GridSTEP.SelectedIndex = -1;
|
|
/**存入信息**/
|
|
//SQLiteHelpers = new SQLiteHelper(DBAddress); //数据库连接路径
|
|
//SQLiteHelpers.Open(); //打开数据库
|
|
MainWindow.SQLiteHelpers.Delete("RUN", null, null);
|
|
DataTable data_t = MainWindowViewModel.dt_TP.Clone();
|
|
for (int i = 0; i < MainWindowViewModel.dt_TP.Rows.Count; i++)
|
|
{
|
|
DataRow dt = MainWindowViewModel.dt_TP.Rows[i];//行转换
|
|
dt.BeginEdit(); //添加订单号
|
|
dt["DYELOT"] = MainWindowViewModel.WorkNumder;
|
|
dt.EndEdit();
|
|
|
|
MainWindow.SQLiteHelpers.InsertData("RUN", MainWindow.SQLiteHelpers.ToDictionary(dt));//行插入
|
|
} //SQLiteHelpers.Close(); //关闭连接
|
|
APILog.LOGlog(MainWindowViewModel.WorkNumder.ToString(), "CentralControl", "EDIT", dr.ToJsonString());
|
|
client.SendAsync("SC831" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.dt_TP.ToJsonString());
|
|
MainWindowViewModel.TX++;
|
|
}//编辑
|
|
else if (dat_821.GetValue("INSTRUCTION").ToString() == "DELETE")
|
|
{
|
|
int d = Convert.ToInt16(dat_821.GetValue("ID"));
|
|
MainWindowViewModel.dt_TP.Rows.RemoveAt(d - 1);
|
|
TechnologicalProcessView.Dat();
|
|
/**存入信息**/
|
|
//SQLiteHelpers = new SQLiteHelper(DBAddress); //数据库连接路径
|
|
//SQLiteHelpers.Open(); //打开数据库
|
|
MainWindow.SQLiteHelpers.Delete("RUN", null, null);
|
|
DataTable data_t = MainWindowViewModel.dt_TP.Clone();
|
|
for (int i = 0; i < MainWindowViewModel.dt_TP.Rows.Count; i++)
|
|
{
|
|
DataRow dt = MainWindowViewModel.dt_TP.Rows[i];//行转换
|
|
dt.BeginEdit(); //添加订单号
|
|
dt["DYELOT"] = MainWindowViewModel.WorkNumder;
|
|
dt.EndEdit();
|
|
|
|
MainWindow.SQLiteHelpers.InsertData("RUN", MainWindow.SQLiteHelpers.ToDictionary(dt));//行插入
|
|
}
|
|
//SQLiteHelpers.Close(); //关闭连接
|
|
APILog.LOGlog(MainWindowViewModel.WorkNumder.ToString(), "CentralControl", "DELETE","ID="+ dat_821.GetValue("ID").ToString());
|
|
client.SendAsync("SC831" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.dt_TP.ToJsonString());
|
|
MainWindowViewModel.TX++;
|
|
}//删除
|
|
else
|
|
{
|
|
client.SendAsync("SC821" + SYSKEY + SYSDAT);
|
|
}
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC921" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//启停跳步指令
|
|
else if (SYSAPI == "SC822")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
DataTable Workorder = MainWindow.SQLiteHelpers.ExecuteDataSet(
|
|
"select * from Workorder where ReDye=0 AND State='101'AND StartTime >'"+
|
|
DateTime.Now.AddHours(-1).ToString("yyyy/MM/dd HH:mm:ss") +"'", null).Tables[0]; //读取表写入缓存
|
|
|
|
client.SendAsync("SC822" + "[" + MainWindowViewModel.S01 + "]" + Workorder.ToJsonString());
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC922" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//最近可用工艺
|
|
else if (SYSAPI == "SC827")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
// SQLiteHelpers = new SQLiteHelper(DBAddress); //数据库连接路径
|
|
// SQLiteHelpers.Open(); //打开数据库
|
|
string sql_script = "select * from Dyelot where State = '201' AND WorkOrder = '" +
|
|
MainWindowViewModel.WorkNumder + "'";
|
|
DataTable dt = MainWindow.SQLiteHelpers.ExecuteDataSet(sql_script, null).Tables[0]; //转换
|
|
//SQLiteHelpers.Close(); //关闭连接
|
|
|
|
client.SendAsync("SC827" + "[" + MainWindowViewModel.S01 + "]" + dt.ToJsonString());
|
|
MainWindowViewModel.TX++;
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC927" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//呼叫领料单
|
|
else if (SYSAPI == "SC828")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
Dictionary<string, object> Dyelot_dat;
|
|
Dyelot_dat = SerializeConvert.JsonDeserializeFromString<Dictionary<string, object>>(SYSDAT);
|
|
|
|
// SQLiteHelpers = new SQLiteHelper(DBAddress); //数据库连接路径
|
|
// SQLiteHelpers.Open(); //打开数据库
|
|
Dictionary<string, object> Product_data = new Dictionary<string, object>();//缓存函数
|
|
|
|
Product_data.Add("State", Dyelot_dat.GetValue("State"));
|
|
if (Dyelot_dat.GetValue("State").ToString() == "301")
|
|
{
|
|
Product_data.Add("Amount", Dyelot_dat.GetValue("Amount"));
|
|
Product_data.Add("DispenseEndTime", Dyelot_dat.GetValue("DispenseEndTime"));
|
|
}
|
|
MainWindow.SQLiteHelpers.Update("Dyelot", Product_data, "Dyelot ='" + Dyelot_dat.GetValue("Dyelot")
|
|
+ "' AND Step ='" + Dyelot_dat.GetValue("Step") + "' AND ProductCode='" +
|
|
Dyelot_dat.GetValue("ProductCode") + "'", null);
|
|
MainWindowViewModel.Dyelot_dat = MainWindow.SQLiteHelpers.ExecuteDataSet(
|
|
"select * from Dyelot where WorkOrder = '" +
|
|
MainWindowViewModel.WorkNumder + "'", null).Tables[0];
|
|
int dt = MainWindow.SQLiteHelpers.ExecuteDataSet("select * from Dyelot where Dyelot='" +
|
|
Dyelot_dat.GetValue("Dyelot") + "' AND State ='201'", null).Tables[0].Rows.Count;
|
|
if (dt == 0) MainWindowViewModel.CALL_FR = false;
|
|
|
|
//SQLiteHelpers.Close(); //关闭连接
|
|
client.SendAsync("SC828" + SYSKEY + SYSDAT);
|
|
|
|
MainWindowViewModel.TX++;
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC928" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//输送状态指令
|
|
else if (SYSAPI == "SC829")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
Dictionary<string, object> dat_829;
|
|
dat_829 = SerializeConvert.JsonDeserializeFromString<Dictionary<string, object>>(SYSDAT);
|
|
if (dat_829.GetValue("NAME").ToString() == "LOCK") {
|
|
if (dat_829.GetValue("VALUE").ToString() == "True")
|
|
{
|
|
MainWindowViewModel._Lock_bool = true;
|
|
client.SendAsync("SC829" + SYSKEY + SYSDAT);
|
|
}
|
|
else
|
|
{
|
|
MainWindowViewModel._Lock_bool = false;
|
|
client.SendAsync("SC829" + SYSKEY + SYSDAT);
|
|
}
|
|
}
|
|
else if (dat_829.GetValue("NAME").ToString() == "AUTO")
|
|
{
|
|
if (dat_829.GetValue("VALUE").ToString() == "True")
|
|
{
|
|
MainWindowViewModel._AUTO_bool = true;
|
|
client.SendAsync("SC829" + SYSKEY + SYSDAT);
|
|
}
|
|
else
|
|
{
|
|
MainWindowViewModel._AUTO_bool = false;
|
|
client.SendAsync("SC829" + SYSKEY + SYSDAT);
|
|
}
|
|
}
|
|
|
|
MainWindowViewModel.TX++;
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC929" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//锁指令
|
|
else if (SYSAPI == "SC830")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
Dictionary<string, object> Chart_new = new Dictionary<string, object>();//缓存函数
|
|
Chart_new.Add("ERR", MainWindowViewModel.ERR_JOG);
|
|
Chart_new.Add("UserButton", MainWindowViewModel._UserButton);
|
|
Chart_new.Add("UserInfoStart", MainWindowViewModel.UserInfoStart);
|
|
Chart_new.Add("UserInfo", MainWindowViewModel.UserInfo);
|
|
Chart_new.Add("WORK_RUN", MainWindowViewModel.WORK_RUN);
|
|
Chart_new.Add("RUN_STEPID", MainWindowViewModel.RUN_STEPID);
|
|
Chart_new.Add("LOCK", MainWindowViewModel._Lock_bool);
|
|
Chart_new.Add("CALL", MainWindowViewModel.CALL_FR);
|
|
Chart_new.Add("Status", MainWindowViewModel.StatusStr);
|
|
Chart_new.Add("Machine", MainWindowViewModel.S01);
|
|
Chart_new.Add("WorkNumder", MainWindowViewModel.WorkNumder);
|
|
Chart_new.Add("Time", MainWindowViewModel.SYSTime);
|
|
Chart_new.Add("Process", MainWindowViewModel.ProgramName);
|
|
Chart_new.Add("Step", MainWindowViewModel.Process_step);
|
|
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());
|
|
MainWindowViewModel.TX++;
|
|
|
|
MainWindowViewModel.UserInfoStart = 900;
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC931" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//当前信息
|
|
else if (SYSAPI == "SC831")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
client.SendAsync("SC831" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.dt_TP.ToJsonString());
|
|
MainWindowViewModel.TX++;
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC931" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//当前工作表
|
|
else if (SYSAPI == "SC832")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
client.SendAsync("SC832" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.SYSlog);
|
|
MainWindowViewModel.TX++;
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC932" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//当前细节信息
|
|
else if (SYSAPI == "SC833")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
//SQLiteHelpers = new SQLiteHelper(DBAddress); //数据库连接路径
|
|
//SQLiteHelpers.Open(); //打开数据库
|
|
string sql_script = "select * from Dyelot where WorkOrder = '" + MainWindowViewModel.WorkNumder + "'";
|
|
DataTable dt = MainWindow.SQLiteHelpers.ExecuteDataSet(sql_script, null).Tables[0]; //转换
|
|
// SQLiteHelpers.Close(); //关闭连接
|
|
|
|
client.SendAsync("SC833" + "[" + MainWindowViewModel.S01 + "]" + dt.ToJsonString());
|
|
MainWindowViewModel.TX++;
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC933" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//当前领料单
|
|
else if (SYSAPI == "SC851")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
client.SendAsync("SC851" + "[" + MainWindowViewModel.S01 + "]" + JsonConvert.SerializeObject(MainWindowViewModel.dt_d));//数字开关信息
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC951" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//数字开关表
|
|
else if (SYSAPI == "SC852")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
client.SendAsync("SC852" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.dt_a.ToJsonString());//寄存器信息
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC952" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//寄存器表
|
|
else if (SYSAPI == "SC853")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
client.SendAsync("SC853" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.dt_m.ToJsonString());//缓存信息
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC953" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//缓存表
|
|
else if (SYSAPI == "SC854")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
client.SendAsync("SC854" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.dt_ParameterSet.ToJsonString());//缓存信息
|
|
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC954" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//程序设置表
|
|
else if (SYSAPI == "SC855")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
client.SendAsync("SC855" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.dt_SysSet.ToJsonString());//缓存信息
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
catch (Exception ex) { client.SendAsync("SC955" + "[" + MainWindowViewModel.S01 + "]" + ex); }
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//系统设置表
|
|
else if (SYSAPI == "SC859")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
// SQLiteHelper SQLiteHelpersLOG = new SQLiteHelper(Environment.CurrentDirectory+"\\DataBase\\LOG.db"); //数据库连接路径
|
|
// SQLiteHelpersLOG.Open(); //打开数据库
|
|
Dictionary<string, object> dat_859;
|
|
dat_859 = SerializeConvert.JsonDeserializeFromString<Dictionary<string, object>>(SYSDAT);
|
|
|
|
if (dat_859.GetValue("INSTRUCTION").ToString() == "SERVER")
|
|
{
|
|
var dt_ = APILog.LOGSELECT("select * from SERVER where TIME >'" +
|
|
DateTime.Parse(dat_859.GetValue("TIME_S").ToString()).ToString("yyyy/MM/dd HH:mm:ss") + "' and TIME <'" +
|
|
DateTime.Parse(dat_859.GetValue("TIME_E").ToString()).ToString("yyyy/MM/dd HH:mm:ss") + "'");
|
|
client.SendAsync("SC859" + "[" + MainWindowViewModel.S01 + "]" + dt_.ToJsonString());//缓存信息
|
|
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
else if (dat_859.GetValue("INSTRUCTION").ToString() == "OperationLog")
|
|
{
|
|
var dt_ = APILog.LOGSELECT("select * from OperationLog where TIME >'" +
|
|
DateTime.Parse(dat_859.GetValue("TIME_S").ToString()).ToString("yyyy/MM/dd HH:mm:ss") + "' and TIME <'" +
|
|
DateTime.Parse(dat_859.GetValue("TIME_E").ToString()).ToString("yyyy/MM/dd HH:mm:ss") + "'");
|
|
client.SendAsync("SC859" + "[" + MainWindowViewModel.S01 + "]" + dt_.ToJsonString());//缓存信息
|
|
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
else if (dat_859.GetValue("INSTRUCTION").ToString() == "IOLog")
|
|
{
|
|
var dt_ = APILog.LOGSELECT("select * from IOLog where TIME >'" +
|
|
DateTime.Parse(dat_859.GetValue("TIME_S").ToString()).ToString("yyyy/MM/dd HH:mm:ss") + "' and TIME <'" +
|
|
DateTime.Parse(dat_859.GetValue("TIME_E").ToString()).ToString("yyyy/MM/dd HH:mm:ss") + "'");
|
|
dt_.Columns.Remove("type");
|
|
dt_.Columns.Remove("Value");
|
|
dt_.Columns.Remove("PLC");
|
|
client.SendAsync("SC859" + "[" + MainWindowViewModel.S01 + "]" + dt_.ToJsonString());//缓存信息
|
|
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
else if (dat_859.GetValue("INSTRUCTION").ToString() == "ERRLog")
|
|
{
|
|
var dt_ = APILog.LOGSELECT("select * from ERRLog where TIME >'" +
|
|
DateTime.Parse(dat_859.GetValue("TIME_S").ToString()).ToString("yyyy/MM/dd HH:mm:ss") + "' and TIME <'" +
|
|
DateTime.Parse(dat_859.GetValue("TIME_E").ToString()).ToString("yyyy/MM/dd HH:mm:ss") + "'");
|
|
client.SendAsync("SC859" + "[" + MainWindowViewModel.S01 + "]" + dt_.ToJsonString());//缓存信息
|
|
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
client.SendAsync("SC959" + "[" + MainWindowViewModel.S01 + "]" + ex.Message);
|
|
}
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//读取设备日志
|
|
else if (SYSAPI == "SC861")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
Dictionary<string, object> dat_861;
|
|
dat_861 = SerializeConvert.JsonDeserializeFromString<Dictionary<string, object>>(SYSDAT);
|
|
|
|
Dictionary<string, object> datagrid_v = new Dictionary<string, object>();//缓存函数
|
|
datagrid_v.Add("Value", dat_861.GetValue("Value"));
|
|
|
|
// SQLiteHelpers = new SQLiteHelper(DBAddress); //数据库连接路径
|
|
// SQLiteHelpers.Open(); //打开数据库
|
|
MainWindow.SQLiteHelpers.Update("Parameters", datagrid_v, "ParameterID ='" + dat_861.GetValue("ID") + "'", null);//更新
|
|
MainWindowViewModel.dt_ParameterSet = MainWindow.SQLiteHelpers.ExecuteDataSet("select * from Parameters order by ParameterID asc", null).Tables[0];
|
|
//SQLiteHelpers.Close();//关闭数据库
|
|
|
|
client.SendAsync("SC854" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.dt_ParameterSet.ToJsonString());//缓存信息
|
|
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
client.SendAsync("SC961" + "[" + MainWindowViewModel.S01 + "]" + ex);
|
|
}
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//修改软件设置
|
|
else if (SYSAPI == "SC862")
|
|
{
|
|
if (SYSKEY == MainWindowViewModel.SYSKEY)
|
|
{
|
|
try
|
|
{
|
|
Dictionary<string, object> dat_862;
|
|
dat_862 = SerializeConvert.JsonDeserializeFromString<Dictionary<string, object>>(SYSDAT);
|
|
|
|
if (((IList)Prohibit).Contains(dat_862.GetValue("ID")))//是否允许操作
|
|
{
|
|
client.SendAsync("SC980" + "[" + MainWindowViewModel.S01 + "]" + "Settings that are not allowed to be modified remotely");
|
|
}
|
|
else
|
|
{
|
|
Dictionary<string, object> datagrid_v = new Dictionary<string, object>();//缓存函数
|
|
datagrid_v.Add("Value", dat_862.GetValue("Value"));
|
|
|
|
// SQLiteHelpers = new SQLiteHelper(DBAddress); //数据库连接路径
|
|
// SQLiteHelpers.Open(); //打开数据库
|
|
MainWindow.SQLiteHelpers.Update("System", datagrid_v, "ParameterID ='" + dat_862.GetValue("ID") + "'", null);//更新
|
|
MainWindowViewModel.dt_SysSet = MainWindow.SQLiteHelpers.ExecuteDataSet("select * from System order by ParameterID asc", null).Tables[0];
|
|
//SQLiteHelpers.Close();//关闭数据库
|
|
|
|
client.SendAsync("SC855" + "[" + MainWindowViewModel.S01 + "]" + MainWindowViewModel.dt_SysSet.ToJsonString());//缓存信息
|
|
|
|
APILog.DBlog(client.IP, SYSKEY, SYSAPI, SYSDAT);//记录指令
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
client.SendAsync("SC962" + "[" + MainWindowViewModel.S01 + "]" + ex);
|
|
}
|
|
}
|
|
else { client.SendAsync("SC999"); }
|
|
}//修改系统
|
|
|
|
return EasyTask.CompletedTask;
|
|
};
|
|
|
|
await service.SetupAsync(new TouchSocketConfig()//载入配置
|
|
.SetMaxBufferSize(1024 * 1024 * 100)
|
|
.SetMinBufferSize(1024 * 1024)
|
|
.SetListenIPHosts(new IPHost[] { new IPHost(7789), new IPHost(7790) })//同时监听两个地址
|
|
.ConfigureContainer(a =>//容器的配置顺序应该在最前面
|
|
{
|
|
})
|
|
.ConfigurePlugins(a =>
|
|
{
|
|
})
|
|
);
|
|
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();
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|