1

czw

9 天以前 8dfba1cab2ea59fca7b2c9cfad2da68e9f49b440

 2025Äê6ÔÂ12ÈÕ/AuxAllWCS/Build/Project/´úÂë/VS×Ô¶¨ÒåÀà/AutoThread.cs

@@ -28,6 +28,8 @@
using System.IO;
using GZ.Device.Agv;
using System.Net.NetworkInformation;
using System.Windows.Documents;
using System.Text.RegularExpressions;

namespace GZ.Projects.AuxAllWCS
{
@@ -128,38 +130,86 @@
        }


        public void ThreaTotal(Tag tag)
        public void ThreaTotal(Tag tag, Device device)
        {
            List<Task> tasks = new List<Task>();
            tasks.Add(GetTask(delegate (Tag tag1, Device device1)
            {
                try
                {
                    foreach (var ip in new List<string> {
                    device1.p发那科1下线.Config.IP,
                    device1.p发那科2下线.Config.IP,
                    device1.D定子1号机械手.Config.IP,
                    device1.D定子2号机械手.Config.IP,
                    device1.Js捷顺1.Config.IP,
                    device1.Js捷顺2.Config.IP,
                    device1.维希尔抓臂1.Config.IP,
                    device1.维希尔抓臂2.Config.IP,
                    device1.RGV.Config.IP
                })
                    {
                        string pattern = @"\b(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\b";

                        var matches = Regex.Match(ip, pattern);
                        if (matches.Success)
                            IsMachineOnline(matches.Value);
                    }
                }
                catch (Exception ex)
                {
                    LogHelper.Error(ex.Message, ex);
                }

            }, tag, device, 3000));
            tasks.Add(GetTask(ThreadMXC3, tag, 3000));
            tasks.Add(GetTask(ThreadMXC4, tag, 3000));
            tasks.Add(GetTask(ResetGats, tag, 3000));
            

            tasks.Add(GetTask(sa1022, tag, 3000));
            tasks.Add(GetTask(sa1025, tag, 3000));
            tasks.Add(GetTask(sa1030, tag, 3000));
            tasks.Add(GetTask(sa2001, tag, 3000));
            tasks.Add(GetTask(sa2030, tag, 3000));
            tasks.Add(GetTask(sa2008, tag, 3000));
            tasks.Add(GetTask(sa3001, tag, 3000));
            tasks.Add(GetTask(sa3005, tag, 3000));
            tasks.Add(GetTask(sa3006, tag, 3000));
            tasks.Add(GetTask(sa3010, tag, 3000));




            Task.WaitAll(tasks.ToArray());
        }
        public static bool IsMachineOnline(string hostNameOrIp, int timeout = 1000)

        public bool IsMachineOnline(string hostNameOrIp, int timeout = 1000)
        {
            //device.p发那科1下线.Config.IP
            LogHelper.Info("检测ip:>" + hostNameOrIp, "IP在线检测");
            bool res = false;
            try
            {
                using (var ping = new Ping())
                {
                    var reply = ping.Send(hostNameOrIp, timeout);
                    return reply.Status == IPStatus.Success;
                    res = reply.Status == IPStatus.Success;
                }
            }
            catch (PingException)
            {
                return false;
                res = false;
            }
            catch (Exception)
            {
                // å…¶ä»–异常处理
                return false;
                res = false;
            }
            finally
            {
                LogHelper.Info("检测ip:>" + hostNameOrIp + " ç»“果：" + (res ? "通" : "不通"), "IP在线检测");
            }
            return res;
        }

        private Task GetTask(Action<Tag> action, Tag tag, int i = 2500)
@@ -182,6 +232,25 @@
            return task;
        }

        private Task GetTask(Action<Tag, Device> action, Tag tag, Device dev, int i = 2500)
        {
            var task = Task.Run(() =>
            {
                while (true)
                {
                    try
                    {
                        action(tag, dev);
                    }
                    catch (Exception ex)
                    {
                        LogHelper.Error(ex.Message, ex);
                    }
                    Thread.Sleep(i);
                }
            });
            return task;
        }
        public string WriteLine(string value = "")
        {

@@ -1113,28 +1182,93 @@
                    //车走了  å¼€å…‰æ …
                    if (!goin)
                    {
                        if (dev.deviceType == 1)
                        if (dev.deviceType == 4)
                        {
                            LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤‡æ˜¯{dev.deviceName} å¼€å¯å…‰æ …处理 =================> ");
                            LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "右")} å…‰æ …{(goin ? "关闭" : "开启")} ç”³è¯·ã€‚" + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "R02" : "R04"), "true", dev.deviceName + "Queue"));
                            Conn.默认Redis.SetValue(dev.deviceName + "." + (V ? "R02" : "R04"), "true", dev.deviceName + "Queue", false);
                            LogHelper.Info($"车离开输送线交互>  {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤‡æ˜¯{dev.deviceName} SSX AGV äº¤äº’。。。");
                            switch (loc)
                            {
                                case "1019":
                                    {
                                        SetRedistoPlc("A1019取货交互.SOver", "true", "A1019取货交互Queue", "agv å–货完成写完成交互");
                                    }
                                    break;
                                case "1030":
                                    {
                                        SetRedistoPlc("A1030取货交互.SOver", "true", "A1030取货交互Queue", "agv å–货完成写完成交互");
                                    }
                                    break;
                                case "2030":
                                    {
                                        SetRedistoPlc("A2030取货交互.SOver", "true", "A2030取货交互Queue", "agv å–货完成写完成交互");
                                    }
                                    break;
                                case "3005":
                                    {
                                        SetRedistoPlc("A3005取货交互.SOver", "true", "A3005取货交互Queue", "agv å–货完成写完成交互");
                                    }
                                    break;
                                case "3010":
                                    {
                                        SetRedistoPlc("A3010取货交互.SOver", "true", "A3010取货交互Queue", "agv å–货完成写完成交互");
                                    }
                                    break;
                                //}
                                //switch (loc)
                                //{
                                case "1022":
                                    {
                                        SetRedistoPlc("A1022放货交互.SOver", "true", "A1022放货交互Queue", "agv æ”¾è´§å®Œæˆå†™å®Œæˆäº¤äº’");
                                    }
                                    break;
                                case "1025":
                                    {
                                        SetRedistoPlc("A1025放货交互.SOver", "true", "A1025放货交互Queue", "agv æ”¾è´§å®Œæˆå†™å®Œæˆäº¤äº’");
                                    }
                                    break;
                                case "2001":
                                    {
                                        SetRedistoPlc("A2001放货交互.SOver", "true", "A2001放货交互Queue", "agv æ”¾è´§å®Œæˆå†™å®Œæˆäº¤äº’");
                                        tag.SA2001.wTaskNo = 20012007;
                                        tag.SA2001.wEbit = 2007;
                                        tag.SA2001.w托盘码 = TaskProcess.GenerateTaskNo("虚拟托盘号").Substring(3);
                                    }
                                    break;
                                case "3001":
                                    {
                                        SetRedistoPlc("A3001放货交互.SOver", "true", "A3001放货交互Queue", "agv æ”¾è´§å®Œæˆå†™å®Œæˆäº¤äº’");
                                    }
                                    break;
                                case "3006":
                                    {
                                        SetRedistoPlc("A3006放货交互.SOver", "true", "A3006放货交互Queue", "agv æ”¾è´§å®Œæˆå†™å®Œæˆäº¤äº’");
                                    }
                                    break;
                            }
                        }
                        else if (dev.deviceType == 2)
                        else
                        {
                            LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤‡æ˜¯{dev.deviceName} å¼€å¯å…‰æ …处理 =================> ");
                            LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "右")} å…‰æ …{(goin ? "关闭" : "开启")} ç”³è¯·ã€‚" + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "D1222" : "D1223"), "1", dev.deviceName + "Queue"));
                            if (dev.deviceType == 1)
                            {
                                LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤‡æ˜¯{dev.deviceName} å¼€å¯å…‰æ …处理 =================> ");
                                LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "右")} å…‰æ …{(goin ? "关闭" : "开启")} ç”³è¯·ã€‚" + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "R02" : "R04"), "true", dev.deviceName + "Queue"));
                                Conn.默认Redis.SetValue(dev.deviceName + "." + (V ? "R02" : "R04"), "true", dev.deviceName + "Queue", false);
                            }
                            else if (dev.deviceType == 2)
                            {
                                LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤‡æ˜¯{dev.deviceName} å¼€å¯å…‰æ …处理 =================> ");
                                LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "右")} å…‰æ …{(goin ? "关闭" : "开启")} ç”³è¯·ã€‚" + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "D1222" : "D1223"), "1", dev.deviceName + "Queue"));

                            Conn.默认Redis.SetValue(dev.deviceName + "." + (V ? "D1220" : "D1221"), "0", dev.deviceName + "Queue");
                            Conn.默认Redis.SetValue(dev.deviceName + "." + (V ? "D1222" : "D1223"), "1", dev.deviceName + "Queue");
                                Conn.默认Redis.SetValue(dev.deviceName + "." + (V ? "D1220" : "D1221"), "0", dev.deviceName + "Queue");
                                Conn.默认Redis.SetValue(dev.deviceName + "." + (V ? "D1222" : "D1223"), "1", dev.deviceName + "Queue");
                            }
                            else if (dev.deviceType == 5)
                            {
                                LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤‡æ˜¯{dev.deviceName} å¼€å¯å…‰æ …处理 =================> ");
                                Conn.默认Redis.SetValue(dev.deviceName + "." + (V ? "D2211" : "D2216"), "1", dev.deviceName + "Queue");
                                Conn.默认Redis.SetValue(dev.deviceName + "." + (V ? "D2212" : "D2217"), "0", dev.deviceName + "Queue");
                            }
                            LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤‡æ˜¯{dev.deviceName} å¼€å¯å…‰æ …处理完成 =================> ");
                        }
                        else if (dev.deviceType == 5)
                        {
                            LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤‡æ˜¯{dev.deviceName} å¼€å¯å…‰æ …处理 =================> ");
                            Conn.默认Redis.SetValue(dev.deviceName + "." + (V ? "D2211" : "D2216"), "1", dev.deviceName + "Queue");
                            Conn.默认Redis.SetValue(dev.deviceName + "." + (V ? "D2212" : "D2217"), "0", dev.deviceName + "Queue");
                        }
                        LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤‡æ˜¯{dev.deviceName} å¼€å¯å…‰æ …处理完成 =================> ");

                        item.N_CREATEMETHOD = 1;
                        item.S_REVIEW_COMMENT = $"光栅开启完成";
                        taskActRepository.Update(item);
@@ -1144,8 +1278,124 @@
                    {
                        if (dev.deviceType == 4)
                        {
                            LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤‡æ˜¯{dev.deviceName} SSX AGV äº¤äº’。。。");
                            LogHelper.Info($"车请求输送线交互> {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤‡æ˜¯{dev.deviceName} SSX AGV äº¤äº’。。。");
                            //tag.SA1019.Sagverr
                            switch (loc)
                            {
                                case "1019":
                                    {
                                        if (tag.SA1019.SreadCan)
                                        {
                                            LogHelper.Info($"1019 è¯»åˆ°è¾“送线允许。");
                                            continuuuuu = true;
                                        }
                                        else
                                            SetRedistoPlc("A1019取货交互.Ssetreq", "true", "A1019取货交互Queue", "写AGV申请");
                                    }
                                    break;
                                case "1030":
                                    {
                                        if (tag.SA1030.SreadCan)
                                        {
                                            LogHelper.Info($"1030 è¯»åˆ°è¾“送线允许。");
                                            continuuuuu = true;
                                        }
                                        else
                                            SetRedistoPlc("A1030取货交互.Ssetreq", "true", "A1030取货交互Queue", "写AGV申请");
                                    }
                                    break;
                                case "2030":
                                    {
                                        if (tag.SA2030.SreadCan)
                                        {
                                            LogHelper.Info($"2030 è¯»åˆ°è¾“送线允许。");
                                            continuuuuu = true;
                                        }
                                        else
                                            SetRedistoPlc("A2030取货交互.Ssetreq", "true", "A2030取货交互Queue", "写AGV申请");
                                    }
                                    break;
                                case "3005":
                                    {
                                        if (tag.ssx输送线.s3005.SreadCan)
                                        {
                                            LogHelper.Info($"3005 è¯»åˆ°è¾“送线允许。");
                                            continuuuuu = true;
                                        }
                                        else
                                            SetRedistoPlc("A3005取货交互.Ssetreq", "true", "A3005取货交互Queue", "写AGV申请");
                                    }
                                    break;
                                case "3010":
                                    {
                                        if (tag.ssx输送线.s3010.SreadCan)
                                        {
                                            LogHelper.Info($"3010 è¯»åˆ°è¾“送线允许。");
                                            continuuuuu = true;
                                        }
                                        else
                                            SetRedistoPlc("A3010取货交互.Ssetreq", "true", "A3010取货交互Queue", "写AGV申请");
                                    }
                                    break;
                                //}
                                //switch (loc)
                                //{
                                case "1022":
                                    {
                                        if (tag.SA1022.SreadCan)
                                        {
                                            LogHelper.Info($"1022 è¯»åˆ°è¾“送线允许。");
                                            continuuuuu = true;
                                        }
                                        else
                                            SetRedistoPlc("A1022放货交互.Ssetreq", "true", "A1022放货交互Queue", "写AGV申请");
                                    }
                                    break;
                                case "1025":
                                    {
                                        if (tag.SA1025.SreadCan)
                                        {
                                            LogHelper.Info($"1025 è¯»åˆ°è¾“送线允许。");
                                            continuuuuu = true;
                                        }
                                        else
                                            SetRedistoPlc("A1025放货交互.Ssetreq", "true", "A1025放货交互Queue", "写AGV申请");
                                    }
                                    break;
                                case "2001":
                                    {
                                        if (tag.SA2001.SreadCan)
                                        {
                                            LogHelper.Info($"2001 è¯»åˆ°è¾“送线允许。");
                                            continuuuuu = true;
                                        }
                                        else
                                            SetRedistoPlc("A2001放货交互.Ssetreq", "true", "A2001放货交互Queue", "写AGV申请");
                                    }
                                    break;
                                case "3001":
                                    {
                                        if (tag.ssx输送线.s3001.SreadCan)
                                        {
                                            LogHelper.Info($"3001 è¯»åˆ°è¾“送线允许。");
                                            continuuuuu = true;
                                        }
                                        else
                                            SetRedistoPlc("A3001放货交互.Ssetreq", "true", "A3001放货交互Queue", "写AGV申请");
                                    }
                                    break;
                                case "3006":
                                    {
                                        if (tag.ssx输送线.s3006.SreadCan)
                                        {
                                            LogHelper.Info($"3006 è¯»åˆ°è¾“送线允许。");
                                            continuuuuu = true;
                                        }
                                        else
                                            SetRedistoPlc("A3006放货交互.Ssetreq", "true", "A3006放货交互Queue", "写AGV申请");
                                    }
                                    break;
                            }
                        }
                        else
                        {
@@ -1186,7 +1436,7 @@
                                    LogHelper.Info($"ThreadGrats å†™{(dev.deviceName + "." + (V ? "D1220" : "D1221"))}为 1 ï¼Œ åŽè¯»{d12201}");
                                }
                            }
                            else if (dev.deviceType == 3)
                            else if (dev.deviceType == 5)
                            {

                                var close = (System.UInt16)System.Convert.ChangeType(Conn.默认Redis.GetValue(dev.deviceName + "." + (V ? "D2220" : "D2225")), typeof(System.UInt16));
@@ -1255,15 +1505,24 @@
            LogHelper.Info($"ThreadGrats deviceType5光栅写入位重置 =================> ");
            //重置信号
            //foreach (var dev in Settings.deviceInfos.FindAll(x => x.deviceType == 5))

            {
                if (tag.DZ1.D2211 == 1 && tag.DZ1.D2220 == 1)
                    tag.DZ1.D2211 = 0;
                if (tag.DZ1.D2216 == 1 && tag.DZ1.D2225 == 1)
                    tag.DZ1.D2216 = 0;
                if (tag.DZ2.D2211 == 1 && tag.DZ2.D2220 == 1)
                    tag.DZ2.D2211 = 0;
                if (tag.DZ2.D2216 == 1 && tag.DZ2.D2225 == 1)
                    tag.DZ2.D2216 = 0;
                //一线地址：10.221.55.181     ç«¯å£ï¼š6000
                //if (IsMachineOnline("10.221.55.181"))
                {
                    //if (tag.DZ1.D2211 == 1 && tag.DZ1.D2220 == 1)
                    //    tag.DZ1.D2211 = 0;
                    //if (tag.DZ1.D2216 == 1 && tag.DZ1.D2225 == 1)
                    //    tag.DZ1.D2216 = 0;
                }
                //二线地址：10.221.55.179     ç«¯å£ï¼š6000
                //if (IsMachineOnline("10.221.55.179"))
                {
                    //if (tag.DZ2.D2211 == 1 && tag.DZ2.D2220 == 1)
                    //    tag.DZ2.D2211 = 0;
                    //if (tag.DZ2.D2216 == 1 && tag.DZ2.D2225 == 1)
                    //    tag.DZ2.D2216 = 0;
                }
            }
            LogHelper.Info($"ThreadGrats deviceType5光栅写入位重置完成。 =================> ");
        }
@@ -1496,6 +1755,7 @@
        public void Thread下料位检测(Tag tag)
        {
            Console.WriteLine($"Thread下料位检测    =====>");
            var lsi = new List<string>();
            foreach (var ssx in new string[] { "1003", "1005", "1011", "1013" })
            {
                var RArrive = (System.UInt16)System.Convert.ChangeType(Conn.默认Redis.GetValue($"FNK1003051113.RArrive{ssx}"), typeof(System.UInt16));
@@ -1716,31 +1976,167 @@

        public void Thread1019Down(Tag tag)
        {
            Console.WriteLine($"1019任务状态：   =====>");
            Console.WriteLine($"1019任务状态：{tag.SA1019.RtaskState}- barcode:{tag.SA1019.R托盘码}- ç©ºé—²{tag.SA1019.R5空闲}");
            var taggg = tag.SA1019;
            string vqu = "A1019取货交互";
            Console.WriteLine($"1019任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
            }
            //Console.WriteLine($"1019任务状态：   =====>");
            //Console.WriteLine($"1019任务状态：{tag.SA1019.RtaskState}- barcode:{tag.SA1019.R托盘码}- ç©ºé—²{tag.SA1019.R5空闲}");
        }

        private void sa2008(Tag tag)
        {
            var rdisTcode = RedisHelper.Get<string>($"Arrive{2008}BarcodeLast", out string msg);
            //if(tag.ssx输送线.s2008)
        }

        private void sa2030(Tag tag)
        {
            var taggg = tag.SA2030;
            string vqu = "A2030取货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
            }
        }

        private void sa2001(Tag tag)
        {
            var taggg = tag.SA2001;
            string vqu = "A2001放货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
            }
        }

        private void sa1030(Tag tag)
        {
            var taggg = tag.SA1030;
            string vqu = "A1030取货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
            }
        }

        private void sa1025(Tag tag)
        {
            var taggg = tag.SA1025;
            string vqu = "A1025放货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
            }
        }

        private void sa1022(Tag tag)
        {
            var taggg = tag.SA1022;
            string vqu = "A1022放货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
            }
        }

        private void sa3010(Tag tag)
        {
            var taggg = tag.ssx输送线.s3010;
            string vqu = "A3010取货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
            }
        }

        private void sa3006(Tag tag)
        {
            var taggg = tag.ssx输送线.s3006;
            string vqu = "A3006放货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
            }
        }

        private void sa3005(Tag tag)
        {
            var taggg = tag.ssx输送线.s3005;
            string vqu = "A3005取货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
            }
        }

        private void sa3001(Tag tag)
        {
            var taggg = tag.ssx输送线.s3010;
            string vqu = "A3001放货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
            }
        }

        public void Thread1025Up(Tag tag)
        {
            Console.WriteLine($"SA1025 ä»»åŠ¡çŠ¶æ€ï¼š   =====>");
            Console.WriteLine($"SA1025 ä»»åŠ¡çŠ¶æ€ï¼š{tag.SA1025.RtaskState}- ç©ºé—²{tag.SA1025.R5空闲}");
            //if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            //{
            //    SetRedistoPlc("A1019取货交互.Ssetreq", "false", "A1019取货交互Queue", "写AGV申请");
            //    SetRedistoPlc("A1019取货交互.SOver", "false", "A1019取货交互Queue", "写AGV申请");
            //}
            //Console.WriteLine($"SA1025 ä»»åŠ¡çŠ¶æ€ï¼š   =====>");
            //Console.WriteLine($"SA1025 ä»»åŠ¡çŠ¶æ€ï¼š{tag.SA1025.RtaskState}- ç©ºé—²{tag.SA1025.R5空闲}");
        }
        public void Thread1022Up(Tag tag)
        {
            Console.WriteLine($"SA1022    =====>");
            Console.WriteLine($"SA1022 ä»»åŠ¡çŠ¶æ€ï¼š{tag.SA1022.RtaskState}- ç©ºé—²{tag.SA1022.R5空闲}");
            //if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            //{
            //    SetRedistoPlc("A1019取货交互.Ssetreq", "false", "A1019取货交互Queue", "清理");
            //    SetRedistoPlc("A1019取货交互.SOver", "false", "A1019取货交互Queue", "清理");
            //}
            //Console.WriteLine($"SA1022    =====>");
            //Console.WriteLine($"SA1022 ä»»åŠ¡çŠ¶æ€ï¼š{tag.SA1022.RtaskState}- ç©ºé—²{tag.SA1022.R5空闲}");
        }
        public void Thread1030Down(Tag tag)
        {
            Console.WriteLine($"SA1030 ä»»åŠ¡çŠ¶æ€ï¼š   =====>");
            Console.WriteLine($"SA1030 ä»»åŠ¡çŠ¶æ€ï¼š{tag.SA1030.RtaskState}- ç©ºé—²{tag.SA1030.R5空闲}-->对应终点2001>空闲5：{tag.SA2001.R5空闲}");
            //Console.WriteLine($"SA1030 ä»»åŠ¡çŠ¶æ€ï¼š   =====>agv完成SOver{tag.SA1030.SOver}");
            //if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            //{
            //    SetRedistoPlc("A1022放货交互.Ssetreq", "false", "A1022放货交互Queue", "清理");
            //    SetRedistoPlc("A1022放货交互.SOver", "false", "A1022放货交互Queue", "清理");
            //}
            //Console.WriteLine($"SA1030 ä»»åŠ¡çŠ¶æ€ï¼š{tag.SA1030.RtaskState}- ç©ºé—²{tag.SA1030.R5空闲}-->对应终点2001>空闲5：{tag.SA2001.R5空闲}");
        }
        public void Thread2030Down(Tag tag)
        {

            Console.WriteLine($"SA2030 ä»»åŠ¡çŠ¶æ€ï¼š   =====>");
            Console.WriteLine($"SA2030 ä»»åŠ¡çŠ¶æ€ï¼š{tag.SA2030.RtaskState}- ç©ºé—²{tag.SA2030.R5空闲} - barcode:{tag.SA2030.R托盘码}");


            //Console.WriteLine($"SA2030 ä»»åŠ¡çŠ¶æ€ï¼š   =====>");
            //Console.WriteLine($"SA2030 ä»»åŠ¡çŠ¶æ€ï¼š{tag.SA2030.RtaskState}- ç©ºé—²{tag.SA2030.R5空闲} - barcode:{tag.SA2030.R托盘码}");

        }

@@ -1761,71 +2157,360 @@
                LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} {(sx == null ? "非" : "是")}总装机器人任务");
                if (sx == null)
                {
                gotoOOOOOOOOO:
                    if (string.IsNullOrEmpty(task.S_CNTRS) && !string.IsNullOrEmpty(task.S_INDEX))
                    {
                        // å«æ–™ä»»åŠ¡ã€‚ æŒ‡å®šç‰©æ–™ä¸æŒ‡å®šæ‰˜ç›˜ï¼Œéœ€è¦å‡ºåº“
                        switch (task.S_START_LOC)
                        {
                            case "2030":
                                if (!string.IsNullOrEmpty(tag.SA2030.R托盘码))
                                {
                                    var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
                        var ssagv = Settings.deviceInfos.Find(x => x.deviceType == 4);
                        if (ssagv.location.Contains(task.S_START_LOC))
                            switch (task.S_START_LOC)
                            {
                                case "2030":
                                    if (!string.IsNullOrEmpty(tag.SA2030.R托盘码))
                                    {
                                        cntrCode = tag.SA2030.R托盘码,
                                        type = 1
                                    }));
                                    var strr = JsonConvert.DeserializeObject<MES2234>(str);
                                    if (strr.success && strr.data.materialCode == task.S_INDEX)
                                    {
                                        task.S_CNTRS = tag.SA2030.R托盘码;
                                        taskservice.Update(task);
                                        LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} 2030 å‡ºå£æ‰˜ç›˜å·{tag.SA2030.R托盘码} åŒ¹é…æ ¡éªŒã€‚");
                                        var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
                                        {
                                            cntrCode = tag.SA2030.R托盘码,
                                            type = 1
                                        }));
                                        var strr = JsonConvert.DeserializeObject<MES2234>(str);
                                        if (strr.success && strr.data.materialCode == task.S_INDEX)
                                        {
                                            task.S_CNTRS = tag.SA2030.R托盘码;
                                            taskservice.Update(task);
                                            goto gotoOOOOOOOOO;
                                        }
                                        else
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç‰©æ–™{task.S_INDEX} ä¸Ž 2030 å‡ºå£çš„托盘物料{strr.data.materialCode}不符合");
                                        }
                                    }
                                    else
                                    {
                                        LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} 2030 å‡ºå£çš„托盘物料不符合");
                                        //2027  2220   2013.. è¯†åˆ«ä¸€ä¸‹ï¼Œå¼€å§‹åº“
                                        //1 çœ‹27 20 13 æ˜¯å¦æœ‰ä»»åŠ¡ã€‚ æœ‰åˆ™ä¸å‡ºäº†ã€‚ ç­‰å‡ºå£åˆ¤æ–­åŒ¹é…ã€‚
                                        //2  éƒ½æ²¡æœ‰ä»»åŠ¡ï¼Œé€ä¸ªåŒ¹é…æ˜¯å¦ç¬¦åˆï¼Œåˆ™å‡ºåº“。
                                        //LogHelper.Info($"");
                                        {
                                            var t20132027 = tag.ssx输送线.s2027;
                                            LogHelper.Info($"识别2027任务 æ‰˜ç›˜å·ï¼š{t20132027.R托盘码} RTaskNo>{t20132027.RTaskNo} REbit>{t20132027.REbit} wTaskNo>{t20132027.wTaskNo} wEbit>{t20132027.wEbit}");
                                            if ((t20132027.RTaskNo > 0 && t20132027.REbit == 2030) || (t20132027.wTaskNo > 0 && t20132027.wEbit == 2030))
                                            {
                                                LogHelper.Info($"2027任务 ä»»åŠ¡ç»ˆç‚¹æ˜¯2030 ï¼Œç»ˆæ­¢");
                                                continue;
                                            }
                                        }
                                        {
                                            var t20132027 = tag.ssx输送线.s2020;
                                            LogHelper.Info($"识别2027任务 æ‰˜ç›˜å·ï¼š{t20132027.R托盘码} RTaskNo>{t20132027.RTaskNo} REbit>{t20132027.REbit} wTaskNo>{t20132027.wTaskNo} wEbit>{t20132027.wEbit}");
                                            if ((t20132027.RTaskNo > 0 && t20132027.REbit == 2030) || (t20132027.wTaskNo > 0 && t20132027.wEbit == 2030))
                                            {
                                                LogHelper.Info($"2020任务 ä»»åŠ¡ç»ˆç‚¹æ˜¯2030 ï¼Œç»ˆæ­¢");
                                                continue;
                                            }
                                        }
                                        {
                                            var t20132027 = tag.ssx输送线.s2013;
                                            LogHelper.Info($"识别2027任务 æ‰˜ç›˜å·ï¼š{t20132027.R托盘码} RTaskNo>{t20132027.RTaskNo} REbit>{t20132027.REbit} wTaskNo>{t20132027.wTaskNo} wEbit>{t20132027.wEbit}");
                                            if ((t20132027.RTaskNo > 0 && t20132027.REbit == 2030) || (t20132027.wTaskNo > 0 && t20132027.wEbit == 2030))
                                            {
                                                LogHelper.Info($"2013任务 ä»»åŠ¡ç»ˆç‚¹æ˜¯2030 ï¼Œç»ˆæ­¢");
                                                continue;
                                            }
                                        }
                                        if (!string.IsNullOrEmpty(tag.ssx输送线.s2027.R托盘码))
                                        {
                                            var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
                                            {
                                                cntrCode = tag.ssx输送线.s2027.R托盘码,
                                                type = 1
                                            }));
                                            var strr = JsonConvert.DeserializeObject<MES2234>(str);
                                            if (strr.success && strr.data.materialCode == task.S_INDEX)
                                            {
                                                LogHelper.Info($"2027 è¯»åˆ°æ‰˜ç›˜{tag.ssx输送线.s2027.R托盘码} åŒ¹é…æˆåŠŸï¼Œå†™ä»»åŠ¡å·ï¼š20272030，终点：2030 å’Œæ‰˜ç›˜ç åŒè¯»");
                                                tag.ssx输送线.s2027.wTaskNo = 20272030;
                                                tag.ssx输送线.s2027.wEbit = 2030;
                                                tag.ssx输送线.s2027.w托盘码 = tag.ssx输送线.s2027.R托盘码;
                                                LogHelper.Info($"2027 > 2030  SSX任务下发完成。");
                                                continue;
                                            }
                                        }
                                        if (!string.IsNullOrEmpty(tag.ssx输送线.s2020.R托盘码))
                                        {
                                            var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
                                            {
                                                cntrCode = tag.ssx输送线.s2020.R托盘码,
                                                type = 1
                                            }));
                                            var strr = JsonConvert.DeserializeObject<MES2234>(str);
                                            if (strr.success && strr.data.materialCode == task.S_INDEX)
                                            {
                                                LogHelper.Info($"2020 è¯»åˆ°æ‰˜ç›˜{tag.ssx输送线.s2020.R托盘码} åŒ¹é…æˆåŠŸï¼Œå†™ä»»åŠ¡å·ï¼š20202030，终点：2030 å’Œæ‰˜ç›˜ç åŒè¯»");
                                                tag.ssx输送线.s2020.wTaskNo = 20202030;
                                                tag.ssx输送线.s2020.wEbit = 2030;
                                                tag.ssx输送线.s2020.w托盘码 = tag.ssx输送线.s2020.R托盘码;
                                                LogHelper.Info($"2020 > 2030  SSX任务下发完成。");
                                                continue;
                                            }
                                        }
                                        if (!string.IsNullOrEmpty(tag.ssx输送线.s2013.R托盘码))
                                        {
                                            var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
                                            {
                                                cntrCode = tag.ssx输送线.s2013.R托盘码,
                                                type = 1
                                            }));
                                            var strr = JsonConvert.DeserializeObject<MES2234>(str);
                                            if (strr.success && strr.data.materialCode == task.S_INDEX)
                                            {
                                                LogHelper.Info($"2013 è¯»åˆ°æ‰˜ç›˜{tag.ssx输送线.s2013.R托盘码} åŒ¹é…æˆåŠŸï¼Œå†™ä»»åŠ¡å·ï¼š20132030，终点：2030 å’Œæ‰˜ç›˜ç åŒè¯»");
                                                tag.ssx输送线.s2013.wTaskNo = 20132030;
                                                tag.ssx输送线.s2013.wEbit = 2030;
                                                tag.ssx输送线.s2013.w托盘码 = tag.ssx输送线.s2013.R托盘码;
                                                LogHelper.Info($"2013 > 2030  SSX任务下发完成。");
                                                continue;
                                            }
                                        }
                                        LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} æ—¥å¿—能跑到这，说明没物料，或者都不符合 æ— æ³•åŽ»2030");
                                    }
                                }
                                else
                                {
                                    //TODO------------------2027  2220   2013.. è¯†åˆ«ä¸€ä¸‹ï¼Œå¼€å§‹åº“
                                }
                                break;
                            case "1019":
                                if (!string.IsNullOrEmpty(tag.SA1019.R托盘码))
                                {
                                    var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
                                    break;
                                case "1019":
                                    if (!string.IsNullOrEmpty(tag.SA1019.R托盘码))
                                    {
                                        cntrCode = tag.SA1019.R托盘码,
                                        type = 2
                                    }));
                                    var strr = JsonConvert.DeserializeObject<MES2234>(str);
                                    if (strr.success && strr.data.materialCode == task.S_INDEX)
                                    {
                                        task.S_CNTRS = tag.SA2030.R托盘码;
                                        taskservice.Update(task);
                                        var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
                                        {
                                            cntrCode = tag.SA1019.R托盘码,
                                            type = 2
                                        }));
                                        var strr = JsonConvert.DeserializeObject<MES2234>(str);
                                        if (strr.success && strr.data.materialCode == task.S_INDEX)
                                        {
                                            task.S_CNTRS = tag.SA2030.R托盘码;
                                            taskservice.Update(task);
                                            goto gotoOOOOOOOOO;
                                        }
                                        else
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç‰©æ–™{task.S_INDEX} ä¸Ž 1019 å‡ºå£çš„托盘物料{strr.data.materialCode}不符合");
                                        }
                                    }
                                    else
                                    break;
                                //case "1030":
                                //    {

                                //    }
                                //break;
                                case "3005":
                                    {
                                        LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} 1019 å‡ºå£çš„托盘物料不符合");
                                        if (!string.IsNullOrEmpty(tag.ssx输送线.s3005.R托盘码))
                                        {
                                            var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
                                            {
                                                cntrCode = tag.ssx输送线.s3005.R托盘码,
                                                type = 2
                                            }));
                                            var strr = JsonConvert.DeserializeObject<MES2234>(str);
                                            if (strr.success && strr.data.materialCode == task.S_INDEX)
                                            {
                                                task.S_CNTRS = tag.ssx输送线.s3005.R托盘码;
                                                taskservice.Update(task);
                                                goto gotoOOOOOOOOO;
                                            }
                                            else
                                            {
                                                LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç‰©æ–™{task.S_INDEX} ä¸Ž 3010 å‡ºå£çš„托盘物料{strr.data.materialCode}不符合");
                                            }
                                        }
                                    }
                                }
                                break;
                        }
                                    break;
                                case "3010":
                                    {
                                        if (!string.IsNullOrEmpty(tag.ssx输送线.s3010.R托盘码))
                                        {
                                            var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
                                            {
                                                cntrCode = tag.ssx输送线.s3010.R托盘码,
                                                type = 2
                                            }));
                                            var strr = JsonConvert.DeserializeObject<MES2234>(str);
                                            if (strr.success && strr.data.materialCode == task.S_INDEX)
                                            {
                                                task.S_CNTRS = tag.ssx输送线.s3010.R托盘码;
                                                taskservice.Update(task);
                                                goto gotoOOOOOOOOO;
                                            }
                                            else
                                            {
                                                LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç‰©æ–™{task.S_INDEX} ä¸Ž 3010 å‡ºå£çš„托盘物料{strr.data.materialCode}不符合");
                                            }
                                        }
                                    }
                                    break;
                            }
                        //else if (ssagv.location.Contains(task.S_END_LOC))
                        //    switch (task.S_END_LOC)
                        //    {
                        //        case "1022":
                        //            {
                        //                if (tag.SA1022.R5空闲 != 1)
                        //                {
                        //                    LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹1022 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                        //                    continue;
                        //                }
                        //            }
                        //            break;
                        //        case "1025":
                        //            {
                        //                if (tag.SA1025.R5空闲 != 1)
                        //                {
                        //                    LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 1025 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                        //                    continue;
                        //                }
                        //            }
                        //            break;
                        //        case "2001":
                        //            {
                        //                if (tag.SA2001.R5空闲 != 1)
                        //                {
                        //                    LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 2001 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                        //                    continue;
                        //                }
                        //            }
                        //            break;
                        //        case "3001":
                        //            {
                        //                if (tag.ssx输送线.s3001.R5空闲 != 1)
                        //                {
                        //                    LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 3001 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                        //                    continue;
                        //                }
                        //            }
                        //            break;
                        //        case "3006":
                        //            {
                        //                if (tag.ssx输送线.s3006.R5空闲 != 1)
                        //                {
                        //                    LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 3006 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                        //                    continue;
                        //                }
                        //            }
                        //            break;
                        //    }
                    }
                    else
                    {
                        //if (new List<string> { "2001", "1022", "1025", "3001", "3006" }.Contains(task.S_END_LOC))
                        //{
                        //}
                        //if (new List<string> { "1019"/*, "1030"*/, "2030", "3005", "3010" }.Contains(task.S_START_LOC))  //1030 æ˜¯ä¸»åŠ¨ç”³è¯·ï¼Œ ä¸ç”¨åˆ¤æ–­ã€‚
                        //{
                        //    //物料匹配判断。和 2030判断
                        //}
                        string type = "";
                        if (new List<string> { "1019"/*, "1030"*/, "2030", "3005", "3010" }.Contains(task.S_START_LOC))
                            switch (task.S_START_LOC)
                            {
                                case "1019":
                                    {
                                        type = "A009";
                                        if (tag.SA1019.RtaskState != 4)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} èµ·ç‚¹ 1019 RtaskState>{tag.SA1019.RtaskState} æœªç”³è¯·RGV任务，不推送");
                                            continue;
                                        }
                                    }
                                    break;
                                case "2030":
                                    {
                                        type = "A007";
                                        if (tag.SA2030.RtaskState != 4)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} èµ·ç‚¹ 2030 RtaskState>{tag.SA2030.RtaskState} æœªç”³è¯·RGV任务，不推送");
                                            continue;
                                        }
                                    }
                                    break;
                                case "3005":
                                    {
                                        type = "A010";
                                        if (tag.ssx输送线.s3005.RtaskState != 4)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} èµ·ç‚¹ 3005 RtaskState>{tag.ssx输送线.s3005.RtaskState} æœªç”³è¯·RGV任务，不推送");
                                            continue;
                                        }
                                    }
                                    break;
                                case "3010":
                                    {
                                        type = "A010";
                                        if (tag.ssx输送线.s3010.RtaskState != 4)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} èµ·ç‚¹ 3010 RtaskState>{tag.ssx输送线.s3010.RtaskState} æœªç”³è¯·RGV任务，不推送");
                                            continue;
                                        }
                                    }
                                    break;
                            }
                        if (new List<string> { "2001", "1022", "1025", "3001", "3006" }.Contains(task.S_END_LOC))
                        {
                            //------------------
                        }
                        else if (new List<string> { "1019"/*, "1030"*/, "2030", "3005", "3010" }.Contains(task.S_START_LOC))  //1030 æ˜¯ä¸»åŠ¨ç”³è¯·ï¼Œ ä¸ç”¨åˆ¤æ–­ã€‚
                        {

                        }
                            switch (task.S_END_LOC)
                            {
                                case "1022":
                                    {
                                        type = "A008";
                                        if (tag.SA1022.R5空闲 != 1)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹1022 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            continue;
                                        }
                                    }
                                    break;
                                case "1025":
                                    {
                                        type = "A007";
                                        if (tag.SA1025.R5空闲 != 1)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 1025 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            continue;
                                        }
                                    }
                                    break;
                                case "2001":
                                    {
                                        type = "A007";
                                        if (tag.SA2001.R5空闲 != 1)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 2001 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            continue;
                                        }
                                    }
                                    break;
                                case "3001":
                                    {
                                        type = "A010";
                                        if (tag.ssx输送线.s3001.R5空闲 != 1)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 3001 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            continue;
                                        }
                                    }
                                    break;
                                case "3006":
                                    {
                                        type = "A010";
                                        if (tag.ssx输送线.s3006.R5空闲 != 1)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 3006 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            continue;
                                        }
                                    }
                                    break;
                            }

                        LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç›´æŽ¥ç”Ÿæˆå¯¹åº”任务");
                        //直接生成对应任务。
                        var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS?.Split(',').ToList() ?? new List<string>());
                        var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS?.Split(',').ToList() ?? new List<string>(), type);

                        LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç›´æŽ¥ç”Ÿæˆå¯¹åº”任务 ç»“果：{res}");
                        if (res)
@@ -1968,7 +2653,18 @@
            }
        }


        public string procNo()
        {
            return TaskProcess.GenerateTaskNo("日志流水号");
        }
        public bool SetRedistoPlc(string key, string value, string queue, string desc)
        {
            var vnc = procNo();
            LogHelper.Info($"{vnc}>>Redis.SetValue写plc æè¿°ï¼š{desc} tagName:{key},value:{value},queue:{queue}");
            var v = Conn.默认Redis.SetValue(key, value, queue);
            LogHelper.Info($"{vnc}>> å†™å…¥ç»“æžœ{v}");
            return v;
        }
        public HkReturnResult OperateHKTaskStatus(HaiKangOrderInfo model)
        {
            // æŸ¥è¯¢ä»»åŠ¡ï¼šæ ¹æ®ä»»åŠ¡å·
@@ -2037,6 +2733,16 @@
                                    //    Conn.默认Redis.SetValue(device.deviceName + "." + V, "0", device.deviceName + "Queue");
                                    //});
                                }
                                else
                                    switch (device.deviceType)
                                    {
                                        case 4:
                                            {

                                            }
                                            break;

                                    }
                            }
                            //LocationHelper.UnLockLoc(wcsTask.S_START_LOC);
                            break;
@@ -2131,31 +2837,29 @@
                                        LogHelper.Info($"{ssloc}申请mes任务结果{str}");
                                    }
                                }
                                switch (device2.deviceType)
                                {
                                    case 4:
                                        {
                                            if (wcsTask.S_END_LOC == "2001")
                                else
                                    switch (device2.deviceType)
                                    {
                                        case 4:
                                            {

                                            }
                                        }
                                        break;
                                    case 5:
                                        {
                                            var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;
                                            string V = inde ? "D2210" : "D2215";
                                            Conn.默认Redis.SetValue(device2.deviceName + "." + V, "1", device2.deviceName + "Queue");
                                        }
                                        break;
                                    case 6:
                                        {
                                            //var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;
                                            //string V = inde ? "D2210" : "D2215";
                                            //Conn.默认Redis.SetValue(device2.deviceName + "." + V, "1", device2.deviceName + "Queue");
                                        }
                                        break;
                                }
                                            break;
                                        case 5:
                                            {
                                                var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;
                                                string V = inde ? "D2210" : "D2215";
                                                Conn.默认Redis.SetValue(device2.deviceName + "." + V, "1", device2.deviceName + "Queue");
                                            }
                                            break;
                                        case 6:
                                            {
                                                //var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;
                                                //string V = inde ? "D2210" : "D2215";
                                                //Conn.默认Redis.SetValue(device2.deviceName + "." + V, "1", device2.deviceName + "Queue");
                                            }
                                            break;
                                    }
                            }

                            //LocationMethod.JudgeLocation(wcsTask);