From dc600c6298a3231e05875813ec0fa2fa18151d84 Mon Sep 17 00:00:00 2001
From: pulg <plg@Haninfo>
Date: 星期一, 14 七月 2025 10:14:38 +0800
Subject: [PATCH] 1

---
 HH.WCS.QingXiNongfu/process/DeviceProcess.cs |  324 +++++++++++++++++++++++++++++++++++++++++------------
 1 files changed, 249 insertions(+), 75 deletions(-)

diff --git a/HH.WCS.QingXiNongfu/process/DeviceProcess.cs b/HH.WCS.QingXiNongfu/process/DeviceProcess.cs
index 402373f..f85d37e 100644
--- a/HH.WCS.QingXiNongfu/process/DeviceProcess.cs
+++ b/HH.WCS.QingXiNongfu/process/DeviceProcess.cs
@@ -98,7 +98,9 @@
                         //缈绘枟鏈�-  鐡跺澂
                         else if (plc.deviceType == 5)
                         {
-                            AnalysisBottleCapTipper(data, plc);
+
+                            PpFdjData(data, plc);
+                            // AnalysisBottleCapTipper(data, plc);
                         }
                         //缈绘枟鏈�- 鐡剁洊  4 姘寸洊銆� 鏃犺弻
                         else if (plc.deviceType <= 6)
@@ -2001,6 +2003,12 @@
         private static object lockoIn = new object();
         private static object lockoOut = new object();
 
+        /// <summary>
+        /// 鐡跺澂鏈�+        /// </summary>
+        /// <param name="plc"></param>
+        /// <param name="location"></param>
+        /// <returns></returns>
         static bool BottlePEMInfoFullTwo(Settings.deviceInfo plc, string location)
         {
             try
@@ -2060,6 +2068,10 @@
                                     }
                                 }
                             }
+                            if (staBit != null)
+                            {
+                                break;
+                            }
                         }
                         if (staBit != null)
                         {
@@ -2103,9 +2115,6 @@
                         foreach (var Area in AreaList)
                         {
                             var Row = jcjykk.Select(e => e.N_ROW).Distinct().ToList();
-
-
-
                             var EndList = GetInWork(Area, Row, true, workOrder.SQL_ItemCode);
                             if (EndList.Any())
                             {
@@ -2123,6 +2132,10 @@
                                         break;
                                     }
                                 }
+                            }
+                            if (endBit != null)
+                            {
+                                break;
                             }
                         }
                         if (endBit != null)
@@ -2266,7 +2279,7 @@
         /// <param name="Row"></param>
         /// <param name="ItemCode"></param>
         /// <returns></returns>
-        public static List<Location> GetInWork(string AreaCode, List<int> Row, bool InOutLock = true, string ItemCode = "")
+        public static List<Location> GetInWork(string AreaCode, List<int> Row, bool InOutLock = true, string ItemCode = "", string Jt = "")
         {
             var lstCanOutL = new List<Location>();
             try
@@ -2308,7 +2321,22 @@
                                 var MaxCol = Mhw.FindAll(e => e.N_ROW == item.N_ROW).OrderByDescending(c => c.N_COL).FirstOrDefault();
                                 if (MaxCol != null)
                                 {
-                                    lstCanOutL.RemoveAll(e => e.S_AREA_CODE == item.S_AREA_CODE && e.N_ROW == item.N_ROW && e.N_COL < MaxCol.N_COL);
+                                    if (!string.IsNullOrEmpty(ItemCode) && AreaCode == "QXPPXXQ")
+                                    {
+                                        lstCanOutL.RemoveAll(e => e.S_AREA_CODE == item.S_AREA_CODE && e.N_ROW == item.N_ROW && e.N_COL < MaxCol.N_COL);
+                                    }
+                                    else if (AreaCode == "QXPPXXQ" && Jt == "缈绘枟鏈�)
+                                    {
+                                        lstCanOutL.RemoveAll(e => e.S_AREA_CODE == item.S_AREA_CODE && e.N_ROW == item.N_ROW && e.N_COL > MaxCol.N_COL);
+                                    }
+                                    //if (!string.IsNullOrEmpty(ItemCode) && AreaCode == "QXPPXXQ")
+                                    //{
+                                    //    lstCanOutL.RemoveAll(e => e.S_AREA_CODE == item.S_AREA_CODE && e.N_ROW == item.N_ROW && e.N_COL < MaxCol.N_COL);
+                                    //}
+                                    //else
+                                    //{
+                                    //    lstCanOutL.RemoveAll(e => e.S_AREA_CODE == item.S_AREA_CODE && e.N_ROW == item.N_ROW && e.N_COL > MaxCol.N_COL);
+                                    //}
                                 }
                             }
 
@@ -4132,6 +4160,214 @@
             return result;
         }
 
+        public static void PpFdjData(string Data, Settings.deviceInfo plc)
+        {
+            try
+            {
+                if (Data.Length == 2)
+                {
+                    if (Data == "11")
+                    {
+                        BottlePpFdjFullTwo(plc, plc.location[0]);
+                    }
+                }
+            }
+            catch (Exception ex)
+            {
+
+                throw;
+            }
+        }
+        private static object lockoPp = new object();
+        /// <summary>
+        /// 鐡跺澂缈绘枟鏈�+        /// </summary>
+        /// <param name="plc"></param>
+        /// <param name="location"></param>
+        /// <returns></returns>
+        static bool BottlePpFdjFullTwo(Settings.deviceInfo plc, string location)
+        {
+            try
+            {
+                lock (lockoPp)
+                {
+                    var chi = new SqlHelper<object>().GetInstance();
+                    var newDb = chi.CopyNew();
+                    Location endBit = null;
+                    Location staBit = null;
+                    bool SentTask = false;
+                    if (location == "")
+                    {
+                        throw new Exception("璐т綅涓虹┖");
+                    }
+                    var workOrder = WCSHelper.GetWorkOrder(plc.deviceName);
+                    if (workOrder == null)
+                    {
+                        throw new Exception("娌℃湁銆愭墽琛屼腑銆戠殑宸ュ崟");
+                    }
+                    //鍏堟煡璇㈣揣浣嶆湁娌℃湁璐� 婊$殑涓嬫弧 绌虹殑鍒欎笂绌�+                    //  = newDb.Queryable<Location>().FindAll(x => x.S_LOCK_STATE == "鏃� && x.N_CURRENT_NUM == 0);
+                    var hojs = newDb.Queryable<Location>().Where(e => e.S_LOC_CODE == location).First();
+                    if (hojs != null && hojs.S_LOCK_STATE != "鏃�)
+                    {
+                        return false;
+                    }
+                    var bcpList = WCSHelper.BcpQyOrderList(plc.deviceName);
+                    if (bcpList.Count() == 0)
+                    {
+                        throw new Exception("鏈垝鍒嗗搴旂殑鍖哄煙 鏌ョ湅杩欎釜浜х嚎鏄惁鍦ㄥ崐鎴愬搧鍖哄煙琛ㄨ繘琛岄厤缃�骞跺惎鐢�);
+                    }
+                    if (hojs.N_CURRENT_NUM == 0)//涓婃墭鐩�鍚﹀垯涓嬫墭鐩�+                    {
+                        //涓婃墭鐩�婊℃墭
+                        var jcjykk = bcpList.FindAll(e => e.S_CNTR_TYPE == "婊℃墭").OrderByDescending(g => g.N_PRI).ToList();
+                        var AreaList = jcjykk.Select(e => e.S_AREA_CODE).Distinct().ToList();
+                        foreach (var Area in AreaList)
+                        {
+                            var Row = jcjykk.FindAll(f => f.S_AREA_CODE == Area).Select(e => e.N_ROW).Distinct().ToList();
+                            //杩囩畻娉�璁$畻璧风偣
+                            var staList = GetOutWork(Area, Row, true, workOrder.SQL_ItemCode);
+                            if (staList.Any())
+                            {
+                                foreach (var item in jcjykk)
+                                {
+                                    Location sta = null;
+                                    var staLisL = staList.FindAll(e => e.S_AREA_CODE == item.S_AREA_CODE && e.N_ROW == item.N_ROW).ToList();
+                                    if (staLisL.Any())
+                                    {
+                                        if (item.S_AREA_CODE != "QXPPXXQ")
+                                        {
+                                            sta = staLisL.OrderByDescending(e => e.N_COL).First();
+                                        }
+                                        else
+                                        {
+                                            sta = staLisL.OrderBy(e => e.N_COL).First();
+                                        }
+
+                                    }
+                                    if (sta != null)
+                                    {
+                                        staBit = sta;
+                                        break;
+                                    }
+                                }
+                            }
+                            if (staBit != null)
+                            {
+                                break;
+                            }
+                        }
+                        if (staBit != null)
+                        {
+                            var _ctrl = LocationHelper.GetLocCntrRel(staBit.S_LOC_CODE);
+                            int StaLayer = staBit.N_CURRENT_NUM;
+                            var carryCntrs = new List<string> { _ctrl.FirstOrDefault().S_CNTR_CODE };//DateTime.Now.ToString("yyMMddHHmmss") };
+                            var bb = TaskProcess.CreateTransport(workOrder.SQL_WorkNo, staBit.S_LOC_CODE, location, "鐡跺澂缈绘枟鏈烘弧鎵�鍑哄簱", carryCntrs, StaLayer, 1, carryCntrs.Count, plc.taskPri);
+                            if (bb)
+                            {
+                                SentTask = true;
+                            }
+                        }
+                        if (SentTask)
+                        {
+                            return SentTask;
+                        }
+                    }
+                    else
+                    {
+                        var time = LocationHelper.GetT_FULL_TIME(location);
+                        LogHelper.Info(location + "锛氭墭鐩樻斁缃椂闂�(" + time + ") 璐т綅鎵樼洏鏁伴噺(" + hojs.N_CURRENT_NUM + ")");
+                        if (DateTime.Now.Subtract(time ?? DateTime.Now).TotalMinutes < 1)
+                        {
+                            PlcHelper.SendHex(plc.address, "3F00110D0A");
+                            return false;
+                        }
+                        LocCntrRel _clrel = LocationHelper.GetLocCntrRel(hojs.S_LOC_CODE).FirstOrDefault();
+                        //涓嬫墭鐩�绌烘
+                        var jcjykk = bcpList.FindAll(e => e.S_CNTR_TYPE == "绌烘墭").OrderByDescending(g => g.N_PRI).ToList();
+                        var AreaList = jcjykk.Select(e => e.S_AREA_CODE).Distinct().ToList();
+
+                        //杩囩畻娉�璁$畻璧风偣
+                        foreach (var Area in AreaList)
+                        {
+                            var Row = jcjykk.Select(e => e.N_ROW).Distinct().ToList();
+                            var EndList = GetInWork(Area, Row, true, "", "缈绘枟鏈�);
+                            if (EndList.Any())
+                            {
+                                foreach (var item in jcjykk)
+                                {
+                                    Location End = null;
+                                    var EndListT = EndList.FindAll(e => e.S_AREA_CODE == item.S_AREA_CODE && e.N_ROW == item.N_ROW).ToList();
+                                    if (EndListT.Count() > 0)
+                                    {
+                                        if (item.S_AREA_CODE != "QXPPXXQ")
+                                        {
+                                            End = EndListT.OrderBy(e => e.N_COL).First();
+                                        }
+                                        else
+                                        {
+                                            End = EndListT.OrderByDescending(e => e.N_COL).First();
+                                        }
+                                    }
+                                    if (End != null)
+                                    {
+                                        endBit = End;
+                                        break;
+                                    }
+                                }
+                            }
+                            if (endBit != null)
+                            {
+                                break;
+                            }
+                        }
+                        if (endBit != null)
+                        {
+                            var _ctrl = LocationHelper.GetLocCntrRel(location);
+                            var ggf = 0;
+                            foreach (var item in _ctrl)
+                            {
+                                var cntrrel = ContainerHelper.GetCntrItemRel(item.S_CNTR_CODE).FirstOrDefault();
+                                if (cntrrel != null)
+                                {
+                                    ggf = newDb.Deleteable<CntrItemRel>().Where(it => it.S_ID.Trim() == cntrrel.S_ID.Trim()).ExecuteCommand();
+                                }
+                            }
+                            //if (ggf > 0)
+                            //{
+                            int endLayer = endBit.N_CURRENT_NUM + 1;
+                            var carryCntrs = new List<string> { _ctrl.FirstOrDefault().S_CNTR_CODE };
+                            var bb = TaskProcess.CreateTransport(workOrder.SQL_WorkNo, location, endBit.S_LOC_CODE, "鐡跺澂缈绘枟鏈虹┖鎵�鍏ュ簱", carryCntrs, 1, endLayer, carryCntrs.Count, plc.taskPri);
+                            if (bb)
+                            {
+                                SentTask = true;
+                                //瑙﹀彂鑷姩瑙g粦
+                                //var zdjb = jcjykk.FindAll(e => e.SQL_UsingNow == "Y").OrderByDescending(g => g.N_PRI).ToList();
+                                //foreach (var item in zdjb)
+                                //{
+
+                                //}
+                                //var Jb = newDb.Queryable<Location>().Where(e => e.S_AREA_CODE == Area && Row.Contains(e.N_ROW)).ToList();
+                                ////鏌ヨ绗竴鎺掓槸鍚︽弧 骞朵笖绗簩鎺掑叆婊′笁涓悗瑙g粦绗竴鎺�+                                ////1.鏌ヨ绗竴鎺掓槸鍚︽湁绌鸿揣浣�鏈�鍒欒烦杩�+                            }
+                            // }
+                        }
+                        if (SentTask)
+                        {
+                            return SentTask;
+                        }
+
+                    }
+                    return true;
+                }
+            }
+            catch (Exception ex)
+            {
+                LogHelper.Info(plc.deviceName + $" 鎶ラ敊: {ex.Message}");
+                return false;
+            }
+        }
 
 
 
@@ -4148,7 +4384,6 @@
 
         internal static void AnalysisBottleCapTipper(string data, Settings.deviceInfo plc)
         {
-            //LogHelper.Info($"{plc.deviceName}-{plc.address}-{plc.deviceType}-data:{data}銆�");
             bool containsKey = true;
             int llll = 0;
             if (!FJD_wwwwFD.TryGetValue(plc.deviceName.Trim(), out llll))
@@ -4164,46 +4399,8 @@
             bool flag = data.Length == 2;
             if (flag)
             {
-                //LogHelper.Info(string.Concat(new string[]
-                //{
-                //    "缈绘枟鏈洪棬 ",
-                //    plc.deviceNo[1],
-                //    " - 淇″彿锛�",
-                //    data,
-                //    " 闂ㄧ姸鎬侊細锛�寮�鍏筹級 ",
-                //    data.Substring(3, 1)
-                //        }), "鑷姩闂�);
-                string s = "2";// data.Substring(3, 1);
+                string s = "2";
 
-                //bool flag4 = DeviceProcess.doorStatus.Keys.Contains(plc.deviceNo[1]);
-                //if (flag4)
-                //{
-                //    DeviceProcess.doorStatus[plc.deviceNo[1]].info = s;
-                //    DeviceProcess.doorStatus[plc.deviceNo[1]].modify = DateTime.Now;
-                //}
-                //else
-                //{
-                //    DeviceProcess.doorStatus.Add(plc.deviceNo[1], new DeviceProcess.signalInfo
-                //    {
-                //        info = data.Substring(3, 1),
-                //        modify = DateTime.Now
-                //    });
-                //}
-                //if (data.Substring(1, 1) == "1")
-                //{
-                //    LogHelper.Info(plc.location[0] + "璇诲埌11淇″彿銆傦紙12淇″彿鎸佺画鏁伴噺锛夛細" + llll);
-                //    if (llll < 10)
-                //    {
-                //        llll = 0;
-                //        LogHelper.Info(plc.deviceName + "璇诲埌11淇″彿,鎴栬繛缁�2淇″彿涓嶈冻10娆�);
-                //        if (containsKey)
-                //            FJD_wwwwFD[plc.deviceName.Trim()] = llll;
-                //        else FJD_wwwwFD.Add(plc.deviceName.Trim(), llll);
-
-                //        return;
-                //    }
-                //}
-                //else 
                 if (data.Substring(1, 1) == "0" || data.Substring(1, 1) == "2")
                 {
                     LogHelper.Info(plc.location[0] + $"璇诲埌1 0/2淇″彿銆傦紙1 0/2淇″彿鎸佺画鏁伴噺锛夛細" + llll);
@@ -4213,11 +4410,7 @@
                     else FJD_wwwwFD.Add(plc.deviceName.Trim(), llll);
                 }
 
-                //if (llll < 10)
-                //{
-                //    LogHelper.Info(plc.deviceName + "璇诲埌11淇″彿 ,鎴栬繛缁�2淇″彿涓嶈冻10娆�" + llll + "娆�");
-                //    return;
-                //}
+
 
                 LogHelper.Info(plc.deviceName + "鏌ョ湅缈绘枟楦$┖绛愪綅" + (data.Substring(1, 1) == "1").ToString() + LocationHelper.CheckLocFree(plc.location[0]).ToString(), "缈绘枟鏈�);
                 bool flag5 = data.Substring(1, 1) == "1" && LocationHelper.CheckLocFree(plc.location[0]) && s == "2";
@@ -4230,15 +4423,7 @@
                     }
                     else
                     {
-                        //if (llll > 10)
-                        //{
-                        //    LogHelper.Info(plc.deviceName + "浜ょ缁欑炕鏂椾俊鍙峰悗杩樻病鏈夌炕鏂�, "缈绘枟鏈�);
-                        //    return;
-                        //}
-                        //else
-                        //{
-                        //    LogHelper.Info(plc.deviceName + "浜ょ缁欑炕鏂椾俊鍙峰悗 宸茬炕鏂�" + llll, "缈绘枟鏈�);
-                        //}
+
 
                         WorkOrder workOrder = WCSHelper.GetWorkOrder(plc.deviceName);
                         bool flag7 = workOrder == null;
@@ -4293,21 +4478,17 @@
                                         if (flag11 > 30)
                                         {
 
-                                            //if (data.Substring(1, 1) == "1")
-                                            //{
+
                                             LogHelper.Info(plc.location[0] + "璇诲埌11淇″彿銆傦紙1 0/2淇″彿鎸佺画鏁伴噺锛夛細" + llll);
-                                            //if (flag11 < 3.0)
+
                                             if (llll < 0)
                                             {
-                                                //llll = 0;
+
                                                 LogHelper.Info(plc.deviceName + "璇诲埌11淇″彿,浣嗘槸娌″嚭鐜拌繃1 0/2");
-                                                //if (containsKey)
-                                                //    FJD_wwwwFD[plc.deviceName.Trim()] = llll;
-                                                //else FJD_wwwwFD.Add(plc.deviceName.Trim(), llll);
+
 
                                                 return;
                                             }
-                                            //}
 
                                             var b = TaskProcess.FDJTakeEmpyt2(plc, workOrder);
 
@@ -4321,20 +4502,13 @@
                                         }
                                         else
                                         {
-                                            ///- 
                                             LogHelper.Info($"{plc.deviceName} 璐т綅 {plc.location} 婊℃鍗歌揣涓嶈冻30S缂撳啿鏃堕棿銆�");
-
-                                            //if (time != null && DateTime.Now.Subtract(time ?? DateTime.Now).TotalSeconds < 30)
-                                            //{
                                             LogHelper.Info($"缈绘枟鏈烘弧妗嗘斁涓嬫椂闂磠time}涓嶈冻30绉� 鍥炲啓缈绘枟淇″彿", "缈绘枟鏈�);
                                             PlcHelper.SendHex(plc.address, $"3f 00 11 0d 0a");
-
                                             if (containsKey)
                                                 FJD_wwwwFD[plc.deviceName.Trim()] = 0;
                                             else FJD_wwwwFD.Add(plc.deviceName.Trim(), 0);
-
                                             return;
-                                            //}
                                         }
                                     }
                                 }

--
Gitblit v1.9.1