From 6c663b92b0078aa89657df22ec188dff65599f04 Mon Sep 17 00:00:00 2001
From: huangxiaoqiang <huangxiaoqiang@hnkhzn.com>
Date: 星期二, 21 十月 2025 17:24:38 +0800
Subject: [PATCH] 1

---
 项目代码/WMS/WIDESEA_WMSServer/WIDESEA_StorageBasicServices/Boxing/BoxingInfoService.cs |  193 ++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 169 insertions(+), 24 deletions(-)

diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageBasicServices/Boxing/BoxingInfoService.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageBasicServices/Boxing/BoxingInfoService.cs"
index 79d8610..87df8eb 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageBasicServices/Boxing/BoxingInfoService.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageBasicServices/Boxing/BoxingInfoService.cs"
@@ -1,37 +1,182 @@
-锘縰sing Masuit.Tools;
+锘縰sing Mapster;
+using Masuit.Tools;
+using SqlSugar;
 using System.ComponentModel.DataAnnotations;
+using System.Linq.Expressions;
+using WIDESEA_Core.BaseRepository;
+using WIDESEA_DTO.Basic;
+using WIDESEA_IOrderRepository;
 
 namespace WIDESEA_StorageBasicService;
 
 public class BoxingInfoService : ServiceBase<DtBoxingInfo, IBoxingInfoRepository>, IBoxingInfoService
 {
-    public BoxingInfoService(IBoxingInfoRepository BaseDal) : base(BaseDal)
+    private readonly IDt_InboundOrderRepository _inboundOrderRepository;
+    private readonly IUnitOfWorkManage _unitOfWorkManage;
+    public BoxingInfoService(IBoxingInfoRepository BaseDal, IDt_InboundOrderRepository inboundOrderRepository, IUnitOfWorkManage unitOfWorkManage) : base(BaseDal)
     {
+        _inboundOrderRepository = inboundOrderRepository;
+        _unitOfWorkManage = unitOfWorkManage;
     }
-
-    public async Task<WebResponseContent> AddBoxingInfoAsync(DtBoxingInfo boxingInfo)
-    {
-        WebResponseContent content = new WebResponseContent();
-        var info = await BaseDal.QueryFirstAsync(x => x.PalletCode == boxingInfo.PalletCode);
-        if (!info.IsNullOrEmpty())
-        {
-            content.Error("璇ユ墭鐩樺凡瀛樺湪缁勭洏");
-        }
-        else
-        {
-            // 娣诲姞缁勭洏淇℃伅
-            var result = await BaseDal.AddDataNavAsync(boxingInfo);
-            if (result)
-            {
-                content.OK("娣诲姞鎴愬姛", boxingInfo);
-            }
-        }
-        return content;
-    }
-
     public override PageGridData<DtBoxingInfo> GetPageData(PageDataOptions options)
     {
-        return base.GetPageData(options);
+        string wheres = ValidatePageOptions(options);
+        //鑾峰彇鎺掑簭瀛楁
+        Dictionary<string, OrderByType> orderbyDic = GetPageDataSort(options, TProperties);
+        List<OrderByModel> orderByModels = new List<OrderByModel>();
+        foreach (var item in orderbyDic)
+        {
+            OrderByModel orderByModel = new()
+            {
+                FieldName = item.Key,
+                OrderByType = item.Value
+            };
+            orderByModels.Add(orderByModel);
+        }
+
+
+        int totalCount = 0;
+        List<SearchParameters> searchParametersList = new List<SearchParameters>();
+        if (!string.IsNullOrEmpty(options.Wheres))
+        {
+            try
+            {
+                searchParametersList = options.Wheres.DeserializeObject<List<SearchParameters>>();
+                options.Filter = searchParametersList;
+            }
+            catch { }
+        }
+        var data = BaseDal.Db.Queryable<DtBoxingInfo>()
+            .Includes(x => x.BoxingInfoDetails)
+            .WhereIF(!wheres.IsNullOrEmpty(), wheres)
+            .OrderBy(orderByModels)
+            .ToPageList(options.Page, options.Rows, ref totalCount);
+        new PageGridData<DtBoxingInfo>(totalCount, data);
+        return new PageGridData<DtBoxingInfo>(totalCount, data);
+    }
+
+    public async Task<WebResponseContent> AddBoxingInfoAsync(AddBoxingDto boxingInfo)
+    {
+        WebResponseContent content = new WebResponseContent();
+        try
+        {
+            if(boxingInfo == null || boxingInfo.OrderNos.IsNullOrEmpty() || boxingInfo.palletCode.IsNullOrEmpty())
+            {
+                return content.Error("鍙傛暟閿欒");
+            }
+            var info = await BaseDal.QueryFirstAsync(x => x.PalletCode == boxingInfo.palletCode);
+            if (!info.IsNullOrEmpty())
+            {
+                content.Error("璇ユ墭鐩樺凡瀛樺湪缁勭洏");
+            }
+            else
+            {
+                List<DtBoxingInfoDetail> details = new List<DtBoxingInfoDetail>();
+                foreach (var item in boxingInfo.OrderNos)
+                {
+                    var InboundOrder = _inboundOrderRepository.QueryFirst(x => x.PrintCode == item);
+
+                    if(InboundOrder != null)
+                    {
+                        var x = details.Where(x => x.MaterielCode == InboundOrder.MaterialNo && x.Warehouse == InboundOrder.WarehouseName && x.DrawingNumber==InboundOrder.ProductDrawingNumber &&x.DemandClassification ==InboundOrder.DemandClassification).FirstOrDefault();
+                        if (x != null)
+                        {
+                            details.Remove(x);
+                            x.MaterielCode = InboundOrder.MaterialNo;
+                            x.MaterielName = InboundOrder.MaterialName;
+                            x.DemandClassification = InboundOrder.DemandClassification;
+                            x.Warehouse = InboundOrder.WarehouseName;
+                            x.OrderNo = InboundOrder.OrderNo;
+                            x.Unit = InboundOrder.Unit;
+                            x.Specs = InboundOrder.Specs;
+                            x.Weight = InboundOrder.Weight;
+                            x.Quantity = x.Quantity + InboundOrder.Quantity;
+                            x.DrawingNumber = InboundOrder.ProductDrawingNumber;
+                            x.Date = InboundOrder.Datetime;
+                            details.Add(x);
+                        }
+                        else
+                        {
+                            DtBoxingInfoDetail detail = new DtBoxingInfoDetail()
+                            {
+                                MaterielCode = InboundOrder.MaterialNo,
+                                MaterielName = InboundOrder.MaterialName,
+                                DemandClassification = InboundOrder.DemandClassification,
+                                Warehouse = InboundOrder.WarehouseName,
+                                OrderNo = InboundOrder.OrderNo,
+                                Unit = InboundOrder.Unit,
+                                Specs = InboundOrder.Specs,
+                                Weight = InboundOrder.Weight,
+                                Quantity = InboundOrder.Quantity,
+                                DrawingNumber = InboundOrder.ProductDrawingNumber,
+                                Date = InboundOrder.Datetime,
+                            };
+                            details.Add(detail);
+                        }
+                    }
+                    else
+                    {
+                        return content.Error("鏈壘鍒板叆搴撳崟鎹俊鎭�");
+                    }
+                }
+
+                DtBoxingInfo boxing = new DtBoxingInfo()
+                {
+                    PalletCode=boxingInfo.palletCode,
+                    BoxingInfoDetails= details
+                };
+                await BaseDal.AddDataNavAsync(boxing);
+                content.OK("缁勭洏鎴愬姛");
+            }
+            return content;
+        }
+        catch (Exception ex)
+        {
+            return content.Error(ex.Message);
+        }
+    }
+
+    public async Task<WebResponseContent> DeleteBoxingInfoAsync(AddBoxingDto boxingInfo)
+    {
+        WebResponseContent content = new WebResponseContent();
+        try
+        {
+            if (boxingInfo == null || boxingInfo.palletCode.IsNullOrEmpty())
+            {
+                return content.Error("鍙傛暟閿欒");
+            }
+            var boxing = await BaseDal.QueryFirstNavAsync(x => x.PalletCode == boxingInfo.palletCode);
+            if (!boxing.IsNullOrEmpty())
+            {
+                DtBoxingInfo_Hty boxingInfo_Hty = boxing.Adapt<DtBoxingInfo_Hty>();
+                boxingInfo_Hty.ModifyDate = DateTime.Now;
+                await _unitOfWorkManage.UseTranAsync(async () =>
+                {
+                    await BaseDal.Db.DeleteNav<DtBoxingInfo>(x => x.Id == boxing.Id)
+                                            .Include(x => x.BoxingInfoDetails)
+                                            .ExecuteCommandAsync();
+                    await AddBoxingHtyAsync(boxingInfo_Hty);
+                });
+                content.OK("瑙g洏鎴愬姛");
+            }
+            else
+            {
+                content.Error("鏈壘鍒扮粍鐩樻暟鎹�");
+            }
+            return content;
+        }
+        catch (Exception ex)
+        {
+            return content.Error(ex.Message);
+        }
+    }
+    private async Task AddBoxingHtyAsync(DtBoxingInfo_Hty boxingInfo)
+    {
+        var isStockAdd = await SqlSugarHelper.DbWMS.InsertNav(boxingInfo).IncludesAllFirstLayer().ExecuteCommandAsync();
+        if (!isStockAdd)
+        {
+            throw new Exception("缁勭洏鍘嗗彶淇℃伅娣诲姞澶辫触");
+        }
     }
 
     // 楠岃瘉妯″瀷

--
Gitblit v1.9.3