1

czw

10 天以前 8dfba1cab2ea59fca7b2c9cfad2da68e9f49b440

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

@@ -119,7 +119,7 @@
            else
            {
                logger = LogFactory.CreateLogger(name);
                if (logger != null)
                if (logger != null && !loggers.Keys.Contains(name))
                {
                    loggers.Add(name, logger);
                }
@@ -143,7 +143,7 @@
        /// </summary>
        static LogFactory()
        {
            var loggerNames = new List<string>() { "HosttoagvTask", "HosttoagvCar", "NDC", "杭奥" };
            var loggerNames = new List<string>() { "HosttoagvTask", "HosttoagvCar", "NDC", "杭奥","IP在线检测" };
            LogManager.Configuration = DefaultConfig(loggerNames);
        }
        public static ILogger CreateLogger(string name)
@@ -430,7 +430,10 @@
        /// <summary>
        ///  1 ç»´å¸Œå°”机械臂
        ///  2 æ·çž¬æœºæ¢°è‡‚臂
        ///  3 æ·çž¬è¾“送线
        ///  3 é«˜å†²æœºæ¢°æ‰‹
        ///  4 SSXaAGV  äº¤äº’的输送线 çº¤ä½“编号
        ///  5 å®šå­ä¸Šæ–™æœºæ¢°æ‰‹
        ///  6 è½¬å­ä¸Šæ–™æœºæ¢°æ‰‹
        /// </summary>
        public int deviceType { get; set; }
        public int enable { get; set; }
@@ -519,15 +522,13 @@
    {
        #region    [自定义类][20250325131633664][SYSHelper]
        private static object locker = new object();
        internal static int GetSerialNumber(string snType, string prefix, string Vend = "0")
        internal static int GetSerialNumber(string snType, string prefix)
        {
            if (Vend == "1")
                Vend = DateTime.Now.ToString("yyMMdd");
            int result = 0;
            lock (locker)
            {
                SYSRepository sysservice = new SYSRepository();
                var sId = sysservice.FindEntity(a => a.CN_S_TYPE.Trim() == snType && a.CN_S_PRE.Trim() == prefix + Vend);
                var sId = sysservice.FindEntity(a => a.CN_S_TYPE.Trim() == snType && a.CN_S_PRE.Trim() == prefix);

                if (sId != null)
                {
@@ -549,7 +550,7 @@
                }
                else
                {
                    sId = new SYSEntity { CN_S_TYPE = snType, CN_T_LAST = DateTime.Now, CN_S_PRE = prefix + Vend, CN_N_MAX = 0, CN_S_APP_TYPE = "WCS" };
                    sId = new SYSEntity { CN_S_TYPE = snType, CN_T_LAST = DateTime.Now, CN_S_PRE = prefix , CN_N_MAX = 0, CN_S_APP_TYPE = "WCS" };
                    sysservice.Insert(sId);
                }
            }
@@ -560,21 +561,26 @@
    public class TaskProcess
    {
        #region    [自定义类][20250325152141671][TaskProcess]
        internal static bool CreateTask(string no, string from, string to, string taskType, int pri, List<string> cntrs, string workMode = "AGV", int cntrCount = 1, int startLayer = 1, int endLayer = 1)
        internal static bool CreateTask(string no, string from, string to, string taskType, int pri, List<string> cntrs, string workMode = "AGV", string S_INDEX = "", int cntrCount = 1, int startLayer = 1, int endLayer = 1)
        {
            LogHelper.Info($"输送线RGV空托任务 from:{from}>to {to}开始创建>"); 

            LogHelper.Info($"创建任务 from:{from}>to {to}开始创建>");
            var cntrInfo = string.Join(",", cntrs);
            ILocRepository locc = new LocRepository();
            var fromLoc = locc.FindEntity(x => x.S_LOC_CODE == from);
            var endLoc = locc.FindEntity(x => x.S_LOC_CODE == to);

            var s = Settings.deviceInfos.Find(x => x.location.Contains(from)) != null;
            var e = Settings.deviceInfos.Find(x => x.location.Contains(to)) != null;
            string t = "F01";
            if (s && !e) t = "A002";
            if (!s && e) t = "A003";
            if (s && e) t = "A004";
            string t = "";
            if (workMode == "AGV" && string.IsNullOrEmpty(S_INDEX))
            {
                var s = Settings.deviceInfos.Find(x => x.location.Contains(from)) != null;
                var e = Settings.deviceInfos.Find(x => x.location.Contains(to)) != null;

                t = "F01";
                if (s && !e) t = "A002";
                if (!s && e) t = "A003";
                if (s && e) t = "A004";
            }
            try
            {

@@ -604,6 +610,7 @@
                };
                ITaskRepository taskserice = new TaskRepository();
                taskserice.Insert(wmsTask);

                if (workMode == "AGV")
                {
                    fromLoc.S_LOCK_STATE = "出库锁";
@@ -612,7 +619,7 @@
                    locc.Update(endLoc);
                }

                LogHelper.Info($"输送线RGV空托任务 from:{from}>to {to} åˆ›å»º{wmsTask.S_TASK_NO}成功");
                LogHelper.Info($"创建任务 from:{from}>to {to} åˆ›å»º{wmsTask.S_TASK_NO}成功");
                return true;
            }
            catch (Exception ex)
@@ -644,10 +651,10 @@
            taskserice.Insert(action);
        }

        public static System.String GenerateTaskNo()
        public static System.String GenerateTaskNo(string snType = "任务号")
        {
            var id = SYSHelper.GetSerialNumber("任务号", "TN", "1");
            var date = DateTime.Now.ToString("yyMMdd");
            var id = SYSHelper.GetSerialNumber(snType, date);
            return $"TN{date}{id.ToString().PadLeft(4, '0')}";
        }
        #endregion [自定义类][20250325152141671][TaskProcess]
@@ -671,6 +678,7 @@
            public string endBit { get; set; }
            public string reqCode { get; set; }
            public string cntrCode { get; set; }
            public string materialCode { get; set; }

            internal static ReturnMsg CreatemesTask(CreateTask model)
            {
@@ -692,12 +700,13 @@
                        S_DEPART_NAME = "",
                        S_START_LOC = model.startBit,
                        S_END_LOC = model.endBit,
                        S_TYPE = model.reqCode,
                        S_TYPE = model.taskType,
                        S_SRC_NO = "",//
                        N_PRIORITY = -88,
                        S_WORK_MODE = "agv",
                        S_B_STATE = "MES",
                        S_CNTRS = model.cntrCode,
                        S_INDEX = model.materialCode,//mes任务中 S_INDEX是 ç‰©æ–™ç¼–码。 agv任务中是 agv任务类型
                        N_START_LAYER = 1,
                        N_END_LAYER = 1,
                        N_CNTR_COUNT = 1
@@ -758,131 +767,11 @@
                }
            }
        }
        public static void ResMesTask()
        public static void ResMesTask(Tag tag)
        {
            ///1.
            TaskRepository taskservice = new TaskRepository();
            var tasks = taskservice.FindList(x => (x.S_B_STATE == "MES" || x.S_B_STATE == "People") && x.N_PRIORITY == -88);
            var VERXs = Settings.deviceInfos?.FindAll(x => x.deviceType == 2);
            //if (VERXs.Any())
            foreach (var task in tasks)
            {
                var sx = VERXs?.Find(x => x.location.Contains(task.S_END_LOC));
                if (sx == null)
                {
                    //直接生成对应任务。
                    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());
                    if (res)
                    {
                        //task.N_PRIORITY = 0;
                        taskservice.dbcontext.Set<TaskEntity>().Attach(task);
                        taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).CurrentValue = 0;
                        taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).IsModified = true;
                        taskservice.dbcontext.SaveChanges();
                    }
                }
                else
                {
                    var sindex = sx.location.ToList().IndexOf(task.S_END_LOC);
                    LocRepository locRepository = new LocRepository();
                    //生成跳跃任务。  -- æ‰˜ç›˜è´§ä½è¡¨ã€‚ 
                    var t1s = taskservice.FindList(x => x.S_SRC_NO == task.S_TASK_NO);
                    if (t1s.Any())
                    {
                        var t1 = t1s.OrderBy(x => x.T_CREATE).LastOrDefault();
                        if (t1.S_END_LOC == task.S_END_LOC)
                        {
                            task.N_PRIORITY = 0;
                            task.S_B_STATE = "MES_完成";
                            taskservice.Update(task);
                            continue;
                        }
                        if (t1.S_B_STATE == "完成")
                        {
                            //1.终点是否有托盘。 ä¾æ®æ˜¯ç»ˆç‚¹çš„任务是 ä½œä¸ºç»ˆç‚¹ï¼Œè¿˜æ˜¯èµ·ç‚¹ã€‚
                            //var ec = taskservice.FindList(x => (x.S_START_LOC == task.S_START_LOC || x.S_END_LOC == task.S_END_LOC) /*&& DateTime.Now.Subtract(x.T_CREATE).TotalHours < 5*/).OrderByDescending(x => x.T_CREATE).FirstOrDefault();//($"select top 1 * from TN_TASK WHERE S_START_LOC='{task.S_END_LOC}' OR S_END_LOC='{task.S_END_LOC}' ORDER BY T_CREATE DESC");
                            //var ec = taskservice.FindList(x => x.S_START_LOC == task.S_START_LOC && x.S_END_LOC == task.S_START_LOC, new Common.Data.Pagination
                            //                        {
                            //                            page = 1,
                            //                            sidx = "T_CREATE",
                            //                            sord = "desc",
                            //                            rows = 1
                            //                        }).FirstOrDefault();
                            TaskEntity ec = null;
                            var dev = Conn.默认Redis.GetValue(sx.deviceName + "." + (sindex == 0 ? "D1224" : "D1225"));
                            if (dev?.Trim() == "1")
                                ec = taskservice.FindList(x => x.S_END_LOC == task.S_END_LOC && x.S_B_STATE == "完成", new Common.Data.Pagination
                                {
                                    page = 1,
                                    sidx = "T_CREATE",
                                    sord = "desc",
                                    rows = 1
                                }).FirstOrDefault();
                            if (t1.S_START_LOC == task.S_START_LOC && ec != null)//!= task.S_END_LOC)
                            {
                                //第二段。
                                LocEntity endLoc = null;
                                var di = sx;
                                if (di != null)
                                {
                                    foreach (var ssloc in di.deviceNo)
                                    {
                                        var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);
                                        if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == "无")
                                        {
                                            endLoc = endloc;
                                            break;
                                        }
                                    }
                                    if (endLoc != null)
                                    {
                                        var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_END_LOC, endLoc.S_LOC_CODE, task.S_TYPE + "下空", 7, ec.S_CNTRS.Split(',').ToList());
                                        if (res)
                                        {
                                            task.N_PRIORITY = 0; taskservice.Update(task);
                                        }
                                    }
                                }
                            }
                            else
                            {
                                var res = TaskProcess.CreateTask(task.S_TASK_NO, t1.S_END_LOC, task.S_END_LOC, task.S_TYPE + "补满", 6, task.S_CNTRS.Split(',').ToList());
                                if (res)
                                {
                                    task.N_PRIORITY = 0; taskservice.Update(task);
                                }
                            }
                        }
                    }
                    else
                    {
                        //生成第一段。
                        LocEntity endLoc = null;
                        var di = sx;
                        if (di != null)
                        {
                            foreach (var ssloc in di.deviceNo)
                            {
                                var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);
                                if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE == "无")
                                {
                                    endLoc = endloc;
                                    break;
                                }
                            }
                            if (endLoc != null)
                            {
                                var res = TaskProcess.CreateTask("", task.S_START_LOC, endLoc.S_LOC_CODE, task.S_TYPE + "满转", 8, task.S_CNTRS.Split(',').ToList());
                                if (res)
                                {
                                    task.N_PRIORITY = 0; taskservice.Update(task);
                                }
                            }
                        }
                    }

                }
            }
            AutoThread.InvokeMethod(AutoThread.Instance, "ResolveMesTask", new object[] { tag });
            //var VERX = Settings.deviceInfos?.FindAll(x => x.deviceName.Contains("捷瞬抓臂"));
            //if ()
            ///2  çœ‹ç¼“存区。 æ²¡æ»¡çš„。
@@ -893,4 +782,25 @@

        #endregion [自定义类][20250531152402452][ToWMSMES]
    }
    public class ConsoleInterceptor : TextWriter
    {
        #region    [自定义类][20250702112833751][ConsoleInterceptor]
        private readonly TextWriter _originalOut;

        public ConsoleInterceptor()
        {
            _originalOut = Console.Out;
        }

        public override Encoding Encoding => Encoding.UTF8;

        public override void WriteLine(string value = "")
        {
            string values = (string)AutoThread.InvokeMethod(AutoThread.Instance, "WriteLine", new object[] { value });
            //// å¯ä»¥é€‰æ‹©ç»§ç»­è¾“出到原控制台
            if (!string.IsNullOrEmpty(values))
                _originalOut.WriteLine(values);
        }
        #endregion [自定义类][20250702112833751][ConsoleInterceptor]
    }
}