From 2ca90a404fa1ab94eb6374f50c6ddd47a2b7f0e6 Mon Sep 17 00:00:00 2001
From: kazelee <1847801760@qq.com>
Date: 星期四, 31 七月 2025 17:23:57 +0800
Subject: [PATCH] 删除有问题的TCP旧代码, 优化事务处理和ERP数据模型
---
wms/WCSHelper.cs | 95 ++++++++++++++++++++++++-----------------------
1 files changed, 49 insertions(+), 46 deletions(-)
diff --git a/wms/WCSHelper.cs b/wms/WCSHelper.cs
index 9962930..c18f8d9 100644
--- a/wms/WCSHelper.cs
+++ b/wms/WCSHelper.cs
@@ -51,47 +51,8 @@
return loc == null ? "0" : loc.S_AGV_SITE;
}
#endregion
-
- #region 浠诲姟鍒涘缓 / 涓嬪彂 / 鏌ヨ
- internal static string GenerateTaskNo() {
- //var id = SYSHelper.GetSerialNumber("浠诲姟鍙�, "TN");
- //var date = DateTime.Now.ToString("yyMMdd");
- //return $"TN{date}{id.ToString().PadLeft(4, '0')}";
- return SYSHelper.GenerateSN("浠诲姟鍙�, "TN", "yyMMdd");
- }
-
- internal static bool UpdateTaskState(TN_Task task, string state) {
- var res = false;
- var db = new SqlHelper<TN_Task>().GetInstance();
- task.S_B_STATE = state;
- res = db.Updateable(task).UpdateColumns(it => new { it.S_B_STATE }).ExecuteCommand() > 0;
- return res;
- }
-
- internal static bool UpdateTaskState(TN_Task task) {
- var res = false;
- var db = new SqlHelper<TN_Task>().GetInstance();
- task.S_B_STATE = TN_Task.GetStateStr(task.N_B_STATE);
- task.T_MODIFY = DateTime.Now;
- res = db.Updateable(task).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE, it.T_MODIFY }).ExecuteCommand() > 0;
- return res;
- }
-
- internal static bool UpdateEqTaskNo(TN_Task task) {
- var res = false;
- var db = new SqlHelper<TN_Task>().GetInstance();
- task.T_MODIFY = DateTime.Now;
- res = db.Updateable(task).UpdateColumns(it => new { it.S_EQ_TASK_CODE, it.T_MODIFY }).ExecuteCommand() > 0;
- return res;
- }
-
- internal static TN_Task GetTask(string taskNo) {
- var db = new SqlHelper<TN_Task>().GetInstance();
- var task = db.Queryable<TN_Task>().Where(a => a.S_CODE == taskNo).First();
- return task;
- }
- #endregion
-
+
+ private const bool __瀹瑰櫒鏌ヨ缁戝畾妯″潡__ = false; // 浠呯敤浜庡垎娈�娌℃湁瀹炶川鎰忎箟
#region 瀹瑰櫒鐩稿叧淇℃伅 鏌ヨ / 缁戝畾
/// <summary>
/// 鏍规嵁 [ 瀹瑰櫒鍙�] , 鏌ヨ褰撳墠瀹瑰櫒鍏宠仈鐨�[ 璐т綅 ] [ 璐т綅瀹瑰櫒 ] [ 瀹瑰櫒璐у搧 ] 淇℃伅 ( 鍙煡璇�1 鏉�)
@@ -171,9 +132,10 @@
loc.T_MODIFY = DateTime.Now;
return locCntrRel;
- }
+ }
#endregion
+ private const bool __鍒涘缓浠诲姟妯″潡__ = false; // 浠呯敤浜庡垎娈�娌℃湁瀹炶川鎰忎箟
#region 璧风偣 / 缁堢偣璐т綅閿�+ 鍒涘缓浠诲姟
/// <summary>
/// 璧风偣鍑哄簱閿�@@ -211,6 +173,17 @@
loc.T_MODIFY = System.DateTime.Now;
LogHelper.Info($"缁堢偣鍏ュ簱閿�缁堢偣璐т綅='{loc.S_CODE}',鏉ユ簮='{lockSource}'");
+ }
+
+ /// <summary>
+ /// 鐢熸垚浠诲姟鍙�閫氬父鍙BuildTask浣跨敤,鏁呰涓虹鏈�
+ /// </summary>
+ /// <returns></returns>
+ private static string GenerateTaskNo() {
+ //var id = SYSHelper.GetSerialNumber("浠诲姟鍙�, "TN");
+ //var date = DateTime.Now.ToString("yyMMdd");
+ //return $"TN{date}{id.ToString().PadLeft(4, '0')}";
+ return SYSHelper.GenerateSN("浠诲姟鍙�, "TN", "yyMMdd");
}
/// <summary>
@@ -254,7 +227,7 @@
/// <param name="pri">浼樺厛绾�/param>
/// <param name="agv">AGV 绫诲瀷</param>
/// <returns></returns>
- public static TN_Task BuildTaskWithLocLock(TN_Location startLoc, TN_Location endLoc, string cntId, string type,
+ public static TN_Task BuildTaskAndLockLoc(TN_Location startLoc, TN_Location endLoc, string cntId, string type,
int pri = 3, int agv = 1) {
var task = BuildTask(startLoc, endLoc, cntId, type, pri);
@@ -263,14 +236,44 @@
return task;
}
-
-
#endregion
+ private const bool __浠诲姟鍒嗗彂澶勭悊妯″潡__ = false; // 浠呯敤浜庡垎娈�娌℃湁瀹炶川鎰忎箟
#region 浠诲姟鍒嗗彂 / 鎵ц / 璁板綍
internal static bool CheckActionRecordExist(string no, int code) {
var db = new SqlHelper<TN_Task_Action>().GetInstance();
return db.Queryable<TN_Task_Action>().Count(a => a.S_TASK_CODE == no && a.N_ACTION_CODE == code) > 0;
+ }
+
+ internal static bool UpdateTaskState(TN_Task task, string state) {
+ var res = false;
+ var db = new SqlHelper<TN_Task>().GetInstance();
+ task.S_B_STATE = state;
+ res = db.Updateable(task).UpdateColumns(it => new { it.S_B_STATE }).ExecuteCommand() > 0;
+ return res;
+ }
+
+ internal static bool UpdateTaskState(TN_Task task) {
+ var res = false;
+ var db = new SqlHelper<TN_Task>().GetInstance();
+ task.S_B_STATE = TN_Task.GetStateStr(task.N_B_STATE);
+ task.T_MODIFY = DateTime.Now;
+ res = db.Updateable(task).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE, it.T_MODIFY }).ExecuteCommand() > 0;
+ return res;
+ }
+
+ internal static bool UpdateEqTaskNo(TN_Task task) {
+ var res = false;
+ var db = new SqlHelper<TN_Task>().GetInstance();
+ task.T_MODIFY = DateTime.Now;
+ res = db.Updateable(task).UpdateColumns(it => new { it.S_EQ_TASK_CODE, it.T_MODIFY }).ExecuteCommand() > 0;
+ return res;
+ }
+
+ internal static TN_Task GetTask(string taskNo) {
+ var db = new SqlHelper<TN_Task>().GetInstance();
+ var task = db.Queryable<TN_Task>().Where(a => a.S_CODE == taskNo).First();
+ return task;
}
internal static void SetTaskBegin(TN_Task task, string forklift_no) {
@@ -297,7 +300,7 @@
internal static void SetTaskFail(TN_Task task) {
var db = new SqlHelper<TN_Task>().GetInstance();
if (task != null) {
- //鍒ゆ柇鏈夋病鏈夊彇璐у畬鎴�娌℃湁灏卞彉鎴愬け璐ャ�鏈夊彇璐у畬鎴愰粯璁ゅ畬鎴愪簡 (璺熸嵁椤圭洰鑰屽畾,鏈変簺椤圭洰浜哄伐鎷夎蛋浜嗕篃娌℃湁鏀惧埌缁堢偣) 銆�+ //鍒ゆ柇鏈夋病鏈夊彇璐у畬鎴�娌℃湁灏卞彉鎴愬け璐�鏈夊彇璐у畬鎴愰粯璁ゅ畬鎴愪簡 (璺熸嵁椤圭洰鑰屽畾,鏈変簺椤圭洰浜哄伐鎷夎蛋浜嗕篃娌℃湁鏀惧埌缁堢偣)
task.N_B_STATE = 4;
task.S_B_STATE = TN_Task.GetStateStr(task.N_B_STATE);
db.Updateable(task).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE }).ExecuteCommand();
--
Gitblit v1.9.1