初步 增加 推送线程

schangxiang@126.com

2025-09-17 c9c91ad3e3ac218d81c86809c93a35622b51a686

 DEmon/iWareCc/Service1.cs

@@ -413,6 +413,8 @@
            //ReSendThread.Name = "向WIP重新推送报文";
            //StartThread(ReSendThread);

            //开启推送给MES的出入库完成线程 【Editby shaocx,2025-09-17】
            new Thread(mesDataTranfficForRealMes.Handler).Start();

        }

@@ -445,7 +447,7 @@
            //结束生成入库主任务的线程
            CloseThread(CreatMainTaskInThread);

              //结束生成出库主任务的线程
            //结束生成出库主任务的线程
            CloseThread(CreatMainTaskOutThread);

            //关闭分解任务的线程
@@ -516,8 +518,8 @@

            var s = (StackerEntity)stacker;
            //LogTextHelper.WriteLine(Resources.LogDir, "获取堆垛机{0}状态线程已开启", s.Equipment.EquipName);
            var items = new string[] 
            {           
            var items = new string[]
            {
                s.OpcReadItems.SrmNo,// 1Srm编号
                s.OpcReadItems.Mode,// 2任务号 
                s.OpcReadItems.Alarm,// 3告警
@@ -857,7 +859,7 @@
                    {
                        gateService.HandleMsgSCReceive(gateService.ReadFromDatagramPoolSCReceive());
                    }
                    else 
                    else
                    {
                        gateService.HandleMsgReceive(gateService.ReadFromDatagramPoolReceive());
                        gateService.HandleMsgAlarmReceive(gateService.ReadFromDatagramPoolAlarmReceive());
@@ -928,20 +930,20 @@
        /// </summary>
        private void CreateMainInTask()
        {
               var c = (ConveyorEntity)CacheEntity.Conveyors.Find(x => x.Equipment.EquipName == "conveyor1");
               var mainTaskContainer = new MainTaskContainer();
               var 生成入库主任务 = new 根据扫码生成入库主任务(c, mainTaskContainer);
               var 保存生成的任务 = new 保存生成的入库任务(c, mainTaskContainer);
               生成入库主任务.NextHandler = 保存生成的任务;
            var c = (ConveyorEntity)CacheEntity.Conveyors.Find(x => x.Equipment.EquipName == "conveyor1");
            var mainTaskContainer = new MainTaskContainer();
            var 生成入库主任务 = new 根据扫码生成入库主任务(c, mainTaskContainer);
            var 保存生成的任务 = new 保存生成的入库任务(c, mainTaskContainer);
            生成入库主任务.NextHandler = 保存生成的任务;

                while (true)
            while (true)
            {
                if (CacheEntity.IsAutoRun)
                {
                    if (CacheEntity.IsAutoRun)
                    {
                        生成入库主任务.Handle();
                    }
                    Thread.Sleep(1000);
                    生成入库主任务.Handle();
                }
                Thread.Sleep(1000);
            }
        }
        /// <summary>
        /// 生成出库主任务
@@ -1287,7 +1289,7 @@
                {
                    try
                    {
                       // string stackerName = Enum.GetName(typeof(EEquipmentCnName), EEquipmentCnName.stacker1);
                        // string stackerName = Enum.GetName(typeof(EEquipmentCnName), EEquipmentCnName.stacker1);
                        var reports = dbModel.COUNTStackerReports.Where(x => x.isfinished == (int)EYesOrNo.否).ToList();
                        var stacker = CacheEntity.Stackers.FirstOrDefault(x => x.Equipment.EquipName == "stacker1");
                        var unfinishedReport = reports.FirstOrDefault(x => x.name == stacker.Equipment.EquipName);