From ac2f359d397c0ec5eb87c9cbc415584d1d88439f Mon Sep 17 00:00:00 2001
From: 快乐的昕的电脑 <快乐的昕的电脑@DESKTOP-C2BQPQU>
Date: 星期二, 16 九月 2025 08:56:53 +0800
Subject: [PATCH] 采购退料:列表选择、列表明细更改为存储过程,添加组织隔离,添加库位列表,添加隐藏完结单号功能

---
 service/Wom/WwGdManager.cs |  189 +++++++++++++++++++++++++++--------------------
 1 files changed, 108 insertions(+), 81 deletions(-)

diff --git a/service/Wom/WwGdManager.cs b/service/Wom/WwGdManager.cs
index 83ad617..0abca21 100644
--- a/service/Wom/WwGdManager.cs
+++ b/service/Wom/WwGdManager.cs
@@ -1,11 +1,13 @@
-锘縰sing System.Data;
-using System.Data.SqlClient;
-using Masuit.Tools;
+锘縰sing Masuit.Tools;
 using NewPdaSqlServer.DB;
 using NewPdaSqlServer.Dto.service;
 using NewPdaSqlServer.entity;
+using NewPdaSqlServer.entity.Base;
 using NewPdaSqlServer.util;
 using SqlSugar;
+using System.Data;
+using System.Data.SqlClient;
+using System.Threading.Tasks.Dataflow;
 
 namespace NewPdaSqlServer.service.Wom;
 
@@ -137,86 +139,110 @@
         }
     }
 
-    public ProductionPickDto GetItemsByDaa001(WarehouseQuery query)
+
+    /// <summary>
+    /// 鑾峰彇搴撲綅淇℃伅
+    /// </summary>
+    /// <param name="unity"></param>
+    /// <returns></returns>
+    /// <exception cref="Exception"></exception>
+    public dynamic GetBarKwByItem(dynamic unity)
     {
-        return getDaa001(query);
+        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)
+            };
+
+            return Db.Ado.SqlQuery<dynamic>("EXEC prc_pda_scll_selBarMx @itemId", parameters);
+        }
+        catch (Exception ex)
+        {
+            throw new Exception($"鑾峰彇鏉$爜淇℃伅澶辫触锛歿ex.Message}");
+        }
+
     }
 
-    private ProductionPickDto getDaa001(WarehouseQuery query)
+    /// <summary>
+    /// 閫夊彇鍒楄〃
+    /// </summary>
+    /// <param name="unity"></param>
+    /// <param name="RequestInfo"></param>
+    /// <returns></returns>
+    public dynamic GetXcslDaa(dynamic unity, dynamic RequestInfo)
     {
-        if (string.IsNullOrEmpty(query.daa001)) throw new Exception("宸ュ崟鍙蜂负绌�");
-
-        var wwgd = Db.Queryable<WwGd, MesItems>((a, i) =>
-                new JoinQueryInfos(JoinType.Left,
-                    a.Daa003 == i.ItemId))
-            .Where((a, i) => a.Daa001 == query.daa001 && (a.PcSh ?? 0) == 1)
-            .Select((a, i) => new
-            {
-                a.Daa001, a.RwdGuid
-            }).First();
-
-        if (wwgd?.Daa001 == null) throw new Exception("宸ュ崟鍙蜂笉瀛樺湪");
-
-        var womdabs = Db
-            .Queryable<WwGd, WwGdDetail, MesItems, ProductionOrderSub>(
-                (a, b, c, d) =>
-                    new JoinQueryInfos(
-                        JoinType.Left,
-                        a.Id == b.Pid,
-                        JoinType.Inner,
-                        c.Id == b.Dab003,
-                        JoinType.Inner, b.Erpid.ToString() == d.ErpId
-                    ))
-            .Where((a, b, c, d) =>
-                a.Daa001 == query.daa001 && d.IssuingMethod == "1")
-            .Select((a, b, c, d) => new WwGdDetail
-            {
-                Pid = b.Pid,
-                Dab003 = b.Dab003,
-                Dab006 = b.Dab006,
-                Dab007 = b.Dab007,
-                wNum = b.Dab006 - b.Dab007, // 璁$畻瀛楁 W_NUM
-                ItemName = c.ItemName, // 鍔ㄦ�佸瓧娈� ITEM_NAME
-                ItemNo = c.ItemNo // 鍔ㄦ�佸瓧娈� ITEM_NO
-            })
-            .ToList();
-
-        var list = womdabs.Where(s => s.wNum > 0).ToList();
-
-        var mesInvItemOutCDetailsList = Db
-            .Queryable<MesInvItemOutCDetails, MesItems, MesDepots>
-            ((a, b, c) =>
-                new JoinQueryInfos(
-                    JoinType.Inner, a.ItemId == b.Id,
-                    JoinType.Inner, c.DepotId == a.DepotId
-                ))
-            .Where((a, b, c) => a.WorkNo == query.daa001)
-            .Select((a, b, c) => new MesInvItemOutCDetails
-            {
-                ItemName = b.ItemName,
-                ItemNo = b.ItemNo,
-                ItemId = a.ItemId,
-                DepotId = a.DepotId,
-                WorkNo = a.WorkNo,
-                DepotName = c.DepotName,
-                Quantity = a.Quantity
-            })
-            .ToList();
-
-        var womcaa = Db.Queryable<ProductionOrder>()
-            .Where(s => s.Guid == wwgd.RwdGuid)
-            .First();
-
-        var dto = new ProductionPickDto
+        var orgId = RequestInfo.OrgId;
+        var parameters = new List<SugarParameter>
         {
-            daa001 = wwgd.Daa001,
-            PlanNo = womcaa.ErpProductionOrderNo,
-            totals1 = womdabs,
-            daisao1 = list,
-            yisao = mesInvItemOutCDetailsList
+            new SugarParameter("@selectKey", unity.selectKey),
+            new SugarParameter("@inP1", orgId), // 鍙�夊弬鏁�
+            new SugarParameter("@inP2", unity.selDaaType), // 鍙�夊弬鏁�
+            new SugarParameter("@inP3", null), // 鍙�夊弬鏁�
+            new SugarParameter("@inP4", null), // 鍙�夊弬鏁�
+            // ...鍏朵粬鍙�夊弬鏁�
         };
+        var result = Db.Ado.SqlQuery<dynamic>("EXEC prc_pda_wwll_list @selectKey, @inP1, @inP2, @inP3, @inP4", parameters);
+        return result;
+    }
 
-        return dto;
+    /// <summary>
+    /// 鍒楄〃鏄庣粏
+    /// </summary>
+    /// <param name="query"></param>
+    /// <param name="RequestInfo"></param>
+    /// <returns></returns>
+    public dynamic GetItemsByDaa001(WarehouseQuery query, dynamic RequestInfo)
+    {
+        return getDaa001(query, RequestInfo);
+    }
+
+    private dynamic getDaa001(WarehouseQuery query, dynamic RequestInfo)
+    {
+        if (string.IsNullOrEmpty(query.daa001)) throw new Exception("璇烽�夊伐鍗曞彿锛�");
+        if (query == null)
+            throw new ArgumentNullException(nameof(query), "鍙傛暟瀵硅薄涓嶈兘涓簄ull");
+        if (string.IsNullOrEmpty(query.daa001?.ToString()))
+            throw new ArgumentException("宸ュ崟鍙蜂笉瀛樺湪", nameof(query.daa001));
+
+        var orgId = RequestInfo.OrgId;
+        if (orgId == null)
+            throw new Exception("缁勭粐涓嶅瓨鍦紒");
+
+        var parameters = new[]
+        {
+            new SugarParameter("@daa001", query.daa001),
+            new SugarParameter("@pi_orgId", orgId),
+            new SugarParameter("@inP1", null),
+            new SugarParameter("@inP2", null),
+            new SugarParameter("@inP3", null),
+            new SugarParameter("@inP4", null)
+        };
+        try
+        {
+            List<dynamic>? blDetails = Db.Ado.SqlQuery<dynamic>(
+                "EXEC prc_pda_wwll_detailList @daa001,@pi_orgId,@inP1,@inP2,@inP3,@inP4", parameters);
+            var items = blDetails.Where(x => x.DSQty > 0).ToList();    // 寰呮壂鐗╂枡
+            var ysitems = blDetails.Where(x => x.SQty > 0).ToList();   // 宸叉壂鐗╂枡
+            var planNo = blDetails.FirstOrDefault()?.ErpProductionOrderNo?.ToString();// 鑾峰彇宸ュ崟璁″垝鍙�
+            return new 
+            {
+                daa001 = query.daa001,
+                PlanNo = planNo,
+                items = items,
+                ysitems = ysitems
+            };
+        }
+        catch (Exception ex)
+        {
+            throw new Exception($"{ex.Message}");
+        }
     }
 
     #region 濮斿閫�鏂�
@@ -773,7 +799,7 @@
         // 鑾峰彇琛ユ枡鍗曟槑缁嗗苟鏍¢獙
         var blDetail = Db.Queryable<MesItemBlDetail>()
             .Where(b =>
-                b.Mid == mesItemBl.Id && b.Bld012 == stockBarcode.ItemId)
+                b.Mid == mesItemBl.Id && b.Bld012 == stockBarcode.ItemId && b.Bld007 > b.Bld008)
             .First();
 
         if (blDetail == null)
@@ -938,8 +964,9 @@
                     ErpAutoid = womdab.Erpid,
                     PbillNo = query.billNo,
                     ItemId = blDetail.Bld012,
-                    DepotId = stockBarcode.DepotsId.ToString(),
-                    ItemDabid = womdab.Id,
+                    DepotId = stockBarcode.DepotId.ToString(),
+                    ItemDabid = blDetail.Id,
+                    //AboutGuid = womdab.Id
                     // Unit = blDetail.Bld009,
                     // DepotId = (int)stockBarcode.DepotsId
                 }).IgnoreColumns(true).ExecuteCommand();
@@ -972,7 +999,7 @@
                 PbillNo = query.billNo,
                 ItemId = blDetail.Bld012,
                 Unit = blDetail.Bld009,
-                DepotId = (int)stockBarcode.DepotsId,
+                DepotId = (int)stockBarcode.DepotId,
                 EbelnK3id = womdab.Eid,
                 LineK3id = womdab.Erpid
             }).IgnoreColumns(true).ExecuteCommand();
@@ -1069,7 +1096,7 @@
 
             // 鍒涘缓 鎻掑叆鏃ュ織
             var logService = new LogService();
-            var LogMsg = "[PDA]"+query.Type + "銆傛潯鐮併��" +query.barcode+"銆� 鍑哄簱鍗曞彿銆�"+ outNo +"銆�";
+            var LogMsg = "[PDA]"+query.Type + "銆傛潯鐮併��" +query.barcode+"銆� 鏁伴噺銆�"+ stockBarcode.Quantity.ToString() + "銆� 鍑哄簱鍗曞彿銆�"+ outNo +"銆�";
             logService.CreateLog(db,query.userName,wwgd.Id.ToString(), "WW_GD", LogMsg,wwgd.Daa001);
 
             return 1;

--
Gitblit v1.9.3