From d016d7ff02586fb9535baef4916cd339e18c7867 Mon Sep 17 00:00:00 2001
From: cdk <2441919651@qq.com>
Date: 星期一, 22 十二月 2025 09:48:52 +0800
Subject: [PATCH] 增加新称重后端

---
 service/Wom/WomdaaManager.cs |  147 ++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 126 insertions(+), 21 deletions(-)

diff --git a/service/Wom/WomdaaManager.cs b/service/Wom/WomdaaManager.cs
index 547ff5b..0f94f5d 100644
--- a/service/Wom/WomdaaManager.cs
+++ b/service/Wom/WomdaaManager.cs
@@ -50,12 +50,12 @@
         {
             new SugarParameter("@daa001", query.daa001),
             new SugarParameter("@pi_orgId",orgId),
-            new SugarParameter("@inP1", null),
+            new SugarParameter("@inP1", query.userName),
             new SugarParameter("@inP2", null),
             new SugarParameter("@inP3", null),
             new SugarParameter("@inP4", null)
         };
-        var womdabs = Db.Ado.SqlQuery<ItemDetailModel>("EXEC prc_pda_scll_detailList @daa001", parameters);
+        var womdabs = Db.Ado.SqlQuery<dynamic>("EXEC prc_pda_scll_detailList @daa001,@pi_orgId,@inP1", parameters);
 
         var DS_list = womdabs.Where(s => s.DSQty > 0).ToList();
         var YS_list = womdabs.Where(s => s.SQty > 0).ToList();
@@ -69,7 +69,7 @@
             throw new Exception("璇ュ伐鍗曚俊鎭笉瀛樺湪锛岃鏍稿锛�");
         }
 
-        var dto = new ProductionPickDto
+        var dto = new 
         {
             daa001 = query.daa001,
             daaInfo = womdaa,
@@ -397,6 +397,37 @@
 
     }
 
+    /// <summary>
+    /// 鑾峰彇鐗╂枡鐩稿叧鏉$爜淇℃伅
+    /// </summary>
+    /// <param name="unity"></param>
+    /// <returns></returns>
+    /// <exception cref="Exception"></exception>
+    public dynamic GetBarKwByItemCK(dynamic unity)
+    {
+        if (unity == null)
+            throw new ArgumentNullException(nameof(unity), "鍙傛暟瀵硅薄涓嶈兘涓簄ull");
+
+        if (string.IsNullOrEmpty(unity.itemId?.ToString()))
+            throw new ArgumentException("鐗╂枡ID涓嶈兘涓虹┖", nameof(unity.itemId));
+
+        try
+        {
+            var parameters = new List<SugarParameter>
+            {
+                new SugarParameter("@itemId", unity.itemId),
+                new SugarParameter("@inP1", unity.type),
+                new SugarParameter("@inP2", unity.billNo)
+            };
+
+            return Db.Ado.SqlQuery<dynamic>("EXEC prc_pda_scll_selBarMx @itemId,@inP1,@inP2", parameters);
+        }
+        catch (Exception ex)
+        {
+            throw new Exception($"鑾峰彇鏉$爜淇℃伅澶辫触锛歿ex.Message}");
+        }
+
+    }
 
     public dynamic ProductBinding(dynamic query)
     {
@@ -469,27 +500,37 @@
     /// </summary>
     /// <param name="query"></param>
     /// <returns></returns>
-    public dynamic getKbBarInfo(dynamic query)
+public dynamic getKbBarInfo(dynamic query)
+{    
+    if (string.IsNullOrEmpty(query.Kbbarcode?.ToString()))
+        throw new ArgumentException("鍗℃澘鏉$爜涓嶅厑璁镐负绌�", nameof(query.Kbbarcode));
+
+    var parameters = new[]
     {
-        if (string.IsNullOrEmpty(query.Kbbarcode?.ToString()))
-            throw new ArgumentException("鍗℃澘鏉$爜涓嶅厑璁镐负绌�", nameof(query.userName));
-
-        var sql = string.Format(@"SELECT QUANTITY,agvPostion,
-       ISNULL((SELECT COUNT(1) FROM MES_INV_ITEM_BARCODES_TBMX WHERE ABOUT_TB_BARCODE = '{0}'), 0) AS YSum,
-       DAA001
-FROM MES_INV_ITEM_BARCODES A LEFT JOIN WOMDAA B ON A.ABOUT_GUID = B.guid
-left join MES_WORKSHOP_LINE C ON DAA015 = C.id AND iSAgV = 1
-WHERE ITEM_BARCODE = '{0}' ",  query.Kbbarcode);
-
-        var ZsBarInfo = Db.Ado.SqlQuery<dynamic>(sql);
-
+        new SugarParameter("@pi_kbbarcode", query.Kbbarcode),
+        new SugarParameter("@inP1", null),
+        new SugarParameter("@inP2", null),
+        new SugarParameter("@inP3", null),
+        new SugarParameter("@inP4", null)
+    };
+    
+    try
+    {
+        var ZsBarInfo = Db.Ado.SqlQuery<dynamic>(
+            "EXEC prc_pda_getKbBarInfo @pi_kbbarcode,@inP1,@inP2,@inP3,@inP4", parameters);
+        
         if (ZsBarInfo.Count < 1)
         {
-            throw new Exception($"璇ュ崱鏉跨爜{query.Zsbarcode}涓嶅瓨鍦紒");
+            throw new Exception($"璇ュ崱鏉跨爜{query.Kbbarcode}涓嶅瓨鍦紒");
         }
-
+        
         return ZsBarInfo;
     }
+    catch (Exception ex)
+    {
+        throw new Exception($"{ex.Message}");
+    }
+}
 
     /// <summary>
     /// 鑾峰彇鍗℃澘鏄庣粏淇℃伅
@@ -961,6 +1002,69 @@
         }
     }
 
+    //鏂扮О閲嶉〉闈紝鏆傛椂涓嶇敤
+    public dynamic GetWeightByXt_new(dynamic query)
+    {
+        if (query == null) throw new ArgumentNullException(nameof(query), "鍙傛暟瀵硅薄涓嶈兘涓簄ull");
+
+        // 鍙傛暟鏍¢獙
+        if (string.IsNullOrEmpty(query.userName?.ToString()))
+            throw new ArgumentException("鐢ㄦ埛鍚嶄笉鍏佽涓虹┖", nameof(query.userName));
+
+        if (string.IsNullOrEmpty(query.LsBar?.ToString()))
+            throw new ArgumentException("鍗℃澘鏉$爜涓嶅厑璁镐负绌�", nameof(query.LsBar));
+
+        var _strMsg = "";
+        var _status = -1;
+        var _weight = "0";
+
+        using (var conn = new SqlConnection(DbHelperSQL.strConn))
+        {
+            using (var cmd = new SqlCommand("prc_pda_Xbar_chenzhong_new", conn))
+            {
+                try
+                {
+                    conn.Open();
+                    cmd.CommandType = CommandType.StoredProcedure;
+
+                    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 }
+                    };
+
+                    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();
+                }
+            }
+        }
+    }
+
     public dynamic GetXcslDaa(dynamic unity,dynamic RequestInfo)
     {
 
@@ -1382,7 +1486,7 @@
         var sqlParams = new List<SugarParameter> { };
 
         var sql2 = new StringBuilder(@"
-SELECT NAME,line_no FROM MES_WORKSHOP_LINE WHERE isAgv = 1 ORDER BY line_no");
+SELECT NAME,line_no,agvPostion FROM MES_WORKSHOP_LINE WHERE isAgv = 1 ORDER BY line_no");
 
 
         var XtItem = Db.Ado.SqlQuery<dynamic>(sql2.ToString(), sqlParams);
@@ -1433,8 +1537,8 @@
 
                 var result = new
                 {
-                    message = parameters[2].Value?.ToString(),
-                    status = Convert.ToInt32(parameters[3].Value)
+                    message = parameters[3].Value?.ToString(),
+                    status = Convert.ToInt32(parameters[4].Value)
                 };
 
                 if (result.status <= 0)
@@ -1464,6 +1568,7 @@
                 {
                     new("@pi_user", SqlDbType.NVarChar, 100) { Value = query.userAccount },
                     new("@pi_xtNum", SqlDbType.NVarChar, 100) { Value = query.XtNum },
+                    new("@in1", SqlDbType.NVarChar, 100) { Value = query.AgvDw },
                     new("@outMsg", SqlDbType.NVarChar, 2500) { Direction = ParameterDirection.Output },
                     new("@outSum", SqlDbType.Int) { Direction = ParameterDirection.Output }
                 };

--
Gitblit v1.9.3