From 74a352255e4a8d7cd10eaaab8cb44f568f88b6c2 Mon Sep 17 00:00:00 2001
From: czw <selecti@yeah.net>
Date: 星期二, 17 六月 2025 16:10:59 +0800
Subject: [PATCH] 清溪问题处理
---
HH.WCS.QingXiNongfu/core/TaskCore.cs | 243 ++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 243 insertions(+), 0 deletions(-)
diff --git a/HH.WCS.QingXiNongfu/core/TaskCore.cs b/HH.WCS.QingXiNongfu/core/TaskCore.cs
index 4faf73c..1d0daeb 100644
--- a/HH.WCS.QingXiNongfu/core/TaskCore.cs
+++ b/HH.WCS.QingXiNongfu/core/TaskCore.cs
@@ -250,7 +250,250 @@
}
}
+ /// <summary>
+ /// 60鍒嗛挓鏇存柊涓�搴撳
+ /// </summary>
+ /// <param name="min"></param>
+ public static void CheckKuRong(int min)
+ {
+ try
+ {
+ Console.WriteLine("CheckKurRong");
+ //濡傛灉琛ㄥ唴娌℃湁鏁版嵁灏卞垵濮嬪寲涓�笅锛屾湁鏁版嵁浜唌odify鏃堕棿鍜屽綋鍓嶆椂闂磋秴杩�0min鍐嶇粺璁′竴娆�+ var db = new SqlHelper<object>().GetInstance();
+ var info = db.Queryable<KuRong>().First();
+ if (info == null || DateTime.Now.Subtract(info.T_MODIFY).TotalMinutes > min)
+ {
+ //1銆佹煡鍒板皬鏉垮簱鍖轰笅闈㈡墍鏈夌殑搴撲綅
+ var totalX = 0;
+ var totalRows = 0;
+ var list = new List<KuRong>();
+ var areas = db.Queryable<Location>().Select(x => x.S_AREA_CODE).ToList().FindAll(x => System.Text.RegularExpressions.Regex.IsMatch(x, @"QX-\d+_[A-Z]+")).Select(x => x.Split('_')[0]).Distinct().ToList(); //GetAreas();
+ areas.ForEach(area =>
+ {
+ totalX += db.Queryable<Location>().Count(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_X"));
+ totalRows += db.Queryable<Location>().Where(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_X")).Select(b => b.N_ROW).Distinct().Count();
+ var aresList = db.Queryable<Location>().Where(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_")).Select(b => b.S_AREA_CODE).Distinct().ToList();
+ aresList = aresList.Select(a => a.Split('_')[0]).Distinct().ToList();
+ aresList.ForEach(a =>
+ {
+ //b => b.S_AREA_CODE == a + "_X"
+ Console.WriteLine("area:" + a);
+ // && b.S_AREA_CODE.EndsWith("X")
+ var rows = db.Queryable<Location>().Where(b => b.S_AREA_CODE.StartsWith(a)).Select(b => b.N_ROW).Distinct().ToList();
+ if (rows.Count > 0)
+ {
+ Console.WriteLine(string.Join(",", rows));
+ rows.ForEach(b =>
+ {
+ var kr = new KuRong() { StorageLoc = a.Split('-')[1] + "-" + b, T_MODIFY = DateTime.Now };
+ Console.WriteLine(kr.StorageLoc);
+ //姣忎竴鎺掕鏌ヤ竴涓嬫湁娌℃湁鎵樼洏
+ var listLoc = db.Queryable<Location>().Where(c => c.S_AREA_CODE.Contains(c.S_AREA_CODE) && c.N_ROW == b && c.N_CURRENT_NUM > 0).ToList();
+ if (!listLoc.Any())
+ {
+ //娌℃墭鐩橈紝榛樿鏈�ぇ瀹归噺鏄皬鏉跨殑鏁伴噺
+ var count = db.Queryable<Location>().Count(c => c.S_AREA_CODE == a + "_X" && c.N_ROW == b) * 2 * 2;//2灞�鎵�+ kr.MaxCapacity = count;
+ kr.AvailableCapacity = count;
+ kr.ProductItem = "";
+ }
+ else
+ {
+ //鏈夋墭鐩�鍒ゆ柇鏄彔2灞傝繕鏄�灞傦紝瑕佽幏鍙栫墿鏂欎俊鎭�+ var lcr = db.Queryable<LocCntrRel>().Includes(it => it.CntrItemRel).Where(l => l.S_LOC_CODE == listLoc[0].S_LOC_CODE).First();
+ if (lcr != null && lcr.CntrItemRel != null)
+ {
+ var maxLayer = ContainerHelper.GetItem(ass => ass.S_ITEM_NAME == lcr.CntrItemRel.S_ITEM_NAME && ass.S_ITEM_CODE == lcr.CntrItemRel.S_ITEM_CODE)?.MaxLayer ?? listLoc[0].N_CAPACITY;
+ var total = db.Queryable<Location>().Count(c => c.S_AREA_CODE == listLoc[0].S_AREA_CODE && c.N_ROW == b) * maxLayer * 2;
+ var count = db.Queryable<Location>().Where(c => c.S_AREA_CODE == listLoc[0].S_AREA_CODE && c.N_ROW == b && c.N_CURRENT_NUM > 0).Sum(c => c.N_CURRENT_NUM) * 2; // 鎸囧畾缁熻瀛楁
+ kr.ProductItem = lcr.CntrItemRel.S_ITEM_CODE;
+ kr.MaxCapacity = total;
+ kr.FilledCapacity = count;
+ kr.AvailableCapacity = total - count;
+ }
+ }
+ list.Add(kr);
+ });
+ }
+ else
+ {
+ Console.WriteLine("area:" + a + ":鏈幏鍙栧埌鎺�);
+ }
+ });
+ });
+ var ordersCount = db.Queryable<WorkOrder>().Where(a => a.SQL_State == "鎵ц涓�).Count();
+ var totalDesiredCapacity = ordersCount * 4 * 3 * (totalX / totalRows);
+ LogHelper.Error($"鎴愬搧灏忔澘鍖烘�璐т綅鏄瘂totalX},鎬绘帓鏁版槸{totalRows},褰撳墠鎵ц宸ュ崟鏁伴噺鏄瘂ordersCount}", null);
+ var totalAvailableCapacity = list.Sum(a => a.AvailableCapacity);
+ var totalAssignableCapacity = totalAvailableCapacity - totalDesiredCapacity;
+ list.ForEach(a => { a.DesiredCapacity = totalDesiredCapacity; a.CRC = totalAvailableCapacity; a.RAC = totalAssignableCapacity; });
+ if (info == null)
+ {
+ /*鈥婼QL Server鈥�1000 鏉�鎵规 鍗曚釜 INSERT 璇彞鏈�鏀寔 1000 鏉�VALUES 瀛愬彞锛岃秴鍑轰細鎶ヨ娉曢敊璇�*/
+ db.Insertable(list).ExecuteCommand();
+ }
+ else
+ {
+ //鏇存柊
+ list.ForEach(a =>
+ {
+ var old = db.Queryable<KuRong>().Where(b => b.StorageLoc == a.StorageLoc).First();
+ if (old != null)
+ {
+ old.MaxCapacity = a.MaxCapacity;
+ old.AvailableCapacity = a.AvailableCapacity;
+ old.FilledCapacity = a.FilledCapacity;
+ old.ProductItem = a.ProductItem;
+ old.DesiredCapacity = a.DesiredCapacity;
+ old.CRC = a.CRC;
+ old.RAC = a.RAC;
+ old.T_MODIFY = DateTime.Now;
+ db.Updateable(old).UpdateColumns(it => new { it.MaxCapacity, it.FilledCapacity, it.AvailableCapacity, it.ProductItem, it.T_MODIFY }).ExecuteCommand();
+ }
+ else
+ {
+ db.Insertable(a).ExecuteCommand();
+ }
+ });
+ }
+ }
+ }
+ catch (Exception ex)
+ {
+ Console.WriteLine(ex.Message);
+ LogHelper.Error(ex.Message, ex);
+ }
+
+ //缁熻褰撳墠浜х嚎
+ }
+
+ internal static void Kuronggg()
+ {
+ int min = 60;
+ try
+ {
+ LogHelper.Info("Run>>CheckKurRong");
+ //濡傛灉琛ㄥ唴娌℃湁鏁版嵁灏卞垵濮嬪寲涓�笅锛屾湁鏁版嵁浜唌odify鏃堕棿鍜屽綋鍓嶆椂闂磋秴杩�0min鍐嶇粺璁′竴娆�+ var db = new SqlHelper<object>().GetInstance();
+ var info = db.Queryable<KuRong>().First();
+ if (info == null || DateTime.Now.Subtract(info.T_MODIFY).TotalMinutes > min)
+ {
+ //1銆佹煡鍒板皬鏉垮簱鍖轰笅闈㈡墍鏈夌殑搴撲綅
+ var totalX = 0;
+ var totalRows = 0;
+ var list = new List<KuRong>();
+ var areas = db.Queryable<Location>().Select(x => x.S_AREA_CODE).ToList().FindAll(x => System.Text.RegularExpressions.Regex.IsMatch(x, @"QX-\d+_[A-Z]+")).Select(x => x.Split('_')[0]).Distinct().ToList(); //GetAreas();
+ areas.ForEach(area =>
+ {
+ totalX += db.Queryable<Location>().Count(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_X"));
+ totalRows += db.Queryable<Location>().Where(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_X")).Select(b => b.N_ROW).Distinct().Count();
+ var aresList = db.Queryable<Location>().Where(b => b.S_AREA_CODE.StartsWith(area) && b.S_AREA_CODE.Contains("_")).Select(b => b.S_AREA_CODE).Distinct().ToList();
+ aresList = aresList.Select(a => a.Split('_')[0]).Distinct().ToList();
+ aresList.ForEach(a =>
+ {
+ //b => b.S_AREA_CODE == a + "_X"
+ Console.WriteLine("area:" + a);
+ // && b.S_AREA_CODE.EndsWith("X")
+ var rows = db.Queryable<Location>().Where(b => b.S_AREA_CODE.StartsWith(a)).Select(b => b.N_ROW).Distinct().ToList();
+ if (rows.Count > 0)
+ {
+ Console.WriteLine(string.Join(",", rows));
+ rows.ForEach(b =>
+ {
+ var kr = new KuRong() { StorageLoc = a.Split('-')[1] + "-" + b, T_MODIFY = DateTime.Now };
+ Console.WriteLine(kr.StorageLoc);
+ //姣忎竴鎺掕鏌ヤ竴涓嬫湁娌℃湁鎵樼洏
+ var listLoc = db.Queryable<Location>().Where(c => c.S_AREA_CODE.Contains(c.S_AREA_CODE) && c.N_ROW == b && c.N_CURRENT_NUM > 0).ToList();
+ if (!listLoc.Any())
+ {
+ //娌℃墭鐩橈紝榛樿鏈�ぇ瀹归噺鏄皬鏉跨殑鏁伴噺
+ var count = db.Queryable<Location>().Count(c => c.S_AREA_CODE == a + "_X" && c.N_ROW == b) * 2 * 2;//2灞�鎵�+ kr.MaxCapacity = count;
+ kr.AvailableCapacity = count;
+ kr.ProductItem = "";
+ }
+ else
+ {
+ //鏈夋墭鐩�鍒ゆ柇鏄彔2灞傝繕鏄�灞傦紝瑕佽幏鍙栫墿鏂欎俊鎭�+ var lcr = db.Queryable<LocCntrRel>().Includes(it => it.CntrItemRel).Where(l => l.S_LOC_CODE == listLoc[0].S_LOC_CODE).First();
+ if (lcr != null && lcr.CntrItemRel != null)
+ {
+ var maxLayer = ContainerHelper.GetItem(ass => ass.S_ITEM_NAME == lcr.CntrItemRel.S_ITEM_NAME && ass.S_ITEM_CODE == lcr.CntrItemRel.S_ITEM_CODE)?.MaxLayer ?? listLoc[0].N_CAPACITY;
+ var total = db.Queryable<Location>().Count(c => c.S_AREA_CODE == listLoc[0].S_AREA_CODE && c.N_ROW == b) * maxLayer * 2;
+ var count = db.Queryable<Location>().Where(c => c.S_AREA_CODE == listLoc[0].S_AREA_CODE && c.N_ROW == b && c.N_CURRENT_NUM > 0).Sum(c => c.N_CURRENT_NUM) * 2; // 鎸囧畾缁熻瀛楁
+
+ kr.ProductItem = lcr.CntrItemRel.S_ITEM_CODE;
+ kr.MaxCapacity = total;
+ kr.FilledCapacity = count;
+ kr.AvailableCapacity = total - count;
+ }
+ }
+ list.Add(kr);
+ });
+ }
+ else
+ {
+ Console.WriteLine("area:" + a + ":鏈幏鍙栧埌鎺�);
+ }
+ });
+
+ });
+
+ var ordersCount = 0;// db.Queryable<WorkOrder>().Where(a => a.SQL_State == "鎵ц涓�).Count();
+ foreach (var pline in Settings.GetDeviceInfoList().FindAll(x => x.deviceType == 9))
+ {
+ ordersCount += db.Queryable<WorkOrder>().Where(a => a.SQL_PLineNo == pline.deviceName && a.SQL_State == "鎵ц涓�).Count();
+ }
+ var totalDesiredCapacity = ordersCount * 4 * 3 * (totalX / totalRows);
+ LogHelper.Error($"鎴愬搧灏忔澘鍖烘�璐т綅鏄瘂totalX},鎬绘帓鏁版槸{totalRows},褰撳墠鎵ц宸ュ崟鏁伴噺鏄瘂ordersCount}", new Exception("Kurong"));
+ var totalAvailableCapacity = list.Sum(a => a.AvailableCapacity);
+ var totalAssignableCapacity = totalAvailableCapacity - totalDesiredCapacity;
+ list.ForEach(a => { a.DesiredCapacity = totalDesiredCapacity; a.CRC = totalAvailableCapacity; a.RAC = totalAssignableCapacity; });
+ if (info == null)
+ {
+ /*鈥婼QL Server鈥�1000 鏉�鎵规 鍗曚釜 INSERT 璇彞鏈�鏀寔 1000 鏉�VALUES 瀛愬彞锛岃秴鍑轰細鎶ヨ娉曢敊璇�*/
+ for (int i = 0; i < list.Count; i += 1000)
+ {
+ db.Insertable(list.Skip(i).Take(1000).ToList()).ExecuteCommand();
+ }
+ }
+ else
+ {
+ //鏇存柊
+ list.ForEach(a =>
+ {
+ var old = db.Queryable<KuRong>().Where(b => b.StorageLoc == a.StorageLoc).First();
+ if (old != null)
+ {
+ old.MaxCapacity = a.MaxCapacity;
+ old.AvailableCapacity = a.AvailableCapacity;
+ old.FilledCapacity = a.FilledCapacity;
+ old.ProductItem = a.ProductItem;
+ old.DesiredCapacity = a.DesiredCapacity;
+ old.CRC = a.CRC;
+ old.RAC = a.RAC;
+ old.T_MODIFY = DateTime.Now;
+ db.Updateable(old).UpdateColumns(it => new { it.MaxCapacity, it.FilledCapacity, it.AvailableCapacity, it.ProductItem, it.T_MODIFY }).ExecuteCommand();
+ }
+ else
+ {
+ db.Insertable(a).ExecuteCommand();
+ }
+ });
+ }
+ }
+
+ LogHelper.Info("OVER<<CheckKurRong");
+ }
+ catch (Exception ex)
+ {
+ Console.WriteLine(ex.Message);
+ LogHelper.Error(ex.Message, ex);
+ }
+
+ }
}
}
--
Gitblit v1.9.1