From 44908416a5ecd4596118505eea8501681739963f Mon Sep 17 00:00:00 2001
From: IPC-610 <IPC-610@DESKTOP-6LEOOS3>
Date: 星期三, 25 九月 2024 18:53:09 +0800
Subject: [PATCH] Merge branch 'master' of http://47.95.120.53:8083/r/WCSNet6

---
 Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs |   71 +++++++++++++++++++++++++----------
 1 files changed, 50 insertions(+), 21 deletions(-)

diff --git a/Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs b/Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs
index 2f85b2f..91deb8c 100644
--- a/Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs
+++ b/Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs
@@ -193,38 +193,67 @@
         checkTaskInfo.BoxType = taskInfo.BoxType;
         checkTaskInfo.Qty = taskInfo.Qty;
         checkTaskInfo.Status = "1";//宸茬粦瀹�
-        checkTaskInfo.PZNo = skuInfo.PZNo;
-        //鏇存柊鍒嗘嫞浠诲姟
-        await _wcsCheckTaskRep.AsUpdateable(checkTaskInfo).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
+        checkTaskInfo.PZNo = skuInfo.PZNo;        
 
-        #region#缁橮LC鍐欐暟鎹�
-
+        #region#缁橮LC鍐欏叆鎶撶鍝佺鍙�
+        var modPlc = await _wcsDeviceRep.Context.Queryable<WcsPlc>().FirstAsync(s => s.Id == deviceInfo.PlcId);
+        if (modPlc == null)
+        {
+            throw Oops.Bah("鎵句笉鍒癙LC淇℃伅");
+        }
+        PLCUtil modUtil = new PLCUtil(modPlc);
+        var ret= modUtil.SetPlcDBValue(checkTaskInfo.PosType, checkTaskInfo.DbNumber, checkTaskInfo.PlcPos, checkTaskInfo.PZNo);
+        if (ret.IsSucceed)
+        {
+            //鍐欏叆娴佺▼瀛楁垚鍔熷悗鏇存柊鍒嗘嫞浠诲姟
+            await _wcsCheckTaskRep.AsUpdateable(checkTaskInfo).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
+        }
         #endregion
     }
 
     [HttpPost]
     [ApiDescriptionSettings(Name = "CloseTaskForPLC")]
     [DisplayName("浠诲姟缁撴壒")]
-    public async Task CloseTaskForPLC(BindTaskPLCInput input)
+    public async Task CloseTaskForPLC(CloseTaskPLCInput input)
     {
-        #region 璇锋眰PLC鎺ュ彛锛堣繖涓柟娉曞疄闄呮槸棰勭粨鎵癸紝缁橮LC鍙戦�侀缁撴壒淇℃伅锛岀劧鍚嶱LC鍐嶇粰WCS鍙戦�佺粨鎵逛俊鍙峰啀灏嗗垎鎷d俊鎭竻绌猴級
-
-        #endregion
         //鍒嗘嫞浠诲姟淇℃伅
         var checkTaskList = _wcsCheckTaskRep.Context.Queryable<WcsCheckTask>().Where(w => w.LotNo == input.lotNo && w.Status == "1").ToList();
+        if (checkTaskList.Count <= 0)
+        {
+            throw Oops.Bah("鎵句笉鍒拌鎵规鍒嗘嫞浠诲姟淇℃伅");
+        }
         foreach (var item in checkTaskList)
         {
-            item.OrderNo = "";
-            item.TaskNo = "";
-            item.LotNo = "";
-            item.SkuNo = "";
-            item.SkuName = "";
-            item.BoxType = "";
-            item.Qty = 0;
-            item.PZNo = "";
-            item.Status = "0";//鏈粦瀹�           
-        }
-        //鏇存柊鍒嗘嫞浠诲姟
-        await _wcsCheckTaskRep.AsUpdateable(checkTaskList).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
+            #region#缁橮LC鍐欏叆缁撴壒鎵规鍙�
+            var deviceInfo = await _wcsDeviceRep.Context.Queryable<WcsDevice>().FirstAsync(w => w.StationNum == item.Port);
+            if (deviceInfo == null)
+            {
+                throw Oops.Bah($"鎵句笉鍒板伐浣嶅彿锛歿item.Port} 鐨勭爜鍨涘伐浣嶄俊鎭�");
+            }
+            var modPlc = await _wcsDeviceRep.Context.Queryable<WcsPlc>().FirstAsync(s => s.Id == deviceInfo.PlcId);
+            if (modPlc == null)
+            {
+                throw Oops.Bah($"鎵句笉鍒板伐浣嶅彿锛歿item.Port} 鐨勮澶囦俊鎭�");
+            }
+            PLCUtil modUtil = new PLCUtil(modPlc);
+            var ret = modUtil.SetPlcDBValue(item.PosType, item.DbNumber, item.PlcPos, item.PZNo);
+            if (ret.IsSucceed)
+            {
+                //鍐欏叆娴佺▼瀛楁垚鍔熷悗鏇存柊鍒嗘嫞浠诲姟
+                item.OrderNo = "";
+                item.TaskNo = "";
+                item.LotNo = "";
+                item.SkuNo = "";
+                item.SkuName = "";
+                item.BoxType = "";
+                item.Qty = 0;
+                item.PZNo = "";
+                item.Status = "0";//鏈粦瀹� 
+
+                //鏇存柊鍒嗘嫞浠诲姟
+                await _wcsCheckTaskRep.AsUpdateable(item).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
+            }
+            #endregion                      
+        }  
     }
 }

--
Gitblit v1.8.0