473 lines
16 KiB
C#
473 lines
16 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Text.Json;
|
||
using System.Threading.Tasks;
|
||
using Common;
|
||
using CommonEntity;
|
||
using IotManager.Common;
|
||
using LogCap.Common;
|
||
using Microsoft.AspNetCore.Authorization;
|
||
using Microsoft.AspNetCore.Http;
|
||
using Microsoft.AspNetCore.Mvc;
|
||
using Microsoft.EntityFrameworkCore;
|
||
using Microsoft.VisualBasic;
|
||
using MySQLAccess.PGModels;
|
||
using NLog;
|
||
using NPOI.OpenXmlFormats.Dml;
|
||
using Proto.Extensions;
|
||
using RestSharp;
|
||
using ViewModels;
|
||
|
||
namespace IotManager.Controllers
|
||
{
|
||
[Route("api/[controller]/[action]")]
|
||
[ApiController]
|
||
public class DeviceinfoesController : ControllerBase
|
||
{
|
||
private readonly Logger _logger = LogManager.GetCurrentClassLogger();
|
||
private readonly PostgresContext _context;
|
||
|
||
public DeviceinfoesController(PostgresContext context)
|
||
{
|
||
_context = context;
|
||
}
|
||
|
||
// GET: api/Deviceinfoes
|
||
[HttpPost()]
|
||
public async Task<ReturnInfo> GetDeviceinfos(QueryAll_Or_Single Q)
|
||
{
|
||
ReturnInfo r = new ReturnInfo();
|
||
try
|
||
{
|
||
if (Q.IsAll)
|
||
{
|
||
r.isok = true;
|
||
r.response = await _context.Deviceinfos.ToListAsync();
|
||
}
|
||
else
|
||
{
|
||
var deviceinfo = await _context.Deviceinfos.FindAsync(Q.ID);
|
||
if (deviceinfo == null)
|
||
{
|
||
r.isok = false;
|
||
r.message = "找不到此数据";
|
||
}
|
||
r.isok = true;
|
||
r.response = deviceinfo;
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
r.isok = false;
|
||
r.message = ex.Message;
|
||
}
|
||
return r;
|
||
|
||
}
|
||
|
||
[HttpPost()]
|
||
public async Task<ReturnInfo> GetAllBatchFlag(QueryMachineType S)
|
||
{
|
||
ReturnInfo r = new ReturnInfo();
|
||
try
|
||
{
|
||
int one = S.MachineType;
|
||
var st = S.StartTime;
|
||
var et = S.EndTime;
|
||
var ST = DateTime.Parse(st);
|
||
var ET = DateTime.Parse(et);
|
||
|
||
var data = await _context.Deviceinfos.Where(A => A.MachineType == one && A.CreateTime > ST && A.CreateTime <= ET)
|
||
.GroupBy(d => d.ExcelBatchFlag)
|
||
.Select(g => new
|
||
{
|
||
ExcelBatchFlag = g.Key.ToString(),
|
||
CreateTime = g.Select(x => x.CreateTime).FirstOrDefault(),
|
||
Count = g.Count()
|
||
})
|
||
.ToListAsync();
|
||
r.isok = true;
|
||
r.response = data;
|
||
return r;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
r.isok = false;
|
||
r.response = ex.Message;
|
||
}
|
||
return r;
|
||
}
|
||
|
||
[Authorize()]
|
||
[HttpPost()]
|
||
public async Task<ReturnInfo> GetDeviceinfosByBatchFlag(Dictionary<string, string> Q)
|
||
{
|
||
ReturnInfo r = new ReturnInfo();
|
||
try
|
||
{
|
||
string batchflag = Q["FileBatchFlag"];
|
||
long NNN = 0L;
|
||
long.TryParse(batchflag, out NNN);
|
||
var data = from a in _context.Deviceinfos
|
||
join b in _context.EmqxLogininfos
|
||
on a.Uuid equals b.DeviceUuid
|
||
into DeviceInfo
|
||
from d in DeviceInfo.DefaultIfEmpty()
|
||
where a.ExcelBatchFlag == NNN
|
||
select new { a.DeviceName, a.OrderNo, a.ClientId, a.SecretKey, a.Remark, d.PassWord };
|
||
|
||
var data1 = await data.Select(A => new DeviceInfoResponse
|
||
{
|
||
DeviceName = A.DeviceName,
|
||
MO = A.OrderNo,
|
||
ClientID = A.ClientId,
|
||
MQTT_Login_Password = A.PassWord,
|
||
Key = A.SecretKey,
|
||
Remark = A.Remark
|
||
}).ToListAsync();
|
||
r.isok = true;
|
||
r.response = data1;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
r.isok = false;
|
||
r.response = ex.Message;
|
||
}
|
||
return r;
|
||
}
|
||
|
||
[Authorize()]
|
||
[HttpPost()]
|
||
public async Task<ReturnInfo> EditDeviceinfo(Deviceinfo deviceinfo)
|
||
{
|
||
ReturnInfo r = new ReturnInfo();
|
||
try
|
||
{
|
||
if (!DeviceinfoExists(deviceinfo.ClientId))
|
||
{
|
||
r.isok = false;
|
||
r.message = "not found";
|
||
return r;
|
||
}
|
||
|
||
_context.Entry(deviceinfo).State = EntityState.Modified;
|
||
await _context.SaveChangesAsync();
|
||
|
||
r.isok = true;
|
||
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
r.isok = false;
|
||
r.message = ex.Message;
|
||
}
|
||
return r;
|
||
}
|
||
|
||
public string GetId(string device_name, string uuid)
|
||
{
|
||
string NNN = PasswordGenerator.Generate(16);
|
||
//string data = string.Format("inhaos_{0}_{1}_{2}", device_name, uuid, NNN);
|
||
//// 密钥，用于生成MAC
|
||
//string key = "[secNret)Key#&!";
|
||
//// 计算MAC
|
||
//byte[] mac = Base64.ComputeHMACSHA256(data, key);
|
||
//string str = Convert.ToBase64String(mac);
|
||
return NNN;
|
||
}
|
||
|
||
public record DeviceInfoRequest
|
||
{
|
||
public int id { get; set; }
|
||
public string DeviceName { get; set; }
|
||
public string MO { get; set; }
|
||
public int MachineType { get; set; }
|
||
public string Remark { get; set; }
|
||
}
|
||
public record DeviceInfoResponse
|
||
{
|
||
public string? DeviceName { get; set; }
|
||
public string? MO { get; set; }
|
||
public long? ClientID { get; set; }
|
||
public string? MQTT_Login_Password { get; set; }
|
||
public string? Key { get; set; }
|
||
public string? Remark { get; set; }
|
||
}
|
||
public record IdFilter
|
||
{
|
||
public int id { get; set; }
|
||
public string UUID { get; set; }
|
||
}
|
||
|
||
/// <summary>
|
||
/// 设备查询参数
|
||
/// </summary>
|
||
public class DeviceQueryParams
|
||
{
|
||
public int MachineType { get; set; }
|
||
public string Mcu_Uuid { get; set; }
|
||
public int? Brandld { get; set; }
|
||
}
|
||
|
||
|
||
public class UserData
|
||
{
|
||
public string username { get; set; }
|
||
public string password { get; set; }
|
||
}
|
||
|
||
[HttpPost()]
|
||
public async Task<string> SendHttpData(List<UserData> userdata)
|
||
{
|
||
string resp = "";
|
||
try
|
||
{
|
||
resp = await RedisWriter(userdata);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
_logger.Error(ex.Message);
|
||
}
|
||
return resp;
|
||
}
|
||
|
||
private async Task<string> RedisWriter(List<UserData> userdata)
|
||
{
|
||
RestClient client1 = new RestClient("http://iot-manage.uts-data.com:5001");
|
||
string ti = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
|
||
var request1 = new RestRequest("/api/Values/SetChache", Method.Post);
|
||
request1.AddJsonBody(userdata);
|
||
var re = await client1.ExecuteAsync(request1);
|
||
string resp = re.Content;
|
||
_logger.Error("Redis缓存：" + resp);
|
||
return resp;
|
||
}
|
||
|
||
[Authorize()]
|
||
[HttpPost]
|
||
public async Task<ReturnInfo> AddDeviceinfo(List<DeviceInfoRequest> List_LLL)
|
||
{
|
||
ReturnInfo returnInfo = new ReturnInfo();
|
||
|
||
try
|
||
{
|
||
|
||
var QQQ = List_LLL.Select(A => A.DeviceName);
|
||
var q1 = _context.Deviceinfos.Any(A => QQQ.Contains(A.DeviceName));
|
||
if (q1)
|
||
{
|
||
returnInfo.isok = false;
|
||
returnInfo.message = "设备名字重复，不可导入";
|
||
return returnInfo;
|
||
}
|
||
var worker = new IdWorker(31, 30);
|
||
long filebatch = worker.nextId();
|
||
List<UserData> lll = new List<UserData>();
|
||
_context.Database.BeginTransaction();
|
||
var DT = DateTime.Now;
|
||
var LT = Tools.ToUnixTimestampBySeconds(DT);
|
||
|
||
List<Deviceinfo> device_list = new List<Deviceinfo>();
|
||
List<EmqxLogininfo> login_list = new List<EmqxLogininfo>();
|
||
foreach (var LLL in List_LLL)
|
||
{
|
||
UserData u = new UserData();
|
||
var LLL1 = new Deviceinfo();
|
||
var uuid = Guid.NewGuid().ToString("N");
|
||
|
||
LLL1.Uuid = uuid;
|
||
LLL1.DeviceName = LLL.DeviceName;
|
||
LLL1.OrderNo = LLL.MO;
|
||
LLL1.MachineType = LLL.MachineType;
|
||
|
||
LLL1.SecretKey = PasswordGenerator.Generate(16);
|
||
LLL1.Remark = LLL.Remark;
|
||
LLL1.ExcelBatchFlag = filebatch;
|
||
|
||
|
||
LLL1.CreateTime = DT;
|
||
LLL1.UpdateTime = DT;
|
||
|
||
LLL1.CreateTimeUnix = LT;
|
||
LLL1.UpdateTimeUnix = LT;
|
||
|
||
device_list.Add(LLL1);
|
||
|
||
// 如果 是MQTT才会
|
||
if (LLL.MachineType != 1)
|
||
{
|
||
EmqxLogininfo l = new EmqxLogininfo();
|
||
l.DeviceUuid = uuid;
|
||
l.UserName = LLL.DeviceName;
|
||
l.PassWord = GetId(l.UserName, uuid);
|
||
l.UpdateTime = DT;
|
||
l.UpdateTimeUnix = LT;
|
||
l.CreateTime = DT;
|
||
l.CreateTimeUnix = LT;
|
||
login_list.Add(l);
|
||
|
||
u.username = LLL1.DeviceName;
|
||
u.password = l.PassWord;
|
||
lll.Add(u);
|
||
}
|
||
|
||
//_context.EmqxLogininfos.Add(l);
|
||
|
||
}
|
||
|
||
_context.Deviceinfos.AddRange(device_list);
|
||
_context.EmqxLogininfos.AddRange(login_list);
|
||
_context.SaveChanges();
|
||
|
||
if (lll.Count > 0)
|
||
{
|
||
string tr = await RedisWriter(lll);
|
||
if (!string.IsNullOrEmpty(tr))
|
||
{
|
||
var rest = JsonSerializer.Deserialize<ReturnInfo>(tr);
|
||
if (rest?.isok == false)
|
||
{
|
||
throw new Exception("Redis写入失败");
|
||
}
|
||
}
|
||
}
|
||
_context.Database.CommitTransaction();
|
||
|
||
returnInfo.response = filebatch.ToString();
|
||
returnInfo.isok = true;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
returnInfo.isok = false;
|
||
returnInfo.message = ex.Message;
|
||
}
|
||
|
||
return returnInfo;
|
||
}
|
||
|
||
[HttpPost()]
|
||
public async Task<ReturnInfo> DeleteDeviceinfo(Dictionary<string, string> data)
|
||
{
|
||
ReturnInfo r = new ReturnInfo();
|
||
try
|
||
{
|
||
string id = data["id"];
|
||
var deviceinfo = await _context.Deviceinfos.FindAsync(id);
|
||
if (deviceinfo == null)
|
||
{
|
||
r.isok = false;
|
||
r.message = "not found this data";
|
||
}
|
||
|
||
_context.Deviceinfos.Remove(deviceinfo);
|
||
await _context.SaveChangesAsync();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
r.isok = false;
|
||
r.isok = true;
|
||
}
|
||
return r;
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 条件查询接口 - 根据MachineType、UUID和Brandld查询唯一记录
|
||
/// </summary>
|
||
/// <param name="queryParams">查询参数</param>
|
||
/// <returns>查询结果</returns>
|
||
[HttpPost]
|
||
public async Task<ReturnInfo> GetDeviceByCondition(DeviceQueryParams queryParams)
|
||
{
|
||
ReturnInfo r = new();
|
||
try
|
||
{
|
||
var query = _context.Deviceinfos
|
||
.Where(d => d.MachineType == queryParams.MachineType && d.McuUuid.Equals(queryParams.Mcu_Uuid));
|
||
|
||
// 如果Brandld不为空，则添加Brandld条件
|
||
if (queryParams.Brandld != null)
|
||
{
|
||
query = query.Where(d => d.Brandld == queryParams.Brandld);
|
||
}
|
||
var ddd = query.ToList();
|
||
var deviceinfo = await query.FirstOrDefaultAsync();
|
||
r.isok = true;
|
||
r.response = deviceinfo;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
r.isok = false;
|
||
r.message = ex.Message;
|
||
}
|
||
return r;
|
||
}
|
||
|
||
private bool DeviceinfoExists(long id)
|
||
{
|
||
return _context.Deviceinfos.Any(e => e.ClientId == id);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 条件查询并修改接口
|
||
/// </summary>
|
||
/// <param name="queryParams">查询参数</param>
|
||
/// <returns>查询或更新后的记录</returns>
|
||
[HttpPost]
|
||
public async Task<ReturnInfo> GetOrUpdateDevice(DeviceQueryParams queryParams)
|
||
{
|
||
ReturnInfo r = new();
|
||
try
|
||
{
|
||
// 第一步：根据条件查询
|
||
var query = _context.Deviceinfos
|
||
.Where(d => d.MachineType == queryParams.MachineType && d.McuUuid.Equals(queryParams.Mcu_Uuid));
|
||
|
||
// 如果Brandld不为空，则添加Brandld条件
|
||
if (queryParams.Brandld != null)
|
||
{
|
||
query = query.Where(d => d.Brandld == queryParams.Brandld);
|
||
}
|
||
|
||
var deviceinfo = await query.FirstOrDefaultAsync();
|
||
|
||
if (deviceinfo == null)
|
||
{
|
||
// 第二步：查询ClientId最小，MachineType匹配且Uuid为空的记录
|
||
var minClientIdQuery = _context.Deviceinfos
|
||
.Where(d => d.MachineType == queryParams.MachineType && string.IsNullOrEmpty(d.McuUuid))
|
||
.OrderBy(d => d.ClientId);
|
||
|
||
var minClientIdDevice = await minClientIdQuery.FirstOrDefaultAsync();
|
||
|
||
if (minClientIdDevice != null)
|
||
{
|
||
// 第三步：更新记录
|
||
minClientIdDevice.McuUuid = queryParams.Mcu_Uuid;
|
||
minClientIdDevice.Brandld = queryParams.Brandld;
|
||
minClientIdDevice.UpdateTime = DateTime.Now;
|
||
minClientIdDevice.UpdateTimeUnix = Tools.ToUnixTimestampBySeconds(DateTime.Now);
|
||
|
||
_context.Deviceinfos.Update(minClientIdDevice);
|
||
await _context.SaveChangesAsync();
|
||
|
||
// 第四步：查询更新后的记录
|
||
deviceinfo = await _context.Deviceinfos.FindAsync(minClientIdDevice.ClientId);
|
||
}
|
||
}
|
||
|
||
r.isok = true;
|
||
r.response = deviceinfo;
|
||
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
r.isok = false;
|
||
r.message = ex.Message;
|
||
}
|
||
return r;
|
||
}
|
||
}
|
||
}
|