From a5ca8352f035f95d23717e49b74a6c6aea8a9fc9 Mon Sep 17 00:00:00 2001
From: huangxiaoqiang <1247017146@qq.com>
Date: 星期三, 02 四月 2025 16:03:12 +0800
Subject: [PATCH] 添加MOM异常信息页面,OCV管理页面,优化WCS不能添加用户信息问题,优化分容空框回流写入线体信息失败问题

---
 CodeManagement/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs |   70 ++++++++++++-----------------------
 1 files changed, 24 insertions(+), 46 deletions(-)

diff --git a/CodeManagement/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs b/CodeManagement/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
index 7c0cb7e..a59aa03 100644
--- a/CodeManagement/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
+++ b/CodeManagement/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
@@ -20,6 +20,7 @@
     /// <returns>鍖呭惈浠诲姟淇℃伅鐨勫搷搴斿唴瀹�</returns>
     public async Task<WebResponseContent> RequestInTask(RequestTaskDto input)
     {
+        Console.WriteLine($"{JsonConvert.SerializeObject(input)}");
         // 鍒涘缓涓�涓猈ebResponseContent瀵硅薄
         WebResponseContent content = new WebResponseContent();
         try
@@ -540,15 +541,6 @@
         {
             if (stationManager.stationType != 7) throw new Exception("閿欒鐨勮皟鍙�");
 
-            // 浠庣紦瀛樹腑鑾峰彇搴撳瓨淇℃伅
-            //IDictionary<string, DtStockInfo>? stockInfos = _simpleCacheService.HashGetAll<DtStockInfo>(WIDESEA_Cache.CacheConst.Cache_DtStockInfo);
-            //List<DtStockInfo> stockInfoList = stockInfos.Values.ToList();
-
-            //var stockinfo1 = stockInfoList.OrderBy(x => x.CreateDate)
-            //    .ToList();
-            //var strings = stationManager.Roadway.Split(",");
-            //var stockinfo = stockinfo1.Where(x => x.LocationInfo != null && !x.IsFull && strings.Contains(x.LocationInfo.RoadwayNo))
-            //    .FirstOrDefault();
             var stockInfo = await QueryStockInfoForEmptyTrayFRAsync("CWSC1", "10086", input.ProductionLine);
 
             if (stockInfo == null) return null;
@@ -577,7 +569,6 @@
             location.LocationStatus = (int)LocationEnum.InStockDisable;
             _locationRepository.UpdateData(location);
 
-            _simpleCacheService.HashDel<DtStockInfo>(WIDESEA_Cache.CacheConst.Cache_DtStockInfo, new string[] { task.PalletCode });
             return task;
         }
         catch (Exception ex)
@@ -987,23 +978,17 @@
             .Where(x => stackers.Contains(x.DeviceCode))
             .ToList().Select(x => x.DeviceCode).ToList();
 
-        // 浠庣紦瀛樹腑鑾峰彇搴撳瓨淇℃伅
-        IDictionary<string, DtStockInfo>? stockInfos = _simpleCacheService.HashGetAll<DtStockInfo>(WIDESEA_Cache.CacheConst.Cache_DtStockInfo);
-        List<DtStockInfo> stockInfoList = stockInfos.Values.ToList();
+        var result = await _stockInfoRepository.Db.Queryable<DtStockInfo>()
+                                .Includes(x => x.LocationInfo)
+                                .Includes(x => x.StockInfoDetails)
+                                .Where(x => x.AreaCode == areaCode && x.IsFull == false && x.ProductionLine == productLine)
+                                .WhereIF(!deviceCode.IsNullOrEmpty(), x => deviceCode.Contains(x.LocationInfo.RoadwayNo))
+                                .Where(x => x.LocationInfo.LocationStatus == (int)LocationEnum.InStock && x.LocationInfo.AreaId == area.AreaID && x.LocationInfo.EnalbeStatus == (int)EnableEnum.Enable) // 杩囨护鏉′欢
+                                .Where(x => x.StockInfoDetails.Any(y => y.MaterielCode == "绌烘墭鐩�"))
+                                .OrderBy(x => x.CreateDate) // 鎺掑簭
+                                .FirstAsync();
 
-        var result1 = stockInfoList.Where(x => x.ProductionLine == productLine)
-            .Where(x => x.AreaCode == areaCode && x.IsFull == false)
-            .WhereIF(!deviceCode.IsNullOrEmpty(), x => x.LocationInfo != null && deviceCode.Contains(x.LocationInfo.RoadwayNo))
-            .OrderBy(x => x.CreateDate) // 鎺掑簭
-            .ToList(); // 杞崲涓哄垪琛�
-
-        var result = result1.Where(x => x.StockInfoDetails != null && x.StockInfoDetails.Any(y => y.MaterielCode == "绌烘墭鐩�"))
-            .Where(x => x.LocationInfo != null && x.LocationInfo.LocationStatus == (int)LocationEnum.InStock && x.LocationInfo.AreaId == area.AreaID && x.LocationInfo.EnalbeStatus == (int)EnableEnum.Enable) // 杩囨护鏉′欢
-            .FirstOrDefault(); // 鑾峰彇绗竴涓厓绱�
-
-        if (result != null)
-            _simpleCacheService.HashDel<DtStockInfo>(WIDESEA_Cache.CacheConst.Cache_DtStockInfo, new string[] { result.PalletCode });
-        else
+        if (result.IsNullOrEmpty())
             ConsoleHelper.WriteColorLine($"甯告俯{productLine}绌烘墭鐩樺簱瀛樹笉瓒�", ConsoleColor.Red);
 
         return result;
@@ -1034,29 +1019,24 @@
                 .Where(x => x.DeviceCode.Contains("CWSC")) // 杩囨护鏉′欢
                 .ToList().Select(x => x.DeviceCode).ToList();
 
-            // 浠庣紦瀛樹腑鑾峰彇搴撳瓨淇℃伅
-            IDictionary<string, DtStockInfo>? stockInfos = _simpleCacheService.HashGetAll<DtStockInfo>(WIDESEA_Cache.CacheConst.Cache_DtStockInfo);
-            List<DtStockInfo> stockInfoList = stockInfos.Values.ToList();
-
             // 淇敼鍚庣殑鏌ヨ浠g爜
-            var stockInfo1 = stockInfoList
-                .Where(x => x.ProductionLine == station.productLine)
-                .Where(x => x.AreaCode == "CWSC3" && x.IsFull == true)
-                .OrderBy(x => x.OutboundTime)
-                .ToList();
+            var stockInfo = await _stockInfoRepository.Db.Queryable<DtStockInfo>()
+                                .Includes(x => x.LocationInfo)
+                                .Includes(x => x.StockInfoDetails)
+                                .Where(x => x.ProductionLine == station.productLine)
+                                .Where(x => x.AreaCode == "CWSC3" && x.IsFull == true)
+                                // 澧炲姞瀵� LocationInfo 鐨勭┖鍊兼鏌�
+                                .Where(x => x.LocationInfo.LocationStatus == (int)LocationEnum.InStock)
+                                // 澧炲姞瀵� LocationInfo 鐨勭┖鍊兼鏌�
+                                .WhereIF(!deviceCode.IsNullOrEmpty(), x => deviceCode.Contains(x.LocationInfo.RoadwayNo))
+                                .OrderBy(x => x.OutboundTime)
+                                .FirstAsync();
 
-            var stockInfo = stockInfo1
-                // 澧炲姞瀵� LocationInfo 鐨勭┖鍊兼鏌�
-                .Where(x => x.LocationInfo != null && x.LocationInfo.LocationStatus == (int)LocationEnum.InStock)
-                // 澧炲姞瀵� LocationInfo 鐨勭┖鍊兼鏌�
-                .WhereIF(!deviceCode.IsNullOrEmpty(), x => x.LocationInfo != null && deviceCode.Contains(x.LocationInfo.RoadwayNo))
-                .FirstOrDefault();
-
-            if (stockInfo == null) throw new Exception($"搴撳唴{station.productLine}鏃犳弧瓒虫潯浠剁殑搴撳瓨鍙嚭搴�");
+            if (stockInfo.IsNullOrEmpty()) throw new Exception($"CWSC3搴撳唴{station.productLine}鏃犳弧瓒虫潯浠剁殑搴撳瓨鍙嚭搴�");
 
             DtLocationInfo locationInfo = _locationRepository.QueryFirst(x => x.AreaId == 5 && x.LocationCode == stockInfo.LocationCode);
 
-            Dt_StationManager OutStation = _stationManagerRepository.QueryFirst(x => x.stationPLC == "1016" && x.stationType == 10 && x.Roadway == locationInfo.RoadwayNo && x.stationStatus == "1");
+            Dt_StationManager OutStation = _stationManagerRepository.QueryFirst(x => x.stationPLC == "1005" && x.stationType == 10 && x.Roadway == locationInfo.RoadwayNo && x.stationStatus == "1");
 
             // 鍒涘缓鏂颁换鍔″疄渚�
             var task = new Dt_Task
@@ -1086,8 +1066,6 @@
             BaseDal.AddData(task);
             stockInfo.LocationInfo.LocationStatus = (int)LocationEnum.InStockDisable;
             _locationRepository.UpdateData(stockInfo.LocationInfo);
-
-            _simpleCacheService.HashDel<DtStockInfo>(WIDESEA_Cache.CacheConst.Cache_DtStockInfo, new string[] { taskDTO.PalletCode });
 
             _locationStatusChangeRecordRepository.AddLocationStatusChangeRecord(stockInfo.LocationInfo, lastStatus, (int)StatusChangeTypeEnum.AutomaticDelivery, task.TaskNum);
 

--
Gitblit v1.9.3