From 4d5e2e2340899e8cb8dd6855fcdd9ce384d78351 Mon Sep 17 00:00:00 2001
From: huanghongfeng <huanghongfeng@hnkhzn.com>
Date: 星期五, 28 二月 2025 19:17:28 +0800
Subject: [PATCH] 1
---
项目代码/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/LogJob.cs | 75 +++++++++++++++
项目代码/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/Controllers/QuartzJob/DeviceProtocolController.cs | 166 +++++++++++++++++++++++++++++++++
2 files changed, 241 insertions(+), 0 deletions(-)
diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/Controllers/QuartzJob/DeviceProtocolController.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/Controllers/QuartzJob/DeviceProtocolController.cs"
index 68078c5..d71814d 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/Controllers/QuartzJob/DeviceProtocolController.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Server/Controllers/QuartzJob/DeviceProtocolController.cs"
@@ -20,5 +20,171 @@
{
return Service.GetImportData(fileInput);
}
+
+
+ [HttpPost, Route("GetImportData2"), AllowAnonymous]
+ public void GetImportData2()
+ {
+ try
+ {
+ List<Dt_DeviceProtocol> dt_Devices = new List<Dt_DeviceProtocol>();
+ for (int i = 0; i < 4; i++)
+ {
+ //鍐欏叆妯″潡
+ #region
+ Dt_DeviceProtocol dt_DeviceProtocol = new Dt_DeviceProtocol();
+ dt_DeviceProtocol.DeviceId = 1002;
+ dt_DeviceProtocol.DeviceChildCode = ("B" +1+i + "02").ToString();
+ dt_DeviceProtocol.DeviceProDataBlock = "DB50";
+ dt_DeviceProtocol.DeviceProOffset = (decimal)0 + (16 * i); //鎸囧�煎灏�
+ dt_DeviceProtocol.DeviceProDataType = "bool"; //绫诲瀷
+ dt_DeviceProtocol.DeviceProParamName = "Backup01"; //鍚嶇О
+ dt_DeviceProtocol.DeviceProDataLength = 1; //闀垮害
+ dt_DeviceProtocol.DeviceProParamType = "DeviceCommand"; //璇诲彇
+ dt_DeviceProtocol.DeviceProParamDes = "";
+ dt_DeviceProtocol.DeviceProRemark = "澶囩敤1"; //澶囨敞
+ dt_DeviceProtocol.Creater = "admin";
+ dt_DeviceProtocol.CreateDate = DateTime.Now;
+ dt_Devices.Add(dt_DeviceProtocol);
+
+ Dt_DeviceProtocol dt_DeviceProtoco2 = new Dt_DeviceProtocol();
+ dt_DeviceProtoco2.DeviceId = 1002;
+ dt_DeviceProtoco2.DeviceChildCode = ("B" + 1 + i + "02").ToString();
+ dt_DeviceProtoco2.DeviceProDataBlock = "DB50";
+ dt_DeviceProtoco2.DeviceProOffset = (decimal)0.1 + (16 * i); //鎸囧�煎灏�
+ dt_DeviceProtoco2.DeviceProDataType = "bool"; //绫诲瀷
+ dt_DeviceProtoco2.DeviceProParamName = "Backup02"; //鍚嶇О
+ dt_DeviceProtoco2.DeviceProDataLength = 1; //闀垮害
+ dt_DeviceProtoco2.DeviceProParamType = "DeviceCommand"; //璇诲彇
+ dt_DeviceProtoco2.DeviceProParamDes = "";
+ dt_DeviceProtoco2.DeviceProRemark = "澶囩敤2"; //澶囨敞
+ dt_DeviceProtoco2.Creater = "admin";
+ dt_DeviceProtoco2.CreateDate = DateTime.Now;
+ dt_Devices.Add(dt_DeviceProtoco2);
+
+ Dt_DeviceProtocol dt_DeviceProtoco3 = new Dt_DeviceProtocol();
+ dt_DeviceProtoco3.DeviceId = 1002;
+ dt_DeviceProtoco3.DeviceChildCode = ("B" + 1 + i + "02").ToString();
+ dt_DeviceProtoco3.DeviceProDataBlock = "DB50";
+ dt_DeviceProtoco3.DeviceProOffset = (decimal)0.2 + (16 * i); //鎸囧�煎灏�
+ dt_DeviceProtoco3.DeviceProDataType = "bool"; //绫诲瀷
+ dt_DeviceProtoco3.DeviceProParamName = "Backup03"; //鍚嶇О
+ dt_DeviceProtoco3.DeviceProDataLength = 1; //闀垮害
+ dt_DeviceProtoco3.DeviceProParamType = "DeviceCommand"; //璇诲彇
+ dt_DeviceProtoco3.DeviceProParamDes = "";
+ dt_DeviceProtoco3.DeviceProRemark = "澶囩敤3"; //澶囨敞
+ dt_DeviceProtoco3.Creater = "admin";
+ dt_DeviceProtoco3.CreateDate = DateTime.Now;
+ dt_Devices.Add(dt_DeviceProtoco3);
+
+ Dt_DeviceProtocol dt_DeviceProtoco4 = new Dt_DeviceProtocol();
+ dt_DeviceProtoco4.DeviceId = 1002;
+ dt_DeviceProtoco4.DeviceChildCode = ("B" + 1 + i + "02").ToString();
+ dt_DeviceProtoco4.DeviceProDataBlock = "DB50";
+ dt_DeviceProtoco4.DeviceProOffset = (decimal)0.3 + (16 * i); //鎸囧�煎灏�
+ dt_DeviceProtoco4.DeviceProDataType = "bool"; //绫诲瀷
+ dt_DeviceProtoco4.DeviceProParamName = "Backup04"; //鍚嶇О
+ dt_DeviceProtoco4.DeviceProDataLength = 1; //闀垮害
+ dt_DeviceProtoco4.DeviceProParamType = "DeviceCommand"; //璇诲彇
+ dt_DeviceProtoco4.DeviceProParamDes = "";
+ dt_DeviceProtoco4.DeviceProRemark = "澶囩敤4"; //澶囨敞
+ dt_DeviceProtoco4.Creater = "admin";
+ dt_DeviceProtoco4.CreateDate = DateTime.Now;
+ dt_Devices.Add(dt_DeviceProtoco4);
+ #endregion
+
+ //璇诲彇妯″潡
+ #region
+ Dt_DeviceProtocol dt_DeviceProtoco5 = new Dt_DeviceProtocol();
+ dt_DeviceProtoco5.DeviceId = 1002;
+ dt_DeviceProtoco5.DeviceChildCode = ("B" + 1 + i + "02").ToString();
+ dt_DeviceProtoco5.DeviceProDataBlock = "DB50";
+ dt_DeviceProtoco5.DeviceProOffset = (decimal)8 + (16 * i); //鎸囧�煎灏�
+ dt_DeviceProtoco5.DeviceProDataType = "bool"; //绫诲瀷
+ dt_DeviceProtoco5.DeviceProParamName = "Heartbeat"; //鍚嶇О
+ dt_DeviceProtoco5.DeviceProDataLength = 1; //闀垮害
+ dt_DeviceProtoco5.DeviceProParamType = "ReadDeviceCommand"; //璇诲彇
+ dt_DeviceProtoco5.DeviceProParamDes = "";
+ dt_DeviceProtoco5.DeviceProRemark = "蹇冭烦"; //澶囨敞
+ dt_DeviceProtoco5.Creater = "admin";
+ dt_DeviceProtoco5.CreateDate = DateTime.Now;
+ dt_Devices.Add(dt_DeviceProtoco5);
+
+ Dt_DeviceProtocol dt_DeviceProtoco6 = new Dt_DeviceProtocol();
+ dt_DeviceProtoco6.DeviceId = 1002;
+ dt_DeviceProtoco6.DeviceChildCode = ("B" + 1 + i + "02").ToString();
+ dt_DeviceProtoco6.DeviceProDataBlock = "DB50";
+ dt_DeviceProtoco6.DeviceProOffset = (decimal)8.1 + (16 * i); //鎸囧�煎灏�
+ dt_DeviceProtoco6.DeviceProDataType = "bool"; //绫诲瀷
+ dt_DeviceProtoco6.DeviceProParamName = "Allowpickup"; //鍚嶇О
+ dt_DeviceProtoco6.DeviceProDataLength = 1; //闀垮害
+ dt_DeviceProtoco6.DeviceProParamType = "ReadDeviceCommand"; //璇诲彇
+ dt_DeviceProtoco6.DeviceProParamDes = "";
+ dt_DeviceProtoco6.DeviceProRemark = "璇锋眰鍙栬揣鐘舵��"; //澶囨敞
+ dt_DeviceProtoco6.Creater = "admin";
+ dt_DeviceProtoco6.CreateDate = DateTime.Now;
+ dt_Devices.Add(dt_DeviceProtoco6);
+
+ Dt_DeviceProtocol dt_DeviceProtoco7 = new Dt_DeviceProtocol();
+ dt_DeviceProtoco7.DeviceId = 1002;
+ dt_DeviceProtoco7.DeviceChildCode = ("B" + 1 + i + "02").ToString();
+ dt_DeviceProtoco7.DeviceProDataBlock = "DB50";
+ dt_DeviceProtoco7.DeviceProOffset = (decimal)8.2 + (16 * i); //鎸囧�煎灏�
+ dt_DeviceProtoco7.DeviceProDataType = "bool"; //绫诲瀷
+ dt_DeviceProtoco7.DeviceProParamName = "Allowreleasegoods"; //鍚嶇О
+ dt_DeviceProtoco7.DeviceProDataLength = 1; //闀垮害
+ dt_DeviceProtoco7.DeviceProParamType = "ReadDeviceCommand"; //璇诲彇
+ dt_DeviceProtoco7.DeviceProParamDes = "";
+ dt_DeviceProtoco7.DeviceProRemark = "鍏佽鏀捐揣鐘舵��"; //澶囨敞
+ dt_DeviceProtoco7.Creater = "admin";
+ dt_DeviceProtoco7.CreateDate = DateTime.Now;
+ dt_Devices.Add(dt_DeviceProtoco7);
+
+ Dt_DeviceProtocol dt_DeviceProtoco8 = new Dt_DeviceProtocol();
+ dt_DeviceProtoco8.DeviceId = 1002;
+ dt_DeviceProtoco8.DeviceChildCode = ("B" + 1 + i + "02").ToString();
+ dt_DeviceProtoco8.DeviceProDataBlock = "DB50";
+ dt_DeviceProtoco8.DeviceProOffset = (decimal)8.3 + (16 * i); //鎸囧�煎灏�
+ dt_DeviceProtoco8.DeviceProDataType = "bool"; //绫诲瀷
+ dt_DeviceProtoco8.DeviceProParamName = "Backup01"; //鍚嶇О
+ dt_DeviceProtoco8.DeviceProDataLength = 1; //闀垮害
+ dt_DeviceProtoco8.DeviceProParamType = "ReadDeviceCommand"; //璇诲彇
+ dt_DeviceProtoco8.DeviceProParamDes = "";
+ dt_DeviceProtoco8.DeviceProRemark = "澶囩敤1"; //澶囨敞
+ dt_DeviceProtoco8.Creater = "admin";
+ dt_DeviceProtoco8.CreateDate = DateTime.Now;
+ dt_Devices.Add(dt_DeviceProtoco8);
+
+ Dt_DeviceProtocol dt_DeviceProtoco9 = new Dt_DeviceProtocol();
+ dt_DeviceProtoco9.DeviceId = 1002;
+ dt_DeviceProtoco9.DeviceChildCode = ("B" + 1 + i + "02").ToString();
+ dt_DeviceProtoco9.DeviceProDataBlock = "DB50";
+ dt_DeviceProtoco9.DeviceProOffset = (decimal)8.4 + (16 * i); //鎸囧�煎灏�
+ dt_DeviceProtoco9.DeviceProDataType = "bool"; //绫诲瀷
+ dt_DeviceProtoco9.DeviceProParamName = "Backup02"; //鍚嶇О
+ dt_DeviceProtoco9.DeviceProDataLength = 1; //闀垮害
+ dt_DeviceProtoco9.DeviceProParamType = "ReadDeviceCommand"; //璇诲彇
+ dt_DeviceProtoco9.DeviceProParamDes = "";
+ dt_DeviceProtoco9.DeviceProRemark = "澶囩敤2"; //澶囨敞
+ dt_DeviceProtoco9.Creater = "admin";
+ dt_DeviceProtoco9.CreateDate = DateTime.Now;
+ dt_Devices.Add(dt_DeviceProtoco9);
+ #endregion
+ }
+
+
+ foreach (var deviceProtocol in dt_Devices)
+ {
+ base.AddData(deviceProtocol);
+ }
+ }
+ catch (Exception ex)
+ {
+
+ throw;
+ }
+
+
+ }
}
}
diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/LogJob.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/LogJob.cs"
new file mode 100644
index 0000000..ebb0563
--- /dev/null
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/LogJob.cs"
@@ -0,0 +1,75 @@
+锘縰sing HslCommunication;
+using HslCommunication.Core;
+using HslCommunication.WebSocket;
+using Microsoft.AspNetCore.Http;
+using Microsoft.VisualBasic.FileIO;
+using Newtonsoft.Json;
+using Quartz;
+using Quartz.Util;
+using SixLabors.ImageSharp.PixelFormats;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel;
+using System.Linq;
+using System.Reflection;
+using System.Reflection.Metadata.Ecma335;
+using System.Text;
+using System.Threading.Tasks;
+using WIDESEA_Common.Log;
+using WIDESEAWCS_Communicator;
+using WIDESEAWCS_Core.Helper;
+using WIDESEAWCS_QuartzJob;
+using WIDESEAWCS_QuartzJob.DeviceBase;
+using WIDESEAWCS_QuartzJob.StackerCrane.Enum;
+
+namespace WIDESEAWCS_Tasks
+{
+ [DisallowConcurrentExecution]
+ public class LogJob : IJob
+ {
+ static object sendData = null;
+ public Task Execute(IJobExecutionContext context)
+ {
+ try
+ {
+
+ Task.Run(() =>
+ {
+ try
+ {
+ while (true)
+ {
+ Run(5);
+ }
+ }
+ catch { }
+ });
+
+ }
+ catch (Exception ex)
+ {
+ Console.Out.WriteLine(nameof(LogJob) + ":" + ex.Message);
+ }
+
+ return Task.CompletedTask;
+ }
+ private static void Run(int saveDays)
+ {
+ sendData = new { code = "1002", Messagest = $"杞﹁疆SN鍙凤細123123123" };
+ CacheData.WebSocket.PublishAllClientPayload(sendData.Serialize());
+ }
+
+ public class CacheData
+ {
+ public static WebSocketServer WebSocket = new WebSocketServer();
+
+ public static void StartServer()
+ {
+ WebSocket = new WebSocketServer();
+ WebSocket.ServerStart(1880);
+ }
+ }
+ }
+
+
+}
--
Gitblit v1.9.3