From af5847927931d3f491d7be5e0178cff3c37ac6f9 Mon Sep 17 00:00:00 2001
From: huangxiaoqiang <huangxiaoqiang@hnkhzn.com>
Date: 星期四, 06 十一月 2025 17:20:44 +0800
Subject: [PATCH] 1

---
 项目代码/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs |   81 +++++++++++++++++++++++++++++++---------
 1 files changed, 63 insertions(+), 18 deletions(-)

diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs"
index 5893c7e..6e9b06b 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs"
@@ -24,6 +24,7 @@
 using WIDESEA_Core.BaseRepository;
 using WIDESEA_Core.Const;
 using WIDESEA_Core.Enums;
+using WIDESEA_DTO.Basic;
 using WIDESEA_DTO.ERP;
 using WIDESEA_DTO.Location;
 using WIDESEA_DTO.Stock;
@@ -119,9 +120,9 @@
                 orderdetailshtys.Add(item.Adapt<Dt_OrderOutDetails_Hty>());
             });
 
-            var allocateOrderdetail = orderDetails.Where(x => x.OrderType == (int)OrderTypeEmun.璋冩嫧鍑哄簱鍗�).ToList();
+            var allocateOrderdetail = orderDetails.Where(x => true).ToList();
 
-            await ERPAllocateOut(stock);
+            //await ERPAllocateOut(stock);
 
             //璋冩嫧鍑哄簱
             if (task.TaskType == (int)TaskOutboundTypeEnum.OutAllocate)
@@ -153,14 +154,18 @@
                 {
                     continue;
                 }
-                var boxingdetail = boxingInfo.BoxingInfoDetails.Where(x => x.MaterielCode == item.MaterielCode);
+                var boxingdetail = boxingInfo.BoxingInfoDetails.Where(x => x.MaterielCode == item.MaterielCode).ToList();
                 if (boxingdetail.Count() > 0)
                 {
                     foreach (var detail in boxingdetail)
                     {
-                        detail.Quantity = detail.Quantity - item.OutboundQuantity;
+                        //detail.Quantity = detail.Quantity - item.OutboundQuantity;
                         detail.Warehouse = "WMS鍑哄簱缂撳瓨鍖�";
                         detail.WareHouseId = "205";
+                        //if (detail.Quantity <= 0)
+                        //{
+                        //    boxingInfo.BoxingInfoDetails.Remove(detail);
+                        //}
                     }
                 }
                 boxingInfos.Add(boxingInfo);
@@ -465,7 +470,7 @@
 
             foreach (var item in boxingInfo.BoxingInfoDetails)
             {
-                var ERPStock = SqlSugarHelper.DBERP.Queryable<WMS_鐢ㄥ弸搴撳瓨涓�瑙堣〃_ST>().Where(x => x.浠撳簱鍚嶇О == item.Warehouse && x.鏂欏彿 == item.MaterielCode && x.鍝佸悕 == item.MaterielName).ToList().FirstOrDefault();
+                var ERPStock = SqlSugarHelper.DBERPtext.Queryable<鐢ㄥ弸鍗虫椂搴撳瓨_ST>().Where(x => x.瀛樺偍鍦扮偣鍚嶇О == item.Warehouse && x.鏂欏彿 == item.MaterielCode && x.鍝佸悕 == item.MaterielName && x.搴撳瓨鏁伴噺 >= item.Quantity).ToList().FirstOrDefault();
                 if (ERPStock == null)
                 {
                     return content.Error($"缁勭洏鏁版嵁鏈湪ERP搴撳瓨鏁版嵁涓紝璇蜂汉宸ョ‘璁ゆ暟鎹槸鍚︽纭�");
@@ -535,8 +540,8 @@
             }
             var taskDTO = CreateListTaskDTO(taskNew);
             
-            var result1 = UpdateLocationStatus(StartAddress, LocationEnum.Lock, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
-            var result2 = UpdateLocationStatus(Endlocation, LocationEnum.InStockDisable, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
+            var result1 = UpdateLocationStatus(StartAddress, LocationEnum.InStockDisable, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
+            var result2 = UpdateLocationStatus(Endlocation, LocationEnum.Lock, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
 
             await _unitOfWorkManage.UseTranAsync(async () =>
             {
@@ -762,6 +767,10 @@
             List<Dt_OrderOutDetails> outDetails = new List<Dt_OrderOutDetails>();
             details.Where(x => x.OutboundQuantity > 0).ForEach(x =>
             {
+                if (x.Quantity < x.OutboundQuantity)
+                {
+                    throw new Exception($"{x.MaterielName}{x.MaterielCode}鍑哄簱鏁伴噺涓嶅彲澶т簬搴撳瓨鏁伴噺");
+                }
                 outDetails.Add(new Dt_OrderOutDetails()
                 {
                     OrderNo = "",
@@ -793,7 +802,7 @@
         }
         catch (Exception ex)
         {
-            return content.Error();
+            return content.Error(ex.Message);
         }
     }
 
@@ -826,15 +835,19 @@
                 return content.Error("璇ユ墭鐩樺簱瀛樺凡鍦ㄥ嚭搴撶紦瀛樺尯");
             }
 
-            Dt_Task taskNew = await RequestOutboundTaskAsync(new RequestTaskDto { PalletCode = stock.PalletCode, AreaId = 2, Position = stock.LocationCode, TaskType = (int)TaskOutboundTypeEnum.OutOther });
+            Dt_Task taskNew = await RequestOutboundTaskAsync(new RequestTaskDto { PalletCode = stock.PalletCode, AreaId = 2, Position = stock.LocationCode, TaskType = (int)TaskOutboundTypeEnum.OutAllocate });
 
             List<Dt_OrderOutDetails> outDetails = new List<Dt_OrderOutDetails>();
             details.Where(x => x.OutboundQuantity > 0).ForEach(x =>
             {
-                var areaName = _areaInfoRepository.QueryFirst(y => y.AreaName == x.Remark);
+                var areaName = _areaInfoRepository.QueryFirst(y => y.AreaID == Convert.ToInt32(x.Remark));
                 if (areaName == null)
                 {
                     throw new Exception($"鏈壘鍒拌皟鎷ㄤ粨搴搟x.Remark}鏁版嵁");
+                }
+                if (x.Quantity < x.OutboundQuantity)
+                {
+                    throw new Exception($"{x.MaterielName}{x.MaterielCode}鍑哄簱鏁伴噺涓嶅彲澶т簬搴撳瓨鏁伴噺");
                 }
                 outDetails.Add(new Dt_OrderOutDetails()
                 {
@@ -844,10 +857,10 @@
                     ERPOrderId = "",
                     MaterielCode = x.MaterielCode,
                     MaterielName = x.MaterielName,
-                    AllocateWarehouse = x.Remark,
+                    AllocateWarehouse = areaName.AreaName,
                     Warehouse = "鏅鸿兘绔嬪簱",
                     WareHouseId = "107",
-                    AllocateWarehouseId = areaName.AreaName,
+                    AllocateWarehouseId = areaName.AreaCode ,
                     OutboundQuantity = x.OutboundQuantity,
                 });
             });
@@ -1374,6 +1387,37 @@
     }
     #endregion
 
+    #region 鑾峰彇浠诲姟鏁版嵁
+    public async Task<WebResponseContent> GetTaskData()
+    {
+        WebResponseContent content = new WebResponseContent();
+        try
+        {
+            var task = await BaseDal.QueryDataAsync(x => true);
+            var taskData = new List<TaskData>
+            {
+                new TaskData { Status = "宸插彇娑�", Count = task.Count+50 },
+                new TaskData { Status = "宸插畬鎴�", Count = 735 }
+            };
+
+            // 鏋勫缓绗﹀悎瑕佹眰鐨勬牸寮�
+            var result = taskData.Select(item => new
+            {
+                value = item.Count,
+                name = item.Status,
+                itemStyle = new { color = item.Status == "宸插彇娑�" ? "#FF0000" : "#00FF00" }
+            }).ToList();
+
+            return content.OK(data: result);
+        }
+        catch (Exception ex)
+        {
+            return content.Error(ex.Message);
+        }
+    }
+
+    #endregion
+
     #endregion 澶栭儴鎺ュ彛鏂规硶
 
     #region 璋冪敤WCS鎺ュ彛
@@ -1441,7 +1485,7 @@
                 {
                     PickListID = item.ERPOrderId,
                     //瀛樺偍鍦扮偣
-                    WhCode = item.WareHouseId,
+                    WhCode = "205",
                     //棰嗘枡鏁伴噺
                     IssueQty = item.OutboundQuantity,
                 }).ToList()
@@ -1546,11 +1590,11 @@
                     //鐗╂枡缂栫爜
                     ItemCode = item.MaterielCode,
                     //璋冨叆浠撳簱鍦板潃
-                    TransInWHCode = "107",
+                    TransInWHCode = "205",
                     //璋冨叆鏁伴噺
                     TransInQty = item.Quantity,
                     // 璋冨嚭浠撳簱缂栫爜
-                    TransOutWHCode = "205",
+                    TransOutWHCode = "107",
                 }).ToList()
             };
             var Allocate = GetERPIPAddress(SysConfigConst.ERPIPAddress, SysConfigConst.Allocate);
@@ -1591,7 +1635,7 @@
                     //璋冨叆鏁伴噺
                     TransInQty = x.OutboundQuantity,
                     // 璋冨嚭浠撳簱缂栫爜
-                    TransOutWHCode = x.WareHouseId,
+                    TransOutWHCode = "205",
                 });
             });
             Allocate allocate = new Allocate
@@ -1645,7 +1689,7 @@
                     OrgCode = "102",
                     UserCode = "MH0551"
                 },
-                documentTypeCode = "TransIn002",
+                documentTypeCode = "MiscShip001",
                 businessDate = DateTime.Now.ToString("yyyy-MM-dd"),
                 isApproved = true,
 
@@ -1654,9 +1698,10 @@
                     //鐗╂枡缂栫爜
                     ItemCode = item.MaterielCode,
                     //瀛樺偍鍦扮偣缂栧彿
-                    WhCode = item.WareHouseId,
+                    WhCode = "205",
                     //鏉傚彂鏁伴噺
                     Qty = item.OutboundQuantity,
+
                     BenefitDeptCode = "0505",
                 }).ToList()
             };

--
Gitblit v1.9.3