From 06d50c0f77ccf01ebe751a819e9ad06b871d8e90 Mon Sep 17 00:00:00 2001
From: wxw <Administrator@DESKTOP-5BIMHQ3>
Date: 星期四, 26 九月 2024 14:59:15 +0800
Subject: [PATCH] 增加WCS接收WMS下发的入库单任务;修改分拣码垛绑定和结批功能

---
 Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs |   61 +++++++++++++++++++++---------
 1 files changed, 42 insertions(+), 19 deletions(-)

diff --git a/Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs b/Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs
index 154209a..2033a79 100644
--- a/Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs
+++ b/Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs
@@ -203,11 +203,22 @@
             throw Oops.Bah("鎵句笉鍒癙LC淇℃伅");
         }
         PLCUtil modUtil = new PLCUtil(modPlc);
-        var ret= modUtil.SetPlcDBValue(checkTaskInfo.PosType, checkTaskInfo.DbNumber, checkTaskInfo.PlcPos, checkTaskInfo.PZNo);
-        if (ret.IsSucceed)
+        if (modUtil.Connected)
         {
-            //鍐欏叆娴佺▼瀛楁垚鍔熷悗鏇存柊鍒嗘嫞浠诲姟
-            await _wcsCheckTaskRep.AsUpdateable(checkTaskInfo).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
+            var ret = modUtil.SetPlcDBValue(checkTaskInfo.PosType, checkTaskInfo.DbNumber, checkTaskInfo.PlcPos, checkTaskInfo.PZNo);
+            if (ret.IsSucceed)
+            {
+                //鍐欏叆娴佺▼瀛楁垚鍔熷悗鏇存柊鍒嗘嫞浠诲姟
+                await _wcsCheckTaskRep.AsUpdateable(checkTaskInfo).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
+            }
+            else
+            {
+                throw Oops.Bah("涓嶱CL浜や簰澶辫触锛岀粦瀹氬け璐ワ紒");
+            }
+        }
+        else
+        {
+            throw Oops.Bah("PCL鏈繛鎺ワ紝缁戝畾澶辫触锛�");
         }
         #endregion
     }
@@ -242,23 +253,35 @@
                 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)
+            if (modUtil.Connected)
             {
-                //鍐欏叆娴佺▼瀛楁垚鍔熷悗鏇存柊鍒嗘嫞浠诲姟
-                item.OrderNo = "";
-                item.TaskNo = "";
-                item.LotNo = "";
-                item.SkuNo = "";
-                item.SkuName = "";
-                item.BoxType = "";
-                item.Qty = 0;
-                item.PZNo = "";
-                item.Status = "0";//鏈粦瀹� 
+                var ret = modUtil.SetPlcDBValue(item.PosTypeLot, item.DbNumber, item.PosLot, "1");
+                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();
+                    //鏇存柊鍒嗘嫞浠诲姟
+                    await _wcsCheckTaskRep.AsUpdateable(item).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
+                }
+                else
+                {
+                    throw Oops.Bah("涓嶱CL浜や簰澶辫触锛岀粨鎵瑰け璐ワ紒");
+                }
             }
+            else
+            {
+                throw Oops.Bah("PCL鏈繛鎺ワ紝缁撴壒澶辫触锛�");
+            }
+
 
             //Service.WcsDevice.Dto.WcsDeviceTaskOrderDto order=  await _wcsDeviceRep.Context.Queryable<WcsDevice>()
             //    .InnerJoin<WcsPlc>((device, plc) => device.PlcId == plc.Id)
@@ -284,7 +307,7 @@
             ////涓嬪彂鍒嗘嫞浠诲姟
             //HubUtil.PublicCheckTask(order.Adapt<Service.WcsDevice.Dto.WcsDeviceTaskOrderDto>());
 
-            #endregion                      
+            #endregion
         }  
     }
 }

--
Gitblit v1.8.0