280 lines
9.7 KiB
C#
280 lines
9.7 KiB
C#
using AutoMapper;
|
||
using LangGuan.Command.AutoMapper;
|
||
using LangGuan.Command.Model;
|
||
using LangGuan.Command.Model.EntityModel;
|
||
using Microsoft.Extensions.Configuration;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Diagnostics;
|
||
using System.IO;
|
||
using System.Linq;
|
||
using System.Linq.Expressions;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace LangGuan.Services
|
||
{
|
||
/// <summary>
|
||
///
|
||
/// </summary>
|
||
public class RadarService : BaseService<Radar>
|
||
{
|
||
private readonly IMapper _mapper;
|
||
private DeviceSerive _deviceSerive;
|
||
private RadarItemService _radarItemService;
|
||
/// <summary>
|
||
///
|
||
/// </summary>
|
||
/// <param name="config"></param>
|
||
/// <param name="mapper"></param>
|
||
/// <param name="deviceSerive"></param>
|
||
/// <param name="radarItemService"></param>
|
||
public RadarService(IConfiguration config, IMapper mapper,
|
||
DeviceSerive deviceSerive, RadarItemService radarItemService) : base(config, nameof(Radar))
|
||
{
|
||
_mapper = mapper;
|
||
_deviceSerive = deviceSerive;
|
||
_radarItemService = radarItemService;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 新加数据
|
||
/// </summary>
|
||
/// <param name="request"></param>
|
||
/// <returns></returns>
|
||
public async Task<ApiResult> Add(RadarView request)
|
||
{
|
||
var entity = _mapper.Map<Radar>(request);
|
||
await _deviceSerive.Add(new Device()
|
||
{
|
||
deviceId = request.deviceId,
|
||
deviceIp = request.deviceIp,
|
||
state = 1
|
||
});
|
||
|
||
//数据量过大，这里要分开存储
|
||
var result = await base.CreateAsync(entity);
|
||
List<RadarItems> items = new List<RadarItems>();
|
||
foreach (var item in request.Signal)
|
||
{
|
||
items.Add(new RadarItems() { pid = result.Id, Signal = item });
|
||
}
|
||
await _radarItemService.AddMany(items);
|
||
return new ApiResult() { code = 0, msg = "" };
|
||
}
|
||
/// <summary>
|
||
/// 首页用图
|
||
/// </summary>
|
||
/// <param name="n"></param>
|
||
/// <returns></returns>
|
||
public async Task<List<object>> Top(int n)
|
||
{
|
||
Expression<Func<Radar, bool>> exp = filter => true;
|
||
var query = await base.GetListWithExp(exp);
|
||
var items = query.OrderByDescending(s => s.AcqTime).Take(n)
|
||
.Select(s => new
|
||
{
|
||
s.Id,
|
||
s.deviceId,
|
||
s.AcqTime,
|
||
s.DataPointNum,
|
||
s.DetectRange,
|
||
s.ExposureTime,
|
||
s.ScanAngle,
|
||
s.SystemBlind
|
||
}).ToList();
|
||
List<object> result = new List<object>();
|
||
Parallel.ForEach(items, async entry =>
|
||
{
|
||
result.Add(new
|
||
{
|
||
datetime = entry.AcqTime.AddHours(8).ToString("yyyy-MM-dd HH mm "),
|
||
items = await ConvertData(entry.DetectRange, entry.DataPointNum, entry.SystemBlind, entry.Id)
|
||
});
|
||
});
|
||
return result;
|
||
}
|
||
/// <summary>
|
||
///
|
||
/// </summary>
|
||
/// <param name="start"></param>
|
||
/// <param name="end"></param>
|
||
/// <returns></returns>
|
||
public async Task<ApiResult> GetList(DateTime start, DateTime end)
|
||
{
|
||
//Stopwatch stopwatch = new Stopwatch();
|
||
//var path = Path.Combine(Directory.GetCurrentDirectory(), "wwwroot", "radar", "Signal_2023.json");
|
||
//stopwatch.Start();
|
||
//FileStream fileStream = new FileStream(path, FileMode.Open);
|
||
//using (StreamReader reader = new StreamReader(fileStream))
|
||
//{
|
||
// string line = await reader.ReadToEndAsync();
|
||
//}
|
||
//stopwatch.Stop();
|
||
//Console.WriteLine("StreamReader:" + stopwatch.ElapsedMilliseconds);
|
||
//string txt = "";
|
||
//byte[] allBytes = null;
|
||
//byte[] buffer = new byte[1024];//一个1K的缓冲字节容器
|
||
//stopwatch.Reset();
|
||
//stopwatch.Start();
|
||
//using (MemoryStream ms = new MemoryStream())
|
||
//{
|
||
// using (FileStream fs = new FileStream(path, FileMode.Open, FileAccess.Read))
|
||
// {
|
||
// int positon = 0;
|
||
// while ((positon = await fs.ReadAsync(buffer, 0, buffer.Length)) > 0)
|
||
// {
|
||
// await ms.WriteAsync(buffer, 0, positon);
|
||
// }
|
||
// allBytes = ms.ToArray();
|
||
// }
|
||
|
||
//}
|
||
//if (null != allBytes)
|
||
//{
|
||
// //尝试将字节转成字符串
|
||
// txt = System.Text.Encoding.UTF8.GetString(allBytes);
|
||
// // this.richTextBox_Result.Text = txt;
|
||
|
||
//}
|
||
//var path1 = Path.Combine(Directory.GetCurrentDirectory(), "wwwroot", "radar", DateTime.Now.ToString("yyyy-MM-dd") + ".txt");
|
||
//using (FileStream fs = new FileStream(path1, FileMode.OpenOrCreate, FileAccess.Write))
|
||
//{
|
||
// await fs.WriteAsync(allBytes, 0, allBytes.Length);
|
||
//}
|
||
|
||
//// string[] txtToArray = txt.Split('\r');
|
||
//// ReadData_List.Add(txtToArray);
|
||
//stopwatch.Stop();
|
||
//Console.WriteLine("MemoryStream" + stopwatch.ElapsedMilliseconds);
|
||
|
||
end = end.AddDays(1);
|
||
Expression<Func<Radar, bool>> exp = filter => filter.AcqTime >= start && filter.AcqTime < end;
|
||
var query = await base.GetListWithExp(exp);
|
||
var items = query.OrderByDescending(s => s.AcqTime)
|
||
.Select(s => new
|
||
{
|
||
s.Id,
|
||
s.deviceId,
|
||
s.AcqTime,
|
||
s.DataPointNum,
|
||
s.DetectRange,
|
||
s.ExposureTime,
|
||
s.ScanAngle,
|
||
s.SystemBlind
|
||
}).ToList();
|
||
List<object> result = new List<object>();
|
||
Parallel.ForEach(items, async entry =>
|
||
{
|
||
result.Add(new
|
||
{
|
||
datetime = entry.AcqTime.ToString("yyyy-MM-dd HH mm "),
|
||
items = await ConvertData(entry.DetectRange, entry.DataPointNum, entry.SystemBlind, entry.Id)
|
||
});
|
||
});
|
||
//var result = items.Select(async s => new
|
||
//{
|
||
// datetime = s.AcqTime.AddHours(8).ToString("yyyy-MM-dd HH mm "),
|
||
// items = await ConvertData(s.DetectRange, s.DataPointNum, s.SystemBlind, s.Id)
|
||
//}).ToList();
|
||
|
||
return new ApiResult()
|
||
{
|
||
code = 0,
|
||
data = new { items = result }
|
||
};
|
||
}
|
||
private async Task<List<radarModel>> ConvertData(double rang, double DataPointNum, double SystemBlind, string id)
|
||
{
|
||
|
||
// var count = await _radarItemService.getcount(id);
|
||
List<radarModel> radarModels = new List<radarModel>();
|
||
//里面先取度数
|
||
//取1000米的数， 1000/3
|
||
List<IEnumerable<double>> vs = new List<IEnumerable<double>>();
|
||
vs = await _radarItemService.GetByPid(id);
|
||
|
||
|
||
//角度，
|
||
var t1 = convertangle();
|
||
var t2 = convertDistance(rang, SystemBlind);
|
||
for (int i = 0; i < t1.Length; i++)
|
||
{
|
||
var temp = (vs[i]).ToList();
|
||
int m = 0;
|
||
foreach (var v in t2)
|
||
{
|
||
//如果有第一个，就直接取，
|
||
m = v == SystemBlind ? m : (int)((v - SystemBlind) / 3);
|
||
m = m == 0 ? m : m - 1;
|
||
radarModels.Add(new radarModel()
|
||
{
|
||
angle = t1[i],
|
||
distance = v,
|
||
value = Math.Round(m > temp.Count() ? temp[temp.Count() - 1] : temp[m], 2)
|
||
});
|
||
}
|
||
}
|
||
return radarModels;
|
||
}
|
||
private int[] convertangle()
|
||
{
|
||
List<int> reuslt = new List<int>();
|
||
int i = 0;
|
||
while (i < 360)
|
||
{
|
||
reuslt.Add(i);
|
||
i = i + 10;
|
||
|
||
}
|
||
return reuslt.ToArray();
|
||
|
||
}
|
||
/// <summary>
|
||
/// 计算圈数
|
||
/// </summary>
|
||
/// <param name="DetectRange"></param>
|
||
/// <param name="SystemBlind"></param>
|
||
/// <returns></returns>
|
||
private int[] convertDistance(double DetectRange, double SystemBlind)
|
||
{
|
||
List<int> reuslt = new List<int>();
|
||
reuslt.Add((int)SystemBlind);
|
||
var d1 = DetectRange - SystemBlind;
|
||
int n = 1;
|
||
while (d1 - 1000 > 0)
|
||
{
|
||
if (n == 1)
|
||
{
|
||
reuslt.Add(1000);
|
||
}
|
||
else
|
||
{
|
||
reuslt.Add(n * 1000);
|
||
}
|
||
d1 = d1 - 1000;
|
||
n++;
|
||
}
|
||
reuslt.Add((int)DetectRange);
|
||
return reuslt.ToArray();
|
||
}
|
||
/// <summary>
|
||
/// 返回结果
|
||
/// </summary>
|
||
public class radarModel
|
||
{
|
||
/// <summary>
|
||
/// 角度
|
||
/// </summary>
|
||
public int angle { get; set; }
|
||
/// <summary>
|
||
/// 距离
|
||
/// </summary>
|
||
public int distance { get; set; }
|
||
/// <summary>
|
||
/// 结果
|
||
/// </summary>
|
||
public double value { get; set; }
|
||
}
|
||
}
|
||
}
|