From e0b3df2463fc78841a45357067f6ef7a7da6d3e1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E4=BC=9F?= <421281095@qq.com>
Date: Fri, 18 Jul 2025 14:23:28 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AA=92=E4=BD=93=E5=9B=9E=E4=BC=A0=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ServiceApp/Subscribe/ConfigSubscribe.cs         | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)

diff --git a/OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs b/OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs
index c69f232..2e80ecf 100644
--- a/OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs
+++ b/OpenAuth.App/ServiceApp/Subscribe/ConfigSubscribe.cs
@@ -206,12 +206,6 @@ public class ConfigSubscribe : IJob
                         Console.WriteLine("进入文件上传处理");
                         Console.WriteLine($"文件上传处理：{message}");
                         int flightType = data.flight_task.flight_type;
-                        /*if (flightType == 1) // 不处理一键起飞媒体信息
-                        {
-                            // todo 后续可能要存
-                            break;
-                        }*/
-
                         string flightId = data.file.ext.flight_id;
                         var taskAssign = _manageApp.GetTaskAssignByFlightId(flightId);
                         var taskId = taskAssign.TaskId;
@@ -220,10 +214,10 @@ public class ConfigSubscribe : IJob
                             .SingleAsync(a => a.Id == taskId);
                         string objectKey = data.file.object_key;
                         var folderKey = ((string)data.file.object_key).Split("/");
-                        var parentKey = folderKey[^2];
+                        var parentKey = folderKey[2];
                         var isExist = await _sqlSugarClient
                             .Queryable<LasaMediaFile>()
-                            .Where(x => x.ObjectKey.Equals(parentKey)).CountAsync();
+                            .Where(x => x.Name.Equals(parentKey)).CountAsync();
                         if (isExist == 0)
                         {
                             var parents = new List<LasaMediaFile>(3);
@@ -233,6 +227,7 @@ public class ConfigSubscribe : IJob
                                 FlightId = flightId,
                                 TaskId = taskId,
                                 ParentKey = "",
+                                Name = folderKey[0],
                                 WorkspaceId = executeTask.WorkspaceId,
                                 Level = 1,
                             };
@@ -243,6 +238,7 @@ public class ConfigSubscribe : IJob
                                 FlightId = flightId,
                                 TaskId = taskId,
                                 ParentKey = folderKey[0],
+                                Name = folderKey[1],
                                 WorkspaceId = executeTask.WorkspaceId,
                                 Level = 2,
                             };
@@ -253,6 +249,7 @@ public class ConfigSubscribe : IJob
                                 FlightId = flightId,
                                 TaskId = taskId,
                                 ParentKey = folderKey[1],
+                                Name = folderKey[2],
                                 WorkspaceId = executeTask.WorkspaceId,
                                 Level = 3,
                             };