|
|
|
@ -819,6 +819,9 @@ public class ConfigSubscribe : IJob
|
|
|
|
|
{
|
|
|
|
|
Id = taskAssignExecute.TaskId,
|
|
|
|
|
};
|
|
|
|
|
var flyTask = await _sqlSugarClient.Queryable<LasaTask>()
|
|
|
|
|
.Where(x => x.Id == taskAssignExecute.TaskId)
|
|
|
|
|
.FirstAsync();
|
|
|
|
|
if (code != 0)
|
|
|
|
|
{
|
|
|
|
|
var errorMsg = ErrorMap[code];
|
|
|
|
@ -835,6 +838,21 @@ public class ConfigSubscribe : IJob
|
|
|
|
|
Console.WriteLine($"任务执行响应 {code} {message}");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// if 查看是否是部级飞行任务
|
|
|
|
|
// todo 先得到部级任务id , 然后查看有哪些任务 ,是否全部完成
|
|
|
|
|
var detail = await _sqlSugarClient.Queryable<DroneDocktaskdetail>()
|
|
|
|
|
.Where(x => x.flighttaskid == taskAssignExecute.FlightId)
|
|
|
|
|
.FirstAsync();
|
|
|
|
|
if (detail != null)
|
|
|
|
|
{
|
|
|
|
|
var droneTask = new DroneDocktask()
|
|
|
|
|
{
|
|
|
|
|
id = detail.taskid,
|
|
|
|
|
state = 1
|
|
|
|
|
};
|
|
|
|
|
await _sqlSugarClient.Updateable(droneTask).IgnoreNullColumns().ExecuteCommandAsync();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
await _sqlSugarClient.Updateable(taskRecordExecute).IgnoreNullColumns().ExecuteCommandAsync();
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|