From 8a52166f4021216bad4597babfbb56e6f8908b0b Mon Sep 17 00:00:00 2001
From: 南骏 池 <chiffly@163.com>
Date: 星期六, 24 五月 2025 08:11:55 +0800
Subject: [PATCH] 1.扫码获取当前线体称重机的重量.

---
 service/Wom/WomdaaManager.cs |   66 ++++++++++++++++++++++++++++-----
 1 files changed, 56 insertions(+), 10 deletions(-)

diff --git a/service/Wom/WomdaaManager.cs b/service/Wom/WomdaaManager.cs
index 78c156e..6eec2ea 100644
--- a/service/Wom/WomdaaManager.cs
+++ b/service/Wom/WomdaaManager.cs
@@ -407,7 +407,7 @@
     public dynamic getKbBarMxInfo(dynamic query)
     {
 
-        var sql = string.Format(@"SELECT ITEM_BARCODE, QUANTITY,item_no,item_name,item_model
+        var sql = string.Format(@"SELECT ITEM_BARCODE, QUANTITY,item_no,item_name,item_model,weight
 FROM MES_INV_ITEM_BARCODES_TBMX A
          LEFT JOIN WOMDAA B ON B.daa001 = A.DAA_001
         LEFT JOIN MES_ITEMS C ON C.item_id = B.daa002
@@ -607,7 +607,7 @@
     public dynamic SubmitKbInspection(dynamic query)
     {
         if (query == null) throw new ArgumentNullException(nameof(query), "鍙傛暟瀵硅薄涓嶈兘涓� null");
-    
+
         // 鍙傛暟鏍¢獙
         if (string.IsNullOrEmpty(query.userAccount?.ToString()))
             throw new ArgumentException("鐢ㄦ埛鍚嶄笉鍏佽涓虹┖", nameof(query.userAccount));
@@ -826,20 +826,66 @@
     }
 
 
-    public dynamic GetWeightByXt(dynamic unity)
+    public dynamic GetWeightByXt(dynamic query)
     {
+        if (query == null) throw new ArgumentNullException(nameof(query), "鍙傛暟瀵硅薄涓嶈兘涓簄ull");
 
-        //// 浣跨敤鍙傛暟鍖栨煡璇㈤槻姝QL娉ㄥ叆
-        var sqlParams = new List<SugarParameter> { new("@LINEID", unity.shdh) };
+        // 鍙傛暟鏍¢獙
+        if (string.IsNullOrEmpty(query.userName?.ToString()))
+            throw new ArgumentException("鐢ㄦ埛鍚嶄笉鍏佽涓虹┖", nameof(query.userName));
 
-        var sql2 = @"SELECT TOP 1 realWeight FROM WORK_WEIGHT WHERE lineId = '' ORDER BY createDate DESC";
+        if (string.IsNullOrEmpty(query.LsBar?.ToString()))
+            throw new ArgumentException("鍗℃澘鏉$爜涓嶅厑璁镐负绌�", nameof(query.LsBar));
 
-        var XcslItem = Db.Ado.SqlQuery<dynamic>(sql2, sqlParams);
+        var _strMsg = "";
+        var _status = -1;
+        var _weight = "0";
+        
+        using (var conn = new SqlConnection(DbHelperSQL.strConn))
+        {
+            using (var cmd = new SqlCommand("prc_pda_Xbar_chenzhong", conn))
+            {
+                try
+                {
+                    conn.Open();
+                    cmd.CommandType = CommandType.StoredProcedure;
 
-        if (XcslItem.Count < 1)
-            throw new Exception($"閫佽揣鍗曞彿銆恵unity.shdh}銆戞潯鐮佹槑缁嗕笉瀛樺湪鎴栨湭鍚屾!");
+                    SqlParameter[] parameters = 
+                    {
+                        new("@pi_user", SqlDbType.NVarChar, 100) { Value = query.userName },
+                        new("@pi_ls_barcode", SqlDbType.NVarChar, 100) { Value = query.LsBar },
+                        new("@po_outMsg", SqlDbType.NVarChar, 2000) { Direction = ParameterDirection.Output },
+                        new("@po_outStatus", SqlDbType.Int) { Direction = ParameterDirection.Output },
+                        new("@po_outWeight", SqlDbType.NVarChar, 100) { Direction = ParameterDirection.Output }
+                    };
 
-        return XcslItem; // 杩斿洖绗竴琛屾暟鎹紝濡傛灉娌℃湁鍒欒繑鍥� null
+                    cmd.Parameters.AddRange(parameters);
+                    cmd.ExecuteNonQuery();
+
+                    _strMsg = parameters[2].Value?.ToString() ?? "";
+                    _status = Convert.ToInt32(parameters[3].Value ?? -1);
+                    _weight = parameters[4].Value?.ToString() ?? "0";
+
+                    if (_status <= 0) throw new Exception(_strMsg);
+
+                    return new 
+                    {
+                        message = _strMsg,
+                        status = _status,
+                        weight = _weight,
+                        barCode = query.Bar
+                    };
+                }
+                catch (Exception ex)
+                {
+                    throw new Exception($"浜у搧绉伴噸澶辫触锛歿ex.Message}");
+                }
+                finally
+                {
+                    conn.Close();
+                }
+            }
+        }
     }
 
 }
\ No newline at end of file

--
Gitblit v1.9.3