From 19598c8162599f635fb340cf6981bf21f11745ae Mon Sep 17 00:00:00 2001 From: czw <selecti@yeah.net> Date: 星期五, 20 六月 2025 22:36:53 +0800 Subject: [PATCH] 1 --- HH.WCS.QingXiNongfu/core/Monitor.cs | 498 ++++++++++++++++++++++++++++++------------------------ 1 files changed, 276 insertions(+), 222 deletions(-) diff --git a/HH.WCS.QingXiNongfu/core/Monitor.cs b/HH.WCS.QingXiNongfu/core/Monitor.cs index 6f2dfef..7a90c6f 100644 --- a/HH.WCS.QingXiNongfu/core/Monitor.cs +++ b/HH.WCS.QingXiNongfu/core/Monitor.cs @@ -850,7 +850,7 @@ { var locs = LocationHelper.GetList<Location>(x => x.S_AREA_CODE == item.S_AREA_CODE && x.N_ROW == item.N_ROW); if (locs.Find(x => x.N_CURRENT_NUM > 0) == null) - LocationHelper.SetRowLock(item, 0); + WCSHelper.Do(db => db.Deleteable(item).ExecuteCommand()); } } Rlock = Rlocks.FindAll(x => x.S_LOCK_STATE.Contains("鍏ュ簱閿�)); @@ -867,15 +867,15 @@ // LocationHelper.SetRowLock(item, 0); //} //濡傛灉涓�帓鍐呮棤璐с�涔熸棤閿併� 鍙兘鏄墿鏂欑殑鍏ュ簱鍙栨秷浜嗐� 鍙栨秷褰撳墠鎺掗攣锛岄槻姝㈠悗缁笉鍏ヨ繖涓墿鏂欎簡渚濈劧鍗犵潃鎺掋� - if (locs.Find(x => x.N_CURRENT_NUM > 0) == null && locs.Find(x => x.S_LOCK_STATE != "鏃�) == null) LocationHelper.SetRowLock(item, 0); + if (locs.Find(x => x.N_CURRENT_NUM > 0) == null && locs.Find(x => x.S_LOCK_STATE != "鏃�) == null) WCSHelper.Do(db => db.Deleteable(item).ExecuteCommand()); else { var lastloC = locs.OrderByDescending(x => x.N_COL).FirstOrDefault(); - if (lastloC.N_CURRENT_NUM == lastloC.N_CAPACITY) LocationHelper.SetRowLock(item, 0); + if (lastloC.N_CURRENT_NUM == lastloC.N_CAPACITY) WCSHelper.Do(db => db.Deleteable(item).ExecuteCommand()); + else if (new List<string>() { "YWLAQWJ", "YWLBQWJ", "YWLCQSX", "YWLDQWJ" }.Contains(item.S_AREA_CODE)) WCSHelper.Do(db => db.Deleteable(item).ExecuteCommand()); } } } - } /// <summary> @@ -1009,16 +1009,17 @@ static bool InworkLock = false; /// <summary> /// 鍘熸潗鏂�妫�祴鍚勬祦杞綅缃� 鍐欏叆鎵樼洏璐т綅s_type 涓�涓嬩竴涓洰鐨勫湴銆傚氨寮�涓浆銆�- /// 2025.4.8 - /// 1.娓呮邯鍘熸潗鏂欐祴璇曚笌鎴愬搧鎷嗗垎 - /// 2.杩涘嚭鍙e崟鎹笌CS寮傚父澶勭悊 + /// 鍘熺墿鏂欑焊绠憋紝鍏ュ簱鍫嗗彔鍖鸿浆杩� /// </summary> internal static void BottTask() { //InworkLock = false; var usingSpace = new List<string> { "鍏ュ簱鎺ラ┏鍖�, "搴撳唴鎺ラ┏鍖�, "鍑哄簱鎺ラ┏鍖�, "鎻愬崌鏈洪�鏂欏彛" }; //usingSpace = new List<string> { "YWLRGDD", "YWLWJJB", "YWLYLTKQ", "YWLTKKTQ", "YWLKTDDQ", "YWLT1TSJ", "YWLT1TSJCD", "YWLT2TSJ", "YWLT2TSJCD" }; - usingSpace = new List<string> { "YWLRGDD", "YWLWJJB", "YWLYLTKQ", "YWLTKKTQ", "YWLT1TSJ", "YWLT2TSJ" }; + usingSpace = new List<string> { "YWLYLTKQ", "YWLTKKTQ", "YWLWJJB", "YWLRGDD", "YWLT1TSJ", "YWLT2TSJ" }; + ///----------------------------閫�綑鏂欎腑闂村簱鍖猴紝閫�┖涓棿搴撳尯锛�+ /// /*鎵樼洏璐т綅琛ㄧ殑 S_TYPE銆� 搴撳尯1,搴撳尯,*/ + foreach (var area in usingSpace) { try @@ -1043,6 +1044,7 @@ if (!cntritems.Any()) continue; var cir1 = cntritems.First(); + //鍙瓫閫夌焊绠辩墿鏂欑殑搴撳尯鏁版嵁銆� if (!string.IsNullOrEmpty(cir1.S_ITEM_NAME) && cir1.S_ITEM_NAME.Contains("绾哥-")) if (dsll.TryGetValue(cir1.S_ITEM_CODE, out List<Location> ll)) { @@ -1259,6 +1261,9 @@ public static string RK_BQCDQ = "SXBQDDKQ"; } + /// <summary> + /// 鎻愭墸 銆傛爣绛俱�PE鑶滃嚭搴�+ /// </summary> internal static void YwlTKPEBQ_Auto() { LogHelper.CoCo(DateTime.Now + "鏍囩-鎻愭墸-PE鑶�>>>>>>>>>>>> ", ConsoleColor.Cyan); @@ -1285,7 +1290,8 @@ S_CNTR_CODE = cir.S_CNTR_CODE }) .ToList(); - + /// 浜哄伐鍫嗗彔鍖虹焊绠�鍜�鏍囩 鏄寜鏍囪瘑+鐗╂枡绛涢�杩涜鍏ュ簱杞繍銆� + /// 鐗╂枡鍚嶇О鍖呭惈瀵瑰簲绉嶇被杩涜鍏ュ簱銆� var locsFirst = locsFirstA.FindAll(x => x.S_NOTE.Contains("鏍囩-") && x.S_TYPE == WJ_BQ.RK_BBHJQ); var SlocsFirst = locsFirstA.FindAll(x => x.S_NOTE.Contains("鏍囩-") && x.S_TYPE == SX_BQ.RK_BBHJQ); var TKlocsFirst = locsFirstA.FindAll(x => x.S_NOTE.Contains("鎻愭墸-")); @@ -1302,16 +1308,19 @@ { try { - var yuworders = LocationHelper.GetList<YWLWorkOrder>(x => x.SQL_PLineNo == "鏃犺弻鏍囩鍑哄簱" && x.WorkType == 6 && x.SQL_State == "鎵ц涓�).FindAll(x => DateTime.Now.Subtract(x.SQL_Modify_TIme ?? DateTime.Now).TotalSeconds > 10).OrderBy(x => !string.IsNullOrEmpty(x.TagOver) ? 1 : 2).ThenBy(x => x.TagOverTime).ToList(); + var yuworders = LocationHelper.GetList<YWLWorkOrder>(x => x.SQL_PLineNo == "鏃犺弻鏍囩鍑哄簱" && x.WorkType == 6 && x.SQL_State == "鎵ц涓�).FindAll(x => x.OutNum > 0 && DateTime.Now.Subtract(x.SQL_Modify_TIme ?? DateTime.Now).TotalSeconds > 10).OrderBy(x => !string.IsNullOrEmpty(x.TagOver) ? 1 : 2).ThenBy(x => x.TagOverTime).ToList(); if (!yuworders.Any()) { YwlBQ_CreInwork(locsFirst, WJ_BQ.RK_BQDDQ, WJ_BQ.RK_BBHJQ); } else { - LogHelper.Info($" 鏃犺弻鍑哄簱 宸ュ崟寮�惎涓�); + LogHelper.Info($" 鏃犺弻鍑哄簱 宸ュ崟寮�惎涓�"); + // 鏍囩鍑哄簱銆傝揣鏋剁洿鎺ュ嚭鍒扮嚎杈� YwlBQ_CreWJOutOrder(); } + + // 鏍囩鏃犺弻閫�簱銆� YwlBQ_CreWJTK(); } catch (Exception ex) @@ -1435,6 +1444,15 @@ { var srloclist = rs.OrderBy(x => x.N_COL).ToList(); var lastfull = srloclist.FindAll(x => x.N_CURRENT_NUM > 0).LastOrDefault(); + if (lastfull != null) + { + var c = LocationHelper.GetList<LocCntrRel>(x => x.S_LOC_CODE == lastfull.S_LOC_CODE); + var xcirs = ContainerHelper.GetCntrItemRel(c.FirstOrDefault().S_CNTR_CODE); + if (!xcirs.Any()) continue; + var xcir = xcirs.OrderByDescending(x => x.T_CREATE).FirstOrDefault(); + if (cir.S_ITEM_CODE != xcir.S_ITEM_CODE || cir.S_ITEM_NAME != xcir.S_ITEM_NAME || xcir.S_CJ_NAME != cir.S_CJ_NAME) + continue; + } EndBit = srloclist.Find(x => x.S_LOCK_STATE == "鏃� && x.N_CURRENT_NUM < Math.Min(x.N_CAPACITY, 3) && x.S_LOCK_STATE != "鎶ュ簾" && x.N_COL >= (lastfull?.N_COL ?? 0)); if (EndBit != null) break; @@ -1721,13 +1739,13 @@ Console.WriteLine($"{v.FirstOrDefault()?.S_LOC_CODE} 闇�閫�簱-- 鑷姩閫�簱-鏈疄鐜�); } } - + //鏍囩閫�簱銆�绾胯竟杞埌 璐ф灦銆� private static void YwlBQ_CreWJTK() { var db = new SqlHelper<object>().GetInstance(); var v = db.Queryable<Location>(). LeftJoin<LocCntrRel>((l, c) => l.S_LOC_CODE == c.S_LOC_CODE) - .Where((l, c) => (l.S_AREA_CODE == WJ_BQ.RK_XBKQ || l.S_AREA_CODE == WJ_BQ.RK_BQJBQ) && c.S_TYPE == BQ_PRA.B) + .Where((l, c) => (l.S_AREA_CODE == WJ_BQ.RK_XBKQ /*|| l.S_AREA_CODE == WJ_BQ.RK_BQJBQ*/) && c.S_TYPE == BQ_PRA.B) .ToList(); if (v.Any()) { @@ -1750,45 +1768,46 @@ { var s_type = ContainerHelper.GetCntrItemRel(CNTR.FirstOrDefault().S_CNTR_CODE).FirstOrDefault()?.N_BQ_TRAY_TYPE ?? 0; Location Endbit = null; - if (area == WJ_BQ.RK_BQJBQ) + if (area == area/* WJ_BQ.RK_BQJBQ*/) { var hjs = LocationHelper.GetAreaNormalLocList(WJ_BQ.RK_BBHJQ, true, false); Endbit = hjs.FindAll(x => x.N_CURRENT_NUM == 0 && x.N_LAYER == (s_type == .5 ? 1 : (s_type == .75 ? 2 : 3))).OrderBy(x => x.N_ROW).ThenBy(x => x.N_COL).FirstOrDefault(); if (Endbit != null) { - var re = TaskProcess.CreateTransport("", lastfull.S_LOC_CODE.Trim(), Endbit.S_LOC_CODE, "鏍囩鍙夎繍-鎺ラ┏鏍囩閫�簱", CNTR.Select(x => x.S_CNTR_CODE).ToList(), 1, 1, 1, 62); + var re = TaskProcess.CreateTransport("", lastfull.S_LOC_CODE.Trim(), Endbit.S_LOC_CODE, "鏍囩鍙夎繍-绾胯竟鏍囩閫�簱", CNTR.Select(x => x.S_CNTR_CODE).ToList(), 1, 1, 1, 62); LogHelper.CSucessLog($"from {lastfull.S_LOC_CODE} to {Endbit.S_LOC_CODE} 鏍囩鍙夎繍-鎺ラ┏鏍囩閫�簱 锛屽垱寤簕re}"); } } - else - { - var jbqs = LocationHelper.GetAreaNormalLocList(WJ_BQ.RK_BQJBQ); - foreach (var rowloc in jbqs.GroupBy(x => x.N_ROW)) - { - var y2 = rowloc.OrderBy(x => x.N_COL).ToList(); - var l2 = y2.FindAll(x => x.N_CURRENT_NUM > 0).LastOrDefault(); - if (l2 != null && l2.N_CURRENT_NUM > 0) - { - var c = LocationHelper.GetList<LocCntrRel>(x => x.S_LOC_CODE == l2.S_LOC_CODE); - if (c.FirstOrDefault()?.S_TYPE != BQ_PRA.B) - { - continue; - } - var xcirs = ContainerHelper.GetCntrItemRel(c.FirstOrDefault().S_CNTR_CODE); - if (!xcirs.Any()) continue; - var xcir = xcirs.OrderByDescending(x => x.T_CREATE).FirstOrDefault(); - if (cir.S_ITEM_CODE != xcir.S_ITEM_CODE || cir.S_ITEM_NAME != xcir.S_ITEM_NAME) - continue; - } - var e = y2.Find(x => x.N_COL > (l2?.N_COL ?? 0) && x.N_CURRENT_NUM == 0); - if (e != null) - { - var re = TaskProcess.CreateTransport("", lastfull.S_LOC_CODE.Trim(), e.S_LOC_CODE, "鏍囩鍙夎繍-绾胯竟鏍囩閫�簱", new List<string> { CNTR.FirstOrDefault().S_CNTR_CODE }, 1, 1, 1, 62, BQ_PRA.B); - LogHelper.Info($"from {lastfull.S_LOC_CODE} to {e.S_LOC_CODE} 鏍囩鍙夎繍-绾胯竟鏍囩閫�簱 锛屽垱寤簕re} "); - break; - } - } - } + + //else + //{ + // var jbqs = LocationHelper.GetAreaNormalLocList(WJ_BQ.RK_BQJBQ); + // foreach (var rowloc in jbqs.GroupBy(x => x.N_ROW)) + // { + // var y2 = rowloc.OrderBy(x => x.N_COL).ToList(); + // var l2 = y2.FindAll(x => x.N_CURRENT_NUM > 0).LastOrDefault(); + // if (l2 != null && l2.N_CURRENT_NUM > 0) + // { + // var c = LocationHelper.GetList<LocCntrRel>(x => x.S_LOC_CODE == l2.S_LOC_CODE); + // if (c.FirstOrDefault()?.S_TYPE != BQ_PRA.B) + // { + // continue; + // } + // var xcirs = ContainerHelper.GetCntrItemRel(c.FirstOrDefault().S_CNTR_CODE); + // if (!xcirs.Any()) continue; + // var xcir = xcirs.OrderByDescending(x => x.T_CREATE).FirstOrDefault(); + // if (cir.S_ITEM_CODE != xcir.S_ITEM_CODE || cir.S_ITEM_NAME != xcir.S_ITEM_NAME) + // continue; + // } + // var e = y2.Find(x => x.N_COL > (l2?.N_COL ?? 0) && x.N_CURRENT_NUM == 0); + // if (e != null) + // { + // var re = TaskProcess.CreateTransport("", lastfull.S_LOC_CODE.Trim(), e.S_LOC_CODE, "鏍囩鍙夎繍-绾胯竟鏍囩閫�簱", new List<string> { CNTR.FirstOrDefault().S_CNTR_CODE }, 1, 1, 1, 62, BQ_PRA.B); + // LogHelper.Info($"from {lastfull.S_LOC_CODE} to {e.S_LOC_CODE} 鏍囩鍙夎繍-绾胯竟鏍囩閫�簱 锛屽垱寤簕re} "); + // break; + // } + // } + //} } } } @@ -2253,7 +2272,7 @@ } /// <summary> - /// + /// 鏍囩鍏ュ簱銆�浠庝汉宸ョ粦瀹氬尯 鍒�璐ф灦鍖恒� /// </summary> /// <param name="locsFirst"></param> internal static void YwlBQ_CreInwork(List<locCntItem> locsFirst, string RK_BQDDQ, string RK_BBHJQ) @@ -2467,73 +2486,74 @@ LogHelper.Info($" 鏃犺弻鍑哄簱 寮�"); //1.妫�煡鏄惁鏈夐�搴� var db = new SqlHelper<object>().GetInstance(); - ///绗笁娈碉細鎺ラ┏鍖�杞�绾胯竟 - var JQBS = LocationHelper.GetAreaNormalLocList(WJ_BQ.RK_BQJBQ); - foreach (var jbr in JQBS.GroupBy(x => x.N_ROW)) + + if (false) { - LogHelper.Info($" 鏃犺弻鍑哄簱 鎺ラ┏鏈夋暟鎹�); - var y2 = jbr.OrderBy(x => x.N_COL).ToList(); - var l2 = y2.FindAll(x => x.N_CURRENT_NUM > 0).LastOrDefault(); - if (l2 != null) + ///绗笁娈碉細鎺ラ┏鍖�杞�绾胯竟 + var JQBS = LocationHelper.GetAreaNormalLocList(WJ_BQ.RK_BQJBQ); + foreach (var jbr in JQBS.GroupBy(x => x.N_ROW)) { - var c = LocationHelper.GetList<LocCntrRel>(x => x.S_LOC_CODE == l2.S_LOC_CODE); - if (!c.Any() || c.FirstOrDefault()?.S_TYPE == BQ_PRA.B) + LogHelper.Info($" 鏃犺弻鍑哄簱 鎺ラ┏鏈夋暟鎹�); + var y2 = jbr.OrderBy(x => x.N_COL).ToList(); + var l2 = y2.FindAll(x => x.N_CURRENT_NUM > 0).LastOrDefault(); + if (l2 != null) { - //鍥炲簱銆�- LogHelper.Info($"寰幆鏈夋棤閫�簱==> 鏈�閫�簱" + l2.S_LOC_CODE); - continue; - } - var cirs = ContainerHelper.GetCntrItemRel(c.FirstOrDefault().S_CNTR_CODE); - if (!cirs.Any()) - { - LogHelper.Info($"寰幆鏈夋棤閫�簱==> 娌℃湁鐗╂枡淇℃伅 鎵樼洏:" + c.FirstOrDefault().S_CNTR_CODE); - continue; - } - var cir = cirs.OrderByDescending(x => x.T_CREATE).FirstOrDefault(); - - var xbqs = LocationHelper.GetAreaNormalLocList(WJ_BQ.RK_XBKQ); - foreach (var x1 in xbqs.GroupBy(x => x.N_ROW)) - { - LogHelper.Info($" 鏃犺弻鍑哄簱 绾胯竟鏈夋暟鎹�); - var x2 = x1.OrderBy(x => x.N_COL).ToList(); - var l3 = x2.FindAll(x => x.N_CURRENT_NUM > 0).LastOrDefault(); - if (l3 != null) + var c = LocationHelper.GetList<LocCntrRel>(x => x.S_LOC_CODE == l2.S_LOC_CODE); + if (!c.Any() || c.FirstOrDefault()?.S_TYPE == BQ_PRA.B) { - var xc = LocationHelper.GetList<LocCntrRel>(x => x.S_LOC_CODE == l3.S_LOC_CODE); - if (!xc.Any() || xc.FirstOrDefault()?.S_TYPE == BQ_PRA.B) - { - LogHelper.Info($"寰幆绾胯竟==> 鏈�閫�簱" + xc.FirstOrDefault()?.S_TYPE); - continue; - } - var xcirs = ContainerHelper.GetCntrItemRel(xc.FirstOrDefault().S_CNTR_CODE); - if (!xcirs.Any()) - { - LogHelper.Info($"寰幆绾胯竟==> 娌℃湁鐗╂枡淇℃伅 鎵樼洏:" + xc.FirstOrDefault().S_CNTR_CODE); - continue; - } - - var xcir = xcirs.OrderByDescending(x => x.T_CREATE).FirstOrDefault(); - if (xcir.S_ITEM_CODE != cir.S_ITEM_CODE || xcir.S_ITEM_NAME != cir.S_ITEM_CODE) - { - LogHelper.Info($"寰幆绾胯竟==> 鐗╂枡涓嶅尮閰�鎵樼洏:" + xc.FirstOrDefault().S_CNTR_CODE); - continue; - } + //鍥炲簱銆�+ LogHelper.Info($"寰幆鏈夋棤閫�簱==> 鏈�閫�簱" + l2.S_LOC_CODE); + continue; } - var e = x2.FindAll(x => x.N_COL > (l3?.N_COL ?? 0) && x.N_CURRENT_NUM == 0).FirstOrDefault(); - LogHelper.Info($"鏃犺弻 鐢熸垚浠诲姟==> 鏄惁鏈夊悎閫傜殑璐т綅淇℃伅" + e?.S_LOC_CODE); - if (e != null) + var cirs = ContainerHelper.GetCntrItemRel(c.FirstOrDefault().S_CNTR_CODE); + if (!cirs.Any()) { - var re = TaskProcess.CreateTransport("", l2.S_LOC_CODE.Trim(), e.S_LOC_CODE, "鏍囩鍙夎繍-鎺ラ┏杞嚎杈�, new List<string> { c.FirstOrDefault().S_CNTR_CODE }, 1, 1, 1, 62, BQ_PRA.Out); - LogHelper.Info($"from {l2.S_LOC_CODE} to {e.S_LOC_CODE} 鏍囩鍙夎繍-鎺ラ┏杞嚎杈�锛屽垱寤簕re} "); - break; + LogHelper.Info($"寰幆鏈夋棤閫�簱==> 娌℃湁鐗╂枡淇℃伅 鎵樼洏:" + c.FirstOrDefault().S_CNTR_CODE); + continue; + } + var cir = cirs.OrderByDescending(x => x.T_CREATE).FirstOrDefault(); + + var xbqs = LocationHelper.GetAreaNormalLocList(WJ_BQ.RK_XBKQ); + foreach (var x1 in xbqs.GroupBy(x => x.N_ROW)) + { + LogHelper.Info($" 鏃犺弻鍑哄簱 绾胯竟鏈夋暟鎹�); + var x2 = x1.OrderBy(x => x.N_COL).ToList(); + var l3 = x2.FindAll(x => x.N_CURRENT_NUM > 0).LastOrDefault(); + if (l3 != null) + { + var xc = LocationHelper.GetList<LocCntrRel>(x => x.S_LOC_CODE == l3.S_LOC_CODE); + if (!xc.Any() || xc.FirstOrDefault()?.S_TYPE == BQ_PRA.B) + { + LogHelper.Info($"寰幆绾胯竟==> 鏈�閫�簱" + xc.FirstOrDefault()?.S_TYPE); + continue; + } + var xcirs = ContainerHelper.GetCntrItemRel(xc.FirstOrDefault().S_CNTR_CODE); + if (!xcirs.Any()) + { + LogHelper.Info($"寰幆绾胯竟==> 娌℃湁鐗╂枡淇℃伅 鎵樼洏:" + xc.FirstOrDefault().S_CNTR_CODE); + continue; + } + + var xcir = xcirs.OrderByDescending(x => x.T_CREATE).FirstOrDefault(); + if (xcir.S_ITEM_CODE != cir.S_ITEM_CODE || xcir.S_ITEM_NAME != cir.S_ITEM_CODE) + { + LogHelper.Info($"寰幆绾胯竟==> 鐗╂枡涓嶅尮閰�鎵樼洏:" + xc.FirstOrDefault().S_CNTR_CODE); + continue; + } + } + var e = x2.FindAll(x => x.N_COL > (l3?.N_COL ?? 0) && x.N_CURRENT_NUM == 0).FirstOrDefault(); + LogHelper.Info($"鏃犺弻 鐢熸垚浠诲姟==> 鏄惁鏈夊悎閫傜殑璐т綅淇℃伅" + e?.S_LOC_CODE); + if (e != null) + { + var re = TaskProcess.CreateTransport("", l2.S_LOC_CODE.Trim(), e.S_LOC_CODE, "鏍囩鍙夎繍-鎺ラ┏杞嚎杈�, new List<string> { c.FirstOrDefault().S_CNTR_CODE }, 1, 1, 1, 62, BQ_PRA.Out); + LogHelper.Info($"from {l2.S_LOC_CODE} to {e.S_LOC_CODE} 鏍囩鍙夎繍-鎺ラ┏杞嚎杈�锛屽垱寤簕re} "); + break; + } } } } - } - LogHelper.Info($" 鏃犺弻鍑哄簱 鍒扮嚎杈�缁撴潫"); - ///鎷嗗灈鍖哄彇娑堛� - if (false) - { + LogHelper.Info($" 鏃犺弻鍑哄簱 鍒扮嚎杈�缁撴潫"); + ///鎷嗗灈鍖哄彇娑堛� ///绗簩娈碉細鎷嗗灈鍖恒�鎷嗗幓鎺ラ┏銆�鎴栬�鍥炲簱銆� var v = LocationHelper.GetAreaNormalLocList(WJ_BQ.RK_BQCDQ); ///鎷嗗灈鐨勫嚭搴撱� 鍗曞眰鐨勫洖搴� 鍗曞眰涓嶅叆鎷嗗灈鍖�@@ -2588,6 +2608,7 @@ } } } + ///绗竴娈碉細鍑哄簱 -鍒版媶鍨涙垨鑰�鎺ラ┏銆� var yuworders = LocationHelper.GetList<YWLWorkOrder>(x => x.SQL_PLineNo == "鏃犺弻鏍囩鍑哄簱" && x.WorkType == 6 && x.SQL_State == "鎵ц涓�).FindAll(x => x.OutNum > 0 && DateTime.Now.Subtract(x.SQL_Modify_TIme ?? DateTime.Now).TotalSeconds > 10).OrderBy(x => !string.IsNullOrEmpty(x.TagOver) ? 1 : 2).ThenBy(x => x.TagOverTime).ToList(); @@ -2651,7 +2672,7 @@ if (tagLoc.N_LAYER == 1 || tagLoc.N_CURRENT_NUM == 1) { // 鐩存帴鍑烘帴椹充綅 - var jbqs = LocationHelper.GetAreaNormalLocList(WJ_BQ.RK_BQJBQ); + var jbqs = LocationHelper.GetAreaNormalLocList(WJ_BQ.RK_XBKQ); foreach (var rowloc in jbqs.GroupBy(x => x.N_ROW)) { var y2 = rowloc.OrderBy(x => x.N_COL).ToList(); @@ -2663,16 +2684,16 @@ { continue; } - var cirs = ContainerHelper.GetCntrItemRel(c.FirstOrDefault().S_CNTR_CODE); - if (!cirs.Any()) continue; - var cir = cirs.OrderByDescending(x => x.T_CREATE).FirstOrDefault(); - if (cir.S_ITEM_CODE != tagLoc.S_ITEM_CODE || cir.S_ITEM_NAME != tagLoc.S_ITEM_NAME) - continue; + //var cirs = ContainerHelper.GetCntrItemRel(c.FirstOrDefault().S_CNTR_CODE); + //if (!cirs.Any()) continue; + //var cir = cirs.OrderByDescending(x => x.T_CREATE).FirstOrDefault(); + //if (cir.S_ITEM_CODE != tagLoc.S_ITEM_CODE || cir.S_ITEM_NAME != tagLoc.S_ITEM_NAME) + // continue; } var e = y2.FindAll(x => x.N_COL > (l2?.N_COL ?? 0) && x.N_CURRENT_NUM == 0).FirstOrDefault(); if (e != null) { - var re = TaskProcess.CreateTransport("", tagLoc.S_LOC_CODE.Trim(), e.S_LOC_CODE, "鏍囩鍙夎繍-璐ф灦鍑烘帴椹�, new List<string> { tagLoc.S_CNTR_CODE }, 1, 1, 1, 62); + var re = TaskProcess.CreateTransport("", tagLoc.S_LOC_CODE.Trim(), e.S_LOC_CODE, "鏍囩鍙夎繍-璐ф灦鍑虹嚎杈�, new List<string> { tagLoc.S_CNTR_CODE }, 1, 1, 1, 62); LogHelper.Info($"from {tagLoc.S_LOC_CODE} to {e.S_LOC_CODE} 鏍囩鍙夎繍-璐ф灦鍑烘帴椹�锛屽垱寤簕re} "); if (re) oto.Add(item); @@ -3005,7 +3026,7 @@ if (endBit != null) { LogHelper.Info($"{spn} - 鍘讳腑杞尯锛屾壘鍒颁綅缃畕endBit.S_LOC_CODE}"); - bool bb = TaskProcess.CreateTransport(order.SQL_WorkNo, strBit.S_LOC_CODE, endBit.S_LOC_CODE, spn + "涓浆鍘�, new List<string> { crl.S_CNTR_CODE }, strBit.N_CURRENT_NUM, endBit.N_CURRENT_NUM++, 1, 50, crl.S_TYPE); + bool bb = TaskProcess.CreateTransport(order.SQL_WorkNo, strBit.S_LOC_CODE, endBit.S_LOC_CODE, spn + "涓浆鍘�, new List<string> { crl.S_CNTR_CODE }, strBit.N_CURRENT_NUM, endBit.N_CURRENT_NUM + 1, 1, 50, crl.S_TYPE); LogHelper.Info($"{spn}鏈紑锛岀炕鏂楁満寮��绾跨▼锛屽垱寤哄幓{areaList}涓浆鍖虹殑浠诲姟{(bb ? "鎴愬姛" : "澶辫触")}"); if (bb && needBread) { @@ -3300,6 +3321,7 @@ LogHelper.Info($"澶囪揣鍗曪細{outOer.S_Work_NO} 鏈�悗绉诲簱搴撳尯{ea} - 鎺抺er} 鎬庝箞浠栧鏄┖鐨勶紒锛侊紒璇′簡涓紓鐨�); } } + eaaa: if (string.IsNullOrEmpty(end_area)) { @@ -3380,7 +3402,6 @@ //} } } - if (string.IsNullOrEmpty(start_area) || string.IsNullOrEmpty(start_row) @@ -3544,7 +3565,7 @@ public static void AutoRun13TSJ() { var list = new List<string>() { "YWLAQWJ", "YWLBQWJ", "YWLCQSX", "YWLDQWJ" }; - var WorkOrder = new List<YWLWorkOrder>(); + //var WorkOrder = new List<YWLWorkOrder>(); foreach (var PLC in Settings.GetDeviceInfoList().FindAll(X => X.deviceType == 13 && X.enable == 1)) { string pline = PLC.deviceName; @@ -3552,7 +3573,6 @@ pline = "T2鎻愬崌鏈�绾哥"; var orkOrd = LocationHelper.GetList<YWLWorkOrder>(x => x.SQL_PLineNo == pline && x.WorkType == 6 && x.SQL_State == "鎵ц涓�); - orkOrd = orkOrd.FindAll(x => DateTime.Now.Subtract(x.SQL_Modify_TIme ?? DateTime.Now).TotalSeconds > 10); bool can = false; if (orkOrd.Any()) { @@ -3564,42 +3584,47 @@ continue; can = true; - foreach (var item in list) - { - YWLWorkOrder source = new YWLWorkOrder(); - var source1 = orkOrd.FirstOrDefault(); - source.SQL_PLineNo = source1.SQL_PLineNo; - source.FuLe_PLine_No = source1.FuLe_PLine_No; - source.SQL_LinkLineNO = source1.SQL_LinkLineNO; - source.SQL_Area = item; - source.SQL_UsingNow = source1.SQL_UsingNow; - source.SQL_State = source1.SQL_State; - source.SQL_WorkNo = source1.SQL_WorkNo; - source.SQL_ItemCode = source1.SQL_ItemCode; - source.SQL_ItemName = source1.SQL_ItemName; - source.SQL_charge = source1.SQL_charge; - source.SQL_Total = source1.SQL_Total; - source.SQL_PLAN_END = source1.SQL_PLAN_END; - source.SQL_Modify_TIme = source1.SQL_Modify_TIme; - source.OutNum = source1.OutNum; - source.WorkType = source1.WorkType; - source.MidArea = source1.MidArea; - source.TagOver = source1.TagOver; - source.TagOverTime = source1.TagOverTime; - source.S_BQ_TRAY_TYPE = source1.S_BQ_TRAY_TYPE; - source.S_CJ_NAME = source1.S_CJ_NAME; - source.S_ROW = item; - WorkOrder.Add(source); - } + //var source1 = orkOrd.FirstOrDefault(); + //foreach (var item in list) + //{ + // YWLWorkOrder source = new YWLWorkOrder(); + // source.SQL_PLineNo = source1.SQL_PLineNo; + // source.FuLe_PLine_No = source1.FuLe_PLine_No; + // source.SQL_LinkLineNO = source1.SQL_LinkLineNO; + // source.SQL_Area = item; + // source.SQL_UsingNow = source1.SQL_UsingNow; + // source.SQL_State = source1.SQL_State; + // source.SQL_WorkNo = source1.SQL_WorkNo; + // source.SQL_ItemCode = source1.SQL_ItemCode; + // source.SQL_ItemName = source1.SQL_ItemName; + // source.SQL_charge = source1.SQL_charge; + // source.SQL_Total = source1.SQL_Total; + // source.SQL_PLAN_END = source1.SQL_PLAN_END; + // source.SQL_Modify_TIme = source1.SQL_Modify_TIme; + // source.OutNum = source1.OutNum; + // source.WorkType = source1.WorkType; + // source.MidArea = source1.MidArea; + // source.TagOver = source1.TagOver; + // source.TagOverTime = source1.TagOverTime; + // source.S_BQ_TRAY_TYPE = source1.S_BQ_TRAY_TYPE; + // source.S_CJ_NAME = source1.S_CJ_NAME; + // source.S_ROW = item; + // WorkOrder.Add(source); + //} } + + orkOrd = orkOrd.FindAll(x => x.OutNum > 0 && DateTime.Now.Subtract(x.SQL_Modify_TIme ?? DateTime.Now).TotalSeconds > 10); ReadCCK = can; if (orkOrd.Any()) - // foreach (var od in orkOrd.OrderByDescending(x => x.OutNum)) - foreach (var od in WorkOrder) + foreach (var od in orkOrd.OrderBy(x => x.TagOverTime).ThenBy(x => x.OutNum)) + //foreach (var od in od2.ToList()) { + var l2 = new List<string>() { "YWLAQWJ", "YWLBQWJ", "YWLCQSX", "YWLDQWJ" }; + l2.Remove(od.S_ROW); + var odsr = new List<string> { od.S_ROW }.Concat(l2).Distinct().ToList(); ///姹囨�浠撳簱閲屾渶澶у眰鏄嚑灞傘� Dictitems Lart = null; - foreach (var area in od.S_ROW.Split('$')) + foreach (var area in odsr)//od.S_ROW.Split('$')) { if (dsi.TryGetValue(area, out var dictitems1)) { @@ -3613,110 +3638,127 @@ Lart = d; } } + } } + LogHelper.Info($"AutoRun13TSJ 绛涢�鐗╂枡 搴撳尯鎺掓暟鎹� {od.SQL_PLineNo} >>{od.OutNum}> {JsonConvert.SerializeObject(Lart)}"); // 闇�鏁伴噺 >= 浠撳簱鏈�ぇ鏁伴噺銆�灏卞紑濮嬪嚭搴撱� - if (od.OutNum >= Lart?.ItemLayer) - { - var v = new List<string>() { Lart.area }; - Location StartBit = null; - List<LocCntrRel> _clrel = new List<LocCntrRel>(); - - foreach (var area in v.Concat(od.S_ROW.Split('$')).Distinct()) + if (Lart != null) + if (od.OutNum >= Lart?.ItemLayer) { - var AreaRowlist = LocationHelper.GetAreaNormalLocList(area); - foreach (var item in AreaRowlist.GroupBy(x => x.N_ROW)) - { - var rl = item.ToList().FindAll(x => x.N_CURRENT_NUM > 0).OrderBy(x => x.N_COL).LastOrDefault(); - if (rl == null) continue; - _clrel = LocationHelper.GetLocCntrRel(rl.S_LOC_CODE); - //鏉垮瀷鐩稿悓 - var _clrel0 = _clrel.OrderByDescending(xx => xx.T_CREATE).First(); - LogHelper.Info(rl.S_LOC_CODE + "璇嗗埆鎵樼洏绫诲瀷銆� + JsonConvert.SerializeObject(_clrel0)); - var _clcntitem = ContainerHelper.GetCntrItemRel(_clrel0.S_CNTR_CODE.Trim()).FirstOrDefault(); - LogHelper.Info(rl.S_LOC_CODE + "璇嗗埆鎵樼洏涓婄殑鐗╂枡淇℃伅銆� + JsonConvert.SerializeObject(_clcntitem)); - if (_clcntitem != null) - { - LogHelper.Info("鐩镐簰鏄惁鍖归厤 _clcntitem S_ITEM_CODE:" + _clcntitem.S_ITEM_CODE + " od" + od.SQL_ItemCode + " _clcntitem S_ITEM_NAME:" + _clcntitem.S_ITEM_NAME + "od: " + od.SQL_ItemName + " od.S_CJ_NAME:" + od.S_CJ_NAME); - if (_clcntitem.S_ITEM_CODE == od.SQL_ItemCode && _clcntitem.S_ITEM_NAME == od.SQL_ItemName && _clcntitem.S_CJ_NAME == od.S_CJ_NAME) - { + var v = new List<string>() { Lart.area }; + Location StartBit = null; + List<LocCntrRel> _clrel = new List<LocCntrRel>(); - StartBit = rl; - break; + foreach (var area in v) //.Concat(od.S_ROW.Split('$')).Distinct()) + { + var AreaRowlist = LocationHelper.GetAreaNormalLocList(area); + foreach (var item in AreaRowlist.GroupBy(x => x.N_ROW)) + { + var rl = item.ToList().FindAll(x => x.N_CURRENT_NUM > 0).OrderBy(x => x.N_COL).LastOrDefault(); + if (rl == null) continue; + _clrel = LocationHelper.GetLocCntrRel(rl.S_LOC_CODE); + //鏉垮瀷鐩稿悓 + var _clrel0 = _clrel.OrderByDescending(xx => xx.T_CREATE).First(); + LogHelper.Info(rl.S_LOC_CODE + "璇嗗埆鎵樼洏绫诲瀷銆� + JsonConvert.SerializeObject(_clrel0)); + var _clcntitem = ContainerHelper.GetCntrItemRel(_clrel0.S_CNTR_CODE.Trim()).FirstOrDefault(); + LogHelper.Info(rl.S_LOC_CODE + "璇嗗埆鎵樼洏涓婄殑鐗╂枡淇℃伅銆� + JsonConvert.SerializeObject(_clcntitem)); + if (_clcntitem != null) + { + LogHelper.Info("鐩镐簰鏄惁鍖归厤 _clcntitem S_ITEM_CODE:" + _clcntitem.S_ITEM_CODE + " od" + od.SQL_ItemCode + " _clcntitem S_ITEM_NAME:" + _clcntitem.S_ITEM_NAME + "od: " + od.SQL_ItemName + " od.S_CJ_NAME:" + od.S_CJ_NAME); + if (_clcntitem.S_ITEM_CODE == od.SQL_ItemCode && _clcntitem.S_ITEM_NAME == od.SQL_ItemName && _clcntitem.S_CJ_NAME == od.S_CJ_NAME) + { + + StartBit = rl; + break; + } } } + if (StartBit != null) + break; } - if (StartBit != null) - break; - } - if (StartBit == null) - continue; - Location Endbit = null; - var loc = LocationHelper.GetLoc(PLC.location[0]); - if (loc?.N_CURRENT_NUM == 0 && StartBit.N_CURRENT_NUM == 1 && DeviceProcess.doorStatus.ContainsKey(PLC.location[0])) - { - if (DeviceProcess.doorStatus[PLC.location[0]].info == "1") + if (StartBit == null) { - Endbit = LocationHelper.GetLoc(PLC.location[0]); + LogHelper.Info($"{od.SQL_PLineNo} 鍑哄簱 {Lart.area}鍖哄煙娌℃湁鐗╂枡鍙敤璧风偣"); + continue; } - } - else - { - Endbit = LocationHelper.GetAreaNormalLocList(PLC.areaPriy[0]).Find(x => x.N_CURRENT_NUM == 0); - } + Location Endbit = null; - if (StartBit != null && Endbit != null) - { - var crs = _clrel.Select(x => x.S_CNTR_CODE).ToList(); - var EndBit = Endbit.S_LOC_CODE; - if (od.S_ROW == "YWLCQSX" || od.S_ROW == "YWLDQWJ") + var loc = LocationHelper.GetLoc(PLC.location[0]); + if (loc?.N_CURRENT_NUM == 0 && StartBit.N_CURRENT_NUM == 1 && DeviceProcess.doorStatus.ContainsKey(PLC.location[0])) { - var locs1 = LocationHelper.GetList<Location>(x => x.S_AREA_CODE == "YWLWJJB" && x.S_LOCK_STATE != "鎶ュ簾" && x.S_LOCK_STATE == "鏃� && x.N_CURRENT_NUM == 0).ToList(); - if (locs1.Count() > 0) + if (DeviceProcess.doorStatus[PLC.location[0]].info == "1") { - EndBit = locs1.FirstOrDefault().S_LOC_CODE; - } - else - { - continue; + Endbit = LocationHelper.GetLoc(PLC.location[0]); } } - var b = TaskProcess.CreateTransport(od.SQL_WorkNo, StartBit.S_LOC_CODE, EndBit, "鍘熺墿鏂欐惉杩�绾哥", crs, StartBit.N_CURRENT_NUM - crs.Count + 1, 1, crs.Count, PLC.taskPri, "", Endbit.S_LOC_CODE); - if (b) + else { + Endbit = LocationHelper.GetAreaNormalLocList(PLC.areaPriy[0]).Find(x => x.S_LOCK_STATE == "鏃� && x.N_CURRENT_NUM == 0); + } - var r = new RowLock { S_LOCK_SRC = od.SQL_ItemCode, T_LOCK_TIME = DateTime.Now, S_LOCK_STATE = "鍑哄簱閿�, S_AREA_CODE = StartBit.S_AREA_CODE, N_ROW = StartBit.N_ROW }; - var db = new SqlHelper<object>().GetInstance(); - //缁欑粓鐐归攣瀹氫綇 + if (StartBit != null && Endbit != null) + { + var crs = _clrel.Select(x => x.S_CNTR_CODE).ToList(); + var jbbit = ""; if (od.S_ROW == "YWLCQSX" || od.S_ROW == "YWLDQWJ") { - var model = db.Queryable<Location>().Where(a => a.S_LOC_CODE == Endbit.S_LOC_CODE).First(); - - model.S_LOCK_STATE = "鍏ュ簱閿�; - var res = db.Updateable(model).UpdateColumns(it => new { it.S_LOCK_STATE }).ExecuteCommand() > 0; - LogHelper.Info(Endbit.S_LOC_CODE + "LockLoc:閿佺粨鏋� + res); - } - //鎺掗攣 - var row = db.Queryable<RowLock>().Where(x => x.S_AREA_CODE == r.S_AREA_CODE && r.N_ROW == x.N_ROW).First(); - if (row != null) - { - if (row.S_LOCK_SRC != r.S_LOCK_SRC) + var locs1 = LocationHelper.GetList<Location>(x => x.S_AREA_CODE == "YWLWJJB" && x.S_LOCK_STATE != "鎶ュ簾" && x.S_LOCK_STATE == "鏃� && x.N_CURRENT_NUM == 0).ToList(); + if (locs1.Count() > 0) { - db.Deleteable(row).ExecuteCommand(); - db.Insertable(r).ExecuteCommand(); + jbbit = locs1.FirstOrDefault().S_LOC_CODE; + } + else + { + continue; } } - else db.Insertable(r).ExecuteCommand(); + var b = false; + if (!string.IsNullOrEmpty(jbbit)) + b = TaskProcess.CreateTransport(od.SQL_WorkNo, StartBit.S_LOC_CODE, jbbit, "鍘熺墿鏂欐惉杩�绾哥", crs, StartBit.N_CURRENT_NUM - crs.Count + 1, 1, crs.Count, PLC.taskPri, "", Endbit.S_LOC_CODE); + else b = TaskProcess.CreateTransport(od.SQL_WorkNo, StartBit.S_LOC_CODE, Endbit.S_LOC_CODE, "鍘熺墿鏂欐惉杩�绾哥", crs, StartBit.N_CURRENT_NUM - crs.Count + 1, 1, crs.Count, PLC.taskPri); + if (b) + { + var r = new RowLock { S_LOCK_SRC = od.SQL_ItemCode, T_LOCK_TIME = DateTime.Now, S_LOCK_STATE = "鍑哄簱閿�, S_AREA_CODE = StartBit.S_AREA_CODE, N_ROW = StartBit.N_ROW }; + var db = new SqlHelper<object>().GetInstance(); + //缁欑粓鐐归攣瀹氫綇 + if (od.S_ROW == "YWLCQSX" || od.S_ROW == "YWLDQWJ") + { + var model = db.Queryable<Location>().Where(a => a.S_LOC_CODE == Endbit.S_LOC_CODE).First(); + + model.S_LOCK_STATE = "鍏ュ簱閿�; + var res = db.Updateable(model).UpdateColumns(it => new { it.S_LOCK_STATE }).ExecuteCommand() > 0; + LogHelper.Info(Endbit.S_LOC_CODE + "LockLoc:閿佺粨鏋� + res); + } + //鎺掗攣 + //var row = db.Queryable<RowLock>().Where(x => x.S_AREA_CODE == r.S_AREA_CODE && r.N_ROW == x.N_ROW).First(); + //if (row != null) + //{ + // if (row.S_LOCK_SRC != r.S_LOCK_SRC) + // { + // db.Deleteable(row).ExecuteCommand(); + // db.Insertable(r).ExecuteCommand(); + // } + //} + //else db.Insertable(r).ExecuteCommand(); + od.TagOverTime = DateTime.Now; + db.Updateable(od).UpdateColumns(it => new { it.TagOverTime }).ExecuteCommand(); + //break; + } } - break; + else + { + LogHelper.Info($"{od.SQL_PLineNo} 鍑哄簱璧风偣{StartBit.S_LOC_CODE}-{StartBit.N_CURRENT_NUM},娌℃湁鍙敤缁堢偣"); + continue; + } } - } } } } public static void AutoRunABD() { + LogHelper.Info($"AutoRunABD abcd鐗╂枡姹囨� >>{ReadCCK}|| {dsi.Count}"); if (!ReadCCK) { Thread.Sleep(3000); @@ -3747,8 +3789,13 @@ var rl = item.ToList().FindAll(x => x.N_CURRENT_NUM > 0).OrderBy(x => x.N_COL).LastOrDefault(); var _clrel = LocationHelper.GetLocCntrRel(rl.S_LOC_CODE); + if (!_clrel.Any()) + { + LogHelper.Info($"{area}>> {rl.S_LOC_CODE}鏈夋暟閲忥紝 娌℃墭鐩�); + continue; + } //鏉垮瀷鐩稿悓 - var _clrel0 = _clrel.OrderByDescending(xx => xx.T_CREATE).First(); + var _clrel0 = _clrel.OrderByDescending(xx => xx.T_CREATE).FirstOrDefault(); LogHelper.Info(rl.S_LOC_CODE + "璇嗗埆鎵樼洏绫诲瀷銆�); var _clcntitem = ContainerHelper.GetCntrItemRel(_clrel0.S_CNTR_CODE.Trim()).FirstOrDefault(); @@ -3796,6 +3843,7 @@ } } } + LogHelper.Info($"AutoRunABD abcd鐗╂枡姹囨�瀹屾垚 >>{ReadCCK}|| {dsi.Count}"); } public static void chargeCCD() @@ -3813,6 +3861,7 @@ list.AddRange(item.MidArea.Split('$')); } } + foreach (var item in list.Distinct()) { var locs = LocationHelper.GetList<Location>(x => x.S_AREA_CODE == item && x.N_CURRENT_NUM > 0 && x.S_LOCK_STATE == "鏃�); @@ -3868,6 +3917,7 @@ var locS = LocationHelper.GetAreaNormalLocList(ODs.Key); foreach (var od in ODs) { + LogHelper.Info($"from{od.S_START_AREA} mid:{od.S_ZZ_AREA} to{od.S_END_AREA} 寮� 銆嬨�銆�); if (string.IsNullOrEmpty(od.S_ZZ_AREA) || string.IsNullOrEmpty(od.S_END_AREA)) { LogHelper.CError($"from{od.S_START_AREA} mid:{od.S_ZZ_AREA} to{od.S_END_AREA} 鏁版嵁缂哄け銆傛棤娉曞畬鎴愮Щ搴撱�"); @@ -3887,10 +3937,12 @@ var lastful = rows.FindAll(x => x.N_CURRENT_NUM > 0).OrderBy(x => x.N_COL).LastOrDefault(); if (lastful != null) { + LogHelper.Info($"from{od.S_START_AREA} mid:{od.S_ZZ_AREA} to{od.S_END_AREA} 鎵惧埌绉诲簱璧风偣銆媨lastful.S_LOC_CODE}銆�); var crs = LocationHelper.GetLocCntrRel(lastful.S_LOC_CODE); var cntritems = ContainerHelper.GetCntrItemRel(crs.FirstOrDefault()?.S_CNTR_CODE); if (!cntritems.Any()) continue; + LogHelper.Info($"from{od.S_START_AREA} mid:{od.S_ZZ_AREA} to{od.S_END_AREA} 鎵惧埌绉诲簱璧风偣銆媨lastful.S_LOC_CODE}銆傛帴椹虫槸鍚﹁閿侊紵锛歿InworkLock}"); var cir1 = cntritems.First(); if (od.S_ZZ_AREA == "YWLWJJB") { @@ -3899,7 +3951,8 @@ else InworkLock = true; } else InworkLock = false; - var zzlocs = LocationHelper.GetAreaNormalLocList(od.S_ZZ_AREA); + string nextarea = !string.IsNullOrEmpty(od.S_ZZ_AREA) ? od.S_ZZ_AREA : od.S_END_AREA; + var zzlocs = LocationHelper.GetAreaNormalLocList(nextarea); Location Endbit = null; foreach (var zzrs in zzlocs.GroupBy(x => x.N_ROW).OrderBy(x => x.Key)) { @@ -3911,7 +3964,7 @@ var cntrrel = ContainerHelper.GetCntrItemRel(rel.FirstOrDefault()?.S_CNTR_CODE).FirstOrDefault(); if (cntrrel == null) continue; - if (cntrrel.S_ITEM_CODE == cir1.S_ITEM_CODE && cntrrel.S_ITEM_NAME == cir1.S_ITEM_NAME) + if (cntrrel.S_ITEM_CODE == cir1.S_ITEM_CODE && cntrrel.S_ITEM_NAME == cir1.S_ITEM_NAME && cntrrel.S_CJ_NAME == cir1.S_CJ_NAME) { Endbit = zzrloclist.Find(x => x.N_COL > (_cl2?.N_COL ?? 0)); } @@ -3924,10 +3977,11 @@ break; } } + LogHelper.Info($"from{od.S_START_AREA} mid:{od.S_ZZ_AREA} to{od.S_END_AREA} 鎵惧埌绉诲簱缁堢偣銆媨Endbit?.S_LOC_CODE}"); if (Endbit != null) { //鐢熸垚鎺ラ┏鍖轰换鍔★紝鏍囪涓虹粓鐐瑰簱鍖恒� - var b = TaskProcess.CreateTransport(od.S_ID, lastful.S_LOC_CODE, Endbit.S_LOC_CODE, "鍘熺墿鏂欐惉杩�绾哥", crs.Select(x => x.S_CNTR_CODE).ToList(), 1, 1, crs.Count, 50, od.S_END_AREA); + var b = TaskProcess.CreateTransport(od.S_ID, lastful.S_LOC_CODE, Endbit.S_LOC_CODE, "鍘熺墿鏂欐惉杩�绾哥", crs.Select(x => x.S_CNTR_CODE).ToList(), 1, 1, crs.Count, 50, nextarea == od.S_END_AREA ? "" : od.S_END_AREA); if (od.S_ZZ_AREA == "YWLWJJB") InworkLock = false; break; } -- Gitblit v1.9.1