From 2d2342157638cab98a4c59b0c687808cc2f98ea1 Mon Sep 17 00:00:00 2001 From: 杨张扬 <634643841@qq.com> Date: 星期五, 25 七月 2025 17:24:57 +0800 Subject: [PATCH] 增加空托堆叠和空托入货架的新逻辑,增加拆盘入库和回炉胶和废料的逻辑 --- core/Monitor.cs | 272 +++++++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 247 insertions(+), 25 deletions(-) diff --git a/core/Monitor.cs b/core/Monitor.cs index e81d5fd..5669c96 100644 --- a/core/Monitor.cs +++ b/core/Monitor.cs @@ -226,6 +226,7 @@ ITEMCODE = woInfo.S_ITEM_CODE, LOGINNAME = woInfo.S_LINE_NO, SHIFT = "None", + STARTLOC = startLoc.S_CODE, }; SpecHelper.InsertInventoryM(target); }); @@ -350,14 +351,106 @@ } /// <summary> + /// 妫�祴鍘熸潗鏂欎骇绾夸笅绾块檮杩戞槸鍚︽湁绌轰綅 + /// </summary> + internal static void CheckEmptyLoc_YclOutLineArea() + { + try + { + var db = new SqlHelper<object>().GetInstance(); + + var endLoc = db.Queryable<TN_Location>(). + Where(o => o.S_AREA_CODE == Settings.Areas[15] + && o.N_LOCK_STATE == 0 + && o.S_LOCK_STATE == "鏃� + && o.C_ENABLE == "Y" + && o.N_CURRENT_NUM == 0 + && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny() + ).//鍘熸潗鏂欎骇绾块檮杩戠┖鎵樺簱鍖�+ First(); + + if (endLoc == null) + { + LogHelper.Info($"鍘熸潗鏂欎骇绾块檮杩戠┖鎵樺簱鍖簕Settings.Areas[15]}锛屽凡婊★紝鏃犻渶鍐嶅叆绌烘墭"); + return; + } + + var startLoc = db.Queryable<TN_Location>(). + Where(o => o.S_AREA_CODE == Settings.Areas[3] + && o.N_LOCK_STATE == 0 + && o.S_LOCK_STATE == "鏃� + && o.C_ENABLE == "Y" + && o.N_CURRENT_NUM == o.N_CAPACITY + && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).Any() + ).ToList().//绌烘墭鍫嗗彔搴撳尯 + FirstOrDefault(); + + if (startLoc == null) + { + startLoc = db.Queryable<TN_Location>(). + Where(o => o.S_AREA_CODE == Settings.Areas[16] + && o.N_LOCK_STATE == 0 + && o.S_LOCK_STATE == "鏃� + && o.C_ENABLE == "Y" + && o.N_CURRENT_NUM == o.N_CAPACITY + && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).Any() + ).ToList().//绌烘墭璐ф灦搴撳尯 + FirstOrDefault(); + } + + if (startLoc == null) + { + LogHelper.Info($"妫�祴鍘熸潗鏂欎骇绾夸笅绾块檮杩戞槸鍚︽湁绌轰綅,璧风偣娌℃湁鎵惧埌鍚堥�鐨勭┖鎵樿揣浣嶏紝瑕佹眰鏈夎揣"); + return; + } + + var cntrList = db.Queryable<TN_Loc_Container>().Where(a => a.S_LOC_CODE == startLoc.S_CODE).OrderBy(a => a.T_CREATE, OrderByType.Asc).ToList(); + + if (cntrList.Count < 1) + { + LogHelper.Info($"妫�祴鍘熸潗鏂欎骇绾夸笅绾块檮杩戞槸鍚︽湁绌轰綅,璧风偣{startLoc.S_CODE}鏈壘鍒拌揣浣嶅鍣ㄥ叧绯讳俊鎭�); + return; + } + + string cntrString = ""; + for (int i = 0; i < cntrList.Count; i++) + { + if (i == cntrList.Count - 1)//鏈�悗涓�釜瀛楃涓茶繛鎺ヤ笉鍔犻�鍙�+ { + cntrString += cntrList[i].S_CNTR_CODE; + } + else + { + cntrString += cntrList[i].S_CNTR_CODE + ","; + } + } + + if (WCSHelper.CreateTask(startLoc.S_CODE, endLoc.S_CODE, "绌烘墭鑷姩涓婄嚎", 3, cntrString))//鍒涘缓鎼�浠诲姟锛岃捣鐐圭粓鐐瑰鍣�+ { + LocationHelper.LockLoc(startLoc.S_CODE, 2);//璧风偣鍑哄簱閿侊紝 + LocationHelper.LockLoc(endLoc.S_CODE, 1);//缁堢偣鍏ュ簱閿�+ + LogHelper.Info($"妫�祴鍘熸潗鏂欎骇绾夸笅绾块檮杩戞槸鍚︽湁绌轰綅,鐢熸垚绌烘墭鑷姩涓婄嚎浠诲姟鎴愬姛锛屽鍣細{cntrString}锛岃捣鐐癸細{startLoc.S_CODE}"); + } + else + { + LogHelper.Info($"妫�祴鍘熸潗鏂欎骇绾夸笅绾块檮杩戞槸鍚︽湁绌轰綅,鐢熸垚绌烘墭鑷姩涓婄嚎浠诲姟澶辫触锛屽鍣細{cntrString}锛岃捣鐐癸細{startLoc.S_CODE}"); + } + } + catch (Exception ex) + { + LogHelper.Error(ex.Message, ex); + } + } + + /// <summary> /// 绾胯竟婊℃墭璐т綅鑷姩瑙g粦 /// </summary> internal static void XBChekcFull() { - var db = new SqlHelper<object>().GetInstance(); try { - + } catch (Exception ex) { @@ -376,22 +469,38 @@ var startLoc = db.Queryable<TN_Location>() .LeftJoin<TN_Loc_Container>((o, i) => o.S_CODE == i.S_LOC_CODE) .LeftJoin<TN_CG_Detail>((o, i, s) => i.S_CNTR_CODE == s.S_CNTR_CODE) - .Where((o, i, s) => s.N_ITEM_STATE == 0 && s.S_ITEM_STATE == "鍚堟牸" + .Where((o, i, s) => + s.N_ITEM_STATE == 6 && s.S_ITEM_STATE == "E绾ф枡" && o.S_AREA_CODE == Settings.Areas[7] && o.N_CURRENT_NUM > 0 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�).First(); + var typename = "澶嶆E绾ф枡鑷姩鍥炲簱"; + + if (startLoc == null) + { + startLoc = db.Queryable<TN_Location>() + .LeftJoin<TN_Loc_Container>((o, i) => o.S_CODE == i.S_LOC_CODE) + .LeftJoin<TN_CG_Detail>((o, i, s) => i.S_CNTR_CODE == s.S_CNTR_CODE) + .Where((o, i, s) => + s.N_ITEM_STATE == 0 && s.S_ITEM_STATE == "鍚堟牸" + && o.S_AREA_CODE == Settings.Areas[7] && o.N_CURRENT_NUM > 0 + && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�).First(); + + typename = "澶嶆鍚堟牸鑷姩鍥炲簱"; + } + + if (startLoc== null) { - LogHelper.Info("澶嶆鍖烘病鏈夊悎鏍肩殑鐗╁搧锛屾棤闇�嚜鍔ㄨ繑鍥�); + LogHelper.Info("澶嶆鍖烘病鏈夊悎鏍肩殑鎴朎绾ф枡鐨勭墿鍝侊紝鏃犻渶鑷姩杩斿洖"); return; } var endLoc = db.Queryable<TN_Location>() - .OrderBy(a => a.N_LAYER, OrderByType.Asc) - .First(a => a.S_AREA_CODE == Settings.Areas[1] + .Where(a => a.S_AREA_CODE == Settings.Areas[1] && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == a.S_CODE).NotAny()//涓嶈兘鏈夎揣 - ); + ).OrderBy(a => a.N_LAYER, OrderByType.Asc).First(); if (endLoc == null) { @@ -403,15 +512,15 @@ .LeftJoin<TN_Loc_Container>((o, i) => o.S_CNTR_CODE == i.S_CNTR_CODE) .Where((o, i) => i.S_LOC_CODE == startLoc.S_CODE).First(); - if (WCSHelper.CreateTask(startLoc.S_CODE, endLoc.S_CODE, "澶嶆鍚堟牸鑷姩鍥炲簱", 3, cginfo.S_CNTR_CODE, out string taskNo, cginfo.S_SPE))//鍒涘缓鎼�浠诲姟锛岃捣鐐圭粓鐐瑰鍣�+ if (WCSHelper.CreateTask(startLoc.S_CODE, endLoc.S_CODE, typename, 3, cginfo.S_CNTR_CODE, out string taskNo, cginfo.S_SPE))//鍒涘缓鎼�浠诲姟锛岃捣鐐圭粓鐐瑰鍣� { LocationHelper.LockLoc(startLoc.S_CODE, 2);//璧风偣鍑哄簱閿侊紝 LocationHelper.LockLoc(endLoc.S_CODE, 1);//缁堢偣鍏ュ簱閿�- LogHelper.Info($"鐢熸垚澶嶆鍚堟牸鑷姩鍥炲簱浠诲姟鎴愬姛锛屽鍣ㄥ彿{cginfo.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}"); + LogHelper.Info($"鐢熸垚{typename}浠诲姟鎴愬姛锛屽鍣ㄥ彿{cginfo.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}"); Task task99 = Task.Run(() => { - WMSHelper.InsertOpInfo("鑷姩杞", "澶嶆鍚堟牸鑷姩鍥炲簱", cginfo.S_CNTR_CODE); + WMSHelper.InsertOpInfo("鑷姩杞", typename, cginfo.S_CNTR_CODE); }); Task task27 = Task.Run(() => @@ -426,6 +535,7 @@ ITEMCODE = cginfo.S_ITEM_CODE, LOGINNAME = "鑷姩杞", SHIFT = "鏃�, + STARTLOC = startLoc.S_CODE, }; SpecHelper.InsertInventoryM(target); }); @@ -434,7 +544,7 @@ } else { - LogHelper.Info($"鐢熸垚澶嶆鍚堟牸鑷姩鍥炲簱浠诲姟澶辫触锛屽鍣ㄥ彿{cginfo.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}"); + LogHelper.Info($"鐢熸垚{typename}浠诲姟澶辫触锛屽鍣ㄥ彿{cginfo.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}"); return; } @@ -442,6 +552,100 @@ catch(Exception ex) { LogHelper.Error("CGOkCheck鍙戠敓浜嗗紓甯�, ex); + } + } + + /// <summary> + /// 鍦ㄥ妫�尯妫�祴鐗╁搧鍥炵倝鑳惰繕鏄姤搴�+ /// </summary> + public static void CGNGCheck() + { + var db = new SqlHelper<object>().GetInstance(); + try + { + // 搴熸枡鐩存帴鍒犻櫎 + var locCntFeiLiao = db.Queryable<TN_CG_Detail>() + .LeftJoin<TN_Loc_Container>((o, i) => o.S_CNTR_CODE == i.S_CNTR_CODE) + .LeftJoin<TN_Location>((o, i, s) => i.S_LOC_CODE == s.S_CODE) + .Where((o, i, s) => + o.N_ITEM_STATE == 9 && o.S_ITEM_STATE == "搴熸枡" + && s.S_AREA_CODE == Settings.Areas[7] && s.N_CURRENT_NUM > 0 + && s.N_LOCK_STATE == 0 && s.S_LOCK_STATE == "鏃�).First(); + + if (locCntFeiLiao != null) + { + var reuslt1 = db.Deleteable<TN_CG_Detail>().Where(a => a.S_CNTR_CODE == locCntFeiLiao.S_CNTR_CODE).ExecuteCommand(); + var reuslt2 = db.Deleteable<TN_Loc_Container>().Where(a => a.S_CNTR_CODE == locCntFeiLiao.S_CNTR_CODE).ExecuteCommand(); + LogHelper.Info($"鍒犻櫎浜嗗簾鏂檣locCntFeiLiao.S_CNTR_CODE},褰卞搷鐨勮鏁帮細{reuslt1}銆亄reuslt2}"); + } + + var startLoc = db.Queryable<TN_Location>() + .LeftJoin<TN_Loc_Container>((o, i) => o.S_CODE == i.S_LOC_CODE) + .LeftJoin<TN_CG_Detail>((o, i, s) => i.S_CNTR_CODE == s.S_CNTR_CODE) + .Where((o, i, s) => + s.N_ITEM_STATE == 8 && s.S_ITEM_STATE == "鍥炵倝鑳� + && o.S_AREA_CODE == Settings.Areas[7] && o.N_CURRENT_NUM > 0 + && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�).First(); + + var typename = "澶嶆鍖哄洖鐐夎兌鑷姩鍥炵倝"; + + if (startLoc == null) + { + LogHelper.Info("澶嶆鍖烘病鏈夊洖鐐夎兌锛屾棤闇�嚜鍔ㄨ繑鍥�); + return; + } + + var cginfo = db.Queryable<TN_CG_Detail>() + .LeftJoin<TN_Loc_Container>((o, i) => o.S_CNTR_CODE == i.S_CNTR_CODE) + .Where((o, i) => i.S_LOC_CODE == startLoc.S_CODE).First(); + + if (cginfo == null) + { + LogHelper.Info($"鏈壘鍒拌捣鐐箋startLoc.S_CODE}鐨勭墿鏂欎俊鎭�); + return; + } + + var endArea = db.Queryable<TN_TN_SPE>().First(a => a.S_SPE == cginfo.S_SPE || a.S_SPE == cginfo.S_ITEM_SPEC); + if (endArea == null || string.IsNullOrWhiteSpace(endArea.S_RETURN_AREA)) + { + LogHelper.Info($"鏈壘鍒拌鏍納cginfo.S_SPE}銆亄cginfo.S_ITEM_SPEC}鐨勮鏍奸厤缃俊鎭�鎶ヨ鐗╂枡鏈厤缃洖鐐夊簱鍖�); + return; + } + + var endLoc = db.Queryable<TN_Location>() + .Where(a => a.S_AREA_CODE == endArea.S_RETURN_AREA + && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� + && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == a.S_CODE).NotAny()//涓嶈兘鏈夎揣 + ).OrderBy(a => a.N_LAYER, OrderByType.Asc).First(); + + if (endLoc == null) + { + LogHelper.Info($"鍥炵倝缁堢偣搴撳尯{endArea.S_RETURN_AREA}宸叉弧鎴栬�宸插叏閮ㄩ攣浣�); + return; + } + + if (WCSHelper.CreateTask(startLoc.S_CODE, endLoc.S_CODE, typename, 3, cginfo.S_CNTR_CODE, out string taskNo, cginfo.S_SPE))//鍒涘缓鎼�浠诲姟锛岃捣鐐圭粓鐐瑰鍣�+ { + LocationHelper.LockLoc(startLoc.S_CODE, 2);//璧风偣鍑哄簱閿侊紝 + LocationHelper.LockLoc(endLoc.S_CODE, 1);//缁堢偣鍏ュ簱閿�+ LogHelper.Info($"鐢熸垚{typename}浠诲姟鎴愬姛锛屽鍣ㄥ彿{cginfo.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}"); + + Task task99 = Task.Run(() => + { + WMSHelper.InsertOpInfo("鑷姩杞", typename, cginfo.S_CNTR_CODE); + }); + + return; + } + else + { + LogHelper.Info($"鐢熸垚{typename}浠诲姟澶辫触锛屽鍣ㄥ彿{cginfo.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}"); + return; + } + } + catch (Exception ex) + { + LogHelper.Error("CGNGCheck鍙戠敓浜嗗紓甯�, ex); } } @@ -520,6 +724,7 @@ ITEMCODE = outTimeCg.S_ITEM_CODE, LOGINNAME = "杩囨湡鍚堟牸鍥炲簱杞", SHIFT = "None", + STARTLOC = startLoc_2.S_CODE, }; SpecHelper.InsertInventoryM(target); }); @@ -548,7 +753,7 @@ { var cntCode = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == startLoc_3.S_CODE); var outTimeCg = db.Queryable<TN_CG_Detail>().First(a => a.S_CNTR_CODE == cntCode.S_CNTR_CODE); - if (WCSHelper.CreateTask(startLoc_3.S_CODE, endLoc_3.S_CODE, "杩囨湡娆″搧鍥炵倝", 3, outTimeCg.S_CNTR_CODE,out string taskno, outTimeCg.S_SPE)) + if (WCSHelper.CreateTask(startLoc_3.S_CODE, endLoc_3.S_CODE, "杩囨湡娆″搧鍥炵倝", 3, outTimeCg.S_CNTR_CODE, out string taskno, outTimeCg.S_SPE)) { LocationHelper.LockLoc(startLoc_3.S_CODE, 2);//璧风偣鍑哄簱閿侊紝 LocationHelper.LockLoc(endLoc_3.S_CODE, 1);//缁堢偣鍏ュ簱閿�@@ -706,14 +911,14 @@ } else { - LogHelper.Info("閲嶉噺鐩哥瓑锛屽悓姝N_DayProDetail璺宠繃"); + //LogHelper.Info("閲嶉噺鐩哥瓑锛屽悓姝N_DayProDetail璺宠繃"); } } } } else { - LogHelper.Info("褰撳ぉ鐨勮揣鍝佽鏍煎垪琛ㄤ负0锛屽悓姝N_DayProDetail璺宠繃"); + //LogHelper.Info("褰撳ぉ鐨勮揣鍝佽鏍煎垪琛ㄤ负0锛屽悓姝N_DayProDetail璺宠繃"); } // 鍚屾 TN_WeekProSpcDetail @@ -744,14 +949,14 @@ } else { - LogHelper.Info("閲嶉噺鐩哥瓑锛屽悓姝N_WeekProSpcDetail璺宠繃"); + //LogHelper.Info("閲嶉噺鐩哥瓑锛屽悓姝N_WeekProSpcDetail璺宠繃"); } } } } else { - LogHelper.Info("褰撳懆鐨勮揣鍝佽鏍煎垪琛ㄤ负0锛屽悓姝N_WeekProSpcDetail璺宠繃"); + //LogHelper.Info("褰撳懆鐨勮揣鍝佽鏍煎垪琛ㄤ负0锛屽悓姝N_WeekProSpcDetail璺宠繃"); } // 鍚屾 TN_MonthProSpcDetail @@ -782,14 +987,14 @@ } else { - LogHelper.Info("閲嶉噺鐩哥瓑锛屽悓姝N_MonthProSpcDetail璺宠繃"); + //LogHelper.Info("閲嶉噺鐩哥瓑锛屽悓姝N_MonthProSpcDetail璺宠繃"); } } } } else { - LogHelper.Info("褰撴湀鐨勮揣鍝佽鏍煎垪琛ㄤ负0锛屽悓姝N_MonthProSpcDetail璺宠繃"); + //LogHelper.Info("褰撴湀鐨勮揣鍝佽鏍煎垪琛ㄤ负0锛屽悓姝N_MonthProSpcDetail璺宠繃"); } // 鍚屾 TN_YearProSpcDetail @@ -821,14 +1026,14 @@ } else { - LogHelper.Info("閲嶉噺鐩哥瓑锛屽悓姝N_YearProSpcDetail璺宠繃"); + //LogHelper.Info("閲嶉噺鐩哥瓑锛屽悓姝N_YearProSpcDetail璺宠繃"); } } } } else { - LogHelper.Info("褰撳勾鐨勮揣鍝佽鏍煎垪琛ㄤ负0锛屽悓姝N_YearProSpcDetail璺宠繃"); + //LogHelper.Info("褰撳勾鐨勮揣鍝佽鏍煎垪琛ㄤ负0锛屽悓姝N_YearProSpcDetail璺宠繃"); } } catch (Exception ex) @@ -907,7 +1112,7 @@ } /// <summary> - /// 妫�祴婊℃墭缂撳瓨搴撳尯涓嶅悎鏍肩殑鐗╁搧锛屾弧鎵樺嚭搴撳妫�+ /// 妫�祴婊℃墭缂撳瓨搴撳尯涓嶅悎鏍肩殑鐗╁搧锛屾弧鎵樺嚭搴撳埌澶嶆鍖猴紝鏇夸唬浜嗘媶鐩樺嚭搴� /// </summary> internal static void CheckNoOkCg() { @@ -988,12 +1193,29 @@ } var endLoc = db.Queryable<TN_Location>(). - Where(a => a.S_AREA_CODE == Settings.Areas[4] && a.N_LOCK_STATE == 0 + Where(a => a.S_AREA_CODE == Settings.Areas[15] && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && a.N_CURRENT_NUM == 0 && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == a.S_CODE).NotAny() - ). - OrderBy(a => a.N_CURRENT_NUM, OrderByType.Asc). - First(); + ).First();//鍏堟壘 鍘熸潗鏂欎骇绾块檮杩戠┖鎵樺簱鍖�+ + if (endLoc == null) + { + endLoc = db.Queryable<TN_Location>(). + Where(a => a.S_AREA_CODE == Settings.Areas[16] && a.N_LOCK_STATE == 0 + && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && a.N_CURRENT_NUM == 0 + && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == a.S_CODE).NotAny() + ).First(); + }// 鍐嶆壘 绌烘墭璐ф灦搴撳尯 + + if (endLoc == null) + { + endLoc = db.Queryable<TN_Location>(). + Where(a => a.S_AREA_CODE == Settings.Areas[4] && a.N_LOCK_STATE == 0 + && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && a.N_CURRENT_NUM == 0 + && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == a.S_CODE).NotAny() + ).First(); + }// 鏈�悗鎵�绌烘墭缂撳瓨搴撳尯 + if (endLoc == null) { -- Gitblit v1.9.1