From 3865194441f1e1da34c0be9034d86c8d0d68706c Mon Sep 17 00:00:00 2001
From: lss <2538410689@qq.com>
Date: 星期五, 04 七月 2025 17:26:23 +0800
Subject: [PATCH] 接口调用中间表开发
---
HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/wms/LocationHelper.cs | 262 +++++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 246 insertions(+), 16 deletions(-)
diff --git a/HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/wms/LocationHelper.cs b/HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/wms/LocationHelper.cs
index 4f6d9a9..68614f6 100644
--- a/HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/wms/LocationHelper.cs
+++ b/HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/wms/LocationHelper.cs
@@ -3,9 +3,11 @@
using NLog.Fluent;
using SqlSugar;
using System;
+using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Text;
+using System.Threading;
using System.Threading.Tasks;
using static HH.WCS.JiaTong.dispatch.NDC;
@@ -37,7 +39,7 @@
//鍒濆鍖朙ocationExt鍔犲叆鍒伴泦鍚堢紦瀛� LocationExts = new Dictionary<string, LocationExt>();
var exts = GetAllLocExtList();
- // LogHelper.Info($"鑾峰彇璐т綅鎵╁睍琛ㄤ俊鎭細{JsonConvert.SerializeObject(exts)}");
+ // LogHelper.Info($"鑾峰彇璐т綅鎵╁睍琛ㄤ俊鎭細{JsonConvert.SerializeObject(exts)}");
if (exts.Count > 0)
{
exts.ForEach(a =>
@@ -193,6 +195,14 @@
return result;
}
+ // 瀹氫箟绛夌骇椤哄簭锛堜粠楂樺埌浣庯級
+ private static readonly List<string> LevelOrder = new List<string>
+ {
+ "A", "B", "C", "D", "E", "F", "G", "H", "I", "J",
+ "K", "L", "M", "N", "O", "P", "Q", "R", "S", "T",
+ "U", "V", "W", "X", "Y", "Z"
+ };
+
/// <summary>
/// 鏍规嵁鐗╂枡鎵炬墭鐩� /// </summary>
@@ -200,17 +210,34 @@
/// <param name="lev">鐗╂枡绛夌骇</param>
/// <param name="ItemCode">鐗╂枡缂栫爜</param>
/// <returns></returns>
- internal static List<Location> GetLocByItemCode(string areaCode, string ItemCode, string lev)
+ internal static List<Location> GetLocByItemCode(string areaCode, string ItemCode, string lev, string powderType)
{
+
List<Location> locs;
+
+
var db = new SqlHelper<object>().GetInstance();
-
var queryable = db.Queryable<Location>()
- .LeftJoin<LocCntrRel>((a, b) => a.S_CODE == b.S_LOC_CODE)
- .LeftJoin<CntrItemDetail>((a, b, c) => b.S_CNTR_CODE == c.S_CNTR_CODE)
- .Where((a, b, c) => a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0 && a.S_AREA_CODE == areaCode && c.S_ITEM_CODE == ItemCode);
+ .LeftJoin<LocCntrRel>((a, b) => a.S_CODE == b.S_LOC_CODE)
+ .LeftJoin<CntrItemDetail>((a, b, c) => b.S_CNTR_CODE == c.S_CNTR_CODE)
+ .Where((a, b, c) => a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0 && a.S_AREA_CODE == areaCode);
+ //鍏綅鐮佸尮閰嶅墠鍏綅锛屽叾浠栫殑鍏ㄩ儴閰嶇疆
+ if (ItemCode.Trim().Length == 6)
+ {
+ queryable = queryable.Where((a, b, c) => c.S_ITEM_CODE.StartsWith(ItemCode));
- // LogHelper.Info($"GetLocByItemCode=>鏍规嵁搴撳尯缂栫爜:{areaCode}锛岀墿鏂欑紪鐮�{ItemCode},鐗╂枡浼樺厛绾э紝鐗╂枡绛夌骇璁＄畻鍑烘湁鎵樼洏璐т綅{JsonConvert.SerializeObject(queryable.ToList())}");
+ }
+ else
+ {
+ queryable = queryable.Where((a, b, c) => c.S_ITEM_CODE == ItemCode);
+ }
+ //int targetIndex = LevelOrder.IndexOf(lev);
+ //// 鑾峰彇鎵�湁浣庝簬鎴栫瓑浜庣洰鏍囩瓑绾х殑绛夌骇
+ //var validLevels = LevelOrder
+ //.Skip(targetIndex) // 璺宠繃楂樹簬鐩爣绛夌骇鐨勭瓑绾�+ //.ToList();
+
+ LogHelper.Info($"GetLocByItemCode=>鏍规嵁搴撳尯缂栫爜:{areaCode}锛岀墿鏂欑紪鐮�{ItemCode},鐗╂枡浼樺厛绾�{lev}锛屾満鍙板瀷鍙�{powderType}锛岀墿鏂欑瓑绾ц绠楀嚭鏈夋墭鐩樿揣浣峽JsonConvert.SerializeObject(queryable.ToList())}");
//鍒ゆ柇闇�笉闇�鐗╂枡绛夌骇鏌ユ壘锛屽苟浼樺厛鍑哄簱浣欐枡
if (string.IsNullOrEmpty(lev))
{
@@ -220,7 +247,14 @@
{
locs = queryable.Where((a, b, c) => c.LEV == lev && c.S_BS_TYPE == "浣欐枡").ToList();
}
- // LogHelper.Info($"GetLocByItemCode=>鏌ユ壘浣欐枡,{JsonConvert.SerializeObject(locs)}");
+ if (string.IsNullOrEmpty(powderType))
+ {
+ locs = queryable.Where((a, b, c) => c.S_BS_TYPE == "浣欐枡").ToList();
+ }
+ else
+ {
+ locs = queryable.Where((a, b, c) => c.S_FLTYPE == powderType && c.S_BS_TYPE == "浣欐枡").ToList();
+ }
//娌℃湁浣欐枡鍒欏鎵惧叏閮ㄧ墿鏂� if (locs.Count == 0)
@@ -228,7 +262,20 @@
queryable = db.Queryable<Location>()
.LeftJoin<LocCntrRel>((a, b) => a.S_CODE == b.S_LOC_CODE)
.LeftJoin<CntrItemDetail>((a, b, c) => b.S_CNTR_CODE == c.S_CNTR_CODE)
- .Where((a, b, c) => a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0 && a.S_AREA_CODE == areaCode && c.S_ITEM_CODE == ItemCode);
+ .Where((a, b, c) => a.N_CURRENT_NUM > 0 && a.N_LOCK_STATE == 0 && a.S_AREA_CODE == areaCode && c.S_FLTYPE == powderType);
+ //鍏綅鐮佸尮閰嶅墠鍏綅锛屽叾浠栫殑鍏ㄩ儴閰嶇疆
+ if (ItemCode.Trim().Length == 6)
+ {
+ queryable = queryable.Where((a, b, c) => c.S_ITEM_CODE.StartsWith(ItemCode));
+
+ }
+ else
+ {
+ queryable = queryable.Where((a, b, c) => c.S_ITEM_CODE == ItemCode);
+ }
+ LogHelper.Info($"GetLocByItemCode=>鏃犱綑鏂�鏌ユ壘鍏ㄩ儴{JsonConvert.SerializeObject(queryable.ToList())}");
+
+
if (string.IsNullOrEmpty(lev))
{
locs = queryable.ToList();
@@ -237,13 +284,83 @@
{
locs = queryable.Where((a, b, c) => c.LEV == lev).ToList();
}
- // LogHelper.Info($"GetLocByItemCode=>鏃犱綑鏂�鏌ユ壘鍏ㄩ儴{JsonConvert.SerializeObject(locs)}");
+ if (string.IsNullOrEmpty(powderType))
+ {
+ locs = queryable.ToList();
+ }
+ else
+ {
+ locs = queryable.Where((a, b, c) => c.S_FLTYPE == powderType ).ToList();
+ }
+ LogHelper.Info($"GetLocByItemCode=>鏃犱綑鏂�鏌ユ壘鍏ㄩ儴{JsonConvert.SerializeObject(locs)}");
}
return locs;
}
+ /// <summary>
+ /// 鏍规嵁搴撳尯鑾峰彇绌烘墭
+ /// </summary>
+ /// <param name="areaCode">搴撳尯缂栫爜</param>
+ /// <returns></returns>
+ internal static Location GetLocByAreacode(string areaCode, string type)
+ {
+ Location loc = new Location();
+ var db = new SqlHelper<object>().GetInstance();
+ string CntrCodeWith = "";
+ if (type.Trim().Contains("MA"))
+ {
+ CntrCodeWith = "MA";
+ }
+ else if (type.Trim().Contains("NA"))
+ {
+ CntrCodeWith = "NA";
+ }
+ if (CntrCodeWith == "")
+ {
+ LogHelper.Info($"鎵樼洏绫诲瀷{type}涓嶅湪瑙勫畾鑼冨洿");
+ }
+ var query = db.Queryable<Location>()
+ .LeftJoin<LocCntrRel>((a, b) => a.S_CODE == b.S_LOC_CODE)
+ .LeftJoin<CntrItemDetail>((a, b, c) => b.S_CNTR_CODE == c.S_CNTR_CODE)
+ .Where((a, b, c) => a.S_AREA_CODE == areaCode && a.N_CURRENT_NUM == 1
+ && a.N_LOCK_STATE == 0
+ && b.S_CNTR_CODE != null && b.S_CNTR_CODE.Contains(CntrCodeWith) && c.S_ITEM_CODE == null
+ );
+ loc = query.First();
+
+ return loc;
+ }
+
+ /// <summary>
+ /// 鍒嗛厤鐢垫璐т綅
+ /// </summary>
+ /// <returns></returns>
+ internal static Location GetElevatorLoc()
+ {
+ var db = new SqlHelper<object>().GetInstance();
+ Location location = new Location();
+ //鏌ユ壘鍏ㄩ儴鐢垫锛屽垎閰嶄换鍔℃渶灏戠殑鐢垫
+ var devices = Settings.deviceInfos.Where(a => a.deviceType == 2 && a.enable == 1).ToList();
+ string[] state = new string[] { "鎵ц涓�, "寮�鍙栬揣", "鍙栬揣瀹屾垚" };
+ Dictionary<int, string> dics = new Dictionary<int, string>();
+ foreach (var deviceInfo in devices)
+ {
+ int mst = db.Queryable<WCSTask>().Where(a => a.S_TYPE.Contains("鐢垫") && state.Contains(a.S_B_STATE) && a.S_END_LOC == deviceInfo.TN_Location).Count();
+ dics.Add(mst, deviceInfo.TN_Location);
+ }
+ if (dics.Count > 0)
+ {
+ var dic = dics.OrderBy(a => a.Key).First();
+ location = db.Queryable<Location>().Where(a => a.S_CODE == dic.Value).First();
+ if (location == null)
+ {
+ LogHelper.Info($"鏍规嵁璐т綅缂栫爜:{dic.Value},鏈壘鍒板搴旇揣浣�);
+ }
+ }
+ return location;
+ }
/// <summary>
/// 鏍规嵁鐗╂枡缂栫爜锛屼粨搴撶紪鐮佽幏鍙栨墭鐩樻暟閲� /// </summary>
@@ -423,15 +540,15 @@
}
/// <summary>
- /// 鏍规嵁璐т綅闆嗗悎鑾峰彇 娌℃湁瀹瑰櫒 娌℃湁閿佺殑璐т綅
+ /// 鏍规嵁璐т綅鑾峰彇璐т綅淇℃伅
/// </summary>
/// <param name="loc"></param>
/// <returns></returns>
- internal static List<Location> GetLocListEmptyFree(List<string> loc)
+ internal static Location GetLocByLoc(string loc)
{
//1.0 鏌ヨ揣浣嶅鍣ㄨ〃
var db = new SqlHelper<object>().GetInstance();
- var list = db.Queryable<Location>().Where(a => loc.Contains(a.S_CODE) && a.N_CURRENT_NUM == 0 && a.S_LOCK_STATE.Trim() == "鏃�).ToList();
+ var list = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();
return list;
}
@@ -462,7 +579,11 @@
}
else
{
- LogHelper.Info($"閿佸畾璐т綅{loc}鎴愬姛");
+ LogHelper.Info($"閿佸畾璐т綅{loc}澶辫触,閲嶆柊閿�);
+ Task.Run(() =>
+ {
+ LockLoc(loc, lockState);
+ });
}
return res;
}
@@ -513,13 +634,123 @@
var location = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();
try
{
+ LogHelper.Info($"BindingLoc锛氬紑濮嬭В缁戝鍣細{JsonConvert.SerializeObject(cntrs)}");
db.BeginTran();
var lcrList = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == loc).ToList();
+ //if (!string.IsNullOrEmpty(location.S_NOTE) && lcrList.Count > 0)
+ //{
+ // if (location.S_NOTE == "鍙犵洏" || location.S_NOTE.Trim() == "鐗囪兌鍫嗗彔浣�)
+ // {
+ // LogHelper.Info("鍙犵洏璐т綅鍒犻櫎鎵樼洏");
+ // cntrs = lcrList.Select(a => a.S_CNTR_CODE).ToList();
+
+ // }
+ //}
+ if (lcrList.Count > 0)
+ {
+ cntrs = lcrList.Select(a => a.S_CNTR_CODE).ToList();
+ }
var count = db.Deleteable<LocCntrRel>().Where(it => cntrs.Contains(it.S_CNTR_CODE.Trim()) && it.S_LOC_CODE.Trim() == loc).ExecuteCommand();
location.N_CURRENT_NUM = lcrList.Count - count;
location.S_LOCK_STATE = "鏃�;
location.N_LOCK_STATE = 0;
db.Updateable(location).UpdateColumns(it => new { it.N_CURRENT_NUM, it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();
+ LogHelper.Info($"BindingLoc锛氳В缁戝鍣細{JsonConvert.SerializeObject(cntrs)}鎴愬姛");
+ db.CommitTran();
+ res = true;
+ }
+ catch (Exception ex)
+ {
+ LogHelper.Info($"BindingLoc Error:{ex}");
+ db.RollbackTran();
+ }
+ return res;
+ }
+
+ /// <summary>
+ /// 搴撲綅娓呯┖
+ /// </summary>
+ /// <param name="loc"></param>
+ /// <param name="cntrs"></param>
+ /// <returns></returns>
+ public static bool Clear(string loc, List<string> cntrs)
+ {
+ var res = false;
+ var db = new SqlHelper<object>().GetInstance();
+
+ try
+ {
+ var location = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();
+ if (location == null)
+ {
+ LogHelper.Info($"Clear锛氳揣浣嶏細{loc}璐т綅琛ㄦ煡璇㈤敊璇紝璇峰亣鏌ヨ揣浣嶈〃");
+ return res;
+ }
+ LogHelper.Info($"Clear锛氬紑濮嬭В缁戝鍣細{JsonConvert.SerializeObject(cntrs)}");
+ db.BeginTran();
+ var lcrList = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == loc).ToList();
+ if (lcrList.Count > 0)
+ {
+ cntrs = lcrList.Select(a => a.S_CNTR_CODE).ToList();
+ }
+ var count = db.Deleteable<LocCntrRel>().Where(it => cntrs.Contains(it.S_CNTR_CODE.Trim()) && it.S_LOC_CODE.Trim() == loc).ExecuteCommand();
+ LogHelper.Info($"Clear锛氬紑濮嬪垹闄ゅ鍣細{JsonConvert.SerializeObject(cntrs)}");
+ db.Deleteable<Container>().Where(it => cntrs.Contains(it.S_CODE)).ExecuteCommand();
+
+ location.N_CURRENT_NUM = lcrList.Count - count;
+ location.S_LOCK_STATE = "鏃�;
+ location.N_LOCK_STATE = 0;
+ db.Updateable(location).UpdateColumns(it => new { it.N_CURRENT_NUM, it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();
+ LogHelper.Info($"Clear锛氬紑濮嬪垹闄ゅ鍣ㄧ墿鏂欙細{JsonConvert.SerializeObject(cntrs)}");
+ var CntrItem = db.Queryable<CntrItemDetail>().Where(a => cntrs.Contains(a.S_CNTR_CODE.Trim())).First();
+ if (CntrItem != null)
+ {
+ db.Deleteable<CntrItemDetail>().Where(it => cntrs.Contains(it.S_CNTR_CODE)).ExecuteCommand();
+ }
+ else
+ {
+ LogHelper.Info($"Clear=銆嬫墭鐩�{JsonConvert.SerializeObject(cntrs)}鏃犵墿鏂欐暟鎹�);
+
+ }
+ LogHelper.Info($"BindingLoc锛氳В缁戝鍣細{JsonConvert.SerializeObject(cntrs)}鎴愬姛");
+ db.CommitTran();
+ res = true;
+ }
+ catch (Exception ex)
+ {
+ LogHelper.Info($"BindingLoc Error:{ex}");
+ db.RollbackTran();
+ }
+ return res;
+ }
+ /// <summary>
+ /// 瑙ｉ攣璐т綅锛屽垹闄よ揣浣嶆墭鐩�+ /// </summary>
+ /// <param name="loc"></param>
+ /// <returns></returns>
+ public static bool UnlockLocDeleteCntrs(string loc)
+ {
+ var res = false;
+ var db = new SqlHelper<object>().GetInstance();
+ List<string> cntrs = null; int count = 0;
+ var location = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == loc).First();
+ try
+ {
+ db.BeginTran();
+ var lcrList = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == loc).ToList();
+ if (lcrList.Count > 0)
+ {
+ cntrs = lcrList.Select(a => a.S_CNTR_CODE).ToList();
+ LogHelper.Info($"UnlockLocDeleteCntrs锛氳揣浣峽loc}锛氭煡璇㈢粦瀹氭墭鐩榹cntrs}");
+ LogHelper.Info($"UnlockLocDeleteCntrs锛氬紑濮嬪垹闄ゅ鍣細{JsonConvert.SerializeObject(cntrs)}");
+ count = db.Deleteable<LocCntrRel>().Where(it => cntrs.Contains(it.S_CNTR_CODE.Trim()) && it.S_LOC_CODE.Trim() == loc).ExecuteCommand();
+
+ }
+
+ location.N_CURRENT_NUM = lcrList.Count - count;
+ location.S_LOCK_STATE = "鏃�;
+ location.N_LOCK_STATE = 0;
+ db.Updateable(location).UpdateColumns(it => new { it.S_LOCK_STATE, it.N_LOCK_STATE, it.N_CURRENT_NUM }).ExecuteCommand();
db.CommitTran();
res = true;
}
@@ -529,7 +760,6 @@
}
return res;
}
-
/// <summary>
/// 瑙ｉ攣璐т綅
/// </summary>
@@ -546,7 +776,7 @@
var lcrList = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == loc).ToList();
location.S_LOCK_STATE = "鏃�;
location.N_LOCK_STATE = 0;
- db.Updateable(location).UpdateColumns(it => new { it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();
+ db.Updateable(location).UpdateColumns(it => new { it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();
db.CommitTran();
res = true;
}
--
Gitblit v1.9.1