From c6e8b600398de38b6684f5fa1eaaaade8562859b Mon Sep 17 00:00:00 2001
From: wangxinhui <wangxinhui@hnkhzn.com>
Date: 星期六, 20 九月 2025 15:16:56 +0800
Subject: [PATCH] Merge branch 'master' of http://115.159.85.185:8098/r/ZhiHuiQiCe/LongDeLiLiKu

---
 项目代码/WMS/WMSServices/WIDESEA_TaskInfoService/TaskService_Inbound.cs |  290 ++++++++++++++++++++++++++++++++++++++++------------------
 1 files changed, 200 insertions(+), 90 deletions(-)

diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WMSServices/WIDESEA_TaskInfoService/TaskService_Inbound.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WMSServices/WIDESEA_TaskInfoService/TaskService_Inbound.cs"
index 5692ab7..5490b32 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WMSServices/WIDESEA_TaskInfoService/TaskService_Inbound.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WMSServices/WIDESEA_TaskInfoService/TaskService_Inbound.cs"
@@ -20,6 +20,7 @@
 using WIDESEA_DTO;
 using WIDESEA_DTO.Basic;
 using WIDESEA_DTO.Task;
+using WIDESEA_External.Model;
 using WIDESEA_Model.Models;
 
 namespace WIDESEA_TaskInfoService
@@ -131,15 +132,17 @@
                 {
                     return content.Error($"鏈壘鍒扮粍鐩樹俊鎭�");
                 }
-                if (stockInfo.StockStatus != StockStatusEmun.鎵嬪姩缁勭洏鏆傚瓨.ObjToInt())
+                if (stockInfo.StockStatus != StockStatusEmun.鎵嬪姩缁勭洏鏆傚瓨.ObjToInt() && stockInfo.StockStatus != StockStatusEmun.缁勭洏鏆傚瓨.ObjToInt() && stockInfo.StockStatus != StockStatusEmun.鑰佸巶閫�搴�.ObjToInt())
                 {
                     return content.Error($"璇ユ墭鐩樼姸鎬佷笉姝g‘,涓嶅彲鐢宠鍏ュ簱");
                 }
+                //鍒嗛厤宸烽亾
                 string rowWay = AssignYLRoadwayNo(stockInfo.PalletCode);
                 if (string.IsNullOrEmpty(rowWay))
                 {
                     return content.Error($"鏈壘鍒板彲鍒嗛厤宸烽亾");
                 }
+                //鐢熸垚浠诲姟
                 Dt_Task newTask = new Dt_Task()
                 {
                     CurrentAddress = stationCode,
@@ -149,16 +152,22 @@
                     Roadway = rowWay,
                     SourceAddress = stationCode,
                     TargetAddress = "",
-                    TaskType = TaskTypeEnum.Inbound.ObjToInt(),
+                    TaskType = stationCode=="307" ? TaskTypeEnum.PaperOldYLBackInbound.ObjToInt() : TaskTypeEnum.Inbound.ObjToInt(),
                     TaskStatus = TaskStatusEnum.New.ObjToInt(),
                     WarehouseId = stockInfo.WarehouseId,
                     PalletType = stockInfo.PalletType,
+                    TaskLength = (int)stockInfo.MaterielWide
                 };
-
+                //鏇存柊鐘舵��
                 if (stockInfo.StockStatus == StockStatusEmun.鎵嬪姩缁勭洏鏆傚瓨.ObjToInt())
                 {
                     stockInfo.StockStatus = StockStatusEmun.鎵嬪姩缁勭洏鍏ュ簱纭.ObjToInt();
                 }
+                else
+                {
+                    stockInfo.StockStatus = StockStatusEmun.鍏ュ簱纭.ObjToInt();
+                }
+                //鏁版嵁鏇存柊
                 _unitOfWorkManage.BeginTran();
                 int taskId = BaseDal.AddData(newTask);
                 newTask.TaskId = taskId;
@@ -174,6 +183,91 @@
                 content.Error(ex.Message);
             }
             return content;
+        }
+        /// <summary>
+        /// 鍘熸枡璇锋眰缁勭洏
+        /// </summary>
+        /// <returns></returns>
+        public WebResponseContent YLPurchaseBoxing(string palletCode)
+        {
+            WebResponseContent content = new WebResponseContent();
+            try
+            {
+                Dt_StockInfo stockInfoOld = _stockRepository.StockInfoRepository.QueryFirst(x => x.PalletCode == palletCode);
+                if (stockInfoOld != null && stockInfoOld.MaterielInvOrgId==MaterielInvOrgEnum.鏂板巶.ObjToInt())
+                {
+                    return content.OK($"鏂板巶涓存椂鍏ュ簱{stockInfoOld.PalletCode}");
+                }
+                else if (stockInfoOld != null && stockInfoOld.MaterielInvOrgId==MaterielInvOrgEnum.鑰佸巶.ObjToInt() && stockInfoOld.StockStatus == StockStatusEmun.鑰佸巶閫�搴�.ObjToInt())
+                {
+                    return content.OK($"鑰佸巶涓存椂閫�搴搟stockInfoOld.PalletCode}");
+                }
+                else if (stockInfoOld != null)
+                {
+                    return content.Error($"鏉$爜{stockInfoOld.PalletCode}淇℃伅宸插瓨鍦�");
+                }
+                
+                //鑾峰彇閲囪喘淇℃伅
+                Dt_PurchaseBSTOrderDetail purchaseBSTOrderDetail = _purchaseBSTOrderDetailRepository.QueryFirst(x=>x.Barcode== palletCode);
+                if (purchaseBSTOrderDetail == null)
+                {
+                    return content.Error($"鏈壘鍒版潯鐮亄palletCode}閲囪喘淇℃伅");
+                }
+                if (purchaseBSTOrderDetail.PurchaseBSTOrderDetailStatus!=InOrderStatusEnum.鏈紑濮�.ObjToInt())
+                {
+                    return content.Error($"閲囪喘{purchaseBSTOrderDetail.Barcode}淇℃伅宸插叆搴撴垨鍏ュ簱涓�");
+                }
+                else
+                {
+                    purchaseBSTOrderDetail.PurchaseBSTOrderDetailStatus = InOrderStatusEnum.鍏ュ簱涓�.ObjToInt();
+                }
+                //鑾峰彇閲囪喘涓诲崟
+                Dt_PurchaseBSTOrder purchaseBSTOrder = _purchaseBSTOrderRepository.QueryFirst(x=>x.Id==purchaseBSTOrderDetail.PurchaseBSTOrderId);
+                //鑾峰彇鐗╂枡
+                Dt_MaterielInfo materielInfo = _basicRepository.MaterielInfoRepository.QueryFirst(x => x.MaterialSourceId == purchaseBSTOrderDetail.MaterialId);
+                //鐢熸垚搴撳瓨缁勭洏淇℃伅
+                Dt_StockInfo stockInfo = new Dt_StockInfo()
+                {
+                    MaterielInvOrgId = materielInfo.MaterielInvOrgId,
+                    PalletCode = purchaseBSTOrderDetail.Barcode,
+                    LocationCode = "",
+                    PalletType = 1,
+                    WarehouseId = materielInfo.WarehouseId,
+                    StockAttribute = materielInfo.MaterielSourceType,
+                    StockStatus = StockStatusEmun.缁勭洏鏆傚瓨.ObjToInt(),
+                    MaterielSpec = materielInfo.MaterielSpec,
+                    Unit = materielInfo.MaterielUnit,
+                    MaterielThickness = purchaseBSTOrderDetail.MaterialThick,
+                    MaterielWide = purchaseBSTOrderDetail.MaterialWide,
+                    MaterielWeight = purchaseBSTOrderDetail.DeliveryQty,
+                    MaterielCode = materielInfo.MaterielCode,
+                    MaterielName = materielInfo.MaterielName,
+                    StockLength= purchaseBSTOrderDetail.ProcurementLength,
+                    MaterielId= purchaseBSTOrderDetail.MaterialId
+                };
+                if (purchaseBSTOrderDetail.MaterialWide > 1200)
+                {
+                    stockInfo.PalletType = 2;
+                }
+                _unitOfWorkManage.BeginTran();
+                //鏂板缁勭洏淇℃伅
+                _stockRepository.StockInfoRepository.AddData(stockInfo);
+                if (purchaseBSTOrder.PurchaseOrderStatus==InOrderStatusEnum.鏈紑濮�.ObjToInt())
+                {
+                    purchaseBSTOrder.PurchaseOrderStatus = InOrderStatusEnum.鍏ュ簱涓�.ObjToInt();
+                    _purchaseBSTOrderRepository.UpdateData(purchaseBSTOrder);
+                }
+                _purchaseBSTOrderDetailRepository.UpdateData(purchaseBSTOrderDetail);
+                _unitOfWorkManage.CommitTran();
+                content.OK("璇锋眰鎴愬姛");
+            }
+            catch (Exception ex)
+            {
+                _unitOfWorkManage.RollbackTran();
+                content.Error(ex.Message);
+            }
+            return content;
+            
         }
         public string AssignYLRoadwayNo(string palletCode)
         {
@@ -192,16 +286,44 @@
                 }
 
                 string roadwayNo = "";
-                if (stockInfo.MaterielThickness > 800)
+                
+                if (stockInfo.MaterielInvOrgId==MaterielInvOrgEnum.鏂板巶.ObjToInt())
                 {
-                    List<LocationCount> locationCounts = Db.Queryable<Dt_LocationInfo>().Where(x => x.WarehouseId == warehouse.WarehouseId && x.LocationStatus == LocationStatusEnum.Free.ObjToInt() && (x.EnableStatus == EnableStatusEnum.OnlyIn.ObjToInt() || x.EnableStatus == EnableStatusEnum.Normal.ObjToInt()) && x.RoadwayNo.Contains("YL")).GroupBy(x => x.RoadwayNo).Select(x => new LocationCount { RoadwayNo = x.RoadwayNo, Count = SqlFunc.AggregateCount(x) }).ToList();
-                    roadwayNo = locationCounts.OrderByDescending(x => x.Count).FirstOrDefault()?.RoadwayNo ?? "";
-                    if (stockInfo.MaterielWide > 2200)
+                    //闄愬埗鐩村緞
+                    if (stockInfo.MaterielThickness >= 300 && stockInfo.MaterielThickness <= 1300 && stockInfo.MaterielWide >= 700 && stockInfo.MaterielWide <= 2700)
                     {
-                        locationCounts = Db.Queryable<Dt_LocationInfo>().Where(x => x.WarehouseId == warehouse.WarehouseId && x.LocationStatus == LocationStatusEnum.Free.ObjToInt() && (x.EnableStatus == EnableStatusEnum.OnlyIn.ObjToInt() || x.EnableStatus == EnableStatusEnum.Normal.ObjToInt()) && x.RoadwayNo=="SC02_YL").GroupBy(x => x.RoadwayNo).Select(x => new LocationCount { RoadwayNo = x.RoadwayNo, Count = SqlFunc.AggregateCount(x) }).ToList();
-                        roadwayNo = locationCounts.OrderByDescending(x => x.Count).FirstOrDefault()?.RoadwayNo ?? "";
+                        bool LayerLimit = false;
+                        if (stockInfo.MaterielThickness >= 800)
+                        {
+                            LayerLimit = true;
+                        }
+                        //鑾峰彇鍒嗛厤
+                        List<LocationCount> locationCounts = Db.Queryable<Dt_LocationInfo>().Where(x => x.WarehouseId == warehouse.WarehouseId && x.LocationStatus == LocationStatusEnum.Free.ObjToInt() && (x.EnableStatus == EnableStatusEnum.OnlyIn.ObjToInt() || x.EnableStatus == EnableStatusEnum.Normal.ObjToInt()) && x.RoadwayNo.Contains("YLDual")).GroupBy(x => x.RoadwayNo).Select(x => new LocationCount { RoadwayNo = x.RoadwayNo, Count = SqlFunc.AggregateCount(x) }).ToList();
+
+                        roadwayNo = HandleRoadway(locationCounts, warehouse);
                     }
                 }
+                else
+                {
+                    //闄愬埗
+                    if (stockInfo.MaterielThickness >= 800 && stockInfo.MaterielThickness <= 1500 && stockInfo.MaterielWide >= 700 && stockInfo.MaterielWide <= 2500)
+                    {
+                        bool LayerLimit = false;
+                        if (stockInfo.MaterielThickness>1300)
+                        {
+                            LayerLimit = true;
+                        }
+                        //鑾峰彇鍒嗛厤
+                        List<LocationCount> locationCounts = Db.Queryable<Dt_LocationInfo>().Where(x => x.WarehouseId == warehouse.WarehouseId && x.LocationStatus == LocationStatusEnum.Free.ObjToInt() && (x.EnableStatus == EnableStatusEnum.OnlyIn.ObjToInt() || x.EnableStatus == EnableStatusEnum.Normal.ObjToInt()) && x.RoadwayNo.Contains("YL") && !x.RoadwayNo.Contains("YLDual") && (LayerLimit ? x.Columns>=56 : x.Columns<=55)).GroupBy(x => x.RoadwayNo).Select(x => new LocationCount { RoadwayNo = x.RoadwayNo, Count = SqlFunc.AggregateCount(x) }).ToList();
+                        if (stockInfo.MaterielWide > 2200)
+                        {
+                            locationCounts = Db.Queryable<Dt_LocationInfo>().Where(x => x.WarehouseId == warehouse.WarehouseId && x.LocationStatus == LocationStatusEnum.Free.ObjToInt() && (x.EnableStatus == EnableStatusEnum.OnlyIn.ObjToInt() || x.EnableStatus == EnableStatusEnum.Normal.ObjToInt()) && x.RoadwayNo == "SC02_YL" && (LayerLimit ? x.Columns >= 56 : x.Columns <= 55)).GroupBy(x => x.RoadwayNo).Select(x => new LocationCount { RoadwayNo = x.RoadwayNo, Count = SqlFunc.AggregateCount(x) }).ToList();
+                        }
+
+                        roadwayNo = HandleRoadway(locationCounts, warehouse);
+                    }
+                }
+                
                 return !string.IsNullOrEmpty(roadwayNo) ? (roadwayNo) : throw new Exception("鏈壘鍒板彲鍒嗛厤宸烽亾");
             }
             catch (Exception ex)
@@ -210,20 +332,38 @@
                 throw new Exception(ex.Message);
             }
         }
+        //澶勭悊鍒嗛厤宸烽亾 浠诲姟鏁伴噺
+        public string HandleRoadway(List<LocationCount> locationCounts, Dt_Warehouse warehouse)
+        {
+            //宸烽亾浠诲姟鍒嗛厤鏁伴噺
+            List<LocationCount> useLocationCounts = Db.Queryable<Dt_Task>().Where(x => x.WarehouseId == warehouse.WarehouseId
+            && locationCounts.Select(j => j.RoadwayNo).Distinct().Contains(x.Roadway)
+            && TaskInboundTypes.Contains(x.TaskType)).GroupBy(x => x.Roadway).Select(x => new LocationCount { RoadwayNo = x.Roadway, Count = SqlFunc.AggregateCount(x) }).ToList();
+            foreach (var item in locationCounts)
+            {
+                LocationCount? count = useLocationCounts.FirstOrDefault(x => x.RoadwayNo == item.RoadwayNo);
+                if (count != null)
+                {
+                    item.Count -= count.Count;
+                }
+            }
+            return locationCounts.Where(x => x.Count > 0).OrderByDescending(x => x.Count).FirstOrDefault()?.RoadwayNo ?? "";
+        }
         /// <summary>
         /// 鍏ュ簱瀹屾垚
         /// </summary>
         public WebResponseContent InboundTaskCompleted(Dt_Task task)
         {
+            WebResponseContent content = new WebResponseContent();
             try
             {
                 Dt_Warehouse warehouse = _basicRepository.WarehouseRepository.QueryFirst(x => x.WarehouseId == task.WarehouseId);
-                if (warehouse.WarehouseCode == WarehouseEnum.LLDCP.ToString()) //鎴愬搧瀹屾垚
+                if (warehouse.WarehouseCode == WarehouseEnum.LLDCP.ToString() || warehouse.WarehouseCode == WarehouseEnum.LLDFL.ToString()) //鎴愬搧/杈呮枡瀹屾垚
                 {
                     Dt_LocationInfo locationInfoEnd = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == task.TargetAddress);
                     if (locationInfoEnd == null)
                     {
-                        return WebResponseContent.Instance.Error($"鏈壘鍒板搴旂殑缁堢偣璐т綅淇℃伅");
+                        return content.Error($"鏈壘鍒板搴旂殑缁堢偣璐т綅淇℃伅");
                     }
                     Dt_AGVStationInfo agvstation = _agvStationInfoRepository.QueryFirst(x => x.AGVStationCode == task.SourceAddress && ( x.StationArea == AGVStationAreaEnum.AreaA.ObjToInt() || x.StationArea == AGVStationAreaEnum.AreaC.ObjToInt()));
                     if (agvstation != null)
@@ -268,22 +408,24 @@
                     }
                     else
                     {
-                        return WebResponseContent.Instance.Error($"鏈壘鍒板搴斿簱瀛樹俊鎭�");
+                        return content.Error($"鏈壘鍒板搴斿簱瀛樹俊鎭�");
                     }
                 }
                 else//鍘熸枡搴撳畬鎴�
                 {
+                    //鑾峰彇搴撳瓨
                     Dt_StockInfo stockInfo = _stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == task.PalletCode);
                     if (stockInfo == null)
                     {
-                        return WebResponseContent.Instance.Error($"鏈壘鍒板搴斿簱瀛樹俊鎭�");
+                        return content.Error($"鏈壘鍒板搴斿簱瀛樹俊鎭�");
                     }
+                    //鑾峰彇璐т綅淇℃伅
                     Dt_LocationInfo locationInfoEnd = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == task.TargetAddress);
                     if (locationInfoEnd == null)
                     {
-                        return WebResponseContent.Instance.Error($"鏈壘鍒板搴旂殑缁堢偣璐т綅淇℃伅");
+                        return content.Error($"鏈壘鍒板搴旂殑缁堢偣璐т綅淇℃伅");
                     }
-                    
+                    //鏇存柊鐘舵��
                     task.TaskStatus = TaskStatusEnum.Finish.ObjToInt();
                     _unitOfWorkManage.BeginTran();
                     if (task.TaskType == TaskTypeEnum.InPick.ObjToInt())
@@ -296,15 +438,33 @@
                     _stockService.StockInfoService.Repository.UpdateData(stockInfo);
                     _basicService.LocationInfoService.UpdateLocationStatus(locationInfoEnd, stockInfo.PalletType, LocationStatusEnum.InStock, stockInfo.WarehouseId);
                     BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId > 0 ? WIDESEA_Core.Enums.OperateTypeEnum.浜哄伐瀹屾垚 : WIDESEA_Core.Enums.OperateTypeEnum.鑷姩瀹屾垚);
+                    //涓婃姤鑰佸巶ERP
+                    if (stockInfo.MaterielInvOrgId == MaterielInvOrgEnum.鑰佸巶.ObjToInt())
+                    {
+                        int Qty = Convert.ToInt32(stockInfo.MaterielWeight);
+                        BSTPurchaseUpModel bSTPurchaseUpModel = new BSTPurchaseUpModel()
+                        {
+                            Barcode = stockInfo.PalletCode,
+                            BarcodeQty = Qty,
+                            Rfid = stockInfo.PalletCode,
+                            RfidUpdateTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
+                        };
+                        BSTResponse bSTResponse = _invokeERPService.BSTPurchaseUp(bSTPurchaseUpModel).DeserializeObject<BSTResponse>();
+                        if (bSTResponse.Code == 500)
+                        {
+                            throw new Exception($"BST涓�鏈烢RP鍚屾鍏ュ簱淇℃伅澶辫触,閿欒淇℃伅锛歿bSTResponse.Msg}");
+                        }
+                    }
                     _unitOfWorkManage.CommitTran();
                 }
-                return WebResponseContent.Instance.OK();
+                return content.OK();
             }
             catch (Exception ex)
             {
                 _unitOfWorkManage.RollbackTran();
-                return WebResponseContent.Instance.Error(ex.Message);
+                content.Error(ex.Message);
             }
+            return content;
         }
         /// <summary>
         /// 鍒嗛厤鎴愬搧宸烽亾
@@ -314,17 +474,12 @@
         {
             try
             {
-                Dt_Warehouse warehouse = _basicRepository.WarehouseRepository.QueryFirst(x => x.WarehouseId == 2);
-                if (warehouse == null)
-                {
-                    throw new Exception($"鏈壘鍒板贩閬撳搴斾粨搴撲俊鎭�");
-                }
-
                 string roadwayNo = "";
-                List<LocationCount> locationCounts = Db.Queryable<Dt_LocationInfo>().Where(x => x.WarehouseId == warehouse.WarehouseId && x.LocationStatus == LocationStatusEnum.Free.ObjToInt() && (x.EnableStatus == EnableStatusEnum.OnlyIn.ObjToInt() || x.EnableStatus == EnableStatusEnum.Normal.ObjToInt()) && x.RoadwayNo.Contains("CP")).GroupBy(x => x.RoadwayNo).Select(x => new LocationCount { RoadwayNo = x.RoadwayNo, Count = SqlFunc.AggregateCount(x) }).ToList();
+                //鑾峰彇宸烽亾鍙垎閰嶇殑璐т綅鏁伴噺
+                List<LocationCount> locationCounts = Db.Queryable<Dt_LocationInfo>().Where(x => x.WarehouseId == WarehouseEnum.LLDCP.ObjToInt() && x.LocationStatus == LocationStatusEnum.Free.ObjToInt() && (x.EnableStatus == EnableStatusEnum.OnlyIn.ObjToInt() || x.EnableStatus == EnableStatusEnum.Normal.ObjToInt()) && x.RoadwayNo.Contains("CP")).GroupBy(x => x.RoadwayNo).Select(x => new LocationCount { RoadwayNo = x.RoadwayNo, Count = SqlFunc.AggregateCount(x) }).ToList();
                 //绛涢�夊綋鍓嶅叆搴撲换鍔′腑宸插垎閰嶅贩閬撲换鍔℃暟閲�
-                List<LocationCount> useLocationCounts = Db.Queryable<Dt_Task>().Where(x => x.WarehouseId == warehouse.WarehouseId 
-                && locationCounts.Select(j=>j.RoadwayNo).Contains(x.Roadway)
+                List<LocationCount> useLocationCounts = Db.Queryable<Dt_Task>().Where(x => (x.WarehouseId == WarehouseEnum.LLDCP.ObjToInt()|| x.WarehouseId == WarehouseEnum.LLDFL.ObjToInt())
+                && locationCounts.Select(j=>j.RoadwayNo).Distinct().Contains(x.Roadway)
                 && TaskInboundTypes.Contains(x.TaskType)).GroupBy(x => x.Roadway).Select(x => new LocationCount { RoadwayNo = x.Roadway, Count = SqlFunc.AggregateCount(x) }).ToList();
                 foreach (var item in locationCounts)
                 {
@@ -334,7 +489,8 @@
                         item.Count -= count.Count;
                     }
                 }
-                roadwayNo = locationCounts.OrderByDescending(x => x.Count).FirstOrDefault()?.RoadwayNo ?? "";
+                //閫氳繃鍙敤璐т綅鏁伴噺鎺掑簭锛屾渶澶氱殑浼樺厛鍒嗛厤
+                roadwayNo = locationCounts.Where(x=>x.Count>0).OrderByDescending(x => x.Count).FirstOrDefault()?.RoadwayNo ?? "";
                 return !string.IsNullOrEmpty(roadwayNo) ? (roadwayNo) : throw new Exception("鏈壘鍒板彲鍒嗛厤宸烽亾");
             }
             catch (Exception ex)
@@ -382,7 +538,6 @@
                     task.TaskStatus = TaskStatusEnum.SC_Execute.ObjToInt();
                 }
 
-
                 LocationStatusEnum lastStatus = (LocationStatusEnum)locationInfo.LocationStatus;
                 //鏇存柊閿佸畾璐т綅
                 _unitOfWorkManage.BeginTran();
@@ -398,54 +553,7 @@
                 return WebResponseContent.Instance.Error(ex.Message);
             }
         }
-
-        /// <summary>
-        /// 
-        /// </summary>
-        /// <param name="taskNum"></param>
-        /// <param name="roadwayNo"></param>
-        /// <param name="heightType"></param>
-        /// <returns></returns>
-        public WebResponseContent AssignInboundTaskLocationByHeight(int taskNum, string roadwayNo, int heightType)
-        {
-            try
-            {
-                Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
-                if (task == null)
-                {
-                    return WebResponseContent.Instance.Error($"鏈壘鍒拌鍏ュ簱浠诲姟");
-                }
-
-                if (_basicRepository.LocationInfoRepository.QueryFirst(x => x.LocationCode == task.TargetAddress) != null)
-                {
-                    return WebResponseContent.Instance.OK(data: task.TargetAddress);
-                }
-
-                Dt_LocationInfo? locationInfo = _basicService.LocationInfoService.AssignLocation(roadwayNo, task.PalletType, task.WarehouseId, heightType: heightType);
-                if (locationInfo == null)
-                {
-                    return WebResponseContent.Instance.Error($"璐т綅鍒嗛厤澶辫触,鏈壘鍒板彲鍒嗛厤璐т綅");
-                }
-
-                task.Roadway = roadwayNo;
-                task.TargetAddress = locationInfo.LocationCode;
-                task.TaskStatus = TaskStatusEnum.SC_Execute.ObjToInt();
-
-                LocationStatusEnum lastStatus = (LocationStatusEnum)locationInfo.LocationStatus;
-
-                _unitOfWorkManage.BeginTran();
-                _recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfo, lastStatus, LocationStatusEnum.Lock, LocationChangeType.InboundAssignLocation);
-                _basicService.LocationInfoService.UpdateLocationStatus(locationInfo, task.PalletType, LocationStatusEnum.Lock, task.WarehouseId);
-                BaseDal.UpdateData(task);
-                _unitOfWorkManage.CommitTran();
-                return WebResponseContent.Instance.OK(data: locationInfo.LocationCode);
-            }
-            catch (Exception ex)
-            {
-                _unitOfWorkManage.RollbackTran();
-                return WebResponseContent.Instance.Error(ex.Message);
-            }
-        }
+        
         /// <summary>
         /// 绌烘鍥炲簱
         /// </summary>
@@ -484,15 +592,13 @@
                 //鍒嗛厤宸烽亾
                 string roadWay=AssignCPRoadwayNo();
                 
-                //鑾峰彇鎴愬搧搴�
-                Dt_Warehouse warehouse = _basicRepository.WarehouseRepository.QueryFirst(x => x.WarehouseCode == WarehouseEnum.LLDCP.ToString());
                 Dt_ProStockInfo proStockInfo = new Dt_ProStockInfo()
                 {
                     PalletCode=barCode,
                     ProStockAttribute=ProStockAttributeEnum.绌烘墭.ObjToInt(),
                     PalletType=1,
                     LocationCode="",
-                    WarehouseId=warehouse.WarehouseId,
+                    WarehouseId= WarehouseEnum.LLDFL.ObjToInt(),
                     StockStatus=StockStatusEmun.MES绌烘墭閫�搴�.ObjToInt()
                 }; 
 
@@ -507,7 +613,7 @@
                     TargetAddress = "",
                     TaskType = TaskTypeEnum.EmptyProductBack.ObjToInt(),
                     TaskStatus = TaskStatusEnum.New.ObjToInt(),
-                    WarehouseId = warehouse.WarehouseId,
+                    WarehouseId = WarehouseEnum.LLDFL.ObjToInt(),
                     PalletType = 1
                 };
                 _unitOfWorkManage.BeginTran();
@@ -526,14 +632,14 @@
             }
             return content;
         }
-        private readonly static object _lockerFL = new object();
+        private readonly static object _lockerFLorCP = new object();
         /// <summary>
-        /// 杈呮枡鍏ュ簱
+        /// 杈呮枡/鎴愬搧涓存椂鍏ュ簱
         /// </summary>
         /// <returns></returns>
-        public WebResponseContent InboundFLTask(string barCode, string startPoint,string matCode,int matCount)
+        public WebResponseContent InboundFLOrCPTask(string barCode, string startPoint,string matCode,int matCount)
         {
-            lock (_lockerFL)
+            lock (_lockerFLorCP)
             {
                 WebResponseContent content = new WebResponseContent();
                 try
@@ -544,7 +650,8 @@
                     //{
                     //    return content.Error($"妗嗙爜鏍煎紡閿欒{barCode}");
                     //}
-                    Dt_MaterielInfo materielInfo = _basicRepository.MaterielInfoRepository.QueryFirst(x => x.MaterielCode == matCode && x.MaterielInvOrgId == MaterielInvOrgEnum.鏂板巶.ObjToInt() && x.MaterielSourceType == MaterielTypeEnum.杈呮枡澶囦欢.ObjToInt());
+                    //鑾峰彇鐗╂枡
+                    Dt_MaterielInfo materielInfo = _basicRepository.MaterielInfoRepository.QueryFirst(x => x.MaterielCode == matCode && x.MaterielInvOrgId == MaterielInvOrgEnum.鏂板巶.ObjToInt() && (x.WarehouseId==WarehouseEnum.LLDCP.ObjToInt() || x.WarehouseId == WarehouseEnum.LLDFL.ObjToInt()));
                     if (materielInfo == null)
                     {
                         return content.Error($"鏈壘鍒扮墿鏂欎俊鎭瘂matCode}");
@@ -574,20 +681,23 @@
                     string roadWay = AssignCPRoadwayNo();
 
                     //鑾峰彇鎴愬搧搴�
-                    Dt_Warehouse warehouse = _basicRepository.WarehouseRepository.QueryFirst(x => x.WarehouseCode == WarehouseEnum.LLDCP.ToString());
+                    WarehouseEnum warehouseEnum = materielInfo.MaterielSourceType == MaterielTypeEnum.鎴愬搧.ObjToInt() ? WarehouseEnum.LLDCP : WarehouseEnum.LLDFL;
                     Dt_ProStockInfoDetail proStockInfoDetail = new Dt_ProStockInfoDetail()
                     {
-                        ProductCode = matCode,
+                        ProductCode = materielInfo.MaterielCode,
+                        ProductName= materielInfo.MaterielName,
+                        ProductSpec=materielInfo.MaterielSpec,
+                        ProductUnit=materielInfo.MaterielUnit,
                         StockQty = matCount,
                         ProStockDetailStatus = StockStatusEmun.鎵嬪姩缁勭洏鍏ュ簱纭.ObjToInt()
                     };
                     Dt_ProStockInfo proStockInfo = new Dt_ProStockInfo()
                     {
                         PalletCode = barCode,
-                        ProStockAttribute = ProStockAttributeEnum.杈呮枡澶囦欢.ObjToInt(),
+                        ProStockAttribute = materielInfo.MaterielSourceType,
                         PalletType = 1,
                         LocationCode = "",
-                        WarehouseId = warehouse.WarehouseId,
+                        WarehouseId = warehouseEnum.ObjToInt(),
                         StockStatus = StockStatusEmun.鎵嬪姩缁勭洏鍏ュ簱纭.ObjToInt(),
                         proStockInfoDetails = new List<Dt_ProStockInfoDetail> { proStockInfoDetail }
                     };
@@ -603,7 +713,7 @@
                         TargetAddress = "",
                         TaskType = TaskTypeEnum.Inbound.ObjToInt(),
                         TaskStatus = TaskStatusEnum.New.ObjToInt(),
-                        WarehouseId = warehouse.WarehouseId,
+                        WarehouseId = warehouseEnum.ObjToInt(),
                         PalletType = 1
                     };
                     _unitOfWorkManage.BeginTran();

--
Gitblit v1.9.3