优化代码, 封装货位锁和创建任务流程, 数据库事务等

kazelee

4 天以前 2d3ee03961d6cfbde70342e8a97bc7b05d0b0dc3

 Program.cs

@@ -1,16 +1,17 @@
using System;
using System.Collections.Generic;
using System.Threading;
using HH.WCS.Mobox3.DSZSH.device;

using HH.WCS.Mobox3.DSZSH.core;
using HH.WCS.Mobox3.DSZSH.device;
using HH.WCS.Mobox3.DSZSH.util;

using Microsoft.Owin.Hosting;

using Topshelf;

using Task = System.Threading.Tasks.Task;
using Monitor = HH.WCS.Mobox3.DSZSH.core.Monitor;
using System.Net.Sockets;
using Task = System.Threading.Tasks.Task;

namespace HH.WCS.Mobox3.DSZSH {
    internal class Program
@@ -68,7 +69,7 @@
        }
        
        /// <summary>
        /// 开启TCP协议通讯，服务端
        /// 开启TCP协议通讯,服务端
        /// </summary>
        private static void StartTcp()
        {
@@ -123,16 +124,16 @@

                tasks.Add(GetTask(WCSCore.Dispatch));

                // 测试：托盘下线
                // 测试:托盘下线
                //tasks.Add(GetTask(Monitor.CheckInbound));

                // 轮询：出库单状态
                // 轮询:出库单状态
                tasks.Add(GetTask(Monitor.CheckOutboundOrder));

                // 轮询：抽检单状态
                // 轮询:抽检单状态
                tasks.Add(GetTask(Monitor.CheckCheckOrder));

                // 轮询：移库单状态
                // 轮询:移库单状态
                tasks.Add(GetTask(Monitor.CheckShiftOrder));

                Task.WaitAll(tasks.ToArray());
@@ -151,7 +152,7 @@
                        }
                        catch (Exception ex)
                        {
                            LogHelper.Error(ex.Message, ex);
                            LogHelper.InfoEx(ex);
                        }
                        Thread.Sleep(intervalMs);
                    }