main
洁 任
2 months ago
commit
01b87dbbf2
@ -0,0 +1,105 @@
|
||||
using Infrastructure;
|
||||
using OpenAuth.App.BaseApp.Base;
|
||||
using OpenAuth.App.Interface;
|
||||
using OpenAuth.Repository;
|
||||
using OpenAuth.Repository.Domain;
|
||||
using SqlSugar;
|
||||
|
||||
namespace OpenAuth.App.ServiceApp;
|
||||
|
||||
public class LasaAircraftServiceApp : SqlSugarBaseApp<LasaAircraft, SugarDbContext>
|
||||
{
|
||||
public LasaAircraftServiceApp(ISugarUnitOfWork<SugarDbContext> unitWork,
|
||||
ISimpleClient<LasaAircraft> repository, IAuth auth) : base(unitWork, repository, auth)
|
||||
{
|
||||
}
|
||||
|
||||
public async Task<Response<bool>> AddLasaAircraft(LasaAircraft info)
|
||||
{
|
||||
info.Id = Guid.NewGuid().ToString();
|
||||
info.CreateTime = DateTime.Now;
|
||||
if (await Repository.InsertAsync(info))
|
||||
{
|
||||
return new Response<bool>
|
||||
{
|
||||
Result = true,
|
||||
Message = "添加成功"
|
||||
};
|
||||
}
|
||||
|
||||
return new Response<bool>
|
||||
{
|
||||
Result = false,
|
||||
Message = "添加失败"
|
||||
};
|
||||
}
|
||||
|
||||
public async Task<Response<bool>> DeleteLasaAircraft(string id)
|
||||
{
|
||||
if (await Repository.DeleteByIdAsync(id))
|
||||
{
|
||||
return new Response<bool>
|
||||
{
|
||||
Result = true,
|
||||
Message = "删除成功"
|
||||
};
|
||||
}
|
||||
|
||||
return new Response<bool>
|
||||
{
|
||||
Result = false,
|
||||
Message = "删除失败"
|
||||
};
|
||||
}
|
||||
|
||||
public async Task<Response<bool>> UpdateLasaAircraft(LasaAircraft info)
|
||||
{
|
||||
info.UpdateTime = DateTime.Now;
|
||||
// 使用Updateable方法来避免空值更新问题
|
||||
using (var db = Repository.AsSugarClient())
|
||||
{
|
||||
var result = await Repository.AsSugarClient().Updateable(info).IgnoreNullColumns().ExecuteCommandAsync();
|
||||
if (result > 0)
|
||||
{
|
||||
return new Response<bool>
|
||||
{
|
||||
Result = true,
|
||||
Message = "修改成功"
|
||||
};
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
return new Response<bool>
|
||||
{
|
||||
Result = false,
|
||||
Message = "修改失败"
|
||||
};
|
||||
}
|
||||
|
||||
public async Task<Response<PageInfo<IEnumerable<LasaAircraft>>>> GetLasaAircraftList(string key, int page,
|
||||
int limit)
|
||||
{
|
||||
RefAsync<int> totalCount = 0;
|
||||
var pageList = await Repository.AsQueryable()
|
||||
.WhereIF(!string.IsNullOrEmpty(key), x => x.Name.Contains(key) || x.Sn.Contains(key))
|
||||
.ToPageListAsync(page, limit, totalCount);
|
||||
|
||||
return new Response<PageInfo<IEnumerable<LasaAircraft>>>
|
||||
{
|
||||
Result = new PageInfo<IEnumerable<LasaAircraft>>
|
||||
{
|
||||
Items = pageList,
|
||||
Total = totalCount
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
public async Task<Response<LasaAircraft>> GetLasaAircraft(string id)
|
||||
{
|
||||
return new Response<LasaAircraft>
|
||||
{
|
||||
Result = await Repository.GetByIdAsync(id)
|
||||
};
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,77 @@
|
||||
using SqlSugar;
|
||||
|
||||
namespace OpenAuth.Repository.Domain
|
||||
{
|
||||
/// <summary>
|
||||
/// 任务历史记录实体类
|
||||
/// </summary>
|
||||
[SugarTable("lasa_task_history")]
|
||||
public class LasaTaskHistory
|
||||
{
|
||||
/// <summary>
|
||||
/// 主键ID
|
||||
/// </summary>
|
||||
[SugarColumn(IsPrimaryKey = true, ColumnName = "Id")]
|
||||
public string Id { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 任务名称
|
||||
/// </summary>
|
||||
public string TaskName { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 任务状态 0-待执行任务 1-任务执行中 2-任务执行失败 5-任务成功
|
||||
/// </summary>
|
||||
public short? Status { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 任务id
|
||||
/// </summary>
|
||||
public string TaskId { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 任务执行时间
|
||||
/// </summary>
|
||||
public System.DateTime? ExecuteTime { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 任务完成时间
|
||||
/// </summary>
|
||||
public System.DateTime? CompletedTime { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 执行时长（秒）
|
||||
/// </summary>
|
||||
public long? ActualExecuteDuration { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 期望文件数量
|
||||
/// </summary>
|
||||
public int? ExpectedFileCount { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 已上传文件数量
|
||||
/// </summary>
|
||||
public int? UploadedFileCount { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 失败原因
|
||||
/// </summary>
|
||||
public string Reason { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 任务id 大疆使用
|
||||
/// </summary>
|
||||
public string FlightId { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 部级任务id
|
||||
/// </summary>
|
||||
public string ExternalTaskId { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 断点信息
|
||||
/// </summary>
|
||||
public string BreakPoint { get; set; }
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,79 @@
|
||||
using Infrastructure;
|
||||
using Microsoft.AspNetCore.Mvc;
|
||||
using OpenAuth.App.ServiceApp;
|
||||
using OpenAuth.Repository.Domain;
|
||||
|
||||
namespace OpenAuth.WebApi.Controllers.ServiceControllers;
|
||||
|
||||
/// <summary>
|
||||
/// 大飞机信息
|
||||
/// </summary>
|
||||
[Route("api/[controller]/[action]")]
|
||||
[ApiController]
|
||||
public class LasaAircraftController : ControllerBase
|
||||
{
|
||||
private readonly LasaAircraftServiceApp _app;
|
||||
|
||||
public LasaAircraftController(LasaAircraftServiceApp app)
|
||||
{
|
||||
_app = app;
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 添加大飞机信息
|
||||
/// </summary>
|
||||
/// <param name="info"></param>
|
||||
/// <returns></returns>
|
||||
[HttpPost]
|
||||
public async Task<Response<bool>> AddLasaAircraft(LasaAircraft info)
|
||||
{
|
||||
return await _app.AddLasaAircraft(info);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 删除大飞机信息
|
||||
/// </summary>
|
||||
/// <param name="id"></param>
|
||||
/// <returns></returns>
|
||||
[HttpPost]
|
||||
public async Task<Response<bool>> DeleteLasaAircraft(string id)
|
||||
{
|
||||
return await _app.DeleteLasaAircraft(id);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 修改大飞机信息
|
||||
/// </summary>
|
||||
/// <param name="info"></param>
|
||||
/// <returns></returns>
|
||||
[HttpPost]
|
||||
public async Task<Response<bool>> UpdateLasaAircraft(LasaAircraft info)
|
||||
{
|
||||
return await _app.UpdateLasaAircraft(info);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 获取大飞机信息列表
|
||||
/// </summary>
|
||||
/// <param name="key"></param>
|
||||
/// <param name="page"></param>
|
||||
/// <param name="limit"></param>
|
||||
/// <returns></returns>
|
||||
[HttpGet]
|
||||
public async Task<Response<PageInfo<IEnumerable<LasaAircraft>>>> GetLasaAircraftList(
|
||||
[FromQuery] string key, [FromQuery] int page = 1, [FromQuery] int limit = 10)
|
||||
{
|
||||
return await _app.GetLasaAircraftList(key, page, limit);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 获取大飞机信息详情
|
||||
/// </summary>
|
||||
/// <param name="id"></param>
|
||||
/// <returns></returns>
|
||||
[HttpGet]
|
||||
public async Task<Response<LasaAircraft>> GetLasaAircraft(string id)
|
||||
{
|
||||
return await _app.GetLasaAircraft(id);
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue