From f4163300190b9eca182419543540e3c1f2a8ebb6 Mon Sep 17 00:00:00 2001
From: 肖洋 <cathay_xy@163.com>
Date: 星期三, 11 十二月 2024 14:39:19 +0800
Subject: [PATCH] Merge branch 'master' of http://115.159.85.185:8098/r/HuaYiZhongHeng/BaiBuLiKu

---
 /dev/null                                                                                        |    3 -
 Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs         |   25 ++++++------
 Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs |   67 +++++++++++++++++----------------
 3 files changed, 47 insertions(+), 48 deletions(-)

diff --git a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/obj/Debug/net6.0/staticwebassets/msbuild.buildMultiTargeting.WIDESEAWCS_Server.props b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/obj/Debug/net6.0/staticwebassets/msbuild.buildMultiTargeting.WIDESEAWCS_Server.props
deleted file mode 100644
index c119e5c..0000000
--- a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/obj/Debug/net6.0/staticwebassets/msbuild.buildMultiTargeting.WIDESEAWCS_Server.props
+++ /dev/null
@@ -1,3 +0,0 @@
-锘�<Project>
-  <Import Project="..\build\WIDESEAWCS_Server.props" />
-</Project>
\ No newline at end of file
diff --git a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/obj/Debug/net6.0/staticwebassets/msbuild.buildTransitive.WIDESEAWCS_Server.props b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/obj/Debug/net6.0/staticwebassets/msbuild.buildTransitive.WIDESEAWCS_Server.props
deleted file mode 100644
index 9a801fa..0000000
--- a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/obj/Debug/net6.0/staticwebassets/msbuild.buildTransitive.WIDESEAWCS_Server.props
+++ /dev/null
@@ -1,3 +0,0 @@
-锘�<Project>
-  <Import Project="..\buildMultiTargeting\WIDESEAWCS_Server.props" />
-</Project>
\ No newline at end of file
diff --git a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
index 9e9e3ef..49943b4 100644
--- a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
+++ b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
@@ -262,12 +262,12 @@
         try
         {
             // 鏇存柊璐т綅鍜屽簱瀛樹俊鎭�
-            (DtStockInfo updateStock, DtLocationInfo locationInf) = UpdateStockLocation(stock, task.NextAddress);
+            (DtStockInfo updateStock, DtLocationInfo locationInForm, DtLocationInfo locationInfoTo) = UpdateStockLocation(stock, task);
             var taskHty = CreateHistoricalTask(task);
-            LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "绉诲簱浠诲姟瀹屾垚", $"璐т綅鍦板潃锛歿task.TargetAddress},淇敼鍚庡簱瀛樻暟鎹細{JsonConvert.SerializeObject(updateStock)}锛屽師鍏堣揣浣嶆暟鎹細{locationInf}");
+            LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "绉诲簱浠诲姟瀹屾垚", $"璐т綅鍦板潃锛歿task.TargetAddress},淇敼鍚庡簱瀛樻暟鎹細{JsonConvert.SerializeObject(updateStock)}锛屽師鍏堣揣浣嶆暟鎹細{locationInForm}");
 
             // 鎵ц鏁版嵁搴撲簨鍔�
-            bool isResult = await ExecuteTransaction(updateStock, taskHty, locationInf, task.TaskId);
+            bool isResult = await ExecuteTransaction(updateStock, taskHty, locationInForm, locationInfoTo, task.TaskId);
             if (isResult)
                 content.OK("绉诲簱浠诲姟瀹屾垚鎴愬姛");
             else
@@ -522,6 +522,8 @@
                 LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍑哄簱浠诲姟", "");
                 return await CompleteStackTaskAsync(task, stock);
 
+            case (int)TaskRelocationTypeEnum.Relocation:
+                return await CompleteTransferTaskAsync(task, stock);
             default:
                 return content.Error("浠诲姟绫诲瀷涓嶅瓨鍦�");
         }
@@ -1450,20 +1452,19 @@
     /// <param name="stock">搴撳瓨瀵硅薄</param>
     /// <param name="toLocation">鐩爣浣嶇疆</param>
     // 鏇存柊搴撳瓨鍜屼綅缃俊鎭�
-    private (DtStockInfo, DtLocationInfo) UpdateStockLocation(DtStockInfo stock, string toLocation)
+    private (DtStockInfo, DtLocationInfo, DtLocationInfo) UpdateStockLocation(DtStockInfo stock, Dt_Task task)
     {
-        // 鑾峰彇搴撳瓨淇℃伅
-        var locationInfo = _locationRepository.QueryFirst(x => x.LocationCode == stock.LocationCode);
-        // 灏嗗簱瀛樼姸鎬佽缃负鍦ㄥ簱
-        locationInfo.LocationStatus = LocationEnum.InStock.ObjToInt();
+        //淇敼鏉ユ簮搴撲綅鍜� 鐩爣搴撲綅鐘舵��
+        var fromLocation = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway);
+        fromLocation.LocationStatus = LocationEnum.Free.ObjToInt();
+        var toLocation = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway);
+        toLocation.LocationStatus = LocationEnum.InStock.ObjToInt();
 
         // 灏嗗簱瀛樹綅缃缃负鐩爣浣嶇疆
-        stock.LocationCode = toLocation;
-        // 灏嗗簱瀛樼姸鎬佽缃负鍦ㄥ簱
-        stock.LocationInfo.LocationStatus = LocationEnum.InStock.ObjToInt();
+        stock.LocationCode = task.TargetAddress;
 
         // 杩斿洖鏇存柊鍚庣殑搴撳瓨鍜屼綅缃俊鎭�
-        return (stock, locationInfo);
+        return (stock, fromLocation, toLocation);
     }
 
     /// <summary>
diff --git a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
index c50b4d1..0b56001 100644
--- a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
+++ b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
@@ -826,43 +826,44 @@
 
 
     #region MyRegion
-    //private async Task<bool> ExecuteTransaction(DtStockInfo stock, Dt_Task_Hty taskHty, DtLocationInfo locationInfo, int taskId)
-    //{
-    //    _unitOfWorkManage.BeginTran();
-    //    try
-    //    {
-    //        var isUpdateStock = true;
+    private async Task<bool> ExecuteTransaction(DtStockInfo stock, Dt_Task_Hty taskHty, DtLocationInfo fromLocation,DtLocationInfo toLocation, int taskId)
+    {
+        _unitOfWorkManage.BeginTran();
+        try
+        {
+            var isUpdateStock = true;
 
-    //        // 娣诲姞鍘嗗彶浠诲姟
-    //        var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;
+            // 娣诲姞鍘嗗彶浠诲姟
+            var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;
 
-    //        // 淇敼绉诲簱鍓嶈揣浣嶇姸鎬�
-    //        var isUpdateLoc = _locationRepository.UpdateData(locationInfo);
+            // 淇敼绉诲簱鍓嶈揣浣嶇姸鎬�
+            var isUpdateLocF = _locationRepository.UpdateData(fromLocation);
+            var isUpdateLocT = _locationRepository.UpdateData(toLocation);
 
-    //        // 鍒犻櫎浠诲姟鏁版嵁
-    //        var isTaskDelete = await Delete(taskId);
+            // 鍒犻櫎浠诲姟鏁版嵁
+            var isTaskDelete = await Delete(taskId);
 
-    //        // 鎻愪氦鎴栧洖婊氫簨鍔�
-    //        if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLoc)
-    //        {
-    //            LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "浠诲姟瀹屾垚", $"浜嬪姟澶勭悊瀹屾垚,鎻愪氦浜嬪姟銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鏇存柊鎴栨坊鍔犲簱瀛橈細{isUpdateStock},淇敼绉诲簱鍓嶈揣浣嶇姸鎬侊細{isUpdateLoc}");
-    //            _unitOfWorkManage.CommitTran();
-    //            return true;
-    //        }
-    //        else
-    //        {
-    //            LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "浠诲姟瀹屾垚", $"鏁版嵁澶勭悊澶辫触,璇锋鏌ユ暟鎹槸鍚︽纭�,鏁版嵁鍥炴粴銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鏇存柊搴撳瓨锛歿isUpdateStock},淇敼绉诲簱鍓嶈揣浣嶇姸鎬侊細{isUpdateLoc}");
-    //            _unitOfWorkManage.RollbackTran();
-    //            return false;
-    //        }
-    //    }
-    //    catch (Exception err)
-    //    {
-    //        LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, $"浠诲姟瀹屾垚,绯荤粺寮傚父锛屽紓甯镐俊鎭細{err.Message}", "鏃犲弬鏁�");
-    //        _unitOfWorkManage.RollbackTran();
-    //        throw; // 鎶涘嚭寮傚父浠ヤ究澶栭儴鎹曡幏
-    //    }
-    //}
+            // 鎻愪氦鎴栧洖婊氫簨鍔�
+            if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLocF && isUpdateLocT)
+            {
+                LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "浠诲姟瀹屾垚", $"浜嬪姟澶勭悊瀹屾垚,鎻愪氦浜嬪姟銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鏇存柊鎴栨坊鍔犲簱瀛橈細{isUpdateStock},淇敼绉诲簱鍓嶈揣浣嶇姸鎬侊細{isUpdateLocF}");
+                _unitOfWorkManage.CommitTran();
+                return true;
+            }
+            else
+            {
+                LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "浠诲姟瀹屾垚", $"鏁版嵁澶勭悊澶辫触,璇锋鏌ユ暟鎹槸鍚︽纭�,鏁版嵁鍥炴粴銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鏇存柊搴撳瓨锛歿isUpdateStock},淇敼绉诲簱鍓嶈揣浣嶇姸鎬侊細{isUpdateLocF}");
+                _unitOfWorkManage.RollbackTran();
+                return false;
+            }
+        }
+        catch (Exception err)
+        {
+            LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, $"浠诲姟瀹屾垚,绯荤粺寮傚父锛屽紓甯镐俊鎭細{err.Message}", "鏃犲弬鏁�");
+            _unitOfWorkManage.RollbackTran();
+            throw new Exception(err.Message); // 鎶涘嚭寮傚父浠ヤ究澶栭儴鎹曡幏
+        }
+    }
     #endregion
 
     #region 妫�娴嬮珮娓╁簱鏄惁鏈夊彲鍑哄簱搴撳瓨

--
Gitblit v1.9.3