From a4254c45c86d19a76147cbf375cba7f1a7aff5d6 Mon Sep 17 00:00:00 2001
From: 肖洋 <cathay_xy@163.com>
Date: 星期五, 29 十一月 2024 13:54:28 +0800
Subject: [PATCH] 忽略项

---
 Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs |   75 ++++++++++++++++++++++++-------------
 1 files changed, 48 insertions(+), 27 deletions(-)

diff --git a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
index fae1f1e..69b11ac 100644
--- a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
+++ b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
@@ -1,17 +1,9 @@
-锘縰sing log4net.Core;
-using Mapster;
+锘縰sing Mapster;
 using Masuit.Tools;
-using Masuit.Tools.Models;
-using System.Linq;
-using System.Threading.Tasks;
 using WIDESEA_DTO.MOM;
 using WIDESEA_DTO.WMS;
-using WIDESEA_IStorageBasicRepository;
 using WIDESEA_IStoragIntegrationServices;
-using WIDESEA_Model.Models;
 using WIDESEA_StorageBasicRepository;
-using WIDESEA_StorageTaskRepository;
-using WIDESEA_StoragIntegrationServices;
 using WIDESEAWCS_BasicInfoRepository;
 
 namespace WIDESEA_StorageOutTaskServices;
@@ -106,7 +98,12 @@
                 {
                     var agingOutputDto = MapToAgingOutputDto(stock);
                     content = await _agingInOrOutInputService.GetOCVOutputAsync(agingOutputDto);
-                    ValidateResponse(content);
+                    //ValidateResponse(content);
+                    var result = JsonConvert.DeserializeObject<BasicResult>(content.Data.ToString());
+                    if (!result.Success)
+                    {
+                        task.Remark = "NG";
+                    }
                 }
             }
 
@@ -119,10 +116,11 @@
                 await UpdateLocationAsync(loc);
                 await DeleteStockInfoAsync(stock.Id);
                 await DeleteStockInfoDetailsAsync(stock.StockInfoDetails);
-                //await DeleteTaskAsync(task.TaskId);
+                if (task.Roadway.Contains("FR") || task.Roadway.Contains("GW"))   //濡傛灉鏄垎瀹规垨楂樻俯鍑哄簱 灏嗕换鍔″垹闄�
+                    await DeleteTaskAsync(task.TaskId);
             });
 
-            return content.OK("浠诲姟瀹屾垚鎴愬姛");
+            return content.OK("浠诲姟瀹屾垚鎴愬姛", task.Remark);
         }
         catch (Exception err)
         {
@@ -145,7 +143,8 @@
 
         var outHours = (DateTime.Now - stock.OutboundTime.Value).TotalHours;
         var isNG = outHours > parameterInfo.LowerSpecificationsLimit.ToDouble() && outHours < parameterInfo.UpperSpecificationsLimit.ToDouble();
-
+        var defectCode = string.Empty;
+        if (!isNG) defectCode = "TQCK";
         return new AgingOutputDto
         {
             OpFlag = 1,
@@ -166,6 +165,7 @@
                         TargetValue = parameterInfo.TargetValue,
                         LowerLomit = parameterInfo.LowerSpecificationsLimit,
                         UpperLimit = parameterInfo.UpperSpecificationsLimit,
+                        DefectCode = defectCode
                     }
                 }
             }).ToList()
@@ -174,11 +174,7 @@
 
     private void ValidateResponse(WebResponseContent content)
     {
-        var result = JsonConvert.DeserializeObject<BasicResult>(content.Data.ToString());
-        if (!result.Success)
-        {
-            throw new Exception(result.MOMMessage);
-        }
+
     }
 
     private (DtLocationInfo, Dt_Task) UpdateStockAndTaskStatus(DtStockInfo stock, Dt_Task task)
@@ -303,7 +299,7 @@
 
             // 鑾峰彇瑁呯淇℃伅鍜岀洰鏍囦綅缃俊鎭�
             var boxing = await _boxingInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode);
-            var locationInf = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.TargetAddress);
+            var locationInf = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.TargetAddress && x.RoadwayNo == task.Roadway);
 
             // 鏇存柊鐩爣浣嶇疆鐘舵�佷负搴撳瓨涓�
             locationInf.LocationStatus = (int)LocationEnum.InStock;
@@ -316,7 +312,7 @@
 
 
             // 鎵ц鏁版嵁搴撲簨鍔�
-            bool isResult = await ExecuteTransaction(stock, taskHty, locationInf, task.TaskId);
+            bool isResult = await ExecuteTransaction(stock, taskHty, locationInf, task.TaskId, boxing);
             if (isResult)
             {
                 content.OK("鍏ュ簱浠诲姟瀹屾垚鎴愬姛");
@@ -433,7 +429,7 @@
         stock.LinedProcessFeedbackTime = respone.LinedProcessFeedbackTime;
         stock.SpecialParameterDuration = respone.SpecialParameterDuration;
         //2024骞�11鏈�16鏃ワ細鏂板瀛楁璁$畻搴斿嚭搴撴椂闂�
-        stock.OutboundTime = Convert.ToDateTime(respone.LinedProcessFeedbackTime).AddHours(Convert.ToDouble(respone.SpecialParameterDuration));
+        stock.OutboundTime = Convert.ToDateTime(respone.LinedProcessFeedbackTime == null ? DateTime.Now : respone.LinedProcessFeedbackTime).AddHours(Convert.ToDouble(respone.SpecialParameterDuration));
         stock.ProductionLine = respone.ProductionLine;
         stock.ParameterInfos = respone.ParameterInfos.ToJsonString();
         stock.StockStatus = 1;
@@ -570,7 +566,17 @@
             if (serialNosError.Count > 0)
             {
                 // TODO 鍒涘缓浠诲姟閫佽嚦NG鎺掑嚭鍙�
-                List<string> NGStation = input.Position == "1088" ? new List<string>() { "1020" } : new List<string>() { "JZSC01" };
+                var efg = _stationManagerRepository.QueryData(x => x.stationType == 1 && x.stationChildCode == input.Position && x.stationArea == area.AreaCode).ToList();
+                //List<string> NGStation = input.Position == "1088" ? new List<string>() { "1020" } : new List<string>() { "JZSC01" };
+                if (efg.Count <= 0)
+                {
+                    throw new Exception("鏈壘鍒癗G鍏ュ簱绔欏彴閰嶇疆");
+                }
+                List<string> NGStation = efg.Select(x => x.stationNGLocation).ToList();
+                if (NGStation.Count <= 0)
+                {
+                    NGStation = efg.Select(x => x.stationNGChildCode).ToList();
+                }
                 content = await CreateNewTask(input, NGStation, 2);
                 return content.Error("瀛樺湪寮傚父鐢佃姱");
             }
@@ -581,6 +587,7 @@
                 content = await RequestTrayInTaskAsync(input);
                 return content;
             }
+            //Console.WriteLine("qqqqq");
 
             // TODO 鑾峰彇鏈湴鏂欐灞炴�т笌鏁寸洏鐢佃姱灞炴�ц幏鍙栫殑鍊艰繘琛屽姣旓紝濡傛灉涓�鑷村垯缁х画锛屽惁鍒欒繑鍥為敊璇俊鎭�
             //var productions = await _productionRepository.QueryDataAsync(x => result.TrayBarcodePropertys.Select(x => x.TrayBarcodeProperty).ToList().Contains(x.TrayBarcodeProperty));
@@ -590,6 +597,7 @@
             // 璋冪敤CreateBoxingInfo鏂规硶锛屽垱寤虹粍鐩樹俊鎭�
 
             var boxing = CreateBoxingInfo(result, input.PalletCode);
+            //Console.WriteLine(boxing.ToJsonString());
             if (boxing == null) return content.Error("缁勭洏澶辫触");
 
             // 璋冪敤GetProcessApplyAsync鏂规硶锛岃幏鍙栧伐鑹鸿矾绾�
@@ -613,8 +621,14 @@
             //// 璋冪敤GetProcessResponseAsync鏂规硶锛岃幏鍙栧伐鑹哄搷搴�
             //var processResponse = await GetProcessResponseAsync(process, input.Position);
 
-            List<string> strings = input.Position == "1088" ? new List<string>() { "CHSC01" } : new List<string>() { "JZSC01" };
-            // 璋冪敤CreateNewTask鏂规硶锛屽垱寤烘柊浠诲姟
+            //List<string> strings = input.Position == "1088" ? new List<string>() { "CHSC01" } : new List<string>() { "JZSC01" };
+            var stationManagers = _stationManagerRepository.QueryData(x => x.stationType == 1 && x.stationChildCode == input.Position && x.stationArea == area.AreaCode).ToList();
+            if (stationManagers.Count <= 0)
+            {
+                throw new Exception("鏈壘鍒癗G鍏ュ簱绔欏彴閰嶇疆");
+            }
+            List<string> strings = stationManagers.Select(x => x.Roadway).ToList();
+            //// 璋冪敤CreateNewTask鏂规硶锛屽垱寤烘柊浠诲姟
             content = await CreateNewTask(input, strings);
             if (content.Status)
             {
@@ -687,8 +701,15 @@
                 return content.OK(data: task);
             }
 
+            var stationManagers = _stationManagerRepository.QueryData(x => x.stationType == 1 && x.stationChildCode == input.Position).ToList();
+            if (stationManagers.Count <= 0)
+            {
+                throw new Exception("鏈壘鍒扮┖鎵樼洏鍏ュ簱绔欏彴閰嶇疆");
+            }
+
+
             // 鑾峰彇鐩爣鍦板潃
-            List<string> strings = input.Position == "1016" ? new List<string>() { "CHSC01" } : new List<string>() { "JZSC01" };
+            List<string> strings = stationManagers.Select(x => x.Roadway).ToList();
 
             return await CreateNewTask(input, strings, 1);
         }
@@ -1216,8 +1237,8 @@
                 if (boxingInfo != null)
                 {
                     isDeleteBoxing = await _boxingInfoRepository.Db.DeleteNav<DtBoxingInfo>(x => x.Id == boxingInfo.Id)
-                .Include(x => x.BoxingInfoDetails)
-                .ExecuteCommandAsync();
+                                            .Include(x => x.BoxingInfoDetails)
+                                            .ExecuteCommandAsync();
                 }
 
             }

--
Gitblit v1.9.3