From 9250e3e48760f91fbefef03331fc7b14b4b1be18 Mon Sep 17 00:00:00 2001
From: yanjinhui <3306209981@qq.com>
Date: 星期六, 07 六月 2025 13:09:59 +0800
Subject: [PATCH] 修改数字大屏接口
---
project/WCS/WIDESEAWCS_Server/WIDESEAWCS_TelescopicService/AlarmResetHsyServer.cs | 91 +++++++++++++++++++++++++++++++++++++++++----
1 files changed, 82 insertions(+), 9 deletions(-)
diff --git a/project/WCS/WIDESEAWCS_Server/WIDESEAWCS_TelescopicService/AlarmResetHsyServer.cs b/project/WCS/WIDESEAWCS_Server/WIDESEAWCS_TelescopicService/AlarmResetHsyServer.cs
index b9bba81..ca85a13 100644
--- a/project/WCS/WIDESEAWCS_Server/WIDESEAWCS_TelescopicService/AlarmResetHsyServer.cs
+++ b/project/WCS/WIDESEAWCS_Server/WIDESEAWCS_TelescopicService/AlarmResetHsyServer.cs
@@ -1,5 +1,6 @@
锘縰sing HslCommunication.WebSocket;
using Newtonsoft.Json;
+using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
using SqlSugar;
using System;
using System.Collections;
@@ -10,9 +11,11 @@
using WIDESEAWCS_Core;
using WIDESEAWCS_Core.BaseRepository;
using WIDESEAWCS_Core.BaseServices;
+using WIDESEAWCS_Core.Helper;
using WIDESEAWCS_DTO.Telescopic;
using WIDESEAWCS_ITaskInfoService;
using WIDESEAWCS_Model.Models;
+using WIDESEAWCS_QuartzJob;
namespace WIDESEAWCS_TelescopicService
{
@@ -34,11 +37,12 @@
/// </summary>
/// <param name="entity"></param>
/// <returns></returns>
- public WebResponseContent AddAlarmHsy(string alarmContent, bool resetStatus)
+ public WebResponseContent AddAlarmHsy(int deptid,string alarmContent, bool resetStatus)
{
var alarm = new Dt_AlarmResetHsy
{
- AlarmContent= alarmContent,
+ Deptid= deptid,
+ AlarmContent = alarmContent,
ResetStatus= resetStatus,
AlarmTime=DateTime.Now,
@@ -49,7 +53,7 @@
}
- public WebResponseContent GetWebSocketInfo()
+ public WebResponseContent GetWebSocketInfo(int deptid)
{
try
{
@@ -57,7 +61,7 @@
// var query = Db.Queryable<Dt_AlarmResetHsy>()
// .OrderBy(x => new { ResetStatus = SqlFunc.IsNull(x.ResetStatus, false), x.CreateDate }, OrderByType.Desc); // 鎸� ResetStatus 涓� true 鎺掑湪鍓嶏紝骞舵寜 CreateDate 闄嶅簭
- var query = BaseDal.QueryData().OrderByDescending(x => x.ResetStatus). ThenByDescending(x => x.CreateDate); // 鍐嶆寜 CreateDate 闄嶅簭;
+ var query = BaseDal.QueryData(x=>x.Deptid==deptid).OrderByDescending(x => x.ResetStatus). ThenByDescending(x => x.CreateDate); // 鍐嶆寜 CreateDate 闄嶅簭;
// 濡傛灉闇�瑕佹牴鎹叾浠栧瓧娈佃繘琛岃繃婊ゆ垨妯＄硦鏌ヨ锛屽彲浠ュ湪姝ゆ坊鍔�
@@ -82,16 +86,43 @@
/// </summary>
/// <param name="status"></param>
/// <returns></returns>
- public WebResponseContent BecomeTrue(string account)
+ public WebResponseContent BecomeTrue()
{
- //鎵惧埌鐧诲叆浜虹殑deptid
- var loginer = _user.QueryFirst(x => x.UserName == account);
+ ////鎵惧埌鐧诲叆浜虹殑deptid
+ //var loginer = _user.QueryFirst(x => x.UserName == account);
+ if (!int.TryParse(AppSettings.Get("DepartmentID"), out int deid))
+ {
+ return new WebResponseContent { Status = false, Message = "閰嶇疆椤� DepartmentID 鏃犳硶杞崲涓烘暣鏁�" };
+ }
+ var devices = GetDevicesByDeptId(deid);
+
- var query = BaseDal.QueryData(x => x.ResetStatus == true && x.Deptid==loginer.Dept_Id ).ToList();
+
+ var query = BaseDal.QueryData(x => x.ResetStatus == true && x.Deptid== deid).ToList();
// 濡傛灉娌℃湁鎵惧埌绗﹀悎鏉′欢鐨勬暟鎹�
if (query.Count == 0)
{
return new WebResponseContent { Status = false, Message = "娌℃湁瑕佸浣嶆暟鎹�" };
+ }
+ try
+ {
+ var left = devices.Value.left.Communicator.Write<bool>("M105", true); //閲嶅惎鎶ヨ澶嶄綅
+ Console.WriteLine($"宸︽姤璀︿俊鍙峰浣嶅啓鍏left}");
+ }
+ catch (Exception)
+ {
+
+
+ }
+ try
+ {
+ var right = devices.Value.right.Communicator.Write<bool>("M105", true);
+ Console.WriteLine($"鍙虫姤璀︿俊鍙峰浣嶅啓鍏right}");
+ }
+ catch (Exception)
+ {
+
+
}
foreach (var item in query)
{
@@ -137,6 +168,48 @@
}
}
-
+ public WebResponseContent DeleteAllinform()
+ {
+ try
+ {
+
+ if (!int.TryParse(AppSettings.Get("DepartmentID"), out int deid)) //鑾峰彇杞ㄩ亾绔欏彿
+ {
+ Console.WriteLine("閰嶇疆椤� DepartmentID 鏃犳硶杞崲涓烘暣鏁�");
+ }
+ //鎵惧埌璇ヨ建閬撶珯鐨勫叏閮ㄤ俊鎭�
+ var alarm = BaseDal.QueryData(x => x.Deptid == deid).ToList();
+ if (alarm.Count<=0)
+ {
+ return new WebResponseContent { Status = false, Message = $"娌℃湁瑕佸垹闄ょ殑{deid}杞ㄩ亾绔欑殑鎶ヨ淇℃伅" };
+ }
+ //鎵惧埌鍚庡叏閮ㄥ垹闄�
+ var reslut= BaseDal.DeleteData(alarm);
+ return new WebResponseContent { Status = true, Message = "鍒犻櫎鎴愬姛", Data = reslut };
+ }
+ catch (Exception ex)
+ {
+
+ return new WebResponseContent { Status = false, Message = ex.Message };
+ }
+ }
+
+
+ public (OtherDevice left, OtherDevice right)? GetDevicesByDeptId(int deptId)
+ {
+ // 宸﹁澶囧彿锛�1 -> 001锛�2 -> 003锛�3 -> 005...
+ int baseCode = 1 + (deptId - 1) * 2;
+ string leftCode = $"SSG{baseCode.ToString("D3")}";
+ string rightCode = $"SSG{(baseCode + 1).ToString("D3")}";
+
+ var left = (OtherDevice)Storage.Devices.Find(x => x.DeviceCode == leftCode);
+ var right = (OtherDevice)Storage.Devices.Find(x => x.DeviceCode == rightCode);
+
+
+ //if (left == null || right == null)
+ // return null;
+
+ return (left, right);
+ }
}
}
--
Gitblit v1.9.3