From 9b85a8b67aa6354ee9ea1a13c5799bf1c934922f Mon Sep 17 00:00:00 2001
From: IPC-610 <IPC-610@DESKTOP-6LEOOS3>
Date: 星期四, 31 十月 2024 18:12:14 +0800
Subject: [PATCH] 修改问题

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

diff --git a/Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs b/Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs
index 5d9c864..b99dd08 100644
--- a/Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs
+++ b/Admin.NET/WCS.Application/Service/WcsCheckTask/WcsCheckTaskService.cs
@@ -6,6 +6,7 @@
 
 using Admin.NET.Core.Service;
 using AngleSharp.Dom;
+using DocumentFormat.OpenXml.Vml.Office;
 using Elastic.Clients.Elasticsearch.Tasks;
 using Microsoft.AspNetCore.Http;
 using WCS.Application.Entity;
@@ -45,7 +46,7 @@
             .WhereIF(!string.IsNullOrEmpty(input.SearchKey), u =>
                 u.OrderNo.Contains(input.SearchKey)
                 || u.RoboatNo.Contains(input.SearchKey)
-                || u.LineNO.Contains(input.SearchKey)
+                || u.LineNo.Contains(input.SearchKey)
                 || u.Port.Contains(input.SearchKey)
                 || u.LotNo.Contains(input.SearchKey)
                 || u.SkuNo.Contains(input.SearchKey)
@@ -57,7 +58,7 @@
             )
             .WhereIF(!string.IsNullOrWhiteSpace(input.OrderNo), u => u.OrderNo.Contains(input.OrderNo.Trim()))
             .WhereIF(!string.IsNullOrWhiteSpace(input.RoboatNo), u => u.RoboatNo.Contains(input.RoboatNo.Trim()))
-            .WhereIF(!string.IsNullOrWhiteSpace(input.LineNO), u => u.LineNO.Contains(input.LineNO.Trim()))
+            .WhereIF(!string.IsNullOrWhiteSpace(input.LineNo), u => u.LineNo.Contains(input.LineNo.Trim()))
             .WhereIF(!string.IsNullOrWhiteSpace(input.Port), u => u.Port.Contains(input.Port.Trim()))
             .WhereIF(!string.IsNullOrWhiteSpace(input.LotNo), u => u.LotNo.Contains(input.LotNo.Trim()))
             .WhereIF(!string.IsNullOrWhiteSpace(input.SkuNo), u => u.SkuNo.Contains(input.SkuNo.Trim()))
@@ -147,13 +148,13 @@
     }
 
     /// <summary>
-    /// 鎵嬪姩缁戝畾浠诲姟鍒癙LC
+    /// 鎵嬪姩缁戝畾浠诲姟
     /// </summary>
     /// <param name="input"></param>
     /// <returns></returns>
     [HttpPost]
     [ApiDescriptionSettings(Name = "BindTaskForPLC")]
-    [DisplayName("鎵嬪姩缁戝畾浠诲姟鍒癙LC")]
+    [DisplayName("鎵嬪姩缁戝畾浠诲姟")]
     public async Task BindTaskForPLC(BindTaskPLCInput input)
     {
         var deviceInfo = await _wcsDeviceRep.GetByIdAsync(input.deviceId);
@@ -193,31 +194,120 @@
         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鍐欏叆鎶撶鍝佺鍙�
+        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);
+        if (modUtil.Connected)
+        {
+            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
     }
 
+    /// <summary>
+    /// 浠诲姟寮哄埗缁撴壒
+    /// </summary>
+    /// <param name="input"></param>
+    /// <returns></returns>
     [HttpPost]
     [ApiDescriptionSettings(Name = "CloseTaskForPLC")]
-    [DisplayName("浠诲姟缁撴壒")]
-    public async Task CloseTaskForPLC(BindTaskPLCInput input)
+    [DisplayName("浠诲姟寮哄埗缁撴壒")]
+    public async Task CloseTaskForPLC(CloseTaskPLCInput input)
     {
-        #region 璇锋眰PLC鎺ュ彛
-        #endregion
-        //鍒嗘嫞浠诲姟淇℃伅
+        //  娉ㄩ噴锛氭紨绀烘ā寮忎笉缁戝畾鍒嗛亾銆俵iudl 2024-10-30
+        //if (PLCTaskAction.boDemo)
+        //{
+        //    //婕旂ず妯″紡
+        //    var checkTaskList2 = await _wcsCheckTaskRep.Context.Queryable<WcsCheckTask>().FirstAsync(w => w.Port == "208");
+
+        //    var deviceInfo = await _wcsDeviceRep.Context.Queryable<WcsDevice>().FirstAsync(w => w.StationNum == "208");
+        //    if (deviceInfo == null)
+        //    {
+        //        throw Oops.Bah($"鎵句笉鍒板伐浣嶅彿锛�208鐨勭爜鍨涘伐浣嶄俊鎭�");
+        //    }
+        //    var modPlc = await _wcsDeviceRep.Context.Queryable<WcsPlc>().FirstAsync(s => s.Id == deviceInfo.PlcId);
+        //    if (modPlc == null)
+        //    {
+        //        throw Oops.Bah($"鎵句笉鍒板伐浣嶅彿锛�208鐨勮澶囦俊鎭�");
+        //    }
+        //    PLCUtil modUtil = new PLCUtil(modPlc);
+            
+        //    var ret = modUtil.SetPlcDBValue(checkTaskList2.PosTypeLot, checkTaskList2.DbNumber, checkTaskList2.PosLot, "1");
+        //    return;
+        //}
+
+        // 姝e父妯″紡
+        if (string.IsNullOrWhiteSpace(input.lotNo))
+        {
+            throw Oops.Bah($"璇ュ伐浣嶆湭缁戝畾浠诲姟锛�");
+        }
         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.LotNo = "";
-            item.SkuNo = "";
-            item.SkuName = "";
-            item.BoxType = "";
-            item.Qty = 0;
-            item.Status = "0";//鏈粦瀹�           
+            #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);
+            if (modUtil.Connected)
+            {
+                var ret = modUtil.SetPlcDBValue(item.PosTypeLot, item.DbNumber, item.PosLot, "0");    // 瑙g粦鍒嗛亾
+                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();
+                }
+                else
+                {
+                    throw Oops.Bah("涓嶱CL浜や簰澶辫触锛岀粨鎵瑰け璐ワ紒");
+                }
+            }
+            else
+            {
+                throw Oops.Bah("PCL鏈繛鎺ワ紝缁撴壒澶辫触锛�");
+            }
+            #endregion
         }
-        //鏇存柊鍒嗘嫞浠诲姟
-        await _wcsCheckTaskRep.AsUpdateable(checkTaskList).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
     }
 }

--
Gitblit v1.8.0