From 112c9bd20afed95d582b7eb227075ab8d10cdd12 Mon Sep 17 00:00:00 2001
From: 海波 张 <2956280567@qq.com>
Date: 星期二, 24 六月 2025 17:29:28 +0800
Subject: [PATCH] 金坛优化
---
wms/LocationHelper.cs | 330 +++++++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 310 insertions(+), 20 deletions(-)
diff --git a/wms/LocationHelper.cs b/wms/LocationHelper.cs
index f806d68..38141d3 100644
--- a/wms/LocationHelper.cs
+++ b/wms/LocationHelper.cs
@@ -1,6 +1,7 @@
锘縰sing HH.WCS.ZhongCeJinTan;
using HH.WCS.ZhongCeJinTan.util;
using HH.WCS.ZhongCeJinTan.wms;
+using Microsoft.Owin;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
@@ -8,6 +9,9 @@
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
+using Top.Api;
+using WebSocketSharp.Frame;
+using static HH.WCS.ZhongCeJinTan.api.ApiModel;
using static HH.WCS.ZhongCeJinTan.util.Settings;
using static HH.WCS.ZhongCeJinTan.wms.WcsModel;
@@ -20,15 +24,15 @@
static LocationHelper() {
//鍒濆鍖杔ocation鍔犲叆鍒板瓧鍏哥紦瀛�- locations = new Dictionary<string, Location>();
- var list = GetAllLocList();
- if (list.Count > 0) {
- list.ForEach(a => {
- if (!locations.ContainsKey(a.S_CODE)) {
- locations.Add(a.S_CODE, a);
- }
- });
- }
+ //locations = new Dictionary<string, Location>();
+ //var list = GetAllLocList();
+ //if (list.Count > 0) {
+ // list.ForEach(a => {
+ // if (!locations.ContainsKey(a.S_CODE)) {
+ // locations.Add(a.S_CODE, a);
+ // }
+ // });
+ //}
//鍒濆鍖杔ocationExt鍔犲叆鍒伴泦鍚堢紦瀛� //locationExts = new Dictionary<string, LocationExt>();
//var exts = GetAllLocExtList();
@@ -68,7 +72,7 @@
internal static List<Location> GetAllLocList1(string S_AREA_CODE)
{
var db = new SqlHelper<object>().GetInstance();
- return db.Queryable<Location>().Where(s => s.S_AREA_CODE == S_AREA_CODE).OrderBy(a=> a.N_ROW).OrderBy(a => a.N_COL).ToList();
+ return db.Queryable<Location>().Where(s => s.S_AREA_CODE == S_AREA_CODE && s.C_ENABLE == "Y").OrderBy(a=> a.N_ROW).OrderBy(a => a.N_COL).ToList();
}
/// <summary>
@@ -77,7 +81,7 @@
internal static List<Location> GetAllLocList2(string S_AREA_CODE)
{
var db = new SqlHelper<object>().GetInstance();
- return db.Queryable<Location>().Where(s => s.S_AREA_CODE == S_AREA_CODE).OrderBy(a => a.N_ROW).OrderByDescending(a => a.N_COL).ToList();
+ return db.Queryable<Location>().Where(s => s.S_AREA_CODE == S_AREA_CODE && s.C_ENABLE == "Y").OrderBy(a => a.N_ROW).OrderByDescending(a => a.N_COL).ToList();
}
@@ -87,7 +91,7 @@
internal static List<string> GetConnectionList(string S_AREA_CODE)
{
var db = new SqlHelper<object>().GetInstance();
- var ConnectionList = db.Queryable<Location>().Where(s => s.S_AREA_CODE == S_AREA_CODE).OrderBy(a => a.N_ROW).OrderBy(a => a.N_COL).ToList();
+ var ConnectionList = db.Queryable<Location>().Where(s => s.S_AREA_CODE == S_AREA_CODE && s.C_ENABLE == "Y").OrderBy(a => a.N_ROW).OrderBy(a => a.N_COL).ToList();
List<string> result = new List<string>();
foreach (var item in ConnectionList)
{
@@ -95,6 +99,41 @@
}
return result;
}
+
+ /// <summary>
+ /// 杩斿洖鍧囪 鐨勬帴椹充綅闆嗗悎
+ /// </summary>
+ internal static List<connectionBalance> GetBalanceConnectionList(List<string> locList)
+ {
+ var db = new SqlHelper<object>().GetInstance();
+
+ List<connectionBalance> result = new List<connectionBalance>();
+
+ foreach (var item in locList)
+ {
+ var ConnectionList = 0;
+ ConnectionList = db.Queryable<WMSTask>().Where(a => (a.S_END_LOC.Contains(item) || a.S_START_LOC.Contains(item)) && a.S_B_STATE != "瀹屾垚" && a.S_B_STATE != "鍙栨秷" && a.S_B_STATE != "澶辫触" && a.S_B_STATE != "宸插畬鎴� && a.S_B_STATE != "鏈墽琛�).ToList().Count();
+ var re = new connectionBalance();
+ var con = LocationHelper.GetLoc(item);
+ re.loc = con;
+ re.taskCount = ConnectionList;
+ result.Add(re);
+ }
+ return result.OrderBy(a => a.taskCount).ToList();
+ }
+
+ /// <summary>
+ /// 杩斿洖褰撳墠鎺ラ┏浣嶆墽琛屼换鍔℃暟閲�+ /// </summary>
+ internal static int GetConnectionTaskCount(string connection)
+ {
+ var db = new SqlHelper<object>().GetInstance();
+
+ var ConnectionList = 0;
+ ConnectionList = db.Queryable<WMSTask>().Where(a => (a.S_END_LOC.Contains(connection) || a.S_START_LOC.Contains(connection)) && a.S_B_STATE != "瀹屾垚" && a.S_B_STATE != "鍙栨秷" && a.S_B_STATE != "澶辫触" && a.S_B_STATE != "宸插畬鎴� ).ToList().Count();
+ return ConnectionList;
+ }
+
/// <summary>
/// 鎵剧粓鐐瑰贩閬撳彲鐢ㄧ┖璐т綅
@@ -176,10 +215,10 @@
{
other = rowList.Where(b => b.S_LOCK_STATE == "鏃�).OrderBy(a => a.N_COL).Where(a => a.N_COL > full.N_COL).FirstOrDefault();
}
- if (other != null && (!string.IsNullOrEmpty(other.C_ENABLE) && other.C_ENABLE == "绂佺敤"))
+ if (other != null && (!string.IsNullOrEmpty(other.C_ENABLE) && other.C_ENABLE == "N"))
{
//绂佺敤浜嗛�鎷╁悗闈竴涓揣浣�- other = db.Queryable<Location>().OrderBy(a => a.N_COL).Where(a => (string.IsNullOrEmpty(a.C_ENABLE) || a.C_ENABLE.Trim() != "绂佺敤") && a.S_AREA_CODE == other.S_AREA_CODE && a.S_LOCK_STATE=="鏃�&& a.N_ROW == other.N_ROW && a.N_COL > other.N_COL).First();
+ other = db.Queryable<Location>().OrderBy(a => a.N_COL).Where(a => (string.IsNullOrEmpty(a.C_ENABLE) || a.C_ENABLE.Trim() != "N") && a.S_AREA_CODE == other.S_AREA_CODE && a.S_LOCK_STATE=="鏃�&& a.N_ROW == other.N_ROW && a.N_COL > other.N_COL).First();
}
if (other != null)
{
@@ -198,6 +237,131 @@
throw;
}
+ }
+
+
+ /// <summary>
+ /// 鎵剧粓鐐瑰贩閬撳彲鐢ㄧ┖璐т綅 鍧囪
+ /// </summary>
+ /// <param name="locations"></param>
+ /// <returns></returns>
+ internal static Location FindBalanceEndcolByLocList(List<Location> locations, string endArea, string rodway = "")
+ {
+ try
+ {
+ var db = new SqlHelper<object>().GetInstance();
+ Location end = null;
+ //鏍规嵁缁堢偣璐т綅鎵剧┖闂茶揣浣�+ var rows = locations.Select(a => a.N_ROW).Distinct().ToList();
+
+ //浣滀笟娴佺▼鐨勫贩閬�+ var xd = new List<string>();
+
+ List<RoadWayEnable> rowdwa = null;
+
+ if (!string.IsNullOrEmpty(rodway))
+ {
+ xd = rodway.Split('-').ToList();
+ rowdwa = db.Queryable<RoadWayEnable>().Where(x => x.areaCode == endArea && x.status == "0" && xd.Contains(x.roadWay)).ToList();
+ }
+ else
+ {
+ //鏌ユ壘鍙敤宸烽亾
+ rowdwa = db.Queryable<RoadWayEnable>().Where(x => x.areaCode == endArea && x.status == "0").ToList();
+ }
+
+
+
+
+ for (int i = 0; i < rows.Count; i++)
+ {
+ var rowList = locations.Where(r => r.N_ROW == rows[i]).ToList();
+
+ var flag = false;
+ var flag1 = false;
+
+ foreach (var item in rowdwa)
+ {
+ if (rowList.Count(a => a.N_ROADWAY.ToString() == item.roadWay) > 0)
+ {
+ flag = true;
+ break;
+ }
+
+
+ }
+
+ foreach (var item1 in xd)
+ {
+ if (rowList.Count(a => a.N_ROADWAY.ToString() != item1) > 0)
+ {
+ flag1 = true;
+ break;
+ }
+ }
+
+ if (flag1 || flag)
+ {
+ locations.RemoveAll(a => a.N_ROW == rows[i]);
+ }
+
+ if (rowList.Count(a => a.N_CURRENT_NUM == 0) == 0)
+ {
+ locations.RemoveAll(a => a.N_ROW == rows[i]);
+ }
+ }
+
+ var balanceLocList = RoadWayBalance(locations);
+
+ foreach (var item in balanceLocList)
+ {
+ if (item.S_LOCK_STATE=="鏃� && item.N_CURRENT_NUM==0)
+ {
+ end = item;
+ break;
+ }
+ }
+ return end;
+ }
+ catch (Exception)
+ {
+
+ throw;
+ }
+
+ }
+
+
+ /// <summary>
+ /// 宸烽亾鍧囪 绛栫暐
+ /// </summary>
+ /// <param name="lstTrueLocation">鍙敤鐨勮揣浣嶄俊鎭暟鎹�/param>
+ /// <returns>璁＄畻鍚庤繑鍥炵殑瀹炰綋</returns>
+ public static List<Location> RoadWayBalance(List<Location> lstTrueLocation)
+ {
+ //鎸囧畾璁＄畻鍚庤繑鍥炵殑瀹炰綋
+ List<Location> location_roadray = new List<Location>();
+
+ //鎸夌収宸烽亾鍒嗙粍 骞惰幏寰楀贩閬撲腑鍙敤璐т綅鐨勬暟鎹�+ //涔嬪悗杩涜鍊掑彊 鎵惧埌鍙敤璐т綅鏈�鐨勫贩閬�+ var v = lstTrueLocation.GroupBy(x => x.N_ROADWAY).Select(g => (new
+ {
+ roadWay = g.Key,
+ qty = g.Count(p => p.S_LOCK_STATE=="鏃�)
+ })).OrderByDescending(o => o.qty);
+
+ //鍊掑彊鎺掑垪鍚庣殑宸烽亾 寰幆
+ foreach (var item in v)
+ {
+ //鍙栧緱宸烽亾鍒楄〃涓彲鐢ㄨ揣浣嶆渶澶氱殑宸烽亾 骞惰幏鍙栧贩閬撲腑鎵�湁璐т綅
+ location_roadray = lstTrueLocation.Where(o => o.N_ROADWAY == item.roadWay).ToList();
+
+ if (location_roadray != null && location_roadray.Count > 0)
+ {
+ break;
+ }
+ }
+ return location_roadray;
}
@@ -253,10 +417,10 @@
{
other = rowList.Where(b => b.S_LOCK_STATE == "鏃�).OrderBy(a => a.N_COL).Where(a => a.N_COL > full.N_COL).FirstOrDefault();
}
- if (other != null && (!string.IsNullOrEmpty(other.C_ENABLE) && other.C_ENABLE == "绂佺敤"))
+ if (other != null && (!string.IsNullOrEmpty(other.C_ENABLE) && other.C_ENABLE == "N"))
{
//绂佺敤浜嗛�鎷╁悗闈竴涓揣浣�- other = db.Queryable<Location>().OrderBy(a => a.N_COL).Where(a => (string.IsNullOrEmpty(a.C_ENABLE) || a.C_ENABLE.Trim() != "绂佺敤") && a.S_AREA_CODE == other.S_AREA_CODE && a.S_LOCK_STATE == "鏃� && a.N_ROW == other.N_ROW && a.N_COL > other.N_COL).First();
+ other = db.Queryable<Location>().OrderBy(a => a.N_COL).Where(a => (string.IsNullOrEmpty(a.C_ENABLE) || a.C_ENABLE.Trim() != "N") && a.S_AREA_CODE == other.S_AREA_CODE && a.S_LOCK_STATE == "鏃� && a.N_ROW == other.N_ROW && a.N_COL > other.N_COL).First();
}
if (other != null)
{
@@ -313,10 +477,10 @@
{
other = rowList.Where(b => b.S_LOCK_STATE == "鏃�).OrderBy(a => a.N_COL).Where(a => a.N_COL > full.N_COL).FirstOrDefault();
}
- if (other != null && (!string.IsNullOrEmpty(other.C_ENABLE) && other.C_ENABLE == "绂佺敤"))
+ if (other != null && (!string.IsNullOrEmpty(other.C_ENABLE) && other.C_ENABLE == "N"))
{
//绂佺敤浜嗛�鎷╁悗闈竴涓揣浣�- other = db.Queryable<Location>().OrderBy(a => a.N_COL).Where(a => (string.IsNullOrEmpty(a.C_ENABLE) || a.C_ENABLE.Trim() != "绂佺敤") && a.S_AREA_CODE == other.S_AREA_CODE && a.S_LOCK_STATE == "鏃� && a.N_ROW == other.N_ROW && a.N_COL > other.N_COL).First();
+ other = db.Queryable<Location>().OrderBy(a => a.N_COL).Where(a => (string.IsNullOrEmpty(a.C_ENABLE) || a.C_ENABLE.Trim() != "N") && a.S_AREA_CODE == other.S_AREA_CODE && a.S_LOCK_STATE == "鏃� && a.N_ROW == other.N_ROW && a.N_COL > other.N_COL).First();
}
if (other != null)
{
@@ -389,7 +553,7 @@
Location start = null;
var rowsStart = locations.Select(a => a.N_ROW).Distinct().ToList();
- //鏌ユ壘鍙敤宸烽亾
+ //鏌ユ壘涓嶅彲鐢ㄥ贩閬� var rowdwa = db.Queryable<RoadWayEnable>().Where(x => x.areaCode == startArea && x.status == "0").ToList();
for (int i = 0; i < rowsStart.Count; i++)
@@ -447,6 +611,50 @@
throw;
}
}
+
+
+ /// <summary>
+ /// 鏍规嵁璧风偣绔嬪簱鍖烘壘绌烘墭 鏍￠獙搴撳瓨
+ /// </summary>
+ /// <param name="locations"></param>
+ /// <returns></returns>
+ internal static bool FindStartcolByLoclistAndcntrFlag(List<Location> locations, string startArea)
+ {
+ var db = new SqlHelper<object>().GetInstance();
+ try
+ {
+ var start = false;
+ var rowsStart = locations.Select(a => a.N_ROW).Distinct().ToList();
+
+
+ foreach (var item in locations)
+ {
+ if (item.N_CURRENT_NUM == 0)
+ {
+ continue;
+ }
+ var tp = db.Queryable<LocCntrRel>().Where(s => s.S_LOC_CODE == item.S_CODE).First();
+
+ if (tp != null && item.S_LOCK_STATE == "鏃�)
+ {
+ var tp1 = db.Queryable<Container>().Where(s => s.S_CODE == tp.S_CNTR_CODE).First();
+
+ if (tp1 != null && tp1.N_DETAIL_COUNT == 0)
+ {
+ return true;
+ }
+ }
+ }
+ return start;
+
+ }
+ catch (Exception)
+ {
+
+ throw;
+ }
+ }
+
/// <summary>
/// 鏍规嵁璧风偣璐ф灦鍖烘壘绌烘墭
@@ -675,6 +883,8 @@
LogHelper.Info($"ZCSendTask鍑哄簱浠诲姟涓嬪彂璧风偣鎸夌敓浜ф椂闂存帓搴忕墿鏂欎俊鎭� + JsonConvert.SerializeObject(startItem), "Mes浠诲姟涓嬪彂");
if (startItem!=null)
{
+
+
var tp = db.Queryable<LocCntrRel>().Where(s => s.S_CNTR_CODE == startItem.S_CNTR_CODE).First();
start = LocationHelper.GetLocOne(tp.S_LOC_CODE);
LogHelper.Info($"ZCSendTask鍑哄簱浠诲姟涓嬪彂璧风偣璐т綅淇℃伅" + JsonConvert.SerializeObject(start), "Mes浠诲姟涓嬪彂");
@@ -686,8 +896,59 @@
throw;
}
-
}
+
+
+ /// <summary>
+ /// 鏍规嵁鐗╂枡缂栫爜鎵剧珛搴撳尯璧风偣婊¤揣浣�鏍￠獙鏈夊簱瀛樹絾鏄澶囨姤璀�+ /// </summary>
+ /// <param name="locations"></param>
+ /// <returns></returns>
+ internal static bool FindStartcolByLoclistAndItemFlag(List<Location> locations, string itemCode, string endArea)
+ {
+ var db = new SqlHelper<object>().GetInstance();
+ var res = false;
+ try
+ {
+
+ var rowsStart = locations.Select(a => a.N_ROW).Distinct().ToList();
+
+ DateTime date = DateTime.Now;
+ List<CntrItemRel> startList = new List<CntrItemRel>(); ;
+
+ foreach (var item in locations)
+ {
+ if (item.N_CURRENT_NUM == 0)
+ {
+ continue;
+ }
+
+ var tp = db.Queryable<LocCntrRel>().Where(s => s.S_LOC_CODE == item.S_CODE).First();
+
+ // LogHelper.Info($"ZCSendTask鍑哄簱浠诲姟涓嬪彂璧风偣璐т綅瀹瑰櫒淇℃伅" + JsonConvert.SerializeObject(tp), "Mes浠诲姟涓嬪彂");
+ if (tp != null && item.S_LOCK_STATE == "鏃�)
+ {
+ var tp1 = db.Queryable<CntrItemRel>().Where(s => s.S_CNTR_CODE == tp.S_CNTR_CODE).First();
+ //LogHelper.Info($"ZCSendTask鍑哄簱浠诲姟涓嬪彂璧风偣瀹瑰櫒鐗╂枡淇℃伅" + JsonConvert.SerializeObject(tp1), "Mes浠诲姟涓嬪彂");
+
+ if (tp1 != null && tp1.S_ITEM_CODE == itemCode && tp1.S_ITEM_STATE == "鍚堟牸" && tp1.takeEffectTime < date && tp1.expireTime > date)
+ {
+ res = true;
+ return res;
+ }
+ }
+ }
+
+
+ return res;
+ }
+ catch (Exception)
+ {
+
+ throw;
+ }
+ }
+
/// <summary>
/// 鏍规嵁鐗╂枡缂栫爜鎵捐揣鏋跺尯璧风偣婊¤揣浣�@@ -1290,5 +1551,34 @@
}
return res;
}
+
+ /// <summary>
+ /// 鑾峰彇閫昏緫搴撳尯璐т綅
+ /// </summary>
+ /// <param name="zoneCode"></param>
+ /// <returns></returns>
+ public static List<Location> GetZoneLoc(string zoneCode) {
+ var db = new SqlHelper<object>().GetInstance();
+ LogHelper.Info($"ZCSendTask鍏ュ簱浠诲姟瀵绘壘閫昏緫搴撳尯鍙傛暟{zoneCode}", "Mes浠诲姟涓嬪彂");
+ var zones = db.Queryable<Zone>().Where(a => a.S_ZONE_CLS_CODE == zoneCode).ToList();
+ LogHelper.Info($"ZCSendTask鍏ュ簱浠诲姟瀵绘壘閫昏緫搴撳尯淇℃伅" +JsonConvert.SerializeObject(zones), "Mes浠诲姟涓嬪彂");
+ var locList = new List<Location>();
+
+ foreach (var item in zones)
+ {
+ var locations = db.Queryable<ZoneLoc>().Includes(t => t.Loc).Where(a => a.S_ZONE_CODE == item.S_CODE).ToList();
+
+ foreach (var item1 in locations)
+ {
+ locList.Add(item1.Loc);
+ }
+ }
+
+ LogHelper.Info($"ZCSendTask鍏ュ簱浠诲姟瀵绘壘閫昏緫璐т綅鏁伴噺淇℃伅{locList.Count}", "Mes浠诲姟涓嬪彂");
+
+ return locList.OrderBy(a => a.N_ROW).OrderBy(a => a.N_COL).ToList(); ;
+ }
+
+
}
}
--
Gitblit v1.9.1