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

初版IO监控

Browse Source
This commit is contained in:
dell
2024-01-12 08:54:55 +08:00
parent 6025fb75a3
commit 62959ab75a
10 changed files with 4910 additions and 108 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
HT.Cloud.Service/SystemSecurity/RealTimeIOState.cs → HT.Cloud.Service/SystemSecurity/RealTimeIOStateService.cs
View File

@ -17,21 +17,41 @@ using HT.Cloud.Domain.DevicesManage;
using Quartz;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using HT.Cloud.Domain.SystemSecurity;
namespace HT.Cloud.Service.SystemSecurity
{
public class RealTimeIOState : BaseService<RTMainPageEntity>, IDenpendency
public class RealTimeIOStateService : BaseService<RealTimeIOGroupEntity>, IDenpendency
{
/// <summary>
/// 绑定数据仓库的数据库ID
/// </summary>
private string dataDBNumber = GlobalContext.SystemConfig.DataDBNumber;
public RealTimeIOState(ISqlSugarClient context) : base(context)
public RealTimeIOStateService(ISqlSugarClient context) : base(context)
{
}
public async Task<string> GetRtData()
public async Task<List<RealTimeIOGroupEntity>> GetIOGroup(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<RealTimeIOGroupEntity>($"SELECT * FROM HT_{driverName}_{groupName}_IOGROUP");
return list;
}
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;
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");
return list;
}
public async Task<string> GetRtData()
{
//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;