You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
871 lines
36 KiB
C#
871 lines
36 KiB
C#
using OpenAuth.App.BaseApp.Base;
|
|
using OpenAuth.Repository.Domain;
|
|
using OpenAuth.Repository;
|
|
using System.Text;
|
|
using OpenAuth.App.Interface;
|
|
using SqlSugar;
|
|
using Infrastructure;
|
|
using Infrastructure.Helpers;
|
|
using System.Text.Json;
|
|
using OpenAuth.App.ServiceApp.Response;
|
|
using Microsoft.Extensions.Configuration;
|
|
using OpenAuth.App.ServiceApp.DroneDocking.Request;
|
|
using DocumentFormat.OpenXml.Office.CustomUI;
|
|
using DocumentFormat.OpenXml.EMMA;
|
|
using OpenAuth.App.ServiceApp.DroneDocking.Response;
|
|
using DocumentFormat.OpenXml.Math;
|
|
using static Microsoft.Extensions.Logging.EventSource.LoggingEventSource;
|
|
using DocumentFormat.OpenXml.Drawing.Charts;
|
|
|
|
|
|
namespace OpenAuth.App.ServiceApp.DroneDocking
|
|
{
|
|
public class DroneDockApp : SqlSugarBaseApp<DroneDocktask, SugarDbContext>
|
|
{
|
|
private EncryptionHelper _helper;
|
|
private IConfiguration configuration;
|
|
public DroneDockApp(EncryptionHelper helper, IConfiguration configuration, ISugarUnitOfWork<SugarDbContext> unitWork, ISimpleClient<DroneDocktask> repository, IAuth auth) : base(unitWork, repository, auth)
|
|
{
|
|
_helper = helper;
|
|
this.configuration = configuration;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 无人机机场接口注册更新
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
/// <returns></returns>
|
|
public async Task<Response<string>> RegistService(AirPortRegistReq req )
|
|
{
|
|
Response<string> Response = new Response<string>();
|
|
|
|
var handler = new HttpClientHandler();
|
|
// 如果需要忽略服务器证书错误（仅测试环境）
|
|
handler.ServerCertificateCustomValidationCallback = (sender, cert, chain, sslPolicyErrors) => true;
|
|
using (var client = new HttpClient())
|
|
{
|
|
try
|
|
{
|
|
string url = configuration.GetSection("DroneDocking:Url").Value + "/droneAirport/RegistService";
|
|
string x_lc_secret = _helper.getxseret();
|
|
string centercode = "UAV32_LJY2FPMYDE6UDES3P3ZD7V3IKQ";
|
|
string x_token = _helper.GetToken(centercode);
|
|
|
|
// 序列化为 JSON 字符串
|
|
string json = JsonSerializer.Serialize(req);
|
|
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(json);
|
|
|
|
var encryptedData = _helper.Encrypt(bytes);
|
|
// 创建请求体
|
|
var httpContent = new StringContent(encryptedData, Encoding.UTF8, "application/json");
|
|
|
|
// 添加请求头
|
|
client.DefaultRequestHeaders.Add("x-lc-secret", x_lc_secret);
|
|
client.DefaultRequestHeaders.Add("x-lc-token", x_token);
|
|
|
|
//发送请求
|
|
HttpResponseMessage response = await client.PostAsync(url, httpContent);
|
|
response.EnsureSuccessStatusCode();
|
|
|
|
// 获取响应头中的 x_cl_screte 参数
|
|
string resx_cl_screte = GetHeaderValue(response, "x-lc-secret");
|
|
|
|
// 读取响应内容并反序列化
|
|
string responseBody = await response.Content.ReadAsStringAsync();
|
|
var result = JsonSerializer.Deserialize<ReciveData<string>>(responseBody);
|
|
|
|
//解密数据
|
|
byte[] resbytesx = Convert.FromBase64String(resx_cl_screte);
|
|
byte[] resdatabytes = Convert.FromBase64String(result?.data);
|
|
string data = _helper.Decrypt(resbytesx, resdatabytes);
|
|
|
|
Response.Result = data;
|
|
Response.Message = result.message;
|
|
Response.Code = result.code;
|
|
}
|
|
catch (HttpRequestException e)
|
|
{
|
|
Console.WriteLine("\nException Caught!");
|
|
Console.WriteLine("Message :{0} ", e.Message);
|
|
Response.Result = "连接错误";
|
|
}
|
|
}
|
|
|
|
return Response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 无人机机场设备注册/更新
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
/// <returns></returns>
|
|
public async Task<Response<string>> AddDevice(AddDeviceReq req)
|
|
{
|
|
Response<string> Response = new Response<string>();
|
|
|
|
var handler = new HttpClientHandler();
|
|
// 如果需要忽略服务器证书错误（仅测试环境）
|
|
handler.ServerCertificateCustomValidationCallback = (sender, cert, chain, sslPolicyErrors) => true;
|
|
using (var client = new HttpClient())
|
|
{
|
|
try
|
|
{
|
|
string url = configuration.GetSection("DroneDocking:Url").Value+ "/droneAirport/addDevice";
|
|
string x_lc_secret = _helper.getxseret();
|
|
string centercode = "UAV32_LJY2FPMYDE6UDES3P3ZD7V3IKQ";
|
|
string x_token = _helper.GetToken(centercode);
|
|
|
|
// 序列化为 JSON 字符串
|
|
string json = JsonSerializer.Serialize(req);
|
|
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(json);
|
|
|
|
var encryptedData = _helper.Encrypt(bytes);
|
|
// 创建请求体
|
|
var httpContent = new StringContent(encryptedData, Encoding.UTF8, "application/json");
|
|
|
|
// 添加请求头
|
|
client.DefaultRequestHeaders.Add("x-lc-secret", x_lc_secret);
|
|
client.DefaultRequestHeaders.Add("x-lc-token", x_token);
|
|
|
|
//发送请求
|
|
HttpResponseMessage response = await client.PostAsync(url, httpContent);
|
|
response.EnsureSuccessStatusCode();
|
|
|
|
// 获取响应头中的 x_cl_screte 参数
|
|
string resx_cl_screte = GetHeaderValue(response, "x-lc-secret");
|
|
|
|
// 读取响应内容并反序列化
|
|
string responseBody = await response.Content.ReadAsStringAsync();
|
|
var result = JsonSerializer.Deserialize<ReciveData<string>>(responseBody);
|
|
|
|
//解密数据
|
|
byte[] resbytesx = Convert.FromBase64String(resx_cl_screte);
|
|
byte[] resdatabytes = Convert.FromBase64String(result?.data);
|
|
string data = _helper.Decrypt(resbytesx, resdatabytes);
|
|
|
|
Response.Result = data;
|
|
Response.Message = result.message;
|
|
Response.Code = result.code;
|
|
}
|
|
catch (HttpRequestException e)
|
|
{
|
|
Console.WriteLine("\nException Caught!");
|
|
Console.WriteLine("Message :{0} ", e.Message);
|
|
Response.Result = "连接错误";
|
|
}
|
|
}
|
|
|
|
return Response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 无人机机场授权
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
/// <returns></returns>
|
|
public async Task<Response<string>> Authorization(AuthorizationReq req)
|
|
{
|
|
Response<string> Response = new Response<string>();
|
|
|
|
var handler = new HttpClientHandler();
|
|
// 如果需要忽略服务器证书错误（仅测试环境）
|
|
handler.ServerCertificateCustomValidationCallback = (sender, cert, chain, sslPolicyErrors) => true;
|
|
using (var client = new HttpClient())
|
|
{
|
|
try
|
|
{
|
|
string url = configuration.GetSection("DroneDocking:Url").Value + "/droneAirport/authorization";
|
|
string x_lc_secret = _helper.getxseret();
|
|
string centercode = "UAV32_LJY2FPMYDE6UDES3P3ZD7V3IKQ";
|
|
string x_token = _helper.GetToken(centercode);
|
|
|
|
// 序列化为 JSON 字符串
|
|
string json = JsonSerializer.Serialize(req);
|
|
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(json);
|
|
|
|
var encryptedData = _helper.Encrypt(bytes);
|
|
// 创建请求体
|
|
var httpContent = new StringContent(encryptedData, Encoding.UTF8, "application/json");
|
|
|
|
// 添加请求头
|
|
client.DefaultRequestHeaders.Add("x-lc-secret", x_lc_secret);
|
|
client.DefaultRequestHeaders.Add("x-lc-token", x_token);
|
|
|
|
//发送请求
|
|
HttpResponseMessage response = await client.PostAsync(url, httpContent);
|
|
response.EnsureSuccessStatusCode();
|
|
|
|
// 获取响应头中的 x_cl_screte 参数
|
|
string resx_cl_screte = GetHeaderValue(response, "x-lc-secret");
|
|
|
|
// 读取响应内容并反序列化
|
|
string responseBody = await response.Content.ReadAsStringAsync();
|
|
var result = JsonSerializer.Deserialize<ReciveData<string>>(responseBody);
|
|
|
|
//解密数据
|
|
byte[] resbytesx = Convert.FromBase64String(resx_cl_screte);
|
|
byte[] resdatabytes = Convert.FromBase64String(result?.data);
|
|
string data = _helper.Decrypt(resbytesx, resdatabytes);
|
|
|
|
Response.Result = data;
|
|
Response.Message = result.message;
|
|
Response.Code = result.code;
|
|
}
|
|
catch (HttpRequestException e)
|
|
{
|
|
Console.WriteLine("\nException Caught!");
|
|
Console.WriteLine("Message :{0} ", e.Message);
|
|
Response.Result = "连接错误";
|
|
}
|
|
}
|
|
|
|
return Response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 无人机机场授权
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
/// <returns></returns>
|
|
public async Task<Response<string>> Test(AirPortUpdateTaskReq req)
|
|
{
|
|
Response<string> Response = new Response<string>();
|
|
|
|
var handler = new HttpClientHandler();
|
|
// 如果需要忽略服务器证书错误（仅测试环境）
|
|
handler.ServerCertificateCustomValidationCallback = (sender, cert, chain, sslPolicyErrors) => true;
|
|
using (var client = new HttpClient())
|
|
{
|
|
try
|
|
{
|
|
string url = "http://localhost:10042/zhcfzx/droneAirport/updateTask";
|
|
string x_lc_secret = _helper.getxseret();
|
|
string centercode = "UAV32_LJY2FPMYDE6UDES3P3ZD7V3IKQ";
|
|
string x_token = "API32_HENJOZMPBYKEXNVLFMY3Y5W5SQ.1751622229582.fmCjIucQYyq4YZe4CnSStN/rHcwjZTxUsDuXeXJfrYn0bwoaV1/IW8mcFwtLw8JHjowvMJrmPyy/QZAhssxQCQ==";
|
|
|
|
// 序列化为 JSON 字符串
|
|
string json = JsonSerializer.Serialize(req);
|
|
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(json);
|
|
|
|
var encryptedData = _helper.Encrypt(bytes);
|
|
// 创建请求体
|
|
var httpContent = new StringContent(encryptedData, Encoding.UTF8, "application/json");
|
|
|
|
// 添加请求头
|
|
client.DefaultRequestHeaders.Add("x-lc-secret", x_lc_secret);
|
|
client.DefaultRequestHeaders.Add("x-lc-token", x_token);
|
|
|
|
//发送请求
|
|
HttpResponseMessage response = await client.PostAsync(url, httpContent);
|
|
response.EnsureSuccessStatusCode();
|
|
|
|
// 获取响应头中的 x_cl_screte 参数
|
|
string resx_cl_screte = GetHeaderValue(response, "x-lc-secret");
|
|
|
|
// 读取响应内容并反序列化
|
|
string responseBody = await response.Content.ReadAsStringAsync();
|
|
var result = JsonSerializer.Deserialize<ReciveData<string>>(responseBody);
|
|
|
|
//解密数据
|
|
byte[] resbytesx = Convert.FromBase64String(resx_cl_screte);
|
|
byte[] resdatabytes = Convert.FromBase64String(result?.data);
|
|
string data = _helper.Decrypt(resbytesx, resdatabytes);
|
|
|
|
Response.Result = data;
|
|
Response.Message = result.message;
|
|
Response.Code = result.code;
|
|
}
|
|
catch (HttpRequestException e)
|
|
{
|
|
Console.WriteLine("\nException Caught!");
|
|
Console.WriteLine("Message :{0} ", e.Message);
|
|
Response.Result = "连接错误";
|
|
}
|
|
}
|
|
|
|
return Response;
|
|
}
|
|
|
|
public async Task<Response<string>> Test1(string taskid)
|
|
{
|
|
Response<string> Response = new Response<string>();
|
|
|
|
var handler = new HttpClientHandler();
|
|
// 如果需要忽略服务器证书错误（仅测试环境）
|
|
handler.ServerCertificateCustomValidationCallback = (sender, cert, chain, sslPolicyErrors) => true;
|
|
using (var client = new HttpClient())
|
|
{
|
|
try
|
|
{
|
|
string url = $"http://localhost:10042/zhcfzx/droneAirport/cancelTask?taskid={taskid}";
|
|
//string x_lc_secret = _helper.getxseret();
|
|
string centercode = "UAV32_LJY2FPMYDE6UDES3P3ZD7V3IKQ";
|
|
string x_token = "API32_HENJOZMPBYKEXNVLFMY3Y5W5SQ.1751622229582.fmCjIucQYyq4YZe4CnSStN/rHcwjZTxUsDuXeXJfrYn0bwoaV1/IW8mcFwtLw8JHjowvMJrmPyy/QZAhssxQCQ==";
|
|
|
|
// 添加请求头
|
|
client.DefaultRequestHeaders.Add("x-lc-token", x_token);
|
|
|
|
//发送请求
|
|
HttpResponseMessage response = await client.GetAsync(url);
|
|
response.EnsureSuccessStatusCode();
|
|
|
|
// 获取响应头中的 x_cl_screte 参数
|
|
string resx_cl_screte = GetHeaderValue(response, "x-lc-secret");
|
|
|
|
// 读取响应内容并反序列化
|
|
string responseBody = await response.Content.ReadAsStringAsync();
|
|
var result = JsonSerializer.Deserialize<ReciveData<string>>(responseBody);
|
|
|
|
//解密数据
|
|
byte[] resbytesx = Convert.FromBase64String(resx_cl_screte);
|
|
byte[] resdatabytes = Convert.FromBase64String(result?.data);
|
|
string data = _helper.Decrypt(resbytesx, resdatabytes);
|
|
|
|
Response.Result = data;
|
|
Response.Message = result.message;
|
|
Response.Code = result.code;
|
|
}
|
|
catch (HttpRequestException e)
|
|
{
|
|
Console.WriteLine("\nException Caught!");
|
|
Console.WriteLine("Message :{0} ", e.Message);
|
|
Response.Result = "连接错误";
|
|
}
|
|
}
|
|
|
|
return Response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 无人机任务添加
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
/// <returns></returns>
|
|
public async Task<ResData> AddTask(string req,string secret)
|
|
{
|
|
ResData Response = new ResData();
|
|
|
|
//解密数据
|
|
byte[] secretbyte = Convert.FromBase64String(secret); //x-lc-secret
|
|
byte[] reqbyte = Convert.FromBase64String(req); //返回数据
|
|
string data = _helper.Decrypt(secretbyte, reqbyte);
|
|
|
|
//序列化返回数据并处理
|
|
var task = JsonSerializer.Deserialize<AirPortTaskReq>(data);
|
|
|
|
string ids = "";
|
|
foreach(var item in task.deviceid)
|
|
{
|
|
|
|
}
|
|
|
|
//task数据生成
|
|
DroneDocktask dt= new DroneDocktask();
|
|
dt.id=Guid.NewGuid().ToString();
|
|
dt.deviceid= string.Join(",", task.deviceid);
|
|
dt.bizidname=task.bizidname.ToString();
|
|
dt.taskid = task.taskid;
|
|
dt.taskname = task.taskname;
|
|
dt.datacode= task.datacode;
|
|
dt.state = 0;
|
|
dt.createtime = DateTime.Now;
|
|
|
|
//taskdetail数据生成
|
|
List<DroneDocktaskdetail> dalist= new List<DroneDocktaskdetail>();
|
|
if (task.tasklist.Count > 0 )
|
|
{
|
|
foreach(var item in task.tasklist)
|
|
{
|
|
DroneDocktaskdetail da= new DroneDocktaskdetail();
|
|
da.id = Guid.NewGuid().ToString();
|
|
da.taskid = dt.id;
|
|
da.bz=item.bz;
|
|
da.dkbh=item.dkbh;
|
|
da.dkfw=item.dkfw;
|
|
da.dkmj=item.dkmj;
|
|
da.dkmc=item.dkmc;
|
|
da.xzqdm=item.xzqdm;
|
|
da.zdkbh=item.zdkbh;
|
|
da.bsm=item.bsm;
|
|
da.dklx=item.dklx;
|
|
dalist.Add(da);
|
|
}
|
|
}
|
|
|
|
using (var uow = base.UnitWork.CreateContext())
|
|
{
|
|
//查询数据 检查是否有重复数据
|
|
var info = uow.DroneDocktask.AsQueryable().Where(r => r.taskid == task.taskid).First();
|
|
if (info != null)
|
|
{
|
|
//本地数据库数据添加
|
|
await uow.DroneDocktask.InsertAsync(dt);
|
|
await uow.DroneDocktaskdetail.InsertRangeAsync(dalist);
|
|
var flag = uow.Commit();
|
|
|
|
//返回数据
|
|
if (flag)
|
|
{
|
|
string x_lc_secret = _helper.getxseret();
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(dt.taskid);
|
|
var encryptedResData = _helper.Encrypt(bytes);
|
|
Response.Result = encryptedResData;
|
|
Response.Message = "无人机机场任务添加成功";
|
|
Response.Code = 200;
|
|
Response.Secret = x_lc_secret;
|
|
return Response;
|
|
}
|
|
else
|
|
{
|
|
string x_lc_secret = _helper.getxseret();
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(" ");
|
|
|
|
var encryptedResData = _helper.Encrypt(bytes);
|
|
Response.Result = encryptedResData;
|
|
Response.Message = "无人机机场任务添加失败";
|
|
Response.Code = 500;
|
|
Response.Secret = x_lc_secret;
|
|
return Response;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
string x_lc_secret = _helper.getxseret();
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(" ");
|
|
|
|
var encryptedResData = _helper.Encrypt(bytes);
|
|
Response.Result = encryptedResData;
|
|
Response.Message = "已存在相同taskid任务";
|
|
Response.Code = 500;
|
|
Response.Secret = x_lc_secret;
|
|
return Response;
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 无人机任务更新
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
/// <returns></returns>
|
|
public async Task<ResData> UpdateTask(string req, string secret)
|
|
{
|
|
ResData Response = new ResData();
|
|
|
|
//解密数据
|
|
byte[] secretbyte = Convert.FromBase64String(secret); //x-lc-secret
|
|
byte[] reqbyte = Convert.FromBase64String(req); //返回数据
|
|
string data = _helper.Decrypt(secretbyte, reqbyte);
|
|
|
|
//序列化返回数据并处理
|
|
var task = JsonSerializer.Deserialize<AirPortUpdateTaskReq>(data);
|
|
|
|
using (var uow = base.UnitWork.CreateContext())
|
|
{
|
|
//查询数据
|
|
var info=uow.DroneDocktask.AsQueryable().Where(r=>r.taskid==task.taskid).First();
|
|
if (info != null)
|
|
{
|
|
if (info.state == 0)
|
|
{
|
|
//taskdetail数据生成
|
|
List<DroneDocktaskdetail> dalist = new List<DroneDocktaskdetail>();
|
|
if (task.tasklist.Count > 0)
|
|
{
|
|
foreach (var item in task.tasklist)
|
|
{
|
|
DroneDocktaskdetail da = new DroneDocktaskdetail();
|
|
da.id = Guid.NewGuid().ToString();
|
|
da.taskid = info.id;
|
|
da.bz = item.bz;
|
|
da.dkbh = item.dkbh;
|
|
da.dkfw = item.dkfw;
|
|
da.dkmj = item.dkmj;
|
|
da.dkmc = item.dkmc;
|
|
da.xzqdm = item.xzqdm;
|
|
da.zdkbh = item.zdkbh;
|
|
da.bsm = item.bsm;
|
|
da.dklx = item.dklx;
|
|
dalist.Add(da);
|
|
}
|
|
}
|
|
await uow.DroneDocktaskdetail.DeleteAsync(r => r.taskid == info.taskid);
|
|
await uow.DroneDocktaskdetail.InsertRangeAsync(dalist);
|
|
var flag = uow.Commit();
|
|
|
|
//返回数据
|
|
if (flag)
|
|
{
|
|
string x_lc_secret = _helper.getxseret();
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(info.taskid);
|
|
var encryptedResData = _helper.Encrypt(bytes);
|
|
Response.Result = encryptedResData;
|
|
Response.Message = "无人机机场任务更新成功";
|
|
Response.Code = 200;
|
|
Response.Secret = x_lc_secret;
|
|
return Response;
|
|
}
|
|
else
|
|
{
|
|
string x_lc_secret = _helper.getxseret();
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(" ");
|
|
|
|
var encryptedResData = _helper.Encrypt(bytes);
|
|
Response.Result = encryptedResData;
|
|
Response.Message = "无人机机场任务更新失败";
|
|
Response.Code = 500;
|
|
Response.Secret = x_lc_secret;
|
|
return Response;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
string x_lc_secret = _helper.getxseret();
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(" ");
|
|
|
|
var encryptedResData = _helper.Encrypt(bytes);
|
|
Response.Result = encryptedResData;
|
|
Response.Message = "任务已开始执行，无法更新，请重新添加任务";
|
|
Response.Code = 500;
|
|
Response.Secret = x_lc_secret;
|
|
return Response;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
string x_lc_secret = _helper.getxseret();
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(" ");
|
|
|
|
var encryptedResData = _helper.Encrypt(bytes);
|
|
Response.Result = encryptedResData;
|
|
Response.Message = "未找到任务数据";
|
|
Response.Code = 500;
|
|
Response.Secret = x_lc_secret;
|
|
return Response;
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 取消任务
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
/// <returns></returns>
|
|
public async Task<ResData> CancelTask(string taskid)
|
|
{
|
|
ResData Response = new ResData();
|
|
|
|
using (var uow = base.UnitWork.CreateContext())
|
|
{
|
|
//查询数据
|
|
var info = uow.DroneDocktask.AsQueryable().Where(r => r.taskid == taskid).First();
|
|
if (info != null)
|
|
{
|
|
var flag = await uow.DroneDocktask.UpdateAsync(it => new DroneDocktask()
|
|
{
|
|
state=3
|
|
}, it => it.id == info.id);
|
|
|
|
//返回数据
|
|
if (uow.Commit())
|
|
{
|
|
string x_lc_secret = _helper.getxseret();
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(info.taskid);
|
|
var encryptedResData = _helper.Encrypt(bytes);
|
|
Response.Result = encryptedResData;
|
|
Response.Message = "无人机机场任务取消成功";
|
|
Response.Code = 200;
|
|
Response.Secret = x_lc_secret;
|
|
return Response;
|
|
}
|
|
else
|
|
{
|
|
string x_lc_secret = _helper.getxseret();
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(" ");
|
|
|
|
var encryptedResData = _helper.Encrypt(bytes);
|
|
Response.Result = encryptedResData;
|
|
Response.Message = "无人机机场任务取消失败";
|
|
Response.Code = 500;
|
|
Response.Secret = x_lc_secret;
|
|
return Response;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
string x_lc_secret = _helper.getxseret();
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(" ");
|
|
|
|
var encryptedResData = _helper.Encrypt(bytes);
|
|
Response.Result = encryptedResData;
|
|
Response.Message = "未找到任务数据";
|
|
Response.Code = 500;
|
|
Response.Secret = x_lc_secret;
|
|
return Response;
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 无人机状态获取
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
/// <returns></returns>
|
|
public async Task<ResData> getDroneStatus(string deviceid)
|
|
{
|
|
ResData Response = new ResData();
|
|
string data = "{\r\n\"code\": 200,\r\n\"data\": {\r\n\"mode_code\":0,\r\n\"longitude\":122.45,\r\n\"latitude\":30.45,\r\n\"height\":80,\r\n\"elevation\":50,\r\n\"gimbal_pitch\":-45,\r\n\"gimbal_yaw\":23,\r\n\"battery_capacity_percent\":35,\r\n\"gps_state\":2,\r\n},\r\n\"message\": \"获取无人机机场状态成功！\",\r\n\"traceid\": \"xxx\"\r\n}";
|
|
//todo deviceid
|
|
if (true)
|
|
{
|
|
string x_lc_secret = _helper.getxseret();
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(data);
|
|
var encryptedResData = _helper.Encrypt(bytes);
|
|
Response.Result = encryptedResData;
|
|
Response.Message = "获取无人机机场状态成功！";
|
|
Response.Code = 200;
|
|
Response.Secret = x_lc_secret;
|
|
return Response;
|
|
}
|
|
else
|
|
{
|
|
string x_lc_secret = _helper.getxseret();
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(" ");
|
|
|
|
var encryptedResData = _helper.Encrypt(bytes);
|
|
Response.Result = encryptedResData;
|
|
Response.Message = "获取无人机机场状态失败！";
|
|
Response.Code = 500;
|
|
Response.Secret = x_lc_secret;
|
|
return Response;
|
|
}
|
|
|
|
}
|
|
/// <summary>
|
|
/// 无人机任务查询
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
/// <returns></returns>
|
|
public async Task<ResData> queryTaskStatus(string req, string secret)
|
|
{
|
|
ResData Response = new ResData();
|
|
|
|
//解密数据
|
|
byte[] secretbyte = Convert.FromBase64String(secret); //x-lc-secret
|
|
byte[] reqbyte = Convert.FromBase64String(req); //返回数据
|
|
string data = _helper.Decrypt(secretbyte, reqbyte);
|
|
|
|
//序列化返回数据并处理
|
|
var task = JsonSerializer.Deserialize<AirPortTaskReq>(data);
|
|
string sql = "select * from drone_docktask where taskid=" + data;
|
|
|
|
|
|
string x_lc_secret = _helper.getxseret();
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(sql);
|
|
var encryptedResData = _helper.Encrypt(bytes);
|
|
Response.Result = encryptedResData;
|
|
Response.Message = "查询无人机机场任务状态成功！";
|
|
Response.Code = 200;
|
|
Response.Secret = x_lc_secret;
|
|
return Response;
|
|
|
|
|
|
}
|
|
/// <summary>
|
|
/// 无人机机场设备注册/更新
|
|
/// </summary>
|
|
/// <param name="req"></param>
|
|
/// <returns></returns>
|
|
public async Task<Response<string>> reportDroneStatus(List<AirPortStatusApply> req)
|
|
{
|
|
Response<string> Response = new Response<string>();
|
|
|
|
var handler = new HttpClientHandler();
|
|
// 如果需要忽略服务器证书错误（仅测试环境）
|
|
handler.ServerCertificateCustomValidationCallback = (sender, cert, chain, sslPolicyErrors) => true;
|
|
using (var client = new HttpClient())
|
|
{
|
|
try
|
|
{
|
|
string url = configuration.GetSection("DroneDocking:Url").Value + "/droneAirport/reportDroneStatus";
|
|
string x_lc_secret = _helper.getxseret();
|
|
string centercode = "UAV32_LJY2FPMYDE6UDES3P3ZD7V3IKQ";
|
|
string x_token = _helper.GetToken(centercode);
|
|
|
|
// 序列化为 JSON 字符串
|
|
string json = JsonSerializer.Serialize(req);
|
|
|
|
// 转换为字节数组
|
|
byte[] bytes = Encoding.UTF8.GetBytes(json);
|
|
|
|
var encryptedData = _helper.Encrypt(bytes);
|
|
// 创建请求体
|
|
var httpContent = new StringContent(encryptedData, Encoding.UTF8, "application/json");
|
|
|
|
// 添加请求头
|
|
client.DefaultRequestHeaders.Add("x-lc-secret", x_lc_secret);
|
|
client.DefaultRequestHeaders.Add("x-lc-token", x_token);
|
|
|
|
//发送请求
|
|
HttpResponseMessage response = await client.PostAsync(url, httpContent);
|
|
response.EnsureSuccessStatusCode();
|
|
|
|
// 获取响应头中的 x_cl_screte 参数
|
|
string resx_cl_screte = GetHeaderValue(response, "x-lc-secret");
|
|
|
|
// 读取响应内容并反序列化
|
|
string responseBody = await response.Content.ReadAsStringAsync();
|
|
var result = JsonSerializer.Deserialize<ReciveData<string>>(responseBody);
|
|
|
|
//解密数据
|
|
byte[] resbytesx = Convert.FromBase64String(resx_cl_screte);
|
|
byte[] resdatabytes = Convert.FromBase64String(result?.data);
|
|
string data = _helper.Decrypt(resbytesx, resdatabytes);
|
|
|
|
Response.Result = data;
|
|
Response.Message = result.message;
|
|
Response.Code = result.code;
|
|
}
|
|
catch (HttpRequestException e)
|
|
{
|
|
Console.WriteLine("\nException Caught!");
|
|
Console.WriteLine("Message :{0} ", e.Message);
|
|
Response.Result = "连接错误";
|
|
}
|
|
}
|
|
|
|
return Response;
|
|
}
|
|
|
|
// 安全获取响应头值的方法
|
|
private static string GetHeaderValue(HttpResponseMessage response, string headerName)
|
|
{
|
|
if (response.Headers.TryGetValues(headerName, out IEnumerable<string> values))
|
|
{
|
|
return string.Join(", ", values); // 如果多个值则合并
|
|
}
|
|
|
|
// 尝试忽略大小写再次查找
|
|
foreach (var header in response.Headers)
|
|
{
|
|
if (header.Key.Equals(headerName, StringComparison.OrdinalIgnoreCase))
|
|
{
|
|
return string.Join(", ", header.Value);
|
|
}
|
|
}
|
|
|
|
return null; // 未找到
|
|
}
|
|
|
|
//获取省对接任务信息
|
|
public async Task<Response<PageInfo<List<DroneDockRes>>>> GetDroneDockInfos(string keyWord, int page, int limit)
|
|
{
|
|
RefAsync<int> totalCount = 0;
|
|
var info = await base.Repository.AsQueryable()
|
|
.WhereIF(!string.IsNullOrEmpty(keyWord), t => t.taskname.Contains(keyWord)||t.bizidname.Contains(keyWord))
|
|
.Select(t=>new DroneDockRes
|
|
{
|
|
id= t.id,
|
|
bizidname= t.bizidname,
|
|
taskname= t.taskname,
|
|
createtime= t.createtime,
|
|
state= t.state,
|
|
datacode= t.datacode,
|
|
deviceid= t.deviceid,
|
|
taskid= t.taskid,
|
|
tasklist=SqlFunc.Subqueryable<DroneDocktaskdetail>().Where(r=>r.taskid==t.id).ToList()
|
|
})
|
|
.ToPageListAsync(page, limit, totalCount);
|
|
return new Response<PageInfo<List<DroneDockRes>>>
|
|
{
|
|
Result = new PageInfo<List<DroneDockRes>>
|
|
{
|
|
Items = info,
|
|
Total = totalCount
|
|
}
|
|
};
|
|
}
|
|
|
|
//获取飞行数据
|
|
public async Task<Response<DroneDockflightRes>> GetDroneDockflightInfos(string taskid)
|
|
{
|
|
DroneDockflightRes res=new DroneDockflightRes();
|
|
var detailinfo=await Repository.ChangeRepository<SugarRepositiry<DroneDocktaskdetail>>()
|
|
.AsQueryable()
|
|
.Where(r=>r.flighttaskid==taskid)
|
|
.ToListAsync();
|
|
if (detailinfo.Count > 0)
|
|
{
|
|
var taskId= detailinfo[0].taskid;
|
|
var taskinfo = await Repository.AsQueryable().Where(r => r.id == taskId).FirstAsync();
|
|
var flighttaskinfo= await Repository.ChangeRepository<SugarRepositiry<LasaTask>>()
|
|
.AsQueryable()
|
|
.Where(r => r.FlightId == taskid)
|
|
.FirstAsync();
|
|
if (taskinfo != null)
|
|
{
|
|
res.bizidname = taskinfo.bizidname;
|
|
res.taskname = taskinfo.taskname;
|
|
}
|
|
res.tasklist = detailinfo;
|
|
if(flighttaskinfo != null)
|
|
{
|
|
res.taskExecuteTime =Convert.ToDateTime(flighttaskinfo.ExecuteTime).ToString("yyyy-MM-dd HH:mm:ss");
|
|
res.waylineName=flighttaskinfo.TaskAirLineName;
|
|
res.flightTaskType=Convert.ToInt32(flighttaskinfo.FlightTaskType);
|
|
switch (flighttaskinfo.Status)
|
|
{
|
|
case 0:
|
|
res.flightTaskState = 1;
|
|
break;
|
|
|
|
case 1:
|
|
res.flightTaskState = 2;
|
|
break;
|
|
|
|
case 2:
|
|
res.flightTaskState = 3;
|
|
break;
|
|
|
|
case 5:
|
|
res.flightTaskState = 0;
|
|
break;
|
|
case null: //交集
|
|
res.flightTaskState = 4;
|
|
break;
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
return new Response<DroneDockflightRes>
|
|
{
|
|
Result = res
|
|
};
|
|
}
|
|
|
|
}
|
|
}
|