伸缩杆控制系统
上一版本: 2ea808bf | 补丁 | 提交 | 显示空白
qiuyao
2025-03-20 8bd244a83cb20be190e1f480809a4b98254cd811 
提交job类
已删除1个文件
已修改1个文件
已添加2个文件
392 ■■■■■ 文件已修改
项目代码/WCS/WIDESEAWCS_Server/.vs/WIDESEAWCS_Server/v17/DocumentLayout.json 258 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
项目代码/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs 2 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
项目代码/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SSG/SSGOneJob.cs 66 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
项目代码/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SSG/SSGTwoJob.cs 66 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 
 ÏîÄ¿´úÂë/WCS/WIDESEAWCS_Server/.vs/WIDESEAWCS_Server/v17/DocumentLayout.json


ÎļþÒÑɾ³ý




 ÏîÄ¿´úÂë/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs


@@ -16,6 +16,7 @@


#endregion << ç‰ˆ æœ¬ æ³¨ é‡Š >>




using AutoMapper;


using HslCommunication.WebSocket;


using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;


using SqlSugar;


using System.Diagnostics.CodeAnalysis;


@@ -35,6 +36,7 @@


using WIDESEAWCS_QuartzJob;


using WIDESEAWCS_QuartzJob.Models;


using WIDESEAWCS_QuartzJob.Service;


using static HslCommunication.Profinet.Knx.KnxCode;




namespace WIDESEAWCS_TaskInfoService


{




 ÏîÄ¿´úÂë/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SSG/SSGOneJob.cs


¶Ô±ÈÐÂÎļþ


@@ -0,0 +1,66 @@


using Autofac.Core;


using HslCommunication;


using HslCommunication.Core;


using HslCommunication.WebSocket;


using Microsoft.Extensions.Hosting;


using Microsoft.VisualBasic.FileIO;


using Newtonsoft.Json;


using Quartz;


using SixLabors.ImageSharp.PixelFormats;


using System;


using System.Collections.Generic;


using System.ComponentModel;


using System.Diagnostics.CodeAnalysis;


using System.Linq;


using System.Reflection;


using System.Text;


using System.Threading.Tasks;


using WIDESEAWCS_Communicator;


using WIDESEAWCS_Core.Helper;


using WIDESEAWCS_ISystemServices;


using WIDESEAWCS_ITaskInfoService;


using WIDESEAWCS_Model.Models;


using WIDESEAWCS_QuartzJob;


using WIDESEAWCS_QuartzJob.DeviceBase;


using WIDESEAWCS_QuartzJob.StackerCrane.Enum;


using WIDESEAWCS_Tasks.OHT;




namespace WIDESEAWCS_Tasks


{


    [DisallowConcurrentExecution]


    public class SSGOneJob : JobBase, IJob


    {


        public static bool W_ZXJ_Heat = true;


        public static bool W_TC_Heat = true;


        WebSocketServer _webSocketServer;


        private readonly Idt_ErrormsginfoService _ErrormsginfoService;


        public SSGOneJob(WebSocketServer webSocketServer,Idt_ErrormsginfoService errormsginfoService)


        {


            _webSocketServer = webSocketServer;


            _ErrormsginfoService = errormsginfoService;


        }




        public Task Execute(IJobExecutionContext context)


        {


            bool flag = context.JobDetail.JobDataMap.TryGetValue("JobParams", out object? value);


            if (flag && value != null)


            {                


                try


                {


                    OtherDevice device = (OtherDevice)value;




                    //状态数据发送给前端


                    string ohtData = JsonConvert.SerializeObject(device.Communicator.IsConnected);


                    _webSocketServer.PublishAllClientPayload(ohtData);


                }


                catch (Exception ex)


                {


                    //状态数据发送给前端


                    _webSocketServer.PublishAllClientPayload("false");


                    _ErrormsginfoService.UpdateErrorMsg(ex.Message, 1);


                }


            }


            return Task.CompletedTask;


        }


    }


}




 ÏîÄ¿´úÂë/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/SSG/SSGTwoJob.cs


¶Ô±ÈÐÂÎļþ


@@ -0,0 +1,66 @@


using Autofac.Core;


using HslCommunication;


using HslCommunication.Core;


using HslCommunication.WebSocket;


using Microsoft.Extensions.Hosting;


using Microsoft.VisualBasic.FileIO;


using Newtonsoft.Json;


using Quartz;


using SixLabors.ImageSharp.PixelFormats;


using System;


using System.Collections.Generic;


using System.ComponentModel;


using System.Diagnostics.CodeAnalysis;


using System.Linq;


using System.Reflection;


using System.Text;


using System.Threading.Tasks;


using WIDESEAWCS_Communicator;


using WIDESEAWCS_Core.Helper;


using WIDESEAWCS_ISystemServices;


using WIDESEAWCS_ITaskInfoService;


using WIDESEAWCS_Model.Models;


using WIDESEAWCS_QuartzJob;


using WIDESEAWCS_QuartzJob.DeviceBase;


using WIDESEAWCS_QuartzJob.StackerCrane.Enum;


using WIDESEAWCS_Tasks.OHT;




namespace WIDESEAWCS_Tasks


{


    [DisallowConcurrentExecution]


    public class SSGTwoJob : JobBase, IJob


    {


        public static bool W_ZXJ_Heat = true;


        public static bool W_TC_Heat = true;


        WebSocketServer _webSocketServer;


        private readonly Idt_ErrormsginfoService _ErrormsginfoService;


        public SSGTwoJob(WebSocketServer webSocketServer,Idt_ErrormsginfoService errormsginfoService)


        {


            _webSocketServer = webSocketServer;


            _ErrormsginfoService = errormsginfoService;


        }




        public Task Execute(IJobExecutionContext context)


        {


            bool flag = context.JobDetail.JobDataMap.TryGetValue("JobParams", out object? value);


            if (flag && value != null)


            {                


                try


                {


                    OtherDevice device = (OtherDevice)value;




                    //状态数据发送给前端


                    string ohtData = JsonConvert.SerializeObject(device.Communicator.IsConnected);


                    _webSocketServer.PublishAllClientPayload(ohtData);


                }


                catch (Exception ex)


                {


                    //状态数据发送给前端


                    _webSocketServer.PublishAllClientPayload("false");


                    _ErrormsginfoService.UpdateErrorMsg(ex.Message, 1);


                }


            }


            return Task.CompletedTask;


        }


    }


}