using HH.WCS.Mobox3.HD.api; using HH.WCS.Mobox3.HD.core; using HH.WCS.Mobox3.HD.device; using HH.WCS.Mobox3.HD.process; using HH.WCS.Mobox3.HD.util; using HH.WCS.Mobox3.HD.wms; using Microsoft.Owin.Hosting; using NLog; using System; using System.Collections.Generic; using System.Diagnostics; using System.Linq; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; using System.Threading.Tasks; using Topshelf; using Monitor = HH.WCS.Mobox3.HD.core.Monitor; namespace HH.WCS.Mobox3.HD { internal class Program { static void Main(string[] args) { string currentProcessName = Process.GetCurrentProcess().ProcessName; Process[] processes = Process.GetProcessesByName(currentProcessName); if (processes.Length <= 1) { Settings.Init(); //1.0 开启api Startup(); //2.0 开启tcp StartTcp(); //3.0 开启线程 var rc = HostFactory.Run(x => { x.Service(s => { s.ConstructUsing(name => new WorkThread()); s.WhenStarted(tc => tc.Start()); s.WhenStopped(tc => tc.Stop()); }); x.RunAsLocalSystem(); x.SetDescription("hh123"); x.SetDisplayName("hh123.wms"); x.SetServiceName("hh123.wms"); }); var exitCode = (int)Convert.ChangeType(rc, rc.GetTypeCode()); Environment.ExitCode = exitCode; } } private static void Startup() { Console.WriteLine("Startup ApiController"); Task.Run(() => { var url = $"http://+:{Settings.port}"; Console.WriteLine(url); using (WebApp.Start(url)) { Console.WriteLine("Running on {0}", url); Console.ReadLine(); } }); } private static void StartTcp() { //new TcpServer("192.168.1.87"); var host = Dns.GetHostEntry(Dns.GetHostName()); foreach (var ip in host.AddressList) { if (ip.AddressFamily == AddressFamily.InterNetwork) { Console.WriteLine($"ip= {ip.ToString()}"); new TcpServer(ip.ToString()); } } } public class WorkThread { public void Start() { List tasks = new List(); //添加任务推送线程 tasks.Add(GetTask(WCSCore.Dispatch,5000)); //添加作业任务启动线程 /*tasks.Add(GetTask(WMSCore.Dispatch, 5000));*/ //添加堆垛机信号检测线程 tasks.Add(GetTask(Monitor.MonitorDDJSignal)); //添加输送线信号检测线程 tasks.Add(GetTask(Monitor.MonitorPipeline)); //添加分拣区检测线程 tasks.Add(GetTask(Monitor.MonitorSortArea, 10000)); // 对连接失败的plc设备进行重连 tasks.Add(GetTask(Monitor.PlcAgainLink, 600000)); // 对通知车间下发灵动任务失败,再次进行通知 tasks.Add(GetTask(Monitor.TimerNotification, 10000)); Task.WaitAll(tasks.ToArray()); } public void Stop() { Console.WriteLine("work stopped"); } private Task GetTask(Action action ,int sleepTime = 3000) { var task = Task.Run(() => { while (true) { try { action(); } catch (Exception ex) { LogHelper.Error(ex.Message, ex); } Thread.Sleep(sleepTime); } }); return task; } } } }