|
|
|
|
@ -1,12 +1,18 @@
|
|
|
|
|
using Application.Domain.Entities;
|
|
|
|
|
using Infrastructure.Data;
|
|
|
|
|
using Infrastructure.Extensions;
|
|
|
|
|
using IoTCenter.ViewModels;
|
|
|
|
|
using Microsoft.AspNetCore.Mvc;
|
|
|
|
|
using Microsoft.EntityFrameworkCore;
|
|
|
|
|
using Microsoft.Extensions.Configuration;
|
|
|
|
|
using System;
|
|
|
|
|
using System.Collections.Generic;
|
|
|
|
|
using System.ComponentModel.DataAnnotations;
|
|
|
|
|
using System.Drawing;
|
|
|
|
|
using System.Globalization;
|
|
|
|
|
using System.Linq;
|
|
|
|
|
using Vibrant.InfluxDB.Client;
|
|
|
|
|
using Vibrant.InfluxDB.Client.Rows;
|
|
|
|
|
|
|
|
|
|
namespace UserCenter.Controllers
|
|
|
|
|
{
|
|
|
|
|
@ -45,5 +51,75 @@ namespace UserCenter.Controllers
|
|
|
|
|
return Problem(ex.Message);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
[HttpPost]
|
|
|
|
|
public IActionResult GetChartData([FromBody]ChartDataRequest model)
|
|
|
|
|
{
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
var device = this._deviceRepo.ReadOnlyTable().Include(o => o.Data).FirstOrDefault(o => o.Number == model.Number);
|
|
|
|
|
var data = device.Data.FirstOrDefault(o => o.Key == model.Key);
|
|
|
|
|
var url = this._cfg["influxdb:url"];
|
|
|
|
|
var usr = this._cfg["influxdb:usr"];
|
|
|
|
|
var pwd = this._cfg["influxdb:pwd"];
|
|
|
|
|
var dbName = "iot";
|
|
|
|
|
var measurementName = "data";
|
|
|
|
|
var datasets = new List<object>();
|
|
|
|
|
var labels = new List<string>();
|
|
|
|
|
var hours = Convert.ToInt32(DateTime.Now.ToString("%z"));
|
|
|
|
|
using (var client = new InfluxClient(new Uri(url), usr, pwd))
|
|
|
|
|
{
|
|
|
|
|
var query = $"select { model.Key} from {measurementName} where time>now() - {model.Key} and DeviceNumber = '{model.Number}' limit 10000";
|
|
|
|
|
var result = client.ReadAsync<DynamicInfluxRow>(dbName, query).Result;
|
|
|
|
|
var rows = result.Results.FirstOrDefault()?
|
|
|
|
|
.Series.FirstOrDefault()?
|
|
|
|
|
.Rows;
|
|
|
|
|
datasets.Add(new
|
|
|
|
|
{
|
|
|
|
|
label = data.Name,
|
|
|
|
|
data = rows != null ? rows.Select(o => o.GetField(data.Key)).ToList() : new List<object>(),
|
|
|
|
|
backgroundColor = this.GetColor(data.Key),
|
|
|
|
|
fill = false
|
|
|
|
|
});
|
|
|
|
|
if (rows != null)
|
|
|
|
|
{
|
|
|
|
|
var format = model.Time.StartsWith("1") ? "H:mm" : (model.Time.StartsWith("7") ? "ddd" : "MMM-d");
|
|
|
|
|
labels = rows.Select(o => o.Timestamp.Value).Select(o => o.AddHours(hours).ToString(format, new CultureInfo("zh-CN"))).ToList();
|
|
|
|
|
}
|
|
|
|
|
var response = new
|
|
|
|
|
{
|
|
|
|
|
datasets,
|
|
|
|
|
labels
|
|
|
|
|
};
|
|
|
|
|
return Ok(response);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
catch (Exception ex)
|
|
|
|
|
{
|
|
|
|
|
ex.PrintStack();
|
|
|
|
|
return Problem(ex.Message);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
private string GetColor(string key)
|
|
|
|
|
{
|
|
|
|
|
//var randomGen = new Random();
|
|
|
|
|
//var names = (KnownColor[])Enum.GetValues(typeof(KnownColor));
|
|
|
|
|
//var randomColorName = names[randomGen.Next(names.Length)];
|
|
|
|
|
//var randomColor = Color.FromKnownColor(randomColorName);
|
|
|
|
|
//return randomColor.Name;
|
|
|
|
|
if (key == "Humidity")
|
|
|
|
|
{
|
|
|
|
|
return Color.FromKnownColor(KnownColor.Green).Name;
|
|
|
|
|
}
|
|
|
|
|
else if (key == "Electricity")
|
|
|
|
|
{
|
|
|
|
|
return Color.FromKnownColor(KnownColor.Red).Name;
|
|
|
|
|
}
|
|
|
|
|
else if (key == "Light")
|
|
|
|
|
{
|
|
|
|
|
return Color.FromKnownColor(KnownColor.Orange).Name;
|
|
|
|
|
}
|
|
|
|
|
return Color.FromKnownColor(KnownColor.DarkBlue).Name;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
