81 lines
3.0 KiB
C#
81 lines
3.0 KiB
C#
|
using MiniExcelLibs;
|
|||
|
|
using Serenity.Services;
|
|||
|
|
using SqlSugar;
|
|||
|
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.Data.SqlClient;
|
|||
|
|
using System.IO;
|
|||
|
|
using System.Linq;
|
|||
|
|
using System.Text;
|
|||
|
|
using System.Threading.Tasks;
|
|||
|
|
using HT.Cloud.Domain.ReportManage;
|
|||
|
|
using Newtonsoft.Json.Linq;
|
|||
|
|
using System.Data;
|
|||
|
|
using HT.Cloud.Code;
|
|||
|
|
using HT.Cloud.Domain.ChartsManage;
|
|||
|
|
using HT.Cloud.Domain.DevicesManage;
|
|||
|
|
using Quartz;
|
|||
|
|
using Microsoft.Extensions.Logging;
|
|||
|
|
using HT.Cloud.Domain.Entity.ReportManage;
|
|||
|
|
using System.Diagnostics;
|
|||
|
|
using System.Threading;
|
|||
|
|
|
|||
|
|
namespace HT.Cloud.Service.ReportManage
|
|||
|
|
{
|
|||
|
|
public class ApplicationStateService : BaseService<RTApplicationStateEntity>, IDenpendency
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// 绑定数据仓库的数据库ID
|
|||
|
|
/// </summary>
|
|||
|
|
private string dataDBNumber = GlobalContext.SystemConfig.DataDBNumber;
|
|||
|
|
|
|||
|
|
public ApplicationStateService(ISqlSugarClient context) : base(context)
|
|||
|
|
{
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task<string> GetApplicationList(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}_STATE");
|
|||
|
|
|
|||
|
|
return list.ToJson();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task<string> GetRtApplicationState(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}_STATE");
|
|||
|
|
|
|||
|
|
var interval = 1000;
|
|||
|
|
|
|||
|
|
foreach ( var item in list )
|
|||
|
|
{
|
|||
|
|
var process = Process.GetProcessesByName("HT.Cloud.Web")[0];
|
|||
|
|
var startTime = DateTime.UtcNow;
|
|||
|
|
var startCpuUsage = process.TotalProcessorTime;
|
|||
|
|
// Perform some work
|
|||
|
|
Thread.Sleep(interval);
|
|||
|
|
var endTime = DateTime.UtcNow;
|
|||
|
|
var endCpuUsage = process.TotalProcessorTime;
|
|||
|
|
var cpuUsage = (endCpuUsage - startCpuUsage) / (endTime - startTime) / Environment.ProcessorCount * 100;
|
|||
|
|
var memory = process.WorkingSet64 / (1024 * 1024);
|
|||
|
|
Console.WriteLine($"CPU usage: {cpuUsage}% Memory: {memory}MB");
|
|||
|
|
}
|
|||
|
|
return list.ToJson();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
public class RealTimeDataFormat
|
|||
|
|
{
|
|||
|
|
public string Description { get; set; }
|
|||
|
|
public string Value { get; set; }
|
|||
|
|
public string RtTime { get; set; }
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|