iot/projects/IoTCenter/Api/DeviceController.cs

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 IoTCenter.Api.Controllers
{
    [ApiVersion("1.0")]
    [Route("api/v{version:apiVersion}/[controller]/[action]")]
    [ApiController]
    public class DeviceController : ControllerBase
    {
        private readonly IConfiguration _cfg;
        private readonly IRepository<Device> _deviceRepo;

        public DeviceController(IConfiguration cfg,
            IRepository<Device> deviceRepo)
        {
            this._cfg = cfg;
            this._deviceRepo = deviceRepo;
        }

        [HttpPost]
        public ActionResult GetDevice([Required]string number)
        {
            try
            {
                var model = this._deviceRepo.ReadOnlyTable()
                    .Include(o => o.Data)
                    .Include(o => o.Product)
                    .ThenInclude(o => o.Apis)
                    .ThenInclude(o => o.Parameters)
                    .Where(o => o.Number == number)
                    .FirstOrDefault();
                model.Data = model.Data.OrderBy(o => o.Key).ToList();
                return Ok(model);
            }
            catch (Exception ex)
            {
                ex.PrintStack();
                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 days = Convert.ToInt32(model.Time.TrimEnd('d'));
                var group = days == 1 ? "1m" : (days == 7 ? "10m" : "1h");
                var query = $"select last({model.Key}) from {measurementName} where time>now() - {days}d and DeviceNumber = '{model.Number}' group by time({group}) fill(none)";
                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("last")).ToList() : new List<object>(),
                    backgroundColor = this.GetColor(data.Key),
                    fill = false
                });
                if (rows != null)
                {
                    labels = rows.Select(o => o.Timestamp.Value).Select(o => o.AddHours(hours).ToString("MMM-d H:mm", 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;
        }
    }
}