From 50fd5cc9cfad08714c4daa6d481c5293ff2ae6b1 Mon Sep 17 00:00:00 2001 From: dengjunjie <dengjunjie@hnkhzn.com> Date: 星期三, 31 一月 2024 18:55:28 +0800 Subject: [PATCH] 逻辑完善 --- 代码管理/PCS/WCS_Server/WIDESEA_WCS/Jobs/equipment/GantryJob.cs | 38 ++++++++++++++++++++++---------------- 1 files changed, 22 insertions(+), 16 deletions(-) diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Jobs/equipment/GantryJob.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Jobs/equipment/GantryJob.cs" index baffdeb..71a8d36 100644 --- "a/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Jobs/equipment/GantryJob.cs" +++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/PCS/WCS_Server/WIDESEA_WCS/Jobs/equipment/GantryJob.cs" @@ -10,6 +10,7 @@ using WIDESEA_Core.EFDbContext; using WIDESEA_Entity.DomainModels; using WIDESEA_WCS.IRepositories; +using WIDESEA_WCS.Jobs; using WIDESEA_WCS.Repositories; using WIDESEA_WCS.WCSClient; @@ -19,31 +20,35 @@ /// 妗佹灦 /// </summary> [DisallowConcurrentExecution] - public class GantryJob : IJob + public class GantryJob : JobBase, IJob { public Task Execute(IJobExecutionContext context) { try { - var client = context.JobDetail.JobDataMap.Get("JobParams") as PLCClient; - if (client == null) - { - return Task.CompletedTask; - } - - //鑷姩閲嶈繛 - if (!client.IsConnected) - { - client.Connect(); - return Task.CompletedTask; - } - - //DoAction(client); - //ExecuteJob(context, DoAction); + ExecuteJob(context, DoAction); } catch { } return Task.CompletedTask; } + + private void DoAction(IJobExecutionContext context) + { + var client = context.JobDetail.JobDataMap.Get("JobParams") as PLCClient; + //鑷姩閲嶈繛 + if (!client.IsConnected) + { + client.Connect(); + return; + } + Gantry gantry = new Gantry(); + gantry.QueryWheeldata(client); + gantry.QueryOrder(client); + gantry.Layofflevel(client); + gantry.Stupidproofmeasure(client); + } + + #region static List<MachineDB> MachineDBs = new List<MachineDB>(); static List<WheelDataDB> wheelDataDBs = new List<WheelDataDB>(); private void DoAction(PLCClient client) @@ -121,6 +126,7 @@ throw; } } + #endregion public void HandleReadSignal(string type, MachineDB DBItem) { switch (type) -- Gitblit v1.9.3