From 2aa6ffae020b4dab66ac30ee4436346aa15ff3cb Mon Sep 17 00:00:00 2001 From: kazelee <1847801760@qq.com> Date: 星期二, 15 七月 2025 17:26:54 +0800 Subject: [PATCH] 修复绑定解绑可能导致的信息丢失问题 --- Program.cs | 31 +++++++++++++++---------------- 1 files changed, 15 insertions(+), 16 deletions(-) diff --git a/Program.cs b/Program.cs index 942c7dd..84cf1fb 100644 --- a/Program.cs +++ b/Program.cs @@ -3,17 +3,19 @@ using System.Threading; using System.Threading.Tasks; -using HH.WCS.Mobox3.AnGang.AppStart; -using HH.WCS.Mobox3.AnGang.Devices; +using HH.WCS.Mobox3.AnGang.core; +using HH.WCS.Mobox3.AnGang.device; using Microsoft.Owin.Hosting; using Topshelf; +using Monitor = HH.WCS.Mobox3.AnGang.core.Monitor; + namespace HH.WCS.Mobox3.AnGang { internal class Program { - [STAThread] + //[STAThread] // SNAP 娉ㄩ噴璇ヨ淇濈暀鍏朵粬琛屽悗锛岀▼搴忔甯歌繍琛� static void Main(string[] args) { //鍩虹璁剧疆淇℃伅鍒濆鍖�@@ -21,7 +23,7 @@ //1.0 寮�惎api Startup(); //2.0 寮�惎tcp - StartTcp(); + //StartTcp(); //3.0 寮�惎S7 //StartS7(); //4.0 寮�惎Modbus @@ -59,7 +61,7 @@ Console.WriteLine("Startup ApiController"); Task.Run(() => { - var url = Settings.Config.WebApiUrl; + var url = Settings.WebApiUrl; Console.WriteLine(url); using (WebApp.Start<Startup>(url)) { @@ -74,9 +76,9 @@ /// </summary> private static void StartTcp() { - var tcpServerIP = Settings.Config.TCPServerIP; - var tcpServerPort = Settings.Config.TCPServerPort; - new TcpServer(tcpServerIP, tcpServerPort); + //var tcpServerIP = Settings.TCPServerIP; + //var tcpServerPort = Settings.TCPServerPort; + //new TcpServer(tcpServerIP, tcpServerPort); } @@ -115,8 +117,7 @@ } private static void StartSnap() { - //new SnapManager(Settings.Snap); - new SnapManager(Settings.Config.Snap[0]); + new SnapManager(Settings.Snaps[0]); } public class WorkThread @@ -125,13 +126,11 @@ { List<Task> tasks = new List<Task>(); // 娣诲姞浠诲姟鎺ㄩ�绾跨▼ - //tasks.Add(GetTask(WCSCore.Dispatch)); + tasks.Add(GetTask(WCSCore.Dispatch)); + //tasks.Add(GetTask(Monitor.CheckCountOrder)); - ////娣诲姞鑷畾涔夌嚎绋�- //tasks.Add(GetTask(Monitor.CheckEmptyCnt));//妫�祴绌烘墭鐩�- - ////鏍规嵁S7/Modbus鍗忚鍒ゆ柇杈撻�绾跨殑淇″彿 鍘熸潗鏂欎骇绾垮簱鍖�>婊℃墭缂撳瓨搴撳尯锛岀┖鎵樼紦瀛樺簱鍖�>鍘熸潗鏂欎骇绾垮簱鍖�- //tasks.Add(GetTask(Monitor.CheckS7Devices)); + tasks.Add(GetTask(Monitor.InboundDataSync)); + tasks.Add(GetTask(Monitor.OutboundDataSync)); Task.WaitAll(tasks.ToArray()); } -- Gitblit v1.9.1