From 373c52bea19dd631687453b4d6cb711ccf55b73a Mon Sep 17 00:00:00 2001
From: 刘磊 <1161824510@qq.com>
Date: 星期一, 04 八月 2025 18:08:22 +0800
Subject: [PATCH] 同步

---
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/GWTask/RequestInbound.cs    |   14 ++-
 Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs              |   69 ++++++++--------
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_IBasicInfoService/IDt_StationManagerService.cs       |    8 ++
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_BasicInfoService/Partial/Method.cs                   |    5 +
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/CommonConveyorLine_GWJob.cs |  136 ++++++++++++++++++---------------
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_CW/CommonConveyorLine_CWJob.cs |    6 
 6 files changed, 133 insertions(+), 105 deletions(-)

diff --git a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_BasicInfoService/Partial/Method.cs b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_BasicInfoService/Partial/Method.cs
index 9000e31..6a2929b 100644
--- a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_BasicInfoService/Partial/Method.cs
+++ b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_BasicInfoService/Partial/Method.cs
@@ -21,5 +21,10 @@
             return BaseDal.QueryFirst(x => x.stationChildCode == ChildCode && x.stationArea == area && x.stationStatus == "1");
         }
 
+        public List<Dt_StationManager> GetStationInfoByOCV(string ChildCode, int stationType)
+        {
+            return BaseDal.QueryData(x => x.stationChildCode == ChildCode && x.stationType == stationType && x.stationStatus == "1").ToList();
+        }
+
     }
 }
diff --git a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_IBasicInfoService/IDt_StationManagerService.cs b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_IBasicInfoService/IDt_StationManagerService.cs
index 423e7d1..1bf9a98 100644
--- a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_IBasicInfoService/IDt_StationManagerService.cs
+++ b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_IBasicInfoService/IDt_StationManagerService.cs
@@ -39,5 +39,13 @@
         /// <param name="area"></param>
         /// <returns></returns>
         Dt_StationManager GetStationInfoByChildCode(string ChildCode, string area);
+
+        /// <summary>
+        /// 鏍规嵁瀛愯澶囩紪鍙峰拰绔欏彴绫诲瀷 鑾峰彇鍚敤鐨勭珯鍙�
+        /// </summary>
+        /// <param name="ChildCode">璁惧PLC缂栧彿</param>
+        /// <param name="sttionType">绔欏彴绫诲瀷</param>
+        /// <returns></returns>
+        List<Dt_StationManager> GetStationInfoByOCV(string ChildCode, int sttionType);
     }
 }
\ No newline at end of file
diff --git a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_CW/CommonConveyorLine_CWJob.cs b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_CW/CommonConveyorLine_CWJob.cs
index ecb95db..bdeadd9 100644
--- a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_CW/CommonConveyorLine_CWJob.cs
+++ b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_CW/CommonConveyorLine_CWJob.cs
@@ -118,8 +118,8 @@
                     #region 璺敱鏂瑰紡
 
                     List<string> childDeviceCodes = _routerService.QueryAllPositions(conveyorLine.DeviceCode);
-                    DateTime dateTime = DateTime.Now;
-                    Console.WriteLine($"寰幆寮�濮嬫椂闂磠dateTime}");
+                    //DateTime dateTime = DateTime.Now;
+                    //Console.WriteLine($"寰幆寮�濮嬫椂闂磠dateTime}");
                     foreach (string childDeviceCode in childDeviceCodes)
                     {
                         //Thread.Sleep(1000);
@@ -188,7 +188,7 @@
 
                     }
                     DateTime ENDdateTime = DateTime.Now;
-                    Console.WriteLine($"寰幆缁撴潫鏃堕棿{ENDdateTime}");
+                    //Console.WriteLine($"寰幆缁撴潫鏃堕棿{ENDdateTime}");
 
                     #endregion 璺敱鏂瑰紡
                 }
diff --git a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/CommonConveyorLine_GWJob.cs b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/CommonConveyorLine_GWJob.cs
index 7bb1fe6..bf43183 100644
--- a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/CommonConveyorLine_GWJob.cs
+++ b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/CommonConveyorLine_GWJob.cs
@@ -52,7 +52,7 @@
 
 namespace WIDESEAWCS_Tasks
 {
-    //[DisallowConcurrentExecution]
+    [DisallowConcurrentExecution]
     public partial class CommonConveyorLine_GWJob : JobBase, IJob
     {
         public readonly ITaskService _taskService;
@@ -69,7 +69,7 @@
         private readonly IDeviceInfoRepository _deviceInfoRepository;
         private static List<string>? userTokenIds;
         private static List<int>? userIds;
-        private static List<string> childCodeList = new List<string>();
+        //private static List<string> childCodeList = new List<string>();
 
         public CommonConveyorLine_GWJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper, ITaskRepository taskRepository, IPlatFormRepository platFormRepository, ISys_ConfigService sys_ConfigService, IDt_StationManagerRepository stationManagerRepository, ICacheService cacheService, INoticeService noticeService, IDt_needBarcodeRepository needBarcodeRepository, IDeviceInfoRepository deviceInfoRepository)
         {
@@ -118,71 +118,77 @@
                     #region 璺敱鏂瑰紡
 
                     List<string> childDeviceCodes = _routerService.QueryAllPositions(conveyorLine.DeviceCode);
+                    //DateTime dateTime = DateTime.Now;
+                    //Console.WriteLine($"寰幆寮�濮嬫椂闂磠dateTime}");
                     foreach (string childDeviceCode in childDeviceCodes)
                     {
-                        if (childCodeList.Contains(childDeviceCode))
+                        //Thread.Sleep(1000);
+                        //if (childCodeList.Contains(childDeviceCode))
+                        //{
+                        //    Console.WriteLine($"褰撳墠{childDeviceCode}鎵ц涓紝宸茶烦杩�");
+                        //    continue;
+                        //}
+                        //childCodeList.Add(childDeviceCode);
+                        //Console.WriteLine(childDeviceCode);
+                        ConveyorLineTaskCommand_After command = conveyorLine.ReadCustomer<ConveyorLineTaskCommand_After>(childDeviceCode);
+
+                        if (command == null) continue;
+                        //if (command.InteractiveSignal == 0 && command.HasPallet != 1) continue;
+                        if (command.ConveyorLineBarcode.Trim().Contains("\0")) command.ConveyorLineBarcode = "";
+                        
+                        DeviceProtocolDetailDTO? deviceProtocolDetails = conveyorLine.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(ConveyorLineTaskCommand_After.InteractiveSignal) && x.ProtocalDetailValue == command.InteractiveSignal.ToString());
+                        if (deviceProtocolDetails != null)
                         {
+                            MethodInfo? method = GetType().GetMethod(deviceProtocolDetails.ProtocolDetailType);
+                            if (method != null)
+                            {
+                                method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode });
+                            }
+                        }
+
+                        //if (childDeviceCode == "1670" || childDeviceCode == "1666" || childDeviceCode == "1548" || childDeviceCode == "1448")
+                        //{
+                        //    Platform platform = _platFormRepository.QueryFirst(x => x.DeviceCode == conveyorLine.DeviceCode && x.PlatCode == childDeviceCode && x.Status == "Active");
+                        //    if (platform != null)
+                        //    {
+                        //        if (command.HasPallet != 1)
+                        //        {
+                        //            MethodInfo? method = GetType().GetMethod(platform.ExecutionMethod);
+                        //            if (method != null)
+                        //            {
+                        //                //var strings = platform.Location.Split(',').ToList();
+                        //                int count = 1;
+                        //                method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count, platform });
+                        //            }
+                        //        }
+                        //    }
+                        //}
+
+                        //childCodeList.Remove(childDeviceCode);
+
+                        #region 璋冪敤浜嬩欢鎬荤嚎閫氱煡鍓嶇
+
+                        var tokenInfos = _cacheService.Get<List<UserInfo>>("Cache_UserToken");
+                        if (tokenInfos == null || !tokenInfos.Any())
+                        {
+                            //throw new Exception(conveyorLine.DeviceName + "缂撳瓨涓湭鎵惧埌Token缂撳瓨");
                             continue;
                         }
-                        childCodeList.Add(childDeviceCode);
+                        var userTokenIds = tokenInfos?.Select(x => x.Token_ID).ToList();
+                        var userIds = tokenInfos?.Select(x => x.UserId).ToList();
 
-                        lock (this)
+                        object obj = new
                         {
-                            ConveyorLineTaskCommand_After command = conveyorLine.ReadCustomer<ConveyorLineTaskCommand_After>(childDeviceCode);
+                            childDeviceCode,
+                            commandAfter = command,
+                        };
+                        _noticeService.LineData(userIds?.FirstOrDefault(), userTokenIds, new { conveyorLine.DeviceName, data = obj });
 
-                            if (command == null) continue;
-                            if (command.ConveyorLineBarcode.Trim().Contains("\0")) command.ConveyorLineBarcode = "";
+                        #endregion 璋冪敤浜嬩欢鎬荤嚎閫氱煡鍓嶇
 
-                            DeviceProtocolDetailDTO? deviceProtocolDetails = conveyorLine.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(ConveyorLineTaskCommand_After.InteractiveSignal) && x.ProtocalDetailValue == command.InteractiveSignal.ToString());
-                            if (deviceProtocolDetails != null)
-                            {
-                                MethodInfo? method = GetType().GetMethod(deviceProtocolDetails.ProtocolDetailType);
-                                if (method != null)
-                                {
-                                    method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode });
-                                }
-                            }
-
-                            if (childDeviceCode == "1670" || childDeviceCode == "1666" || childDeviceCode == "1548" || childDeviceCode == "1448")
-                            {
-                                Platform platform = _platFormRepository.QueryFirst(x => x.DeviceCode == conveyorLine.DeviceCode && x.PlatCode == childDeviceCode && x.Status == "Active");
-                                if (platform != null)
-                                {
-                                    if (command.HasPallet != 1)
-                                    {
-                                        MethodInfo? method = GetType().GetMethod(platform.ExecutionMethod);
-                                        if (method != null)
-                                        {
-                                            //var strings = platform.Location.Split(',').ToList();
-                                            int count = 1;
-                                            method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count, platform });
-                                        }
-                                    }
-                                }
-                            }
-                            #region 璋冪敤浜嬩欢鎬荤嚎閫氱煡鍓嶇
-
-                            var tokenInfos = _cacheService.Get<List<UserInfo>>("Cache_UserToken");
-                            if (tokenInfos == null || !tokenInfos.Any())
-                            {
-                                //throw new Exception(conveyorLine.DeviceName + "缂撳瓨涓湭鎵惧埌Token缂撳瓨");
-                                continue;
-                            }
-                            var userTokenIds = tokenInfos?.Select(x => x.Token_ID).ToList();
-                            var userIds = tokenInfos?.Select(x => x.UserId).ToList();
-
-                            object obj = new
-                            {
-                                childDeviceCode,
-                                commandAfter = command,
-                            };
-                            _noticeService.LineData(userIds?.FirstOrDefault(), userTokenIds, new { conveyorLine.DeviceName, data = obj });
-
-                            #endregion 璋冪敤浜嬩欢鎬荤嚎閫氱煡鍓嶇
-
-                            childCodeList.Remove(childDeviceCode);
-                        }
                     }
+                    //DateTime ENDdateTime = DateTime.Now;
+                    //Console.WriteLine($"寰幆缁撴潫鏃堕棿{ENDdateTime}");
 
                     #endregion 璺敱鏂瑰紡
                 }
@@ -214,7 +220,7 @@
                 var log = $"鏃堕棿锛氥�恵DateTime.Now}銆戙�恵conveyorLine.DeviceName}銆戞墭鐩樺彿锛氥�恵command.ConveyorLineBarcode}銆戜换鍔″彿锛氥�恵command.ConveyorLineTaskNum}銆戣澶囩紪鐮侊細銆恵childDeviceCode}銆�";
                 ConsoleHelper.WriteSuccessLine(log);
 
-                _noticeService.Logs(userTokenIds, new { conveyorLine.DeviceName, log = log, time = DateTime.Now.ToString("G"), color = "red" });
+                //_noticeService.Logs(userTokenIds, new { conveyorLine.DeviceName, log = log, time = DateTime.Now.ToString("G"), color = "red" });
                 WriteInfo(conveyorLine.DeviceName, log);
 
                 if (task == null)
@@ -223,12 +229,16 @@
                 }
                 else
                 {
-                    var GWTask = _taskRepository.QueryData(x => x.Roadway.Contains("GWSC2") && x.SourceAddress == "1039" && (x.TaskState == (int)TaskInStatusEnum.Line_InExecuting || x.TaskState == (int)TaskInStatusEnum.Line_InFinish)).ToList();
-                    if (GWTask.Count >= 2 && childDeviceCode == "1039" && task.Roadway.Contains("GWSC2"))
+                    if (childDeviceCode == "1039")
                     {
-                        ConsoleHelper.WriteErrorLine($"鏃堕棿锛氥�恵DateTime.Now}銆戞墭鐩樺彿锛氥�恵command.ConveyorLineBarcode}銆戦珮娓╀簩宸插瓨鍦ㄣ�恵GWTask.Count}銆戜釜浠诲姟澶т簬2涓换鍔′笉鍙笅鍙�");
-                        return;
+                        var GWTask = _taskRepository.QueryData(x => x.Roadway.Contains("GWSC2") && x.SourceAddress == "1039" && (x.TaskState == (int)TaskInStatusEnum.Line_InExecuting || x.TaskState == (int)TaskInStatusEnum.Line_InFinish)).ToList();
+                        if (GWTask.Count >= 2 && childDeviceCode == "1039" && task.Roadway.Contains("GWSC2"))
+                        {
+                            ConsoleHelper.WriteErrorLine($"鏃堕棿锛氥�恵DateTime.Now}銆戞墭鐩樺彿锛氥�恵command.ConveyorLineBarcode}銆戦珮娓╀簩宸插瓨鍦ㄣ�恵GWTask.Count}銆戜釜浠诲姟澶т簬2涓换鍔′笉鍙笅鍙�");
+                            return;
+                        }
                     }
+
                     ConveyorLineTaskCommand_After taskCommand = _mapper.Map<ConveyorLineTaskCommand_After>(task);
 
                     bool sendFlag = SendCommand(taskCommand, conveyorLine, childDeviceCode);
@@ -419,7 +429,7 @@
             var log = $"鏃堕棿锛氥�恵DateTime.Now}銆戙�恵conveyorLine.DeviceName}銆戞墭鐩樺彿锛氥�恵command.ConveyorLineBarcode}銆戜换鍔″彿锛氥�恵command.ConveyorLineTaskNum}銆戣澶囩紪鐮侊細銆恵childDeviceCode}銆�";
             ConsoleHelper.WriteSuccessLine(log);
 
-            _noticeService.Logs(userTokenIds, new { conveyorLine.DeviceName, log = log, time = DateTime.Now.ToString("G"), color = "red" });
+            //_noticeService.Logs(userTokenIds, new { conveyorLine.DeviceName, log = log, time = DateTime.Now.ToString("G"), color = "red" });
             WriteInfo(conveyorLine.DeviceName, log);
 
 
diff --git a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/GWTask/RequestInbound.cs b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/GWTask/RequestInbound.cs
index 1d5c18e..5ff0b39 100644
--- a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/GWTask/RequestInbound.cs
+++ b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/GWTask/RequestInbound.cs
@@ -321,12 +321,16 @@
                     var task = _taskService.QueryBarCodeConveyorLineTask(command.ConveyorLineBarcode, childDeviceCode);
                     if (task != null)
                     {
-                        var GWTask = _taskRepository.QueryData(x => x.Roadway.Contains("GWSC2") && x.SourceAddress == "1039" && (x.TaskState == (int)TaskInStatusEnum.Line_InExecuting || x.TaskState == (int)TaskInStatusEnum.Line_InFinish)).ToList();
-                        if (GWTask.Count >= 2 && childDeviceCode == "1039" && task.Roadway.Contains("GWSC2"))
+                        if (childDeviceCode == "1039")
                         {
-                            ConsoleHelper.WriteErrorLine($"鎵樼洏鍙凤細銆恵command.ConveyorLineBarcode}銆戦珮娓╀簩宸插瓨鍦ㄣ�恵GWTask.Count}銆戜釜浠诲姟澶т簬2涓换鍔′笉鍙笅鍙�");
-                            return;
+                            var GWTask = _taskRepository.QueryData(x => x.Roadway.Contains("GWSC2") && x.SourceAddress == "1039" && (x.TaskState == (int)TaskInStatusEnum.Line_InExecuting || x.TaskState == (int)TaskInStatusEnum.Line_InFinish)).ToList();
+                            if (GWTask.Count >= 2 && childDeviceCode == "1039" && task.Roadway.Contains("GWSC2"))
+                            {
+                                ConsoleHelper.WriteErrorLine($"鎵樼洏鍙凤細銆恵command.ConveyorLineBarcode}銆戦珮娓╀簩宸插瓨鍦ㄣ�恵GWTask.Count}銆戜釜浠诲姟澶т簬2涓换鍔′笉鍙笅鍙�");
+                                return;
+                            }
                         }
+
                         ConveyorLineTaskCommand_After taskCommand = _mapper.Map<ConveyorLineTaskCommand_After>(task);
                         //conveyorLine.SendCommand(taskCommand, childDeviceCode);
 
@@ -356,7 +360,7 @@
             {
                 WriteInfo(conveyorLine.DeviceName, $"銆恵conveyorLine.DeviceName}銆戞墭鐩樺彿锛氥�恵command.ConveyorLineBarcode}銆戣姹傜偣浣嶏細銆恵childDeviceCode}銆戝紓甯镐俊鎭�恵ex.Message}銆戝紓甯歌銆恵ex.StackTrace}銆�");
             }
-            
+
         }
 
         /// <summary>
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 ff4ee7c..7948f6c 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
@@ -86,30 +86,30 @@
         {
             if (task.TaskType == (int)TaskOutboundTypeEnum.Outbound)
             {
-                if (task.TaskType == (int)TaskOutboundTypeEnum.Outbound)
+                //if (task.TaskType == (int)TaskOutboundTypeEnum.Outbound)
+                //{
+                if (!task.Roadway.Contains("FR") && stock.ProcessCode != "OCVB")
                 {
-                    if (!task.Roadway.Contains("FR") && stock.ProcessCode != "OCVB")
+                    var agingOutputDto = MapToAgingOutputDto(stock);
+                    content = await _agingInOrOutInputService.GetOCVOutputAsync(agingOutputDto);
+
+                    if (content.Status)
                     {
-                        var agingOutputDto = MapToAgingOutputDto(stock);
-                        content = await _agingInOrOutInputService.GetOCVOutputAsync(agingOutputDto);
+                        var result = JsonConvert.DeserializeObject<BasicResult>(content.Data.ToString());
 
-                        if (content.Status)
+                        if (!result.Success && result.MessageCode == "E10001")
                         {
-                            var result = JsonConvert.DeserializeObject<BasicResult>(content.Data.ToString());
-
-                            if (!result.Success && result.MessageCode == "E10001")
-                            {
-                                await HandleOutBoundError(stock, task);
-                            }
-                        }
-                        else
-                        {
-                            task.Remark = "NG";
-                            ConsoleHelper.WriteErrorLine("MOM閫氭姤鐐硅姱NG");
-                            return content.Error("MOM閫氭姤鐐硅姱NG");
+                            await HandleOutBoundError(stock, task);
                         }
                     }
+                    else
+                    {
+                        task.Remark = "NG";
+                        ConsoleHelper.WriteErrorLine("MOM閫氭姤鐐硅姱NG");
+                        return content.Error("MOM閫氭姤鐐硅姱NG");
+                    }
                 }
+                //}
             }
 
             if (task.Remark == "NG")
@@ -429,8 +429,8 @@
             Console.WriteLine(err.Message.ToString());
             LogFactory.GetLog("浠诲姟瀹屾垚").Error(true, err);
             content.Error(err.Message);
-            task.ErrorMessage= err.Message;
-            task.TaskState=(int)TaskInStatusEnum.SC_InExecuting;
+            task.ErrorMessage = err.Message;
+            task.TaskState = (int)TaskInStatusEnum.SC_InExecuting;
             await BaseDal.Update(task);
         }
         return content;
@@ -617,12 +617,12 @@
         }
         LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "楠岃瘉浠诲姟鏄惁瀛樺湪", JsonConvert.SerializeObject(task));
 
-        
+
         // 楠岃瘉搴撳瓨鏄惁瀛樺湪
         var stock = await _stockInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode);
         if (task.TaskType == (int)TaskOutboundTypeEnum.InToOut)
         {
-            return await CompleteInToOutTaskAsync(task,stock);
+            return await CompleteInToOutTaskAsync(task, stock);
         }
         // 鏍规嵁浠诲姟绫诲瀷璋冪敤鐩稿簲鐨勫畬鎴愪换鍔℃柟娉�
         switch (task.TaskType)
@@ -637,7 +637,7 @@
             case (int)TaskOutboundTypeEnum.OutTray:
             case (int)TaskOutboundTypeEnum.Outbound:
             case (int)TaskOutboundTypeEnum.OutNG:
-            
+
                 LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍑哄簱浠诲姟", "");
                 return await CompleteStackTaskAsync(task, stock);
 
@@ -674,7 +674,7 @@
             var stock = await QueryStockInfo(input.PalletCode);
             if (stock != null)
             {
-                List<string> strings = new List<string>() { "GW","CW","FR"};
+                List<string> strings = new List<string>() { "GW", "CW", "FR" };
                 if (stock.AreaCode.Contains(strings))
                 {
                     return content.Error($"鎵樼洏銆恵stock.PalletCode}銆戝瓨鍦ㄥ簱瀛樹笉鍏佽鍏ュ簱");
@@ -865,8 +865,8 @@
                 var configOne = _configService.GetByConfigKey(CateGoryConst.CONFIG_SYS_InStacker, SysConfigConst.CHInboundEmptyProductLineOne);
                 var configTwo = _configService.GetByConfigKey(CateGoryConst.CONFIG_SYS_InStacker, SysConfigConst.CHInboundEmptyProductLineTwo);
 
-                List<string>  productLineconfigOne = configOne.ConfigValue.Split(',').ToList();
-                List<string>  productLineconfigTwo = configTwo.ConfigValue.Split(',').ToList();
+                List<string> productLineconfigOne = configOne.ConfigValue.Split(',').ToList();
+                List<string> productLineconfigTwo = configTwo.ConfigValue.Split(',').ToList();
 
                 if (productLineconfigOne.Count == 0 && productLineconfigTwo.Count() == 0)
                 {
@@ -885,13 +885,13 @@
                 {
                     ConsoleHelper.WriteErrorLine($"鏈壘鍒皗result.ProductionLine}瀵瑰簲閰嶇疆宸烽亾");
                     return content.Error($"鏈壘鍒皗result.ProductionLine}瀵瑰簲閰嶇疆宸烽亾");
-                }   
+                }
             }
             else
             {
                 strings = stationManagers.Roadway.Split(',').ToList();
             }
-             
+
 
             return await CreateNewTask(input, result.ProductionLine, result.ProcessCode, strings, 1);
         }
@@ -910,8 +910,8 @@
 
     // 鑾峰彇缁勭洏淇℃伅
     private DtBoxingInfo CreateBoxingInfo(ResultTrayCellsStatus result, string palletCode)
-    {  
-         var boxing=_boxingInfoRepository.QueryFirst(x=>x.PalletCode == palletCode);
+    {
+        var boxing = _boxingInfoRepository.QueryFirst(x => x.PalletCode == palletCode);
         if (boxing == null)
         {
             return new DtBoxingInfo
@@ -930,7 +930,8 @@
                 }).ToList()
             };
         }
-        else { 
+        else
+        {
             _boxingInfoRepository.DeleteData(boxing);
             return new DtBoxingInfo
             {
@@ -948,7 +949,7 @@
                 }).ToList()
             };
         }
-       
+
     }
 
     // 鑾峰彇宸ヨ壓鐢宠
@@ -1314,7 +1315,7 @@
             if (stockInfo.AreaCode.Contains("CH"))
             {
                 // 鍒涘缓骞舵坊鍔犱换鍔″埌鏁版嵁搴�
-                if(stockInfo.LocationInfo.RoadwayNo=="CHSC1"|| stockInfo.LocationInfo.RoadwayNo == "CHSC2"|| stockInfo.LocationInfo.RoadwayNo == "CHSC3")
+                if (stockInfo.LocationInfo.RoadwayNo == "CHSC1" || stockInfo.LocationInfo.RoadwayNo == "CHSC2" || stockInfo.LocationInfo.RoadwayNo == "CHSC3")
                 {
                     task = CreateTask(stockInfo, "1020-1", taskType);
                 }
@@ -1322,7 +1323,7 @@
                 {
                     task = CreateTask(stockInfo, "1049-8", taskType);
                 }
-                
+
             }
             else
             {
@@ -2149,7 +2150,7 @@
             ToAddress = await GetRoadWayAsync(process);
         else
             ToAddress = process[0];
-        if(string.IsNullOrEmpty(ToAddress))
+        if (string.IsNullOrEmpty(ToAddress))
         {
             return content.Error("鏃犳硶鑾峰彇鐩爣鍦板潃");
         }

--
Gitblit v1.9.3