龙得利纸质行业立库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liulijun
18 小时以前 5270308151082506e0e6df2c72d278d2976ec860 
 ÏîÄ¿´úÂë/WCS/WCSServices/WIDESEAWCS_Tasks/Ô­ÁÏ¿â/StackerCraneJob_YLSC2.cs


@@ -1,4 +1,6 @@


using Microsoft.AspNetCore.Components.Routing;


using HslCommunication.WebSocket;


using Microsoft.AspNetCore.Components.Routing;


using Newtonsoft.Json;


using Quartz;


using System;


using System.Collections.Generic;


@@ -7,25 +9,30 @@


using System.Text;


using System.Threading.Tasks;


using WIDESEAWCS_Common.TaskEnum;


using WIDESEAWCS_Core;


using WIDESEAWCS_Core.Enums;


using WIDESEAWCS_Core.Helper;


using WIDESEAWCS_DTO.Equipment;


using WIDESEAWCS_IBasicInfoRepository;


using WIDESEAWCS_ITaskInfoRepository;


using WIDESEAWCS_ITaskInfoService;


using WIDESEAWCS_Model.Models;


using WIDESEAWCS_QuartzJob;


using WIDESEAWCS_QuartzJob.DeviceBase;


using WIDESEAWCS_QuartzJob.DTO;


using WIDESEAWCS_QuartzJob.Models;


using WIDESEAWCS_QuartzJob.Repository;


using WIDESEAWCS_QuartzJob.Service;


using WIDESEAWCS_QuartzJob.StackerCrane;


using WIDESEAWCS_QuartzJob.StackerCrane.Enum;


using WIDESEAWCS_Tasks.StackerCraneJob;


using WIDESEAWCS_Tasks;


using WIDESEAWCS_Core;


using SqlSugar.Extensions;


using WIDESEAWCS_Tasks.ConveyorLineJob;


using WIDESEAWCS_QuartzJob.Repository;


using WIDESEAWCS_QuartzJob.DTO;


using WIDESEAWCS_QuartzJob.StackerCrane;


using WIDESEAWCS_Tasks.StackerCraneJob;


using WIDESEAWCS_DTO.TaskInfo;


using WIDESEAWCS_Tasks.原料库;




namespace WIDESEAWCS_Tasks


{


@@ -38,8 +45,9 @@


        private readonly IRouterService _routerService;


        private readonly IRouterRepository _routerRepository;


        private readonly IStationMangerRepository _stationMangerRepository;


        private WebSocketServer _webSocketServer;




        public StackerCraneJob_YLSC2(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, IStationMangerRepository stationMangerRepository, IRouterRepository routerRepository)


        public StackerCraneJob_YLSC2(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, ITaskRepository taskRepository, IRouterService routerService, IStationMangerRepository stationMangerRepository, IRouterRepository routerRepository, WebSocketServer webSocketServer)


        {


            _taskService = taskService;


            _taskExecuteDetailService = taskExecuteDetailService;


@@ -47,6 +55,7 @@


            _routerService = routerService;


            _stationMangerRepository = stationMangerRepository;


            _routerRepository = routerRepository;


            _webSocketServer = webSocketServer;


        }




        public Task Execute(IJobExecutionContext context)


@@ -106,6 +115,63 @@


                            }


                        }


                    }


                    // è®¾ç½®è®¾å¤‡ç¼–号，前端用于识别堆垛机


                    YL_DB yL_DB = new YL_DB();


                    yL_DB.R_PP_Status = commonStackerCrane.DeviceCode;


                    // è®¾ç½®å †åž›æœºçŠ¶æ€


                    yL_DB.YL_Status = commonStackerCrane.StackerCraneStatusValue switch


                    {


                        StackerCraneStatus.Fault => 0,


                        StackerCraneStatus.Normal => 1,


                        StackerCraneStatus.EmergencyStop => 2,


                        StackerCraneStatus.Unkonw => 3,


                    };


                    yL_DB.YL_AutoStatus = commonStackerCrane.StackerCraneAutoStatusValue switch


                    {


                        StackerCraneAutoStatus.SemiAutomatic => 1,


                        StackerCraneAutoStatus.Maintenance => 2,


                        StackerCraneAutoStatus.Automatic => 3,


                        StackerCraneAutoStatus.Manual => 4,


                        StackerCraneAutoStatus.Unkonw => 5,


                    };


                    yL_DB.YL_WorkStatus = commonStackerCrane.StackerCraneWorkStatusValue switch


                    {


                        StackerCraneWorkStatus.Standby => 1,


                        StackerCraneWorkStatus.PickUpCompleted => 2,


                        StackerCraneWorkStatus.PickUp => 3,


                        StackerCraneWorkStatus.Putting => 5,


                        StackerCraneWorkStatus.WorkCompleted => 9,


                    };


                    yL_DB.YL_TaskNum = commonStackerCrane.CurrentTaskNum;


                    yL_DB.YL_WorkType = commonStackerCrane.GetValue<StackerCraneDBName, short>(StackerCraneDBName.WorkType);


                    yL_DB.YL_Row = commonStackerCrane.Communicator.Read<short>("DB1000.46");


                    yL_DB.YL_Column = commonStackerCrane.Communicator.Read<short>("DB1000.48.0");


                    yL_DB.YL_Layer = commonStackerCrane.Communicator.Read<short>("DB1000.50.0");


                    // è¯»å–报警信息


                    short stackerError2 = commonStackerCrane.Communicator.Read<short>("DB1000.54.0");


                    yL_DB.StackerAlarm = stackerError2 == 0 ? "无" : $"报警代码: {stackerError2}";


                    // åºåˆ—化并发送数据


                    string ylDB = JsonConvert.SerializeObject(yL_DB);


                    _webSocketServer.PublishAllClientPayload(ylDB);




                    #region è°ƒç”¨äº‹ä»¶æ€»çº¿é€šçŸ¥å‰ç«¯




                    EquipmentDTO equipmentDTO = new EquipmentDTO();


                    object obj = new


                    {


                        commonStackerCrane.DeviceName,


                        commonStackerCrane.DeviceCode,


                        StackerCraneAutoStatus.Automatic,


                        StackerCraneStatus.Normal,


                        StackerCraneWorkStatus.Standby,


                        TaskNum = commonStackerCrane.CurrentTaskNum,


                        WorkType = commonStackerCrane.GetValue<StackerCraneDBName, short>(StackerCraneDBName.WorkType),


                        StackerAlarm = commonStackerCrane.Communicator.Read<short>("DB1000.54.0"),


                    };


                    equipmentDTO.StackerDataJson = obj.Serialize();


                    _webSocketServer.PublishAllClientPayload(equipmentDTO.Serialize());




                    #endregion


                }


            }


            catch (Exception ex)


@@ -151,7 +217,7 @@


                            return WebResponseContent.Instance.Error($"输送线出库站点未配置,{task.NextAddress}");


                        }


                        bool depth = false;


                        if (task.Grade>0 && task.TaskType==TaskTypeEnum.PrintYLOutbound.ObjToInt())


                        if (task.Grade > 0 && task.TaskType==TaskTypeEnum.PrintYLOutbound.ObjToInt())


                        {


                            depth = true;


                        }


@@ -307,6 +373,7 @@


                    {


                        task.ExceptionMessage = "出库站台无法下发";


                        _taskRepository.UpdateData(task);


                        WriteInfo(task.DeviceCode, $"出库站台无法下发");


                    }


                }


                else