From 39531cf0ea52494fe56b8734afa552db32b7a164 Mon Sep 17 00:00:00 2001
From: yanjinhui <3306209981@qq.com>
Date: 星期三, 15 四月 2026 14:27:07 +0800
Subject: [PATCH] Merge branch 'master' of http://115.159.85.185:8098/r/RuiShengZhiNeng/GaoPuLiTiKu

---
 代码管理/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TSJExtend.cs |  318 +++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 318 insertions(+), 0 deletions(-)

diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TSJExtend.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TSJExtend.cs"
new file mode 100644
index 0000000..fb18f0c
--- /dev/null
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TSJExtend.cs"
@@ -0,0 +1,318 @@
+锘縰sing System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using WIDESEAWCS_Common.TaskEnum;
+using WIDESEAWCS_Common;
+using WIDESEAWCS_Model.Models;
+using WIDESEAWCS_QuartzJob;
+using WIDESEAWCS_Core.Helper;
+using WIDESEAWCS_Common.LocationEnum;
+using SixLabors.ImageSharp;
+using Autofac.Core;
+
+namespace WIDESEAWCS_Tasks
+{
+    public partial class TSJJob
+    {
+        /// <summary>
+        /// 娴峰悍缁х画鎵ц浠诲姟
+        /// </summary>
+        /// <param name="device"></param>
+        public void HKConexecutTask(OtherDevice device)
+        {
+
+            List<Dt_Task> Uptasks = new List<Dt_Task>();
+            //鏌ヨ鎵�鏈変换鍔$被鍨嬩负3,4妤肩殑鍏ュ簱浠诲姟绫诲瀷涓斾换鍔$姸鎬佷负AGV_WaitToExecute鐨勪换鍔� 
+            var taskList = _taskService.Repository.QueryData(x => x.TaskState == TaskStatusEnum.AGV_WaitToExecute.ObjToInt());
+            //浠诲姟鐨勭洰鏍囧湴鍧�瀵逛簬绔欏彴鍙凤紱
+            foreach (var task in taskList)
+            {
+                //鍏堟鏌ヨ澶囩姸鎬�
+                if (device.GetValue<HoistEnum, short>(HoistEnum.EquipmentStatus, "TSJ") == 2)
+                {
+                    if (task.ExceptionMessage == "鎻愬崌鏈鸿澶囨晠闅�")
+                    {
+                        continue;
+                    }
+                    task.ExceptionMessage = "鎻愬崌鏈鸿澶囨晠闅�";
+                    Uptasks.Add(task);
+                    continue;
+                    //throw new Exception("璁惧鏁呴殰");
+                }
+                if (task.TaskType == TaskTypeEnum.RK3F.ObjToInt() || task.TaskType == TaskTypeEnum.CHUKU1.ObjToInt() || task.TaskType == TaskTypeEnum.F04.ObjToInt())
+                {
+                    if (task.TaskType == TaskTypeEnum.RK3F.ObjToInt())
+                    {
+                        //鍒ゆ柇3妤煎叆搴撶鍙锋湁鏃�
+                        if (device.GetValue<HoistEnum, short>(HoistEnum.OutboundInplace, task.TargetAddress) != 2)
+                        {
+                            if (task.ExceptionMessage == "3妤煎叆搴撶鍙锋湁璐э紝璇峰厛澶勭悊")
+                            {
+                                continue;
+                            }
+                            task.ExceptionMessage = "3妤煎叆搴撶鍙锋湁璐э紝璇峰厛澶勭悊";
+                            Uptasks.Add(task);
+                            continue;
+                        }
+                    }
+                    else
+                    {
+                        if (device.GetValue<HoistEnum, short>(HoistEnum.ReturnbinAvailable, task.TargetAddress) != 2)
+                        {
+                            if (task.ExceptionMessage != "4F鎻愬崌鏈哄叆鍙f湁璐�")
+                            {
+                                task.ExceptionMessage = "4F鎻愬崌鏈哄叆鍙f湁璐�";
+                                Uptasks.Add(task);
+                            }
+                            continue;
+                        }
+                    }
+
+
+                    //鐒跺悗璋冪敤杈撻�佺嚎鎺ュ彛锛岄�氱煡杈撻�佺嚎鏈夋枡绠遍渶瑕佸叆搴擄紝浠诲姟涓捐鎵ц
+                    var result = _taskService.Hikvisiontaskscontinue(task.WMSTaskNum);
+                    if (result.Status == false)
+                    {
+                        if (task.ExceptionMessage != result.Message)
+                        {
+                            task.ExceptionMessage = result.Message;
+                            Uptasks.Add(task);
+                        }
+                        continue;
+                    }
+                    task.TaskState = (int)TaskStatusEnum.AGV_ToExecute;
+                    task.ExceptionMessage = "";
+                    Uptasks.Add(task);
+
+                    //杩欓噷浠诲姟鍙樻垚浜咰heckPalletCodeing
+
+                }
+                else if (task.TaskType == TaskTypeEnum.CK3F.ObjToInt() || task.TaskType == TaskTypeEnum.Q1TSJ4.ObjToInt() || task.TaskType == TaskTypeEnum.F03.ObjToInt()) //鍑哄簱
+                {
+                    ////鍑哄簱鏂欑缂撳瓨鏁伴噺(杩欎釜鏄簱鍖烘煡璇㈢殑鏃跺�欒鏌ヤ竴涓嬶紝杩旂粰wms)
+                    //if (device.GetValue<HoistEnum, short>(HoistEnum.Outboundmaterialbox, "TSJ") == 0) throw new Exception("娌℃湁鍑哄簱鏂欑缂撳瓨鏁伴噺涓虹┖");
+
+                    if (task.TaskType == TaskTypeEnum.CK3F.ObjToInt())
+                    {
+                        //璇诲彇3妤煎嚭搴撴枡绠卞埌浣�
+                        if (device.GetValue<HoistEnum, short>(HoistEnum.SOutboundmaterialbox, task.SourceAddress) != 1)
+                        {
+                            if (task.ExceptionMessage != "3妤兼彁鍗囨満鍑哄彛鍏夌數鍙嶉鏃犺揣")
+                            {
+                                task.ExceptionMessage = "3妤兼彁鍗囨満鍑哄彛鍏夌數鍙嶉鏃犺揣";
+                                Uptasks.Add(task);
+                            }
+                            continue;
+                        }
+                    }
+                    else
+                    {
+                        if (device.GetValue<HoistEnum, short>(HoistEnum.FOutboundmaterialbox, task.SourceAddress) != 1)
+                        {
+                            if (task.ExceptionMessage != "4妤兼彁鍗囨満鍑哄彛鍏夌數鍙嶉鏃犺揣")
+                            {
+                                task.ExceptionMessage = "4妤兼彁鍗囨満鍑哄彛鍏夌數鍙嶉鏃犺揣";
+                                Uptasks.Add(task);
+                            }
+                            continue;
+                        }
+
+                        if (device.GetValue<HoistEnum, short>(HoistEnum.ROutScanningCompletionSignal, task.SourceAddress) != 1)
+                        {
+                            if (task.ExceptionMessage != "4妤兼彁鍗囨満鍑哄彛鎵爜瀹屾垚淇″彿娌℃湁瀹屾垚")
+                            {
+                                task.ExceptionMessage = "4妤兼彁鍗囨満鍑哄彛鎵爜瀹屾垚淇″彿娌℃湁瀹屾垚";
+                                Uptasks.Add(task);
+                            }
+                            continue;
+                        }
+                    }
+                    //鐒跺悗璋冪敤杈撻�佺嚎鎺ュ彛锛岄�氱煡杈撻�佺嚎鏈夋枡绠遍渶瑕佸叆搴擄紝浠诲姟涓捐鎵ц
+                    var result = _taskService.Hikvisiontaskscontinue(task.WMSTaskNum);
+                    if (result.Status == false)
+                    {
+                        if (task.ExceptionMessage != result.Message)
+                        {
+                            task.ExceptionMessage = result.Message;
+                            Uptasks.Add(task);
+                        }
+                        continue;
+                    }
+                    task.TaskState = (int)TaskStatusEnum.AGV_ToExecute;
+                    task.ExceptionMessage = "";
+                    Uptasks.Add(task);
+                }
+            }
+            if (Uptasks.Count > 0)
+            {
+                _taskService.UpdateData(Uptasks);
+            }
+
+
+
+        }
+
+
+
+        /// <summary>
+        /// 鎵樼洏鍙风‘璁や腑
+        /// </summary>
+        /// <param name="device"></param>
+        public void PalletNumConfirmation(OtherDevice device)
+        {
+            #region 鎵樼洏鍙风‘璁や腑
+            //鏌ユ壘涓夋ゼ鍏ュ簱浠诲姟鐘舵�佷负CheckPalletCodeing鐨勪换鍔℃墭鐩樺彿纭涓�
+            var RK3FTask = _taskService.Repository.QueryFirst(x => x.TaskType == TaskTypeEnum.RK3F.ObjToInt() && x.TaskState == (int)TaskStatusEnum.CheckPalletCodeing);
+            if (RK3FTask != null)
+            {
+                if (device.GetValue<HoistEnum, short>(HoistEnum.RInScanningCompletionSignal, RK3FTask.TargetAddress) != 1)
+                {
+                    RK3FTask.ExceptionMessage = "3妤兼壂鐮佸畬鎴愪俊鍙锋病鏈夊畬鎴�";
+                    _taskService.UpdateData(RK3FTask);
+                }
+                else //瀹屾垚灏辨妸浠诲姟鐘舵�佹敼鎴愭墭鐩樺彿纭瀹屾垚
+                {
+                    //妫�鏌�3妤煎叆搴撶鍙锋槸澶氬皯锛岀劧鍚庝紶缁檞ms
+                    var BinNumber = device.GetValue<HoistEnum, string>(HoistEnum.Inboxnumber, RK3FTask.TargetAddress);
+                    if (!string.IsNullOrEmpty(BinNumber))
+                    {
+                        BinNumber = BinNumber.TrimEnd('\0').Substring(2);
+                        //鏍规嵁璇诲埌鐨勭鍙疯繘琛屾枡绠辨楠岋紝妫�楠岄�氳繃灏辫Е鍙戣鐮佸櫒璇诲彇锛屽鏋滀笉閫氳繃灏辨姏鍑哄紓甯�
+                        var Verification = _taskService.MaterialBoxInspection(RK3FTask.WMSTaskNum, BinNumber);
+                        if (!Verification.Status)
+                        {
+                            if (RK3FTask.ExceptionMessage != Verification.Message)
+                            {
+                                RK3FTask.ExceptionMessage = Verification.Message;
+                                _taskService.UpdateData(RK3FTask);
+                            }
+                        }
+                        else
+                        {
+
+                            //濡傛灉璐ㄦ閫氳繃灏变笉鏀瑰彉RK3FTask.TargetAddress鐨勫�硷紝
+                            if (!string.IsNullOrEmpty(Verification.Message))
+                            {
+                                //瀵绘壘骞冲簱璐т綅
+                                var Location = _stationInfoService.Repository.QueryFirst(x => x.StationRegion == Verification.Message.ObjToInt() && x.StationStatus == (int)LocationStatusEnum.Free && x.FloorNumber == "CC" && x.IsOccupied == (int)LocationStatusEnum.Free);
+                                //杩欓噷瑕佸垽鏂�
+                                if (Location == null)
+                                {
+                                    RK3FTask.ExceptionMessage = "$鏈壘鍒皗Verification.Message}鍖哄煙鐨勮揣浣峽Location}";
+                                }
+                                RK3FTask.CurrentAddress = RK3FTask.TargetAddress;
+                                RK3FTask.NextAddress = Location.StationCode;
+                                RK3FTask.TargetAddress = Location.StationCode;
+                                _taskService.UpdateData(RK3FTask);
+                            }
+                            //璋冪敤娴峰悍杩涜鎵ц瀹屾垚鎺ュ彛
+                            var result = _taskService.Hikvisiontaskscontinue(RK3FTask.WMSTaskNum, RK3FTask.NextAddress);
+                            if (result.Status)
+                            {
+                                RK3FTask.ExceptionMessage = "";
+                                RK3FTask.TaskState = (int)TaskStatusEnum.CheckPalletCodeFinish;
+                                _taskService.UpdateData(RK3FTask);
+                            }
+                            else
+                            {
+                                if (RK3FTask.ExceptionMessage != result.Message)
+                                {
+                                    RK3FTask.ExceptionMessage = result.Message;
+                                    _taskService.UpdateData(RK3FTask);
+                                }
+                            }
+                        }
+                    }
+                }
+            }
+            #endregion
+        }
+
+
+        /// <summary>
+        /// 4F鎻愬崌鏈哄嚭鍙f墭鐩樺彿涓婃姤WMS
+        /// </summary>
+        /// <param name="device"></param>
+
+        public void PalletReportingToWMS(OtherDevice device)
+        {
+            #region 4F鎻愬崌鏈哄嚭鍙f墭鐩樺彿涓婃姤WMS
+            var Address = "TSJC4F";
+            if (device.GetValue<HoistEnum, short>(HoistEnum.ROutScanningCompletionSignal, Address) == 1)
+            {
+                var BinNumber = device.GetValue<HoistEnum, string>(HoistEnum.Emptycontainernumber, Address);
+                if (!string.IsNullOrEmpty(BinNumber))
+                {
+                    BinNumber = BinNumber.TrimEnd('\0').Substring(2);
+                    _taskService.InboundElevatorExit(Address, BinNumber);
+                }
+            }
+            #endregion
+        }
+
+
+        /// <summary>
+        /// 鎻愬崌鏈烘姤璀�
+        /// </summary>
+        /// <param name="device"></param>
+        public void TSJAlarm(OtherDevice device)
+        {
+
+            var alarmPoints = new Dictionary<HoistEnum, string>{
+            { HoistEnum.EquipmentStatus, "璁惧鐘舵��" },
+            { HoistEnum.R_ElectricDrumA301, "鐢靛姩婊氱瓛A301鎶ヨ" },
+            { HoistEnum.R_ElectricDrumA302, "鐢靛姩婊氱瓛A302鎶ヨ" },
+            { HoistEnum.R_ElectricDrumA303, "鐢靛姩婊氱瓛A303鎶ヨ" },
+            { HoistEnum.R_ElectricDrumA304, "鐢靛姩婊氱瓛A304鎶ヨ" },
+            { HoistEnum.R_ElectricDrumA305, "鐢靛姩婊氱瓛A305鎶ヨ" },
+            { HoistEnum.R_ElectricDrumA306, "鐢靛姩婊氱瓛A306鎶ヨ" },
+            { HoistEnum.R_ElectricDrumA307, "鐢靛姩婊氱瓛A307鎶ヨ" },
+            { HoistEnum.R_ElectricDrumT001, "鐢靛姩婊氱瓛T001鎶ヨ" },
+            { HoistEnum.R_InverterAlarm, "鍙橀鍣ㄦ姤璀�" },
+            { HoistEnum.R_ElectricDrumA401, "鐢靛姩婊氱瓛A401鎶ヨ" },
+            { HoistEnum.R_ElectricDrumA402, "鐢靛姩婊氱瓛A402鎶ヨ" },
+            { HoistEnum.R_ElectricDrumA403, "鐢靛姩婊氱瓛A403鎶ヨ" },
+            { HoistEnum.R_ElectricDrumA404, "鐢靛姩婊氱瓛A404鎶ヨ" },
+            { HoistEnum.R_ElectricDrumA405, "鐢靛姩婊氱瓛A405鎶ヨ" },
+            { HoistEnum.R_ElectricDrumA406, "鐢靛姩婊氱瓛A406鎶ヨ" },
+            { HoistEnum.R_ElectricDrumA407, "鐢靛姩婊氱瓛A407鎶ヨ" },
+            { HoistEnum.R_ElectricDrumT002, "鎻愬崌鏈�2鍙橀鍣ㄦ姤璀�" },
+            { HoistEnum.R_UpperlimitAlarm1, "涓婇檺浣嶆姤璀�1" },
+            { HoistEnum.R_LowerlimitAlarm1, "涓嬮檺浣嶆姤璀�1" },
+            { HoistEnum.R_UpperlimitAlarm2, "涓婇檺浣嶆姤璀�2" },
+            { HoistEnum.R_LowerlimitAlarm2, "涓嬮檺浣嶆姤璀�2" },
+            { HoistEnum.R_ScancodeError1, "璇荤爜鍣�3妤兼壂鐮佸紓甯�" },
+            { HoistEnum.R_ScancodeError2, "璇荤爜鍣�4妤兼壂鐮佸紓甯�" },
+            { HoistEnum.R_EmergencSytop1, "鎬ュ仠1" },
+            { HoistEnum.R_EmergencSytop2, "鎬ュ仠2" },
+            { HoistEnum.R_TSJEmergencSytop1, "鎻愬崌鏈烘�ュ仠1" },
+            { HoistEnum.R_TSJEmergencSytop2, "鎻愬崌鏈烘�ュ仠2" },
+            { HoistEnum.R_DrumAlarmT002, "鐢垫粴绛�4妤兼姤璀002" },
+            { HoistEnum.R_TSJSpare1, "澶囩敤鎶ヨ1" },
+            { HoistEnum.R_TSJSpare2, "澶囩敤鎶ヨ2" }
+        };
+            var Address = "TSJ";
+
+
+            foreach (var point in alarmPoints)
+            {
+                    // 璇诲彇PLC鍊硷紙闇�瑕佹牴鎹疄闄匒PI璋冩暣锛�
+                    bool isAlarming = device.GetValue<HoistEnum, bool>(point.Key,Address);
+                    // 鎴栬�� device.ReadBool(point.Key);
+
+                    if (isAlarming)
+                    {
+                        // 鏈夋姤璀︼紝鍙戦�佺粰WMS
+                        //SendAlarmToWMS(device, point.Key, point.Value);
+                    }
+                
+            }
+        }
+
+
+    }
+
+    }
+

--
Gitblit v1.9.3