|
|
|
@ -204,16 +204,18 @@ public class ConfigSubscribe : IJob
|
|
|
|
|
case "file_upload_callback":
|
|
|
|
|
// 文件上传
|
|
|
|
|
int flightType = int.Parse(data.flight_task.flight_type);
|
|
|
|
|
if (flightType == 1)
|
|
|
|
|
if (flightType == 1) // 不处理一键起飞媒体信息
|
|
|
|
|
{
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
string flightId = data.file.ext.flight_id;
|
|
|
|
|
string taskId = _manageApp.GetTaskAssignByFlightId(flightId).TaskId;
|
|
|
|
|
var fileUpload = new LasaMediaFile()
|
|
|
|
|
{
|
|
|
|
|
Id = Guid.NewGuid().ToString(),
|
|
|
|
|
FlightId = flightId,
|
|
|
|
|
FlightId = flightId, // 计划id
|
|
|
|
|
TaskId = taskId, // 任务id
|
|
|
|
|
DroneModelKey = data.file.ext.drone_model_key,
|
|
|
|
|
IsOriginal = data.file.ext.is_original,
|
|
|
|
|
MediaIndex = data.file.ext.media_index,
|
|
|
|
@ -231,7 +233,7 @@ public class ConfigSubscribe : IJob
|
|
|
|
|
await _sqlSugarClient.Insertable(fileUpload).ExecuteCommandAsync();
|
|
|
|
|
var expectFileCount = data.flight_task.expected_file_count;
|
|
|
|
|
var uploadedFileCount = data.flight_task.uploaded_file_count;
|
|
|
|
|
string taskId = _manageApp.GetTaskAssignByFlightId(flightId).TaskId;
|
|
|
|
|
|
|
|
|
|
var taskRecord = new LasaTask()
|
|
|
|
|
{
|
|
|
|
|
Id = taskId,
|
|
|
|
|