cdl/HTCloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新兴铸管

Browse Source
This commit is contained in:
dell
2024-09-03 14:16:18 +08:00
parent aee89ebeb1
commit aa742f0036
18 changed files with 18658 additions and 1825 deletions
Download Patch File Download Diff File Expand all files Collapse all files

76
HT.Cloud.Service/SystemSecurity/RealTimeIOStateService.cs
View File

@ -18,6 +18,7 @@ using Quartz;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using HT.Cloud.Domain.SystemSecurity;
using System.Net.NetworkInformation;
namespace HT.Cloud.Service.SystemSecurity
{
@ -41,8 +42,17 @@ namespace HT.Cloud.Service.SystemSecurity
return list;
}
public async Task<List<RealTimeIOGroupEntity>> GetIOGroup(string systemName, string iogroupid)
{
var groupName = _context.AsTenant().QueryableWithAttr<MetaGroupEntity>().Where(x => x.GroupDescription == systemName).First().GroupName;
var driverId = _context.AsTenant().QueryableWithAttr<MetaGroupEntity>().Where(x => x.GroupDescription == systemName).First().DriverID;
var driverName = _context.AsTenant().QueryableWithAttr<MetaDriverEntity>().Where(x => x.DriverID == driverId).First().DriverName;
var list = _context.AsTenant().GetConnection(dataDBNumber).Ado.SqlQuery<RealTimeIOGroupEntity>($"SELECT * FROM HT_{driverName}_{groupName}_IOGROUP_{iogroupid}");
return list;
public async Task<List<RealTimeIOInfoEntity>> GetIOInfo(string systemName)
}
public async Task<List<RealTimeIOInfoEntity>> GetIOInfo(string systemName)
{
var groupName = _context.AsTenant().QueryableWithAttr<MetaGroupEntity>().Where(x => x.GroupDescription == systemName).First().GroupName;
var driverId = _context.AsTenant().QueryableWithAttr<MetaGroupEntity>().Where(x => x.GroupDescription == systemName).First().DriverID;
@ -50,19 +60,71 @@ namespace HT.Cloud.Service.SystemSecurity
var list = _context.AsTenant().GetConnection(dataDBNumber).Ado.SqlQuery<RealTimeIOInfoEntity>($"SELECT * FROM HT_{driverName}_{groupName}_IOINFO");
return list;
}
public async Task<string> GetRtData()
public async Task<List<RealTimeIOInfoEntity>> GetIOInfo(string systemName, string iogroupid)
{
var groupName = _context.AsTenant().QueryableWithAttr<MetaGroupEntity>().Where(x => x.GroupDescription == systemName).First().GroupName;
var driverId = _context.AsTenant().QueryableWithAttr<MetaGroupEntity>().Where(x => x.GroupDescription == systemName).First().DriverID;
var driverName = _context.AsTenant().QueryableWithAttr<MetaDriverEntity>().Where(x => x.DriverID == driverId).First().DriverName;
var list = _context.AsTenant().GetConnection(dataDBNumber).Ado.SqlQuery<RealTimeIOInfoEntity>($"SELECT * FROM HT_{driverName}_{groupName}_IOINFO_{iogroupid}");
return list;
}
public async Task<List<RealTimeDevNetWorkEntity>> GetDevNetWork(string systemName)
{
//var groupName = _context.AsTenant().QueryableWithAttr<MetaGroupEntity>().Where(x => x.GroupDescription == systemName).First().GroupName;
var groupName = _context.AsTenant().QueryableWithAttr<MetaGroupEntity>().Where(x => x.GroupDescription == systemName).First().GroupName;
var driverId = _context.AsTenant().QueryableWithAttr<MetaGroupEntity>().Where(x => x.GroupDescription == systemName).First().DriverID;
var driverName = _context.AsTenant().QueryableWithAttr<MetaDriverEntity>().Where(x => x.DriverID == driverId).First().DriverName;
var list = _context.AsTenant().GetConnection(dataDBNumber).Ado.SqlQuery<RealTimeDevNetWorkEntity>($"SELECT * FROM HT_{driverName}_{groupName}_DEVNETWORK");
return list;
}
public async Task<List<RealTimeDevNetWorkEntity>> GetRealDevNetWork(string systemName)
{
var groupName = _context.AsTenant().QueryableWithAttr<MetaGroupEntity>().Where(x => x.GroupDescription == systemName).First().GroupName;
var driverId = _context.AsTenant().QueryableWithAttr<MetaGroupEntity>().Where(x => x.GroupDescription == systemName).First().DriverID;
var driverName = _context.AsTenant().QueryableWithAttr<MetaDriverEntity>().Where(x => x.DriverID == driverId).First().DriverName;
var list = _context.AsTenant().GetConnection(dataDBNumber).Ado.SqlQuery<RealTimeDevNetWorkEntity>($"SELECT * FROM HT_{driverName}_{groupName}_DEVNETWORK");
var listNT = new List<RealTimeDevNetWorkEntity>();
foreach (var dev in list)
{
var devNT = new RealTimeDevNetWorkEntity();
devNT = dev;
string message = "";
string address = devNT.DeviceIP;
Ping ping = new Ping();
try
{
PingReply pingReply = ping.Send(address,247);
if (pingReply.Status == IPStatus.Success)
{
devNT.DeviceNetWorkStatus = "True";
}
else
{
devNT.DeviceNetWorkStatus = "False";
}
}
catch (Exception e)
{
devNT.DeviceNetWorkStatus = "False";
}
listNT.Add(devNT);
}
return listNT;
}
public async Task<string> GetRtData(string systemName)
{
var groupName = _context.AsTenant().QueryableWithAttr<MetaGroupEntity>().Where(x => x.GroupDescription == systemName).First().GroupName;
//var driverId = _context.AsTenant().QueryableWithAttr<MetaGroupEntity>().Where(x => x.GroupDescription == systemName).First().DriverID;
//var driverName = _context.AsTenant().QueryableWithAttr<MetaDriverEntity>().Where(x => x.DriverID == driverId).First().DriverName;
//var list = _context.AsTenant().GetConnection(dataDBNumber).Ado.SqlQuery<RTMainPageEntity>($"SELECT * FROM HT_{driverName}_{groupName}_MAINPAGE");
var remoteRtDataServer = " http://localhost:5276/TestIOApi/";
//var remoteRtDataServer = " http://localhost:5276/TestIOApi/";
var responseStr = RemoteHttpRequest.HttpGet(remoteRtDataServer);
var remoteRtDataServer = _context.AsTenant().QueryableWithAttr<RtchartsEntity>().First().remotertdataserver + $"?groupName={groupName}";
var responseStr = RemoteHttpRequest.HttpGet(remoteRtDataServer);
JObject valueJson = JObject.Parse(responseStr);