最新

zhangchengsong

12 小时以前 f59f3b24814387573b5bca9a9b6c832a3720ee7e

 ÏîÄ¿´úÂë/WIDESEAWCS_Server/WIDESEAWCS_Tasks/StackerCraneJob/CommonStackerCraneJob.cs

@@ -2,6 +2,7 @@
using HslCommunication;
using Microsoft.AspNetCore.Components.Routing;
using Microsoft.AspNetCore.Hosting;
using Newtonsoft.Json;
using OfficeOpenXml.FormulaParsing.Excel.Functions.RefAndLookup;
using Quartz;
using System;
@@ -17,6 +18,7 @@
using System.Text;
using System.Threading.Tasks;
using System.Transactions;
using WIDESEA_Comm.Http;
using WIDESEA_Common.Log;
using WIDESEAWCS_Common.TaskEnum;
using WIDESEAWCS_Core;
@@ -35,6 +37,7 @@
using WIDESEAWCS_QuartzJob.StackerCrane.Enum;
using WIDESEAWCS_TaskInfoService;
using WIDESEAWCS_Tasks.StackerCraneJob;
using static WIDESEAWCS_Model.Models.System.JobError;

namespace WIDESEAWCS_Tasks
{
@@ -53,18 +56,50 @@
            _taskExecuteDetailService = taskExecuteDetailService;
            _taskRepository = taskRepository;
            _routerService = routerService;
            _DtPlatformStationService= dt_PlatformStationService;
            _DtPlatformStationService = dt_PlatformStationService;
        }
        private static readonly Dictionary<string, bool> _deviceLastStatus = new Dictionary<string, bool>();
        public string urlWMSdeverror = WIDESEAWCS_Core.Helper.AppSettings.Configuration["urlWMSdeverror"];


        public Task Execute(IJobExecutionContext context)
        {
            try
            {
                CommonStackerCrane commonStackerCrane = (CommonStackerCrane)context.JobDetail.JobDataMap.Get("JobParams");
                

                if (commonStackerCrane != null)
                {
                WriteLog.Write_Log("堆垛机当前状态信息", $"{commonStackerCrane.DeviceCode}库堆垛机当前状态",
                                                $"堆垛机设备状态地址:【DB105.2.0】,读取的数据：【{commonStackerCrane.StackerCraneAutoStatusDes}】\n" +
                                               $"堆垛机工作模式地址:【DB105.3.0】,读取的数据：【{commonStackerCrane.StackerCraneStatusDes}】\n" +
                                               $"堆垛机作业状态地址:【DB105.22.0】,读取的数据：【{commonStackerCrane.StackerCraneWorkStatusDes}】\n" +
                                               $"堆垛机当前任务执行中地址:【DB105.18.0】,读取的数据：【{commonStackerCrane.CurrentTaskNum}】\n");
                    // èŽ·å–当前状态
                    bool isFaultNow = commonStackerCrane.StackerCraneStatusDes.Equals("故障");
                    string deviceCode = commonStackerCrane.DeviceCode;

                    if (!_deviceLastStatus.ContainsKey(deviceCode))
                    {
                        _deviceLastStatus[deviceCode] = isFaultNow;
                        if (isFaultNow)
                        {
                            SendDevError(commonStackerCrane, "66", "start", ReadStackerFaults(commonStackerCrane));
                        }
                    }
                    else
                    {
                        bool lastStatus = _deviceLastStatus[deviceCode];
                        if (!lastStatus && isFaultNow)
                        {
                            SendDevError(commonStackerCrane, "66", "start", ReadStackerFaults(commonStackerCrane));
                            _deviceLastStatus[deviceCode] = true;
                        }
                        else if (lastStatus && !isFaultNow)
                        {
                            SendDevError(commonStackerCrane, "99", "stop", "堆垛机恢复正常");
                            _deviceLastStatus[deviceCode] = false;
                        }
                    }

                    UpdateHandShake(commonStackerCrane.CurrentTaskNum, commonStackerCrane.StackerCraneWorkStatusDes);
                    //任务完成StackerCraneWorkStatus
@@ -89,20 +124,13 @@
                            WebResponseContent webResponse = _taskService.StackCraneTaskCompleted(commonStackerCrane.CurrentTaskNum, PalletCode);
                            if (webResponse.Status)
                            {
                                WriteLog.Write_Log("堆垛机任务上报完成信息", "堆垛机任务上报完成信息", $"【{commonStackerCrane.DeviceCode}】库堆垛机上报任务号:【{commonStackerCrane.CurrentTaskNum}】完成信号！");
                                Task.Run(() => WriteLog.Write_Log("堆垛机任务上报完成信息", "堆垛机任务上报完成信息", $"【{commonStackerCrane.DeviceCode}】库堆垛机上报任务号:【{commonStackerCrane.CurrentTaskNum}】完成信号！"));

                                bool ddjfk = commonStackerCrane.SetValue(StackerCraneDBName.WorkType, 5);
                            }
                        }
                    }

                    WriteLog.Write_Log("堆垛机当前状态", "堆垛机当前状态信息", $"堆垛机设备地址:【DB105.2.0】,读取的数据：【{commonStackerCrane.StackerCraneAutoStatusDes}】\n" +
                           $"堆垛机工作模式地址:【DB105.3.0】,读取的数据：【{commonStackerCrane.StackerCraneStatusDes}】\n" +
                           $"堆垛机作业状态地址:【DB105.22.0】,读取的数据：【{commonStackerCrane.StackerCraneWorkStatusDes}】\n" +
                           $"堆垛机当前任务执行中地址:【DB105.18.0】,读取的数据：【{commonStackerCrane.CurrentTaskNum}】\n");

                  
                   

                    if (commonStackerCrane.StackerCraneAutoStatusValue == StackerCraneAutoStatus.Automatic && commonStackerCrane.StackerCraneStatusValue == StackerCraneStatus.Normal)
                    {
@@ -140,23 +168,43 @@
        }

        /// <summary>
        /// ä»»åŠ¡å®Œæˆäº‹ä»¶è®¢é˜…的方法
        /// æ•…障上报（改为await调用，修复异步BUG）
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void CommonStackerCrane_StackerCraneTaskCompletedEventHandler(object? sender, WIDESEAWCS_QuartzJob.StackerCrane.StackerCraneTaskCompletedEventArgs e)
        public void SendDevError(CommonStackerCrane crane, string errorcode, string dealType, string errorInfo = "")
        {
            CommonStackerCrane? commonStackerCrane = sender as CommonStackerCrane;
            if (commonStackerCrane != null)
            CommandResult commandResult = new CommandResult();
            try
            {
                if (commonStackerCrane.GetValue<StackerCraneDBName, short>(StackerCraneDBName.WorkType) != 5 && e.TaskNum !=0)
                DeviceErrorRequest deviceErrorRequest = new DeviceErrorRequest
                {
                    //Console.Out.WriteLine("TaskCompleted" + e.TaskNum);
                    //_taskService.StackCraneTaskCompleted(e.TaskNum,);
                    commonStackerCrane.SetValue(StackerCraneDBName.WorkType, 5);
                }
                    devErrorJsons = new List<DeviceErrorInfo>
                    {
                        new DeviceErrorInfo
                        {
                            devuuid = crane.DeviceCode,
                            id = "",
                            errorcode = errorcode,
                            errorinfo = errorInfo,
                            erroraddress = "DB107",
                            warehouse = crane.DeviceCode == "B" ? "ZR17":(crane.DeviceCode == "G"?"ZR18":"ZR16"),
                            remark = dealType == "start" ? "设备异常" : "设备恢复",
                            devname =  $"{crane.DeviceCode}库堆垛机",
                        }
                    },
                    dealType = dealType,
                    psd = "akjfapjfpadaoif",
                };
                
                commandResult = HttpHelper.Post<CommandResult>(urlWMSdeverror, deviceErrorRequest, "设备故障回调");
                WriteLog.Write_Log("同步给上游设备故障信息", "设备故障信息", $"设备id：【{crane.DeviceCode}】，成功", $"设备回调状态：【{dealType}】，异常信息：【{errorInfo}】\n" +
                    $"调用上游返回结果信息：【{commandResult?.ToJsonString() ?? "返回结果为null"}】");
            }
            catch (Exception ex)
            {
                WriteLog.Write_Log("故障上报失败", "错误", ex.ToString());
            }
        }


        /// <summary>
        /// èŽ·å–任务
@@ -183,9 +231,9 @@
                                return taskItem;
                            }
                        }
                        else if (taskItem.TaskType == (int)TaskTypeEnum.Inbound || taskItem.TaskType == (int)TaskTypeEnum.Inventorybound)
                        else if ((InTaskStationIsOccupied(taskItem.SourceAddress, taskItem.Roadway) && taskItem.TaskType == (int)TaskTypeEnum.Inbound) || taskItem.TaskType == (int)TaskTypeEnum.Inventorybound)
                        {
                            InTaskStationIsOccupied(taskItem.SourceAddress, taskItem.Roadway);
                            
                            return taskItem;
                        }
                    }
@@ -209,90 +257,61 @@
        {
            try
            {
                if (Roadway == "C")
                CommonConveyorLine? conveyorLine = null;
                lock (Storage.Devices)
                {
                    IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "1004");
                    if (device == null) return false;
                    CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
                    DeviceProDTO? deviceProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == NextAddress && x.DeviceProParamName == "StationNum");
                    DeviceProDTO? HandShakeprodto = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == NextAddress && x.DeviceProParamName == "HandShake");
                    if (deviceProDTO == null || HandShakeprodto == null) return false;

                    int StationNum = conveyorLine.Communicator.Read<ushort>(deviceProDTO.DeviceProAddress);
                    int HandShake = conveyorLine.Communicator.Read<ushort>(HandShakeprodto.DeviceProAddress);
                     conveyorLine.Communicator.Write<short>(HandShakeprodto.DeviceProAddress, 1);

                    WriteLog.Write_Log("出库库口状态信息", "出库库口状态信息", $"库口是【{NextAddress}】，申请状态地址：【{HandShakeprodto.DeviceProAddress}】,读取的数据：【{HandShake}】\n" +
                         $"库口是否有货状态地址：【{deviceProDTO.DeviceProAddress}】，读取的数据【{StationNum}】");
                    if (StationNum == 0 && HandShake == 0 && Roadway == "C")
                    {
                        return true;
                    }
                    string deviceCode = Roadway == "C" ? "1004" : "1003";
                    conveyorLine = Storage.Devices.FirstOrDefault(x => x.DeviceCode == deviceCode) as CommonConveyorLine;
                }
                else
                {
                    IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "1003");
                    if (device == null) return false;
                    CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
                    DeviceProDTO? deviceProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == NextAddress && x.DeviceProParamName == "StationNum");
                    DeviceProDTO? HandShakeprodto = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == NextAddress && x.DeviceProParamName == "HandShake");
                    if (deviceProDTO == null || HandShakeprodto == null) return false;
                if (conveyorLine == null) return false;

                    int StationNum = conveyorLine.Communicator.Read<ushort>(deviceProDTO.DeviceProAddress);
                    int HandShake = conveyorLine.Communicator.Read<ushort>(HandShakeprodto.DeviceProAddress);
                    WriteLog.Write_Log("出库库口状态信息", "出库库口状态信息", $"库口是【{NextAddress}】，申请状态地址：【{HandShakeprodto.DeviceProAddress}】,读取的数据：【{HandShake}】\n" +
                        $"库口是否有货状态地址：【{deviceProDTO.DeviceProAddress}】，读取的数据【{StationNum}】");
                DeviceProDTO? deviceProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == NextAddress && x.DeviceProParamName == "StationNum");
                DeviceProDTO? HandShakeprodto = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == NextAddress && x.DeviceProParamName == "HandShake");
                if (deviceProDTO == null || HandShakeprodto == null) return false;

                    if ((StationNum == 1 && HandShake == 0 && Roadway == "B") || (StationNum == 0 && HandShake == 0 && Roadway != "B"))
                    {
                        return true;
                    }
                }
                int StationNum = conveyorLine.Communicator.Read<ushort>(deviceProDTO.DeviceProAddress);
                int HandShake = conveyorLine.Communicator.Read<ushort>(HandShakeprodto.DeviceProAddress);

                WriteLog.Write_Log("出库库口状态信息", "出库库口状态信息", $"库口是【{NextAddress}】，申请状态地址：【{HandShakeprodto.DeviceProAddress}】,读取的数据：【{HandShake}】\n库口是否有货状态地址：【{deviceProDTO.DeviceProAddress}】，读取的数据【{StationNum}】");
                  if (Roadway == "C" || Roadway == "G") return StationNum == 0 && HandShake == 0;
                return (StationNum == 1 && HandShake == 0 && Roadway == "B");
            }
            catch (Exception ex)
            {
                Console.WriteLine("读取站台信息错误："+ex.Message);
              Console.WriteLine("读取站台信息错误：" + ex.Message);
                return false;
            }

            return false;
        }
        /// <summary>
        /// å…¥åº“任务库口有货无货状态
        /// </summary>
        private void InTaskStationIsOccupied(string SourceAddress, string Roadway)
        public bool InTaskStationIsOccupied(string SourceAddress, string Roadway)
        {
            try
            {
                if (Roadway == "C")
                {
                    IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "1004");
                    CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
                    DeviceProDTO? deviceProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == SourceAddress && x.DeviceProParamName == "StationNum");
                    DeviceProDTO? HandShakeprodto = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == SourceAddress && x.DeviceProParamName == "HandShake");
 
                    int StationNum = conveyorLine.Communicator.Read<ushort>(deviceProDTO.DeviceProAddress);
                    int HandShake = conveyorLine.Communicator.Read<ushort>(HandShakeprodto.DeviceProAddress);
                    WriteLog.Write_Log("入库库口状态信息", "入库库口状态信息", $"库口是【{SourceAddress}】，申请状态地址：【{HandShakeprodto.DeviceProAddress}】,读取的数据：【{HandShake}】\n" +
                        $"库口是否有货状态地址：【{deviceProDTO.DeviceProAddress}】，读取的数据【{StationNum}】");
                }
                else
                {
                    IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "1003");
                    CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
                    DeviceProDTO? deviceProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == SourceAddress && x.DeviceProParamName == "StationNum");
                    DeviceProDTO? HandShakeprodto = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == SourceAddress && x.DeviceProParamName == "HandShake");

                    int StationNum = conveyorLine.Communicator.Read<ushort>(deviceProDTO.DeviceProAddress);
                    int HandShake = conveyorLine.Communicator.Read<ushort>(HandShakeprodto.DeviceProAddress);
                    WriteLog.Write_Log("入库库口状态信息", "入库库口状态信息", $"库口是【{SourceAddress}】，申请状态地址：【{HandShakeprodto.DeviceProAddress}】,读取的数据：【{HandShake}】\n" +
                        $"库口是否有货状态地址：【{deviceProDTO.DeviceProAddress}】，读取的数据【{StationNum}】");
                CommonConveyorLine? conveyorLine = null;
                lock (Storage.Devices)
                {
                    string deviceCode = Roadway == "C" ? "1004" : "1003";
                    conveyorLine = Storage.Devices.FirstOrDefault(x => x.DeviceCode == deviceCode) as CommonConveyorLine;
                }
                if (conveyorLine == null) return false;

                DeviceProDTO? deviceProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == SourceAddress && x.DeviceProParamName == "StationNum");
                DeviceProDTO? HandShakeprodto = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == SourceAddress && x.DeviceProParamName == "HandShake");
                if (deviceProDTO == null || HandShakeprodto == null) return false;

                int StationNum = conveyorLine.Communicator.Read<ushort>(deviceProDTO.DeviceProAddress);
                int HandShake = conveyorLine.Communicator.Read<ushort>(HandShakeprodto.DeviceProAddress);
                WriteLog.Write_Log("入库库口状态信息", "入库库口状态信息", $"库口是【{SourceAddress}】，申请状态地址：【{HandShakeprodto.DeviceProAddress}】,读取的数据：【{HandShake}】\n库口是否有货状态地址：【{deviceProDTO.DeviceProAddress}】，读取的数据【{StationNum}】");
                return (StationNum == 1 && HandShake == 0) ? true : false;
            }
            catch (Exception ex)
            {
                Console.WriteLine("读取站台信息错误：" + ex.Message);
               Console.WriteLine("读取站台信息错误：" + ex.Message);
                return false;
            }

        }

        /// <summary>
@@ -421,7 +440,7 @@
                {

                    //数据配置错误
                    _taskService.UpdateTaskExceptionMessage(task.TaskNum, $"移库任务起点错误，起点：【{task.CurrentAddress}】");
                    _taskService.UpdateTaskExceptionMessage(task.TaskNum, $"盘点任务起点错误，起点：【{task.CurrentAddress}】");
                    return null;
                }

@@ -451,54 +470,62 @@
        /// <param name="stackerCraneWorkStatusDes"></param>
        public void UpdateHandShake(int taskNum, string stackerCraneWorkStatusDes)
        {
            // 1. æŸ¥è¯¢ä»»åŠ¡ï¼Œç©ºå€¼ç›´æŽ¥è¿”回
            Dt_Task? dtTask = _taskRepository.QueryFirst(x => x.TaskNum == taskNum);
            if (dtTask == null) return;

            // 2. å®šä¹‰å›ºå®šåœ°å€
            string[] targetAddresses = { "G03", "G04", "C02", "C01" };

            // 3. æ¡ä»¶åˆ¤æ–­ + ç¡®å®šå†™å…¥å€¼
            short writeValue = -1;
            if (dtTask.TaskType == 100 && targetAddresses.Contains(dtTask.TargetAddress))
            {
                writeValue = stackerCraneWorkStatusDes switch
                try
                {
                    "放货中" => 1,
                    "任务完成" => 0,
                    _ => -1
                };
            }
                    var dtTask = _taskRepository.QueryFirst(x => x.TaskNum == taskNum);
                    if (dtTask == null) return;

            // 4. èŽ·å–设备编码
            string deviceCode = dtTask.CurrentAddress.StartsWith("C") ? "1004" : "1003";
                    string[] targets = { "G02", "G03", "G04", "C02", "C01" };
                    if (dtTask.TaskType != 100 || !targets.Contains(dtTask.TargetAddress)) return;

            // 5. èŽ·å–设备，空值直接返回
            IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == deviceCode);
            if (device != null && writeValue != -1)
            {
                CommonConveyorLine? conveyorLine = (CommonConveyorLine)device;
                    short writeValue = stackerCraneWorkStatusDes switch
                    {
                        "放货中" => 1,
                        "任务完成" => 0,
                        _ => -1
                    };
                    if (writeValue == -1) return;

                // 6. èŽ·å–握手点位，空值直接返回
                DeviceProDTO? handShake = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == dtTask.TargetAddress && x.DeviceProParamName == "HandShake");
                if (handShake == null)
                {
                    WriteLog.Write_Log("出库库口光栅状态错误信息", "出库库口光栅状态错误信息", $"WCS未找到库口信息是【{dtTask.TargetAddress}】，任务号：【{dtTask.TaskNum}】,堆垛机作业状态：【{stackerCraneWorkStatusDes}】");
                    return;
                    CommonConveyorLine? conveyorLine = null;
                    lock (Storage.Devices)
                    {
                        string deviceCode = dtTask.CurrentAddress.StartsWith("C") ? "1004" : "1003";
                        conveyorLine = Storage.Devices.FirstOrDefault(x => x.DeviceCode == deviceCode) as CommonConveyorLine;
                    }
                    if (conveyorLine == null) return;

                    var handShake = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == dtTask.TargetAddress && x.DeviceProParamName == "HandShake");
                    if (handShake == null) return;

                    conveyorLine.Communicator.Write<short>(handShake.DeviceProAddress, writeValue);
                }
                    // 7. å†™å…¥å€¼
                 conveyorLine.Communicator.Write<short>(handShake.DeviceProAddress, writeValue);
                WriteLog.Write_Log("出库库口光栅状态正常信息", "出库库口光栅状态正常信息", $"库口是【{dtTask.TargetAddress}】，申请状态地址：【{handShake.DeviceProAddress}】,读取的数据：【{conveyorLine.Communicator.Read<ushort>(handShake.DeviceProAddress)}】\n" +
                 $"任务号：【{dtTask.TaskNum}】,堆垛机作业状态：【{stackerCraneWorkStatusDes}】");
                return;
            }
            else
            {
                WriteLog.Write_Log("出库库口光栅状态错误信息", "出库库口光栅状态错误信息", $"库口是【{dtTask.TargetAddress}】，任务号：【{dtTask.TaskNum}】,堆垛机作业状态：【{stackerCraneWorkStatusDes}】");
                return;
            }
           
                catch
                { }
        }

        /// <summary>
        /// è¯»å–故障（优化GC）
        /// </summary>
        public string ReadStackerFaults(CommonStackerCrane crane)
        {
            try
            {
                foreach (StackerFault fault in Enum.GetValues(typeof(StackerFault)))
                {
                    try
                    {
                        bool isFault = crane.Communicator.Read<bool>(fault.ToPlcAddress());
                        if (isFault)
                            return fault.GetDesc();
                    }
                    catch { }
                }
            }
            catch (Exception ex)
            {
                WriteLog.Write_Log("DB107故障读取异常", "错误", ex.ToString());
            }
            return string.Empty;
        }
    }
}